aboutsummaryrefslogtreecommitdiffstats
path: root/util/system/condvar.cpp
diff options
context:
space:
mode:
authorilnurkh <ilnurkh@yandex-team.com>2023-10-10 10:09:12 +0300
committerilnurkh <ilnurkh@yandex-team.com>2023-10-10 10:26:34 +0300
commit335c640261b6272bc052a251d9b8780150090b45 (patch)
tree7d4a4954aacb63514087edaaf1cd0c9999fcb94d /util/system/condvar.cpp
parentb359f0072dbc794d0287c26984dd0ea0a2c27efc (diff)
downloadydb-335c640261b6272bc052a251d9b8780150090b45.tar.gz
Y_VERIFY->Y_ABORT_UNLESS at ^u
https://clubs.at.yandex-team.ru/arcadia/29404
Diffstat (limited to 'util/system/condvar.cpp')
-rw-r--r--util/system/condvar.cpp10
1 files changed, 5 insertions, 5 deletions
diff --git a/util/system/condvar.cpp b/util/system/condvar.cpp
index a2031a89b8..b4d748e4e9 100644
--- a/util/system/condvar.cpp
+++ b/util/system/condvar.cpp
@@ -86,18 +86,18 @@ public:
inline ~TImpl() {
int ret = pthread_cond_destroy(&Cond_);
- Y_VERIFY(ret == 0, "pthread_cond_destroy failed: %s", LastSystemErrorText(ret));
+ Y_ABORT_UNLESS(ret == 0, "pthread_cond_destroy failed: %s", LastSystemErrorText(ret));
}
inline void Signal() noexcept {
int ret = pthread_cond_signal(&Cond_);
- Y_VERIFY(ret == 0, "pthread_cond_signal failed: %s", LastSystemErrorText(ret));
+ Y_ABORT_UNLESS(ret == 0, "pthread_cond_signal failed: %s", LastSystemErrorText(ret));
}
inline bool WaitD(TMutex& lock, TInstant deadLine) noexcept {
if (deadLine == TInstant::Max()) {
int ret = pthread_cond_wait(&Cond_, (pthread_mutex_t*)lock.Handle());
- Y_VERIFY(ret == 0, "pthread_cond_wait failed: %s", LastSystemErrorText(ret));
+ Y_ABORT_UNLESS(ret == 0, "pthread_cond_wait failed: %s", LastSystemErrorText(ret));
return true;
} else {
struct timespec spec;
@@ -109,7 +109,7 @@ public:
int ret = pthread_cond_timedwait(&Cond_, (pthread_mutex_t*)lock.Handle(), &spec);
- Y_VERIFY(ret == 0 || ret == ETIMEDOUT, "pthread_cond_timedwait failed: %s", LastSystemErrorText(ret));
+ Y_ABORT_UNLESS(ret == 0 || ret == ETIMEDOUT, "pthread_cond_timedwait failed: %s", LastSystemErrorText(ret));
return ret == 0;
}
@@ -117,7 +117,7 @@ public:
inline void BroadCast() noexcept {
int ret = pthread_cond_broadcast(&Cond_);
- Y_VERIFY(ret == 0, "pthread_cond_broadcast failed: %s", LastSystemErrorText(ret));
+ Y_ABORT_UNLESS(ret == 0, "pthread_cond_broadcast failed: %s", LastSystemErrorText(ret));
}
private: