Source-Changes-HG archive

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index][Old Index]

[src/trunk]: src/sys/coda Rewrite coda_readdir() to directly process the cont...



details:   https://anonhg.NetBSD.org/src/rev/803ab3eea6f3
branches:  trunk
changeset: 957003:803ab3eea6f3
user:      hannken <hannken%NetBSD.org@localhost>
date:      Sat Nov 14 11:42:56 2020 +0000

description:
Rewrite coda_readdir() to directly process the container file.

Passing this operation down to the file system holding the container
cannot work for anything but UFS and UFS doesn't allow reading
directory from a plain file since ~2015.

Fixes PR kern/55775 Coda client, its in-kernel part, opens wrong files ...

diffstat:

 sys/coda/coda.h       |    8 +-
 sys/coda/coda_vnops.c |  168 ++++++++++++++++++++++++++++++++++++-------------
 2 files changed, 127 insertions(+), 49 deletions(-)

diffs (244 lines):

diff -r 1f3e9b76ee6a -r 803ab3eea6f3 sys/coda/coda.h
--- a/sys/coda/coda.h   Sat Nov 14 11:42:05 2020 +0000
+++ b/sys/coda/coda.h   Sat Nov 14 11:42:56 2020 +0000
@@ -1,4 +1,4 @@
-/* $NetBSD: coda.h,v 1.20 2018/04/19 21:50:07 christos Exp $ */
+/* $NetBSD: coda.h,v 1.21 2020/11/14 11:42:56 hannken Exp $ */
 
 /*
 
@@ -61,6 +61,10 @@
 #define CODA_MAXSYMLINKS 10
 #endif
 
+#ifndef CODA_DIRBLKSIZ
+#define CODA_DIRBLKSIZ 0x1000
+#endif
+
 #if defined(DJGPP) || defined(__CYGWIN32__)
 #ifdef KERNEL
 typedef unsigned long u_long;
@@ -169,7 +173,7 @@
 #ifndef _VENUS_DIRENT_T_
 #define _VENUS_DIRENT_T_ 1
 struct venus_dirent {
-        unsigned long  d_fileno;               /* file number of entry */
+        unsigned int   d_fileno;               /* file number of entry */
         unsigned short d_reclen;               /* length of this record */
         unsigned char  d_type;                 /* file type, see below */
         unsigned char  d_namlen;               /* length of string in d_name */
diff -r 1f3e9b76ee6a -r 803ab3eea6f3 sys/coda/coda_vnops.c
--- a/sys/coda/coda_vnops.c     Sat Nov 14 11:42:05 2020 +0000
+++ b/sys/coda/coda_vnops.c     Sat Nov 14 11:42:56 2020 +0000
@@ -1,4 +1,4 @@
-/*     $NetBSD: coda_vnops.c,v 1.113 2020/11/14 11:42:05 hannken Exp $ */
+/*     $NetBSD: coda_vnops.c,v 1.114 2020/11/14 11:42:56 hannken Exp $ */
 
 /*
  *
@@ -46,7 +46,7 @@
  */
 
 #include <sys/cdefs.h>
-__KERNEL_RCSID(0, "$NetBSD: coda_vnops.c,v 1.113 2020/11/14 11:42:05 hannken Exp $");
+__KERNEL_RCSID(0, "$NetBSD: coda_vnops.c,v 1.114 2020/11/14 11:42:56 hannken Exp $");
 
 #include <sys/param.h>
 #include <sys/systm.h>
@@ -62,6 +62,7 @@
 #include <sys/select.h>
 #include <sys/vnode.h>
 #include <sys/kauth.h>
+#include <sys/dirent.h>
 
 #include <miscfs/genfs/genfs.h>
 #include <miscfs/specfs/specdev.h>
@@ -1528,70 +1529,143 @@
 coda_readdir(void *v)
 {
 /* true args */
-    struct vop_readdir_args *ap = v;
-    vnode_t *vp = ap->a_vp;
-    struct cnode *cp = VTOC(vp);
-    struct uio *uiop = ap->a_uio;
-    kauth_cred_t cred = ap->a_cred;
-    int *eofflag = ap->a_eofflag;
-    off_t **cookies = ap->a_cookies;
-    int *ncookies = ap->a_ncookies;
+       struct vop_readdir_args *ap = v;
+       vnode_t *vp = ap->a_vp;
+       struct cnode *cp = VTOC(vp);
+       struct uio *uiop = ap->a_uio;
+       kauth_cred_t cred = ap->a_cred;
+       int *eofflag = ap->a_eofflag;
 /* upcall decl */
 /* locals */
-    int error = 0;
-    enum vtype saved_type;
+       size_t initial_resid = uiop->uio_resid;
+       int error = 0;
+       int opened_internally = 0;
+       int ncookies;
+       char *buf;
+       struct vnode *cvp;
+       struct dirent *dirp;
 
-    MARK_ENTRY(CODA_READDIR_STATS);
-
-    CODADEBUG(CODA_READDIR, myprintf(("%s: (%p, %lu, %lld)\n", __func__,
-       uiop->uio_iov->iov_base, (unsigned long) uiop->uio_resid,
-       (long long) uiop->uio_offset)); )
+       MARK_ENTRY(CODA_READDIR_STATS);
 
-    /* Check for readdir of control object. */
-    if (IS_CTL_VP(vp)) {
-       MARK_INT_FAIL(CODA_READDIR_STATS);
-       return(ENOENT);
-    }
+       CODADEBUG(CODA_READDIR, myprintf(("%s: (%p, %lu, %lld)\n", __func__,
+           uiop->uio_iov->iov_base, (unsigned long) uiop->uio_resid,
+           (long long) uiop->uio_offset)); )
 
-    {
-       /* Redirect the request to UFS. */
+       /* Check for readdir of control object. */
+       if (IS_CTL_VP(vp)) {
+               MARK_INT_FAIL(CODA_READDIR_STATS);
+               return ENOENT;
+       }
 
        /* If directory is not already open do an "internal open" on it. */
-       int opened_internally = 0;
        if (cp->c_ovp == NULL) {
-           opened_internally = 1;
-           MARK_INT_GEN(CODA_OPEN_STATS);
-           error = VOP_OPEN(vp, FREAD, cred);
+               opened_internally = 1;
+               MARK_INT_GEN(CODA_OPEN_STATS);
+               error = VOP_OPEN(vp, FREAD, cred);
 #ifdef CODA_VERBOSE
-           printf("%s: Internally Opening %p\n", __func__, vp);
+               printf("%s: Internally Opening %p\n", __func__, vp);
 #endif
-           if (error) return(error);
-       } else
-           vp = cp->c_ovp;
+               if (error)
+                       return error;
+               KASSERT(cp->c_ovp != NULL);
+       }
+       cvp = cp->c_ovp;
+
+       CODADEBUG(CODA_READDIR, myprintf(("%s: fid = %s, refcnt = %d\n",
+           __func__, coda_f2s(&cp->c_fid), vrefcnt(cvp))); )
+
+       if (ap->a_ncookies) {
+               ncookies = ap->a_uio->uio_resid / _DIRENT_RECLEN(dirp, 1);
+               *ap->a_ncookies = 0;
+               *ap->a_cookies = malloc(ncookies * sizeof (off_t),
+                   M_TEMP, M_WAITOK);
+       }
+       buf = kmem_alloc(CODA_DIRBLKSIZ, KM_SLEEP);
+       dirp = kmem_alloc(sizeof(*dirp), KM_SLEEP);
+       vn_lock(cvp, LK_EXCLUSIVE | LK_RETRY);
+
+       while (error == 0) {
+               size_t resid = 0;
+               char *dp, *ep;
+
+               if (!ALIGNED_POINTER(uiop->uio_offset, uint32_t)) {
+                       error = EINVAL;
+                       break;
+               }
+               error = vn_rdwr(UIO_READ, cvp, buf,
+                   CODA_DIRBLKSIZ, uiop->uio_offset,
+                   UIO_SYSSPACE, IO_NODELOCKED, cred, &resid, curlwp);
+               if (error || resid == CODA_DIRBLKSIZ)
+                       break;
+               for (dp = buf, ep = dp + CODA_DIRBLKSIZ - resid; dp < ep; ) {
+                       off_t off;
+                       struct venus_dirent *vd = (struct venus_dirent *)dp;
 
-       /* Have UFS handle the call. */
-       CODADEBUG(CODA_READDIR, myprintf(("%s: fid = %s, refcnt = %d\n",
-           __func__, coda_f2s(&cp->c_fid), vrefcnt(vp))); )
-       saved_type = vp->v_type;
-       vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
-       vp->v_type = VDIR; /* pretend the container file is a dir */
-       error = VOP_READDIR(vp, uiop, cred, eofflag, cookies, ncookies);
-       vp->v_type = saved_type;
-       VOP_UNLOCK(vp);
+                       if (!ALIGNED_POINTER(vd, uint32_t) ||
+                           !ALIGNED_POINTER(vd->d_reclen, uint32_t) ||
+                           vd->d_reclen == 0) {
+                               error = EINVAL;
+                               break;
+                       }
+                       if (dp + vd->d_reclen > ep) {
+                               error = ENAMETOOLONG;
+                               break;
+                       }
+                       if (vd->d_namlen == 0) {
+                               uiop->uio_offset += vd->d_reclen;
+                               dp += vd->d_reclen;
+                               continue;
+                       }
+
+                       dirp->d_fileno = vd->d_fileno;
+                       dirp->d_type = vd->d_type;
+                       dirp->d_namlen = vd->d_namlen;
+                       dirp->d_reclen = _DIRENT_SIZE(dirp);
+                       strlcpy(dirp->d_name, vd->d_name, dirp->d_namlen + 1);
+
+                       if (uiop->uio_resid < dirp->d_reclen) {
+                               error = ENAMETOOLONG;
+                               break;
+                       }
 
+                       off = uiop->uio_offset;
+                       error = uiomove(dirp, dirp->d_reclen, uiop);
+                       uiop->uio_offset = off;
+                       if (error)
+                               break;
+
+                       uiop->uio_offset += vd->d_reclen;
+                       dp += vd->d_reclen;
+                       if (ap->a_ncookies)
+                               (*ap->a_cookies)[(*ap->a_ncookies)++] =
+                                   uiop->uio_offset;
+               }
+       }
+
+       VOP_UNLOCK(cvp);
+       kmem_free(dirp, sizeof(*dirp));
+       kmem_free(buf, CODA_DIRBLKSIZ);
+       if (eofflag && error == 0)
+               *eofflag = 1;
+       if (uiop->uio_resid < initial_resid && error == ENAMETOOLONG)
+               error = 0;
+       if (ap->a_ncookies && error) {
+               free(*ap->a_cookies, M_TEMP);
+               *ap->a_ncookies = 0;
+               *ap->a_cookies = NULL;
+       }
        if (error)
-           MARK_INT_FAIL(CODA_READDIR_STATS);
+               MARK_INT_FAIL(CODA_READDIR_STATS);
        else
-           MARK_INT_SAT(CODA_READDIR_STATS);
+               MARK_INT_SAT(CODA_READDIR_STATS);
 
        /* Do an "internal close" if necessary. */
        if (opened_internally) {
-           MARK_INT_GEN(CODA_CLOSE_STATS);
-           (void)VOP_CLOSE(vp, FREAD, cred);
+               MARK_INT_GEN(CODA_CLOSE_STATS);
+               (void)VOP_CLOSE(vp, FREAD, cred);
        }
-    }
 
-    return(error);
+       return error;
 }
 
 /*



Home | Main Index | Thread Index | Old Index