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

Send a exit message to a node that should be stoped

Browse Source
This commit is contained in:
Parker Liu
2021-11-23 12:14:53 +08:00
parent d50220724a
commit be83f83101
2 changed files with 10 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
plugins/sample/plugin_sample_app.c
+7
View File
@@ -305,6 +305,13 @@ get_grp_configs_retry:
neu_dvalue_free(write_val);
neu_taggrp_cfg_free(grp_config);
usleep(500000);
log_info("Stop a node(%d)", dst_node_id);
neu_plugin_node_ctl(plugin, dst_node_id, NEU_ADAPTER_CTL_STOP);
usleep(500000);
log_info("Restart a node(%d)", dst_node_id);
neu_plugin_node_ctl(plugin, dst_node_id, NEU_ADAPTER_CTL_START);
return NULL;
}
src/core/neu_manager.c
+3 -2
View File
@@ -658,6 +658,7 @@ int neu_manager_stop_adapter(neu_manager_t *manager, neu_adapter_t *adapter)
buf_ptr = msg_get_buf_ptr(pay_msg);
*(uint32_t *) buf_ptr = 0; // exit_code is 0
manager_bind_info_t *manager_bind = &manager->bind_info;
nng_msg_set_pipe(msg, msg_pipe);
nng_sendmsg(manager_bind->mng_sock, msg, 0);
stop_adapter:
@@ -1939,7 +1940,7 @@ int neu_manager_adapter_ctl(neu_manager_t *manager, neu_node_id_t node_id,
break;
case NEU_PLUGIN_RUNNING_STATE_READY:
case NEU_PLUGIN_RUNNING_STATE_STOPPED:
// ret = neu_manager_start_adapter(manager, adapter);
ret = neu_manager_start_adapter(manager, adapter);
ret = 0;
break;
case NEU_PLUGIN_RUNNING_STATE_RUNNING:
@@ -1954,7 +1955,7 @@ int neu_manager_adapter_ctl(neu_manager_t *manager, neu_node_id_t node_id,
ret = -1;
break;
case NEU_PLUGIN_RUNNING_STATE_RUNNING:
// ret = neu_manager_stop_adapter(manager, adapter);
ret = neu_manager_stop_adapter(manager, adapter);
ret = 0;
break;
case NEU_PLUGIN_RUNNING_STATE_STOPPED: