mirror of
https://github.com/LadybirdBrowser/ladybird.git
synced 2026-06-19 08:11:58 +00:00
85 lines
2.5 KiB
C++
85 lines
2.5 KiB
C++
/*
|
|
* Copyright (c) 2021, kleines Filmröllchen <filmroellchen@serenityos.org>.
|
|
* Copyright (c) 2025, Ryszard Goc <ryszardgoc@gmail.com>
|
|
*
|
|
* SPDX-License-Identifier: BSD-2-Clause
|
|
*/
|
|
|
|
#include <AK/Time.h>
|
|
#include <LibSync/ConditionVariable.h>
|
|
#include <LibSync/Export.h>
|
|
#include <LibSync/Mutex.h>
|
|
#include <errno.h>
|
|
#include <pthread.h>
|
|
|
|
namespace Sync {
|
|
|
|
namespace {
|
|
|
|
ALWAYS_INLINE pthread_cond_t* to_impl(void* ptr)
|
|
{
|
|
return reinterpret_cast<pthread_cond_t*>(ptr);
|
|
}
|
|
|
|
}
|
|
|
|
template<typename MutexType>
|
|
requires Detail::IsIntraprocess<MutexType> && Detail::IsNonRecursive<MutexType>
|
|
ConditionVariableBase<MutexType>::ConditionVariableBase(MutexType& to_wait_on)
|
|
: m_to_wait_on(to_wait_on)
|
|
{
|
|
static_assert(sizeof(m_storage) == sizeof(pthread_cond_t));
|
|
int result = pthread_cond_init(to_impl(m_storage), nullptr);
|
|
VERIFY(result == 0);
|
|
}
|
|
|
|
template<typename MutexType>
|
|
requires Detail::IsIntraprocess<MutexType> && Detail::IsNonRecursive<MutexType>
|
|
ConditionVariableBase<MutexType>::~ConditionVariableBase()
|
|
{
|
|
int result = pthread_cond_destroy(to_impl(m_storage));
|
|
VERIFY(result == 0);
|
|
}
|
|
|
|
template<typename MutexType>
|
|
requires Detail::IsIntraprocess<MutexType> && Detail::IsNonRecursive<MutexType>
|
|
void ConditionVariableBase<MutexType>::wait()
|
|
{
|
|
int result = pthread_cond_wait(to_impl(m_storage), reinterpret_cast<pthread_mutex_t*>(m_to_wait_on.m_storage));
|
|
VERIFY(result == 0);
|
|
}
|
|
|
|
template<typename MutexType>
|
|
requires Detail::IsIntraprocess<MutexType> && Detail::IsNonRecursive<MutexType>
|
|
bool ConditionVariableBase<MutexType>::wait_for(AK::Duration const& timeout)
|
|
{
|
|
if (timeout <= AK::Duration::zero())
|
|
return false;
|
|
|
|
auto absolute_timeout = (AK::UnixDateTime::now() + timeout).to_timespec();
|
|
int result = pthread_cond_timedwait(to_impl(m_storage), reinterpret_cast<pthread_mutex_t*>(m_to_wait_on.m_storage), &absolute_timeout);
|
|
if (result == ETIMEDOUT)
|
|
return false;
|
|
VERIFY(result == 0);
|
|
return true;
|
|
}
|
|
|
|
template<typename MutexType>
|
|
requires Detail::IsIntraprocess<MutexType> && Detail::IsNonRecursive<MutexType>
|
|
void ConditionVariableBase<MutexType>::signal()
|
|
{
|
|
int result = pthread_cond_signal(to_impl(m_storage));
|
|
VERIFY(result == 0);
|
|
}
|
|
|
|
template<typename MutexType>
|
|
requires Detail::IsIntraprocess<MutexType> && Detail::IsNonRecursive<MutexType>
|
|
void ConditionVariableBase<MutexType>::broadcast()
|
|
{
|
|
int result = pthread_cond_broadcast(to_impl(m_storage));
|
|
VERIFY(result == 0);
|
|
}
|
|
|
|
template class SYNC_API ConditionVariableBase<Mutex>;
|
|
|
|
}
|