Searched refs:rank_request_id (Results 1 – 1 of 1) sorted by relevance
362 uint64_t rank_request_id = NextExpectedRankRequestId(rank_id); in CollectiveReceiveAsync() local363 auto pair_data = std::make_pair(rank_id, rank_request_id); in CollectiveReceiveAsync()371 …EBUG) << "Receive data from rank id:" << rank_id << ", the rank request id is:" << rank_request_id; in CollectiveReceiveAsync()374 auto res_output = received_data_[std::make_pair(rank_id, rank_request_id)]; in CollectiveReceiveAsync()380 received_data_.erase(std::make_pair(rank_id, rank_request_id)); in CollectiveReceiveAsync()381 receive_messages_done_[std::make_pair(rank_id, rank_request_id)] = true; in CollectiveReceiveAsync()382 …EBUG) << "Receive data from rank id:" << rank_id << ", the rank request id is:" << rank_request_id; in CollectiveReceiveAsync()386 return std::make_pair(rank_id, rank_request_id); in CollectiveReceiveAsync()984 uint64_t rank_request_id = NextActualRankRequestId(rank_id); in RunReceiveCallback() local993 received_data_[std::make_pair(rank_id, rank_request_id)] = received_data; in RunReceiveCallback()[all …]