diff options
Diffstat (limited to 'PACE/pace/posix/pthread.h')
| -rw-r--r-- | PACE/pace/posix/pthread.h | 222 |
1 files changed, 176 insertions, 46 deletions
diff --git a/PACE/pace/posix/pthread.h b/PACE/pace/posix/pthread.h index b998c50e7c1..61d5ef55c78 100644 --- a/PACE/pace/posix/pthread.h +++ b/PACE/pace/posix/pthread.h @@ -13,69 +13,199 @@ * * ============================================================================ */ -#ifndef PACE_PTHREAD_H_POSIX -#define PACE_PTHREAD_H_POSIX +#ifndef PACE_PTHREAD_H +#define PACE_PTHREAD_H -#include <pthread.h> #include "pace/sys/types.h" #include "pace/signal.h" +#include <pthread.h> #if defined (PACE_HAS_CPLUSPLUS) extern "C" { #endif /* PACE_HAS_CPLUSPLUS */ -#define PACE_PTHREAD_CANCELED PTHREAD_CANCELED -#define PACE_PTHREAD_CANCEL_AYNCHRONOUS PTHREAD_CANCEL_ASYNCHRONOUS -#define PACE_PTHREAD_CANCEL_DEFERRED PTHREAD_CANCEL_DEFERRED -#define PACE_PTHREAD_CACEL_DISABLE PTHREAD_CANCEL_DISABLE -#define PACE_PTHREAD_CANCEL_ENABLE PTHREAD_CANCEL_ENABLE -#define PACE_PTHREAD_COND_INITIALIZER PTHREAD_COND_INITIALIZER -#define PACE_PTHREAD_CREATE_DETACHED PTHREAD_CREATE_DETACHED -#define PACE_PTHREAD_CREATE_JOINABLE PTHREAD_CREATE_JOINABLE -#define PACE_PTHREAD_EXPLICIT_SCHED PTHREAD_EXPLICIT_SCHED -#define PACE_PTHREAD_INHERIT_SCHED PTHREAD_INHERIT_SCHED -#define PACE_PTHREAD_MUTEX_INITIALIZER PTHREAD_MUTEX_INITIALIZER -#define PACE_PTHREAD_ONCE_INIT PTHREAD_ONCE_INIT -#define PACE_PTHREAD_PRIO_INHERIT PTHREAD_PRIO_INHERIT -#define PACE_PTHREAD_PRIO_NONE PTHREAD_PRIO_NONE -#define PACE_PTHREAD_PRIO_PROTECT PTHREAD_PRIO_PROTECT -#define PACE_PTHREAD_PROCESS_PRIVATE PTHREAD_PROCESS_PRIVATE -#define PACE_PTHREAD_PROCESS_SHARED PTHREAD_PROCESS_SHARED -#define PACE_PTHREAD_SCOPE_PROCESS PTHREAD_SCOPE_PROCESS -#define PACE_PTHREAD_SCOPE_SYSTEM PTHREAD_SCOPE_SYSTEM - -#ifndef PACE_SCHED_PARAM -#define PACE_SCHED_PARAM - typedef struct sched_param pace_sched_param; -#endif /* PACE_SCHED_PARAM */ + PACE_INLINE int pace_pthread_atfork (void (*prepare) (), + void (*parent) (), + void (*child) ()); -#if defined (PACE_HAS_CPLUSPLUS) -# ifndef PACE_ATFORK_PF -# define PACE_ATFORK_PF - typedef void (*pace_atfork_pf) (void); -# endif /* PACE_ATFORK_PF */ + PACE_INLINE int pace_pthread_attr_destroy (pace_pthread_attr_t * attr); + + PACE_INLINE int pace_pthread_attr_getdetachstate (const pace_pthread_attr_t * attr, + int * detachstate); + + PACE_INLINE int pace_pthread_attr_getinheritsched (const pace_pthread_attr_t * attr, + int * inheritsched); + + PACE_INLINE int pace_pthread_attr_getschedparam (const pace_pthread_attr_t * attr, + struct sched_param * param); + + PACE_INLINE int pace_pthread_attr_getschedpolicy (const pace_pthread_attr_t * attr, + int * policy); + + PACE_INLINE int pace_pthread_attr_getscope (const pace_pthread_attr_t * attr, + int * contentionscope); + + PACE_INLINE int pace_pthread_attr_getstackaddr (const pace_pthread_attr_t * attr, + void ** stackaddr); + + PACE_INLINE int pace_pthread_attr_getstacksize (const pace_pthread_attr_t * attr, + size_t * stacksize); + + PACE_INLINE int pace_pthread_attr_init (pace_pthread_attr_t * attr); + + PACE_INLINE int pace_pthread_attr_setdetachstate (pace_pthread_attr_t * attr, + int detachstate); + + PACE_INLINE int pace_pthread_attr_setinheritsched (pace_pthread_attr_t * attr, + int inheritsched); + + PACE_INLINE int pace_pthread_attr_setschedparam (pace_pthread_attr_t * attr, + const struct + sched_param * param); + + PACE_INLINE int pace_pthread_attr_setschedpolicy (pace_pthread_attr_t * attr, + int policy); + + PACE_INLINE int pace_pthread_attr_setscope (pace_pthread_attr_t * attr, + int contentionscope); + + PACE_INLINE int pace_pthread_attr_setstackaddr (pace_pthread_attr_t * attr, + void * stackaddr); + + PACE_INLINE int pace_pthread_attr_setstacksize (pace_pthread_attr_t * attr, + size_t stacksize); + + PACE_INLINE int pace_pthread_cancel (pace_pthread_t thread); + + PACE_INLINE void pace_cleanup_pop (int execute); + + PACE_INLINE void pace_pthread_cleanup_push (void (*routine)(void*), void * arg); + + # define PACE_PTHREAD_COND_INITIALIZER PTHREAD_COND_INITIALIZER + + PACE_INLINE int pace_pthread_cond_broadcast (pace_pthread_cond_t * cond); + + PACE_INLINE int pace_pthread_cond_destroy (pace_pthread_cond_t * cond); + + PACE_INLINE int pace_pthread_cond_init (pace_pthread_cond_t * cond, + const pace_pthread_condattr_t * attr); + + PACE_INLINE int pace_pthread_cond_signal (pace_pthread_cond_t * cond); + + PACE_INLINE int pace_pace_pthread_cond_timedwait (pthread_cond_t * cond, + pace_pthread_mutex_t * mutex, + const struct timespec * abstime); + + PACE_INLINE int pace_pthread_cond_wait (pace_pthread_cond_t * cond, + pace_pthread_mutex_t * mutex); + + PACE_INLINE int pace_pthread_condattr_destroy (pace_pthread_condattr_t * attr); + + PACE_INLINE int pace_pthread_condattr_getpshared (const pace_pthread_condattr_t * attr, + int * pshared); + + PACE_INLINE int pace_pthead_condattr_init (pace_pthread_condattr_t * attr); -# ifndef PACE_KEYCREATE_PF -# define PACE_KEYCREATE_PF - typedef void (*pace_keycreate_pf) (void*); -# endif /* PACE_KEYCREATE_PF */ + PACE_INLINE int pace_pthread_condattr_setpshared (pace_pthread_condattr_t * attr, + int pshared); -# ifndef PACE_ONCE_PF -# define PACE_ONCE_PF - typedef void (*pace_once_pf) (void); -# endif /* PACE_ONCE_PF */ + PACE_INLINE int pace_pthread_create (pace_pthread_t * thread, + const pace_pthread_attr_t * attr, + void * (*start_routine) (void*), + void * arg); -# ifndef PACE_CREATE_PF -# define PACE_CREATE_PF - typedef void* (*pace_create_pf) (void*); -# endif /* PACE_CREATE_PF */ + PACE_INLINE int pace_pthread_detach (pace_pthread_t thread); -#endif /* PACE_HAS_CPLUPLUS */ + PACE_INLINE int pace_pthread_equal (pace_pthread_t t1, pthread_t t2); + PACE_INLINE void pace_pthread_exit (void * value_ptr); + PACE_INLINE int pace_pthread_getschedparam (pace_pthread_t thread, + int * policy, + struct sched_param * param); + + PACE_INLINE void * pace_pthread_getspecific (pace_pthread_key_t key); + + PACE_INLINE int pace_pthread_join (pace_pthread_t thread, void ** value_ptr); + + PACE_INLINE int pace_pthread_key_create (pace_pthread_key_t * key, + void (*destructor)(void*)); + + PACE_INLINE int pace_pthread_key_delete (pace_pthread_key_t key); + + PACE_INLINE int pace_pthread_kill (pace_pthread_t thread, int sig); + + # define PACE_PTHREAD_MUTEX_INITIALIZER PTHREAD_MUTEX_INITIALIZER + + PACE_INLINE int pace_pthread_mutex_destroy (pace_pthread_mutex_t * mutex); + + PACE_INLINE int pace_pthread_mutex_getprioceiling (pace_pthread_mutex_t * mutex, + int * prioceiling); + + PACE_INLINE int pace_pthread_mutex_init (pace_pthread_mutex_t * mutex, + const pace_pthread_mutexattr_t * attr); + + PACE_INLINE int pace_pthread_mutex_lock (pace_pthread_mutex_t * mutex); + + PACE_INLINE int pace_pthread_mutex_setprioceiling (pace_pthread_mutex_t * mutex, + int prioceiling, + int * old_ceiling); + + PACE_INLINE int pace_pace_pthread_mutex_trylock (pthread_mutex_t * mutex); + + PACE_INLINE int pace_pthread_mutex_unlock (pace_pthread_mutex_t * mutex); + + PACE_INLINE int pace_pthread_mutexattr_destroy (pace_pthread_mutexattr_t * sttr); + + PACE_INLINE int pace_pthread_mutexattr_getprioceiling (pace_pthread_mutexattr_t * attr, + int * prioceiling); + + PACE_INLINE int pace_pthread_mutexattr_getprotocol + (const pace_pthread_mutexattr_t * attr, int * protocol); + + PACE_INLINE int pace_pthread_mutexattr_setprioceiling (pace_pthread_mutexattr_t * attr, + int prioceiling); + + PACE_INLINE int pace_pthread_mutexattr_setprotocol (pace_pthread_mutexattr_t * attr, + int protocol); + PACE_INLINE int + pace_pthread_mutexattr_getpshared (const pace_pthread_mutexattr_t * attr, + int * pshared); + + PACE_INLINE int pace_pthread_mutexattr_init (pace_pthread_mutexattr_t * attr); + + PACE_INLINE int pace_pthread_mutexattr_setpshared (pace_pthread_mutexattr_t * attr, + int pshared); + + PACE_INLINE int pace_pthread_once (pace_pthread_once_t * once_control, + void (*void_routine) ()); + + # define PACE_PTHREAD_ONCE_INIT PTHREAD_ONCE_INIT + + PACE_INLINE pace_pthread_t pace_pthread_self (); + + PACE_INLINE int pace_pthread_setcancelstate (int state, int * oldstate); + + PACE_INLINE int pace_pthread_setcanceltype (int type, int * oldtype); + + PACE_INLINE int pace_pthread_setschedparam (pace_pthread_t thread, + int policy, + const struct sched_param * param); + + PACE_INLINE int pace_pthread_setspecific (pace_pthread_key_t key, const void * value); + + PACE_INLINE int pace_pthread_sigmask (int how, + const sigset_t * set, + sigset_t * oset); + + PACE_INLINE void pace_pace_pthread_testcancel (); #if defined (PACE_HAS_CPLUSPLUS) } #endif /* PACE_HAS_CPLUSPLUS */ -#endif /* PACE_PTHREAD_H_POSIX */ +#if defined (PACE_HAS_INLINE) +# include "pace/posix/pthread.inl" +#endif /* PACE_HAS_INLINE */ + +#endif /* PACE_PTHREAD_H */ |