lichao
2021-04-15 af86015d724e5edf001aa024fe7d8581c45cffd9
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_;
};