mirror of
https://github.com/RPCSX/rpcsx.git
synced 2025-12-06 07:12:14 +01:00
65e653f5ef
ipmi: fixed respond sync, get message, try get message, try send message event: detach event emitter from file signals: basic implementation linker: fixed zero symbol relocation, fixed exec relocation shared_cv/mutex: implement eintr response support shared_cv: fixed possible loop instead of wait ipmi: implement invoke async, respond async, get result, get client app id, client get name rpcsx-os: add safemode flag
72 lines
1.6 KiB
C++
72 lines
1.6 KiB
C++
#pragma once
|
|
|
|
#include <cstdint>
|
|
#include <orbis/utils/AtomicOp.hpp>
|
|
#include <orbis/utils/SharedMutex.hpp>
|
|
|
|
namespace orbis {
|
|
inline namespace utils {
|
|
// IPC-ready lightweight condition variable
|
|
class shared_cv final {
|
|
enum : unsigned {
|
|
c_waiter_mask = 0xffff,
|
|
c_signal_mask = 0x7fff0000,
|
|
c_locked_mask = 0x80000000,
|
|
c_signal_one = c_waiter_mask + 1,
|
|
};
|
|
|
|
std::atomic<unsigned> m_value{0};
|
|
|
|
protected:
|
|
// Increment waiter count
|
|
unsigned add_waiter() noexcept {
|
|
return atomic_op(m_value, [](unsigned &value) -> unsigned {
|
|
if ((value & c_signal_mask) == c_signal_mask ||
|
|
(value & c_waiter_mask) == c_waiter_mask) {
|
|
// Signal or waiter overflow, return immediately
|
|
return 0;
|
|
}
|
|
|
|
// Add waiter (c_waiter_mask)
|
|
value += 1;
|
|
return value;
|
|
});
|
|
}
|
|
|
|
// Internal waiting function
|
|
int impl_wait(shared_mutex &mutex, unsigned _val,
|
|
std::uint64_t usec_timeout) noexcept;
|
|
|
|
// Try to notify up to _count threads
|
|
void impl_wake(shared_mutex &mutex, int _count) noexcept;
|
|
|
|
public:
|
|
constexpr shared_cv() = default;
|
|
|
|
int wait(shared_mutex &mutex, std::uint64_t usec_timeout = -1) noexcept {
|
|
const unsigned _val = add_waiter();
|
|
if (!_val) {
|
|
return 0;
|
|
}
|
|
|
|
mutex.unlock();
|
|
return impl_wait(mutex, _val, usec_timeout);
|
|
}
|
|
|
|
// Wake one thread
|
|
void notify_one(shared_mutex &mutex) noexcept {
|
|
if (m_value) {
|
|
impl_wake(mutex, 1);
|
|
}
|
|
}
|
|
|
|
// Wake all threads
|
|
void notify_all(shared_mutex &mutex) noexcept {
|
|
if (m_value) {
|
|
impl_wake(mutex, INT_MAX);
|
|
}
|
|
}
|
|
};
|
|
} // namespace utils
|
|
} // namespace orbis
|