3 #define MUTEX_UNLOCK(m)
5 #define MUTEX_DESTROY(m)
8 #define COND_BROADCAST(c)
9 #define COND_WAIT(c, m)
10 #define COND_DESTROY(c)
13 /* Rats: if dTHR is just blank then the subsequent ";" throws an error */
14 #define dTHR extern int errno
18 typedef struct thread *perl_thread;
19 /* With fake threads, thr is global(ish) so we don't need dTHR */
20 #define dTHR extern int errno
23 * Note that SCHEDULE() is only callable from pp code (which
24 * must be expecting to be restarted). We'll have to do
25 * something a bit different for XS code.
27 #define SCHEDULE() return schedule(), op
30 #define MUTEX_UNLOCK(m)
32 #define MUTEX_DESTROY(m)
33 #define COND_INIT(c) perl_cond_init(c)
34 #define COND_SIGNAL(c) perl_cond_signal(c)
35 #define COND_BROADCAST(c) perl_cond_broadcast(c)
36 #define COND_WAIT(c, m) STMT_START { \
40 #define COND_DESTROY(c)
42 /* POSIXish threads */
43 typedef pthread_t perl_thread;
44 #ifdef OLD_PTHREADS_API
45 #define pthread_mutexattr_init(a) pthread_mutexattr_create(a)
46 #define pthread_mutexattr_settype(a,t) pthread_mutexattr_setkind_np(a,t)
47 #define pthread_key_create(k,d) pthread_keycreate(k,(pthread_destructor_t)(d))
49 #define pthread_mutexattr_default NULL
50 #define pthread_condattr_default NULL
51 #endif /* OLD_PTHREADS_API */
53 #define MUTEX_INIT(m) \
54 if (pthread_mutex_init((m), pthread_mutexattr_default)) \
55 croak("panic: MUTEX_INIT"); \
57 #define MUTEX_LOCK(m) \
58 if (pthread_mutex_lock((m))) croak("panic: MUTEX_LOCK"); else 1
59 #define MUTEX_UNLOCK(m) \
60 if (pthread_mutex_unlock((m))) croak("panic: MUTEX_UNLOCK"); else 1
61 #define MUTEX_DESTROY(m) \
62 if (pthread_mutex_destroy((m))) croak("panic: MUTEX_DESTROY"); else 1
63 #define COND_INIT(c) \
64 if (pthread_cond_init((c), pthread_condattr_default)) \
65 croak("panic: COND_INIT"); \
67 #define COND_SIGNAL(c) \
68 if (pthread_cond_signal((c))) croak("panic: COND_SIGNAL"); else 1
69 #define COND_BROADCAST(c) \
70 if (pthread_cond_broadcast((c))) croak("panic: COND_BROADCAST"); else 1
71 #define COND_WAIT(c, m) \
72 if (pthread_cond_wait((c), (m))) croak("panic: COND_WAIT"); else 1
73 #define COND_DESTROY(c) \
74 if (pthread_cond_destroy((c))) croak("panic: COND_DESTROY"); else 1
77 if (pthread_detach((t)->Tself)) croak("panic: DETACH"); else 1
79 /* XXX Add "old" (?) POSIX draft interface too */
80 #ifdef OLD_PTHREADS_API
81 struct thread *getTHR _((void));
84 #define THR ((struct thread *) pthread_getspecific(thr_key))
85 #endif /* OLD_PTHREADS_API */
86 #define dTHR struct thread *thr = THR
87 #endif /* FAKE_THREADS */
90 # ifdef NEED_PTHREAD_INIT
91 # define INIT_THREADS pthread_init()
93 # define INIT_THREADS NOOP
98 /* The fields that used to be global */
99 /* Important ones in the first cache line (if alignment is done right) */
101 #ifdef OP_IN_REGISTER
124 I32 * Tmarkstack_ptr;
125 I32 * Tmarkstack_max;
129 struct stat Tstatbuf;
130 struct tms Ttimesbuf;
132 /* XXX What about regexp stuff? */
134 /* Now the fields that used to be "per interpreter" (even when global) */
136 /* XXX What about magic variables such as $/, $? and so on? */
161 /* XXX Sort stuff, firstgv, secongv and so on? */
169 struct thread *next, *prev; /* Circular linked list of threads */
172 perl_thread next_run, prev_run; /* Linked list of runnable threads */
173 perl_cond wait_queue; /* Wait queue that we are waiting on */
174 IV private; /* Holds data across time slices */
175 I32 savemark; /* Holds MARK for thread join values */
176 #endif /* FAKE_THREADS */
179 typedef struct thread *Thread;
181 /* Values and macros for thr->flags */
182 #define THRf_STATE_MASK 7
183 #define THRf_R_JOINABLE 0
184 #define THRf_R_JOINED 1
185 #define THRf_R_DETACHED 2
186 #define THRf_ZOMBIE 3
189 #define THRf_DIE_FATAL 8
191 #define ThrSTATE(t) ((t)->flags)
192 #define ThrSETSTATE(t, s) STMT_START { \
193 MUTEX_LOCK(&(t)->mutex); \
194 (t)->flags &= ~THRf_STATE_MASK; \
196 MUTEX_UNLOCK(&(t)->mutex); \
197 DEBUG_L(PerlIO_printf(PerlIO_stderr(), \
198 "thread %p set to state %d\n", (t), (s))); \
201 typedef struct condpair {
203 perl_cond owner_cond;
208 #define MgMUTEXP(mg) (&((condpair_t *)(mg->mg_ptr))->mutex)
209 #define MgOWNERCONDP(mg) (&((condpair_t *)(mg->mg_ptr))->owner_cond)
210 #define MgCONDP(mg) (&((condpair_t *)(mg->mg_ptr))->cond)
211 #define MgOWNER(mg) ((condpair_t *)(mg->mg_ptr))->owner
223 #undef scopestack_max
253 #define self (thr->Tself)
254 #define oursv (thr->Toursv)
255 #define stack_base (thr->Tstack_base)
256 #define stack_sp (thr->Tstack_sp)
257 #define stack_max (thr->Tstack_max)
258 #ifdef OP_IN_REGISTER
259 #define opsave (thr->Topsave)
262 #define op (thr->Top)
264 #define curcop (thr->Tcurcop)
265 #define stack (thr->Tstack)
266 #define curstack (thr->Tcurstack)
267 #define mainstack (thr->Tmainstack)
268 #define markstack (thr->Tmarkstack)
269 #define markstack_ptr (thr->Tmarkstack_ptr)
270 #define markstack_max (thr->Tmarkstack_max)
271 #define scopestack (thr->Tscopestack)
272 #define scopestack_ix (thr->Tscopestack_ix)
273 #define scopestack_max (thr->Tscopestack_max)
275 #define savestack (thr->Tsavestack)
276 #define savestack_ix (thr->Tsavestack_ix)
277 #define savestack_max (thr->Tsavestack_max)
279 #define retstack (thr->Tretstack)
280 #define retstack_ix (thr->Tretstack_ix)
281 #define retstack_max (thr->Tretstack_max)
283 #define cxstack (thr->Tcxstack)
284 #define cxstack_ix (thr->Tcxstack_ix)
285 #define cxstack_max (thr->Tcxstack_max)
287 #define curpad (thr->Tcurpad)
288 #define Sv (thr->TSv)
289 #define Xpv (thr->TXpv)
290 #define statbuf (thr->Tstatbuf)
291 #define timesbuf (thr->Ttimesbuf)
292 #define defstash (thr->Tdefstash)
293 #define curstash (thr->Tcurstash)
295 #define tmps_stack (thr->Ttmps_stack)
296 #define tmps_ix (thr->Ttmps_ix)
297 #define tmps_floor (thr->Ttmps_floor)
298 #define tmps_max (thr->Ttmps_max)
300 #define in_eval (thr->Tin_eval)
301 #define restartop (thr->Trestartop)
302 #define delaymagic (thr->Tdelaymagic)
303 #define dirty (thr->Tdirty)
304 #define localizing (thr->Tlocalizing)
306 #define top_env (thr->Ttop_env)
307 #define runlevel (thr->Trunlevel)
309 #define cvcache (thr->Tcvcache)
310 #endif /* USE_THREADS */