320 lines
11 KiB
C
320 lines
11 KiB
C
/*
|
|
* Copyright (c) 2013, 2014, 2021 Jonas 'Sortie' Termansen.
|
|
*
|
|
* Permission to use, copy, modify, and distribute this software for any
|
|
* purpose with or without fee is hereby granted, provided that the above
|
|
* copyright notice and this permission notice appear in all copies.
|
|
*
|
|
* THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
|
|
* WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
|
|
* MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
|
|
* ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
|
|
* WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
|
|
* ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
|
|
* OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
|
|
*
|
|
* pthread.h
|
|
* Thread API.
|
|
*/
|
|
|
|
#ifndef _INCLUDE_PTHREAD_H
|
|
#define _INCLUDE_PTHREAD_H
|
|
|
|
#include <sys/cdefs.h>
|
|
|
|
#include <sys/__/types.h>
|
|
|
|
#include <sched.h>
|
|
#include <time.h>
|
|
|
|
#if defined(__is_sortix_libc)
|
|
#include <stddef.h>
|
|
#include <stdint.h>
|
|
#endif
|
|
|
|
#if defined(__is_sortix_libc)
|
|
#include <sortix/uthread.h>
|
|
#endif
|
|
|
|
#include <__/pthread.h>
|
|
|
|
#ifdef __cplusplus
|
|
extern "C" {
|
|
#endif
|
|
|
|
/* TODO: #define PTHREAD_BARRIER_SERIAL_THREAD */
|
|
/* TODO: #define PTHREAD_CANCEL_ASYNCHRONOUS */
|
|
/* TODO: #define PTHREAD_CANCEL_ENABLE */
|
|
/* TODO: #define PTHREAD_CANCEL_DEFERRED */
|
|
/* TODO: #define PTHREAD_CANCEL_DISABLE */
|
|
/* TODO: #define PTHREAD_CANCELED */
|
|
#define PTHREAD_CREATE_DETACHED 1
|
|
#define PTHREAD_CREATE_JOINABLE 0
|
|
/* TODO: #define PTHREAD_EXPLICIT_SCHED */
|
|
/* TODO: #define PTHREAD_INHERIT_SCHED */
|
|
#define PTHREAD_MUTEX_DEFAULT PTHREAD_MUTEX_NORMAL
|
|
/* TODO: #define PTHREAD_MUTEX_ERRORCHECK */
|
|
#define PTHREAD_MUTEX_NORMAL 0
|
|
#define PTHREAD_MUTEX_RECURSIVE 1
|
|
/* TODO: #define PTHREAD_MUTEX_ROBUST */
|
|
/* TODO: #define PTHREAD_MUTEX_STALLED */
|
|
/* TODO: #define PTHREAD_PRIO_INHERIT */
|
|
/* TODO: #define PTHREAD_PRIO_NONE */
|
|
/* TODO: #define PTHREAD_PRIO_PROTECT */
|
|
/* TODO: #define PTHREAD_PROCESS_SHARED */
|
|
/* TODO: #define PTHREAD_PROCESS_PRIVATE */
|
|
/* TODO: #define PTHREAD_SCOPE_PROCESS */
|
|
/* TODO: #define PTHREAD_SCOPE_SYSTEM */
|
|
|
|
#ifndef __pthread_attr_t_defined
|
|
#define __pthread_attr_t_defined
|
|
typedef __pthread_attr_t pthread_attr_t;
|
|
#endif
|
|
|
|
#ifndef __pthread_barrier_t_defined
|
|
#define __pthread_barrier_t_defined
|
|
typedef __pthread_barrier_t pthread_barrier_t;
|
|
#endif
|
|
|
|
#ifndef __pthread_barrierattr_t_defined
|
|
#define __pthread_barrierattr_t_defined
|
|
typedef __pthread_barrierattr_t pthread_barrierattr_t;
|
|
#endif
|
|
|
|
#ifndef __pthread_cond_t_defined
|
|
#define __pthread_cond_t_defined
|
|
typedef __pthread_cond_t pthread_cond_t;
|
|
#endif
|
|
|
|
#ifndef __pthread_condattr_t_defined
|
|
#define __pthread_condattr_t_defined
|
|
typedef __pthread_condattr_t pthread_condattr_t;
|
|
#endif
|
|
|
|
#ifndef __pthread_key_t_defined
|
|
#define __pthread_key_t_defined
|
|
typedef __pthread_key_t pthread_key_t;
|
|
#endif
|
|
|
|
#ifndef __pthread_mutex_t_defined
|
|
#define __pthread_mutex_t_defined
|
|
typedef __pthread_mutex_t pthread_mutex_t;
|
|
#endif
|
|
|
|
#ifndef __pthread_mutexattr_t_defined
|
|
#define __pthread_mutexattr_t_defined
|
|
typedef __pthread_mutexattr_t pthread_mutexattr_t;
|
|
#endif
|
|
|
|
#ifndef __pthread_once_t_defined
|
|
#define __pthread_once_t_defined
|
|
typedef __pthread_once_t pthread_once_t;
|
|
#endif
|
|
|
|
#ifndef __pthread_rwlock_t_defined
|
|
#define __pthread_rwlock_t_defined
|
|
typedef __pthread_rwlock_t pthread_rwlock_t;
|
|
#endif
|
|
|
|
#ifndef __pthread_rwlockattr_t_defined
|
|
#define __pthread_rwlockattr_t_defined
|
|
typedef __pthread_rwlockattr_t pthread_rwlockattr_t;
|
|
#endif
|
|
|
|
#ifndef __pthread_spinlock_t_defined
|
|
#define __pthread_spinlock_t_defined
|
|
typedef __pthread_spinlock_t pthread_spinlock_t;
|
|
#endif
|
|
|
|
#ifndef __pthread_t_defined
|
|
#define __pthread_t_defined
|
|
typedef __pthread_t pthread_t;
|
|
#endif
|
|
|
|
#if defined(__is_sortix_libc)
|
|
struct pthread
|
|
{
|
|
struct uthread uthread;
|
|
pthread_mutex_t join_lock;
|
|
pthread_mutex_t detach_lock;
|
|
void* (*entry_function)(void*);
|
|
void* entry_cookie;
|
|
void* exit_result;
|
|
void** keys;
|
|
size_t keys_length;
|
|
int detach_state;
|
|
};
|
|
#endif
|
|
|
|
#if defined(__is_sortix_libc)
|
|
struct pthread_cond_elem
|
|
{
|
|
struct pthread_cond_elem* next;
|
|
struct pthread_cond_elem* prev;
|
|
int woken;
|
|
};
|
|
#endif
|
|
|
|
#define PTHREAD_COND_INITIALIZER { PTHREAD_NORMAL_MUTEX_INITIALIZER_NP, NULL, \
|
|
NULL, CLOCK_REALTIME }
|
|
#define PTHREAD_MUTEX_INITIALIZER { 0, PTHREAD_MUTEX_DEFAULT, 0, 0 }
|
|
#define PTHREAD_RWLOCK_INITIALIZER { PTHREAD_COND_INITIALIZER, \
|
|
PTHREAD_COND_INITIALIZER, \
|
|
PTHREAD_MUTEX_INITIALIZER, 0, 0, 0, 0 }
|
|
|
|
#define PTHREAD_NORMAL_MUTEX_INITIALIZER_NP { 0, PTHREAD_MUTEX_NORMAL, 0, 0 }
|
|
#define PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP { 0, PTHREAD_MUTEX_RECURSIVE, \
|
|
0, 0 }
|
|
|
|
#define PTHREAD_ONCE_INIT { PTHREAD_NORMAL_MUTEX_INITIALIZER_NP, 0 }
|
|
|
|
#define PTHREAD_NULL ((pthread_t) 0)
|
|
|
|
#if defined(__is_sortix_libc)
|
|
|
|
struct pthread_key
|
|
{
|
|
void (*destructor)(void*);
|
|
};
|
|
|
|
extern pthread_mutex_t __pthread_keys_lock;
|
|
extern struct pthread_key* __pthread_keys;
|
|
extern size_t __pthread_keys_used;
|
|
extern size_t __pthread_keys_length;
|
|
|
|
struct pthread* pthread_allocate_tls(void);
|
|
|
|
#endif
|
|
|
|
/* TODO: pthread_atfork */
|
|
int pthread_attr_destroy(pthread_attr_t*);
|
|
int pthread_attr_getdetachstate(const pthread_attr_t*, int*);
|
|
/* TODO: pthread_attr_getguardsize */
|
|
/* TODO: pthread_attr_getinheritsched */
|
|
/* TODO: pthread_attr_getschedparam */
|
|
/* TODO: pthread_attr_getschedpolicy */
|
|
/* TODO: pthread_attr_getscope */
|
|
/* TODO: pthread_attr_getstack */
|
|
int pthread_attr_getstacksize(const pthread_attr_t* __restrict,
|
|
size_t* __restrict);
|
|
int pthread_attr_init(pthread_attr_t*);
|
|
int pthread_attr_setdetachstate(pthread_attr_t*, int);
|
|
/* TODO: pthread_attr_setguardsize */
|
|
/* TODO: pthread_attr_setinheritsched */
|
|
/* TODO: pthread_attr_setschedparam */
|
|
/* TODO: pthread_attr_setschedpolicy */
|
|
/* TODO: pthread_attr_setscope */
|
|
/* TODO: pthread_attr_setstack */
|
|
int pthread_attr_setstacksize(pthread_attr_t*, size_t);
|
|
/* TODO: pthread_barrier_destroy */
|
|
/* TODO: pthread_barrier_init */
|
|
/* TODO: pthread_barrier_wait */
|
|
/* TODO: pthread_barrierattr_destroy */
|
|
/* TODO: pthread_barrierattr_getpshared */
|
|
/* TODO: pthread_barrierattr_init */
|
|
/* TODO: pthread_barrierattr_setpshared */
|
|
/* TODO: pthread_cancel */
|
|
/* TODO: pthread_cleanup_pop */
|
|
/* TODO: pthread_cleanup_push */
|
|
int pthread_cond_broadcast(pthread_cond_t*);
|
|
int pthread_cond_destroy(pthread_cond_t*);
|
|
int pthread_cond_init(pthread_cond_t* __restrict,
|
|
const pthread_condattr_t* __restrict);
|
|
int pthread_cond_signal(pthread_cond_t*);
|
|
int pthread_cond_timedwait(pthread_cond_t* __restrict,
|
|
pthread_mutex_t* __restrict,
|
|
const struct timespec* __restrict);
|
|
int pthread_cond_wait(pthread_cond_t* __restrict, pthread_mutex_t* __restrict);
|
|
int pthread_condattr_destroy(pthread_condattr_t*);
|
|
int pthread_condattr_getclock(const pthread_condattr_t* __restrict,
|
|
clockid_t* __restrict);
|
|
/* TODO: pthread_condattr_getpshared */
|
|
int pthread_condattr_init(pthread_condattr_t*);
|
|
int pthread_condattr_setclock(pthread_condattr_t*, clockid_t);
|
|
/* TODO: pthread_condattr_setpshared */
|
|
int pthread_create(pthread_t* __restrict,
|
|
const pthread_attr_t* __restrict,
|
|
void* (*)(void*),
|
|
void* __restrict);
|
|
int pthread_detach(pthread_t);
|
|
int pthread_equal(pthread_t, pthread_t);
|
|
__attribute__((__noreturn__))
|
|
void pthread_exit(void*);
|
|
/* TODO: pthread_getconcurrency */
|
|
/* TODO: pthread_getcpuclockid */
|
|
/* TODO: pthread_getschedparam */
|
|
void* pthread_getspecific(pthread_key_t);
|
|
int pthread_join(pthread_t, void**);
|
|
int pthread_key_create(pthread_key_t*, void (*)(void*));
|
|
int pthread_key_delete(pthread_key_t);
|
|
/* TODO: pthread_mutex_consistent */
|
|
int pthread_mutex_destroy(pthread_mutex_t*);
|
|
/* TODO: pthread_mutex_getprioceiling */
|
|
int pthread_mutex_init(pthread_mutex_t* __restrict,
|
|
const pthread_mutexattr_t* __restrict);
|
|
int pthread_mutex_lock(pthread_mutex_t*);
|
|
/* TODO: pthread_mutex_setprioceiling */
|
|
int pthread_mutex_timedlock(pthread_mutex_t* __restrict,
|
|
const struct timespec* __restrict);
|
|
int pthread_mutex_trylock(pthread_mutex_t*);
|
|
int pthread_mutex_unlock(pthread_mutex_t*);
|
|
int pthread_mutexattr_destroy(pthread_mutexattr_t*);
|
|
/* TODO: pthread_mutexattr_getprioceiling */
|
|
/* TODO: pthread_mutexattr_getprotocol */
|
|
/* TODO: pthread_mutexattr_getpshared */
|
|
/* TODO: pthread_mutexattr_getrobust */
|
|
int pthread_mutexattr_gettype(pthread_mutexattr_t* __restrict, int* __restrict);
|
|
int pthread_mutexattr_init(pthread_mutexattr_t*);
|
|
/* TODO: pthread_mutexattr_setprioceiling */
|
|
/* TODO: pthread_mutexattr_setprotocol */
|
|
/* TODO: pthread_mutexattr_setpshared */
|
|
/* TODO: pthread_mutexattr_setrobust */
|
|
int pthread_mutexattr_settype(pthread_mutexattr_t*, int);
|
|
int pthread_once(pthread_once_t*, void (*)(void));
|
|
int pthread_rwlock_destroy(pthread_rwlock_t*);
|
|
int pthread_rwlock_init(pthread_rwlock_t* __restrict,
|
|
const pthread_rwlockattr_t* __restrict);
|
|
int pthread_rwlock_rdlock(pthread_rwlock_t*);
|
|
int pthread_rwlock_timedrdlock(pthread_rwlock_t* __restrict,
|
|
const struct timespec* __restrict);
|
|
int pthread_rwlock_timedwrlock(pthread_rwlock_t* __restrict,
|
|
const struct timespec* __restrict);
|
|
int pthread_rwlock_tryrdlock(pthread_rwlock_t*);
|
|
int pthread_rwlock_trywrlock(pthread_rwlock_t*);
|
|
int pthread_rwlock_unlock(pthread_rwlock_t*);
|
|
int pthread_rwlock_wrlock(pthread_rwlock_t*);
|
|
int pthread_rwlockattr_destroy(pthread_rwlockattr_t*);
|
|
/* TODO: pthread_rwlockattr_getpshared */
|
|
int pthread_rwlockattr_init(pthread_rwlockattr_t*);
|
|
/* TODO: pthread_rwlockattr_setpshared */
|
|
pthread_t pthread_self(void);
|
|
/* TODO: pthread_setcancelstate */
|
|
/* TODO: pthread_setcanceltype */
|
|
/* TODO: pthread_setconcurrency */
|
|
/* TODO: pthread_setschedparam */
|
|
/* TODO: pthread_setschedprio */
|
|
int pthread_setspecific(pthread_key_t, const void*);
|
|
/* TODO: pthread_spin_destroy */
|
|
/* TODO: pthread_spin_init */
|
|
/* TODO: pthread_spin_lock */
|
|
/* TODO: pthread_spin_trylock */
|
|
/* TODO: pthread_spin_unlock */
|
|
/* TODO: pthread_testcancel */
|
|
|
|
#if __USE_SORTIX || 202405L <= __USE_POSIX
|
|
int pthread_cond_clockwait(pthread_cond_t* __restrict,
|
|
pthread_mutex_t* __restrict, clockid_t,
|
|
const struct timespec* __restrict);
|
|
int pthread_mutex_clocklock(pthread_mutex_t* __restrict, clockid_t,
|
|
const struct timespec* __restrict);
|
|
int pthread_rwlock_clockrdlock(pthread_rwlock_t* __restrict, clockid_t,
|
|
const struct timespec* __restrict);
|
|
int pthread_rwlock_clockwrlock(pthread_rwlock_t* __restrict, clockid_t,
|
|
const struct timespec* __restrict);
|
|
#endif
|
|
|
|
#ifdef __cplusplus
|
|
} /* extern "C" */
|
|
#endif
|
|
|
|
#endif
|