4 # include <win32thread.h>
8 typedef pthread_t perl_thread;
9 #ifdef OLD_PTHREADS_API
10 # define pthread_mutexattr_init(a) pthread_mutexattr_create(a)
11 # define pthread_mutexattr_settype(a,t) pthread_mutexattr_setkind_np(a,t)
12 # define pthread_key_create(k,d) pthread_keycreate(k,(pthread_destructor_t)(d))
13 # define YIELD pthread_yield()
16 if (pthread_detach(&(t)->self)) { \
17 MUTEX_UNLOCK(&(t)->mutex); \
18 croak("panic: DETACH"); \
22 # define pthread_mutexattr_default NULL
23 # define pthread_condattr_default NULL
24 # define pthread_attr_default NULL
25 #endif /* OLD_PTHREADS_API */
29 # define YIELD sched_yield()
33 #define MUTEX_INIT(m) \
35 if (pthread_mutex_init((m), pthread_mutexattr_default)) \
36 croak("panic: MUTEX_INIT"); \
38 #define MUTEX_LOCK(m) \
40 if (pthread_mutex_lock((m))) \
41 croak("panic: MUTEX_LOCK"); \
43 #define MUTEX_UNLOCK(m) \
45 if (pthread_mutex_unlock((m))) \
46 croak("panic: MUTEX_UNLOCK"); \
48 #define MUTEX_DESTROY(m) \
50 if (pthread_mutex_destroy((m))) \
51 croak("panic: MUTEX_DESTROY"); \
53 #endif /* MUTEX_INIT */
56 #define COND_INIT(c) \
58 if (pthread_cond_init((c), pthread_condattr_default)) \
59 croak("panic: COND_INIT"); \
61 #define COND_SIGNAL(c) \
63 if (pthread_cond_signal((c))) \
64 croak("panic: COND_SIGNAL"); \
66 #define COND_BROADCAST(c) \
68 if (pthread_cond_broadcast((c))) \
69 croak("panic: COND_BROADCAST"); \
71 #define COND_WAIT(c, m) \
73 if (pthread_cond_wait((c), (m))) \
74 croak("panic: COND_WAIT"); \
76 #define COND_DESTROY(c) \
78 if (pthread_cond_destroy((c))) \
79 croak("panic: COND_DESTROY"); \
81 #endif /* COND_INIT */
83 /* DETACH(t) must only be called while holding t->mutex */
87 if (pthread_detach((t)->self)) { \
88 MUTEX_UNLOCK(&(t)->mutex); \
89 croak("panic: DETACH"); \
95 #define JOIN(t, avp) \
97 if (pthread_join((t)->self, (void**)(avp))) \
98 croak("panic: pthread_join"); \
105 if (pthread_setspecific(thr_key, (void *) (t))) \
106 croak("panic: pthread_setspecific"); \
111 # ifdef OLD_PTHREADS_API
112 struct thread *getTHR _((void));
113 # define THR getTHR()
115 # define THR ((struct thread *) pthread_getspecific(thr_key))
116 # endif /* OLD_PTHREADS_API */
120 # define dTHR struct thread *thr = THR
124 # ifdef NEED_PTHREAD_INIT
125 # define INIT_THREADS pthread_init()
127 # define INIT_THREADS NOOP
131 #ifndef THREAD_RET_TYPE
132 # define THREAD_RET_TYPE void *
133 # define THREAD_RET_CAST(p) ((void *)(p))
134 #endif /* THREAD_RET */
137 /* The fields that used to be global */
138 /* Important ones in the first cache line (if alignment is done right) */
140 #ifdef OP_IN_REGISTER
163 I32 * Tmarkstack_ptr;
164 I32 * Tmarkstack_max;
168 struct stat Tstatbuf;
169 struct tms Ttimesbuf;
171 /* XXX What about regexp stuff? */
173 /* Now the fields that used to be "per interpreter" (even when global) */
175 /* XXX What about magic variables such as $/, $? and so on? */
200 /* XXX Sort stuff, firstgv, secongv and so on? */
204 perl_thread self; /* Underlying thread object */
206 perl_mutex mutex; /* For the fields others can change */
208 struct thread *next, *prev; /* Circular linked list of threads */
210 #ifdef ADD_THREAD_INTERN
211 struct thread_intern i; /* Platform-dependent internals */
213 char trailing_nul; /* For the sake of thrsv, t->Toursv */
216 typedef struct thread *Thread;
218 /* Values and macros for thr->flags */
219 #define THRf_STATE_MASK 7
220 #define THRf_R_JOINABLE 0
221 #define THRf_R_JOINED 1
222 #define THRf_R_DETACHED 2
223 #define THRf_ZOMBIE 3
226 #define THRf_DIE_FATAL 8
228 /* ThrSTATE(t) and ThrSETSTATE(t) must only be called while holding t->mutex */
229 #define ThrSTATE(t) ((t)->flags)
230 #define ThrSETSTATE(t, s) STMT_START { \
231 (t)->flags &= ~THRf_STATE_MASK; \
233 DEBUG_L(PerlIO_printf(PerlIO_stderr(), \
234 "thread %p set to state %d\n", (t), (s))); \
237 typedef struct condpair {
238 perl_mutex mutex; /* Protects all other fields */
239 perl_cond owner_cond; /* For when owner changes at all */
240 perl_cond cond; /* For cond_signal and cond_broadcast */
241 Thread owner; /* Currently owning thread */
244 #define MgMUTEXP(mg) (&((condpair_t *)(mg->mg_ptr))->mutex)
245 #define MgOWNERCONDP(mg) (&((condpair_t *)(mg->mg_ptr))->owner_cond)
246 #define MgCONDP(mg) (&((condpair_t *)(mg->mg_ptr))->cond)
247 #define MgOWNER(mg) ((condpair_t *)(mg->mg_ptr))->owner
259 #undef scopestack_max
289 #define oursv (thr->Toursv)
290 #define stack_base (thr->Tstack_base)
291 #define stack_sp (thr->Tstack_sp)
292 #define stack_max (thr->Tstack_max)
293 #ifdef OP_IN_REGISTER
294 #define opsave (thr->Topsave)
297 #define op (thr->Top)
299 #define curcop (thr->Tcurcop)
300 #define stack (thr->Tstack)
301 #define curstack (thr->Tcurstack)
302 #define mainstack (thr->Tmainstack)
303 #define markstack (thr->Tmarkstack)
304 #define markstack_ptr (thr->Tmarkstack_ptr)
305 #define markstack_max (thr->Tmarkstack_max)
306 #define scopestack (thr->Tscopestack)
307 #define scopestack_ix (thr->Tscopestack_ix)
308 #define scopestack_max (thr->Tscopestack_max)
310 #define savestack (thr->Tsavestack)
311 #define savestack_ix (thr->Tsavestack_ix)
312 #define savestack_max (thr->Tsavestack_max)
314 #define retstack (thr->Tretstack)
315 #define retstack_ix (thr->Tretstack_ix)
316 #define retstack_max (thr->Tretstack_max)
318 #define cxstack (thr->Tcxstack)
319 #define cxstack_ix (thr->Tcxstack_ix)
320 #define cxstack_max (thr->Tcxstack_max)
322 #define curpad (thr->Tcurpad)
323 #define Sv (thr->TSv)
324 #define Xpv (thr->TXpv)
325 #define statbuf (thr->Tstatbuf)
326 #define timesbuf (thr->Ttimesbuf)
327 #define defstash (thr->Tdefstash)
328 #define curstash (thr->Tcurstash)
330 #define tmps_stack (thr->Ttmps_stack)
331 #define tmps_ix (thr->Ttmps_ix)
332 #define tmps_floor (thr->Ttmps_floor)
333 #define tmps_max (thr->Ttmps_max)
335 #define in_eval (thr->Tin_eval)
336 #define restartop (thr->Trestartop)
337 #define delaymagic (thr->Tdelaymagic)
338 #define dirty (thr->Tdirty)
339 #define localizing (thr->Tlocalizing)
341 #define top_env (thr->Ttop_env)
342 #define runlevel (thr->Trunlevel)
344 #define cvcache (thr->Tcvcache)
346 /* USE_THREADS is not defined */
347 #define MUTEX_LOCK(m)
348 #define MUTEX_UNLOCK(m)
349 #define MUTEX_INIT(m)
350 #define MUTEX_DESTROY(m)
352 #define COND_SIGNAL(c)
353 #define COND_BROADCAST(c)
354 #define COND_WAIT(c, m)
355 #define COND_DESTROY(c)
358 /* Rats: if dTHR is just blank then the subsequent ";" throws an error */
359 #define dTHR extern int errno
360 #endif /* USE_THREADS */