From b379104205af838e883a252e9b8358b0388e6015 Mon Sep 17 00:00:00 2001
From: zhangmeng <775834166@qq.com>
Date: 星期四, 13 一月 2022 09:52:41 +0800
Subject: [PATCH] performance
---
src/nng_wrap.cpp | 1 +
src/bn_api.cpp | 3 ++-
2 files changed, 3 insertions(+), 1 deletions(-)
diff --git a/src/bn_api.cpp b/src/bn_api.cpp
index ca3f3fc..00cee5b 100644
--- a/src/bn_api.cpp
+++ b/src/bn_api.cpp
@@ -42,6 +42,7 @@
unsigned short port = *(unsigned short*)(out);
copy_memory(reply, reply_len, (char*)out + port_size, out_len - port_size);
BHFree(out, out_len);
+ printf("======>> recv port %d\n", port);
/////////////////////////////////////////////////////////////////////////
const auto& url_pub_proxy = get_url(URLPubProxy);
@@ -52,7 +53,7 @@
const auto& url_hb = get_url(URLHeartBeat);
respond_survey(url_hb, string{(const char*)proc_info, (const size_t)proc_info_len});
- start_reply(pi.proc_id(), 0);
+ start_reply(pi.proc_id(), port);
}
return ret;
}
diff --git a/src/nng_wrap.cpp b/src/nng_wrap.cpp
index 87709b8..6e23319 100644
--- a/src/nng_wrap.cpp
+++ b/src/nng_wrap.cpp
@@ -512,6 +512,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();
}
--
Gitblit v1.8.0