Restoring authorship annotation for Alexander Gololobov <[email protected]>. Commit 1 of 2.

1 files changed, 4 insertions, 4 deletions

diff --git a/library/cpp/messagebus/oldmodule/module.cpp b/library/cpp/messagebus/oldmodule/module.cpp
index 24bd778799f..a322a2366f0 100644
--- a/library/cpp/messagebus/oldmodule/module.cpp
+++ b/library/cpp/messagebus/oldmodule/module.cpp
@@ -777,7 +777,7 @@ void TBusModuleImpl::DestroyJob(TJobRunner* job) {
         Y_VERIFY(jobCount >= 0, "decremented too much");
         Jobs.erase(job->JobStorageIterator);
 
-        if (AtomicGet(State) == STOPPED) {
+        if (AtomicGet(State) == STOPPED) { 
             if (jobCount == 0) {
                 ShutdownCondVar.BroadCast();
             }
@@ -804,11 +804,11 @@ void TBusModuleImpl::OnMessageReceived(TAutoPtr<TBusMessage> msg0, TOnMessageCon
 }
 
 void TBusModuleImpl::Shutdown() {
-    if (AtomicGet(State) != TBusModuleImpl::RUNNING) {
-        AtomicSet(State, TBusModuleImpl::STOPPED);
+    if (AtomicGet(State) != TBusModuleImpl::RUNNING) { 
+        AtomicSet(State, TBusModuleImpl::STOPPED); 
         return;
     }
-    AtomicSet(State, TBusModuleImpl::STOPPED);
+    AtomicSet(State, TBusModuleImpl::STOPPED); 
 
     for (auto& clientSession : ClientSessions) {
         clientSession->Shutdown();