Searched refs:qp_endpoint_map_ (Results 1 – 2 of 2) sorted by relevance
263 std::for_each(qp_endpoint_map_.begin(), qp_endpoint_map_.end(), in debug_connections()322 auto present = qp_endpoint_map_.is_in_map(qpnum); in handle_event()441 qp_endpoint_map_.erase(qpnum); in handle_event()488 qp_endpoint_map_.insert(std::make_pair(qpnum, temp_client)); in handle_event()506 qp_endpoint_map_.erase(event_client->get_qp_num()); in handle_event()587 qp_endpoint_map_.insert(std::make_pair(qpnum, new_client)); in handle_connect_request()685 for (const auto &client_pair : qp_endpoint_map_) { in connect_to_server()743 map_read_lock_type read_lock(qp_endpoint_map_.read_write_mutex()); in disconnect_all()745 std::for_each(qp_endpoint_map_.begin(), qp_endpoint_map_.end(), in disconnect_all()761 map_read_lock_type read_lock(qp_endpoint_map_.read_write_mutex()); in active()[all …]
63 return (qp_endpoint_map_.size() == 0); in isTerminated()96 return qp_endpoint_map_.at(completion.qp_num).get(); in get_client_from_completion()188 hpx::concurrent::unordered_map<uint32_t, verbs_endpoint_ptr> qp_endpoint_map_; member in hpx::parcelset::policies::verbs::rdma_controller