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 {
