--- IO-AIO/AIO.xs	2006/10/24 16:35:04	1.71
+++ IO-AIO/AIO.xs	2006/10/24 17:22:17	1.72
@@ -242,6 +242,7 @@
 
 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)
@@ -470,17 +471,25 @@
   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)
-    {
-      aio_req sub;
-
-      for (sub = req->grp_first; sub; sub = sub->grp_next)
-        req_cancel (sub);
-    }
+  req_cancel_subs (req);
 }
 
 static int poll_cb ()
@@ -1497,6 +1506,11 @@
 }
 
 void
+cancel_subs (aio_req_ornot req)
+	CODE:
+        req_cancel_subs (req);
+
+void
 result (aio_req grp, ...)
         CODE:
 {