zhangmeng
2022-01-20 bef24e7b4001c7c7cd7a03a22f8eaf7c8af3c4b7
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){
@@ -140,6 +140,7 @@
    int operator()(){return msg_.size();}
    virtual ~_ps(){
        t_quit_.store(true, std::memory_order_relaxed);
        cv_msg_.notify_all();
        if (t_.joinable()) t_.join();
    }