Y_VERIFY->Y_ABORT_UNLESS at ^l

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

1 files changed, 4 insertions, 4 deletions

diff --git a/library/cpp/messagebus/remote_client_connection.cpp b/library/cpp/messagebus/remote_client_connection.cpp
index 8c7a6db3a8..30a7fc25fb 100644
--- a/library/cpp/messagebus/remote_client_connection.cpp
+++ b/library/cpp/messagebus/remote_client_connection.cpp
@@ -20,7 +20,7 @@ TRemoteClientConnection::TRemoteClientConnection(TRemoteClientSessionPtr session
     : TRemoteConnection(session.Get(), id, addr)
     , ClientHandler(GetSession()->ClientHandler)
 {
-    Y_VERIFY(addr.GetPort() > 0, "must connect to non-zero port");
+    Y_ABORT_UNLESS(addr.GetPort() > 0, "must connect to non-zero port");
 
     ScheduleWrite();
 }
@@ -35,7 +35,7 @@ TBusMessage* TRemoteClientConnection::PopAck(TBusKey id) {
 
 SOCKET TRemoteClientConnection::CreateSocket(const TNetAddr& addr) {
     SOCKET handle = socket(addr.Addr()->sa_family, SOCK_STREAM, 0);
-    Y_VERIFY(handle != INVALID_SOCKET, "failed to create socket: %s", LastSystemErrorText());
+    Y_ABORT_UNLESS(handle != INVALID_SOCKET, "failed to create socket: %s", LastSystemErrorText());
 
     TSocketHolder s(handle);
 
@@ -61,7 +61,7 @@ void TRemoteClientConnection::TryConnect() {
     if (AtomicGet(WriterData.Down)) {
         return;
     }
-    Y_VERIFY(!WriterData.Status.Connected);
+    Y_ABORT_UNLESS(!WriterData.Status.Connected);
 
     TInstant now = TInstant::Now();
 
@@ -306,7 +306,7 @@ EMessageStatus TRemoteClientConnection::SendMessageImpl(TBusMessage* msg, bool w
     }
 
     if (wait) {
-        Y_VERIFY(!Session->Queue->GetExecutor()->IsInExecutorThread());
+        Y_ABORT_UNLESS(!Session->Queue->GetExecutor()->IsInExecutorThread());
         GetSession()->ClientRemoteInFlight.Wait();
     } else {
         if (!GetSession()->ClientRemoteInFlight.TryWait()) {