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