lichao
2021-05-17 cab831748a2a9cc18b7f18f3b5e14a4374b7ab68
src/topic_node.h
@@ -78,7 +78,7 @@
   MQId ssn() { return SockNode().id(); }
   bool ClientQueryRPCTopic(const Topic &topic, BHAddress &addr, const int timeout_ms);
   typedef MsgQueryTopicReply::BHNodeAddress NodeAddress;
   int QueryRPCTopics(const Topic &topic, std::vector<NodeAddress> &addr, const int timeout_ms);
   int QueryTopicServers(const Topic &topic, std::vector<NodeAddress> &addr, const int timeout_ms);
   const std::string &proc_id() { return info_.proc_id(); }
   typedef BHAddress Address;
@@ -139,6 +139,7 @@
   }
   enum State {
      eStateUninited,
      eStateUnregistered,
      eStateOnline,
      eStateOffline // heartbeat fail.
@@ -146,7 +147,7 @@
   void state(const State st) { state_.store(st); }
   void state_cas(State expected, const State val) { state_.compare_exchange_strong(expected, val); }
   State state() const { return state_.load(); }
   bool IsOnline() { return Init() && state() == eStateOnline; }
   bool IsOnline() { return state() == eStateOnline; }
   bool Init();
   bool Valid() const { return !sockets_.empty(); }
   std::mutex mutex_;