From e601ca03f859335d57ecff2e5aa6af234b6052ed Mon Sep 17 00:00:00 2001 From: ilnurkh Date: Mon, 9 Oct 2023 23:39:40 +0300 Subject: Y_VERIFY->Y_ABORT_UNLESS at ^l https://clubs.at.yandex-team.ru/arcadia/29404 --- library/cpp/threading/local_executor/local_executor.cpp | 2 +- library/cpp/threading/mux_event/mux_event.h | 2 +- library/cpp/threading/queue/mpmc_unordered_ring.cpp | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) (limited to 'library/cpp/threading') 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); -- cgit v1.3