xfs_alloc.c 94.3 KB
Newer Older
D
Dave Chinner 已提交
1
// SPDX-License-Identifier: GPL-2.0
L
Linus Torvalds 已提交
2
/*
3 4
 * Copyright (c) 2000-2002,2005 Silicon Graphics, Inc.
 * All Rights Reserved.
L
Linus Torvalds 已提交
5 6
 */
#include "xfs.h"
7
#include "xfs_fs.h"
8
#include "xfs_format.h"
9
#include "xfs_log_format.h"
10
#include "xfs_shared.h"
11
#include "xfs_trans_resv.h"
12
#include "xfs_bit.h"
L
Linus Torvalds 已提交
13
#include "xfs_mount.h"
14
#include "xfs_defer.h"
L
Linus Torvalds 已提交
15
#include "xfs_btree.h"
16
#include "xfs_rmap.h"
17
#include "xfs_alloc_btree.h"
L
Linus Torvalds 已提交
18
#include "xfs_alloc.h"
19
#include "xfs_extent_busy.h"
20
#include "xfs_errortag.h"
L
Linus Torvalds 已提交
21
#include "xfs_error.h"
C
Christoph Hellwig 已提交
22
#include "xfs_trace.h"
23
#include "xfs_trans.h"
D
Dave Chinner 已提交
24
#include "xfs_buf_item.h"
25
#include "xfs_log.h"
26
#include "xfs_ag.h"
27
#include "xfs_ag_resv.h"
28 29
#include "xfs_bmap.h"

30
struct kmem_cache	*xfs_extfree_item_cache;
L
Linus Torvalds 已提交
31

32
struct workqueue_struct *xfs_alloc_wq;
L
Linus Torvalds 已提交
33 34 35 36 37 38 39 40 41 42

#define XFS_ABSDIFF(a,b)	(((a) <= (b)) ? ((b) - (a)) : ((a) - (b)))

#define	XFSA_FIXUP_BNO_OK	1
#define	XFSA_FIXUP_CNT_OK	2

STATIC int xfs_alloc_ag_vextent_exact(xfs_alloc_arg_t *);
STATIC int xfs_alloc_ag_vextent_near(xfs_alloc_arg_t *);
STATIC int xfs_alloc_ag_vextent_size(xfs_alloc_arg_t *);

43 44 45 46 47 48 49 50 51 52 53
/*
 * Size of the AGFL.  For CRC-enabled filesystes we steal a couple of slots in
 * the beginning of the block for a proper header with the location information
 * and CRC.
 */
unsigned int
xfs_agfl_size(
	struct xfs_mount	*mp)
{
	unsigned int		size = mp->m_sb.sb_sectsize;

54
	if (xfs_has_crc(mp))
55 56 57 58 59
		size -= sizeof(struct xfs_agfl);

	return size / sizeof(xfs_agblock_t);
}

60 61 62 63
unsigned int
xfs_refc_block(
	struct xfs_mount	*mp)
{
64
	if (xfs_has_rmapbt(mp))
65
		return XFS_RMAP_BLOCK(mp) + 1;
66
	if (xfs_has_finobt(mp))
67 68 69 70
		return XFS_FIBT_BLOCK(mp) + 1;
	return XFS_IBT_BLOCK(mp) + 1;
}

71 72 73 74
xfs_extlen_t
xfs_prealloc_blocks(
	struct xfs_mount	*mp)
{
75
	if (xfs_has_reflink(mp))
76
		return xfs_refc_block(mp) + 1;
77
	if (xfs_has_rmapbt(mp))
78
		return XFS_RMAP_BLOCK(mp) + 1;
79
	if (xfs_has_finobt(mp))
80 81 82 83
		return XFS_FIBT_BLOCK(mp) + 1;
	return XFS_IBT_BLOCK(mp) + 1;
}

84
/*
85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102
 * The number of blocks per AG that we withhold from xfs_mod_fdblocks to
 * guarantee that we can refill the AGFL prior to allocating space in a nearly
 * full AG.  Although the the space described by the free space btrees, the
 * blocks used by the freesp btrees themselves, and the blocks owned by the
 * AGFL are counted in the ondisk fdblocks, it's a mistake to let the ondisk
 * free space in the AG drop so low that the free space btrees cannot refill an
 * empty AGFL up to the minimum level.  Rather than grind through empty AGs
 * until the fs goes down, we subtract this many AG blocks from the incore
 * fdblocks to ensure user allocation does not overcommit the space the
 * filesystem needs for the AGFLs.  The rmap btree uses a per-AG reservation to
 * withhold space from xfs_mod_fdblocks, so we do not account for that here.
 */
#define XFS_ALLOCBT_AGFL_RESERVE	4

/*
 * Compute the number of blocks that we set aside to guarantee the ability to
 * refill the AGFL and handle a full bmap btree split.
 *
103 104 105 106 107 108 109 110 111 112 113
 * In order to avoid ENOSPC-related deadlock caused by out-of-order locking of
 * AGF buffer (PV 947395), we place constraints on the relationship among
 * actual allocations for data blocks, freelist blocks, and potential file data
 * bmap btree blocks. However, these restrictions may result in no actual space
 * allocated for a delayed extent, for example, a data block in a certain AG is
 * allocated but there is no additional block for the additional bmap btree
 * block due to a split of the bmap btree of the file. The result of this may
 * lead to an infinite loop when the file gets flushed to disk and all delayed
 * extents need to be actually allocated. To get around this, we explicitly set
 * aside a few blocks which will not be reserved in delayed allocation.
 *
114 115
 * For each AG, we need to reserve enough blocks to replenish a totally empty
 * AGFL and 4 more to handle a potential split of the file's bmap btree.
116 117 118 119 120
 */
unsigned int
xfs_alloc_set_aside(
	struct xfs_mount	*mp)
{
121
	return mp->m_sb.sb_agcount * (XFS_ALLOCBT_AGFL_RESERVE + 4);
122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144
}

/*
 * When deciding how much space to allocate out of an AG, we limit the
 * allocation maximum size to the size the AG. However, we cannot use all the
 * blocks in the AG - some are permanently used by metadata. These
 * blocks are generally:
 *	- the AG superblock, AGF, AGI and AGFL
 *	- the AGF (bno and cnt) and AGI btree root blocks, and optionally
 *	  the AGI free inode and rmap btree root blocks.
 *	- blocks on the AGFL according to xfs_alloc_set_aside() limits
 *	- the rmapbt root block
 *
 * The AG headers are sector sized, so the amount of space they take up is
 * dependent on filesystem geometry. The others are all single blocks.
 */
unsigned int
xfs_alloc_ag_max_usable(
	struct xfs_mount	*mp)
{
	unsigned int		blocks;

	blocks = XFS_BB_TO_FSB(mp, XFS_FSS_TO_BB(mp, 4)); /* ag headers */
145
	blocks += XFS_ALLOCBT_AGFL_RESERVE;
146
	blocks += 3;			/* AGF, AGI btree root blocks */
147
	if (xfs_has_finobt(mp))
148
		blocks++;		/* finobt root block */
149
	if (xfs_has_rmapbt(mp))
150
		blocks++;		/* rmap root block */
151
	if (xfs_has_reflink(mp))
152
		blocks++;		/* refcount root block */
153 154 155 156

	return mp->m_sb.sb_agblocks - blocks;
}

157 158 159 160 161 162 163 164 165 166
/*
 * Lookup the record equal to [bno, len] in the btree given by cur.
 */
STATIC int				/* error */
xfs_alloc_lookup_eq(
	struct xfs_btree_cur	*cur,	/* btree cursor */
	xfs_agblock_t		bno,	/* starting block of extent */
	xfs_extlen_t		len,	/* length of extent */
	int			*stat)	/* success/failure */
{
167 168
	int			error;

169 170
	cur->bc_rec.a.ar_startblock = bno;
	cur->bc_rec.a.ar_blockcount = len;
171
	error = xfs_btree_lookup(cur, XFS_LOOKUP_EQ, stat);
172
	cur->bc_ag.abt.active = (*stat == 1);
173
	return error;
174 175 176 177 178 179
}

/*
 * Lookup the first record greater than or equal to [bno, len]
 * in the btree given by cur.
 */
180
int				/* error */
181 182 183 184 185 186
xfs_alloc_lookup_ge(
	struct xfs_btree_cur	*cur,	/* btree cursor */
	xfs_agblock_t		bno,	/* starting block of extent */
	xfs_extlen_t		len,	/* length of extent */
	int			*stat)	/* success/failure */
{
187 188
	int			error;

189 190
	cur->bc_rec.a.ar_startblock = bno;
	cur->bc_rec.a.ar_blockcount = len;
191
	error = xfs_btree_lookup(cur, XFS_LOOKUP_GE, stat);
192
	cur->bc_ag.abt.active = (*stat == 1);
193
	return error;
194 195 196 197 198 199
}

/*
 * Lookup the first record less than or equal to [bno, len]
 * in the btree given by cur.
 */
200
int					/* error */
201 202 203 204 205 206
xfs_alloc_lookup_le(
	struct xfs_btree_cur	*cur,	/* btree cursor */
	xfs_agblock_t		bno,	/* starting block of extent */
	xfs_extlen_t		len,	/* length of extent */
	int			*stat)	/* success/failure */
{
207
	int			error;
208 209
	cur->bc_rec.a.ar_startblock = bno;
	cur->bc_rec.a.ar_blockcount = len;
210
	error = xfs_btree_lookup(cur, XFS_LOOKUP_LE, stat);
211
	cur->bc_ag.abt.active = (*stat == 1);
212 213 214 215 216 217 218
	return error;
}

static inline bool
xfs_alloc_cur_active(
	struct xfs_btree_cur	*cur)
{
219
	return cur && cur->bc_ag.abt.active;
220 221
}

222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238
/*
 * Update the record referred to by cur to the value given
 * by [bno, len].
 * This either works (return 0) or gets an EFSCORRUPTED error.
 */
STATIC int				/* error */
xfs_alloc_update(
	struct xfs_btree_cur	*cur,	/* btree cursor */
	xfs_agblock_t		bno,	/* starting block of extent */
	xfs_extlen_t		len)	/* length of extent */
{
	union xfs_btree_rec	rec;

	rec.alloc.ar_startblock = cpu_to_be32(bno);
	rec.alloc.ar_blockcount = cpu_to_be32(len);
	return xfs_btree_update(cur, &rec);
}
239

240 241 242
/*
 * Get the data from the pointed-to record.
 */
C
Christoph Hellwig 已提交
243
int					/* error */
244 245 246 247 248 249
xfs_alloc_get_rec(
	struct xfs_btree_cur	*cur,	/* btree cursor */
	xfs_agblock_t		*bno,	/* output: starting block of extent */
	xfs_extlen_t		*len,	/* output: length of extent */
	int			*stat)	/* output: success/failure */
{
250
	struct xfs_mount	*mp = cur->bc_mp;
251
	xfs_agnumber_t		agno = cur->bc_ag.pag->pag_agno;
252 253 254 255
	union xfs_btree_rec	*rec;
	int			error;

	error = xfs_btree_get_rec(cur, &rec, stat);
256 257 258 259 260 261
	if (error || !(*stat))
		return error;

	*bno = be32_to_cpu(rec->alloc.ar_startblock);
	*len = be32_to_cpu(rec->alloc.ar_blockcount);

262 263 264
	if (*len == 0)
		goto out_bad_rec;

265 266 267 268 269 270 271 272 273 274 275 276 277 278 279 280 281
	/* check for valid extent range, including overflow */
	if (!xfs_verify_agbno(mp, agno, *bno))
		goto out_bad_rec;
	if (*bno > *bno + *len)
		goto out_bad_rec;
	if (!xfs_verify_agbno(mp, agno, *bno + *len - 1))
		goto out_bad_rec;

	return 0;

out_bad_rec:
	xfs_warn(mp,
		"%s Freespace BTree record corruption in AG %d detected!",
		cur->bc_btnum == XFS_BTNUM_BNO ? "Block" : "Size", agno);
	xfs_warn(mp,
		"start block 0x%x block count 0x%x", *bno, *len);
	return -EFSCORRUPTED;
282 283
}

L
Linus Torvalds 已提交
284 285 286 287
/*
 * Compute aligned version of the found extent.
 * Takes alignment and min length into account.
 */
288
STATIC bool
L
Linus Torvalds 已提交
289
xfs_alloc_compute_aligned(
290
	xfs_alloc_arg_t	*args,		/* allocation argument structure */
L
Linus Torvalds 已提交
291 292 293
	xfs_agblock_t	foundbno,	/* starting block in found extent */
	xfs_extlen_t	foundlen,	/* length in found extent */
	xfs_agblock_t	*resbno,	/* result block number */
294 295
	xfs_extlen_t	*reslen,	/* result length */
	unsigned	*busy_gen)
L
Linus Torvalds 已提交
296
{
297 298
	xfs_agblock_t	bno = foundbno;
	xfs_extlen_t	len = foundlen;
299
	xfs_extlen_t	diff;
300
	bool		busy;
L
Linus Torvalds 已提交
301

302
	/* Trim busy sections out of found extent */
303
	busy = xfs_extent_busy_trim(args, &bno, &len, busy_gen);
304

305 306 307 308 309 310 311 312 313 314 315 316
	/*
	 * If we have a largish extent that happens to start before min_agbno,
	 * see if we can shift it into range...
	 */
	if (bno < args->min_agbno && bno + len > args->min_agbno) {
		diff = args->min_agbno - bno;
		if (len > diff) {
			bno += diff;
			len -= diff;
		}
	}

317 318
	if (args->alignment > 1 && len >= args->minlen) {
		xfs_agblock_t	aligned_bno = roundup(bno, args->alignment);
319 320

		diff = aligned_bno - bno;
321 322 323

		*resbno = aligned_bno;
		*reslen = diff >= len ? 0 : len - diff;
L
Linus Torvalds 已提交
324
	} else {
325 326
		*resbno = bno;
		*reslen = len;
L
Linus Torvalds 已提交
327
	}
328 329

	return busy;
L
Linus Torvalds 已提交
330 331 332 333 334 335 336 337 338 339 340
}

/*
 * Compute best start block and diff for "near" allocations.
 * freelen >= wantlen already checked by caller.
 */
STATIC xfs_extlen_t			/* difference value (absolute) */
xfs_alloc_compute_diff(
	xfs_agblock_t	wantbno,	/* target starting block */
	xfs_extlen_t	wantlen,	/* target length */
	xfs_extlen_t	alignment,	/* target alignment */
341
	int		datatype,	/* are we allocating data? */
L
Linus Torvalds 已提交
342 343 344 345 346 347 348 349 350 351
	xfs_agblock_t	freebno,	/* freespace's starting block */
	xfs_extlen_t	freelen,	/* freespace's length */
	xfs_agblock_t	*newbnop)	/* result: best start block from free */
{
	xfs_agblock_t	freeend;	/* end of freespace extent */
	xfs_agblock_t	newbno1;	/* return block number */
	xfs_agblock_t	newbno2;	/* other new block number */
	xfs_extlen_t	newlen1=0;	/* length with newbno1 */
	xfs_extlen_t	newlen2=0;	/* length with newbno2 */
	xfs_agblock_t	wantend;	/* end of target extent */
352
	bool		userdata = datatype & XFS_ALLOC_USERDATA;
L
Linus Torvalds 已提交
353 354 355 356

	ASSERT(freelen >= wantlen);
	freeend = freebno + freelen;
	wantend = wantbno + wantlen;
357 358 359 360 361 362 363 364
	/*
	 * We want to allocate from the start of a free extent if it is past
	 * the desired block or if we are allocating user data and the free
	 * extent is before desired block. The second case is there to allow
	 * for contiguous allocation from the remaining free space if the file
	 * grows in the short term.
	 */
	if (freebno >= wantbno || (userdata && freeend < wantend)) {
L
Linus Torvalds 已提交
365 366 367 368 369 370 371 372 373 374 375 376 377 378 379 380 381 382 383 384 385 386 387 388 389 390 391 392 393 394 395 396 397 398 399 400 401 402 403 404 405 406 407 408 409 410 411 412 413 414 415 416 417 418 419 420 421 422 423
		if ((newbno1 = roundup(freebno, alignment)) >= freeend)
			newbno1 = NULLAGBLOCK;
	} else if (freeend >= wantend && alignment > 1) {
		newbno1 = roundup(wantbno, alignment);
		newbno2 = newbno1 - alignment;
		if (newbno1 >= freeend)
			newbno1 = NULLAGBLOCK;
		else
			newlen1 = XFS_EXTLEN_MIN(wantlen, freeend - newbno1);
		if (newbno2 < freebno)
			newbno2 = NULLAGBLOCK;
		else
			newlen2 = XFS_EXTLEN_MIN(wantlen, freeend - newbno2);
		if (newbno1 != NULLAGBLOCK && newbno2 != NULLAGBLOCK) {
			if (newlen1 < newlen2 ||
			    (newlen1 == newlen2 &&
			     XFS_ABSDIFF(newbno1, wantbno) >
			     XFS_ABSDIFF(newbno2, wantbno)))
				newbno1 = newbno2;
		} else if (newbno2 != NULLAGBLOCK)
			newbno1 = newbno2;
	} else if (freeend >= wantend) {
		newbno1 = wantbno;
	} else if (alignment > 1) {
		newbno1 = roundup(freeend - wantlen, alignment);
		if (newbno1 > freeend - wantlen &&
		    newbno1 - alignment >= freebno)
			newbno1 -= alignment;
		else if (newbno1 >= freeend)
			newbno1 = NULLAGBLOCK;
	} else
		newbno1 = freeend - wantlen;
	*newbnop = newbno1;
	return newbno1 == NULLAGBLOCK ? 0 : XFS_ABSDIFF(newbno1, wantbno);
}

/*
 * Fix up the length, based on mod and prod.
 * len should be k * prod + mod for some k.
 * If len is too small it is returned unchanged.
 * If len hits maxlen it is left alone.
 */
STATIC void
xfs_alloc_fix_len(
	xfs_alloc_arg_t	*args)		/* allocation argument structure */
{
	xfs_extlen_t	k;
	xfs_extlen_t	rlen;

	ASSERT(args->mod < args->prod);
	rlen = args->len;
	ASSERT(rlen >= args->minlen);
	ASSERT(rlen <= args->maxlen);
	if (args->prod <= 1 || rlen < args->mod || rlen == args->maxlen ||
	    (args->mod == 0 && rlen < args->prod))
		return;
	k = rlen % args->prod;
	if (k == args->mod)
		return;
424 425 426 427
	if (k > args->mod)
		rlen = rlen - (k - args->mod);
	else
		rlen = rlen - args->prod + (args->mod - k);
428
	/* casts to (int) catch length underflows */
429 430 431 432
	if ((int)rlen < (int)args->minlen)
		return;
	ASSERT(rlen >= args->minlen && rlen <= args->maxlen);
	ASSERT(rlen % args->prod == args->mod);
433 434
	ASSERT(args->pag->pagf_freeblks + args->pag->pagf_flcount >=
		rlen + args->minleft);
L
Linus Torvalds 已提交
435 436 437 438 439 440 441 442 443 444 445 446
	args->len = rlen;
}

/*
 * Update the two btrees, logically removing from freespace the extent
 * starting at rbno, rlen blocks.  The extent is contained within the
 * actual (current) free extent fbno for flen blocks.
 * Flags are passed in indicating whether the cursors are set to the
 * relevant records.
 */
STATIC int				/* error code */
xfs_alloc_fixup_trees(
447 448
	struct xfs_btree_cur *cnt_cur,	/* cursor for by-size btree */
	struct xfs_btree_cur *bno_cur,	/* cursor for by-block btree */
L
Linus Torvalds 已提交
449 450 451 452 453 454 455 456 457 458 459 460
	xfs_agblock_t	fbno,		/* starting block of free extent */
	xfs_extlen_t	flen,		/* length of free extent */
	xfs_agblock_t	rbno,		/* starting block of returned extent */
	xfs_extlen_t	rlen,		/* length of returned extent */
	int		flags)		/* flags, XFSA_FIXUP_... */
{
	int		error;		/* error code */
	int		i;		/* operation results */
	xfs_agblock_t	nfbno1;		/* first new free startblock */
	xfs_agblock_t	nfbno2;		/* second new free startblock */
	xfs_extlen_t	nflen1=0;	/* first new free length */
	xfs_extlen_t	nflen2=0;	/* second new free length */
461 462 463
	struct xfs_mount *mp;

	mp = cnt_cur->bc_mp;
L
Linus Torvalds 已提交
464 465 466 467 468 469 470 471

	/*
	 * Look up the record in the by-size tree if necessary.
	 */
	if (flags & XFSA_FIXUP_CNT_OK) {
#ifdef DEBUG
		if ((error = xfs_alloc_get_rec(cnt_cur, &nfbno1, &nflen1, &i)))
			return error;
472 473 474 475 476
		if (XFS_IS_CORRUPT(mp,
				   i != 1 ||
				   nfbno1 != fbno ||
				   nflen1 != flen))
			return -EFSCORRUPTED;
L
Linus Torvalds 已提交
477 478 479 480
#endif
	} else {
		if ((error = xfs_alloc_lookup_eq(cnt_cur, fbno, flen, &i)))
			return error;
481 482
		if (XFS_IS_CORRUPT(mp, i != 1))
			return -EFSCORRUPTED;
L
Linus Torvalds 已提交
483 484 485 486 487 488 489 490
	}
	/*
	 * Look up the record in the by-block tree if necessary.
	 */
	if (flags & XFSA_FIXUP_BNO_OK) {
#ifdef DEBUG
		if ((error = xfs_alloc_get_rec(bno_cur, &nfbno1, &nflen1, &i)))
			return error;
491 492 493 494 495
		if (XFS_IS_CORRUPT(mp,
				   i != 1 ||
				   nfbno1 != fbno ||
				   nflen1 != flen))
			return -EFSCORRUPTED;
L
Linus Torvalds 已提交
496 497 498 499
#endif
	} else {
		if ((error = xfs_alloc_lookup_eq(bno_cur, fbno, flen, &i)))
			return error;
500 501
		if (XFS_IS_CORRUPT(mp, i != 1))
			return -EFSCORRUPTED;
L
Linus Torvalds 已提交
502
	}
503

L
Linus Torvalds 已提交
504
#ifdef DEBUG
505 506 507 508
	if (bno_cur->bc_nlevels == 1 && cnt_cur->bc_nlevels == 1) {
		struct xfs_btree_block	*bnoblock;
		struct xfs_btree_block	*cntblock;

509 510
		bnoblock = XFS_BUF_TO_BLOCK(bno_cur->bc_levels[0].bp);
		cntblock = XFS_BUF_TO_BLOCK(cnt_cur->bc_levels[0].bp);
L
Linus Torvalds 已提交
511

512 513 514 515
		if (XFS_IS_CORRUPT(mp,
				   bnoblock->bb_numrecs !=
				   cntblock->bb_numrecs))
			return -EFSCORRUPTED;
L
Linus Torvalds 已提交
516 517
	}
#endif
518

L
Linus Torvalds 已提交
519 520 521 522 523 524 525 526 527 528 529 530 531 532 533 534 535 536 537 538 539 540 541 542
	/*
	 * Deal with all four cases: the allocated record is contained
	 * within the freespace record, so we can have new freespace
	 * at either (or both) end, or no freespace remaining.
	 */
	if (rbno == fbno && rlen == flen)
		nfbno1 = nfbno2 = NULLAGBLOCK;
	else if (rbno == fbno) {
		nfbno1 = rbno + rlen;
		nflen1 = flen - rlen;
		nfbno2 = NULLAGBLOCK;
	} else if (rbno + rlen == fbno + flen) {
		nfbno1 = fbno;
		nflen1 = flen - rlen;
		nfbno2 = NULLAGBLOCK;
	} else {
		nfbno1 = fbno;
		nflen1 = rbno - fbno;
		nfbno2 = rbno + rlen;
		nflen2 = (fbno + flen) - nfbno2;
	}
	/*
	 * Delete the entry from the by-size btree.
	 */
543
	if ((error = xfs_btree_delete(cnt_cur, &i)))
L
Linus Torvalds 已提交
544
		return error;
545 546
	if (XFS_IS_CORRUPT(mp, i != 1))
		return -EFSCORRUPTED;
L
Linus Torvalds 已提交
547 548 549 550 551 552
	/*
	 * Add new by-size btree entry(s).
	 */
	if (nfbno1 != NULLAGBLOCK) {
		if ((error = xfs_alloc_lookup_eq(cnt_cur, nfbno1, nflen1, &i)))
			return error;
553 554
		if (XFS_IS_CORRUPT(mp, i != 0))
			return -EFSCORRUPTED;
555
		if ((error = xfs_btree_insert(cnt_cur, &i)))
L
Linus Torvalds 已提交
556
			return error;
557 558
		if (XFS_IS_CORRUPT(mp, i != 1))
			return -EFSCORRUPTED;
L
Linus Torvalds 已提交
559 560 561 562
	}
	if (nfbno2 != NULLAGBLOCK) {
		if ((error = xfs_alloc_lookup_eq(cnt_cur, nfbno2, nflen2, &i)))
			return error;
563 564
		if (XFS_IS_CORRUPT(mp, i != 0))
			return -EFSCORRUPTED;
565
		if ((error = xfs_btree_insert(cnt_cur, &i)))
L
Linus Torvalds 已提交
566
			return error;
567 568
		if (XFS_IS_CORRUPT(mp, i != 1))
			return -EFSCORRUPTED;
L
Linus Torvalds 已提交
569 570 571 572 573 574 575 576
	}
	/*
	 * Fix up the by-block btree entry(s).
	 */
	if (nfbno1 == NULLAGBLOCK) {
		/*
		 * No remaining freespace, just delete the by-block tree entry.
		 */
577
		if ((error = xfs_btree_delete(bno_cur, &i)))
L
Linus Torvalds 已提交
578
			return error;
579 580
		if (XFS_IS_CORRUPT(mp, i != 1))
			return -EFSCORRUPTED;
L
Linus Torvalds 已提交
581 582 583 584 585 586 587 588 589 590 591 592 593
	} else {
		/*
		 * Update the by-block entry to start later|be shorter.
		 */
		if ((error = xfs_alloc_update(bno_cur, nfbno1, nflen1)))
			return error;
	}
	if (nfbno2 != NULLAGBLOCK) {
		/*
		 * 2 resulting free entries, need to add one.
		 */
		if ((error = xfs_alloc_lookup_eq(bno_cur, nfbno2, nflen2, &i)))
			return error;
594 595
		if (XFS_IS_CORRUPT(mp, i != 0))
			return -EFSCORRUPTED;
596
		if ((error = xfs_btree_insert(bno_cur, &i)))
L
Linus Torvalds 已提交
597
			return error;
598 599
		if (XFS_IS_CORRUPT(mp, i != 1))
			return -EFSCORRUPTED;
L
Linus Torvalds 已提交
600 601 602 603
	}
	return 0;
}

604
static xfs_failaddr_t
605
xfs_agfl_verify(
606 607
	struct xfs_buf	*bp)
{
608
	struct xfs_mount *mp = bp->b_mount;
609
	struct xfs_agfl	*agfl = XFS_BUF_TO_AGFL(bp);
610
	__be32		*agfl_bno = xfs_buf_to_agfl_bno(bp);
611 612
	int		i;

613 614 615 616 617 618
	/*
	 * There is no verification of non-crc AGFLs because mkfs does not
	 * initialise the AGFL to zero or NULL. Hence the only valid part of the
	 * AGFL is what the AGF says is active. We can't get to the AGF, so we
	 * can't verify just those entries are valid.
	 */
619
	if (!xfs_has_crc(mp))
620 621
		return NULL;

622
	if (!xfs_verify_magic(bp, agfl->agfl_magicnum))
623
		return __this_address;
624
	if (!uuid_equal(&agfl->agfl_uuid, &mp->m_sb.sb_meta_uuid))
625
		return __this_address;
626 627 628 629 630 631 632
	/*
	 * during growfs operations, the perag is not fully initialised,
	 * so we can't use it for any useful checking. growfs ensures we can't
	 * use it by using uncached buffers that don't have the perag attached
	 * so we can detect and avoid this problem.
	 */
	if (bp->b_pag && be32_to_cpu(agfl->agfl_seqno) != bp->b_pag->pag_agno)
633
		return __this_address;
634

635
	for (i = 0; i < xfs_agfl_size(mp); i++) {
636 637
		if (be32_to_cpu(agfl_bno[i]) != NULLAGBLOCK &&
		    be32_to_cpu(agfl_bno[i]) >= mp->m_sb.sb_agblocks)
638
			return __this_address;
639
	}
640

641 642 643
	if (!xfs_log_check_lsn(mp, be64_to_cpu(XFS_BUF_TO_AGFL(bp)->agfl_lsn)))
		return __this_address;
	return NULL;
644 645 646 647 648 649
}

static void
xfs_agfl_read_verify(
	struct xfs_buf	*bp)
{
650
	struct xfs_mount *mp = bp->b_mount;
651
	xfs_failaddr_t	fa;
652 653 654 655 656 657 658

	/*
	 * There is no verification of non-crc AGFLs because mkfs does not
	 * initialise the AGFL to zero or NULL. Hence the only valid part of the
	 * AGFL is what the AGF says is active. We can't get to the AGF, so we
	 * can't verify just those entries are valid.
	 */
659
	if (!xfs_has_crc(mp))
660 661
		return;

662
	if (!xfs_buf_verify_cksum(bp, XFS_AGFL_CRC_OFF))
663 664 665 666 667 668
		xfs_verifier_error(bp, -EFSBADCRC, __this_address);
	else {
		fa = xfs_agfl_verify(bp);
		if (fa)
			xfs_verifier_error(bp, -EFSCORRUPTED, fa);
	}
669 670
}

671
static void
672 673 674
xfs_agfl_write_verify(
	struct xfs_buf	*bp)
{
675
	struct xfs_mount	*mp = bp->b_mount;
C
Carlos Maiolino 已提交
676
	struct xfs_buf_log_item	*bip = bp->b_log_item;
677
	xfs_failaddr_t		fa;
678

679
	/* no verification of non-crc AGFLs */
680
	if (!xfs_has_crc(mp))
681 682
		return;

683 684 685
	fa = xfs_agfl_verify(bp);
	if (fa) {
		xfs_verifier_error(bp, -EFSCORRUPTED, fa);
686 687 688 689 690 691
		return;
	}

	if (bip)
		XFS_BUF_TO_AGFL(bp)->agfl_lsn = cpu_to_be64(bip->bli_item.li_lsn);

692
	xfs_buf_update_cksum(bp, XFS_AGFL_CRC_OFF);
693 694
}

695
const struct xfs_buf_ops xfs_agfl_buf_ops = {
696
	.name = "xfs_agfl",
697
	.magic = { cpu_to_be32(XFS_AGFL_MAGIC), cpu_to_be32(XFS_AGFL_MAGIC) },
698 699
	.verify_read = xfs_agfl_read_verify,
	.verify_write = xfs_agfl_write_verify,
700
	.verify_struct = xfs_agfl_verify,
701 702
};

L
Linus Torvalds 已提交
703 704 705
/*
 * Read in the allocation group free block array.
 */
706
int					/* error */
L
Linus Torvalds 已提交
707 708 709 710
xfs_alloc_read_agfl(
	xfs_mount_t	*mp,		/* mount point structure */
	xfs_trans_t	*tp,		/* transaction pointer */
	xfs_agnumber_t	agno,		/* allocation group number */
D
Dave Chinner 已提交
711
	struct xfs_buf	**bpp)		/* buffer for the ag free block array */
L
Linus Torvalds 已提交
712
{
D
Dave Chinner 已提交
713
	struct xfs_buf	*bp;		/* return value */
L
Linus Torvalds 已提交
714 715 716 717 718 719
	int		error;

	ASSERT(agno != NULLAGNUMBER);
	error = xfs_trans_read_buf(
			mp, tp, mp->m_ddev_targp,
			XFS_AG_DADDR(mp, agno, XFS_AGFL_DADDR(mp)),
720
			XFS_FSS_TO_BB(mp, 1), 0, &bp, &xfs_agfl_buf_ops);
L
Linus Torvalds 已提交
721 722
	if (error)
		return error;
723
	xfs_buf_set_ref(bp, XFS_AGFL_REF);
L
Linus Torvalds 已提交
724 725 726 727
	*bpp = bp;
	return 0;
}

728 729 730 731 732 733
STATIC int
xfs_alloc_update_counters(
	struct xfs_trans	*tp,
	struct xfs_buf		*agbp,
	long			len)
{
C
Christoph Hellwig 已提交
734
	struct xfs_agf		*agf = agbp->b_addr;
735

736
	agbp->b_pag->pagf_freeblks += len;
737 738 739
	be32_add_cpu(&agf->agf_freeblks, len);

	if (unlikely(be32_to_cpu(agf->agf_freeblks) >
740
		     be32_to_cpu(agf->agf_length))) {
741
		xfs_buf_mark_corrupt(agbp);
D
Dave Chinner 已提交
742
		return -EFSCORRUPTED;
743
	}
744 745 746 747 748

	xfs_alloc_log_agf(tp, agbp, XFS_AGF_FREEBLKS);
	return 0;
}

L
Linus Torvalds 已提交
749
/*
750
 * Block allocation algorithm and data structures.
L
Linus Torvalds 已提交
751
 */
752 753 754 755
struct xfs_alloc_cur {
	struct xfs_btree_cur		*cnt;	/* btree cursors */
	struct xfs_btree_cur		*bnolt;
	struct xfs_btree_cur		*bnogt;
756
	xfs_extlen_t			cur_len;/* current search length */
757 758 759 760 761
	xfs_agblock_t			rec_bno;/* extent startblock */
	xfs_extlen_t			rec_len;/* extent length */
	xfs_agblock_t			bno;	/* alloc bno */
	xfs_extlen_t			len;	/* alloc len */
	xfs_extlen_t			diff;	/* diff from search bno */
762 763
	unsigned int			busy_gen;/* busy state */
	bool				busy;
764 765 766 767 768 769 770 771 772 773 774 775 776 777 778 779 780
};

/*
 * Set up cursors, etc. in the extent allocation cursor. This function can be
 * called multiple times to reset an initialized structure without having to
 * reallocate cursors.
 */
static int
xfs_alloc_cur_setup(
	struct xfs_alloc_arg	*args,
	struct xfs_alloc_cur	*acur)
{
	int			error;
	int			i;

	ASSERT(args->alignment == 1 || args->type != XFS_ALLOCTYPE_THIS_BNO);

781
	acur->cur_len = args->maxlen;
782 783 784 785
	acur->rec_bno = 0;
	acur->rec_len = 0;
	acur->bno = 0;
	acur->len = 0;
786
	acur->diff = -1;
787 788 789
	acur->busy = false;
	acur->busy_gen = 0;

790 791 792 793 794 795 796
	/*
	 * Perform an initial cntbt lookup to check for availability of maxlen
	 * extents. If this fails, we'll return -ENOSPC to signal the caller to
	 * attempt a small allocation.
	 */
	if (!acur->cnt)
		acur->cnt = xfs_allocbt_init_cursor(args->mp, args->tp,
797
					args->agbp, args->pag, XFS_BTNUM_CNT);
798 799 800 801 802 803 804 805 806
	error = xfs_alloc_lookup_ge(acur->cnt, 0, args->maxlen, &i);
	if (error)
		return error;

	/*
	 * Allocate the bnobt left and right search cursors.
	 */
	if (!acur->bnolt)
		acur->bnolt = xfs_allocbt_init_cursor(args->mp, args->tp,
807
					args->agbp, args->pag, XFS_BTNUM_BNO);
808 809
	if (!acur->bnogt)
		acur->bnogt = xfs_allocbt_init_cursor(args->mp, args->tp,
810
					args->agbp, args->pag, XFS_BTNUM_BNO);
811 812 813 814 815 816 817 818 819 820 821 822 823 824 825 826 827 828 829 830 831
	return i == 1 ? 0 : -ENOSPC;
}

static void
xfs_alloc_cur_close(
	struct xfs_alloc_cur	*acur,
	bool			error)
{
	int			cur_error = XFS_BTREE_NOERROR;

	if (error)
		cur_error = XFS_BTREE_ERROR;

	if (acur->cnt)
		xfs_btree_del_cursor(acur->cnt, cur_error);
	if (acur->bnolt)
		xfs_btree_del_cursor(acur->bnolt, cur_error);
	if (acur->bnogt)
		xfs_btree_del_cursor(acur->bnogt, cur_error);
	acur->cnt = acur->bnolt = acur->bnogt = NULL;
}
L
Linus Torvalds 已提交
832

833 834 835 836 837 838 839 840 841 842 843 844 845 846 847 848 849 850 851
/*
 * Check an extent for allocation and track the best available candidate in the
 * allocation structure. The cursor is deactivated if it has entered an out of
 * range state based on allocation arguments. Optionally return the extent
 * extent geometry and allocation status if requested by the caller.
 */
static int
xfs_alloc_cur_check(
	struct xfs_alloc_arg	*args,
	struct xfs_alloc_cur	*acur,
	struct xfs_btree_cur	*cur,
	int			*new)
{
	int			error, i;
	xfs_agblock_t		bno, bnoa, bnew;
	xfs_extlen_t		len, lena, diff = -1;
	bool			busy;
	unsigned		busy_gen = 0;
	bool			deactivate = false;
852
	bool			isbnobt = cur->bc_btnum == XFS_BTNUM_BNO;
853 854 855 856 857 858

	*new = 0;

	error = xfs_alloc_get_rec(cur, &bno, &len, &i);
	if (error)
		return error;
859 860
	if (XFS_IS_CORRUPT(args->mp, i != 1))
		return -EFSCORRUPTED;
861 862 863 864 865 866

	/*
	 * Check minlen and deactivate a cntbt cursor if out of acceptable size
	 * range (i.e., walking backwards looking for a minlen extent).
	 */
	if (len < args->minlen) {
867
		deactivate = !isbnobt;
868 869 870 871 872 873 874 875 876
		goto out;
	}

	busy = xfs_alloc_compute_aligned(args, bno, len, &bnoa, &lena,
					 &busy_gen);
	acur->busy |= busy;
	if (busy)
		acur->busy_gen = busy_gen;
	/* deactivate a bnobt cursor outside of locality range */
877 878
	if (bnoa < args->min_agbno || bnoa > args->max_agbno) {
		deactivate = isbnobt;
879
		goto out;
880
	}
881 882 883 884 885 886 887 888 889 890 891 892 893 894 895 896 897 898 899
	if (lena < args->minlen)
		goto out;

	args->len = XFS_EXTLEN_MIN(lena, args->maxlen);
	xfs_alloc_fix_len(args);
	ASSERT(args->len >= args->minlen);
	if (args->len < acur->len)
		goto out;

	/*
	 * We have an aligned record that satisfies minlen and beats or matches
	 * the candidate extent size. Compare locality for near allocation mode.
	 */
	ASSERT(args->type == XFS_ALLOCTYPE_NEAR_BNO);
	diff = xfs_alloc_compute_diff(args->agbno, args->len,
				      args->alignment, args->datatype,
				      bnoa, lena, &bnew);
	if (bnew == NULLAGBLOCK)
		goto out;
900 901 902 903 904 905

	/*
	 * Deactivate a bnobt cursor with worse locality than the current best.
	 */
	if (diff > acur->diff) {
		deactivate = isbnobt;
906
		goto out;
907
	}
908 909 910 911 912 913 914 915 916 917

	ASSERT(args->len > acur->len ||
	       (args->len == acur->len && diff <= acur->diff));
	acur->rec_bno = bno;
	acur->rec_len = len;
	acur->bno = bnew;
	acur->len = args->len;
	acur->diff = diff;
	*new = 1;

918 919 920 921 922 923 924
	/*
	 * We're done if we found a perfect allocation. This only deactivates
	 * the current cursor, but this is just an optimization to terminate a
	 * cntbt search that otherwise runs to the edge of the tree.
	 */
	if (acur->diff == 0 && acur->len == args->maxlen)
		deactivate = true;
925 926
out:
	if (deactivate)
927
		cur->bc_ag.abt.active = false;
928 929 930 931 932
	trace_xfs_alloc_cur_check(args->mp, cur->bc_btnum, bno, len, diff,
				  *new);
	return 0;
}

933 934 935 936 937 938 939 940 941
/*
 * Complete an allocation of a candidate extent. Remove the extent from both
 * trees and update the args structure.
 */
STATIC int
xfs_alloc_cur_finish(
	struct xfs_alloc_arg	*args,
	struct xfs_alloc_cur	*acur)
{
C
Christoph Hellwig 已提交
942
	struct xfs_agf __maybe_unused *agf = args->agbp->b_addr;
943 944 945 946 947
	int			error;

	ASSERT(acur->cnt && acur->bnolt);
	ASSERT(acur->bno >= acur->rec_bno);
	ASSERT(acur->bno + acur->len <= acur->rec_bno + acur->rec_len);
C
Christoph Hellwig 已提交
948
	ASSERT(acur->rec_bno + acur->rec_len <= be32_to_cpu(agf->agf_length));
949 950 951 952 953 954 955 956 957 958 959 960 961 962

	error = xfs_alloc_fixup_trees(acur->cnt, acur->bnolt, acur->rec_bno,
				      acur->rec_len, acur->bno, acur->len, 0);
	if (error)
		return error;

	args->agbno = acur->bno;
	args->len = acur->len;
	args->wasfromfl = 0;

	trace_xfs_alloc_cur(args);
	return 0;
}

963 964 965 966 967 968 969 970 971 972 973 974 975 976 977 978 979 980 981 982 983 984 985 986 987 988 989 990 991 992 993 994 995 996 997 998 999 1000 1001 1002 1003 1004 1005 1006 1007 1008 1009 1010 1011 1012 1013 1014 1015 1016 1017 1018 1019 1020 1021 1022 1023 1024 1025 1026 1027 1028 1029 1030 1031 1032
/*
 * Locality allocation lookup algorithm. This expects a cntbt cursor and uses
 * bno optimized lookup to search for extents with ideal size and locality.
 */
STATIC int
xfs_alloc_cntbt_iter(
	struct xfs_alloc_arg		*args,
	struct xfs_alloc_cur		*acur)
{
	struct xfs_btree_cur	*cur = acur->cnt;
	xfs_agblock_t		bno;
	xfs_extlen_t		len, cur_len;
	int			error;
	int			i;

	if (!xfs_alloc_cur_active(cur))
		return 0;

	/* locality optimized lookup */
	cur_len = acur->cur_len;
	error = xfs_alloc_lookup_ge(cur, args->agbno, cur_len, &i);
	if (error)
		return error;
	if (i == 0)
		return 0;
	error = xfs_alloc_get_rec(cur, &bno, &len, &i);
	if (error)
		return error;

	/* check the current record and update search length from it */
	error = xfs_alloc_cur_check(args, acur, cur, &i);
	if (error)
		return error;
	ASSERT(len >= acur->cur_len);
	acur->cur_len = len;

	/*
	 * We looked up the first record >= [agbno, len] above. The agbno is a
	 * secondary key and so the current record may lie just before or after
	 * agbno. If it is past agbno, check the previous record too so long as
	 * the length matches as it may be closer. Don't check a smaller record
	 * because that could deactivate our cursor.
	 */
	if (bno > args->agbno) {
		error = xfs_btree_decrement(cur, 0, &i);
		if (!error && i) {
			error = xfs_alloc_get_rec(cur, &bno, &len, &i);
			if (!error && i && len == acur->cur_len)
				error = xfs_alloc_cur_check(args, acur, cur,
							    &i);
		}
		if (error)
			return error;
	}

	/*
	 * Increment the search key until we find at least one allocation
	 * candidate or if the extent we found was larger. Otherwise, double the
	 * search key to optimize the search. Efficiency is more important here
	 * than absolute best locality.
	 */
	cur_len <<= 1;
	if (!acur->len || acur->cur_len >= cur_len)
		acur->cur_len++;
	else
		acur->cur_len = cur_len;

	return error;
}

B
Brian Foster 已提交
1033 1034 1035 1036 1037 1038 1039 1040 1041 1042 1043 1044 1045
/*
 * Deal with the case where only small freespaces remain. Either return the
 * contents of the last freespace record, or allocate space from the freelist if
 * there is nothing in the tree.
 */
STATIC int			/* error */
xfs_alloc_ag_vextent_small(
	struct xfs_alloc_arg	*args,	/* allocation argument structure */
	struct xfs_btree_cur	*ccur,	/* optional by-size cursor */
	xfs_agblock_t		*fbnop,	/* result block number */
	xfs_extlen_t		*flenp,	/* result length */
	int			*stat)	/* status: 0-freelist, 1-normal/none */
{
C
Christoph Hellwig 已提交
1046
	struct xfs_agf		*agf = args->agbp->b_addr;
B
Brian Foster 已提交
1047 1048 1049
	int			error = 0;
	xfs_agblock_t		fbno = NULLAGBLOCK;
	xfs_extlen_t		flen = 0;
1050
	int			i = 0;
B
Brian Foster 已提交
1051

1052 1053 1054 1055 1056 1057 1058 1059
	/*
	 * If a cntbt cursor is provided, try to allocate the largest record in
	 * the tree. Try the AGFL if the cntbt is empty, otherwise fail the
	 * allocation. Make sure to respect minleft even when pulling from the
	 * freelist.
	 */
	if (ccur)
		error = xfs_btree_decrement(ccur, 0, &i);
B
Brian Foster 已提交
1060 1061 1062 1063 1064 1065
	if (error)
		goto error;
	if (i) {
		error = xfs_alloc_get_rec(ccur, &fbno, &flen, &i);
		if (error)
			goto error;
1066 1067 1068 1069
		if (XFS_IS_CORRUPT(args->mp, i != 1)) {
			error = -EFSCORRUPTED;
			goto error;
		}
B
Brian Foster 已提交
1070 1071 1072 1073 1074
		goto out;
	}

	if (args->minlen != 1 || args->alignment != 1 ||
	    args->resv == XFS_AG_RESV_AGFL ||
C
Christoph Hellwig 已提交
1075
	    be32_to_cpu(agf->agf_flcount) <= args->minleft)
B
Brian Foster 已提交
1076 1077 1078 1079 1080 1081 1082 1083
		goto out;

	error = xfs_alloc_get_freelist(args->tp, args->agbp, &fbno, 0);
	if (error)
		goto error;
	if (fbno == NULLAGBLOCK)
		goto out;

1084
	xfs_extent_busy_reuse(args->mp, args->pag, fbno, 1,
1085
			      (args->datatype & XFS_ALLOC_NOBUSY));
B
Brian Foster 已提交
1086

1087
	if (args->datatype & XFS_ALLOC_USERDATA) {
B
Brian Foster 已提交
1088 1089
		struct xfs_buf	*bp;

1090 1091 1092 1093
		error = xfs_trans_get_buf(args->tp, args->mp->m_ddev_targp,
				XFS_AGB_TO_DADDR(args->mp, args->agno, fbno),
				args->mp->m_bsize, 0, &bp);
		if (error)
B
Brian Foster 已提交
1094 1095 1096
			goto error;
		xfs_trans_binval(args->tp, bp);
	}
1097 1098
	*fbnop = args->agbno = fbno;
	*flenp = args->len = 1;
C
Christoph Hellwig 已提交
1099
	if (XFS_IS_CORRUPT(args->mp, fbno >= be32_to_cpu(agf->agf_length))) {
1100 1101 1102
		error = -EFSCORRUPTED;
		goto error;
	}
B
Brian Foster 已提交
1103 1104 1105 1106 1107 1108 1109
	args->wasfromfl = 1;
	trace_xfs_alloc_small_freelist(args);

	/*
	 * If we're feeding an AGFL block to something that doesn't live in the
	 * free space, we need to clear out the OWN_AG rmap.
	 */
1110
	error = xfs_rmap_free(args->tp, args->agbp, args->pag, fbno, 1,
B
Brian Foster 已提交
1111 1112 1113 1114 1115 1116 1117 1118 1119 1120 1121 1122 1123 1124 1125 1126 1127 1128 1129 1130 1131 1132 1133 1134 1135 1136 1137
			      &XFS_RMAP_OINFO_AG);
	if (error)
		goto error;

	*stat = 0;
	return 0;

out:
	/*
	 * Can't do the allocation, give up.
	 */
	if (flen < args->minlen) {
		args->agbno = NULLAGBLOCK;
		trace_xfs_alloc_small_notenough(args);
		flen = 0;
	}
	*fbnop = fbno;
	*flenp = flen;
	*stat = 1;
	trace_xfs_alloc_small_done(args);
	return 0;

error:
	trace_xfs_alloc_small_error(args);
	return error;
}

L
Linus Torvalds 已提交
1138 1139 1140 1141 1142 1143 1144 1145 1146 1147 1148 1149 1150 1151 1152 1153 1154 1155 1156
/*
 * Allocate a variable extent in the allocation group agno.
 * Type and bno are used to determine where in the allocation group the
 * extent will start.
 * Extent's length (returned in *len) will be between minlen and maxlen,
 * and of the form k * prod + mod unless there's nothing that large.
 * Return the starting a.g. block, or NULLAGBLOCK if we can't do it.
 */
STATIC int			/* error */
xfs_alloc_ag_vextent(
	xfs_alloc_arg_t	*args)	/* argument structure for allocation */
{
	int		error=0;

	ASSERT(args->minlen > 0);
	ASSERT(args->maxlen > 0);
	ASSERT(args->minlen <= args->maxlen);
	ASSERT(args->mod < args->prod);
	ASSERT(args->alignment > 0);
1157

L
Linus Torvalds 已提交
1158 1159 1160 1161 1162 1163 1164 1165 1166 1167 1168 1169 1170 1171 1172 1173 1174 1175
	/*
	 * Branch to correct routine based on the type.
	 */
	args->wasfromfl = 0;
	switch (args->type) {
	case XFS_ALLOCTYPE_THIS_AG:
		error = xfs_alloc_ag_vextent_size(args);
		break;
	case XFS_ALLOCTYPE_NEAR_BNO:
		error = xfs_alloc_ag_vextent_near(args);
		break;
	case XFS_ALLOCTYPE_THIS_BNO:
		error = xfs_alloc_ag_vextent_exact(args);
		break;
	default:
		ASSERT(0);
		/* NOTREACHED */
	}
1176 1177

	if (error || args->agbno == NULLAGBLOCK)
L
Linus Torvalds 已提交
1178
		return error;
1179 1180 1181

	ASSERT(args->len >= args->minlen);
	ASSERT(args->len <= args->maxlen);
1182
	ASSERT(!args->wasfromfl || args->resv != XFS_AG_RESV_AGFL);
1183 1184
	ASSERT(args->agbno % args->alignment == 0);

1185
	/* if not file data, insert new block into the reverse map btree */
1186
	if (!xfs_rmap_should_skip_owner_update(&args->oinfo)) {
1187
		error = xfs_rmap_alloc(args->tp, args->agbp, args->pag,
1188 1189 1190 1191 1192
				       args->agbno, args->len, &args->oinfo);
		if (error)
			return error;
	}

1193
	if (!args->wasfromfl) {
1194
		error = xfs_alloc_update_counters(args->tp, args->agbp,
1195 1196 1197 1198
						  -((long)(args->len)));
		if (error)
			return error;

1199
		ASSERT(!xfs_extent_busy_search(args->mp, args->pag,
1200
					      args->agbno, args->len));
L
Linus Torvalds 已提交
1201
	}
1202

1203
	xfs_ag_resv_alloc_extent(args->pag, args->resv, args);
1204

1205 1206
	XFS_STATS_INC(args->mp, xs_allocx);
	XFS_STATS_ADD(args->mp, xs_allocb, args->len);
1207
	return error;
L
Linus Torvalds 已提交
1208 1209 1210 1211 1212 1213 1214 1215 1216 1217 1218 1219
}

/*
 * Allocate a variable extent at exactly agno/bno.
 * Extent's length (returned in *len) will be between minlen and maxlen,
 * and of the form k * prod + mod unless there's nothing that large.
 * Return the starting a.g. block (bno), or NULLAGBLOCK if we can't do it.
 */
STATIC int			/* error */
xfs_alloc_ag_vextent_exact(
	xfs_alloc_arg_t	*args)	/* allocation argument structure */
{
C
Christoph Hellwig 已提交
1220
	struct xfs_agf __maybe_unused *agf = args->agbp->b_addr;
1221 1222
	struct xfs_btree_cur *bno_cur;/* by block-number btree cursor */
	struct xfs_btree_cur *cnt_cur;/* by count btree cursor */
L
Linus Torvalds 已提交
1223 1224 1225
	int		error;
	xfs_agblock_t	fbno;	/* start block of found extent */
	xfs_extlen_t	flen;	/* length of found extent */
1226 1227 1228
	xfs_agblock_t	tbno;	/* start block of busy extent */
	xfs_extlen_t	tlen;	/* length of busy extent */
	xfs_agblock_t	tend;	/* end block of busy extent */
L
Linus Torvalds 已提交
1229
	int		i;	/* success/failure of operation */
1230
	unsigned	busy_gen;
L
Linus Torvalds 已提交
1231 1232

	ASSERT(args->alignment == 1);
1233

L
Linus Torvalds 已提交
1234 1235 1236
	/*
	 * Allocate/initialize a cursor for the by-number freespace btree.
	 */
1237
	bno_cur = xfs_allocbt_init_cursor(args->mp, args->tp, args->agbp,
1238
					  args->pag, XFS_BTNUM_BNO);
1239

L
Linus Torvalds 已提交
1240 1241 1242 1243 1244
	/*
	 * Lookup bno and minlen in the btree (minlen is irrelevant, really).
	 * Look for the closest free block <= bno, it must contain bno
	 * if any free block does.
	 */
1245 1246
	error = xfs_alloc_lookup_le(bno_cur, args->agbno, args->minlen, &i);
	if (error)
L
Linus Torvalds 已提交
1247
		goto error0;
1248 1249 1250
	if (!i)
		goto not_found;

L
Linus Torvalds 已提交
1251 1252 1253
	/*
	 * Grab the freespace record.
	 */
1254 1255
	error = xfs_alloc_get_rec(bno_cur, &fbno, &flen, &i);
	if (error)
L
Linus Torvalds 已提交
1256
		goto error0;
1257 1258 1259 1260
	if (XFS_IS_CORRUPT(args->mp, i != 1)) {
		error = -EFSCORRUPTED;
		goto error0;
	}
L
Linus Torvalds 已提交
1261
	ASSERT(fbno <= args->agbno);
1262

L
Linus Torvalds 已提交
1263
	/*
1264
	 * Check for overlapping busy extents.
L
Linus Torvalds 已提交
1265
	 */
1266 1267 1268
	tbno = fbno;
	tlen = flen;
	xfs_extent_busy_trim(args, &tbno, &tlen, &busy_gen);
1269 1270 1271 1272 1273 1274 1275 1276 1277 1278 1279

	/*
	 * Give up if the start of the extent is busy, or the freespace isn't
	 * long enough for the minimum request.
	 */
	if (tbno > args->agbno)
		goto not_found;
	if (tlen < args->minlen)
		goto not_found;
	tend = tbno + tlen;
	if (tend < args->agbno + args->minlen)
1280 1281
		goto not_found;

L
Linus Torvalds 已提交
1282 1283 1284
	/*
	 * End of extent will be smaller of the freespace end and the
	 * maximal requested end.
1285
	 *
L
Linus Torvalds 已提交
1286 1287
	 * Fix the length according to mod and prod if given.
	 */
1288 1289
	args->len = XFS_AGBLOCK_MIN(tend, args->agbno + args->maxlen)
						- args->agbno;
L
Linus Torvalds 已提交
1290
	xfs_alloc_fix_len(args);
1291
	ASSERT(args->agbno + args->len <= tend);
1292

L
Linus Torvalds 已提交
1293
	/*
1294
	 * We are allocating agbno for args->len
L
Linus Torvalds 已提交
1295 1296
	 * Allocate/initialize a cursor for the by-size btree.
	 */
1297
	cnt_cur = xfs_allocbt_init_cursor(args->mp, args->tp, args->agbp,
1298
					args->pag, XFS_BTNUM_CNT);
C
Christoph Hellwig 已提交
1299
	ASSERT(args->agbno + args->len <= be32_to_cpu(agf->agf_length));
1300 1301 1302
	error = xfs_alloc_fixup_trees(cnt_cur, bno_cur, fbno, flen, args->agbno,
				      args->len, XFSA_FIXUP_BNO_OK);
	if (error) {
L
Linus Torvalds 已提交
1303 1304 1305
		xfs_btree_del_cursor(cnt_cur, XFS_BTREE_ERROR);
		goto error0;
	}
1306

L
Linus Torvalds 已提交
1307 1308
	xfs_btree_del_cursor(bno_cur, XFS_BTREE_NOERROR);
	xfs_btree_del_cursor(cnt_cur, XFS_BTREE_NOERROR);
C
Christoph Hellwig 已提交
1309

L
Linus Torvalds 已提交
1310
	args->wasfromfl = 0;
1311 1312 1313 1314 1315 1316 1317 1318
	trace_xfs_alloc_exact_done(args);
	return 0;

not_found:
	/* Didn't find it, return null. */
	xfs_btree_del_cursor(bno_cur, XFS_BTREE_NOERROR);
	args->agbno = NULLAGBLOCK;
	trace_xfs_alloc_exact_notfound(args);
L
Linus Torvalds 已提交
1319 1320 1321 1322
	return 0;

error0:
	xfs_btree_del_cursor(bno_cur, XFS_BTREE_ERROR);
C
Christoph Hellwig 已提交
1323
	trace_xfs_alloc_exact_error(args);
L
Linus Torvalds 已提交
1324 1325 1326
	return error;
}

1327
/*
1328 1329
 * Search a given number of btree records in a given direction. Check each
 * record against the good extent we've already found.
1330 1331
 */
STATIC int
1332
xfs_alloc_walk_iter(
1333 1334 1335
	struct xfs_alloc_arg	*args,
	struct xfs_alloc_cur	*acur,
	struct xfs_btree_cur	*cur,
1336 1337 1338 1339
	bool			increment,
	bool			find_one, /* quit on first candidate */
	int			count,    /* rec count (-1 for infinite) */
	int			*stat)
1340 1341 1342 1343
{
	int			error;
	int			i;

1344 1345
	*stat = 0;

1346
	/*
1347 1348 1349
	 * Search so long as the cursor is active or we find a better extent.
	 * The cursor is deactivated if it extends beyond the range of the
	 * current allocation candidate.
1350
	 */
1351
	while (xfs_alloc_cur_active(cur) && count) {
1352
		error = xfs_alloc_cur_check(args, acur, cur, &i);
1353
		if (error)
1354
			return error;
1355 1356 1357 1358 1359
		if (i == 1) {
			*stat = 1;
			if (find_one)
				break;
		}
1360 1361
		if (!xfs_alloc_cur_active(cur))
			break;
1362

1363 1364
		if (increment)
			error = xfs_btree_increment(cur, 0, &i);
1365
		else
1366
			error = xfs_btree_decrement(cur, 0, &i);
1367
		if (error)
1368 1369
			return error;
		if (i == 0)
1370
			cur->bc_ag.abt.active = false;
1371 1372 1373

		if (count > 0)
			count--;
1374
	}
1375 1376 1377 1378

	return 0;
}

1379
/*
1380 1381
 * Search the by-bno and by-size btrees in parallel in search of an extent with
 * ideal locality based on the NEAR mode ->agbno locality hint.
1382 1383
 */
STATIC int
1384
xfs_alloc_ag_vextent_locality(
1385 1386 1387 1388 1389 1390 1391 1392 1393 1394 1395 1396 1397 1398
	struct xfs_alloc_arg	*args,
	struct xfs_alloc_cur	*acur,
	int			*stat)
{
	struct xfs_btree_cur	*fbcur = NULL;
	int			error;
	int			i;
	bool			fbinc;

	ASSERT(acur->len == 0);
	ASSERT(args->type == XFS_ALLOCTYPE_NEAR_BNO);

	*stat = 0;

1399 1400 1401
	error = xfs_alloc_lookup_ge(acur->cnt, args->agbno, acur->cur_len, &i);
	if (error)
		return error;
1402 1403 1404 1405 1406 1407 1408 1409
	error = xfs_alloc_lookup_le(acur->bnolt, args->agbno, 0, &i);
	if (error)
		return error;
	error = xfs_alloc_lookup_ge(acur->bnogt, args->agbno, 0, &i);
	if (error)
		return error;

	/*
1410 1411 1412 1413 1414 1415 1416 1417 1418 1419 1420 1421 1422 1423 1424 1425 1426 1427 1428 1429
	 * Search the bnobt and cntbt in parallel. Search the bnobt left and
	 * right and lookup the closest extent to the locality hint for each
	 * extent size key in the cntbt. The entire search terminates
	 * immediately on a bnobt hit because that means we've found best case
	 * locality. Otherwise the search continues until the cntbt cursor runs
	 * off the end of the tree. If no allocation candidate is found at this
	 * point, give up on locality, walk backwards from the end of the cntbt
	 * and take the first available extent.
	 *
	 * The parallel tree searches balance each other out to provide fairly
	 * consistent performance for various situations. The bnobt search can
	 * have pathological behavior in the worst case scenario of larger
	 * allocation requests and fragmented free space. On the other hand, the
	 * bnobt is able to satisfy most smaller allocation requests much more
	 * quickly than the cntbt. The cntbt search can sift through fragmented
	 * free space and sets of free extents for larger allocation requests
	 * more quickly than the bnobt. Since the locality hint is just a hint
	 * and we don't want to scan the entire bnobt for perfect locality, the
	 * cntbt search essentially bounds the bnobt search such that we can
	 * find good enough locality at reasonable performance in most cases.
1430 1431
	 */
	while (xfs_alloc_cur_active(acur->bnolt) ||
1432 1433 1434 1435 1436 1437 1438 1439 1440
	       xfs_alloc_cur_active(acur->bnogt) ||
	       xfs_alloc_cur_active(acur->cnt)) {

		trace_xfs_alloc_cur_lookup(args);

		/*
		 * Search the bnobt left and right. In the case of a hit, finish
		 * the search in the opposite direction and we're done.
		 */
1441 1442 1443 1444 1445 1446 1447 1448 1449 1450 1451 1452 1453 1454 1455 1456 1457 1458 1459 1460
		error = xfs_alloc_walk_iter(args, acur, acur->bnolt, false,
					    true, 1, &i);
		if (error)
			return error;
		if (i == 1) {
			trace_xfs_alloc_cur_left(args);
			fbcur = acur->bnogt;
			fbinc = true;
			break;
		}
		error = xfs_alloc_walk_iter(args, acur, acur->bnogt, true, true,
					    1, &i);
		if (error)
			return error;
		if (i == 1) {
			trace_xfs_alloc_cur_right(args);
			fbcur = acur->bnolt;
			fbinc = false;
			break;
		}
1461 1462 1463 1464 1465 1466 1467 1468 1469 1470 1471 1472 1473 1474 1475 1476 1477 1478 1479 1480 1481 1482 1483 1484

		/*
		 * Check the extent with best locality based on the current
		 * extent size search key and keep track of the best candidate.
		 */
		error = xfs_alloc_cntbt_iter(args, acur);
		if (error)
			return error;
		if (!xfs_alloc_cur_active(acur->cnt)) {
			trace_xfs_alloc_cur_lookup_done(args);
			break;
		}
	}

	/*
	 * If we failed to find anything due to busy extents, return empty
	 * handed so the caller can flush and retry. If no busy extents were
	 * found, walk backwards from the end of the cntbt as a last resort.
	 */
	if (!xfs_alloc_cur_active(acur->cnt) && !acur->len && !acur->busy) {
		error = xfs_btree_decrement(acur->cnt, 0, &i);
		if (error)
			return error;
		if (i) {
1485
			acur->cnt->bc_ag.abt.active = true;
1486 1487 1488
			fbcur = acur->cnt;
			fbinc = false;
		}
1489 1490
	}

1491 1492 1493 1494
	/*
	 * Search in the opposite direction for a better entry in the case of
	 * a bnobt hit or walk backwards from the end of the cntbt.
	 */
1495 1496 1497 1498 1499 1500 1501 1502 1503 1504 1505 1506 1507
	if (fbcur) {
		error = xfs_alloc_walk_iter(args, acur, fbcur, fbinc, true, -1,
					    &i);
		if (error)
			return error;
	}

	if (acur->len)
		*stat = 1;

	return 0;
}

1508 1509 1510 1511 1512 1513 1514 1515 1516 1517 1518 1519 1520 1521 1522 1523 1524 1525 1526 1527 1528 1529 1530 1531
/* Check the last block of the cnt btree for allocations. */
static int
xfs_alloc_ag_vextent_lastblock(
	struct xfs_alloc_arg	*args,
	struct xfs_alloc_cur	*acur,
	xfs_agblock_t		*bno,
	xfs_extlen_t		*len,
	bool			*allocated)
{
	int			error;
	int			i;

#ifdef DEBUG
	/* Randomly don't execute the first algorithm. */
	if (prandom_u32() & 1)
		return 0;
#endif

	/*
	 * Start from the entry that lookup found, sequence through all larger
	 * free blocks.  If we're actually pointing at a record smaller than
	 * maxlen, go to the start of this block, and skip all those smaller
	 * than minlen.
	 */
1532
	if (*len || args->alignment > 1) {
1533
		acur->cnt->bc_levels[0].ptr = 1;
1534 1535 1536 1537
		do {
			error = xfs_alloc_get_rec(acur->cnt, bno, len, &i);
			if (error)
				return error;
1538 1539
			if (XFS_IS_CORRUPT(args->mp, i != 1))
				return -EFSCORRUPTED;
1540 1541 1542 1543 1544 1545 1546 1547 1548 1549 1550 1551 1552 1553 1554 1555 1556 1557 1558 1559 1560 1561 1562 1563 1564 1565 1566
			if (*len >= args->minlen)
				break;
			error = xfs_btree_increment(acur->cnt, 0, &i);
			if (error)
				return error;
		} while (i);
		ASSERT(*len >= args->minlen);
		if (!i)
			return 0;
	}

	error = xfs_alloc_walk_iter(args, acur, acur->cnt, true, false, -1, &i);
	if (error)
		return error;

	/*
	 * It didn't work.  We COULD be in a case where there's a good record
	 * somewhere, so try again.
	 */
	if (acur->len == 0)
		return 0;

	trace_xfs_alloc_near_first(args);
	*allocated = true;
	return 0;
}

L
Linus Torvalds 已提交
1567 1568 1569 1570 1571 1572
/*
 * Allocate a variable extent near bno in the allocation group agno.
 * Extent's length (returned in len) will be between minlen and maxlen,
 * and of the form k * prod + mod unless there's nothing that large.
 * Return the starting a.g. block, or NULLAGBLOCK if we can't do it.
 */
1573
STATIC int
L
Linus Torvalds 已提交
1574
xfs_alloc_ag_vextent_near(
1575
	struct xfs_alloc_arg	*args)
L
Linus Torvalds 已提交
1576
{
1577
	struct xfs_alloc_cur	acur = {};
1578 1579 1580 1581
	int			error;		/* error code */
	int			i;		/* result code, temporary */
	xfs_agblock_t		bno;
	xfs_extlen_t		len;
1582

J
Joe Perches 已提交
1583
	/* handle uninitialized agbno range so caller doesn't have to */
1584 1585 1586 1587 1588 1589 1590 1591 1592 1593
	if (!args->min_agbno && !args->max_agbno)
		args->max_agbno = args->mp->m_sb.sb_agblocks - 1;
	ASSERT(args->min_agbno <= args->max_agbno);

	/* clamp agbno to the range if it's outside */
	if (args->agbno < args->min_agbno)
		args->agbno = args->min_agbno;
	if (args->agbno > args->max_agbno)
		args->agbno = args->max_agbno;

1594
restart:
1595
	len = 0;
1596

L
Linus Torvalds 已提交
1597
	/*
1598 1599 1600
	 * Set up cursors and see if there are any free extents as big as
	 * maxlen. If not, pick the last entry in the tree unless the tree is
	 * empty.
L
Linus Torvalds 已提交
1601
	 */
1602 1603
	error = xfs_alloc_cur_setup(args, &acur);
	if (error == -ENOSPC) {
1604 1605
		error = xfs_alloc_ag_vextent_small(args, acur.cnt, &bno,
				&len, &i);
1606 1607
		if (error)
			goto out;
1608
		if (i == 0 || len == 0) {
1609
			trace_xfs_alloc_near_noentry(args);
1610
			goto out;
L
Linus Torvalds 已提交
1611 1612
		}
		ASSERT(i == 1);
1613 1614
	} else if (error) {
		goto out;
L
Linus Torvalds 已提交
1615
	}
1616

L
Linus Torvalds 已提交
1617 1618 1619 1620 1621 1622 1623 1624
	/*
	 * First algorithm.
	 * If the requested extent is large wrt the freespaces available
	 * in this a.g., then the cursor will be pointing to a btree entry
	 * near the right edge of the tree.  If it's in the last btree leaf
	 * block, then we just examine all the entries in that block
	 * that are big enough, and pick the best one.
	 */
1625 1626
	if (xfs_btree_islastblock(acur.cnt, 0)) {
		bool		allocated = false;
1627

1628 1629
		error = xfs_alloc_ag_vextent_lastblock(args, &acur, &bno, &len,
				&allocated);
1630 1631
		if (error)
			goto out;
1632 1633
		if (allocated)
			goto alloc_finish;
L
Linus Torvalds 已提交
1634
	}
1635

L
Linus Torvalds 已提交
1636
	/*
1637 1638
	 * Second algorithm. Combined cntbt and bnobt search to find ideal
	 * locality.
L
Linus Torvalds 已提交
1639
	 */
1640
	error = xfs_alloc_ag_vextent_locality(args, &acur, &i);
1641 1642 1643
	if (error)
		goto out;

L
Linus Torvalds 已提交
1644 1645 1646
	/*
	 * If we couldn't get anything, give up.
	 */
1647
	if (!acur.len) {
1648
		if (acur.busy) {
1649
			trace_xfs_alloc_near_busy(args);
1650 1651
			xfs_extent_busy_flush(args->mp, args->pag,
					      acur.busy_gen);
1652 1653
			goto restart;
		}
C
Christoph Hellwig 已提交
1654
		trace_xfs_alloc_size_neither(args);
L
Linus Torvalds 已提交
1655
		args->agbno = NULLAGBLOCK;
1656
		goto out;
L
Linus Torvalds 已提交
1657
	}
1658

1659
alloc_finish:
1660 1661
	/* fix up btrees on a successful allocation */
	error = xfs_alloc_cur_finish(args, &acur);
C
Christoph Hellwig 已提交
1662

1663 1664
out:
	xfs_alloc_cur_close(&acur, error);
L
Linus Torvalds 已提交
1665 1666 1667 1668 1669 1670 1671 1672 1673 1674 1675 1676 1677
	return error;
}

/*
 * Allocate a variable extent anywhere in the allocation group agno.
 * Extent's length (returned in len) will be between minlen and maxlen,
 * and of the form k * prod + mod unless there's nothing that large.
 * Return the starting a.g. block, or NULLAGBLOCK if we can't do it.
 */
STATIC int				/* error */
xfs_alloc_ag_vextent_size(
	xfs_alloc_arg_t	*args)		/* allocation argument structure */
{
C
Christoph Hellwig 已提交
1678
	struct xfs_agf	*agf = args->agbp->b_addr;
1679 1680
	struct xfs_btree_cur *bno_cur;	/* cursor for bno btree */
	struct xfs_btree_cur *cnt_cur;	/* cursor for cnt btree */
L
Linus Torvalds 已提交
1681 1682 1683 1684 1685 1686
	int		error;		/* error result */
	xfs_agblock_t	fbno;		/* start of found freespace */
	xfs_extlen_t	flen;		/* length of found freespace */
	int		i;		/* temp status variable */
	xfs_agblock_t	rbno;		/* returned block number */
	xfs_extlen_t	rlen;		/* length of returned extent */
1687 1688
	bool		busy;
	unsigned	busy_gen;
L
Linus Torvalds 已提交
1689

1690
restart:
L
Linus Torvalds 已提交
1691 1692 1693
	/*
	 * Allocate and initialize a cursor for the by-size btree.
	 */
1694
	cnt_cur = xfs_allocbt_init_cursor(args->mp, args->tp, args->agbp,
1695
					args->pag, XFS_BTNUM_CNT);
L
Linus Torvalds 已提交
1696
	bno_cur = NULL;
1697

L
Linus Torvalds 已提交
1698 1699 1700 1701 1702 1703
	/*
	 * Look for an entry >= maxlen+alignment-1 blocks.
	 */
	if ((error = xfs_alloc_lookup_ge(cnt_cur, 0,
			args->maxlen + args->alignment - 1, &i)))
		goto error0;
1704

L
Linus Torvalds 已提交
1705
	/*
1706 1707 1708 1709
	 * If none then we have to settle for a smaller extent. In the case that
	 * there are no large extents, this will return the last entry in the
	 * tree unless the tree is empty. In the case that there are only busy
	 * large extents, this will return the largest small extent unless there
1710
	 * are no smaller extents available.
L
Linus Torvalds 已提交
1711
	 */
1712
	if (!i) {
1713 1714 1715
		error = xfs_alloc_ag_vextent_small(args, cnt_cur,
						   &fbno, &flen, &i);
		if (error)
L
Linus Torvalds 已提交
1716 1717 1718
			goto error0;
		if (i == 0 || flen == 0) {
			xfs_btree_del_cursor(cnt_cur, XFS_BTREE_NOERROR);
C
Christoph Hellwig 已提交
1719
			trace_xfs_alloc_size_noentry(args);
L
Linus Torvalds 已提交
1720 1721 1722
			return 0;
		}
		ASSERT(i == 1);
1723 1724
		busy = xfs_alloc_compute_aligned(args, fbno, flen, &rbno,
				&rlen, &busy_gen);
1725 1726 1727 1728 1729 1730 1731 1732
	} else {
		/*
		 * Search for a non-busy extent that is large enough.
		 */
		for (;;) {
			error = xfs_alloc_get_rec(cnt_cur, &fbno, &flen, &i);
			if (error)
				goto error0;
1733 1734 1735 1736
			if (XFS_IS_CORRUPT(args->mp, i != 1)) {
				error = -EFSCORRUPTED;
				goto error0;
			}
1737

1738 1739
			busy = xfs_alloc_compute_aligned(args, fbno, flen,
					&rbno, &rlen, &busy_gen);
1740 1741 1742 1743 1744 1745 1746 1747 1748 1749 1750

			if (rlen >= args->maxlen)
				break;

			error = xfs_btree_increment(cnt_cur, 0, &i);
			if (error)
				goto error0;
			if (i == 0) {
				/*
				 * Our only valid extents must have been busy.
				 * Make it unbusy by forcing the log out and
1751
				 * retrying.
1752 1753 1754 1755
				 */
				xfs_btree_del_cursor(cnt_cur,
						     XFS_BTREE_NOERROR);
				trace_xfs_alloc_size_busy(args);
1756 1757
				xfs_extent_busy_flush(args->mp,
							args->pag, busy_gen);
1758 1759 1760
				goto restart;
			}
		}
L
Linus Torvalds 已提交
1761
	}
1762

L
Linus Torvalds 已提交
1763 1764 1765 1766 1767 1768 1769
	/*
	 * In the first case above, we got the last entry in the
	 * by-size btree.  Now we check to see if the space hits maxlen
	 * once aligned; if not, we search left for something better.
	 * This can't happen in the second case above.
	 */
	rlen = XFS_EXTLEN_MIN(args->maxlen, rlen);
1770 1771 1772 1773 1774 1775 1776
	if (XFS_IS_CORRUPT(args->mp,
			   rlen != 0 &&
			   (rlen > flen ||
			    rbno + rlen > fbno + flen))) {
		error = -EFSCORRUPTED;
		goto error0;
	}
L
Linus Torvalds 已提交
1777 1778 1779 1780 1781 1782 1783 1784 1785 1786 1787
	if (rlen < args->maxlen) {
		xfs_agblock_t	bestfbno;
		xfs_extlen_t	bestflen;
		xfs_agblock_t	bestrbno;
		xfs_extlen_t	bestrlen;

		bestrlen = rlen;
		bestrbno = rbno;
		bestflen = flen;
		bestfbno = fbno;
		for (;;) {
1788
			if ((error = xfs_btree_decrement(cnt_cur, 0, &i)))
L
Linus Torvalds 已提交
1789 1790 1791 1792 1793 1794
				goto error0;
			if (i == 0)
				break;
			if ((error = xfs_alloc_get_rec(cnt_cur, &fbno, &flen,
					&i)))
				goto error0;
1795 1796 1797 1798
			if (XFS_IS_CORRUPT(args->mp, i != 1)) {
				error = -EFSCORRUPTED;
				goto error0;
			}
L
Linus Torvalds 已提交
1799 1800
			if (flen < bestrlen)
				break;
1801 1802
			busy = xfs_alloc_compute_aligned(args, fbno, flen,
					&rbno, &rlen, &busy_gen);
L
Linus Torvalds 已提交
1803
			rlen = XFS_EXTLEN_MIN(args->maxlen, rlen);
1804 1805 1806 1807 1808 1809 1810
			if (XFS_IS_CORRUPT(args->mp,
					   rlen != 0 &&
					   (rlen > flen ||
					    rbno + rlen > fbno + flen))) {
				error = -EFSCORRUPTED;
				goto error0;
			}
L
Linus Torvalds 已提交
1811 1812 1813 1814 1815 1816 1817 1818 1819 1820 1821 1822
			if (rlen > bestrlen) {
				bestrlen = rlen;
				bestrbno = rbno;
				bestflen = flen;
				bestfbno = fbno;
				if (rlen == args->maxlen)
					break;
			}
		}
		if ((error = xfs_alloc_lookup_eq(cnt_cur, bestfbno, bestflen,
				&i)))
			goto error0;
1823 1824 1825 1826
		if (XFS_IS_CORRUPT(args->mp, i != 1)) {
			error = -EFSCORRUPTED;
			goto error0;
		}
L
Linus Torvalds 已提交
1827 1828 1829 1830 1831 1832 1833 1834 1835 1836
		rlen = bestrlen;
		rbno = bestrbno;
		flen = bestflen;
		fbno = bestfbno;
	}
	args->wasfromfl = 0;
	/*
	 * Fix up the length.
	 */
	args->len = rlen;
1837
	if (rlen < args->minlen) {
1838
		if (busy) {
1839 1840
			xfs_btree_del_cursor(cnt_cur, XFS_BTREE_NOERROR);
			trace_xfs_alloc_size_busy(args);
1841
			xfs_extent_busy_flush(args->mp, args->pag, busy_gen);
1842 1843 1844
			goto restart;
		}
		goto out_nominleft;
L
Linus Torvalds 已提交
1845
	}
1846 1847
	xfs_alloc_fix_len(args);

L
Linus Torvalds 已提交
1848
	rlen = args->len;
1849 1850 1851 1852
	if (XFS_IS_CORRUPT(args->mp, rlen > flen)) {
		error = -EFSCORRUPTED;
		goto error0;
	}
L
Linus Torvalds 已提交
1853 1854 1855
	/*
	 * Allocate and initialize a cursor for the by-block tree.
	 */
1856
	bno_cur = xfs_allocbt_init_cursor(args->mp, args->tp, args->agbp,
1857
					args->pag, XFS_BTNUM_BNO);
L
Linus Torvalds 已提交
1858 1859 1860 1861 1862 1863 1864 1865
	if ((error = xfs_alloc_fixup_trees(cnt_cur, bno_cur, fbno, flen,
			rbno, rlen, XFSA_FIXUP_CNT_OK)))
		goto error0;
	xfs_btree_del_cursor(cnt_cur, XFS_BTREE_NOERROR);
	xfs_btree_del_cursor(bno_cur, XFS_BTREE_NOERROR);
	cnt_cur = bno_cur = NULL;
	args->len = rlen;
	args->agbno = rbno;
1866 1867
	if (XFS_IS_CORRUPT(args->mp,
			   args->agbno + args->len >
C
Christoph Hellwig 已提交
1868
			   be32_to_cpu(agf->agf_length))) {
1869 1870 1871
		error = -EFSCORRUPTED;
		goto error0;
	}
C
Christoph Hellwig 已提交
1872
	trace_xfs_alloc_size_done(args);
L
Linus Torvalds 已提交
1873 1874 1875
	return 0;

error0:
C
Christoph Hellwig 已提交
1876
	trace_xfs_alloc_size_error(args);
L
Linus Torvalds 已提交
1877 1878 1879 1880 1881
	if (cnt_cur)
		xfs_btree_del_cursor(cnt_cur, XFS_BTREE_ERROR);
	if (bno_cur)
		xfs_btree_del_cursor(bno_cur, XFS_BTREE_ERROR);
	return error;
1882 1883 1884 1885 1886 1887

out_nominleft:
	xfs_btree_del_cursor(cnt_cur, XFS_BTREE_NOERROR);
	trace_xfs_alloc_size_nominleft(args);
	args->agbno = NULLAGBLOCK;
	return 0;
L
Linus Torvalds 已提交
1888 1889 1890 1891 1892
}

/*
 * Free the extent starting at agno/bno for length.
 */
1893
STATIC int
L
Linus Torvalds 已提交
1894
xfs_free_ag_extent(
1895 1896 1897 1898 1899 1900 1901
	struct xfs_trans		*tp,
	struct xfs_buf			*agbp,
	xfs_agnumber_t			agno,
	xfs_agblock_t			bno,
	xfs_extlen_t			len,
	const struct xfs_owner_info	*oinfo,
	enum xfs_ag_resv_type		type)
L
Linus Torvalds 已提交
1902
{
1903 1904 1905 1906 1907 1908 1909 1910 1911 1912 1913 1914 1915
	struct xfs_mount		*mp;
	struct xfs_btree_cur		*bno_cur;
	struct xfs_btree_cur		*cnt_cur;
	xfs_agblock_t			gtbno; /* start of right neighbor */
	xfs_extlen_t			gtlen; /* length of right neighbor */
	xfs_agblock_t			ltbno; /* start of left neighbor */
	xfs_extlen_t			ltlen; /* length of left neighbor */
	xfs_agblock_t			nbno; /* new starting block of freesp */
	xfs_extlen_t			nlen; /* new length of freespace */
	int				haveleft; /* have a left neighbor */
	int				haveright; /* have a right neighbor */
	int				i;
	int				error;
1916
	struct xfs_perag		*pag = agbp->b_pag;
L
Linus Torvalds 已提交
1917

1918
	bno_cur = cnt_cur = NULL;
L
Linus Torvalds 已提交
1919
	mp = tp->t_mountp;
1920

1921
	if (!xfs_rmap_should_skip_owner_update(oinfo)) {
1922
		error = xfs_rmap_free(tp, agbp, pag, bno, len, oinfo);
1923 1924 1925 1926
		if (error)
			goto error0;
	}

L
Linus Torvalds 已提交
1927 1928 1929
	/*
	 * Allocate and initialize a cursor for the by-block btree.
	 */
1930
	bno_cur = xfs_allocbt_init_cursor(mp, tp, agbp, pag, XFS_BTNUM_BNO);
L
Linus Torvalds 已提交
1931 1932 1933 1934 1935 1936 1937 1938 1939 1940 1941 1942
	/*
	 * Look for a neighboring block on the left (lower block numbers)
	 * that is contiguous with this space.
	 */
	if ((error = xfs_alloc_lookup_le(bno_cur, bno, len, &haveleft)))
		goto error0;
	if (haveleft) {
		/*
		 * There is a block to our left.
		 */
		if ((error = xfs_alloc_get_rec(bno_cur, &ltbno, &ltlen, &i)))
			goto error0;
1943 1944 1945 1946
		if (XFS_IS_CORRUPT(mp, i != 1)) {
			error = -EFSCORRUPTED;
			goto error0;
		}
L
Linus Torvalds 已提交
1947 1948 1949 1950 1951 1952 1953 1954 1955 1956 1957
		/*
		 * It's not contiguous, though.
		 */
		if (ltbno + ltlen < bno)
			haveleft = 0;
		else {
			/*
			 * If this failure happens the request to free this
			 * space was invalid, it's (partly) already free.
			 * Very bad.
			 */
1958 1959 1960 1961
			if (XFS_IS_CORRUPT(mp, ltbno + ltlen > bno)) {
				error = -EFSCORRUPTED;
				goto error0;
			}
L
Linus Torvalds 已提交
1962 1963 1964 1965 1966 1967
		}
	}
	/*
	 * Look for a neighboring block on the right (higher block numbers)
	 * that is contiguous with this space.
	 */
1968
	if ((error = xfs_btree_increment(bno_cur, 0, &haveright)))
L
Linus Torvalds 已提交
1969 1970 1971 1972 1973 1974 1975
		goto error0;
	if (haveright) {
		/*
		 * There is a block to our right.
		 */
		if ((error = xfs_alloc_get_rec(bno_cur, &gtbno, &gtlen, &i)))
			goto error0;
1976 1977 1978 1979
		if (XFS_IS_CORRUPT(mp, i != 1)) {
			error = -EFSCORRUPTED;
			goto error0;
		}
L
Linus Torvalds 已提交
1980 1981 1982 1983 1984 1985 1986 1987 1988 1989 1990
		/*
		 * It's not contiguous, though.
		 */
		if (bno + len < gtbno)
			haveright = 0;
		else {
			/*
			 * If this failure happens the request to free this
			 * space was invalid, it's (partly) already free.
			 * Very bad.
			 */
1991 1992 1993 1994
			if (XFS_IS_CORRUPT(mp, bno + len > gtbno)) {
				error = -EFSCORRUPTED;
				goto error0;
			}
L
Linus Torvalds 已提交
1995 1996 1997 1998 1999
		}
	}
	/*
	 * Now allocate and initialize a cursor for the by-size tree.
	 */
2000
	cnt_cur = xfs_allocbt_init_cursor(mp, tp, agbp, pag, XFS_BTNUM_CNT);
L
Linus Torvalds 已提交
2001 2002 2003 2004 2005 2006 2007 2008 2009 2010
	/*
	 * Have both left and right contiguous neighbors.
	 * Merge all three into a single free block.
	 */
	if (haveleft && haveright) {
		/*
		 * Delete the old by-size entry on the left.
		 */
		if ((error = xfs_alloc_lookup_eq(cnt_cur, ltbno, ltlen, &i)))
			goto error0;
2011 2012 2013 2014
		if (XFS_IS_CORRUPT(mp, i != 1)) {
			error = -EFSCORRUPTED;
			goto error0;
		}
2015
		if ((error = xfs_btree_delete(cnt_cur, &i)))
L
Linus Torvalds 已提交
2016
			goto error0;
2017 2018 2019 2020
		if (XFS_IS_CORRUPT(mp, i != 1)) {
			error = -EFSCORRUPTED;
			goto error0;
		}
L
Linus Torvalds 已提交
2021 2022 2023 2024 2025
		/*
		 * Delete the old by-size entry on the right.
		 */
		if ((error = xfs_alloc_lookup_eq(cnt_cur, gtbno, gtlen, &i)))
			goto error0;
2026 2027 2028 2029
		if (XFS_IS_CORRUPT(mp, i != 1)) {
			error = -EFSCORRUPTED;
			goto error0;
		}
2030
		if ((error = xfs_btree_delete(cnt_cur, &i)))
L
Linus Torvalds 已提交
2031
			goto error0;
2032 2033 2034 2035
		if (XFS_IS_CORRUPT(mp, i != 1)) {
			error = -EFSCORRUPTED;
			goto error0;
		}
L
Linus Torvalds 已提交
2036 2037 2038
		/*
		 * Delete the old by-block entry for the right block.
		 */
2039
		if ((error = xfs_btree_delete(bno_cur, &i)))
L
Linus Torvalds 已提交
2040
			goto error0;
2041 2042 2043 2044
		if (XFS_IS_CORRUPT(mp, i != 1)) {
			error = -EFSCORRUPTED;
			goto error0;
		}
L
Linus Torvalds 已提交
2045 2046 2047
		/*
		 * Move the by-block cursor back to the left neighbor.
		 */
2048
		if ((error = xfs_btree_decrement(bno_cur, 0, &i)))
L
Linus Torvalds 已提交
2049
			goto error0;
2050 2051 2052 2053
		if (XFS_IS_CORRUPT(mp, i != 1)) {
			error = -EFSCORRUPTED;
			goto error0;
		}
L
Linus Torvalds 已提交
2054 2055 2056 2057 2058 2059 2060 2061 2062 2063 2064 2065
#ifdef DEBUG
		/*
		 * Check that this is the right record: delete didn't
		 * mangle the cursor.
		 */
		{
			xfs_agblock_t	xxbno;
			xfs_extlen_t	xxlen;

			if ((error = xfs_alloc_get_rec(bno_cur, &xxbno, &xxlen,
					&i)))
				goto error0;
2066 2067 2068 2069 2070 2071 2072
			if (XFS_IS_CORRUPT(mp,
					   i != 1 ||
					   xxbno != ltbno ||
					   xxlen != ltlen)) {
				error = -EFSCORRUPTED;
				goto error0;
			}
L
Linus Torvalds 已提交
2073 2074 2075 2076 2077 2078 2079 2080 2081 2082 2083 2084 2085 2086 2087 2088 2089 2090 2091 2092
		}
#endif
		/*
		 * Update remaining by-block entry to the new, joined block.
		 */
		nbno = ltbno;
		nlen = len + ltlen + gtlen;
		if ((error = xfs_alloc_update(bno_cur, nbno, nlen)))
			goto error0;
	}
	/*
	 * Have only a left contiguous neighbor.
	 * Merge it together with the new freespace.
	 */
	else if (haveleft) {
		/*
		 * Delete the old by-size entry on the left.
		 */
		if ((error = xfs_alloc_lookup_eq(cnt_cur, ltbno, ltlen, &i)))
			goto error0;
2093 2094 2095 2096
		if (XFS_IS_CORRUPT(mp, i != 1)) {
			error = -EFSCORRUPTED;
			goto error0;
		}
2097
		if ((error = xfs_btree_delete(cnt_cur, &i)))
L
Linus Torvalds 已提交
2098
			goto error0;
2099 2100 2101 2102
		if (XFS_IS_CORRUPT(mp, i != 1)) {
			error = -EFSCORRUPTED;
			goto error0;
		}
L
Linus Torvalds 已提交
2103 2104 2105 2106
		/*
		 * Back up the by-block cursor to the left neighbor, and
		 * update its length.
		 */
2107
		if ((error = xfs_btree_decrement(bno_cur, 0, &i)))
L
Linus Torvalds 已提交
2108
			goto error0;
2109 2110 2111 2112
		if (XFS_IS_CORRUPT(mp, i != 1)) {
			error = -EFSCORRUPTED;
			goto error0;
		}
L
Linus Torvalds 已提交
2113 2114 2115 2116 2117 2118 2119 2120 2121 2122 2123 2124 2125 2126 2127
		nbno = ltbno;
		nlen = len + ltlen;
		if ((error = xfs_alloc_update(bno_cur, nbno, nlen)))
			goto error0;
	}
	/*
	 * Have only a right contiguous neighbor.
	 * Merge it together with the new freespace.
	 */
	else if (haveright) {
		/*
		 * Delete the old by-size entry on the right.
		 */
		if ((error = xfs_alloc_lookup_eq(cnt_cur, gtbno, gtlen, &i)))
			goto error0;
2128 2129 2130 2131
		if (XFS_IS_CORRUPT(mp, i != 1)) {
			error = -EFSCORRUPTED;
			goto error0;
		}
2132
		if ((error = xfs_btree_delete(cnt_cur, &i)))
L
Linus Torvalds 已提交
2133
			goto error0;
2134 2135 2136 2137
		if (XFS_IS_CORRUPT(mp, i != 1)) {
			error = -EFSCORRUPTED;
			goto error0;
		}
L
Linus Torvalds 已提交
2138 2139 2140 2141 2142 2143 2144 2145 2146 2147 2148 2149 2150 2151 2152 2153
		/*
		 * Update the starting block and length of the right
		 * neighbor in the by-block tree.
		 */
		nbno = bno;
		nlen = len + gtlen;
		if ((error = xfs_alloc_update(bno_cur, nbno, nlen)))
			goto error0;
	}
	/*
	 * No contiguous neighbors.
	 * Insert the new freespace into the by-block tree.
	 */
	else {
		nbno = bno;
		nlen = len;
2154
		if ((error = xfs_btree_insert(bno_cur, &i)))
L
Linus Torvalds 已提交
2155
			goto error0;
2156 2157 2158 2159
		if (XFS_IS_CORRUPT(mp, i != 1)) {
			error = -EFSCORRUPTED;
			goto error0;
		}
L
Linus Torvalds 已提交
2160 2161 2162 2163 2164 2165 2166 2167
	}
	xfs_btree_del_cursor(bno_cur, XFS_BTREE_NOERROR);
	bno_cur = NULL;
	/*
	 * In all cases we need to insert the new freespace in the by-size tree.
	 */
	if ((error = xfs_alloc_lookup_eq(cnt_cur, nbno, nlen, &i)))
		goto error0;
2168 2169 2170 2171
	if (XFS_IS_CORRUPT(mp, i != 0)) {
		error = -EFSCORRUPTED;
		goto error0;
	}
2172
	if ((error = xfs_btree_insert(cnt_cur, &i)))
L
Linus Torvalds 已提交
2173
		goto error0;
2174 2175 2176 2177
	if (XFS_IS_CORRUPT(mp, i != 1)) {
		error = -EFSCORRUPTED;
		goto error0;
	}
L
Linus Torvalds 已提交
2178 2179
	xfs_btree_del_cursor(cnt_cur, XFS_BTREE_NOERROR);
	cnt_cur = NULL;
2180

L
Linus Torvalds 已提交
2181 2182 2183
	/*
	 * Update the freespace totals in the ag and superblock.
	 */
2184 2185
	error = xfs_alloc_update_counters(tp, agbp, len);
	xfs_ag_resv_free_extent(agbp->b_pag, type, tp, len);
2186 2187 2188
	if (error)
		goto error0;

2189 2190
	XFS_STATS_INC(mp, xs_freex);
	XFS_STATS_ADD(mp, xs_freeb, len);
C
Christoph Hellwig 已提交
2191

2192
	trace_xfs_free_extent(mp, agno, bno, len, type, haveleft, haveright);
L
Linus Torvalds 已提交
2193 2194 2195 2196

	return 0;

 error0:
2197
	trace_xfs_free_extent(mp, agno, bno, len, type, -1, -1);
L
Linus Torvalds 已提交
2198 2199 2200 2201 2202 2203 2204 2205 2206 2207 2208 2209 2210
	if (bno_cur)
		xfs_btree_del_cursor(bno_cur, XFS_BTREE_ERROR);
	if (cnt_cur)
		xfs_btree_del_cursor(cnt_cur, XFS_BTREE_ERROR);
	return error;
}

/*
 * Visible (exported) allocation/free functions.
 * Some of these are used just by xfs_alloc_btree.c and this file.
 */

/*
2211
 * Compute and fill in value of m_alloc_maxlevels.
L
Linus Torvalds 已提交
2212 2213 2214 2215 2216
 */
void
xfs_alloc_compute_maxlevels(
	xfs_mount_t	*mp)	/* file system mount structure */
{
2217
	mp->m_alloc_maxlevels = xfs_btree_compute_maxlevels(mp->m_alloc_mnr,
2218
			(mp->m_sb.sb_agblocks + 1) / 2);
2219
	ASSERT(mp->m_alloc_maxlevels <= xfs_allocbt_maxlevels_ondisk());
L
Linus Torvalds 已提交
2220 2221
}

2222
/*
2223 2224 2225 2226
 * Find the length of the longest extent in an AG.  The 'need' parameter
 * specifies how much space we're going to need for the AGFL and the
 * 'reserved' parameter tells us how many blocks in this AG are reserved for
 * other callers.
2227 2228 2229
 */
xfs_extlen_t
xfs_alloc_longest_free_extent(
2230
	struct xfs_perag	*pag,
2231 2232
	xfs_extlen_t		need,
	xfs_extlen_t		reserved)
2233
{
2234
	xfs_extlen_t		delta = 0;
2235

2236 2237 2238 2239
	/*
	 * If the AGFL needs a recharge, we'll have to subtract that from the
	 * longest extent.
	 */
2240 2241 2242
	if (need > pag->pagf_flcount)
		delta = need - pag->pagf_flcount;

2243 2244 2245 2246 2247 2248 2249 2250 2251 2252 2253 2254
	/*
	 * If we cannot maintain others' reservations with space from the
	 * not-longest freesp extents, we'll have to subtract /that/ from
	 * the longest extent too.
	 */
	if (pag->pagf_freeblks - pag->pagf_longest < reserved)
		delta += reserved - (pag->pagf_freeblks - pag->pagf_longest);

	/*
	 * If the longest extent is long enough to satisfy all the
	 * reservations and AGFL rules in place, we can return this extent.
	 */
2255
	if (pag->pagf_longest > delta)
2256 2257
		return min_t(xfs_extlen_t, pag->pag_mount->m_ag_max_usable,
				pag->pagf_longest - delta);
2258 2259

	/* Otherwise, let the caller try for 1 block if there's space. */
2260 2261 2262
	return pag->pagf_flcount > 0 || pag->pagf_longest > 0;
}

2263 2264 2265 2266
/*
 * Compute the minimum length of the AGFL in the given AG.  If @pag is NULL,
 * return the largest possible minimum length.
 */
2267 2268 2269 2270 2271
unsigned int
xfs_alloc_min_freelist(
	struct xfs_mount	*mp,
	struct xfs_perag	*pag)
{
2272 2273 2274
	/* AG btrees have at least 1 level. */
	static const uint8_t	fake_levels[XFS_BTNUM_AGF] = {1, 1, 1};
	const uint8_t		*levels = pag ? pag->pagf_levels : fake_levels;
2275 2276
	unsigned int		min_free;

2277
	ASSERT(mp->m_alloc_maxlevels > 0);
2278

2279
	/* space needed by-bno freespace btree */
2280
	min_free = min_t(unsigned int, levels[XFS_BTNUM_BNOi] + 1,
2281
				       mp->m_alloc_maxlevels);
2282
	/* space needed by-size freespace btree */
2283
	min_free += min_t(unsigned int, levels[XFS_BTNUM_CNTi] + 1,
2284
				       mp->m_alloc_maxlevels);
2285
	/* space needed reverse mapping used space btree */
2286
	if (xfs_has_rmapbt(mp))
2287 2288
		min_free += min_t(unsigned int, levels[XFS_BTNUM_RMAPi] + 1,
						mp->m_rmap_maxlevels);
2289 2290 2291 2292

	return min_free;
}

2293 2294 2295 2296 2297 2298 2299 2300 2301 2302 2303 2304 2305
/*
 * Check if the operation we are fixing up the freelist for should go ahead or
 * not. If we are freeing blocks, we always allow it, otherwise the allocation
 * is dependent on whether the size and shape of free space available will
 * permit the requested allocation to take place.
 */
static bool
xfs_alloc_space_available(
	struct xfs_alloc_arg	*args,
	xfs_extlen_t		min_free,
	int			flags)
{
	struct xfs_perag	*pag = args->pag;
2306
	xfs_extlen_t		alloc_len, longest;
2307
	xfs_extlen_t		reservation; /* blocks that are still reserved */
2308
	int			available;
2309
	xfs_extlen_t		agflcount;
2310 2311 2312 2313

	if (flags & XFS_ALLOC_FLAG_FREEING)
		return true;

2314 2315
	reservation = xfs_ag_resv_needed(pag, args->resv);

2316
	/* do we have enough contiguous free space for the allocation? */
2317
	alloc_len = args->minlen + (args->alignment - 1) + args->minalignslop;
2318
	longest = xfs_alloc_longest_free_extent(pag, min_free, reservation);
2319
	if (longest < alloc_len)
2320 2321
		return false;

2322 2323 2324 2325 2326 2327 2328
	/*
	 * Do we have enough free space remaining for the allocation? Don't
	 * account extra agfl blocks because we are about to defer free them,
	 * making them unavailable until the current transaction commits.
	 */
	agflcount = min_t(xfs_extlen_t, pag->pagf_flcount, min_free);
	available = (int)(pag->pagf_freeblks + agflcount -
2329
			  reservation - min_free - args->minleft);
2330
	if (available < (int)max(args->total, alloc_len))
2331 2332
		return false;

2333 2334 2335 2336 2337 2338 2339 2340 2341 2342
	/*
	 * Clamp maxlen to the amount of free space available for the actual
	 * extent allocation.
	 */
	if (available < (int)args->maxlen && !(flags & XFS_ALLOC_FLAG_CHECK)) {
		args->maxlen = available;
		ASSERT(args->maxlen > 0);
		ASSERT(args->maxlen >= args->minlen);
	}

2343 2344 2345
	return true;
}

2346 2347 2348 2349 2350 2351 2352 2353 2354 2355 2356 2357 2358 2359 2360 2361
int
xfs_free_agfl_block(
	struct xfs_trans	*tp,
	xfs_agnumber_t		agno,
	xfs_agblock_t		agbno,
	struct xfs_buf		*agbp,
	struct xfs_owner_info	*oinfo)
{
	int			error;
	struct xfs_buf		*bp;

	error = xfs_free_ag_extent(tp, agbp, agno, agbno, 1, oinfo,
				   XFS_AG_RESV_AGFL);
	if (error)
		return error;

2362 2363 2364 2365 2366
	error = xfs_trans_get_buf(tp, tp->t_mountp->m_ddev_targp,
			XFS_AGB_TO_DADDR(tp->t_mountp, agno, agbno),
			tp->t_mountp->m_bsize, 0, &bp);
	if (error)
		return error;
2367 2368 2369 2370 2371
	xfs_trans_binval(tp, bp);

	return 0;
}

2372 2373 2374 2375 2376 2377 2378 2379 2380 2381 2382 2383 2384 2385 2386 2387 2388 2389 2390 2391 2392 2393 2394
/*
 * Check the agfl fields of the agf for inconsistency or corruption. The purpose
 * is to detect an agfl header padding mismatch between current and early v5
 * kernels. This problem manifests as a 1-slot size difference between the
 * on-disk flcount and the active [first, last] range of a wrapped agfl. This
 * may also catch variants of agfl count corruption unrelated to padding. Either
 * way, we'll reset the agfl and warn the user.
 *
 * Return true if a reset is required before the agfl can be used, false
 * otherwise.
 */
static bool
xfs_agfl_needs_reset(
	struct xfs_mount	*mp,
	struct xfs_agf		*agf)
{
	uint32_t		f = be32_to_cpu(agf->agf_flfirst);
	uint32_t		l = be32_to_cpu(agf->agf_fllast);
	uint32_t		c = be32_to_cpu(agf->agf_flcount);
	int			agfl_size = xfs_agfl_size(mp);
	int			active;

	/* no agfl header on v4 supers */
2395
	if (!xfs_has_crc(mp))
2396 2397 2398 2399 2400 2401 2402 2403 2404 2405 2406 2407 2408 2409 2410 2411 2412 2413 2414 2415 2416 2417 2418 2419 2420 2421 2422 2423 2424 2425 2426 2427 2428 2429 2430 2431 2432 2433 2434 2435 2436 2437 2438
		return false;

	/*
	 * The agf read verifier catches severe corruption of these fields.
	 * Repeat some sanity checks to cover a packed -> unpacked mismatch if
	 * the verifier allows it.
	 */
	if (f >= agfl_size || l >= agfl_size)
		return true;
	if (c > agfl_size)
		return true;

	/*
	 * Check consistency between the on-disk count and the active range. An
	 * agfl padding mismatch manifests as an inconsistent flcount.
	 */
	if (c && l >= f)
		active = l - f + 1;
	else if (c)
		active = agfl_size - f + l + 1;
	else
		active = 0;

	return active != c;
}

/*
 * Reset the agfl to an empty state. Ignore/drop any existing blocks since the
 * agfl content cannot be trusted. Warn the user that a repair is required to
 * recover leaked blocks.
 *
 * The purpose of this mechanism is to handle filesystems affected by the agfl
 * header padding mismatch problem. A reset keeps the filesystem online with a
 * relatively minor free space accounting inconsistency rather than suffer the
 * inevitable crash from use of an invalid agfl block.
 */
static void
xfs_agfl_reset(
	struct xfs_trans	*tp,
	struct xfs_buf		*agbp,
	struct xfs_perag	*pag)
{
	struct xfs_mount	*mp = tp->t_mountp;
C
Christoph Hellwig 已提交
2439
	struct xfs_agf		*agf = agbp->b_addr;
2440 2441 2442 2443 2444 2445 2446 2447 2448 2449 2450 2451 2452 2453 2454 2455 2456 2457 2458

	ASSERT(pag->pagf_agflreset);
	trace_xfs_agfl_reset(mp, agf, 0, _RET_IP_);

	xfs_warn(mp,
	       "WARNING: Reset corrupted AGFL on AG %u. %d blocks leaked. "
	       "Please unmount and run xfs_repair.",
	         pag->pag_agno, pag->pagf_flcount);

	agf->agf_flfirst = 0;
	agf->agf_fllast = cpu_to_be32(xfs_agfl_size(mp) - 1);
	agf->agf_flcount = 0;
	xfs_alloc_log_agf(tp, agbp, XFS_AGF_FLFIRST | XFS_AGF_FLLAST |
				    XFS_AGF_FLCOUNT);

	pag->pagf_flcount = 0;
	pag->pagf_agflreset = false;
}

2459 2460
/*
 * Defer an AGFL block free. This is effectively equivalent to
2461
 * xfs_free_extent_later() with some special handling particular to AGFL blocks.
2462 2463 2464 2465 2466 2467 2468 2469 2470 2471
 *
 * Deferring AGFL frees helps prevent log reservation overruns due to too many
 * allocation operations in a transaction. AGFL frees are prone to this problem
 * because for one they are always freed one at a time. Further, an immediate
 * AGFL block free can cause a btree join and require another block free before
 * the real allocation can proceed. Deferring the free disconnects freeing up
 * the AGFL slot from freeing the block.
 */
STATIC void
xfs_defer_agfl_block(
2472
	struct xfs_trans		*tp,
2473 2474 2475 2476
	xfs_agnumber_t			agno,
	xfs_fsblock_t			agbno,
	struct xfs_owner_info		*oinfo)
{
2477
	struct xfs_mount		*mp = tp->t_mountp;
2478 2479
	struct xfs_extent_free_item	*new;		/* new element */

2480
	ASSERT(xfs_extfree_item_cache != NULL);
2481 2482
	ASSERT(oinfo != NULL);

2483
	new = kmem_cache_zalloc(xfs_extfree_item_cache,
2484
			       GFP_KERNEL | __GFP_NOFAIL);
2485 2486
	new->xefi_startblock = XFS_AGB_TO_FSB(mp, agno, agbno);
	new->xefi_blockcount = 1;
2487
	new->xefi_owner = oinfo->oi_owner;
2488 2489 2490

	trace_xfs_agfl_free_defer(mp, agno, 0, agbno, 1);

2491
	xfs_defer_add(tp, XFS_DEFER_OPS_TYPE_AGFL_FREE, &new->xefi_list);
2492 2493
}

2494 2495 2496 2497 2498 2499 2500 2501 2502 2503 2504 2505 2506 2507 2508 2509 2510 2511 2512 2513
/*
 * Add the extent to the list of extents to be free at transaction end.
 * The list is maintained sorted (by block number).
 */
void
__xfs_free_extent_later(
	struct xfs_trans		*tp,
	xfs_fsblock_t			bno,
	xfs_filblks_t			len,
	const struct xfs_owner_info	*oinfo,
	bool				skip_discard)
{
	struct xfs_extent_free_item	*new;		/* new element */
#ifdef DEBUG
	struct xfs_mount		*mp = tp->t_mountp;
	xfs_agnumber_t			agno;
	xfs_agblock_t			agbno;

	ASSERT(bno != NULLFSBLOCK);
	ASSERT(len > 0);
2514
	ASSERT(len <= XFS_MAX_BMBT_EXTLEN);
2515 2516 2517 2518 2519 2520 2521 2522 2523 2524
	ASSERT(!isnullstartblock(bno));
	agno = XFS_FSB_TO_AGNO(mp, bno);
	agbno = XFS_FSB_TO_AGBNO(mp, bno);
	ASSERT(agno < mp->m_sb.sb_agcount);
	ASSERT(agbno < mp->m_sb.sb_agblocks);
	ASSERT(len < mp->m_sb.sb_agblocks);
	ASSERT(agbno + len <= mp->m_sb.sb_agblocks);
#endif
	ASSERT(xfs_extfree_item_cache != NULL);

2525
	new = kmem_cache_zalloc(xfs_extfree_item_cache,
2526 2527 2528
			       GFP_KERNEL | __GFP_NOFAIL);
	new->xefi_startblock = bno;
	new->xefi_blockcount = (xfs_extlen_t)len;
2529 2530 2531 2532 2533 2534 2535 2536 2537 2538 2539 2540 2541
	if (skip_discard)
		new->xefi_flags |= XFS_EFI_SKIP_DISCARD;
	if (oinfo) {
		ASSERT(oinfo->oi_offset == 0);

		if (oinfo->oi_flags & XFS_OWNER_INFO_ATTR_FORK)
			new->xefi_flags |= XFS_EFI_ATTR_FORK;
		if (oinfo->oi_flags & XFS_OWNER_INFO_BMBT_BLOCK)
			new->xefi_flags |= XFS_EFI_BMBT_BLOCK;
		new->xefi_owner = oinfo->oi_owner;
	} else {
		new->xefi_owner = XFS_RMAP_OWN_NULL;
	}
2542 2543 2544 2545 2546 2547
	trace_xfs_bmap_free_defer(tp->t_mountp,
			XFS_FSB_TO_AGNO(tp->t_mountp, bno), 0,
			XFS_FSB_TO_AGBNO(tp->t_mountp, bno), len);
	xfs_defer_add(tp, XFS_DEFER_OPS_TYPE_FREE, &new->xefi_list);
}

2548 2549 2550 2551 2552 2553 2554 2555 2556 2557 2558 2559 2560 2561 2562 2563 2564
#ifdef DEBUG
/*
 * Check if an AGF has a free extent record whose length is equal to
 * args->minlen.
 */
STATIC int
xfs_exact_minlen_extent_available(
	struct xfs_alloc_arg	*args,
	struct xfs_buf		*agbp,
	int			*stat)
{
	struct xfs_btree_cur	*cnt_cur;
	xfs_agblock_t		fbno;
	xfs_extlen_t		flen;
	int			error = 0;

	cnt_cur = xfs_allocbt_init_cursor(args->mp, args->tp, agbp,
2565
					args->pag, XFS_BTNUM_CNT);
2566 2567 2568 2569 2570 2571 2572 2573 2574 2575 2576 2577 2578 2579 2580 2581 2582 2583 2584 2585 2586 2587 2588
	error = xfs_alloc_lookup_ge(cnt_cur, 0, args->minlen, stat);
	if (error)
		goto out;

	if (*stat == 0) {
		error = -EFSCORRUPTED;
		goto out;
	}

	error = xfs_alloc_get_rec(cnt_cur, &fbno, &flen, stat);
	if (error)
		goto out;

	if (*stat == 1 && flen != args->minlen)
		*stat = 0;

out:
	xfs_btree_del_cursor(cnt_cur, error);

	return error;
}
#endif

L
Linus Torvalds 已提交
2589 2590 2591 2592
/*
 * Decide whether to use this allocation group for this allocation.
 * If so, fix up the btree freelist's size.
 */
2593
int			/* error */
L
Linus Torvalds 已提交
2594
xfs_alloc_fix_freelist(
2595 2596
	struct xfs_alloc_arg	*args,	/* allocation argument structure */
	int			flags)	/* XFS_ALLOC_FLAG_... */
L
Linus Torvalds 已提交
2597
{
2598 2599 2600 2601 2602 2603 2604 2605
	struct xfs_mount	*mp = args->mp;
	struct xfs_perag	*pag = args->pag;
	struct xfs_trans	*tp = args->tp;
	struct xfs_buf		*agbp = NULL;
	struct xfs_buf		*agflbp = NULL;
	struct xfs_alloc_arg	targs;	/* local allocation arguments */
	xfs_agblock_t		bno;	/* freelist block */
	xfs_extlen_t		need;	/* total blocks needed in freelist */
2606
	int			error = 0;
2607

2608 2609 2610
	/* deferred ops (AGFL block frees) require permanent transactions */
	ASSERT(tp->t_flags & XFS_TRANS_PERM_LOG_RES);

L
Linus Torvalds 已提交
2611
	if (!pag->pagf_init) {
2612
		error = xfs_alloc_read_agf(pag, tp, flags, &agbp);
2613 2614 2615 2616
		if (error) {
			/* Couldn't lock the AGF so skip this AG. */
			if (error == -EAGAIN)
				error = 0;
2617
			goto out_no_agbp;
L
Linus Torvalds 已提交
2618
		}
2619
	}
L
Linus Torvalds 已提交
2620

2621
	/*
2622 2623 2624
	 * If this is a metadata preferred pag and we are user data then try
	 * somewhere else if we are not being asked to try harder at this
	 * point
L
Linus Torvalds 已提交
2625
	 */
2626
	if (pag->pagf_metadata && (args->datatype & XFS_ALLOC_USERDATA) &&
2627 2628
	    (flags & XFS_ALLOC_FLAG_TRYLOCK)) {
		ASSERT(!(flags & XFS_ALLOC_FLAG_FREEING));
2629
		goto out_agbp_relse;
L
Linus Torvalds 已提交
2630 2631
	}

2632
	need = xfs_alloc_min_freelist(mp, pag);
2633 2634
	if (!xfs_alloc_space_available(args, need, flags |
			XFS_ALLOC_FLAG_CHECK))
2635
		goto out_agbp_relse;
2636

L
Linus Torvalds 已提交
2637 2638 2639 2640
	/*
	 * Get the a.g. freespace buffer.
	 * Can fail if we're not blocking on locks, and it's held.
	 */
2641
	if (!agbp) {
2642
		error = xfs_alloc_read_agf(pag, tp, flags, &agbp);
2643 2644 2645 2646
		if (error) {
			/* Couldn't lock the AGF so skip this AG. */
			if (error == -EAGAIN)
				error = 0;
2647
			goto out_no_agbp;
2648
		}
L
Linus Torvalds 已提交
2649
	}
2650

2651 2652 2653 2654
	/* reset a padding mismatched agfl before final free space check */
	if (pag->pagf_agflreset)
		xfs_agfl_reset(tp, agbp, pag);

2655
	/* If there isn't enough total space or single-extent, reject it. */
2656
	need = xfs_alloc_min_freelist(mp, pag);
2657 2658
	if (!xfs_alloc_space_available(args, need, flags))
		goto out_agbp_relse;
2659

2660 2661 2662 2663 2664 2665 2666 2667 2668
#ifdef DEBUG
	if (args->alloc_minlen_only) {
		int stat;

		error = xfs_exact_minlen_extent_available(args, agbp, &stat);
		if (error || !stat)
			goto out_agbp_relse;
	}
#endif
L
Linus Torvalds 已提交
2669 2670
	/*
	 * Make the freelist shorter if it's too long.
2671
	 *
2672 2673 2674 2675 2676 2677 2678 2679
	 * Note that from this point onwards, we will always release the agf and
	 * agfl buffers on error. This handles the case where we error out and
	 * the buffers are clean or may not have been joined to the transaction
	 * and hence need to be released manually. If they have been joined to
	 * the transaction, then xfs_trans_brelse() will handle them
	 * appropriately based on the recursion count and dirty state of the
	 * buffer.
	 *
2680 2681 2682 2683
	 * XXX (dgc): When we have lots of free space, does this buy us
	 * anything other than extra overhead when we need to put more blocks
	 * back on the free list? Maybe we should only do this when space is
	 * getting low or the AGFL is more than half full?
2684 2685 2686 2687 2688 2689 2690 2691
	 *
	 * The NOSHRINK flag prevents the AGFL from being shrunk if it's too
	 * big; the NORMAP flag prevents AGFL expand/shrink operations from
	 * updating the rmapbt.  Both flags are used in xfs_repair while we're
	 * rebuilding the rmapbt, and neither are used by the kernel.  They're
	 * both required to ensure that rmaps are correctly recorded for the
	 * regenerated AGFL, bnobt, and cntbt.  See repair/phase5.c and
	 * repair/rmap.c in xfsprogs for details.
L
Linus Torvalds 已提交
2692
	 */
2693
	memset(&targs, 0, sizeof(targs));
2694
	/* struct copy below */
2695
	if (flags & XFS_ALLOC_FLAG_NORMAP)
2696
		targs.oinfo = XFS_RMAP_OINFO_SKIP_UPDATE;
2697
	else
2698
		targs.oinfo = XFS_RMAP_OINFO_AG;
2699
	while (!(flags & XFS_ALLOC_FLAG_NOSHRINK) && pag->pagf_flcount > need) {
D
David Chinner 已提交
2700 2701
		error = xfs_alloc_get_freelist(tp, agbp, &bno, 0);
		if (error)
2702
			goto out_agbp_relse;
2703

2704 2705
		/* defer agfl frees */
		xfs_defer_agfl_block(tp, args->agno, bno, &targs.oinfo);
L
Linus Torvalds 已提交
2706
	}
2707

L
Linus Torvalds 已提交
2708 2709 2710 2711
	targs.tp = tp;
	targs.mp = mp;
	targs.agbp = agbp;
	targs.agno = args->agno;
2712
	targs.alignment = targs.minlen = targs.prod = 1;
L
Linus Torvalds 已提交
2713 2714
	targs.type = XFS_ALLOCTYPE_THIS_AG;
	targs.pag = pag;
2715 2716
	error = xfs_alloc_read_agfl(mp, tp, targs.agno, &agflbp);
	if (error)
2717
		goto out_agbp_relse;
2718 2719 2720

	/* Make the freelist longer if it's too short. */
	while (pag->pagf_flcount < need) {
L
Linus Torvalds 已提交
2721
		targs.agbno = 0;
2722
		targs.maxlen = need - pag->pagf_flcount;
2723
		targs.resv = XFS_AG_RESV_AGFL;
2724 2725 2726

		/* Allocate as many blocks as possible at once. */
		error = xfs_alloc_ag_vextent(&targs);
2727 2728 2729
		if (error)
			goto out_agflbp_relse;

L
Linus Torvalds 已提交
2730 2731 2732 2733 2734
		/*
		 * Stop if we run out.  Won't happen if callers are obeying
		 * the restrictions correctly.  Can happen for free calls
		 * on a completely full ag.
		 */
2735
		if (targs.agbno == NULLAGBLOCK) {
2736 2737
			if (flags & XFS_ALLOC_FLAG_FREEING)
				break;
2738
			goto out_agflbp_relse;
2739
		}
L
Linus Torvalds 已提交
2740 2741 2742 2743
		/*
		 * Put each allocated block on the list.
		 */
		for (bno = targs.agbno; bno < targs.agbno + targs.len; bno++) {
D
David Chinner 已提交
2744 2745 2746
			error = xfs_alloc_put_freelist(tp, agbp,
							agflbp, bno, 0);
			if (error)
2747
				goto out_agflbp_relse;
L
Linus Torvalds 已提交
2748 2749
		}
	}
2750
	xfs_trans_brelse(tp, agflbp);
L
Linus Torvalds 已提交
2751 2752
	args->agbp = agbp;
	return 0;
2753 2754 2755 2756 2757 2758 2759 2760 2761

out_agflbp_relse:
	xfs_trans_brelse(tp, agflbp);
out_agbp_relse:
	if (agbp)
		xfs_trans_brelse(tp, agbp);
out_no_agbp:
	args->agbp = NULL;
	return error;
L
Linus Torvalds 已提交
2762 2763 2764 2765 2766 2767
}

/*
 * Get a block from the freelist.
 * Returns with the buffer for the block gotten.
 */
D
Dave Chinner 已提交
2768
int
L
Linus Torvalds 已提交
2769
xfs_alloc_get_freelist(
D
Dave Chinner 已提交
2770 2771 2772 2773
	struct xfs_trans	*tp,
	struct xfs_buf		*agbp,
	xfs_agblock_t		*bnop,
	int			btreeblk)
L
Linus Torvalds 已提交
2774
{
D
Dave Chinner 已提交
2775 2776 2777 2778 2779
	struct xfs_agf		*agf = agbp->b_addr;
	struct xfs_buf		*agflbp;
	xfs_agblock_t		bno;
	__be32			*agfl_bno;
	int			error;
2780
	uint32_t		logflags;
D
Dave Chinner 已提交
2781 2782
	struct xfs_mount	*mp = tp->t_mountp;
	struct xfs_perag	*pag;
L
Linus Torvalds 已提交
2783 2784 2785 2786 2787 2788 2789 2790 2791 2792 2793

	/*
	 * Freelist is empty, give up.
	 */
	if (!agf->agf_flcount) {
		*bnop = NULLAGBLOCK;
		return 0;
	}
	/*
	 * Read the array of free blocks.
	 */
2794 2795 2796
	error = xfs_alloc_read_agfl(mp, tp, be32_to_cpu(agf->agf_seqno),
				    &agflbp);
	if (error)
L
Linus Torvalds 已提交
2797
		return error;
2798 2799


L
Linus Torvalds 已提交
2800 2801 2802
	/*
	 * Get the block number and update the data structures.
	 */
2803
	agfl_bno = xfs_buf_to_agfl_bno(agflbp);
2804
	bno = be32_to_cpu(agfl_bno[be32_to_cpu(agf->agf_flfirst)]);
2805
	be32_add_cpu(&agf->agf_flfirst, 1);
L
Linus Torvalds 已提交
2806
	xfs_trans_brelse(tp, agflbp);
2807
	if (be32_to_cpu(agf->agf_flfirst) == xfs_agfl_size(mp))
L
Linus Torvalds 已提交
2808
		agf->agf_flfirst = 0;
2809

2810
	pag = agbp->b_pag;
2811
	ASSERT(!pag->pagf_agflreset);
2812
	be32_add_cpu(&agf->agf_flcount, -1);
L
Linus Torvalds 已提交
2813
	pag->pagf_flcount--;
D
David Chinner 已提交
2814 2815 2816

	logflags = XFS_AGF_FLFIRST | XFS_AGF_FLCOUNT;
	if (btreeblk) {
2817
		be32_add_cpu(&agf->agf_btreeblks, 1);
D
David Chinner 已提交
2818 2819 2820 2821 2822
		pag->pagf_btreeblks++;
		logflags |= XFS_AGF_BTREEBLKS;
	}

	xfs_alloc_log_agf(tp, agbp, logflags);
L
Linus Torvalds 已提交
2823 2824 2825 2826 2827 2828 2829 2830 2831 2832
	*bnop = bno;

	return 0;
}

/*
 * Log the given fields from the agf structure.
 */
void
xfs_alloc_log_agf(
2833 2834 2835
	struct xfs_trans	*tp,
	struct xfs_buf		*bp,
	uint32_t		fields)
L
Linus Torvalds 已提交
2836 2837 2838 2839 2840 2841 2842 2843 2844 2845 2846 2847 2848 2849 2850
{
	int	first;		/* first byte offset */
	int	last;		/* last byte offset */
	static const short	offsets[] = {
		offsetof(xfs_agf_t, agf_magicnum),
		offsetof(xfs_agf_t, agf_versionnum),
		offsetof(xfs_agf_t, agf_seqno),
		offsetof(xfs_agf_t, agf_length),
		offsetof(xfs_agf_t, agf_roots[0]),
		offsetof(xfs_agf_t, agf_levels[0]),
		offsetof(xfs_agf_t, agf_flfirst),
		offsetof(xfs_agf_t, agf_fllast),
		offsetof(xfs_agf_t, agf_flcount),
		offsetof(xfs_agf_t, agf_freeblks),
		offsetof(xfs_agf_t, agf_longest),
D
David Chinner 已提交
2851
		offsetof(xfs_agf_t, agf_btreeblks),
D
Dave Chinner 已提交
2852
		offsetof(xfs_agf_t, agf_uuid),
2853
		offsetof(xfs_agf_t, agf_rmap_blocks),
2854 2855 2856
		offsetof(xfs_agf_t, agf_refcount_blocks),
		offsetof(xfs_agf_t, agf_refcount_root),
		offsetof(xfs_agf_t, agf_refcount_level),
2857 2858
		/* needed so that we don't log the whole rest of the structure: */
		offsetof(xfs_agf_t, agf_spare64),
L
Linus Torvalds 已提交
2859 2860 2861
		sizeof(xfs_agf_t)
	};

C
Christoph Hellwig 已提交
2862
	trace_xfs_agf(tp->t_mountp, bp->b_addr, fields, _RET_IP_);
C
Christoph Hellwig 已提交
2863

2864
	xfs_trans_buf_set_type(tp, bp, XFS_BLFT_AGF_BUF);
D
Dave Chinner 已提交
2865

L
Linus Torvalds 已提交
2866 2867 2868 2869 2870 2871 2872
	xfs_btree_offsets(fields, offsets, XFS_AGF_NUM_BITS, &first, &last);
	xfs_trans_log_buf(tp, bp, (uint)first, (uint)last);
}

/*
 * Put the block on the freelist for the allocation group.
 */
D
Dave Chinner 已提交
2873
int
L
Linus Torvalds 已提交
2874
xfs_alloc_put_freelist(
D
Dave Chinner 已提交
2875 2876 2877 2878 2879
	struct xfs_trans	*tp,
	struct xfs_buf		*agbp,
	struct xfs_buf		*agflbp,
	xfs_agblock_t		bno,
	int			btreeblk)
L
Linus Torvalds 已提交
2880
{
C
Christoph Hellwig 已提交
2881 2882
	struct xfs_mount	*mp = tp->t_mountp;
	struct xfs_agf		*agf = agbp->b_addr;
D
Dave Chinner 已提交
2883 2884
	struct xfs_perag	*pag;
	__be32			*blockp;
L
Linus Torvalds 已提交
2885
	int			error;
2886
	uint32_t		logflags;
2887 2888
	__be32			*agfl_bno;
	int			startoff;
L
Linus Torvalds 已提交
2889 2890

	if (!agflbp && (error = xfs_alloc_read_agfl(mp, tp,
2891
			be32_to_cpu(agf->agf_seqno), &agflbp)))
L
Linus Torvalds 已提交
2892
		return error;
2893
	be32_add_cpu(&agf->agf_fllast, 1);
2894
	if (be32_to_cpu(agf->agf_fllast) == xfs_agfl_size(mp))
L
Linus Torvalds 已提交
2895
		agf->agf_fllast = 0;
2896

2897
	pag = agbp->b_pag;
2898
	ASSERT(!pag->pagf_agflreset);
2899
	be32_add_cpu(&agf->agf_flcount, 1);
L
Linus Torvalds 已提交
2900
	pag->pagf_flcount++;
D
David Chinner 已提交
2901 2902 2903

	logflags = XFS_AGF_FLLAST | XFS_AGF_FLCOUNT;
	if (btreeblk) {
2904
		be32_add_cpu(&agf->agf_btreeblks, -1);
D
David Chinner 已提交
2905 2906 2907 2908 2909 2910
		pag->pagf_btreeblks--;
		logflags |= XFS_AGF_BTREEBLKS;
	}

	xfs_alloc_log_agf(tp, agbp, logflags);

2911
	ASSERT(be32_to_cpu(agf->agf_flcount) <= xfs_agfl_size(mp));
2912

2913
	agfl_bno = xfs_buf_to_agfl_bno(agflbp);
2914
	blockp = &agfl_bno[be32_to_cpu(agf->agf_fllast)];
2915
	*blockp = cpu_to_be32(bno);
2916 2917
	startoff = (char *)blockp - (char *)agflbp->b_addr;

D
David Chinner 已提交
2918
	xfs_alloc_log_agf(tp, agbp, logflags);
2919

2920
	xfs_trans_buf_set_type(tp, agflbp, XFS_BLFT_AGFL_BUF);
2921 2922
	xfs_trans_log_buf(tp, agflbp, startoff,
			  startoff + sizeof(xfs_agblock_t) - 1);
L
Linus Torvalds 已提交
2923 2924 2925
	return 0;
}

2926
static xfs_failaddr_t
2927
xfs_agf_verify(
2928 2929
	struct xfs_buf		*bp)
{
2930
	struct xfs_mount	*mp = bp->b_mount;
C
Christoph Hellwig 已提交
2931
	struct xfs_agf		*agf = bp->b_addr;
2932

2933
	if (xfs_has_crc(mp)) {
2934
		if (!uuid_equal(&agf->agf_uuid, &mp->m_sb.sb_meta_uuid))
2935
			return __this_address;
C
Christoph Hellwig 已提交
2936
		if (!xfs_log_check_lsn(mp, be64_to_cpu(agf->agf_lsn)))
2937
			return __this_address;
2938
	}
2939

2940 2941 2942 2943
	if (!xfs_verify_magic(bp, agf->agf_magicnum))
		return __this_address;

	if (!(XFS_AGF_GOOD_VERSION(be32_to_cpu(agf->agf_versionnum)) &&
D
Dave Chinner 已提交
2944
	      be32_to_cpu(agf->agf_freeblks) <= be32_to_cpu(agf->agf_length) &&
2945 2946 2947
	      be32_to_cpu(agf->agf_flfirst) < xfs_agfl_size(mp) &&
	      be32_to_cpu(agf->agf_fllast) < xfs_agfl_size(mp) &&
	      be32_to_cpu(agf->agf_flcount) <= xfs_agfl_size(mp)))
2948
		return __this_address;
2949

2950 2951 2952 2953 2954 2955 2956
	if (be32_to_cpu(agf->agf_length) > mp->m_sb.sb_dblocks)
		return __this_address;

	if (be32_to_cpu(agf->agf_freeblks) < be32_to_cpu(agf->agf_longest) ||
	    be32_to_cpu(agf->agf_freeblks) > be32_to_cpu(agf->agf_length))
		return __this_address;

2957 2958
	if (be32_to_cpu(agf->agf_levels[XFS_BTNUM_BNO]) < 1 ||
	    be32_to_cpu(agf->agf_levels[XFS_BTNUM_CNT]) < 1 ||
2959 2960 2961 2962
	    be32_to_cpu(agf->agf_levels[XFS_BTNUM_BNO]) >
						mp->m_alloc_maxlevels ||
	    be32_to_cpu(agf->agf_levels[XFS_BTNUM_CNT]) >
						mp->m_alloc_maxlevels)
2963
		return __this_address;
2964

2965
	if (xfs_has_rmapbt(mp) &&
2966
	    (be32_to_cpu(agf->agf_levels[XFS_BTNUM_RMAP]) < 1 ||
2967 2968
	     be32_to_cpu(agf->agf_levels[XFS_BTNUM_RMAP]) >
						mp->m_rmap_maxlevels))
2969
		return __this_address;
2970

2971
	if (xfs_has_rmapbt(mp) &&
2972 2973 2974
	    be32_to_cpu(agf->agf_rmap_blocks) > be32_to_cpu(agf->agf_length))
		return __this_address;

2975 2976 2977 2978 2979 2980
	/*
	 * during growfs operations, the perag is not fully initialised,
	 * so we can't use it for any useful checking. growfs ensures we can't
	 * use it by using uncached buffers that don't have the perag attached
	 * so we can detect and avoid this problem.
	 */
D
Dave Chinner 已提交
2981
	if (bp->b_pag && be32_to_cpu(agf->agf_seqno) != bp->b_pag->pag_agno)
2982
		return __this_address;
2983

2984
	if (xfs_has_lazysbcount(mp) &&
D
Dave Chinner 已提交
2985
	    be32_to_cpu(agf->agf_btreeblks) > be32_to_cpu(agf->agf_length))
2986
		return __this_address;
D
Dave Chinner 已提交
2987

2988
	if (xfs_has_reflink(mp) &&
2989 2990 2991 2992
	    be32_to_cpu(agf->agf_refcount_blocks) >
	    be32_to_cpu(agf->agf_length))
		return __this_address;

2993
	if (xfs_has_reflink(mp) &&
2994
	    (be32_to_cpu(agf->agf_refcount_level) < 1 ||
2995
	     be32_to_cpu(agf->agf_refcount_level) > mp->m_refc_maxlevels))
2996
		return __this_address;
2997

2998
	return NULL;
2999

3000 3001
}

3002 3003
static void
xfs_agf_read_verify(
3004 3005
	struct xfs_buf	*bp)
{
3006
	struct xfs_mount *mp = bp->b_mount;
3007
	xfs_failaddr_t	fa;
D
Dave Chinner 已提交
3008

3009
	if (xfs_has_crc(mp) &&
3010
	    !xfs_buf_verify_cksum(bp, XFS_AGF_CRC_OFF))
3011 3012
		xfs_verifier_error(bp, -EFSBADCRC, __this_address);
	else {
3013
		fa = xfs_agf_verify(bp);
3014 3015 3016
		if (XFS_TEST_ERROR(fa, mp, XFS_ERRTAG_ALLOC_READ_AGF))
			xfs_verifier_error(bp, -EFSCORRUPTED, fa);
	}
3017
}
3018

3019
static void
3020
xfs_agf_write_verify(
3021 3022
	struct xfs_buf	*bp)
{
3023
	struct xfs_mount	*mp = bp->b_mount;
C
Carlos Maiolino 已提交
3024
	struct xfs_buf_log_item	*bip = bp->b_log_item;
C
Christoph Hellwig 已提交
3025
	struct xfs_agf		*agf = bp->b_addr;
3026
	xfs_failaddr_t		fa;
D
Dave Chinner 已提交
3027

3028
	fa = xfs_agf_verify(bp);
3029 3030
	if (fa) {
		xfs_verifier_error(bp, -EFSCORRUPTED, fa);
D
Dave Chinner 已提交
3031 3032 3033
		return;
	}

3034
	if (!xfs_has_crc(mp))
D
Dave Chinner 已提交
3035 3036 3037
		return;

	if (bip)
C
Christoph Hellwig 已提交
3038
		agf->agf_lsn = cpu_to_be64(bip->bli_item.li_lsn);
D
Dave Chinner 已提交
3039

3040
	xfs_buf_update_cksum(bp, XFS_AGF_CRC_OFF);
3041 3042
}

3043
const struct xfs_buf_ops xfs_agf_buf_ops = {
3044
	.name = "xfs_agf",
3045
	.magic = { cpu_to_be32(XFS_AGF_MAGIC), cpu_to_be32(XFS_AGF_MAGIC) },
3046 3047
	.verify_read = xfs_agf_read_verify,
	.verify_write = xfs_agf_write_verify,
3048
	.verify_struct = xfs_agf_verify,
3049 3050
};

L
Linus Torvalds 已提交
3051 3052 3053
/*
 * Read in the allocation group header (free/alloc section).
 */
D
Dave Chinner 已提交
3054
int
3055
xfs_read_agf(
D
Dave Chinner 已提交
3056 3057 3058 3059
	struct xfs_perag	*pag,
	struct xfs_trans	*tp,
	int			flags,
	struct xfs_buf		**agfbpp)
L
Linus Torvalds 已提交
3060
{
D
Dave Chinner 已提交
3061 3062
	struct xfs_mount	*mp = pag->pag_mount;
	int			error;
L
Linus Torvalds 已提交
3063

D
Dave Chinner 已提交
3064
	trace_xfs_read_agf(pag->pag_mount, pag->pag_agno);
3065

3066
	error = xfs_trans_read_buf(mp, tp, mp->m_ddev_targp,
D
Dave Chinner 已提交
3067 3068
			XFS_AG_DADDR(mp, pag->pag_agno, XFS_AGF_DADDR(mp)),
			XFS_FSS_TO_BB(mp, 1), flags, agfbpp, &xfs_agf_buf_ops);
L
Linus Torvalds 已提交
3069 3070
	if (error)
		return error;
3071

D
Dave Chinner 已提交
3072
	xfs_buf_set_ref(*agfbpp, XFS_AGF_REF);
3073 3074 3075 3076
	return 0;
}

/*
D
Dave Chinner 已提交
3077 3078 3079
 * Read in the allocation group header (free/alloc section) and initialise the
 * perag structure if necessary. If the caller provides @agfbpp, then return the
 * locked buffer to the caller, otherwise free it.
3080
 */
3081
int
3082
xfs_alloc_read_agf(
3083 3084 3085
	struct xfs_perag	*pag,
	struct xfs_trans	*tp,
	int			flags,
D
Dave Chinner 已提交
3086
	struct xfs_buf		**agfbpp)
3087
{
D
Dave Chinner 已提交
3088
	struct xfs_buf		*agfbp;
3089
	struct xfs_agf		*agf;
3090
	int			error;
3091
	int			allocbt_blks;
3092

3093
	trace_xfs_alloc_read_agf(pag->pag_mount, pag->pag_agno);
3094

3095 3096 3097
	/* We don't support trylock when freeing. */
	ASSERT((flags & (XFS_ALLOC_FLAG_FREEING | XFS_ALLOC_FLAG_TRYLOCK)) !=
			(XFS_ALLOC_FLAG_FREEING | XFS_ALLOC_FLAG_TRYLOCK));
D
Dave Chinner 已提交
3098
	error = xfs_read_agf(pag, tp,
3099
			(flags & XFS_ALLOC_FLAG_TRYLOCK) ? XBF_TRYLOCK : 0,
D
Dave Chinner 已提交
3100
			&agfbp);
3101 3102 3103
	if (error)
		return error;

D
Dave Chinner 已提交
3104
	agf = agfbp->b_addr;
L
Linus Torvalds 已提交
3105
	if (!pag->pagf_init) {
3106
		pag->pagf_freeblks = be32_to_cpu(agf->agf_freeblks);
D
David Chinner 已提交
3107
		pag->pagf_btreeblks = be32_to_cpu(agf->agf_btreeblks);
3108 3109
		pag->pagf_flcount = be32_to_cpu(agf->agf_flcount);
		pag->pagf_longest = be32_to_cpu(agf->agf_longest);
L
Linus Torvalds 已提交
3110
		pag->pagf_levels[XFS_BTNUM_BNOi] =
3111
			be32_to_cpu(agf->agf_levels[XFS_BTNUM_BNOi]);
L
Linus Torvalds 已提交
3112
		pag->pagf_levels[XFS_BTNUM_CNTi] =
3113
			be32_to_cpu(agf->agf_levels[XFS_BTNUM_CNTi]);
3114 3115
		pag->pagf_levels[XFS_BTNUM_RMAPi] =
			be32_to_cpu(agf->agf_levels[XFS_BTNUM_RMAPi]);
3116
		pag->pagf_refcount_level = be32_to_cpu(agf->agf_refcount_level);
L
Linus Torvalds 已提交
3117
		pag->pagf_init = 1;
3118
		pag->pagf_agflreset = xfs_agfl_needs_reset(pag->pag_mount, agf);
3119 3120 3121 3122 3123 3124 3125 3126 3127

		/*
		 * Update the in-core allocbt counter. Filter out the rmapbt
		 * subset of the btreeblks counter because the rmapbt is managed
		 * by perag reservation. Subtract one for the rmapbt root block
		 * because the rmap counter includes it while the btreeblks
		 * counter only tracks non-root blocks.
		 */
		allocbt_blks = pag->pagf_btreeblks;
3128
		if (xfs_has_rmapbt(pag->pag_mount))
3129 3130
			allocbt_blks -= be32_to_cpu(agf->agf_rmap_blocks) - 1;
		if (allocbt_blks > 0)
3131 3132
			atomic64_add(allocbt_blks,
					&pag->pag_mount->m_allocbt_blks);
L
Linus Torvalds 已提交
3133 3134
	}
#ifdef DEBUG
3135
	else if (!xfs_is_shutdown(pag->pag_mount)) {
3136
		ASSERT(pag->pagf_freeblks == be32_to_cpu(agf->agf_freeblks));
3137
		ASSERT(pag->pagf_btreeblks == be32_to_cpu(agf->agf_btreeblks));
3138 3139
		ASSERT(pag->pagf_flcount == be32_to_cpu(agf->agf_flcount));
		ASSERT(pag->pagf_longest == be32_to_cpu(agf->agf_longest));
L
Linus Torvalds 已提交
3140
		ASSERT(pag->pagf_levels[XFS_BTNUM_BNOi] ==
3141
		       be32_to_cpu(agf->agf_levels[XFS_BTNUM_BNOi]));
L
Linus Torvalds 已提交
3142
		ASSERT(pag->pagf_levels[XFS_BTNUM_CNTi] ==
3143
		       be32_to_cpu(agf->agf_levels[XFS_BTNUM_CNTi]));
L
Linus Torvalds 已提交
3144 3145
	}
#endif
D
Dave Chinner 已提交
3146 3147 3148 3149
	if (agfbpp)
		*agfbpp = agfbp;
	else
		xfs_trans_brelse(tp, agfbp);
L
Linus Torvalds 已提交
3150 3151 3152 3153 3154 3155 3156 3157 3158
	return 0;
}

/*
 * Allocate an extent (variable-size).
 * Depending on the allocation type, we either look in a single allocation
 * group or loop over the allocation groups to find the result.
 */
int				/* error */
3159
xfs_alloc_vextent(
3160
	struct xfs_alloc_arg	*args)	/* allocation argument structure */
L
Linus Torvalds 已提交
3161
{
3162 3163 3164 3165 3166 3167 3168 3169
	xfs_agblock_t		agsize;	/* allocation group size */
	int			error;
	int			flags;	/* XFS_ALLOC_FLAG_... locking flags */
	struct xfs_mount	*mp;	/* mount structure pointer */
	xfs_agnumber_t		sagno;	/* starting allocation group number */
	xfs_alloctype_t		type;	/* input allocation type */
	int			bump_rotor = 0;
	xfs_agnumber_t		rotorstep = xfs_rotorstep; /* inode32 agf stepper */
L
Linus Torvalds 已提交
3170 3171 3172 3173 3174 3175 3176 3177 3178 3179 3180 3181 3182 3183 3184 3185 3186 3187 3188 3189 3190 3191 3192 3193

	mp = args->mp;
	type = args->otype = args->type;
	args->agbno = NULLAGBLOCK;
	/*
	 * Just fix this up, for the case where the last a.g. is shorter
	 * (or there's only one a.g.) and the caller couldn't easily figure
	 * that out (xfs_bmap_alloc).
	 */
	agsize = mp->m_sb.sb_agblocks;
	if (args->maxlen > agsize)
		args->maxlen = agsize;
	if (args->alignment == 0)
		args->alignment = 1;
	ASSERT(XFS_FSB_TO_AGNO(mp, args->fsbno) < mp->m_sb.sb_agcount);
	ASSERT(XFS_FSB_TO_AGBNO(mp, args->fsbno) < agsize);
	ASSERT(args->minlen <= args->maxlen);
	ASSERT(args->minlen <= agsize);
	ASSERT(args->mod < args->prod);
	if (XFS_FSB_TO_AGNO(mp, args->fsbno) >= mp->m_sb.sb_agcount ||
	    XFS_FSB_TO_AGBNO(mp, args->fsbno) >= agsize ||
	    args->minlen > args->maxlen || args->minlen > agsize ||
	    args->mod >= args->prod) {
		args->fsbno = NULLFSBLOCK;
C
Christoph Hellwig 已提交
3194
		trace_xfs_alloc_vextent_badargs(args);
L
Linus Torvalds 已提交
3195 3196 3197 3198 3199 3200 3201 3202 3203 3204 3205
		return 0;
	}

	switch (type) {
	case XFS_ALLOCTYPE_THIS_AG:
	case XFS_ALLOCTYPE_NEAR_BNO:
	case XFS_ALLOCTYPE_THIS_BNO:
		/*
		 * These three force us into a single a.g.
		 */
		args->agno = XFS_FSB_TO_AGNO(mp, args->fsbno);
3206
		args->pag = xfs_perag_get(mp, args->agno);
L
Linus Torvalds 已提交
3207 3208
		error = xfs_alloc_fix_freelist(args, 0);
		if (error) {
C
Christoph Hellwig 已提交
3209
			trace_xfs_alloc_vextent_nofix(args);
L
Linus Torvalds 已提交
3210 3211 3212
			goto error0;
		}
		if (!args->agbp) {
C
Christoph Hellwig 已提交
3213
			trace_xfs_alloc_vextent_noagbp(args);
L
Linus Torvalds 已提交
3214 3215 3216 3217 3218 3219 3220 3221 3222 3223 3224
			break;
		}
		args->agbno = XFS_FSB_TO_AGBNO(mp, args->fsbno);
		if ((error = xfs_alloc_ag_vextent(args)))
			goto error0;
		break;
	case XFS_ALLOCTYPE_START_BNO:
		/*
		 * Try near allocation first, then anywhere-in-ag after
		 * the first a.g. fails.
		 */
3225
		if ((args->datatype & XFS_ALLOC_INITIAL_USER_DATA) &&
3226
		    xfs_is_inode32(mp)) {
L
Linus Torvalds 已提交
3227 3228 3229 3230 3231 3232 3233
			args->fsbno = XFS_AGB_TO_FSB(mp,
					((mp->m_agfrotor / rotorstep) %
					mp->m_sb.sb_agcount), 0);
			bump_rotor = 1;
		}
		args->agbno = XFS_FSB_TO_AGBNO(mp, args->fsbno);
		args->type = XFS_ALLOCTYPE_NEAR_BNO;
3234
		fallthrough;
L
Linus Torvalds 已提交
3235 3236 3237 3238
	case XFS_ALLOCTYPE_FIRST_AG:
		/*
		 * Rotate through the allocation groups looking for a winner.
		 */
3239
		if (type == XFS_ALLOCTYPE_FIRST_AG) {
L
Linus Torvalds 已提交
3240 3241 3242 3243 3244 3245 3246 3247 3248 3249 3250 3251 3252 3253 3254 3255 3256 3257 3258
			/*
			 * Start with allocation group given by bno.
			 */
			args->agno = XFS_FSB_TO_AGNO(mp, args->fsbno);
			args->type = XFS_ALLOCTYPE_THIS_AG;
			sagno = 0;
			flags = 0;
		} else {
			/*
			 * Start with the given allocation group.
			 */
			args->agno = sagno = XFS_FSB_TO_AGNO(mp, args->fsbno);
			flags = XFS_ALLOC_FLAG_TRYLOCK;
		}
		/*
		 * Loop over allocation groups twice; first time with
		 * trylock set, second time without.
		 */
		for (;;) {
3259
			args->pag = xfs_perag_get(mp, args->agno);
L
Linus Torvalds 已提交
3260 3261
			error = xfs_alloc_fix_freelist(args, flags);
			if (error) {
C
Christoph Hellwig 已提交
3262
				trace_xfs_alloc_vextent_nofix(args);
L
Linus Torvalds 已提交
3263 3264 3265 3266 3267 3268 3269 3270 3271 3272
				goto error0;
			}
			/*
			 * If we get a buffer back then the allocation will fly.
			 */
			if (args->agbp) {
				if ((error = xfs_alloc_ag_vextent(args)))
					goto error0;
				break;
			}
C
Christoph Hellwig 已提交
3273 3274 3275

			trace_xfs_alloc_vextent_loopfailed(args);

L
Linus Torvalds 已提交
3276 3277 3278 3279 3280 3281
			/*
			 * Didn't work, figure out the next iteration.
			 */
			if (args->agno == sagno &&
			    type == XFS_ALLOCTYPE_START_BNO)
				args->type = XFS_ALLOCTYPE_THIS_AG;
3282 3283 3284 3285 3286 3287 3288 3289
			/*
			* For the first allocation, we can try any AG to get
			* space.  However, if we already have allocated a
			* block, we don't want to try AGs whose number is below
			* sagno. Otherwise, we may end up with out-of-order
			* locking of AGF, which might cause deadlock.
			*/
			if (++(args->agno) == mp->m_sb.sb_agcount) {
3290
				if (args->tp->t_firstblock != NULLFSBLOCK)
3291 3292 3293 3294
					args->agno = sagno;
				else
					args->agno = 0;
			}
L
Linus Torvalds 已提交
3295 3296 3297 3298 3299
			/*
			 * Reached the starting a.g., must either be done
			 * or switch to non-trylock mode.
			 */
			if (args->agno == sagno) {
3300
				if (flags == 0) {
L
Linus Torvalds 已提交
3301
					args->agbno = NULLAGBLOCK;
C
Christoph Hellwig 已提交
3302
					trace_xfs_alloc_vextent_allfailed(args);
L
Linus Torvalds 已提交
3303 3304
					break;
				}
3305 3306 3307 3308 3309 3310

				flags = 0;
				if (type == XFS_ALLOCTYPE_START_BNO) {
					args->agbno = XFS_FSB_TO_AGBNO(mp,
						args->fsbno);
					args->type = XFS_ALLOCTYPE_NEAR_BNO;
L
Linus Torvalds 已提交
3311 3312
				}
			}
3313
			xfs_perag_put(args->pag);
L
Linus Torvalds 已提交
3314
		}
3315
		if (bump_rotor) {
L
Linus Torvalds 已提交
3316 3317 3318 3319 3320 3321 3322 3323 3324 3325 3326 3327 3328 3329 3330 3331 3332 3333 3334 3335 3336 3337 3338
			if (args->agno == sagno)
				mp->m_agfrotor = (mp->m_agfrotor + 1) %
					(mp->m_sb.sb_agcount * rotorstep);
			else
				mp->m_agfrotor = (args->agno * rotorstep + 1) %
					(mp->m_sb.sb_agcount * rotorstep);
		}
		break;
	default:
		ASSERT(0);
		/* NOTREACHED */
	}
	if (args->agbno == NULLAGBLOCK)
		args->fsbno = NULLFSBLOCK;
	else {
		args->fsbno = XFS_AGB_TO_FSB(mp, args->agno, args->agbno);
#ifdef DEBUG
		ASSERT(args->len >= args->minlen);
		ASSERT(args->len <= args->maxlen);
		ASSERT(args->agbno % args->alignment == 0);
		XFS_AG_CHECK_DADDR(mp, XFS_FSB_TO_DADDR(mp, args->fsbno),
			args->len);
#endif
3339

L
Linus Torvalds 已提交
3340
	}
3341
	xfs_perag_put(args->pag);
L
Linus Torvalds 已提交
3342 3343
	return 0;
error0:
3344
	xfs_perag_put(args->pag);
L
Linus Torvalds 已提交
3345 3346 3347
	return error;
}

3348 3349 3350 3351
/* Ensure that the freelist is at full capacity. */
int
xfs_free_extent_fix_freelist(
	struct xfs_trans	*tp,
3352
	struct xfs_perag	*pag,
3353
	struct xfs_buf		**agbp)
L
Linus Torvalds 已提交
3354
{
3355 3356
	struct xfs_alloc_arg	args;
	int			error;
L
Linus Torvalds 已提交
3357

3358
	memset(&args, 0, sizeof(struct xfs_alloc_arg));
L
Linus Torvalds 已提交
3359 3360
	args.tp = tp;
	args.mp = tp->t_mountp;
3361 3362
	args.agno = pag->pag_agno;
	args.pag = pag;
3363 3364 3365 3366 3367 3368

	/*
	 * validate that the block number is legal - the enables us to detect
	 * and handle a silent filesystem corruption rather than crashing.
	 */
	if (args.agno >= args.mp->m_sb.sb_agcount)
D
Dave Chinner 已提交
3369
		return -EFSCORRUPTED;
3370 3371 3372

	error = xfs_alloc_fix_freelist(&args, XFS_ALLOC_FLAG_FREEING);
	if (error)
3373
		return error;
3374 3375

	*agbp = args.agbp;
3376
	return 0;
3377 3378 3379 3380 3381 3382 3383
}

/*
 * Free an extent.
 * Just break up the extent address and hand off to xfs_free_ag_extent
 * after fixing up the freelist.
 */
3384
int
B
Brian Foster 已提交
3385
__xfs_free_extent(
3386 3387 3388 3389 3390 3391
	struct xfs_trans		*tp,
	xfs_fsblock_t			bno,
	xfs_extlen_t			len,
	const struct xfs_owner_info	*oinfo,
	enum xfs_ag_resv_type		type,
	bool				skip_discard)
3392
{
3393 3394 3395 3396
	struct xfs_mount		*mp = tp->t_mountp;
	struct xfs_buf			*agbp;
	xfs_agnumber_t			agno = XFS_FSB_TO_AGNO(mp, bno);
	xfs_agblock_t			agbno = XFS_FSB_TO_AGBNO(mp, bno);
C
Christoph Hellwig 已提交
3397
	struct xfs_agf			*agf;
3398 3399
	int				error;
	unsigned int			busy_flags = 0;
3400
	struct xfs_perag		*pag;
3401 3402

	ASSERT(len != 0);
3403
	ASSERT(type != XFS_AG_RESV_AGFL);
3404

3405
	if (XFS_TEST_ERROR(false, mp,
3406
			XFS_ERRTAG_FREE_EXTENT))
3407 3408
		return -EIO;

3409 3410
	pag = xfs_perag_get(mp, agno);
	error = xfs_free_extent_fix_freelist(tp, pag, &agbp);
3411
	if (error)
3412
		goto err;
C
Christoph Hellwig 已提交
3413
	agf = agbp->b_addr;
3414

3415 3416
	if (XFS_IS_CORRUPT(mp, agbno >= mp->m_sb.sb_agblocks)) {
		error = -EFSCORRUPTED;
3417
		goto err_release;
3418
	}
3419 3420

	/* validate the extent size is legal now we have the agf locked */
C
Christoph Hellwig 已提交
3421
	if (XFS_IS_CORRUPT(mp, agbno + len > be32_to_cpu(agf->agf_length))) {
3422
		error = -EFSCORRUPTED;
3423
		goto err_release;
3424
	}
3425

3426
	error = xfs_free_ag_extent(tp, agbp, agno, agbno, len, oinfo, type);
3427
	if (error)
3428
		goto err_release;
3429

B
Brian Foster 已提交
3430 3431
	if (skip_discard)
		busy_flags |= XFS_EXTENT_BUSY_SKIP_DISCARD;
3432 3433
	xfs_extent_busy_insert(tp, pag, agbno, len, busy_flags);
	xfs_perag_put(pag);
3434 3435
	return 0;

3436
err_release:
3437
	xfs_trans_brelse(tp, agbp);
3438 3439
err:
	xfs_perag_put(pag);
L
Linus Torvalds 已提交
3440 3441
	return error;
}
3442 3443 3444 3445 3446 3447 3448 3449 3450 3451

struct xfs_alloc_query_range_info {
	xfs_alloc_query_range_fn	fn;
	void				*priv;
};

/* Format btree record and pass to our callback. */
STATIC int
xfs_alloc_query_range_helper(
	struct xfs_btree_cur		*cur,
3452
	const union xfs_btree_rec	*rec,
3453 3454 3455 3456 3457 3458 3459 3460 3461 3462 3463 3464 3465 3466
	void				*priv)
{
	struct xfs_alloc_query_range_info	*query = priv;
	struct xfs_alloc_rec_incore		irec;

	irec.ar_startblock = be32_to_cpu(rec->alloc.ar_startblock);
	irec.ar_blockcount = be32_to_cpu(rec->alloc.ar_blockcount);
	return query->fn(cur, &irec, query->priv);
}

/* Find all free space within a given range of blocks. */
int
xfs_alloc_query_range(
	struct xfs_btree_cur			*cur,
3467 3468
	const struct xfs_alloc_rec_incore	*low_rec,
	const struct xfs_alloc_rec_incore	*high_rec,
3469 3470 3471 3472 3473 3474 3475 3476 3477 3478 3479 3480 3481 3482 3483
	xfs_alloc_query_range_fn		fn,
	void					*priv)
{
	union xfs_btree_irec			low_brec;
	union xfs_btree_irec			high_brec;
	struct xfs_alloc_query_range_info	query;

	ASSERT(cur->bc_btnum == XFS_BTNUM_BNO);
	low_brec.a = *low_rec;
	high_brec.a = *high_rec;
	query.priv = priv;
	query.fn = fn;
	return xfs_btree_query_range(cur, &low_brec, &high_brec,
			xfs_alloc_query_range_helper, &query);
}
3484 3485 3486 3487 3488 3489 3490 3491 3492 3493 3494 3495 3496 3497 3498

/* Find all free space records. */
int
xfs_alloc_query_all(
	struct xfs_btree_cur			*cur,
	xfs_alloc_query_range_fn		fn,
	void					*priv)
{
	struct xfs_alloc_query_range_info	query;

	ASSERT(cur->bc_btnum == XFS_BTNUM_BNO);
	query.priv = priv;
	query.fn = fn;
	return xfs_btree_query_all(cur, xfs_alloc_query_range_helper, &query);
}
3499

3500 3501 3502 3503 3504 3505 3506 3507 3508 3509 3510 3511 3512 3513 3514 3515 3516 3517
/* Is there a record covering a given extent? */
int
xfs_alloc_has_record(
	struct xfs_btree_cur	*cur,
	xfs_agblock_t		bno,
	xfs_extlen_t		len,
	bool			*exists)
{
	union xfs_btree_irec	low;
	union xfs_btree_irec	high;

	memset(&low, 0, sizeof(low));
	low.a.ar_startblock = bno;
	memset(&high, 0xFF, sizeof(high));
	high.a.ar_startblock = bno + len - 1;

	return xfs_btree_has_record(cur, &low, &high, exists);
}
3518 3519 3520

/*
 * Walk all the blocks in the AGFL.  The @walk_fn can return any negative
3521
 * error code or XFS_ITER_*.
3522 3523 3524 3525 3526 3527 3528 3529 3530 3531 3532 3533 3534
 */
int
xfs_agfl_walk(
	struct xfs_mount	*mp,
	struct xfs_agf		*agf,
	struct xfs_buf		*agflbp,
	xfs_agfl_walk_fn	walk_fn,
	void			*priv)
{
	__be32			*agfl_bno;
	unsigned int		i;
	int			error;

3535
	agfl_bno = xfs_buf_to_agfl_bno(agflbp);
3536 3537 3538 3539 3540 3541 3542 3543 3544 3545 3546 3547 3548 3549 3550 3551 3552 3553 3554
	i = be32_to_cpu(agf->agf_flfirst);

	/* Nothing to walk in an empty AGFL. */
	if (agf->agf_flcount == cpu_to_be32(0))
		return 0;

	/* Otherwise, walk from first to last, wrapping as needed. */
	for (;;) {
		error = walk_fn(mp, be32_to_cpu(agfl_bno[i]), priv);
		if (error)
			return error;
		if (i == be32_to_cpu(agf->agf_fllast))
			break;
		if (++i == xfs_agfl_size(mp))
			i = 0;
	}

	return 0;
}
3555 3556 3557 3558 3559 3560 3561 3562 3563 3564 3565 3566 3567 3568 3569 3570 3571

int __init
xfs_extfree_intent_init_cache(void)
{
	xfs_extfree_item_cache = kmem_cache_create("xfs_extfree_intent",
			sizeof(struct xfs_extent_free_item),
			0, 0, NULL);

	return xfs_extfree_item_cache != NULL ? 0 : -ENOMEM;
}

void
xfs_extfree_intent_destroy_cache(void)
{
	kmem_cache_destroy(xfs_extfree_item_cache);
	xfs_extfree_item_cache = NULL;
}