From b4bda4a8e6aa1acf5e161a95642e944e08c72646 Mon Sep 17 00:00:00 2001
From: zhangmeng <775834166@qq.com>
Date: 星期一, 17 一月 2022 18:02:39 +0800
Subject: [PATCH] performance
---
src/nng_wrap.cpp | 6 ++++--
1 files changed, 4 insertions(+), 2 deletions(-)
diff --git a/src/nng_wrap.cpp b/src/nng_wrap.cpp
index d5e1928..be364ee 100644
--- a/src/nng_wrap.cpp
+++ b/src/nng_wrap.cpp
@@ -162,6 +162,7 @@
}
int publish(const std::string& topic, const void* data, const int data_len, void* arg/*=NULL*/){
+ // printf("======>> publish topic %s\n", topic.c_str());
_ps* pub = (_ps*)arg;
if (!pub) pub = singleton<_ps>();
@@ -214,7 +215,7 @@
{
lock_guard<mutex> l{(*sub)()};
for(auto && i : sub->topics_){
- if (i.compare(topic) == 0){
+ if (!!!i.compare(topic)){
msg = move(tmp_msg.substr(i.size()+1));
break;
}
@@ -512,6 +513,7 @@
get<1>(get<1>(rep->socks_)) = port;
ipc = "tcp://0.0.0.0:" + to_string(port);
if(create_server(&get<0>(get<1>(rep->socks_)), ipc, 62, rep) != 0) return -1;
+ printf("======>> create server for remote port %d\n", port);
}else {
get<0>(get<1>(rep->socks_)).id = numeric_limits<int32_t>::max();
}
@@ -564,7 +566,7 @@
return !rep->msg_.empty();
});
if (!status){
- PRNTVITAG("subscribe_read timeout");
+ PRNTVITAG("read_request timeout");
return -1;
}
auto iter = rep->msg_.begin();
--
Gitblit v1.8.0