From aa1542b6d6a4680088ac715c4ce40f97ada554fb Mon Sep 17 00:00:00 2001
From: lichao <lichao@aiotlink.com>
Date: 星期三, 14 四月 2021 17:52:31 +0800
Subject: [PATCH] add SendQ TrySend() TryRecv(); handle re-register.

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

diff --git a/src/topic_node.h b/src/topic_node.h
index d671026..0627930 100644
--- a/src/topic_node.h
+++ b/src/topic_node.h
@@ -48,12 +48,12 @@
 	bool ServerStart(ServerCB const &cb, const int nworker = 2);
 	bool ServerRegisterRPC(MsgTopicList &topics, MsgCommonReply &reply, const int timeout_ms);
 	bool ServerRecvRequest(void *&src_info, std::string &proc_id, MsgRequestTopic &request, const int timeout_ms);
-	bool ServerSendReply(void *src_info, const MsgRequestTopicReply &reply, const int timeout_ms);
+	bool ServerSendReply(void *src_info, const MsgRequestTopicReply &reply);
 
 	// topic client
 	typedef std::function<void(const std::string &proc_id, const MsgRequestTopicReply &reply)> RequestResultCB;
 	bool ClientStartWorker(RequestResultCB const &cb, const int nworker = 2);
-	bool ClientAsyncRequest(const MsgRequestTopic &request, const int timeout_ms, const RequestResultCB &rrcb = RequestResultCB());
+	bool ClientAsyncRequest(const MsgRequestTopic &request, const RequestResultCB &rrcb = RequestResultCB());
 	bool ClientSyncRequest(const MsgRequestTopic &request, std::string &proc_id, MsgRequestTopicReply &reply, const int timeout_ms);
 
 	// publish

--
Gitblit v1.8.0