aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/test/ut/starter_ut.cpp
diff options
context:
space:
mode:
authoryazevnul <yazevnul@yandex-team.ru>2022-02-10 16:46:46 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:46:46 +0300
commit8cbc307de0221f84c80c42dcbe07d40727537e2c (patch)
tree625d5a673015d1df891e051033e9fcde5c7be4e5 /library/cpp/messagebus/test/ut/starter_ut.cpp
parent30d1ef3941e0dc835be7609de5ebee66958f215a (diff)
downloadydb-8cbc307de0221f84c80c42dcbe07d40727537e2c.tar.gz
Restoring authorship annotation for <yazevnul@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/messagebus/test/ut/starter_ut.cpp')
-rw-r--r--library/cpp/messagebus/test/ut/starter_ut.cpp20
1 files changed, 10 insertions, 10 deletions
diff --git a/library/cpp/messagebus/test/ut/starter_ut.cpp b/library/cpp/messagebus/test/ut/starter_ut.cpp
index dd4d3aaa5e..76d688b62e 100644
--- a/library/cpp/messagebus/test/ut/starter_ut.cpp
+++ b/library/cpp/messagebus/test/ut/starter_ut.cpp
@@ -7,7 +7,7 @@
using namespace NBus;
using namespace NBus::NTest;
-Y_UNIT_TEST_SUITE(TBusStarterTest) {
+Y_UNIT_TEST_SUITE(TBusStarterTest) {
struct TStartJobTestModule: public TExampleModule {
using TBusModule::CreateDefaultStarter;
@@ -19,21 +19,21 @@ Y_UNIT_TEST_SUITE(TBusStarterTest) {
}
TJobHandler Start(TBusJob* job, TBusMessage* mess) override {
- Y_UNUSED(mess);
+ Y_UNUSED(mess);
AtomicIncrement(StartCount);
job->Sleep(10);
return &TStartJobTestModule::End;
}
TJobHandler End(TBusJob* job, TBusMessage* mess) {
- Y_UNUSED(mess);
+ Y_UNUSED(mess);
AtomicIncrement(StartCount);
job->Cancel(MESSAGE_UNKNOWN);
return nullptr;
}
};
- Y_UNIT_TEST(Test) {
+ Y_UNIT_TEST(Test) {
TObjectCountCheck objectCountCheck;
TBusMessageQueuePtr bus(CreateMessageQueue());
@@ -55,7 +55,7 @@ Y_UNIT_TEST_SUITE(TBusStarterTest) {
bus->Stop();
}
- Y_UNIT_TEST(TestModuleStartJob) {
+ Y_UNIT_TEST(TestModuleStartJob) {
TObjectCountCheck objectCountCheck;
TExampleProtocol proto;
@@ -79,7 +79,7 @@ Y_UNIT_TEST_SUITE(TBusStarterTest) {
TSystemEvent MessageReceivedEvent;
TJobHandler Start(TBusJob* job, TBusMessage* mess) override {
- Y_UNUSED(mess);
+ Y_UNUSED(mess);
MessageReceivedEvent.Signal();
@@ -89,12 +89,12 @@ Y_UNIT_TEST_SUITE(TBusStarterTest) {
}
TJobHandler Never(TBusJob*, TBusMessage*) {
- Y_FAIL("happens");
+ Y_FAIL("happens");
throw 1;
}
};
- Y_UNIT_TEST(StartJobDestroyDuringSleep) {
+ Y_UNIT_TEST(StartJobDestroyDuringSleep) {
TObjectCountCheck objectCountCheck;
TExampleProtocol proto;
@@ -114,7 +114,7 @@ Y_UNIT_TEST_SUITE(TBusStarterTest) {
TSystemEvent MessageReceivedEvent;
TJobHandler Start(TBusJob* job, TBusMessage* mess) override {
- Y_UNUSED(mess);
+ Y_UNUSED(mess);
job->SendReply(new TExampleResponse(&Proto.ResponseCount));
@@ -124,7 +124,7 @@ Y_UNIT_TEST_SUITE(TBusStarterTest) {
}
};
- Y_UNIT_TEST(AllowSendReplyInStarted) {
+ Y_UNIT_TEST(AllowSendReplyInStarted) {
TObjectCountCheck objectCountCheck;
TExampleProtocol proto;