From 83085f2ce99cca05d40a19482151873a55e6393a Mon Sep 17 00:00:00 2001
From: lichao <lichao@aiotlink.com>
Date: 星期五, 02 四月 2021 19:32:21 +0800
Subject: [PATCH] refactor center; add async request no cb.

---
 src/reqrep.h |   11 +++++++++--
 1 files changed, 9 insertions(+), 2 deletions(-)

diff --git a/src/reqrep.h b/src/reqrep.h
index 9e43c7b..8a4743c 100644
--- a/src/reqrep.h
+++ b/src/reqrep.h
@@ -43,9 +43,15 @@
 	bool StartWorker(int nworker = 2) { return StartWorker(RequestResultCB(), nworker); }
 	bool Stop() { return Socket::Stop(); }
 	bool AsyncRequest(const Topic &topic, const void *data, const size_t size, const int timeout_ms, const RequestResultCB &rrcb);
+	bool AsyncRequest(const Topic &topic, const void *data, const size_t size, const int timeout_ms);
+
 	bool AsyncRequest(const Topic &topic, const std::string &data, const int timeout_ms, const RequestResultCB &rrcb)
 	{
 		return AsyncRequest(topic, data.data(), data.size(), timeout_ms, rrcb);
+	}
+	bool AsyncRequest(const Topic &topic, const std::string &data, const int timeout_ms)
+	{
+		return AsyncRequest(topic, data.data(), data.size(), timeout_ms);
 	}
 	bool SyncRequest(const Topic &topic, const void *data, const size_t size, std::string &out, const int timeout_ms);
 	bool SyncRequest(const Topic &topic, const std::string &data, std::string &out, const int timeout_ms)
@@ -54,10 +60,11 @@
 	}
 
 private:
-	bool AsyncSend(const void *remote, const void *msg, const int timeout_ms, const RecvCB &cb);
+	bool AsyncSend(const void *remote, const void *msg, const int timeout_ms, const RecvBHMsgCB &cb);
+	bool AsyncSend(const void *remote, const void *msg, const int timeout_ms);
 	bool SyncSendAndRecv(const void *remote, const void *msg, void *result, const int timeout_ms);
 	bool QueryRPCTopic(const Topic &topic, bhome::msg::BHAddress &addr, const int timeout_ms);
-	std::unordered_map<std::string, RecvCB> async_cbs_;
+	std::unordered_map<std::string, RecvBHMsgCB> async_cbs_;
 
 	typedef bhome_msg::BHAddress Address;
 	class TopicCache

--
Gitblit v1.8.0