--- IO-AIO/AIO.xs	2009/07/17 00:56:54	1.155
+++ IO-AIO/AIO.xs	2010/01/02 14:11:32	1.158
@@ -101,13 +101,11 @@
 
 /*****************************************************************************/
 
-static HV *stash;
 typedef SV SV8; /* byte-sv, used for argument-checking */
 typedef int aio_rfd; /* read file desriptor */
 typedef int aio_wfd; /* write file descriptor */
 
-#define AIO_REQ_KLASS "IO::AIO::REQ"
-#define AIO_GRP_KLASS "IO::AIO::GRP"
+static HV *aio_stash, *aio_req_stash, *aio_grp_stash;
 
 #define EIO_REQ_MEMBERS	\
   SV *callback;		\
@@ -180,7 +178,7 @@
 }
 
 /* must be called at most once */
-static SV *req_sv (aio_req req, const char *klass)
+static SV *req_sv (aio_req req, HV *stash)
 {
   if (!req->self)
     {
@@ -188,15 +186,18 @@
       sv_magic (req->self, 0, PERL_MAGIC_ext, (char *)req, 0);
     }
 
-  return sv_2mortal (sv_bless (newRV_inc (req->self), gv_stashpv (klass, 1)));
+  return sv_2mortal (sv_bless (newRV_inc (req->self), stash));
 }
 
 static aio_req SvAIO_REQ (SV *sv)
 {
   MAGIC *mg;
 
-  if (!sv_derived_from (sv, AIO_REQ_KLASS) || !SvROK (sv))
-    croak ("object of class " AIO_REQ_KLASS " expected");
+  if (!SvROK (sv)
+      || (SvSTASH (SvRV (sv)) != aio_grp_stash
+          && SvSTASH (SvRV (sv)) != aio_req_stash
+          && !sv_derived_from (sv, "IO::AIO::REQ")))
+    croak ("object of class IO::AIO::REQ expected");
 
   mg = mg_find (SvRV (sv), PERL_MAGIC_ext);
 
@@ -212,7 +213,7 @@
       ENTER;
       SAVETMPS;
       PUSHMARK (SP);
-      XPUSHs (req_sv (grp, AIO_GRP_KLASS));
+      XPUSHs (req_sv (grp, aio_grp_stash));
       PUTBACK;
       call_sv (grp->sv2, G_VOID | G_EVAL | G_KEEPERR);
       SPAGAIN;
@@ -328,7 +329,7 @@
                   int symlen;
                   
                   symlen = snprintf (sym, sizeof (sym), "fd#%d", (int)req->result);
-                  gv_init (gv, stash, sym, symlen, 0);
+                  gv_init (gv, aio_stash, sym, symlen, 0);
 
                   symlen = snprintf (
                      sym,
@@ -516,7 +517,7 @@
   SPAGAIN;							\
 								\
   if (GIMME_V != G_VOID)					\
-    XPUSHs (req_sv (req, AIO_REQ_KLASS));
+    XPUSHs (req_sv (req, aio_req_stash));
 
 MODULE = IO::AIO                PACKAGE = IO::AIO
 
@@ -546,6 +547,12 @@
     const_iv (FADV_WILLNEED  , POSIX_FADV_WILLNEED)
     const_iv (FADV_DONTNEED  , POSIX_FADV_DONTNEED)
 
+    const_eio (MS_ASYNC)
+    const_eio (MS_INVALIDATE)
+    const_eio (MS_SYNC)
+
+    const_eio (MT_MODIFY)
+
     const_eio (SYNC_FILE_RANGE_WAIT_BEFORE)
     const_eio (SYNC_FILE_RANGE_WRITE)
     const_eio (SYNC_FILE_RANGE_WAIT_AFTER)
@@ -566,10 +573,12 @@
     const_eio (DT_WHT)
   };
 
-  stash = gv_stashpv ("IO::AIO", 1);
+  aio_stash     = gv_stashpv ("IO::AIO"     , 1);
+  aio_req_stash = gv_stashpv ("IO::AIO::REQ", 1);
+  aio_grp_stash = gv_stashpv ("IO::AIO::GRP", 1);
 
   for (civ = const_iv + sizeof (const_iv) / sizeof (const_iv [0]); civ-- > const_iv; )
-    newCONSTSUB (stash, (char *)civ->name, newSViv (civ->iv));
+    newCONSTSUB (aio_stash, (char *)civ->name, newSViv (civ->iv));
 
   create_respipe ();
 
@@ -994,6 +1003,40 @@
 }
 
 void
+aio_mtouch (SV8 *data, IV offset = 0, SV *length = &PL_sv_undef, int flags = 0, SV *callback=&PL_sv_undef)
+        ALIAS:
+           aio_mtouch = EIO_MTOUCH
+           aio_msync  = EIO_MSYNC
+	PROTOTYPE: $$$$;$
+        PPCODE:
+{
+        STRLEN svlen;
+        UV len = SvUV (length);
+        char *svptr = SvPVbyte (data, svlen);
+
+        if (offset < 0)
+          offset += svlen;
+
+        if (offset < 0 || offset > svlen)
+          croak ("offset outside of scalar");
+
+        if (!SvOK (length) || len + offset > svlen)
+          len = svlen - offset;
+
+        {
+          dREQ;
+
+          req->type = ix;
+          req->size = len;
+          req->sv2  = SvREFCNT_inc (data);
+          req->ptr2 = (char *)svptr + offset;
+          req->int1 = flags;
+
+          REQ_SEND;
+        }
+}
+
+void
 aio_busy (double delay, SV *callback=&PL_sv_undef)
 	PPCODE:
 {
@@ -1015,7 +1058,7 @@
         req->type = EIO_GROUP;
 
         req_submit (req);
-        XPUSHs (req_sv (req, AIO_GRP_KLASS));
+        XPUSHs (req_sv (req, aio_grp_stash));
 }
 
 void
@@ -1143,7 +1186,9 @@
 sendfile (aio_wfd ofh, aio_rfd ifh, off_t offset, size_t count)
         PROTOTYPE: $$$$
         CODE:
-        eio_sendfile_sync (ofh, ifh, offset, count);
+        RETVAL = eio_sendfile_sync (ofh, ifh, offset, count);
+	OUTPUT:
+        RETVAL
 
 void _on_next_submit (SV *cb)
 	CODE: