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

Method GetRecv

library/cpp/netliba/v6/ib_cs.cpp:215–223  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

213 return SendQueue.begin();
214 }
215 TDeque<TQueuedRecv>::iterator GetRecv(const TGUID& packetGuid) {
216 for (TDeque<TQueuedRecv>::iterator z = RecvQueue.begin(); z != RecvQueue.end(); ++z) {
217 if (z->PacketGuid == packetGuid) {
218 return z;
219 }
220 }
221 Y_ABORT_UNLESS(0, "no recv by guid");
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,

Callers 1

ParsePacketMethod · 0.45

Calls 2

beginMethod · 0.45
endMethod · 0.45

Tested by

no test coverage detected