aboutsummaryrefslogtreecommitdiffstats
path: root/util/system/sem.cpp
diff options
context:
space:
mode:
authorlevong <levong@yandex-team.ru>2022-02-10 16:51:45 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:51:45 +0300
commitdd80ec62c76c5c848197b5b7468e6e215e59d715 (patch)
treeab7fbbf3253d4c0e2793218f09378908beb025fb /util/system/sem.cpp
parent5a1d870a044e6a0fc52fe457c2a6055181cf7438 (diff)
downloadydb-dd80ec62c76c5c848197b5b7468e6e215e59d715.tar.gz
Restoring authorship annotation for <levong@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'util/system/sem.cpp')
-rw-r--r--util/system/sem.cpp12
1 files changed, 6 insertions, 6 deletions
diff --git a/util/system/sem.cpp b/util/system/sem.cpp
index 34d0b0da93..4a93b903b5 100644
--- a/util/system/sem.cpp
+++ b/util/system/sem.cpp
@@ -1,6 +1,6 @@
#include "sem.h"
-#ifdef _win_
+#ifdef _win_
#include <malloc.h>
#elif defined(_sun)
#include <alloca.h>
@@ -48,7 +48,7 @@ union semun arg;
namespace {
class TSemaphoreImpl {
private:
-#ifdef _win_
+#ifdef _win_
using SEMHANDLE = HANDLE;
#else
#ifdef USE_SYSV_SEMAPHORES
@@ -105,7 +105,7 @@ namespace {
}
inline ~TSemaphoreImpl() {
-#ifdef _win_
+#ifdef _win_
::CloseHandle(Handle);
#else
#ifdef USE_SYSV_SEMAPHORES
@@ -120,7 +120,7 @@ namespace {
}
inline void Release() noexcept {
-#ifdef _win_
+#ifdef _win_
::ReleaseSemaphore(Handle, 1, 0);
#else
#ifdef USE_SYSV_SEMAPHORES
@@ -136,7 +136,7 @@ namespace {
//The UNIX semaphore object does not support a timed "wait", and
//hence to maintain consistancy, for win32 case we use INFINITE or 0 timeout.
inline void Acquire() noexcept {
-#ifdef _win_
+#ifdef _win_
Y_VERIFY(::WaitForSingleObject(Handle, INFINITE) == WAIT_OBJECT_0, "can not acquire semaphore");
#else
#ifdef USE_SYSV_SEMAPHORES
@@ -150,7 +150,7 @@ namespace {
}
inline bool TryAcquire() noexcept {
-#ifdef _win_
+#ifdef _win_
// zero-second time-out interval
// WAIT_OBJECT_0: current free count > 0
// WAIT_TIMEOUT: current free count == 0