Home | History | Annotate | Line # | Download | only in lfs
lfs_vnops.c revision 1.103
      1  1.103  perseant /*	$NetBSD: lfs_vnops.c,v 1.103 2003/04/23 07:20:39 perseant 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  * 3. All advertising materials mentioning features or use of this software
     19   1.22  perseant  *    must display the following acknowledgement:
     20   1.86  perseant  *	This product includes software developed by the NetBSD
     21   1.86  perseant  *	Foundation, Inc. and its contributors.
     22   1.22  perseant  * 4. Neither the name of The NetBSD Foundation nor the names of its
     23   1.22  perseant  *    contributors may be used to endorse or promote products derived
     24   1.22  perseant  *    from this software without specific prior written permission.
     25   1.22  perseant  *
     26   1.22  perseant  * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
     27   1.22  perseant  * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
     28   1.22  perseant  * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
     29   1.22  perseant  * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
     30   1.22  perseant  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
     31   1.22  perseant  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
     32   1.22  perseant  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
     33   1.22  perseant  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
     34   1.22  perseant  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
     35   1.22  perseant  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
     36   1.22  perseant  * POSSIBILITY OF SUCH DAMAGE.
     37   1.22  perseant  */
     38    1.1   mycroft /*
     39   1.15      fvdl  * Copyright (c) 1986, 1989, 1991, 1993, 1995
     40    1.1   mycroft  *	The Regents of the University of California.  All rights reserved.
     41    1.1   mycroft  *
     42    1.1   mycroft  * Redistribution and use in source and binary forms, with or without
     43    1.1   mycroft  * modification, are permitted provided that the following conditions
     44    1.1   mycroft  * are met:
     45    1.1   mycroft  * 1. Redistributions of source code must retain the above copyright
     46    1.1   mycroft  *    notice, this list of conditions and the following disclaimer.
     47    1.1   mycroft  * 2. Redistributions in binary form must reproduce the above copyright
     48    1.1   mycroft  *    notice, this list of conditions and the following disclaimer in the
     49    1.1   mycroft  *    documentation and/or other materials provided with the distribution.
     50    1.1   mycroft  * 3. All advertising materials mentioning features or use of this software
     51    1.1   mycroft  *    must display the following acknowledgement:
     52    1.1   mycroft  *	This product includes software developed by the University of
     53    1.1   mycroft  *	California, Berkeley and its contributors.
     54    1.1   mycroft  * 4. Neither the name of the University nor the names of its contributors
     55    1.1   mycroft  *    may be used to endorse or promote products derived from this software
     56    1.1   mycroft  *    without specific prior written permission.
     57    1.1   mycroft  *
     58    1.1   mycroft  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     59    1.1   mycroft  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     60    1.1   mycroft  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     61    1.1   mycroft  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     62    1.1   mycroft  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     63    1.1   mycroft  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     64    1.1   mycroft  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     65    1.1   mycroft  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     66    1.1   mycroft  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     67    1.1   mycroft  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     68    1.1   mycroft  * SUCH DAMAGE.
     69    1.1   mycroft  *
     70   1.15      fvdl  *	@(#)lfs_vnops.c	8.13 (Berkeley) 6/10/95
     71    1.1   mycroft  */
     72   1.58     lukem 
     73   1.58     lukem #include <sys/cdefs.h>
     74  1.103  perseant __KERNEL_RCSID(0, "$NetBSD: lfs_vnops.c,v 1.103 2003/04/23 07:20:39 perseant Exp $");
     75   1.17  sommerfe 
     76    1.1   mycroft #include <sys/param.h>
     77    1.1   mycroft #include <sys/systm.h>
     78    1.1   mycroft #include <sys/namei.h>
     79    1.1   mycroft #include <sys/resourcevar.h>
     80    1.1   mycroft #include <sys/kernel.h>
     81    1.1   mycroft #include <sys/file.h>
     82    1.1   mycroft #include <sys/stat.h>
     83    1.1   mycroft #include <sys/buf.h>
     84    1.1   mycroft #include <sys/proc.h>
     85    1.1   mycroft #include <sys/mount.h>
     86    1.1   mycroft #include <sys/vnode.h>
     87    1.1   mycroft #include <sys/malloc.h>
     88   1.19   thorpej #include <sys/pool.h>
     89   1.10  christos #include <sys/signalvar.h>
     90    1.1   mycroft 
     91   1.12   mycroft #include <miscfs/fifofs/fifo.h>
     92   1.12   mycroft #include <miscfs/genfs/genfs.h>
     93    1.1   mycroft #include <miscfs/specfs/specdev.h>
     94    1.1   mycroft 
     95    1.1   mycroft #include <ufs/ufs/inode.h>
     96    1.1   mycroft #include <ufs/ufs/dir.h>
     97    1.1   mycroft #include <ufs/ufs/ufsmount.h>
     98    1.1   mycroft #include <ufs/ufs/ufs_extern.h>
     99    1.1   mycroft 
    100   1.84  perseant #include <uvm/uvm.h>
    101   1.95  perseant #include <uvm/uvm_pmap.h>
    102   1.95  perseant #include <uvm/uvm_stat.h>
    103   1.95  perseant #include <uvm/uvm_pager.h>
    104   1.84  perseant 
    105    1.1   mycroft #include <ufs/lfs/lfs.h>
    106    1.1   mycroft #include <ufs/lfs/lfs_extern.h>
    107    1.1   mycroft 
    108   1.91      yamt extern pid_t lfs_writer_daemon;
    109   1.84  perseant extern int lfs_subsys_pages;
    110   1.96  perseant extern int lfs_dirvcount;
    111   1.96  perseant extern struct simplelock lfs_subsys_lock;
    112   1.84  perseant 
    113    1.1   mycroft /* Global vfs data structures for lfs. */
    114   1.51  perseant int (**lfs_vnodeop_p)(void *);
    115   1.50  jdolecek const struct vnodeopv_entry_desc lfs_vnodeop_entries[] = {
    116    1.1   mycroft 	{ &vop_default_desc, vn_default_error },
    117    1.1   mycroft 	{ &vop_lookup_desc, ufs_lookup },		/* lookup */
    118   1.22  perseant 	{ &vop_create_desc, lfs_create },		/* create */
    119   1.82      yamt 	{ &vop_whiteout_desc, ufs_whiteout },		/* whiteout */
    120   1.22  perseant 	{ &vop_mknod_desc, lfs_mknod },			/* mknod */
    121    1.1   mycroft 	{ &vop_open_desc, ufs_open },			/* open */
    122    1.1   mycroft 	{ &vop_close_desc, lfs_close },			/* close */
    123    1.1   mycroft 	{ &vop_access_desc, ufs_access },		/* access */
    124    1.1   mycroft 	{ &vop_getattr_desc, lfs_getattr },		/* getattr */
    125   1.61  perseant 	{ &vop_setattr_desc, lfs_setattr },		/* setattr */
    126    1.1   mycroft 	{ &vop_read_desc, lfs_read },			/* read */
    127    1.1   mycroft 	{ &vop_write_desc, lfs_write },			/* write */
    128    1.4   mycroft 	{ &vop_lease_desc, ufs_lease_check },		/* lease */
    129   1.90  perseant 	{ &vop_ioctl_desc, ufs_ioctl },			/* ioctl */
    130   1.90  perseant 	{ &vop_fcntl_desc, lfs_fcntl },			/* fcntl */
    131   1.13   mycroft 	{ &vop_poll_desc, ufs_poll },			/* poll */
    132   1.68  jdolecek 	{ &vop_kqfilter_desc, genfs_kqfilter },		/* kqfilter */
    133   1.15      fvdl 	{ &vop_revoke_desc, ufs_revoke },		/* revoke */
    134   1.84  perseant 	{ &vop_mmap_desc, lfs_mmap },			/* mmap */
    135    1.1   mycroft 	{ &vop_fsync_desc, lfs_fsync },			/* fsync */
    136    1.1   mycroft 	{ &vop_seek_desc, ufs_seek },			/* seek */
    137   1.22  perseant 	{ &vop_remove_desc, lfs_remove },		/* remove */
    138   1.22  perseant 	{ &vop_link_desc, lfs_link },			/* link */
    139   1.22  perseant 	{ &vop_rename_desc, lfs_rename },		/* rename */
    140   1.22  perseant 	{ &vop_mkdir_desc, lfs_mkdir },			/* mkdir */
    141   1.22  perseant 	{ &vop_rmdir_desc, lfs_rmdir },			/* rmdir */
    142   1.22  perseant 	{ &vop_symlink_desc, lfs_symlink },		/* symlink */
    143    1.1   mycroft 	{ &vop_readdir_desc, ufs_readdir },		/* readdir */
    144    1.1   mycroft 	{ &vop_readlink_desc, ufs_readlink },		/* readlink */
    145    1.1   mycroft 	{ &vop_abortop_desc, ufs_abortop },		/* abortop */
    146   1.40  perseant 	{ &vop_inactive_desc, lfs_inactive },		/* inactive */
    147    1.1   mycroft 	{ &vop_reclaim_desc, lfs_reclaim },		/* reclaim */
    148    1.1   mycroft 	{ &vop_lock_desc, ufs_lock },			/* lock */
    149    1.1   mycroft 	{ &vop_unlock_desc, ufs_unlock },		/* unlock */
    150    1.1   mycroft 	{ &vop_bmap_desc, ufs_bmap },			/* bmap */
    151   1.94  perseant 	{ &vop_strategy_desc, lfs_strategy },		/* strategy */
    152    1.1   mycroft 	{ &vop_print_desc, ufs_print },			/* print */
    153    1.1   mycroft 	{ &vop_islocked_desc, ufs_islocked },		/* islocked */
    154    1.1   mycroft 	{ &vop_pathconf_desc, ufs_pathconf },		/* pathconf */
    155    1.1   mycroft 	{ &vop_advlock_desc, ufs_advlock },		/* advlock */
    156    1.1   mycroft 	{ &vop_blkatoff_desc, lfs_blkatoff },		/* blkatoff */
    157    1.1   mycroft 	{ &vop_valloc_desc, lfs_valloc },		/* valloc */
    158   1.32      fvdl 	{ &vop_balloc_desc, lfs_balloc },		/* balloc */
    159    1.1   mycroft 	{ &vop_vfree_desc, lfs_vfree },			/* vfree */
    160    1.1   mycroft 	{ &vop_truncate_desc, lfs_truncate },		/* truncate */
    161    1.1   mycroft 	{ &vop_update_desc, lfs_update },		/* update */
    162    1.1   mycroft 	{ &vop_bwrite_desc, lfs_bwrite },		/* bwrite */
    163   1.60       chs 	{ &vop_getpages_desc, lfs_getpages },		/* getpages */
    164   1.60       chs 	{ &vop_putpages_desc, lfs_putpages },		/* putpages */
    165   1.53       chs 	{ NULL, NULL }
    166    1.1   mycroft };
    167   1.50  jdolecek const struct vnodeopv_desc lfs_vnodeop_opv_desc =
    168    1.1   mycroft 	{ &lfs_vnodeop_p, lfs_vnodeop_entries };
    169    1.1   mycroft 
    170   1.51  perseant int (**lfs_specop_p)(void *);
    171   1.50  jdolecek const struct vnodeopv_entry_desc lfs_specop_entries[] = {
    172    1.1   mycroft 	{ &vop_default_desc, vn_default_error },
    173    1.1   mycroft 	{ &vop_lookup_desc, spec_lookup },		/* lookup */
    174    1.1   mycroft 	{ &vop_create_desc, spec_create },		/* create */
    175    1.1   mycroft 	{ &vop_mknod_desc, spec_mknod },		/* mknod */
    176    1.1   mycroft 	{ &vop_open_desc, spec_open },			/* open */
    177   1.65  perseant 	{ &vop_close_desc, lfsspec_close },		/* close */
    178    1.1   mycroft 	{ &vop_access_desc, ufs_access },		/* access */
    179    1.1   mycroft 	{ &vop_getattr_desc, lfs_getattr },		/* getattr */
    180   1.61  perseant 	{ &vop_setattr_desc, lfs_setattr },		/* setattr */
    181    1.1   mycroft 	{ &vop_read_desc, ufsspec_read },		/* read */
    182    1.1   mycroft 	{ &vop_write_desc, ufsspec_write },		/* write */
    183    1.4   mycroft 	{ &vop_lease_desc, spec_lease_check },		/* lease */
    184    1.1   mycroft 	{ &vop_ioctl_desc, spec_ioctl },		/* ioctl */
    185   1.27  wrstuden 	{ &vop_fcntl_desc, ufs_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.1   mycroft 	{ &vop_lock_desc, ufs_lock },			/* lock */
    204    1.1   mycroft 	{ &vop_unlock_desc, ufs_unlock },		/* unlock */
    205    1.1   mycroft 	{ &vop_bmap_desc, spec_bmap },			/* bmap */
    206    1.1   mycroft 	{ &vop_strategy_desc, spec_strategy },		/* strategy */
    207    1.1   mycroft 	{ &vop_print_desc, ufs_print },			/* print */
    208    1.1   mycroft 	{ &vop_islocked_desc, ufs_islocked },		/* islocked */
    209    1.1   mycroft 	{ &vop_pathconf_desc, spec_pathconf },		/* pathconf */
    210    1.1   mycroft 	{ &vop_advlock_desc, spec_advlock },		/* advlock */
    211    1.1   mycroft 	{ &vop_blkatoff_desc, spec_blkatoff },		/* blkatoff */
    212    1.1   mycroft 	{ &vop_valloc_desc, spec_valloc },		/* valloc */
    213    1.1   mycroft 	{ &vop_vfree_desc, lfs_vfree },			/* vfree */
    214    1.1   mycroft 	{ &vop_truncate_desc, spec_truncate },		/* truncate */
    215    1.1   mycroft 	{ &vop_update_desc, lfs_update },		/* update */
    216   1.28  perseant 	{ &vop_bwrite_desc, vn_bwrite },		/* bwrite */
    217   1.53       chs 	{ &vop_getpages_desc, spec_getpages },		/* getpages */
    218   1.53       chs 	{ &vop_putpages_desc, spec_putpages },		/* putpages */
    219   1.53       chs 	{ NULL, NULL }
    220    1.1   mycroft };
    221   1.50  jdolecek const struct vnodeopv_desc lfs_specop_opv_desc =
    222    1.1   mycroft 	{ &lfs_specop_p, lfs_specop_entries };
    223    1.1   mycroft 
    224   1.51  perseant int (**lfs_fifoop_p)(void *);
    225   1.50  jdolecek const struct vnodeopv_entry_desc lfs_fifoop_entries[] = {
    226    1.1   mycroft 	{ &vop_default_desc, vn_default_error },
    227    1.1   mycroft 	{ &vop_lookup_desc, fifo_lookup },		/* lookup */
    228    1.1   mycroft 	{ &vop_create_desc, fifo_create },		/* create */
    229    1.1   mycroft 	{ &vop_mknod_desc, fifo_mknod },		/* mknod */
    230    1.1   mycroft 	{ &vop_open_desc, fifo_open },			/* open */
    231   1.65  perseant 	{ &vop_close_desc, lfsfifo_close },		/* close */
    232    1.1   mycroft 	{ &vop_access_desc, ufs_access },		/* access */
    233    1.1   mycroft 	{ &vop_getattr_desc, lfs_getattr },		/* getattr */
    234   1.61  perseant 	{ &vop_setattr_desc, lfs_setattr },		/* setattr */
    235    1.1   mycroft 	{ &vop_read_desc, ufsfifo_read },		/* read */
    236    1.1   mycroft 	{ &vop_write_desc, ufsfifo_write },		/* write */
    237    1.4   mycroft 	{ &vop_lease_desc, fifo_lease_check },		/* lease */
    238    1.1   mycroft 	{ &vop_ioctl_desc, fifo_ioctl },		/* ioctl */
    239   1.27  wrstuden 	{ &vop_fcntl_desc, ufs_fcntl },			/* fcntl */
    240   1.13   mycroft 	{ &vop_poll_desc, fifo_poll },			/* poll */
    241   1.68  jdolecek 	{ &vop_kqfilter_desc, fifo_kqfilter },		/* kqfilter */
    242   1.15      fvdl 	{ &vop_revoke_desc, fifo_revoke },		/* revoke */
    243    1.1   mycroft 	{ &vop_mmap_desc, fifo_mmap },			/* mmap */
    244    1.1   mycroft 	{ &vop_fsync_desc, fifo_fsync },		/* fsync */
    245    1.1   mycroft 	{ &vop_seek_desc, fifo_seek },			/* seek */
    246    1.1   mycroft 	{ &vop_remove_desc, fifo_remove },		/* remove */
    247    1.1   mycroft 	{ &vop_link_desc, fifo_link },			/* link */
    248    1.1   mycroft 	{ &vop_rename_desc, fifo_rename },		/* rename */
    249    1.1   mycroft 	{ &vop_mkdir_desc, fifo_mkdir },		/* mkdir */
    250    1.1   mycroft 	{ &vop_rmdir_desc, fifo_rmdir },		/* rmdir */
    251    1.1   mycroft 	{ &vop_symlink_desc, fifo_symlink },		/* symlink */
    252    1.1   mycroft 	{ &vop_readdir_desc, fifo_readdir },		/* readdir */
    253    1.1   mycroft 	{ &vop_readlink_desc, fifo_readlink },		/* readlink */
    254    1.1   mycroft 	{ &vop_abortop_desc, fifo_abortop },		/* abortop */
    255   1.40  perseant 	{ &vop_inactive_desc, lfs_inactive },		/* inactive */
    256    1.1   mycroft 	{ &vop_reclaim_desc, lfs_reclaim },		/* reclaim */
    257    1.1   mycroft 	{ &vop_lock_desc, ufs_lock },			/* lock */
    258    1.1   mycroft 	{ &vop_unlock_desc, ufs_unlock },		/* unlock */
    259    1.1   mycroft 	{ &vop_bmap_desc, fifo_bmap },			/* bmap */
    260    1.1   mycroft 	{ &vop_strategy_desc, fifo_strategy },		/* strategy */
    261    1.1   mycroft 	{ &vop_print_desc, ufs_print },			/* print */
    262    1.1   mycroft 	{ &vop_islocked_desc, ufs_islocked },		/* islocked */
    263    1.1   mycroft 	{ &vop_pathconf_desc, fifo_pathconf },		/* pathconf */
    264    1.1   mycroft 	{ &vop_advlock_desc, fifo_advlock },		/* advlock */
    265    1.1   mycroft 	{ &vop_blkatoff_desc, fifo_blkatoff },		/* blkatoff */
    266    1.1   mycroft 	{ &vop_valloc_desc, fifo_valloc },		/* valloc */
    267    1.1   mycroft 	{ &vop_vfree_desc, lfs_vfree },			/* vfree */
    268    1.1   mycroft 	{ &vop_truncate_desc, fifo_truncate },		/* truncate */
    269    1.1   mycroft 	{ &vop_update_desc, lfs_update },		/* update */
    270    1.1   mycroft 	{ &vop_bwrite_desc, lfs_bwrite },		/* bwrite */
    271   1.86  perseant 	{ &vop_putpages_desc, fifo_putpages },		/* putpages */
    272   1.53       chs 	{ NULL, NULL }
    273    1.1   mycroft };
    274   1.50  jdolecek const struct vnodeopv_desc lfs_fifoop_opv_desc =
    275    1.1   mycroft 	{ &lfs_fifoop_p, lfs_fifoop_entries };
    276    1.1   mycroft 
    277   1.43  perseant /*
    278   1.43  perseant  * A function version of LFS_ITIMES, for the UFS functions which call ITIMES
    279   1.43  perseant  */
    280   1.43  perseant void
    281   1.51  perseant lfs_itimes(struct inode *ip, struct timespec *acc, struct timespec *mod, struct timespec *cre)
    282   1.43  perseant {
    283   1.43  perseant 	LFS_ITIMES(ip, acc, mod, cre);
    284   1.43  perseant }
    285   1.43  perseant 
    286    1.1   mycroft #define	LFS_READWRITE
    287    1.1   mycroft #include <ufs/ufs/ufs_readwrite.c>
    288    1.1   mycroft #undef	LFS_READWRITE
    289    1.1   mycroft 
    290    1.1   mycroft /*
    291    1.1   mycroft  * Synch an open file.
    292    1.1   mycroft  */
    293    1.1   mycroft /* ARGSUSED */
    294   1.10  christos int
    295   1.51  perseant lfs_fsync(void *v)
    296   1.10  christos {
    297    1.1   mycroft 	struct vop_fsync_args /* {
    298    1.1   mycroft 		struct vnode *a_vp;
    299    1.1   mycroft 		struct ucred *a_cred;
    300   1.22  perseant 		int a_flags;
    301   1.49    toshii 		off_t offlo;
    302   1.49    toshii 		off_t offhi;
    303    1.1   mycroft 		struct proc *a_p;
    304   1.10  christos 	} */ *ap = v;
    305   1.60       chs 	struct vnode *vp = ap->a_vp;
    306   1.84  perseant 	int error, wait;
    307   1.84  perseant 
    308   1.86  perseant 	/*
    309   1.84  perseant 	 * Trickle sync checks for need to do a checkpoint after possible
    310   1.84  perseant 	 * activity from the pagedaemon.
    311   1.86  perseant 	 */
    312   1.84  perseant 	if (ap->a_flags & FSYNC_LAZY) {
    313   1.84  perseant 		wakeup(&lfs_writer_daemon);
    314   1.47  perseant 		return 0;
    315   1.84  perseant 	}
    316   1.47  perseant 
    317   1.84  perseant 	wait = (ap->a_flags & FSYNC_WAIT);
    318  1.103  perseant 	simple_lock(&vp->v_interlock);
    319  1.103  perseant 	error = VOP_PUTPAGES(vp, trunc_page(ap->a_offlo),
    320  1.103  perseant 			round_page(ap->a_offhi),
    321  1.103  perseant 			PGO_CLEANIT | (wait ? PGO_SYNCIO : 0));
    322  1.103  perseant 	if (error)
    323  1.103  perseant 		return error;
    324  1.103  perseant 	error = VOP_UPDATE(vp, NULL, NULL, wait ? UPDATE_WAIT : 0);
    325  1.103  perseant 	if (wait && !VPISEMPTY(vp))
    326  1.103  perseant 		LFS_SET_UINO(VTOI(vp), IN_MODIFIED);
    327   1.84  perseant 
    328   1.63  perseant 	return error;
    329    1.1   mycroft }
    330    1.1   mycroft 
    331    1.1   mycroft /*
    332   1.40  perseant  * Take IN_ADIROP off, then call ufs_inactive.
    333   1.40  perseant  */
    334   1.40  perseant int
    335   1.51  perseant lfs_inactive(void *v)
    336   1.40  perseant {
    337   1.40  perseant 	struct vop_inactive_args /* {
    338   1.40  perseant 		struct vnode *a_vp;
    339   1.40  perseant 		struct proc *a_p;
    340   1.40  perseant 	} */ *ap = v;
    341   1.72      yamt 
    342  1.102      fvdl 	KASSERT(VTOI(ap->a_vp)->i_nlink == VTOI(ap->a_vp)->i_ffs_effnlink);
    343   1.77      yamt 
    344   1.76      yamt 	lfs_unmark_vnode(ap->a_vp);
    345   1.76      yamt 
    346   1.97  perseant 	/*
    347   1.97  perseant 	 * The Ifile is only ever inactivated on unmount.
    348   1.97  perseant 	 * Streamline this process by not giving it more dirty blocks.
    349   1.97  perseant 	 */
    350   1.97  perseant 	if (VTOI(ap->a_vp)->i_number == LFS_IFILE_INUM) {
    351   1.97  perseant 		LFS_CLR_UINO(VTOI(ap->a_vp), IN_ALLMOD);
    352   1.99  perseant 		VOP_UNLOCK(ap->a_vp, 0);
    353   1.97  perseant 		return 0;
    354   1.97  perseant 	}
    355   1.97  perseant 
    356   1.75      yamt 	return ufs_inactive(v);
    357   1.40  perseant }
    358   1.40  perseant 
    359   1.40  perseant /*
    360    1.1   mycroft  * These macros are used to bracket UFS directory ops, so that we can
    361    1.1   mycroft  * identify all the pages touched during directory ops which need to
    362    1.1   mycroft  * be ordered and flushed atomically, so that they may be recovered.
    363    1.1   mycroft  */
    364   1.22  perseant /*
    365   1.22  perseant  * XXX KS - Because we have to mark nodes VDIROP in order to prevent
    366   1.22  perseant  * the cache from reclaiming them while a dirop is in progress, we must
    367   1.22  perseant  * also manage the number of nodes so marked (otherwise we can run out).
    368   1.22  perseant  * We do this by setting lfs_dirvcount to the number of marked vnodes; it
    369   1.22  perseant  * is decremented during segment write, when VDIROP is taken off.
    370   1.22  perseant  */
    371   1.71      yamt #define	SET_DIROP(vp)		SET_DIROP2((vp), NULL)
    372   1.71      yamt #define	SET_DIROP2(vp, vp2)	lfs_set_dirop((vp), (vp2))
    373   1.71      yamt static int lfs_set_dirop(struct vnode *, struct vnode *);
    374   1.31  perseant extern int lfs_dirvcount;
    375   1.84  perseant extern int lfs_do_flush;
    376   1.24  perseant 
    377   1.70      yamt #define	NRESERVE(fs)	(btofsb(fs, (NIADDR + 3 + (2 * NIADDR + 3)) << fs->lfs_bshift))
    378   1.70      yamt 
    379   1.46  perseant static int
    380   1.71      yamt lfs_set_dirop(struct vnode *vp, struct vnode *vp2)
    381   1.40  perseant {
    382   1.24  perseant 	struct lfs *fs;
    383   1.24  perseant 	int error;
    384   1.24  perseant 
    385   1.71      yamt 	KASSERT(VOP_ISLOCKED(vp));
    386   1.71      yamt 	KASSERT(vp2 == NULL || VOP_ISLOCKED(vp2));
    387   1.71      yamt 
    388   1.40  perseant 	fs = VTOI(vp)->i_lfs;
    389   1.44  perseant 	/*
    390   1.44  perseant 	 * We might need one directory block plus supporting indirect blocks,
    391   1.44  perseant 	 * plus an inode block and ifile page for the new vnode.
    392   1.44  perseant 	 */
    393   1.71      yamt 	if ((error = lfs_reserve(fs, vp, vp2, NRESERVE(fs))) != 0)
    394   1.44  perseant 		return (error);
    395   1.70      yamt 
    396   1.40  perseant 	if (fs->lfs_dirops == 0)
    397   1.40  perseant 		lfs_check(vp, LFS_UNUSED_LBN, 0);
    398   1.84  perseant 	while (fs->lfs_writer || lfs_dirvcount > LFS_MAX_DIROP) {
    399   1.59       chs 		if (fs->lfs_writer)
    400   1.63  perseant 			tsleep(&fs->lfs_dirops, PRIBIO + 1, "lfs_sdirop", 0);
    401   1.84  perseant 		if (lfs_dirvcount > LFS_MAX_DIROP && fs->lfs_dirops == 0) {
    402   1.84  perseant 			wakeup(&lfs_writer_daemon);
    403   1.84  perseant 			preempt(NULL);
    404   1.33  perseant 		}
    405   1.33  perseant 
    406   1.84  perseant 		if (lfs_dirvcount > LFS_MAX_DIROP) {
    407   1.24  perseant #ifdef DEBUG_LFS
    408   1.44  perseant 			printf("lfs_set_dirop: sleeping with dirops=%d, "
    409   1.44  perseant 			       "dirvcount=%d\n", fs->lfs_dirops,
    410   1.44  perseant 			       lfs_dirvcount);
    411   1.24  perseant #endif
    412   1.59       chs 			if ((error = tsleep(&lfs_dirvcount, PCATCH|PUSER,
    413   1.59       chs 					   "lfs_maxdirop", 0)) != 0) {
    414   1.70      yamt 				goto unreserve;
    415   1.44  perseant 			}
    416   1.24  perseant 		}
    417   1.24  perseant 	}
    418   1.24  perseant 	++fs->lfs_dirops;
    419   1.24  perseant 	fs->lfs_doifile = 1;
    420   1.24  perseant 
    421   1.46  perseant 	/* Hold a reference so SET_ENDOP will be happy */
    422   1.78      yamt 	vref(vp);
    423   1.78      yamt 	if (vp2)
    424   1.78      yamt 		vref(vp2);
    425   1.46  perseant 
    426   1.24  perseant 	return 0;
    427   1.70      yamt 
    428   1.70      yamt unreserve:
    429   1.71      yamt 	lfs_reserve(fs, vp, vp2, -NRESERVE(fs));
    430   1.70      yamt 	return error;
    431    1.1   mycroft }
    432    1.1   mycroft 
    433   1.71      yamt #define	SET_ENDOP(fs, vp, str)	SET_ENDOP2((fs), (vp), NULL, (str))
    434   1.71      yamt #define	SET_ENDOP2(fs, vp, vp2, str) {					\
    435    1.1   mycroft 	--(fs)->lfs_dirops;						\
    436   1.22  perseant 	if (!(fs)->lfs_dirops) {					\
    437   1.40  perseant 		if ((fs)->lfs_nadirop) {				\
    438   1.67    provos 			panic("SET_ENDOP: %s: no dirops but nadirop=%d", \
    439   1.40  perseant 			      (str), (fs)->lfs_nadirop);		\
    440   1.40  perseant 		}							\
    441    1.1   mycroft 		wakeup(&(fs)->lfs_writer);				\
    442   1.26  perseant 		lfs_check((vp),LFS_UNUSED_LBN,0);			\
    443   1.22  perseant 	}								\
    444   1.71      yamt 	lfs_reserve((fs), vp, vp2, -NRESERVE(fs)); /* XXX */		\
    445   1.78      yamt 	vrele(vp);							\
    446   1.78      yamt 	if (vp2)							\
    447   1.78      yamt 		vrele(vp2);						\
    448    1.1   mycroft }
    449    1.1   mycroft 
    450   1.86  perseant #define	MARK_VNODE(dvp)	 do {						\
    451   1.84  perseant 	struct inode *_ip = VTOI(dvp);					\
    452   1.84  perseant 	struct lfs *_fs = _ip->i_lfs;					\
    453   1.84  perseant 									\
    454   1.86  perseant 	if (!((dvp)->v_flag & VDIROP)) {				\
    455   1.86  perseant 		(void)lfs_vref(dvp);					\
    456   1.31  perseant 		++lfs_dirvcount;					\
    457   1.84  perseant 		TAILQ_INSERT_TAIL(&_fs->lfs_dchainhd, _ip, i_lfs_dchain); \
    458   1.22  perseant 	}								\
    459   1.86  perseant 	(dvp)->v_flag |= VDIROP;					\
    460   1.84  perseant 	if (!(_ip->i_flag & IN_ADIROP)) {				\
    461   1.84  perseant 		++_fs->lfs_nadirop;					\
    462   1.37  perseant 	}								\
    463   1.84  perseant 	_ip->i_flag |= IN_ADIROP;					\
    464   1.59       chs } while (0)
    465   1.37  perseant 
    466   1.40  perseant #define UNMARK_VNODE(vp) lfs_unmark_vnode(vp)
    467   1.40  perseant 
    468   1.51  perseant void lfs_unmark_vnode(struct vnode *vp)
    469   1.40  perseant {
    470   1.40  perseant 	struct inode *ip;
    471   1.40  perseant 
    472   1.40  perseant 	ip = VTOI(vp);
    473   1.40  perseant 
    474   1.40  perseant 	if (ip->i_flag & IN_ADIROP)
    475   1.40  perseant 		--ip->i_lfs->lfs_nadirop;
    476   1.40  perseant 	ip->i_flag &= ~IN_ADIROP;
    477   1.40  perseant }
    478   1.15      fvdl 
    479    1.1   mycroft int
    480   1.51  perseant lfs_symlink(void *v)
    481   1.10  christos {
    482    1.1   mycroft 	struct vop_symlink_args /* {
    483    1.1   mycroft 		struct vnode *a_dvp;
    484    1.1   mycroft 		struct vnode **a_vpp;
    485    1.1   mycroft 		struct componentname *a_cnp;
    486    1.1   mycroft 		struct vattr *a_vap;
    487    1.1   mycroft 		char *a_target;
    488   1.10  christos 	} */ *ap = v;
    489   1.37  perseant 	int error;
    490    1.1   mycroft 
    491   1.40  perseant 	if ((error = SET_DIROP(ap->a_dvp)) != 0) {
    492   1.34  perseant 		vput(ap->a_dvp);
    493   1.37  perseant 		return error;
    494   1.34  perseant 	}
    495    1.1   mycroft 	MARK_VNODE(ap->a_dvp);
    496   1.37  perseant 	error = ufs_symlink(ap);
    497   1.37  perseant 	UNMARK_VNODE(ap->a_dvp);
    498   1.40  perseant 	if (*(ap->a_vpp))
    499   1.37  perseant 		UNMARK_VNODE(*(ap->a_vpp));
    500   1.37  perseant 	SET_ENDOP(VTOI(ap->a_dvp)->i_lfs,ap->a_dvp,"symlink");
    501   1.37  perseant 	return (error);
    502    1.1   mycroft }
    503    1.1   mycroft 
    504    1.1   mycroft int
    505   1.51  perseant lfs_mknod(void *v)
    506   1.10  christos {
    507   1.22  perseant 	struct vop_mknod_args	/* {
    508    1.1   mycroft 		struct vnode *a_dvp;
    509    1.1   mycroft 		struct vnode **a_vpp;
    510    1.1   mycroft 		struct componentname *a_cnp;
    511    1.1   mycroft 		struct vattr *a_vap;
    512   1.22  perseant 		} */ *ap = v;
    513   1.86  perseant 	struct vattr *vap = ap->a_vap;
    514   1.86  perseant 	struct vnode **vpp = ap->a_vpp;
    515   1.86  perseant 	struct inode *ip;
    516   1.86  perseant 	int error;
    517   1.52     assar 	struct mount	*mp;
    518   1.52     assar 	ino_t		ino;
    519    1.1   mycroft 
    520   1.40  perseant 	if ((error = SET_DIROP(ap->a_dvp)) != 0) {
    521   1.34  perseant 		vput(ap->a_dvp);
    522   1.28  perseant 		return error;
    523   1.34  perseant 	}
    524    1.1   mycroft 	MARK_VNODE(ap->a_dvp);
    525   1.28  perseant 	error = ufs_makeinode(MAKEIMODE(vap->va_type, vap->va_mode),
    526   1.86  perseant 	    ap->a_dvp, vpp, ap->a_cnp);
    527   1.37  perseant 	UNMARK_VNODE(ap->a_dvp);
    528   1.86  perseant 	if (*(ap->a_vpp))
    529   1.86  perseant 		UNMARK_VNODE(*(ap->a_vpp));
    530   1.28  perseant 
    531   1.28  perseant 	/* Either way we're done with the dirop at this point */
    532   1.26  perseant 	SET_ENDOP(VTOI(ap->a_dvp)->i_lfs,ap->a_dvp,"mknod");
    533   1.28  perseant 
    534   1.86  perseant 	if (error)
    535   1.28  perseant 		return (error);
    536   1.28  perseant 
    537   1.86  perseant 	ip = VTOI(*vpp);
    538   1.52     assar 	mp  = (*vpp)->v_mount;
    539   1.52     assar 	ino = ip->i_number;
    540   1.86  perseant 	ip->i_flag |= IN_ACCESS | IN_CHANGE | IN_UPDATE;
    541   1.86  perseant 	if (vap->va_rdev != VNOVAL) {
    542   1.86  perseant 		/*
    543   1.86  perseant 		 * Want to be able to use this to make badblock
    544   1.86  perseant 		 * inodes, so don't truncate the dev number.
    545   1.86  perseant 		 */
    546   1.28  perseant #if 0
    547  1.102      fvdl 		ip->i_ffs1_rdev = ufs_rw32(vap->va_rdev,
    548   1.86  perseant 		    UFS_MPNEEDSWAP((*vpp)->v_mount));
    549   1.28  perseant #else
    550  1.102      fvdl 		ip->i_ffs1_rdev = vap->va_rdev;
    551   1.28  perseant #endif
    552   1.86  perseant 	}
    553   1.28  perseant 	/*
    554   1.28  perseant 	 * Call fsync to write the vnode so that we don't have to deal with
    555   1.28  perseant 	 * flushing it when it's marked VDIROP|VXLOCK.
    556   1.28  perseant 	 *
    557   1.28  perseant 	 * XXX KS - If we can't flush we also can't call vgone(), so must
    558   1.28  perseant 	 * return.  But, that leaves this vnode in limbo, also not good.
    559   1.28  perseant 	 * Can this ever happen (barring hardware failure)?
    560   1.28  perseant 	 */
    561   1.80   thorpej 	if ((error = VOP_FSYNC(*vpp, NOCRED, FSYNC_WAIT, 0, 0,
    562   1.80   thorpej 	    curproc)) != 0) {
    563   1.40  perseant 		printf("Couldn't fsync in mknod (ino %d)---what do I do?\n",
    564   1.40  perseant 		       VTOI(*vpp)->i_number);
    565   1.28  perseant 		return (error);
    566   1.40  perseant 	}
    567   1.86  perseant 	/*
    568   1.86  perseant 	 * Remove vnode so that it will be reloaded by VFS_VGET and
    569   1.86  perseant 	 * checked to see if it is an alias of an existing entry in
    570   1.86  perseant 	 * the inode cache.
    571   1.86  perseant 	 */
    572   1.28  perseant 	/* Used to be vput, but that causes us to call VOP_INACTIVE twice. */
    573   1.40  perseant 	VOP_UNLOCK(*vpp, 0);
    574   1.28  perseant 	lfs_vunref(*vpp);
    575   1.86  perseant 	(*vpp)->v_type = VNON;
    576   1.86  perseant 	vgone(*vpp);
    577   1.52     assar 	error = VFS_VGET(mp, ino, vpp);
    578   1.52     assar 	if (error != 0) {
    579   1.52     assar 		*vpp = NULL;
    580   1.52     assar 		return (error);
    581   1.52     assar 	}
    582   1.86  perseant 	return (0);
    583    1.1   mycroft }
    584    1.1   mycroft 
    585    1.1   mycroft int
    586   1.51  perseant lfs_create(void *v)
    587   1.10  christos {
    588   1.22  perseant 	struct vop_create_args	/* {
    589    1.1   mycroft 		struct vnode *a_dvp;
    590    1.1   mycroft 		struct vnode **a_vpp;
    591    1.1   mycroft 		struct componentname *a_cnp;
    592    1.1   mycroft 		struct vattr *a_vap;
    593   1.10  christos 	} */ *ap = v;
    594   1.37  perseant 	int error;
    595    1.1   mycroft 
    596   1.59       chs 	if ((error = SET_DIROP(ap->a_dvp)) != 0) {
    597   1.34  perseant 		vput(ap->a_dvp);
    598   1.37  perseant 		return error;
    599   1.34  perseant 	}
    600    1.1   mycroft 	MARK_VNODE(ap->a_dvp);
    601   1.37  perseant 	error = ufs_create(ap);
    602   1.37  perseant 	UNMARK_VNODE(ap->a_dvp);
    603   1.86  perseant 	if (*(ap->a_vpp))
    604   1.86  perseant 		UNMARK_VNODE(*(ap->a_vpp));
    605   1.26  perseant 	SET_ENDOP(VTOI(ap->a_dvp)->i_lfs,ap->a_dvp,"create");
    606   1.37  perseant 	return (error);
    607   1.22  perseant }
    608   1.22  perseant 
    609   1.22  perseant int
    610   1.51  perseant lfs_mkdir(void *v)
    611   1.10  christos {
    612   1.22  perseant 	struct vop_mkdir_args	/* {
    613    1.1   mycroft 		struct vnode *a_dvp;
    614    1.1   mycroft 		struct vnode **a_vpp;
    615    1.1   mycroft 		struct componentname *a_cnp;
    616    1.1   mycroft 		struct vattr *a_vap;
    617   1.10  christos 	} */ *ap = v;
    618   1.37  perseant 	int error;
    619    1.1   mycroft 
    620   1.59       chs 	if ((error = SET_DIROP(ap->a_dvp)) != 0) {
    621   1.34  perseant 		vput(ap->a_dvp);
    622   1.37  perseant 		return error;
    623   1.34  perseant 	}
    624    1.1   mycroft 	MARK_VNODE(ap->a_dvp);
    625   1.37  perseant 	error = ufs_mkdir(ap);
    626   1.37  perseant 	UNMARK_VNODE(ap->a_dvp);
    627   1.86  perseant 	if (*(ap->a_vpp))
    628   1.86  perseant 		UNMARK_VNODE(*(ap->a_vpp));
    629   1.26  perseant 	SET_ENDOP(VTOI(ap->a_dvp)->i_lfs,ap->a_dvp,"mkdir");
    630   1.37  perseant 	return (error);
    631    1.1   mycroft }
    632    1.1   mycroft 
    633    1.1   mycroft int
    634   1.51  perseant lfs_remove(void *v)
    635   1.10  christos {
    636   1.22  perseant 	struct vop_remove_args	/* {
    637    1.1   mycroft 		struct vnode *a_dvp;
    638    1.1   mycroft 		struct vnode *a_vp;
    639    1.1   mycroft 		struct componentname *a_cnp;
    640   1.10  christos 	} */ *ap = v;
    641   1.34  perseant 	struct vnode *dvp, *vp;
    642   1.37  perseant 	int error;
    643   1.34  perseant 
    644   1.34  perseant 	dvp = ap->a_dvp;
    645   1.34  perseant 	vp = ap->a_vp;
    646   1.71      yamt 	if ((error = SET_DIROP2(dvp, vp)) != 0) {
    647   1.34  perseant 		if (dvp == vp)
    648   1.34  perseant 			vrele(vp);
    649   1.34  perseant 		else
    650   1.34  perseant 			vput(vp);
    651   1.34  perseant 		vput(dvp);
    652   1.37  perseant 		return error;
    653   1.34  perseant 	}
    654   1.34  perseant 	MARK_VNODE(dvp);
    655   1.34  perseant 	MARK_VNODE(vp);
    656   1.37  perseant 	error = ufs_remove(ap);
    657   1.37  perseant 	UNMARK_VNODE(dvp);
    658   1.37  perseant 	UNMARK_VNODE(vp);
    659   1.40  perseant 
    660   1.71      yamt 	SET_ENDOP2(VTOI(dvp)->i_lfs, dvp, vp, "remove");
    661   1.37  perseant 	return (error);
    662    1.1   mycroft }
    663    1.1   mycroft 
    664    1.1   mycroft int
    665   1.51  perseant lfs_rmdir(void *v)
    666   1.10  christos {
    667   1.22  perseant 	struct vop_rmdir_args	/* {
    668    1.1   mycroft 		struct vnodeop_desc *a_desc;
    669    1.1   mycroft 		struct vnode *a_dvp;
    670    1.1   mycroft 		struct vnode *a_vp;
    671    1.1   mycroft 		struct componentname *a_cnp;
    672   1.10  christos 	} */ *ap = v;
    673   1.84  perseant 	struct vnode *vp;
    674   1.37  perseant 	int error;
    675    1.1   mycroft 
    676   1.84  perseant 	vp = ap->a_vp;
    677   1.71      yamt 	if ((error = SET_DIROP2(ap->a_dvp, ap->a_vp)) != 0) {
    678   1.34  perseant 		vrele(ap->a_dvp);
    679   1.69      yamt 		if (ap->a_vp != ap->a_dvp)
    680   1.34  perseant 			VOP_UNLOCK(ap->a_dvp, 0);
    681   1.84  perseant 		vput(vp);
    682   1.37  perseant 		return error;
    683   1.34  perseant 	}
    684    1.1   mycroft 	MARK_VNODE(ap->a_dvp);
    685   1.84  perseant 	MARK_VNODE(vp);
    686   1.37  perseant 	error = ufs_rmdir(ap);
    687   1.37  perseant 	UNMARK_VNODE(ap->a_dvp);
    688   1.84  perseant 	UNMARK_VNODE(vp);
    689   1.40  perseant 
    690   1.84  perseant 	SET_ENDOP2(VTOI(ap->a_dvp)->i_lfs, ap->a_dvp, vp, "rmdir");
    691   1.37  perseant 	return (error);
    692    1.1   mycroft }
    693    1.1   mycroft 
    694    1.1   mycroft int
    695   1.51  perseant lfs_link(void *v)
    696   1.10  christos {
    697   1.22  perseant 	struct vop_link_args	/* {
    698    1.9   mycroft 		struct vnode *a_dvp;
    699    1.1   mycroft 		struct vnode *a_vp;
    700    1.1   mycroft 		struct componentname *a_cnp;
    701   1.10  christos 	} */ *ap = v;
    702   1.37  perseant 	int error;
    703    1.1   mycroft 
    704   1.40  perseant 	if ((error = SET_DIROP(ap->a_dvp)) != 0) {
    705   1.34  perseant 		vput(ap->a_dvp);
    706   1.37  perseant 		return error;
    707   1.34  perseant 	}
    708    1.9   mycroft 	MARK_VNODE(ap->a_dvp);
    709   1.37  perseant 	error = ufs_link(ap);
    710   1.37  perseant 	UNMARK_VNODE(ap->a_dvp);
    711   1.26  perseant 	SET_ENDOP(VTOI(ap->a_dvp)->i_lfs,ap->a_dvp,"link");
    712   1.37  perseant 	return (error);
    713    1.1   mycroft }
    714   1.22  perseant 
    715    1.1   mycroft int
    716   1.51  perseant lfs_rename(void *v)
    717   1.10  christos {
    718   1.22  perseant 	struct vop_rename_args	/* {
    719    1.1   mycroft 		struct vnode *a_fdvp;
    720    1.1   mycroft 		struct vnode *a_fvp;
    721    1.1   mycroft 		struct componentname *a_fcnp;
    722    1.1   mycroft 		struct vnode *a_tdvp;
    723    1.1   mycroft 		struct vnode *a_tvp;
    724    1.1   mycroft 		struct componentname *a_tcnp;
    725   1.10  christos 	} */ *ap = v;
    726   1.30  perseant 	struct vnode *tvp, *fvp, *tdvp, *fdvp;
    727   1.83  perseant 	struct componentname *tcnp, *fcnp;
    728   1.30  perseant 	int error;
    729   1.29  perseant 	struct lfs *fs;
    730   1.29  perseant 
    731   1.29  perseant 	fs = VTOI(ap->a_fdvp)->i_lfs;
    732   1.30  perseant 	tvp = ap->a_tvp;
    733   1.30  perseant 	tdvp = ap->a_tdvp;
    734   1.83  perseant 	tcnp = ap->a_tcnp;
    735   1.30  perseant 	fvp = ap->a_fvp;
    736   1.30  perseant 	fdvp = ap->a_fdvp;
    737   1.83  perseant 	fcnp = ap->a_fcnp;
    738   1.30  perseant 
    739   1.30  perseant 	/*
    740   1.30  perseant 	 * Check for cross-device rename.
    741   1.30  perseant 	 * If it is, we don't want to set dirops, just error out.
    742   1.30  perseant 	 * (In particular note that MARK_VNODE(tdvp) will DTWT on
    743   1.30  perseant 	 * a cross-device rename.)
    744   1.30  perseant 	 *
    745   1.30  perseant 	 * Copied from ufs_rename.
    746   1.30  perseant 	 */
    747   1.30  perseant 	if ((fvp->v_mount != tdvp->v_mount) ||
    748   1.30  perseant 	    (tvp && (fvp->v_mount != tvp->v_mount))) {
    749   1.30  perseant 		error = EXDEV;
    750   1.34  perseant 		goto errout;
    751   1.30  perseant 	}
    752   1.83  perseant 
    753   1.83  perseant 	/*
    754   1.83  perseant 	 * Check to make sure we're not renaming a vnode onto itself
    755   1.83  perseant 	 * (deleting a hard link by renaming one name onto another);
    756   1.83  perseant 	 * if we are we can't recursively call VOP_REMOVE since that
    757   1.83  perseant 	 * would leave us with an unaccounted-for number of live dirops.
    758   1.83  perseant 	 *
    759   1.83  perseant 	 * Inline the relevant section of ufs_rename here, *before*
    760   1.83  perseant 	 * calling SET_DIROP2.
    761   1.83  perseant 	 */
    762  1.102      fvdl 	if (tvp && ((VTOI(tvp)->i_flags & (IMMUTABLE | APPEND)) ||
    763  1.102      fvdl 	    (VTOI(tdvp)->i_flags & APPEND))) {
    764   1.83  perseant 		error = EPERM;
    765   1.83  perseant 		goto errout;
    766   1.83  perseant 	}
    767   1.86  perseant 	if (fvp == tvp) {
    768   1.86  perseant 		if (fvp->v_type == VDIR) {
    769   1.86  perseant 			error = EINVAL;
    770   1.86  perseant 			goto errout;
    771   1.86  perseant 		}
    772   1.86  perseant 
    773   1.86  perseant 		/* Release destination completely. */
    774   1.86  perseant 		VOP_ABORTOP(tdvp, tcnp);
    775   1.86  perseant 		vput(tdvp);
    776   1.86  perseant 		vput(tvp);
    777   1.86  perseant 
    778   1.86  perseant 		/* Delete source. */
    779   1.86  perseant 		vrele(fvp);
    780   1.86  perseant 		fcnp->cn_flags &= ~(MODMASK | SAVESTART);
    781   1.86  perseant 		fcnp->cn_flags |= LOCKPARENT | LOCKLEAF;
    782   1.86  perseant 		fcnp->cn_nameiop = DELETE;
    783   1.86  perseant 		if ((error = relookup(fdvp, &fvp, fcnp))){
    784   1.86  perseant 			/* relookup blew away fdvp */
    785   1.86  perseant 			return (error);
    786   1.86  perseant 		}
    787   1.86  perseant 		return (VOP_REMOVE(fdvp, fvp, fcnp));
    788   1.86  perseant 	}
    789   1.83  perseant 
    790   1.71      yamt 	if ((error = SET_DIROP2(tdvp, tvp)) != 0)
    791   1.34  perseant 		goto errout;
    792   1.30  perseant 	MARK_VNODE(fdvp);
    793   1.30  perseant 	MARK_VNODE(tdvp);
    794   1.71      yamt 	MARK_VNODE(fvp);
    795   1.71      yamt 	if (tvp) {
    796   1.71      yamt 		MARK_VNODE(tvp);
    797   1.71      yamt 	}
    798   1.83  perseant 
    799   1.30  perseant 	error = ufs_rename(ap);
    800   1.37  perseant 	UNMARK_VNODE(fdvp);
    801   1.37  perseant 	UNMARK_VNODE(tdvp);
    802   1.71      yamt 	UNMARK_VNODE(fvp);
    803   1.71      yamt 	if (tvp) {
    804   1.71      yamt 		UNMARK_VNODE(tvp);
    805   1.71      yamt 	}
    806   1.71      yamt 	SET_ENDOP2(fs, tdvp, tvp, "rename");
    807   1.34  perseant 	return (error);
    808   1.34  perseant 
    809   1.34  perseant     errout:
    810   1.34  perseant 	VOP_ABORTOP(tdvp, ap->a_tcnp); /* XXX, why not in NFS? */
    811   1.34  perseant 	if (tdvp == tvp)
    812   1.34  perseant 		vrele(tdvp);
    813   1.34  perseant 	else
    814   1.34  perseant 		vput(tdvp);
    815   1.34  perseant 	if (tvp)
    816   1.34  perseant 		vput(tvp);
    817   1.34  perseant 	VOP_ABORTOP(fdvp, ap->a_fcnp); /* XXX, why not in NFS? */
    818   1.34  perseant 	vrele(fdvp);
    819   1.34  perseant 	vrele(fvp);
    820   1.30  perseant 	return (error);
    821    1.1   mycroft }
    822   1.22  perseant 
    823    1.1   mycroft /* XXX hack to avoid calling ITIMES in getattr */
    824    1.1   mycroft int
    825   1.51  perseant lfs_getattr(void *v)
    826   1.10  christos {
    827    1.1   mycroft 	struct vop_getattr_args /* {
    828    1.1   mycroft 		struct vnode *a_vp;
    829    1.1   mycroft 		struct vattr *a_vap;
    830    1.1   mycroft 		struct ucred *a_cred;
    831    1.1   mycroft 		struct proc *a_p;
    832   1.10  christos 	} */ *ap = v;
    833   1.35  augustss 	struct vnode *vp = ap->a_vp;
    834   1.35  augustss 	struct inode *ip = VTOI(vp);
    835   1.35  augustss 	struct vattr *vap = ap->a_vap;
    836   1.51  perseant 	struct lfs *fs = ip->i_lfs;
    837    1.1   mycroft 	/*
    838    1.1   mycroft 	 * Copy from inode table
    839    1.1   mycroft 	 */
    840    1.1   mycroft 	vap->va_fsid = ip->i_dev;
    841    1.1   mycroft 	vap->va_fileid = ip->i_number;
    842  1.102      fvdl 	vap->va_mode = ip->i_mode & ~IFMT;
    843  1.102      fvdl 	vap->va_nlink = ip->i_nlink;
    844  1.102      fvdl 	vap->va_uid = ip->i_uid;
    845  1.102      fvdl 	vap->va_gid = ip->i_gid;
    846  1.102      fvdl 	vap->va_rdev = (dev_t)ip->i_ffs1_rdev;
    847   1.55       chs 	vap->va_size = vp->v_size;
    848  1.102      fvdl 	vap->va_atime.tv_sec = ip->i_ffs1_atime;
    849  1.102      fvdl 	vap->va_atime.tv_nsec = ip->i_ffs1_atimensec;
    850  1.102      fvdl 	vap->va_mtime.tv_sec = ip->i_ffs1_mtime;
    851  1.102      fvdl 	vap->va_mtime.tv_nsec = ip->i_ffs1_mtimensec;
    852  1.102      fvdl 	vap->va_ctime.tv_sec = ip->i_ffs1_ctime;
    853  1.102      fvdl 	vap->va_ctime.tv_nsec = ip->i_ffs1_ctimensec;
    854  1.102      fvdl 	vap->va_flags = ip->i_flags;
    855  1.102      fvdl 	vap->va_gen = ip->i_gen;
    856    1.1   mycroft 	/* this doesn't belong here */
    857    1.1   mycroft 	if (vp->v_type == VBLK)
    858    1.1   mycroft 		vap->va_blocksize = BLKDEV_IOSIZE;
    859    1.1   mycroft 	else if (vp->v_type == VCHR)
    860    1.1   mycroft 		vap->va_blocksize = MAXBSIZE;
    861    1.1   mycroft 	else
    862    1.1   mycroft 		vap->va_blocksize = vp->v_mount->mnt_stat.f_iosize;
    863   1.84  perseant 	vap->va_bytes = fsbtob(fs, (u_quad_t)ip->i_lfs_effnblks);
    864    1.1   mycroft 	vap->va_type = vp->v_type;
    865    1.1   mycroft 	vap->va_filerev = ip->i_modrev;
    866    1.1   mycroft 	return (0);
    867   1.61  perseant }
    868   1.61  perseant 
    869   1.61  perseant /*
    870   1.61  perseant  * Check to make sure the inode blocks won't choke the buffer
    871   1.61  perseant  * cache, then call ufs_setattr as usual.
    872   1.61  perseant  */
    873   1.61  perseant int
    874   1.61  perseant lfs_setattr(void *v)
    875   1.61  perseant {
    876   1.61  perseant 	struct vop_getattr_args /* {
    877   1.61  perseant 		struct vnode *a_vp;
    878   1.61  perseant 		struct vattr *a_vap;
    879   1.61  perseant 		struct ucred *a_cred;
    880   1.61  perseant 		struct proc *a_p;
    881   1.61  perseant 	} */ *ap = v;
    882   1.61  perseant 	struct vnode *vp = ap->a_vp;
    883   1.61  perseant 
    884   1.61  perseant 	lfs_check(vp, LFS_UNUSED_LBN, 0);
    885   1.61  perseant 	return ufs_setattr(v);
    886    1.1   mycroft }
    887   1.22  perseant 
    888    1.1   mycroft /*
    889    1.1   mycroft  * Close called
    890    1.1   mycroft  *
    891    1.1   mycroft  * XXX -- we were using ufs_close, but since it updates the
    892    1.1   mycroft  * times on the inode, we might need to bump the uinodes
    893    1.1   mycroft  * count.
    894    1.1   mycroft  */
    895    1.1   mycroft /* ARGSUSED */
    896    1.1   mycroft int
    897   1.51  perseant lfs_close(void *v)
    898   1.10  christos {
    899    1.1   mycroft 	struct vop_close_args /* {
    900    1.1   mycroft 		struct vnode *a_vp;
    901    1.1   mycroft 		int  a_fflag;
    902    1.1   mycroft 		struct ucred *a_cred;
    903    1.1   mycroft 		struct proc *a_p;
    904   1.10  christos 	} */ *ap = v;
    905   1.35  augustss 	struct vnode *vp = ap->a_vp;
    906   1.35  augustss 	struct inode *ip = VTOI(vp);
    907   1.12   mycroft 	struct timespec ts;
    908    1.1   mycroft 
    909   1.97  perseant 	if (vp == ip->i_lfs->lfs_ivnode &&
    910   1.97  perseant 	    vp->v_mount->mnt_flag & MNT_UNMOUNT)
    911   1.97  perseant 		return 0;
    912   1.97  perseant 
    913   1.97  perseant 	if (vp->v_usecount > 1 && vp != ip->i_lfs->lfs_ivnode) {
    914   1.12   mycroft 		TIMEVAL_TO_TIMESPEC(&time, &ts);
    915   1.22  perseant 		LFS_ITIMES(ip, &ts, &ts, &ts);
    916    1.1   mycroft 	}
    917    1.1   mycroft 	return (0);
    918   1.65  perseant }
    919   1.65  perseant 
    920   1.65  perseant /*
    921   1.65  perseant  * Close wrapper for special devices.
    922   1.65  perseant  *
    923   1.65  perseant  * Update the times on the inode then do device close.
    924   1.65  perseant  */
    925   1.65  perseant int
    926   1.65  perseant lfsspec_close(void *v)
    927   1.65  perseant {
    928   1.65  perseant 	struct vop_close_args /* {
    929   1.65  perseant 		struct vnode	*a_vp;
    930   1.65  perseant 		int		a_fflag;
    931   1.65  perseant 		struct ucred	*a_cred;
    932   1.65  perseant 		struct proc	*a_p;
    933   1.65  perseant 	} */ *ap = v;
    934   1.65  perseant 	struct vnode	*vp;
    935   1.65  perseant 	struct inode	*ip;
    936   1.65  perseant 	struct timespec	ts;
    937   1.65  perseant 
    938   1.65  perseant 	vp = ap->a_vp;
    939   1.65  perseant 	ip = VTOI(vp);
    940   1.65  perseant 	if (vp->v_usecount > 1) {
    941   1.65  perseant 		TIMEVAL_TO_TIMESPEC(&time, &ts);
    942   1.65  perseant 		LFS_ITIMES(ip, &ts, &ts, &ts);
    943   1.65  perseant 	}
    944   1.65  perseant 	return (VOCALL (spec_vnodeop_p, VOFFSET(vop_close), ap));
    945   1.65  perseant }
    946   1.65  perseant 
    947   1.65  perseant /*
    948   1.65  perseant  * Close wrapper for fifo's.
    949   1.65  perseant  *
    950   1.65  perseant  * Update the times on the inode then do device close.
    951   1.65  perseant  */
    952   1.65  perseant int
    953   1.65  perseant lfsfifo_close(void *v)
    954   1.65  perseant {
    955   1.65  perseant 	struct vop_close_args /* {
    956   1.65  perseant 		struct vnode	*a_vp;
    957   1.65  perseant 		int		a_fflag;
    958   1.65  perseant 		struct ucred	*a_cred;
    959   1.65  perseant 		struct proc	*a_p;
    960   1.65  perseant 	} */ *ap = v;
    961   1.65  perseant 	struct vnode	*vp;
    962   1.65  perseant 	struct inode	*ip;
    963   1.65  perseant 	struct timespec	ts;
    964   1.65  perseant 
    965   1.65  perseant 	vp = ap->a_vp;
    966   1.65  perseant 	ip = VTOI(vp);
    967   1.65  perseant 	if (ap->a_vp->v_usecount > 1) {
    968   1.65  perseant 		TIMEVAL_TO_TIMESPEC(&time, &ts);
    969   1.65  perseant 		LFS_ITIMES(ip, &ts, &ts, &ts);
    970   1.65  perseant 	}
    971   1.65  perseant 	return (VOCALL (fifo_vnodeop_p, VOFFSET(vop_close), ap));
    972    1.1   mycroft }
    973    1.1   mycroft 
    974    1.1   mycroft /*
    975   1.15      fvdl  * Reclaim an inode so that it can be used for other purposes.
    976    1.1   mycroft  */
    977    1.1   mycroft int lfs_no_inactive = 0;
    978    1.1   mycroft 
    979    1.1   mycroft int
    980   1.51  perseant lfs_reclaim(void *v)
    981   1.10  christos {
    982    1.1   mycroft 	struct vop_reclaim_args /* {
    983    1.1   mycroft 		struct vnode *a_vp;
    984   1.15      fvdl 		struct proc *a_p;
    985   1.10  christos 	} */ *ap = v;
    986   1.15      fvdl 	struct vnode *vp = ap->a_vp;
    987   1.84  perseant 	struct inode *ip = VTOI(vp);
    988    1.1   mycroft 	int error;
    989   1.77      yamt 
    990  1.102      fvdl 	KASSERT(ip->i_nlink == ip->i_ffs_effnlink);
    991    1.1   mycroft 
    992   1.84  perseant 	LFS_CLR_UINO(ip, IN_ALLMOD);
    993   1.15      fvdl 	if ((error = ufs_reclaim(vp, ap->a_p)))
    994    1.1   mycroft 		return (error);
    995  1.102      fvdl 	pool_put(&lfs_dinode_pool, VTOI(vp)->i_din.ffs1_din);
    996   1.84  perseant 	pool_put(&lfs_inoext_pool, ip->inode_ext.lfs);
    997   1.84  perseant 	ip->inode_ext.lfs = NULL;
    998   1.19   thorpej 	pool_put(&lfs_inode_pool, vp->v_data);
    999    1.1   mycroft 	vp->v_data = NULL;
   1000   1.94  perseant 	return (0);
   1001   1.94  perseant }
   1002   1.94  perseant 
   1003   1.94  perseant /*
   1004  1.101      yamt  * Read a block from a storage device.
   1005   1.94  perseant  * In order to avoid reading blocks that are in the process of being
   1006   1.94  perseant  * written by the cleaner---and hence are not mutexed by the normal
   1007   1.94  perseant  * buffer cache / page cache mechanisms---check for collisions before
   1008   1.94  perseant  * reading.
   1009   1.94  perseant  *
   1010   1.94  perseant  * We inline ufs_strategy to make sure that the VOP_BMAP occurs *before*
   1011   1.94  perseant  * the active cleaner test.
   1012   1.94  perseant  *
   1013   1.94  perseant  * XXX This code assumes that lfs_markv makes synchronous checkpoints.
   1014   1.94  perseant  */
   1015   1.94  perseant int
   1016   1.94  perseant lfs_strategy(void *v)
   1017   1.94  perseant {
   1018   1.94  perseant 	struct vop_strategy_args /* {
   1019   1.94  perseant 		struct buf *a_bp;
   1020   1.94  perseant 	} */ *ap = v;
   1021   1.94  perseant 	struct buf	*bp;
   1022   1.94  perseant 	struct lfs	*fs;
   1023   1.94  perseant 	struct vnode	*vp;
   1024   1.94  perseant 	struct inode	*ip;
   1025   1.94  perseant 	daddr_t		tbn;
   1026   1.94  perseant 	int		i, sn, error, slept;
   1027   1.94  perseant 
   1028   1.94  perseant 	bp = ap->a_bp;
   1029   1.94  perseant 	vp = bp->b_vp;
   1030   1.94  perseant 	ip = VTOI(vp);
   1031   1.94  perseant 	fs = ip->i_lfs;
   1032   1.94  perseant 
   1033  1.101      yamt 	/* lfs uses its strategy routine only for read */
   1034  1.101      yamt 	KASSERT(bp->b_flags & B_READ);
   1035  1.101      yamt 
   1036   1.94  perseant 	if (vp->v_type == VBLK || vp->v_type == VCHR)
   1037   1.94  perseant 		panic("lfs_strategy: spec");
   1038   1.94  perseant 	KASSERT(bp->b_bcount != 0);
   1039   1.94  perseant 	if (bp->b_blkno == bp->b_lblkno) {
   1040   1.94  perseant 		error = VOP_BMAP(vp, bp->b_lblkno, NULL, &bp->b_blkno,
   1041   1.94  perseant 				 NULL);
   1042   1.94  perseant 		if (error) {
   1043   1.94  perseant 			bp->b_error = error;
   1044   1.94  perseant 			bp->b_flags |= B_ERROR;
   1045   1.94  perseant 			biodone(bp);
   1046   1.94  perseant 			return (error);
   1047   1.94  perseant 		}
   1048   1.94  perseant 		if ((long)bp->b_blkno == -1) /* no valid data */
   1049   1.94  perseant 			clrbuf(bp);
   1050   1.94  perseant 	}
   1051   1.94  perseant 	if ((long)bp->b_blkno < 0) { /* block is not on disk */
   1052   1.94  perseant 		biodone(bp);
   1053   1.94  perseant 		return (0);
   1054   1.94  perseant 	}
   1055   1.94  perseant 
   1056   1.94  perseant 	slept = 1;
   1057   1.96  perseant 	simple_lock(&fs->lfs_interlock);
   1058  1.101      yamt 	while (slept && fs->lfs_seglock) {
   1059   1.96  perseant 		simple_unlock(&fs->lfs_interlock);
   1060   1.94  perseant 		/*
   1061   1.94  perseant 		 * Look through list of intervals.
   1062   1.94  perseant 		 * There will only be intervals to look through
   1063   1.94  perseant 		 * if the cleaner holds the seglock.
   1064   1.94  perseant 		 * Since the cleaner is synchronous, we can trust
   1065   1.94  perseant 		 * the list of intervals to be current.
   1066   1.94  perseant 		 */
   1067   1.94  perseant 		tbn = dbtofsb(fs, bp->b_blkno);
   1068   1.94  perseant 		sn = dtosn(fs, tbn);
   1069   1.94  perseant 		slept = 0;
   1070   1.94  perseant 		for (i = 0; i < fs->lfs_cleanind; i++) {
   1071   1.94  perseant 			if (sn == dtosn(fs, fs->lfs_cleanint[i]) &&
   1072   1.94  perseant 			    tbn >= fs->lfs_cleanint[i]) {
   1073   1.94  perseant #ifdef DEBUG_LFS
   1074   1.94  perseant 				printf("lfs_strategy: ino %d lbn %" PRId64
   1075   1.94  perseant 				       " ind %d sn %d fsb %" PRIx32
   1076   1.94  perseant 				       " given sn %d fsb %" PRIx64 "\n",
   1077   1.94  perseant 					ip->i_number, bp->b_lblkno, i,
   1078   1.94  perseant 					dtosn(fs, fs->lfs_cleanint[i]),
   1079   1.94  perseant 					fs->lfs_cleanint[i], sn, tbn);
   1080   1.94  perseant 				printf("lfs_strategy: sleeping on ino %d lbn %"
   1081   1.94  perseant 				       PRId64 "\n", ip->i_number, bp->b_lblkno);
   1082   1.94  perseant #endif
   1083   1.94  perseant 				tsleep(&fs->lfs_seglock, PRIBIO+1,
   1084   1.94  perseant 					"lfs_strategy", 0);
   1085   1.94  perseant 				/* Things may be different now; start over. */
   1086   1.94  perseant 				slept = 1;
   1087   1.94  perseant 				break;
   1088   1.94  perseant 			}
   1089   1.94  perseant 		}
   1090   1.96  perseant 		simple_lock(&fs->lfs_interlock);
   1091   1.94  perseant 	}
   1092   1.96  perseant 	simple_unlock(&fs->lfs_interlock);
   1093   1.94  perseant 
   1094   1.94  perseant 	vp = ip->i_devvp;
   1095   1.94  perseant 	bp->b_dev = vp->v_rdev;
   1096   1.94  perseant 	VOCALL (vp->v_op, VOFFSET(vop_strategy), ap);
   1097    1.1   mycroft 	return (0);
   1098   1.89  perseant }
   1099   1.89  perseant 
   1100   1.92  perseant static void
   1101   1.92  perseant lfs_flush_dirops(struct lfs *fs)
   1102   1.92  perseant {
   1103   1.92  perseant 	struct inode *ip, *nip;
   1104   1.92  perseant 	struct vnode *vp;
   1105   1.92  perseant 	extern int lfs_dostats;
   1106   1.92  perseant 	struct segment *sp;
   1107   1.92  perseant 	int needunlock;
   1108   1.92  perseant 
   1109   1.92  perseant 	if (fs->lfs_ronly)
   1110   1.92  perseant 		return;
   1111   1.92  perseant 
   1112   1.92  perseant 	if (TAILQ_FIRST(&fs->lfs_dchainhd) == NULL)
   1113   1.92  perseant 		return;
   1114   1.92  perseant 
   1115   1.92  perseant 	/* XXX simplelock fs->lfs_dirops */
   1116   1.92  perseant 	while (fs->lfs_dirops > 0) {
   1117   1.92  perseant 		++fs->lfs_diropwait;
   1118   1.92  perseant 		tsleep(&fs->lfs_writer, PRIBIO+1, "pndirop", 0);
   1119   1.92  perseant 		--fs->lfs_diropwait;
   1120   1.92  perseant 	}
   1121   1.92  perseant 	/* disallow dirops during flush */
   1122   1.92  perseant 	fs->lfs_writer++;
   1123   1.92  perseant 
   1124   1.92  perseant 	if (lfs_dostats)
   1125   1.92  perseant 		++lfs_stats.flush_invoked;
   1126   1.92  perseant 
   1127   1.92  perseant 	/*
   1128   1.92  perseant 	 * Inline lfs_segwrite/lfs_writevnodes, but just for dirops.
   1129   1.92  perseant 	 * Technically this is a checkpoint (the on-disk state is valid)
   1130   1.92  perseant 	 * even though we are leaving out all the file data.
   1131   1.92  perseant 	 */
   1132   1.92  perseant 	lfs_imtime(fs);
   1133   1.92  perseant 	lfs_seglock(fs, SEGM_CKP);
   1134   1.92  perseant 	sp = fs->lfs_sp;
   1135   1.92  perseant 
   1136   1.92  perseant 	/*
   1137   1.92  perseant 	 * lfs_writevnodes, optimized to get dirops out of the way.
   1138   1.92  perseant 	 * Only write dirops, and don't flush files' pages, only
   1139   1.92  perseant 	 * blocks from the directories.
   1140   1.92  perseant 	 *
   1141   1.92  perseant 	 * We don't need to vref these files because they are
   1142   1.92  perseant 	 * dirops and so hold an extra reference until the
   1143   1.92  perseant 	 * segunlock clears them of that status.
   1144   1.92  perseant 	 *
   1145   1.92  perseant 	 * We don't need to check for IN_ADIROP because we know that
   1146   1.92  perseant 	 * no dirops are active.
   1147   1.92  perseant 	 *
   1148   1.92  perseant 	 */
   1149   1.92  perseant 	for (ip = TAILQ_FIRST(&fs->lfs_dchainhd); ip != NULL; ip = nip) {
   1150   1.92  perseant 		nip = TAILQ_NEXT(ip, i_lfs_dchain);
   1151   1.92  perseant 		vp = ITOV(ip);
   1152   1.92  perseant 
   1153   1.92  perseant 		/*
   1154   1.92  perseant 		 * All writes to directories come from dirops; all
   1155   1.92  perseant 		 * writes to files' direct blocks go through the page
   1156   1.92  perseant 		 * cache, which we're not touching.  Reads to files
   1157   1.92  perseant 		 * and/or directories will not be affected by writing
   1158   1.92  perseant 		 * directory blocks inodes and file inodes.  So we don't
   1159   1.92  perseant 		 * really need to lock.  If we don't lock, though,
   1160   1.92  perseant 		 * make sure that we don't clear IN_MODIFIED
   1161   1.92  perseant 		 * unnecessarily.
   1162   1.92  perseant 		 */
   1163   1.92  perseant 		if (vp->v_flag & VXLOCK)
   1164   1.92  perseant 			continue;
   1165   1.92  perseant 		if (vn_lock(vp, LK_EXCLUSIVE | LK_CANRECURSE |
   1166   1.92  perseant 			    LK_NOWAIT) == 0) {
   1167   1.92  perseant 			needunlock = 1;
   1168   1.92  perseant 		} else {
   1169   1.92  perseant 			printf("lfs_flush_dirops: flushing locked ino %d\n",
   1170   1.92  perseant 			       VTOI(vp)->i_number);
   1171   1.92  perseant 			needunlock = 0;
   1172   1.92  perseant 		}
   1173   1.92  perseant 		if (vp->v_type != VREG &&
   1174   1.92  perseant 		    ((ip->i_flag & IN_ALLMOD) || !VPISEMPTY(vp))) {
   1175   1.92  perseant 			lfs_writefile(fs, sp, vp);
   1176   1.92  perseant 			if (!VPISEMPTY(vp) && !WRITEINPROG(vp) &&
   1177   1.92  perseant 			    !(ip->i_flag & IN_ALLMOD)) {
   1178   1.92  perseant 				LFS_SET_UINO(ip, IN_MODIFIED);
   1179   1.92  perseant 			}
   1180   1.92  perseant 		}
   1181   1.92  perseant 		(void) lfs_writeinode(fs, sp, ip);
   1182   1.92  perseant 		if (needunlock)
   1183   1.92  perseant 			VOP_UNLOCK(vp, 0);
   1184   1.92  perseant 		else
   1185   1.92  perseant 			LFS_SET_UINO(ip, IN_MODIFIED);
   1186   1.92  perseant 	}
   1187   1.92  perseant 	/* We've written all the dirops there are */
   1188   1.92  perseant 	((SEGSUM *)(sp->segsum))->ss_flags &= ~(SS_CONT);
   1189   1.92  perseant 	(void) lfs_writeseg(fs, sp);
   1190   1.92  perseant 	lfs_segunlock(fs);
   1191   1.92  perseant 
   1192   1.92  perseant 	if (--fs->lfs_writer == 0)
   1193   1.92  perseant 		wakeup(&fs->lfs_dirops);
   1194   1.92  perseant }
   1195   1.92  perseant 
   1196   1.89  perseant /*
   1197   1.90  perseant  * Provide a fcntl interface to sys_lfs_{segwait,bmapv,markv}.
   1198   1.89  perseant  */
   1199   1.89  perseant int
   1200   1.90  perseant lfs_fcntl(void *v)
   1201   1.89  perseant {
   1202   1.90  perseant         struct vop_fcntl_args /* {
   1203   1.89  perseant                 struct vnode *a_vp;
   1204   1.89  perseant                 u_long a_command;
   1205   1.89  perseant                 caddr_t  a_data;
   1206   1.89  perseant                 int  a_fflag;
   1207   1.89  perseant                 struct ucred *a_cred;
   1208   1.89  perseant                 struct proc *a_p;
   1209   1.89  perseant         } */ *ap = v;
   1210   1.89  perseant 	struct timeval *tvp;
   1211   1.89  perseant 	BLOCK_INFO *blkiov;
   1212   1.92  perseant 	CLEANERINFO *cip;
   1213   1.92  perseant 	int blkcnt, error, oclean;
   1214   1.90  perseant 	struct lfs_fcntl_markv blkvp;
   1215   1.89  perseant 	fsid_t *fsidp;
   1216   1.92  perseant 	struct lfs *fs;
   1217   1.92  perseant 	struct buf *bp;
   1218   1.92  perseant 	daddr_t off;
   1219   1.89  perseant 
   1220   1.90  perseant 	/* Only respect LFS fcntls on fs root or Ifile */
   1221   1.89  perseant 	if (VTOI(ap->a_vp)->i_number != ROOTINO &&
   1222   1.89  perseant 	    VTOI(ap->a_vp)->i_number != LFS_IFILE_INUM) {
   1223   1.90  perseant 		return ufs_fcntl(v);
   1224   1.89  perseant 	}
   1225   1.89  perseant 
   1226  1.100  perseant 	/* Avoid locking a draining lock */
   1227  1.100  perseant 	if (ap->a_vp->v_mount->mnt_flag & MNT_UNMOUNT) {
   1228  1.100  perseant 		return ESHUTDOWN;
   1229  1.100  perseant 	}
   1230  1.100  perseant 
   1231  1.100  perseant 	fs = VTOI(ap->a_vp)->i_lfs;
   1232   1.89  perseant 	fsidp = &ap->a_vp->v_mount->mnt_stat.f_fsid;
   1233   1.89  perseant 
   1234   1.98  perseant 	switch (ap->a_command) {
   1235   1.90  perseant 	    case LFCNSEGWAITALL:
   1236   1.89  perseant 		fsidp = NULL;
   1237   1.89  perseant 		/* FALLSTHROUGH */
   1238   1.90  perseant 	    case LFCNSEGWAIT:
   1239   1.89  perseant 		tvp = (struct timeval *)ap->a_data;
   1240  1.100  perseant 		simple_lock(&fs->lfs_interlock);
   1241  1.100  perseant 		++fs->lfs_sleepers;
   1242  1.100  perseant 		simple_unlock(&fs->lfs_interlock);
   1243   1.90  perseant 		VOP_UNLOCK(ap->a_vp, 0);
   1244  1.100  perseant 
   1245   1.90  perseant 		error = lfs_segwait(fsidp, tvp);
   1246  1.100  perseant 
   1247   1.90  perseant 		VOP_LOCK(ap->a_vp, LK_EXCLUSIVE);
   1248  1.100  perseant 		simple_lock(&fs->lfs_interlock);
   1249  1.100  perseant 		if (--fs->lfs_sleepers == 0)
   1250  1.100  perseant 			wakeup(&fs->lfs_sleepers);
   1251  1.100  perseant 		simple_unlock(&fs->lfs_interlock);
   1252   1.90  perseant 		return error;
   1253   1.89  perseant 
   1254   1.90  perseant 	    case LFCNBMAPV:
   1255   1.90  perseant 	    case LFCNMARKV:
   1256   1.89  perseant 		if ((error = suser(ap->a_p->p_ucred, &ap->a_p->p_acflag)) != 0)
   1257   1.89  perseant 			return (error);
   1258   1.90  perseant 		blkvp = *(struct lfs_fcntl_markv *)ap->a_data;
   1259   1.89  perseant 
   1260   1.89  perseant 		blkcnt = blkvp.blkcnt;
   1261   1.89  perseant 		if ((u_int) blkcnt > LFS_MARKV_MAXBLKCNT)
   1262   1.89  perseant 			return (EINVAL);
   1263   1.89  perseant 		blkiov = malloc(blkcnt * sizeof(BLOCK_INFO), M_SEGMENT, M_WAITOK);
   1264   1.89  perseant 		if ((error = copyin(blkvp.blkiov, blkiov,
   1265   1.89  perseant 		     blkcnt * sizeof(BLOCK_INFO))) != 0) {
   1266   1.89  perseant 			free(blkiov, M_SEGMENT);
   1267   1.89  perseant 			return error;
   1268   1.89  perseant 		}
   1269   1.89  perseant 
   1270  1.100  perseant 		simple_lock(&fs->lfs_interlock);
   1271  1.100  perseant 		++fs->lfs_sleepers;
   1272  1.100  perseant 		simple_unlock(&fs->lfs_interlock);
   1273   1.90  perseant 		VOP_UNLOCK(ap->a_vp, 0);
   1274   1.90  perseant 		if (ap->a_command == LFCNBMAPV)
   1275   1.89  perseant 			error = lfs_bmapv(ap->a_p, fsidp, blkiov, blkcnt);
   1276   1.90  perseant 		else /* LFCNMARKV */
   1277   1.89  perseant 			error = lfs_markv(ap->a_p, fsidp, blkiov, blkcnt);
   1278   1.89  perseant 		if (error == 0)
   1279   1.89  perseant 			error = copyout(blkiov, blkvp.blkiov,
   1280   1.89  perseant 					blkcnt * sizeof(BLOCK_INFO));
   1281   1.90  perseant 		VOP_LOCK(ap->a_vp, LK_EXCLUSIVE);
   1282  1.100  perseant 		simple_lock(&fs->lfs_interlock);
   1283  1.100  perseant 		if (--fs->lfs_sleepers == 0)
   1284  1.100  perseant 			wakeup(&fs->lfs_sleepers);
   1285  1.100  perseant 		simple_unlock(&fs->lfs_interlock);
   1286   1.89  perseant 		free(blkiov, M_SEGMENT);
   1287   1.89  perseant 		return error;
   1288   1.92  perseant 
   1289   1.92  perseant 	    case LFCNRECLAIM:
   1290   1.92  perseant 		/*
   1291   1.92  perseant 		 * Flush dirops and write Ifile, allowing empty segments
   1292   1.92  perseant 		 * to be immediately reclaimed.
   1293   1.92  perseant 		 */
   1294   1.92  perseant 		off = fs->lfs_offset;
   1295   1.92  perseant 		lfs_seglock(fs, SEGM_FORCE_CKP | SEGM_CKP);
   1296   1.92  perseant 		lfs_flush_dirops(fs);
   1297   1.92  perseant 		LFS_CLEANERINFO(cip, fs, bp);
   1298   1.92  perseant 		oclean = cip->clean;
   1299   1.92  perseant 		LFS_SYNC_CLEANERINFO(cip, fs, bp, 1);
   1300   1.92  perseant 		lfs_segwrite(ap->a_vp->v_mount, SEGM_FORCE_CKP);
   1301   1.92  perseant 		lfs_segunlock(fs);
   1302   1.92  perseant 
   1303   1.92  perseant #ifdef DEBUG_LFS
   1304   1.92  perseant 		LFS_CLEANERINFO(cip, fs, bp);
   1305   1.92  perseant 		oclean = cip->clean;
   1306   1.92  perseant 		printf("lfs_fcntl: reclaim wrote %" PRId64 " blocks, cleaned "
   1307   1.92  perseant 			"%" PRId32 " segments (activesb %d)\n",
   1308   1.92  perseant 			fs->lfs_offset - off, cip->clean - oclean,
   1309   1.92  perseant 			fs->lfs_activesb);
   1310   1.92  perseant 		LFS_SYNC_CLEANERINFO(cip, fs, bp, 0);
   1311   1.92  perseant #endif
   1312   1.92  perseant 
   1313   1.92  perseant 		return 0;
   1314   1.89  perseant 
   1315   1.89  perseant 	    default:
   1316   1.90  perseant 		return ufs_fcntl(v);
   1317   1.89  perseant 	}
   1318   1.89  perseant 	return 0;
   1319   1.60       chs }
   1320   1.60       chs 
   1321   1.60       chs int
   1322   1.60       chs lfs_getpages(void *v)
   1323   1.60       chs {
   1324   1.60       chs 	struct vop_getpages_args /* {
   1325   1.60       chs 		struct vnode *a_vp;
   1326   1.60       chs 		voff_t a_offset;
   1327   1.60       chs 		struct vm_page **a_m;
   1328   1.60       chs 		int *a_count;
   1329   1.60       chs 		int a_centeridx;
   1330   1.60       chs 		vm_prot_t a_access_type;
   1331   1.60       chs 		int a_advice;
   1332   1.60       chs 		int a_flags;
   1333   1.60       chs 	} */ *ap = v;
   1334   1.60       chs 
   1335   1.97  perseant 	if (VTOI(ap->a_vp)->i_number == LFS_IFILE_INUM &&
   1336   1.97  perseant 	    (ap->a_access_type & VM_PROT_WRITE) != 0) {
   1337   1.97  perseant 		return EPERM;
   1338   1.97  perseant 	}
   1339   1.60       chs 	if ((ap->a_access_type & VM_PROT_WRITE) != 0) {
   1340   1.60       chs 		LFS_SET_UINO(VTOI(ap->a_vp), IN_MODIFIED);
   1341   1.60       chs 	}
   1342   1.95  perseant 	return genfs_getpages(v);
   1343    1.1   mycroft }
   1344   1.84  perseant 
   1345   1.84  perseant /*
   1346   1.84  perseant  * Make sure that for all pages in every block in the given range,
   1347   1.84  perseant  * either all are dirty or all are clean.  If any of the pages
   1348   1.84  perseant  * we've seen so far are dirty, put the vnode on the paging chain,
   1349   1.84  perseant  * and mark it IN_PAGING.
   1350   1.84  perseant  */
   1351   1.84  perseant static int
   1352   1.84  perseant check_dirty(struct lfs *fs, struct vnode *vp,
   1353   1.84  perseant 	    off_t startoffset, off_t endoffset, off_t blkeof,
   1354  1.103  perseant 	    int flags, int checkfirst)
   1355   1.84  perseant {
   1356   1.86  perseant 	int by_list;
   1357   1.84  perseant 	struct vm_page *curpg, *pgs[MAXBSIZE / PAGE_SIZE], *pg;
   1358   1.84  perseant 	struct lwp *l = curlwp ? curlwp : &lwp0;
   1359   1.84  perseant 	off_t soff;
   1360   1.84  perseant 	voff_t off;
   1361   1.84  perseant 	int i, dirty, tdirty, nonexistent, any_dirty;
   1362   1.84  perseant 	int pages_per_block = fs->lfs_bsize >> PAGE_SHIFT;
   1363   1.84  perseant 
   1364   1.84  perseant   top:
   1365   1.84  perseant 	by_list = (vp->v_uobj.uo_npages <=
   1366   1.84  perseant 		   ((endoffset - startoffset) >> PAGE_SHIFT) *
   1367   1.84  perseant 		   UVM_PAGE_HASH_PENALTY);
   1368   1.84  perseant 	any_dirty = 0;
   1369   1.84  perseant 
   1370   1.84  perseant 	if (by_list) {
   1371   1.84  perseant 		curpg = TAILQ_FIRST(&vp->v_uobj.memq);
   1372   1.84  perseant 		PHOLD(l);
   1373   1.84  perseant 	} else {
   1374   1.84  perseant 		soff = startoffset;
   1375   1.84  perseant 	}
   1376   1.84  perseant 	while (by_list || soff < MIN(blkeof, endoffset)) {
   1377   1.84  perseant 		if (by_list) {
   1378   1.84  perseant 			if (pages_per_block > 1) {
   1379   1.84  perseant 				while (curpg && (curpg->offset & fs->lfs_bmask))
   1380   1.84  perseant 					curpg = TAILQ_NEXT(curpg, listq);
   1381   1.84  perseant 			}
   1382   1.84  perseant 			if (curpg == NULL)
   1383   1.84  perseant 				break;
   1384   1.84  perseant 			soff = curpg->offset;
   1385   1.84  perseant 		}
   1386   1.84  perseant 
   1387   1.84  perseant 		/*
   1388   1.84  perseant 		 * Mark all pages in extended range busy; find out if any
   1389   1.84  perseant 		 * of them are dirty.
   1390   1.84  perseant 		 */
   1391   1.84  perseant 		nonexistent = dirty = 0;
   1392   1.84  perseant 		for (i = 0; i == 0 || i < pages_per_block; i++) {
   1393   1.84  perseant 			if (by_list && pages_per_block <= 1) {
   1394   1.84  perseant 				pgs[i] = pg = curpg;
   1395   1.84  perseant 			} else {
   1396   1.84  perseant 				off = soff + (i << PAGE_SHIFT);
   1397   1.84  perseant 				pgs[i] = pg = uvm_pagelookup(&vp->v_uobj, off);
   1398   1.84  perseant 				if (pg == NULL) {
   1399   1.84  perseant 					++nonexistent;
   1400   1.84  perseant 					continue;
   1401   1.84  perseant 				}
   1402   1.84  perseant 			}
   1403   1.84  perseant 			KASSERT(pg != NULL);
   1404   1.84  perseant 			while (pg->flags & PG_BUSY) {
   1405   1.84  perseant 				pg->flags |= PG_WANTED;
   1406   1.84  perseant 				UVM_UNLOCK_AND_WAIT(pg, &vp->v_interlock, 0,
   1407   1.84  perseant 						    "lfsput", 0);
   1408   1.84  perseant 				simple_lock(&vp->v_interlock);
   1409   1.96  perseant 				if (by_list) {
   1410   1.96  perseant 					if (i > 0)
   1411   1.96  perseant 						uvm_page_unbusy(pgs, i);
   1412   1.84  perseant 					goto top;
   1413   1.96  perseant 				}
   1414   1.84  perseant 			}
   1415   1.84  perseant 			pg->flags |= PG_BUSY;
   1416   1.84  perseant 			UVM_PAGE_OWN(pg, "lfs_putpages");
   1417   1.84  perseant 
   1418   1.84  perseant 			pmap_page_protect(pg, VM_PROT_NONE);
   1419   1.84  perseant 			tdirty = (pmap_clear_modify(pg) ||
   1420   1.84  perseant 				  (pg->flags & PG_CLEAN) == 0);
   1421   1.84  perseant 			dirty += tdirty;
   1422   1.84  perseant 		}
   1423   1.84  perseant 		if (pages_per_block > 0 && nonexistent >= pages_per_block) {
   1424   1.84  perseant 			if (by_list) {
   1425   1.84  perseant 				curpg = TAILQ_NEXT(curpg, listq);
   1426   1.84  perseant 			} else {
   1427   1.84  perseant 				soff += fs->lfs_bsize;
   1428   1.84  perseant 			}
   1429   1.84  perseant 			continue;
   1430   1.84  perseant 		}
   1431   1.84  perseant 
   1432   1.84  perseant 		any_dirty += dirty;
   1433   1.84  perseant 		KASSERT(nonexistent == 0);
   1434   1.84  perseant 
   1435   1.84  perseant 		/*
   1436   1.84  perseant 		 * If any are dirty make all dirty; unbusy them,
   1437   1.88  perseant 		 * but if we were asked to clean, wire them so that
   1438   1.88  perseant 		 * the pagedaemon doesn't bother us about them while
   1439   1.88  perseant 		 * they're on their way to disk.
   1440   1.84  perseant 		 */
   1441   1.84  perseant 		for (i = 0; i == 0 || i < pages_per_block; i++) {
   1442   1.84  perseant 			pg = pgs[i];
   1443   1.84  perseant 			KASSERT(!((pg->flags & PG_CLEAN) && (pg->flags & PG_DELWRI)));
   1444   1.84  perseant 			if (dirty) {
   1445   1.84  perseant 				pg->flags &= ~PG_CLEAN;
   1446   1.84  perseant 				if (flags & PGO_FREE) {
   1447   1.84  perseant 					/* XXXUBC need better way to update */
   1448   1.96  perseant 					simple_lock(&lfs_subsys_lock);
   1449   1.84  perseant 					lfs_subsys_pages += MIN(1, pages_per_block);
   1450   1.96  perseant 					simple_unlock(&lfs_subsys_lock);
   1451   1.85      yamt 					/*
   1452   1.96  perseant 					 * Wire the page so that
   1453   1.96  perseant 					 * pdaemon doesn't see it again.
   1454   1.85      yamt 					 */
   1455   1.84  perseant 					uvm_lock_pageq();
   1456   1.85      yamt 					uvm_pagewire(pg);
   1457   1.85      yamt 					uvm_unlock_pageq();
   1458   1.88  perseant 
   1459   1.84  perseant 					/* Suspended write flag */
   1460   1.84  perseant 					pg->flags |= PG_DELWRI;
   1461   1.84  perseant 				}
   1462   1.84  perseant 			}
   1463   1.84  perseant 			if (pg->flags & PG_WANTED)
   1464   1.84  perseant 				wakeup(pg);
   1465   1.84  perseant 			pg->flags &= ~(PG_WANTED|PG_BUSY);
   1466   1.85      yamt 			UVM_PAGE_OWN(pg, NULL);
   1467   1.84  perseant 		}
   1468   1.84  perseant 
   1469  1.103  perseant 		if (checkfirst && any_dirty)
   1470  1.103  perseant 			return any_dirty;
   1471  1.103  perseant 
   1472   1.84  perseant 		if (by_list) {
   1473   1.84  perseant 			curpg = TAILQ_NEXT(curpg, listq);
   1474   1.84  perseant 		} else {
   1475   1.84  perseant 			soff += MAX(PAGE_SIZE, fs->lfs_bsize);
   1476   1.84  perseant 		}
   1477   1.84  perseant 	}
   1478   1.84  perseant 	if (by_list) {
   1479   1.84  perseant 		PRELE(l);
   1480   1.84  perseant 	}
   1481   1.84  perseant 
   1482   1.84  perseant 	/*
   1483   1.84  perseant 	 * If any pages were dirty, mark this inode as "pageout requested",
   1484   1.84  perseant 	 * and put it on the paging queue.
   1485   1.84  perseant 	 * XXXUBC locking (check locking on dchainhd too)
   1486   1.84  perseant 	 */
   1487   1.84  perseant #ifdef notyet
   1488   1.84  perseant 	if (any_dirty) {
   1489   1.84  perseant 		if (!(ip->i_flags & IN_PAGING)) {
   1490   1.84  perseant 			ip->i_flags |= IN_PAGING;
   1491   1.84  perseant 			TAILQ_INSERT_TAIL(&fs->lfs_pchainhd, ip, i_lfs_pchain);
   1492   1.84  perseant 		}
   1493   1.84  perseant 	}
   1494   1.84  perseant #endif
   1495   1.84  perseant 	return any_dirty;
   1496   1.84  perseant }
   1497   1.84  perseant 
   1498   1.84  perseant /*
   1499   1.84  perseant  * lfs_putpages functions like genfs_putpages except that
   1500   1.84  perseant  *
   1501   1.84  perseant  * (1) It needs to bounds-check the incoming requests to ensure that
   1502   1.84  perseant  *     they are block-aligned; if they are not, expand the range and
   1503   1.84  perseant  *     do the right thing in case, e.g., the requested range is clean
   1504   1.84  perseant  *     but the expanded range is dirty.
   1505   1.84  perseant  * (2) It needs to explicitly send blocks to be written when it is done.
   1506   1.84  perseant  *     VOP_PUTPAGES is not ever called with the seglock held, so
   1507   1.84  perseant  *     we simply take the seglock and let lfs_segunlock wait for us.
   1508   1.84  perseant  *     XXX Actually we can be called with the seglock held, if we have
   1509   1.84  perseant  *     XXX to flush a vnode while lfs_markv is in operation.  As of this
   1510   1.84  perseant  *     XXX writing we panic in this case.
   1511   1.84  perseant  *
   1512   1.84  perseant  * Assumptions:
   1513   1.84  perseant  *
   1514   1.84  perseant  * (1) The caller does not hold any pages in this vnode busy.  If it does,
   1515   1.84  perseant  *     there is a danger that when we expand the page range and busy the
   1516   1.84  perseant  *     pages we will deadlock.
   1517   1.84  perseant  * (2) We are called with vp->v_interlock held; we must return with it
   1518   1.84  perseant  *     released.
   1519   1.84  perseant  * (3) We don't absolutely have to free pages right away, provided that
   1520   1.84  perseant  *     the request does not have PGO_SYNCIO.  When the pagedaemon gives
   1521   1.84  perseant  *     us a request with PGO_FREE, we take the pages out of the paging
   1522   1.84  perseant  *     queue and wake up the writer, which will handle freeing them for us.
   1523   1.84  perseant  *
   1524   1.84  perseant  *     We ensure that for any filesystem block, all pages for that
   1525   1.84  perseant  *     block are either resident or not, even if those pages are higher
   1526   1.84  perseant  *     than EOF; that means that we will be getting requests to free
   1527   1.84  perseant  *     "unused" pages above EOF all the time, and should ignore them.
   1528   1.84  perseant  */
   1529   1.84  perseant 
   1530   1.84  perseant int
   1531   1.84  perseant lfs_putpages(void *v)
   1532   1.84  perseant {
   1533   1.84  perseant 	int error;
   1534   1.84  perseant 	struct vop_putpages_args /* {
   1535   1.84  perseant 		struct vnode *a_vp;
   1536   1.84  perseant 		voff_t a_offlo;
   1537   1.84  perseant 		voff_t a_offhi;
   1538   1.84  perseant 		int a_flags;
   1539   1.84  perseant 	} */ *ap = v;
   1540   1.84  perseant 	struct vnode *vp;
   1541   1.84  perseant 	struct inode *ip;
   1542   1.84  perseant 	struct lfs *fs;
   1543   1.84  perseant 	struct segment *sp;
   1544   1.84  perseant 	off_t origoffset, startoffset, endoffset, origendoffset, blkeof;
   1545   1.95  perseant 	off_t off, max_endoffset;
   1546   1.84  perseant 	int pages_per_block;
   1547   1.84  perseant 	int s, sync, dirty, pagedaemon;
   1548   1.95  perseant 	struct vm_page *pg;
   1549   1.84  perseant 	UVMHIST_FUNC("lfs_putpages"); UVMHIST_CALLED(ubchist);
   1550   1.84  perseant 
   1551   1.84  perseant 	vp = ap->a_vp;
   1552   1.84  perseant 	ip = VTOI(vp);
   1553   1.84  perseant 	fs = ip->i_lfs;
   1554   1.84  perseant 	sync = (ap->a_flags & PGO_SYNCIO);
   1555   1.84  perseant 	pagedaemon = (curproc == uvm.pagedaemon_proc);
   1556   1.84  perseant 
   1557   1.84  perseant 	/* Putpages does nothing for metadata. */
   1558   1.84  perseant 	if (vp == fs->lfs_ivnode || vp->v_type != VREG) {
   1559   1.84  perseant 		simple_unlock(&vp->v_interlock);
   1560   1.84  perseant 		return 0;
   1561   1.84  perseant 	}
   1562   1.84  perseant 
   1563   1.84  perseant 	/*
   1564   1.84  perseant 	 * If there are no pages, don't do anything.
   1565   1.84  perseant 	 */
   1566   1.84  perseant 	if (vp->v_uobj.uo_npages == 0) {
   1567   1.84  perseant 		s = splbio();
   1568   1.84  perseant 		if (LIST_FIRST(&vp->v_dirtyblkhd) == NULL &&
   1569   1.84  perseant 		    (vp->v_flag & VONWORKLST)) {
   1570   1.84  perseant 			vp->v_flag &= ~VONWORKLST;
   1571   1.84  perseant 			LIST_REMOVE(vp, v_synclist);
   1572   1.84  perseant 		}
   1573   1.84  perseant 		splx(s);
   1574   1.84  perseant 		simple_unlock(&vp->v_interlock);
   1575   1.84  perseant 		return 0;
   1576   1.84  perseant 	}
   1577   1.84  perseant 
   1578  1.102      fvdl 	blkeof = blkroundup(fs, ip->i_size);
   1579   1.84  perseant 
   1580   1.84  perseant 	/*
   1581   1.84  perseant 	 * Ignore requests to free pages past EOF but in the same block
   1582   1.84  perseant 	 * as EOF, unless the request is synchronous. (XXX why sync?)
   1583   1.84  perseant 	 * XXXUBC Make these pages look "active" so the pagedaemon won't
   1584   1.84  perseant 	 * XXXUBC bother us with them again.
   1585   1.84  perseant 	 */
   1586  1.102      fvdl 	if (!sync && ap->a_offlo >= ip->i_size && ap->a_offlo < blkeof) {
   1587   1.84  perseant 		origoffset = ap->a_offlo;
   1588   1.95  perseant 		for (off = origoffset; off < blkeof; off += fs->lfs_bsize) {
   1589   1.95  perseant 			pg = uvm_pagelookup(&vp->v_uobj, off);
   1590   1.95  perseant 			KASSERT(pg != NULL);
   1591   1.95  perseant 			while (pg->flags & PG_BUSY) {
   1592   1.95  perseant 				pg->flags |= PG_WANTED;
   1593   1.95  perseant 				UVM_UNLOCK_AND_WAIT(pg, &vp->v_interlock, 0,
   1594   1.95  perseant 						    "lfsput2", 0);
   1595   1.95  perseant 				simple_lock(&vp->v_interlock);
   1596   1.95  perseant 			}
   1597   1.95  perseant 			uvm_lock_pageq();
   1598   1.95  perseant 			uvm_pageactivate(pg);
   1599   1.95  perseant 			uvm_unlock_pageq();
   1600   1.95  perseant 		}
   1601   1.84  perseant 		ap->a_offlo = blkeof;
   1602   1.84  perseant 		if (ap->a_offhi > 0 && ap->a_offhi <= ap->a_offlo) {
   1603   1.84  perseant 			simple_unlock(&vp->v_interlock);
   1604   1.84  perseant 			return 0;
   1605   1.84  perseant 		}
   1606   1.84  perseant 	}
   1607   1.84  perseant 
   1608   1.84  perseant 	/*
   1609   1.84  perseant 	 * Extend page range to start and end at block boundaries.
   1610   1.84  perseant 	 * (For the purposes of VOP_PUTPAGES, fragments don't exist.)
   1611   1.84  perseant 	 */
   1612   1.84  perseant 	pages_per_block = fs->lfs_bsize >> PAGE_SHIFT;
   1613   1.86  perseant 	origoffset = ap->a_offlo;
   1614   1.84  perseant 	origendoffset = ap->a_offhi;
   1615   1.86  perseant 	startoffset = origoffset & ~(fs->lfs_bmask);
   1616   1.84  perseant 	max_endoffset = (trunc_page(LLONG_MAX) >> fs->lfs_bshift)
   1617   1.84  perseant 					       << fs->lfs_bshift;
   1618   1.84  perseant 
   1619   1.84  perseant 	if (origendoffset == 0 || ap->a_flags & PGO_ALLPAGES) {
   1620   1.86  perseant 		endoffset = max_endoffset;
   1621   1.84  perseant 		origendoffset = endoffset;
   1622   1.86  perseant 	} else {
   1623   1.84  perseant 		origendoffset = round_page(ap->a_offhi);
   1624   1.84  perseant 		endoffset = round_page(blkroundup(fs, origendoffset));
   1625   1.84  perseant 	}
   1626   1.84  perseant 
   1627   1.84  perseant 	KASSERT(startoffset > 0 || endoffset >= startoffset);
   1628   1.84  perseant 	if (startoffset == endoffset) {
   1629   1.84  perseant 		/* Nothing to do, why were we called? */
   1630   1.84  perseant 		simple_unlock(&vp->v_interlock);
   1631   1.84  perseant #ifdef DEBUG
   1632   1.84  perseant 		printf("lfs_putpages: startoffset = endoffset = %" PRId64 "\n",
   1633   1.84  perseant 			startoffset);
   1634   1.84  perseant #endif
   1635   1.84  perseant 		return 0;
   1636   1.84  perseant 	}
   1637   1.84  perseant 
   1638   1.84  perseant 	ap->a_offlo = startoffset;
   1639   1.84  perseant 	ap->a_offhi = endoffset;
   1640   1.84  perseant 
   1641   1.84  perseant 	if (!(ap->a_flags & PGO_CLEANIT))
   1642   1.84  perseant 		return genfs_putpages(v);
   1643   1.84  perseant 
   1644   1.84  perseant 	/*
   1645  1.103  perseant 	 * If there are more than one page per block, we don't want
   1646  1.103  perseant 	 * to get caught locking them backwards; so set PGO_BUSYFAIL
   1647  1.103  perseant 	 * to avoid deadlocks.
   1648   1.84  perseant 	 */
   1649  1.103  perseant 	ap->a_flags |= PGO_BUSYFAIL;
   1650  1.103  perseant 
   1651  1.103  perseant 	do {
   1652  1.103  perseant 		int r;
   1653  1.103  perseant 
   1654  1.103  perseant 		/* If no pages are dirty, we can just use genfs_getpages. */
   1655  1.103  perseant 		if ((dirty = check_dirty(fs, vp, startoffset, endoffset, blkeof,
   1656  1.103  perseant 					 ap->a_flags, 1)) != 0)
   1657  1.103  perseant 			break;
   1658  1.103  perseant 
   1659  1.103  perseant 		if ((r = genfs_putpages(v)) != EDEADLK)
   1660  1.103  perseant 			return r;
   1661  1.103  perseant 
   1662  1.103  perseant 		/* Start over. */
   1663  1.103  perseant 		preempt(NULL);
   1664  1.103  perseant 		simple_lock(&vp->v_interlock);
   1665  1.103  perseant 	} while(1);
   1666   1.84  perseant 
   1667   1.84  perseant 	/*
   1668   1.84  perseant 	 * Dirty and asked to clean.
   1669   1.84  perseant 	 *
   1670   1.84  perseant 	 * Pagedaemon can't actually write LFS pages; wake up
   1671   1.84  perseant 	 * the writer to take care of that.  The writer will
   1672   1.84  perseant 	 * notice the pager inode queue and act on that.
   1673   1.84  perseant 	 */
   1674   1.84  perseant 	if (pagedaemon) {
   1675   1.84  perseant 		++fs->lfs_pdflush;
   1676   1.84  perseant 		wakeup(&lfs_writer_daemon);
   1677   1.87      yamt 		simple_unlock(&vp->v_interlock);
   1678   1.84  perseant 		return EWOULDBLOCK;
   1679   1.84  perseant 	}
   1680   1.84  perseant 
   1681   1.84  perseant 	/*
   1682   1.84  perseant 	 * If this is a file created in a recent dirop, we can't flush its
   1683   1.84  perseant 	 * inode until the dirop is complete.  Drain dirops, then flush the
   1684   1.84  perseant 	 * filesystem (taking care of any other pending dirops while we're
   1685   1.84  perseant 	 * at it).
   1686   1.84  perseant 	 */
   1687   1.84  perseant 	if ((ap->a_flags & (PGO_CLEANIT|PGO_LOCKED)) == PGO_CLEANIT &&
   1688   1.84  perseant 	    (vp->v_flag & VDIROP)) {
   1689   1.84  perseant 		int locked;
   1690   1.84  perseant 
   1691   1.84  perseant 		/* printf("putpages to clean VDIROP, flushing\n"); */
   1692   1.84  perseant 		while (fs->lfs_dirops > 0) {
   1693   1.84  perseant 			++fs->lfs_diropwait;
   1694   1.84  perseant 			tsleep(&fs->lfs_writer, PRIBIO+1, "ppdirop", 0);
   1695   1.84  perseant 			--fs->lfs_diropwait;
   1696   1.84  perseant 		}
   1697   1.84  perseant 		++fs->lfs_writer;
   1698   1.84  perseant 		locked = VOP_ISLOCKED(vp) && /* XXX */
   1699   1.84  perseant 			vp->v_lock.lk_lockholder == curproc->p_pid;
   1700   1.84  perseant 		if (locked)
   1701   1.84  perseant 			VOP_UNLOCK(vp, 0);
   1702   1.84  perseant 		simple_unlock(&vp->v_interlock);
   1703   1.84  perseant 
   1704   1.84  perseant 		lfs_flush_fs(fs, sync ? SEGM_SYNC : 0);
   1705   1.84  perseant 
   1706   1.84  perseant 		simple_lock(&vp->v_interlock);
   1707   1.84  perseant 		if (locked)
   1708   1.84  perseant 			VOP_LOCK(vp, LK_EXCLUSIVE);
   1709   1.84  perseant 		if (--fs->lfs_writer == 0)
   1710   1.84  perseant 			wakeup(&fs->lfs_dirops);
   1711   1.84  perseant 
   1712   1.84  perseant 		/* XXX the flush should have taken care of this one too! */
   1713   1.84  perseant 	}
   1714   1.84  perseant 
   1715   1.84  perseant 	/*
   1716   1.86  perseant 	 * This is it.	We are going to write some pages.  From here on
   1717   1.84  perseant 	 * down it's all just mechanics.
   1718   1.84  perseant 	 *
   1719  1.103  perseant 	 * Don't let genfs_putpages wait; lfs_segunlock will wait for us.
   1720   1.84  perseant 	 */
   1721   1.84  perseant 	ap->a_flags &= ~PGO_SYNCIO;
   1722   1.84  perseant 
   1723   1.84  perseant 	/*
   1724   1.84  perseant 	 * If we've already got the seglock, flush the node and return.
   1725   1.84  perseant 	 * The FIP has already been set up for us by lfs_writefile,
   1726   1.84  perseant 	 * and FIP cleanup and lfs_updatemeta will also be done there,
   1727   1.84  perseant 	 * unless genfs_putpages returns EDEADLK; then we must flush
   1728   1.84  perseant 	 * what we have, and correct FIP and segment header accounting.
   1729   1.84  perseant 	 */
   1730   1.84  perseant 	if (ap->a_flags & PGO_LOCKED) {
   1731   1.84  perseant 		sp = fs->lfs_sp;
   1732   1.84  perseant 		sp->vp = vp;
   1733   1.84  perseant 
   1734  1.103  perseant 		/*
   1735  1.103  perseant 		 * Make sure that all pages in any given block are dirty, or
   1736  1.103  perseant 		 * none of them are.
   1737  1.103  perseant 		 */
   1738  1.103  perseant 	    again:
   1739  1.103  perseant 		check_dirty(fs, vp, startoffset, endoffset, blkeof,
   1740  1.103  perseant 			    ap->a_flags, 1);
   1741  1.103  perseant 
   1742  1.103  perseant 		if ((error = genfs_putpages(v)) == EDEADLK) {
   1743   1.84  perseant #ifdef DEBUG_LFS
   1744   1.84  perseant 			printf("lfs_putpages: genfs_putpages returned EDEADLK"
   1745   1.84  perseant 			       " ino %d off %x (seg %d)\n",
   1746   1.84  perseant 			       ip->i_number, fs->lfs_offset,
   1747   1.84  perseant 			       dtosn(fs, fs->lfs_offset));
   1748   1.84  perseant #endif
   1749   1.88  perseant 			/* If nothing to write, short-circuit */
   1750   1.88  perseant 			if (sp->cbpp - sp->bpp == 1) {
   1751   1.88  perseant 				preempt(NULL);
   1752   1.88  perseant 				simple_lock(&vp->v_interlock);
   1753  1.103  perseant 				goto again;
   1754   1.88  perseant 			}
   1755   1.84  perseant 			/* Write gathered pages */
   1756   1.86  perseant 			lfs_updatemeta(sp);
   1757   1.86  perseant 			(void) lfs_writeseg(fs, sp);
   1758   1.84  perseant 
   1759   1.84  perseant 			/* Reinitialize brand new FIP and add us to it */
   1760   1.84  perseant 			sp->vp = vp;
   1761  1.102      fvdl 			sp->fip->fi_version = ip->i_gen;
   1762   1.86  perseant 			sp->fip->fi_ino = ip->i_number;
   1763   1.86  perseant 			/* Add us to the new segment summary. */
   1764   1.86  perseant 			++((SEGSUM *)(sp->segsum))->ss_nfinfo;
   1765   1.86  perseant 			sp->sum_bytes_left -=
   1766   1.86  perseant 				sizeof(struct finfo) - sizeof(int32_t);
   1767   1.84  perseant 
   1768   1.84  perseant 			/* Give the write a chance to complete */
   1769   1.84  perseant 			preempt(NULL);
   1770  1.103  perseant 
   1771  1.103  perseant 			/* We've lost the interlock.  Start over. */
   1772   1.84  perseant 			simple_lock(&vp->v_interlock);
   1773  1.103  perseant 			goto again;
   1774   1.84  perseant 		}
   1775  1.103  perseant 		lfs_updatemeta(sp);
   1776   1.84  perseant 		return error;
   1777   1.84  perseant 	}
   1778   1.84  perseant 
   1779   1.87      yamt 	simple_unlock(&vp->v_interlock);
   1780   1.84  perseant 	/*
   1781   1.84  perseant 	 * Take the seglock, because we are going to be writing pages.
   1782   1.84  perseant 	 */
   1783   1.84  perseant 	if ((error = lfs_seglock(fs, SEGM_PROT | (sync ? SEGM_SYNC : 0))) != 0)
   1784   1.84  perseant 		return error;
   1785   1.84  perseant 
   1786   1.84  perseant 	/*
   1787   1.84  perseant 	 * VOP_PUTPAGES should not be called while holding the seglock.
   1788   1.93  perseant 	 * XXXUBC fix lfs_markv, or do this properly.
   1789   1.84  perseant 	 */
   1790   1.93  perseant 	/* KASSERT(fs->lfs_seglock == 1); */
   1791   1.84  perseant 
   1792   1.84  perseant 	/*
   1793   1.84  perseant 	 * We assume we're being called with sp->fip pointing at blank space.
   1794   1.84  perseant 	 * Account for a new FIP in the segment header, and set sp->vp.
   1795   1.84  perseant 	 * (This should duplicate the setup at the top of lfs_writefile().)
   1796   1.84  perseant 	 */
   1797   1.84  perseant 	sp = fs->lfs_sp;
   1798   1.86  perseant 	if (sp->seg_bytes_left < fs->lfs_bsize ||
   1799   1.86  perseant 	    sp->sum_bytes_left < sizeof(struct finfo))
   1800   1.86  perseant 		(void) lfs_writeseg(fs, fs->lfs_sp);
   1801   1.84  perseant 
   1802   1.86  perseant 	sp->sum_bytes_left -= sizeof(struct finfo) - sizeof(int32_t);
   1803   1.86  perseant 	++((SEGSUM *)(sp->segsum))->ss_nfinfo;
   1804   1.84  perseant 	sp->vp = vp;
   1805   1.84  perseant 
   1806   1.86  perseant 	if (vp->v_flag & VDIROP)
   1807   1.86  perseant 		((SEGSUM *)(sp->segsum))->ss_flags |= (SS_DIROP|SS_CONT);
   1808   1.84  perseant 
   1809   1.86  perseant 	sp->fip->fi_nblocks = 0;
   1810   1.86  perseant 	sp->fip->fi_ino = ip->i_number;
   1811  1.102      fvdl 	sp->fip->fi_version = ip->i_gen;
   1812   1.84  perseant 
   1813   1.84  perseant 	/*
   1814   1.84  perseant 	 * Loop through genfs_putpages until all pages are gathered.
   1815   1.88  perseant 	 * genfs_putpages() drops the interlock, so reacquire it if necessary.
   1816  1.103  perseant 	 * Whenever we lose the interlock we have to rerun check_dirty, as
   1817  1.103  perseant 	 * well.
   1818   1.84  perseant 	 */
   1819  1.103  perseant     again2:
   1820   1.87      yamt 	simple_lock(&vp->v_interlock);
   1821  1.103  perseant 	check_dirty(fs, vp, startoffset, endoffset, blkeof, ap->a_flags, 1);
   1822  1.103  perseant 
   1823  1.103  perseant 	if ((error = genfs_putpages(v)) == EDEADLK) {
   1824   1.84  perseant #ifdef DEBUG_LFS
   1825   1.84  perseant 		printf("lfs_putpages: genfs_putpages returned EDEADLK [2]"
   1826   1.84  perseant 		       " ino %d off %x (seg %d)\n",
   1827   1.84  perseant 		       ip->i_number, fs->lfs_offset,
   1828   1.84  perseant 		       dtosn(fs, fs->lfs_offset));
   1829   1.84  perseant #endif
   1830   1.88  perseant 		/* If nothing to write, short-circuit */
   1831   1.88  perseant 		if (sp->cbpp - sp->bpp == 1) {
   1832   1.88  perseant 			preempt(NULL);
   1833  1.103  perseant 			goto again2;
   1834   1.88  perseant 		}
   1835   1.84  perseant 		/* Write gathered pages */
   1836   1.86  perseant 		lfs_updatemeta(sp);
   1837   1.86  perseant 		(void) lfs_writeseg(fs, sp);
   1838   1.84  perseant 
   1839   1.84  perseant 		/*
   1840   1.84  perseant 		 * Reinitialize brand new FIP and add us to it.
   1841   1.84  perseant 		 * (This should duplicate the fixup in lfs_gatherpages().)
   1842   1.84  perseant 		 */
   1843   1.84  perseant 		sp->vp = vp;
   1844  1.102      fvdl 		sp->fip->fi_version = ip->i_gen;
   1845   1.86  perseant 		sp->fip->fi_ino = ip->i_number;
   1846   1.86  perseant 		/* Add us to the new segment summary. */
   1847   1.86  perseant 		++((SEGSUM *)(sp->segsum))->ss_nfinfo;
   1848   1.86  perseant 		sp->sum_bytes_left -=
   1849   1.86  perseant 			sizeof(struct finfo) - sizeof(int32_t);
   1850   1.84  perseant 
   1851   1.84  perseant 		/* Give the write a chance to complete */
   1852   1.84  perseant 		preempt(NULL);
   1853  1.103  perseant 
   1854  1.103  perseant 		/* We've lost the interlock.  Start over. */
   1855  1.103  perseant 		goto again2;
   1856   1.84  perseant 	}
   1857  1.103  perseant 
   1858  1.103  perseant 	/* Write indirect blocks as well */
   1859  1.103  perseant 	lfs_gather(fs, fs->lfs_sp, vp, lfs_match_indir);
   1860  1.103  perseant 	lfs_gather(fs, fs->lfs_sp, vp, lfs_match_dindir);
   1861  1.103  perseant 	lfs_gather(fs, fs->lfs_sp, vp, lfs_match_tindir);
   1862   1.84  perseant 
   1863   1.84  perseant 	/*
   1864   1.84  perseant 	 * Blocks are now gathered into a segment waiting to be written.
   1865   1.84  perseant 	 * All that's left to do is update metadata, and write them.
   1866   1.84  perseant 	 */
   1867   1.84  perseant 	lfs_updatemeta(fs->lfs_sp);
   1868   1.84  perseant 	fs->lfs_sp->vp = NULL;
   1869   1.84  perseant 	/*
   1870   1.88  perseant 	 * Clean up FIP, since we're done writing this file.
   1871   1.88  perseant 	 * This should duplicate cleanup at the end of lfs_writefile().
   1872   1.84  perseant 	 */
   1873   1.86  perseant 	if (sp->fip->fi_nblocks != 0) {
   1874   1.86  perseant 		sp->fip = (FINFO*)((caddr_t)sp->fip + sizeof(struct finfo) +
   1875   1.84  perseant 			sizeof(int32_t) * (sp->fip->fi_nblocks - 1));
   1876   1.86  perseant 		sp->start_lbp = &sp->fip->fi_blocks[0];
   1877   1.86  perseant 	} else {
   1878   1.86  perseant 		sp->sum_bytes_left += sizeof(FINFO) - sizeof(int32_t);
   1879   1.86  perseant 		--((SEGSUM *)(sp->segsum))->ss_nfinfo;
   1880   1.86  perseant 	}
   1881   1.88  perseant 	lfs_writeseg(fs, fs->lfs_sp);
   1882   1.88  perseant 
   1883   1.84  perseant 	/*
   1884   1.84  perseant 	 * XXX - with the malloc/copy writeseg, the pages are freed by now
   1885   1.84  perseant 	 * even if we don't wait (e.g. if we hold a nested lock).  This
   1886   1.84  perseant 	 * will not be true if we stop using malloc/copy.
   1887   1.84  perseant 	 */
   1888   1.84  perseant 	KASSERT(fs->lfs_sp->seg_flags & SEGM_PROT);
   1889   1.84  perseant 	lfs_segunlock(fs);
   1890   1.84  perseant 
   1891   1.84  perseant 	/*
   1892   1.84  perseant 	 * Wait for v_numoutput to drop to zero.  The seglock should
   1893   1.84  perseant 	 * take care of this, but there is a slight possibility that
   1894   1.84  perseant 	 * aiodoned might not have got around to our buffers yet.
   1895   1.84  perseant 	 */
   1896   1.84  perseant 	if (sync) {
   1897   1.84  perseant 		int s;
   1898   1.84  perseant 
   1899   1.84  perseant 		s = splbio();
   1900   1.84  perseant 		simple_lock(&global_v_numoutput_slock);
   1901   1.98  perseant 		while (vp->v_numoutput > 0) {
   1902   1.84  perseant #ifdef DEBUG
   1903   1.84  perseant 			printf("ino %d sleeping on num %d\n",
   1904   1.84  perseant 				ip->i_number, vp->v_numoutput);
   1905   1.84  perseant #endif
   1906   1.84  perseant 			vp->v_flag |= VBWAIT;
   1907   1.87      yamt 			ltsleep(&vp->v_numoutput, PRIBIO + 1, "lfs_vn", 0,
   1908   1.87      yamt 			    &global_v_numoutput_slock);
   1909   1.84  perseant 		}
   1910   1.84  perseant 		simple_unlock(&global_v_numoutput_slock);
   1911   1.84  perseant 		splx(s);
   1912   1.84  perseant 	}
   1913   1.84  perseant 	return error;
   1914   1.84  perseant }
   1915   1.84  perseant 
   1916   1.84  perseant /*
   1917   1.84  perseant  * Return the last logical file offset that should be written for this file
   1918   1.86  perseant  * if we're doing a write that ends at "size".	If writing, we need to know
   1919   1.84  perseant  * about sizes on disk, i.e. fragments if there are any; if reading, we need
   1920   1.84  perseant  * to know about entire blocks.
   1921   1.84  perseant  */
   1922   1.84  perseant void
   1923   1.84  perseant lfs_gop_size(struct vnode *vp, off_t size, off_t *eobp, int flags)
   1924   1.84  perseant {
   1925   1.84  perseant 	struct inode *ip = VTOI(vp);
   1926   1.84  perseant 	struct lfs *fs = ip->i_lfs;
   1927   1.84  perseant 	daddr_t olbn, nlbn;
   1928   1.84  perseant 
   1929   1.84  perseant 	KASSERT(flags & (GOP_SIZE_READ | GOP_SIZE_WRITE));
   1930   1.84  perseant 	KASSERT((flags & (GOP_SIZE_READ | GOP_SIZE_WRITE))
   1931   1.84  perseant 		!= (GOP_SIZE_READ | GOP_SIZE_WRITE));
   1932   1.84  perseant 
   1933  1.102      fvdl 	olbn = lblkno(fs, ip->i_size);
   1934   1.84  perseant 	nlbn = lblkno(fs, size);
   1935   1.86  perseant 	if ((flags & GOP_SIZE_WRITE) && nlbn < NDADDR && olbn <= nlbn) {
   1936   1.86  perseant 		*eobp = fragroundup(fs, size);
   1937   1.86  perseant 	} else {
   1938   1.86  perseant 		*eobp = blkroundup(fs, size);
   1939   1.86  perseant 	}
   1940   1.84  perseant }
   1941   1.84  perseant 
   1942   1.84  perseant #ifdef DEBUG
   1943   1.84  perseant void lfs_dump_vop(void *);
   1944   1.84  perseant 
   1945   1.84  perseant void
   1946   1.84  perseant lfs_dump_vop(void *v)
   1947   1.84  perseant {
   1948   1.86  perseant 	struct vop_putpages_args /* {
   1949   1.86  perseant 		struct vnode *a_vp;
   1950   1.86  perseant 		voff_t a_offlo;
   1951   1.86  perseant 		voff_t a_offhi;
   1952   1.86  perseant 		int a_flags;
   1953   1.86  perseant 	} */ *ap = v;
   1954   1.84  perseant 
   1955   1.84  perseant 	vfs_vnode_print(ap->a_vp, 0, printf);
   1956  1.102      fvdl 	lfs_dump_dinode(VTOI(ap->a_vp)->i_din.ffs1_din);
   1957   1.84  perseant }
   1958   1.84  perseant #endif
   1959   1.84  perseant 
   1960   1.84  perseant int
   1961   1.84  perseant lfs_mmap(void *v)
   1962   1.84  perseant {
   1963   1.84  perseant 	struct vop_mmap_args /* {
   1964   1.86  perseant 		const struct vnodeop_desc *a_desc;
   1965   1.86  perseant 		struct vnode *a_vp;
   1966   1.86  perseant 		int a_fflags;
   1967   1.86  perseant 		struct ucred *a_cred;
   1968   1.86  perseant 		struct proc *a_p;
   1969   1.84  perseant 	} */ *ap = v;
   1970   1.84  perseant 
   1971   1.84  perseant 	if (VTOI(ap->a_vp)->i_number == LFS_IFILE_INUM)
   1972   1.84  perseant 		return EOPNOTSUPP;
   1973   1.84  perseant 	return ufs_mmap(v);
   1974   1.84  perseant }
   1975