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.439 by root, Tue Nov 19 05:16:01 2013 UTC vs.
Revision 1.452 by root, Tue Jun 30 12:42:45 2015 UTC

… …
14#include "perliol.h" 14#include "perliol.h"
15 15
16#include "schmorp.h" 16#include "schmorp.h"
17 17
18#define ECB_NO_THREADS 1 18#define ECB_NO_THREADS 1
19#define ECB_NO_LIBM 1
19#include "ecb.h" 20#include "ecb.h"
20 21
21#include <stddef.h> 22#include <stddef.h>
22#include <stdio.h> 23#include <stdio.h>
23#include <errno.h> 24#include <errno.h>
24#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
25 34
26#ifndef SVs_PADSTALE 35#ifndef SVs_PADSTALE
27# define SVs_PADSTALE 0 36# define SVs_PADSTALE 0
28#endif 37#endif
29 38
… …
41# define PadlistNAMES(pl) (*PadlistARRAY (pl)) 50# define PadlistNAMES(pl) (*PadlistARRAY (pl))
42# define PadARRAY AvARRAY 51# define PadARRAY AvARRAY
43# define PadMAX AvFILLp 52# define PadMAX AvFILLp
44# define newPADLIST(var) ((var) = newAV (), av_extend (var, 1)) 53# define newPADLIST(var) ((var) = newAV (), av_extend (var, 1))
45#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
46 61
47/* 5.19.something has replaced SVt_BIND by SVt_INVLIST */ 62/* 5.19.something has replaced SVt_BIND by SVt_INVLIST */
48/* 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 */
49#if PERL_VERSION_ATLEAST(5,19,0) 64#if PERL_VERSION_ATLEAST(5,19,0)
50# define SVt_BIND SVt_IV 65# define SVt_BIND SVt_IV
… …
241 SV *saved_deffh; 256 SV *saved_deffh;
242 SV *invoke_cb; 257 SV *invoke_cb;
243 AV *invoke_av; 258 AV *invoke_av;
244 259
245 /* on_enter/on_leave */ 260 /* on_enter/on_leave */
246 AV *on_enter; 261 AV *on_enter; AV *on_enter_xs;
247 AV *on_leave; 262 AV *on_leave; AV *on_leave_xs;
248 263
249 /* swap_sv */ 264 /* swap_sv */
250 AV *swap_sv; 265 AV *swap_sv;
251 266
252 /* times */ 267 /* times */
… …
488 503
489 return 0; 504 return 0;
490} 505}
491 506
492ecb_inline struct coro * 507ecb_inline struct coro *
493SvSTATE_ (pTHX_ SV *coro) 508SvSTATE_ (pTHX_ SV *coro_sv)
494{ 509{
495 MAGIC *mg; 510 MAGIC *mg;
496 511
497 if (SvROK (coro)) 512 if (SvROK (coro_sv))
498 coro = SvRV (coro); 513 coro_sv = SvRV (coro_sv);
499 514
500 mg = SvSTATEhv_p (aTHX_ coro); 515 mg = SvSTATEhv_p (aTHX_ coro_sv);
501 if (!mg) 516 if (!mg)
502 croak ("Coro::State object required"); 517 croak ("Coro::State object required");
503 518
504 return (struct coro *)mg->mg_ptr; 519 return (struct coro *)mg->mg_ptr;
505} 520}
… …
516ecb_inline PADLIST * 531ecb_inline PADLIST *
517coro_derive_padlist (pTHX_ CV *cv) 532coro_derive_padlist (pTHX_ CV *cv)
518{ 533{
519 PADLIST *padlist = CvPADLIST (cv); 534 PADLIST *padlist = CvPADLIST (cv);
520 PADLIST *newpadlist; 535 PADLIST *newpadlist;
536 PADNAMELIST *padnames;
521 PAD *newpad; 537 PAD *newpad;
522 PADOFFSET off = PadlistMAX (padlist) + 1; 538 PADOFFSET off = PadlistMAX (padlist) + 1;
523 539
524#if NEWPADAPI 540#if NEWPADAPI
525 541
… …
552 AvREAL_off (newpadlist); 568 AvREAL_off (newpadlist);
553#endif 569#endif
554 570
555 /* Already extended to 2 elements by newPADLIST. */ 571 /* Already extended to 2 elements by newPADLIST. */
556 PadlistMAX (newpadlist) = 1; 572 PadlistMAX (newpadlist) = 1;
557 PadlistNAMES (newpadlist) = (PADNAMELIST *)SvREFCNT_inc_NN (PadlistNAMES (padlist)); 573
574 padnames = PadlistNAMES (padlist);
575 ++PadnamelistREFCNT (padnames);
576 PadlistNAMES (newpadlist) = padnames;
577
558 PadlistARRAY (newpadlist)[1] = newpad; 578 PadlistARRAY (newpadlist)[1] = newpad;
559 579
560 return newpadlist; 580 return newpadlist;
561} 581}
562 582
… …
583 PadMAX (pad) = -1; 603 PadMAX (pad) = -1;
584 SvREFCNT_dec (pad); 604 SvREFCNT_dec (pad);
585 } 605 }
586 } 606 }
587 607
588 SvREFCNT_dec (PadlistNAMES (padlist)); 608 PadnamelistREFCNT_dec (PadlistNAMES (padlist));
589 609
590#if NEWPADAPI 610#if NEWPADAPI
591 Safefree (PadlistARRAY (padlist)); 611 Safefree (PadlistARRAY (padlist));
592 Safefree (padlist); 612 Safefree (padlist);
593#else 613#else
… …
768 788
769 for (i = 0; i <= AvFILLp (c->on_enter); ++i) 789 for (i = 0; i <= AvFILLp (c->on_enter); ++i)
770 on_enterleave_call (aTHX_ AvARRAY (c->on_enter)[i]); 790 on_enterleave_call (aTHX_ AvARRAY (c->on_enter)[i]);
771 } 791 }
772 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
773 SWAP_SVS (c); 801 SWAP_SVS (c);
774} 802}
775 803
776static void 804static void
777save_perl (pTHX_ Coro__State c) 805save_perl (pTHX_ Coro__State c)
778{ 806{
779 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 }
780 816
781 if (ecb_expect_false (c->on_leave)) 817 if (ecb_expect_false (c->on_leave))
782 { 818 {
783 int i; 819 int i;
784 820
… …
1137 1173
1138 GvSV (PL_defgv) = newSV (0); 1174 GvSV (PL_defgv) = newSV (0);
1139 GvAV (PL_defgv) = coro->args; coro->args = 0; 1175 GvAV (PL_defgv) = coro->args; coro->args = 0;
1140 GvSV (PL_errgv) = newSV (0); 1176 GvSV (PL_errgv) = newSV (0);
1141 GvSV (irsgv) = newSVpvn ("\n", 1); sv_magic (GvSV (irsgv), (SV *)irsgv, PERL_MAGIC_sv, "/", 0); 1177 GvSV (irsgv) = newSVpvn ("\n", 1); sv_magic (GvSV (irsgv), (SV *)irsgv, PERL_MAGIC_sv, "/", 0);
1142 GvHV (PL_hintgv) = 0; 1178 GvHV (PL_hintgv) = newHV ();
1179#if PERL_VERSION_ATLEAST (5,10,0)
1180 hv_magic (GvHV (PL_hintgv), 0, PERL_MAGIC_hints);
1181#endif
1143 PL_rs = newSVsv (GvSV (irsgv)); 1182 PL_rs = newSVsv (GvSV (irsgv));
1144 PL_defoutgv = (GV *)SvREFCNT_inc_NN (stdoutgv); 1183 PL_defoutgv = (GV *)SvREFCNT_inc_NN (stdoutgv);
1145 1184
1146 { 1185 {
1147 dSP; 1186 dSP;
… …
1257 1296
1258 SvREFCNT_dec (coro->saved_deffh); 1297 SvREFCNT_dec (coro->saved_deffh);
1259 SvREFCNT_dec (coro->rouse_cb); 1298 SvREFCNT_dec (coro->rouse_cb);
1260 SvREFCNT_dec (coro->invoke_cb); 1299 SvREFCNT_dec (coro->invoke_cb);
1261 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);
1262 } 1303 }
1263} 1304}
1264 1305
1265ecb_inline void 1306ecb_inline void
1266free_coro_mortal (pTHX) 1307free_coro_mortal (pTHX)
… …
1329 1370
1330 if (PL_curcop != &PL_compiling) 1371 if (PL_curcop != &PL_compiling)
1331 { 1372 {
1332 SV **cb; 1373 SV **cb;
1333 1374
1334 if (oldcxix != cxstack_ix && cctx_current->flags & CC_TRACE_SUB) 1375 if (oldcxix != cxstack_ix && cctx_current->flags & CC_TRACE_SUB && cxstack_ix >= 0)
1335 { 1376 {
1336 PERL_CONTEXT *cx = &cxstack[cxstack_ix]; 1377 PERL_CONTEXT *cx = &cxstack[cxstack_ix];
1337 1378
1338 if (CxTYPE (cx) == CXt_SUB && oldcxix < cxstack_ix) 1379 if (CxTYPE (cx) == CXt_SUB && oldcxix < cxstack_ix)
1339 { 1380 {
… …
1926 1967
1927 ENTER; 1968 ENTER;
1928 SAVETMPS; 1969 SAVETMPS;
1929 1970
1930 PUSHMARK (SP); 1971 PUSHMARK (SP);
1931 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)));
1932 PUTBACK; 1973 PUTBACK;
1933 call_pv ("Carp::confess", G_VOID | G_DISCARD); 1974 call_pv ("Carp::confess", G_VOID | G_DISCARD);
1934 1975
1935 FREETMPS; 1976 FREETMPS;
1936 LEAVE; 1977 LEAVE;
… …
2247 slf_init_terminate_cancel_common (aTHX_ frame, coro_hv); 2288 slf_init_terminate_cancel_common (aTHX_ frame, coro_hv);
2248 } 2289 }
2249 else 2290 else
2250 { 2291 {
2251 struct coro *self = SvSTATE_current; 2292 struct coro *self = SvSTATE_current;
2293
2294 if (!self)
2295 croak ("Coro::cancel called outside of thread content,");
2252 2296
2253 /* otherwise we cancel directly, purely for speed reasons 2297 /* otherwise we cancel directly, purely for speed reasons
2254 * unfortunately, this requires some magic trickery, as 2298 * unfortunately, this requires some magic trickery, as
2255 * somebody else could cancel us, so we have to fight the cancellation. 2299 * somebody else could cancel us, so we have to fight the cancellation.
2256 * this is ugly, and hopefully fully worth the extra speed. 2300 * this is ugly, and hopefully fully worth the extra speed.
… …
2598 2642
2599/* "undo"/cancel a running slf call - used when cancelling a coro, mainly */ 2643/* "undo"/cancel a running slf call - used when cancelling a coro, mainly */
2600static void 2644static void
2601slf_destroy (pTHX_ struct coro *coro) 2645slf_destroy (pTHX_ struct coro *coro)
2602{ 2646{
2603 /* this callback is reserved for slf functions needing to do cleanup */ 2647 struct CoroSLF frame = coro->slf_frame;
2604 if (coro->slf_frame.destroy && coro->slf_frame.prepare && !PL_dirty)
2605 coro->slf_frame.destroy (aTHX_ &coro->slf_frame);
2606 2648
2607 /* 2649 /*
2608 * The on_destroy above most likely is from an SLF call. 2650 * The on_destroy below most likely is from an SLF call.
2609 * Since by definition the SLF call will not finish when we destroy 2651 * Since by definition the SLF call will not finish when we destroy
2610 * the coro, we will have to force-finish it here, otherwise 2652 * the coro, we will have to force-finish it here, otherwise
2611 * cleanup functions cannot call SLF functions. 2653 * cleanup functions cannot call SLF functions.
2612 */ 2654 */
2613 coro->slf_frame.prepare = 0; 2655 coro->slf_frame.prepare = 0;
2656
2657 /* this callback is reserved for slf functions needing to do cleanup */
2658 if (frame.destroy && frame.prepare && !PL_dirty)
2659 frame.destroy (aTHX_ &frame);
2614} 2660}
2615 2661
2616/* 2662/*
2617 * these not obviously related functions are all rolled into one 2663 * these not obviously related functions are all rolled into one
2618 * function to increase chances that they all will call transfer with the same 2664 * function to increase chances that they all will call transfer with the same
… …
2801static void 2847static void
2802coro_pop_on_leave (pTHX_ void *coro) 2848coro_pop_on_leave (pTHX_ void *coro)
2803{ 2849{
2804 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);
2805 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);
2806} 2944}
2807 2945
2808/*****************************************************************************/ 2946/*****************************************************************************/
2809/* PerlIO::cede */ 2947/* PerlIO::cede */
2810 2948
… …
2940 XPUSHs (sv_2mortal (newRV_inc ((SV *)av))); 3078 XPUSHs (sv_2mortal (newRV_inc ((SV *)av)));
2941 PUTBACK; 3079 PUTBACK;
2942 call_sv (cb, G_VOID | G_DISCARD | G_EVAL | G_KEEPERR); 3080 call_sv (cb, G_VOID | G_DISCARD | G_EVAL | G_KEEPERR);
2943 } 3081 }
2944 3082
2945 SvREFCNT_dec (cb); 3083 SvREFCNT_dec_NN (cb);
2946 } 3084 }
2947} 3085}
2948 3086
2949static void 3087static void
2950coro_semaphore_destroy (pTHX_ struct CoroSLF *frame) 3088coro_semaphore_destroy (pTHX_ struct CoroSLF *frame)
… …
2958{ 3096{
2959 AV *av = (AV *)frame->data; 3097 AV *av = (AV *)frame->data;
2960 SV *count_sv = AvARRAY (av)[0]; 3098 SV *count_sv = AvARRAY (av)[0];
2961 SV *coro_hv = SvRV (coro_current); 3099 SV *coro_hv = SvRV (coro_current);
2962 3100
3101 frame->destroy = 0;
3102
2963 /* if we are about to throw, don't actually acquire the lock, just throw */ 3103 /* if we are about to throw, don't actually acquire the lock, just throw */
2964 if (CORO_THROW) 3104 if (ecb_expect_false (CORO_THROW))
3105 {
3106 /* we still might be responsible for the semaphore, so wake up others */
3107 coro_semaphore_adjust (aTHX_ av, 0);
3108
2965 return 0; 3109 return 0;
3110 }
2966 else if (SvIVX (count_sv) > 0) 3111 else if (SvIVX (count_sv) > 0)
2967 { 3112 {
2968 frame->destroy = 0;
2969
2970 if (acquire) 3113 if (acquire)
2971 SvIVX (count_sv) = SvIVX (count_sv) - 1; 3114 SvIVX (count_sv) = SvIVX (count_sv) - 1;
2972 else 3115 else
2973 coro_semaphore_adjust (aTHX_ av, 0); 3116 coro_semaphore_adjust (aTHX_ av, 0);
2974 3117
… …
3085 { 3228 {
3086 api_ready (aTHX_ cb); 3229 api_ready (aTHX_ cb);
3087 sv_setiv (cb, 0); /* signal waiter */ 3230 sv_setiv (cb, 0); /* signal waiter */
3088 } 3231 }
3089 3232
3090 SvREFCNT_dec (cb); 3233 SvREFCNT_dec_NN (cb);
3091 3234
3092 --count; 3235 --count;
3093 } 3236 }
3094} 3237}
3095 3238
… …
3180 } 3323 }
3181 3324
3182 av_push (state, data_sv); 3325 av_push (state, data_sv);
3183 3326
3184 api_ready (aTHX_ coro); 3327 api_ready (aTHX_ coro);
3185 SvREFCNT_dec (coro); 3328 SvREFCNT_dec_NN (coro);
3186 SvREFCNT_dec ((AV *)state); 3329 SvREFCNT_dec_NN ((AV *)state);
3187} 3330}
3188 3331
3189static int 3332static int
3190slf_check_aio_req (pTHX_ struct CoroSLF *frame) 3333slf_check_aio_req (pTHX_ struct CoroSLF *frame)
3191{ 3334{
… …
3209 errno = data->errorno; 3352 errno = data->errorno;
3210 PL_laststype = data->laststype; 3353 PL_laststype = data->laststype;
3211 PL_laststatval = data->laststatval; 3354 PL_laststatval = data->laststatval;
3212 PL_statcache = data->statcache; 3355 PL_statcache = data->statcache;
3213 3356
3214 SvREFCNT_dec (data_sv); 3357 SvREFCNT_dec_NN (data_sv);
3215 } 3358 }
3216 3359
3217 /* push result values */ 3360 /* push result values */
3218 { 3361 {
3219 dSP; 3362 dSP;
… …
3434 3577
3435PROTOTYPES: DISABLE 3578PROTOTYPES: DISABLE
3436 3579
3437BOOT: 3580BOOT:
3438{ 3581{
3582#define VARx(name,expr,type) if (sizeof (type) < sizeof (expr)) croak ("FATAL: Coro thread context slot '" # name "' too small for this version of perl.");
3583#include "state.h"
3439#ifdef USE_ITHREADS 3584#ifdef USE_ITHREADS
3440# if CORO_PTHREAD 3585# if CORO_PTHREAD
3441 coro_thx = PERL_GET_CONTEXT; 3586 coro_thx = PERL_GET_CONTEXT;
3442# endif 3587# endif
3443#endif 3588#endif
… …
3829 coroapi.ready = api_ready; 3974 coroapi.ready = api_ready;
3830 coroapi.is_ready = api_is_ready; 3975 coroapi.is_ready = api_is_ready;
3831 coroapi.nready = coro_nready; 3976 coroapi.nready = coro_nready;
3832 coroapi.current = coro_current; 3977 coroapi.current = coro_current;
3833 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
3834 /*GCoroAPI = &coroapi;*/ 3983 /*GCoroAPI = &coroapi;*/
3835 sv_setiv (sv, (IV)&coroapi); 3984 sv_setiv (sv, (IV)&coroapi);
3836 SvREADONLY_on (sv); 3985 SvREADONLY_on (sv);
3837 } 3986 }
3838} 3987}
… …
3903 4052
3904void 4053void
3905_set_current (SV *current) 4054_set_current (SV *current)
3906 PROTOTYPE: $ 4055 PROTOTYPE: $
3907 CODE: 4056 CODE:
3908 SvREFCNT_dec (SvRV (coro_current)); 4057 SvREFCNT_dec_NN (SvRV (coro_current));
3909 SvRV_set (coro_current, SvREFCNT_inc_NN (SvRV (current))); 4058 SvRV_set (coro_current, SvREFCNT_inc_NN (SvRV (current)));
3910 4059
3911void 4060void
3912_set_readyhook (SV *hook) 4061_set_readyhook (SV *hook)
3913 PROTOTYPE: $ 4062 PROTOTYPE: $
… …
3997 4146
3998 if ((SV *)hv == &PL_sv_undef) 4147 if ((SV *)hv == &PL_sv_undef)
3999 { 4148 {
4000 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);
4001 hv = (HV *)SvREFCNT_inc_NN (SvRV (sv)); 4150 hv = (HV *)SvREFCNT_inc_NN (SvRV (sv));
4002 SvREFCNT_dec (sv); 4151 SvREFCNT_dec_NN (sv);
4003 } 4152 }
4004 4153
4005 { 4154 {
4006 struct coro *coro = SvSTATE_hv (hv); 4155 struct coro *coro = SvSTATE_hv (hv);
4007 4156
… …
4014 api_ready (aTHX_ (SV *)hv); 4163 api_ready (aTHX_ (SV *)hv);
4015 4164
4016 if (GIMME_V != G_VOID) 4165 if (GIMME_V != G_VOID)
4017 XPUSHs (sv_2mortal (newRV_noinc ((SV *)hv))); 4166 XPUSHs (sv_2mortal (newRV_noinc ((SV *)hv)));
4018 else 4167 else
4019 SvREFCNT_dec (hv); 4168 SvREFCNT_dec_NN (hv);
4020} 4169}
4021 4170
4022SV * 4171SV *
4023rouse_cb () 4172rouse_cb ()
4024 PROTOTYPE: 4173 PROTOTYPE:

Diff Legend

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