| 685 | } |
| 686 | |
| 687 | RdmaTensorRequest* RdmaChannel::GetTensorRequest(uint32_t request_index) { |
| 688 | mutex_lock lock{ct_mu_}; |
| 689 | RequestTable::iterator iter = request_table_.find(request_index); |
| 690 | CHECK(iter != request_table_.end()); |
| 691 | return &iter->second; |
| 692 | } |
| 693 | |
| 694 | void RdmaChannel::Connect() { |
| 695 | { |
no test coverage detected