aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/test/ut/module_server_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/module_server_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/module_server_ut.cpp')
-rw-r--r--library/cpp/messagebus/test/ut/module_server_ut.cpp14
1 files changed, 7 insertions, 7 deletions
diff --git a/library/cpp/messagebus/test/ut/module_server_ut.cpp b/library/cpp/messagebus/test/ut/module_server_ut.cpp
index 4acc9e3f59..88fe1dd9b6 100644
--- a/library/cpp/messagebus/test/ut/module_server_ut.cpp
+++ b/library/cpp/messagebus/test/ut/module_server_ut.cpp
@@ -15,8 +15,8 @@
using namespace NBus;
using namespace NBus::NTest;
-Y_UNIT_TEST_SUITE(ModuleServerTests) {
- Y_UNIT_TEST(TestModule) {
+Y_UNIT_TEST_SUITE(ModuleServerTests) {
+ Y_UNIT_TEST(TestModule) {
TObjectCountCheck objectCountCheck;
/// create or get instance of message queue, need one per application
@@ -49,7 +49,7 @@ Y_UNIT_TEST_SUITE(ModuleServerTests) {
TJobHandler Start(TBusJob* job, TBusMessage* mess) override {
WaitTwoRequestsLatch.CountDown();
- Y_VERIFY(WaitTwoRequestsLatch.Await(TDuration::Seconds(5)), "oops");
+ Y_VERIFY(WaitTwoRequestsLatch.Await(TDuration::Seconds(5)), "oops");
VerifyDynamicCast<TExampleRequest*>(mess);
@@ -58,7 +58,7 @@ Y_UNIT_TEST_SUITE(ModuleServerTests) {
}
};
- Y_UNIT_TEST(TestOnMessageHandlerCalledInParallel) {
+ Y_UNIT_TEST(TestOnMessageHandlerCalledInParallel) {
TObjectCountCheck objectCountCheck;
TBusQueueConfig config;
@@ -79,18 +79,18 @@ Y_UNIT_TEST_SUITE(ModuleServerTests) {
TSystemEvent ClientDiedEvent;
TJobHandler Start(TBusJob* job, TBusMessage* mess) override {
- Y_UNUSED(mess);
+ Y_UNUSED(mess);
MessageReceivedEvent.Signal();
- Y_VERIFY(ClientDiedEvent.WaitT(TDuration::Seconds(5)), "oops");
+ Y_VERIFY(ClientDiedEvent.WaitT(TDuration::Seconds(5)), "oops");
job->SendReply(new TExampleResponse(&Proto.ResponseCount));
return nullptr;
}
};
- Y_UNIT_TEST(TestReplyCalledAfterClientDisconnected) {
+ Y_UNIT_TEST(TestReplyCalledAfterClientDisconnected) {
TObjectCountCheck objectCountCheck;
TBusQueueConfig config;