Home | History | Annotate | Line # | Download | only in lfs
lfs_vfsops.c revision 1.62
      1  1.62  perseant /*	$NetBSD: lfs_vfsops.c,v 1.62 2000/12/03 07:34:49 perseant Exp $	*/
      2   1.2       cgd 
      3  1.26  perseant /*-
      4  1.58  perseant  * Copyright (c) 1999, 2000 The NetBSD Foundation, Inc.
      5  1.26  perseant  * All rights reserved.
      6  1.26  perseant  *
      7  1.26  perseant  * This code is derived from software contributed to The NetBSD Foundation
      8  1.26  perseant  * by Konrad E. Schroder <perseant (at) hhhh.org>.
      9  1.26  perseant  *
     10  1.26  perseant  * Redistribution and use in source and binary forms, with or without
     11  1.26  perseant  * modification, are permitted provided that the following conditions
     12  1.26  perseant  * are met:
     13  1.26  perseant  * 1. Redistributions of source code must retain the above copyright
     14  1.26  perseant  *    notice, this list of conditions and the following disclaimer.
     15  1.26  perseant  * 2. Redistributions in binary form must reproduce the above copyright
     16  1.26  perseant  *    notice, this list of conditions and the following disclaimer in the
     17  1.26  perseant  *    documentation and/or other materials provided with the distribution.
     18  1.26  perseant  * 3. All advertising materials mentioning features or use of this software
     19  1.26  perseant  *    must display the following acknowledgement:
     20  1.26  perseant  *      This product includes software developed by the NetBSD
     21  1.26  perseant  *      Foundation, Inc. and its contributors.
     22  1.26  perseant  * 4. Neither the name of The NetBSD Foundation nor the names of its
     23  1.26  perseant  *    contributors may be used to endorse or promote products derived
     24  1.26  perseant  *    from this software without specific prior written permission.
     25  1.26  perseant  *
     26  1.26  perseant  * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
     27  1.26  perseant  * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
     28  1.26  perseant  * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
     29  1.26  perseant  * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
     30  1.26  perseant  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
     31  1.26  perseant  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
     32  1.26  perseant  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
     33  1.26  perseant  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
     34  1.26  perseant  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
     35  1.26  perseant  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
     36  1.26  perseant  * POSSIBILITY OF SUCH DAMAGE.
     37  1.26  perseant  */
     38  1.26  perseant /*-
     39   1.1   mycroft  * Copyright (c) 1989, 1991, 1993, 1994
     40   1.1   mycroft  *	The Regents of the University of California.  All rights reserved.
     41   1.1   mycroft  *
     42   1.1   mycroft  * Redistribution and use in source and binary forms, with or without
     43   1.1   mycroft  * modification, are permitted provided that the following conditions
     44   1.1   mycroft  * are met:
     45   1.1   mycroft  * 1. Redistributions of source code must retain the above copyright
     46   1.1   mycroft  *    notice, this list of conditions and the following disclaimer.
     47   1.1   mycroft  * 2. Redistributions in binary form must reproduce the above copyright
     48   1.1   mycroft  *    notice, this list of conditions and the following disclaimer in the
     49   1.1   mycroft  *    documentation and/or other materials provided with the distribution.
     50   1.1   mycroft  * 3. All advertising materials mentioning features or use of this software
     51   1.1   mycroft  *    must display the following acknowledgement:
     52   1.1   mycroft  *	This product includes software developed by the University of
     53   1.1   mycroft  *	California, Berkeley and its contributors.
     54   1.1   mycroft  * 4. Neither the name of the University nor the names of its contributors
     55   1.1   mycroft  *    may be used to endorse or promote products derived from this software
     56   1.1   mycroft  *    without specific prior written permission.
     57   1.1   mycroft  *
     58   1.1   mycroft  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     59   1.1   mycroft  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     60   1.1   mycroft  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     61   1.1   mycroft  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     62   1.1   mycroft  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     63   1.1   mycroft  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     64   1.1   mycroft  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     65   1.1   mycroft  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     66   1.1   mycroft  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     67   1.1   mycroft  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     68   1.1   mycroft  * SUCH DAMAGE.
     69   1.1   mycroft  *
     70  1.16      fvdl  *	@(#)lfs_vfsops.c	8.20 (Berkeley) 6/10/95
     71   1.1   mycroft  */
     72  1.19    scottr 
     73  1.20    scottr #if defined(_KERNEL) && !defined(_LKM)
     74  1.19    scottr #include "opt_quota.h"
     75  1.20    scottr #endif
     76   1.1   mycroft 
     77   1.1   mycroft #include <sys/param.h>
     78   1.1   mycroft #include <sys/systm.h>
     79   1.1   mycroft #include <sys/namei.h>
     80   1.1   mycroft #include <sys/proc.h>
     81   1.1   mycroft #include <sys/kernel.h>
     82   1.1   mycroft #include <sys/vnode.h>
     83   1.1   mycroft #include <sys/mount.h>
     84   1.1   mycroft #include <sys/buf.h>
     85  1.38  augustss #include <sys/device.h>
     86   1.1   mycroft #include <sys/mbuf.h>
     87   1.1   mycroft #include <sys/file.h>
     88   1.1   mycroft #include <sys/disklabel.h>
     89   1.1   mycroft #include <sys/ioctl.h>
     90   1.1   mycroft #include <sys/errno.h>
     91   1.1   mycroft #include <sys/malloc.h>
     92  1.23   thorpej #include <sys/pool.h>
     93   1.1   mycroft #include <sys/socket.h>
     94  1.54       mrg #include <uvm/uvm_extern.h>
     95  1.26  perseant #include <sys/sysctl.h>
     96   1.1   mycroft 
     97   1.1   mycroft #include <miscfs/specfs/specdev.h>
     98   1.1   mycroft 
     99   1.1   mycroft #include <ufs/ufs/quota.h>
    100   1.1   mycroft #include <ufs/ufs/inode.h>
    101   1.1   mycroft #include <ufs/ufs/ufsmount.h>
    102   1.1   mycroft #include <ufs/ufs/ufs_extern.h>
    103   1.1   mycroft 
    104   1.1   mycroft #include <ufs/lfs/lfs.h>
    105   1.1   mycroft #include <ufs/lfs/lfs_extern.h>
    106   1.1   mycroft 
    107   1.1   mycroft int lfs_mountfs __P((struct vnode *, struct mount *, struct proc *));
    108   1.1   mycroft 
    109  1.15   thorpej extern struct vnodeopv_desc lfs_vnodeop_opv_desc;
    110  1.15   thorpej extern struct vnodeopv_desc lfs_specop_opv_desc;
    111  1.15   thorpej extern struct vnodeopv_desc lfs_fifoop_opv_desc;
    112  1.15   thorpej 
    113  1.15   thorpej struct vnodeopv_desc *lfs_vnodeopv_descs[] = {
    114  1.15   thorpej 	&lfs_vnodeop_opv_desc,
    115  1.15   thorpej 	&lfs_specop_opv_desc,
    116  1.15   thorpej 	&lfs_fifoop_opv_desc,
    117  1.15   thorpej 	NULL,
    118  1.15   thorpej };
    119  1.15   thorpej 
    120   1.1   mycroft struct vfsops lfs_vfsops = {
    121   1.1   mycroft 	MOUNT_LFS,
    122   1.1   mycroft 	lfs_mount,
    123   1.1   mycroft 	ufs_start,
    124   1.1   mycroft 	lfs_unmount,
    125   1.1   mycroft 	ufs_root,
    126   1.1   mycroft 	ufs_quotactl,
    127   1.1   mycroft 	lfs_statfs,
    128   1.1   mycroft 	lfs_sync,
    129   1.1   mycroft 	lfs_vget,
    130   1.1   mycroft 	lfs_fhtovp,
    131   1.1   mycroft 	lfs_vptofh,
    132   1.1   mycroft 	lfs_init,
    133  1.47  jdolecek 	lfs_done,
    134  1.16      fvdl 	lfs_sysctl,
    135  1.36  perseant 	lfs_mountroot,
    136  1.25  wrstuden 	ufs_check_export,
    137  1.15   thorpej 	lfs_vnodeopv_descs,
    138   1.1   mycroft };
    139   1.1   mycroft 
    140  1.23   thorpej struct pool lfs_inode_pool;
    141  1.23   thorpej 
    142  1.60  perseant extern int locked_queue_count;
    143  1.60  perseant extern long locked_queue_bytes;
    144  1.60  perseant 
    145  1.16      fvdl /*
    146  1.16      fvdl  * Initialize the filesystem, most work done by ufs_init.
    147  1.16      fvdl  */
    148  1.16      fvdl void
    149  1.16      fvdl lfs_init()
    150  1.16      fvdl {
    151  1.16      fvdl 	ufs_init();
    152  1.56  perseant 
    153  1.23   thorpej 	/*
    154  1.23   thorpej 	 * XXX Same structure as FFS inodes?  Should we share a common pool?
    155  1.23   thorpej 	 */
    156  1.23   thorpej 	pool_init(&lfs_inode_pool, sizeof(struct inode), 0, 0, 0,
    157  1.26  perseant 		  "lfsinopl", 0, pool_page_alloc_nointr, pool_page_free_nointr,
    158  1.26  perseant 		  M_LFSNODE);
    159  1.47  jdolecek }
    160  1.47  jdolecek 
    161  1.47  jdolecek void
    162  1.47  jdolecek lfs_done()
    163  1.47  jdolecek {
    164  1.47  jdolecek 	ufs_done();
    165  1.47  jdolecek 	pool_destroy(&lfs_inode_pool);
    166  1.16      fvdl }
    167  1.16      fvdl 
    168  1.16      fvdl /*
    169  1.16      fvdl  * Called by main() when ufs is going to be mounted as root.
    170  1.16      fvdl  */
    171   1.1   mycroft int
    172   1.1   mycroft lfs_mountroot()
    173   1.1   mycroft {
    174  1.16      fvdl 	extern struct vnode *rootvp;
    175  1.16      fvdl 	struct mount *mp;
    176  1.16      fvdl 	struct proc *p = curproc;	/* XXX */
    177  1.16      fvdl 	int error;
    178  1.16      fvdl 
    179  1.37  sommerfe 	if (root_device->dv_class != DV_DISK)
    180  1.37  sommerfe 		return (ENODEV);
    181  1.37  sommerfe 
    182  1.37  sommerfe 	if (rootdev == NODEV)
    183  1.37  sommerfe 	  	return (ENODEV);
    184  1.16      fvdl 	/*
    185  1.16      fvdl 	 * Get vnodes for swapdev and rootdev.
    186  1.16      fvdl 	 */
    187  1.16      fvdl 	if ((error = bdevvp(rootdev, &rootvp))) {
    188  1.16      fvdl 		printf("lfs_mountroot: can't setup bdevvp's");
    189  1.16      fvdl 		return (error);
    190  1.16      fvdl 	}
    191  1.35  wrstuden 	if ((error = vfs_rootmountalloc(MOUNT_LFS, "root_device", &mp))) {
    192  1.35  wrstuden 		vrele(rootvp);
    193  1.16      fvdl 		return (error);
    194  1.35  wrstuden 	}
    195  1.16      fvdl 	if ((error = lfs_mountfs(rootvp, mp, p))) {
    196  1.16      fvdl 		mp->mnt_op->vfs_refcount--;
    197  1.16      fvdl 		vfs_unbusy(mp);
    198  1.16      fvdl 		free(mp, M_MOUNT);
    199  1.35  wrstuden 		vrele(rootvp);
    200  1.16      fvdl 		return (error);
    201  1.16      fvdl 	}
    202  1.16      fvdl 	simple_lock(&mountlist_slock);
    203  1.16      fvdl 	CIRCLEQ_INSERT_TAIL(&mountlist, mp, mnt_list);
    204  1.16      fvdl 	simple_unlock(&mountlist_slock);
    205  1.16      fvdl 	(void)lfs_statfs(mp, &mp->mnt_stat, p);
    206  1.16      fvdl 	vfs_unbusy(mp);
    207  1.16      fvdl 	return (0);
    208   1.1   mycroft }
    209   1.1   mycroft 
    210   1.1   mycroft /*
    211   1.1   mycroft  * VFS Operations.
    212   1.1   mycroft  *
    213   1.1   mycroft  * mount system call
    214   1.1   mycroft  */
    215  1.10  christos int
    216   1.1   mycroft lfs_mount(mp, path, data, ndp, p)
    217  1.48  augustss 	struct mount *mp;
    218  1.12       cgd 	const char *path;
    219  1.12       cgd 	void *data;
    220   1.1   mycroft 	struct nameidata *ndp;
    221   1.1   mycroft 	struct proc *p;
    222   1.1   mycroft {
    223   1.1   mycroft 	struct vnode *devvp;
    224   1.1   mycroft 	struct ufs_args args;
    225  1.10  christos 	struct ufsmount *ump = NULL;
    226  1.48  augustss 	struct lfs *fs = NULL;				/* LFS */
    227   1.8   mycroft 	size_t size;
    228   1.1   mycroft 	int error;
    229   1.3   mycroft 	mode_t accessmode;
    230   1.1   mycroft 
    231  1.10  christos 	error = copyin(data, (caddr_t)&args, sizeof (struct ufs_args));
    232  1.10  christos 	if (error)
    233   1.1   mycroft 		return (error);
    234   1.1   mycroft 
    235  1.29   mycroft #if 0
    236   1.1   mycroft 	/* Until LFS can do NFS right.		XXX */
    237   1.1   mycroft 	if (args.export.ex_flags & MNT_EXPORTED)
    238   1.1   mycroft 		return (EINVAL);
    239  1.29   mycroft #endif
    240   1.1   mycroft 
    241   1.1   mycroft 	/*
    242   1.1   mycroft 	 * If updating, check whether changing from read-only to
    243   1.1   mycroft 	 * read/write; if there is no device name, that's all we do.
    244   1.1   mycroft 	 */
    245   1.1   mycroft 	if (mp->mnt_flag & MNT_UPDATE) {
    246   1.1   mycroft 		ump = VFSTOUFS(mp);
    247  1.29   mycroft 		fs = ump->um_lfs;
    248   1.3   mycroft 		if (fs->lfs_ronly && (mp->mnt_flag & MNT_WANTRDWR)) {
    249   1.3   mycroft 			/*
    250   1.3   mycroft 			 * If upgrade to read-write by non-root, then verify
    251   1.3   mycroft 			 * that user has necessary permissions on the device.
    252   1.3   mycroft 			 */
    253   1.3   mycroft 			if (p->p_ucred->cr_uid != 0) {
    254  1.16      fvdl 				vn_lock(ump->um_devvp, LK_EXCLUSIVE | LK_RETRY);
    255  1.10  christos 				error = VOP_ACCESS(ump->um_devvp, VREAD|VWRITE,
    256  1.10  christos 						   p->p_ucred, p);
    257  1.16      fvdl 				VOP_UNLOCK(ump->um_devvp, 0);
    258  1.16      fvdl 				if (error)
    259   1.3   mycroft 					return (error);
    260   1.3   mycroft 			}
    261   1.1   mycroft 			fs->lfs_ronly = 0;
    262   1.3   mycroft 		}
    263   1.1   mycroft 		if (args.fspec == 0) {
    264   1.1   mycroft 			/*
    265   1.1   mycroft 			 * Process export requests.
    266   1.1   mycroft 			 */
    267   1.1   mycroft 			return (vfs_export(mp, &ump->um_export, &args.export));
    268   1.1   mycroft 		}
    269   1.1   mycroft 	}
    270   1.1   mycroft 	/*
    271   1.1   mycroft 	 * Not an update, or updating the name: look up the name
    272   1.1   mycroft 	 * and verify that it refers to a sensible block device.
    273   1.1   mycroft 	 */
    274   1.1   mycroft 	NDINIT(ndp, LOOKUP, FOLLOW, UIO_USERSPACE, args.fspec, p);
    275  1.10  christos 	if ((error = namei(ndp)) != 0)
    276   1.1   mycroft 		return (error);
    277   1.1   mycroft 	devvp = ndp->ni_vp;
    278   1.1   mycroft 	if (devvp->v_type != VBLK) {
    279   1.1   mycroft 		vrele(devvp);
    280   1.1   mycroft 		return (ENOTBLK);
    281   1.1   mycroft 	}
    282   1.1   mycroft 	if (major(devvp->v_rdev) >= nblkdev) {
    283   1.1   mycroft 		vrele(devvp);
    284   1.1   mycroft 		return (ENXIO);
    285   1.1   mycroft 	}
    286   1.3   mycroft 	/*
    287   1.3   mycroft 	 * If mount by non-root, then verify that user has necessary
    288   1.3   mycroft 	 * permissions on the device.
    289   1.3   mycroft 	 */
    290   1.3   mycroft 	if (p->p_ucred->cr_uid != 0) {
    291   1.3   mycroft 		accessmode = VREAD;
    292   1.3   mycroft 		if ((mp->mnt_flag & MNT_RDONLY) == 0)
    293   1.3   mycroft 			accessmode |= VWRITE;
    294  1.16      fvdl 		vn_lock(devvp, LK_EXCLUSIVE | LK_RETRY);
    295  1.10  christos 		error = VOP_ACCESS(devvp, accessmode, p->p_ucred, p);
    296  1.10  christos 		if (error) {
    297   1.3   mycroft 			vput(devvp);
    298   1.3   mycroft 			return (error);
    299   1.3   mycroft 		}
    300  1.16      fvdl 		VOP_UNLOCK(devvp, 0);
    301   1.3   mycroft 	}
    302   1.1   mycroft 	if ((mp->mnt_flag & MNT_UPDATE) == 0)
    303   1.1   mycroft 		error = lfs_mountfs(devvp, mp, p);		/* LFS */
    304   1.1   mycroft 	else {
    305   1.1   mycroft 		if (devvp != ump->um_devvp)
    306   1.1   mycroft 			error = EINVAL;	/* needs translation */
    307   1.1   mycroft 		else
    308   1.1   mycroft 			vrele(devvp);
    309   1.1   mycroft 	}
    310   1.1   mycroft 	if (error) {
    311   1.1   mycroft 		vrele(devvp);
    312   1.1   mycroft 		return (error);
    313   1.1   mycroft 	}
    314   1.1   mycroft 	ump = VFSTOUFS(mp);
    315   1.1   mycroft 	fs = ump->um_lfs;					/* LFS */
    316   1.1   mycroft 	(void)copyinstr(path, fs->lfs_fsmnt, sizeof(fs->lfs_fsmnt) - 1, &size);
    317   1.1   mycroft 	bzero(fs->lfs_fsmnt + size, sizeof(fs->lfs_fsmnt) - size);
    318   1.6   mycroft 	bcopy(fs->lfs_fsmnt, mp->mnt_stat.f_mntonname, MNAMELEN);
    319   1.1   mycroft 	(void) copyinstr(args.fspec, mp->mnt_stat.f_mntfromname, MNAMELEN - 1,
    320  1.26  perseant 			 &size);
    321   1.1   mycroft 	bzero(mp->mnt_stat.f_mntfromname + size, MNAMELEN - size);
    322   1.1   mycroft 	return (0);
    323   1.1   mycroft }
    324   1.1   mycroft 
    325  1.60  perseant #ifdef LFS_DO_ROLLFORWARD
    326  1.60  perseant /*
    327  1.60  perseant  * Roll-forward code.
    328  1.60  perseant  */
    329  1.60  perseant 
    330  1.60  perseant /*
    331  1.60  perseant  * Load the appropriate indirect block, and change the appropriate pointer.
    332  1.60  perseant  * Mark the block dirty.  Do segment and avail accounting.
    333  1.60  perseant  */
    334  1.60  perseant static int
    335  1.60  perseant update_meta(struct lfs *fs, ino_t ino, int version, ufs_daddr_t lbn,
    336  1.60  perseant 	    daddr_t ndaddr, size_t size, struct proc *p)
    337  1.60  perseant {
    338  1.60  perseant 	int error;
    339  1.60  perseant 	struct vnode *vp;
    340  1.60  perseant 	struct inode *ip;
    341  1.60  perseant 	daddr_t odaddr, ooff;
    342  1.60  perseant 	struct indir a[NIADDR], *ap;
    343  1.60  perseant 	struct buf *bp;
    344  1.60  perseant 	SEGUSE *sup;
    345  1.60  perseant 	int num;
    346  1.60  perseant 
    347  1.60  perseant 	if ((error = lfs_rf_valloc(fs, ino, version, p, &vp)) != 0) {
    348  1.60  perseant 		printf("update_meta: ino %d: lfs_rf_valloc returned %d\n", ino,
    349  1.60  perseant 		       error);
    350  1.60  perseant 		return error;
    351  1.60  perseant 	}
    352  1.60  perseant 
    353  1.60  perseant 	if ((error = VOP_BALLOC(vp, (lbn << fs->lfs_bshift), size,
    354  1.60  perseant 				NOCRED, 0, &bp)) != 0) {
    355  1.60  perseant 		vput(vp);
    356  1.60  perseant 		return (error);
    357  1.60  perseant 	}
    358  1.60  perseant 	/* No need to write, the block is already on disk */
    359  1.60  perseant 	if (bp->b_flags & B_DELWRI) {
    360  1.60  perseant 		LFS_UNLOCK_BUF(bp);
    361  1.60  perseant 		fs->lfs_avail += btodb(bp->b_bcount);
    362  1.60  perseant 	}
    363  1.60  perseant 	bp->b_flags |= B_INVAL;
    364  1.60  perseant 	brelse(bp);
    365  1.60  perseant 
    366  1.60  perseant 	/*
    367  1.60  perseant 	 * Extend the file, if it is not large enough already.
    368  1.60  perseant 	 * XXX this is not exactly right, we don't know how much of the
    369  1.60  perseant 	 * XXX last block is actually used.  We hope that an inode will
    370  1.60  perseant 	 * XXX appear later to give the correct size.
    371  1.60  perseant 	 */
    372  1.60  perseant 	ip = VTOI(vp);
    373  1.60  perseant 	if (ip->i_ffs_size <= (lbn << fs->lfs_bshift)) {
    374  1.60  perseant 		if (lbn < NDADDR)
    375  1.60  perseant 			ip->i_ffs_size = (lbn << fs->lfs_bshift) +
    376  1.60  perseant 				(size - fs->lfs_fsize) + 1;
    377  1.60  perseant 		else
    378  1.60  perseant 			ip->i_ffs_size = (lbn << fs->lfs_bshift) + 1;
    379  1.60  perseant 	}
    380  1.60  perseant 
    381  1.60  perseant 	error = ufs_bmaparray(vp, lbn, &odaddr, &a[0], &num, NULL);
    382  1.60  perseant 	if (error) {
    383  1.60  perseant 		printf("update_meta: ufs_bmaparray returned %d\n", error);
    384  1.60  perseant 		vput(vp);
    385  1.60  perseant 		return error;
    386  1.60  perseant 	}
    387  1.60  perseant 	switch (num) {
    388  1.60  perseant 	    case 0:
    389  1.60  perseant 		ooff = ip->i_ffs_db[lbn];
    390  1.60  perseant 		if (ooff == UNWRITTEN)
    391  1.60  perseant 			ip->i_ffs_blocks += btodb(size);
    392  1.60  perseant 		ip->i_ffs_db[lbn] = ndaddr;
    393  1.60  perseant 		break;
    394  1.60  perseant 	    case 1:
    395  1.60  perseant 		ooff = ip->i_ffs_ib[a[0].in_off];
    396  1.60  perseant 		if (ooff == UNWRITTEN)
    397  1.60  perseant 			ip->i_ffs_blocks += btodb(size);
    398  1.60  perseant 		ip->i_ffs_ib[a[0].in_off] = ndaddr;
    399  1.60  perseant 		break;
    400  1.60  perseant 	    default:
    401  1.60  perseant 		ap = &a[num - 1];
    402  1.60  perseant 		if (bread(vp, ap->in_lbn, fs->lfs_bsize, NOCRED, &bp))
    403  1.60  perseant 			panic("update_meta: bread bno %d", ap->in_lbn);
    404  1.60  perseant 
    405  1.60  perseant 		ooff = ((ufs_daddr_t *)bp->b_data)[ap->in_off];
    406  1.60  perseant 		if (ooff == UNWRITTEN)
    407  1.60  perseant 			ip->i_ffs_blocks += btodb(size);
    408  1.60  perseant 		((ufs_daddr_t *)bp->b_data)[ap->in_off] = ndaddr;
    409  1.60  perseant 		(void) VOP_BWRITE(bp);
    410  1.60  perseant 	}
    411  1.60  perseant 	LFS_SET_UINO(ip, IN_CHANGE | IN_MODIFIED | IN_UPDATE);
    412  1.60  perseant 
    413  1.60  perseant 	/* Update segment usage information. */
    414  1.60  perseant 	if (odaddr > 0) {
    415  1.60  perseant 		LFS_SEGENTRY(sup, fs, datosn(fs, odaddr), bp);
    416  1.60  perseant #ifdef DIAGNOSTIC
    417  1.60  perseant 		if (sup->su_nbytes < size) {
    418  1.60  perseant 			panic("update_meta: negative bytes "
    419  1.60  perseant 			      "(segment %d short by %ld)\n",
    420  1.60  perseant 			      datosn(fs, odaddr), (long)size - sup->su_nbytes);
    421  1.60  perseant 			sup->su_nbytes = size;
    422  1.60  perseant 		}
    423  1.60  perseant #endif
    424  1.60  perseant 		sup->su_nbytes -= size;
    425  1.60  perseant 		VOP_BWRITE(bp);
    426  1.60  perseant 	}
    427  1.60  perseant 	LFS_SEGENTRY(sup, fs, datosn(fs, ndaddr), bp);
    428  1.60  perseant 	sup->su_nbytes += size;
    429  1.60  perseant 	VOP_BWRITE(bp);
    430  1.60  perseant 
    431  1.60  perseant 	/* Fix this so it can be released */
    432  1.60  perseant 	/* ip->i_lfs_effnblks = ip->i_ffs_blocks; */
    433  1.60  perseant 
    434  1.60  perseant 	/* Now look again to make sure it worked */
    435  1.60  perseant 	ufs_bmaparray(vp, lbn, &odaddr, &a[0], &num, NULL );
    436  1.60  perseant 	if (odaddr != ndaddr)
    437  1.60  perseant 		printf("update_meta: failed setting ino %d lbn %d to %x\n",
    438  1.60  perseant 		       ino, lbn, ndaddr);
    439  1.60  perseant 
    440  1.60  perseant 	vput(vp);
    441  1.60  perseant 	return 0;
    442  1.60  perseant }
    443  1.60  perseant 
    444  1.60  perseant static int
    445  1.60  perseant update_inoblk(struct lfs *fs, daddr_t offset, struct ucred *cred,
    446  1.60  perseant 	      struct proc *p)
    447  1.60  perseant {
    448  1.60  perseant 	struct vnode *devvp, *vp;
    449  1.60  perseant 	struct inode *ip;
    450  1.60  perseant 	struct dinode *dip;
    451  1.60  perseant 	struct buf *dbp, *ibp;
    452  1.60  perseant 	int error;
    453  1.60  perseant 	daddr_t daddr;
    454  1.60  perseant 	IFILE *ifp;
    455  1.60  perseant 	SEGUSE *sup;
    456  1.60  perseant 
    457  1.60  perseant 	devvp = VTOI(fs->lfs_ivnode)->i_devvp;
    458  1.60  perseant 
    459  1.60  perseant 	/*
    460  1.60  perseant 	 * Get the inode, update times and perms.
    461  1.60  perseant 	 * DO NOT update disk blocks, we do that separately.
    462  1.60  perseant 	 */
    463  1.60  perseant 	error = bread(devvp, offset, fs->lfs_bsize, cred, &dbp);
    464  1.60  perseant 	if (error) {
    465  1.60  perseant 		printf("update_inoblk: bread returned %d\n", error);
    466  1.60  perseant 		return error;
    467  1.60  perseant 	}
    468  1.60  perseant 	dip = ((struct dinode *)(dbp->b_data)) + INOPB(fs);
    469  1.60  perseant 	while(--dip >= (struct dinode *)dbp->b_data) {
    470  1.60  perseant 		if(dip->di_inumber > LFS_IFILE_INUM) {
    471  1.60  perseant 			/* printf("ino %d version %d\n", dip->di_inumber,
    472  1.60  perseant 			       dip->di_gen); */
    473  1.60  perseant 			error = lfs_rf_valloc(fs, dip->di_inumber, dip->di_gen,
    474  1.60  perseant 					      p, &vp);
    475  1.60  perseant 			if (error) {
    476  1.60  perseant 				printf("update_inoblk: lfs_rf_valloc returned %d\n", error);
    477  1.60  perseant 				continue;
    478  1.60  perseant 			}
    479  1.60  perseant 			ip = VTOI(vp);
    480  1.60  perseant 			if (dip->di_size != ip->i_ffs_size)
    481  1.60  perseant 				VOP_TRUNCATE(vp, dip->di_size, 0, NOCRED, p);
    482  1.60  perseant 			/* Get mode, link count, size, and times */
    483  1.60  perseant 			memcpy(&ip->i_din.ffs_din, dip,
    484  1.60  perseant 			       offsetof(struct dinode, di_db[0]));
    485  1.60  perseant 
    486  1.60  perseant 			/* Then the rest, except di_blocks */
    487  1.60  perseant 			ip->i_ffs_flags = dip->di_flags;
    488  1.60  perseant 			ip->i_ffs_gen = dip->di_gen;
    489  1.60  perseant 			ip->i_ffs_uid = dip->di_uid;
    490  1.60  perseant 			ip->i_ffs_gid = dip->di_gid;
    491  1.60  perseant 
    492  1.60  perseant 			ip->i_ffs_effnlink = dip->di_nlink;
    493  1.60  perseant 
    494  1.60  perseant 			LFS_SET_UINO(ip, IN_CHANGE | IN_MODIFIED | IN_UPDATE);
    495  1.60  perseant 
    496  1.60  perseant 			/* Re-initialize to get type right */
    497  1.60  perseant 			ufs_vinit(vp->v_mount, lfs_specop_p, lfs_fifoop_p,
    498  1.60  perseant 				  &vp);
    499  1.60  perseant 			vput(vp);
    500  1.60  perseant 
    501  1.60  perseant 			/* Record change in location */
    502  1.60  perseant 			LFS_IENTRY(ifp, fs, dip->di_inumber, ibp);
    503  1.60  perseant 			daddr = ifp->if_daddr;
    504  1.60  perseant 			ifp->if_daddr = dbp->b_blkno;
    505  1.60  perseant 			error = VOP_BWRITE(ibp); /* Ifile */
    506  1.60  perseant 			/* And do segment accounting */
    507  1.60  perseant 			if (datosn(fs, daddr) != datosn(fs, dbp->b_blkno)) {
    508  1.60  perseant 				if (daddr > 0) {
    509  1.60  perseant 					LFS_SEGENTRY(sup, fs, datosn(fs, daddr),
    510  1.60  perseant 						     ibp);
    511  1.60  perseant 					sup->su_nbytes -= DINODE_SIZE;
    512  1.60  perseant 					VOP_BWRITE(ibp);
    513  1.60  perseant 				}
    514  1.60  perseant 				LFS_SEGENTRY(sup, fs, datosn(fs, dbp->b_blkno),
    515  1.60  perseant 					     ibp);
    516  1.60  perseant 				sup->su_nbytes += DINODE_SIZE;
    517  1.60  perseant 				VOP_BWRITE(ibp);
    518  1.60  perseant 			}
    519  1.60  perseant 		}
    520  1.60  perseant 	}
    521  1.60  perseant 	dbp->b_flags |= B_AGE;
    522  1.60  perseant 	brelse(dbp);
    523  1.60  perseant 
    524  1.60  perseant 	return 0;
    525  1.60  perseant }
    526  1.60  perseant 
    527  1.60  perseant #define CHECK_CKSUM   0x0001  /* Check the checksum to make sure it's valid */
    528  1.60  perseant #define CHECK_UPDATE  0x0002  /* Update Ifile for new data blocks / inodes */
    529  1.60  perseant 
    530  1.60  perseant static daddr_t
    531  1.60  perseant check_segsum(struct lfs *fs, daddr_t offset,
    532  1.60  perseant 	     struct ucred *cred, int flags, int *pseg_flags, struct proc *p)
    533  1.60  perseant {
    534  1.60  perseant 	struct vnode *devvp;
    535  1.60  perseant 	struct buf *bp, *dbp;
    536  1.60  perseant 	int error, nblocks, ninos, i, j;
    537  1.60  perseant 	SEGSUM *ssp;
    538  1.60  perseant 	u_long *dp, *datap; /* XXX u_int32_t */
    539  1.60  perseant 	daddr_t *iaddr, oldoffset;
    540  1.60  perseant 	FINFO *fip;
    541  1.60  perseant 	SEGUSE *sup;
    542  1.60  perseant 	size_t size;
    543  1.60  perseant 
    544  1.60  perseant 	devvp = VTOI(fs->lfs_ivnode)->i_devvp;
    545  1.60  perseant 	/*
    546  1.60  perseant 	 * If the segment has a superblock and we're at the top
    547  1.60  perseant 	 * of the segment, skip the superblock.
    548  1.60  perseant 	 */
    549  1.60  perseant 	if(sntoda(fs, datosn(fs, offset)) == offset) {
    550  1.60  perseant        		LFS_SEGENTRY(sup, fs, datosn(fs, offset), bp);
    551  1.60  perseant        		if(sup->su_flags & SEGUSE_SUPERBLOCK)
    552  1.60  perseant 			offset += btodb(LFS_SBPAD);
    553  1.60  perseant        		brelse(bp);
    554  1.60  perseant 	}
    555  1.60  perseant 
    556  1.60  perseant 	/* Read in the segment summary */
    557  1.60  perseant 	error = bread(devvp, offset, LFS_SUMMARY_SIZE, cred, &bp);
    558  1.60  perseant 	if(error)
    559  1.60  perseant 		return -1;
    560  1.60  perseant 
    561  1.60  perseant 	/* Check summary checksum */
    562  1.60  perseant 	ssp = (SEGSUM *)bp->b_data;
    563  1.60  perseant 	if(flags & CHECK_CKSUM) {
    564  1.60  perseant 		if(ssp->ss_sumsum != cksum(&ssp->ss_datasum,
    565  1.60  perseant 					   LFS_SUMMARY_SIZE -
    566  1.60  perseant 					   sizeof(ssp->ss_sumsum))) {
    567  1.60  perseant #ifdef DEBUG_LFS_RFW
    568  1.60  perseant 			printf("Sumsum error at 0x%x\n", offset);
    569  1.60  perseant #endif
    570  1.60  perseant 			offset = -1;
    571  1.60  perseant 			goto err1;
    572  1.60  perseant 		}
    573  1.60  perseant 		if (ssp->ss_nfinfo == 0 && ssp->ss_ninos == 0) {
    574  1.60  perseant #ifdef DEBUG_LFS_RFW
    575  1.60  perseant 			printf("Empty pseg at 0x%x\n", offset);
    576  1.60  perseant #endif
    577  1.60  perseant 			offset = -1;
    578  1.60  perseant 			goto err1;
    579  1.60  perseant 		}
    580  1.60  perseant 		if (ssp->ss_create < fs->lfs_tstamp) {
    581  1.60  perseant #ifdef DEBUG_LFS_RFW
    582  1.60  perseant 			printf("Old data at 0x%x\n", offset);
    583  1.60  perseant #endif
    584  1.60  perseant 			offset = -1;
    585  1.60  perseant 			goto err1;
    586  1.60  perseant 		}
    587  1.60  perseant 	}
    588  1.60  perseant 	if(pseg_flags)
    589  1.60  perseant 		*pseg_flags = ssp->ss_flags;
    590  1.60  perseant 	oldoffset = offset;
    591  1.60  perseant 	offset += btodb(LFS_SUMMARY_SIZE);
    592  1.60  perseant 
    593  1.60  perseant 	ninos = howmany(ssp->ss_ninos, INOPB(fs));
    594  1.60  perseant 	iaddr = (daddr_t *)(bp->b_data + LFS_SUMMARY_SIZE - sizeof(daddr_t));
    595  1.60  perseant 	if(flags & CHECK_CKSUM) {
    596  1.60  perseant 		/* Count blocks */
    597  1.60  perseant 		nblocks = 0;
    598  1.60  perseant 		fip = (FINFO *)(bp->b_data + sizeof(SEGSUM));
    599  1.60  perseant 		for(i = 0; i < ssp->ss_nfinfo; ++i) {
    600  1.60  perseant 			nblocks += fip->fi_nblocks;
    601  1.60  perseant 			if(fip->fi_nblocks <= 0)
    602  1.60  perseant 				break;
    603  1.60  perseant 			fip = (FINFO *)(((char *)fip) + sizeof(FINFO) +
    604  1.60  perseant 					(fip->fi_nblocks - 1) *
    605  1.60  perseant 					sizeof(ufs_daddr_t));
    606  1.60  perseant 		}
    607  1.60  perseant 		nblocks += ninos;
    608  1.60  perseant 		/* Create the sum array */
    609  1.60  perseant 		datap = dp = (u_long *)malloc(nblocks * sizeof(u_long),
    610  1.60  perseant 					      M_SEGMENT, M_WAITOK);
    611  1.60  perseant 	}
    612  1.60  perseant 
    613  1.60  perseant 	/* Handle individual blocks */
    614  1.60  perseant 	fip = (FINFO *)(bp->b_data + sizeof(SEGSUM));
    615  1.60  perseant 	for(i = 0; i < ssp->ss_nfinfo || ninos; ++i) {
    616  1.60  perseant 		/* Inode block? */
    617  1.60  perseant 		if(ninos && *iaddr == offset) {
    618  1.60  perseant 			if(flags & CHECK_CKSUM) {
    619  1.60  perseant 				/* Read in the head and add to the buffer */
    620  1.60  perseant 				error = bread(devvp, offset, fs->lfs_bsize,
    621  1.60  perseant 					      cred, &dbp);
    622  1.60  perseant 				if(error) {
    623  1.60  perseant 					offset = -1;
    624  1.60  perseant 					goto err2;
    625  1.60  perseant 				}
    626  1.60  perseant 				(*dp++) = ((u_long *)(dbp->b_data))[0];
    627  1.60  perseant 				dbp->b_flags |= B_AGE;
    628  1.60  perseant 				brelse(dbp);
    629  1.60  perseant 			}
    630  1.60  perseant 			if(flags & CHECK_UPDATE) {
    631  1.60  perseant 				if ((error = update_inoblk(fs, offset, cred, p))
    632  1.60  perseant 				    != 0) {
    633  1.60  perseant 					offset = -1;
    634  1.60  perseant 					goto err2;
    635  1.60  perseant 				}
    636  1.60  perseant 			}
    637  1.60  perseant 			offset += fsbtodb(fs,1);
    638  1.60  perseant 			--iaddr;
    639  1.60  perseant 			--ninos;
    640  1.60  perseant 			--i; /* compensate */
    641  1.60  perseant 			continue;
    642  1.60  perseant 		}
    643  1.60  perseant 		/* printf("check: blocks from ino %d version %d\n",
    644  1.60  perseant 		       fip->fi_ino, fip->fi_version); */
    645  1.60  perseant 		size = fs->lfs_bsize;
    646  1.60  perseant 		for(j = 0; j < fip->fi_nblocks; ++j) {
    647  1.60  perseant 			if (j == fip->fi_nblocks - 1)
    648  1.60  perseant 				size = fip->fi_lastlength;
    649  1.60  perseant 			if(flags & CHECK_CKSUM) {
    650  1.60  perseant 				error = bread(devvp, offset, size, cred, &dbp);
    651  1.60  perseant 				if(error) {
    652  1.60  perseant 					offset = -1;
    653  1.60  perseant 					goto err2;
    654  1.60  perseant 				}
    655  1.60  perseant 				(*dp++) = ((u_long *)(dbp->b_data))[0];
    656  1.60  perseant 				dbp->b_flags |= B_AGE;
    657  1.60  perseant 				brelse(dbp);
    658  1.60  perseant 			}
    659  1.60  perseant 			/* Account for and update any direct blocks */
    660  1.60  perseant 			if((flags & CHECK_UPDATE) &&
    661  1.60  perseant 			   fip->fi_ino > LFS_IFILE_INUM &&
    662  1.60  perseant 			   fip->fi_blocks[j] >= 0) {
    663  1.60  perseant 				update_meta(fs, fip->fi_ino, fip->fi_version,
    664  1.60  perseant 					    fip->fi_blocks[j], offset, size, p);
    665  1.60  perseant 			}
    666  1.60  perseant 			offset += btodb(size);
    667  1.60  perseant 		}
    668  1.60  perseant 		fip = (FINFO *)(((char *)fip) + sizeof(FINFO)
    669  1.60  perseant 				+ (fip->fi_nblocks - 1) * sizeof(ufs_daddr_t));
    670  1.60  perseant 	}
    671  1.60  perseant 	/* Checksum the array, compare */
    672  1.60  perseant 	if((flags & CHECK_CKSUM) &&
    673  1.60  perseant 	   ssp->ss_datasum != cksum(datap, nblocks * sizeof(u_long)))
    674  1.60  perseant 	{
    675  1.60  perseant 		printf("Datasum error at 0x%x (wanted %x got %x)\n", offset,
    676  1.60  perseant 		       ssp->ss_datasum, cksum(datap, nblocks *
    677  1.60  perseant 					      sizeof(u_long)));
    678  1.60  perseant 		offset = -1;
    679  1.60  perseant 		goto err2;
    680  1.60  perseant 	}
    681  1.60  perseant 
    682  1.60  perseant 	/* If we're at the end of the segment, move to the next */
    683  1.60  perseant 	if(datosn(fs, offset + btodb(LFS_SUMMARY_SIZE + fs->lfs_bsize)) !=
    684  1.60  perseant 	   datosn(fs, offset)) {
    685  1.60  perseant 		if (datosn(fs, offset) == datosn(fs, ssp->ss_next)) {
    686  1.60  perseant 			offset = -1;
    687  1.60  perseant 			goto err2;
    688  1.60  perseant 		}
    689  1.60  perseant 		offset = ssp->ss_next;
    690  1.60  perseant #ifdef DEBUG_LFS_RFW
    691  1.60  perseant 		printf("LFS roll forward: moving on to offset 0x%x "
    692  1.60  perseant 		       " -> segment %d\n", offset, datosn(fs,offset));
    693  1.60  perseant #endif
    694  1.60  perseant 	}
    695  1.60  perseant 
    696  1.60  perseant 	if (flags & CHECK_UPDATE) {
    697  1.60  perseant 		fs->lfs_avail -= (offset - oldoffset);
    698  1.60  perseant 		/* Don't clog the buffer queue */
    699  1.60  perseant 		if (locked_queue_count > LFS_MAX_BUFS ||
    700  1.60  perseant 		    locked_queue_bytes > LFS_MAX_BYTES) {
    701  1.60  perseant 			++fs->lfs_writer;
    702  1.60  perseant 			lfs_flush(fs, SEGM_CKP);
    703  1.60  perseant 			if(--fs->lfs_writer==0)
    704  1.60  perseant 				wakeup(&fs->lfs_dirops);
    705  1.60  perseant 		}
    706  1.60  perseant 	}
    707  1.60  perseant 
    708  1.60  perseant     err2:
    709  1.60  perseant 	if(flags & CHECK_CKSUM)
    710  1.60  perseant 		free(datap, M_SEGMENT);
    711  1.60  perseant     err1:
    712  1.60  perseant 	bp->b_flags |= B_AGE;
    713  1.60  perseant 	brelse(bp);
    714  1.60  perseant 
    715  1.60  perseant 	return offset;
    716  1.60  perseant }
    717  1.60  perseant #endif /* LFS_DO_ROLLFORWARD */
    718  1.60  perseant 
    719   1.1   mycroft /*
    720   1.1   mycroft  * Common code for mount and mountroot
    721   1.1   mycroft  * LFS specific
    722   1.1   mycroft  */
    723   1.1   mycroft int
    724   1.1   mycroft lfs_mountfs(devvp, mp, p)
    725  1.48  augustss 	struct vnode *devvp;
    726   1.1   mycroft 	struct mount *mp;
    727   1.1   mycroft 	struct proc *p;
    728   1.1   mycroft {
    729   1.1   mycroft 	extern struct vnode *rootvp;
    730  1.60  perseant 	struct dlfs *tdfs, *dfs, *adfs;
    731  1.48  augustss 	struct lfs *fs;
    732  1.48  augustss 	struct ufsmount *ump;
    733   1.1   mycroft 	struct vnode *vp;
    734  1.28  perseant 	struct buf *bp, *abp;
    735   1.1   mycroft 	struct partinfo dpart;
    736   1.1   mycroft 	dev_t dev;
    737   1.1   mycroft 	int error, i, ronly, size;
    738   1.3   mycroft 	struct ucred *cred;
    739  1.59  perseant 	CLEANERINFO *cip;
    740  1.30  perseant         SEGUSE *sup;
    741  1.60  perseant #ifdef LFS_DO_ROLLFORWARD
    742  1.60  perseant 	int flags, dirty;
    743  1.60  perseant 	daddr_t offset, oldoffset, lastgoodpseg;
    744  1.60  perseant 	int sn, curseg;
    745  1.60  perseant #endif
    746   1.1   mycroft 
    747   1.3   mycroft 	cred = p ? p->p_ucred : NOCRED;
    748   1.1   mycroft 	/*
    749   1.1   mycroft 	 * Disallow multiple mounts of the same device.
    750   1.1   mycroft 	 * Disallow mounting of a device that is currently in use
    751   1.1   mycroft 	 * (except for root, which might share swap device for miniroot).
    752   1.1   mycroft 	 * Flush out any old buffers remaining from a previous use.
    753   1.1   mycroft 	 */
    754  1.10  christos 	if ((error = vfs_mountedon(devvp)) != 0)
    755   1.1   mycroft 		return (error);
    756   1.1   mycroft 	if (vcount(devvp) > 1 && devvp != rootvp)
    757   1.1   mycroft 		return (EBUSY);
    758  1.10  christos 	if ((error = vinvalbuf(devvp, V_SAVE, cred, p, 0, 0)) != 0)
    759   1.1   mycroft 		return (error);
    760   1.1   mycroft 
    761   1.1   mycroft 	ronly = (mp->mnt_flag & MNT_RDONLY) != 0;
    762  1.10  christos 	error = VOP_OPEN(devvp, ronly ? FREAD : FREAD|FWRITE, FSCRED, p);
    763  1.10  christos 	if (error)
    764   1.1   mycroft 		return (error);
    765   1.3   mycroft 	if (VOP_IOCTL(devvp, DIOCGPART, (caddr_t)&dpart, FREAD, cred, p) != 0)
    766   1.1   mycroft 		size = DEV_BSIZE;
    767  1.29   mycroft 	else
    768   1.1   mycroft 		size = dpart.disklab->d_secsize;
    769   1.1   mycroft 
    770   1.1   mycroft 	/* Don't free random space on error. */
    771   1.1   mycroft 	bp = NULL;
    772  1.50  perseant 	abp = NULL;
    773   1.1   mycroft 	ump = NULL;
    774   1.1   mycroft 
    775   1.1   mycroft 	/* Read in the superblock. */
    776  1.10  christos 	error = bread(devvp, LFS_LABELPAD / size, LFS_SBPAD, cred, &bp);
    777  1.10  christos 	if (error)
    778   1.1   mycroft 		goto out;
    779  1.24        pk 	dfs = (struct dlfs *)bp->b_data;
    780   1.1   mycroft 
    781  1.50  perseant 	/* Check the basics. */
    782  1.50  perseant 	if (dfs->dlfs_magic != LFS_MAGIC || dfs->dlfs_bsize > MAXBSIZE ||
    783  1.50  perseant 	    dfs->dlfs_version > LFS_VERSION ||
    784  1.50  perseant 	    dfs->dlfs_bsize < sizeof(struct dlfs)) {
    785  1.50  perseant 		error = EINVAL;		/* XXX needs translation */
    786  1.50  perseant 		goto out;
    787  1.50  perseant 	}
    788  1.50  perseant 
    789  1.26  perseant 	/*
    790  1.26  perseant 	 * Check the second superblock to see which is newer; then mount
    791  1.26  perseant 	 * using the older of the two.  This is necessary to ensure that
    792  1.26  perseant 	 * the filesystem is valid if it was not unmounted cleanly.
    793  1.26  perseant 	 */
    794  1.60  perseant 
    795  1.50  perseant 	if (dfs->dlfs_sboffs[1] &&
    796  1.50  perseant 	    dfs->dlfs_sboffs[1]-(LFS_LABELPAD/size) > LFS_SBPAD/size)
    797  1.50  perseant 	{
    798  1.50  perseant 		error = bread(devvp, dfs->dlfs_sboffs[1], LFS_SBPAD, cred, &abp);
    799  1.50  perseant 		if (error)
    800  1.50  perseant 			goto out;
    801  1.50  perseant 		adfs = (struct dlfs *)abp->b_data;
    802  1.50  perseant 
    803  1.50  perseant 		if (adfs->dlfs_tstamp < dfs->dlfs_tstamp) /* XXX 1s? */
    804  1.60  perseant 			tdfs = adfs;
    805  1.60  perseant 		else
    806  1.60  perseant 			tdfs = dfs;
    807  1.60  perseant 
    808  1.60  perseant 		/* Check the basics. */
    809  1.60  perseant 		if (tdfs->dlfs_magic != LFS_MAGIC ||
    810  1.60  perseant 		    tdfs->dlfs_bsize > MAXBSIZE ||
    811  1.60  perseant 	    	    tdfs->dlfs_version > LFS_VERSION ||
    812  1.60  perseant 	    	    tdfs->dlfs_bsize < sizeof(struct dlfs)) {
    813  1.60  perseant 			error = EINVAL;		/* XXX needs translation */
    814  1.60  perseant 			goto out;
    815  1.60  perseant 		}
    816  1.50  perseant 	} else {
    817  1.50  perseant 		printf("lfs_mountfs: invalid alt superblock daddr=0x%x\n",
    818  1.50  perseant 			dfs->dlfs_sboffs[1]);
    819  1.50  perseant 		error = EINVAL;
    820   1.1   mycroft 		goto out;
    821   1.1   mycroft 	}
    822   1.1   mycroft 
    823   1.1   mycroft 	/* Allocate the mount structure, copy the superblock into it. */
    824  1.29   mycroft 	fs = malloc(sizeof(struct lfs), M_UFSMNT, M_WAITOK);
    825  1.60  perseant 	memcpy(&fs->lfs_dlfs, tdfs, sizeof(struct dlfs));
    826  1.60  perseant 
    827  1.60  perseant #ifdef LFS_DO_ROLLFORWARD
    828  1.60  perseant 	/* Before rolling forward, lock so vget will sleep for other procs */
    829  1.60  perseant 	fs->lfs_flags = LFS_NOTYET;
    830  1.60  perseant 	fs->lfs_rfpid = p->p_pid;
    831  1.60  perseant #else
    832  1.60  perseant 	fs->lfs_flags = 0;
    833  1.60  perseant #endif
    834  1.60  perseant 
    835  1.29   mycroft 	ump = malloc(sizeof *ump, M_UFSMNT, M_WAITOK);
    836  1.29   mycroft 	memset((caddr_t)ump, 0, sizeof *ump);
    837  1.29   mycroft 	ump->um_lfs = fs;
    838  1.60  perseant 	if (sizeof(struct lfs) < LFS_SBPAD) {			/* XXX why? */
    839   1.1   mycroft 		bp->b_flags |= B_INVAL;
    840  1.60  perseant 		abp->b_flags |= B_INVAL;
    841  1.60  perseant 	}
    842   1.1   mycroft 	brelse(bp);
    843   1.1   mycroft 	bp = NULL;
    844  1.26  perseant 	brelse(abp);
    845  1.26  perseant 	abp = NULL;
    846   1.1   mycroft 
    847   1.1   mycroft 	/* Set up the I/O information */
    848   1.1   mycroft 	fs->lfs_iocount = 0;
    849  1.34  perseant 	fs->lfs_diropwait = 0;
    850  1.26  perseant 	fs->lfs_activesb = 0;
    851  1.57  perseant 	fs->lfs_uinodes = 0;
    852  1.58  perseant 	fs->lfs_ravail = 0;
    853  1.26  perseant #ifdef LFS_CANNOT_ROLLFW
    854  1.51   thorpej 	fs->lfs_sbactive = 0;
    855  1.26  perseant #endif
    856  1.26  perseant #ifdef LFS_TRACK_IOS
    857  1.29   mycroft 	for (i=0;i<LFS_THROTTLE;i++)
    858  1.26  perseant 		fs->lfs_pending[i] = LFS_UNUSED_DADDR;
    859  1.26  perseant #endif
    860   1.1   mycroft 
    861   1.1   mycroft 	/* Set up the ifile and lock aflags */
    862   1.1   mycroft 	fs->lfs_doifile = 0;
    863   1.1   mycroft 	fs->lfs_writer = 0;
    864   1.1   mycroft 	fs->lfs_dirops = 0;
    865  1.52  perseant 	fs->lfs_nadirop = 0;
    866   1.1   mycroft 	fs->lfs_seglock = 0;
    867  1.46  perseant 	lockinit(&fs->lfs_freelock, PINOD, "lfs_freelock", 0, 0);
    868   1.1   mycroft 
    869   1.1   mycroft 	/* Set the file system readonly/modify bits. */
    870   1.1   mycroft 	fs->lfs_ronly = ronly;
    871   1.1   mycroft 	if (ronly == 0)
    872   1.1   mycroft 		fs->lfs_fmod = 1;
    873   1.1   mycroft 
    874   1.1   mycroft 	/* Initialize the mount structure. */
    875   1.1   mycroft 	dev = devvp->v_rdev;
    876   1.1   mycroft 	mp->mnt_data = (qaddr_t)ump;
    877   1.1   mycroft 	mp->mnt_stat.f_fsid.val[0] = (long)dev;
    878   1.1   mycroft 	mp->mnt_stat.f_fsid.val[1] = makefstype(MOUNT_LFS);
    879  1.49  perseant 	mp->mnt_stat.f_iosize = fs->lfs_bsize;
    880   1.1   mycroft 	mp->mnt_maxsymlinklen = fs->lfs_maxsymlinklen;
    881   1.1   mycroft 	mp->mnt_flag |= MNT_LOCAL;
    882  1.18    bouyer 	ump->um_flags = 0;
    883   1.1   mycroft 	ump->um_mountp = mp;
    884   1.1   mycroft 	ump->um_dev = dev;
    885   1.1   mycroft 	ump->um_devvp = devvp;
    886   1.1   mycroft 	ump->um_bptrtodb = 0;
    887   1.1   mycroft 	ump->um_seqinc = 1 << fs->lfs_fsbtodb;
    888   1.1   mycroft 	ump->um_nindir = fs->lfs_nindir;
    889  1.61       chs 	ump->um_lognindir = ffs(fs->lfs_nindir) - 1;
    890   1.1   mycroft 	for (i = 0; i < MAXQUOTAS; i++)
    891   1.1   mycroft 		ump->um_quotas[i] = NULLVP;
    892  1.44      fvdl 	devvp->v_specmountpoint = mp;
    893   1.1   mycroft 
    894   1.1   mycroft 	/*
    895   1.1   mycroft 	 * We use the ifile vnode for almost every operation.  Instead of
    896   1.1   mycroft 	 * retrieving it from the hash table each time we retrieve it here,
    897   1.1   mycroft 	 * artificially increment the reference count and keep a pointer
    898   1.1   mycroft 	 * to it in the incore copy of the superblock.
    899   1.1   mycroft 	 */
    900  1.10  christos 	if ((error = VFS_VGET(mp, LFS_IFILE_INUM, &vp)) != 0)
    901   1.1   mycroft 		goto out;
    902   1.1   mycroft 	fs->lfs_ivnode = vp;
    903   1.1   mycroft 	VREF(vp);
    904   1.1   mycroft 	vput(vp);
    905  1.30  perseant 
    906  1.60  perseant #ifdef LFS_DO_ROLLFORWARD
    907  1.60  perseant 	/*
    908  1.60  perseant 	 * Roll forward.
    909  1.60  perseant 	 */
    910  1.60  perseant 	/*
    911  1.60  perseant 	 * Phase I:
    912  1.60  perseant 	 * Find the address of the last good partial segment that was written
    913  1.60  perseant 	 * after the checkpoint.  Mark the segments in question dirty, so
    914  1.60  perseant 	 * they won't be reallocated.
    915  1.60  perseant 	 */
    916  1.60  perseant 	lastgoodpseg = oldoffset = offset = fs->lfs_offset;
    917  1.60  perseant 	flags = 0x0;
    918  1.60  perseant #ifdef DEBUG_LFS_RFW
    919  1.60  perseant 	printf("LFS roll forward phase 1: starting at offset 0x%x\n", offset);
    920  1.60  perseant #endif
    921  1.60  perseant 	LFS_SEGENTRY(sup, fs, datosn(fs, offset), bp);
    922  1.60  perseant 	if (!(sup->su_flags & SEGUSE_DIRTY))
    923  1.60  perseant 		--fs->lfs_nclean;
    924  1.60  perseant 	sup->su_flags |= SEGUSE_DIRTY;
    925  1.60  perseant 	(void) VOP_BWRITE(bp);
    926  1.60  perseant 	while ((offset = check_segsum(fs, offset, cred, CHECK_CKSUM, &flags,
    927  1.60  perseant 				      p)) > 0) {
    928  1.60  perseant 		if(sntoda(fs, oldoffset) != sntoda(fs, offset)) {
    929  1.60  perseant         		LFS_SEGENTRY(sup, fs, datosn(fs, oldoffset), bp);
    930  1.60  perseant 			if (!(sup->su_flags & SEGUSE_DIRTY))
    931  1.60  perseant 				--fs->lfs_nclean;
    932  1.60  perseant         		sup->su_flags |= SEGUSE_DIRTY;
    933  1.60  perseant         		(void) VOP_BWRITE(bp);
    934  1.60  perseant 		}
    935  1.60  perseant 
    936  1.60  perseant #ifdef DEBUG_LFS_RFW
    937  1.60  perseant 		printf("LFS roll forward phase 1: offset=0x%x\n", offset);
    938  1.60  perseant 		if(flags & SS_DIROP) {
    939  1.60  perseant 			printf("lfs_mountfs: dirops at 0x%x\n", oldoffset);
    940  1.60  perseant 			if(!(flags & SS_CONT))
    941  1.60  perseant 				printf("lfs_mountfs: dirops end at 0x%x\n",
    942  1.60  perseant 				       oldoffset);
    943  1.60  perseant 		}
    944  1.60  perseant #endif
    945  1.60  perseant 		if(!(flags & SS_CONT))
    946  1.60  perseant 			lastgoodpseg = offset;
    947  1.60  perseant 		oldoffset = offset;
    948  1.60  perseant 	}
    949  1.60  perseant #ifdef DEBUG_LFS_RFW
    950  1.60  perseant 	if (flags & SS_CONT) {
    951  1.60  perseant 		printf("LFS roll forward: warning: incomplete dirops discarded\n");
    952  1.60  perseant 	}
    953  1.60  perseant 	printf("LFS roll forward phase 1: completed: lastgoodpseg=0x%x\n",
    954  1.60  perseant 	       lastgoodpseg);
    955  1.60  perseant #endif
    956  1.60  perseant 
    957  1.60  perseant 	/* Don't accidentally overwrite what we're trying to preserve */
    958  1.60  perseant 	offset = fs->lfs_offset;
    959  1.60  perseant 	fs->lfs_offset = lastgoodpseg;
    960  1.60  perseant 	fs->lfs_curseg = sntoda(fs, datosn(fs, fs->lfs_offset));
    961  1.60  perseant 	for (sn = curseg = datosn(fs, fs->lfs_curseg);;) {
    962  1.60  perseant 		sn = (sn + 1) % fs->lfs_nseg;
    963  1.60  perseant 		if (sn == curseg)
    964  1.60  perseant 			panic("lfs_mountfs: no clean segments");
    965  1.60  perseant 		LFS_SEGENTRY(sup, fs, sn, bp);
    966  1.60  perseant 		dirty = (sup->su_flags & SEGUSE_DIRTY);
    967  1.60  perseant 		brelse(bp);
    968  1.60  perseant 		if (!dirty)
    969  1.60  perseant 			break;
    970  1.60  perseant 	}
    971  1.60  perseant 	fs->lfs_nextseg = sntoda(fs, sn);
    972  1.60  perseant 
    973  1.60  perseant 	/*
    974  1.60  perseant 	 * Phase II: Roll forward from the first superblock.
    975  1.60  perseant 	 */
    976  1.60  perseant 	while (offset != lastgoodpseg) {
    977  1.60  perseant #ifdef DEBUG_LFS_RFW
    978  1.60  perseant 		printf("LFS roll forward phase 2: 0x%x\n", offset);
    979  1.60  perseant #endif
    980  1.60  perseant 		oldoffset = offset;
    981  1.60  perseant 		offset = check_segsum(fs, offset, cred, CHECK_UPDATE, NULL, p);
    982  1.60  perseant 	}
    983  1.60  perseant 
    984  1.60  perseant 	/*
    985  1.60  perseant 	 * Finish: flush our changes to disk.
    986  1.60  perseant 	 */
    987  1.60  perseant 	lfs_segwrite(fs->lfs_ivnode->v_mount, SEGM_CKP | SEGM_SYNC);
    988  1.60  perseant 
    989  1.60  perseant #ifdef DEBUG_LFS_RFW
    990  1.60  perseant 	printf("LFS roll forward complete\n");
    991  1.60  perseant #endif
    992  1.60  perseant 	/* Allow vget now that roll-forward is complete */
    993  1.60  perseant 	fs->lfs_flags &= ~(LFS_NOTYET);
    994  1.60  perseant 	wakeup(&fs->lfs_flags);
    995  1.60  perseant #endif /* LFS_DO_ROLLFORWARD */
    996  1.60  perseant 
    997  1.30  perseant 	/*
    998  1.59  perseant 	 * Initialize the ifile cleaner info with information from
    999  1.59  perseant 	 * the superblock.
   1000  1.59  perseant 	 */
   1001  1.59  perseant 	LFS_CLEANERINFO(cip, fs, bp);
   1002  1.59  perseant 	cip->clean = fs->lfs_nclean;
   1003  1.59  perseant 	cip->dirty = fs->lfs_nseg - fs->lfs_nclean;
   1004  1.59  perseant 	cip->avail = fs->lfs_avail;
   1005  1.59  perseant 	cip->bfree = fs->lfs_bfree;
   1006  1.59  perseant 	(void) VOP_BWRITE(bp); /* Ifile */
   1007  1.59  perseant 
   1008  1.59  perseant 	/*
   1009  1.30  perseant 	 * Mark the current segment as ACTIVE, since we're going to
   1010  1.30  perseant 	 * be writing to it.
   1011  1.30  perseant 	 */
   1012  1.30  perseant         LFS_SEGENTRY(sup, fs, datosn(fs, fs->lfs_offset), bp);
   1013  1.30  perseant         sup->su_flags |= SEGUSE_DIRTY | SEGUSE_ACTIVE;
   1014  1.59  perseant         (void) VOP_BWRITE(bp); /* Ifile */
   1015   1.1   mycroft 
   1016   1.1   mycroft 	return (0);
   1017   1.1   mycroft out:
   1018   1.1   mycroft 	if (bp)
   1019   1.1   mycroft 		brelse(bp);
   1020  1.26  perseant 	if (abp)
   1021  1.26  perseant 		brelse(abp);
   1022  1.39  wrstuden 	vn_lock(devvp, LK_EXCLUSIVE | LK_RETRY);
   1023   1.3   mycroft 	(void)VOP_CLOSE(devvp, ronly ? FREAD : FREAD|FWRITE, cred, p);
   1024  1.39  wrstuden 	VOP_UNLOCK(devvp, 0);
   1025   1.1   mycroft 	if (ump) {
   1026   1.1   mycroft 		free(ump->um_lfs, M_UFSMNT);
   1027   1.1   mycroft 		free(ump, M_UFSMNT);
   1028   1.1   mycroft 		mp->mnt_data = (qaddr_t)0;
   1029   1.1   mycroft 	}
   1030   1.1   mycroft 	return (error);
   1031   1.1   mycroft }
   1032   1.1   mycroft 
   1033   1.1   mycroft /*
   1034   1.1   mycroft  * unmount system call
   1035   1.1   mycroft  */
   1036  1.10  christos int
   1037   1.1   mycroft lfs_unmount(mp, mntflags, p)
   1038   1.1   mycroft 	struct mount *mp;
   1039   1.1   mycroft 	int mntflags;
   1040   1.1   mycroft 	struct proc *p;
   1041   1.1   mycroft {
   1042  1.48  augustss 	struct ufsmount *ump;
   1043  1.48  augustss 	struct lfs *fs;
   1044  1.11        pk 	int error, flags, ronly;
   1045  1.26  perseant 	extern int lfs_allclean_wakeup;
   1046   1.1   mycroft 
   1047   1.1   mycroft 	flags = 0;
   1048   1.5   mycroft 	if (mntflags & MNT_FORCE)
   1049   1.1   mycroft 		flags |= FORCECLOSE;
   1050   1.1   mycroft 
   1051   1.1   mycroft 	ump = VFSTOUFS(mp);
   1052   1.1   mycroft 	fs = ump->um_lfs;
   1053   1.1   mycroft #ifdef QUOTA
   1054   1.1   mycroft 	if (mp->mnt_flag & MNT_QUOTA) {
   1055  1.11        pk 		int i;
   1056  1.10  christos 		error = vflush(mp, fs->lfs_ivnode, SKIPSYSTEM|flags);
   1057  1.10  christos 		if (error)
   1058   1.1   mycroft 			return (error);
   1059   1.1   mycroft 		for (i = 0; i < MAXQUOTAS; i++) {
   1060   1.1   mycroft 			if (ump->um_quotas[i] == NULLVP)
   1061   1.1   mycroft 				continue;
   1062   1.1   mycroft 			quotaoff(p, mp, i);
   1063   1.1   mycroft 		}
   1064   1.1   mycroft 		/*
   1065   1.1   mycroft 		 * Here we fall through to vflush again to ensure
   1066   1.1   mycroft 		 * that we have gotten rid of all the system vnodes.
   1067   1.1   mycroft 		 */
   1068   1.1   mycroft 	}
   1069   1.1   mycroft #endif
   1070  1.10  christos 	if ((error = vflush(mp, fs->lfs_ivnode, flags)) != 0)
   1071   1.1   mycroft 		return (error);
   1072   1.1   mycroft 	fs->lfs_clean = 1;
   1073  1.10  christos 	if ((error = VFS_SYNC(mp, 1, p->p_ucred, p)) != 0)
   1074   1.1   mycroft 		return (error);
   1075   1.1   mycroft 	if (fs->lfs_ivnode->v_dirtyblkhd.lh_first)
   1076   1.1   mycroft 		panic("lfs_unmount: still dirty blocks on ifile vnode\n");
   1077   1.1   mycroft 	vrele(fs->lfs_ivnode);
   1078   1.1   mycroft 	vgone(fs->lfs_ivnode);
   1079   1.1   mycroft 
   1080   1.1   mycroft 	ronly = !fs->lfs_ronly;
   1081  1.40     enami 	if (ump->um_devvp->v_type != VBAD)
   1082  1.44      fvdl 		ump->um_devvp->v_specmountpoint = NULL;
   1083  1.39  wrstuden 	vn_lock(ump->um_devvp, LK_EXCLUSIVE | LK_RETRY);
   1084   1.1   mycroft 	error = VOP_CLOSE(ump->um_devvp,
   1085   1.1   mycroft 	    ronly ? FREAD : FREAD|FWRITE, NOCRED, p);
   1086  1.39  wrstuden 	vput(ump->um_devvp);
   1087  1.26  perseant 
   1088  1.26  perseant 	/* XXX KS - wake up the cleaner so it can die */
   1089  1.26  perseant 	wakeup(&fs->lfs_nextseg);
   1090  1.26  perseant 	wakeup(&lfs_allclean_wakeup);
   1091  1.26  perseant 
   1092   1.1   mycroft 	free(fs, M_UFSMNT);
   1093   1.1   mycroft 	free(ump, M_UFSMNT);
   1094   1.1   mycroft 	mp->mnt_data = (qaddr_t)0;
   1095   1.1   mycroft 	mp->mnt_flag &= ~MNT_LOCAL;
   1096   1.1   mycroft 	return (error);
   1097   1.1   mycroft }
   1098   1.1   mycroft 
   1099   1.1   mycroft /*
   1100   1.1   mycroft  * Get file system statistics.
   1101   1.1   mycroft  */
   1102  1.10  christos int
   1103   1.1   mycroft lfs_statfs(mp, sbp, p)
   1104   1.1   mycroft 	struct mount *mp;
   1105  1.48  augustss 	struct statfs *sbp;
   1106   1.1   mycroft 	struct proc *p;
   1107   1.1   mycroft {
   1108  1.48  augustss 	struct lfs *fs;
   1109  1.48  augustss 	struct ufsmount *ump;
   1110   1.1   mycroft 
   1111   1.1   mycroft 	ump = VFSTOUFS(mp);
   1112   1.1   mycroft 	fs = ump->um_lfs;
   1113   1.1   mycroft 	if (fs->lfs_magic != LFS_MAGIC)
   1114   1.1   mycroft 		panic("lfs_statfs: magic");
   1115  1.53  perseant 
   1116   1.1   mycroft 	sbp->f_type = 0;
   1117  1.26  perseant 	sbp->f_bsize = fs->lfs_fsize;
   1118   1.1   mycroft 	sbp->f_iosize = fs->lfs_bsize;
   1119  1.53  perseant 	sbp->f_blocks = dbtofrags(fs, LFS_EST_NONMETA(fs));
   1120  1.53  perseant 	sbp->f_bfree = dbtofrags(fs, LFS_EST_BFREE(fs));
   1121  1.53  perseant 	sbp->f_bavail = dbtofrags(fs, (long)LFS_EST_BFREE(fs) -
   1122  1.53  perseant 				  (long)LFS_EST_RSVD(fs));
   1123  1.31  perseant 	sbp->f_files = dbtofsb(fs,fs->lfs_bfree) * INOPB(fs);
   1124  1.31  perseant 	sbp->f_ffree = sbp->f_files - fs->lfs_nfiles;
   1125   1.1   mycroft 	if (sbp != &mp->mnt_stat) {
   1126   1.6   mycroft 		bcopy(mp->mnt_stat.f_mntonname, sbp->f_mntonname, MNAMELEN);
   1127   1.6   mycroft 		bcopy(mp->mnt_stat.f_mntfromname, sbp->f_mntfromname, MNAMELEN);
   1128   1.1   mycroft 	}
   1129   1.6   mycroft 	strncpy(sbp->f_fstypename, mp->mnt_op->vfs_name, MFSNAMELEN);
   1130   1.1   mycroft 	return (0);
   1131   1.1   mycroft }
   1132   1.1   mycroft 
   1133   1.1   mycroft /*
   1134   1.1   mycroft  * Go through the disk queues to initiate sandbagged IO;
   1135   1.1   mycroft  * go through the inodes to write those that have been modified;
   1136   1.1   mycroft  * initiate the writing of the super block if it has been modified.
   1137   1.1   mycroft  *
   1138   1.1   mycroft  * Note: we are always called with the filesystem marked `MPBUSY'.
   1139   1.1   mycroft  */
   1140  1.10  christos int
   1141   1.1   mycroft lfs_sync(mp, waitfor, cred, p)
   1142   1.1   mycroft 	struct mount *mp;
   1143   1.1   mycroft 	int waitfor;
   1144   1.1   mycroft 	struct ucred *cred;
   1145   1.1   mycroft 	struct proc *p;
   1146   1.1   mycroft {
   1147   1.1   mycroft 	int error;
   1148  1.26  perseant 	struct lfs *fs;
   1149  1.26  perseant 
   1150  1.26  perseant 	fs = ((struct ufsmount *)mp->mnt_data)->ufsmount_u.lfs;
   1151  1.56  perseant 	if (fs->lfs_ronly)
   1152  1.56  perseant 		return 0;
   1153  1.26  perseant 	while(fs->lfs_dirops)
   1154  1.26  perseant 		error = tsleep(&fs->lfs_dirops, PRIBIO + 1, "lfs_dirops", 0);
   1155  1.26  perseant 	fs->lfs_writer++;
   1156   1.1   mycroft 
   1157   1.1   mycroft 	/* All syncs must be checkpoints until roll-forward is implemented. */
   1158   1.1   mycroft 	error = lfs_segwrite(mp, SEGM_CKP | (waitfor ? SEGM_SYNC : 0));
   1159  1.26  perseant 	if(--fs->lfs_writer==0)
   1160  1.26  perseant 		wakeup(&fs->lfs_dirops);
   1161   1.1   mycroft #ifdef QUOTA
   1162   1.1   mycroft 	qsync(mp);
   1163   1.1   mycroft #endif
   1164   1.1   mycroft 	return (error);
   1165   1.1   mycroft }
   1166   1.1   mycroft 
   1167  1.26  perseant extern struct lock ufs_hashlock;
   1168  1.26  perseant 
   1169   1.1   mycroft /*
   1170   1.1   mycroft  * Look up an LFS dinode number to find its incore vnode.  If not already
   1171   1.1   mycroft  * in core, read it in from the specified device.  Return the inode locked.
   1172   1.1   mycroft  * Detection and handling of mount points must be done by the calling routine.
   1173   1.1   mycroft  */
   1174   1.1   mycroft int
   1175   1.1   mycroft lfs_vget(mp, ino, vpp)
   1176   1.1   mycroft 	struct mount *mp;
   1177   1.1   mycroft 	ino_t ino;
   1178   1.1   mycroft 	struct vnode **vpp;
   1179   1.1   mycroft {
   1180  1.48  augustss 	struct lfs *fs;
   1181  1.48  augustss 	struct inode *ip;
   1182   1.1   mycroft 	struct buf *bp;
   1183   1.1   mycroft 	struct ifile *ifp;
   1184   1.1   mycroft 	struct vnode *vp;
   1185   1.1   mycroft 	struct ufsmount *ump;
   1186  1.16      fvdl 	ufs_daddr_t daddr;
   1187   1.1   mycroft 	dev_t dev;
   1188   1.1   mycroft 	int error;
   1189  1.26  perseant #ifdef LFS_ATIME_IFILE
   1190  1.26  perseant 	struct timespec ts;
   1191  1.26  perseant #endif
   1192   1.1   mycroft 
   1193   1.1   mycroft 	ump = VFSTOUFS(mp);
   1194   1.1   mycroft 	dev = ump->um_dev;
   1195  1.60  perseant 	fs = ump->um_lfs;
   1196  1.60  perseant 
   1197  1.60  perseant 	/*
   1198  1.60  perseant 	 * If the filesystem is not completely mounted yet, suspend
   1199  1.60  perseant 	 * any access requests (wait for roll-forward to complete).
   1200  1.60  perseant 	 */
   1201  1.60  perseant 	while((fs->lfs_flags & LFS_NOTYET) && curproc->p_pid != fs->lfs_rfpid)
   1202  1.60  perseant 		tsleep(&fs->lfs_flags, PRIBIO+1, "lfs_notyet", 0);
   1203  1.26  perseant 
   1204  1.55      fvdl 	if ((*vpp = ufs_ihashget(dev, ino, LK_EXCLUSIVE)) != NULL)
   1205  1.55      fvdl 		return (0);
   1206  1.55      fvdl 
   1207  1.55      fvdl 	if ((error = getnewvnode(VT_LFS, mp, lfs_vnodeop_p, &vp)) != 0) {
   1208  1.55      fvdl 		*vpp = NULL;
   1209  1.55      fvdl 		 return (error);
   1210  1.55      fvdl 	}
   1211  1.55      fvdl 
   1212  1.26  perseant 	do {
   1213  1.55      fvdl 		if ((*vpp = ufs_ihashget(dev, ino, LK_EXCLUSIVE)) != NULL) {
   1214  1.55      fvdl 			ungetnewvnode(vp);
   1215  1.26  perseant 			return (0);
   1216  1.55      fvdl 		}
   1217  1.26  perseant 	} while (lockmgr(&ufs_hashlock, LK_EXCLUSIVE|LK_SLEEPFAIL, 0));
   1218   1.1   mycroft 
   1219   1.1   mycroft 	/* Translate the inode number to a disk address. */
   1220   1.1   mycroft 	if (ino == LFS_IFILE_INUM)
   1221   1.1   mycroft 		daddr = fs->lfs_idaddr;
   1222   1.1   mycroft 	else {
   1223  1.60  perseant 		/* XXX bounds-check this too */
   1224   1.1   mycroft 		LFS_IENTRY(ifp, fs, ino, bp);
   1225   1.1   mycroft 		daddr = ifp->if_daddr;
   1226  1.26  perseant #ifdef LFS_ATIME_IFILE
   1227  1.26  perseant 		ts = ifp->if_atime; /* structure copy */
   1228  1.26  perseant #endif
   1229   1.1   mycroft 		brelse(bp);
   1230  1.26  perseant 		if (daddr == LFS_UNUSED_DADDR) {
   1231  1.60  perseant 			*vpp = NULLVP;
   1232  1.60  perseant 			ungetnewvnode(vp);
   1233  1.26  perseant 			lockmgr(&ufs_hashlock, LK_RELEASE, 0);
   1234   1.1   mycroft 			return (ENOENT);
   1235  1.26  perseant 		}
   1236   1.1   mycroft 	}
   1237   1.1   mycroft 
   1238  1.55      fvdl 	/* Allocate/init new vnode/inode. */
   1239  1.55      fvdl 	lfs_vcreate(mp, ino, vp);
   1240   1.1   mycroft 
   1241   1.1   mycroft 	/*
   1242   1.1   mycroft 	 * Put it onto its hash chain and lock it so that other requests for
   1243   1.1   mycroft 	 * this inode will block if they arrive while we are sleeping waiting
   1244   1.1   mycroft 	 * for old data structures to be purged or for the contents of the
   1245   1.1   mycroft 	 * disk portion of this inode to be read.
   1246   1.1   mycroft 	 */
   1247   1.1   mycroft 	ip = VTOI(vp);
   1248   1.1   mycroft 	ufs_ihashins(ip);
   1249  1.26  perseant 	lockmgr(&ufs_hashlock, LK_RELEASE, 0);
   1250   1.1   mycroft 
   1251   1.1   mycroft 	/*
   1252   1.1   mycroft 	 * XXX
   1253   1.1   mycroft 	 * This may not need to be here, logically it should go down with
   1254   1.1   mycroft 	 * the i_devvp initialization.
   1255   1.1   mycroft 	 * Ask Kirk.
   1256   1.1   mycroft 	 */
   1257   1.1   mycroft 	ip->i_lfs = ump->um_lfs;
   1258   1.1   mycroft 
   1259   1.1   mycroft 	/* Read in the disk contents for the inode, copy into the inode. */
   1260  1.10  christos 	error = bread(ump->um_devvp, daddr, (int)fs->lfs_bsize, NOCRED, &bp);
   1261  1.10  christos 	if (error) {
   1262   1.1   mycroft 		/*
   1263   1.1   mycroft 		 * The inode does not contain anything useful, so it would
   1264   1.1   mycroft 		 * be misleading to leave it on its hash chain. With mode
   1265   1.1   mycroft 		 * still zero, it will be unlinked and returned to the free
   1266   1.1   mycroft 		 * list by vput().
   1267   1.1   mycroft 		 */
   1268   1.1   mycroft 		vput(vp);
   1269   1.1   mycroft 		brelse(bp);
   1270   1.1   mycroft 		*vpp = NULL;
   1271   1.1   mycroft 		return (error);
   1272   1.1   mycroft 	}
   1273  1.46  perseant 	ip->i_din.ffs_din = *lfs_ifind(fs, ino, bp);
   1274  1.45  perseant 	ip->i_ffs_effnlink = ip->i_ffs_nlink;
   1275  1.56  perseant 	ip->i_lfs_effnblks = ip->i_ffs_blocks;
   1276  1.26  perseant #ifdef LFS_ATIME_IFILE
   1277  1.26  perseant 	ip->i_ffs_atime = ts.tv_sec;
   1278  1.26  perseant 	ip->i_ffs_atimensec = ts.tv_nsec;
   1279  1.26  perseant #endif
   1280   1.1   mycroft 	brelse(bp);
   1281   1.1   mycroft 
   1282   1.1   mycroft 	/*
   1283   1.1   mycroft 	 * Initialize the vnode from the inode, check for aliases.  In all
   1284   1.1   mycroft 	 * cases re-init ip, the underlying vnode/inode may have changed.
   1285   1.1   mycroft 	 */
   1286  1.22  sommerfe 	error = ufs_vinit(mp, lfs_specop_p, lfs_fifoop_p, &vp);
   1287  1.10  christos 	if (error) {
   1288   1.1   mycroft 		vput(vp);
   1289   1.1   mycroft 		*vpp = NULL;
   1290   1.1   mycroft 		return (error);
   1291   1.1   mycroft 	}
   1292  1.58  perseant #ifdef DIAGNOSTIC
   1293  1.26  perseant 	if(vp->v_type == VNON) {
   1294  1.58  perseant 		panic("lfs_vget: ino %d is type VNON! (ifmt %o)\n",
   1295  1.58  perseant 		       ip->i_number, (ip->i_ffs_mode & IFMT) >> 12);
   1296  1.58  perseant 	}
   1297  1.26  perseant #endif
   1298   1.1   mycroft 	/*
   1299   1.1   mycroft 	 * Finish inode initialization now that aliasing has been resolved.
   1300   1.1   mycroft 	 */
   1301   1.1   mycroft 	ip->i_devvp = ump->um_devvp;
   1302   1.1   mycroft 	VREF(ip->i_devvp);
   1303   1.1   mycroft 	*vpp = vp;
   1304  1.62  perseant 
   1305  1.62  perseant 	uvm_vnp_setsize(vp, ip->i_ffs_size);
   1306  1.26  perseant 
   1307   1.1   mycroft 	return (0);
   1308   1.1   mycroft }
   1309   1.1   mycroft 
   1310   1.1   mycroft /*
   1311   1.1   mycroft  * File handle to vnode
   1312   1.1   mycroft  *
   1313   1.1   mycroft  * Have to be really careful about stale file handles:
   1314   1.1   mycroft  * - check that the inode number is valid
   1315   1.1   mycroft  * - call lfs_vget() to get the locked inode
   1316   1.1   mycroft  * - check for an unallocated inode (i_mode == 0)
   1317   1.1   mycroft  *
   1318   1.1   mycroft  * XXX
   1319   1.1   mycroft  * use ifile to see if inode is allocated instead of reading off disk
   1320   1.1   mycroft  * what is the relationship between my generational number and the NFS
   1321   1.1   mycroft  * generational number.
   1322   1.1   mycroft  */
   1323   1.1   mycroft int
   1324  1.25  wrstuden lfs_fhtovp(mp, fhp, vpp)
   1325  1.48  augustss 	struct mount *mp;
   1326   1.1   mycroft 	struct fid *fhp;
   1327   1.1   mycroft 	struct vnode **vpp;
   1328   1.1   mycroft {
   1329  1.48  augustss 	struct ufid *ufhp;
   1330   1.1   mycroft 
   1331   1.1   mycroft 	ufhp = (struct ufid *)fhp;
   1332   1.1   mycroft 	if (ufhp->ufid_ino < ROOTINO)
   1333   1.1   mycroft 		return (ESTALE);
   1334  1.25  wrstuden 	return (ufs_fhtovp(mp, ufhp, vpp));
   1335   1.1   mycroft }
   1336   1.1   mycroft 
   1337   1.1   mycroft /*
   1338   1.1   mycroft  * Vnode pointer to File handle
   1339   1.1   mycroft  */
   1340   1.1   mycroft /* ARGSUSED */
   1341  1.10  christos int
   1342   1.1   mycroft lfs_vptofh(vp, fhp)
   1343   1.1   mycroft 	struct vnode *vp;
   1344   1.1   mycroft 	struct fid *fhp;
   1345   1.1   mycroft {
   1346  1.48  augustss 	struct inode *ip;
   1347  1.48  augustss 	struct ufid *ufhp;
   1348   1.1   mycroft 
   1349   1.1   mycroft 	ip = VTOI(vp);
   1350   1.1   mycroft 	ufhp = (struct ufid *)fhp;
   1351   1.1   mycroft 	ufhp->ufid_len = sizeof(struct ufid);
   1352   1.1   mycroft 	ufhp->ufid_ino = ip->i_number;
   1353  1.13    bouyer 	ufhp->ufid_gen = ip->i_ffs_gen;
   1354   1.1   mycroft 	return (0);
   1355  1.16      fvdl }
   1356  1.16      fvdl 
   1357  1.16      fvdl int
   1358  1.16      fvdl lfs_sysctl(name, namelen, oldp, oldlenp, newp, newlen, p)
   1359  1.16      fvdl 	int *name;
   1360  1.16      fvdl 	u_int namelen;
   1361  1.16      fvdl 	void *oldp;
   1362  1.16      fvdl 	size_t *oldlenp;
   1363  1.16      fvdl 	void *newp;
   1364  1.16      fvdl 	size_t newlen;
   1365  1.16      fvdl 	struct proc *p;
   1366  1.16      fvdl {
   1367  1.26  perseant 	extern int lfs_writeindir, lfs_dostats, lfs_clean_vnhead;
   1368  1.26  perseant 	extern struct lfs_stats lfs_stats;
   1369  1.26  perseant 	int error;
   1370  1.26  perseant 
   1371  1.26  perseant 	/* all sysctl names at this level are terminal */
   1372  1.26  perseant 	if (namelen != 1)
   1373  1.26  perseant 		return (ENOTDIR);
   1374  1.26  perseant 
   1375  1.26  perseant 	switch (name[0]) {
   1376  1.26  perseant 	case LFS_WRITEINDIR:
   1377  1.26  perseant 		return (sysctl_int(oldp, oldlenp, newp, newlen,
   1378  1.26  perseant 				   &lfs_writeindir));
   1379  1.26  perseant 	case LFS_CLEAN_VNHEAD:
   1380  1.26  perseant 		return (sysctl_int(oldp, oldlenp, newp, newlen,
   1381  1.26  perseant 				   &lfs_clean_vnhead));
   1382  1.26  perseant 	case LFS_DOSTATS:
   1383  1.26  perseant 		if((error = sysctl_int(oldp, oldlenp, newp, newlen,
   1384  1.26  perseant 				       &lfs_dostats)))
   1385  1.26  perseant 			return error;
   1386  1.26  perseant 		if(lfs_dostats == 0)
   1387  1.26  perseant 			memset(&lfs_stats,0,sizeof(lfs_stats));
   1388  1.26  perseant 		return 0;
   1389  1.26  perseant 	case LFS_STATS:
   1390  1.26  perseant 		return (sysctl_rdstruct(oldp, oldlenp, newp,
   1391  1.26  perseant 					&lfs_stats, sizeof(lfs_stats)));
   1392  1.26  perseant 	default:
   1393  1.26  perseant 		return (EOPNOTSUPP);
   1394  1.26  perseant 	}
   1395  1.26  perseant 	/* NOTREACHED */
   1396   1.1   mycroft }
   1397