bhshmq
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
lichao
2021-05-21 11f6c600e55ca5677f93624efe44d2605cdd908d 
 src/topic_node.h


@@ -43,8 +43,8 @@


   ~TopicNode();




   // topic node


   bool Register(ProcInfo &proc, MsgCommonReply &reply_body, const int timeout_ms) { return UniRegister(false, proc, reply_body, timeout_ms); }


   bool UniRegister(const bool internal, ProcInfo &proc, MsgCommonReply &reply_body, const int timeout_ms);


   bool Register(ProcInfo &proc, MsgCommonReply &reply_body, const int timeout_ms) { return DoRegister(false, proc, reply_body, timeout_ms); }


   bool DoRegister(const bool internal, ProcInfo &proc, MsgCommonReply &reply_body, const int timeout_ms);


   bool Unregister(ProcInfo &proc, MsgCommonReply &reply_body, const int timeout_ms);


   bool Heartbeat(ProcInfo &proc, MsgCommonReply &reply_body, const int timeout_ms);


   bool Heartbeat(const int timeout_ms);


@@ -56,7 +56,8 @@


   typedef std::function<void(void *src_info, std::string &client_proc_id, MsgRequestTopic &request)> ServerAsyncCB;


   bool ServerStart(ServerSyncCB const &cb, const int nworker = 2);


   bool ServerStart(ServerAsyncCB const &cb, const int nworker = 2);


   bool ServerRegisterRPC(MsgTopicList &topics, MsgCommonReply &reply, const int timeout_ms);


   bool ServerRegisterRPC(MsgTopicList &topics, MsgCommonReply &reply, const int timeout_ms) { return DoServerRegisterRPC(false, topics, reply, timeout_ms); }


   bool DoServerRegisterRPC(const bool internal, 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);