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

19 files changed, 63 insertions, 63 deletions

diff --git a/library/cpp/messagebus/rain_check/core/coro.h b/library/cpp/messagebus/rain_check/core/coro.h
index 95e2a30f9b6..5d77e8b55bb 100644
--- a/library/cpp/messagebus/rain_check/core/coro.h
+++ b/library/cpp/messagebus/rain_check/core/coro.h
@@ -22,14 +22,14 @@ namespace NRainCheck {
 
     public:
         TCoroTaskRunner(IEnv* env, ISubtaskListener* parent, TAutoPtr<ICoroTask> impl);
-        ~TCoroTaskRunner() override;
+        ~TCoroTaskRunner() override; 
 
     private:
         static TContClosure ContClosure(TCoroTaskRunner* runner, TArrayRef<char> memRegion);
 
-        bool ReplyReceived() override /* override */;
+        bool ReplyReceived() override /* override */; 
 
-        void DoRun() override /* override */;
+        void DoRun() override /* override */; 
 
         ICoroTask* GetImpl() {
             return (ICoroTask*)GetImplBase();
diff --git a/library/cpp/messagebus/rain_check/core/coro_ut.cpp b/library/cpp/messagebus/rain_check/core/coro_ut.cpp
index 61a33584a5f..b0a9d47fbf3 100644
--- a/library/cpp/messagebus/rain_check/core/coro_ut.cpp
+++ b/library/cpp/messagebus/rain_check/core/coro_ut.cpp
@@ -16,7 +16,7 @@ Y_UNIT_TEST_SUITE(RainCheckCoro) {
         {
         }
 
-        void Run() override {
+        void Run() override { 
             TestSync->WaitForAndIncrement(0);
         }
     };
@@ -42,7 +42,7 @@ Y_UNIT_TEST_SUITE(RainCheckCoro) {
 
         TSubtaskCompletion SleepCompletion;
 
-        void Run() override {
+        void Run() override { 
             Env->SleepService.Sleep(&SleepCompletion, TDuration::MilliSeconds(1));
             WaitForSubtasks();
             TestSync->WaitForAndIncrement(0);
@@ -69,7 +69,7 @@ Y_UNIT_TEST_SUITE(RainCheckCoro) {
         {
         }
 
-        void Run() override {
+        void Run() override { 
             TestSync->CheckAndIncrement(1);
         }
     };
@@ -86,7 +86,7 @@ Y_UNIT_TEST_SUITE(RainCheckCoro) {
 
         TSubtaskCompletion SubtaskCompletion;
 
-        void Run() override {
+        void Run() override { 
             TestSync->CheckAndIncrement(0);
             SpawnSubtask<TSubtask>(Env, &SubtaskCompletion, TestSync);
             WaitForSubtasks();
diff --git a/library/cpp/messagebus/rain_check/core/simple.h b/library/cpp/messagebus/rain_check/core/simple.h
index 20e1bf19f56..06890b84431 100644
--- a/library/cpp/messagebus/rain_check/core/simple.h
+++ b/library/cpp/messagebus/rain_check/core/simple.h
@@ -14,12 +14,12 @@ namespace NRainCheck {
 
     public:
         TContinueFunc()
-            : Func(nullptr)
+            : Func(nullptr) 
         {
         }
 
         TContinueFunc(void*)
-            : Func(nullptr)
+            : Func(nullptr) 
         {
         }
 
@@ -38,13 +38,13 @@ namespace NRainCheck {
     class TSimpleTaskRunner: public TTaskRunnerBase {
     public:
         TSimpleTaskRunner(IEnv* env, ISubtaskListener* parentTask, TAutoPtr<ISimpleTask>);
-        ~TSimpleTaskRunner() override;
+        ~TSimpleTaskRunner() override; 
 
     private:
         // Function to be called on completion of all pending tasks.
         TContinueFunc ContinueFunc;
 
-        bool ReplyReceived() override /* override */;
+        bool ReplyReceived() override /* override */; 
 
         ISimpleTask* GetImpl() {
             return (ISimpleTask*)GetImplBase();
diff --git a/library/cpp/messagebus/rain_check/core/simple_ut.cpp b/library/cpp/messagebus/rain_check/core/simple_ut.cpp
index d4545e05aa1..98b4b9bd52f 100644
--- a/library/cpp/messagebus/rain_check/core/simple_ut.cpp
+++ b/library/cpp/messagebus/rain_check/core/simple_ut.cpp
@@ -21,7 +21,7 @@ Y_UNIT_TEST_SUITE(RainCheckSimple) {
 
         TSubtaskCompletion SleepCompletion;
 
-        TContinueFunc Start() override {
+        TContinueFunc Start() override { 
             TestSync->CheckAndIncrement(0);
 
             Env->SleepService.Sleep(&SleepCompletion, TDuration::MilliSeconds(1));
@@ -44,7 +44,7 @@ Y_UNIT_TEST_SUITE(RainCheckSimple) {
 
         TContinueFunc Last() {
             TestSync->CheckAndIncrement(3);
-            return nullptr;
+            return nullptr; 
         }
     };
 
diff --git a/library/cpp/messagebus/rain_check/core/sleep.cpp b/library/cpp/messagebus/rain_check/core/sleep.cpp
index f5d0b4cac9c..ae38d8017c6 100644
--- a/library/cpp/messagebus/rain_check/core/sleep.cpp
+++ b/library/cpp/messagebus/rain_check/core/sleep.cpp
@@ -34,7 +34,7 @@ namespace {
         {
         }
 
-        void Do() override {
+        void Do() override { 
             Parent->SetDone();
         }
     };
diff --git a/library/cpp/messagebus/rain_check/core/sleep_ut.cpp b/library/cpp/messagebus/rain_check/core/sleep_ut.cpp
index 2ae85a87b18..da00dee1536 100644
--- a/library/cpp/messagebus/rain_check/core/sleep_ut.cpp
+++ b/library/cpp/messagebus/rain_check/core/sleep_ut.cpp
@@ -20,7 +20,7 @@ Y_UNIT_TEST_SUITE(Sleep) {
 
         TSubtaskCompletion Sleep;
 
-        TContinueFunc Start() override {
+        TContinueFunc Start() override { 
             Env->SleepService.Sleep(&Sleep, TDuration::MilliSeconds(1));
 
             TestSync->CheckAndIncrement(0);
@@ -30,7 +30,7 @@ Y_UNIT_TEST_SUITE(Sleep) {
 
         TContinueFunc Continue() {
             TestSync->CheckAndIncrement(1);
-            return nullptr;
+            return nullptr; 
         }
     };
 
diff --git a/library/cpp/messagebus/rain_check/core/spawn_ut.cpp b/library/cpp/messagebus/rain_check/core/spawn_ut.cpp
index ba5a5e41cf6..acfa11ded97 100644
--- a/library/cpp/messagebus/rain_check/core/spawn_ut.cpp
+++ b/library/cpp/messagebus/rain_check/core/spawn_ut.cpp
@@ -26,7 +26,7 @@ Y_UNIT_TEST_SUITE(Spawn) {
 
         unsigned I;
 
-        TContinueFunc Start() override {
+        TContinueFunc Start() override { 
             if (I < 4) {
                 I += 1;
                 return &TTestTask::Start;
@@ -39,7 +39,7 @@ Y_UNIT_TEST_SUITE(Spawn) {
             TestSync->CheckAndIncrement(1);
 
             Started.Signal();
-            return nullptr;
+            return nullptr; 
         }
     };
 
@@ -63,10 +63,10 @@ Y_UNIT_TEST_SUITE(Spawn) {
         {
         }
 
-        TContinueFunc Start() override {
+        TContinueFunc Start() override { 
             Sleep(TDuration::MilliSeconds(1));
             TestSync->CheckAndIncrement(1);
-            return nullptr;
+            return nullptr; 
         }
     };
 
@@ -82,7 +82,7 @@ Y_UNIT_TEST_SUITE(Spawn) {
 
         TSubtaskCompletion SubtaskCompletion;
 
-        TContinueFunc Start() override {
+        TContinueFunc Start() override { 
             TestSync->CheckAndIncrement(0);
             SpawnSubtask<TSubtask>(Env, &SubtaskCompletion, TestSync);
             return &TSpawnTask::Continue;
@@ -90,7 +90,7 @@ Y_UNIT_TEST_SUITE(Spawn) {
 
         TContinueFunc Continue() {
             TestSync->CheckAndIncrement(2);
-            return nullptr;
+            return nullptr; 
         }
     };
 
@@ -118,10 +118,10 @@ Y_UNIT_TEST_SUITE(Spawn) {
 
         std::array<TSubtaskCompletion, 3> Subtasks;
 
-        TContinueFunc Start() override {
+        TContinueFunc Start() override { 
             if (I == 1000) {
                 TestSync->CheckAndIncrement(0);
-                return nullptr;
+                return nullptr; 
             }
 
             for (auto& subtask : Subtasks) {
diff --git a/library/cpp/messagebus/rain_check/core/task.cpp b/library/cpp/messagebus/rain_check/core/task.cpp
index a098437d534..0cd209f44f4 100644
--- a/library/cpp/messagebus/rain_check/core/task.cpp
+++ b/library/cpp/messagebus/rain_check/core/task.cpp
@@ -153,7 +153,7 @@ void TSubtaskCompletion::SetRunning(TTaskRunnerBase* parent) {
 void TSubtaskCompletion::SetDone() {
     Y_ASSERT(!!TaskRunner);
     TTaskRunnerBase* temp = TaskRunner;
-    TaskRunner = nullptr;
+    TaskRunner = nullptr; 
 
     for (;;) {
         ESubtaskState state = State.Get();
@@ -212,5 +212,5 @@ TString TTaskRunnerBase::GetStatusSingleLine() {
 }
 
 bool NRainCheck::AreWeInsideTask() {
-    return ThreadCurrentTask != nullptr;
+    return ThreadCurrentTask != nullptr; 
 }
diff --git a/library/cpp/messagebus/rain_check/core/task.h b/library/cpp/messagebus/rain_check/core/task.h
index 7d8778bcda5..5da3136b23f 100644
--- a/library/cpp/messagebus/rain_check/core/task.h
+++ b/library/cpp/messagebus/rain_check/core/task.h
@@ -19,7 +19,7 @@ namespace NRainCheck {
     };
 
     struct TNopSubtaskListener: public ISubtaskListener {
-        void SetDone() override;
+        void SetDone() override; 
 
         static TNopSubtaskListener Instance;
     };
@@ -32,12 +32,12 @@ namespace NRainCheck {
 
     public:
         TSubtaskCompletionFunc()
-            : Func(nullptr)
+            : Func(nullptr) 
         {
         }
 
         TSubtaskCompletionFunc(void*)
-            : Func(nullptr)
+            : Func(nullptr) 
         {
         }
 
@@ -84,7 +84,7 @@ namespace NRainCheck {
             , TaskRunner()
         {
         }
-        ~TSubtaskCompletion() override;
+        ~TSubtaskCompletion() override; 
 
         // Either done or cancel requested or cancelled
         bool IsComplete() const {
@@ -124,7 +124,7 @@ namespace NRainCheck {
         // called by service provider implementations
         // must not be called by actor
         void SetRunning(TTaskRunnerBase* parent);
-        void SetDone() override;
+        void SetDone() override; 
     };
 
     // See ISimpleTask, ICoroTask
@@ -151,7 +151,7 @@ namespace NRainCheck {
     public:
         // Construct task. Task is not automatically started.
         TTaskRunnerBase(IEnv*, ISubtaskListener* parent, TAutoPtr<ITaskBase> impl);
-        ~TTaskRunnerBase() override;
+        ~TTaskRunnerBase() override; 
 
         bool IsRunningInThisThread() const;
         void AssertInThisThread() const;
diff --git a/library/cpp/messagebus/rain_check/core/track.h b/library/cpp/messagebus/rain_check/core/track.h
index d387de75742..90993c128f4 100644
--- a/library/cpp/messagebus/rain_check/core/track.h
+++ b/library/cpp/messagebus/rain_check/core/track.h
@@ -29,7 +29,7 @@ namespace NRainCheck {
             {
             }
 
-            void SetDone() override;
+            void SetDone() override; 
 
             TString GetStatusSingleLine();
         };
@@ -61,7 +61,7 @@ namespace NRainCheck {
 
     public:
         TTaskTracker(NActor::TExecutor* executor);
-        ~TTaskTracker() override;
+        ~TTaskTracker() override; 
 
         void Shutdown();
 
@@ -83,7 +83,7 @@ namespace NRainCheck {
                 {
                 }
 
-                TIntrusivePtr<TTaskRunnerBase> NewTask(ISubtaskListener* subtaskListener) override {
+                TIntrusivePtr<TTaskRunnerBase> NewTask(ISubtaskListener* subtaskListener) override { 
                     return NRainCheck::SpawnTask<TTask>(Env, Param, subtaskListener).Get();
                 }
             };
diff --git a/library/cpp/messagebus/rain_check/core/track_ut.cpp b/library/cpp/messagebus/rain_check/core/track_ut.cpp
index 05f7de13195..86f6f604167 100644
--- a/library/cpp/messagebus/rain_check/core/track_ut.cpp
+++ b/library/cpp/messagebus/rain_check/core/track_ut.cpp
@@ -16,10 +16,10 @@ Y_UNIT_TEST_SUITE(TaskTracker) {
         {
         }
 
-        TContinueFunc Start() override {
+        TContinueFunc Start() override { 
             TestSync->WaitForAndIncrement(0);
             TestSync->WaitForAndIncrement(2);
-            return nullptr;
+            return nullptr; 
         }
     };
 
diff --git a/library/cpp/messagebus/rain_check/messagebus/messagebus_client.cpp b/library/cpp/messagebus/rain_check/messagebus/messagebus_client.cpp
index daac8d9a993..bd7d7cb13a0 100644
--- a/library/cpp/messagebus/rain_check/messagebus/messagebus_client.cpp
+++ b/library/cpp/messagebus/rain_check/messagebus/messagebus_client.cpp
@@ -37,7 +37,7 @@ void TBusClientService::ProcessResultCommon(NBus::TBusMessageAutoPtr message,
         return;
     }
 
-    future->SetDoneAndSchedule(status, nullptr);
+    future->SetDoneAndSchedule(status, nullptr); 
 }
 
 void TBusClientService::SendOneWay(
@@ -76,19 +76,19 @@ void NRainCheck::TBusClientService::OnMessageSentOneWay(
     TBusFuture* future = (TBusFuture*)request->Data;
     Y_ASSERT(future->Request.Get() == request.Get());
     Y_UNUSED(request.Release());
-    future->SetDoneAndSchedule(MESSAGE_OK, nullptr);
+    future->SetDoneAndSchedule(MESSAGE_OK, nullptr); 
 }
 
 void TBusClientService::OnError(
     TAutoPtr<TBusMessage> message, NBus::EMessageStatus status) {
-    if (message->Data == nullptr) {
+    if (message->Data == nullptr) { 
         return;
     }
 
     TBusFuture* future = (TBusFuture*)message->Data;
     Y_ASSERT(future->Request.Get() == message.Get());
     Y_UNUSED(message.Release());
-    future->SetDoneAndSchedule(status, nullptr);
+    future->SetDoneAndSchedule(status, nullptr); 
 }
 
 void TBusFuture::SetDoneAndSchedule(EMessageStatus status, TAutoPtr<TBusMessage> response) {
diff --git a/library/cpp/messagebus/rain_check/messagebus/messagebus_client.h b/library/cpp/messagebus/rain_check/messagebus/messagebus_client.h
index 0a291cdea69..251eae57387 100644
--- a/library/cpp/messagebus/rain_check/messagebus/messagebus_client.h
+++ b/library/cpp/messagebus/rain_check/messagebus/messagebus_client.h
@@ -47,7 +47,7 @@ namespace NRainCheck {
 
     public:
         TBusClientService(const NBus::TBusSessionConfig&, NBus::TBusProtocol*, NBus::TBusMessageQueue*);
-        ~TBusClientService() override;
+        ~TBusClientService() override; 
 
         void Send(NBus::TBusMessageAutoPtr, const NBus::TNetAddr&, TBusFuture* future);
         void SendOneWay(NBus::TBusMessageAutoPtr, const NBus::TNetAddr&, TBusFuture* future);
@@ -59,9 +59,9 @@ namespace NRainCheck {
         void SendCommon(NBus::TBusMessage*, const NBus::TNetAddr&, TBusFuture* future);
         void ProcessResultCommon(NBus::TBusMessageAutoPtr, const NBus::TNetAddr&, TBusFuture* future, NBus::EMessageStatus);
 
-        void OnReply(TAutoPtr<NBus::TBusMessage> pMessage, TAutoPtr<NBus::TBusMessage> pReply) override;
-        void OnError(TAutoPtr<NBus::TBusMessage> pMessage, NBus::EMessageStatus status) override;
-        void OnMessageSentOneWay(TAutoPtr<NBus::TBusMessage>) override;
+        void OnReply(TAutoPtr<NBus::TBusMessage> pMessage, TAutoPtr<NBus::TBusMessage> pReply) override; 
+        void OnError(TAutoPtr<NBus::TBusMessage> pMessage, NBus::EMessageStatus status) override; 
+        void OnMessageSentOneWay(TAutoPtr<NBus::TBusMessage>) override; 
     };
 
 }
diff --git a/library/cpp/messagebus/rain_check/messagebus/messagebus_client_ut.cpp b/library/cpp/messagebus/rain_check/messagebus/messagebus_client_ut.cpp
index 1b3618558b8..f65e8b382c5 100644
--- a/library/cpp/messagebus/rain_check/messagebus/messagebus_client_ut.cpp
+++ b/library/cpp/messagebus/rain_check/messagebus/messagebus_client_ut.cpp
@@ -46,7 +46,7 @@ Y_UNIT_TEST_SUITE(RainCheckMessageBusClient) {
 
         TVector<TSimpleSharedPtr<TBusFuture>> Requests;
 
-        TContinueFunc Start() override {
+        TContinueFunc Start() override { 
             for (unsigned i = 0; i < 3; ++i) {
                 Requests.push_back(new TBusFuture);
                 TNetAddr addr("localhost", ServerPort);
@@ -62,7 +62,7 @@ Y_UNIT_TEST_SUITE(RainCheckMessageBusClient) {
                 VerifyDynamicCast<TExampleResponse*>(Requests[i]->GetResponse());
             }
             Env->TestSync.CheckAndIncrement(0);
-            return nullptr;
+            return nullptr; 
         }
     };
 
@@ -91,7 +91,7 @@ Y_UNIT_TEST_SUITE(RainCheckMessageBusClient) {
             Session = Queue->CreateDestination(&Proto, this, NBus::TBusSessionConfig());
         }
 
-        void OnMessage(NBus::TOnMessageContext& context) override {
+        void OnMessage(NBus::TOnMessageContext& context) override { 
             TestSync->CheckAndIncrement(1);
             context.ForgetRequest();
         }
@@ -110,7 +110,7 @@ Y_UNIT_TEST_SUITE(RainCheckMessageBusClient) {
 
         TVector<TSimpleSharedPtr<TBusFuture>> Requests;
 
-        TContinueFunc Start() override {
+        TContinueFunc Start() override { 
             Env->TestSync.CheckAndIncrement(0);
 
             for (unsigned i = 0; i < 1; ++i) {
@@ -128,7 +128,7 @@ Y_UNIT_TEST_SUITE(RainCheckMessageBusClient) {
                 Y_VERIFY(!Requests[i]->GetResponse());
             }
             Env->TestSync.WaitForAndIncrement(2);
-            return nullptr;
+            return nullptr; 
         }
     };
 
diff --git a/library/cpp/messagebus/rain_check/messagebus/messagebus_server.h b/library/cpp/messagebus/rain_check/messagebus/messagebus_server.h
index 1334f05fe46..ec7a883d32d 100644
--- a/library/cpp/messagebus/rain_check/messagebus/messagebus_server.h
+++ b/library/cpp/messagebus/rain_check/messagebus/messagebus_server.h
@@ -18,11 +18,11 @@ namespace NRainCheck {
 
         THolder<ITaskFactory> TaskFactory;
 
-        void OnMessage(NBus::TOnMessageContext&) override;
+        void OnMessage(NBus::TOnMessageContext&) override; 
 
     public:
         TBusTaskStarter(TAutoPtr<ITaskFactory>);
-        ~TBusTaskStarter() override;
+        ~TBusTaskStarter() override; 
 
     public:
         template <typename TTask, typename TEnv>
@@ -35,7 +35,7 @@ namespace NRainCheck {
                 {
                 }
 
-                void NewTask(NBus::TOnMessageContext& context) override {
+                void NewTask(NBus::TOnMessageContext& context) override { 
                     SpawnTask<TTask, TEnv, NBus::TOnMessageContext&>(Env, context);
                 }
             };
diff --git a/library/cpp/messagebus/rain_check/messagebus/messagebus_server_ut.cpp b/library/cpp/messagebus/rain_check/messagebus/messagebus_server_ut.cpp
index 7c11399f1be..32c131798b8 100644
--- a/library/cpp/messagebus/rain_check/messagebus/messagebus_server_ut.cpp
+++ b/library/cpp/messagebus/rain_check/messagebus/messagebus_server_ut.cpp
@@ -27,9 +27,9 @@ Y_UNIT_TEST_SUITE(RainCheckMessageBusServer) {
             MessageContext.Swap(messageContext);
         }
 
-        TContinueFunc Start() override {
+        TContinueFunc Start() override { 
             MessageContext.SendReplyMove(new TExampleResponse(&Env->Proto.ResponseCount));
-            return nullptr;
+            return nullptr; 
         }
     };
 
diff --git a/library/cpp/messagebus/rain_check/test/helper/misc.cpp b/library/cpp/messagebus/rain_check/test/helper/misc.cpp
index c0fcb272523..e07fc7e3cc7 100644
--- a/library/cpp/messagebus/rain_check/test/helper/misc.cpp
+++ b/library/cpp/messagebus/rain_check/test/helper/misc.cpp
@@ -23,5 +23,5 @@ TContinueFunc TSpawnNopTasksSimpleTask::Start() {
 }
 
 TContinueFunc TSpawnNopTasksSimpleTask::Join() {
-    return nullptr;
+    return nullptr; 
 }
diff --git a/library/cpp/messagebus/rain_check/test/helper/misc.h b/library/cpp/messagebus/rain_check/test/helper/misc.h
index 9150be4d2f3..ba95ee5f23c 100644
--- a/library/cpp/messagebus/rain_check/test/helper/misc.h
+++ b/library/cpp/messagebus/rain_check/test/helper/misc.h
@@ -9,8 +9,8 @@ namespace NRainCheck {
         TNopSimpleTask(IEnv*, const void*) {
         }
 
-        TContinueFunc Start() override {
-            return nullptr;
+        TContinueFunc Start() override { 
+            return nullptr; 
         }
     };
 
@@ -34,7 +34,7 @@ namespace NRainCheck {
 
         std::array<TSubtaskCompletion, 2> Completion;
 
-        void Run() override;
+        void Run() override; 
     };
 
     struct TSpawnNopTasksSimpleTask: public ISimpleTask {
@@ -49,7 +49,7 @@ namespace NRainCheck {
 
         std::array<TSubtaskCompletion, 2> Completion;
 
-        TContinueFunc Start() override;
+        TContinueFunc Start() override; 
 
         TContinueFunc Join();
     };
diff --git a/library/cpp/messagebus/rain_check/test/perftest/perftest.cpp b/library/cpp/messagebus/rain_check/test/perftest/perftest.cpp
index 22edbd8c6ba..e19dea55610 100644
--- a/library/cpp/messagebus/rain_check/test/perftest/perftest.cpp
+++ b/library/cpp/messagebus/rain_check/test/perftest/perftest.cpp
@@ -28,7 +28,7 @@ struct TCoroOuter: public ICoroTask {
     {
     }
 
-    void Run() override {
+    void Run() override { 
         for (;;) {
             TInstant start = TInstant::Now();
 
@@ -73,7 +73,7 @@ struct TSimpleOuter: public ISimpleTask {
     unsigned Current;
     unsigned I;
 
-    TContinueFunc Start() override {
+    TContinueFunc Start() override { 
         StartInstant = TInstant::Now();
         Count = 0;
         Current = 1000;
@@ -126,7 +126,7 @@ struct TReproduceCrashTask: public ISimpleTask {
 
     std::array<TSubtaskCompletion, SUBTASKS> Completion;
 
-    TContinueFunc Start() override {
+    TContinueFunc Start() override { 
         for (unsigned j = 0; j < 2; ++j) {
             //SpawnSubtask<TNopSimpleTask>(Env, &Completion[j]);
             SpawnSubtask<TSpawnNopTasksSimpleTask>(Env, &Completion[j], SUBTASKS);