| 1254 | } |
| 1255 | |
| 1256 | void RdmaTensorResponse::Destroy() { |
| 1257 | if (src_buffer_ != nullptr) { |
| 1258 | src_buffer_->Unref(); |
| 1259 | } |
| 1260 | if (tensor_ != nullptr) { |
| 1261 | delete tensor_; |
| 1262 | } |
| 1263 | if (proto_ != nullptr) { |
| 1264 | ibv_dereg_mr(mr_); |
| 1265 | free(src_addr_); |
| 1266 | delete proto_; |
| 1267 | } |
| 1268 | // Remove response from the pending list: |
| 1269 | channel_->RemoveTensorResponse(rm_.request_index_); |
| 1270 | } |
| 1271 | |
| 1272 | // Create a RdmaMessage according to the pre-defined format |
| 1273 | // Args: |
no test coverage detected