From a8f8443c3aa4cf6e643cdbadbff86a7d09755ab0 Mon Sep 17 00:00:00 2001
From: liuxiaolong <liuxiaolong@aiotlink.com>
Date: 星期四, 20 五月 2021 09:41:03 +0800
Subject: [PATCH] rebuild proto
---
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