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

5 files changed, 24 insertions, 24 deletions

diff --git a/library/cpp/messagebus/messqueue.cpp b/library/cpp/messagebus/messqueue.cpp
index 3474d62705..09c33a3b7c 100644
--- a/library/cpp/messagebus/messqueue.cpp
+++ b/library/cpp/messagebus/messqueue.cpp
@@ -186,12 +186,12 @@ void TBusMessageQueue::DestroyAllSessions() {
 
     for (auto& session : sessions) {
         Y_VERIFY(session->IsDown(), "Session must be shut down prior to queue shutdown");
-    }
+    } 
 }
-
+ 
 void TBusMessageQueue::Schedule(IScheduleItemAutoPtr i) {
     Scheduler.Schedule(i);
-}
+} 
 
 TString TBusMessageQueue::GetNameInternal() const {
     return Config.Name;
diff --git a/library/cpp/messagebus/oldmodule/module.cpp b/library/cpp/messagebus/oldmodule/module.cpp
index 24bd778799..42d6e0b202 100644
--- a/library/cpp/messagebus/oldmodule/module.cpp
+++ b/library/cpp/messagebus/oldmodule/module.cpp
@@ -10,15 +10,15 @@
 #include <util/generic/singleton.h>
 #include <util/string/printf.h>
 #include <util/system/event.h>
-
+ 
 using namespace NActor;
 using namespace NBus;
 using namespace NBus::NPrivate;
 
-namespace {
+namespace { 
     Y_POD_STATIC_THREAD(TBusJob*)
     ThreadCurrentJob;
-
+ 
     struct TThreadCurrentJobGuard {
         TBusJob* Prev;
 
@@ -53,13 +53,13 @@ namespace {
 
         for (auto& call : *vec) {
             ClearState(&call);
-        }
-
+        } 
+ 
         vec->clear();
-    }
-
-}
-
+    } 
+ 
+} 
+ 
 namespace NBus {
     namespace NPrivate {
         class TJobStorage {
@@ -146,7 +146,7 @@ namespace NBus {
                 Y_VERIFY(State != RUNNING, "if running, must explicitly call Shutdown() before destructor");
 
                 Scheduler.Stop();
-
+ 
                 while (!Jobs.empty()) {
                     DestroyJob(Jobs.front());
                 }
@@ -577,7 +577,7 @@ namespace NBus {
         ClearJobStateVector(&Finished);
         ClearJobStateVector(&Pending);
     }
-
+ 
     void TBusJob::Sleep(int milliSeconds) {
         CheckThreadCurrentJob();
 
@@ -831,8 +831,8 @@ void TBusModuleImpl::Shutdown() {
             ShutdownCondVar.WaitI(Lock);
         }
     }
-}
-
+} 
+ 
 EMessageStatus TBusModule::StartJob(TAutoPtr<TBusMessage> message) {
     Y_VERIFY(Impl->State == TBusModuleImpl::RUNNING);
     Y_VERIFY(!!Impl->Queue);
diff --git a/library/cpp/messagebus/oldmodule/module.h b/library/cpp/messagebus/oldmodule/module.h
index 8d1c4a5d52..be02e6eeec 100644
--- a/library/cpp/messagebus/oldmodule/module.h
+++ b/library/cpp/messagebus/oldmodule/module.h
@@ -264,7 +264,7 @@ namespace NBus {
 
         /// clears all message states
         void ClearAllMessageStates();
-
+ 
         /// returns true if job is done
         bool IsDone();
 
diff --git a/library/cpp/messagebus/test/ut/messagebus_ut.cpp b/library/cpp/messagebus/test/ut/messagebus_ut.cpp
index 040f9b7702..254afad737 100644
--- a/library/cpp/messagebus/test/ut/messagebus_ut.cpp
+++ b/library/cpp/messagebus/test/ut/messagebus_ut.cpp
@@ -5,16 +5,16 @@
 #include <library/cpp/messagebus/test/helper/hanging_server.h>
 #include <library/cpp/messagebus/test/helper/object_count_check.h>
 #include <library/cpp/messagebus/test/helper/wait_for.h>
-
+ 
 #include <library/cpp/messagebus/misc/test_sync.h>
-
+ 
 #include <util/network/sock.h>
 
 #include <utility>
 
-using namespace NBus;
+using namespace NBus; 
 using namespace NBus::NTest;
-
+ 
 namespace {
     struct TExampleClientSlowOnMessageSent: public TExampleClient {
         TAtomic SentCompleted;
@@ -55,7 +55,7 @@ Y_UNIT_TEST_SUITE(TMessageBusTests) {
 
         TExampleClient client(sessionConfig);
         client.CrashOnError = true;
-
+ 
         server.UseCompression = useCompression;
         client.UseCompression = useCompression;
 
@@ -1148,4 +1148,4 @@ Y_UNIT_TEST_SUITE(TMessageBusTests) {
         // but it should occur at least once
         UNIT_ASSERT(client.Session->GetConnectSyscallsNumForTest(noServerAddr) > 2);
     };
-};
+}; 
diff --git a/library/cpp/messagebus/ybus.h b/library/cpp/messagebus/ybus.h
index de21ad8521..7433aef821 100644
--- a/library/cpp/messagebus/ybus.h
+++ b/library/cpp/messagebus/ybus.h
@@ -187,7 +187,7 @@ namespace NBus {
 
     public:
         void Schedule(NPrivate::IScheduleItemAutoPtr i);
-
+ 
     private:
         void DestroyAllSessions();
         void Add(TIntrusivePtr< ::NBus::NPrivate::TBusSessionImpl> session);