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

Comparing libeio/eio.c (file contents):
Revision 1.90 by root, Sat Jul 16 16:46:10 2011 UTC vs.
Revision 1.93 by root, Mon Jul 18 01:27:03 2011 UTC

   #define fsync(fd)            (FlushFileBuffers ((HANDLE)EIO_FD_TO_WIN32_HANDLE (fd)) ? 0 : EIO_ERRNO (EBADF, -1))
   #define mkdir(path,mode)     _mkdir (path)
   #define link(old,neu)        (CreateHardLink (neu, old, 0) ? 0 : EIO_ERRNO (ENOENT, -1))
   #define chmod(path,mode)     _chmod (path, mode)
+  #define dup(fd)              _dup (fd)
+  #define dup2(fd1,fd2)        _dup2 (fd1, fd2)
   #define fchmod(fd,mode)      EIO_ENOSYS ()
   #define chown(path,uid,gid)  EIO_ENOSYS ()
   #define fchown(fd,uid,gid)   EIO_ENOSYS ()
   #define truncate(path,offs)  EIO_ENOSYS () /* far-miss: SetEndOfFile */
   #define ftruncate(fd,offs)   EIO_ENOSYS () /* near-miss: SetEndOfFile */
     return EIO_ERRNO (ENOENT, -1);
   }
   /* POSIX API only */
-  #define CreateHardLink(neu,old) 0
+  #define CreateHardLink(neu,old,flags) 0
   #define CreateSymbolicLink(neu,old,flags) 0
   struct statvfs
   {
     int dummy;
   };
+  #define DT_DIR EIO_DT_DIR
+  #define DT_REG EIO_DT_REG
+  #define D_NAME(entp) entp.cFileName
+  #define D_TYPE(entp) (entp.dwFileAttributes & FILE_ATTRIBUTE_DIRECTORY ? DT_DIR : DT_REG)
 #else
   #include <sys/time.h>
   #include <sys/select.h>
   #include <dirent.h>
   #if _POSIX_MEMLOCK || _POSIX_MEMLOCK_RANGE || _POSIX_MAPPED_FILES
     #include <sys/mman.h>
   #endif
+  #define D_NAME(entp) entp->d_name
   /* POSIX_SOURCE is useless on bsd's, and XOPEN_SOURCE is unreliable there, too */
   #if __FreeBSD__ || defined __NetBSD__ || defined __OpenBSD__
     #define _DIRENT_HAVE_D_TYPE /* sigh */
     #define D_INO(de) (de)->d_fileno
 #endif
 #ifndef D_INO
 # define D_INO(de) 0
 #endif
 #ifndef D_NAMLEN
-# define D_NAMLEN(de) strlen ((de)->d_name)
+# define D_NAMLEN(entp) strlen (D_NAME (entp))
 #endif
 /* used for struct dirent, AIX doesn't provide it */
 #ifndef NAME_MAX
 # define NAME_MAX 4096
 #define ETP_WORKER_CLEAR(req)	\
   if (wrk->dbuf)		\
     {				\
       free (wrk->dbuf);		\
       wrk->dbuf = 0;		\
-    }				\
-				\
-  if (wrk->dirp)		\
-    {				\
-      closedir (wrk->dirp);	\
-      wrk->dirp = 0;		\
     }
 #define ETP_WORKER_COMMON \
-  void *dbuf;	\
+  void *dbuf;
-  DIR *dirp;
 /*****************************************************************************/
 #define ETP_NUM_PRI (ETP_PRI_MAX - ETP_PRI_MIN + 1)
 /*
  * make our pread/pwrite emulation safe against themselves, but not against
  * normal read/write by using a mutex. slows down execution a lot,
  * but that's your problem, not mine.
  */
-static xmutex_t preadwritelock = X_MUTEX_INIT;
+static xmutex_t preadwritelock;
 #endif
 typedef struct etp_worker
 {
   /* locked by wrklock */
   ETP_REQ *req; /* currently processed request */
   ETP_WORKER_COMMON
 } etp_worker;
-static etp_worker wrk_first = { &wrk_first, &wrk_first, 0 }; /* NOT etp */
+static etp_worker wrk_first; /* NOT etp */
 #define ETP_WORKER_LOCK(wrk)   X_LOCK   (wrklock)
 #define ETP_WORKER_UNLOCK(wrk) X_UNLOCK (wrklock)
 /* worker threads management */
 } etp_reqq;
 static etp_reqq req_queue;
 static etp_reqq res_queue;
+static void ecb_noinline ecb_cold
+reqq_init (etp_reqq *q)
+{
+  int pri;
+  for (pri = 0; pri < ETP_NUM_PRI; ++pri)
+    q->qs[pri] = q->qe[pri] = 0;
+  q->size = 0;
+}
 static int ecb_noinline
 reqq_push (etp_reqq *q, ETP_REQ *req)
 {
   int pri = req->pri;
   req->next = 0;
     }
   abort ();
 }
-static void ecb_cold
+static int ecb_cold
-etp_thread_init (void)
+etp_init (void (*want_poll)(void), void (*done_poll)(void))
 {
-#if !HAVE_PREADWRITE
-  X_MUTEX_CREATE (preadwritelock);
-#endif
   X_MUTEX_CREATE (wrklock);
   X_MUTEX_CREATE (reslock);
   X_MUTEX_CREATE (reqlock);
   X_COND_CREATE  (reqwait);
-}
-static void ecb_cold
+  reqq_init (&req_queue);
-etp_atfork_prepare (void)
+  reqq_init (&res_queue);
-{
-}
-static void ecb_cold
+  wrk_first.next =
-etp_atfork_parent (void)
+  wrk_first.prev = &wrk_first;
-{
-}
-static void ecb_cold
-etp_atfork_child (void)
-{
-  ETP_REQ *prv;
-  while ((prv = reqq_shift (&req_queue)))
-    ETP_DESTROY (prv);
-  while ((prv = reqq_shift (&res_queue)))
-    ETP_DESTROY (prv);
-  while (wrk_first.next != &wrk_first)
-    {
-      etp_worker *wrk = wrk_first.next;
-      if (wrk->req)
-        ETP_DESTROY (wrk->req);
-      etp_worker_clear (wrk);
-      etp_worker_free (wrk);
-    }
   started  = 0;
   idle     = 0;
   nreqs    = 0;
   nready   = 0;
   npending = 0;
-  etp_thread_init ();
-}
-static void ecb_cold
-etp_once_init (void)
-{
-  etp_thread_init ();
-  X_THREAD_ATFORK (etp_atfork_prepare, etp_atfork_parent, etp_atfork_child);
-}
-static int ecb_cold
-etp_init (void (*want_poll)(void), void (*done_poll)(void))
-{
-  static pthread_once_t doinit = PTHREAD_ONCE_INIT;
-  pthread_once (&doinit, etp_once_init);
   want_poll_cb = want_poll;
   done_poll_cb = done_poll;
   return 0;
 #define EIO_SORT_CUTOFF 30 /* quite high, but performs well on many filesystems */
 #define EIO_SORT_FAST   60 /* when to only use insertion sort */
 static void
-eio_dent_radix_sort (eio_dirent *dents, int size, signed char score_bits, ino_t inode_bits)
+eio_dent_radix_sort (eio_dirent *dents, int size, signed char score_bits, eio_ino_t inode_bits)
 {
-  unsigned char bits [9 + sizeof (ino_t) * 8];
+  unsigned char bits [9 + sizeof (eio_ino_t) * 8];
   unsigned char *bit = bits;
   assert (CHAR_BIT == 8);
   assert (sizeof (eio_dirent) * 8 < 256);
   assert (offsetof (eio_dirent, inode)); /* we use bit #0 as sentinel */
   if (size <= EIO_SORT_FAST)
     return;
   /* first prepare an array of bits to test in our radix sort */
-  /* try to take endianness into account, as well as differences in ino_t sizes */
+  /* try to take endianness into account, as well as differences in eio_ino_t sizes */
   /* inode_bits must contain all inodes ORed together */
   /* which is used to skip bits that are 0 everywhere, which is very common */
   {
-    ino_t endianness;
+    eio_ino_t endianness;
     int i, j;
     /* we store the byte offset of byte n into byte n of "endianness" */
-    for (i = 0; i < sizeof (ino_t); ++i)
+    for (i = 0; i < sizeof (eio_ino_t); ++i)
       ((unsigned char *)&endianness)[i] = i;
     *bit++ = 0;
-    for (i = 0; i < sizeof (ino_t); ++i)
+    for (i = 0; i < sizeof (eio_ino_t); ++i)
       {
         /* shifting off the byte offsets out of "endianness" */
         int offs = (offsetof (eio_dirent, inode) + (endianness & 0xff)) * 8;
         endianness >>= 8;
         for (j = 0; j < 8; ++j)
-          if (inode_bits & (((ino_t)1) << (i * 8 + j)))
+          if (inode_bits & (((eio_ino_t)1) << (i * 8 + j)))
             *bit++ = offs + j;
       }
     for (j = 0; j < 8; ++j)
       if (score_bits & (1 << j))
         *bit++ = offsetof (eio_dirent, score) * 8 + j;
   }
   /* now actually do the sorting (a variant of MSD radix sort) */
   {
-    eio_dirent    *base_stk [9 + sizeof (ino_t) * 8], *base;
+    eio_dirent    *base_stk [9 + sizeof (eio_ino_t) * 8], *base;
-    eio_dirent    *end_stk  [9 + sizeof (ino_t) * 8], *end;
+    eio_dirent    *end_stk  [9 + sizeof (eio_ino_t) * 8], *end;
-    unsigned char *bit_stk  [9 + sizeof (ino_t) * 8];
+    unsigned char *bit_stk  [9 + sizeof (eio_ino_t) * 8];
     int stk_idx = 0;
     base_stk [stk_idx] = dents;
     end_stk  [stk_idx] = dents + size;
     bit_stk  [stk_idx] = bit - 1;
       }
   }
 }
 static void
-eio_dent_sort (eio_dirent *dents, int size, signed char score_bits, ino_t inode_bits)
+eio_dent_sort (eio_dirent *dents, int size, signed char score_bits, eio_ino_t inode_bits)
 {
   if (size <= 1)
     return; /* our insertion sort relies on size > 0 */
   /* first we use a radix sort, but only for dirs >= EIO_SORT_FAST */
 /* read a full directory */
 static void
 eio__scandir (eio_req *req, etp_worker *self)
 {
-  DIR *dirp;
-  EIO_STRUCT_DIRENT *entp;
   char *name, *names;
-  int namesalloc = 4096;
+  int namesalloc = 4096 - sizeof (void *) * 4;
   int namesoffs = 0;
   int flags = req->int1;
   eio_dirent *dents = 0;
   int dentalloc = 128;
   int dentoffs = 0;
-  ino_t inode_bits = 0;
+  eio_ino_t inode_bits = 0;
+#ifdef _WIN32
+  HANDLE dirp;
+  WIN32_FIND_DATA entp;
+#else
+  DIR *dirp;
+  EIO_STRUCT_DIRENT *entp;
+#endif
   req->result = -1;
   if (!(flags & EIO_READDIR_DENTS))
     flags &= ~(EIO_READDIR_DIRS_FIRST | EIO_READDIR_STAT_ORDER);
-  X_LOCK (wrklock);
+#ifdef _WIN32
-  /* the corresponding closedir is in ETP_WORKER_CLEAR */
+  {
+    int len = strlen ((const char *)req->ptr1);
+    char *path = malloc (MAX_PATH);
+    const char *fmt;
+    if (!len)
+      fmt = "./*";
+    else if (((const char *)req->ptr1)[len - 1] == '/' || ((const char *)req->ptr1)[len - 1] == '\\')
+      fmt = "%s*";
+    else
+      fmt = "%s/*";
+    _snprintf (path, MAX_PATH, fmt, (const char *)req->ptr1);
+    dirp = FindFirstFile (path, &entp);
+    free (path);
+    if (dirp == INVALID_HANDLE_VALUE)
+     {
+       dirp = 0;
+        switch (GetLastError ())
+          {
+            case ERROR_FILE_NOT_FOUND:
+              req->result = 0;
+              break;
+            case ERROR_INVALID_NAME:
+            case ERROR_PATH_NOT_FOUND:
+            case ERROR_NO_MORE_FILES:
+              errno = ENOENT;
+              break;
+            case ERROR_NOT_ENOUGH_MEMORY:
+              errno = ENOMEM;
+              break;
+            default:
+              errno = EINVAL;
+              break;
+          }
+     }
+  }
+#else
-  self->dirp = dirp = opendir (req->ptr1);
+  dirp = opendir (req->ptr1);
+#endif
   if (req->flags & EIO_FLAG_PTR1_FREE)
     free (req->ptr1);
   req->flags |= EIO_FLAG_PTR1_FREE | EIO_FLAG_PTR2_FREE;
   req->ptr1 = dents = flags ? malloc (dentalloc * sizeof (eio_dirent)) : 0;
   req->ptr2 = names = malloc (namesalloc);
-  X_UNLOCK (wrklock);
   if (dirp && names && (!flags || dents))
     for (;;)
       {
+        int done;
+#ifdef _WIN32
+        done = !dirp;
+#else
         errno = 0;
         entp = readdir (dirp);
+        done = !entp;
+#endif
-        if (!entp)
+        if (done)
           {
+#ifndef _WIN32
+            int old_errno = errno;
+            closedir (dirp);
+            errno = old_errno;
             if (errno)
               break;
+#endif
             /* sort etc. */
             req->int1   = flags;
             req->result = dentoffs;
             break;
           }
         /* now add the entry to our list(s) */
-        name = entp->d_name;
+        name = D_NAME (entp);
         /* skip . and .. entries */
         if (name [0] != '.' || (name [1] && (name [1] != '.' || name [2])))
           {
             int len = D_NAMLEN (entp) + 1;
             while (ecb_expect_false (namesoffs + len > namesalloc))
               {
                 namesalloc *= 2;
-                X_LOCK (wrklock);
                 req->ptr2 = names = realloc (names, namesalloc);
-                X_UNLOCK (wrklock);
                 if (!names)
                   break;
               }
                 struct eio_dirent *ent;
                 if (ecb_expect_false (dentoffs == dentalloc))
                   {
                     dentalloc *= 2;
-                    X_LOCK (wrklock);
                     req->ptr1 = dents = realloc (dents, dentalloc * sizeof (eio_dirent));
-                    X_UNLOCK (wrklock);
                     if (!dents)
                       break;
                   }
         if (EIO_CANCELLED (req))
           {
             errno = ECANCELED;
             break;
           }
+#ifdef _WIN32
+        if (!FindNextFile (dirp, &entp))
+          {
+            FindClose (dirp);
+            dirp = 0;
+          }
+#endif
       }
 }
 /*****************************************************************************/
 X_THREAD_PROC (etp_proc)
 {
   ETP_REQ *req;
   struct timespec ts;
   etp_worker *self = (etp_worker *)thr_arg;
-  int timeout;
   /* try to distribute timeouts somewhat evenly */
   ts.tv_nsec = ((unsigned long)self & 1023UL) * (1000000000UL / 1024UL);
   for (;;)
 /*****************************************************************************/
 int ecb_cold
 eio_init (void (*want_poll)(void), void (*done_poll)(void))
 {
+#if !HAVE_PREADWRITE
+  X_MUTEX_CREATE (preadwritelock);
+#endif
   return etp_init (want_poll, done_poll);
 }
 ecb_inline void
 eio_api_destroy (eio_req *req)

Diff Legend

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

Comparing libeio/eio.c (file contents): Revision 1.90 by root, Sat Jul 16 16:46:10 2011 UTC vs. Revision 1.93 by root, Mon Jul 18 01:27:03 2011 UTC

Diff Legend

Comparing libeio/eio.c (file contents):
Revision 1.90 by root, Sat Jul 16 16:46:10 2011 UTC vs.
Revision 1.93 by root, Mon Jul 18 01:27:03 2011 UTC