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