| 229 | return RecvQueue.begin(); |
| 230 | } |
| 231 | void PostRDMA(TQueuedSend& qs) { |
| 232 | Y_ASSERT(qs.RemoteAddr != 0 && qs.MemBlock.Get() != nullptr); |
| 233 | QP->PostRDMAWrite(qs.RemoteAddr, qs.RemoteKey, |
| 234 | qs.MemBlock->GetMemRegion(), 0, qs.MemBlock->GetData(), qs.MemBlock->GetSize()); |
| 235 | OutMsgs.push_back(TCompleteInfo(TCompleteInfo::CI_RDMA_COMPLETE, 0, qs.MsgHandle)); |
| 236 | //printf("Post rdma write, size %d\n", qs.Data->GetSize()); |
| 237 | } |
| 238 | void PostSend(TIBBufferPool& bp, const void* data, size_t len, int t, TIBMsgHandle msgHandle) { |
| 239 | int bufId = bp.PostSend(QP, data, len); |
| 240 | OutMsgs.push_back(TCompleteInfo(t, bufId, msgHandle)); |
no test coverage detected