diff options
Diffstat (limited to 'library/cpp/messagebus/oldmodule/module.cpp')
| -rw-r--r-- | library/cpp/messagebus/oldmodule/module.cpp | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/library/cpp/messagebus/oldmodule/module.cpp b/library/cpp/messagebus/oldmodule/module.cpp index a322a2366f0..24bd778799f 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(); |
