diff options
author | ermolovd <ermolovd@yandex-team.ru> | 2022-02-10 16:47:53 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:47:53 +0300 |
commit | 2a4a975b112fa0fa138abc7457fe67e0e1e7fd02 (patch) | |
tree | c0748b5dcbade83af788c0abfa89c0383d6b779c /library/cpp/messagebus/oldmodule | |
parent | b91bcef7c99a119b0846479ef71bfab4beec72ca (diff) | |
download | ydb-2a4a975b112fa0fa138abc7457fe67e0e1e7fd02.tar.gz |
Restoring authorship annotation for <ermolovd@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/messagebus/oldmodule')
-rw-r--r-- | library/cpp/messagebus/oldmodule/module.cpp | 26 | ||||
-rw-r--r-- | library/cpp/messagebus/oldmodule/module.h | 2 |
2 files changed, 14 insertions, 14 deletions
diff --git a/library/cpp/messagebus/oldmodule/module.cpp b/library/cpp/messagebus/oldmodule/module.cpp index 42d6e0b202..24bd778799 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 be02e6eeec..8d1c4a5d52 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(); |