Y_FAIL->Y_ABORT at '^li'

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

20 files changed, 49 insertions, 49 deletions

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