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

Update adapter loop to handle tags add/del/update events

Browse Source
This commit is contained in:
eeff
2022-01-21 18:58:34 +08:00
committed by Parker Liu
parent 7d1fc986c9
commit fa657e79d7
1 changed files with 47 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/adapter/adapter.c
+47
View File
@@ -472,6 +472,39 @@ static int persister_singleton_handle_grp_config(neu_adapter_t *adapter,
return rv;
}
static int persister_singleton_handle_datatags(neu_adapter_t *adapter,
neu_node_id_t node_id,
const char * grp_config_name)
{
neu_persister_t *persister = persister_singleton_get();
char * adapter_name = NULL;
int rv = neu_manager_get_node_name_by_id(adapter->manager, node_id,
&adapter_name);
if (0 != rv) {
return rv;
}
vector_t *datatag_infos = NULL;
rv = neu_manager_get_persist_datatag_infos(adapter->manager, node_id,
grp_config_name, &datatag_infos);
if (0 != rv) {
log_error("%s fail get persist datatag infos", adapter->name);
free(adapter_name);
return rv;
}
rv = neu_persister_store_datatags(persister, adapter_name, grp_config_name,
datatag_infos);
if (0 != rv) {
log_error("%s fail store adapter:% grp:%s datatag infos", adapter_name,
grp_config_name);
}
neu_persist_datatag_infos_free(datatag_infos);
free(adapter_name);
return rv;
}
neu_plugin_running_state_e
neu_adapter_state_to_plugin_state(neu_adapter_t *adapter)
{
@@ -672,6 +705,20 @@ static void adapter_loop(void *arg)
break;
}
case MSG_EVENT_ADD_TAGS:
// fall through
case MSG_EVENT_UPDATE_TAGS:
// fall through
case MSG_EVENT_DEL_TAGS: {
neu_event_tags_t *event = msg_get_buf_ptr(pay_msg);
persister_singleton_handle_datatags(adapter, event->node_id,
event->grp_config_name);
free(event->grp_config_name);
break;
}
case MSG_EVENT_ADD_PLUGIN:
// fall through