Home | History | Annotate | Line # | Download | only in lfs
      1  1.388  perseant /*	$NetBSD: lfs_vfsops.c,v 1.388 2025/09/19 15:55:12 perseant Exp $	*/
      2    1.2       cgd 
      3   1.26  perseant /*-
      4  1.255        ad  * Copyright (c) 1999, 2000, 2001, 2002, 2003, 2007, 2007
      5  1.255        ad  *     The NetBSD Foundation, Inc.
      6   1.26  perseant  * All rights reserved.
      7   1.26  perseant  *
      8   1.26  perseant  * This code is derived from software contributed to The NetBSD Foundation
      9   1.26  perseant  * by Konrad E. Schroder <perseant (at) hhhh.org>.
     10   1.26  perseant  *
     11   1.26  perseant  * Redistribution and use in source and binary forms, with or without
     12   1.26  perseant  * modification, are permitted provided that the following conditions
     13   1.26  perseant  * are met:
     14   1.26  perseant  * 1. Redistributions of source code must retain the above copyright
     15   1.26  perseant  *    notice, this list of conditions and the following disclaimer.
     16   1.26  perseant  * 2. Redistributions in binary form must reproduce the above copyright
     17   1.26  perseant  *    notice, this list of conditions and the following disclaimer in the
     18   1.26  perseant  *    documentation and/or other materials provided with the distribution.
     19   1.26  perseant  *
     20   1.26  perseant  * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
     21   1.26  perseant  * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
     22   1.26  perseant  * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
     23   1.26  perseant  * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
     24   1.26  perseant  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
     25   1.26  perseant  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
     26   1.26  perseant  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
     27   1.26  perseant  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
     28   1.26  perseant  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
     29   1.26  perseant  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
     30   1.26  perseant  * POSSIBILITY OF SUCH DAMAGE.
     31   1.26  perseant  */
     32   1.26  perseant /*-
     33    1.1   mycroft  * Copyright (c) 1989, 1991, 1993, 1994
     34    1.1   mycroft  *	The Regents of the University of California.  All rights reserved.
     35    1.1   mycroft  *
     36    1.1   mycroft  * Redistribution and use in source and binary forms, with or without
     37    1.1   mycroft  * modification, are permitted provided that the following conditions
     38    1.1   mycroft  * are met:
     39    1.1   mycroft  * 1. Redistributions of source code must retain the above copyright
     40    1.1   mycroft  *    notice, this list of conditions and the following disclaimer.
     41    1.1   mycroft  * 2. Redistributions in binary form must reproduce the above copyright
     42    1.1   mycroft  *    notice, this list of conditions and the following disclaimer in the
     43    1.1   mycroft  *    documentation and/or other materials provided with the distribution.
     44  1.130       agc  * 3. Neither the name of the University nor the names of its contributors
     45    1.1   mycroft  *    may be used to endorse or promote products derived from this software
     46    1.1   mycroft  *    without specific prior written permission.
     47    1.1   mycroft  *
     48    1.1   mycroft  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     49    1.1   mycroft  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     50    1.1   mycroft  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     51    1.1   mycroft  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     52    1.1   mycroft  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     53    1.1   mycroft  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     54    1.1   mycroft  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     55    1.1   mycroft  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     56    1.1   mycroft  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     57    1.1   mycroft  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     58    1.1   mycroft  * SUCH DAMAGE.
     59    1.1   mycroft  *
     60   1.16      fvdl  *	@(#)lfs_vfsops.c	8.20 (Berkeley) 6/10/95
     61    1.1   mycroft  */
     62   1.69     lukem 
     63   1.69     lukem #include <sys/cdefs.h>
     64  1.388  perseant __KERNEL_RCSID(0, "$NetBSD: lfs_vfsops.c,v 1.388 2025/09/19 15:55:12 perseant Exp $");
     65   1.19    scottr 
     66   1.65       mrg #if defined(_KERNEL_OPT)
     67  1.251     lukem #include "opt_lfs.h"
     68   1.19    scottr #include "opt_quota.h"
     69  1.380  riastrad #include "opt_uvmhist.h"
     70   1.20    scottr #endif
     71    1.1   mycroft 
     72    1.1   mycroft #include <sys/param.h>
     73    1.1   mycroft #include <sys/systm.h>
     74    1.1   mycroft #include <sys/namei.h>
     75    1.1   mycroft #include <sys/proc.h>
     76    1.1   mycroft #include <sys/kernel.h>
     77    1.1   mycroft #include <sys/vnode.h>
     78    1.1   mycroft #include <sys/mount.h>
     79   1.91  perseant #include <sys/kthread.h>
     80    1.1   mycroft #include <sys/buf.h>
     81   1.38  augustss #include <sys/device.h>
     82    1.1   mycroft #include <sys/file.h>
     83  1.388  perseant #include <sys/fstypes.h>
     84    1.1   mycroft #include <sys/disklabel.h>
     85    1.1   mycroft #include <sys/ioctl.h>
     86    1.1   mycroft #include <sys/errno.h>
     87    1.1   mycroft #include <sys/malloc.h>
     88   1.23   thorpej #include <sys/pool.h>
     89    1.1   mycroft #include <sys/socket.h>
     90  1.165  perseant #include <sys/syslog.h>
     91   1.26  perseant #include <sys/sysctl.h>
     92   1.80   gehenna #include <sys/conf.h>
     93  1.210      elad #include <sys/kauth.h>
     94  1.261    rumble #include <sys/module.h>
     95  1.286     pooka #include <sys/syscallvar.h>
     96  1.286     pooka #include <sys/syscall.h>
     97  1.286     pooka #include <sys/syscallargs.h>
     98    1.1   mycroft 
     99    1.1   mycroft #include <miscfs/specfs/specdev.h>
    100    1.1   mycroft 
    101  1.299  dholland #include <ufs/lfs/ulfs_quotacommon.h>
    102  1.299  dholland #include <ufs/lfs/ulfs_inode.h>
    103  1.299  dholland #include <ufs/lfs/ulfsmount.h>
    104  1.324   hannken #include <ufs/lfs/ulfs_bswap.h>
    105  1.299  dholland #include <ufs/lfs/ulfs_extern.h>
    106    1.1   mycroft 
    107  1.380  riastrad #ifdef UVMHIST
    108   1.91  perseant #include <uvm/uvm.h>
    109  1.380  riastrad #endif
    110  1.380  riastrad #include <uvm/uvm_extern.h>
    111  1.380  riastrad #include <uvm/uvm_object.h>
    112  1.380  riastrad #include <uvm/uvm_page.h>
    113   1.91  perseant #include <uvm/uvm_stat.h>
    114   1.91  perseant 
    115    1.1   mycroft #include <ufs/lfs/lfs.h>
    116  1.329  dholland #include <ufs/lfs/lfs_accessors.h>
    117  1.309  dholland #include <ufs/lfs/lfs_kernel.h>
    118    1.1   mycroft #include <ufs/lfs/lfs_extern.h>
    119    1.1   mycroft 
    120   1.91  perseant #include <miscfs/genfs/genfs.h>
    121   1.91  perseant #include <miscfs/genfs/genfs_node.h>
    122  1.128      yamt 
    123  1.306  christos MODULE(MODULE_CLASS_VFS, lfs, NULL);
    124  1.261    rumble 
    125   1.91  perseant static int lfs_gop_write(struct vnode *, struct vm_page **, int, int);
    126  1.190  christos static int lfs_mountfs(struct vnode *, struct mount *, struct lwp *);
    127  1.371  riastrad static int lfs_flushfiles(struct mount *, int);
    128    1.1   mycroft 
    129   1.63  jdolecek extern const struct vnodeopv_desc lfs_vnodeop_opv_desc;
    130   1.63  jdolecek extern const struct vnodeopv_desc lfs_specop_opv_desc;
    131   1.63  jdolecek extern const struct vnodeopv_desc lfs_fifoop_opv_desc;
    132   1.91  perseant 
    133  1.386  perseant extern int locked_queue_rcount;
    134  1.386  perseant extern long locked_queue_rbytes;
    135  1.386  perseant 
    136  1.356      maya struct lwp * lfs_writer_daemon = NULL;
    137  1.356      maya kcondvar_t lfs_writerd_cv;
    138  1.356      maya 
    139  1.386  perseant struct workqueue *lfs_cluster_wq = NULL;
    140  1.386  perseant struct workqueue *lfs_super_wq = NULL;
    141  1.384  perseant 
    142   1.91  perseant int lfs_do_flush = 0;
    143  1.387  perseant int lfs_do_rfw = 1;
    144   1.15   thorpej 
    145   1.63  jdolecek const struct vnodeopv_desc * const lfs_vnodeopv_descs[] = {
    146   1.15   thorpej 	&lfs_vnodeop_opv_desc,
    147   1.15   thorpej 	&lfs_specop_opv_desc,
    148   1.15   thorpej 	&lfs_fifoop_opv_desc,
    149   1.15   thorpej 	NULL,
    150   1.15   thorpej };
    151   1.15   thorpej 
    152    1.1   mycroft struct vfsops lfs_vfsops = {
    153  1.319   hannken 	.vfs_name = MOUNT_LFS,
    154  1.319   hannken 	.vfs_min_mount_data = sizeof (struct ulfs_args),
    155  1.319   hannken 	.vfs_mount = lfs_mount,
    156  1.319   hannken 	.vfs_start = ulfs_start,
    157  1.319   hannken 	.vfs_unmount = lfs_unmount,
    158  1.319   hannken 	.vfs_root = ulfs_root,
    159  1.319   hannken 	.vfs_quotactl = ulfs_quotactl,
    160  1.319   hannken 	.vfs_statvfs = lfs_statvfs,
    161  1.319   hannken 	.vfs_sync = lfs_sync,
    162  1.319   hannken 	.vfs_vget = lfs_vget,
    163  1.324   hannken 	.vfs_loadvnode = lfs_loadvnode,
    164  1.324   hannken 	.vfs_newvnode = lfs_newvnode,
    165  1.319   hannken 	.vfs_fhtovp = lfs_fhtovp,
    166  1.319   hannken 	.vfs_vptofh = lfs_vptofh,
    167  1.319   hannken 	.vfs_init = lfs_init,
    168  1.319   hannken 	.vfs_reinit = lfs_reinit,
    169  1.319   hannken 	.vfs_done = lfs_done,
    170  1.319   hannken 	.vfs_mountroot = lfs_mountroot,
    171  1.319   hannken 	.vfs_snapshot = (void *)eopnotsupp,
    172  1.319   hannken 	.vfs_extattrctl = lfs_extattrctl,
    173  1.352   hannken 	.vfs_suspendctl = genfs_suspendctl,
    174  1.319   hannken 	.vfs_renamelock_enter = genfs_renamelock_enter,
    175  1.319   hannken 	.vfs_renamelock_exit = genfs_renamelock_exit,
    176  1.319   hannken 	.vfs_fsync = (void *)eopnotsupp,
    177  1.319   hannken 	.vfs_opv_descs = lfs_vnodeopv_descs
    178    1.1   mycroft };
    179    1.1   mycroft 
    180  1.183      yamt const struct genfs_ops lfs_genfsops = {
    181  1.183      yamt 	.gop_size = lfs_gop_size,
    182  1.301  dholland 	.gop_alloc = ulfs_gop_alloc,
    183  1.183      yamt 	.gop_write = lfs_gop_write,
    184  1.301  dholland 	.gop_markupdate = ulfs_gop_markupdate,
    185  1.362       chs 	.gop_putrange = genfs_gop_putrange,
    186   1.71       chs };
    187   1.71       chs 
    188  1.266    rumble struct shortlong {
    189  1.266    rumble 	const char *sname;
    190  1.266    rumble 	const char *lname;
    191  1.266    rumble };
    192  1.266    rumble 
    193  1.266    rumble static int
    194  1.266    rumble sysctl_lfs_dostats(SYSCTLFN_ARGS)
    195  1.266    rumble {
    196  1.266    rumble 	extern struct lfs_stats lfs_stats;
    197  1.266    rumble 	extern int lfs_dostats;
    198  1.266    rumble 	int error;
    199  1.266    rumble 
    200  1.266    rumble 	error = sysctl_lookup(SYSCTLFN_CALL(rnode));
    201  1.266    rumble 	if (error || newp == NULL)
    202  1.266    rumble 		return (error);
    203  1.266    rumble 
    204  1.266    rumble 	if (lfs_dostats == 0)
    205  1.266    rumble 		memset(&lfs_stats, 0, sizeof(lfs_stats));
    206  1.266    rumble 
    207  1.266    rumble 	return (0);
    208  1.266    rumble }
    209  1.266    rumble 
    210  1.377  pgoyette SYSCTL_SETUP(lfs_sysctl_setup, "lfs sysctl")
    211  1.266    rumble {
    212  1.266    rumble 	int i;
    213  1.266    rumble 	extern int lfs_writeindir, lfs_dostats, lfs_clean_vnhead,
    214  1.266    rumble 		   lfs_fs_pagetrip, lfs_ignore_lazy_sync;
    215  1.266    rumble #ifdef DEBUG
    216  1.266    rumble 	extern int lfs_debug_log_subsys[DLOG_MAX];
    217  1.266    rumble 	struct shortlong dlog_names[DLOG_MAX] = { /* Must match lfs.h ! */
    218  1.266    rumble 		{ "rollforward", "Debug roll-forward code" },
    219  1.266    rumble 		{ "alloc",	"Debug inode allocation and free list" },
    220  1.266    rumble 		{ "avail",	"Debug space-available-now accounting" },
    221  1.266    rumble 		{ "flush",	"Debug flush triggers" },
    222  1.266    rumble 		{ "lockedlist",	"Debug locked list accounting" },
    223  1.266    rumble 		{ "vnode_verbose", "Verbose per-vnode-written debugging" },
    224  1.266    rumble 		{ "vnode",	"Debug vnode use during segment write" },
    225  1.266    rumble 		{ "segment",	"Debug segment writing" },
    226  1.266    rumble 		{ "seguse",	"Debug segment used-bytes accounting" },
    227  1.266    rumble 		{ "cleaner",	"Debug cleaning routines" },
    228  1.266    rumble 		{ "mount",	"Debug mount/unmount routines" },
    229  1.266    rumble 		{ "pagecache",	"Debug UBC interactions" },
    230  1.266    rumble 		{ "dirop",	"Debug directory-operation accounting" },
    231  1.266    rumble 		{ "malloc",	"Debug private malloc accounting" },
    232  1.266    rumble 	};
    233  1.266    rumble #endif /* DEBUG */
    234  1.266    rumble 	struct shortlong stat_names[] = { /* Must match lfs.h! */
    235  1.266    rumble 		{ "segsused",	    "Number of new segments allocated" },
    236  1.266    rumble 		{ "psegwrites",	    "Number of partial-segment writes" },
    237  1.266    rumble 		{ "psyncwrites",    "Number of synchronous partial-segment"
    238  1.266    rumble 				    " writes" },
    239  1.266    rumble 		{ "pcleanwrites",   "Number of partial-segment writes by the"
    240  1.266    rumble 				    " cleaner" },
    241  1.266    rumble 		{ "blocktot",       "Number of blocks written" },
    242  1.266    rumble 		{ "cleanblocks",    "Number of blocks written by the cleaner" },
    243  1.266    rumble 		{ "ncheckpoints",   "Number of checkpoints made" },
    244  1.266    rumble 		{ "nwrites",        "Number of whole writes" },
    245  1.266    rumble 		{ "nsync_writes",   "Number of synchronous writes" },
    246  1.266    rumble 		{ "wait_exceeded",  "Number of times writer waited for"
    247  1.266    rumble 				    " cleaner" },
    248  1.266    rumble 		{ "write_exceeded", "Number of times writer invoked flush" },
    249  1.266    rumble 		{ "flush_invoked",  "Number of times flush was invoked" },
    250  1.266    rumble 		{ "vflush_invoked", "Number of time vflush was called" },
    251  1.320   hannken 		{ "clean_inlocked", "Number of vnodes skipped for being dead" },
    252  1.266    rumble 		{ "clean_vnlocked", "Number of vnodes skipped for vget failure" },
    253  1.266    rumble 		{ "segs_reclaimed", "Number of segments reclaimed" },
    254  1.266    rumble 	};
    255  1.266    rumble 
    256  1.280     pooka 	sysctl_createv(clog, 0, NULL, NULL,
    257  1.266    rumble 		       CTLFLAG_PERMANENT,
    258  1.266    rumble 		       CTLTYPE_NODE, "lfs",
    259  1.266    rumble 		       SYSCTL_DESCR("Log-structured file system"),
    260  1.266    rumble 		       NULL, 0, NULL, 0,
    261  1.266    rumble 		       CTL_VFS, 5, CTL_EOL);
    262  1.266    rumble 	/*
    263  1.266    rumble 	 * XXX the "5" above could be dynamic, thereby eliminating one
    264  1.266    rumble 	 * more instance of the "number to vfs" mapping problem, but
    265  1.266    rumble 	 * "5" is the order as taken from sys/mount.h
    266  1.266    rumble 	 */
    267  1.266    rumble 
    268  1.280     pooka 	sysctl_createv(clog, 0, NULL, NULL,
    269  1.266    rumble 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
    270  1.266    rumble 		       CTLTYPE_INT, "flushindir", NULL,
    271  1.266    rumble 		       NULL, 0, &lfs_writeindir, 0,
    272  1.266    rumble 		       CTL_VFS, 5, LFS_WRITEINDIR, CTL_EOL);
    273  1.280     pooka 	sysctl_createv(clog, 0, NULL, NULL,
    274  1.266    rumble 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
    275  1.266    rumble 		       CTLTYPE_INT, "clean_vnhead", NULL,
    276  1.266    rumble 		       NULL, 0, &lfs_clean_vnhead, 0,
    277  1.266    rumble 		       CTL_VFS, 5, LFS_CLEAN_VNHEAD, CTL_EOL);
    278  1.280     pooka 	sysctl_createv(clog, 0, NULL, NULL,
    279  1.266    rumble 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
    280  1.266    rumble 		       CTLTYPE_INT, "dostats",
    281  1.266    rumble 		       SYSCTL_DESCR("Maintain statistics on LFS operations"),
    282  1.266    rumble 		       sysctl_lfs_dostats, 0, &lfs_dostats, 0,
    283  1.266    rumble 		       CTL_VFS, 5, LFS_DOSTATS, CTL_EOL);
    284  1.280     pooka 	sysctl_createv(clog, 0, NULL, NULL,
    285  1.266    rumble 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
    286  1.266    rumble 		       CTLTYPE_INT, "pagetrip",
    287  1.266    rumble 		       SYSCTL_DESCR("How many dirty pages in fs triggers"
    288  1.266    rumble 				    " a flush"),
    289  1.266    rumble 		       NULL, 0, &lfs_fs_pagetrip, 0,
    290  1.266    rumble 		       CTL_VFS, 5, LFS_FS_PAGETRIP, CTL_EOL);
    291  1.280     pooka 	sysctl_createv(clog, 0, NULL, NULL,
    292  1.266    rumble 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
    293  1.266    rumble 		       CTLTYPE_INT, "ignore_lazy_sync",
    294  1.266    rumble 		       SYSCTL_DESCR("Lazy Sync is ignored entirely"),
    295  1.266    rumble 		       NULL, 0, &lfs_ignore_lazy_sync, 0,
    296  1.266    rumble 		       CTL_VFS, 5, LFS_IGNORE_LAZY_SYNC, CTL_EOL);
    297  1.280     pooka 	sysctl_createv(clog, 0, NULL, NULL,
    298  1.266    rumble 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
    299  1.266    rumble 		       CTLTYPE_INT, "rfw",
    300  1.266    rumble 		       SYSCTL_DESCR("Use in-kernel roll-forward on mount"),
    301  1.266    rumble 		       NULL, 0, &lfs_do_rfw, 0,
    302  1.266    rumble 		       CTL_VFS, 5, LFS_DO_RFW, CTL_EOL);
    303  1.387  perseant 	sysctl_createv(clog, 0, NULL, NULL,
    304  1.387  perseant 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
    305  1.387  perseant 		       CTLTYPE_INT, "rfw_limit",
    306  1.387  perseant 		       SYSCTL_DESCR("Maximum number of partial segments"
    307  1.387  perseant 				    " to roll forward"),
    308  1.387  perseant 		       NULL, 0, &lfs_rfw_max_psegs, 0,
    309  1.387  perseant 		       CTL_VFS, 5, LFS_RFW_LIMIT, CTL_EOL);
    310  1.266    rumble 
    311  1.280     pooka 	sysctl_createv(clog, 0, NULL, NULL,
    312  1.266    rumble 		       CTLFLAG_PERMANENT,
    313  1.266    rumble 		       CTLTYPE_NODE, "stats",
    314  1.387  perseant 		       SYSCTL_DESCR("Statistics"),
    315  1.266    rumble 		       NULL, 0, NULL, 0,
    316  1.266    rumble 		       CTL_VFS, 5, LFS_STATS, CTL_EOL);
    317  1.266    rumble 	for (i = 0; i < sizeof(struct lfs_stats) / sizeof(u_int); i++) {
    318  1.280     pooka 		sysctl_createv(clog, 0, NULL, NULL,
    319  1.266    rumble 			       CTLFLAG_PERMANENT|CTLFLAG_READONLY,
    320  1.266    rumble 			       CTLTYPE_INT, stat_names[i].sname,
    321  1.266    rumble 			       SYSCTL_DESCR(stat_names[i].lname),
    322  1.266    rumble 			       NULL, 0, &(((u_int *)&lfs_stats.segsused)[i]),
    323  1.266    rumble 			       0, CTL_VFS, 5, LFS_STATS, i, CTL_EOL);
    324  1.266    rumble 	}
    325  1.387  perseant 
    326  1.266    rumble #ifdef DEBUG
    327  1.280     pooka 	sysctl_createv(clog, 0, NULL, NULL,
    328  1.266    rumble 		       CTLFLAG_PERMANENT,
    329  1.266    rumble 		       CTLTYPE_NODE, "debug",
    330  1.387  perseant 		       SYSCTL_DESCR("Debug options"),
    331  1.387  perseant 		       NULL, 0, NULL, 0,
    332  1.387  perseant 		       CTL_VFS, 5, LFS_DEBUG, CTL_EOL);
    333  1.387  perseant 	sysctl_createv(clog, 0, NULL, NULL,
    334  1.387  perseant 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
    335  1.387  perseant 		       CTLTYPE_INT, "freelist",
    336  1.387  perseant 		       SYSCTL_DESCR("Track consistency of inode freelist"),
    337  1.387  perseant 		       NULL, 0, &lfs_do_check_freelist, 0,
    338  1.387  perseant 		       CTL_VFS, 5, LFS_DEBUG, LFS_DEBUG_FREELIST, CTL_EOL);
    339  1.387  perseant 	sysctl_createv(clog, 0, NULL, NULL,
    340  1.387  perseant 		       CTLFLAG_PERMANENT,
    341  1.387  perseant 		       CTLTYPE_NODE, "log",
    342  1.387  perseant 		       SYSCTL_DESCR("Verbose logging"),
    343  1.266    rumble 		       NULL, 0, NULL, 0,
    344  1.387  perseant 		       CTL_VFS, 5, LFS_DEBUG, LFS_DEBUG_LOG, CTL_EOL);
    345  1.266    rumble 	for (i = 0; i < DLOG_MAX; i++) {
    346  1.280     pooka 		sysctl_createv(clog, 0, NULL, NULL,
    347  1.266    rumble 			       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
    348  1.266    rumble 			       CTLTYPE_INT, dlog_names[i].sname,
    349  1.266    rumble 			       SYSCTL_DESCR(dlog_names[i].lname),
    350  1.266    rumble 			       NULL, 0, &(lfs_debug_log_subsys[i]), 0,
    351  1.387  perseant 			       CTL_VFS, 5, LFS_DEBUG, LFS_DEBUG_LOG, i, CTL_EOL);
    352  1.266    rumble 	}
    353  1.266    rumble #endif
    354  1.266    rumble }
    355  1.266    rumble 
    356  1.286     pooka /* old cleaner syscall interface.  see VOP_FCNTL() */
    357  1.286     pooka static const struct syscall_package lfs_syscalls[] = {
    358  1.286     pooka 	{ SYS_lfs_bmapv,	0, (sy_call_t *)sys_lfs_bmapv		},
    359  1.286     pooka 	{ SYS_lfs_markv,	0, (sy_call_t *)sys_lfs_markv		},
    360  1.335  dholland 	{ SYS___lfs_segwait50,	0, (sy_call_t *)sys___lfs_segwait50	},
    361  1.335  dholland 	{ SYS_lfs_segclean,	0, (sy_call_t *)sys_lfs_segclean	},
    362  1.286     pooka 	{ 0, 0, NULL },
    363  1.286     pooka };
    364  1.286     pooka 
    365  1.261    rumble static int
    366  1.261    rumble lfs_modcmd(modcmd_t cmd, void *arg)
    367  1.261    rumble {
    368  1.266    rumble 	int error;
    369  1.261    rumble 
    370  1.261    rumble 	switch (cmd) {
    371  1.261    rumble 	case MODULE_CMD_INIT:
    372  1.286     pooka 		error = syscall_establish(NULL, lfs_syscalls);
    373  1.286     pooka 		if (error)
    374  1.286     pooka 			return error;
    375  1.266    rumble 		error = vfs_attach(&lfs_vfsops);
    376  1.286     pooka 		if (error != 0) {
    377  1.286     pooka 			syscall_disestablish(NULL, lfs_syscalls);
    378  1.266    rumble 			break;
    379  1.286     pooka 		}
    380  1.372  riastrad 		cv_init(&lfs_allclean_wakeup, "segment");
    381  1.266    rumble 		break;
    382  1.261    rumble 	case MODULE_CMD_FINI:
    383  1.266    rumble 		error = vfs_detach(&lfs_vfsops);
    384  1.266    rumble 		if (error != 0)
    385  1.266    rumble 			break;
    386  1.286     pooka 		syscall_disestablish(NULL, lfs_syscalls);
    387  1.372  riastrad 		cv_destroy(&lfs_allclean_wakeup);
    388  1.266    rumble 		break;
    389  1.261    rumble 	default:
    390  1.266    rumble 		error = ENOTTY;
    391  1.266    rumble 		break;
    392  1.261    rumble 	}
    393  1.266    rumble 
    394  1.266    rumble 	return (error);
    395  1.261    rumble }
    396  1.261    rumble 
    397  1.149    simonb /*
    398  1.149    simonb  * XXX Same structure as FFS inodes?  Should we share a common pool?
    399  1.149    simonb  */
    400  1.236     pooka struct pool lfs_inode_pool;
    401  1.236     pooka struct pool lfs_dinode_pool;
    402  1.236     pooka struct pool lfs_inoext_pool;
    403  1.236     pooka struct pool lfs_lbnentry_pool;
    404   1.91  perseant 
    405   1.91  perseant /*
    406   1.91  perseant  * The writer daemon.  UVM keeps track of how many dirty pages we are holding
    407   1.91  perseant  * in lfs_subsys_pages; the daemon flushes the filesystem when this value
    408  1.381    andvar  * crosses the (user-defined) threshold LFS_MAX_PAGES.
    409   1.91  perseant  */
    410   1.91  perseant static void
    411  1.224  christos lfs_writerd(void *arg)
    412   1.91  perseant {
    413  1.357   hannken 	mount_iterator_t *iter;
    414  1.357   hannken  	struct mount *mp;
    415  1.292  perseant  	struct lfs *fs;
    416  1.292  perseant 	struct vfsops *vfs = NULL;
    417  1.292  perseant  	int fsflags;
    418  1.292  perseant 	int lfsc;
    419  1.292  perseant 	int wrote_something = 0;
    420  1.292  perseant 
    421  1.292  perseant 	mutex_enter(&lfs_lock);
    422  1.356      maya 	KASSERTMSG(lfs_writer_daemon == NULL, "more than one LFS writer daemon");
    423  1.356      maya 	lfs_writer_daemon = curlwp;
    424  1.292  perseant 	mutex_exit(&lfs_lock);
    425   1.91  perseant 
    426  1.292  perseant 	/* Take an extra reference to the LFS vfsops. */
    427  1.292  perseant 	vfs = vfs_getopsbyname(MOUNT_LFS);
    428  1.292  perseant 
    429  1.292  perseant  	mutex_enter(&lfs_lock);
    430  1.292  perseant  	for (;;) {
    431  1.292  perseant 		KASSERT(mutex_owned(&lfs_lock));
    432  1.292  perseant 		if (wrote_something == 0)
    433  1.356      maya 			cv_timedwait(&lfs_writerd_cv, &lfs_lock, hz/10 + 1);
    434  1.292  perseant 		KASSERT(mutex_owned(&lfs_lock));
    435  1.292  perseant 		wrote_something = 0;
    436   1.23   thorpej 
    437   1.91  perseant 		/*
    438   1.91  perseant 		 * If global state wants a flush, flush everything.
    439   1.91  perseant 		 */
    440  1.387  perseant 		if (lfs_do_flush || locked_queue_count + locked_queue_rcount > LFS_MAX_BUFS ||
    441  1.387  perseant 			locked_queue_bytes + locked_queue_rbytes > LFS_MAX_BYTES ||
    442   1.91  perseant 			lfs_subsys_pages > LFS_MAX_PAGES) {
    443   1.91  perseant 
    444  1.222  christos 			if (lfs_do_flush) {
    445  1.292  perseant 				DLOG((DLOG_FLUSH, "lfs_writerd: lfs_do_flush\n"));
    446  1.222  christos 			}
    447  1.387  perseant 			if (locked_queue_count + locked_queue_rcount > LFS_MAX_BUFS) {
    448  1.387  perseant 				DLOG((DLOG_FLUSH, "lfs_writerd: lqc+lqrc = %d, max %d\n",
    449  1.166  perseant 				      locked_queue_count, LFS_MAX_BUFS));
    450  1.222  christos 			}
    451  1.387  perseant 			if (locked_queue_bytes + locked_queue_rbytes > LFS_MAX_BYTES) {
    452  1.387  perseant 				DLOG((DLOG_FLUSH, "lfs_writerd: lqb + lqrb = %ld, max %ld\n",
    453  1.166  perseant 				      locked_queue_bytes, LFS_MAX_BYTES));
    454  1.222  christos 			}
    455  1.222  christos 			if (lfs_subsys_pages > LFS_MAX_PAGES) {
    456  1.292  perseant 				DLOG((DLOG_FLUSH, "lfs_writerd: lssp = %d, max %d\n",
    457  1.166  perseant 				      lfs_subsys_pages, LFS_MAX_PAGES));
    458  1.222  christos 			}
    459  1.166  perseant 
    460  1.163  perseant 			lfs_flush(NULL, SEGM_WRITERD, 0);
    461   1.91  perseant 			lfs_do_flush = 0;
    462  1.292  perseant 			KASSERT(mutex_owned(&lfs_lock));
    463  1.292  perseant 			continue;
    464   1.91  perseant 		}
    465  1.292  perseant 		KASSERT(mutex_owned(&lfs_lock));
    466  1.292  perseant 		mutex_exit(&lfs_lock);
    467  1.292  perseant 
    468  1.292  perseant  		/*
    469  1.292  perseant  		 * Look through the list of LFSs to see if any of them
    470  1.292  perseant  		 * have requested pageouts.
    471  1.292  perseant  		 */
    472  1.357   hannken  		mountlist_iterator_init(&iter);
    473  1.292  perseant 		lfsc = 0;
    474  1.357   hannken 		while ((mp = mountlist_iterator_next(iter)) != NULL) {
    475  1.292  perseant 			KASSERT(!mutex_owned(&lfs_lock));
    476  1.292  perseant  			if (strncmp(mp->mnt_stat.f_fstypename, MOUNT_LFS,
    477  1.292  perseant  			    sizeof(mp->mnt_stat.f_fstypename)) == 0) {
    478  1.292  perseant 				++lfsc;
    479  1.301  dholland  				fs = VFSTOULFS(mp)->um_lfs;
    480  1.331  dholland 				daddr_t ooffset = 0;
    481  1.292  perseant 				fsflags = SEGM_SINGLE;
    482  1.292  perseant 
    483  1.292  perseant  				mutex_enter(&lfs_lock);
    484  1.327  dholland 				ooffset = lfs_sb_getoffset(fs);
    485  1.292  perseant 
    486  1.327  dholland 				if (lfs_sb_getnextseg(fs) < lfs_sb_getcurseg(fs) && fs->lfs_nowrap) {
    487  1.292  perseant 					/* Don't try to write if we're suspended */
    488  1.292  perseant 					mutex_exit(&lfs_lock);
    489  1.292  perseant 					continue;
    490  1.292  perseant 				}
    491  1.292  perseant 				if (LFS_STARVED_FOR_SEGS(fs)) {
    492  1.292  perseant 					mutex_exit(&lfs_lock);
    493  1.292  perseant 
    494  1.292  perseant 					DLOG((DLOG_FLUSH, "lfs_writerd: need cleaning before writing possible\n"));
    495  1.292  perseant 					lfs_wakeup_cleaner(fs);
    496  1.292  perseant 					continue;
    497  1.292  perseant 				}
    498  1.292  perseant 
    499  1.292  perseant  				if ((fs->lfs_dirvcount > LFS_MAX_FSDIROP(fs) ||
    500  1.292  perseant  				     lfs_dirvcount > LFS_MAX_DIROP) &&
    501  1.292  perseant 				    fs->lfs_dirops == 0) {
    502  1.292  perseant 					fsflags &= ~SEGM_SINGLE;
    503  1.292  perseant  					fsflags |= SEGM_CKP;
    504  1.292  perseant 					DLOG((DLOG_FLUSH, "lfs_writerd: checkpoint\n"));
    505  1.292  perseant 					lfs_flush_fs(fs, fsflags);
    506  1.292  perseant 				} else if (fs->lfs_pdflush) {
    507  1.292  perseant  					DLOG((DLOG_FLUSH, "lfs_writerd: pdflush set\n"));
    508  1.292  perseant  					lfs_flush_fs(fs, fsflags);
    509  1.292  perseant  				} else if (!TAILQ_EMPTY(&fs->lfs_pchainhd)) {
    510  1.292  perseant  					DLOG((DLOG_FLUSH, "lfs_writerd: pchain non-empty\n"));
    511  1.292  perseant  					mutex_exit(&lfs_lock);
    512  1.292  perseant  					lfs_writer_enter(fs, "wrdirop");
    513  1.292  perseant  					lfs_flush_pchain(fs);
    514  1.292  perseant  					lfs_writer_leave(fs);
    515  1.292  perseant 					mutex_enter(&lfs_lock);
    516  1.292  perseant 				}
    517  1.327  dholland 				if (lfs_sb_getoffset(fs) != ooffset)
    518  1.292  perseant 					++wrote_something;
    519  1.292  perseant 				mutex_exit(&lfs_lock);
    520  1.292  perseant  			}
    521  1.292  perseant 			KASSERT(!mutex_owned(&lfs_lock));
    522  1.292  perseant  		}
    523  1.357   hannken 		if (lfsc == 0) {
    524  1.292  perseant 			mutex_enter(&lfs_lock);
    525  1.356      maya 			lfs_writer_daemon = NULL;
    526  1.292  perseant 			mutex_exit(&lfs_lock);
    527  1.357   hannken 			mountlist_iterator_destroy(iter);
    528  1.292  perseant 			break;
    529  1.292  perseant 		}
    530  1.357   hannken  		mountlist_iterator_destroy(iter);
    531  1.292  perseant 
    532  1.292  perseant  		mutex_enter(&lfs_lock);
    533  1.292  perseant  	}
    534  1.292  perseant 	KASSERT(!mutex_owned(&lfs_lock));
    535  1.292  perseant 
    536  1.292  perseant 	/* Give up our extra reference so the module can be unloaded. */
    537  1.292  perseant 	mutex_enter(&vfs_list_lock);
    538  1.292  perseant 	if (vfs != NULL)
    539  1.292  perseant 		vfs->vfs_refcount--;
    540  1.292  perseant 	mutex_exit(&vfs_list_lock);
    541  1.293  perseant 
    542  1.293  perseant 	/* Done! */
    543  1.293  perseant 	kthread_exit(0);
    544   1.91  perseant }
    545   1.60  perseant 
    546   1.16      fvdl /*
    547  1.301  dholland  * Initialize the filesystem, most work done by ulfs_init.
    548   1.16      fvdl  */
    549   1.16      fvdl void
    550  1.271    cegger lfs_init(void)
    551   1.16      fvdl {
    552  1.236     pooka 
    553  1.340  dholland 	/*
    554  1.340  dholland 	 * XXX: should we use separate pools for 32-bit and 64-bit
    555  1.340  dholland 	 * dinodes?
    556  1.340  dholland 	 */
    557  1.146    atatat 	malloc_type_attach(M_SEGMENT);
    558  1.150    atatat 	pool_init(&lfs_inode_pool, sizeof(struct inode), 0, 0, 0,
    559  1.233        ad 	    "lfsinopl", &pool_allocator_nointr, IPL_NONE);
    560  1.340  dholland 	pool_init(&lfs_dinode_pool, sizeof(union lfs_dinode), 0, 0, 0,
    561  1.233        ad 	    "lfsdinopl", &pool_allocator_nointr, IPL_NONE);
    562  1.150    atatat 	pool_init(&lfs_inoext_pool, sizeof(struct lfs_inode_ext), 8, 0, 0,
    563  1.233        ad 	    "lfsinoextpl", &pool_allocator_nointr, IPL_NONE);
    564  1.163  perseant 	pool_init(&lfs_lbnentry_pool, sizeof(struct lbnentry), 0, 0, 0,
    565  1.233        ad 	    "lfslbnpool", &pool_allocator_nointr, IPL_NONE);
    566  1.301  dholland 	ulfs_init();
    567   1.56  perseant 
    568   1.74  perseant #ifdef DEBUG
    569   1.74  perseant 	memset(lfs_log, 0, sizeof(lfs_log));
    570   1.74  perseant #endif
    571  1.252        ad 	mutex_init(&lfs_lock, MUTEX_DEFAULT, IPL_NONE);
    572  1.356      maya 	cv_init(&lfs_writerd_cv, "lfswrite");
    573  1.252        ad 	cv_init(&locked_queue_cv, "lfsbuf");
    574  1.252        ad 	cv_init(&lfs_writing_cv, "lfsflush");
    575  1.386  perseant 	workqueue_create(&lfs_cluster_wq, "lfscwq", lfs_cluster_work, NULL,
    576  1.384  perseant 					PRI_BIO, IPL_BIO, WQ_MPSAFE);
    577  1.386  perseant 	workqueue_create(&lfs_super_wq, "lfsswq", lfs_super_work, NULL,
    578  1.386  perseant  					PRI_BIO, IPL_BIO, WQ_MPSAFE);
    579   1.67       chs }
    580   1.67       chs 
    581   1.67       chs void
    582  1.271    cegger lfs_reinit(void)
    583   1.67       chs {
    584  1.301  dholland 	ulfs_reinit();
    585   1.47  jdolecek }
    586   1.47  jdolecek 
    587   1.47  jdolecek void
    588  1.271    cegger lfs_done(void)
    589   1.47  jdolecek {
    590  1.301  dholland 	ulfs_done();
    591  1.252        ad 	mutex_destroy(&lfs_lock);
    592  1.356      maya 	cv_destroy(&lfs_writerd_cv);
    593  1.252        ad 	cv_destroy(&locked_queue_cv);
    594  1.252        ad 	cv_destroy(&lfs_writing_cv);
    595  1.386  perseant 	workqueue_destroy(lfs_cluster_wq);
    596  1.386  perseant 	workqueue_destroy(lfs_super_wq);
    597   1.47  jdolecek 	pool_destroy(&lfs_inode_pool);
    598  1.144     oster 	pool_destroy(&lfs_dinode_pool);
    599  1.106  perseant 	pool_destroy(&lfs_inoext_pool);
    600  1.174  perseant 	pool_destroy(&lfs_lbnentry_pool);
    601  1.146    atatat 	malloc_type_detach(M_SEGMENT);
    602   1.16      fvdl }
    603   1.16      fvdl 
    604   1.16      fvdl /*
    605  1.301  dholland  * Called by main() when ulfs is going to be mounted as root.
    606   1.16      fvdl  */
    607    1.1   mycroft int
    608  1.271    cegger lfs_mountroot(void)
    609    1.1   mycroft {
    610   1.16      fvdl 	extern struct vnode *rootvp;
    611  1.284       eeh 	struct lfs *fs = NULL;				/* LFS */
    612   1.16      fvdl 	struct mount *mp;
    613  1.249     pooka 	struct lwp *l = curlwp;
    614  1.301  dholland 	struct ulfsmount *ump;
    615   1.16      fvdl 	int error;
    616  1.164     perry 
    617  1.193   thorpej 	if (device_class(root_device) != DV_DISK)
    618   1.37  sommerfe 		return (ENODEV);
    619   1.37  sommerfe 
    620   1.37  sommerfe 	if (rootdev == NODEV)
    621   1.96  perseant 		return (ENODEV);
    622   1.35  wrstuden 	if ((error = vfs_rootmountalloc(MOUNT_LFS, "root_device", &mp))) {
    623   1.35  wrstuden 		vrele(rootvp);
    624   1.16      fvdl 		return (error);
    625   1.35  wrstuden 	}
    626  1.190  christos 	if ((error = lfs_mountfs(rootvp, mp, l))) {
    627  1.359   hannken 		vfs_unbusy(mp);
    628  1.358   hannken 		vfs_rele(mp);
    629   1.16      fvdl 		return (error);
    630   1.16      fvdl 	}
    631  1.316  christos 	mountlist_append(mp);
    632  1.301  dholland 	ump = VFSTOULFS(mp);
    633  1.284       eeh 	fs = ump->um_lfs;
    634  1.333  dholland 	lfs_sb_setfsmnt(fs, mp->mnt_stat.f_mntonname);
    635  1.249     pooka 	(void)lfs_statvfs(mp, &mp->mnt_stat);
    636  1.359   hannken 	vfs_unbusy(mp);
    637  1.327  dholland 	setrootfstime((time_t)lfs_sb_gettstamp(VFSTOULFS(mp)->um_lfs));
    638   1.16      fvdl 	return (0);
    639    1.1   mycroft }
    640    1.1   mycroft 
    641    1.1   mycroft /*
    642    1.1   mycroft  * VFS Operations.
    643    1.1   mycroft  *
    644    1.1   mycroft  * mount system call
    645    1.1   mycroft  */
    646   1.10  christos int
    647  1.249     pooka lfs_mount(struct mount *mp, const char *path, void *data, size_t *data_len)
    648    1.1   mycroft {
    649  1.249     pooka 	struct lwp *l = curlwp;
    650    1.1   mycroft 	struct vnode *devvp;
    651  1.301  dholland 	struct ulfs_args *args = data;
    652  1.301  dholland 	struct ulfsmount *ump = NULL;
    653   1.48  augustss 	struct lfs *fs = NULL;				/* LFS */
    654  1.238       dsl 	int error = 0, update;
    655    1.3   mycroft 	mode_t accessmode;
    656    1.1   mycroft 
    657  1.321      maxv 	if (args == NULL)
    658  1.321      maxv 		return EINVAL;
    659  1.238       dsl 	if (*data_len < sizeof *args)
    660  1.238       dsl 		return EINVAL;
    661  1.238       dsl 
    662   1.81  christos 	if (mp->mnt_flag & MNT_GETARGS) {
    663  1.301  dholland 		ump = VFSTOULFS(mp);
    664   1.81  christos 		if (ump == NULL)
    665   1.81  christos 			return EIO;
    666  1.238       dsl 		args->fspec = NULL;
    667  1.238       dsl 		*data_len = sizeof *args;
    668  1.238       dsl 		return 0;
    669   1.81  christos 	}
    670    1.1   mycroft 
    671  1.161   mycroft 	update = mp->mnt_flag & MNT_UPDATE;
    672  1.161   mycroft 
    673  1.162   mycroft 	/* Check arguments */
    674  1.238       dsl 	if (args->fspec != NULL) {
    675  1.161   mycroft 		/*
    676  1.161   mycroft 		 * Look up the name and verify that it's sane.
    677  1.161   mycroft 		 */
    678  1.274  dholland 		error = namei_simple_user(args->fspec,
    679  1.274  dholland 					NSM_FOLLOW_NOEMULROOT, &devvp);
    680  1.274  dholland 		if (error != 0)
    681  1.161   mycroft 			return (error);
    682  1.161   mycroft 
    683  1.161   mycroft 		if (!update) {
    684    1.3   mycroft 			/*
    685  1.161   mycroft 			 * Be sure this is a valid block device
    686    1.3   mycroft 			 */
    687  1.161   mycroft 			if (devvp->v_type != VBLK)
    688  1.161   mycroft 				error = ENOTBLK;
    689  1.161   mycroft 			else if (bdevsw_lookup(devvp->v_rdev) == NULL)
    690  1.161   mycroft 				error = ENXIO;
    691  1.161   mycroft 		} else {
    692    1.1   mycroft 			/*
    693  1.161   mycroft 			 * Be sure we're still naming the same device
    694  1.161   mycroft 			 * used for our initial mount
    695  1.347  dholland 			 *
    696  1.347  dholland 			 * XXX dholland 20151010: if namei gives us a
    697  1.347  dholland 			 * different vnode for the same device,
    698  1.347  dholland 			 * wouldn't it be better to use it going
    699  1.347  dholland 			 * forward rather than ignore it in favor of
    700  1.347  dholland 			 * the old one?
    701    1.1   mycroft 			 */
    702  1.301  dholland 			ump = VFSTOULFS(mp);
    703  1.347  dholland 			fs = ump->um_lfs;
    704  1.347  dholland 			if (devvp != fs->lfs_devvp) {
    705  1.347  dholland 				if (devvp->v_rdev != fs->lfs_devvp->v_rdev)
    706  1.284       eeh 					error = EINVAL;
    707  1.284       eeh 				else {
    708  1.284       eeh 					vrele(devvp);
    709  1.347  dholland 					devvp = fs->lfs_devvp;
    710  1.284       eeh 					vref(devvp);
    711  1.284       eeh 				}
    712  1.284       eeh 			}
    713    1.1   mycroft 		}
    714  1.162   mycroft 	} else {
    715  1.162   mycroft 		if (!update) {
    716  1.162   mycroft 			/* New mounts must have a filename for the device */
    717  1.162   mycroft 			return (EINVAL);
    718  1.162   mycroft 		} else {
    719  1.162   mycroft 			/* Use the extant mount */
    720  1.301  dholland 			ump = VFSTOULFS(mp);
    721  1.347  dholland 			fs = ump->um_lfs;
    722  1.347  dholland 			devvp = fs->lfs_devvp;
    723  1.162   mycroft 			vref(devvp);
    724  1.162   mycroft 		}
    725    1.1   mycroft 	}
    726  1.161   mycroft 
    727  1.162   mycroft 
    728    1.3   mycroft 	/*
    729    1.3   mycroft 	 * If mount by non-root, then verify that user has necessary
    730    1.3   mycroft 	 * permissions on the device.
    731    1.3   mycroft 	 */
    732  1.273      elad 	if (error == 0) {
    733    1.3   mycroft 		accessmode = VREAD;
    734  1.161   mycroft 		if (update ?
    735  1.161   mycroft 		    (mp->mnt_iflag & IMNT_WANTRDWR) != 0 :
    736  1.161   mycroft 		    (mp->mnt_flag & MNT_RDONLY) == 0)
    737    1.3   mycroft 			accessmode |= VWRITE;
    738   1.16      fvdl 		vn_lock(devvp, LK_EXCLUSIVE | LK_RETRY);
    739  1.295      elad 		error = kauth_authorize_system(l->l_cred, KAUTH_SYSTEM_MOUNT,
    740  1.295      elad 		    KAUTH_REQ_SYSTEM_MOUNT_DEVICE, mp, devvp,
    741  1.295      elad 		    KAUTH_ARG(accessmode));
    742  1.287   hannken 		VOP_UNLOCK(devvp);
    743    1.3   mycroft 	}
    744  1.161   mycroft 
    745    1.1   mycroft 	if (error) {
    746    1.1   mycroft 		vrele(devvp);
    747    1.1   mycroft 		return (error);
    748    1.1   mycroft 	}
    749  1.161   mycroft 
    750  1.161   mycroft 	if (!update) {
    751  1.161   mycroft 		int flags;
    752  1.161   mycroft 
    753  1.161   mycroft 		if (mp->mnt_flag & MNT_RDONLY)
    754  1.161   mycroft 			flags = FREAD;
    755  1.161   mycroft 		else
    756  1.161   mycroft 			flags = FREAD|FWRITE;
    757  1.291   hannken 		vn_lock(devvp, LK_EXCLUSIVE | LK_RETRY);
    758  1.249     pooka 		error = VOP_OPEN(devvp, flags, FSCRED);
    759  1.291   hannken 		VOP_UNLOCK(devvp);
    760  1.161   mycroft 		if (error)
    761  1.161   mycroft 			goto fail;
    762  1.190  christos 		error = lfs_mountfs(devvp, mp, l);		/* LFS */
    763  1.161   mycroft 		if (error) {
    764  1.161   mycroft 			vn_lock(devvp, LK_EXCLUSIVE | LK_RETRY);
    765  1.249     pooka 			(void)VOP_CLOSE(devvp, flags, NOCRED);
    766  1.287   hannken 			VOP_UNLOCK(devvp);
    767  1.161   mycroft 			goto fail;
    768  1.161   mycroft 		}
    769  1.161   mycroft 
    770  1.301  dholland 		ump = VFSTOULFS(mp);
    771  1.161   mycroft 		fs = ump->um_lfs;
    772  1.161   mycroft 	} else {
    773  1.161   mycroft 		/*
    774  1.161   mycroft 		 * Update the mount.
    775  1.161   mycroft 		 */
    776  1.161   mycroft 
    777  1.161   mycroft 		/*
    778  1.161   mycroft 		 * The initial mount got a reference on this
    779  1.161   mycroft 		 * device, so drop the one obtained via
    780  1.161   mycroft 		 * namei(), above.
    781  1.161   mycroft 		 */
    782  1.161   mycroft 		vrele(devvp);
    783  1.161   mycroft 
    784  1.301  dholland 		ump = VFSTOULFS(mp);
    785  1.161   mycroft 		fs = ump->um_lfs;
    786  1.312  dholland 
    787  1.371  riastrad 		if (!fs->lfs_ronly && (mp->mnt_iflag & IMNT_WANTRDONLY)) {
    788  1.312  dholland 			/*
    789  1.312  dholland 			 * Changing from read/write to read-only.
    790  1.312  dholland 			 */
    791  1.371  riastrad 			int flags = WRITECLOSE;
    792  1.371  riastrad 			if (mp->mnt_flag & MNT_FORCE)
    793  1.371  riastrad 				flags |= FORCECLOSE;
    794  1.371  riastrad 			error = lfs_flushfiles(mp, flags);
    795  1.371  riastrad 			if (error)
    796  1.371  riastrad 				return error;
    797  1.371  riastrad 			fs->lfs_ronly = 1;
    798  1.371  riastrad 		} else if (fs->lfs_ronly && (mp->mnt_iflag & IMNT_WANTRDWR)) {
    799  1.161   mycroft 			/*
    800  1.198  perseant 			 * Changing from read-only to read/write.
    801  1.198  perseant 			 * Note in the superblocks that we're writing.
    802  1.161   mycroft 			 */
    803  1.312  dholland 
    804  1.312  dholland 			/* XXX: quotas should have been on even if readonly */
    805  1.312  dholland 			if (fs->lfs_use_quota2) {
    806  1.312  dholland #ifdef LFS_QUOTA2
    807  1.312  dholland 				error = lfs_quota2_mount(mp);
    808  1.312  dholland #else
    809  1.312  dholland 				uprintf("%s: no kernel support for this "
    810  1.312  dholland 					"filesystem's quotas\n",
    811  1.312  dholland 					mp->mnt_stat.f_mntonname);
    812  1.312  dholland 				if (mp->mnt_flag & MNT_FORCE) {
    813  1.312  dholland 					uprintf("%s: mounting anyway; "
    814  1.312  dholland 						"fsck afterwards\n",
    815  1.312  dholland 						mp->mnt_stat.f_mntonname);
    816  1.312  dholland 				} else {
    817  1.312  dholland 					error = EINVAL;
    818  1.312  dholland 				}
    819  1.312  dholland #endif
    820  1.312  dholland 				if (error) {
    821  1.312  dholland 					return error;
    822  1.312  dholland 				}
    823  1.312  dholland 			}
    824  1.312  dholland 
    825  1.161   mycroft 			fs->lfs_ronly = 0;
    826  1.328  dholland 			if (lfs_sb_getpflags(fs) & LFS_PF_CLEAN) {
    827  1.328  dholland 				lfs_sb_setpflags(fs, lfs_sb_getpflags(fs) & ~LFS_PF_CLEAN);
    828  1.328  dholland 				lfs_writesuper(fs, lfs_sb_getsboff(fs, 0));
    829  1.328  dholland 				lfs_writesuper(fs, lfs_sb_getsboff(fs, 1));
    830  1.198  perseant 			}
    831  1.161   mycroft 		}
    832  1.371  riastrad 
    833  1.238       dsl 		if (args->fspec == NULL)
    834  1.371  riastrad 			return 0;
    835  1.161   mycroft 	}
    836  1.161   mycroft 
    837  1.238       dsl 	error = set_statvfs_info(path, UIO_USERSPACE, args->fspec,
    838  1.239     pooka 	    UIO_USERSPACE, mp->mnt_op->vfs_name, mp, l);
    839  1.179  perseant 	if (error == 0)
    840  1.333  dholland 		lfs_sb_setfsmnt(fs, mp->mnt_stat.f_mntonname);
    841  1.179  perseant 	return error;
    842  1.161   mycroft 
    843  1.161   mycroft fail:
    844  1.161   mycroft 	vrele(devvp);
    845  1.161   mycroft 	return (error);
    846    1.1   mycroft }
    847    1.1   mycroft 
    848  1.348  dholland /*
    849  1.348  dholland  * Helper for mountfs. Note that the fs pointer may be a dummy one
    850  1.348  dholland  * pointing into a superblock buffer. (Which is gross; see below.)
    851  1.348  dholland  */
    852  1.348  dholland static int
    853  1.348  dholland lfs_checkmagic(struct lfs *fs)
    854  1.348  dholland {
    855  1.348  dholland 	switch (fs->lfs_dlfs_u.u_32.dlfs_magic) {
    856  1.348  dholland 	    case LFS_MAGIC:
    857  1.348  dholland 		fs->lfs_is64 = false;
    858  1.348  dholland 		fs->lfs_dobyteswap = false;
    859  1.348  dholland 		break;
    860  1.348  dholland 	    case LFS64_MAGIC:
    861  1.348  dholland 		fs->lfs_is64 = true;
    862  1.348  dholland 		fs->lfs_dobyteswap = false;
    863  1.348  dholland 		break;
    864  1.348  dholland #ifdef LFS_EI
    865  1.348  dholland 	    case LFS_MAGIC_SWAPPED:
    866  1.348  dholland 		fs->lfs_is64 = false;
    867  1.348  dholland 		fs->lfs_dobyteswap = true;
    868  1.348  dholland 		break;
    869  1.348  dholland 	    case LFS64_MAGIC_SWAPPED:
    870  1.348  dholland 		fs->lfs_is64 = true;
    871  1.348  dholland 		fs->lfs_dobyteswap = true;
    872  1.348  dholland 		break;
    873  1.348  dholland #endif
    874  1.348  dholland 	    default:
    875  1.348  dholland 		/* XXX needs translation */
    876  1.348  dholland 		return EINVAL;
    877  1.348  dholland 	}
    878  1.348  dholland 	return 0;
    879  1.348  dholland }
    880   1.60  perseant 
    881    1.1   mycroft /*
    882    1.1   mycroft  * Common code for mount and mountroot
    883    1.1   mycroft  * LFS specific
    884    1.1   mycroft  */
    885    1.1   mycroft int
    886  1.190  christos lfs_mountfs(struct vnode *devvp, struct mount *mp, struct lwp *l)
    887    1.1   mycroft {
    888  1.348  dholland 	struct lfs *primarysb, *altsb, *thesb;
    889  1.348  dholland 	struct buf *primarybuf, *altbuf;
    890   1.48  augustss 	struct lfs *fs;
    891  1.301  dholland 	struct ulfsmount *ump;
    892    1.1   mycroft 	struct vnode *vp;
    893    1.1   mycroft 	dev_t dev;
    894  1.283   mlelstv 	int error, i, ronly, fsbsize;
    895  1.210      elad 	kauth_cred_t cred;
    896   1.59  perseant 	CLEANERINFO *cip;
    897   1.96  perseant 	SEGUSE *sup;
    898  1.217  perseant 	daddr_t sb_addr;
    899  1.373  riastrad 	ino_t *orphan;
    900  1.373  riastrad 	size_t norphan;
    901    1.1   mycroft 
    902  1.218        ad 	cred = l ? l->l_cred : NOCRED;
    903  1.161   mycroft 
    904  1.344  dholland 	/* The superblock is supposed to be 512 bytes. */
    905  1.344  dholland 	__CTASSERT(sizeof(struct dlfs) == DEV_BSIZE);
    906  1.344  dholland 
    907    1.1   mycroft 	/*
    908    1.1   mycroft 	 * Flush out any old buffers remaining from a previous use.
    909    1.1   mycroft 	 */
    910  1.161   mycroft 	vn_lock(devvp, LK_EXCLUSIVE | LK_RETRY);
    911  1.190  christos 	error = vinvalbuf(devvp, V_SAVE, cred, l, 0, 0);
    912  1.287   hannken 	VOP_UNLOCK(devvp);
    913  1.161   mycroft 	if (error)
    914    1.1   mycroft 		return (error);
    915    1.1   mycroft 
    916    1.1   mycroft 	ronly = (mp->mnt_flag & MNT_RDONLY) != 0;
    917    1.1   mycroft 
    918    1.1   mycroft 	/* Don't free random space on error. */
    919  1.348  dholland 	primarybuf = NULL;
    920  1.348  dholland 	altbuf = NULL;
    921    1.1   mycroft 	ump = NULL;
    922    1.1   mycroft 
    923  1.283   mlelstv 	sb_addr = LFS_LABELPAD / DEV_BSIZE;
    924   1.70       chs 	while (1) {
    925  1.348  dholland 		/*
    926  1.348  dholland 		 * Read in the superblock.
    927  1.348  dholland 		 *
    928  1.348  dholland 		 * Note that because LFS_SBPAD is substantially larger
    929  1.348  dholland 		 * (8K) than the actual on-disk superblock (512 bytes)
    930  1.348  dholland 		 * the buffer contains enough space to be used as a
    931  1.348  dholland 		 * whole struct lfs (in-memory superblock) - we do this
    932  1.348  dholland 		 * only so we can set and use the is64 and dobyteswap
    933  1.348  dholland 		 * members. XXX this is gross and the logic here should
    934  1.348  dholland 		 * be reworked.
    935  1.348  dholland 		 */
    936  1.348  dholland 		error = bread(devvp, sb_addr, LFS_SBPAD, 0, &primarybuf);
    937   1.66  perseant 		if (error)
    938   1.66  perseant 			goto out;
    939  1.348  dholland 		primarysb = (struct lfs *)primarybuf->b_data;
    940    1.1   mycroft 
    941   1.66  perseant 		/* Check the basics. */
    942  1.348  dholland 		error = lfs_checkmagic(primarysb);
    943  1.348  dholland 		if (error) {
    944  1.348  dholland 			DLOG((DLOG_MOUNT, "lfs_mountfs: primary superblock wrong magic\n"));
    945  1.348  dholland 			goto out;
    946  1.348  dholland 		}
    947  1.348  dholland 		if (lfs_sb_getbsize(primarysb) > MAXBSIZE ||
    948  1.348  dholland 		    lfs_sb_getversion(primarysb) > LFS_VERSION ||
    949  1.348  dholland 		    lfs_sb_getbsize(primarysb) < sizeof(struct dlfs)) {
    950  1.166  perseant 			DLOG((DLOG_MOUNT, "lfs_mountfs: primary superblock sanity failed\n"));
    951  1.348  dholland 			/* XXX needs translation */
    952  1.348  dholland 			error = EINVAL;
    953   1.66  perseant 			goto out;
    954   1.66  perseant 		}
    955  1.348  dholland 		if (lfs_sb_getinodefmt(primarysb) > LFS_MAXINODEFMT) {
    956  1.166  perseant 			DLOG((DLOG_MOUNT, "lfs_mountfs: unknown inode format %d\n",
    957  1.348  dholland 			       lfs_sb_getinodefmt(primarysb)));
    958  1.166  perseant 			error = EINVAL;
    959  1.166  perseant 			goto out;
    960  1.166  perseant 		}
    961  1.164     perry 
    962  1.348  dholland 		if (lfs_sb_getversion(primarysb) == 1)
    963  1.283   mlelstv 			fsbsize = DEV_BSIZE;
    964   1.66  perseant 		else {
    965  1.348  dholland 			fsbsize = 1 << lfs_sb_getffshift(primarysb);
    966   1.66  perseant 			/*
    967   1.66  perseant 			 * Could be, if the frag size is large enough, that we
    968   1.66  perseant 			 * don't have the "real" primary superblock.  If that's
    969   1.66  perseant 			 * the case, get the real one, and try again.
    970   1.66  perseant 			 */
    971  1.348  dholland 			if (sb_addr != (lfs_sb_getsboff(primarysb, 0) << (lfs_sb_getffshift(primarysb) - DEV_BSHIFT))) {
    972  1.166  perseant 				DLOG((DLOG_MOUNT, "lfs_mountfs: sb daddr"
    973  1.166  perseant 				      " 0x%llx is not right, trying 0x%llx\n",
    974  1.166  perseant 				      (long long)sb_addr,
    975  1.348  dholland 				      (long long)(lfs_sb_getsboff(primarysb, 0) << (lfs_sb_getffshift(primarysb) - DEV_BSHIFT))));
    976  1.348  dholland 				sb_addr = lfs_sb_getsboff(primarysb, 0) << (lfs_sb_getffshift(primarysb) - DEV_BSHIFT);
    977  1.348  dholland 				brelse(primarybuf, BC_INVAL);
    978   1.66  perseant 				continue;
    979   1.66  perseant 			}
    980   1.66  perseant 		}
    981   1.66  perseant 		break;
    982   1.50  perseant 	}
    983   1.50  perseant 
    984   1.26  perseant 	/*
    985   1.26  perseant 	 * Check the second superblock to see which is newer; then mount
    986   1.96  perseant 	 * using the older of the two.	This is necessary to ensure that
    987   1.26  perseant 	 * the filesystem is valid if it was not unmounted cleanly.
    988   1.26  perseant 	 */
    989   1.60  perseant 
    990  1.348  dholland 	if (lfs_sb_getsboff(primarysb, 1) &&
    991  1.348  dholland 	    lfs_sb_getsboff(primarysb, 1) - LFS_LABELPAD / fsbsize > LFS_SBPAD / fsbsize)
    992   1.50  perseant 	{
    993  1.348  dholland 		error = bread(devvp, lfs_sb_getsboff(primarysb, 1) * (fsbsize / DEV_BSIZE),
    994  1.348  dholland 			LFS_SBPAD, 0, &altbuf);
    995   1.50  perseant 		if (error)
    996   1.50  perseant 			goto out;
    997  1.348  dholland 		altsb = (struct lfs *)altbuf->b_data;
    998   1.50  perseant 
    999  1.348  dholland 		/*
   1000  1.348  dholland 		 * Note: this used to do the sanity check only if the
   1001  1.348  dholland 		 * timestamp/serial comparison required use of altsb;
   1002  1.348  dholland 		 * this way is less tolerant, but if altsb is corrupted
   1003  1.348  dholland 		 * enough that the magic number, version, and blocksize
   1004  1.348  dholland 		 * are bogus, why would the timestamp or serial fields
   1005  1.348  dholland 		 * mean anything either? If this kind of thing happens,
   1006  1.348  dholland 		 * you need to fsck anyway.
   1007  1.348  dholland 		 */
   1008  1.348  dholland 
   1009  1.348  dholland 		error = lfs_checkmagic(altsb);
   1010  1.348  dholland 		if (error)
   1011  1.348  dholland 			goto out;
   1012   1.60  perseant 
   1013   1.60  perseant 		/* Check the basics. */
   1014  1.348  dholland 		if (lfs_sb_getbsize(altsb) > MAXBSIZE ||
   1015  1.348  dholland 		    lfs_sb_getversion(altsb) > LFS_VERSION ||
   1016  1.348  dholland 		    lfs_sb_getbsize(altsb) < sizeof(struct dlfs)) {
   1017  1.166  perseant 			DLOG((DLOG_MOUNT, "lfs_mountfs: alt superblock"
   1018  1.166  perseant 			      " sanity failed\n"));
   1019   1.60  perseant 			error = EINVAL;		/* XXX needs translation */
   1020   1.60  perseant 			goto out;
   1021   1.60  perseant 		}
   1022  1.348  dholland 
   1023  1.348  dholland 		if (lfs_sb_getversion(primarysb) == 1) {
   1024  1.348  dholland 			/* 1s resolution comparison */
   1025  1.348  dholland 			if (lfs_sb_gettstamp(altsb) < lfs_sb_gettstamp(primarysb))
   1026  1.348  dholland 				thesb = altsb;
   1027  1.348  dholland 			else
   1028  1.348  dholland 				thesb = primarysb;
   1029  1.348  dholland 		} else {
   1030  1.348  dholland 			/* monotonic infinite-resolution comparison */
   1031  1.348  dholland 			if (lfs_sb_getserial(altsb) < lfs_sb_getserial(primarysb))
   1032  1.348  dholland 				thesb = altsb;
   1033  1.348  dholland 			else
   1034  1.348  dholland 				thesb = primarysb;
   1035  1.348  dholland 		}
   1036   1.50  perseant 	} else {
   1037  1.348  dholland 		DLOG((DLOG_MOUNT, "lfs_mountfs: invalid alt superblock location"
   1038  1.348  dholland 		      " daddr=0x%x\n", lfs_sb_getsboff(primarysb, 1)));
   1039   1.50  perseant 		error = EINVAL;
   1040    1.1   mycroft 		goto out;
   1041    1.1   mycroft 	}
   1042    1.1   mycroft 
   1043  1.348  dholland 	/*
   1044  1.348  dholland 	 * Allocate the mount structure, copy the superblock into it.
   1045  1.348  dholland 	 * Note that the 32-bit and 64-bit superblocks are the same size.
   1046  1.348  dholland 	 */
   1047  1.296     rmind 	fs = kmem_zalloc(sizeof(struct lfs), KM_SLEEP);
   1048  1.348  dholland 	memcpy(&fs->lfs_dlfs_u.u_32, &thesb->lfs_dlfs_u.u_32,
   1049  1.348  dholland 	       sizeof(struct dlfs));
   1050  1.348  dholland 	fs->lfs_is64 = thesb->lfs_is64;
   1051  1.348  dholland 	fs->lfs_dobyteswap = thesb->lfs_dobyteswap;
   1052  1.345  dholland 	fs->lfs_hasolddirfmt = false; /* set for real below */
   1053   1.60  perseant 
   1054   1.66  perseant 	/* Compatibility */
   1055  1.332  dholland 	if (lfs_sb_getversion(fs) < 2) {
   1056  1.328  dholland 		lfs_sb_setsumsize(fs, LFS_V1_SUMMARY_SIZE);
   1057  1.327  dholland 		lfs_sb_setibsize(fs, lfs_sb_getbsize(fs));
   1058  1.328  dholland 		lfs_sb_sets0addr(fs, lfs_sb_getsboff(fs, 0));
   1059  1.327  dholland 		lfs_sb_settstamp(fs, lfs_sb_getotstamp(fs));
   1060  1.327  dholland 		lfs_sb_setfsbtodb(fs, 0);
   1061   1.66  perseant 	}
   1062  1.328  dholland 	if (lfs_sb_getresvseg(fs) == 0)
   1063  1.328  dholland 		lfs_sb_setresvseg(fs, MIN(lfs_sb_getminfreeseg(fs) - 1, \
   1064  1.328  dholland 			MAX(MIN_RESV_SEGS, lfs_sb_getminfreeseg(fs) / 2 + 1)));
   1065   1.66  perseant 
   1066  1.163  perseant 	/*
   1067  1.163  perseant 	 * If we aren't going to be able to write meaningfully to this
   1068  1.163  perseant 	 * filesystem, and were not mounted readonly, bomb out now.
   1069  1.163  perseant 	 */
   1070  1.307  christos 	if (lfs_fsbtob(fs, LFS_NRESERVE(fs)) > LFS_MAX_BYTES && !ronly) {
   1071  1.166  perseant 		DLOG((DLOG_MOUNT, "lfs_mount: to mount this filesystem read/write,"
   1072  1.166  perseant 		      " we need BUFPAGES >= %lld\n",
   1073  1.166  perseant 		      (long long)((bufmem_hiwater / bufmem_lowater) *
   1074  1.166  perseant 				  LFS_INVERSE_MAX_BYTES(
   1075  1.307  christos 					  lfs_fsbtob(fs, LFS_NRESERVE(fs))) >> PAGE_SHIFT)));
   1076  1.296     rmind 		kmem_free(fs, sizeof(struct lfs));
   1077  1.163  perseant 		error = EFBIG; /* XXX needs translation */
   1078  1.163  perseant 		goto out;
   1079  1.163  perseant 	}
   1080  1.164     perry 
   1081   1.60  perseant 	/* Before rolling forward, lock so vget will sleep for other procs */
   1082  1.218        ad 	if (l != NULL) {
   1083  1.205  perseant 		fs->lfs_flags = LFS_NOTYET;
   1084  1.218        ad 		fs->lfs_rfpid = l->l_proc->p_pid;
   1085  1.205  perseant 	}
   1086   1.60  perseant 
   1087  1.296     rmind 	ump = kmem_zalloc(sizeof(*ump), KM_SLEEP);
   1088   1.29   mycroft 	ump->um_lfs = fs;
   1089  1.349  dholland 	ump->um_fstype = fs->lfs_is64 ? ULFS2 : ULFS1;
   1090  1.324   hannken 	/* ump->um_cleaner_thread = NULL; */
   1091  1.348  dholland 	brelse(primarybuf, BC_INVAL);
   1092  1.348  dholland 	brelse(altbuf, BC_INVAL);
   1093  1.348  dholland 	primarybuf = NULL;
   1094  1.348  dholland 	altbuf = NULL;
   1095    1.1   mycroft 
   1096  1.245        ad 
   1097    1.1   mycroft 	/* Set up the I/O information */
   1098  1.283   mlelstv 	fs->lfs_devbsize = DEV_BSIZE;
   1099    1.1   mycroft 	fs->lfs_iocount = 0;
   1100   1.34  perseant 	fs->lfs_diropwait = 0;
   1101   1.26  perseant 	fs->lfs_activesb = 0;
   1102  1.327  dholland 	lfs_sb_setuinodes(fs, 0);
   1103   1.58  perseant 	fs->lfs_ravail = 0;
   1104  1.163  perseant 	fs->lfs_favail = 0;
   1105   1.51   thorpej 	fs->lfs_sbactive = 0;
   1106    1.1   mycroft 
   1107    1.1   mycroft 	/* Set up the ifile and lock aflags */
   1108    1.1   mycroft 	fs->lfs_doifile = 0;
   1109    1.1   mycroft 	fs->lfs_writer = 0;
   1110    1.1   mycroft 	fs->lfs_dirops = 0;
   1111   1.52  perseant 	fs->lfs_nadirop = 0;
   1112    1.1   mycroft 	fs->lfs_seglock = 0;
   1113   1.91  perseant 	fs->lfs_pdflush = 0;
   1114  1.112  perseant 	fs->lfs_sleepers = 0;
   1115  1.163  perseant 	fs->lfs_pages = 0;
   1116  1.227        ad 	rw_init(&fs->lfs_fraglock);
   1117  1.252        ad 	rw_init(&fs->lfs_iflock);
   1118  1.354      maya 	cv_init(&fs->lfs_sleeperscv, "lfs_slp");
   1119  1.355      maya 	cv_init(&fs->lfs_diropscv, "lfs_dirop");
   1120  1.252        ad 	cv_init(&fs->lfs_stopcv, "lfsstop");
   1121  1.360      maya 	cv_init(&fs->lfs_nextsegsleep, "segment");
   1122  1.360      maya 
   1123    1.1   mycroft 	/* Set the file system readonly/modify bits. */
   1124    1.1   mycroft 	fs->lfs_ronly = ronly;
   1125    1.1   mycroft 	if (ronly == 0)
   1126    1.1   mycroft 		fs->lfs_fmod = 1;
   1127    1.1   mycroft 
   1128  1.347  dholland 	/* Device we're using */
   1129  1.347  dholland 	dev = devvp->v_rdev;
   1130  1.347  dholland 	fs->lfs_dev = dev;
   1131  1.347  dholland 	fs->lfs_devvp = devvp;
   1132  1.347  dholland 
   1133  1.310  dholland 	/* ulfs-level information */
   1134  1.310  dholland 	fs->um_flags = 0;
   1135  1.328  dholland 	fs->um_bptrtodb = lfs_sb_getffshift(fs) - DEV_BSHIFT;
   1136  1.327  dholland 	fs->um_seqinc = lfs_sb_getfrag(fs);
   1137  1.328  dholland 	fs->um_nindir = lfs_sb_getnindir(fs);
   1138  1.328  dholland 	fs->um_lognindir = ffs(lfs_sb_getnindir(fs)) - 1;
   1139  1.328  dholland 	fs->um_maxsymlinklen = lfs_sb_getmaxsymlinklen(fs);
   1140  1.310  dholland 	fs->um_dirblksiz = LFS_DIRBLKSIZ;
   1141  1.328  dholland 	fs->um_maxfilesize = lfs_sb_getmaxfilesize(fs);
   1142  1.310  dholland 
   1143  1.311  dholland 	/* quota stuff */
   1144  1.311  dholland 	/* XXX: these need to come from the on-disk superblock to be used */
   1145  1.311  dholland 	fs->lfs_use_quota2 = 0;
   1146  1.311  dholland 	fs->lfs_quota_magic = 0;
   1147  1.311  dholland 	fs->lfs_quota_flags = 0;
   1148  1.311  dholland 	fs->lfs_quotaino[0] = 0;
   1149  1.311  dholland 	fs->lfs_quotaino[1] = 0;
   1150  1.311  dholland 
   1151    1.1   mycroft 	/* Initialize the mount structure. */
   1152   1.79     soren 	mp->mnt_data = ump;
   1153  1.147  christos 	mp->mnt_stat.f_fsidx.__fsid_val[0] = (long)dev;
   1154  1.147  christos 	mp->mnt_stat.f_fsidx.__fsid_val[1] = makefstype(MOUNT_LFS);
   1155  1.147  christos 	mp->mnt_stat.f_fsid = mp->mnt_stat.f_fsidx.__fsid_val[0];
   1156  1.186  christos 	mp->mnt_stat.f_namemax = LFS_MAXNAMLEN;
   1157  1.327  dholland 	mp->mnt_stat.f_iosize = lfs_sb_getbsize(fs);
   1158    1.1   mycroft 	mp->mnt_flag |= MNT_LOCAL;
   1159  1.378        ad 	mp->mnt_iflag |= IMNT_SHRLOOKUP;
   1160  1.328  dholland 	mp->mnt_fs_bshift = lfs_sb_getbshift(fs);
   1161  1.371  riastrad 	mp->mnt_iflag |= IMNT_CAN_RWTORO;
   1162  1.310  dholland 	if (fs->um_maxsymlinklen > 0)
   1163  1.310  dholland 		mp->mnt_iflag |= IMNT_DTYPE;
   1164  1.345  dholland 	else
   1165  1.345  dholland 		fs->lfs_hasolddirfmt = true;
   1166  1.310  dholland 
   1167    1.1   mycroft 	ump->um_mountp = mp;
   1168  1.301  dholland 	for (i = 0; i < ULFS_MAXQUOTAS; i++)
   1169    1.1   mycroft 		ump->um_quotas[i] = NULLVP;
   1170  1.314   hannken 	spec_node_setmountedfs(devvp, mp);
   1171    1.1   mycroft 
   1172   1.91  perseant 	/* Set up reserved memory for pageout */
   1173   1.91  perseant 	lfs_setup_resblks(fs);
   1174   1.91  perseant 	/* Set up vdirop tailq */
   1175   1.91  perseant 	TAILQ_INIT(&fs->lfs_dchainhd);
   1176   1.91  perseant 	/* and paging tailq */
   1177   1.91  perseant 	TAILQ_INIT(&fs->lfs_pchainhd);
   1178  1.206  perseant 	/* and delayed segment accounting for truncation list */
   1179  1.206  perseant 	LIST_INIT(&fs->lfs_segdhd);
   1180   1.91  perseant 
   1181    1.1   mycroft 	/*
   1182    1.1   mycroft 	 * We use the ifile vnode for almost every operation.  Instead of
   1183    1.1   mycroft 	 * retrieving it from the hash table each time we retrieve it here,
   1184    1.1   mycroft 	 * artificially increment the reference count and keep a pointer
   1185    1.1   mycroft 	 * to it in the incore copy of the superblock.
   1186    1.1   mycroft 	 */
   1187  1.369        ad 	if ((error = VFS_VGET(mp, LFS_IFILE_INUM, LK_EXCLUSIVE, &vp)) != 0) {
   1188  1.166  perseant 		DLOG((DLOG_MOUNT, "lfs_mountfs: ifile vget failed, error=%d\n", error));
   1189    1.1   mycroft 		goto out;
   1190   1.66  perseant 	}
   1191    1.1   mycroft 	fs->lfs_ivnode = vp;
   1192  1.282     pooka 	vref(vp);
   1193   1.30  perseant 
   1194  1.373  riastrad 	/* Set up inode bitmap, order free list, and gather orphans.  */
   1195  1.373  riastrad 	lfs_order_freelist(fs, &orphan, &norphan);
   1196  1.199  perseant 
   1197   1.91  perseant 	/* Set up segment usage flags for the autocleaner. */
   1198  1.102  perseant 	fs->lfs_nactive = 0;
   1199  1.326  dholland 	fs->lfs_suflags = malloc(2 * sizeof(u_int32_t *),
   1200  1.326  dholland 				 M_SEGMENT, M_WAITOK);
   1201  1.328  dholland 	fs->lfs_suflags[0] = malloc(lfs_sb_getnseg(fs) * sizeof(u_int32_t),
   1202  1.326  dholland 				    M_SEGMENT, M_WAITOK);
   1203  1.328  dholland 	fs->lfs_suflags[1] = malloc(lfs_sb_getnseg(fs) * sizeof(u_int32_t),
   1204  1.326  dholland 				    M_SEGMENT, M_WAITOK);
   1205  1.328  dholland 	memset(fs->lfs_suflags[1], 0, lfs_sb_getnseg(fs) * sizeof(u_int32_t));
   1206  1.328  dholland 	for (i = 0; i < lfs_sb_getnseg(fs); i++) {
   1207  1.102  perseant 		int changed;
   1208  1.348  dholland 		struct buf *bp;
   1209  1.102  perseant 
   1210   1.91  perseant 		LFS_SEGENTRY(sup, fs, i, bp);
   1211  1.102  perseant 		changed = 0;
   1212  1.102  perseant 		if (!ronly) {
   1213  1.102  perseant 			if (sup->su_nbytes == 0 &&
   1214  1.102  perseant 			    !(sup->su_flags & SEGUSE_EMPTY)) {
   1215  1.102  perseant 				sup->su_flags |= SEGUSE_EMPTY;
   1216  1.102  perseant 				++changed;
   1217  1.102  perseant 			} else if (!(sup->su_nbytes == 0) &&
   1218  1.102  perseant 				   (sup->su_flags & SEGUSE_EMPTY)) {
   1219  1.102  perseant 				sup->su_flags &= ~SEGUSE_EMPTY;
   1220  1.102  perseant 				++changed;
   1221  1.102  perseant 			}
   1222  1.177  perseant 			if (sup->su_flags & (SEGUSE_ACTIVE|SEGUSE_INVAL)) {
   1223  1.177  perseant 				sup->su_flags &= ~(SEGUSE_ACTIVE|SEGUSE_INVAL);
   1224  1.102  perseant 				++changed;
   1225  1.102  perseant 			}
   1226  1.102  perseant 		}
   1227  1.102  perseant 		fs->lfs_suflags[0][i] = sup->su_flags;
   1228  1.102  perseant 		if (changed)
   1229   1.91  perseant 			LFS_WRITESEGENTRY(sup, fs, i, bp);
   1230  1.102  perseant 		else
   1231  1.245        ad 			brelse(bp, 0);
   1232   1.91  perseant 	}
   1233   1.91  perseant 
   1234  1.373  riastrad 	/* Free the orphans we discovered while ordering the freelist.  */
   1235  1.373  riastrad 	lfs_free_orphans(fs, orphan, norphan);
   1236  1.373  riastrad 
   1237  1.387  perseant 	if (!ronly) {
   1238  1.387  perseant 		/* Roll forward */
   1239  1.387  perseant 		lfs_roll_forward(fs, mp, l);
   1240  1.387  perseant 		lfs_reset_avail(fs);
   1241  1.387  perseant 	}
   1242  1.387  perseant 	fs->lfs_rfpid = 0;
   1243  1.387  perseant 
   1244  1.312  dholland 	/*
   1245  1.312  dholland 	 * XXX: if the fs has quotas, quotas should be on even if
   1246  1.312  dholland 	 * readonly. Otherwise you can't query the quota info!
   1247  1.312  dholland 	 * However, that's not how the quota2 code got written and I
   1248  1.312  dholland 	 * don't know if it'll behave itself if enabled while
   1249  1.312  dholland 	 * readonly, so for now use the same enable logic as ffs.
   1250  1.312  dholland 	 *
   1251  1.312  dholland 	 * XXX: also, if you use the -f behavior allowed here (and
   1252  1.312  dholland 	 * equivalently above for remount) it will corrupt the fs. It
   1253  1.312  dholland 	 * ought not to allow that. It should allow mounting readonly
   1254  1.312  dholland 	 * if there are quotas and the kernel doesn't have the quota
   1255  1.312  dholland 	 * code, but only readonly.
   1256  1.312  dholland 	 *
   1257  1.312  dholland 	 * XXX: and if you use the -f behavior allowed here it will
   1258  1.312  dholland 	 * likely crash at unmount time (or remount time) because we
   1259  1.312  dholland 	 * think quotas are active.
   1260  1.312  dholland 	 *
   1261  1.312  dholland 	 * Although none of this applies until there's a way to set
   1262  1.312  dholland 	 * lfs_use_quota2 and have quotas in the fs at all.
   1263  1.312  dholland 	 */
   1264  1.312  dholland 	if (!ronly && fs->lfs_use_quota2) {
   1265  1.312  dholland #ifdef LFS_QUOTA2
   1266  1.312  dholland 		error = lfs_quota2_mount(mp);
   1267  1.312  dholland #else
   1268  1.312  dholland 		uprintf("%s: no kernel support for this filesystem's quotas\n",
   1269  1.312  dholland 			mp->mnt_stat.f_mntonname);
   1270  1.312  dholland 		if (mp->mnt_flag & MNT_FORCE) {
   1271  1.312  dholland 			uprintf("%s: mounting anyway; fsck afterwards\n",
   1272  1.312  dholland 				mp->mnt_stat.f_mntonname);
   1273  1.312  dholland 		} else {
   1274  1.312  dholland 			error = EINVAL;
   1275  1.312  dholland 		}
   1276  1.312  dholland #endif
   1277  1.312  dholland 		if (error) {
   1278  1.312  dholland 			/* XXX XXX must clean up the stuff immediately above */
   1279  1.312  dholland 			printf("lfs_mountfs: sorry, leaking some memory\n");
   1280  1.312  dholland 			goto out;
   1281  1.312  dholland 		}
   1282  1.312  dholland 	}
   1283  1.312  dholland 
   1284   1.66  perseant 	/* If writing, sb is not clean; record in case of immediate crash */
   1285   1.66  perseant 	if (!fs->lfs_ronly) {
   1286  1.328  dholland 		lfs_sb_setpflags(fs, lfs_sb_getpflags(fs) & ~LFS_PF_CLEAN);
   1287  1.328  dholland 		lfs_writesuper(fs, lfs_sb_getsboff(fs, 0));
   1288  1.328  dholland 		lfs_writesuper(fs, lfs_sb_getsboff(fs, 1));
   1289   1.66  perseant 	}
   1290  1.164     perry 
   1291   1.60  perseant 	/* Allow vget now that roll-forward is complete */
   1292   1.60  perseant 	fs->lfs_flags &= ~(LFS_NOTYET);
   1293   1.60  perseant 	wakeup(&fs->lfs_flags);
   1294   1.60  perseant 
   1295   1.30  perseant 	/*
   1296  1.164     perry 	 * Initialize the ifile cleaner info with information from
   1297   1.59  perseant 	 * the superblock.
   1298  1.164     perry 	 */
   1299  1.348  dholland 	{
   1300  1.348  dholland 		struct buf *bp;
   1301  1.348  dholland 
   1302  1.348  dholland 		LFS_CLEANERINFO(cip, fs, bp);
   1303  1.348  dholland 		lfs_ci_setclean(fs, cip, lfs_sb_getnclean(fs));
   1304  1.348  dholland 		lfs_ci_setdirty(fs, cip, lfs_sb_getnseg(fs) - lfs_sb_getnclean(fs));
   1305  1.348  dholland 		lfs_ci_setavail(fs, cip, lfs_sb_getavail(fs));
   1306  1.348  dholland 		lfs_ci_setbfree(fs, cip, lfs_sb_getbfree(fs));
   1307  1.348  dholland 		(void) LFS_BWRITE_LOG(bp); /* Ifile */
   1308  1.348  dholland 	}
   1309   1.59  perseant 
   1310   1.59  perseant 	/*
   1311  1.164     perry 	 * Mark the current segment as ACTIVE, since we're going to
   1312   1.30  perseant 	 * be writing to it.
   1313   1.30  perseant 	 */
   1314  1.348  dholland 	{
   1315  1.348  dholland 		struct buf *bp;
   1316  1.348  dholland 
   1317  1.348  dholland 		LFS_SEGENTRY(sup, fs, lfs_dtosn(fs, lfs_sb_getoffset(fs)), bp);
   1318  1.348  dholland 		sup->su_flags |= SEGUSE_DIRTY | SEGUSE_ACTIVE;
   1319  1.348  dholland 		fs->lfs_nactive++;
   1320  1.348  dholland 		LFS_WRITESEGENTRY(sup, fs, lfs_dtosn(fs, lfs_sb_getoffset(fs)), bp);  /* Ifile */
   1321  1.348  dholland 	}
   1322   1.74  perseant 
   1323   1.74  perseant 	/* Now that roll-forward is done, unlock the Ifile */
   1324   1.74  perseant 	vput(vp);
   1325   1.74  perseant 
   1326  1.163  perseant 	/* Start the pagedaemon-anticipating daemon */
   1327  1.292  perseant 	mutex_enter(&lfs_lock);
   1328  1.356      maya 	if (lfs_writer_daemon == NULL &&
   1329  1.292  perseant 	    kthread_create(PRI_BIO, 0, NULL,
   1330  1.245        ad 	    lfs_writerd, NULL, NULL, "lfs_writer") != 0)
   1331  1.163  perseant 		panic("fork lfs_writer");
   1332  1.292  perseant 	mutex_exit(&lfs_lock);
   1333  1.163  perseant 
   1334  1.272        ad 	printf("WARNING: the log-structured file system is experimental\n"
   1335  1.272        ad 	    "WARNING: it may cause system crashes and/or corrupt data\n");
   1336  1.264        ad 
   1337    1.1   mycroft 	return (0);
   1338  1.161   mycroft 
   1339    1.1   mycroft out:
   1340  1.348  dholland 	if (primarybuf)
   1341  1.348  dholland 		brelse(primarybuf, BC_INVAL);
   1342  1.348  dholland 	if (altbuf)
   1343  1.348  dholland 		brelse(altbuf, BC_INVAL);
   1344    1.1   mycroft 	if (ump) {
   1345  1.296     rmind 		kmem_free(ump->um_lfs, sizeof(struct lfs));
   1346  1.296     rmind 		kmem_free(ump, sizeof(*ump));
   1347   1.79     soren 		mp->mnt_data = NULL;
   1348    1.1   mycroft 	}
   1349   1.91  perseant 
   1350    1.1   mycroft 	return (error);
   1351    1.1   mycroft }
   1352    1.1   mycroft 
   1353  1.387  perseant void
   1354  1.387  perseant lfs_reset_avail(struct lfs *fs)
   1355  1.387  perseant {
   1356  1.387  perseant 	daddr_t avail;
   1357  1.387  perseant 	int sn, nclean, nsb, labelcorrect, curr, mfs;
   1358  1.387  perseant 	SEGUSE *sup;
   1359  1.387  perseant 	struct buf *bp;
   1360  1.387  perseant 
   1361  1.387  perseant 	KASSERT(!fs->lfs_ronly);
   1362  1.387  perseant 
   1363  1.387  perseant 	avail = nclean = nsb = labelcorrect = 0;
   1364  1.387  perseant 	for (sn = 0; sn < lfs_sb_getnseg(fs); ++sn) {
   1365  1.387  perseant 		LFS_SEGENTRY(sup, fs, sn, bp);
   1366  1.387  perseant 
   1367  1.387  perseant 		/* Count all clean segments and the remainder of this one */
   1368  1.387  perseant 		if (!(sup->su_flags & SEGUSE_DIRTY)) {
   1369  1.387  perseant 			++nclean;
   1370  1.387  perseant 			avail += lfs_segtod(fs, 1);
   1371  1.387  perseant 
   1372  1.387  perseant 			/* Correct for label and superblock, if present */
   1373  1.387  perseant 			if (sup->su_flags & SEGUSE_SUPERBLOCK)
   1374  1.387  perseant 				++nsb;
   1375  1.387  perseant 			if (sn == 0 && lfs_sb_getversion(fs) > 1
   1376  1.387  perseant 			    && lfs_sb_gets0addr(fs) < lfs_btofsb(fs, LFS_LABELPAD))
   1377  1.387  perseant 				labelcorrect = lfs_btofsb(fs, LFS_LABELPAD)
   1378  1.387  perseant 					- lfs_sb_gets0addr(fs);
   1379  1.387  perseant 		}
   1380  1.387  perseant 
   1381  1.387  perseant 		brelse(bp, 0);
   1382  1.387  perseant 	}
   1383  1.387  perseant 
   1384  1.387  perseant 	/* Also may be available bytes in current seg */
   1385  1.387  perseant 	sn = lfs_dtosn(fs, lfs_sb_getoffset(fs));
   1386  1.387  perseant 	curr = lfs_sntod(fs, sn + 1) - lfs_sb_getoffset(fs);
   1387  1.387  perseant 	/* But do not count minfreesegs */
   1388  1.387  perseant 	mfs = lfs_segtod(fs, (lfs_sb_getminfreeseg(fs) -
   1389  1.387  perseant 		(lfs_sb_getminfreeseg(fs) / 2)));
   1390  1.387  perseant 
   1391  1.387  perseant 	avail = nclean * lfs_segtod(fs, 1);
   1392  1.387  perseant 	avail -= nsb * lfs_btofsb(fs, LFS_SBPAD);
   1393  1.387  perseant 	avail -= labelcorrect;
   1394  1.387  perseant 	avail += curr;
   1395  1.387  perseant 	avail -= mfs;
   1396  1.387  perseant 
   1397  1.387  perseant 	DLOG((DLOG_AVAIL, "avail := %jd*%jd-%jd*%jd-%jd+%jd-%jd=%jd\n",
   1398  1.387  perseant 	       (intmax_t)nclean,
   1399  1.387  perseant 	       (intmax_t)lfs_segtod(fs, 1),
   1400  1.387  perseant 	       (intmax_t)nsb,
   1401  1.387  perseant 	       (intmax_t)lfs_btofsb(fs, LFS_SBPAD),
   1402  1.387  perseant 	       (intmax_t)labelcorrect,
   1403  1.387  perseant 	       (intmax_t)curr,
   1404  1.387  perseant 	       (intmax_t)mfs,
   1405  1.387  perseant 	       (intmax_t)avail));
   1406  1.387  perseant 
   1407  1.387  perseant 	lfs_sb_setavail(fs, avail);
   1408  1.387  perseant 	lfs_sb_setnclean(fs, nclean);
   1409  1.387  perseant }
   1410  1.387  perseant 
   1411    1.1   mycroft /*
   1412    1.1   mycroft  * unmount system call
   1413    1.1   mycroft  */
   1414   1.10  christos int
   1415  1.249     pooka lfs_unmount(struct mount *mp, int mntflags)
   1416    1.1   mycroft {
   1417  1.371  riastrad 	struct ulfsmount *ump;
   1418  1.371  riastrad 	struct lfs *fs;
   1419  1.371  riastrad 	int error, ronly;
   1420  1.371  riastrad 
   1421  1.371  riastrad 	ump = VFSTOULFS(mp);
   1422  1.371  riastrad 	fs = ump->um_lfs;
   1423  1.371  riastrad 
   1424  1.371  riastrad 	error = lfs_flushfiles(mp, mntflags & MNT_FORCE ? FORCECLOSE : 0);
   1425  1.371  riastrad 	if (error)
   1426  1.371  riastrad 		return error;
   1427  1.371  riastrad 
   1428  1.385  perseant 	DEBUG_CHECK_FREELIST(fs);
   1429  1.385  perseant 
   1430  1.371  riastrad 	/* Finish with the Ifile, now that we're done with it */
   1431  1.371  riastrad 	vgone(fs->lfs_ivnode);
   1432  1.371  riastrad 
   1433  1.371  riastrad 	ronly = !fs->lfs_ronly;
   1434  1.371  riastrad 	if (fs->lfs_devvp->v_type != VBAD)
   1435  1.371  riastrad 		spec_node_setmountedfs(fs->lfs_devvp, NULL);
   1436  1.371  riastrad 	vn_lock(fs->lfs_devvp, LK_EXCLUSIVE | LK_RETRY);
   1437  1.371  riastrad 	error = VOP_CLOSE(fs->lfs_devvp,
   1438  1.371  riastrad 	    ronly ? FREAD : FREAD|FWRITE, NOCRED);
   1439  1.371  riastrad 	vput(fs->lfs_devvp);
   1440  1.371  riastrad 
   1441  1.371  riastrad 	/* Complain about page leakage */
   1442  1.371  riastrad 	if (fs->lfs_pages > 0)
   1443  1.371  riastrad 		printf("lfs_unmount: still claim %d pages (%d in subsystem)\n",
   1444  1.371  riastrad 			fs->lfs_pages, lfs_subsys_pages);
   1445  1.371  riastrad 
   1446  1.371  riastrad 	/* Free per-mount data structures */
   1447  1.371  riastrad 	free(fs->lfs_ino_bitmap, M_SEGMENT);
   1448  1.371  riastrad 	free(fs->lfs_suflags[0], M_SEGMENT);
   1449  1.371  riastrad 	free(fs->lfs_suflags[1], M_SEGMENT);
   1450  1.371  riastrad 	free(fs->lfs_suflags, M_SEGMENT);
   1451  1.371  riastrad 	lfs_free_resblks(fs);
   1452  1.371  riastrad 	cv_destroy(&fs->lfs_sleeperscv);
   1453  1.371  riastrad 	cv_destroy(&fs->lfs_diropscv);
   1454  1.371  riastrad 	cv_destroy(&fs->lfs_stopcv);
   1455  1.371  riastrad 	cv_destroy(&fs->lfs_nextsegsleep);
   1456  1.371  riastrad 
   1457  1.371  riastrad 	rw_destroy(&fs->lfs_fraglock);
   1458  1.371  riastrad 	rw_destroy(&fs->lfs_iflock);
   1459  1.371  riastrad 
   1460  1.371  riastrad 	kmem_free(fs, sizeof(struct lfs));
   1461  1.371  riastrad 	kmem_free(ump, sizeof(*ump));
   1462  1.371  riastrad 
   1463  1.371  riastrad 	mp->mnt_data = NULL;
   1464  1.371  riastrad 	mp->mnt_flag &= ~MNT_LOCAL;
   1465  1.371  riastrad 	return (error);
   1466  1.371  riastrad }
   1467  1.371  riastrad 
   1468  1.371  riastrad static int
   1469  1.371  riastrad lfs_flushfiles(struct mount *mp, int flags)
   1470  1.371  riastrad {
   1471  1.249     pooka 	struct lwp *l = curlwp;
   1472  1.301  dholland 	struct ulfsmount *ump;
   1473   1.48  augustss 	struct lfs *fs;
   1474  1.371  riastrad 	struct vnode *vp;
   1475  1.371  riastrad 	int error;
   1476    1.1   mycroft 
   1477  1.301  dholland 	ump = VFSTOULFS(mp);
   1478    1.1   mycroft 	fs = ump->um_lfs;
   1479  1.112  perseant 
   1480  1.196  perseant 	/* Two checkpoints */
   1481  1.371  riastrad 	if (!fs->lfs_ronly) {
   1482  1.371  riastrad 		lfs_segwrite(mp, SEGM_CKP | SEGM_SYNC);
   1483  1.371  riastrad 		lfs_segwrite(mp, SEGM_CKP | SEGM_SYNC);
   1484  1.371  riastrad 	}
   1485  1.195  perseant 
   1486  1.112  perseant 	/* wake up the cleaner so it can die */
   1487  1.312  dholland 	/* XXX: shouldn't this be *after* the error cases below? */
   1488  1.214  perseant 	lfs_wakeup_cleaner(fs);
   1489  1.252        ad 	mutex_enter(&lfs_lock);
   1490  1.112  perseant 	while (fs->lfs_sleepers)
   1491  1.354      maya 		cv_wait(&fs->lfs_sleeperscv, &lfs_lock);
   1492  1.252        ad 	mutex_exit(&lfs_lock);
   1493  1.112  perseant 
   1494  1.313  dholland #ifdef LFS_EXTATTR
   1495  1.313  dholland 	if (ump->um_fstype == ULFS1) {
   1496  1.313  dholland 		if (ump->um_extattr.uepm_flags & ULFS_EXTATTR_UEPM_STARTED) {
   1497  1.313  dholland 			ulfs_extattr_stop(mp, curlwp);
   1498  1.313  dholland 		}
   1499  1.313  dholland 		if (ump->um_extattr.uepm_flags & ULFS_EXTATTR_UEPM_INITIALIZED) {
   1500  1.313  dholland 			ulfs_extattr_uepm_destroy(&ump->um_extattr);
   1501  1.350  dholland 			mp->mnt_flag &= ~MNT_EXTATTR;
   1502  1.313  dholland 		}
   1503  1.313  dholland 	}
   1504  1.313  dholland #endif
   1505  1.300  dholland #ifdef LFS_QUOTA
   1506  1.302  dholland         if ((error = lfsquota1_umount(mp, flags)) != 0)
   1507  1.288    bouyer 		return (error);
   1508    1.1   mycroft #endif
   1509  1.312  dholland #ifdef LFS_QUOTA2
   1510  1.312  dholland         if ((error = lfsquota2_umount(mp, flags)) != 0)
   1511  1.312  dholland 		return (error);
   1512  1.312  dholland #endif
   1513   1.10  christos 	if ((error = vflush(mp, fs->lfs_ivnode, flags)) != 0)
   1514    1.1   mycroft 		return (error);
   1515  1.249     pooka 	if ((error = VFS_SYNC(mp, 1, l->l_cred)) != 0)
   1516    1.1   mycroft 		return (error);
   1517  1.252        ad 	vp = fs->lfs_ivnode;
   1518  1.289     rmind 	mutex_enter(vp->v_interlock);
   1519  1.252        ad 	if (LIST_FIRST(&vp->v_dirtyblkhd))
   1520   1.82    provos 		panic("lfs_unmount: still dirty blocks on ifile vnode");
   1521  1.289     rmind 	mutex_exit(vp->v_interlock);
   1522   1.66  perseant 
   1523  1.109  perseant 	/* Explicitly write the superblock, to update serial and pflags */
   1524  1.371  riastrad 	if (!fs->lfs_ronly) {
   1525  1.371  riastrad 		lfs_sb_setpflags(fs, lfs_sb_getpflags(fs) | LFS_PF_CLEAN);
   1526  1.371  riastrad 		lfs_writesuper(fs, lfs_sb_getsboff(fs, 0));
   1527  1.371  riastrad 		lfs_writesuper(fs, lfs_sb_getsboff(fs, 1));
   1528  1.371  riastrad 	}
   1529  1.252        ad 	mutex_enter(&lfs_lock);
   1530  1.109  perseant 	while (fs->lfs_iocount)
   1531  1.252        ad 		mtsleep(&fs->lfs_iocount, PRIBIO + 1, "lfs_umount", 0,
   1532  1.252        ad 			&lfs_lock);
   1533  1.252        ad 	mutex_exit(&lfs_lock);
   1534  1.109  perseant 
   1535  1.371  riastrad 	return 0;
   1536    1.1   mycroft }
   1537    1.1   mycroft 
   1538    1.1   mycroft /*
   1539    1.1   mycroft  * Get file system statistics.
   1540  1.169  perseant  *
   1541  1.169  perseant  * NB: We don't lock to access the superblock here, because it's not
   1542  1.169  perseant  * really that important if we get it wrong.
   1543    1.1   mycroft  */
   1544   1.10  christos int
   1545  1.249     pooka lfs_statvfs(struct mount *mp, struct statvfs *sbp)
   1546    1.1   mycroft {
   1547   1.48  augustss 	struct lfs *fs;
   1548  1.301  dholland 	struct ulfsmount *ump;
   1549    1.1   mycroft 
   1550  1.301  dholland 	ump = VFSTOULFS(mp);
   1551    1.1   mycroft 	fs = ump->um_lfs;
   1552   1.53  perseant 
   1553  1.327  dholland 	sbp->f_bsize = lfs_sb_getbsize(fs);
   1554  1.327  dholland 	sbp->f_frsize = lfs_sb_getfsize(fs);
   1555  1.327  dholland 	sbp->f_iosize = lfs_sb_getbsize(fs);
   1556  1.283   mlelstv 	sbp->f_blocks = LFS_EST_NONMETA(fs) - VTOI(fs->lfs_ivnode)->i_lfs_effnblks;
   1557  1.163  perseant 
   1558  1.283   mlelstv 	sbp->f_bfree = LFS_EST_BFREE(fs);
   1559  1.330  dholland 	/*
   1560  1.330  dholland 	 * XXX this should be lfs_sb_getsize (measured in frags)
   1561  1.330  dholland 	 * rather than dsize (measured in diskblocks). However,
   1562  1.330  dholland 	 * getsize needs a format version check (for version 1 it
   1563  1.330  dholland 	 * needs to be blockstofrags'd) so for the moment I'm going to
   1564  1.330  dholland 	 * leave this...  it won't fire wrongly as frags are at least
   1565  1.330  dholland 	 * as big as diskblocks.
   1566  1.330  dholland 	 */
   1567  1.327  dholland 	KASSERT(sbp->f_bfree <= lfs_sb_getdsize(fs));
   1568  1.220  christos #if 0
   1569  1.163  perseant 	if (sbp->f_bfree < 0)
   1570  1.163  perseant 		sbp->f_bfree = 0;
   1571  1.220  christos #endif
   1572  1.163  perseant 
   1573  1.283   mlelstv 	sbp->f_bresvd = LFS_EST_RSVD(fs);
   1574  1.147  christos 	if (sbp->f_bfree > sbp->f_bresvd)
   1575  1.147  christos 		sbp->f_bavail = sbp->f_bfree - sbp->f_bresvd;
   1576  1.147  christos 	else
   1577  1.147  christos 		sbp->f_bavail = 0;
   1578  1.164     perry 
   1579  1.330  dholland 	/* XXX: huh? - dholland 20150728 */
   1580  1.327  dholland 	sbp->f_files = lfs_sb_getbfree(fs) / lfs_btofsb(fs, lfs_sb_getibsize(fs))
   1581  1.307  christos 	    * LFS_INOPB(fs);
   1582  1.327  dholland 	sbp->f_ffree = sbp->f_files - lfs_sb_getnfiles(fs);
   1583  1.147  christos 	sbp->f_favail = sbp->f_ffree;
   1584  1.147  christos 	sbp->f_fresvd = 0;
   1585  1.147  christos 	copy_statvfs_info(sbp, mp);
   1586    1.1   mycroft 	return (0);
   1587    1.1   mycroft }
   1588    1.1   mycroft 
   1589    1.1   mycroft /*
   1590    1.1   mycroft  * Go through the disk queues to initiate sandbagged IO;
   1591    1.1   mycroft  * go through the inodes to write those that have been modified;
   1592    1.1   mycroft  * initiate the writing of the super block if it has been modified.
   1593    1.1   mycroft  */
   1594   1.10  christos int
   1595  1.249     pooka lfs_sync(struct mount *mp, int waitfor, kauth_cred_t cred)
   1596    1.1   mycroft {
   1597  1.388  perseant 	int error, segflags;
   1598   1.26  perseant 	struct lfs *fs;
   1599   1.26  perseant 
   1600  1.301  dholland 	fs = VFSTOULFS(mp)->um_lfs;
   1601   1.56  perseant 	if (fs->lfs_ronly)
   1602   1.56  perseant 		return 0;
   1603  1.206  perseant 
   1604  1.206  perseant 	/* Snapshots should not hose the syncer */
   1605  1.206  perseant 	/*
   1606  1.206  perseant 	 * XXX Sync can block here anyway, since we don't have a very
   1607  1.206  perseant 	 * XXX good idea of how much data is pending.  If it's more
   1608  1.206  perseant 	 * XXX than a segment and lfs_nextseg is close to the end of
   1609  1.206  perseant 	 * XXX the log, we'll likely block.
   1610  1.206  perseant 	 */
   1611  1.252        ad 	mutex_enter(&lfs_lock);
   1612  1.327  dholland 	if (fs->lfs_nowrap && lfs_sb_getnextseg(fs) < lfs_sb_getcurseg(fs)) {
   1613  1.252        ad 		mutex_exit(&lfs_lock);
   1614  1.206  perseant 		return 0;
   1615  1.206  perseant 	}
   1616  1.252        ad 	mutex_exit(&lfs_lock);
   1617  1.206  perseant 
   1618  1.122      yamt 	lfs_writer_enter(fs, "lfs_dirops");
   1619    1.1   mycroft 
   1620  1.388  perseant 	DLOG((DLOG_FLUSH, "lfs_sync waitfor=%x at 0x%jx\n", waitfor,
   1621  1.327  dholland 	      (uintmax_t)lfs_sb_getoffset(fs)));
   1622  1.388  perseant 
   1623  1.388  perseant 	segflags = 0;
   1624  1.388  perseant 	if (waitfor == MNT_LAZY)
   1625  1.388  perseant 		segflags = 0;
   1626  1.388  perseant 	else if (waitfor == MNT_NOWAIT)
   1627  1.388  perseant 		segflags = SEGM_CKP;
   1628  1.388  perseant 	else /* MNT_WAIT, or unknown value */
   1629  1.388  perseant 		segflags = SEGM_SYNC | SEGM_CKP;
   1630  1.388  perseant 
   1631  1.388  perseant 	error = lfs_segwrite(mp, segflags);
   1632  1.122      yamt 	lfs_writer_leave(fs);
   1633  1.300  dholland #ifdef LFS_QUOTA
   1634  1.302  dholland 	lfs_qsync(mp);
   1635    1.1   mycroft #endif
   1636    1.1   mycroft 	return (error);
   1637    1.1   mycroft }
   1638    1.1   mycroft 
   1639    1.1   mycroft /*
   1640    1.1   mycroft  * Look up an LFS dinode number to find its incore vnode.  If not already
   1641    1.1   mycroft  * in core, read it in from the specified device.  Return the inode locked.
   1642    1.1   mycroft  * Detection and handling of mount points must be done by the calling routine.
   1643    1.1   mycroft  */
   1644    1.1   mycroft int
   1645  1.369        ad lfs_vget(struct mount *mp, ino_t ino, int lktype, struct vnode **vpp)
   1646    1.1   mycroft {
   1647  1.324   hannken 	int error;
   1648  1.324   hannken 
   1649  1.324   hannken 	error = vcache_get(mp, &ino, sizeof(ino), vpp);
   1650  1.324   hannken 	if (error)
   1651  1.324   hannken 		return error;
   1652  1.369        ad 	error = vn_lock(*vpp, lktype);
   1653  1.324   hannken 	if (error) {
   1654  1.324   hannken 		vrele(*vpp);
   1655  1.324   hannken 		*vpp = NULL;
   1656  1.324   hannken 		return error;
   1657  1.324   hannken 	}
   1658  1.324   hannken 
   1659  1.324   hannken 	return 0;
   1660  1.324   hannken }
   1661  1.324   hannken 
   1662  1.324   hannken /*
   1663  1.324   hannken  * Create a new vnode/inode pair and initialize what fields we can.
   1664  1.324   hannken  */
   1665  1.324   hannken static void
   1666  1.324   hannken lfs_init_vnode(struct ulfsmount *ump, ino_t ino, struct vnode *vp)
   1667  1.324   hannken {
   1668  1.340  dholland 	struct lfs *fs = ump->um_lfs;
   1669  1.324   hannken 	struct inode *ip;
   1670  1.340  dholland 	union lfs_dinode *dp;
   1671  1.324   hannken 
   1672  1.347  dholland 	ASSERT_NO_SEGLOCK(fs);
   1673  1.324   hannken 
   1674  1.324   hannken 	/* Initialize the inode. */
   1675  1.324   hannken 	ip = pool_get(&lfs_inode_pool, PR_WAITOK);
   1676  1.324   hannken 	memset(ip, 0, sizeof(*ip));
   1677  1.324   hannken 	dp = pool_get(&lfs_dinode_pool, PR_WAITOK);
   1678  1.324   hannken 	memset(dp, 0, sizeof(*dp));
   1679  1.324   hannken 	ip->inode_ext.lfs = pool_get(&lfs_inoext_pool, PR_WAITOK);
   1680  1.324   hannken 	memset(ip->inode_ext.lfs, 0, sizeof(*ip->inode_ext.lfs));
   1681  1.341  dholland 	ip->i_din = dp;
   1682  1.324   hannken 	ip->i_ump = ump;
   1683  1.324   hannken 	ip->i_vnode = vp;
   1684  1.347  dholland 	ip->i_dev = fs->lfs_dev;
   1685  1.340  dholland 	lfs_dino_setinumber(fs, dp, ino);
   1686  1.340  dholland 	ip->i_number = ino;
   1687  1.347  dholland 	ip->i_lfs = fs;
   1688  1.324   hannken 	ip->i_lfs_effnblks = 0;
   1689  1.324   hannken 	SPLAY_INIT(&ip->i_lfs_lbtree);
   1690  1.324   hannken 	ip->i_lfs_nbtree = 0;
   1691  1.324   hannken 	LIST_INIT(&ip->i_lfs_segdhd);
   1692  1.324   hannken 
   1693  1.324   hannken 	vp->v_tag = VT_LFS;
   1694  1.324   hannken 	vp->v_op = lfs_vnodeop_p;
   1695  1.324   hannken 	vp->v_data = ip;
   1696  1.324   hannken }
   1697  1.324   hannken 
   1698  1.324   hannken /*
   1699  1.324   hannken  * Undo lfs_init_vnode().
   1700  1.324   hannken  */
   1701  1.324   hannken static void
   1702  1.324   hannken lfs_deinit_vnode(struct ulfsmount *ump, struct vnode *vp)
   1703  1.324   hannken {
   1704  1.324   hannken 	struct inode *ip = VTOI(vp);
   1705  1.324   hannken 
   1706  1.324   hannken 	pool_put(&lfs_inoext_pool, ip->inode_ext.lfs);
   1707  1.341  dholland 	pool_put(&lfs_dinode_pool, ip->i_din);
   1708  1.324   hannken 	pool_put(&lfs_inode_pool, ip);
   1709  1.324   hannken 	vp->v_data = NULL;
   1710  1.324   hannken }
   1711  1.324   hannken 
   1712  1.324   hannken /*
   1713  1.324   hannken  * Read an inode from disk and initialize this vnode / inode pair.
   1714  1.324   hannken  * Caller assures no other thread will try to load this inode.
   1715  1.324   hannken  */
   1716  1.324   hannken int
   1717  1.324   hannken lfs_loadvnode(struct mount *mp, struct vnode *vp,
   1718  1.324   hannken     const void *key, size_t key_len, const void **new_key)
   1719  1.324   hannken {
   1720   1.48  augustss 	struct lfs *fs;
   1721  1.340  dholland 	union lfs_dinode *dip;
   1722   1.48  augustss 	struct inode *ip;
   1723    1.1   mycroft 	struct buf *bp;
   1724  1.337  dholland 	IFILE *ifp;
   1725  1.301  dholland 	struct ulfsmount *ump;
   1726  1.324   hannken 	ino_t ino;
   1727   1.85      fvdl 	daddr_t daddr;
   1728  1.107      yamt 	int error, retries;
   1729   1.26  perseant 	struct timespec ts;
   1730    1.1   mycroft 
   1731  1.324   hannken 	KASSERT(key_len == sizeof(ino));
   1732  1.324   hannken 	memcpy(&ino, key, key_len);
   1733  1.324   hannken 
   1734  1.208       mrg 	memset(&ts, 0, sizeof ts);	/* XXX gcc */
   1735  1.208       mrg 
   1736  1.301  dholland 	ump = VFSTOULFS(mp);
   1737   1.60  perseant 	fs = ump->um_lfs;
   1738   1.60  perseant 
   1739   1.60  perseant 	/*
   1740   1.60  perseant 	 * If the filesystem is not completely mounted yet, suspend
   1741   1.60  perseant 	 * any access requests (wait for roll-forward to complete).
   1742   1.60  perseant 	 */
   1743  1.252        ad 	mutex_enter(&lfs_lock);
   1744   1.70       chs 	while ((fs->lfs_flags & LFS_NOTYET) && curproc->p_pid != fs->lfs_rfpid)
   1745  1.252        ad 		mtsleep(&fs->lfs_flags, PRIBIO+1, "lfs_notyet", 0,
   1746  1.252        ad 			&lfs_lock);
   1747  1.252        ad 	mutex_exit(&lfs_lock);
   1748   1.26  perseant 
   1749    1.1   mycroft 	/* Translate the inode number to a disk address. */
   1750    1.1   mycroft 	if (ino == LFS_IFILE_INUM)
   1751  1.327  dholland 		daddr = lfs_sb_getidaddr(fs);
   1752    1.1   mycroft 	else {
   1753   1.60  perseant 		/* XXX bounds-check this too */
   1754    1.1   mycroft 		LFS_IENTRY(ifp, fs, ino, bp);
   1755  1.337  dholland 		daddr = lfs_if_getdaddr(fs, ifp);
   1756  1.332  dholland 		if (lfs_sb_getversion(fs) > 1) {
   1757  1.337  dholland 			ts.tv_sec = lfs_if_getatime_sec(fs, ifp);
   1758  1.337  dholland 			ts.tv_nsec = lfs_if_getatime_nsec(fs, ifp);
   1759   1.66  perseant 		}
   1760   1.66  perseant 
   1761  1.245        ad 		brelse(bp, 0);
   1762  1.385  perseant 		if (DADDR_IS_BAD(daddr))
   1763    1.1   mycroft 			return (ENOENT);
   1764    1.1   mycroft 	}
   1765    1.1   mycroft 
   1766   1.55      fvdl 	/* Allocate/init new vnode/inode. */
   1767  1.324   hannken 	lfs_init_vnode(ump, ino, vp);
   1768    1.1   mycroft 	ip = VTOI(vp);
   1769    1.1   mycroft 
   1770  1.324   hannken 	/* If the cleaner supplied the inode, use it. */
   1771  1.347  dholland 	if (curlwp == fs->lfs_cleaner_thread && fs->lfs_cleaner_hint != NULL &&
   1772  1.347  dholland 	    fs->lfs_cleaner_hint->bi_lbn == LFS_UNUSED_LBN) {
   1773  1.347  dholland 		dip = fs->lfs_cleaner_hint->bi_bp;
   1774  1.340  dholland 		if (fs->lfs_is64) {
   1775  1.341  dholland 			error = copyin(dip, &ip->i_din->u_64,
   1776  1.340  dholland 				       sizeof(struct lfs64_dinode));
   1777  1.340  dholland 		} else {
   1778  1.341  dholland 			error = copyin(dip, &ip->i_din->u_32,
   1779  1.340  dholland 				       sizeof(struct lfs32_dinode));
   1780  1.340  dholland 		}
   1781  1.324   hannken 		if (error) {
   1782  1.324   hannken 			lfs_deinit_vnode(ump, vp);
   1783  1.324   hannken 			return error;
   1784  1.324   hannken 		}
   1785  1.324   hannken 		KASSERT(ip->i_number == ino);
   1786  1.324   hannken 		goto out;
   1787  1.324   hannken 	}
   1788    1.1   mycroft 
   1789    1.1   mycroft 	/* Read in the disk contents for the inode, copy into the inode. */
   1790   1.74  perseant 	retries = 0;
   1791  1.324   hannken again:
   1792  1.347  dholland 	error = bread(fs->lfs_devvp, LFS_FSBTODB(fs, daddr),
   1793  1.332  dholland 		(lfs_sb_getversion(fs) == 1 ? lfs_sb_getbsize(fs) : lfs_sb_getibsize(fs)),
   1794  1.322      maxv 		0, &bp);
   1795   1.10  christos 	if (error) {
   1796  1.324   hannken 		lfs_deinit_vnode(ump, vp);
   1797  1.324   hannken 		return error;
   1798    1.1   mycroft 	}
   1799   1.74  perseant 
   1800   1.74  perseant 	dip = lfs_ifind(fs, ino, bp);
   1801   1.74  perseant 	if (dip == NULL) {
   1802   1.74  perseant 		/* Assume write has not completed yet; try again */
   1803  1.245        ad 		brelse(bp, BC_INVAL);
   1804   1.74  perseant 		++retries;
   1805  1.324   hannken 		if (retries <= LFS_IFIND_RETRIES) {
   1806  1.324   hannken 			mutex_enter(&lfs_lock);
   1807  1.324   hannken 			if (fs->lfs_iocount) {
   1808  1.324   hannken 				DLOG((DLOG_VNODE,
   1809  1.324   hannken 				    "%s: dinode %d not found, retrying...\n",
   1810  1.324   hannken 				    __func__, ino));
   1811  1.324   hannken 				(void)mtsleep(&fs->lfs_iocount, PRIBIO + 1,
   1812  1.324   hannken 					      "lfs ifind", 1, &lfs_lock);
   1813  1.324   hannken 			} else
   1814  1.324   hannken 				retries = LFS_IFIND_RETRIES;
   1815  1.324   hannken 			mutex_exit(&lfs_lock);
   1816  1.324   hannken 			goto again;
   1817  1.324   hannken 		}
   1818   1.74  perseant #ifdef DEBUG
   1819  1.324   hannken 		/* If the seglock is held look at the bpp to see
   1820  1.324   hannken 		   what is there anyway */
   1821  1.324   hannken 		mutex_enter(&lfs_lock);
   1822  1.324   hannken 		if (fs->lfs_seglock > 0) {
   1823  1.324   hannken 			struct buf **bpp;
   1824  1.340  dholland 			union lfs_dinode *dp;
   1825  1.324   hannken 			int i;
   1826  1.324   hannken 
   1827  1.324   hannken 			for (bpp = fs->lfs_sp->bpp;
   1828  1.324   hannken 			     bpp != fs->lfs_sp->cbpp; ++bpp) {
   1829  1.324   hannken 				if ((*bpp)->b_vp == fs->lfs_ivnode &&
   1830  1.324   hannken 				    bpp != fs->lfs_sp->bpp) {
   1831  1.324   hannken 					/* Inode block */
   1832  1.324   hannken 					printf("%s: block 0x%" PRIx64 ": ",
   1833  1.324   hannken 					       __func__, (*bpp)->b_blkno);
   1834  1.340  dholland 					for (i = 0; i < LFS_INOPB(fs); i++) {
   1835  1.340  dholland 						dp = DINO_IN_BLOCK(fs,
   1836  1.340  dholland 						    (*bpp)->b_data, i);
   1837  1.340  dholland 						if (lfs_dino_getinumber(fs, dp))
   1838  1.340  dholland 							printf("%ju ",
   1839  1.340  dholland 							    (uintmax_t)lfs_dino_getinumber(fs, dp));
   1840  1.340  dholland 					}
   1841  1.324   hannken 					printf("\n");
   1842   1.74  perseant 				}
   1843   1.74  perseant 			}
   1844   1.74  perseant 		}
   1845  1.252        ad 		mutex_exit(&lfs_lock);
   1846  1.324   hannken #endif /* DEBUG */
   1847  1.324   hannken 		panic("lfs_loadvnode: dinode not found");
   1848   1.74  perseant 	}
   1849  1.341  dholland 	lfs_copy_dinode(fs, ip->i_din, dip);
   1850  1.245        ad 	brelse(bp, 0);
   1851   1.74  perseant 
   1852  1.324   hannken out:
   1853  1.332  dholland 	if (lfs_sb_getversion(fs) > 1) {
   1854  1.342  dholland 		lfs_dino_setatime(fs, ip->i_din, ts.tv_sec);
   1855  1.342  dholland 		lfs_dino_setatimensec(fs, ip->i_din, ts.tv_nsec);
   1856   1.66  perseant 	}
   1857    1.1   mycroft 
   1858  1.139      yamt 	lfs_vinit(mp, &vp);
   1859   1.71       chs 
   1860  1.324   hannken 	*new_key = &ip->i_number;
   1861  1.324   hannken 	return 0;
   1862  1.324   hannken }
   1863  1.324   hannken 
   1864  1.324   hannken /*
   1865  1.324   hannken  * Create a new inode and initialize this vnode / inode pair.
   1866  1.324   hannken  */
   1867  1.324   hannken int
   1868  1.324   hannken lfs_newvnode(struct mount *mp, struct vnode *dvp, struct vnode *vp,
   1869  1.364   hannken     struct vattr *vap, kauth_cred_t cred, void *extra,
   1870  1.324   hannken     size_t *key_len, const void **new_key)
   1871  1.324   hannken {
   1872  1.324   hannken 	ino_t ino;
   1873  1.324   hannken 	struct inode *ip;
   1874  1.324   hannken 	struct ulfsmount *ump;
   1875  1.324   hannken 	struct lfs *fs;
   1876  1.324   hannken 	int error, mode, gen;
   1877  1.324   hannken 
   1878  1.387  perseant 	ump = VFSTOULFS(mp);
   1879  1.387  perseant 	fs = ump->um_lfs;
   1880  1.387  perseant 
   1881  1.324   hannken 	KASSERT(dvp != NULL || vap->va_fileid > 0);
   1882  1.387  perseant 	KASSERT((fs->lfs_flags & LFS_NOTYET) ||
   1883  1.387  perseant 		(dvp != NULL && dvp->v_mount == mp));
   1884  1.324   hannken 	KASSERT(vap->va_type != VNON);
   1885  1.324   hannken 
   1886  1.324   hannken 	*key_len = sizeof(ino);
   1887  1.324   hannken 	mode = MAKEIMODE(vap->va_type, vap->va_mode);
   1888  1.324   hannken 
   1889  1.324   hannken 	/*
   1890  1.324   hannken 	 * Allocate fresh inode.  With "dvp == NULL" take the inode number
   1891  1.324   hannken 	 * and version from "vap".
   1892  1.324   hannken 	*/
   1893  1.324   hannken 	if (dvp == NULL) {
   1894  1.324   hannken 		ino = vap->va_fileid;
   1895  1.324   hannken 		gen = vap->va_gen;
   1896  1.324   hannken 		error = lfs_valloc_fixed(fs, ino, gen);
   1897  1.324   hannken 	} else {
   1898  1.324   hannken 		error = lfs_valloc(dvp, mode, cred, &ino, &gen);
   1899  1.324   hannken 	}
   1900  1.324   hannken 	if (error)
   1901  1.324   hannken 		return error;
   1902  1.324   hannken 
   1903  1.324   hannken 	/* Attach inode to vnode. */
   1904  1.324   hannken 	lfs_init_vnode(ump, ino, vp);
   1905  1.324   hannken 	ip = VTOI(vp);
   1906  1.324   hannken 
   1907  1.324   hannken 	mutex_enter(&lfs_lock);
   1908  1.324   hannken 	LFS_SET_UINO(ip, IN_CHANGE);
   1909  1.324   hannken 	mutex_exit(&lfs_lock);
   1910  1.324   hannken 
   1911  1.324   hannken 	/* Note no blocks yet */
   1912  1.324   hannken 	ip->i_lfs_hiblk = -1;
   1913  1.324   hannken 
   1914  1.324   hannken 	/* Set a new generation number for this inode. */
   1915  1.324   hannken 	ip->i_gen = gen;
   1916  1.342  dholland 	lfs_dino_setgen(fs, ip->i_din, gen);
   1917  1.324   hannken 
   1918  1.324   hannken 	memset(ip->i_lfs_fragsize, 0,
   1919  1.324   hannken 	    ULFS_NDADDR * sizeof(*ip->i_lfs_fragsize));
   1920  1.324   hannken 
   1921  1.324   hannken 	/* Set uid / gid. */
   1922  1.324   hannken 	if (cred == NOCRED || cred == FSCRED) {
   1923  1.324   hannken 		ip->i_gid = 0;
   1924  1.324   hannken 		ip->i_uid = 0;
   1925  1.324   hannken 	} else {
   1926  1.324   hannken 		ip->i_gid = VTOI(dvp)->i_gid;
   1927  1.324   hannken 		ip->i_uid = kauth_cred_geteuid(cred);
   1928  1.324   hannken 	}
   1929  1.324   hannken 	DIP_ASSIGN(ip, gid, ip->i_gid);
   1930  1.324   hannken 	DIP_ASSIGN(ip, uid, ip->i_uid);
   1931  1.324   hannken 
   1932  1.324   hannken #if defined(LFS_QUOTA) || defined(LFS_QUOTA2)
   1933  1.324   hannken 	error = lfs_chkiq(ip, 1, cred, 0);
   1934  1.324   hannken 	if (error) {
   1935  1.324   hannken 		lfs_vfree(dvp, ino, mode);
   1936  1.325   hannken 		lfs_deinit_vnode(ump, vp);
   1937  1.324   hannken 
   1938  1.324   hannken 		return error;
   1939  1.324   hannken 	}
   1940  1.324   hannken #endif
   1941   1.62  perseant 
   1942  1.324   hannken 	/* Set type and finalize. */
   1943  1.324   hannken 	ip->i_flags = 0;
   1944  1.324   hannken 	DIP_ASSIGN(ip, flags, 0);
   1945  1.324   hannken 	ip->i_mode = mode;
   1946  1.324   hannken 	DIP_ASSIGN(ip, mode, mode);
   1947  1.324   hannken 	if (vap->va_rdev != VNOVAL) {
   1948  1.324   hannken 		/*
   1949  1.324   hannken 		 * Want to be able to use this to make badblock
   1950  1.324   hannken 		 * inodes, so don't truncate the dev number.
   1951  1.324   hannken 		 */
   1952  1.342  dholland 		// XXX clean this up
   1953  1.324   hannken 		if (ump->um_fstype == ULFS1)
   1954  1.342  dholland 			ip->i_din->u_32.di_rdev = ulfs_rw32(vap->va_rdev,
   1955  1.325   hannken 			    ULFS_MPNEEDSWAP(fs));
   1956  1.324   hannken 		else
   1957  1.342  dholland 			ip->i_din->u_64.di_rdev = ulfs_rw64(vap->va_rdev,
   1958  1.325   hannken 			    ULFS_MPNEEDSWAP(fs));
   1959  1.324   hannken 	}
   1960  1.324   hannken 	lfs_vinit(mp, &vp);
   1961   1.26  perseant 
   1962  1.324   hannken 	*new_key = &ip->i_number;
   1963  1.324   hannken 	return 0;
   1964    1.1   mycroft }
   1965    1.1   mycroft 
   1966    1.1   mycroft /*
   1967    1.1   mycroft  * File handle to vnode
   1968    1.1   mycroft  */
   1969    1.1   mycroft int
   1970  1.369        ad lfs_fhtovp(struct mount *mp, struct fid *fhp, int lktype, struct vnode **vpp)
   1971    1.1   mycroft {
   1972  1.216    martin 	struct lfid lfh;
   1973  1.115  perseant 	struct lfs *fs;
   1974  1.115  perseant 
   1975  1.216    martin 	if (fhp->fid_len != sizeof(struct lfid))
   1976  1.216    martin 		return EINVAL;
   1977  1.216    martin 
   1978  1.216    martin 	memcpy(&lfh, fhp, sizeof(lfh));
   1979  1.216    martin 	if (lfh.lfid_ino < LFS_IFILE_INUM)
   1980  1.115  perseant 		return ESTALE;
   1981  1.115  perseant 
   1982  1.301  dholland 	fs = VFSTOULFS(mp)->um_lfs;
   1983  1.328  dholland 	if (lfh.lfid_ident != lfs_sb_getident(fs))
   1984  1.115  perseant 		return ESTALE;
   1985  1.115  perseant 
   1986  1.216    martin 	if (lfh.lfid_ino >
   1987  1.342  dholland 	    ((lfs_dino_getsize(fs, VTOI(fs->lfs_ivnode)->i_din) >> lfs_sb_getbshift(fs)) -
   1988  1.327  dholland 	     lfs_sb_getcleansz(fs) - lfs_sb_getsegtabsz(fs)) * lfs_sb_getifpb(fs))
   1989  1.115  perseant 		return ESTALE;
   1990  1.115  perseant 
   1991  1.369        ad 	return (ulfs_fhtovp(mp, &lfh.lfid_ufid, lktype, vpp));
   1992    1.1   mycroft }
   1993    1.1   mycroft 
   1994    1.1   mycroft /*
   1995    1.1   mycroft  * Vnode pointer to File handle
   1996    1.1   mycroft  */
   1997    1.1   mycroft /* ARGSUSED */
   1998   1.10  christos int
   1999  1.216    martin lfs_vptofh(struct vnode *vp, struct fid *fhp, size_t *fh_size)
   2000    1.1   mycroft {
   2001   1.48  augustss 	struct inode *ip;
   2002  1.216    martin 	struct lfid lfh;
   2003    1.1   mycroft 
   2004  1.216    martin 	if (*fh_size < sizeof(struct lfid)) {
   2005  1.216    martin 		*fh_size = sizeof(struct lfid);
   2006  1.216    martin 		return E2BIG;
   2007  1.216    martin 	}
   2008  1.216    martin 	*fh_size = sizeof(struct lfid);
   2009    1.1   mycroft 	ip = VTOI(vp);
   2010  1.216    martin 	memset(&lfh, 0, sizeof(lfh));
   2011  1.216    martin 	lfh.lfid_len = sizeof(struct lfid);
   2012  1.216    martin 	lfh.lfid_ino = ip->i_number;
   2013  1.216    martin 	lfh.lfid_gen = ip->i_gen;
   2014  1.328  dholland 	lfh.lfid_ident = lfs_sb_getident(ip->i_lfs);
   2015  1.216    martin 	memcpy(fhp, &lfh, sizeof(lfh));
   2016    1.1   mycroft 	return (0);
   2017   1.16      fvdl }
   2018   1.16      fvdl 
   2019  1.131      yamt /*
   2020  1.301  dholland  * ulfs_bmaparray callback function for writing.
   2021  1.131      yamt  *
   2022  1.131      yamt  * Since blocks will be written to the new segment anyway,
   2023  1.131      yamt  * we don't care about current daddr of them.
   2024  1.131      yamt  */
   2025  1.230   thorpej static bool
   2026  1.310  dholland lfs_issequential_hole(const struct lfs *fs,
   2027  1.117      yamt     daddr_t daddr0, daddr_t daddr1)
   2028  1.117      yamt {
   2029  1.310  dholland 	(void)fs; /* not used */
   2030  1.310  dholland 
   2031  1.129      yamt 	KASSERT(daddr0 == UNWRITTEN ||
   2032  1.334  dholland 	    (0 <= daddr0 && daddr0 <= LFS_MAX_DADDR(fs)));
   2033  1.129      yamt 	KASSERT(daddr1 == UNWRITTEN ||
   2034  1.334  dholland 	    (0 <= daddr1 && daddr1 <= LFS_MAX_DADDR(fs)));
   2035  1.117      yamt 
   2036  1.117      yamt 	/* NOTE: all we want to know here is 'hole or not'. */
   2037  1.301  dholland 	/* NOTE: UNASSIGNED is converted to 0 by ulfs_bmaparray. */
   2038  1.117      yamt 
   2039  1.117      yamt 	/*
   2040  1.117      yamt 	 * treat UNWRITTENs and all resident blocks as 'contiguous'
   2041  1.117      yamt 	 */
   2042  1.117      yamt 	if (daddr0 != 0 && daddr1 != 0)
   2043  1.231   thorpej 		return true;
   2044  1.117      yamt 
   2045  1.117      yamt 	/*
   2046  1.117      yamt 	 * both are in hole?
   2047  1.117      yamt 	 */
   2048  1.117      yamt 	if (daddr0 == 0 && daddr1 == 0)
   2049  1.231   thorpej 		return true; /* all holes are 'contiguous' for us. */
   2050  1.117      yamt 
   2051  1.231   thorpej 	return false;
   2052  1.117      yamt }
   2053  1.117      yamt 
   2054   1.91  perseant /*
   2055   1.91  perseant  * lfs_gop_write functions exactly like genfs_gop_write, except that
   2056   1.91  perseant  * (1) it requires the seglock to be held by its caller, and sp->fip
   2057   1.91  perseant  *     to be properly initialized (it will return without re-initializing
   2058   1.91  perseant  *     sp->fip, and without calling lfs_writeseg).
   2059   1.91  perseant  * (2) it uses the remaining space in the segment, rather than VOP_BMAP,
   2060   1.91  perseant  *     to determine how large a block it can write at once (though it does
   2061   1.91  perseant  *     still use VOP_BMAP to find holes in the file);
   2062   1.91  perseant  * (3) it calls lfs_gatherblock instead of VOP_STRATEGY on its blocks
   2063   1.91  perseant  *     (leaving lfs_writeseg to deal with the cluster blocks, so we might
   2064   1.91  perseant  *     now have clusters of clusters, ick.)
   2065   1.91  perseant  */
   2066   1.91  perseant static int
   2067  1.223  christos lfs_gop_write(struct vnode *vp, struct vm_page **pgs, int npages,
   2068  1.224  christos     int flags)
   2069   1.91  perseant {
   2070  1.252        ad 	int i, error, run, haveeof = 0;
   2071  1.137    simonb 	int fs_bshift;
   2072   1.91  perseant 	vaddr_t kva;
   2073  1.170  perseant 	off_t eof, offset, startoffset = 0;
   2074   1.91  perseant 	size_t bytes, iobytes, skipbytes;
   2075  1.281       eeh 	bool async = (flags & PGO_SYNCIO) == 0;
   2076   1.91  perseant 	daddr_t lbn, blkno;
   2077   1.91  perseant 	struct vm_page *pg;
   2078   1.91  perseant 	struct buf *mbp, *bp;
   2079  1.117      yamt 	struct vnode *devvp = VTOI(vp)->i_devvp;
   2080   1.91  perseant 	struct inode *ip = VTOI(vp);
   2081   1.91  perseant 	struct lfs *fs = ip->i_lfs;
   2082   1.91  perseant 	struct segment *sp = fs->lfs_sp;
   2083  1.338  dholland 	SEGSUM *ssp;
   2084   1.91  perseant 	UVMHIST_FUNC("lfs_gop_write"); UVMHIST_CALLED(ubchist);
   2085  1.292  perseant 	const char * failreason = NULL;
   2086   1.91  perseant 
   2087  1.169  perseant 	ASSERT_SEGLOCK(fs);
   2088  1.169  perseant 
   2089   1.91  perseant 	/* The Ifile lives in the buffer cache */
   2090  1.153      yamt 	KASSERT(vp != fs->lfs_ivnode);
   2091   1.91  perseant 
   2092  1.209  perseant 	/*
   2093  1.209  perseant 	 * We don't want to fill the disk before the cleaner has a chance
   2094  1.209  perseant 	 * to make room for us.  If we're in danger of doing that, fail
   2095  1.209  perseant 	 * with EAGAIN.  The caller will have to notice this, unlock
   2096  1.209  perseant 	 * so the cleaner can run, relock and try again.
   2097  1.209  perseant 	 *
   2098  1.209  perseant 	 * We must write everything, however, if our vnode is being
   2099  1.209  perseant 	 * reclaimed.
   2100  1.209  perseant 	 */
   2101  1.320   hannken 	mutex_enter(vp->v_interlock);
   2102  1.320   hannken 	if (LFS_STARVED_FOR_SEGS(fs) && vdead_check(vp, VDEAD_NOWAIT) == 0) {
   2103  1.320   hannken 		mutex_exit(vp->v_interlock);
   2104  1.292  perseant 		failreason = "Starved for segs and not flushing vp";
   2105  1.292  perseant  		goto tryagain;
   2106  1.292  perseant 	}
   2107  1.320   hannken 	mutex_exit(vp->v_interlock);
   2108  1.195  perseant 
   2109   1.91  perseant 	/*
   2110   1.91  perseant 	 * Sometimes things slip past the filters in lfs_putpages,
   2111   1.91  perseant 	 * and the pagedaemon tries to write pages---problem is
   2112   1.91  perseant 	 * that the pagedaemon never acquires the segment lock.
   2113   1.91  perseant 	 *
   2114  1.163  perseant 	 * Alternatively, pages that were clean when we called
   2115  1.163  perseant 	 * genfs_putpages may have become dirty in the meantime.  In this
   2116  1.163  perseant 	 * case the segment header is not properly set up for blocks
   2117  1.163  perseant 	 * to be added to it.
   2118  1.163  perseant 	 *
   2119   1.91  perseant 	 * Unbusy and unclean the pages, and put them on the ACTIVE
   2120   1.91  perseant 	 * queue under the hypothesis that they couldn't have got here
   2121   1.91  perseant 	 * unless they were modified *quite* recently.
   2122   1.91  perseant 	 *
   2123   1.91  perseant 	 * XXXUBC that last statement is an oversimplification of course.
   2124   1.91  perseant 	 */
   2125  1.292  perseant 	if (!LFS_SEGLOCK_HELD(fs)) {
   2126  1.292  perseant 		failreason = "Seglock not held";
   2127  1.292  perseant 		goto tryagain;
   2128  1.292  perseant 	}
   2129  1.292  perseant 	if (ip->i_lfs_iflags & LFSI_NO_GOP_WRITE) {
   2130  1.292  perseant 		failreason = "Inode with no_gop_write";
   2131  1.292  perseant 		goto tryagain;
   2132  1.292  perseant 	}
   2133  1.328  dholland 	if ((pgs[0]->offset & lfs_sb_getbmask(fs)) != 0) {
   2134  1.292  perseant 		failreason = "Bad page offset";
   2135  1.167    simonb 		goto tryagain;
   2136   1.91  perseant 	}
   2137   1.91  perseant 
   2138  1.361  pgoyette 	UVMHIST_LOG(ubchist, "vp %#jx pgs %#jx npages %jd flags 0x%jx",
   2139  1.361  pgoyette 	    (uintptr_t)vp, (uintptr_t)pgs, npages, flags);
   2140   1.91  perseant 
   2141  1.197      yamt 	GOP_SIZE(vp, vp->v_size, &eof, 0);
   2142  1.204  christos 	haveeof = 1;
   2143   1.91  perseant 
   2144  1.137    simonb 	if (vp->v_type == VREG)
   2145   1.91  perseant 		fs_bshift = vp->v_mount->mnt_fs_bshift;
   2146  1.137    simonb 	else
   2147   1.91  perseant 		fs_bshift = DEV_BSHIFT;
   2148   1.91  perseant 	error = 0;
   2149   1.91  perseant 	pg = pgs[0];
   2150   1.91  perseant 	startoffset = pg->offset;
   2151  1.195  perseant 	KASSERT(eof >= 0);
   2152  1.234  perseant 
   2153  1.170  perseant 	if (startoffset >= eof) {
   2154  1.292  perseant 		failreason = "Offset beyond EOF";
   2155  1.170  perseant 		goto tryagain;
   2156  1.170  perseant 	} else
   2157  1.170  perseant 		bytes = MIN(npages << PAGE_SHIFT, eof - startoffset);
   2158   1.91  perseant 	skipbytes = 0;
   2159   1.91  perseant 
   2160  1.170  perseant 	KASSERT(bytes != 0);
   2161   1.91  perseant 
   2162   1.91  perseant 	/* Swap PG_DELWRI for PG_PAGEOUT */
   2163  1.234  perseant 	for (i = 0; i < npages; i++) {
   2164   1.91  perseant 		if (pgs[i]->flags & PG_DELWRI) {
   2165   1.91  perseant 			KASSERT(!(pgs[i]->flags & PG_PAGEOUT));
   2166   1.91  perseant 			pgs[i]->flags &= ~PG_DELWRI;
   2167   1.91  perseant 			pgs[i]->flags |= PG_PAGEOUT;
   2168  1.252        ad 			uvm_pageout_start(1);
   2169  1.374        ad 			rw_enter(vp->v_uobj.vmobjlock, RW_WRITER);
   2170  1.367        ad 			uvm_pagelock(pgs[i]);
   2171   1.94      yamt 			uvm_pageunwire(pgs[i]);
   2172  1.367        ad 			uvm_pageunlock(pgs[i]);
   2173  1.374        ad 			rw_exit(vp->v_uobj.vmobjlock);
   2174   1.91  perseant 		}
   2175  1.234  perseant 	}
   2176   1.91  perseant 
   2177   1.91  perseant 	/*
   2178   1.91  perseant 	 * Check to make sure we're starting on a block boundary.
   2179   1.91  perseant 	 * We'll check later to make sure we always write entire
   2180   1.91  perseant 	 * blocks (or fragments).
   2181   1.91  perseant 	 */
   2182  1.328  dholland 	if (startoffset & lfs_sb_getbmask(fs))
   2183  1.328  dholland 		printf("%" PRId64 " & %" PRIu64 " = %" PRId64 "\n",
   2184  1.328  dholland 		       startoffset, lfs_sb_getbmask(fs),
   2185  1.328  dholland 		       startoffset & lfs_sb_getbmask(fs));
   2186  1.328  dholland 	KASSERT((startoffset & lfs_sb_getbmask(fs)) == 0);
   2187  1.328  dholland 	if (bytes & lfs_sb_getffmask(fs)) {
   2188   1.91  perseant 		printf("lfs_gop_write: asked to write %ld bytes\n", (long)bytes);
   2189   1.91  perseant 		panic("lfs_gop_write: non-integer blocks");
   2190   1.91  perseant 	}
   2191   1.91  perseant 
   2192  1.163  perseant 	/*
   2193  1.170  perseant 	 * We could deadlock here on pager_map with UVMPAGER_MAPIN_WAITOK.
   2194  1.170  perseant 	 * If we would, write what we have and try again.  If we don't
   2195  1.170  perseant 	 * have anything to write, we'll have to sleep.
   2196  1.170  perseant 	 */
   2197  1.338  dholland 	ssp = (SEGSUM *)sp->segsum;
   2198  1.171  perseant 	if ((kva = uvm_pagermapin(pgs, npages, UVMPAGER_MAPIN_WRITE |
   2199  1.338  dholland 				      (lfs_ss_getnfinfo(fs, ssp) < 1 ?
   2200  1.170  perseant 				       UVMPAGER_MAPIN_WAITOK : 0))) == 0x0) {
   2201  1.170  perseant 		DLOG((DLOG_PAGE, "lfs_gop_write: forcing write\n"));
   2202  1.171  perseant #if 0
   2203  1.327  dholland 		      " with nfinfo=%d at offset 0x%jx\n",
   2204  1.338  dholland 		      (int)lfs_ss_getnfinfo(fs, ssp),
   2205  1.327  dholland 		      (uintmax_t)lfs_sb_getoffset(fs)));
   2206  1.171  perseant #endif
   2207  1.212  perseant 		lfs_updatemeta(sp);
   2208  1.212  perseant 		lfs_release_finfo(fs);
   2209  1.170  perseant 		(void) lfs_writeseg(fs, sp);
   2210  1.170  perseant 
   2211  1.213  perseant 		lfs_acquire_finfo(fs, ip->i_number, ip->i_gen);
   2212  1.170  perseant 
   2213  1.171  perseant 		/*
   2214  1.171  perseant 		 * Having given up all of the pager_map we were holding,
   2215  1.171  perseant 		 * we can now wait for aiodoned to reclaim it for us
   2216  1.171  perseant 		 * without fear of deadlock.
   2217  1.171  perseant 		 */
   2218  1.171  perseant 		kva = uvm_pagermapin(pgs, npages, UVMPAGER_MAPIN_WRITE |
   2219  1.171  perseant 				     UVMPAGER_MAPIN_WAITOK);
   2220  1.170  perseant 	}
   2221   1.91  perseant 
   2222  1.252        ad 	mbp = getiobuf(NULL, true);
   2223  1.361  pgoyette 	UVMHIST_LOG(ubchist, "vp %#jx mbp %#jx num now %jd bytes 0x%jx",
   2224  1.361  pgoyette 	    (uintptr_t)vp, (uintptr_t)mbp, vp->v_numoutput, bytes);
   2225   1.91  perseant 	mbp->b_bufsize = npages << PAGE_SHIFT;
   2226   1.91  perseant 	mbp->b_data = (void *)kva;
   2227   1.91  perseant 	mbp->b_resid = mbp->b_bcount = bytes;
   2228  1.375        ad 	mbp->b_cflags |= BC_BUSY|BC_AGE;
   2229  1.370       chs 	mbp->b_iodone = uvm_aio_aiodone;
   2230   1.91  perseant 
   2231   1.91  perseant 	bp = NULL;
   2232   1.91  perseant 	for (offset = startoffset;
   2233   1.91  perseant 	    bytes > 0;
   2234   1.91  perseant 	    offset += iobytes, bytes -= iobytes) {
   2235   1.91  perseant 		lbn = offset >> fs_bshift;
   2236  1.301  dholland 		error = ulfs_bmaparray(vp, lbn, &blkno, NULL, NULL, &run,
   2237  1.117      yamt 		    lfs_issequential_hole);
   2238   1.91  perseant 		if (error) {
   2239  1.361  pgoyette 			UVMHIST_LOG(ubchist, "ulfs_bmaparray() -> %jd",
   2240  1.117      yamt 			    error,0,0,0);
   2241   1.91  perseant 			skipbytes += bytes;
   2242   1.91  perseant 			bytes = 0;
   2243   1.91  perseant 			break;
   2244   1.91  perseant 		}
   2245   1.91  perseant 
   2246  1.116  perseant 		iobytes = MIN((((off_t)lbn + 1 + run) << fs_bshift) - offset,
   2247  1.116  perseant 		    bytes);
   2248   1.91  perseant 		if (blkno == (daddr_t)-1) {
   2249   1.91  perseant 			skipbytes += iobytes;
   2250   1.91  perseant 			continue;
   2251   1.91  perseant 		}
   2252   1.91  perseant 
   2253   1.91  perseant 		/*
   2254   1.91  perseant 		 * Discover how much we can really pack into this buffer.
   2255   1.91  perseant 		 */
   2256   1.91  perseant 		/* If no room in the current segment, finish it up */
   2257   1.91  perseant 		if (sp->sum_bytes_left < sizeof(int32_t) ||
   2258  1.328  dholland 		    sp->seg_bytes_left < (1 << lfs_sb_getbshift(fs))) {
   2259  1.181  christos 			int vers;
   2260   1.91  perseant 
   2261   1.91  perseant 			lfs_updatemeta(sp);
   2262  1.339  dholland 			vers = lfs_fi_getversion(fs, sp->fip);
   2263  1.212  perseant 			lfs_release_finfo(fs);
   2264   1.91  perseant 			(void) lfs_writeseg(fs, sp);
   2265  1.164     perry 
   2266  1.212  perseant 			lfs_acquire_finfo(fs, ip->i_number, vers);
   2267   1.91  perseant 		}
   2268   1.97  perseant 		/* Check both for space in segment and space in segsum */
   2269   1.97  perseant 		iobytes = MIN(iobytes, (sp->seg_bytes_left >> fs_bshift)
   2270   1.97  perseant 					<< fs_bshift);
   2271   1.97  perseant 		iobytes = MIN(iobytes, (sp->sum_bytes_left / sizeof(int32_t))
   2272   1.97  perseant 				       << fs_bshift);
   2273   1.91  perseant 		KASSERT(iobytes > 0);
   2274   1.91  perseant 
   2275   1.91  perseant 		/* if it's really one i/o, don't make a second buf */
   2276   1.91  perseant 		if (offset == startoffset && iobytes == bytes) {
   2277   1.91  perseant 			bp = mbp;
   2278  1.279       eeh 			/*
   2279  1.279       eeh 			 * All the LFS output is done by the segwriter.  It
   2280  1.279       eeh 			 * will increment numoutput by one for all the bufs it
   2281  1.365   msaitoh 			 * receives.  However this buffer needs one extra to
   2282  1.279       eeh 			 * account for aiodone.
   2283  1.279       eeh 			 */
   2284  1.289     rmind 			mutex_enter(vp->v_interlock);
   2285  1.279       eeh 			vp->v_numoutput++;
   2286  1.289     rmind 			mutex_exit(vp->v_interlock);
   2287   1.91  perseant 		} else {
   2288  1.252        ad 			bp = getiobuf(NULL, true);
   2289  1.361  pgoyette 			UVMHIST_LOG(ubchist, "vp %#jx bp %#jx num now %jd",
   2290  1.361  pgoyette 			    (uintptr_t)vp, (uintptr_t)bp, vp->v_numoutput, 0);
   2291  1.275     pooka 			nestiobuf_setup(mbp, bp, offset - pg->offset, iobytes);
   2292  1.275     pooka 			/*
   2293  1.275     pooka 			 * LFS doesn't like async I/O here, dies with
   2294  1.292  perseant 			 * an assert in lfs_bwrite().  Is that assert
   2295  1.275     pooka 			 * valid?  I retained non-async behaviour when
   2296  1.275     pooka 			 * converted this to use nestiobuf --pooka
   2297  1.275     pooka 			 */
   2298  1.275     pooka 			bp->b_flags &= ~B_ASYNC;
   2299   1.91  perseant 		}
   2300   1.91  perseant 
   2301   1.91  perseant 		/* XXX This is silly ... is this necessary? */
   2302  1.252        ad 		mutex_enter(&bufcache_lock);
   2303  1.289     rmind 		mutex_enter(vp->v_interlock);
   2304   1.91  perseant 		bgetvp(vp, bp);
   2305  1.289     rmind 		mutex_exit(vp->v_interlock);
   2306  1.252        ad 		mutex_exit(&bufcache_lock);
   2307   1.91  perseant 
   2308  1.307  christos 		bp->b_lblkno = lfs_lblkno(fs, offset);
   2309   1.91  perseant 		bp->b_private = mbp;
   2310   1.91  perseant 		if (devvp->v_type == VBLK) {
   2311   1.91  perseant 			bp->b_dev = devvp->v_rdev;
   2312   1.91  perseant 		}
   2313  1.290   hannken 		VOP_BWRITE(bp->b_vp, bp);
   2314  1.110  perseant 		while (lfs_gatherblock(sp, bp, NULL))
   2315  1.111       dsl 			continue;
   2316   1.91  perseant 	}
   2317   1.91  perseant 
   2318  1.276     pooka 	nestiobuf_done(mbp, skipbytes, error);
   2319   1.91  perseant 	if (skipbytes) {
   2320  1.361  pgoyette 		UVMHIST_LOG(ubchist, "skipbytes %jd", skipbytes, 0,0,0);
   2321   1.91  perseant 	}
   2322   1.91  perseant 	UVMHIST_LOG(ubchist, "returning 0", 0,0,0,0);
   2323  1.281       eeh 
   2324  1.281       eeh 	if (!async) {
   2325  1.281       eeh 		/* Start a segment write. */
   2326  1.281       eeh 		UVMHIST_LOG(ubchist, "flushing", 0,0,0,0);
   2327  1.281       eeh 		mutex_enter(&lfs_lock);
   2328  1.281       eeh 		lfs_flush(fs, 0, 1);
   2329  1.281       eeh 		mutex_exit(&lfs_lock);
   2330  1.281       eeh 	}
   2331  1.292  perseant 
   2332  1.327  dholland 	if ((sp->seg_flags & SEGM_SINGLE) && lfs_sb_getcurseg(fs) != fs->lfs_startseg)
   2333  1.292  perseant 		return EAGAIN;
   2334  1.292  perseant 
   2335   1.91  perseant 	return (0);
   2336  1.163  perseant 
   2337  1.163  perseant     tryagain:
   2338  1.167    simonb 	/*
   2339  1.167    simonb 	 * We can't write the pages, for whatever reason.
   2340  1.167    simonb 	 * Clean up after ourselves, and make the caller try again.
   2341  1.167    simonb 	 */
   2342  1.166  perseant 
   2343  1.166  perseant 	/* Tell why we're here, if we know */
   2344  1.292  perseant 	if (failreason != NULL) {
   2345  1.292  perseant 		DLOG((DLOG_PAGE, "lfs_gop_write: %s\n", failreason));
   2346  1.292  perseant 	}
   2347  1.292  perseant 	if (haveeof && startoffset >= eof) {
   2348  1.292  perseant  		DLOG((DLOG_PAGE, "lfs_gop_write: ino %d start 0x%" PRIx64
   2349  1.292  perseant  		      " eof 0x%" PRIx64 " npages=%d\n", VTOI(vp)->i_number,
   2350  1.292  perseant  		      pgs[0]->offset, eof, npages));
   2351  1.222  christos 	}
   2352  1.166  perseant 
   2353  1.387  perseant 	rw_enter(vp->v_uobj.vmobjlock, RW_WRITER);
   2354  1.167    simonb 	for (i = 0; i < npages; i++) {
   2355  1.167    simonb 		pg = pgs[i];
   2356  1.167    simonb 
   2357  1.167    simonb 		if (pg->flags & PG_PAGEOUT)
   2358  1.252        ad 			uvm_pageout_done(1);
   2359  1.367        ad 		uvm_pagelock(pg);
   2360  1.167    simonb 		if (pg->flags & PG_DELWRI) {
   2361  1.167    simonb 			uvm_pageunwire(pg);
   2362  1.167    simonb 		}
   2363  1.167    simonb 		uvm_pageactivate(pg);
   2364  1.367        ad 		uvm_pageunlock(pg);
   2365  1.368        ad 		pg->flags &= ~(PG_DELWRI|PG_PAGEOUT|PG_RELEASED);
   2366  1.368        ad 		uvm_pagemarkdirty(pg, UVM_PAGE_STATUS_DIRTY);
   2367  1.195  perseant 		DLOG((DLOG_PAGE, "pg[%d] = %p (vp %p off %" PRIx64 ")\n", i, pg,
   2368  1.195  perseant 			vp, pg->offset));
   2369  1.167    simonb 		DLOG((DLOG_PAGE, "pg[%d]->flags = %x\n", i, pg->flags));
   2370  1.166  perseant 		DLOG((DLOG_PAGE, "pg[%d]->pqflags = %x\n", i, pg->pqflags));
   2371  1.167    simonb 		DLOG((DLOG_PAGE, "pg[%d]->uanon = %p\n", i, pg->uanon));
   2372  1.167    simonb 		DLOG((DLOG_PAGE, "pg[%d]->uobject = %p\n", i, pg->uobject));
   2373  1.167    simonb 		DLOG((DLOG_PAGE, "pg[%d]->wire_count = %d\n", i,
   2374  1.166  perseant 		      pg->wire_count));
   2375  1.167    simonb 		DLOG((DLOG_PAGE, "pg[%d]->loan_count = %d\n", i,
   2376  1.166  perseant 		      pg->loan_count));
   2377  1.167    simonb 	}
   2378  1.167    simonb 	uvm_page_unbusy(pgs, npages);
   2379  1.387  perseant 	rw_exit(vp->v_uobj.vmobjlock);
   2380  1.167    simonb 	return EAGAIN;
   2381  1.107      yamt }
   2382  1.107      yamt 
   2383  1.107      yamt /*
   2384  1.107      yamt  * finish vnode/inode initialization.
   2385  1.324   hannken  * used by lfs_vget.
   2386  1.107      yamt  */
   2387  1.107      yamt void
   2388  1.139      yamt lfs_vinit(struct mount *mp, struct vnode **vpp)
   2389  1.107      yamt {
   2390  1.139      yamt 	struct vnode *vp = *vpp;
   2391  1.107      yamt 	struct inode *ip = VTOI(vp);
   2392  1.301  dholland 	struct ulfsmount *ump = VFSTOULFS(mp);
   2393  1.234  perseant 	struct lfs *fs = ump->um_lfs;
   2394  1.107      yamt 	int i;
   2395  1.107      yamt 
   2396  1.342  dholland 	ip->i_mode = lfs_dino_getmode(fs, ip->i_din);
   2397  1.342  dholland 	ip->i_nlink = lfs_dino_getnlink(fs, ip->i_din);
   2398  1.342  dholland 	ip->i_lfs_osize = ip->i_size = lfs_dino_getsize(fs, ip->i_din);
   2399  1.342  dholland 	ip->i_flags = lfs_dino_getflags(fs, ip->i_din);
   2400  1.342  dholland 	ip->i_gen = lfs_dino_getgen(fs, ip->i_din);
   2401  1.342  dholland 	ip->i_uid = lfs_dino_getuid(fs, ip->i_din);
   2402  1.342  dholland 	ip->i_gid = lfs_dino_getgid(fs, ip->i_din);
   2403  1.113      fvdl 
   2404  1.342  dholland 	ip->i_lfs_effnblks = lfs_dino_getblocks(fs, ip->i_din);
   2405  1.342  dholland 	ip->i_lfs_odnlink = lfs_dino_getnlink(fs, ip->i_din);
   2406  1.107      yamt 
   2407  1.107      yamt 	/*
   2408  1.107      yamt 	 * Initialize the vnode from the inode, check for aliases.  In all
   2409  1.107      yamt 	 * cases re-init ip, the underlying vnode/inode may have changed.
   2410  1.107      yamt 	 */
   2411  1.301  dholland 	ulfs_vinit(mp, lfs_specop_p, lfs_fifoop_p, &vp);
   2412  1.163  perseant 	ip = VTOI(vp);
   2413  1.107      yamt 
   2414  1.301  dholland 	memset(ip->i_lfs_fragsize, 0, ULFS_NDADDR * sizeof(*ip->i_lfs_fragsize));
   2415  1.310  dholland 	if (vp->v_type != VLNK || ip->i_size >= ip->i_lfs->um_maxsymlinklen) {
   2416  1.108      yamt #ifdef DEBUG
   2417  1.328  dholland 		for (i = (ip->i_size + lfs_sb_getbsize(fs) - 1) >> lfs_sb_getbshift(fs);
   2418  1.301  dholland 		    i < ULFS_NDADDR; i++) {
   2419  1.163  perseant 			if ((vp->v_type == VBLK || vp->v_type == VCHR) &&
   2420  1.163  perseant 			    i == 0)
   2421  1.163  perseant 				continue;
   2422  1.342  dholland 			if (lfs_dino_getdb(fs, ip->i_din, i) != 0) {
   2423  1.341  dholland 				lfs_dump_dinode(fs, ip->i_din);
   2424  1.292  perseant 				panic("inconsistent inode (direct)");
   2425  1.107      yamt 			}
   2426  1.107      yamt 		}
   2427  1.301  dholland 		for ( ; i < ULFS_NDADDR + ULFS_NIADDR; i++) {
   2428  1.342  dholland 			if (lfs_dino_getib(fs, ip->i_din, i - ULFS_NDADDR) != 0) {
   2429  1.341  dholland 				lfs_dump_dinode(fs, ip->i_din);
   2430  1.292  perseant 				panic("inconsistent inode (indirect)");
   2431  1.107      yamt 			}
   2432  1.107      yamt 		}
   2433  1.108      yamt #endif /* DEBUG */
   2434  1.301  dholland 		for (i = 0; i < ULFS_NDADDR; i++)
   2435  1.342  dholland 			if (lfs_dino_getdb(fs, ip->i_din, i) != 0)
   2436  1.307  christos 				ip->i_lfs_fragsize[i] = lfs_blksize(fs, ip, i);
   2437  1.107      yamt 	}
   2438  1.107      yamt 
   2439  1.353  riastrad 	KASSERTMSG((vp->v_type != VNON),
   2440  1.353  riastrad 	    "lfs_vinit: ino %llu is type VNON! (ifmt=%o)\n",
   2441  1.353  riastrad 	    (unsigned long long)ip->i_number,
   2442  1.353  riastrad 	    (ip->i_mode & LFS_IFMT) >> 12);
   2443  1.107      yamt 
   2444  1.107      yamt 	/*
   2445  1.107      yamt 	 * Finish inode initialization now that aliasing has been resolved.
   2446  1.107      yamt 	 */
   2447  1.107      yamt 
   2448  1.347  dholland 	ip->i_devvp = fs->lfs_devvp;
   2449  1.282     pooka 	vref(ip->i_devvp);
   2450  1.312  dholland #if defined(LFS_QUOTA) || defined(LFS_QUOTA2)
   2451  1.312  dholland 	ulfsquota_init(ip);
   2452  1.312  dholland #endif
   2453  1.107      yamt 	genfs_node_init(vp, &lfs_genfsops);
   2454  1.113      fvdl 	uvm_vnp_setsize(vp, ip->i_size);
   2455  1.139      yamt 
   2456  1.172  perseant 	/* Initialize hiblk from file size */
   2457  1.327  dholland 	ip->i_lfs_hiblk = lfs_lblkno(ip->i_lfs, ip->i_size + lfs_sb_getbsize(ip->i_lfs) - 1) - 1;
   2458  1.172  perseant 
   2459  1.139      yamt 	*vpp = vp;
   2460   1.91  perseant }
   2461  1.165  perseant 
   2462  1.165  perseant /*
   2463  1.177  perseant  * Resize the filesystem to contain the specified number of segments.
   2464  1.177  perseant  */
   2465  1.177  perseant int
   2466  1.177  perseant lfs_resize_fs(struct lfs *fs, int newnsegs)
   2467  1.177  perseant {
   2468  1.177  perseant 	SEGUSE *sup;
   2469  1.336  dholland 	CLEANERINFO *cip;
   2470  1.177  perseant 	struct buf *bp, *obp;
   2471  1.177  perseant 	daddr_t olast, nlast, ilast, noff, start, end;
   2472  1.177  perseant 	struct vnode *ivp;
   2473  1.177  perseant 	struct inode *ip;
   2474  1.177  perseant 	int error, badnews, inc, oldnsegs;
   2475  1.177  perseant 	int sbbytes, csbbytes, gain, cgain;
   2476  1.177  perseant 	int i;
   2477  1.177  perseant 
   2478  1.177  perseant 	/* Only support v2 and up */
   2479  1.332  dholland 	if (lfs_sb_getversion(fs) < 2)
   2480  1.177  perseant 		return EOPNOTSUPP;
   2481  1.177  perseant 
   2482  1.177  perseant 	/* If we're doing nothing, do it fast */
   2483  1.328  dholland 	oldnsegs = lfs_sb_getnseg(fs);
   2484  1.177  perseant 	if (newnsegs == oldnsegs)
   2485  1.177  perseant 		return 0;
   2486  1.177  perseant 
   2487  1.177  perseant 	/* We always have to have two superblocks */
   2488  1.328  dholland 	if (newnsegs <= lfs_dtosn(fs, lfs_sb_getsboff(fs, 1)))
   2489  1.328  dholland 		/* XXX this error code is rather nonsense */
   2490  1.177  perseant 		return EFBIG;
   2491  1.177  perseant 
   2492  1.177  perseant 	ivp = fs->lfs_ivnode;
   2493  1.177  perseant 	ip = VTOI(ivp);
   2494  1.177  perseant 	error = 0;
   2495  1.177  perseant 
   2496  1.177  perseant 	/* Take the segment lock so no one else calls lfs_newseg() */
   2497  1.177  perseant 	lfs_seglock(fs, SEGM_PROT);
   2498  1.177  perseant 
   2499  1.177  perseant 	/*
   2500  1.177  perseant 	 * Make sure the segments we're going to be losing, if any,
   2501  1.177  perseant 	 * are in fact empty.  We hold the seglock, so their status
   2502  1.177  perseant 	 * cannot change underneath us.  Count the superblocks we lose,
   2503  1.177  perseant 	 * while we're at it.
   2504  1.177  perseant 	 */
   2505  1.177  perseant 	sbbytes = csbbytes = 0;
   2506  1.177  perseant 	cgain = 0;
   2507  1.177  perseant 	for (i = newnsegs; i < oldnsegs; i++) {
   2508  1.177  perseant 		LFS_SEGENTRY(sup, fs, i, bp);
   2509  1.177  perseant 		badnews = sup->su_nbytes || !(sup->su_flags & SEGUSE_INVAL);
   2510  1.177  perseant 		if (sup->su_flags & SEGUSE_SUPERBLOCK)
   2511  1.177  perseant 			sbbytes += LFS_SBPAD;
   2512  1.177  perseant 		if (!(sup->su_flags & SEGUSE_DIRTY)) {
   2513  1.177  perseant 			++cgain;
   2514  1.177  perseant 			if (sup->su_flags & SEGUSE_SUPERBLOCK)
   2515  1.177  perseant 				csbbytes += LFS_SBPAD;
   2516  1.177  perseant 		}
   2517  1.245        ad 		brelse(bp, 0);
   2518  1.177  perseant 		if (badnews) {
   2519  1.177  perseant 			error = EBUSY;
   2520  1.177  perseant 			goto out;
   2521  1.177  perseant 		}
   2522  1.177  perseant 	}
   2523  1.177  perseant 
   2524  1.177  perseant 	/* Note old and new segment table endpoints, and old ifile size */
   2525  1.327  dholland 	olast = lfs_sb_getcleansz(fs) + lfs_sb_getsegtabsz(fs);
   2526  1.327  dholland 	nlast = howmany(newnsegs, lfs_sb_getsepb(fs)) + lfs_sb_getcleansz(fs);
   2527  1.328  dholland 	ilast = ivp->v_size >> lfs_sb_getbshift(fs);
   2528  1.177  perseant 	noff = nlast - olast;
   2529  1.177  perseant 
   2530  1.177  perseant 	/*
   2531  1.177  perseant 	 * Make sure no one can use the Ifile while we change it around.
   2532  1.177  perseant 	 * Even after taking the iflock we need to make sure no one still
   2533  1.177  perseant 	 * is holding Ifile buffers, so we get each one, to drain them.
   2534  1.177  perseant 	 * (XXX this could be done better.)
   2535  1.177  perseant 	 */
   2536  1.252        ad 	rw_enter(&fs->lfs_iflock, RW_WRITER);
   2537  1.177  perseant 	for (i = 0; i < ilast; i++) {
   2538  1.297   hannken 		/* XXX what to do if bread fails? */
   2539  1.327  dholland 		bread(ivp, i, lfs_sb_getbsize(fs), 0, &bp);
   2540  1.245        ad 		brelse(bp, 0);
   2541  1.177  perseant 	}
   2542  1.177  perseant 
   2543  1.177  perseant 	/* Allocate new Ifile blocks */
   2544  1.177  perseant 	for (i = ilast; i < ilast + noff; i++) {
   2545  1.327  dholland 		if (lfs_balloc(ivp, i * lfs_sb_getbsize(fs), lfs_sb_getbsize(fs), NOCRED, 0,
   2546  1.177  perseant 			       &bp) != 0)
   2547  1.177  perseant 			panic("balloc extending ifile");
   2548  1.327  dholland 		memset(bp->b_data, 0, lfs_sb_getbsize(fs));
   2549  1.290   hannken 		VOP_BWRITE(bp->b_vp, bp);
   2550  1.177  perseant 	}
   2551  1.177  perseant 
   2552  1.177  perseant 	/* Register new ifile size */
   2553  1.351   msaitoh 	ip->i_size += noff * lfs_sb_getbsize(fs);
   2554  1.342  dholland 	lfs_dino_setsize(fs, ip->i_din, ip->i_size);
   2555  1.177  perseant 	uvm_vnp_setsize(ivp, ip->i_size);
   2556  1.177  perseant 
   2557  1.177  perseant 	/* Copy the inode table to its new position */
   2558  1.177  perseant 	if (noff != 0) {
   2559  1.177  perseant 		if (noff < 0) {
   2560  1.177  perseant 			start = nlast;
   2561  1.177  perseant 			end = ilast + noff;
   2562  1.177  perseant 			inc = 1;
   2563  1.177  perseant 		} else {
   2564  1.177  perseant 			start = ilast + noff - 1;
   2565  1.177  perseant 			end = nlast - 1;
   2566  1.177  perseant 			inc = -1;
   2567  1.177  perseant 		}
   2568  1.177  perseant 		for (i = start; i != end; i += inc) {
   2569  1.327  dholland 			if (bread(ivp, i, lfs_sb_getbsize(fs),
   2570  1.262   hannken 			    B_MODIFY, &bp) != 0)
   2571  1.177  perseant 				panic("resize: bread dst blk failed");
   2572  1.327  dholland 			if (bread(ivp, i - noff, lfs_sb_getbsize(fs),
   2573  1.322      maxv 			    0, &obp))
   2574  1.177  perseant 				panic("resize: bread src blk failed");
   2575  1.327  dholland 			memcpy(bp->b_data, obp->b_data, lfs_sb_getbsize(fs));
   2576  1.290   hannken 			VOP_BWRITE(bp->b_vp, bp);
   2577  1.245        ad 			brelse(obp, 0);
   2578  1.177  perseant 		}
   2579  1.177  perseant 	}
   2580  1.177  perseant 
   2581  1.177  perseant 	/* If we are expanding, write the new empty SEGUSE entries */
   2582  1.177  perseant 	if (newnsegs > oldnsegs) {
   2583  1.177  perseant 		for (i = oldnsegs; i < newnsegs; i++) {
   2584  1.327  dholland 			if ((error = bread(ivp, i / lfs_sb_getsepb(fs) +
   2585  1.327  dholland 					   lfs_sb_getcleansz(fs), lfs_sb_getbsize(fs),
   2586  1.322      maxv 					   B_MODIFY, &bp)) != 0)
   2587  1.177  perseant 				panic("lfs: ifile read: %d", error);
   2588  1.327  dholland 			while ((i + 1) % lfs_sb_getsepb(fs) && i < newnsegs) {
   2589  1.327  dholland 				sup = &((SEGUSE *)bp->b_data)[i % lfs_sb_getsepb(fs)];
   2590  1.177  perseant 				memset(sup, 0, sizeof(*sup));
   2591  1.177  perseant 				i++;
   2592  1.177  perseant 			}
   2593  1.290   hannken 			VOP_BWRITE(bp->b_vp, bp);
   2594  1.177  perseant 		}
   2595  1.177  perseant 	}
   2596  1.177  perseant 
   2597  1.177  perseant 	/* Zero out unused superblock offsets */
   2598  1.177  perseant 	for (i = 2; i < LFS_MAXNUMSB; i++)
   2599  1.328  dholland 		if (lfs_dtosn(fs, lfs_sb_getsboff(fs, i)) >= newnsegs)
   2600  1.328  dholland 			lfs_sb_setsboff(fs, i, 0x0);
   2601  1.177  perseant 
   2602  1.177  perseant 	/*
   2603  1.177  perseant 	 * Correct superblock entries that depend on fs size.
   2604  1.177  perseant 	 * The computations of these are as follows:
   2605  1.177  perseant 	 *
   2606  1.307  christos 	 * size  = lfs_segtod(fs, nseg)
   2607  1.307  christos 	 * dsize = lfs_segtod(fs, nseg - minfreeseg) - lfs_btofsb(#super * LFS_SBPAD)
   2608  1.307  christos 	 * bfree = dsize - lfs_btofsb(fs, bsize * nseg / 2) - blocks_actually_used
   2609  1.307  christos 	 * avail = lfs_segtod(fs, nclean) - lfs_btofsb(#clean_super * LFS_SBPAD)
   2610  1.307  christos 	 *         + (lfs_segtod(fs, 1) - (offset - curseg))
   2611  1.307  christos 	 *	   - lfs_segtod(fs, minfreeseg - (minfreeseg / 2))
   2612  1.177  perseant 	 *
   2613  1.177  perseant 	 * XXX - we should probably adjust minfreeseg as well.
   2614  1.177  perseant 	 */
   2615  1.177  perseant 	gain = (newnsegs - oldnsegs);
   2616  1.328  dholland 	lfs_sb_setnseg(fs, newnsegs);
   2617  1.327  dholland 	lfs_sb_setsegtabsz(fs, nlast - lfs_sb_getcleansz(fs));
   2618  1.327  dholland 	lfs_sb_addsize(fs, gain * lfs_btofsb(fs, lfs_sb_getssize(fs)));
   2619  1.327  dholland 	lfs_sb_adddsize(fs, gain * lfs_btofsb(fs, lfs_sb_getssize(fs)) - lfs_btofsb(fs, sbbytes));
   2620  1.327  dholland 	lfs_sb_addbfree(fs, gain * lfs_btofsb(fs, lfs_sb_getssize(fs)) - lfs_btofsb(fs, sbbytes)
   2621  1.327  dholland 		       - gain * lfs_btofsb(fs, lfs_sb_getbsize(fs) / 2));
   2622  1.177  perseant 	if (gain > 0) {
   2623  1.328  dholland 		lfs_sb_addnclean(fs, gain);
   2624  1.327  dholland 		lfs_sb_addavail(fs, gain * lfs_btofsb(fs, lfs_sb_getssize(fs)));
   2625  1.177  perseant 	} else {
   2626  1.328  dholland 		lfs_sb_subnclean(fs, cgain);
   2627  1.327  dholland 		lfs_sb_subavail(fs, cgain * lfs_btofsb(fs, lfs_sb_getssize(fs)) -
   2628  1.327  dholland 				 lfs_btofsb(fs, csbbytes));
   2629  1.177  perseant 	}
   2630  1.177  perseant 
   2631  1.177  perseant 	/* Resize segment flag cache */
   2632  1.307  christos 	fs->lfs_suflags[0] = realloc(fs->lfs_suflags[0],
   2633  1.328  dholland 	    lfs_sb_getnseg(fs) * sizeof(u_int32_t), M_SEGMENT, M_WAITOK);
   2634  1.307  christos 	fs->lfs_suflags[1] = realloc(fs->lfs_suflags[1],
   2635  1.328  dholland 	    lfs_sb_getnseg(fs) * sizeof(u_int32_t), M_SEGMENT, M_WAITOK);
   2636  1.177  perseant 	for (i = oldnsegs; i < newnsegs; i++)
   2637  1.177  perseant 		fs->lfs_suflags[0][i] = fs->lfs_suflags[1][i] = 0x0;
   2638  1.177  perseant 
   2639  1.177  perseant 	/* Truncate Ifile if necessary */
   2640  1.177  perseant 	if (noff < 0)
   2641  1.328  dholland 		lfs_truncate(ivp, ivp->v_size + (noff << lfs_sb_getbshift(fs)), 0,
   2642  1.250     pooka 		    NOCRED);
   2643  1.177  perseant 
   2644  1.177  perseant 	/* Update cleaner info so the cleaner can die */
   2645  1.297   hannken 	/* XXX what to do if bread fails? */
   2646  1.327  dholland 	bread(ivp, 0, lfs_sb_getbsize(fs), B_MODIFY, &bp);
   2647  1.336  dholland 	cip = bp->b_data;
   2648  1.336  dholland 	lfs_ci_setclean(fs, cip, lfs_sb_getnclean(fs));
   2649  1.336  dholland 	lfs_ci_setdirty(fs, cip, lfs_sb_getnseg(fs) - lfs_sb_getnclean(fs));
   2650  1.290   hannken 	VOP_BWRITE(bp->b_vp, bp);
   2651  1.177  perseant 
   2652  1.177  perseant 	/* Let Ifile accesses proceed */
   2653  1.252        ad 	rw_exit(&fs->lfs_iflock);
   2654  1.177  perseant 
   2655  1.177  perseant     out:
   2656  1.177  perseant 	lfs_segunlock(fs);
   2657  1.177  perseant 	return error;
   2658  1.177  perseant }
   2659  1.313  dholland 
   2660  1.313  dholland /*
   2661  1.313  dholland  * Extended attribute dispatch
   2662  1.313  dholland  */
   2663  1.323   hannken int
   2664  1.313  dholland lfs_extattrctl(struct mount *mp, int cmd, struct vnode *vp,
   2665  1.313  dholland 	       int attrnamespace, const char *attrname)
   2666  1.313  dholland {
   2667  1.313  dholland #ifdef LFS_EXTATTR
   2668  1.313  dholland 	struct ulfsmount *ump;
   2669  1.313  dholland 
   2670  1.313  dholland 	ump = VFSTOULFS(mp);
   2671  1.313  dholland 	if (ump->um_fstype == ULFS1) {
   2672  1.313  dholland 		return ulfs_extattrctl(mp, cmd, vp, attrnamespace, attrname);
   2673  1.313  dholland 	}
   2674  1.313  dholland #endif
   2675  1.313  dholland 	return vfs_stdextattrctl(mp, cmd, vp, attrnamespace, attrname);
   2676  1.313  dholland }
   2677