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

Method EraseStale

library/cpp/neh/udp.cpp:486–494  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

484 }
485
486 inline void EraseStale() noexcept {
487 const TTimeStamp now = TimeStamp();
488
489 for (TIterator it = Begin(); (it != End()) && (it->TS < now) && ((now - it->TS) > 120);) {
490 it->Hndl->NotifyError("request timeout");
491 TString safe_key = (it++)->Guid;
492 erase(safe_key);
493 }
494 }
495 };
496
497 inline void ExecuteRecv() {

Callers 1

CancelStaleRequestsMethod · 0.45

Calls 4

TimeStampFunction · 0.85
BeginClass · 0.85
eraseFunction · 0.50
NotifyErrorMethod · 0.45

Tested by

no test coverage detected