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