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

Method PostRDMA

library/cpp/netliba/v12/ib_cs.cpp:231–237  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

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));

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