aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/coroutine/engine/condvar.h
diff options
context:
space:
mode:
authorAnton Samokhvalov <pg83@yandex.ru>2022-02-10 16:45:17 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:45:17 +0300
commitd3a398281c6fd1d3672036cb2d63f842d2cb28c5 (patch)
treedd4bd3ca0f36b817e96812825ffaf10d645803f2 /library/cpp/coroutine/engine/condvar.h
parent72cb13b4aff9bc9cf22e49251bc8fd143f82538f (diff)
downloadydb-d3a398281c6fd1d3672036cb2d63f842d2cb28c5.tar.gz
Restoring authorship annotation for Anton Samokhvalov <pg83@yandex.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/coroutine/engine/condvar.h')
-rw-r--r--library/cpp/coroutine/engine/condvar.h52
1 files changed, 26 insertions, 26 deletions
diff --git a/library/cpp/coroutine/engine/condvar.h b/library/cpp/coroutine/engine/condvar.h
index 384a6c19f8..ffceede6fa 100644
--- a/library/cpp/coroutine/engine/condvar.h
+++ b/library/cpp/coroutine/engine/condvar.h
@@ -1,38 +1,38 @@
#pragma once
-
+
#include "events.h"
#include "mutex.h"
-class TContCondVar {
-public:
+class TContCondVar {
+public:
int WaitD(TCont* current, TContMutex* mutex, TInstant deadline) {
- mutex->UnLock();
-
- const int ret = WaitQueue_.WaitD(current, deadline);
-
- if (ret != EWAKEDUP) {
+ mutex->UnLock();
+
+ const int ret = WaitQueue_.WaitD(current, deadline);
+
+ if (ret != EWAKEDUP) {
return ret;
}
- return mutex->LockD(current, deadline);
- }
-
+ return mutex->LockD(current, deadline);
+ }
+
int WaitT(TCont* current, TContMutex* mutex, TDuration timeout) {
- return WaitD(current, mutex, timeout.ToDeadLine());
- }
-
+ return WaitD(current, mutex, timeout.ToDeadLine());
+ }
+
int WaitI(TCont* current, TContMutex* mutex) {
- return WaitD(current, mutex, TInstant::Max());
- }
-
+ return WaitD(current, mutex, TInstant::Max());
+ }
+
void Signal() noexcept {
- WaitQueue_.Signal();
- }
-
+ WaitQueue_.Signal();
+ }
+
void BroadCast() noexcept {
- WaitQueue_.BroadCast();
- }
-
-private:
- TContWaitQueue WaitQueue_;
-};
+ WaitQueue_.BroadCast();
+ }
+
+private:
+ TContWaitQueue WaitQueue_;
+};