diff options
author | Sergey Bugaev <bugaevc@serenityos.org> | 2021-07-06 14:36:51 +0300 |
---|---|---|
committer | Andreas Kling <kling@serenityos.org> | 2021-07-06 17:25:34 +0200 |
commit | 78f5c4a4c29f051d3c5d363803063f08bfa5fbe0 (patch) | |
tree | 1bc6573904c88ca4aa7db24c256c811d2c877ed7 /Userland/Libraries/LibPthread | |
parent | 30caa33f7e56f01c68807c58328be614f39de604 (diff) | |
download | serenity-78f5c4a4c29f051d3c5d363803063f08bfa5fbe0.zip |
LibPthread: Fix ordering
It would be enough to use relaxed ordering here if it weren't for
the mutex, which we also need to store and retrieve. To ensure the
pthread_cond_broadcast() call sees the store, use release and acquire
as appropriate. Thankfully, both of these are on the slow paths.
Diffstat (limited to 'Userland/Libraries/LibPthread')
-rw-r--r-- | Userland/Libraries/LibPthread/pthread_cond.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/Userland/Libraries/LibPthread/pthread_cond.cpp b/Userland/Libraries/LibPthread/pthread_cond.cpp index 0465e7df94..48436f9429 100644 --- a/Userland/Libraries/LibPthread/pthread_cond.cpp +++ b/Userland/Libraries/LibPthread/pthread_cond.cpp @@ -73,7 +73,7 @@ int pthread_cond_timedwait(pthread_cond_t* cond, pthread_mutex_t* mutex, const s // Fetch the current value, and record that we're about to wait. Fetching // the current value has to be done while we hold the mutex, because the // value might change as soon as we unlock it. - u32 value = AK::atomic_fetch_or(&cond->value, NEED_TO_WAKE_ONE | NEED_TO_WAKE_ALL, AK::memory_order_relaxed) | NEED_TO_WAKE_ONE | NEED_TO_WAKE_ALL; + u32 value = AK::atomic_fetch_or(&cond->value, NEED_TO_WAKE_ONE | NEED_TO_WAKE_ALL, AK::memory_order_release) | NEED_TO_WAKE_ONE | NEED_TO_WAKE_ALL; pthread_mutex_unlock(mutex); int rc = futex_wait(&cond->value, value, abstime, cond->clockid); if (rc < 0 && errno != EAGAIN) @@ -122,7 +122,7 @@ int pthread_cond_broadcast(pthread_cond_t* cond) if (!(value & NEED_TO_WAKE_ALL)) [[likely]] return 0; - AK::atomic_fetch_and(&cond->value, ~(NEED_TO_WAKE_ONE | NEED_TO_WAKE_ALL), AK::memory_order_relaxed); + AK::atomic_fetch_and(&cond->value, ~(NEED_TO_WAKE_ONE | NEED_TO_WAKE_ALL), AK::memory_order_acquire); pthread_mutex_t* mutex = AK::atomic_load(&cond->mutex, AK::memory_order_relaxed); VERIFY(mutex); |