forked from RPCS3/rpcs3
/
sys_cond.h
59 lines (47 loc) · 1.21 KB
/
sys_cond.h
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
#pragma once
#include "sys_sync.h"
#include "sys_mutex.h"
struct lv2_mutex;
struct sys_cond_attribute_t
{
be_t<u32> pshared;
be_t<s32> flags;
be_t<u64> ipc_key;
union
{
le_t<u64> name_u64;
char name[sizeof(u64)];
};
};
struct lv2_cond final : lv2_obj
{
static const u32 id_base = 0x86000000;
const u32 shared;
const s32 flags;
const u64 key;
const u64 name;
std::shared_ptr<lv2_mutex> mutex; // Associated Mutex
atomic_t<u32> waiters{0};
std::deque<cpu_thread*> sq;
lv2_cond(u32 shared, s32 flags, u64 key, u64 name, std::shared_ptr<lv2_mutex> mutex)
: shared(shared)
, key(key)
, flags(flags)
, name(name)
, mutex(std::move(mutex))
{
this->mutex->cond_count++;
}
~lv2_cond()
{
this->mutex->cond_count--;
}
};
class ppu_thread;
// Syscalls
error_code sys_cond_create(ppu_thread& ppu, vm::ptr<u32> cond_id, u32 mutex_id, vm::ptr<sys_cond_attribute_t> attr);
error_code sys_cond_destroy(ppu_thread& ppu, u32 cond_id);
error_code sys_cond_wait(ppu_thread& ppu, u32 cond_id, u64 timeout);
error_code sys_cond_signal(ppu_thread& ppu, u32 cond_id);
error_code sys_cond_signal_all(ppu_thread& ppu, u32 cond_id);
error_code sys_cond_signal_to(ppu_thread& ppu, u32 cond_id, u32 thread_id);