[ViewVC] Diff of: cvs/Coro/Coro/State.xs

Comparing Coro/Coro/State.xs (file contents):
Revision 1.194 by root, Sat Oct 6 00:08:04 2007 UTC vs.
Revision 1.196 by root, Sat Oct 6 01:11:01 2007 UTC

   /* statistics */
   int usecount; /* number of transfers to this coro */
   /* coro process data */
   int prio;
-  //SV *throw;
+  SV *throw;
   /* async_pool */
   SV *saved_deffh;
   /* linked list */
   PL_runops     = RUNOPS_DEFAULT;
   PL_curcop     = &PL_compiling;
   PL_in_eval    = EVAL_NULL;
   PL_comppad    = 0;
   PL_curpm      = 0;
+  PL_curpad     = 0;
   PL_localizing = 0;
   PL_dirty      = 0;
   PL_restartop  = 0;
   GvSV (PL_defgv)    = newSV (0);
   GvAV (PL_defgv)    = coro->args; coro->args = 0;
   GvSV (PL_errgv)    = newSV (0);
   GvSV (irsgv)       = newSVpvn ("\n", 1); sv_magic (GvSV (irsgv), (SV *)irsgv, PERL_MAGIC_sv, "/", 0);
   PL_rs              = newSVsv (GvSV (irsgv));
-  PL_defoutgv        = SvREFCNT_inc (stdoutgv);
+  PL_defoutgv        = (GV *)SvREFCNT_inc (stdoutgv);
-  ENTER; /* necessary e.g. for dounwind */
   {
     dSP;
     LOGOP myop;
     PUTBACK;
     PL_op = (OP *)&myop;
     PL_op = PL_ppaddr[OP_ENTERSUB](aTHX);
     SPAGAIN;
   }
+  ENTER; /* necessary e.g. for dounwind and to balance the xsub-entersub */
 }
 static void
 coro_destroy (pTHX_ struct coro *coro)
 {
   SvREFCNT_dec (PL_defoutgv);
   SvREFCNT_dec (PL_rs);
   SvREFCNT_dec (GvSV (irsgv));
   SvREFCNT_dec (coro->saved_deffh);
-  //SvREFCNT_dec (coro->throw);
+  SvREFCNT_dec (coro->throw);
   coro_destroy_stacks (aTHX);
 }
 static void
           coro_transfer (&prev__cctx->cctx, &next->cctx->cctx);
         }
       free_coro_mortal (aTHX);
       UNLOCK;
+      if (expect_false (prev->throw || next->throw))
+        {
+          struct coro *coro = SvSTATE (coro_current);
+          if (coro->throw)
+            {
+              SV *exception = coro->throw;
+              coro->throw = 0;
+              sv_setsv (ERRSV, exception);
+              croak (0);
+            }
+        }
     }
 }
 struct transfer_args
 {
         CODE:
         RETVAL = coro_nready;
 	OUTPUT:
         RETVAL
+void
+throw (Coro::State self, SV *throw = &PL_sv_undef)
+	PROTOTYPE: $;$
+        CODE:
+        SvREFCNT_dec (self->throw);
+        self->throw = SvOK (throw) ? newSVsv (throw) : 0;
 # for async_pool speedup
 void
 _pool_1 (SV *cb)
 	CODE:
 {

Diff Legend

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

Comparing Coro/Coro/State.xs (file contents): Revision 1.194 by root, Sat Oct 6 00:08:04 2007 UTC vs. Revision 1.196 by root, Sat Oct 6 01:11:01 2007 UTC

Diff Legend

Comparing Coro/Coro/State.xs (file contents):
Revision 1.194 by root, Sat Oct 6 00:08:04 2007 UTC vs.
Revision 1.196 by root, Sat Oct 6 01:11:01 2007 UTC