Home | History | Annotate | Line # | Download | only in lfs
lfs_segment.c revision 1.177
      1 /*	$NetBSD: lfs_segment.c,v 1.177 2006/05/01 19:47:29 perseant Exp $	*/
      2 
      3 /*-
      4  * Copyright (c) 1999, 2000, 2001, 2002, 2003 The NetBSD Foundation, Inc.
      5  * All rights reserved.
      6  *
      7  * This code is derived from software contributed to The NetBSD Foundation
      8  * by Konrad E. Schroder <perseant (at) hhhh.org>.
      9  *
     10  * Redistribution and use in source and binary forms, with or without
     11  * modification, are permitted provided that the following conditions
     12  * are met:
     13  * 1. Redistributions of source code must retain the above copyright
     14  *    notice, this list of conditions and the following disclaimer.
     15  * 2. Redistributions in binary form must reproduce the above copyright
     16  *    notice, this list of conditions and the following disclaimer in the
     17  *    documentation and/or other materials provided with the distribution.
     18  * 3. All advertising materials mentioning features or use of this software
     19  *    must display the following acknowledgement:
     20  *	This product includes software developed by the NetBSD
     21  *	Foundation, Inc. and its contributors.
     22  * 4. Neither the name of The NetBSD Foundation nor the names of its
     23  *    contributors may be used to endorse or promote products derived
     24  *    from this software without specific prior written permission.
     25  *
     26  * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
     27  * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
     28  * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
     29  * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
     30  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
     31  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
     32  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
     33  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
     34  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
     35  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
     36  * POSSIBILITY OF SUCH DAMAGE.
     37  */
     38 /*
     39  * Copyright (c) 1991, 1993
     40  *	The Regents of the University of California.  All rights reserved.
     41  *
     42  * Redistribution and use in source and binary forms, with or without
     43  * modification, are permitted provided that the following conditions
     44  * are met:
     45  * 1. Redistributions of source code must retain the above copyright
     46  *    notice, this list of conditions and the following disclaimer.
     47  * 2. Redistributions in binary form must reproduce the above copyright
     48  *    notice, this list of conditions and the following disclaimer in the
     49  *    documentation and/or other materials provided with the distribution.
     50  * 3. Neither the name of the University nor the names of its contributors
     51  *    may be used to endorse or promote products derived from this software
     52  *    without specific prior written permission.
     53  *
     54  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     55  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     56  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     57  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     58  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     59  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     60  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     61  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     62  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     63  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     64  * SUCH DAMAGE.
     65  *
     66  *	@(#)lfs_segment.c	8.10 (Berkeley) 6/10/95
     67  */
     68 
     69 #include <sys/cdefs.h>
     70 __KERNEL_RCSID(0, "$NetBSD: lfs_segment.c,v 1.177 2006/05/01 19:47:29 perseant Exp $");
     71 
     72 #ifdef DEBUG
     73 # define vndebug(vp, str) do {						\
     74 	if (VTOI(vp)->i_flag & IN_CLEANING)				\
     75 		DLOG((DLOG_WVNODE, "not writing ino %d because %s (op %d)\n", \
     76 		     VTOI(vp)->i_number, (str), op));			\
     77 } while(0)
     78 #else
     79 # define vndebug(vp, str)
     80 #endif
     81 #define ivndebug(vp, str) \
     82 	DLOG((DLOG_WVNODE, "ino %d: %s\n", VTOI(vp)->i_number, (str)))
     83 
     84 #if defined(_KERNEL_OPT)
     85 #include "opt_ddb.h"
     86 #endif
     87 
     88 #include <sys/param.h>
     89 #include <sys/systm.h>
     90 #include <sys/namei.h>
     91 #include <sys/kernel.h>
     92 #include <sys/resourcevar.h>
     93 #include <sys/file.h>
     94 #include <sys/stat.h>
     95 #include <sys/buf.h>
     96 #include <sys/proc.h>
     97 #include <sys/vnode.h>
     98 #include <sys/mount.h>
     99 
    100 #include <miscfs/specfs/specdev.h>
    101 #include <miscfs/fifofs/fifo.h>
    102 
    103 #include <ufs/ufs/inode.h>
    104 #include <ufs/ufs/dir.h>
    105 #include <ufs/ufs/ufsmount.h>
    106 #include <ufs/ufs/ufs_extern.h>
    107 
    108 #include <ufs/lfs/lfs.h>
    109 #include <ufs/lfs/lfs_extern.h>
    110 
    111 #include <uvm/uvm.h>
    112 #include <uvm/uvm_extern.h>
    113 
    114 MALLOC_DEFINE(M_SEGMENT, "LFS segment", "Segment for LFS");
    115 
    116 extern int count_lock_queue(void);
    117 extern struct simplelock vnode_free_list_slock;		/* XXX */
    118 extern struct simplelock bqueue_slock;			/* XXX */
    119 
    120 static void lfs_generic_callback(struct buf *, void (*)(struct buf *));
    121 static void lfs_super_aiodone(struct buf *);
    122 static void lfs_cluster_aiodone(struct buf *);
    123 static void lfs_cluster_callback(struct buf *);
    124 
    125 /*
    126  * Determine if it's OK to start a partial in this segment, or if we need
    127  * to go on to a new segment.
    128  */
    129 #define	LFS_PARTIAL_FITS(fs) \
    130 	((fs)->lfs_fsbpseg - ((fs)->lfs_offset - (fs)->lfs_curseg) > \
    131 	fragstofsb((fs), (fs)->lfs_frag))
    132 
    133 /*
    134  * Figure out whether we should do a checkpoint write or go ahead with
    135  * an ordinary write.
    136  */
    137 #define LFS_SHOULD_CHECKPOINT(fs, flags) \
    138 	(fs->lfs_nactive > LFS_MAX_ACTIVE ||				\
    139 	 (flags & SEGM_CKP) ||						\
    140 	 fs->lfs_nclean < LFS_MAX_ACTIVE)
    141 
    142 int	 lfs_match_fake(struct lfs *, struct buf *);
    143 void	 lfs_newseg(struct lfs *);
    144 /* XXX ondisk32 */
    145 void	 lfs_shellsort(struct buf **, int32_t *, int, int);
    146 void	 lfs_supercallback(struct buf *);
    147 void	 lfs_updatemeta(struct segment *);
    148 void	 lfs_writesuper(struct lfs *, daddr_t);
    149 int	 lfs_writevnodes(struct lfs *fs, struct mount *mp,
    150 	    struct segment *sp, int dirops);
    151 
    152 int	lfs_allclean_wakeup;		/* Cleaner wakeup address. */
    153 int	lfs_writeindir = 1;		/* whether to flush indir on non-ckp */
    154 int	lfs_clean_vnhead = 0;		/* Allow freeing to head of vn list */
    155 int	lfs_dirvcount = 0;		/* # active dirops */
    156 
    157 /* Statistics Counters */
    158 int lfs_dostats = 1;
    159 struct lfs_stats lfs_stats;
    160 
    161 /* op values to lfs_writevnodes */
    162 #define	VN_REG		0
    163 #define	VN_DIROP	1
    164 #define	VN_EMPTY	2
    165 #define VN_CLEAN	3
    166 
    167 /*
    168  * XXX KS - Set modification time on the Ifile, so the cleaner can
    169  * read the fs mod time off of it.  We don't set IN_UPDATE here,
    170  * since we don't really need this to be flushed to disk (and in any
    171  * case that wouldn't happen to the Ifile until we checkpoint).
    172  */
    173 void
    174 lfs_imtime(struct lfs *fs)
    175 {
    176 	struct timespec ts;
    177 	struct inode *ip;
    178 
    179 	ASSERT_MAYBE_SEGLOCK(fs);
    180 	nanotime(&ts);
    181 	ip = VTOI(fs->lfs_ivnode);
    182 	ip->i_ffs1_mtime = ts.tv_sec;
    183 	ip->i_ffs1_mtimensec = ts.tv_nsec;
    184 }
    185 
    186 /*
    187  * Ifile and meta data blocks are not marked busy, so segment writes MUST be
    188  * single threaded.  Currently, there are two paths into lfs_segwrite, sync()
    189  * and getnewbuf().  They both mark the file system busy.  Lfs_vflush()
    190  * explicitly marks the file system busy.  So lfs_segwrite is safe.  I think.
    191  */
    192 
    193 #define IS_FLUSHING(fs,vp)  ((fs)->lfs_flushvp == (vp))
    194 
    195 int
    196 lfs_vflush(struct vnode *vp)
    197 {
    198 	struct inode *ip;
    199 	struct lfs *fs;
    200 	struct segment *sp;
    201 	struct buf *bp, *nbp, *tbp, *tnbp;
    202 	int error, s;
    203 	int flushed;
    204 	int relock;
    205 
    206 	ip = VTOI(vp);
    207 	fs = VFSTOUFS(vp->v_mount)->um_lfs;
    208 	relock = 0;
    209 
    210     top:
    211 	ASSERT_NO_SEGLOCK(fs);
    212 	if (ip->i_flag & IN_CLEANING) {
    213 		ivndebug(vp,"vflush/in_cleaning");
    214 		LFS_CLR_UINO(ip, IN_CLEANING);
    215 		LFS_SET_UINO(ip, IN_MODIFIED);
    216 
    217 		/*
    218 		 * Toss any cleaning buffers that have real counterparts
    219 		 * to avoid losing new data.
    220 		 */
    221 		s = splbio();
    222 		for (bp = LIST_FIRST(&vp->v_dirtyblkhd); bp; bp = nbp) {
    223 			nbp = LIST_NEXT(bp, b_vnbufs);
    224 			if (!LFS_IS_MALLOC_BUF(bp))
    225 				continue;
    226 			/*
    227 			 * Look for pages matching the range covered
    228 			 * by cleaning blocks.  It's okay if more dirty
    229 			 * pages appear, so long as none disappear out
    230 			 * from under us.
    231 			 */
    232 			if (bp->b_lblkno > 0 && vp->v_type == VREG &&
    233 			    vp != fs->lfs_ivnode) {
    234 				struct vm_page *pg;
    235 				voff_t off;
    236 
    237 				simple_lock(&vp->v_interlock);
    238 				for (off = lblktosize(fs, bp->b_lblkno);
    239 				     off < lblktosize(fs, bp->b_lblkno + 1);
    240 				     off += PAGE_SIZE) {
    241 					pg = uvm_pagelookup(&vp->v_uobj, off);
    242 					if (pg == NULL)
    243 						continue;
    244 					if ((pg->flags & PG_CLEAN) == 0 ||
    245 					    pmap_is_modified(pg)) {
    246 						fs->lfs_avail += btofsb(fs,
    247 							bp->b_bcount);
    248 						wakeup(&fs->lfs_avail);
    249 						lfs_freebuf(fs, bp);
    250 						bp = NULL;
    251 						simple_unlock(&vp->v_interlock);
    252 						goto nextbp;
    253 					}
    254 				}
    255 				simple_unlock(&vp->v_interlock);
    256 			}
    257 			for (tbp = LIST_FIRST(&vp->v_dirtyblkhd); tbp;
    258 			    tbp = tnbp)
    259 			{
    260 				tnbp = LIST_NEXT(tbp, b_vnbufs);
    261 				if (tbp->b_vp == bp->b_vp
    262 				   && tbp->b_lblkno == bp->b_lblkno
    263 				   && tbp != bp)
    264 				{
    265 					fs->lfs_avail += btofsb(fs,
    266 						bp->b_bcount);
    267 					wakeup(&fs->lfs_avail);
    268 					lfs_freebuf(fs, bp);
    269 					bp = NULL;
    270 					break;
    271 				}
    272 			}
    273 		    nextbp:
    274 			;
    275 		}
    276 		splx(s);
    277 	}
    278 
    279 	/* If the node is being written, wait until that is done */
    280 	simple_lock(&vp->v_interlock);
    281 	s = splbio();
    282 	if (WRITEINPROG(vp)) {
    283 		ivndebug(vp,"vflush/writeinprog");
    284 		ltsleep(vp, (PRIBIO+1), "lfs_vw", 0, &vp->v_interlock);
    285 	}
    286 	splx(s);
    287 	simple_unlock(&vp->v_interlock);
    288 
    289 	/* Protect against VXLOCK deadlock in vinvalbuf() */
    290 	lfs_seglock(fs, SEGM_SYNC);
    291 
    292 	/* If we're supposed to flush a freed inode, just toss it */
    293 	/* XXX - seglock, so these buffers can't be gathered, right? */
    294 	if (ip->i_mode == 0) {
    295 		DLOG((DLOG_VNODE, "lfs_vflush: ino %d freed, not flushing\n",
    296 		      ip->i_number));
    297 		s = splbio();
    298 		for (bp = LIST_FIRST(&vp->v_dirtyblkhd); bp; bp = nbp) {
    299 			nbp = LIST_NEXT(bp, b_vnbufs);
    300 			if (bp->b_flags & B_DELWRI) { /* XXX always true? */
    301 				fs->lfs_avail += btofsb(fs, bp->b_bcount);
    302 				wakeup(&fs->lfs_avail);
    303 			}
    304 			/* Copied from lfs_writeseg */
    305 			if (bp->b_flags & B_CALL) {
    306 				biodone(bp);
    307 			} else {
    308 				bremfree(bp);
    309 				LFS_UNLOCK_BUF(bp);
    310 				bp->b_flags &= ~(B_ERROR | B_READ | B_DELWRI |
    311 					 B_GATHERED);
    312 				bp->b_flags |= B_DONE;
    313 				reassignbuf(bp, vp);
    314 				brelse(bp);
    315 			}
    316 		}
    317 		splx(s);
    318 		LFS_CLR_UINO(ip, IN_CLEANING);
    319 		LFS_CLR_UINO(ip, IN_MODIFIED | IN_ACCESSED);
    320 		ip->i_flag &= ~IN_ALLMOD;
    321 		DLOG((DLOG_VNODE, "lfs_vflush: done not flushing ino %d\n",
    322 		      ip->i_number));
    323 		lfs_segunlock(fs);
    324 		return 0;
    325 	}
    326 
    327 	fs->lfs_flushvp = vp;
    328 	if (LFS_SHOULD_CHECKPOINT(fs, fs->lfs_sp->seg_flags)) {
    329 		error = lfs_segwrite(vp->v_mount, SEGM_CKP | SEGM_SYNC);
    330 		fs->lfs_flushvp = NULL;
    331 		KASSERT(fs->lfs_flushvp_fakevref == 0);
    332 		lfs_segunlock(fs);
    333 		return error;
    334 	}
    335 	sp = fs->lfs_sp;
    336 
    337 	flushed = 0;
    338 	if (VPISEMPTY(vp)) {
    339 		lfs_writevnodes(fs, vp->v_mount, sp, VN_EMPTY);
    340 		++flushed;
    341 	} else if ((ip->i_flag & IN_CLEANING) &&
    342 		  (fs->lfs_sp->seg_flags & SEGM_CLEAN)) {
    343 		ivndebug(vp,"vflush/clean");
    344 		lfs_writevnodes(fs, vp->v_mount, sp, VN_CLEAN);
    345 		++flushed;
    346 	} else if (lfs_dostats) {
    347 		if (!VPISEMPTY(vp) || (VTOI(vp)->i_flag & IN_ALLMOD))
    348 			++lfs_stats.vflush_invoked;
    349 		ivndebug(vp,"vflush");
    350 	}
    351 
    352 #ifdef DIAGNOSTIC
    353 	if (vp->v_flag & VDIROP) {
    354 		DLOG((DLOG_VNODE, "lfs_vflush: flushing VDIROP\n"));
    355 		/* panic("lfs_vflush: VDIROP being flushed...this can\'t happen"); */
    356 	}
    357 	if (vp->v_usecount < 0) {
    358 		printf("usecount=%ld\n", (long)vp->v_usecount);
    359 		panic("lfs_vflush: usecount<0");
    360 	}
    361 #endif
    362 
    363 	do {
    364 		do {
    365 			if (LIST_FIRST(&vp->v_dirtyblkhd) != NULL) {
    366 				relock = lfs_writefile(fs, sp, vp);
    367 				if (relock) {
    368 					/*
    369 					 * Might have to wait for the
    370 					 * cleaner to run; but we're
    371 					 * still not done with this vnode.
    372 					 */
    373 					lfs_writeinode(fs, sp, ip);
    374 					LFS_SET_UINO(ip, IN_MODIFIED);
    375 					lfs_writeseg(fs, sp);
    376 					lfs_segunlock(fs);
    377 					lfs_segunlock_relock(fs);
    378 					goto top;
    379 				}
    380 			}
    381 			/*
    382 			 * If we begin a new segment in the middle of writing
    383 			 * the Ifile, it creates an inconsistent checkpoint,
    384 			 * since the Ifile information for the new segment
    385 			 * is not up-to-date.  Take care of this here by
    386 			 * sending the Ifile through again in case there
    387 			 * are newly dirtied blocks.  But wait, there's more!
    388 			 * This second Ifile write could *also* cross a segment
    389 			 * boundary, if the first one was large.  The second
    390 			 * one is guaranteed to be no more than 8 blocks,
    391 			 * though (two segment blocks and supporting indirects)
    392 			 * so the third write *will not* cross the boundary.
    393 			 */
    394 			if (vp == fs->lfs_ivnode) {
    395 				lfs_writefile(fs, sp, vp);
    396 				lfs_writefile(fs, sp, vp);
    397 			}
    398 		} while (lfs_writeinode(fs, sp, ip));
    399 	} while (lfs_writeseg(fs, sp) && ip->i_number == LFS_IFILE_INUM);
    400 
    401 	if (lfs_dostats) {
    402 		++lfs_stats.nwrites;
    403 		if (sp->seg_flags & SEGM_SYNC)
    404 			++lfs_stats.nsync_writes;
    405 		if (sp->seg_flags & SEGM_CKP)
    406 			++lfs_stats.ncheckpoints;
    407 	}
    408 	/*
    409 	 * If we were called from somewhere that has already held the seglock
    410 	 * (e.g., lfs_markv()), the lfs_segunlock will not wait for
    411 	 * the write to complete because we are still locked.
    412 	 * Since lfs_vflush() must return the vnode with no dirty buffers,
    413 	 * we must explicitly wait, if that is the case.
    414 	 *
    415 	 * We compare the iocount against 1, not 0, because it is
    416 	 * artificially incremented by lfs_seglock().
    417 	 */
    418 	simple_lock(&fs->lfs_interlock);
    419 	if (fs->lfs_seglock > 1) {
    420 		while (fs->lfs_iocount > 1)
    421 			(void)ltsleep(&fs->lfs_iocount, PRIBIO + 1,
    422 				     "lfs_vflush", 0, &fs->lfs_interlock);
    423 	}
    424 	simple_unlock(&fs->lfs_interlock);
    425 
    426 	lfs_segunlock(fs);
    427 
    428 	/* Wait for these buffers to be recovered by aiodoned */
    429 	s = splbio();
    430 	simple_lock(&global_v_numoutput_slock);
    431 	while (vp->v_numoutput > 0) {
    432 		vp->v_flag |= VBWAIT;
    433 		ltsleep(&vp->v_numoutput, PRIBIO + 1, "lfs_vf2", 0,
    434 			&global_v_numoutput_slock);
    435 	}
    436 	simple_unlock(&global_v_numoutput_slock);
    437 	splx(s);
    438 
    439 	fs->lfs_flushvp = NULL;
    440 	KASSERT(fs->lfs_flushvp_fakevref == 0);
    441 
    442 	return (0);
    443 }
    444 
    445 int
    446 lfs_writevnodes(struct lfs *fs, struct mount *mp, struct segment *sp, int op)
    447 {
    448 	struct inode *ip;
    449 	struct vnode *vp, *nvp;
    450 	int inodes_written = 0, only_cleaning;
    451 	int error = 0;
    452 
    453 	ASSERT_SEGLOCK(fs);
    454 #ifndef LFS_NO_BACKVP_HACK
    455 	/* BEGIN HACK */
    456 #define	VN_OFFSET	\
    457 	(((caddr_t)&LIST_NEXT(vp, v_mntvnodes)) - (caddr_t)vp)
    458 #define	BACK_VP(VP)	\
    459 	((struct vnode *)(((caddr_t)(VP)->v_mntvnodes.le_prev) - VN_OFFSET))
    460 #define	BEG_OF_VLIST	\
    461 	((struct vnode *)(((caddr_t)&LIST_FIRST(&mp->mnt_vnodelist)) \
    462 	- VN_OFFSET))
    463 
    464 	/* Find last vnode. */
    465  loop:	for (vp = LIST_FIRST(&mp->mnt_vnodelist);
    466 	     vp && LIST_NEXT(vp, v_mntvnodes) != NULL;
    467 	     vp = LIST_NEXT(vp, v_mntvnodes));
    468 	for (; vp && vp != BEG_OF_VLIST; vp = nvp) {
    469 		nvp = BACK_VP(vp);
    470 #else
    471 	loop:
    472 	for (vp = LIST_FIRST(&mp->mnt_vnodelist); vp; vp = nvp) {
    473 		nvp = LIST_NEXT(vp, v_mntvnodes);
    474 #endif
    475 		/*
    476 		 * If the vnode that we are about to sync is no longer
    477 		 * associated with this mount point, start over.
    478 		 */
    479 		if (vp->v_mount != mp) {
    480 			DLOG((DLOG_VNODE, "lfs_writevnodes: starting over\n"));
    481 			/*
    482 			 * After this, pages might be busy
    483 			 * due to our own previous putpages.
    484 			 * Start actual segment write here to avoid deadlock.
    485 			 */
    486 			(void)lfs_writeseg(fs, sp);
    487 			goto loop;
    488 		}
    489 
    490 		if (vp->v_type == VNON) {
    491 			continue;
    492 		}
    493 
    494 		ip = VTOI(vp);
    495 		if ((op == VN_DIROP && !(vp->v_flag & VDIROP)) ||
    496 		    (op != VN_DIROP && op != VN_CLEAN &&
    497 		    (vp->v_flag & VDIROP))) {
    498 			vndebug(vp,"dirop");
    499 			continue;
    500 		}
    501 
    502 		if (op == VN_EMPTY && !VPISEMPTY(vp)) {
    503 			vndebug(vp,"empty");
    504 			continue;
    505 		}
    506 
    507 		if (op == VN_CLEAN && ip->i_number != LFS_IFILE_INUM
    508 		   && vp != fs->lfs_flushvp
    509 		   && !(ip->i_flag & IN_CLEANING)) {
    510 			vndebug(vp,"cleaning");
    511 			continue;
    512 		}
    513 
    514 		if (lfs_vref(vp)) {
    515 			vndebug(vp,"vref");
    516 			continue;
    517 		}
    518 
    519 		only_cleaning = 0;
    520 		/*
    521 		 * Write the inode/file if dirty and it's not the IFILE.
    522 		 */
    523 		if ((ip->i_flag & IN_ALLMOD) || !VPISEMPTY(vp)) {
    524 			only_cleaning =
    525 			    ((ip->i_flag & IN_ALLMOD) == IN_CLEANING);
    526 
    527 			if (ip->i_number != LFS_IFILE_INUM) {
    528 				error = lfs_writefile(fs, sp, vp);
    529 				if (error) {
    530 					lfs_vunref(vp);
    531 					if (error == EAGAIN) {
    532 						/*
    533 						 * This error from lfs_putpages
    534 						 * indicates we need to drop
    535 						 * the segment lock and start
    536 						 * over after the cleaner has
    537 						 * had a chance to run.
    538 						 */
    539 						lfs_writeinode(fs, sp, ip);
    540 						lfs_writeseg(fs, sp);
    541 						if (!VPISEMPTY(vp) &&
    542 						    !WRITEINPROG(vp) &&
    543 						    !(ip->i_flag & IN_ALLMOD))
    544 							LFS_SET_UINO(ip, IN_MODIFIED);
    545 						break;
    546 					}
    547 					error = 0; /* XXX not quite right */
    548 					continue;
    549 				}
    550 
    551 				if (!VPISEMPTY(vp)) {
    552 					if (WRITEINPROG(vp)) {
    553 						ivndebug(vp,"writevnodes/write2");
    554 					} else if (!(ip->i_flag & IN_ALLMOD)) {
    555 						LFS_SET_UINO(ip, IN_MODIFIED);
    556 					}
    557 				}
    558 				(void) lfs_writeinode(fs, sp, ip);
    559 				inodes_written++;
    560 			}
    561 		}
    562 
    563 		if (lfs_clean_vnhead && only_cleaning)
    564 			lfs_vunref_head(vp);
    565 		else
    566 			lfs_vunref(vp);
    567 	}
    568 	return error;
    569 }
    570 
    571 /*
    572  * Do a checkpoint.
    573  */
    574 int
    575 lfs_segwrite(struct mount *mp, int flags)
    576 {
    577 	struct buf *bp;
    578 	struct inode *ip;
    579 	struct lfs *fs;
    580 	struct segment *sp;
    581 	struct vnode *vp;
    582 	SEGUSE *segusep;
    583 	int do_ckp, did_ckp, error, s;
    584 	unsigned n, segleft, maxseg, sn, i, curseg;
    585 	int writer_set = 0;
    586 	int dirty;
    587 	int redo;
    588 	int um_error;
    589 
    590 	fs = VFSTOUFS(mp)->um_lfs;
    591 	ASSERT_MAYBE_SEGLOCK(fs);
    592 
    593 	if (fs->lfs_ronly)
    594 		return EROFS;
    595 
    596 	lfs_imtime(fs);
    597 
    598 	/*
    599 	 * Allocate a segment structure and enough space to hold pointers to
    600 	 * the maximum possible number of buffers which can be described in a
    601 	 * single summary block.
    602 	 */
    603 	do_ckp = LFS_SHOULD_CHECKPOINT(fs, flags);
    604 
    605 	lfs_seglock(fs, flags | (do_ckp ? SEGM_CKP : 0));
    606 	sp = fs->lfs_sp;
    607 
    608 	/*
    609 	 * If lfs_flushvp is non-NULL, we are called from lfs_vflush,
    610 	 * in which case we have to flush *all* buffers off of this vnode.
    611 	 * We don't care about other nodes, but write any non-dirop nodes
    612 	 * anyway in anticipation of another getnewvnode().
    613 	 *
    614 	 * If we're cleaning we only write cleaning and ifile blocks, and
    615 	 * no dirops, since otherwise we'd risk corruption in a crash.
    616 	 */
    617 	if (sp->seg_flags & SEGM_CLEAN)
    618 		lfs_writevnodes(fs, mp, sp, VN_CLEAN);
    619 	else if (!(sp->seg_flags & SEGM_FORCE_CKP)) {
    620 		do {
    621 			um_error = lfs_writevnodes(fs, mp, sp, VN_REG);
    622 			if (!fs->lfs_dirops || !fs->lfs_flushvp) {
    623 				if (!writer_set) {
    624 					lfs_writer_enter(fs, "lfs writer");
    625 					writer_set = 1;
    626 				}
    627 				error = lfs_writevnodes(fs, mp, sp, VN_DIROP);
    628 				if (um_error == 0)
    629 					um_error = error;
    630 				/* In case writevnodes errored out */
    631 				lfs_flush_dirops(fs);
    632 				((SEGSUM *)(sp->segsum))->ss_flags &= ~(SS_CONT);
    633 				lfs_finalize_fs_seguse(fs);
    634 			}
    635 			if (do_ckp && um_error) {
    636 				lfs_segunlock_relock(fs);
    637 				sp = fs->lfs_sp;
    638 			}
    639 		} while (do_ckp && um_error != 0);
    640 	}
    641 
    642 	/*
    643 	 * If we are doing a checkpoint, mark everything since the
    644 	 * last checkpoint as no longer ACTIVE.
    645 	 */
    646 	if (do_ckp) {
    647 		segleft = fs->lfs_nseg;
    648 		curseg = 0;
    649 		for (n = 0; n < fs->lfs_segtabsz; n++) {
    650 			dirty = 0;
    651 			if (bread(fs->lfs_ivnode,
    652 			    fs->lfs_cleansz + n, fs->lfs_bsize, NOCRED, &bp))
    653 				panic("lfs_segwrite: ifile read");
    654 			segusep = (SEGUSE *)bp->b_data;
    655 			maxseg = min(segleft, fs->lfs_sepb);
    656 			for (i = 0; i < maxseg; i++) {
    657 				sn = curseg + i;
    658 				if (sn != dtosn(fs, fs->lfs_curseg) &&
    659 				    segusep->su_flags & SEGUSE_ACTIVE) {
    660 					segusep->su_flags &= ~SEGUSE_ACTIVE;
    661 					--fs->lfs_nactive;
    662 					++dirty;
    663 				}
    664 				fs->lfs_suflags[fs->lfs_activesb][sn] =
    665 					segusep->su_flags;
    666 				if (fs->lfs_version > 1)
    667 					++segusep;
    668 				else
    669 					segusep = (SEGUSE *)
    670 						((SEGUSE_V1 *)segusep + 1);
    671 			}
    672 
    673 			if (dirty)
    674 				error = LFS_BWRITE_LOG(bp); /* Ifile */
    675 			else
    676 				brelse(bp);
    677 			segleft -= fs->lfs_sepb;
    678 			curseg += fs->lfs_sepb;
    679 		}
    680 	}
    681 
    682 	LOCK_ASSERT(LFS_SEGLOCK_HELD(fs));
    683 
    684 	did_ckp = 0;
    685 	if (do_ckp || fs->lfs_doifile) {
    686 		vp = fs->lfs_ivnode;
    687 		vn_lock(vp, LK_EXCLUSIVE);
    688 		do {
    689 #ifdef DEBUG
    690 			LFS_ENTER_LOG("pretend", __FILE__, __LINE__, 0, 0, curproc->p_pid);
    691 #endif
    692 			simple_lock(&fs->lfs_interlock);
    693 			fs->lfs_flags &= ~LFS_IFDIRTY;
    694 			simple_unlock(&fs->lfs_interlock);
    695 
    696 			ip = VTOI(vp);
    697 
    698 			if (LIST_FIRST(&vp->v_dirtyblkhd) != NULL) {
    699 				/*
    700 				 * Ifile has no pages, so we don't need
    701 				 * to check error return here.
    702 				 */
    703 				lfs_writefile(fs, sp, vp);
    704 				/*
    705 				 * Ensure the Ifile takes the current segment
    706 				 * into account.  See comment in lfs_vflush.
    707 				 */
    708 				lfs_writefile(fs, sp, vp);
    709 				lfs_writefile(fs, sp, vp);
    710 			}
    711 
    712 			if (ip->i_flag & IN_ALLMOD)
    713 				++did_ckp;
    714 			redo = lfs_writeinode(fs, sp, ip);
    715 			redo += lfs_writeseg(fs, sp);
    716 			simple_lock(&fs->lfs_interlock);
    717 			redo += (fs->lfs_flags & LFS_IFDIRTY);
    718 			simple_unlock(&fs->lfs_interlock);
    719 		} while (redo && do_ckp);
    720 
    721 		/*
    722 		 * Unless we are unmounting, the Ifile may continue to have
    723 		 * dirty blocks even after a checkpoint, due to changes to
    724 		 * inodes' atime.  If we're checkpointing, it's "impossible"
    725 		 * for other parts of the Ifile to be dirty after the loop
    726 		 * above, since we hold the segment lock.
    727 		 */
    728 		s = splbio();
    729 		if (LIST_EMPTY(&vp->v_dirtyblkhd)) {
    730 			LFS_CLR_UINO(ip, IN_ALLMOD);
    731 		}
    732 #ifdef DIAGNOSTIC
    733 		else if (do_ckp) {
    734 			int do_panic = 0;
    735 			LIST_FOREACH(bp, &vp->v_dirtyblkhd, b_vnbufs) {
    736 				if (bp->b_lblkno < fs->lfs_cleansz +
    737 				    fs->lfs_segtabsz &&
    738 				    !(bp->b_flags & B_GATHERED)) {
    739 					printf("ifile lbn %ld still dirty (flags %lx)\n",
    740 						(long)bp->b_lblkno,
    741 						(long)bp->b_flags);
    742 					++do_panic;
    743 				}
    744 			}
    745 			if (do_panic)
    746 				panic("dirty blocks");
    747 		}
    748 #endif
    749 		splx(s);
    750 		VOP_UNLOCK(vp, 0);
    751 	} else {
    752 		(void) lfs_writeseg(fs, sp);
    753 	}
    754 
    755 	/* Note Ifile no longer needs to be written */
    756 	fs->lfs_doifile = 0;
    757 	if (writer_set)
    758 		lfs_writer_leave(fs);
    759 
    760 	/*
    761 	 * If we didn't write the Ifile, we didn't really do anything.
    762 	 * That means that (1) there is a checkpoint on disk and (2)
    763 	 * nothing has changed since it was written.
    764 	 *
    765 	 * Take the flags off of the segment so that lfs_segunlock
    766 	 * doesn't have to write the superblock either.
    767 	 */
    768 	if (do_ckp && !did_ckp) {
    769 		sp->seg_flags &= ~SEGM_CKP;
    770 	}
    771 
    772 	if (lfs_dostats) {
    773 		++lfs_stats.nwrites;
    774 		if (sp->seg_flags & SEGM_SYNC)
    775 			++lfs_stats.nsync_writes;
    776 		if (sp->seg_flags & SEGM_CKP)
    777 			++lfs_stats.ncheckpoints;
    778 	}
    779 	lfs_segunlock(fs);
    780 	return (0);
    781 }
    782 
    783 /*
    784  * Write the dirty blocks associated with a vnode.
    785  */
    786 int
    787 lfs_writefile(struct lfs *fs, struct segment *sp, struct vnode *vp)
    788 {
    789 	struct buf *bp;
    790 	struct finfo *fip;
    791 	struct inode *ip;
    792 	IFILE *ifp;
    793 	int i, frag;
    794 	int error;
    795 
    796 	ASSERT_SEGLOCK(fs);
    797 	error = 0;
    798 	ip = VTOI(vp);
    799 
    800 	if (sp->seg_bytes_left < fs->lfs_bsize ||
    801 	    sp->sum_bytes_left < sizeof(struct finfo))
    802 		(void) lfs_writeseg(fs, sp);
    803 
    804 	sp->sum_bytes_left -= FINFOSIZE;
    805 	++((SEGSUM *)(sp->segsum))->ss_nfinfo;
    806 
    807 	if (vp->v_flag & VDIROP)
    808 		((SEGSUM *)(sp->segsum))->ss_flags |= (SS_DIROP|SS_CONT);
    809 
    810 	fip = sp->fip;
    811 	fip->fi_nblocks = 0;
    812 	fip->fi_ino = ip->i_number;
    813 	LFS_IENTRY(ifp, fs, fip->fi_ino, bp);
    814 	fip->fi_version = ifp->if_version;
    815 	brelse(bp);
    816 
    817 	if (sp->seg_flags & SEGM_CLEAN) {
    818 		lfs_gather(fs, sp, vp, lfs_match_fake);
    819 		/*
    820 		 * For a file being flushed, we need to write *all* blocks.
    821 		 * This means writing the cleaning blocks first, and then
    822 		 * immediately following with any non-cleaning blocks.
    823 		 * The same is true of the Ifile since checkpoints assume
    824 		 * that all valid Ifile blocks are written.
    825 		 */
    826 		if (IS_FLUSHING(fs,vp) || vp == fs->lfs_ivnode) {
    827 			lfs_gather(fs, sp, vp, lfs_match_data);
    828 			/*
    829 			 * Don't call VOP_PUTPAGES: if we're flushing,
    830 			 * we've already done it, and the Ifile doesn't
    831 			 * use the page cache.
    832 			 */
    833 		}
    834 	} else {
    835 		lfs_gather(fs, sp, vp, lfs_match_data);
    836 		/*
    837 		 * If we're flushing, we've already called VOP_PUTPAGES
    838 		 * so don't do it again.  Otherwise, we want to write
    839 		 * everything we've got.
    840 		 */
    841 		if (!IS_FLUSHING(fs, vp)) {
    842 			simple_lock(&vp->v_interlock);
    843 			error = VOP_PUTPAGES(vp, 0, 0,
    844 				PGO_CLEANIT | PGO_ALLPAGES | PGO_LOCKED);
    845 		}
    846 	}
    847 
    848 	/*
    849 	 * It may not be necessary to write the meta-data blocks at this point,
    850 	 * as the roll-forward recovery code should be able to reconstruct the
    851 	 * list.
    852 	 *
    853 	 * We have to write them anyway, though, under two conditions: (1) the
    854 	 * vnode is being flushed (for reuse by vinvalbuf); or (2) we are
    855 	 * checkpointing.
    856 	 *
    857 	 * BUT if we are cleaning, we might have indirect blocks that refer to
    858 	 * new blocks not being written yet, in addition to fragments being
    859 	 * moved out of a cleaned segment.  If that is the case, don't
    860 	 * write the indirect blocks, or the finfo will have a small block
    861 	 * in the middle of it!
    862 	 * XXX in this case isn't the inode size wrong too?
    863 	 */
    864 	frag = 0;
    865 	if (sp->seg_flags & SEGM_CLEAN) {
    866 		for (i = 0; i < NDADDR; i++)
    867 			if (ip->i_lfs_fragsize[i] > 0 &&
    868 			    ip->i_lfs_fragsize[i] < fs->lfs_bsize)
    869 				++frag;
    870 	}
    871 #ifdef DIAGNOSTIC
    872 	if (frag > 1)
    873 		panic("lfs_writefile: more than one fragment!");
    874 #endif
    875 	if (IS_FLUSHING(fs, vp) ||
    876 	    (frag == 0 && (lfs_writeindir || (sp->seg_flags & SEGM_CKP)))) {
    877 		lfs_gather(fs, sp, vp, lfs_match_indir);
    878 		lfs_gather(fs, sp, vp, lfs_match_dindir);
    879 		lfs_gather(fs, sp, vp, lfs_match_tindir);
    880 	}
    881 	fip = sp->fip;
    882 	if (fip->fi_nblocks != 0) {
    883 		sp->fip = (FINFO*)((caddr_t)fip + FINFOSIZE +
    884 				   sizeof(int32_t) * (fip->fi_nblocks));
    885 		sp->start_lbp = &sp->fip->fi_blocks[0];
    886 	} else {
    887 		sp->sum_bytes_left += FINFOSIZE;
    888 		--((SEGSUM *)(sp->segsum))->ss_nfinfo;
    889 	}
    890 
    891 	return error;
    892 }
    893 
    894 int
    895 lfs_writeinode(struct lfs *fs, struct segment *sp, struct inode *ip)
    896 {
    897 	struct buf *bp, *ibp;
    898 	struct ufs1_dinode *cdp;
    899 	IFILE *ifp;
    900 	SEGUSE *sup;
    901 	daddr_t daddr;
    902 	int32_t *daddrp;	/* XXX ondisk32 */
    903 	ino_t ino;
    904 	int error, i, ndx, fsb = 0;
    905 	int redo_ifile = 0;
    906 	int gotblk = 0;
    907 
    908 	ASSERT_SEGLOCK(fs);
    909 	if (!(ip->i_flag & IN_ALLMOD))
    910 		return (0);
    911 
    912 	/* Allocate a new inode block if necessary. */
    913 	if ((ip->i_number != LFS_IFILE_INUM || sp->idp == NULL) &&
    914 	    sp->ibp == NULL) {
    915 		/* Allocate a new segment if necessary. */
    916 		if (sp->seg_bytes_left < fs->lfs_ibsize ||
    917 		    sp->sum_bytes_left < sizeof(int32_t))
    918 			(void) lfs_writeseg(fs, sp);
    919 
    920 		/* Get next inode block. */
    921 		daddr = fs->lfs_offset;
    922 		fs->lfs_offset += btofsb(fs, fs->lfs_ibsize);
    923 		sp->ibp = *sp->cbpp++ =
    924 			getblk(VTOI(fs->lfs_ivnode)->i_devvp,
    925 			    fsbtodb(fs, daddr), fs->lfs_ibsize, 0, 0);
    926 		gotblk++;
    927 
    928 		/* Zero out inode numbers */
    929 		for (i = 0; i < INOPB(fs); ++i)
    930 			((struct ufs1_dinode *)sp->ibp->b_data)[i].di_inumber =
    931 			    0;
    932 
    933 		++sp->start_bpp;
    934 		fs->lfs_avail -= btofsb(fs, fs->lfs_ibsize);
    935 		/* Set remaining space counters. */
    936 		sp->seg_bytes_left -= fs->lfs_ibsize;
    937 		sp->sum_bytes_left -= sizeof(int32_t);
    938 		ndx = fs->lfs_sumsize / sizeof(int32_t) -
    939 			sp->ninodes / INOPB(fs) - 1;
    940 		((int32_t *)(sp->segsum))[ndx] = daddr;
    941 	}
    942 
    943 	/* Update the inode times and copy the inode onto the inode page. */
    944 	/* XXX kludge --- don't redirty the ifile just to put times on it */
    945 	if (ip->i_number != LFS_IFILE_INUM)
    946 		LFS_ITIMES(ip, NULL, NULL, NULL);
    947 
    948 	/*
    949 	 * If this is the Ifile, and we've already written the Ifile in this
    950 	 * partial segment, just overwrite it (it's not on disk yet) and
    951 	 * continue.
    952 	 *
    953 	 * XXX we know that the bp that we get the second time around has
    954 	 * already been gathered.
    955 	 */
    956 	if (ip->i_number == LFS_IFILE_INUM && sp->idp) {
    957 		*(sp->idp) = *ip->i_din.ffs1_din;
    958 		ip->i_lfs_osize = ip->i_size;
    959 		return 0;
    960 	}
    961 
    962 	bp = sp->ibp;
    963 	cdp = ((struct ufs1_dinode *)bp->b_data) + (sp->ninodes % INOPB(fs));
    964 	*cdp = *ip->i_din.ffs1_din;
    965 
    966 	/* We can finish the segment accounting for truncations now */
    967 	lfs_finalize_ino_seguse(fs, ip);
    968 
    969 	/*
    970 	 * If we are cleaning, ensure that we don't write UNWRITTEN disk
    971 	 * addresses to disk; possibly change the on-disk record of
    972 	 * the inode size, either by reverting to the previous size
    973 	 * (in the case of cleaning) or by verifying the inode's block
    974 	 * holdings (in the case of files being allocated as they are being
    975 	 * written).
    976 	 * XXX By not writing UNWRITTEN blocks, we are making the lfs_avail
    977 	 * XXX count on disk wrong by the same amount.	We should be
    978 	 * XXX able to "borrow" from lfs_avail and return it after the
    979 	 * XXX Ifile is written.  See also in lfs_writeseg.
    980 	 */
    981 
    982 	/* Check file size based on highest allocated block */
    983 	if (((ip->i_ffs1_mode & IFMT) == IFREG ||
    984 	     (ip->i_ffs1_mode & IFMT) == IFDIR) &&
    985 	    ip->i_size > ((ip->i_lfs_hiblk + 1) << fs->lfs_bshift)) {
    986 		cdp->di_size = (ip->i_lfs_hiblk + 1) << fs->lfs_bshift;
    987 		DLOG((DLOG_SEG, "lfs_writeinode: ino %d size %" PRId64 " -> %"
    988 		      PRId64 "\n", (int)ip->i_number, ip->i_size, cdp->di_size));
    989 	}
    990 	if (ip->i_lfs_effnblks != ip->i_ffs1_blocks) {
    991 		if (ip->i_flags & IN_CLEANING)
    992 			cdp->di_size = ip->i_lfs_osize;
    993 		DLOG((DLOG_SEG, "lfs_writeinode: cleansing ino %d eff %d != nblk %d)"
    994 		      " at %x\n", ip->i_number, ip->i_lfs_effnblks,
    995 		      ip->i_ffs1_blocks, fs->lfs_offset));
    996 		for (daddrp = cdp->di_db; daddrp < cdp->di_ib + NIADDR;
    997 		     daddrp++) {
    998 			if (*daddrp == UNWRITTEN) {
    999 				DLOG((DLOG_SEG, "lfs_writeinode: wiping UNWRITTEN\n"));
   1000 				*daddrp = 0;
   1001 			}
   1002 		}
   1003 	} else {
   1004 		/* If all blocks are going to disk, update "size on disk" */
   1005 		ip->i_lfs_osize = ip->i_size;
   1006 	}
   1007 
   1008 #ifdef DIAGNOSTIC
   1009 	/*
   1010 	 * Check dinode held blocks against dinode size.
   1011 	 * This should be identical to the check in lfs_vget().
   1012 	 */
   1013 	for (i = (cdp->di_size + fs->lfs_bsize - 1) >> fs->lfs_bshift;
   1014 	     i < NDADDR; i++) {
   1015 		KASSERT(i >= 0);
   1016 		if ((cdp->di_mode & IFMT) == IFLNK)
   1017 			continue;
   1018 		if (((cdp->di_mode & IFMT) == IFBLK ||
   1019 		     (cdp->di_mode & IFMT) == IFCHR) && i == 0)
   1020 			continue;
   1021 		if (cdp->di_db[i] != 0) {
   1022 # ifdef DEBUG
   1023 			lfs_dump_dinode(cdp);
   1024 # endif
   1025 			panic("writing inconsistent inode");
   1026 		}
   1027 	}
   1028 #endif /* DIAGNOSTIC */
   1029 
   1030 	if (ip->i_flag & IN_CLEANING)
   1031 		LFS_CLR_UINO(ip, IN_CLEANING);
   1032 	else {
   1033 		/* XXX IN_ALLMOD */
   1034 		LFS_CLR_UINO(ip, IN_ACCESSED | IN_ACCESS | IN_CHANGE |
   1035 			     IN_UPDATE | IN_MODIFY);
   1036 		if (ip->i_lfs_effnblks == ip->i_ffs1_blocks)
   1037 			LFS_CLR_UINO(ip, IN_MODIFIED);
   1038 		else
   1039 			DLOG((DLOG_VNODE, "lfs_writeinode: ino %d: real blks=%d, "
   1040 			      "eff=%d\n", ip->i_number, ip->i_ffs1_blocks,
   1041 			      ip->i_lfs_effnblks));
   1042 	}
   1043 
   1044 	if (ip->i_number == LFS_IFILE_INUM) /* We know sp->idp == NULL */
   1045 		sp->idp = ((struct ufs1_dinode *)bp->b_data) +
   1046 			(sp->ninodes % INOPB(fs));
   1047 	if (gotblk) {
   1048 		LFS_LOCK_BUF(bp);
   1049 		brelse(bp);
   1050 	}
   1051 
   1052 	/* Increment inode count in segment summary block. */
   1053 	++((SEGSUM *)(sp->segsum))->ss_ninos;
   1054 
   1055 	/* If this page is full, set flag to allocate a new page. */
   1056 	if (++sp->ninodes % INOPB(fs) == 0)
   1057 		sp->ibp = NULL;
   1058 
   1059 	/*
   1060 	 * If updating the ifile, update the super-block.  Update the disk
   1061 	 * address and access times for this inode in the ifile.
   1062 	 */
   1063 	ino = ip->i_number;
   1064 	if (ino == LFS_IFILE_INUM) {
   1065 		daddr = fs->lfs_idaddr;
   1066 		fs->lfs_idaddr = dbtofsb(fs, bp->b_blkno);
   1067 	} else {
   1068 		LFS_IENTRY(ifp, fs, ino, ibp);
   1069 		daddr = ifp->if_daddr;
   1070 		ifp->if_daddr = dbtofsb(fs, bp->b_blkno) + fsb;
   1071 		error = LFS_BWRITE_LOG(ibp); /* Ifile */
   1072 	}
   1073 
   1074 	/*
   1075 	 * The inode's last address should not be in the current partial
   1076 	 * segment, except under exceptional circumstances (lfs_writevnodes
   1077 	 * had to start over, and in the meantime more blocks were written
   1078 	 * to a vnode).	 Both inodes will be accounted to this segment
   1079 	 * in lfs_writeseg so we need to subtract the earlier version
   1080 	 * here anyway.	 The segment count can temporarily dip below
   1081 	 * zero here; keep track of how many duplicates we have in
   1082 	 * "dupino" so we don't panic below.
   1083 	 */
   1084 	if (daddr >= fs->lfs_lastpseg && daddr <= dbtofsb(fs, bp->b_blkno)) {
   1085 		++sp->ndupino;
   1086 		DLOG((DLOG_SEG, "lfs_writeinode: last inode addr in current pseg "
   1087 		      "(ino %d daddr 0x%llx) ndupino=%d\n", ino,
   1088 		      (long long)daddr, sp->ndupino));
   1089 	}
   1090 	/*
   1091 	 * Account the inode: it no longer belongs to its former segment,
   1092 	 * though it will not belong to the new segment until that segment
   1093 	 * is actually written.
   1094 	 */
   1095 	if (daddr != LFS_UNUSED_DADDR) {
   1096 		u_int32_t oldsn = dtosn(fs, daddr);
   1097 #ifdef DIAGNOSTIC
   1098 		int ndupino = (sp->seg_number == oldsn) ? sp->ndupino : 0;
   1099 #endif
   1100 		LFS_SEGENTRY(sup, fs, oldsn, bp);
   1101 #ifdef DIAGNOSTIC
   1102 		if (sup->su_nbytes +
   1103 		    sizeof (struct ufs1_dinode) * ndupino
   1104 		      < sizeof (struct ufs1_dinode)) {
   1105 			printf("lfs_writeinode: negative bytes "
   1106 			       "(segment %" PRIu32 " short by %d, "
   1107 			       "oldsn=%" PRIu32 ", cursn=%" PRIu32
   1108 			       ", daddr=%" PRId64 ", su_nbytes=%u, "
   1109 			       "ndupino=%d)\n",
   1110 			       dtosn(fs, daddr),
   1111 			       (int)sizeof (struct ufs1_dinode) *
   1112 				   (1 - sp->ndupino) - sup->su_nbytes,
   1113 			       oldsn, sp->seg_number, daddr,
   1114 			       (unsigned int)sup->su_nbytes,
   1115 			       sp->ndupino);
   1116 			panic("lfs_writeinode: negative bytes");
   1117 			sup->su_nbytes = sizeof (struct ufs1_dinode);
   1118 		}
   1119 #endif
   1120 		DLOG((DLOG_SU, "seg %d -= %d for ino %d inode\n",
   1121 		      dtosn(fs, daddr), sizeof (struct ufs1_dinode), ino));
   1122 		sup->su_nbytes -= sizeof (struct ufs1_dinode);
   1123 		redo_ifile =
   1124 			(ino == LFS_IFILE_INUM && !(bp->b_flags & B_GATHERED));
   1125 		if (redo_ifile) {
   1126 			simple_lock(&fs->lfs_interlock);
   1127 			fs->lfs_flags |= LFS_IFDIRTY;
   1128 			simple_unlock(&fs->lfs_interlock);
   1129 		}
   1130 		LFS_WRITESEGENTRY(sup, fs, oldsn, bp); /* Ifile */
   1131 	}
   1132 	return (redo_ifile);
   1133 }
   1134 
   1135 int
   1136 lfs_gatherblock(struct segment *sp, struct buf *bp, int *sptr)
   1137 {
   1138 	struct lfs *fs;
   1139 	int vers;
   1140 	int j, blksinblk;
   1141 
   1142 	ASSERT_SEGLOCK(sp->fs);
   1143 	/*
   1144 	 * If full, finish this segment.  We may be doing I/O, so
   1145 	 * release and reacquire the splbio().
   1146 	 */
   1147 #ifdef DIAGNOSTIC
   1148 	if (sp->vp == NULL)
   1149 		panic ("lfs_gatherblock: Null vp in segment");
   1150 #endif
   1151 	fs = sp->fs;
   1152 	blksinblk = howmany(bp->b_bcount, fs->lfs_bsize);
   1153 	if (sp->sum_bytes_left < sizeof(int32_t) * blksinblk ||
   1154 	    sp->seg_bytes_left < bp->b_bcount) {
   1155 		if (sptr)
   1156 			splx(*sptr);
   1157 		lfs_updatemeta(sp);
   1158 
   1159 		vers = sp->fip->fi_version;
   1160 		(void) lfs_writeseg(fs, sp);
   1161 
   1162 		sp->fip->fi_version = vers;
   1163 		sp->fip->fi_ino = VTOI(sp->vp)->i_number;
   1164 		/* Add the current file to the segment summary. */
   1165 		++((SEGSUM *)(sp->segsum))->ss_nfinfo;
   1166 		sp->sum_bytes_left -= FINFOSIZE;
   1167 
   1168 		if (sptr)
   1169 			*sptr = splbio();
   1170 		return (1);
   1171 	}
   1172 
   1173 	if (bp->b_flags & B_GATHERED) {
   1174 		DLOG((DLOG_SEG, "lfs_gatherblock: already gathered! Ino %d,"
   1175 		      " lbn %" PRId64 "\n",
   1176 		      sp->fip->fi_ino, bp->b_lblkno));
   1177 		return (0);
   1178 	}
   1179 
   1180 	/* Insert into the buffer list, update the FINFO block. */
   1181 	bp->b_flags |= B_GATHERED;
   1182 
   1183 	*sp->cbpp++ = bp;
   1184 	for (j = 0; j < blksinblk; j++) {
   1185 		sp->fip->fi_blocks[sp->fip->fi_nblocks++] = bp->b_lblkno + j;
   1186 		/* This block's accounting moves from lfs_favail to lfs_avail */
   1187 		lfs_deregister_block(sp->vp, bp->b_lblkno + j);
   1188 	}
   1189 
   1190 	sp->sum_bytes_left -= sizeof(int32_t) * blksinblk;
   1191 	sp->seg_bytes_left -= bp->b_bcount;
   1192 	return (0);
   1193 }
   1194 
   1195 int
   1196 lfs_gather(struct lfs *fs, struct segment *sp, struct vnode *vp,
   1197     int (*match)(struct lfs *, struct buf *))
   1198 {
   1199 	struct buf *bp, *nbp;
   1200 	int s, count = 0;
   1201 
   1202 	ASSERT_SEGLOCK(fs);
   1203 	if (vp->v_type == VBLK)
   1204 		return 0;
   1205 	KASSERT(sp->vp == NULL);
   1206 	sp->vp = vp;
   1207 	s = splbio();
   1208 
   1209 #ifndef LFS_NO_BACKBUF_HACK
   1210 /* This is a hack to see if ordering the blocks in LFS makes a difference. */
   1211 # define	BUF_OFFSET	\
   1212 	(((caddr_t)&LIST_NEXT(bp, b_vnbufs)) - (caddr_t)bp)
   1213 # define	BACK_BUF(BP)	\
   1214 	((struct buf *)(((caddr_t)(BP)->b_vnbufs.le_prev) - BUF_OFFSET))
   1215 # define	BEG_OF_LIST	\
   1216 	((struct buf *)(((caddr_t)&LIST_FIRST(&vp->v_dirtyblkhd)) - BUF_OFFSET))
   1217 
   1218 loop:
   1219 	/* Find last buffer. */
   1220 	for (bp = LIST_FIRST(&vp->v_dirtyblkhd);
   1221 	     bp && LIST_NEXT(bp, b_vnbufs) != NULL;
   1222 	     bp = LIST_NEXT(bp, b_vnbufs))
   1223 		/* nothing */;
   1224 	for (; bp && bp != BEG_OF_LIST; bp = nbp) {
   1225 		nbp = BACK_BUF(bp);
   1226 #else /* LFS_NO_BACKBUF_HACK */
   1227 loop:
   1228 	for (bp = LIST_FIRST(&vp->v_dirtyblkhd); bp; bp = nbp) {
   1229 		nbp = LIST_NEXT(bp, b_vnbufs);
   1230 #endif /* LFS_NO_BACKBUF_HACK */
   1231 		if ((bp->b_flags & (B_BUSY|B_GATHERED)) || !match(fs, bp)) {
   1232 #ifdef DEBUG
   1233 			if (vp == fs->lfs_ivnode &&
   1234 			    (bp->b_flags & (B_BUSY|B_GATHERED)) == B_BUSY)
   1235 				DLOG((DLOG_SEG, "lfs_gather: ifile lbn %"
   1236 				      PRId64 " busy (%x)",
   1237 				      bp->b_lblkno, bp->b_flags));
   1238 #endif
   1239 			continue;
   1240 		}
   1241 #ifdef DIAGNOSTIC
   1242 # ifdef LFS_USE_B_INVAL
   1243 		if ((bp->b_flags & (B_CALL|B_INVAL)) == B_INVAL) {
   1244 			DLOG((DLOG_SEG, "lfs_gather: lbn %" PRId64
   1245 			      " is B_INVAL\n", bp->b_lblkno));
   1246 			VOP_PRINT(bp->b_vp);
   1247 		}
   1248 # endif /* LFS_USE_B_INVAL */
   1249 		if (!(bp->b_flags & B_DELWRI))
   1250 			panic("lfs_gather: bp not B_DELWRI");
   1251 		if (!(bp->b_flags & B_LOCKED)) {
   1252 			DLOG((DLOG_SEG, "lfs_gather: lbn %" PRId64
   1253 			      " blk %" PRId64 " not B_LOCKED\n",
   1254 			      bp->b_lblkno,
   1255 			      dbtofsb(fs, bp->b_blkno)));
   1256 			VOP_PRINT(bp->b_vp);
   1257 			panic("lfs_gather: bp not B_LOCKED");
   1258 		}
   1259 #endif
   1260 		if (lfs_gatherblock(sp, bp, &s)) {
   1261 			goto loop;
   1262 		}
   1263 		count++;
   1264 	}
   1265 	splx(s);
   1266 	lfs_updatemeta(sp);
   1267 	KASSERT(sp->vp == vp);
   1268 	sp->vp = NULL;
   1269 	return count;
   1270 }
   1271 
   1272 #if DEBUG
   1273 # define DEBUG_OOFF(n) do {						\
   1274 	if (ooff == 0) {						\
   1275 		DLOG((DLOG_SEG, "lfs_updatemeta[%d]: warning: writing " \
   1276 			"ino %d lbn %" PRId64 " at 0x%" PRIx32		\
   1277 			", was 0x0 (or %" PRId64 ")\n",			\
   1278 			(n), ip->i_number, lbn, ndaddr, daddr));	\
   1279 	}								\
   1280 } while (0)
   1281 #else
   1282 # define DEBUG_OOFF(n)
   1283 #endif
   1284 
   1285 /*
   1286  * Change the given block's address to ndaddr, finding its previous
   1287  * location using ufs_bmaparray().
   1288  *
   1289  * Account for this change in the segment table.
   1290  *
   1291  * called with sp == NULL by roll-forwarding code.
   1292  */
   1293 void
   1294 lfs_update_single(struct lfs *fs, struct segment *sp, struct vnode *vp,
   1295     daddr_t lbn, int32_t ndaddr, int size)
   1296 {
   1297 	SEGUSE *sup;
   1298 	struct buf *bp;
   1299 	struct indir a[NIADDR + 2], *ap;
   1300 	struct inode *ip;
   1301 	daddr_t daddr, ooff;
   1302 	int num, error;
   1303 	int bb, osize, obb;
   1304 
   1305 	ASSERT_SEGLOCK(fs);
   1306 	KASSERT(sp == NULL || sp->vp == vp);
   1307 	ip = VTOI(vp);
   1308 
   1309 	error = ufs_bmaparray(vp, lbn, &daddr, a, &num, NULL, NULL);
   1310 	if (error)
   1311 		panic("lfs_updatemeta: ufs_bmaparray returned %d", error);
   1312 
   1313 	daddr = (daddr_t)((int32_t)daddr); /* XXX ondisk32 */
   1314 	KASSERT(daddr <= LFS_MAX_DADDR);
   1315 	if (daddr > 0)
   1316 		daddr = dbtofsb(fs, daddr);
   1317 
   1318 	bb = fragstofsb(fs, numfrags(fs, size));
   1319 	switch (num) {
   1320 	    case 0:
   1321 		    ooff = ip->i_ffs1_db[lbn];
   1322 		    DEBUG_OOFF(0);
   1323 		    if (ooff == UNWRITTEN)
   1324 			    ip->i_ffs1_blocks += bb;
   1325 		    else {
   1326 			    /* possible fragment truncation or extension */
   1327 			    obb = btofsb(fs, ip->i_lfs_fragsize[lbn]);
   1328 			    ip->i_ffs1_blocks += (bb - obb);
   1329 		    }
   1330 		    ip->i_ffs1_db[lbn] = ndaddr;
   1331 		    break;
   1332 	    case 1:
   1333 		    ooff = ip->i_ffs1_ib[a[0].in_off];
   1334 		    DEBUG_OOFF(1);
   1335 		    if (ooff == UNWRITTEN)
   1336 			    ip->i_ffs1_blocks += bb;
   1337 		    ip->i_ffs1_ib[a[0].in_off] = ndaddr;
   1338 		    break;
   1339 	    default:
   1340 		    ap = &a[num - 1];
   1341 		    if (bread(vp, ap->in_lbn, fs->lfs_bsize, NOCRED, &bp))
   1342 			    panic("lfs_updatemeta: bread bno %" PRId64,
   1343 				  ap->in_lbn);
   1344 
   1345 		    /* XXX ondisk32 */
   1346 		    ooff = ((int32_t *)bp->b_data)[ap->in_off];
   1347 		    DEBUG_OOFF(num);
   1348 		    if (ooff == UNWRITTEN)
   1349 			    ip->i_ffs1_blocks += bb;
   1350 		    /* XXX ondisk32 */
   1351 		    ((int32_t *)bp->b_data)[ap->in_off] = ndaddr;
   1352 		    (void) VOP_BWRITE(bp);
   1353 	}
   1354 
   1355 	KASSERT(ooff == 0 || ooff == UNWRITTEN || ooff == daddr);
   1356 
   1357 	/* Update hiblk when extending the file */
   1358 	if (lbn > ip->i_lfs_hiblk)
   1359 		ip->i_lfs_hiblk = lbn;
   1360 
   1361 	/*
   1362 	 * Though we'd rather it couldn't, this *can* happen right now
   1363 	 * if cleaning blocks and regular blocks coexist.
   1364 	 */
   1365 	/* KASSERT(daddr < fs->lfs_lastpseg || daddr > ndaddr); */
   1366 
   1367 	/*
   1368 	 * Update segment usage information, based on old size
   1369 	 * and location.
   1370 	 */
   1371 	if (daddr > 0) {
   1372 		u_int32_t oldsn = dtosn(fs, daddr);
   1373 #ifdef DIAGNOSTIC
   1374 		int ndupino;
   1375 
   1376 		if (sp && sp->seg_number == oldsn) {
   1377 			ndupino = sp->ndupino;
   1378 		} else {
   1379 			ndupino = 0;
   1380 		}
   1381 #endif
   1382 		KASSERT(oldsn >= 0 && oldsn < fs->lfs_nseg);
   1383 		if (lbn >= 0 && lbn < NDADDR)
   1384 			osize = ip->i_lfs_fragsize[lbn];
   1385 		else
   1386 			osize = fs->lfs_bsize;
   1387 		LFS_SEGENTRY(sup, fs, oldsn, bp);
   1388 #ifdef DIAGNOSTIC
   1389 		if (sup->su_nbytes + sizeof (struct ufs1_dinode) * ndupino
   1390 		    < osize) {
   1391 			printf("lfs_updatemeta: negative bytes "
   1392 			       "(segment %" PRIu32 " short by %" PRId64
   1393 			       ")\n", dtosn(fs, daddr),
   1394 			       (int64_t)osize -
   1395 			       (sizeof (struct ufs1_dinode) * ndupino +
   1396 				sup->su_nbytes));
   1397 			printf("lfs_updatemeta: ino %llu, lbn %" PRId64
   1398 			       ", addr = 0x%" PRIx64 "\n",
   1399 			       (unsigned long long)ip->i_number, lbn, daddr);
   1400 			printf("lfs_updatemeta: ndupino=%d\n", ndupino);
   1401 			panic("lfs_updatemeta: negative bytes");
   1402 			sup->su_nbytes = osize -
   1403 			    sizeof (struct ufs1_dinode) * ndupino;
   1404 		}
   1405 #endif
   1406 		DLOG((DLOG_SU, "seg %" PRIu32 " -= %d for ino %d lbn %" PRId64
   1407 		      " db 0x%" PRIx64 "\n",
   1408 		      dtosn(fs, daddr), osize,
   1409 		      ip->i_number, lbn, daddr));
   1410 		sup->su_nbytes -= osize;
   1411 		if (!(bp->b_flags & B_GATHERED)) {
   1412 			simple_lock(&fs->lfs_interlock);
   1413 			fs->lfs_flags |= LFS_IFDIRTY;
   1414 			simple_unlock(&fs->lfs_interlock);
   1415 		}
   1416 		LFS_WRITESEGENTRY(sup, fs, oldsn, bp);
   1417 	}
   1418 	/*
   1419 	 * Now that this block has a new address, and its old
   1420 	 * segment no longer owns it, we can forget about its
   1421 	 * old size.
   1422 	 */
   1423 	if (lbn >= 0 && lbn < NDADDR)
   1424 		ip->i_lfs_fragsize[lbn] = size;
   1425 }
   1426 
   1427 /*
   1428  * Update the metadata that points to the blocks listed in the FINFO
   1429  * array.
   1430  */
   1431 void
   1432 lfs_updatemeta(struct segment *sp)
   1433 {
   1434 	struct buf *sbp;
   1435 	struct lfs *fs;
   1436 	struct vnode *vp;
   1437 	daddr_t lbn;
   1438 	int i, nblocks, num;
   1439 	int bb;
   1440 	int bytesleft, size;
   1441 
   1442 	ASSERT_SEGLOCK(sp->fs);
   1443 	vp = sp->vp;
   1444 	nblocks = &sp->fip->fi_blocks[sp->fip->fi_nblocks] - sp->start_lbp;
   1445 	KASSERT(nblocks >= 0);
   1446 	KASSERT(vp != NULL);
   1447 	if (nblocks == 0)
   1448 		return;
   1449 
   1450 	/*
   1451 	 * This count may be high due to oversize blocks from lfs_gop_write.
   1452 	 * Correct for this. (XXX we should be able to keep track of these.)
   1453 	 */
   1454 	fs = sp->fs;
   1455 	for (i = 0; i < nblocks; i++) {
   1456 		if (sp->start_bpp[i] == NULL) {
   1457 			DLOG((DLOG_SEG, "lfs_updatemeta: nblocks = %d, not %d\n", i, nblocks));
   1458 			nblocks = i;
   1459 			break;
   1460 		}
   1461 		num = howmany(sp->start_bpp[i]->b_bcount, fs->lfs_bsize);
   1462 		KASSERT(sp->start_bpp[i]->b_lblkno >= 0 || num == 1);
   1463 		nblocks -= num - 1;
   1464 	}
   1465 
   1466 	KASSERT(vp->v_type == VREG ||
   1467 	   nblocks == &sp->fip->fi_blocks[sp->fip->fi_nblocks] - sp->start_lbp);
   1468 	KASSERT(nblocks == sp->cbpp - sp->start_bpp);
   1469 
   1470 	/*
   1471 	 * Sort the blocks.
   1472 	 *
   1473 	 * We have to sort even if the blocks come from the
   1474 	 * cleaner, because there might be other pending blocks on the
   1475 	 * same inode...and if we don't sort, and there are fragments
   1476 	 * present, blocks may be written in the wrong place.
   1477 	 */
   1478 	lfs_shellsort(sp->start_bpp, sp->start_lbp, nblocks, fs->lfs_bsize);
   1479 
   1480 	/*
   1481 	 * Record the length of the last block in case it's a fragment.
   1482 	 * If there are indirect blocks present, they sort last.  An
   1483 	 * indirect block will be lfs_bsize and its presence indicates
   1484 	 * that you cannot have fragments.
   1485 	 *
   1486 	 * XXX This last is a lie.  A cleaned fragment can coexist with
   1487 	 * XXX a later indirect block.	This will continue to be
   1488 	 * XXX true until lfs_markv is fixed to do everything with
   1489 	 * XXX fake blocks (including fake inodes and fake indirect blocks).
   1490 	 */
   1491 	sp->fip->fi_lastlength = ((sp->start_bpp[nblocks - 1]->b_bcount - 1) &
   1492 		fs->lfs_bmask) + 1;
   1493 
   1494 	/*
   1495 	 * Assign disk addresses, and update references to the logical
   1496 	 * block and the segment usage information.
   1497 	 */
   1498 	for (i = nblocks; i--; ++sp->start_bpp) {
   1499 		sbp = *sp->start_bpp;
   1500 		lbn = *sp->start_lbp;
   1501 		KASSERT(sbp->b_lblkno == lbn);
   1502 
   1503 		sbp->b_blkno = fsbtodb(fs, fs->lfs_offset);
   1504 
   1505 		/*
   1506 		 * If we write a frag in the wrong place, the cleaner won't
   1507 		 * be able to correctly identify its size later, and the
   1508 		 * segment will be uncleanable.	 (Even worse, it will assume
   1509 		 * that the indirect block that actually ends the list
   1510 		 * is of a smaller size!)
   1511 		 */
   1512 		if ((sbp->b_bcount & fs->lfs_bmask) && i != 0)
   1513 			panic("lfs_updatemeta: fragment is not last block");
   1514 
   1515 		/*
   1516 		 * For each subblock in this possibly oversized block,
   1517 		 * update its address on disk.
   1518 		 */
   1519 		KASSERT(lbn >= 0 || sbp->b_bcount == fs->lfs_bsize);
   1520 		KASSERT(vp == sbp->b_vp);
   1521 		for (bytesleft = sbp->b_bcount; bytesleft > 0;
   1522 		     bytesleft -= fs->lfs_bsize) {
   1523 			size = MIN(bytesleft, fs->lfs_bsize);
   1524 			bb = fragstofsb(fs, numfrags(fs, size));
   1525 			lbn = *sp->start_lbp++;
   1526 			lfs_update_single(fs, sp, sp->vp, lbn, fs->lfs_offset,
   1527 			    size);
   1528 			fs->lfs_offset += bb;
   1529 		}
   1530 
   1531 	}
   1532 }
   1533 
   1534 /*
   1535  * Move lfs_offset to a segment earlier than sn.
   1536  */
   1537 int
   1538 lfs_rewind(struct lfs *fs, int newsn)
   1539 {
   1540 	int sn, osn, isdirty;
   1541 	struct buf *bp;
   1542 	SEGUSE *sup;
   1543 
   1544 	ASSERT_SEGLOCK(fs);
   1545 
   1546 	osn = dtosn(fs, fs->lfs_offset);
   1547 	if (osn < newsn)
   1548 		return 0;
   1549 
   1550 	/* lfs_avail eats the remaining space in this segment */
   1551 	fs->lfs_avail -= fs->lfs_fsbpseg - (fs->lfs_offset - fs->lfs_curseg);
   1552 
   1553 	/* Find a low-numbered segment */
   1554 	for (sn = 0; sn < fs->lfs_nseg; ++sn) {
   1555 		LFS_SEGENTRY(sup, fs, sn, bp);
   1556 		isdirty = sup->su_flags & SEGUSE_DIRTY;
   1557 		brelse(bp);
   1558 
   1559 		if (!isdirty)
   1560 			break;
   1561 	}
   1562 	if (sn == fs->lfs_nseg)
   1563 		panic("lfs_rewind: no clean segments");
   1564 	if (sn >= newsn)
   1565 		return ENOENT;
   1566 	fs->lfs_nextseg = sn;
   1567 	lfs_newseg(fs);
   1568 	fs->lfs_offset = fs->lfs_curseg;
   1569 
   1570 	return 0;
   1571 }
   1572 
   1573 /*
   1574  * Start a new partial segment.
   1575  *
   1576  * Return 1 when we entered to a new segment.
   1577  * Otherwise, return 0.
   1578  */
   1579 int
   1580 lfs_initseg(struct lfs *fs)
   1581 {
   1582 	struct segment *sp = fs->lfs_sp;
   1583 	SEGSUM *ssp;
   1584 	struct buf *sbp;	/* buffer for SEGSUM */
   1585 	int repeat = 0;		/* return value */
   1586 
   1587 	ASSERT_SEGLOCK(fs);
   1588 	/* Advance to the next segment. */
   1589 	if (!LFS_PARTIAL_FITS(fs)) {
   1590 		SEGUSE *sup;
   1591 		struct buf *bp;
   1592 
   1593 		/* lfs_avail eats the remaining space */
   1594 		fs->lfs_avail -= fs->lfs_fsbpseg - (fs->lfs_offset -
   1595 						   fs->lfs_curseg);
   1596 		/* Wake up any cleaning procs waiting on this file system. */
   1597 		wakeup(&lfs_allclean_wakeup);
   1598 		wakeup(&fs->lfs_nextseg);
   1599 		lfs_newseg(fs);
   1600 		repeat = 1;
   1601 		fs->lfs_offset = fs->lfs_curseg;
   1602 
   1603 		sp->seg_number = dtosn(fs, fs->lfs_curseg);
   1604 		sp->seg_bytes_left = fsbtob(fs, fs->lfs_fsbpseg);
   1605 
   1606 		/*
   1607 		 * If the segment contains a superblock, update the offset
   1608 		 * and summary address to skip over it.
   1609 		 */
   1610 		LFS_SEGENTRY(sup, fs, sp->seg_number, bp);
   1611 		if (sup->su_flags & SEGUSE_SUPERBLOCK) {
   1612 			fs->lfs_offset += btofsb(fs, LFS_SBPAD);
   1613 			sp->seg_bytes_left -= LFS_SBPAD;
   1614 		}
   1615 		brelse(bp);
   1616 		/* Segment zero could also contain the labelpad */
   1617 		if (fs->lfs_version > 1 && sp->seg_number == 0 &&
   1618 		    fs->lfs_start < btofsb(fs, LFS_LABELPAD)) {
   1619 			fs->lfs_offset +=
   1620 			    btofsb(fs, LFS_LABELPAD) - fs->lfs_start;
   1621 			sp->seg_bytes_left -=
   1622 			    LFS_LABELPAD - fsbtob(fs, fs->lfs_start);
   1623 		}
   1624 	} else {
   1625 		sp->seg_number = dtosn(fs, fs->lfs_curseg);
   1626 		sp->seg_bytes_left = fsbtob(fs, fs->lfs_fsbpseg -
   1627 				      (fs->lfs_offset - fs->lfs_curseg));
   1628 	}
   1629 	fs->lfs_lastpseg = fs->lfs_offset;
   1630 
   1631 	/* Record first address of this partial segment */
   1632 	if (sp->seg_flags & SEGM_CLEAN) {
   1633 		fs->lfs_cleanint[fs->lfs_cleanind] = fs->lfs_offset;
   1634 		if (++fs->lfs_cleanind >= LFS_MAX_CLEANIND) {
   1635 			/* "1" is the artificial inc in lfs_seglock */
   1636 			simple_lock(&fs->lfs_interlock);
   1637 			while (fs->lfs_iocount > 1) {
   1638 				ltsleep(&fs->lfs_iocount, PRIBIO + 1,
   1639 				    "lfs_initseg", 0, &fs->lfs_interlock);
   1640 			}
   1641 			simple_unlock(&fs->lfs_interlock);
   1642 			fs->lfs_cleanind = 0;
   1643 		}
   1644 	}
   1645 
   1646 	sp->fs = fs;
   1647 	sp->ibp = NULL;
   1648 	sp->idp = NULL;
   1649 	sp->ninodes = 0;
   1650 	sp->ndupino = 0;
   1651 
   1652 	sp->cbpp = sp->bpp;
   1653 
   1654 	/* Get a new buffer for SEGSUM */
   1655 	sbp = lfs_newbuf(fs, VTOI(fs->lfs_ivnode)->i_devvp,
   1656 	    fsbtodb(fs, fs->lfs_offset), fs->lfs_sumsize, LFS_NB_SUMMARY);
   1657 
   1658 	/* ... and enter it into the buffer list. */
   1659 	*sp->cbpp = sbp;
   1660 	sp->cbpp++;
   1661 	fs->lfs_offset += btofsb(fs, fs->lfs_sumsize);
   1662 
   1663 	sp->start_bpp = sp->cbpp;
   1664 
   1665 	/* Set point to SEGSUM, initialize it. */
   1666 	ssp = sp->segsum = sbp->b_data;
   1667 	memset(ssp, 0, fs->lfs_sumsize);
   1668 	ssp->ss_next = fs->lfs_nextseg;
   1669 	ssp->ss_nfinfo = ssp->ss_ninos = 0;
   1670 	ssp->ss_magic = SS_MAGIC;
   1671 
   1672 	/* Set pointer to first FINFO, initialize it. */
   1673 	sp->fip = (struct finfo *)((caddr_t)sp->segsum + SEGSUM_SIZE(fs));
   1674 	sp->fip->fi_nblocks = 0;
   1675 	sp->start_lbp = &sp->fip->fi_blocks[0];
   1676 	sp->fip->fi_lastlength = 0;
   1677 
   1678 	sp->seg_bytes_left -= fs->lfs_sumsize;
   1679 	sp->sum_bytes_left = fs->lfs_sumsize - SEGSUM_SIZE(fs);
   1680 
   1681 	return (repeat);
   1682 }
   1683 
   1684 /*
   1685  * Remove SEGUSE_INVAL from all segments.
   1686  */
   1687 void
   1688 lfs_unset_inval_all(struct lfs *fs)
   1689 {
   1690 	SEGUSE *sup;
   1691 	struct buf *bp;
   1692 	int i;
   1693 
   1694 	for (i = 0; i < fs->lfs_nseg; i++) {
   1695 		LFS_SEGENTRY(sup, fs, i, bp);
   1696 		if (sup->su_flags & SEGUSE_INVAL) {
   1697 			sup->su_flags &= ~SEGUSE_INVAL;
   1698 			VOP_BWRITE(bp);
   1699 		} else
   1700 			brelse(bp);
   1701 	}
   1702 }
   1703 
   1704 /*
   1705  * Return the next segment to write.
   1706  */
   1707 void
   1708 lfs_newseg(struct lfs *fs)
   1709 {
   1710 	CLEANERINFO *cip;
   1711 	SEGUSE *sup;
   1712 	struct buf *bp;
   1713 	int curseg, isdirty, sn, skip_inval;
   1714 
   1715 	ASSERT_SEGLOCK(fs);
   1716 
   1717 	/* Honor LFCNWRAPSTOP */
   1718 	simple_lock(&fs->lfs_interlock);
   1719 	if (fs->lfs_nowrap && fs->lfs_nextseg < fs->lfs_curseg) {
   1720 		wakeup(&fs->lfs_nowrap);
   1721 		ltsleep(&fs->lfs_nowrap, PVFS, "newseg", 0,
   1722 			&fs->lfs_interlock);
   1723 	}
   1724 	simple_unlock(&fs->lfs_interlock);
   1725 
   1726 	LFS_SEGENTRY(sup, fs, dtosn(fs, fs->lfs_nextseg), bp);
   1727 	DLOG((DLOG_SU, "lfs_newseg: seg %d := 0 in newseg\n",
   1728 	      dtosn(fs, fs->lfs_nextseg)));
   1729 	sup->su_flags |= SEGUSE_DIRTY | SEGUSE_ACTIVE;
   1730 	sup->su_nbytes = 0;
   1731 	sup->su_nsums = 0;
   1732 	sup->su_ninos = 0;
   1733 	LFS_WRITESEGENTRY(sup, fs, dtosn(fs, fs->lfs_nextseg), bp);
   1734 
   1735 	LFS_CLEANERINFO(cip, fs, bp);
   1736 	--cip->clean;
   1737 	++cip->dirty;
   1738 	fs->lfs_nclean = cip->clean;
   1739 	LFS_SYNC_CLEANERINFO(cip, fs, bp, 1);
   1740 
   1741 	fs->lfs_lastseg = fs->lfs_curseg;
   1742 	fs->lfs_curseg = fs->lfs_nextseg;
   1743 	skip_inval = 1;
   1744 	for (sn = curseg = dtosn(fs, fs->lfs_curseg) + fs->lfs_interleave;;) {
   1745 		sn = (sn + 1) % fs->lfs_nseg;
   1746 
   1747 		if (sn == curseg) {
   1748 			if (skip_inval)
   1749 				skip_inval = 0;
   1750 			else
   1751 				panic("lfs_nextseg: no clean segments");
   1752 		}
   1753 		LFS_SEGENTRY(sup, fs, sn, bp);
   1754 		isdirty = sup->su_flags & (SEGUSE_DIRTY | (skip_inval ? SEGUSE_INVAL : 0));
   1755 		/* Check SEGUSE_EMPTY as we go along */
   1756 		if (isdirty && sup->su_nbytes == 0 &&
   1757 		    !(sup->su_flags & SEGUSE_EMPTY))
   1758 			LFS_WRITESEGENTRY(sup, fs, sn, bp);
   1759 		else
   1760 			brelse(bp);
   1761 
   1762 		if (!isdirty)
   1763 			break;
   1764 	}
   1765 	if (skip_inval == 0)
   1766 		lfs_unset_inval_all(fs);
   1767 
   1768 	++fs->lfs_nactive;
   1769 	fs->lfs_nextseg = sntod(fs, sn);
   1770 	if (lfs_dostats) {
   1771 		++lfs_stats.segsused;
   1772 	}
   1773 }
   1774 
   1775 static struct buf *
   1776 lfs_newclusterbuf(struct lfs *fs, struct vnode *vp, daddr_t addr, int n)
   1777 {
   1778 	struct lfs_cluster *cl;
   1779 	struct buf **bpp, *bp;
   1780 
   1781 	ASSERT_SEGLOCK(fs);
   1782 	cl = (struct lfs_cluster *)pool_get(&fs->lfs_clpool, PR_WAITOK);
   1783 	bpp = (struct buf **)pool_get(&fs->lfs_bpppool, PR_WAITOK);
   1784 	memset(cl, 0, sizeof(*cl));
   1785 	cl->fs = fs;
   1786 	cl->bpp = bpp;
   1787 	cl->bufcount = 0;
   1788 	cl->bufsize = 0;
   1789 
   1790 	/* If this segment is being written synchronously, note that */
   1791 	if (fs->lfs_sp->seg_flags & SEGM_SYNC) {
   1792 		cl->flags |= LFS_CL_SYNC;
   1793 		cl->seg = fs->lfs_sp;
   1794 		++cl->seg->seg_iocount;
   1795 	}
   1796 
   1797 	/* Get an empty buffer header, or maybe one with something on it */
   1798 	bp = getiobuf();
   1799 	bp->b_flags = B_BUSY | B_CALL;
   1800 	bp->b_dev = NODEV;
   1801 	bp->b_blkno = bp->b_lblkno = addr;
   1802 	bp->b_iodone = lfs_cluster_callback;
   1803 	bp->b_private = cl;
   1804 	bp->b_vp = vp;
   1805 
   1806 	return bp;
   1807 }
   1808 
   1809 int
   1810 lfs_writeseg(struct lfs *fs, struct segment *sp)
   1811 {
   1812 	struct buf **bpp, *bp, *cbp, *newbp;
   1813 	SEGUSE *sup;
   1814 	SEGSUM *ssp;
   1815 	int i, s;
   1816 	int do_again, nblocks, byteoffset;
   1817 	size_t el_size;
   1818 	struct lfs_cluster *cl;
   1819 	u_short ninos;
   1820 	struct vnode *devvp;
   1821 	char *p = NULL;
   1822 	struct vnode *vp;
   1823 	int32_t *daddrp;	/* XXX ondisk32 */
   1824 	int changed;
   1825 	u_int32_t sum;
   1826 
   1827 	ASSERT_SEGLOCK(fs);
   1828 	/*
   1829 	 * If there are no buffers other than the segment summary to write
   1830 	 * and it is not a checkpoint, don't do anything.  On a checkpoint,
   1831 	 * even if there aren't any buffers, you need to write the superblock.
   1832 	 */
   1833 	if ((nblocks = sp->cbpp - sp->bpp) == 1)
   1834 		return (0);
   1835 
   1836 	devvp = VTOI(fs->lfs_ivnode)->i_devvp;
   1837 
   1838 	/* Update the segment usage information. */
   1839 	LFS_SEGENTRY(sup, fs, sp->seg_number, bp);
   1840 
   1841 	/* Loop through all blocks, except the segment summary. */
   1842 	for (bpp = sp->bpp; ++bpp < sp->cbpp; ) {
   1843 		if ((*bpp)->b_vp != devvp) {
   1844 			sup->su_nbytes += (*bpp)->b_bcount;
   1845 			DLOG((DLOG_SU, "seg %" PRIu32 " += %ld for ino %d"
   1846 			      " lbn %" PRId64 " db 0x%" PRIx64 "\n",
   1847 			      sp->seg_number, (*bpp)->b_bcount,
   1848 			      VTOI((*bpp)->b_vp)->i_number, (*bpp)->b_lblkno,
   1849 			      (*bpp)->b_blkno));
   1850 		}
   1851 	}
   1852 
   1853 	ssp = (SEGSUM *)sp->segsum;
   1854 
   1855 	ninos = (ssp->ss_ninos + INOPB(fs) - 1) / INOPB(fs);
   1856 	DLOG((DLOG_SU, "seg %d += %d for %d inodes\n",
   1857 	      sp->seg_number, ssp->ss_ninos * sizeof (struct ufs1_dinode),
   1858 	      ssp->ss_ninos));
   1859 	sup->su_nbytes += ssp->ss_ninos * sizeof (struct ufs1_dinode);
   1860 	/* sup->su_nbytes += fs->lfs_sumsize; */
   1861 	if (fs->lfs_version == 1)
   1862 		sup->su_olastmod = time.tv_sec;
   1863 	else
   1864 		sup->su_lastmod = time.tv_sec;
   1865 	sup->su_ninos += ninos;
   1866 	++sup->su_nsums;
   1867 	fs->lfs_avail -= btofsb(fs, fs->lfs_sumsize);
   1868 
   1869 	do_again = !(bp->b_flags & B_GATHERED);
   1870 	LFS_WRITESEGENTRY(sup, fs, sp->seg_number, bp); /* Ifile */
   1871 
   1872 	/*
   1873 	 * Mark blocks B_BUSY, to prevent then from being changed between
   1874 	 * the checksum computation and the actual write.
   1875 	 *
   1876 	 * If we are cleaning, check indirect blocks for UNWRITTEN, and if
   1877 	 * there are any, replace them with copies that have UNASSIGNED
   1878 	 * instead.
   1879 	 */
   1880 	for (bpp = sp->bpp, i = nblocks - 1; i--;) {
   1881 		++bpp;
   1882 		bp = *bpp;
   1883 		if (bp->b_flags & B_CALL) { /* UBC or malloced buffer */
   1884 			bp->b_flags |= B_BUSY;
   1885 			continue;
   1886 		}
   1887 
   1888 		simple_lock(&bp->b_interlock);
   1889 		s = splbio();
   1890 		while (bp->b_flags & B_BUSY) {
   1891 			DLOG((DLOG_SEG, "lfs_writeseg: avoiding potential"
   1892 			      " data summary corruption for ino %d, lbn %"
   1893 			      PRId64 "\n",
   1894 			      VTOI(bp->b_vp)->i_number, bp->b_lblkno));
   1895 			bp->b_flags |= B_WANTED;
   1896 			ltsleep(bp, (PRIBIO + 1), "lfs_writeseg", 0,
   1897 				&bp->b_interlock);
   1898 			splx(s);
   1899 			s = splbio();
   1900 		}
   1901 		bp->b_flags |= B_BUSY;
   1902 		splx(s);
   1903 		simple_unlock(&bp->b_interlock);
   1904 
   1905 		/*
   1906 		 * Check and replace indirect block UNWRITTEN bogosity.
   1907 		 * XXX See comment in lfs_writefile.
   1908 		 */
   1909 		if (bp->b_lblkno < 0 && bp->b_vp != devvp && bp->b_vp &&
   1910 		   VTOI(bp->b_vp)->i_ffs1_blocks !=
   1911 		   VTOI(bp->b_vp)->i_lfs_effnblks) {
   1912 			DLOG((DLOG_VNODE, "lfs_writeseg: cleansing ino %d (%d != %d)\n",
   1913 			      VTOI(bp->b_vp)->i_number,
   1914 			      VTOI(bp->b_vp)->i_lfs_effnblks,
   1915 			      VTOI(bp->b_vp)->i_ffs1_blocks));
   1916 			/* Make a copy we'll make changes to */
   1917 			newbp = lfs_newbuf(fs, bp->b_vp, bp->b_lblkno,
   1918 					   bp->b_bcount, LFS_NB_IBLOCK);
   1919 			newbp->b_blkno = bp->b_blkno;
   1920 			memcpy(newbp->b_data, bp->b_data,
   1921 			       newbp->b_bcount);
   1922 
   1923 			changed = 0;
   1924 			/* XXX ondisk32 */
   1925 			for (daddrp = (int32_t *)(newbp->b_data);
   1926 			     daddrp < (int32_t *)(newbp->b_data +
   1927 						  newbp->b_bcount); daddrp++) {
   1928 				if (*daddrp == UNWRITTEN) {
   1929 					++changed;
   1930 					*daddrp = 0;
   1931 				}
   1932 			}
   1933 			/*
   1934 			 * Get rid of the old buffer.  Don't mark it clean,
   1935 			 * though, if it still has dirty data on it.
   1936 			 */
   1937 			if (changed) {
   1938 				DLOG((DLOG_SEG, "lfs_writeseg: replacing UNWRITTEN(%d):"
   1939 				      " bp = %p newbp = %p\n", changed, bp,
   1940 				      newbp));
   1941 				*bpp = newbp;
   1942 				bp->b_flags &= ~(B_ERROR | B_GATHERED);
   1943 				if (bp->b_flags & B_CALL) {
   1944 					DLOG((DLOG_SEG, "lfs_writeseg: "
   1945 					      "indir bp should not be B_CALL\n"));
   1946 					s = splbio();
   1947 					biodone(bp);
   1948 					splx(s);
   1949 					bp = NULL;
   1950 				} else {
   1951 					/* Still on free list, leave it there */
   1952 					s = splbio();
   1953 					bp->b_flags &= ~B_BUSY;
   1954 					if (bp->b_flags & B_WANTED)
   1955 						wakeup(bp);
   1956 					splx(s);
   1957 					/*
   1958 					 * We have to re-decrement lfs_avail
   1959 					 * since this block is going to come
   1960 					 * back around to us in the next
   1961 					 * segment.
   1962 					 */
   1963 					fs->lfs_avail -=
   1964 					    btofsb(fs, bp->b_bcount);
   1965 				}
   1966 			} else {
   1967 				lfs_freebuf(fs, newbp);
   1968 			}
   1969 		}
   1970 	}
   1971 	/*
   1972 	 * Compute checksum across data and then across summary; the first
   1973 	 * block (the summary block) is skipped.  Set the create time here
   1974 	 * so that it's guaranteed to be later than the inode mod times.
   1975 	 */
   1976 	sum = 0;
   1977 	if (fs->lfs_version == 1)
   1978 		el_size = sizeof(u_long);
   1979 	else
   1980 		el_size = sizeof(u_int32_t);
   1981 	for (bpp = sp->bpp, i = nblocks - 1; i--; ) {
   1982 		++bpp;
   1983 		/* Loop through gop_write cluster blocks */
   1984 		for (byteoffset = 0; byteoffset < (*bpp)->b_bcount;
   1985 		     byteoffset += fs->lfs_bsize) {
   1986 #ifdef LFS_USE_B_INVAL
   1987 			if (((*bpp)->b_flags & (B_CALL | B_INVAL)) ==
   1988 			    (B_CALL | B_INVAL)) {
   1989 				if (copyin((caddr_t)(*bpp)->b_saveaddr +
   1990 					   byteoffset, dp, el_size)) {
   1991 					panic("lfs_writeseg: copyin failed [1]:"
   1992 						" ino %d blk %" PRId64,
   1993 						VTOI((*bpp)->b_vp)->i_number,
   1994 						(*bpp)->b_lblkno);
   1995 				}
   1996 			} else
   1997 #endif /* LFS_USE_B_INVAL */
   1998 			{
   1999 				sum = lfs_cksum_part(
   2000 				    (*bpp)->b_data + byteoffset, el_size, sum);
   2001 			}
   2002 		}
   2003 	}
   2004 	if (fs->lfs_version == 1)
   2005 		ssp->ss_ocreate = time.tv_sec;
   2006 	else {
   2007 		ssp->ss_create = time.tv_sec;
   2008 		ssp->ss_serial = ++fs->lfs_serial;
   2009 		ssp->ss_ident  = fs->lfs_ident;
   2010 	}
   2011 	ssp->ss_datasum = lfs_cksum_fold(sum);
   2012 	ssp->ss_sumsum = cksum(&ssp->ss_datasum,
   2013 	    fs->lfs_sumsize - sizeof(ssp->ss_sumsum));
   2014 
   2015 	simple_lock(&fs->lfs_interlock);
   2016 	fs->lfs_bfree -= (btofsb(fs, ninos * fs->lfs_ibsize) +
   2017 			  btofsb(fs, fs->lfs_sumsize));
   2018 	fs->lfs_dmeta += (btofsb(fs, ninos * fs->lfs_ibsize) +
   2019 			  btofsb(fs, fs->lfs_sumsize));
   2020 	simple_unlock(&fs->lfs_interlock);
   2021 
   2022 	/*
   2023 	 * When we simply write the blocks we lose a rotation for every block
   2024 	 * written.  To avoid this problem, we cluster the buffers into a
   2025 	 * chunk and write the chunk.  MAXPHYS is the largest size I/O
   2026 	 * devices can handle, use that for the size of the chunks.
   2027 	 *
   2028 	 * Blocks that are already clusters (from GOP_WRITE), however, we
   2029 	 * don't bother to copy into other clusters.
   2030 	 */
   2031 
   2032 #define CHUNKSIZE MAXPHYS
   2033 
   2034 	if (devvp == NULL)
   2035 		panic("devvp is NULL");
   2036 	for (bpp = sp->bpp, i = nblocks; i;) {
   2037 		cbp = lfs_newclusterbuf(fs, devvp, (*bpp)->b_blkno, i);
   2038 		cl = cbp->b_private;
   2039 
   2040 		cbp->b_flags |= B_ASYNC | B_BUSY;
   2041 		cbp->b_bcount = 0;
   2042 
   2043 #if defined(DEBUG) && defined(DIAGNOSTIC)
   2044 		if (bpp - sp->bpp > (fs->lfs_sumsize - SEGSUM_SIZE(fs))
   2045 		    / sizeof(int32_t)) {
   2046 			panic("lfs_writeseg: real bpp overwrite");
   2047 		}
   2048 		if (bpp - sp->bpp > segsize(fs) / fs->lfs_fsize) {
   2049 			panic("lfs_writeseg: theoretical bpp overwrite");
   2050 		}
   2051 #endif
   2052 
   2053 		/*
   2054 		 * Construct the cluster.
   2055 		 */
   2056 		simple_lock(&fs->lfs_interlock);
   2057 		++fs->lfs_iocount;
   2058 		simple_unlock(&fs->lfs_interlock);
   2059 		while (i && cbp->b_bcount < CHUNKSIZE) {
   2060 			bp = *bpp;
   2061 
   2062 			if (bp->b_bcount > (CHUNKSIZE - cbp->b_bcount))
   2063 				break;
   2064 			if (cbp->b_bcount > 0 && !(cl->flags & LFS_CL_MALLOC))
   2065 				break;
   2066 
   2067 			/* Clusters from GOP_WRITE are expedited */
   2068 			if (bp->b_bcount > fs->lfs_bsize) {
   2069 				if (cbp->b_bcount > 0)
   2070 					/* Put in its own buffer */
   2071 					break;
   2072 				else {
   2073 					cbp->b_data = bp->b_data;
   2074 				}
   2075 			} else if (cbp->b_bcount == 0) {
   2076 				p = cbp->b_data = lfs_malloc(fs, CHUNKSIZE,
   2077 							     LFS_NB_CLUSTER);
   2078 				cl->flags |= LFS_CL_MALLOC;
   2079 			}
   2080 #ifdef DIAGNOSTIC
   2081 			if (dtosn(fs, dbtofsb(fs, bp->b_blkno +
   2082 					      btodb(bp->b_bcount - 1))) !=
   2083 			    sp->seg_number) {
   2084 				printf("blk size %d daddr %" PRIx64
   2085 				    " not in seg %d\n",
   2086 				    bp->b_bcount, bp->b_blkno,
   2087 				    sp->seg_number);
   2088 				panic("segment overwrite");
   2089 			}
   2090 #endif
   2091 
   2092 #ifdef LFS_USE_B_INVAL
   2093 			/*
   2094 			 * Fake buffers from the cleaner are marked as B_INVAL.
   2095 			 * We need to copy the data from user space rather than
   2096 			 * from the buffer indicated.
   2097 			 * XXX == what do I do on an error?
   2098 			 */
   2099 			if ((bp->b_flags & (B_CALL|B_INVAL)) ==
   2100 			    (B_CALL|B_INVAL)) {
   2101 				if (copyin(bp->b_saveaddr, p, bp->b_bcount))
   2102 					panic("lfs_writeseg: "
   2103 					    "copyin failed [2]");
   2104 			} else
   2105 #endif /* LFS_USE_B_INVAL */
   2106 			if (cl->flags & LFS_CL_MALLOC) {
   2107 				/* copy data into our cluster. */
   2108 				memcpy(p, bp->b_data, bp->b_bcount);
   2109 				p += bp->b_bcount;
   2110 			}
   2111 
   2112 			cbp->b_bcount += bp->b_bcount;
   2113 			cl->bufsize += bp->b_bcount;
   2114 
   2115 			bp->b_flags &= ~(B_ERROR | B_READ | B_DELWRI | B_DONE);
   2116 			cl->bpp[cl->bufcount++] = bp;
   2117 			vp = bp->b_vp;
   2118 			s = splbio();
   2119 			reassignbuf(bp, vp);
   2120 			V_INCR_NUMOUTPUT(vp);
   2121 			splx(s);
   2122 
   2123 			bpp++;
   2124 			i--;
   2125 		}
   2126 		if (fs->lfs_sp->seg_flags & SEGM_SYNC)
   2127 			BIO_SETPRIO(cbp, BPRIO_TIMECRITICAL);
   2128 		else
   2129 			BIO_SETPRIO(cbp, BPRIO_TIMELIMITED);
   2130 		s = splbio();
   2131 		V_INCR_NUMOUTPUT(devvp);
   2132 		splx(s);
   2133 		VOP_STRATEGY(devvp, cbp);
   2134 		curproc->p_stats->p_ru.ru_oublock++;
   2135 	}
   2136 
   2137 	if (lfs_dostats) {
   2138 		++lfs_stats.psegwrites;
   2139 		lfs_stats.blocktot += nblocks - 1;
   2140 		if (fs->lfs_sp->seg_flags & SEGM_SYNC)
   2141 			++lfs_stats.psyncwrites;
   2142 		if (fs->lfs_sp->seg_flags & SEGM_CLEAN) {
   2143 			++lfs_stats.pcleanwrites;
   2144 			lfs_stats.cleanblocks += nblocks - 1;
   2145 		}
   2146 	}
   2147 	return (lfs_initseg(fs) || do_again);
   2148 }
   2149 
   2150 void
   2151 lfs_writesuper(struct lfs *fs, daddr_t daddr)
   2152 {
   2153 	struct buf *bp;
   2154 	int s;
   2155 	struct vnode *devvp = VTOI(fs->lfs_ivnode)->i_devvp;
   2156 
   2157 	ASSERT_MAYBE_SEGLOCK(fs);
   2158 #ifdef DIAGNOSTIC
   2159 	KASSERT(fs->lfs_magic == LFS_MAGIC);
   2160 #endif
   2161 	/*
   2162 	 * If we can write one superblock while another is in
   2163 	 * progress, we risk not having a complete checkpoint if we crash.
   2164 	 * So, block here if a superblock write is in progress.
   2165 	 */
   2166 	simple_lock(&fs->lfs_interlock);
   2167 	s = splbio();
   2168 	while (fs->lfs_sbactive) {
   2169 		ltsleep(&fs->lfs_sbactive, PRIBIO+1, "lfs sb", 0,
   2170 			&fs->lfs_interlock);
   2171 	}
   2172 	fs->lfs_sbactive = daddr;
   2173 	splx(s);
   2174 	simple_unlock(&fs->lfs_interlock);
   2175 
   2176 	/* Set timestamp of this version of the superblock */
   2177 	if (fs->lfs_version == 1)
   2178 		fs->lfs_otstamp = time.tv_sec;
   2179 	fs->lfs_tstamp = time.tv_sec;
   2180 
   2181 	/* Checksum the superblock and copy it into a buffer. */
   2182 	fs->lfs_cksum = lfs_sb_cksum(&(fs->lfs_dlfs));
   2183 	bp = lfs_newbuf(fs, devvp,
   2184 	    fsbtodb(fs, daddr), LFS_SBPAD, LFS_NB_SBLOCK);
   2185 	memset(bp->b_data + sizeof(struct dlfs), 0,
   2186 	    LFS_SBPAD - sizeof(struct dlfs));
   2187 	*(struct dlfs *)bp->b_data = fs->lfs_dlfs;
   2188 
   2189 	bp->b_flags |= B_BUSY | B_CALL | B_ASYNC;
   2190 	bp->b_flags &= ~(B_DONE | B_ERROR | B_READ | B_DELWRI);
   2191 	bp->b_iodone = lfs_supercallback;
   2192 
   2193 	if (fs->lfs_sp != NULL && fs->lfs_sp->seg_flags & SEGM_SYNC)
   2194 		BIO_SETPRIO(bp, BPRIO_TIMECRITICAL);
   2195 	else
   2196 		BIO_SETPRIO(bp, BPRIO_TIMELIMITED);
   2197 	curproc->p_stats->p_ru.ru_oublock++;
   2198 	s = splbio();
   2199 	V_INCR_NUMOUTPUT(bp->b_vp);
   2200 	splx(s);
   2201 	simple_lock(&fs->lfs_interlock);
   2202 	++fs->lfs_iocount;
   2203 	simple_unlock(&fs->lfs_interlock);
   2204 	VOP_STRATEGY(devvp, bp);
   2205 }
   2206 
   2207 /*
   2208  * Logical block number match routines used when traversing the dirty block
   2209  * chain.
   2210  */
   2211 int
   2212 lfs_match_fake(struct lfs *fs, struct buf *bp)
   2213 {
   2214 
   2215 	ASSERT_SEGLOCK(fs);
   2216 	return LFS_IS_MALLOC_BUF(bp);
   2217 }
   2218 
   2219 #if 0
   2220 int
   2221 lfs_match_real(struct lfs *fs, struct buf *bp)
   2222 {
   2223 
   2224 	ASSERT_SEGLOCK(fs);
   2225 	return (lfs_match_data(fs, bp) && !lfs_match_fake(fs, bp));
   2226 }
   2227 #endif
   2228 
   2229 int
   2230 lfs_match_data(struct lfs *fs, struct buf *bp)
   2231 {
   2232 
   2233 	ASSERT_SEGLOCK(fs);
   2234 	return (bp->b_lblkno >= 0);
   2235 }
   2236 
   2237 int
   2238 lfs_match_indir(struct lfs *fs, struct buf *bp)
   2239 {
   2240 	daddr_t lbn;
   2241 
   2242 	ASSERT_SEGLOCK(fs);
   2243 	lbn = bp->b_lblkno;
   2244 	return (lbn < 0 && (-lbn - NDADDR) % NINDIR(fs) == 0);
   2245 }
   2246 
   2247 int
   2248 lfs_match_dindir(struct lfs *fs, struct buf *bp)
   2249 {
   2250 	daddr_t lbn;
   2251 
   2252 	ASSERT_SEGLOCK(fs);
   2253 	lbn = bp->b_lblkno;
   2254 	return (lbn < 0 && (-lbn - NDADDR) % NINDIR(fs) == 1);
   2255 }
   2256 
   2257 int
   2258 lfs_match_tindir(struct lfs *fs, struct buf *bp)
   2259 {
   2260 	daddr_t lbn;
   2261 
   2262 	ASSERT_SEGLOCK(fs);
   2263 	lbn = bp->b_lblkno;
   2264 	return (lbn < 0 && (-lbn - NDADDR) % NINDIR(fs) == 2);
   2265 }
   2266 
   2267 /*
   2268  * XXX - The only buffers that are going to hit these functions are the
   2269  * segment write blocks, or the segment summaries, or the superblocks.
   2270  *
   2271  * All of the above are created by lfs_newbuf, and so do not need to be
   2272  * released via brelse.
   2273  */
   2274 void
   2275 lfs_callback(struct buf *bp)
   2276 {
   2277 	struct lfs *fs;
   2278 
   2279 	fs = bp->b_private;
   2280 	ASSERT_NO_SEGLOCK(fs);
   2281 	lfs_freebuf(fs, bp);
   2282 }
   2283 
   2284 static void
   2285 lfs_super_aiodone(struct buf *bp)
   2286 {
   2287 	struct lfs *fs;
   2288 
   2289 	fs = bp->b_private;
   2290 	ASSERT_NO_SEGLOCK(fs);
   2291 	simple_lock(&fs->lfs_interlock);
   2292 	fs->lfs_sbactive = 0;
   2293 	if (--fs->lfs_iocount <= 1)
   2294 		wakeup(&fs->lfs_iocount);
   2295 	simple_unlock(&fs->lfs_interlock);
   2296 	wakeup(&fs->lfs_sbactive);
   2297 	lfs_freebuf(fs, bp);
   2298 }
   2299 
   2300 static void
   2301 lfs_cluster_aiodone(struct buf *bp)
   2302 {
   2303 	struct lfs_cluster *cl;
   2304 	struct lfs *fs;
   2305 	struct buf *tbp, *fbp;
   2306 	struct vnode *vp, *devvp;
   2307 	struct inode *ip;
   2308 	int s, error=0;
   2309 
   2310 	if (bp->b_flags & B_ERROR)
   2311 		error = bp->b_error;
   2312 
   2313 	cl = bp->b_private;
   2314 	fs = cl->fs;
   2315 	devvp = VTOI(fs->lfs_ivnode)->i_devvp;
   2316 	ASSERT_NO_SEGLOCK(fs);
   2317 
   2318 	/* Put the pages back, and release the buffer */
   2319 	while (cl->bufcount--) {
   2320 		tbp = cl->bpp[cl->bufcount];
   2321 		KASSERT(tbp->b_flags & B_BUSY);
   2322 		if (error) {
   2323 			tbp->b_flags |= B_ERROR;
   2324 			tbp->b_error = error;
   2325 		}
   2326 
   2327 		/*
   2328 		 * We're done with tbp.	 If it has not been re-dirtied since
   2329 		 * the cluster was written, free it.  Otherwise, keep it on
   2330 		 * the locked list to be written again.
   2331 		 */
   2332 		vp = tbp->b_vp;
   2333 
   2334 		tbp->b_flags &= ~B_GATHERED;
   2335 
   2336 		LFS_BCLEAN_LOG(fs, tbp);
   2337 
   2338 		if (!(tbp->b_flags & B_CALL)) {
   2339 			KASSERT(tbp->b_flags & B_LOCKED);
   2340 			s = splbio();
   2341 			simple_lock(&bqueue_slock);
   2342 			bremfree(tbp);
   2343 			simple_unlock(&bqueue_slock);
   2344 			if (vp)
   2345 				reassignbuf(tbp, vp);
   2346 			splx(s);
   2347 			tbp->b_flags |= B_ASYNC; /* for biodone */
   2348 		}
   2349 
   2350 		if ((tbp->b_flags & (B_LOCKED | B_DELWRI)) == B_LOCKED)
   2351 			LFS_UNLOCK_BUF(tbp);
   2352 
   2353 		if (tbp->b_flags & B_DONE) {
   2354 			DLOG((DLOG_SEG, "blk %d biodone already (flags %lx)\n",
   2355 				cl->bufcount, (long)tbp->b_flags));
   2356 		}
   2357 
   2358 		if ((tbp->b_flags & B_CALL) && !LFS_IS_MALLOC_BUF(tbp)) {
   2359 			/*
   2360 			 * A buffer from the page daemon.
   2361 			 * We use the same iodone as it does,
   2362 			 * so we must manually disassociate its
   2363 			 * buffers from the vp.
   2364 			 */
   2365 			if (tbp->b_vp) {
   2366 				/* This is just silly */
   2367 				s = splbio();
   2368 				brelvp(tbp);
   2369 				tbp->b_vp = vp;
   2370 				splx(s);
   2371 			}
   2372 			/* Put it back the way it was */
   2373 			tbp->b_flags |= B_ASYNC;
   2374 			/* Master buffers have B_AGE */
   2375 			if (tbp->b_private == tbp)
   2376 				tbp->b_flags |= B_AGE;
   2377 		}
   2378 		s = splbio();
   2379 		biodone(tbp);
   2380 
   2381 		/*
   2382 		 * If this is the last block for this vnode, but
   2383 		 * there are other blocks on its dirty list,
   2384 		 * set IN_MODIFIED/IN_CLEANING depending on what
   2385 		 * sort of block.  Only do this for our mount point,
   2386 		 * not for, e.g., inode blocks that are attached to
   2387 		 * the devvp.
   2388 		 * XXX KS - Shouldn't we set *both* if both types
   2389 		 * of blocks are present (traverse the dirty list?)
   2390 		 */
   2391 		simple_lock(&global_v_numoutput_slock);
   2392 		if (vp != devvp && vp->v_numoutput == 0 &&
   2393 		    (fbp = LIST_FIRST(&vp->v_dirtyblkhd)) != NULL) {
   2394 			ip = VTOI(vp);
   2395 			DLOG((DLOG_SEG, "lfs_cluster_aiodone: mark ino %d\n",
   2396 			       ip->i_number));
   2397 			if (LFS_IS_MALLOC_BUF(fbp))
   2398 				LFS_SET_UINO(ip, IN_CLEANING);
   2399 			else
   2400 				LFS_SET_UINO(ip, IN_MODIFIED);
   2401 		}
   2402 		simple_unlock(&global_v_numoutput_slock);
   2403 		splx(s);
   2404 		wakeup(vp);
   2405 	}
   2406 
   2407 	/* Fix up the cluster buffer, and release it */
   2408 	if (cl->flags & LFS_CL_MALLOC)
   2409 		lfs_free(fs, bp->b_data, LFS_NB_CLUSTER);
   2410 	putiobuf(bp);
   2411 
   2412 	/* Note i/o done */
   2413 	if (cl->flags & LFS_CL_SYNC) {
   2414 		if (--cl->seg->seg_iocount == 0)
   2415 			wakeup(&cl->seg->seg_iocount);
   2416 	}
   2417 	simple_lock(&fs->lfs_interlock);
   2418 #ifdef DIAGNOSTIC
   2419 	if (fs->lfs_iocount == 0)
   2420 		panic("lfs_cluster_aiodone: zero iocount");
   2421 #endif
   2422 	if (--fs->lfs_iocount <= 1)
   2423 		wakeup(&fs->lfs_iocount);
   2424 	simple_unlock(&fs->lfs_interlock);
   2425 
   2426 	pool_put(&fs->lfs_bpppool, cl->bpp);
   2427 	cl->bpp = NULL;
   2428 	pool_put(&fs->lfs_clpool, cl);
   2429 }
   2430 
   2431 static void
   2432 lfs_generic_callback(struct buf *bp, void (*aiodone)(struct buf *))
   2433 {
   2434 	/* reset b_iodone for when this is a single-buf i/o. */
   2435 	bp->b_iodone = aiodone;
   2436 
   2437 	simple_lock(&uvm.aiodoned_lock);	/* locks uvm.aio_done */
   2438 	TAILQ_INSERT_TAIL(&uvm.aio_done, bp, b_freelist);
   2439 	wakeup(&uvm.aiodoned);
   2440 	simple_unlock(&uvm.aiodoned_lock);
   2441 }
   2442 
   2443 static void
   2444 lfs_cluster_callback(struct buf *bp)
   2445 {
   2446 
   2447 	lfs_generic_callback(bp, lfs_cluster_aiodone);
   2448 }
   2449 
   2450 void
   2451 lfs_supercallback(struct buf *bp)
   2452 {
   2453 
   2454 	lfs_generic_callback(bp, lfs_super_aiodone);
   2455 }
   2456 
   2457 /*
   2458  * Shellsort (diminishing increment sort) from Data Structures and
   2459  * Algorithms, Aho, Hopcraft and Ullman, 1983 Edition, page 290;
   2460  * see also Knuth Vol. 3, page 84.  The increments are selected from
   2461  * formula (8), page 95.  Roughly O(N^3/2).
   2462  */
   2463 /*
   2464  * This is our own private copy of shellsort because we want to sort
   2465  * two parallel arrays (the array of buffer pointers and the array of
   2466  * logical block numbers) simultaneously.  Note that we cast the array
   2467  * of logical block numbers to a unsigned in this routine so that the
   2468  * negative block numbers (meta data blocks) sort AFTER the data blocks.
   2469  */
   2470 
   2471 void
   2472 lfs_shellsort(struct buf **bp_array, int32_t *lb_array, int nmemb, int size)
   2473 {
   2474 	static int __rsshell_increments[] = { 4, 1, 0 };
   2475 	int incr, *incrp, t1, t2;
   2476 	struct buf *bp_temp;
   2477 
   2478 #ifdef DEBUG
   2479 	incr = 0;
   2480 	for (t1 = 0; t1 < nmemb; t1++) {
   2481 		for (t2 = 0; t2 * size < bp_array[t1]->b_bcount; t2++) {
   2482 			if (lb_array[incr++] != bp_array[t1]->b_lblkno + t2) {
   2483 				/* dump before panic */
   2484 				printf("lfs_shellsort: nmemb=%d, size=%d\n",
   2485 				    nmemb, size);
   2486 				incr = 0;
   2487 				for (t1 = 0; t1 < nmemb; t1++) {
   2488 					const struct buf *bp = bp_array[t1];
   2489 
   2490 					printf("bp[%d]: lbn=%" PRIu64 ", size=%"
   2491 					    PRIu64 "\n", t1,
   2492 					    (uint64_t)bp->b_bcount,
   2493 					    (uint64_t)bp->b_lblkno);
   2494 					printf("lbns:");
   2495 					for (t2 = 0; t2 * size < bp->b_bcount;
   2496 					    t2++) {
   2497 						printf(" %" PRId32,
   2498 						    lb_array[incr++]);
   2499 					}
   2500 					printf("\n");
   2501 				}
   2502 				panic("lfs_shellsort: inconsistent input");
   2503 			}
   2504 		}
   2505 	}
   2506 #endif
   2507 
   2508 	for (incrp = __rsshell_increments; (incr = *incrp++) != 0;)
   2509 		for (t1 = incr; t1 < nmemb; ++t1)
   2510 			for (t2 = t1 - incr; t2 >= 0;)
   2511 				if ((u_int32_t)bp_array[t2]->b_lblkno >
   2512 				    (u_int32_t)bp_array[t2 + incr]->b_lblkno) {
   2513 					bp_temp = bp_array[t2];
   2514 					bp_array[t2] = bp_array[t2 + incr];
   2515 					bp_array[t2 + incr] = bp_temp;
   2516 					t2 -= incr;
   2517 				} else
   2518 					break;
   2519 
   2520 	/* Reform the list of logical blocks */
   2521 	incr = 0;
   2522 	for (t1 = 0; t1 < nmemb; t1++) {
   2523 		for (t2 = 0; t2 * size < bp_array[t1]->b_bcount; t2++) {
   2524 			lb_array[incr++] = bp_array[t1]->b_lblkno + t2;
   2525 		}
   2526 	}
   2527 }
   2528 
   2529 /*
   2530  * Call vget with LK_NOWAIT.  If we are the one who holds VXLOCK/VFREEING,
   2531  * however, we must press on.  Just fake success in that case.
   2532  */
   2533 int
   2534 lfs_vref(struct vnode *vp)
   2535 {
   2536 	int error;
   2537 	struct lfs *fs;
   2538 
   2539 	fs = VTOI(vp)->i_lfs;
   2540 
   2541 	ASSERT_MAYBE_SEGLOCK(fs);
   2542 
   2543 	/*
   2544 	 * If we return 1 here during a flush, we risk vinvalbuf() not
   2545 	 * being able to flush all of the pages from this vnode, which
   2546 	 * will cause it to panic.  So, return 0 if a flush is in progress.
   2547 	 */
   2548 	error = vget(vp, LK_NOWAIT);
   2549 	if (error == EBUSY && IS_FLUSHING(VTOI(vp)->i_lfs, vp)) {
   2550 		++fs->lfs_flushvp_fakevref;
   2551 		return 0;
   2552 	}
   2553 	return error;
   2554 }
   2555 
   2556 /*
   2557  * This is vrele except that we do not want to VOP_INACTIVE this vnode. We
   2558  * inline vrele here to avoid the vn_lock and VOP_INACTIVE call at the end.
   2559  */
   2560 void
   2561 lfs_vunref(struct vnode *vp)
   2562 {
   2563 	struct lfs *fs;
   2564 
   2565 	fs = VTOI(vp)->i_lfs;
   2566 	ASSERT_MAYBE_SEGLOCK(fs);
   2567 
   2568 	/*
   2569 	 * Analogous to lfs_vref, if the node is flushing, fake it.
   2570 	 */
   2571 	if (IS_FLUSHING(fs, vp) && fs->lfs_flushvp_fakevref) {
   2572 		--fs->lfs_flushvp_fakevref;
   2573 		return;
   2574 	}
   2575 
   2576 	simple_lock(&vp->v_interlock);
   2577 #ifdef DIAGNOSTIC
   2578 	if (vp->v_usecount <= 0) {
   2579 		printf("lfs_vunref: inum is %llu\n", (unsigned long long)
   2580 		    VTOI(vp)->i_number);
   2581 		printf("lfs_vunref: flags are 0x%lx\n", (u_long)vp->v_flag);
   2582 		printf("lfs_vunref: usecount = %ld\n", (long)vp->v_usecount);
   2583 		panic("lfs_vunref: v_usecount < 0");
   2584 	}
   2585 #endif
   2586 	vp->v_usecount--;
   2587 	if (vp->v_usecount > 0) {
   2588 		simple_unlock(&vp->v_interlock);
   2589 		return;
   2590 	}
   2591 	/*
   2592 	 * insert at tail of LRU list
   2593 	 */
   2594 	simple_lock(&vnode_free_list_slock);
   2595 	if (vp->v_holdcnt > 0)
   2596 		TAILQ_INSERT_TAIL(&vnode_hold_list, vp, v_freelist);
   2597 	else
   2598 		TAILQ_INSERT_TAIL(&vnode_free_list, vp, v_freelist);
   2599 	simple_unlock(&vnode_free_list_slock);
   2600 	simple_unlock(&vp->v_interlock);
   2601 }
   2602 
   2603 /*
   2604  * We use this when we have vnodes that were loaded in solely for cleaning.
   2605  * There is no reason to believe that these vnodes will be referenced again
   2606  * soon, since the cleaning process is unrelated to normal filesystem
   2607  * activity.  Putting cleaned vnodes at the tail of the list has the effect
   2608  * of flushing the vnode LRU.  So, put vnodes that were loaded only for
   2609  * cleaning at the head of the list, instead.
   2610  */
   2611 void
   2612 lfs_vunref_head(struct vnode *vp)
   2613 {
   2614 
   2615 	ASSERT_SEGLOCK(VTOI(vp)->i_lfs);
   2616 	simple_lock(&vp->v_interlock);
   2617 #ifdef DIAGNOSTIC
   2618 	if (vp->v_usecount == 0) {
   2619 		panic("lfs_vunref: v_usecount<0");
   2620 	}
   2621 #endif
   2622 	vp->v_usecount--;
   2623 	if (vp->v_usecount > 0) {
   2624 		simple_unlock(&vp->v_interlock);
   2625 		return;
   2626 	}
   2627 	/*
   2628 	 * insert at head of LRU list
   2629 	 */
   2630 	simple_lock(&vnode_free_list_slock);
   2631 	if (vp->v_holdcnt > 0)
   2632 		TAILQ_INSERT_TAIL(&vnode_hold_list, vp, v_freelist);
   2633 	else
   2634 		TAILQ_INSERT_HEAD(&vnode_free_list, vp, v_freelist);
   2635 	simple_unlock(&vnode_free_list_slock);
   2636 	simple_unlock(&vp->v_interlock);
   2637 }
   2638 
   2639