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.353 by root, Mon Jun 22 11:25:53 2009 UTC vs.
Revision 1.359 by root, Mon Jun 29 05:07:19 2009 UTC

… …
137 137
138#define IN_DESTRUCT PL_dirty 138#define IN_DESTRUCT PL_dirty
139 139
140#if __GNUC__ >= 3 140#if __GNUC__ >= 3
141# define attribute(x) __attribute__(x) 141# define attribute(x) __attribute__(x)
142# define expect(expr,value) __builtin_expect ((expr),(value)) 142# define expect(expr,value) __builtin_expect ((expr), (value))
143# define INLINE static inline 143# define INLINE static inline
144#else 144#else
145# define attribute(x) 145# define attribute(x)
146# define expect(expr,value) (expr) 146# define expect(expr,value) (expr)
147# define INLINE static 147# define INLINE static
… …
156#define GCoroAPI (&coroapi) /* very sneaky */ 156#define GCoroAPI (&coroapi) /* very sneaky */
157 157
158#ifdef USE_ITHREADS 158#ifdef USE_ITHREADS
159# if CORO_PTHREAD 159# if CORO_PTHREAD
160static void *coro_thx; 160static void *coro_thx;
161# endif
162#endif
163
164#ifdef __linux
165# include <time.h> /* for timespec */
166# include <syscall.h> /* for SYS_* */
167# ifdef SYS_clock_gettime
168# define coro_clock_gettime(id, ts) syscall (SYS_clock_gettime, (id), (ts))
169# define CORO_CLOCK_MONOTONIC 1
170# define CORO_CLOCK_THREAD_CPUTIME_ID 3
161# endif 171# endif
162#endif 172#endif
163 173
164static double (*nvtime)(); /* so why doesn't it take void? */ 174static double (*nvtime)(); /* so why doesn't it take void? */
165 175
… …
194static CV *cv_pool_handler; 204static CV *cv_pool_handler;
195static CV *cv_coro_state_new; 205static CV *cv_coro_state_new;
196 206
197/* Coro::AnyEvent */ 207/* Coro::AnyEvent */
198static SV *sv_activity; 208static SV *sv_activity;
209
210/* enable processtime/realtime profiling */
211static char profile_times;
212typedef U32 coro_ts[2];
199 213
200static struct coro_cctx *cctx_first; 214static struct coro_cctx *cctx_first;
201static int cctx_count, cctx_idle; 215static int cctx_count, cctx_idle;
202 216
203enum { 217enum {
… …
307/* the mainr easonw e don't support windows process emulation */ 321/* the mainr easonw e don't support windows process emulation */
308static struct CoroSLF slf_frame; /* the current slf frame */ 322static struct CoroSLF slf_frame; /* the current slf frame */
309 323
310/** Coro ********************************************************************/ 324/** Coro ********************************************************************/
311 325
312#define PRIO_MAX 3 326#define CORO_PRIO_MAX 3
313#define PRIO_HIGH 1 327#define CORO_PRIO_HIGH 1
314#define PRIO_NORMAL 0 328#define CORO_PRIO_NORMAL 0
315#define PRIO_LOW -1 329#define CORO_PRIO_LOW -1
316#define PRIO_IDLE -3 330#define CORO_PRIO_IDLE -3
317#define PRIO_MIN -4 331#define CORO_PRIO_MIN -4
318 332
319/* for Coro.pm */ 333/* for Coro.pm */
320static SV *coro_current; 334static SV *coro_current;
321static SV *coro_readyhook; 335static SV *coro_readyhook;
322static struct coro *coro_ready [PRIO_MAX - PRIO_MIN + 1][2]; /* head|tail */ 336static struct coro *coro_ready [CORO_PRIO_MAX - CORO_PRIO_MIN + 1][2]; /* head|tail */
323static CV *cv_coro_run, *cv_coro_terminate; 337static CV *cv_coro_run, *cv_coro_terminate;
324static struct coro *coro_first; 338static struct coro *coro_first;
325#define coro_nready coroapi.nready 339#define coro_nready coroapi.nready
326 340
327/** lowlevel stuff **********************************************************/ 341/** lowlevel stuff **********************************************************/
… …
475static int 489static int
476coro_cv_free (pTHX_ SV *sv, MAGIC *mg) 490coro_cv_free (pTHX_ SV *sv, MAGIC *mg)
477{ 491{
478 AV *padlist; 492 AV *padlist;
479 AV *av = (AV *)mg->mg_obj; 493 AV *av = (AV *)mg->mg_obj;
494
495 /* perl manages to free our internal AV and _then_ call us */
496 if (IN_DESTRUCT)
497 return;
480 498
481 /* casting is fun. */ 499 /* casting is fun. */
482 while (&PL_sv_undef != (SV *)(padlist = (AV *)av_pop (av))) 500 while (&PL_sv_undef != (SV *)(padlist = (AV *)av_pop (av)))
483 free_padlist (aTHX_ padlist); 501 free_padlist (aTHX_ padlist);
484 502
… …
615 { 633 {
616 while (expect_true (cxix >= 0)) 634 while (expect_true (cxix >= 0))
617 { 635 {
618 PERL_CONTEXT *cx = &ccstk[cxix--]; 636 PERL_CONTEXT *cx = &ccstk[cxix--];
619 637
620 if (expect_true (CxTYPE (cx) == CXt_SUB || CxTYPE (cx) == CXt_FORMAT)) 638 if (expect_true (CxTYPE (cx) == CXt_SUB) || expect_false (CxTYPE (cx) == CXt_FORMAT))
621 { 639 {
622 CV *cv = cx->blk_sub.cv; 640 CV *cv = cx->blk_sub.cv;
623 641
624 if (expect_true (CvDEPTH (cv))) 642 if (expect_true (CvDEPTH (cv)))
625 { 643 {
… …
1622/** Coro ********************************************************************/ 1640/** Coro ********************************************************************/
1623 1641
1624INLINE void 1642INLINE void
1625coro_enq (pTHX_ struct coro *coro) 1643coro_enq (pTHX_ struct coro *coro)
1626{ 1644{
1627 struct coro **ready = coro_ready [coro->prio - PRIO_MIN]; 1645 struct coro **ready = coro_ready [coro->prio - CORO_PRIO_MIN];
1628 1646
1629 SvREFCNT_inc_NN (coro->hv); 1647 SvREFCNT_inc_NN (coro->hv);
1630 1648
1631 coro->next_ready = 0; 1649 coro->next_ready = 0;
1632 *(ready [0] ? &ready [1]->next_ready : &ready [0]) = coro; 1650 *(ready [0] ? &ready [1]->next_ready : &ready [0]) = coro;
… …
1636INLINE struct coro * 1654INLINE struct coro *
1637coro_deq (pTHX) 1655coro_deq (pTHX)
1638{ 1656{
1639 int prio; 1657 int prio;
1640 1658
1641 for (prio = PRIO_MAX - PRIO_MIN + 1; --prio >= 0; ) 1659 for (prio = CORO_PRIO_MAX - CORO_PRIO_MIN + 1; --prio >= 0; )
1642 { 1660 {
1643 struct coro **ready = coro_ready [prio]; 1661 struct coro **ready = coro_ready [prio];
1644 1662
1645 if (ready [0]) 1663 if (ready [0])
1646 { 1664 {
… …
2631 { 2649 {
2632 /* callback form */ 2650 /* callback form */
2633 AV *av = (AV *)SvRV (arg [0]); 2651 AV *av = (AV *)SvRV (arg [0]);
2634 CV *cb_cv = coro_sv_2cv (aTHX_ arg [1]); 2652 CV *cb_cv = coro_sv_2cv (aTHX_ arg [1]);
2635 2653
2636 av_push (av, (SV *)SvREFCNT_inc_NN (cb_cv)); 2654 av_push (av, SvREFCNT_inc_NN (cb_cv));
2637 2655
2638 if (SvIVX (AvARRAY (av)[0]) > 0) 2656 if (SvIVX (AvARRAY (av)[0]) > 0)
2639 coro_semaphore_adjust (aTHX_ av, 0); 2657 coro_semaphore_adjust (aTHX_ av, 0);
2640 2658
2641 frame->prepare = prepare_nop; 2659 frame->prepare = prepare_nop;
… …
2665 AvARRAY (av)[0] = AvARRAY (av)[1]; 2683 AvARRAY (av)[0] = AvARRAY (av)[1];
2666 AvARRAY (av)[1] = cb; 2684 AvARRAY (av)[1] = cb;
2667 2685
2668 cb = av_shift (av); 2686 cb = av_shift (av);
2669 2687
2688 if (SvTYPE (cb) == SVt_PVCV)
2689 {
2690 dSP;
2691 PUSHMARK (SP);
2692 XPUSHs (sv_2mortal (newRV_inc ((SV *)av)));
2693 PUTBACK;
2694 call_sv (cb, G_VOID | G_DISCARD | G_EVAL | G_KEEPERR);
2695 }
2696 else
2697 {
2670 api_ready (aTHX_ cb); 2698 api_ready (aTHX_ cb);
2671 sv_setiv (cb, 0); /* signal waiter */ 2699 sv_setiv (cb, 0); /* signal waiter */
2700 }
2701
2672 SvREFCNT_dec (cb); 2702 SvREFCNT_dec (cb);
2673 2703
2674 --count; 2704 --count;
2675 } 2705 }
2676} 2706}
… …
2685static void 2715static void
2686slf_init_signal_wait (pTHX_ struct CoroSLF *frame, CV *cv, SV **arg, int items) 2716slf_init_signal_wait (pTHX_ struct CoroSLF *frame, CV *cv, SV **arg, int items)
2687{ 2717{
2688 AV *av = (AV *)SvRV (arg [0]); 2718 AV *av = (AV *)SvRV (arg [0]);
2689 2719
2720 if (items >= 2)
2721 {
2722 CV *cb_cv = coro_sv_2cv (aTHX_ arg [1]);
2723 av_push (av, SvREFCNT_inc_NN (cb_cv));
2724
2690 if (SvIVX (AvARRAY (av)[0])) 2725 if (SvIVX (AvARRAY (av)[0]))
2726 coro_signal_wake (aTHX_ av, 1); /* ust be the only waiter */
2727
2728 frame->prepare = prepare_nop;
2729 frame->check = slf_check_nop;
2730 }
2731 else if (SvIVX (AvARRAY (av)[0]))
2691 { 2732 {
2692 SvIVX (AvARRAY (av)[0]) = 0; 2733 SvIVX (AvARRAY (av)[0]) = 0;
2693 frame->prepare = prepare_nop; 2734 frame->prepare = prepare_nop;
2694 frame->check = slf_check_nop; 2735 frame->check = slf_check_nop;
2695 } 2736 }
2696 else 2737 else
2697 { 2738 {
2698 SV *waiter = newRV_inc (SvRV (coro_current)); /* owned by signal av */ 2739 SV *waiter = newSVsv (coro_current); /* owned by signal av */
2699 2740
2700 av_push (av, waiter); 2741 av_push (av, waiter);
2701 2742
2702 frame->data = (void *)sv_2mortal (SvREFCNT_inc_NN (waiter)); /* owned by process */ 2743 frame->data = (void *)sv_2mortal (SvREFCNT_inc_NN (waiter)); /* owned by process */
2703 frame->prepare = prepare_schedule; 2744 frame->prepare = prepare_schedule;
… …
2944 if (!SvIOK (*svp)) croak ("Time::NVtime isn't a function pointer"); 2985 if (!SvIOK (*svp)) croak ("Time::NVtime isn't a function pointer");
2945 2986
2946 nvtime = INT2PTR (double (*)(), SvIV (*svp)); 2987 nvtime = INT2PTR (double (*)(), SvIV (*svp));
2947 } 2988 }
2948 2989
2949 assert (("PRIO_NORMAL must be 0", !PRIO_NORMAL)); 2990 assert (("PRIO_NORMAL must be 0", !CORO_PRIO_NORMAL));
2950} 2991}
2951 2992
2952SV * 2993SV *
2953new (char *klass, ...) 2994new (char *klass, ...)
2954 ALIAS: 2995 ALIAS:
… …
3156 CODE: 3197 CODE:
3157{ 3198{
3158 struct coro *current = SvSTATE_current; 3199 struct coro *current = SvSTATE_current;
3159 SV **throwp = self == current ? &CORO_THROW : &self->except; 3200 SV **throwp = self == current ? &CORO_THROW : &self->except;
3160 SvREFCNT_dec (*throwp); 3201 SvREFCNT_dec (*throwp);
3202 SvGETMAGIC (throw);
3161 *throwp = SvOK (throw) ? newSVsv (throw) : 0; 3203 *throwp = SvOK (throw) ? newSVsv (throw) : 0;
3162} 3204}
3163 3205
3164void 3206void
3165api_trace (SV *coro, int flags = CC_TRACE | CC_TRACE_SUB) 3207api_trace (SV *coro, int flags = CC_TRACE | CC_TRACE_SUB)
… …
3245 cv_pool_handler = get_cv ("Coro::pool_handler", GV_ADD); SvREADONLY_on (cv_pool_handler); 3287 cv_pool_handler = get_cv ("Coro::pool_handler", GV_ADD); SvREADONLY_on (cv_pool_handler);
3246 cv_coro_state_new = get_cv ("Coro::State::new", 0); SvREADONLY_on (cv_coro_state_new); 3288 cv_coro_state_new = get_cv ("Coro::State::new", 0); SvREADONLY_on (cv_coro_state_new);
3247 3289
3248 coro_stash = gv_stashpv ("Coro", TRUE); 3290 coro_stash = gv_stashpv ("Coro", TRUE);
3249 3291
3250 newCONSTSUB (coro_stash, "PRIO_MAX", newSViv (PRIO_MAX)); 3292 newCONSTSUB (coro_stash, "PRIO_MAX", newSViv (CORO_PRIO_MAX));
3251 newCONSTSUB (coro_stash, "PRIO_HIGH", newSViv (PRIO_HIGH)); 3293 newCONSTSUB (coro_stash, "PRIO_HIGH", newSViv (CORO_PRIO_HIGH));
3252 newCONSTSUB (coro_stash, "PRIO_NORMAL", newSViv (PRIO_NORMAL)); 3294 newCONSTSUB (coro_stash, "PRIO_NORMAL", newSViv (CORO_PRIO_NORMAL));
3253 newCONSTSUB (coro_stash, "PRIO_LOW", newSViv (PRIO_LOW)); 3295 newCONSTSUB (coro_stash, "PRIO_LOW", newSViv (CORO_PRIO_LOW));
3254 newCONSTSUB (coro_stash, "PRIO_IDLE", newSViv (PRIO_IDLE)); 3296 newCONSTSUB (coro_stash, "PRIO_IDLE", newSViv (CORO_PRIO_IDLE));
3255 newCONSTSUB (coro_stash, "PRIO_MIN", newSViv (PRIO_MIN)); 3297 newCONSTSUB (coro_stash, "PRIO_MIN", newSViv (CORO_PRIO_MIN));
3256 3298
3257 { 3299 {
3258 SV *sv = coro_get_sv (aTHX_ "Coro::API", TRUE); 3300 SV *sv = coro_get_sv (aTHX_ "Coro::API", TRUE);
3259 3301
3260 coroapi.schedule = api_schedule; 3302 coroapi.schedule = api_schedule;
… …
3312void 3354void
3313_set_readyhook (SV *hook) 3355_set_readyhook (SV *hook)
3314 PROTOTYPE: $ 3356 PROTOTYPE: $
3315 CODE: 3357 CODE:
3316 SvREFCNT_dec (coro_readyhook); 3358 SvREFCNT_dec (coro_readyhook);
3359 SvGETMAGIC (hook);
3317 coro_readyhook = SvOK (hook) ? newSVsv (hook) : 0; 3360 coro_readyhook = SvOK (hook) ? newSVsv (hook) : 0;
3318 3361
3319int 3362int
3320prio (Coro::State coro, int newprio = 0) 3363prio (Coro::State coro, int newprio = 0)
3321 PROTOTYPE: $;$ 3364 PROTOTYPE: $;$
… …
3328 if (items > 1) 3371 if (items > 1)
3329 { 3372 {
3330 if (ix) 3373 if (ix)
3331 newprio = coro->prio - newprio; 3374 newprio = coro->prio - newprio;
3332 3375
3333 if (newprio < PRIO_MIN) newprio = PRIO_MIN; 3376 if (newprio < CORO_PRIO_MIN) newprio = CORO_PRIO_MIN;
3334 if (newprio > PRIO_MAX) newprio = PRIO_MAX; 3377 if (newprio > CORO_PRIO_MAX) newprio = CORO_PRIO_MAX;
3335 3378
3336 coro->prio = newprio; 3379 coro->prio = newprio;
3337 } 3380 }
3338} 3381}
3339 OUTPUT: 3382 OUTPUT:
… …
3465MODULE = Coro::State PACKAGE = Coro::Semaphore 3508MODULE = Coro::State PACKAGE = Coro::Semaphore
3466 3509
3467SV * 3510SV *
3468new (SV *klass, SV *count = 0) 3511new (SV *klass, SV *count = 0)
3469 CODE: 3512 CODE:
3513{
3514 int semcnt = 1;
3515
3516 if (count)
3517 {
3518 SvGETMAGIC (count);
3519
3520 if (SvOK (count))
3521 semcnt = SvIV (count);
3522 }
3523
3470 RETVAL = sv_bless ( 3524 RETVAL = sv_bless (
3471 coro_waitarray_new (aTHX_ count && SvOK (count) ? SvIV (count) : 1), 3525 coro_waitarray_new (aTHX_ semcnt),
3472 GvSTASH (CvGV (cv)) 3526 GvSTASH (CvGV (cv))
3473 ); 3527 );
3528}
3474 OUTPUT: 3529 OUTPUT:
3475 RETVAL 3530 RETVAL
3476 3531
3477# helper for Coro::Channel and others 3532# helper for Coro::Channel and others
3478SV * 3533SV *

Diff Legend

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