blob: 5fc7850bcbd71d63a45ba74042b3af3426d31880 [file] [log] [blame]
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +00001/***********************************************************
Guido van Rossum6d023c91995-01-04 19:12:13 +00002Copyright 1991-1995 by Stichting Mathematisch Centrum, Amsterdam,
3The Netherlands.
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +00004
5 All Rights Reserved
6
Guido van Rossumd266eb41996-10-25 14:44:06 +00007Permission to use, copy, modify, and distribute this software and its
8documentation for any purpose and without fee is hereby granted,
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +00009provided that the above copyright notice appear in all copies and that
Guido van Rossumd266eb41996-10-25 14:44:06 +000010both that copyright notice and this permission notice appear in
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +000011supporting documentation, and that the names of Stichting Mathematisch
Guido van Rossumd266eb41996-10-25 14:44:06 +000012Centrum or CWI or Corporation for National Research Initiatives or
13CNRI not be used in advertising or publicity pertaining to
14distribution of the software without specific, written prior
15permission.
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +000016
Guido van Rossumd266eb41996-10-25 14:44:06 +000017While CWI is the initial source for this software, a modified version
18is made available by the Corporation for National Research Initiatives
19(CNRI) at the Internet address ftp://ftp.python.org.
20
21STICHTING MATHEMATISCH CENTRUM AND CNRI DISCLAIM ALL WARRANTIES WITH
22REGARD TO THIS SOFTWARE, INCLUDING ALL IMPLIED WARRANTIES OF
23MERCHANTABILITY AND FITNESS, IN NO EVENT SHALL STICHTING MATHEMATISCH
24CENTRUM OR CNRI BE LIABLE FOR ANY SPECIAL, INDIRECT OR CONSEQUENTIAL
25DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR
26PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR OTHER
27TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR
28PERFORMANCE OF THIS SOFTWARE.
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +000029
30******************************************************************/
31
32#include <stdlib.h>
33#include <stdio.h>
34#include <unistd.h>
Guido van Rossumcf1474b1996-10-08 14:17:53 +000035#include <errno.h>
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +000036#include </usr/include/thread.h>
Guido van Rossum6eea3261996-08-26 14:58:54 +000037#undef _POSIX_THREADS
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +000038
39
40/*
41 * Initialization.
42 */
Guido van Rossum65d5b571998-12-21 19:32:43 +000043static void PyThread__init_thread _P0()
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +000044{
45}
46
47/*
48 * Thread support.
49 */
50struct func_arg {
51 void (*func) _P((void *));
52 void *arg;
53};
54
55static void *new_func _P1(funcarg, void *funcarg)
56{
57 void (*func) _P((void *));
58 void *arg;
59
60 func = ((struct func_arg *) funcarg)->func;
61 arg = ((struct func_arg *) funcarg)->arg;
62 free(funcarg);
63 (*func)(arg);
64 return 0;
65}
66
67
Guido van Rossum65d5b571998-12-21 19:32:43 +000068int PyThread_start_new_thread _P2(func, void (*func) _P((void *)), arg, void *arg)
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +000069{
70 struct func_arg *funcarg;
71 int success = 0; /* init not needed when SOLARIS_THREADS and */
72 /* C_THREADS implemented properly */
73
Guido van Rossum65d5b571998-12-21 19:32:43 +000074 dprintf(("PyThread_start_new_thread called\n"));
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +000075 if (!initialized)
Guido van Rossum65d5b571998-12-21 19:32:43 +000076 PyThread_init_thread();
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +000077 funcarg = (struct func_arg *) malloc(sizeof(struct func_arg));
78 funcarg->func = func;
79 funcarg->arg = arg;
Guido van Rossum495894e1999-04-13 14:32:12 +000080 if (thr_create(0, 0, new_func, funcarg,
81 THR_DETACHED | THR_NEW_LWP, 0)) {
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +000082 perror("thr_create");
83 free((void *) funcarg);
84 success = -1;
85 }
86 return success < 0 ? 0 : 1;
87}
88
Guido van Rossum65d5b571998-12-21 19:32:43 +000089long PyThread_get_thread_ident _P0()
Guido van Rossume944da81994-05-23 12:43:41 +000090{
91 if (!initialized)
Guido van Rossum65d5b571998-12-21 19:32:43 +000092 PyThread_init_thread();
Guido van Rossume944da81994-05-23 12:43:41 +000093 return thr_self();
94}
95
Guido van Rossum65d5b571998-12-21 19:32:43 +000096static void do_PyThread_exit_thread _P1(no_cleanup, int no_cleanup)
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +000097{
Guido van Rossum65d5b571998-12-21 19:32:43 +000098 dprintf(("PyThread_exit_thread called\n"));
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +000099 if (!initialized)
100 if (no_cleanup)
101 _exit(0);
102 else
103 exit(0);
104 thr_exit(0);
105}
106
Guido van Rossum65d5b571998-12-21 19:32:43 +0000107void PyThread_exit_thread _P0()
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +0000108{
Guido van Rossum65d5b571998-12-21 19:32:43 +0000109 do_PyThread_exit_thread(0);
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +0000110}
111
Guido van Rossum65d5b571998-12-21 19:32:43 +0000112void PyThread__exit_thread _P0()
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +0000113{
Guido van Rossum65d5b571998-12-21 19:32:43 +0000114 do_PyThread_exit_thread(1);
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +0000115}
116
117#ifndef NO_EXIT_PROG
Guido van Rossum65d5b571998-12-21 19:32:43 +0000118static void do_PyThread_exit_prog _P2(status, int status, no_cleanup, int no_cleanup)
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +0000119{
Guido van Rossum65d5b571998-12-21 19:32:43 +0000120 dprintf(("PyThread_exit_prog(%d) called\n", status));
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +0000121 if (!initialized)
122 if (no_cleanup)
123 _exit(status);
124 else
125 exit(status);
126 if (no_cleanup)
127 _exit(status);
128 else
129 exit(status);
130}
131
Guido van Rossum65d5b571998-12-21 19:32:43 +0000132void PyThread_exit_prog _P1(status, int status)
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +0000133{
Guido van Rossum65d5b571998-12-21 19:32:43 +0000134 do_PyThread_exit_prog(status, 0);
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +0000135}
136
Guido van Rossum65d5b571998-12-21 19:32:43 +0000137void PyThread__exit_prog _P1(status, int status)
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +0000138{
Guido van Rossum65d5b571998-12-21 19:32:43 +0000139 do_PyThread_exit_prog(status, 1);
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +0000140}
141#endif /* NO_EXIT_PROG */
142
143/*
144 * Lock support.
145 */
Guido van Rossum65d5b571998-12-21 19:32:43 +0000146PyThread_type_lock PyThread_allocate_lock _P0()
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +0000147{
148 mutex_t *lock;
149
Guido van Rossum65d5b571998-12-21 19:32:43 +0000150 dprintf(("PyThread_allocate_lock called\n"));
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +0000151 if (!initialized)
Guido van Rossum65d5b571998-12-21 19:32:43 +0000152 PyThread_init_thread();
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +0000153
154 lock = (mutex_t *) malloc(sizeof(mutex_t));
155 if (mutex_init(lock, USYNC_THREAD, 0)) {
156 perror("mutex_init");
157 free((void *) lock);
158 lock = 0;
159 }
Guido van Rossum65d5b571998-12-21 19:32:43 +0000160 dprintf(("PyThread_allocate_lock() -> %lx\n", (long)lock));
161 return (PyThread_type_lock) lock;
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +0000162}
163
Guido van Rossum65d5b571998-12-21 19:32:43 +0000164void PyThread_free_lock _P1(lock, PyThread_type_lock lock)
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +0000165{
Guido van Rossum65d5b571998-12-21 19:32:43 +0000166 dprintf(("PyThread_free_lock(%lx) called\n", (long)lock));
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +0000167 mutex_destroy((mutex_t *) lock);
168 free((void *) lock);
169}
170
Guido van Rossum65d5b571998-12-21 19:32:43 +0000171int PyThread_acquire_lock _P2(lock, PyThread_type_lock lock, waitflag, int waitflag)
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +0000172{
173 int success;
174
Guido van Rossum65d5b571998-12-21 19:32:43 +0000175 dprintf(("PyThread_acquire_lock(%lx, %d) called\n", (long)lock, waitflag));
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +0000176 if (waitflag)
177 success = mutex_lock((mutex_t *) lock);
178 else
179 success = mutex_trylock((mutex_t *) lock);
180 if (success < 0)
181 perror(waitflag ? "mutex_lock" : "mutex_trylock");
182 else
183 success = !success; /* solaris does it the other way round */
Guido van Rossum65d5b571998-12-21 19:32:43 +0000184 dprintf(("PyThread_acquire_lock(%lx, %d) -> %d\n", (long)lock, waitflag, success));
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +0000185 return success;
186}
187
Guido van Rossum65d5b571998-12-21 19:32:43 +0000188void PyThread_release_lock _P1(lock, PyThread_type_lock lock)
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +0000189{
Guido van Rossum65d5b571998-12-21 19:32:43 +0000190 dprintf(("PyThread_release_lock(%lx) called\n", (long)lock));
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +0000191 if (mutex_unlock((mutex_t *) lock))
192 perror("mutex_unlock");
193}
194
195/*
196 * Semaphore support.
197 */
Guido van Rossum65d5b571998-12-21 19:32:43 +0000198PyThread_type_sema PyThread_allocate_sema _P1(value, int value)
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +0000199{
200 sema_t *sema;
Guido van Rossum65d5b571998-12-21 19:32:43 +0000201 dprintf(("PyThread_allocate_sema called\n"));
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +0000202 if (!initialized)
Guido van Rossum65d5b571998-12-21 19:32:43 +0000203 PyThread_init_thread();
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +0000204
205 sema = (sema_t *) malloc(sizeof(sema_t));
206 if (sema_init(sema, value, USYNC_THREAD, 0)) {
207 perror("sema_init");
208 free((void *) sema);
209 sema = 0;
210 }
Guido van Rossum65d5b571998-12-21 19:32:43 +0000211 dprintf(("PyThread_allocate_sema() -> %lx\n", (long) sema));
212 return (PyThread_type_sema) sema;
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +0000213}
214
Guido van Rossum65d5b571998-12-21 19:32:43 +0000215void PyThread_free_sema _P1(sema, PyThread_type_sema sema)
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +0000216{
Guido van Rossum65d5b571998-12-21 19:32:43 +0000217 dprintf(("PyThread_free_sema(%lx) called\n", (long) sema));
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +0000218 if (sema_destroy((sema_t *) sema))
219 perror("sema_destroy");
220 free((void *) sema);
221}
222
Guido van Rossum65d5b571998-12-21 19:32:43 +0000223int PyThread_down_sema _P2(sema, PyThread_type_sema sema, waitflag, int waitflag)
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +0000224{
Guido van Rossumcf1474b1996-10-08 14:17:53 +0000225 int success;
226
Guido van Rossum65d5b571998-12-21 19:32:43 +0000227 dprintf(("PyThread_down_sema(%lx) called\n", (long) sema));
Guido van Rossumcf1474b1996-10-08 14:17:53 +0000228 if (waitflag)
229 success = sema_wait((sema_t *) sema);
230 else
231 success = sema_trywait((sema_t *) sema);
232 if (success < 0) {
233 if (errno == EBUSY)
234 success = 0;
235 else
236 perror("sema_wait");
237 }
238 else
239 success = !success;
Guido van Rossum65d5b571998-12-21 19:32:43 +0000240 dprintf(("PyThread_down_sema(%lx) return %d\n", (long) sema, success));
Guido van Rossumcf1474b1996-10-08 14:17:53 +0000241 return success;
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +0000242}
243
Guido van Rossum65d5b571998-12-21 19:32:43 +0000244void PyThread_up_sema _P1(sema, PyThread_type_sema sema)
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +0000245{
Guido van Rossum65d5b571998-12-21 19:32:43 +0000246 dprintf(("PyThread_up_sema(%lx)\n", (long) sema));
Guido van Rossum2c8cb9f1994-05-09 15:12:46 +0000247 if (sema_post((sema_t *) sema))
248 perror("sema_post");
249}