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

Update adapter command to send node setting event

Browse Source 
1. Add message type MSG_EVENT_SET_NODE_SETTING
  2. Send the corresponding message when set node setting
This commit is contained in:
eeff
2022-01-13 15:36:00 +08:00
committed by Parker Liu
parent 985c29d0ad
commit 96e2829d92
2 changed files with 17 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/adapter/adapter.c
+16 -6
View File
@@ -1014,12 +1014,22 @@ static int adapter_command(neu_adapter_t *adapter, neu_request_t *cmd,
}
case NEU_REQRESP_SET_NODE_SETTING: {
ADAPTER_RESP_CODE(adapter, cmd, intptr_t, neu_cmd_set_node_setting_t,
rv, NEU_REQRESP_ERR_CODE, p_result, {
ret = neu_manager_adapter_set_setting(
adapter->manager, req_cmd->node_id,
req_cmd->setting);
});
ADAPTER_RESP_CODE(
adapter, cmd, intptr_t, neu_cmd_set_node_setting_t, rv,
NEU_REQRESP_ERR_CODE, p_result, {
ret = neu_manager_adapter_set_setting(
adapter->manager, req_cmd->node_id, req_cmd->setting);
if (ret == 0) {
neu_cmd_set_node_setting_t event = {};
event.node_id = req_cmd->node_id;
event.setting = strdup(req_cmd->setting);
if (NULL != event.setting) {
ADAPTER_SEND_BUF(adapter, rv,
MSG_EVENT_SET_NODE_SETTING, &event,
sizeof(event));
}
}
});
break;
}
src/core/message.h
+1
View File
@@ -62,6 +62,7 @@ typedef enum msg_type {
MSG_EVENT_NODE_PING,
MSG_EVENT_ADD_NODE,
MSG_EVENT_UPDATE_NODE,
MSG_EVENT_SET_NODE_SETTING,
MSG_EVENT_DEL_NODE,
MSG_EVENT_ADD_PLUGIN,
MSG_EVENT_UPDATE_PLUGIN,