aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/oldmodule
diff options
context:
space:
mode:
authorermolovd <ermolovd@yandex-team.ru>2022-02-10 16:47:53 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:47:53 +0300
commit2a4a975b112fa0fa138abc7457fe67e0e1e7fd02 (patch)
treec0748b5dcbade83af788c0abfa89c0383d6b779c /library/cpp/messagebus/oldmodule
parentb91bcef7c99a119b0846479ef71bfab4beec72ca (diff)
downloadydb-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.cpp26
-rw-r--r--library/cpp/messagebus/oldmodule/module.h2
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();