GithubStar/neuron
1
0
Fork 0
mirror of https://github.com/emqx/neuron.git synced 2026-10-22 01:05:56 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #568 from fengzeroz/main

Browse Source 
fix(manager): when the neuron exits, the node data is deleted
This commit is contained in:
fengzeroz
2022-06-21 11:15:03 +08:00
committed by GitHub
parent 1c8dfa5729 d05688f9c8
commit eb45c6fc68
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/core/manager.c
+1 -1
View File
@@ -247,6 +247,7 @@ static int manager_loop(enum neu_event_io_type type, int fd, void *usr_data)
strcpy(header->receiver, cmd->node);
if (neu_node_manager_find(manager->node_manager, header->receiver) !=
NULL) {
manager_storage_del_node(manager, cmd->node);
header->type = NEU_REQ_NODE_UNINIT;
forward_msg(manager, msg, header->receiver);
} else {
@@ -261,7 +262,6 @@ static int manager_loop(enum neu_event_io_type type, int fd, void *usr_data)
neu_resp_node_uninit_t *cmd = (neu_resp_node_uninit_t *) &header[1];
neu_manager_del_node(manager, cmd->node);
manager_storage_del_node(manager, cmd->node);
if (strlen(header->receiver) > 0) {
neu_resp_error_t error = { 0 };
header->type = NEU_RESP_ERROR;