lichao
2021-06-01 f7f8fbc85c48b003d1e3094a94a3528001977977
src/shm_socket.h
@@ -47,9 +47,11 @@
   typedef std::function<bool(ShmSocket &sock, MsgI &imsg, BHMsgHead &head)> PartialRecvCB;
   typedef std::function<void(ShmSocket &sock)> IdleCB;
   ShmSocket(Shm &shm, const MQId id, const int len);
   ShmSocket(Shm &shm, const bool create_or_else_find, const MQId id, const int len);
   ShmSocket(int64_t offset, Shm &shm, const MQId id);
   ShmSocket(Shm &shm, const MQId id, Mode mode) :
       run_(false), mq_(shm, id, mode), alloc_id_(0), send_buffer_(shm) { Start(); }
   ShmSocket(int64_t abs_addr, Shm &shm, const MQId id) :
       run_(false), mq_(abs_addr, shm, id), alloc_id_(0), send_buffer_(shm) { Start(); }
   ~ShmSocket();
   static bool Remove(SharedMemory &shm, const MQId id) { return Queue::Remove(shm, id); }
   bool Remove() { return Remove(shm(), id()); }