MCPcopy Create free account
hub / github.com/catboost/catboost / PostRDMA

Method PostRDMA

library/cpp/netliba/v6/ib_cs.cpp:224–230  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

222 return RecvQueue.begin();
223 }
224 void PostRDMA(TQueuedSend& qs) {
225 Y_ASSERT(qs.RemoteAddr != 0 && qs.MemBlock.Get() != nullptr);
226 QP->PostRDMAWrite(qs.RemoteAddr, qs.RemoteKey,
227 qs.MemBlock->GetMemRegion(), 0, qs.MemBlock->GetData(), qs.MemBlock->GetSize());
228 OutMsgs.push_back(TCompleteInfo(TCompleteInfo::CI_RDMA_COMPLETE, 0, qs.MsgHandle));
229 //printf("Post rdma write, size %d\n", qs.Data->GetSize());
230 }
231 void PostSend(TIBBufferPool& bp, const void* data, size_t len, int t, TIBMsgHandle msgHandle) {
232 int bufId = bp.PostSend(QP, data, len);
233 OutMsgs.push_back(TCompleteInfo(t, bufId, msgHandle));

Callers 2

ParsePacketMethod · 0.45
StepMethod · 0.45

Calls 7

TCompleteInfoClass · 0.70
GetMethod · 0.45
PostRDMAWriteMethod · 0.45
GetMemRegionMethod · 0.45
GetDataMethod · 0.45
GetSizeMethod · 0.45
push_backMethod · 0.45

Tested by

no test coverage detected