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

Add function neu_system_ref_group_config for reference a special group config

Browse Source
This commit is contained in:
Parker Liu
2021-11-26 18:36:21 +08:00
parent 906b9c053c
commit dfeb5fb4a7
2 changed files with 26 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
include/neu_plugin.h
+3
View File
@@ -90,6 +90,9 @@ intptr_t neu_system_update_group_config(neu_plugin_t * plugin,
neu_taggrp_config_t *neu_system_find_group_config(neu_plugin_t *plugin,
neu_node_id_t node_id,
const char * name);
neu_taggrp_config_t *neu_system_ref_group_config(neu_plugin_t *plugin,
neu_node_id_t node_id,
const char * name);
// uninit vector
vector_t neu_system_get_group_configs(neu_plugin_t *plugin,
neu_node_id_t node_id);
src/base/neu_plugin_common.c
+23 -1
View File
@@ -406,6 +406,28 @@ neu_taggrp_config_t *neu_system_find_group_config(neu_plugin_t *plugin,
return find_config;
}
neu_taggrp_config_t *neu_system_ref_group_config(neu_plugin_t *plugin,
neu_node_id_t node_id,
const char * name)
{
vector_t grp_configs = neu_system_get_group_configs(plugin, node_id);
neu_taggrp_config_t *find_config = NULL;
VECTOR_FOR_EACH(&grp_configs, iter)
{
neu_taggrp_config_t *config =
*(neu_taggrp_config_t **) iterator_get(&iter);
if (strncmp(neu_taggrp_cfg_get_name(config), name, strlen(name)) == 0) {
find_config = config;
break;
}
}
vector_uninit(&grp_configs);
return neu_taggrp_cfg_ref(find_config);
}
int neu_plugin_tag_count_by_attribute(neu_taggrp_config_t *grp_config,
neu_datatag_table_t *tag_table,
neu_attribute_e attribute)
@@ -498,4 +520,4 @@ vector_t *neu_system_get_sub_group_configs(neu_plugin_t *plugin,
neu_reqresp_sub_grp_configs_t,
{ sub_group_configs = resp->sub_grp_configs; })
return sub_group_configs;
}
}