diff options
author | Vlad Yaroslavlev <vladon@vladon.com> | 2022-02-10 16:46:25 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:46:25 +0300 |
commit | 344ea37b4a345701ab0e67de2266a1c1bd7baf2d (patch) | |
tree | 1a2c5ffcf89eb53ecd79dbc9bc0a195c27404d0c /util/system/sem.cpp | |
parent | 706b83ed7de5a473436620367af31fc0ceecde07 (diff) | |
download | ydb-344ea37b4a345701ab0e67de2266a1c1bd7baf2d.tar.gz |
Restoring authorship annotation for Vlad Yaroslavlev <vladon@vladon.com>. Commit 2 of 2.
Diffstat (limited to 'util/system/sem.cpp')
-rw-r--r-- | util/system/sem.cpp | 36 |
1 files changed, 18 insertions, 18 deletions
diff --git a/util/system/sem.cpp b/util/system/sem.cpp index 885ad8a255..4a93b903b5 100644 --- a/util/system/sem.cpp +++ b/util/system/sem.cpp @@ -104,7 +104,7 @@ namespace { #endif } - inline ~TSemaphoreImpl() { + inline ~TSemaphoreImpl() { #ifdef _win_ ::CloseHandle(Handle); #else @@ -119,7 +119,7 @@ namespace { #endif } - inline void Release() noexcept { + inline void Release() noexcept { #ifdef _win_ ::ReleaseSemaphore(Handle, 1, 0); #else @@ -135,7 +135,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 { + inline void Acquire() noexcept { #ifdef _win_ Y_VERIFY(::WaitForSingleObject(Handle, INFINITE) == WAIT_OBJECT_0, "can not acquire semaphore"); #else @@ -149,7 +149,7 @@ namespace { #endif } - inline bool TryAcquire() noexcept { + inline bool TryAcquire() noexcept { #ifdef _win_ // zero-second time-out interval // WAIT_OBJECT_0: current free count > 0 @@ -169,8 +169,8 @@ namespace { #if defined(_unix_) /* - Disable errors/warnings about deprecated sem_* in Darwin -*/ + Disable errors/warnings about deprecated sem_* in Darwin +*/ #ifdef _darwin_ Y_PRAGMA_DIAGNOSTIC_PUSH Y_PRAGMA_NO_DEPRECATED @@ -182,19 +182,19 @@ namespace { } } - inline ~TPosixSemaphore() { + inline ~TPosixSemaphore() { Y_VERIFY(sem_destroy(&S_) == 0, "semaphore destroy failed"); } - inline void Acquire() noexcept { + inline void Acquire() noexcept { Y_VERIFY(sem_wait(&S_) == 0, "semaphore acquire failed"); } - inline void Release() noexcept { + inline void Release() noexcept { Y_VERIFY(sem_post(&S_) == 0, "semaphore release failed"); } - inline bool TryAcquire() noexcept { + inline bool TryAcquire() noexcept { if (sem_trywait(&S_)) { Y_VERIFY(errno == EAGAIN, "semaphore try wait failed"); @@ -227,15 +227,15 @@ TSemaphore::TSemaphore(const char* name, ui32 maxFreeCount) TSemaphore::~TSemaphore() = default; -void TSemaphore::Release() noexcept { +void TSemaphore::Release() noexcept { Impl_->Release(); } -void TSemaphore::Acquire() noexcept { +void TSemaphore::Acquire() noexcept { Impl_->Acquire(); } -bool TSemaphore::TryAcquire() noexcept { +bool TSemaphore::TryAcquire() noexcept { return Impl_->TryAcquire(); } @@ -248,10 +248,10 @@ public: } }; #else -class TFastSemaphore::TImpl: public TString, public TSemaphoreImpl { +class TFastSemaphore::TImpl: public TString, public TSemaphoreImpl { public: inline TImpl(ui32 n) - : TString(ToString(RandomNumber<ui64>())) + : TString(ToString(RandomNumber<ui64>())) , TSemaphoreImpl(c_str(), n) { } @@ -265,14 +265,14 @@ TFastSemaphore::TFastSemaphore(ui32 maxFreeCount) TFastSemaphore::~TFastSemaphore() = default; -void TFastSemaphore::Release() noexcept { +void TFastSemaphore::Release() noexcept { Impl_->Release(); } -void TFastSemaphore::Acquire() noexcept { +void TFastSemaphore::Acquire() noexcept { Impl_->Acquire(); } -bool TFastSemaphore::TryAcquire() noexcept { +bool TFastSemaphore::TryAcquire() noexcept { return Impl_->TryAcquire(); } |