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

Merge pull request #591 from fengzeroz/main

Browse Source 
notify app subscribe if neuron restart
This commit is contained in:
fengzeroz
2022-06-24 14:33:57 +08:00
committed by GitHub
parent d807c92227 25ed37c39b
commit 7a44d986df
2 changed files with 11 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/adapter/adapter.c
+6 -3
View File
@@ -557,7 +557,9 @@ static int adapter_loop(enum neu_event_io_type type, int fd, void *usr_data)
}
case NEU_REQ_NODE_UNINIT: {
neu_req_node_uninit_t *cmd = (neu_req_node_uninit_t *) &header[1];
nng_msg * uninit_msg = NULL;
nng_msg * uninit_msg = NULL;
char name[NEU_NODE_NAME_LEN] = { 0 };
char receiver[NEU_NODE_NAME_LEN] = { 0 };
neu_adapter_uninit(adapter);
@@ -567,9 +569,10 @@ static int adapter_loop(enum neu_event_io_type type, int fd, void *usr_data)
strcpy(cmd->node, adapter->name);
uninit_msg = neu_msg_gen(header, cmd);
strcpy(name, adapter->name);
strcpy(receiver, header->receiver);
if (nng_sendmsg(adapter->sock, uninit_msg, 0) == 0) {
nlog_warn("%s send uninit msg to %s", adapter->name,
header->receiver);
nlog_warn("%s send uninit msg to %s", name, receiver);
} else {
nng_msg_free(uninit_msg);
}
src/core/storage.c
+5
View File
@@ -144,6 +144,11 @@ int manager_load_subscribe(neu_manager_t *manager)
nlog_info("%s load subscription app:%s driver:%s grp:%s",
ok_or_err, info->sub_adapter_name,
info->src_adapter_name, info->group_config_name);
if (rv == 0) {
neu_manager_notify_app_sub_update(manager,
info->src_adapter_name,
info->group_config_name);
}
}
neu_persist_subscription_infos_free(sub_infos);