From 93ca5ec2e377961d0a7825b6906ee72dfc78480a Mon Sep 17 00:00:00 2001
From: zhangmeng <775834166@qq.com>
Date: 星期三, 15 十二月 2021 11:22:50 +0800
Subject: [PATCH] bug fixed nn_recv
---
src/nng_wrap.cpp | 4 ++--
1 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/src/nng_wrap.cpp b/src/nng_wrap.cpp
index a231ae9..e400da7 100644
--- a/src/nng_wrap.cpp
+++ b/src/nng_wrap.cpp
@@ -235,8 +235,8 @@
if (rc == (int)sndmsg.size()){
char* tmp{};
rc = nn_recv(pub_.socket_, &tmp, NN_MSG, 0);
- nn_freemsg(tmp);
if (rc > 0){
+ nn_freemsg(tmp);
printf("======>> publish topic %s data length %lu\n", msg->topic_.c_str(), msg->data_.size());
lock_guard<mutex> l{pub_.mtx_msg_};
pub_.msg_.pop_front();
@@ -439,8 +439,8 @@
char* tmp{};
int rc = nn_recv(sock, &tmp, NN_MSG, 0);
- nn_freemsg(tmp);
if (rc > 0){
+ nn_freemsg(tmp);
rc = nn_send(sock, msg.data(), msg.size(), 0);
if (rc < 0){
PRNTVITAG("heartbeat survey failed");
--
Gitblit v1.8.0