--- IO-AIO/AIO.xs	2015/06/25 15:47:01	1.235
+++ IO-AIO/AIO.xs	2016/02/23 19:42:43	1.239
@@ -706,14 +706,14 @@
     {
       int size;
 
-      X_LOCK   (reslock);
-      size = res_queue.size;
-      X_UNLOCK (reslock);
+      X_LOCK   (EIO_POOL->reslock);
+      size = EIO_POOL->res_queue.size;
+      X_UNLOCK (EIO_POOL->reslock);
 
       if (size)
         return;
 
-      etp_maybe_start_thread ();
+      etp_maybe_start_thread (EIO_POOL);
 
       s_epipe_wait (&respipe);
     }
@@ -987,7 +987,6 @@
     const_iv (MAP_ANONYMOUS)
 
     /* linuxish */
-    const_iv (MAP_HUGETLB)
     const_iv (MAP_LOCKED)
     const_iv (MAP_NORESERVE)
     const_iv (MAP_POPULATE)
@@ -1296,6 +1295,46 @@
 
           REQ_SEND;
         }
+}
+
+void
+aio_ioctl (SV *fh, unsigned long request, SV8 *arg, SV *callback = &PL_sv_undef)
+        ALIAS:
+           aio_ioctl = EIO_IOCTL
+           aio_fcntl = EIO_FCNTL
+        PPCODE:
+{
+        int fd = s_fileno_croak (fh, 0);
+        char *svptr;
+
+        if (SvPOK (arg) || !SvNIOK (arg))
+          {
+            STRLEN svlen;
+            /* perl uses IOCPARM_LEN for fcntl, so we do, too */
+#ifdef IOCPARM_LEN
+            STRLEN need = IOCPARM_LEN (request);
+#else
+            STRLEN need = 256;
+#endif
+
+            if (svlen < need)
+              svptr = SvGROW (arg, need + 1);
+          }
+        else
+          svptr = (char *)SvIV (arg);
+
+        {
+          dREQ;
+
+          req->type = ix;
+          req->sv1  = newSVsv (fh);
+          req->int1 = fd;
+          req->int2 = (long)request;
+          req->sv2  = SvREFCNT_inc (arg);
+          req->ptr2 = svptr;
+
+          REQ_SEND;
+        }
 }
 
 void