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

Add function neu_manager_adapter_get_grp_config_ref_by_name

Browse Source
This commit is contained in:
eeff
2022-01-30 09:29:15 +08:00
committed by Parker Liu
parent 79476693ba
commit ba479d76aa
2 changed files with 39 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/core/neu_manager.c
+36
View File
@@ -2542,6 +2542,42 @@ int neu_manager_adapter_get_sub_grp_configs(neu_manager_t *manager,
return 0;
}
int neu_manager_adapter_get_grp_config_ref_by_name(
neu_manager_t *manager, neu_node_id_t node_id, const char *grp_config_name,
neu_taggrp_config_t **p_grp_config)
{
int rv = 0;
if (NULL == manager || NULL == grp_config_name || NULL == p_grp_config) {
log_error(
"get nodes with NULL manager, grp_config_name or p_grp_config");
return NEU_ERR_EINVAL;
}
nng_mtx_lock(manager->adapters_mtx);
adapter_id_t adapter_id =
neu_manager_adapter_id_from_node_id(manager, node_id);
adapter_reg_entity_t *reg_entity =
find_reg_adapter_by_id(&manager->reg_adapters, adapter_id);
if (NULL == reg_entity) {
nng_mtx_unlock(manager->adapters_mtx);
return NEU_ERR_NODE_NOT_EXIST;
}
neu_taggrp_config_t *grp_config =
(neu_taggrp_config_t *) neu_datatag_mng_ref_grp_config(
reg_entity->datatag_manager, grp_config_name);
if (NULL != grp_config) {
*p_grp_config = grp_config;
} else {
rv = NEU_ERR_GRP_CONFIG_NOT_EXIST;
}
nng_mtx_unlock(manager->adapters_mtx);
return rv;
}
int neu_manager_get_persist_subscription_infos(neu_manager_t *manager,
neu_node_id_t node_id,
vector_t ** result)
src/core/neu_manager.h
+3
View File
@@ -106,6 +106,9 @@ int neu_manager_uninit_adapter(neu_manager_t *manager, neu_adapter_t *adapter);
int neu_manager_adapter_get_sub_grp_configs(neu_manager_t *manager,
neu_node_id_t node_id,
vector_t ** result_sgc);
int neu_manager_adapter_get_grp_config_ref_by_name(
neu_manager_t *manager, neu_node_id_t node_id, const char *grp_config_name,
neu_taggrp_config_t **p_grp_config);
int neu_manager_init_main_adapter(neu_manager_t * manager,
bind_notify_fun bind_adapter,