core/sync/sync2/futex_windows.odin


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

//+private
//+build windows
package sync2

import "core:time"

foreign import Synchronization "system:Synchronization.lib"

@(default_calling_convention="stdcall")
foreign Synchronization {
	WaitOnAddress       :: proc(Address: rawptr, CompareAddress: rawptr, AddressSize: uint, Timeout: u32) -> b32 ---
	WakeByAddressSingle :: proc(Address: rawptr) ---
	WakeByAddressAll    :: proc(Address: rawptr) ---
}


_futex_wait :: proc(f: ^Futex, expect: u32) -> bool {
	expect := expect
	return bool(WaitOnAddress(f, &expect, size_of(expect), ~u32(0)))
}

_futex_wait_with_timeout :: proc(f: ^Futex, expect: u32, duration: time.Duration) -> bool {
	expect := expect
	timeout := u32(0)
	if duration > 0 {
		timeout = u32(duration/1e6)
	}
	return bool(WaitOnAddress(f, &expect, size_of(expect), timeout))
}

_futex_signal :: proc(f: ^Futex) {
	WakeByAddressSingle(f)
}

_futex_broadcast :: proc(f: ^Futex) {
	WakeByAddressAll(f)
}