Adding tokens to the completion queue Tokens are needed to process future messages.
| 657 | // Adding tokens to the completion queue |
| 658 | // Tokens are needed to process future messages. |
| 659 | void RdmaChannel::Recv() { |
| 660 | struct ibv_recv_wr wr; |
| 661 | memset(&wr, 0, sizeof(wr)); |
| 662 | wr.wr_id = (uint64_t)this; |
| 663 | struct ibv_recv_wr* bad_wr; |
| 664 | CHECK(!ibv_post_recv(qp_, &wr, &bad_wr)) << "Failed to post recv"; |
| 665 | } |
| 666 | |
| 667 | RdmaTensorRequest* RdmaChannel::InsertTensorRequest( |
| 668 | const string& key, int64 step_id, Device* dst_dev, |
no outgoing calls
no test coverage detected