From 438a5decf4cc7049876ce84dc31a47e39719cf15 Mon Sep 17 00:00:00 2001 From: wangzhengquan <wangzhengquan85@126.com> Date: 星期二, 19 一月 2021 09:56:36 +0800 Subject: [PATCH] update --- src/socket/net_mod_socket.cpp | 3 ++- 1 files changed, 2 insertions(+), 1 deletions(-) diff --git a/src/socket/net_mod_socket.cpp b/src/socket/net_mod_socket.cpp index 73be131..6c62bae 100644 --- a/src/socket/net_mod_socket.cpp +++ b/src/socket/net_mod_socket.cpp @@ -345,6 +345,7 @@ if(ret == 0 ) { n_pub_suc++; } + return n_pub_suc; } for (i = 0; i < arrlen; i++) { @@ -374,7 +375,7 @@ } request_head.mod = BUS; memcpy(request_head.host, node->host, sizeof(request_head.host)); - request_head.key = node->key; + request_head.key = SHM_BUS_KEY; request_head.content_length = content_size; request_head.topic_length = strlen(topic) + 1; request_head.timeout = msec; -- Gitblit v1.8.0