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.446 by root, Wed Sep 3 14:26:34 2014 UTC vs.
Revision 1.452 by root, Tue Jun 30 12:42:45 2015 UTC

… …
21 21
22#include <stddef.h> 22#include <stddef.h>
23#include <stdio.h> 23#include <stdio.h>
24#include <errno.h> 24#include <errno.h>
25#include <assert.h> 25#include <assert.h>
26
27#ifndef SvREFCNT_dec_NN
28 #define SvREFCNT_dec_NN(sv) SvREFCNT_dec (sv)
29#endif
30
31#ifndef SvREFCNT_inc_NN
32 #define SvREFCNT_inc_NN(sv) SvREFCNT_inc (sv)
33#endif
26 34
27#ifndef SVs_PADSTALE 35#ifndef SVs_PADSTALE
28# define SVs_PADSTALE 0 36# define SVs_PADSTALE 0
29#endif 37#endif
30 38
… …
42# define PadlistNAMES(pl) (*PadlistARRAY (pl)) 50# define PadlistNAMES(pl) (*PadlistARRAY (pl))
43# define PadARRAY AvARRAY 51# define PadARRAY AvARRAY
44# define PadMAX AvFILLp 52# define PadMAX AvFILLp
45# define newPADLIST(var) ((var) = newAV (), av_extend (var, 1)) 53# define newPADLIST(var) ((var) = newAV (), av_extend (var, 1))
46#endif 54#endif
55#ifndef PadnamelistREFCNT
56# define PadnamelistREFCNT(pnl) SvREFCNT (pnl)
57#endif
58#ifndef PadnamelistREFCNT_dec
59# define PadnamelistREFCNT_dec(pnl) SvREFCNT_dec (pnl)
60#endif
47 61
48/* 5.19.something has replaced SVt_BIND by SVt_INVLIST */ 62/* 5.19.something has replaced SVt_BIND by SVt_INVLIST */
49/* we just alias it to SVt_IV, as that is sufficient for swap_sv for now */ 63/* we just alias it to SVt_IV, as that is sufficient for swap_sv for now */
50#if PERL_VERSION_ATLEAST(5,19,0) 64#if PERL_VERSION_ATLEAST(5,19,0)
51# define SVt_BIND SVt_IV 65# define SVt_BIND SVt_IV
… …
242 SV *saved_deffh; 256 SV *saved_deffh;
243 SV *invoke_cb; 257 SV *invoke_cb;
244 AV *invoke_av; 258 AV *invoke_av;
245 259
246 /* on_enter/on_leave */ 260 /* on_enter/on_leave */
247 AV *on_enter; 261 AV *on_enter; AV *on_enter_xs;
248 AV *on_leave; 262 AV *on_leave; AV *on_leave_xs;
249 263
250 /* swap_sv */ 264 /* swap_sv */
251 AV *swap_sv; 265 AV *swap_sv;
252 266
253 /* times */ 267 /* times */
… …
489 503
490 return 0; 504 return 0;
491} 505}
492 506
493ecb_inline struct coro * 507ecb_inline struct coro *
494SvSTATE_ (pTHX_ SV *coro) 508SvSTATE_ (pTHX_ SV *coro_sv)
495{ 509{
496 MAGIC *mg; 510 MAGIC *mg;
497 511
498 if (SvROK (coro)) 512 if (SvROK (coro_sv))
499 coro = SvRV (coro); 513 coro_sv = SvRV (coro_sv);
500 514
501 mg = SvSTATEhv_p (aTHX_ coro); 515 mg = SvSTATEhv_p (aTHX_ coro_sv);
502 if (!mg) 516 if (!mg)
503 croak ("Coro::State object required"); 517 croak ("Coro::State object required");
504 518
505 return (struct coro *)mg->mg_ptr; 519 return (struct coro *)mg->mg_ptr;
506} 520}
… …
517ecb_inline PADLIST * 531ecb_inline PADLIST *
518coro_derive_padlist (pTHX_ CV *cv) 532coro_derive_padlist (pTHX_ CV *cv)
519{ 533{
520 PADLIST *padlist = CvPADLIST (cv); 534 PADLIST *padlist = CvPADLIST (cv);
521 PADLIST *newpadlist; 535 PADLIST *newpadlist;
536 PADNAMELIST *padnames;
522 PAD *newpad; 537 PAD *newpad;
523 PADOFFSET off = PadlistMAX (padlist) + 1; 538 PADOFFSET off = PadlistMAX (padlist) + 1;
524 539
525#if NEWPADAPI 540#if NEWPADAPI
526 541
… …
553 AvREAL_off (newpadlist); 568 AvREAL_off (newpadlist);
554#endif 569#endif
555 570
556 /* Already extended to 2 elements by newPADLIST. */ 571 /* Already extended to 2 elements by newPADLIST. */
557 PadlistMAX (newpadlist) = 1; 572 PadlistMAX (newpadlist) = 1;
558 PadlistNAMES (newpadlist) = (PADNAMELIST *)SvREFCNT_inc_NN (PadlistNAMES (padlist)); 573
574 padnames = PadlistNAMES (padlist);
575 ++PadnamelistREFCNT (padnames);
576 PadlistNAMES (newpadlist) = padnames;
577
559 PadlistARRAY (newpadlist)[1] = newpad; 578 PadlistARRAY (newpadlist)[1] = newpad;
560 579
561 return newpadlist; 580 return newpadlist;
562} 581}
563 582
… …
584 PadMAX (pad) = -1; 603 PadMAX (pad) = -1;
585 SvREFCNT_dec (pad); 604 SvREFCNT_dec (pad);
586 } 605 }
587 } 606 }
588 607
589 SvREFCNT_dec (PadlistNAMES (padlist)); 608 PadnamelistREFCNT_dec (PadlistNAMES (padlist));
590 609
591#if NEWPADAPI 610#if NEWPADAPI
592 Safefree (PadlistARRAY (padlist)); 611 Safefree (PadlistARRAY (padlist));
593 Safefree (padlist); 612 Safefree (padlist);
594#else 613#else
… …
769 788
770 for (i = 0; i <= AvFILLp (c->on_enter); ++i) 789 for (i = 0; i <= AvFILLp (c->on_enter); ++i)
771 on_enterleave_call (aTHX_ AvARRAY (c->on_enter)[i]); 790 on_enterleave_call (aTHX_ AvARRAY (c->on_enter)[i]);
772 } 791 }
773 792
793 if (ecb_expect_false (c->on_enter_xs))
794 {
795 int i;
796
797 for (i = 0; i <= AvFILLp (c->on_enter_xs); i += 2)
798 ((coro_enterleave_hook)AvARRAY (c->on_enter_xs)[i]) (aTHX_ AvARRAY (c->on_enter_xs)[i + 1]);
799 }
800
774 SWAP_SVS (c); 801 SWAP_SVS (c);
775} 802}
776 803
777static void 804static void
778save_perl (pTHX_ Coro__State c) 805save_perl (pTHX_ Coro__State c)
779{ 806{
780 SWAP_SVS (c); 807 SWAP_SVS (c);
808
809 if (ecb_expect_false (c->on_leave_xs))
810 {
811 int i;
812
813 for (i = AvFILLp (c->on_leave_xs) - 1; i >= 0; i -= 2)
814 ((coro_enterleave_hook)AvARRAY (c->on_leave_xs)[i]) (aTHX_ AvARRAY (c->on_leave_xs)[i + 1]);
815 }
781 816
782 if (ecb_expect_false (c->on_leave)) 817 if (ecb_expect_false (c->on_leave))
783 { 818 {
784 int i; 819 int i;
785 820
… …
1261 1296
1262 SvREFCNT_dec (coro->saved_deffh); 1297 SvREFCNT_dec (coro->saved_deffh);
1263 SvREFCNT_dec (coro->rouse_cb); 1298 SvREFCNT_dec (coro->rouse_cb);
1264 SvREFCNT_dec (coro->invoke_cb); 1299 SvREFCNT_dec (coro->invoke_cb);
1265 SvREFCNT_dec (coro->invoke_av); 1300 SvREFCNT_dec (coro->invoke_av);
1301 SvREFCNT_dec (coro->on_enter_xs);
1302 SvREFCNT_dec (coro->on_leave_xs);
1266 } 1303 }
1267} 1304}
1268 1305
1269ecb_inline void 1306ecb_inline void
1270free_coro_mortal (pTHX) 1307free_coro_mortal (pTHX)
… …
1333 1370
1334 if (PL_curcop != &PL_compiling) 1371 if (PL_curcop != &PL_compiling)
1335 { 1372 {
1336 SV **cb; 1373 SV **cb;
1337 1374
1338 if (oldcxix != cxstack_ix && cctx_current->flags & CC_TRACE_SUB) 1375 if (oldcxix != cxstack_ix && cctx_current->flags & CC_TRACE_SUB && cxstack_ix >= 0)
1339 { 1376 {
1340 PERL_CONTEXT *cx = &cxstack[cxstack_ix]; 1377 PERL_CONTEXT *cx = &cxstack[cxstack_ix];
1341 1378
1342 if (CxTYPE (cx) == CXt_SUB && oldcxix < cxstack_ix) 1379 if (CxTYPE (cx) == CXt_SUB && oldcxix < cxstack_ix)
1343 { 1380 {
… …
1930 1967
1931 ENTER; 1968 ENTER;
1932 SAVETMPS; 1969 SAVETMPS;
1933 1970
1934 PUSHMARK (SP); 1971 PUSHMARK (SP);
1935 XPUSHs (sv_2mortal (newSVpv ("FATAL: $Coro::IDLE blocked itself - did you try to block inside an event loop callback? Caught", 0))); 1972 XPUSHs (sv_2mortal (newSVpv ("FATAL: $Coro::idle blocked itself - did you try to block inside an event loop callback? Caught", 0)));
1936 PUTBACK; 1973 PUTBACK;
1937 call_pv ("Carp::confess", G_VOID | G_DISCARD); 1974 call_pv ("Carp::confess", G_VOID | G_DISCARD);
1938 1975
1939 FREETMPS; 1976 FREETMPS;
1940 LEAVE; 1977 LEAVE;
… …
2810static void 2847static void
2811coro_pop_on_leave (pTHX_ void *coro) 2848coro_pop_on_leave (pTHX_ void *coro)
2812{ 2849{
2813 SV *cb = coro_avp_pop_and_free (aTHX_ &((struct coro *)coro)->on_leave); 2850 SV *cb = coro_avp_pop_and_free (aTHX_ &((struct coro *)coro)->on_leave);
2814 on_enterleave_call (aTHX_ sv_2mortal (cb)); 2851 on_enterleave_call (aTHX_ sv_2mortal (cb));
2852}
2853
2854static void
2855enterleave_hook_xs (pTHX_ struct coro *coro, AV **avp, coro_enterleave_hook hook, void *arg)
2856{
2857 if (!hook)
2858 return;
2859
2860 if (!*avp)
2861 {
2862 *avp = newAV ();
2863 AvREAL_off (*avp);
2864 }
2865
2866 av_push (*avp, (SV *)hook);
2867 av_push (*avp, (SV *)arg);
2868}
2869
2870static void
2871enterleave_unhook_xs (pTHX_ struct coro *coro, AV **avp, coro_enterleave_hook hook, int execute)
2872{
2873 AV *av = *avp;
2874 int i;
2875
2876 if (!av)
2877 return;
2878
2879 for (i = AvFILLp (av) - 1; i >= 0; i -= 2)
2880 if (AvARRAY (av)[i] == (SV *)hook)
2881 {
2882 if (execute)
2883 hook (aTHX_ (void *)AvARRAY (av)[i + 1]);
2884
2885 memmove (AvARRAY (av) + i, AvARRAY (av) + i + 2, AvFILLp (av) - i - 1);
2886 av_pop (av);
2887 av_pop (av);
2888 break;
2889 }
2890
2891 if (AvFILLp (av) >= 0)
2892 {
2893 *avp = 0;
2894 SvREFCNT_dec_NN (av);
2895 }
2896}
2897
2898static void
2899api_enterleave_hook (pTHX_ SV *coro_sv, coro_enterleave_hook enter, void *enter_arg, coro_enterleave_hook leave, void *leave_arg)
2900{
2901 struct coro *coro = SvSTATE (coro_sv);
2902
2903 if (SvSTATE_current == coro)
2904 if (enter)
2905 enter (aTHX_ enter_arg);
2906
2907 enterleave_hook_xs (aTHX_ coro, &coro->on_enter_xs, enter, enter_arg);
2908 enterleave_hook_xs (aTHX_ coro, &coro->on_leave_xs, leave, leave_arg);
2909}
2910
2911static void
2912api_enterleave_unhook (pTHX_ SV *coro_sv, coro_enterleave_hook enter, coro_enterleave_hook leave)
2913{
2914 struct coro *coro = SvSTATE (coro_sv);
2915
2916 enterleave_unhook_xs (aTHX_ coro, &coro->on_enter_xs, enter, 0);
2917 enterleave_unhook_xs (aTHX_ coro, &coro->on_leave_xs, leave, SvSTATE_current == coro);
2918}
2919
2920static void
2921savedestructor_unhook_enter (pTHX_ coro_enterleave_hook enter)
2922{
2923 struct coro *coro = SvSTATE_current;
2924
2925 enterleave_unhook_xs (aTHX_ coro, &coro->on_enter_xs, enter, 0);
2926}
2927
2928static void
2929savedestructor_unhook_leave (pTHX_ coro_enterleave_hook leave)
2930{
2931 struct coro *coro = SvSTATE_current;
2932
2933 enterleave_unhook_xs (aTHX_ coro, &coro->on_leave_xs, leave, 1);
2934}
2935
2936static void
2937api_enterleave_scope_hook (pTHX_ coro_enterleave_hook enter, void *enter_arg, coro_enterleave_hook leave, void *leave_arg)
2938{
2939 api_enterleave_hook (aTHX_ coro_current, enter, enter_arg, leave, leave_arg);
2940
2941 /* this ought to be much cheaper than malloc + a single destructor call */
2942 if (enter) SAVEDESTRUCTOR_X (savedestructor_unhook_enter, enter);
2943 if (leave) SAVEDESTRUCTOR_X (savedestructor_unhook_leave, leave);
2815} 2944}
2816 2945
2817/*****************************************************************************/ 2946/*****************************************************************************/
2818/* PerlIO::cede */ 2947/* PerlIO::cede */
2819 2948
… …
2949 XPUSHs (sv_2mortal (newRV_inc ((SV *)av))); 3078 XPUSHs (sv_2mortal (newRV_inc ((SV *)av)));
2950 PUTBACK; 3079 PUTBACK;
2951 call_sv (cb, G_VOID | G_DISCARD | G_EVAL | G_KEEPERR); 3080 call_sv (cb, G_VOID | G_DISCARD | G_EVAL | G_KEEPERR);
2952 } 3081 }
2953 3082
2954 SvREFCNT_dec (cb); 3083 SvREFCNT_dec_NN (cb);
2955 } 3084 }
2956} 3085}
2957 3086
2958static void 3087static void
2959coro_semaphore_destroy (pTHX_ struct CoroSLF *frame) 3088coro_semaphore_destroy (pTHX_ struct CoroSLF *frame)
… …
3099 { 3228 {
3100 api_ready (aTHX_ cb); 3229 api_ready (aTHX_ cb);
3101 sv_setiv (cb, 0); /* signal waiter */ 3230 sv_setiv (cb, 0); /* signal waiter */
3102 } 3231 }
3103 3232
3104 SvREFCNT_dec (cb); 3233 SvREFCNT_dec_NN (cb);
3105 3234
3106 --count; 3235 --count;
3107 } 3236 }
3108} 3237}
3109 3238
… …
3194 } 3323 }
3195 3324
3196 av_push (state, data_sv); 3325 av_push (state, data_sv);
3197 3326
3198 api_ready (aTHX_ coro); 3327 api_ready (aTHX_ coro);
3199 SvREFCNT_dec (coro); 3328 SvREFCNT_dec_NN (coro);
3200 SvREFCNT_dec ((AV *)state); 3329 SvREFCNT_dec_NN ((AV *)state);
3201} 3330}
3202 3331
3203static int 3332static int
3204slf_check_aio_req (pTHX_ struct CoroSLF *frame) 3333slf_check_aio_req (pTHX_ struct CoroSLF *frame)
3205{ 3334{
… …
3223 errno = data->errorno; 3352 errno = data->errorno;
3224 PL_laststype = data->laststype; 3353 PL_laststype = data->laststype;
3225 PL_laststatval = data->laststatval; 3354 PL_laststatval = data->laststatval;
3226 PL_statcache = data->statcache; 3355 PL_statcache = data->statcache;
3227 3356
3228 SvREFCNT_dec (data_sv); 3357 SvREFCNT_dec_NN (data_sv);
3229 } 3358 }
3230 3359
3231 /* push result values */ 3360 /* push result values */
3232 { 3361 {
3233 dSP; 3362 dSP;
… …
3845 coroapi.ready = api_ready; 3974 coroapi.ready = api_ready;
3846 coroapi.is_ready = api_is_ready; 3975 coroapi.is_ready = api_is_ready;
3847 coroapi.nready = coro_nready; 3976 coroapi.nready = coro_nready;
3848 coroapi.current = coro_current; 3977 coroapi.current = coro_current;
3849 3978
3979 coroapi.enterleave_hook = api_enterleave_hook;
3980 coroapi.enterleave_unhook = api_enterleave_unhook;
3981 coroapi.enterleave_scope_hook = api_enterleave_scope_hook;
3982
3850 /*GCoroAPI = &coroapi;*/ 3983 /*GCoroAPI = &coroapi;*/
3851 sv_setiv (sv, (IV)&coroapi); 3984 sv_setiv (sv, (IV)&coroapi);
3852 SvREADONLY_on (sv); 3985 SvREADONLY_on (sv);
3853 } 3986 }
3854} 3987}
… …
3919 4052
3920void 4053void
3921_set_current (SV *current) 4054_set_current (SV *current)
3922 PROTOTYPE: $ 4055 PROTOTYPE: $
3923 CODE: 4056 CODE:
3924 SvREFCNT_dec (SvRV (coro_current)); 4057 SvREFCNT_dec_NN (SvRV (coro_current));
3925 SvRV_set (coro_current, SvREFCNT_inc_NN (SvRV (current))); 4058 SvRV_set (coro_current, SvREFCNT_inc_NN (SvRV (current)));
3926 4059
3927void 4060void
3928_set_readyhook (SV *hook) 4061_set_readyhook (SV *hook)
3929 PROTOTYPE: $ 4062 PROTOTYPE: $
… …
4013 4146
4014 if ((SV *)hv == &PL_sv_undef) 4147 if ((SV *)hv == &PL_sv_undef)
4015 { 4148 {
4016 SV *sv = coro_new (aTHX_ coro_stash, (SV **)&cv_pool_handler, 1, 1); 4149 SV *sv = coro_new (aTHX_ coro_stash, (SV **)&cv_pool_handler, 1, 1);
4017 hv = (HV *)SvREFCNT_inc_NN (SvRV (sv)); 4150 hv = (HV *)SvREFCNT_inc_NN (SvRV (sv));
4018 SvREFCNT_dec (sv); 4151 SvREFCNT_dec_NN (sv);
4019 } 4152 }
4020 4153
4021 { 4154 {
4022 struct coro *coro = SvSTATE_hv (hv); 4155 struct coro *coro = SvSTATE_hv (hv);
4023 4156
… …
4030 api_ready (aTHX_ (SV *)hv); 4163 api_ready (aTHX_ (SV *)hv);
4031 4164
4032 if (GIMME_V != G_VOID) 4165 if (GIMME_V != G_VOID)
4033 XPUSHs (sv_2mortal (newRV_noinc ((SV *)hv))); 4166 XPUSHs (sv_2mortal (newRV_noinc ((SV *)hv)));
4034 else 4167 else
4035 SvREFCNT_dec (hv); 4168 SvREFCNT_dec_NN (hv);
4036} 4169}
4037 4170
4038SV * 4171SV *
4039rouse_cb () 4172rouse_cb ()
4040 PROTOTYPE: 4173 PROTOTYPE:

Diff Legend

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