aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus
diff options
context:
space:
mode:
authorivanmorozov <ivanmorozov@yandex-team.ru>2022-02-10 16:47:34 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:47:34 +0300
commit464ba3814a83db4f2d5327393b0b6eaf0c86bfd7 (patch)
treec0748b5dcbade83af788c0abfa89c0383d6b779c /library/cpp/messagebus
parentcba5d9a444e2cfe105f55ccda66cd21d50440017 (diff)
downloadydb-464ba3814a83db4f2d5327393b0b6eaf0c86bfd7.tar.gz
Restoring authorship annotation for <ivanmorozov@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/messagebus')
-rw-r--r--library/cpp/messagebus/scheduler/scheduler.cpp22
1 files changed, 11 insertions, 11 deletions
diff --git a/library/cpp/messagebus/scheduler/scheduler.cpp b/library/cpp/messagebus/scheduler/scheduler.cpp
index 7ed8576e27..5a5fe52894 100644
--- a/library/cpp/messagebus/scheduler/scheduler.cpp
+++ b/library/cpp/messagebus/scheduler/scheduler.cpp
@@ -26,11 +26,11 @@ TScheduler::~TScheduler() {
Y_VERIFY(StopThread, "state check");
}
-size_t TScheduler::Size() const {
- TGuard<TLock> guard(Lock);
- return Items.size() + (!!NextItem ? 1 : 0);
-}
-
+size_t TScheduler::Size() const {
+ TGuard<TLock> guard(Lock);
+ return Items.size() + (!!NextItem ? 1 : 0);
+}
+
void TScheduler::Stop() {
{
TGuard<TLock> guard(Lock);
@@ -39,11 +39,11 @@ void TScheduler::Stop() {
CondVar.Signal();
}
Thread.Get();
-
- if (!!NextItem) {
- NextItem.Destroy();
- }
-
+
+ if (!!NextItem) {
+ NextItem.Destroy();
+ }
+
for (auto& item : Items) {
item.Destroy();
}
@@ -105,7 +105,7 @@ void TScheduler::SchedulerThread() {
continue;
}
- current = NextItem.Release();
+ current = NextItem.Release();
}
current->Do();