This is a live mirror of the Perl 5 development currently hosted at https://github.com/perl/perl5
Tweaks to allow compilation without -DUSE_THREADS and fix
[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
63 OP * Top;
64
65 I32 * Tscopestack;
66 I32 Tscopestack_ix;
67 I32 Tscopestack_max;
68
69 ANY * Tsavestack;
70 I32 Tsavestack_ix;
71 I32 Tsavestack_max;
72
73 OP ** Tretstack;
74 I32 Tretstack_ix;
75 I32 Tretstack_max;
76
77 I32 * Tmarkstack;
78 I32 * Tmarkstack_ptr;
79 I32 * Tmarkstack_max;
80
81 SV ** Tcurpad;
82
83 SV * TSv;
84 XPV * TXpv;
85 char Tbuf[2048]; /* should be a global locked by a mutex */
86 char Ttokenbuf[256]; /* should be a global locked by a mutex */
87 struct stat Tstatbuf;
88 struct tms Ttimesbuf;
89
90 /* XXX What about regexp stuff? */
91
92 /* Now the fields that used to be "per interpreter" (even when global) */
93
94 /* XXX What about magic variables such as $/, $? and so on? */
95 HV * Tdefstash;
96 HV * Tcurstash;
97 AV * Tpad;
98 AV * Tpadname;
99
100 SV ** Ttmps_stack;
101 I32 Ttmps_ix;
102 I32 Ttmps_floor;
103 I32 Ttmps_max;
104
105 int Tin_eval;
106 OP * Trestartop;
107 int Tdelaymagic;
108 bool Tdirty;
109 U8 Tlocalizing;
110
111 CONTEXT * Tcxstack;
112 I32 Tcxstack_ix;
113 I32 Tcxstack_max;
114
115 AV * Tstack;
116 AV * Tmainstack;
117 Sigjmp_buf Ttop_env;
118 I32 Trunlevel;
119
120 /* XXX Sort stuff, firstgv, secongv and so on? */
121
122 pthread_mutex_t * Tthreadstart_mutexp;
123 HV * Tcvcache;
124};
125
126typedef struct thread *Thread;
127
128#undef stack_base
129#undef stack_sp
130#undef stack_max
131#undef stack
132#undef mainstack
133#undef markstack
134#undef markstack_ptr
135#undef markstack_max
136#undef scopestack
137#undef scopestack_ix
138#undef scopestack_max
139#undef savestack
140#undef savestack_ix
141#undef savestack_max
142#undef retstack
143#undef retstack_ix
144#undef retstack_max
145#undef cxstack
146#undef cxstack_ix
147#undef cxstack_max
148#undef curpad
149#undef Sv
150#undef Xpv
151#undef op
152#undef top_env
153#undef runlevel
154#undef in_eval
155
156#define self (thr->Tself)
157#define stack_base (thr->Tstack_base)
158#define stack_sp (thr->Tstack_sp)
159#define stack_max (thr->Tstack_max)
160#define op (thr->Top)
161#define stack (thr->Tstack)
162#define mainstack (thr->Tmainstack)
163#define markstack (thr->Tmarkstack)
164#define markstack_ptr (thr->Tmarkstack_ptr)
165#define markstack_max (thr->Tmarkstack_max)
166#define scopestack (thr->Tscopestack)
167#define scopestack_ix (thr->Tscopestack_ix)
168#define scopestack_max (thr->Tscopestack_max)
169
170#define savestack (thr->Tsavestack)
171#define savestack_ix (thr->Tsavestack_ix)
172#define savestack_max (thr->Tsavestack_max)
173
174#define retstack (thr->Tretstack)
175#define retstack_ix (thr->Tretstack_ix)
176#define retstack_max (thr->Tretstack_max)
177
178#define cxstack (thr->Tcxstack)
179#define cxstack_ix (thr->Tcxstack_ix)
180#define cxstack_max (thr->Tcxstack_max)
181
182#define curpad (thr->Tcurpad)
183#define Sv (thr->TSv)
184#define Xpv (thr->TXpv)
185#define defstash (thr->Tdefstash)
186#define curstash (thr->Tcurstash)
187#define pad (thr->Tpad)
188#define padname (thr->Tpadname)
189
190#define tmps_stack (thr->Ttmps_stack)
191#define tmps_ix (thr->Ttmps_ix)
192#define tmps_floor (thr->Ttmps_floor)
193#define tmps_max (thr->Ttmps_max)
194
195#define in_eval (thr->Tin_eval)
196#define restartop (thr->Trestartop)
197#define delaymagic (thr->Tdelaymagic)
198#define dirty (thr->Tdirty)
199#define localizing (thr->Tlocalizing)
200
201#define top_env (thr->Ttop_env)
202#define runlevel (thr->Trunlevel)
203
204#define threadstart_mutexp (thr->Tthreadstart_mutexp)
205#define cvcache (thr->Tcvcache)
206#endif /* USE_THREADS */