xref: /csrg-svn/sys/ufs/ffs/ffs_alloc.c (revision 66176)
123394Smckusick /*
263371Sbostic  * Copyright (c) 1982, 1986, 1989, 1993
363371Sbostic  *	The Regents of the University of California.  All rights reserved.
423394Smckusick  *
544536Sbostic  * %sccs.include.redist.c%
634432Sbostic  *
7*66176Smckusick  *	@(#)ffs_alloc.c	8.8 (Berkeley) 02/21/94
823394Smckusick  */
94359Smckusick 
1051469Sbostic #include <sys/param.h>
1151469Sbostic #include <sys/systm.h>
1251469Sbostic #include <sys/buf.h>
1351469Sbostic #include <sys/proc.h>
1451469Sbostic #include <sys/vnode.h>
1554653Smckusick #include <sys/mount.h>
1651469Sbostic #include <sys/kernel.h>
1751469Sbostic #include <sys/syslog.h>
184359Smckusick 
1953317Smckusick #include <vm/vm.h>
2053317Smckusick 
2151469Sbostic #include <ufs/ufs/quota.h>
2251469Sbostic #include <ufs/ufs/inode.h>
2347571Skarels 
2451469Sbostic #include <ufs/ffs/fs.h>
2551469Sbostic #include <ufs/ffs/ffs_extern.h>
264359Smckusick 
2751469Sbostic extern u_long nextgennumber;
2851469Sbostic 
2951469Sbostic static daddr_t	ffs_alloccg __P((struct inode *, int, daddr_t, int));
3051469Sbostic static daddr_t	ffs_alloccgblk __P((struct fs *, struct cg *, daddr_t));
3165999Smckusick static daddr_t	ffs_clusteralloc __P((struct inode *, int, daddr_t, int));
3251469Sbostic static ino_t	ffs_dirpref __P((struct fs *));
3351469Sbostic static daddr_t	ffs_fragextend __P((struct inode *, int, long, int, int));
3451469Sbostic static void	ffs_fserr __P((struct fs *, u_int, char *));
3551469Sbostic static u_long	ffs_hashalloc
3651469Sbostic 		    __P((struct inode *, int, long, int, u_long (*)()));
3764603Sbostic static ino_t	ffs_nodealloccg __P((struct inode *, int, daddr_t, int));
3851469Sbostic static daddr_t	ffs_mapsearch __P((struct fs *, struct cg *, daddr_t, int));
3951469Sbostic 
405375Smckusic /*
415375Smckusic  * Allocate a block in the file system.
425375Smckusic  *
435375Smckusic  * The size of the requested block is given, which must be some
445375Smckusic  * multiple of fs_fsize and <= fs_bsize.
455375Smckusic  * A preference may be optionally specified. If a preference is given
465375Smckusic  * the following hierarchy is used to allocate a block:
475375Smckusic  *   1) allocate the requested block.
485375Smckusic  *   2) allocate a rotationally optimal block in the same cylinder.
495375Smckusic  *   3) allocate a block in the same cylinder group.
505375Smckusic  *   4) quadradically rehash into other cylinder groups, until an
515375Smckusic  *      available block is located.
525375Smckusic  * If no block preference is given the following heirarchy is used
535375Smckusic  * to allocate a block:
545375Smckusic  *   1) allocate a block in the cylinder group that contains the
555375Smckusic  *      inode for the file.
565375Smckusic  *   2) quadradically rehash into other cylinder groups, until an
575375Smckusic  *      available block is located.
585375Smckusic  */
5953244Smckusick ffs_alloc(ip, lbn, bpref, size, cred, bnp)
604463Smckusic 	register struct inode *ip;
6139678Smckusick 	daddr_t lbn, bpref;
624359Smckusick 	int size;
6353244Smckusick 	struct ucred *cred;
6439678Smckusick 	daddr_t *bnp;
654359Smckusick {
6665468Sbostic 	register struct fs *fs;
674359Smckusick 	daddr_t bno;
6837735Smckusick 	int cg, error;
694359Smckusick 
7039678Smckusick 	*bnp = 0;
715965Smckusic 	fs = ip->i_fs;
7253244Smckusick #ifdef DIAGNOSTIC
7364508Sbostic 	if ((u_int)size > fs->fs_bsize || fragoff(fs, size) != 0) {
746716Smckusick 		printf("dev = 0x%x, bsize = %d, size = %d, fs = %s\n",
756716Smckusick 		    ip->i_dev, fs->fs_bsize, size, fs->fs_fsmnt);
7651469Sbostic 		panic("ffs_alloc: bad size");
776716Smckusick 	}
7853244Smckusick 	if (cred == NOCRED)
7953244Smckusick 		panic("ffs_alloc: missing credential\n");
8053244Smckusick #endif /* DIAGNOSTIC */
815322Smckusic 	if (size == fs->fs_bsize && fs->fs_cstotal.cs_nbfree == 0)
824359Smckusick 		goto nospace;
8341309Smckusick 	if (cred->cr_uid != 0 && freespace(fs, fs->fs_minfree) <= 0)
844792Smckusic 		goto nospace;
857650Ssam #ifdef QUOTA
8641309Smckusick 	if (error = chkdq(ip, (long)btodb(size), cred, 0))
8737735Smckusick 		return (error);
887483Skre #endif
894948Smckusic 	if (bpref >= fs->fs_size)
904948Smckusic 		bpref = 0;
914359Smckusick 	if (bpref == 0)
9264603Sbostic 		cg = ino_to_cg(fs, ip->i_number);
934359Smckusick 	else
945377Smckusic 		cg = dtog(fs, bpref);
9551469Sbostic 	bno = (daddr_t)ffs_hashalloc(ip, cg, (long)bpref, size,
9651469Sbostic 	    (u_long (*)())ffs_alloccg);
9739678Smckusick 	if (bno > 0) {
9839678Smckusick 		ip->i_blocks += btodb(size);
9964603Sbostic 		ip->i_flag |= IN_CHANGE | IN_UPDATE;
10039678Smckusick 		*bnp = bno;
10139678Smckusick 		return (0);
10239678Smckusick 	}
10345173Smckusick #ifdef QUOTA
10445173Smckusick 	/*
10545173Smckusick 	 * Restore user's disk quota because allocation failed.
10645173Smckusick 	 */
10745173Smckusick 	(void) chkdq(ip, (long)-btodb(size), cred, FORCE);
10845173Smckusick #endif
1094359Smckusick nospace:
11051469Sbostic 	ffs_fserr(fs, cred->cr_uid, "file system full");
1114359Smckusick 	uprintf("\n%s: write failed, file system is full\n", fs->fs_fsmnt);
11237735Smckusick 	return (ENOSPC);
1134359Smckusick }
1144359Smckusick 
1155375Smckusic /*
1165375Smckusic  * Reallocate a fragment to a bigger size
1175375Smckusic  *
1185375Smckusic  * The number and size of the old block is given, and a preference
1195375Smckusic  * and new size is also specified. The allocator attempts to extend
1205375Smckusic  * the original block. Failing that, the regular block allocator is
1215375Smckusic  * invoked to get an appropriate block.
1225375Smckusic  */
12353244Smckusick ffs_realloccg(ip, lbprev, bpref, osize, nsize, cred, bpp)
1245965Smckusic 	register struct inode *ip;
12553059Smckusick 	daddr_t lbprev;
12639678Smckusick 	daddr_t bpref;
1274426Smckusic 	int osize, nsize;
12853244Smckusick 	struct ucred *cred;
12937735Smckusick 	struct buf **bpp;
1304426Smckusic {
1314426Smckusic 	register struct fs *fs;
13265468Sbostic 	struct buf *bp;
13345719Smckusick 	int cg, request, error;
13445719Smckusick 	daddr_t bprev, bno;
1354426Smckusic 
13637735Smckusick 	*bpp = 0;
1375965Smckusic 	fs = ip->i_fs;
13853244Smckusick #ifdef DIAGNOSTIC
13964508Sbostic 	if ((u_int)osize > fs->fs_bsize || fragoff(fs, osize) != 0 ||
14064508Sbostic 	    (u_int)nsize > fs->fs_bsize || fragoff(fs, nsize) != 0) {
14151469Sbostic 		printf(
14251469Sbostic 		    "dev = 0x%x, bsize = %d, osize = %d, nsize = %d, fs = %s\n",
1436716Smckusick 		    ip->i_dev, fs->fs_bsize, osize, nsize, fs->fs_fsmnt);
14451469Sbostic 		panic("ffs_realloccg: bad size");
1456716Smckusick 	}
14653244Smckusick 	if (cred == NOCRED)
14753244Smckusick 		panic("ffs_realloccg: missing credential\n");
14853244Smckusick #endif /* DIAGNOSTIC */
14941309Smckusick 	if (cred->cr_uid != 0 && freespace(fs, fs->fs_minfree) <= 0)
1504792Smckusic 		goto nospace;
15139678Smckusick 	if ((bprev = ip->i_db[lbprev]) == 0) {
1526716Smckusick 		printf("dev = 0x%x, bsize = %d, bprev = %d, fs = %s\n",
1536716Smckusick 		    ip->i_dev, fs->fs_bsize, bprev, fs->fs_fsmnt);
15451469Sbostic 		panic("ffs_realloccg: bad bprev");
1556716Smckusick 	}
15639678Smckusick 	/*
15739678Smckusick 	 * Allocate the extra space in the buffer.
15839678Smckusick 	 */
15939678Smckusick 	if (error = bread(ITOV(ip), lbprev, osize, NOCRED, &bp)) {
16039678Smckusick 		brelse(bp);
16139678Smckusick 		return (error);
16239678Smckusick 	}
16345173Smckusick #ifdef QUOTA
16445173Smckusick 	if (error = chkdq(ip, (long)btodb(nsize - osize), cred, 0)) {
16545173Smckusick 		brelse(bp);
16645173Smckusick 		return (error);
16745173Smckusick 	}
16845173Smckusick #endif
16939678Smckusick 	/*
17039678Smckusick 	 * Check for extension in the existing location.
17139678Smckusick 	 */
1726294Smckusick 	cg = dtog(fs, bprev);
17351469Sbostic 	if (bno = ffs_fragextend(ip, cg, (long)bprev, osize, nsize)) {
17439887Smckusick 		if (bp->b_blkno != fsbtodb(fs, bno))
17539678Smckusick 			panic("bad blockno");
17639762Smckusick 		ip->i_blocks += btodb(nsize - osize);
17764603Sbostic 		ip->i_flag |= IN_CHANGE | IN_UPDATE;
17848948Smckusick 		allocbuf(bp, nsize);
17948948Smckusick 		bp->b_flags |= B_DONE;
18064508Sbostic 		bzero((char *)bp->b_data + osize, (u_int)nsize - osize);
18137735Smckusick 		*bpp = bp;
18237735Smckusick 		return (0);
1834463Smckusic 	}
18439678Smckusick 	/*
18539678Smckusick 	 * Allocate a new disk location.
18639678Smckusick 	 */
1874948Smckusic 	if (bpref >= fs->fs_size)
1884948Smckusic 		bpref = 0;
18926253Skarels 	switch ((int)fs->fs_optim) {
19025256Smckusick 	case FS_OPTSPACE:
19125256Smckusick 		/*
19225256Smckusick 		 * Allocate an exact sized fragment. Although this makes
19325256Smckusick 		 * best use of space, we will waste time relocating it if
19425256Smckusick 		 * the file continues to grow. If the fragmentation is
19525256Smckusick 		 * less than half of the minimum free reserve, we choose
19625256Smckusick 		 * to begin optimizing for time.
19725256Smckusick 		 */
19824698Smckusick 		request = nsize;
19925256Smckusick 		if (fs->fs_minfree < 5 ||
20025256Smckusick 		    fs->fs_cstotal.cs_nffree >
20125256Smckusick 		    fs->fs_dsize * fs->fs_minfree / (2 * 100))
20225256Smckusick 			break;
20325256Smckusick 		log(LOG_NOTICE, "%s: optimization changed from SPACE to TIME\n",
20425256Smckusick 			fs->fs_fsmnt);
20525256Smckusick 		fs->fs_optim = FS_OPTTIME;
20625256Smckusick 		break;
20725256Smckusick 	case FS_OPTTIME:
20825256Smckusick 		/*
20951469Sbostic 		 * At this point we have discovered a file that is trying to
21051469Sbostic 		 * grow a small fragment to a larger fragment. To save time,
21151469Sbostic 		 * we allocate a full sized block, then free the unused portion.
21251469Sbostic 		 * If the file continues to grow, the `ffs_fragextend' call
21351469Sbostic 		 * above will be able to grow it in place without further
21451469Sbostic 		 * copying. If aberrant programs cause disk fragmentation to
21551469Sbostic 		 * grow within 2% of the free reserve, we choose to begin
21651469Sbostic 		 * optimizing for space.
21725256Smckusick 		 */
21824698Smckusick 		request = fs->fs_bsize;
21925256Smckusick 		if (fs->fs_cstotal.cs_nffree <
22025256Smckusick 		    fs->fs_dsize * (fs->fs_minfree - 2) / 100)
22125256Smckusick 			break;
22225256Smckusick 		log(LOG_NOTICE, "%s: optimization changed from TIME to SPACE\n",
22325256Smckusick 			fs->fs_fsmnt);
22425256Smckusick 		fs->fs_optim = FS_OPTSPACE;
22525256Smckusick 		break;
22625256Smckusick 	default:
22725256Smckusick 		printf("dev = 0x%x, optim = %d, fs = %s\n",
22825256Smckusick 		    ip->i_dev, fs->fs_optim, fs->fs_fsmnt);
22951469Sbostic 		panic("ffs_realloccg: bad optim");
23025256Smckusick 		/* NOTREACHED */
23125256Smckusick 	}
23251469Sbostic 	bno = (daddr_t)ffs_hashalloc(ip, cg, (long)bpref, request,
23351469Sbostic 	    (u_long (*)())ffs_alloccg);
2346567Smckusic 	if (bno > 0) {
23545719Smckusick 		bp->b_blkno = fsbtodb(fs, bno);
23645719Smckusick 		(void) vnode_pager_uncache(ITOV(ip));
23753059Smckusick 		ffs_blkfree(ip, bprev, (long)osize);
23824698Smckusick 		if (nsize < request)
23951469Sbostic 			ffs_blkfree(ip, bno + numfrags(fs, nsize),
24053059Smckusick 			    (long)(request - nsize));
24112643Ssam 		ip->i_blocks += btodb(nsize - osize);
24264603Sbostic 		ip->i_flag |= IN_CHANGE | IN_UPDATE;
24348948Smckusick 		allocbuf(bp, nsize);
24448948Smckusick 		bp->b_flags |= B_DONE;
24564508Sbostic 		bzero((char *)bp->b_data + osize, (u_int)nsize - osize);
24637735Smckusick 		*bpp = bp;
24737735Smckusick 		return (0);
2484463Smckusic 	}
24945173Smckusick #ifdef QUOTA
25045173Smckusick 	/*
25145173Smckusick 	 * Restore user's disk quota because allocation failed.
25245173Smckusick 	 */
25345173Smckusick 	(void) chkdq(ip, (long)-btodb(nsize - osize), cred, FORCE);
25445173Smckusick #endif
25539678Smckusick 	brelse(bp);
2564792Smckusic nospace:
2574463Smckusic 	/*
2584463Smckusic 	 * no space available
2594463Smckusic 	 */
26051469Sbostic 	ffs_fserr(fs, cred->cr_uid, "file system full");
2614426Smckusic 	uprintf("\n%s: write failed, file system is full\n", fs->fs_fsmnt);
26237735Smckusick 	return (ENOSPC);
2634426Smckusic }
2644426Smckusic 
2655375Smckusic /*
26665999Smckusick  * Reallocate a sequence of blocks into a contiguous sequence of blocks.
26765999Smckusick  *
26865999Smckusick  * The vnode and an array of buffer pointers for a range of sequential
26965999Smckusick  * logical blocks to be made contiguous is given. The allocator attempts
27065999Smckusick  * to find a range of sequential blocks starting as close as possible to
27165999Smckusick  * an fs_rotdelay offset from the end of the allocation for the logical
27265999Smckusick  * block immediately preceeding the current range. If successful, the
27365999Smckusick  * physical block numbers in the buffer pointers and in the inode are
27465999Smckusick  * changed to reflect the new allocation. If unsuccessful, the allocation
27565999Smckusick  * is left unchanged. The success in doing the reallocation is returned.
27665999Smckusick  * Note that the error return is not reflected back to the user. Rather
27765999Smckusick  * the previous block allocation will be used.
27865999Smckusick  */
279*66176Smckusick #include <sys/sysctl.h>
280*66176Smckusick int doasyncfree = 1;
281*66176Smckusick struct ctldebug debug14 = { "doasyncfree", &doasyncfree };
28265999Smckusick int
28365999Smckusick ffs_reallocblks(ap)
28465999Smckusick 	struct vop_reallocblks_args /* {
28565999Smckusick 		struct vnode *a_vp;
28665999Smckusick 		struct cluster_save *a_buflist;
28765999Smckusick 	} */ *ap;
28865999Smckusick {
28965999Smckusick 	struct fs *fs;
29065999Smckusick 	struct inode *ip;
29165999Smckusick 	struct vnode *vp;
29265999Smckusick 	struct buf *sbp, *ebp;
29365999Smckusick 	daddr_t *bap, *sbap, *ebap;
29465999Smckusick 	struct cluster_save *buflist;
29565999Smckusick 	daddr_t start_lbn, end_lbn, soff, eoff, newblk, blkno;
29665999Smckusick 	struct indir start_ap[NIADDR + 1], end_ap[NIADDR + 1], *idp;
29765999Smckusick 	int i, len, start_lvl, end_lvl, pref, ssize;
29865999Smckusick 
29965999Smckusick 	vp = ap->a_vp;
30065999Smckusick 	ip = VTOI(vp);
30165999Smckusick 	fs = ip->i_fs;
30265999Smckusick 	if (fs->fs_contigsumsize <= 0)
30365999Smckusick 		return (ENOSPC);
30465999Smckusick 	buflist = ap->a_buflist;
30565999Smckusick 	len = buflist->bs_nchildren;
30665999Smckusick 	start_lbn = buflist->bs_children[0]->b_lblkno;
30765999Smckusick 	end_lbn = start_lbn + len - 1;
30865999Smckusick #ifdef DIAGNOSTIC
30965999Smckusick 	for (i = 1; i < len; i++)
31065999Smckusick 		if (buflist->bs_children[i]->b_lblkno != start_lbn + i)
31165999Smckusick 			panic("ffs_reallocblks: non-cluster");
31265999Smckusick #endif
31365999Smckusick 	/*
31465999Smckusick 	 * If the latest allocation is in a new cylinder group, assume that
31565999Smckusick 	 * the filesystem has decided to move and do not force it back to
31665999Smckusick 	 * the previous cylinder group.
31765999Smckusick 	 */
31865999Smckusick 	if (dtog(fs, dbtofsb(fs, buflist->bs_children[0]->b_blkno)) !=
31965999Smckusick 	    dtog(fs, dbtofsb(fs, buflist->bs_children[len - 1]->b_blkno)))
32065999Smckusick 		return (ENOSPC);
32165999Smckusick 	if (ufs_getlbns(vp, start_lbn, start_ap, &start_lvl) ||
32265999Smckusick 	    ufs_getlbns(vp, end_lbn, end_ap, &end_lvl))
32365999Smckusick 		return (ENOSPC);
32465999Smckusick 	/*
32565999Smckusick 	 * Get the starting offset and block map for the first block.
32665999Smckusick 	 */
32765999Smckusick 	if (start_lvl == 0) {
32865999Smckusick 		sbap = &ip->i_db[0];
32965999Smckusick 		soff = start_lbn;
33065999Smckusick 	} else {
33165999Smckusick 		idp = &start_ap[start_lvl - 1];
33265999Smckusick 		if (bread(vp, idp->in_lbn, (int)fs->fs_bsize, NOCRED, &sbp)) {
33365999Smckusick 			brelse(sbp);
33465999Smckusick 			return (ENOSPC);
33565999Smckusick 		}
33665999Smckusick 		sbap = (daddr_t *)sbp->b_data;
33765999Smckusick 		soff = idp->in_off;
33865999Smckusick 	}
33965999Smckusick 	/*
34065999Smckusick 	 * Find the preferred location for the cluster.
34165999Smckusick 	 */
34265999Smckusick 	pref = ffs_blkpref(ip, start_lbn, soff, sbap);
34365999Smckusick 	/*
34465999Smckusick 	 * If the block range spans two block maps, get the second map.
34565999Smckusick 	 */
34666086Smckusick 	if (end_lvl == 0 || (idp = &end_ap[end_lvl - 1])->in_off + 1 >= len) {
34765999Smckusick 		ssize = len;
34865999Smckusick 	} else {
34966086Smckusick #ifdef DIAGNOSTIC
35066086Smckusick 		if (start_ap[start_lvl-1].in_lbn == idp->in_lbn)
35166086Smckusick 			panic("ffs_reallocblk: start == end");
35266086Smckusick #endif
35365999Smckusick 		ssize = len - (idp->in_off + 1);
35465999Smckusick 		if (bread(vp, idp->in_lbn, (int)fs->fs_bsize, NOCRED, &ebp))
35565999Smckusick 			goto fail;
35665999Smckusick 		ebap = (daddr_t *)ebp->b_data;
35765999Smckusick 	}
35865999Smckusick 	/*
35965999Smckusick 	 * Search the block map looking for an allocation of the desired size.
36065999Smckusick 	 */
36165999Smckusick 	if ((newblk = (daddr_t)ffs_hashalloc(ip, dtog(fs, pref), (long)pref,
36265999Smckusick 	    len, (u_long (*)())ffs_clusteralloc)) == 0)
36365999Smckusick 		goto fail;
36465999Smckusick 	/*
36565999Smckusick 	 * We have found a new contiguous block.
36665999Smckusick 	 *
36765999Smckusick 	 * First we have to replace the old block pointers with the new
36865999Smckusick 	 * block pointers in the inode and indirect blocks associated
36965999Smckusick 	 * with the file.
37065999Smckusick 	 */
37165999Smckusick 	blkno = newblk;
37265999Smckusick 	for (bap = &sbap[soff], i = 0; i < len; i++, blkno += fs->fs_frag) {
37365999Smckusick 		if (i == ssize)
37465999Smckusick 			bap = ebap;
37565999Smckusick #ifdef DIAGNOSTIC
37665999Smckusick 		if (buflist->bs_children[i]->b_blkno != fsbtodb(fs, *bap))
37765999Smckusick 			panic("ffs_reallocblks: alloc mismatch");
37865999Smckusick #endif
37965999Smckusick 		*bap++ = blkno;
38065999Smckusick 	}
38165999Smckusick 	/*
38265999Smckusick 	 * Next we must write out the modified inode and indirect blocks.
383*66176Smckusick 	 * For strict correctness, the writes should be synchronous since
384*66176Smckusick 	 * the old block values may have been written to disk. In practise
385*66176Smckusick 	 * they are almost never written, but if we are concerned about
386*66176Smckusick 	 * strict correctness, the `doasyncfree' flag should be set to zero.
38765999Smckusick 	 *
388*66176Smckusick 	 * The test on `doasyncfree' should be changed to test a flag
389*66176Smckusick 	 * that shows whether the associated buffers and inodes have
390*66176Smckusick 	 * been written. The flag should be set when the cluster is
391*66176Smckusick 	 * started and cleared whenever the buffer or inode is flushed.
392*66176Smckusick 	 * We can then check below to see if it is set, and do the
393*66176Smckusick 	 * synchronous write only when it has been cleared.
39465999Smckusick 	 */
39565999Smckusick 	if (sbap != &ip->i_db[0]) {
396*66176Smckusick 		if (doasyncfree)
397*66176Smckusick 			bdwrite(sbp);
398*66176Smckusick 		else
399*66176Smckusick 			bwrite(sbp);
40065999Smckusick 	} else {
40165999Smckusick 		ip->i_flag |= IN_CHANGE | IN_UPDATE;
402*66176Smckusick 		if (!doasyncfree)
403*66176Smckusick 			VOP_UPDATE(vp, &time, &time, MNT_WAIT);
40465999Smckusick 	}
40565999Smckusick 	if (ssize < len)
406*66176Smckusick 		if (doasyncfree)
407*66176Smckusick 			bdwrite(ebp);
408*66176Smckusick 		else
409*66176Smckusick 			bwrite(ebp);
41065999Smckusick 	/*
41165999Smckusick 	 * Last, free the old blocks and assign the new blocks to the buffers.
41265999Smckusick 	 */
41365999Smckusick 	for (blkno = newblk, i = 0; i < len; i++, blkno += fs->fs_frag) {
41465999Smckusick 		ffs_blkfree(ip, dbtofsb(fs, buflist->bs_children[i]->b_blkno),
41565999Smckusick 		    fs->fs_bsize);
41665999Smckusick 		buflist->bs_children[i]->b_blkno = fsbtodb(fs, blkno);
41765999Smckusick 	}
41865999Smckusick 	return (0);
41965999Smckusick 
42065999Smckusick fail:
42165999Smckusick 	if (ssize < len)
42265999Smckusick 		brelse(ebp);
42365999Smckusick 	if (sbap != &ip->i_db[0])
42465999Smckusick 		brelse(sbp);
42565999Smckusick 	return (ENOSPC);
42665999Smckusick }
42765999Smckusick 
42865999Smckusick /*
4295375Smckusic  * Allocate an inode in the file system.
4305375Smckusic  *
43151469Sbostic  * If allocating a directory, use ffs_dirpref to select the inode.
43251469Sbostic  * If allocating in a directory, the following hierarchy is followed:
43351469Sbostic  *   1) allocate the preferred inode.
4345375Smckusic  *   2) allocate an inode in the same cylinder group.
4355375Smckusic  *   3) quadradically rehash into other cylinder groups, until an
4365375Smckusic  *      available inode is located.
4375375Smckusic  * If no inode preference is given the following heirarchy is used
4385375Smckusic  * to allocate an inode:
4395375Smckusic  *   1) allocate an inode in cylinder group 0.
4405375Smckusic  *   2) quadradically rehash into other cylinder groups, until an
4415375Smckusic  *      available inode is located.
4425375Smckusic  */
44354653Smckusick ffs_valloc(ap)
44454653Smckusick 	struct vop_valloc_args /* {
44554653Smckusick 		struct vnode *a_pvp;
44654653Smckusick 		int a_mode;
44754653Smckusick 		struct ucred *a_cred;
44854653Smckusick 		struct vnode **a_vpp;
44954653Smckusick 	} */ *ap;
4504359Smckusick {
45153865Sheideman 	register struct vnode *pvp = ap->a_pvp;
45251541Smckusick 	register struct inode *pip;
4534359Smckusick 	register struct fs *fs;
4544359Smckusick 	register struct inode *ip;
45554653Smckusick 	mode_t mode = ap->a_mode;
45651469Sbostic 	ino_t ino, ipref;
45737735Smckusick 	int cg, error;
4584359Smckusick 
45953583Sheideman 	*ap->a_vpp = NULL;
46053865Sheideman 	pip = VTOI(pvp);
4615965Smckusic 	fs = pip->i_fs;
4624792Smckusic 	if (fs->fs_cstotal.cs_nifree == 0)
4634359Smckusick 		goto noinodes;
46451469Sbostic 
46554653Smckusick 	if ((mode & IFMT) == IFDIR)
46651541Smckusick 		ipref = ffs_dirpref(fs);
46751469Sbostic 	else
46851469Sbostic 		ipref = pip->i_number;
4694948Smckusic 	if (ipref >= fs->fs_ncg * fs->fs_ipg)
4704948Smckusic 		ipref = 0;
47164603Sbostic 	cg = ino_to_cg(fs, ipref);
47264603Sbostic 	ino = (ino_t)ffs_hashalloc(pip, cg, (long)ipref, mode, ffs_nodealloccg);
4734359Smckusick 	if (ino == 0)
4744359Smckusick 		goto noinodes;
47554653Smckusick 	error = VFS_VGET(pvp->v_mount, ino, ap->a_vpp);
47637735Smckusick 	if (error) {
47754653Smckusick 		VOP_VFREE(pvp, ino, mode);
47837735Smckusick 		return (error);
4794359Smckusick 	}
48053583Sheideman 	ip = VTOI(*ap->a_vpp);
4816716Smckusick 	if (ip->i_mode) {
48254653Smckusick 		printf("mode = 0%o, inum = %d, fs = %s\n",
4836716Smckusick 		    ip->i_mode, ip->i_number, fs->fs_fsmnt);
48451541Smckusick 		panic("ffs_valloc: dup alloc");
4856716Smckusick 	}
48612643Ssam 	if (ip->i_blocks) {				/* XXX */
48712643Ssam 		printf("free inode %s/%d had %d blocks\n",
48812643Ssam 		    fs->fs_fsmnt, ino, ip->i_blocks);
48912643Ssam 		ip->i_blocks = 0;
49012643Ssam 	}
49139516Smckusick 	ip->i_flags = 0;
49238255Smckusick 	/*
49338255Smckusick 	 * Set up a new generation number for this inode.
49438255Smckusick 	 */
49538255Smckusick 	if (++nextgennumber < (u_long)time.tv_sec)
49638255Smckusick 		nextgennumber = time.tv_sec;
49738255Smckusick 	ip->i_gen = nextgennumber;
49837735Smckusick 	return (0);
4994359Smckusick noinodes:
50053583Sheideman 	ffs_fserr(fs, ap->a_cred->cr_uid, "out of inodes");
5016294Smckusick 	uprintf("\n%s: create/symlink failed, no inodes free\n", fs->fs_fsmnt);
50237735Smckusick 	return (ENOSPC);
5034359Smckusick }
5044359Smckusick 
5054651Smckusic /*
5065375Smckusic  * Find a cylinder to place a directory.
5075375Smckusic  *
5085375Smckusic  * The policy implemented by this algorithm is to select from
5095375Smckusic  * among those cylinder groups with above the average number of
5105375Smckusic  * free inodes, the one with the smallest number of directories.
5114651Smckusic  */
51251469Sbostic static ino_t
51351469Sbostic ffs_dirpref(fs)
5145965Smckusic 	register struct fs *fs;
5154359Smckusick {
5164651Smckusic 	int cg, minndir, mincg, avgifree;
5174359Smckusick 
5184792Smckusic 	avgifree = fs->fs_cstotal.cs_nifree / fs->fs_ncg;
5194651Smckusic 	minndir = fs->fs_ipg;
5204359Smckusick 	mincg = 0;
5214651Smckusic 	for (cg = 0; cg < fs->fs_ncg; cg++)
5225322Smckusic 		if (fs->fs_cs(fs, cg).cs_ndir < minndir &&
5235322Smckusic 		    fs->fs_cs(fs, cg).cs_nifree >= avgifree) {
5244359Smckusick 			mincg = cg;
5255322Smckusic 			minndir = fs->fs_cs(fs, cg).cs_ndir;
5264359Smckusick 		}
5279163Ssam 	return ((ino_t)(fs->fs_ipg * mincg));
5284359Smckusick }
5294359Smckusick 
5304651Smckusic /*
5319163Ssam  * Select the desired position for the next block in a file.  The file is
5329163Ssam  * logically divided into sections. The first section is composed of the
5339163Ssam  * direct blocks. Each additional section contains fs_maxbpg blocks.
5349163Ssam  *
5359163Ssam  * If no blocks have been allocated in the first section, the policy is to
5369163Ssam  * request a block in the same cylinder group as the inode that describes
5379163Ssam  * the file. If no blocks have been allocated in any other section, the
5389163Ssam  * policy is to place the section in a cylinder group with a greater than
5399163Ssam  * average number of free blocks.  An appropriate cylinder group is found
54017696Smckusick  * by using a rotor that sweeps the cylinder groups. When a new group of
54117696Smckusick  * blocks is needed, the sweep begins in the cylinder group following the
54217696Smckusick  * cylinder group from which the previous allocation was made. The sweep
54317696Smckusick  * continues until a cylinder group with greater than the average number
54417696Smckusick  * of free blocks is found. If the allocation is for the first block in an
54517696Smckusick  * indirect block, the information on the previous allocation is unavailable;
54617696Smckusick  * here a best guess is made based upon the logical block number being
54717696Smckusick  * allocated.
5489163Ssam  *
5499163Ssam  * If a section is already partially allocated, the policy is to
5509163Ssam  * contiguously allocate fs_maxcontig blocks.  The end of one of these
5519163Ssam  * contiguous blocks and the beginning of the next is physically separated
5529163Ssam  * so that the disk head will be in transit between them for at least
5539163Ssam  * fs_rotdelay milliseconds.  This is to allow time for the processor to
5549163Ssam  * schedule another I/O transfer.
5554651Smckusic  */
5565212Smckusic daddr_t
55751469Sbostic ffs_blkpref(ip, lbn, indx, bap)
5589163Ssam 	struct inode *ip;
5599163Ssam 	daddr_t lbn;
5609163Ssam 	int indx;
5619163Ssam 	daddr_t *bap;
5629163Ssam {
5635965Smckusic 	register struct fs *fs;
56417696Smckusick 	register int cg;
56517696Smckusick 	int avgbfree, startcg;
5669163Ssam 	daddr_t nextblk;
5674651Smckusic 
5689163Ssam 	fs = ip->i_fs;
5699163Ssam 	if (indx % fs->fs_maxbpg == 0 || bap[indx - 1] == 0) {
5709163Ssam 		if (lbn < NDADDR) {
57164603Sbostic 			cg = ino_to_cg(fs, ip->i_number);
5725322Smckusic 			return (fs->fs_fpg * cg + fs->fs_frag);
5734651Smckusic 		}
5749163Ssam 		/*
5759163Ssam 		 * Find a cylinder with greater than average number of
5769163Ssam 		 * unused data blocks.
5779163Ssam 		 */
57817696Smckusick 		if (indx == 0 || bap[indx - 1] == 0)
57964603Sbostic 			startcg =
58064603Sbostic 			    ino_to_cg(fs, ip->i_number) + lbn / fs->fs_maxbpg;
58117696Smckusick 		else
58217696Smckusick 			startcg = dtog(fs, bap[indx - 1]) + 1;
58317696Smckusick 		startcg %= fs->fs_ncg;
5849163Ssam 		avgbfree = fs->fs_cstotal.cs_nbfree / fs->fs_ncg;
58517696Smckusick 		for (cg = startcg; cg < fs->fs_ncg; cg++)
5869163Ssam 			if (fs->fs_cs(fs, cg).cs_nbfree >= avgbfree) {
5879163Ssam 				fs->fs_cgrotor = cg;
5889163Ssam 				return (fs->fs_fpg * cg + fs->fs_frag);
5899163Ssam 			}
59017696Smckusick 		for (cg = 0; cg <= startcg; cg++)
5919163Ssam 			if (fs->fs_cs(fs, cg).cs_nbfree >= avgbfree) {
5929163Ssam 				fs->fs_cgrotor = cg;
5939163Ssam 				return (fs->fs_fpg * cg + fs->fs_frag);
5949163Ssam 			}
5959163Ssam 		return (NULL);
5969163Ssam 	}
5979163Ssam 	/*
5989163Ssam 	 * One or more previous blocks have been laid out. If less
5999163Ssam 	 * than fs_maxcontig previous blocks are contiguous, the
6009163Ssam 	 * next block is requested contiguously, otherwise it is
6019163Ssam 	 * requested rotationally delayed by fs_rotdelay milliseconds.
6029163Ssam 	 */
6039163Ssam 	nextblk = bap[indx - 1] + fs->fs_frag;
60456665Smargo 	if (indx < fs->fs_maxcontig || bap[indx - fs->fs_maxcontig] +
60556665Smargo 	    blkstofrags(fs, fs->fs_maxcontig) != nextblk)
6069163Ssam 		return (nextblk);
6079163Ssam 	if (fs->fs_rotdelay != 0)
6089163Ssam 		/*
6099163Ssam 		 * Here we convert ms of delay to frags as:
6109163Ssam 		 * (frags) = (ms) * (rev/sec) * (sect/rev) /
6119163Ssam 		 *	((sect/frag) * (ms/sec))
6129163Ssam 		 * then round up to the next block.
6139163Ssam 		 */
6149163Ssam 		nextblk += roundup(fs->fs_rotdelay * fs->fs_rps * fs->fs_nsect /
6159163Ssam 		    (NSPF(fs) * 1000), fs->fs_frag);
6169163Ssam 	return (nextblk);
6174651Smckusic }
6184651Smckusic 
6195375Smckusic /*
6205375Smckusic  * Implement the cylinder overflow algorithm.
6215375Smckusic  *
6225375Smckusic  * The policy implemented by this algorithm is:
6235375Smckusic  *   1) allocate the block in its requested cylinder group.
6245375Smckusic  *   2) quadradically rehash on the cylinder group number.
6255375Smckusic  *   3) brute force search for a free block.
6265375Smckusic  */
6275212Smckusic /*VARARGS5*/
62851469Sbostic static u_long
62951469Sbostic ffs_hashalloc(ip, cg, pref, size, allocator)
6305965Smckusic 	struct inode *ip;
6314359Smckusick 	int cg;
6324359Smckusick 	long pref;
6334359Smckusick 	int size;	/* size for data blocks, mode for inodes */
6345212Smckusic 	u_long (*allocator)();
6354359Smckusick {
6365965Smckusic 	register struct fs *fs;
6374359Smckusick 	long result;
6384359Smckusick 	int i, icg = cg;
6394359Smckusick 
6405965Smckusic 	fs = ip->i_fs;
6414359Smckusick 	/*
6424359Smckusick 	 * 1: preferred cylinder group
6434359Smckusick 	 */
6445965Smckusic 	result = (*allocator)(ip, cg, pref, size);
6454359Smckusick 	if (result)
6464359Smckusick 		return (result);
6474359Smckusick 	/*
6484359Smckusick 	 * 2: quadratic rehash
6494359Smckusick 	 */
6504359Smckusick 	for (i = 1; i < fs->fs_ncg; i *= 2) {
6514359Smckusick 		cg += i;
6524359Smckusick 		if (cg >= fs->fs_ncg)
6534359Smckusick 			cg -= fs->fs_ncg;
6545965Smckusic 		result = (*allocator)(ip, cg, 0, size);
6554359Smckusick 		if (result)
6564359Smckusick 			return (result);
6574359Smckusick 	}
6584359Smckusick 	/*
6594359Smckusick 	 * 3: brute force search
66010847Ssam 	 * Note that we start at i == 2, since 0 was checked initially,
66110847Ssam 	 * and 1 is always checked in the quadratic rehash.
6624359Smckusick 	 */
66310848Smckusick 	cg = (icg + 2) % fs->fs_ncg;
66410847Ssam 	for (i = 2; i < fs->fs_ncg; i++) {
6655965Smckusic 		result = (*allocator)(ip, cg, 0, size);
6664359Smckusick 		if (result)
6674359Smckusick 			return (result);
6684359Smckusick 		cg++;
6694359Smckusick 		if (cg == fs->fs_ncg)
6704359Smckusick 			cg = 0;
6714359Smckusick 	}
6726294Smckusick 	return (NULL);
6734359Smckusick }
6744359Smckusick 
6755375Smckusic /*
6765375Smckusic  * Determine whether a fragment can be extended.
6775375Smckusic  *
6785375Smckusic  * Check to see if the necessary fragments are available, and
6795375Smckusic  * if they are, allocate them.
6805375Smckusic  */
68151469Sbostic static daddr_t
68251469Sbostic ffs_fragextend(ip, cg, bprev, osize, nsize)
6835965Smckusic 	struct inode *ip;
6844426Smckusic 	int cg;
6854463Smckusic 	long bprev;
6864426Smckusic 	int osize, nsize;
6874426Smckusic {
6885965Smckusic 	register struct fs *fs;
6894463Smckusic 	register struct cg *cgp;
69037735Smckusick 	struct buf *bp;
6914463Smckusic 	long bno;
6924463Smckusic 	int frags, bbase;
69337735Smckusick 	int i, error;
6944426Smckusic 
6955965Smckusic 	fs = ip->i_fs;
69617224Smckusick 	if (fs->fs_cs(fs, cg).cs_nffree < numfrags(fs, nsize - osize))
6976531Smckusick 		return (NULL);
6985960Smckusic 	frags = numfrags(fs, nsize);
69917224Smckusick 	bbase = fragnum(fs, bprev);
70017224Smckusick 	if (bbase > fragnum(fs, (bprev + frags - 1))) {
70130749Skarels 		/* cannot extend across a block boundary */
7026294Smckusick 		return (NULL);
7034463Smckusic 	}
70437735Smckusick 	error = bread(ip->i_devvp, fsbtodb(fs, cgtod(fs, cg)),
70538776Smckusick 		(int)fs->fs_cgsize, NOCRED, &bp);
70637735Smckusick 	if (error) {
70737735Smckusick 		brelse(bp);
70837735Smckusick 		return (NULL);
70937735Smckusick 	}
71064508Sbostic 	cgp = (struct cg *)bp->b_data;
71137735Smckusick 	if (!cg_chkmagic(cgp)) {
7125960Smckusic 		brelse(bp);
7136294Smckusick 		return (NULL);
7145960Smckusic 	}
7158105Sroot 	cgp->cg_time = time.tv_sec;
7165377Smckusic 	bno = dtogd(fs, bprev);
7175960Smckusic 	for (i = numfrags(fs, osize); i < frags; i++)
71834143Smckusick 		if (isclr(cg_blksfree(cgp), bno + i)) {
7195361Smckusic 			brelse(bp);
7206294Smckusick 			return (NULL);
7215361Smckusic 		}
7225361Smckusic 	/*
7235361Smckusic 	 * the current fragment can be extended
7245361Smckusic 	 * deduct the count on fragment being extended into
7255361Smckusic 	 * increase the count on the remaining fragment (if any)
7265361Smckusic 	 * allocate the extended piece
7275361Smckusic 	 */
7285361Smckusic 	for (i = frags; i < fs->fs_frag - bbase; i++)
72934143Smckusick 		if (isclr(cg_blksfree(cgp), bno + i))
7304463Smckusic 			break;
7315960Smckusic 	cgp->cg_frsum[i - numfrags(fs, osize)]--;
7325361Smckusic 	if (i != frags)
7335361Smckusic 		cgp->cg_frsum[i - frags]++;
7345960Smckusic 	for (i = numfrags(fs, osize); i < frags; i++) {
73534143Smckusick 		clrbit(cg_blksfree(cgp), bno + i);
7365361Smckusic 		cgp->cg_cs.cs_nffree--;
7375361Smckusic 		fs->fs_cstotal.cs_nffree--;
7385361Smckusic 		fs->fs_cs(fs, cg).cs_nffree--;
7394463Smckusic 	}
74050893Smckusick 	fs->fs_fmod = 1;
7415361Smckusic 	bdwrite(bp);
7425361Smckusic 	return (bprev);
7434426Smckusic }
7444426Smckusic 
7455375Smckusic /*
7465375Smckusic  * Determine whether a block can be allocated.
7475375Smckusic  *
74864603Sbostic  * Check to see if a block of the appropriate size is available,
7495375Smckusic  * and if it is, allocate it.
7505375Smckusic  */
75151779Smarc static daddr_t
75251469Sbostic ffs_alloccg(ip, cg, bpref, size)
7535965Smckusic 	struct inode *ip;
7544359Smckusick 	int cg;
7554359Smckusick 	daddr_t bpref;
7564359Smckusick 	int size;
7574359Smckusick {
7585965Smckusic 	register struct fs *fs;
7594463Smckusic 	register struct cg *cgp;
76037735Smckusick 	struct buf *bp;
7614463Smckusic 	register int i;
76237735Smckusick 	int error, bno, frags, allocsiz;
7634359Smckusick 
7645965Smckusic 	fs = ip->i_fs;
7655322Smckusic 	if (fs->fs_cs(fs, cg).cs_nbfree == 0 && size == fs->fs_bsize)
7666294Smckusick 		return (NULL);
76737735Smckusick 	error = bread(ip->i_devvp, fsbtodb(fs, cgtod(fs, cg)),
76838776Smckusick 		(int)fs->fs_cgsize, NOCRED, &bp);
76937735Smckusick 	if (error) {
77037735Smckusick 		brelse(bp);
77137735Smckusick 		return (NULL);
77237735Smckusick 	}
77364508Sbostic 	cgp = (struct cg *)bp->b_data;
77437735Smckusick 	if (!cg_chkmagic(cgp) ||
77515950Smckusick 	    (cgp->cg_cs.cs_nbfree == 0 && size == fs->fs_bsize)) {
7765960Smckusic 		brelse(bp);
7776294Smckusick 		return (NULL);
7785960Smckusic 	}
7798105Sroot 	cgp->cg_time = time.tv_sec;
7805322Smckusic 	if (size == fs->fs_bsize) {
78151469Sbostic 		bno = ffs_alloccgblk(fs, cgp, bpref);
7824463Smckusic 		bdwrite(bp);
7834463Smckusic 		return (bno);
7844463Smckusic 	}
7854463Smckusic 	/*
7864463Smckusic 	 * check to see if any fragments are already available
7874463Smckusic 	 * allocsiz is the size which will be allocated, hacking
7884463Smckusic 	 * it down to a smaller size if necessary
7894463Smckusic 	 */
7905960Smckusic 	frags = numfrags(fs, size);
7915322Smckusic 	for (allocsiz = frags; allocsiz < fs->fs_frag; allocsiz++)
7924463Smckusic 		if (cgp->cg_frsum[allocsiz] != 0)
7934463Smckusic 			break;
7945322Smckusic 	if (allocsiz == fs->fs_frag) {
7954463Smckusic 		/*
7964463Smckusic 		 * no fragments were available, so a block will be
7974463Smckusic 		 * allocated, and hacked up
7984463Smckusic 		 */
7994792Smckusic 		if (cgp->cg_cs.cs_nbfree == 0) {
8004463Smckusic 			brelse(bp);
8016294Smckusick 			return (NULL);
8024463Smckusic 		}
80351469Sbostic 		bno = ffs_alloccgblk(fs, cgp, bpref);
8045377Smckusic 		bpref = dtogd(fs, bno);
8055322Smckusic 		for (i = frags; i < fs->fs_frag; i++)
80634143Smckusick 			setbit(cg_blksfree(cgp), bpref + i);
8075322Smckusic 		i = fs->fs_frag - frags;
8084792Smckusic 		cgp->cg_cs.cs_nffree += i;
8094792Smckusic 		fs->fs_cstotal.cs_nffree += i;
8105322Smckusic 		fs->fs_cs(fs, cg).cs_nffree += i;
81150893Smckusick 		fs->fs_fmod = 1;
8124463Smckusic 		cgp->cg_frsum[i]++;
8134463Smckusic 		bdwrite(bp);
8144463Smckusic 		return (bno);
8154463Smckusic 	}
81651469Sbostic 	bno = ffs_mapsearch(fs, cgp, bpref, allocsiz);
81715950Smckusick 	if (bno < 0) {
81815950Smckusick 		brelse(bp);
8196294Smckusick 		return (NULL);
82015950Smckusick 	}
8214463Smckusic 	for (i = 0; i < frags; i++)
82234143Smckusick 		clrbit(cg_blksfree(cgp), bno + i);
8234792Smckusic 	cgp->cg_cs.cs_nffree -= frags;
8244792Smckusic 	fs->fs_cstotal.cs_nffree -= frags;
8255322Smckusic 	fs->fs_cs(fs, cg).cs_nffree -= frags;
82650893Smckusick 	fs->fs_fmod = 1;
8274463Smckusic 	cgp->cg_frsum[allocsiz]--;
8284463Smckusic 	if (frags != allocsiz)
8294463Smckusic 		cgp->cg_frsum[allocsiz - frags]++;
8304463Smckusic 	bdwrite(bp);
8314463Smckusic 	return (cg * fs->fs_fpg + bno);
8324463Smckusic }
8334463Smckusic 
8345375Smckusic /*
8355375Smckusic  * Allocate a block in a cylinder group.
8365375Smckusic  *
8375375Smckusic  * This algorithm implements the following policy:
8385375Smckusic  *   1) allocate the requested block.
8395375Smckusic  *   2) allocate a rotationally optimal block in the same cylinder.
8405375Smckusic  *   3) allocate the next available block on the block rotor for the
8415375Smckusic  *      specified cylinder group.
8425375Smckusic  * Note that this routine only allocates fs_bsize blocks; these
8435375Smckusic  * blocks may be fragmented by the routine that allocates them.
8445375Smckusic  */
84551469Sbostic static daddr_t
84651469Sbostic ffs_alloccgblk(fs, cgp, bpref)
8475965Smckusic 	register struct fs *fs;
8484463Smckusic 	register struct cg *cgp;
8494463Smckusic 	daddr_t bpref;
8504463Smckusic {
85165999Smckusick 	daddr_t bno, blkno;
8526294Smckusick 	int cylno, pos, delta;
8534651Smckusic 	short *cylbp;
8545361Smckusic 	register int i;
8554463Smckusic 
85665999Smckusick 	if (bpref == 0 || dtog(fs, bpref) != cgp->cg_cgx) {
8574651Smckusic 		bpref = cgp->cg_rotor;
8585361Smckusic 		goto norot;
8595361Smckusic 	}
86017224Smckusick 	bpref = blknum(fs, bpref);
8615377Smckusic 	bpref = dtogd(fs, bpref);
8625361Smckusic 	/*
8635361Smckusic 	 * if the requested block is available, use it
8645361Smckusic 	 */
86551469Sbostic 	if (ffs_isblock(fs, cg_blksfree(cgp), fragstoblks(fs, bpref))) {
8665361Smckusic 		bno = bpref;
8675361Smckusic 		goto gotit;
8685361Smckusic 	}
8695361Smckusic 	/*
8705361Smckusic 	 * check for a block available on the same cylinder
8715361Smckusic 	 */
8725361Smckusic 	cylno = cbtocylno(fs, bpref);
87334143Smckusick 	if (cg_blktot(cgp)[cylno] == 0)
8745375Smckusic 		goto norot;
8755375Smckusic 	if (fs->fs_cpc == 0) {
8765375Smckusic 		/*
87757000Smckusick 		 * Block layout information is not available.
87857000Smckusick 		 * Leaving bpref unchanged means we take the
87957000Smckusick 		 * next available free block following the one
88057000Smckusick 		 * we just allocated. Hopefully this will at
88157000Smckusick 		 * least hit a track cache on drives of unknown
88257000Smckusick 		 * geometry (e.g. SCSI).
8835375Smckusic 		 */
8845375Smckusic 		goto norot;
8855375Smckusic 	}
8865375Smckusic 	/*
8875361Smckusic 	 * check the summary information to see if a block is
8885361Smckusic 	 * available in the requested cylinder starting at the
8899163Ssam 	 * requested rotational position and proceeding around.
8905361Smckusic 	 */
89134143Smckusick 	cylbp = cg_blks(fs, cgp, cylno);
8929163Ssam 	pos = cbtorpos(fs, bpref);
89334143Smckusick 	for (i = pos; i < fs->fs_nrpos; i++)
8945361Smckusic 		if (cylbp[i] > 0)
8955361Smckusic 			break;
89634143Smckusick 	if (i == fs->fs_nrpos)
8975361Smckusic 		for (i = 0; i < pos; i++)
8985361Smckusic 			if (cylbp[i] > 0)
8995361Smckusic 				break;
9005361Smckusic 	if (cylbp[i] > 0) {
9014651Smckusic 		/*
9025361Smckusic 		 * found a rotational position, now find the actual
9035361Smckusic 		 * block. A panic if none is actually there.
9044651Smckusic 		 */
9055361Smckusic 		pos = cylno % fs->fs_cpc;
9065361Smckusic 		bno = (cylno - pos) * fs->fs_spc / NSPB(fs);
90734143Smckusick 		if (fs_postbl(fs, pos)[i] == -1) {
9086716Smckusick 			printf("pos = %d, i = %d, fs = %s\n",
9096716Smckusick 			    pos, i, fs->fs_fsmnt);
91051469Sbostic 			panic("ffs_alloccgblk: cyl groups corrupted");
9116716Smckusick 		}
91234143Smckusick 		for (i = fs_postbl(fs, pos)[i];; ) {
91351469Sbostic 			if (ffs_isblock(fs, cg_blksfree(cgp), bno + i)) {
91411638Ssam 				bno = blkstofrags(fs, (bno + i));
9155361Smckusic 				goto gotit;
9165361Smckusic 			}
91734143Smckusick 			delta = fs_rotbl(fs)[i];
91834143Smckusick 			if (delta <= 0 ||
91934143Smckusick 			    delta + i > fragstoblks(fs, fs->fs_fpg))
9204651Smckusic 				break;
9216294Smckusick 			i += delta;
9224651Smckusic 		}
9236716Smckusick 		printf("pos = %d, i = %d, fs = %s\n", pos, i, fs->fs_fsmnt);
92451469Sbostic 		panic("ffs_alloccgblk: can't find blk in cyl");
9254359Smckusick 	}
9265361Smckusic norot:
9275361Smckusic 	/*
9285361Smckusic 	 * no blocks in the requested cylinder, so take next
9295361Smckusic 	 * available one in this cylinder group.
9305361Smckusic 	 */
93151469Sbostic 	bno = ffs_mapsearch(fs, cgp, bpref, (int)fs->fs_frag);
9326567Smckusic 	if (bno < 0)
9336294Smckusick 		return (NULL);
9344651Smckusic 	cgp->cg_rotor = bno;
9354359Smckusick gotit:
93665999Smckusick 	blkno = fragstoblks(fs, bno);
93765999Smckusick 	ffs_clrblock(fs, cg_blksfree(cgp), (long)blkno);
93865999Smckusick 	ffs_clusteracct(fs, cgp, blkno, -1);
9394792Smckusic 	cgp->cg_cs.cs_nbfree--;
9404792Smckusic 	fs->fs_cstotal.cs_nbfree--;
9415322Smckusic 	fs->fs_cs(fs, cgp->cg_cgx).cs_nbfree--;
9425375Smckusic 	cylno = cbtocylno(fs, bno);
94334143Smckusick 	cg_blks(fs, cgp, cylno)[cbtorpos(fs, bno)]--;
94434143Smckusick 	cg_blktot(cgp)[cylno]--;
94550893Smckusick 	fs->fs_fmod = 1;
9464651Smckusic 	return (cgp->cg_cgx * fs->fs_fpg + bno);
9474359Smckusick }
94834143Smckusick 
9495375Smckusic /*
95065999Smckusick  * Determine whether a cluster can be allocated.
95165999Smckusick  *
95265999Smckusick  * We do not currently check for optimal rotational layout if there
95365999Smckusick  * are multiple choices in the same cylinder group. Instead we just
95465999Smckusick  * take the first one that we find following bpref.
95565999Smckusick  */
95665999Smckusick static daddr_t
95765999Smckusick ffs_clusteralloc(ip, cg, bpref, len)
95865999Smckusick 	struct inode *ip;
95965999Smckusick 	int cg;
96065999Smckusick 	daddr_t bpref;
96165999Smckusick 	int len;
96265999Smckusick {
96365999Smckusick 	register struct fs *fs;
96465999Smckusick 	register struct cg *cgp;
96565999Smckusick 	struct buf *bp;
96665999Smckusick 	int i, run, bno, bit, map;
96765999Smckusick 	u_char *mapp;
96865999Smckusick 
96965999Smckusick 	fs = ip->i_fs;
97065999Smckusick 	if (fs->fs_cs(fs, cg).cs_nbfree < len)
97165999Smckusick 		return (NULL);
97265999Smckusick 	if (bread(ip->i_devvp, fsbtodb(fs, cgtod(fs, cg)), (int)fs->fs_cgsize,
97365999Smckusick 	    NOCRED, &bp))
97465999Smckusick 		goto fail;
97565999Smckusick 	cgp = (struct cg *)bp->b_data;
97665999Smckusick 	if (!cg_chkmagic(cgp))
97765999Smckusick 		goto fail;
97865999Smckusick 	/*
97965999Smckusick 	 * Check to see if a cluster of the needed size (or bigger) is
98065999Smckusick 	 * available in this cylinder group.
98165999Smckusick 	 */
98265999Smckusick 	for (i = len; i <= fs->fs_contigsumsize; i++)
98365999Smckusick 		if (cg_clustersum(cgp)[i] > 0)
98465999Smckusick 			break;
98565999Smckusick 	if (i > fs->fs_contigsumsize)
98665999Smckusick 		goto fail;
98765999Smckusick 	/*
98865999Smckusick 	 * Search the cluster map to find a big enough cluster.
98965999Smckusick 	 * We take the first one that we find, even if it is larger
99065999Smckusick 	 * than we need as we prefer to get one close to the previous
99165999Smckusick 	 * block allocation. We do not search before the current
99265999Smckusick 	 * preference point as we do not want to allocate a block
99365999Smckusick 	 * that is allocated before the previous one (as we will
99465999Smckusick 	 * then have to wait for another pass of the elevator
99565999Smckusick 	 * algorithm before it will be read). We prefer to fail and
99665999Smckusick 	 * be recalled to try an allocation in the next cylinder group.
99765999Smckusick 	 */
99865999Smckusick 	if (dtog(fs, bpref) != cg)
99965999Smckusick 		bpref = 0;
100065999Smckusick 	else
100165999Smckusick 		bpref = fragstoblks(fs, dtogd(fs, blknum(fs, bpref)));
100265999Smckusick 	mapp = &cg_clustersfree(cgp)[bpref / NBBY];
100365999Smckusick 	map = *mapp++;
100465999Smckusick 	bit = 1 << (bpref % NBBY);
100565999Smckusick 	for (run = 0, i = bpref; i < cgp->cg_nclusterblks; i++) {
100665999Smckusick 		if ((map & bit) == 0) {
100765999Smckusick 			run = 0;
100865999Smckusick 		} else {
100965999Smckusick 			run++;
101065999Smckusick 			if (run == len)
101165999Smckusick 				break;
101265999Smckusick 		}
101365999Smckusick 		if ((i & (NBBY - 1)) != (NBBY - 1)) {
101465999Smckusick 			bit <<= 1;
101565999Smckusick 		} else {
101665999Smckusick 			map = *mapp++;
101765999Smckusick 			bit = 1;
101865999Smckusick 		}
101965999Smckusick 	}
102065999Smckusick 	if (i == cgp->cg_nclusterblks)
102165999Smckusick 		goto fail;
102265999Smckusick 	/*
102365999Smckusick 	 * Allocate the cluster that we have found.
102465999Smckusick 	 */
102565999Smckusick 	bno = cg * fs->fs_fpg + blkstofrags(fs, i - run + 1);
102665999Smckusick 	len = blkstofrags(fs, len);
102765999Smckusick 	for (i = 0; i < len; i += fs->fs_frag)
102865999Smckusick 		if (ffs_alloccgblk(fs, cgp, bno + i) != bno + i)
102965999Smckusick 			panic("ffs_clusteralloc: lost block");
103065999Smckusick 	brelse(bp);
103165999Smckusick 	return (bno);
103265999Smckusick 
103365999Smckusick fail:
103465999Smckusick 	brelse(bp);
103565999Smckusick 	return (0);
103665999Smckusick }
103765999Smckusick 
103865999Smckusick /*
10395375Smckusic  * Determine whether an inode can be allocated.
10405375Smckusic  *
10415375Smckusic  * Check to see if an inode is available, and if it is,
10425375Smckusic  * allocate it using the following policy:
10435375Smckusic  *   1) allocate the requested inode.
10445375Smckusic  *   2) allocate the next available inode after the requested
10455375Smckusic  *      inode in the specified cylinder group.
10465375Smckusic  */
104751469Sbostic static ino_t
104864603Sbostic ffs_nodealloccg(ip, cg, ipref, mode)
10495965Smckusic 	struct inode *ip;
10504359Smckusick 	int cg;
10514359Smckusick 	daddr_t ipref;
10524359Smckusick 	int mode;
10534359Smckusick {
10545965Smckusic 	register struct fs *fs;
10554463Smckusic 	register struct cg *cgp;
105616784Smckusick 	struct buf *bp;
105737735Smckusick 	int error, start, len, loc, map, i;
10584359Smckusick 
10595965Smckusic 	fs = ip->i_fs;
10605322Smckusic 	if (fs->fs_cs(fs, cg).cs_nifree == 0)
10616294Smckusick 		return (NULL);
106237735Smckusick 	error = bread(ip->i_devvp, fsbtodb(fs, cgtod(fs, cg)),
106338776Smckusick 		(int)fs->fs_cgsize, NOCRED, &bp);
106437735Smckusick 	if (error) {
106537735Smckusick 		brelse(bp);
106637735Smckusick 		return (NULL);
106737735Smckusick 	}
106864508Sbostic 	cgp = (struct cg *)bp->b_data;
106937735Smckusick 	if (!cg_chkmagic(cgp) || cgp->cg_cs.cs_nifree == 0) {
10705960Smckusic 		brelse(bp);
10716294Smckusick 		return (NULL);
10725960Smckusic 	}
10738105Sroot 	cgp->cg_time = time.tv_sec;
10744359Smckusick 	if (ipref) {
10754359Smckusick 		ipref %= fs->fs_ipg;
107634143Smckusick 		if (isclr(cg_inosused(cgp), ipref))
10774359Smckusick 			goto gotit;
107816784Smckusick 	}
107916784Smckusick 	start = cgp->cg_irotor / NBBY;
108016784Smckusick 	len = howmany(fs->fs_ipg - cgp->cg_irotor, NBBY);
108134143Smckusick 	loc = skpc(0xff, len, &cg_inosused(cgp)[start]);
108216784Smckusick 	if (loc == 0) {
108317697Smckusick 		len = start + 1;
108417697Smckusick 		start = 0;
108534143Smckusick 		loc = skpc(0xff, len, &cg_inosused(cgp)[0]);
108617697Smckusick 		if (loc == 0) {
108765718Sbostic 			printf("cg = %d, irotor = %d, fs = %s\n",
108817697Smckusick 			    cg, cgp->cg_irotor, fs->fs_fsmnt);
108964603Sbostic 			panic("ffs_nodealloccg: map corrupted");
109017697Smckusick 			/* NOTREACHED */
109117697Smckusick 		}
109216784Smckusick 	}
109316784Smckusick 	i = start + len - loc;
109434143Smckusick 	map = cg_inosused(cgp)[i];
109516784Smckusick 	ipref = i * NBBY;
109616784Smckusick 	for (i = 1; i < (1 << NBBY); i <<= 1, ipref++) {
109716784Smckusick 		if ((map & i) == 0) {
10984359Smckusick 			cgp->cg_irotor = ipref;
10994359Smckusick 			goto gotit;
11004359Smckusick 		}
11014359Smckusick 	}
110216784Smckusick 	printf("fs = %s\n", fs->fs_fsmnt);
110364603Sbostic 	panic("ffs_nodealloccg: block not in map");
110416784Smckusick 	/* NOTREACHED */
11054359Smckusick gotit:
110634143Smckusick 	setbit(cg_inosused(cgp), ipref);
11074792Smckusic 	cgp->cg_cs.cs_nifree--;
11084792Smckusic 	fs->fs_cstotal.cs_nifree--;
11095322Smckusic 	fs->fs_cs(fs, cg).cs_nifree--;
111050893Smckusick 	fs->fs_fmod = 1;
11114359Smckusick 	if ((mode & IFMT) == IFDIR) {
11124792Smckusic 		cgp->cg_cs.cs_ndir++;
11134792Smckusic 		fs->fs_cstotal.cs_ndir++;
11145322Smckusic 		fs->fs_cs(fs, cg).cs_ndir++;
11154359Smckusick 	}
11164359Smckusick 	bdwrite(bp);
11174359Smckusick 	return (cg * fs->fs_ipg + ipref);
11184359Smckusick }
11194359Smckusick 
11205375Smckusic /*
11215375Smckusic  * Free a block or fragment.
11225375Smckusic  *
11235375Smckusic  * The specified block or fragment is placed back in the
11245375Smckusic  * free map. If a fragment is deallocated, a possible
11255375Smckusic  * block reassembly is checked.
11265375Smckusic  */
112751469Sbostic ffs_blkfree(ip, bno, size)
11285965Smckusic 	register struct inode *ip;
11294359Smckusick 	daddr_t bno;
113053059Smckusick 	long size;
11314359Smckusick {
11324359Smckusick 	register struct fs *fs;
11334359Smckusick 	register struct cg *cgp;
113437735Smckusick 	struct buf *bp;
113565999Smckusick 	daddr_t blkno;
113665999Smckusick 	int i, error, cg, blk, frags, bbase;
11374359Smckusick 
11385965Smckusic 	fs = ip->i_fs;
113964508Sbostic 	if ((u_int)size > fs->fs_bsize || fragoff(fs, size) != 0) {
11406716Smckusick 		printf("dev = 0x%x, bsize = %d, size = %d, fs = %s\n",
11416716Smckusick 		    ip->i_dev, fs->fs_bsize, size, fs->fs_fsmnt);
114231402Smckusick 		panic("blkfree: bad size");
11436716Smckusick 	}
11445377Smckusic 	cg = dtog(fs, bno);
114564508Sbostic 	if ((u_int)bno >= fs->fs_size) {
11466567Smckusic 		printf("bad block %d, ino %d\n", bno, ip->i_number);
114753244Smckusick 		ffs_fserr(fs, ip->i_uid, "bad block");
11484359Smckusick 		return;
11496567Smckusic 	}
115037735Smckusick 	error = bread(ip->i_devvp, fsbtodb(fs, cgtod(fs, cg)),
115138776Smckusick 		(int)fs->fs_cgsize, NOCRED, &bp);
115237735Smckusick 	if (error) {
115337735Smckusick 		brelse(bp);
115437735Smckusick 		return;
115537735Smckusick 	}
115664508Sbostic 	cgp = (struct cg *)bp->b_data;
115737735Smckusick 	if (!cg_chkmagic(cgp)) {
11585960Smckusic 		brelse(bp);
11594359Smckusick 		return;
11605960Smckusic 	}
11618105Sroot 	cgp->cg_time = time.tv_sec;
11625377Smckusic 	bno = dtogd(fs, bno);
11635322Smckusic 	if (size == fs->fs_bsize) {
116465999Smckusick 		blkno = fragstoblks(fs, bno);
116565999Smckusick 		if (ffs_isblock(fs, cg_blksfree(cgp), blkno)) {
11666716Smckusick 			printf("dev = 0x%x, block = %d, fs = %s\n",
11676716Smckusick 			    ip->i_dev, bno, fs->fs_fsmnt);
116831402Smckusick 			panic("blkfree: freeing free block");
11696567Smckusic 		}
117065999Smckusick 		ffs_setblock(fs, cg_blksfree(cgp), blkno);
117165999Smckusick 		ffs_clusteracct(fs, cgp, blkno, 1);
11724792Smckusic 		cgp->cg_cs.cs_nbfree++;
11734792Smckusic 		fs->fs_cstotal.cs_nbfree++;
11745322Smckusic 		fs->fs_cs(fs, cg).cs_nbfree++;
11755375Smckusic 		i = cbtocylno(fs, bno);
117634143Smckusick 		cg_blks(fs, cgp, i)[cbtorpos(fs, bno)]++;
117734143Smckusick 		cg_blktot(cgp)[i]++;
11784426Smckusic 	} else {
117917224Smckusick 		bbase = bno - fragnum(fs, bno);
11804463Smckusic 		/*
11814463Smckusic 		 * decrement the counts associated with the old frags
11824463Smckusic 		 */
118334143Smckusick 		blk = blkmap(fs, cg_blksfree(cgp), bbase);
118451469Sbostic 		ffs_fragacct(fs, blk, cgp->cg_frsum, -1);
11854463Smckusic 		/*
11864463Smckusic 		 * deallocate the fragment
11874463Smckusic 		 */
11885960Smckusic 		frags = numfrags(fs, size);
11894463Smckusic 		for (i = 0; i < frags; i++) {
119034143Smckusick 			if (isset(cg_blksfree(cgp), bno + i)) {
11916716Smckusick 				printf("dev = 0x%x, block = %d, fs = %s\n",
11926716Smckusick 				    ip->i_dev, bno + i, fs->fs_fsmnt);
119331402Smckusick 				panic("blkfree: freeing free frag");
11946716Smckusick 			}
119534143Smckusick 			setbit(cg_blksfree(cgp), bno + i);
11964426Smckusic 		}
11976294Smckusick 		cgp->cg_cs.cs_nffree += i;
11986294Smckusick 		fs->fs_cstotal.cs_nffree += i;
11996294Smckusick 		fs->fs_cs(fs, cg).cs_nffree += i;
12004463Smckusic 		/*
12014463Smckusic 		 * add back in counts associated with the new frags
12024463Smckusic 		 */
120334143Smckusick 		blk = blkmap(fs, cg_blksfree(cgp), bbase);
120451469Sbostic 		ffs_fragacct(fs, blk, cgp->cg_frsum, 1);
12054463Smckusic 		/*
12064463Smckusic 		 * if a complete block has been reassembled, account for it
12074463Smckusic 		 */
120865999Smckusick 		blkno = fragstoblks(fs, bbase);
120965999Smckusick 		if (ffs_isblock(fs, cg_blksfree(cgp), blkno)) {
12105322Smckusic 			cgp->cg_cs.cs_nffree -= fs->fs_frag;
12115322Smckusic 			fs->fs_cstotal.cs_nffree -= fs->fs_frag;
12125322Smckusic 			fs->fs_cs(fs, cg).cs_nffree -= fs->fs_frag;
121365999Smckusick 			ffs_clusteracct(fs, cgp, blkno, 1);
12144792Smckusic 			cgp->cg_cs.cs_nbfree++;
12154792Smckusic 			fs->fs_cstotal.cs_nbfree++;
12165322Smckusic 			fs->fs_cs(fs, cg).cs_nbfree++;
12175375Smckusic 			i = cbtocylno(fs, bbase);
121834143Smckusick 			cg_blks(fs, cgp, i)[cbtorpos(fs, bbase)]++;
121934143Smckusick 			cg_blktot(cgp)[i]++;
12204426Smckusic 		}
12214426Smckusic 	}
122250893Smckusick 	fs->fs_fmod = 1;
12234359Smckusick 	bdwrite(bp);
12244359Smckusick }
12254359Smckusick 
12265375Smckusic /*
12275375Smckusic  * Free an inode.
12285375Smckusic  *
12295375Smckusic  * The specified inode is placed back in the free map.
12305375Smckusic  */
123153577Sheideman int
123254653Smckusick ffs_vfree(ap)
123354653Smckusick 	struct vop_vfree_args /* {
123454653Smckusick 		struct vnode *a_pvp;
123554653Smckusick 		ino_t a_ino;
123654653Smckusick 		int a_mode;
123754653Smckusick 	} */ *ap;
12384359Smckusick {
12394359Smckusick 	register struct fs *fs;
12404359Smckusick 	register struct cg *cgp;
124151541Smckusick 	register struct inode *pip;
124254653Smckusick 	ino_t ino = ap->a_ino;
124337735Smckusick 	struct buf *bp;
124437735Smckusick 	int error, cg;
12454359Smckusick 
124653583Sheideman 	pip = VTOI(ap->a_pvp);
124751469Sbostic 	fs = pip->i_fs;
124854653Smckusick 	if ((u_int)ino >= fs->fs_ipg * fs->fs_ncg)
124954653Smckusick 		panic("ifree: range: dev = 0x%x, ino = %d, fs = %s\n",
125054653Smckusick 		    pip->i_dev, ino, fs->fs_fsmnt);
125164603Sbostic 	cg = ino_to_cg(fs, ino);
125251469Sbostic 	error = bread(pip->i_devvp, fsbtodb(fs, cgtod(fs, cg)),
125338776Smckusick 		(int)fs->fs_cgsize, NOCRED, &bp);
125437735Smckusick 	if (error) {
125537735Smckusick 		brelse(bp);
125653577Sheideman 		return (0);
125737735Smckusick 	}
125864508Sbostic 	cgp = (struct cg *)bp->b_data;
125937735Smckusick 	if (!cg_chkmagic(cgp)) {
12605960Smckusic 		brelse(bp);
126153577Sheideman 		return (0);
12625960Smckusic 	}
12638105Sroot 	cgp->cg_time = time.tv_sec;
126454653Smckusick 	ino %= fs->fs_ipg;
126554653Smckusick 	if (isclr(cg_inosused(cgp), ino)) {
126654653Smckusick 		printf("dev = 0x%x, ino = %d, fs = %s\n",
126754653Smckusick 		    pip->i_dev, ino, fs->fs_fsmnt);
126848057Smckusick 		if (fs->fs_ronly == 0)
126948057Smckusick 			panic("ifree: freeing free inode");
12706716Smckusick 	}
127154653Smckusick 	clrbit(cg_inosused(cgp), ino);
127254653Smckusick 	if (ino < cgp->cg_irotor)
127354653Smckusick 		cgp->cg_irotor = ino;
12744792Smckusic 	cgp->cg_cs.cs_nifree++;
12754792Smckusic 	fs->fs_cstotal.cs_nifree++;
12765322Smckusic 	fs->fs_cs(fs, cg).cs_nifree++;
127753583Sheideman 	if ((ap->a_mode & IFMT) == IFDIR) {
12784792Smckusic 		cgp->cg_cs.cs_ndir--;
12794792Smckusic 		fs->fs_cstotal.cs_ndir--;
12805322Smckusic 		fs->fs_cs(fs, cg).cs_ndir--;
12814359Smckusick 	}
128250893Smckusick 	fs->fs_fmod = 1;
12834359Smckusick 	bdwrite(bp);
128453577Sheideman 	return (0);
12854359Smckusick }
12864359Smckusick 
12874463Smckusic /*
12885375Smckusic  * Find a block of the specified size in the specified cylinder group.
12895375Smckusic  *
12904651Smckusic  * It is a panic if a request is made to find a block if none are
12914651Smckusic  * available.
12924651Smckusic  */
129351469Sbostic static daddr_t
129451469Sbostic ffs_mapsearch(fs, cgp, bpref, allocsiz)
12954651Smckusic 	register struct fs *fs;
12964651Smckusic 	register struct cg *cgp;
12974651Smckusic 	daddr_t bpref;
12984651Smckusic 	int allocsiz;
12994651Smckusic {
13004651Smckusic 	daddr_t bno;
13014651Smckusic 	int start, len, loc, i;
13024651Smckusic 	int blk, field, subfield, pos;
13034651Smckusic 
13044651Smckusic 	/*
13054651Smckusic 	 * find the fragment by searching through the free block
13064651Smckusic 	 * map for an appropriate bit pattern
13074651Smckusic 	 */
13084651Smckusic 	if (bpref)
13095377Smckusic 		start = dtogd(fs, bpref) / NBBY;
13104651Smckusic 	else
13114651Smckusic 		start = cgp->cg_frotor / NBBY;
13125398Smckusic 	len = howmany(fs->fs_fpg, NBBY) - start;
131364508Sbostic 	loc = scanc((u_int)len, (u_char *)&cg_blksfree(cgp)[start],
131434476Smckusick 		(u_char *)fragtbl[fs->fs_frag],
131534476Smckusick 		(u_char)(1 << (allocsiz - 1 + (fs->fs_frag % NBBY))));
13164651Smckusic 	if (loc == 0) {
13176531Smckusick 		len = start + 1;
13186531Smckusick 		start = 0;
131964508Sbostic 		loc = scanc((u_int)len, (u_char *)&cg_blksfree(cgp)[0],
132034476Smckusick 			(u_char *)fragtbl[fs->fs_frag],
132134476Smckusick 			(u_char)(1 << (allocsiz - 1 + (fs->fs_frag % NBBY))));
132216784Smckusick 		if (loc == 0) {
132316784Smckusick 			printf("start = %d, len = %d, fs = %s\n",
132416784Smckusick 			    start, len, fs->fs_fsmnt);
132551469Sbostic 			panic("ffs_alloccg: map corrupted");
132617697Smckusick 			/* NOTREACHED */
132716784Smckusick 		}
13284651Smckusic 	}
13294651Smckusic 	bno = (start + len - loc) * NBBY;
13304651Smckusic 	cgp->cg_frotor = bno;
13314651Smckusic 	/*
13324651Smckusic 	 * found the byte in the map
13334651Smckusic 	 * sift through the bits to find the selected frag
13344651Smckusic 	 */
13356294Smckusick 	for (i = bno + NBBY; bno < i; bno += fs->fs_frag) {
133634143Smckusick 		blk = blkmap(fs, cg_blksfree(cgp), bno);
13374651Smckusic 		blk <<= 1;
13384651Smckusic 		field = around[allocsiz];
13394651Smckusic 		subfield = inside[allocsiz];
13405322Smckusic 		for (pos = 0; pos <= fs->fs_frag - allocsiz; pos++) {
13416294Smckusick 			if ((blk & field) == subfield)
13426294Smckusick 				return (bno + pos);
13434651Smckusic 			field <<= 1;
13444651Smckusic 			subfield <<= 1;
13454651Smckusic 		}
13464651Smckusic 	}
13476716Smckusick 	printf("bno = %d, fs = %s\n", bno, fs->fs_fsmnt);
134851469Sbostic 	panic("ffs_alloccg: block not in map");
13496531Smckusick 	return (-1);
13504651Smckusic }
13514651Smckusic 
13524651Smckusic /*
135365999Smckusick  * Update the cluster map because of an allocation or free.
135465999Smckusick  *
135565999Smckusick  * Cnt == 1 means free; cnt == -1 means allocating.
135665999Smckusick  */
135765999Smckusick ffs_clusteracct(fs, cgp, blkno, cnt)
135865999Smckusick 	struct fs *fs;
135965999Smckusick 	struct cg *cgp;
136065999Smckusick 	daddr_t blkno;
136165999Smckusick 	int cnt;
136265999Smckusick {
136365999Smckusick 	long *sump;
136465999Smckusick 	u_char *freemapp, *mapp;
136565999Smckusick 	int i, start, end, forw, back, map, bit;
136665999Smckusick 
136765999Smckusick 	if (fs->fs_contigsumsize <= 0)
136865999Smckusick 		return;
136965999Smckusick 	freemapp = cg_clustersfree(cgp);
137065999Smckusick 	sump = cg_clustersum(cgp);
137165999Smckusick 	/*
137265999Smckusick 	 * Allocate or clear the actual block.
137365999Smckusick 	 */
137465999Smckusick 	if (cnt > 0)
137565999Smckusick 		setbit(freemapp, blkno);
137665999Smckusick 	else
137765999Smckusick 		clrbit(freemapp, blkno);
137865999Smckusick 	/*
137965999Smckusick 	 * Find the size of the cluster going forward.
138065999Smckusick 	 */
138165999Smckusick 	start = blkno + 1;
138265999Smckusick 	end = start + fs->fs_contigsumsize;
138365999Smckusick 	if (end >= cgp->cg_nclusterblks)
138465999Smckusick 		end = cgp->cg_nclusterblks;
138565999Smckusick 	mapp = &freemapp[start / NBBY];
138665999Smckusick 	map = *mapp++;
138765999Smckusick 	bit = 1 << (start % NBBY);
138865999Smckusick 	for (i = start; i < end; i++) {
138965999Smckusick 		if ((map & bit) == 0)
139065999Smckusick 			break;
139165999Smckusick 		if ((i & (NBBY - 1)) != (NBBY - 1)) {
139265999Smckusick 			bit <<= 1;
139365999Smckusick 		} else {
139465999Smckusick 			map = *mapp++;
139565999Smckusick 			bit = 1;
139665999Smckusick 		}
139765999Smckusick 	}
139865999Smckusick 	forw = i - start;
139965999Smckusick 	/*
140065999Smckusick 	 * Find the size of the cluster going backward.
140165999Smckusick 	 */
140265999Smckusick 	start = blkno - 1;
140365999Smckusick 	end = start - fs->fs_contigsumsize;
140465999Smckusick 	if (end < 0)
140565999Smckusick 		end = -1;
140665999Smckusick 	mapp = &freemapp[start / NBBY];
140765999Smckusick 	map = *mapp--;
140865999Smckusick 	bit = 1 << (start % NBBY);
140965999Smckusick 	for (i = start; i > end; i--) {
141065999Smckusick 		if ((map & bit) == 0)
141165999Smckusick 			break;
141265999Smckusick 		if ((i & (NBBY - 1)) != 0) {
141365999Smckusick 			bit >>= 1;
141465999Smckusick 		} else {
141565999Smckusick 			map = *mapp--;
141665999Smckusick 			bit = 1 << (NBBY - 1);
141765999Smckusick 		}
141865999Smckusick 	}
141965999Smckusick 	back = start - i;
142065999Smckusick 	/*
142165999Smckusick 	 * Account for old cluster and the possibly new forward and
142265999Smckusick 	 * back clusters.
142365999Smckusick 	 */
142465999Smckusick 	i = back + forw + 1;
142565999Smckusick 	if (i > fs->fs_contigsumsize)
142665999Smckusick 		i = fs->fs_contigsumsize;
142765999Smckusick 	sump[i] += cnt;
142865999Smckusick 	if (back > 0)
142965999Smckusick 		sump[back] -= cnt;
143065999Smckusick 	if (forw > 0)
143165999Smckusick 		sump[forw] -= cnt;
143265999Smckusick }
143365999Smckusick 
143465999Smckusick /*
14355375Smckusic  * Fserr prints the name of a file system with an error diagnostic.
14365375Smckusic  *
14375375Smckusic  * The form of the error message is:
14384359Smckusick  *	fs: error message
14394359Smckusick  */
144051469Sbostic static void
144151469Sbostic ffs_fserr(fs, uid, cp)
14424359Smckusick 	struct fs *fs;
144351469Sbostic 	u_int uid;
14444359Smckusick 	char *cp;
14454359Smckusick {
14464359Smckusick 
144742318Smckusick 	log(LOG_ERR, "uid %d on %s: %s\n", uid, fs->fs_fsmnt, cp);
14484359Smckusick }
1449