From 1f3729698a131b3f701f67adb6a1258aa1235dce Mon Sep 17 00:00:00 2001
From: lichao <lichao@aiotlink.com>
Date: 星期二, 20 四月 2021 15:43:53 +0800
Subject: [PATCH] api server callback change tag to src; refactor.

---
 src/socket.cpp |    4 ++--
 1 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/socket.cpp b/src/socket.cpp
index 0ba195a..1315474 100644
--- a/src/socket.cpp
+++ b/src/socket.cpp
@@ -52,7 +52,7 @@
 		auto DoRecv = [=] {
 			auto onRecvWithPerMsgCB = [this, onData](ShmSocket &socket, MsgI &imsg, BHMsgHead &head) {
 				RecvCB cb;
-				if (per_msg_cbs_->Find(head.msg_id(), cb)) {
+				if (per_msg_cbs_->Pick(head.msg_id(), cb)) {
 					cb(socket, imsg, head);
 				} else if (onData) {
 					onData(socket, imsg, head);
@@ -115,7 +115,7 @@
 }
 
 //maybe reimplment, using async cbs?
-bool ShmSocket::SyncRecv(bhome_msg::MsgI &msg, bhome::msg::BHMsgHead &head, const int timeout_ms)
+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);

--
Gitblit v1.8.0