Searched refs:receive_callbacks_ (Results 1 – 2 of 2) sorted by relevance
373 receive_callbacks_[pair_data] = [=]() mutable { in CollectiveReceiveAsync()996 auto it = receive_callbacks_.find(std::make_pair(rank_id, rank_request_id)); in RunReceiveCallback()997 if (it != receive_callbacks_.end()) { in RunReceiveCallback()1004 receive_callbacks_.erase(it); in RunReceiveCallback()
227 std::map<std::pair<uint32_t, uint64_t>, MessageCallback> receive_callbacks_; variable