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

Merge pull request #2103 from hxy7yx/v2.8-1

Browse Source 
[v2.8]fix(manager): exit after sending uninit msg failed
This commit is contained in:
fengzeroz
2024-06-14 15:27:31 +08:00
committed by GitHub
parent 8bd802c492 6793c0a1f0
commit 2e05ab4bba
1 changed files with 10 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/core/manager.c
+10 -5
View File
@@ -162,7 +162,8 @@ neu_manager_t *neu_manager_create()
void neu_manager_destroy(neu_manager_t *manager)
{
neu_req_node_init_t uninit = { 0 };
neu_req_node_init_t uninit = { 0 };
int send_msg_success = 1;
UT_array *addrs = neu_node_manager_get_addrs_all(manager->node_manager);
@@ -176,15 +177,19 @@ void neu_manager_destroy(neu_manager_t *manager)
if (0 != neu_send_msg_to(manager->server_fd, addr, msg)) {
nlog_error("manager -> %s uninit msg send fail",
&addr->sun_path[1]);
send_msg_success = 0;
neu_msg_free(msg);
break;
}
}
utarray_free(addrs);
while (1) {
usleep(1000 * 100);
if (neu_node_manager_size(manager->node_manager) == 0) {
break;
if (send_msg_success) {
while (1) {
usleep(1000 * 100);
if (neu_node_manager_size(manager->node_manager) == 0) {
break;
}
}
}