lichao
2021-04-14 fa95ddd1a294ebad47cabf9e149ee7d789271044
src/socket.h
@@ -38,7 +38,9 @@
{
   bool SendImpl(const void *valid_remote, const MsgI &imsg, SendQ::OnMsgEvent onExpire = SendQ::OnMsgEvent())
   {
      send_buffer_->Append(*static_cast<const MQId *>(valid_remote), imsg, onExpire);
      // if (!mq().TrySend(*(MQId *) valid_remote, imsg)) {
      send_buffer_.Append(*static_cast<const MQId *>(valid_remote), imsg, onExpire);
      // }
      return true;
   }
@@ -170,7 +172,8 @@
   };
   Synced<AsyncCBs> per_msg_cbs_;
   Synced<SendQ> send_buffer_;
   SendQ send_buffer_;
   // Synced<SendQ> send_buffer_;
};
#endif // end of include guard: SOCKET_GWTJHBPO