/* * pthread.h * * This is an implementation of the threads API of the Single Unix Specification. * * -------------------------------------------------------------------------- * * Pthreads-win32 - POSIX Threads Library for Win32 * Copyright(C) 1998 John E. Bossom * Copyright(C) 1999,2013 Pthreads-win32 contributors * * Homepage1: http://sourceware.org/pthreads-win32/ * Homepage2: http://sourceforge.net/projects/pthreads4w/ * * The current list of contributors is contained * in the file CONTRIBUTORS included with the source * code distribution. The list can also be seen at the * following World Wide Web location: * http://sources.redhat.com/pthreads-win32/contributors.html * * This library is free software; you can redistribute it and/or * modify it under the terms of the GNU Lesser General Public * License as published by the Free Software Foundation; either * version 2 of the License, or (at your option) any later version. * * This library is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU * Lesser General Public License for more details. * * You should have received a copy of the GNU Lesser General Public * License along with this library in the file COPYING.LIB; * if not, write to the Free Software Foundation, Inc., * 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA */ #ifndef _PTHREAD_H #define _PTHREAD_H /* There are three implementations of cancel cleanup. * Note that pthread.h is included in both application * compilation units and also internally for the library. * The code here and within the library aims to work * for all reasonable combinations of environments. * * The three implementations are: * * WIN32 SEH * C * C++ * * Please note that exiting a push/pop block via * "return", "exit", "break", or "continue" will * lead to different behaviour amongst applications * depending upon whether the library was built * using SEH, C++, or C. For example, a library built * with SEH will call the cleanup routine, while both * C++ and C built versions will not. */ /* Define defaults for cleanup code. * Note: Unless the build explicitly defines one of the following, then * we default to standard C style cleanup. This style uses setjmp/longjmp * in the cancellation and thread exit implementations and therefore won't * do stack unwinding if linked to applications that have it (e.g. * C++ apps). This is currently consistent with most/all commercial Unix * POSIX threads implementations. */ #if !defined(__CLEANUP_SEH) && !defined(__CLEANUP_CXX) && !defined(__CLEANUP_C) # define __CLEANUP_C #endif #if defined(__CLEANUP_SEH) && (!defined(_MSC_VER) && !defined(__PTW32_RC_MSC)) #error ERROR [__FILE__, line __LINE__]: SEH is not supported for this compiler. #endif #include <_ptw32.h> /* * Stop here if we are being included by the resource compiler. */ #if !defined(RC_INVOKED) #undef __PTW32_LEVEL #undef __PTW32_LEVEL_MAX #define __PTW32_LEVEL_MAX 3 #if _POSIX_C_SOURCE >= 200112L /* POSIX.1-2001 and later */ # define __PTW32_LEVEL __PTW32_LEVEL_MAX /* include everything */ #elif defined INCLUDE_NP /* earlier than POSIX.1-2001, but... */ # define __PTW32_LEVEL 2 /* include non-portable extensions */ #elif _POSIX_C_SOURCE >= 199309L /* POSIX.1-1993 */ # define __PTW32_LEVEL 1 /* include 1b, 1c, and 1d */ #elif defined _POSIX_SOURCE /* early POSIX */ # define __PTW32_LEVEL 0 /* minimal support */ #else /* unspecified support level */ # define __PTW32_LEVEL __PTW32_LEVEL_MAX /* include everything anyway */ #endif /* ------------------------------------------------------------- * * Module: pthread.h * * Purpose: * Provides an implementation of PThreads based upon the * standard: * * POSIX 1003.1-2001 * and * The Single Unix Specification version 3 * * (these two are equivalent) * * in order to enhance code portability between Windows, * various commercial Unix implementations, and Linux. * * See the ANNOUNCE file for a full list of conforming * routines and defined constants, and a list of missing * routines and constants not defined in this implementation. * * Authors: * There have been many contributors to this library. * The initial implementation was contributed by * John Bossom, and several others have provided major * sections or revisions of parts of the implementation. * Often significant effort has been contributed to * find and fix important bugs and other problems to * improve the reliability of the library, which sometimes * is not reflected in the amount of code which changed as * result. * As much as possible, the contributors are acknowledged * in the ChangeLog file in the source code distribution * where their changes are noted in detail. * * Contributors are listed in the CONTRIBUTORS file. * * As usual, all bouquets go to the contributors, and all * brickbats go to the project maintainer. * * Maintainer: * The code base for this project is coordinated and * eventually pre-tested, packaged, and made available by * * Ross Johnson * * QA Testers: * Ultimately, the library is tested in the real world by * a host of competent and demanding scientists and * engineers who report bugs and/or provide solutions * which are then fixed or incorporated into subsequent * versions of the library. Each time a bug is fixed, a * test case is written to prove the fix and ensure * that later changes to the code don't reintroduce the * same error. The number of test cases is slowly growing * and therefore so is the code reliability. * * Compliance: * See the file ANNOUNCE for the list of implemented * and not-implemented routines and defined options. * Of course, these are all defined is this file as well. * * Web site: * The source code and other information about this library * are available from * * http://sources.redhat.com/pthreads-win32/ * * ------------------------------------------------------------- */ enum { /* Boolean values to make us independent of system includes. */ PTW32_FALSE = 0, PTW32_TRUE = (! PTW32_FALSE) }; #include #include /* ------------------------------------------------------------- * * POSIX 1003.1-2001 Options * ========================= * * Options are normally set in , which is not provided * with pthreads-win32. * * For conformance with the Single Unix Specification (version 3), all of the * options below are defined, and have a value of either -1 (not supported) * or yyyymm[dd]L (supported). * * These options can neither be left undefined nor have a value of 0, because * either indicates that sysconf(), which is not implemented, may be used at * runtime to check the status of the option. * * _POSIX_THREADS (== 20080912L) * If == 20080912L, you can use threads * * _POSIX_THREAD_ATTR_STACKSIZE (== 200809L) * If == 200809L, you can control the size of a thread's * stack * pthread_attr_getstacksize * pthread_attr_setstacksize * * _POSIX_THREAD_ATTR_STACKADDR (== -1) * If == 200809L, you can allocate and control a thread's * stack. If not supported, the following functions * will return ENOSYS, indicating they are not * supported: * pthread_attr_getstackaddr * pthread_attr_setstackaddr * * _POSIX_THREAD_PRIORITY_SCHEDULING (== -1) * If == 200112L, you can use realtime scheduling. * This option indicates that the behaviour of some * implemented functions conforms to the additional TPS * requirements in the standard. E.g. rwlocks favour * writers over readers when threads have equal priority. * * _POSIX_THREAD_PRIO_INHERIT (== -1) * If == 200809L, you can create priority inheritance * mutexes. * pthread_mutexattr_getprotocol + * pthread_mutexattr_setprotocol + * * _POSIX_THREAD_PRIO_PROTECT (== -1) * If == 200809L, you can create priority ceiling mutexes * Indicates the availability of: * pthread_mutex_getprioceiling * pthread_mutex_setprioceiling * pthread_mutexattr_getprioceiling * pthread_mutexattr_getprotocol + * pthread_mutexattr_setprioceiling * pthread_mutexattr_setprotocol + * * _POSIX_THREAD_PROCESS_SHARED (== -1) * If set, you can create mutexes and condition * variables that can be shared with another * process.If set, indicates the availability * of: * pthread_mutexattr_getpshared * pthread_mutexattr_setpshared * pthread_condattr_getpshared * pthread_condattr_setpshared * * _POSIX_THREAD_SAFE_FUNCTIONS (== 200809L) * If == 200809L you can use the special *_r library * functions that provide thread-safe behaviour * * _POSIX_READER_WRITER_LOCKS (== 200809L) * If == 200809L, you can use read/write locks * * _POSIX_SPIN_LOCKS (== 200809L) * If == 200809L, you can use spin locks * * _POSIX_BARRIERS (== 200809L) * If == 200809L, you can use barriers * * _POSIX_ROBUST_MUTEXES (== 200809L) * If == 200809L, you can use robust mutexes * Officially this should also imply * _POSIX_THREAD_PROCESS_SHARED != -1 however * not here yet. * * ------------------------------------------------------------- */ /* POSIX Options */ #undef _POSIX_THREADS #define _POSIX_THREADS 200809L #undef _POSIX_READER_WRITER_LOCKS #define _POSIX_READER_WRITER_LOCKS 200809L #undef _POSIX_SPIN_LOCKS #define _POSIX_SPIN_LOCKS 200809L #undef _POSIX_BARRIERS #define _POSIX_BARRIERS 200809L #undef _POSIX_THREAD_SAFE_FUNCTIONS #define _POSIX_THREAD_SAFE_FUNCTIONS 200809L #undef _POSIX_THREAD_ATTR_STACKSIZE #define _POSIX_THREAD_ATTR_STACKSIZE 200809L #undef _POSIX_ROBUST_MUTEXES #define _POSIX_ROBUST_MUTEXES 200809L /* The following options are not supported */ #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 /* TPS is not fully supported. */ #undef _POSIX_THREAD_PRIORITY_SCHEDULING #define _POSIX_THREAD_PRIORITY_SCHEDULING -1 #undef _POSIX_THREAD_PROCESS_SHARED #define _POSIX_THREAD_PROCESS_SHARED -1 /* POSIX 1003.1-2001 Limits * =========================== * * These limits are normally set in , which is not provided with * pthreads-win32. * * PTHREAD_DESTRUCTOR_ITERATIONS * Maximum number of attempts to destroy * a thread's thread-specific data on * termination (must be at least 4) * * PTHREAD_KEYS_MAX * Maximum number of thread-specific data keys * available per process (must be at least 128) * * PTHREAD_STACK_MIN * Minimum supported stack size for a thread * * PTHREAD_THREADS_MAX * Maximum number of threads supported per * process (must be at least 64). * * SEM_NSEMS_MAX * The maximum number of semaphores a process can have. * (must be at least 256) * * SEM_VALUE_MAX * The maximum value a semaphore can have. * (must be at least 32767) * */ #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 /* Arbitrary value */ #undef PTHREAD_THREADS_MAX #define PTHREAD_THREADS_MAX 2019 #undef _POSIX_SEM_NSEMS_MAX #define _POSIX_SEM_NSEMS_MAX 256 /* Arbitrary value */ #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 #if defined(_UWIN) && __PTW32_LEVEL >= __PTW32_LEVEL_MAX # include #else /* Generic handle type - intended to provide the lifetime-uniqueness that * a simple pointer can't. It should scale for either * 32 or 64 bit systems. * * The constraint with this approach is that applications must * strictly comply with POSIX, e.g. not assume scalar type, only * compare pthread_t using the API function pthread_equal(), etc. * * Applications can use the element 'p' to compare, e.g. for sorting, * but it will be up to the application to determine if handles are * live or dead, or resurrected for an entirely new/different thread. */ typedef struct { void * p; /* Pointer to actual object */ #if __PTW32_VERSION_MAJOR > 2 size_t x; /* Extra information - reuse count etc */ #else unsigned int x; /* Extra information - reuse count etc */ #endif } ptw32_handle_t; typedef ptw32_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; #endif 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; /* ==================== * ==================== * POSIX Threads * ==================== * ==================== */ enum { /* pthread_attr_{get,set}detachstate */ PTHREAD_CREATE_JOINABLE = 0, /* Default */ PTHREAD_CREATE_DETACHED = 1, /* * pthread_attr_{get,set}inheritsched */ PTHREAD_INHERIT_SCHED = 0, PTHREAD_EXPLICIT_SCHED = 1, /* Default */ /* * pthread_{get,set}scope */ PTHREAD_SCOPE_PROCESS = 0, PTHREAD_SCOPE_SYSTEM = 1, /* Default */ /* * pthread_setcancelstate paramters */ PTHREAD_CANCEL_ENABLE = 0, /* Default */ PTHREAD_CANCEL_DISABLE = 1, /* * pthread_setcanceltype parameters */ PTHREAD_CANCEL_ASYNCHRONOUS = 0, PTHREAD_CANCEL_DEFERRED = 1, /* Default */ /* * pthread_mutexattr_{get,set}pshared * pthread_condattr_{get,set}pshared */ PTHREAD_PROCESS_PRIVATE = 0, PTHREAD_PROCESS_SHARED = 1, /* * pthread_mutexattr_{get,set}robust */ PTHREAD_MUTEX_STALLED = 0, /* Default */ PTHREAD_MUTEX_ROBUST = 1, /* * pthread_barrier_wait */ PTHREAD_BARRIER_SERIAL_THREAD = -1 }; /* ==================== * ==================== * cancellation * ==================== * ==================== */ #define PTHREAD_CANCELED ((void *)(size_t) -1) /* ==================== * ==================== * Once Key * ==================== * ==================== */ #if __PTW32_VERSION_MAJOR > 2 #define PTHREAD_ONCE_INIT { PTW32_FALSE, 0 } struct pthread_once_t_ { void * lock; /* MCS lock */ int done; /* indicates if user function has been executed */ }; #else #define PTHREAD_ONCE_INIT { PTW32_FALSE, 0, 0, 0 } struct pthread_once_t_ { int done; /* indicates if user function has been executed */ void * lock; /* MCS lock */ int reserved1; int reserved2; }; #endif /* ==================== * ==================== * Object initialisers * ==================== * ==================== */ #define PTHREAD_MUTEX_INITIALIZER ((pthread_mutex_t)(size_t) -1) #define PTHREAD_RECURSIVE_MUTEX_INITIALIZER ((pthread_mutex_t)(size_t) -2) #define PTHREAD_ERRORCHECK_MUTEX_INITIALIZER ((pthread_mutex_t)(size_t) -3) /* Compatibility with LinuxThreads */ #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)(size_t) -1) #define PTHREAD_RWLOCK_INITIALIZER ((pthread_rwlock_t)(size_t) -1) #define PTHREAD_SPINLOCK_INITIALIZER ((pthread_spinlock_t)(size_t) -1) /* Mutex types. */ enum { /* Compatibility with LinuxThreads */ 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, /* For compatibility with POSIX */ 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 ptw32_cleanup_t ptw32_cleanup_t; #if defined(_MSC_VER) /* Disable MSVC 'anachronism used' warning */ #pragma warning( disable : 4229 ) #endif typedef void (* __PTW32_CDECL ptw32_cleanup_callback_t)(void *); #if defined(_MSC_VER) #pragma warning( default : 4229 ) #endif struct ptw32_cleanup_t { ptw32_cleanup_callback_t routine; void *arg; struct ptw32_cleanup_t *prev; }; #if defined(__CLEANUP_SEH) /* WIN32 SEH version of cancel cleanup. */ #define pthread_cleanup_push( _rout, _arg ) \ { \ ptw32_cleanup_t _cleanup; \ \ _cleanup.routine = (ptw32_cleanup_callback_t)(_rout); \ _cleanup.arg = (_arg); \ __try \ { \ #define pthread_cleanup_pop( _execute ) \ } \ __finally \ { \ if( _execute || AbnormalTermination()) \ { \ (*(_cleanup.routine))( _cleanup.arg ); \ } \ } \ } #else /* !__CLEANUP_SEH */ #if defined(__CLEANUP_C) /* C implementation of PThreads cancel cleanup */ #define pthread_cleanup_push( _rout, _arg ) \ { \ ptw32_cleanup_t _cleanup; \ \ ptw32_push_cleanup( &_cleanup, (ptw32_cleanup_callback_t) (_rout), (_arg) ); \ #define pthread_cleanup_pop( _execute ) \ (void) ptw32_pop_cleanup( _execute ); \ } #else /* !__CLEANUP_C */ #if defined(__CLEANUP_CXX) /* C++ version of cancel cleanup. * - John E. Bossom. */ class PThreadCleanup { /* * PThreadCleanup * * Purpose * This class is a C++ helper class that is * used to implement pthread_cleanup_push/ * pthread_cleanup_pop. * The destructor of this class automatically * pops the pushed cleanup routine regardless * of how the code exits the scope * (i.e. such as by an exception) */ ptw32_cleanup_callback_t cleanUpRout; void * obj; int executeIt; public: PThreadCleanup() : cleanUpRout( 0 ), obj( 0 ), executeIt( 0 ) /* * No cleanup performed */ { } PThreadCleanup( ptw32_cleanup_callback_t routine, void * arg ) : cleanUpRout( routine ), obj( arg ), executeIt( 1 ) /* * Registers a cleanup routine for 'arg' */ { } ~PThreadCleanup() { if ( executeIt && ((void *) cleanUpRout != (void *) 0) ) { (void) (*cleanUpRout)( obj ); } } void execute( int exec ) { executeIt = exec; } }; /* C++ implementation of PThreads cancel cleanup; * This implementation takes advantage of a helper * class who's destructor automatically calls the * cleanup routine if we exit our scope weirdly */ #define pthread_cleanup_push( _rout, _arg ) \ { \ PThreadCleanup cleanup((ptw32_cleanup_callback_t)(_rout), \ (void *) (_arg) ); #define pthread_cleanup_pop( _execute ) \ cleanup.execute( _execute ); \ } #else #error ERROR [__FILE__, line __LINE__]: Cleanup type undefined. #endif /* __CLEANUP_CXX */ #endif /* __CLEANUP_C */ #endif /* __CLEANUP_SEH */ /* * =============== * =============== * Methods * =============== * =============== */ __PTW32_BEGIN_C_DECLS /* PThread Attribute Functions */ __PTW32_DECLSPEC int pthread_attr_init (pthread_attr_t *); __PTW32_DECLSPEC int pthread_attr_destroy (pthread_attr_t *); __PTW32_DECLSPEC int pthread_attr_getaffinity_np (const pthread_attr_t *, size_t, cpu_set_t *); __PTW32_DECLSPEC int pthread_attr_getdetachstate (const pthread_attr_t *, int *); __PTW32_DECLSPEC int pthread_attr_getstackaddr (const pthread_attr_t *, void **); __PTW32_DECLSPEC int pthread_attr_getstacksize (const pthread_attr_t *, size_t *); __PTW32_DECLSPEC int pthread_attr_setaffinity_np (pthread_attr_t *, size_t, const cpu_set_t *); __PTW32_DECLSPEC int pthread_attr_setdetachstate (pthread_attr_t *, int); __PTW32_DECLSPEC int pthread_attr_setstackaddr (pthread_attr_t *, void *); __PTW32_DECLSPEC int pthread_attr_setstacksize (pthread_attr_t *, size_t); __PTW32_DECLSPEC int pthread_attr_getschedparam (const pthread_attr_t *, struct sched_param *); __PTW32_DECLSPEC int pthread_attr_setschedparam (pthread_attr_t *, const struct sched_param *); __PTW32_DECLSPEC int pthread_attr_setschedpolicy (pthread_attr_t *, int); __PTW32_DECLSPEC int pthread_attr_getschedpolicy (const pthread_attr_t *, int *); __PTW32_DECLSPEC int pthread_attr_setinheritsched (pthread_attr_t *, int); __PTW32_DECLSPEC int pthread_attr_getinheritsched (const pthread_attr_t *, int * inheritsched); __PTW32_DECLSPEC int pthread_attr_setscope (pthread_attr_t *, int); __PTW32_DECLSPEC int pthread_attr_getscope (const pthread_attr_t *, int *); /* PThread Functions */ __PTW32_DECLSPEC int pthread_create (pthread_t *, const pthread_attr_t *, void *(__PTW32_CDECL *)(void *), void *); __PTW32_DECLSPEC int pthread_detach (pthread_t); __PTW32_DECLSPEC int pthread_equal (pthread_t, pthread_t); __PTW32_DECLSPEC void pthread_exit (void *); __PTW32_DECLSPEC int pthread_join (pthread_t, void **); __PTW32_DECLSPEC pthread_t pthread_self (void); __PTW32_DECLSPEC int pthread_cancel (pthread_t); __PTW32_DECLSPEC int pthread_setcancelstate (int, int *); __PTW32_DECLSPEC int pthread_setcanceltype (int, int *); __PTW32_DECLSPEC void pthread_testcancel (void); __PTW32_DECLSPEC int pthread_once (pthread_once_t *, void (__PTW32_CDECL *)(void)); #if __PTW32_LEVEL >= __PTW32_LEVEL_MAX __PTW32_DECLSPEC ptw32_cleanup_t * ptw32_pop_cleanup (int); __PTW32_DECLSPEC void ptw32_push_cleanup (ptw32_cleanup_t *, ptw32_cleanup_callback_t, void *); #endif /* __PTW32_LEVEL >= __PTW32_LEVEL_MAX */ /* Thread Specific Data Functions */ __PTW32_DECLSPEC int pthread_key_create (pthread_key_t *, void (__PTW32_CDECL *)(void *)); __PTW32_DECLSPEC int pthread_key_delete (pthread_key_t); __PTW32_DECLSPEC int pthread_setspecific (pthread_key_t, const void *); __PTW32_DECLSPEC void * pthread_getspecific (pthread_key_t); /* Mutex Attribute Functions */ __PTW32_DECLSPEC int pthread_mutexattr_init (pthread_mutexattr_t *); __PTW32_DECLSPEC int pthread_mutexattr_destroy (pthread_mutexattr_t *); __PTW32_DECLSPEC int pthread_mutexattr_getpshared (const pthread_mutexattr_t *, int *); __PTW32_DECLSPEC int pthread_mutexattr_setpshared (pthread_mutexattr_t *, int); __PTW32_DECLSPEC int pthread_mutexattr_settype (pthread_mutexattr_t *, int); __PTW32_DECLSPEC int pthread_mutexattr_gettype (const pthread_mutexattr_t *, int *); __PTW32_DECLSPEC int pthread_mutexattr_setrobust (pthread_mutexattr_t *, int); __PTW32_DECLSPEC int pthread_mutexattr_getrobust ( const pthread_mutexattr_t *, int *); /* Barrier Attribute Functions */ __PTW32_DECLSPEC int pthread_barrierattr_init (pthread_barrierattr_t *); __PTW32_DECLSPEC int pthread_barrierattr_destroy (pthread_barrierattr_t *); __PTW32_DECLSPEC int pthread_barrierattr_getpshared (const pthread_barrierattr_t *, int *); __PTW32_DECLSPEC int pthread_barrierattr_setpshared (pthread_barrierattr_t *, int); /* Mutex Functions */ __PTW32_DECLSPEC int pthread_mutex_init (pthread_mutex_t *, const pthread_mutexattr_t *); __PTW32_DECLSPEC int pthread_mutex_destroy (pthread_mutex_t *); __PTW32_DECLSPEC int pthread_mutex_lock (pthread_mutex_t *); __PTW32_DECLSPEC int pthread_mutex_timedlock (pthread_mutex_t *, const struct timespec *); __PTW32_DECLSPEC int pthread_mutex_trylock (pthread_mutex_t *); __PTW32_DECLSPEC int pthread_mutex_unlock (pthread_mutex_t *); __PTW32_DECLSPEC int pthread_mutex_consistent (pthread_mutex_t *); /* Spinlock Functions */ __PTW32_DECLSPEC int pthread_spin_init (pthread_spinlock_t *, int); __PTW32_DECLSPEC int pthread_spin_destroy (pthread_spinlock_t *); __PTW32_DECLSPEC int pthread_spin_lock (pthread_spinlock_t *); __PTW32_DECLSPEC int pthread_spin_trylock (pthread_spinlock_t *); __PTW32_DECLSPEC int pthread_spin_unlock (pthread_spinlock_t *); /* Barrier Functions */ __PTW32_DECLSPEC int pthread_barrier_init (pthread_barrier_t *, const pthread_barrierattr_t *, unsigned int); __PTW32_DECLSPEC int pthread_barrier_destroy (pthread_barrier_t *); __PTW32_DECLSPEC int pthread_barrier_wait (pthread_barrier_t *); /* Condition Variable Attribute Functions */ __PTW32_DECLSPEC int pthread_condattr_init (pthread_condattr_t *); __PTW32_DECLSPEC int pthread_condattr_destroy (pthread_condattr_t *); __PTW32_DECLSPEC int pthread_condattr_getpshared (const pthread_condattr_t *, int *); __PTW32_DECLSPEC int pthread_condattr_setpshared (pthread_condattr_t *, int); /* Condition Variable Functions */ __PTW32_DECLSPEC int pthread_cond_init (pthread_cond_t *, const pthread_condattr_t *); __PTW32_DECLSPEC int pthread_cond_destroy (pthread_cond_t * cond); __PTW32_DECLSPEC int pthread_cond_wait (pthread_cond_t *, pthread_mutex_t *); __PTW32_DECLSPEC int pthread_cond_timedwait (pthread_cond_t *, pthread_mutex_t *, const struct timespec *); __PTW32_DECLSPEC int pthread_cond_signal (pthread_cond_t *); __PTW32_DECLSPEC int pthread_cond_broadcast (pthread_cond_t *); /* Scheduling */ __PTW32_DECLSPEC int pthread_setschedparam (pthread_t, int, const struct sched_param *); __PTW32_DECLSPEC int pthread_getschedparam (pthread_t, int *, struct sched_param *); __PTW32_DECLSPEC int pthread_setconcurrency (int); __PTW32_DECLSPEC int pthread_getconcurrency (void); /* Read-Write Lock Functions */ __PTW32_DECLSPEC int pthread_rwlock_init (pthread_rwlock_t *, const pthread_rwlockattr_t *); __PTW32_DECLSPEC int pthread_rwlock_destroy (pthread_rwlock_t *); __PTW32_DECLSPEC int pthread_rwlock_tryrdlock (pthread_rwlock_t *); __PTW32_DECLSPEC int pthread_rwlock_trywrlock (pthread_rwlock_t *); __PTW32_DECLSPEC int pthread_rwlock_rdlock (pthread_rwlock_t *); __PTW32_DECLSPEC int pthread_rwlock_timedrdlock (pthread_rwlock_t *, const struct timespec *); __PTW32_DECLSPEC int pthread_rwlock_wrlock (pthread_rwlock_t *); __PTW32_DECLSPEC int pthread_rwlock_timedwrlock (pthread_rwlock_t *, const struct timespec *); __PTW32_DECLSPEC int pthread_rwlock_unlock (pthread_rwlock_t *lock); __PTW32_DECLSPEC int pthread_rwlockattr_init (pthread_rwlockattr_t *); __PTW32_DECLSPEC int pthread_rwlockattr_destroy (pthread_rwlockattr_t *); __PTW32_DECLSPEC int pthread_rwlockattr_getpshared (const pthread_rwlockattr_t *, int *); __PTW32_DECLSPEC int pthread_rwlockattr_setpshared (pthread_rwlockattr_t *, int); #if __PTW32_LEVEL >= __PTW32_LEVEL_MAX - 1 /* Signal Functions. Should be defined in but MSVC and MinGW32 * already have signal.h that don't define these. */ __PTW32_DECLSPEC int pthread_kill (pthread_t, int); /* Non-portable functions */ /* Compatibility with Linux. */ __PTW32_DECLSPEC int pthread_mutexattr_setkind_np (pthread_mutexattr_t *, int); __PTW32_DECLSPEC int pthread_mutexattr_getkind_np (pthread_mutexattr_t *, int *); __PTW32_DECLSPEC int pthread_timedjoin_np (pthread_t, void **, const struct timespec *); __PTW32_DECLSPEC int pthread_tryjoin_np (pthread_t, void **); __PTW32_DECLSPEC int pthread_setaffinity_np (pthread_t, size_t, const cpu_set_t *); __PTW32_DECLSPEC int pthread_getaffinity_np (pthread_t, size_t, cpu_set_t *); /* Possibly supported by other POSIX threads implementations */ __PTW32_DECLSPEC int pthread_delay_np (struct timespec *); __PTW32_DECLSPEC int pthread_num_processors_np (void); __PTW32_DECLSPEC unsigned __int64 pthread_getunique_np (pthread_t); /* Useful if an application wants to statically link * the lib rather than load the DLL at run-time. */ __PTW32_DECLSPEC int pthread_win32_process_attach_np (void); __PTW32_DECLSPEC int pthread_win32_process_detach_np (void); __PTW32_DECLSPEC int pthread_win32_thread_attach_np (void); __PTW32_DECLSPEC int pthread_win32_thread_detach_np (void); /* Returns the first parameter "abstime" modified to represent the current system time. * If "relative" is not NULL it represents an interval to add to "abstime". */ __PTW32_DECLSPEC struct timespec *pthread_win32_getabstime_np ( struct timespec *, const struct timespec *); /* Features that are auto-detected at load/run time. */ __PTW32_DECLSPEC int pthread_win32_test_features_np (int); enum ptw32_features { PTW32_SYSTEM_INTERLOCKED_COMPARE_EXCHANGE = 0x0001, /* System provides it. */ PTW32_ALERTABLE_ASYNC_CANCEL = 0x0002 /* Can cancel blocked threads. */ }; /* Register a system time change with the library. * Causes the library to perform various functions * in response to the change. Should be called whenever * the application's top level window receives a * WM_TIMECHANGE message. It can be passed directly to * pthread_create() as a new thread if desired. */ __PTW32_DECLSPEC void *pthread_timechange_handler_np (void *); #endif /* __PTW32_LEVEL >= __PTW32_LEVEL_MAX - 1 */ #if __PTW32_LEVEL >= __PTW32_LEVEL_MAX /* Returns the Win32 HANDLE for the POSIX thread. */ __PTW32_DECLSPEC void *pthread_getw32threadhandle_np (pthread_t); /* * Returns the win32 thread ID for POSIX thread. */ __PTW32_DECLSPEC unsigned long pthread_getw32threadid_np (pthread_t); /* Sets the POSIX thread name. If _MSC_VER is defined the name should be displayed by * the MSVS debugger. */ #if defined(_PTW32_COMPATIBILITY_BSD) || defined(_PTW32_COMPATIBILITY_TRU64) #define PTHREAD_MAX_NAMELEN_NP 16 __PTW32_DECLSPEC int pthread_setname_np (pthread_t, const char *, void *); __PTW32_DECLSPEC int pthread_attr_setname_np (pthread_attr_t *, const char *, void *); #else __PTW32_DECLSPEC int pthread_setname_np (pthread_t, const char *); __PTW32_DECLSPEC int pthread_attr_setname_np (pthread_attr_t *, const char *); #endif __PTW32_DECLSPEC int pthread_getname_np (pthread_t, char *, int); __PTW32_DECLSPEC int pthread_attr_getname_np (pthread_attr_t *, char *, int); /* Protected Methods * * This function blocks until the given WIN32 handle * is signalled or pthread_cancel had been called. * This function allows the caller to hook into the * PThreads cancel mechanism. It is implemented using * * WaitForMultipleObjects * * on 'waitHandle' and a manually reset WIN32 Event * used to implement pthread_cancel. The 'timeout' * argument to TimedWait is simply passed to * WaitForMultipleObjects. */ __PTW32_DECLSPEC int pthreadCancelableWait (void *); __PTW32_DECLSPEC int pthreadCancelableTimedWait (void *, unsigned long); #endif /* __PTW32_LEVEL >= __PTW32_LEVEL_MAX */ /* Declare a thread-safe errno for Open Watcom * (note: this has not been tested in a long time) */ #if defined(__WATCOMC__) && !defined(errno) # if defined(_MT) || defined(_DLL) __declspec(dllimport) extern int * __cdecl _errno (void); # define errno (*_errno()) # endif #endif /* If pthreads-win32 is compiled as a DLL with MSVC, and * both it and the application are linked against the static * C runtime (i.e. with the /MT compiler flag), then the * application will not see the same C runtime globals as * the library. These include the errno variable, and the * termination routine called by terminate(). For details, * refer to the following links: * * http://support.microsoft.com/kb/94248 * (Section 4: Problems Encountered When Using Multiple CRT Libraries) * * http://social.msdn.microsoft.com/forums/en-US/vclanguage/thread/b4500c0d-1b69-40c7-9ef5-08da1025b5bf * * When pthreads-win32 is built with __PTW32_USES_SEPARATE_CRT * defined, the following features are enabled: * * (1) In addition to setting the errno variable when errors * occur, the library will also call SetLastError() with the * same value. The application can then use GetLastError() * to obtain the value of errno. (This pair of routines are * in kernel32.dll, and so are not affected by the use of * multiple CRT libraries.) * * (2) When C++ or SEH cleanup is used, the library defines * a function pthread_win32_set_terminate_np(), which can be * used to set the termination routine that should be called * when an unhandled exception occurs in a thread function * (or otherwise inside the library). * * Note: "_DLL" implies the /MD compiler flag. */ #if defined(_MSC_VER) && !defined(_DLL) && !defined(_PTW32_STATIC_LIB) # define __PTW32_USES_SEPARATE_CRT #endif #if defined(__PTW32_USES_SEPARATE_CRT) && (defined(__CLEANUP_CXX) || defined(__CLEANUP_SEH)) typedef void (*ptw32_terminate_handler)(); __PTW32_DECLSPEC ptw32_terminate_handler pthread_win32_set_terminate_np (ptw32_terminate_handler); #endif /* Some compiler environments don't define some things. */ #if defined(__BORLANDC__) # define _ftime ftime # define _timeb timeb #endif #if defined(__cplusplus) /* Internal exceptions */ class ptw32_exception {}; class ptw32_exception_cancel : public ptw32_exception {}; class ptw32_exception_exit : public ptw32_exception {}; #endif #if __PTW32_LEVEL >= __PTW32_LEVEL_MAX /* FIXME: This is only required if the library was built using SEH */ /* * Get internal SEH tag */ __PTW32_DECLSPEC unsigned long ptw32_get_exception_services_code (void); #endif /* __PTW32_LEVEL >= __PTW32_LEVEL_MAX */ #if !defined(__PTW32_BUILD) #if defined(__CLEANUP_SEH) /* Redefine the SEH __except keyword to ensure that applications * propagate our internal exceptions up to the library's internal handlers. */ #define __except( E ) \ __except( ( GetExceptionCode() == ptw32_get_exception_services_code() ) \ ? EXCEPTION_CONTINUE_SEARCH : ( E ) ) #endif /* __CLEANUP_SEH */ #if defined(__CLEANUP_CXX) /* Redefine the C++ catch keyword to ensure that applications * propagate our internal exceptions up to the library's internal handlers. */ #if defined(_MSC_VER) /* WARNING: Replace any 'catch( ... )' with 'PtW32CatchAll' * if you want Pthread-Win32 cancellation and pthread_exit to work. */ #if !defined(PtW32NoCatchWarn) #pragma message("Specify \"/DPtW32NoCatchWarn\" compiler flag to skip this message.") #pragma message("------------------------------------------------------------------") #pragma message("When compiling applications with MSVC++ and C++ exception handling:") #pragma message(" Replace any 'catch( ... )' in routines called from POSIX threads") #pragma message(" with 'PtW32CatchAll' or 'CATCHALL' if you want POSIX thread") #pragma message(" cancellation and pthread_exit to work. For example:") #pragma message("") #pragma message(" #if defined(PtW32CatchAll)") #pragma message(" PtW32CatchAll") #pragma message(" #else") #pragma message(" catch(...)") #pragma message(" #endif") #pragma message(" {") #pragma message(" /* Catchall block processing */") #pragma message(" }") #pragma message("------------------------------------------------------------------") #endif #define PtW32CatchAll \ catch( ptw32_exception & ) { throw; } \ catch( ... ) #else /* _MSC_VER */ #define catch( E ) \ catch( ptw32_exception & ) { throw; } \ catch( E ) #endif /* _MSC_VER */ #endif /* __CLEANUP_CXX */ #endif /* ! __PTW32_BUILD */ __PTW32_END_C_DECLS #undef __PTW32_LEVEL #undef __PTW32_LEVEL_MAX #endif /* ! RC_INVOKED */ #endif /* !_PTHREAD_H */