This is a live mirror of the Perl 5 development currently hosted at https://github.com/perl/perl5
Add missing reset of eval_owner if doeval() fails to parse.
[perl5.git] / thread.h
CommitLineData
11343788
MB
1#ifndef USE_THREADS
2#define MUTEX_LOCK(m)
3#define MUTEX_UNLOCK(m)
4#define MUTEX_INIT(m)
5#define MUTEX_DESTROY(m)
6#define COND_INIT(c)
7#define COND_SIGNAL(c)
8#define COND_BROADCAST(c)
9#define COND_WAIT(c, m)
10#define COND_DESTROY(c)
11
12#define THR
13/* Rats: if dTHR is just blank then the subsequent ";" throws an error */
14#define dTHR extern int errno
15#else
16#include <pthread.h>
17
18#ifdef OLD_PTHREADS_API
19#define pthread_mutexattr_init(a) pthread_mutexattr_create(a)
20#define pthread_mutexattr_settype(a,t) pthread_mutexattr_setkind_np(a,t)
21#define pthread_key_create(k,d) pthread_keycreate(k,(pthread_destructor_t)(d))
22#else
23#define pthread_mutexattr_default NULL
24#endif /* OLD_PTHREADS_API */
25
26#define MUTEX_INIT(m) \
27 if (pthread_mutex_init((m), pthread_mutexattr_default)) \
28 croak("panic: MUTEX_INIT"); \
29 else 1
30#define MUTEX_LOCK(m) \
31 if (pthread_mutex_lock((m))) croak("panic: MUTEX_LOCK"); else 1
32#define MUTEX_UNLOCK(m) \
33 if (pthread_mutex_unlock((m))) croak("panic: MUTEX_UNLOCK"); else 1
34#define MUTEX_DESTROY(m) \
35 if (pthread_mutex_destroy((m))) croak("panic: MUTEX_DESTROY"); else 1
36#define COND_INIT(c) \
37 if (pthread_cond_init((c), NULL)) croak("panic: COND_INIT"); else 1
38#define COND_SIGNAL(c) \
39 if (pthread_cond_signal((c))) croak("panic: COND_SIGNAL"); else 1
40#define COND_BROADCAST(c) \
41 if (pthread_cond_broadcast((c))) croak("panic: COND_BROADCAST"); else 1
42#define COND_WAIT(c, m) \
43 if (pthread_cond_wait((c), (m))) croak("panic: COND_WAIT"); else 1
44#define COND_DESTROY(c) \
45 if (pthread_cond_destroy((c))) croak("panic: COND_DESTROY"); else 1
46/* XXX Add "old" (?) POSIX draft interface too */
47#ifdef OLD_PTHREADS_API
48struct thread *getTHR _((void));
49#define THR getTHR()
50#else
51#define THR ((struct thread *) pthread_getspecific(thr_key))
52#endif /* OLD_PTHREADS_API */
53#define dTHR struct thread *thr = THR
54
55struct thread {
56 pthread_t Tself;
57
58 /* The fields that used to be global */
59 SV ** Tstack_base;
60 SV ** Tstack_sp;
61 SV ** Tstack_max;
62
462e5cf6
MB
63#ifdef OP_IN_REGISTER
64 OP * Topsave;
65#else
11343788 66 OP * Top;
462e5cf6 67#endif
11343788
MB
68
69 I32 * Tscopestack;
70 I32 Tscopestack_ix;
71 I32 Tscopestack_max;
72
73 ANY * Tsavestack;
74 I32 Tsavestack_ix;
75 I32 Tsavestack_max;
76
77 OP ** Tretstack;
78 I32 Tretstack_ix;
79 I32 Tretstack_max;
80
81 I32 * Tmarkstack;
82 I32 * Tmarkstack_ptr;
83 I32 * Tmarkstack_max;
84
85 SV ** Tcurpad;
86
87 SV * TSv;
88 XPV * TXpv;
89 char Tbuf[2048]; /* should be a global locked by a mutex */
90 char Ttokenbuf[256]; /* should be a global locked by a mutex */
91 struct stat Tstatbuf;
92 struct tms Ttimesbuf;
93
94 /* XXX What about regexp stuff? */
95
96 /* Now the fields that used to be "per interpreter" (even when global) */
97
98 /* XXX What about magic variables such as $/, $? and so on? */
99 HV * Tdefstash;
100 HV * Tcurstash;
101 AV * Tpad;
102 AV * Tpadname;
103
104 SV ** Ttmps_stack;
105 I32 Ttmps_ix;
106 I32 Ttmps_floor;
107 I32 Ttmps_max;
108
109 int Tin_eval;
110 OP * Trestartop;
111 int Tdelaymagic;
112 bool Tdirty;
113 U8 Tlocalizing;
114
115 CONTEXT * Tcxstack;
116 I32 Tcxstack_ix;
117 I32 Tcxstack_max;
118
119 AV * Tstack;
120 AV * Tmainstack;
e858de61 121 JMPENV * Ttop_env;
11343788
MB
122 I32 Trunlevel;
123
124 /* XXX Sort stuff, firstgv, secongv and so on? */
125
126 pthread_mutex_t * Tthreadstart_mutexp;
127 HV * Tcvcache;
f93b4edd 128 U32 Tthrflags;
11343788
MB
129};
130
131typedef struct thread *Thread;
132
f93b4edd
MB
133/* Values and macros for thrflags */
134#define THR_STATE_MASK 3
135#define THR_NORMAL 0
136#define THR_DETACHED 1
137#define THR_JOINED 2
138#define THR_DEAD 3
139
140#define ThrSTATE(t) (t->Tthrflags & THR_STATE_MASK)
141#define ThrSETSTATE(t, s) STMT_START { \
142 (t)->Tthrflags &= ~THR_STATE_MASK; \
143 (t)->Tthrflags |= (s); \
144 DEBUG_L(fprintf(stderr, "thread 0x%lx set to state %d\n", \
145 (unsigned long)(t), (s))); \
146 } STMT_END
147
148typedef struct condpair {
149 pthread_mutex_t mutex;
150 pthread_cond_t owner_cond;
151 pthread_cond_t cond;
152 Thread owner;
153} condpair_t;
154
155#define MgMUTEXP(mg) (&((condpair_t *)(mg->mg_ptr))->mutex)
156#define MgOWNERCONDP(mg) (&((condpair_t *)(mg->mg_ptr))->owner_cond)
157#define MgCONDP(mg) (&((condpair_t *)(mg->mg_ptr))->cond)
158#define MgOWNER(mg) ((condpair_t *)(mg->mg_ptr))->owner
159
11343788
MB
160#undef stack_base
161#undef stack_sp
162#undef stack_max
163#undef stack
164#undef mainstack
165#undef markstack
166#undef markstack_ptr
167#undef markstack_max
168#undef scopestack
169#undef scopestack_ix
170#undef scopestack_max
171#undef savestack
172#undef savestack_ix
173#undef savestack_max
174#undef retstack
175#undef retstack_ix
176#undef retstack_max
177#undef cxstack
178#undef cxstack_ix
179#undef cxstack_max
6d4ff0d2
MB
180#undef tmps_stack
181#undef tmps_floor
182#undef tmps_ix
183#undef tmps_max
11343788
MB
184#undef curpad
185#undef Sv
186#undef Xpv
11343788
MB
187#undef top_env
188#undef runlevel
189#undef in_eval
190
191#define self (thr->Tself)
192#define stack_base (thr->Tstack_base)
193#define stack_sp (thr->Tstack_sp)
194#define stack_max (thr->Tstack_max)
462e5cf6
MB
195#ifdef OP_IN_REGISTER
196#define opsave (thr->Topsave)
197#else
198#undef op
11343788 199#define op (thr->Top)
462e5cf6 200#endif
11343788
MB
201#define stack (thr->Tstack)
202#define mainstack (thr->Tmainstack)
203#define markstack (thr->Tmarkstack)
204#define markstack_ptr (thr->Tmarkstack_ptr)
205#define markstack_max (thr->Tmarkstack_max)
206#define scopestack (thr->Tscopestack)
207#define scopestack_ix (thr->Tscopestack_ix)
208#define scopestack_max (thr->Tscopestack_max)
209
210#define savestack (thr->Tsavestack)
211#define savestack_ix (thr->Tsavestack_ix)
212#define savestack_max (thr->Tsavestack_max)
213
214#define retstack (thr->Tretstack)
215#define retstack_ix (thr->Tretstack_ix)
216#define retstack_max (thr->Tretstack_max)
217
218#define cxstack (thr->Tcxstack)
219#define cxstack_ix (thr->Tcxstack_ix)
220#define cxstack_max (thr->Tcxstack_max)
221
222#define curpad (thr->Tcurpad)
223#define Sv (thr->TSv)
224#define Xpv (thr->TXpv)
225#define defstash (thr->Tdefstash)
226#define curstash (thr->Tcurstash)
227#define pad (thr->Tpad)
228#define padname (thr->Tpadname)
229
230#define tmps_stack (thr->Ttmps_stack)
231#define tmps_ix (thr->Ttmps_ix)
232#define tmps_floor (thr->Ttmps_floor)
233#define tmps_max (thr->Ttmps_max)
234
235#define in_eval (thr->Tin_eval)
236#define restartop (thr->Trestartop)
237#define delaymagic (thr->Tdelaymagic)
238#define dirty (thr->Tdirty)
239#define localizing (thr->Tlocalizing)
240
241#define top_env (thr->Ttop_env)
242#define runlevel (thr->Trunlevel)
243
244#define threadstart_mutexp (thr->Tthreadstart_mutexp)
f93b4edd
MB
245#define cvcache (thr->Tcvcache)
246#define thrflags (thr->Tthrflags)
11343788 247#endif /* USE_THREADS */