diff options
author | Alexander Gololobov <davenger@yandex-team.com> | 2022-02-10 16:47:38 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:47:38 +0300 |
commit | fccc62e9bfdce9be2fe7e0f23479da3a5512211a (patch) | |
tree | c0748b5dcbade83af788c0abfa89c0383d6b779c /library/cpp/messagebus/oldmodule/module.cpp | |
parent | 39608cdb86363c75ce55b2b9a69841c3b71f22cf (diff) | |
download | ydb-fccc62e9bfdce9be2fe7e0f23479da3a5512211a.tar.gz |
Restoring authorship annotation for Alexander Gololobov <davenger@yandex-team.com>. Commit 2 of 2.
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 a322a2366f..24bd778799 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(); |