cpython-lru_cache-weakref: Python/thread

annotate Python/thread_pthread.h @ 78855:5a2ef447b80d 2.7

Issue #13992: The trashcan mechanism is now thread-safe. This eliminates sporadic crashes in multi-thread programs when several long deallocator chains ran concurrently and involved subclasses of built-in container types. Because of this change, a couple extension modules compiled for 2.7.4 (those which use the trashcan mechanism, despite it being undocumented) will not be loadable by 2.7.3 and earlier. However, extension modules compiled for 2.7.3 and earlier will be loadable by 2.7.4.

author	Antoine Pitrou <solipsis@pitrou.net>
date	Thu, 06 Sep 2012 00:59:49 +0200
parents	ecf0ef85c72a
children	0adfbafe8a99

rev	line source
1628 a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	1
3663 07164d30429d Got rid of florida hack and made it work with Solaris 2.5 pthreads. Guido van Rossum <guido@python.org> parents: 2097 diff changeset	2 /* Posix threads interface */
1628 a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	3
3663 07164d30429d Got rid of florida hack and made it work with Solaris 2.5 pthreads. Guido van Rossum <guido@python.org> parents: 2097 diff changeset	4 #include <stdlib.h>
9290 2340f615da8f BSDI specific patches, inspired by Nigel Head and otto@mail.olympus.net. Guido van Rossum <guido@python.org> parents: 9079 diff changeset	5 #include <string.h>
25545 3731be28e1a3 Patch #618347: Work around Solaris 2.6 pthread.h bug. Will backport to 2.2. Martin v. Löwis <martin@v.loewis.de> parents: 22341 diff changeset	6 #if defined(__APPLE__) \|\| defined(HAVE_PTHREAD_DESTRUCTOR)
21724 884e57bf3ada Workaround for what is probably a problem in Apple's gcc: <pthread.h> fails Jack Jansen <jack.jansen@cwi.nl> parents: 20922 diff changeset	7 #define destructor xxdestructor
884e57bf3ada Workaround for what is probably a problem in Apple's gcc: <pthread.h> fails Jack Jansen <jack.jansen@cwi.nl> parents: 20922 diff changeset	8 #endif
3663 07164d30429d Got rid of florida hack and made it work with Solaris 2.5 pthreads. Guido van Rossum <guido@python.org> parents: 2097 diff changeset	9 #include <pthread.h>
25545 3731be28e1a3 Patch #618347: Work around Solaris 2.6 pthread.h bug. Will backport to 2.2. Martin v. Löwis <martin@v.loewis.de> parents: 22341 diff changeset	10 #if defined(__APPLE__) \|\| defined(HAVE_PTHREAD_DESTRUCTOR)
21724 884e57bf3ada Workaround for what is probably a problem in Apple's gcc: <pthread.h> fails Jack Jansen <jack.jansen@cwi.nl> parents: 20922 diff changeset	11 #undef destructor
884e57bf3ada Workaround for what is probably a problem in Apple's gcc: <pthread.h> fails Jack Jansen <jack.jansen@cwi.nl> parents: 20922 diff changeset	12 #endif
20398 c9a212329da6 Add SF patch #468347 -- mask signals for non-main pthreads, by Jason Lowe: Guido van Rossum <guido@python.org> parents: 19826 diff changeset	13 #include <signal.h>
22341 2548e2f323fa Document that _POSIX_SEMAPHORES is predefined. Martin v. Löwis <martin@v.loewis.de> parents: 22339 diff changeset	14
38794 f7d23bca599f Patch #1454481: Make thread stack size runtime tunable. Andrew MacIntyre <andymac@bullseye.apana.org.au> parents: 38592 diff changeset	15 /* The POSIX spec requires that use of pthread_attr_setstacksize
f7d23bca599f Patch #1454481: Make thread stack size runtime tunable. Andrew MacIntyre <andymac@bullseye.apana.org.au> parents: 38592 diff changeset	16 be conditional on _POSIX_THREAD_ATTR_STACKSIZE being defined. */
f7d23bca599f Patch #1454481: Make thread stack size runtime tunable. Andrew MacIntyre <andymac@bullseye.apana.org.au> parents: 38592 diff changeset	17 #ifdef _POSIX_THREAD_ATTR_STACKSIZE
f7d23bca599f Patch #1454481: Make thread stack size runtime tunable. Andrew MacIntyre <andymac@bullseye.apana.org.au> parents: 38592 diff changeset	18 #ifndef THREAD_STACK_SIZE
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	19 #define THREAD_STACK_SIZE 0 /* use default stack size */
38794 f7d23bca599f Patch #1454481: Make thread stack size runtime tunable. Andrew MacIntyre <andymac@bullseye.apana.org.au> parents: 38592 diff changeset	20 #endif
70447 ecf0ef85c72a Issue #9670: Increase the default stack size for secondary threads on Ned Deily <nad@acm.org> parents: 69228 diff changeset	21
ecf0ef85c72a Issue #9670: Increase the default stack size for secondary threads on Ned Deily <nad@acm.org> parents: 69228 diff changeset	22 #if (defined(__APPLE__) \|\| defined(__FreeBSD__)) && defined(THREAD_STACK_SIZE) && THREAD_STACK_SIZE == 0
ecf0ef85c72a Issue #9670: Increase the default stack size for secondary threads on Ned Deily <nad@acm.org> parents: 69228 diff changeset	23 /* The default stack size for new threads on OSX is small enough that
ecf0ef85c72a Issue #9670: Increase the default stack size for secondary threads on Ned Deily <nad@acm.org> parents: 69228 diff changeset	24 * we'll get hard crashes instead of 'maximum recursion depth exceeded'
ecf0ef85c72a Issue #9670: Increase the default stack size for secondary threads on Ned Deily <nad@acm.org> parents: 69228 diff changeset	25 * exceptions.
ecf0ef85c72a Issue #9670: Increase the default stack size for secondary threads on Ned Deily <nad@acm.org> parents: 69228 diff changeset	26 *
ecf0ef85c72a Issue #9670: Increase the default stack size for secondary threads on Ned Deily <nad@acm.org> parents: 69228 diff changeset	27 * The default stack size below is the minimal stack size where a
ecf0ef85c72a Issue #9670: Increase the default stack size for secondary threads on Ned Deily <nad@acm.org> parents: 69228 diff changeset	28 * simple recursive function doesn't cause a hard crash.
ecf0ef85c72a Issue #9670: Increase the default stack size for secondary threads on Ned Deily <nad@acm.org> parents: 69228 diff changeset	29 */
ecf0ef85c72a Issue #9670: Increase the default stack size for secondary threads on Ned Deily <nad@acm.org> parents: 69228 diff changeset	30 #undef THREAD_STACK_SIZE
ecf0ef85c72a Issue #9670: Increase the default stack size for secondary threads on Ned Deily <nad@acm.org> parents: 69228 diff changeset	31 #define THREAD_STACK_SIZE 0x400000
ecf0ef85c72a Issue #9670: Increase the default stack size for secondary threads on Ned Deily <nad@acm.org> parents: 69228 diff changeset	32 #endif
38794 f7d23bca599f Patch #1454481: Make thread stack size runtime tunable. Andrew MacIntyre <andymac@bullseye.apana.org.au> parents: 38592 diff changeset	33 /* for safety, ensure a viable minimum stacksize */
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	34 #define THREAD_STACK_MIN 0x8000 /* 32kB */
38794 f7d23bca599f Patch #1454481: Make thread stack size runtime tunable. Andrew MacIntyre <andymac@bullseye.apana.org.au> parents: 38592 diff changeset	35 #else /* !_POSIX_THREAD_ATTR_STACKSIZE */
f7d23bca599f Patch #1454481: Make thread stack size runtime tunable. Andrew MacIntyre <andymac@bullseye.apana.org.au> parents: 38592 diff changeset	36 #ifdef THREAD_STACK_SIZE
f7d23bca599f Patch #1454481: Make thread stack size runtime tunable. Andrew MacIntyre <andymac@bullseye.apana.org.au> parents: 38592 diff changeset	37 #error "THREAD_STACK_SIZE defined but _POSIX_THREAD_ATTR_STACKSIZE undefined"
f7d23bca599f Patch #1454481: Make thread stack size runtime tunable. Andrew MacIntyre <andymac@bullseye.apana.org.au> parents: 38592 diff changeset	38 #endif
f7d23bca599f Patch #1454481: Make thread stack size runtime tunable. Andrew MacIntyre <andymac@bullseye.apana.org.au> parents: 38592 diff changeset	39 #endif
f7d23bca599f Patch #1454481: Make thread stack size runtime tunable. Andrew MacIntyre <andymac@bullseye.apana.org.au> parents: 38592 diff changeset	40
22341 2548e2f323fa Document that _POSIX_SEMAPHORES is predefined. Martin v. Löwis <martin@v.loewis.de> parents: 22339 diff changeset	41 /* The POSIX spec says that implementations supporting the sem_*
2548e2f323fa Document that _POSIX_SEMAPHORES is predefined. Martin v. Löwis <martin@v.loewis.de> parents: 22339 diff changeset	42 family of functions must indicate this by defining
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	43 _POSIX_SEMAPHORES. */
22339 6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	44 #ifdef _POSIX_SEMAPHORES
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	45 /* On FreeBSD 4.x, _POSIX_SEMAPHORES is defined empty, so
34824 a50ffe65911b Add 0 to _POSIX_SEMAPHORES. Martin v. Löwis <martin@v.loewis.de> parents: 34762 diff changeset	46 we need to add 0 to make it work there as well. */
a50ffe65911b Add 0 to _POSIX_SEMAPHORES. Martin v. Löwis <martin@v.loewis.de> parents: 34762 diff changeset	47 #if (_POSIX_SEMAPHORES+0) == -1
34762 fcb507414c41 Patch #1163249 - Correctly handle _POSIX_SEMAPHORES == -1 to mean no Anthony Baxter <anthonybaxter@gmail.com> parents: 32526 diff changeset	48 #define HAVE_BROKEN_POSIX_SEMAPHORES
fcb507414c41 Patch #1163249 - Correctly handle _POSIX_SEMAPHORES == -1 to mean no Anthony Baxter <anthonybaxter@gmail.com> parents: 32526 diff changeset	49 #else
22339 6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	50 #include <semaphore.h>
6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	51 #include <errno.h>
6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	52 #endif
34762 fcb507414c41 Patch #1163249 - Correctly handle _POSIX_SEMAPHORES == -1 to mean no Anthony Baxter <anthonybaxter@gmail.com> parents: 32526 diff changeset	53 #endif
3663 07164d30429d Got rid of florida hack and made it work with Solaris 2.5 pthreads. Guido van Rossum <guido@python.org> parents: 2097 diff changeset	54
37168 4f97b6a229ce Patch #1396919: Reenable the system scope threads on FreeBSD 5.4 Hye-Shik Chang <hyeshik@gmail.com> parents: 35607 diff changeset	55 /* Before FreeBSD 5.4, system scope threads was very limited resource
4f97b6a229ce Patch #1396919: Reenable the system scope threads on FreeBSD 5.4 Hye-Shik Chang <hyeshik@gmail.com> parents: 35607 diff changeset	56 in default setting. So the process scope is preferred to get
4f97b6a229ce Patch #1396919: Reenable the system scope threads on FreeBSD 5.4 Hye-Shik Chang <hyeshik@gmail.com> parents: 35607 diff changeset	57 enough number of threads to work. */
4f97b6a229ce Patch #1396919: Reenable the system scope threads on FreeBSD 5.4 Hye-Shik Chang <hyeshik@gmail.com> parents: 35607 diff changeset	58 #ifdef __FreeBSD__
4f97b6a229ce Patch #1396919: Reenable the system scope threads on FreeBSD 5.4 Hye-Shik Chang <hyeshik@gmail.com> parents: 35607 diff changeset	59 #include <osreldate.h>
4f97b6a229ce Patch #1396919: Reenable the system scope threads on FreeBSD 5.4 Hye-Shik Chang <hyeshik@gmail.com> parents: 35607 diff changeset	60 #if __FreeBSD_version >= 500000 && __FreeBSD_version < 504101
4f97b6a229ce Patch #1396919: Reenable the system scope threads on FreeBSD 5.4 Hye-Shik Chang <hyeshik@gmail.com> parents: 35607 diff changeset	61 #undef PTHREAD_SYSTEM_SCHED_SUPPORTED
4f97b6a229ce Patch #1396919: Reenable the system scope threads on FreeBSD 5.4 Hye-Shik Chang <hyeshik@gmail.com> parents: 35607 diff changeset	62 #endif
4f97b6a229ce Patch #1396919: Reenable the system scope threads on FreeBSD 5.4 Hye-Shik Chang <hyeshik@gmail.com> parents: 35607 diff changeset	63 #endif
4f97b6a229ce Patch #1396919: Reenable the system scope threads on FreeBSD 5.4 Hye-Shik Chang <hyeshik@gmail.com> parents: 35607 diff changeset	64
26598 56dbd9079a13 Patch #650415: Avoid redefinition of macros. Martin v. Löwis <martin@v.loewis.de> parents: 26499 diff changeset	65 #if !defined(pthread_attr_default)
5493 ef93d51dab36 Support for various versions of the pthread draft. Guido van Rossum <guido@python.org> parents: 5395 diff changeset	66 # define pthread_attr_default ((pthread_attr_t *)NULL)
26598 56dbd9079a13 Patch #650415: Avoid redefinition of macros. Martin v. Löwis <martin@v.loewis.de> parents: 26499 diff changeset	67 #endif
56dbd9079a13 Patch #650415: Avoid redefinition of macros. Martin v. Löwis <martin@v.loewis.de> parents: 26499 diff changeset	68 #if !defined(pthread_mutexattr_default)
5493 ef93d51dab36 Support for various versions of the pthread draft. Guido van Rossum <guido@python.org> parents: 5395 diff changeset	69 # define pthread_mutexattr_default ((pthread_mutexattr_t *)NULL)
26598 56dbd9079a13 Patch #650415: Avoid redefinition of macros. Martin v. Löwis <martin@v.loewis.de> parents: 26499 diff changeset	70 #endif
56dbd9079a13 Patch #650415: Avoid redefinition of macros. Martin v. Löwis <martin@v.loewis.de> parents: 26499 diff changeset	71 #if !defined(pthread_condattr_default)
5493 ef93d51dab36 Support for various versions of the pthread draft. Guido van Rossum <guido@python.org> parents: 5395 diff changeset	72 # define pthread_condattr_default ((pthread_condattr_t *)NULL)
3965 9c05ff6fb0a4 Changes necessary for AIX. Guido van Rossum <guido@python.org> parents: 3663 diff changeset	73 #endif
1628 a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	74
5493 ef93d51dab36 Support for various versions of the pthread draft. Guido van Rossum <guido@python.org> parents: 5395 diff changeset	75
22339 6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	76 /* Whether or not to use semaphores directly rather than emulating them with
6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	77 * mutexes and condition variables:
6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	78 */
27320 1562c1e10b49 Don't use Posix semaphores on Solaris 8. Fixes #662787. Martin v. Löwis <martin@v.loewis.de> parents: 26598 diff changeset	79 #if defined(_POSIX_SEMAPHORES) && !defined(HAVE_BROKEN_POSIX_SEMAPHORES)
22339 6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	80 # define USE_SEMAPHORES
6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	81 #else
6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	82 # undef USE_SEMAPHORES
6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	83 #endif
6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	84
6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	85
20398 c9a212329da6 Add SF patch #468347 -- mask signals for non-main pthreads, by Jason Lowe: Guido van Rossum <guido@python.org> parents: 19826 diff changeset	86 /* On platforms that don't use standard POSIX threads pthread_sigmask()
c9a212329da6 Add SF patch #468347 -- mask signals for non-main pthreads, by Jason Lowe: Guido van Rossum <guido@python.org> parents: 19826 diff changeset	87 * isn't present. DEC threads uses sigprocmask() instead as do most
c9a212329da6 Add SF patch #468347 -- mask signals for non-main pthreads, by Jason Lowe: Guido van Rossum <guido@python.org> parents: 19826 diff changeset	88 * other UNIX International compliant systems that don't have the full
c9a212329da6 Add SF patch #468347 -- mask signals for non-main pthreads, by Jason Lowe: Guido van Rossum <guido@python.org> parents: 19826 diff changeset	89 * pthread implementation.
c9a212329da6 Add SF patch #468347 -- mask signals for non-main pthreads, by Jason Lowe: Guido van Rossum <guido@python.org> parents: 19826 diff changeset	90 */
29972 a408ac5527c3 Patch 775605: Cygwin pthread_sigmask() workaround patch Jason Tishler <jason@tishler.net> parents: 28687 diff changeset	91 #if defined(HAVE_PTHREAD_SIGMASK) && !defined(HAVE_BROKEN_PTHREAD_SIGMASK)
20398 c9a212329da6 Add SF patch #468347 -- mask signals for non-main pthreads, by Jason Lowe: Guido van Rossum <guido@python.org> parents: 19826 diff changeset	92 # define SET_THREAD_SIGMASK pthread_sigmask
c9a212329da6 Add SF patch #468347 -- mask signals for non-main pthreads, by Jason Lowe: Guido van Rossum <guido@python.org> parents: 19826 diff changeset	93 #else
c9a212329da6 Add SF patch #468347 -- mask signals for non-main pthreads, by Jason Lowe: Guido van Rossum <guido@python.org> parents: 19826 diff changeset	94 # define SET_THREAD_SIGMASK sigprocmask
c9a212329da6 Add SF patch #468347 -- mask signals for non-main pthreads, by Jason Lowe: Guido van Rossum <guido@python.org> parents: 19826 diff changeset	95 #endif
c9a212329da6 Add SF patch #468347 -- mask signals for non-main pthreads, by Jason Lowe: Guido van Rossum <guido@python.org> parents: 19826 diff changeset	96
c9a212329da6 Add SF patch #468347 -- mask signals for non-main pthreads, by Jason Lowe: Guido van Rossum <guido@python.org> parents: 19826 diff changeset	97
1629 4121afd76d73 Tim's changes; removed some remaining non-functional ifdefs Guido van Rossum <guido@python.org> parents: 1628 diff changeset	98 /* A pthread mutex isn't sufficient to model the Python lock type
4121afd76d73 Tim's changes; removed some remaining non-functional ifdefs Guido van Rossum <guido@python.org> parents: 1628 diff changeset	99 * because, according to Draft 5 of the docs (P1003.4a/D5), both of the
4121afd76d73 Tim's changes; removed some remaining non-functional ifdefs Guido van Rossum <guido@python.org> parents: 1628 diff changeset	100 * following are undefined:
4121afd76d73 Tim's changes; removed some remaining non-functional ifdefs Guido van Rossum <guido@python.org> parents: 1628 diff changeset	101 * -> a thread tries to lock a mutex it already has locked
4121afd76d73 Tim's changes; removed some remaining non-functional ifdefs Guido van Rossum <guido@python.org> parents: 1628 diff changeset	102 * -> a thread tries to unlock a mutex locked by a different thread
4121afd76d73 Tim's changes; removed some remaining non-functional ifdefs Guido van Rossum <guido@python.org> parents: 1628 diff changeset	103 * pthread mutexes are designed for serializing threads over short pieces
4121afd76d73 Tim's changes; removed some remaining non-functional ifdefs Guido van Rossum <guido@python.org> parents: 1628 diff changeset	104 * of code anyway, so wouldn't be an appropriate implementation of
1628 a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	105 * Python's locks regardless.
1629 4121afd76d73 Tim's changes; removed some remaining non-functional ifdefs Guido van Rossum <guido@python.org> parents: 1628 diff changeset	106 *
4121afd76d73 Tim's changes; removed some remaining non-functional ifdefs Guido van Rossum <guido@python.org> parents: 1628 diff changeset	107 * The pthread_lock struct implements a Python lock as a "locked?" bit
4121afd76d73 Tim's changes; removed some remaining non-functional ifdefs Guido van Rossum <guido@python.org> parents: 1628 diff changeset	108 * and a <condition, mutex> pair. In general, if the bit can be acquired
4121afd76d73 Tim's changes; removed some remaining non-functional ifdefs Guido van Rossum <guido@python.org> parents: 1628 diff changeset	109 * instantly, it is, else the pair is used to block the thread until the
4121afd76d73 Tim's changes; removed some remaining non-functional ifdefs Guido van Rossum <guido@python.org> parents: 1628 diff changeset	110 * bit is cleared. 9 May 1994 tim@ksr.com
1628 a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	111 */
1629 4121afd76d73 Tim's changes; removed some remaining non-functional ifdefs Guido van Rossum <guido@python.org> parents: 1628 diff changeset	112
1628 a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	113 typedef struct {
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	114 char locked; /* 0=unlocked, 1=locked */
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	115 /* a <cond, mutex> pair to handle an acquire of a locked lock */
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	116 pthread_cond_t lock_released;
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	117 pthread_mutex_t mut;
1628 a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	118 } pthread_lock;
a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	119
9290 2340f615da8f BSDI specific patches, inspired by Nigel Head and otto@mail.olympus.net. Guido van Rossum <guido@python.org> parents: 9079 diff changeset	120 #define CHECK_STATUS(name) if (status != 0) { perror(name); error = 1; }
1629 4121afd76d73 Tim's changes; removed some remaining non-functional ifdefs Guido van Rossum <guido@python.org> parents: 1628 diff changeset	121
1628 a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	122 /*
a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	123 * Initialization.
a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	124 */
9290 2340f615da8f BSDI specific patches, inspired by Nigel Head and otto@mail.olympus.net. Guido van Rossum <guido@python.org> parents: 9079 diff changeset	125
2340f615da8f BSDI specific patches, inspired by Nigel Head and otto@mail.olympus.net. Guido van Rossum <guido@python.org> parents: 9079 diff changeset	126 #ifdef _HAVE_BSDI
13658 f79434ee41fa Mass ANSIfication of function definitions. Doesn't cover all 'extern' Thomas Wouters <thomas@python.org> parents: 13256 diff changeset	127 static
f79434ee41fa Mass ANSIfication of function definitions. Doesn't cover all 'extern' Thomas Wouters <thomas@python.org> parents: 13256 diff changeset	128 void _noop(void)
9290 2340f615da8f BSDI specific patches, inspired by Nigel Head and otto@mail.olympus.net. Guido van Rossum <guido@python.org> parents: 9079 diff changeset	129 {
2340f615da8f BSDI specific patches, inspired by Nigel Head and otto@mail.olympus.net. Guido van Rossum <guido@python.org> parents: 9079 diff changeset	130 }
2340f615da8f BSDI specific patches, inspired by Nigel Head and otto@mail.olympus.net. Guido van Rossum <guido@python.org> parents: 9079 diff changeset	131
13658 f79434ee41fa Mass ANSIfication of function definitions. Doesn't cover all 'extern' Thomas Wouters <thomas@python.org> parents: 13256 diff changeset	132 static void
f79434ee41fa Mass ANSIfication of function definitions. Doesn't cover all 'extern' Thomas Wouters <thomas@python.org> parents: 13256 diff changeset	133 PyThread__init_thread(void)
9290 2340f615da8f BSDI specific patches, inspired by Nigel Head and otto@mail.olympus.net. Guido van Rossum <guido@python.org> parents: 9079 diff changeset	134 {
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	135 /* DO AN INIT BY STARTING THE THREAD */
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	136 static int dummy = 0;
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	137 pthread_t thread1;
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	138 pthread_create(&thread1, NULL, (void *) _noop, &dummy);
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	139 pthread_join(thread1, NULL);
9290 2340f615da8f BSDI specific patches, inspired by Nigel Head and otto@mail.olympus.net. Guido van Rossum <guido@python.org> parents: 9079 diff changeset	140 }
2340f615da8f BSDI specific patches, inspired by Nigel Head and otto@mail.olympus.net. Guido van Rossum <guido@python.org> parents: 9079 diff changeset	141
2340f615da8f BSDI specific patches, inspired by Nigel Head and otto@mail.olympus.net. Guido van Rossum <guido@python.org> parents: 9079 diff changeset	142 #else /* !_HAVE_BSDI */
2340f615da8f BSDI specific patches, inspired by Nigel Head and otto@mail.olympus.net. Guido van Rossum <guido@python.org> parents: 9079 diff changeset	143
13658 f79434ee41fa Mass ANSIfication of function definitions. Doesn't cover all 'extern' Thomas Wouters <thomas@python.org> parents: 13256 diff changeset	144 static void
f79434ee41fa Mass ANSIfication of function definitions. Doesn't cover all 'extern' Thomas Wouters <thomas@python.org> parents: 13256 diff changeset	145 PyThread__init_thread(void)
1628 a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	146 {
9079 4d2cb212c8d1 Apparently on AIX when using gcc you need to call pthread_init() Guido van Rossum <guido@python.org> parents: 9070 diff changeset	147 #if defined(_AIX) && defined(__GNUC__)
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	148 pthread_init();
9079 4d2cb212c8d1 Apparently on AIX when using gcc you need to call pthread_init() Guido van Rossum <guido@python.org> parents: 9070 diff changeset	149 #endif
1628 a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	150 }
a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	151
9290 2340f615da8f BSDI specific patches, inspired by Nigel Head and otto@mail.olympus.net. Guido van Rossum <guido@python.org> parents: 9079 diff changeset	152 #endif /* !_HAVE_BSDI */
2340f615da8f BSDI specific patches, inspired by Nigel Head and otto@mail.olympus.net. Guido van Rossum <guido@python.org> parents: 9079 diff changeset	153
1628 a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	154 /*
a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	155 * Thread support.
a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	156 */
1629 4121afd76d73 Tim's changes; removed some remaining non-functional ifdefs Guido van Rossum <guido@python.org> parents: 1628 diff changeset	157
4121afd76d73 Tim's changes; removed some remaining non-functional ifdefs Guido van Rossum <guido@python.org> parents: 1628 diff changeset	158
20468 ebfd87e87884 Partial patch from SF #452266, by Jason Petrone. Guido van Rossum <guido@python.org> parents: 20431 diff changeset	159 long
13658 f79434ee41fa Mass ANSIfication of function definitions. Doesn't cover all 'extern' Thomas Wouters <thomas@python.org> parents: 13256 diff changeset	160 PyThread_start_new_thread(void (func)(void ), void *arg)
1628 a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	161 {
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	162 pthread_t th;
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	163 int status;
19826 8ef456949b76 Improve threading on Solaris, according to SF patch #460269, submitted Guido van Rossum <guido@python.org> parents: 19549 diff changeset	164 #if defined(THREAD_STACK_SIZE) \|\| defined(PTHREAD_SYSTEM_SCHED_SUPPORTED)
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	165 pthread_attr_t attrs;
19549 11a758c56027 GUSI on the Mac creates threads with a default stack size of 20KB, which is Jack Jansen <jack.jansen@cwi.nl> parents: 14375 diff changeset	166 #endif
38794 f7d23bca599f Patch #1454481: Make thread stack size runtime tunable. Andrew MacIntyre <andymac@bullseye.apana.org.au> parents: 38592 diff changeset	167 #if defined(THREAD_STACK_SIZE)
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	168 size_t tss;
38794 f7d23bca599f Patch #1454481: Make thread stack size runtime tunable. Andrew MacIntyre <andymac@bullseye.apana.org.au> parents: 38592 diff changeset	169 #endif
f7d23bca599f Patch #1454481: Make thread stack size runtime tunable. Andrew MacIntyre <andymac@bullseye.apana.org.au> parents: 38592 diff changeset	170
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	171 dprintf(("PyThread_start_new_thread called\n"));
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	172 if (!initialized)
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	173 PyThread_init_thread();
5493 ef93d51dab36 Support for various versions of the pthread draft. Guido van Rossum <guido@python.org> parents: 5395 diff changeset	174
19826 8ef456949b76 Improve threading on Solaris, according to SF patch #460269, submitted Guido van Rossum <guido@python.org> parents: 19549 diff changeset	175 #if defined(THREAD_STACK_SIZE) \|\| defined(PTHREAD_SYSTEM_SCHED_SUPPORTED)
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	176 if (pthread_attr_init(&attrs) != 0)
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	177 return -1;
19826 8ef456949b76 Improve threading on Solaris, according to SF patch #460269, submitted Guido van Rossum <guido@python.org> parents: 19549 diff changeset	178 #endif
38794 f7d23bca599f Patch #1454481: Make thread stack size runtime tunable. Andrew MacIntyre <andymac@bullseye.apana.org.au> parents: 38592 diff changeset	179 #if defined(THREAD_STACK_SIZE)
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	180 tss = (_pythread_stacksize != 0) ? _pythread_stacksize
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	181 : THREAD_STACK_SIZE;
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	182 if (tss != 0) {
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	183 if (pthread_attr_setstacksize(&attrs, tss) != 0) {
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	184 pthread_attr_destroy(&attrs);
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	185 return -1;
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	186 }
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	187 }
19549 11a758c56027 GUSI on the Mac creates threads with a default stack size of 20KB, which is Jack Jansen <jack.jansen@cwi.nl> parents: 14375 diff changeset	188 #endif
37168 4f97b6a229ce Patch #1396919: Reenable the system scope threads on FreeBSD 5.4 Hye-Shik Chang <hyeshik@gmail.com> parents: 35607 diff changeset	189 #if defined(PTHREAD_SYSTEM_SCHED_SUPPORTED)
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	190 pthread_attr_setscope(&attrs, PTHREAD_SCOPE_SYSTEM);
19826 8ef456949b76 Improve threading on Solaris, according to SF patch #460269, submitted Guido van Rossum <guido@python.org> parents: 19549 diff changeset	191 #endif
20398 c9a212329da6 Add SF patch #468347 -- mask signals for non-main pthreads, by Jason Lowe: Guido van Rossum <guido@python.org> parents: 19826 diff changeset	192
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	193 status = pthread_create(&th,
19826 8ef456949b76 Improve threading on Solaris, according to SF patch #460269, submitted Guido van Rossum <guido@python.org> parents: 19549 diff changeset	194 #if defined(THREAD_STACK_SIZE) \|\| defined(PTHREAD_SYSTEM_SCHED_SUPPORTED)
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	195 &attrs,
19549 11a758c56027 GUSI on the Mac creates threads with a default stack size of 20KB, which is Jack Jansen <jack.jansen@cwi.nl> parents: 14375 diff changeset	196 #else
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	197 (pthread_attr_t*)NULL,
19549 11a758c56027 GUSI on the Mac creates threads with a default stack size of 20KB, which is Jack Jansen <jack.jansen@cwi.nl> parents: 14375 diff changeset	198 #endif
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	199 (void* ()(void ))func,
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	200 (void *)arg
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	201 );
20398 c9a212329da6 Add SF patch #468347 -- mask signals for non-main pthreads, by Jason Lowe: Guido van Rossum <guido@python.org> parents: 19826 diff changeset	202
20922 7a991d012cd6 Fix memory leak. This is part of SF patch #478006. Fred Drake <fdrake@acm.org> parents: 20468 diff changeset	203 #if defined(THREAD_STACK_SIZE) \|\| defined(PTHREAD_SYSTEM_SCHED_SUPPORTED)
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	204 pthread_attr_destroy(&attrs);
19549 11a758c56027 GUSI on the Mac creates threads with a default stack size of 20KB, which is Jack Jansen <jack.jansen@cwi.nl> parents: 14375 diff changeset	205 #endif
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	206 if (status != 0)
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	207 return -1;
28687 40d287c3d906 Patch #716969: Detect thread creation failure. Will backport to 2.2. Martin v. Löwis <martin@v.loewis.de> parents: 28673 diff changeset	208
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	209 pthread_detach(th);
28687 40d287c3d906 Patch #716969: Detect thread creation failure. Will backport to 2.2. Martin v. Löwis <martin@v.loewis.de> parents: 28673 diff changeset	210
20468 ebfd87e87884 Partial patch from SF #452266, by Jason Petrone. Guido van Rossum <guido@python.org> parents: 20431 diff changeset	211 #if SIZEOF_PTHREAD_T <= SIZEOF_LONG
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	212 return (long) th;
20468 ebfd87e87884 Partial patch from SF #452266, by Jason Petrone. Guido van Rossum <guido@python.org> parents: 20431 diff changeset	213 #else
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	214 return (long) (long ) &th;
20468 ebfd87e87884 Partial patch from SF #452266, by Jason Petrone. Guido van Rossum <guido@python.org> parents: 20431 diff changeset	215 #endif
1628 a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	216 }
a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	217
14144 31cda87e9ff4 This patch partly (some stuff went in already) ports Python to Monterey. Trent Mick <trentm@activestate.com> parents: 13658 diff changeset	218 /* XXX This implementation is considered (to quote Tim Peters) "inherently
31cda87e9ff4 This patch partly (some stuff went in already) ports Python to Monterey. Trent Mick <trentm@activestate.com> parents: 13658 diff changeset	219 hosed" because:
31611 0979fa062deb typo Skip Montanaro <skip@pobox.com> parents: 31470 diff changeset	220 - It does not guarantee the promise that a non-zero integer is returned.
14144 31cda87e9ff4 This patch partly (some stuff went in already) ports Python to Monterey. Trent Mick <trentm@activestate.com> parents: 13658 diff changeset	221 - The cast to long is inherently unsafe.
31cda87e9ff4 This patch partly (some stuff went in already) ports Python to Monterey. Trent Mick <trentm@activestate.com> parents: 13658 diff changeset	222 - It is not clear that the 'volatile' (for AIX?) and ugly casting in the
31cda87e9ff4 This patch partly (some stuff went in already) ports Python to Monterey. Trent Mick <trentm@activestate.com> parents: 13658 diff changeset	223 latter return statement (for Alpha OSF/1) are any longer necessary.
31cda87e9ff4 This patch partly (some stuff went in already) ports Python to Monterey. Trent Mick <trentm@activestate.com> parents: 13658 diff changeset	224 */
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	225 long
13658 f79434ee41fa Mass ANSIfication of function definitions. Doesn't cover all 'extern' Thomas Wouters <thomas@python.org> parents: 13256 diff changeset	226 PyThread_get_thread_ident(void)
1651 7e5f97bab1e6 ceval.c: dict of local mapping is now a tuple Guido van Rossum <guido@python.org> parents: 1629 diff changeset	227 {
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	228 volatile pthread_t threadid;
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	229 if (!initialized)
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	230 PyThread_init_thread();
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	231 /* Jump through some hoops for Alpha OSF/1 */
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	232 threadid = pthread_self();
14144 31cda87e9ff4 This patch partly (some stuff went in already) ports Python to Monterey. Trent Mick <trentm@activestate.com> parents: 13658 diff changeset	233 #if SIZEOF_PTHREAD_T <= SIZEOF_LONG
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	234 return (long) threadid;
14144 31cda87e9ff4 This patch partly (some stuff went in already) ports Python to Monterey. Trent Mick <trentm@activestate.com> parents: 13658 diff changeset	235 #else
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	236 return (long) (long ) &threadid;
14144 31cda87e9ff4 This patch partly (some stuff went in already) ports Python to Monterey. Trent Mick <trentm@activestate.com> parents: 13658 diff changeset	237 #endif
1651 7e5f97bab1e6 ceval.c: dict of local mapping is now a tuple Guido van Rossum <guido@python.org> parents: 1629 diff changeset	238 }
7e5f97bab1e6 ceval.c: dict of local mapping is now a tuple Guido van Rossum <guido@python.org> parents: 1629 diff changeset	239
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	240 void
13658 f79434ee41fa Mass ANSIfication of function definitions. Doesn't cover all 'extern' Thomas Wouters <thomas@python.org> parents: 13256 diff changeset	241 PyThread_exit_thread(void)
1628 a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	242 {
61463 fd25030223b0 Untabify C files. Will watch buildbots. Antoine Pitrou <solipsis@pitrou.net> parents: 59086 diff changeset	243 dprintf(("PyThread_exit_thread called\n"));
fd25030223b0 Untabify C files. Will watch buildbots. Antoine Pitrou <solipsis@pitrou.net> parents: 59086 diff changeset	244 if (!initialized) {
fd25030223b0 Untabify C files. Will watch buildbots. Antoine Pitrou <solipsis@pitrou.net> parents: 59086 diff changeset	245 exit(0);
fd25030223b0 Untabify C files. Will watch buildbots. Antoine Pitrou <solipsis@pitrou.net> parents: 59086 diff changeset	246 }
1628 a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	247 }
a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	248
22339 6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	249 #ifdef USE_SEMAPHORES
6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	250
6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	251 /*
6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	252 * Lock support.
6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	253 */
6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	254
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	255 PyThread_type_lock
22339 6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	256 PyThread_allocate_lock(void)
6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	257 {
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	258 sem_t *lock;
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	259 int status, error = 0;
22339 6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	260
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	261 dprintf(("PyThread_allocate_lock called\n"));
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	262 if (!initialized)
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	263 PyThread_init_thread();
22339 6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	264
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	265 lock = (sem_t *)malloc(sizeof(sem_t));
22339 6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	266
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	267 if (lock) {
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	268 status = sem_init(lock,0,1);
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	269 CHECK_STATUS("sem_init");
22339 6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	270
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	271 if (error) {
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	272 free((void *)lock);
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	273 lock = NULL;
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	274 }
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	275 }
22339 6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	276
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	277 dprintf(("PyThread_allocate_lock() -> %p\n", lock));
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	278 return (PyThread_type_lock)lock;
22339 6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	279 }
6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	280
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	281 void
22339 6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	282 PyThread_free_lock(PyThread_type_lock lock)
6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	283 {
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	284 sem_t thelock = (sem_t )lock;
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	285 int status, error = 0;
22339 6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	286
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	287 dprintf(("PyThread_free_lock(%p) called\n", lock));
22339 6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	288
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	289 if (!thelock)
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	290 return;
22339 6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	291
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	292 status = sem_destroy(thelock);
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	293 CHECK_STATUS("sem_destroy");
22339 6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	294
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	295 free((void *)thelock);
22339 6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	296 }
6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	297
6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	298 /*
6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	299 * As of February 2002, Cygwin thread implementations mistakenly report error
6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	300 * codes in the return value of the sem_ calls (like the pthread_ functions).
6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	301 * Correct implementations return -1 and put the code in errno. This supports
6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	302 * either.
6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	303 */
6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	304 static int
6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	305 fix_status(int status)
6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	306 {
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	307 return (status == -1) ? errno : status;
22339 6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	308 }
6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	309
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	310 int
22339 6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	311 PyThread_acquire_lock(PyThread_type_lock lock, int waitflag)
6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	312 {
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	313 int success;
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	314 sem_t thelock = (sem_t )lock;
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	315 int status, error = 0;
22339 6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	316
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	317 dprintf(("PyThread_acquire_lock(%p, %d) called\n", lock, waitflag));
22339 6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	318
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	319 do {
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	320 if (waitflag)
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	321 status = fix_status(sem_wait(thelock));
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	322 else
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	323 status = fix_status(sem_trywait(thelock));
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	324 } while (status == EINTR); /* Retry if interrupted by a signal */
22339 6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	325
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	326 if (waitflag) {
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	327 CHECK_STATUS("sem_wait");
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	328 } else if (status != EAGAIN) {
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	329 CHECK_STATUS("sem_trywait");
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	330 }
22339 6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	331
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	332 success = (status == 0) ? 1 : 0;
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	333
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	334 dprintf(("PyThread_acquire_lock(%p, %d) -> %d\n", lock, waitflag, success));
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	335 return success;
22339 6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	336 }
6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	337
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	338 void
22339 6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	339 PyThread_release_lock(PyThread_type_lock lock)
6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	340 {
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	341 sem_t thelock = (sem_t )lock;
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	342 int status, error = 0;
22339 6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	343
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	344 dprintf(("PyThread_release_lock(%p) called\n", lock));
22339 6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	345
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	346 status = sem_post(thelock);
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	347 CHECK_STATUS("sem_post");
22339 6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	348 }
6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	349
6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	350 #else /* USE_SEMAPHORES */
6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	351
1628 a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	352 /*
a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	353 * Lock support.
a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	354 */
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	355 PyThread_type_lock
13658 f79434ee41fa Mass ANSIfication of function definitions. Doesn't cover all 'extern' Thomas Wouters <thomas@python.org> parents: 13256 diff changeset	356 PyThread_allocate_lock(void)
1628 a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	357 {
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	358 pthread_lock *lock;
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	359 int status, error = 0;
1628 a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	360
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	361 dprintf(("PyThread_allocate_lock called\n"));
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	362 if (!initialized)
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	363 PyThread_init_thread();
1628 a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	364
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	365 lock = (pthread_lock *) malloc(sizeof(pthread_lock));
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	366 if (lock) {
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	367 memset((void *)lock, '\0', sizeof(pthread_lock));
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	368 lock->locked = 0;
1629 4121afd76d73 Tim's changes; removed some remaining non-functional ifdefs Guido van Rossum <guido@python.org> parents: 1628 diff changeset	369
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	370 status = pthread_mutex_init(&lock->mut,
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	371 pthread_mutexattr_default);
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	372 CHECK_STATUS("pthread_mutex_init");
1629 4121afd76d73 Tim's changes; removed some remaining non-functional ifdefs Guido van Rossum <guido@python.org> parents: 1628 diff changeset	373
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	374 status = pthread_cond_init(&lock->lock_released,
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	375 pthread_condattr_default);
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	376 CHECK_STATUS("pthread_cond_init");
1629 4121afd76d73 Tim's changes; removed some remaining non-functional ifdefs Guido van Rossum <guido@python.org> parents: 1628 diff changeset	377
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	378 if (error) {
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	379 free((void *)lock);
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	380 lock = 0;
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	381 }
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	382 }
1628 a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	383
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	384 dprintf(("PyThread_allocate_lock() -> %p\n", lock));
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	385 return (PyThread_type_lock) lock;
1628 a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	386 }
a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	387
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	388 void
13658 f79434ee41fa Mass ANSIfication of function definitions. Doesn't cover all 'extern' Thomas Wouters <thomas@python.org> parents: 13256 diff changeset	389 PyThread_free_lock(PyThread_type_lock lock)
1628 a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	390 {
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	391 pthread_lock thelock = (pthread_lock )lock;
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	392 int status, error = 0;
1629 4121afd76d73 Tim's changes; removed some remaining non-functional ifdefs Guido van Rossum <guido@python.org> parents: 1628 diff changeset	393
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	394 dprintf(("PyThread_free_lock(%p) called\n", lock));
1629 4121afd76d73 Tim's changes; removed some remaining non-functional ifdefs Guido van Rossum <guido@python.org> parents: 1628 diff changeset	395
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	396 status = pthread_mutex_destroy( &thelock->mut );
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	397 CHECK_STATUS("pthread_mutex_destroy");
1629 4121afd76d73 Tim's changes; removed some remaining non-functional ifdefs Guido van Rossum <guido@python.org> parents: 1628 diff changeset	398
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	399 status = pthread_cond_destroy( &thelock->lock_released );
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	400 CHECK_STATUS("pthread_cond_destroy");
1629 4121afd76d73 Tim's changes; removed some remaining non-functional ifdefs Guido van Rossum <guido@python.org> parents: 1628 diff changeset	401
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	402 free((void *)thelock);
1628 a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	403 }
a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	404
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	405 int
13658 f79434ee41fa Mass ANSIfication of function definitions. Doesn't cover all 'extern' Thomas Wouters <thomas@python.org> parents: 13256 diff changeset	406 PyThread_acquire_lock(PyThread_type_lock lock, int waitflag)
1628 a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	407 {
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	408 int success;
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	409 pthread_lock thelock = (pthread_lock )lock;
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	410 int status, error = 0;
1628 a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	411
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	412 dprintf(("PyThread_acquire_lock(%p, %d) called\n", lock, waitflag));
1629 4121afd76d73 Tim's changes; removed some remaining non-functional ifdefs Guido van Rossum <guido@python.org> parents: 1628 diff changeset	413
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	414 status = pthread_mutex_lock( &thelock->mut );
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	415 CHECK_STATUS("pthread_mutex_lock[1]");
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	416 success = thelock->locked == 0;
1629 4121afd76d73 Tim's changes; removed some remaining non-functional ifdefs Guido van Rossum <guido@python.org> parents: 1628 diff changeset	417
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	418 if ( !success && waitflag ) {
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	419 /* continue trying until we get the lock */
1628 a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	420
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	421 /* mut must be locked by me -- part of the condition
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	422 * protocol */
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	423 while ( thelock->locked ) {
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	424 status = pthread_cond_wait(&thelock->lock_released,
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	425 &thelock->mut);
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	426 CHECK_STATUS("pthread_cond_wait");
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	427 }
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	428 success = 1;
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	429 }
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	430 if (success) thelock->locked = 1;
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	431 status = pthread_mutex_unlock( &thelock->mut );
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	432 CHECK_STATUS("pthread_mutex_unlock[1]");
28673 c1ba50790c83 Patch #711835: Remove unnecessary lock operations. Will backport to 2.2. Martin v. Löwis <martin@v.loewis.de> parents: 27320 diff changeset	433
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	434 if (error) success = 0;
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	435 dprintf(("PyThread_acquire_lock(%p, %d) -> %d\n", lock, waitflag, success));
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	436 return success;
1628 a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	437 }
a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	438
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	439 void
13658 f79434ee41fa Mass ANSIfication of function definitions. Doesn't cover all 'extern' Thomas Wouters <thomas@python.org> parents: 13256 diff changeset	440 PyThread_release_lock(PyThread_type_lock lock)
1628 a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	441 {
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	442 pthread_lock thelock = (pthread_lock )lock;
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	443 int status, error = 0;
1629 4121afd76d73 Tim's changes; removed some remaining non-functional ifdefs Guido van Rossum <guido@python.org> parents: 1628 diff changeset	444
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	445 dprintf(("PyThread_release_lock(%p) called\n", lock));
1629 4121afd76d73 Tim's changes; removed some remaining non-functional ifdefs Guido van Rossum <guido@python.org> parents: 1628 diff changeset	446
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	447 status = pthread_mutex_lock( &thelock->mut );
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	448 CHECK_STATUS("pthread_mutex_lock[3]");
1628 a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	449
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	450 thelock->locked = 0;
1628 a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	451
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	452 status = pthread_mutex_unlock( &thelock->mut );
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	453 CHECK_STATUS("pthread_mutex_unlock[3]");
1629 4121afd76d73 Tim's changes; removed some remaining non-functional ifdefs Guido van Rossum <guido@python.org> parents: 1628 diff changeset	454
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	455 /* wake up someone (anyone, if any) waiting on the lock */
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	456 status = pthread_cond_signal( &thelock->lock_released );
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	457 CHECK_STATUS("pthread_cond_signal");
1628 a9dd2e1ea5c9 Split thread.c into a number of system-specific files. Guido van Rossum <guido@python.org> parents: diff changeset	458 }
22339 6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	459
6c3e32357d91 Patch #525532: Add support for POSIX semaphores. Martin v. Löwis <martin@v.loewis.de> parents: 21766 diff changeset	460 #endif /* USE_SEMAPHORES */
38794 f7d23bca599f Patch #1454481: Make thread stack size runtime tunable. Andrew MacIntyre <andymac@bullseye.apana.org.au> parents: 38592 diff changeset	461
f7d23bca599f Patch #1454481: Make thread stack size runtime tunable. Andrew MacIntyre <andymac@bullseye.apana.org.au> parents: 38592 diff changeset	462 /* set the thread stack size.
f7d23bca599f Patch #1454481: Make thread stack size runtime tunable. Andrew MacIntyre <andymac@bullseye.apana.org.au> parents: 38592 diff changeset	463 * Return 0 if size is valid, -1 if size is invalid,
f7d23bca599f Patch #1454481: Make thread stack size runtime tunable. Andrew MacIntyre <andymac@bullseye.apana.org.au> parents: 38592 diff changeset	464 * -2 if setting stack size is not supported.
f7d23bca599f Patch #1454481: Make thread stack size runtime tunable. Andrew MacIntyre <andymac@bullseye.apana.org.au> parents: 38592 diff changeset	465 */
f7d23bca599f Patch #1454481: Make thread stack size runtime tunable. Andrew MacIntyre <andymac@bullseye.apana.org.au> parents: 38592 diff changeset	466 static int
f7d23bca599f Patch #1454481: Make thread stack size runtime tunable. Andrew MacIntyre <andymac@bullseye.apana.org.au> parents: 38592 diff changeset	467 _pythread_pthread_set_stacksize(size_t size)
f7d23bca599f Patch #1454481: Make thread stack size runtime tunable. Andrew MacIntyre <andymac@bullseye.apana.org.au> parents: 38592 diff changeset	468 {
f7d23bca599f Patch #1454481: Make thread stack size runtime tunable. Andrew MacIntyre <andymac@bullseye.apana.org.au> parents: 38592 diff changeset	469 #if defined(THREAD_STACK_SIZE)
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	470 pthread_attr_t attrs;
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	471 size_t tss_min;
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	472 int rc = 0;
38794 f7d23bca599f Patch #1454481: Make thread stack size runtime tunable. Andrew MacIntyre <andymac@bullseye.apana.org.au> parents: 38592 diff changeset	473 #endif
f7d23bca599f Patch #1454481: Make thread stack size runtime tunable. Andrew MacIntyre <andymac@bullseye.apana.org.au> parents: 38592 diff changeset	474
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	475 /* set to default */
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	476 if (size == 0) {
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	477 _pythread_stacksize = 0;
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	478 return 0;
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	479 }
38794 f7d23bca599f Patch #1454481: Make thread stack size runtime tunable. Andrew MacIntyre <andymac@bullseye.apana.org.au> parents: 38592 diff changeset	480
f7d23bca599f Patch #1454481: Make thread stack size runtime tunable. Andrew MacIntyre <andymac@bullseye.apana.org.au> parents: 38592 diff changeset	481 #if defined(THREAD_STACK_SIZE)
f7d23bca599f Patch #1454481: Make thread stack size runtime tunable. Andrew MacIntyre <andymac@bullseye.apana.org.au> parents: 38592 diff changeset	482 #if defined(PTHREAD_STACK_MIN)
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	483 tss_min = PTHREAD_STACK_MIN > THREAD_STACK_MIN ? PTHREAD_STACK_MIN
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	484 : THREAD_STACK_MIN;
38794 f7d23bca599f Patch #1454481: Make thread stack size runtime tunable. Andrew MacIntyre <andymac@bullseye.apana.org.au> parents: 38592 diff changeset	485 #else
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	486 tss_min = THREAD_STACK_MIN;
38794 f7d23bca599f Patch #1454481: Make thread stack size runtime tunable. Andrew MacIntyre <andymac@bullseye.apana.org.au> parents: 38592 diff changeset	487 #endif
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	488 if (size >= tss_min) {
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	489 /* validate stack size by setting thread attribute */
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	490 if (pthread_attr_init(&attrs) == 0) {
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	491 rc = pthread_attr_setstacksize(&attrs, size);
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	492 pthread_attr_destroy(&attrs);
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	493 if (rc == 0) {
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	494 _pythread_stacksize = size;
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	495 return 0;
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	496 }
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	497 }
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	498 }
e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	499 return -1;
38794 f7d23bca599f Patch #1454481: Make thread stack size runtime tunable. Andrew MacIntyre <andymac@bullseye.apana.org.au> parents: 38592 diff changeset	500 #else
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	501 return -2;
38794 f7d23bca599f Patch #1454481: Make thread stack size runtime tunable. Andrew MacIntyre <andymac@bullseye.apana.org.au> parents: 38592 diff changeset	502 #endif
f7d23bca599f Patch #1454481: Make thread stack size runtime tunable. Andrew MacIntyre <andymac@bullseye.apana.org.au> parents: 38592 diff changeset	503 }
f7d23bca599f Patch #1454481: Make thread stack size runtime tunable. Andrew MacIntyre <andymac@bullseye.apana.org.au> parents: 38592 diff changeset	504
61465 e38335d4df91 Recorded merge of revisions 81029 via svnmerge from Antoine Pitrou <solipsis@pitrou.net> parents: 38794 diff changeset	505 #define THREAD_SET_STACKSIZE(x) _pythread_pthread_set_stacksize(x)

Mercurial > cpython-lru_cache-weakref

annotate Python/thread_pthread.h @ 78855:5a2ef447b80d 2.7