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/threading | |
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/threading')
-rw-r--r-- | library/cpp/threading/local_executor/local_executor.cpp | 2 | ||||
-rw-r--r-- | library/cpp/threading/mux_event/mux_event.h | 2 | ||||
-rw-r--r-- | library/cpp/threading/queue/mpmc_unordered_ring.cpp | 2 |
3 files changed, 3 insertions, 3 deletions
diff --git a/library/cpp/threading/local_executor/local_executor.cpp b/library/cpp/threading/local_executor/local_executor.cpp index 1440a3a67ad..4b4f69c0cbe 100644 --- a/library/cpp/threading/local_executor/local_executor.cpp +++ b/library/cpp/threading/local_executor/local_executor.cpp @@ -313,7 +313,7 @@ void NPar::ILocalExecutor::ExecRange(TLocallyExecutableFunction exec, int firstI } void NPar::ILocalExecutor::ExecRangeWithThrow(TLocallyExecutableFunction exec, int firstId, int lastId, int flags) { - Y_VERIFY((flags & WAIT_COMPLETE) != 0, "ExecRangeWithThrow() requires WAIT_COMPLETE to wait if exceptions arise."); + Y_ABORT_UNLESS((flags & WAIT_COMPLETE) != 0, "ExecRangeWithThrow() requires WAIT_COMPLETE to wait if exceptions arise."); if (TryExecRangeSequentially(exec, firstId, lastId, flags)) { return; } diff --git a/library/cpp/threading/mux_event/mux_event.h b/library/cpp/threading/mux_event/mux_event.h index 6ff32ee49d2..b25e1acbbb9 100644 --- a/library/cpp/threading/mux_event/mux_event.h +++ b/library/cpp/threading/mux_event/mux_event.h @@ -25,7 +25,7 @@ public: Y_UNUSED(rmode); } ~TMuxEvent() { - Y_VERIFY(WaitList.empty(), ""); + Y_ABORT_UNLESS(WaitList.empty(), ""); } // TODO: potentially unsafe, but currently I can't add "virtual" to TSystemEvent methods diff --git a/library/cpp/threading/queue/mpmc_unordered_ring.cpp b/library/cpp/threading/queue/mpmc_unordered_ring.cpp index 160547f5946..a3a0d425659 100644 --- a/library/cpp/threading/queue/mpmc_unordered_ring.cpp +++ b/library/cpp/threading/queue/mpmc_unordered_ring.cpp @@ -2,7 +2,7 @@ namespace NThreading { TMPMCUnorderedRing::TMPMCUnorderedRing(size_t size) { - Y_VERIFY(size > 0); + Y_ABORT_UNLESS(size > 0); RingSize = size; RingBuffer.Reset(new void*[size]); memset(&RingBuffer[0], 0, sizeof(void*) * size); |