| 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() { |
no test coverage detected