1/* 2 * implement.h 3 * 4 * Definitions that don't need to be public. 5 * 6 * Keeps all the internals out of pthread.h 7 * 8 * -------------------------------------------------------------------------- 9 * 10 * Pthreads-win32 - POSIX Threads Library for Win32 11 * Copyright(C) 1998 John E. Bossom 12 * Copyright(C) 1999,2005 Pthreads-win32 contributors 13 * 14 * Contact Email: Ross.Johnson@homemail.com.au 15 * 16 * The current list of contributors is contained 17 * in the file CONTRIBUTORS included with the source 18 * code distribution. The list can also be seen at the 19 * following World Wide Web location: 20 * http://sources.redhat.com/pthreads-win32/contributors.html 21 * 22 * This library is free software; you can redistribute it and/or 23 * modify it under the terms of the GNU Lesser General Public 24 * License as published by the Free Software Foundation; either 25 * version 2 of the License, or (at your option) any later version. 26 * 27 * This library is distributed in the hope that it will be useful, 28 * but WITHOUT ANY WARRANTY; without even the implied warranty of 29 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU 30 * Lesser General Public License for more details. 31 * 32 * You should have received a copy of the GNU Lesser General Public 33 * License along with this library in the file COPYING.LIB; 34 * if not, write to the Free Software Foundation, Inc., 35 * 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA 36 */ 37 38#if !defined(_IMPLEMENT_H) 39#define _IMPLEMENT_H 40 41#if !defined(_WIN32_WINNT) 42#define _WIN32_WINNT 0x0400 43#endif 44 45#include <windows.h> 46 47/* 48 * In case windows.h doesn't define it (e.g. WinCE perhaps) 49 */ 50#if defined(WINCE) 51typedef VOID (APIENTRY *PAPCFUNC)(DWORD dwParam); 52#endif 53 54/* 55 * note: ETIMEDOUT is correctly defined in winsock.h 56 */ 57#include <winsock.h> 58 59/* 60 * In case ETIMEDOUT hasn't been defined above somehow. 61 */ 62#if !defined(ETIMEDOUT) 63# define ETIMEDOUT 10060 /* This is the value in winsock.h. */ 64#endif 65 66#if !defined(malloc) 67#include <malloc.h> 68#endif 69 70#if defined(__CLEANUP_C) 71# include <setjmp.h> 72#endif 73 74#if !defined(INT_MAX) 75#include <limits.h> 76#endif 77 78/* use local include files during development */ 79#include "semaphore.h" 80#include "sched.h" 81 82#if defined(HAVE_C_INLINE) || defined(__cplusplus) 83#define INLINE inline 84#else 85#define INLINE 86#endif 87 88#if defined(_MSC_VER) && _MSC_VER < 1300 89/* 90 * MSVC 6 does not use the "volatile" qualifier 91 */ 92#define PTW32_INTERLOCKED_VOLATILE 93#else 94#define PTW32_INTERLOCKED_VOLATILE volatile 95#endif 96 97#define PTW32_INTERLOCKED_LONG long 98#define PTW32_INTERLOCKED_SIZE size_t 99#define PTW32_INTERLOCKED_PVOID PVOID 100#define PTW32_INTERLOCKED_LONGPTR PTW32_INTERLOCKED_VOLATILE long* 101#define PTW32_INTERLOCKED_SIZEPTR PTW32_INTERLOCKED_VOLATILE size_t* 102#define PTW32_INTERLOCKED_PVOID_PTR PTW32_INTERLOCKED_VOLATILE PVOID* 103 104#if defined(__MINGW64__) || defined(__MINGW32__) 105# include <stdint.h> 106#elif defined(__BORLANDC__) 107# define int64_t ULONGLONG 108#else 109# define int64_t _int64 110# if defined(_MSC_VER) && _MSC_VER < 1300 111 typedef long intptr_t; 112# endif 113#endif 114 115/* 116 * Don't allow the linker to optimize away autostatic.obj in static builds. 117 */ 118#if defined(PTW32_STATIC_LIB) 119 void ptw32_autostatic_anchor(void); 120# if defined(__MINGW64__) || defined(__MINGW32__) 121 __attribute__((unused, used)) 122# endif 123 static void (*local_autostatic_anchor)(void) = ptw32_autostatic_anchor; 124#endif 125 126typedef enum 127{ 128 /* 129 * This enumeration represents the state of the thread; 130 * The thread is still "alive" if the numeric value of the 131 * state is greater or equal "PThreadStateRunning". 132 */ 133 PThreadStateInitial = 0, /* Thread not running */ 134 PThreadStateRunning, /* Thread alive & kicking */ 135 PThreadStateSuspended, /* Thread alive but suspended */ 136 PThreadStateCancelPending, /* Thread alive but */ 137 /* has cancelation pending. */ 138 PThreadStateCanceling, /* Thread alive but is */ 139 /* in the process of terminating */ 140 /* due to a cancellation request */ 141 PThreadStateExiting, /* Thread alive but exiting */ 142 /* due to an exception */ 143 PThreadStateLast, /* All handlers have been run and now */ 144 /* final cleanup can be done. */ 145 PThreadStateReuse /* In reuse pool. */ 146} 147PThreadState; 148 149typedef struct ptw32_mcs_node_t_ ptw32_mcs_local_node_t; 150typedef struct ptw32_mcs_node_t_* ptw32_mcs_lock_t; 151typedef struct ptw32_robust_node_t_ ptw32_robust_node_t; 152typedef struct ptw32_thread_t_ ptw32_thread_t; 153 154 155struct ptw32_thread_t_ 156{ 157 unsigned __int64 seqNumber; /* Process-unique thread sequence number */ 158 HANDLE threadH; /* Win32 thread handle - POSIX thread is invalid if threadH == 0 */ 159 pthread_t ptHandle; /* This thread's permanent pthread_t handle */ 160 ptw32_thread_t * prevReuse; /* Links threads on reuse stack */ 161 volatile PThreadState state; 162 ptw32_mcs_lock_t threadLock; /* Used for serialised access to public thread state */ 163 ptw32_mcs_lock_t stateLock; /* Used for async-cancel safety */ 164 HANDLE cancelEvent; 165 void *exitStatus; 166 void *parms; 167 void *keys; 168 void *nextAssoc; 169#if defined(__CLEANUP_C) 170 jmp_buf start_mark; /* Jump buffer follows void* so should be aligned */ 171#endif /* __CLEANUP_C */ 172#if defined(HAVE_SIGSET_T) 173 sigset_t sigmask; 174#endif /* HAVE_SIGSET_T */ 175 ptw32_mcs_lock_t 176 robustMxListLock; /* robustMxList lock */ 177 ptw32_robust_node_t* 178 robustMxList; /* List of currenty held robust mutexes */ 179 int ptErrno; 180 int detachState; 181 int sched_priority; /* As set, not as currently is */ 182 int cancelState; 183 int cancelType; 184 int implicit:1; 185 DWORD thread; /* Win32 thread ID */ 186#if defined(_UWIN) 187 DWORD dummy[5]; 188#endif 189 size_t align; /* Force alignment if this struct is packed */ 190}; 191 192 193/* 194 * Special value to mark attribute objects as valid. 195 */ 196#define PTW32_ATTR_VALID ((unsigned long) 0xC4C0FFEE) 197 198struct pthread_attr_t_ 199{ 200 unsigned long valid; 201 void *stackaddr; 202 size_t stacksize; 203 int detachstate; 204 struct sched_param param; 205 int inheritsched; 206 int contentionscope; 207#if defined(HAVE_SIGSET_T) 208 sigset_t sigmask; 209#endif /* HAVE_SIGSET_T */ 210}; 211 212 213/* 214 * ==================== 215 * ==================== 216 * Semaphores, Mutexes and Condition Variables 217 * ==================== 218 * ==================== 219 */ 220 221struct sem_t_ 222{ 223 int value; 224 pthread_mutex_t lock; 225 HANDLE sem; 226#if defined(NEED_SEM) 227 int leftToUnblock; 228#endif 229}; 230 231#define PTW32_OBJECT_AUTO_INIT ((void *)(size_t) -1) 232#define PTW32_OBJECT_INVALID NULL 233 234struct pthread_mutex_t_ 235{ 236 LONG lock_idx; /* Provides exclusive access to mutex state 237 via the Interlocked* mechanism. 238 0: unlocked/free. 239 1: locked - no other waiters. 240 -1: locked - with possible other waiters. 241 */ 242 int recursive_count; /* Number of unlocks a thread needs to perform 243 before the lock is released (recursive 244 mutexes only). */ 245 int kind; /* Mutex type. */ 246 pthread_t ownerThread; 247 HANDLE event; /* Mutex release notification to waiting 248 threads. */ 249 ptw32_robust_node_t* 250 robustNode; /* Extra state for robust mutexes */ 251}; 252 253enum ptw32_robust_state_t_ 254{ 255 PTW32_ROBUST_CONSISTENT, 256 PTW32_ROBUST_INCONSISTENT, 257 PTW32_ROBUST_NOTRECOVERABLE 258}; 259 260typedef enum ptw32_robust_state_t_ ptw32_robust_state_t; 261 262/* 263 * Node used to manage per-thread lists of currently-held robust mutexes. 264 */ 265struct ptw32_robust_node_t_ 266{ 267 pthread_mutex_t mx; 268 ptw32_robust_state_t stateInconsistent; 269 ptw32_robust_node_t* prev; 270 ptw32_robust_node_t* next; 271}; 272 273struct pthread_mutexattr_t_ 274{ 275 int pshared; 276 int kind; 277 int robustness; 278}; 279 280/* 281 * Possible values, other than PTW32_OBJECT_INVALID, 282 * for the "interlock" element in a spinlock. 283 * 284 * In this implementation, when a spinlock is initialised, 285 * the number of cpus available to the process is checked. 286 * If there is only one cpu then "interlock" is set equal to 287 * PTW32_SPIN_USE_MUTEX and u.mutex is an initialised mutex. 288 * If the number of cpus is greater than 1 then "interlock" 289 * is set equal to PTW32_SPIN_UNLOCKED and the number is 290 * stored in u.cpus. This arrangement allows the spinlock 291 * routines to attempt an InterlockedCompareExchange on "interlock" 292 * immediately and, if that fails, to try the inferior mutex. 293 * 294 * "u.cpus" isn't used for anything yet, but could be used at 295 * some point to optimise spinlock behaviour. 296 */ 297#define PTW32_SPIN_INVALID (0) 298#define PTW32_SPIN_UNLOCKED (1) 299#define PTW32_SPIN_LOCKED (2) 300#define PTW32_SPIN_USE_MUTEX (3) 301 302struct pthread_spinlock_t_ 303{ 304 long interlock; /* Locking element for multi-cpus. */ 305 union 306 { 307 int cpus; /* No. of cpus if multi cpus, or */ 308 pthread_mutex_t mutex; /* mutex if single cpu. */ 309 } u; 310}; 311 312/* 313 * MCS lock queue node - see ptw32_MCS_lock.c 314 */ 315struct ptw32_mcs_node_t_ 316{ 317 struct ptw32_mcs_node_t_ **lock; /* ptr to tail of queue */ 318 struct ptw32_mcs_node_t_ *next; /* ptr to successor in queue */ 319 HANDLE readyFlag; /* set after lock is released by 320 predecessor */ 321 HANDLE nextFlag; /* set after 'next' ptr is set by 322 successor */ 323}; 324 325 326struct pthread_barrier_t_ 327{ 328 unsigned int nCurrentBarrierHeight; 329 unsigned int nInitialBarrierHeight; 330 int pshared; 331 sem_t semBarrierBreeched; 332 ptw32_mcs_lock_t lock; 333 ptw32_mcs_local_node_t proxynode; 334}; 335 336struct pthread_barrierattr_t_ 337{ 338 int pshared; 339}; 340 341struct pthread_key_t_ 342{ 343 DWORD key; 344 void (PTW32_CDECL *destructor) (void *); 345 ptw32_mcs_lock_t keyLock; 346 void *threads; 347}; 348 349 350typedef struct ThreadParms ThreadParms; 351 352struct ThreadParms 353{ 354 pthread_t tid; 355 void *(PTW32_CDECL *start) (void *); 356 void *arg; 357}; 358 359 360struct pthread_cond_t_ 361{ 362 long nWaitersBlocked; /* Number of threads blocked */ 363 long nWaitersGone; /* Number of threads timed out */ 364 long nWaitersToUnblock; /* Number of threads to unblock */ 365 sem_t semBlockQueue; /* Queue up threads waiting for the */ 366 /* condition to become signalled */ 367 sem_t semBlockLock; /* Semaphore that guards access to */ 368 /* | waiters blocked count/block queue */ 369 /* +-> Mandatory Sync.LEVEL-1 */ 370 pthread_mutex_t mtxUnblockLock; /* Mutex that guards access to */ 371 /* | waiters (to)unblock(ed) counts */ 372 /* +-> Optional* Sync.LEVEL-2 */ 373 pthread_cond_t next; /* Doubly linked list */ 374 pthread_cond_t prev; 375}; 376 377 378struct pthread_condattr_t_ 379{ 380 int pshared; 381}; 382 383#define PTW32_RWLOCK_MAGIC 0xfacade2 384 385struct pthread_rwlock_t_ 386{ 387 pthread_mutex_t mtxExclusiveAccess; 388 pthread_mutex_t mtxSharedAccessCompleted; 389 pthread_cond_t cndSharedAccessCompleted; 390 int nSharedAccessCount; 391 int nExclusiveAccessCount; 392 int nCompletedSharedAccessCount; 393 int nMagic; 394}; 395 396struct pthread_rwlockattr_t_ 397{ 398 int pshared; 399}; 400 401typedef struct ThreadKeyAssoc ThreadKeyAssoc; 402 403struct ThreadKeyAssoc 404{ 405 /* 406 * Purpose: 407 * This structure creates an association between a thread and a key. 408 * It is used to implement the implicit invocation of a user defined 409 * destroy routine for thread specific data registered by a user upon 410 * exiting a thread. 411 * 412 * Graphically, the arrangement is as follows, where: 413 * 414 * K - Key with destructor 415 * (head of chain is key->threads) 416 * T - Thread that has called pthread_setspecific(Kn) 417 * (head of chain is thread->keys) 418 * A - Association. Each association is a node at the 419 * intersection of two doubly-linked lists. 420 * 421 * T1 T2 T3 422 * | | | 423 * | | | 424 * K1 -----+-----A-----A-----> 425 * | | | 426 * | | | 427 * K2 -----A-----A-----+-----> 428 * | | | 429 * | | | 430 * K3 -----A-----+-----A-----> 431 * | | | 432 * | | | 433 * V V V 434 * 435 * Access to the association is guarded by two locks: the key's 436 * general lock (guarding the row) and the thread's general 437 * lock (guarding the column). This avoids the need for a 438 * dedicated lock for each association, which not only consumes 439 * more handles but requires that the lock resources persist 440 * until both the key is deleted and the thread has called the 441 * destructor. The two-lock arrangement allows those resources 442 * to be freed as soon as either thread or key is concluded. 443 * 444 * To avoid deadlock, whenever both locks are required both the 445 * key and thread locks are acquired consistently in the order 446 * "key lock then thread lock". An exception to this exists 447 * when a thread calls the destructors, however, this is done 448 * carefully (but inelegantly) to avoid deadlock. 449 * 450 * An association is created when a thread first calls 451 * pthread_setspecific() on a key that has a specified 452 * destructor. 453 * 454 * An association is destroyed either immediately after the 455 * thread calls the key destructor function on thread exit, or 456 * when the key is deleted. 457 * 458 * Attributes: 459 * thread 460 * reference to the thread that owns the 461 * association. This is actually the pointer to the 462 * thread struct itself. Since the association is 463 * destroyed before the thread exits, this can never 464 * point to a different logical thread to the one that 465 * created the assoc, i.e. after thread struct reuse. 466 * 467 * key 468 * reference to the key that owns the association. 469 * 470 * nextKey 471 * The pthread_t->keys attribute is the head of a 472 * chain of associations that runs through the nextKey 473 * link. This chain provides the 1 to many relationship 474 * between a pthread_t and all pthread_key_t on which 475 * it called pthread_setspecific. 476 * 477 * prevKey 478 * Similarly. 479 * 480 * nextThread 481 * The pthread_key_t->threads attribute is the head of 482 * a chain of associations that runs through the 483 * nextThreads link. This chain provides the 1 to many 484 * relationship between a pthread_key_t and all the 485 * PThreads that have called pthread_setspecific for 486 * this pthread_key_t. 487 * 488 * prevThread 489 * Similarly. 490 * 491 * Notes: 492 * 1) As soon as either the key or the thread is no longer 493 * referencing the association, it can be destroyed. The 494 * association will be removed from both chains. 495 * 496 * 2) Under WIN32, an association is only created by 497 * pthread_setspecific if the user provided a 498 * destroyRoutine when they created the key. 499 * 500 * 501 */ 502 ptw32_thread_t * thread; 503 pthread_key_t key; 504 ThreadKeyAssoc *nextKey; 505 ThreadKeyAssoc *nextThread; 506 ThreadKeyAssoc *prevKey; 507 ThreadKeyAssoc *prevThread; 508}; 509 510 511#if defined(__CLEANUP_SEH) 512/* 513 * -------------------------------------------------------------- 514 * MAKE_SOFTWARE_EXCEPTION 515 * This macro constructs a software exception code following 516 * the same format as the standard Win32 error codes as defined 517 * in WINERROR.H 518 * Values are 32 bit values laid out as follows: 519 * 520 * 1 0 9 8 7 6 5 4 3 2 1 0 9 8 7 6 5 4 3 2 1 0 9 8 7 6 5 4 3 2 1 0 521 * +---+-+-+-----------------------+-------------------------------+ 522 * |Sev|C|R| Facility | Code | 523 * +---+-+-+-----------------------+-------------------------------+ 524 * 525 * Severity Values: 526 */ 527#define SE_SUCCESS 0x00 528#define SE_INFORMATION 0x01 529#define SE_WARNING 0x02 530#define SE_ERROR 0x03 531 532#define MAKE_SOFTWARE_EXCEPTION( _severity, _facility, _exception ) \ 533( (DWORD) ( ( (_severity) << 30 ) | /* Severity code */ \ 534 ( 1 << 29 ) | /* MS=0, User=1 */ \ 535 ( 0 << 28 ) | /* Reserved */ \ 536 ( (_facility) << 16 ) | /* Facility Code */ \ 537 ( (_exception) << 0 ) /* Exception Code */ \ 538 ) ) 539 540/* 541 * We choose one specific Facility/Error code combination to 542 * identify our software exceptions vs. WIN32 exceptions. 543 * We store our actual component and error code within 544 * the optional information array. 545 */ 546#define EXCEPTION_PTW32_SERVICES \ 547 MAKE_SOFTWARE_EXCEPTION( SE_ERROR, \ 548 PTW32_SERVICES_FACILITY, \ 549 PTW32_SERVICES_ERROR ) 550 551#define PTW32_SERVICES_FACILITY 0xBAD 552#define PTW32_SERVICES_ERROR 0xDEED 553 554#endif /* __CLEANUP_SEH */ 555 556/* 557 * Services available through EXCEPTION_PTW32_SERVICES 558 * and also used [as parameters to ptw32_throw()] as 559 * generic exception selectors. 560 */ 561 562#define PTW32_EPS_EXIT (1) 563#define PTW32_EPS_CANCEL (2) 564 565 566/* Useful macros */ 567#define PTW32_MAX(a,b) ((a)<(b)?(b):(a)) 568#define PTW32_MIN(a,b) ((a)>(b)?(b):(a)) 569 570 571/* Declared in pthread_cancel.c */ 572extern DWORD (*ptw32_register_cancelation) (PAPCFUNC, HANDLE, DWORD); 573 574/* Thread Reuse stack bottom marker. Must not be NULL or any valid pointer to memory. */ 575#define PTW32_THREAD_REUSE_EMPTY ((ptw32_thread_t *)(size_t) 1) 576 577extern int ptw32_processInitialized; 578extern ptw32_thread_t * ptw32_threadReuseTop; 579extern ptw32_thread_t * ptw32_threadReuseBottom; 580extern pthread_key_t ptw32_selfThreadKey; 581extern pthread_key_t ptw32_cleanupKey; 582extern pthread_cond_t ptw32_cond_list_head; 583extern pthread_cond_t ptw32_cond_list_tail; 584 585extern int ptw32_mutex_default_kind; 586 587extern unsigned __int64 ptw32_threadSeqNumber; 588 589extern int ptw32_concurrency; 590 591extern int ptw32_features; 592 593extern ptw32_mcs_lock_t ptw32_thread_reuse_lock; 594extern ptw32_mcs_lock_t ptw32_mutex_test_init_lock; 595extern ptw32_mcs_lock_t ptw32_cond_list_lock; 596extern ptw32_mcs_lock_t ptw32_cond_test_init_lock; 597extern ptw32_mcs_lock_t ptw32_rwlock_test_init_lock; 598extern ptw32_mcs_lock_t ptw32_spinlock_test_init_lock; 599 600#if defined(_UWIN) 601extern int pthread_count; 602#endif 603 604#if defined(__cplusplus) 605extern "C" 606{ 607#endif /* __cplusplus */ 608 609/* 610 * ===================== 611 * ===================== 612 * Forward Declarations 613 * ===================== 614 * ===================== 615 */ 616 617 int ptw32_is_attr (const pthread_attr_t * attr); 618 619 int ptw32_cond_check_need_init (pthread_cond_t * cond); 620 int ptw32_mutex_check_need_init (pthread_mutex_t * mutex); 621 int ptw32_rwlock_check_need_init (pthread_rwlock_t * rwlock); 622 int ptw32_spinlock_check_need_init (pthread_spinlock_t * lock); 623 624 int ptw32_robust_mutex_inherit(pthread_mutex_t * mutex); 625 void ptw32_robust_mutex_add(pthread_mutex_t* mutex, pthread_t self); 626 void ptw32_robust_mutex_remove(pthread_mutex_t* mutex, ptw32_thread_t* otp); 627 628 DWORD 629 ptw32_RegisterCancelation (PAPCFUNC callback, 630 HANDLE threadH, DWORD callback_arg); 631 632 int ptw32_processInitialize (void); 633 634 void ptw32_processTerminate (void); 635 636 void ptw32_threadDestroy (pthread_t tid); 637 638 void ptw32_pop_cleanup_all (int execute); 639 640 pthread_t ptw32_new (void); 641 642 pthread_t ptw32_threadReusePop (void); 643 644 void ptw32_threadReusePush (pthread_t thread); 645 646 int ptw32_getprocessors (int *count); 647 648 int ptw32_setthreadpriority (pthread_t thread, int policy, int priority); 649 650 void ptw32_rwlock_cancelwrwait (void *arg); 651 652#if ! (defined (__MINGW64__) || defined(__MINGW32__)) || (defined(__MSVCRT__) && ! defined(__DMC__)) 653 unsigned __stdcall 654#else 655 void 656#endif 657 ptw32_threadStart (void *vthreadParms); 658 659 void ptw32_callUserDestroyRoutines (pthread_t thread); 660 661 int ptw32_tkAssocCreate (ptw32_thread_t * thread, pthread_key_t key); 662 663 void ptw32_tkAssocDestroy (ThreadKeyAssoc * assoc); 664 665 int ptw32_semwait (sem_t * sem); 666 667 DWORD ptw32_relmillisecs (const struct timespec * abstime); 668 669 void ptw32_mcs_lock_acquire (ptw32_mcs_lock_t * lock, ptw32_mcs_local_node_t * node); 670 671 int ptw32_mcs_lock_try_acquire (ptw32_mcs_lock_t * lock, ptw32_mcs_local_node_t * node); 672 673 void ptw32_mcs_lock_release (ptw32_mcs_local_node_t * node); 674 675 void ptw32_mcs_node_transfer (ptw32_mcs_local_node_t * new_node, ptw32_mcs_local_node_t * old_node); 676 677#if defined(NEED_FTIME) 678 void ptw32_timespec_to_filetime (const struct timespec *ts, FILETIME * ft); 679 void ptw32_filetime_to_timespec (const FILETIME * ft, struct timespec *ts); 680#endif 681 682/* Declared in misc.c */ 683#if defined(NEED_CALLOC) 684#define calloc(n, s) ptw32_calloc(n, s) 685 void *ptw32_calloc (size_t n, size_t s); 686#endif 687 688/* Declared in private.c */ 689#if defined(_MSC_VER) 690/* 691 * Ignore the warning: 692 * "C++ exception specification ignored except to indicate that 693 * the function is not __declspec(nothrow)." 694 */ 695#pragma warning(disable:4290) 696#endif 697 void ptw32_throw (DWORD exception) 698#if defined(__CLEANUP_CXX) 699 throw(ptw32_exception_cancel,ptw32_exception_exit) 700#endif 701; 702 703#if defined(__cplusplus) 704} 705#endif /* __cplusplus */ 706 707 708#if defined(_UWIN_) 709# if defined(_MT) 710# if defined(__cplusplus) 711extern "C" 712{ 713# endif 714 _CRTIMP unsigned long __cdecl _beginthread (void (__cdecl *) (void *), 715 unsigned, void *); 716 _CRTIMP void __cdecl _endthread (void); 717 _CRTIMP unsigned long __cdecl _beginthreadex (void *, unsigned, 718 unsigned (__stdcall *) (void *), 719 void *, unsigned, unsigned *); 720 _CRTIMP void __cdecl _endthreadex (unsigned); 721# if defined(__cplusplus) 722} 723# endif 724# endif 725#else 726# include <process.h> 727# endif 728 729 730/* 731 * Use intrinsic versions wherever possible. VC will do this 732 * automatically where possible and GCC define these if available: 733 * __GCC_HAVE_SYNC_COMPARE_AND_SWAP_1 734 * __GCC_HAVE_SYNC_COMPARE_AND_SWAP_2 735 * __GCC_HAVE_SYNC_COMPARE_AND_SWAP_4 736 * __GCC_HAVE_SYNC_COMPARE_AND_SWAP_8 737 * __GCC_HAVE_SYNC_COMPARE_AND_SWAP_16 738 * 739 * The full set of Interlocked intrinsics in GCC are (check versions): 740 * type __sync_fetch_and_add (type *ptr, type value, ...) 741 * type __sync_fetch_and_sub (type *ptr, type value, ...) 742 * type __sync_fetch_and_or (type *ptr, type value, ...) 743 * type __sync_fetch_and_and (type *ptr, type value, ...) 744 * type __sync_fetch_and_xor (type *ptr, type value, ...) 745 * type __sync_fetch_and_nand (type *ptr, type value, ...) 746 * type __sync_add_and_fetch (type *ptr, type value, ...) 747 * type __sync_sub_and_fetch (type *ptr, type value, ...) 748 * type __sync_or_and_fetch (type *ptr, type value, ...) 749 * type __sync_and_and_fetch (type *ptr, type value, ...) 750 * type __sync_xor_and_fetch (type *ptr, type value, ...) 751 * type __sync_nand_and_fetch (type *ptr, type value, ...) 752 * bool __sync_bool_compare_and_swap (type *ptr, type oldval type newval, ...) 753 * type __sync_val_compare_and_swap (type *ptr, type oldval type newval, ...) 754 * __sync_synchronize (...) // Full memory barrier 755 * type __sync_lock_test_and_set (type *ptr, type value, ...) // Acquire barrier 756 * void __sync_lock_release (type *ptr, ...) // Release barrier 757 * 758 * These are all overloaded and take 1,2,4,8 byte scalar or pointer types. 759 * 760 * The above aren't available in Mingw32 as of gcc 4.5.2 so define our own. 761 */ 762#if defined(__cplusplus) 763# define PTW32_TO_VLONG64PTR(ptr) reinterpret_cast<volatile LONG64 *>(ptr) 764#else 765# define PTW32_TO_VLONG64PTR(ptr) (ptr) 766#endif 767 768#if defined(__GNUC__) 769# if defined(_WIN64) 770# define PTW32_INTERLOCKED_COMPARE_EXCHANGE_64(location, value, comparand) \ 771 ({ \ 772 __typeof (value) _result; \ 773 __asm__ __volatile__ \ 774 ( \ 775 "lock\n\t" \ 776 "cmpxchgq %2,(%1)" \ 777 :"=a" (_result) \ 778 :"r" (location), "r" (value), "a" (comparand) \ 779 :"memory", "cc"); \ 780 _result; \ 781 }) 782# define PTW32_INTERLOCKED_EXCHANGE_64(location, value) \ 783 ({ \ 784 __typeof (value) _result; \ 785 __asm__ __volatile__ \ 786 ( \ 787 "xchgq %0,(%1)" \ 788 :"=r" (_result) \ 789 :"r" (location), "0" (value) \ 790 :"memory", "cc"); \ 791 _result; \ 792 }) 793# define PTW32_INTERLOCKED_EXCHANGE_ADD_64(location, value) \ 794 ({ \ 795 __typeof (value) _result; \ 796 __asm__ __volatile__ \ 797 ( \ 798 "lock\n\t" \ 799 "xaddq %0,(%1)" \ 800 :"=r" (_result) \ 801 :"r" (location), "0" (value) \ 802 :"memory", "cc"); \ 803 _result; \ 804 }) 805# define PTW32_INTERLOCKED_INCREMENT_64(location) \ 806 ({ \ 807 PTW32_INTERLOCKED_LONG _temp = 1; \ 808 __asm__ __volatile__ \ 809 ( \ 810 "lock\n\t" \ 811 "xaddq %0,(%1)" \ 812 :"+r" (_temp) \ 813 :"r" (location) \ 814 :"memory", "cc"); \ 815 ++_temp; \ 816 }) 817# define PTW32_INTERLOCKED_DECREMENT_64(location) \ 818 ({ \ 819 PTW32_INTERLOCKED_LONG _temp = -1; \ 820 __asm__ __volatile__ \ 821 ( \ 822 "lock\n\t" \ 823 "xaddq %2,(%1)" \ 824 :"+r" (_temp) \ 825 :"r" (location) \ 826 :"memory", "cc"); \ 827 --_temp; \ 828 }) 829#endif 830# define PTW32_INTERLOCKED_COMPARE_EXCHANGE_LONG(location, value, comparand) \ 831 ({ \ 832 __typeof (value) _result; \ 833 __asm__ __volatile__ \ 834 ( \ 835 "lock\n\t" \ 836 "cmpxchgl %2,(%1)" \ 837 :"=a" (_result) \ 838 :"r" (location), "r" (value), "a" (comparand) \ 839 :"memory", "cc"); \ 840 _result; \ 841 }) 842# define PTW32_INTERLOCKED_EXCHANGE_LONG(location, value) \ 843 ({ \ 844 __typeof (value) _result; \ 845 __asm__ __volatile__ \ 846 ( \ 847 "xchgl %0,(%1)" \ 848 :"=r" (_result) \ 849 :"r" (location), "0" (value) \ 850 :"memory", "cc"); \ 851 _result; \ 852 }) 853# define PTW32_INTERLOCKED_EXCHANGE_ADD_LONG(location, value) \ 854 ({ \ 855 __typeof (value) _result; \ 856 __asm__ __volatile__ \ 857 ( \ 858 "lock\n\t" \ 859 "xaddl %0,(%1)" \ 860 :"=r" (_result) \ 861 :"r" (location), "0" (value) \ 862 :"memory", "cc"); \ 863 _result; \ 864 }) 865# define PTW32_INTERLOCKED_INCREMENT_LONG(location) \ 866 ({ \ 867 PTW32_INTERLOCKED_LONG _temp = 1; \ 868 __asm__ __volatile__ \ 869 ( \ 870 "lock\n\t" \ 871 "xaddl %0,(%1)" \ 872 :"+r" (_temp) \ 873 :"r" (location) \ 874 :"memory", "cc"); \ 875 ++_temp; \ 876 }) 877# define PTW32_INTERLOCKED_DECREMENT_LONG(location) \ 878 ({ \ 879 PTW32_INTERLOCKED_LONG _temp = -1; \ 880 __asm__ __volatile__ \ 881 ( \ 882 "lock\n\t" \ 883 "xaddl %0,(%1)" \ 884 :"+r" (_temp) \ 885 :"r" (location) \ 886 :"memory", "cc"); \ 887 --_temp; \ 888 }) 889# define PTW32_INTERLOCKED_COMPARE_EXCHANGE_PTR(location, value, comparand) \ 890 PTW32_INTERLOCKED_COMPARE_EXCHANGE_SIZE((PTW32_INTERLOCKED_SIZEPTR)location, \ 891 (PTW32_INTERLOCKED_SIZE)value, \ 892 (PTW32_INTERLOCKED_SIZE)comparand) 893# define PTW32_INTERLOCKED_EXCHANGE_PTR(location, value) \ 894 PTW32_INTERLOCKED_EXCHANGE_SIZE((PTW32_INTERLOCKED_SIZEPTR)location, \ 895 (PTW32_INTERLOCKED_SIZE)value) 896#else 897# if defined(_WIN64) 898# define PTW32_INTERLOCKED_COMPARE_EXCHANGE_64(p,v,c) InterlockedCompareExchange64(PTW32_TO_VLONG64PTR(p),(v),(c)) 899# define PTW32_INTERLOCKED_EXCHANGE_64(p,v) InterlockedExchange64(PTW32_TO_VLONG64PTR(p),(v)) 900# define PTW32_INTERLOCKED_EXCHANGE_ADD_64(p,v) InterlockedExchangeAdd64(PTW32_TO_VLONG64PTR(p),(v)) 901# define PTW32_INTERLOCKED_INCREMENT_64(p) InterlockedIncrement64(PTW32_TO_VLONG64PTR(p)) 902# define PTW32_INTERLOCKED_DECREMENT_64(p) InterlockedDecrement64(PTW32_TO_VLONG64PTR(p)) 903# endif 904# if defined(_MSC_VER) && _MSC_VER < 1300 && !defined(_WIN64) /* MSVC 6 */ 905# define PTW32_INTERLOCKED_COMPARE_EXCHANGE_LONG(location, value, comparand) \ 906 ((LONG)InterlockedCompareExchange((PVOID *)(location), (PVOID)(value), (PVOID)(comparand))) 907# else 908# define PTW32_INTERLOCKED_COMPARE_EXCHANGE_LONG InterlockedCompareExchange 909# endif 910# define PTW32_INTERLOCKED_EXCHANGE_LONG(p,v) InterlockedExchange((p),(v)) 911# define PTW32_INTERLOCKED_EXCHANGE_ADD_LONG(p,v) InterlockedExchangeAdd((p),(v)) 912# define PTW32_INTERLOCKED_INCREMENT_LONG(p) InterlockedIncrement((p)) 913# define PTW32_INTERLOCKED_DECREMENT_LONG(p) InterlockedDecrement((p)) 914# if defined(_MSC_VER) && _MSC_VER < 1300 && !defined(_WIN64) /* MSVC 6 */ 915# define PTW32_INTERLOCKED_COMPARE_EXCHANGE_PTR InterlockedCompareExchange 916# define PTW32_INTERLOCKED_EXCHANGE_PTR(location, value) \ 917 ((PVOID)InterlockedExchange((LPLONG)(location), (LONG)(value))) 918# else 919# define PTW32_INTERLOCKED_COMPARE_EXCHANGE_PTR(p,v,c) InterlockedCompareExchangePointer((p),(v),(c)) 920# define PTW32_INTERLOCKED_EXCHANGE_PTR(p,v) InterlockedExchangePointer((p),(v)) 921# endif 922#endif 923#if defined(_WIN64) 924# define PTW32_INTERLOCKED_COMPARE_EXCHANGE_SIZE(p,v,c) PTW32_INTERLOCKED_COMPARE_EXCHANGE_64(PTW32_TO_VLONG64PTR(p),(v),(c)) 925# define PTW32_INTERLOCKED_EXCHANGE_SIZE(p,v) PTW32_INTERLOCKED_EXCHANGE_64(PTW32_TO_VLONG64PTR(p),(v)) 926# define PTW32_INTERLOCKED_EXCHANGE_ADD_SIZE(p,v) PTW32_INTERLOCKED_EXCHANGE_ADD_64(PTW32_TO_VLONG64PTR(p),(v)) 927# define PTW32_INTERLOCKED_INCREMENT_SIZE(p) PTW32_INTERLOCKED_INCREMENT_64(PTW32_TO_VLONG64PTR(p)) 928# define PTW32_INTERLOCKED_DECREMENT_SIZE(p) PTW32_INTERLOCKED_DECREMENT_64(PTW32_TO_VLONG64PTR(p)) 929#else 930# define PTW32_INTERLOCKED_COMPARE_EXCHANGE_SIZE(p,v,c) PTW32_INTERLOCKED_COMPARE_EXCHANGE_LONG((p),(v),(c)) 931# define PTW32_INTERLOCKED_EXCHANGE_SIZE(p,v) PTW32_INTERLOCKED_EXCHANGE_LONG((p),(v)) 932# define PTW32_INTERLOCKED_EXCHANGE_ADD_SIZE(p,v) PTW32_INTERLOCKED_EXCHANGE_ADD_LONG((p),(v)) 933# define PTW32_INTERLOCKED_INCREMENT_SIZE(p) PTW32_INTERLOCKED_INCREMENT_LONG((p)) 934# define PTW32_INTERLOCKED_DECREMENT_SIZE(p) PTW32_INTERLOCKED_DECREMENT_LONG((p)) 935#endif 936 937#if defined(NEED_CREATETHREAD) 938 939/* 940 * Macro uses args so we can cast start_proc to LPTHREAD_START_ROUTINE 941 * in order to avoid warnings because of return type 942 */ 943 944#define _beginthreadex(security, \ 945 stack_size, \ 946 start_proc, \ 947 arg, \ 948 flags, \ 949 pid) \ 950 CreateThread(security, \ 951 stack_size, \ 952 (LPTHREAD_START_ROUTINE) start_proc, \ 953 arg, \ 954 flags, \ 955 pid) 956 957#define _endthreadex ExitThread 958 959#endif /* NEED_CREATETHREAD */ 960 961 962#endif /* _IMPLEMENT_H */ 963