Restoring authorship annotation for <agorodilov@yandex-team.ru>. Commit 2 of 2.

12 files changed, 76 insertions, 76 deletions

diff --git a/library/cpp/messagebus/test/example/client/client.cpp b/library/cpp/messagebus/test/example/client/client.cpp
index b61bfb1a6e..89b5f2c9be 100644
--- a/library/cpp/messagebus/test/example/client/client.cpp
+++ b/library/cpp/messagebus/test/example/client/client.cpp
@@ -18,11 +18,11 @@ namespace NCalculator {
             ClientSession = TBusClientSession::Create(&Proto, this, config, MessageQueue);
         }
 
-        ~TCalculatorClient() override { 
+        ~TCalculatorClient() override {
             MessageQueue->Stop();
         }
 
-        void OnReply(TAutoPtr<TBusMessage> request, TAutoPtr<TBusMessage> response0) override { 
+        void OnReply(TAutoPtr<TBusMessage> request, TAutoPtr<TBusMessage> response0) override {
             Y_VERIFY(response0->GetHeader()->Type == TResponse::MessageType, "wrong response");
             TResponse* response = VerifyDynamicCast<TResponse*>(response0.Get());
             if (request->GetHeader()->Type == TRequestSum::MessageType) {
@@ -40,7 +40,7 @@ namespace NCalculator {
             }
         }
 
-        void OnError(TAutoPtr<TBusMessage>, EMessageStatus status) override { 
+        void OnError(TAutoPtr<TBusMessage>, EMessageStatus status) override {
             Cerr << "got error " << status << "\n";
         }
     };
diff --git a/library/cpp/messagebus/test/example/server/server.cpp b/library/cpp/messagebus/test/example/server/server.cpp
index b7e1045782..13e52d75f5 100644
--- a/library/cpp/messagebus/test/example/server/server.cpp
+++ b/library/cpp/messagebus/test/example/server/server.cpp
@@ -15,11 +15,11 @@ namespace NCalculator {
             ServerSession = TBusServerSession::Create(&Proto, this, config, MessageQueue);
         }
 
-        ~TCalculatorServer() override { 
+        ~TCalculatorServer() override {
             MessageQueue->Stop();
         }
 
-        void OnMessage(TOnMessageContext& request) override { 
+        void OnMessage(TOnMessageContext& request) override {
             if (request.GetMessage()->GetHeader()->Type == TRequestSum::MessageType) {
                 TRequestSum* requestSum = VerifyDynamicCast<TRequestSum*>(request.GetMessage());
                 int a = requestSum->Record.GetA();
diff --git a/library/cpp/messagebus/test/helper/example.cpp b/library/cpp/messagebus/test/helper/example.cpp
index b76fcbbe5f..7c6d704042 100644
--- a/library/cpp/messagebus/test/helper/example.cpp
+++ b/library/cpp/messagebus/test/helper/example.cpp
@@ -100,7 +100,7 @@ TAutoPtr<TBusMessage> TExampleProtocol::Deserialize(ui16 messageType, TArrayRef<
         exampleReply->Data.append(payload.data(), payload.size());
         return exampleReply;
     } else {
-        return nullptr; 
+        return nullptr;
     }
 }
 
diff --git a/library/cpp/messagebus/test/helper/example_module.cpp b/library/cpp/messagebus/test/helper/example_module.cpp
index 3f040b37c9..65ecfcf73f 100644
--- a/library/cpp/messagebus/test/helper/example_module.cpp
+++ b/library/cpp/messagebus/test/helper/example_module.cpp
@@ -22,7 +22,7 @@ bool TExampleModule::Shutdown() {
 }
 
 TBusServerSessionPtr TExampleModule::CreateExtSession(TBusMessageQueue&) {
-    return nullptr; 
+    return nullptr;
 }
 
 TBusServerSessionPtr TExampleServerModule::CreateExtSession(TBusMessageQueue& queue) {
@@ -39,5 +39,5 @@ TExampleClientModule::TExampleClientModule()
 TBusServerSessionPtr TExampleClientModule::CreateExtSession(TBusMessageQueue& queue) {
     Source = CreateDefaultSource(queue, &Proto, TBusServerSessionConfig());
     Source->RegisterService("localhost");
-    return nullptr; 
+    return nullptr;
 }
diff --git a/library/cpp/messagebus/test/perftest/perftest.cpp b/library/cpp/messagebus/test/perftest/perftest.cpp
index 20ac0e2015..8489319278 100644
--- a/library/cpp/messagebus/test/perftest/perftest.cpp
+++ b/library/cpp/messagebus/test/perftest/perftest.cpp
@@ -294,7 +294,7 @@ public:
     }
 
     /// actual work is being done here
-    void OnReply(TAutoPtr<TBusMessage> mess, TAutoPtr<TBusMessage> reply) override { 
+    void OnReply(TAutoPtr<TBusMessage> mess, TAutoPtr<TBusMessage> reply) override {
         Y_UNUSED(mess);
 
         if (Config.SimpleProtocol) {
@@ -309,7 +309,7 @@ public:
     }
 
     /// message that could not be delivered
-    void OnError(TAutoPtr<TBusMessage> mess, EMessageStatus status) override { 
+    void OnError(TAutoPtr<TBusMessage> mess, EMessageStatus status) override {
         Y_UNUSED(mess);
         Y_UNUSED(status);
 
@@ -372,7 +372,7 @@ public:
     }
 
     /// when message comes, send reply
-    void OnMessage(TOnMessageContext& mess) override { 
+    void OnMessage(TOnMessageContext& mess) override {
         if (Config.SimpleProtocol) {
             TSimpleMessage* typed = VerifyDynamicCast<TSimpleMessage*>(mess.GetMessage());
             TAutoPtr<TSimpleMessage> response(new TSimpleMessage);
@@ -425,7 +425,7 @@ public:
     }
 
 private:
-    TJobHandler Start(TBusJob* job, TBusMessage* mess) override { 
+    TJobHandler Start(TBusJob* job, TBusMessage* mess) override {
         TPerftestRequest* typed = VerifyDynamicCast<TPerftestRequest*>(mess);
         CheckRequest(typed);
 
@@ -436,14 +436,14 @@ private:
 
         /// forget replies for few messages, see what happends
         if (TheConfig->Failure > RandomNumber<double>()) {
-            return nullptr; 
+            return nullptr;
         }
 
         job->SendReply(NewResponse(typed).Release());
-        return nullptr; 
+        return nullptr;
     }
 
-    TBusServerSessionPtr CreateExtSession(TBusMessageQueue& queue) override { 
+    TBusServerSessionPtr CreateExtSession(TBusMessageQueue& queue) override {
         return Session = CreateDefaultDestination(queue, Proto.Get(), Config.ServerSessionConfig);
     }
 };
@@ -459,7 +459,7 @@ static TNetworkAddress ParseNetworkAddress(const char* string) {
 
     const char* port = strchr(string, ':');
 
-    if (port != nullptr) { 
+    if (port != nullptr) {
         Name.append(string, port - string);
         Port = atoi(port + 1);
     } else {
@@ -591,8 +591,8 @@ int main(int argc, char* argv[]) {
     NLWTrace::StartLwtraceFromEnv();
 
     /* unix foo */
-    setvbuf(stdout, nullptr, _IONBF, 0); 
-    setvbuf(stderr, nullptr, _IONBF, 0); 
+    setvbuf(stdout, nullptr, _IONBF, 0);
+    setvbuf(stderr, nullptr, _IONBF, 0);
     Umask(0);
     SetAsyncSignalHandler(SIGINT, stopsignal);
     SetAsyncSignalHandler(SIGTERM, stopsignal);
diff --git a/library/cpp/messagebus/test/perftest/simple_proto.cpp b/library/cpp/messagebus/test/perftest/simple_proto.cpp
index b50659d794..19d6c15b9d 100644
--- a/library/cpp/messagebus/test/perftest/simple_proto.cpp
+++ b/library/cpp/messagebus/test/perftest/simple_proto.cpp
@@ -14,7 +14,7 @@ void TSimpleProtocol::Serialize(const TBusMessage* mess, TBuffer& data) {
 
 TAutoPtr<TBusMessage> TSimpleProtocol::Deserialize(ui16, TArrayRef<const char> payload) {
     if (payload.size() != 4) {
-        return nullptr; 
+        return nullptr;
     }
     TAutoPtr<TSimpleMessage> r(new TSimpleMessage);
     memcpy(&r->Payload, payload.data(), 4);
diff --git a/library/cpp/messagebus/test/ut/messagebus_ut.cpp b/library/cpp/messagebus/test/ut/messagebus_ut.cpp
index 26db074861..040f9b7702 100644
--- a/library/cpp/messagebus/test/ut/messagebus_ut.cpp
+++ b/library/cpp/messagebus/test/ut/messagebus_ut.cpp
@@ -30,7 +30,7 @@ namespace {
             Session->Shutdown();
         }
 
-        void OnReply(TAutoPtr<TBusMessage> mess, TAutoPtr<TBusMessage> reply) override { 
+        void OnReply(TAutoPtr<TBusMessage> mess, TAutoPtr<TBusMessage> reply) override {
             Y_VERIFY(AtomicGet(SentCompleted), "must be completed");
 
             TExampleClient::OnReply(mess, reply);
@@ -38,7 +38,7 @@ namespace {
             ReplyReceived.Signal();
         }
 
-        void OnMessageSent(TBusMessage*) override { 
+        void OnMessageSent(TBusMessage*) override {
             Sleep(TDuration::MilliSeconds(100));
             AtomicSet(SentCompleted, 1);
         }
@@ -259,13 +259,13 @@ Y_UNIT_TEST_SUITE(TMessageBusTests) {
         {
         }
 
-        ~TSendTimeoutCheckerExampleClient() override { 
+        ~TSendTimeoutCheckerExampleClient() override {
             Session->Shutdown();
         }
 
         TSystemEvent ErrorHappened;
 
-        void OnError(TAutoPtr<TBusMessage>, EMessageStatus status) override { 
+        void OnError(TAutoPtr<TBusMessage>, EMessageStatus status) override {
             Y_VERIFY(status == MESSAGE_CONNECT_FAILED || status == MESSAGE_TIMEOUT, "got status: %s", ToString(status).data());
             ErrorHappened.Signal();
         }
@@ -326,7 +326,7 @@ Y_UNIT_TEST_SUITE(TMessageBusTests) {
             }
         }
 
-        void OnMessage(TOnMessageContext& mess) override { 
+        void OnMessage(TOnMessageContext& mess) override {
             Y_VERIFY(mess.IsConnectionAlive(), "connection should be alive here");
             TAutoPtr<TOnMessageContext> delayedMsg(new TOnMessageContext);
             delayedMsg->Swap(mess);
@@ -376,7 +376,7 @@ Y_UNIT_TEST_SUITE(TMessageBusTests) {
             return DelayedMessages.size();
         }
 
-        void OnError(TAutoPtr<TBusMessage> mess, EMessageStatus status) override { 
+        void OnError(TAutoPtr<TBusMessage> mess, EMessageStatus status) override {
             Y_UNUSED(mess);
             Y_VERIFY(status == MESSAGE_SHUTDOWN, "only shutdown allowed, got %s", ToString(status).data());
         }
@@ -418,7 +418,7 @@ Y_UNIT_TEST_SUITE(TMessageBusTests) {
             Session = TBusServerSession::Create(&Proto, this, sessionConfig, Bus);
         }
 
-        void OnMessage(TOnMessageContext& mess) override { 
+        void OnMessage(TOnMessageContext& mess) override {
             TBusIdentity ident;
             mess.AckMessage(ident);
 
@@ -430,7 +430,7 @@ Y_UNIT_TEST_SUITE(TMessageBusTests) {
             mess.GetSession()->SendReply(resurrected, new TExampleResponse(&Proto.ResponseCount));
         }
 
-        void OnError(TAutoPtr<TBusMessage> mess, EMessageStatus status) override { 
+        void OnError(TAutoPtr<TBusMessage> mess, EMessageStatus status) override {
             Y_UNUSED(mess);
             Y_VERIFY(status == MESSAGE_SHUTDOWN, "only shutdown allowed");
         }
@@ -488,7 +488,7 @@ Y_UNIT_TEST_SUITE(TMessageBusTests) {
             Session->Shutdown();
         }
 
-        void OnMessage(TOnMessageContext& mess) override { 
+        void OnMessage(TOnMessageContext& mess) override {
             TAutoPtr<TBusMessage> response;
 
             if (TestSync.Get() == 0) {
@@ -502,7 +502,7 @@ Y_UNIT_TEST_SUITE(TMessageBusTests) {
             mess.SendReplyMove(response);
         }
 
-        void OnError(TAutoPtr<TBusMessage>, EMessageStatus status) override { 
+        void OnError(TAutoPtr<TBusMessage>, EMessageStatus status) override {
             TestSync.WaitForAndIncrement(1);
 
             Y_VERIFY(status == MESSAGE_MESSAGE_TOO_LARGE, "status");
@@ -548,7 +548,7 @@ Y_UNIT_TEST_SUITE(TMessageBusTests) {
             Session->Shutdown();
         }
 
-        void OnMessage(TOnMessageContext& req) override { 
+        void OnMessage(TOnMessageContext& req) override {
             unsigned n = TestSync.Get();
             if (n < 2) {
                 TestSync.CheckAndIncrement(n);
@@ -695,7 +695,7 @@ Y_UNIT_TEST_SUITE(TMessageBusTests) {
             Session->Shutdown();
         }
 
-        void OnError(TAutoPtr<TBusMessage> mess, EMessageStatus status) override { 
+        void OnError(TAutoPtr<TBusMessage> mess, EMessageStatus status) override {
             TestSync.WaitForAndIncrement(0);
             Y_VERIFY(status == MESSAGE_CONNECT_FAILED || status == MESSAGE_TIMEOUT, "must be connection failed, got %s", ToString(status).data());
             mess.Destroy();
@@ -723,7 +723,7 @@ Y_UNIT_TEST_SUITE(TMessageBusTests) {
             Session->Shutdown();
         }
 
-        void OnError(TAutoPtr<TBusMessage> message, EMessageStatus status) override { 
+        void OnError(TAutoPtr<TBusMessage> message, EMessageStatus status) override {
             TestSync.CheckAndIncrement(0);
 
             Y_VERIFY(status == MESSAGE_CONNECT_FAILED, "must be MESSAGE_CONNECT_FAILED, got %s", ToString(status).data());
@@ -777,7 +777,7 @@ Y_UNIT_TEST_SUITE(TMessageBusTests) {
             Session->Shutdown();
         }
 
-        void OnMessageSentOneWay(TAutoPtr<TBusMessage> sent) override { 
+        void OnMessageSentOneWay(TAutoPtr<TBusMessage> sent) override {
             TestSync.WaitForAndIncrement(0);
             sent->Reset();
             TestSync.CheckAndIncrement(1);
@@ -889,7 +889,7 @@ Y_UNIT_TEST_SUITE(TMessageBusTests) {
             Session->Shutdown();
         }
 
-        void OnClientConnectionEvent(const TClientConnectionEvent& event) override { 
+        void OnClientConnectionEvent(const TClientConnectionEvent& event) override {
             if (Sync.Get() > 2) {
                 // Test OnClientConnectionEvent_Disconnect is broken.
                 // Sometimes reconnect happens during server shutdown
@@ -905,11 +905,11 @@ Y_UNIT_TEST_SUITE(TMessageBusTests) {
             }
         }
 
-        void OnError(TAutoPtr<TBusMessage>, EMessageStatus) override { 
+        void OnError(TAutoPtr<TBusMessage>, EMessageStatus) override {
             // We do not check for message errors in this test.
         }
 
-        void OnMessageSentOneWay(TAutoPtr<TBusMessage>) override { 
+        void OnMessageSentOneWay(TAutoPtr<TBusMessage>) override {
         }
     };
 
@@ -923,7 +923,7 @@ Y_UNIT_TEST_SUITE(TMessageBusTests) {
             Session->Shutdown();
         }
 
-        void OnError(TAutoPtr<TBusMessage>, EMessageStatus) override { 
+        void OnError(TAutoPtr<TBusMessage>, EMessageStatus) override {
             // We do not check for server message errors in this test.
         }
     };
@@ -988,7 +988,7 @@ Y_UNIT_TEST_SUITE(TMessageBusTests) {
             Session->Shutdown();
         }
 
-        void OnMessage(TOnMessageContext& req) override { 
+        void OnMessage(TOnMessageContext& req) override {
             if (!GoOn.Wait(0)) {
                 TGuard<TMutex> guard(OneLock);
 
diff --git a/library/cpp/messagebus/test/ut/module_client_one_way_ut.cpp b/library/cpp/messagebus/test/ut/module_client_one_way_ut.cpp
index 8cbef0b4a5..4083cf3b7b 100644
--- a/library/cpp/messagebus/test/ut/module_client_one_way_ut.cpp
+++ b/library/cpp/messagebus/test/ut/module_client_one_way_ut.cpp
@@ -25,7 +25,7 @@ Y_UNIT_TEST_SUITE(ModuleClientOneWay) {
             ServerSession = TBusServerSession::Create(&Proto, this, TBusServerSessionConfig(), Queue);
         }
 
-        void OnMessage(TOnMessageContext& context) override { 
+        void OnMessage(TOnMessageContext& context) override {
             TestSync->WaitForAndIncrement(1);
             context.ForgetRequest();
         }
@@ -46,7 +46,7 @@ Y_UNIT_TEST_SUITE(ModuleClientOneWay) {
         {
         }
 
-        TJobHandler Start(TBusJob* job, TBusMessage*) override { 
+        TJobHandler Start(TBusJob* job, TBusMessage*) override {
             TestSync->WaitForAndIncrement(0);
 
             job->SendOneWayTo(new TExampleRequest(&Proto.RequestCount), ClientSession.Get(), TNetAddr("localhost", Port));
@@ -57,12 +57,12 @@ Y_UNIT_TEST_SUITE(ModuleClientOneWay) {
         TJobHandler Sent(TBusJob* job, TBusMessage*) {
             TestSync->WaitForAndIncrement(2);
             job->Cancel(MESSAGE_DONT_ASK);
-            return nullptr; 
+            return nullptr;
         }
 
-        TBusServerSessionPtr CreateExtSession(TBusMessageQueue& queue) override { 
+        TBusServerSessionPtr CreateExtSession(TBusMessageQueue& queue) override {
             ClientSession = CreateDefaultSource(queue, &Proto, TBusServerSessionConfig());
-            return nullptr; 
+            return nullptr;
         }
     };
 
@@ -97,7 +97,7 @@ Y_UNIT_TEST_SUITE(ModuleClientOneWay) {
         {
         }
 
-        TJobHandler Start(TBusJob* job, TBusMessage*) override { 
+        TJobHandler Start(TBusJob* job, TBusMessage*) override {
             TestSync->WaitForAndIncrement(0);
 
             job->SendOneWayTo(new TExampleRequest(&Proto.RequestCount), ClientSession.Get(), TNetAddr("localhost", 1));
@@ -108,17 +108,17 @@ Y_UNIT_TEST_SUITE(ModuleClientOneWay) {
         TJobHandler Sent(TBusJob* job, TBusMessage*) {
             TestSync->WaitForAndIncrement(1);
             job->Cancel(MESSAGE_DONT_ASK);
-            return nullptr; 
+            return nullptr;
         }
 
-        TBusServerSessionPtr CreateExtSession(TBusMessageQueue& queue) override { 
+        TBusServerSessionPtr CreateExtSession(TBusMessageQueue& queue) override {
             TBusServerSessionConfig sessionConfig;
             sessionConfig.ConnectTimeout = 1;
             sessionConfig.SendTimeout = 1;
             sessionConfig.TotalTimeout = 1;
             sessionConfig.Secret.TimeoutPeriod = TDuration::MilliSeconds(1);
             ClientSession = CreateDefaultSource(queue, &Proto, sessionConfig);
-            return nullptr; 
+            return nullptr;
         }
     };
 
diff --git a/library/cpp/messagebus/test/ut/module_client_ut.cpp b/library/cpp/messagebus/test/ut/module_client_ut.cpp
index ef446dd7e2..ebfe185cc6 100644
--- a/library/cpp/messagebus/test/ut/module_client_ut.cpp
+++ b/library/cpp/messagebus/test/ut/module_client_ut.cpp
@@ -111,7 +111,7 @@ Y_UNIT_TEST_SUITE(BusJobTest) {
         {
         }
 
-        TJobHandler Start(TBusJob* job, TBusMessage* mess) override { 
+        TJobHandler Start(TBusJob* job, TBusMessage* mess) override {
             Y_UNUSED(mess);
             job->Send(new TExampleRequest(&Proto.RequestCount), Source, TReplyHandler(&TParallelOnReplyModule::ReplyHandler), 0, ServerAddr);
             return &TParallelOnReplyModule::HandleReplies;
@@ -128,7 +128,7 @@ Y_UNIT_TEST_SUITE(BusJobTest) {
             RepliesLatch.CountDown();
             Y_VERIFY(RepliesLatch.Await(TDuration::Seconds(10)), "failed to get answers");
             job->Cancel(MESSAGE_UNKNOWN);
-            return nullptr; 
+            return nullptr;
         }
     };
 
@@ -169,7 +169,7 @@ Y_UNIT_TEST_SUITE(BusJobTest) {
         {
         }
 
-        TJobHandler Start(TBusJob* job, TBusMessage* mess) override { 
+        TJobHandler Start(TBusJob* job, TBusMessage* mess) override {
             Y_UNUSED(mess);
             TExampleRequest* message = new TExampleRequest(&Proto.RequestCount);
             job->Send(message, Source, TReplyHandler(&TErrorHandlerCheckerModule::ReplyHandler), 0, ServerAddr);
@@ -188,16 +188,16 @@ Y_UNIT_TEST_SUITE(BusJobTest) {
             Y_UNUSED(mess);
             job->Cancel(MESSAGE_UNKNOWN);
             GotReplyLatch.CountDown();
-            return nullptr; 
+            return nullptr;
         }
 
-        TBusServerSessionPtr CreateExtSession(TBusMessageQueue& queue) override { 
+        TBusServerSessionPtr CreateExtSession(TBusMessageQueue& queue) override {
             TBusClientSessionConfig sessionConfig;
             sessionConfig.SendTimeout = 1; // TODO: allow 0
             sessionConfig.Secret.TimeoutPeriod = TDuration::MilliSeconds(10);
             Source = CreateDefaultSource(queue, &Proto, sessionConfig);
             Source->RegisterService("localhost");
-            return nullptr; 
+            return nullptr;
         }
     };
 
@@ -239,7 +239,7 @@ Y_UNIT_TEST_SUITE(BusJobTest) {
             ServerSession = TBusServerSession::Create(&Proto, this, sessionConfig, Bus);
         }
 
-        void OnMessage(TOnMessageContext& req) override { 
+        void OnMessage(TOnMessageContext& req) override {
             if (AtomicIncrement(OnMessageCount) == 1) {
                 TestSync->WaitForAndIncrement(0);
             }
@@ -258,12 +258,12 @@ Y_UNIT_TEST_SUITE(BusJobTest) {
         TModuleThatSendsReplyEarly(TTestSync* testSync, unsigned serverPort)
             : TestSync(testSync)
             , ServerPort(serverPort)
-            , ServerSession(nullptr) 
+            , ServerSession(nullptr)
             , ReplyCount(0)
         {
         }
 
-        TJobHandler Start(TBusJob* job, TBusMessage* mess) override { 
+        TJobHandler Start(TBusJob* job, TBusMessage* mess) override {
             Y_UNUSED(mess);
             for (unsigned i = 0; i < 2; ++i) {
                 job->Send(
@@ -291,10 +291,10 @@ Y_UNIT_TEST_SUITE(BusJobTest) {
         TJobHandler HandleReplies(TBusJob* job, TBusMessage* mess) {
             Y_UNUSED(mess);
             job->Cancel(MESSAGE_UNKNOWN);
-            return nullptr; 
+            return nullptr;
         }
 
-        TBusServerSessionPtr CreateExtSession(TBusMessageQueue& queue) override { 
+        TBusServerSessionPtr CreateExtSession(TBusMessageQueue& queue) override {
             TExampleClientModule::CreateExtSession(queue);
             TBusServerSessionConfig sessionConfig;
             return ServerSession = CreateDefaultDestination(queue, &Proto, sessionConfig);
@@ -328,7 +328,7 @@ Y_UNIT_TEST_SUITE(BusJobTest) {
         {
         }
 
-        TJobHandler Start(TBusJob* job, TBusMessage*) override { 
+        TJobHandler Start(TBusJob* job, TBusMessage*) override {
             TestSync.CheckAndIncrement(0);
 
             job->Send(new TExampleRequest(&Proto.RequestCount), Source,
@@ -345,7 +345,7 @@ Y_UNIT_TEST_SUITE(BusJobTest) {
         TJobHandler End(TBusJob* job, TBusMessage*) {
             TestSync.CheckAndIncrement(2);
             job->Cancel(MESSAGE_SHUTDOWN);
-            return nullptr; 
+            return nullptr;
         }
     };
 
diff --git a/library/cpp/messagebus/test/ut/module_server_ut.cpp b/library/cpp/messagebus/test/ut/module_server_ut.cpp
index b96479af71..88fe1dd9b6 100644
--- a/library/cpp/messagebus/test/ut/module_server_ut.cpp
+++ b/library/cpp/messagebus/test/ut/module_server_ut.cpp
@@ -47,14 +47,14 @@ Y_UNIT_TEST_SUITE(ModuleServerTests) {
         {
         }
 
-        TJobHandler Start(TBusJob* job, TBusMessage* mess) override { 
+        TJobHandler Start(TBusJob* job, TBusMessage* mess) override {
             WaitTwoRequestsLatch.CountDown();
             Y_VERIFY(WaitTwoRequestsLatch.Await(TDuration::Seconds(5)), "oops");
 
             VerifyDynamicCast<TExampleRequest*>(mess);
 
             job->SendReply(new TExampleResponse(&Proto.ResponseCount));
-            return nullptr; 
+            return nullptr;
         }
     };
 
@@ -78,7 +78,7 @@ Y_UNIT_TEST_SUITE(ModuleServerTests) {
         TSystemEvent MessageReceivedEvent;
         TSystemEvent ClientDiedEvent;
 
-        TJobHandler Start(TBusJob* job, TBusMessage* mess) override { 
+        TJobHandler Start(TBusJob* job, TBusMessage* mess) override {
             Y_UNUSED(mess);
 
             MessageReceivedEvent.Signal();
@@ -86,7 +86,7 @@ Y_UNIT_TEST_SUITE(ModuleServerTests) {
             Y_VERIFY(ClientDiedEvent.WaitT(TDuration::Seconds(5)), "oops");
 
             job->SendReply(new TExampleResponse(&Proto.ResponseCount));
-            return nullptr; 
+            return nullptr;
         }
     };
 
diff --git a/library/cpp/messagebus/test/ut/one_way_ut.cpp b/library/cpp/messagebus/test/ut/one_way_ut.cpp
index 057c0de406..9c21227e2b 100644
--- a/library/cpp/messagebus/test/ut/one_way_ut.cpp
+++ b/library/cpp/messagebus/test/ut/one_way_ut.cpp
@@ -79,7 +79,7 @@ struct NullClient : TBusClientHandlerError {
         }
     }
 
-    void OnMessageSentOneWay(TAutoPtr<TBusMessage>) override { 
+    void OnMessageSentOneWay(TAutoPtr<TBusMessage>) override {
     }
 };
 
@@ -111,7 +111,7 @@ public:
     }
 
     /// when message comes do not send reply, just acknowledge
-    void OnMessage(TOnMessageContext& mess) override { 
+    void OnMessage(TOnMessageContext& mess) override {
         TExampleRequest* fmess = static_cast<TExampleRequest*>(mess.GetMessage());
 
         Y_ASSERT(fmess->Data == "TADA");
@@ -123,7 +123,7 @@ public:
     }
 
     /// this handler should not be called because this server does not send replies
-    void OnSent(TAutoPtr<TBusMessage> mess) override { 
+    void OnSent(TAutoPtr<TBusMessage> mess) override {
         Y_UNUSED(mess);
         Y_FAIL("This server does not sent replies");
     }
@@ -161,11 +161,11 @@ Y_UNIT_TEST_SUITE(TMessageBusTests_OneWay) {
         {
         }
 
-        ~TMessageTooLargeClient() override { 
+        ~TMessageTooLargeClient() override {
             Session->Shutdown();
         }
 
-        void OnError(TAutoPtr<TBusMessage> mess, EMessageStatus status) override { 
+        void OnError(TAutoPtr<TBusMessage> mess, EMessageStatus status) override {
             Y_UNUSED(mess);
 
             Y_VERIFY(status == MESSAGE_MESSAGE_TOO_LARGE, "wrong status: %s", ToCString(status));
@@ -188,7 +188,7 @@ Y_UNIT_TEST_SUITE(TMessageBusTests_OneWay) {
     }
 
     struct TCheckTimeoutClient: public NullClient {
-        ~TCheckTimeoutClient() override { 
+        ~TCheckTimeoutClient() override {
             Session->Shutdown();
         }
 
@@ -208,7 +208,7 @@ Y_UNIT_TEST_SUITE(TMessageBusTests_OneWay) {
         TSystemEvent GotError;
 
         /// message that could not be delivered
-        void OnError(TAutoPtr<TBusMessage> mess, EMessageStatus status) override { 
+        void OnError(TAutoPtr<TBusMessage> mess, EMessageStatus status) override {
             Y_UNUSED(mess);
             Y_UNUSED(status); // TODO: check status
 
diff --git a/library/cpp/messagebus/test/ut/starter_ut.cpp b/library/cpp/messagebus/test/ut/starter_ut.cpp
index c738b16eb5..dd4d3aaa5e 100644
--- a/library/cpp/messagebus/test/ut/starter_ut.cpp
+++ b/library/cpp/messagebus/test/ut/starter_ut.cpp
@@ -18,7 +18,7 @@ Y_UNIT_TEST_SUITE(TBusStarterTest) {
         {
         }
 
-        TJobHandler Start(TBusJob* job, TBusMessage* mess) override { 
+        TJobHandler Start(TBusJob* job, TBusMessage* mess) override {
             Y_UNUSED(mess);
             AtomicIncrement(StartCount);
             job->Sleep(10);
@@ -29,7 +29,7 @@ Y_UNIT_TEST_SUITE(TBusStarterTest) {
             Y_UNUSED(mess);
             AtomicIncrement(StartCount);
             job->Cancel(MESSAGE_UNKNOWN);
-            return nullptr; 
+            return nullptr;
         }
     };
 
@@ -78,7 +78,7 @@ Y_UNIT_TEST_SUITE(TBusStarterTest) {
     struct TSleepModule: public TExampleServerModule {
         TSystemEvent MessageReceivedEvent;
 
-        TJobHandler Start(TBusJob* job, TBusMessage* mess) override { 
+        TJobHandler Start(TBusJob* job, TBusMessage* mess) override {
             Y_UNUSED(mess);
 
             MessageReceivedEvent.Signal();
@@ -113,14 +113,14 @@ Y_UNIT_TEST_SUITE(TBusStarterTest) {
     struct TSendReplyModule: public TExampleServerModule {
         TSystemEvent MessageReceivedEvent;
 
-        TJobHandler Start(TBusJob* job, TBusMessage* mess) override { 
+        TJobHandler Start(TBusJob* job, TBusMessage* mess) override {
             Y_UNUSED(mess);
 
             job->SendReply(new TExampleResponse(&Proto.ResponseCount));
 
             MessageReceivedEvent.Signal();
 
-            return nullptr; 
+            return nullptr;
         }
     };