From 13a953a8cb3f0c2e68c17b5962c7ee2c40c2caf8 Mon Sep 17 00:00:00 2001 From: fengzero Date: Wed, 5 Jun 2024 06:29:30 +0000 Subject: [PATCH 1/2] start node if node state is ready --- src/core/manager.c | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/core/manager.c b/src/core/manager.c index fd843520..18b349c6 100644 --- a/src/core/manager.c +++ b/src/core/manager.c @@ -236,7 +236,8 @@ static int manager_loop(enum neu_event_io_type type, int fd, void *usr_data) break; } - if (init->state == NEU_NODE_RUNNING_STATE_RUNNING || + if (init->state == NEU_NODE_RUNNING_STATE_READY || + init->state == NEU_NODE_RUNNING_STATE_RUNNING || init->state == NEU_NODE_RUNNING_STATE_STOPPED) { neu_adapter_t *adapter = neu_node_manager_find(manager->node_manager, init->node); From f9770052c28a9b51893a8416613fb2820110dc00 Mon Sep 17 00:00:00 2001 From: fengzero Date: Wed, 5 Jun 2024 06:36:03 +0000 Subject: [PATCH 2/2] fix init msg state init --- src/core/manager.c | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/src/core/manager.c b/src/core/manager.c index 18b349c6..61569295 100644 --- a/src/core/manager.c +++ b/src/core/manager.c @@ -700,8 +700,9 @@ static int manager_loop(enum neu_event_io_type type, int fd, void *usr_data) } case NEU_REQ_ADD_NODE: { neu_req_add_node_t *cmd = (neu_req_add_node_t *) &header[1]; - int error = neu_manager_add_node(manager, cmd->node, cmd->plugin, - cmd->setting, false, false); + int error = + neu_manager_add_node(manager, cmd->node, cmd->plugin, cmd->setting, + NEU_NODE_RUNNING_STATE_INIT, false); neu_resp_error_t e = { .error = error }; if (error == NEU_ERR_SUCCESS) {