12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182 |
- //+private
- //+build openbsd
- package sync
- import "core:c"
- import "core:time"
- FUTEX_WAIT :: 1
- FUTEX_WAKE :: 2
- FUTEX_PRIVATE_FLAG :: 128
- FUTEX_WAIT_PRIVATE :: (FUTEX_WAIT | FUTEX_PRIVATE_FLAG)
- FUTEX_WAKE_PRIVATE :: (FUTEX_WAKE | FUTEX_PRIVATE_FLAG)
- ETIMEDOUT :: 60
- foreign import libc "system:c"
- foreign libc {
- @(link_name="futex")
- _unix_futex :: proc "c" (f: ^Futex, op: c.int, val: u32, timeout: rawptr) -> c.int ---
- @(link_name="__errno") __errno :: proc() -> ^int ---
- }
- _futex_wait :: proc "contextless" (f: ^Futex, expected: u32) -> bool {
- res := _unix_futex(f, FUTEX_WAIT_PRIVATE, expected, nil)
- if res != -1 {
- return true
- }
- if __errno()^ == ETIMEDOUT {
- return false
- }
- _panic("futex_wait failure")
- }
- _futex_wait_with_timeout :: proc "contextless" (f: ^Futex, expected: u32, duration: time.Duration) -> bool {
- if duration <= 0 {
- return false
- }
- timespec_t :: struct {
- tv_sec: c.long,
- tv_nsec: c.long,
- }
- res := _unix_futex(f, FUTEX_WAIT_PRIVATE, expected, ×pec_t{
- tv_sec = (c.long)(duration/1e9),
- tv_nsec = (c.long)(duration%1e9),
- })
- if res != -1 {
- return true
- }
- if __errno()^ == ETIMEDOUT {
- return false
- }
- _panic("futex_wait_with_timeout failure")
- }
- _futex_signal :: proc "contextless" (f: ^Futex) {
- res := _unix_futex(f, FUTEX_WAKE_PRIVATE, 1, nil)
- if res == -1 {
- _panic("futex_wake_single failure")
- }
- }
- _futex_broadcast :: proc "contextless" (f: ^Futex) {
- res := _unix_futex(f, FUTEX_WAKE_PRIVATE, u32(max(i32)), nil)
- if res == -1 {
- _panic("_futex_wake_all failure")
- }
- }
|