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;