From 58d904a328c0d849769b483e901a0be9426b8209 Mon Sep 17 00:00:00 2001 From: liuxiaolong <liuxiaolong@aiotlink.com> Date: 星期二, 20 七月 2021 20:20:44 +0800 Subject: [PATCH] 调整Request C.BHFree的位置 --- src/shm_msg_queue.h | 55 ++++++++++++------------------------------------------- 1 files changed, 12 insertions(+), 43 deletions(-) diff --git a/src/shm_msg_queue.h b/src/shm_msg_queue.h index 56ea076..6a4d7a4 100644 --- a/src/shm_msg_queue.h +++ b/src/shm_msg_queue.h @@ -18,71 +18,40 @@ #ifndef SHM_MSG_QUEUE_D847TQXH #define SHM_MSG_QUEUE_D847TQXH +#include "defs.h" #include "msg.h" #include "shm_queue.h" using namespace bhome_shm; using namespace bhome_msg; -#define BH_USE_ATOMIC_Q - -class ShmMsgQueue : public StaticDataRef<std::atomic<uint64_t>, ShmMsgQueue> +class ShmMsgQueue { public: typedef int64_t RawData; - -#ifdef BH_USE_ATOMIC_Q - typedef ShmObject<SharedQ63<0>> Shmq; -#else - typedef ShmObject<SharedQueue<RawData>> Shmq; - // typedef robust::FMutex Mutex; - // typedef robust::SemMutex Mutex; - typedef robust::NullMutex Mutex; - typedef robust::Guard<Mutex> Guard; -#endif - + typedef NamedShmObject<SharedQ63> Shmq; typedef Shmq::Data Queue; typedef Shmq::ShmType ShmType; typedef uint64_t MQId; - static MQId NewId(); - - ShmMsgQueue(const MQId id, ShmType &segment, const int len); - ShmMsgQueue(const MQId id, const bool create_or_else_find, ShmType &segment, const int len); - ShmMsgQueue(ShmType &segment, const int len); + ShmMsgQueue(ShmType &segment, const MQId id, Mode mode); + ShmMsgQueue(const int64_t abs_addr, ShmType &segment, const MQId id); ~ShmMsgQueue(); static bool Remove(ShmType &shm, const MQId id); MQId Id() const { return id_; } ShmType &shm() const { return queue_.shm(); } + int64_t AbsAddr() const { return queue_.offset(); } - bool Recv(RawData &val, const int timeout_ms) - { -#ifndef BH_USE_ATOMIC_Q - Guard lock(GetMutex(Id())); -#endif - return queue().Read(val, timeout_ms); - } + // bool Recv(RawData &val, const int timeout_ms) { return queue().Read(val, timeout_ms); } + bool TryRecv(RawData &val) { return queue().TryRead(val); } - bool TryRecv(RawData &val) - { -#ifndef BH_USE_ATOMIC_Q - Guard lock(GetMutex(Id())); -#endif - return queue().TryRead(val); - } - - bool Recv(MsgI &msg, const int timeout_ms) { return Recv(msg.OffsetRef(), timeout_ms); } + // bool Recv(MsgI &msg, const int timeout_ms) { return Recv(msg.OffsetRef(), timeout_ms); } bool TryRecv(MsgI &msg) { return TryRecv(msg.OffsetRef()); } - static Queue *Find(ShmType &shm, const MQId remote_id); - static bool TrySend(ShmType &shm, const MQId remote_id, const RawData val); - static bool TrySend(ShmType &shm, const MQId remote_id, MsgI msg) { return TrySend(shm, remote_id, msg.Offset()); } - bool TrySend(const MQId remote_id, const MsgI &msg) { return TrySend(shm(), remote_id, msg); } - bool TrySend(const MQId remote_id, const RawData val) { return TrySend(shm(), remote_id, val); } + static Queue *Find(ShmType &shm, const MQId remote); + static bool TrySend(ShmType &shm, const MQInfo &remote, const RawData val); + bool TrySend(const MQInfo &remote, const RawData val) { return TrySend(shm(), remote, val); } private: -#ifndef BH_USE_ATOMIC_Q - static Mutex &GetMutex(const MQId id); -#endif MQId id_; Queue &queue() { return *queue_.data(); } Shmq queue_; -- Gitblit v1.8.0