| 1656 | } |
| 1657 | |
| 1658 | void RdmaTensorRequest::RecvErrorStatus(const Status& status) { |
| 1659 | if (result_tensor_ == nullptr) { |
| 1660 | result_tensor_ = new Tensor(); |
| 1661 | } |
| 1662 | LOG(ERROR) << "Received RDMA_MESSAGE_ERROR_STATUS: " << status.ToString(); |
| 1663 | Done(status); |
| 1664 | } |
| 1665 | |
| 1666 | void RdmaTensorRequest::Start() { |
| 1667 | meta_data_ = RdmaMemoryMgr::Singleton().GetTensorMetaData(key_); |