From 8967e7f2f8b94dc032135707e16c8a9f233d0db6 Mon Sep 17 00:00:00 2001 From: lichao <lichao@aiotlink.com> Date: 星期四, 03 六月 2021 13:32:16 +0800 Subject: [PATCH] rafactor, remove old todo, add some err msg. --- src/msg.cpp | 30 ++++++++++++++++++++++++++++++ 1 files changed, 30 insertions(+), 0 deletions(-) diff --git a/src/msg.cpp b/src/msg.cpp index f180d67..3546424 100644 --- a/src/msg.cpp +++ b/src/msg.cpp @@ -17,8 +17,38 @@ */ #include "msg.h" #include "bh_util.h" +#include "defs.h" +#include "shm_socket.h" namespace bhome_msg { +int ShmMsg::Release() +{ + if (!valid()) { + return 0; + } + auto n = meta()->count_.Dec(); + if (n == 0) { + if (meta()->managed_) { + int64_t free_cmd = (id() << 4) | EncodeCmd(eCmdFree); + DefaultSender(shm()).Send(BHTopicCenterAddress(shm()), free_cmd); + } else { + Free(); + } + } else if (n < 0) { + // ns_log::GetTrace(); + LOG_FATAL() << "double release msg."; + throw std::runtime_error("double release msg."); + } + return n; +} + +void ShmMsg::Free() +{ + assert(valid()); + shm().Dealloc(meta()); + offset_ = 0; + assert(!valid()); +} } // namespace bhome_msg -- Gitblit v1.8.0