chfs_vnops.c revision 1.4.2.6
1 1.4.2.6 yamt /* $NetBSD: chfs_vnops.c,v 1.4.2.6 2013/01/23 00:06:31 yamt Exp $ */ 2 1.4.2.2 yamt 3 1.4.2.2 yamt /*- 4 1.4.2.2 yamt * Copyright (c) 2010 Department of Software Engineering, 5 1.4.2.2 yamt * University of Szeged, Hungary 6 1.4.2.2 yamt * Copyright (C) 2010 Tamas Toth <ttoth (at) inf.u-szeged.hu> 7 1.4.2.2 yamt * Copyright (C) 2010 Adam Hoka <ahoka (at) NetBSD.org> 8 1.4.2.2 yamt * All rights reserved. 9 1.4.2.2 yamt * 10 1.4.2.2 yamt * This code is derived from software contributed to The NetBSD Foundation 11 1.4.2.2 yamt * by the Department of Software Engineering, University of Szeged, Hungary 12 1.4.2.2 yamt * 13 1.4.2.2 yamt * Redistribution and use in source and binary forms, with or without 14 1.4.2.2 yamt * modification, are permitted provided that the following conditions 15 1.4.2.2 yamt * are met: 16 1.4.2.2 yamt * 1. Redistributions of source code must retain the above copyright 17 1.4.2.2 yamt * notice, this list of conditions and the following disclaimer. 18 1.4.2.2 yamt * 2. Redistributions in binary form must reproduce the above copyright 19 1.4.2.2 yamt * notice, this list of conditions and the following disclaimer in the 20 1.4.2.2 yamt * documentation and/or other materials provided with the distribution. 21 1.4.2.2 yamt * 22 1.4.2.2 yamt * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR 23 1.4.2.2 yamt * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES 24 1.4.2.2 yamt * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. 25 1.4.2.2 yamt * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, 26 1.4.2.2 yamt * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, 27 1.4.2.2 yamt * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; 28 1.4.2.2 yamt * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED 29 1.4.2.2 yamt * AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, 30 1.4.2.2 yamt * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY 31 1.4.2.2 yamt * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 32 1.4.2.2 yamt * SUCH DAMAGE. 33 1.4.2.2 yamt */ 34 1.4.2.2 yamt 35 1.4.2.2 yamt #include <sys/param.h> 36 1.4.2.2 yamt #include <miscfs/specfs/specdev.h> 37 1.4.2.2 yamt #include <miscfs/fifofs/fifo.h> 38 1.4.2.2 yamt #include <miscfs/genfs/genfs.h> 39 1.4.2.2 yamt #include <ufs/ufs/dir.h> 40 1.4.2.2 yamt #include <ufs/ufs/ufs_extern.h> 41 1.4.2.2 yamt #include <uvm/uvm.h> 42 1.4.2.2 yamt #include <sys/namei.h> 43 1.4.2.2 yamt #include <sys/stat.h> 44 1.4.2.2 yamt #include <sys/fcntl.h> 45 1.4.2.2 yamt #include <sys/buf.h> 46 1.4.2.2 yamt #include <sys/fstrans.h> 47 1.4.2.2 yamt #include <sys/vnode.h> 48 1.4.2.2 yamt 49 1.4.2.2 yamt #include "chfs.h" 50 1.4.2.2 yamt 51 1.4.2.2 yamt #define READ_S "chfs_read" 52 1.4.2.2 yamt 53 1.4.2.2 yamt int 54 1.4.2.2 yamt chfs_lookup(void *v) 55 1.4.2.2 yamt { 56 1.4.2.2 yamt struct vnode *dvp = ((struct vop_lookup_args *) v)->a_dvp; 57 1.4.2.2 yamt struct vnode **vpp = ((struct vop_lookup_args *) v)->a_vpp; 58 1.4.2.2 yamt struct componentname *cnp = ((struct vop_lookup_args *) v)->a_cnp; 59 1.4.2.2 yamt 60 1.4.2.2 yamt int error; 61 1.4.2.2 yamt struct chfs_inode* ip; 62 1.4.2.2 yamt struct ufsmount* ump; 63 1.4.2.2 yamt struct chfs_mount* chmp; 64 1.4.2.2 yamt struct chfs_vnode_cache* chvc; 65 1.4.2.2 yamt struct chfs_dirent* fd; 66 1.4.2.2 yamt 67 1.4.2.2 yamt dbg("lookup(): %s\n", cnp->cn_nameptr); 68 1.4.2.2 yamt 69 1.4.2.2 yamt KASSERT(VOP_ISLOCKED(dvp)); 70 1.4.2.2 yamt 71 1.4.2.2 yamt *vpp = NULL; 72 1.4.2.2 yamt 73 1.4.2.4 yamt /* Check accessibility of requested node as a first step. */ 74 1.4.2.2 yamt error = VOP_ACCESS(dvp, VEXEC, cnp->cn_cred); 75 1.4.2.2 yamt if (error != 0) { 76 1.4.2.2 yamt goto out; 77 1.4.2.2 yamt } 78 1.4.2.2 yamt 79 1.4.2.4 yamt /* If requesting the last path component on a read-only file system 80 1.4.2.4 yamt * with a write operation, deny it. */ 81 1.4.2.2 yamt if ((cnp->cn_flags & ISLASTCN) && (dvp->v_mount->mnt_flag & MNT_RDONLY) 82 1.4.2.2 yamt && (cnp->cn_nameiop == DELETE || cnp->cn_nameiop == RENAME)) { 83 1.4.2.2 yamt error = EROFS; 84 1.4.2.2 yamt goto out; 85 1.4.2.2 yamt } 86 1.4.2.2 yamt 87 1.4.2.4 yamt /* Avoid doing a linear scan of the directory if the requested 88 1.4.2.4 yamt * directory/name couple is already in the cache. */ 89 1.4.2.5 yamt if (cache_lookup(dvp, cnp->cn_nameptr, cnp->cn_namelen, 90 1.4.2.5 yamt cnp->cn_nameiop, cnp->cn_flags, NULL, vpp)) { 91 1.4.2.5 yamt error = *vpp == NULLVP ? ENOENT : 0; 92 1.4.2.2 yamt goto out; 93 1.4.2.2 yamt } 94 1.4.2.2 yamt 95 1.4.2.2 yamt ip = VTOI(dvp); 96 1.4.2.2 yamt ump = VFSTOUFS(dvp->v_mount); 97 1.4.2.2 yamt chmp = ump->um_chfs; 98 1.4.2.2 yamt if (ip->ino == 0) { 99 1.4.2.2 yamt ip->ino = ++chmp->chm_max_vno; 100 1.4.2.2 yamt } 101 1.4.2.2 yamt mutex_enter(&chmp->chm_lock_vnocache); 102 1.4.2.2 yamt chvc = chfs_vnode_cache_get(chmp, ip->ino); 103 1.4.2.2 yamt mutex_exit(&chmp->chm_lock_vnocache); 104 1.4.2.2 yamt 105 1.4.2.4 yamt /* We cannot be requesting the parent directory of the root node. */ 106 1.4.2.2 yamt KASSERT(IMPLIES(ip->ch_type == CHT_DIR && chvc->pvno == chvc->vno, 107 1.4.2.2 yamt !(cnp->cn_flags & ISDOTDOT))); 108 1.4.2.2 yamt 109 1.4.2.2 yamt if (cnp->cn_flags & ISDOTDOT) { 110 1.4.2.2 yamt VOP_UNLOCK(dvp); 111 1.4.2.2 yamt error = VFS_VGET(dvp->v_mount, ip->chvc->pvno, vpp); 112 1.4.2.2 yamt vn_lock(dvp, LK_EXCLUSIVE | LK_RETRY); 113 1.4.2.2 yamt } else if (cnp->cn_namelen == 1 && cnp->cn_nameptr[0] == '.') { 114 1.4.2.2 yamt vref(dvp); 115 1.4.2.2 yamt *vpp = dvp; 116 1.4.2.2 yamt error = 0; 117 1.4.2.2 yamt } else { 118 1.4.2.2 yamt fd = chfs_dir_lookup(ip, cnp); 119 1.4.2.2 yamt 120 1.4.2.2 yamt if (fd == NULL) { 121 1.4.2.2 yamt dbg("fd null\n"); 122 1.4.2.4 yamt /* The entry was not found in the directory. 123 1.4.2.4 yamt * This is OK if we are creating or renaming an 124 1.4.2.4 yamt * entry and are working on the last component of 125 1.4.2.4 yamt * the path name. */ 126 1.4.2.2 yamt if ((cnp->cn_flags & ISLASTCN) && (cnp->cn_nameiop == CREATE 127 1.4.2.2 yamt || cnp->cn_nameiop == RENAME)) { 128 1.4.2.2 yamt error = VOP_ACCESS(dvp, VWRITE, cnp->cn_cred); 129 1.4.2.2 yamt if (error) { 130 1.4.2.2 yamt dbg("after the entry was not found in dir\n"); 131 1.4.2.2 yamt goto out; 132 1.4.2.2 yamt } 133 1.4.2.2 yamt 134 1.4.2.2 yamt dbg("return EJUSTRETURN\n"); 135 1.4.2.2 yamt error = EJUSTRETURN; 136 1.4.2.2 yamt } else { 137 1.4.2.2 yamt error = ENOENT; 138 1.4.2.2 yamt } 139 1.4.2.2 yamt } else { 140 1.4.2.4 yamt /* If we are not at the last path component and 141 1.4.2.4 yamt * found a non-directory or non-link entry (which 142 1.4.2.4 yamt * may itself be pointing to a directory), raise 143 1.4.2.4 yamt * an error. */ 144 1.4.2.2 yamt if ((fd->type != CHT_DIR && fd->type != CHT_LNK) && !(cnp->cn_flags 145 1.4.2.2 yamt & ISLASTCN)) { 146 1.4.2.2 yamt error = ENOTDIR; 147 1.4.2.2 yamt goto out; 148 1.4.2.2 yamt } 149 1.4.2.2 yamt 150 1.4.2.2 yamt dbg("vno@allocating new vnode: %llu\n", 151 1.4.2.2 yamt (unsigned long long)fd->vno); 152 1.4.2.2 yamt error = VFS_VGET(dvp->v_mount, fd->vno, vpp); 153 1.4.2.2 yamt } 154 1.4.2.2 yamt } 155 1.4.2.4 yamt /* Store the result of this lookup in the cache. Avoid this if the 156 1.4.2.4 yamt * request was for creation, as it does not improve timings on 157 1.4.2.4 yamt * emprical tests. */ 158 1.4.2.4 yamt if (cnp->cn_nameiop != CREATE && (cnp->cn_flags & ISDOTDOT) == 0) { 159 1.4.2.5 yamt cache_enter(dvp, *vpp, cnp->cn_nameptr, cnp->cn_namelen, 160 1.4.2.5 yamt cnp->cn_flags); 161 1.4.2.4 yamt } 162 1.4.2.2 yamt 163 1.4.2.2 yamt out: 164 1.4.2.4 yamt /* If there were no errors, *vpp cannot be null and it must be 165 1.4.2.4 yamt * locked. */ 166 1.4.2.2 yamt KASSERT(IFF(error == 0, *vpp != NULL && VOP_ISLOCKED(*vpp))); 167 1.4.2.2 yamt KASSERT(VOP_ISLOCKED(dvp)); 168 1.4.2.2 yamt 169 1.4.2.2 yamt return error; 170 1.4.2.2 yamt } 171 1.4.2.2 yamt 172 1.4.2.2 yamt /* --------------------------------------------------------------------- */ 173 1.4.2.2 yamt 174 1.4.2.2 yamt int 175 1.4.2.2 yamt chfs_create(void *v) 176 1.4.2.2 yamt { 177 1.4.2.2 yamt struct vop_create_args /* { 178 1.4.2.2 yamt struct vnode *a_dvp; 179 1.4.2.2 yamt struct vnode **a_vpp; 180 1.4.2.2 yamt struct componentname *a_cnp; 181 1.4.2.2 yamt struct vattr *a_vap; 182 1.4.2.2 yamt } */*ap = v; 183 1.4.2.2 yamt int error, mode; 184 1.4.2.2 yamt dbg("create()\n"); 185 1.4.2.2 yamt 186 1.4.2.2 yamt mode = MAKEIMODE(ap->a_vap->va_type, ap->a_vap->va_mode); 187 1.4.2.2 yamt 188 1.4.2.2 yamt if ((mode & IFMT) == 0) { 189 1.4.2.2 yamt if (ap->a_vap->va_type == VREG) 190 1.4.2.2 yamt mode |= IFREG; 191 1.4.2.2 yamt if (ap->a_vap->va_type == VSOCK) 192 1.4.2.2 yamt mode |= IFSOCK; 193 1.4.2.2 yamt } 194 1.4.2.2 yamt 195 1.4.2.2 yamt error = chfs_makeinode(mode, ap->a_dvp, ap->a_vpp, ap->a_cnp, ap->a_vap->va_type); 196 1.4.2.2 yamt 197 1.4.2.2 yamt if (error) { 198 1.4.2.2 yamt dbg("error: %d\n", error); 199 1.4.2.2 yamt return error; 200 1.4.2.2 yamt } 201 1.4.2.2 yamt 202 1.4.2.2 yamt VN_KNOTE(ap->a_dvp, NOTE_WRITE); 203 1.4.2.2 yamt return 0; 204 1.4.2.2 yamt } 205 1.4.2.2 yamt /* --------------------------------------------------------------------- */ 206 1.4.2.2 yamt 207 1.4.2.2 yamt int 208 1.4.2.2 yamt chfs_mknod(void *v) 209 1.4.2.2 yamt { 210 1.4.2.2 yamt struct vnode *dvp = ((struct vop_mknod_args *) v)->a_dvp; 211 1.4.2.2 yamt struct vnode **vpp = ((struct vop_mknod_args *) v)->a_vpp; 212 1.4.2.2 yamt struct componentname *cnp = ((struct vop_mknod_args *) v)->a_cnp; 213 1.4.2.2 yamt struct vattr *vap = ((struct vop_mknod_args *) v)->a_vap; 214 1.4.2.2 yamt int mode, err = 0; 215 1.4.2.2 yamt struct chfs_inode *ip; 216 1.4.2.2 yamt struct vnode *vp; 217 1.4.2.2 yamt 218 1.4.2.2 yamt struct ufsmount *ump; 219 1.4.2.2 yamt struct chfs_mount *chmp; 220 1.4.2.2 yamt ino_t ino; 221 1.4.2.2 yamt 222 1.4.2.2 yamt struct chfs_full_dnode *fd; 223 1.4.2.2 yamt struct buf *bp; 224 1.4.2.2 yamt int len; 225 1.4.2.2 yamt dbg("mknod()\n"); 226 1.4.2.2 yamt 227 1.4.2.2 yamt ump = VFSTOUFS(dvp->v_mount); 228 1.4.2.2 yamt chmp = ump->um_chfs; 229 1.4.2.2 yamt 230 1.4.2.4 yamt /* Check type of node. */ 231 1.4.2.2 yamt if (vap->va_type != VBLK && vap->va_type != VCHR && vap->va_type != VFIFO) 232 1.4.2.2 yamt return EINVAL; 233 1.4.2.2 yamt 234 1.4.2.2 yamt vp = *vpp; 235 1.4.2.2 yamt 236 1.4.2.2 yamt mode = MAKEIMODE(vap->va_type, vap->va_mode); 237 1.4.2.2 yamt 238 1.4.2.2 yamt if ((mode & IFMT) == 0) { 239 1.4.2.2 yamt switch (vap->va_type) { 240 1.4.2.2 yamt case VBLK: 241 1.4.2.2 yamt mode |= IFBLK; 242 1.4.2.2 yamt break; 243 1.4.2.2 yamt case VCHR: 244 1.4.2.2 yamt mode |= IFCHR; 245 1.4.2.2 yamt break; 246 1.4.2.2 yamt case VFIFO: 247 1.4.2.2 yamt mode |= IFIFO; 248 1.4.2.2 yamt break; 249 1.4.2.2 yamt default: 250 1.4.2.2 yamt break; 251 1.4.2.2 yamt } 252 1.4.2.2 yamt } 253 1.4.2.2 yamt 254 1.4.2.4 yamt /* Create a new node. */ 255 1.4.2.2 yamt err = chfs_makeinode(mode, dvp, &vp, cnp, vap->va_type); 256 1.4.2.2 yamt 257 1.4.2.2 yamt ip = VTOI(vp); 258 1.4.2.2 yamt ino = ip->ino; 259 1.4.2.2 yamt if (vap->va_rdev != VNOVAL) 260 1.4.2.2 yamt ip->rdev = vap->va_rdev; 261 1.4.2.2 yamt 262 1.4.2.2 yamt if (vap->va_type == VFIFO) 263 1.4.2.2 yamt vp->v_op = chfs_fifoop_p; 264 1.4.2.2 yamt else { 265 1.4.2.2 yamt vp->v_op = chfs_specop_p; 266 1.4.2.2 yamt spec_node_init(vp, ip->rdev); 267 1.4.2.2 yamt } 268 1.4.2.2 yamt 269 1.4.2.2 yamt if (err) 270 1.4.2.2 yamt return err; 271 1.4.2.2 yamt 272 1.4.2.4 yamt /* Device is written out as a data node. */ 273 1.4.2.2 yamt len = sizeof(dev_t); 274 1.4.2.2 yamt chfs_set_vnode_size(vp, len); 275 1.4.2.2 yamt bp = getiobuf(vp, true); 276 1.4.2.2 yamt bp->b_bufsize = bp->b_resid = len; 277 1.4.2.2 yamt bp->b_data = kmem_alloc(len, KM_SLEEP); 278 1.4.2.2 yamt memcpy(bp->b_data, &ip->rdev, len); 279 1.4.2.2 yamt bp->b_blkno = 0; 280 1.4.2.2 yamt 281 1.4.2.2 yamt fd = chfs_alloc_full_dnode(); 282 1.4.2.2 yamt 283 1.4.2.2 yamt mutex_enter(&chmp->chm_lock_mountfields); 284 1.4.2.2 yamt 285 1.4.2.2 yamt err = chfs_write_flash_dnode(chmp, vp, bp, fd); 286 1.4.2.2 yamt if (err) { 287 1.4.2.2 yamt mutex_exit(&chmp->chm_lock_mountfields); 288 1.4.2.2 yamt kmem_free(bp->b_data, len); 289 1.4.2.2 yamt return err; 290 1.4.2.2 yamt } 291 1.4.2.2 yamt 292 1.4.2.4 yamt /* Add data node to the inode. */ 293 1.4.2.2 yamt err = chfs_add_full_dnode_to_inode(chmp, ip, fd); 294 1.4.2.2 yamt if (err) { 295 1.4.2.2 yamt mutex_exit(&chmp->chm_lock_mountfields); 296 1.4.2.2 yamt kmem_free(bp->b_data, len); 297 1.4.2.2 yamt return err; 298 1.4.2.2 yamt } 299 1.4.2.2 yamt 300 1.4.2.2 yamt mutex_exit(&chmp->chm_lock_mountfields); 301 1.4.2.2 yamt 302 1.4.2.2 yamt *vpp = vp; 303 1.4.2.2 yamt kmem_free(bp->b_data, len); 304 1.4.2.2 yamt putiobuf(bp); 305 1.4.2.2 yamt 306 1.4.2.2 yamt return 0; 307 1.4.2.2 yamt } 308 1.4.2.2 yamt 309 1.4.2.2 yamt /* --------------------------------------------------------------------- */ 310 1.4.2.2 yamt 311 1.4.2.2 yamt int 312 1.4.2.2 yamt chfs_open(void *v) 313 1.4.2.2 yamt { 314 1.4.2.2 yamt struct vnode *vp = ((struct vop_open_args *) v)->a_vp; 315 1.4.2.2 yamt int mode = ((struct vop_open_args *) v)->a_mode; 316 1.4.2.2 yamt dbg("open()\n"); 317 1.4.2.2 yamt 318 1.4.2.2 yamt int error; 319 1.4.2.2 yamt struct chfs_inode *ip; 320 1.4.2.2 yamt 321 1.4.2.2 yamt KASSERT(VOP_ISLOCKED(vp)); 322 1.4.2.2 yamt 323 1.4.2.2 yamt ip = VTOI(vp); 324 1.4.2.2 yamt 325 1.4.2.2 yamt KASSERT(vp->v_size == ip->size); 326 1.4.2.2 yamt if (ip->chvc->nlink < 1) { 327 1.4.2.2 yamt error = ENOENT; 328 1.4.2.2 yamt goto out; 329 1.4.2.2 yamt } 330 1.4.2.2 yamt 331 1.4.2.4 yamt /* If the file is marked append-only, deny write requests. */ 332 1.4.2.2 yamt if (ip->flags & APPEND && (mode & (FWRITE | O_APPEND)) == FWRITE) 333 1.4.2.2 yamt error = EPERM; 334 1.4.2.2 yamt else 335 1.4.2.2 yamt error = 0; 336 1.4.2.2 yamt 337 1.4.2.2 yamt out: 338 1.4.2.2 yamt KASSERT(VOP_ISLOCKED(vp)); 339 1.4.2.2 yamt return error; 340 1.4.2.2 yamt } 341 1.4.2.2 yamt 342 1.4.2.2 yamt /* --------------------------------------------------------------------- */ 343 1.4.2.2 yamt 344 1.4.2.2 yamt int 345 1.4.2.2 yamt chfs_close(void *v) 346 1.4.2.2 yamt { 347 1.4.2.2 yamt struct vnode *vp = ((struct vop_close_args *) v)->a_vp; 348 1.4.2.2 yamt dbg("close()\n"); 349 1.4.2.2 yamt 350 1.4.2.2 yamt struct chfs_inode *ip; 351 1.4.2.2 yamt 352 1.4.2.2 yamt KASSERT(VOP_ISLOCKED(vp)); 353 1.4.2.2 yamt 354 1.4.2.2 yamt ip = VTOI(vp); 355 1.4.2.2 yamt 356 1.4.2.2 yamt if (ip->chvc->nlink > 0) { 357 1.4.2.2 yamt chfs_update(vp, NULL, NULL, UPDATE_CLOSE); 358 1.4.2.2 yamt } 359 1.4.2.2 yamt 360 1.4.2.2 yamt return 0; 361 1.4.2.2 yamt } 362 1.4.2.2 yamt 363 1.4.2.2 yamt /* --------------------------------------------------------------------- */ 364 1.4.2.2 yamt 365 1.4.2.2 yamt int 366 1.4.2.2 yamt chfs_access(void *v) 367 1.4.2.2 yamt { 368 1.4.2.2 yamt struct vnode *vp = ((struct vop_access_args *) v)->a_vp; 369 1.4.2.2 yamt int mode = ((struct vop_access_args *) v)->a_mode; 370 1.4.2.2 yamt kauth_cred_t cred = ((struct vop_access_args *) v)->a_cred; 371 1.4.2.2 yamt 372 1.4.2.2 yamt dbg("access()\n"); 373 1.4.2.2 yamt struct chfs_inode *ip = VTOI(vp); 374 1.4.2.2 yamt 375 1.4.2.2 yamt if (mode & VWRITE) { 376 1.4.2.2 yamt switch (vp->v_type) { 377 1.4.2.2 yamt case VLNK: 378 1.4.2.2 yamt case VDIR: 379 1.4.2.2 yamt case VREG: 380 1.4.2.2 yamt if (vp->v_mount->mnt_flag & MNT_RDONLY) 381 1.4.2.2 yamt return (EROFS); 382 1.4.2.2 yamt break; 383 1.4.2.2 yamt case VBLK: 384 1.4.2.2 yamt case VCHR: 385 1.4.2.2 yamt case VSOCK: 386 1.4.2.2 yamt case VFIFO: 387 1.4.2.2 yamt break; 388 1.4.2.2 yamt default: 389 1.4.2.2 yamt break; 390 1.4.2.2 yamt } 391 1.4.2.2 yamt } 392 1.4.2.2 yamt 393 1.4.2.2 yamt if (mode & VWRITE && ip->flags & IMMUTABLE) 394 1.4.2.2 yamt return (EPERM); 395 1.4.2.2 yamt 396 1.4.2.2 yamt return kauth_authorize_vnode(cred, kauth_access_action(mode, vp->v_type, 397 1.4.2.2 yamt ip->mode & ALLPERMS), vp, NULL, genfs_can_access(vp->v_type, 398 1.4.2.2 yamt ip->mode & ALLPERMS, ip->uid, ip->gid, mode, cred)); 399 1.4.2.2 yamt } 400 1.4.2.2 yamt 401 1.4.2.2 yamt /* --------------------------------------------------------------------- */ 402 1.4.2.2 yamt 403 1.4.2.2 yamt int 404 1.4.2.2 yamt chfs_getattr(void *v) 405 1.4.2.2 yamt { 406 1.4.2.2 yamt struct vnode *vp = ((struct vop_getattr_args *) v)->a_vp; 407 1.4.2.2 yamt struct vattr *vap = ((struct vop_getattr_args *) v)->a_vap; 408 1.4.2.2 yamt 409 1.4.2.2 yamt struct chfs_inode *ip = VTOI(vp); 410 1.4.2.2 yamt dbg("getattr()\n"); 411 1.4.2.2 yamt 412 1.4.2.2 yamt KASSERT(vp->v_size == ip->size); 413 1.4.2.2 yamt 414 1.4.2.2 yamt vattr_null(vap); 415 1.4.2.2 yamt CHFS_ITIMES(ip, NULL, NULL, NULL); 416 1.4.2.2 yamt 417 1.4.2.2 yamt vap->va_type = CHTTOVT(ip->ch_type); 418 1.4.2.2 yamt vap->va_mode = ip->mode & ALLPERMS; 419 1.4.2.2 yamt vap->va_nlink = ip->chvc->nlink; 420 1.4.2.2 yamt vap->va_uid = ip->uid; 421 1.4.2.2 yamt vap->va_gid = ip->gid; 422 1.4.2.2 yamt vap->va_fsid = ip->dev; 423 1.4.2.2 yamt vap->va_fileid = ip->ino; 424 1.4.2.2 yamt vap->va_size = ip->size; 425 1.4.2.2 yamt vap->va_blocksize = PAGE_SIZE; 426 1.4.2.2 yamt vap->va_atime.tv_sec = ip->atime; 427 1.4.2.2 yamt vap->va_atime.tv_nsec = 0; 428 1.4.2.2 yamt vap->va_mtime.tv_sec = ip->mtime; 429 1.4.2.2 yamt vap->va_mtime.tv_nsec = 0; 430 1.4.2.2 yamt vap->va_ctime.tv_sec = ip->ctime; 431 1.4.2.2 yamt vap->va_ctime.tv_nsec = 0; 432 1.4.2.2 yamt vap->va_gen = ip->version; 433 1.4.2.2 yamt vap->va_flags = ip->flags; 434 1.4.2.2 yamt vap->va_rdev = ip->rdev; 435 1.4.2.2 yamt vap->va_bytes = round_page(ip->size); 436 1.4.2.2 yamt vap->va_filerev = VNOVAL; 437 1.4.2.2 yamt vap->va_vaflags = 0; 438 1.4.2.2 yamt vap->va_spare = VNOVAL; 439 1.4.2.2 yamt 440 1.4.2.2 yamt return 0; 441 1.4.2.2 yamt } 442 1.4.2.2 yamt 443 1.4.2.2 yamt /* --------------------------------------------------------------------- */ 444 1.4.2.2 yamt 445 1.4.2.2 yamt /* Note: modelled after tmpfs's same function */ 446 1.4.2.2 yamt 447 1.4.2.2 yamt int 448 1.4.2.2 yamt chfs_setattr(void *v) 449 1.4.2.2 yamt { 450 1.4.2.2 yamt struct vnode *vp = ((struct vop_setattr_args *) v)->a_vp; 451 1.4.2.2 yamt struct vattr *vap = ((struct vop_setattr_args *) v)->a_vap; 452 1.4.2.2 yamt kauth_cred_t cred = ((struct vop_setattr_args *) v)->a_cred; 453 1.4.2.2 yamt 454 1.4.2.2 yamt struct chfs_inode *ip; 455 1.4.2.2 yamt struct ufsmount *ump = VFSTOUFS(vp->v_mount); 456 1.4.2.2 yamt struct chfs_mount *chmp = ump->um_chfs; 457 1.4.2.2 yamt int error = 0; 458 1.4.2.2 yamt 459 1.4.2.2 yamt dbg("setattr()\n"); 460 1.4.2.2 yamt 461 1.4.2.2 yamt KASSERT(VOP_ISLOCKED(vp)); 462 1.4.2.2 yamt ip = VTOI(vp); 463 1.4.2.2 yamt 464 1.4.2.2 yamt /* Abort if any unsettable attribute is given. */ 465 1.4.2.2 yamt if (vap->va_type != VNON || vap->va_nlink != VNOVAL || 466 1.4.2.2 yamt vap->va_fsid != VNOVAL || vap->va_fileid != VNOVAL || 467 1.4.2.2 yamt vap->va_blocksize != VNOVAL /*|| GOODTIME(&vap->va_ctime)*/ || 468 1.4.2.2 yamt vap->va_gen != VNOVAL || vap->va_rdev != VNOVAL || 469 1.4.2.2 yamt vap->va_bytes != VNOVAL) { 470 1.4.2.2 yamt return EINVAL; 471 1.4.2.2 yamt } 472 1.4.2.2 yamt 473 1.4.2.4 yamt /* set flags */ 474 1.4.2.4 yamt if (error == 0 && (vap->va_flags != VNOVAL)) { 475 1.4.2.2 yamt error = chfs_chflags(vp, vap->va_flags, cred); 476 1.4.2.4 yamt return error; 477 1.4.2.4 yamt } 478 1.4.2.4 yamt 479 1.4.2.4 yamt if (ip->flags & (IMMUTABLE | APPEND)) { 480 1.4.2.4 yamt error = EPERM; 481 1.4.2.4 yamt return error; 482 1.4.2.4 yamt } 483 1.4.2.2 yamt 484 1.4.2.4 yamt /* set size */ 485 1.4.2.4 yamt if (error == 0 && (vap->va_size != VNOVAL)) { 486 1.4.2.2 yamt error = chfs_chsize(vp, vap->va_size, cred); 487 1.4.2.4 yamt if (error) 488 1.4.2.4 yamt return error; 489 1.4.2.4 yamt } 490 1.4.2.2 yamt 491 1.4.2.4 yamt /* set owner */ 492 1.4.2.4 yamt if (error == 0 && (vap->va_uid != VNOVAL || vap->va_gid != VNOVAL)) { 493 1.4.2.2 yamt error = chfs_chown(vp, vap->va_uid, vap->va_gid, cred); 494 1.4.2.4 yamt if (error) 495 1.4.2.4 yamt return error; 496 1.4.2.4 yamt } 497 1.4.2.2 yamt 498 1.4.2.4 yamt /* set mode */ 499 1.4.2.4 yamt if (error == 0 && (vap->va_mode != VNOVAL)) { 500 1.4.2.2 yamt error = chfs_chmod(vp, vap->va_mode, cred); 501 1.4.2.4 yamt if (error) 502 1.4.2.4 yamt return error; 503 1.4.2.4 yamt } 504 1.4.2.2 yamt 505 1.4.2.4 yamt /* set time */ 506 1.4.2.2 yamt if (vap->va_atime.tv_sec != VNOVAL || vap->va_mtime.tv_sec != VNOVAL) { 507 1.4.2.2 yamt error = kauth_authorize_vnode(cred, KAUTH_VNODE_WRITE_TIMES, vp, 508 1.4.2.2 yamt NULL, genfs_can_chtimes(vp, vap->va_vaflags, ip->uid, cred)); 509 1.4.2.2 yamt if (error) 510 1.4.2.2 yamt return error; 511 1.4.2.2 yamt if (vap->va_atime.tv_sec != VNOVAL) 512 1.4.2.2 yamt ip->iflag |= IN_ACCESS; 513 1.4.2.2 yamt if (vap->va_mtime.tv_sec != VNOVAL) 514 1.4.2.2 yamt ip->iflag |= IN_CHANGE | IN_UPDATE; 515 1.4.2.2 yamt error = chfs_update(vp, 516 1.4.2.2 yamt &vap->va_atime, &vap->va_mtime, UPDATE_WAIT); 517 1.4.2.2 yamt if (error) 518 1.4.2.2 yamt return error; 519 1.4.2.2 yamt } 520 1.4.2.2 yamt 521 1.4.2.4 yamt /* Write it out. */ 522 1.4.2.2 yamt mutex_enter(&chmp->chm_lock_mountfields); 523 1.4.2.2 yamt error = chfs_write_flash_vnode(chmp, ip, ALLOC_NORMAL); 524 1.4.2.2 yamt mutex_exit(&chmp->chm_lock_mountfields); 525 1.4.2.2 yamt 526 1.4.2.2 yamt return error; 527 1.4.2.2 yamt } 528 1.4.2.2 yamt 529 1.4.2.2 yamt int 530 1.4.2.2 yamt chfs_chmod(struct vnode *vp, int mode, kauth_cred_t cred) 531 1.4.2.2 yamt { 532 1.4.2.2 yamt struct chfs_inode *ip = VTOI(vp); 533 1.4.2.2 yamt int error; 534 1.4.2.2 yamt dbg("chmod\n"); 535 1.4.2.2 yamt 536 1.4.2.2 yamt error = kauth_authorize_vnode(cred, KAUTH_VNODE_WRITE_SECURITY, vp, 537 1.4.2.2 yamt NULL, genfs_can_chmod(vp->v_type, cred, ip->uid, ip->gid, mode)); 538 1.4.2.2 yamt if (error) 539 1.4.2.2 yamt return error; 540 1.4.2.2 yamt ip->mode &= ~ALLPERMS; 541 1.4.2.2 yamt ip->mode |= (mode & ALLPERMS); 542 1.4.2.2 yamt ip->iflag |= IN_CHANGE; 543 1.4.2.2 yamt 544 1.4.2.2 yamt error = chfs_update(vp, NULL, NULL, UPDATE_WAIT); 545 1.4.2.2 yamt if (error) 546 1.4.2.2 yamt return error; 547 1.4.2.2 yamt 548 1.4.2.2 yamt return 0; 549 1.4.2.2 yamt } 550 1.4.2.2 yamt 551 1.4.2.2 yamt int 552 1.4.2.2 yamt chfs_chown(struct vnode *vp, uid_t uid, gid_t gid, kauth_cred_t cred) 553 1.4.2.2 yamt { 554 1.4.2.2 yamt struct chfs_inode *ip = VTOI(vp); 555 1.4.2.2 yamt int error; 556 1.4.2.2 yamt dbg("chown\n"); 557 1.4.2.2 yamt 558 1.4.2.2 yamt if (uid == (uid_t)VNOVAL) 559 1.4.2.2 yamt uid = ip->uid; 560 1.4.2.2 yamt if (gid == (gid_t)VNOVAL) 561 1.4.2.2 yamt gid = ip->gid; 562 1.4.2.2 yamt 563 1.4.2.2 yamt error = kauth_authorize_vnode(cred, KAUTH_VNODE_CHANGE_OWNERSHIP, vp, 564 1.4.2.2 yamt NULL, genfs_can_chown(cred, ip->uid, ip->gid, uid, gid)); 565 1.4.2.2 yamt if (error) 566 1.4.2.2 yamt return error; 567 1.4.2.2 yamt 568 1.4.2.2 yamt ip->gid = gid; 569 1.4.2.2 yamt ip->uid = uid; 570 1.4.2.2 yamt ip->iflag |= IN_CHANGE; 571 1.4.2.2 yamt 572 1.4.2.2 yamt error = chfs_update(vp, NULL, NULL, UPDATE_WAIT); 573 1.4.2.2 yamt if (error) 574 1.4.2.2 yamt return error; 575 1.4.2.2 yamt 576 1.4.2.2 yamt return 0; 577 1.4.2.2 yamt } 578 1.4.2.2 yamt 579 1.4.2.2 yamt 580 1.4.2.2 yamt /* --------------------------------------------------------------------- */ 581 1.4.2.2 yamt /* calculates ((off_t)blk * chmp->chm_chm_fs_bsize) */ 582 1.4.2.2 yamt #define lblktosize(chmp, blk) \ 583 1.4.2.2 yamt (((off_t)(blk)) << (chmp)->chm_fs_bshift) 584 1.4.2.2 yamt 585 1.4.2.2 yamt /* calculates (loc % chmp->chm_chm_fs_bsize) */ 586 1.4.2.2 yamt #define blkoff(chmp, loc) \ 587 1.4.2.2 yamt ((loc) & (chmp)->chm_fs_qbmask) 588 1.4.2.2 yamt 589 1.4.2.2 yamt /* calculates (loc / chmp->chm_chm_fs_bsize) */ 590 1.4.2.2 yamt #define lblkno(chmp, loc) \ 591 1.4.2.2 yamt ((loc) >> (chmp)->chm_fs_bshift) 592 1.4.2.2 yamt 593 1.4.2.2 yamt /* calculates roundup(size, chmp->chm_chm_fs_fsize) */ 594 1.4.2.2 yamt #define fragroundup(chmp, size) \ 595 1.4.2.2 yamt (((size) + (chmp)->chm_fs_qfmask) & (chmp)->chm_fs_fmask) 596 1.4.2.2 yamt 597 1.4.2.2 yamt #define blksize(chmp, ip, lbn) \ 598 1.4.2.6 yamt (((lbn) >= UFS_NDADDR || (ip)->size >= lblktosize(chmp, (lbn) + 1)) \ 599 1.4.2.2 yamt ? (chmp)->chm_fs_bsize \ 600 1.4.2.2 yamt : (fragroundup(chmp, blkoff(chmp, (ip)->size)))) 601 1.4.2.2 yamt 602 1.4.2.2 yamt /* calculates roundup(size, chmp->chm_chm_fs_bsize) */ 603 1.4.2.2 yamt #define blkroundup(chmp, size) \ 604 1.4.2.2 yamt (((size) + (chmp)->chm_fs_qbmask) & (chmp)->chm_fs_bmask) 605 1.4.2.2 yamt 606 1.4.2.4 yamt /* from ffs read */ 607 1.4.2.2 yamt int 608 1.4.2.2 yamt chfs_read(void *v) 609 1.4.2.2 yamt { 610 1.4.2.2 yamt struct vop_read_args /* { 611 1.4.2.2 yamt struct vnode *a_vp; 612 1.4.2.2 yamt struct uio *a_uio; 613 1.4.2.2 yamt int a_ioflag; 614 1.4.2.2 yamt kauth_cred_t a_cred; 615 1.4.2.2 yamt } */ *ap = v; 616 1.4.2.2 yamt struct vnode *vp; 617 1.4.2.2 yamt struct chfs_inode *ip; 618 1.4.2.2 yamt struct uio *uio; 619 1.4.2.2 yamt struct ufsmount *ump; 620 1.4.2.2 yamt struct buf *bp; 621 1.4.2.2 yamt struct chfs_mount *chmp; 622 1.4.2.2 yamt daddr_t lbn, nextlbn; 623 1.4.2.2 yamt off_t bytesinfile; 624 1.4.2.2 yamt long size, xfersize, blkoffset; 625 1.4.2.2 yamt int error, ioflag; 626 1.4.2.2 yamt vsize_t bytelen; 627 1.4.2.2 yamt bool usepc = false; 628 1.4.2.2 yamt 629 1.4.2.2 yamt dbg("chfs_read\n"); 630 1.4.2.2 yamt 631 1.4.2.2 yamt vp = ap->a_vp; 632 1.4.2.2 yamt ip = VTOI(vp); 633 1.4.2.2 yamt ump = ip->ump; 634 1.4.2.2 yamt uio = ap->a_uio; 635 1.4.2.2 yamt ioflag = ap->a_ioflag; 636 1.4.2.2 yamt error = 0; 637 1.4.2.2 yamt 638 1.4.2.2 yamt dbg("ip->size:%llu\n", (unsigned long long)ip->size); 639 1.4.2.2 yamt 640 1.4.2.2 yamt #ifdef DIAGNOSTIC 641 1.4.2.2 yamt if (uio->uio_rw != UIO_READ) 642 1.4.2.2 yamt panic("%s: mode", READ_S); 643 1.4.2.2 yamt 644 1.4.2.2 yamt if (vp->v_type == VLNK) { 645 1.4.2.2 yamt if (ip->size < ump->um_maxsymlinklen) 646 1.4.2.2 yamt panic("%s: short symlink", READ_S); 647 1.4.2.2 yamt } else if (vp->v_type != VREG && vp->v_type != VDIR) 648 1.4.2.2 yamt panic("%s: type %d", READ_S, vp->v_type); 649 1.4.2.2 yamt #endif 650 1.4.2.2 yamt chmp = ip->chmp; 651 1.4.2.2 yamt if ((u_int64_t)uio->uio_offset > ump->um_maxfilesize) 652 1.4.2.2 yamt return (EFBIG); 653 1.4.2.2 yamt if (uio->uio_resid == 0) 654 1.4.2.2 yamt return (0); 655 1.4.2.2 yamt 656 1.4.2.2 yamt fstrans_start(vp->v_mount, FSTRANS_SHARED); 657 1.4.2.2 yamt 658 1.4.2.2 yamt if (uio->uio_offset >= ip->size) 659 1.4.2.2 yamt goto out; 660 1.4.2.2 yamt 661 1.4.2.2 yamt usepc = vp->v_type == VREG; 662 1.4.2.2 yamt bytelen = 0; 663 1.4.2.2 yamt if (usepc) { 664 1.4.2.2 yamt const int advice = IO_ADV_DECODE(ap->a_ioflag); 665 1.4.2.2 yamt 666 1.4.2.2 yamt while (uio->uio_resid > 0) { 667 1.4.2.2 yamt if (ioflag & IO_DIRECT) { 668 1.4.2.2 yamt genfs_directio(vp, uio, ioflag); 669 1.4.2.2 yamt } 670 1.4.2.2 yamt bytelen = MIN(ip->size - uio->uio_offset, 671 1.4.2.2 yamt uio->uio_resid); 672 1.4.2.2 yamt if (bytelen == 0) 673 1.4.2.2 yamt break; 674 1.4.2.2 yamt error = ubc_uiomove(&vp->v_uobj, uio, bytelen, advice, 675 1.4.2.2 yamt UBC_READ | UBC_PARTIALOK | 676 1.4.2.2 yamt (UBC_WANT_UNMAP(vp) ? UBC_UNMAP : 0)); 677 1.4.2.2 yamt if (error) 678 1.4.2.2 yamt break; 679 1.4.2.2 yamt 680 1.4.2.2 yamt } 681 1.4.2.2 yamt goto out; 682 1.4.2.2 yamt } 683 1.4.2.2 yamt 684 1.4.2.2 yamt dbg("start reading\n"); 685 1.4.2.2 yamt for (error = 0, bp = NULL; uio->uio_resid > 0; bp = NULL) { 686 1.4.2.2 yamt bytesinfile = ip->size - uio->uio_offset; 687 1.4.2.2 yamt if (bytesinfile <= 0) 688 1.4.2.2 yamt break; 689 1.4.2.2 yamt lbn = lblkno(chmp, uio->uio_offset); 690 1.4.2.2 yamt nextlbn = lbn + 1; 691 1.4.2.2 yamt size = blksize(chmp, ip, lbn); 692 1.4.2.2 yamt blkoffset = blkoff(chmp, uio->uio_offset); 693 1.4.2.2 yamt xfersize = MIN(MIN(chmp->chm_fs_bsize - blkoffset, uio->uio_resid), 694 1.4.2.2 yamt bytesinfile); 695 1.4.2.2 yamt 696 1.4.2.2 yamt if (lblktosize(chmp, nextlbn) >= ip->size) { 697 1.4.2.2 yamt error = bread(vp, lbn, size, NOCRED, 0, &bp); 698 1.4.2.2 yamt dbg("after bread\n"); 699 1.4.2.2 yamt } else { 700 1.4.2.2 yamt int nextsize = blksize(chmp, ip, nextlbn); 701 1.4.2.2 yamt dbg("size: %ld\n", size); 702 1.4.2.2 yamt error = breadn(vp, lbn, 703 1.4.2.2 yamt size, &nextlbn, &nextsize, 1, NOCRED, 0, &bp); 704 1.4.2.2 yamt dbg("after breadN\n"); 705 1.4.2.2 yamt } 706 1.4.2.2 yamt if (error) 707 1.4.2.2 yamt break; 708 1.4.2.2 yamt 709 1.4.2.2 yamt /* 710 1.4.2.2 yamt * We should only get non-zero b_resid when an I/O error 711 1.4.2.2 yamt * has occurred, which should cause us to break above. 712 1.4.2.2 yamt * However, if the short read did not cause an error, 713 1.4.2.2 yamt * then we want to ensure that we do not uiomove bad 714 1.4.2.2 yamt * or uninitialized data. 715 1.4.2.2 yamt */ 716 1.4.2.2 yamt size -= bp->b_resid; 717 1.4.2.2 yamt if (size < xfersize) { 718 1.4.2.2 yamt if (size == 0) 719 1.4.2.2 yamt break; 720 1.4.2.2 yamt xfersize = size; 721 1.4.2.2 yamt } 722 1.4.2.2 yamt dbg("uiomove\n"); 723 1.4.2.2 yamt error = uiomove((char *)bp->b_data + blkoffset, xfersize, uio); 724 1.4.2.2 yamt if (error) 725 1.4.2.2 yamt break; 726 1.4.2.2 yamt brelse(bp, 0); 727 1.4.2.2 yamt } 728 1.4.2.4 yamt 729 1.4.2.2 yamt if (bp != NULL) 730 1.4.2.2 yamt brelse(bp, 0); 731 1.4.2.2 yamt 732 1.4.2.2 yamt out: 733 1.4.2.4 yamt // FIXME HACK 734 1.4.2.4 yamt ip->ino = ip->chvc->vno; 735 1.4.2.4 yamt 736 1.4.2.2 yamt if (!(vp->v_mount->mnt_flag & MNT_NOATIME)) { 737 1.4.2.2 yamt ip->iflag |= IN_ACCESS; 738 1.4.2.2 yamt if ((ap->a_ioflag & IO_SYNC) == IO_SYNC) { 739 1.4.2.2 yamt if (error) { 740 1.4.2.2 yamt fstrans_done(vp->v_mount); 741 1.4.2.2 yamt return error; 742 1.4.2.2 yamt } 743 1.4.2.2 yamt error = chfs_update(vp, NULL, NULL, UPDATE_WAIT); 744 1.4.2.2 yamt } 745 1.4.2.2 yamt } 746 1.4.2.2 yamt 747 1.4.2.2 yamt dbg("[END]\n"); 748 1.4.2.2 yamt fstrans_done(vp->v_mount); 749 1.4.2.4 yamt 750 1.4.2.2 yamt return (error); 751 1.4.2.2 yamt } 752 1.4.2.2 yamt 753 1.4.2.2 yamt 754 1.4.2.2 yamt /* --------------------------------------------------------------------- */ 755 1.4.2.2 yamt 756 1.4.2.4 yamt /* from ffs write */ 757 1.4.2.2 yamt int 758 1.4.2.2 yamt chfs_write(void *v) 759 1.4.2.2 yamt { 760 1.4.2.2 yamt struct vop_write_args /* { 761 1.4.2.2 yamt struct vnode *a_vp; 762 1.4.2.2 yamt struct uio *a_uio; 763 1.4.2.2 yamt int a_ioflag; 764 1.4.2.2 yamt kauth_cred_t a_cred; 765 1.4.2.2 yamt } */ *ap = v; 766 1.4.2.2 yamt struct vnode *vp ; 767 1.4.2.2 yamt struct uio *uio; 768 1.4.2.2 yamt struct chfs_inode *ip; 769 1.4.2.2 yamt struct chfs_mount *chmp; 770 1.4.2.2 yamt struct lwp *l; 771 1.4.2.2 yamt kauth_cred_t cred; 772 1.4.2.2 yamt off_t osize, origoff, oldoff, preallocoff, endallocoff, nsize; 773 1.4.2.2 yamt int blkoffset, error, flags, ioflag, resid; 774 1.4.2.2 yamt int aflag; 775 1.4.2.2 yamt int extended=0; 776 1.4.2.2 yamt vsize_t bytelen; 777 1.4.2.2 yamt bool async; 778 1.4.2.2 yamt struct ufsmount *ump; 779 1.4.2.2 yamt 780 1.4.2.2 yamt 781 1.4.2.2 yamt cred = ap->a_cred; 782 1.4.2.2 yamt ioflag = ap->a_ioflag; 783 1.4.2.2 yamt uio = ap->a_uio; 784 1.4.2.2 yamt vp = ap->a_vp; 785 1.4.2.2 yamt ip = VTOI(vp); 786 1.4.2.2 yamt ump = ip->ump; 787 1.4.2.2 yamt 788 1.4.2.2 yamt dbg("write\n"); 789 1.4.2.2 yamt 790 1.4.2.2 yamt KASSERT(vp->v_size == ip->size); 791 1.4.2.2 yamt 792 1.4.2.2 yamt switch (vp->v_type) { 793 1.4.2.2 yamt case VREG: 794 1.4.2.2 yamt if (ioflag & IO_APPEND) 795 1.4.2.2 yamt uio->uio_offset = ip->size; 796 1.4.2.2 yamt if ((ip->flags & APPEND) && uio->uio_offset != ip->size) 797 1.4.2.2 yamt return (EPERM); 798 1.4.2.2 yamt /* FALLTHROUGH */ 799 1.4.2.2 yamt case VLNK: 800 1.4.2.2 yamt break; 801 1.4.2.2 yamt case VDIR: 802 1.4.2.2 yamt if ((ioflag & IO_SYNC) == 0) 803 1.4.2.2 yamt panic("chfs_write: nonsync dir write"); 804 1.4.2.2 yamt break; 805 1.4.2.2 yamt default: 806 1.4.2.2 yamt panic("chfs_write: type"); 807 1.4.2.2 yamt } 808 1.4.2.2 yamt 809 1.4.2.2 yamt chmp = ip->chmp; 810 1.4.2.2 yamt if (uio->uio_offset < 0 || 811 1.4.2.2 yamt (u_int64_t)uio->uio_offset + 812 1.4.2.2 yamt uio->uio_resid > ump->um_maxfilesize) { 813 1.4.2.2 yamt dbg("uio->uio_offset = %lld | uio->uio_offset + " 814 1.4.2.2 yamt "uio->uio_resid (%llu) > ump->um_maxfilesize (%lld)\n", 815 1.4.2.2 yamt (long long)uio->uio_offset, 816 1.4.2.2 yamt (uint64_t)uio->uio_offset + uio->uio_resid, 817 1.4.2.2 yamt (long long)ump->um_maxfilesize); 818 1.4.2.2 yamt return (EFBIG); 819 1.4.2.2 yamt } 820 1.4.2.2 yamt /* 821 1.4.2.2 yamt * Maybe this should be above the vnode op call, but so long as 822 1.4.2.2 yamt * file servers have no limits, I don't think it matters. 823 1.4.2.2 yamt */ 824 1.4.2.2 yamt l = curlwp; 825 1.4.2.2 yamt if (vp->v_type == VREG && l && 826 1.4.2.2 yamt uio->uio_offset + uio->uio_resid > 827 1.4.2.2 yamt l->l_proc->p_rlimit[RLIMIT_FSIZE].rlim_cur) { 828 1.4.2.2 yamt mutex_enter(proc_lock); 829 1.4.2.2 yamt psignal(l->l_proc, SIGXFSZ); 830 1.4.2.2 yamt mutex_exit(proc_lock); 831 1.4.2.2 yamt return (EFBIG); 832 1.4.2.2 yamt } 833 1.4.2.2 yamt if (uio->uio_resid == 0) 834 1.4.2.2 yamt return (0); 835 1.4.2.2 yamt 836 1.4.2.2 yamt fstrans_start(vp->v_mount, FSTRANS_SHARED); 837 1.4.2.2 yamt 838 1.4.2.2 yamt flags = ioflag & IO_SYNC ? B_SYNC : 0; 839 1.4.2.2 yamt async = vp->v_mount->mnt_flag & MNT_ASYNC; 840 1.4.2.2 yamt origoff = uio->uio_offset; 841 1.4.2.2 yamt resid = uio->uio_resid; 842 1.4.2.2 yamt osize = ip->size; 843 1.4.2.2 yamt error = 0; 844 1.4.2.2 yamt 845 1.4.2.2 yamt preallocoff = round_page(blkroundup(chmp, 846 1.4.2.2 yamt MAX(osize, uio->uio_offset))); 847 1.4.2.2 yamt aflag = ioflag & IO_SYNC ? B_SYNC : 0; 848 1.4.2.2 yamt nsize = MAX(osize, uio->uio_offset + uio->uio_resid); 849 1.4.2.2 yamt endallocoff = nsize - blkoff(chmp, nsize); 850 1.4.2.2 yamt 851 1.4.2.2 yamt /* 852 1.4.2.2 yamt * if we're increasing the file size, deal with expanding 853 1.4.2.2 yamt * the fragment if there is one. 854 1.4.2.2 yamt */ 855 1.4.2.2 yamt 856 1.4.2.6 yamt if (nsize > osize && lblkno(chmp, osize) < UFS_NDADDR && 857 1.4.2.2 yamt lblkno(chmp, osize) != lblkno(chmp, nsize) && 858 1.4.2.2 yamt blkroundup(chmp, osize) != osize) { 859 1.4.2.2 yamt off_t eob; 860 1.4.2.2 yamt 861 1.4.2.2 yamt eob = blkroundup(chmp, osize); 862 1.4.2.2 yamt uvm_vnp_setwritesize(vp, eob); 863 1.4.2.2 yamt error = ufs_balloc_range(vp, osize, eob - osize, cred, aflag); 864 1.4.2.2 yamt if (error) 865 1.4.2.2 yamt goto out; 866 1.4.2.2 yamt if (flags & B_SYNC) { 867 1.4.2.2 yamt mutex_enter(vp->v_interlock); 868 1.4.2.2 yamt VOP_PUTPAGES(vp, 869 1.4.2.2 yamt trunc_page(osize & chmp->chm_fs_bmask), 870 1.4.2.2 yamt round_page(eob), 871 1.4.2.2 yamt PGO_CLEANIT | PGO_SYNCIO | PGO_JOURNALLOCKED); 872 1.4.2.2 yamt } 873 1.4.2.2 yamt } 874 1.4.2.2 yamt 875 1.4.2.2 yamt while (uio->uio_resid > 0) { 876 1.4.2.2 yamt int ubc_flags = UBC_WRITE; 877 1.4.2.2 yamt bool overwrite; /* if we're overwrite a whole block */ 878 1.4.2.2 yamt off_t newoff; 879 1.4.2.2 yamt 880 1.4.2.2 yamt if (ioflag & IO_DIRECT) { 881 1.4.2.2 yamt genfs_directio(vp, uio, ioflag | IO_JOURNALLOCKED); 882 1.4.2.2 yamt } 883 1.4.2.2 yamt 884 1.4.2.2 yamt oldoff = uio->uio_offset; 885 1.4.2.2 yamt blkoffset = blkoff(chmp, uio->uio_offset); 886 1.4.2.2 yamt bytelen = MIN(chmp->chm_fs_bsize - blkoffset, uio->uio_resid); 887 1.4.2.2 yamt if (bytelen == 0) { 888 1.4.2.2 yamt break; 889 1.4.2.2 yamt } 890 1.4.2.2 yamt 891 1.4.2.2 yamt /* 892 1.4.2.2 yamt * if we're filling in a hole, allocate the blocks now and 893 1.4.2.2 yamt * initialize the pages first. if we're extending the file, 894 1.4.2.2 yamt * we can safely allocate blocks without initializing pages 895 1.4.2.2 yamt * since the new blocks will be inaccessible until the write 896 1.4.2.2 yamt * is complete. 897 1.4.2.2 yamt */ 898 1.4.2.2 yamt overwrite = uio->uio_offset >= preallocoff && 899 1.4.2.2 yamt uio->uio_offset < endallocoff; 900 1.4.2.2 yamt if (!overwrite && (vp->v_vflag & VV_MAPPED) == 0 && 901 1.4.2.2 yamt blkoff(chmp, uio->uio_offset) == 0 && 902 1.4.2.2 yamt (uio->uio_offset & PAGE_MASK) == 0) { 903 1.4.2.2 yamt vsize_t len; 904 1.4.2.2 yamt 905 1.4.2.2 yamt len = trunc_page(bytelen); 906 1.4.2.2 yamt len -= blkoff(chmp, len); 907 1.4.2.2 yamt if (len > 0) { 908 1.4.2.2 yamt overwrite = true; 909 1.4.2.2 yamt bytelen = len; 910 1.4.2.2 yamt } 911 1.4.2.2 yamt } 912 1.4.2.2 yamt 913 1.4.2.2 yamt newoff = oldoff + bytelen; 914 1.4.2.2 yamt if (vp->v_size < newoff) { 915 1.4.2.2 yamt uvm_vnp_setwritesize(vp, newoff); 916 1.4.2.2 yamt } 917 1.4.2.2 yamt 918 1.4.2.2 yamt if (!overwrite) { 919 1.4.2.2 yamt error = ufs_balloc_range(vp, uio->uio_offset, bytelen, 920 1.4.2.2 yamt cred, aflag); 921 1.4.2.2 yamt if (error) 922 1.4.2.2 yamt break; 923 1.4.2.2 yamt } else { 924 1.4.2.2 yamt genfs_node_wrlock(vp); 925 1.4.2.2 yamt error = GOP_ALLOC(vp, uio->uio_offset, bytelen, 926 1.4.2.2 yamt aflag, cred); 927 1.4.2.2 yamt genfs_node_unlock(vp); 928 1.4.2.2 yamt if (error) 929 1.4.2.2 yamt break; 930 1.4.2.2 yamt ubc_flags |= UBC_FAULTBUSY; 931 1.4.2.2 yamt } 932 1.4.2.2 yamt 933 1.4.2.2 yamt /* 934 1.4.2.2 yamt * copy the data. 935 1.4.2.2 yamt */ 936 1.4.2.2 yamt 937 1.4.2.2 yamt ubc_flags |= UBC_WANT_UNMAP(vp) ? UBC_UNMAP : 0; 938 1.4.2.2 yamt error = ubc_uiomove(&vp->v_uobj, uio, bytelen, 939 1.4.2.2 yamt IO_ADV_DECODE(ioflag), ubc_flags); 940 1.4.2.2 yamt 941 1.4.2.2 yamt /* 942 1.4.2.2 yamt * update UVM's notion of the size now that we've 943 1.4.2.2 yamt * copied the data into the vnode's pages. 944 1.4.2.2 yamt * 945 1.4.2.2 yamt * we should update the size even when uiomove failed. 946 1.4.2.2 yamt */ 947 1.4.2.2 yamt 948 1.4.2.2 yamt if (vp->v_size < newoff) { 949 1.4.2.2 yamt uvm_vnp_setsize(vp, newoff); 950 1.4.2.2 yamt extended = 1; 951 1.4.2.2 yamt } 952 1.4.2.2 yamt 953 1.4.2.2 yamt if (error) 954 1.4.2.2 yamt break; 955 1.4.2.2 yamt 956 1.4.2.2 yamt /* 957 1.4.2.2 yamt * flush what we just wrote if necessary. 958 1.4.2.2 yamt * XXXUBC simplistic async flushing. 959 1.4.2.2 yamt */ 960 1.4.2.2 yamt 961 1.4.2.2 yamt if (!async && oldoff >> 16 != uio->uio_offset >> 16) { 962 1.4.2.2 yamt mutex_enter(vp->v_interlock); 963 1.4.2.2 yamt error = VOP_PUTPAGES(vp, (oldoff >> 16) << 16, 964 1.4.2.2 yamt (uio->uio_offset >> 16) << 16, 965 1.4.2.2 yamt PGO_CLEANIT | PGO_JOURNALLOCKED); 966 1.4.2.2 yamt if (error) 967 1.4.2.2 yamt break; 968 1.4.2.2 yamt } 969 1.4.2.2 yamt } 970 1.4.2.2 yamt out: 971 1.4.2.2 yamt if (error == 0 && ioflag & IO_SYNC) { 972 1.4.2.2 yamt mutex_enter(vp->v_interlock); 973 1.4.2.2 yamt error = VOP_PUTPAGES(vp, 974 1.4.2.2 yamt trunc_page(origoff & chmp->chm_fs_bmask), 975 1.4.2.2 yamt round_page(blkroundup(chmp, uio->uio_offset)), 976 1.4.2.2 yamt PGO_CLEANIT | PGO_SYNCIO | PGO_JOURNALLOCKED); 977 1.4.2.2 yamt } 978 1.4.2.2 yamt ip->iflag |= IN_CHANGE | IN_UPDATE; 979 1.4.2.2 yamt if (resid > uio->uio_resid && ap->a_cred) { 980 1.4.2.2 yamt if (ip->mode & ISUID) { 981 1.4.2.3 yamt if (kauth_authorize_vnode(ap->a_cred, 982 1.4.2.3 yamt KAUTH_VNODE_RETAIN_SUID, vp, NULL, EPERM) != 0) 983 1.4.2.2 yamt ip->mode &= ~ISUID; 984 1.4.2.2 yamt } 985 1.4.2.2 yamt 986 1.4.2.2 yamt if (ip->mode & ISGID) { 987 1.4.2.3 yamt if (kauth_authorize_vnode(ap->a_cred, 988 1.4.2.3 yamt KAUTH_VNODE_RETAIN_SGID, vp, NULL, EPERM) != 0) 989 1.4.2.2 yamt ip->mode &= ~ISGID; 990 1.4.2.2 yamt } 991 1.4.2.2 yamt } 992 1.4.2.2 yamt if (resid > uio->uio_resid) 993 1.4.2.2 yamt VN_KNOTE(vp, NOTE_WRITE | (extended ? NOTE_EXTEND : 0)); 994 1.4.2.2 yamt if (error) { 995 1.4.2.2 yamt (void) UFS_TRUNCATE(vp, osize, ioflag & IO_SYNC, ap->a_cred); 996 1.4.2.2 yamt uio->uio_offset -= resid - uio->uio_resid; 997 1.4.2.2 yamt uio->uio_resid = resid; 998 1.4.2.2 yamt } else if (resid > uio->uio_resid && (ioflag & IO_SYNC) == IO_SYNC) 999 1.4.2.2 yamt error = UFS_UPDATE(vp, NULL, NULL, UPDATE_WAIT); 1000 1.4.2.2 yamt 1001 1.4.2.4 yamt //FIXME HACK 1002 1.4.2.2 yamt chfs_set_vnode_size(vp, vp->v_size); 1003 1.4.2.2 yamt 1004 1.4.2.2 yamt 1005 1.4.2.2 yamt KASSERT(vp->v_size == ip->size); 1006 1.4.2.2 yamt fstrans_done(vp->v_mount); 1007 1.4.2.2 yamt 1008 1.4.2.2 yamt mutex_enter(&chmp->chm_lock_mountfields); 1009 1.4.2.2 yamt error = chfs_write_flash_vnode(chmp, ip, ALLOC_NORMAL); 1010 1.4.2.2 yamt mutex_exit(&chmp->chm_lock_mountfields); 1011 1.4.2.2 yamt 1012 1.4.2.2 yamt return (error); 1013 1.4.2.2 yamt } 1014 1.4.2.2 yamt 1015 1.4.2.2 yamt 1016 1.4.2.2 yamt /* --------------------------------------------------------------------- */ 1017 1.4.2.2 yamt 1018 1.4.2.2 yamt int 1019 1.4.2.2 yamt chfs_fsync(void *v) 1020 1.4.2.2 yamt { 1021 1.4.2.2 yamt struct vop_fsync_args /* { 1022 1.4.2.2 yamt struct vnode *a_vp; 1023 1.4.2.2 yamt kauth_cred_t a_cred; 1024 1.4.2.2 yamt int a_flags; 1025 1.4.2.2 yamt off_t offlo; 1026 1.4.2.2 yamt off_t offhi; 1027 1.4.2.2 yamt } */ *ap = v; 1028 1.4.2.2 yamt struct vnode *vp = ap->a_vp; 1029 1.4.2.2 yamt 1030 1.4.2.2 yamt if (ap->a_flags & FSYNC_CACHE) { 1031 1.4.2.2 yamt return ENODEV; 1032 1.4.2.2 yamt } 1033 1.4.2.3 yamt vflushbuf(vp, ap->a_flags); 1034 1.4.2.2 yamt 1035 1.4.2.2 yamt return 0; 1036 1.4.2.2 yamt } 1037 1.4.2.2 yamt 1038 1.4.2.2 yamt /* --------------------------------------------------------------------- */ 1039 1.4.2.2 yamt 1040 1.4.2.2 yamt int 1041 1.4.2.2 yamt chfs_remove(void *v) 1042 1.4.2.2 yamt { 1043 1.4.2.2 yamt struct vnode *dvp = ((struct vop_remove_args *) v)->a_dvp; 1044 1.4.2.2 yamt struct vnode *vp = ((struct vop_remove_args *) v)->a_vp; 1045 1.4.2.2 yamt struct componentname *cnp = (((struct vop_remove_args *) v)->a_cnp); 1046 1.4.2.2 yamt dbg("remove\n"); 1047 1.4.2.2 yamt 1048 1.4.2.2 yamt KASSERT(VOP_ISLOCKED(dvp)); 1049 1.4.2.2 yamt KASSERT(VOP_ISLOCKED(vp)); 1050 1.4.2.2 yamt 1051 1.4.2.2 yamt struct chfs_inode *ip = VTOI(vp); 1052 1.4.2.2 yamt struct chfs_inode *parent = VTOI(dvp); 1053 1.4.2.2 yamt int error = 0; 1054 1.4.2.2 yamt 1055 1.4.2.4 yamt if (vp->v_type == VDIR || (ip->flags & (IMMUTABLE | APPEND)) || 1056 1.4.2.4 yamt (parent->flags & APPEND)) { 1057 1.4.2.4 yamt error = EPERM; 1058 1.4.2.4 yamt goto out; 1059 1.4.2.4 yamt } 1060 1.4.2.4 yamt 1061 1.4.2.2 yamt KASSERT(ip->chvc->vno != ip->chvc->pvno); 1062 1.4.2.2 yamt 1063 1.4.2.2 yamt error = chfs_do_unlink(ip, 1064 1.4.2.2 yamt parent, cnp->cn_nameptr, cnp->cn_namelen); 1065 1.4.2.2 yamt 1066 1.4.2.4 yamt out: 1067 1.4.2.2 yamt vput(dvp); 1068 1.4.2.2 yamt vput(vp); 1069 1.4.2.2 yamt 1070 1.4.2.2 yamt return error; 1071 1.4.2.2 yamt } 1072 1.4.2.2 yamt 1073 1.4.2.2 yamt /* --------------------------------------------------------------------- */ 1074 1.4.2.2 yamt 1075 1.4.2.2 yamt int 1076 1.4.2.2 yamt chfs_link(void *v) 1077 1.4.2.2 yamt { 1078 1.4.2.2 yamt struct vnode *dvp = ((struct vop_link_args *) v)->a_dvp; 1079 1.4.2.2 yamt struct vnode *vp = ((struct vop_link_args *) v)->a_vp; 1080 1.4.2.2 yamt struct componentname *cnp = ((struct vop_link_args *) v)->a_cnp; 1081 1.4.2.2 yamt 1082 1.4.2.2 yamt struct chfs_inode *ip, *parent; 1083 1.4.2.2 yamt int error = 0; 1084 1.4.2.2 yamt 1085 1.4.2.2 yamt if (vp->v_type == VDIR) { 1086 1.4.2.2 yamt VOP_ABORTOP(dvp, cnp); 1087 1.4.2.2 yamt error = EISDIR; 1088 1.4.2.2 yamt goto out; 1089 1.4.2.2 yamt } 1090 1.4.2.2 yamt if (dvp->v_mount != vp->v_mount) { 1091 1.4.2.2 yamt VOP_ABORTOP(dvp, cnp); 1092 1.4.2.2 yamt error = EXDEV; 1093 1.4.2.2 yamt goto out; 1094 1.4.2.2 yamt } 1095 1.4.2.2 yamt if (dvp != vp && (error = vn_lock(vp, LK_EXCLUSIVE))) { 1096 1.4.2.2 yamt VOP_ABORTOP(dvp, cnp); 1097 1.4.2.2 yamt goto out; 1098 1.4.2.2 yamt } 1099 1.4.2.2 yamt 1100 1.4.2.2 yamt parent = VTOI(dvp); 1101 1.4.2.2 yamt ip = VTOI(vp); 1102 1.4.2.2 yamt 1103 1.4.2.2 yamt error = chfs_do_link(ip, 1104 1.4.2.2 yamt parent, cnp->cn_nameptr, cnp->cn_namelen, ip->ch_type); 1105 1.4.2.2 yamt 1106 1.4.2.2 yamt if (dvp != vp) 1107 1.4.2.2 yamt VOP_UNLOCK(vp); 1108 1.4.2.2 yamt out: 1109 1.4.2.2 yamt vput(dvp); 1110 1.4.2.2 yamt return error; 1111 1.4.2.2 yamt } 1112 1.4.2.2 yamt 1113 1.4.2.2 yamt /* --------------------------------------------------------------------- */ 1114 1.4.2.2 yamt 1115 1.4.2.2 yamt int 1116 1.4.2.2 yamt chfs_rename(void *v) 1117 1.4.2.2 yamt { 1118 1.4.2.2 yamt struct vnode *fdvp = ((struct vop_rename_args *) v)->a_fdvp; 1119 1.4.2.2 yamt struct vnode *fvp = ((struct vop_rename_args *) v)->a_fvp; 1120 1.4.2.2 yamt struct componentname *fcnp = ((struct vop_rename_args *) v)->a_fcnp; 1121 1.4.2.2 yamt struct vnode *tdvp = ((struct vop_rename_args *) v)->a_tdvp; 1122 1.4.2.2 yamt struct vnode *tvp = ((struct vop_rename_args *) v)->a_tvp; 1123 1.4.2.2 yamt struct componentname *tcnp = ((struct vop_rename_args *) v)->a_tcnp; 1124 1.4.2.2 yamt 1125 1.4.2.2 yamt struct chfs_inode *oldparent, *old; 1126 1.4.2.2 yamt struct chfs_inode *newparent; 1127 1.4.2.4 yamt struct chfs_dirent *fd; 1128 1.4.2.2 yamt struct chfs_inode *ip; 1129 1.4.2.2 yamt int error = 0; 1130 1.4.2.2 yamt dbg("rename\n"); 1131 1.4.2.2 yamt 1132 1.4.2.2 yamt KASSERT(VOP_ISLOCKED(tdvp)); 1133 1.4.2.2 yamt KASSERT(IMPLIES(tvp != NULL, VOP_ISLOCKED(tvp) == LK_EXCLUSIVE)); 1134 1.4.2.2 yamt 1135 1.4.2.2 yamt oldparent = VTOI(fdvp); 1136 1.4.2.2 yamt old = VTOI(fvp); 1137 1.4.2.2 yamt newparent = VTOI(tdvp); 1138 1.4.2.2 yamt if (tvp) { 1139 1.4.2.2 yamt dbg("tvp not null\n"); 1140 1.4.2.2 yamt ip = VTOI(tvp); 1141 1.4.2.2 yamt if (tvp->v_type == VDIR) { 1142 1.4.2.2 yamt TAILQ_FOREACH(fd, &ip->dents, fds) { 1143 1.4.2.2 yamt if (fd->vno) { 1144 1.4.2.2 yamt error = ENOTEMPTY; 1145 1.4.2.2 yamt goto out_unlocked; 1146 1.4.2.2 yamt } 1147 1.4.2.2 yamt } 1148 1.4.2.2 yamt } 1149 1.4.2.2 yamt error = chfs_do_unlink(ip, 1150 1.4.2.2 yamt newparent, tcnp->cn_nameptr, tcnp->cn_namelen); 1151 1.4.2.2 yamt vput(tvp); 1152 1.4.2.2 yamt } 1153 1.4.2.2 yamt VFS_VGET(tdvp->v_mount, old->ino, &tvp); 1154 1.4.2.2 yamt ip = VTOI(tvp); 1155 1.4.2.2 yamt 1156 1.4.2.4 yamt /* link new */ 1157 1.4.2.2 yamt error = chfs_do_link(ip, 1158 1.4.2.2 yamt newparent, tcnp->cn_nameptr, tcnp->cn_namelen, ip->ch_type); 1159 1.4.2.4 yamt /* remove old */ 1160 1.4.2.2 yamt error = chfs_do_unlink(old, 1161 1.4.2.2 yamt oldparent, fcnp->cn_nameptr, fcnp->cn_namelen); 1162 1.4.2.2 yamt 1163 1.4.2.2 yamt out_unlocked: 1164 1.4.2.4 yamt /* Release target nodes. */ 1165 1.4.2.2 yamt if (tdvp == tvp) 1166 1.4.2.2 yamt vrele(tdvp); 1167 1.4.2.2 yamt else 1168 1.4.2.2 yamt vput(tdvp); 1169 1.4.2.2 yamt if (tvp != NULL) 1170 1.4.2.2 yamt vput(tvp); 1171 1.4.2.2 yamt 1172 1.4.2.4 yamt /* Release source nodes. */ 1173 1.4.2.2 yamt vrele(fdvp); 1174 1.4.2.2 yamt vrele(fvp); 1175 1.4.2.2 yamt 1176 1.4.2.2 yamt return error; 1177 1.4.2.2 yamt } 1178 1.4.2.2 yamt 1179 1.4.2.2 yamt /* --------------------------------------------------------------------- */ 1180 1.4.2.2 yamt 1181 1.4.2.2 yamt int 1182 1.4.2.2 yamt chfs_mkdir(void *v) 1183 1.4.2.2 yamt { 1184 1.4.2.2 yamt struct vnode *dvp = ((struct vop_mkdir_args *) v)->a_dvp; 1185 1.4.2.2 yamt struct vnode **vpp = ((struct vop_mkdir_args *)v)->a_vpp; 1186 1.4.2.2 yamt struct componentname *cnp = ((struct vop_mkdir_args *) v)->a_cnp; 1187 1.4.2.2 yamt struct vattr *vap = ((struct vop_mkdir_args *) v)->a_vap; 1188 1.4.2.2 yamt dbg("mkdir()\n"); 1189 1.4.2.2 yamt 1190 1.4.2.2 yamt int mode; 1191 1.4.2.2 yamt 1192 1.4.2.2 yamt mode = vap->va_mode & ACCESSPERMS; 1193 1.4.2.2 yamt if ((mode & IFMT) == 0) { 1194 1.4.2.2 yamt mode |= IFDIR; 1195 1.4.2.2 yamt } 1196 1.4.2.2 yamt 1197 1.4.2.2 yamt KASSERT(vap->va_type == VDIR); 1198 1.4.2.2 yamt 1199 1.4.2.2 yamt return chfs_makeinode(mode, dvp, vpp, cnp, VDIR); 1200 1.4.2.2 yamt } 1201 1.4.2.2 yamt 1202 1.4.2.2 yamt /* --------------------------------------------------------------------- */ 1203 1.4.2.2 yamt 1204 1.4.2.2 yamt int 1205 1.4.2.2 yamt chfs_rmdir(void *v) 1206 1.4.2.2 yamt { 1207 1.4.2.2 yamt struct vnode *dvp = ((struct vop_rmdir_args *) v)->a_dvp; 1208 1.4.2.2 yamt struct vnode *vp = ((struct vop_rmdir_args *) v)->a_vp; 1209 1.4.2.2 yamt struct componentname *cnp = ((struct vop_rmdir_args *) v)->a_cnp; 1210 1.4.2.2 yamt dbg("rmdir()\n"); 1211 1.4.2.2 yamt 1212 1.4.2.2 yamt KASSERT(VOP_ISLOCKED(dvp)); 1213 1.4.2.2 yamt KASSERT(VOP_ISLOCKED(vp)); 1214 1.4.2.2 yamt 1215 1.4.2.2 yamt struct chfs_inode *ip = VTOI(vp); 1216 1.4.2.2 yamt struct chfs_inode *parent = VTOI(dvp); 1217 1.4.2.2 yamt struct chfs_dirent *fd; 1218 1.4.2.2 yamt int error = 0; 1219 1.4.2.2 yamt 1220 1.4.2.2 yamt if (vp->v_type != VDIR) { 1221 1.4.2.2 yamt error = ENOTDIR; 1222 1.4.2.2 yamt goto out; 1223 1.4.2.2 yamt } 1224 1.4.2.2 yamt 1225 1.4.2.2 yamt KASSERT(ip->chvc->vno != ip->chvc->pvno); 1226 1.4.2.2 yamt 1227 1.4.2.2 yamt TAILQ_FOREACH(fd, &ip->dents, fds) { 1228 1.4.2.2 yamt if (fd->vno) { 1229 1.4.2.2 yamt error = ENOTEMPTY; 1230 1.4.2.2 yamt goto out; 1231 1.4.2.2 yamt } 1232 1.4.2.2 yamt } 1233 1.4.2.2 yamt 1234 1.4.2.2 yamt error = chfs_do_unlink(ip, 1235 1.4.2.2 yamt parent, cnp->cn_nameptr, cnp->cn_namelen); 1236 1.4.2.2 yamt 1237 1.4.2.2 yamt out: 1238 1.4.2.2 yamt vput(dvp); 1239 1.4.2.2 yamt vput(vp); 1240 1.4.2.2 yamt 1241 1.4.2.2 yamt return error; 1242 1.4.2.2 yamt } 1243 1.4.2.2 yamt 1244 1.4.2.2 yamt /* --------------------------------------------------------------------- */ 1245 1.4.2.2 yamt 1246 1.4.2.2 yamt int 1247 1.4.2.2 yamt chfs_symlink(void *v) 1248 1.4.2.2 yamt { 1249 1.4.2.2 yamt struct vnode *dvp = ((struct vop_symlink_args *) v)->a_dvp; 1250 1.4.2.2 yamt struct vnode **vpp = ((struct vop_symlink_args *) v)->a_vpp; 1251 1.4.2.2 yamt struct componentname *cnp = ((struct vop_symlink_args *) v)->a_cnp; 1252 1.4.2.2 yamt struct vattr *vap = ((struct vop_symlink_args *) v)->a_vap; 1253 1.4.2.2 yamt char *target = ((struct vop_symlink_args *) v)->a_target; 1254 1.4.2.2 yamt 1255 1.4.2.2 yamt struct ufsmount *ump; 1256 1.4.2.2 yamt struct chfs_mount *chmp; 1257 1.4.2.2 yamt struct vnode *vp; 1258 1.4.2.2 yamt struct chfs_inode *ip; 1259 1.4.2.2 yamt int len, err; 1260 1.4.2.2 yamt struct chfs_full_dnode *fd; 1261 1.4.2.2 yamt struct buf *bp; 1262 1.4.2.2 yamt dbg("symlink()\n"); 1263 1.4.2.2 yamt 1264 1.4.2.2 yamt ump = VFSTOUFS(dvp->v_mount); 1265 1.4.2.2 yamt chmp = ump->um_chfs; 1266 1.4.2.2 yamt 1267 1.4.2.2 yamt err = chfs_makeinode(IFLNK | vap->va_mode, dvp, vpp, cnp, VLNK); 1268 1.4.2.2 yamt if (err) 1269 1.4.2.2 yamt return (err); 1270 1.4.2.2 yamt VN_KNOTE(dvp, NOTE_WRITE); 1271 1.4.2.2 yamt vp = *vpp; 1272 1.4.2.2 yamt len = strlen(target); 1273 1.4.2.2 yamt ip = VTOI(vp); 1274 1.4.2.2 yamt /* TODO max symlink len instead of "100" */ 1275 1.4.2.2 yamt if (len < 100) { 1276 1.4.2.4 yamt /* symlink path stored as a data node */ 1277 1.4.2.2 yamt ip->target = kmem_alloc(len, KM_SLEEP); 1278 1.4.2.2 yamt memcpy(ip->target, target, len); 1279 1.4.2.2 yamt chfs_set_vnode_size(vp, len); 1280 1.4.2.2 yamt ip->iflag |= IN_CHANGE | IN_UPDATE; 1281 1.4.2.2 yamt 1282 1.4.2.2 yamt bp = getiobuf(vp, true); 1283 1.4.2.2 yamt bp->b_bufsize = bp->b_resid = len; 1284 1.4.2.2 yamt bp->b_data = kmem_alloc(len, KM_SLEEP); 1285 1.4.2.2 yamt memcpy(bp->b_data, target, len); 1286 1.4.2.2 yamt bp->b_blkno = 0; 1287 1.4.2.2 yamt 1288 1.4.2.2 yamt fd = chfs_alloc_full_dnode(); 1289 1.4.2.2 yamt 1290 1.4.2.2 yamt mutex_enter(&chmp->chm_lock_mountfields); 1291 1.4.2.2 yamt 1292 1.4.2.4 yamt /* write out the data node */ 1293 1.4.2.2 yamt err = chfs_write_flash_dnode(chmp, vp, bp, fd); 1294 1.4.2.2 yamt if (err) { 1295 1.4.2.2 yamt mutex_exit(&chmp->chm_lock_mountfields); 1296 1.4.2.2 yamt goto out; 1297 1.4.2.2 yamt } 1298 1.4.2.2 yamt 1299 1.4.2.4 yamt /* add it to the inode */ 1300 1.4.2.2 yamt err = chfs_add_full_dnode_to_inode(chmp, ip, fd); 1301 1.4.2.2 yamt if (err) { 1302 1.4.2.2 yamt mutex_exit(&chmp->chm_lock_mountfields); 1303 1.4.2.2 yamt goto out; 1304 1.4.2.2 yamt } 1305 1.4.2.2 yamt 1306 1.4.2.2 yamt mutex_exit(&chmp->chm_lock_mountfields); 1307 1.4.2.2 yamt 1308 1.4.2.2 yamt kmem_free(bp->b_data, len); 1309 1.4.2.2 yamt putiobuf(bp); 1310 1.4.2.2 yamt 1311 1.4.2.2 yamt uvm_vnp_setsize(vp, len); 1312 1.4.2.2 yamt } else { 1313 1.4.2.2 yamt err = vn_rdwr(UIO_WRITE, vp, target, len, (off_t)0, 1314 1.4.2.2 yamt UIO_SYSSPACE, IO_NODELOCKED, cnp->cn_cred, 1315 1.4.2.2 yamt (size_t *)0, NULL); 1316 1.4.2.2 yamt } 1317 1.4.2.2 yamt 1318 1.4.2.2 yamt out: 1319 1.4.2.2 yamt if (err) 1320 1.4.2.2 yamt vput(vp); 1321 1.4.2.2 yamt 1322 1.4.2.2 yamt return (err); 1323 1.4.2.2 yamt } 1324 1.4.2.2 yamt 1325 1.4.2.2 yamt /* --------------------------------------------------------------------- */ 1326 1.4.2.2 yamt 1327 1.4.2.2 yamt int 1328 1.4.2.2 yamt chfs_readdir(void *v) 1329 1.4.2.2 yamt { 1330 1.4.2.2 yamt struct vnode *vp = ((struct vop_readdir_args *) v)->a_vp; 1331 1.4.2.2 yamt struct uio *uio = ((struct vop_readdir_args *) v)->a_uio; 1332 1.4.2.2 yamt int *eofflag = ((struct vop_readdir_args *) v)->a_eofflag; 1333 1.4.2.2 yamt 1334 1.4.2.2 yamt int error = 0; 1335 1.4.2.2 yamt off_t skip, offset; 1336 1.4.2.2 yamt struct chfs_inode *ip; 1337 1.4.2.2 yamt struct chfs_dirent *fd; 1338 1.4.2.2 yamt 1339 1.4.2.2 yamt struct ufsmount *ump; 1340 1.4.2.2 yamt struct chfs_mount *chmp; 1341 1.4.2.2 yamt struct chfs_vnode_cache *chvc; 1342 1.4.2.2 yamt 1343 1.4.2.2 yamt KASSERT(VOP_ISLOCKED(vp)); 1344 1.4.2.2 yamt 1345 1.4.2.2 yamt /* This operation only makes sense on directory nodes. */ 1346 1.4.2.2 yamt if (vp->v_type != VDIR) { 1347 1.4.2.2 yamt error = ENOTDIR; 1348 1.4.2.2 yamt goto out; 1349 1.4.2.2 yamt } 1350 1.4.2.2 yamt 1351 1.4.2.2 yamt ip = VTOI(vp); 1352 1.4.2.2 yamt 1353 1.4.2.2 yamt /* uiomove in chfs_filldir automatically increments the 1354 1.4.2.2 yamt * uio_offset by an arbitrary size, so we discard any change 1355 1.4.2.2 yamt * to uio_offset and set it to our own value on return 1356 1.4.2.2 yamt */ 1357 1.4.2.2 yamt offset = uio->uio_offset; 1358 1.4.2.2 yamt 1359 1.4.2.4 yamt /* Add this entry. */ 1360 1.4.2.2 yamt if (offset == CHFS_OFFSET_DOT) { 1361 1.4.2.3 yamt error = chfs_filldir(uio, ip->ino, ".", 1, CHT_DIR); 1362 1.4.2.2 yamt if (error == -1) { 1363 1.4.2.2 yamt error = 0; 1364 1.4.2.2 yamt goto outok; 1365 1.4.2.2 yamt } else if (error != 0) 1366 1.4.2.2 yamt goto outok; 1367 1.4.2.2 yamt 1368 1.4.2.2 yamt offset = CHFS_OFFSET_DOTDOT; 1369 1.4.2.2 yamt } 1370 1.4.2.2 yamt 1371 1.4.2.4 yamt /* Add parent entry. */ 1372 1.4.2.2 yamt if (offset == CHFS_OFFSET_DOTDOT) { 1373 1.4.2.2 yamt ump = VFSTOUFS(vp->v_mount); 1374 1.4.2.2 yamt chmp = ump->um_chfs; 1375 1.4.2.2 yamt mutex_enter(&chmp->chm_lock_vnocache); 1376 1.4.2.2 yamt chvc = chfs_vnode_cache_get(chmp, ip->ino); 1377 1.4.2.2 yamt mutex_exit(&chmp->chm_lock_vnocache); 1378 1.4.2.2 yamt 1379 1.4.2.3 yamt error = chfs_filldir(uio, chvc->pvno, "..", 2, CHT_DIR); 1380 1.4.2.2 yamt if (error == -1) { 1381 1.4.2.2 yamt error = 0; 1382 1.4.2.2 yamt goto outok; 1383 1.4.2.2 yamt } else if (error != 0) { 1384 1.4.2.2 yamt goto outok; 1385 1.4.2.2 yamt } 1386 1.4.2.2 yamt 1387 1.4.2.4 yamt /* Has child or not? */ 1388 1.4.2.2 yamt if (TAILQ_EMPTY(&ip->dents)) { 1389 1.4.2.2 yamt offset = CHFS_OFFSET_EOF; 1390 1.4.2.2 yamt } else { 1391 1.4.2.2 yamt offset = CHFS_OFFSET_FIRST; 1392 1.4.2.2 yamt } 1393 1.4.2.2 yamt } 1394 1.4.2.2 yamt 1395 1.4.2.2 yamt if (offset != CHFS_OFFSET_EOF) { 1396 1.4.2.4 yamt /* Child entries. */ 1397 1.4.2.2 yamt skip = offset - CHFS_OFFSET_FIRST; 1398 1.4.2.2 yamt 1399 1.4.2.2 yamt TAILQ_FOREACH(fd, &ip->dents, fds) { 1400 1.4.2.2 yamt /* seek to offset by skipping items */ 1401 1.4.2.2 yamt /* XXX race conditions by changed dirent? */ 1402 1.4.2.2 yamt if (skip > 0) { 1403 1.4.2.2 yamt skip--; 1404 1.4.2.2 yamt continue; 1405 1.4.2.2 yamt } 1406 1.4.2.2 yamt 1407 1.4.2.2 yamt if (fd->vno != 0) { 1408 1.4.2.2 yamt error = chfs_filldir(uio, fd->vno, 1409 1.4.2.2 yamt fd->name, fd->nsize, fd->type); 1410 1.4.2.2 yamt if (error == -1) { 1411 1.4.2.2 yamt error = 0; 1412 1.4.2.2 yamt goto outok; 1413 1.4.2.2 yamt } else if (error != 0) { 1414 1.4.2.2 yamt dbg("err %d\n", error); 1415 1.4.2.2 yamt goto outok; 1416 1.4.2.2 yamt } 1417 1.4.2.2 yamt } 1418 1.4.2.2 yamt offset++; 1419 1.4.2.2 yamt } 1420 1.4.2.2 yamt } 1421 1.4.2.2 yamt offset = CHFS_OFFSET_EOF; 1422 1.4.2.2 yamt 1423 1.4.2.2 yamt outok: 1424 1.4.2.2 yamt uio->uio_offset = offset; 1425 1.4.2.2 yamt 1426 1.4.2.2 yamt if (eofflag != NULL) { 1427 1.4.2.2 yamt *eofflag = (error == 0 && 1428 1.4.2.2 yamt uio->uio_offset == CHFS_OFFSET_EOF); 1429 1.4.2.2 yamt } 1430 1.4.2.2 yamt 1431 1.4.2.2 yamt out: 1432 1.4.2.2 yamt KASSERT(VOP_ISLOCKED(vp)); 1433 1.4.2.2 yamt 1434 1.4.2.2 yamt return error; 1435 1.4.2.2 yamt } 1436 1.4.2.2 yamt 1437 1.4.2.2 yamt /* --------------------------------------------------------------------- */ 1438 1.4.2.2 yamt 1439 1.4.2.2 yamt int 1440 1.4.2.2 yamt chfs_readlink(void *v) 1441 1.4.2.2 yamt { 1442 1.4.2.2 yamt 1443 1.4.2.2 yamt struct vnode *vp = ((struct vop_readlink_args *) v)->a_vp; 1444 1.4.2.2 yamt struct uio *uio = ((struct vop_readlink_args *) v)->a_uio; 1445 1.4.2.2 yamt kauth_cred_t cred = ((struct vop_readlink_args *) v)->a_cred; 1446 1.4.2.2 yamt 1447 1.4.2.2 yamt struct chfs_inode *ip = VTOI(vp); 1448 1.4.2.2 yamt 1449 1.4.2.2 yamt dbg("readlink()\n"); 1450 1.4.2.2 yamt 1451 1.4.2.2 yamt /* TODO max symlink len instead of "100" */ 1452 1.4.2.2 yamt if (ip->size < 100) { 1453 1.4.2.2 yamt uiomove(ip->target, ip->size, uio); 1454 1.4.2.2 yamt return (0); 1455 1.4.2.2 yamt } 1456 1.4.2.2 yamt 1457 1.4.2.2 yamt return (VOP_READ(vp, uio, 0, cred)); 1458 1.4.2.2 yamt } 1459 1.4.2.2 yamt 1460 1.4.2.2 yamt /* --------------------------------------------------------------------- */ 1461 1.4.2.2 yamt 1462 1.4.2.2 yamt int 1463 1.4.2.2 yamt chfs_inactive(void *v) 1464 1.4.2.2 yamt { 1465 1.4.2.2 yamt struct vnode *vp = ((struct vop_inactive_args *) v)->a_vp; 1466 1.4.2.2 yamt struct chfs_inode *ip = VTOI(vp); 1467 1.4.2.2 yamt struct chfs_vnode_cache *chvc; 1468 1.4.2.2 yamt dbg("inactive | vno: %llu\n", (unsigned long long)ip->ino); 1469 1.4.2.2 yamt 1470 1.4.2.2 yamt KASSERT(VOP_ISLOCKED(vp)); 1471 1.4.2.2 yamt 1472 1.4.2.4 yamt /* Reclaim only if there is no link to the node. */ 1473 1.4.2.2 yamt if (ip->ino) { 1474 1.4.2.2 yamt chvc = ip->chvc; 1475 1.4.2.2 yamt if (chvc->nlink) 1476 1.4.2.2 yamt *((struct vop_inactive_args *) v)->a_recycle = 0; 1477 1.4.2.2 yamt } else { 1478 1.4.2.2 yamt *((struct vop_inactive_args *) v)->a_recycle = 1; 1479 1.4.2.2 yamt } 1480 1.4.2.2 yamt 1481 1.4.2.2 yamt VOP_UNLOCK(vp); 1482 1.4.2.2 yamt 1483 1.4.2.2 yamt return 0; 1484 1.4.2.2 yamt } 1485 1.4.2.2 yamt 1486 1.4.2.2 yamt /* --------------------------------------------------------------------- */ 1487 1.4.2.2 yamt 1488 1.4.2.2 yamt int 1489 1.4.2.2 yamt chfs_reclaim(void *v) 1490 1.4.2.2 yamt { 1491 1.4.2.2 yamt struct vop_reclaim_args *ap = v; 1492 1.4.2.2 yamt struct vnode *vp = ap->a_vp; 1493 1.4.2.2 yamt struct chfs_inode *ip = VTOI(vp); 1494 1.4.2.2 yamt struct chfs_mount *chmp = ip->chmp; 1495 1.4.2.2 yamt struct chfs_dirent *fd; 1496 1.4.2.2 yamt 1497 1.4.2.4 yamt mutex_enter(&chmp->chm_lock_mountfields); 1498 1.4.2.2 yamt 1499 1.4.2.2 yamt mutex_enter(&chmp->chm_lock_vnocache); 1500 1.4.2.4 yamt ip->chvc->state = VNO_STATE_CHECKEDABSENT; 1501 1.4.2.2 yamt mutex_exit(&chmp->chm_lock_vnocache); 1502 1.4.2.2 yamt 1503 1.4.2.2 yamt chfs_update(vp, NULL, NULL, UPDATE_CLOSE); 1504 1.4.2.2 yamt 1505 1.4.2.4 yamt /* Clean fragments. */ 1506 1.4.2.4 yamt chfs_kill_fragtree(chmp, &ip->fragtree); 1507 1.4.2.2 yamt 1508 1.4.2.4 yamt /* Clean dirents. */ 1509 1.4.2.2 yamt fd = TAILQ_FIRST(&ip->dents); 1510 1.4.2.4 yamt while (fd) { 1511 1.4.2.2 yamt TAILQ_REMOVE(&ip->dents, fd, fds); 1512 1.4.2.2 yamt chfs_free_dirent(fd); 1513 1.4.2.2 yamt fd = TAILQ_FIRST(&ip->dents); 1514 1.4.2.2 yamt } 1515 1.4.2.2 yamt 1516 1.4.2.2 yamt cache_purge(vp); 1517 1.4.2.2 yamt if (ip->devvp) { 1518 1.4.2.2 yamt vrele(ip->devvp); 1519 1.4.2.2 yamt ip->devvp = 0; 1520 1.4.2.2 yamt } 1521 1.4.2.2 yamt chfs_ihashrem(ip); 1522 1.4.2.2 yamt 1523 1.4.2.2 yamt genfs_node_destroy(vp); 1524 1.4.2.2 yamt pool_put(&chfs_inode_pool, vp->v_data); 1525 1.4.2.2 yamt vp->v_data = NULL; 1526 1.4.2.4 yamt 1527 1.4.2.4 yamt mutex_exit(&chmp->chm_lock_mountfields); 1528 1.4.2.4 yamt 1529 1.4.2.2 yamt return (0); 1530 1.4.2.2 yamt } 1531 1.4.2.2 yamt 1532 1.4.2.2 yamt /* --------------------------------------------------------------------- */ 1533 1.4.2.2 yamt 1534 1.4.2.2 yamt int 1535 1.4.2.2 yamt chfs_advlock(void *v) 1536 1.4.2.2 yamt { 1537 1.4.2.2 yamt return 0; 1538 1.4.2.2 yamt } 1539 1.4.2.2 yamt 1540 1.4.2.2 yamt /* --------------------------------------------------------------------- */ 1541 1.4.2.2 yamt int 1542 1.4.2.2 yamt chfs_strategy(void *v) 1543 1.4.2.2 yamt { 1544 1.4.2.2 yamt struct vop_strategy_args /* { 1545 1.4.2.2 yamt const struct vnodeop_desc *a_desc; 1546 1.4.2.2 yamt struct vnode *a_vp; 1547 1.4.2.2 yamt struct buf *a_bp; 1548 1.4.2.2 yamt } */ *ap = v; 1549 1.4.2.2 yamt struct chfs_full_dnode *fd; 1550 1.4.2.2 yamt struct buf *bp = ap->a_bp; 1551 1.4.2.2 yamt struct vnode *vp = ap->a_vp; 1552 1.4.2.2 yamt struct chfs_inode *ip = VTOI(vp); 1553 1.4.2.2 yamt struct chfs_mount *chmp = ip->chmp; 1554 1.4.2.2 yamt int read = (bp->b_flags & B_READ) ? 1 : 0; 1555 1.4.2.2 yamt int err = 0; 1556 1.4.2.2 yamt 1557 1.4.2.2 yamt if (read) { 1558 1.4.2.2 yamt err = chfs_read_data(chmp, vp, bp); 1559 1.4.2.2 yamt } else { 1560 1.4.2.2 yamt mutex_enter(&chmp->chm_lock_mountfields); 1561 1.4.2.2 yamt 1562 1.4.2.4 yamt fd = chfs_alloc_full_dnode(); 1563 1.4.2.4 yamt 1564 1.4.2.2 yamt err = chfs_write_flash_dnode(chmp, vp, bp, fd); 1565 1.4.2.2 yamt if (err) { 1566 1.4.2.2 yamt mutex_exit(&chmp->chm_lock_mountfields); 1567 1.4.2.2 yamt goto out; 1568 1.4.2.2 yamt } 1569 1.4.2.2 yamt 1570 1.4.2.4 yamt ip = VTOI(vp); 1571 1.4.2.2 yamt err = chfs_add_full_dnode_to_inode(chmp, ip, fd); 1572 1.4.2.2 yamt 1573 1.4.2.2 yamt mutex_exit(&chmp->chm_lock_mountfields); 1574 1.4.2.2 yamt } 1575 1.4.2.2 yamt out: 1576 1.4.2.2 yamt biodone(bp); 1577 1.4.2.2 yamt return err; 1578 1.4.2.2 yamt } 1579 1.4.2.2 yamt 1580 1.4.2.2 yamt int 1581 1.4.2.2 yamt chfs_bmap(void *v) 1582 1.4.2.2 yamt { 1583 1.4.2.2 yamt struct vop_bmap_args /* { 1584 1.4.2.2 yamt struct vnode *a_vp; 1585 1.4.2.2 yamt daddr_t a_bn; 1586 1.4.2.2 yamt struct vnode **a_vpp; 1587 1.4.2.2 yamt daddr_t *a_bnp; 1588 1.4.2.2 yamt int *a_runp; 1589 1.4.2.2 yamt int *a_runb; 1590 1.4.2.2 yamt } */ *ap = v; 1591 1.4.2.2 yamt if (ap->a_vpp != NULL) 1592 1.4.2.2 yamt *ap->a_vpp = ap->a_vp; 1593 1.4.2.2 yamt if (ap->a_bnp != NULL) 1594 1.4.2.2 yamt *ap->a_bnp = ap->a_bn; 1595 1.4.2.2 yamt if (ap->a_runp != NULL) 1596 1.4.2.2 yamt *ap->a_runp = 0; 1597 1.4.2.2 yamt return (0); 1598 1.4.2.2 yamt } 1599 1.4.2.2 yamt 1600 1.4.2.2 yamt /* 1601 1.4.2.2 yamt * vnode operations vector used for files stored in a chfs file system. 1602 1.4.2.2 yamt */ 1603 1.4.2.2 yamt int 1604 1.4.2.2 yamt (**chfs_vnodeop_p)(void *); 1605 1.4.2.2 yamt const struct vnodeopv_entry_desc chfs_vnodeop_entries[] = 1606 1.4.2.2 yamt { 1607 1.4.2.2 yamt { &vop_default_desc, vn_default_error }, 1608 1.4.2.2 yamt { &vop_lookup_desc, chfs_lookup }, 1609 1.4.2.2 yamt { &vop_create_desc, chfs_create }, 1610 1.4.2.2 yamt { &vop_mknod_desc, chfs_mknod }, 1611 1.4.2.2 yamt { &vop_open_desc, chfs_open }, 1612 1.4.2.2 yamt { &vop_close_desc, chfs_close }, 1613 1.4.2.2 yamt { &vop_access_desc, chfs_access }, 1614 1.4.2.2 yamt { &vop_getattr_desc, chfs_getattr }, 1615 1.4.2.2 yamt { &vop_setattr_desc, chfs_setattr }, 1616 1.4.2.2 yamt { &vop_read_desc, chfs_read }, 1617 1.4.2.2 yamt { &vop_write_desc, chfs_write }, 1618 1.4.2.2 yamt { &vop_ioctl_desc, genfs_enoioctl }, 1619 1.4.2.2 yamt { &vop_fcntl_desc, genfs_fcntl }, 1620 1.4.2.2 yamt { &vop_poll_desc, genfs_poll }, 1621 1.4.2.2 yamt { &vop_kqfilter_desc, genfs_kqfilter }, 1622 1.4.2.2 yamt { &vop_revoke_desc, genfs_revoke }, 1623 1.4.2.2 yamt { &vop_mmap_desc, genfs_mmap }, 1624 1.4.2.2 yamt { &vop_fsync_desc, chfs_fsync }, 1625 1.4.2.2 yamt { &vop_seek_desc, genfs_seek }, 1626 1.4.2.2 yamt { &vop_remove_desc, chfs_remove }, 1627 1.4.2.2 yamt { &vop_link_desc, chfs_link }, 1628 1.4.2.2 yamt { &vop_rename_desc, chfs_rename }, 1629 1.4.2.2 yamt { &vop_mkdir_desc, chfs_mkdir }, 1630 1.4.2.2 yamt { &vop_rmdir_desc, chfs_rmdir }, 1631 1.4.2.2 yamt { &vop_symlink_desc, chfs_symlink }, 1632 1.4.2.2 yamt { &vop_readdir_desc, chfs_readdir }, 1633 1.4.2.2 yamt { &vop_readlink_desc, chfs_readlink }, 1634 1.4.2.2 yamt { &vop_abortop_desc, genfs_abortop }, 1635 1.4.2.2 yamt { &vop_inactive_desc, chfs_inactive }, 1636 1.4.2.2 yamt { &vop_reclaim_desc, chfs_reclaim }, 1637 1.4.2.2 yamt { &vop_lock_desc, genfs_lock }, 1638 1.4.2.2 yamt { &vop_unlock_desc, genfs_unlock }, 1639 1.4.2.2 yamt { &vop_bmap_desc, chfs_bmap }, 1640 1.4.2.2 yamt { &vop_strategy_desc, chfs_strategy }, 1641 1.4.2.2 yamt { &vop_print_desc, ufs_print }, 1642 1.4.2.2 yamt { &vop_pathconf_desc, ufs_pathconf }, 1643 1.4.2.2 yamt { &vop_islocked_desc, genfs_islocked }, 1644 1.4.2.2 yamt { &vop_advlock_desc, chfs_advlock }, 1645 1.4.2.2 yamt { &vop_bwrite_desc, vn_bwrite }, 1646 1.4.2.2 yamt { &vop_getpages_desc, genfs_getpages }, 1647 1.4.2.2 yamt { &vop_putpages_desc, genfs_putpages }, 1648 1.4.2.2 yamt { NULL, NULL } }; 1649 1.4.2.2 yamt 1650 1.4.2.2 yamt const struct vnodeopv_desc chfs_vnodeop_opv_desc = 1651 1.4.2.2 yamt { &chfs_vnodeop_p, chfs_vnodeop_entries }; 1652 1.4.2.2 yamt 1653 1.4.2.2 yamt /* --------------------------------------------------------------------- */ 1654 1.4.2.2 yamt 1655 1.4.2.2 yamt /* 1656 1.4.2.2 yamt * vnode operations vector used for special devices stored in a chfs 1657 1.4.2.2 yamt * file system. 1658 1.4.2.2 yamt */ 1659 1.4.2.2 yamt int 1660 1.4.2.2 yamt (**chfs_specop_p)(void *); 1661 1.4.2.2 yamt const struct vnodeopv_entry_desc chfs_specop_entries[] = 1662 1.4.2.2 yamt { 1663 1.4.2.2 yamt { &vop_default_desc, vn_default_error }, 1664 1.4.2.2 yamt { &vop_lookup_desc, spec_lookup }, 1665 1.4.2.2 yamt { &vop_create_desc, spec_create }, 1666 1.4.2.2 yamt { &vop_mknod_desc, spec_mknod }, 1667 1.4.2.2 yamt { &vop_open_desc, spec_open }, 1668 1.4.2.2 yamt { &vop_close_desc, ufsspec_close }, 1669 1.4.2.2 yamt { &vop_access_desc, chfs_access }, 1670 1.4.2.2 yamt { &vop_getattr_desc, chfs_getattr }, 1671 1.4.2.2 yamt { &vop_setattr_desc, chfs_setattr }, 1672 1.4.2.2 yamt { &vop_read_desc, chfs_read }, 1673 1.4.2.2 yamt { &vop_write_desc, chfs_write }, 1674 1.4.2.2 yamt { &vop_ioctl_desc, spec_ioctl }, 1675 1.4.2.2 yamt { &vop_fcntl_desc, genfs_fcntl }, 1676 1.4.2.2 yamt { &vop_poll_desc, spec_poll }, 1677 1.4.2.2 yamt { &vop_kqfilter_desc, spec_kqfilter }, 1678 1.4.2.2 yamt { &vop_revoke_desc, spec_revoke }, 1679 1.4.2.2 yamt { &vop_mmap_desc, spec_mmap }, 1680 1.4.2.2 yamt { &vop_fsync_desc, spec_fsync }, 1681 1.4.2.2 yamt { &vop_seek_desc, spec_seek }, 1682 1.4.2.2 yamt { &vop_remove_desc, spec_remove }, 1683 1.4.2.2 yamt { &vop_link_desc, spec_link }, 1684 1.4.2.2 yamt { &vop_rename_desc, spec_rename }, 1685 1.4.2.2 yamt { &vop_mkdir_desc, spec_mkdir }, 1686 1.4.2.2 yamt { &vop_rmdir_desc, spec_rmdir }, 1687 1.4.2.2 yamt { &vop_symlink_desc, spec_symlink }, 1688 1.4.2.2 yamt { &vop_readdir_desc, spec_readdir }, 1689 1.4.2.2 yamt { &vop_readlink_desc, spec_readlink }, 1690 1.4.2.2 yamt { &vop_abortop_desc, spec_abortop }, 1691 1.4.2.2 yamt { &vop_inactive_desc, chfs_inactive }, 1692 1.4.2.2 yamt { &vop_reclaim_desc, chfs_reclaim }, 1693 1.4.2.2 yamt { &vop_lock_desc, genfs_lock }, 1694 1.4.2.2 yamt { &vop_unlock_desc, genfs_unlock }, 1695 1.4.2.2 yamt { &vop_bmap_desc, spec_bmap }, 1696 1.4.2.2 yamt { &vop_strategy_desc, spec_strategy }, 1697 1.4.2.2 yamt { &vop_print_desc, ufs_print }, 1698 1.4.2.2 yamt { &vop_pathconf_desc, spec_pathconf }, 1699 1.4.2.2 yamt { &vop_islocked_desc, genfs_islocked }, 1700 1.4.2.2 yamt { &vop_advlock_desc, spec_advlock }, 1701 1.4.2.2 yamt { &vop_bwrite_desc, vn_bwrite }, 1702 1.4.2.2 yamt { &vop_getpages_desc, spec_getpages }, 1703 1.4.2.2 yamt { &vop_putpages_desc, spec_putpages }, 1704 1.4.2.2 yamt { NULL, NULL } }; 1705 1.4.2.2 yamt 1706 1.4.2.2 yamt const struct vnodeopv_desc chfs_specop_opv_desc = 1707 1.4.2.2 yamt { &chfs_specop_p, chfs_specop_entries }; 1708 1.4.2.2 yamt 1709 1.4.2.2 yamt /* --------------------------------------------------------------------- */ 1710 1.4.2.2 yamt /* 1711 1.4.2.2 yamt * vnode operations vector used for fifos stored in a chfs file system. 1712 1.4.2.2 yamt */ 1713 1.4.2.2 yamt int 1714 1.4.2.2 yamt (**chfs_fifoop_p)(void *); 1715 1.4.2.2 yamt const struct vnodeopv_entry_desc chfs_fifoop_entries[] = 1716 1.4.2.2 yamt { 1717 1.4.2.2 yamt { &vop_default_desc, vn_default_error }, 1718 1.4.2.2 yamt { &vop_lookup_desc, vn_fifo_bypass }, 1719 1.4.2.2 yamt { &vop_create_desc, vn_fifo_bypass }, 1720 1.4.2.2 yamt { &vop_mknod_desc, vn_fifo_bypass }, 1721 1.4.2.2 yamt { &vop_open_desc, vn_fifo_bypass }, 1722 1.4.2.2 yamt { &vop_close_desc, ufsfifo_close }, 1723 1.4.2.2 yamt { &vop_access_desc, chfs_access }, 1724 1.4.2.2 yamt { &vop_getattr_desc, chfs_getattr }, 1725 1.4.2.2 yamt { &vop_setattr_desc, chfs_setattr }, 1726 1.4.2.2 yamt { &vop_read_desc, ufsfifo_read }, 1727 1.4.2.2 yamt { &vop_write_desc, ufsfifo_write }, 1728 1.4.2.2 yamt { &vop_ioctl_desc, vn_fifo_bypass }, 1729 1.4.2.2 yamt { &vop_fcntl_desc, genfs_fcntl }, 1730 1.4.2.2 yamt { &vop_poll_desc, vn_fifo_bypass }, 1731 1.4.2.2 yamt { &vop_kqfilter_desc, vn_fifo_bypass }, 1732 1.4.2.2 yamt { &vop_revoke_desc, vn_fifo_bypass }, 1733 1.4.2.2 yamt { &vop_mmap_desc, vn_fifo_bypass }, 1734 1.4.2.2 yamt { &vop_fsync_desc, vn_fifo_bypass }, 1735 1.4.2.2 yamt { &vop_seek_desc, vn_fifo_bypass }, 1736 1.4.2.2 yamt { &vop_remove_desc, vn_fifo_bypass }, 1737 1.4.2.2 yamt { &vop_link_desc, vn_fifo_bypass }, 1738 1.4.2.2 yamt { &vop_rename_desc, vn_fifo_bypass }, 1739 1.4.2.2 yamt { &vop_mkdir_desc, vn_fifo_bypass }, 1740 1.4.2.2 yamt { &vop_rmdir_desc, vn_fifo_bypass }, 1741 1.4.2.2 yamt { &vop_symlink_desc, vn_fifo_bypass }, 1742 1.4.2.2 yamt { &vop_readdir_desc, vn_fifo_bypass }, 1743 1.4.2.2 yamt { &vop_readlink_desc, vn_fifo_bypass }, 1744 1.4.2.2 yamt { &vop_abortop_desc, vn_fifo_bypass }, 1745 1.4.2.2 yamt { &vop_inactive_desc, chfs_inactive }, 1746 1.4.2.2 yamt { &vop_reclaim_desc, chfs_reclaim }, 1747 1.4.2.2 yamt { &vop_lock_desc, genfs_lock }, 1748 1.4.2.2 yamt { &vop_unlock_desc, genfs_unlock }, 1749 1.4.2.2 yamt { &vop_bmap_desc, vn_fifo_bypass }, 1750 1.4.2.2 yamt { &vop_strategy_desc, vn_fifo_bypass }, 1751 1.4.2.2 yamt { &vop_print_desc, ufs_print }, 1752 1.4.2.2 yamt { &vop_pathconf_desc, vn_fifo_bypass }, 1753 1.4.2.2 yamt { &vop_islocked_desc, genfs_islocked }, 1754 1.4.2.2 yamt { &vop_advlock_desc, vn_fifo_bypass }, 1755 1.4.2.2 yamt { &vop_bwrite_desc, genfs_nullop }, 1756 1.4.2.2 yamt { &vop_getpages_desc, genfs_badop }, 1757 1.4.2.2 yamt { &vop_putpages_desc, vn_fifo_bypass }, 1758 1.4.2.2 yamt { NULL, NULL } }; 1759 1.4.2.2 yamt 1760 1.4.2.2 yamt const struct vnodeopv_desc chfs_fifoop_opv_desc = 1761 1.4.2.2 yamt { &chfs_fifoop_p, chfs_fifoop_entries }; 1762
Indexes created Thu Oct 23 22:10:10 GMT 2025