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

Comparing IO-AIO/AIO.xs (file contents):
Revision 1.71 by root, Tue Oct 24 16:35:04 2006 UTC vs.
Revision 1.73 by root, Tue Oct 24 21:26:30 2006 UTC

   abort ();
 }
 static void req_invoke (aio_req req);
 static void req_free (aio_req req);
+static void req_cancel (aio_req req);
 /* must be called at most once */
 static SV *req_sv (aio_req req, const char *klass)
 {
   if (!req->self)
     free (req->data2ptr);
   Safefree (req);
 }
+static void req_cancel_subs (aio_req grp)
+{
+  aio_req sub;
+  if (grp->type != REQ_GROUP)
+    return;
+  SvREFCNT_dec (grp->fh2);
+  grp->fh2 = 0;
+  for (sub = grp->grp_first; sub; sub = sub->grp_next)
+    req_cancel (sub);
+}
 static void req_cancel (aio_req req)
 {
   req->flags |= FLAG_CANCELLED;
-  if (req->type == REQ_GROUP)
+  req_cancel_subs (req);
-    {
-      aio_req sub;
-      for (sub = req->grp_first; sub; sub = sub->grp_next)
-        req_cancel (sub);
-    }
 }
 static int poll_cb ()
 {
   dSP;
 static void *aio_proc(void *arg);
 static void start_thread (void)
 {
+  sigset_t fullsigset, oldsigset;
+  pthread_attr_t attr;
   worker *wrk = calloc (1, sizeof (worker));
   if (!wrk)
     croak ("unable to allocate worker thread data");
-  sigset_t fullsigset, oldsigset;
-  pthread_attr_t attr;
   pthread_attr_init (&attr);
   pthread_attr_setstacksize (&attr, STACKSIZE);
   pthread_attr_setdetachstate (&attr, PTHREAD_CREATE_DETACHED);
               }
           }
 }
 void
+cancel_subs (aio_req_ornot req)
+	CODE:
+        req_cancel_subs (req);
+void
 result (aio_req grp, ...)
         CODE:
 {
         int i;
         AV *av = newAV ();

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