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

fix: only when rv==0 and need_forward==1, the unsubscribe message is forwarded

Browse Source
This commit is contained in:
fengzero
2021-12-31 10:22:01 +08:00
committed by Parker Liu
parent 47322c087f
commit 99816cb1e2
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/core/neu_manager.c
+1 -1
View File
@@ -1338,7 +1338,7 @@ static void manager_loop(void *arg)
rv = nng_msg_alloc(&out_msg, msg_size);
need_forward = unsub_grp_config_with_pipe(cmd_ptr->grp_config,
nng_msg_get_pipe(msg));
if (rv == 0 || need_forward == 1) {
if (rv == 0 && need_forward == 1) {
message_t * msg_ptr;
unsubscribe_node_cmd_t *out_cmd_ptr;
msg_ptr = (message_t *) nng_msg_body(out_msg);