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