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 |   43 ++++++-------------------------------------
 1 files changed, 6 insertions(+), 37 deletions(-)

diff --git a/src/shm_msg_queue.h b/src/shm_msg_queue.h
index de60fde..6a4d7a4 100644
--- a/src/shm_msg_queue.h
+++ b/src/shm_msg_queue.h
@@ -25,31 +25,16 @@
 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(ShmType &segment, const MQId id, const int len);
-	ShmMsgQueue(ShmType &segment, const bool create_or_else_find, const MQId id, 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);
@@ -57,32 +42,16 @@
 	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);
 	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