lichao
2021-04-30 377e395a5fdc6ad44bdd5a2d41d2930f45fc4384
src/socket.h
@@ -42,6 +42,7 @@
public:
   typedef ShmMsgQueue::MQId MQId;
   typedef bhome_shm::SharedMemory Shm;
   typedef std::function<void(ShmSocket &sock, MsgI &imsg)> RawRecvCB;
   typedef std::function<void(ShmSocket &sock, MsgI &imsg, BHMsgHead &head)> RecvCB;
   typedef std::function<bool(ShmSocket &sock, MsgI &imsg, BHMsgHead &head)> PartialRecvCB;
   typedef std::function<void(ShmSocket &sock)> IdleCB;
@@ -53,6 +54,7 @@
   bool Remove() { return Remove(shm(), id()); }
   MQId id() const { return mq().Id(); }
   // start recv.
   bool Start(const RawRecvCB &onData, const IdleCB &onIdle, int nworker = 1);
   bool Start(int nworker = 1, const RecvCB &onData = RecvCB(), const IdleCB &onIdle = IdleCB());
   bool Start(const RecvCB &onData, const IdleCB &onIdle, int nworker = 1) { return Start(nworker, onData, onIdle); }
   bool Start(const RecvCB &onData, int nworker = 1) { return Start(nworker, onData); }