Searched refs:connected_nodes_ (Results 1 – 6 of 6) sorted by relevance
76 if (!connected_nodes_.empty()) { in Stop()77 for (auto &connected_node : connected_nodes_) { in Stop()
156 if (connected_nodes_.count(node_id)) { in ProcessRegister()157 (void)connected_nodes_.erase(node_id); in ProcessRegister()465 if (connected_nodes_.count(node_info.node_id_)) { in GetOrCreateClient()466 return connected_nodes_[node_info.node_id_]; in GetOrCreateClient()497 connected_nodes_[node_info.node_id_] = client; in GetOrCreateClient()498 return connected_nodes_[node_info.node_id_]; in GetOrCreateClient()512 if (!connected_nodes_.empty()) { in Stop()513 for (auto &connected_node : connected_nodes_) { in Stop()
97 connected_nodes_.clear(); in set_ready_for_scale_out()105 connected_nodes_.clear(); in set_ready_for_scale_in()683 connected_nodes_.clear(); in ProcessSendMetadata()860 if (connected_nodes_.find(rank_id) != connected_nodes_.end()) { in GetOrCreateTcpClient()861 return connected_nodes_[rank_id]; in GetOrCreateTcpClient()889 connected_nodes_[rank_id] = client; in GetOrCreateTcpClient()890 return connected_nodes_[rank_id]; in GetOrCreateTcpClient()
158 std::unordered_map<std::string, std::shared_ptr<TcpClient>> connected_nodes_; variable
221 std::unordered_map<uint32_t, std::shared_ptr<TcpClient>> connected_nodes_; variable