From 93b71a7989f678bf36f12333787a056559f29ccf Mon Sep 17 00:00:00 2001
From: lichao <lichao@aiotlink.com>
Date: 星期日, 25 四月 2021 10:21:39 +0800
Subject: [PATCH] remove failed msgq.
---
src/sendq.cpp | 12 +++++-------
1 files changed, 5 insertions(+), 7 deletions(-)
diff --git a/src/sendq.cpp b/src/sendq.cpp
index 4be24f1..54de419 100644
--- a/src/sendq.cpp
+++ b/src/sendq.cpp
@@ -33,7 +33,7 @@
info.on_expire_(info.data_);
}
if (info.data_.index() == 0) {
- boost::variant2::get<0>(info.data_).Release(mq.shm());
+ boost::variant2::get<0>(info.data_).Release();
}
}
@@ -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()) {
- msg.Release(mq.shm());
+ if (r) {
+ msg.Release();
}
} else {
auto &content = boost::variant2::get<1>(pos->data().data_);
MsgI msg;
- if (msg.Make(mq.shm(), content)) {
+ if (msg.Make(content)) {
+ DEFER1(msg.Release(););
r = mq.TrySend(*(MQId *) remote.data(), msg);
- if (!r || msg.IsCounted()) {
- msg.Release(mq.shm());
- }
}
}
return r;
--
Gitblit v1.8.0