]> arthur.barton.de Git - netatalk.git/blobdiff - libatalk/adouble/ad_open.c
remove gcc warnings and cleanup inline mess
[netatalk.git] / libatalk / adouble / ad_open.c
index 3f8b7a60ff752f155d7436dd8f1b9185a486c934..086b5d850fd02c0996aacd4a6c90e2e046a00b52 100644 (file)
@@ -1,5 +1,5 @@
 /*
- * $Id: ad_open.c,v 1.12 2002-01-04 04:45:48 sibaz Exp $
+ * $Id: ad_open.c,v 1.30.6.18.2.8 2008-11-25 15:16:33 didg Exp $
  *
  * Copyright (c) 1999 Adrian Sun (asun@u.washington.edu)
  * Copyright (c) 1990,1991 Regents of The University of Michigan.
  *     Ann Arbor, Michigan
  *     +1-313-763-0525
  *     netatalk@itd.umich.edu
+ * 
+ * NOTE: I don't use inline because a good compiler should be
+ * able to optimize all the static below. Didier
  */
 
 #ifdef HAVE_CONFIG_H
 #include "config.h"
 #endif /* HAVE_CONFIG_H */
 
-#include <string.h>
-#ifdef HAVE_FCNTL_H
-#include <fcntl.h>
-#endif /* HAVE_FCNTL_H */
-#ifdef HAVE_UNISTD_H
-#include <unistd.h>
-#endif /* HAVE_UNISTD_H */
 #include <errno.h>
-#include <atalk/logger.h>
 
-#include <sys/time.h>
-#include <sys/types.h>
-#include <sys/stat.h>
+#include <atalk/adouble.h>
 #include <sys/param.h>
-#include <sys/mman.h>
+#include <atalk/logger.h>
 
-#include <netatalk/endian.h>
-#include <atalk/adouble.h>
+#include <atalk/util.h>
+#include <string.h>
 
 #include "ad_private.h"
+#include <stdlib.h>
 
 #ifndef MAX
 #define MAX(a, b)  ((a) < (b) ? (b) : (a))
@@ -94,7 +88,6 @@
 #undef ADEDOFF_FILEI
 #endif /* ADEDOFF_FILEI */
 
-#define ADEID_NUM_V1         5
 #define ADEDOFF_NAME_V1             (AD_HEADER_LEN + ADEID_NUM_V1*AD_ENTRY_LEN)
 #define ADEDOFF_COMMENT_V1   (ADEDOFF_NAME_V1 + ADEDLEN_NAME)
 #define ADEDOFF_FILEI        (ADEDOFF_COMMENT_V1 + ADEDLEN_COMMENT)
 /* i stick things in a slightly different order than their eid order in 
  * case i ever want to separate RootInfo behaviour from the rest of the 
  * stuff. */
-#define ADEID_NUM_V2         9
 #define ADEDOFF_NAME_V2      (AD_HEADER_LEN + ADEID_NUM_V2*AD_ENTRY_LEN)
 #define ADEDOFF_COMMENT_V2   (ADEDOFF_NAME_V2 + ADEDLEN_NAME)
 #define ADEDOFF_FILEDATESI   (ADEDOFF_COMMENT_V2 + ADEDLEN_COMMENT)
 #define ADEDOFF_AFPFILEI     (ADEDOFF_DID + ADEDLEN_DID)
 #define ADEDOFF_SHORTNAME    (ADEDOFF_AFPFILEI + ADEDLEN_AFPFILEI)
 #define ADEDOFF_PRODOSFILEI  (ADEDOFF_SHORTNAME + ADEDLEN_SHORTNAME)
-#define ADEDOFF_RFORK_V2     (ADEDOFF_PRODOSFILEI + ADEDLEN_PRODOSFILEI)
+#define ADEDOFF_PRIVDEV      (ADEDOFF_PRODOSFILEI + ADEDLEN_PRODOSFILEI)
+#define ADEDOFF_PRIVINO      (ADEDOFF_PRIVDEV + ADEDLEN_PRIVDEV)
+#define ADEDOFF_PRIVSYN      (ADEDOFF_PRIVINO + ADEDLEN_PRIVINO)
+#define ADEDOFF_PRIVID       (ADEDOFF_PRIVSYN + ADEDLEN_PRIVSYN)
 
+#define ADEDOFF_RFORK_V2     (ADEDOFF_PRIVID + ADEDLEN_PRIVID)
 
+#define ADEID_NUM_OSX        2
+#define ADEDOFF_FINDERI_OSX  (AD_HEADER_LEN + ADEID_NUM_OSX*AD_ENTRY_LEN)
+#define ADEDOFF_RFORK_OSX    (ADEDOFF_FINDERI_OSX + ADEDLEN_FINDERI)
 
 /* we keep local copies of a bunch of stuff so that we can initialize things 
  * correctly. */
 
-/* Bits in the finderinfo data. 
- * see etc/afpd/{directory.c,file.c} for the finderinfo structure
- * layout. */
-#define FINDERINFO_CUSTOMICON 0x4
-#define FINDERINFO_CLOSEDVIEW 0x100
-
-/* offsets in finderinfo */
-#define FINDERINFO_FRTYPEOFF   0
-#define FINDERINFO_FRCREATOFF  4
-#define FINDERINFO_FRFLAGOFF   8
-#define FINDERINFO_FRVIEWOFF  14
-
 /* invisible bit for dot files */
 #define ATTRBIT_INVISIBLE     (1 << 0)
-#define FINDERINFO_INVISIBLE  (1 << 14)
 
 /* this is to prevent changing timezones from causing problems with
    localtime volumes. the screw-up is 30 years. we use a delta of 5
@@ -146,17 +132,41 @@ struct entry {
   u_int32_t id, offset, len;
 };
 
-#if AD_VERSION == AD_VERSION1 
-static const struct entry entry_order[] = {
-  {ADEID_NAME, ADEDOFF_NAME_V1, ADEDLEN_INIT},
-  {ADEID_COMMENT, ADEDOFF_COMMENT_V1, ADEDLEN_INIT},
-  {ADEID_FILEI, ADEDOFF_FILEI, ADEDLEN_FILEI},
-  {ADEID_FINDERI, ADEDOFF_FINDERI_V1, ADEDLEN_FINDERI},
-  {ADEID_RFORK, ADEDOFF_RFORK_V1, ADEDLEN_INIT},
+static const struct entry entry_order1[ADEID_NUM_V1 +1] = {
+  {ADEID_NAME,    ADEDOFF_NAME_V1,    ADEDLEN_INIT},      /* 3 */
+  {ADEID_COMMENT, ADEDOFF_COMMENT_V1, ADEDLEN_INIT},      /* 4 */
+  {ADEID_FILEI,   ADEDOFF_FILEI,      ADEDLEN_FILEI},     /* 7 */
+  {ADEID_FINDERI, ADEDOFF_FINDERI_V1, ADEDLEN_FINDERI},   /* 9 */
+  {ADEID_RFORK,   ADEDOFF_RFORK_V1,   ADEDLEN_INIT},      /* 2 */
   {0, 0, 0}
 };
+
+#if AD_VERSION == AD_VERSION1 
+#define DISK_EID(ad, a) (a)
+
 #else /* AD_VERSION == AD_VERSION2 */
-static const struct entry entry_order[] = {
+
+static u_int32_t get_eid(struct adouble *ad, u_int32_t eid) 
+{
+    if (eid <= 15)
+        return eid;
+    if (ad->ad_version == AD_VERSION1)
+        return 0;
+    if (eid == AD_DEV)
+        return ADEID_PRIVDEV;
+    if (eid == AD_INO)
+        return ADEID_PRIVINO;
+    if (eid == AD_SYN)
+        return ADEID_PRIVSYN;
+    if (eid == AD_ID)
+        return ADEID_PRIVID;
+
+    return 0;
+}
+
+#define DISK_EID(ad, a) get_eid(ad, a)
+
+static const struct entry entry_order2[ADEID_NUM_V2 +1] = {
   {ADEID_NAME, ADEDOFF_NAME_V2, ADEDLEN_INIT},
   {ADEID_COMMENT, ADEDOFF_COMMENT_V2, ADEDLEN_INIT},
   {ADEID_FILEDATESI, ADEDOFF_FILEDATESI, ADEDLEN_FILEDATESI},
@@ -165,72 +175,245 @@ static const struct entry entry_order[] = {
   {ADEID_AFPFILEI, ADEDOFF_AFPFILEI, ADEDLEN_AFPFILEI},
   {ADEID_SHORTNAME, ADEDOFF_SHORTNAME, ADEDLEN_INIT},
   {ADEID_PRODOSFILEI, ADEDOFF_PRODOSFILEI, ADEDLEN_PRODOSFILEI},
+  {ADEID_PRIVDEV,     ADEDOFF_PRIVDEV, ADEDLEN_INIT},
+  {ADEID_PRIVINO,     ADEDOFF_PRIVINO, ADEDLEN_INIT},
+  {ADEID_PRIVSYN,     ADEDOFF_PRIVSYN, ADEDLEN_INIT},
+  {ADEID_PRIVID,     ADEDOFF_PRIVID, ADEDLEN_INIT},
   {ADEID_RFORK, ADEDOFF_RFORK_V2, ADEDLEN_INIT},
+
   {0, 0, 0}
 };
+
+/* OS X adouble finder info and resource fork only
+*/
+static const struct entry entry_order_osx[ADEID_NUM_OSX +1] = {
+  {ADEID_FINDERI, ADEDOFF_FINDERI_OSX, ADEDLEN_FINDERI},
+  {ADEID_RFORK, ADEDOFF_RFORK_OSX, ADEDLEN_INIT},
+
+  {0, 0, 0}
+};
+
 #endif /* AD_VERSION == AD_VERSION2 */
 
 #if AD_VERSION == AD_VERSION2
 
+/* update a version 2 adouble resource fork with our private entries */
+static int ad_update(struct adouble *ad, const char *path)
+{
+  struct stat st;
+  u_int16_t nentries = 0;
+  off_t     off, shiftdata=0;
+  const struct entry  *eid;
+  static off_t entry_len[ADEID_MAX];
+  static char  databuf[ADEID_MAX][256], *buf;
+  int fd;
+  int ret = -1;
+
+  /* check to see if we should convert this header. */
+  if (!path || ad->ad_flags != AD_VERSION2)
+    return 0;
+  
+  if (!(ad->ad_hf.adf_flags & O_RDWR)) {
+      /* we were unable to open the file read write the last time */
+      return 0;
+  }
+
+  if (ad->ad_eid[ADEID_RFORK].ade_off) {
+      shiftdata = ADEDOFF_RFORK_V2 -ad->ad_eid[ADEID_RFORK].ade_off;
+  }
+
+  memcpy(&nentries, ad->ad_data + ADEDOFF_NENTRIES, sizeof( nentries ));
+  nentries = ntohs( nentries );
+
+  if ( shiftdata == 0 && nentries == ADEID_NUM_V2)
+    return 0;
+
+  memset(entry_len, 0, sizeof(entry_len));
+  memset(databuf, 0, sizeof(databuf));
+
+  /* bail if we can't get a lock */
+  if (ad_tmplock(ad, ADEID_RFORK, ADLOCK_WR, 0, 0, 0) < 0)
+    goto bail_err;
+
+  fd = ad->ad_hf.adf_fd;
+
+  if (fstat(fd, &st)) {
+    goto bail_lock;
+  }
+
+  if (st.st_size > 0x7fffffff) {
+      LOG(log_debug, logtype_default, "ad_update: file '%s' too big for update.", path);
+      errno = EIO;
+      goto bail_lock;
+  }
+
+  off = ad->ad_eid[ADEID_RFORK].ade_off;
+  if (off > st.st_size) {
+      LOG(log_error, logtype_default, "ad_update: invalid resource fork offset. (off: %u)", off); 
+      errno = EIO;
+      goto bail_lock;
+  }
+
+  if (ad->ad_eid[ADEID_RFORK].ade_len > st.st_size - off) {
+      LOG(log_error, logtype_default, "ad_update: invalid resource fork length. (rfork len: %u)", ad->ad_eid[ADEID_RFORK].ade_len); 
+      errno = EIO;
+      goto bail_lock;
+  }
+  
+  if ((void *) (buf = (char *)
+                mmap(NULL, st.st_size + shiftdata,
+                     PROT_READ | PROT_WRITE, MAP_SHARED, fd, 0)) ==
+          MAP_FAILED) {
+    goto bail_lock;
+  }
+
+  /* last place for failure. */
+  if (sys_ftruncate(fd, st.st_size + shiftdata) < 0) {
+    goto bail_lock;
+  }
+
+  /* move the RFORK. this assumes that the RFORK is at the end */
+  if (off) {
+    memmove(buf + ADEDOFF_RFORK_V2, buf + off, ad->ad_eid[ADEID_RFORK].ade_len);
+  }
+
+  munmap(buf, st.st_size + shiftdata);
+
+  /* now, fix up our copy of the header */
+  memset(ad->ad_filler, 0, sizeof(ad->ad_filler));
+  /* save the header entries */ 
+  eid = entry_order2;
+  while (eid->id) {
+    if( ad->ad_eid[eid->id].ade_off != 0) {
+      if ( eid->id > 2 && ad->ad_eid[eid->id].ade_len < 256)
+        memcpy( databuf[eid->id], ad->ad_data +ad->ad_eid[eid->id].ade_off, ad->ad_eid[eid->id].ade_len);
+      entry_len[eid->id] = ad->ad_eid[eid->id].ade_len;
+    }
+    eid++;
+  }
 
-static __inline__ int ad_v1tov2(struct adouble *ad, const char *path)
+  memset(ad->ad_data + AD_HEADER_LEN, 0, AD_DATASZ - AD_HEADER_LEN);
+
+  /* copy the saved entries to the new header */
+  eid = entry_order2;
+  while (eid->id) {
+    if ( eid->id > 2 && entry_len[eid->id] > 0) {
+      memcpy(ad->ad_data+eid->offset, databuf[eid->id], entry_len[eid->id]);
+    }
+    ad->ad_eid[eid->id].ade_off = eid->offset;
+    ad->ad_eid[eid->id].ade_len = entry_len[eid->id];
+    eid++;
+  }
+
+  /* rebuild the header and cleanup */
+  LOG(log_debug, logtype_default, "updated AD2 header %s", path);
+  ad_flush(ad, ADFLAGS_HF );
+  ret = 0;
+
+bail_lock:
+  ad_tmplock(ad, ADEID_RFORK, ADLOCK_CLR, 0, 0, 0);
+bail_err:
+  return ret;
+}
+
+/* ------------------------------------------
+   FIXME work only if < 2GB 
+*/
+static int ad_convert(struct adouble *ad, const char *path)
 {
   struct stat st;
-  struct timeval tv;
   u_int16_t attr;
   char *buf;
   int fd, off;
+  int ret = -1;
+  /* use resource fork offset from file */
+  int shiftdata;
+  int toV2;
+  int toV1;
+  
+  if (!path) {
+      return 0;
+  }
   
+  if (!(ad->ad_hf.adf_flags & ( O_RDWR))) {
+      /* we were unable to open the file read write the last time */
+      return 0;
+  }
+
   /* check to see if we should convert this header. */
-  if (!path || (ad->ad_version != AD_VERSION1))
-    return 0;
+  toV2 = ad->ad_version == AD_VERSION1 && ad->ad_flags == AD_VERSION2;
+  toV1 = ad->ad_version == AD_VERSION2 && ad->ad_flags == AD_VERSION1;
+
+  if (!toV2 && !toV1)
+      return 0;
 
   /* convert from v1 to v2. what does this mean?
    *  1) change FILEI into FILEDATESI
    *  2) create space for SHORTNAME, AFPFILEI, DID, and PRODOSI
    *  3) move FILEI attributes into AFPFILEI
    *  4) initialize ACCESS field of FILEDATESI.
-   *
-   *  so, we need 4*12 (entry ids) + 12 (shortname) + 4 (afpfilei) +
-   *  4 (did) + 8 (prodosi) = 76 more bytes.  */
+   *  5) move the resource fork
+   */
   
-#define SHIFTDATA (AD_DATASZ2 - AD_DATASZ1)
-
   /* bail if we can't get a lock */
-  if (ad_tmplock(ad, ADEID_RFORK, ADLOCK_WR, 0, 0) < 0) 
+  if (ad_tmplock(ad, ADEID_RFORK, ADLOCK_WR, 0, 0, 0) < 0) 
     goto bail_err;
+
+  /* we reuse fd from the resource fork */
+  fd = ad->ad_hf.adf_fd;
+
+  if (ad->ad_eid[ADEID_RFORK].ade_off) {
+      shiftdata = ADEDOFF_RFORK_V2 -ad->ad_eid[ADEID_RFORK].ade_off;
+  }
+  else {
+      shiftdata = ADEDOFF_RFORK_V2 -ADEDOFF_RFORK_V1; /* 136 */
+  }
+
+  if (fstat(fd, &st)) { 
+      goto bail_lock;
+  }
+
+  if (st.st_size > 0x7fffffff -shiftdata) {
+      LOG(log_debug, logtype_default, "ad_v1tov2: file too big."); 
+      errno = EIO;
+      goto bail_lock;
+  }
   
-  if ((fd = open(path, O_RDWR)) < 0) 
-    goto bail_lock;
-  
-  if (gettimeofday(&tv, NULL) < 0) 
-    goto bail_lock;
-  
-  if (fstat(fd, &st) ||
-      ftruncate(fd, st.st_size + SHIFTDATA) < 0) {
-    goto bail_open;
+  off = ad->ad_eid[ADEID_RFORK].ade_off;
+
+  if (off > st.st_size) {
+      LOG(log_error, logtype_default, "ad_v1tov2: invalid resource fork offset. (off: %u)", off); 
+      errno = EIO;
+      goto bail_lock;
+  }
+
+  if (ad->ad_eid[ADEID_RFORK].ade_len > st.st_size - off) {
+      LOG(log_error, logtype_default, "ad_v1tov2: invalid resource fork length. (rfork len: %u)", ad->ad_eid[ADEID_RFORK].ade_len); 
+      errno = EIO;
+      goto bail_lock;
   }
   
-  /* last place for failure. */
   if ((void *) (buf = (char *) 
-               mmap(NULL, st.st_size + SHIFTDATA,
+               mmap(NULL, st.st_size + shiftdata,
                     PROT_READ | PROT_WRITE, MAP_SHARED, fd, 0)) == 
          MAP_FAILED) {
-    goto bail_truncate;
+    goto bail_lock;
   }
-  
-  off = ad->ad_eid[ADEID_RFORK].ade_off;
 
-#ifdef USE_MMAPPED_HEADERS
-  /* okay, unmap our old ad header and point it to our local copy */
-  munmap(ad->ad_data, off);
-  ad->ad_data = buf;
-#endif /* USER_MMAPPED_HEADERS */
+  /* last place for failure. */
 
-  /* move the RFORK. this assumes that the RFORK is at the end */
-  memmove(buf + off + SHIFTDATA, buf + off, 
-         ad->ad_eid[ADEID_RFORK].ade_len);
+  if (sys_ftruncate(fd, st.st_size + shiftdata) < 0) {
+      goto bail_lock;
+  }
   
+  /* move the RFORK. this assumes that the RFORK is at the end */
+  if (off) {
+      memmove(buf + ADEDOFF_RFORK_V2, buf + off, ad->ad_eid[ADEID_RFORK].ade_len);
+  }
+
+  munmap(buf, st.st_size + shiftdata);
+
   /* now, fix up our copy of the header */
   memset(ad->ad_filler, 0, sizeof(ad->ad_filler));
   
@@ -251,22 +434,31 @@ static __inline__ int ad_v1tov2(struct adouble *ad, const char *path)
   ad->ad_eid[ADEID_PRODOSFILEI].ade_off = ADEDOFF_PRODOSFILEI;
   ad->ad_eid[ADEID_PRODOSFILEI].ade_len = ADEDLEN_PRODOSFILEI;
   
+  ad->ad_eid[ADEID_PRIVDEV].ade_off = ADEDOFF_PRIVDEV;
+  ad->ad_eid[ADEID_PRIVDEV].ade_len = ADEDLEN_INIT;
+  ad->ad_eid[ADEID_PRIVINO].ade_off = ADEDOFF_PRIVINO;
+  ad->ad_eid[ADEID_PRIVINO].ade_len = ADEDLEN_INIT;
+  ad->ad_eid[ADEID_PRIVSYN].ade_off = ADEDOFF_PRIVSYN;
+  ad->ad_eid[ADEID_PRIVSYN].ade_len = ADEDLEN_INIT;
+  ad->ad_eid[ADEID_PRIVID].ade_off  = ADEDOFF_PRIVID;
+  ad->ad_eid[ADEID_PRIVID].ade_len =  ADEDLEN_INIT;
+  
   /* shift the old entries (NAME, COMMENT, FINDERI, RFORK) */
   ad->ad_eid[ADEID_NAME].ade_off = ADEDOFF_NAME_V2;
   ad->ad_eid[ADEID_COMMENT].ade_off = ADEDOFF_COMMENT_V2;
   ad->ad_eid[ADEID_FINDERI].ade_off = ADEDOFF_FINDERI_V2;
   ad->ad_eid[ADEID_RFORK].ade_off = ADEDOFF_RFORK_V2;
   
-  /* switch to v2 */
-  ad->ad_version = AD_VERSION2;
+  /* switch to dest version */
+  ad->ad_version = (toV2)?AD_VERSION2:AD_VERSION1;
   
   /* move our data buffer to make space for the new entries. */
-  memmove(buf + ADEDOFF_NAME_V2, buf + ADEDOFF_NAME_V1,
+  memmove(ad->ad_data + ADEDOFF_NAME_V2, ad->ad_data + ADEDOFF_NAME_V1,
          ADEDOFF_RFORK_V1 - ADEDOFF_NAME_V1);
   
   /* now, fill in the space with appropriate stuff. we're
      operating as a v2 file now. */
-  ad_setdate(ad, AD_DATE_ACCESS | AD_DATE_UNIX, tv.tv_sec);
+  ad_setdate(ad, AD_DATE_ACCESS | AD_DATE_UNIX, st.st_mtime);
   memset(ad_entry(ad, ADEID_DID), 0, ADEDLEN_DID);
   memset(ad_entry(ad, ADEID_AFPFILEI), 0, ADEDLEN_AFPFILEI);
   ad_setattr(ad, attr);
@@ -274,44 +466,58 @@ static __inline__ int ad_v1tov2(struct adouble *ad, const char *path)
   memset(ad_entry(ad, ADEID_PRODOSFILEI), 0, ADEDLEN_PRODOSFILEI);
   
   /* rebuild the header and cleanup */
-  ad_rebuild_header(ad);
-  munmap(buf, st.st_size + SHIFTDATA);
-  close(fd);
-  ad_tmplock(ad, ADEID_RFORK, ADLOCK_CLR, 0, 0);
-
-#ifdef USE_MMAPPED_HEADERS
-  /* now remap our header */
-  ad->ad_data = mmap(NULL, ADEDOFF_RFORK_V2, PROT_READ | PROT_WRITE,
-                    (ad_getoflags(ad, ADFLAGS_HF) & O_RDWR) ? MAP_SHARED :
-                    MAP_PRIVATE, ad->ad_hf.adf_fd, 0);
-  if (ad->ad_data == MAP_FAILED)
-    goto bail_err;
-#endif /* USE_MMAPPED_HEADERS */
-
-  return 0;
+  ad_flush(ad, ADFLAGS_HF );
+  ret = 0;
   
-bail_truncate:
-  ftruncate(fd, st.st_size);
-bail_open:
-  close(fd);
 bail_lock:
-  ad_tmplock(ad, ADEID_RFORK, ADLOCK_CLR, 0, 0);
+  ad_tmplock(ad, ADEID_RFORK, ADLOCK_CLR, 0, 0, 0);
 bail_err:
-  return -1;
+  return ret;
 }
 #endif /* AD_VERSION == AD_VERSION2 */
 
+/* --------------------------- */
+#ifdef ATACC
+mode_t ad_hf_mode (mode_t mode)
+{
+    /* we always need RW mode for file owner */
+#if 0
+    mode |= S_IRUSR;
+#endif    
+    mode &= ~(S_IXUSR | S_IXGRP | S_IXOTH);
+    /* fnctl lock need write access */
+    if ((mode & S_IRUSR))
+        mode |= S_IWUSR;
+    if ((mode & S_IRGRP))
+        mode |= S_IWGRP;
+    if ((mode & S_IROTH))
+        mode |= S_IWOTH;
+    /* if write mode set add read mode */
+    if ((mode & S_IWUSR))
+        mode |= S_IRUSR;
+    if ((mode & S_IWGRP))
+        mode |= S_IRGRP;
+    if ((mode & S_IWOTH))
+        mode |= S_IROTH;
+
+    return mode;
+}
 
-/* read in the entries */
-static __inline__ void parse_entries(struct adouble *ad, char *buf,
+#endif
+
+/* ------------------------------------- 
+  read in the entries 
+*/
+static void parse_entries(struct adouble *ad, char *buf,
                                    u_int16_t nentries)
 {
-    u_int32_t          eid, len, off;
+    u_int32_t  eid, len, off;
+    int         warning = 0;
 
     /* now, read in the entry bits */
     for (; nentries > 0; nentries-- ) {
        memcpy(&eid, buf, sizeof( eid ));
-       eid = ntohl( eid );
+       eid = DISK_EID(ad, ntohl( eid ));
        buf += sizeof( eid );
        memcpy(&off, buf, sizeof( off ));
        off = ntohl( off );
@@ -320,11 +526,13 @@ static __inline__ void parse_entries(struct adouble *ad, char *buf,
        len = ntohl( len );
        buf += sizeof( len );
 
-       if ( 0 < eid && eid < ADEID_MAX ) {
+       if (eid && eid < ADEID_MAX && ( (off < sizeof(ad->ad_data) && 
+                off +len <= sizeof(ad->ad_data)) || eid == ADEID_RFORK)) {
            ad->ad_eid[ eid ].ade_off = off;
            ad->ad_eid[ eid ].ade_len = len;
-       } else {
-           LOG(log_debug, logtype_default, "ad_refresh: nentries %hd  eid %d\n",
+       } else if (!warning) {
+           warning = 1;
+           LOG(log_debug, logtype_default, "ad_refresh: nentries %hd  eid %d",
                    nentries, eid );
        }
     }
@@ -338,36 +546,26 @@ static __inline__ void parse_entries(struct adouble *ad, char *buf,
  * NOTE: we're assuming that the resource fork is kept at the end of
  *       the file. also, mmapping won't work for the hfs fs until it
  *       understands how to mmap header files. */
-static __inline__ int ad_header_read(struct adouble *ad)
+static int ad_header_read(struct adouble *ad, struct stat *hst)
 {
-#ifdef USE_MMAPPED_HEADERS
-    char                buf[AD_ENTRY_LEN*ADEID_MAX];
-#else /* USE_MMAPPED_HEADERS */
     char                *buf = ad->ad_data;
-#endif /* USE_MMAPPED_HEADERS */
     u_int16_t           nentries;
     int                 len;
+    ssize_t             header_len;
     static int          warning = 0;
+    struct stat         st;
 
     /* read the header */
-    if ( ad->ad_hf.adf_off != 0 ) {
-      if ( lseek( ad->ad_hf.adf_fd, 0L, SEEK_SET ) < 0L ) {
-               return( -1 );
-      }
-      ad->ad_hf.adf_off = 0;
+    if ((header_len = adf_pread( &ad->ad_hf, buf, sizeof(ad->ad_data), 0)) < 0) {
+       return -1;
     }
-
-    if (read( ad->ad_hf.adf_fd, buf, AD_HEADER_LEN) != AD_HEADER_LEN) {
-       if ( errno == 0 ) {
-           errno = EIO;
-       }
-       return( -1 );
+    if (header_len < AD_HEADER_LEN) {
+        errno = EIO;
+        return -1;
     }
-    ad->ad_hf.adf_off = AD_HEADER_LEN;
 
     memcpy(&ad->ad_magic, buf, sizeof( ad->ad_magic ));
-    memcpy(&ad->ad_version, buf + ADEDOFF_VERSION, 
-          sizeof( ad->ad_version ));
+    memcpy(&ad->ad_version, buf + ADEDOFF_VERSION, sizeof( ad->ad_version ));
 
     /* tag broken v1 headers. just assume they're all right. 
      * we detect two cases: null magic/version
@@ -382,8 +580,7 @@ static __inline__ int ad_header_read(struct adouble *ad)
       ad->ad_magic = AD_MAGIC;
       ad->ad_version = AD_VERSION1;
 
-    } else if ((ad->ad_magic == AD_MAGIC) && 
-              (ad->ad_version == AD_VERSION1)) {
+    } else if (ad->ad_magic == AD_MAGIC && ad->ad_version == AD_VERSION1) {
       if (!warning) {
        LOG(log_debug, logtype_default, "notice: fixing up byte-swapped v1 magic/version.");
        warning++;
@@ -411,66 +608,51 @@ static __inline__ int ad_header_read(struct adouble *ad)
     /* read in all the entry headers. if we have more than the 
      * maximum, just hope that the rfork is specified early on. */
     len = nentries*AD_ENTRY_LEN;
-#ifdef USE_MMAPPED_HEADERS
-    if (len > sizeof(buf))
-      len = sizeof(buf);
-#else /* USE_MMAPPED_HEADERS */
+
     if (len + AD_HEADER_LEN > sizeof(ad->ad_data))
       len = sizeof(ad->ad_data) - AD_HEADER_LEN;
+
     buf += AD_HEADER_LEN;
-#endif /* USE_MMAPPED_HEADERS */
-    if (read(ad->ad_hf.adf_fd, buf, len) != len) {
-        if (errno == 0)
-           errno = EIO;
+    if (len > header_len - AD_HEADER_LEN) {
+        errno = EIO;
        LOG(log_debug, logtype_default, "ad_header_read: can't read entry info.");
        return -1;
     }
-    ad->ad_hf.adf_off += len;
 
     /* figure out all of the entry offsets and lengths. if we aren't
      * able to read a resource fork entry, bail. */
+    nentries = len / AD_ENTRY_LEN;
     parse_entries(ad, buf, nentries);
     if (!ad_getentryoff(ad, ADEID_RFORK)
-#ifndef USE_MMAPPED_HEADERS
        || (ad_getentryoff(ad, ADEID_RFORK) > sizeof(ad->ad_data))
-#endif /* ! USE_MMAPPED_HEADERS */
        ) {
-      LOG(log_debug, logtype_default, "ad_header_read: problem with rfork entry offset."); 
-      return -1;
+        errno = EIO;
+        LOG(log_debug, logtype_default, "ad_header_read: problem with rfork entry offset."); 
+        return -1;
     }
 
-    /* read/mmap up to the beginning of the resource fork. */
-#ifdef USE_MMAPPED_HEADERS
-    ad->ad_data = mmap(NULL, ad_getentryoff(ad, ADEID_RFORK),
-                      PROT_READ | PROT_WRITE,
-                      (ad_getoflags(ad, ADFLAGS_HF) & O_RDWR) ? MAP_SHARED :
-                      MAP_PRIVATE, ad->ad_hf.adf_fd, 0);
-    if (ad->ad_data == MAP_FAILED) 
-      return -1;
-#else /* USE_MMAPPED_HEADERS */
-    buf += len;
-    len = ad_getentryoff(ad, ADEID_RFORK) - ad->ad_hf.adf_off;
-    if (read(ad->ad_hf.adf_fd, buf, len) != len) {
-        if (errno == 0)
-           errno = EIO;
+    if (ad_getentryoff(ad, ADEID_RFORK) > header_len) {
+       errno = EIO;
        LOG(log_debug, logtype_default, "ad_header_read: can't read in entries.");
        return -1;
     }
-#endif /* USE_MMAPPED_HEADERS */
     
+    if (hst == NULL) {
+        hst = &st;
+        if (fstat(ad->ad_hf.adf_fd, &st) < 0) {
+           return 1; /* fail silently */
+        }
+    }
+    ad->ad_rlen = hst->st_size - ad_getentryoff(ad, ADEID_RFORK);
+
     /* fix up broken dates */
     if (ad->ad_version == AD_VERSION1) {
-      struct stat st;
       u_int32_t aint;
       
-      if (fstat(ad->ad_hf.adf_fd, &st) < 0) {
-       return 1; /* fail silently */
-      }
-      
       /* check to see if the ad date is wrong. just see if we have
       * a modification date in the future. */
       if (((ad_getdate(ad, AD_DATE_MODIFY | AD_DATE_UNIX, &aint)) == 0) &&
-         (aint > TIMEWARP_DELTA + st.st_mtime)) {
+         (aint > TIMEWARP_DELTA + hst->st_mtime)) {
        ad_setdate(ad, AD_DATE_MODIFY | AD_DATE_UNIX, aint - AD_DATE_DELTA);
        ad_getdate(ad, AD_DATE_CREATE | AD_DATE_UNIX, &aint);
        ad_setdate(ad, AD_DATE_CREATE | AD_DATE_UNIX, aint - AD_DATE_DELTA);
@@ -482,69 +664,99 @@ static __inline__ int ad_header_read(struct adouble *ad)
     return 0;
 }
 
-
-/*
+/* ---------------------------------------
  * Put the .AppleDouble where it needs to be:
  *
  *         /   a/.AppleDouble/b
  *     a/b
  *         \   b/.AppleDouble/.Parent
+ *
+ * FIXME: should do something for pathname > MAXPATHLEN
  */
 char *
 ad_path( path, adflags )
-    char       *path;
+    const char *path;
     int                adflags;
 {
     static char        pathbuf[ MAXPATHLEN + 1];
     char       c, *slash, buf[MAXPATHLEN + 1];
+    size_t      l;
 
-    strncpy(buf, path, MAXPATHLEN);
+    l = strlcpy(buf, path, MAXPATHLEN +1);
     if ( adflags & ADFLAGS_DIR ) {
-       strncpy( pathbuf, buf, MAXPATHLEN );
-       if ( *buf != '\0' ) {
-           strcat( pathbuf, "/" );
+       strcpy( pathbuf, buf);
+       if ( *buf != '\0' && l < MAXPATHLEN) {
+           pathbuf[l++] = '/';
+           pathbuf[l] = 0;
        }
        slash = ".Parent";
     } else {
-       if (( slash = strrchr( buf, '/' )) != NULL ) {
+       if (NULL != ( slash = strrchr( buf, '/' )) ) {
            c = *++slash;
            *slash = '\0';
-           strncpy( pathbuf, buf, MAXPATHLEN);
+           strcpy( pathbuf, buf);
            *slash = c;
        } else {
            pathbuf[ 0 ] = '\0';
            slash = buf;
        }
     }
-    strncat( pathbuf, ".AppleDouble/", MAXPATHLEN - strlen(pathbuf));
-    strncat( pathbuf, slash, MAXPATHLEN - strlen(pathbuf));
+    strlcat( pathbuf, ".AppleDouble/", MAXPATHLEN +1);
+    strlcat( pathbuf, slash, MAXPATHLEN +1);
 
     return( pathbuf );
 }
 
+/* ---------------------------------------
+ * Put the resource fork where it needs to be:
+ * ._name
+ */
+char *
+ad_path_osx( const char        *path, int adflags _U_)
+{
+    static char        pathbuf[ MAXPATHLEN + 1];
+    char       c, *slash, buf[MAXPATHLEN + 1];
+    
+    if (!strcmp(path,".")) {
+            /* fixme */
+        getcwd(buf, MAXPATHLEN);
+    }
+    else {
+        strlcpy(buf, path, MAXPATHLEN +1);
+    }
+    if (NULL != ( slash = strrchr( buf, '/' )) ) {
+       c = *++slash;
+       *slash = '\0';
+       strlcpy( pathbuf, buf, MAXPATHLEN +1);
+       *slash = c;
+    } else {
+       pathbuf[ 0 ] = '\0';
+       slash = buf;
+    }
+    strlcat( pathbuf, "._", MAXPATHLEN  +1);  
+    strlcat( pathbuf, slash, MAXPATHLEN +1);
+    return pathbuf;
+}
+
 /*
  * Support inherited protection modes for AppleDouble files.  The supplied
  * mode is ANDed with the parent directory's mask value in lieu of "umask",
  * and that value is returned.
  */
 
-#define DEFMASK 7700   /* be conservative */
+#define DEFMASK 07700  /* be conservative */
 
-int
-ad_mode( path, mode )
-    char               *path;
-    int                        mode;
+char 
+*ad_dir(path)
+    const char         *path;
 {
     static char                modebuf[ MAXPATHLEN + 1];
-    struct stat                stbuf;
     char               *slash;
+    size_t              len;
 
-    if ( mode == 0 ) {
-       return( mode );         /* save on syscalls */
-    }
-
-    if ( strlen( path ) >= MAXPATHLEN ) {
-       return( mode & DEFMASK );  /* can't do it */
+    if ( (len = strlen( path )) >= MAXPATHLEN ) {
+        errno = ENAMETOOLONG;
+       return NULL;  /* can't do it */
     }
 
     /*
@@ -553,18 +765,108 @@ ad_mode( path, mode )
      * For a path which is just a filename, use "." instead.
      */
     strcpy( modebuf, path );
-    if (( slash = strrchr( modebuf, '/' )) != NULL ) {
+    slash = strrchr( modebuf, '/' );
+    /* is last char a '/' */
+    if (slash && slash[1] == 0) {
+        while (modebuf < slash && slash[-1] == '/') {
+            --slash;
+        }
+        if (modebuf < slash) {
+           *slash = '\0';              /* remove pathname component */
+           slash = strrchr( modebuf, '/' );
+       }
+    }
+    if (slash) {
        *slash = '\0';          /* remove pathname component */
     } else {
        modebuf[0] = '.';       /* use current directory */
        modebuf[1] = '\0';
     }
+    return modebuf;
+}
+
+/* ---------------- */
+static uid_t default_uid = -1;
+
+int ad_setfuid(const uid_t id)
+{
+    default_uid = id;
+    return 0;
+}
+
+/* ---------------- */
+uid_t ad_getfuid(void) 
+{
+    return default_uid;
+}
+
+/* ---------------- 
+   return inode of path parent directory
+*/
+int ad_stat(const char *path, struct stat *stbuf)
+{
+    char                *p;
+
+    p = ad_dir(path);
+    if (!p) {
+        return -1;
+    }
+
+    return stat( p, stbuf );
+}
+
+/* ---------------- 
+   if we are root change path user/ group
+   It can be a native function for BSD cf. FAQ.Q10
+   path:  pathname to chown 
+   stbuf: parent directory inode
+   
+   use fstat and fchown or lchown with linux?
+*/
+#define EMULATE_SUIDDIR
+static int ad_chown(const char *path, struct stat *stbuf)
+{
+int ret = 0;
+#ifdef EMULATE_SUIDDIR
+uid_t id;
+
+    if (default_uid != (uid_t)-1) {  
+        /* we are root (admin) */
+        id = (default_uid)?default_uid:stbuf->st_uid;
+       ret = chown( path, id, stbuf->st_gid );
+    }
+#endif    
+    return ret;
+}
 
-    if ( stat( modebuf, &stbuf ) != 0 ) {
-       return( mode & DEFMASK );       /* bail out... can't stat dir? */
+/* ---------------- 
+   return access right and inode of path parent directory
+*/
+static int ad_mode_st(const char *path, int *mode, struct stat *stbuf)
+{
+    if (*mode == 0) {
+       return -1;
+    }
+    if (ad_stat(path, stbuf) != 0) {
+       *mode &= DEFMASK;
+       return -1;
     }
+    *mode &= stbuf->st_mode;
+    return 0;    
+}
 
-    return( mode & stbuf.st_mode );
+/* ---------------- 
+   return access right of path parent directory
+*/
+int
+ad_mode( path, mode )
+    const char         *path;
+    int                        mode;
+{
+    struct stat                stbuf;
+    ad_mode_st(path, &mode, &stbuf);
+    return mode;
 }
 
 /*
@@ -572,240 +874,352 @@ ad_mode( path, mode )
  */
 int
 ad_mkdir( path, mode )
-    char               *path;
+    const char         *path;
     int                        mode;
 {
+int ret;
+int st_invalid;
+struct stat stbuf;
+
 #ifdef DEBUG
     LOG(log_info, logtype_default, "ad_mkdir: Creating directory with mode %d", mode);
 #endif /* DEBUG */
-    return mkdir( path, ad_mode( path, mode ) );
+
+    st_invalid = ad_mode_st(path, &mode, &stbuf);
+    ret = mkdir( path, mode );
+    if (ret || st_invalid)
+       return ret;
+    ad_chown(path, &stbuf);
+
+    return ret;    
+}
+
+/* ----------------- */
+static int ad_error(struct adouble *ad, int adflags)
+{
+int err = errno;
+    if ((adflags & ADFLAGS_NOHF)) {
+        /* FIXME double check : set header offset ?*/
+        return 0;
+    }
+    if ((adflags & ADFLAGS_DF)) {
+       ad_close( ad, ADFLAGS_DF );
+       err = errno;
+    }
+    return -1 ;
 }
 
+static int new_rfork(const char *path, struct adouble *ad, int adflags);
 
-/*
+#ifdef  HAVE_PREAD
+#define AD_SET(a) 
+#else 
+#define AD_SET(a) a = 0
+#endif
+
+void ad_init(struct adouble *ad, int flags, int options)
+{
+    memset( ad, 0, sizeof( struct adouble ) );
+    ad->ad_flags = flags;
+    if (flags == AD_VERSION2_OSX) {
+        ad->ad_path     = ad_path_osx;
+    }
+    else {
+        ad->ad_path     = ad_path;
+    }
+    ad->ad_options = options;
+}
+
+/* -------------------
  * It's not possible to open the header file O_RDONLY -- the read
  * will fail and return an error. this refcounts things now. 
  */
 int ad_open( path, adflags, oflags, mode, ad )
-    char               *path;
+    const char         *path;
     int                        adflags, oflags, mode;
     struct adouble     *ad;
 {
-    const struct entry  *eid;
     struct stat         st;
     char               *slash, *ad_p;
     int                        hoflags, admode;
-    u_int16_t           ashort;
-
+    int                 st_invalid = -1;
+    int                 open_df = 0;
+    
     if (ad->ad_inited != AD_INITED) {
         ad_dfileno(ad) = -1;
         ad_hfileno(ad) = -1;
        adf_lock_init(&ad->ad_df);
        adf_lock_init(&ad->ad_hf);
-#ifdef USE_MMAPPED_HEADERS
-       ad->ad_data = MAP_FAILED;
-#endif /* USE_MMAPPED_HEADERS */
         ad->ad_inited = AD_INITED;
         ad->ad_refcount = 1;
     }
 
-    if (adflags & ADFLAGS_DF) { 
+    if ((adflags & ADFLAGS_DF)) { 
         if (ad_dfileno(ad) == -1) {
-         if (( ad->ad_df.adf_fd =
-               open( path, oflags, ad_mode( path, mode ) )) < 0 ) {
-           return( -1 );
+         hoflags = (oflags & ~(O_RDONLY | O_WRONLY)) | O_RDWR;
+         admode = mode;
+         if ((oflags & O_CREAT)) {
+             st_invalid = ad_mode_st(path, &admode, &st);
+             if ((ad->ad_options & ADVOL_UNIXPRIV)) {
+                 admode = mode;
+             }
+         }
+          ad->ad_df.adf_fd =open( path, hoflags, admode );
+         if (ad->ad_df.adf_fd < 0 ) {
+             if ((errno == EACCES || errno == EROFS) && !(oflags & O_RDWR)) {
+                hoflags = oflags;
+                ad->ad_df.adf_fd = open( path, hoflags, admode );
+             }
+         }
+         if ( ad->ad_df.adf_fd < 0)
+               return -1;
+
+         AD_SET(ad->ad_df.adf_off);
+         ad->ad_df.adf_flags = hoflags;
+         if (!st_invalid) {
+             /* just created, set owner if admin (root) */
+             ad_chown(path, &st);
          }
-         ad->ad_df.adf_off = 0;
-         ad->ad_df.adf_flags = oflags;
        } 
+        else {
+            /* the file is already open... but */
+            if ((oflags & ( O_RDWR | O_WRONLY)) &&             /* we want write access */
+               !(ad->ad_df.adf_flags & ( O_RDWR | O_WRONLY))) /* and it was denied the first time */
+            {
+                 errno = EACCES;
+                 return -1;
+            }
+           /* FIXME 
+            * for now ad_open is never called with O_TRUNC or O_EXCL if the file is
+            * already open. Should we check for it? ie
+            * O_EXCL --> error 
+            * O_TRUNC --> truncate the fork.
+            * idem for ressource fork.
+            */
+       }
+       open_df = ADFLAGS_DF;
        ad->ad_df.adf_refcount++;
     }
 
-    if (adflags & ADFLAGS_HF) {
-        if (ad_hfileno(ad) == -1) {
-         ad_p = ad_path( path, adflags );
-         admode = ad_mode( ad_p, mode ); /* FIXME? */
-         
-         hoflags = oflags & ~O_CREAT;
-         if (( ad->ad_hf.adf_fd = open( ad_p, hoflags, admode )) < 0 ) {
-           if ( errno == ENOENT && hoflags != oflags ) {
-             /*
-              * We're expecting to create a new adouble header file,
-              * here.
-              */
-             errno = 0;
-             if (( ad->ad_hf.adf_fd = open( ad_p, oflags,
-                                            admode )) < 0 ) {
+    if (!(adflags & ADFLAGS_HF)) 
+        return 0;
+        
+    if (ad_hfileno(ad) != -1) { /* the file is already open */
+        if ((oflags & ( O_RDWR | O_WRONLY)) &&             
+               !(ad->ad_hf.adf_flags & ( O_RDWR | O_WRONLY))) {
+           if (open_df) {
+                /* don't call with ADFLAGS_HF because we didn't open ressource fork */
+               ad_close( ad, open_df );
+           }
+            errno = EACCES;
+           return -1;
+       }
+       ad_refresh(ad);
+       ad->ad_hf.adf_refcount++;
+       return 0;
+    }
+
+    ad_p = ad->ad_path( path, adflags );
+
+    hoflags = oflags & ~O_CREAT;
+    if (!(adflags & ADFLAGS_RDONLY)) {
+        hoflags = (hoflags & ~(O_RDONLY | O_WRONLY)) | O_RDWR;
+    }
+    ad->ad_hf.adf_fd = open( ad_p, hoflags, 0 );
+    if (ad->ad_hf.adf_fd < 0 ) {
+        if ((errno == EACCES || errno == EROFS) && !(oflags & O_RDWR)) {
+            hoflags = oflags & ~O_CREAT;
+            ad->ad_hf.adf_fd = open( ad_p, hoflags, 0 );
+        }    
+    }
+
+    if ( ad->ad_hf.adf_fd < 0 ) { 
+        if (errno == ENOENT && (oflags & O_CREAT) ) {
+           /*
+            * We're expecting to create a new adouble header file,
+            * here.
+            * if ((oflags & O_CREAT) ==> (oflags & O_RDWR)
+            */
+           admode = mode;
+           errno = 0;
+           st_invalid = ad_mode_st(ad_p, &admode, &st);
+           if ((ad->ad_options & ADVOL_UNIXPRIV)) {
+               admode = mode;
+           }
+           admode = ad_hf_mode(admode); 
+           if ( errno == ENOENT && !(adflags & ADFLAGS_NOADOUBLE) && ad->ad_flags != AD_VERSION2_OSX) {
                /*
                 * Probably .AppleDouble doesn't exist, try to
                 * mkdir it.
                 */
-               if ((errno == ENOENT) && 
-                   ((adflags & ADFLAGS_NOADOUBLE) == 0)) {
-                 if (( slash = strrchr( ad_p, '/' )) == NULL ) {
-                   ad_close( ad, adflags );
-                   return( -1 );
-                 }
-                 *slash = '\0';
-                 errno = 0;
-                 if ( ad_mkdir( ad_p, 0777 ) < 0 ) {
-                   ad_close( ad, adflags );
-                   return( -1 );
-                 }
-                 *slash = '/';
-                 if (( ad->ad_hf.adf_fd = 
-                       open( ad_p, oflags, ad_mode( ad_p, mode) )) < 0 ) {
-                   ad_close( ad, adflags );
-                   return( -1 );
-                 }
-               } else {
-                 ad_close( ad, adflags );
-                 return( -1 );
+               if (NULL == ( slash = strrchr( ad_p, '/' )) ) {
+                   return ad_error(ad, adflags);
                }
-             }
-             ad->ad_hf.adf_flags = oflags;
-           } else {
-             ad_close( ad, adflags );
-             return( -1 );
+               *slash = '\0';
+               errno = 0;
+               if ( ad_mkdir( ad_p, 0777 ) < 0 ) {
+                   return ad_error(ad, adflags);
+               }
+               *slash = '/';
+               admode = mode;
+               st_invalid = ad_mode_st(ad_p, &admode, &st);
+               if ((ad->ad_options & ADVOL_UNIXPRIV)) {
+                   admode = mode;
+               }
+               admode = ad_hf_mode(admode); 
            }
-         } else if ((fstat(ad->ad_hf.adf_fd, &st) == 0) && 
-                    (st.st_size == 0)) {
-           /* for 0 length files, treat them as new. */
-           ad->ad_hf.adf_flags = oflags;
-         } else {
-           ad->ad_hf.adf_flags = hoflags;
-         }
-         ad->ad_hf.adf_off = 0;
-         
-         /*
-          * This is a new adouble header file. Initialize the structure,
-          * instead of reading it.
-          */
-         memset(ad->ad_eid, 0, sizeof( ad->ad_eid ));
-         if ( ad->ad_hf.adf_flags & ( O_TRUNC | O_CREAT )) {
-           struct timeval tv;
-
-           ad->ad_magic = AD_MAGIC;
-           ad->ad_version = AD_VERSION;
-           memset(ad->ad_filler, 0, sizeof( ad->ad_filler ));
-
-#ifdef USE_MMAPPED_HEADERS
-           /* truncate the header file and mmap it. */
-           ftruncate(ad->ad_hf.adf_fd, AD_DATASZ);
-           ad->ad_data = mmap(NULL, AD_DATASZ, PROT_READ | PROT_WRITE,
-                              MAP_SHARED, ad->ad_hf.adf_fd, 0);
-           if (ad->ad_data == MAP_FAILED) {
-             ad_close(ad, adflags);
-             return -1;
-           }       
-#else /* USE_MMAPPED_HEADERS */
-           memset(ad->ad_data, 0, sizeof(ad->ad_data));
-#endif /* USE_MMAPPED_HEADERS */
-
-           eid = entry_order;
-           while (eid->id) {
-             ad->ad_eid[eid->id].ade_off = eid->offset;
-             ad->ad_eid[eid->id].ade_len = eid->len;
-             eid++;
+           /* retry with O_CREAT */
+           ad->ad_hf.adf_fd = open( ad_p, oflags,admode );
+           if ( ad->ad_hf.adf_fd < 0 ) {
+               return ad_error(ad, adflags);
            }
-           
-           /* put something sane in the directory finderinfo */
-           if (adflags & ADFLAGS_DIR) {
-             /* set default view */
-             ashort = htons(FINDERINFO_CLOSEDVIEW);
-             memcpy(ad_entry(ad, ADEID_FINDERI) + FINDERINFO_FRVIEWOFF, 
-                    &ashort, sizeof(ashort));
-           } else {
-             /* set default creator/type fields */
-             memcpy(ad_entry(ad, ADEID_FINDERI) + FINDERINFO_FRTYPEOFF,
-                    "TEXT", 4);
-             memcpy(ad_entry(ad, ADEID_FINDERI) + FINDERINFO_FRCREATOFF,
-                    "UNIX", 4);
+           ad->ad_hf.adf_flags = oflags;
+           /* just created, set owner if admin owner (root) */
+           if (!st_invalid) {
+               ad_chown(ad_p, &st);
            }
+       }
+       else {
+           return ad_error(ad, adflags);
+       }
+    } else if (fstat(ad->ad_hf.adf_fd, &st) == 0 && st.st_size == 0) {
+       /* for 0 length files, treat them as new. */
+       ad->ad_hf.adf_flags = hoflags| O_TRUNC;
+    } else {
+        ad->ad_hf.adf_flags = hoflags;
+    }
+    AD_SET(ad->ad_hf.adf_off);
+         
+    memset(ad->ad_eid, 0, sizeof( ad->ad_eid ));
+    ad->ad_hf.adf_refcount++;
+    if ((ad->ad_hf.adf_flags & ( O_TRUNC | O_CREAT ))) {
+        /*
+         * This is a new adouble header file. Initialize the structure,
+         * instead of reading it.
+        */
+        if (new_rfork(path, ad, adflags) < 0) {
+            int err = errno;
+            /* the file is already deleted, perm, whatever, so return an error*/
+            ad_close(ad, adflags);
+            errno = err;
+           return -1;
+       }
+    } else {
+           /* Read the adouble header in and parse it.*/
+       if ((ad_header_read( ad , &st) < 0)
+#if AD_VERSION == AD_VERSION2
+               || (ad_convert(ad, ad_p) < 0) || (ad_update(ad, ad_p) < 0)
+#endif /* AD_VERSION == AD_VERSION2 */
+        ) {
+            int err = errno;
+            
+            ad_close( ad, adflags );
+            errno = err;
+           return -1;
+       }
+    }
+    return 0 ;
+}
 
-           /* make things invisible */
-           if ((*path == '.') && strcmp(path, ".") && strcmp(path, "..")) {
-             ashort = htons(ATTRBIT_INVISIBLE);
-             ad_setattr(ad, ashort);
-             ashort = htons(FINDERINFO_INVISIBLE);
-             memcpy(ad_entry(ad, ADEID_FINDERI) + FINDERINFO_FRFLAGOFF,
-                    &ashort, sizeof(ashort));
-           }
+/* ----------------------------------- 
+ * return only metadata but try very hard
+*/
+int ad_metadata(const char *name, int flags, struct adouble *adp)
+{
+    uid_t uid;
+    int   ret, err;
+
+    if ((ret = ad_open(name, ADFLAGS_HF | (flags), O_RDONLY, 0, adp)) < 0 && errno == EACCES) {
+        uid = geteuid();
+        if (seteuid(0)) {
+            LOG(log_error, logtype_default, "ad_metadata(%s): seteuid failed %s", name, strerror(errno));
+            errno = EACCES;
+            return -1;
+        }
+        /* we are root open read only */
+        ret = ad_open(name, ADFLAGS_HF|ADFLAGS_RDONLY|(flags), O_RDONLY, 0, adp);
+        err = errno;
+        if ( seteuid(uid) < 0) {
+            LOG(log_error, logtype_default, "ad_metadata: can't seteuid back");
+            exit(EXITERR_SYS);
+        }
+        errno = err;
+    }
+    return ret;
+}
 
-           if (gettimeofday(&tv, NULL) < 0) {
-             ad_close(ad, adflags);
-             return -1;
-           }
-           
-           /* put something sane in the date fields */
-           ad_setdate(ad, AD_DATE_CREATE | AD_DATE_UNIX, tv.tv_sec);
-           ad_setdate(ad, AD_DATE_MODIFY | AD_DATE_UNIX, tv.tv_sec);
-           ad_setdate(ad, AD_DATE_ACCESS | AD_DATE_UNIX, tv.tv_sec);
-           ad_setdate(ad, AD_DATE_BACKUP, AD_DATE_START);
+/* ----------------------------------- */
+static int new_rfork(const char *path, struct adouble *ad, int adflags)
+{
+    const struct entry  *eid;
+    u_int16_t           ashort;
+    struct stat         st;
+
+    ad->ad_magic = AD_MAGIC;
+    ad->ad_version = ad->ad_flags & 0x0f0000;
+    if (!ad->ad_version) {
+        ad->ad_version = AD_VERSION;
+    }
+
+    memset(ad->ad_filler, 0, sizeof( ad->ad_filler ));
+    memset(ad->ad_data, 0, sizeof(ad->ad_data));
 
-         } else {
-           /*
-            * Read the adouble header in and parse it.
-            */
-           if ((ad_header_read( ad ) < 0)
 #if AD_VERSION == AD_VERSION2
-               || (ad_v1tov2(ad, ad_p) < 0)
-#endif /* AD_VERSION == AD_VERSION2 */
-               ) {
-             ad_close( ad, adflags );
-             return( -1 );
-           }
-         }
-       }
-       ad->ad_hf.adf_refcount++;
+    if (ad->ad_flags == AD_VERSION2)
+       eid = entry_order2;
+    else if (ad->ad_flags == AD_VERSION2_OSX)
+       eid = entry_order_osx;
+    else
+#endif
+       eid = entry_order1;
+
+    while (eid->id) {
+        ad->ad_eid[eid->id].ade_off = eid->offset;
+       ad->ad_eid[eid->id].ade_len = eid->len;
+       eid++;
+    }
+           
+    /* put something sane in the directory finderinfo */
+    if ((adflags & ADFLAGS_DIR)) {
+        /* set default view */
+       ashort = htons(FINDERINFO_CLOSEDVIEW);
+       memcpy(ad_entry(ad, ADEID_FINDERI) + FINDERINFO_FRVIEWOFF, 
+                    &ashort, sizeof(ashort));
+    } else {
+        /* set default creator/type fields */
+       memcpy(ad_entry(ad, ADEID_FINDERI) + FINDERINFO_FRTYPEOFF,"\0\0\0\0", 4);
+       memcpy(ad_entry(ad, ADEID_FINDERI) + FINDERINFO_FRCREATOFF,"\0\0\0\0", 4);
+    }
+
+    /* make things invisible */
+    if ((ad->ad_options & ADVOL_INVDOTS) && !(adflags & ADFLAGS_CREATE) && 
+           (*path == '.') && strcmp(path, ".") && strcmp(path, "..")) 
+    {
+        ashort = htons(ATTRBIT_INVISIBLE);
+       ad_setattr(ad, ashort);
+       ashort = htons(FINDERINFO_INVISIBLE);
+       memcpy(ad_entry(ad, ADEID_FINDERI) + FINDERINFO_FRFLAGOFF, &ashort, sizeof(ashort));
     }
-       
-    return( 0 );
+
+    if (stat(path, &st) < 0) {
+       return -1;
+    }
+           
+    /* put something sane in the date fields */
+    ad_setdate(ad, AD_DATE_CREATE | AD_DATE_UNIX, st.st_mtime);
+    ad_setdate(ad, AD_DATE_MODIFY | AD_DATE_UNIX, st.st_mtime);
+    ad_setdate(ad, AD_DATE_ACCESS | AD_DATE_UNIX, st.st_mtime);
+    ad_setdate(ad, AD_DATE_BACKUP, AD_DATE_START);
+    return 0;
 }
 
 /* to do this with mmap, we need the hfs fs to understand how to mmap
    header files. */
 int ad_refresh(struct adouble *ad)
 {
-#ifdef USE_MMAPPED_HEADERS
-  off_t off;
-#endif /* USE_MMAPPED_HEADERS */
-
-  if (ad->ad_hf.adf_fd < -1)
-    return -1;
 
-#ifdef USE_MMAPPED_HEADERS
-  if (ad->ad_data == MAP_FAILED)
-    return -1;
-  
-  /* re-read the header */
-  off = ad_getentryoff(ad, ADEID_RFORK);
-  memcpy(&nentries, ad->ad_data + ADEDOFF_NENTRIES, sizeof(nentries));
-  nentries = ntohs(nentries);
-  parse_entries(ad, ad->ad_data + AD_HEADER_LEN, nentries);
-
-  /* check to see if something screwy happened */
-  if (!ad_getentryoff(ad, ADEID_RFORK))
+  if (ad->ad_hf.adf_fd < 0)
     return -1;
 
-  /* if there's a length discrepancy, remap the header. this shouldn't
-   * really ever happen. */
-  if (off != ad_getentryoff(ad, ADEID_RFORK)) {
-    char *buf = ad->ad_data;
-    buf = ad->ad_data;
-    ad->ad_data = mmap(NULL, ad_getentryoff(ad, ADEID_RFORK), 
-                      PROT_READ | PROT_WRITE,
-                      (ad_getoflags(ad, ADFLAGS_HF) & O_RDWR) ? 
-                      MAP_SHARED : MAP_PRIVATE, ad->ad_hf.adf_fd, 0);
-    if (ad->ad_data == MAP_FAILED) {
-      ad->ad_data = buf;
-      return -1;
-    }
-    munmap(buf, off);
-  }
-  return 0;
-
-#else /* USE_MMAPPED_HEADERS */
-  return ad_header_read(ad);
-#endif /* USE_MMAPPED_HEADERS */
+  return ad_header_read(ad, NULL);
 }