aboutsummaryrefslogtreecommitdiffstats
path: root/util/system/event.cpp
diff options
context:
space:
mode:
authorand42 <and42@yandex-team.ru>2022-02-10 16:47:12 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:47:12 +0300
commit4fc9a1a64db469cc94894abfec740aa5c9e9789b (patch)
tree525f0b4c196e68c46ae8411cddc11211ef5670c1 /util/system/event.cpp
parent287d7d8c4ffc811d1e51c756ecfb13b78f4ee62d (diff)
downloadydb-4fc9a1a64db469cc94894abfec740aa5c9e9789b.tar.gz
Restoring authorship annotation for <and42@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'util/system/event.cpp')
-rw-r--r--util/system/event.cpp20
1 files changed, 10 insertions, 10 deletions
diff --git a/util/system/event.cpp b/util/system/event.cpp
index 79b3cdb2917..9771e44a89c 100644
--- a/util/system/event.cpp
+++ b/util/system/event.cpp
@@ -3,7 +3,7 @@
#include <cstdio>
-#include "atomic.h"
+#include "atomic.h"
#include "event.h"
#include "mutex.h"
#include "condvar.h"
@@ -47,17 +47,17 @@ public:
}
#else
inline TEvImpl(ResetMode rmode)
- : Manual(rmode == rManual ? true : false)
+ : Manual(rmode == rManual ? true : false)
{
}
inline void Signal() noexcept {
- if (Manual && AtomicGet(Signaled)) {
+ if (Manual && AtomicGet(Signaled)) {
return; // shortcut
}
with_lock (Mutex) {
- AtomicSet(Signaled, 1);
+ AtomicSet(Signaled, 1);
}
if (Manual) {
@@ -68,27 +68,27 @@ public:
}
inline void Reset() noexcept {
- AtomicSet(Signaled, 0);
+ AtomicSet(Signaled, 0);
}
inline bool WaitD(TInstant deadLine) noexcept {
- if (Manual && AtomicGet(Signaled)) {
+ if (Manual && AtomicGet(Signaled)) {
return true; // shortcut
}
bool resSignaled = true;
with_lock (Mutex) {
- while (!AtomicGet(Signaled)) {
+ while (!AtomicGet(Signaled)) {
if (!Cond.WaitD(Mutex, deadLine)) {
- resSignaled = AtomicGet(Signaled); // timed out, but Signaled could have been set
+ resSignaled = AtomicGet(Signaled); // timed out, but Signaled could have been set
break;
}
}
if (!Manual) {
- AtomicSet(Signaled, 0);
+ AtomicSet(Signaled, 0);
}
}
@@ -102,7 +102,7 @@ private:
#else
TCondVar Cond;
TMutex Mutex;
- TAtomic Signaled = 0;
+ TAtomic Signaled = 0;
bool Manual;
#endif
};