X-Git-Url: https://git.subgeniuskitty.com/unix-history/.git/blobdiff_plain/d60a94eb292ed956869287c34a6c324d576188ce..ad7871609881e73855d0b04da49b486cd93efca7:/usr/src/sys/ufs/ufs/ufs_vnops.c diff --git a/usr/src/sys/ufs/ufs/ufs_vnops.c b/usr/src/sys/ufs/ufs/ufs_vnops.c index 4e2a54d0d0..71a395e843 100644 --- a/usr/src/sys/ufs/ufs/ufs_vnops.c +++ b/usr/src/sys/ufs/ufs/ufs_vnops.c @@ -1,10 +1,36 @@ /* - * Copyright (c) 1982, 1986, 1989 Regents of the University of California. - * All rights reserved. + * Copyright (c) 1982, 1986, 1989, 1993 + * The Regents of the University of California. All rights reserved. * - * %sccs.include.redist.c% + * Redistribution and use in source and binary forms, with or without + * modification, are permitted provided that the following conditions + * are met: + * 1. Redistributions of source code must retain the above copyright + * notice, this list of conditions and the following disclaimer. + * 2. Redistributions in binary form must reproduce the above copyright + * notice, this list of conditions and the following disclaimer in the + * documentation and/or other materials provided with the distribution. + * 3. All advertising materials mentioning features or use of this software + * must display the following acknowledgement: + * This product includes software developed by the University of + * California, Berkeley and its contributors. + * 4. Neither the name of the University nor the names of its contributors + * may be used to endorse or promote products derived from this software + * without specific prior written permission. * - * @(#)ufs_vnops.c 7.106 (Berkeley) %G% + * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND + * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE + * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE + * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE + * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL + * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS + * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) + * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT + * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY + * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF + * SUCH DAMAGE. + * + * @(#)ufs_vnops.c 8.1 (Berkeley) 6/11/93 */ #include @@ -134,6 +160,12 @@ ufs_open(ap) } */ *ap; { + /* + * Files marked append-only must be opened for appending. + */ + if ((VTOI(ap->a_vp)->i_flags & APPEND) && + (ap->a_mode & (FWRITE | O_APPEND)) == FWRITE) + return (EPERM); return (0); } @@ -196,6 +228,8 @@ ufs_access(ap) } } #endif /* QUOTA */ + if ((mode & VWRITE) && (ip->i_flags & IMMUTABLE)) + return (EPERM); /* * If you're the super-user, you always get access. */ @@ -216,9 +250,7 @@ ufs_access(ap) found: ; } - if ((ip->i_mode & mode) != 0) - return (0); - return (EACCES); + return ((ip->i_mode & mode) == mode ? 0 : EACCES); } /* ARGSUSED */ @@ -294,6 +326,27 @@ ufs_setattr(ap) ((int)vap->va_bytes != VNOVAL) || (vap->va_gen != VNOVAL)) { return (EINVAL); } + if (vap->va_flags != VNOVAL) { + if (cred->cr_uid != ip->i_uid && + (error = suser(cred, &p->p_acflag))) + return (error); + if (cred->cr_uid == 0) { + if ((ip->i_flags & (SF_IMMUTABLE | SF_APPEND)) && + securelevel > 0) + return (EPERM); + ip->i_flags = vap->va_flags; + } else { + if (ip->i_flags & (SF_IMMUTABLE | SF_APPEND)) + return (EPERM); + ip->i_flags &= SF_SETTABLE; + ip->i_flags |= (vap->va_flags & UF_SETTABLE); + } + ip->i_flag |= ICHG; + if (vap->va_flags & (IMMUTABLE | APPEND)) + return (0); + } + if (ip->i_flags & (IMMUTABLE | APPEND)) + return (EPERM); /* * Go through the fields and update iff not VNOVAL. */ @@ -309,13 +362,14 @@ ufs_setattr(ap) ip = VTOI(vp); if (vap->va_atime.ts_sec != VNOVAL || vap->va_mtime.ts_sec != VNOVAL) { if (cred->cr_uid != ip->i_uid && - (error = suser(cred, &p->p_acflag))) + (error = suser(cred, &p->p_acflag)) && + ((vap->va_vaflags & VA_UTIMES_NULL) == 0 || + (error = VOP_ACCESS(vp, VWRITE, cred, p)))) return (error); if (vap->va_atime.ts_sec != VNOVAL) ip->i_flag |= IACC; if (vap->va_mtime.ts_sec != VNOVAL) - ip->i_flag |= IUPD; - ip->i_flag |= ICHG; + ip->i_flag |= IUPD | ICHG; atimeval.tv_sec = vap->va_atime.ts_sec; atimeval.tv_usec = vap->va_atime.ts_nsec / 1000; mtimeval.tv_sec = vap->va_mtime.ts_sec; @@ -326,18 +380,6 @@ ufs_setattr(ap) error = 0; if (vap->va_mode != (mode_t)VNOVAL) error = ufs_chmod(vp, (int)vap->va_mode, cred, p); - if (vap->va_flags != VNOVAL) { - if (cred->cr_uid != ip->i_uid && - (error = suser(cred, &p->p_acflag))) - return (error); - if (cred->cr_uid == 0) { - ip->i_flags = vap->va_flags; - } else { - ip->i_flags &= 0xffff0000; - ip->i_flags |= (vap->va_flags & 0xffff); - } - ip->i_flag |= ICHG; - } return (error); } @@ -564,21 +606,27 @@ ufs_remove(ap) struct componentname *a_cnp; } */ *ap; { - register struct inode *ip, *dp; + register struct inode *ip; + register struct vnode *vp = ap->a_vp; + register struct vnode *dvp = ap->a_dvp; int error; - ip = VTOI(ap->a_vp); - dp = VTOI(ap->a_dvp); - error = ufs_dirremove(ap->a_dvp, ap->a_cnp); - if (!error) { + ip = VTOI(vp); + if ((ip->i_flags & (IMMUTABLE | APPEND)) || + (VTOI(dvp)->i_flags & APPEND)) { + error = EPERM; + goto out; + } + if ((error = ufs_dirremove(dvp, ap->a_cnp)) == 0) { ip->i_nlink--; ip->i_flag |= ICHG; } - if (dp == ip) - vrele(ITOV(ip)); +out: + if (dvp == vp) + vrele(vp); else - ufs_iput(ip); - ufs_iput(dp); + vput(vp); + vput(dvp); return (error); } @@ -600,40 +648,46 @@ ufs_link(ap) struct timeval tv; int error; - if (vp->v_mount != tdvp->v_mount) { - VOP_ABORTOP(vp, cnp); - if (tdvp == vp) - vrele(vp); - else - vput(vp); - return (EXDEV); - } - #ifdef DIAGNOSTIC if ((cnp->cn_flags & HASBUF) == 0) panic("ufs_link: no name"); #endif + if (vp->v_mount != tdvp->v_mount) { + VOP_ABORTOP(vp, cnp); + error = EXDEV; + goto out2; + } + if (vp != tdvp && (error = VOP_LOCK(tdvp))) { + VOP_ABORTOP(vp, cnp); + goto out2; + } ip = VTOI(tdvp); if ((nlink_t)ip->i_nlink >= LINK_MAX) { - free(cnp->cn_pnbuf, M_NAMEI); - return (EMLINK); + VOP_ABORTOP(vp, cnp); + error = EMLINK; + goto out1; + } + if (ip->i_flags & (IMMUTABLE | APPEND)) { + VOP_ABORTOP(vp, cnp); + error = EPERM; + goto out1; } - if (vp != tdvp) - ILOCK(ip); ip->i_nlink++; ip->i_flag |= ICHG; tv = time; error = VOP_UPDATE(tdvp, &tv, &tv, 1); if (!error) error = ufs_direnter(ip, vp, cnp); - if (vp != tdvp) - IUNLOCK(ip); - FREE(cnp->cn_pnbuf, M_NAMEI); - vput(vp); if (error) { ip->i_nlink--; ip->i_flag |= ICHG; } + FREE(cnp->cn_pnbuf, M_NAMEI); +out1: + if (vp != tdvp) + VOP_UNLOCK(tdvp); +out2: + vput(vp); return (error); } @@ -842,9 +896,18 @@ ufs_rename(ap) int fdvpneedsrele = 1, tdvpneedsrele = 1; u_char namlen; - /* Check for cross-device rename */ +#ifdef DIAGNOSTIC + if ((tcnp->cn_flags & HASBUF) == 0 || + (fcnp->cn_flags & HASBUF) == 0) + panic("ufs_rename: no name"); +#endif + /* + * Check for cross-device rename. + */ if ((fvp->v_mount != tdvp->v_mount) || (tvp && (fvp->v_mount != tvp->v_mount))) { + error = EXDEV; +abortit: VOP_ABORTOP(tdvp, tcnp); /* XXX, why not in NFS? */ if (tdvp == tvp) vrele(tdvp); @@ -855,48 +918,54 @@ ufs_rename(ap) VOP_ABORTOP(fdvp, fcnp); /* XXX, why not in NFS? */ vrele(fdvp); vrele(fvp); - return (EXDEV); + return (error); } -#ifdef DIAGNOSTIC - if ((tcnp->cn_flags & HASBUF) == 0 || - (fcnp->cn_flags & HASBUF) == 0) - panic("ufs_rename: no name"); -#endif - dp = VTOI(fdvp); - ip = VTOI(fvp); /* * Check if just deleting a link name. */ + if (tvp && ((VTOI(tvp)->i_flags & (IMMUTABLE | APPEND)) || + (VTOI(tdvp)->i_flags & APPEND))) { + error = EPERM; + goto abortit; + } if (fvp == tvp) { - VOP_ABORTOP(tdvp, tcnp); + if (fvp->v_type == VDIR) { + error = EINVAL; + goto abortit; + } + VOP_ABORTOP(fdvp, fcnp); + vrele(fdvp); + vrele(fvp); vput(tdvp); vput(tvp); - vrele(fdvp); - if ((ip->i_mode&IFMT) == IFDIR) { - VOP_ABORTOP(fdvp, fcnp); - vrele(fvp); - return (EINVAL); - } - doingdirectory = 0; - goto unlinkit; + tcnp->cn_flags &= ~MODMASK; + tcnp->cn_flags |= LOCKPARENT | LOCKLEAF; + if ((tcnp->cn_flags & SAVESTART) == 0) + panic("ufs_rename: lost from startdir"); + tcnp->cn_nameiop = DELETE; + (void) relookup(tdvp, &tvp, tcnp); + return (VOP_REMOVE(tdvp, tvp, tcnp)); + } + if (error = VOP_LOCK(fvp)) + goto abortit; + dp = VTOI(fdvp); + ip = VTOI(fvp); + if ((ip->i_flags & (IMMUTABLE | APPEND)) || (dp->i_flags & APPEND)) { + VOP_UNLOCK(fvp); + error = EPERM; + goto abortit; } - ILOCK(ip); - if ((ip->i_mode&IFMT) == IFDIR) { + if ((ip->i_mode & IFMT) == IFDIR) { /* * Avoid ".", "..", and aliases of "." for obvious reasons. */ if ((fcnp->cn_namelen == 1 && fcnp->cn_nameptr[0] == '.') || dp == ip || (fcnp->cn_flags&ISDOTDOT) || (ip->i_flag & IRENAME)) { - VOP_ABORTOP(tdvp, tcnp); - vput(tdvp); - if (tvp) - vput(tvp); - VOP_ABORTOP(fdvp, fcnp); - vrele(fdvp); - vput(fvp); - return (EINVAL); + VOP_UNLOCK(fvp); + error = EINVAL; + goto abortit; } ip->i_flag |= IRENAME; oldparent = dp->i_number; @@ -904,6 +973,15 @@ ufs_rename(ap) } vrele(fdvp); + /* + * When the target exists, both the directory + * and target vnodes are returned locked. + */ + dp = VTOI(tdvp); + xp = NULL; + if (tvp) + xp = VTOI(tvp); + /* * 1) Bump link count while we're moving stuff * around. If we crash somewhere before @@ -913,17 +991,11 @@ ufs_rename(ap) ip->i_nlink++; ip->i_flag |= ICHG; tv = time; - error = VOP_UPDATE(fvp, &tv, &tv, 1); - IUNLOCK(ip); + if (error = VOP_UPDATE(fvp, &tv, &tv, 1)) { + VOP_UNLOCK(fvp); + goto bad; + } - /* - * When the target exists, both the directory - * and target vnodes are returned locked. - */ - dp = VTOI(tdvp); - xp = NULL; - if (tvp) - xp = VTOI(tvp); /* * If ".." must be changed (ie the directory gets a new * parent) then the source directory must not be in the @@ -934,21 +1006,19 @@ ufs_rename(ap) * to namei, as the parent directory is unlocked by the * call to checkpath(). */ + error = VOP_ACCESS(fvp, VWRITE, tcnp->cn_cred, tcnp->cn_proc); + VOP_UNLOCK(fvp); if (oldparent != dp->i_number) newparent = dp->i_number; if (doingdirectory && newparent) { - VOP_LOCK(fvp); - error = VOP_ACCESS(fvp, VWRITE, tcnp->cn_cred, tcnp->cn_proc); - VOP_UNLOCK(fvp); - if (error) + if (error) /* write access check above */ goto bad; if (xp != NULL) - ufs_iput(xp); + vput(tvp); if (error = ufs_checkpath(ip, dp, tcnp->cn_cred)) goto out; if ((tcnp->cn_flags & SAVESTART) == 0) panic("ufs_rename: lost to startdir"); - p->p_spare[1]--; if (error = relookup(tdvp, &tvp, tcnp)) goto out; dp = VTOI(tdvp); @@ -978,18 +1048,18 @@ ufs_rename(ap) } dp->i_nlink++; dp->i_flag |= ICHG; - if (error = VOP_UPDATE(ITOV(dp), &tv, &tv, 1)) + if (error = VOP_UPDATE(tdvp, &tv, &tv, 1)) goto bad; } if (error = ufs_direnter(ip, tdvp, tcnp)) { if (doingdirectory && newparent) { dp->i_nlink--; dp->i_flag |= ICHG; - (void)VOP_UPDATE(ITOV(dp), &tv, &tv, 1); + (void)VOP_UPDATE(tdvp, &tv, &tv, 1); } goto bad; } - ufs_iput(dp); + vput(tdvp); } else { if (xp->i_dev != dp->i_dev || xp->i_dev != ip->i_dev) panic("rename: EXDEV"); @@ -1025,7 +1095,7 @@ ufs_rename(ap) error = ENOTDIR; goto bad; } - cache_purge(ITOV(dp)); + cache_purge(tdvp); } else if (doingdirectory) { error = EISDIR; goto bad; @@ -1042,7 +1112,7 @@ ufs_rename(ap) dp->i_nlink--; dp->i_flag |= ICHG; } - ufs_iput(dp); + vput(tdvp); /* * Adjust the link count of the target to * reflect the dirrewrite above. If this is @@ -1057,23 +1127,21 @@ ufs_rename(ap) if (doingdirectory) { if (--xp->i_nlink != 0) panic("rename: linked directory"); - error = VOP_TRUNCATE(ITOV(xp), (off_t)0, IO_SYNC, + error = VOP_TRUNCATE(tvp, (off_t)0, IO_SYNC, tcnp->cn_cred, tcnp->cn_proc); } xp->i_flag |= ICHG; - ufs_iput(xp); + vput(tvp); xp = NULL; } /* * 3) Unlink the source. */ -unlinkit: fcnp->cn_flags &= ~MODMASK; fcnp->cn_flags |= LOCKPARENT | LOCKLEAF; if ((fcnp->cn_flags & SAVESTART) == 0) panic("ufs_rename: lost from startdir"); - p->p_spare[1]--; (void) relookup(fdvp, &fvp, fcnp); if (fvp != NULL) { xp = VTOI(fvp); @@ -1084,7 +1152,7 @@ unlinkit: */ if (doingdirectory) panic("rename: lost dir entry"); - vrele(ITOV(ip)); + vrele(ap->a_fvp); return (0); } /* @@ -1110,7 +1178,7 @@ unlinkit: if (doingdirectory && newparent) { dp->i_nlink--; dp->i_flag |= ICHG; - error = vn_rdwr(UIO_READ, ITOV(xp), (caddr_t)&dirbuf, + error = vn_rdwr(UIO_READ, fvp, (caddr_t)&dirbuf, sizeof (struct dirtemplate), (off_t)0, UIO_SYSSPACE, IO_NODELOCKED, tcnp->cn_cred, (int *)0, (struct proc *)0); @@ -1130,14 +1198,14 @@ unlinkit: "rename: mangled dir"); } else { dirbuf.dotdot_ino = newparent; - (void) vn_rdwr(UIO_WRITE, ITOV(xp), + (void) vn_rdwr(UIO_WRITE, fvp, (caddr_t)&dirbuf, sizeof (struct dirtemplate), (off_t)0, UIO_SYSSPACE, IO_NODELOCKED|IO_SYNC, tcnp->cn_cred, (int *)0, (struct proc *)0); - cache_purge(ITOV(dp)); + cache_purge(fdvp); } } } @@ -1149,10 +1217,10 @@ unlinkit: xp->i_flag &= ~IRENAME; } if (dp) - vput(ITOV(dp)); + vput(fdvp); if (xp) - vput(ITOV(xp)); - vrele(ITOV(ip)); + vput(fvp); + vrele(ap->a_fvp); return (error); bad: @@ -1160,9 +1228,12 @@ bad: vput(ITOV(xp)); vput(ITOV(dp)); out: - ip->i_nlink--; - ip->i_flag |= ICHG; - vrele(ITOV(ip)); + if (VOP_LOCK(fvp) == 0) { + ip->i_nlink--; + ip->i_flag |= ICHG; + vput(fvp); + } else + vrele(fvp); return (error); } @@ -1205,22 +1276,18 @@ ufs_mkdir(ap) #endif dp = VTOI(dvp); if ((nlink_t)dp->i_nlink >= LINK_MAX) { - free(cnp->cn_pnbuf, M_NAMEI); - ufs_iput(dp); - return (EMLINK); + error = EMLINK; + goto out; } - dmode = vap->va_mode&0777; + dmode = vap->va_mode & 0777; dmode |= IFDIR; /* - * Must simulate part of maknode here to acquire the inode, but - * not have it entered in the parent directory. The entry is made - * later after writing "." and ".." entries. + * Must simulate part of ufs_makeinode here to acquire the inode, + * but not have it entered in the parent directory. The entry is + * made later after writing "." and ".." entries. */ - if (error = VOP_VALLOC(dvp, dmode, cnp->cn_cred, &tvp)) { - free(cnp->cn_pnbuf, M_NAMEI); - ufs_iput(dp); - return (error); - } + if (error = VOP_VALLOC(dvp, dmode, cnp->cn_cred, &tvp)) + goto out; ip = VTOI(tvp); ip->i_uid = cnp->cn_cred->cr_uid; ip->i_gid = dp->i_gid; @@ -1229,17 +1296,17 @@ ufs_mkdir(ap) (error = chkiq(ip, 1, cnp->cn_cred, 0))) { free(cnp->cn_pnbuf, M_NAMEI); VOP_VFREE(tvp, ip->i_number, dmode); - ufs_iput(ip); - ufs_iput(dp); + vput(tvp); + vput(dvp); return (error); } #endif ip->i_flag |= IACC|IUPD|ICHG; ip->i_mode = dmode; - ITOV(ip)->v_type = VDIR; /* Rest init'd in iget() */ + tvp->v_type = VDIR; /* Rest init'd in iget() */ ip->i_nlink = 2; tv = time; - error = VOP_UPDATE(ITOV(ip), &tv, &tv, 1); + error = VOP_UPDATE(tvp, &tv, &tv, 1); /* * Bump link count in parent directory @@ -1249,7 +1316,7 @@ ufs_mkdir(ap) */ dp->i_nlink++; dp->i_flag |= ICHG; - if (error = VOP_UPDATE(ITOV(dp), &tv, &tv, 1)) + if (error = VOP_UPDATE(dvp, &tv, &tv, 1)) goto bad; /* Initialize directory with "." and ".." from static template. */ @@ -1260,7 +1327,7 @@ ufs_mkdir(ap) dirtemplate = *dtp; dirtemplate.dot_ino = ip->i_number; dirtemplate.dotdot_ino = dp->i_number; - error = vn_rdwr(UIO_WRITE, ITOV(ip), (caddr_t)&dirtemplate, + error = vn_rdwr(UIO_WRITE, tvp, (caddr_t)&dirtemplate, sizeof (dirtemplate), (off_t)0, UIO_SYSSPACE, IO_NODELOCKED|IO_SYNC, cnp->cn_cred, (int *)0, (struct proc *)0); if (error) { @@ -1288,11 +1355,12 @@ bad: if (error) { ip->i_nlink = 0; ip->i_flag |= ICHG; - ufs_iput(ip); + vput(tvp); } else - *ap->a_vpp = ITOV(ip); + *ap->a_vpp = tvp; +out: FREE(cnp->cn_pnbuf, M_NAMEI); - ufs_iput(dp); + vput(dvp); return (error); } @@ -1307,19 +1375,20 @@ ufs_rmdir(ap) struct componentname *a_cnp; } */ *ap; { + register struct vnode *vp = ap->a_vp; register struct vnode *dvp = ap->a_dvp; register struct componentname *cnp = ap->a_cnp; register struct inode *ip, *dp; int error; - ip = VTOI(ap->a_vp); + ip = VTOI(vp); dp = VTOI(dvp); /* * No rmdir "." please. */ if (dp == ip) { vrele(dvp); - ufs_iput(ip); + vput(vp); return (EINVAL); } /* @@ -1335,6 +1404,10 @@ ufs_rmdir(ap) error = ENOTEMPTY; goto out; } + if ((dp->i_flags & APPEND) || (ip->i_flags & (IMMUTABLE | APPEND))) { + error = EPERM; + goto out; + } /* * Delete reference to directory before purging * inode. If we crash in between, the directory @@ -1345,7 +1418,7 @@ ufs_rmdir(ap) dp->i_nlink--; dp->i_flag |= ICHG; cache_purge(dvp); - ufs_iput(dp); + vput(dvp); dvp = NULL; /* * Truncate inode. The only stuff left @@ -1359,13 +1432,13 @@ ufs_rmdir(ap) * worry about them later. */ ip->i_nlink -= 2; - error = VOP_TRUNCATE(ap->a_vp, (off_t)0, IO_SYNC, cnp->cn_cred, + error = VOP_TRUNCATE(vp, (off_t)0, IO_SYNC, cnp->cn_cred, cnp->cn_proc); cache_purge(ITOV(ip)); out: if (dvp) - ufs_iput(dp); - ufs_iput(ip); + vput(dvp); + vput(vp); return (error); } @@ -1449,7 +1522,7 @@ ufs_readdir(ap) aiov.iov_len = count; MALLOC(dirbuf, caddr_t, count, M_TEMP, M_WAITOK); aiov.iov_base = dirbuf; - error = VOP_READ(ap->a_vp, uio, 0, ap->a_cred); + error = VOP_READ(ap->a_vp, &auio, 0, ap->a_cred); if (error == 0) { readcnt = count - auio.uio_resid; edp = (struct dirent *)&dirbuf[readcnt]; @@ -1518,7 +1591,7 @@ ufs_abortop(ap) } /* - * Lock an inode. + * Lock an inode. If its already locked, set the WANT bit and sleep. */ int ufs_lock(ap) @@ -1526,15 +1599,50 @@ ufs_lock(ap) struct vnode *a_vp; } */ *ap; { - register struct inode *ip = VTOI(ap->a_vp); + register struct vnode *vp = ap->a_vp; + register struct inode *ip; + struct proc *p = curproc; /* XXX */ - ILOCK(ip); +start: + while (vp->v_flag & VXLOCK) { + vp->v_flag |= VXWANT; + sleep((caddr_t)vp, PINOD); + } + if (vp->v_tag == VT_NON) + return (ENOENT); + ip = VTOI(vp); + if (ip->i_flag & ILOCKED) { + ip->i_flag |= IWANT; +#ifdef DIAGNOSTIC + if (p) { + if (p->p_pid == ip->i_lockholder) + panic("locking against myself"); + ip->i_lockwaiter = p->p_pid; + } else + ip->i_lockwaiter = -1; +#endif + (void) sleep((caddr_t)ip, PINOD); + goto start; + } +#ifdef DIAGNOSTIC + ip->i_lockwaiter = 0; + if (ip->i_lockholder != 0) + panic("lockholder (%d) != 0", ip->i_lockholder); + if (p && p->p_pid == 0) + printf("locking by process 0\n"); + if (p) + ip->i_lockholder = p->p_pid; + else + ip->i_lockholder = -1; +#endif + ip->i_flag |= ILOCKED; return (0); } /* - * Unlock an inode. + * Unlock an inode. If WANT bit is on, wakeup. */ +int lockcount = 90; int ufs_unlock(ap) struct vop_unlock_args /* { @@ -1542,10 +1650,24 @@ ufs_unlock(ap) } */ *ap; { register struct inode *ip = VTOI(ap->a_vp); + struct proc *p = curproc; /* XXX */ - if (!(ip->i_flag & ILOCKED)) +#ifdef DIAGNOSTIC + if ((ip->i_flag & ILOCKED) == 0) { + vprint("ufs_unlock: unlocked inode", ap->a_vp); panic("ufs_unlock NOT LOCKED"); - IUNLOCK(ip); + } + if (p && p->p_pid != ip->i_lockholder && p->p_pid > -1 && + ip->i_lockholder > -1 && lockcount++ < 100) + panic("unlocker (%d) != lock holder (%d)", + p->p_pid, ip->i_lockholder); + ip->i_lockholder = 0; +#endif + ip->i_flag &= ~ILOCKED; + if (ip->i_flag & IWANT) { + ip->i_flag &= ~IWANT; + wakeup((caddr_t)ip); + } return (0); } @@ -1584,7 +1706,7 @@ ufs_strategy(ap) panic("ufs_strategy: spec"); if (bp->b_blkno == bp->b_lblkno) { if (error = - VOP_BMAP(vp, bp->b_lblkno, NULL, &bp->b_blkno)) { + VOP_BMAP(vp, bp->b_lblkno, NULL, &bp->b_blkno, NULL)) { bp->b_error = error; bp->b_flags |= B_ERROR; biodone(bp); @@ -1757,6 +1879,42 @@ ufsfifo_close(ap) } #endif /* FIFO */ +/* + * Return POSIX pathconf information applicable to ufs filesystems. + */ +ufs_pathconf(ap) + struct vop_pathconf_args /* { + struct vnode *a_vp; + int a_name; + int *a_retval; + } */ *ap; +{ + + switch (ap->a_name) { + case _PC_LINK_MAX: + *ap->a_retval = LINK_MAX; + return (0); + case _PC_NAME_MAX: + *ap->a_retval = NAME_MAX; + return (0); + case _PC_PATH_MAX: + *ap->a_retval = PATH_MAX; + return (0); + case _PC_PIPE_BUF: + *ap->a_retval = PIPE_BUF; + return (0); + case _PC_CHOWN_RESTRICTED: + *ap->a_retval = 1; + return (0); + case _PC_NO_TRUNC: + *ap->a_retval = 1; + return (0); + default: + return (EINVAL); + } + /* NOTREACHED */ +} + /* * Advisory record locking support */ @@ -1873,7 +2031,7 @@ ufs_vinit(mntp, specops, fifoops, vpp) * Discard unneeded vnode, but save its inode. */ ufs_ihashrem(ip); - IUNLOCK(ip); + VOP_UNLOCK(vp); nvp->v_data = vp->v_data; vp->v_data = NULL; vp->v_op = spec_vnodeop_p; @@ -1932,19 +2090,22 @@ ufs_makeinode(mode, dvp, vpp, cnp) if (error = VOP_VALLOC(dvp, mode, cnp->cn_cred, &tvp)) { free(cnp->cn_pnbuf, M_NAMEI); - ufs_iput(pdir); + vput(dvp); return (error); } ip = VTOI(tvp); - ip->i_uid = cnp->cn_cred->cr_uid; ip->i_gid = pdir->i_gid; + if ((mode & IFMT) == IFLNK) + ip->i_uid = pdir->i_uid; + else + ip->i_uid = cnp->cn_cred->cr_uid; #ifdef QUOTA if ((error = getinoquota(ip)) || (error = chkiq(ip, 1, cnp->cn_cred, 0))) { free(cnp->cn_pnbuf, M_NAMEI); VOP_VFREE(tvp, ip->i_number, mode); - ufs_iput(ip); - ufs_iput(pdir); + vput(tvp); + vput(dvp); return (error); } #endif @@ -1966,7 +2127,7 @@ ufs_makeinode(mode, dvp, vpp, cnp) goto bad; if ((cnp->cn_flags & SAVESTART) == 0) FREE(cnp->cn_pnbuf, M_NAMEI); - ufs_iput(pdir); + vput(dvp); *vpp = tvp; return (0); @@ -1976,9 +2137,9 @@ bad: * or the directory so must deallocate the inode. */ free(cnp->cn_pnbuf, M_NAMEI); - ufs_iput(pdir); + vput(dvp); ip->i_nlink = 0; ip->i_flag |= ICHG; - ufs_iput(ip); + vput(tvp); return (error); }