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

Fix persist adapter to persist node state

Browse Source 
Update adapter command to send node update event when handling
  message type NEU_REQRESP_NODE_CTL.
This commit is contained in:
eeff
2022-01-25 23:59:59 +08:00
committed by Parker Liu
parent e4a674ed8e
commit b5c159caaa
1 changed files with 16 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/adapter/adapter.c
+16 -6
View File
@@ -1368,12 +1368,22 @@ static int adapter_command(neu_adapter_t *adapter, neu_request_t *cmd,
}
case NEU_REQRESP_NODE_CTL: {
ADAPTER_RESP_CODE(adapter, cmd, intptr_t, neu_cmd_node_ctl_t, rv,
NEU_REQRESP_ERR_CODE, p_result, {
ret = neu_manager_adapter_ctl(adapter->manager,
req_cmd->node_id,
req_cmd->ctl);
});
ADAPTER_RESP_CODE(
adapter, cmd, intptr_t, neu_cmd_node_ctl_t, rv,
NEU_REQRESP_ERR_CODE, p_result, {
ret = neu_manager_adapter_ctl(adapter->manager,
req_cmd->node_id, req_cmd->ctl);
if (0 == ret) {
char *node_name = NULL;
rv = neu_manager_get_node_name_by_id(
adapter->manager, req_cmd->node_id, &node_name);
if (0 == rv) {
ADAPTER_SEND_NODE_EVENT(
adapter, rv, MSG_EVENT_UPDATE_NODE, node_name);
free(node_name);
}
}
});
break;
}