aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/coroutine/engine/condvar.h
diff options
context:
space:
mode:
authorAnton Samokhvalov <pg83@yandex.ru>2022-02-10 16:45:15 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:45:15 +0300
commit72cb13b4aff9bc9cf22e49251bc8fd143f82538f (patch)
treeda2c34829458c7d4e74bdfbdf85dff449e9e7fb8 /library/cpp/coroutine/engine/condvar.h
parent778e51ba091dc39e7b7fcab2b9cf4dbedfb6f2b5 (diff)
downloadydb-72cb13b4aff9bc9cf22e49251bc8fd143f82538f.tar.gz
Restoring authorship annotation for Anton Samokhvalov <pg83@yandex.ru>. Commit 1 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 ffceede6fa..384a6c19f8 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_;
+};