Y_VERIFY_DEBUG->Y_DEBUG_ABORT_UNLESS at '-v ydb'

https://clubs.at.yandex-team.ru/arcadia/29404

67 files changed, 220 insertions, 220 deletions

diff --git a/library/cpp/actors/core/actor.cpp b/library/cpp/actors/core/actor.cpp
index 4f7d4c1493..ddd849d285 100644
--- a/library/cpp/actors/core/actor.cpp
+++ b/library/cpp/actors/core/actor.cpp
@@ -101,7 +101,7 @@ namespace NActors {
     }
 
     TActorId TActivationContext::RegisterWithSameMailbox(IActor* actor, TActorId parentId) {
-        Y_VERIFY_DEBUG(parentId);
+        Y_DEBUG_ABORT_UNLESS(parentId);
         auto& ctx = *TlsActivationContext;
         return ctx.ExecutorThread.RegisterActor(actor, &ctx.Mailbox, parentId.Hint(), parentId);
     }
diff --git a/library/cpp/actors/core/actor.h b/library/cpp/actors/core/actor.h
index d151425680..c807227c43 100644
--- a/library/cpp/actors/core/actor.h
+++ b/library/cpp/actors/core/actor.h
@@ -694,7 +694,7 @@ namespace NActors {
 #define STFUNC(funcName) void funcName(TAutoPtr<::NActors::IEventHandle>& ev)
 #define STATEFN(funcName) void funcName(TAutoPtr<::NActors::IEventHandle>& ev)
 
-#define STFUNC_STRICT_UNHANDLED_MSG_HANDLER Y_VERIFY_DEBUG(false, "%s: unexpected message type 0x%08" PRIx32, __func__, etype);
+#define STFUNC_STRICT_UNHANDLED_MSG_HANDLER Y_DEBUG_ABORT_UNLESS(false, "%s: unexpected message type 0x%08" PRIx32, __func__, etype);
 
 #define STFUNC_BODY(HANDLERS, UNHANDLED_MSG_HANDLER)                    \
     switch (const ui32 etype = ev->GetTypeRewrite()) {                  \
diff --git a/library/cpp/actors/core/actor_virtual.h b/library/cpp/actors/core/actor_virtual.h
index 9b02660c65..5598312952 100644
--- a/library/cpp/actors/core/actor_virtual.h
+++ b/library/cpp/actors/core/actor_virtual.h
@@ -19,7 +19,7 @@ public:
     TEventContext(std::unique_ptr<IEventHandle> handle)
         : Handle(std::move(handle))
     {
-        Y_VERIFY_DEBUG(dynamic_cast<TEvent*>(Handle->GetBase()));
+        Y_DEBUG_ABORT_UNLESS(dynamic_cast<TEvent*>(Handle->GetBase()));
         Event = static_cast<TEvent*>(Handle->GetBase());
         Y_ABORT_UNLESS(Event);
     }
@@ -29,7 +29,7 @@ template <class TEvent, class TExpectedActor>
 class IEventForActor: public IEventBase {
 protected:
     virtual bool DoExecute(IActor* actor, std::unique_ptr<IEventHandle> eventPtr) override {
-        Y_VERIFY_DEBUG(dynamic_cast<TExpectedActor*>(actor));
+        Y_DEBUG_ABORT_UNLESS(dynamic_cast<TExpectedActor*>(actor));
         auto* actorCorrect = static_cast<TExpectedActor*>(actor);
         TEventContext<TEvent> context(std::move(eventPtr));
         actorCorrect->ProcessEvent(context);
diff --git a/library/cpp/actors/core/actorid.h b/library/cpp/actors/core/actorid.h
index df1cac1c4e..4e9a7bc3c3 100644
--- a/library/cpp/actors/core/actorid.h
+++ b/library/cpp/actors/core/actorid.h
@@ -43,7 +43,7 @@ namespace NActors {
         }
 
         explicit TActorId(ui32 nodeId, ui32 poolId, ui64 localId, ui32 hint) noexcept {
-            Y_VERIFY_DEBUG(poolId <= MaxPoolID);
+            Y_DEBUG_ABORT_UNLESS(poolId <= MaxPoolID);
             Raw.N.LocalId = localId;
             Raw.N.Hint = hint;
             Raw.N.NodeId = nodeId | (poolId << PoolIndexShift);
@@ -83,7 +83,7 @@ namespace NActors {
         }
 
         TStringBuf ServiceId() const noexcept {
-            Y_VERIFY_DEBUG(IsService());
+            Y_DEBUG_ABORT_UNLESS(IsService());
             return TStringBuf((const char*)Raw.Buf, MaxServiceIDLength);
         }
 
@@ -166,7 +166,7 @@ namespace NActors {
 
         struct TOrderedCmp {
             bool operator()(const TActorId &left, const TActorId &right) const noexcept {
-                Y_VERIFY_DEBUG(!left.IsService() && !right.IsService(), "ordered compare works for plain actorids only");
+                Y_DEBUG_ABORT_UNLESS(!left.IsService() && !right.IsService(), "ordered compare works for plain actorids only");
                 const ui32 n1 = left.NodeId();
                 const ui32 n2 = right.NodeId();
 
diff --git a/library/cpp/actors/core/actorsystem.cpp b/library/cpp/actors/core/actorsystem.cpp
index b73c545134..c09a208ef5 100644
--- a/library/cpp/actors/core/actorsystem.cpp
+++ b/library/cpp/actors/core/actorsystem.cpp
@@ -105,7 +105,7 @@ namespace NActors {
 
         if (recpNodeId != NodeId && recpNodeId != 0) {
             // if recipient is not local one - rewrite with forward instruction
-            Y_VERIFY_DEBUG(!ev->HasEvent() || ev->GetBase()->IsSerializable());
+            Y_DEBUG_ABORT_UNLESS(!ev->HasEvent() || ev->GetBase()->IsSerializable());
             Y_ABORT_UNLESS(ev->Recipient == recipient,
                 "Event rewrite from %s to %s would be lost via interconnect",
                 ev->Recipient.ToString().c_str(),
@@ -134,7 +134,7 @@ namespace NActors {
             ev->Rewrite(ev->GetTypeRewrite(), recipient);
         }
 
-        Y_VERIFY_DEBUG(recipient == ev->GetRecipientRewrite());
+        Y_DEBUG_ABORT_UNLESS(recipient == ev->GetRecipientRewrite());
         const ui32 recpPool = recipient.PoolID();
         if (recipient && recpPool < ExecutorPoolCount) {
             if ((CpuManager->GetExecutorPool(recpPool)->*EPSpecificSend)(ev)) {
@@ -200,7 +200,7 @@ namespace NActors {
     }
 
     ui64 TActorSystem::AllocateIDSpace(ui64 count) {
-        Y_VERIFY_DEBUG(count < Max<ui32>() / 65536);
+        Y_DEBUG_ABORT_UNLESS(count < Max<ui32>() / 65536);
 
         static_assert(sizeof(TAtomic) == sizeof(ui64), "expect sizeof(TAtomic) == sizeof(ui64)");
 
diff --git a/library/cpp/actors/core/buffer.cpp b/library/cpp/actors/core/buffer.cpp
index 48128d76ef..91ff4dde68 100644
--- a/library/cpp/actors/core/buffer.cpp
+++ b/library/cpp/actors/core/buffer.cpp
@@ -41,14 +41,14 @@ void TBufferBaseT<PointerType>::Assign(PointerType data, size_t size) noexcept {
 
 template <>
 void TBufferBaseT<void*>::Cut(size_t offset) noexcept {
-    Y_VERIFY_DEBUG(offset <= Size);
+    Y_DEBUG_ABORT_UNLESS(offset <= Size);
     Data = static_cast<char*>(Data) + offset;
     TBufferBase::Size -= offset;
 }
 
 template <>
 void TBufferBaseT<const void*>::Cut(size_t offset) noexcept {
-    Y_VERIFY_DEBUG(offset <= Size);
+    Y_DEBUG_ABORT_UNLESS(offset <= Size);
     Data = static_cast<const char*>(Data) + offset;
     TBufferBase::Size -= offset;
 }
diff --git a/library/cpp/actors/core/cpu_state.h b/library/cpp/actors/core/cpu_state.h
index b8030149a7..3f779d5623 100644
--- a/library/cpp/actors/core/cpu_state.h
+++ b/library/cpp/actors/core/cpu_state.h
@@ -97,7 +97,7 @@ namespace NActors {
                 if (Y_UNLIKELY(current == CpuStopped)) {
                     return false;
                 }
-                Y_VERIFY_DEBUG(current < MaxPools, "unexpected already waiting state of cpu (%d)", (int)current);
+                Y_DEBUG_ABORT_UNLESS(current < MaxPools, "unexpected already waiting state of cpu (%d)", (int)current);
                 if (AtomicCas(&State, (state & ~CurrentMask) | CpuSpinning, state)) { // successfully marked as spinning
                     return true;
                 }
diff --git a/library/cpp/actors/core/event.h b/library/cpp/actors/core/event.h
index 4f6aefc0ee..e7f561338f 100644
--- a/library/cpp/actors/core/event.h
+++ b/library/cpp/actors/core/event.h
@@ -24,7 +24,7 @@ namespace NActors {
     protected:
         // for compatibility with virtual actors
         virtual bool DoExecute(IActor* /*actor*/, std::unique_ptr<IEventHandle> /*eventPtr*/) {
-            Y_VERIFY_DEBUG(false);
+            Y_DEBUG_ABORT_UNLESS(false);
             return false;
         }
     public:
diff --git a/library/cpp/actors/core/event_pb.cpp b/library/cpp/actors/core/event_pb.cpp
index a72c52efc2..e6a863c44e 100644
--- a/library/cpp/actors/core/event_pb.cpp
+++ b/library/cpp/actors/core/event_pb.cpp
@@ -148,7 +148,7 @@ namespace NActors {
         // fill in base params
         BufferPtr = static_cast<char*>(data);
         SizeRemain = size;
-        Y_VERIFY_DEBUG(size);
+        Y_DEBUG_ABORT_UNLESS(size);
 
         // transfer control to the coroutine
         Y_ABORT_UNLESS(Event);
diff --git a/library/cpp/actors/core/event_pb.h b/library/cpp/actors/core/event_pb.h
index b6789df2fc..d3b422f1dc 100644
--- a/library/cpp/actors/core/event_pb.h
+++ b/library/cpp/actors/core/event_pb.h
@@ -647,7 +647,7 @@ namespace NActors {
     }
 
     inline void ActorIdToProto(const TActorId& src, NActorsProto::TActorId* dest) {
-        Y_VERIFY_DEBUG(dest);
+        Y_DEBUG_ABORT_UNLESS(dest);
         dest->SetRawX1(src.RawX1());
         dest->SetRawX2(src.RawX2());
     }
diff --git a/library/cpp/actors/core/executor_pool_base.cpp b/library/cpp/actors/core/executor_pool_base.cpp
index 3658736a7c..d58cd6ce08 100644
--- a/library/cpp/actors/core/executor_pool_base.cpp
+++ b/library/cpp/actors/core/executor_pool_base.cpp
@@ -90,7 +90,7 @@ namespace NActors {
     }
 
     bool TExecutorPoolBaseMailboxed::Send(TAutoPtr<IEventHandle>& ev) {
-        Y_VERIFY_DEBUG(ev->GetRecipientRewrite().PoolID() == PoolId);
+        Y_DEBUG_ABORT_UNLESS(ev->GetRecipientRewrite().PoolID() == PoolId);
 #ifdef ACTORSLIB_COLLECT_EXEC_STATS
         RelaxedStore(&ev->SendTime, (::NHPTimer::STime)GetCycleCountFast());
 #endif
@@ -98,7 +98,7 @@ namespace NActors {
     }
 
     bool TExecutorPoolBaseMailboxed::SpecificSend(TAutoPtr<IEventHandle>& ev) {
-        Y_VERIFY_DEBUG(ev->GetRecipientRewrite().PoolID() == PoolId);
+        Y_DEBUG_ABORT_UNLESS(ev->GetRecipientRewrite().PoolID() == PoolId);
 #ifdef ACTORSLIB_COLLECT_EXEC_STATS
         RelaxedStore(&ev->SendTime, (::NHPTimer::STime)GetCycleCountFast());
 #endif
@@ -134,7 +134,7 @@ namespace NActors {
         NHPTimer::STime hpstart = GetCycleCountFast();
 #ifdef ACTORSLIB_COLLECT_EXEC_STATS
         ui32 at = actor->GetActivityType();
-        Y_VERIFY_DEBUG(at < Stats.ActorsAliveByActivity.size());
+        Y_DEBUG_ABORT_UNLESS(at < Stats.ActorsAliveByActivity.size());
         if (at >= Stats.MaxActivityType()) {
             at = TActorTypeOperator::GetActorActivityIncorrectIndex();
             Y_ABORT_UNLESS(at < Stats.ActorsAliveByActivity.size());
diff --git a/library/cpp/actors/core/executor_pool_basic.cpp b/library/cpp/actors/core/executor_pool_basic.cpp
index 762ab32190..f9ea74a920 100644
--- a/library/cpp/actors/core/executor_pool_basic.cpp
+++ b/library/cpp/actors/core/executor_pool_basic.cpp
@@ -183,7 +183,7 @@ namespace NActors {
             }
         }
 
-        Y_VERIFY_DEBUG(AtomicLoad(&StopFlag) || AtomicLoad(&threadCtx.WaitingFlag) == TThreadCtx::WS_NONE);
+        Y_DEBUG_ABORT_UNLESS(AtomicLoad(&StopFlag) || AtomicLoad(&threadCtx.WaitingFlag) == TThreadCtx::WS_NONE);
 
 #if defined ACTORSLIB_COLLECT_EXEC_STATS
         if (AtomicDecrement(ThreadUtilization) == 0) {
@@ -242,7 +242,7 @@ namespace NActors {
 
     ui32 TBasicExecutorPool::GetReadyActivationCommon(TWorkerContext& wctx, ui64 revolvingCounter) {
         TWorkerId workerId = wctx.WorkerId;
-        Y_VERIFY_DEBUG(workerId < PoolThreads);
+        Y_DEBUG_ABORT_UNLESS(workerId < PoolThreads);
 
         TTimers timers;
 
@@ -303,7 +303,7 @@ namespace NActors {
 
     ui32 TBasicExecutorPool::GetReadyActivationLocalQueue(TWorkerContext& wctx, ui64 revolvingCounter) {
         TWorkerId workerId = wctx.WorkerId;
-        Y_VERIFY_DEBUG(workerId < static_cast<i32>(PoolThreads));
+        Y_DEBUG_ABORT_UNLESS(workerId < static_cast<i32>(PoolThreads));
 
         if (workerId >= 0 && LocalQueues[workerId].size()) {
             ui32 activation = LocalQueues[workerId].front();
@@ -500,13 +500,13 @@ namespace NActors {
     }
 
     void TBasicExecutorPool::Schedule(TInstant deadline, TAutoPtr<IEventHandle> ev, ISchedulerCookie* cookie, TWorkerId workerId) {
-        Y_VERIFY_DEBUG(workerId < PoolThreads);
+        Y_DEBUG_ABORT_UNLESS(workerId < PoolThreads);
 
         Schedule(deadline - ActorSystem->Timestamp(), ev, cookie, workerId);
     }
 
     void TBasicExecutorPool::Schedule(TMonotonic deadline, TAutoPtr<IEventHandle> ev, ISchedulerCookie* cookie, TWorkerId workerId) {
-        Y_VERIFY_DEBUG(workerId < PoolThreads);
+        Y_DEBUG_ABORT_UNLESS(workerId < PoolThreads);
 
         const auto current = ActorSystem->Monotonic();
         if (deadline < current)
@@ -516,7 +516,7 @@ namespace NActors {
     }
 
     void TBasicExecutorPool::Schedule(TDuration delta, TAutoPtr<IEventHandle> ev, ISchedulerCookie* cookie, TWorkerId workerId) {
-        Y_VERIFY_DEBUG(workerId < PoolThreads);
+        Y_DEBUG_ABORT_UNLESS(workerId < PoolThreads);
 
         const auto deadline = ActorSystem->Monotonic() + delta;
         ScheduleWriters[workerId].Push(deadline.MicroSeconds(), ev.Release(), cookie);
diff --git a/library/cpp/actors/core/executor_pool_io.cpp b/library/cpp/actors/core/executor_pool_io.cpp
index f315effe0c..78e1d8e1ea 100644
--- a/library/cpp/actors/core/executor_pool_io.cpp
+++ b/library/cpp/actors/core/executor_pool_io.cpp
@@ -28,7 +28,7 @@ namespace NActors {
 
     ui32 TIOExecutorPool::GetReadyActivation(TWorkerContext& wctx, ui64 revolvingCounter) {
         i16 workerId = wctx.WorkerId;
-        Y_VERIFY_DEBUG(workerId < PoolThreads);
+        Y_DEBUG_ABORT_UNLESS(workerId < PoolThreads);
 
         NHPTimer::STime elapsed = 0;
         NHPTimer::STime parked = 0;
diff --git a/library/cpp/actors/core/executor_pool_united.cpp b/library/cpp/actors/core/executor_pool_united.cpp
index a4a9b26269..a21fd2d1a7 100644
--- a/library/cpp/actors/core/executor_pool_united.cpp
+++ b/library/cpp/actors/core/executor_pool_united.cpp
@@ -1429,7 +1429,7 @@ namespace NActors {
     }
 
     void TUnitedExecutorPool::Schedule(TMonotonic deadline, TAutoPtr<IEventHandle> ev, ISchedulerCookie* cookie, TWorkerId workerId) {
-        Y_VERIFY_DEBUG(workerId < United->GetWorkerCount());
+        Y_DEBUG_ABORT_UNLESS(workerId < United->GetWorkerCount());
         const auto current = ActorSystem->Monotonic();
         if (deadline < current) {
             deadline = current;
@@ -1438,7 +1438,7 @@ namespace NActors {
     }
 
     void TUnitedExecutorPool::Schedule(TDuration delta, TAutoPtr<IEventHandle> ev, ISchedulerCookie* cookie, TWorkerId workerId) {
-        Y_VERIFY_DEBUG(workerId < United->GetWorkerCount());
+        Y_DEBUG_ABORT_UNLESS(workerId < United->GetWorkerCount());
         const auto deadline = ActorSystem->Monotonic() + delta;
         United->GetScheduleWriter(workerId)->Push(deadline.MicroSeconds(), ev.Release(), cookie);
     }
diff --git a/library/cpp/actors/core/executor_thread.cpp b/library/cpp/actors/core/executor_thread.cpp
index 2cdb54a874..deddb0a97e 100644
--- a/library/cpp/actors/core/executor_thread.cpp
+++ b/library/cpp/actors/core/executor_thread.cpp
@@ -76,7 +76,7 @@ namespace NActors {
     { }
 
     void TExecutorThread::UnregisterActor(TMailboxHeader* mailbox, TActorId actorId) {
-        Y_VERIFY_DEBUG(IsUnitedWorker || actorId.PoolID() == ExecutorPool->PoolId && ExecutorPool->ResolveMailbox(actorId.Hint()) == mailbox);
+        Y_DEBUG_ABORT_UNLESS(IsUnitedWorker || actorId.PoolID() == ExecutorPool->PoolId && ExecutorPool->ResolveMailbox(actorId.Hint()) == mailbox);
         IActor* actor = mailbox->DetachActor(actorId.LocalId());
         Ctx.DecrementActorsAliveByActivity(actor->GetActivityType());
         DyingActors.push_back(THolder(actor));
@@ -154,7 +154,7 @@ namespace NActors {
 
     template <typename TMailbox>
     bool TExecutorThread::Execute(TMailbox* mailbox, ui32 hint, bool isTailExecution) {
-        Y_VERIFY_DEBUG(DyingActors.empty());
+        Y_DEBUG_ABORT_UNLESS(DyingActors.empty());
 
         bool reclaimAsFree = false;
 
diff --git a/library/cpp/actors/core/log_settings.h b/library/cpp/actors/core/log_settings.h
index bb7eabfa5f..f62f55c200 100644
--- a/library/cpp/actors/core/log_settings.h
+++ b/library/cpp/actors/core/log_settings.h
@@ -143,13 +143,13 @@ namespace NActors {
             }
 
             inline TComponentSettings GetComponentSettings(EComponent component) const {
-                Y_VERIFY_DEBUG((component & Mask) == component);
+                Y_DEBUG_ABORT_UNLESS((component & Mask) == component);
                 // by using Mask we don't get outside of array boundaries
                 return TComponentSettings(AtomicGet(ComponentInfo[component & Mask]));
             }
 
             const char* ComponentName(EComponent component) const {
-                Y_VERIFY_DEBUG((component & Mask) == component);
+                Y_DEBUG_ABORT_UNLESS((component & Mask) == component);
                 return ComponentNames[component & Mask].data();
             }
 
diff --git a/library/cpp/actors/core/mailbox.cpp b/library/cpp/actors/core/mailbox.cpp
index de746f0ecb..37cb900ecf 100644
--- a/library/cpp/actors/core/mailbox.cpp
+++ b/library/cpp/actors/core/mailbox.cpp
@@ -155,7 +155,7 @@ namespace NActors {
                 case TMailboxType::TinyReadAsFilled:
                     return TTinyReadAsFilledMailbox::Get(lineHint, x);
                 default:
-                    Y_VERIFY_DEBUG(false);
+                    Y_DEBUG_ABORT_UNLESS(false);
                     break;
             }
         }
@@ -182,7 +182,7 @@ namespace NActors {
                     TSimpleMailbox* const mailbox = TSimpleMailbox::Get(lineHint, x);
                     mailbox->Push(recipient.LocalId());
 #if (!defined(_tsan_enabled_))
-                    Y_VERIFY_DEBUG(mailbox->Type == (ui32)x->MailboxType);
+                    Y_DEBUG_ABORT_UNLESS(mailbox->Type == (ui32)x->MailboxType);
 #endif
                     mailbox->Queue.Push(ev.Release());
                     if (mailbox->MarkForSchedule()) {
@@ -207,7 +207,7 @@ namespace NActors {
                     TRevolvingMailbox* const mailbox = TRevolvingMailbox::Get(lineHint, x);
                     mailbox->Push(recipient.LocalId());
 #if (!defined(_tsan_enabled_))
-                    Y_VERIFY_DEBUG(mailbox->Type == (ui32)x->MailboxType);
+                    Y_DEBUG_ABORT_UNLESS(mailbox->Type == (ui32)x->MailboxType);
 #endif
                     mailbox->QueueWriter.Push(ev.Release());
                     if (mailbox->MarkForSchedule()) {
@@ -220,7 +220,7 @@ namespace NActors {
                     THTSwapMailbox* const mailbox = THTSwapMailbox::Get(lineHint, x);
                     mailbox->Push(recipient.LocalId());
 #if (!defined(_tsan_enabled_))
-                    Y_VERIFY_DEBUG(mailbox->Type == (ui32)x->MailboxType);
+                    Y_DEBUG_ABORT_UNLESS(mailbox->Type == (ui32)x->MailboxType);
 #endif
                     mailbox->Queue.Push(ev.Release());
                     if (mailbox->MarkForSchedule()) {
@@ -236,7 +236,7 @@ namespace NActors {
                     TReadAsFilledMailbox* const mailbox = TReadAsFilledMailbox::Get(lineHint, x);
                     mailbox->Push(recipient.LocalId());
 #if (!defined(_tsan_enabled_))
-                    Y_VERIFY_DEBUG(mailbox->Type == (ui32)x->MailboxType);
+                    Y_DEBUG_ABORT_UNLESS(mailbox->Type == (ui32)x->MailboxType);
 #endif
                     mailbox->Queue.Push(ev.Release());
                     if (mailbox->MarkForSchedule()) {
@@ -252,7 +252,7 @@ namespace NActors {
                     TTinyReadAsFilledMailbox* const mailbox = TTinyReadAsFilledMailbox::Get(lineHint, x);
                     mailbox->Push(recipient.LocalId());
 #if (!defined(_tsan_enabled_))
-                    Y_VERIFY_DEBUG(mailbox->Type == (ui32)x->MailboxType);
+                    Y_DEBUG_ABORT_UNLESS(mailbox->Type == (ui32)x->MailboxType);
 #endif
                     mailbox->Queue.Push(ev.Release());
                     if (mailbox->MarkForSchedule()) {
diff --git a/library/cpp/actors/core/mailbox.h b/library/cpp/actors/core/mailbox.h
index 0daafa83ac..d7e3ef5384 100644
--- a/library/cpp/actors/core/mailbox.h
+++ b/library/cpp/actors/core/mailbox.h
@@ -216,7 +216,7 @@ namespace NActors {
         }
 
         IActor* DetachActor(ui64 localActorId) noexcept {
-            Y_VERIFY_DEBUG(FindActor(localActorId) != nullptr);
+            Y_DEBUG_ABORT_UNLESS(FindActor(localActorId) != nullptr);
 
             IActor* actorToDestruct = nullptr;
 
diff --git a/library/cpp/actors/core/mailbox_queue_revolving.h b/library/cpp/actors/core/mailbox_queue_revolving.h
index 22b0332095..e1a25dd352 100644
--- a/library/cpp/actors/core/mailbox_queue_revolving.h
+++ b/library/cpp/actors/core/mailbox_queue_revolving.h
@@ -85,7 +85,7 @@ namespace NActors {
             }
 
             ~TReader() {
-                Y_VERIFY_DEBUG(Head() == 0);
+                Y_DEBUG_ABORT_UNLESS(Head() == 0);
                 for (ui32 i = 0; i < TWriteConcurrency; ++i)
                     delete ReadFrom[i];
             }
@@ -179,7 +179,7 @@ namespace NActors {
                     if (RelaxedLoad(&WriteTo[i]) != nullptr) {
                         if (TChunk* writeTo = AtomicSwap(&WriteTo[i], nullptr)) {
                             const ui64 nextTag = AtomicIncrement(Tag);
-                            Y_VERIFY_DEBUG(nextTag < Max<ui64>());
+                            Y_DEBUG_ABORT_UNLESS(nextTag < Max<ui64>());
                             const ui32 writePosition = WritePosition[i];
                             if (writePosition != TChunk::EntriesCount) {
                                 writeTo->Entries[writePosition].Tag = nextTag;
diff --git a/library/cpp/actors/core/scheduler_actor.cpp b/library/cpp/actors/core/scheduler_actor.cpp
index 513505b5d7..73fd6bd183 100644
--- a/library/cpp/actors/core/scheduler_actor.cpp
+++ b/library/cpp/actors/core/scheduler_actor.cpp
@@ -184,7 +184,7 @@ namespace NActors {
                         if (it->first <= MonotonicTime) {
                             if (NSchedulerQueue::TQueueType* q = it->second.Get()) {
                                 while (NSchedulerQueue::TEntry* x = q->Reader.Pop()) {
-                                    Y_VERIFY_DEBUG(x->InstantMicroseconds <= ActiveTick);
+                                    Y_DEBUG_ABORT_UNLESS(x->InstantMicroseconds <= ActiveTick);
                                     if (eventSchedulingErrorUs == 0 && MonotonicTime > x->InstantMicroseconds) {
                                         eventSchedulingErrorUs = MonotonicTime - x->InstantMicroseconds;
                                     }
@@ -209,7 +209,7 @@ namespace NActors {
                     }
 
                     if (ActiveTick <= MonotonicTime) {
-                        Y_VERIFY_DEBUG(!ActiveSec || ActiveSec->empty());
+                        Y_DEBUG_ABORT_UNLESS(!ActiveSec || ActiveSec->empty());
                         ActiveSec.Destroy();
                         ActiveTick += IntrasecondThreshold;
                         TScheduleMap::iterator it = ScheduleMap.find(ActiveTick);
diff --git a/library/cpp/actors/core/scheduler_basic.cpp b/library/cpp/actors/core/scheduler_basic.cpp
index 3b4e0a08c1..5d66224f05 100644
--- a/library/cpp/actors/core/scheduler_basic.cpp
+++ b/library/cpp/actors/core/scheduler_basic.cpp
@@ -98,7 +98,7 @@ namespace NActors {
                         if (NSchedulerQueue::TQueueType* q = it->second.Get()) {
                             while (NSchedulerQueue::TEntry* x = q->Reader.Pop()) {
                                 somethingDone = true;
-                                Y_VERIFY_DEBUG(x->InstantMicroseconds <= activeTick);
+                                Y_DEBUG_ABORT_UNLESS(x->InstantMicroseconds <= activeTick);
                                 IEventHandle* ev = x->Ev;
                                 ISchedulerCookie* cookie = x->Cookie;
                                 // TODO: lazy send with backoff queue to not hang over contended mailboxes
@@ -122,7 +122,7 @@ namespace NActors {
                 }
 
                 if (activeTick <= throttledMonotonic) {
-                    Y_VERIFY_DEBUG(!activeSec || activeSec->empty());
+                    Y_DEBUG_ABORT_UNLESS(!activeSec || activeSec->empty());
                     activeSec.Destroy();
                     activeTick += IntrasecondThreshold;
                     TScheduleMap::iterator it = ScheduleMap.find(activeTick);
diff --git a/library/cpp/actors/core/worker_context.h b/library/cpp/actors/core/worker_context.h
index 7ee9394cd9..b51ff55cd3 100644
--- a/library/cpp/actors/core/worker_context.h
+++ b/library/cpp/actors/core/worker_context.h
@@ -47,7 +47,7 @@ namespace NActors {
         }
 
         void AddElapsedCycles(ui32 activityType, i64 elapsed) {
-            Y_VERIFY_DEBUG(activityType < Stats->MaxActivityType());
+            Y_DEBUG_ABORT_UNLESS(activityType < Stats->MaxActivityType());
             RelaxedStore(&Stats->ElapsedTicks, RelaxedLoad(&Stats->ElapsedTicks) + elapsed);
             RelaxedStore(&Stats->ElapsedTicksByActivity[activityType], RelaxedLoad(&Stats->ElapsedTicksByActivity[activityType]) + elapsed);
         }
diff --git a/library/cpp/actors/cppcoro/task.h b/library/cpp/actors/cppcoro/task.h
index ad665d4cbf..8afeb7e705 100644
--- a/library/cpp/actors/cppcoro/task.h
+++ b/library/cpp/actors/cppcoro/task.h
@@ -33,7 +33,7 @@ namespace NActors {
             explicit TTaskAwaiter(TTaskHandle<T> handle)
                 : Handle(handle)
             {
-                Y_VERIFY_DEBUG(Handle);
+                Y_DEBUG_ABORT_UNLESS(Handle);
             }
 
             TTaskAwaiter(TTaskAwaiter&& rhs)
@@ -54,13 +54,13 @@ namespace NActors {
 
             // Some arbitrary continuation c suspended and awaits the task
             TTaskHandle<T> await_suspend(std::coroutine_handle<> c) noexcept {
-                Y_VERIFY_DEBUG(Handle);
+                Y_DEBUG_ABORT_UNLESS(Handle);
                 Handle.promise().SetContinuation(c);
                 return Handle;
             }
 
             TTaskResult<T>&& await_resume() noexcept {
-                Y_VERIFY_DEBUG(Handle);
+                Y_DEBUG_ABORT_UNLESS(Handle);
                 return std::move(Handle.promise().Result);
             }
 
@@ -133,7 +133,7 @@ namespace NActors {
 
                 static std::coroutine_handle<> await_suspend(std::coroutine_handle<TTaskPromise<T>> h) noexcept {
                     auto next = std::exchange(h.promise().Continuation, std::noop_coroutine());
-                    Y_VERIFY_DEBUG(next, "Task finished without a continuation");
+                    Y_DEBUG_ABORT_UNLESS(next, "Task finished without a continuation");
                     return next;
                 }
             };
@@ -142,7 +142,7 @@ namespace NActors {
 
         private:
             void SetContinuation(std::coroutine_handle<> continuation) noexcept {
-                Y_VERIFY_DEBUG(!Continuation, "Task can only be awaited once");
+                Y_DEBUG_ABORT_UNLESS(!Continuation, "Task can only be awaited once");
                 Continuation = continuation;
             }
 
@@ -200,7 +200,7 @@ namespace NActors {
          * Starts task and returns TTaskResult<T> when it completes
          */
         auto WhenDone() && noexcept {
-            Y_VERIFY_DEBUG(Handle, "Cannot await an empty task");
+            Y_DEBUG_ABORT_UNLESS(Handle, "Cannot await an empty task");
             return NDetail::TTaskAwaiter<T>(std::exchange(Handle, {}));
         }
 
@@ -208,7 +208,7 @@ namespace NActors {
          * Starts task and returns its result when it completes
          */
         auto operator co_await() && noexcept {
-            Y_VERIFY_DEBUG(Handle, "Cannot await an empty task");
+            Y_DEBUG_ABORT_UNLESS(Handle, "Cannot await an empty task");
             return NDetail::TTaskResultAwaiter<T>(std::exchange(Handle, {}));
         }
 
diff --git a/library/cpp/actors/cppcoro/task_group.h b/library/cpp/actors/cppcoro/task_group.h
index 0f7a91262b..5b82e5f592 100644
--- a/library/cpp/actors/cppcoro/task_group.h
+++ b/library/cpp/actors/cppcoro/task_group.h
@@ -41,7 +41,7 @@ namespace NActors {
                             continue;
                         }
                         // We consume the awaiter
-                        Y_VERIFY_DEBUG(ReadyQueue == nullptr, "TaskGroup is awaiting with non-empty ready queue");
+                        Y_DEBUG_ABORT_UNLESS(ReadyQueue == nullptr, "TaskGroup is awaiting with non-empty ready queue");
                         result->Next = ReadyQueue;
                         ReadyQueue = result.release();
                         return std::exchange(Continuation, {});
@@ -66,7 +66,7 @@ namespace NActors {
             }
 
             Y_NO_INLINE std::coroutine_handle<> Suspend(std::coroutine_handle<> h) noexcept {
-                Y_VERIFY_DEBUG(ReadyQueue == nullptr, "Caller suspending with non-empty ready queue");
+                Y_DEBUG_ABORT_UNLESS(ReadyQueue == nullptr, "Caller suspending with non-empty ready queue");
                 Continuation = h;
                 void* currentValue = LastReady.load(std::memory_order_acquire);
                 for (;;) {
diff --git a/library/cpp/actors/cppcoro/task_result.h b/library/cpp/actors/cppcoro/task_result.h
index 70176e64d5..54e66fd57f 100644
--- a/library/cpp/actors/cppcoro/task_result.h
+++ b/library/cpp/actors/cppcoro/task_result.h
@@ -78,7 +78,7 @@ namespace NActors {
                 }
                 case 2: {
                     std::exception_ptr& e = std::get<2>(Result);
-                    Y_VERIFY_DEBUG(e, "Task exception missing");
+                    Y_DEBUG_ABORT_UNLESS(e, "Task exception missing");
                     std::rethrow_exception(e);
                 }
             }
@@ -99,7 +99,7 @@ namespace NActors {
                 }
                 case 2: {
                     std::exception_ptr& e = std::get<2>(Result);
-                    Y_VERIFY_DEBUG(e, "Task exception missing");
+                    Y_DEBUG_ABORT_UNLESS(e, "Task exception missing");
                     std::rethrow_exception(std::move(e));
                 }
             }
diff --git a/library/cpp/actors/http/http.h b/library/cpp/actors/http/http.h
index a2d8004a64..d96ab062e8 100644
--- a/library/cpp/actors/http/http.h
+++ b/library/cpp/actors/http/http.h
@@ -470,7 +470,7 @@ public:
 
     //THttpRenderer(TStringBuf method, TStringBuf url, TStringBuf protocol, TStringBuf version); // request
     void InitRequest(TStringBuf method, TStringBuf url, TStringBuf protocol, TStringBuf version) {
-        Y_VERIFY_DEBUG(Stage == ERenderStage::Init);
+        Y_DEBUG_ABORT_UNLESS(Stage == ERenderStage::Init);
         AppendParsedValue<&THttpRequest::Method>(method);
         Append(' ');
         AppendParsedValue<&THttpRequest::URL>(url);
@@ -485,7 +485,7 @@ public:
 
     //THttpRenderer(TStringBuf protocol, TStringBuf version, TStringBuf status, TStringBuf message); // response
     void InitResponse(TStringBuf protocol, TStringBuf version, TStringBuf status, TStringBuf message) {
-        Y_VERIFY_DEBUG(Stage == ERenderStage::Init);
+        Y_DEBUG_ABORT_UNLESS(Stage == ERenderStage::Init);
         AppendParsedValue<&THttpResponse::Protocol>(protocol);
         Append('/');
         AppendParsedValue<&THttpResponse::Version>(version);
@@ -516,7 +516,7 @@ public:
 
     template <TStringBuf HeaderType::* name>
     void Set(TStringBuf value) {
-        Y_VERIFY_DEBUG(Stage == ERenderStage::Header);
+        Y_DEBUG_ABORT_UNLESS(Stage == ERenderStage::Header);
         Append(HeaderType::template GetName<name>());
         Append(": ");
         AppendParsedValue<name>(value);
@@ -525,7 +525,7 @@ public:
     }
 
     void Set(TStringBuf name, TStringBuf value) {
-        Y_VERIFY_DEBUG(Stage == ERenderStage::Header);
+        Y_DEBUG_ABORT_UNLESS(Stage == ERenderStage::Header);
         Append(name);
         Append(": ");
         auto data = BufferType::Pos();
@@ -539,7 +539,7 @@ public:
     }
 
     void Set(const THeaders& headers) {
-        Y_VERIFY_DEBUG(Stage == ERenderStage::Header);
+        Y_DEBUG_ABORT_UNLESS(Stage == ERenderStage::Header);
         for (const auto& [name, value] : headers.Headers) {
             Set(name, value);
         }
@@ -549,7 +549,7 @@ public:
     static constexpr TStringBuf ALLOWED_CONTENT_ENCODINGS[] = {"deflate"};
 
     void SetContentEncoding(TStringBuf contentEncoding) {
-        Y_VERIFY_DEBUG(Stage == ERenderStage::Header);
+        Y_DEBUG_ABORT_UNLESS(Stage == ERenderStage::Header);
         if (Count(ALLOWED_CONTENT_ENCODINGS, contentEncoding) != 0) {
             Set("Content-Encoding", contentEncoding);
         }
@@ -562,7 +562,7 @@ public:
     }
 
     void SetBody(TStringBuf body) {
-        Y_VERIFY_DEBUG(Stage == ERenderStage::Header);
+        Y_DEBUG_ABORT_UNLESS(Stage == ERenderStage::Header);
         if (HeaderType::ContentLength.empty()) {
             Set<&HeaderType::ContentLength>(ToString(body.size()));
         }
diff --git a/library/cpp/actors/interconnect/channel_scheduler.h b/library/cpp/actors/interconnect/channel_scheduler.h
index 3040601ef2..b0eac9debc 100644
--- a/library/cpp/actors/interconnect/channel_scheduler.h
+++ b/library/cpp/actors/interconnect/channel_scheduler.h
@@ -48,7 +48,7 @@ namespace NActors {
         }
 
         void AddToHeap(TEventOutputChannel& channel, ui64 counter) {
-            Y_VERIFY_DEBUG(channel.IsWorking());
+            Y_DEBUG_ABORT_UNLESS(channel.IsWorking());
             ui64 weight = channel.WeightConsumedOnPause;
             weight -= Min(weight, counter - channel.EqualizeCounterOnPause);
             Heap.push_back(THeapItem{&channel, weight});
diff --git a/library/cpp/actors/interconnect/interconnect_channel.cpp b/library/cpp/actors/interconnect/interconnect_channel.cpp
index ab6af8f8d4..30f384786b 100644
--- a/library/cpp/actors/interconnect/interconnect_channel.cpp
+++ b/library/cpp/actors/interconnect/interconnect_channel.cpp
@@ -188,7 +188,7 @@ namespace NActors {
                 task.Append<External>(data, len);
             }
             *bytesSerialized += len;
-            Y_VERIFY_DEBUG(len <= PartLenRemain);
+            Y_DEBUG_ABORT_UNLESS(len <= PartLenRemain);
             PartLenRemain -= len;
 
             event.EventActuallySerialized += len;
@@ -275,7 +275,7 @@ namespace NActors {
         size_t bytesSerialized = 0;
         const bool complete = SerializeEvent<false>(task, event, &bytesSerialized);
 
-        Y_VERIFY_DEBUG(bytesSerialized);
+        Y_DEBUG_ABORT_UNLESS(bytesSerialized);
         Y_ABORT_UNLESS(bytesSerialized <= Max<ui16>());
 
         TChannelPart part{
diff --git a/library/cpp/actors/interconnect/interconnect_handshake.cpp b/library/cpp/actors/interconnect/interconnect_handshake.cpp
index 3c1e90115a..7783de1f92 100644
--- a/library/cpp/actors/interconnect/interconnect_handshake.cpp
+++ b/library/cpp/actors/interconnect/interconnect_handshake.cpp
@@ -346,7 +346,7 @@ namespace NActors {
                             auto ev = WaitForSpecificEvent<TEvReportConnection>("WaitInboundXdcStream");
                             SubscribedForConnection = false;
                             if (ev->Get()->HandshakeId != *HandshakeId) {
-                                Y_VERIFY_DEBUG(false);
+                                Y_DEBUG_ABORT_UNLESS(false);
                                 Fail(TEvHandshakeFail::HANDSHAKE_FAIL_PERMANENT, "Mismatching HandshakeId in external data channel");
                             }
                             ExternalDataChannel.GetSocketRef() = std::move(ev->Get()->Socket);
@@ -892,7 +892,7 @@ namespace NActors {
             // extract peer node id from the peer
             PeerNodeId = request.Header.SelfVirtualId.NodeId();
             if (!PeerNodeId) {
-                Y_VERIFY_DEBUG(false, "PeerNodeId is zero request# %s", request.ToString().data());
+                Y_DEBUG_ABORT_UNLESS(false, "PeerNodeId is zero request# %s", request.ToString().data());
                 Fail(TEvHandshakeFail::HANDSHAKE_FAIL_PERMANENT, "SelfVirtualId.NodeId is empty in initial packet");
             }
             UpdatePrefix();
diff --git a/library/cpp/actors/interconnect/interconnect_tcp_input_session.cpp b/library/cpp/actors/interconnect/interconnect_tcp_input_session.cpp
index 41fd36a824..5e29f49590 100644
--- a/library/cpp/actors/interconnect/interconnect_tcp_input_session.cpp
+++ b/library/cpp/actors/interconnect/interconnect_tcp_input_session.cpp
@@ -24,7 +24,7 @@ namespace NActors {
             const char *begin = buffer.data();
             const char *mid = begin + offset;
             const char *end = begin + buffer.size();
-            Y_VERIFY_DEBUG(begin <= mid && mid < end);
+            Y_DEBUG_ABORT_UNLESS(begin <= mid && mid < end);
 
             TRope rope;
             rope.Insert(rope.End(), TRcBuf(TRcBuf::Piece, mid, end, buffer));
@@ -34,16 +34,16 @@ namespace NActors {
 
             DropFront(&rope, buffer.size());
         } else {
-            Y_VERIFY_DEBUG(!XdcCatchBytesRead);
+            Y_DEBUG_ABORT_UNLESS(!XdcCatchBytesRead);
         }
     }
 
     void TReceiveContext::TPerChannelContext::FetchBuffers(ui16 channel, size_t numBytes,
             std::deque<std::tuple<ui16, TMutableContiguousSpan>>& outQ) {
-        Y_VERIFY_DEBUG(numBytes);
+        Y_DEBUG_ABORT_UNLESS(numBytes);
         auto it = XdcBuffers.begin() + FetchIndex;
         for (;;) {
-            Y_VERIFY_DEBUG(it != XdcBuffers.end());
+            Y_DEBUG_ABORT_UNLESS(it != XdcBuffers.end());
             const TMutableContiguousSpan span = it->SubSpan(FetchOffset, numBytes);
             outQ.emplace_back(channel, span);
             numBytes -= span.size();
@@ -60,7 +60,7 @@ namespace NActors {
     }
 
     void TReceiveContext::TPerChannelContext::DropFront(TRope *from, size_t numBytes) {
-        Y_VERIFY_DEBUG(from || !XdcCatchBuffer);
+        Y_DEBUG_ABORT_UNLESS(from || !XdcCatchBuffer);
 
         size_t n = numBytes;
         for (auto& pendingEvent : PendingEvents) {
@@ -73,7 +73,7 @@ namespace NActors {
         }
 
         while (numBytes) {
-            Y_VERIFY_DEBUG(!XdcBuffers.empty());
+            Y_DEBUG_ABORT_UNLESS(!XdcBuffers.empty());
             auto& front = XdcBuffers.front();
             if (from) {
                 from->ExtractFrontPlain(front.data(), Min(numBytes, front.size()));
@@ -81,13 +81,13 @@ namespace NActors {
             if (numBytes < front.size()) {
                 front = front.SubSpan(numBytes, Max<size_t>());
                 if (!FetchIndex) { // we are sending this very buffer, adjust sending offset
-                    Y_VERIFY_DEBUG(numBytes <= FetchOffset);
+                    Y_DEBUG_ABORT_UNLESS(numBytes <= FetchOffset);
                     FetchOffset -= numBytes;
                 }
                 break;
             } else {
                 numBytes -= front.size();
-                Y_VERIFY_DEBUG(FetchIndex);
+                Y_DEBUG_ABORT_UNLESS(FetchIndex);
                 --FetchIndex;
                 XdcBuffers.pop_front();
             }
@@ -240,7 +240,7 @@ namespace NActors {
                     }
 
                 case EState::PAYLOAD:
-                    Y_VERIFY_DEBUG(PayloadSize);
+                    Y_DEBUG_ABORT_UNLESS(PayloadSize);
                     if (!IncomingData) {
                         break;
                     } else {
@@ -369,7 +369,7 @@ namespace NActors {
         if (PayloadSize) {
             const ui64 expectedMin = Context->GetLastPacketSerialToConfirm() + 1;
             const ui64 expectedMax = Context->LastProcessedSerial + 1;
-            Y_VERIFY_DEBUG(expectedMin <= expectedMax);
+            Y_DEBUG_ABORT_UNLESS(expectedMin <= expectedMax);
             if (CurrentSerial ? serial != CurrentSerial + 1 : (serial == 0 || serial > expectedMin)) {
                 LOG_CRIT_IC_SESSION("ICIS06", "%s", TString(TStringBuilder()
                         << "packet serial number mismatch"
@@ -383,7 +383,7 @@ namespace NActors {
             IgnorePayload = serial != expectedMax;
             CurrentSerial = serial;
             State = EState::PAYLOAD;
-            Y_VERIFY_DEBUG(!Payload);
+            Y_DEBUG_ABORT_UNLESS(!Payload);
         } else if (serial & TTcpPacketBuf::PingRequestMask) {
             Send(SessionId, new TEvProcessPingRequest(serial & ~TTcpPacketBuf::PingRequestMask));
         } else if (serial & TTcpPacketBuf::PingResponseMask) {
@@ -488,10 +488,10 @@ namespace NActors {
 
         // mark packet as processed
         if (IgnorePayload) {
-            Y_VERIFY_DEBUG(CurrentSerial <= Context->LastProcessedSerial);
+            Y_DEBUG_ABORT_UNLESS(CurrentSerial <= Context->LastProcessedSerial);
         } else {
             ++Context->LastProcessedSerial;
-            Y_VERIFY_DEBUG(CurrentSerial == Context->LastProcessedSerial);
+            Y_DEBUG_ABORT_UNLESS(CurrentSerial == Context->LastProcessedSerial);
         }
         XdcCatchStream.Ready = Context->LastProcessedSerial == CurrentSerial;
         ApplyXdcCatchStream();
@@ -515,7 +515,7 @@ namespace NActors {
                 break;
             }
 
-            Y_VERIFY_DEBUG(front.Serial + InboundPacketQ.size() - 1 <= Context->LastProcessedSerial,
+            Y_DEBUG_ABORT_UNLESS(front.Serial + InboundPacketQ.size() - 1 <= Context->LastProcessedSerial,
                 "front.Serial# %" PRIu64 " LastProcessedSerial# %" PRIu64 " InboundPacketQ.size# %zu",
                 front.Serial, Context->LastProcessedSerial, InboundPacketQ.size());
 
@@ -643,7 +643,7 @@ namespace NActors {
                     LOG_CRIT_IC_SESSION("ICIS19", "unprocessed payload remains after shuffling"
                         " Type# 0x%08" PRIx32 " InternalPayload.size# %zu ExternalPayload.size# %zu",
                         descr.Type, pendingEvent.InternalPayload.size(), pendingEvent.ExternalPayload.size());
-                    Y_VERIFY_DEBUG(false);
+                    Y_DEBUG_ABORT_UNLESS(false);
                     throw TExReestablishConnection{TDisconnectReason::FormatError()};
                 }
             }
@@ -800,7 +800,7 @@ namespace NActors {
         if (Buffers.empty()) { // we have read all the data, increase number of buffers
             CurrentBuffers = Min(CurrentBuffers * 2, MaxBuffers);
         } else {
-            Y_VERIFY_DEBUG(numBuffersCovered);
+            Y_DEBUG_ABORT_UNLESS(numBuffersCovered);
 
             const size_t index = numBuffersCovered - 1;
 
@@ -858,7 +858,7 @@ namespace NActors {
             // scatter read data
             const char *in = XdcCatchStream.Buffer.data();
             while (recvres) {
-                Y_VERIFY_DEBUG(!XdcCatchStream.Markup.empty());
+                Y_DEBUG_ABORT_UNLESS(!XdcCatchStream.Markup.empty());
                 auto& [channel, apply, bytes] = XdcCatchStream.Markup.front();
                 size_t bytesInChannel = Min<size_t>(recvres, bytes);
                 bytes -= bytesInChannel;
@@ -893,7 +893,7 @@ namespace NActors {
 
     void TInputSessionTCP::ApplyXdcCatchStream() {
         if (!XdcCatchStream.Applied && XdcCatchStream.Ready && !XdcCatchStream.BytesPending) {
-            Y_VERIFY_DEBUG(XdcCatchStream.Markup.empty());
+            Y_DEBUG_ABORT_UNLESS(XdcCatchStream.Markup.empty());
 
             auto process = [&](auto& context) {
                 context.ApplyCatchBuffer();
@@ -967,7 +967,7 @@ namespace NActors {
                 Y_ABORT_UNLESS(!bytesToCut);
             }
 
-            Y_VERIFY_DEBUG(n);
+            Y_DEBUG_ABORT_UNLESS(n);
             auto& context = GetPerChannelContext(channel);
             context.DropFront(nullptr, n);
             ProcessEvents(context);
@@ -986,7 +986,7 @@ namespace NActors {
             return;
         }
         while (span.size()) {
-            Y_VERIFY_DEBUG(!XdcChecksumQ.empty());
+            Y_DEBUG_ABORT_UNLESS(!XdcChecksumQ.empty());
             auto& [size, expected] = XdcChecksumQ.front();
             const size_t n = Min<size_t>(size, span.size());
             if (Params.UseXxhash) {
diff --git a/library/cpp/actors/interconnect/interconnect_tcp_proxy.h b/library/cpp/actors/interconnect/interconnect_tcp_proxy.h
index b03b406195..4622bf3f88 100644
--- a/library/cpp/actors/interconnect/interconnect_tcp_proxy.h
+++ b/library/cpp/actors/interconnect/interconnect_tcp_proxy.h
@@ -364,7 +364,7 @@ namespace NActors {
                     " THIS IS NOT A BUG IN INTERCONNECT, check the event sender instead",
                     ev->Type, ev->GetTypeRewrite(), ev->Sender.ToString().data());
                 LOG_ERROR_IC("ICP03", "%s", msg.data());
-                Y_VERIFY_DEBUG(false, "%s", msg.data());
+                Y_DEBUG_ABORT_UNLESS(false, "%s", msg.data());
             }
 
             Y_ABORT_UNLESS(ev->GetTypeRewrite() != TEvInterconnect::EvForward || ev->Recipient.NodeId() == PeerNodeId,
@@ -499,7 +499,7 @@ namespace NActors {
             auto& msg = *ev->Get();
             if (msg.Subscribe) {
                 if (const auto [it, inserted] = ConnectionSubscriptions.emplace(msg.HandshakeId, ev->Sender); !inserted) {
-                    Y_VERIFY_DEBUG(false);
+                    Y_DEBUG_ABORT_UNLESS(false);
                     ConnectionSubscriptions.erase(it); // collision happened somehow?
                 }
             } else {
diff --git a/library/cpp/actors/interconnect/interconnect_tcp_session.cpp b/library/cpp/actors/interconnect/interconnect_tcp_session.cpp
index 3644706e51..59738b2052 100644
--- a/library/cpp/actors/interconnect/interconnect_tcp_session.cpp
+++ b/library/cpp/actors/interconnect/interconnect_tcp_session.cpp
@@ -591,7 +591,7 @@ namespace NActors {
         static constexpr size_t maxBytesAtOnce = 256 * 1024;
         size_t bytesToSendInMain = maxBytesAtOnce;
 
-        Y_VERIFY_DEBUG(OutgoingIndex < SendQueue.size() || (OutgoingIndex == SendQueue.size() && !OutgoingOffset && !OutgoingStream));
+        Y_DEBUG_ABORT_UNLESS(OutgoingIndex < SendQueue.size() || (OutgoingIndex == SendQueue.size() && !OutgoingOffset && !OutgoingStream));
 
         if (OutOfBandStream) {
             bytesToSendInMain = 0;
@@ -603,7 +603,7 @@ namespace NActors {
             // align send up to packet boundary
             size_t offset = OutgoingOffset;
             for (auto it = sendQueueIt; ForcedWriteLength; ++it, offset = 0) {
-                Y_VERIFY_DEBUG(it != SendQueue.end());
+                Y_DEBUG_ABORT_UNLESS(it != SendQueue.end());
                 bytesToSendInMain += it->PacketSize - offset; // send remainder of current packet
                 ForcedWriteLength -= Min(it->PacketSize - offset, ForcedWriteLength);
             }
@@ -861,7 +861,7 @@ namespace NActors {
         size_t bytesDropped = 0;
         size_t bytesDroppedFromXdc = 0;
         ui64 frontPacketSerial = OutputCounter - SendQueue.size() + 1;
-        Y_VERIFY_DEBUG(OutgoingIndex < SendQueue.size() || (OutgoingIndex == SendQueue.size() && !OutgoingOffset && !OutgoingStream),
+        Y_DEBUG_ABORT_UNLESS(OutgoingIndex < SendQueue.size() || (OutgoingIndex == SendQueue.size() && !OutgoingOffset && !OutgoingStream),
             "OutgoingIndex# %zu SendQueue.size# %zu OutgoingOffset# %zu Unsent# %zu Total# %zu",
             OutgoingIndex, SendQueue.size(), OutgoingOffset, OutgoingStream.CalculateUnsentSize(),
             OutgoingStream.CalculateOutgoingSize());
@@ -910,7 +910,7 @@ namespace NActors {
         Y_ABORT_UNLESS(NumEventsInQueue);
         while (NumEventsInQueue) {
             TEventOutputChannel *channel = ChannelScheduler->PickChannelWithLeastConsumedWeight();
-            Y_VERIFY_DEBUG(!channel->IsEmpty());
+            Y_DEBUG_ABORT_UNLESS(!channel->IsEmpty());
 
             // generate some data within this channel
             const ui64 netBefore = channel->GetBufferedAmountOfData();
@@ -918,14 +918,14 @@ namespace NActors {
             const bool eventDone = channel->FeedBuf(task, serial, &gross);
             channel->UnaccountedTraffic += gross;
             const ui64 netAfter = channel->GetBufferedAmountOfData();
-            Y_VERIFY_DEBUG(netAfter <= netBefore); // net amount should shrink
+            Y_DEBUG_ABORT_UNLESS(netAfter <= netBefore); // net amount should shrink
             const ui64 net = netBefore - netAfter; // number of net bytes serialized
 
             // adjust metrics for local and global queue size
             TotalOutputQueueSize -= net;
             Proxy->Metrics->SubOutputBuffersTotalSize(net);
             bytesGenerated += gross;
-            Y_VERIFY_DEBUG(!!net == !!gross && gross >= net, "net# %" PRIu64 " gross# %" PRIu64, net, gross);
+            Y_DEBUG_ABORT_UNLESS(!!net == !!gross && gross >= net, "net# %" PRIu64 " gross# %" PRIu64, net, gross);
 
             // return it back to queue or delete, depending on whether this channel is still working or not
             ChannelScheduler->FinishPick(gross, EqualizeCounter);
diff --git a/library/cpp/actors/interconnect/interconnect_tcp_session.h b/library/cpp/actors/interconnect/interconnect_tcp_session.h
index a499d189c2..64519b2667 100644
--- a/library/cpp/actors/interconnect/interconnect_tcp_session.h
+++ b/library/cpp/actors/interconnect/interconnect_tcp_session.h
@@ -162,7 +162,7 @@ namespace NActors {
                 if (value & LastPacketSerialToConfirmLockBit) {
                     return false;
                 }
-                Y_VERIFY_DEBUG(value + 1 == nextValue);
+                Y_DEBUG_ABORT_UNLESS(value + 1 == nextValue);
                 if (LastPacketSerialToConfirm.compare_exchange_weak(value, nextValue)) {
                     return true;
                 }
diff --git a/library/cpp/actors/interconnect/outgoing_stream.h b/library/cpp/actors/interconnect/outgoing_stream.h
index 23982c4a3e..47803764d7 100644
--- a/library/cpp/actors/interconnect/outgoing_stream.h
+++ b/library/cpp/actors/interconnect/outgoing_stream.h
@@ -134,7 +134,7 @@ namespace NInterconnect {
 
         void WriteBookmark(TBookmark&& bookmark, TContiguousSpan in) {
             for (auto& outChunk : bookmark) {
-                Y_VERIFY_DEBUG(outChunk.size() <= in.size());
+                Y_DEBUG_ABORT_UNLESS(outChunk.size() <= in.size());
                 memcpy(outChunk.data(), in.data(), outChunk.size());
                 in = in.SubSpan(outChunk.size(), Max<size_t>());
             }
@@ -167,24 +167,24 @@ namespace NInterconnect {
         }
 
         void Advance(size_t numBytes) { // called when numBytes portion of data has been sent
-            Y_VERIFY_DEBUG(numBytes == 0 || SendQueuePos != SendQueue.size());
-            Y_VERIFY_DEBUG(numBytes <= UnsentBytes);
+            Y_DEBUG_ABORT_UNLESS(numBytes == 0 || SendQueuePos != SendQueue.size());
+            Y_DEBUG_ABORT_UNLESS(numBytes <= UnsentBytes);
             SendOffset += numBytes;
             UnsentBytes -= numBytes;
             for (auto it = SendQueue.begin() + SendQueuePos; SendOffset && it->Span.size() <= SendOffset; ++SendQueuePos, ++it) {
                 SendOffset -= it->Span.size();
-                Y_VERIFY_DEBUG(SendOffset == 0 || SendQueuePos != SendQueue.size() - 1);
+                Y_DEBUG_ABORT_UNLESS(SendOffset == 0 || SendQueuePos != SendQueue.size() - 1);
             }
         }
 
         void DropFront(size_t numBytes) { // drops first numBytes from the queue, freeing buffers when necessary
             while (numBytes) {
-                Y_VERIFY_DEBUG(!SendQueue.empty());
+                Y_DEBUG_ABORT_UNLESS(!SendQueue.empty());
                 auto& front = SendQueue.front();
                 if (numBytes < front.Span.size()) {
                     front.Span = front.Span.SubSpan(numBytes, Max<size_t>());
                     if (SendQueuePos == 0) {
-                        Y_VERIFY_DEBUG(numBytes <= SendOffset, "numBytes# %zu SendOffset# %zu SendQueuePos# %zu"
+                        Y_DEBUG_ABORT_UNLESS(numBytes <= SendOffset, "numBytes# %zu SendOffset# %zu SendQueuePos# %zu"
                             " SendQueue.size# %zu CalculateUnsentSize# %zu", numBytes, SendOffset, SendQueuePos,
                             SendQueue.size(), CalculateUnsentSize());
                         SendOffset -= numBytes;
@@ -193,7 +193,7 @@ namespace NInterconnect {
                 } else {
                     numBytes -= front.Span.size();
                 }
-                Y_VERIFY_DEBUG(!front.Buffer || (front.Span.data() >= front.Buffer->Data &&
+                Y_DEBUG_ABORT_UNLESS(!front.Buffer || (front.Span.data() >= front.Buffer->Data &&
                     front.Span.data() + front.Span.size() <= front.Buffer->Data + BufferSize));
                 DropBufferReference(front.Buffer);
                 SendQueue.pop_front();
@@ -210,7 +210,7 @@ namespace NInterconnect {
             auto it = SendQueue.end();
             ssize_t offset = -numBytes;
             while (offset < 0) {
-                Y_VERIFY_DEBUG(it != SendQueue.begin());
+                Y_DEBUG_ABORT_UNLESS(it != SendQueue.begin());
                 const TSendChunk& chunk = *--it;
                 offset += chunk.Span.size();
             }
@@ -222,10 +222,10 @@ namespace NInterconnect {
     private:
         void AppendAcquiredSpan(TContiguousSpan span) {
             TBuffer *buffer = AppendBuffer;
-            Y_VERIFY_DEBUG(buffer);
-            Y_VERIFY_DEBUG(span.data() == AppendBuffer->Data + AppendOffset);
+            Y_DEBUG_ABORT_UNLESS(buffer);
+            Y_DEBUG_ABORT_UNLESS(span.data() == AppendBuffer->Data + AppendOffset);
             AppendOffset += span.size();
-            Y_VERIFY_DEBUG(AppendOffset <= BufferSize);
+            Y_DEBUG_ABORT_UNLESS(AppendOffset <= BufferSize);
             if (AppendOffset == BufferSize) {
                 AppendBuffer = nullptr;
             } else {
@@ -239,7 +239,7 @@ namespace NInterconnect {
             if (!SendQueue.empty()) {
                 auto& back = SendQueue.back();
                 if (back.Span.data() + back.Span.size() == span.data()) { // check if it is possible just to extend the last span
-                    Y_VERIFY_DEBUG(buffer == back.Buffer);
+                    Y_DEBUG_ABORT_UNLESS(buffer == back.Buffer);
                     if (SendQueuePos == SendQueue.size()) {
                         --SendQueuePos;
                         SendOffset = back.Span.size();
@@ -256,7 +256,7 @@ namespace NInterconnect {
             if (buffer && !--buffer->RefCount) {
                 const size_t index = buffer->Index;
                 auto& cell = Buffers[index];
-                Y_VERIFY_DEBUG(cell.get() == buffer);
+                Y_DEBUG_ABORT_UNLESS(cell.get() == buffer);
                 std::swap(cell, Buffers.back());
                 cell->Index = index;
                 Buffers.pop_back();
diff --git a/library/cpp/actors/interconnect/packet.h b/library/cpp/actors/interconnect/packet.h
index 105cc41ce3..0a748cda2a 100644
--- a/library/cpp/actors/interconnect/packet.h
+++ b/library/cpp/actors/interconnect/packet.h
@@ -162,12 +162,12 @@ struct TTcpPacketOutTask : TNonCopyable {
     // Preallocate some space to fill it later.
     NInterconnect::TOutgoingStream::TBookmark Bookmark(size_t len) {
         if (ChecksummingCrc32c()) {
-            Y_VERIFY_DEBUG(!InsideBookmark);
+            Y_DEBUG_ABORT_UNLESS(!InsideBookmark);
             InsideBookmark = true;
             PreBookmarkChecksum = std::exchange(InternalChecksum, 0);
             InternalChecksumLen = 0;
         }
-        Y_VERIFY_DEBUG(len <= GetInternalFreeAmount());
+        Y_DEBUG_ABORT_UNLESS(len <= GetInternalFreeAmount());
         InternalSize += len;
         return OutgoingStream.Bookmark(len);
     }
@@ -175,7 +175,7 @@ struct TTcpPacketOutTask : TNonCopyable {
     // Write previously bookmarked space.
     void WriteBookmark(NInterconnect::TOutgoingStream::TBookmark&& bookmark, const void *buffer, size_t len) {
         if (ChecksummingCrc32c()) {
-            Y_VERIFY_DEBUG(InsideBookmark);
+            Y_DEBUG_ABORT_UNLESS(InsideBookmark);
             InsideBookmark = false;
             const ui32 bookmarkChecksum = Crc32cExtendMSanCompatible(PreBookmarkChecksum, buffer, len);
             InternalChecksum = Crc32cCombine(bookmarkChecksum, InternalChecksum, InternalChecksumLen);
@@ -196,7 +196,7 @@ struct TTcpPacketOutTask : TNonCopyable {
     // Append reference to some data (acquired previously or external pointer).
     template<bool External>
     void Append(const void *buffer, size_t len) {
-        Y_VERIFY_DEBUG(len <= (External ? GetExternalFreeAmount() : GetInternalFreeAmount()));
+        Y_DEBUG_ABORT_UNLESS(len <= (External ? GetExternalFreeAmount() : GetInternalFreeAmount()));
         (External ? ExternalSize : InternalSize) += len;
         (External ? XdcStream : OutgoingStream).Append({static_cast<const char*>(buffer), len});
         ProcessChecksum<External>(buffer, len);
@@ -205,7 +205,7 @@ struct TTcpPacketOutTask : TNonCopyable {
     // Write some data with copying.
     template<bool External>
     void Write(const void *buffer, size_t len) {
-        Y_VERIFY_DEBUG(len <= (External ? GetExternalFreeAmount() : GetInternalFreeAmount()));
+        Y_DEBUG_ABORT_UNLESS(len <= (External ? GetExternalFreeAmount() : GetInternalFreeAmount()));
         (External ? ExternalSize : InternalSize) += len;
         (External ? XdcStream : OutgoingStream).Write({static_cast<const char*>(buffer), len});
         ProcessChecksum<External>(buffer, len);
@@ -246,7 +246,7 @@ struct TTcpPacketOutTask : TNonCopyable {
             });
             header.Checksum = XXH3_64bits_digest(&state);
         } else if (ChecksummingCrc32c()) {
-            Y_VERIFY_DEBUG(!InsideBookmark);
+            Y_DEBUG_ABORT_UNLESS(!InsideBookmark);
             const ui32 headerChecksum = Crc32cExtendMSanCompatible(0, &header, sizeof(header));
             header.Checksum = Crc32cCombine(headerChecksum, InternalChecksum, InternalSize);
         }
diff --git a/library/cpp/actors/interconnect/poller_tcp.cpp b/library/cpp/actors/interconnect/poller_tcp.cpp
index 8267df31ea..ab9b7c85ea 100644
--- a/library/cpp/actors/interconnect/poller_tcp.cpp
+++ b/library/cpp/actors/interconnect/poller_tcp.cpp
@@ -4,7 +4,7 @@ namespace NInterconnect {
     TPollerThreads::TPollerThreads(size_t units, bool useSelect)
         : Units(units)
     {
-        Y_VERIFY_DEBUG(!Units.empty());
+        Y_DEBUG_ABORT_UNLESS(!Units.empty());
         for (auto& unit : Units)
             unit = TPollerUnit::Make(useSelect);
     }
diff --git a/library/cpp/actors/interconnect/poller_tcp_unit.cpp b/library/cpp/actors/interconnect/poller_tcp_unit.cpp
index 59e7dda810..853fce04b4 100644
--- a/library/cpp/actors/interconnect/poller_tcp_unit.cpp
+++ b/library/cpp/actors/interconnect/poller_tcp_unit.cpp
@@ -67,7 +67,7 @@ namespace NInterconnect {
     TPollerUnit::StartReadOperation(
         const TIntrusivePtr<TSharedDescriptor>& stream,
         TFDDelegate&& operation) {
-        Y_VERIFY_DEBUG(stream);
+        Y_DEBUG_ABORT_UNLESS(stream);
         if (AtomicLoad(&StopFlag))
             return;
         GetSide<false>().InputQueue.Push(TSide::TItem(stream, std::move(operation)));
@@ -77,7 +77,7 @@ namespace NInterconnect {
     TPollerUnit::StartWriteOperation(
         const TIntrusivePtr<TSharedDescriptor>& stream,
         TFDDelegate&& operation) {
-        Y_VERIFY_DEBUG(stream);
+        Y_DEBUG_ABORT_UNLESS(stream);
         if (AtomicLoad(&StopFlag))
             return;
         GetSide<true>().InputQueue.Push(TSide::TItem(stream, std::move(operation)));
diff --git a/library/cpp/actors/interconnect/poller_tcp_unit_epoll.cpp b/library/cpp/actors/interconnect/poller_tcp_unit_epoll.cpp
index 5067f6724f..33666a2747 100644
--- a/library/cpp/actors/interconnect/poller_tcp_unit_epoll.cpp
+++ b/library/cpp/actors/interconnect/poller_tcp_unit_epoll.cpp
@@ -31,7 +31,7 @@ namespace NInterconnect {
         int
         Initialize() {
             const auto epoll = ::epoll_create(10000);
-            Y_VERIFY_DEBUG(epoll > 0);
+            Y_DEBUG_ABORT_UNLESS(epoll > 0);
             return epoll;
         }
 
diff --git a/library/cpp/actors/interconnect/poller_tcp_unit_select.cpp b/library/cpp/actors/interconnect/poller_tcp_unit_select.cpp
index ae7aaad566..1615d4679d 100644
--- a/library/cpp/actors/interconnect/poller_tcp_unit_select.cpp
+++ b/library/cpp/actors/interconnect/poller_tcp_unit_select.cpp
@@ -60,7 +60,7 @@ namespace NInterconnect {
         const auto numberEvents = ::pselect(FD_SETSIZE, &sets[R], &sets[W], &sets[E], &timeout, &sigmask);
 #endif
 
-        Y_VERIFY_DEBUG(numberEvents >= 0);
+        Y_DEBUG_ABORT_UNLESS(numberEvents >= 0);
 
         for (auto it = side.Operations.cbegin(); side.Operations.cend() != it;) {
             if (FD_ISSET(it->first, &sets[O]) || FD_ISSET(it->first, &sets[E]))
diff --git a/library/cpp/actors/interconnect/watchdog_timer.h b/library/cpp/actors/interconnect/watchdog_timer.h
index 66cf19dc4d..2a5860f84c 100644
--- a/library/cpp/actors/interconnect/watchdog_timer.h
+++ b/library/cpp/actors/interconnect/watchdog_timer.h
@@ -37,7 +37,7 @@ namespace NActors {
         }
 
         void operator()(typename TEvent::TPtr& ev) {
-            Y_VERIFY_DEBUG(EventScheduled);
+            Y_DEBUG_ABORT_UNLESS(EventScheduled);
             EventScheduled = false;
             if (!Armed()) {
                 // just do nothing
@@ -58,7 +58,7 @@ namespace NActors {
 
     private:
         void Schedule(const TActorIdentity& actor) {
-            Y_VERIFY_DEBUG(Armed());
+            Y_DEBUG_ABORT_UNLESS(Armed());
             if (!EventScheduled) {
                 actor.Schedule(TriggerTimestamp, new TEvent);
                 EventScheduled = true;
diff --git a/library/cpp/actors/util/affinity.cpp b/library/cpp/actors/util/affinity.cpp
index cc1b6e70ec..5851105ae7 100644
--- a/library/cpp/actors/util/affinity.cpp
+++ b/library/cpp/actors/util/affinity.cpp
@@ -12,7 +12,7 @@ public:
     TImpl() {
 #ifdef _linux_
         int ar = sched_getaffinity(0, sizeof(cpu_set_t), &Mask);
-        Y_VERIFY_DEBUG(ar == 0);
+        Y_DEBUG_ABORT_UNLESS(ar == 0);
 #endif
     }
 
@@ -33,7 +33,7 @@ public:
     void Set() const {
 #ifdef _linux_
         int ar = sched_setaffinity(0, sizeof(cpu_set_t), &Mask);
-        Y_VERIFY_DEBUG(ar == 0);
+        Y_DEBUG_ABORT_UNLESS(ar == 0);
 #endif
     }
 
diff --git a/library/cpp/actors/util/queue_oneone_inplace.h b/library/cpp/actors/util/queue_oneone_inplace.h
index d7ec8bb21c..288011955a 100644
--- a/library/cpp/actors/util/queue_oneone_inplace.h
+++ b/library/cpp/actors/util/queue_oneone_inplace.h
@@ -48,7 +48,7 @@ public:
     }
 
     ~TOneOneQueueInplace() {
-        Y_VERIFY_DEBUG(Head() == 0);
+        Y_DEBUG_ABORT_UNLESS(Head() == 0);
         delete ReadFrom;
     }
 
diff --git a/library/cpp/actors/util/rc_buf.h b/library/cpp/actors/util/rc_buf.h
index 638a410f6b..b5b15fa4cc 100644
--- a/library/cpp/actors/util/rc_buf.h
+++ b/library/cpp/actors/util/rc_buf.h
@@ -69,7 +69,7 @@ public:
     {}
 
     const char& operator[](size_t index) const {
-        Y_VERIFY_DEBUG(index < Size_);
+        Y_DEBUG_ABORT_UNLESS(index < Size_);
         return Data_[index];
     }
 
@@ -639,7 +639,7 @@ class TRcBuf {
             if constexpr (sizeof(TObject) <= sizeof(TBackendHolder)) {
                 TBackendHolder res = TBackend::Empty;
                 new(&res) std::decay_t<TObject>(std::forward<TObject>(object));
-                Y_VERIFY_DEBUG((res.Data[0] & ValueMask) == res.Data[0]);
+                Y_DEBUG_ABORT_UNLESS((res.Data[0] & ValueMask) == res.Data[0]);
                 res.Data[0] = res.Data[0] | static_cast<uintptr_t>(type);
                 return res;
             } else {
@@ -649,7 +649,7 @@ class TRcBuf {
 
         template<typename TOwner, typename TCallback, bool IsConst = std::is_const_v<TOwner>>
         static std::invoke_result_t<TCallback, EType, std::conditional_t<IsConst, const TString&, TString&>> VisitRaw(TOwner& origValue, TCallback&& callback) {
-            Y_VERIFY_DEBUG(origValue);
+            Y_DEBUG_ABORT_UNLESS(origValue);
             const EType type = static_cast<EType>(origValue.Data[0] & TypeMask);
             TBackendHolder value(origValue);
             value.Data[0] = value.Data[0] & ValueMask;
diff --git a/library/cpp/actors/util/rc_buf_backend.h b/library/cpp/actors/util/rc_buf_backend.h
index f7089a302c..9cb8616554 100644
--- a/library/cpp/actors/util/rc_buf_backend.h
+++ b/library/cpp/actors/util/rc_buf_backend.h
@@ -157,12 +157,12 @@ public:
 
 private:
     Y_FORCE_INLINE THeader* Header() const noexcept {
-        Y_VERIFY_DEBUG(Data_);
+        Y_DEBUG_ABORT_UNLESS(Data_);
         return reinterpret_cast<THeader*>(Data_);
     }
 
     Y_FORCE_INLINE char* Data() const noexcept {
-        Y_VERIFY_DEBUG(Data_);
+        Y_DEBUG_ABORT_UNLESS(Data_);
         return Data_ + OverheadSize;
     }
 
diff --git a/library/cpp/actors/util/rope.h b/library/cpp/actors/util/rope.h
index 1ab9a1b8ee..4487fdc87d 100644
--- a/library/cpp/actors/util/rope.h
+++ b/library/cpp/actors/util/rope.h
@@ -162,7 +162,7 @@ private:
             CheckValid();
 
             while (amount) {
-                Y_VERIFY_DEBUG(Valid());
+                Y_DEBUG_ABORT_UNLESS(Valid());
                 const size_t max = ContiguousSize();
                 const size_t num = std::min(amount, max);
                 amount -= num;
@@ -189,7 +189,7 @@ private:
                 amount -= num;
                 Ptr -= num;
                 if (amount) {
-                    Y_VERIFY_DEBUG(Iter != GetChainBegin());
+                    Y_DEBUG_ABORT_UNLESS(Iter != GetChainBegin());
                     --Iter;
                     Ptr = Iter->End;
                 }
@@ -253,7 +253,7 @@ private:
         // Advance to next contiguous block of data.
         void AdvanceToNextContiguousBlock() {
             CheckValid();
-            Y_VERIFY_DEBUG(Valid());
+            Y_DEBUG_ABORT_UNLESS(Valid());
             ++Iter;
             Ptr = Iter != GetChainEnd() ? Iter->Begin : nullptr;
         }
@@ -263,7 +263,7 @@ private:
             CheckValid();
 
             while (len) {
-                Y_VERIFY_DEBUG(Ptr);
+                Y_DEBUG_ABORT_UNLESS(Ptr);
 
                 // calculate amount of bytes we need to move
                 const size_t max = ContiguousSize();
@@ -290,7 +290,7 @@ private:
 
         template<bool IsOtherConst>
         bool operator ==(const TIteratorImpl<IsOtherConst>& other) const {
-            Y_VERIFY_DEBUG(Rope == other.Rope);
+            Y_DEBUG_ABORT_UNLESS(Rope == other.Rope);
             CheckValid();
             other.CheckValid();
             return Iter == other.Iter && Ptr == other.Ptr;
@@ -399,7 +399,7 @@ public:
     }
 
     TRope(TConstIterator begin, TConstIterator end) {
-        Y_VERIFY_DEBUG(begin.Rope == end.Rope);
+        Y_DEBUG_ABORT_UNLESS(begin.Rope == end.Rope);
         if (begin.Rope == this) {
             TRope temp(begin, end);
             *this = std::move(temp);
@@ -545,8 +545,8 @@ public:
     }
 
     void Insert(TIterator pos, TRope&& rope) {
-        Y_VERIFY_DEBUG(this == pos.Rope);
-        Y_VERIFY_DEBUG(this != &rope);
+        Y_DEBUG_ABORT_UNLESS(this == pos.Rope);
+        Y_DEBUG_ABORT_UNLESS(this != &rope);
 
         if (!rope) {
             return; // do nothing for empty rope
@@ -595,16 +595,16 @@ public:
         if (rope) { // insert remains
             Chain.Splice(pos.Iter, rope.Chain, rope.Chain.begin(), rope.Chain.end());
         }
-        Y_VERIFY_DEBUG(!rope);
+        Y_DEBUG_ABORT_UNLESS(!rope);
         InvalidateIterators();
     }
 
     void EraseFront(size_t len) {
-        Y_VERIFY_DEBUG(Size >= len);
+        Y_DEBUG_ABORT_UNLESS(Size >= len);
         Size -= len;
 
         while (len) {
-            Y_VERIFY_DEBUG(Chain);
+            Y_DEBUG_ABORT_UNLESS(Chain);
             TRcBuf& item = Chain.GetFirstChunk();
             const size_t itemSize = item.GetSize();
             if (len >= itemSize) {
@@ -620,11 +620,11 @@ public:
     }
 
     void EraseBack(size_t len) {
-        Y_VERIFY_DEBUG(Size >= len);
+        Y_DEBUG_ABORT_UNLESS(Size >= len);
         Size -= len;
 
         while (len) {
-            Y_VERIFY_DEBUG(Chain);
+            Y_DEBUG_ABORT_UNLESS(Chain);
             TRcBuf& item = Chain.GetLastChunk();
             const size_t itemSize = item.GetSize();
             if (len >= itemSize) {
@@ -647,7 +647,7 @@ public:
         Size -= len;
         while (len) {
             auto& chunk = Chain.GetFirstChunk();
-            Y_VERIFY_DEBUG(chunk.Backend);
+            Y_DEBUG_ABORT_UNLESS(chunk.Backend);
             const size_t num = Min(len, chunk.GetSize());
             memcpy(buffer, chunk.Begin, num);
             buffer = static_cast<char*>(buffer) + num;
@@ -848,7 +848,7 @@ public:
 private:
     void Cut(TIterator begin, TIterator end, TRope *target) {
         // ensure all iterators are belong to us
-        Y_VERIFY_DEBUG(this == begin.Rope && this == end.Rope);
+        Y_DEBUG_ABORT_UNLESS(this == begin.Rope && this == end.Rope);
 
         // if begin and end are equal, we do nothing -- checking this case allows us to find out that begin does not
         // point to End(), for example
@@ -886,7 +886,7 @@ private:
             // now drop full blocks
             size_t rangeSize = 0;
             for (auto it = begin.Iter; it != end.Iter; ++it) {
-                Y_VERIFY_DEBUG(it->GetSize());
+                Y_DEBUG_ABORT_UNLESS(it->GetSize());
                 rangeSize += it->GetSize();
             }
             if (rangeSize) {
@@ -927,7 +927,7 @@ public:
         while (len) {
             if (Arena) {
                 auto iter = Arena.Begin();
-                Y_VERIFY_DEBUG(iter.Valid());
+                Y_DEBUG_ABORT_UNLESS(iter.Valid());
                 char *dest = const_cast<char*>(iter.ContiguousData());
                 const size_t bytesToCopy = std::min(len, iter.ContiguousSize());
                 memcpy(dest, buffer, bytesToCopy);
@@ -952,7 +952,7 @@ public:
 struct TRopeUtils {
     static void Memset(TRope::TConstIterator dst, char c, size_t size) {
         while (size) {
-            Y_VERIFY_DEBUG(dst.Valid());
+            Y_DEBUG_ABORT_UNLESS(dst.Valid());
             size_t len = std::min(size, dst.ContiguousSize());
             memset(const_cast<char*>(dst.ContiguousData()), c, len);
             dst += len;
@@ -962,7 +962,7 @@ struct TRopeUtils {
 
     static void Memcpy(TRope::TConstIterator dst, TRope::TConstIterator src, size_t size) {
         while (size) {
-            Y_VERIFY_DEBUG(dst.Valid() && src.Valid(),
+            Y_DEBUG_ABORT_UNLESS(dst.Valid() && src.Valid(),
                     "Invalid iterator in memcpy: dst.Valid() - %" PRIu32 ", src.Valid() - %" PRIu32,
                       (ui32)dst.Valid(), (ui32)src.Valid());
             size_t len = std::min(size, std::min(dst.ContiguousSize(), src.ContiguousSize()));
@@ -975,7 +975,7 @@ struct TRopeUtils {
 
     static void Memcpy(TRope::TConstIterator dst, const char* src, size_t size) {
         while (size) {
-            Y_VERIFY_DEBUG(dst.Valid());
+            Y_DEBUG_ABORT_UNLESS(dst.Valid());
             size_t len = std::min(size, dst.ContiguousSize());
             memcpy(const_cast<char*>(dst.ContiguousData()), src, len);
             size -= len;
@@ -986,7 +986,7 @@ struct TRopeUtils {
 
     static void Memcpy(char* dst, TRope::TConstIterator src, size_t size) {
         while (size) {
-            Y_VERIFY_DEBUG(src.Valid());
+            Y_DEBUG_ABORT_UNLESS(src.Valid());
             size_t len = std::min(size, src.ContiguousSize());
             memcpy(dst, src.ContiguousData(), len);
             size -= len;
@@ -1080,13 +1080,13 @@ class TRopeZeroCopyInput : public IZeroCopyInput {
 
 private:
     size_t DoNext(const void** ptr, size_t len) override {
-        Y_VERIFY_DEBUG(ptr);
+        Y_DEBUG_ABORT_UNLESS(ptr);
         if (Len == 0) {
             if (Iter.Valid()) {
                 Data = Iter.ContiguousData();
                 Len = Iter.ContiguousSize();
-                Y_VERIFY_DEBUG(Len);
-                Y_VERIFY_DEBUG(Data);
+                Y_DEBUG_ABORT_UNLESS(Len);
+                Y_DEBUG_ABORT_UNLESS(Data);
                 ++Iter;
             } else {
                 Data = nullptr;
diff --git a/library/cpp/actors/util/rope_cont_embedded_list.h b/library/cpp/actors/util/rope_cont_embedded_list.h
index 80d5990310..294599538f 100644
--- a/library/cpp/actors/util/rope_cont_embedded_list.h
+++ b/library/cpp/actors/util/rope_cont_embedded_list.h
@@ -40,14 +40,14 @@ class TChunkList {
         }
 
         void ClearSingleItem() {
-            Y_VERIFY_DEBUG(Next == this && Prev == this);
+            Y_DEBUG_ABORT_UNLESS(Next == this && Prev == this);
             static_cast<TChunk&>(*this) = {};
             Next = Prev = nullptr;
         }
 
         template<typename... TArgs>
         TItem *PrepareForUse(TArgs&&... args) {
-            Y_VERIFY_DEBUG(!IsInUse());
+            Y_DEBUG_ABORT_UNLESS(!IsInUse());
             static_cast<TChunk&>(*this) = TChunk(std::forward<TArgs>(args)...);
             Next = Prev = this;
             Invalidate();
@@ -136,7 +136,7 @@ private:
 
         TIterator& operator++() {
             CheckValid();
-            Y_VERIFY_DEBUG(Item);
+            Y_DEBUG_ABORT_UNLESS(Item);
             Item = Item->Next;
             if (Item == &Cont->Root) {
                 Item = nullptr; // make it end
@@ -154,10 +154,10 @@ private:
         TIterator& operator--() {
             CheckValid();
             if (!Item) {
-                Y_VERIFY_DEBUG(*Cont);
+                Y_DEBUG_ABORT_UNLESS(*Cont);
                 Item = Cont->Root.Prev;
             } else {
-                Y_VERIFY_DEBUG(Item != &Cont->Root);
+                Y_DEBUG_ABORT_UNLESS(Item != &Cont->Root);
                 Item = Item->Prev;
             }
             UpdateValidityToken();
@@ -171,7 +171,7 @@ private:
         }
 
         friend bool operator ==(const TIterator& x, const TIterator& y) {
-            Y_VERIFY_DEBUG(x.Cont == y.Cont);
+            Y_DEBUG_ABORT_UNLESS(x.Cont == y.Cont);
             x.CheckValid();
             y.CheckValid();
             return x.Item == y.Item;
@@ -184,8 +184,8 @@ private:
     private:
         void CheckValid() const {
 #ifndef NDEBUG
-            Y_VERIFY_DEBUG(ValidityToken == (Item ? Item->ValidityToken : 0));
-            Y_VERIFY_DEBUG(Cont && (Item != &Cont->Root || *Cont));
+            Y_DEBUG_ABORT_UNLESS(ValidityToken == (Item ? Item->ValidityToken : 0));
+            Y_DEBUG_ABORT_UNLESS(Cont && (Item != &Cont->Root || *Cont));
 #endif
         }
 
@@ -207,7 +207,7 @@ public:
 
     ~TChunkList() {
         Erase(begin(), end());
-        Y_VERIFY_DEBUG(!*this);
+        Y_DEBUG_ABORT_UNLESS(!*this);
     }
 
     TChunkList(const TChunkList& other) {
@@ -231,7 +231,7 @@ public:
     TChunkList& operator=(TChunkList&& other) {
         if (this != &other) {
             Erase(begin(), end());
-            Y_VERIFY_DEBUG(!*this);
+            Y_DEBUG_ABORT_UNLESS(!*this);
             if (other.Root.IsInUse()) { // do we have something to move?
                 Root.PrepareForUse(std::move(static_cast<TChunk&>(other.Root)));
                 if (other.Root.Next != &other.Root) { // does other contain more than one item?
@@ -290,7 +290,7 @@ public:
     }
 
     void EraseBack() {
-        Y_VERIFY_DEBUG(*this);
+        Y_DEBUG_ABORT_UNLESS(*this);
         if (Root.Prev != &Root) {
             delete Root.Prev;
         } else {
@@ -324,8 +324,8 @@ public:
         if (first != last) {
             --last; // set 'last' pointing to the actual last element of the source range
 
-            Y_VERIFY_DEBUG(first.Item != &from.Root);
-            Y_VERIFY_DEBUG(pos.Item != &Root);
+            Y_DEBUG_ABORT_UNLESS(first.Item != &from.Root);
+            Y_DEBUG_ABORT_UNLESS(pos.Item != &Root);
 
             TItem* const firstItem = first.Item;
             TItem* const lastItem = last.Item;
@@ -347,9 +347,9 @@ public:
 
     operator bool() const { return Root.IsInUse(); }
 
-    TChunk& GetFirstChunk() { Y_VERIFY_DEBUG(*this); return Root; }
-    const TChunk& GetFirstChunk() const { Y_VERIFY_DEBUG(*this); return Root; }
-    TChunk& GetLastChunk() { Y_VERIFY_DEBUG(*this); return *Root.Prev; }
+    TChunk& GetFirstChunk() { Y_DEBUG_ABORT_UNLESS(*this); return Root; }
+    const TChunk& GetFirstChunk() const { Y_DEBUG_ABORT_UNLESS(*this); return Root; }
+    TChunk& GetLastChunk() { Y_DEBUG_ABORT_UNLESS(*this); return *Root.Prev; }
 
     iterator begin() { return *this ? iterator(this, &Root) : end(); }
     const_iterator begin() const { return *this ? const_iterator(this, &Root) : end(); }
@@ -359,14 +359,14 @@ public:
 private:
     TChunk Pop(iterator& pos) {
         pos.CheckValid();
-        Y_VERIFY_DEBUG(pos.Item);
+        Y_DEBUG_ABORT_UNLESS(pos.Item);
 
         if (pos.Item == &Root) {
             TChunk res = PopFront();
             pos = begin();
             return res;
         } else {
-            Y_VERIFY_DEBUG(pos != end());
+            Y_DEBUG_ABORT_UNLESS(pos != end());
             TItem* const item = pos++.Item;
             TChunk res = std::move(static_cast<TChunk&>(*item));
             delete item;
@@ -375,7 +375,7 @@ private:
     }
 
     TChunk PopFront() {
-        Y_VERIFY_DEBUG(*this);
+        Y_DEBUG_ABORT_UNLESS(*this);
         TChunk res = std::move(static_cast<TChunk&>(Root));
         if (Root.Next != &Root) {
             static_cast<TChunk&>(Root) = std::move(static_cast<TChunk&>(*Root.Next));
diff --git a/library/cpp/actors/util/shared_data.cpp b/library/cpp/actors/util/shared_data.cpp
index 209ca7bcbd..51311ce7a3 100644
--- a/library/cpp/actors/util/shared_data.cpp
+++ b/library/cpp/actors/util/shared_data.cpp
@@ -40,7 +40,7 @@ namespace NActors {
             NActors::NMemory::TLabel<MemoryLabelSharedData>::Sub(privateHeader->AllocSize);
 
             auto* header = reinterpret_cast<THeader*>(raw + PrivateHeaderSize);
-            Y_VERIFY_DEBUG(header->Owner == nullptr);
+            Y_DEBUG_ABORT_UNLESS(header->Owner == nullptr);
 
             y_deallocate(raw);
         }
diff --git a/library/cpp/actors/util/shared_data.h b/library/cpp/actors/util/shared_data.h
index 753eb85d07..bd9afb00a5 100644
--- a/library/cpp/actors/util/shared_data.h
+++ b/library/cpp/actors/util/shared_data.h
@@ -86,9 +86,9 @@ namespace NActors {
 
         Y_FORCE_INLINE explicit operator bool() const { return Size_ > 0; }
 
-        Y_FORCE_INLINE char* mutable_data() { Y_VERIFY_DEBUG(IsPrivate()); return Data_; }
-        Y_FORCE_INLINE char* mutable_begin() { Y_VERIFY_DEBUG(IsPrivate()); return Data_; }
-        Y_FORCE_INLINE char* mutable_end() { Y_VERIFY_DEBUG(IsPrivate()); return Data_ + Size_; }
+        Y_FORCE_INLINE char* mutable_data() { Y_DEBUG_ABORT_UNLESS(IsPrivate()); return Data_; }
+        Y_FORCE_INLINE char* mutable_begin() { Y_DEBUG_ABORT_UNLESS(IsPrivate()); return Data_; }
+        Y_FORCE_INLINE char* mutable_end() { Y_DEBUG_ABORT_UNLESS(IsPrivate()); return Data_ + Size_; }
 
         Y_FORCE_INLINE const char* data() const { return Data_; }
         Y_FORCE_INLINE const char* begin() const { return Data_; }
@@ -188,7 +188,7 @@ namespace NActors {
 
     private:
         Y_FORCE_INLINE THeader* Header() const noexcept {
-            Y_VERIFY_DEBUG(Data_);
+            Y_DEBUG_ABORT_UNLESS(Data_);
             return reinterpret_cast<THeader*>(Data_ - sizeof(THeader));
         }
 
diff --git a/library/cpp/actors/util/ticket_lock.h b/library/cpp/actors/util/ticket_lock.h
index 3b1fa80393..30355c3390 100644
--- a/library/cpp/actors/util/ticket_lock.h
+++ b/library/cpp/actors/util/ticket_lock.h
@@ -23,7 +23,7 @@ public:
         ui32 revolves = 0;
         const ui32 ticket = AtomicUi32Increment(&TicketIn) - 1;
         while (ticket != AtomicLoad(&TicketOut)) {
-            Y_VERIFY_DEBUG(ticket >= AtomicLoad(&TicketOut));
+            Y_DEBUG_ABORT_UNLESS(ticket >= AtomicLoad(&TicketOut));
             SpinLockPause();
             ++revolves;
         }
diff --git a/library/cpp/actors/util/unordered_cache.h b/library/cpp/actors/util/unordered_cache.h
index 0ab1a3d220..40794fc04b 100644
--- a/library/cpp/actors/util/unordered_cache.h
+++ b/library/cpp/actors/util/unordered_cache.h
@@ -100,7 +100,7 @@ private:
     }
 
     void WriteOne(TLockedWriter& lock, T x) {
-        Y_VERIFY_DEBUG(x != 0);
+        Y_DEBUG_ABORT_UNLESS(x != 0);
 
         const ui32 pos = AtomicLoad(&lock.Slot->WritePosition);
         if (pos != TChunk::EntriesCount) {
diff --git a/library/cpp/actors/wilson/wilson_span.h b/library/cpp/actors/wilson/wilson_span.h
index bf9b5bcf61..2ebf837cda 100644
--- a/library/cpp/actors/wilson/wilson_span.h
+++ b/library/cpp/actors/wilson/wilson_span.h
@@ -65,7 +65,7 @@ namespace NWilson {
             {}
 
             ~TData() {
-                Y_VERIFY_DEBUG(Sent || Ignored);
+                Y_DEBUG_ABORT_UNLESS(Sent || Ignored);
             }
         };
 
@@ -237,7 +237,7 @@ namespace NWilson {
         }
 
         void VerifyNotSent() {
-            Y_VERIFY_DEBUG(!Data || !Data->Sent, "span has been ended");
+            Y_DEBUG_ABORT_UNLESS(!Data || !Data->Sent, "span has been ended");
         }
     };
 
diff --git a/library/cpp/actors/wilson/wilson_trace.h b/library/cpp/actors/wilson/wilson_trace.h
index 1675250566..41a6505134 100644
--- a/library/cpp/actors/wilson/wilson_trace.h
+++ b/library/cpp/actors/wilson/wilson_trace.h
@@ -116,7 +116,7 @@ namespace NWilson {
             p += sizeof(SpanId);
             memcpy(&Raw, p, sizeof(Raw));
             p += sizeof(Raw);
-            Y_VERIFY_DEBUG(p - in == sizeof(TSerializedTraceId));
+            Y_DEBUG_ABORT_UNLESS(p - in == sizeof(TSerializedTraceId));
         }
 
         TTraceId(const NActorsProto::TTraceId& pb)
@@ -138,7 +138,7 @@ namespace NWilson {
             p += sizeof(SpanId);
             memcpy(p, &Raw, sizeof(Raw));
             p += sizeof(Raw);
-            Y_VERIFY_DEBUG(p - *out == sizeof(TSerializedTraceId));
+            Y_DEBUG_ABORT_UNLESS(p - *out == sizeof(TSerializedTraceId));
         }
 
         void Serialize(NActorsProto::TTraceId *pb) const {
@@ -223,7 +223,7 @@ namespace NWilson {
         static constexpr size_t GetSpanIdSize() { return sizeof(ui64); }
 
         void Validate() const {
-            Y_VERIFY_DEBUG(*this || !SpanId);
+            Y_DEBUG_ABORT_UNLESS(*this || !SpanId);
         }
 
         // for compatibility with NBS
diff --git a/library/cpp/containers/bitseq/bititerator.h b/library/cpp/containers/bitseq/bititerator.h
index 52dadd3798..efe7ba873b 100644
--- a/library/cpp/containers/bitseq/bititerator.h
+++ b/library/cpp/containers/bitseq/bititerator.h
@@ -44,7 +44,7 @@ public:
     TWord Peek(ui8 count) const {
         if (!count)
             return 0;
-        Y_VERIFY_DEBUG(count <= TTraits::NumBits);
+        Y_DEBUG_ABORT_UNLESS(count <= TTraits::NumBits);
 
         if (!Mask)
             return *Data & TTraits::ElemMask(count);
@@ -64,7 +64,7 @@ public:
     TWord Read(ui8 count) {
         if (!count)
             return 0;
-        Y_VERIFY_DEBUG(count <= TTraits::NumBits);
+        Y_DEBUG_ABORT_UNLESS(count <= TTraits::NumBits);
 
         if (!Mask) {
             Current = *Data++;
diff --git a/library/cpp/containers/disjoint_interval_tree/disjoint_interval_tree.h b/library/cpp/containers/disjoint_interval_tree/disjoint_interval_tree.h
index 1f899c9991..3f51c61277 100644
--- a/library/cpp/containers/disjoint_interval_tree/disjoint_interval_tree.h
+++ b/library/cpp/containers/disjoint_interval_tree/disjoint_interval_tree.h
@@ -214,9 +214,9 @@ private:
 
 #ifndef NDEBUG
         TIterator u = Tree.upper_bound(begin);
-        Y_VERIFY_DEBUG(u == Tree.end() || u->first >= end, "Trying to add [%" PRIu64 ", %" PRIu64 ") which intersects with existing [%" PRIu64 ", %" PRIu64 ")", begin, end, u->first, u->second);
-        Y_VERIFY_DEBUG(l == Tree.end() || l == u, "Trying to add [%" PRIu64 ", %" PRIu64 ") which intersects with existing [%" PRIu64 ", %" PRIu64 ")", begin, end, l->first, l->second);
-        Y_VERIFY_DEBUG(p == Tree.end() || p->second <= begin, "Trying to add [%" PRIu64 ", %" PRIu64 ") which intersects with existing [%" PRIu64 ", %" PRIu64 ")", begin, end, p->first, p->second);
+        Y_DEBUG_ABORT_UNLESS(u == Tree.end() || u->first >= end, "Trying to add [%" PRIu64 ", %" PRIu64 ") which intersects with existing [%" PRIu64 ", %" PRIu64 ")", begin, end, u->first, u->second);
+        Y_DEBUG_ABORT_UNLESS(l == Tree.end() || l == u, "Trying to add [%" PRIu64 ", %" PRIu64 ") which intersects with existing [%" PRIu64 ", %" PRIu64 ")", begin, end, l->first, l->second);
+        Y_DEBUG_ABORT_UNLESS(p == Tree.end() || p->second <= begin, "Trying to add [%" PRIu64 ", %" PRIu64 ") which intersects with existing [%" PRIu64 ", %" PRIu64 ")", begin, end, p->first, p->second);
 #endif
 
         // try to extend interval
diff --git a/library/cpp/grpc/server/actors/logger.cpp b/library/cpp/grpc/server/actors/logger.cpp
index d8b2042576..5233c0cb9a 100644
--- a/library/cpp/grpc/server/actors/logger.cpp
+++ b/library/cpp/grpc/server/actors/logger.cpp
@@ -25,7 +25,7 @@ protected:
     }
 
     void DoWrite(ELogPriority p, const char* format, va_list args) noexcept override {
-        Y_VERIFY_DEBUG(DoIsEnabled(p));
+        Y_DEBUG_ABORT_UNLESS(DoIsEnabled(p));
 
         const auto priority = static_cast<::NActors::NLog::EPriority>(p);
         ::NActors::MemLogAdapter(ActorSystem_, priority, Component_, format, args);
diff --git a/library/cpp/monlib/encode/prometheus/prometheus_decoder.cpp b/library/cpp/monlib/encode/prometheus/prometheus_decoder.cpp
index 29441c88c3..d37961a241 100644
--- a/library/cpp/monlib/encode/prometheus/prometheus_decoder.cpp
+++ b/library/cpp/monlib/encode/prometheus/prometheus_decoder.cpp
@@ -426,7 +426,7 @@ namespace NMonitoring {
             }
 
             TStringBuf ReadToken() {
-                Y_VERIFY_DEBUG(CurrentPos_ > 0);
+                Y_DEBUG_ABORT_UNLESS(CurrentPos_ > 0);
                 size_t begin = CurrentPos_ - 1; // read first byte again
                 while (HasRemaining() && !IsSpace(CurrentByte_) && CurrentByte_ != '\n') {
                     ReadNextByteUnsafe();
@@ -439,7 +439,7 @@ namespace NMonitoring {
                     return "";
                 }
 
-                Y_VERIFY_DEBUG(CurrentPos_ > 0);
+                Y_DEBUG_ABORT_UNLESS(CurrentPos_ > 0);
                 size_t begin = CurrentPos_ - 1; // read first byte again
                 while (HasRemaining()) {
                     ReadNextByteUnsafe();
@@ -455,7 +455,7 @@ namespace NMonitoring {
                     return "";
                 }
 
-                Y_VERIFY_DEBUG(CurrentPos_ > 0);
+                Y_DEBUG_ABORT_UNLESS(CurrentPos_ > 0);
                 size_t begin = CurrentPos_ - 1; // read first byte again
                 while (HasRemaining()) {
                     ReadNextByteUnsafe();
@@ -506,7 +506,7 @@ namespace NMonitoring {
             }
 
             TStringBuf TokenFromPos(size_t begin) {
-                Y_VERIFY_DEBUG(CurrentPos_ > begin);
+                Y_DEBUG_ABORT_UNLESS(CurrentPos_ > begin);
                 size_t len = CurrentPos_ - begin - 1;
                 if (len == 0) {
                     return {};
diff --git a/library/cpp/monlib/metrics/atomics_array.h b/library/cpp/monlib/metrics/atomics_array.h
index 4a26c8186a..876c167938 100644
--- a/library/cpp/monlib/metrics/atomics_array.h
+++ b/library/cpp/monlib/metrics/atomics_array.h
@@ -18,7 +18,7 @@ namespace NMonitoring {
         }
 
         ui64 operator[](size_t index) const noexcept {
-            Y_VERIFY_DEBUG(index < Size_);
+            Y_DEBUG_ABORT_UNLESS(index < Size_);
             return Values_[index].load(std::memory_order_relaxed);
         }
 
@@ -27,7 +27,7 @@ namespace NMonitoring {
         }
 
         void Add(size_t index, ui64 count) noexcept {
-            Y_VERIFY_DEBUG(index < Size_);
+            Y_DEBUG_ABORT_UNLESS(index < Size_);
             Values_[index].fetch_add(count, std::memory_order_relaxed);
         }
 
diff --git a/library/cpp/monlib/metrics/histogram_snapshot.h b/library/cpp/monlib/metrics/histogram_snapshot.h
index 05cb174fa8..6cd9f1dab5 100644
--- a/library/cpp/monlib/metrics/histogram_snapshot.h
+++ b/library/cpp/monlib/metrics/histogram_snapshot.h
@@ -187,12 +187,12 @@ namespace NMonitoring {
         }
 
         TBucket& Bucket(ui32 index) noexcept {
-            Y_VERIFY_DEBUG(index < BucketsCount_);
+            Y_DEBUG_ABORT_UNLESS(index < BucketsCount_);
             return *(reinterpret_cast<TBucket*>(this + 1) + index);
         }
 
         const TBucket& Bucket(ui32 index) const noexcept {
-            Y_VERIFY_DEBUG(index < BucketsCount_);
+            Y_DEBUG_ABORT_UNLESS(index < BucketsCount_);
             return *(reinterpret_cast<const TBucket*>(this + 1) + index);
         }
 
diff --git a/library/cpp/monlib/metrics/labels.h b/library/cpp/monlib/metrics/labels.h
index 7e18e88161..1f86e7ffaf 100644
--- a/library/cpp/monlib/metrics/labels.h
+++ b/library/cpp/monlib/metrics/labels.h
@@ -141,12 +141,12 @@ namespace NMonitoring {
             }
 
             const ILabel* operator->() const noexcept {
-                Y_VERIFY_DEBUG(Labels_);
+                Y_DEBUG_ABORT_UNLESS(Labels_);
                 return Labels_->Get(Idx_);
             }
 
             const ILabel& operator*() const noexcept {
-                Y_VERIFY_DEBUG(Labels_);
+                Y_DEBUG_ABORT_UNLESS(Labels_);
                 return *Labels_->Get(Idx_);
             }
 
diff --git a/library/cpp/monlib/metrics/log_histogram_collector.h b/library/cpp/monlib/metrics/log_histogram_collector.h
index b81f84ebf3..30beaa1908 100644
--- a/library/cpp/monlib/metrics/log_histogram_collector.h
+++ b/library/cpp/monlib/metrics/log_histogram_collector.h
@@ -101,7 +101,7 @@ namespace NMonitoring {
         }
 
         int ExtendUp(int expectedIndex) {
-            Y_VERIFY_DEBUG(expectedIndex >= (int) Buckets_.size());
+            Y_DEBUG_ABORT_UNLESS(expectedIndex >= (int) Buckets_.size());
             const size_t toAdd = expectedIndex - Buckets_.size() + 1;
             const size_t newSize = Buckets_.size() + toAdd;
             if (newSize <= MAX_BUCKETS) {
@@ -126,7 +126,7 @@ namespace NMonitoring {
         }
 
         int ExtendDown(int expectedIndex, int margin) {
-            Y_VERIFY_DEBUG(expectedIndex <= 0);
+            Y_DEBUG_ABORT_UNLESS(expectedIndex <= 0);
             int toAdd = std::min<int>(MAX_BUCKETS - Buckets_.size(), margin - expectedIndex);
             if (toAdd > 0) {
                 Buckets_.insert(Buckets_.begin(), toAdd, 0.0);
diff --git a/library/cpp/monlib/metrics/timer.h b/library/cpp/monlib/metrics/timer.h
index 5c4e26e37b..93e5e7eb27 100644
--- a/library/cpp/monlib/metrics/timer.h
+++ b/library/cpp/monlib/metrics/timer.h
@@ -40,7 +40,7 @@ namespace NMonitoring {
         }
 
         void Record() {
-            Y_VERIFY_DEBUG(Metric_);
+            Y_DEBUG_ABORT_UNLESS(Metric_);
             if (Metric_ == nullptr) {
                 return;
             }
diff --git a/library/cpp/netliba/socket/socket.cpp b/library/cpp/netliba/socket/socket.cpp
index ca8a64d25c..0a869302b1 100644
--- a/library/cpp/netliba/socket/socket.cpp
+++ b/library/cpp/netliba/socket/socket.cpp
@@ -266,13 +266,13 @@ namespace NNetlibaSocket {
 
     int TAbstractSocket::SetSockOpt(int level, int option_name, const void* option_value, socklen_t option_len) {
         const int rv = setsockopt(S, level, option_name, (const char*)option_value, option_len);
-        Y_VERIFY_DEBUG(rv == 0, "SetSockOpt failed: %s (errno = %d)", LastSystemErrorText(), LastSystemError());
+        Y_DEBUG_ABORT_UNLESS(rv == 0, "SetSockOpt failed: %s (errno = %d)", LastSystemErrorText(), LastSystemError());
         return rv;
     }
 
     int TAbstractSocket::GetSockOpt(int level, int option_name, void* option_value, socklen_t* option_len) {
         const int rv = getsockopt(S, level, option_name, (char*)option_value, option_len);
-        Y_VERIFY_DEBUG(rv == 0, "GetSockOpt failed: %s (errno = %d)", LastSystemErrorText(), LastSystemError());
+        Y_DEBUG_ABORT_UNLESS(rv == 0, "GetSockOpt failed: %s (errno = %d)", LastSystemErrorText(), LastSystemError());
         return rv;
     }
 
diff --git a/library/cpp/protobuf/json/json2proto.cpp b/library/cpp/protobuf/json/json2proto.cpp
index 067e307146..0a623736cc 100644
--- a/library/cpp/protobuf/json/json2proto.cpp
+++ b/library/cpp/protobuf/json/json2proto.cpp
@@ -74,7 +74,7 @@ static TString GetFieldName(const google::protobuf::FieldDescriptor& field,
             NProtobufJson::ToSnakeCaseDense(&name);
             break;
         default:
-            Y_VERIFY_DEBUG(false, "Unknown FieldNameMode.");
+            Y_DEBUG_ABORT_UNLESS(false, "Unknown FieldNameMode.");
     }
     return name;
 }
diff --git a/library/cpp/protobuf/json/proto2json_printer.cpp b/library/cpp/protobuf/json/proto2json_printer.cpp
index 2b2c9b1713..456d1c43c5 100644
--- a/library/cpp/protobuf/json/proto2json_printer.cpp
+++ b/library/cpp/protobuf/json/proto2json_printer.cpp
@@ -81,7 +81,7 @@ namespace NProtobufJson {
                 }
 
                 default:
-                    Y_VERIFY_DEBUG(false, "Unknown FieldNameMode.");
+                    Y_DEBUG_ABORT_UNLESS(false, "Unknown FieldNameMode.");
             }
         }
 
@@ -187,7 +187,7 @@ namespace NProtobufJson {
             }
 
             default:
-                Y_VERIFY_DEBUG(false, "Unknown EnumMode.");
+                Y_DEBUG_ABORT_UNLESS(false, "Unknown EnumMode.");
         }
     }
 
diff --git a/library/cpp/type_info/type.cpp b/library/cpp/type_info/type.cpp
index b0f3ccd46c..d2c2fc6a5f 100644
--- a/library/cpp/type_info/type.cpp
+++ b/library/cpp/type_info/type.cpp
@@ -229,7 +229,7 @@ namespace NTi {
         }
 
         Y_ABORT_UNLESS(result->GetTypeName() == type->GetTypeName());
-        Y_VERIFY_DEBUG(result->GetHash() == type->GetHash());
+        Y_DEBUG_ABORT_UNLESS(result->GetHash() == type->GetHash());
         return static_cast<const T*>(result);
     }
 
diff --git a/library/cpp/yaml/fyamlcpp/fyamlcpp.cpp b/library/cpp/yaml/fyamlcpp/fyamlcpp.cpp
index 4bfae03994..bea2ea4c7e 100644
--- a/library/cpp/yaml/fyamlcpp/fyamlcpp.cpp
+++ b/library/cpp/yaml/fyamlcpp/fyamlcpp.cpp
@@ -423,7 +423,7 @@ bool TMapping::Has(TString key) const {
 
 TMappingIterator TMapping::Remove(const TMappingIterator& toRemove) {
     ENSURE_NODE_NOT_EMPTY(Node_);
-    Y_VERIFY_DEBUG(Node_ == toRemove.Node_);
+    Y_DEBUG_ABORT_UNLESS(Node_ == toRemove.Node_);
     TMappingIterator ret = toRemove;
     ++ret;
     fy_node_mapping_remove(Node_, toRemove.NodePair_.Pair_);
@@ -549,7 +549,7 @@ TNode TSequence::Remove(const TNodeRef& toRemove) {
 
 TSequenceIterator TSequence::Remove(const TSequenceIterator& toRemove) {
     ENSURE_NODE_NOT_EMPTY(Node_);
-    Y_VERIFY_DEBUG(Node_ == toRemove.Node_);
+    Y_DEBUG_ABORT_UNLESS(Node_ == toRemove.Node_);
     ENSURE_NODE_NOT_EMPTY(toRemove.IterNode_);
     TSequenceIterator ret = toRemove;
     ++ret;
@@ -560,7 +560,7 @@ TSequenceIterator TSequence::Remove(const TSequenceIterator& toRemove) {
 
 TReverseSequenceIterator TSequence::Remove(const TReverseSequenceIterator& toRemove) {
     ENSURE_NODE_NOT_EMPTY(Node_);
-    Y_VERIFY_DEBUG(Node_ == toRemove.Node_);
+    Y_DEBUG_ABORT_UNLESS(Node_ == toRemove.Node_);
     ENSURE_NODE_NOT_EMPTY(toRemove.IterNode_);
     TReverseSequenceIterator ret = toRemove;
     ++ret;
@@ -820,7 +820,7 @@ bool TNodeOpsBase::IsAlias(fy_node* node) const {
 
 fy_node* TNodeOpsBase::ResolveAlias(fy_node* node) const {
     ENSURE_NODE_NOT_EMPTY(node);
-    Y_VERIFY_DEBUG(IsAlias(node));
+    Y_DEBUG_ABORT_UNLESS(IsAlias(node));
     return fy_node_resolve_alias(node);
 }
 
diff --git a/library/cpp/yaml/fyamlcpp/fyamlcpp.h b/library/cpp/yaml/fyamlcpp/fyamlcpp.h
index 4542386846..e205db7122 100644
--- a/library/cpp/yaml/fyamlcpp/fyamlcpp.h
+++ b/library/cpp/yaml/fyamlcpp/fyamlcpp.h
@@ -444,7 +444,7 @@ public:
     explicit TMapping(const TNodeOps<T>& node)
         : TNodeRef(node)
     {
-        Y_VERIFY_DEBUG(Type() == ENodeType::Mapping);
+        Y_DEBUG_ABORT_UNLESS(Type() == ENodeType::Mapping);
     }
 
     TMappingIterator begin() const {
@@ -591,7 +591,7 @@ public:
     explicit TSequence(const TNodeRef& node)
         : TNodeRef(node)
     {
-        Y_VERIFY_DEBUG(Type() == ENodeType::Sequence);
+        Y_DEBUG_ABORT_UNLESS(Type() == ENodeType::Sequence);
     }
 
     TSequenceIterator begin() const {
@@ -692,7 +692,7 @@ public:
 
     template <class... Args>
     size_t Scanf(const char* fmt, Args&& ...args) {
-        Y_VERIFY_DEBUG(Document_);
+        Y_DEBUG_ABORT_UNLESS(Document_);
         return fy_document_scanf(Document_.get(), fmt, std::forward<Args>(args)...);
     }
 
@@ -700,7 +700,7 @@ public:
 
     template <class... Args>
     TNodeRef Buildf(const char* fmt, Args&& ...args) {
-        Y_VERIFY_DEBUG(Document_);
+        Y_DEBUG_ABORT_UNLESS(Document_);
         return fy_node_buildf(Document_.get(), fmt, std::forward<Args>(args)...);
     }