performance

zhangmeng

2022-01-19 5d7b83d63d1bc58ce3a40aaf7dfdadea39055191

performance

 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){

 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 {