From 4e5cb7960ce4e7e66d5190be67426aeca8b55c3d Mon Sep 17 00:00:00 2001
From: lichao <lichao@aiotlink.com>
Date: 星期五, 09 四月 2021 18:45:08 +0800
Subject: [PATCH] add heartbeat, not tested yet.

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

diff --git a/src/topic_node.h b/src/topic_node.h
index 34fe2ee..60497ad 100644
--- a/src/topic_node.h
+++ b/src/topic_node.h
@@ -39,12 +39,12 @@
 
 	void StopAll();
 	// topic node
-	bool Register(const MsgRegister &body, MsgCommonReply &reply, const int timeout_ms);
-	bool RegisterRPC(const MsgRegisterRPC &body, MsgCommonReply &reply, const int timeout_ms);
+	bool Register(ProcInfo &body, MsgCommonReply &reply, const int timeout_ms);
 
 	// topic rpc server
 	typedef std::function<bool(const std::string &topic, const std::string &data, std::string &reply)> OnRequest;
 	bool ServerStart(OnRequest const &cb, const int nworker = 2);
+	bool ServerRegisterRPC(MsgTopicList &topics, MsgCommonReply &reply, const int timeout_ms);
 	bool ServerRecvRequest(void *&src_info, std::string &topic, std::string &data, const int timeout_ms);
 	bool ServerSendReply(void *src_info, const std::string &data, const int timeout_ms);
 
@@ -68,7 +68,7 @@
 	// subscribe
 	typedef std::function<void(const std::string &proc_id, const Topic &topic, const std::string &data)> TopicDataCB;
 	bool SubscribeStartWorker(const TopicDataCB &tdcb, int nworker = 2);
-	bool Subscribe(const std::vector<Topic> &topics, const int timeout_ms);
+	bool Subscribe(MsgTopicList &topics, const int timeout_ms);
 	bool RecvSub(std::string &proc_id, Topic &topic, std::string &data, const int timeout_ms);
 
 private:

--
Gitblit v1.8.0