From 34cd75f77d0ca94dbdba4e6cc9451fe4d33e78b3 Mon Sep 17 00:00:00 2001 From: lichao <lichao@aiotlink.com> Date: 星期三, 19 五月 2021 19:14:13 +0800 Subject: [PATCH] add api BHQueryProcs. --- src/shm_queue.cpp | 78 +-------------------------------------- 1 files changed, 2 insertions(+), 76 deletions(-) diff --git a/src/shm_queue.cpp b/src/shm_queue.cpp index 5e67d1f..86f0d91 100644 --- a/src/shm_queue.cpp +++ b/src/shm_queue.cpp @@ -15,84 +15,10 @@ * * ===================================================================================== */ + #include "shm_queue.h" -#include <boost/uuid/uuid_io.hpp> -#include <boost/uuid/uuid_generators.hpp> #include "bh_util.h" -namespace bhome_shm { - -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()(); } -} - -ShmMsgQueue::ShmMsgQueue(const MQId &id, ShmType &segment, const uint32_t len): -SharedQueue(segment, MsgQIdToName(id), id, len, segment.get_segment_manager()) +namespace bhome_shm { - printf("queue size: %ld cap: %ld\n", data()->size(), data()->capacity()); -} - -ShmMsgQueue::ShmMsgQueue(ShmType &segment, const uint32_t len):ShmMsgQueue(NewId(), segment, len) -{} - -ShmMsgQueue::~ShmMsgQueue() -{ - Remove(); -} - -bool ShmMsgQueue::Send(const MQId &remote_id, const Msg &msg, const int timeout_ms) -{ - Queue *remote = find(MsgQIdToName(remote_id)); - return remote && remote->Write(msg, timeout_ms, [&](){msg.AddRef();}); -} - -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. - - Msg msg; - if(msg.Build(shm(), Id(), data, size, false)) { - if(Send(remote_id, msg, timeout_ms)) { - return true; - } else { - msg.Release(shm()); - } - } - return false; -} - -bool ShmMsgQueue::Recv(MQId &source_id, void *&data, size_t &size, const int timeout_ms) -{ - Msg msg; - if (Read(msg, timeout_ms)) { - DEFER1(msg.Release(shm());); - - auto ptr = msg.get<char>(); - if (ptr) { - MsgMetaV1 meta; - meta.Parse(ptr); - source_id = meta.src_id_; - size = meta.data_size_; - data = malloc(size); - if (data) { - memcpy(data, ptr + meta.self_size_, size); - return true; - } - } - } - source_id = EmptyId(); - data = 0; - size = 0; - return false; -} - } // namespace bhome_shm - -- Gitblit v1.8.0