//+build linux, darwin, freebsd, openbsd, netbsd, haiku package unix foreign import "system:pthread" import "core:c" timespec :: struct { tv_sec: i64, tv_nsec: i64, } // // On success, these functions return 0. // @(default_calling_convention="c") foreign pthread { pthread_create :: proc(t: ^pthread_t, attrs: ^pthread_attr_t, routine: proc(data: rawptr) -> rawptr, arg: rawptr) -> c.int --- // retval is a pointer to a location to put the return value of the thread proc. pthread_join :: proc(t: pthread_t, retval: ^rawptr) -> c.int --- pthread_kill :: proc(t: pthread_t, sig: c.int) -> c.int --- pthread_self :: proc() -> pthread_t --- pthread_equal :: proc(a, b: pthread_t) -> b32 --- pthread_detach :: proc(t: pthread_t) -> c.int --- sched_get_priority_min :: proc(policy: c.int) -> c.int --- sched_get_priority_max :: proc(policy: c.int) -> c.int --- // NOTE: POSIX says this can fail with OOM. pthread_attr_init :: proc(attrs: ^pthread_attr_t) -> c.int --- pthread_attr_destroy :: proc(attrs: ^pthread_attr_t) -> c.int --- pthread_attr_getschedparam :: proc(attrs: ^pthread_attr_t, param: ^sched_param) -> c.int --- pthread_attr_setschedparam :: proc(attrs: ^pthread_attr_t, param: ^sched_param) -> c.int --- // states: PTHREAD_CREATE_DETACHED, PTHREAD_CREATE_JOINABLE pthread_attr_setdetachstate :: proc(attrs: ^pthread_attr_t, detach_state: c.int) -> c.int --- // NOTE(tetra, 2019-11-06): WARNING: Different systems have different alignment requirements. // For maximum usefulness, use the OS's page size. // ALSO VERY MAJOR WARNING: `stack_ptr` must be the LAST byte of the stack on systems // where the stack grows downwards, which is the common case, so far as I know. // On systems where it grows upwards, give the FIRST byte instead. // ALSO SLIGHTLY LESS MAJOR WARNING: Using this procedure DISABLES automatically-provided // guard pages. If you are using this procedure, YOU must set them up manually. // If you forget to do this, you WILL get stack corruption bugs if you do not EXTREMELY // know what you are doing! pthread_attr_setstack :: proc(attrs: ^pthread_attr_t, stack_ptr: rawptr, stack_size: u64) -> c.int --- pthread_attr_getstack :: proc(attrs: ^pthread_attr_t, stack_ptr: ^rawptr, stack_size: ^u64) -> c.int --- pthread_sigmask :: proc(how: c.int, set: rawptr, oldset: rawptr) -> c.int --- sched_yield :: proc() -> c.int --- } // NOTE: Unimplemented in Haiku. when ODIN_OS != .Haiku { foreign pthread { // scheds: PTHREAD_INHERIT_SCHED, PTHREAD_EXPLICIT_SCHED pthread_attr_setinheritsched :: proc(attrs: ^pthread_attr_t, sched: c.int) -> c.int --- pthread_attr_getschedpolicy :: proc(t: ^pthread_attr_t, policy: ^c.int) -> c.int --- pthread_attr_setschedpolicy :: proc(t: ^pthread_attr_t, policy: c.int) -> c.int --- } } @(default_calling_convention="c") foreign pthread { // NOTE: POSIX says this can fail with OOM. pthread_cond_init :: proc(cond: ^pthread_cond_t, attrs: ^pthread_condattr_t) -> c.int --- pthread_cond_destroy :: proc(cond: ^pthread_cond_t) -> c.int --- pthread_cond_signal :: proc(cond: ^pthread_cond_t) -> c.int --- // same as signal, but wakes up _all_ threads that are waiting pthread_cond_broadcast :: proc(cond: ^pthread_cond_t) -> c.int --- // assumes the mutex is pre-locked pthread_cond_wait :: proc(cond: ^pthread_cond_t, mutex: ^pthread_mutex_t) -> c.int --- pthread_cond_timedwait :: proc(cond: ^pthread_cond_t, mutex: ^pthread_mutex_t, timeout: ^timespec) -> c.int --- pthread_condattr_init :: proc(attrs: ^pthread_condattr_t) -> c.int --- pthread_condattr_destroy :: proc(attrs: ^pthread_condattr_t) -> c.int --- // p-shared = "process-shared" - i.e: is this condition shared among multiple processes? // values: PTHREAD_PROCESS_PRIVATE, PTHREAD_PROCESS_SHARED pthread_condattr_setpshared :: proc(attrs: ^pthread_condattr_t, value: c.int) -> c.int --- pthread_condattr_getpshared :: proc(attrs: ^pthread_condattr_t, result: ^c.int) -> c.int --- } @(default_calling_convention="c") foreign pthread { // NOTE: POSIX says this can fail with OOM. pthread_mutex_init :: proc(mutex: ^pthread_mutex_t, attrs: ^pthread_mutexattr_t) -> c.int --- pthread_mutex_destroy :: proc(mutex: ^pthread_mutex_t) -> c.int --- pthread_mutex_trylock :: proc(mutex: ^pthread_mutex_t) -> c.int --- pthread_mutex_lock :: proc(mutex: ^pthread_mutex_t) -> c.int --- pthread_mutex_timedlock :: proc(mutex: ^pthread_mutex_t, timeout: ^timespec) -> c.int --- pthread_mutex_unlock :: proc(mutex: ^pthread_mutex_t) -> c.int --- pthread_mutexattr_init :: proc(attrs: ^pthread_mutexattr_t) -> c.int --- pthread_mutexattr_destroy :: proc(attrs: ^pthread_mutexattr_t) -> c.int --- pthread_mutexattr_settype :: proc(attrs: ^pthread_mutexattr_t, type: c.int) -> c.int --- // p-shared = "process-shared" - i.e: is this mutex shared among multiple processes? // values: PTHREAD_PROCESS_PRIVATE, PTHREAD_PROCESS_SHARED pthread_mutexattr_setpshared :: proc(attrs: ^pthread_mutexattr_t, value: c.int) -> c.int --- pthread_mutexattr_getpshared :: proc(attrs: ^pthread_mutexattr_t, result: ^c.int) -> c.int --- pthread_testcancel :: proc () --- }