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