Home | History | Annotate | Line # | Download | only in lfs
lfs_vnops.c revision 1.275
      1  1.275  dholland /*	$NetBSD: lfs_vnops.c,v 1.275 2015/07/24 06:59:32 dholland Exp $	*/
      2    1.2       cgd 
      3   1.22  perseant /*-
      4   1.84  perseant  * Copyright (c) 1999, 2000, 2001, 2002, 2003 The NetBSD Foundation, Inc.
      5   1.22  perseant  * All rights reserved.
      6   1.22  perseant  *
      7   1.22  perseant  * This code is derived from software contributed to The NetBSD Foundation
      8   1.22  perseant  * by Konrad E. Schroder <perseant (at) hhhh.org>.
      9   1.22  perseant  *
     10   1.22  perseant  * Redistribution and use in source and binary forms, with or without
     11   1.22  perseant  * modification, are permitted provided that the following conditions
     12   1.22  perseant  * are met:
     13   1.22  perseant  * 1. Redistributions of source code must retain the above copyright
     14   1.22  perseant  *    notice, this list of conditions and the following disclaimer.
     15   1.22  perseant  * 2. Redistributions in binary form must reproduce the above copyright
     16   1.22  perseant  *    notice, this list of conditions and the following disclaimer in the
     17   1.22  perseant  *    documentation and/or other materials provided with the distribution.
     18   1.22  perseant  *
     19   1.22  perseant  * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
     20   1.22  perseant  * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
     21   1.22  perseant  * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
     22   1.22  perseant  * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
     23   1.22  perseant  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
     24   1.22  perseant  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
     25   1.22  perseant  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
     26   1.22  perseant  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
     27   1.22  perseant  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
     28   1.22  perseant  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
     29   1.22  perseant  * POSSIBILITY OF SUCH DAMAGE.
     30   1.22  perseant  */
     31    1.1   mycroft /*
     32   1.15      fvdl  * Copyright (c) 1986, 1989, 1991, 1993, 1995
     33    1.1   mycroft  *	The Regents of the University of California.  All rights reserved.
     34    1.1   mycroft  *
     35    1.1   mycroft  * Redistribution and use in source and binary forms, with or without
     36    1.1   mycroft  * modification, are permitted provided that the following conditions
     37    1.1   mycroft  * are met:
     38    1.1   mycroft  * 1. Redistributions of source code must retain the above copyright
     39    1.1   mycroft  *    notice, this list of conditions and the following disclaimer.
     40    1.1   mycroft  * 2. Redistributions in binary form must reproduce the above copyright
     41    1.1   mycroft  *    notice, this list of conditions and the following disclaimer in the
     42    1.1   mycroft  *    documentation and/or other materials provided with the distribution.
     43  1.114       agc  * 3. Neither the name of the University nor the names of its contributors
     44    1.1   mycroft  *    may be used to endorse or promote products derived from this software
     45    1.1   mycroft  *    without specific prior written permission.
     46    1.1   mycroft  *
     47    1.1   mycroft  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     48    1.1   mycroft  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     49    1.1   mycroft  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     50    1.1   mycroft  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     51    1.1   mycroft  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     52    1.1   mycroft  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     53    1.1   mycroft  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     54    1.1   mycroft  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     55    1.1   mycroft  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     56    1.1   mycroft  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     57    1.1   mycroft  * SUCH DAMAGE.
     58    1.1   mycroft  *
     59   1.15      fvdl  *	@(#)lfs_vnops.c	8.13 (Berkeley) 6/10/95
     60    1.1   mycroft  */
     61   1.58     lukem 
     62  1.265  dholland /*  from NetBSD: ufs_vnops.c,v 1.213 2013/06/08 05:47:02 kardel Exp  */
     63  1.265  dholland /*-
     64  1.265  dholland  * Copyright (c) 2008 The NetBSD Foundation, Inc.
     65  1.265  dholland  * All rights reserved.
     66  1.265  dholland  *
     67  1.265  dholland  * This code is derived from software contributed to The NetBSD Foundation
     68  1.265  dholland  * by Wasabi Systems, Inc.
     69  1.265  dholland  *
     70  1.265  dholland  * Redistribution and use in source and binary forms, with or without
     71  1.265  dholland  * modification, are permitted provided that the following conditions
     72  1.265  dholland  * are met:
     73  1.265  dholland  * 1. Redistributions of source code must retain the above copyright
     74  1.265  dholland  *    notice, this list of conditions and the following disclaimer.
     75  1.265  dholland  * 2. Redistributions in binary form must reproduce the above copyright
     76  1.265  dholland  *    notice, this list of conditions and the following disclaimer in the
     77  1.265  dholland  *    documentation and/or other materials provided with the distribution.
     78  1.265  dholland  *
     79  1.265  dholland  * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
     80  1.265  dholland  * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
     81  1.265  dholland  * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
     82  1.265  dholland  * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
     83  1.265  dholland  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
     84  1.265  dholland  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
     85  1.265  dholland  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
     86  1.265  dholland  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
     87  1.265  dholland  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
     88  1.265  dholland  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
     89  1.265  dholland  * POSSIBILITY OF SUCH DAMAGE.
     90  1.265  dholland  */
     91  1.265  dholland /*
     92  1.265  dholland  * Copyright (c) 1982, 1986, 1989, 1993, 1995
     93  1.265  dholland  *	The Regents of the University of California.  All rights reserved.
     94  1.265  dholland  * (c) UNIX System Laboratories, Inc.
     95  1.265  dholland  * All or some portions of this file are derived from material licensed
     96  1.265  dholland  * to the University of California by American Telephone and Telegraph
     97  1.265  dholland  * Co. or Unix System Laboratories, Inc. and are reproduced herein with
     98  1.265  dholland  * the permission of UNIX System Laboratories, Inc.
     99  1.265  dholland  *
    100  1.265  dholland  * Redistribution and use in source and binary forms, with or without
    101  1.265  dholland  * modification, are permitted provided that the following conditions
    102  1.265  dholland  * are met:
    103  1.265  dholland  * 1. Redistributions of source code must retain the above copyright
    104  1.265  dholland  *    notice, this list of conditions and the following disclaimer.
    105  1.265  dholland  * 2. Redistributions in binary form must reproduce the above copyright
    106  1.265  dholland  *    notice, this list of conditions and the following disclaimer in the
    107  1.265  dholland  *    documentation and/or other materials provided with the distribution.
    108  1.265  dholland  * 3. Neither the name of the University nor the names of its contributors
    109  1.265  dholland  *    may be used to endorse or promote products derived from this software
    110  1.265  dholland  *    without specific prior written permission.
    111  1.265  dholland  *
    112  1.265  dholland  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
    113  1.265  dholland  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
    114  1.265  dholland  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
    115  1.265  dholland  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
    116  1.265  dholland  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
    117  1.265  dholland  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
    118  1.265  dholland  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
    119  1.265  dholland  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
    120  1.265  dholland  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
    121  1.265  dholland  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
    122  1.265  dholland  * SUCH DAMAGE.
    123  1.265  dholland  *
    124  1.265  dholland  *	@(#)ufs_vnops.c	8.28 (Berkeley) 7/31/95
    125  1.265  dholland  */
    126  1.265  dholland 
    127   1.58     lukem #include <sys/cdefs.h>
    128  1.275  dholland __KERNEL_RCSID(0, "$NetBSD: lfs_vnops.c,v 1.275 2015/07/24 06:59:32 dholland Exp $");
    129  1.182    martin 
    130  1.183    martin #ifdef _KERNEL_OPT
    131  1.182    martin #include "opt_compat_netbsd.h"
    132  1.238       chs #include "opt_uvm_page_trkown.h"
    133  1.183    martin #endif
    134   1.17  sommerfe 
    135    1.1   mycroft #include <sys/param.h>
    136    1.1   mycroft #include <sys/systm.h>
    137    1.1   mycroft #include <sys/namei.h>
    138    1.1   mycroft #include <sys/resourcevar.h>
    139    1.1   mycroft #include <sys/kernel.h>
    140    1.1   mycroft #include <sys/file.h>
    141    1.1   mycroft #include <sys/stat.h>
    142    1.1   mycroft #include <sys/buf.h>
    143    1.1   mycroft #include <sys/proc.h>
    144    1.1   mycroft #include <sys/mount.h>
    145    1.1   mycroft #include <sys/vnode.h>
    146   1.19   thorpej #include <sys/pool.h>
    147   1.10  christos #include <sys/signalvar.h>
    148  1.176      elad #include <sys/kauth.h>
    149  1.179  perseant #include <sys/syslog.h>
    150  1.197   hannken #include <sys/fstrans.h>
    151    1.1   mycroft 
    152   1.12   mycroft #include <miscfs/fifofs/fifo.h>
    153   1.12   mycroft #include <miscfs/genfs/genfs.h>
    154    1.1   mycroft #include <miscfs/specfs/specdev.h>
    155    1.1   mycroft 
    156  1.244  dholland #include <ufs/lfs/ulfs_inode.h>
    157  1.244  dholland #include <ufs/lfs/ulfsmount.h>
    158  1.244  dholland #include <ufs/lfs/ulfs_bswap.h>
    159  1.244  dholland #include <ufs/lfs/ulfs_extern.h>
    160    1.1   mycroft 
    161   1.84  perseant #include <uvm/uvm.h>
    162   1.95  perseant #include <uvm/uvm_pmap.h>
    163   1.95  perseant #include <uvm/uvm_stat.h>
    164   1.95  perseant #include <uvm/uvm_pager.h>
    165   1.84  perseant 
    166    1.1   mycroft #include <ufs/lfs/lfs.h>
    167  1.252  dholland #include <ufs/lfs/lfs_kernel.h>
    168    1.1   mycroft #include <ufs/lfs/lfs_extern.h>
    169    1.1   mycroft 
    170   1.91      yamt extern pid_t lfs_writer_daemon;
    171  1.203  perseant int lfs_ignore_lazy_sync = 1;
    172  1.203  perseant 
    173  1.254  dholland static int lfs_openextattr(void *v);
    174  1.254  dholland static int lfs_closeextattr(void *v);
    175  1.254  dholland static int lfs_getextattr(void *v);
    176  1.254  dholland static int lfs_setextattr(void *v);
    177  1.254  dholland static int lfs_listextattr(void *v);
    178  1.254  dholland static int lfs_deleteextattr(void *v);
    179  1.254  dholland 
    180  1.265  dholland /*
    181  1.265  dholland  * A virgin directory (no blushing please).
    182  1.265  dholland  */
    183  1.265  dholland static const struct lfs_dirtemplate mastertemplate = {
    184  1.265  dholland 	0,	12,			LFS_DT_DIR,	1,	".",
    185  1.265  dholland 	0,	LFS_DIRBLKSIZ - 12,	LFS_DT_DIR,	2,	".."
    186  1.265  dholland };
    187  1.265  dholland 
    188    1.1   mycroft /* Global vfs data structures for lfs. */
    189   1.51  perseant int (**lfs_vnodeop_p)(void *);
    190   1.50  jdolecek const struct vnodeopv_entry_desc lfs_vnodeop_entries[] = {
    191    1.1   mycroft 	{ &vop_default_desc, vn_default_error },
    192  1.245  dholland 	{ &vop_lookup_desc, ulfs_lookup },		/* lookup */
    193   1.22  perseant 	{ &vop_create_desc, lfs_create },		/* create */
    194  1.245  dholland 	{ &vop_whiteout_desc, ulfs_whiteout },		/* whiteout */
    195   1.22  perseant 	{ &vop_mknod_desc, lfs_mknod },			/* mknod */
    196  1.245  dholland 	{ &vop_open_desc, ulfs_open },			/* open */
    197    1.1   mycroft 	{ &vop_close_desc, lfs_close },			/* close */
    198  1.245  dholland 	{ &vop_access_desc, ulfs_access },		/* access */
    199    1.1   mycroft 	{ &vop_getattr_desc, lfs_getattr },		/* getattr */
    200   1.61  perseant 	{ &vop_setattr_desc, lfs_setattr },		/* setattr */
    201    1.1   mycroft 	{ &vop_read_desc, lfs_read },			/* read */
    202    1.1   mycroft 	{ &vop_write_desc, lfs_write },			/* write */
    203  1.269  dholland 	{ &vop_fallocate_desc, genfs_eopnotsupp },	/* fallocate */
    204  1.269  dholland 	{ &vop_fdiscard_desc, genfs_eopnotsupp },	/* fdiscard */
    205  1.245  dholland 	{ &vop_ioctl_desc, ulfs_ioctl },		/* ioctl */
    206   1.90  perseant 	{ &vop_fcntl_desc, lfs_fcntl },			/* fcntl */
    207  1.245  dholland 	{ &vop_poll_desc, ulfs_poll },			/* poll */
    208   1.68  jdolecek 	{ &vop_kqfilter_desc, genfs_kqfilter },		/* kqfilter */
    209  1.245  dholland 	{ &vop_revoke_desc, ulfs_revoke },		/* revoke */
    210   1.84  perseant 	{ &vop_mmap_desc, lfs_mmap },			/* mmap */
    211    1.1   mycroft 	{ &vop_fsync_desc, lfs_fsync },			/* fsync */
    212  1.245  dholland 	{ &vop_seek_desc, ulfs_seek },			/* seek */
    213   1.22  perseant 	{ &vop_remove_desc, lfs_remove },		/* remove */
    214   1.22  perseant 	{ &vop_link_desc, lfs_link },			/* link */
    215   1.22  perseant 	{ &vop_rename_desc, lfs_rename },		/* rename */
    216   1.22  perseant 	{ &vop_mkdir_desc, lfs_mkdir },			/* mkdir */
    217   1.22  perseant 	{ &vop_rmdir_desc, lfs_rmdir },			/* rmdir */
    218   1.22  perseant 	{ &vop_symlink_desc, lfs_symlink },		/* symlink */
    219  1.245  dholland 	{ &vop_readdir_desc, ulfs_readdir },		/* readdir */
    220  1.245  dholland 	{ &vop_readlink_desc, ulfs_readlink },		/* readlink */
    221  1.245  dholland 	{ &vop_abortop_desc, ulfs_abortop },		/* abortop */
    222   1.40  perseant 	{ &vop_inactive_desc, lfs_inactive },		/* inactive */
    223    1.1   mycroft 	{ &vop_reclaim_desc, lfs_reclaim },		/* reclaim */
    224  1.245  dholland 	{ &vop_lock_desc, ulfs_lock },			/* lock */
    225  1.245  dholland 	{ &vop_unlock_desc, ulfs_unlock },		/* unlock */
    226  1.245  dholland 	{ &vop_bmap_desc, ulfs_bmap },			/* bmap */
    227   1.94  perseant 	{ &vop_strategy_desc, lfs_strategy },		/* strategy */
    228  1.245  dholland 	{ &vop_print_desc, ulfs_print },		/* print */
    229  1.245  dholland 	{ &vop_islocked_desc, ulfs_islocked },		/* islocked */
    230  1.245  dholland 	{ &vop_pathconf_desc, ulfs_pathconf },		/* pathconf */
    231  1.245  dholland 	{ &vop_advlock_desc, ulfs_advlock },		/* advlock */
    232    1.1   mycroft 	{ &vop_bwrite_desc, lfs_bwrite },		/* bwrite */
    233   1.60       chs 	{ &vop_getpages_desc, lfs_getpages },		/* getpages */
    234   1.60       chs 	{ &vop_putpages_desc, lfs_putpages },		/* putpages */
    235  1.254  dholland 	{ &vop_openextattr_desc, lfs_openextattr },	/* openextattr */
    236  1.254  dholland 	{ &vop_closeextattr_desc, lfs_closeextattr },	/* closeextattr */
    237  1.254  dholland 	{ &vop_getextattr_desc, lfs_getextattr },	/* getextattr */
    238  1.254  dholland 	{ &vop_setextattr_desc, lfs_setextattr },	/* setextattr */
    239  1.254  dholland 	{ &vop_listextattr_desc, lfs_listextattr },	/* listextattr */
    240  1.254  dholland 	{ &vop_deleteextattr_desc, lfs_deleteextattr },	/* deleteextattr */
    241   1.53       chs 	{ NULL, NULL }
    242    1.1   mycroft };
    243   1.50  jdolecek const struct vnodeopv_desc lfs_vnodeop_opv_desc =
    244    1.1   mycroft 	{ &lfs_vnodeop_p, lfs_vnodeop_entries };
    245    1.1   mycroft 
    246   1.51  perseant int (**lfs_specop_p)(void *);
    247   1.50  jdolecek const struct vnodeopv_entry_desc lfs_specop_entries[] = {
    248    1.1   mycroft 	{ &vop_default_desc, vn_default_error },
    249    1.1   mycroft 	{ &vop_lookup_desc, spec_lookup },		/* lookup */
    250    1.1   mycroft 	{ &vop_create_desc, spec_create },		/* create */
    251    1.1   mycroft 	{ &vop_mknod_desc, spec_mknod },		/* mknod */
    252    1.1   mycroft 	{ &vop_open_desc, spec_open },			/* open */
    253   1.65  perseant 	{ &vop_close_desc, lfsspec_close },		/* close */
    254  1.245  dholland 	{ &vop_access_desc, ulfs_access },		/* access */
    255    1.1   mycroft 	{ &vop_getattr_desc, lfs_getattr },		/* getattr */
    256   1.61  perseant 	{ &vop_setattr_desc, lfs_setattr },		/* setattr */
    257  1.245  dholland 	{ &vop_read_desc, ulfsspec_read },		/* read */
    258  1.245  dholland 	{ &vop_write_desc, ulfsspec_write },		/* write */
    259  1.269  dholland 	{ &vop_fallocate_desc, spec_fallocate },	/* fallocate */
    260  1.269  dholland 	{ &vop_fdiscard_desc, spec_fdiscard },		/* fdiscard */
    261    1.1   mycroft 	{ &vop_ioctl_desc, spec_ioctl },		/* ioctl */
    262  1.245  dholland 	{ &vop_fcntl_desc, ulfs_fcntl },		/* fcntl */
    263   1.13   mycroft 	{ &vop_poll_desc, spec_poll },			/* poll */
    264   1.68  jdolecek 	{ &vop_kqfilter_desc, spec_kqfilter },		/* kqfilter */
    265   1.15      fvdl 	{ &vop_revoke_desc, spec_revoke },		/* revoke */
    266    1.1   mycroft 	{ &vop_mmap_desc, spec_mmap },			/* mmap */
    267    1.1   mycroft 	{ &vop_fsync_desc, spec_fsync },		/* fsync */
    268    1.1   mycroft 	{ &vop_seek_desc, spec_seek },			/* seek */
    269    1.1   mycroft 	{ &vop_remove_desc, spec_remove },		/* remove */
    270    1.1   mycroft 	{ &vop_link_desc, spec_link },			/* link */
    271    1.1   mycroft 	{ &vop_rename_desc, spec_rename },		/* rename */
    272    1.1   mycroft 	{ &vop_mkdir_desc, spec_mkdir },		/* mkdir */
    273    1.1   mycroft 	{ &vop_rmdir_desc, spec_rmdir },		/* rmdir */
    274    1.1   mycroft 	{ &vop_symlink_desc, spec_symlink },		/* symlink */
    275    1.1   mycroft 	{ &vop_readdir_desc, spec_readdir },		/* readdir */
    276    1.1   mycroft 	{ &vop_readlink_desc, spec_readlink },		/* readlink */
    277    1.1   mycroft 	{ &vop_abortop_desc, spec_abortop },		/* abortop */
    278   1.40  perseant 	{ &vop_inactive_desc, lfs_inactive },		/* inactive */
    279    1.1   mycroft 	{ &vop_reclaim_desc, lfs_reclaim },		/* reclaim */
    280  1.245  dholland 	{ &vop_lock_desc, ulfs_lock },			/* lock */
    281  1.245  dholland 	{ &vop_unlock_desc, ulfs_unlock },		/* unlock */
    282    1.1   mycroft 	{ &vop_bmap_desc, spec_bmap },			/* bmap */
    283    1.1   mycroft 	{ &vop_strategy_desc, spec_strategy },		/* strategy */
    284  1.245  dholland 	{ &vop_print_desc, ulfs_print },		/* print */
    285  1.245  dholland 	{ &vop_islocked_desc, ulfs_islocked },		/* islocked */
    286    1.1   mycroft 	{ &vop_pathconf_desc, spec_pathconf },		/* pathconf */
    287    1.1   mycroft 	{ &vop_advlock_desc, spec_advlock },		/* advlock */
    288   1.28  perseant 	{ &vop_bwrite_desc, vn_bwrite },		/* bwrite */
    289   1.53       chs 	{ &vop_getpages_desc, spec_getpages },		/* getpages */
    290   1.53       chs 	{ &vop_putpages_desc, spec_putpages },		/* putpages */
    291  1.254  dholland 	{ &vop_openextattr_desc, lfs_openextattr },	/* openextattr */
    292  1.254  dholland 	{ &vop_closeextattr_desc, lfs_closeextattr },	/* closeextattr */
    293  1.254  dholland 	{ &vop_getextattr_desc, lfs_getextattr },	/* getextattr */
    294  1.254  dholland 	{ &vop_setextattr_desc, lfs_setextattr },	/* setextattr */
    295  1.254  dholland 	{ &vop_listextattr_desc, lfs_listextattr },	/* listextattr */
    296  1.254  dholland 	{ &vop_deleteextattr_desc, lfs_deleteextattr },	/* deleteextattr */
    297   1.53       chs 	{ NULL, NULL }
    298    1.1   mycroft };
    299   1.50  jdolecek const struct vnodeopv_desc lfs_specop_opv_desc =
    300    1.1   mycroft 	{ &lfs_specop_p, lfs_specop_entries };
    301    1.1   mycroft 
    302   1.51  perseant int (**lfs_fifoop_p)(void *);
    303   1.50  jdolecek const struct vnodeopv_entry_desc lfs_fifoop_entries[] = {
    304    1.1   mycroft 	{ &vop_default_desc, vn_default_error },
    305  1.227     pooka 	{ &vop_lookup_desc, vn_fifo_bypass },		/* lookup */
    306  1.227     pooka 	{ &vop_create_desc, vn_fifo_bypass },		/* create */
    307  1.227     pooka 	{ &vop_mknod_desc, vn_fifo_bypass },		/* mknod */
    308  1.227     pooka 	{ &vop_open_desc, vn_fifo_bypass },		/* open */
    309   1.65  perseant 	{ &vop_close_desc, lfsfifo_close },		/* close */
    310  1.245  dholland 	{ &vop_access_desc, ulfs_access },		/* access */
    311    1.1   mycroft 	{ &vop_getattr_desc, lfs_getattr },		/* getattr */
    312   1.61  perseant 	{ &vop_setattr_desc, lfs_setattr },		/* setattr */
    313  1.245  dholland 	{ &vop_read_desc, ulfsfifo_read },		/* read */
    314  1.245  dholland 	{ &vop_write_desc, ulfsfifo_write },		/* write */
    315  1.269  dholland 	{ &vop_fallocate_desc, vn_fifo_bypass },	/* fallocate */
    316  1.269  dholland 	{ &vop_fdiscard_desc, vn_fifo_bypass },		/* fdiscard */
    317  1.227     pooka 	{ &vop_ioctl_desc, vn_fifo_bypass },		/* ioctl */
    318  1.245  dholland 	{ &vop_fcntl_desc, ulfs_fcntl },		/* fcntl */
    319  1.227     pooka 	{ &vop_poll_desc, vn_fifo_bypass },		/* poll */
    320  1.227     pooka 	{ &vop_kqfilter_desc, vn_fifo_bypass },		/* kqfilter */
    321  1.227     pooka 	{ &vop_revoke_desc, vn_fifo_bypass },		/* revoke */
    322  1.227     pooka 	{ &vop_mmap_desc, vn_fifo_bypass },		/* mmap */
    323  1.227     pooka 	{ &vop_fsync_desc, vn_fifo_bypass },		/* fsync */
    324  1.227     pooka 	{ &vop_seek_desc, vn_fifo_bypass },		/* seek */
    325  1.227     pooka 	{ &vop_remove_desc, vn_fifo_bypass },		/* remove */
    326  1.227     pooka 	{ &vop_link_desc, vn_fifo_bypass },		/* link */
    327  1.227     pooka 	{ &vop_rename_desc, vn_fifo_bypass },		/* rename */
    328  1.227     pooka 	{ &vop_mkdir_desc, vn_fifo_bypass },		/* mkdir */
    329  1.227     pooka 	{ &vop_rmdir_desc, vn_fifo_bypass },		/* rmdir */
    330  1.227     pooka 	{ &vop_symlink_desc, vn_fifo_bypass },		/* symlink */
    331  1.227     pooka 	{ &vop_readdir_desc, vn_fifo_bypass },		/* readdir */
    332  1.227     pooka 	{ &vop_readlink_desc, vn_fifo_bypass },		/* readlink */
    333  1.227     pooka 	{ &vop_abortop_desc, vn_fifo_bypass },		/* abortop */
    334   1.40  perseant 	{ &vop_inactive_desc, lfs_inactive },		/* inactive */
    335    1.1   mycroft 	{ &vop_reclaim_desc, lfs_reclaim },		/* reclaim */
    336  1.245  dholland 	{ &vop_lock_desc, ulfs_lock },			/* lock */
    337  1.245  dholland 	{ &vop_unlock_desc, ulfs_unlock },		/* unlock */
    338  1.227     pooka 	{ &vop_bmap_desc, vn_fifo_bypass },		/* bmap */
    339  1.227     pooka 	{ &vop_strategy_desc, vn_fifo_bypass },		/* strategy */
    340  1.245  dholland 	{ &vop_print_desc, ulfs_print },		/* print */
    341  1.245  dholland 	{ &vop_islocked_desc, ulfs_islocked },		/* islocked */
    342  1.227     pooka 	{ &vop_pathconf_desc, vn_fifo_bypass },		/* pathconf */
    343  1.227     pooka 	{ &vop_advlock_desc, vn_fifo_bypass },		/* advlock */
    344    1.1   mycroft 	{ &vop_bwrite_desc, lfs_bwrite },		/* bwrite */
    345  1.227     pooka 	{ &vop_putpages_desc, vn_fifo_bypass },		/* putpages */
    346  1.254  dholland 	{ &vop_openextattr_desc, lfs_openextattr },	/* openextattr */
    347  1.254  dholland 	{ &vop_closeextattr_desc, lfs_closeextattr },	/* closeextattr */
    348  1.254  dholland 	{ &vop_getextattr_desc, lfs_getextattr },	/* getextattr */
    349  1.254  dholland 	{ &vop_setextattr_desc, lfs_setextattr },	/* setextattr */
    350  1.254  dholland 	{ &vop_listextattr_desc, lfs_listextattr },	/* listextattr */
    351  1.254  dholland 	{ &vop_deleteextattr_desc, lfs_deleteextattr },	/* deleteextattr */
    352   1.53       chs 	{ NULL, NULL }
    353    1.1   mycroft };
    354   1.50  jdolecek const struct vnodeopv_desc lfs_fifoop_opv_desc =
    355    1.1   mycroft 	{ &lfs_fifoop_p, lfs_fifoop_entries };
    356    1.1   mycroft 
    357    1.1   mycroft #define	LFS_READWRITE
    358  1.244  dholland #include <ufs/lfs/ulfs_readwrite.c>
    359    1.1   mycroft #undef	LFS_READWRITE
    360    1.1   mycroft 
    361    1.1   mycroft /*
    362    1.1   mycroft  * Synch an open file.
    363    1.1   mycroft  */
    364    1.1   mycroft /* ARGSUSED */
    365   1.10  christos int
    366   1.51  perseant lfs_fsync(void *v)
    367   1.10  christos {
    368    1.1   mycroft 	struct vop_fsync_args /* {
    369    1.1   mycroft 		struct vnode *a_vp;
    370  1.176      elad 		kauth_cred_t a_cred;
    371   1.22  perseant 		int a_flags;
    372   1.49    toshii 		off_t offlo;
    373   1.49    toshii 		off_t offhi;
    374   1.10  christos 	} */ *ap = v;
    375   1.60       chs 	struct vnode *vp = ap->a_vp;
    376   1.84  perseant 	int error, wait;
    377  1.203  perseant 	struct inode *ip = VTOI(vp);
    378  1.203  perseant 	struct lfs *fs = ip->i_lfs;
    379   1.84  perseant 
    380  1.161  perseant 	/* If we're mounted read-only, don't try to sync. */
    381  1.203  perseant 	if (fs->lfs_ronly)
    382  1.161  perseant 		return 0;
    383  1.161  perseant 
    384  1.231   hannken 	/* If a removed vnode is being cleaned, no need to sync here. */
    385  1.231   hannken 	if ((ap->a_flags & FSYNC_RECLAIM) != 0 && ip->i_mode == 0)
    386  1.231   hannken 		return 0;
    387  1.231   hannken 
    388   1.86  perseant 	/*
    389  1.203  perseant 	 * Trickle sync simply adds this vnode to the pager list, as if
    390  1.203  perseant 	 * the pagedaemon had requested a pageout.
    391   1.86  perseant 	 */
    392   1.84  perseant 	if (ap->a_flags & FSYNC_LAZY) {
    393  1.203  perseant 		if (lfs_ignore_lazy_sync == 0) {
    394  1.214        ad 			mutex_enter(&lfs_lock);
    395  1.203  perseant 			if (!(ip->i_flags & IN_PAGING)) {
    396  1.203  perseant 				ip->i_flags |= IN_PAGING;
    397  1.203  perseant 				TAILQ_INSERT_TAIL(&fs->lfs_pchainhd, ip,
    398  1.203  perseant 						  i_lfs_pchain);
    399  1.203  perseant 			}
    400  1.203  perseant 			wakeup(&lfs_writer_daemon);
    401  1.214        ad 			mutex_exit(&lfs_lock);
    402  1.203  perseant 		}
    403   1.47  perseant 		return 0;
    404   1.84  perseant 	}
    405   1.47  perseant 
    406  1.175  perseant 	/*
    407  1.188  perseant 	 * If a vnode is bring cleaned, flush it out before we try to
    408  1.188  perseant 	 * reuse it.  This prevents the cleaner from writing files twice
    409  1.188  perseant 	 * in the same partial segment, causing an accounting underflow.
    410  1.188  perseant 	 */
    411  1.203  perseant 	if (ap->a_flags & FSYNC_RECLAIM && ip->i_flags & IN_CLEANING) {
    412  1.188  perseant 		lfs_vflush(vp);
    413  1.175  perseant 	}
    414  1.175  perseant 
    415   1.84  perseant 	wait = (ap->a_flags & FSYNC_WAIT);
    416  1.203  perseant 	do {
    417  1.235     rmind 		mutex_enter(vp->v_interlock);
    418  1.203  perseant 		error = VOP_PUTPAGES(vp, trunc_page(ap->a_offlo),
    419  1.203  perseant 				     round_page(ap->a_offhi),
    420  1.203  perseant 				     PGO_CLEANIT | (wait ? PGO_SYNCIO : 0));
    421  1.205  perseant 		if (error == EAGAIN) {
    422  1.214        ad 			mutex_enter(&lfs_lock);
    423  1.274  dholland 			mtsleep(&fs->lfs_availsleep, PCATCH | PUSER,
    424  1.274  dholland 				"lfs_fsync", hz / 100 + 1, &lfs_lock);
    425  1.214        ad 			mutex_exit(&lfs_lock);
    426  1.205  perseant 		}
    427  1.203  perseant 	} while (error == EAGAIN);
    428  1.103  perseant 	if (error)
    429  1.103  perseant 		return error;
    430  1.203  perseant 
    431  1.203  perseant 	if ((ap->a_flags & FSYNC_DATAONLY) == 0)
    432  1.203  perseant 		error = lfs_update(vp, NULL, NULL, wait ? UPDATE_WAIT : 0);
    433  1.203  perseant 
    434  1.133  wrstuden 	if (error == 0 && ap->a_flags & FSYNC_CACHE) {
    435  1.133  wrstuden 		int l = 0;
    436  1.203  perseant 		error = VOP_IOCTL(ip->i_devvp, DIOCCACHESYNC, &l, FWRITE,
    437  1.213     pooka 				  curlwp->l_cred);
    438  1.133  wrstuden 	}
    439  1.103  perseant 	if (wait && !VPISEMPTY(vp))
    440  1.203  perseant 		LFS_SET_UINO(ip, IN_MODIFIED);
    441   1.84  perseant 
    442   1.63  perseant 	return error;
    443    1.1   mycroft }
    444    1.1   mycroft 
    445    1.1   mycroft /*
    446  1.245  dholland  * Take IN_ADIROP off, then call ulfs_inactive.
    447   1.40  perseant  */
    448   1.40  perseant int
    449   1.51  perseant lfs_inactive(void *v)
    450   1.40  perseant {
    451   1.40  perseant 	struct vop_inactive_args /* {
    452   1.40  perseant 		struct vnode *a_vp;
    453   1.40  perseant 	} */ *ap = v;
    454   1.72      yamt 
    455   1.76      yamt 	lfs_unmark_vnode(ap->a_vp);
    456   1.76      yamt 
    457   1.97  perseant 	/*
    458   1.97  perseant 	 * The Ifile is only ever inactivated on unmount.
    459   1.97  perseant 	 * Streamline this process by not giving it more dirty blocks.
    460   1.97  perseant 	 */
    461   1.97  perseant 	if (VTOI(ap->a_vp)->i_number == LFS_IFILE_INUM) {
    462  1.214        ad 		mutex_enter(&lfs_lock);
    463   1.97  perseant 		LFS_CLR_UINO(VTOI(ap->a_vp), IN_ALLMOD);
    464  1.214        ad 		mutex_exit(&lfs_lock);
    465  1.229   hannken 		VOP_UNLOCK(ap->a_vp);
    466   1.97  perseant 		return 0;
    467   1.97  perseant 	}
    468   1.97  perseant 
    469  1.239  perseant #ifdef DEBUG
    470  1.239  perseant 	/*
    471  1.239  perseant 	 * This might happen on unmount.
    472  1.239  perseant 	 * XXX If it happens at any other time, it should be a panic.
    473  1.239  perseant 	 */
    474  1.239  perseant 	if (ap->a_vp->v_uflag & VU_DIROP) {
    475  1.239  perseant 		struct inode *ip = VTOI(ap->a_vp);
    476  1.239  perseant 		printf("lfs_inactive: inactivating VU_DIROP? ino = %d\n", (int)ip->i_number);
    477  1.239  perseant 	}
    478  1.239  perseant #endif /* DIAGNOSTIC */
    479  1.239  perseant 
    480  1.245  dholland 	return ulfs_inactive(v);
    481   1.40  perseant }
    482   1.40  perseant 
    483  1.249  dholland int
    484  1.138  perseant lfs_set_dirop(struct vnode *dvp, struct vnode *vp)
    485   1.40  perseant {
    486   1.24  perseant 	struct lfs *fs;
    487   1.24  perseant 	int error;
    488   1.24  perseant 
    489  1.138  perseant 	KASSERT(VOP_ISLOCKED(dvp));
    490  1.138  perseant 	KASSERT(vp == NULL || VOP_ISLOCKED(vp));
    491   1.71      yamt 
    492  1.138  perseant 	fs = VTOI(dvp)->i_lfs;
    493  1.141  perseant 
    494  1.141  perseant 	ASSERT_NO_SEGLOCK(fs);
    495   1.44  perseant 	/*
    496  1.134  perseant 	 * LFS_NRESERVE calculates direct and indirect blocks as well
    497  1.134  perseant 	 * as an inode block; an overestimate in most cases.
    498   1.44  perseant 	 */
    499  1.138  perseant 	if ((error = lfs_reserve(fs, dvp, vp, LFS_NRESERVE(fs))) != 0)
    500   1.44  perseant 		return (error);
    501   1.70      yamt 
    502  1.214        ad     restart:
    503  1.214        ad 	mutex_enter(&lfs_lock);
    504  1.141  perseant 	if (fs->lfs_dirops == 0) {
    505  1.214        ad 		mutex_exit(&lfs_lock);
    506  1.138  perseant 		lfs_check(dvp, LFS_UNUSED_LBN, 0);
    507  1.214        ad 		mutex_enter(&lfs_lock);
    508  1.113      yamt 	}
    509  1.190  perseant 	while (fs->lfs_writer) {
    510  1.214        ad 		error = mtsleep(&fs->lfs_dirops, (PRIBIO + 1) | PCATCH,
    511  1.214        ad 		    "lfs_sdirop", 0, &lfs_lock);
    512  1.190  perseant 		if (error == EINTR) {
    513  1.214        ad 			mutex_exit(&lfs_lock);
    514  1.190  perseant 			goto unreserve;
    515  1.190  perseant 		}
    516  1.190  perseant 	}
    517  1.113      yamt 	if (lfs_dirvcount > LFS_MAX_DIROP && fs->lfs_dirops == 0) {
    518  1.113      yamt 		wakeup(&lfs_writer_daemon);
    519  1.214        ad 		mutex_exit(&lfs_lock);
    520  1.198        ad 		preempt();
    521  1.113      yamt 		goto restart;
    522  1.113      yamt 	}
    523   1.33  perseant 
    524  1.113      yamt 	if (lfs_dirvcount > LFS_MAX_DIROP) {
    525  1.136  perseant 		DLOG((DLOG_DIROP, "lfs_set_dirop: sleeping with dirops=%d, "
    526  1.136  perseant 		      "dirvcount=%d\n", fs->lfs_dirops, lfs_dirvcount));
    527  1.214        ad 		if ((error = mtsleep(&lfs_dirvcount,
    528  1.214        ad 		    PCATCH | PUSER | PNORELOCK, "lfs_maxdirop", 0,
    529  1.214        ad 		    &lfs_lock)) != 0) {
    530  1.113      yamt 			goto unreserve;
    531  1.113      yamt 		}
    532  1.113      yamt 		goto restart;
    533  1.135     perry 	}
    534  1.113      yamt 
    535  1.135     perry 	++fs->lfs_dirops;
    536  1.239  perseant 	/* fs->lfs_doifile = 1; */ /* XXX why? --ks */
    537  1.214        ad 	mutex_exit(&lfs_lock);
    538   1.24  perseant 
    539   1.46  perseant 	/* Hold a reference so SET_ENDOP will be happy */
    540  1.138  perseant 	vref(dvp);
    541  1.138  perseant 	if (vp) {
    542  1.138  perseant 		vref(vp);
    543  1.138  perseant 		MARK_VNODE(vp);
    544  1.138  perseant 	}
    545   1.46  perseant 
    546  1.138  perseant 	MARK_VNODE(dvp);
    547   1.24  perseant 	return 0;
    548   1.70      yamt 
    549  1.203  perseant   unreserve:
    550  1.138  perseant 	lfs_reserve(fs, dvp, vp, -LFS_NRESERVE(fs));
    551   1.70      yamt 	return error;
    552    1.1   mycroft }
    553    1.1   mycroft 
    554  1.138  perseant /*
    555  1.264  dholland  * Opposite of lfs_set_dirop... mostly. For now at least must call
    556  1.264  dholland  * UNMARK_VNODE(dvp) explicitly first. (XXX: clean that up)
    557  1.138  perseant  */
    558  1.264  dholland void
    559  1.264  dholland lfs_unset_dirop(struct lfs *fs, struct vnode *dvp, const char *str)
    560  1.138  perseant {
    561  1.264  dholland 	mutex_enter(&lfs_lock);
    562  1.264  dholland 	--fs->lfs_dirops;
    563  1.264  dholland 	if (!fs->lfs_dirops) {
    564  1.264  dholland 		if (fs->lfs_nadirop) {
    565  1.264  dholland 			panic("lfs_unset_dirop: %s: no dirops but "
    566  1.264  dholland 			      " nadirop=%d", str,
    567  1.264  dholland 			      fs->lfs_nadirop);
    568  1.264  dholland 		}
    569  1.264  dholland 		wakeup(&fs->lfs_writer);
    570  1.264  dholland 		mutex_exit(&lfs_lock);
    571  1.264  dholland 		lfs_check(dvp, LFS_UNUSED_LBN, 0);
    572  1.264  dholland 	} else {
    573  1.264  dholland 		mutex_exit(&lfs_lock);
    574  1.138  perseant 	}
    575  1.264  dholland 	lfs_reserve(fs, dvp, NULL, -LFS_NRESERVE(fs));
    576    1.1   mycroft }
    577    1.1   mycroft 
    578  1.117      yamt void
    579  1.117      yamt lfs_mark_vnode(struct vnode *vp)
    580  1.117      yamt {
    581  1.117      yamt 	struct inode *ip = VTOI(vp);
    582  1.117      yamt 	struct lfs *fs = ip->i_lfs;
    583   1.37  perseant 
    584  1.214        ad 	mutex_enter(&lfs_lock);
    585  1.117      yamt 	if (!(ip->i_flag & IN_ADIROP)) {
    586  1.212        ad 		if (!(vp->v_uflag & VU_DIROP)) {
    587  1.240  perseant 			mutex_exit(&lfs_lock);
    588  1.272   hannken 			vref(vp);
    589  1.240  perseant 			mutex_enter(&lfs_lock);
    590  1.117      yamt 			++lfs_dirvcount;
    591  1.173  perseant 			++fs->lfs_dirvcount;
    592  1.117      yamt 			TAILQ_INSERT_TAIL(&fs->lfs_dchainhd, ip, i_lfs_dchain);
    593  1.212        ad 			vp->v_uflag |= VU_DIROP;
    594  1.117      yamt 		}
    595  1.117      yamt 		++fs->lfs_nadirop;
    596  1.239  perseant 		ip->i_flag &= ~IN_CDIROP;
    597  1.117      yamt 		ip->i_flag |= IN_ADIROP;
    598  1.117      yamt 	} else
    599  1.212        ad 		KASSERT(vp->v_uflag & VU_DIROP);
    600  1.214        ad 	mutex_exit(&lfs_lock);
    601  1.117      yamt }
    602   1.40  perseant 
    603  1.117      yamt void
    604  1.117      yamt lfs_unmark_vnode(struct vnode *vp)
    605   1.40  perseant {
    606  1.117      yamt 	struct inode *ip = VTOI(vp);
    607   1.40  perseant 
    608  1.240  perseant 	mutex_enter(&lfs_lock);
    609  1.146  perseant 	if (ip && (ip->i_flag & IN_ADIROP)) {
    610  1.212        ad 		KASSERT(vp->v_uflag & VU_DIROP);
    611   1.40  perseant 		--ip->i_lfs->lfs_nadirop;
    612  1.117      yamt 		ip->i_flag &= ~IN_ADIROP;
    613  1.117      yamt 	}
    614  1.240  perseant 	mutex_exit(&lfs_lock);
    615   1.40  perseant }
    616   1.15      fvdl 
    617    1.1   mycroft int
    618   1.51  perseant lfs_symlink(void *v)
    619   1.10  christos {
    620  1.261   hannken 	struct vop_symlink_v3_args /* {
    621    1.1   mycroft 		struct vnode *a_dvp;
    622    1.1   mycroft 		struct vnode **a_vpp;
    623    1.1   mycroft 		struct componentname *a_cnp;
    624    1.1   mycroft 		struct vattr *a_vap;
    625    1.1   mycroft 		char *a_target;
    626   1.10  christos 	} */ *ap = v;
    627  1.264  dholland 	struct lfs *fs;
    628  1.264  dholland 	struct vnode *dvp, **vpp;
    629  1.266  dholland 	struct inode *ip;
    630  1.266  dholland 	struct ulfs_lookup_results *ulr;
    631  1.266  dholland 	ssize_t len; /* XXX should be size_t */
    632   1.37  perseant 	int error;
    633    1.1   mycroft 
    634  1.264  dholland 	dvp = ap->a_dvp;
    635  1.264  dholland 	vpp = ap->a_vpp;
    636  1.264  dholland 
    637  1.264  dholland 	KASSERT(vpp != NULL);
    638  1.264  dholland 	KASSERT(*vpp == NULL);
    639  1.272   hannken 	KASSERT(ap->a_vap->va_type == VLNK);
    640  1.264  dholland 
    641  1.266  dholland 	/* XXX should handle this material another way */
    642  1.266  dholland 	ulr = &VTOI(ap->a_dvp)->i_crap;
    643  1.266  dholland 	ULFS_CHECK_CRAPCOUNTER(VTOI(ap->a_dvp));
    644  1.266  dholland 
    645  1.264  dholland 	fs = VFSTOULFS(dvp->v_mount)->um_lfs;
    646  1.264  dholland 	ASSERT_NO_SEGLOCK(fs);
    647  1.264  dholland 	if (fs->lfs_ronly) {
    648  1.264  dholland 		return EROFS;
    649  1.264  dholland 	}
    650  1.264  dholland 
    651  1.264  dholland 	error = lfs_set_dirop(dvp, NULL);
    652  1.272   hannken 	if (error)
    653   1.37  perseant 		return error;
    654  1.264  dholland 
    655  1.266  dholland 	fstrans_start(dvp->v_mount, FSTRANS_SHARED);
    656  1.272   hannken 	error = ulfs_makeinode(ap->a_vap, dvp, ulr, vpp, ap->a_cnp);
    657  1.266  dholland 	if (error) {
    658  1.266  dholland 		goto out;
    659  1.266  dholland 	}
    660  1.266  dholland 
    661  1.266  dholland 	VN_KNOTE(ap->a_dvp, NOTE_WRITE);
    662  1.266  dholland 	ip = VTOI(*vpp);
    663  1.266  dholland 
    664  1.266  dholland 	len = strlen(ap->a_target);
    665  1.266  dholland 	if (len < ip->i_lfs->um_maxsymlinklen) {
    666  1.266  dholland 		memcpy((char *)SHORTLINK(ip), ap->a_target, len);
    667  1.266  dholland 		ip->i_size = len;
    668  1.266  dholland 		DIP_ASSIGN(ip, size, len);
    669  1.266  dholland 		uvm_vnp_setsize(*vpp, ip->i_size);
    670  1.266  dholland 		ip->i_flag |= IN_CHANGE | IN_UPDATE;
    671  1.266  dholland 		if ((*vpp)->v_mount->mnt_flag & MNT_RELATIME)
    672  1.266  dholland 			ip->i_flag |= IN_ACCESS;
    673  1.266  dholland 	} else {
    674  1.270  riastrad 		error = ulfs_bufio(UIO_WRITE, *vpp, ap->a_target, len, (off_t)0,
    675  1.270  riastrad 		    IO_NODELOCKED | IO_JOURNALLOCKED, ap->a_cnp->cn_cred, NULL,
    676  1.270  riastrad 		    NULL);
    677  1.266  dholland 	}
    678  1.266  dholland 
    679  1.266  dholland 	VOP_UNLOCK(*vpp);
    680  1.266  dholland 	if (error)
    681  1.266  dholland 		vrele(*vpp);
    682  1.266  dholland 
    683  1.266  dholland out:
    684  1.266  dholland 	fstrans_done(dvp->v_mount);
    685  1.264  dholland 
    686  1.264  dholland 	UNMARK_VNODE(dvp);
    687  1.264  dholland 	/* XXX: is it even possible for the symlink to get MARK'd? */
    688  1.264  dholland 	UNMARK_VNODE(*vpp);
    689  1.264  dholland 	if (!((*vpp)->v_uflag & VU_DIROP)) {
    690  1.264  dholland 		KASSERT(error != 0);
    691  1.264  dholland 		*vpp = NULL;
    692  1.264  dholland 	}
    693  1.264  dholland 	else {
    694  1.264  dholland 		KASSERT(error == 0);
    695  1.264  dholland 	}
    696  1.264  dholland 	lfs_unset_dirop(fs, dvp, "symlink");
    697  1.264  dholland 
    698  1.264  dholland 	vrele(dvp);
    699   1.37  perseant 	return (error);
    700    1.1   mycroft }
    701    1.1   mycroft 
    702    1.1   mycroft int
    703   1.51  perseant lfs_mknod(void *v)
    704   1.10  christos {
    705  1.261   hannken 	struct vop_mknod_v3_args	/* {
    706    1.1   mycroft 		struct vnode *a_dvp;
    707    1.1   mycroft 		struct vnode **a_vpp;
    708    1.1   mycroft 		struct componentname *a_cnp;
    709    1.1   mycroft 		struct vattr *a_vap;
    710  1.203  perseant 	} */ *ap = v;
    711  1.264  dholland 	struct lfs *fs;
    712  1.264  dholland 	struct vnode *dvp, **vpp;
    713  1.250  dholland 	struct vattr *vap;
    714   1.86  perseant 	struct inode *ip;
    715   1.86  perseant 	int error;
    716   1.52     assar 	ino_t		ino;
    717  1.245  dholland 	struct ulfs_lookup_results *ulr;
    718  1.237  dholland 
    719  1.264  dholland 	dvp = ap->a_dvp;
    720  1.264  dholland 	vpp = ap->a_vpp;
    721  1.250  dholland 	vap = ap->a_vap;
    722  1.250  dholland 
    723  1.264  dholland 	KASSERT(vpp != NULL);
    724  1.264  dholland 	KASSERT(*vpp == NULL);
    725  1.264  dholland 
    726  1.237  dholland 	/* XXX should handle this material another way */
    727  1.264  dholland 	ulr = &VTOI(dvp)->i_crap;
    728  1.264  dholland 	ULFS_CHECK_CRAPCOUNTER(VTOI(dvp));
    729  1.264  dholland 
    730  1.264  dholland 	fs = VFSTOULFS(dvp->v_mount)->um_lfs;
    731  1.264  dholland 	ASSERT_NO_SEGLOCK(fs);
    732  1.264  dholland 	if (fs->lfs_ronly) {
    733  1.264  dholland 		return EROFS;
    734  1.264  dholland 	}
    735  1.264  dholland 
    736  1.264  dholland 	error = lfs_set_dirop(dvp, NULL);
    737  1.272   hannken 	if (error)
    738   1.28  perseant 		return error;
    739  1.250  dholland 
    740  1.250  dholland 	fstrans_start(ap->a_dvp->v_mount, FSTRANS_SHARED);
    741  1.272   hannken 	error = ulfs_makeinode(vap, dvp, ulr, vpp, ap->a_cnp);
    742   1.28  perseant 
    743   1.28  perseant 	/* Either way we're done with the dirop at this point */
    744  1.264  dholland 	UNMARK_VNODE(dvp);
    745  1.264  dholland 	UNMARK_VNODE(*vpp);
    746  1.264  dholland 	if (!((*vpp)->v_uflag & VU_DIROP)) {
    747  1.264  dholland 		KASSERT(error != 0);
    748  1.264  dholland 		*vpp = NULL;
    749  1.264  dholland 	}
    750  1.264  dholland 	else {
    751  1.264  dholland 		KASSERT(error == 0);
    752  1.264  dholland 	}
    753  1.264  dholland 	lfs_unset_dirop(fs, dvp, "mknod");
    754  1.264  dholland 	/*
    755  1.264  dholland 	 * XXX this is where this used to be (though inside some evil
    756  1.264  dholland 	 * macros) but it clearly should be moved further down.
    757  1.264  dholland 	 * - dholland 20140515
    758  1.264  dholland 	 */
    759  1.264  dholland 	vrele(dvp);
    760   1.28  perseant 
    761  1.250  dholland 	if (error) {
    762  1.250  dholland 		fstrans_done(ap->a_dvp->v_mount);
    763  1.250  dholland 		*vpp = NULL;
    764   1.28  perseant 		return (error);
    765  1.250  dholland 	}
    766   1.28  perseant 
    767  1.264  dholland 	VN_KNOTE(dvp, NOTE_WRITE);
    768   1.86  perseant 	ip = VTOI(*vpp);
    769   1.52     assar 	ino = ip->i_number;
    770   1.86  perseant 	ip->i_flag |= IN_ACCESS | IN_CHANGE | IN_UPDATE;
    771  1.134  perseant 
    772   1.28  perseant 	/*
    773   1.28  perseant 	 * Call fsync to write the vnode so that we don't have to deal with
    774  1.262   hannken 	 * flushing it when it's marked VU_DIROP or reclaiming.
    775   1.28  perseant 	 *
    776   1.28  perseant 	 * XXX KS - If we can't flush we also can't call vgone(), so must
    777   1.28  perseant 	 * return.  But, that leaves this vnode in limbo, also not good.
    778   1.28  perseant 	 * Can this ever happen (barring hardware failure)?
    779   1.28  perseant 	 */
    780  1.213     pooka 	if ((error = VOP_FSYNC(*vpp, NOCRED, FSYNC_WAIT, 0, 0)) != 0) {
    781  1.153  christos 		panic("lfs_mknod: couldn't fsync (ino %llu)",
    782  1.203  perseant 		      (unsigned long long)ino);
    783  1.136  perseant 		/* return (error); */
    784   1.40  perseant 	}
    785  1.134  perseant 
    786  1.250  dholland 	fstrans_done(ap->a_dvp->v_mount);
    787  1.273   hannken 	KASSERT(error == 0);
    788  1.261   hannken 	VOP_UNLOCK(*vpp);
    789   1.86  perseant 	return (0);
    790    1.1   mycroft }
    791    1.1   mycroft 
    792  1.265  dholland /*
    793  1.265  dholland  * Create a regular file
    794  1.265  dholland  */
    795  1.265  dholland int
    796   1.51  perseant lfs_create(void *v)
    797   1.10  christos {
    798  1.261   hannken 	struct vop_create_v3_args	/* {
    799    1.1   mycroft 		struct vnode *a_dvp;
    800    1.1   mycroft 		struct vnode **a_vpp;
    801    1.1   mycroft 		struct componentname *a_cnp;
    802    1.1   mycroft 		struct vattr *a_vap;
    803   1.10  christos 	} */ *ap = v;
    804  1.264  dholland 	struct lfs *fs;
    805  1.264  dholland 	struct vnode *dvp, **vpp;
    806  1.268  dholland 	struct vattr *vap;
    807  1.268  dholland 	struct ulfs_lookup_results *ulr;
    808   1.37  perseant 	int error;
    809    1.1   mycroft 
    810  1.264  dholland 	dvp = ap->a_dvp;
    811  1.264  dholland 	vpp = ap->a_vpp;
    812  1.268  dholland 	vap = ap->a_vap;
    813  1.264  dholland 
    814  1.264  dholland 	KASSERT(vpp != NULL);
    815  1.264  dholland 	KASSERT(*vpp == NULL);
    816  1.264  dholland 
    817  1.268  dholland 	/* XXX should handle this material another way */
    818  1.268  dholland 	ulr = &VTOI(dvp)->i_crap;
    819  1.268  dholland 	ULFS_CHECK_CRAPCOUNTER(VTOI(dvp));
    820  1.268  dholland 
    821  1.264  dholland 	fs = VFSTOULFS(dvp->v_mount)->um_lfs;
    822  1.264  dholland 	ASSERT_NO_SEGLOCK(fs);
    823  1.264  dholland 	if (fs->lfs_ronly) {
    824  1.264  dholland 		return EROFS;
    825  1.264  dholland 	}
    826  1.264  dholland 
    827  1.264  dholland 	error = lfs_set_dirop(dvp, NULL);
    828  1.272   hannken 	if (error)
    829   1.37  perseant 		return error;
    830  1.264  dholland 
    831  1.268  dholland 	fstrans_start(dvp->v_mount, FSTRANS_SHARED);
    832  1.272   hannken 	error = ulfs_makeinode(vap, dvp, ulr, vpp, ap->a_cnp);
    833  1.268  dholland 	if (error) {
    834  1.268  dholland 		fstrans_done(dvp->v_mount);
    835  1.268  dholland 		goto out;
    836  1.268  dholland 	}
    837  1.268  dholland 	fstrans_done(dvp->v_mount);
    838  1.268  dholland 	VN_KNOTE(dvp, NOTE_WRITE);
    839  1.268  dholland 	VOP_UNLOCK(*vpp);
    840  1.268  dholland 
    841  1.268  dholland out:
    842  1.264  dholland 
    843  1.264  dholland 	UNMARK_VNODE(dvp);
    844  1.264  dholland 	UNMARK_VNODE(*vpp);
    845  1.264  dholland 	if (!((*vpp)->v_uflag & VU_DIROP)) {
    846  1.264  dholland 		KASSERT(error != 0);
    847  1.264  dholland 		*vpp = NULL;
    848  1.264  dholland 	}
    849  1.264  dholland 	else {
    850  1.264  dholland 		KASSERT(error == 0);
    851  1.264  dholland 	}
    852  1.264  dholland 	lfs_unset_dirop(fs, dvp, "create");
    853  1.264  dholland 
    854  1.264  dholland 	vrele(dvp);
    855   1.37  perseant 	return (error);
    856   1.22  perseant }
    857   1.22  perseant 
    858   1.22  perseant int
    859  1.267  dholland lfs_mkdir(void *v)
    860  1.265  dholland {
    861  1.267  dholland 	struct vop_mkdir_v3_args	/* {
    862  1.267  dholland 		struct vnode *a_dvp;
    863  1.267  dholland 		struct vnode **a_vpp;
    864  1.267  dholland 		struct componentname *a_cnp;
    865  1.267  dholland 		struct vattr *a_vap;
    866  1.265  dholland 	} */ *ap = v;
    867  1.267  dholland 	struct lfs *fs;
    868  1.267  dholland 	struct vnode *dvp, *tvp, **vpp;
    869  1.267  dholland 	struct inode *dp, *ip;
    870  1.267  dholland 	struct componentname *cnp;
    871  1.267  dholland 	struct vattr *vap;
    872  1.265  dholland 	struct ulfs_lookup_results *ulr;
    873  1.267  dholland 	struct buf *bp;
    874  1.267  dholland 	struct lfs_dirtemplate dirtemplate;
    875  1.267  dholland 	struct lfs_direct *newdir;
    876  1.267  dholland 	int dirblksiz;
    877  1.267  dholland 	int error;
    878  1.265  dholland 
    879  1.267  dholland 	dvp = ap->a_dvp;
    880  1.267  dholland 	tvp = NULL;
    881  1.267  dholland 	vpp = ap->a_vpp;
    882  1.267  dholland 	cnp = ap->a_cnp;
    883  1.267  dholland 	vap = ap->a_vap;
    884  1.267  dholland 
    885  1.267  dholland 	dp = VTOI(dvp);
    886  1.267  dholland 	ip = NULL;
    887  1.267  dholland 
    888  1.272   hannken 	KASSERT(vap->va_type == VDIR);
    889  1.267  dholland 	KASSERT(vpp != NULL);
    890  1.267  dholland 	KASSERT(*vpp == NULL);
    891  1.265  dholland 
    892  1.265  dholland 	/* XXX should handle this material another way */
    893  1.265  dholland 	ulr = &dp->i_crap;
    894  1.265  dholland 	ULFS_CHECK_CRAPCOUNTER(dp);
    895  1.265  dholland 
    896  1.267  dholland 	fs = VFSTOULFS(dvp->v_mount)->um_lfs;
    897  1.267  dholland 	ASSERT_NO_SEGLOCK(fs);
    898  1.267  dholland 	if (fs->lfs_ronly) {
    899  1.267  dholland 		return EROFS;
    900  1.267  dholland 	}
    901  1.267  dholland 	dirblksiz = fs->um_dirblksiz;
    902  1.267  dholland 
    903  1.267  dholland 	error = lfs_set_dirop(dvp, NULL);
    904  1.272   hannken 	if (error)
    905  1.267  dholland 		return error;
    906  1.267  dholland 
    907  1.267  dholland 	fstrans_start(dvp->v_mount, FSTRANS_SHARED);
    908  1.267  dholland 
    909  1.265  dholland 	if ((nlink_t)dp->i_nlink >= LINK_MAX) {
    910  1.265  dholland 		error = EMLINK;
    911  1.265  dholland 		goto out;
    912  1.265  dholland 	}
    913  1.267  dholland 
    914  1.265  dholland 	/*
    915  1.265  dholland 	 * Must simulate part of ulfs_makeinode here to acquire the inode,
    916  1.265  dholland 	 * but not have it entered in the parent directory. The entry is
    917  1.265  dholland 	 * made later after writing "." and ".." entries.
    918  1.265  dholland 	 */
    919  1.272   hannken 	error = vcache_new(dvp->v_mount, dvp, vap, cnp->cn_cred, ap->a_vpp);
    920  1.272   hannken 	if (error)
    921  1.272   hannken 		goto out;
    922  1.272   hannken 
    923  1.272   hannken 	error = vn_lock(*ap->a_vpp, LK_EXCLUSIVE);
    924  1.272   hannken 	if (error) {
    925  1.272   hannken 		vrele(*ap->a_vpp);
    926  1.272   hannken 		*ap->a_vpp = NULL;
    927  1.265  dholland 		goto out;
    928  1.272   hannken 	}
    929  1.265  dholland 
    930  1.272   hannken 	tvp = *ap->a_vpp;
    931  1.272   hannken 	lfs_mark_vnode(tvp);
    932  1.265  dholland 	ip = VTOI(tvp);
    933  1.265  dholland 	ip->i_flag |= IN_ACCESS | IN_CHANGE | IN_UPDATE;
    934  1.265  dholland 	ip->i_nlink = 2;
    935  1.265  dholland 	DIP_ASSIGN(ip, nlink, 2);
    936  1.265  dholland 	if (cnp->cn_flags & ISWHITEOUT) {
    937  1.265  dholland 		ip->i_flags |= UF_OPAQUE;
    938  1.265  dholland 		DIP_ASSIGN(ip, flags, ip->i_flags);
    939  1.265  dholland 	}
    940  1.265  dholland 
    941  1.265  dholland 	/*
    942  1.265  dholland 	 * Bump link count in parent directory to reflect work done below.
    943  1.265  dholland 	 */
    944  1.265  dholland 	dp->i_nlink++;
    945  1.265  dholland 	DIP_ASSIGN(dp, nlink, dp->i_nlink);
    946  1.265  dholland 	dp->i_flag |= IN_CHANGE;
    947  1.265  dholland 	if ((error = lfs_update(dvp, NULL, NULL, UPDATE_DIROP)) != 0)
    948  1.265  dholland 		goto bad;
    949  1.265  dholland 
    950  1.265  dholland 	/*
    951  1.265  dholland 	 * Initialize directory with "." and ".." from static template.
    952  1.265  dholland 	 */
    953  1.265  dholland 	dirtemplate = mastertemplate;
    954  1.265  dholland 	dirtemplate.dotdot_reclen = dirblksiz - dirtemplate.dot_reclen;
    955  1.265  dholland 	dirtemplate.dot_ino = ulfs_rw32(ip->i_number, ULFS_MPNEEDSWAP(fs));
    956  1.265  dholland 	dirtemplate.dotdot_ino = ulfs_rw32(dp->i_number, ULFS_MPNEEDSWAP(fs));
    957  1.265  dholland 	dirtemplate.dot_reclen = ulfs_rw16(dirtemplate.dot_reclen,
    958  1.265  dholland 	    ULFS_MPNEEDSWAP(fs));
    959  1.265  dholland 	dirtemplate.dotdot_reclen = ulfs_rw16(dirtemplate.dotdot_reclen,
    960  1.265  dholland 	    ULFS_MPNEEDSWAP(fs));
    961  1.265  dholland 	if (fs->um_maxsymlinklen <= 0) {
    962  1.265  dholland #if BYTE_ORDER == LITTLE_ENDIAN
    963  1.265  dholland 		if (ULFS_MPNEEDSWAP(fs) == 0)
    964  1.265  dholland #else
    965  1.265  dholland 		if (ULFS_MPNEEDSWAP(fs) != 0)
    966  1.265  dholland #endif
    967  1.265  dholland 		{
    968  1.265  dholland 			dirtemplate.dot_type = dirtemplate.dot_namlen;
    969  1.265  dholland 			dirtemplate.dotdot_type = dirtemplate.dotdot_namlen;
    970  1.265  dholland 			dirtemplate.dot_namlen = dirtemplate.dotdot_namlen = 0;
    971  1.265  dholland 		} else
    972  1.265  dholland 			dirtemplate.dot_type = dirtemplate.dotdot_type = 0;
    973  1.265  dholland 	}
    974  1.265  dholland 	if ((error = lfs_balloc(tvp, (off_t)0, dirblksiz, cnp->cn_cred,
    975  1.265  dholland 	    B_CLRBUF, &bp)) != 0)
    976  1.265  dholland 		goto bad;
    977  1.265  dholland 	ip->i_size = dirblksiz;
    978  1.265  dholland 	DIP_ASSIGN(ip, size, dirblksiz);
    979  1.265  dholland 	ip->i_flag |= IN_ACCESS | IN_CHANGE | IN_UPDATE;
    980  1.265  dholland 	uvm_vnp_setsize(tvp, ip->i_size);
    981  1.265  dholland 	memcpy((void *)bp->b_data, (void *)&dirtemplate, sizeof dirtemplate);
    982  1.265  dholland 
    983  1.265  dholland 	/*
    984  1.267  dholland 	 * Directory set up; now install its entry in the parent directory.
    985  1.265  dholland 	 */
    986  1.265  dholland 	if ((error = VOP_BWRITE(bp->b_vp, bp)) != 0)
    987  1.265  dholland 		goto bad;
    988  1.265  dholland 	if ((error = lfs_update(tvp, NULL, NULL, UPDATE_DIROP)) != 0) {
    989  1.265  dholland 		goto bad;
    990  1.265  dholland 	}
    991  1.265  dholland 	newdir = pool_cache_get(ulfs_direct_cache, PR_WAITOK);
    992  1.265  dholland 	ulfs_makedirentry(ip, cnp, newdir);
    993  1.265  dholland 	error = ulfs_direnter(dvp, ulr, tvp, newdir, cnp, bp);
    994  1.265  dholland 	pool_cache_put(ulfs_direct_cache, newdir);
    995  1.265  dholland  bad:
    996  1.265  dholland 	if (error == 0) {
    997  1.265  dholland 		VN_KNOTE(dvp, NOTE_WRITE | NOTE_LINK);
    998  1.265  dholland 		VOP_UNLOCK(tvp);
    999  1.265  dholland 	} else {
   1000  1.265  dholland 		dp->i_nlink--;
   1001  1.265  dholland 		DIP_ASSIGN(dp, nlink, dp->i_nlink);
   1002  1.265  dholland 		dp->i_flag |= IN_CHANGE;
   1003  1.265  dholland 		/*
   1004  1.265  dholland 		 * No need to do an explicit lfs_truncate here, vrele will
   1005  1.265  dholland 		 * do this for us because we set the link count to 0.
   1006  1.265  dholland 		 */
   1007  1.265  dholland 		ip->i_nlink = 0;
   1008  1.265  dholland 		DIP_ASSIGN(ip, nlink, 0);
   1009  1.265  dholland 		ip->i_flag |= IN_CHANGE;
   1010  1.265  dholland 		/* If IN_ADIROP, account for it */
   1011  1.265  dholland 		lfs_unmark_vnode(tvp);
   1012  1.265  dholland 		vput(tvp);
   1013  1.265  dholland 	}
   1014  1.267  dholland 
   1015  1.267  dholland out:
   1016  1.265  dholland 	fstrans_done(dvp->v_mount);
   1017  1.264  dholland 
   1018  1.264  dholland 	UNMARK_VNODE(dvp);
   1019  1.264  dholland 	UNMARK_VNODE(*vpp);
   1020  1.264  dholland 	if (!((*vpp)->v_uflag & VU_DIROP)) {
   1021  1.264  dholland 		KASSERT(error != 0);
   1022  1.264  dholland 		*vpp = NULL;
   1023  1.264  dholland 	}
   1024  1.264  dholland 	else {
   1025  1.264  dholland 		KASSERT(error == 0);
   1026  1.264  dholland 	}
   1027  1.264  dholland 	lfs_unset_dirop(fs, dvp, "mkdir");
   1028  1.264  dholland 
   1029  1.264  dholland 	vrele(dvp);
   1030   1.37  perseant 	return (error);
   1031    1.1   mycroft }
   1032    1.1   mycroft 
   1033    1.1   mycroft int
   1034   1.51  perseant lfs_remove(void *v)
   1035   1.10  christos {
   1036   1.22  perseant 	struct vop_remove_args	/* {
   1037    1.1   mycroft 		struct vnode *a_dvp;
   1038    1.1   mycroft 		struct vnode *a_vp;
   1039    1.1   mycroft 		struct componentname *a_cnp;
   1040   1.10  christos 	} */ *ap = v;
   1041   1.34  perseant 	struct vnode *dvp, *vp;
   1042  1.188  perseant 	struct inode *ip;
   1043   1.37  perseant 	int error;
   1044   1.34  perseant 
   1045   1.34  perseant 	dvp = ap->a_dvp;
   1046   1.34  perseant 	vp = ap->a_vp;
   1047  1.188  perseant 	ip = VTOI(vp);
   1048  1.264  dholland 	if ((error = lfs_set_dirop(dvp, vp)) != 0) {
   1049   1.34  perseant 		if (dvp == vp)
   1050   1.34  perseant 			vrele(vp);
   1051   1.34  perseant 		else
   1052   1.34  perseant 			vput(vp);
   1053   1.34  perseant 		vput(dvp);
   1054   1.37  perseant 		return error;
   1055   1.34  perseant 	}
   1056  1.245  dholland 	error = ulfs_remove(ap);
   1057  1.188  perseant 	if (ip->i_nlink == 0)
   1058  1.188  perseant 		lfs_orphan(ip->i_lfs, ip->i_number);
   1059  1.264  dholland 
   1060  1.264  dholland 	UNMARK_VNODE(dvp);
   1061  1.264  dholland 	if (ap->a_vp) {
   1062  1.264  dholland 		UNMARK_VNODE(ap->a_vp);
   1063  1.264  dholland 	}
   1064  1.264  dholland 	lfs_unset_dirop(ip->i_lfs, dvp, "remove");
   1065  1.264  dholland 	vrele(dvp);
   1066  1.264  dholland 	if (ap->a_vp) {
   1067  1.264  dholland 		vrele(ap->a_vp);
   1068  1.264  dholland 	}
   1069  1.264  dholland 
   1070   1.37  perseant 	return (error);
   1071    1.1   mycroft }
   1072    1.1   mycroft 
   1073    1.1   mycroft int
   1074   1.51  perseant lfs_rmdir(void *v)
   1075   1.10  christos {
   1076   1.22  perseant 	struct vop_rmdir_args	/* {
   1077    1.1   mycroft 		struct vnodeop_desc *a_desc;
   1078    1.1   mycroft 		struct vnode *a_dvp;
   1079    1.1   mycroft 		struct vnode *a_vp;
   1080    1.1   mycroft 		struct componentname *a_cnp;
   1081   1.10  christos 	} */ *ap = v;
   1082   1.84  perseant 	struct vnode *vp;
   1083  1.188  perseant 	struct inode *ip;
   1084   1.37  perseant 	int error;
   1085    1.1   mycroft 
   1086   1.84  perseant 	vp = ap->a_vp;
   1087  1.188  perseant 	ip = VTOI(vp);
   1088  1.264  dholland 	if ((error = lfs_set_dirop(ap->a_dvp, ap->a_vp)) != 0) {
   1089  1.194       chs 		if (ap->a_dvp == vp)
   1090  1.194       chs 			vrele(ap->a_dvp);
   1091  1.194       chs 		else
   1092  1.194       chs 			vput(ap->a_dvp);
   1093   1.84  perseant 		vput(vp);
   1094   1.37  perseant 		return error;
   1095   1.34  perseant 	}
   1096  1.245  dholland 	error = ulfs_rmdir(ap);
   1097  1.188  perseant 	if (ip->i_nlink == 0)
   1098  1.188  perseant 		lfs_orphan(ip->i_lfs, ip->i_number);
   1099  1.264  dholland 
   1100  1.264  dholland 	UNMARK_VNODE(ap->a_dvp);
   1101  1.264  dholland 	if (ap->a_vp) {
   1102  1.264  dholland 		UNMARK_VNODE(ap->a_vp);
   1103  1.264  dholland 	}
   1104  1.264  dholland 	lfs_unset_dirop(ip->i_lfs, ap->a_dvp, "rmdir");
   1105  1.264  dholland 	vrele(ap->a_dvp);
   1106  1.264  dholland 	if (ap->a_vp) {
   1107  1.264  dholland 		vrele(ap->a_vp);
   1108  1.264  dholland 	}
   1109  1.264  dholland 
   1110   1.37  perseant 	return (error);
   1111    1.1   mycroft }
   1112    1.1   mycroft 
   1113    1.1   mycroft int
   1114   1.51  perseant lfs_link(void *v)
   1115   1.10  christos {
   1116  1.271  riastrad 	struct vop_link_v2_args	/* {
   1117    1.9   mycroft 		struct vnode *a_dvp;
   1118    1.1   mycroft 		struct vnode *a_vp;
   1119    1.1   mycroft 		struct componentname *a_cnp;
   1120   1.10  christos 	} */ *ap = v;
   1121  1.264  dholland 	struct lfs *fs;
   1122  1.265  dholland 	struct vnode *dvp;
   1123   1.37  perseant 	int error;
   1124    1.1   mycroft 
   1125  1.264  dholland 	dvp = ap->a_dvp;
   1126  1.264  dholland 
   1127  1.264  dholland 	fs = VFSTOULFS(dvp->v_mount)->um_lfs;
   1128  1.264  dholland 	ASSERT_NO_SEGLOCK(fs);
   1129  1.264  dholland 	if (fs->lfs_ronly) {
   1130  1.264  dholland 		return EROFS;
   1131  1.264  dholland 	}
   1132  1.264  dholland 
   1133  1.264  dholland 	error = lfs_set_dirop(dvp, NULL);
   1134  1.264  dholland 	if (error) {
   1135   1.37  perseant 		return error;
   1136   1.34  perseant 	}
   1137  1.264  dholland 
   1138  1.245  dholland 	error = ulfs_link(ap);
   1139  1.264  dholland 
   1140  1.264  dholland 	UNMARK_VNODE(dvp);
   1141  1.264  dholland 	lfs_unset_dirop(fs, dvp, "link");
   1142  1.264  dholland 	vrele(dvp);
   1143  1.264  dholland 
   1144   1.37  perseant 	return (error);
   1145    1.1   mycroft }
   1146   1.22  perseant 
   1147    1.1   mycroft /* XXX hack to avoid calling ITIMES in getattr */
   1148    1.1   mycroft int
   1149   1.51  perseant lfs_getattr(void *v)
   1150   1.10  christos {
   1151    1.1   mycroft 	struct vop_getattr_args /* {
   1152    1.1   mycroft 		struct vnode *a_vp;
   1153    1.1   mycroft 		struct vattr *a_vap;
   1154  1.176      elad 		kauth_cred_t a_cred;
   1155   1.10  christos 	} */ *ap = v;
   1156   1.35  augustss 	struct vnode *vp = ap->a_vp;
   1157   1.35  augustss 	struct inode *ip = VTOI(vp);
   1158   1.35  augustss 	struct vattr *vap = ap->a_vap;
   1159   1.51  perseant 	struct lfs *fs = ip->i_lfs;
   1160  1.251  dholland 
   1161  1.251  dholland 	fstrans_start(vp->v_mount, FSTRANS_SHARED);
   1162    1.1   mycroft 	/*
   1163    1.1   mycroft 	 * Copy from inode table
   1164    1.1   mycroft 	 */
   1165    1.1   mycroft 	vap->va_fsid = ip->i_dev;
   1166    1.1   mycroft 	vap->va_fileid = ip->i_number;
   1167  1.246  dholland 	vap->va_mode = ip->i_mode & ~LFS_IFMT;
   1168  1.102      fvdl 	vap->va_nlink = ip->i_nlink;
   1169  1.102      fvdl 	vap->va_uid = ip->i_uid;
   1170  1.102      fvdl 	vap->va_gid = ip->i_gid;
   1171  1.102      fvdl 	vap->va_rdev = (dev_t)ip->i_ffs1_rdev;
   1172   1.55       chs 	vap->va_size = vp->v_size;
   1173  1.102      fvdl 	vap->va_atime.tv_sec = ip->i_ffs1_atime;
   1174  1.102      fvdl 	vap->va_atime.tv_nsec = ip->i_ffs1_atimensec;
   1175  1.102      fvdl 	vap->va_mtime.tv_sec = ip->i_ffs1_mtime;
   1176  1.102      fvdl 	vap->va_mtime.tv_nsec = ip->i_ffs1_mtimensec;
   1177  1.102      fvdl 	vap->va_ctime.tv_sec = ip->i_ffs1_ctime;
   1178  1.102      fvdl 	vap->va_ctime.tv_nsec = ip->i_ffs1_ctimensec;
   1179  1.102      fvdl 	vap->va_flags = ip->i_flags;
   1180  1.102      fvdl 	vap->va_gen = ip->i_gen;
   1181    1.1   mycroft 	/* this doesn't belong here */
   1182    1.1   mycroft 	if (vp->v_type == VBLK)
   1183    1.1   mycroft 		vap->va_blocksize = BLKDEV_IOSIZE;
   1184    1.1   mycroft 	else if (vp->v_type == VCHR)
   1185    1.1   mycroft 		vap->va_blocksize = MAXBSIZE;
   1186    1.1   mycroft 	else
   1187    1.1   mycroft 		vap->va_blocksize = vp->v_mount->mnt_stat.f_iosize;
   1188  1.248  christos 	vap->va_bytes = lfs_fsbtob(fs, (u_quad_t)ip->i_lfs_effnblks);
   1189    1.1   mycroft 	vap->va_type = vp->v_type;
   1190    1.1   mycroft 	vap->va_filerev = ip->i_modrev;
   1191  1.251  dholland 	fstrans_done(vp->v_mount);
   1192    1.1   mycroft 	return (0);
   1193   1.61  perseant }
   1194   1.61  perseant 
   1195   1.61  perseant /*
   1196   1.61  perseant  * Check to make sure the inode blocks won't choke the buffer
   1197  1.245  dholland  * cache, then call ulfs_setattr as usual.
   1198   1.61  perseant  */
   1199   1.61  perseant int
   1200   1.61  perseant lfs_setattr(void *v)
   1201   1.61  perseant {
   1202  1.149     skrll 	struct vop_setattr_args /* {
   1203   1.61  perseant 		struct vnode *a_vp;
   1204   1.61  perseant 		struct vattr *a_vap;
   1205  1.176      elad 		kauth_cred_t a_cred;
   1206   1.61  perseant 	} */ *ap = v;
   1207   1.61  perseant 	struct vnode *vp = ap->a_vp;
   1208   1.61  perseant 
   1209   1.61  perseant 	lfs_check(vp, LFS_UNUSED_LBN, 0);
   1210  1.245  dholland 	return ulfs_setattr(v);
   1211    1.1   mycroft }
   1212   1.22  perseant 
   1213    1.1   mycroft /*
   1214  1.179  perseant  * Release the block we hold on lfs_newseg wrapping.  Called on file close,
   1215  1.188  perseant  * or explicitly from LFCNWRAPGO.  Called with the interlock held.
   1216  1.179  perseant  */
   1217  1.179  perseant static int
   1218  1.193  christos lfs_wrapgo(struct lfs *fs, struct inode *ip, int waitfor)
   1219  1.179  perseant {
   1220  1.214        ad 	if (fs->lfs_stoplwp != curlwp)
   1221  1.179  perseant 		return EBUSY;
   1222  1.179  perseant 
   1223  1.214        ad 	fs->lfs_stoplwp = NULL;
   1224  1.214        ad 	cv_signal(&fs->lfs_stopcv);
   1225  1.179  perseant 
   1226  1.179  perseant 	KASSERT(fs->lfs_nowrap > 0);
   1227  1.179  perseant 	if (fs->lfs_nowrap <= 0) {
   1228  1.179  perseant 		return 0;
   1229  1.179  perseant 	}
   1230  1.179  perseant 
   1231  1.179  perseant 	if (--fs->lfs_nowrap == 0) {
   1232  1.275  dholland 		log(LOG_NOTICE, "%s: re-enabled log wrap\n",
   1233  1.275  dholland 		    lfs_sb_getfsmnt(fs));
   1234  1.188  perseant 		wakeup(&fs->lfs_wrappass);
   1235  1.180  perseant 		lfs_wakeup_cleaner(fs);
   1236  1.179  perseant 	}
   1237  1.179  perseant 	if (waitfor) {
   1238  1.274  dholland 		mtsleep(&fs->lfs_nextsegsleep, PCATCH | PUSER, "segment",
   1239  1.214        ad 		    0, &lfs_lock);
   1240  1.179  perseant 	}
   1241  1.179  perseant 
   1242  1.179  perseant 	return 0;
   1243  1.179  perseant }
   1244  1.179  perseant 
   1245  1.179  perseant /*
   1246  1.251  dholland  * Close called.
   1247  1.251  dholland  *
   1248  1.251  dholland  * Update the times on the inode.
   1249    1.1   mycroft  */
   1250    1.1   mycroft /* ARGSUSED */
   1251    1.1   mycroft int
   1252   1.51  perseant lfs_close(void *v)
   1253   1.10  christos {
   1254    1.1   mycroft 	struct vop_close_args /* {
   1255    1.1   mycroft 		struct vnode *a_vp;
   1256    1.1   mycroft 		int  a_fflag;
   1257  1.176      elad 		kauth_cred_t a_cred;
   1258   1.10  christos 	} */ *ap = v;
   1259   1.35  augustss 	struct vnode *vp = ap->a_vp;
   1260   1.35  augustss 	struct inode *ip = VTOI(vp);
   1261  1.180  perseant 	struct lfs *fs = ip->i_lfs;
   1262    1.1   mycroft 
   1263  1.245  dholland 	if ((ip->i_number == ULFS_ROOTINO || ip->i_number == LFS_IFILE_INUM) &&
   1264  1.214        ad 	    fs->lfs_stoplwp == curlwp) {
   1265  1.214        ad 		mutex_enter(&lfs_lock);
   1266  1.188  perseant 		log(LOG_NOTICE, "lfs_close: releasing log wrap control\n");
   1267  1.180  perseant 		lfs_wrapgo(fs, ip, 0);
   1268  1.214        ad 		mutex_exit(&lfs_lock);
   1269  1.179  perseant 	}
   1270  1.179  perseant 
   1271   1.97  perseant 	if (vp == ip->i_lfs->lfs_ivnode &&
   1272  1.119       dbj 	    vp->v_mount->mnt_iflag & IMNT_UNMOUNT)
   1273   1.97  perseant 		return 0;
   1274   1.97  perseant 
   1275  1.251  dholland 	fstrans_start(vp->v_mount, FSTRANS_SHARED);
   1276   1.97  perseant 	if (vp->v_usecount > 1 && vp != ip->i_lfs->lfs_ivnode) {
   1277  1.154  christos 		LFS_ITIMES(ip, NULL, NULL, NULL);
   1278    1.1   mycroft 	}
   1279  1.251  dholland 	fstrans_done(vp->v_mount);
   1280    1.1   mycroft 	return (0);
   1281   1.65  perseant }
   1282   1.65  perseant 
   1283   1.65  perseant /*
   1284   1.65  perseant  * Close wrapper for special devices.
   1285   1.65  perseant  *
   1286   1.65  perseant  * Update the times on the inode then do device close.
   1287   1.65  perseant  */
   1288   1.65  perseant int
   1289   1.65  perseant lfsspec_close(void *v)
   1290   1.65  perseant {
   1291   1.65  perseant 	struct vop_close_args /* {
   1292   1.65  perseant 		struct vnode	*a_vp;
   1293   1.65  perseant 		int		a_fflag;
   1294  1.176      elad 		kauth_cred_t	a_cred;
   1295   1.65  perseant 	} */ *ap = v;
   1296   1.65  perseant 	struct vnode	*vp;
   1297   1.65  perseant 	struct inode	*ip;
   1298   1.65  perseant 
   1299   1.65  perseant 	vp = ap->a_vp;
   1300   1.65  perseant 	ip = VTOI(vp);
   1301   1.65  perseant 	if (vp->v_usecount > 1) {
   1302  1.154  christos 		LFS_ITIMES(ip, NULL, NULL, NULL);
   1303   1.65  perseant 	}
   1304   1.65  perseant 	return (VOCALL (spec_vnodeop_p, VOFFSET(vop_close), ap));
   1305   1.65  perseant }
   1306   1.65  perseant 
   1307   1.65  perseant /*
   1308   1.65  perseant  * Close wrapper for fifo's.
   1309   1.65  perseant  *
   1310   1.65  perseant  * Update the times on the inode then do device close.
   1311   1.65  perseant  */
   1312   1.65  perseant int
   1313   1.65  perseant lfsfifo_close(void *v)
   1314   1.65  perseant {
   1315   1.65  perseant 	struct vop_close_args /* {
   1316   1.65  perseant 		struct vnode	*a_vp;
   1317   1.65  perseant 		int		a_fflag;
   1318  1.176      elad 		kauth_cred_	a_cred;
   1319   1.65  perseant 	} */ *ap = v;
   1320   1.65  perseant 	struct vnode	*vp;
   1321   1.65  perseant 	struct inode	*ip;
   1322   1.65  perseant 
   1323   1.65  perseant 	vp = ap->a_vp;
   1324   1.65  perseant 	ip = VTOI(vp);
   1325   1.65  perseant 	if (ap->a_vp->v_usecount > 1) {
   1326  1.154  christos 		LFS_ITIMES(ip, NULL, NULL, NULL);
   1327   1.65  perseant 	}
   1328   1.65  perseant 	return (VOCALL (fifo_vnodeop_p, VOFFSET(vop_close), ap));
   1329    1.1   mycroft }
   1330    1.1   mycroft 
   1331    1.1   mycroft /*
   1332   1.15      fvdl  * Reclaim an inode so that it can be used for other purposes.
   1333    1.1   mycroft  */
   1334    1.1   mycroft 
   1335    1.1   mycroft int
   1336   1.51  perseant lfs_reclaim(void *v)
   1337   1.10  christos {
   1338    1.1   mycroft 	struct vop_reclaim_args /* {
   1339    1.1   mycroft 		struct vnode *a_vp;
   1340   1.10  christos 	} */ *ap = v;
   1341   1.15      fvdl 	struct vnode *vp = ap->a_vp;
   1342   1.84  perseant 	struct inode *ip = VTOI(vp);
   1343  1.203  perseant 	struct lfs *fs = ip->i_lfs;
   1344    1.1   mycroft 	int error;
   1345   1.77      yamt 
   1346  1.231   hannken 	/*
   1347  1.231   hannken 	 * The inode must be freed and updated before being removed
   1348  1.231   hannken 	 * from its hash chain.  Other threads trying to gain a hold
   1349  1.262   hannken 	 * or lock on the inode will be stalled.
   1350  1.231   hannken 	 */
   1351  1.231   hannken 	if (ip->i_nlink <= 0 && (vp->v_mount->mnt_flag & MNT_RDONLY) == 0)
   1352  1.231   hannken 		lfs_vfree(vp, ip->i_number, ip->i_omode);
   1353  1.231   hannken 
   1354  1.214        ad 	mutex_enter(&lfs_lock);
   1355   1.84  perseant 	LFS_CLR_UINO(ip, IN_ALLMOD);
   1356  1.214        ad 	mutex_exit(&lfs_lock);
   1357  1.245  dholland 	if ((error = ulfs_reclaim(vp)))
   1358    1.1   mycroft 		return (error);
   1359  1.203  perseant 
   1360  1.203  perseant 	/*
   1361  1.203  perseant 	 * Take us off the paging and/or dirop queues if we were on them.
   1362  1.203  perseant 	 * We shouldn't be on them.
   1363  1.203  perseant 	 */
   1364  1.214        ad 	mutex_enter(&lfs_lock);
   1365  1.203  perseant 	if (ip->i_flags & IN_PAGING) {
   1366  1.203  perseant 		log(LOG_WARNING, "%s: reclaimed vnode is IN_PAGING\n",
   1367  1.275  dholland 		    lfs_sb_getfsmnt(fs));
   1368  1.203  perseant 		ip->i_flags &= ~IN_PAGING;
   1369  1.203  perseant 		TAILQ_REMOVE(&fs->lfs_pchainhd, ip, i_lfs_pchain);
   1370  1.203  perseant 	}
   1371  1.212        ad 	if (vp->v_uflag & VU_DIROP) {
   1372  1.212        ad 		panic("reclaimed vnode is VU_DIROP");
   1373  1.212        ad 		vp->v_uflag &= ~VU_DIROP;
   1374  1.203  perseant 		TAILQ_REMOVE(&fs->lfs_dchainhd, ip, i_lfs_dchain);
   1375  1.203  perseant 	}
   1376  1.214        ad 	mutex_exit(&lfs_lock);
   1377  1.203  perseant 
   1378  1.142  perseant 	pool_put(&lfs_dinode_pool, ip->i_din.ffs1_din);
   1379  1.145  perseant 	lfs_deregister_all(vp);
   1380   1.84  perseant 	pool_put(&lfs_inoext_pool, ip->inode_ext.lfs);
   1381   1.84  perseant 	ip->inode_ext.lfs = NULL;
   1382  1.199        ad 	genfs_node_destroy(vp);
   1383   1.19   thorpej 	pool_put(&lfs_inode_pool, vp->v_data);
   1384    1.1   mycroft 	vp->v_data = NULL;
   1385   1.94  perseant 	return (0);
   1386   1.94  perseant }
   1387   1.94  perseant 
   1388   1.94  perseant /*
   1389  1.101      yamt  * Read a block from a storage device.
   1390  1.251  dholland  *
   1391  1.251  dholland  * Calculate the logical to physical mapping if not done already,
   1392  1.251  dholland  * then call the device strategy routine.
   1393  1.251  dholland  *
   1394   1.94  perseant  * In order to avoid reading blocks that are in the process of being
   1395   1.94  perseant  * written by the cleaner---and hence are not mutexed by the normal
   1396   1.94  perseant  * buffer cache / page cache mechanisms---check for collisions before
   1397   1.94  perseant  * reading.
   1398   1.94  perseant  *
   1399  1.245  dholland  * We inline ulfs_strategy to make sure that the VOP_BMAP occurs *before*
   1400   1.94  perseant  * the active cleaner test.
   1401   1.94  perseant  *
   1402   1.94  perseant  * XXX This code assumes that lfs_markv makes synchronous checkpoints.
   1403   1.94  perseant  */
   1404   1.94  perseant int
   1405   1.94  perseant lfs_strategy(void *v)
   1406   1.94  perseant {
   1407   1.94  perseant 	struct vop_strategy_args /* {
   1408  1.128   hannken 		struct vnode *a_vp;
   1409   1.94  perseant 		struct buf *a_bp;
   1410   1.94  perseant 	} */ *ap = v;
   1411   1.94  perseant 	struct buf	*bp;
   1412   1.94  perseant 	struct lfs	*fs;
   1413   1.94  perseant 	struct vnode	*vp;
   1414   1.94  perseant 	struct inode	*ip;
   1415   1.94  perseant 	daddr_t		tbn;
   1416  1.239  perseant #define MAXLOOP 25
   1417  1.239  perseant 	int		i, sn, error, slept, loopcount;
   1418   1.94  perseant 
   1419   1.94  perseant 	bp = ap->a_bp;
   1420  1.128   hannken 	vp = ap->a_vp;
   1421   1.94  perseant 	ip = VTOI(vp);
   1422   1.94  perseant 	fs = ip->i_lfs;
   1423   1.94  perseant 
   1424  1.101      yamt 	/* lfs uses its strategy routine only for read */
   1425  1.101      yamt 	KASSERT(bp->b_flags & B_READ);
   1426  1.101      yamt 
   1427   1.94  perseant 	if (vp->v_type == VBLK || vp->v_type == VCHR)
   1428   1.94  perseant 		panic("lfs_strategy: spec");
   1429   1.94  perseant 	KASSERT(bp->b_bcount != 0);
   1430   1.94  perseant 	if (bp->b_blkno == bp->b_lblkno) {
   1431   1.94  perseant 		error = VOP_BMAP(vp, bp->b_lblkno, NULL, &bp->b_blkno,
   1432   1.94  perseant 				 NULL);
   1433   1.94  perseant 		if (error) {
   1434   1.94  perseant 			bp->b_error = error;
   1435  1.214        ad 			bp->b_resid = bp->b_bcount;
   1436   1.94  perseant 			biodone(bp);
   1437   1.94  perseant 			return (error);
   1438   1.94  perseant 		}
   1439   1.94  perseant 		if ((long)bp->b_blkno == -1) /* no valid data */
   1440   1.94  perseant 			clrbuf(bp);
   1441   1.94  perseant 	}
   1442   1.94  perseant 	if ((long)bp->b_blkno < 0) { /* block is not on disk */
   1443  1.214        ad 		bp->b_resid = bp->b_bcount;
   1444   1.94  perseant 		biodone(bp);
   1445   1.94  perseant 		return (0);
   1446   1.94  perseant 	}
   1447   1.94  perseant 
   1448   1.94  perseant 	slept = 1;
   1449  1.239  perseant 	loopcount = 0;
   1450  1.214        ad 	mutex_enter(&lfs_lock);
   1451  1.101      yamt 	while (slept && fs->lfs_seglock) {
   1452  1.214        ad 		mutex_exit(&lfs_lock);
   1453   1.94  perseant 		/*
   1454   1.94  perseant 		 * Look through list of intervals.
   1455   1.94  perseant 		 * There will only be intervals to look through
   1456   1.94  perseant 		 * if the cleaner holds the seglock.
   1457   1.94  perseant 		 * Since the cleaner is synchronous, we can trust
   1458   1.94  perseant 		 * the list of intervals to be current.
   1459   1.94  perseant 		 */
   1460  1.248  christos 		tbn = LFS_DBTOFSB(fs, bp->b_blkno);
   1461  1.248  christos 		sn = lfs_dtosn(fs, tbn);
   1462   1.94  perseant 		slept = 0;
   1463   1.94  perseant 		for (i = 0; i < fs->lfs_cleanind; i++) {
   1464  1.248  christos 			if (sn == lfs_dtosn(fs, fs->lfs_cleanint[i]) &&
   1465   1.94  perseant 			    tbn >= fs->lfs_cleanint[i]) {
   1466  1.136  perseant 				DLOG((DLOG_CLEAN,
   1467  1.136  perseant 				      "lfs_strategy: ino %d lbn %" PRId64
   1468  1.203  perseant 				      " ind %d sn %d fsb %" PRIx32
   1469  1.203  perseant 				      " given sn %d fsb %" PRIx64 "\n",
   1470  1.203  perseant 				      ip->i_number, bp->b_lblkno, i,
   1471  1.248  christos 				      lfs_dtosn(fs, fs->lfs_cleanint[i]),
   1472  1.203  perseant 				      fs->lfs_cleanint[i], sn, tbn));
   1473  1.136  perseant 				DLOG((DLOG_CLEAN,
   1474  1.136  perseant 				      "lfs_strategy: sleeping on ino %d lbn %"
   1475  1.136  perseant 				      PRId64 "\n", ip->i_number, bp->b_lblkno));
   1476  1.214        ad 				mutex_enter(&lfs_lock);
   1477  1.170  perseant 				if (LFS_SEGLOCK_HELD(fs) && fs->lfs_iocount) {
   1478  1.239  perseant 					/*
   1479  1.239  perseant 					 * Cleaner can't wait for itself.
   1480  1.239  perseant 					 * Instead, wait for the blocks
   1481  1.239  perseant 					 * to be written to disk.
   1482  1.239  perseant 					 * XXX we need pribio in the test
   1483  1.239  perseant 					 * XXX here.
   1484  1.239  perseant 					 */
   1485  1.239  perseant  					mtsleep(&fs->lfs_iocount,
   1486  1.239  perseant  						(PRIBIO + 1) | PNORELOCK,
   1487  1.239  perseant 						"clean2", hz/10 + 1,
   1488  1.239  perseant  						&lfs_lock);
   1489  1.170  perseant 					slept = 1;
   1490  1.239  perseant 					++loopcount;
   1491  1.170  perseant 					break;
   1492  1.170  perseant 				} else if (fs->lfs_seglock) {
   1493  1.214        ad 					mtsleep(&fs->lfs_seglock,
   1494  1.141  perseant 						(PRIBIO + 1) | PNORELOCK,
   1495  1.170  perseant 						"clean1", 0,
   1496  1.214        ad 						&lfs_lock);
   1497  1.167  perseant 					slept = 1;
   1498  1.167  perseant 					break;
   1499  1.167  perseant 				}
   1500  1.214        ad 				mutex_exit(&lfs_lock);
   1501   1.94  perseant 			}
   1502   1.94  perseant 		}
   1503  1.214        ad 		mutex_enter(&lfs_lock);
   1504  1.239  perseant 		if (loopcount > MAXLOOP) {
   1505  1.239  perseant 			printf("lfs_strategy: breaking out of clean2 loop\n");
   1506  1.239  perseant 			break;
   1507  1.239  perseant 		}
   1508   1.94  perseant 	}
   1509  1.214        ad 	mutex_exit(&lfs_lock);
   1510   1.94  perseant 
   1511   1.94  perseant 	vp = ip->i_devvp;
   1512  1.251  dholland 	return VOP_STRATEGY(vp, bp);
   1513   1.89  perseant }
   1514   1.89  perseant 
   1515  1.239  perseant /*
   1516  1.239  perseant  * Inline lfs_segwrite/lfs_writevnodes, but just for dirops.
   1517  1.239  perseant  * Technically this is a checkpoint (the on-disk state is valid)
   1518  1.239  perseant  * even though we are leaving out all the file data.
   1519  1.239  perseant  */
   1520  1.239  perseant int
   1521   1.92  perseant lfs_flush_dirops(struct lfs *fs)
   1522   1.92  perseant {
   1523   1.92  perseant 	struct inode *ip, *nip;
   1524   1.92  perseant 	struct vnode *vp;
   1525   1.92  perseant 	extern int lfs_dostats;
   1526   1.92  perseant 	struct segment *sp;
   1527  1.239  perseant 	int flags = 0;
   1528  1.239  perseant 	int error = 0;
   1529   1.92  perseant 
   1530  1.163  perseant 	ASSERT_MAYBE_SEGLOCK(fs);
   1531  1.171  perseant 	KASSERT(fs->lfs_nadirop == 0);
   1532  1.141  perseant 
   1533   1.92  perseant 	if (fs->lfs_ronly)
   1534  1.239  perseant 		return EROFS;
   1535   1.92  perseant 
   1536  1.214        ad 	mutex_enter(&lfs_lock);
   1537  1.141  perseant 	if (TAILQ_FIRST(&fs->lfs_dchainhd) == NULL) {
   1538  1.214        ad 		mutex_exit(&lfs_lock);
   1539  1.239  perseant 		return 0;
   1540  1.141  perseant 	} else
   1541  1.214        ad 		mutex_exit(&lfs_lock);
   1542   1.92  perseant 
   1543   1.92  perseant 	if (lfs_dostats)
   1544   1.92  perseant 		++lfs_stats.flush_invoked;
   1545   1.92  perseant 
   1546   1.92  perseant 	lfs_imtime(fs);
   1547  1.239  perseant 	lfs_seglock(fs, flags);
   1548   1.92  perseant 	sp = fs->lfs_sp;
   1549   1.92  perseant 
   1550   1.92  perseant 	/*
   1551   1.92  perseant 	 * lfs_writevnodes, optimized to get dirops out of the way.
   1552   1.92  perseant 	 * Only write dirops, and don't flush files' pages, only
   1553   1.92  perseant 	 * blocks from the directories.
   1554   1.92  perseant 	 *
   1555   1.92  perseant 	 * We don't need to vref these files because they are
   1556   1.92  perseant 	 * dirops and so hold an extra reference until the
   1557   1.92  perseant 	 * segunlock clears them of that status.
   1558   1.92  perseant 	 *
   1559   1.92  perseant 	 * We don't need to check for IN_ADIROP because we know that
   1560   1.92  perseant 	 * no dirops are active.
   1561   1.92  perseant 	 *
   1562   1.92  perseant 	 */
   1563  1.214        ad 	mutex_enter(&lfs_lock);
   1564   1.92  perseant 	for (ip = TAILQ_FIRST(&fs->lfs_dchainhd); ip != NULL; ip = nip) {
   1565   1.92  perseant 		nip = TAILQ_NEXT(ip, i_lfs_dchain);
   1566  1.214        ad 		mutex_exit(&lfs_lock);
   1567   1.92  perseant 		vp = ITOV(ip);
   1568  1.262   hannken 		mutex_enter(vp->v_interlock);
   1569   1.92  perseant 
   1570  1.171  perseant 		KASSERT((ip->i_flag & IN_ADIROP) == 0);
   1571  1.239  perseant 		KASSERT(vp->v_uflag & VU_DIROP);
   1572  1.262   hannken 		KASSERT(vdead_check(vp, VDEAD_NOWAIT) == 0);
   1573  1.171  perseant 
   1574   1.92  perseant 		/*
   1575   1.92  perseant 		 * All writes to directories come from dirops; all
   1576   1.92  perseant 		 * writes to files' direct blocks go through the page
   1577   1.92  perseant 		 * cache, which we're not touching.  Reads to files
   1578   1.92  perseant 		 * and/or directories will not be affected by writing
   1579   1.92  perseant 		 * directory blocks inodes and file inodes.  So we don't
   1580  1.239  perseant 		 * really need to lock.
   1581   1.92  perseant 		 */
   1582  1.262   hannken 		if (vdead_check(vp, VDEAD_NOWAIT) != 0) {
   1583  1.262   hannken 			mutex_exit(vp->v_interlock);
   1584  1.214        ad 			mutex_enter(&lfs_lock);
   1585   1.92  perseant 			continue;
   1586  1.167  perseant 		}
   1587  1.262   hannken 		mutex_exit(vp->v_interlock);
   1588  1.228   hannken 		/* XXX see below
   1589  1.228   hannken 		 * waslocked = VOP_ISLOCKED(vp);
   1590  1.228   hannken 		 */
   1591   1.92  perseant 		if (vp->v_type != VREG &&
   1592   1.92  perseant 		    ((ip->i_flag & IN_ALLMOD) || !VPISEMPTY(vp))) {
   1593  1.239  perseant 			error = lfs_writefile(fs, sp, vp);
   1594   1.92  perseant 			if (!VPISEMPTY(vp) && !WRITEINPROG(vp) &&
   1595   1.92  perseant 			    !(ip->i_flag & IN_ALLMOD)) {
   1596  1.214        ad 			    	mutex_enter(&lfs_lock);
   1597   1.92  perseant 				LFS_SET_UINO(ip, IN_MODIFIED);
   1598  1.214        ad 			    	mutex_exit(&lfs_lock);
   1599   1.92  perseant 			}
   1600  1.239  perseant 			if (error && (sp->seg_flags & SEGM_SINGLE)) {
   1601  1.239  perseant 				mutex_enter(&lfs_lock);
   1602  1.239  perseant 				error = EAGAIN;
   1603  1.239  perseant 				break;
   1604  1.239  perseant 			}
   1605   1.92  perseant 		}
   1606  1.188  perseant 		KDASSERT(ip->i_number != LFS_IFILE_INUM);
   1607  1.239  perseant 		error = lfs_writeinode(fs, sp, ip);
   1608  1.214        ad 		mutex_enter(&lfs_lock);
   1609  1.239  perseant 		if (error && (sp->seg_flags & SEGM_SINGLE)) {
   1610  1.239  perseant 			error = EAGAIN;
   1611  1.239  perseant 			break;
   1612  1.239  perseant 		}
   1613  1.239  perseant 
   1614  1.228   hannken 		/*
   1615  1.239  perseant 		 * We might need to update these inodes again,
   1616  1.239  perseant 		 * for example, if they have data blocks to write.
   1617  1.239  perseant 		 * Make sure that after this flush, they are still
   1618  1.239  perseant 		 * marked IN_MODIFIED so that we don't forget to
   1619  1.239  perseant 		 * write them.
   1620  1.228   hannken 		 */
   1621  1.239  perseant 		/* XXX only for non-directories? --KS */
   1622  1.239  perseant 		LFS_SET_UINO(ip, IN_MODIFIED);
   1623   1.92  perseant 	}
   1624  1.214        ad 	mutex_exit(&lfs_lock);
   1625   1.92  perseant 	/* We've written all the dirops there are */
   1626   1.92  perseant 	((SEGSUM *)(sp->segsum))->ss_flags &= ~(SS_CONT);
   1627  1.170  perseant 	lfs_finalize_fs_seguse(fs);
   1628   1.92  perseant 	(void) lfs_writeseg(fs, sp);
   1629   1.92  perseant 	lfs_segunlock(fs);
   1630  1.239  perseant 
   1631  1.239  perseant 	return error;
   1632   1.92  perseant }
   1633   1.92  perseant 
   1634   1.89  perseant /*
   1635  1.164  perseant  * Flush all vnodes for which the pagedaemon has requested pageouts.
   1636  1.212        ad  * Skip over any files that are marked VU_DIROP (since lfs_flush_dirop()
   1637  1.164  perseant  * has just run, this would be an error).  If we have to skip a vnode
   1638  1.164  perseant  * for any reason, just skip it; if we have to wait for the cleaner,
   1639  1.164  perseant  * abort.  The writer daemon will call us again later.
   1640  1.164  perseant  */
   1641  1.239  perseant int
   1642  1.164  perseant lfs_flush_pchain(struct lfs *fs)
   1643  1.164  perseant {
   1644  1.164  perseant 	struct inode *ip, *nip;
   1645  1.164  perseant 	struct vnode *vp;
   1646  1.164  perseant 	extern int lfs_dostats;
   1647  1.164  perseant 	struct segment *sp;
   1648  1.239  perseant 	int error, error2;
   1649  1.164  perseant 
   1650  1.164  perseant 	ASSERT_NO_SEGLOCK(fs);
   1651  1.164  perseant 
   1652  1.164  perseant 	if (fs->lfs_ronly)
   1653  1.239  perseant 		return EROFS;
   1654  1.164  perseant 
   1655  1.214        ad 	mutex_enter(&lfs_lock);
   1656  1.164  perseant 	if (TAILQ_FIRST(&fs->lfs_pchainhd) == NULL) {
   1657  1.214        ad 		mutex_exit(&lfs_lock);
   1658  1.239  perseant 		return 0;
   1659  1.164  perseant 	} else
   1660  1.214        ad 		mutex_exit(&lfs_lock);
   1661  1.164  perseant 
   1662  1.164  perseant 	/* Get dirops out of the way */
   1663  1.239  perseant 	if ((error = lfs_flush_dirops(fs)) != 0)
   1664  1.239  perseant 		return error;
   1665  1.164  perseant 
   1666  1.164  perseant 	if (lfs_dostats)
   1667  1.164  perseant 		++lfs_stats.flush_invoked;
   1668  1.164  perseant 
   1669  1.164  perseant 	/*
   1670  1.164  perseant 	 * Inline lfs_segwrite/lfs_writevnodes, but just for pageouts.
   1671  1.164  perseant 	 */
   1672  1.164  perseant 	lfs_imtime(fs);
   1673  1.164  perseant 	lfs_seglock(fs, 0);
   1674  1.164  perseant 	sp = fs->lfs_sp;
   1675  1.164  perseant 
   1676  1.164  perseant 	/*
   1677  1.164  perseant 	 * lfs_writevnodes, optimized to clear pageout requests.
   1678  1.164  perseant 	 * Only write non-dirop files that are in the pageout queue.
   1679  1.164  perseant 	 * We're very conservative about what we write; we want to be
   1680  1.164  perseant 	 * fast and async.
   1681  1.164  perseant 	 */
   1682  1.214        ad 	mutex_enter(&lfs_lock);
   1683  1.214        ad     top:
   1684  1.164  perseant 	for (ip = TAILQ_FIRST(&fs->lfs_pchainhd); ip != NULL; ip = nip) {
   1685  1.164  perseant 		nip = TAILQ_NEXT(ip, i_lfs_pchain);
   1686  1.164  perseant 		vp = ITOV(ip);
   1687  1.164  perseant 
   1688  1.164  perseant 		if (!(ip->i_flags & IN_PAGING))
   1689  1.164  perseant 			goto top;
   1690  1.164  perseant 
   1691  1.235     rmind 		mutex_enter(vp->v_interlock);
   1692  1.262   hannken 		if (vdead_check(vp, VDEAD_NOWAIT) != 0 ||
   1693  1.262   hannken 		    (vp->v_uflag & VU_DIROP) != 0) {
   1694  1.235     rmind 			mutex_exit(vp->v_interlock);
   1695  1.164  perseant 			continue;
   1696  1.214        ad 		}
   1697  1.214        ad 		if (vp->v_type != VREG) {
   1698  1.235     rmind 			mutex_exit(vp->v_interlock);
   1699  1.164  perseant 			continue;
   1700  1.214        ad 		}
   1701  1.272   hannken 		if (vget(vp, LK_NOWAIT, false /* !wait */))
   1702  1.164  perseant 			continue;
   1703  1.214        ad 		mutex_exit(&lfs_lock);
   1704  1.169  perseant 
   1705  1.228   hannken 		if (vn_lock(vp, LK_EXCLUSIVE | LK_NOWAIT | LK_RETRY) != 0) {
   1706  1.272   hannken 			vrele(vp);
   1707  1.214        ad 			mutex_enter(&lfs_lock);
   1708  1.164  perseant 			continue;
   1709  1.165  perseant 		}
   1710  1.164  perseant 
   1711  1.164  perseant 		error = lfs_writefile(fs, sp, vp);
   1712  1.164  perseant 		if (!VPISEMPTY(vp) && !WRITEINPROG(vp) &&
   1713  1.164  perseant 		    !(ip->i_flag & IN_ALLMOD)) {
   1714  1.214        ad 		    	mutex_enter(&lfs_lock);
   1715  1.164  perseant 			LFS_SET_UINO(ip, IN_MODIFIED);
   1716  1.214        ad 		    	mutex_exit(&lfs_lock);
   1717  1.164  perseant 		}
   1718  1.188  perseant 		KDASSERT(ip->i_number != LFS_IFILE_INUM);
   1719  1.239  perseant 		error2 = lfs_writeinode(fs, sp, ip);
   1720  1.164  perseant 
   1721  1.229   hannken 		VOP_UNLOCK(vp);
   1722  1.272   hannken 		vrele(vp);
   1723  1.164  perseant 
   1724  1.239  perseant 		if (error == EAGAIN || error2 == EAGAIN) {
   1725  1.164  perseant 			lfs_writeseg(fs, sp);
   1726  1.214        ad 			mutex_enter(&lfs_lock);
   1727  1.164  perseant 			break;
   1728  1.164  perseant 		}
   1729  1.214        ad 		mutex_enter(&lfs_lock);
   1730  1.164  perseant 	}
   1731  1.214        ad 	mutex_exit(&lfs_lock);
   1732  1.164  perseant 	(void) lfs_writeseg(fs, sp);
   1733  1.164  perseant 	lfs_segunlock(fs);
   1734  1.239  perseant 
   1735  1.239  perseant 	return 0;
   1736  1.164  perseant }
   1737  1.164  perseant 
   1738  1.164  perseant /*
   1739   1.90  perseant  * Provide a fcntl interface to sys_lfs_{segwait,bmapv,markv}.
   1740   1.89  perseant  */
   1741   1.89  perseant int
   1742   1.90  perseant lfs_fcntl(void *v)
   1743   1.89  perseant {
   1744  1.137    simonb 	struct vop_fcntl_args /* {
   1745  1.137    simonb 		struct vnode *a_vp;
   1746  1.218  gmcgarry 		u_int a_command;
   1747  1.201  christos 		void * a_data;
   1748  1.137    simonb 		int  a_fflag;
   1749  1.176      elad 		kauth_cred_t a_cred;
   1750  1.137    simonb 	} */ *ap = v;
   1751  1.222  christos 	struct timeval tv;
   1752   1.89  perseant 	struct timeval *tvp;
   1753   1.89  perseant 	BLOCK_INFO *blkiov;
   1754   1.92  perseant 	CLEANERINFO *cip;
   1755  1.148  perseant 	SEGUSE *sup;
   1756  1.258  christos 	int blkcnt, error;
   1757  1.181    martin 	size_t fh_size;
   1758   1.90  perseant 	struct lfs_fcntl_markv blkvp;
   1759  1.185        ad 	struct lwp *l;
   1760   1.89  perseant 	fsid_t *fsidp;
   1761   1.92  perseant 	struct lfs *fs;
   1762   1.92  perseant 	struct buf *bp;
   1763  1.134  perseant 	fhandle_t *fhp;
   1764   1.92  perseant 	daddr_t off;
   1765  1.258  christos 	int oclean;
   1766   1.89  perseant 
   1767   1.90  perseant 	/* Only respect LFS fcntls on fs root or Ifile */
   1768  1.245  dholland 	if (VTOI(ap->a_vp)->i_number != ULFS_ROOTINO &&
   1769   1.89  perseant 	    VTOI(ap->a_vp)->i_number != LFS_IFILE_INUM) {
   1770  1.245  dholland 		return ulfs_fcntl(v);
   1771   1.89  perseant 	}
   1772   1.89  perseant 
   1773  1.100  perseant 	/* Avoid locking a draining lock */
   1774  1.119       dbj 	if (ap->a_vp->v_mount->mnt_iflag & IMNT_UNMOUNT) {
   1775  1.100  perseant 		return ESHUTDOWN;
   1776  1.100  perseant 	}
   1777  1.100  perseant 
   1778  1.184  perseant 	/* LFS control and monitoring fcntls are available only to root */
   1779  1.213     pooka 	l = curlwp;
   1780  1.184  perseant 	if (((ap->a_command & 0xff00) >> 8) == 'L' &&
   1781  1.241      elad 	    (error = kauth_authorize_system(l->l_cred, KAUTH_SYSTEM_LFS,
   1782  1.241      elad 	     KAUTH_REQ_SYSTEM_LFS_FCNTL, NULL, NULL, NULL)) != 0)
   1783  1.184  perseant 		return (error);
   1784  1.184  perseant 
   1785  1.100  perseant 	fs = VTOI(ap->a_vp)->i_lfs;
   1786  1.131  christos 	fsidp = &ap->a_vp->v_mount->mnt_stat.f_fsidx;
   1787   1.89  perseant 
   1788  1.188  perseant 	error = 0;
   1789  1.218  gmcgarry 	switch ((int)ap->a_command) {
   1790  1.222  christos 	    case LFCNSEGWAITALL_COMPAT_50:
   1791  1.222  christos 	    case LFCNSEGWAITALL_COMPAT:
   1792  1.222  christos 		fsidp = NULL;
   1793  1.222  christos 		/* FALLSTHROUGH */
   1794  1.222  christos 	    case LFCNSEGWAIT_COMPAT_50:
   1795  1.222  christos 	    case LFCNSEGWAIT_COMPAT:
   1796  1.222  christos 		{
   1797  1.222  christos 			struct timeval50 *tvp50
   1798  1.222  christos 				= (struct timeval50 *)ap->a_data;
   1799  1.222  christos 			timeval50_to_timeval(tvp50, &tv);
   1800  1.222  christos 			tvp = &tv;
   1801  1.222  christos 		}
   1802  1.222  christos 		goto segwait_common;
   1803   1.90  perseant 	    case LFCNSEGWAITALL:
   1804  1.214        ad 		fsidp = NULL;
   1805  1.214        ad 		/* FALLSTHROUGH */
   1806   1.90  perseant 	    case LFCNSEGWAIT:
   1807  1.214        ad 		tvp = (struct timeval *)ap->a_data;
   1808  1.222  christos segwait_common:
   1809  1.214        ad 		mutex_enter(&lfs_lock);
   1810  1.214        ad 		++fs->lfs_sleepers;
   1811  1.214        ad 		mutex_exit(&lfs_lock);
   1812  1.214        ad 
   1813  1.214        ad 		error = lfs_segwait(fsidp, tvp);
   1814  1.214        ad 
   1815  1.214        ad 		mutex_enter(&lfs_lock);
   1816  1.214        ad 		if (--fs->lfs_sleepers == 0)
   1817  1.214        ad 			wakeup(&fs->lfs_sleepers);
   1818  1.214        ad 		mutex_exit(&lfs_lock);
   1819  1.214        ad 		return error;
   1820   1.89  perseant 
   1821   1.90  perseant 	    case LFCNBMAPV:
   1822   1.90  perseant 	    case LFCNMARKV:
   1823  1.214        ad 		blkvp = *(struct lfs_fcntl_markv *)ap->a_data;
   1824   1.89  perseant 
   1825  1.214        ad 		blkcnt = blkvp.blkcnt;
   1826  1.214        ad 		if ((u_int) blkcnt > LFS_MARKV_MAXBLKCNT)
   1827  1.214        ad 			return (EINVAL);
   1828  1.214        ad 		blkiov = lfs_malloc(fs, blkcnt * sizeof(BLOCK_INFO), LFS_NB_BLKIOV);
   1829  1.214        ad 		if ((error = copyin(blkvp.blkiov, blkiov,
   1830  1.214        ad 		     blkcnt * sizeof(BLOCK_INFO))) != 0) {
   1831  1.214        ad 			lfs_free(fs, blkiov, LFS_NB_BLKIOV);
   1832  1.214        ad 			return error;
   1833  1.214        ad 		}
   1834  1.214        ad 
   1835  1.214        ad 		mutex_enter(&lfs_lock);
   1836  1.214        ad 		++fs->lfs_sleepers;
   1837  1.214        ad 		mutex_exit(&lfs_lock);
   1838  1.214        ad 		if (ap->a_command == LFCNBMAPV)
   1839  1.214        ad 			error = lfs_bmapv(l->l_proc, fsidp, blkiov, blkcnt);
   1840  1.214        ad 		else /* LFCNMARKV */
   1841  1.214        ad 			error = lfs_markv(l->l_proc, fsidp, blkiov, blkcnt);
   1842  1.214        ad 		if (error == 0)
   1843  1.214        ad 			error = copyout(blkiov, blkvp.blkiov,
   1844  1.214        ad 					blkcnt * sizeof(BLOCK_INFO));
   1845  1.214        ad 		mutex_enter(&lfs_lock);
   1846  1.214        ad 		if (--fs->lfs_sleepers == 0)
   1847  1.214        ad 			wakeup(&fs->lfs_sleepers);
   1848  1.214        ad 		mutex_exit(&lfs_lock);
   1849  1.214        ad 		lfs_free(fs, blkiov, LFS_NB_BLKIOV);
   1850  1.214        ad 		return error;
   1851   1.92  perseant 
   1852   1.92  perseant 	    case LFCNRECLAIM:
   1853  1.214        ad 		/*
   1854  1.214        ad 		 * Flush dirops and write Ifile, allowing empty segments
   1855  1.214        ad 		 * to be immediately reclaimed.
   1856  1.214        ad 		 */
   1857  1.214        ad 		lfs_writer_enter(fs, "pndirop");
   1858  1.274  dholland 		off = lfs_sb_getoffset(fs);
   1859  1.214        ad 		lfs_seglock(fs, SEGM_FORCE_CKP | SEGM_CKP);
   1860  1.214        ad 		lfs_flush_dirops(fs);
   1861  1.214        ad 		LFS_CLEANERINFO(cip, fs, bp);
   1862  1.214        ad 		oclean = cip->clean;
   1863  1.214        ad 		LFS_SYNC_CLEANERINFO(cip, fs, bp, 1);
   1864  1.214        ad 		lfs_segwrite(ap->a_vp->v_mount, SEGM_FORCE_CKP);
   1865  1.214        ad 		fs->lfs_sp->seg_flags |= SEGM_PROT;
   1866  1.214        ad 		lfs_segunlock(fs);
   1867  1.214        ad 		lfs_writer_leave(fs);
   1868   1.92  perseant 
   1869  1.136  perseant #ifdef DEBUG
   1870  1.214        ad 		LFS_CLEANERINFO(cip, fs, bp);
   1871  1.214        ad 		DLOG((DLOG_CLEAN, "lfs_fcntl: reclaim wrote %" PRId64
   1872  1.214        ad 		      " blocks, cleaned %" PRId32 " segments (activesb %d)\n",
   1873  1.214        ad 		      fs->lfs_offset - off, cip->clean - oclean,
   1874  1.214        ad 		      fs->lfs_activesb));
   1875  1.214        ad 		LFS_SYNC_CLEANERINFO(cip, fs, bp, 0);
   1876  1.258  christos #else
   1877  1.258  christos 		__USE(oclean);
   1878  1.258  christos 		__USE(off);
   1879   1.92  perseant #endif
   1880   1.92  perseant 
   1881  1.214        ad 		return 0;
   1882   1.89  perseant 
   1883  1.182    martin 	    case LFCNIFILEFH_COMPAT:
   1884  1.214        ad 		/* Return the filehandle of the Ifile */
   1885  1.221      elad 		if ((error = kauth_authorize_system(l->l_cred,
   1886  1.221      elad 		    KAUTH_SYSTEM_FILEHANDLE, 0, NULL, NULL, NULL)) != 0)
   1887  1.214        ad 			return (error);
   1888  1.214        ad 		fhp = (struct fhandle *)ap->a_data;
   1889  1.214        ad 		fhp->fh_fsid = *fsidp;
   1890  1.214        ad 		fh_size = 16;	/* former VFS_MAXFIDSIZ */
   1891  1.214        ad 		return lfs_vptofh(fs->lfs_ivnode, &(fhp->fh_fid), &fh_size);
   1892  1.182    martin 
   1893  1.187    martin 	    case LFCNIFILEFH_COMPAT2:
   1894  1.134  perseant 	    case LFCNIFILEFH:
   1895  1.214        ad 		/* Return the filehandle of the Ifile */
   1896  1.214        ad 		fhp = (struct fhandle *)ap->a_data;
   1897  1.214        ad 		fhp->fh_fsid = *fsidp;
   1898  1.214        ad 		fh_size = sizeof(struct lfs_fhandle) -
   1899  1.214        ad 		    offsetof(fhandle_t, fh_fid);
   1900  1.214        ad 		return lfs_vptofh(fs->lfs_ivnode, &(fhp->fh_fid), &fh_size);
   1901  1.134  perseant 
   1902  1.148  perseant 	    case LFCNREWIND:
   1903  1.214        ad 		/* Move lfs_offset to the lowest-numbered segment */
   1904  1.214        ad 		return lfs_rewind(fs, *(int *)ap->a_data);
   1905  1.148  perseant 
   1906  1.148  perseant 	    case LFCNINVAL:
   1907  1.214        ad 		/* Mark a segment SEGUSE_INVAL */
   1908  1.214        ad 		LFS_SEGENTRY(sup, fs, *(int *)ap->a_data, bp);
   1909  1.214        ad 		if (sup->su_nbytes > 0) {
   1910  1.214        ad 			brelse(bp, 0);
   1911  1.214        ad 			lfs_unset_inval_all(fs);
   1912  1.214        ad 			return EBUSY;
   1913  1.214        ad 		}
   1914  1.214        ad 		sup->su_flags |= SEGUSE_INVAL;
   1915  1.236   hannken 		VOP_BWRITE(bp->b_vp, bp);
   1916  1.214        ad 		return 0;
   1917  1.148  perseant 
   1918  1.148  perseant 	    case LFCNRESIZE:
   1919  1.214        ad 		/* Resize the filesystem */
   1920  1.214        ad 		return lfs_resize_fs(fs, *(int *)ap->a_data);
   1921  1.148  perseant 
   1922  1.168  perseant 	    case LFCNWRAPSTOP:
   1923  1.179  perseant 	    case LFCNWRAPSTOP_COMPAT:
   1924  1.214        ad 		/*
   1925  1.214        ad 		 * Hold lfs_newseg at segment 0; if requested, sleep until
   1926  1.214        ad 		 * the filesystem wraps around.  To support external agents
   1927  1.214        ad 		 * (dump, fsck-based regression test) that need to look at
   1928  1.214        ad 		 * a snapshot of the filesystem, without necessarily
   1929  1.214        ad 		 * requiring that all fs activity stops.
   1930  1.214        ad 		 */
   1931  1.214        ad 		if (fs->lfs_stoplwp == curlwp)
   1932  1.214        ad 			return EALREADY;
   1933  1.214        ad 
   1934  1.214        ad 		mutex_enter(&lfs_lock);
   1935  1.214        ad 		while (fs->lfs_stoplwp != NULL)
   1936  1.214        ad 			cv_wait(&fs->lfs_stopcv, &lfs_lock);
   1937  1.214        ad 		fs->lfs_stoplwp = curlwp;
   1938  1.214        ad 		if (fs->lfs_nowrap == 0)
   1939  1.275  dholland 			log(LOG_NOTICE, "%s: disabled log wrap\n",
   1940  1.275  dholland 			    lfs_sb_getfsmnt(fs));
   1941  1.214        ad 		++fs->lfs_nowrap;
   1942  1.222  christos 		if (*(int *)ap->a_data == 1
   1943  1.224     pooka 		    || ap->a_command == LFCNWRAPSTOP_COMPAT) {
   1944  1.214        ad 			log(LOG_NOTICE, "LFCNSTOPWRAP waiting for log wrap\n");
   1945  1.214        ad 			error = mtsleep(&fs->lfs_nowrap, PCATCH | PUSER,
   1946  1.214        ad 				"segwrap", 0, &lfs_lock);
   1947  1.214        ad 			log(LOG_NOTICE, "LFCNSTOPWRAP done waiting\n");
   1948  1.214        ad 			if (error) {
   1949  1.214        ad 				lfs_wrapgo(fs, VTOI(ap->a_vp), 0);
   1950  1.214        ad 			}
   1951  1.214        ad 		}
   1952  1.214        ad 		mutex_exit(&lfs_lock);
   1953  1.214        ad 		return 0;
   1954  1.168  perseant 
   1955  1.168  perseant 	    case LFCNWRAPGO:
   1956  1.179  perseant 	    case LFCNWRAPGO_COMPAT:
   1957  1.214        ad 		/*
   1958  1.214        ad 		 * Having done its work, the agent wakes up the writer.
   1959  1.214        ad 		 * If the argument is 1, it sleeps until a new segment
   1960  1.214        ad 		 * is selected.
   1961  1.214        ad 		 */
   1962  1.214        ad 		mutex_enter(&lfs_lock);
   1963  1.214        ad 		error = lfs_wrapgo(fs, VTOI(ap->a_vp),
   1964  1.222  christos 				   ap->a_command == LFCNWRAPGO_COMPAT ? 1 :
   1965  1.222  christos 				    *((int *)ap->a_data));
   1966  1.214        ad 		mutex_exit(&lfs_lock);
   1967  1.214        ad 		return error;
   1968  1.168  perseant 
   1969  1.188  perseant 	    case LFCNWRAPPASS:
   1970  1.214        ad 		if ((VTOI(ap->a_vp)->i_lfs_iflags & LFSI_WRAPWAIT))
   1971  1.214        ad 			return EALREADY;
   1972  1.214        ad 		mutex_enter(&lfs_lock);
   1973  1.214        ad 		if (fs->lfs_stoplwp != curlwp) {
   1974  1.214        ad 			mutex_exit(&lfs_lock);
   1975  1.214        ad 			return EALREADY;
   1976  1.214        ad 		}
   1977  1.214        ad 		if (fs->lfs_nowrap == 0) {
   1978  1.214        ad 			mutex_exit(&lfs_lock);
   1979  1.214        ad 			return EBUSY;
   1980  1.214        ad 		}
   1981  1.214        ad 		fs->lfs_wrappass = 1;
   1982  1.214        ad 		wakeup(&fs->lfs_wrappass);
   1983  1.214        ad 		/* Wait for the log to wrap, if asked */
   1984  1.214        ad 		if (*(int *)ap->a_data) {
   1985  1.272   hannken 			vref(ap->a_vp);
   1986  1.214        ad 			VTOI(ap->a_vp)->i_lfs_iflags |= LFSI_WRAPWAIT;
   1987  1.214        ad 			log(LOG_NOTICE, "LFCNPASS waiting for log wrap\n");
   1988  1.214        ad 			error = mtsleep(&fs->lfs_nowrap, PCATCH | PUSER,
   1989  1.214        ad 				"segwrap", 0, &lfs_lock);
   1990  1.214        ad 			log(LOG_NOTICE, "LFCNPASS done waiting\n");
   1991  1.214        ad 			VTOI(ap->a_vp)->i_lfs_iflags &= ~LFSI_WRAPWAIT;
   1992  1.272   hannken 			vrele(ap->a_vp);
   1993  1.214        ad 		}
   1994  1.214        ad 		mutex_exit(&lfs_lock);
   1995  1.214        ad 		return error;
   1996  1.188  perseant 
   1997  1.188  perseant 	    case LFCNWRAPSTATUS:
   1998  1.214        ad 		mutex_enter(&lfs_lock);
   1999  1.214        ad 		*(int *)ap->a_data = fs->lfs_wrapstatus;
   2000  1.214        ad 		mutex_exit(&lfs_lock);
   2001  1.214        ad 		return 0;
   2002  1.188  perseant 
   2003   1.89  perseant 	    default:
   2004  1.245  dholland 		return ulfs_fcntl(v);
   2005   1.89  perseant 	}
   2006   1.89  perseant 	return 0;
   2007   1.60       chs }
   2008   1.60       chs 
   2009   1.84  perseant /*
   2010   1.84  perseant  * Return the last logical file offset that should be written for this file
   2011   1.86  perseant  * if we're doing a write that ends at "size".	If writing, we need to know
   2012   1.84  perseant  * about sizes on disk, i.e. fragments if there are any; if reading, we need
   2013   1.84  perseant  * to know about entire blocks.
   2014   1.84  perseant  */
   2015   1.84  perseant void
   2016   1.84  perseant lfs_gop_size(struct vnode *vp, off_t size, off_t *eobp, int flags)
   2017   1.84  perseant {
   2018   1.84  perseant 	struct inode *ip = VTOI(vp);
   2019  1.135     perry 	struct lfs *fs = ip->i_lfs;
   2020   1.84  perseant 	daddr_t olbn, nlbn;
   2021   1.84  perseant 
   2022  1.248  christos 	olbn = lfs_lblkno(fs, ip->i_size);
   2023  1.248  christos 	nlbn = lfs_lblkno(fs, size);
   2024  1.245  dholland 	if (!(flags & GOP_SIZE_MEM) && nlbn < ULFS_NDADDR && olbn <= nlbn) {
   2025  1.248  christos 		*eobp = lfs_fragroundup(fs, size);
   2026   1.86  perseant 	} else {
   2027  1.248  christos 		*eobp = lfs_blkroundup(fs, size);
   2028   1.86  perseant 	}
   2029   1.84  perseant }
   2030   1.84  perseant 
   2031   1.84  perseant #ifdef DEBUG
   2032   1.84  perseant void lfs_dump_vop(void *);
   2033   1.84  perseant 
   2034   1.84  perseant void
   2035   1.84  perseant lfs_dump_vop(void *v)
   2036   1.84  perseant {
   2037   1.86  perseant 	struct vop_putpages_args /* {
   2038   1.86  perseant 		struct vnode *a_vp;
   2039   1.86  perseant 		voff_t a_offlo;
   2040   1.86  perseant 		voff_t a_offhi;
   2041   1.86  perseant 		int a_flags;
   2042   1.86  perseant 	} */ *ap = v;
   2043   1.84  perseant 
   2044  1.106     ragge #ifdef DDB
   2045   1.84  perseant 	vfs_vnode_print(ap->a_vp, 0, printf);
   2046  1.106     ragge #endif
   2047  1.102      fvdl 	lfs_dump_dinode(VTOI(ap->a_vp)->i_din.ffs1_din);
   2048   1.84  perseant }
   2049   1.84  perseant #endif
   2050   1.84  perseant 
   2051   1.84  perseant int
   2052   1.84  perseant lfs_mmap(void *v)
   2053   1.84  perseant {
   2054   1.84  perseant 	struct vop_mmap_args /* {
   2055   1.86  perseant 		const struct vnodeop_desc *a_desc;
   2056   1.86  perseant 		struct vnode *a_vp;
   2057  1.209     pooka 		vm_prot_t a_prot;
   2058  1.176      elad 		kauth_cred_t a_cred;
   2059   1.84  perseant 	} */ *ap = v;
   2060   1.84  perseant 
   2061   1.84  perseant 	if (VTOI(ap->a_vp)->i_number == LFS_IFILE_INUM)
   2062   1.84  perseant 		return EOPNOTSUPP;
   2063  1.245  dholland 	return ulfs_mmap(v);
   2064   1.84  perseant }
   2065  1.254  dholland 
   2066  1.254  dholland static int
   2067  1.254  dholland lfs_openextattr(void *v)
   2068  1.254  dholland {
   2069  1.254  dholland 	struct vop_openextattr_args /* {
   2070  1.254  dholland 		struct vnode *a_vp;
   2071  1.254  dholland 		kauth_cred_t a_cred;
   2072  1.254  dholland 		struct proc *a_p;
   2073  1.254  dholland 	} */ *ap = v;
   2074  1.254  dholland 	struct inode *ip = VTOI(ap->a_vp);
   2075  1.254  dholland 	struct ulfsmount *ump = ip->i_ump;
   2076  1.254  dholland 	//struct lfs *fs = ip->i_lfs;
   2077  1.254  dholland 
   2078  1.254  dholland 	/* Not supported for ULFS1 file systems. */
   2079  1.254  dholland 	if (ump->um_fstype == ULFS1)
   2080  1.254  dholland 		return (EOPNOTSUPP);
   2081  1.254  dholland 
   2082  1.254  dholland 	/* XXX Not implemented for ULFS2 file systems. */
   2083  1.254  dholland 	return (EOPNOTSUPP);
   2084  1.254  dholland }
   2085  1.254  dholland 
   2086  1.254  dholland static int
   2087  1.254  dholland lfs_closeextattr(void *v)
   2088  1.254  dholland {
   2089  1.254  dholland 	struct vop_closeextattr_args /* {
   2090  1.254  dholland 		struct vnode *a_vp;
   2091  1.254  dholland 		int a_commit;
   2092  1.254  dholland 		kauth_cred_t a_cred;
   2093  1.254  dholland 		struct proc *a_p;
   2094  1.254  dholland 	} */ *ap = v;
   2095  1.254  dholland 	struct inode *ip = VTOI(ap->a_vp);
   2096  1.254  dholland 	struct ulfsmount *ump = ip->i_ump;
   2097  1.254  dholland 	//struct lfs *fs = ip->i_lfs;
   2098  1.254  dholland 
   2099  1.254  dholland 	/* Not supported for ULFS1 file systems. */
   2100  1.254  dholland 	if (ump->um_fstype == ULFS1)
   2101  1.254  dholland 		return (EOPNOTSUPP);
   2102  1.254  dholland 
   2103  1.254  dholland 	/* XXX Not implemented for ULFS2 file systems. */
   2104  1.254  dholland 	return (EOPNOTSUPP);
   2105  1.254  dholland }
   2106  1.254  dholland 
   2107  1.254  dholland static int
   2108  1.254  dholland lfs_getextattr(void *v)
   2109  1.254  dholland {
   2110  1.254  dholland 	struct vop_getextattr_args /* {
   2111  1.254  dholland 		struct vnode *a_vp;
   2112  1.254  dholland 		int a_attrnamespace;
   2113  1.254  dholland 		const char *a_name;
   2114  1.254  dholland 		struct uio *a_uio;
   2115  1.254  dholland 		size_t *a_size;
   2116  1.254  dholland 		kauth_cred_t a_cred;
   2117  1.254  dholland 		struct proc *a_p;
   2118  1.254  dholland 	} */ *ap = v;
   2119  1.254  dholland 	struct vnode *vp = ap->a_vp;
   2120  1.254  dholland 	struct inode *ip = VTOI(vp);
   2121  1.254  dholland 	struct ulfsmount *ump = ip->i_ump;
   2122  1.254  dholland 	//struct lfs *fs = ip->i_lfs;
   2123  1.254  dholland 	int error;
   2124  1.254  dholland 
   2125  1.254  dholland 	if (ump->um_fstype == ULFS1) {
   2126  1.254  dholland #ifdef LFS_EXTATTR
   2127  1.254  dholland 		fstrans_start(vp->v_mount, FSTRANS_SHARED);
   2128  1.254  dholland 		error = ulfs_getextattr(ap);
   2129  1.254  dholland 		fstrans_done(vp->v_mount);
   2130  1.254  dholland #else
   2131  1.254  dholland 		error = EOPNOTSUPP;
   2132  1.254  dholland #endif
   2133  1.254  dholland 		return error;
   2134  1.254  dholland 	}
   2135  1.254  dholland 
   2136  1.254  dholland 	/* XXX Not implemented for ULFS2 file systems. */
   2137  1.254  dholland 	return (EOPNOTSUPP);
   2138  1.254  dholland }
   2139  1.254  dholland 
   2140  1.254  dholland static int
   2141  1.254  dholland lfs_setextattr(void *v)
   2142  1.254  dholland {
   2143  1.254  dholland 	struct vop_setextattr_args /* {
   2144  1.254  dholland 		struct vnode *a_vp;
   2145  1.254  dholland 		int a_attrnamespace;
   2146  1.254  dholland 		const char *a_name;
   2147  1.254  dholland 		struct uio *a_uio;
   2148  1.254  dholland 		kauth_cred_t a_cred;
   2149  1.254  dholland 		struct proc *a_p;
   2150  1.254  dholland 	} */ *ap = v;
   2151  1.254  dholland 	struct vnode *vp = ap->a_vp;
   2152  1.254  dholland 	struct inode *ip = VTOI(vp);
   2153  1.254  dholland 	struct ulfsmount *ump = ip->i_ump;
   2154  1.254  dholland 	//struct lfs *fs = ip->i_lfs;
   2155  1.254  dholland 	int error;
   2156  1.254  dholland 
   2157  1.254  dholland 	if (ump->um_fstype == ULFS1) {
   2158  1.254  dholland #ifdef LFS_EXTATTR
   2159  1.254  dholland 		fstrans_start(vp->v_mount, FSTRANS_SHARED);
   2160  1.254  dholland 		error = ulfs_setextattr(ap);
   2161  1.254  dholland 		fstrans_done(vp->v_mount);
   2162  1.254  dholland #else
   2163  1.254  dholland 		error = EOPNOTSUPP;
   2164  1.254  dholland #endif
   2165  1.254  dholland 		return error;
   2166  1.254  dholland 	}
   2167  1.254  dholland 
   2168  1.254  dholland 	/* XXX Not implemented for ULFS2 file systems. */
   2169  1.254  dholland 	return (EOPNOTSUPP);
   2170  1.254  dholland }
   2171  1.254  dholland 
   2172  1.254  dholland static int
   2173  1.254  dholland lfs_listextattr(void *v)
   2174  1.254  dholland {
   2175  1.254  dholland 	struct vop_listextattr_args /* {
   2176  1.254  dholland 		struct vnode *a_vp;
   2177  1.254  dholland 		int a_attrnamespace;
   2178  1.254  dholland 		struct uio *a_uio;
   2179  1.254  dholland 		size_t *a_size;
   2180  1.254  dholland 		kauth_cred_t a_cred;
   2181  1.254  dholland 		struct proc *a_p;
   2182  1.254  dholland 	} */ *ap = v;
   2183  1.254  dholland 	struct vnode *vp = ap->a_vp;
   2184  1.254  dholland 	struct inode *ip = VTOI(vp);
   2185  1.254  dholland 	struct ulfsmount *ump = ip->i_ump;
   2186  1.254  dholland 	//struct lfs *fs = ip->i_lfs;
   2187  1.254  dholland 	int error;
   2188  1.254  dholland 
   2189  1.254  dholland 	if (ump->um_fstype == ULFS1) {
   2190  1.254  dholland #ifdef LFS_EXTATTR
   2191  1.254  dholland 		fstrans_start(vp->v_mount, FSTRANS_SHARED);
   2192  1.254  dholland 		error = ulfs_listextattr(ap);
   2193  1.254  dholland 		fstrans_done(vp->v_mount);
   2194  1.254  dholland #else
   2195  1.254  dholland 		error = EOPNOTSUPP;
   2196  1.254  dholland #endif
   2197  1.254  dholland 		return error;
   2198  1.254  dholland 	}
   2199  1.254  dholland 
   2200  1.254  dholland 	/* XXX Not implemented for ULFS2 file systems. */
   2201  1.254  dholland 	return (EOPNOTSUPP);
   2202  1.254  dholland }
   2203  1.254  dholland 
   2204  1.254  dholland static int
   2205  1.254  dholland lfs_deleteextattr(void *v)
   2206  1.254  dholland {
   2207  1.254  dholland 	struct vop_deleteextattr_args /* {
   2208  1.254  dholland 		struct vnode *a_vp;
   2209  1.254  dholland 		int a_attrnamespace;
   2210  1.254  dholland 		kauth_cred_t a_cred;
   2211  1.254  dholland 		struct proc *a_p;
   2212  1.254  dholland 	} */ *ap = v;
   2213  1.254  dholland 	struct vnode *vp = ap->a_vp;
   2214  1.254  dholland 	struct inode *ip = VTOI(vp);
   2215  1.254  dholland 	struct ulfsmount *ump = ip->i_ump;
   2216  1.254  dholland 	//struct fs *fs = ip->i_lfs;
   2217  1.254  dholland 	int error;
   2218  1.254  dholland 
   2219  1.254  dholland 	if (ump->um_fstype == ULFS1) {
   2220  1.254  dholland #ifdef LFS_EXTATTR
   2221  1.254  dholland 		fstrans_start(vp->v_mount, FSTRANS_SHARED);
   2222  1.254  dholland 		error = ulfs_deleteextattr(ap);
   2223  1.254  dholland 		fstrans_done(vp->v_mount);
   2224  1.254  dholland #else
   2225  1.254  dholland 		error = EOPNOTSUPP;
   2226  1.254  dholland #endif
   2227  1.254  dholland 		return error;
   2228  1.254  dholland 	}
   2229  1.254  dholland 
   2230  1.254  dholland 	/* XXX Not implemented for ULFS2 file systems. */
   2231  1.254  dholland 	return (EOPNOTSUPP);
   2232  1.254  dholland }
   2233