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

Add function neu_manager_start_adapter_with_id

Browse Source
This commit is contained in:
eeff
2022-01-26 10:43:00 +08:00
committed by Parker Liu
parent 70aa5e2d8c
commit 9ec363e631
2 changed files with 27 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/core/neu_manager.c
+25
View File
@@ -2372,6 +2372,31 @@ int neu_manager_adapter_get_setting(neu_manager_t *manager,
return ret;
}
int neu_manager_start_adapter_with_id(neu_manager_t *manager,
neu_node_id_t node_id)
{
adapter_id_t adapter_id = { 0 };
adapter_reg_entity_t *reg_entity = NULL;
nng_mtx_lock(manager->adapters_mtx);
adapter_id = neu_manager_adapter_id_from_node_id(manager, node_id);
reg_entity = find_reg_adapter_by_id(&manager->reg_adapters, adapter_id);
if (reg_entity == NULL) {
log_error("Can't find matched src registered adapter");
nng_mtx_unlock(manager->adapters_mtx);
return NEU_ERR_NODE_NOT_EXIST;
}
// TODO: this should better be outside of lock
neu_adapter_start(reg_entity->adapter);
nng_mtx_unlock(manager->adapters_mtx);
return NEU_ERR_SUCCESS;
}
int neu_manager_adapter_get_state(neu_manager_t *manager, neu_node_id_t node_id,
neu_plugin_state_t *state)
{
src/core/neu_manager.h
+2
View File
@@ -87,6 +87,8 @@ int neu_manager_adapter_ctl(neu_manager_t *manager, neu_node_id_t node_id,
int neu_manager_get_persist_adapter_infos(neu_manager_t *manager,
vector_t ** result);
int neu_manager_start_adapter(neu_adapter_t *adapter);
int neu_manager_start_adapter_with_id(neu_manager_t *manager,
neu_node_id_t node_id);
int neu_manager_stop_adapter(neu_adapter_t *adapter);
int neu_manager_init_adapter(neu_manager_t *manager, neu_adapter_t *adapter);
int neu_manager_uninit_adapter(neu_manager_t *manager, neu_adapter_t *adapter);