aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/test/ut/one_way_ut.cpp
diff options
context:
space:
mode:
authoryazevnul <yazevnul@yandex-team.ru>2022-02-10 16:46:48 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:46:48 +0300
commit9abfb1a53b7f7b791444d1378e645d8fad9b06ed (patch)
tree49e222ea1c5804306084bb3ae065bb702625360f /library/cpp/messagebus/test/ut/one_way_ut.cpp
parent8cbc307de0221f84c80c42dcbe07d40727537e2c (diff)
downloadydb-9abfb1a53b7f7b791444d1378e645d8fad9b06ed.tar.gz
Restoring authorship annotation for <yazevnul@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/messagebus/test/ut/one_way_ut.cpp')
-rw-r--r--library/cpp/messagebus/test/ut/one_way_ut.cpp24
1 files changed, 12 insertions, 12 deletions
diff --git a/library/cpp/messagebus/test/ut/one_way_ut.cpp b/library/cpp/messagebus/test/ut/one_way_ut.cpp
index 7f18da400e..9c21227e2b 100644
--- a/library/cpp/messagebus/test/ut/one_way_ut.cpp
+++ b/library/cpp/messagebus/test/ut/one_way_ut.cpp
@@ -114,7 +114,7 @@ public:
void OnMessage(TOnMessageContext& mess) override {
TExampleRequest* fmess = static_cast<TExampleRequest*>(mess.GetMessage());
- Y_ASSERT(fmess->Data == "TADA");
+ Y_ASSERT(fmess->Data == "TADA");
/// tell session to forget this message and never expect any reply
mess.ForgetRequest();
@@ -124,13 +124,13 @@ 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_UNUSED(mess);
+ Y_FAIL("This server does not sent replies");
}
};
-Y_UNIT_TEST_SUITE(TMessageBusTests_OneWay) {
- Y_UNIT_TEST(Simple) {
+Y_UNIT_TEST_SUITE(TMessageBusTests_OneWay) {
+ Y_UNIT_TEST(Simple) {
TObjectCountCheck objectCountCheck;
NullServer server;
@@ -166,15 +166,15 @@ Y_UNIT_TEST_SUITE(TMessageBusTests_OneWay) {
}
void OnError(TAutoPtr<TBusMessage> mess, EMessageStatus status) override {
- Y_UNUSED(mess);
+ Y_UNUSED(mess);
- Y_VERIFY(status == MESSAGE_MESSAGE_TOO_LARGE, "wrong status: %s", ToCString(status));
+ Y_VERIFY(status == MESSAGE_MESSAGE_TOO_LARGE, "wrong status: %s", ToCString(status));
GotTooLarge.Signal();
}
};
- Y_UNIT_TEST(MessageTooLargeOnClient) {
+ Y_UNIT_TEST(MessageTooLargeOnClient) {
TObjectCountCheck objectCountCheck;
NullServer server;
@@ -209,14 +209,14 @@ Y_UNIT_TEST_SUITE(TMessageBusTests_OneWay) {
/// message that could not be delivered
void OnError(TAutoPtr<TBusMessage> mess, EMessageStatus status) override {
- Y_UNUSED(mess);
- Y_UNUSED(status); // TODO: check status
+ Y_UNUSED(mess);
+ Y_UNUSED(status); // TODO: check status
GotError.Signal();
}
};
- Y_UNIT_TEST(SendTimeout_Callback_NoServer) {
+ Y_UNIT_TEST(SendTimeout_Callback_NoServer) {
TObjectCountCheck objectCountCheck;
TCheckTimeoutClient client(TNetAddr("localhost", 17));
@@ -227,7 +227,7 @@ Y_UNIT_TEST_SUITE(TMessageBusTests_OneWay) {
client.GotError.WaitI();
}
- Y_UNIT_TEST(SendTimeout_Callback_HangingServer) {
+ Y_UNIT_TEST(SendTimeout_Callback_HangingServer) {
THangingServer server;
TObjectCountCheck objectCountCheck;