]> arthur.barton.de Git - netatalk.git/blobdiff - bin/ad/ad_util.c
Merge product-2-2
[netatalk.git] / bin / ad / ad_util.c
index 25a980b8437a59215ab6110af7ceef77e704838a..897bdf3b1415c609efdae24f2104d019ef3464fc 100644 (file)
@@ -1,4 +1,4 @@
-/* 
+/*
  * Copyright (c) 2009 Frank Lahm <franklahm@gmail.com>
  * Copyright (c) 1991, 1993, 1994
  * The Regents of the University of California.  All rights reserved.
@@ -25,7 +25,7 @@
  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
- * SUCH DAMAGE.   
+ * SUCH DAMAGE.
  */
 
 #ifdef HAVE_CONFIG_H
@@ -33,7 +33,6 @@
 #endif /* HAVE_CONFIG_H */
 
 #include <sys/types.h>
-#include <sys/acl.h>
 #include <sys/param.h>
 #include <sys/stat.h>
 #include <sys/mman.h>
 #include <unistd.h>
 #include <stdarg.h>
 #include <string.h>
+#include <libgen.h>
 
+#ifdef HAVE_SOLARIS_ACLS
+#include <sys/acl.h>
+#endif  /* HAVE_SOLARIS_ACLS */
+
+#ifdef HAVE_POSIX_ACLS
+#include <sys/types.h>
+#include <sys/acl.h>
+#endif /* HAVE_POSIX_ACLS */
+
+#include <atalk/util.h>
 #include <atalk/cnid.h>
-#include <atalk/volinfo.h>
 #include <atalk/bstrlib.h>
 #include <atalk/bstradd.h>
-#include <atalk/util.h>
 #include <atalk/logger.h>
 #include <atalk/errchk.h>
-#include "ad.h"
-
-#define cp_pct(x, y)((y == 0) ? 0 : (int)(100.0 * (x) / (y)))
+#include <atalk/unicode.h>
+#include <atalk/globals.h>
+#include <atalk/netatalk_conf.h>
 
-/* Memory strategy threshold, in pages: if physmem is larger then this, use a 
- * large buffer */
-#define PHYSPAGES_THRESHOLD (32*1024)
 
-/* Maximum buffer size in bytes - do not allow it to grow larger than this */
-#define BUFSIZE_MAX (2*1024*1024)
-
-/* Small (default) buffer size in bytes. It's inefficient for this to be
- * smaller than MAXPHYS */
-#define MAXPHYS (64 * 1024)
-#define BUFSIZE_SMALL (MAXPHYS)
+#include "ad.h"
 
 int log_verbose;             /* Logging flag */
 
@@ -89,46 +88,71 @@ void _log(enum logtype lt, char *fmt, ...)
     }
 }
 
-int newvol(const char *path, afpvol_t *vol)
+/*!
+ * Load volinfo and initialize struct vol
+ *
+ * Only opens "dbd" volumes !
+ *
+ * @param path   (r)  path to evaluate
+ * @param vol    (rw) structure to initialize
+ *
+ * @returns 0 on success, exits on error
+ */
+int openvol(AFPObj *obj, const char *path, afpvol_t *vol)
 {
-    //    char *pathdup;
-    
+    int flags = 0;
+
     memset(vol, 0, sizeof(afpvol_t));
 
-    //    pathdup = strdup(path);
-    //    vol->dirname = strdup(dirname(pathdup));
-    //    free(pathdup);
-    
-    //    pathdup = strdup(path);
-    //    vol->basename = strdup(basename(pathdup));
-    //    free(pathdup);
+    if ((vol->vol = getvolbypath(obj, path)) == NULL)
+        return -1;
+
+    if (STRCMP(vol->vol->v_cnidscheme, != , "dbd"))
+        ERROR("\"%s\" isn't a \"dbd\" CNID volume!", vol->vol->v_path);
+
+    /* Sanity checks to ensure we can touch this volume */
+    if (vol->vol->v_adouble != AD_VERSION2
+        && vol->vol->v_adouble != AD_VERSION_EA)
+        ERROR("Unsupported adouble versions: %u", vol->vol->v_adouble);
+
+    if (vol->vol->v_vfs_ea != AFPVOL_EA_SYS)
+        ERROR("Unsupported Extended Attributes option: %u", vol->vol->v_vfs_ea);
+
+    if ((vol->vol->v_flags & AFPVOL_NODEV))
+        flags |= CNID_FLAG_NODEV;
 
-    loadvolinfo((char *)path, &vol->volinfo);
+    if ((vol->vol->v_cdb = cnid_open(vol->vol->v_path,
+                                     0000,
+                                     "dbd",
+                                     flags,
+                                     vol->vol->v_cnidserver,
+                                     vol->vol->v_cnidport)) == NULL)
+        ERROR("Cant initialize CNID database connection for %s", vol->vol->v_path);
 
+    cnid_getstamp(vol->vol->v_cdb,
+                  vol->db_stamp,
+                  sizeof(vol->db_stamp));
+    
     return 0;
 }
 
-void freevol(afpvol_t *vol)
+void closevol(afpvol_t *vol)
 {
-#if 0
-    if (vol->dirname) {
-        free(vol->dirname);
-        vol->dirname = NULL;
-    }
-    if (vol->basename) {
-        free(vol->basename);
-        vol->basename = NULL;
+    if (vol->vol->v_cdb) {
+        cnid_close(vol->vol->v_cdb);
+        vol->vol->v_cdb = NULL;
     }
-#endif
+    memset(vol, 0, sizeof(afpvol_t));
 }
 
 /*
   Taken form afpd/desktop.c
 */
-char *utompath(const struct volinfo *volinfo, char *upath)
+char *utompath(const struct vol *vol, const char *upath)
 {
     static char  mpath[ MAXPATHLEN + 2]; /* for convert_charset dest_len parameter +2 */
-    char         *m, *u;
+    char         *m;
+    const char   *u;
     uint16_t     flags = CONV_IGNORE | CONV_UNESCAPEHEX;
     size_t       outlen;
 
@@ -139,78 +163,72 @@ char *utompath(const struct volinfo *volinfo, char *upath)
     u = upath;
     outlen = strlen(upath);
 
-    if ((volinfo->v_casefold & AFPVOL_UTOMUPPER))
+    if ((vol->v_casefold & AFPVOL_UTOMUPPER))
         flags |= CONV_TOUPPER;
-    else if ((volinfo->v_casefold & AFPVOL_UTOMLOWER))
+    else if ((vol->v_casefold & AFPVOL_UTOMLOWER))
         flags |= CONV_TOLOWER;
 
-    if ((volinfo->v_flags & AFPVOL_EILSEQ)) {
+    if ((vol->v_flags & AFPVOL_EILSEQ)) {
         flags |= CONV__EILSEQ;
     }
 
     /* convert charsets */
-    if ((size_t)-1 == ( outlen = convert_charset(volinfo->v_volcharset,
+    if ((size_t)-1 == ( outlen = convert_charset(vol->v_volcharset,
                                                  CH_UTF8_MAC,
-                                                 volinfo->v_maccharset,
+                                                 vol->v_maccharset,
                                                  u, outlen, mpath, MAXPATHLEN, &flags)) ) {
         SLOG("Conversion from %s to %s for %s failed.",
-            volinfo->v_volcodepage, volinfo->v_maccodepage, u);
+             vol->v_volcodepage, vol->v_maccodepage, u);
         return NULL;
     }
 
     return(m);
 }
 
+
 /*!
- * Build path relativ to volume root
+ * Convert dot encoding of basename _in place_
  *
- * path might be:
- * (a) relative:
- *     "dir/subdir" with cwd: "/afp_volume/topdir"
- * (b) absolute:
- *     "/afp_volume/dir/subdir"
+ * path arg can be "[/][dir/ | ...]filename". It will be converted in place
+ * possible encoding ".file" as ":2efile" which means the result will be
+ * longer then the original which means provide a big enough buffer.
  *
- * @param path     (r) path relative to cwd() or absolute
- * @param volpath  (r) volume path that path is a subdir of (has been computed in volinfo funcs) 
+ * @param svol   (r)  source volume
+ * @param dvol   (r)  destinatio volume
+ * @param path   (rw) path to convert _in place_
+ * @param buflen (r)  size of path buffer (max strlen == buflen -1)
  *
- * @returns relative path in new bstring, caller must bdestroy it
+ * @returns 0 on sucess, -1 on error
  */
-static bstring rel_path_in_vol(const char *path, const char *volpath)
+int convert_dots_encoding(const afpvol_t *svol, const afpvol_t *dvol, char *path, size_t buflen)
 {
-    EC_INIT;
-
-    if (path == NULL || volpath == NULL)
-        return NULL;
-
-    bstring fpath = NULL;
-
-    /* Make path absolute by concetanating for case (a) */
-    if (path[0] != '/') {
-        EC_NULL(fpath = bfromcstr(getcwdpath()));
-        if (bchar(fpath, blength(fpath) - 1) != '/')
-            EC_ZERO(bcatcstr(fpath, "/"));
-        EC_ZERO(bcatcstr(fpath, path));
-        BSTRING_STRIP_SLASH(fpath);
-        SLOG("Built path: %s", cfrombstr(fpath));
+    static charset_t from = (charset_t) -1;
+    static char buf[MAXPATHLEN+2];
+    char *bname = stripped_slashes_basename(path);
+    int pos = bname - path;
+    uint16_t flags = 0;
+
+    if ( ! svol->vol->v_path) {
+        /* no source volume: escape special chars (eg ':') */
+        from = dvol->vol->v_volcharset; /* src = dst charset */
+        if (dvol->vol->v_adouble == AD_VERSION2)
+            flags |= CONV_ESCAPEHEX;
     } else {
-        EC_NULL(fpath = bfromcstr(path));
-        BSTRING_STRIP_SLASH(fpath);
-        SLOG("Built path: %s", cfrombstr(fpath));
+        from = svol->vol->v_volcharset;
     }
 
-    /*
-     * Now we have eg:
-     *   fpath:   /Volume/netatalk/dir/bla
-     *   volpath: /Volume/netatalk/
-     * we want: "dir/bla"
-     */
-    EC_ZERO(bdelete(fpath, 0, strlen(volpath)));
-    SLOG("rel path: %s", cfrombstr(fpath));    
-    return fpath;
-
-EC_CLEANUP:
-    bdestroy(fpath);
-    return NULL;
+    int len = convert_charset(from,
+                              dvol->vol->v_volcharset,
+                              dvol->vol->v_maccharset,
+                              bname, strlen(bname),
+                              buf, MAXPATHLEN,
+                              &flags);
+    if (len == -1)
+        return -1;
+
+    if (strlcpy(bname, buf, MAXPATHLEN - pos) > MAXPATHLEN - pos)
+        return -1;
+    return 0;
 }
 
 /*!
@@ -222,49 +240,51 @@ EC_CLEANUP:
  * (b) absolute:
  *     "/afp_volume/dir/subdir"
  *
- * 1) start recursive CNID search with
- *    a) DID:2 / "topdir"
- *    b) DID:2 / "dir"
- * 2) ...until we have the CNID for
- *    a) "/afp_volume/topdir/dir"
- *    b) "/afp_volume/dir" (no recursion required)
+ * path MUST be pointing inside vol, this is usually the case as vol has been build from
+ * path using loadvolinfo and friends.
+ *
+ * @param vol  (r) pointer to afpvol_t
+ * @param path (r) path, see above
+ * @param did  (rw) parent CNID of returned CNID
+ *
+ * @returns CNID of path
  */
-cnid_t cnid_for_path(const struct volinfo *vi,
-                     const struct vol *vol,
-                     const char *path)
+cnid_t cnid_for_path(const afpvol_t *vol,
+                     const char *path,
+                     cnid_t *did)
 {
     EC_INIT;
 
-    cnid_t did;
     cnid_t cnid;
     bstring rpath = NULL;
     bstring statpath = NULL;
     struct bstrList *l = NULL;
     struct stat st;
 
-    EC_NULL(rpath = rel_path_in_vol(path, vi->v_path));
-    SLOG("vol:%s, path: %s, rpath: %s", vi->v_path, path, bdata(rpath));
-
     cnid = htonl(2);
 
-    EC_NULL(statpath = bfromcstr(vi->v_path));
+    EC_NULL(rpath = rel_path_in_vol(path, vol->vol->v_path));
+    EC_NULL(statpath = bfromcstr(vol->vol->v_path));
+    EC_ZERO(bcatcstr(statpath, "/"));
 
     l = bsplit(rpath, '/');
-    SLOG("elem: %s, qty: %u", cfrombstr(l->entry[0]), l->qty);
-    for(int i = 0; i < l->qty ; i++) {
-        did = cnid;
-        EC_ZERO(bconcat(statpath, l->entry[i]));
-        SLOG("statpath: %s", cfrombstr(statpath));
-        EC_ZERO_LOG(stat(cfrombstr(statpath), &st));
-        SLOG("db query: did: %u, name: %s, dev: %08x, ino: %08x",
-             ntohl(did), cfrombstr(l->entry[i]), st.st_dev, st.st_ino);
-        cnid = cnid_add(vol->v_cdb,
-                        &st,
-                        did,
-                        cfrombstr(l->entry[i]),
-                        blength(l->entry[i]),
-                        0);
+    for (int i = 0; i < l->qty ; i++) {
+        *did = cnid;
 
+        EC_ZERO(bconcat(statpath, l->entry[i]));
+        EC_ZERO_LOGSTR(lstat(cfrombstr(statpath), &st),
+                       "lstat(rpath: %s, elem: %s): %s: %s",
+                       cfrombstr(rpath), cfrombstr(l->entry[i]),
+                       cfrombstr(statpath), strerror(errno));
+
+        if ((cnid = cnid_add(vol->vol->v_cdb,
+                             &st,
+                             *did,
+                             cfrombstr(l->entry[i]),
+                             blength(l->entry[i]),
+                             0)) == CNID_INVALID) {
+            EC_FAIL;
+        }
         EC_ZERO(bcatcstr(statpath, "/"));
     }
 
@@ -278,404 +298,72 @@ EC_CLEANUP:
     return cnid;
 }
 
-int ftw_copy_file(const struct FTW *entp,
-              const char *spath,
-              const struct stat *sp,
-              int dne)
-{
-    static char *buf = NULL;
-    static size_t bufsize;
-    ssize_t wcount;
-    size_t wresid;
-    off_t wtotal;
-    int ch, checkch, from_fd = 0, rcount, rval, to_fd = 0;
-    char *bufp;
-    char *p;
-
-    if ((from_fd = open(spath, O_RDONLY, 0)) == -1) {
-        SLOG("%s: %s", spath, strerror(errno));
-        return (1);
-    }
-
-    /*
-     * If the file exists and we're interactive, verify with the user.
-     * If the file DNE, set the mode to be the from file, minus setuid
-     * bits, modified by the umask; arguably wrong, but it makes copying
-     * executables work right and it's been that way forever.  (The
-     * other choice is 666 or'ed with the execute bits on the from file
-     * modified by the umask.)
-     */
-    if (!dne) {
-#define YESNO "(y/n [n]) "
-        if (nflag) {
-            if (vflag)
-                printf("%s not overwritten\n", to.p_path);
-            (void)close(from_fd);
-            return (0);
-        } else if (iflag) {
-            (void)fprintf(stderr, "overwrite %s? %s", 
-                          to.p_path, YESNO);
-            checkch = ch = getchar();
-            while (ch != '\n' && ch != EOF)
-                ch = getchar();
-            if (checkch != 'y' && checkch != 'Y') {
-                (void)close(from_fd);
-                (void)fprintf(stderr, "not overwritten\n");
-                return (1);
-            }
-        }
-        
-        if (fflag) {
-            /* remove existing destination file name, 
-             * create a new file  */
-            (void)unlink(to.p_path);
-            if (!lflag)
-                to_fd = open(to.p_path, O_WRONLY | O_TRUNC | O_CREAT,
-                             sp->st_mode & ~(S_ISUID | S_ISGID));
-        } else {
-            if (!lflag)
-                /* overwrite existing destination file name */
-                to_fd = open(to.p_path, O_WRONLY | O_TRUNC, 0);
-        }
-    } else {
-        if (!lflag)
-            to_fd = open(to.p_path, O_WRONLY | O_TRUNC | O_CREAT,
-                         sp->st_mode & ~(S_ISUID | S_ISGID));
-    }
-    
-    if (to_fd == -1) {
-        SLOG("%s: %s", to.p_path, strerror(errno));
-        (void)close(from_fd);
-        return (1);
-    }
-
-    rval = 0;
-
-    if (!lflag) {
-        /*
-         * Mmap and write if less than 8M (the limit is so we don't totally
-         * trash memory on big files.  This is really a minor hack, but it
-         * wins some CPU back.
-         * Some filesystems, such as smbnetfs, don't support mmap,
-         * so this is a best-effort attempt.
-         */
-
-        if (S_ISREG(sp->st_mode) && sp->st_size > 0 &&
-            sp->st_size <= 8 * 1024 * 1024 &&
-            (p = mmap(NULL, (size_t)sp->st_size, PROT_READ,
-                      MAP_SHARED, from_fd, (off_t)0)) != MAP_FAILED) {
-            wtotal = 0;
-            for (bufp = p, wresid = sp->st_size; ;
-                 bufp += wcount, wresid -= (size_t)wcount) {
-                wcount = write(to_fd, bufp, wresid);
-                if (wcount <= 0)
-                    break;
-                wtotal += wcount;
-                if (wcount >= (ssize_t)wresid)
-                    break;
-            }
-            if (wcount != (ssize_t)wresid) {
-                SLOG("%s: %s", to.p_path, strerror(errno));
-                rval = 1;
-            }
-            /* Some systems don't unmap on close(2). */
-            if (munmap(p, sp->st_size) < 0) {
-                SLOG("%s: %s", spath, strerror(errno));
-                rval = 1;
-            }
-        } else {
-            if (buf == NULL) {
-                /*
-                 * Note that buf and bufsize are static. If
-                 * malloc() fails, it will fail at the start
-                 * and not copy only some files. 
-                 */ 
-                if (sysconf(_SC_PHYS_PAGES) > 
-                    PHYSPAGES_THRESHOLD)
-                    bufsize = MIN(BUFSIZE_MAX, MAXPHYS * 8);
-                else
-                    bufsize = BUFSIZE_SMALL;
-                buf = malloc(bufsize);
-                if (buf == NULL)
-                    ERROR("Not enough memory");
-
-            }
-            wtotal = 0;
-            while ((rcount = read(from_fd, buf, bufsize)) > 0) {
-                for (bufp = buf, wresid = rcount; ;
-                     bufp += wcount, wresid -= wcount) {
-                    wcount = write(to_fd, bufp, wresid);
-                    if (wcount <= 0)
-                        break;
-                    wtotal += wcount;
-                    if (wcount >= (ssize_t)wresid)
-                        break;
-                }
-                if (wcount != (ssize_t)wresid) {
-                    SLOG("%s: %s", to.p_path, strerror(errno));
-                    rval = 1;
-                    break;
-                }
-            }
-            if (rcount < 0) {
-                SLOG("%s: %s", spath, strerror(errno));
-                rval = 1;
-            }
-        }
-    } else {
-        if (link(spath, to.p_path)) {
-            SLOG("%s", to.p_path);
-            rval = 1;
-        }
-    }
-    
-    /*
-     * Don't remove the target even after an error.  The target might
-     * not be a regular file, or its attributes might be important,
-     * or its contents might be irreplaceable.  It would only be safe
-     * to remove it if we created it and its length is 0.
-     */
-
-    if (!lflag) {
-        if (pflag && setfile(sp, to_fd))
-            rval = 1;
-        if (pflag && preserve_fd_acls(from_fd, to_fd) != 0)
-            rval = 1;
-        if (close(to_fd)) {
-            SLOG("%s: %s", to.p_path, strerror(errno));
-            rval = 1;
-        }
-    }
-
-    (void)close(from_fd);
-
-    return (rval);
-}
-
-int copy_link(const struct FTW *p,
-              const char *spath,
-              const struct stat *sstp,
-              int exists)
-{
-    int len;
-    char llink[PATH_MAX];
-
-    if ((len = readlink(spath, llink, sizeof(llink) - 1)) == -1) {
-        SLOG("readlink: %s: %s", spath, strerror(errno));
-        return (1);
-    }
-    llink[len] = '\0';
-    if (exists && unlink(to.p_path)) {
-        SLOG("unlink: %s: %s", to.p_path, strerror(errno));
-        return (1);
-    }
-    if (symlink(llink, to.p_path)) {
-        SLOG("symlink: %s: %s", llink, strerror(errno));
-        return (1);
-    }
-    return (pflag ? setfile(sstp, -1) : 0);
-}
-
-int setfile(const struct stat *fs, int fd)
+/*!
+ * Resolves CNID of a given paths parent directory
+ *
+ * path might be:
+ * (a) relative:
+ *     "dir/subdir" with cwd: "/afp_volume/topdir"
+ * (b) absolute:
+ *     "/afp_volume/dir/subdir"
+ *
+ * path MUST be pointing inside vol, this is usually the case as vol has been build from
+ * path using loadvolinfo and friends.
+ *
+ * @param vol  (r) pointer to afpvol_t
+ * @param path (r) path, see above
+ * @param did  (rw) parent CNID of returned CNID
+ *
+ * @returns CNID of path
+ */
+cnid_t cnid_for_paths_parent(const afpvol_t *vol,
+                             const char *path,
+                             cnid_t *did)
 {
-    static struct timeval tv[2];
-    struct stat ts;
-    int rval, gotstat, islink, fdval;
-    mode_t mode;
-
-    rval = 0;
-    fdval = fd != -1;
-    islink = !fdval && S_ISLNK(fs->st_mode);
-    mode = fs->st_mode & (S_ISUID | S_ISGID | S_ISVTX | S_IRWXU | S_IRWXG | S_IRWXO);
-
-    TIMESPEC_TO_TIMEVAL(&tv[0], &fs->st_atim);
-    TIMESPEC_TO_TIMEVAL(&tv[1], &fs->st_mtim);
-    if (islink ? lutimes(to.p_path, tv) : utimes(to.p_path, tv)) {
-        SLOG("%sutimes: %s", islink ? "l" : "", to.p_path);
-        rval = 1;
-    }
-    if (fdval ? fstat(fd, &ts) :
-        (islink ? lstat(to.p_path, &ts) : stat(to.p_path, &ts)))
-        gotstat = 0;
-    else {
-        gotstat = 1;
-        ts.st_mode &= S_ISUID | S_ISGID | S_ISVTX |
-            S_IRWXU | S_IRWXG | S_IRWXO;
-    }
-    /*
-     * Changing the ownership probably won't succeed, unless we're root
-     * or POSIX_CHOWN_RESTRICTED is not set.  Set uid/gid before setting
-     * the mode; current BSD behavior is to remove all setuid bits on
-     * chown.  If chown fails, lose setuid/setgid bits.
-     */
-    if (!gotstat || fs->st_uid != ts.st_uid || fs->st_gid != ts.st_gid)
-        if (fdval ? fchown(fd, fs->st_uid, fs->st_gid) :
-            (islink ? lchown(to.p_path, fs->st_uid, fs->st_gid) :
-             chown(to.p_path, fs->st_uid, fs->st_gid))) {
-            if (errno != EPERM) {
-                SLOG("chown: %s: %s", to.p_path, strerror(errno));
-                rval = 1;
-            }
-            mode &= ~(S_ISUID | S_ISGID);
-        }
+    EC_INIT;
 
-    if (!gotstat || mode != ts.st_mode)
-        if (fdval ? fchmod(fd, mode) : chmod(to.p_path, mode)) {
-            SLOG("chmod: %s: %s", to.p_path, strerror(errno));
-            rval = 1;
-        }
+    cnid_t cnid;
+    bstring rpath = NULL;
+    bstring statpath = NULL;
+    struct bstrList *l = NULL;
+    struct stat st;
 
-#ifdef HAVE_ST_FLAGS
-    if (!gotstat || fs->st_flags != ts.st_flags)
-        if (fdval ?
-            fchflags(fd, fs->st_flags) :
-            (islink ? lchflags(to.p_path, fs->st_flags) :
-             chflags(to.p_path, fs->st_flags))) {
-            SLOG("chflags: %s: %s", to.p_path, strerror(errno));
-            rval = 1;
-        }
-#endif
+    *did = htonl(1);
+    cnid = htonl(2);
 
-    return (rval);
-}
+    EC_NULL(rpath = rel_path_in_vol(path, vol->vol->v_path));
+    EC_NULL(statpath = bfromcstr(vol->vol->v_path));
 
-int preserve_fd_acls(int source_fd, int dest_fd)
-{
-#if 0
-    acl_t acl;
-    acl_type_t acl_type;
-    int acl_supported = 0, ret, trivial;
-
-    ret = fpathconf(source_fd, _PC_ACL_NFS4);
-    if (ret > 0 ) {
-        acl_supported = 1;
-        acl_type = ACL_TYPE_NFS4;
-    } else if (ret < 0 && errno != EINVAL) {
-        warn("fpathconf(..., _PC_ACL_NFS4) failed for %s", to.p_path);
-        return (1);
-    }
-    if (acl_supported == 0) {
-        ret = fpathconf(source_fd, _PC_ACL_EXTENDED);
-        if (ret > 0 ) {
-            acl_supported = 1;
-            acl_type = ACL_TYPE_ACCESS;
-        } else if (ret < 0 && errno != EINVAL) {
-            warn("fpathconf(..., _PC_ACL_EXTENDED) failed for %s",
-                 to.p_path);
-            return (1);
+    l = bsplit(rpath, '/');
+    if (l->qty == 1)
+        /* only one path element, means parent dir cnid is volume root = 2 */
+        goto EC_CLEANUP;
+    for (int i = 0; i < (l->qty - 1); i++) {
+        *did = cnid;
+        EC_ZERO(bconcat(statpath, l->entry[i]));
+        EC_ZERO_LOGSTR(lstat(cfrombstr(statpath), &st),
+                       "lstat(rpath: %s, elem: %s): %s: %s",
+                       cfrombstr(rpath), cfrombstr(l->entry[i]),
+                       cfrombstr(statpath), strerror(errno));
+
+        if ((cnid = cnid_add(vol->vol->v_cdb,
+                             &st,
+                             *did,
+                             cfrombstr(l->entry[i]),
+                             blength(l->entry[i]),
+                             0)) == CNID_INVALID) {
+            EC_FAIL;
         }
+        EC_ZERO(bcatcstr(statpath, "/"));
     }
-    if (acl_supported == 0)
-        return (0);
 
-    acl = acl_get_fd_np(source_fd, acl_type);
-    if (acl == NULL) {
-        warn("failed to get acl entries while setting %s", to.p_path);
-        return (1);
-    }
-    if (acl_is_trivial_np(acl, &trivial)) {
-        warn("acl_is_trivial() failed for %s", to.p_path);
-        acl_free(acl);
-        return (1);
-    }
-    if (trivial) {
-        acl_free(acl);
-        return (0);
-    }
-    if (acl_set_fd_np(dest_fd, acl, acl_type) < 0) {
-        warn("failed to set acl entries for %s", to.p_path);
-        acl_free(acl);
-        return (1);
-    }
-    acl_free(acl);
-#endif
-    return (0);
-}
+EC_CLEANUP:
+    bdestroy(rpath);
+    bstrListDestroy(l);
+    bdestroy(statpath);
+    if (ret != 0)
+        return CNID_INVALID;
 
-int preserve_dir_acls(const struct stat *fs, char *source_dir, char *dest_dir)
-{
-#if 0
-    acl_t (*aclgetf)(const char *, acl_type_t);
-    int (*aclsetf)(const char *, acl_type_t, acl_t);
-    struct acl *aclp;
-    acl_t acl;
-    acl_type_t acl_type;
-    int acl_supported = 0, ret, trivial;
-
-    ret = pathconf(source_dir, _PC_ACL_NFS4);
-    if (ret > 0) {
-        acl_supported = 1;
-        acl_type = ACL_TYPE_NFS4;
-    } else if (ret < 0 && errno != EINVAL) {
-        warn("fpathconf(..., _PC_ACL_NFS4) failed for %s", source_dir);
-        return (1);
-    }
-    if (acl_supported == 0) {
-        ret = pathconf(source_dir, _PC_ACL_EXTENDED);
-        if (ret > 0) {
-            acl_supported = 1;
-            acl_type = ACL_TYPE_ACCESS;
-        } else if (ret < 0 && errno != EINVAL) {
-            warn("fpathconf(..., _PC_ACL_EXTENDED) failed for %s",
-                 source_dir);
-            return (1);
-        }
-    }
-    if (acl_supported == 0)
-        return (0);
-
-    /*
-     * If the file is a link we will not follow it
-     */
-    if (S_ISLNK(fs->st_mode)) {
-        aclgetf = acl_get_link_np;
-        aclsetf = acl_set_link_np;
-    } else {
-        aclgetf = acl_get_file;
-        aclsetf = acl_set_file;
-    }
-    if (acl_type == ACL_TYPE_ACCESS) {
-        /*
-         * Even if there is no ACL_TYPE_DEFAULT entry here, a zero
-         * size ACL will be returned. So it is not safe to simply
-         * check the pointer to see if the default ACL is present.
-         */
-        acl = aclgetf(source_dir, ACL_TYPE_DEFAULT);
-        if (acl == NULL) {
-            warn("failed to get default acl entries on %s",
-                 source_dir);
-            return (1);
-        }
-        aclp = &acl->ats_acl;
-        if (aclp->acl_cnt != 0 && aclsetf(dest_dir,
-                                          ACL_TYPE_DEFAULT, acl) < 0) {
-            warn("failed to set default acl entries on %s",
-                 dest_dir);
-            acl_free(acl);
-            return (1);
-        }
-        acl_free(acl);
-    }
-    acl = aclgetf(source_dir, acl_type);
-    if (acl == NULL) {
-        warn("failed to get acl entries on %s", source_dir);
-        return (1);
-    }
-    if (acl_is_trivial_np(acl, &trivial)) {
-        warn("acl_is_trivial() failed on %s", source_dir);
-        acl_free(acl);
-        return (1);
-    }
-    if (trivial) {
-        acl_free(acl);
-        return (0);
-    }
-    if (aclsetf(dest_dir, acl_type, acl) < 0) {
-        warn("failed to set acl entries on %s", dest_dir);
-        acl_free(acl);
-        return (1);
-    }
-    acl_free(acl);
-#endif
-    return (0);
+    return cnid;
 }
+