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

Update adapter command to send group config event

Browse Source 
1. Add message type MSG_EVENT_ADD_GRP_CONFIG,
     MSG_EVENT_UPDATE_GRP_CONFIG, MSG_EVENT_DEL_GRP_CONFIG
  2. Send the corresponding message when add/update/del group config
This commit is contained in:
eeff
2022-01-19 10:12:28 +08:00
committed by Parker Liu
parent b1cfb43096
commit c0f90596f4
2 changed files with 37 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/adapter/adapter.c
+34 -13
View File
@@ -39,6 +39,7 @@
#include "neu_plugin.h"
#include "neu_plugin_info.h"
#include "neu_subscribe.h"
#include "neu_tag_group_config.h"
#include "persist/persist.h"
#define to_node_id(adapter, id) \
@@ -877,27 +878,47 @@ static int adapter_command(neu_adapter_t *adapter, neu_request_t *cmd,
case NEU_REQRESP_ADD_GRP_CONFIG: {
ADAPTER_RESP_CODE(
adapter, cmd, intptr_t, neu_cmd_add_grp_config_t, rv,
NEU_REQRESP_ERR_CODE, p_result,
{ ret = neu_manager_add_grp_config(adapter->manager, req_cmd); });
NEU_REQRESP_ERR_CODE, p_result, {
neu_taggrp_cfg_ref(req_cmd->grp_config);
ret = neu_manager_add_grp_config(adapter->manager, req_cmd);
if (0 == ret) {
ADAPTER_SEND_BUF(adapter, rv, MSG_EVENT_ADD_GRP_CONFIG,
req_cmd, sizeof(*req_cmd));
}
});
break;
}
case NEU_REQRESP_DEL_GRP_CONFIG: {
ADAPTER_RESP_CODE(adapter, cmd, intptr_t, neu_cmd_del_grp_config_t, rv,
NEU_REQRESP_ERR_CODE, p_result, {
ret = neu_manager_del_grp_config(
adapter->manager, req_cmd->node_id,
req_cmd->config_name);
});
ADAPTER_RESP_CODE(
adapter, cmd, intptr_t, neu_cmd_del_grp_config_t, rv,
NEU_REQRESP_ERR_CODE, p_result, {
ret = neu_manager_del_grp_config(
adapter->manager, req_cmd->node_id, req_cmd->config_name);
if (0 == ret) {
neu_cmd_del_grp_config_t event = {};
event.node_id = req_cmd->node_id;
event.config_name = strdup(req_cmd->config_name);
if (NULL != event.config_name) {
ADAPTER_SEND_BUF(adapter, rv, MSG_EVENT_DEL_GRP_CONFIG,
&event, sizeof(event));
}
}
});
break;
}
case NEU_REQRESP_UPDATE_GRP_CONFIG: {
ADAPTER_RESP_CODE(adapter, cmd, intptr_t, neu_cmd_update_grp_config_t,
rv, NEU_REQRESP_ERR_CODE, p_result, {
ret = neu_manager_update_grp_config(
adapter->manager, req_cmd);
});
ADAPTER_RESP_CODE(
adapter, cmd, intptr_t, neu_cmd_update_grp_config_t, rv,
NEU_REQRESP_ERR_CODE, p_result, {
neu_taggrp_cfg_ref(req_cmd->grp_config);
ret = neu_manager_update_grp_config(adapter->manager, req_cmd);
if (0 == ret) {
ADAPTER_SEND_BUF(adapter, rv, MSG_EVENT_UPDATE_GRP_CONFIG,
req_cmd, sizeof(*req_cmd));
}
});
break;
}
src/core/message.h
+3
View File
@@ -64,6 +64,9 @@ typedef enum msg_type {
MSG_EVENT_UPDATE_NODE,
MSG_EVENT_SET_NODE_SETTING,
MSG_EVENT_DEL_NODE,
MSG_EVENT_ADD_GRP_CONFIG,
MSG_EVENT_UPDATE_GRP_CONFIG,
MSG_EVENT_DEL_GRP_CONFIG,
MSG_EVENT_ADD_PLUGIN,
MSG_EVENT_UPDATE_PLUGIN,
MSG_EVENT_DEL_PLUGIN,