aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/test
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/messagebus/test
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/messagebus/test')
-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
9 files changed, 14 insertions, 14 deletions
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;
}
};