[ViewVC] Diff of: cvs/IO-AIO/AIO.xs

Comparing IO-AIO/AIO.xs (file contents):
Revision 1.115 by root, Sat May 10 18:06:41 2008 UTC vs.
Revision 1.116 by root, Sat May 10 19:25:33 2008 UTC

 #include "libeio/eio.c"
 typedef eio_req *aio_req;
 typedef eio_req *aio_req_ornot;
-static unsigned int max_outstanding = 0x7fffffff;
+static int max_outstanding = 0;
 static int next_pri = EIO_DEFAULT_PRI + EIO_PRI_BIAS;
 static int respipe_osf [2], respipe [2] = { -1, -1 };
     }
 }
 static int poll_cb (void)
 {
+  int res;
+  do
+    {
-  int res = eio_poll ();
+      res = eio_poll ();
-  if (res > 0)
+      if (res > 0)
-    croak (0);
+        croak (0);
+    }
+  while (max_outstanding && max_outstanding <= eio_nreqs ());
   return res;
+}
+static void atfork_child (void)
+{
+  create_respipe ();
 }
 #define dREQ							\
   aio_req req;							\
   int req_pri = next_pri;					\
         create_respipe ();
         if (eio_init (want_poll, done_poll) < 0)
           croak ("IO::AIO: unable to initialise eio library");
+        /* atfork child called in fifo order, so before eio's handler */
+        X_THREAD_ATFORK (0, 0, atfork_child);
 }
 void
 max_poll_reqs (int nreqs)
 	PROTOTYPE: $
 void
 flush ()
 	PROTOTYPE:
 	CODE:
-        while (nreqs)
+        while (eio_nreqs ())
           {
             poll_wait ();
             poll_cb ();
           }

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