• Home
  • Line#
  • Scopes#
  • Navigate#
  • Raw
  • Download
1 
2 #ifdef MACH_C_THREADS
3 #include <mach/cthreads.h>
4 #endif
5 
6 #ifdef HURD_C_THREADS
7 #include <cthreads.h>
8 #endif
9 
10 /*
11  * Initialization.
12  */
13 static void
PyThread__init_thread(void)14 PyThread__init_thread(void)
15 {
16 #ifndef HURD_C_THREADS
17     /* Roland McGrath said this should not be used since this is
18     done while linking to threads */
19     cthread_init();
20 #else
21 /* do nothing */
22     ;
23 #endif
24 }
25 
26 /*
27  * Thread support.
28  */
29 long
PyThread_start_new_thread(void (* func)(void *),void * arg)30 PyThread_start_new_thread(void (*func)(void *), void *arg)
31 {
32     int success = 0;            /* init not needed when SOLARIS_THREADS and */
33                 /* C_THREADS implemented properly */
34 
35     dprintf(("PyThread_start_new_thread called\n"));
36     if (!initialized)
37         PyThread_init_thread();
38     /* looks like solaris detaches the thread to never rejoin
39      * so well do it here
40      */
41     cthread_detach(cthread_fork((cthread_fn_t) func, arg));
42     return success < 0 ? -1 : 0;
43 }
44 
45 long
PyThread_get_thread_ident(void)46 PyThread_get_thread_ident(void)
47 {
48     if (!initialized)
49         PyThread_init_thread();
50     return (long) cthread_self();
51 }
52 
53 void
PyThread_exit_thread(void)54 PyThread_exit_thread(void)
55 {
56     dprintf(("PyThread_exit_thread called\n"));
57     if (!initialized)
58         exit(0);
59     cthread_exit(0);
60 }
61 
62 /*
63  * Lock support.
64  */
65 PyThread_type_lock
PyThread_allocate_lock(void)66 PyThread_allocate_lock(void)
67 {
68     mutex_t lock;
69 
70     dprintf(("PyThread_allocate_lock called\n"));
71     if (!initialized)
72         PyThread_init_thread();
73 
74     lock = mutex_alloc();
75     if (mutex_init(lock)) {
76         perror("mutex_init");
77         free((void *) lock);
78         lock = 0;
79     }
80     dprintf(("PyThread_allocate_lock() -> %p\n", lock));
81     return (PyThread_type_lock) lock;
82 }
83 
84 void
PyThread_free_lock(PyThread_type_lock lock)85 PyThread_free_lock(PyThread_type_lock lock)
86 {
87     dprintf(("PyThread_free_lock(%p) called\n", lock));
88     mutex_free(lock);
89 }
90 
91 int
PyThread_acquire_lock(PyThread_type_lock lock,int waitflag)92 PyThread_acquire_lock(PyThread_type_lock lock, int waitflag)
93 {
94     int success = FALSE;
95 
96     dprintf(("PyThread_acquire_lock(%p, %d) called\n", lock, waitflag));
97     if (waitflag) {             /* blocking */
98         mutex_lock((mutex_t)lock);
99         success = TRUE;
100     } else {                    /* non blocking */
101         success = mutex_try_lock((mutex_t)lock);
102     }
103     dprintf(("PyThread_acquire_lock(%p, %d) -> %d\n", lock, waitflag, success));
104     return success;
105 }
106 
107 void
PyThread_release_lock(PyThread_type_lock lock)108 PyThread_release_lock(PyThread_type_lock lock)
109 {
110     dprintf(("PyThread_release_lock(%p) called\n", lock));
111     mutex_unlock((mutex_t )lock);
112 }
113