12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010 |
- #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
- #ifdef __cplusplus
- extern "C" {
- #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
- #ifdef __cplusplus
- }
- #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
|