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

Comparing Coro/Coro/State.xs (file contents):
Revision 1.114 by root, Thu Nov 30 21:22:45 2006 UTC vs.
Revision 1.115 by root, Fri Dec 1 13:36:08 2006 UTC

 #include "patchlevel.h"
 #if USE_VALGRIND
 # include <valgrind/valgrind.h>
 #endif
+/* the maximum number of idle cctx that will be pooled */
+#define MAX_IDLE_CCTX 8
 #define PERL_VERSION_ATLEAST(a,b,c)				\
   (PERL_REVISION > (a)						\
    || (PERL_REVISION == (a)					\
        && (PERL_VERSION > (b)					\
   return cctx;
 }
 static void
-cctx_free (coro_cctx *cctx)
+cctx_destroy (coro_cctx *cctx)
 {
   if (!cctx)
     return;
   --cctx_count;
 {
   coro_cctx *cctx;
   if (cctx_first)
     {
-      --cctx_idle;
       cctx = cctx_first;
       cctx_first = cctx->next;
+      --cctx_idle;
     }
   else
    {
      cctx = cctx_new ();
      PL_op = PL_op->op_next;
 }
 static void
 cctx_put (coro_cctx *cctx)
 {
+  /* free another cctx if overlimit */
+  if (cctx_idle >= MAX_IDLE_CCTX)
+    {
+      coro_cctx *first = cctx_first;
+      cctx_first = first->next;
+      --cctx_idle;
+      assert (!first->inuse);
+      cctx_destroy (first);
+    }
   ++cctx_idle;
   cctx->next = cctx_first;
   cctx_first = cctx;
 }
       LOAD ((&temp)); /* this will get rid of defsv etc.. */
       coro->mainstack = 0;
     }
-  cctx_free (coro->cctx);
+  cctx_destroy (coro->cctx);
   SvREFCNT_dec (coro->args);
   Safefree (coro);
 }
 static int

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