lichao
2021-04-23 dc86ace85e437ecb8a2e728e4dce36d02bbb8a6e
src/sendq.cpp
@@ -42,17 +42,15 @@
      if (d.index() == 0) {
         auto &msg = boost::variant2::get<0>(pos->data().data_);
         r = mq.TrySend(*(MQId *) remote.data(), msg);
         if (r && msg.IsCounted()) {
         if (r) {
            msg.Release(mq.shm());
         }
      } else {
         auto &content = boost::variant2::get<1>(pos->data().data_);
         MsgI msg;
         if (msg.Make(mq.shm(), content)) {
            DEFER1(msg.Release(mq.shm()););
            r = mq.TrySend(*(MQId *) remote.data(), msg);
            if (!r || msg.IsCounted()) {
               msg.Release(mq.shm());
            }
         }
      }
      return r;