bhshmq
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
lichao
2021-06-02 993c556000a414011626770540678948f16eaa9e 
 src/topic_node.h


@@ -34,14 +34,17 @@


   SharedMemory &shm_;


   ProcInfo info_;




   SharedMemory &shm() { return shm_; }


   SharedMemory &shm() const { return shm_; }


   const MQInfo &CenterAddr() const { return BHTopicCenterAddress(shm()); }


   const MQInfo &BusAddr() const { return BHTopicBusAddress(shm()); }




public:


   TopicNode(SharedMemory &shm);


   TopicNode(SharedMemory &shm, MQId ssn_id = 0);


   ~TopicNode();




   // topic node


   bool Register(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);


@@ -53,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);