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