ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/Coro/Coro/State.xs
(Generate patch)

Comparing Coro/Coro/State.xs (file contents):
Revision 1.6 by root, Tue Jul 17 15:42:28 2001 UTC vs.
Revision 1.275 by root, Sat Nov 15 06:26:52 2008 UTC

1#include "libcoro/coro.c"
2
3#define PERL_NO_GET_CONTEXT
4#define PERL_EXT
5
1#include "EXTERN.h" 6#include "EXTERN.h"
2#include "perl.h" 7#include "perl.h"
3#include "XSUB.h" 8#include "XSUB.h"
9#include "perliol.h"
4 10
5#if 0 11#include "patchlevel.h"
6# define CHK(x) (void *)0 12
13#include <stdio.h>
14#include <errno.h>
15#include <assert.h>
16
17#ifdef WIN32
18# undef setjmp
19# undef longjmp
20# undef _exit
21# define setjmp _setjmp // deep magic, don't ask
7#else 22#else
8# define CHK(x) if (!(x)) croak("FATAL, CHK: " #x) 23# include <inttypes.h> /* most portable stdint.h */
24#endif
25
26#ifdef HAVE_MMAP
27# include <unistd.h>
28# include <sys/mman.h>
29# ifndef MAP_ANONYMOUS
30# ifdef MAP_ANON
31# define MAP_ANONYMOUS MAP_ANON
32# else
33# undef HAVE_MMAP
34# endif
9#endif 35# endif
36# include <limits.h>
37# ifndef PAGESIZE
38# define PAGESIZE pagesize
39# define BOOT_PAGESIZE pagesize = sysconf (_SC_PAGESIZE)
40static long pagesize;
41# else
42# define BOOT_PAGESIZE (void)0
43# endif
44#else
45# define PAGESIZE 0
46# define BOOT_PAGESIZE (void)0
47#endif
10 48
49#if CORO_USE_VALGRIND
50# include <valgrind/valgrind.h>
51#endif
52
53/* the maximum number of idle cctx that will be pooled */
54static int cctx_max_idle = 4;
55
56#define PERL_VERSION_ATLEAST(a,b,c) \
57 (PERL_REVISION > (a) \
58 || (PERL_REVISION == (a) \
59 && (PERL_VERSION > (b) \
60 || (PERL_VERSION == (b) && PERLSUBVERSION >= (c)))))
61
62#if !PERL_VERSION_ATLEAST (5,6,0)
63# ifndef PL_ppaddr
64# define PL_ppaddr ppaddr
65# endif
66# ifndef call_sv
67# define call_sv perl_call_sv
68# endif
69# ifndef get_sv
70# define get_sv perl_get_sv
71# endif
72# ifndef get_cv
73# define get_cv perl_get_cv
74# endif
75# ifndef IS_PADGV
76# define IS_PADGV(v) 0
77# endif
78# ifndef IS_PADCONST
79# define IS_PADCONST(v) 0
80# endif
81#endif
82
83/* 5.11 */
84#ifndef CxHASARGS
85# define CxHASARGS(cx) (cx)->blk_sub.hasargs
86#endif
87
88/* 5.10.0 */
89#ifndef SvREFCNT_inc_NN
90# define SvREFCNT_inc_NN(sv) SvREFCNT_inc (sv)
91#endif
92
93/* 5.8.8 */
94#ifndef GV_NOTQUAL
95# define GV_NOTQUAL 0
96#endif
97#ifndef newSV
98# define newSV(l) NEWSV(0,l)
99#endif
100
101/* 5.8.7 */
102#ifndef SvRV_set
103# define SvRV_set(s,v) SvRV(s) = (v)
104#endif
105
106#if !__i386 && !__x86_64 && !__powerpc && !__m68k && !__alpha && !__mips && !__sparc64
107# undef CORO_STACKGUARD
108#endif
109
110#ifndef CORO_STACKGUARD
111# define CORO_STACKGUARD 0
112#endif
113
114/* prefer perl internal functions over our own? */
115#ifndef CORO_PREFER_PERL_FUNCTIONS
116# define CORO_PREFER_PERL_FUNCTIONS 0
117#endif
118
119/* The next macros try to return the current stack pointer, in an as
120 * portable way as possible. */
121#if __GNUC__ >= 4
122# define dSTACKLEVEL void *stacklevel = __builtin_frame_address (0)
123#else
124# define dSTACKLEVEL volatile void *stacklevel = (volatile void *)&stacklevel
125#endif
126
127#define IN_DESTRUCT (PL_main_cv == Nullcv)
128
129#if __GNUC__ >= 3
130# define attribute(x) __attribute__(x)
131# define expect(expr,value) __builtin_expect ((expr),(value))
132# define INLINE static inline
133#else
134# define attribute(x)
135# define expect(expr,value) (expr)
136# define INLINE static
137#endif
138
139#define expect_false(expr) expect ((expr) != 0, 0)
140#define expect_true(expr) expect ((expr) != 0, 1)
141
142#define NOINLINE attribute ((noinline))
143
144#include "CoroAPI.h"
145
146#ifdef USE_ITHREADS
147
148static perl_mutex coro_lock;
149# define LOCK do { MUTEX_LOCK (&coro_lock); } while (0)
150# define UNLOCK do { MUTEX_UNLOCK (&coro_lock); } while (0)
151# if CORO_PTHREAD
152static void *coro_thx;
153# endif
154
155#else
156
157# define LOCK (void)0
158# define UNLOCK (void)0
159
160#endif
161
162# undef LOCK
163# define LOCK (void)0
164# undef UNLOCK
165# define UNLOCK (void)0
166
167/* helper storage struct for Coro::AIO */
168struct io_state
169{
170 AV *res;
171 int errorno;
172 I32 laststype; /* U16 in 5.10.0 */
173 int laststatval;
174 Stat_t statcache;
175};
176
177static double (*nvtime)(); /* so why doesn't it take void? */
178
179static U32 cctx_gen;
180static size_t cctx_stacksize = CORO_STACKSIZE;
181static struct CoroAPI coroapi;
182static AV *main_mainstack; /* used to differentiate between $main and others */
183static JMPENV *main_top_env;
184static HV *coro_state_stash, *coro_stash;
185static volatile SV *coro_mortal; /* will be freed/thrown after next transfer */
186static volatile struct coro *transfer_next;
187
188static GV *irsgv; /* $/ */
189static GV *stdoutgv; /* *STDOUT */
190static SV *rv_diehook;
191static SV *rv_warnhook;
192static HV *hv_sig; /* %SIG */
193
194/* async_pool helper stuff */
195static SV *sv_pool_rss;
196static SV *sv_pool_size;
197static AV *av_async_pool;
198
199/* Coro::AnyEvent */
200static SV *sv_activity;
201
202static struct coro_cctx *cctx_first;
203static int cctx_count, cctx_idle;
204
205enum {
206 CC_MAPPED = 0x01,
207 CC_NOREUSE = 0x02, /* throw this away after tracing */
208 CC_TRACE = 0x04,
209 CC_TRACE_SUB = 0x08, /* trace sub calls */
210 CC_TRACE_LINE = 0x10, /* trace each statement */
211 CC_TRACE_ALL = CC_TRACE_SUB | CC_TRACE_LINE,
212};
213
214/* this is a structure representing a c-level coroutine */
215typedef struct coro_cctx
216{
217 struct coro_cctx *next;
218
219 /* the stack */
220 void *sptr;
221 size_t ssize;
222
223 /* cpu state */
224 void *idle_sp; /* sp of top-level transfer/schedule/cede call */
225 JMPENV *idle_te; /* same as idle_sp, but for top_env, TODO: remove once stable */
226 JMPENV *top_env;
227 coro_context cctx;
228
229 U32 gen;
230#if CORO_USE_VALGRIND
231 int valgrind_id;
232#endif
233 unsigned char flags;
234} coro_cctx;
235
236enum {
237 CF_RUNNING = 0x0001, /* coroutine is running */
238 CF_READY = 0x0002, /* coroutine is ready */
239 CF_NEW = 0x0004, /* has never been switched to */
240 CF_DESTROYED = 0x0008, /* coroutine data has been freed */
241};
242
243/* the structure where most of the perl state is stored, overlaid on the cxstack */
244typedef struct
245{
246 SV *defsv;
247 AV *defav;
248 SV *errsv;
249 SV *irsgv;
250#define VAR(name,type) type name;
251# include "state.h"
252#undef VAR
253} perl_slots;
254
255#define SLOT_COUNT ((sizeof (perl_slots) + sizeof (PERL_CONTEXT) - 1) / sizeof (PERL_CONTEXT))
256
257/* this is a structure representing a perl-level coroutine */
11struct coro { 258struct coro {
12 U8 dowarn; 259 /* the C coroutine allocated to this perl coroutine, if any */
13 AV *defav; 260 coro_cctx *cctx;
14 261
15 PERL_SI *curstackinfo; 262 /* process data */
16 AV *curstack; 263 struct CoroSLF slf_frame; /* saved slf frame */
17 AV *mainstack; 264 AV *mainstack;
18 SV **stack_sp; 265 perl_slots *slot; /* basically the saved sp */
19 OP *op;
20 SV **curpad;
21 SV **stack_base;
22 SV **stack_max;
23 SV **tmps_stack;
24 I32 tmps_floor;
25 I32 tmps_ix;
26 I32 tmps_max;
27 I32 *markstack;
28 I32 *markstack_ptr;
29 I32 *markstack_max;
30 I32 *scopestack;
31 I32 scopestack_ix;
32 I32 scopestack_max;
33 ANY *savestack;
34 I32 savestack_ix;
35 I32 savestack_max;
36 OP **retstack;
37 I32 retstack_ix;
38 I32 retstack_max;
39 COP *curcop;
40 266
41 AV *args; 267 AV *args; /* data associated with this coroutine (initial args) */
268 int refcnt; /* coroutines are refcounted, yes */
269 int flags; /* CF_ flags */
270 HV *hv; /* the perl hash associated with this coro, if any */
271
272 /* statistics */
273 int usecount; /* number of transfers to this coro */
274
275 /* coro process data */
276 int prio;
277 SV *throw; /* exception to be thrown */
278
279 /* async_pool */
280 SV *saved_deffh;
281
282 /* linked list */
283 struct coro *next, *prev;
42}; 284};
43 285
44typedef struct coro *Coro__State; 286typedef struct coro *Coro__State;
45typedef struct coro *Coro__State_or_hashref; 287typedef struct coro *Coro__State_or_hashref;
46 288
47static HV *padlist_cache; 289static struct CoroSLF slf_frame; /* the current slf frame */
48 290
49/* mostly copied from op.c:cv_clone2 */ 291/** Coro ********************************************************************/
50STATIC AV * 292
51clone_padlist (AV *protopadlist) 293#define PRIO_MAX 3
294#define PRIO_HIGH 1
295#define PRIO_NORMAL 0
296#define PRIO_LOW -1
297#define PRIO_IDLE -3
298#define PRIO_MIN -4
299
300/* for Coro.pm */
301static SV *coro_current;
302static SV *coro_readyhook;
303static AV *coro_ready [PRIO_MAX - PRIO_MIN + 1];
304static struct coro *coro_first;
305#define coro_nready coroapi.nready
306
307/** lowlevel stuff **********************************************************/
308
309static SV *
310coro_get_sv (pTHX_ const char *name, int create)
52{ 311{
53 AV *av; 312#if PERL_VERSION_ATLEAST (5,10,0)
54 I32 ix; 313 /* silence stupid and wrong 5.10 warning that I am unable to switch off */
55 AV *protopad_name = (AV *) * av_fetch (protopadlist, 0, FALSE); 314 get_sv (name, create);
56 AV *protopad = (AV *) * av_fetch (protopadlist, 1, FALSE); 315#endif
57 SV **pname = AvARRAY (protopad_name); 316 return get_sv (name, create);
58 SV **ppad = AvARRAY (protopad); 317}
59 I32 fname = AvFILLp (protopad_name); 318
60 I32 fpad = AvFILLp (protopad); 319static AV *
320coro_get_av (pTHX_ const char *name, int create)
321{
322#if PERL_VERSION_ATLEAST (5,10,0)
323 /* silence stupid and wrong 5.10 warning that I am unable to switch off */
324 get_av (name, create);
325#endif
326 return get_av (name, create);
327}
328
329static HV *
330coro_get_hv (pTHX_ const char *name, int create)
331{
332#if PERL_VERSION_ATLEAST (5,10,0)
333 /* silence stupid and wrong 5.10 warning that I am unable to switch off */
334 get_hv (name, create);
335#endif
336 return get_hv (name, create);
337}
338
339static AV *
340coro_clone_padlist (pTHX_ CV *cv)
341{
342 AV *padlist = CvPADLIST (cv);
61 AV *newpadlist, *newpad_name, *newpad; 343 AV *newpadlist, *newpad;
62 SV **npad;
63
64 newpad_name = newAV ();
65 for (ix = fname; ix >= 0; ix--)
66 av_store (newpad_name, ix, SvREFCNT_inc (pname[ix]));
67
68 newpad = newAV ();
69 av_fill (newpad, AvFILLp (protopad));
70 npad = AvARRAY (newpad);
71 344
72 newpadlist = newAV (); 345 newpadlist = newAV ();
73 AvREAL_off (newpadlist); 346 AvREAL_off (newpadlist);
74 av_store (newpadlist, 0, (SV *) newpad_name); 347#if PERL_VERSION_ATLEAST (5,10,0)
348 Perl_pad_push (aTHX_ padlist, AvFILLp (padlist) + 1);
349#else
350 Perl_pad_push (aTHX_ padlist, AvFILLp (padlist) + 1, 1);
351#endif
352 newpad = (AV *)AvARRAY (padlist)[AvFILLp (padlist)];
353 --AvFILLp (padlist);
354
355 av_store (newpadlist, 0, SvREFCNT_inc_NN (*av_fetch (padlist, 0, FALSE)));
75 av_store (newpadlist, 1, (SV *) newpad); 356 av_store (newpadlist, 1, (SV *)newpad);
76 357
77 av = newAV (); /* will be @_ */ 358 return newpadlist;
78 av_extend (av, 0); 359}
79 av_store (newpad, 0, (SV *) av);
80 AvFLAGS (av) = AVf_REIFY;
81 360
82 for (ix = fpad; ix > 0; ix--) 361static void
362free_padlist (pTHX_ AV *padlist)
363{
364 /* may be during global destruction */
365 if (SvREFCNT (padlist))
83 { 366 {
84 SV *namesv = (ix <= fname) ? pname[ix] : Nullsv; 367 I32 i = AvFILLp (padlist);
85 if (namesv && namesv != &PL_sv_undef) 368 while (i >= 0)
86 { 369 {
87 char *name = SvPVX (namesv); /* XXX */ 370 SV **svp = av_fetch (padlist, i--, FALSE);
88 if (SvFLAGS (namesv) & SVf_FAKE || *name == '&') 371 if (svp)
89 { /* lexical from outside? */
90 npad[ix] = SvREFCNT_inc (ppad[ix]);
91 } 372 {
92 else
93 { /* our own lexical */
94 SV *sv; 373 SV *sv;
95 if (*name == '&') 374 while (&PL_sv_undef != (sv = av_pop ((AV *)*svp)))
96 sv = SvREFCNT_inc (ppad[ix]); 375 SvREFCNT_dec (sv);
97 else if (*name == '@') 376
98 sv = (SV *) newAV (); 377 SvREFCNT_dec (*svp);
99 else if (*name == '%')
100 sv = (SV *) newHV ();
101 else
102 sv = NEWSV (0, 0);
103 if (!SvPADBUSY (sv))
104 SvPADMY_on (sv);
105 npad[ix] = sv;
106 } 378 }
107 } 379 }
108 else if (IS_PADGV (ppad[ix]) || IS_PADCONST (ppad[ix]))
109 {
110 npad[ix] = SvREFCNT_inc (ppad[ix]);
111 }
112 else
113 {
114 SV *sv = NEWSV (0, 0);
115 SvPADTMP_on (sv);
116 npad[ix] = sv;
117 }
118 }
119 380
120#if 0 /* NONOTUNDERSTOOD */
121 /* Now that vars are all in place, clone nested closures. */
122
123 for (ix = fpad; ix > 0; ix--) {
124 SV* namesv = (ix <= fname) ? pname[ix] : Nullsv;
125 if (namesv
126 && namesv != &PL_sv_undef
127 && !(SvFLAGS(namesv) & SVf_FAKE)
128 && *SvPVX(namesv) == '&'
129 && CvCLONE(ppad[ix]))
130 {
131 CV *kid = cv_clone((CV*)ppad[ix]);
132 SvREFCNT_dec(ppad[ix]);
133 CvCLONE_on(kid);
134 SvPADMY_on(kid);
135 npad[ix] = (SV*)kid;
136 }
137 }
138#endif
139
140 return newpadlist;
141}
142
143STATIC AV *
144free_padlist (AV *padlist)
145{
146 /* may be during global destruction */
147 if (SvREFCNT(padlist))
148 {
149 I32 i = AvFILLp(padlist);
150 while (i >= 0)
151 {
152 SV **svp = av_fetch(padlist, i--, FALSE);
153 SV *sv = svp ? *svp : Nullsv;
154 if (sv)
155 SvREFCNT_dec(sv);
156 }
157
158 SvREFCNT_dec((SV*)padlist); 381 SvREFCNT_dec ((SV*)padlist);
382 }
383}
384
385static int
386coro_cv_free (pTHX_ SV *sv, MAGIC *mg)
387{
388 AV *padlist;
389 AV *av = (AV *)mg->mg_obj;
390
391 /* casting is fun. */
392 while (&PL_sv_undef != (SV *)(padlist = (AV *)av_pop (av)))
393 free_padlist (aTHX_ padlist);
394
395 SvREFCNT_dec (av); /* sv_magicext increased the refcount */
396
397 return 0;
398}
399
400#define CORO_MAGIC_type_cv PERL_MAGIC_ext
401#define CORO_MAGIC_type_state PERL_MAGIC_ext
402
403static MGVTBL coro_cv_vtbl = {
404 0, 0, 0, 0,
405 coro_cv_free
406};
407
408#define CORO_MAGIC(sv, type) \
409 SvMAGIC (sv) \
410 ? SvMAGIC (sv)->mg_type == type \
411 ? SvMAGIC (sv) \
412 : mg_find (sv, type) \
413 : 0
414
415#define CORO_MAGIC_cv(cv) CORO_MAGIC (((SV *)(cv)), CORO_MAGIC_type_cv)
416#define CORO_MAGIC_state(sv) CORO_MAGIC (((SV *)(sv)), CORO_MAGIC_type_state)
417
418INLINE struct coro *
419SvSTATE_ (pTHX_ SV *coro)
420{
421 HV *stash;
422 MAGIC *mg;
423
424 if (SvROK (coro))
425 coro = SvRV (coro);
426
427 if (expect_false (SvTYPE (coro) != SVt_PVHV))
428 croak ("Coro::State object required");
429
430 stash = SvSTASH (coro);
431 if (expect_false (stash != coro_stash && stash != coro_state_stash))
432 {
433 /* very slow, but rare, check */
434 if (!sv_derived_from (sv_2mortal (newRV_inc (coro)), "Coro::State"))
435 croak ("Coro::State object required");
436 }
437
438 mg = CORO_MAGIC_state (coro);
439 return (struct coro *)mg->mg_ptr;
440}
441
442#define SvSTATE(sv) SvSTATE_ (aTHX_ (sv))
443
444/* the next two functions merely cache the padlists */
445static void
446get_padlist (pTHX_ CV *cv)
447{
448 MAGIC *mg = CORO_MAGIC_cv (cv);
449 AV *av;
450
451 if (expect_true (mg && AvFILLp ((av = (AV *)mg->mg_obj)) >= 0))
452 CvPADLIST (cv) = (AV *)AvARRAY (av)[AvFILLp (av)--];
453 else
454 {
455#if CORO_PREFER_PERL_FUNCTIONS
456 /* this is probably cleaner? but also slower! */
457 /* in practise, it seems to be less stable */
458 CV *cp = Perl_cv_clone (cv);
459 CvPADLIST (cv) = CvPADLIST (cp);
460 CvPADLIST (cp) = 0;
461 SvREFCNT_dec (cp);
462#else
463 CvPADLIST (cv) = coro_clone_padlist (aTHX_ cv);
464#endif
465 }
466}
467
468static void
469put_padlist (pTHX_ CV *cv)
470{
471 MAGIC *mg = CORO_MAGIC_cv (cv);
472 AV *av;
473
474 if (expect_false (!mg))
475 mg = sv_magicext ((SV *)cv, (SV *)newAV (), CORO_MAGIC_type_cv, &coro_cv_vtbl, 0, 0);
476
477 av = (AV *)mg->mg_obj;
478
479 if (expect_false (AvFILLp (av) >= AvMAX (av)))
480 av_extend (av, AvMAX (av) + 1);
481
482 AvARRAY (av)[++AvFILLp (av)] = (SV *)CvPADLIST (cv);
483}
484
485/** load & save, init *******************************************************/
486
487static void
488load_perl (pTHX_ Coro__State c)
489{
490 perl_slots *slot = c->slot;
491 c->slot = 0;
492
493 PL_mainstack = c->mainstack;
494
495 GvSV (PL_defgv) = slot->defsv;
496 GvAV (PL_defgv) = slot->defav;
497 GvSV (PL_errgv) = slot->errsv;
498 GvSV (irsgv) = slot->irsgv;
499
500 #define VAR(name,type) PL_ ## name = slot->name;
501 # include "state.h"
502 #undef VAR
503
504 {
505 dSP;
506
507 CV *cv;
508
509 /* now do the ugly restore mess */
510 while (expect_true (cv = (CV *)POPs))
511 {
512 put_padlist (aTHX_ cv); /* mark this padlist as available */
513 CvDEPTH (cv) = PTR2IV (POPs);
514 CvPADLIST (cv) = (AV *)POPs;
515 }
516
517 PUTBACK;
159 } 518 }
160}
161 519
162/* the next tow functions merely cache the padlists */ 520 slf_frame = c->slf_frame;
163STATIC void
164get_padlist (CV *cv)
165{
166 SV **he = hv_fetch (padlist_cache, (void *)&cv, sizeof (CV *), 0);
167
168 if (he && AvFILLp ((AV *)*he) >= 0)
169 CvPADLIST (cv) = (AV *)av_pop ((AV *)*he);
170 else
171 CvPADLIST (cv) = clone_padlist (CvPADLIST (cv));
172} 521}
173 522
174STATIC void
175put_padlist (CV *cv)
176{
177 SV **he = hv_fetch (padlist_cache, (void *)&cv, sizeof (CV *), 1);
178
179 if (SvTYPE (*he) != SVt_PVAV)
180 {
181 SvREFCNT_dec (*he);
182 *he = (SV *)newAV ();
183 }
184
185 av_push ((AV *)*he, (SV *)CvPADLIST (cv));
186}
187
188static void 523static void
189save_state(pTHX_ Coro__State c) 524save_perl (pTHX_ Coro__State c)
190{ 525{
526 c->slf_frame = slf_frame;
527
191 { 528 {
192 dSP; 529 dSP;
193 I32 cxix = cxstack_ix; 530 I32 cxix = cxstack_ix;
531 PERL_CONTEXT *ccstk = cxstack;
194 PERL_SI *top_si = PL_curstackinfo; 532 PERL_SI *top_si = PL_curstackinfo;
195 PERL_CONTEXT *ccstk = cxstack;
196 533
197 /* 534 /*
198 * the worst thing you can imagine happens first - we have to save 535 * the worst thing you can imagine happens first - we have to save
199 * (and reinitialize) all cv's in the whole callchain :( 536 * (and reinitialize) all cv's in the whole callchain :(
200 */ 537 */
201 538
202 PUSHs (Nullsv); 539 XPUSHs (Nullsv);
203 /* this loop was inspired by pp_caller */ 540 /* this loop was inspired by pp_caller */
204 for (;;) 541 for (;;)
205 { 542 {
206 while (cxix >= 0) 543 while (expect_true (cxix >= 0))
207 { 544 {
208 PERL_CONTEXT *cx = &ccstk[cxix--]; 545 PERL_CONTEXT *cx = &ccstk[cxix--];
209 546
210 if (CxTYPE(cx) == CXt_SUB) 547 if (expect_true (CxTYPE (cx) == CXt_SUB || CxTYPE (cx) == CXt_FORMAT))
211 { 548 {
212 CV *cv = cx->blk_sub.cv; 549 CV *cv = cx->blk_sub.cv;
550
213 if (CvDEPTH(cv)) 551 if (expect_true (CvDEPTH (cv)))
214 { 552 {
215#ifdef USE_THREADS
216 XPUSHs ((SV *)CvOWNER(cv));
217#endif
218 EXTEND (SP, 3); 553 EXTEND (SP, 3);
219 PUSHs ((SV *)CvDEPTH(cv));
220 PUSHs ((SV *)CvPADLIST(cv)); 554 PUSHs ((SV *)CvPADLIST (cv));
555 PUSHs (INT2PTR (SV *, (IV)CvDEPTH (cv)));
221 PUSHs ((SV *)cv); 556 PUSHs ((SV *)cv);
222 557
223 get_padlist (cv);
224
225 CvDEPTH(cv) = 0; 558 CvDEPTH (cv) = 0;
226#ifdef USE_THREADS 559 get_padlist (aTHX_ cv);
227 CvOWNER(cv) = 0;
228 error must unlock this cv etc.. etc...
229 if you are here wondering about this error message then
230 the reason is that it will not work as advertised yet
231#endif
232 } 560 }
233 } 561 }
234 else if (CxTYPE(cx) == CXt_FORMAT) 562 }
563
564 if (expect_true (top_si->si_type == PERLSI_MAIN))
565 break;
566
567 top_si = top_si->si_prev;
568 ccstk = top_si->si_cxstack;
569 cxix = top_si->si_cxix;
570 }
571
572 PUTBACK;
573 }
574
575 /* allocate some space on the context stack for our purposes */
576 /* we manually unroll here, as usually 2 slots is enough */
577 if (SLOT_COUNT >= 1) CXINC;
578 if (SLOT_COUNT >= 2) CXINC;
579 if (SLOT_COUNT >= 3) CXINC;
580 {
581 int i;
582 for (i = 3; i < SLOT_COUNT; ++i)
583 CXINC;
584 }
585 cxstack_ix -= SLOT_COUNT; /* undo allocation */
586
587 c->mainstack = PL_mainstack;
588
589 {
590 perl_slots *slot = c->slot = (perl_slots *)(cxstack + cxstack_ix + 1);
591
592 slot->defav = GvAV (PL_defgv);
593 slot->defsv = DEFSV;
594 slot->errsv = ERRSV;
595 slot->irsgv = GvSV (irsgv);
596
597 #define VAR(name,type) slot->name = PL_ ## name;
598 # include "state.h"
599 #undef VAR
600 }
601}
602
603/*
604 * allocate various perl stacks. This is almost an exact copy
605 * of perl.c:init_stacks, except that it uses less memory
606 * on the (sometimes correct) assumption that coroutines do
607 * not usually need a lot of stackspace.
608 */
609#if CORO_PREFER_PERL_FUNCTIONS
610# define coro_init_stacks init_stacks
611#else
612static void
613coro_init_stacks (pTHX)
614{
615 PL_curstackinfo = new_stackinfo(32, 8);
616 PL_curstackinfo->si_type = PERLSI_MAIN;
617 PL_curstack = PL_curstackinfo->si_stack;
618 PL_mainstack = PL_curstack; /* remember in case we switch stacks */
619
620 PL_stack_base = AvARRAY(PL_curstack);
621 PL_stack_sp = PL_stack_base;
622 PL_stack_max = PL_stack_base + AvMAX(PL_curstack);
623
624 New(50,PL_tmps_stack,32,SV*);
625 PL_tmps_floor = -1;
626 PL_tmps_ix = -1;
627 PL_tmps_max = 32;
628
629 New(54,PL_markstack,16,I32);
630 PL_markstack_ptr = PL_markstack;
631 PL_markstack_max = PL_markstack + 16;
632
633#ifdef SET_MARK_OFFSET
634 SET_MARK_OFFSET;
635#endif
636
637 New(54,PL_scopestack,8,I32);
638 PL_scopestack_ix = 0;
639 PL_scopestack_max = 8;
640
641 New(54,PL_savestack,24,ANY);
642 PL_savestack_ix = 0;
643 PL_savestack_max = 24;
644
645#if !PERL_VERSION_ATLEAST (5,10,0)
646 New(54,PL_retstack,4,OP*);
647 PL_retstack_ix = 0;
648 PL_retstack_max = 4;
649#endif
650}
651#endif
652
653/*
654 * destroy the stacks, the callchain etc...
655 */
656static void
657coro_destruct_stacks (pTHX)
658{
659 while (PL_curstackinfo->si_next)
660 PL_curstackinfo = PL_curstackinfo->si_next;
661
662 while (PL_curstackinfo)
663 {
664 PERL_SI *p = PL_curstackinfo->si_prev;
665
666 if (!IN_DESTRUCT)
667 SvREFCNT_dec (PL_curstackinfo->si_stack);
668
669 Safefree (PL_curstackinfo->si_cxstack);
670 Safefree (PL_curstackinfo);
671 PL_curstackinfo = p;
672 }
673
674 Safefree (PL_tmps_stack);
675 Safefree (PL_markstack);
676 Safefree (PL_scopestack);
677 Safefree (PL_savestack);
678#if !PERL_VERSION_ATLEAST (5,10,0)
679 Safefree (PL_retstack);
680#endif
681}
682
683static size_t
684coro_rss (pTHX_ struct coro *coro)
685{
686 size_t rss = sizeof (*coro);
687
688 if (coro->mainstack)
689 {
690 perl_slots tmp_slot;
691 perl_slots *slot;
692
693 if (coro->flags & CF_RUNNING)
694 {
695 slot = &tmp_slot;
696
697 #define VAR(name,type) slot->name = PL_ ## name;
698 # include "state.h"
699 #undef VAR
700 }
701 else
702 slot = coro->slot;
703
704 if (slot)
705 {
706 rss += sizeof (slot->curstackinfo);
707 rss += (slot->curstackinfo->si_cxmax + 1) * sizeof (PERL_CONTEXT);
708 rss += sizeof (SV) + sizeof (struct xpvav) + (1 + AvMAX (slot->curstack)) * sizeof (SV *);
709 rss += slot->tmps_max * sizeof (SV *);
710 rss += (slot->markstack_max - slot->markstack_ptr) * sizeof (I32);
711 rss += slot->scopestack_max * sizeof (I32);
712 rss += slot->savestack_max * sizeof (ANY);
713
714#if !PERL_VERSION_ATLEAST (5,10,0)
715 rss += slot->retstack_max * sizeof (OP *);
716#endif
717 }
718 }
719
720 return rss;
721}
722
723/** coroutine stack handling ************************************************/
724
725static int (*orig_sigelem_get) (pTHX_ SV *sv, MAGIC *mg);
726static int (*orig_sigelem_set) (pTHX_ SV *sv, MAGIC *mg);
727static int (*orig_sigelem_clr) (pTHX_ SV *sv, MAGIC *mg);
728
729/* apparently < 5.8.8 */
730#ifndef MgPV_nolen_const
731#define MgPV_nolen_const(mg) (((((int)(mg)->mg_len)) == HEf_SVKEY) ? \
732 SvPV_nolen((SV*)((mg)->mg_ptr)) : \
733 (const char*)(mg)->mg_ptr)
734#endif
735
736/*
737 * This overrides the default magic get method of %SIG elements.
738 * The original one doesn't provide for reading back of PL_diehook/PL_warnhook
739 * and instead of tryign to save and restore the hash elements, we just provide
740 * readback here.
741 * We only do this when the hook is != 0, as they are often set to 0 temporarily,
742 * not expecting this to actually change the hook. This is a potential problem
743 * when a schedule happens then, but we ignore this.
744 */
745static int
746coro_sigelem_get (pTHX_ SV *sv, MAGIC *mg)
747{
748 const char *s = MgPV_nolen_const (mg);
749
750 if (*s == '_')
751 {
752 SV **svp = 0;
753
754 if (strEQ (s, "__DIE__" )) svp = &PL_diehook;
755 if (strEQ (s, "__WARN__")) svp = &PL_warnhook;
756
757 if (svp)
758 {
759 sv_setsv (sv, *svp ? *svp : &PL_sv_undef);
760 return 0;
761 }
762 }
763
764 return orig_sigelem_get ? orig_sigelem_get (aTHX_ sv, mg) : 0;
765}
766
767static int
768coro_sigelem_clr (pTHX_ SV *sv, MAGIC *mg)
769{
770 const char *s = MgPV_nolen_const (mg);
771
772 if (*s == '_')
773 {
774 SV **svp = 0;
775
776 if (strEQ (s, "__DIE__" )) svp = &PL_diehook;
777 if (strEQ (s, "__WARN__")) svp = &PL_warnhook;
778
779 if (svp)
780 {
781 SV *old = *svp;
782 *svp = 0;
783 SvREFCNT_dec (old);
784 return 0;
785 }
786 }
787
788 return orig_sigelem_clr ? orig_sigelem_clr (aTHX_ sv, mg) : 0;
789}
790
791static int
792coro_sigelem_set (pTHX_ SV *sv, MAGIC *mg)
793{
794 const char *s = MgPV_nolen_const (mg);
795
796 if (*s == '_')
797 {
798 SV **svp = 0;
799
800 if (strEQ (s, "__DIE__" )) svp = &PL_diehook;
801 if (strEQ (s, "__WARN__")) svp = &PL_warnhook;
802
803 if (svp)
804 {
805 SV *old = *svp;
806 *svp = newSVsv (sv);
807 SvREFCNT_dec (old);
808 return 0;
809 }
810 }
811
812 return orig_sigelem_set ? orig_sigelem_set (aTHX_ sv, mg) : 0;
813}
814
815static void
816prepare_nop (aTHX_ struct coro_transfer_args *ta)
817{
818 /* kind of mega-hacky, but works */
819 ta->next = ta->prev = (struct coro *)ta;
820}
821
822static int
823slf_check_nop (aTHX)
824{
825 return 0;
826}
827
828static void
829coro_setup (pTHX_ struct coro *coro)
830{
831 /*
832 * emulate part of the perl startup here.
833 */
834 coro_init_stacks (aTHX);
835
836 PL_runops = RUNOPS_DEFAULT;
837 PL_curcop = &PL_compiling;
838 PL_in_eval = EVAL_NULL;
839 PL_comppad = 0;
840 PL_curpm = 0;
841 PL_curpad = 0;
842 PL_localizing = 0;
843 PL_dirty = 0;
844 PL_restartop = 0;
845#if PERL_VERSION_ATLEAST (5,10,0)
846 PL_parser = 0;
847#endif
848
849 /* recreate the die/warn hooks */
850 PL_diehook = 0; SvSetMagicSV (*hv_fetch (hv_sig, "__DIE__" , sizeof ("__DIE__" ) - 1, 1), rv_diehook );
851 PL_warnhook = 0; SvSetMagicSV (*hv_fetch (hv_sig, "__WARN__", sizeof ("__WARN__") - 1, 1), rv_warnhook);
852
853 GvSV (PL_defgv) = newSV (0);
854 GvAV (PL_defgv) = coro->args; coro->args = 0;
855 GvSV (PL_errgv) = newSV (0);
856 GvSV (irsgv) = newSVpvn ("\n", 1); sv_magic (GvSV (irsgv), (SV *)irsgv, PERL_MAGIC_sv, "/", 0);
857 PL_rs = newSVsv (GvSV (irsgv));
858 PL_defoutgv = (GV *)SvREFCNT_inc_NN (stdoutgv);
859
860 {
861 dSP;
862 UNOP myop;
863
864 Zero (&myop, 1, UNOP);
865 myop.op_next = Nullop;
866 myop.op_flags = OPf_WANT_VOID;
867
868 PUSHMARK (SP);
869 XPUSHs (sv_2mortal (av_shift (GvAV (PL_defgv))));
870 PUTBACK;
871 PL_op = (OP *)&myop;
872 PL_op = PL_ppaddr[OP_ENTERSUB](aTHX);
873 SPAGAIN;
874 }
875
876 /* this newly created coroutine might be run on an existing cctx which most
877 * likely was suspended in pp_slf, so we have to emulate entering pp_slf here.
878 */
879 slf_frame.prepare = prepare_nop; /* provide a nop function for an eventual pp_slf */
880 slf_frame.check = slf_check_nop; /* signal pp_slf to not repeat */
881}
882
883static void
884coro_destruct (pTHX_ struct coro *coro)
885{
886 if (!IN_DESTRUCT)
887 {
888 /* restore all saved variables and stuff */
889 LEAVE_SCOPE (0);
890 assert (PL_tmps_floor == -1);
891
892 /* free all temporaries */
893 FREETMPS;
894 assert (PL_tmps_ix == -1);
895
896 /* unwind all extra stacks */
897 POPSTACK_TO (PL_mainstack);
898
899 /* unwind main stack */
900 dounwind (-1);
901 }
902
903 SvREFCNT_dec (GvSV (PL_defgv));
904 SvREFCNT_dec (GvAV (PL_defgv));
905 SvREFCNT_dec (GvSV (PL_errgv));
906 SvREFCNT_dec (PL_defoutgv);
907 SvREFCNT_dec (PL_rs);
908 SvREFCNT_dec (GvSV (irsgv));
909
910 SvREFCNT_dec (PL_diehook);
911 SvREFCNT_dec (PL_warnhook);
912
913 SvREFCNT_dec (coro->saved_deffh);
914 SvREFCNT_dec (coro->throw);
915
916 coro_destruct_stacks (aTHX);
917}
918
919INLINE void
920free_coro_mortal (pTHX)
921{
922 if (expect_true (coro_mortal))
923 {
924 SvREFCNT_dec (coro_mortal);
925 coro_mortal = 0;
926 }
927}
928
929static int
930runops_trace (pTHX)
931{
932 COP *oldcop = 0;
933 int oldcxix = -2;
934 struct coro *coro = SvSTATE (coro_current); /* trace cctx is tied to specific coro */
935 coro_cctx *cctx = coro->cctx;
936
937 while ((PL_op = CALL_FPTR (PL_op->op_ppaddr) (aTHX)))
938 {
939 PERL_ASYNC_CHECK ();
940
941 if (cctx->flags & CC_TRACE_ALL)
942 {
943 if (PL_op->op_type == OP_LEAVESUB && cctx->flags & CC_TRACE_SUB)
944 {
945 PERL_CONTEXT *cx = &cxstack[cxstack_ix];
946 SV **bot, **top;
947 AV *av = newAV (); /* return values */
948 SV **cb;
949 dSP;
950
951 GV *gv = CvGV (cx->blk_sub.cv);
952 SV *fullname = sv_2mortal (newSV (0));
953 if (isGV (gv))
954 gv_efullname3 (fullname, gv, 0);
955
956 bot = PL_stack_base + cx->blk_oldsp + 1;
957 top = cx->blk_gimme == G_ARRAY ? SP + 1
958 : cx->blk_gimme == G_SCALAR ? bot + 1
959 : bot;
960
961 av_extend (av, top - bot);
962 while (bot < top)
963 av_push (av, SvREFCNT_inc_NN (*bot++));
964
965 PL_runops = RUNOPS_DEFAULT;
966 ENTER;
967 SAVETMPS;
968 EXTEND (SP, 3);
969 PUSHMARK (SP);
970 PUSHs (&PL_sv_no);
971 PUSHs (fullname);
972 PUSHs (sv_2mortal (newRV_noinc ((SV *)av)));
973 PUTBACK;
974 cb = hv_fetch ((HV *)SvRV (coro_current), "_trace_sub_cb", sizeof ("_trace_sub_cb") - 1, 0);
975 if (cb) call_sv (*cb, G_KEEPERR | G_EVAL | G_VOID | G_DISCARD);
976 SPAGAIN;
977 FREETMPS;
978 LEAVE;
979 PL_runops = runops_trace;
980 }
981
982 if (oldcop != PL_curcop)
983 {
984 oldcop = PL_curcop;
985
986 if (PL_curcop != &PL_compiling)
987 {
988 SV **cb;
989
990 if (oldcxix != cxstack_ix && cctx->flags & CC_TRACE_SUB)
991 {
992 PERL_CONTEXT *cx = &cxstack[cxstack_ix];
993
994 if (CxTYPE (cx) == CXt_SUB && oldcxix < cxstack_ix)
995 {
996 runops_proc_t old_runops = PL_runops;
997 dSP;
998 GV *gv = CvGV (cx->blk_sub.cv);
999 SV *fullname = sv_2mortal (newSV (0));
1000
1001 if (isGV (gv))
1002 gv_efullname3 (fullname, gv, 0);
1003
1004 PL_runops = RUNOPS_DEFAULT;
1005 ENTER;
1006 SAVETMPS;
1007 EXTEND (SP, 3);
1008 PUSHMARK (SP);
1009 PUSHs (&PL_sv_yes);
1010 PUSHs (fullname);
1011 PUSHs (CxHASARGS (cx) ? sv_2mortal (newRV_inc ((SV *)cx->blk_sub.argarray)) : &PL_sv_undef);
1012 PUTBACK;
1013 cb = hv_fetch ((HV *)SvRV (coro_current), "_trace_sub_cb", sizeof ("_trace_sub_cb") - 1, 0);
1014 if (cb) call_sv (*cb, G_KEEPERR | G_EVAL | G_VOID | G_DISCARD);
1015 SPAGAIN;
1016 FREETMPS;
1017 LEAVE;
1018 PL_runops = runops_trace;
1019 }
1020
1021 oldcxix = cxstack_ix;
1022 }
1023
1024 if (cctx->flags & CC_TRACE_LINE)
1025 {
1026 dSP;
1027
1028 PL_runops = RUNOPS_DEFAULT;
1029 ENTER;
1030 SAVETMPS;
1031 EXTEND (SP, 3);
1032 PL_runops = RUNOPS_DEFAULT;
1033 PUSHMARK (SP);
1034 PUSHs (sv_2mortal (newSVpv (OutCopFILE (oldcop), 0)));
1035 PUSHs (sv_2mortal (newSViv (CopLINE (oldcop))));
1036 PUTBACK;
1037 cb = hv_fetch ((HV *)SvRV (coro_current), "_trace_line_cb", sizeof ("_trace_line_cb") - 1, 0);
1038 if (cb) call_sv (*cb, G_KEEPERR | G_EVAL | G_VOID | G_DISCARD);
1039 SPAGAIN;
1040 FREETMPS;
1041 LEAVE;
1042 PL_runops = runops_trace;
1043 }
1044 }
1045 }
1046 }
1047 }
1048
1049 TAINT_NOT;
1050 return 0;
1051}
1052
1053static void
1054prepare_set_stacklevel (struct coro_transfer_args *ta, struct coro_cctx *cctx)
1055{
1056 ta->prev = (struct coro *)cctx;
1057 ta->next = 0;
1058}
1059
1060/* inject a fake call to Coro::State::_cctx_init into the execution */
1061/* _cctx_init should be careful, as it could be called at almost any time */
1062/* during execution of a perl program */
1063/* also initialises PL_top_env */
1064static void NOINLINE
1065cctx_prepare (pTHX_ coro_cctx *cctx)
1066{
1067 dSP;
1068 UNOP myop;
1069
1070 PL_top_env = &PL_start_env;
1071
1072 if (cctx->flags & CC_TRACE)
1073 PL_runops = runops_trace;
1074
1075 Zero (&myop, 1, UNOP);
1076 myop.op_next = PL_op;
1077 myop.op_flags = OPf_WANT_VOID | OPf_STACKED;
1078
1079 PUSHMARK (SP);
1080 EXTEND (SP, 2);
1081 PUSHs (sv_2mortal (newSViv ((IV)cctx)));
1082 PUSHs ((SV *)get_cv ("Coro::State::_cctx_init", FALSE));
1083 PUTBACK;
1084 PL_op = (OP *)&myop;
1085 PL_op = PL_ppaddr[OP_ENTERSUB](aTHX);
1086 SPAGAIN;
1087}
1088
1089/* the tail of transfer: execute stuff we can only do after a transfer */
1090INLINE void
1091transfer_tail (pTHX)
1092{
1093 struct coro *next = (struct coro *)transfer_next;
1094 assert (!(transfer_next = 0)); /* just used for the side effect when asserts are enabled */
1095 assert (("FATAL: next coroutine was zero in transfer_tail (please report)", next));
1096
1097 free_coro_mortal (aTHX);
1098 UNLOCK;
1099
1100 if (expect_false (next->throw))
1101 {
1102 SV *exception = sv_2mortal (next->throw);
1103
1104 next->throw = 0;
1105 sv_setsv (ERRSV, exception);
1106 croak (0);
1107 }
1108}
1109
1110/*
1111 * this is a _very_ stripped down perl interpreter ;)
1112 */
1113static void
1114cctx_run (void *arg)
1115{
1116#ifdef USE_ITHREADS
1117# if CORO_PTHREAD
1118 PERL_SET_CONTEXT (coro_thx);
1119# endif
1120#endif
1121 {
1122 dTHX;
1123
1124 /* normally we would need to skip the entersub here */
1125 /* not doing so will re-execute it, which is exactly what we want */
1126 /* PL_nop = PL_nop->op_next */
1127
1128 /* inject a fake subroutine call to cctx_init */
1129 cctx_prepare (aTHX_ (coro_cctx *)arg);
1130
1131 /* cctx_run is the alternative tail of transfer() */
1132 /* TODO: throwing an exception here might be deadly, VERIFY */
1133 transfer_tail (aTHX);
1134
1135 /* somebody or something will hit me for both perl_run and PL_restartop */
1136 PL_restartop = PL_op;
1137 perl_run (PL_curinterp);
1138
1139 /*
1140 * If perl-run returns we assume exit() was being called or the coro
1141 * fell off the end, which seems to be the only valid (non-bug)
1142 * reason for perl_run to return. We try to exit by jumping to the
1143 * bootstrap-time "top" top_env, as we cannot restore the "main"
1144 * coroutine as Coro has no such concept
1145 */
1146 PL_top_env = main_top_env;
1147 JMPENV_JUMP (2); /* I do not feel well about the hardcoded 2 at all */
1148 }
1149}
1150
1151static coro_cctx *
1152cctx_new ()
1153{
1154 coro_cctx *cctx;
1155
1156 ++cctx_count;
1157 New (0, cctx, 1, coro_cctx);
1158
1159 cctx->gen = cctx_gen;
1160 cctx->flags = 0;
1161 cctx->idle_sp = 0; /* can be accessed by transfer between cctx_run and set_stacklevel, on throw */
1162
1163 return cctx;
1164}
1165
1166/* create a new cctx only suitable as source */
1167static coro_cctx *
1168cctx_new_empty ()
1169{
1170 coro_cctx *cctx = cctx_new ();
1171
1172 cctx->sptr = 0;
1173 coro_create (&cctx->cctx, 0, 0, 0, 0);
1174
1175 return cctx;
1176}
1177
1178/* create a new cctx suitable as destination/running a perl interpreter */
1179static coro_cctx *
1180cctx_new_run ()
1181{
1182 coro_cctx *cctx = cctx_new ();
1183 void *stack_start;
1184 size_t stack_size;
1185
1186#if HAVE_MMAP
1187 cctx->ssize = ((cctx_stacksize * sizeof (long) + PAGESIZE - 1) / PAGESIZE + CORO_STACKGUARD) * PAGESIZE;
1188 /* mmap supposedly does allocate-on-write for us */
1189 cctx->sptr = mmap (0, cctx->ssize, PROT_EXEC|PROT_READ|PROT_WRITE, MAP_PRIVATE|MAP_ANONYMOUS, 0, 0);
1190
1191 if (cctx->sptr != (void *)-1)
1192 {
1193 #if CORO_STACKGUARD
1194 mprotect (cctx->sptr, CORO_STACKGUARD * PAGESIZE, PROT_NONE);
1195 #endif
1196 stack_start = (char *)cctx->sptr + CORO_STACKGUARD * PAGESIZE;
1197 stack_size = cctx->ssize - CORO_STACKGUARD * PAGESIZE;
1198 cctx->flags |= CC_MAPPED;
1199 }
1200 else
1201#endif
1202 {
1203 cctx->ssize = cctx_stacksize * (long)sizeof (long);
1204 New (0, cctx->sptr, cctx_stacksize, long);
1205
1206 if (!cctx->sptr)
1207 {
1208 perror ("FATAL: unable to allocate stack for coroutine, exiting.");
1209 _exit (EXIT_FAILURE);
1210 }
1211
1212 stack_start = cctx->sptr;
1213 stack_size = cctx->ssize;
1214 }
1215
1216 #if CORO_USE_VALGRIND
1217 cctx->valgrind_id = VALGRIND_STACK_REGISTER ((char *)stack_start, (char *)stack_start + stack_size);
1218 #endif
1219
1220 coro_create (&cctx->cctx, cctx_run, (void *)cctx, stack_start, stack_size);
1221
1222 return cctx;
1223}
1224
1225static void
1226cctx_destroy (coro_cctx *cctx)
1227{
1228 if (!cctx)
1229 return;
1230
1231 --cctx_count;
1232 coro_destroy (&cctx->cctx);
1233
1234 /* coro_transfer creates new, empty cctx's */
1235 if (cctx->sptr)
1236 {
1237 #if CORO_USE_VALGRIND
1238 VALGRIND_STACK_DEREGISTER (cctx->valgrind_id);
1239 #endif
1240
1241#if HAVE_MMAP
1242 if (cctx->flags & CC_MAPPED)
1243 munmap (cctx->sptr, cctx->ssize);
1244 else
1245#endif
1246 Safefree (cctx->sptr);
1247 }
1248
1249 Safefree (cctx);
1250}
1251
1252/* wether this cctx should be destructed */
1253#define CCTX_EXPIRED(cctx) ((cctx)->gen != cctx_gen || ((cctx)->flags & CC_NOREUSE))
1254
1255static coro_cctx *
1256cctx_get (pTHX)
1257{
1258 while (expect_true (cctx_first))
1259 {
1260 coro_cctx *cctx = cctx_first;
1261 cctx_first = cctx->next;
1262 --cctx_idle;
1263
1264 if (expect_true (!CCTX_EXPIRED (cctx)))
1265 return cctx;
1266
1267 cctx_destroy (cctx);
1268 }
1269
1270 return cctx_new_run ();
1271}
1272
1273static void
1274cctx_put (coro_cctx *cctx)
1275{
1276 assert (("FATAL: cctx_put called on non-initialised cctx in Coro (please report)", cctx->sptr));
1277
1278 /* free another cctx if overlimit */
1279 if (expect_false (cctx_idle >= cctx_max_idle))
1280 {
1281 coro_cctx *first = cctx_first;
1282 cctx_first = first->next;
1283 --cctx_idle;
1284
1285 cctx_destroy (first);
1286 }
1287
1288 ++cctx_idle;
1289 cctx->next = cctx_first;
1290 cctx_first = cctx;
1291}
1292
1293/** coroutine switching *****************************************************/
1294
1295static void
1296transfer_check (pTHX_ struct coro *prev, struct coro *next)
1297{
1298 if (expect_true (prev != next))
1299 {
1300 if (expect_false (!(prev->flags & (CF_RUNNING | CF_NEW))))
1301 croak ("Coro::State::transfer called with non-running/new prev Coro::State, but can only transfer from running or new states,");
1302
1303 if (expect_false (next->flags & CF_RUNNING))
1304 croak ("Coro::State::transfer called with running next Coro::State, but can only transfer to inactive states,");
1305
1306 if (expect_false (next->flags & CF_DESTROYED))
1307 croak ("Coro::State::transfer called with destroyed next Coro::State, but can only transfer to inactive states,");
1308
1309#if !PERL_VERSION_ATLEAST (5,10,0)
1310 if (expect_false (PL_lex_state != LEX_NOTPARSING))
1311 croak ("Coro::State::transfer called while parsing, but this is not supported in your perl version,");
1312#endif
1313 }
1314}
1315
1316/* always use the TRANSFER macro */
1317static void NOINLINE
1318transfer (pTHX_ struct coro *prev, struct coro *next, int force_cctx)
1319{
1320 dSTACKLEVEL;
1321
1322 /* sometimes transfer is only called to set idle_sp */
1323 if (expect_false (!next))
1324 {
1325 ((coro_cctx *)prev)->idle_sp = stacklevel;
1326 assert (((coro_cctx *)prev)->idle_te = PL_top_env); /* just for the side-effect when asserts are enabled */
1327 }
1328 else if (expect_true (prev != next))
1329 {
1330 coro_cctx *prev__cctx;
1331
1332 if (expect_false (prev->flags & CF_NEW))
1333 {
1334 /* create a new empty/source context */
1335 prev->cctx = cctx_new_empty ();
1336 prev->flags &= ~CF_NEW;
1337 prev->flags |= CF_RUNNING;
1338 }
1339
1340 prev->flags &= ~CF_RUNNING;
1341 next->flags |= CF_RUNNING;
1342
1343 LOCK;
1344
1345 /* first get rid of the old state */
1346 save_perl (aTHX_ prev);
1347
1348 if (expect_false (next->flags & CF_NEW))
1349 {
1350 /* need to start coroutine */
1351 next->flags &= ~CF_NEW;
1352 /* setup coroutine call */
1353 coro_setup (aTHX_ next);
1354 }
1355 else
1356 load_perl (aTHX_ next);
1357
1358 prev__cctx = prev->cctx;
1359
1360 /* possibly untie and reuse the cctx */
1361 if (expect_true (
1362 prev__cctx->idle_sp == stacklevel
1363 && !(prev__cctx->flags & CC_TRACE)
1364 && !force_cctx
1365 ))
1366 {
1367 /* I assume that stacklevel is a stronger indicator than PL_top_env changes */
1368 assert (("FATAL: current top_env must equal previous top_env in Coro (please report)", PL_top_env == prev__cctx->idle_te));
1369
1370 prev->cctx = 0;
1371
1372 /* if the cctx is about to be destroyed we need to make sure we won't see it in cctx_get */
1373 /* without this the next cctx_get might destroy the prev__cctx while still in use */
1374 if (expect_false (CCTX_EXPIRED (prev__cctx)))
1375 if (!next->cctx)
1376 next->cctx = cctx_get (aTHX);
1377
1378 cctx_put (prev__cctx);
1379 }
1380
1381 ++next->usecount;
1382
1383 if (expect_true (!next->cctx))
1384 next->cctx = cctx_get (aTHX);
1385
1386 assert (("FATAL: transfer_next already nonzero in Coro (please report)", !transfer_next));
1387 transfer_next = next;
1388
1389 if (expect_false (prev__cctx != next->cctx))
1390 {
1391 prev__cctx->top_env = PL_top_env;
1392 PL_top_env = next->cctx->top_env;
1393 coro_transfer (&prev__cctx->cctx, &next->cctx->cctx);
1394 }
1395
1396 transfer_tail (aTHX);
1397 }
1398}
1399
1400#define TRANSFER(ta, force_cctx) transfer (aTHX_ (ta).prev, (ta).next, (force_cctx))
1401#define TRANSFER_CHECK(ta) transfer_check (aTHX_ (ta).prev, (ta).next)
1402
1403/** high level stuff ********************************************************/
1404
1405static int
1406coro_state_destroy (pTHX_ struct coro *coro)
1407{
1408 if (coro->flags & CF_DESTROYED)
1409 return 0;
1410
1411 coro->flags |= CF_DESTROYED;
1412
1413 if (coro->flags & CF_READY)
1414 {
1415 /* reduce nready, as destroying a ready coro effectively unreadies it */
1416 /* alternative: look through all ready queues and remove the coro */
1417 LOCK;
1418 --coro_nready;
1419 UNLOCK;
1420 }
1421 else
1422 coro->flags |= CF_READY; /* make sure it is NOT put into the readyqueue */
1423
1424 if (coro->mainstack && coro->mainstack != main_mainstack)
1425 {
1426 struct coro temp;
1427
1428 assert (("FATAL: tried to destroy currently running coroutine (please report)", !(coro->flags & CF_RUNNING)));
1429
1430 save_perl (aTHX_ &temp);
1431 load_perl (aTHX_ coro);
1432
1433 coro_destruct (aTHX_ coro);
1434
1435 load_perl (aTHX_ &temp);
1436
1437 coro->slot = 0;
1438 }
1439
1440 cctx_destroy (coro->cctx);
1441 SvREFCNT_dec (coro->args);
1442
1443 if (coro->next) coro->next->prev = coro->prev;
1444 if (coro->prev) coro->prev->next = coro->next;
1445 if (coro == coro_first) coro_first = coro->next;
1446
1447 return 1;
1448}
1449
1450static int
1451coro_state_free (pTHX_ SV *sv, MAGIC *mg)
1452{
1453 struct coro *coro = (struct coro *)mg->mg_ptr;
1454 mg->mg_ptr = 0;
1455
1456 coro->hv = 0;
1457
1458 if (--coro->refcnt < 0)
1459 {
1460 coro_state_destroy (aTHX_ coro);
1461 Safefree (coro);
1462 }
1463
1464 return 0;
1465}
1466
1467static int
1468coro_state_dup (pTHX_ MAGIC *mg, CLONE_PARAMS *params)
1469{
1470 struct coro *coro = (struct coro *)mg->mg_ptr;
1471
1472 ++coro->refcnt;
1473
1474 return 0;
1475}
1476
1477static MGVTBL coro_state_vtbl = {
1478 0, 0, 0, 0,
1479 coro_state_free,
1480 0,
1481#ifdef MGf_DUP
1482 coro_state_dup,
1483#else
1484# define MGf_DUP 0
1485#endif
1486};
1487
1488static void
1489prepare_transfer (pTHX_ struct coro_transfer_args *ta, SV *prev_sv, SV *next_sv)
1490{
1491 ta->prev = SvSTATE (prev_sv);
1492 ta->next = SvSTATE (next_sv);
1493 TRANSFER_CHECK (*ta);
1494}
1495
1496static void
1497api_transfer (pTHX_ SV *prev_sv, SV *next_sv)
1498{
1499 struct coro_transfer_args ta;
1500
1501 prepare_transfer (aTHX_ &ta, prev_sv, next_sv);
1502 TRANSFER (ta, 1);
1503}
1504
1505/** Coro ********************************************************************/
1506
1507static void
1508coro_enq (pTHX_ SV *coro_sv)
1509{
1510 av_push (coro_ready [SvSTATE (coro_sv)->prio - PRIO_MIN], coro_sv);
1511}
1512
1513static SV *
1514coro_deq (pTHX)
1515{
1516 int prio;
1517
1518 for (prio = PRIO_MAX - PRIO_MIN + 1; --prio >= 0; )
1519 if (AvFILLp (coro_ready [prio]) >= 0)
1520 return av_shift (coro_ready [prio]);
1521
1522 return 0;
1523}
1524
1525static int
1526api_ready (pTHX_ SV *coro_sv)
1527{
1528 struct coro *coro;
1529 SV *sv_hook;
1530 void (*xs_hook)(void);
1531
1532 if (SvROK (coro_sv))
1533 coro_sv = SvRV (coro_sv);
1534
1535 coro = SvSTATE (coro_sv);
1536
1537 if (coro->flags & CF_READY)
1538 return 0;
1539
1540 coro->flags |= CF_READY;
1541
1542 LOCK;
1543
1544 sv_hook = coro_nready ? 0 : coro_readyhook;
1545 xs_hook = coro_nready ? 0 : coroapi.readyhook;
1546
1547 coro_enq (aTHX_ SvREFCNT_inc_NN (coro_sv));
1548 ++coro_nready;
1549
1550 UNLOCK;
1551
1552 if (sv_hook)
1553 {
1554 dSP;
1555
1556 ENTER;
1557 SAVETMPS;
1558
1559 PUSHMARK (SP);
1560 PUTBACK;
1561 call_sv (sv_hook, G_DISCARD);
1562 SPAGAIN;
1563
1564 FREETMPS;
1565 LEAVE;
1566 }
1567
1568 if (xs_hook)
1569 xs_hook ();
1570
1571 return 1;
1572}
1573
1574static int
1575api_is_ready (pTHX_ SV *coro_sv)
1576{
1577 return !!(SvSTATE (coro_sv)->flags & CF_READY);
1578}
1579
1580INLINE void
1581prepare_schedule (pTHX_ struct coro_transfer_args *ta)
1582{
1583 SV *prev_sv, *next_sv;
1584
1585 for (;;)
1586 {
1587 LOCK;
1588 next_sv = coro_deq (aTHX);
1589
1590 /* nothing to schedule: call the idle handler */
1591 if (expect_false (!next_sv))
1592 {
1593 dSP;
1594 UNLOCK;
1595
1596 ENTER;
1597 SAVETMPS;
1598
1599 PUSHMARK (SP);
1600 PUTBACK;
1601 call_sv (get_sv ("Coro::idle", FALSE), G_DISCARD);
1602 SPAGAIN;
1603
1604 FREETMPS;
1605 LEAVE;
1606 continue;
1607 }
1608
1609 ta->next = SvSTATE (next_sv);
1610
1611 /* cannot transfer to destroyed coros, skip and look for next */
1612 if (expect_false (ta->next->flags & CF_DESTROYED))
1613 {
1614 UNLOCK;
1615 SvREFCNT_dec (next_sv);
1616 /* coro_nready has already been taken care of by destroy */
1617 continue;
1618 }
1619
1620 --coro_nready;
1621 UNLOCK;
1622 break;
1623 }
1624
1625 /* free this only after the transfer */
1626 prev_sv = SvRV (coro_current);
1627 ta->prev = SvSTATE (prev_sv);
1628 TRANSFER_CHECK (*ta);
1629 assert (("FATAL: next coroutine isn't marked as ready in Coro (please report)", ta->next->flags & CF_READY));
1630 ta->next->flags &= ~CF_READY;
1631 SvRV_set (coro_current, next_sv);
1632
1633 LOCK;
1634 free_coro_mortal (aTHX);
1635 coro_mortal = prev_sv;
1636 UNLOCK;
1637}
1638
1639INLINE void
1640prepare_cede (pTHX_ struct coro_transfer_args *ta)
1641{
1642 api_ready (aTHX_ coro_current);
1643 prepare_schedule (aTHX_ ta);
1644}
1645
1646INLINE void
1647prepare_cede_notself (pTHX_ struct coro_transfer_args *ta)
1648{
1649 SV *prev = SvRV (coro_current);
1650
1651 if (coro_nready)
1652 {
1653 prepare_schedule (aTHX_ ta);
1654 api_ready (aTHX_ prev);
1655 }
1656 else
1657 prepare_nop (aTHX_ ta);
1658}
1659
1660static void
1661api_schedule (pTHX)
1662{
1663 struct coro_transfer_args ta;
1664
1665 prepare_schedule (aTHX_ &ta);
1666 TRANSFER (ta, 1);
1667}
1668
1669static int
1670api_cede (pTHX)
1671{
1672 struct coro_transfer_args ta;
1673
1674 prepare_cede (aTHX_ &ta);
1675
1676 if (expect_true (ta.prev != ta.next))
1677 {
1678 TRANSFER (ta, 1);
1679 return 1;
1680 }
1681 else
1682 return 0;
1683}
1684
1685static int
1686api_cede_notself (pTHX)
1687{
1688 if (coro_nready)
1689 {
1690 struct coro_transfer_args ta;
1691
1692 prepare_cede_notself (aTHX_ &ta);
1693 TRANSFER (ta, 1);
1694 return 1;
1695 }
1696 else
1697 return 0;
1698}
1699
1700static void
1701api_trace (pTHX_ SV *coro_sv, int flags)
1702{
1703 struct coro *coro = SvSTATE (coro_sv);
1704
1705 if (flags & CC_TRACE)
1706 {
1707 if (!coro->cctx)
1708 coro->cctx = cctx_new_run ();
1709 else if (!(coro->cctx->flags & CC_TRACE))
1710 croak ("cannot enable tracing on coroutine with custom stack,");
1711
1712 coro->cctx->flags |= CC_NOREUSE | (flags & (CC_TRACE | CC_TRACE_ALL));
1713 }
1714 else if (coro->cctx && coro->cctx->flags & CC_TRACE)
1715 {
1716 coro->cctx->flags &= ~(CC_TRACE | CC_TRACE_ALL);
1717
1718 if (coro->flags & CF_RUNNING)
1719 PL_runops = RUNOPS_DEFAULT;
1720 else
1721 coro->slot->runops = RUNOPS_DEFAULT;
1722 }
1723}
1724
1725#if 0
1726static int
1727coro_gensub_free (pTHX_ SV *sv, MAGIC *mg)
1728{
1729 AV *padlist;
1730 AV *av = (AV *)mg->mg_obj;
1731
1732 abort ();
1733
1734 return 0;
1735}
1736
1737static MGVTBL coro_gensub_vtbl = {
1738 0, 0, 0, 0,
1739 coro_gensub_free
1740};
1741#endif
1742
1743/*****************************************************************************/
1744/* PerlIO::cede */
1745
1746typedef struct
1747{
1748 PerlIOBuf base;
1749 NV next, every;
1750} PerlIOCede;
1751
1752static IV
1753PerlIOCede_pushed (pTHX_ PerlIO *f, const char *mode, SV *arg, PerlIO_funcs *tab)
1754{
1755 PerlIOCede *self = PerlIOSelf (f, PerlIOCede);
1756
1757 self->every = SvCUR (arg) ? SvNV (arg) : 0.01;
1758 self->next = nvtime () + self->every;
1759
1760 return PerlIOBuf_pushed (aTHX_ f, mode, Nullsv, tab);
1761}
1762
1763static SV *
1764PerlIOCede_getarg (pTHX_ PerlIO *f, CLONE_PARAMS *param, int flags)
1765{
1766 PerlIOCede *self = PerlIOSelf (f, PerlIOCede);
1767
1768 return newSVnv (self->every);
1769}
1770
1771static IV
1772PerlIOCede_flush (pTHX_ PerlIO *f)
1773{
1774 PerlIOCede *self = PerlIOSelf (f, PerlIOCede);
1775 double now = nvtime ();
1776
1777 if (now >= self->next)
1778 {
1779 api_cede (aTHX);
1780 self->next = now + self->every;
1781 }
1782
1783 return PerlIOBuf_flush (aTHX_ f);
1784}
1785
1786static PerlIO_funcs PerlIO_cede =
1787{
1788 sizeof(PerlIO_funcs),
1789 "cede",
1790 sizeof(PerlIOCede),
1791 PERLIO_K_DESTRUCT | PERLIO_K_RAW,
1792 PerlIOCede_pushed,
1793 PerlIOBuf_popped,
1794 PerlIOBuf_open,
1795 PerlIOBase_binmode,
1796 PerlIOCede_getarg,
1797 PerlIOBase_fileno,
1798 PerlIOBuf_dup,
1799 PerlIOBuf_read,
1800 PerlIOBuf_unread,
1801 PerlIOBuf_write,
1802 PerlIOBuf_seek,
1803 PerlIOBuf_tell,
1804 PerlIOBuf_close,
1805 PerlIOCede_flush,
1806 PerlIOBuf_fill,
1807 PerlIOBase_eof,
1808 PerlIOBase_error,
1809 PerlIOBase_clearerr,
1810 PerlIOBase_setlinebuf,
1811 PerlIOBuf_get_base,
1812 PerlIOBuf_bufsiz,
1813 PerlIOBuf_get_ptr,
1814 PerlIOBuf_get_cnt,
1815 PerlIOBuf_set_ptrcnt,
1816};
1817
1818/*****************************************************************************/
1819
1820static const CV *slf_cv; /* for quick consistency check */
1821
1822static UNOP slf_restore; /* restore stack as entersub did, for first-re-run */
1823static SV *slf_arg0;
1824static SV *slf_arg1;
1825static SV *slf_arg2;
1826
1827/* this restores the stack in the case we patched the entersub, to */
1828/* recreate the stack frame as perl will on following calls */
1829/* since entersub cleared the stack */
1830static OP *
1831pp_restore (pTHX)
1832{
1833 dSP;
1834
1835 PUSHMARK (SP);
1836
1837 EXTEND (SP, 3);
1838 if (slf_arg0) PUSHs (sv_2mortal (slf_arg0));
1839 if (slf_arg1) PUSHs (sv_2mortal (slf_arg1));
1840 if (slf_arg2) PUSHs (sv_2mortal (slf_arg2));
1841 PUSHs ((SV *)CvGV (slf_cv));
1842
1843 RETURNOP (slf_restore.op_first);
1844}
1845
1846static void
1847slf_prepare_set_stacklevel (pTHX_ struct coro_transfer_args *ta)
1848{
1849 prepare_set_stacklevel (ta, (struct coro_cctx *)slf_frame.data);
1850}
1851
1852static void
1853slf_init_set_stacklevel (pTHX_ struct CoroSLF *frame, SV **arg, int items)
1854{
1855 assert (("FATAL: set_stacklevel needs the coro cctx as sole argument", items == 1));
1856
1857 frame->prepare = slf_prepare_set_stacklevel;
1858 frame->check = slf_check_nop;
1859 frame->data = (void *)SvIV (arg [0]);
1860}
1861
1862static void
1863slf_prepare_transfer (pTHX_ struct coro_transfer_args *ta)
1864{
1865 SV **arg = (SV **)slf_frame.data;
1866
1867 prepare_transfer (ta, arg [0], arg [1]);
1868}
1869
1870static void
1871slf_init_transfer (pTHX_ struct CoroSLF *frame, SV **arg, int items)
1872{
1873 if (items != 2)
1874 croak ("Coro::State::transfer (prev, next) expects two arguments, not %d,", items);
1875
1876 frame->prepare = slf_prepare_transfer;
1877 frame->check = slf_check_nop;
1878 frame->data = (void *)arg; /* let's hope it will stay valid */
1879}
1880
1881static void
1882slf_init_schedule (pTHX_ struct CoroSLF *frame, SV **arg, int items)
1883{
1884 frame->prepare = prepare_schedule;
1885 frame->check = slf_check_nop;
1886}
1887
1888static void
1889slf_init_cede (pTHX_ struct CoroSLF *frame, SV **arg, int items)
1890{
1891 frame->prepare = prepare_cede;
1892 frame->check = slf_check_nop;
1893}
1894
1895static void
1896slf_init_cede_notself (pTHX_ struct CoroSLF *frame, SV **arg, int items)
1897{
1898 frame->prepare = prepare_cede_notself;
1899 frame->check = slf_check_nop;
1900}
1901
1902/* we hijack an hopefully unused CV flag for our purposes */
1903#define CVf_SLF 0x4000
1904
1905/*
1906 * these not obviously related functions are all rolled into one
1907 * function to increase chances that they all will call transfer with the same
1908 * stack offset
1909 * SLF stands for "schedule-like-function".
1910 */
1911static OP *
1912pp_slf (pTHX)
1913{
1914 I32 checkmark; /* mark SP to see how many elements check has pushed */
1915
1916 /* set up the slf frame, unless it has already been set-up */
1917 /* the latter happens when a new coro has been started */
1918 /* or when a new cctx was attached to an existing coroutine */
1919 if (expect_true (!slf_frame.prepare))
1920 {
1921 /* first iteration */
1922 dSP;
1923 SV **arg = PL_stack_base + TOPMARK + 1;
1924 int items = SP - arg; /* args without function object */
1925 SV *gv = *sp;
1926
1927 /* do a quick consistency check on the "function" object, and if it isn't */
1928 /* for us, divert to the real entersub */
1929 if (SvTYPE (gv) != SVt_PVGV || !(CvFLAGS (GvCV (gv)) & CVf_SLF))
1930 return PL_ppaddr[OP_ENTERSUB](aTHX);
1931
1932 /* pop args */
1933 SP = PL_stack_base + POPMARK;
1934
1935 if (!(PL_op->op_flags & OPf_STACKED))
1936 {
1937 /* ampersand-form of call, use @_ instead of stack */
1938 AV *av = GvAV (PL_defgv);
1939 arg = AvARRAY (av);
1940 items = AvFILLp (av) + 1;
1941 }
1942
1943 PUTBACK;
1944
1945 ((coro_slf_cb)CvXSUBANY (GvCV (gv)).any_ptr) (aTHX_ &slf_frame, arg, items);
1946 }
1947
1948 /* now interpret the slf_frame */
1949 /* we use a callback system not to make the code needlessly */
1950 /* complicated, but so we can run multiple perl coros from one cctx */
1951
1952 do
1953 {
1954 struct coro_transfer_args ta;
1955
1956 slf_frame.prepare (aTHX_ &ta);
1957 TRANSFER (ta, 0);
1958
1959 checkmark = PL_stack_sp - PL_stack_base;
1960 }
1961 while (slf_frame.check (aTHX_ &slf_frame));
1962
1963 {
1964 dSP;
1965 SV **bot = PL_stack_base + checkmark;
1966 int gimme = GIMME_V;
1967
1968 slf_frame.prepare = 0; /* signal pp_slf that we need a new frame */
1969
1970 /* make sure we put something on the stack in scalar context */
1971 if (gimme == G_SCALAR)
1972 {
1973 if (sp == bot)
1974 XPUSHs (&PL_sv_undef);
1975
1976 SP = bot + 1;
1977 }
1978
1979 PUTBACK;
1980 }
1981
1982 return NORMAL;
1983}
1984
1985static void
1986api_execute_slf (pTHX_ CV *cv, coro_slf_cb init_cb, SV **arg, int items)
1987{
1988 assert (("FATAL: SLF call with illegal CV value", !CvANON (cv)));
1989
1990 if (PL_op->op_ppaddr != PL_ppaddr [OP_ENTERSUB]
1991 && PL_op->op_ppaddr != pp_slf)
1992 croak ("FATAL: Coro SLF calls can only be made normally, not via goto or any other means, caught");
1993
1994 if (items > 3)
1995 croak ("Coro only supports up to three arguments to SLF functions currently (not %d), caught", items);
1996
1997 CvFLAGS (cv) |= CVf_SLF;
1998 CvXSUBANY (cv).any_ptr = (void *)init_cb;
1999 slf_cv = cv;
2000
2001 /* we patch the op, and then re-run the whole call */
2002 /* we have to put the same argument on the stack for this to work */
2003 /* and this will be done by pp_restore */
2004 slf_restore.op_next = (OP *)&slf_restore;
2005 slf_restore.op_type = OP_NULL;
2006 slf_restore.op_ppaddr = pp_restore;
2007 slf_restore.op_first = PL_op;
2008
2009 slf_arg0 = items > 0 ? SvREFCNT_inc (arg [0]) : 0;
2010 slf_arg1 = items > 1 ? SvREFCNT_inc (arg [1]) : 0;
2011 slf_arg2 = items > 2 ? SvREFCNT_inc (arg [2]) : 0;
2012
2013 PL_op->op_ppaddr = pp_slf;
2014
2015 PL_op = (OP *)&slf_restore;
2016}
2017
2018/*****************************************************************************/
2019
2020static int
2021slf_check_semaphore_down (pTHX_ struct CoroSLF *frame)
2022{
2023 AV *av = (AV *)frame->data;
2024 SV *count_sv = AvARRAY (av)[0];
2025
2026 if (SvIVX (count_sv) > 0)
2027 {
2028 SvIVX (count_sv) = SvIVX (count_sv) - 1;
2029 return 0;
2030 }
2031 else
2032 {
2033 int i;
2034 /* if we were woken up but can't down, we look through the whole */
2035 /* waiters list and only add us if we aren't in there already */
2036 /* this avoids some degenerate memory usage cases */
2037
2038 for (i = 1; i <= AvFILLp (av); ++i)
2039 if (AvARRAY (av)[i] == SvRV (coro_current))
2040 return 1;
2041
2042 av_push (av, SvREFCNT_inc (SvRV (coro_current)));
2043 return 1;
2044 }
2045}
2046
2047static void
2048slf_init_semaphore_down (pTHX_ struct CoroSLF *frame, SV **arg, int items)
2049{
2050 AV *av = (AV *)SvRV (arg [0]);
2051
2052 if (SvIVX (AvARRAY (av)[0]) > 0)
2053 {
2054 frame->data = (void *)av;
2055 frame->prepare = prepare_nop;
2056 }
2057 else
2058 {
2059 av_push (av, SvREFCNT_inc (SvRV (coro_current)));
2060
2061 frame->data = (void *)sv_2mortal (SvREFCNT_inc ((SV *)av));
2062 frame->prepare = prepare_schedule;
2063 }
2064
2065 frame->check = slf_check_semaphore_down;
2066
2067}
2068
2069MODULE = Coro::State PACKAGE = Coro::State PREFIX = api_
2070
2071PROTOTYPES: DISABLE
2072
2073BOOT:
2074{
2075#ifdef USE_ITHREADS
2076 MUTEX_INIT (&coro_lock);
2077# if CORO_PTHREAD
2078 coro_thx = PERL_GET_CONTEXT;
2079# endif
2080#endif
2081 BOOT_PAGESIZE;
2082
2083 irsgv = gv_fetchpv ("/" , GV_ADD|GV_NOTQUAL, SVt_PV);
2084 stdoutgv = gv_fetchpv ("STDOUT", GV_ADD|GV_NOTQUAL, SVt_PVIO);
2085
2086 orig_sigelem_get = PL_vtbl_sigelem.svt_get; PL_vtbl_sigelem.svt_get = coro_sigelem_get;
2087 orig_sigelem_set = PL_vtbl_sigelem.svt_set; PL_vtbl_sigelem.svt_set = coro_sigelem_set;
2088 orig_sigelem_clr = PL_vtbl_sigelem.svt_clear; PL_vtbl_sigelem.svt_clear = coro_sigelem_clr;
2089
2090 hv_sig = coro_get_hv (aTHX_ "SIG", TRUE);
2091 rv_diehook = newRV_inc ((SV *)gv_fetchpv ("Coro::State::diehook" , 0, SVt_PVCV));
2092 rv_warnhook = newRV_inc ((SV *)gv_fetchpv ("Coro::State::warnhook", 0, SVt_PVCV));
2093
2094 coro_state_stash = gv_stashpv ("Coro::State", TRUE);
2095
2096 newCONSTSUB (coro_state_stash, "CC_TRACE" , newSViv (CC_TRACE));
2097 newCONSTSUB (coro_state_stash, "CC_TRACE_SUB" , newSViv (CC_TRACE_SUB));
2098 newCONSTSUB (coro_state_stash, "CC_TRACE_LINE", newSViv (CC_TRACE_LINE));
2099 newCONSTSUB (coro_state_stash, "CC_TRACE_ALL" , newSViv (CC_TRACE_ALL));
2100
2101 main_mainstack = PL_mainstack;
2102 main_top_env = PL_top_env;
2103
2104 while (main_top_env->je_prev)
2105 main_top_env = main_top_env->je_prev;
2106
2107 coroapi.ver = CORO_API_VERSION;
2108 coroapi.rev = CORO_API_REVISION;
2109
2110 coroapi.transfer = api_transfer;
2111
2112 coroapi.sv_state = SvSTATE_;
2113 coroapi.execute_slf = api_execute_slf;
2114 coroapi.prepare_nop = prepare_nop;
2115 coroapi.prepare_schedule = prepare_schedule;
2116 coroapi.prepare_cede = prepare_cede;
2117 coroapi.prepare_cede_notself = prepare_cede_notself;
2118
2119 {
2120 SV **svp = hv_fetch (PL_modglobal, "Time::NVtime", 12, 0);
2121
2122 if (!svp) croak ("Time::HiRes is required");
2123 if (!SvIOK (*svp)) croak ("Time::NVtime isn't a function pointer");
2124
2125 nvtime = INT2PTR (double (*)(), SvIV (*svp));
2126 }
2127
2128 assert (("PRIO_NORMAL must be 0", !PRIO_NORMAL));
2129}
2130
2131SV *
2132new (char *klass, ...)
2133 CODE:
2134{
2135 struct coro *coro;
2136 MAGIC *mg;
2137 HV *hv;
2138 int i;
2139
2140 Newz (0, coro, 1, struct coro);
2141 coro->args = newAV ();
2142 coro->flags = CF_NEW;
2143
2144 if (coro_first) coro_first->prev = coro;
2145 coro->next = coro_first;
2146 coro_first = coro;
2147
2148 coro->hv = hv = newHV ();
2149 mg = sv_magicext ((SV *)hv, 0, CORO_MAGIC_type_state, &coro_state_vtbl, (char *)coro, 0);
2150 mg->mg_flags |= MGf_DUP;
2151 RETVAL = sv_bless (newRV_noinc ((SV *)hv), gv_stashpv (klass, 1));
2152
2153 av_extend (coro->args, items - 1);
2154 for (i = 1; i < items; i++)
2155 av_push (coro->args, newSVsv (ST (i)));
2156}
2157 OUTPUT:
2158 RETVAL
2159
2160void
2161_set_stacklevel (...)
2162 CODE:
2163 api_execute_slf (aTHX_ cv, slf_init_set_stacklevel, &ST (0), items);
2164
2165void
2166transfer (...)
2167 CODE:
2168 api_execute_slf (aTHX_ cv, slf_init_transfer, &ST (0), items);
2169
2170bool
2171_destroy (SV *coro_sv)
2172 CODE:
2173 RETVAL = coro_state_destroy (aTHX_ SvSTATE (coro_sv));
2174 OUTPUT:
2175 RETVAL
2176
2177void
2178_exit (int code)
2179 PROTOTYPE: $
2180 CODE:
2181 _exit (code);
2182
2183int
2184cctx_stacksize (int new_stacksize = 0)
2185 PROTOTYPE: ;$
2186 CODE:
2187 RETVAL = cctx_stacksize;
2188 if (new_stacksize)
2189 {
2190 cctx_stacksize = new_stacksize;
2191 ++cctx_gen;
2192 }
2193 OUTPUT:
2194 RETVAL
2195
2196int
2197cctx_max_idle (int max_idle = 0)
2198 PROTOTYPE: ;$
2199 CODE:
2200 RETVAL = cctx_max_idle;
2201 if (max_idle > 1)
2202 cctx_max_idle = max_idle;
2203 OUTPUT:
2204 RETVAL
2205
2206int
2207cctx_count ()
2208 PROTOTYPE:
2209 CODE:
2210 RETVAL = cctx_count;
2211 OUTPUT:
2212 RETVAL
2213
2214int
2215cctx_idle ()
2216 PROTOTYPE:
2217 CODE:
2218 RETVAL = cctx_idle;
2219 OUTPUT:
2220 RETVAL
2221
2222void
2223list ()
2224 PROTOTYPE:
2225 PPCODE:
2226{
2227 struct coro *coro;
2228 for (coro = coro_first; coro; coro = coro->next)
2229 if (coro->hv)
2230 XPUSHs (sv_2mortal (newRV_inc ((SV *)coro->hv)));
2231}
2232
2233void
2234call (Coro::State coro, SV *coderef)
2235 ALIAS:
2236 eval = 1
2237 CODE:
2238{
2239 if (coro->mainstack && ((coro->flags & CF_RUNNING) || coro->slot))
2240 {
2241 struct coro temp;
2242
2243 if (!(coro->flags & CF_RUNNING))
235 { 2244 {
236 /* I never used formats, so how should I know how these are implemented? */ 2245 PUTBACK;
237 /* my bold guess is as a simple, plain sub... */ 2246 save_perl (aTHX_ &temp);
238 croak ("CXt_FORMAT not yet handled. Don't switch coroutines from within formats"); 2247 load_perl (aTHX_ coro);
2248 }
2249
2250 {
2251 dSP;
2252 ENTER;
2253 SAVETMPS;
2254 PUTBACK;
2255 PUSHSTACK;
2256 PUSHMARK (SP);
2257
2258 if (ix)
2259 eval_sv (coderef, 0);
2260 else
2261 call_sv (coderef, G_KEEPERR | G_EVAL | G_VOID | G_DISCARD);
2262
2263 POPSTACK;
2264 SPAGAIN;
2265 FREETMPS;
2266 LEAVE;
2267 PUTBACK;
2268 }
2269
2270 if (!(coro->flags & CF_RUNNING))
2271 {
2272 save_perl (aTHX_ coro);
2273 load_perl (aTHX_ &temp);
2274 SPAGAIN;
239 } 2275 }
240 } 2276 }
241
242 if (top_si->si_type == PERLSI_MAIN)
243 break;
244
245 top_si = top_si->si_prev;
246 ccstk = top_si->si_cxstack;
247 cxix = top_si->si_cxix;
248 }
249
250 PUTBACK;
251 }
252
253 c->dowarn = PL_dowarn;
254 c->defav = GvAV (PL_defgv);
255 c->curstackinfo = PL_curstackinfo;
256 c->curstack = PL_curstack;
257 c->mainstack = PL_mainstack;
258 c->stack_sp = PL_stack_sp;
259 c->op = PL_op;
260 c->curpad = PL_curpad;
261 c->stack_base = PL_stack_base;
262 c->stack_max = PL_stack_max;
263 c->tmps_stack = PL_tmps_stack;
264 c->tmps_floor = PL_tmps_floor;
265 c->tmps_ix = PL_tmps_ix;
266 c->tmps_max = PL_tmps_max;
267 c->markstack = PL_markstack;
268 c->markstack_ptr = PL_markstack_ptr;
269 c->markstack_max = PL_markstack_max;
270 c->scopestack = PL_scopestack;
271 c->scopestack_ix = PL_scopestack_ix;
272 c->scopestack_max = PL_scopestack_max;
273 c->savestack = PL_savestack;
274 c->savestack_ix = PL_savestack_ix;
275 c->savestack_max = PL_savestack_max;
276 c->retstack = PL_retstack;
277 c->retstack_ix = PL_retstack_ix;
278 c->retstack_max = PL_retstack_max;
279 c->curcop = PL_curcop;
280} 2277}
281 2278
282#define LOAD(state) do { load_state(aTHX_ state); SPAGAIN; } while (0) 2279SV *
283#define SAVE(state) do { PUTBACK; save_state(aTHX_ state); } while (0) 2280is_ready (Coro::State coro)
2281 PROTOTYPE: $
2282 ALIAS:
2283 is_ready = CF_READY
2284 is_running = CF_RUNNING
2285 is_new = CF_NEW
2286 is_destroyed = CF_DESTROYED
2287 CODE:
2288 RETVAL = boolSV (coro->flags & ix);
2289 OUTPUT:
2290 RETVAL
284 2291
285static void 2292void
286load_state(pTHX_ Coro__State c) 2293throw (Coro::State self, SV *throw = &PL_sv_undef)
287{ 2294 PROTOTYPE: $;$
288 PL_dowarn = c->dowarn; 2295 CODE:
289 GvAV (PL_defgv) = c->defav; 2296 SvREFCNT_dec (self->throw);
290 PL_curstackinfo = c->curstackinfo; 2297 self->throw = SvOK (throw) ? newSVsv (throw) : 0;
291 PL_curstack = c->curstack;
292 PL_mainstack = c->mainstack;
293 PL_stack_sp = c->stack_sp;
294 PL_op = c->op;
295 PL_curpad = c->curpad;
296 PL_stack_base = c->stack_base;
297 PL_stack_max = c->stack_max;
298 PL_tmps_stack = c->tmps_stack;
299 PL_tmps_floor = c->tmps_floor;
300 PL_tmps_ix = c->tmps_ix;
301 PL_tmps_max = c->tmps_max;
302 PL_markstack = c->markstack;
303 PL_markstack_ptr = c->markstack_ptr;
304 PL_markstack_max = c->markstack_max;
305 PL_scopestack = c->scopestack;
306 PL_scopestack_ix = c->scopestack_ix;
307 PL_scopestack_max = c->scopestack_max;
308 PL_savestack = c->savestack;
309 PL_savestack_ix = c->savestack_ix;
310 PL_savestack_max = c->savestack_max;
311 PL_retstack = c->retstack;
312 PL_retstack_ix = c->retstack_ix;
313 PL_retstack_max = c->retstack_max;
314 PL_curcop = c->curcop;
315 2298
2299void
2300api_trace (SV *coro, int flags = CC_TRACE | CC_TRACE_SUB)
2301 PROTOTYPE: $;$
2302 C_ARGS: aTHX_ coro, flags
2303
2304SV *
2305has_cctx (Coro::State coro)
2306 PROTOTYPE: $
2307 CODE:
2308 RETVAL = boolSV (!!coro->cctx);
2309 OUTPUT:
2310 RETVAL
2311
2312int
2313is_traced (Coro::State coro)
2314 PROTOTYPE: $
2315 CODE:
2316 RETVAL = (coro->cctx ? coro->cctx->flags : 0) & CC_TRACE_ALL;
2317 OUTPUT:
2318 RETVAL
2319
2320UV
2321rss (Coro::State coro)
2322 PROTOTYPE: $
2323 ALIAS:
2324 usecount = 1
2325 CODE:
2326 switch (ix)
316 { 2327 {
317 dSP; 2328 case 0: RETVAL = coro_rss (aTHX_ coro); break;
318 CV *cv; 2329 case 1: RETVAL = coro->usecount; break;
319
320 /* now do the ugly restore mess */
321 while ((cv = (CV *)POPs))
322 {
323 AV *padlist = (AV *)POPs;
324
325 put_padlist (cv);
326 CvPADLIST(cv) = padlist;
327 CvDEPTH(cv) = (I32)POPs;
328
329#ifdef USE_THREADS
330 CvOWNER(cv) = (struct perl_thread *)POPs;
331 error does not work either
332#endif
333 } 2330 }
2331 OUTPUT:
2332 RETVAL
334 2333
335 PUTBACK; 2334void
336 } 2335force_cctx ()
337} 2336 PROTOTYPE:
2337 CODE:
2338 struct coro *coro = SvSTATE (coro_current);
2339 coro->cctx->idle_sp = 0;
338 2340
339/* this is an EXACT copy of S_nuke_stacks in perl.c, which is unfortunately static */ 2341void
340STATIC void 2342swap_defsv (Coro::State self)
341destroy_stacks(pTHX) 2343 PROTOTYPE: $
342{ 2344 ALIAS:
343 /* die does this while calling POPSTACK, but I just don't see why. */ 2345 swap_defav = 1
344 /* OTOH, die does not have a memleak, but we do... */ 2346 CODE:
345 dounwind(-1); 2347 if (!self->slot)
2348 croak ("cannot swap state with coroutine that has no saved state,");
2349 else
2350 {
2351 SV **src = ix ? (SV **)&GvAV (PL_defgv) : &GvSV (PL_defgv);
2352 SV **dst = ix ? (SV **)&self->slot->defav : (SV **)&self->slot->defsv;
346 2353
347 /* is this ugly, I ask? */ 2354 SV *tmp = *src; *src = *dst; *dst = tmp;
348 while (PL_scopestack_ix) 2355 }
349 LEAVE;
350 2356
351 while (PL_curstackinfo->si_next)
352 PL_curstackinfo = PL_curstackinfo->si_next;
353
354 while (PL_curstackinfo)
355 {
356 PERL_SI *p = PL_curstackinfo->si_prev;
357
358 SvREFCNT_dec(PL_curstackinfo->si_stack);
359 Safefree(PL_curstackinfo->si_cxstack);
360 Safefree(PL_curstackinfo);
361 PL_curstackinfo = p;
362 }
363
364 if (PL_scopestack_ix != 0)
365 Perl_warner(aTHX_ WARN_INTERNAL,
366 "Unbalanced scopes: %ld more ENTERs than LEAVEs\n",
367 (long)PL_scopestack_ix);
368 if (PL_savestack_ix != 0)
369 Perl_warner(aTHX_ WARN_INTERNAL,
370 "Unbalanced saves: %ld more saves than restores\n",
371 (long)PL_savestack_ix);
372 if (PL_tmps_floor != -1)
373 Perl_warner(aTHX_ WARN_INTERNAL,"Unbalanced tmps: %ld more allocs than frees\n",
374 (long)PL_tmps_floor + 1);
375 /*
376 */
377 Safefree(PL_tmps_stack);
378 Safefree(PL_markstack);
379 Safefree(PL_scopestack);
380 Safefree(PL_savestack);
381 Safefree(PL_retstack);
382}
383
384#define SUB_INIT "Coro::State::_newcoro"
385
386MODULE = Coro::State PACKAGE = Coro::State 2357MODULE = Coro::State PACKAGE = Coro
387
388PROTOTYPES: ENABLE
389 2358
390BOOT: 2359BOOT:
391 if (!padlist_cache) 2360{
392 padlist_cache = newHV (); 2361 int i;
393 2362
394Coro::State 2363 av_async_pool = coro_get_av (aTHX_ "Coro::async_pool", TRUE);
395_newprocess(args) 2364 sv_pool_rss = coro_get_sv (aTHX_ "Coro::POOL_RSS" , TRUE);
396 SV * args 2365 sv_pool_size = coro_get_sv (aTHX_ "Coro::POOL_SIZE" , TRUE);
2366
2367 coro_current = coro_get_sv (aTHX_ "Coro::current", FALSE);
2368 SvREADONLY_on (coro_current);
2369
2370 coro_stash = gv_stashpv ("Coro", TRUE);
2371
2372 newCONSTSUB (coro_stash, "PRIO_MAX", newSViv (PRIO_MAX));
2373 newCONSTSUB (coro_stash, "PRIO_HIGH", newSViv (PRIO_HIGH));
2374 newCONSTSUB (coro_stash, "PRIO_NORMAL", newSViv (PRIO_NORMAL));
2375 newCONSTSUB (coro_stash, "PRIO_LOW", newSViv (PRIO_LOW));
2376 newCONSTSUB (coro_stash, "PRIO_IDLE", newSViv (PRIO_IDLE));
2377 newCONSTSUB (coro_stash, "PRIO_MIN", newSViv (PRIO_MIN));
2378
2379 for (i = PRIO_MAX - PRIO_MIN + 1; i--; )
2380 coro_ready[i] = newAV ();
2381
2382 {
2383 SV *sv = coro_get_sv (aTHX_ "Coro::API", TRUE);
2384
2385 coroapi.schedule = api_schedule;
2386 coroapi.cede = api_cede;
2387 coroapi.cede_notself = api_cede_notself;
2388 coroapi.ready = api_ready;
2389 coroapi.is_ready = api_is_ready;
2390 coroapi.nready = coro_nready;
2391 coroapi.current = coro_current;
2392
2393 GCoroAPI = &coroapi;
2394 sv_setiv (sv, (IV)&coroapi);
2395 SvREADONLY_on (sv);
2396 }
2397}
2398
2399void
2400schedule (...)
2401 CODE:
2402 api_execute_slf (aTHX_ cv, slf_init_schedule, &ST (0), items);
2403
2404void
2405cede (...)
2406 CODE:
2407 api_execute_slf (aTHX_ cv, slf_init_cede, &ST (0), items);
2408
2409void
2410cede_notself (...)
2411 CODE:
2412 api_execute_slf (aTHX_ cv, slf_init_cede_notself, &ST (0), items);
2413
2414void
2415_set_current (SV *current)
397 PROTOTYPE: $ 2416 PROTOTYPE: $
2417 CODE:
2418 SvREFCNT_dec (SvRV (coro_current));
2419 SvRV_set (coro_current, SvREFCNT_inc_NN (SvRV (current)));
2420
2421void
2422_set_readyhook (SV *hook)
2423 PROTOTYPE: $
398 CODE: 2424 CODE:
399 Coro__State coro;
400
401 if (!SvROK (args) || SvTYPE (SvRV (args)) != SVt_PVAV)
402 croak ("Coro::State::newprocess expects an arrayref");
403 2425 LOCK;
404 New (0, coro, 1, struct coro); 2426 SvREFCNT_dec (coro_readyhook);
2427 coro_readyhook = SvOK (hook) ? newSVsv (hook) : 0;
2428 UNLOCK;
405 2429
406 coro->mainstack = 0; /* actual work is done inside transfer */ 2430int
407 coro->args = (AV *)SvREFCNT_inc (SvRV (args)); 2431prio (Coro::State coro, int newprio = 0)
408 2432 PROTOTYPE: $;$
2433 ALIAS:
2434 nice = 1
2435 CODE:
2436{
409 RETVAL = coro; 2437 RETVAL = coro->prio;
410 OUTPUT: 2438
2439 if (items > 1)
2440 {
2441 if (ix)
2442 newprio = coro->prio - newprio;
2443
2444 if (newprio < PRIO_MIN) newprio = PRIO_MIN;
2445 if (newprio > PRIO_MAX) newprio = PRIO_MAX;
2446
2447 coro->prio = newprio;
2448 }
2449}
2450 OUTPUT:
411 RETVAL 2451 RETVAL
412 2452
2453SV *
2454ready (SV *self)
2455 PROTOTYPE: $
2456 CODE:
2457 RETVAL = boolSV (api_ready (aTHX_ self));
2458 OUTPUT:
2459 RETVAL
2460
2461int
2462nready (...)
2463 PROTOTYPE:
2464 CODE:
2465 RETVAL = coro_nready;
2466 OUTPUT:
2467 RETVAL
2468
2469# for async_pool speedup
413void 2470void
414transfer(prev,next) 2471_pool_1 (SV *cb)
415 Coro::State_or_hashref prev 2472 CODE:
416 Coro::State_or_hashref next 2473{
2474 struct coro *coro = SvSTATE (coro_current);
2475 HV *hv = (HV *)SvRV (coro_current);
2476 AV *defav = GvAV (PL_defgv);
2477 SV *invoke = hv_delete (hv, "_invoke", sizeof ("_invoke") - 1, 0);
2478 AV *invoke_av;
2479 int i, len;
2480
2481 if (!invoke)
2482 {
2483 SV *old = PL_diehook;
2484 PL_diehook = 0;
2485 SvREFCNT_dec (old);
2486 croak ("\3async_pool terminate\2\n");
2487 }
2488
2489 SvREFCNT_dec (coro->saved_deffh);
2490 coro->saved_deffh = SvREFCNT_inc_NN ((SV *)PL_defoutgv);
2491
2492 hv_store (hv, "desc", sizeof ("desc") - 1,
2493 newSVpvn ("[async_pool]", sizeof ("[async_pool]") - 1), 0);
2494
2495 invoke_av = (AV *)SvRV (invoke);
2496 len = av_len (invoke_av);
2497
2498 sv_setsv (cb, AvARRAY (invoke_av)[0]);
2499
2500 if (len > 0)
2501 {
2502 av_fill (defav, len - 1);
2503 for (i = 0; i < len; ++i)
2504 av_store (defav, i, SvREFCNT_inc_NN (AvARRAY (invoke_av)[i + 1]));
2505 }
2506}
2507
2508void
2509_pool_2 (SV *cb)
2510 CODE:
2511{
2512 struct coro *coro = SvSTATE (coro_current);
2513
2514 sv_setsv (cb, &PL_sv_undef);
2515
2516 SvREFCNT_dec ((SV *)PL_defoutgv); PL_defoutgv = (GV *)coro->saved_deffh;
2517 coro->saved_deffh = 0;
2518
2519 if (coro_rss (aTHX_ coro) > SvUV (sv_pool_rss)
2520 || av_len (av_async_pool) + 1 >= SvIV (sv_pool_size))
2521 {
2522 SV *old = PL_diehook;
2523 PL_diehook = 0;
2524 SvREFCNT_dec (old);
2525 croak ("\3async_pool terminate\2\n");
2526 }
2527
2528 av_clear (GvAV (PL_defgv));
2529 hv_store ((HV *)SvRV (coro_current), "desc", sizeof ("desc") - 1,
2530 newSVpvn ("[async_pool idle]", sizeof ("[async_pool idle]") - 1), 0);
2531
2532 coro->prio = 0;
2533
2534 if (coro->cctx && (coro->cctx->flags & CC_TRACE))
2535 api_trace (aTHX_ coro_current, 0);
2536
2537 av_push (av_async_pool, newSVsv (coro_current));
2538}
2539
2540#if 0
2541
2542void
2543_generator_call (...)
2544 PROTOTYPE: @
2545 PPCODE:
2546 fprintf (stderr, "call %p\n", CvXSUBANY(cv).any_ptr);
2547 xxxx
2548 abort ();
2549
2550SV *
2551gensub (SV *sub, ...)
2552 PROTOTYPE: &;@
417 CODE: 2553 CODE:
2554{
2555 struct coro *coro;
2556 MAGIC *mg;
2557 CV *xcv;
2558 CV *ncv = (CV *)newSV_type (SVt_PVCV);
2559 int i;
418 2560
419 if (prev != next) 2561 CvGV (ncv) = CvGV (cv);
2562 CvFILE (ncv) = CvFILE (cv);
2563
2564 Newz (0, coro, 1, struct coro);
2565 coro->args = newAV ();
2566 coro->flags = CF_NEW;
2567
2568 av_extend (coro->args, items - 1);
2569 for (i = 1; i < items; i++)
2570 av_push (coro->args, newSVsv (ST (i)));
2571
2572 CvISXSUB_on (ncv);
2573 CvXSUBANY (ncv).any_ptr = (void *)coro;
2574
2575 xcv = GvCV (gv_fetchpv ("Coro::_generator_call", 0, SVt_PVCV));
2576
2577 CvXSUB (ncv) = CvXSUB (xcv);
2578 CvANON_on (ncv);
2579
2580 mg = sv_magicext ((SV *)ncv, 0, CORO_MAGIC_type_state, &coro_gensub_vtbl, (char *)coro, 0);
2581 RETVAL = newRV_noinc ((SV *)ncv);
2582}
2583 OUTPUT:
2584 RETVAL
2585
2586#endif
2587
2588
2589MODULE = Coro::State PACKAGE = Coro::AIO
2590
2591void
2592_get_state (SV *self)
2593 PROTOTYPE: $
2594 PPCODE:
2595{
2596 AV *defav = GvAV (PL_defgv);
2597 AV *av = newAV ();
2598 int i;
2599 SV *data_sv = newSV (sizeof (struct io_state));
2600 struct io_state *data = (struct io_state *)SvPVX (data_sv);
2601 SvCUR_set (data_sv, sizeof (struct io_state));
2602 SvPOK_only (data_sv);
2603
2604 data->errorno = errno;
2605 data->laststype = PL_laststype;
2606 data->laststatval = PL_laststatval;
2607 data->statcache = PL_statcache;
2608
2609 av_extend (av, AvFILLp (defav) + 1 + 1);
2610
2611 for (i = 0; i <= AvFILLp (defav); ++i)
2612 av_push (av, SvREFCNT_inc_NN (AvARRAY (defav)[i]));
2613
2614 av_push (av, data_sv);
2615
2616 XPUSHs (sv_2mortal (newRV_noinc ((SV *)av)));
2617
2618 api_ready (aTHX_ self);
2619}
2620
2621void
2622_set_state (SV *state)
2623 PROTOTYPE: $
2624 PPCODE:
2625{
2626 AV *av = (AV *)SvRV (state);
2627 struct io_state *data = (struct io_state *)SvPVX (AvARRAY (av)[AvFILLp (av)]);
2628 int i;
2629
2630 errno = data->errorno;
2631 PL_laststype = data->laststype;
2632 PL_laststatval = data->laststatval;
2633 PL_statcache = data->statcache;
2634
2635 EXTEND (SP, AvFILLp (av));
2636 for (i = 0; i < AvFILLp (av); ++i)
2637 PUSHs (sv_2mortal (SvREFCNT_inc_NN (AvARRAY (av)[i])));
2638}
2639
2640
2641MODULE = Coro::State PACKAGE = Coro::AnyEvent
2642
2643BOOT:
2644 sv_activity = coro_get_sv (aTHX_ "Coro::AnyEvent::ACTIVITY", TRUE);
2645
2646SV *
2647_schedule (...)
2648 CODE:
2649{
2650 static int incede;
2651
2652 api_cede_notself (aTHX);
2653
2654 ++incede;
2655 while (coro_nready >= incede && api_cede (aTHX))
2656 ;
2657
2658 sv_setsv (sv_activity, &PL_sv_undef);
2659 if (coro_nready >= incede)
420 { 2660 {
421 /* 2661 PUSHMARK (SP);
422 * this could be done in newprocess which would lead to 2662 PUTBACK;
423 * extremely elegant and fast (just SAVE/LOAD) 2663 call_pv ("Coro::AnyEvent::_activity", G_DISCARD | G_EVAL);
424 * code here, but lazy allocation of stacks has also 2664 SPAGAIN;
425 * some virtues and the overhead of the if() is nil.
426 */
427 if (next->mainstack)
428 {
429 SAVE (prev);
430 LOAD (next);
431 /* mark this state as in-use */
432 next->mainstack = 0;
433 next->tmps_ix = -2;
434 } 2665 }
435 else if (next->tmps_ix == -2) 2666
2667 --incede;
2668}
2669
2670
2671MODULE = Coro::State PACKAGE = PerlIO::cede
2672
2673BOOT:
2674 PerlIO_define_layer (aTHX_ &PerlIO_cede);
2675
2676MODULE = Coro::State PACKAGE = Coro::Semaphore
2677
2678SV *
2679new (SV *klass, SV *count_ = 0)
2680 CODE:
2681{
2682 /* a semaphore contains a counter IV in $sem->[0] and any waiters after that */
2683 AV *av = newAV ();
2684 av_push (av, newSViv (count_ && SvOK (count_) ? SvIV (count_) : 1));
2685 RETVAL = sv_bless (newRV_noinc ((SV *)av), GvSTASH (CvGV (cv)));
2686}
2687 OUTPUT:
2688 RETVAL
2689
2690SV *
2691count (SV *self)
2692 CODE:
2693 RETVAL = newSVsv (AvARRAY ((AV *)SvRV (self))[0]);
2694 OUTPUT:
2695 RETVAL
2696
2697void
2698up (SV *self, int adjust = 1)
2699 ALIAS:
2700 adjust = 1
2701 CODE:
2702{
2703 AV *av = (AV *)SvRV (self);
2704 SV *count_sv = AvARRAY (av)[0];
2705 IV count = SvIVX (count_sv);
2706
2707 count += ix ? adjust : 1;
2708 SvIVX (count_sv) = count;
2709
2710 /* now wake up as many waiters as possible */
2711 while (count > 0 && AvFILLp (av) >= count)
436 { 2712 {
437 croak ("tried to transfer to running coroutine"); 2713 SV *cb;
438 } 2714
2715 /* swap first two elements so we can shift a waiter */
2716 AvARRAY (av)[0] = AvARRAY (av)[1];
2717 AvARRAY (av)[1] = count_sv;
2718 cb = av_shift (av);
2719
2720 if (SvOBJECT (cb))
2721 api_ready (cb);
439 else 2722 else
440 { 2723 croak ("callbacks not yet supported");
441 SAVE (prev);
442 2724
443 /* 2725 SvREFCNT_dec (cb);
444 * emulate part of the perl startup here.
445 */
446 UNOP myop;
447
448 init_stacks (); /* from perl.c */
449 PL_op = (OP *)&myop;
450 /*PL_curcop = 0;*/
451 GvAV (PL_defgv) = (AV *)SvREFCNT_inc ((SV *)next->args);
452
453 SPAGAIN;
454 Zero(&myop, 1, UNOP);
455 myop.op_next = Nullop;
456 myop.op_flags = OPf_WANT_VOID;
457
458 PUSHMARK(SP);
459 XPUSHs ((SV*)get_cv(SUB_INIT, TRUE));
460 PUTBACK;
461 /*
462 * the next line is slightly wrong, as PL_op->op_next
463 * is actually being executed so we skip the first op.
464 * that doesn't matter, though, since it is only
465 * pp_nextstate and we never return...
466 */
467 PL_op = Perl_pp_entersub(aTHX);
468 SPAGAIN;
469
470 ENTER;
471 }
472 } 2726 }
2727}
473 2728
474void 2729void
475DESTROY(coro) 2730down (SV *self)
476 Coro::State coro
477 CODE: 2731 CODE:
2732 api_execute_slf (aTHX_ cv, slf_init_semaphore_down, &ST (0), items);
478 2733
479 if (coro->mainstack) 2734void
2735try (SV *self)
2736 PPCODE:
2737{
2738 AV *av = (AV *)SvRV (self);
2739 SV *count_sv = AvARRAY (av)[0];
2740 IV count = SvIVX (count_sv);
2741
2742 if (count > 0)
480 { 2743 {
481 struct coro temp; 2744 --count;
482 2745 SvIVX (count_sv) = count;
483 SAVE(aTHX_ (&temp)); 2746 XSRETURN_YES;
484 LOAD(aTHX_ coro);
485
486 destroy_stacks ();
487 SvREFCNT_dec ((SV *)GvAV (PL_defgv));
488
489 LOAD((&temp));
490 } 2747 }
2748 else
2749 XSRETURN_NO;
2750}
491 2751
492 SvREFCNT_dec (coro->args); 2752void
493 Safefree (coro); 2753waiters (SV *self)
2754 CODE:
2755{
2756 AV *av = (AV *)SvRV (self);
494 2757
2758 if (GIMME_V == G_SCALAR)
2759 XPUSHs (sv_2mortal (newSVsv (AvARRAY (av)[0])));
2760 else
2761 {
2762 int i;
2763 EXTEND (SP, AvFILLp (av) + 1 - 1);
2764 for (i = 1; i <= AvFILLp (av); ++i)
2765 PUSHs (newSVsv (AvARRAY (av)[i]));
2766 }
2767}
495 2768

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines