123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002 |
- #if !defined( PTHREAD_H )
- #define PTHREAD_H
- #include <pte_types.h>
- #include <sched.h>
- #define PTE_VERSION 2,8,0,0
- #define PTE_VERSION_STRING "2, 8, 0, 0\0"
- #if !defined( PTE_CLEANUP_CXX ) && !defined( PTE_CLEANUP_C )
- # define PTE_CLEANUP_C
- #endif
- #undef PTE_LEVEL
- #if defined(_POSIX_SOURCE)
- #define PTE_LEVEL 0
- #endif
- #if defined(_POSIX_C_SOURCE) && _POSIX_C_SOURCE >= 199309
- #undef PTE_LEVEL
- #define PTE_LEVEL 1
- #endif
- #if defined(INCLUDE_NP)
- #undef PTE_LEVEL
- #define PTE_LEVEL 2
- #endif
- #define PTE_LEVEL_MAX 3
- #if !defined(PTE_LEVEL)
- #define PTE_LEVEL PTE_LEVEL_MAX
- #endif
- #include <time.h>
- #include <setjmp.h>
- #include <limits.h>
- enum
- {
- PTE_FALSE = 0,
- PTE_TRUE = (! PTE_FALSE)
- };
-
-
- #undef _POSIX_THREADS
- #define _POSIX_THREADS 200112L
- #undef _POSIX_READER_WRITER_LOCKS
- #define _POSIX_READER_WRITER_LOCKS 200112L
- #undef _POSIX_SPIN_LOCKS
- #define _POSIX_SPIN_LOCKS 200112L
- #undef _POSIX_BARRIERS
- #define _POSIX_BARRIERS 200112L
- #undef _POSIX_THREAD_SAFE_FUNCTIONS
- #define _POSIX_THREAD_SAFE_FUNCTIONS 200112L
- #undef _POSIX_THREAD_ATTR_STACKSIZE
- #define _POSIX_THREAD_ATTR_STACKSIZE 200112L
-
- #undef _POSIX_THREAD_ATTR_STACKADDR
- #define _POSIX_THREAD_ATTR_STACKADDR -1
- #undef _POSIX_THREAD_PRIO_INHERIT
- #define _POSIX_THREAD_PRIO_INHERIT -1
- #undef _POSIX_THREAD_PRIO_PROTECT
- #define _POSIX_THREAD_PRIO_PROTECT -1
-
- #undef _POSIX_THREAD_PRIORITY_SCHEDULING
- #define _POSIX_THREAD_PRIORITY_SCHEDULING -1
- #undef _POSIX_THREAD_PROCESS_SHARED
- #define _POSIX_THREAD_PROCESS_SHARED -1
-
- #undef _POSIX_THREAD_DESTRUCTOR_ITERATIONS
- #define _POSIX_THREAD_DESTRUCTOR_ITERATIONS 4
- #undef PTHREAD_DESTRUCTOR_ITERATIONS
- #define PTHREAD_DESTRUCTOR_ITERATIONS _POSIX_THREAD_DESTRUCTOR_ITERATIONS
- #undef _POSIX_THREAD_KEYS_MAX
- #define _POSIX_THREAD_KEYS_MAX 128
- #undef PTHREAD_KEYS_MAX
- #define PTHREAD_KEYS_MAX _POSIX_THREAD_KEYS_MAX
- #undef PTHREAD_STACK_MIN
- #define PTHREAD_STACK_MIN 0
- #undef _POSIX_THREAD_THREADS_MAX
- #define _POSIX_THREAD_THREADS_MAX 64
-
- #undef PTHREAD_THREADS_MAX
- #define PTHREAD_THREADS_MAX 2019
- #undef _POSIX_SEM_NSEMS_MAX
- #define _POSIX_SEM_NSEMS_MAX 256
-
- #undef SEM_NSEMS_MAX
- #define SEM_NSEMS_MAX 1024
- #undef _POSIX_SEM_VALUE_MAX
- #define _POSIX_SEM_VALUE_MAX 32767
- #undef SEM_VALUE_MAX
- #define SEM_VALUE_MAX INT_MAX
-
- typedef struct
- {
- void * p;
- unsigned int x;
- } pte_handle_t;
- typedef pte_handle_t pthread_t;
- typedef struct pthread_attr_t_ * pthread_attr_t;
- typedef struct pthread_once_t_ pthread_once_t;
- typedef struct pthread_key_t_ * pthread_key_t;
- typedef struct pthread_mutex_t_ * pthread_mutex_t;
- typedef struct pthread_mutexattr_t_ * pthread_mutexattr_t;
- typedef struct pthread_cond_t_ * pthread_cond_t;
- typedef struct pthread_condattr_t_ * pthread_condattr_t;
- typedef struct pthread_rwlock_t_ * pthread_rwlock_t;
- typedef struct pthread_rwlockattr_t_ * pthread_rwlockattr_t;
- typedef struct pthread_spinlock_t_ * pthread_spinlock_t;
- typedef struct pthread_barrier_t_ * pthread_barrier_t;
- typedef struct pthread_barrierattr_t_ * pthread_barrierattr_t;
-
- enum
- {
-
- PTHREAD_CREATE_JOINABLE = 0,
- PTHREAD_CREATE_DETACHED = 1,
-
- PTHREAD_INHERIT_SCHED = 0,
- PTHREAD_EXPLICIT_SCHED = 1,
-
- PTHREAD_SCOPE_PROCESS = 0,
- PTHREAD_SCOPE_SYSTEM = 1,
- PTHREAD_SCOPE_PROCESS_VFPU = 2,
-
- PTHREAD_CANCEL_ENABLE = 0,
- PTHREAD_CANCEL_DISABLE = 1,
-
- PTHREAD_CANCEL_ASYNCHRONOUS = 0,
- PTHREAD_CANCEL_DEFERRED = 1,
-
- PTHREAD_PROCESS_PRIVATE = 0,
- PTHREAD_PROCESS_SHARED = 1,
-
- PTHREAD_BARRIER_SERIAL_THREAD = -1
- };
-
- #define PTHREAD_CANCELED ((void *) -1)
-
- #define PTHREAD_ONCE_INIT { PTE_FALSE, 0, 0, 0}
- struct pthread_once_t_
- {
- int state;
- void * semaphore;
- int numSemaphoreUsers;
- int done;
- };
-
- #define PTHREAD_MUTEX_INITIALIZER ((pthread_mutex_t) -1)
- #define PTHREAD_RECURSIVE_MUTEX_INITIALIZER ((pthread_mutex_t) -2)
- #define PTHREAD_ERRORCHECK_MUTEX_INITIALIZER ((pthread_mutex_t) -3)
-
- #define PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP PTHREAD_RECURSIVE_MUTEX_INITIALIZER
- #define PTHREAD_ERRORCHECK_MUTEX_INITIALIZER_NP PTHREAD_ERRORCHECK_MUTEX_INITIALIZER
- #define PTHREAD_COND_INITIALIZER ((pthread_cond_t) -1)
- #define PTHREAD_RWLOCK_INITIALIZER ((pthread_rwlock_t) -1)
- #define PTHREAD_SPINLOCK_INITIALIZER ((pthread_spinlock_t) -1)
-
- enum
- {
-
- PTHREAD_MUTEX_FAST_NP,
- PTHREAD_MUTEX_RECURSIVE_NP,
- PTHREAD_MUTEX_ERRORCHECK_NP,
- PTHREAD_MUTEX_TIMED_NP = PTHREAD_MUTEX_FAST_NP,
- PTHREAD_MUTEX_ADAPTIVE_NP = PTHREAD_MUTEX_FAST_NP,
-
- PTHREAD_MUTEX_NORMAL = PTHREAD_MUTEX_FAST_NP,
- PTHREAD_MUTEX_RECURSIVE = PTHREAD_MUTEX_RECURSIVE_NP,
- PTHREAD_MUTEX_ERRORCHECK = PTHREAD_MUTEX_ERRORCHECK_NP,
- PTHREAD_MUTEX_DEFAULT = PTHREAD_MUTEX_NORMAL
- };
- typedef struct pte_cleanup_t pte_cleanup_t;
- typedef void (* pte_cleanup_callback_t)(void *);
- struct pte_cleanup_t
- {
- pte_cleanup_callback_t routine;
- void *arg;
- struct pte_cleanup_t *prev;
- };
- #ifdef PTE_CLEANUP_C
-
- #define pthread_cleanup_push( _rout, _arg ) \
- { \
- pte_cleanup_t _cleanup; \
- \
- pte_push_cleanup( &_cleanup, (pte_cleanup_callback_t) (_rout), (_arg) ); \
-
- #define pthread_cleanup_pop( _execute ) \
- (void) pte_pop_cleanup( _execute ); \
- }
- #else
- #ifdef PTE_CLEANUP_CXX
-
- class PThreadCleanup
- {
-
- pte_cleanup_callback_t cleanUpRout;
- void * obj;
- int executeIt;
- public:
- PThreadCleanup() :
- cleanUpRout( 0 ),
- obj( 0 ),
- executeIt( 0 )
-
- {
- }
- PThreadCleanup(
- pte_cleanup_callback_t routine,
- void * arg ) :
- cleanUpRout( routine ),
- obj( arg ),
- executeIt( 1 )
-
- {
- }
- ~PThreadCleanup()
- {
- if ( executeIt )
- {
- (void) (*cleanUpRout)( obj );
- }
- }
- void execute( int exec )
- {
- executeIt = exec;
- }
- };
-
- #define pthread_cleanup_push( _rout, _arg ) \
- { \
- PThreadCleanup cleanup((pte_cleanup_callback_t)(_rout), \
- (void *) (_arg) );
- #define pthread_cleanup_pop( _execute ) \
- cleanup.execute( _execute ); \
- }
- #else
- #error ERROR [__FILE__, line __LINE__]: Cleanup type undefined.
- #endif
- #endif
-
- int pthread_init (void);
- void pthread_terminate (void);
-
- int pthread_attr_init (pthread_attr_t * attr);
- int pthread_attr_destroy (pthread_attr_t * attr);
- int pthread_attr_getdetachstate (const pthread_attr_t * attr,
- int *detachstate);
- int pthread_attr_getstackaddr (const pthread_attr_t * attr,
- void **stackaddr);
- int pthread_attr_getstacksize (const pthread_attr_t * attr,
- size_t * stacksize);
- int pthread_attr_setdetachstate (pthread_attr_t * attr,
- int detachstate);
- int pthread_attr_setstackaddr (pthread_attr_t * attr,
- void *stackaddr);
- int pthread_attr_setstacksize (pthread_attr_t * attr,
- size_t stacksize);
- int pthread_attr_getschedparam (const pthread_attr_t *attr,
- struct sched_param *param);
- int pthread_attr_setschedparam (pthread_attr_t *attr,
- const struct sched_param *param);
- int pthread_attr_setschedpolicy (pthread_attr_t *,
- int);
- int pthread_attr_getschedpolicy (pthread_attr_t *,
- int *);
- int pthread_attr_setinheritsched(pthread_attr_t * attr,
- int inheritsched);
- int pthread_attr_getinheritsched(pthread_attr_t * attr,
- int * inheritsched);
- int pthread_attr_setscope (pthread_attr_t *,
- int);
- int pthread_attr_getscope (const pthread_attr_t *,
- int *);
-
- int pthread_create (pthread_t * tid,
- const pthread_attr_t * attr,
- void *(*start) (void *),
- void *arg);
- int pthread_detach (pthread_t tid);
- int pthread_equal (pthread_t t1,
- pthread_t t2);
- void pthread_exit (void *value_ptr);
- int pthread_join (pthread_t thread,
- void **value_ptr);
- pthread_t pthread_self (void);
- int pthread_cancel (pthread_t thread);
- int pthread_setcancelstate (int state,
- int *oldstate);
- int pthread_setcanceltype (int type,
- int *oldtype);
- void pthread_testcancel (void);
- int pthread_once (pthread_once_t * once_control,
- void (*init_routine) (void));
- #if PTE_LEVEL >= PTE_LEVEL_MAX
- pte_cleanup_t * pte_pop_cleanup (int execute);
- void pte_push_cleanup (pte_cleanup_t * cleanup,
- void (*routine) (void *),
- void *arg);
- #endif
-
- int pthread_key_create (pthread_key_t * key,
- void (*destructor) (void *));
- int pthread_key_delete (pthread_key_t key);
- int pthread_setspecific (pthread_key_t key,
- const void *value);
- void * pthread_getspecific (pthread_key_t key);
-
- int pthread_mutexattr_init (pthread_mutexattr_t * attr);
- int pthread_mutexattr_destroy (pthread_mutexattr_t * attr);
- int pthread_mutexattr_getpshared (const pthread_mutexattr_t
- * attr,
- int *pshared);
- int pthread_mutexattr_setpshared (pthread_mutexattr_t * attr,
- int pshared);
- int pthread_mutexattr_settype (pthread_mutexattr_t * attr, int kind);
- int pthread_mutexattr_gettype (pthread_mutexattr_t * attr, int *kind);
-
- int pthread_barrierattr_init (pthread_barrierattr_t * attr);
- int pthread_barrierattr_destroy (pthread_barrierattr_t * attr);
- int pthread_barrierattr_getpshared (const pthread_barrierattr_t
- * attr,
- int *pshared);
- int pthread_barrierattr_setpshared (pthread_barrierattr_t * attr,
- int pshared);
-
- int pthread_mutex_init (pthread_mutex_t * mutex,
- const pthread_mutexattr_t * attr);
- int pthread_mutex_destroy (pthread_mutex_t * mutex);
- int pthread_mutex_lock (pthread_mutex_t * mutex);
- int pthread_mutex_timedlock(pthread_mutex_t *mutex,
- const struct timespec *abstime);
- int pthread_mutex_trylock (pthread_mutex_t * mutex);
- int pthread_mutex_unlock (pthread_mutex_t * mutex);
-
- int pthread_spin_init (pthread_spinlock_t * lock, int pshared);
- int pthread_spin_destroy (pthread_spinlock_t * lock);
- int pthread_spin_lock (pthread_spinlock_t * lock);
- int pthread_spin_trylock (pthread_spinlock_t * lock);
- int pthread_spin_unlock (pthread_spinlock_t * lock);
-
- int pthread_barrier_init (pthread_barrier_t * barrier,
- const pthread_barrierattr_t * attr,
- unsigned int count);
- int pthread_barrier_destroy (pthread_barrier_t * barrier);
- int pthread_barrier_wait (pthread_barrier_t * barrier);
-
- int pthread_condattr_init (pthread_condattr_t * attr);
- int pthread_condattr_destroy (pthread_condattr_t * attr);
- int pthread_condattr_getpshared (const pthread_condattr_t * attr,
- int *pshared);
- int pthread_condattr_setpshared (pthread_condattr_t * attr,
- int pshared);
-
- int pthread_cond_init (pthread_cond_t * cond,
- const pthread_condattr_t * attr);
- int pthread_cond_destroy (pthread_cond_t * cond);
- int pthread_cond_wait (pthread_cond_t * cond,
- pthread_mutex_t * mutex);
- int pthread_cond_timedwait (pthread_cond_t * cond,
- pthread_mutex_t * mutex,
- const struct timespec *abstime);
- int pthread_cond_signal (pthread_cond_t * cond);
- int pthread_cond_broadcast (pthread_cond_t * cond);
-
- int pthread_setschedparam (pthread_t thread,
- int policy,
- const struct sched_param *param);
- int pthread_getschedparam (pthread_t thread,
- int *policy,
- struct sched_param *param);
- int pthread_setconcurrency (int);
- int pthread_getconcurrency (void);
-
- int pthread_rwlock_init(pthread_rwlock_t *lock,
- const pthread_rwlockattr_t *attr);
- int pthread_rwlock_destroy(pthread_rwlock_t *lock);
- int pthread_rwlock_tryrdlock(pthread_rwlock_t *);
- int pthread_rwlock_trywrlock(pthread_rwlock_t *);
- int pthread_rwlock_rdlock(pthread_rwlock_t *lock);
- int pthread_rwlock_timedrdlock(pthread_rwlock_t *lock,
- const struct timespec *abstime);
- int pthread_rwlock_wrlock(pthread_rwlock_t *lock);
- int pthread_rwlock_timedwrlock(pthread_rwlock_t *lock,
- const struct timespec *abstime);
- int pthread_rwlock_unlock(pthread_rwlock_t *lock);
- int pthread_rwlockattr_init (pthread_rwlockattr_t * attr);
- int pthread_rwlockattr_destroy (pthread_rwlockattr_t * attr);
- int pthread_rwlockattr_getpshared (const pthread_rwlockattr_t * attr,
- int *pshared);
- int pthread_rwlockattr_setpshared (pthread_rwlockattr_t * attr,
- int pshared);
- #if PTE_LEVEL >= PTE_LEVEL_MAX - 1
-
- int pthread_kill(pthread_t thread, int sig);
-
-
- int pthread_mutexattr_setkind_np(pthread_mutexattr_t * attr,
- int kind);
- int pthread_mutexattr_getkind_np(pthread_mutexattr_t * attr,
- int *kind);
-
- int pthread_delay_np (struct timespec * interval);
- int pthread_num_processors_np(void);
-
- void * pthread_timechange_handler_np(void *);
- #endif
- #if PTE_LEVEL >= PTE_LEVEL_MAX
- #endif
-
- # define _ftime ftime
- # define _timeb timeb
- #ifdef __cplusplus
-
- class pte_exception {};
- class pte_exception_cancel : public pte_exception {};
- class pte_exception_exit : public pte_exception {};
- #endif
- #ifdef PTE_CXX_EXCEPTIONS
-
- #define catch( E ) \
- catch( pte_exception & ) { throw; } \
- catch( E )
- #endif
- #undef PTE_LEVEL
- #undef PTE_LEVEL_MAX
- #endif
|