-/*
- * Vnode op for reading.
- */
-/* ARGSUSED */
-lfs_read(ap)
- struct vop_read_args /* {
- struct vnode *a_vp;
- struct uio *a_uio;
- int a_ioflag;
- struct ucred *a_cred;
- } */ *ap;
-{
- register struct uio *uio = ap->a_uio;
- register struct inode *ip = VTOI(ap->a_vp);
- register struct lfs *fs; /* LFS */
- struct buf *bp;
- daddr_t lbn, bn, rablock;
- int size, error = 0;
- long n, on, type;
- off_t diff;
-
-#ifdef VERBOSE
- printf("lfs_read: ino %d\n", ip->i_number);
-#endif
-#ifdef DIAGNOSTIC
- if (uio->uio_rw != UIO_READ)
- panic("ufs_read mode");
- type = ip->i_mode & IFMT;
- if (type != IFDIR && type != IFREG && type != IFLNK)
- panic("ufs_read type");
-#endif
- if (uio->uio_resid == 0)
- return (0);
- if (uio->uio_offset < 0)
- return (EINVAL);
- ip->i_flag |= IACC;
-
- fs = ip->i_lfs; /* LFS */
- do {
- lbn = lblkno(fs, uio->uio_offset);
- on = blkoff(fs, uio->uio_offset);
- n = MIN((unsigned)(fs->lfs_bsize - on), uio->uio_resid);
- diff = ip->i_size - uio->uio_offset;
- if (diff <= 0)
- return (0);
- if (diff < n)
- n = diff;
- size = blksize(fs); /* LFS */
- rablock = lbn + 1;
- if (ap->a_vp->v_lastr + 1 == lbn &&
- lblktosize(fs, rablock) < ip->i_size)
- error = breadn(ITOV(ip), lbn, size, &rablock,
- &size, 1, NOCRED, &bp);
- else
- error = bread(ITOV(ip), lbn, size, NOCRED, &bp);
- ap->a_vp->v_lastr = lbn;
- n = MIN(n, size - bp->b_resid);
- if (error) {
- brelse(bp);
- return (error);
- }
- error = uiomove(bp->b_un.b_addr + on, (int)n, uio);
- if (n + on == fs->lfs_bsize || uio->uio_offset == ip->i_size)
- bp->b_flags |= B_AGE;
- brelse(bp);
- } while (error == 0 && uio->uio_resid > 0 && n != 0);
- return (error);
-}
-
-/*
- * Vnode op for writing.
- */
-lfs_write(ap)
- struct vop_write_args /* {
- struct vnode *a_vp;
- struct uio *a_uio;
- int a_ioflag;
- struct ucred *a_cred;
- } */ *ap;
-{
- register struct vnode *vp = ap->a_vp;
- register struct uio *uio = ap->a_uio;
- struct proc *p = uio->uio_procp;
- register struct inode *ip = VTOI(vp);
- register struct lfs *fs;
- register ioflag = ap->a_ioflag;
- struct timeval tv;
- struct buf *bp;
- daddr_t lbn;
- off_t osize;
- int n, on, flags, newblock;
- int size, resid, error = 0;
-
-#ifdef VERBOSE
- printf("lfs_write ino %d\n", ip->i_number);
-#endif
-#ifdef DIAGNOSTIC
- if (uio->uio_rw != UIO_WRITE)
- panic("lfs_write mode");
-#endif
- switch (vp->v_type) {
- case VREG:
- if (ioflag & IO_APPEND)
- uio->uio_offset = ip->i_size;
- /* fall through */
- case VLNK:
- break;
-
- case VDIR:
- /* XXX This may not be correct for LFS. */
- if ((ioflag & IO_SYNC) == 0)
- panic("lfs_write nonsync dir write");
- break;
-
- default:
- panic("lfs_write type");
- }
- if (uio->uio_offset < 0)
- return (EINVAL);
- if (uio->uio_resid == 0)
- return (0);
- /*
- * Maybe this should be above the vnode op call, but so long as
- * file servers have no limits, i don't think it matters
- */
- if (vp->v_type == VREG && p &&
- uio->uio_offset + uio->uio_resid >
- p->p_rlimit[RLIMIT_FSIZE].rlim_cur) {
- psignal(p, SIGXFSZ);
- return (EFBIG);
- }
- resid = uio->uio_resid;
- osize = ip->i_size;
- fs = ip->i_lfs; /* LFS */
- flags = 0;
-#ifdef NOTLFS
- if (ioflag & IO_SYNC)
- flags = B_SYNC;
-#endif
- do {
- lbn = lblkno(fs, uio->uio_offset);
- on = blkoff(fs, uio->uio_offset);
- n = MIN((unsigned)(fs->lfs_bsize - on), uio->uio_resid);
- if (error = lfs_balloc(vp, n, lbn, &bp))
- break;
- if (uio->uio_offset + n > ip->i_size) {
- ip->i_size = uio->uio_offset + n;
- vnode_pager_setsize(vp, (u_long)ip->i_size);
- }
- size = blksize(fs);
- (void) vnode_pager_uncache(vp);
- n = MIN(n, size - bp->b_resid);
- error = uiomove(bp->b_un.b_addr + on, n, uio);
-#ifdef NOTLFS /* LFS */
- if (ioflag & IO_SYNC)
- (void) bwrite(bp);
- else if (n + on == fs->fs_bsize) {
- bp->b_flags |= B_AGE;
- bawrite(bp);
- } else
- bdwrite(bp);
- ip->i_flag |= IUPD|ICHG;
-#else
- /* XXX This doesn't handle IO_SYNC. */
- LFS_UBWRITE(bp);
-#endif
- if (ap->a_cred->cr_uid != 0)
- ip->i_mode &= ~(ISUID|ISGID);
- } while (error == 0 && uio->uio_resid > 0 && n != 0);
- if (error && (ioflag & IO_UNIT)) {
- (void)VOP_TRUNCATE(vp, osize, ioflag & IO_SYNC, ap->a_cred,
- uio->uio_procp);
- uio->uio_offset -= resid - uio->uio_resid;
- uio->uio_resid = resid;
- }
- if (!error && (ioflag & IO_SYNC)) {
- tv = time;
- error = VOP_UPDATE(vp, &tv, &tv, 1);
- }
- return (error);
-}
projects / unix-history / blobdiff