| | |
| | | auto &SockNode() { return sock_node_; } |
| | | auto &SockPub() { return SockNode(); } |
| | | auto &SockSub() { return sock_sub_; } |
| | | auto &SockRequest() { return sock_request_; } |
| | | auto &SockClient() { return SockRequest(); } |
| | | auto &SockReply() { return sock_reply_; } |
| | | auto &SockServer() { return SockReply(); } |
| | | auto &SockClient() { return sock_client_; } |
| | | auto &SockServer() { return sock_server_; } |
| | | bool IsRegistered() const { return registered_.load(); } |
| | | |
| | | std::atomic<bool> registered_; |
| | | ShmSocket sock_node_; |
| | | ShmSocket sock_request_; |
| | | ShmSocket sock_reply_; |
| | | ShmSocket sock_client_; |
| | | ShmSocket sock_server_; |
| | | ShmSocket sock_sub_; |
| | | std::atomic<bool> registered_; |
| | | std::atomic<bool> registered_ever_; |
| | | |
| | | TopicQueryCache topic_query_cache_; |
| | | }; |