From 68c7bef33e74f23aa0136ccd6f7faa654d671ebc Mon Sep 17 00:00:00 2001 From: lichao <lichao@aiotlink.com> Date: 星期五, 21 五月 2021 09:23:01 +0800 Subject: [PATCH] center publish notify; fix topic partial match. --- src/topic_node.h | 3 ++- 1 files changed, 2 insertions(+), 1 deletions(-) diff --git a/src/topic_node.h b/src/topic_node.h index 81bf718..dcc9518 100644 --- a/src/topic_node.h +++ b/src/topic_node.h @@ -19,7 +19,7 @@ #define TOPIC_NODE_YVKWA6TF #include "msg.h" -#include "socket.h" +#include "shm_socket.h" #include <atomic> #include <memory> #include <mutex> @@ -46,6 +46,7 @@ bool Heartbeat(ProcInfo &proc, MsgCommonReply &reply_body, const int timeout_ms); bool Heartbeat(const int timeout_ms); bool QueryTopicAddress(BHAddress &dest, MsgQueryTopic &query, MsgQueryTopicReply &reply_body, const int timeout_ms); + bool QueryProcs(BHAddress &dest, MsgQueryProc &query, MsgQueryProcReply &reply_body, const int timeout_ms); // topic rpc server typedef std::function<bool(const std::string &client_proc_id, const MsgRequestTopic &request, MsgRequestTopicReply &reply)> ServerSyncCB; -- Gitblit v1.8.0