From 5d7b83d63d1bc58ce3a40aaf7dfdadea39055191 Mon Sep 17 00:00:00 2001
From: zhangmeng <775834166@qq.com>
Date: 星期三, 19 一月 2022 16:59:58 +0800
Subject: [PATCH] performance

---
 src/nng_wrap.cpp |    4 +++-
 src/common.h     |    2 +-
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git a/src/common.h b/src/common.h
index 947fea7..253d124 100644
--- a/src/common.h
+++ b/src/common.h
@@ -92,7 +92,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){
diff --git a/src/nng_wrap.cpp b/src/nng_wrap.cpp
index be364ee..c8fbaa3 100644
--- a/src/nng_wrap.cpp
+++ b/src/nng_wrap.cpp
@@ -523,11 +523,13 @@
             constexpr int idle = 10;
             const auto data = rr_unblocking_msg_.data();
             const auto data_size = rr_unblocking_msg_.size();
+            constexpr int life_span = timeout_req_rep*10;
+
             auto f = [rep]{
                 vector<struct work*> tmp{};
                 lock_guard<mutex> l{rep->mtx_msg_};
                 for(auto iter = rep->works_.begin(); iter != rep->works_.end();){
-                    if ((iter->second+=idle) > timeout_req_rep){
+                    if ((iter->second+=idle) > life_span){
                         tmp.push_back(iter->second.w_);
                         iter = rep->works_.erase(iter);
                     }else {

--
Gitblit v1.8.0