diff options
author | ilnurkh <[email protected]> | 2023-10-09 23:39:40 +0300 |
---|---|---|
committer | ilnurkh <[email protected]> | 2023-10-09 23:57:14 +0300 |
commit | e601ca03f859335d57ecff2e5aa6af234b6052ed (patch) | |
tree | de519a847e58a1b3993fcbfe05ff44cc946a3e24 /library/cpp/actors/dnsresolver/dnsresolver_caching.cpp | |
parent | bbf2b6878af3854815a2c0ecb07a687071787639 (diff) |
Y_VERIFY->Y_ABORT_UNLESS at ^l
https://clubs.at.yandex-team.ru/arcadia/29404
Diffstat (limited to 'library/cpp/actors/dnsresolver/dnsresolver_caching.cpp')
-rw-r--r-- | library/cpp/actors/dnsresolver/dnsresolver_caching.cpp | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/library/cpp/actors/dnsresolver/dnsresolver_caching.cpp b/library/cpp/actors/dnsresolver/dnsresolver_caching.cpp index d16fc28e5f8..bc3e5c3d7e6 100644 --- a/library/cpp/actors/dnsresolver/dnsresolver_caching.cpp +++ b/library/cpp/actors/dnsresolver/dnsresolver_caching.cpp @@ -137,7 +137,7 @@ namespace NDnsResolver { void Handle(TEvDns::TEvGetHostByNameResult::TPtr& ev) { auto waitingIt = WaitingRequests.find(ev->Cookie); - Y_VERIFY(waitingIt != WaitingRequests.end(), "Unexpected reply, reqId=%" PRIu64, ev->Cookie); + Y_ABORT_UNLESS(waitingIt != WaitingRequests.end(), "Unexpected reply, reqId=%" PRIu64, ev->Cookie); auto waitingInfo = waitingIt->second; WaitingRequests.erase(waitingIt); @@ -161,7 +161,7 @@ namespace NDnsResolver { switch (ev->Get()->SourceType) { case TEvDns::TEvGetHostByName::EventType: { auto waitingIt = WaitingRequests.find(ev->Cookie); - Y_VERIFY(waitingIt != WaitingRequests.end(), "Unexpected TEvUndelivered, reqId=%" PRIu64, ev->Cookie); + Y_ABORT_UNLESS(waitingIt != WaitingRequests.end(), "Unexpected TEvUndelivered, reqId=%" PRIu64, ev->Cookie); auto waitingInfo = waitingIt->second; WaitingRequests.erase(waitingIt); @@ -253,7 +253,7 @@ namespace NDnsResolver { EnsureRequest(state, req->Name, family, now); if (state.IsHardExpired(now)) { - Y_VERIFY(state.Waiting); + Y_ABORT_UNLESS(state.Waiting); if (MonCounters) { ++*MonCounters->CacheMisses; } @@ -396,7 +396,7 @@ namespace NDnsResolver { auto& req = WaitingRequests[reqId]; req.Position = NameToState.find(name); req.Family = family; - Y_VERIFY(req.Position != NameToState.end()); + Y_ABORT_UNLESS(req.Position != NameToState.end()); Send(Upstream, new TEvDns::TEvGetHostByName(name, family), IEventHandle::FlagTrackDelivery, reqId); state.Waiting = true; @@ -484,7 +484,7 @@ namespace NDnsResolver { } auto& state = it->second.StateByFamily(family); - Y_VERIFY(state.Waiting, "Got error for a state we are not waiting"); + Y_ABORT_UNLESS(state.Waiting, "Got error for a state we are not waiting"); state.Waiting = false; // When we have a cached positive reply, don't overwrite it with spurious errors @@ -532,7 +532,7 @@ namespace NDnsResolver { } auto& state = it->second.StateByFamily(family); - Y_VERIFY(state.Waiting, "Got reply for a state we are not waiting"); + Y_ABORT_UNLESS(state.Waiting, "Got reply for a state we are not waiting"); state.Waiting = false; state.Status = ARES_SUCCESS; @@ -567,7 +567,7 @@ namespace NDnsResolver { } bool& flag = family.*FamilyToFlag; - Y_VERIFY(flag); + Y_ABORT_UNLESS(flag); heap.pop(); flag = false; |