From cf05ea3d9f43e4e84d621e1f9d54cbef552b6e2b Mon Sep 17 00:00:00 2001 From: lichao <lichao@aiotlink.com> Date: 星期二, 18 五月 2021 16:53:28 +0800 Subject: [PATCH] fix center init mutex. --- src/shm_queue.cpp | 98 ------------------------------------------------- 1 files changed, 0 insertions(+), 98 deletions(-) diff --git a/src/shm_queue.cpp b/src/shm_queue.cpp index cf4c8b4..86f0d91 100644 --- a/src/shm_queue.cpp +++ b/src/shm_queue.cpp @@ -18,105 +18,7 @@ #include "shm_queue.h" #include "bh_util.h" -#include <boost/uuid/uuid_generators.hpp> -#include <boost/uuid/uuid_io.hpp> namespace bhome_shm { -using namespace bhome_msg; -using namespace boost::interprocess; -using namespace boost::uuids; - -namespace -{ -std::string MsgQIdToName(const MQId &id) { return "shmq" + to_string(id); } -// MQId EmptyId() { return nil_uuid(); } -MQId NewId() { return random_generator()(); } -const int AdjustMQLength(const int len) -{ - const int kMaxLength = 10000; - const int kDefaultLen = 12; - if (len <= 0) { - return kDefaultLen; - } else if (len < kMaxLength) { - return len; - } else { - return kMaxLength; - } -} - -} // namespace - -// ShmMsgQueue memory usage: (320 + 16*length) bytes, length >= 2 -ShmMsgQueue::ShmMsgQueue(const MQId &id, ShmType &segment, const int len) : - Super(segment, MsgQIdToName(id), AdjustMQLength(len), segment.get_segment_manager()), - id_(id) -{ -} - -ShmMsgQueue::ShmMsgQueue(ShmType &segment, const int len) : - ShmMsgQueue(NewId(), segment, len) -{ -} - -ShmMsgQueue::~ShmMsgQueue() -{ - Remove(); -} - -bool ShmMsgQueue::Send(SharedMemory &shm, const MQId &remote_id, const MsgI &msg, const int timeout_ms) -{ - Queue *remote = Find(shm, MsgQIdToName(remote_id)); - return remote && remote->Write(msg, timeout_ms, [](const MsgI &msg) { msg.AddRef(); }); -} - -// bool ShmMsgQueue::Send(const MQId &remote_id, const MsgI &msg, const int timeout_ms) -// { -// Queue *remote = Find(MsgQIdToName(remote_id)); -// return remote && remote->Write(msg, timeout_ms, [](const MsgI&msg){msg.AddRef();}); -// } - -bool ShmMsgQueue::Send(const MQId &remote_id, const BHMsg &data, const int timeout_ms) -{ - MsgI msg; - if (msg.Make(shm(), data)) { - if (Send(remote_id, msg, timeout_ms)) { - return true; - } else { - msg.Release(shm()); - } - } - return false; -} - -/* -bool ShmMsgQueue::Send(const MQId &remote_id, const void *data, const size_t size, const int timeout_ms) -{ - // Test shows that in the 2 cases: - // 1) build msg first, then find remote queue; - // 2) find remote queue first, then build msg; - // 1 is about 50% faster than 2, maybe cache related. - - MsgI msg; - if(msg.BuildRequest(shm(), Id(), data, size)) { - if(Send(remote_id, msg, timeout_ms)) { - return true; - } else { - msg.Release(shm()); - } - } - return false; -} -//*/ -bool ShmMsgQueue::Recv(BHMsg &msg, const int timeout_ms) -{ - MsgI imsg; - if (Read(imsg, timeout_ms)) { - DEFER1(imsg.Release(shm());); - return imsg.Unpack(msg); - } else { - return false; - } -} - } // namespace bhome_shm -- Gitblit v1.8.0