From 99816cb1e233c20310068d6fe2761886807ebe4c Mon Sep 17 00:00:00 2001
From: fengzero <fengzero@fengzero.com>
Date: Fri, 31 Dec 2021 01:42:30 +0000
Subject: [PATCH] fix: only when rv==0 and need_forward==1, the unsubscribe
 message is forwarded

---
 src/core/neu_manager.c | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/core/neu_manager.c b/src/core/neu_manager.c
index 66b6e4e2..c04a5883 100644
--- a/src/core/neu_manager.c
+++ b/src/core/neu_manager.c
@@ -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);