coffee/wepoll
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add wait object

Browse Source
This commit is contained in:
Raymond Zhao 2024-05-10 09:47:10 -07:00
parent 4cfa6ab9dd
commit 1ab6cd7dab
No known key found for this signature in database
GPG Key ID: 4DA8A81F5F7FCF93
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/reflock.c
View File

@ -15,18 +15,24 @@
#define REFLOCK__POISON ((long) 0x300dead0UL) #define REFLOCK__POISON ((long) 0x300dead0UL)
/* clang-format on */ /* clang-format on */
static void* reflock__wait_object = NULL;
void reflock_init(reflock_t* reflock) { void reflock_init(reflock_t* reflock) {
reflock->state = 0; reflock->state = 0;
} }
static void reflock__signal_event(void* address) { static void reflock__signal_event(void* address) {
reflock__wait_object = NULL;
WakeByAddressSingle(address); WakeByAddressSingle(address);
} }
static void reflock__await_event(void* address) { static void reflock__await_event(void* address) {
BOOL status = WaitOnAddress(address, address, sizeof(void*), INFINITE); reflock__wait_object = address;
if (status != TRUE) do {
abort(); BOOL status = WaitOnAddress(address, reflock__wait_object, sizeof(void*), INFINITE);
if (status != TRUE)
abort();
} while (reflock__wait_object == address);
} }
void reflock_ref(reflock_t* reflock) { void reflock_ref(reflock_t* reflock) {