From e54b8e58780c7d9f37b06cc4e1dc88badb2129c9 Mon Sep 17 00:00:00 2001
From: lichao <lichao@aiotlink.com>
Date: 星期二, 18 五月 2021 17:02:21 +0800
Subject: [PATCH] remove sync recv, node cache msgs for sync recv.
---
src/socket.cpp | 19 -------------------
1 files changed, 0 insertions(+), 19 deletions(-)
diff --git a/src/socket.cpp b/src/socket.cpp
index c450e65..19be201 100644
--- a/src/socket.cpp
+++ b/src/socket.cpp
@@ -139,25 +139,6 @@
return false;
}
-bool ShmSocket::SyncRecv(int64_t &cmd, const int timeout_ms)
-{
- return (timeout_ms == 0) ? mq().TryRecv(cmd) : mq().Recv(cmd, timeout_ms);
-}
-//maybe reimplment, using async cbs?
-bool ShmSocket::SyncRecv(bhome_msg::MsgI &msg, bhome_msg::BHMsgHead &head, const int timeout_ms)
-{
- // std::lock_guard<std::mutex> lock(mutex_); // seems no need to lock mutex_.
- bool got = (timeout_ms == 0) ? mq().TryRecv(msg) : mq().Recv(msg, timeout_ms);
- if (got) {
- if (msg.ParseHead(head)) {
- return true;
- } else {
- msg.Release();
- }
- }
- return false;
-}
-
bool ShmSocket::Send(const MQInfo &remote, std::string &&content, const std::string &msg_id, RecvCB &&cb)
{
size_t size = content.size();
--
Gitblit v1.8.0