Home | History | Annotate | Line # | Download | only in lfs
lfs_segment.c revision 1.72
      1  1.72     lukem /*	$NetBSD: lfs_segment.c,v 1.72 2001/11/08 02:39:11 lukem Exp $	*/
      2   1.2       cgd 
      3  1.15  perseant /*-
      4  1.58  perseant  * Copyright (c) 1999, 2000 The NetBSD Foundation, Inc.
      5  1.15  perseant  * All rights reserved.
      6  1.15  perseant  *
      7  1.15  perseant  * This code is derived from software contributed to The NetBSD Foundation
      8  1.15  perseant  * by Konrad E. Schroder <perseant (at) hhhh.org>.
      9  1.15  perseant  *
     10  1.15  perseant  * Redistribution and use in source and binary forms, with or without
     11  1.15  perseant  * modification, are permitted provided that the following conditions
     12  1.15  perseant  * are met:
     13  1.15  perseant  * 1. Redistributions of source code must retain the above copyright
     14  1.15  perseant  *    notice, this list of conditions and the following disclaimer.
     15  1.15  perseant  * 2. Redistributions in binary form must reproduce the above copyright
     16  1.15  perseant  *    notice, this list of conditions and the following disclaimer in the
     17  1.15  perseant  *    documentation and/or other materials provided with the distribution.
     18  1.15  perseant  * 3. All advertising materials mentioning features or use of this software
     19  1.15  perseant  *    must display the following acknowledgement:
     20  1.15  perseant  *      This product includes software developed by the NetBSD
     21  1.15  perseant  *      Foundation, Inc. and its contributors.
     22  1.15  perseant  * 4. Neither the name of The NetBSD Foundation nor the names of its
     23  1.15  perseant  *    contributors may be used to endorse or promote products derived
     24  1.15  perseant  *    from this software without specific prior written permission.
     25  1.15  perseant  *
     26  1.15  perseant  * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
     27  1.15  perseant  * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
     28  1.15  perseant  * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
     29  1.15  perseant  * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
     30  1.15  perseant  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
     31  1.15  perseant  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
     32  1.15  perseant  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
     33  1.15  perseant  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
     34  1.15  perseant  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
     35  1.15  perseant  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
     36  1.15  perseant  * POSSIBILITY OF SUCH DAMAGE.
     37  1.15  perseant  */
     38   1.1   mycroft /*
     39   1.1   mycroft  * Copyright (c) 1991, 1993
     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.10      fvdl  *	@(#)lfs_segment.c	8.10 (Berkeley) 6/10/95
     71   1.1   mycroft  */
     72  1.72     lukem 
     73  1.72     lukem #include <sys/cdefs.h>
     74  1.72     lukem __KERNEL_RCSID(0, "$NetBSD: lfs_segment.c,v 1.72 2001/11/08 02:39:11 lukem Exp $");
     75   1.1   mycroft 
     76  1.16  perseant #define ivndebug(vp,str) printf("ino %d: %s\n",VTOI(vp)->i_number,(str))
     77  1.16  perseant 
     78  1.68       mrg #if defined(_KERNEL_OPT)
     79  1.30  perseant #include "opt_ddb.h"
     80  1.65  jdolecek #endif
     81  1.65  jdolecek 
     82   1.1   mycroft #include <sys/param.h>
     83   1.1   mycroft #include <sys/systm.h>
     84   1.1   mycroft #include <sys/namei.h>
     85   1.1   mycroft #include <sys/kernel.h>
     86   1.1   mycroft #include <sys/resourcevar.h>
     87   1.1   mycroft #include <sys/file.h>
     88   1.1   mycroft #include <sys/stat.h>
     89   1.1   mycroft #include <sys/buf.h>
     90   1.1   mycroft #include <sys/proc.h>
     91   1.1   mycroft #include <sys/conf.h>
     92   1.1   mycroft #include <sys/vnode.h>
     93   1.1   mycroft #include <sys/malloc.h>
     94   1.1   mycroft #include <sys/mount.h>
     95   1.1   mycroft 
     96   1.1   mycroft #include <miscfs/specfs/specdev.h>
     97   1.1   mycroft #include <miscfs/fifofs/fifo.h>
     98   1.1   mycroft 
     99   1.1   mycroft #include <ufs/ufs/inode.h>
    100   1.1   mycroft #include <ufs/ufs/dir.h>
    101   1.1   mycroft #include <ufs/ufs/ufsmount.h>
    102   1.1   mycroft #include <ufs/ufs/ufs_extern.h>
    103   1.1   mycroft 
    104   1.1   mycroft #include <ufs/lfs/lfs.h>
    105   1.1   mycroft #include <ufs/lfs/lfs_extern.h>
    106   1.1   mycroft 
    107  1.69  perseant extern int count_lock_queue(void);
    108  1.10      fvdl extern struct simplelock vnode_free_list_slock;		/* XXX */
    109   1.1   mycroft 
    110   1.1   mycroft /*
    111   1.1   mycroft  * Determine if it's OK to start a partial in this segment, or if we need
    112   1.1   mycroft  * to go on to a new segment.
    113   1.1   mycroft  */
    114   1.1   mycroft #define	LFS_PARTIAL_FITS(fs) \
    115  1.69  perseant 	((fs)->lfs_fsbpseg - ((fs)->lfs_offset - (fs)->lfs_curseg) > \
    116  1.69  perseant 	fragstofsb((fs), (fs)->lfs_frag))
    117   1.1   mycroft 
    118  1.69  perseant void	 lfs_callback(struct buf *);
    119  1.69  perseant int	 lfs_gather(struct lfs *, struct segment *,
    120  1.69  perseant 	     struct vnode *, int (*)(struct lfs *, struct buf *));
    121  1.69  perseant int	 lfs_gatherblock(struct segment *, struct buf *, int *);
    122  1.69  perseant void	 lfs_iset(struct inode *, ufs_daddr_t, time_t);
    123  1.69  perseant int	 lfs_match_fake(struct lfs *, struct buf *);
    124  1.69  perseant int	 lfs_match_data(struct lfs *, struct buf *);
    125  1.69  perseant int	 lfs_match_dindir(struct lfs *, struct buf *);
    126  1.69  perseant int	 lfs_match_indir(struct lfs *, struct buf *);
    127  1.69  perseant int	 lfs_match_tindir(struct lfs *, struct buf *);
    128  1.69  perseant void	 lfs_newseg(struct lfs *);
    129  1.69  perseant void	 lfs_shellsort(struct buf **, ufs_daddr_t *, int);
    130  1.69  perseant void	 lfs_supercallback(struct buf *);
    131  1.69  perseant void	 lfs_updatemeta(struct segment *);
    132  1.69  perseant int	 lfs_vref(struct vnode *);
    133  1.69  perseant void	 lfs_vunref(struct vnode *);
    134  1.69  perseant void	 lfs_writefile(struct lfs *, struct segment *, struct vnode *);
    135  1.69  perseant int	 lfs_writeinode(struct lfs *, struct segment *, struct inode *);
    136  1.69  perseant int	 lfs_writeseg(struct lfs *, struct segment *);
    137  1.69  perseant void	 lfs_writesuper(struct lfs *, daddr_t);
    138  1.69  perseant int	 lfs_writevnodes(struct lfs *fs, struct mount *mp,
    139  1.69  perseant 	    struct segment *sp, int dirops);
    140   1.1   mycroft 
    141   1.1   mycroft int	lfs_allclean_wakeup;		/* Cleaner wakeup address. */
    142  1.15  perseant int	lfs_writeindir = 1;             /* whether to flush indir on non-ckp */
    143  1.25  perseant int	lfs_clean_vnhead = 0;		/* Allow freeing to head of vn list */
    144  1.32  perseant int	lfs_dirvcount = 0;		/* # active dirops */
    145   1.1   mycroft 
    146   1.1   mycroft /* Statistics Counters */
    147  1.15  perseant int lfs_dostats = 1;
    148   1.1   mycroft struct lfs_stats lfs_stats;
    149   1.1   mycroft 
    150  1.62  perseant extern int locked_queue_count;
    151  1.62  perseant extern long locked_queue_bytes;
    152  1.62  perseant 
    153   1.1   mycroft /* op values to lfs_writevnodes */
    154  1.15  perseant #define	VN_REG	        0
    155   1.1   mycroft #define	VN_DIROP	1
    156   1.1   mycroft #define	VN_EMPTY	2
    157  1.15  perseant #define VN_CLEAN        3
    158  1.15  perseant 
    159  1.15  perseant #define LFS_MAX_ACTIVE          10
    160  1.15  perseant 
    161  1.15  perseant /*
    162  1.15  perseant  * XXX KS - Set modification time on the Ifile, so the cleaner can
    163  1.15  perseant  * read the fs mod time off of it.  We don't set IN_UPDATE here,
    164  1.15  perseant  * since we don't really need this to be flushed to disk (and in any
    165  1.15  perseant  * case that wouldn't happen to the Ifile until we checkpoint).
    166  1.15  perseant  */
    167  1.15  perseant void
    168  1.69  perseant lfs_imtime(struct lfs *fs)
    169  1.15  perseant {
    170  1.15  perseant 	struct timespec ts;
    171  1.15  perseant 	struct inode *ip;
    172  1.15  perseant 
    173  1.15  perseant 	TIMEVAL_TO_TIMESPEC(&time, &ts);
    174  1.15  perseant 	ip = VTOI(fs->lfs_ivnode);
    175  1.15  perseant 	ip->i_ffs_mtime = ts.tv_sec;
    176  1.15  perseant 	ip->i_ffs_mtimensec = ts.tv_nsec;
    177  1.15  perseant }
    178   1.1   mycroft 
    179   1.1   mycroft /*
    180   1.1   mycroft  * Ifile and meta data blocks are not marked busy, so segment writes MUST be
    181   1.1   mycroft  * single threaded.  Currently, there are two paths into lfs_segwrite, sync()
    182   1.1   mycroft  * and getnewbuf().  They both mark the file system busy.  Lfs_vflush()
    183   1.1   mycroft  * explicitly marks the file system busy.  So lfs_segwrite is safe.  I think.
    184   1.1   mycroft  */
    185   1.1   mycroft 
    186  1.15  perseant #define SET_FLUSHING(fs,vp) (fs)->lfs_flushvp = (vp)
    187  1.15  perseant #define IS_FLUSHING(fs,vp)  ((fs)->lfs_flushvp == (vp))
    188  1.15  perseant #define CLR_FLUSHING(fs,vp) (fs)->lfs_flushvp = NULL
    189  1.15  perseant 
    190   1.1   mycroft int
    191  1.69  perseant lfs_vflush(struct vnode *vp)
    192   1.1   mycroft {
    193   1.1   mycroft 	struct inode *ip;
    194   1.1   mycroft 	struct lfs *fs;
    195   1.1   mycroft 	struct segment *sp;
    196  1.38  perseant 	struct buf *bp, *nbp, *tbp, *tnbp;
    197  1.30  perseant 	int error, s;
    198  1.19  perseant 
    199  1.22  perseant 	ip = VTOI(vp);
    200  1.22  perseant 	fs = VFSTOUFS(vp->v_mount)->um_lfs;
    201  1.22  perseant 
    202  1.19  perseant 	if(ip->i_flag & IN_CLEANING) {
    203  1.19  perseant #ifdef DEBUG_LFS
    204  1.19  perseant 		ivndebug(vp,"vflush/in_cleaning");
    205  1.19  perseant #endif
    206  1.56  perseant 		LFS_CLR_UINO(ip, IN_CLEANING);
    207  1.56  perseant 		LFS_SET_UINO(ip, IN_MODIFIED);
    208  1.56  perseant 
    209  1.38  perseant 		/*
    210  1.38  perseant 		 * Toss any cleaning buffers that have real counterparts
    211  1.38  perseant 		 * to avoid losing new data
    212  1.38  perseant 		 */
    213  1.38  perseant 		s = splbio();
    214  1.38  perseant 		for(bp=vp->v_dirtyblkhd.lh_first; bp; bp=nbp) {
    215  1.38  perseant 			nbp = bp->b_vnbufs.le_next;
    216  1.38  perseant 			if(bp->b_flags & B_CALL) {
    217  1.38  perseant 				for(tbp=vp->v_dirtyblkhd.lh_first; tbp;
    218  1.38  perseant 				    tbp=tnbp)
    219  1.38  perseant 				{
    220  1.38  perseant 					tnbp = tbp->b_vnbufs.le_next;
    221  1.38  perseant 					if(tbp->b_vp == bp->b_vp
    222  1.38  perseant 					   && tbp->b_lblkno == bp->b_lblkno
    223  1.38  perseant 					   && tbp != bp)
    224  1.38  perseant 					{
    225  1.69  perseant 						fs->lfs_avail += btofsb(fs, bp->b_bcount);
    226  1.62  perseant 						wakeup(&fs->lfs_avail);
    227  1.38  perseant 						lfs_freebuf(bp);
    228  1.69  perseant 						bp = NULL;
    229  1.69  perseant 						break;
    230  1.38  perseant 					}
    231  1.38  perseant 				}
    232  1.38  perseant 			}
    233  1.38  perseant 		}
    234  1.38  perseant 		splx(s);
    235  1.19  perseant 	}
    236  1.19  perseant 
    237  1.19  perseant 	/* If the node is being written, wait until that is done */
    238  1.19  perseant 	if(WRITEINPROG(vp)) {
    239  1.19  perseant #ifdef DEBUG_LFS
    240  1.19  perseant 		ivndebug(vp,"vflush/writeinprog");
    241  1.19  perseant #endif
    242  1.19  perseant 		tsleep(vp, PRIBIO+1, "lfs_vw", 0);
    243  1.19  perseant 	}
    244   1.1   mycroft 
    245  1.15  perseant 	/* Protect against VXLOCK deadlock in vinvalbuf() */
    246   1.1   mycroft 	lfs_seglock(fs, SEGM_SYNC);
    247  1.30  perseant 
    248  1.30  perseant 	/* If we're supposed to flush a freed inode, just toss it */
    249  1.30  perseant 	/* XXX - seglock, so these buffers can't be gathered, right? */
    250  1.30  perseant 	if(ip->i_ffs_mode == 0) {
    251  1.30  perseant 		printf("lfs_vflush: ino %d is freed, not flushing\n",
    252  1.30  perseant 			ip->i_number);
    253  1.30  perseant 		s = splbio();
    254  1.30  perseant 		for(bp=vp->v_dirtyblkhd.lh_first; bp; bp=nbp) {
    255  1.30  perseant 			nbp = bp->b_vnbufs.le_next;
    256  1.62  perseant 			if (bp->b_flags & B_DELWRI) { /* XXX always true? */
    257  1.69  perseant 				fs->lfs_avail += btofsb(fs, bp->b_bcount);
    258  1.62  perseant 				wakeup(&fs->lfs_avail);
    259  1.62  perseant 			}
    260  1.30  perseant 			/* Copied from lfs_writeseg */
    261  1.30  perseant 			if (bp->b_flags & B_CALL) {
    262  1.30  perseant 				/* if B_CALL, it was created with newbuf */
    263  1.30  perseant 				lfs_freebuf(bp);
    264  1.69  perseant 				bp = NULL;
    265  1.30  perseant 			} else {
    266  1.30  perseant 				bremfree(bp);
    267  1.62  perseant 				LFS_UNLOCK_BUF(bp);
    268  1.30  perseant 				bp->b_flags &= ~(B_ERROR | B_READ | B_DELWRI |
    269  1.62  perseant                                          B_GATHERED);
    270  1.30  perseant 				bp->b_flags |= B_DONE;
    271  1.30  perseant 				reassignbuf(bp, vp);
    272  1.30  perseant 				brelse(bp);
    273  1.30  perseant 			}
    274  1.30  perseant 		}
    275  1.30  perseant 		splx(s);
    276  1.56  perseant 		LFS_CLR_UINO(ip, IN_CLEANING);
    277  1.56  perseant 		LFS_CLR_UINO(ip, IN_MODIFIED | IN_ACCESSED);
    278  1.47  perseant 		ip->i_flag &= ~IN_ALLMOD;
    279  1.30  perseant 		printf("lfs_vflush: done not flushing ino %d\n",
    280  1.30  perseant 			ip->i_number);
    281  1.30  perseant 		lfs_segunlock(fs);
    282  1.30  perseant 		return 0;
    283  1.30  perseant 	}
    284  1.30  perseant 
    285  1.15  perseant 	SET_FLUSHING(fs,vp);
    286  1.15  perseant 	if (fs->lfs_nactive > LFS_MAX_ACTIVE) {
    287  1.15  perseant 		error = lfs_segwrite(vp->v_mount, SEGM_SYNC|SEGM_CKP);
    288  1.15  perseant 		CLR_FLUSHING(fs,vp);
    289  1.15  perseant 		lfs_segunlock(fs);
    290  1.15  perseant 		return error;
    291  1.15  perseant 	}
    292   1.1   mycroft 	sp = fs->lfs_sp;
    293   1.1   mycroft 
    294  1.15  perseant 	if (vp->v_dirtyblkhd.lh_first == NULL) {
    295   1.1   mycroft 		lfs_writevnodes(fs, vp->v_mount, sp, VN_EMPTY);
    296  1.58  perseant 	} else if((ip->i_flag & IN_CLEANING) &&
    297  1.58  perseant 		  (fs->lfs_sp->seg_flags & SEGM_CLEAN)) {
    298  1.19  perseant #ifdef DEBUG_LFS
    299  1.19  perseant 		ivndebug(vp,"vflush/clean");
    300  1.19  perseant #endif
    301  1.19  perseant 		lfs_writevnodes(fs, vp->v_mount, sp, VN_CLEAN);
    302  1.15  perseant 	}
    303  1.15  perseant 	else if(lfs_dostats) {
    304  1.47  perseant 		if(vp->v_dirtyblkhd.lh_first || (VTOI(vp)->i_flag & IN_ALLMOD))
    305  1.15  perseant 			++lfs_stats.vflush_invoked;
    306  1.15  perseant #ifdef DEBUG_LFS
    307  1.19  perseant 		ivndebug(vp,"vflush");
    308  1.15  perseant #endif
    309  1.15  perseant 	}
    310  1.15  perseant 
    311  1.19  perseant #ifdef DIAGNOSTIC
    312  1.21  perseant 	/* XXX KS This actually can happen right now, though it shouldn't(?) */
    313  1.19  perseant 	if(vp->v_flag & VDIROP) {
    314  1.21  perseant 		printf("lfs_vflush: flushing VDIROP, this shouldn\'t be\n");
    315  1.21  perseant 		/* panic("VDIROP being flushed...this can\'t happen"); */
    316  1.19  perseant 	}
    317  1.19  perseant 	if(vp->v_usecount<0) {
    318  1.69  perseant 		printf("usecount=%ld\n", (long)vp->v_usecount);
    319  1.19  perseant 		panic("lfs_vflush: usecount<0");
    320  1.19  perseant 	}
    321  1.15  perseant #endif
    322   1.1   mycroft 
    323   1.1   mycroft 	do {
    324   1.1   mycroft 		do {
    325   1.1   mycroft 			if (vp->v_dirtyblkhd.lh_first != NULL)
    326   1.1   mycroft 				lfs_writefile(fs, sp, vp);
    327   1.1   mycroft 		} while (lfs_writeinode(fs, sp, ip));
    328   1.1   mycroft 	} while (lfs_writeseg(fs, sp) && ip->i_number == LFS_IFILE_INUM);
    329  1.15  perseant 
    330  1.15  perseant 	if(lfs_dostats) {
    331  1.15  perseant 		++lfs_stats.nwrites;
    332  1.15  perseant 		if (sp->seg_flags & SEGM_SYNC)
    333  1.15  perseant 			++lfs_stats.nsync_writes;
    334  1.15  perseant 		if (sp->seg_flags & SEGM_CKP)
    335  1.15  perseant 			++lfs_stats.ncheckpoints;
    336  1.15  perseant 	}
    337  1.15  perseant 	lfs_segunlock(fs);
    338   1.1   mycroft 
    339  1.15  perseant 	CLR_FLUSHING(fs,vp);
    340   1.1   mycroft 	return (0);
    341   1.1   mycroft }
    342   1.1   mycroft 
    343  1.16  perseant #ifdef DEBUG_LFS_VERBOSE
    344  1.16  perseant # define vndebug(vp,str) if(VTOI(vp)->i_flag & IN_CLEANING) printf("not writing ino %d because %s (op %d)\n",VTOI(vp)->i_number,(str),op)
    345  1.16  perseant #else
    346  1.16  perseant # define vndebug(vp,str)
    347  1.16  perseant #endif
    348  1.15  perseant 
    349  1.15  perseant int
    350  1.69  perseant lfs_writevnodes(struct lfs *fs, struct mount *mp, struct segment *sp, int op)
    351   1.1   mycroft {
    352   1.1   mycroft 	struct inode *ip;
    353   1.1   mycroft 	struct vnode *vp;
    354  1.20  perseant 	int inodes_written=0, only_cleaning;
    355  1.43  perseant 	int needs_unlock;
    356   1.1   mycroft 
    357  1.15  perseant #ifndef LFS_NO_BACKVP_HACK
    358  1.15  perseant 	/* BEGIN HACK */
    359  1.11    kleink #define	VN_OFFSET	(((caddr_t)&vp->v_mntvnodes.le_next) - (caddr_t)vp)
    360  1.11    kleink #define	BACK_VP(VP)	((struct vnode *)(((caddr_t)VP->v_mntvnodes.le_prev) - VN_OFFSET))
    361  1.11    kleink #define	BEG_OF_VLIST	((struct vnode *)(((caddr_t)&mp->mnt_vnodelist.lh_first) - VN_OFFSET))
    362  1.15  perseant 
    363  1.15  perseant 	/* Find last vnode. */
    364  1.15  perseant  loop:	for (vp = mp->mnt_vnodelist.lh_first;
    365  1.10      fvdl 	     vp && vp->v_mntvnodes.le_next != NULL;
    366  1.10      fvdl 	     vp = vp->v_mntvnodes.le_next);
    367  1.10      fvdl 	for (; vp && vp != BEG_OF_VLIST; vp = BACK_VP(vp)) {
    368  1.15  perseant #else
    369  1.15  perseant 	loop:
    370   1.1   mycroft 	for (vp = mp->mnt_vnodelist.lh_first;
    371   1.1   mycroft 	     vp != NULL;
    372   1.1   mycroft 	     vp = vp->v_mntvnodes.le_next) {
    373  1.15  perseant #endif
    374   1.1   mycroft 		/*
    375   1.1   mycroft 		 * If the vnode that we are about to sync is no longer
    376   1.1   mycroft 		 * associated with this mount point, start over.
    377   1.1   mycroft 		 */
    378  1.58  perseant 		if (vp->v_mount != mp) {
    379  1.58  perseant 			printf("lfs_writevnodes: starting over\n");
    380   1.1   mycroft 			goto loop;
    381  1.58  perseant 		}
    382   1.1   mycroft 
    383  1.15  perseant 		ip = VTOI(vp);
    384  1.15  perseant 		if ((op == VN_DIROP && !(vp->v_flag & VDIROP)) ||
    385  1.15  perseant 		    (op != VN_DIROP && op != VN_CLEAN && (vp->v_flag & VDIROP))) {
    386  1.15  perseant 			vndebug(vp,"dirop");
    387  1.15  perseant 			continue;
    388  1.15  perseant 		}
    389  1.15  perseant 
    390  1.15  perseant 		if (op == VN_EMPTY && vp->v_dirtyblkhd.lh_first) {
    391  1.15  perseant 			vndebug(vp,"empty");
    392   1.1   mycroft 			continue;
    393  1.15  perseant 		}
    394  1.15  perseant 
    395  1.15  perseant 		if (vp->v_type == VNON) {
    396  1.15  perseant 			continue;
    397  1.15  perseant 		}
    398   1.1   mycroft 
    399  1.15  perseant 		if(op == VN_CLEAN && ip->i_number != LFS_IFILE_INUM
    400  1.38  perseant 		   && vp != fs->lfs_flushvp
    401  1.15  perseant 		   && !(ip->i_flag & IN_CLEANING)) {
    402  1.15  perseant 			vndebug(vp,"cleaning");
    403   1.1   mycroft 			continue;
    404  1.15  perseant 		}
    405   1.1   mycroft 
    406  1.15  perseant 		if (lfs_vref(vp)) {
    407  1.15  perseant 			vndebug(vp,"vref");
    408   1.1   mycroft 			continue;
    409  1.15  perseant 		}
    410   1.1   mycroft 
    411  1.43  perseant 		needs_unlock = 0;
    412  1.52  perseant 		if (VOP_ISLOCKED(vp)) {
    413  1.43  perseant 			if (vp != fs->lfs_ivnode &&
    414  1.43  perseant 			    vp->v_lock.lk_lockholder != curproc->p_pid) {
    415  1.43  perseant #ifdef DEBUG_LFS
    416  1.58  perseant 				printf("lfs_writevnodes: not writing ino %d,"
    417  1.58  perseant 				       " locked by pid %d\n",
    418  1.58  perseant 				       VTOI(vp)->i_number,
    419  1.58  perseant 				       vp->v_lock.lk_lockholder);
    420  1.43  perseant #endif
    421  1.44  perseant 				lfs_vunref(vp);
    422  1.43  perseant 				continue;
    423  1.43  perseant 			}
    424  1.46  perseant 		} else if (vp != fs->lfs_ivnode) {
    425  1.43  perseant 			vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
    426  1.43  perseant 			needs_unlock = 1;
    427  1.43  perseant 		}
    428  1.43  perseant 
    429  1.23  perseant 		only_cleaning = 0;
    430   1.1   mycroft 		/*
    431  1.55  perseant 		 * Write the inode/file if dirty and it's not the IFILE.
    432   1.1   mycroft 		 */
    433  1.47  perseant 		if ((ip->i_flag & IN_ALLMOD) ||
    434  1.48     fredb 		     (vp->v_dirtyblkhd.lh_first != NULL))
    435  1.15  perseant 		{
    436  1.47  perseant 			only_cleaning = ((ip->i_flag & IN_ALLMOD)==IN_CLEANING);
    437  1.20  perseant 
    438  1.15  perseant 			if(ip->i_number != LFS_IFILE_INUM
    439  1.15  perseant 			   && vp->v_dirtyblkhd.lh_first != NULL)
    440  1.15  perseant 			{
    441   1.1   mycroft 				lfs_writefile(fs, sp, vp);
    442  1.15  perseant 			}
    443  1.15  perseant 			if(vp->v_dirtyblkhd.lh_first != NULL) {
    444  1.15  perseant 				if(WRITEINPROG(vp)) {
    445  1.15  perseant #ifdef DEBUG_LFS
    446  1.16  perseant 					ivndebug(vp,"writevnodes/write2");
    447  1.15  perseant #endif
    448  1.47  perseant 				} else if(!(ip->i_flag & IN_ALLMOD)) {
    449  1.15  perseant #ifdef DEBUG_LFS
    450  1.15  perseant 					printf("<%d>",ip->i_number);
    451  1.15  perseant #endif
    452  1.56  perseant 					LFS_SET_UINO(ip, IN_MODIFIED);
    453  1.15  perseant 				}
    454  1.15  perseant 			}
    455   1.1   mycroft 			(void) lfs_writeinode(fs, sp, ip);
    456  1.15  perseant 			inodes_written++;
    457  1.15  perseant 		}
    458  1.15  perseant 
    459  1.52  perseant 		if (needs_unlock)
    460  1.52  perseant 			VOP_UNLOCK(vp, 0);
    461  1.43  perseant 
    462  1.52  perseant 		if (lfs_clean_vnhead && only_cleaning)
    463  1.20  perseant 			lfs_vunref_head(vp);
    464  1.20  perseant 		else
    465  1.20  perseant 			lfs_vunref(vp);
    466   1.1   mycroft 	}
    467  1.15  perseant 	return inodes_written;
    468   1.1   mycroft }
    469   1.1   mycroft 
    470  1.69  perseant /*
    471  1.69  perseant  * Do a checkpoint.
    472  1.69  perseant  */
    473   1.1   mycroft int
    474  1.69  perseant lfs_segwrite(struct mount *mp, int flags)
    475   1.1   mycroft {
    476   1.1   mycroft 	struct buf *bp;
    477   1.1   mycroft 	struct inode *ip;
    478   1.1   mycroft 	struct lfs *fs;
    479   1.1   mycroft 	struct segment *sp;
    480   1.1   mycroft 	struct vnode *vp;
    481   1.1   mycroft 	SEGUSE *segusep;
    482  1.10      fvdl 	ufs_daddr_t ibno;
    483  1.61  perseant 	int do_ckp, did_ckp, error, i;
    484  1.15  perseant 	int writer_set = 0;
    485  1.61  perseant 	int dirty;
    486  1.15  perseant 
    487   1.1   mycroft 	fs = VFSTOUFS(mp)->um_lfs;
    488   1.1   mycroft 
    489  1.53  perseant 	if (fs->lfs_ronly)
    490  1.53  perseant 		return EROFS;
    491  1.53  perseant 
    492  1.15  perseant 	lfs_imtime(fs);
    493  1.58  perseant 
    494  1.61  perseant 	/* printf("lfs_segwrite: ifile flags are 0x%lx\n",
    495  1.61  perseant 	       (long)(VTOI(fs->lfs_ivnode)->i_flag)); */
    496  1.61  perseant 
    497  1.58  perseant #if 0
    498  1.15  perseant 	/*
    499  1.58  perseant 	 * If we are not the cleaner, and there is no space available,
    500  1.58  perseant 	 * wait until cleaner writes.
    501  1.15  perseant 	 */
    502  1.61  perseant 	if(!(flags & SEGM_CLEAN) && !(fs->lfs_seglock && fs->lfs_sp &&
    503  1.61  perseant 				      (fs->lfs_sp->seg_flags & SEGM_CLEAN)))
    504  1.15  perseant 	{
    505  1.58  perseant 		while (fs->lfs_avail <= 0) {
    506  1.61  perseant 			LFS_CLEANERINFO(cip, fs, bp);
    507  1.61  perseant 			LFS_SYNC_CLEANERINFO(cip, fs, bp, 0);
    508  1.61  perseant 
    509  1.58  perseant 			wakeup(&lfs_allclean_wakeup);
    510  1.58  perseant 			wakeup(&fs->lfs_nextseg);
    511  1.58  perseant 			error = tsleep(&fs->lfs_avail, PRIBIO + 1, "lfs_av2",
    512  1.58  perseant 				       0);
    513  1.58  perseant 			if (error) {
    514  1.58  perseant 				return (error);
    515  1.15  perseant 			}
    516  1.58  perseant 		}
    517  1.15  perseant 	}
    518  1.58  perseant #endif
    519   1.1   mycroft 	/*
    520   1.1   mycroft 	 * Allocate a segment structure and enough space to hold pointers to
    521   1.1   mycroft 	 * the maximum possible number of buffers which can be described in a
    522   1.1   mycroft 	 * single summary block.
    523   1.1   mycroft 	 */
    524  1.15  perseant 	do_ckp = (flags & SEGM_CKP) || fs->lfs_nactive > LFS_MAX_ACTIVE;
    525   1.1   mycroft 	lfs_seglock(fs, flags | (do_ckp ? SEGM_CKP : 0));
    526   1.1   mycroft 	sp = fs->lfs_sp;
    527   1.1   mycroft 
    528  1.15  perseant 	/*
    529  1.16  perseant 	 * If lfs_flushvp is non-NULL, we are called from lfs_vflush,
    530  1.16  perseant 	 * in which case we have to flush *all* buffers off of this vnode.
    531  1.37  perseant 	 * We don't care about other nodes, but write any non-dirop nodes
    532  1.37  perseant 	 * anyway in anticipation of another getnewvnode().
    533  1.37  perseant 	 *
    534  1.37  perseant 	 * If we're cleaning we only write cleaning and ifile blocks, and
    535  1.37  perseant 	 * no dirops, since otherwise we'd risk corruption in a crash.
    536  1.15  perseant 	 */
    537  1.38  perseant 	if(sp->seg_flags & SEGM_CLEAN)
    538  1.15  perseant 		lfs_writevnodes(fs, mp, sp, VN_CLEAN);
    539  1.15  perseant 	else {
    540  1.15  perseant 		lfs_writevnodes(fs, mp, sp, VN_REG);
    541  1.38  perseant 		if(!fs->lfs_dirops || !fs->lfs_flushvp) {
    542  1.38  perseant 			while(fs->lfs_dirops)
    543  1.38  perseant 				if((error = tsleep(&fs->lfs_writer, PRIBIO + 1,
    544  1.38  perseant 						"lfs writer", 0)))
    545  1.38  perseant 				{
    546  1.69  perseant 					/* XXX why not segunlock? */
    547  1.38  perseant 					free(sp->bpp, M_SEGMENT);
    548  1.69  perseant 					sp->bpp = NULL;
    549  1.38  perseant 					free(sp, M_SEGMENT);
    550  1.69  perseant 					fs->lfs_sp = NULL;
    551  1.38  perseant 					return (error);
    552  1.38  perseant 				}
    553  1.38  perseant 			fs->lfs_writer++;
    554  1.38  perseant 			writer_set=1;
    555  1.38  perseant 			lfs_writevnodes(fs, mp, sp, VN_DIROP);
    556  1.38  perseant 			((SEGSUM *)(sp->segsum))->ss_flags &= ~(SS_CONT);
    557  1.38  perseant 		}
    558  1.15  perseant 	}
    559   1.1   mycroft 
    560   1.1   mycroft 	/*
    561   1.1   mycroft 	 * If we are doing a checkpoint, mark everything since the
    562   1.1   mycroft 	 * last checkpoint as no longer ACTIVE.
    563   1.1   mycroft 	 */
    564  1.15  perseant 	if (do_ckp) {
    565   1.1   mycroft 		for (ibno = fs->lfs_cleansz + fs->lfs_segtabsz;
    566   1.1   mycroft 		     --ibno >= fs->lfs_cleansz; ) {
    567  1.61  perseant 			dirty = 0;
    568  1.15  perseant 			if (bread(fs->lfs_ivnode, ibno, fs->lfs_bsize, NOCRED, &bp))
    569   1.1   mycroft 
    570  1.15  perseant 				panic("lfs_segwrite: ifile read");
    571   1.1   mycroft 			segusep = (SEGUSE *)bp->b_data;
    572  1.69  perseant 			for (i = fs->lfs_sepb; i--;) {
    573  1.61  perseant 				if (segusep->su_flags & SEGUSE_ACTIVE) {
    574  1.61  perseant 					segusep->su_flags &= ~SEGUSE_ACTIVE;
    575  1.61  perseant 					++dirty;
    576  1.61  perseant 				}
    577  1.69  perseant 				if (fs->lfs_version > 1)
    578  1.69  perseant 					++segusep;
    579  1.69  perseant 				else
    580  1.69  perseant 					segusep = (SEGUSE *)
    581  1.69  perseant 						((SEGUSE_V1 *)segusep + 1);
    582  1.61  perseant 			}
    583   1.1   mycroft 
    584  1.15  perseant 			/* But the current segment is still ACTIVE */
    585  1.51  perseant 			segusep = (SEGUSE *)bp->b_data;
    586  1.69  perseant 			if (dtosn(fs, fs->lfs_curseg) / fs->lfs_sepb ==
    587  1.61  perseant 			    (ibno-fs->lfs_cleansz)) {
    588  1.69  perseant 				if (fs->lfs_version > 1)
    589  1.69  perseant 					segusep[dtosn(fs, fs->lfs_curseg) %
    590  1.69  perseant 					     fs->lfs_sepb].su_flags |=
    591  1.69  perseant 						     SEGUSE_ACTIVE;
    592  1.69  perseant 				else
    593  1.69  perseant 					((SEGUSE *)
    594  1.69  perseant 					 ((SEGUSE_V1 *)(bp->b_data) +
    595  1.69  perseant 					  (dtosn(fs, fs->lfs_curseg) %
    596  1.69  perseant 					   fs->lfs_sepb)))->su_flags
    597  1.69  perseant 						   |= SEGUSE_ACTIVE;
    598  1.61  perseant 				--dirty;
    599  1.61  perseant 			}
    600  1.61  perseant 			if (dirty)
    601  1.61  perseant 				error = VOP_BWRITE(bp); /* Ifile */
    602  1.61  perseant 			else
    603  1.61  perseant 				brelse(bp);
    604   1.1   mycroft 		}
    605  1.15  perseant 	}
    606  1.61  perseant 
    607  1.61  perseant 	did_ckp = 0;
    608   1.1   mycroft 	if (do_ckp || fs->lfs_doifile) {
    609  1.63  perseant 		do {
    610  1.63  perseant 			vp = fs->lfs_ivnode;
    611  1.55  perseant 
    612  1.63  perseant 			vget(vp, LK_EXCLUSIVE | LK_CANRECURSE | LK_RETRY);
    613  1.55  perseant 
    614  1.63  perseant 			ip = VTOI(vp);
    615  1.63  perseant 			if (vp->v_dirtyblkhd.lh_first != NULL)
    616  1.63  perseant 				lfs_writefile(fs, sp, vp);
    617  1.63  perseant 			if (ip->i_flag & IN_ALLMOD)
    618  1.63  perseant 				++did_ckp;
    619  1.63  perseant 			(void) lfs_writeinode(fs, sp, ip);
    620  1.63  perseant 
    621  1.63  perseant 			vput(vp);
    622  1.63  perseant 		} while (lfs_writeseg(fs, sp) && do_ckp);
    623  1.15  perseant 
    624  1.61  perseant 		/* The ifile should now be all clear */
    625  1.61  perseant 		LFS_CLR_UINO(ip, IN_ALLMOD);
    626  1.15  perseant 	} else {
    627   1.1   mycroft 		(void) lfs_writeseg(fs, sp);
    628  1.15  perseant 	}
    629  1.15  perseant 
    630   1.1   mycroft 	/*
    631  1.15  perseant 	 * If the I/O count is non-zero, sleep until it reaches zero.
    632  1.15  perseant 	 * At the moment, the user's process hangs around so we can
    633  1.15  perseant 	 * sleep.
    634   1.1   mycroft 	 */
    635   1.1   mycroft 	fs->lfs_doifile = 0;
    636  1.15  perseant 	if(writer_set && --fs->lfs_writer==0)
    637  1.15  perseant 		wakeup(&fs->lfs_dirops);
    638  1.61  perseant 
    639  1.61  perseant 	/*
    640  1.61  perseant 	 * If we didn't write the Ifile, we didn't really do anything.
    641  1.61  perseant 	 * That means that (1) there is a checkpoint on disk and (2)
    642  1.61  perseant 	 * nothing has changed since it was written.
    643  1.61  perseant 	 *
    644  1.61  perseant 	 * Take the flags off of the segment so that lfs_segunlock
    645  1.61  perseant 	 * doesn't have to write the superblock either.
    646  1.61  perseant 	 */
    647  1.61  perseant 	if (did_ckp == 0) {
    648  1.61  perseant 		sp->seg_flags &= ~(SEGM_SYNC|SEGM_CKP);
    649  1.61  perseant 		/* if(do_ckp) printf("lfs_segwrite: no checkpoint\n"); */
    650  1.61  perseant 	}
    651  1.61  perseant 
    652  1.15  perseant 	if(lfs_dostats) {
    653  1.15  perseant 		++lfs_stats.nwrites;
    654  1.15  perseant 		if (sp->seg_flags & SEGM_SYNC)
    655  1.15  perseant 			++lfs_stats.nsync_writes;
    656  1.15  perseant 		if (sp->seg_flags & SEGM_CKP)
    657  1.15  perseant 			++lfs_stats.ncheckpoints;
    658  1.15  perseant 	}
    659   1.1   mycroft 	lfs_segunlock(fs);
    660   1.1   mycroft 	return (0);
    661   1.1   mycroft }
    662   1.1   mycroft 
    663   1.1   mycroft /*
    664   1.1   mycroft  * Write the dirty blocks associated with a vnode.
    665   1.1   mycroft  */
    666   1.1   mycroft void
    667  1.69  perseant lfs_writefile(struct lfs *fs, struct segment *sp, struct vnode *vp)
    668   1.1   mycroft {
    669   1.1   mycroft 	struct buf *bp;
    670   1.1   mycroft 	struct finfo *fip;
    671   1.1   mycroft 	IFILE *ifp;
    672  1.15  perseant 
    673  1.15  perseant 
    674   1.1   mycroft 	if (sp->seg_bytes_left < fs->lfs_bsize ||
    675   1.1   mycroft 	    sp->sum_bytes_left < sizeof(struct finfo))
    676   1.1   mycroft 		(void) lfs_writeseg(fs, sp);
    677  1.15  perseant 
    678  1.10      fvdl 	sp->sum_bytes_left -= sizeof(struct finfo) - sizeof(ufs_daddr_t);
    679   1.1   mycroft 	++((SEGSUM *)(sp->segsum))->ss_nfinfo;
    680   1.1   mycroft 
    681  1.15  perseant 	if(vp->v_flag & VDIROP)
    682  1.15  perseant 		((SEGSUM *)(sp->segsum))->ss_flags |= (SS_DIROP|SS_CONT);
    683  1.15  perseant 
    684   1.1   mycroft 	fip = sp->fip;
    685   1.1   mycroft 	fip->fi_nblocks = 0;
    686   1.1   mycroft 	fip->fi_ino = VTOI(vp)->i_number;
    687   1.1   mycroft 	LFS_IENTRY(ifp, fs, fip->fi_ino, bp);
    688   1.1   mycroft 	fip->fi_version = ifp->if_version;
    689   1.1   mycroft 	brelse(bp);
    690  1.15  perseant 
    691  1.38  perseant 	if(sp->seg_flags & SEGM_CLEAN)
    692  1.38  perseant 	{
    693  1.38  perseant 		lfs_gather(fs, sp, vp, lfs_match_fake);
    694  1.38  perseant 		/*
    695  1.38  perseant 		 * For a file being flushed, we need to write *all* blocks.
    696  1.38  perseant 		 * This means writing the cleaning blocks first, and then
    697  1.38  perseant 		 * immediately following with any non-cleaning blocks.
    698  1.38  perseant 		 * The same is true of the Ifile since checkpoints assume
    699  1.38  perseant 		 * that all valid Ifile blocks are written.
    700  1.38  perseant 		 */
    701  1.38  perseant 	   	if(IS_FLUSHING(fs,vp) || VTOI(vp)->i_number == LFS_IFILE_INUM)
    702  1.38  perseant 			lfs_gather(fs, sp, vp, lfs_match_data);
    703  1.38  perseant 	} else
    704  1.38  perseant 		lfs_gather(fs, sp, vp, lfs_match_data);
    705  1.38  perseant 
    706   1.1   mycroft 	/*
    707   1.1   mycroft 	 * It may not be necessary to write the meta-data blocks at this point,
    708   1.1   mycroft 	 * as the roll-forward recovery code should be able to reconstruct the
    709   1.1   mycroft 	 * list.
    710  1.15  perseant 	 *
    711  1.15  perseant 	 * We have to write them anyway, though, under two conditions: (1) the
    712  1.15  perseant 	 * vnode is being flushed (for reuse by vinvalbuf); or (2) we are
    713  1.15  perseant 	 * checkpointing.
    714   1.1   mycroft 	 */
    715  1.15  perseant 	if(lfs_writeindir
    716  1.15  perseant 	   || IS_FLUSHING(fs,vp)
    717  1.15  perseant 	   || (sp->seg_flags & SEGM_CKP))
    718  1.15  perseant 	{
    719  1.15  perseant 		lfs_gather(fs, sp, vp, lfs_match_indir);
    720  1.15  perseant 		lfs_gather(fs, sp, vp, lfs_match_dindir);
    721  1.15  perseant 		lfs_gather(fs, sp, vp, lfs_match_tindir);
    722  1.15  perseant 	}
    723   1.1   mycroft 	fip = sp->fip;
    724   1.1   mycroft 	if (fip->fi_nblocks != 0) {
    725  1.15  perseant 		sp->fip = (FINFO*)((caddr_t)fip + sizeof(struct finfo) +
    726  1.15  perseant 				   sizeof(ufs_daddr_t) * (fip->fi_nblocks-1));
    727   1.1   mycroft 		sp->start_lbp = &sp->fip->fi_blocks[0];
    728   1.1   mycroft 	} else {
    729  1.15  perseant 		sp->sum_bytes_left += sizeof(FINFO) - sizeof(ufs_daddr_t);
    730   1.1   mycroft 		--((SEGSUM *)(sp->segsum))->ss_nfinfo;
    731   1.1   mycroft 	}
    732   1.1   mycroft }
    733   1.1   mycroft 
    734   1.1   mycroft int
    735  1.69  perseant lfs_writeinode(struct lfs *fs, struct segment *sp, struct inode *ip)
    736   1.1   mycroft {
    737   1.1   mycroft 	struct buf *bp, *ibp;
    738  1.53  perseant 	struct dinode *cdp;
    739   1.1   mycroft 	IFILE *ifp;
    740   1.1   mycroft 	SEGUSE *sup;
    741  1.10      fvdl 	ufs_daddr_t daddr;
    742  1.53  perseant 	daddr_t *daddrp;
    743   1.1   mycroft 	ino_t ino;
    744  1.69  perseant 	int error, i, ndx, fsb = 0;
    745   1.1   mycroft 	int redo_ifile = 0;
    746   1.5   mycroft 	struct timespec ts;
    747  1.69  perseant 	int gotblk = 0;
    748  1.15  perseant 
    749  1.47  perseant 	if (!(ip->i_flag & IN_ALLMOD))
    750   1.1   mycroft 		return(0);
    751  1.15  perseant 
    752   1.1   mycroft 	/* Allocate a new inode block if necessary. */
    753  1.27  perseant 	if ((ip->i_number != LFS_IFILE_INUM || sp->idp==NULL) && sp->ibp == NULL) {
    754   1.1   mycroft 		/* Allocate a new segment if necessary. */
    755  1.69  perseant 		if (sp->seg_bytes_left < fs->lfs_ibsize ||
    756  1.10      fvdl 		    sp->sum_bytes_left < sizeof(ufs_daddr_t))
    757   1.1   mycroft 			(void) lfs_writeseg(fs, sp);
    758   1.1   mycroft 
    759   1.1   mycroft 		/* Get next inode block. */
    760   1.1   mycroft 		daddr = fs->lfs_offset;
    761  1.69  perseant 		fs->lfs_offset += btofsb(fs, fs->lfs_ibsize);
    762   1.1   mycroft 		sp->ibp = *sp->cbpp++ =
    763  1.69  perseant 			getblk(VTOI(fs->lfs_ivnode)->i_devvp, fsbtodb(fs, daddr),
    764  1.69  perseant 			       fs->lfs_ibsize, 0, 0);
    765  1.24  perseant 		gotblk++;
    766  1.24  perseant 
    767   1.1   mycroft 		/* Zero out inode numbers */
    768   1.1   mycroft 		for (i = 0; i < INOPB(fs); ++i)
    769   1.1   mycroft 			((struct dinode *)sp->ibp->b_data)[i].di_inumber = 0;
    770  1.15  perseant 
    771   1.1   mycroft 		++sp->start_bpp;
    772  1.69  perseant 		fs->lfs_avail -= btofsb(fs, fs->lfs_ibsize);
    773   1.1   mycroft 		/* Set remaining space counters. */
    774  1.69  perseant 		sp->seg_bytes_left -= fs->lfs_ibsize;
    775  1.10      fvdl 		sp->sum_bytes_left -= sizeof(ufs_daddr_t);
    776  1.69  perseant 		ndx = fs->lfs_sumsize / sizeof(ufs_daddr_t) -
    777  1.15  perseant 			sp->ninodes / INOPB(fs) - 1;
    778  1.10      fvdl 		((ufs_daddr_t *)(sp->segsum))[ndx] = daddr;
    779   1.1   mycroft 	}
    780  1.27  perseant 
    781   1.1   mycroft 	/* Update the inode times and copy the inode onto the inode page. */
    782   1.9        pk 	TIMEVAL_TO_TIMESPEC(&time, &ts);
    783  1.15  perseant 	LFS_ITIMES(ip, &ts, &ts, &ts);
    784  1.16  perseant 
    785  1.27  perseant 	/*
    786  1.27  perseant 	 * If this is the Ifile, and we've already written the Ifile in this
    787  1.27  perseant 	 * partial segment, just overwrite it (it's not on disk yet) and
    788  1.27  perseant 	 * continue.
    789  1.27  perseant 	 *
    790  1.27  perseant 	 * XXX we know that the bp that we get the second time around has
    791  1.27  perseant 	 * already been gathered.
    792  1.27  perseant 	 */
    793  1.27  perseant 	if(ip->i_number == LFS_IFILE_INUM && sp->idp) {
    794  1.27  perseant 		*(sp->idp) = ip->i_din.ffs_din;
    795  1.27  perseant 		return 0;
    796  1.27  perseant 	}
    797  1.27  perseant 
    798   1.1   mycroft 	bp = sp->ibp;
    799  1.53  perseant 	cdp = ((struct dinode *)bp->b_data) + (sp->ninodes % INOPB(fs));
    800  1.53  perseant 	*cdp = ip->i_din.ffs_din;
    801  1.69  perseant #ifdef LFS_IFILE_FRAG_ADDRESSING
    802  1.69  perseant 	if (fs->lfs_version > 1)
    803  1.69  perseant 		fsb = (sp->ninodes % INOPB(fs)) / INOPF(fs);
    804  1.69  perseant #endif
    805  1.53  perseant 
    806  1.53  perseant 	/*
    807  1.53  perseant 	 * If we are cleaning, ensure that we don't write UNWRITTEN disk
    808  1.53  perseant 	 * addresses to disk.
    809  1.53  perseant 	 */
    810  1.53  perseant 	if (ip->i_lfs_effnblks != ip->i_ffs_blocks) {
    811  1.55  perseant #ifdef DEBUG_LFS
    812  1.53  perseant 		printf("lfs_writeinode: cleansing ino %d (%d != %d)\n",
    813  1.53  perseant 		       ip->i_number, ip->i_lfs_effnblks, ip->i_ffs_blocks);
    814  1.55  perseant #endif
    815  1.53  perseant 		for (daddrp = cdp->di_db; daddrp < cdp->di_ib + NIADDR;
    816  1.53  perseant 		     daddrp++) {
    817  1.53  perseant 			if (*daddrp == UNWRITTEN) {
    818  1.54  perseant #ifdef DEBUG_LFS
    819  1.53  perseant 				printf("lfs_writeinode: wiping UNWRITTEN\n");
    820  1.53  perseant #endif
    821  1.53  perseant 				*daddrp = 0;
    822  1.53  perseant 			}
    823  1.53  perseant 		}
    824  1.53  perseant 	}
    825  1.27  perseant 
    826  1.55  perseant 	if(ip->i_flag & IN_CLEANING)
    827  1.56  perseant 		LFS_CLR_UINO(ip, IN_CLEANING);
    828  1.55  perseant 	else {
    829  1.56  perseant 		/* XXX IN_ALLMOD */
    830  1.56  perseant 		LFS_CLR_UINO(ip, IN_ACCESSED | IN_ACCESS | IN_CHANGE |
    831  1.56  perseant 			     IN_UPDATE);
    832  1.56  perseant 		if (ip->i_lfs_effnblks == ip->i_ffs_blocks)
    833  1.56  perseant 			LFS_CLR_UINO(ip, IN_MODIFIED);
    834  1.63  perseant #ifdef DEBUG_LFS
    835  1.63  perseant 		else
    836  1.63  perseant 			printf("lfs_writeinode: ino %d: real blks=%d, "
    837  1.63  perseant 			       "eff=%d\n", ip->i_number, ip->i_ffs_blocks,
    838  1.63  perseant 			       ip->i_lfs_effnblks);
    839  1.63  perseant #endif
    840  1.55  perseant 	}
    841  1.55  perseant 
    842  1.27  perseant 	if(ip->i_number == LFS_IFILE_INUM) /* We know sp->idp == NULL */
    843  1.53  perseant 		sp->idp = ((struct dinode *)bp->b_data) +
    844  1.53  perseant 			(sp->ninodes % INOPB(fs));
    845  1.24  perseant 	if(gotblk) {
    846  1.62  perseant 		LFS_LOCK_BUF(bp);
    847  1.24  perseant 		brelse(bp);
    848  1.24  perseant 	}
    849  1.15  perseant 
    850   1.1   mycroft 	/* Increment inode count in segment summary block. */
    851   1.1   mycroft 	++((SEGSUM *)(sp->segsum))->ss_ninos;
    852  1.15  perseant 
    853   1.1   mycroft 	/* If this page is full, set flag to allocate a new page. */
    854   1.1   mycroft 	if (++sp->ninodes % INOPB(fs) == 0)
    855   1.1   mycroft 		sp->ibp = NULL;
    856  1.15  perseant 
    857   1.1   mycroft 	/*
    858   1.1   mycroft 	 * If updating the ifile, update the super-block.  Update the disk
    859   1.1   mycroft 	 * address and access times for this inode in the ifile.
    860   1.1   mycroft 	 */
    861   1.1   mycroft 	ino = ip->i_number;
    862   1.1   mycroft 	if (ino == LFS_IFILE_INUM) {
    863   1.1   mycroft 		daddr = fs->lfs_idaddr;
    864  1.69  perseant 		fs->lfs_idaddr = dbtofsb(fs, bp->b_blkno);
    865   1.1   mycroft 	} else {
    866   1.1   mycroft 		LFS_IENTRY(ifp, fs, ino, ibp);
    867   1.1   mycroft 		daddr = ifp->if_daddr;
    868  1.69  perseant 		ifp->if_daddr = dbtofsb(fs, bp->b_blkno) + fsb;
    869  1.30  perseant #ifdef LFS_DEBUG_NEXTFREE
    870  1.30  perseant 		if(ino > 3 && ifp->if_nextfree) {
    871  1.30  perseant 			vprint("lfs_writeinode",ITOV(ip));
    872  1.30  perseant 			printf("lfs_writeinode: updating free ino %d\n",
    873  1.30  perseant 				ip->i_number);
    874  1.30  perseant 		}
    875  1.30  perseant #endif
    876  1.58  perseant 		error = VOP_BWRITE(ibp); /* Ifile */
    877   1.1   mycroft 	}
    878  1.15  perseant 
    879   1.1   mycroft 	/*
    880  1.60    toshii 	 * Account the inode: it no longer belongs to its former segment,
    881  1.60    toshii 	 * though it will not belong to the new segment until that segment
    882  1.60    toshii 	 * is actually written.
    883   1.1   mycroft 	 */
    884  1.58  perseant #ifdef DEBUG
    885  1.60    toshii 	/*
    886  1.60    toshii 	 * The inode's last address should not be in the current partial
    887  1.60    toshii 	 * segment, except under exceptional circumstances (lfs_writevnodes
    888  1.60    toshii 	 * had to start over, and in the meantime more blocks were written
    889  1.60    toshii 	 * to a vnode).  Although the previous inode won't be accounted in
    890  1.60    toshii 	 * su_nbytes until lfs_writeseg, this shouldn't be a problem as we
    891  1.60    toshii 	 * have more data blocks in the current partial segment.
    892  1.60    toshii 	 */
    893  1.69  perseant 	if (daddr >= fs->lfs_lastpseg && daddr <= dbtofsb(fs, bp->b_blkno))
    894  1.49  perseant 		printf("lfs_writeinode: last inode addr in current pseg "
    895  1.53  perseant 		       "(ino %d daddr 0x%x)\n", ino, daddr);
    896  1.58  perseant #endif
    897  1.49  perseant 	if (daddr != LFS_UNUSED_DADDR) {
    898  1.69  perseant 		LFS_SEGENTRY(sup, fs, dtosn(fs, daddr), bp);
    899   1.1   mycroft #ifdef DIAGNOSTIC
    900  1.13   thorpej 		if (sup->su_nbytes < DINODE_SIZE) {
    901  1.53  perseant 			printf("lfs_writeinode: negative bytes "
    902  1.53  perseant 			       "(segment %d short by %d)\n",
    903  1.69  perseant 			       dtosn(fs, daddr),
    904  1.53  perseant 			       (int)DINODE_SIZE - sup->su_nbytes);
    905  1.27  perseant 			panic("lfs_writeinode: negative bytes");
    906  1.27  perseant 			sup->su_nbytes = DINODE_SIZE;
    907   1.1   mycroft 		}
    908   1.1   mycroft #endif
    909  1.69  perseant #ifdef DEBUG_SU_NBYTES
    910  1.69  perseant 		printf("seg %d -= %d for ino %d inode\n",
    911  1.69  perseant 		       dtosn(fs, daddr), DINODE_SIZE, ino);
    912  1.69  perseant #endif
    913  1.13   thorpej 		sup->su_nbytes -= DINODE_SIZE;
    914   1.1   mycroft 		redo_ifile =
    915  1.15  perseant 			(ino == LFS_IFILE_INUM && !(bp->b_flags & B_GATHERED));
    916  1.58  perseant 		error = VOP_BWRITE(bp); /* Ifile */
    917   1.1   mycroft 	}
    918   1.1   mycroft 	return (redo_ifile);
    919   1.1   mycroft }
    920   1.1   mycroft 
    921   1.1   mycroft int
    922  1.69  perseant lfs_gatherblock(struct segment *sp, struct buf *bp, int *sptr)
    923   1.1   mycroft {
    924   1.1   mycroft 	struct lfs *fs;
    925   1.1   mycroft 	int version;
    926  1.15  perseant 
    927   1.1   mycroft 	/*
    928   1.1   mycroft 	 * If full, finish this segment.  We may be doing I/O, so
    929   1.1   mycroft 	 * release and reacquire the splbio().
    930   1.1   mycroft 	 */
    931   1.1   mycroft #ifdef DIAGNOSTIC
    932   1.1   mycroft 	if (sp->vp == NULL)
    933   1.1   mycroft 		panic ("lfs_gatherblock: Null vp in segment");
    934   1.1   mycroft #endif
    935   1.1   mycroft 	fs = sp->fs;
    936  1.10      fvdl 	if (sp->sum_bytes_left < sizeof(ufs_daddr_t) ||
    937  1.10      fvdl 	    sp->seg_bytes_left < bp->b_bcount) {
    938   1.1   mycroft 		if (sptr)
    939   1.1   mycroft 			splx(*sptr);
    940   1.1   mycroft 		lfs_updatemeta(sp);
    941  1.15  perseant 
    942   1.1   mycroft 		version = sp->fip->fi_version;
    943   1.1   mycroft 		(void) lfs_writeseg(fs, sp);
    944  1.15  perseant 
    945   1.1   mycroft 		sp->fip->fi_version = version;
    946   1.1   mycroft 		sp->fip->fi_ino = VTOI(sp->vp)->i_number;
    947   1.1   mycroft 		/* Add the current file to the segment summary. */
    948   1.1   mycroft 		++((SEGSUM *)(sp->segsum))->ss_nfinfo;
    949   1.1   mycroft 		sp->sum_bytes_left -=
    950  1.15  perseant 			sizeof(struct finfo) - sizeof(ufs_daddr_t);
    951  1.15  perseant 
    952   1.1   mycroft 		if (sptr)
    953   1.1   mycroft 			*sptr = splbio();
    954   1.1   mycroft 		return(1);
    955   1.1   mycroft 	}
    956  1.15  perseant 
    957  1.15  perseant #ifdef DEBUG
    958  1.15  perseant 	if(bp->b_flags & B_GATHERED) {
    959  1.15  perseant 		printf("lfs_gatherblock: already gathered! Ino %d, lbn %d\n",
    960  1.15  perseant 		       sp->fip->fi_ino, bp->b_lblkno);
    961  1.15  perseant 		return(0);
    962  1.15  perseant 	}
    963  1.15  perseant #endif
    964   1.1   mycroft 	/* Insert into the buffer list, update the FINFO block. */
    965   1.1   mycroft 	bp->b_flags |= B_GATHERED;
    966   1.1   mycroft 	*sp->cbpp++ = bp;
    967   1.1   mycroft 	sp->fip->fi_blocks[sp->fip->fi_nblocks++] = bp->b_lblkno;
    968  1.15  perseant 
    969  1.10      fvdl 	sp->sum_bytes_left -= sizeof(ufs_daddr_t);
    970  1.10      fvdl 	sp->seg_bytes_left -= bp->b_bcount;
    971   1.1   mycroft 	return(0);
    972   1.1   mycroft }
    973   1.1   mycroft 
    974  1.15  perseant int
    975  1.69  perseant lfs_gather(struct lfs *fs, struct segment *sp, struct vnode *vp, int (*match)(struct lfs *, struct buf *))
    976   1.1   mycroft {
    977   1.1   mycroft 	struct buf *bp;
    978  1.15  perseant 	int s, count=0;
    979  1.15  perseant 
    980   1.1   mycroft 	sp->vp = vp;
    981   1.1   mycroft 	s = splbio();
    982  1.15  perseant 
    983  1.15  perseant #ifndef LFS_NO_BACKBUF_HACK
    984  1.15  perseant loop:	for (bp = vp->v_dirtyblkhd.lh_first; bp; bp = bp->b_vnbufs.le_next) {
    985  1.15  perseant #else /* LFS_NO_BACKBUF_HACK */
    986  1.10      fvdl /* This is a hack to see if ordering the blocks in LFS makes a difference. */
    987  1.15  perseant # define	BUF_OFFSET	(((void *)&bp->b_vnbufs.le_next) - (void *)bp)
    988  1.15  perseant # define	BACK_BUF(BP)	((struct buf *)(((void *)BP->b_vnbufs.le_prev) - BUF_OFFSET))
    989  1.15  perseant # define	BEG_OF_LIST	((struct buf *)(((void *)&vp->v_dirtyblkhd.lh_first) - BUF_OFFSET))
    990  1.10      fvdl /* Find last buffer. */
    991  1.15  perseant loop:	for (bp = vp->v_dirtyblkhd.lh_first; bp && bp->b_vnbufs.le_next != NULL;
    992  1.10      fvdl 	    bp = bp->b_vnbufs.le_next);
    993  1.10      fvdl 	for (; bp && bp != BEG_OF_LIST; bp = BACK_BUF(bp)) {
    994  1.15  perseant #endif /* LFS_NO_BACKBUF_HACK */
    995  1.15  perseant 		if ((bp->b_flags & (B_BUSY|B_GATHERED)) || !match(fs, bp))
    996   1.1   mycroft 			continue;
    997  1.30  perseant 		if(vp->v_type == VBLK) {
    998  1.30  perseant 			/* For block devices, just write the blocks. */
    999  1.30  perseant 			/* XXX Do we really need to even do this? */
   1000  1.30  perseant #ifdef DEBUG_LFS
   1001  1.30  perseant 			if(count==0)
   1002  1.30  perseant 				printf("BLK(");
   1003  1.30  perseant 			printf(".");
   1004  1.30  perseant #endif
   1005  1.30  perseant 			/* Get the block before bwrite, so we don't corrupt the free list */
   1006  1.30  perseant 			bp->b_flags |= B_BUSY;
   1007  1.30  perseant 			bremfree(bp);
   1008  1.30  perseant 			bwrite(bp);
   1009  1.30  perseant 		} else {
   1010   1.1   mycroft #ifdef DIAGNOSTIC
   1011  1.43  perseant 			if ((bp->b_flags & (B_CALL|B_INVAL))==B_INVAL) {
   1012  1.43  perseant 				printf("lfs_gather: lbn %d is B_INVAL\n",
   1013  1.43  perseant 					bp->b_lblkno);
   1014  1.43  perseant 				VOP_PRINT(bp->b_vp);
   1015  1.43  perseant 			}
   1016  1.30  perseant 			if (!(bp->b_flags & B_DELWRI))
   1017  1.30  perseant 				panic("lfs_gather: bp not B_DELWRI");
   1018  1.30  perseant 			if (!(bp->b_flags & B_LOCKED)) {
   1019  1.58  perseant 				printf("lfs_gather: lbn %d blk %d"
   1020  1.58  perseant 				       " not B_LOCKED\n", bp->b_lblkno,
   1021  1.69  perseant 				       dbtofsb(fs, bp->b_blkno));
   1022  1.30  perseant 				VOP_PRINT(bp->b_vp);
   1023  1.30  perseant 				panic("lfs_gather: bp not B_LOCKED");
   1024  1.30  perseant 			}
   1025   1.1   mycroft #endif
   1026  1.30  perseant 			if (lfs_gatherblock(sp, bp, &s)) {
   1027  1.30  perseant 				goto loop;
   1028  1.30  perseant 			}
   1029  1.30  perseant 		}
   1030  1.15  perseant 		count++;
   1031   1.1   mycroft 	}
   1032   1.1   mycroft 	splx(s);
   1033  1.30  perseant #ifdef DEBUG_LFS
   1034  1.30  perseant 	if(vp->v_type == VBLK && count)
   1035  1.30  perseant 		printf(")\n");
   1036  1.30  perseant #endif
   1037   1.1   mycroft 	lfs_updatemeta(sp);
   1038   1.1   mycroft 	sp->vp = NULL;
   1039  1.15  perseant 	return count;
   1040   1.1   mycroft }
   1041   1.1   mycroft 
   1042   1.1   mycroft /*
   1043   1.1   mycroft  * Update the metadata that points to the blocks listed in the FINFO
   1044   1.1   mycroft  * array.
   1045   1.1   mycroft  */
   1046   1.1   mycroft void
   1047  1.69  perseant lfs_updatemeta(struct segment *sp)
   1048   1.1   mycroft {
   1049   1.1   mycroft 	SEGUSE *sup;
   1050  1.55  perseant 	struct buf *bp;
   1051   1.1   mycroft 	struct lfs *fs;
   1052   1.1   mycroft 	struct vnode *vp;
   1053   1.1   mycroft 	struct indir a[NIADDR + 2], *ap;
   1054   1.1   mycroft 	struct inode *ip;
   1055  1.10      fvdl 	ufs_daddr_t daddr, lbn, off;
   1056  1.43  perseant 	daddr_t ooff;
   1057  1.10      fvdl 	int error, i, nblocks, num;
   1058  1.53  perseant 	int bb;
   1059  1.15  perseant 
   1060   1.1   mycroft 	vp = sp->vp;
   1061   1.1   mycroft 	nblocks = &sp->fip->fi_blocks[sp->fip->fi_nblocks] - sp->start_lbp;
   1062  1.10      fvdl 	if (nblocks < 0)
   1063  1.10      fvdl 		panic("This is a bad thing\n");
   1064   1.1   mycroft 	if (vp == NULL || nblocks == 0)
   1065   1.1   mycroft 		return;
   1066  1.15  perseant 
   1067   1.1   mycroft 	/* Sort the blocks. */
   1068  1.15  perseant 	/*
   1069  1.15  perseant 	 * XXX KS - We have to sort even if the blocks come from the
   1070  1.15  perseant 	 * cleaner, because there might be other pending blocks on the
   1071  1.15  perseant 	 * same inode...and if we don't sort, and there are fragments
   1072  1.15  perseant 	 * present, blocks may be written in the wrong place.
   1073  1.15  perseant 	 */
   1074  1.15  perseant 	/* if (!(sp->seg_flags & SEGM_CLEAN)) */
   1075  1.15  perseant 	lfs_shellsort(sp->start_bpp, sp->start_lbp, nblocks);
   1076  1.15  perseant 
   1077   1.1   mycroft 	/*
   1078  1.10      fvdl 	 * Record the length of the last block in case it's a fragment.
   1079  1.10      fvdl 	 * If there are indirect blocks present, they sort last.  An
   1080  1.10      fvdl 	 * indirect block will be lfs_bsize and its presence indicates
   1081  1.10      fvdl 	 * that you cannot have fragments.
   1082  1.10      fvdl 	 */
   1083  1.10      fvdl 	sp->fip->fi_lastlength = sp->start_bpp[nblocks - 1]->b_bcount;
   1084  1.15  perseant 
   1085  1.10      fvdl 	/*
   1086   1.1   mycroft 	 * Assign disk addresses, and update references to the logical
   1087   1.1   mycroft 	 * block and the segment usage information.
   1088   1.1   mycroft 	 */
   1089   1.1   mycroft 	fs = sp->fs;
   1090   1.1   mycroft 	for (i = nblocks; i--; ++sp->start_bpp) {
   1091   1.1   mycroft 		lbn = *sp->start_lbp++;
   1092  1.15  perseant 
   1093  1.69  perseant 		(*sp->start_bpp)->b_blkno = fsbtodb(fs, fs->lfs_offset);
   1094  1.69  perseant 		off = fs->lfs_offset;
   1095  1.17  perseant 		if((*sp->start_bpp)->b_blkno == (*sp->start_bpp)->b_lblkno) {
   1096  1.58  perseant 			printf("lfs_updatemeta: ino %d blk %d"
   1097  1.58  perseant 			       " has same lbn and daddr\n",
   1098  1.58  perseant 			       VTOI(vp)->i_number, off);
   1099  1.17  perseant 		}
   1100  1.67      joff #ifdef DIAGNOSTIC
   1101  1.67      joff 		if((*sp->start_bpp)->b_bcount < fs->lfs_bsize && i != 0)
   1102  1.67      joff 			panic("lfs_updatemeta: fragment is not last block\n");
   1103  1.67      joff #endif
   1104  1.69  perseant 		bb = fragstofsb(fs, numfrags(fs, (*sp->start_bpp)->b_bcount));
   1105  1.53  perseant 		fs->lfs_offset += bb;
   1106   1.4  christos 		error = ufs_bmaparray(vp, lbn, &daddr, a, &num, NULL);
   1107  1.69  perseant 		if (daddr > 0)
   1108  1.69  perseant 			daddr = dbtofsb(fs, daddr);
   1109   1.4  christos 		if (error)
   1110   1.1   mycroft 			panic("lfs_updatemeta: ufs_bmaparray %d", error);
   1111   1.1   mycroft 		ip = VTOI(vp);
   1112   1.1   mycroft 		switch (num) {
   1113   1.1   mycroft 		case 0:
   1114  1.43  perseant 			ooff = ip->i_ffs_db[lbn];
   1115  1.55  perseant #ifdef DEBUG
   1116  1.55  perseant 			if (ooff == 0) {
   1117  1.53  perseant 				printf("lfs_updatemeta[1]: warning: writing "
   1118  1.55  perseant 				       "ino %d lbn %d at 0x%x, was 0x0\n",
   1119  1.55  perseant 				       ip->i_number, lbn, off);
   1120  1.55  perseant 			}
   1121  1.43  perseant #endif
   1122  1.55  perseant 			if (ooff == UNWRITTEN)
   1123  1.55  perseant 				ip->i_ffs_blocks += bb;
   1124  1.55  perseant 			ip->i_ffs_db[lbn] = off;
   1125   1.1   mycroft 			break;
   1126   1.1   mycroft 		case 1:
   1127  1.43  perseant 			ooff = ip->i_ffs_ib[a[0].in_off];
   1128  1.55  perseant #ifdef DEBUG
   1129  1.55  perseant 			if (ooff == 0) {
   1130  1.53  perseant 				printf("lfs_updatemeta[2]: warning: writing "
   1131  1.55  perseant 				       "ino %d lbn %d at 0x%x, was 0x0\n",
   1132  1.55  perseant 				       ip->i_number, lbn, off);
   1133  1.55  perseant 			}
   1134  1.43  perseant #endif
   1135  1.55  perseant 			if (ooff == UNWRITTEN)
   1136  1.55  perseant 				ip->i_ffs_blocks += bb;
   1137  1.55  perseant 			ip->i_ffs_ib[a[0].in_off] = off;
   1138   1.1   mycroft 			break;
   1139   1.1   mycroft 		default:
   1140   1.1   mycroft 			ap = &a[num - 1];
   1141   1.1   mycroft 			if (bread(vp, ap->in_lbn, fs->lfs_bsize, NOCRED, &bp))
   1142   1.1   mycroft 				panic("lfs_updatemeta: bread bno %d",
   1143  1.15  perseant 				      ap->in_lbn);
   1144  1.43  perseant 
   1145  1.43  perseant 			ooff = ((ufs_daddr_t *)bp->b_data)[ap->in_off];
   1146  1.55  perseant #if DEBUG
   1147  1.55  perseant 			if (ooff == 0) {
   1148  1.53  perseant 				printf("lfs_updatemeta[3]: warning: writing "
   1149  1.55  perseant 				       "ino %d lbn %d at 0x%x, was 0x0\n",
   1150  1.55  perseant 				       ip->i_number, lbn, off);
   1151  1.55  perseant 			}
   1152  1.43  perseant #endif
   1153  1.55  perseant 			if (ooff == UNWRITTEN)
   1154  1.55  perseant 				ip->i_ffs_blocks += bb;
   1155  1.55  perseant 			((ufs_daddr_t *)bp->b_data)[ap->in_off] = off;
   1156  1.58  perseant 			(void) VOP_BWRITE(bp);
   1157   1.1   mycroft 		}
   1158  1.55  perseant #ifdef DEBUG
   1159  1.49  perseant 		if (daddr >= fs->lfs_lastpseg && daddr <= off) {
   1160  1.49  perseant 			printf("lfs_updatemeta: ino %d, lbn %d, addr = %x "
   1161  1.49  perseant 			       "in same pseg\n", VTOI(sp->vp)->i_number,
   1162  1.49  perseant 			       (*sp->start_bpp)->b_lblkno, daddr);
   1163  1.49  perseant 		}
   1164  1.55  perseant #endif
   1165  1.55  perseant 		/* Update segment usage information. */
   1166  1.49  perseant 		if (daddr > 0) {
   1167  1.69  perseant 			LFS_SEGENTRY(sup, fs, dtosn(fs, daddr), bp);
   1168   1.1   mycroft #ifdef DIAGNOSTIC
   1169  1.10      fvdl 			if (sup->su_nbytes < (*sp->start_bpp)->b_bcount) {
   1170   1.1   mycroft 				/* XXX -- Change to a panic. */
   1171  1.55  perseant 				printf("lfs_updatemeta: negative bytes "
   1172  1.55  perseant 				       "(segment %d short by %ld)\n",
   1173  1.69  perseant 				       dtosn(fs, daddr),
   1174  1.55  perseant 				       (*sp->start_bpp)->b_bcount -
   1175  1.55  perseant 				       sup->su_nbytes);
   1176  1.55  perseant 				printf("lfs_updatemeta: ino %d, lbn %d, "
   1177  1.69  perseant 				       "addr = 0x%x\n", VTOI(sp->vp)->i_number,
   1178  1.55  perseant 				       (*sp->start_bpp)->b_lblkno, daddr);
   1179  1.27  perseant 				panic("lfs_updatemeta: negative bytes");
   1180  1.27  perseant 				sup->su_nbytes = (*sp->start_bpp)->b_bcount;
   1181   1.1   mycroft 			}
   1182   1.1   mycroft #endif
   1183  1.69  perseant #ifdef DEBUG_SU_NBYTES
   1184  1.69  perseant 			printf("seg %d -= %ld for ino %d lbn %d db 0x%x\n",
   1185  1.69  perseant 			       dtosn(fs, daddr), (*sp->start_bpp)->b_bcount,
   1186  1.69  perseant 			       VTOI(sp->vp)->i_number,
   1187  1.69  perseant 			       (*sp->start_bpp)->b_lblkno, daddr);
   1188  1.69  perseant #endif
   1189  1.10      fvdl 			sup->su_nbytes -= (*sp->start_bpp)->b_bcount;
   1190  1.58  perseant 			error = VOP_BWRITE(bp); /* Ifile */
   1191   1.1   mycroft 		}
   1192   1.1   mycroft 	}
   1193   1.1   mycroft }
   1194   1.1   mycroft 
   1195   1.1   mycroft /*
   1196   1.1   mycroft  * Start a new segment.
   1197   1.1   mycroft  */
   1198   1.1   mycroft int
   1199  1.69  perseant lfs_initseg(struct lfs *fs)
   1200   1.1   mycroft {
   1201   1.1   mycroft 	struct segment *sp;
   1202   1.1   mycroft 	SEGUSE *sup;
   1203   1.1   mycroft 	SEGSUM *ssp;
   1204   1.1   mycroft 	struct buf *bp;
   1205   1.1   mycroft 	int repeat;
   1206  1.15  perseant 
   1207   1.1   mycroft 	sp = fs->lfs_sp;
   1208  1.69  perseant 
   1209   1.1   mycroft 	repeat = 0;
   1210   1.1   mycroft 	/* Advance to the next segment. */
   1211   1.1   mycroft 	if (!LFS_PARTIAL_FITS(fs)) {
   1212  1.55  perseant 		/* lfs_avail eats the remaining space */
   1213  1.69  perseant 		fs->lfs_avail -= fs->lfs_fsbpseg - (fs->lfs_offset -
   1214  1.55  perseant 						   fs->lfs_curseg);
   1215   1.1   mycroft 		/* Wake up any cleaning procs waiting on this file system. */
   1216   1.1   mycroft 		wakeup(&lfs_allclean_wakeup);
   1217  1.10      fvdl 		wakeup(&fs->lfs_nextseg);
   1218   1.1   mycroft 		lfs_newseg(fs);
   1219   1.1   mycroft 		repeat = 1;
   1220   1.1   mycroft 		fs->lfs_offset = fs->lfs_curseg;
   1221  1.69  perseant 		sp->seg_number = dtosn(fs, fs->lfs_curseg);
   1222  1.69  perseant 		sp->seg_bytes_left = fsbtob(fs, fs->lfs_fsbpseg);
   1223   1.1   mycroft 		/*
   1224   1.1   mycroft 		 * If the segment contains a superblock, update the offset
   1225   1.1   mycroft 		 * and summary address to skip over it.
   1226   1.1   mycroft 		 */
   1227   1.1   mycroft 		LFS_SEGENTRY(sup, fs, sp->seg_number, bp);
   1228   1.1   mycroft 		if (sup->su_flags & SEGUSE_SUPERBLOCK) {
   1229  1.69  perseant 			fs->lfs_offset += btofsb(fs, LFS_SBPAD);
   1230   1.1   mycroft 			sp->seg_bytes_left -= LFS_SBPAD;
   1231   1.1   mycroft 		}
   1232   1.1   mycroft 		brelse(bp);
   1233  1.69  perseant 		/* Segment zero could also contain the labelpad */
   1234  1.69  perseant 		if (fs->lfs_version > 1 && sp->seg_number == 0 &&
   1235  1.69  perseant 		    fs->lfs_start < btofsb(fs, LFS_LABELPAD)) {
   1236  1.69  perseant 			fs->lfs_offset += btofsb(fs, LFS_LABELPAD) - fs->lfs_start;
   1237  1.69  perseant 			sp->seg_bytes_left -= LFS_LABELPAD - fsbtob(fs, fs->lfs_start);
   1238  1.69  perseant 		}
   1239   1.1   mycroft 	} else {
   1240  1.69  perseant 		sp->seg_number = dtosn(fs, fs->lfs_curseg);
   1241  1.69  perseant 		sp->seg_bytes_left = fsbtob(fs, fs->lfs_fsbpseg -
   1242  1.58  perseant 				      (fs->lfs_offset - fs->lfs_curseg));
   1243   1.1   mycroft 	}
   1244   1.1   mycroft 	fs->lfs_lastpseg = fs->lfs_offset;
   1245  1.15  perseant 
   1246   1.1   mycroft 	sp->fs = fs;
   1247   1.1   mycroft 	sp->ibp = NULL;
   1248  1.27  perseant 	sp->idp = NULL;
   1249   1.1   mycroft 	sp->ninodes = 0;
   1250  1.69  perseant 
   1251   1.1   mycroft 	/* Get a new buffer for SEGSUM and enter it into the buffer list. */
   1252   1.1   mycroft 	sp->cbpp = sp->bpp;
   1253  1.69  perseant 	*sp->cbpp = lfs_newbuf(fs, VTOI(fs->lfs_ivnode)->i_devvp,
   1254  1.69  perseant 			       fsbtodb(fs, fs->lfs_offset), fs->lfs_sumsize);
   1255   1.1   mycroft 	sp->segsum = (*sp->cbpp)->b_data;
   1256  1.69  perseant 	bzero(sp->segsum, fs->lfs_sumsize);
   1257   1.1   mycroft 	sp->start_bpp = ++sp->cbpp;
   1258  1.69  perseant 	fs->lfs_offset += btofsb(fs, fs->lfs_sumsize);
   1259  1.15  perseant 
   1260   1.1   mycroft 	/* Set point to SEGSUM, initialize it. */
   1261   1.1   mycroft 	ssp = sp->segsum;
   1262   1.1   mycroft 	ssp->ss_next = fs->lfs_nextseg;
   1263   1.1   mycroft 	ssp->ss_nfinfo = ssp->ss_ninos = 0;
   1264  1.10      fvdl 	ssp->ss_magic = SS_MAGIC;
   1265   1.1   mycroft 
   1266   1.1   mycroft 	/* Set pointer to first FINFO, initialize it. */
   1267  1.69  perseant 	sp->fip = (struct finfo *)((caddr_t)sp->segsum + SEGSUM_SIZE(fs));
   1268   1.1   mycroft 	sp->fip->fi_nblocks = 0;
   1269   1.1   mycroft 	sp->start_lbp = &sp->fip->fi_blocks[0];
   1270  1.10      fvdl 	sp->fip->fi_lastlength = 0;
   1271  1.15  perseant 
   1272  1.69  perseant 	sp->seg_bytes_left -= fs->lfs_sumsize;
   1273  1.69  perseant 	sp->sum_bytes_left = fs->lfs_sumsize - SEGSUM_SIZE(fs);
   1274  1.15  perseant 
   1275   1.1   mycroft 	return(repeat);
   1276   1.1   mycroft }
   1277   1.1   mycroft 
   1278   1.1   mycroft /*
   1279   1.1   mycroft  * Return the next segment to write.
   1280   1.1   mycroft  */
   1281   1.1   mycroft void
   1282  1.69  perseant lfs_newseg(struct lfs *fs)
   1283   1.1   mycroft {
   1284   1.1   mycroft 	CLEANERINFO *cip;
   1285   1.1   mycroft 	SEGUSE *sup;
   1286   1.1   mycroft 	struct buf *bp;
   1287   1.1   mycroft 	int curseg, isdirty, sn;
   1288  1.15  perseant 
   1289  1.69  perseant 	LFS_SEGENTRY(sup, fs, dtosn(fs, fs->lfs_nextseg), bp);
   1290  1.69  perseant #ifdef DEBUG_SU_NBYTES
   1291  1.69  perseant 	printf("lfs_newseg: seg %d := 0 in newseg\n",   /* XXXDEBUG */
   1292  1.69  perseant 	       dtosn(fs, fs->lfs_nextseg)); /* XXXDEBUG */
   1293  1.69  perseant #endif
   1294  1.15  perseant 	sup->su_flags |= SEGUSE_DIRTY | SEGUSE_ACTIVE;
   1295   1.1   mycroft 	sup->su_nbytes = 0;
   1296   1.1   mycroft 	sup->su_nsums = 0;
   1297   1.1   mycroft 	sup->su_ninos = 0;
   1298  1.58  perseant 	(void) VOP_BWRITE(bp); /* Ifile */
   1299   1.1   mycroft 
   1300   1.1   mycroft 	LFS_CLEANERINFO(cip, fs, bp);
   1301   1.1   mycroft 	--cip->clean;
   1302   1.1   mycroft 	++cip->dirty;
   1303  1.15  perseant 	fs->lfs_nclean = cip->clean;
   1304  1.61  perseant 	LFS_SYNC_CLEANERINFO(cip, fs, bp, 1);
   1305  1.15  perseant 
   1306   1.1   mycroft 	fs->lfs_lastseg = fs->lfs_curseg;
   1307   1.1   mycroft 	fs->lfs_curseg = fs->lfs_nextseg;
   1308  1.69  perseant 	for (sn = curseg = dtosn(fs, fs->lfs_curseg) + fs->lfs_interleave;;) {
   1309   1.1   mycroft 		sn = (sn + 1) % fs->lfs_nseg;
   1310   1.1   mycroft 		if (sn == curseg)
   1311   1.1   mycroft 			panic("lfs_nextseg: no clean segments");
   1312   1.1   mycroft 		LFS_SEGENTRY(sup, fs, sn, bp);
   1313   1.1   mycroft 		isdirty = sup->su_flags & SEGUSE_DIRTY;
   1314   1.1   mycroft 		brelse(bp);
   1315   1.1   mycroft 		if (!isdirty)
   1316   1.1   mycroft 			break;
   1317   1.1   mycroft 	}
   1318  1.15  perseant 
   1319   1.1   mycroft 	++fs->lfs_nactive;
   1320  1.69  perseant 	fs->lfs_nextseg = sntod(fs, sn);
   1321  1.15  perseant 	if(lfs_dostats) {
   1322  1.15  perseant 		++lfs_stats.segsused;
   1323  1.15  perseant 	}
   1324   1.1   mycroft }
   1325   1.1   mycroft 
   1326   1.1   mycroft int
   1327  1.69  perseant lfs_writeseg(struct lfs *fs, struct segment *sp)
   1328   1.1   mycroft {
   1329  1.53  perseant 	struct buf **bpp, *bp, *cbp, *newbp;
   1330   1.1   mycroft 	SEGUSE *sup;
   1331   1.1   mycroft 	SEGSUM *ssp;
   1332   1.1   mycroft 	dev_t i_dev;
   1333  1.69  perseant 	char *datap, *dp;
   1334  1.70  jdolecek 	int do_again, i, nblocks, s;
   1335  1.70  jdolecek 	size_t el_size;
   1336  1.15  perseant #ifdef LFS_TRACK_IOS
   1337  1.15  perseant 	int j;
   1338  1.15  perseant #endif
   1339  1.69  perseant 	int (*strategy)(void *);
   1340   1.1   mycroft 	struct vop_strategy_args vop_strategy_a;
   1341   1.1   mycroft 	u_short ninos;
   1342  1.15  perseant 	struct vnode *devvp;
   1343   1.1   mycroft 	char *p;
   1344  1.69  perseant 	struct vnode *vp;
   1345  1.26  perseant 	struct inode *ip;
   1346  1.53  perseant 	daddr_t *daddrp;
   1347  1.55  perseant 	int changed;
   1348  1.15  perseant #if defined(DEBUG) && defined(LFS_PROPELLER)
   1349  1.15  perseant 	static int propeller;
   1350  1.15  perseant 	char propstring[4] = "-\\|/";
   1351  1.15  perseant 
   1352  1.15  perseant 	printf("%c\b",propstring[propeller++]);
   1353  1.15  perseant 	if(propeller==4)
   1354  1.15  perseant 		propeller = 0;
   1355  1.15  perseant #endif
   1356  1.15  perseant 
   1357   1.1   mycroft 	/*
   1358   1.1   mycroft 	 * If there are no buffers other than the segment summary to write
   1359   1.1   mycroft 	 * and it is not a checkpoint, don't do anything.  On a checkpoint,
   1360   1.1   mycroft 	 * even if there aren't any buffers, you need to write the superblock.
   1361   1.1   mycroft 	 */
   1362   1.1   mycroft 	if ((nblocks = sp->cbpp - sp->bpp) == 1)
   1363   1.1   mycroft 		return (0);
   1364  1.15  perseant 
   1365  1.27  perseant 	i_dev = VTOI(fs->lfs_ivnode)->i_dev;
   1366  1.27  perseant 	devvp = VTOI(fs->lfs_ivnode)->i_devvp;
   1367  1.27  perseant 
   1368  1.10      fvdl 	/* Update the segment usage information. */
   1369  1.10      fvdl 	LFS_SEGENTRY(sup, fs, sp->seg_number, bp);
   1370  1.15  perseant 
   1371  1.10      fvdl 	/* Loop through all blocks, except the segment summary. */
   1372  1.27  perseant 	for (bpp = sp->bpp; ++bpp < sp->cbpp; ) {
   1373  1.69  perseant 		if((*bpp)->b_vp != devvp) {
   1374  1.27  perseant 			sup->su_nbytes += (*bpp)->b_bcount;
   1375  1.69  perseant #ifdef DEBUG_SU_NBYTES
   1376  1.69  perseant 		printf("seg %d += %ld for ino %d lbn %d db 0x%x\n",
   1377  1.69  perseant 		       sp->seg_number, (*bpp)->b_bcount,
   1378  1.69  perseant 		       VTOI((*bpp)->b_vp)->i_number,
   1379  1.69  perseant 		       (*bpp)->b_lblkno, (*bpp)->b_blkno);
   1380  1.69  perseant #endif
   1381  1.69  perseant 		}
   1382  1.27  perseant 	}
   1383  1.15  perseant 
   1384   1.1   mycroft 	ssp = (SEGSUM *)sp->segsum;
   1385  1.15  perseant 
   1386   1.1   mycroft 	ninos = (ssp->ss_ninos + INOPB(fs) - 1) / INOPB(fs);
   1387  1.69  perseant #ifdef DEBUG_SU_NBYTES
   1388  1.69  perseant 	printf("seg %d += %d for %d inodes\n",   /* XXXDEBUG */
   1389  1.69  perseant 	       sp->seg_number, ssp->ss_ninos * DINODE_SIZE,
   1390  1.69  perseant 	       ssp->ss_ninos);
   1391  1.69  perseant #endif
   1392  1.27  perseant 	sup->su_nbytes += ssp->ss_ninos * DINODE_SIZE;
   1393  1.69  perseant 	/* sup->su_nbytes += fs->lfs_sumsize; */
   1394  1.69  perseant 	if (fs->lfs_version == 1)
   1395  1.69  perseant 		sup->su_olastmod = time.tv_sec;
   1396  1.69  perseant 	else
   1397  1.69  perseant 		sup->su_lastmod = time.tv_sec;
   1398   1.1   mycroft 	sup->su_ninos += ninos;
   1399   1.1   mycroft 	++sup->su_nsums;
   1400  1.69  perseant 	fs->lfs_dmeta += (btofsb(fs, fs->lfs_sumsize) + btofsb(fs, ninos *
   1401  1.69  perseant 							 fs->lfs_ibsize));
   1402  1.69  perseant 	fs->lfs_avail -= btofsb(fs, fs->lfs_sumsize);
   1403  1.15  perseant 
   1404   1.1   mycroft 	do_again = !(bp->b_flags & B_GATHERED);
   1405  1.58  perseant 	(void)VOP_BWRITE(bp); /* Ifile */
   1406   1.1   mycroft 	/*
   1407  1.53  perseant 	 * Mark blocks B_BUSY, to prevent then from being changed between
   1408  1.53  perseant 	 * the checksum computation and the actual write.
   1409  1.53  perseant 	 *
   1410  1.53  perseant 	 * If we are cleaning, check indirect blocks for UNWRITTEN, and if
   1411  1.53  perseant 	 * there are any, replace them with copies that have UNASSIGNED
   1412  1.53  perseant 	 * instead.
   1413  1.53  perseant 	 */
   1414  1.53  perseant 	for (bpp = sp->bpp, i = nblocks - 1; i--;) {
   1415  1.53  perseant 		++bpp;
   1416  1.53  perseant 		if((*bpp)->b_flags & B_CALL)
   1417  1.53  perseant 			continue;
   1418  1.53  perseant 		bp = *bpp;
   1419  1.53  perseant 	    again:
   1420  1.53  perseant 		s = splbio();
   1421  1.53  perseant 		if(bp->b_flags & B_BUSY) {
   1422  1.53  perseant #ifdef DEBUG
   1423  1.53  perseant 			printf("lfs_writeseg: avoiding potential data "
   1424  1.53  perseant 			       "summary corruption for ino %d, lbn %d\n",
   1425  1.53  perseant 			       VTOI(bp->b_vp)->i_number, bp->b_lblkno);
   1426  1.53  perseant #endif
   1427  1.53  perseant 			bp->b_flags |= B_WANTED;
   1428  1.53  perseant 			tsleep(bp, (PRIBIO + 1), "lfs_writeseg", 0);
   1429  1.53  perseant 			splx(s);
   1430  1.53  perseant 			goto again;
   1431  1.53  perseant 		}
   1432  1.53  perseant 		bp->b_flags |= B_BUSY;
   1433  1.53  perseant 		splx(s);
   1434  1.53  perseant 		/* Check and replace indirect block UNWRITTEN bogosity */
   1435  1.53  perseant 		if(bp->b_lblkno < 0 && bp->b_vp != devvp && bp->b_vp &&
   1436  1.53  perseant 		   VTOI(bp->b_vp)->i_ffs_blocks !=
   1437  1.53  perseant 		   VTOI(bp->b_vp)->i_lfs_effnblks) {
   1438  1.54  perseant #ifdef DEBUG_LFS
   1439  1.53  perseant 			printf("lfs_writeseg: cleansing ino %d (%d != %d)\n",
   1440  1.53  perseant 			       VTOI(bp->b_vp)->i_number,
   1441  1.53  perseant 			       VTOI(bp->b_vp)->i_lfs_effnblks,
   1442  1.53  perseant 			       VTOI(bp->b_vp)->i_ffs_blocks);
   1443  1.54  perseant #endif
   1444  1.53  perseant 			/* Make a copy we'll make changes to */
   1445  1.69  perseant 			newbp = lfs_newbuf(fs, bp->b_vp, bp->b_lblkno,
   1446  1.53  perseant 					   bp->b_bcount);
   1447  1.53  perseant 			newbp->b_blkno = bp->b_blkno;
   1448  1.53  perseant 			memcpy(newbp->b_data, bp->b_data,
   1449  1.53  perseant 			       newbp->b_bcount);
   1450  1.53  perseant 			*bpp = newbp;
   1451  1.53  perseant 
   1452  1.55  perseant 			changed = 0;
   1453  1.53  perseant 			for (daddrp = (daddr_t *)(newbp->b_data);
   1454  1.53  perseant 			     daddrp < (daddr_t *)(newbp->b_data +
   1455  1.53  perseant 						  newbp->b_bcount); daddrp++) {
   1456  1.53  perseant 				if (*daddrp == UNWRITTEN) {
   1457  1.55  perseant 					++changed;
   1458  1.54  perseant #ifdef DEBUG_LFS
   1459  1.54  perseant 					printf("lfs_writeseg: replacing UNWRITTEN\n");
   1460  1.53  perseant #endif
   1461  1.53  perseant 					*daddrp = 0;
   1462  1.53  perseant 				}
   1463  1.53  perseant 			}
   1464  1.55  perseant 			/*
   1465  1.55  perseant 			 * Get rid of the old buffer.  Don't mark it clean,
   1466  1.55  perseant 			 * though, if it still has dirty data on it.
   1467  1.55  perseant 			 */
   1468  1.55  perseant 			if (changed) {
   1469  1.55  perseant 				bp->b_flags &= ~(B_ERROR | B_GATHERED);
   1470  1.69  perseant 				if (bp->b_flags & B_CALL) {
   1471  1.55  perseant 					lfs_freebuf(bp);
   1472  1.69  perseant 					bp = NULL;
   1473  1.69  perseant 				} else {
   1474  1.57  perseant 					/* Still on free list, leave it there */
   1475  1.57  perseant 					s = splbio();
   1476  1.57  perseant 					bp->b_flags &= ~B_BUSY;
   1477  1.57  perseant 					if (bp->b_flags & B_WANTED)
   1478  1.57  perseant 						wakeup(bp);
   1479  1.57  perseant 				 	splx(s);
   1480  1.62  perseant 					/*
   1481  1.62  perseant 					 * We have to re-decrement lfs_avail
   1482  1.62  perseant 					 * since this block is going to come
   1483  1.62  perseant 					 * back around to us in the next
   1484  1.62  perseant 					 * segment.
   1485  1.62  perseant 					 */
   1486  1.69  perseant 					fs->lfs_avail -= btofsb(fs, bp->b_bcount);
   1487  1.57  perseant 				}
   1488  1.55  perseant 			} else {
   1489  1.55  perseant 				bp->b_flags &= ~(B_ERROR | B_READ | B_DELWRI |
   1490  1.62  perseant 						 B_GATHERED);
   1491  1.62  perseant 				LFS_UNLOCK_BUF(bp);
   1492  1.69  perseant 				if (bp->b_flags & B_CALL) {
   1493  1.55  perseant 					lfs_freebuf(bp);
   1494  1.69  perseant 					bp = NULL;
   1495  1.69  perseant 				} else {
   1496  1.55  perseant 					bremfree(bp);
   1497  1.55  perseant 					bp->b_flags |= B_DONE;
   1498  1.55  perseant 					reassignbuf(bp, bp->b_vp);
   1499  1.55  perseant 					brelse(bp);
   1500  1.55  perseant 				}
   1501  1.55  perseant 			}
   1502  1.69  perseant 
   1503  1.53  perseant 		}
   1504  1.53  perseant 	}
   1505  1.53  perseant 	/*
   1506   1.1   mycroft 	 * Compute checksum across data and then across summary; the first
   1507   1.1   mycroft 	 * block (the summary block) is skipped.  Set the create time here
   1508   1.1   mycroft 	 * so that it's guaranteed to be later than the inode mod times.
   1509   1.1   mycroft 	 *
   1510   1.1   mycroft 	 * XXX
   1511   1.1   mycroft 	 * Fix this to do it inline, instead of malloc/copy.
   1512   1.1   mycroft 	 */
   1513  1.69  perseant 	if (fs->lfs_version == 1)
   1514  1.69  perseant 		el_size = sizeof(u_long);
   1515  1.69  perseant 	else
   1516  1.69  perseant 		el_size = sizeof(u_int32_t);
   1517  1.69  perseant 	datap = dp = malloc(nblocks * el_size, M_SEGMENT, M_WAITOK);
   1518   1.1   mycroft 	for (bpp = sp->bpp, i = nblocks - 1; i--;) {
   1519  1.15  perseant 		if (((*++bpp)->b_flags & (B_CALL|B_INVAL)) == (B_CALL|B_INVAL)) {
   1520  1.69  perseant 			if (copyin((*bpp)->b_saveaddr, dp, el_size))
   1521  1.53  perseant 				panic("lfs_writeseg: copyin failed [1]: "
   1522  1.53  perseant 				      "ino %d blk %d",
   1523  1.53  perseant 				      VTOI((*bpp)->b_vp)->i_number,
   1524  1.53  perseant 				      (*bpp)->b_lblkno);
   1525  1.53  perseant 		} else
   1526  1.69  perseant 			memcpy(dp, (*bpp)->b_data, el_size);
   1527  1.69  perseant 		dp += el_size;
   1528  1.69  perseant 	}
   1529  1.69  perseant 	if (fs->lfs_version == 1)
   1530  1.69  perseant 		ssp->ss_ocreate = time.tv_sec;
   1531  1.69  perseant 	else {
   1532  1.69  perseant 		ssp->ss_create = time.tv_sec;
   1533  1.69  perseant 		ssp->ss_serial = ++fs->lfs_serial;
   1534  1.69  perseant 		ssp->ss_ident  = fs->lfs_ident;
   1535   1.1   mycroft 	}
   1536  1.69  perseant 	ssp->ss_datasum = cksum(datap, (nblocks - 1) * el_size);
   1537   1.1   mycroft 	ssp->ss_sumsum =
   1538  1.69  perseant 	    cksum(&ssp->ss_datasum, fs->lfs_sumsize - sizeof(ssp->ss_sumsum));
   1539   1.1   mycroft 	free(datap, M_SEGMENT);
   1540  1.69  perseant 	datap = dp = NULL;
   1541  1.69  perseant #ifdef DIAGNOSTIC
   1542  1.69  perseant 	if (fs->lfs_bfree < btofsb(fs, ninos * fs->lfs_ibsize) + btofsb(fs, fs->lfs_sumsize))
   1543  1.69  perseant 		panic("lfs_writeseg: No diskspace for summary");
   1544  1.69  perseant #endif
   1545  1.69  perseant 	fs->lfs_bfree -= (btofsb(fs, ninos * fs->lfs_ibsize) +
   1546  1.69  perseant 			  btofsb(fs, fs->lfs_sumsize));
   1547   1.1   mycroft 
   1548  1.15  perseant 	strategy = devvp->v_op[VOFFSET(vop_strategy)];
   1549   1.1   mycroft 
   1550   1.1   mycroft 	/*
   1551   1.1   mycroft 	 * When we simply write the blocks we lose a rotation for every block
   1552   1.1   mycroft 	 * written.  To avoid this problem, we allocate memory in chunks, copy
   1553  1.15  perseant 	 * the buffers into the chunk and write the chunk.  CHUNKSIZE is the
   1554   1.1   mycroft 	 * largest size I/O devices can handle.
   1555  1.41     soren 	 * When the data is copied to the chunk, turn off the B_LOCKED bit
   1556   1.1   mycroft 	 * and brelse the buffer (which will move them to the LRU list).  Add
   1557   1.1   mycroft 	 * the B_CALL flag to the buffer header so we can count I/O's for the
   1558   1.1   mycroft 	 * checkpoints and so we can release the allocated memory.
   1559   1.1   mycroft 	 *
   1560   1.1   mycroft 	 * XXX
   1561   1.1   mycroft 	 * This should be removed if the new virtual memory system allows us to
   1562   1.1   mycroft 	 * easily make the buffers contiguous in kernel memory and if that's
   1563   1.1   mycroft 	 * fast enough.
   1564   1.1   mycroft 	 */
   1565  1.15  perseant 
   1566  1.15  perseant #define CHUNKSIZE MAXPHYS
   1567  1.15  perseant 
   1568  1.15  perseant 	if(devvp==NULL)
   1569  1.15  perseant 		panic("devvp is NULL");
   1570  1.15  perseant 	for (bpp = sp->bpp,i = nblocks; i;) {
   1571  1.69  perseant 		cbp = lfs_newbuf(fs, devvp, (*bpp)->b_blkno, CHUNKSIZE);
   1572   1.1   mycroft 		cbp->b_dev = i_dev;
   1573   1.1   mycroft 		cbp->b_flags |= B_ASYNC | B_BUSY;
   1574  1.10      fvdl 		cbp->b_bcount = 0;
   1575   1.1   mycroft 
   1576  1.17  perseant #ifdef DIAGNOSTIC
   1577  1.69  perseant 		if(dtosn(fs, dbtofsb(fs, (*bpp)->b_blkno) + btofsb(fs, (*bpp)->b_bcount) - 1) !=
   1578  1.69  perseant 		   dtosn(fs, dbtofsb(fs, cbp->b_blkno))) {
   1579  1.17  perseant 			panic("lfs_writeseg: Segment overwrite");
   1580  1.17  perseant 		}
   1581  1.17  perseant #endif
   1582  1.17  perseant 
   1583  1.36  perseant 		s = splbio();
   1584  1.15  perseant 		if(fs->lfs_iocount >= LFS_THROTTLE) {
   1585  1.15  perseant 			tsleep(&fs->lfs_iocount, PRIBIO+1, "lfs throttle", 0);
   1586  1.15  perseant 		}
   1587   1.1   mycroft 		++fs->lfs_iocount;
   1588  1.15  perseant #ifdef LFS_TRACK_IOS
   1589  1.15  perseant 		for(j=0;j<LFS_THROTTLE;j++) {
   1590  1.15  perseant 			if(fs->lfs_pending[j]==LFS_UNUSED_DADDR) {
   1591  1.69  perseant 				fs->lfs_pending[j] = dbtofsb(fs, cbp->b_blkno);
   1592  1.15  perseant 				break;
   1593  1.15  perseant 			}
   1594  1.15  perseant 		}
   1595  1.15  perseant #endif /* LFS_TRACK_IOS */
   1596  1.15  perseant 		for (p = cbp->b_data; i && cbp->b_bcount < CHUNKSIZE; i--) {
   1597  1.10      fvdl 			bp = *bpp;
   1598  1.15  perseant 
   1599  1.15  perseant 			if (bp->b_bcount > (CHUNKSIZE - cbp->b_bcount))
   1600  1.10      fvdl 				break;
   1601  1.10      fvdl 
   1602   1.1   mycroft 			/*
   1603   1.1   mycroft 			 * Fake buffers from the cleaner are marked as B_INVAL.
   1604   1.1   mycroft 			 * We need to copy the data from user space rather than
   1605   1.1   mycroft 			 * from the buffer indicated.
   1606   1.1   mycroft 			 * XXX == what do I do on an error?
   1607   1.1   mycroft 			 */
   1608  1.15  perseant 			if ((bp->b_flags & (B_CALL|B_INVAL)) == (B_CALL|B_INVAL)) {
   1609   1.1   mycroft 				if (copyin(bp->b_saveaddr, p, bp->b_bcount))
   1610  1.15  perseant 					panic("lfs_writeseg: copyin failed [2]");
   1611   1.1   mycroft 			} else
   1612   1.1   mycroft 				bcopy(bp->b_data, p, bp->b_bcount);
   1613   1.1   mycroft 			p += bp->b_bcount;
   1614  1.10      fvdl 			cbp->b_bcount += bp->b_bcount;
   1615  1.62  perseant 			LFS_UNLOCK_BUF(bp);
   1616   1.1   mycroft 			bp->b_flags &= ~(B_ERROR | B_READ | B_DELWRI |
   1617  1.62  perseant 					 B_GATHERED);
   1618  1.69  perseant 			vp = bp->b_vp;
   1619   1.1   mycroft 			if (bp->b_flags & B_CALL) {
   1620   1.1   mycroft 				/* if B_CALL, it was created with newbuf */
   1621  1.15  perseant 				lfs_freebuf(bp);
   1622  1.69  perseant 				bp = NULL;
   1623   1.1   mycroft 			} else {
   1624   1.1   mycroft 				bremfree(bp);
   1625   1.1   mycroft 				bp->b_flags |= B_DONE;
   1626  1.69  perseant 				if(vp)
   1627  1.69  perseant 					reassignbuf(bp, vp);
   1628   1.1   mycroft 				brelse(bp);
   1629  1.15  perseant 			}
   1630  1.26  perseant 
   1631  1.26  perseant 			bpp++;
   1632  1.26  perseant 
   1633  1.26  perseant 			/*
   1634  1.26  perseant 			 * If this is the last block for this vnode, but
   1635  1.26  perseant 			 * there are other blocks on its dirty list,
   1636  1.26  perseant 			 * set IN_MODIFIED/IN_CLEANING depending on what
   1637  1.26  perseant 			 * sort of block.  Only do this for our mount point,
   1638  1.26  perseant 			 * not for, e.g., inode blocks that are attached to
   1639  1.26  perseant 			 * the devvp.
   1640  1.69  perseant 			 * XXX KS - Shouldn't we set *both* if both types
   1641  1.69  perseant 			 * of blocks are present (traverse the dirty list?)
   1642  1.26  perseant 			 */
   1643  1.69  perseant 			if((i == 1 ||
   1644  1.69  perseant 			    (i > 1 && vp && *bpp && (*bpp)->b_vp != vp)) &&
   1645  1.69  perseant 			   (bp = vp->v_dirtyblkhd.lh_first) != NULL &&
   1646  1.69  perseant 			   vp->v_mount == fs->lfs_ivnode->v_mount)
   1647  1.26  perseant 			{
   1648  1.69  perseant 				ip = VTOI(vp);
   1649  1.26  perseant #ifdef DEBUG_LFS
   1650  1.69  perseant 				printf("lfs_writeseg: marking ino %d\n",
   1651  1.69  perseant 				       ip->i_number);
   1652  1.26  perseant #endif
   1653  1.56  perseant 				if(bp->b_flags & B_CALL)
   1654  1.56  perseant 					LFS_SET_UINO(ip, IN_CLEANING);
   1655  1.56  perseant 				else
   1656  1.56  perseant 					LFS_SET_UINO(ip, IN_MODIFIED);
   1657  1.26  perseant 			}
   1658  1.69  perseant 			wakeup(vp);
   1659   1.1   mycroft 		}
   1660   1.1   mycroft 		++cbp->b_vp->v_numoutput;
   1661   1.1   mycroft 		splx(s);
   1662   1.1   mycroft 		/*
   1663   1.1   mycroft 		 * XXXX This is a gross and disgusting hack.  Since these
   1664   1.1   mycroft 		 * buffers are physically addressed, they hang off the
   1665   1.1   mycroft 		 * device vnode (devvp).  As a result, they have no way
   1666   1.1   mycroft 		 * of getting to the LFS superblock or lfs structure to
   1667   1.1   mycroft 		 * keep track of the number of I/O's pending.  So, I am
   1668   1.1   mycroft 		 * going to stuff the fs into the saveaddr field of
   1669   1.1   mycroft 		 * the buffer (yuk).
   1670   1.1   mycroft 		 */
   1671   1.1   mycroft 		cbp->b_saveaddr = (caddr_t)fs;
   1672   1.1   mycroft 		vop_strategy_a.a_desc = VDESC(vop_strategy);
   1673   1.1   mycroft 		vop_strategy_a.a_bp = cbp;
   1674   1.1   mycroft 		(strategy)(&vop_strategy_a);
   1675   1.1   mycroft 	}
   1676  1.62  perseant #if 1 || defined(DEBUG)
   1677   1.1   mycroft 	/*
   1678  1.62  perseant 	 * After doing a big write, we recalculate how many buffers are
   1679   1.1   mycroft 	 * really still left on the locked queue.
   1680   1.1   mycroft 	 */
   1681  1.58  perseant 	s = splbio();
   1682  1.58  perseant 	lfs_countlocked(&locked_queue_count, &locked_queue_bytes);
   1683  1.58  perseant 	splx(s);
   1684   1.1   mycroft 	wakeup(&locked_queue_count);
   1685  1.62  perseant #endif /* 1 || DEBUG */
   1686  1.15  perseant 	if(lfs_dostats) {
   1687  1.15  perseant 		++lfs_stats.psegwrites;
   1688  1.15  perseant 		lfs_stats.blocktot += nblocks - 1;
   1689  1.15  perseant 		if (fs->lfs_sp->seg_flags & SEGM_SYNC)
   1690  1.15  perseant 			++lfs_stats.psyncwrites;
   1691  1.15  perseant 		if (fs->lfs_sp->seg_flags & SEGM_CLEAN) {
   1692  1.15  perseant 			++lfs_stats.pcleanwrites;
   1693  1.15  perseant 			lfs_stats.cleanblocks += nblocks - 1;
   1694  1.15  perseant 		}
   1695   1.1   mycroft 	}
   1696   1.1   mycroft 	return (lfs_initseg(fs) || do_again);
   1697   1.1   mycroft }
   1698   1.1   mycroft 
   1699   1.1   mycroft void
   1700  1.69  perseant lfs_writesuper(struct lfs *fs, daddr_t daddr)
   1701   1.1   mycroft {
   1702   1.1   mycroft 	struct buf *bp;
   1703   1.1   mycroft 	dev_t i_dev;
   1704  1.69  perseant 	int (*strategy)(void *);
   1705   1.1   mycroft 	int s;
   1706   1.1   mycroft 	struct vop_strategy_args vop_strategy_a;
   1707   1.1   mycroft 
   1708  1.15  perseant 	/*
   1709  1.15  perseant 	 * If we can write one superblock while another is in
   1710  1.15  perseant 	 * progress, we risk not having a complete checkpoint if we crash.
   1711  1.15  perseant 	 * So, block here if a superblock write is in progress.
   1712  1.15  perseant 	 */
   1713  1.36  perseant 	s = splbio();
   1714  1.15  perseant 	while(fs->lfs_sbactive) {
   1715  1.15  perseant 		tsleep(&fs->lfs_sbactive, PRIBIO+1, "lfs sb", 0);
   1716  1.15  perseant 	}
   1717  1.15  perseant 	fs->lfs_sbactive = daddr;
   1718  1.36  perseant 	splx(s);
   1719   1.1   mycroft 	i_dev = VTOI(fs->lfs_ivnode)->i_dev;
   1720   1.1   mycroft 	strategy = VTOI(fs->lfs_ivnode)->i_devvp->v_op[VOFFSET(vop_strategy)];
   1721   1.1   mycroft 
   1722  1.15  perseant 	/* Set timestamp of this version of the superblock */
   1723  1.69  perseant 	if (fs->lfs_version == 1)
   1724  1.69  perseant 		fs->lfs_otstamp = time.tv_sec;
   1725  1.15  perseant 	fs->lfs_tstamp = time.tv_sec;
   1726  1.15  perseant 
   1727   1.1   mycroft 	/* Checksum the superblock and copy it into a buffer. */
   1728  1.12        pk 	fs->lfs_cksum = lfs_sb_cksum(&(fs->lfs_dlfs));
   1729  1.69  perseant 	bp = lfs_newbuf(fs, VTOI(fs->lfs_ivnode)->i_devvp, fsbtodb(fs, daddr), LFS_SBPAD);
   1730  1.12        pk 	*(struct dlfs *)bp->b_data = fs->lfs_dlfs;
   1731  1.15  perseant 
   1732   1.1   mycroft 	bp->b_dev = i_dev;
   1733   1.1   mycroft 	bp->b_flags |= B_BUSY | B_CALL | B_ASYNC;
   1734   1.1   mycroft 	bp->b_flags &= ~(B_DONE | B_ERROR | B_READ | B_DELWRI);
   1735   1.1   mycroft 	bp->b_iodone = lfs_supercallback;
   1736  1.15  perseant 	/* XXX KS - same nasty hack as above */
   1737  1.15  perseant 	bp->b_saveaddr = (caddr_t)fs;
   1738  1.15  perseant 
   1739   1.1   mycroft 	vop_strategy_a.a_desc = VDESC(vop_strategy);
   1740   1.1   mycroft 	vop_strategy_a.a_bp = bp;
   1741   1.1   mycroft 	s = splbio();
   1742   1.1   mycroft 	++bp->b_vp->v_numoutput;
   1743  1.52  perseant 	++fs->lfs_iocount;
   1744   1.1   mycroft 	splx(s);
   1745   1.1   mycroft 	(strategy)(&vop_strategy_a);
   1746   1.1   mycroft }
   1747   1.1   mycroft 
   1748   1.1   mycroft /*
   1749   1.1   mycroft  * Logical block number match routines used when traversing the dirty block
   1750   1.1   mycroft  * chain.
   1751   1.1   mycroft  */
   1752   1.1   mycroft int
   1753  1.69  perseant lfs_match_fake(struct lfs *fs, struct buf *bp)
   1754  1.15  perseant {
   1755  1.19  perseant 	return (bp->b_flags & B_CALL);
   1756  1.15  perseant }
   1757  1.15  perseant 
   1758  1.15  perseant int
   1759  1.69  perseant lfs_match_data(struct lfs *fs, struct buf *bp)
   1760   1.1   mycroft {
   1761   1.1   mycroft 	return (bp->b_lblkno >= 0);
   1762   1.1   mycroft }
   1763   1.1   mycroft 
   1764   1.1   mycroft int
   1765  1.69  perseant lfs_match_indir(struct lfs *fs, struct buf *bp)
   1766   1.1   mycroft {
   1767   1.1   mycroft 	int lbn;
   1768   1.1   mycroft 
   1769   1.1   mycroft 	lbn = bp->b_lblkno;
   1770   1.1   mycroft 	return (lbn < 0 && (-lbn - NDADDR) % NINDIR(fs) == 0);
   1771   1.1   mycroft }
   1772   1.1   mycroft 
   1773   1.1   mycroft int
   1774  1.69  perseant lfs_match_dindir(struct lfs *fs, struct buf *bp)
   1775   1.1   mycroft {
   1776   1.1   mycroft 	int lbn;
   1777   1.1   mycroft 
   1778   1.1   mycroft 	lbn = bp->b_lblkno;
   1779   1.1   mycroft 	return (lbn < 0 && (-lbn - NDADDR) % NINDIR(fs) == 1);
   1780   1.1   mycroft }
   1781   1.1   mycroft 
   1782   1.1   mycroft int
   1783  1.69  perseant lfs_match_tindir(struct lfs *fs, struct buf *bp)
   1784   1.1   mycroft {
   1785   1.1   mycroft 	int lbn;
   1786   1.1   mycroft 
   1787   1.1   mycroft 	lbn = bp->b_lblkno;
   1788   1.1   mycroft 	return (lbn < 0 && (-lbn - NDADDR) % NINDIR(fs) == 2);
   1789   1.1   mycroft }
   1790   1.1   mycroft 
   1791   1.1   mycroft /*
   1792  1.15  perseant  * XXX - The only buffers that are going to hit these functions are the
   1793  1.15  perseant  * segment write blocks, or the segment summaries, or the superblocks.
   1794  1.15  perseant  *
   1795  1.15  perseant  * All of the above are created by lfs_newbuf, and so do not need to be
   1796  1.15  perseant  * released via brelse.
   1797   1.1   mycroft  */
   1798   1.1   mycroft void
   1799  1.69  perseant lfs_callback(struct buf *bp)
   1800   1.1   mycroft {
   1801   1.1   mycroft 	struct lfs *fs;
   1802  1.15  perseant #ifdef LFS_TRACK_IOS
   1803  1.15  perseant 	int j;
   1804  1.15  perseant #endif
   1805   1.1   mycroft 
   1806   1.1   mycroft 	fs = (struct lfs *)bp->b_saveaddr;
   1807   1.1   mycroft #ifdef DIAGNOSTIC
   1808   1.1   mycroft 	if (fs->lfs_iocount == 0)
   1809   1.1   mycroft 		panic("lfs_callback: zero iocount\n");
   1810   1.1   mycroft #endif
   1811  1.15  perseant 	if (--fs->lfs_iocount < LFS_THROTTLE)
   1812   1.1   mycroft 		wakeup(&fs->lfs_iocount);
   1813  1.15  perseant #ifdef LFS_TRACK_IOS
   1814  1.15  perseant 	for(j=0;j<LFS_THROTTLE;j++) {
   1815  1.69  perseant 		if(fs->lfs_pending[j]==dbtofsb(fs, bp->b_blkno)) {
   1816  1.15  perseant 			fs->lfs_pending[j] = LFS_UNUSED_DADDR;
   1817  1.15  perseant 			wakeup(&(fs->lfs_pending[j]));
   1818  1.15  perseant 			break;
   1819  1.15  perseant 		}
   1820  1.15  perseant 	}
   1821  1.15  perseant #endif /* LFS_TRACK_IOS */
   1822   1.1   mycroft 
   1823  1.15  perseant 	lfs_freebuf(bp);
   1824   1.1   mycroft }
   1825   1.1   mycroft 
   1826   1.1   mycroft void
   1827  1.69  perseant lfs_supercallback(struct buf *bp)
   1828   1.1   mycroft {
   1829  1.15  perseant 	struct lfs *fs;
   1830  1.15  perseant 
   1831  1.15  perseant 	fs = (struct lfs *)bp->b_saveaddr;
   1832  1.45   thorpej 	fs->lfs_sbactive = 0;
   1833  1.15  perseant 	wakeup(&fs->lfs_sbactive);
   1834  1.52  perseant 	if (--fs->lfs_iocount < LFS_THROTTLE)
   1835  1.52  perseant 		wakeup(&fs->lfs_iocount);
   1836  1.15  perseant 	lfs_freebuf(bp);
   1837   1.1   mycroft }
   1838   1.1   mycroft 
   1839   1.1   mycroft /*
   1840   1.1   mycroft  * Shellsort (diminishing increment sort) from Data Structures and
   1841   1.1   mycroft  * Algorithms, Aho, Hopcraft and Ullman, 1983 Edition, page 290;
   1842   1.1   mycroft  * see also Knuth Vol. 3, page 84.  The increments are selected from
   1843   1.1   mycroft  * formula (8), page 95.  Roughly O(N^3/2).
   1844   1.1   mycroft  */
   1845   1.1   mycroft /*
   1846   1.1   mycroft  * This is our own private copy of shellsort because we want to sort
   1847   1.1   mycroft  * two parallel arrays (the array of buffer pointers and the array of
   1848   1.1   mycroft  * logical block numbers) simultaneously.  Note that we cast the array
   1849   1.1   mycroft  * of logical block numbers to a unsigned in this routine so that the
   1850   1.1   mycroft  * negative block numbers (meta data blocks) sort AFTER the data blocks.
   1851   1.1   mycroft  */
   1852  1.15  perseant 
   1853   1.1   mycroft void
   1854  1.69  perseant lfs_shellsort(struct buf **bp_array, ufs_daddr_t *lb_array, int nmemb)
   1855   1.1   mycroft {
   1856   1.1   mycroft 	static int __rsshell_increments[] = { 4, 1, 0 };
   1857  1.42  augustss 	int incr, *incrp, t1, t2;
   1858   1.1   mycroft 	struct buf *bp_temp;
   1859   1.1   mycroft 	u_long lb_temp;
   1860   1.1   mycroft 
   1861   1.4  christos 	for (incrp = __rsshell_increments; (incr = *incrp++) != 0;)
   1862   1.1   mycroft 		for (t1 = incr; t1 < nmemb; ++t1)
   1863   1.1   mycroft 			for (t2 = t1 - incr; t2 >= 0;)
   1864   1.1   mycroft 				if (lb_array[t2] > lb_array[t2 + incr]) {
   1865   1.1   mycroft 					lb_temp = lb_array[t2];
   1866   1.1   mycroft 					lb_array[t2] = lb_array[t2 + incr];
   1867   1.1   mycroft 					lb_array[t2 + incr] = lb_temp;
   1868   1.1   mycroft 					bp_temp = bp_array[t2];
   1869   1.1   mycroft 					bp_array[t2] = bp_array[t2 + incr];
   1870   1.1   mycroft 					bp_array[t2 + incr] = bp_temp;
   1871   1.1   mycroft 					t2 -= incr;
   1872   1.1   mycroft 				} else
   1873   1.1   mycroft 					break;
   1874   1.1   mycroft }
   1875   1.1   mycroft 
   1876   1.1   mycroft /*
   1877   1.1   mycroft  * Check VXLOCK.  Return 1 if the vnode is locked.  Otherwise, vget it.
   1878   1.1   mycroft  */
   1879   1.4  christos int
   1880  1.69  perseant lfs_vref(struct vnode *vp)
   1881   1.1   mycroft {
   1882  1.15  perseant 	/*
   1883  1.15  perseant 	 * If we return 1 here during a flush, we risk vinvalbuf() not
   1884  1.15  perseant 	 * being able to flush all of the pages from this vnode, which
   1885  1.15  perseant 	 * will cause it to panic.  So, return 0 if a flush is in progress.
   1886  1.15  perseant 	 */
   1887  1.15  perseant 	if (vp->v_flag & VXLOCK) {
   1888  1.15  perseant 		if(IS_FLUSHING(VTOI(vp)->i_lfs,vp)) {
   1889  1.15  perseant 			return 0;
   1890  1.15  perseant 		}
   1891   1.1   mycroft 		return(1);
   1892  1.15  perseant 	}
   1893   1.1   mycroft 	return (vget(vp, 0));
   1894   1.1   mycroft }
   1895   1.1   mycroft 
   1896  1.10      fvdl /*
   1897  1.10      fvdl  * This is vrele except that we do not want to VOP_INACTIVE this vnode. We
   1898  1.10      fvdl  * inline vrele here to avoid the vn_lock and VOP_INACTIVE call at the end.
   1899  1.10      fvdl  */
   1900   1.1   mycroft void
   1901  1.69  perseant lfs_vunref(struct vnode *vp)
   1902   1.1   mycroft {
   1903  1.17  perseant 	/*
   1904  1.17  perseant 	 * Analogous to lfs_vref, if the node is flushing, fake it.
   1905  1.17  perseant 	 */
   1906  1.17  perseant 	if((vp->v_flag & VXLOCK) && IS_FLUSHING(VTOI(vp)->i_lfs,vp)) {
   1907  1.17  perseant 		return;
   1908  1.17  perseant 	}
   1909  1.17  perseant 
   1910  1.10      fvdl 	simple_lock(&vp->v_interlock);
   1911  1.15  perseant #ifdef DIAGNOSTIC
   1912  1.17  perseant 	if(vp->v_usecount<=0) {
   1913  1.52  perseant 		printf("lfs_vunref: inum is %d\n", VTOI(vp)->i_number);
   1914  1.69  perseant 		printf("lfs_vunref: flags are 0x%lx\n", (u_long)vp->v_flag);
   1915  1.69  perseant 		printf("lfs_vunref: usecount = %ld\n", (long)vp->v_usecount);
   1916  1.15  perseant 		panic("lfs_vunref: v_usecount<0");
   1917  1.15  perseant 	}
   1918  1.15  perseant #endif
   1919  1.10      fvdl 	vp->v_usecount--;
   1920  1.10      fvdl 	if (vp->v_usecount > 0) {
   1921  1.15  perseant 		simple_unlock(&vp->v_interlock);
   1922  1.15  perseant 		return;
   1923  1.15  perseant 	}
   1924  1.15  perseant 	/*
   1925  1.10      fvdl 	 * insert at tail of LRU list
   1926   1.1   mycroft 	 */
   1927  1.10      fvdl 	simple_lock(&vnode_free_list_slock);
   1928  1.40  perseant 	if (vp->v_holdcnt > 0)
   1929  1.40  perseant 		TAILQ_INSERT_TAIL(&vnode_hold_list, vp, v_freelist);
   1930  1.40  perseant 	else
   1931  1.40  perseant 		TAILQ_INSERT_TAIL(&vnode_free_list, vp, v_freelist);
   1932  1.10      fvdl 	simple_unlock(&vnode_free_list_slock);
   1933  1.10      fvdl 	simple_unlock(&vp->v_interlock);
   1934   1.1   mycroft }
   1935  1.15  perseant 
   1936  1.15  perseant /*
   1937  1.15  perseant  * We use this when we have vnodes that were loaded in solely for cleaning.
   1938  1.15  perseant  * There is no reason to believe that these vnodes will be referenced again
   1939  1.15  perseant  * soon, since the cleaning process is unrelated to normal filesystem
   1940  1.15  perseant  * activity.  Putting cleaned vnodes at the tail of the list has the effect
   1941  1.15  perseant  * of flushing the vnode LRU.  So, put vnodes that were loaded only for
   1942  1.15  perseant  * cleaning at the head of the list, instead.
   1943  1.15  perseant  */
   1944  1.15  perseant void
   1945  1.69  perseant lfs_vunref_head(struct vnode *vp)
   1946  1.15  perseant {
   1947  1.15  perseant 	simple_lock(&vp->v_interlock);
   1948  1.15  perseant #ifdef DIAGNOSTIC
   1949  1.15  perseant 	if(vp->v_usecount==0) {
   1950  1.15  perseant 		panic("lfs_vunref: v_usecount<0");
   1951  1.15  perseant 	}
   1952  1.15  perseant #endif
   1953  1.15  perseant 	vp->v_usecount--;
   1954  1.15  perseant 	if (vp->v_usecount > 0) {
   1955  1.15  perseant 		simple_unlock(&vp->v_interlock);
   1956  1.15  perseant 		return;
   1957  1.15  perseant 	}
   1958  1.15  perseant 	/*
   1959  1.15  perseant 	 * insert at head of LRU list
   1960  1.15  perseant 	 */
   1961  1.15  perseant 	simple_lock(&vnode_free_list_slock);
   1962  1.15  perseant 	TAILQ_INSERT_HEAD(&vnode_free_list, vp, v_freelist);
   1963  1.15  perseant 	simple_unlock(&vnode_free_list_slock);
   1964  1.15  perseant 	simple_unlock(&vp->v_interlock);
   1965  1.15  perseant }
   1966  1.15  perseant 
   1967