1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
|
/* sharedsv.c
*
* Copyright (c) 2001, Larry Wall
*
* You may distribute under the terms of either the GNU General Public
* License or the Artistic License, as specified in the README file.
*
*/
/*
* Contributed by Arthur Bergman arthur@contiller.se
*
* "Hand any two wizards a piece of rope and they would instinctively pull in
* opposite directions."
* --Sourcery
*
*/
#include "EXTERN.h"
#define PERL_IN_SHAREDSV_C
#include "perl.h"
#ifdef USE_ITHREADS
/*
Shared SV
Shared SV is a structure for keeping the backend storage
of shared svs.
*/
/*
=for apidoc sharedsv_init
Saves a space for keeping SVs wider than an interpreter,
currently only stores a pointer to the first interpreter.
=cut
*/
void
Perl_sharedsv_init(pTHX)
{
PerlInterpreter* old_context = PERL_GET_CONTEXT;
PL_sharedsv_space = perl_alloc();
perl_construct(PL_sharedsv_space);
PERL_SET_CONTEXT(old_context);
MUTEX_INIT(&PL_sharedsv_space_mutex);
}
/*
=for apidoc sharedsv_new
Allocates a new shared sv struct, you must yourself create the SV/AV/HV.
=cut
*/
shared_sv *
Perl_sharedsv_new(pTHX)
{
shared_sv* ssv;
New(2555,ssv,1,shared_sv);
MUTEX_INIT(&ssv->mutex);
COND_INIT(&ssv->cond);
COND_INIT(&ssv->user_cond);
ssv->owner = 0;
ssv->locks = 0;
ssv->index = 0;
return ssv;
}
/*
=for apidoc sharedsv_find
Tries to find if a given SV has a shared backend, either by
looking at magic, or by checking if it is tied again threads::shared.
=cut
*/
shared_sv *
Perl_sharedsv_find(pTHX_ SV* sv)
{
/* does all it can to find a shared_sv struct, returns NULL otherwise */
shared_sv* ssv = NULL;
switch (SvTYPE(sv)) {
case SVt_PVMG:
{MAGIC* mg = mg_find(sv, PERL_MAGIC_ext);
if(strcmp(mg->mg_ptr,"threads::shared"))
break;
ssv = (shared_sv*) SvIV(mg->mg_obj);
}
}
return ssv;
}
/*
=for apidoc sharedsv_lock
Recursive locks on a sharedsv.
Locks are dynamicly scoped at the level of the first lock.
=cut
*/
void
Perl_sharedsv_lock(pTHX_ shared_sv* ssv)
{
if(!ssv)
return;
MUTEX_LOCK(&ssv->mutex);
if(ssv->owner && ssv->owner == my_perl) {
ssv->locks++;
MUTEX_UNLOCK(&ssv->mutex);
return;
}
while(ssv->owner)
COND_WAIT(&ssv->cond,&ssv->mutex);
ssv->locks++;
ssv->owner = my_perl;
if(ssv->locks == 1)
SAVEDESTRUCTOR_X(Perl_sharedsv_unlock_scope,ssv);
MUTEX_UNLOCK(&ssv->mutex);
}
/*
=for apidoc sharedsv_unlock
Recursively unlocks a shared sv.
=cut
*/
void
Perl_sharedsv_unlock(pTHX_ shared_sv* ssv)
{
MUTEX_LOCK(&ssv->mutex);
if(ssv->owner != my_perl) {
Perl_croak(aTHX_ "panic: Perl_sharedsv_unlock unlocking mutex that we don't own");
MUTEX_UNLOCK(&ssv->mutex);
return;
}
if(--ssv->locks == 0) {
ssv->owner = NULL;
COND_SIGNAL(&ssv->cond);
}
MUTEX_UNLOCK(&ssv->mutex);
}
void
Perl_sharedsv_unlock_scope(pTHX_ shared_sv* ssv)
{
MUTEX_LOCK(&ssv->mutex);
if(ssv->owner != my_perl) {
MUTEX_UNLOCK(&ssv->mutex);
return;
}
ssv->locks = 0;
ssv->owner = NULL;
COND_SIGNAL(&ssv->cond);
MUTEX_UNLOCK(&ssv->mutex);
}
/*
=for apidoc sharedsv_thrcnt_inc
Increments the threadcount of a sharedsv.
=cut
*/
void
Perl_sharedsv_thrcnt_inc(pTHX_ shared_sv* ssv)
{
SHAREDSvLOCK(ssv);
SvREFCNT_inc(ssv->sv);
SHAREDSvUNLOCK(ssv);
}
/*
=for apidoc sharedsv_thrcnt_dec
Decrements the threadcount of a shared sv. When a threads frontend is freed
this function should be called.
=cut
*/
void
Perl_sharedsv_thrcnt_dec(pTHX_ shared_sv* ssv)
{
SV* sv;
SHAREDSvLOCK(ssv);
sv = SHAREDSvGET(ssv);
if (SvREFCNT(sv) == 1) {
switch (SvTYPE(sv)) {
case SVt_RV:
if (SvROK(sv))
Perl_sharedsv_thrcnt_dec(aTHX_ INT2PTR(shared_sv *, SvIV(SvRV(sv))));
break;
case SVt_PVAV: {
SV **src_ary = AvARRAY((AV *)sv);
SSize_t items = AvFILLp((AV *)sv) + 1;
while (items-- > 0) {
if(SvTYPE(*src_ary))
Perl_sharedsv_thrcnt_dec(aTHX_ INT2PTR(shared_sv *, SvIV(*src_ary++)));
}
break;
}
case SVt_PVHV: {
HE *entry;
(void)hv_iterinit((HV *)sv);
while ((entry = hv_iternext((HV *)sv)))
Perl_sharedsv_thrcnt_dec(
aTHX_ INT2PTR(shared_sv *, SvIV(hv_iterval((HV *)sv, entry)))
);
break;
}
}
}
Perl_sv_free(PL_sharedsv_space,SHAREDSvGET(ssv));
SHAREDSvUNLOCK(ssv);
}
#endif /* USE_ITHREADS */
|
