| | |
| | | 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; |
| | |
| | | } |
| | | |
| | | enum State { |
| | | eStateUninited, |
| | | eStateUnregistered, |
| | | eStateOnline, |
| | | eStateOffline // heartbeat fail. |
| | |
| | | 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_; |