[ViewVC] Diff of: cvs/Coro-Multicore/Multicore.xs

Comparing Coro-Multicore/Multicore.xs (file contents):
Revision 1.10 by root, Fri Jul 3 02:55:10 2015 UTC vs.
Revision 1.11 by root, Sun Jul 5 02:52:15 2015 UTC

 struct tctx
 {
   void *coro;
   int wait_f;
   xcond_t acquire_c;
+  int jeret;
 };
 static struct tctx *tctx_free;
 static struct tctx *
 {
   PERL_SET_CONTEXT (perl_thx);
   {
     dTHX; /* inefficient, we already have perl_thx, but I see no better way */
+    dJMPENV;
     struct tctx *ctx;
+    int catchret;
     X_LOCK (release_m);
     for (;;)
       {
         if (!ctx) /* timed out? */
           break;
         pthread_sigmask (SIG_SETMASK, &cursigset, 0);
+        JMPENV_PUSH (ctx->jeret);
+        if (!ctx->jeret)
-        while (ctx->coro)
+          while (ctx->coro)
-          CORO_SCHEDULE;
+            CORO_SCHEDULE;
+        JMPENV_POP;
         pthread_sigmask (SIG_SETMASK, &fullsigset, &cursigset);
         X_LOCK (acquire_m);
         ctx->wait_f = 1;
         X_COND_SIGNAL (ctx->acquire_c);
 }
 static void
 pmapi_acquire (void)
 {
+  int jeret;
   struct tctx *ctx = pthread_getspecific (current_key);
   if (!ctx)
     return;
   s_epipe_signal (&ep);
   while (!ctx->wait_f)
     X_COND_WAIT (ctx->acquire_c, acquire_m);
   X_UNLOCK (acquire_m);
+  jeret = ctx->jeret;
   tctx_put (ctx);
   pthread_sigmask (SIG_SETMASK, &cursigset, 0);
+  if (jeret)
+    JMPENV_JUMP (jeret);
 }
 static void
 set_thread_enable (pTHX_ void *arg)
 {

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