[ViewVC] Diff of: cvs/libeio/eio.c

Comparing libeio/eio.c (file contents):
Revision 1.79 by root, Tue Jul 5 16:57:41 2011 UTC vs.
Revision 1.80 by root, Tue Jul 5 18:59:28 2011 UTC

 #include <limits.h>
 #include <fcntl.h>
 #include <assert.h>
 /* intptr_t comes from unistd.h, says POSIX/UNIX/tradition */
-/* intptr_t only comes form stdint.h, says idiot openbsd coder */
+/* intptr_t only comes from stdint.h, says idiot openbsd coder */
 #if HAVE_STDINT_H
 # include <stdint.h>
 #endif
+#ifndef ECANCELED
+# define ECANCELED EDOM
+#endif
+static void eio_destroy (eio_req *req);
 #ifndef EIO_FINISH
 # define EIO_FINISH(req)  ((req)->finish) && !EIO_CANCELLED (req) ? (req)->finish (req) : 0
 #endif
     return eio_finish (grp);
   else
     return 0;
 }
-void
+static void
 eio_destroy (eio_req *req)
 {
   if ((req)->flags & EIO_FLAG_PTR1_FREE) free (req->ptr1);
   if ((req)->flags & EIO_FLAG_PTR2_FREE) free (req->ptr2);
       X_UNLOCK (reqlock);
       if (req->type < 0)
         goto quit;
-      if (!EIO_CANCELLED (req))
-        ETP_EXECUTE (self, req);
+      ETP_EXECUTE (self, req);
       X_LOCK (reslock);
       ++npending;
     }
 static void
 eio_execute (etp_worker *self, eio_req *req)
 {
+  if (ecb_expect_false (EIO_CANCELLED (req)))
+    {
+      req->result  = -1;
+      req->errorno = ECANCELED;
+      return;
+    }
   switch (req->type)
     {
       case EIO_READ:      ALLOC (req->size);
                           req->result = req->offs >= 0
                                       ? pread     (req->int1, req->ptr2, req->size, req->offs)

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