From 77a6c3512a44dfe6540dde71946e6484fe4f173f Mon Sep 17 00:00:00 2001
From: lichao <lichao@aiotlink.com>
Date: 星期一, 10 五月 2021 16:05:28 +0800
Subject: [PATCH] test lock code.

---
 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