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

Method GetRecv

library/cpp/netliba/v12/ib_cs.cpp:222–230  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

220 return SendQueue.begin();
221 }
222 TDeque<TQueuedRecv>::iterator GetRecv(const TGUID& packetGuid) {
223 for (TDeque<TQueuedRecv>::iterator z = RecvQueue.begin(); z != RecvQueue.end(); ++z) {
224 if (z->PacketGuid == packetGuid) {
225 return z;
226 }
227 }
228 Y_ABORT_UNLESS(0, "no recv by guid");
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,

Callers 1

ParsePacketMethod · 0.45

Calls 2

beginMethod · 0.45
endMethod · 0.45

Tested by

no test coverage detected