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