aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp
diff options
context:
space:
mode:
authorilnurkh <ilnurkh@yandex-team.com>2023-10-17 08:15:44 +0300
committerilnurkh <ilnurkh@yandex-team.com>2023-10-17 09:00:07 +0300
commit784925324fd115c37bc98c5bbfe64c15f9966d74 (patch)
treef763f6eaacfcd4757d249977aaddfa4e9b2a355b /library/cpp
parentd6c75d9ec33559b29eb61a8f2e17cbca30fd5ae2 (diff)
downloadydb-784925324fd115c37bc98c5bbfe64c15f9966d74.tar.gz
Y_FAIL->Y_ABORT at '^li'
https://clubs.at.yandex-team.ru/arcadia/29404
Diffstat (limited to 'library/cpp')
-rw-r--r--library/cpp/actors/core/actor_benchmark_helper.h2
-rw-r--r--library/cpp/actors/core/actor_coroutine.cpp8
-rw-r--r--library/cpp/actors/core/actor_virtual.h4
-rw-r--r--library/cpp/actors/core/balancer.cpp2
-rw-r--r--library/cpp/actors/core/config.h2
-rw-r--r--library/cpp/actors/core/cpu_manager.cpp2
-rw-r--r--library/cpp/actors/core/event.h8
-rw-r--r--library/cpp/actors/core/event_local.h4
-rw-r--r--library/cpp/actors/core/event_pb.h8
-rw-r--r--library/cpp/actors/core/executor_pool_base.cpp2
-rw-r--r--library/cpp/actors/core/executor_pool_basic.cpp4
-rw-r--r--library/cpp/actors/core/executor_pool_united.cpp60
-rw-r--r--library/cpp/actors/core/executor_thread.cpp28
-rw-r--r--library/cpp/actors/core/interconnect.cpp2
-rw-r--r--library/cpp/actors/core/invoke.h2
-rw-r--r--library/cpp/actors/core/log.h2
-rw-r--r--library/cpp/actors/core/mailbox.cpp14
-rw-r--r--library/cpp/actors/core/mailbox.h4
-rw-r--r--library/cpp/actors/core/scheduler_cookie.cpp8
-rw-r--r--library/cpp/actors/cppcoro/task.h2
-rw-r--r--library/cpp/actors/cppcoro/task_actor_ut.cpp2
-rw-r--r--library/cpp/actors/cppcoro/task_group.h2
-rw-r--r--library/cpp/actors/cppcoro/task_result.h8
-rw-r--r--library/cpp/actors/dnscachelib/dnscache.cpp2
-rw-r--r--library/cpp/actors/dnsresolver/dnsresolver.cpp6
-rw-r--r--library/cpp/actors/dnsresolver/dnsresolver_caching.cpp22
-rw-r--r--library/cpp/actors/helpers/selfping_actor.cpp2
-rw-r--r--library/cpp/actors/http/http.cpp8
-rw-r--r--library/cpp/actors/http/http_proxy.cpp4
-rw-r--r--library/cpp/actors/interconnect/handshake_broker.h4
-rw-r--r--library/cpp/actors/interconnect/interconnect_channel.cpp2
-rw-r--r--library/cpp/actors/interconnect/interconnect_handshake.cpp6
-rw-r--r--library/cpp/actors/interconnect/interconnect_resolve.cpp2
-rw-r--r--library/cpp/actors/interconnect/interconnect_stream.cpp18
-rw-r--r--library/cpp/actors/interconnect/interconnect_tcp_input_session.cpp2
-rw-r--r--library/cpp/actors/interconnect/interconnect_tcp_proxy.cpp4
-rw-r--r--library/cpp/actors/interconnect/interconnect_tcp_proxy.h4
-rw-r--r--library/cpp/actors/interconnect/interconnect_tcp_session.cpp4
-rw-r--r--library/cpp/actors/interconnect/mock/ic_mock.cpp4
-rw-r--r--library/cpp/actors/interconnect/outgoing_stream.h2
-rw-r--r--library/cpp/actors/interconnect/poller_actor.cpp8
-rw-r--r--library/cpp/actors/interconnect/poller_actor_darwin.h2
-rw-r--r--library/cpp/actors/interconnect/poller_actor_linux.h12
-rw-r--r--library/cpp/actors/interconnect/poller_actor_win.h2
-rw-r--r--library/cpp/actors/interconnect/poller_tcp_unit.cpp2
-rw-r--r--library/cpp/actors/interconnect/poller_tcp_unit_epoll.cpp6
-rw-r--r--library/cpp/actors/interconnect/ut/interconnect_ut.cpp4
-rw-r--r--library/cpp/actors/interconnect/ut/large.cpp2
-rw-r--r--library/cpp/actors/interconnect/ut/poller_actor_ut.cpp8
-rw-r--r--library/cpp/actors/testlib/test_runtime.cpp12
-rw-r--r--library/cpp/actors/util/rc_buf.h6
-rw-r--r--library/cpp/actors/util/rope.h2
-rw-r--r--library/cpp/codecs/greedy_dict/gd_stats.h4
-rw-r--r--library/cpp/containers/concurrent_hash/concurrent_hash.h2
-rw-r--r--library/cpp/containers/stack_vector/stack_vec.h2
-rw-r--r--library/cpp/coroutine/engine/impl.cpp4
-rw-r--r--library/cpp/coroutine/engine/poller.cpp2
-rw-r--r--library/cpp/getopt/small/completer.cpp2
-rw-r--r--library/cpp/grpc/client/grpc_client_low.cpp2
-rw-r--r--library/cpp/http/simple/http_client.h2
-rw-r--r--library/cpp/logger/backend.cpp2
-rw-r--r--library/cpp/logger/global/global.cpp2
-rw-r--r--library/cpp/lwtrace/mon/mon_lwtrace.cpp12
-rw-r--r--library/cpp/lwtrace/signature.h14
-rw-r--r--library/cpp/malloc/nalf/alloc_helpers.h8
-rw-r--r--library/cpp/messagebus/actor/tasks.h2
-rw-r--r--library/cpp/messagebus/config/netaddr.cpp8
-rw-r--r--library/cpp/messagebus/debug_receiver/debug_receiver_proto.cpp2
-rw-r--r--library/cpp/messagebus/event_loop.cpp8
-rw-r--r--library/cpp/messagebus/locator.cpp2
-rw-r--r--library/cpp/messagebus/message.cpp4
-rw-r--r--library/cpp/messagebus/message.h2
-rw-r--r--library/cpp/messagebus/messqueue.cpp4
-rw-r--r--library/cpp/messagebus/oldmodule/module.cpp4
-rw-r--r--library/cpp/messagebus/protobuf/ybusbuf.cpp4
-rw-r--r--library/cpp/messagebus/rain_check/core/task.cpp4
-rw-r--r--library/cpp/messagebus/rain_check/core/task.h4
-rw-r--r--library/cpp/messagebus/rain_check/http/client_ut.cpp2
-rw-r--r--library/cpp/messagebus/remote_client_connection.cpp2
-rw-r--r--library/cpp/messagebus/remote_connection.cpp2
-rw-r--r--library/cpp/messagebus/scheduler_actor_ut.cpp2
-rw-r--r--library/cpp/messagebus/socket_addr.cpp2
-rw-r--r--library/cpp/messagebus/test/example/client/client.cpp2
-rw-r--r--library/cpp/messagebus/test/example/server/server.cpp2
-rw-r--r--library/cpp/messagebus/test/helper/example.cpp4
-rw-r--r--library/cpp/messagebus/test/helper/message_handler_error.cpp10
-rw-r--r--library/cpp/messagebus/test/perftest/perftest.cpp2
-rw-r--r--library/cpp/messagebus/test/ut/messagebus_ut.cpp2
-rw-r--r--library/cpp/messagebus/test/ut/moduletest.h2
-rw-r--r--library/cpp/messagebus/test/ut/one_way_ut.cpp2
-rw-r--r--library/cpp/messagebus/test/ut/starter_ut.cpp2
-rw-r--r--library/cpp/messagebus/www/www.cpp2
-rw-r--r--library/cpp/monlib/dynamic_counters/page.cpp2
-rw-r--r--library/cpp/monlib/encode/format.cpp8
-rw-r--r--library/cpp/monlib/encode/json/json_ut.cpp2
-rw-r--r--library/cpp/monlib/encode/spack/compression.cpp4
-rw-r--r--library/cpp/monlib/encode/spack/spack_v1_decoder.cpp4
-rw-r--r--library/cpp/monlib/metrics/metric_value.h6
-rw-r--r--library/cpp/monlib/service/service.cpp2
-rw-r--r--library/cpp/neh/http2.cpp2
-rw-r--r--library/cpp/neh/netliba.cpp4
-rw-r--r--library/cpp/neh/netliba_udp_http.cpp2
-rw-r--r--library/cpp/presort/presort.h2
-rw-r--r--library/cpp/scheme/scimpl_private.cpp2
-rw-r--r--library/cpp/scheme/tests/fuzz_ops/lib/vm_apply.cpp14
-rw-r--r--library/cpp/scheme/tests/fuzz_ops/lib/vm_parse.cpp6
-rw-r--r--library/cpp/skiff/skiff_schema-inl.h2
-rw-r--r--library/cpp/skiff/skiff_validator.cpp4
-rw-r--r--library/cpp/testing/common/network.cpp8
-rw-r--r--library/cpp/testing/unittest/junit.cpp2
-rw-r--r--library/cpp/threading/light_rw_lock/lightrwlock.h4
-rw-r--r--library/cpp/type_info/type.cpp2
-rw-r--r--library/cpp/type_info/type_complexity.cpp2
-rw-r--r--library/cpp/type_info/type_factory.cpp10
-rw-r--r--library/cpp/unified_agent_client/grpc_io.cpp2
-rw-r--r--library/cpp/yaml/fyamlcpp/fyamlcpp.cpp4
-rw-r--r--library/cpp/yson/detail.h4
-rw-r--r--library/cpp/yson/lexer_detail.h2
-rw-r--r--library/cpp/yson/node/node.cpp2
-rw-r--r--library/cpp/yson/node/node_visitor.cpp2
-rw-r--r--library/cpp/yson/parser_detail.h2
-rw-r--r--library/cpp/yson/token.cpp4
122 files changed, 302 insertions, 302 deletions
diff --git a/library/cpp/actors/core/actor_benchmark_helper.h b/library/cpp/actors/core/actor_benchmark_helper.h
index 0671271f42..c5dd09efe1 100644
--- a/library/cpp/actors/core/actor_benchmark_helper.h
+++ b/library/cpp/actors/core/actor_benchmark_helper.h
@@ -325,7 +325,7 @@ struct TActorBenchmark {
}
return setup;
}
- Y_FAIL();
+ Y_ABORT();
}
static double BenchSendReceive(bool allocation, NActors::TMailboxType::EType mType, EPoolType poolType, ESendingType sendingType) {
diff --git a/library/cpp/actors/core/actor_coroutine.cpp b/library/cpp/actors/core/actor_coroutine.cpp
index 9b0c81fa26..32390eaae3 100644
--- a/library/cpp/actors/core/actor_coroutine.cpp
+++ b/library/cpp/actors/core/actor_coroutine.cpp
@@ -67,7 +67,7 @@ namespace NActors {
return nullptr; // it is not a race -- we've got timeout exactly for our current wait
}
}
- Y_FAIL("no pending event");
+ Y_ABORT("no pending event");
}
bool TActorCoroImpl::ProcessEvent(THolder<IEventHandle> ev) {
@@ -127,12 +127,12 @@ namespace NActors {
Run();
} catch (const TDtorException& /*ex*/) {
if (!AllowUnhandledDtor) {
- Y_FAIL("unhandled TDtorException");
+ Y_ABORT("unhandled TDtorException");
}
} catch (const std::exception& ex) {
- Y_FAIL("unhandled exception of type %s", TypeName(ex).data());
+ Y_ABORT("unhandled exception of type %s", TypeName(ex).data());
} catch (...) {
- Y_FAIL("unhandled exception of type not derived from std::exception");
+ Y_ABORT("unhandled exception of type not derived from std::exception");
}
}
Finished = true;
diff --git a/library/cpp/actors/core/actor_virtual.h b/library/cpp/actors/core/actor_virtual.h
index 5598312952..78da45138d 100644
--- a/library/cpp/actors/core/actor_virtual.h
+++ b/library/cpp/actors/core/actor_virtual.h
@@ -70,7 +70,7 @@ public:
}
virtual bool SerializeToArcadiaStream(TChunkSerializer* /*serializer*/) const override {
- Y_FAIL("Serialization of local event %s->%s", typeid(TEvent).name(), typeid(TActor).name());
+ Y_ABORT("Serialization of local event %s->%s", typeid(TEvent).name(), typeid(TActor).name());
}
virtual bool IsSerializable() const override {
@@ -78,7 +78,7 @@ public:
}
static IEventBase* Load(TEventSerializedData*) {
- Y_FAIL("Loading of local event %s->%s", typeid(TEvent).name(), typeid(TActor).name());
+ Y_ABORT("Loading of local event %s->%s", typeid(TEvent).name(), typeid(TActor).name());
}
};
diff --git a/library/cpp/actors/core/balancer.cpp b/library/cpp/actors/core/balancer.cpp
index e09c834543..5e8a280a8b 100644
--- a/library/cpp/actors/core/balancer.cpp
+++ b/library/cpp/actors/core/balancer.cpp
@@ -294,7 +294,7 @@ namespace NActors {
return;
}
}
- Y_FAIL();
+ Y_ABORT();
}
void TBalancer::Unlock() {
diff --git a/library/cpp/actors/core/config.h b/library/cpp/actors/core/config.h
index 38aaf77797..7c843d0847 100644
--- a/library/cpp/actors/core/config.h
+++ b/library/cpp/actors/core/config.h
@@ -122,7 +122,7 @@ namespace NActors {
return p.PoolName;
}
}
- Y_FAIL("undefined pool id: %" PRIu32, (ui32)poolId);
+ Y_ABORT("undefined pool id: %" PRIu32, (ui32)poolId);
}
std::optional<ui32> GetThreadsOptional(ui32 poolId) const {
diff --git a/library/cpp/actors/core/cpu_manager.cpp b/library/cpp/actors/core/cpu_manager.cpp
index df4ea486e4..24b3161e3c 100644
--- a/library/cpp/actors/core/cpu_manager.cpp
+++ b/library/cpp/actors/core/cpu_manager.cpp
@@ -132,7 +132,7 @@ namespace NActors {
return result;
}
}
- Y_FAIL("missing PoolId: %d", int(poolId));
+ Y_ABORT("missing PoolId: %d", int(poolId));
}
TVector<IExecutorPool*> TCpuManager::GetBasicExecutorPools() const {
diff --git a/library/cpp/actors/core/event.h b/library/cpp/actors/core/event.h
index e7f561338f..3517dc7a68 100644
--- a/library/cpp/actors/core/event.h
+++ b/library/cpp/actors/core/event.h
@@ -75,7 +75,7 @@ namespace NActors {
template <typename TEventType>
TEventType* Get() {
if (Type != TEventType::EventType)
- Y_FAIL("Event type %" PRIu32 " doesn't match the expected type %" PRIu32, Type, TEventType::EventType);
+ Y_ABORT("Event type %" PRIu32 " doesn't match the expected type %" PRIu32, Type, TEventType::EventType);
if (!Event) {
static TEventSerializedData empty;
@@ -86,7 +86,7 @@ namespace NActors {
return static_cast<TEventType*>(Event.Get());
}
- Y_FAIL("Failed to Load() event type %" PRIu32 " class %s", Type, TypeName<TEventType>().data());
+ Y_ABORT("Failed to Load() event type %" PRIu32 " class %s", Type, TypeName<TEventType>().data());
}
template <typename T>
@@ -364,10 +364,10 @@ namespace NActors {
return TString(header); \
} \
bool SerializeToArcadiaStream(NActors::TChunkSerializer*) const override { \
- Y_FAIL("Local event " #eventType " is not serializable"); \
+ Y_ABORT("Local event " #eventType " is not serializable"); \
} \
static IEventBase* Load(NActors::TEventSerializedData*) { \
- Y_FAIL("Local event " #eventType " has no load method"); \
+ Y_ABORT("Local event " #eventType " has no load method"); \
} \
bool IsSerializable() const override { \
return false; \
diff --git a/library/cpp/actors/core/event_local.h b/library/cpp/actors/core/event_local.h
index 2845aa94dd..da0f740ba8 100644
--- a/library/cpp/actors/core/event_local.h
+++ b/library/cpp/actors/core/event_local.h
@@ -14,7 +14,7 @@ namespace NActors {
}
bool SerializeToArcadiaStream(TChunkSerializer* /*serializer*/) const override {
- Y_FAIL("Serialization of local event %s type %" PRIu32, TypeName<TEv>().data(), TEventType);
+ Y_ABORT("Serialization of local event %s type %" PRIu32, TypeName<TEv>().data(), TEventType);
}
bool IsSerializable() const override {
@@ -22,7 +22,7 @@ namespace NActors {
}
static IEventBase* Load(TEventSerializedData*) {
- Y_FAIL("Loading of local event %s type %" PRIu32, TypeName<TEv>().data(), TEventType);
+ Y_ABORT("Loading of local event %s type %" PRIu32, TypeName<TEv>().data(), TEventType);
}
};
diff --git a/library/cpp/actors/core/event_pb.h b/library/cpp/actors/core/event_pb.h
index d3b422f1dc..5fce7c830f 100644
--- a/library/cpp/actors/core/event_pb.h
+++ b/library/cpp/actors/core/event_pb.h
@@ -213,7 +213,7 @@ namespace NActors {
if (const auto& info = input->GetSerializationInfo(); info.IsExtendedFormat) {
// check marker
if (!iter.Valid() || (*iter.ContiguousData() != PayloadMarker && *iter.ContiguousData() != ExtendedPayloadMarker)) {
- Y_FAIL("invalid event");
+ Y_ABORT("invalid event");
}
const bool dataIsSeparate = *iter.ContiguousData() == ExtendedPayloadMarker; // ropes go after sizes
@@ -232,7 +232,7 @@ namespace NActors {
// parse number of payload ropes
size_t numRopes = DeserializeNumber(iter, size);
if (numRopes == Max<size_t>()) {
- Y_FAIL("invalid event");
+ Y_ABORT("invalid event");
}
TStackVec<size_t, 16> ropeLens;
if (dataIsSeparate) {
@@ -242,7 +242,7 @@ namespace NActors {
// parse length of the rope
const size_t len = DeserializeNumber(iter, size);
if (len == Max<size_t>() || size < len) {
- Y_FAIL("invalid event len# %zu size# %" PRIu64, len, size);
+ Y_ABORT("invalid event len# %zu size# %" PRIu64, len, size);
}
// extract the rope
if (dataIsSeparate) {
@@ -259,7 +259,7 @@ namespace NActors {
// parse the protobuf
TRopeStream stream(iter, size);
if (!ev->Record.ParseFromZeroCopyStream(&stream)) {
- Y_FAIL("Failed to parse protobuf event type %" PRIu32 " class %s", TEventType, TypeName(ev->Record).data());
+ Y_ABORT("Failed to parse protobuf event type %" PRIu32 " class %s", TEventType, TypeName(ev->Record).data());
}
}
ev->CachedByteSize = input->GetSize();
diff --git a/library/cpp/actors/core/executor_pool_base.cpp b/library/cpp/actors/core/executor_pool_base.cpp
index d58cd6ce08..059cac48d2 100644
--- a/library/cpp/actors/core/executor_pool_base.cpp
+++ b/library/cpp/actors/core/executor_pool_base.cpp
@@ -206,7 +206,7 @@ namespace NActors {
UnlockFromExecution((TMailboxTable::TTinyReadAsFilledMailbox*)mailbox, this, false, hint, MaxWorkers, ++revolvingWriteCounter);
break;
default:
- Y_FAIL();
+ Y_ABORT();
}
NHPTimer::STime elapsed = GetCycleCountFast() - hpstart;
diff --git a/library/cpp/actors/core/executor_pool_basic.cpp b/library/cpp/actors/core/executor_pool_basic.cpp
index f9ea74a920..bb36fce894 100644
--- a/library/cpp/actors/core/executor_pool_basic.cpp
+++ b/library/cpp/actors/core/executor_pool_basic.cpp
@@ -352,7 +352,7 @@ namespace NActors {
}
break;
default:
- Y_FAIL();
+ Y_ABORT();
}
}
}
@@ -530,7 +530,7 @@ namespace NActors {
pthread_t threadSelf = pthread_self();
sched_param param = {RealtimePriority};
if (pthread_setschedparam(threadSelf, SCHED_FIFO, &param)) {
- Y_FAIL("Cannot set realtime priority");
+ Y_ABORT("Cannot set realtime priority");
}
}
#else
diff --git a/library/cpp/actors/core/executor_pool_united.cpp b/library/cpp/actors/core/executor_pool_united.cpp
index a21fd2d1a7..960545ffb5 100644
--- a/library/cpp/actors/core/executor_pool_united.cpp
+++ b/library/cpp/actors/core/executor_pool_united.cpp
@@ -526,7 +526,7 @@ namespace NActors {
FastWorkerSleep(GetCycleCountFast() + Config.SoftLimitTs);
break;
case Stopped: return false;
- default: Y_FAIL();
+ default: Y_ABORT();
}
}
} else if (wctx.Lease.IsNeverExpiring()) { // if idle-worker
@@ -542,7 +542,7 @@ namespace NActors {
idleTimer->Wait();
break;
case Stopped: return false;
- default: Y_FAIL();
+ default: Y_ABORT();
}
} else { // lease has expired and hard preemption occured, so we are executing in a slow-worker
wctx.IncrementPreemptedEvents();
@@ -556,7 +556,7 @@ namespace NActors {
idleTimer = nullptr;
break;
case Stopped: return false;
- default: Y_FAIL();
+ default: Y_ABORT();
}
}
}
@@ -693,7 +693,7 @@ namespace NActors {
return;
}
} else {
- Y_FAIL("two slow-workers executing the same pool on the same core");
+ Y_ABORT("two slow-workers executing the same pool on the same core");
return; // pool is already slow
}
}
@@ -706,7 +706,7 @@ namespace NActors {
void EndHardPreemption(TWorkerId to) {
ATOMIC_COMPILER_BARRIER();
if (!AtomicCas(&CurrentLease, TLease(to, NeverExpire), HardPreemptionLease)) {
- Y_FAIL("hard preemption failed");
+ Y_ABORT("hard preemption failed");
}
}
@@ -717,7 +717,7 @@ namespace NActors {
void EnablePreemptionAndGrant(TLease lease) {
ATOMIC_COMPILER_BARRIER();
if (!AtomicCas(&CurrentLease, lease, lease.NeverExpire())) {
- Y_FAIL("lease grant failed");
+ Y_ABORT("lease grant failed");
}
}
@@ -789,7 +789,7 @@ namespace NActors {
switch (ret) {
case 0: return;
case EINVAL:
- Y_FAIL("sched_setscheduler(%" PRIu64 ", %d, %d) -> EINVAL", tid, policy, param.sched_priority);
+ Y_ABORT("sched_setscheduler(%" PRIu64 ", %d, %d) -> EINVAL", tid, policy, param.sched_priority);
case EPERM:
// Requirements:
// * CAP_SYS_NICE capability to run real-time processes and set cpu affinity.
@@ -802,11 +802,11 @@ namespace NActors {
// echo -1 > /sys/fs/cgroup/cpu/[cgroup]/cpu.rt_runtime_us
// (also set the same value for every parent cgroup)
// https://www.kernel.org/doc/Documentation/scheduler/sched-rt-group.txt
- Y_FAIL("sched_setscheduler(%" PRIu64 ", %d, %d) -> EPERM", tid, policy, param.sched_priority);
+ Y_ABORT("sched_setscheduler(%" PRIu64 ", %d, %d) -> EPERM", tid, policy, param.sched_priority);
case ESRCH:
- Y_FAIL("sched_setscheduler(%" PRIu64 ", %d, %d) -> ESRCH", tid, policy, param.sched_priority);
+ Y_ABORT("sched_setscheduler(%" PRIu64 ", %d, %d) -> ESRCH", tid, policy, param.sched_priority);
default:
- Y_FAIL("sched_setscheduler(%" PRIu64 ", %d, %d) -> %d", tid, policy, param.sched_priority, ret);
+ Y_ABORT("sched_setscheduler(%" PRIu64 ", %d, %d) -> %d", tid, policy, param.sched_priority, ret);
}
#else
Y_UNUSED(tid);
@@ -865,23 +865,23 @@ namespace NActors {
}
// Should never be called
- void ReclaimMailbox(TMailboxType::EType, ui32, TWorkerId, ui64) override { Y_FAIL(); }
- TMailboxHeader *ResolveMailbox(ui32) override { Y_FAIL(); }
- void Schedule(TInstant, TAutoPtr<IEventHandle>, ISchedulerCookie*, TWorkerId) override { Y_FAIL(); }
- void Schedule(TMonotonic, TAutoPtr<IEventHandle>, ISchedulerCookie*, TWorkerId) override { Y_FAIL(); }
- void Schedule(TDuration, TAutoPtr<IEventHandle>, ISchedulerCookie*, TWorkerId) override { Y_FAIL(); }
- bool Send(TAutoPtr<IEventHandle>&) override { Y_FAIL(); }
- bool SpecificSend(TAutoPtr<IEventHandle>&) override { Y_FAIL(); }
- void ScheduleActivation(ui32) override { Y_FAIL(); }
- void SpecificScheduleActivation(ui32) override { Y_FAIL(); }
- void ScheduleActivationEx(ui32, ui64) override { Y_FAIL(); }
- TActorId Register(IActor*, TMailboxType::EType, ui64, const TActorId&) override { Y_FAIL(); }
- TActorId Register(IActor*, TMailboxHeader*, ui32, const TActorId&) override { Y_FAIL(); }
- void Prepare(TActorSystem*, NSchedulerQueue::TReader**, ui32*) override { Y_FAIL(); }
- void Start() override { Y_FAIL(); }
- void PrepareStop() override { Y_FAIL(); }
- void Shutdown() override { Y_FAIL(); }
- bool Cleanup() override { Y_FAIL(); }
+ void ReclaimMailbox(TMailboxType::EType, ui32, TWorkerId, ui64) override { Y_ABORT(); }
+ TMailboxHeader *ResolveMailbox(ui32) override { Y_ABORT(); }
+ void Schedule(TInstant, TAutoPtr<IEventHandle>, ISchedulerCookie*, TWorkerId) override { Y_ABORT(); }
+ void Schedule(TMonotonic, TAutoPtr<IEventHandle>, ISchedulerCookie*, TWorkerId) override { Y_ABORT(); }
+ void Schedule(TDuration, TAutoPtr<IEventHandle>, ISchedulerCookie*, TWorkerId) override { Y_ABORT(); }
+ bool Send(TAutoPtr<IEventHandle>&) override { Y_ABORT(); }
+ bool SpecificSend(TAutoPtr<IEventHandle>&) override { Y_ABORT(); }
+ void ScheduleActivation(ui32) override { Y_ABORT(); }
+ void SpecificScheduleActivation(ui32) override { Y_ABORT(); }
+ void ScheduleActivationEx(ui32, ui64) override { Y_ABORT(); }
+ TActorId Register(IActor*, TMailboxType::EType, ui64, const TActorId&) override { Y_ABORT(); }
+ TActorId Register(IActor*, TMailboxHeader*, ui32, const TActorId&) override { Y_ABORT(); }
+ void Prepare(TActorSystem*, NSchedulerQueue::TReader**, ui32*) override { Y_ABORT(); }
+ void Start() override { Y_ABORT(); }
+ void PrepareStop() override { Y_ABORT(); }
+ void Shutdown() override { Y_ABORT(); }
+ bool Cleanup() override { Y_ABORT(); }
};
// Proxy executor pool working with cpu-local scheduler (aka actorsystem 2.0)
@@ -1058,7 +1058,7 @@ namespace NActors {
return token;
}
case TCpuState::Forbidden:
- Y_FAIL();
+ Y_ABORT();
case TCpuState::Stopped:
return CpuStopped;
}
@@ -1401,7 +1401,7 @@ namespace NActors {
}
TAffinity* TUnitedExecutorPool::Affinity() const {
- Y_FAIL(); // should never be called, TCpuExecutorPool is used instead
+ Y_ABORT(); // should never be called, TCpuExecutorPool is used instead
}
ui32 TUnitedExecutorPool::GetThreads() const {
@@ -1409,7 +1409,7 @@ namespace NActors {
}
ui32 TUnitedExecutorPool::GetReadyActivation(TWorkerContext&, ui64) {
- Y_FAIL(); // should never be called, TCpu*ExecutorPool is used instead
+ Y_ABORT(); // should never be called, TCpu*ExecutorPool is used instead
}
inline void TUnitedExecutorPool::ScheduleActivation(ui32 activation) {
diff --git a/library/cpp/actors/core/executor_thread.cpp b/library/cpp/actors/core/executor_thread.cpp
index deddb0a97e..eed1794ab1 100644
--- a/library/cpp/actors/core/executor_thread.cpp
+++ b/library/cpp/actors/core/executor_thread.cpp
@@ -539,7 +539,7 @@ namespace NActors {
case TExecutionState::FreeLeavingMarked:
return false;
default:
- Y_FAIL();
+ Y_ABORT();
}
}
}
@@ -572,7 +572,7 @@ namespace NActors {
case TExecutionState::FreeLeavingMarked:
return false;
default:
- Y_FAIL();
+ Y_ABORT();
}
}
}
@@ -587,7 +587,7 @@ namespace NActors {
case TExecutionState::Leaving:
case TExecutionState::Executing:
case TExecutionState::LeavingMarked:
- Y_FAIL();
+ Y_ABORT();
case TExecutionState::Free:
if (AtomicUi32Cas(&ExecutionState, TExecutionState::Executing, TExecutionState::Free))
return true;
@@ -601,7 +601,7 @@ namespace NActors {
case TExecutionState::FreeLeavingMarked:
return false;
default:
- Y_FAIL();
+ Y_ABORT();
}
}
}
@@ -613,7 +613,7 @@ namespace NActors {
else if (state == TExecutionState::FreeExecuting)
AtomicStore(&ExecutionState, (ui32)TExecutionState::FreeLeaving);
else
- Y_FAIL();
+ Y_ABORT();
AtomicBarrier();
}
@@ -624,7 +624,7 @@ namespace NActors {
switch (state) {
case TExecutionState::Inactive:
case TExecutionState::Scheduled:
- Y_FAIL();
+ Y_ABORT();
case TExecutionState::Leaving:
if (!wouldReschedule) {
if (AtomicUi32Cas(&ExecutionState, TExecutionState::Inactive, TExecutionState::Leaving))
@@ -635,14 +635,14 @@ namespace NActors {
}
break;
case TExecutionState::Executing:
- Y_FAIL();
+ Y_ABORT();
case TExecutionState::LeavingMarked:
if (AtomicUi32Cas(&ExecutionState, TExecutionState::Scheduled, TExecutionState::LeavingMarked))
return true;
break;
case TExecutionState::Free:
case TExecutionState::FreeScheduled:
- Y_FAIL();
+ Y_ABORT();
case TExecutionState::FreeLeaving:
if (!wouldReschedule) {
if (AtomicUi32Cas(&ExecutionState, TExecutionState::Free, TExecutionState::FreeLeaving))
@@ -653,13 +653,13 @@ namespace NActors {
}
break;
case TExecutionState::FreeExecuting:
- Y_FAIL();
+ Y_ABORT();
case TExecutionState::FreeLeavingMarked:
if (AtomicUi32Cas(&ExecutionState, TExecutionState::FreeScheduled, TExecutionState::FreeLeavingMarked))
return true;
break;
default:
- Y_FAIL();
+ Y_ABORT();
}
}
}
@@ -671,7 +671,7 @@ namespace NActors {
switch (state) {
case TExecutionState::Inactive:
case TExecutionState::Scheduled:
- Y_FAIL();
+ Y_ABORT();
case TExecutionState::Leaving:
if (!wouldReschedule) {
if (AtomicUi32Cas(&ExecutionState, TExecutionState::Free, TExecutionState::Leaving))
@@ -682,7 +682,7 @@ namespace NActors {
}
break;
case TExecutionState::Executing:
- Y_FAIL();
+ Y_ABORT();
case TExecutionState::LeavingMarked:
if (AtomicUi32Cas(&ExecutionState, TExecutionState::FreeScheduled, TExecutionState::LeavingMarked))
return true;
@@ -692,9 +692,9 @@ namespace NActors {
case TExecutionState::FreeLeaving:
case TExecutionState::FreeExecuting:
case TExecutionState::FreeLeavingMarked:
- Y_FAIL();
+ Y_ABORT();
default:
- Y_FAIL();
+ Y_ABORT();
}
}
}
diff --git a/library/cpp/actors/core/interconnect.cpp b/library/cpp/actors/core/interconnect.cpp
index 8671fb2db7..b477f71e57 100644
--- a/library/cpp/actors/core/interconnect.cpp
+++ b/library/cpp/actors/core/interconnect.cpp
@@ -171,7 +171,7 @@ namespace NActors {
}
default:
- Y_FAIL("unexpected legacy key# %d", key);
+ Y_ABORT("unexpected legacy key# %d", key);
}
}
diff --git a/library/cpp/actors/core/invoke.h b/library/cpp/actors/core/invoke.h
index 6151c32bfa..c9e29effe2 100644
--- a/library/cpp/actors/core/invoke.h
+++ b/library/cpp/actors/core/invoke.h
@@ -54,7 +54,7 @@ namespace NActors {
} else if (auto *value = std::any_cast<T>(&arg)) {
return std::move(*value);
} else {
- Y_FAIL("unspported return type for TEvInvokeResult: actual# %s != expected# %s",
+ Y_ABORT("unspported return type for TEvInvokeResult: actual# %s != expected# %s",
TypeName(arg.type()).data(), TypeName<T>().data());
}
}, Result);
diff --git a/library/cpp/actors/core/log.h b/library/cpp/actors/core/log.h
index 3e171b9b73..44cd3730a4 100644
--- a/library/cpp/actors/core/log.h
+++ b/library/cpp/actors/core/log.h
@@ -524,7 +524,7 @@ namespace NActors {
~TVerifyFormattedRecordWriter() {
const TString data = TBase::GetResult();
- Y_FAIL("%s", data.data());
+ Y_ABORT("%s", data.data());
}
};
}
diff --git a/library/cpp/actors/core/mailbox.cpp b/library/cpp/actors/core/mailbox.cpp
index 37cb900ecf..d11ff9cbcb 100644
--- a/library/cpp/actors/core/mailbox.cpp
+++ b/library/cpp/actors/core/mailbox.cpp
@@ -36,7 +36,7 @@ namespace NActors {
case TMailboxHeader::TExecutionState::FreeLeavingMarked:
return false;
default:
- Y_FAIL();
+ Y_ABORT();
}
}
@@ -84,7 +84,7 @@ namespace NActors {
DestructMailboxLine<TTinyReadAsFilledMailbox>((ui8*)lineHeader + 64, (ui8*)lineHeader + LineSize);
break;
default:
- Y_FAIL();
+ Y_ABORT();
}
lineHeader->~TMailboxLineHeader();
@@ -126,7 +126,7 @@ namespace NActors {
done &= CleanupMailboxLine<TTinyReadAsFilledMailbox>((ui8*)lineHeader + 64, (ui8*)lineHeader + LineSize);
break;
default:
- Y_FAIL();
+ Y_ABORT();
}
}
}
@@ -262,7 +262,7 @@ namespace NActors {
}
return true;
default:
- Y_FAIL("unknown mailbox type");
+ Y_ABORT("unknown mailbox type");
}
}
@@ -319,7 +319,7 @@ namespace NActors {
} while (AtomicGet(CachedTinyReadAsFilledMailboxes) > (MailboxCacheTinyReadAsFilled.Concurrency * 512));
return 0;
default:
- Y_FAIL("Unknown mailbox type");
+ Y_ABORT("Unknown mailbox type");
}
}
@@ -353,7 +353,7 @@ namespace NActors {
AtomicIncrement(CachedTinyReadAsFilledMailboxes);
break;
default:
- Y_FAIL();
+ Y_ABORT();
}
}
}
@@ -557,7 +557,7 @@ namespace NActors {
counter = &CachedTinyReadAsFilledMailboxes;
break;
default:
- Y_FAIL();
+ Y_ABORT();
}
AtomicStore(Lines + lineIndex, header);
diff --git a/library/cpp/actors/core/mailbox.h b/library/cpp/actors/core/mailbox.h
index d7e3ef5384..4697dedcfd 100644
--- a/library/cpp/actors/core/mailbox.h
+++ b/library/cpp/actors/core/mailbox.h
@@ -168,7 +168,7 @@ namespace NActors {
break;
}
default:
- Y_FAIL();
+ Y_ABORT();
}
return nullptr;
}
@@ -211,7 +211,7 @@ namespace NActors {
break;
}
default:
- Y_FAIL();
+ Y_ABORT();
}
}
diff --git a/library/cpp/actors/core/scheduler_cookie.cpp b/library/cpp/actors/core/scheduler_cookie.cpp
index 0fa6f543a7..b975a80c07 100644
--- a/library/cpp/actors/core/scheduler_cookie.cpp
+++ b/library/cpp/actors/core/scheduler_cookie.cpp
@@ -24,11 +24,11 @@ namespace NActors {
return false;
}
- Y_FAIL();
+ Y_ABORT();
}
bool DetachEvent() noexcept override {
- Y_FAIL();
+ Y_ABORT();
}
};
@@ -60,7 +60,7 @@ namespace NActors {
return false;
}
- Y_FAIL();
+ Y_ABORT();
}
bool DetachEvent() noexcept override {
@@ -74,7 +74,7 @@ namespace NActors {
return false;
}
- Y_FAIL();
+ Y_ABORT();
}
};
diff --git a/library/cpp/actors/cppcoro/task.h b/library/cpp/actors/cppcoro/task.h
index 8afeb7e705..bb5a385db2 100644
--- a/library/cpp/actors/cppcoro/task.h
+++ b/library/cpp/actors/cppcoro/task.h
@@ -129,7 +129,7 @@ namespace NActors {
struct TFinalSuspend {
static bool await_ready() noexcept { return false; }
- static void await_resume() noexcept { Y_FAIL("unexpected coroutine resume"); }
+ static void await_resume() noexcept { Y_ABORT("unexpected coroutine resume"); }
static std::coroutine_handle<> await_suspend(std::coroutine_handle<TTaskPromise<T>> h) noexcept {
auto next = std::exchange(h.promise().Continuation, std::noop_coroutine());
diff --git a/library/cpp/actors/cppcoro/task_actor_ut.cpp b/library/cpp/actors/cppcoro/task_actor_ut.cpp
index 79d68b64c2..43186bfc55 100644
--- a/library/cpp/actors/cppcoro/task_actor_ut.cpp
+++ b/library/cpp/actors/cppcoro/task_actor_ut.cpp
@@ -45,7 +45,7 @@ Y_UNIT_TEST_SUITE(TaskActor) {
case TEvStop::EventType:
co_return false;
default:
- Y_FAIL("Unexpected event");
+ Y_ABORT("Unexpected event");
}
};
while (co_await singleRequest()) {
diff --git a/library/cpp/actors/cppcoro/task_group.h b/library/cpp/actors/cppcoro/task_group.h
index 5b82e5f592..1de0cf5c1e 100644
--- a/library/cpp/actors/cppcoro/task_group.h
+++ b/library/cpp/actors/cppcoro/task_group.h
@@ -177,7 +177,7 @@ namespace NActors {
struct TFinalSuspend {
static bool await_ready() noexcept { return false; }
- static void await_resume() noexcept { Y_FAIL("unexpected coroutine resume"); }
+ static void await_resume() noexcept { Y_ABORT("unexpected coroutine resume"); }
Y_NO_INLINE
static std::coroutine_handle<> await_suspend(std::coroutine_handle<TTaskGroupPromise<T>> h) noexcept {
diff --git a/library/cpp/actors/cppcoro/task_result.h b/library/cpp/actors/cppcoro/task_result.h
index 54e66fd57f..da78c53b7a 100644
--- a/library/cpp/actors/cppcoro/task_result.h
+++ b/library/cpp/actors/cppcoro/task_result.h
@@ -67,7 +67,7 @@ namespace NActors {
typename NDetail::TLValue<T>::TType Value() & {
switch (Result.index()) {
case 0: {
- Y_FAIL("Task result has no value");
+ Y_ABORT("Task result has no value");
}
case 1: {
if constexpr (std::same_as<T, void>) {
@@ -82,13 +82,13 @@ namespace NActors {
std::rethrow_exception(e);
}
}
- Y_FAIL("Task result has an invalid state");
+ Y_ABORT("Task result has an invalid state");
}
typename NDetail::TRValue<T>::TType Value() && {
switch (Result.index()) {
case 0: {
- Y_FAIL("Task result has no value");
+ Y_ABORT("Task result has no value");
}
case 1: {
if constexpr (std::same_as<T, void>) {
@@ -103,7 +103,7 @@ namespace NActors {
std::rethrow_exception(std::move(e));
}
}
- Y_FAIL("Task result has an invalid state");
+ Y_ABORT("Task result has an invalid state");
}
private:
diff --git a/library/cpp/actors/dnscachelib/dnscache.cpp b/library/cpp/actors/dnscachelib/dnscache.cpp
index c24888caa5..91ed284c12 100644
--- a/library/cpp/actors/dnscachelib/dnscache.cpp
+++ b/library/cpp/actors/dnscachelib/dnscache.cpp
@@ -387,7 +387,7 @@ void TDnsCache::GHBNCallback(void* arg, int status, int, struct hostent* info) {
p->second.AddrsV6.push_back(*(struct in6_addr*)(info->h_addr_list[i]));
}
} else {
- Y_FAIL("unknown address type in ares callback");
+ Y_ABORT("unknown address type in ares callback");
}
resolved = TTimeKeeper::GetTime();
notfound = 0;
diff --git a/library/cpp/actors/dnsresolver/dnsresolver.cpp b/library/cpp/actors/dnsresolver/dnsresolver.cpp
index bf88d7a41c..d7d8c0e3b6 100644
--- a/library/cpp/actors/dnsresolver/dnsresolver.cpp
+++ b/library/cpp/actors/dnsresolver/dnsresolver.cpp
@@ -91,7 +91,7 @@ namespace NDnsResolver {
if (WSAGetLastError() == WSAEWOULDBLOCK) {
break;
}
- Y_FAIL("Unexpected recv error");
+ Y_ABORT("Unexpected recv error");
#else
if (errno == EAGAIN || errno == EWOULDBLOCK) {
break;
@@ -320,7 +320,7 @@ namespace NDnsResolver {
break;
}
default:
- Y_FAIL("unknown address family in ares callback");
+ Y_ABORT("unknown address family in ares callback");
}
}
} else {
@@ -349,7 +349,7 @@ namespace NDnsResolver {
break;
}
default:
- Y_FAIL("unknown address family in ares callback");
+ Y_ABORT("unknown address family in ares callback");
}
} else {
result->ErrorText = ares_strerror(status);
diff --git a/library/cpp/actors/dnsresolver/dnsresolver_caching.cpp b/library/cpp/actors/dnsresolver/dnsresolver_caching.cpp
index bc3e5c3d7e..83b1847962 100644
--- a/library/cpp/actors/dnsresolver/dnsresolver_caching.cpp
+++ b/library/cpp/actors/dnsresolver/dnsresolver_caching.cpp
@@ -58,7 +58,7 @@ namespace NDnsResolver {
case AF_UNSPEC:
return OutgoingInFlightUnspec;
default:
- Y_FAIL("Unexpected family %d", family);
+ Y_ABORT("Unexpected family %d", family);
}
}
@@ -71,7 +71,7 @@ namespace NDnsResolver {
case AF_UNSPEC:
return OutgoingErrorsUnspec;
default:
- Y_FAIL("Unexpected family %d", family);
+ Y_ABORT("Unexpected family %d", family);
}
}
@@ -84,7 +84,7 @@ namespace NDnsResolver {
case AF_UNSPEC:
return OutgoingTotalUnspec;
default:
- Y_FAIL("Unexpected family %d", family);
+ Y_ABORT("Unexpected family %d", family);
}
}
};
@@ -153,7 +153,7 @@ namespace NDnsResolver {
break;
default:
- Y_FAIL("Unexpected request family %d", waitingInfo.Family);
+ Y_ABORT("Unexpected request family %d", waitingInfo.Family);
}
}
@@ -173,14 +173,14 @@ namespace NDnsResolver {
break;
default:
- Y_FAIL("Unexpected request family %d", waitingInfo.Family);
+ Y_ABORT("Unexpected request family %d", waitingInfo.Family);
}
break;
}
default:
- Y_FAIL("Unexpected TEvUndelievered, type=%" PRIu32, ev->Get()->SourceType);
+ Y_ABORT("Unexpected TEvUndelievered, type=%" PRIu32, ev->Get()->SourceType);
}
}
@@ -329,7 +329,7 @@ namespace NDnsResolver {
case AF_INET:
return StateIPv4;
default:
- Y_FAIL("Unsupported family %d", family);
+ Y_ABORT("Unsupported family %d", family);
}
}
@@ -342,7 +342,7 @@ namespace NDnsResolver {
case AF_INET:
return StateIPv4;
default:
- Y_FAIL("Unsupported family %d", family);
+ Y_ABORT("Unsupported family %d", family);
}
}
};
@@ -456,7 +456,7 @@ namespace NDnsResolver {
PushSoftV4(it, newDeadline);
break;
default:
- Y_FAIL("Unexpected family %d", family);
+ Y_ABORT("Unexpected family %d", family);
}
}
@@ -472,7 +472,7 @@ namespace NDnsResolver {
PushHardV4(it, newDeadline);
break;
default:
- Y_FAIL("Unexpected family %d", family);
+ Y_ABORT("Unexpected family %d", family);
}
}
@@ -638,7 +638,7 @@ namespace NDnsResolver {
} else if (!addrs4.empty()) {
reply->Addr = addrs4.front();
} else {
- Y_FAIL("Unexpected reply with empty address list");
+ Y_ABORT("Unexpected reply with empty address list");
}
Send(req->Sender, reply.Release(), 0, req->Cookie);
break;
diff --git a/library/cpp/actors/helpers/selfping_actor.cpp b/library/cpp/actors/helpers/selfping_actor.cpp
index 0ab1dc57e4..f9f7c297fc 100644
--- a/library/cpp/actors/helpers/selfping_actor.cpp
+++ b/library/cpp/actors/helpers/selfping_actor.cpp
@@ -153,7 +153,7 @@ public:
switch (ev->GetTypeRewrite()) {
HFunc(TEvPing, HandlePing);
default:
- Y_FAIL("TSelfPingActor::RunningState: unexpected event 0x%08" PRIx32, ev->GetTypeRewrite());
+ Y_ABORT("TSelfPingActor::RunningState: unexpected event 0x%08" PRIx32, ev->GetTypeRewrite());
}
}
diff --git a/library/cpp/actors/http/http.cpp b/library/cpp/actors/http/http.cpp
index 22d5409343..9da46e412b 100644
--- a/library/cpp/actors/http/http.cpp
+++ b/library/cpp/actors/http/http.cpp
@@ -14,7 +14,7 @@ inline TStringBuf operator +(TStringBuf l, TStringBuf r) {
if (r.end() == l.begin()) {
return TStringBuf(r.data(), l.size() + r.size());
}
- Y_FAIL("oops");
+ Y_ABORT("oops");
return TStringBuf();
}
@@ -203,7 +203,7 @@ void THttpParser<THttpRequest, TSocketBuffer>::Advance(size_t len) {
break;
}
default:
- Y_FAIL("Invalid processing sequence");
+ Y_ABORT("Invalid processing sequence");
break;
}
}
@@ -590,10 +590,10 @@ THttpOutgoingRequest::THttpOutgoingRequest(TStringBuf method, TStringBuf scheme,
THttpOutgoingRequest::THttpOutgoingRequest(TStringBuf method, TStringBuf url, TStringBuf protocol, TStringBuf version) {
TStringBuf scheme, host, uri;
if (!CrackURL(url, scheme, host, uri)) {
- Y_FAIL("Invalid URL specified");
+ Y_ABORT("Invalid URL specified");
}
if (!scheme.empty() && scheme != "http" && scheme != "https") {
- Y_FAIL("Invalid URL specified");
+ Y_ABORT("Invalid URL specified");
}
Secure = (scheme == "https");
TString urie = UrlEscapeRet(uri);
diff --git a/library/cpp/actors/http/http_proxy.cpp b/library/cpp/actors/http/http_proxy.cpp
index ea7792ef81..74bf497632 100644
--- a/library/cpp/actors/http/http_proxy.cpp
+++ b/library/cpp/actors/http/http_proxy.cpp
@@ -87,13 +87,13 @@ protected:
void Handle(TEvHttpProxy::TEvHttpIncomingResponse::TPtr event, const NActors::TActorContext& ctx) {
Y_UNUSED(event);
Y_UNUSED(ctx);
- Y_FAIL("This event shouldn't be there, it should go to the http connection owner directly");
+ Y_ABORT("This event shouldn't be there, it should go to the http connection owner directly");
}
void Handle(TEvHttpProxy::TEvHttpOutgoingResponse::TPtr event, const NActors::TActorContext& ctx) {
Y_UNUSED(event);
Y_UNUSED(ctx);
- Y_FAIL("This event shouldn't be there, it should go to the http connection directly");
+ Y_ABORT("This event shouldn't be there, it should go to the http connection directly");
}
void Handle(TEvHttpProxy::TEvHttpOutgoingRequest::TPtr event, const NActors::TActorContext& ctx) {
diff --git a/library/cpp/actors/interconnect/handshake_broker.h b/library/cpp/actors/interconnect/handshake_broker.h
index d657e7dd51..c850320bd2 100644
--- a/library/cpp/actors/interconnect/handshake_broker.h
+++ b/library/cpp/actors/interconnect/handshake_broker.h
@@ -73,7 +73,7 @@ namespace NActors {
}
default:
- Y_FAIL("Unimplimented selection strategy");
+ Y_ABORT("Unimplimented selection strategy");
}
const size_t n = WaiterLookup.erase(waiter);
@@ -136,7 +136,7 @@ namespace NActors {
hFunc(TEvHandshakeBrokerFree, Handle);
default:
- Y_FAIL("unexpected event 0x%08" PRIx32, ev->GetTypeRewrite());
+ Y_ABORT("unexpected event 0x%08" PRIx32, ev->GetTypeRewrite());
}
}
diff --git a/library/cpp/actors/interconnect/interconnect_channel.cpp b/library/cpp/actors/interconnect/interconnect_channel.cpp
index 30f384786b..71f4d6e5c3 100644
--- a/library/cpp/actors/interconnect/interconnect_channel.cpp
+++ b/library/cpp/actors/interconnect/interconnect_channel.cpp
@@ -221,7 +221,7 @@ namespace NActors {
}
complete = !Iter.Valid();
} else {
- Y_FAIL();
+ Y_ABORT();
}
Y_ABORT_UNLESS(!complete || event.EventActuallySerialized == event.EventSerializedSize,
"EventActuallySerialized# %" PRIu32 " EventSerializedSize# %" PRIu32 " Type# 0x%08" PRIx32,
diff --git a/library/cpp/actors/interconnect/interconnect_handshake.cpp b/library/cpp/actors/interconnect/interconnect_handshake.cpp
index 7783de1f92..eae80d8c5c 100644
--- a/library/cpp/actors/interconnect/interconnect_handshake.cpp
+++ b/library/cpp/actors/interconnect/interconnect_handshake.cpp
@@ -296,7 +296,7 @@ namespace NActors {
} catch (const TExPoison&) {
// just stop execution, do nothing
} catch (...) {
- Y_FAIL("unhandled exception");
+ Y_ABORT("unhandled exception");
}
if (SubscribedForConnection) {
SendToProxy(MakeHolder<TEvSubscribeForConnection>(*HandshakeId, false));
@@ -439,7 +439,7 @@ namespace NActors {
throw TExPoison();
default:
- Y_FAIL("unexpected event 0x%08" PRIx32, type);
+ Y_ABORT("unexpected event 0x%08" PRIx32, type);
}
}
@@ -1097,7 +1097,7 @@ namespace NActors {
SendExBlock(MainChannel, ev->Record, "ExReply");
ProgramInfo.Clear(); // do not issue reply to the proxy
} else {
- Y_FAIL("unexpected event Type# 0x%08" PRIx32, reply->GetTypeRewrite());
+ Y_ABORT("unexpected event Type# 0x%08" PRIx32, reply->GetTypeRewrite());
}
}
}
diff --git a/library/cpp/actors/interconnect/interconnect_resolve.cpp b/library/cpp/actors/interconnect/interconnect_resolve.cpp
index 921f08fba6..071af2f7c4 100644
--- a/library/cpp/actors/interconnect/interconnect_resolve.cpp
+++ b/library/cpp/actors/interconnect/interconnect_resolve.cpp
@@ -157,7 +157,7 @@ namespace NActors {
return MakeHolder<NAddr::TIPv4Addr>(TIpAddress(msg->GetAddrV4().s_addr, Port));
}
- Y_FAIL("Unexpected result address family");
+ Y_ABORT("Unexpected result address family");
}
return nullptr;
diff --git a/library/cpp/actors/interconnect/interconnect_stream.cpp b/library/cpp/actors/interconnect/interconnect_stream.cpp
index 51a23923af..ab3b74fa57 100644
--- a/library/cpp/actors/interconnect/interconnect_stream.cpp
+++ b/library/cpp/actors/interconnect/interconnect_stream.cpp
@@ -50,13 +50,13 @@ namespace NInterconnect {
return;
switch (LastSocketError()) {
case EBADF:
- Y_FAIL("Close bad descriptor");
+ Y_ABORT("Close bad descriptor");
case EINTR:
break;
case EIO:
- Y_FAIL("EIO");
+ Y_ABORT("EIO");
default:
- Y_FAIL("It's something unexpected");
+ Y_ABORT("It's something unexpected");
}
}
@@ -136,7 +136,7 @@ namespace NInterconnect {
return -LastSocketError();
return ret;
#else
- Y_FAIL("WriteV() unsupported on Windows");
+ Y_ABORT("WriteV() unsupported on Windows");
#endif
}
@@ -148,7 +148,7 @@ namespace NInterconnect {
return -LastSocketError();
return ret;
#else
- Y_FAIL("ReadV() unsupported on Windows");
+ Y_ABORT("ReadV() unsupported on Windows");
#endif
}
@@ -481,7 +481,7 @@ namespace NInterconnect {
}
}
}
- Y_FAIL();
+ Y_ABORT();
}
std::optional<std::pair<const void*, size_t>> BlockedSend;
@@ -585,7 +585,7 @@ namespace NInterconnect {
return -EPROTO;
default:
- Y_FAIL("unexpected SSL_get_error() status# %d", status);
+ Y_ABORT("unexpected SSL_get_error() status# %d", status);
}
}
};
@@ -616,11 +616,11 @@ namespace NInterconnect {
}
ssize_t TSecureSocket::WriteV(const struct iovec* /*iov*/, int /*iovcnt*/) const {
- Y_FAIL("unsupported on SSL sockets");
+ Y_ABORT("unsupported on SSL sockets");
}
ssize_t TSecureSocket::ReadV(const struct iovec* /*iov*/, int /*iovcnt*/) const {
- Y_FAIL("unsupported on SSL sockets");
+ Y_ABORT("unsupported on SSL sockets");
}
TString TSecureSocket::GetCipherName() const {
diff --git a/library/cpp/actors/interconnect/interconnect_tcp_input_session.cpp b/library/cpp/actors/interconnect/interconnect_tcp_input_session.cpp
index 5e29f49590..3f5ebd2987 100644
--- a/library/cpp/actors/interconnect/interconnect_tcp_input_session.cpp
+++ b/library/cpp/actors/interconnect/interconnect_tcp_input_session.cpp
@@ -307,7 +307,7 @@ namespace NActors {
break;
default:
- Y_FAIL("unexpected state");
+ Y_ABORT("unexpected state");
}
break;
}
diff --git a/library/cpp/actors/interconnect/interconnect_tcp_proxy.cpp b/library/cpp/actors/interconnect/interconnect_tcp_proxy.cpp
index c1994b2d71..514bfb0b84 100644
--- a/library/cpp/actors/interconnect/interconnect_tcp_proxy.cpp
+++ b/library/cpp/actors/interconnect/interconnect_tcp_proxy.cpp
@@ -525,7 +525,7 @@ namespace NActors {
break;
default:
- Y_FAIL("Unexpected type of event in held event queue");
+ Y_ABORT("Unexpected type of event in held event queue");
}
}
@@ -736,7 +736,7 @@ namespace NActors {
switch (auto& ev = h; ev->GetTypeRewrite()) {
hFunc(NMon::TEvHttpInfoRes, Session->GenerateHttpInfo);
default:
- Y_FAIL();
+ Y_ABORT();
}
} else {
TActivationContext::Send(h.Release());
diff --git a/library/cpp/actors/interconnect/interconnect_tcp_proxy.h b/library/cpp/actors/interconnect/interconnect_tcp_proxy.h
index 4622bf3f88..81f043a2e9 100644
--- a/library/cpp/actors/interconnect/interconnect_tcp_proxy.h
+++ b/library/cpp/actors/interconnect/interconnect_tcp_proxy.h
@@ -129,7 +129,7 @@ namespace NActors {
hFunc(TEvSubscribeForConnection, Handle); \
hFunc(TEvReportConnection, Handle); \
default: \
- Y_FAIL("unexpected event Type# 0x%08" PRIx32, type); \
+ Y_ABORT("unexpected event Type# 0x%08" PRIx32, type); \
} \
} \
if (profiled) { \
@@ -316,7 +316,7 @@ namespace NActors {
hFunc(TEvHandshakeAsk, IncomingHandshake);
hFunc(TEvHandshakeRequest, IncomingHandshake);
default:
- Y_FAIL();
+ Y_ABORT();
}
}
void IncomingHandshake(TEvHandshakeAsk::TPtr& ev);
diff --git a/library/cpp/actors/interconnect/interconnect_tcp_session.cpp b/library/cpp/actors/interconnect/interconnect_tcp_session.cpp
index 59738b2052..a7509fbc94 100644
--- a/library/cpp/actors/interconnect/interconnect_tcp_session.cpp
+++ b/library/cpp/actors/interconnect/interconnect_tcp_session.cpp
@@ -112,7 +112,7 @@ namespace NActors {
}
void TInterconnectSessionTCP::PassAway() {
- Y_FAIL("TInterconnectSessionTCP::PassAway() can't be called directly");
+ Y_ABORT("TInterconnectSessionTCP::PassAway() can't be called directly");
}
void TInterconnectSessionTCP::Forward(STATEFN_SIG) {
@@ -326,7 +326,7 @@ namespace NActors {
switch (EUpdateState state = ReceiveContext->UpdateState) {
case EUpdateState::NONE:
case EUpdateState::CONFIRMING:
- Y_FAIL("unexpected state");
+ Y_ABORT("unexpected state");
case EUpdateState::INFLIGHT:
// this message we are processing was the only one in flight, so we can reset state to NONE here
diff --git a/library/cpp/actors/interconnect/mock/ic_mock.cpp b/library/cpp/actors/interconnect/mock/ic_mock.cpp
index 9178e52da8..81e181b673 100644
--- a/library/cpp/actors/interconnect/mock/ic_mock.cpp
+++ b/library/cpp/actors/interconnect/mock/ic_mock.cpp
@@ -89,7 +89,7 @@ namespace NActors {
} else if (nodeId == ui32(Key >> 32)) {
return PeerInfo + 1;
} else {
- Y_FAIL();
+ Y_ABORT();
}
}
};
@@ -236,7 +236,7 @@ namespace NActors {
break;
default:
- Y_FAIL();
+ Y_ABORT();
}
}
}
diff --git a/library/cpp/actors/interconnect/outgoing_stream.h b/library/cpp/actors/interconnect/outgoing_stream.h
index 47803764d7..980bd401f0 100644
--- a/library/cpp/actors/interconnect/outgoing_stream.h
+++ b/library/cpp/actors/interconnect/outgoing_stream.h
@@ -100,7 +100,7 @@ namespace NInterconnect {
const char *bufferBegin = buffer->Data;
const char *bufferEnd = bufferBegin + BufferSize;
if (bufferBegin < end && begin < bufferEnd) {
- Y_FAIL();
+ Y_ABORT();
}
}
#endif
diff --git a/library/cpp/actors/interconnect/poller_actor.cpp b/library/cpp/actors/interconnect/poller_actor.cpp
index e3ddbe8b98..1f18e72a5b 100644
--- a/library/cpp/actors/interconnect/poller_actor.cpp
+++ b/library/cpp/actors/interconnect/poller_actor.cpp
@@ -89,7 +89,7 @@ namespace NActors {
try {
TPipeHandle::Pipe(ReadEnd, WriteEnd, CloseOnExec);
} catch (const TFileError& err) {
- Y_FAIL("failed to create pipe");
+ Y_ABORT("failed to create pipe");
}
// switch the read/write ends to nonblocking mode
@@ -134,7 +134,7 @@ namespace NActors {
if (err == EINTR) {
continue;
} else {
- Y_FAIL("WriteEnd.Write() failed with %s", strerror(err));
+ Y_ABORT("WriteEnd.Write() failed with %s", strerror(err));
}
} else {
Y_ABORT_UNLESS(nwritten);
@@ -157,7 +157,7 @@ namespace NActors {
} else if (error == EAGAIN || error == EWOULDBLOCK) {
break;
} else {
- Y_FAIL("read() failed with %s", strerror(errno));
+ Y_ABORT("read() failed with %s", strerror(errno));
}
} else {
Y_ABORT_UNLESS(n);
@@ -178,7 +178,7 @@ namespace NActors {
} else if (std::get_if<TPollerWakeup>(&op->Operation)) {
op->SignalDone();
} else {
- Y_FAIL();
+ Y_ABORT();
}
} while (SyncOperationsQ.Pop());
return true;
diff --git a/library/cpp/actors/interconnect/poller_actor_darwin.h b/library/cpp/actors/interconnect/poller_actor_darwin.h
index f091972502..a1f750e711 100644
--- a/library/cpp/actors/interconnect/poller_actor_darwin.h
+++ b/library/cpp/actors/interconnect/poller_actor_darwin.h
@@ -53,7 +53,7 @@ namespace NActors {
if (errno == EINTR) {
return false;
} else {
- Y_FAIL("kevent() failed with %s", strerror(errno));
+ Y_ABORT("kevent() failed with %s", strerror(errno));
}
}
diff --git a/library/cpp/actors/interconnect/poller_actor_linux.h b/library/cpp/actors/interconnect/poller_actor_linux.h
index f19f53f730..8831d2062b 100644
--- a/library/cpp/actors/interconnect/poller_actor_linux.h
+++ b/library/cpp/actors/interconnect/poller_actor_linux.h
@@ -19,7 +19,7 @@ namespace NActors {
event.data.ptr = nullptr;
event.events = EPOLLIN;
if (epoll_ctl(EpollDescriptor, EPOLL_CTL_ADD, ReadEnd, &event) == -1) {
- Y_FAIL("epoll_ctl(EPOLL_CTL_ADD) failed with %s", strerror(errno));
+ Y_ABORT("epoll_ctl(EPOLL_CTL_ADD) failed with %s", strerror(errno));
}
ISimpleThread::Start(); // start poller thread
@@ -44,7 +44,7 @@ namespace NActors {
if (errno == EINTR) {
return false; // restart the call a bit later
} else {
- Y_FAIL("epoll_wait() failed with %s", strerror(errno));
+ Y_ABORT("epoll_wait() failed with %s", strerror(errno));
}
}
@@ -69,7 +69,7 @@ namespace NActors {
event.events = EPOLLONESHOT | EPOLLRDHUP | flags;
event.data.ptr = record;
if (epoll_ctl(EpollDescriptor, EPOLL_CTL_MOD, record->Socket->GetDescriptor(), &event) == -1) {
- Y_FAIL("epoll_ctl(EPOLL_CTL_MOD) failed with %s", strerror(errno));
+ Y_ABORT("epoll_ctl(EPOLL_CTL_MOD) failed with %s", strerror(errno));
}
}
@@ -85,7 +85,7 @@ namespace NActors {
void UnregisterSocketInLoop(const TIntrusivePtr<TSharedDescriptor>& socket) {
if (epoll_ctl(EpollDescriptor, EPOLL_CTL_DEL, socket->GetDescriptor(), nullptr) == -1) {
- Y_FAIL("epoll_ctl(EPOLL_CTL_DEL) failed with %s", strerror(errno));
+ Y_ABORT("epoll_ctl(EPOLL_CTL_DEL) failed with %s", strerror(errno));
}
}
@@ -94,7 +94,7 @@ namespace NActors {
event.events = EPOLLONESHOT | EPOLLRDHUP;
event.data.ptr = record.Get();
if (epoll_ctl(EpollDescriptor, EPOLL_CTL_ADD, record->Socket->GetDescriptor(), &event) == -1) {
- Y_FAIL("epoll_ctl(EPOLL_CTL_ADD) failed with %s", strerror(errno));
+ Y_ABORT("epoll_ctl(EPOLL_CTL_ADD) failed with %s", strerror(errno));
}
}
@@ -109,7 +109,7 @@ namespace NActors {
event.events = EPOLLONESHOT | EPOLLRDHUP | flags;
event.data.ptr = record.Get();
if (epoll_ctl(EpollDescriptor, EPOLL_CTL_MOD, record->Socket->GetDescriptor(), &event) == -1) {
- Y_FAIL("epoll_ctl(EPOLL_CTL_MOD) failed with %s", strerror(errno));
+ Y_ABORT("epoll_ctl(EPOLL_CTL_MOD) failed with %s", strerror(errno));
}
}
}
diff --git a/library/cpp/actors/interconnect/poller_actor_win.h b/library/cpp/actors/interconnect/poller_actor_win.h
index 9666c32be7..f59d3ddda7 100644
--- a/library/cpp/actors/interconnect/poller_actor_win.h
+++ b/library/cpp/actors/interconnect/poller_actor_win.h
@@ -53,7 +53,7 @@ namespace NActors {
if (err == EINTR) {
return false; // try a bit later
} else {
- Y_FAIL("select() failed with %s", strerror(err));
+ Y_ABORT("select() failed with %s", strerror(err));
}
}
diff --git a/library/cpp/actors/interconnect/poller_tcp_unit.cpp b/library/cpp/actors/interconnect/poller_tcp_unit.cpp
index 853fce04b4..994d907004 100644
--- a/library/cpp/actors/interconnect/poller_tcp_unit.cpp
+++ b/library/cpp/actors/interconnect/poller_tcp_unit.cpp
@@ -120,7 +120,7 @@ namespace NInterconnect {
do {
auto sock = InputQueue.Top().first->GetDescriptor();
if (!Operations.emplace(sock, std::move(InputQueue.Top())).second)
- Y_FAIL("Descriptor is already in pooler.");
+ Y_ABORT("Descriptor is already in pooler.");
} while (InputQueue.Pop());
}
}
diff --git a/library/cpp/actors/interconnect/poller_tcp_unit_epoll.cpp b/library/cpp/actors/interconnect/poller_tcp_unit_epoll.cpp
index 33666a2747..aac6d52bb4 100644
--- a/library/cpp/actors/interconnect/poller_tcp_unit_epoll.cpp
+++ b/library/cpp/actors/interconnect/poller_tcp_unit_epoll.cpp
@@ -13,7 +13,7 @@ namespace NInterconnect {
::epoll_event event = {0, {.fd = stream}};
if (::epoll_ctl(epoll, EPOLL_CTL_DEL, stream, &event)) {
Cerr << "epoll_ctl errno: " << errno << Endl;
- Y_FAIL("epoll delete error!");
+ Y_ABORT("epoll delete error!");
}
}
@@ -24,7 +24,7 @@ namespace NInterconnect {
event.data.fd = stream;
if (::epoll_ctl(epoll, EPOLL_CTL_ADD, stream, &event)) {
Cerr << "epoll_ctl errno: " << errno << Endl;
- Y_FAIL("epoll add error!");
+ Y_ABORT("epoll add error!");
}
}
@@ -92,7 +92,7 @@ namespace NInterconnect {
::epoll_pwait(epoll, events, EVENTS_BUF_SIZE, 200, &sigmask);
if (result == -1 && errno != EINTR)
- Y_FAIL("epoll wait error!");
+ Y_ABORT("epoll wait error!");
auto& side = GetSide<WriteOp>();
side.ProcessInput();
diff --git a/library/cpp/actors/interconnect/ut/interconnect_ut.cpp b/library/cpp/actors/interconnect/ut/interconnect_ut.cpp
index 8d1b47c0c6..bc9e86545a 100644
--- a/library/cpp/actors/interconnect/ut/interconnect_ut.cpp
+++ b/library/cpp/actors/interconnect/ut/interconnect_ut.cpp
@@ -64,7 +64,7 @@ public:
Y_ABORT_UNLESS(it->second == ev->GetChainBuffer()->GetString());
Tentative.erase(it);
} else {
- Y_FAIL("Cookie# %" PRIu64, ev->Cookie);
+ Y_ABORT("Cookie# %" PRIu64, ev->Cookie);
}
IssueQueries();
}
@@ -167,7 +167,7 @@ Y_UNIT_TEST_SUITE(Interconnect) {
break;
default:
- Y_FAIL();
+ Y_ABORT();
}
Sleep(TDuration::MilliSeconds(RandomNumber<ui32>(500) + 100));
diff --git a/library/cpp/actors/interconnect/ut/large.cpp b/library/cpp/actors/interconnect/ut/large.cpp
index 725238242a..88207f816b 100644
--- a/library/cpp/actors/interconnect/ut/large.cpp
+++ b/library/cpp/actors/interconnect/ut/large.cpp
@@ -63,7 +63,7 @@ Y_UNIT_TEST_SUITE(LargeMessage) {
Y_ABORT_UNLESS(SessionId != ev->InterconnectSession);
Done.Signal();
} else {
- Y_FAIL("incorrect sequence number");
+ Y_ABORT("incorrect sequence number");
}
}
diff --git a/library/cpp/actors/interconnect/ut/poller_actor_ut.cpp b/library/cpp/actors/interconnect/ut/poller_actor_ut.cpp
index 67921ef9bc..38b9b5a0b6 100644
--- a/library/cpp/actors/interconnect/ut/poller_actor_ut.cpp
+++ b/library/cpp/actors/interconnect/ut/poller_actor_ut.cpp
@@ -44,15 +44,15 @@ std::pair<TTestSocketPtr, TTestSocketPtr> TcpSockets() {
addr.sin_port = 0;
addr.sin_addr.s_addr = htonl(INADDR_LOOPBACK);
if (bind(server, (sockaddr*)&addr, sizeof(addr)) == -1) {
- Y_FAIL("bind() failed with %s", strerror(errno));
+ Y_ABORT("bind() failed with %s", strerror(errno));
} else if (listen(server, 1) == -1) {
- Y_FAIL("listen() failed with %s", strerror(errno));
+ Y_ABORT("listen() failed with %s", strerror(errno));
}
// obtain local address for client
socklen_t len = sizeof(addr);
if (getsockname(server, (sockaddr*)&addr, &len) == -1) {
- Y_FAIL("getsockname() failed with %s", strerror(errno));
+ Y_ABORT("getsockname() failed with %s", strerror(errno));
}
// create client socket
@@ -61,7 +61,7 @@ std::pair<TTestSocketPtr, TTestSocketPtr> TcpSockets() {
// connect to server
if (connect(client, (sockaddr*)&addr, len) == -1) {
- Y_FAIL("connect() failed with %s", strerror(errno));
+ Y_ABORT("connect() failed with %s", strerror(errno));
}
// accept connection from the other side
diff --git a/library/cpp/actors/testlib/test_runtime.cpp b/library/cpp/actors/testlib/test_runtime.cpp
index 256116ce32..20b26c33d3 100644
--- a/library/cpp/actors/testlib/test_runtime.cpp
+++ b/library/cpp/actors/testlib/test_runtime.cpp
@@ -298,7 +298,7 @@ namespace NActors {
ui32 GetReadyActivation(TWorkerContext& wctx, ui64 revolvingCounter) override {
Y_UNUSED(wctx);
Y_UNUSED(revolvingCounter);
- Y_FAIL();
+ Y_ABORT();
}
void ReclaimMailbox(TMailboxType::EType mailboxType, ui32 hint, TWorkerId workerId, ui64 revolvingCounter) override {
@@ -458,7 +458,7 @@ namespace NActors {
// generic
TAffinity* Affinity() const override {
- Y_FAIL();
+ Y_ABORT();
}
private:
@@ -812,7 +812,7 @@ namespace NActors {
TString explanation;
auto status = node->LogSettings->SetLevel(priority, component, explanation);
if (status) {
- Y_FAIL("SetLogPriority failed: %s", explanation.c_str());
+ Y_ABORT("SetLogPriority failed: %s", explanation.c_str());
}
}
}
@@ -956,7 +956,7 @@ namespace NActors {
UnlockFromExecution((TMailboxTable::TTinyReadAsFilledMailbox *)mailbox, node->ExecutorPools[0], false, hint, MaxWorkers, ++revolvingCounter);
break;
default:
- Y_FAIL("Unsupported mailbox type");
+ Y_ABORT("Unsupported mailbox type");
}
return actorId;
@@ -1250,7 +1250,7 @@ namespace NActors {
break;
}
default:
- Y_FAIL("Unknown action");
+ Y_ABORT("Unknown action");
}
}
}
@@ -1753,7 +1753,7 @@ namespace NActors {
for (auto& x : Nodes) {
return x.second->ActorSystem.Get();
}
- Y_FAIL("Don't use this method.");
+ Y_ABORT("Don't use this method.");
}
TActorSystem* TTestActorRuntimeBase::GetActorSystem(ui32 nodeId) {
diff --git a/library/cpp/actors/util/rc_buf.h b/library/cpp/actors/util/rc_buf.h
index b5b15fa4cc..db0f7deff5 100644
--- a/library/cpp/actors/util/rc_buf.h
+++ b/library/cpp/actors/util/rc_buf.h
@@ -679,7 +679,7 @@ class TRcBuf {
case EType::INTERNAL_BACKEND: return wrapper(reinterpret_cast<std::conditional_t<IsConst, const TInternalBackend&, TInternalBackend&>>(value));
case EType::EXTERNAL_BACKEND: return wrapper(reinterpret_cast<std::conditional_t<IsConst, const IContiguousChunk::TPtr&, IContiguousChunk::TPtr&>>(value));
}
- Y_FAIL("Unexpected type# %" PRIu64, static_cast<ui64>(type));
+ Y_ABORT("Unexpected type# %" PRIu64, static_cast<ui64>(type));
}
template<typename TOwner, typename TCallback, bool IsConst = std::is_const_v<TOwner>>
@@ -1039,7 +1039,7 @@ public:
return EResizeResult::NoAlloc;
} else {
if (strategy == EResizeStrategy::FailOnCopy && static_cast<bool>(Backend)) {
- Y_FAIL("Fail on grow");
+ Y_ABORT("Fail on grow");
}
auto newData = TRcBuf::Uninitialized(size + GetSize(), UnsafeHeadroom() > size ? UnsafeHeadroom() - size : 0, UnsafeTailroom());
if (auto data = GetData(); data) {
@@ -1056,7 +1056,7 @@ public:
return EResizeResult::NoAlloc;
} else {
if (strategy == EResizeStrategy::FailOnCopy && static_cast<bool>(Backend)) {
- Y_FAIL("Fail on grow");
+ Y_ABORT("Fail on grow");
}
auto newData = TRcBuf::Uninitialized(size + GetSize(), UnsafeHeadroom(), UnsafeTailroom() > size ? UnsafeTailroom() - size : 0);
if (auto data = GetData(); data) {
diff --git a/library/cpp/actors/util/rope.h b/library/cpp/actors/util/rope.h
index 4487fdc87d..b092d502cd 100644
--- a/library/cpp/actors/util/rope.h
+++ b/library/cpp/actors/util/rope.h
@@ -39,7 +39,7 @@ public:
}
void *operator new(size_t) {
- Y_FAIL();
+ Y_ABORT();
}
void *operator new(size_t, void *ptr) {
diff --git a/library/cpp/codecs/greedy_dict/gd_stats.h b/library/cpp/codecs/greedy_dict/gd_stats.h
index b63c4c38d2..e0e814c7ad 100644
--- a/library/cpp/codecs/greedy_dict/gd_stats.h
+++ b/library/cpp/codecs/greedy_dict/gd_stats.h
@@ -49,7 +49,7 @@ namespace NGreedyDict {
case EST_SIMPLE_NORM:
return SimpleTestNorm(modelp, countAB, total);
}
- Y_FAIL("no way!");
+ Y_ABORT("no way!");
return 0;
}
@@ -72,7 +72,7 @@ namespace NGreedyDict {
case ES_SOLAR:
return SolarTest(modelp, count, total);
}
- Y_FAIL("no way!");
+ Y_ABORT("no way!");
return 0;
}
diff --git a/library/cpp/containers/concurrent_hash/concurrent_hash.h b/library/cpp/containers/concurrent_hash/concurrent_hash.h
index 2c0f68cd8c..88da30fd78 100644
--- a/library/cpp/containers/concurrent_hash/concurrent_hash.h
+++ b/library/cpp/containers/concurrent_hash/concurrent_hash.h
@@ -96,7 +96,7 @@ public:
TBucket& bucket = GetBucketForKey(key);
TGuard<TLock> guard(bucket.Mutex);
if (!bucket.Map.insert(std::make_pair(key, value)).second) {
- Y_FAIL("non-unique key");
+ Y_ABORT("non-unique key");
}
}
diff --git a/library/cpp/containers/stack_vector/stack_vec.h b/library/cpp/containers/stack_vector/stack_vec.h
index 25a8658fd3..b6036059b2 100644
--- a/library/cpp/containers/stack_vector/stack_vec.h
+++ b/library/cpp/containers/stack_vector/stack_vec.h
@@ -64,7 +64,7 @@ namespace NPrivate {
return reinterpret_cast<T*>(&StackBasedStorage[0]);
} else {
if constexpr (!UseFallbackAlloc) {
- Y_FAIL(
+ Y_ABORT(
"Stack storage overflow. Capacity: %d, requested: %d", (int)CountOnStack, int(n));
}
return FallbackAllocator().allocate(n);
diff --git a/library/cpp/coroutine/engine/impl.cpp b/library/cpp/coroutine/engine/impl.cpp
index 5f2e4a53f6..c999fe0e10 100644
--- a/library/cpp/coroutine/engine/impl.cpp
+++ b/library/cpp/coroutine/engine/impl.cpp
@@ -357,7 +357,7 @@ void TContExecutor::RunScheduler() noexcept {
}
} catch (...) {
TBackTrace::FromCurrentException().PrintTo(Cerr);
- Y_FAIL("Uncaught exception in the scheduler: %s", CurrentExceptionMessage().c_str());
+ Y_ABORT("Uncaught exception in the scheduler: %s", CurrentExceptionMessage().c_str());
}
}
@@ -372,7 +372,7 @@ void TContExecutor::Pause() {
void TContExecutor::Exit(TCont* cont) noexcept {
ScheduleToDelete(cont);
cont->SwitchTo(&SchedContext_);
- Y_FAIL("can not return from exit");
+ Y_ABORT("can not return from exit");
}
TInstant TContExecutor::Now() {
diff --git a/library/cpp/coroutine/engine/poller.cpp b/library/cpp/coroutine/engine/poller.cpp
index bcd31d209c..4669828a07 100644
--- a/library/cpp/coroutine/engine/poller.cpp
+++ b/library/cpp/coroutine/engine/poller.cpp
@@ -355,6 +355,6 @@ THolder<IPollerFace> IPollerFace::Construct(EContPoller poller) {
return nullptr;
#endif
default:
- Y_FAIL("bad poller type");
+ Y_ABORT("bad poller type");
}
}
diff --git a/library/cpp/getopt/small/completer.cpp b/library/cpp/getopt/small/completer.cpp
index f9a14b8234..43ceabe25b 100644
--- a/library/cpp/getopt/small/completer.cpp
+++ b/library/cpp/getopt/small/completer.cpp
@@ -122,7 +122,7 @@ namespace NLastGetopt::NComp {
}
void GenerateZsh(TFormattedOutput&, TCompleterManager&) const override {
- Y_FAIL("unreachable");
+ Y_ABORT("unreachable");
}
private:
diff --git a/library/cpp/grpc/client/grpc_client_low.cpp b/library/cpp/grpc/client/grpc_client_low.cpp
index d06bbb2a7d..0e8b97f256 100644
--- a/library/cpp/grpc/client/grpc_client_low.cpp
+++ b/library/cpp/grpc/client/grpc_client_low.cpp
@@ -568,7 +568,7 @@ void TGRpcClientLow::ForgetContext(TContextImpl* context) {
std::unique_lock<std::mutex> guard(Mtx_);
if (!Contexts_.erase(context)) {
- Y_FAIL("Unexpected ForgetContext(%p)", context);
+ Y_ABORT("Unexpected ForgetContext(%p)", context);
}
if (Contexts_.empty()) {
diff --git a/library/cpp/http/simple/http_client.h b/library/cpp/http/simple/http_client.h
index 94ee487202..c01b11ba43 100644
--- a/library/cpp/http/simple/http_client.h
+++ b/library/cpp/http/simple/http_client.h
@@ -271,6 +271,6 @@ TKeepAliveHttpClient::THttpCode TKeepAliveHttpClient::DoRequestReliable(const T&
throw;
}
}
- Y_FAIL(); // We should never be here.
+ Y_ABORT(); // We should never be here.
return 0;
}
diff --git a/library/cpp/logger/backend.cpp b/library/cpp/logger/backend.cpp
index 77211c9655..df23067f17 100644
--- a/library/cpp/logger/backend.cpp
+++ b/library/cpp/logger/backend.cpp
@@ -24,7 +24,7 @@ namespace {
return;
}
}
- Y_FAIL("Incorrect pointer for log backend");
+ Y_ABORT("Incorrect pointer for log backend");
}
void Reopen(bool flush) {
diff --git a/library/cpp/logger/global/global.cpp b/library/cpp/logger/global/global.cpp
index 9fbd10f666..4d4e6aeb37 100644
--- a/library/cpp/logger/global/global.cpp
+++ b/library/cpp/logger/global/global.cpp
@@ -39,5 +39,5 @@ TNullLog* CreateDefaultLogger<TNullLog>() {
NPrivateGlobalLogger::TVerifyEvent::~TVerifyEvent() {
const TString info = Str();
FATAL_LOG << info << Endl;
- Y_FAIL("%s", info.data());
+ Y_ABORT("%s", info.data());
}
diff --git a/library/cpp/lwtrace/mon/mon_lwtrace.cpp b/library/cpp/lwtrace/mon/mon_lwtrace.cpp
index 5e79716834..6642b07098 100644
--- a/library/cpp/lwtrace/mon/mon_lwtrace.cpp
+++ b/library/cpp/lwtrace/mon/mon_lwtrace.cpp
@@ -225,9 +225,9 @@ private:
} else {
return false; // param not found
}
- case TrackDuration: Y_FAIL();
- case TrackBeginTime: Y_FAIL();
- case TrackEndTime: Y_FAIL();
+ case TrackDuration: Y_ABORT();
+ case TrackBeginTime: Y_ABORT();
+ case TrackEndTime: Y_ABORT();
case ElapsedDuration: break;
case SliceDuration: break;
case ThreadTime: break;
@@ -240,9 +240,9 @@ private:
case NotSpecial:
Result = NLWTrace::TTypedParam(Item->GetParam(Query.ParamName));
return true;
- case TrackDuration: Y_FAIL();
- case TrackBeginTime: Y_FAIL();
- case TrackEndTime: Y_FAIL();
+ case TrackDuration: Y_ABORT();
+ case TrackBeginTime: Y_ABORT();
+ case TrackEndTime: Y_ABORT();
case ElapsedDuration:
Result = NLWTrace::TTypedParam(Query.Duration(
Log->GetTimestampCycles(),
diff --git a/library/cpp/lwtrace/signature.h b/library/cpp/lwtrace/signature.h
index 868bd9bcf2..2c68aa40bf 100644
--- a/library/cpp/lwtrace/signature.h
+++ b/library/cpp/lwtrace/signature.h
@@ -139,7 +139,7 @@ namespace NLWTrace {
case PT_UNKNOWN:
return;
default:
- Y_FAIL("unknown param type");
+ Y_ABORT("unknown param type");
}
}
@@ -180,7 +180,7 @@ namespace NLWTrace {
case PT_UNKNOWN:
return;
default:
- Y_FAIL("unknown param type");
+ Y_ABORT("unknown param type");
}
}
@@ -205,7 +205,7 @@ namespace NLWTrace {
case PT_UNKNOWN:
return;
default:
- Y_FAIL("unknown param type");
+ Y_ABORT("unknown param type");
}
}
@@ -224,7 +224,7 @@ namespace NLWTrace {
case PT_UNKNOWN:
return;
default:
- Y_FAIL("unknown param type");
+ Y_ABORT("unknown param type");
}
Type = PT_UNKNOWN;
}
@@ -240,7 +240,7 @@ namespace NLWTrace {
case PT_UNKNOWN:
return false; // All unknowns are equal
default:
- Y_FAIL("unknown param type");
+ Y_ABORT("unknown param type");
}
} else {
return false;
@@ -261,7 +261,7 @@ namespace NLWTrace {
case PT_UNKNOWN:
return false; // All unknowns are equal
default:
- Y_FAIL("unknown param type");
+ Y_ABORT("unknown param type");
}
} else {
return Type < rhs.Type;
@@ -279,7 +279,7 @@ namespace NLWTrace {
case PT_UNKNOWN:
return true; // All unknowns are equal
default:
- Y_FAIL("unknown param type");
+ Y_ABORT("unknown param type");
}
} else {
return Type < rhs.Type;
diff --git a/library/cpp/malloc/nalf/alloc_helpers.h b/library/cpp/malloc/nalf/alloc_helpers.h
index 0e3649d76a..c98c05d998 100644
--- a/library/cpp/malloc/nalf/alloc_helpers.h
+++ b/library/cpp/malloc/nalf/alloc_helpers.h
@@ -9,17 +9,17 @@ struct TNoHeapAlloc {
// implemented and available for gcc virtual destructors
protected:
void operator delete(void*) {
- Y_FAIL();
+ Y_ABORT();
}
void operator delete[](void*) {
- Y_FAIL();
+ Y_ABORT();
}
void operator delete(void*, const std::nothrow_t&) {
- Y_FAIL();
+ Y_ABORT();
}
void operator delete[](void*, const std::nothrow_t&) {
- Y_FAIL();
+ Y_ABORT();
}
};
diff --git a/library/cpp/messagebus/actor/tasks.h b/library/cpp/messagebus/actor/tasks.h
index 5e1fd5f212..ba4bc3050b 100644
--- a/library/cpp/messagebus/actor/tasks.h
+++ b/library/cpp/messagebus/actor/tasks.h
@@ -41,7 +41,7 @@ namespace NActor {
} else if (newState == E_WAITING) {
return false;
}
- Y_FAIL("unknown");
+ Y_ABORT("unknown");
}
};
diff --git a/library/cpp/messagebus/config/netaddr.cpp b/library/cpp/messagebus/config/netaddr.cpp
index 4660711a0c..0e9f76be8c 100644
--- a/library/cpp/messagebus/config/netaddr.cpp
+++ b/library/cpp/messagebus/config/netaddr.cpp
@@ -14,7 +14,7 @@ namespace NBus {
case EIP_VERSION_6:
return "EIP_VERSION_6";
}
- Y_FAIL();
+ Y_ABORT();
}
int ToAddrFamily(EIpVersion ipVersion) {
@@ -26,7 +26,7 @@ namespace NBus {
case EIP_VERSION_6:
return AF_INET6;
}
- Y_FAIL();
+ Y_ABORT();
}
class TNetworkAddressRef: private TNetworkAddress, public TAddrInfo {
@@ -81,7 +81,7 @@ namespace NBus {
case EIP_VERSION_ANY:
return "any address";
default:
- Y_FAIL("unreachable");
+ Y_ABORT("unreachable");
}
}
@@ -158,7 +158,7 @@ namespace NBus {
case AF_INET6:
return InetToHost(((sockaddr_in6*)Ptr->Addr())->sin6_port);
default:
- Y_FAIL("unknown AF: %d", (int)Ptr->Addr()->sa_family);
+ Y_ABORT("unknown AF: %d", (int)Ptr->Addr()->sa_family);
throw 1;
}
}
diff --git a/library/cpp/messagebus/debug_receiver/debug_receiver_proto.cpp b/library/cpp/messagebus/debug_receiver/debug_receiver_proto.cpp
index 0c74f9ecc3..008084d345 100644
--- a/library/cpp/messagebus/debug_receiver/debug_receiver_proto.cpp
+++ b/library/cpp/messagebus/debug_receiver/debug_receiver_proto.cpp
@@ -8,7 +8,7 @@ TDebugReceiverProtocol::TDebugReceiverProtocol()
}
void TDebugReceiverProtocol::Serialize(const NBus::TBusMessage*, TBuffer&) {
- Y_FAIL("it is receiver only");
+ Y_ABORT("it is receiver only");
}
TAutoPtr<NBus::TBusMessage> TDebugReceiverProtocol::Deserialize(ui16, TArrayRef<const char> payload) {
diff --git a/library/cpp/messagebus/event_loop.cpp b/library/cpp/messagebus/event_loop.cpp
index 9a9d90508d..ffb31d0c9b 100644
--- a/library/cpp/messagebus/event_loop.cpp
+++ b/library/cpp/messagebus/event_loop.cpp
@@ -262,7 +262,7 @@ TEventLoop::TImpl::TImpl(const char* name)
SOCKET wakeupSockets[2];
if (SocketPair(wakeupSockets) < 0) {
- Y_FAIL("failed to create socket pair for wakeup sockets: %s", LastSystemErrorText());
+ Y_ABORT("failed to create socket pair for wakeup sockets: %s", LastSystemErrorText());
}
TSocketHolder wakeupReadSocket(wakeupSockets[0]);
@@ -297,7 +297,7 @@ void TEventLoop::TImpl::Run() {
if (*c == this) {
char buf[0x1000];
if (NBus::NPrivate::SocketRecv(WakeupReadSocket, buf) < 0) {
- Y_FAIL("failed to recv from wakeup socket: %s", LastSystemErrorText());
+ Y_ABORT("failed to recv from wakeup socket: %s", LastSystemErrorText());
}
continue;
}
@@ -354,7 +354,7 @@ TChannelPtr TEventLoop::TImpl::Register(TSocket socket, TEventHandlerPtr eventHa
void TEventLoop::TImpl::Wakeup() {
if (NBus::NPrivate::SocketSend(WakeupWriteSocket, TArrayRef<const char>("", 1)) < 0) {
if (LastSystemError() != EAGAIN) {
- Y_FAIL("failed to send to wakeup socket: %s", LastSystemErrorText());
+ Y_ABORT("failed to send to wakeup socket: %s", LastSystemErrorText());
}
}
}
@@ -367,6 +367,6 @@ void TEventLoop::TImpl::AddToPoller(SOCKET socket, void* cookie, int flags) {
} else if (flags == OP_READ_WRITE) {
Poller.WaitReadWriteOneShot(socket, cookie);
} else {
- Y_FAIL("Wrong flags: %d", int(flags));
+ Y_ABORT("Wrong flags: %d", int(flags));
}
}
diff --git a/library/cpp/messagebus/locator.cpp b/library/cpp/messagebus/locator.cpp
index e49716f166..5cc4604754 100644
--- a/library/cpp/messagebus/locator.cpp
+++ b/library/cpp/messagebus/locator.cpp
@@ -409,7 +409,7 @@ namespace NBus {
return 0;
}
if ((item.Start < start && start < item.End) || (item.Start < end && end < item.End)) {
- Y_FAIL("Overlap in registered keys with non-identical range");
+ Y_ABORT("Overlap in registered keys with non-identical range");
}
}
diff --git a/library/cpp/messagebus/message.cpp b/library/cpp/messagebus/message.cpp
index ac8caa5c56..8f8ff7e442 100644
--- a/library/cpp/messagebus/message.cpp
+++ b/library/cpp/messagebus/message.cpp
@@ -34,7 +34,7 @@ namespace NBus {
if (!!Connection) {
return Connection->GetAddr();
} else {
- Y_FAIL();
+ Y_ABORT();
}
}
@@ -112,7 +112,7 @@ namespace NBus {
if (Y_UNLIKELY(LocalFlags != 0)) {
TString describe = Describe();
TString localFlags = LocalFlagSetToString(LocalFlags);
- Y_FAIL("message local flags must be zero, got: %s, message: %s", localFlags.data(), describe.data());
+ Y_ABORT("message local flags must be zero, got: %s, message: %s", localFlags.data(), describe.data());
}
}
diff --git a/library/cpp/messagebus/message.h b/library/cpp/messagebus/message.h
index 2027f24983..f7f58930c9 100644
--- a/library/cpp/messagebus/message.h
+++ b/library/cpp/messagebus/message.h
@@ -86,7 +86,7 @@ namespace NBus {
} else if (LocalFlags == NPrivate::MESSAGE_IN_WORK && !inWork) {
LocalFlags = 0;
} else {
- Y_FAIL("impossible combination of flag and parameter: %s %d",
+ Y_ABORT("impossible combination of flag and parameter: %s %d",
inWork ? "true" : "false", unsigned(LocalFlags));
}
}
diff --git a/library/cpp/messagebus/messqueue.cpp b/library/cpp/messagebus/messqueue.cpp
index 85baa3c383..789b86a15e 100644
--- a/library/cpp/messagebus/messqueue.cpp
+++ b/library/cpp/messagebus/messqueue.cpp
@@ -146,7 +146,7 @@ TBusServerSessionPtr TBusMessageQueue::CreateDestination(TBusProtocol* proto, IB
Add(session.Get());
return session.Release();
} catch (...) {
- Y_FAIL("create destination failure: %s", CurrentExceptionMessage().c_str());
+ Y_ABORT("create destination failure: %s", CurrentExceptionMessage().c_str());
}
}
@@ -157,7 +157,7 @@ TBusServerSessionPtr TBusMessageQueue::CreateDestination(TBusProtocol* proto, IB
Add(session.Get());
return session.Release();
} catch (...) {
- Y_FAIL("create destination failure: %s", CurrentExceptionMessage().c_str());
+ Y_ABORT("create destination failure: %s", CurrentExceptionMessage().c_str());
}
}
diff --git a/library/cpp/messagebus/oldmodule/module.cpp b/library/cpp/messagebus/oldmodule/module.cpp
index 4ec37a4d53..7db3a9af42 100644
--- a/library/cpp/messagebus/oldmodule/module.cpp
+++ b/library/cpp/messagebus/oldmodule/module.cpp
@@ -390,7 +390,7 @@ namespace NBus {
if (call.Status == MESSAGE_OK) {
++it; // keep pending list until we get reply
} else if (call.Status == MESSAGE_BUSY) {
- Y_FAIL("MESSAGE_BUSY is prohibited in modules. Please increase MaxInFlight");
+ Y_ABORT("MESSAGE_BUSY is prohibited in modules. Please increase MaxInFlight");
} else if (call.Status == MESSAGE_CONNECT_FAILED && call.NumRetries < call.MaxRetries) {
++it; // try up to call.MaxRetries times to send message
call.NumRetries++;
@@ -480,7 +480,7 @@ namespace NBus {
/// if not found, report error
if (i == Pending.size()) {
- Y_FAIL("must not happen");
+ Y_ABORT("must not happen");
}
/// fill in response into job state
diff --git a/library/cpp/messagebus/protobuf/ybusbuf.cpp b/library/cpp/messagebus/protobuf/ybusbuf.cpp
index 7212e59590..c6ef971172 100644
--- a/library/cpp/messagebus/protobuf/ybusbuf.cpp
+++ b/library/cpp/messagebus/protobuf/ybusbuf.cpp
@@ -47,7 +47,7 @@ void TBusBufferProtocol::Serialize(const TBusMessage* mess, TBuffer& data) {
const TBusHeader* header = mess->GetHeader();
if (!IsRegisteredType(header->Type)) {
- Y_FAIL("unknown message type: %d", int(header->Type));
+ Y_ABORT("unknown message type: %d", int(header->Type));
return;
}
@@ -69,7 +69,7 @@ TAutoPtr<TBusMessage> TBusBufferProtocol::Deserialize(ui16 messageType, TArrayRe
TBusBufferBase* messageTemplate = FindType(messageType);
if (messageTemplate == nullptr) {
return nullptr;
- //Y_FAIL("unknown message type: %d", unsigned(messageType));
+ //Y_ABORT("unknown message type: %d", unsigned(messageType));
}
// clone the base
diff --git a/library/cpp/messagebus/rain_check/core/task.cpp b/library/cpp/messagebus/rain_check/core/task.cpp
index d8aeefac25..0d4dd198a5 100644
--- a/library/cpp/messagebus/rain_check/core/task.cpp
+++ b/library/cpp/messagebus/rain_check/core/task.cpp
@@ -142,7 +142,7 @@ void TSubtaskCompletion::SetRunning(TTaskRunnerBase* parent) {
for (;;) {
ESubtaskState current = State.Get();
if (current != CREATED && current != DONE) {
- Y_FAIL("current state should be CREATED or DONE: %s", ToCString(current));
+ Y_ABORT("current state should be CREATED or DONE: %s", ToCString(current));
}
if (State.CompareAndSet(current, RUNNING)) {
return;
@@ -166,7 +166,7 @@ void TSubtaskCompletion::SetDone() {
break;
}
} else {
- Y_FAIL("cannot SetDone: unknown state: %s", ToCString(state));
+ Y_ABORT("cannot SetDone: unknown state: %s", ToCString(state));
}
}
diff --git a/library/cpp/messagebus/rain_check/core/task.h b/library/cpp/messagebus/rain_check/core/task.h
index 7d8778bcda..c5fa86323a 100644
--- a/library/cpp/messagebus/rain_check/core/task.h
+++ b/library/cpp/messagebus/rain_check/core/task.h
@@ -99,9 +99,9 @@ namespace NRainCheck {
case CANCELED:
return true;
case CREATED:
- Y_FAIL("not started");
+ Y_ABORT("not started");
default:
- Y_FAIL("unknown value: %u", (unsigned)state);
+ Y_ABORT("unknown value: %u", (unsigned)state);
}
}
diff --git a/library/cpp/messagebus/rain_check/http/client_ut.cpp b/library/cpp/messagebus/rain_check/http/client_ut.cpp
index 1628114391..747128b0b0 100644
--- a/library/cpp/messagebus/rain_check/http/client_ut.cpp
+++ b/library/cpp/messagebus/rain_check/http/client_ut.cpp
@@ -74,7 +74,7 @@ namespace {
const int THR_POOL_SIZE = 2;
runner->ForkLoop(THR_POOL_SIZE);
} catch (...) {
- Y_FAIL("Can't run server: %s", CurrentExceptionMessage().data());
+ Y_ABORT("Can't run server: %s", CurrentExceptionMessage().data());
}
return runner;
diff --git a/library/cpp/messagebus/remote_client_connection.cpp b/library/cpp/messagebus/remote_client_connection.cpp
index 30a7fc25fb..2fa56f7902 100644
--- a/library/cpp/messagebus/remote_client_connection.cpp
+++ b/library/cpp/messagebus/remote_client_connection.cpp
@@ -252,7 +252,7 @@ void TRemoteClientConnection::ReaderProcessMessageUnknownVersion(TArrayRef<const
LWPROBE(Error, ToString(MESSAGE_INVALID_VERSION), ToString(PeerAddr), "");
ReaderData.Status.Incremental.StatusCounter[MESSAGE_INVALID_VERSION] += 1;
// TODO: close connection
- Y_FAIL("unknown message");
+ Y_ABORT("unknown message");
}
void TRemoteClientConnection::ClearOutgoingQueue(TMessagesPtrs& result, bool reconnect) {
diff --git a/library/cpp/messagebus/remote_connection.cpp b/library/cpp/messagebus/remote_connection.cpp
index 24c2153730..0e79ca084a 100644
--- a/library/cpp/messagebus/remote_connection.cpp
+++ b/library/cpp/messagebus/remote_connection.cpp
@@ -143,7 +143,7 @@ namespace NBus {
}
void TRemoteConnection::TryConnect() {
- Y_FAIL("TryConnect is client connection only operation");
+ Y_ABORT("TryConnect is client connection only operation");
}
void TRemoteConnection::ScheduleRead() {
diff --git a/library/cpp/messagebus/scheduler_actor_ut.cpp b/library/cpp/messagebus/scheduler_actor_ut.cpp
index e81ffd3186..9f52e26f0c 100644
--- a/library/cpp/messagebus/scheduler_actor_ut.cpp
+++ b/library/cpp/messagebus/scheduler_actor_ut.cpp
@@ -22,7 +22,7 @@ Y_UNIT_TEST_SUITE(TSchedulerActorTests) {
void Act(TDefaultTag) {
if (!Alarm.FetchTask()) {
- Y_FAIL("must not have no spurious wakeups in test");
+ Y_ABORT("must not have no spurious wakeups in test");
}
TestSync.WaitForAndIncrement(Iteration++);
diff --git a/library/cpp/messagebus/socket_addr.cpp b/library/cpp/messagebus/socket_addr.cpp
index c1b3a28fbe..71a1277a92 100644
--- a/library/cpp/messagebus/socket_addr.cpp
+++ b/library/cpp/messagebus/socket_addr.cpp
@@ -36,7 +36,7 @@ NBus::NPrivate::TBusSocketAddr::TBusSocketAddr(const NAddr::IRemoteAddr* addr)
break;
}
default:
- Y_FAIL("unknown address family");
+ Y_ABORT("unknown address family");
}
}
diff --git a/library/cpp/messagebus/test/example/client/client.cpp b/library/cpp/messagebus/test/example/client/client.cpp
index 8d0f0584e0..e707ec432f 100644
--- a/library/cpp/messagebus/test/example/client/client.cpp
+++ b/library/cpp/messagebus/test/example/client/client.cpp
@@ -36,7 +36,7 @@ namespace NCalculator {
int b = requestMul->Record.GetB();
Cerr << a << " * " << b << " = " << response->Record.GetResult() << "\n";
} else {
- Y_FAIL("unknown request");
+ Y_ABORT("unknown request");
}
}
diff --git a/library/cpp/messagebus/test/example/server/server.cpp b/library/cpp/messagebus/test/example/server/server.cpp
index 13e52d75f5..dc0cda78fa 100644
--- a/library/cpp/messagebus/test/example/server/server.cpp
+++ b/library/cpp/messagebus/test/example/server/server.cpp
@@ -39,7 +39,7 @@ namespace NCalculator {
response->Record.SetResult(result);
request.SendReplyMove(response);
} else {
- Y_FAIL("unknown request");
+ Y_ABORT("unknown request");
}
}
};
diff --git a/library/cpp/messagebus/test/helper/example.cpp b/library/cpp/messagebus/test/helper/example.cpp
index 1ef2809111..80447ca1a8 100644
--- a/library/cpp/messagebus/test/helper/example.cpp
+++ b/library/cpp/messagebus/test/helper/example.cpp
@@ -83,7 +83,7 @@ void TExampleProtocol::Serialize(const TBusMessage* message, TBuffer& buffer) {
} else if (const TExampleResponse* exampleReply = dynamic_cast<const TExampleResponse*>(message)) {
buffer.Append(exampleReply->Data.data(), exampleReply->Data.size());
} else {
- Y_FAIL("unknown message type");
+ Y_ABORT("unknown message type");
}
}
@@ -204,7 +204,7 @@ void TExampleClient::OnReply(TAutoPtr<TBusMessage> mess, TAutoPtr<TBusMessage> r
void TExampleClient::OnError(TAutoPtr<TBusMessage> mess, EMessageStatus status) {
if (CrashOnError) {
- Y_FAIL("client failed: %s", ToCString(status));
+ Y_ABORT("client failed: %s", ToCString(status));
}
Y_UNUSED(mess);
diff --git a/library/cpp/messagebus/test/helper/message_handler_error.cpp b/library/cpp/messagebus/test/helper/message_handler_error.cpp
index c09811ec67..f22f46fa6c 100644
--- a/library/cpp/messagebus/test/helper/message_handler_error.cpp
+++ b/library/cpp/messagebus/test/helper/message_handler_error.cpp
@@ -6,21 +6,21 @@ using namespace NBus;
using namespace NBus::NTest;
void TBusClientHandlerError::OnError(TAutoPtr<TBusMessage>, EMessageStatus status) {
- Y_FAIL("must not be called, status: %s", ToString(status).data());
+ Y_ABORT("must not be called, status: %s", ToString(status).data());
}
void TBusClientHandlerError::OnReply(TAutoPtr<TBusMessage>, TAutoPtr<TBusMessage>) {
- Y_FAIL("must not be called");
+ Y_ABORT("must not be called");
}
void TBusClientHandlerError::OnMessageSentOneWay(TAutoPtr<TBusMessage>) {
- Y_FAIL("must not be called");
+ Y_ABORT("must not be called");
}
void TBusServerHandlerError::OnError(TAutoPtr<TBusMessage>, EMessageStatus status) {
- Y_FAIL("must not be called, status: %s", ToString(status).data());
+ Y_ABORT("must not be called, status: %s", ToString(status).data());
}
void TBusServerHandlerError::OnMessage(TOnMessageContext&) {
- Y_FAIL("must not be called");
+ Y_ABORT("must not be called");
}
diff --git a/library/cpp/messagebus/test/perftest/perftest.cpp b/library/cpp/messagebus/test/perftest/perftest.cpp
index 3084c9e01c..0a681a5c4d 100644
--- a/library/cpp/messagebus/test/perftest/perftest.cpp
+++ b/library/cpp/messagebus/test/perftest/perftest.cpp
@@ -279,7 +279,7 @@ public:
//delete message;
//Sleep(TDuration::MilliSeconds(1));
//continue;
- Y_FAIL("unreachable");
+ Y_ABORT("unreachable");
} else if (ret == MESSAGE_SHUTDOWN) {
delete message;
} else {
diff --git a/library/cpp/messagebus/test/ut/messagebus_ut.cpp b/library/cpp/messagebus/test/ut/messagebus_ut.cpp
index 8f6aa6a295..27886ad74c 100644
--- a/library/cpp/messagebus/test/ut/messagebus_ut.cpp
+++ b/library/cpp/messagebus/test/ut/messagebus_ut.cpp
@@ -555,7 +555,7 @@ Y_UNIT_TEST_SUITE(TMessageBusTests) {
TAutoPtr<TExampleResponse> resp(new TExampleResponse(&Proto.ResponseCount, 10));
req.SendReplyMove(resp);
} else {
- Y_FAIL("wrong");
+ Y_ABORT("wrong");
}
}
};
diff --git a/library/cpp/messagebus/test/ut/moduletest.h b/library/cpp/messagebus/test/ut/moduletest.h
index d5da72c0cb..665afbdf59 100644
--- a/library/cpp/messagebus/test/ut/moduletest.h
+++ b/library/cpp/messagebus/test/ut/moduletest.h
@@ -77,7 +77,7 @@ namespace NBus {
} else if (messageType == TYPE_HOSTINFORESPONSE) {
return new THostInfoReply(MESSAGE_CREATE_UNINITIALIZED);
} else {
- Y_FAIL("unknown");
+ Y_ABORT("unknown");
}
}
};
diff --git a/library/cpp/messagebus/test/ut/one_way_ut.cpp b/library/cpp/messagebus/test/ut/one_way_ut.cpp
index 0b90985289..a391669b39 100644
--- a/library/cpp/messagebus/test/ut/one_way_ut.cpp
+++ b/library/cpp/messagebus/test/ut/one_way_ut.cpp
@@ -125,7 +125,7 @@ public:
/// this handler should not be called because this server does not send replies
void OnSent(TAutoPtr<TBusMessage> mess) override {
Y_UNUSED(mess);
- Y_FAIL("This server does not sent replies");
+ Y_ABORT("This server does not sent replies");
}
};
diff --git a/library/cpp/messagebus/test/ut/starter_ut.cpp b/library/cpp/messagebus/test/ut/starter_ut.cpp
index dd4d3aaa5e..548e83ae5a 100644
--- a/library/cpp/messagebus/test/ut/starter_ut.cpp
+++ b/library/cpp/messagebus/test/ut/starter_ut.cpp
@@ -89,7 +89,7 @@ Y_UNIT_TEST_SUITE(TBusStarterTest) {
}
TJobHandler Never(TBusJob*, TBusMessage*) {
- Y_FAIL("happens");
+ Y_ABORT("happens");
throw 1;
}
};
diff --git a/library/cpp/messagebus/www/www.cpp b/library/cpp/messagebus/www/www.cpp
index a52ad404ff..9c3e0f522d 100644
--- a/library/cpp/messagebus/www/www.cpp
+++ b/library/cpp/messagebus/www/www.cpp
@@ -57,7 +57,7 @@ namespace {
}
}
- Y_FAIL("unregistered");
+ Y_ABORT("unregistered");
}
void Add(TValuePtr p) {
diff --git a/library/cpp/monlib/dynamic_counters/page.cpp b/library/cpp/monlib/dynamic_counters/page.cpp
index f2fdd61710..c0d523248a 100644
--- a/library/cpp/monlib/dynamic_counters/page.cpp
+++ b/library/cpp/monlib/dynamic_counters/page.cpp
@@ -111,7 +111,7 @@ void TDynamicCountersPage::HandleAbsentSubgroup(IMonHttpRequest& request) {
} else if (UnknownGroupPolicy == EUnknownGroupPolicy::Ignore) {
NoContent(request);
} else {
- Y_FAIL("Unsupported policy set");
+ Y_ABORT("Unsupported policy set");
}
}
diff --git a/library/cpp/monlib/encode/format.cpp b/library/cpp/monlib/encode/format.cpp
index fd16d690cb..63f9932aad 100644
--- a/library/cpp/monlib/encode/format.cpp
+++ b/library/cpp/monlib/encode/format.cpp
@@ -86,7 +86,7 @@ namespace NMonitoring {
return TStringBuf();
}
- Y_FAIL(); // for GCC
+ Y_ABORT(); // for GCC
}
ECompression CompressionFromAcceptEncodingHeader(TStringBuf value) {
@@ -111,7 +111,7 @@ namespace NMonitoring {
return TStringBuf();
}
- Y_FAIL(); // for GCC
+ Y_ABORT(); // for GCC
}
}
@@ -165,7 +165,7 @@ void Out<NMonitoring::EFormat>(IOutputStream& o, NMonitoring::EFormat f) {
return;
}
- Y_FAIL(); // for GCC
+ Y_ABORT(); // for GCC
}
template <>
@@ -207,5 +207,5 @@ void Out<NMonitoring::ECompression>(IOutputStream& o, NMonitoring::ECompression
return;
}
- Y_FAIL(); // for GCC
+ Y_ABORT(); // for GCC
}
diff --git a/library/cpp/monlib/encode/json/json_ut.cpp b/library/cpp/monlib/encode/json/json_ut.cpp
index 09e7909289..49de352062 100644
--- a/library/cpp/monlib/encode/json/json_ut.cpp
+++ b/library/cpp/monlib/encode/json/json_ut.cpp
@@ -276,7 +276,7 @@ Y_UNIT_TEST_SUITE(TJsonTest) {
break;
}
default:
- Y_FAIL("unexpected metric type [%s]", ToString(metricType).c_str());
+ Y_ABORT("unexpected metric type [%s]", ToString(metricType).c_str());
}
encoder->OnMetricEnd();
diff --git a/library/cpp/monlib/encode/spack/compression.cpp b/library/cpp/monlib/encode/spack/compression.cpp
index 5dc6fef960..ab27b533a5 100644
--- a/library/cpp/monlib/encode/spack/compression.cpp
+++ b/library/cpp/monlib/encode/spack/compression.cpp
@@ -361,7 +361,7 @@ namespace NMonitoring {
case ECompression::UNKNOWN:
return nullptr;
}
- Y_FAIL("invalid compression algorithm");
+ Y_ABORT("invalid compression algorithm");
}
THolder<IFramedCompressStream> CompressedOutput(IOutputStream* out, ECompression alg) {
@@ -377,7 +377,7 @@ namespace NMonitoring {
case ECompression::UNKNOWN:
return nullptr;
}
- Y_FAIL("invalid compression algorithm");
+ Y_ABORT("invalid compression algorithm");
}
}
diff --git a/library/cpp/monlib/encode/spack/spack_v1_decoder.cpp b/library/cpp/monlib/encode/spack/spack_v1_decoder.cpp
index 1f445fc80d..384ef456dd 100644
--- a/library/cpp/monlib/encode/spack/spack_v1_decoder.cpp
+++ b/library/cpp/monlib/encode/spack/spack_v1_decoder.cpp
@@ -258,7 +258,7 @@ namespace NMonitoring {
case ETimePrecision::MILLIS:
return TInstant::MilliSeconds(ReadFixed<ui64>());
}
- Y_FAIL("invalid time precision");
+ Y_ABORT("invalid time precision");
}
template <typename T>
@@ -413,7 +413,7 @@ namespace NMonitoring {
case ECompression::UNKNOWN:
return Max<ui8>();
}
- Y_FAIL(); // for GCC
+ Y_ABORT(); // for GCC
}
ECompression DecodeCompression(ui8 byte) {
diff --git a/library/cpp/monlib/metrics/metric_value.h b/library/cpp/monlib/metrics/metric_value.h
index 607fcc8602..be9d3e68dd 100644
--- a/library/cpp/monlib/metrics/metric_value.h
+++ b/library/cpp/monlib/metrics/metric_value.h
@@ -120,7 +120,7 @@ namespace NMonitoring {
case EMetricValueType::UNKNOWN:
ythrow yexception() << "unknown value type";
}
- Y_FAIL(); // for GCC
+ Y_ABORT(); // for GCC
}
ui64 AsUint64() const noexcept {
@@ -146,7 +146,7 @@ namespace NMonitoring {
case EMetricValueType::UNKNOWN:
ythrow yexception() << "unknown value type";
}
- Y_FAIL(); // for GCC
+ Y_ABORT(); // for GCC
}
i64 AsInt64() const noexcept {
@@ -172,7 +172,7 @@ namespace NMonitoring {
case EMetricValueType::UNKNOWN:
ythrow yexception() << "unknown value type";
}
- Y_FAIL(); // for GCC
+ Y_ABORT(); // for GCC
}
IHistogramSnapshot* AsHistogram() const noexcept {
diff --git a/library/cpp/monlib/service/service.cpp b/library/cpp/monlib/service/service.cpp
index 929efbf816..93b2d10b0c 100644
--- a/library/cpp/monlib/service/service.cpp
+++ b/library/cpp/monlib/service/service.cpp
@@ -143,7 +143,7 @@ namespace NMonitoring {
try {
Listener.Bind(TIpAddress(bindAddr, port));
} catch (yexception e) {
- Y_FAIL("TCoHttpServer::TCoHttpServer: couldn't bind to %s:%d\n", bindAddr.data(), port);
+ Y_ABORT("TCoHttpServer::TCoHttpServer: couldn't bind to %s:%d\n", bindAddr.data(), port);
}
}
diff --git a/library/cpp/neh/http2.cpp b/library/cpp/neh/http2.cpp
index a685195edf..79e0366de3 100644
--- a/library/cpp/neh/http2.cpp
+++ b/library/cpp/neh/http2.cpp
@@ -948,7 +948,7 @@ namespace {
SuggestPurgeCache();
if (ExceedHardLimit()) {
- Y_FAIL("neh::http2 output connections limit reached");
+ Y_ABORT("neh::http2 output connections limit reached");
//ythrow yexception() << "neh::http2 output connections limit reached";
}
}
diff --git a/library/cpp/neh/netliba.cpp b/library/cpp/neh/netliba.cpp
index 1f46ed0c1e..3a168b6e7e 100644
--- a/library/cpp/neh/netliba.cpp
+++ b/library/cpp/neh/netliba.cpp
@@ -403,7 +403,7 @@ namespace {
}
void AddResponse(TUdpHttpResponse*) override {
- Y_FAIL("unexpected response in neh netliba server");
+ Y_ABORT("unexpected response in neh netliba server");
}
void AddCancel(const TGUID& guid) override {
@@ -414,7 +414,7 @@ namespace {
}
void AddRequestAck(const TGUID&) override {
- Y_FAIL("unexpected acc in neh netliba server");
+ Y_ABORT("unexpected acc in neh netliba server");
}
void UpdateInProcess() {
diff --git a/library/cpp/neh/netliba_udp_http.cpp b/library/cpp/neh/netliba_udp_http.cpp
index 1e89347a13..b0b0e0ff03 100644
--- a/library/cpp/neh/netliba_udp_http.cpp
+++ b/library/cpp/neh/netliba_udp_http.cpp
@@ -322,7 +322,7 @@ namespace NNehNetliba {
void SendResponse(const TGUID& reqId, TVector<char>* data) override {
if (data && data->size() > MAX_PACKET_SIZE) {
- Y_FAIL(
+ Y_ABORT(
"data size is too large; data->size()=%" PRISZT ", MAX_PACKET_SIZE=%" PRISZT,
data->size(), MAX_PACKET_SIZE);
}
diff --git a/library/cpp/presort/presort.h b/library/cpp/presort/presort.h
index 0294892580..11b487e6b1 100644
--- a/library/cpp/presort/presort.h
+++ b/library/cpp/presort/presort.h
@@ -212,7 +212,7 @@ namespace NPresort {
ctx.Filled = byte & OptionalFilled;
break;
default:
- Y_FAIL("Invalid record code: %d", (int)code);
+ Y_ABORT("Invalid record code: %d", (int)code);
}
ctx.Code = (ECode)code;
return true;
diff --git a/library/cpp/scheme/scimpl_private.cpp b/library/cpp/scheme/scimpl_private.cpp
index 024bf8cc3b..cf35a3d767 100644
--- a/library/cpp/scheme/scimpl_private.cpp
+++ b/library/cpp/scheme/scimpl_private.cpp
@@ -58,7 +58,7 @@ namespace NSc {
case EMode::Throw:
ythrow TSchemeException() << "REFERENCE LOOP DETECTED";
case EMode::Abort:
- Y_FAIL("REFERENCE LOOP DETECTED");
+ Y_ABORT("REFERENCE LOOP DETECTED");
break;
case EMode::Stderr:
Cerr << "REFERENCE LOOP DETECTED: " << JoinStrings(Vector.begin(), Vector.end(), ", ")
diff --git a/library/cpp/scheme/tests/fuzz_ops/lib/vm_apply.cpp b/library/cpp/scheme/tests/fuzz_ops/lib/vm_apply.cpp
index ada7b8854f..1a6400457f 100644
--- a/library/cpp/scheme/tests/fuzz_ops/lib/vm_apply.cpp
+++ b/library/cpp/scheme/tests/fuzz_ops/lib/vm_apply.cpp
@@ -17,7 +17,7 @@ namespace NSc::NUt {
op(st.RRef(act.GetSrc(arg).Pos)); \
break; \
default: \
- Y_FAIL(); \
+ Y_ABORT(); \
}
@@ -58,7 +58,7 @@ namespace NSc::NUt {
st.LRef(act.GetDst(arg).Pos) = std::move(op); \
break; \
default: \
- Y_FAIL(); \
+ Y_ABORT(); \
}
@@ -74,7 +74,7 @@ namespace NSc::NUt {
st.LRef(act.GetRef(arg).Pos) = op; \
break; \
default: \
- Y_FAIL(); \
+ Y_ABORT(); \
}
#define Y_GEN_PTR_OP(op, arg, st, act) \
@@ -90,7 +90,7 @@ namespace NSc::NUt {
st.LRef(act.GetRef(arg).Pos) = *r; \
break; \
default: \
- Y_FAIL(); \
+ Y_ABORT(); \
} \
}
@@ -116,7 +116,7 @@ namespace NSc::NUt {
Y_GEN_TRY_OP(st.TryPushBack(st.RRef(act.GetSrc(0).Pos)))
break;
default:
- Y_FAIL();
+ Y_ABORT();
}
return true;
@@ -137,7 +137,7 @@ namespace NSc::NUt {
Y_GEN_TRY_OP(st.TryPushFront(st.RRef(act.GetSrc(0).Pos)))
break;
default:
- Y_FAIL();
+ Y_ABORT();
}
return true;
@@ -296,7 +296,7 @@ namespace NSc::NUt {
return true;
default:
- Y_FAIL();
+ Y_ABORT();
}
}
}
diff --git a/library/cpp/scheme/tests/fuzz_ops/lib/vm_parse.cpp b/library/cpp/scheme/tests/fuzz_ops/lib/vm_parse.cpp
index a03f5aef53..a73a7d6cbc 100644
--- a/library/cpp/scheme/tests/fuzz_ops/lib/vm_parse.cpp
+++ b/library/cpp/scheme/tests/fuzz_ops/lib/vm_parse.cpp
@@ -80,7 +80,7 @@ namespace NSc::NUt {
case TRef::T_CREATE_BACK:
return ref;
default:
- Y_FAIL();
+ Y_ABORT();
}
}
@@ -99,7 +99,7 @@ namespace NSc::NUt {
}
return src;
default:
- Y_FAIL();
+ Y_ABORT();
}
}
@@ -125,7 +125,7 @@ namespace NSc::NUt {
case TDst::T_CREATE_BACK_RREF:
return dst;
default:
- Y_FAIL();
+ Y_ABORT();
}
}
diff --git a/library/cpp/skiff/skiff_schema-inl.h b/library/cpp/skiff/skiff_schema-inl.h
index d66325b222..853ff36738 100644
--- a/library/cpp/skiff/skiff_schema-inl.h
+++ b/library/cpp/skiff/skiff_schema-inl.h
@@ -39,7 +39,7 @@ inline bool IsSimpleType(EWireType type)
case EWireType::RepeatedVariant16:
return false;
}
- Y_FAIL();
+ Y_ABORT();
}
////////////////////////////////////////////////////////////////////////////////
diff --git a/library/cpp/skiff/skiff_validator.cpp b/library/cpp/skiff/skiff_validator.cpp
index 0406e9fdc2..76dd3b7600 100644
--- a/library/cpp/skiff/skiff_validator.cpp
+++ b/library/cpp/skiff/skiff_validator.cpp
@@ -35,7 +35,7 @@ struct IValidatorNode
virtual void OnChildDone(TValidatorNodeStack* /*validatorNodeStack*/)
{
- Y_FAIL();
+ Y_ABORT();
}
virtual void OnSimpleType(TValidatorNodeStack* /*validatorNodeStack*/, EWireType wireType)
@@ -388,7 +388,7 @@ std::shared_ptr<IValidatorNode> CreateUsageValidatorNode(const std::shared_ptr<T
case EWireType::RepeatedVariant16:
return std::make_shared<TRepeatedVariant16TypeUsageValidator>(CreateUsageValidatorNodeList(skiffSchema->GetChildren()));
}
- Y_FAIL();
+ Y_ABORT();
}
////////////////////////////////////////////////////////////////////////////////
diff --git a/library/cpp/testing/common/network.cpp b/library/cpp/testing/common/network.cpp
index a1f9f22e5a..9f018f69b7 100644
--- a/library/cpp/testing/common/network.cpp
+++ b/library/cpp/testing/common/network.cpp
@@ -25,7 +25,7 @@ namespace {
#define Y_VERIFY_SYSERROR(expr) \
do { \
if (!(expr)) { \
- Y_FAIL(#expr ", errno=%d", LastSystemError()); \
+ Y_ABORT(#expr ", errno=%d", LastSystemError()); \
} \
} while (false)
@@ -137,7 +137,7 @@ namespace {
}
}
- Y_FAIL("Cannot get free port!");
+ Y_ABORT("Cannot get free port!");
}
TVector<NTesting::TPortHolder> GetFreePortsRange(size_t count) const {
@@ -167,7 +167,7 @@ namespace {
ports.clear();
}
}
- Y_FAIL("Cannot get range of %zu ports!", count);
+ Y_ABORT("Cannot get range of %zu ports!", count);
}
NTesting::TPortHolder GetPort(ui16 port) const {
@@ -176,7 +176,7 @@ namespace {
if (ackport) {
return NTesting::TPortHolder{std::move(ackport)};
}
- Y_FAIL("Cannot acquire port %hu!", port);
+ Y_ABORT("Cannot acquire port %hu!", port);
}
return GetFreePort();
}
diff --git a/library/cpp/testing/unittest/junit.cpp b/library/cpp/testing/unittest/junit.cpp
index 44771ecd14..0c83625110 100644
--- a/library/cpp/testing/unittest/junit.cpp
+++ b/library/cpp/testing/unittest/junit.cpp
@@ -278,7 +278,7 @@ void TJUnitProcessor::MakeReportFileName() {
if (ResultReportFileName.empty()) {
Cerr << "Could not find a vacant file name to write report for path " << FileName << ", maximum number of reports: " << MaxReps << Endl;
- Y_FAIL("Cannot write report");
+ Y_ABORT("Cannot write report");
}
}
diff --git a/library/cpp/threading/light_rw_lock/lightrwlock.h b/library/cpp/threading/light_rw_lock/lightrwlock.h
index bfe4e9b00c..abb97d6f7c 100644
--- a/library/cpp/threading/light_rw_lock/lightrwlock.h
+++ b/library/cpp/threading/light_rw_lock/lightrwlock.h
@@ -124,7 +124,7 @@ namespace NS_LightRWLock {
return;
if (errno == EINTR)
continue;
- Y_FAIL("futex error");
+ Y_ABORT("futex error");
}
}
}
@@ -133,7 +133,7 @@ namespace NS_LightRWLock {
const int result =
syscall(SYS_futex, &fvar, FUTEX_WAKE_PRIVATE, amount, NULL, NULL, 0);
if (Y_UNLIKELY(result == -1))
- Y_FAIL("futex error");
+ Y_ABORT("futex error");
}
}
diff --git a/library/cpp/type_info/type.cpp b/library/cpp/type_info/type.cpp
index d2c2fc6a5f..fb084fa18b 100644
--- a/library/cpp/type_info/type.cpp
+++ b/library/cpp/type_info/type.cpp
@@ -194,7 +194,7 @@ namespace NTi {
if (Y_LIKELY(IsRc(factoryOrRc))) {
size_t rc = FactoryOrRc_.fetch_sub(2, std::memory_order_acq_rel);
if (rc == 2) {
- Y_FAIL("DecRef isn't supposed to drop");
+ Y_ABORT("DecRef isn't supposed to drop");
}
} else if (Y_LIKELY(IsFactory(factoryOrRc))) {
auto factory = CastToFactory(factoryOrRc);
diff --git a/library/cpp/type_info/type_complexity.cpp b/library/cpp/type_info/type_complexity.cpp
index 073c24b909..b994cc2187 100644
--- a/library/cpp/type_info/type_complexity.cpp
+++ b/library/cpp/type_info/type_complexity.cpp
@@ -71,7 +71,7 @@ int ComputeTypeComplexity(const TType* type)
return 1 + ComputeTypeComplexity(type->AsTaggedRaw()->GetItemType());
}
}
- Y_FAIL("internal error: unreachable code");
+ Y_ABORT("internal error: unreachable code");
}
} // namespace NTi
diff --git a/library/cpp/type_info/type_factory.cpp b/library/cpp/type_info/type_factory.cpp
index 9d60307938..cc4206e012 100644
--- a/library/cpp/type_info/type_factory.cpp
+++ b/library/cpp/type_info/type_factory.cpp
@@ -336,7 +336,7 @@ namespace NTi {
void DecRef() noexcept override {
if (Counter_.Dec() == 0) {
- Y_FAIL("DecRef is not supposed to drop");
+ Y_ABORT("DecRef is not supposed to drop");
}
}
@@ -453,22 +453,22 @@ namespace NTi {
void RefType(NTi::TType* type) noexcept override {
Y_UNUSED(type);
- Y_FAIL("not supposed to be called");
+ Y_ABORT("not supposed to be called");
}
void UnRefType(NTi::TType* type) noexcept override {
Y_UNUSED(type);
- Y_FAIL("not supposed to be called");
+ Y_ABORT("not supposed to be called");
}
void DecRefType(NTi::TType* type) noexcept override {
Y_UNUSED(type);
- Y_FAIL("not supposed to be called");
+ Y_ABORT("not supposed to be called");
}
long RefCountType(const NTi::TType* type) const noexcept override {
Y_UNUSED(type);
- Y_FAIL("not supposed to be called");
+ Y_ABORT("not supposed to be called");
}
};
diff --git a/library/cpp/unified_agent_client/grpc_io.cpp b/library/cpp/unified_agent_client/grpc_io.cpp
index 569e04dde8..8c679ea924 100644
--- a/library/cpp/unified_agent_client/grpc_io.cpp
+++ b/library/cpp/unified_agent_client/grpc_io.cpp
@@ -106,7 +106,7 @@ namespace NUnifiedAgent {
try {
static_cast<IIOCallback*>(tag)->OnIOCompleted(ok ? EIOStatus::Ok : EIOStatus::Error);
} catch (...) {
- Y_FAIL("unexpected exception [%s]", CurrentExceptionMessage().c_str());
+ Y_ABORT("unexpected exception [%s]", CurrentExceptionMessage().c_str());
}
}
});
diff --git a/library/cpp/yaml/fyamlcpp/fyamlcpp.cpp b/library/cpp/yaml/fyamlcpp/fyamlcpp.cpp
index bea2ea4c7e..cf5d01ef70 100644
--- a/library/cpp/yaml/fyamlcpp/fyamlcpp.cpp
+++ b/library/cpp/yaml/fyamlcpp/fyamlcpp.cpp
@@ -864,7 +864,7 @@ fy_event_type GetOpenEventType(ENodeType type) {
case ENodeType::Sequence:
return FYET_SEQUENCE_START;
default:
- Y_FAIL("Not a brackets type");
+ Y_ABORT("Not a brackets type");
}
}
@@ -875,7 +875,7 @@ fy_event_type GetCloseEventType(ENodeType type) {
case ENodeType::Sequence:
return FYET_SEQUENCE_END;
default:
- Y_FAIL("Not a brackets type");
+ Y_ABORT("Not a brackets type");
}
}
diff --git a/library/cpp/yson/detail.h b/library/cpp/yson/detail.h
index 96b35f965c..23971d2d69 100644
--- a/library/cpp/yson/detail.h
+++ b/library/cpp/yson/detail.h
@@ -591,7 +591,7 @@ namespace NYson {
throwIncorrectBoolean();
}
- Y_FAIL("unreachable");
+ Y_ABORT("unreachable");
;
}
@@ -735,7 +735,7 @@ namespace NYson {
}
void RefreshBlock() {
- Y_FAIL("unreachable");
+ Y_ABORT("unreachable");
}
void Advance(size_t bytes) {
diff --git a/library/cpp/yson/lexer_detail.h b/library/cpp/yson/lexer_detail.h
index 0bba30acdd..11e122509e 100644
--- a/library/cpp/yson/lexer_detail.h
+++ b/library/cpp/yson/lexer_detail.h
@@ -217,7 +217,7 @@ namespace NYson {
} else if (state == EReadStartCase::BinaryTrue) {
*token = TToken(true);
} else {
- Y_FAIL("unreachable");
+ Y_ABORT("unreachable");
}
}
} else { // BinaryStringOrOtherSpecialToken = x0b
diff --git a/library/cpp/yson/node/node.cpp b/library/cpp/yson/node/node.cpp
index 3733c3cae2..5156033cfe 100644
--- a/library/cpp/yson/node/node.cpp
+++ b/library/cpp/yson/node/node.cpp
@@ -71,7 +71,7 @@ bool operator<(const TNode& lhs, const TNode& rhs)
case TNode::Undefined:
return false;
default:
- Y_FAIL("Unexpected type: %d", lhs.GetType());
+ Y_ABORT("Unexpected type: %d", lhs.GetType());
}
}
diff --git a/library/cpp/yson/node/node_visitor.cpp b/library/cpp/yson/node/node_visitor.cpp
index 41181a7507..258afc21ea 100644
--- a/library/cpp/yson/node/node_visitor.cpp
+++ b/library/cpp/yson/node/node_visitor.cpp
@@ -83,7 +83,7 @@ void TNodeVisitor::VisitAny(const TNode& node)
case TNode::Undefined:
ythrow TNode::TTypeError() << "unable to visit TNode of type " << node.GetType();
default:
- Y_FAIL("Unexpected type: %d", node.GetType());
+ Y_ABORT("Unexpected type: %d", node.GetType());
}
}
diff --git a/library/cpp/yson/parser_detail.h b/library/cpp/yson/parser_detail.h
index bf9fbfcedf..9d8315dd60 100644
--- a/library/cpp/yson/parser_detail.h
+++ b/library/cpp/yson/parser_detail.h
@@ -35,7 +35,7 @@ namespace NYson {
break;
default:
- Y_FAIL("unreachable");
+ Y_ABORT("unreachable");
}
while (!(TBase::IsFinished() && TBase::IsEmpty())) {
diff --git a/library/cpp/yson/token.cpp b/library/cpp/yson/token.cpp
index c8584c8c2e..589bb6c089 100644
--- a/library/cpp/yson/token.cpp
+++ b/library/cpp/yson/token.cpp
@@ -72,7 +72,7 @@ namespace NYson {
case ETokenType::Comma:
return ',';
default:
- Y_FAIL("unreachable");
+ Y_ABORT("unreachable");
}
}
@@ -106,7 +106,7 @@ namespace NYson {
case ETokenType::Uint64:
case ETokenType::Double:
case ETokenType::Boolean:
- Y_FAIL("unreachable");
+ Y_ABORT("unreachable");
default:
break;
}