Home | History | Annotate | Line # | Download | only in lfs
lfs_vfsops.c revision 1.235
      1  1.235  perseant /*	$NetBSD: lfs_vfsops.c,v 1.235 2007/05/16 19:11:38 perseant Exp $	*/
      2    1.2       cgd 
      3   1.26  perseant /*-
      4  1.227        ad  * Copyright (c) 1999, 2000, 2001, 2002, 2003, 2007 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.96  perseant  *	This product includes software developed by the NetBSD
     21   1.96  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.130       agc  * 3. Neither the name of the University nor the names of its contributors
     51    1.1   mycroft  *    may be used to endorse or promote products derived from this software
     52    1.1   mycroft  *    without specific prior written permission.
     53    1.1   mycroft  *
     54    1.1   mycroft  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     55    1.1   mycroft  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     56    1.1   mycroft  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     57    1.1   mycroft  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     58    1.1   mycroft  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     59    1.1   mycroft  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     60    1.1   mycroft  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     61    1.1   mycroft  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     62    1.1   mycroft  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     63    1.1   mycroft  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     64    1.1   mycroft  * SUCH DAMAGE.
     65    1.1   mycroft  *
     66   1.16      fvdl  *	@(#)lfs_vfsops.c	8.20 (Berkeley) 6/10/95
     67    1.1   mycroft  */
     68   1.69     lukem 
     69   1.69     lukem #include <sys/cdefs.h>
     70  1.235  perseant __KERNEL_RCSID(0, "$NetBSD: lfs_vfsops.c,v 1.235 2007/05/16 19:11:38 perseant Exp $");
     71   1.19    scottr 
     72   1.65       mrg #if defined(_KERNEL_OPT)
     73   1.19    scottr #include "opt_quota.h"
     74   1.20    scottr #endif
     75    1.1   mycroft 
     76    1.1   mycroft #include <sys/param.h>
     77    1.1   mycroft #include <sys/systm.h>
     78    1.1   mycroft #include <sys/namei.h>
     79    1.1   mycroft #include <sys/proc.h>
     80    1.1   mycroft #include <sys/kernel.h>
     81    1.1   mycroft #include <sys/vnode.h>
     82    1.1   mycroft #include <sys/mount.h>
     83   1.91  perseant #include <sys/kthread.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.165  perseant #include <sys/syslog.h>
     95   1.54       mrg #include <uvm/uvm_extern.h>
     96   1.26  perseant #include <sys/sysctl.h>
     97   1.80   gehenna #include <sys/conf.h>
     98  1.210      elad #include <sys/kauth.h>
     99    1.1   mycroft 
    100    1.1   mycroft #include <miscfs/specfs/specdev.h>
    101    1.1   mycroft 
    102    1.1   mycroft #include <ufs/ufs/quota.h>
    103    1.1   mycroft #include <ufs/ufs/inode.h>
    104    1.1   mycroft #include <ufs/ufs/ufsmount.h>
    105    1.1   mycroft #include <ufs/ufs/ufs_extern.h>
    106    1.1   mycroft 
    107   1.91  perseant #include <uvm/uvm.h>
    108   1.91  perseant #include <uvm/uvm_stat.h>
    109   1.91  perseant #include <uvm/uvm_pager.h>
    110   1.91  perseant #include <uvm/uvm_pdaemon.h>
    111   1.91  perseant 
    112    1.1   mycroft #include <ufs/lfs/lfs.h>
    113    1.1   mycroft #include <ufs/lfs/lfs_extern.h>
    114    1.1   mycroft 
    115   1.91  perseant #include <miscfs/genfs/genfs.h>
    116   1.91  perseant #include <miscfs/genfs/genfs_node.h>
    117  1.128      yamt 
    118   1.91  perseant static int lfs_gop_write(struct vnode *, struct vm_page **, int, int);
    119  1.230   thorpej static bool lfs_issequential_hole(const struct ufsmount *,
    120  1.117      yamt     daddr_t, daddr_t);
    121   1.91  perseant 
    122  1.190  christos static int lfs_mountfs(struct vnode *, struct mount *, struct lwp *);
    123    1.1   mycroft 
    124   1.63  jdolecek extern const struct vnodeopv_desc lfs_vnodeop_opv_desc;
    125   1.63  jdolecek extern const struct vnodeopv_desc lfs_specop_opv_desc;
    126   1.63  jdolecek extern const struct vnodeopv_desc lfs_fifoop_opv_desc;
    127   1.91  perseant 
    128  1.101      yamt pid_t lfs_writer_daemon = 0;
    129   1.91  perseant int lfs_do_flush = 0;
    130  1.217  perseant #ifdef LFS_KERNEL_RFW
    131  1.166  perseant int lfs_do_rfw = 0;
    132  1.217  perseant #endif
    133   1.15   thorpej 
    134   1.63  jdolecek const struct vnodeopv_desc * const lfs_vnodeopv_descs[] = {
    135   1.15   thorpej 	&lfs_vnodeop_opv_desc,
    136   1.15   thorpej 	&lfs_specop_opv_desc,
    137   1.15   thorpej 	&lfs_fifoop_opv_desc,
    138   1.15   thorpej 	NULL,
    139   1.15   thorpej };
    140   1.15   thorpej 
    141    1.1   mycroft struct vfsops lfs_vfsops = {
    142    1.1   mycroft 	MOUNT_LFS,
    143    1.1   mycroft 	lfs_mount,
    144    1.1   mycroft 	ufs_start,
    145    1.1   mycroft 	lfs_unmount,
    146    1.1   mycroft 	ufs_root,
    147    1.1   mycroft 	ufs_quotactl,
    148  1.147  christos 	lfs_statvfs,
    149    1.1   mycroft 	lfs_sync,
    150    1.1   mycroft 	lfs_vget,
    151    1.1   mycroft 	lfs_fhtovp,
    152    1.1   mycroft 	lfs_vptofh,
    153    1.1   mycroft 	lfs_init,
    154   1.67       chs 	lfs_reinit,
    155   1.47  jdolecek 	lfs_done,
    156   1.36  perseant 	lfs_mountroot,
    157  1.152   hannken 	(int (*)(struct mount *, struct vnode *, struct timespec *)) eopnotsupp,
    158  1.159   thorpej 	vfs_stdextattrctl,
    159  1.226   hannken 	vfs_stdsuspendctl,
    160   1.15   thorpej 	lfs_vnodeopv_descs,
    161  1.220  christos 	0,
    162  1.220  christos 	{ NULL, NULL },
    163    1.1   mycroft };
    164  1.168   thorpej VFS_ATTACH(lfs_vfsops);
    165    1.1   mycroft 
    166  1.183      yamt const struct genfs_ops lfs_genfsops = {
    167  1.183      yamt 	.gop_size = lfs_gop_size,
    168  1.183      yamt 	.gop_alloc = ufs_gop_alloc,
    169  1.183      yamt 	.gop_write = lfs_gop_write,
    170  1.184      yamt 	.gop_markupdate = ufs_gop_markupdate,
    171   1.71       chs };
    172   1.71       chs 
    173  1.188      yamt static const struct ufs_ops lfs_ufsops = {
    174  1.188      yamt 	.uo_itimes = NULL,
    175  1.189      yamt 	.uo_update = lfs_update,
    176  1.189      yamt 	.uo_truncate = lfs_truncate,
    177  1.189      yamt 	.uo_valloc = lfs_valloc,
    178  1.189      yamt 	.uo_vfree = lfs_vfree,
    179  1.189      yamt 	.uo_balloc = lfs_balloc,
    180  1.188      yamt };
    181  1.188      yamt 
    182  1.149    simonb /*
    183  1.149    simonb  * XXX Same structure as FFS inodes?  Should we share a common pool?
    184  1.149    simonb  */
    185  1.149    simonb POOL_INIT(lfs_inode_pool, sizeof(struct inode), 0, 0, 0, "lfsinopl",
    186  1.232        ad     &pool_allocator_nointr, IPL_NONE);
    187  1.149    simonb POOL_INIT(lfs_dinode_pool, sizeof(struct ufs1_dinode), 0, 0, 0, "lfsdinopl",
    188  1.232        ad     &pool_allocator_nointr, IPL_NONE);
    189  1.149    simonb POOL_INIT(lfs_inoext_pool, sizeof(struct lfs_inode_ext), 8, 0, 0, "lfsinoextpl",
    190  1.232        ad     &pool_allocator_nointr, IPL_NONE);
    191  1.163  perseant POOL_INIT(lfs_lbnentry_pool, sizeof(struct lbnentry), 0, 0, 0, "lfslbnpool",
    192  1.232        ad     &pool_allocator_nointr, IPL_NONE);
    193   1.91  perseant 
    194   1.91  perseant /*
    195   1.91  perseant  * The writer daemon.  UVM keeps track of how many dirty pages we are holding
    196   1.91  perseant  * in lfs_subsys_pages; the daemon flushes the filesystem when this value
    197   1.91  perseant  * crosses the (user-defined) threshhold LFS_MAX_PAGES.
    198   1.91  perseant  */
    199   1.91  perseant static void
    200  1.224  christos lfs_writerd(void *arg)
    201   1.91  perseant {
    202   1.91  perseant 	struct mount *mp, *nmp;
    203   1.91  perseant 	struct lfs *fs;
    204  1.234  perseant 	int fsflags;
    205  1.170  perseant 	int loopcount;
    206   1.91  perseant 
    207   1.91  perseant 	lfs_writer_daemon = curproc->p_pid;
    208   1.91  perseant 
    209  1.126      yamt 	simple_lock(&lfs_subsys_lock);
    210   1.91  perseant 	for (;;) {
    211  1.176  perseant 		ltsleep(&lfs_writer_daemon, PVM | PNORELOCK, "lfswriter", hz/10,
    212  1.126      yamt 		    &lfs_subsys_lock);
    213   1.91  perseant 
    214   1.91  perseant 		/*
    215   1.91  perseant 		 * Look through the list of LFSs to see if any of them
    216   1.91  perseant 		 * have requested pageouts.
    217   1.91  perseant 		 */
    218   1.91  perseant 		simple_lock(&mountlist_slock);
    219  1.124      yamt 		for (mp = CIRCLEQ_FIRST(&mountlist); mp != (void *)&mountlist;
    220   1.91  perseant 		     mp = nmp) {
    221   1.91  perseant 			if (vfs_busy(mp, LK_NOWAIT, &mountlist_slock)) {
    222  1.124      yamt 				nmp = CIRCLEQ_NEXT(mp, mnt_list);
    223   1.91  perseant 				continue;
    224   1.91  perseant 			}
    225   1.91  perseant 			if (strncmp(&mp->mnt_stat.f_fstypename[0], MOUNT_LFS,
    226   1.91  perseant 				    MFSNAMELEN) == 0) {
    227  1.123      yamt 				fs = VFSTOUFS(mp)->um_lfs;
    228  1.169  perseant 				simple_lock(&fs->lfs_interlock);
    229  1.234  perseant 				fsflags = 0;
    230  1.234  perseant 				if ((fs->lfs_dirvcount > LFS_MAX_FSDIROP(fs) ||
    231  1.234  perseant 				     lfs_dirvcount > LFS_MAX_DIROP) &&
    232  1.234  perseant 				    fs->lfs_dirops == 0)
    233  1.235  perseant 					fsflags |= SEGM_CKP;
    234  1.200  perseant 				if (fs->lfs_pdflush) {
    235  1.166  perseant 					DLOG((DLOG_FLUSH, "lfs_writerd: pdflush set\n"));
    236   1.91  perseant 					fs->lfs_pdflush = 0;
    237  1.234  perseant 					lfs_flush_fs(fs, fsflags);
    238  1.200  perseant 					simple_unlock(&fs->lfs_interlock);
    239  1.200  perseant 				} else if (!TAILQ_EMPTY(&fs->lfs_pchainhd)) {
    240  1.200  perseant 					DLOG((DLOG_FLUSH, "lfs_writerd: pchain non-empty\n"));
    241  1.200  perseant 					simple_unlock(&fs->lfs_interlock);
    242  1.200  perseant 					lfs_writer_enter(fs, "wrdirop");
    243  1.200  perseant 					lfs_flush_pchain(fs);
    244  1.200  perseant 					lfs_writer_leave(fs);
    245  1.201  perseant 				} else
    246  1.201  perseant 					simple_unlock(&fs->lfs_interlock);
    247   1.91  perseant 			}
    248   1.91  perseant 
    249   1.91  perseant 			simple_lock(&mountlist_slock);
    250  1.124      yamt 			nmp = CIRCLEQ_NEXT(mp, mnt_list);
    251   1.91  perseant 			vfs_unbusy(mp);
    252   1.91  perseant 		}
    253   1.91  perseant 		simple_unlock(&mountlist_slock);
    254   1.23   thorpej 
    255   1.91  perseant 		/*
    256   1.91  perseant 		 * If global state wants a flush, flush everything.
    257   1.91  perseant 		 */
    258  1.125      yamt 		simple_lock(&lfs_subsys_lock);
    259  1.170  perseant 		loopcount = 0;
    260  1.176  perseant 		if (lfs_do_flush || locked_queue_count > LFS_MAX_BUFS ||
    261   1.91  perseant 			locked_queue_bytes > LFS_MAX_BYTES ||
    262   1.91  perseant 			lfs_subsys_pages > LFS_MAX_PAGES) {
    263   1.91  perseant 
    264  1.222  christos 			if (lfs_do_flush) {
    265  1.166  perseant 				DLOG((DLOG_FLUSH, "daemon: lfs_do_flush\n"));
    266  1.222  christos 			}
    267  1.222  christos 			if (locked_queue_count > LFS_MAX_BUFS) {
    268  1.166  perseant 				DLOG((DLOG_FLUSH, "daemon: lqc = %d, max %d\n",
    269  1.166  perseant 				      locked_queue_count, LFS_MAX_BUFS));
    270  1.222  christos 			}
    271  1.222  christos 			if (locked_queue_bytes > LFS_MAX_BYTES) {
    272  1.166  perseant 				DLOG((DLOG_FLUSH, "daemon: lqb = %ld, max %ld\n",
    273  1.166  perseant 				      locked_queue_bytes, LFS_MAX_BYTES));
    274  1.222  christos 			}
    275  1.222  christos 			if (lfs_subsys_pages > LFS_MAX_PAGES) {
    276  1.166  perseant 				DLOG((DLOG_FLUSH, "daemon: lssp = %d, max %d\n",
    277  1.166  perseant 				      lfs_subsys_pages, LFS_MAX_PAGES));
    278  1.222  christos 			}
    279  1.166  perseant 
    280  1.163  perseant 			lfs_flush(NULL, SEGM_WRITERD, 0);
    281   1.91  perseant 			lfs_do_flush = 0;
    282   1.91  perseant 		}
    283   1.91  perseant 	}
    284   1.91  perseant 	/* NOTREACHED */
    285   1.91  perseant }
    286   1.60  perseant 
    287   1.16      fvdl /*
    288   1.16      fvdl  * Initialize the filesystem, most work done by ufs_init.
    289   1.16      fvdl  */
    290   1.16      fvdl void
    291   1.16      fvdl lfs_init()
    292   1.16      fvdl {
    293  1.146    atatat #ifdef _LKM
    294  1.146    atatat 	malloc_type_attach(M_SEGMENT);
    295  1.150    atatat 	pool_init(&lfs_inode_pool, sizeof(struct inode), 0, 0, 0,
    296  1.233        ad 	    "lfsinopl", &pool_allocator_nointr, IPL_NONE);
    297  1.150    atatat 	pool_init(&lfs_dinode_pool, sizeof(struct ufs1_dinode), 0, 0, 0,
    298  1.233        ad 	    "lfsdinopl", &pool_allocator_nointr, IPL_NONE);
    299  1.150    atatat 	pool_init(&lfs_inoext_pool, sizeof(struct lfs_inode_ext), 8, 0, 0,
    300  1.233        ad 	    "lfsinoextpl", &pool_allocator_nointr, IPL_NONE);
    301  1.163  perseant 	pool_init(&lfs_lbnentry_pool, sizeof(struct lbnentry), 0, 0, 0,
    302  1.233        ad 	    "lfslbnpool", &pool_allocator_nointr, IPL_NONE);
    303  1.146    atatat #endif
    304   1.16      fvdl 	ufs_init();
    305   1.56  perseant 
    306   1.74  perseant #ifdef DEBUG
    307   1.74  perseant 	memset(lfs_log, 0, sizeof(lfs_log));
    308   1.74  perseant #endif
    309   1.91  perseant 	simple_lock_init(&lfs_subsys_lock);
    310   1.67       chs }
    311   1.67       chs 
    312   1.67       chs void
    313   1.67       chs lfs_reinit()
    314   1.67       chs {
    315   1.67       chs 	ufs_reinit();
    316   1.47  jdolecek }
    317   1.47  jdolecek 
    318   1.47  jdolecek void
    319   1.47  jdolecek lfs_done()
    320   1.47  jdolecek {
    321   1.47  jdolecek 	ufs_done();
    322  1.150    atatat #ifdef _LKM
    323   1.47  jdolecek 	pool_destroy(&lfs_inode_pool);
    324  1.144     oster 	pool_destroy(&lfs_dinode_pool);
    325  1.106  perseant 	pool_destroy(&lfs_inoext_pool);
    326  1.174  perseant 	pool_destroy(&lfs_lbnentry_pool);
    327  1.146    atatat 	malloc_type_detach(M_SEGMENT);
    328  1.146    atatat #endif
    329   1.16      fvdl }
    330   1.16      fvdl 
    331   1.16      fvdl /*
    332   1.16      fvdl  * Called by main() when ufs is going to be mounted as root.
    333   1.16      fvdl  */
    334    1.1   mycroft int
    335    1.1   mycroft lfs_mountroot()
    336    1.1   mycroft {
    337   1.16      fvdl 	extern struct vnode *rootvp;
    338   1.16      fvdl 	struct mount *mp;
    339  1.190  christos 	struct lwp *l = curlwp;	/* XXX */
    340   1.16      fvdl 	int error;
    341  1.164     perry 
    342  1.193   thorpej 	if (device_class(root_device) != DV_DISK)
    343   1.37  sommerfe 		return (ENODEV);
    344   1.37  sommerfe 
    345   1.37  sommerfe 	if (rootdev == NODEV)
    346   1.96  perseant 		return (ENODEV);
    347   1.35  wrstuden 	if ((error = vfs_rootmountalloc(MOUNT_LFS, "root_device", &mp))) {
    348   1.35  wrstuden 		vrele(rootvp);
    349   1.16      fvdl 		return (error);
    350   1.35  wrstuden 	}
    351  1.190  christos 	if ((error = lfs_mountfs(rootvp, mp, l))) {
    352   1.16      fvdl 		mp->mnt_op->vfs_refcount--;
    353   1.16      fvdl 		vfs_unbusy(mp);
    354   1.16      fvdl 		free(mp, M_MOUNT);
    355   1.16      fvdl 		return (error);
    356   1.16      fvdl 	}
    357   1.16      fvdl 	simple_lock(&mountlist_slock);
    358   1.16      fvdl 	CIRCLEQ_INSERT_TAIL(&mountlist, mp, mnt_list);
    359   1.16      fvdl 	simple_unlock(&mountlist_slock);
    360  1.190  christos 	(void)lfs_statvfs(mp, &mp->mnt_stat, l);
    361   1.16      fvdl 	vfs_unbusy(mp);
    362  1.154        pk 	setrootfstime((time_t)(VFSTOUFS(mp)->um_lfs->lfs_tstamp));
    363   1.16      fvdl 	return (0);
    364    1.1   mycroft }
    365    1.1   mycroft 
    366    1.1   mycroft /*
    367    1.1   mycroft  * VFS Operations.
    368    1.1   mycroft  *
    369    1.1   mycroft  * mount system call
    370    1.1   mycroft  */
    371   1.10  christos int
    372  1.190  christos lfs_mount(struct mount *mp, const char *path, void *data, struct nameidata *ndp, struct lwp *l)
    373    1.1   mycroft {
    374    1.1   mycroft 	struct vnode *devvp;
    375    1.1   mycroft 	struct ufs_args args;
    376   1.10  christos 	struct ufsmount *ump = NULL;
    377   1.48  augustss 	struct lfs *fs = NULL;				/* LFS */
    378  1.161   mycroft 	int error, update;
    379    1.3   mycroft 	mode_t accessmode;
    380    1.1   mycroft 
    381   1.81  christos 	if (mp->mnt_flag & MNT_GETARGS) {
    382   1.81  christos 		ump = VFSTOUFS(mp);
    383   1.81  christos 		if (ump == NULL)
    384   1.81  christos 			return EIO;
    385   1.81  christos 		args.fspec = NULL;
    386   1.81  christos 		return copyout(&args, data, sizeof(args));
    387   1.81  christos 	}
    388  1.111       dsl 	error = copyin(data, &args, sizeof (struct ufs_args));
    389   1.10  christos 	if (error)
    390    1.1   mycroft 		return (error);
    391    1.1   mycroft 
    392  1.161   mycroft 	update = mp->mnt_flag & MNT_UPDATE;
    393  1.161   mycroft 
    394  1.162   mycroft 	/* Check arguments */
    395  1.161   mycroft 	if (args.fspec != NULL) {
    396  1.161   mycroft 		/*
    397  1.161   mycroft 		 * Look up the name and verify that it's sane.
    398  1.161   mycroft 		 */
    399  1.190  christos 		NDINIT(ndp, LOOKUP, FOLLOW, UIO_USERSPACE, args.fspec, l);
    400  1.161   mycroft 		if ((error = namei(ndp)) != 0)
    401  1.161   mycroft 			return (error);
    402  1.161   mycroft 		devvp = ndp->ni_vp;
    403  1.161   mycroft 
    404  1.161   mycroft 		if (!update) {
    405    1.3   mycroft 			/*
    406  1.161   mycroft 			 * Be sure this is a valid block device
    407    1.3   mycroft 			 */
    408  1.161   mycroft 			if (devvp->v_type != VBLK)
    409  1.161   mycroft 				error = ENOTBLK;
    410  1.161   mycroft 			else if (bdevsw_lookup(devvp->v_rdev) == NULL)
    411  1.161   mycroft 				error = ENXIO;
    412  1.161   mycroft 		} else {
    413    1.1   mycroft 			/*
    414  1.161   mycroft 			 * Be sure we're still naming the same device
    415  1.161   mycroft 			 * used for our initial mount
    416    1.1   mycroft 			 */
    417  1.162   mycroft 			ump = VFSTOUFS(mp);
    418  1.161   mycroft 			if (devvp != ump->um_devvp)
    419  1.161   mycroft 				error = EINVAL;
    420    1.1   mycroft 		}
    421  1.162   mycroft 	} else {
    422  1.162   mycroft 		if (!update) {
    423  1.162   mycroft 			/* New mounts must have a filename for the device */
    424  1.162   mycroft 			return (EINVAL);
    425  1.162   mycroft 		} else {
    426  1.162   mycroft 			/* Use the extant mount */
    427  1.162   mycroft 			ump = VFSTOUFS(mp);
    428  1.162   mycroft 			devvp = ump->um_devvp;
    429  1.162   mycroft 			vref(devvp);
    430  1.162   mycroft 		}
    431    1.1   mycroft 	}
    432  1.161   mycroft 
    433  1.162   mycroft 
    434    1.3   mycroft 	/*
    435    1.3   mycroft 	 * If mount by non-root, then verify that user has necessary
    436    1.3   mycroft 	 * permissions on the device.
    437    1.3   mycroft 	 */
    438  1.225      elad 	if (error == 0 && kauth_authorize_generic(l->l_cred,
    439  1.225      elad 	    KAUTH_GENERIC_ISSUSER, NULL) != 0) {
    440    1.3   mycroft 		accessmode = VREAD;
    441  1.161   mycroft 		if (update ?
    442  1.161   mycroft 		    (mp->mnt_iflag & IMNT_WANTRDWR) != 0 :
    443  1.161   mycroft 		    (mp->mnt_flag & MNT_RDONLY) == 0)
    444    1.3   mycroft 			accessmode |= VWRITE;
    445   1.16      fvdl 		vn_lock(devvp, LK_EXCLUSIVE | LK_RETRY);
    446  1.218        ad 		error = VOP_ACCESS(devvp, accessmode, l->l_cred, l);
    447   1.16      fvdl 		VOP_UNLOCK(devvp, 0);
    448    1.3   mycroft 	}
    449  1.161   mycroft 
    450    1.1   mycroft 	if (error) {
    451    1.1   mycroft 		vrele(devvp);
    452    1.1   mycroft 		return (error);
    453    1.1   mycroft 	}
    454  1.161   mycroft 
    455  1.161   mycroft 	if (!update) {
    456  1.161   mycroft 		int flags;
    457  1.161   mycroft 
    458  1.161   mycroft 		/*
    459  1.161   mycroft 		 * Disallow multiple mounts of the same device.
    460  1.161   mycroft 		 * Disallow mounting of a device that is currently in use
    461  1.161   mycroft 		 * (except for root, which might share swap device for
    462  1.161   mycroft 		 * miniroot).
    463  1.161   mycroft 		 */
    464  1.161   mycroft 		error = vfs_mountedon(devvp);
    465  1.161   mycroft 		if (error)
    466  1.161   mycroft 			goto fail;
    467  1.161   mycroft 		if (vcount(devvp) > 1 && devvp != rootvp) {
    468  1.161   mycroft 			error = EBUSY;
    469  1.161   mycroft 			goto fail;
    470  1.161   mycroft 		}
    471  1.161   mycroft 		if (mp->mnt_flag & MNT_RDONLY)
    472  1.161   mycroft 			flags = FREAD;
    473  1.161   mycroft 		else
    474  1.161   mycroft 			flags = FREAD|FWRITE;
    475  1.190  christos 		error = VOP_OPEN(devvp, flags, FSCRED, l);
    476  1.161   mycroft 		if (error)
    477  1.161   mycroft 			goto fail;
    478  1.190  christos 		error = lfs_mountfs(devvp, mp, l);		/* LFS */
    479  1.161   mycroft 		if (error) {
    480  1.161   mycroft 			vn_lock(devvp, LK_EXCLUSIVE | LK_RETRY);
    481  1.190  christos 			(void)VOP_CLOSE(devvp, flags, NOCRED, l);
    482  1.161   mycroft 			VOP_UNLOCK(devvp, 0);
    483  1.161   mycroft 			goto fail;
    484  1.161   mycroft 		}
    485  1.161   mycroft 
    486  1.161   mycroft 		ump = VFSTOUFS(mp);
    487  1.161   mycroft 		fs = ump->um_lfs;
    488  1.161   mycroft 	} else {
    489  1.161   mycroft 		/*
    490  1.161   mycroft 		 * Update the mount.
    491  1.161   mycroft 		 */
    492  1.161   mycroft 
    493  1.161   mycroft 		/*
    494  1.161   mycroft 		 * The initial mount got a reference on this
    495  1.161   mycroft 		 * device, so drop the one obtained via
    496  1.161   mycroft 		 * namei(), above.
    497  1.161   mycroft 		 */
    498  1.161   mycroft 		vrele(devvp);
    499  1.161   mycroft 
    500  1.162   mycroft 		ump = VFSTOUFS(mp);
    501  1.161   mycroft 		fs = ump->um_lfs;
    502  1.161   mycroft 		if (fs->lfs_ronly && (mp->mnt_iflag & IMNT_WANTRDWR)) {
    503  1.161   mycroft 			/*
    504  1.198  perseant 			 * Changing from read-only to read/write.
    505  1.198  perseant 			 * Note in the superblocks that we're writing.
    506  1.161   mycroft 			 */
    507  1.161   mycroft 			fs->lfs_ronly = 0;
    508  1.198  perseant 			if (fs->lfs_pflags & LFS_PF_CLEAN) {
    509  1.198  perseant 				fs->lfs_pflags &= ~LFS_PF_CLEAN;
    510  1.198  perseant 				lfs_writesuper(fs, fs->lfs_sboffs[0]);
    511  1.198  perseant 				lfs_writesuper(fs, fs->lfs_sboffs[1]);
    512  1.198  perseant 			}
    513  1.161   mycroft 		}
    514  1.187      jmmv 		if (args.fspec == NULL)
    515  1.187      jmmv 			return EINVAL;
    516  1.161   mycroft 	}
    517  1.161   mycroft 
    518  1.179  perseant 	error = set_statvfs_info(path, UIO_USERSPACE, args.fspec,
    519  1.190  christos 	    UIO_USERSPACE, mp, l);
    520  1.179  perseant 	if (error == 0)
    521  1.179  perseant 		(void)strncpy(fs->lfs_fsmnt, mp->mnt_stat.f_mntonname,
    522  1.179  perseant 			      sizeof(fs->lfs_fsmnt));
    523  1.179  perseant 	return error;
    524  1.161   mycroft 
    525  1.161   mycroft fail:
    526  1.161   mycroft 	vrele(devvp);
    527  1.161   mycroft 	return (error);
    528    1.1   mycroft }
    529    1.1   mycroft 
    530   1.60  perseant 
    531    1.1   mycroft /*
    532    1.1   mycroft  * Common code for mount and mountroot
    533    1.1   mycroft  * LFS specific
    534    1.1   mycroft  */
    535    1.1   mycroft int
    536  1.190  christos lfs_mountfs(struct vnode *devvp, struct mount *mp, struct lwp *l)
    537    1.1   mycroft {
    538   1.60  perseant 	struct dlfs *tdfs, *dfs, *adfs;
    539   1.48  augustss 	struct lfs *fs;
    540   1.48  augustss 	struct ufsmount *ump;
    541    1.1   mycroft 	struct vnode *vp;
    542   1.28  perseant 	struct buf *bp, *abp;
    543    1.1   mycroft 	struct partinfo dpart;
    544    1.1   mycroft 	dev_t dev;
    545   1.66  perseant 	int error, i, ronly, secsize, fsbsize;
    546  1.210      elad 	kauth_cred_t cred;
    547   1.59  perseant 	CLEANERINFO *cip;
    548   1.96  perseant 	SEGUSE *sup;
    549  1.217  perseant 	daddr_t sb_addr;
    550    1.1   mycroft 
    551  1.218        ad 	cred = l ? l->l_cred : NOCRED;
    552  1.161   mycroft 
    553    1.1   mycroft 	/*
    554    1.1   mycroft 	 * Flush out any old buffers remaining from a previous use.
    555    1.1   mycroft 	 */
    556  1.161   mycroft 	vn_lock(devvp, LK_EXCLUSIVE | LK_RETRY);
    557  1.190  christos 	error = vinvalbuf(devvp, V_SAVE, cred, l, 0, 0);
    558  1.161   mycroft 	VOP_UNLOCK(devvp, 0);
    559  1.161   mycroft 	if (error)
    560    1.1   mycroft 		return (error);
    561    1.1   mycroft 
    562    1.1   mycroft 	ronly = (mp->mnt_flag & MNT_RDONLY) != 0;
    563  1.190  christos 	if (VOP_IOCTL(devvp, DIOCGPART, &dpart, FREAD, cred, l) != 0)
    564   1.66  perseant 		secsize = DEV_BSIZE;
    565   1.29   mycroft 	else
    566   1.66  perseant 		secsize = dpart.disklab->d_secsize;
    567    1.1   mycroft 
    568    1.1   mycroft 	/* Don't free random space on error. */
    569    1.1   mycroft 	bp = NULL;
    570   1.50  perseant 	abp = NULL;
    571    1.1   mycroft 	ump = NULL;
    572    1.1   mycroft 
    573   1.66  perseant 	sb_addr = LFS_LABELPAD / secsize;
    574   1.70       chs 	while (1) {
    575   1.66  perseant 		/* Read in the superblock. */
    576   1.66  perseant 		error = bread(devvp, sb_addr, LFS_SBPAD, cred, &bp);
    577   1.66  perseant 		if (error)
    578   1.66  perseant 			goto out;
    579   1.66  perseant 		dfs = (struct dlfs *)bp->b_data;
    580    1.1   mycroft 
    581   1.66  perseant 		/* Check the basics. */
    582  1.163  perseant 		if (dfs->dlfs_magic != LFS_MAGIC || dfs->dlfs_bsize > MAXBSIZE ||
    583   1.66  perseant 		    dfs->dlfs_version > LFS_VERSION ||
    584   1.66  perseant 		    dfs->dlfs_bsize < sizeof(struct dlfs)) {
    585  1.166  perseant 			DLOG((DLOG_MOUNT, "lfs_mountfs: primary superblock sanity failed\n"));
    586   1.66  perseant 			error = EINVAL;		/* XXX needs translation */
    587   1.66  perseant 			goto out;
    588   1.66  perseant 		}
    589  1.166  perseant 		if (dfs->dlfs_inodefmt > LFS_MAXINODEFMT) {
    590  1.166  perseant 			DLOG((DLOG_MOUNT, "lfs_mountfs: unknown inode format %d\n",
    591  1.166  perseant 			       dfs->dlfs_inodefmt));
    592  1.166  perseant 			error = EINVAL;
    593  1.166  perseant 			goto out;
    594  1.166  perseant 		}
    595  1.164     perry 
    596  1.164     perry 		if (dfs->dlfs_version == 1)
    597   1.66  perseant 			fsbsize = secsize;
    598   1.66  perseant 		else {
    599  1.164     perry 			fsbsize = 1 << (dfs->dlfs_bshift - dfs->dlfs_blktodb +
    600   1.66  perseant 				dfs->dlfs_fsbtodb);
    601   1.66  perseant 			/*
    602   1.66  perseant 			 * Could be, if the frag size is large enough, that we
    603   1.66  perseant 			 * don't have the "real" primary superblock.  If that's
    604   1.66  perseant 			 * the case, get the real one, and try again.
    605   1.66  perseant 			 */
    606   1.66  perseant 			if (sb_addr != dfs->dlfs_sboffs[0] <<
    607   1.96  perseant 				       dfs->dlfs_fsbtodb) {
    608  1.166  perseant 				DLOG((DLOG_MOUNT, "lfs_mountfs: sb daddr"
    609  1.166  perseant 				      " 0x%llx is not right, trying 0x%llx\n",
    610  1.166  perseant 				      (long long)sb_addr,
    611  1.166  perseant 				      (long long)(dfs->dlfs_sboffs[0] <<
    612  1.166  perseant 						  dfs->dlfs_fsbtodb)));
    613  1.164     perry 				sb_addr = dfs->dlfs_sboffs[0] <<
    614   1.66  perseant 					  dfs->dlfs_fsbtodb;
    615   1.66  perseant 				brelse(bp);
    616   1.66  perseant 				continue;
    617   1.66  perseant 			}
    618   1.66  perseant 		}
    619   1.66  perseant 		break;
    620   1.50  perseant 	}
    621   1.50  perseant 
    622   1.26  perseant 	/*
    623   1.26  perseant 	 * Check the second superblock to see which is newer; then mount
    624   1.96  perseant 	 * using the older of the two.	This is necessary to ensure that
    625   1.26  perseant 	 * the filesystem is valid if it was not unmounted cleanly.
    626   1.26  perseant 	 */
    627   1.60  perseant 
    628   1.50  perseant 	if (dfs->dlfs_sboffs[1] &&
    629   1.66  perseant 	    dfs->dlfs_sboffs[1] - LFS_LABELPAD / fsbsize > LFS_SBPAD / fsbsize)
    630   1.50  perseant 	{
    631  1.164     perry 		error = bread(devvp, dfs->dlfs_sboffs[1] * (fsbsize / secsize),
    632   1.66  perseant 			LFS_SBPAD, cred, &abp);
    633   1.50  perseant 		if (error)
    634   1.50  perseant 			goto out;
    635   1.50  perseant 		adfs = (struct dlfs *)abp->b_data;
    636   1.50  perseant 
    637   1.66  perseant 		if (dfs->dlfs_version == 1) {
    638   1.66  perseant 			/* 1s resolution comparison */
    639   1.66  perseant 			if (adfs->dlfs_tstamp < dfs->dlfs_tstamp)
    640   1.66  perseant 				tdfs = adfs;
    641   1.66  perseant 			else
    642   1.66  perseant 				tdfs = dfs;
    643   1.66  perseant 		} else {
    644   1.66  perseant 			/* monotonic infinite-resolution comparison */
    645   1.66  perseant 			if (adfs->dlfs_serial < dfs->dlfs_serial)
    646   1.66  perseant 				tdfs = adfs;
    647   1.66  perseant 			else
    648   1.66  perseant 				tdfs = dfs;
    649   1.66  perseant 		}
    650   1.60  perseant 
    651   1.60  perseant 		/* Check the basics. */
    652   1.60  perseant 		if (tdfs->dlfs_magic != LFS_MAGIC ||
    653   1.60  perseant 		    tdfs->dlfs_bsize > MAXBSIZE ||
    654   1.96  perseant 		    tdfs->dlfs_version > LFS_VERSION ||
    655   1.96  perseant 		    tdfs->dlfs_bsize < sizeof(struct dlfs)) {
    656  1.166  perseant 			DLOG((DLOG_MOUNT, "lfs_mountfs: alt superblock"
    657  1.166  perseant 			      " sanity failed\n"));
    658   1.60  perseant 			error = EINVAL;		/* XXX needs translation */
    659   1.60  perseant 			goto out;
    660   1.60  perseant 		}
    661   1.50  perseant 	} else {
    662  1.166  perseant 		DLOG((DLOG_MOUNT, "lfs_mountfs: invalid alt superblock"
    663  1.166  perseant 		      " daddr=0x%x\n", dfs->dlfs_sboffs[1]));
    664   1.50  perseant 		error = EINVAL;
    665    1.1   mycroft 		goto out;
    666    1.1   mycroft 	}
    667    1.1   mycroft 
    668    1.1   mycroft 	/* Allocate the mount structure, copy the superblock into it. */
    669   1.84      yamt 	fs = malloc(sizeof(struct lfs), M_UFSMNT, M_WAITOK | M_ZERO);
    670   1.60  perseant 	memcpy(&fs->lfs_dlfs, tdfs, sizeof(struct dlfs));
    671   1.60  perseant 
    672   1.66  perseant 	/* Compatibility */
    673   1.66  perseant 	if (fs->lfs_version < 2) {
    674   1.66  perseant 		fs->lfs_sumsize = LFS_V1_SUMMARY_SIZE;
    675   1.66  perseant 		fs->lfs_ibsize = fs->lfs_bsize;
    676   1.66  perseant 		fs->lfs_start = fs->lfs_sboffs[0];
    677   1.66  perseant 		fs->lfs_tstamp = fs->lfs_otstamp;
    678   1.66  perseant 		fs->lfs_fsbtodb = 0;
    679   1.66  perseant 	}
    680  1.207  perseant 	if (fs->lfs_resvseg == 0)
    681  1.207  perseant 		fs->lfs_resvseg = MIN(fs->lfs_minfreeseg - 1, \
    682  1.207  perseant 			MAX(MIN_RESV_SEGS, fs->lfs_minfreeseg / 2 + 1));
    683   1.66  perseant 
    684  1.163  perseant 	/*
    685  1.163  perseant 	 * If we aren't going to be able to write meaningfully to this
    686  1.163  perseant 	 * filesystem, and were not mounted readonly, bomb out now.
    687  1.163  perseant 	 */
    688  1.163  perseant 	if (fsbtob(fs, LFS_NRESERVE(fs)) > LFS_MAX_BYTES && !ronly) {
    689  1.166  perseant 		DLOG((DLOG_MOUNT, "lfs_mount: to mount this filesystem read/write,"
    690  1.166  perseant 		      " we need BUFPAGES >= %lld\n",
    691  1.166  perseant 		      (long long)((bufmem_hiwater / bufmem_lowater) *
    692  1.166  perseant 				  LFS_INVERSE_MAX_BYTES(
    693  1.166  perseant 					  fsbtob(fs, LFS_NRESERVE(fs))) >> PAGE_SHIFT)));
    694  1.163  perseant 		free(fs, M_UFSMNT);
    695  1.163  perseant 		error = EFBIG; /* XXX needs translation */
    696  1.163  perseant 		goto out;
    697  1.163  perseant 	}
    698  1.164     perry 
    699   1.60  perseant 	/* Before rolling forward, lock so vget will sleep for other procs */
    700  1.218        ad 	if (l != NULL) {
    701  1.205  perseant 		fs->lfs_flags = LFS_NOTYET;
    702  1.218        ad 		fs->lfs_rfpid = l->l_proc->p_pid;
    703  1.205  perseant 	}
    704   1.60  perseant 
    705   1.84      yamt 	ump = malloc(sizeof *ump, M_UFSMNT, M_WAITOK | M_ZERO);
    706   1.29   mycroft 	ump->um_lfs = fs;
    707  1.188      yamt 	ump->um_ops = &lfs_ufsops;
    708  1.113      fvdl 	ump->um_fstype = UFS1;
    709   1.60  perseant 	if (sizeof(struct lfs) < LFS_SBPAD) {			/* XXX why? */
    710    1.1   mycroft 		bp->b_flags |= B_INVAL;
    711   1.60  perseant 		abp->b_flags |= B_INVAL;
    712   1.60  perseant 	}
    713    1.1   mycroft 	brelse(bp);
    714    1.1   mycroft 	bp = NULL;
    715   1.26  perseant 	brelse(abp);
    716   1.26  perseant 	abp = NULL;
    717    1.1   mycroft 
    718    1.1   mycroft 	/* Set up the I/O information */
    719   1.66  perseant 	fs->lfs_devbsize = secsize;
    720    1.1   mycroft 	fs->lfs_iocount = 0;
    721   1.34  perseant 	fs->lfs_diropwait = 0;
    722   1.26  perseant 	fs->lfs_activesb = 0;
    723   1.57  perseant 	fs->lfs_uinodes = 0;
    724   1.58  perseant 	fs->lfs_ravail = 0;
    725  1.163  perseant 	fs->lfs_favail = 0;
    726   1.51   thorpej 	fs->lfs_sbactive = 0;
    727    1.1   mycroft 
    728    1.1   mycroft 	/* Set up the ifile and lock aflags */
    729    1.1   mycroft 	fs->lfs_doifile = 0;
    730    1.1   mycroft 	fs->lfs_writer = 0;
    731    1.1   mycroft 	fs->lfs_dirops = 0;
    732   1.52  perseant 	fs->lfs_nadirop = 0;
    733    1.1   mycroft 	fs->lfs_seglock = 0;
    734   1.91  perseant 	fs->lfs_pdflush = 0;
    735  1.112  perseant 	fs->lfs_sleepers = 0;
    736  1.163  perseant 	fs->lfs_pages = 0;
    737  1.105  perseant 	simple_lock_init(&fs->lfs_interlock);
    738  1.227        ad 	rw_init(&fs->lfs_fraglock);
    739  1.177  perseant 	lockinit(&fs->lfs_iflock, PINOD, "lfs_iflock", 0, 0);
    740  1.221  perseant 	lockinit(&fs->lfs_stoplock, PINOD, "lfs_stoplock", 0, 0);
    741    1.1   mycroft 
    742    1.1   mycroft 	/* Set the file system readonly/modify bits. */
    743    1.1   mycroft 	fs->lfs_ronly = ronly;
    744    1.1   mycroft 	if (ronly == 0)
    745    1.1   mycroft 		fs->lfs_fmod = 1;
    746    1.1   mycroft 
    747    1.1   mycroft 	/* Initialize the mount structure. */
    748    1.1   mycroft 	dev = devvp->v_rdev;
    749   1.79     soren 	mp->mnt_data = ump;
    750  1.147  christos 	mp->mnt_stat.f_fsidx.__fsid_val[0] = (long)dev;
    751  1.147  christos 	mp->mnt_stat.f_fsidx.__fsid_val[1] = makefstype(MOUNT_LFS);
    752  1.147  christos 	mp->mnt_stat.f_fsid = mp->mnt_stat.f_fsidx.__fsid_val[0];
    753  1.186  christos 	mp->mnt_stat.f_namemax = LFS_MAXNAMLEN;
    754   1.49  perseant 	mp->mnt_stat.f_iosize = fs->lfs_bsize;
    755    1.1   mycroft 	mp->mnt_flag |= MNT_LOCAL;
    756   1.91  perseant 	mp->mnt_fs_bshift = fs->lfs_bshift;
    757   1.18    bouyer 	ump->um_flags = 0;
    758    1.1   mycroft 	ump->um_mountp = mp;
    759    1.1   mycroft 	ump->um_dev = dev;
    760    1.1   mycroft 	ump->um_devvp = devvp;
    761   1.66  perseant 	ump->um_bptrtodb = fs->lfs_fsbtodb;
    762   1.66  perseant 	ump->um_seqinc = fragstofsb(fs, fs->lfs_frag);
    763    1.1   mycroft 	ump->um_nindir = fs->lfs_nindir;
    764   1.61       chs 	ump->um_lognindir = ffs(fs->lfs_nindir) - 1;
    765    1.1   mycroft 	for (i = 0; i < MAXQUOTAS; i++)
    766    1.1   mycroft 		ump->um_quotas[i] = NULLVP;
    767  1.156   mycroft 	ump->um_maxsymlinklen = fs->lfs_maxsymlinklen;
    768  1.157   mycroft 	ump->um_dirblksiz = DIRBLKSIZ;
    769  1.156   mycroft 	ump->um_maxfilesize = fs->lfs_maxfilesize;
    770  1.158   mycroft 	if (ump->um_maxsymlinklen > 0)
    771  1.158   mycroft 		mp->mnt_iflag |= IMNT_DTYPE;
    772   1.44      fvdl 	devvp->v_specmountpoint = mp;
    773    1.1   mycroft 
    774   1.91  perseant 	/* Set up reserved memory for pageout */
    775   1.91  perseant 	lfs_setup_resblks(fs);
    776   1.91  perseant 	/* Set up vdirop tailq */
    777   1.91  perseant 	TAILQ_INIT(&fs->lfs_dchainhd);
    778   1.91  perseant 	/* and paging tailq */
    779   1.91  perseant 	TAILQ_INIT(&fs->lfs_pchainhd);
    780  1.206  perseant 	/* and delayed segment accounting for truncation list */
    781  1.206  perseant 	LIST_INIT(&fs->lfs_segdhd);
    782   1.91  perseant 
    783    1.1   mycroft 	/*
    784    1.1   mycroft 	 * We use the ifile vnode for almost every operation.  Instead of
    785    1.1   mycroft 	 * retrieving it from the hash table each time we retrieve it here,
    786    1.1   mycroft 	 * artificially increment the reference count and keep a pointer
    787    1.1   mycroft 	 * to it in the incore copy of the superblock.
    788    1.1   mycroft 	 */
    789  1.120   thorpej 	if ((error = VFS_VGET(mp, LFS_IFILE_INUM, &vp)) != 0) {
    790  1.166  perseant 		DLOG((DLOG_MOUNT, "lfs_mountfs: ifile vget failed, error=%d\n", error));
    791    1.1   mycroft 		goto out;
    792   1.66  perseant 	}
    793    1.1   mycroft 	fs->lfs_ivnode = vp;
    794    1.1   mycroft 	VREF(vp);
    795   1.30  perseant 
    796  1.199  perseant 	/* Set up inode bitmap and order free list */
    797  1.199  perseant 	lfs_order_freelist(fs);
    798  1.199  perseant 
    799   1.91  perseant 	/* Set up segment usage flags for the autocleaner. */
    800  1.102  perseant 	fs->lfs_nactive = 0;
    801   1.91  perseant 	fs->lfs_suflags = (u_int32_t **)malloc(2 * sizeof(u_int32_t *),
    802   1.91  perseant 						M_SEGMENT, M_WAITOK);
    803   1.91  perseant 	fs->lfs_suflags[0] = (u_int32_t *)malloc(fs->lfs_nseg * sizeof(u_int32_t),
    804   1.91  perseant 						 M_SEGMENT, M_WAITOK);
    805   1.91  perseant 	fs->lfs_suflags[1] = (u_int32_t *)malloc(fs->lfs_nseg * sizeof(u_int32_t),
    806   1.91  perseant 						 M_SEGMENT, M_WAITOK);
    807   1.91  perseant 	memset(fs->lfs_suflags[1], 0, fs->lfs_nseg * sizeof(u_int32_t));
    808   1.91  perseant 	for (i = 0; i < fs->lfs_nseg; i++) {
    809  1.102  perseant 		int changed;
    810  1.102  perseant 
    811   1.91  perseant 		LFS_SEGENTRY(sup, fs, i, bp);
    812  1.102  perseant 		changed = 0;
    813  1.102  perseant 		if (!ronly) {
    814  1.102  perseant 			if (sup->su_nbytes == 0 &&
    815  1.102  perseant 			    !(sup->su_flags & SEGUSE_EMPTY)) {
    816  1.102  perseant 				sup->su_flags |= SEGUSE_EMPTY;
    817  1.102  perseant 				++changed;
    818  1.102  perseant 			} else if (!(sup->su_nbytes == 0) &&
    819  1.102  perseant 				   (sup->su_flags & SEGUSE_EMPTY)) {
    820  1.102  perseant 				sup->su_flags &= ~SEGUSE_EMPTY;
    821  1.102  perseant 				++changed;
    822  1.102  perseant 			}
    823  1.177  perseant 			if (sup->su_flags & (SEGUSE_ACTIVE|SEGUSE_INVAL)) {
    824  1.177  perseant 				sup->su_flags &= ~(SEGUSE_ACTIVE|SEGUSE_INVAL);
    825  1.102  perseant 				++changed;
    826  1.102  perseant 			}
    827  1.102  perseant 		}
    828  1.102  perseant 		fs->lfs_suflags[0][i] = sup->su_flags;
    829  1.102  perseant 		if (changed)
    830   1.91  perseant 			LFS_WRITESEGENTRY(sup, fs, i, bp);
    831  1.102  perseant 		else
    832   1.91  perseant 			brelse(bp);
    833   1.91  perseant 	}
    834   1.91  perseant 
    835  1.217  perseant #ifdef LFS_KERNEL_RFW
    836  1.217  perseant 	lfs_roll_forward(fs, mp, l);
    837  1.217  perseant #endif
    838   1.60  perseant 
    839   1.66  perseant 	/* If writing, sb is not clean; record in case of immediate crash */
    840   1.66  perseant 	if (!fs->lfs_ronly) {
    841   1.66  perseant 		fs->lfs_pflags &= ~LFS_PF_CLEAN;
    842   1.66  perseant 		lfs_writesuper(fs, fs->lfs_sboffs[0]);
    843  1.112  perseant 		lfs_writesuper(fs, fs->lfs_sboffs[1]);
    844   1.66  perseant 	}
    845  1.164     perry 
    846   1.60  perseant 	/* Allow vget now that roll-forward is complete */
    847   1.60  perseant 	fs->lfs_flags &= ~(LFS_NOTYET);
    848   1.60  perseant 	wakeup(&fs->lfs_flags);
    849   1.60  perseant 
    850   1.30  perseant 	/*
    851  1.164     perry 	 * Initialize the ifile cleaner info with information from
    852   1.59  perseant 	 * the superblock.
    853  1.164     perry 	 */
    854   1.59  perseant 	LFS_CLEANERINFO(cip, fs, bp);
    855   1.59  perseant 	cip->clean = fs->lfs_nclean;
    856   1.59  perseant 	cip->dirty = fs->lfs_nseg - fs->lfs_nclean;
    857   1.59  perseant 	cip->avail = fs->lfs_avail;
    858   1.59  perseant 	cip->bfree = fs->lfs_bfree;
    859   1.74  perseant 	(void) LFS_BWRITE_LOG(bp); /* Ifile */
    860   1.59  perseant 
    861   1.59  perseant 	/*
    862  1.164     perry 	 * Mark the current segment as ACTIVE, since we're going to
    863   1.30  perseant 	 * be writing to it.
    864   1.30  perseant 	 */
    865  1.164     perry 	LFS_SEGENTRY(sup, fs, dtosn(fs, fs->lfs_offset), bp);
    866   1.96  perseant 	sup->su_flags |= SEGUSE_DIRTY | SEGUSE_ACTIVE;
    867  1.102  perseant 	fs->lfs_nactive++;
    868   1.96  perseant 	LFS_WRITESEGENTRY(sup, fs, dtosn(fs, fs->lfs_offset), bp);  /* Ifile */
    869   1.74  perseant 
    870   1.74  perseant 	/* Now that roll-forward is done, unlock the Ifile */
    871   1.74  perseant 	vput(vp);
    872   1.74  perseant 
    873  1.163  perseant 	/* Start the pagedaemon-anticipating daemon */
    874  1.163  perseant 	if (lfs_writer_daemon == 0 &&
    875  1.163  perseant 	    kthread_create1(lfs_writerd, NULL, NULL, "lfs_writer") != 0)
    876  1.163  perseant 		panic("fork lfs_writer");
    877  1.163  perseant 
    878    1.1   mycroft 	return (0);
    879  1.161   mycroft 
    880    1.1   mycroft out:
    881    1.1   mycroft 	if (bp)
    882    1.1   mycroft 		brelse(bp);
    883   1.26  perseant 	if (abp)
    884   1.26  perseant 		brelse(abp);
    885    1.1   mycroft 	if (ump) {
    886    1.1   mycroft 		free(ump->um_lfs, M_UFSMNT);
    887    1.1   mycroft 		free(ump, M_UFSMNT);
    888   1.79     soren 		mp->mnt_data = NULL;
    889    1.1   mycroft 	}
    890   1.91  perseant 
    891    1.1   mycroft 	return (error);
    892    1.1   mycroft }
    893    1.1   mycroft 
    894    1.1   mycroft /*
    895    1.1   mycroft  * unmount system call
    896    1.1   mycroft  */
    897   1.10  christos int
    898  1.190  christos lfs_unmount(struct mount *mp, int mntflags, struct lwp *l)
    899    1.1   mycroft {
    900   1.48  augustss 	struct ufsmount *ump;
    901   1.48  augustss 	struct lfs *fs;
    902   1.77  perseant 	int error, flags, ronly;
    903  1.109  perseant 	int s;
    904    1.1   mycroft 
    905    1.1   mycroft 	flags = 0;
    906    1.5   mycroft 	if (mntflags & MNT_FORCE)
    907    1.1   mycroft 		flags |= FORCECLOSE;
    908    1.1   mycroft 
    909    1.1   mycroft 	ump = VFSTOUFS(mp);
    910    1.1   mycroft 	fs = ump->um_lfs;
    911  1.112  perseant 
    912  1.196  perseant 	/* Two checkpoints */
    913  1.235  perseant 	lfs_segwrite(mp, SEGM_CKP | SEGM_SYNC);
    914  1.235  perseant 	lfs_segwrite(mp, SEGM_CKP | SEGM_SYNC);
    915  1.195  perseant 
    916  1.112  perseant 	/* wake up the cleaner so it can die */
    917  1.214  perseant 	lfs_wakeup_cleaner(fs);
    918  1.112  perseant 	simple_lock(&fs->lfs_interlock);
    919  1.112  perseant 	while (fs->lfs_sleepers)
    920  1.112  perseant 		ltsleep(&fs->lfs_sleepers, PRIBIO + 1, "lfs_sleepers", 0,
    921  1.112  perseant 			&fs->lfs_interlock);
    922  1.112  perseant 	simple_unlock(&fs->lfs_interlock);
    923  1.112  perseant 
    924    1.1   mycroft #ifdef QUOTA
    925    1.1   mycroft 	if (mp->mnt_flag & MNT_QUOTA) {
    926   1.11        pk 		int i;
    927   1.10  christos 		error = vflush(mp, fs->lfs_ivnode, SKIPSYSTEM|flags);
    928   1.10  christos 		if (error)
    929    1.1   mycroft 			return (error);
    930    1.1   mycroft 		for (i = 0; i < MAXQUOTAS; i++) {
    931    1.1   mycroft 			if (ump->um_quotas[i] == NULLVP)
    932    1.1   mycroft 				continue;
    933  1.190  christos 			quotaoff(l, mp, i);
    934    1.1   mycroft 		}
    935    1.1   mycroft 		/*
    936    1.1   mycroft 		 * Here we fall through to vflush again to ensure
    937    1.1   mycroft 		 * that we have gotten rid of all the system vnodes.
    938    1.1   mycroft 		 */
    939    1.1   mycroft 	}
    940    1.1   mycroft #endif
    941   1.10  christos 	if ((error = vflush(mp, fs->lfs_ivnode, flags)) != 0)
    942    1.1   mycroft 		return (error);
    943  1.218        ad 	if ((error = VFS_SYNC(mp, 1, l->l_cred, l)) != 0)
    944    1.1   mycroft 		return (error);
    945  1.109  perseant 	s = splbio();
    946   1.76  perseant 	if (LIST_FIRST(&fs->lfs_ivnode->v_dirtyblkhd))
    947   1.82    provos 		panic("lfs_unmount: still dirty blocks on ifile vnode");
    948  1.109  perseant 	splx(s);
    949   1.66  perseant 
    950  1.109  perseant 	/* Explicitly write the superblock, to update serial and pflags */
    951  1.109  perseant 	fs->lfs_pflags |= LFS_PF_CLEAN;
    952  1.109  perseant 	lfs_writesuper(fs, fs->lfs_sboffs[0]);
    953  1.109  perseant 	lfs_writesuper(fs, fs->lfs_sboffs[1]);
    954  1.169  perseant 	simple_lock(&fs->lfs_interlock);
    955  1.109  perseant 	while (fs->lfs_iocount)
    956  1.169  perseant 		ltsleep(&fs->lfs_iocount, PRIBIO + 1, "lfs_umount", 0,
    957  1.169  perseant 			&fs->lfs_interlock);
    958  1.169  perseant 	simple_unlock(&fs->lfs_interlock);
    959  1.109  perseant 
    960   1.66  perseant 	/* Finish with the Ifile, now that we're done with it */
    961    1.1   mycroft 	vrele(fs->lfs_ivnode);
    962    1.1   mycroft 	vgone(fs->lfs_ivnode);
    963   1.66  perseant 
    964    1.1   mycroft 	ronly = !fs->lfs_ronly;
    965   1.40     enami 	if (ump->um_devvp->v_type != VBAD)
    966   1.44      fvdl 		ump->um_devvp->v_specmountpoint = NULL;
    967   1.39  wrstuden 	vn_lock(ump->um_devvp, LK_EXCLUSIVE | LK_RETRY);
    968    1.1   mycroft 	error = VOP_CLOSE(ump->um_devvp,
    969  1.190  christos 	    ronly ? FREAD : FREAD|FWRITE, NOCRED, l);
    970   1.39  wrstuden 	vput(ump->um_devvp);
    971   1.26  perseant 
    972  1.176  perseant 	/* Complain about page leakage */
    973  1.176  perseant 	if (fs->lfs_pages > 0)
    974  1.176  perseant 		printf("lfs_unmount: still claim %d pages (%d in subsystem)\n",
    975  1.176  perseant 			fs->lfs_pages, lfs_subsys_pages);
    976  1.176  perseant 
    977   1.91  perseant 	/* Free per-mount data structures */
    978  1.202  perseant 	free(fs->lfs_ino_bitmap, M_SEGMENT);
    979   1.91  perseant 	free(fs->lfs_suflags[0], M_SEGMENT);
    980   1.91  perseant 	free(fs->lfs_suflags[1], M_SEGMENT);
    981   1.91  perseant 	free(fs->lfs_suflags, M_SEGMENT);
    982   1.91  perseant 	lfs_free_resblks(fs);
    983  1.228        ad 	rw_destroy(&fs->lfs_fraglock);
    984    1.1   mycroft 	free(fs, M_UFSMNT);
    985    1.1   mycroft 	free(ump, M_UFSMNT);
    986   1.91  perseant 
    987   1.79     soren 	mp->mnt_data = NULL;
    988    1.1   mycroft 	mp->mnt_flag &= ~MNT_LOCAL;
    989    1.1   mycroft 	return (error);
    990    1.1   mycroft }
    991    1.1   mycroft 
    992    1.1   mycroft /*
    993    1.1   mycroft  * Get file system statistics.
    994  1.169  perseant  *
    995  1.169  perseant  * NB: We don't lock to access the superblock here, because it's not
    996  1.169  perseant  * really that important if we get it wrong.
    997    1.1   mycroft  */
    998   1.10  christos int
    999  1.224  christos lfs_statvfs(struct mount *mp, struct statvfs *sbp, struct lwp *l)
   1000    1.1   mycroft {
   1001   1.48  augustss 	struct lfs *fs;
   1002   1.48  augustss 	struct ufsmount *ump;
   1003    1.1   mycroft 
   1004    1.1   mycroft 	ump = VFSTOUFS(mp);
   1005    1.1   mycroft 	fs = ump->um_lfs;
   1006    1.1   mycroft 	if (fs->lfs_magic != LFS_MAGIC)
   1007  1.147  christos 		panic("lfs_statvfs: magic");
   1008   1.53  perseant 
   1009  1.147  christos 	sbp->f_bsize = fs->lfs_bsize;
   1010  1.148      yamt 	sbp->f_frsize = fs->lfs_fsize;
   1011    1.1   mycroft 	sbp->f_iosize = fs->lfs_bsize;
   1012  1.194       tls 	sbp->f_blocks = fsbtofrags(fs, LFS_EST_NONMETA(fs) - VTOI(fs->lfs_ivnode)->i_lfs_effnblks);
   1013  1.163  perseant 
   1014   1.66  perseant 	sbp->f_bfree = fsbtofrags(fs, LFS_EST_BFREE(fs));
   1015  1.163  perseant 	KASSERT(sbp->f_bfree <= fs->lfs_dsize);
   1016  1.220  christos #if 0
   1017  1.163  perseant 	if (sbp->f_bfree < 0)
   1018  1.163  perseant 		sbp->f_bfree = 0;
   1019  1.220  christos #endif
   1020  1.163  perseant 
   1021  1.147  christos 	sbp->f_bresvd = fsbtofrags(fs, LFS_EST_RSVD(fs));
   1022  1.147  christos 	if (sbp->f_bfree > sbp->f_bresvd)
   1023  1.147  christos 		sbp->f_bavail = sbp->f_bfree - sbp->f_bresvd;
   1024  1.147  christos 	else
   1025  1.147  christos 		sbp->f_bavail = 0;
   1026  1.164     perry 
   1027   1.66  perseant 	sbp->f_files = fs->lfs_bfree / btofsb(fs, fs->lfs_ibsize) * INOPB(fs);
   1028   1.31  perseant 	sbp->f_ffree = sbp->f_files - fs->lfs_nfiles;
   1029  1.147  christos 	sbp->f_favail = sbp->f_ffree;
   1030  1.147  christos 	sbp->f_fresvd = 0;
   1031  1.147  christos 	copy_statvfs_info(sbp, mp);
   1032    1.1   mycroft 	return (0);
   1033    1.1   mycroft }
   1034    1.1   mycroft 
   1035    1.1   mycroft /*
   1036    1.1   mycroft  * Go through the disk queues to initiate sandbagged IO;
   1037    1.1   mycroft  * go through the inodes to write those that have been modified;
   1038    1.1   mycroft  * initiate the writing of the super block if it has been modified.
   1039    1.1   mycroft  *
   1040    1.1   mycroft  * Note: we are always called with the filesystem marked `MPBUSY'.
   1041    1.1   mycroft  */
   1042   1.10  christos int
   1043  1.224  christos lfs_sync(struct mount *mp, int waitfor, kauth_cred_t cred,
   1044  1.224  christos     struct lwp *l)
   1045    1.1   mycroft {
   1046    1.1   mycroft 	int error;
   1047   1.26  perseant 	struct lfs *fs;
   1048   1.26  perseant 
   1049  1.123      yamt 	fs = VFSTOUFS(mp)->um_lfs;
   1050   1.56  perseant 	if (fs->lfs_ronly)
   1051   1.56  perseant 		return 0;
   1052  1.206  perseant 
   1053  1.206  perseant 	/* Snapshots should not hose the syncer */
   1054  1.206  perseant 	/*
   1055  1.206  perseant 	 * XXX Sync can block here anyway, since we don't have a very
   1056  1.206  perseant 	 * XXX good idea of how much data is pending.  If it's more
   1057  1.206  perseant 	 * XXX than a segment and lfs_nextseg is close to the end of
   1058  1.206  perseant 	 * XXX the log, we'll likely block.
   1059  1.206  perseant 	 */
   1060  1.206  perseant 	simple_lock(&fs->lfs_interlock);
   1061  1.206  perseant 	if (fs->lfs_nowrap && fs->lfs_nextseg < fs->lfs_curseg) {
   1062  1.206  perseant 		simple_unlock(&fs->lfs_interlock);
   1063  1.206  perseant 		return 0;
   1064  1.206  perseant 	}
   1065  1.206  perseant 	simple_unlock(&fs->lfs_interlock);
   1066  1.206  perseant 
   1067  1.122      yamt 	lfs_writer_enter(fs, "lfs_dirops");
   1068    1.1   mycroft 
   1069    1.1   mycroft 	/* All syncs must be checkpoints until roll-forward is implemented. */
   1070  1.206  perseant 	DLOG((DLOG_FLUSH, "lfs_sync at 0x%x\n", fs->lfs_offset));
   1071    1.1   mycroft 	error = lfs_segwrite(mp, SEGM_CKP | (waitfor ? SEGM_SYNC : 0));
   1072  1.122      yamt 	lfs_writer_leave(fs);
   1073    1.1   mycroft #ifdef QUOTA
   1074  1.121      fvdl 	qsync(mp);
   1075    1.1   mycroft #endif
   1076    1.1   mycroft 	return (error);
   1077    1.1   mycroft }
   1078    1.1   mycroft 
   1079  1.227        ad extern kmutex_t ufs_hashlock;
   1080   1.26  perseant 
   1081    1.1   mycroft /*
   1082    1.1   mycroft  * Look up an LFS dinode number to find its incore vnode.  If not already
   1083    1.1   mycroft  * in core, read it in from the specified device.  Return the inode locked.
   1084    1.1   mycroft  * Detection and handling of mount points must be done by the calling routine.
   1085    1.1   mycroft  */
   1086    1.1   mycroft int
   1087  1.120   thorpej lfs_vget(struct mount *mp, ino_t ino, struct vnode **vpp)
   1088    1.1   mycroft {
   1089   1.48  augustss 	struct lfs *fs;
   1090  1.113      fvdl 	struct ufs1_dinode *dip;
   1091   1.48  augustss 	struct inode *ip;
   1092    1.1   mycroft 	struct buf *bp;
   1093    1.1   mycroft 	struct ifile *ifp;
   1094    1.1   mycroft 	struct vnode *vp;
   1095    1.1   mycroft 	struct ufsmount *ump;
   1096   1.85      fvdl 	daddr_t daddr;
   1097    1.1   mycroft 	dev_t dev;
   1098  1.107      yamt 	int error, retries;
   1099   1.26  perseant 	struct timespec ts;
   1100    1.1   mycroft 
   1101  1.208       mrg 	memset(&ts, 0, sizeof ts);	/* XXX gcc */
   1102  1.208       mrg 
   1103    1.1   mycroft 	ump = VFSTOUFS(mp);
   1104    1.1   mycroft 	dev = ump->um_dev;
   1105   1.60  perseant 	fs = ump->um_lfs;
   1106   1.60  perseant 
   1107   1.60  perseant 	/*
   1108   1.60  perseant 	 * If the filesystem is not completely mounted yet, suspend
   1109   1.60  perseant 	 * any access requests (wait for roll-forward to complete).
   1110   1.60  perseant 	 */
   1111  1.169  perseant 	simple_lock(&fs->lfs_interlock);
   1112   1.70       chs 	while ((fs->lfs_flags & LFS_NOTYET) && curproc->p_pid != fs->lfs_rfpid)
   1113  1.169  perseant 		ltsleep(&fs->lfs_flags, PRIBIO+1, "lfs_notyet", 0,
   1114  1.169  perseant 			&fs->lfs_interlock);
   1115  1.169  perseant 	simple_unlock(&fs->lfs_interlock);
   1116   1.26  perseant 
   1117  1.120   thorpej 	if ((*vpp = ufs_ihashget(dev, ino, LK_EXCLUSIVE)) != NULL)
   1118   1.55      fvdl 		return (0);
   1119   1.55      fvdl 
   1120   1.55      fvdl 	if ((error = getnewvnode(VT_LFS, mp, lfs_vnodeop_p, &vp)) != 0) {
   1121   1.55      fvdl 		*vpp = NULL;
   1122   1.55      fvdl 		 return (error);
   1123   1.55      fvdl 	}
   1124   1.55      fvdl 
   1125  1.227        ad 	mutex_enter(&ufs_hashlock);
   1126  1.227        ad 	if ((*vpp = ufs_ihashget(dev, ino, LK_EXCLUSIVE)) != NULL) {
   1127  1.227        ad 		mutex_exit(&ufs_hashlock);
   1128  1.227        ad 		ungetnewvnode(vp);
   1129  1.227        ad 		return (0);
   1130  1.227        ad 	}
   1131    1.1   mycroft 
   1132    1.1   mycroft 	/* Translate the inode number to a disk address. */
   1133    1.1   mycroft 	if (ino == LFS_IFILE_INUM)
   1134    1.1   mycroft 		daddr = fs->lfs_idaddr;
   1135    1.1   mycroft 	else {
   1136   1.60  perseant 		/* XXX bounds-check this too */
   1137    1.1   mycroft 		LFS_IENTRY(ifp, fs, ino, bp);
   1138    1.1   mycroft 		daddr = ifp->if_daddr;
   1139   1.66  perseant 		if (fs->lfs_version > 1) {
   1140   1.66  perseant 			ts.tv_sec = ifp->if_atime_sec;
   1141   1.66  perseant 			ts.tv_nsec = ifp->if_atime_nsec;
   1142   1.66  perseant 		}
   1143   1.66  perseant 
   1144    1.1   mycroft 		brelse(bp);
   1145   1.26  perseant 		if (daddr == LFS_UNUSED_DADDR) {
   1146   1.60  perseant 			*vpp = NULLVP;
   1147  1.229        ad 			mutex_exit(&ufs_hashlock);
   1148   1.60  perseant 			ungetnewvnode(vp);
   1149    1.1   mycroft 			return (ENOENT);
   1150   1.26  perseant 		}
   1151    1.1   mycroft 	}
   1152    1.1   mycroft 
   1153   1.55      fvdl 	/* Allocate/init new vnode/inode. */
   1154   1.55      fvdl 	lfs_vcreate(mp, ino, vp);
   1155    1.1   mycroft 
   1156    1.1   mycroft 	/*
   1157    1.1   mycroft 	 * Put it onto its hash chain and lock it so that other requests for
   1158    1.1   mycroft 	 * this inode will block if they arrive while we are sleeping waiting
   1159    1.1   mycroft 	 * for old data structures to be purged or for the contents of the
   1160    1.1   mycroft 	 * disk portion of this inode to be read.
   1161    1.1   mycroft 	 */
   1162    1.1   mycroft 	ip = VTOI(vp);
   1163    1.1   mycroft 	ufs_ihashins(ip);
   1164  1.227        ad 	mutex_exit(&ufs_hashlock);
   1165    1.1   mycroft 
   1166    1.1   mycroft 	/*
   1167    1.1   mycroft 	 * XXX
   1168    1.1   mycroft 	 * This may not need to be here, logically it should go down with
   1169    1.1   mycroft 	 * the i_devvp initialization.
   1170    1.1   mycroft 	 * Ask Kirk.
   1171    1.1   mycroft 	 */
   1172    1.1   mycroft 	ip->i_lfs = ump->um_lfs;
   1173    1.1   mycroft 
   1174    1.1   mycroft 	/* Read in the disk contents for the inode, copy into the inode. */
   1175   1.74  perseant 	retries = 0;
   1176   1.74  perseant     again:
   1177  1.164     perry 	error = bread(ump->um_devvp, fsbtodb(fs, daddr),
   1178   1.74  perseant 		(fs->lfs_version == 1 ? fs->lfs_bsize : fs->lfs_ibsize),
   1179   1.66  perseant 		NOCRED, &bp);
   1180   1.10  christos 	if (error) {
   1181    1.1   mycroft 		/*
   1182    1.1   mycroft 		 * The inode does not contain anything useful, so it would
   1183    1.1   mycroft 		 * be misleading to leave it on its hash chain. With mode
   1184    1.1   mycroft 		 * still zero, it will be unlinked and returned to the free
   1185    1.1   mycroft 		 * list by vput().
   1186    1.1   mycroft 		 */
   1187    1.1   mycroft 		vput(vp);
   1188    1.1   mycroft 		brelse(bp);
   1189    1.1   mycroft 		*vpp = NULL;
   1190    1.1   mycroft 		return (error);
   1191    1.1   mycroft 	}
   1192   1.74  perseant 
   1193   1.74  perseant 	dip = lfs_ifind(fs, ino, bp);
   1194   1.74  perseant 	if (dip == NULL) {
   1195   1.74  perseant 		/* Assume write has not completed yet; try again */
   1196   1.74  perseant 		bp->b_flags |= B_INVAL;
   1197   1.74  perseant 		brelse(bp);
   1198   1.74  perseant 		++retries;
   1199   1.74  perseant 		if (retries > LFS_IFIND_RETRIES) {
   1200   1.74  perseant #ifdef DEBUG
   1201   1.74  perseant 			/* If the seglock is held look at the bpp to see
   1202   1.74  perseant 			   what is there anyway */
   1203  1.169  perseant 			simple_lock(&fs->lfs_interlock);
   1204   1.74  perseant 			if (fs->lfs_seglock > 0) {
   1205   1.74  perseant 				struct buf **bpp;
   1206  1.113      fvdl 				struct ufs1_dinode *dp;
   1207   1.74  perseant 				int i;
   1208   1.74  perseant 
   1209   1.74  perseant 				for (bpp = fs->lfs_sp->bpp;
   1210   1.74  perseant 				     bpp != fs->lfs_sp->cbpp; ++bpp) {
   1211   1.74  perseant 					if ((*bpp)->b_vp == fs->lfs_ivnode &&
   1212   1.74  perseant 					    bpp != fs->lfs_sp->bpp) {
   1213   1.74  perseant 						/* Inode block */
   1214  1.166  perseant 						printf("lfs_vget: block 0x%" PRIx64 ": ",
   1215  1.166  perseant 						       (*bpp)->b_blkno);
   1216  1.113      fvdl 						dp = (struct ufs1_dinode *)(*bpp)->b_data;
   1217   1.74  perseant 						for (i = 0; i < INOPB(fs); i++)
   1218   1.74  perseant 							if (dp[i].di_u.inumber)
   1219   1.74  perseant 								printf("%d ", dp[i].di_u.inumber);
   1220   1.74  perseant 						printf("\n");
   1221   1.74  perseant 					}
   1222   1.74  perseant 				}
   1223   1.74  perseant 			}
   1224  1.169  perseant 			simple_unlock(&fs->lfs_interlock);
   1225  1.166  perseant #endif /* DEBUG */
   1226   1.74  perseant 			panic("lfs_vget: dinode not found");
   1227   1.74  perseant 		}
   1228  1.169  perseant 		simple_lock(&fs->lfs_interlock);
   1229  1.169  perseant 		if (fs->lfs_iocount) {
   1230  1.169  perseant 			DLOG((DLOG_VNODE, "lfs_vget: dinode %d not found, retrying...\n", ino));
   1231  1.169  perseant 			(void)ltsleep(&fs->lfs_iocount, PRIBIO + 1,
   1232  1.169  perseant 				      "lfs ifind", 1, &fs->lfs_interlock);
   1233  1.169  perseant 		} else
   1234  1.169  perseant 			retries = LFS_IFIND_RETRIES;
   1235  1.169  perseant 		simple_unlock(&fs->lfs_interlock);
   1236   1.74  perseant 		goto again;
   1237   1.74  perseant 	}
   1238  1.113      fvdl 	*ip->i_din.ffs1_din = *dip;
   1239  1.107      yamt 	brelse(bp);
   1240   1.74  perseant 
   1241   1.66  perseant 	if (fs->lfs_version > 1) {
   1242  1.113      fvdl 		ip->i_ffs1_atime = ts.tv_sec;
   1243  1.113      fvdl 		ip->i_ffs1_atimensec = ts.tv_nsec;
   1244   1.66  perseant 	}
   1245    1.1   mycroft 
   1246  1.139      yamt 	lfs_vinit(mp, &vp);
   1247   1.71       chs 
   1248    1.1   mycroft 	*vpp = vp;
   1249   1.62  perseant 
   1250  1.107      yamt 	KASSERT(VOP_ISLOCKED(vp));
   1251   1.26  perseant 
   1252    1.1   mycroft 	return (0);
   1253    1.1   mycroft }
   1254    1.1   mycroft 
   1255    1.1   mycroft /*
   1256    1.1   mycroft  * File handle to vnode
   1257    1.1   mycroft  */
   1258    1.1   mycroft int
   1259  1.120   thorpej lfs_fhtovp(struct mount *mp, struct fid *fhp, struct vnode **vpp)
   1260    1.1   mycroft {
   1261  1.216    martin 	struct lfid lfh;
   1262  1.115  perseant 	struct buf *bp;
   1263  1.115  perseant 	IFILE *ifp;
   1264  1.115  perseant 	int32_t daddr;
   1265  1.115  perseant 	struct lfs *fs;
   1266  1.115  perseant 
   1267  1.216    martin 	if (fhp->fid_len != sizeof(struct lfid))
   1268  1.216    martin 		return EINVAL;
   1269  1.216    martin 
   1270  1.216    martin 	memcpy(&lfh, fhp, sizeof(lfh));
   1271  1.216    martin 	if (lfh.lfid_ino < LFS_IFILE_INUM)
   1272  1.115  perseant 		return ESTALE;
   1273  1.115  perseant 
   1274  1.115  perseant 	fs = VFSTOUFS(mp)->um_lfs;
   1275  1.216    martin 	if (lfh.lfid_ident != fs->lfs_ident)
   1276  1.115  perseant 		return ESTALE;
   1277  1.115  perseant 
   1278  1.216    martin 	if (lfh.lfid_ino >
   1279  1.115  perseant 	    ((VTOI(fs->lfs_ivnode)->i_ffs1_size >> fs->lfs_bshift) -
   1280  1.115  perseant 	     fs->lfs_cleansz - fs->lfs_segtabsz) * fs->lfs_ifpb)
   1281  1.115  perseant 		return ESTALE;
   1282  1.115  perseant 
   1283  1.216    martin 	if (ufs_ihashlookup(VFSTOUFS(mp)->um_dev, lfh.lfid_ino) == NULLVP) {
   1284  1.216    martin 		LFS_IENTRY(ifp, fs, lfh.lfid_ino, bp);
   1285  1.115  perseant 		daddr = ifp->if_daddr;
   1286  1.115  perseant 		brelse(bp);
   1287  1.115  perseant 		if (daddr == LFS_UNUSED_DADDR)
   1288  1.115  perseant 			return ESTALE;
   1289  1.115  perseant 	}
   1290    1.1   mycroft 
   1291  1.216    martin 	return (ufs_fhtovp(mp, &lfh.lfid_ufid, vpp));
   1292    1.1   mycroft }
   1293    1.1   mycroft 
   1294    1.1   mycroft /*
   1295    1.1   mycroft  * Vnode pointer to File handle
   1296    1.1   mycroft  */
   1297    1.1   mycroft /* ARGSUSED */
   1298   1.10  christos int
   1299  1.216    martin lfs_vptofh(struct vnode *vp, struct fid *fhp, size_t *fh_size)
   1300    1.1   mycroft {
   1301   1.48  augustss 	struct inode *ip;
   1302  1.216    martin 	struct lfid lfh;
   1303    1.1   mycroft 
   1304  1.216    martin 	if (*fh_size < sizeof(struct lfid)) {
   1305  1.216    martin 		*fh_size = sizeof(struct lfid);
   1306  1.216    martin 		return E2BIG;
   1307  1.216    martin 	}
   1308  1.216    martin 	*fh_size = sizeof(struct lfid);
   1309    1.1   mycroft 	ip = VTOI(vp);
   1310  1.216    martin 	memset(&lfh, 0, sizeof(lfh));
   1311  1.216    martin 	lfh.lfid_len = sizeof(struct lfid);
   1312  1.216    martin 	lfh.lfid_ino = ip->i_number;
   1313  1.216    martin 	lfh.lfid_gen = ip->i_gen;
   1314  1.216    martin 	lfh.lfid_ident = ip->i_lfs->lfs_ident;
   1315  1.216    martin 	memcpy(fhp, &lfh, sizeof(lfh));
   1316    1.1   mycroft 	return (0);
   1317   1.16      fvdl }
   1318   1.16      fvdl 
   1319  1.141    atatat static int
   1320  1.141    atatat sysctl_lfs_dostats(SYSCTLFN_ARGS)
   1321   1.16      fvdl {
   1322   1.26  perseant 	extern struct lfs_stats lfs_stats;
   1323  1.141    atatat 	extern int lfs_dostats;
   1324   1.26  perseant 	int error;
   1325   1.26  perseant 
   1326  1.182    atatat 	error = sysctl_lookup(SYSCTLFN_CALL(rnode));
   1327  1.141    atatat 	if (error || newp == NULL)
   1328  1.141    atatat 		return (error);
   1329  1.141    atatat 
   1330  1.141    atatat 	if (lfs_dostats == 0)
   1331  1.166  perseant 		memset(&lfs_stats, 0, sizeof(lfs_stats));
   1332  1.141    atatat 
   1333  1.141    atatat 	return (0);
   1334  1.141    atatat }
   1335  1.141    atatat 
   1336  1.166  perseant struct shortlong {
   1337  1.181  christos 	const char *sname;
   1338  1.181  christos 	const char *lname;
   1339  1.166  perseant };
   1340  1.166  perseant 
   1341  1.151    atatat SYSCTL_SETUP(sysctl_vfs_lfs_setup, "sysctl vfs.lfs subtree setup")
   1342  1.141    atatat {
   1343  1.166  perseant 	int i;
   1344  1.163  perseant 	extern int lfs_writeindir, lfs_dostats, lfs_clean_vnhead,
   1345  1.234  perseant 		   lfs_fs_pagetrip, lfs_ignore_lazy_sync;
   1346  1.166  perseant #ifdef DEBUG
   1347  1.166  perseant 	extern int lfs_debug_log_subsys[DLOG_MAX];
   1348  1.166  perseant 	struct shortlong dlog_names[DLOG_MAX] = { /* Must match lfs.h ! */
   1349  1.166  perseant 		{ "rollforward", "Debug roll-forward code" },
   1350  1.166  perseant 		{ "alloc",	"Debug inode allocation and free list" },
   1351  1.166  perseant 		{ "avail",	"Debug space-available-now accounting" },
   1352  1.166  perseant 		{ "flush",	"Debug flush triggers" },
   1353  1.166  perseant 		{ "lockedlist",	"Debug locked list accounting" },
   1354  1.166  perseant 		{ "vnode_verbose", "Verbose per-vnode-written debugging" },
   1355  1.166  perseant 		{ "vnode",	"Debug vnode use during segment write" },
   1356  1.166  perseant 		{ "segment",	"Debug segment writing" },
   1357  1.166  perseant 		{ "seguse",	"Debug segment used-bytes accounting" },
   1358  1.166  perseant 		{ "cleaner",	"Debug cleaning routines" },
   1359  1.166  perseant 		{ "mount",	"Debug mount/unmount routines" },
   1360  1.166  perseant 		{ "pagecache",	"Debug UBC interactions" },
   1361  1.166  perseant 		{ "dirop",	"Debug directory-operation accounting" },
   1362  1.166  perseant 		{ "malloc",	"Debug private malloc accounting" },
   1363  1.166  perseant 	};
   1364  1.166  perseant #endif /* DEBUG */
   1365  1.166  perseant 	struct shortlong stat_names[] = { /* Must match lfs.h! */
   1366  1.166  perseant 		{ "segsused",	    "Number of new segments allocated" },
   1367  1.166  perseant 		{ "psegwrites",	    "Number of partial-segment writes" },
   1368  1.166  perseant 		{ "psyncwrites",    "Number of synchronous partial-segment"
   1369  1.166  perseant 				    " writes" },
   1370  1.166  perseant 		{ "pcleanwrites",   "Number of partial-segment writes by the"
   1371  1.166  perseant 				    " cleaner" },
   1372  1.166  perseant 		{ "blocktot",       "Number of blocks written" },
   1373  1.166  perseant 		{ "cleanblocks",    "Number of blocks written by the cleaner" },
   1374  1.166  perseant 		{ "ncheckpoints",   "Number of checkpoints made" },
   1375  1.166  perseant 		{ "nwrites",        "Number of whole writes" },
   1376  1.166  perseant 		{ "nsync_writes",   "Number of synchronous writes" },
   1377  1.166  perseant 		{ "wait_exceeded",  "Number of times writer waited for"
   1378  1.166  perseant 				    " cleaner" },
   1379  1.166  perseant 		{ "write_exceeded", "Number of times writer invoked flush" },
   1380  1.166  perseant 		{ "flush_invoked",  "Number of times flush was invoked" },
   1381  1.166  perseant 		{ "vflush_invoked", "Number of time vflush was called" },
   1382  1.166  perseant 		{ "clean_inlocked", "Number of vnodes skipped for VXLOCK" },
   1383  1.166  perseant 		{ "clean_vnlocked", "Number of vnodes skipped for vget failure" },
   1384  1.180  perseant 		{ "segs_reclaimed", "Number of segments reclaimed" },
   1385  1.166  perseant 	};
   1386  1.141    atatat 
   1387  1.145    atatat 	sysctl_createv(clog, 0, NULL, NULL,
   1388  1.145    atatat 		       CTLFLAG_PERMANENT,
   1389  1.141    atatat 		       CTLTYPE_NODE, "vfs", NULL,
   1390  1.141    atatat 		       NULL, 0, NULL, 0,
   1391  1.141    atatat 		       CTL_VFS, CTL_EOL);
   1392  1.145    atatat 	sysctl_createv(clog, 0, NULL, NULL,
   1393  1.145    atatat 		       CTLFLAG_PERMANENT,
   1394  1.151    atatat 		       CTLTYPE_NODE, "lfs",
   1395  1.151    atatat 		       SYSCTL_DESCR("Log-structured file system"),
   1396  1.141    atatat 		       NULL, 0, NULL, 0,
   1397  1.141    atatat 		       CTL_VFS, 5, CTL_EOL);
   1398  1.141    atatat 	/*
   1399  1.141    atatat 	 * XXX the "5" above could be dynamic, thereby eliminating one
   1400  1.141    atatat 	 * more instance of the "number to vfs" mapping problem, but
   1401  1.166  perseant 	 * "5" is the order as taken from sys/mount.h
   1402  1.141    atatat 	 */
   1403  1.141    atatat 
   1404  1.145    atatat 	sysctl_createv(clog, 0, NULL, NULL,
   1405  1.145    atatat 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   1406  1.141    atatat 		       CTLTYPE_INT, "flushindir", NULL,
   1407  1.141    atatat 		       NULL, 0, &lfs_writeindir, 0,
   1408  1.141    atatat 		       CTL_VFS, 5, LFS_WRITEINDIR, CTL_EOL);
   1409  1.145    atatat 	sysctl_createv(clog, 0, NULL, NULL,
   1410  1.145    atatat 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   1411  1.141    atatat 		       CTLTYPE_INT, "clean_vnhead", NULL,
   1412  1.141    atatat 		       NULL, 0, &lfs_clean_vnhead, 0,
   1413  1.141    atatat 		       CTL_VFS, 5, LFS_CLEAN_VNHEAD, CTL_EOL);
   1414  1.145    atatat 	sysctl_createv(clog, 0, NULL, NULL,
   1415  1.145    atatat 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   1416  1.151    atatat 		       CTLTYPE_INT, "dostats",
   1417  1.151    atatat 		       SYSCTL_DESCR("Maintain statistics on LFS operations"),
   1418  1.141    atatat 		       sysctl_lfs_dostats, 0, &lfs_dostats, 0,
   1419  1.141    atatat 		       CTL_VFS, 5, LFS_DOSTATS, CTL_EOL);
   1420  1.163  perseant 	sysctl_createv(clog, 0, NULL, NULL,
   1421  1.163  perseant 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   1422  1.163  perseant 		       CTLTYPE_INT, "pagetrip",
   1423  1.166  perseant 		       SYSCTL_DESCR("How many dirty pages in fs triggers"
   1424  1.166  perseant 				    " a flush"),
   1425  1.166  perseant 		       NULL, 0, &lfs_fs_pagetrip, 0,
   1426  1.163  perseant 		       CTL_VFS, 5, LFS_FS_PAGETRIP, CTL_EOL);
   1427  1.234  perseant 	sysctl_createv(clog, 0, NULL, NULL,
   1428  1.234  perseant 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   1429  1.234  perseant 		       CTLTYPE_INT, "ignore_lazy_sync",
   1430  1.234  perseant 		       SYSCTL_DESCR("Lazy Sync is ignored entirely"),
   1431  1.234  perseant 		       NULL, 0, &lfs_ignore_lazy_sync, 0,
   1432  1.234  perseant 		       CTL_VFS, 5, LFS_IGNORE_LAZY_SYNC, CTL_EOL);
   1433  1.217  perseant #ifdef LFS_KERNEL_RFW
   1434  1.166  perseant 	sysctl_createv(clog, 0, NULL, NULL,
   1435  1.166  perseant 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   1436  1.166  perseant 		       CTLTYPE_INT, "rfw",
   1437  1.166  perseant 		       SYSCTL_DESCR("Use in-kernel roll-forward on mount"),
   1438  1.166  perseant 		       NULL, 0, &lfs_do_rfw, 0,
   1439  1.166  perseant 		       CTL_VFS, 5, LFS_DO_RFW, CTL_EOL);
   1440  1.217  perseant #endif
   1441  1.166  perseant 
   1442  1.166  perseant 	sysctl_createv(clog, 0, NULL, NULL,
   1443  1.166  perseant 		       CTLFLAG_PERMANENT,
   1444  1.166  perseant 		       CTLTYPE_NODE, "stats",
   1445  1.166  perseant 		       SYSCTL_DESCR("Debugging options"),
   1446  1.166  perseant 		       NULL, 0, NULL, 0,
   1447  1.166  perseant 		       CTL_VFS, 5, LFS_STATS, CTL_EOL);
   1448  1.166  perseant 	for (i = 0; i < sizeof(struct lfs_stats) / sizeof(u_int); i++) {
   1449  1.166  perseant 		sysctl_createv(clog, 0, NULL, NULL,
   1450  1.166  perseant 			       CTLFLAG_PERMANENT|CTLFLAG_READONLY,
   1451  1.166  perseant 			       CTLTYPE_INT, stat_names[i].sname,
   1452  1.166  perseant 			       SYSCTL_DESCR(stat_names[i].lname),
   1453  1.166  perseant 			       NULL, 0, &(((u_int *)&lfs_stats.segsused)[i]),
   1454  1.166  perseant 			       0, CTL_VFS, 5, LFS_STATS, i, CTL_EOL);
   1455  1.166  perseant 	}
   1456  1.166  perseant 
   1457  1.166  perseant #ifdef DEBUG
   1458  1.166  perseant 	sysctl_createv(clog, 0, NULL, NULL,
   1459  1.166  perseant 		       CTLFLAG_PERMANENT,
   1460  1.166  perseant 		       CTLTYPE_NODE, "debug",
   1461  1.166  perseant 		       SYSCTL_DESCR("Debugging options"),
   1462  1.166  perseant 		       NULL, 0, NULL, 0,
   1463  1.166  perseant 		       CTL_VFS, 5, LFS_DEBUGLOG, CTL_EOL);
   1464  1.166  perseant 	for (i = 0; i < DLOG_MAX; i++) {
   1465  1.166  perseant 		sysctl_createv(clog, 0, NULL, NULL,
   1466  1.166  perseant 			       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   1467  1.166  perseant 			       CTLTYPE_INT, dlog_names[i].sname,
   1468  1.166  perseant 			       SYSCTL_DESCR(dlog_names[i].lname),
   1469  1.166  perseant 			       NULL, 0, &(lfs_debug_log_subsys[i]), 0,
   1470  1.166  perseant 			       CTL_VFS, 5, LFS_DEBUGLOG, i, CTL_EOL);
   1471  1.166  perseant 	}
   1472  1.166  perseant #endif
   1473    1.1   mycroft }
   1474   1.91  perseant 
   1475  1.131      yamt /*
   1476  1.131      yamt  * ufs_bmaparray callback function for writing.
   1477  1.131      yamt  *
   1478  1.131      yamt  * Since blocks will be written to the new segment anyway,
   1479  1.131      yamt  * we don't care about current daddr of them.
   1480  1.131      yamt  */
   1481  1.230   thorpej static bool
   1482  1.224  christos lfs_issequential_hole(const struct ufsmount *ump,
   1483  1.117      yamt     daddr_t daddr0, daddr_t daddr1)
   1484  1.117      yamt {
   1485  1.163  perseant 	daddr0 = (daddr_t)((int32_t)daddr0); /* XXX ondisk32 */
   1486  1.163  perseant 	daddr1 = (daddr_t)((int32_t)daddr1); /* XXX ondisk32 */
   1487  1.127      yamt 
   1488  1.129      yamt 	KASSERT(daddr0 == UNWRITTEN ||
   1489  1.129      yamt 	    (0 <= daddr0 && daddr0 <= LFS_MAX_DADDR));
   1490  1.129      yamt 	KASSERT(daddr1 == UNWRITTEN ||
   1491  1.129      yamt 	    (0 <= daddr1 && daddr1 <= LFS_MAX_DADDR));
   1492  1.117      yamt 
   1493  1.117      yamt 	/* NOTE: all we want to know here is 'hole or not'. */
   1494  1.131      yamt 	/* NOTE: UNASSIGNED is converted to 0 by ufs_bmaparray. */
   1495  1.117      yamt 
   1496  1.117      yamt 	/*
   1497  1.117      yamt 	 * treat UNWRITTENs and all resident blocks as 'contiguous'
   1498  1.117      yamt 	 */
   1499  1.117      yamt 	if (daddr0 != 0 && daddr1 != 0)
   1500  1.231   thorpej 		return true;
   1501  1.117      yamt 
   1502  1.117      yamt 	/*
   1503  1.117      yamt 	 * both are in hole?
   1504  1.117      yamt 	 */
   1505  1.117      yamt 	if (daddr0 == 0 && daddr1 == 0)
   1506  1.231   thorpej 		return true; /* all holes are 'contiguous' for us. */
   1507  1.117      yamt 
   1508  1.231   thorpej 	return false;
   1509  1.117      yamt }
   1510  1.117      yamt 
   1511   1.91  perseant /*
   1512   1.91  perseant  * lfs_gop_write functions exactly like genfs_gop_write, except that
   1513   1.91  perseant  * (1) it requires the seglock to be held by its caller, and sp->fip
   1514   1.91  perseant  *     to be properly initialized (it will return without re-initializing
   1515   1.91  perseant  *     sp->fip, and without calling lfs_writeseg).
   1516   1.91  perseant  * (2) it uses the remaining space in the segment, rather than VOP_BMAP,
   1517   1.91  perseant  *     to determine how large a block it can write at once (though it does
   1518   1.91  perseant  *     still use VOP_BMAP to find holes in the file);
   1519   1.91  perseant  * (3) it calls lfs_gatherblock instead of VOP_STRATEGY on its blocks
   1520   1.91  perseant  *     (leaving lfs_writeseg to deal with the cluster blocks, so we might
   1521   1.91  perseant  *     now have clusters of clusters, ick.)
   1522   1.91  perseant  */
   1523   1.91  perseant static int
   1524  1.223  christos lfs_gop_write(struct vnode *vp, struct vm_page **pgs, int npages,
   1525  1.224  christos     int flags)
   1526   1.91  perseant {
   1527  1.204  christos 	int i, s, error, run, haveeof = 0;
   1528  1.137    simonb 	int fs_bshift;
   1529   1.91  perseant 	vaddr_t kva;
   1530  1.170  perseant 	off_t eof, offset, startoffset = 0;
   1531   1.91  perseant 	size_t bytes, iobytes, skipbytes;
   1532   1.91  perseant 	daddr_t lbn, blkno;
   1533   1.91  perseant 	struct vm_page *pg;
   1534   1.91  perseant 	struct buf *mbp, *bp;
   1535  1.117      yamt 	struct vnode *devvp = VTOI(vp)->i_devvp;
   1536   1.91  perseant 	struct inode *ip = VTOI(vp);
   1537   1.91  perseant 	struct lfs *fs = ip->i_lfs;
   1538   1.91  perseant 	struct segment *sp = fs->lfs_sp;
   1539   1.91  perseant 	UVMHIST_FUNC("lfs_gop_write"); UVMHIST_CALLED(ubchist);
   1540   1.91  perseant 
   1541  1.169  perseant 	ASSERT_SEGLOCK(fs);
   1542  1.169  perseant 
   1543   1.91  perseant 	/* The Ifile lives in the buffer cache */
   1544  1.153      yamt 	KASSERT(vp != fs->lfs_ivnode);
   1545   1.91  perseant 
   1546  1.209  perseant 	/*
   1547  1.209  perseant 	 * We don't want to fill the disk before the cleaner has a chance
   1548  1.209  perseant 	 * to make room for us.  If we're in danger of doing that, fail
   1549  1.209  perseant 	 * with EAGAIN.  The caller will have to notice this, unlock
   1550  1.209  perseant 	 * so the cleaner can run, relock and try again.
   1551  1.209  perseant 	 *
   1552  1.209  perseant 	 * We must write everything, however, if our vnode is being
   1553  1.209  perseant 	 * reclaimed.
   1554  1.209  perseant 	 */
   1555  1.209  perseant 	if (LFS_STARVED_FOR_SEGS(fs) && vp != fs->lfs_flushvp)
   1556  1.209  perseant 		goto tryagain;
   1557  1.195  perseant 
   1558   1.91  perseant 	/*
   1559   1.91  perseant 	 * Sometimes things slip past the filters in lfs_putpages,
   1560   1.91  perseant 	 * and the pagedaemon tries to write pages---problem is
   1561   1.91  perseant 	 * that the pagedaemon never acquires the segment lock.
   1562   1.91  perseant 	 *
   1563  1.163  perseant 	 * Alternatively, pages that were clean when we called
   1564  1.163  perseant 	 * genfs_putpages may have become dirty in the meantime.  In this
   1565  1.163  perseant 	 * case the segment header is not properly set up for blocks
   1566  1.163  perseant 	 * to be added to it.
   1567  1.163  perseant 	 *
   1568   1.91  perseant 	 * Unbusy and unclean the pages, and put them on the ACTIVE
   1569   1.91  perseant 	 * queue under the hypothesis that they couldn't have got here
   1570   1.91  perseant 	 * unless they were modified *quite* recently.
   1571   1.91  perseant 	 *
   1572   1.91  perseant 	 * XXXUBC that last statement is an oversimplification of course.
   1573   1.91  perseant 	 */
   1574  1.169  perseant 	if (!LFS_SEGLOCK_HELD(fs) ||
   1575  1.167    simonb 	    (ip->i_lfs_iflags & LFSI_NO_GOP_WRITE) ||
   1576  1.167    simonb 	    (pgs[0]->offset & fs->lfs_bmask) != 0) {
   1577  1.167    simonb 		goto tryagain;
   1578   1.91  perseant 	}
   1579   1.91  perseant 
   1580   1.91  perseant 	UVMHIST_LOG(ubchist, "vp %p pgs %p npages %d flags 0x%x",
   1581   1.91  perseant 	    vp, pgs, npages, flags);
   1582   1.91  perseant 
   1583  1.197      yamt 	GOP_SIZE(vp, vp->v_size, &eof, 0);
   1584  1.204  christos 	haveeof = 1;
   1585   1.91  perseant 
   1586  1.137    simonb 	if (vp->v_type == VREG)
   1587   1.91  perseant 		fs_bshift = vp->v_mount->mnt_fs_bshift;
   1588  1.137    simonb 	else
   1589   1.91  perseant 		fs_bshift = DEV_BSHIFT;
   1590   1.91  perseant 	error = 0;
   1591   1.91  perseant 	pg = pgs[0];
   1592   1.91  perseant 	startoffset = pg->offset;
   1593  1.195  perseant 	KASSERT(eof >= 0);
   1594  1.234  perseant 
   1595  1.170  perseant 	if (startoffset >= eof) {
   1596  1.170  perseant 		goto tryagain;
   1597  1.170  perseant 	} else
   1598  1.170  perseant 		bytes = MIN(npages << PAGE_SHIFT, eof - startoffset);
   1599   1.91  perseant 	skipbytes = 0;
   1600   1.91  perseant 
   1601  1.170  perseant 	KASSERT(bytes != 0);
   1602   1.91  perseant 
   1603   1.91  perseant 	/* Swap PG_DELWRI for PG_PAGEOUT */
   1604  1.234  perseant 	for (i = 0; i < npages; i++) {
   1605   1.91  perseant 		if (pgs[i]->flags & PG_DELWRI) {
   1606   1.91  perseant 			KASSERT(!(pgs[i]->flags & PG_PAGEOUT));
   1607   1.91  perseant 			pgs[i]->flags &= ~PG_DELWRI;
   1608   1.91  perseant 			pgs[i]->flags |= PG_PAGEOUT;
   1609   1.91  perseant 			uvmexp.paging++;
   1610   1.94      yamt 			uvm_lock_pageq();
   1611   1.94      yamt 			uvm_pageunwire(pgs[i]);
   1612   1.94      yamt 			uvm_unlock_pageq();
   1613   1.91  perseant 		}
   1614  1.234  perseant 	}
   1615   1.91  perseant 
   1616   1.91  perseant 	/*
   1617   1.91  perseant 	 * Check to make sure we're starting on a block boundary.
   1618   1.91  perseant 	 * We'll check later to make sure we always write entire
   1619   1.91  perseant 	 * blocks (or fragments).
   1620   1.91  perseant 	 */
   1621   1.91  perseant 	if (startoffset & fs->lfs_bmask)
   1622   1.91  perseant 		printf("%" PRId64 " & %" PRId64 " = %" PRId64 "\n",
   1623  1.166  perseant 		       startoffset, fs->lfs_bmask,
   1624  1.166  perseant 		       startoffset & fs->lfs_bmask);
   1625   1.91  perseant 	KASSERT((startoffset & fs->lfs_bmask) == 0);
   1626   1.91  perseant 	if (bytes & fs->lfs_ffmask) {
   1627   1.91  perseant 		printf("lfs_gop_write: asked to write %ld bytes\n", (long)bytes);
   1628   1.91  perseant 		panic("lfs_gop_write: non-integer blocks");
   1629   1.91  perseant 	}
   1630   1.91  perseant 
   1631  1.163  perseant 	/*
   1632  1.170  perseant 	 * We could deadlock here on pager_map with UVMPAGER_MAPIN_WAITOK.
   1633  1.170  perseant 	 * If we would, write what we have and try again.  If we don't
   1634  1.170  perseant 	 * have anything to write, we'll have to sleep.
   1635  1.170  perseant 	 */
   1636  1.171  perseant 	if ((kva = uvm_pagermapin(pgs, npages, UVMPAGER_MAPIN_WRITE |
   1637  1.170  perseant 				      (((SEGSUM *)(sp->segsum))->ss_nfinfo < 1 ?
   1638  1.170  perseant 				       UVMPAGER_MAPIN_WAITOK : 0))) == 0x0) {
   1639  1.170  perseant 		DLOG((DLOG_PAGE, "lfs_gop_write: forcing write\n"));
   1640  1.171  perseant #if 0
   1641  1.171  perseant 		      " with nfinfo=%d at offset 0x%x\n",
   1642  1.171  perseant 		      (int)((SEGSUM *)(sp->segsum))->ss_nfinfo,
   1643  1.171  perseant 		      (unsigned)fs->lfs_offset));
   1644  1.171  perseant #endif
   1645  1.212  perseant 		lfs_updatemeta(sp);
   1646  1.212  perseant 		lfs_release_finfo(fs);
   1647  1.170  perseant 		(void) lfs_writeseg(fs, sp);
   1648  1.170  perseant 
   1649  1.213  perseant 		lfs_acquire_finfo(fs, ip->i_number, ip->i_gen);
   1650  1.170  perseant 
   1651  1.171  perseant 		/*
   1652  1.171  perseant 		 * Having given up all of the pager_map we were holding,
   1653  1.171  perseant 		 * we can now wait for aiodoned to reclaim it for us
   1654  1.171  perseant 		 * without fear of deadlock.
   1655  1.171  perseant 		 */
   1656  1.171  perseant 		kva = uvm_pagermapin(pgs, npages, UVMPAGER_MAPIN_WRITE |
   1657  1.171  perseant 				     UVMPAGER_MAPIN_WAITOK);
   1658  1.170  perseant 	}
   1659   1.91  perseant 
   1660   1.91  perseant 	s = splbio();
   1661   1.91  perseant 	simple_lock(&global_v_numoutput_slock);
   1662   1.91  perseant 	vp->v_numoutput += 2; /* one for biodone, one for aiodone */
   1663   1.91  perseant 	simple_unlock(&global_v_numoutput_slock);
   1664   1.91  perseant 	splx(s);
   1665   1.91  perseant 
   1666  1.191      yamt 	mbp = getiobuf();
   1667   1.91  perseant 	UVMHIST_LOG(ubchist, "vp %p mbp %p num now %d bytes 0x%x",
   1668   1.91  perseant 	    vp, mbp, vp->v_numoutput, bytes);
   1669   1.91  perseant 	mbp->b_bufsize = npages << PAGE_SHIFT;
   1670   1.91  perseant 	mbp->b_data = (void *)kva;
   1671   1.91  perseant 	mbp->b_resid = mbp->b_bcount = bytes;
   1672   1.91  perseant 	mbp->b_flags = B_BUSY|B_WRITE|B_AGE|B_CALL;
   1673   1.91  perseant 	mbp->b_iodone = uvm_aio_biodone;
   1674   1.91  perseant 	mbp->b_vp = vp;
   1675   1.91  perseant 
   1676   1.91  perseant 	bp = NULL;
   1677   1.91  perseant 	for (offset = startoffset;
   1678   1.91  perseant 	    bytes > 0;
   1679   1.91  perseant 	    offset += iobytes, bytes -= iobytes) {
   1680   1.91  perseant 		lbn = offset >> fs_bshift;
   1681  1.117      yamt 		error = ufs_bmaparray(vp, lbn, &blkno, NULL, NULL, &run,
   1682  1.117      yamt 		    lfs_issequential_hole);
   1683   1.91  perseant 		if (error) {
   1684  1.117      yamt 			UVMHIST_LOG(ubchist, "ufs_bmaparray() -> %d",
   1685  1.117      yamt 			    error,0,0,0);
   1686   1.91  perseant 			skipbytes += bytes;
   1687   1.91  perseant 			bytes = 0;
   1688   1.91  perseant 			break;
   1689   1.91  perseant 		}
   1690   1.91  perseant 
   1691  1.116  perseant 		iobytes = MIN((((off_t)lbn + 1 + run) << fs_bshift) - offset,
   1692  1.116  perseant 		    bytes);
   1693   1.91  perseant 		if (blkno == (daddr_t)-1) {
   1694   1.91  perseant 			skipbytes += iobytes;
   1695   1.91  perseant 			continue;
   1696   1.91  perseant 		}
   1697   1.91  perseant 
   1698   1.91  perseant 		/*
   1699   1.91  perseant 		 * Discover how much we can really pack into this buffer.
   1700   1.91  perseant 		 */
   1701   1.91  perseant 		/* If no room in the current segment, finish it up */
   1702   1.91  perseant 		if (sp->sum_bytes_left < sizeof(int32_t) ||
   1703   1.97  perseant 		    sp->seg_bytes_left < (1 << fs->lfs_bshift)) {
   1704  1.181  christos 			int vers;
   1705   1.91  perseant 
   1706   1.91  perseant 			lfs_updatemeta(sp);
   1707  1.181  christos 			vers = sp->fip->fi_version;
   1708  1.212  perseant 			lfs_release_finfo(fs);
   1709   1.91  perseant 			(void) lfs_writeseg(fs, sp);
   1710  1.164     perry 
   1711  1.212  perseant 			lfs_acquire_finfo(fs, ip->i_number, vers);
   1712   1.91  perseant 		}
   1713   1.97  perseant 		/* Check both for space in segment and space in segsum */
   1714   1.97  perseant 		iobytes = MIN(iobytes, (sp->seg_bytes_left >> fs_bshift)
   1715   1.97  perseant 					<< fs_bshift);
   1716   1.97  perseant 		iobytes = MIN(iobytes, (sp->sum_bytes_left / sizeof(int32_t))
   1717   1.97  perseant 				       << fs_bshift);
   1718   1.91  perseant 		KASSERT(iobytes > 0);
   1719   1.91  perseant 
   1720   1.91  perseant 		/* if it's really one i/o, don't make a second buf */
   1721   1.91  perseant 		if (offset == startoffset && iobytes == bytes) {
   1722   1.91  perseant 			bp = mbp;
   1723   1.91  perseant 			/* correct overcount if there is no second buffer */
   1724   1.91  perseant 			s = splbio();
   1725   1.91  perseant 			simple_lock(&global_v_numoutput_slock);
   1726   1.91  perseant 			--vp->v_numoutput;
   1727   1.91  perseant 			simple_unlock(&global_v_numoutput_slock);
   1728   1.91  perseant 			splx(s);
   1729   1.91  perseant 		} else {
   1730  1.191      yamt 			bp = getiobuf();
   1731   1.91  perseant 			UVMHIST_LOG(ubchist, "vp %p bp %p num now %d",
   1732   1.91  perseant 			    vp, bp, vp->v_numoutput, 0);
   1733   1.91  perseant 			bp->b_data = (char *)kva +
   1734   1.91  perseant 			    (vaddr_t)(offset - pg->offset);
   1735   1.91  perseant 			bp->b_resid = bp->b_bcount = iobytes;
   1736   1.91  perseant 			bp->b_flags = B_BUSY|B_WRITE|B_CALL;
   1737   1.91  perseant 			bp->b_iodone = uvm_aio_biodone1;
   1738   1.91  perseant 		}
   1739   1.91  perseant 
   1740   1.91  perseant 		/* XXX This is silly ... is this necessary? */
   1741   1.91  perseant 		bp->b_vp = NULL;
   1742   1.91  perseant 		s = splbio();
   1743   1.91  perseant 		bgetvp(vp, bp);
   1744   1.91  perseant 		splx(s);
   1745   1.91  perseant 
   1746   1.91  perseant 		bp->b_lblkno = lblkno(fs, offset);
   1747   1.91  perseant 		bp->b_private = mbp;
   1748   1.91  perseant 		if (devvp->v_type == VBLK) {
   1749   1.91  perseant 			bp->b_dev = devvp->v_rdev;
   1750   1.91  perseant 		}
   1751   1.91  perseant 		VOP_BWRITE(bp);
   1752  1.110  perseant 		while (lfs_gatherblock(sp, bp, NULL))
   1753  1.111       dsl 			continue;
   1754   1.91  perseant 	}
   1755   1.91  perseant 
   1756   1.91  perseant 	if (skipbytes) {
   1757   1.91  perseant 		UVMHIST_LOG(ubchist, "skipbytes %d", skipbytes, 0,0,0);
   1758   1.91  perseant 		s = splbio();
   1759   1.91  perseant 		if (error) {
   1760   1.91  perseant 			mbp->b_flags |= B_ERROR;
   1761   1.91  perseant 			mbp->b_error = error;
   1762   1.91  perseant 		}
   1763   1.91  perseant 		mbp->b_resid -= skipbytes;
   1764   1.91  perseant 		if (mbp->b_resid == 0) {
   1765   1.91  perseant 			biodone(mbp);
   1766   1.91  perseant 		}
   1767   1.91  perseant 		splx(s);
   1768   1.91  perseant 	}
   1769   1.91  perseant 	UVMHIST_LOG(ubchist, "returning 0", 0,0,0,0);
   1770   1.91  perseant 	return (0);
   1771  1.163  perseant 
   1772  1.163  perseant     tryagain:
   1773  1.167    simonb 	/*
   1774  1.167    simonb 	 * We can't write the pages, for whatever reason.
   1775  1.167    simonb 	 * Clean up after ourselves, and make the caller try again.
   1776  1.167    simonb 	 */
   1777  1.167    simonb 	simple_lock(&vp->v_interlock);
   1778  1.166  perseant 
   1779  1.166  perseant 	/* Tell why we're here, if we know */
   1780  1.222  christos 	if (ip->i_lfs_iflags & LFSI_NO_GOP_WRITE) {
   1781  1.167    simonb 		DLOG((DLOG_PAGE, "lfs_gop_write: clean pages dirtied\n"));
   1782  1.222  christos 	} else if ((pgs[0]->offset & fs->lfs_bmask) != 0) {
   1783  1.166  perseant 		DLOG((DLOG_PAGE, "lfs_gop_write: not on block boundary\n"));
   1784  1.222  christos 	} else if (haveeof && startoffset >= eof) {
   1785  1.170  perseant 		DLOG((DLOG_PAGE, "lfs_gop_write: ino %d start 0x%" PRIx64
   1786  1.170  perseant 		      " eof 0x%" PRIx64 " npages=%d\n", VTOI(vp)->i_number,
   1787  1.170  perseant 		      pgs[0]->offset, eof, npages));
   1788  1.222  christos 	} else if (LFS_STARVED_FOR_SEGS(fs)) {
   1789  1.195  perseant 		DLOG((DLOG_PAGE, "lfs_gop_write: avail too low\n"));
   1790  1.222  christos 	} else {
   1791  1.167    simonb 		DLOG((DLOG_PAGE, "lfs_gop_write: seglock not held\n"));
   1792  1.222  christos 	}
   1793  1.166  perseant 
   1794  1.167    simonb 	uvm_lock_pageq();
   1795  1.167    simonb 	for (i = 0; i < npages; i++) {
   1796  1.167    simonb 		pg = pgs[i];
   1797  1.167    simonb 
   1798  1.167    simonb 		if (pg->flags & PG_PAGEOUT)
   1799  1.167    simonb 			uvmexp.paging--;
   1800  1.167    simonb 		if (pg->flags & PG_DELWRI) {
   1801  1.167    simonb 			uvm_pageunwire(pg);
   1802  1.167    simonb 		}
   1803  1.167    simonb 		uvm_pageactivate(pg);
   1804  1.167    simonb 		pg->flags &= ~(PG_CLEAN|PG_DELWRI|PG_PAGEOUT|PG_RELEASED);
   1805  1.195  perseant 		DLOG((DLOG_PAGE, "pg[%d] = %p (vp %p off %" PRIx64 ")\n", i, pg,
   1806  1.195  perseant 			vp, pg->offset));
   1807  1.167    simonb 		DLOG((DLOG_PAGE, "pg[%d]->flags = %x\n", i, pg->flags));
   1808  1.166  perseant 		DLOG((DLOG_PAGE, "pg[%d]->pqflags = %x\n", i, pg->pqflags));
   1809  1.167    simonb 		DLOG((DLOG_PAGE, "pg[%d]->uanon = %p\n", i, pg->uanon));
   1810  1.167    simonb 		DLOG((DLOG_PAGE, "pg[%d]->uobject = %p\n", i, pg->uobject));
   1811  1.167    simonb 		DLOG((DLOG_PAGE, "pg[%d]->wire_count = %d\n", i,
   1812  1.166  perseant 		      pg->wire_count));
   1813  1.167    simonb 		DLOG((DLOG_PAGE, "pg[%d]->loan_count = %d\n", i,
   1814  1.166  perseant 		      pg->loan_count));
   1815  1.167    simonb 	}
   1816  1.167    simonb 	/* uvm_pageunbusy takes care of PG_BUSY, PG_WANTED */
   1817  1.167    simonb 	uvm_page_unbusy(pgs, npages);
   1818  1.167    simonb 	uvm_unlock_pageq();
   1819  1.167    simonb 	simple_unlock(&vp->v_interlock);
   1820  1.167    simonb 	return EAGAIN;
   1821  1.107      yamt }
   1822  1.107      yamt 
   1823  1.107      yamt /*
   1824  1.107      yamt  * finish vnode/inode initialization.
   1825  1.107      yamt  * used by lfs_vget and lfs_fastvget.
   1826  1.107      yamt  */
   1827  1.107      yamt void
   1828  1.139      yamt lfs_vinit(struct mount *mp, struct vnode **vpp)
   1829  1.107      yamt {
   1830  1.139      yamt 	struct vnode *vp = *vpp;
   1831  1.107      yamt 	struct inode *ip = VTOI(vp);
   1832  1.107      yamt 	struct ufsmount *ump = VFSTOUFS(mp);
   1833  1.234  perseant 	struct lfs *fs = ump->um_lfs;
   1834  1.107      yamt 	int i;
   1835  1.107      yamt 
   1836  1.113      fvdl 	ip->i_mode = ip->i_ffs1_mode;
   1837  1.113      fvdl 	ip->i_ffs_effnlink = ip->i_nlink = ip->i_ffs1_nlink;
   1838  1.113      fvdl 	ip->i_lfs_osize = ip->i_size = ip->i_ffs1_size;
   1839  1.113      fvdl 	ip->i_flags = ip->i_ffs1_flags;
   1840  1.113      fvdl 	ip->i_gen = ip->i_ffs1_gen;
   1841  1.113      fvdl 	ip->i_uid = ip->i_ffs1_uid;
   1842  1.113      fvdl 	ip->i_gid = ip->i_ffs1_gid;
   1843  1.113      fvdl 
   1844  1.113      fvdl 	ip->i_lfs_effnblks = ip->i_ffs1_blocks;
   1845  1.219  perseant 	ip->i_lfs_odnlink = ip->i_ffs1_nlink;
   1846  1.107      yamt 
   1847  1.107      yamt 	/*
   1848  1.107      yamt 	 * Initialize the vnode from the inode, check for aliases.  In all
   1849  1.107      yamt 	 * cases re-init ip, the underlying vnode/inode may have changed.
   1850  1.107      yamt 	 */
   1851  1.107      yamt 	ufs_vinit(mp, lfs_specop_p, lfs_fifoop_p, &vp);
   1852  1.163  perseant 	ip = VTOI(vp);
   1853  1.107      yamt 
   1854  1.107      yamt 	memset(ip->i_lfs_fragsize, 0, NDADDR * sizeof(*ip->i_lfs_fragsize));
   1855  1.156   mycroft 	if (vp->v_type != VLNK || ip->i_size >= ip->i_ump->um_maxsymlinklen) {
   1856  1.108      yamt #ifdef DEBUG
   1857  1.113      fvdl 		for (i = (ip->i_size + fs->lfs_bsize - 1) >> fs->lfs_bshift;
   1858  1.107      yamt 		    i < NDADDR; i++) {
   1859  1.163  perseant 			if ((vp->v_type == VBLK || vp->v_type == VCHR) &&
   1860  1.163  perseant 			    i == 0)
   1861  1.163  perseant 				continue;
   1862  1.113      fvdl 			if (ip->i_ffs1_db[i] != 0) {
   1863  1.107      yamt inconsistent:
   1864  1.113      fvdl 				lfs_dump_dinode(ip->i_din.ffs1_din);
   1865  1.107      yamt 				panic("inconsistent inode");
   1866  1.107      yamt 			}
   1867  1.107      yamt 		}
   1868  1.107      yamt 		for ( ; i < NDADDR + NIADDR; i++) {
   1869  1.113      fvdl 			if (ip->i_ffs1_ib[i - NDADDR] != 0) {
   1870  1.107      yamt 				goto inconsistent;
   1871  1.107      yamt 			}
   1872  1.107      yamt 		}
   1873  1.108      yamt #endif /* DEBUG */
   1874  1.107      yamt 		for (i = 0; i < NDADDR; i++)
   1875  1.113      fvdl 			if (ip->i_ffs1_db[i] != 0)
   1876  1.107      yamt 				ip->i_lfs_fragsize[i] = blksize(fs, ip, i);
   1877  1.107      yamt 	}
   1878  1.107      yamt 
   1879  1.166  perseant #ifdef DIAGNOSTIC
   1880  1.107      yamt 	if (vp->v_type == VNON) {
   1881  1.166  perseant # ifdef DEBUG
   1882  1.113      fvdl 		lfs_dump_dinode(ip->i_din.ffs1_din);
   1883  1.166  perseant # endif
   1884  1.185  christos 		panic("lfs_vinit: ino %llu is type VNON! (ifmt=%o)\n",
   1885  1.185  christos 		      (unsigned long long)ip->i_number,
   1886  1.185  christos 		      (ip->i_mode & IFMT) >> 12);
   1887  1.107      yamt 	}
   1888  1.166  perseant #endif /* DIAGNOSTIC */
   1889  1.107      yamt 
   1890  1.107      yamt 	/*
   1891  1.107      yamt 	 * Finish inode initialization now that aliasing has been resolved.
   1892  1.107      yamt 	 */
   1893  1.107      yamt 
   1894  1.107      yamt 	ip->i_devvp = ump->um_devvp;
   1895  1.107      yamt 	VREF(ip->i_devvp);
   1896  1.107      yamt 	genfs_node_init(vp, &lfs_genfsops);
   1897  1.113      fvdl 	uvm_vnp_setsize(vp, ip->i_size);
   1898  1.139      yamt 
   1899  1.172  perseant 	/* Initialize hiblk from file size */
   1900  1.172  perseant 	ip->i_lfs_hiblk = lblkno(ip->i_lfs, ip->i_size + ip->i_lfs->lfs_bsize - 1) - 1;
   1901  1.172  perseant 
   1902  1.139      yamt 	*vpp = vp;
   1903   1.91  perseant }
   1904  1.165  perseant 
   1905  1.165  perseant /*
   1906  1.177  perseant  * Resize the filesystem to contain the specified number of segments.
   1907  1.177  perseant  */
   1908  1.177  perseant int
   1909  1.177  perseant lfs_resize_fs(struct lfs *fs, int newnsegs)
   1910  1.177  perseant {
   1911  1.177  perseant 	SEGUSE *sup;
   1912  1.177  perseant 	struct buf *bp, *obp;
   1913  1.177  perseant 	daddr_t olast, nlast, ilast, noff, start, end;
   1914  1.177  perseant 	struct vnode *ivp;
   1915  1.177  perseant 	struct inode *ip;
   1916  1.177  perseant 	int error, badnews, inc, oldnsegs;
   1917  1.177  perseant 	int sbbytes, csbbytes, gain, cgain;
   1918  1.177  perseant 	int i;
   1919  1.177  perseant 
   1920  1.177  perseant 	/* Only support v2 and up */
   1921  1.177  perseant 	if (fs->lfs_version < 2)
   1922  1.177  perseant 		return EOPNOTSUPP;
   1923  1.177  perseant 
   1924  1.177  perseant 	/* If we're doing nothing, do it fast */
   1925  1.177  perseant 	oldnsegs = fs->lfs_nseg;
   1926  1.177  perseant 	if (newnsegs == oldnsegs)
   1927  1.177  perseant 		return 0;
   1928  1.177  perseant 
   1929  1.177  perseant 	/* We always have to have two superblocks */
   1930  1.177  perseant 	if (newnsegs <= dtosn(fs, fs->lfs_sboffs[1]))
   1931  1.177  perseant 		return EFBIG;
   1932  1.177  perseant 
   1933  1.177  perseant 	ivp = fs->lfs_ivnode;
   1934  1.177  perseant 	ip = VTOI(ivp);
   1935  1.177  perseant 	error = 0;
   1936  1.177  perseant 
   1937  1.177  perseant 	/* Take the segment lock so no one else calls lfs_newseg() */
   1938  1.177  perseant 	lfs_seglock(fs, SEGM_PROT);
   1939  1.177  perseant 
   1940  1.177  perseant 	/*
   1941  1.177  perseant 	 * Make sure the segments we're going to be losing, if any,
   1942  1.177  perseant 	 * are in fact empty.  We hold the seglock, so their status
   1943  1.177  perseant 	 * cannot change underneath us.  Count the superblocks we lose,
   1944  1.177  perseant 	 * while we're at it.
   1945  1.177  perseant 	 */
   1946  1.177  perseant 	sbbytes = csbbytes = 0;
   1947  1.177  perseant 	cgain = 0;
   1948  1.177  perseant 	for (i = newnsegs; i < oldnsegs; i++) {
   1949  1.177  perseant 		LFS_SEGENTRY(sup, fs, i, bp);
   1950  1.177  perseant 		badnews = sup->su_nbytes || !(sup->su_flags & SEGUSE_INVAL);
   1951  1.177  perseant 		if (sup->su_flags & SEGUSE_SUPERBLOCK)
   1952  1.177  perseant 			sbbytes += LFS_SBPAD;
   1953  1.177  perseant 		if (!(sup->su_flags & SEGUSE_DIRTY)) {
   1954  1.177  perseant 			++cgain;
   1955  1.177  perseant 			if (sup->su_flags & SEGUSE_SUPERBLOCK)
   1956  1.177  perseant 				csbbytes += LFS_SBPAD;
   1957  1.177  perseant 		}
   1958  1.177  perseant 		brelse(bp);
   1959  1.177  perseant 		if (badnews) {
   1960  1.177  perseant 			error = EBUSY;
   1961  1.177  perseant 			goto out;
   1962  1.177  perseant 		}
   1963  1.177  perseant 	}
   1964  1.177  perseant 
   1965  1.177  perseant 	/* Note old and new segment table endpoints, and old ifile size */
   1966  1.177  perseant 	olast = fs->lfs_cleansz + fs->lfs_segtabsz;
   1967  1.177  perseant 	nlast = howmany(newnsegs, fs->lfs_sepb) + fs->lfs_cleansz;
   1968  1.177  perseant 	ilast = ivp->v_size >> fs->lfs_bshift;
   1969  1.177  perseant 	noff = nlast - olast;
   1970  1.177  perseant 
   1971  1.177  perseant 	/*
   1972  1.177  perseant 	 * Make sure no one can use the Ifile while we change it around.
   1973  1.177  perseant 	 * Even after taking the iflock we need to make sure no one still
   1974  1.177  perseant 	 * is holding Ifile buffers, so we get each one, to drain them.
   1975  1.177  perseant 	 * (XXX this could be done better.)
   1976  1.177  perseant 	 */
   1977  1.177  perseant 	simple_lock(&fs->lfs_interlock);
   1978  1.177  perseant 	lockmgr(&fs->lfs_iflock, LK_EXCLUSIVE, &fs->lfs_interlock);
   1979  1.177  perseant 	simple_unlock(&fs->lfs_interlock);
   1980  1.177  perseant 	vn_lock(ivp, LK_EXCLUSIVE | LK_RETRY);
   1981  1.177  perseant 	for (i = 0; i < ilast; i++) {
   1982  1.177  perseant 		bread(ivp, i, fs->lfs_bsize, NOCRED, &bp);
   1983  1.177  perseant 		brelse(bp);
   1984  1.177  perseant 	}
   1985  1.177  perseant 
   1986  1.177  perseant 	/* Allocate new Ifile blocks */
   1987  1.177  perseant 	for (i = ilast; i < ilast + noff; i++) {
   1988  1.189      yamt 		if (lfs_balloc(ivp, i * fs->lfs_bsize, fs->lfs_bsize, NOCRED, 0,
   1989  1.177  perseant 			       &bp) != 0)
   1990  1.177  perseant 			panic("balloc extending ifile");
   1991  1.177  perseant 		memset(bp->b_data, 0, fs->lfs_bsize);
   1992  1.177  perseant 		VOP_BWRITE(bp);
   1993  1.177  perseant 	}
   1994  1.177  perseant 
   1995  1.177  perseant 	/* Register new ifile size */
   1996  1.177  perseant 	ip->i_size += noff * fs->lfs_bsize;
   1997  1.177  perseant 	ip->i_ffs1_size = ip->i_size;
   1998  1.177  perseant 	uvm_vnp_setsize(ivp, ip->i_size);
   1999  1.177  perseant 
   2000  1.177  perseant 	/* Copy the inode table to its new position */
   2001  1.177  perseant 	if (noff != 0) {
   2002  1.177  perseant 		if (noff < 0) {
   2003  1.177  perseant 			start = nlast;
   2004  1.177  perseant 			end = ilast + noff;
   2005  1.177  perseant 			inc = 1;
   2006  1.177  perseant 		} else {
   2007  1.177  perseant 			start = ilast + noff - 1;
   2008  1.177  perseant 			end = nlast - 1;
   2009  1.177  perseant 			inc = -1;
   2010  1.177  perseant 		}
   2011  1.177  perseant 		for (i = start; i != end; i += inc) {
   2012  1.177  perseant 			if (bread(ivp, i, fs->lfs_bsize, NOCRED, &bp) != 0)
   2013  1.177  perseant 				panic("resize: bread dst blk failed");
   2014  1.177  perseant 			if (bread(ivp, i - noff, fs->lfs_bsize, NOCRED, &obp))
   2015  1.177  perseant 				panic("resize: bread src blk failed");
   2016  1.177  perseant 			memcpy(bp->b_data, obp->b_data, fs->lfs_bsize);
   2017  1.177  perseant 			VOP_BWRITE(bp);
   2018  1.177  perseant 			brelse(obp);
   2019  1.177  perseant 		}
   2020  1.177  perseant 	}
   2021  1.177  perseant 
   2022  1.177  perseant 	/* If we are expanding, write the new empty SEGUSE entries */
   2023  1.177  perseant 	if (newnsegs > oldnsegs) {
   2024  1.177  perseant 		for (i = oldnsegs; i < newnsegs; i++) {
   2025  1.177  perseant 			if ((error = bread(ivp, i / fs->lfs_sepb +
   2026  1.177  perseant 					   fs->lfs_cleansz,
   2027  1.177  perseant 					   fs->lfs_bsize, NOCRED, &bp)) != 0)
   2028  1.177  perseant 				panic("lfs: ifile read: %d", error);
   2029  1.177  perseant 			while ((i + 1) % fs->lfs_sepb && i < newnsegs) {
   2030  1.177  perseant 				sup = &((SEGUSE *)bp->b_data)[i % fs->lfs_sepb];
   2031  1.177  perseant 				memset(sup, 0, sizeof(*sup));
   2032  1.177  perseant 				i++;
   2033  1.177  perseant 			}
   2034  1.177  perseant 			VOP_BWRITE(bp);
   2035  1.177  perseant 		}
   2036  1.177  perseant 	}
   2037  1.177  perseant 
   2038  1.177  perseant 	/* Zero out unused superblock offsets */
   2039  1.177  perseant 	for (i = 2; i < LFS_MAXNUMSB; i++)
   2040  1.177  perseant 		if (dtosn(fs, fs->lfs_sboffs[i]) >= newnsegs)
   2041  1.177  perseant 			fs->lfs_sboffs[i] = 0x0;
   2042  1.177  perseant 
   2043  1.177  perseant 	/*
   2044  1.177  perseant 	 * Correct superblock entries that depend on fs size.
   2045  1.177  perseant 	 * The computations of these are as follows:
   2046  1.177  perseant 	 *
   2047  1.177  perseant 	 * size  = segtod(fs, nseg)
   2048  1.177  perseant 	 * dsize = segtod(fs, nseg - minfreeseg) - btofsb(#super * LFS_SBPAD)
   2049  1.177  perseant 	 * bfree = dsize - btofsb(fs, bsize * nseg / 2) - blocks_actually_used
   2050  1.177  perseant 	 * avail = segtod(fs, nclean) - btofsb(#clean_super * LFS_SBPAD)
   2051  1.177  perseant 	 *         + (segtod(fs, 1) - (offset - curseg))
   2052  1.177  perseant 	 *	   - segtod(fs, minfreeseg - (minfreeseg / 2))
   2053  1.177  perseant 	 *
   2054  1.177  perseant 	 * XXX - we should probably adjust minfreeseg as well.
   2055  1.177  perseant 	 */
   2056  1.177  perseant 	gain = (newnsegs - oldnsegs);
   2057  1.177  perseant 	fs->lfs_nseg = newnsegs;
   2058  1.177  perseant 	fs->lfs_segtabsz = nlast - fs->lfs_cleansz;
   2059  1.177  perseant 	fs->lfs_size += gain * btofsb(fs, fs->lfs_ssize);
   2060  1.177  perseant 	fs->lfs_dsize += gain * btofsb(fs, fs->lfs_ssize) - btofsb(fs, sbbytes);
   2061  1.177  perseant 	fs->lfs_bfree += gain * btofsb(fs, fs->lfs_ssize) - btofsb(fs, sbbytes)
   2062  1.177  perseant 		       - gain * btofsb(fs, fs->lfs_bsize / 2);
   2063  1.177  perseant 	if (gain > 0) {
   2064  1.177  perseant 		fs->lfs_nclean += gain;
   2065  1.177  perseant 		fs->lfs_avail += gain * btofsb(fs, fs->lfs_ssize);
   2066  1.177  perseant 	} else {
   2067  1.177  perseant 		fs->lfs_nclean -= cgain;
   2068  1.177  perseant 		fs->lfs_avail -= cgain * btofsb(fs, fs->lfs_ssize) -
   2069  1.177  perseant 				 btofsb(fs, csbbytes);
   2070  1.177  perseant 	}
   2071  1.177  perseant 
   2072  1.177  perseant 	/* Resize segment flag cache */
   2073  1.177  perseant 	fs->lfs_suflags[0] = (u_int32_t *)realloc(fs->lfs_suflags[0],
   2074  1.177  perseant 						  fs->lfs_nseg * sizeof(u_int32_t),
   2075  1.177  perseant 						  M_SEGMENT, M_WAITOK);
   2076  1.215  perseant 	fs->lfs_suflags[1] = (u_int32_t *)realloc(fs->lfs_suflags[1],
   2077  1.177  perseant 						  fs->lfs_nseg * sizeof(u_int32_t),
   2078  1.177  perseant 						  M_SEGMENT, M_WAITOK);
   2079  1.177  perseant 	for (i = oldnsegs; i < newnsegs; i++)
   2080  1.177  perseant 		fs->lfs_suflags[0][i] = fs->lfs_suflags[1][i] = 0x0;
   2081  1.177  perseant 
   2082  1.177  perseant 	/* Truncate Ifile if necessary */
   2083  1.177  perseant 	if (noff < 0)
   2084  1.189      yamt 		lfs_truncate(ivp, ivp->v_size + (noff << fs->lfs_bshift), 0,
   2085  1.190  christos 			     NOCRED, curlwp);
   2086  1.177  perseant 
   2087  1.177  perseant 	/* Update cleaner info so the cleaner can die */
   2088  1.177  perseant 	bread(ivp, 0, fs->lfs_bsize, NOCRED, &bp);
   2089  1.177  perseant 	((CLEANERINFO *)bp->b_data)->clean = fs->lfs_nclean;
   2090  1.177  perseant 	((CLEANERINFO *)bp->b_data)->dirty = fs->lfs_nseg - fs->lfs_nclean;
   2091  1.177  perseant 	VOP_BWRITE(bp);
   2092  1.177  perseant 
   2093  1.177  perseant 	/* Let Ifile accesses proceed */
   2094  1.177  perseant 	VOP_UNLOCK(ivp, 0);
   2095  1.177  perseant 	simple_lock(&fs->lfs_interlock);
   2096  1.177  perseant 	lockmgr(&fs->lfs_iflock, LK_RELEASE, &fs->lfs_interlock);
   2097  1.177  perseant 	simple_unlock(&fs->lfs_interlock);
   2098  1.177  perseant 
   2099  1.177  perseant     out:
   2100  1.177  perseant 	lfs_segunlock(fs);
   2101  1.177  perseant 	return error;
   2102  1.177  perseant }
   2103