From e4cb33f25012c534f0582d485c4f491f9dd3cd25 Mon Sep 17 00:00:00 2001
From: zhangmeng <775834166@qq.com>
Date: 星期日, 29 一月 2023 09:26:26 +0800
Subject: [PATCH] bug fixed query_proc
---
src/common.h | 13 +++++++++----
1 files changed, 9 insertions(+), 4 deletions(-)
diff --git a/src/common.h b/src/common.h
index 947fea7..ea15849 100644
--- a/src/common.h
+++ b/src/common.h
@@ -17,17 +17,20 @@
namespace nng_wrap {
-static thread_local std::string verbose_info{};
+#define TAG
+#define PRNTVITAG(args)
+
+/*
#ifndef PRNTVITAG
+static thread_local std::string verbose_info{};
#define TAG do{ verbose_info.clear(); \
verbose_info=string("function [")+__FUNCTION__+string("]"); \
}while(0)
#define PRNTVITAG(msg) do{ \
verbose_info+=string("-> (") + msg + string(")"); \
}while(0)
-// #define TAG
-// #define PRNTVITAG(args)
#endif
+*/
/////////////////////////////////////////////////
enum{
@@ -92,7 +95,7 @@
};
template <class T> using is_callable = typename is_callable_h<std::is_class<typename std::remove_reference<T>::type>::value, typename std::remove_reference<T>::type>::type;
-static constexpr int timeout_req_rep = 5162;
+static constexpr int timeout_req_rep = 6251;
inline void remove_exist(const std::string& url){
if (url.find("ipc://") == 0){
@@ -179,6 +182,7 @@
};
enum { INIT, RECV, WAIT, SEND };
+enum { REPLY_IPC, REPLY_TCP };
struct work {
int state{-1};
nng_aio *aio{};
@@ -186,6 +190,7 @@
nng_ctx ctx{};
void(*cb_recv)(work*){};
void* user_data{};
+ int mode{-1};
};
static const std::string rr_unblocking_msg_{"~!@#$%^&*()-=<<UNBLOCKING>>=-()*&^%$#@!~"};
--
Gitblit v1.8.0