src/sendq.h
@@ -68,7 +68,7 @@ msg.AddRef(); TimedMsg tmp(expire, MsgInfo{msg, onExpire}); std::unique_lock<std::mutex> lock(mutex_); std::unique_lock<std::mutex> lock(mutex_in_); auto &al = in_[addr]; if (!al.empty()) { al.front().emplace_back(std::move(tmp)); @@ -95,7 +95,8 @@ MsgI &operator*() { return iter_->data().msg_; } }; std::mutex mutex_; std::mutex mutex_in_; std::mutex mutex_out_; Store in_; Store out_; };