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

Method CancelStaleRequests

library/cpp/neh/udp.cpp:577–585  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

575
576 protected:
577 void CancelStaleRequests(TInFly& infly) {
578 TRequestDescrRef d;
579
580 while (ScheduledReqs_.Dequeue(&d)) {
581 infly.Insert(d);
582 }
583
584 infly.EraseStale();
585 }
586
587 IOnRequest* CB_;
588 NNeh::TAutoLockFreeQueue<TPacket> ToSend_;

Callers

nothing calls this directly

Calls 3

DequeueMethod · 0.45
InsertMethod · 0.45
EraseStaleMethod · 0.45

Tested by

no test coverage detected