diff options
author | ilnurkh <ilnurkh@yandex-team.com> | 2023-10-09 23:39:40 +0300 |
---|---|---|
committer | ilnurkh <ilnurkh@yandex-team.com> | 2023-10-09 23:57:14 +0300 |
commit | e601ca03f859335d57ecff2e5aa6af234b6052ed (patch) | |
tree | de519a847e58a1b3993fcbfe05ff44cc946a3e24 /library/cpp/neh | |
parent | bbf2b6878af3854815a2c0ecb07a687071787639 (diff) | |
download | ydb-e601ca03f859335d57ecff2e5aa6af234b6052ed.tar.gz |
Y_VERIFY->Y_ABORT_UNLESS at ^l
https://clubs.at.yandex-team.ru/arcadia/29404
Diffstat (limited to 'library/cpp/neh')
-rw-r--r-- | library/cpp/neh/http2.cpp | 4 | ||||
-rw-r--r-- | library/cpp/neh/https.cpp | 6 | ||||
-rw-r--r-- | library/cpp/neh/netliba.cpp | 4 | ||||
-rw-r--r-- | library/cpp/neh/netliba_udp_http.cpp | 2 |
4 files changed, 8 insertions, 8 deletions
diff --git a/library/cpp/neh/http2.cpp b/library/cpp/neh/http2.cpp index feaa45c5c9..a685195edf 100644 --- a/library/cpp/neh/http2.cpp +++ b/library/cpp/neh/http2.cpp @@ -1760,7 +1760,7 @@ namespace { TAtomicBase oldReqId; do { oldReqId = AtomicGet(PrimaryResponse_); - Y_VERIFY(oldReqId, "race inside http pipelining"); + Y_ABORT_UNLESS(oldReqId, "race inside http pipelining"); } while (!AtomicCas(&PrimaryResponse_, requestId, oldReqId)); ProcessResponsesData(); @@ -1768,7 +1768,7 @@ namespace { TAtomicBase oldReqId = AtomicGet(PrimaryResponse_); if (oldReqId) { while (!AtomicCas(&PrimaryResponse_, 0, oldReqId)) { - Y_VERIFY(oldReqId == AtomicGet(PrimaryResponse_), "race inside http pipelining [2]"); + Y_ABORT_UNLESS(oldReqId == AtomicGet(PrimaryResponse_), "race inside http pipelining [2]"); } } } diff --git a/library/cpp/neh/https.cpp b/library/cpp/neh/https.cpp index a5b0920d97..f1a2ec9e7e 100644 --- a/library/cpp/neh/https.cpp +++ b/library/cpp/neh/https.cpp @@ -1871,7 +1871,7 @@ namespace NNeh { } void SetHttpOutputConnectionsLimits(size_t softLimit, size_t hardLimit) { - Y_VERIFY( + Y_ABORT_UNLESS( hardLimit > softLimit, "invalid output fd limits; hardLimit=%" PRISZT ", softLimit=%" PRISZT, hardLimit, softLimit); @@ -1880,7 +1880,7 @@ namespace NNeh { } void SetHttpInputConnectionsLimits(size_t softLimit, size_t hardLimit) { - Y_VERIFY( + Y_ABORT_UNLESS( hardLimit > softLimit, "invalid output fd limits; hardLimit=%" PRISZT ", softLimit=%" PRISZT, hardLimit, softLimit); @@ -1889,7 +1889,7 @@ namespace NNeh { } void SetHttpInputConnectionsTimeouts(unsigned minSec, unsigned maxSec) { - Y_VERIFY( + Y_ABORT_UNLESS( maxSec > minSec, "invalid input fd limits timeouts; maxSec=%u, minSec=%u", maxSec, minSec); diff --git a/library/cpp/neh/netliba.cpp b/library/cpp/neh/netliba.cpp index f69906f3ba..1f46ed0c1e 100644 --- a/library/cpp/neh/netliba.cpp +++ b/library/cpp/neh/netliba.cpp @@ -188,7 +188,7 @@ namespace { UpdateInFly(); TInFly::iterator it = InFly_.find(resp->ReqId); - Y_VERIFY(it != InFly_.end(), "incorrect incoming message"); + Y_ABORT_UNLESS(it != InFly_.end(), "incorrect incoming message"); TRequestRef& req = it->second; @@ -220,7 +220,7 @@ namespace { UpdateInFly(); TInFly::iterator it = InFly_.find(guid); - Y_VERIFY(it != InFly_.end(), "incorrect complete notification"); + Y_ABORT_UNLESS(it != InFly_.end(), "incorrect complete notification"); it->second->OnRequestAck(); } diff --git a/library/cpp/neh/netliba_udp_http.cpp b/library/cpp/neh/netliba_udp_http.cpp index a4df426f02..1e89347a13 100644 --- a/library/cpp/neh/netliba_udp_http.cpp +++ b/library/cpp/neh/netliba_udp_http.cpp @@ -282,7 +282,7 @@ namespace NNehNetliba { } void SendRequest(const TUdpAddress& addr, const TString& url, const TString& data, const TGUID& reqId) override { - Y_VERIFY( + Y_ABORT_UNLESS( data.size() < MAX_PACKET_SIZE, "data size is too large; data.size()=%" PRISZT ", MAX_PACKET_SIZE=%" PRISZT, data.size(), MAX_PACKET_SIZE); |