lichao
2021-04-26 5bb28835d06e27dbd960916c9fb11a555fc5a9bc
src/socket.cpp
@@ -24,12 +24,7 @@
using namespace bhome_msg;
using namespace bhome_shm;
namespace
{
} // namespace
ShmSocket::ShmSocket(Shm &shm, const MQId &id, const int len) :
ShmSocket::ShmSocket(Shm &shm, const MQId id, const int len) :
    run_(false), mq_(id, shm, len)
{
   Start();
@@ -42,7 +37,7 @@
ShmSocket::~ShmSocket()
{
   Stop(); //TODO should stop in sub class, incase thread access sub class data.
   Stop();
}
bool ShmSocket::Start(int nworker, const RecvCB &onData, const IdleCB &onIdle)
@@ -64,7 +59,7 @@
            return false;
         }
         auto onMsg = [&](MsgI &imsg) {
            DEFER1(imsg.Release(shm()));
            DEFER1(imsg.Release());
            BHMsgHead head;
            if (imsg.ParseHead(head)) {
               onRecvWithPerMsgCB(*this, imsg, head);
@@ -123,7 +118,7 @@
      if (msg.ParseHead(head)) {
         return true;
      } else {
         msg.Release(shm());
         msg.Release();
      }
   }
   return false;