• Home
  • Line#
  • Scopes#
  • Navigate#
  • Raw
  • Download
1 /*
2  * Copyright (c) 2000-2002,2005 Silicon Graphics, Inc.
3  * All Rights Reserved.
4  *
5  * This program is free software; you can redistribute it and/or
6  * modify it under the terms of the GNU General Public License as
7  * published by the Free Software Foundation.
8  *
9  * This program is distributed in the hope that it would be useful,
10  * but WITHOUT ANY WARRANTY; without even the implied warranty of
11  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
12  * GNU General Public License for more details.
13  *
14  * You should have received a copy of the GNU General Public License
15  * along with this program; if not, write the Free Software Foundation,
16  * Inc.,  51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
17  */
18 #include "xfs.h"
19 #include "xfs_fs.h"
20 #include "xfs_format.h"
21 #include "xfs_log_format.h"
22 #include "xfs_shared.h"
23 #include "xfs_trans_resv.h"
24 #include "xfs_bit.h"
25 #include "xfs_sb.h"
26 #include "xfs_ag.h"
27 #include "xfs_mount.h"
28 #include "xfs_inode.h"
29 #include "xfs_btree.h"
30 #include "xfs_alloc_btree.h"
31 #include "xfs_alloc.h"
32 #include "xfs_extent_busy.h"
33 #include "xfs_error.h"
34 #include "xfs_cksum.h"
35 #include "xfs_trace.h"
36 #include "xfs_trans.h"
37 #include "xfs_buf_item.h"
38 #include "xfs_log.h"
39 
40 struct workqueue_struct *xfs_alloc_wq;
41 
42 #define XFS_ABSDIFF(a,b)	(((a) <= (b)) ? ((b) - (a)) : ((a) - (b)))
43 
44 #define	XFSA_FIXUP_BNO_OK	1
45 #define	XFSA_FIXUP_CNT_OK	2
46 
47 STATIC int xfs_alloc_ag_vextent_exact(xfs_alloc_arg_t *);
48 STATIC int xfs_alloc_ag_vextent_near(xfs_alloc_arg_t *);
49 STATIC int xfs_alloc_ag_vextent_size(xfs_alloc_arg_t *);
50 STATIC int xfs_alloc_ag_vextent_small(xfs_alloc_arg_t *,
51 		xfs_btree_cur_t *, xfs_agblock_t *, xfs_extlen_t *, int *);
52 
53 /*
54  * Lookup the record equal to [bno, len] in the btree given by cur.
55  */
56 STATIC int				/* error */
xfs_alloc_lookup_eq(struct xfs_btree_cur * cur,xfs_agblock_t bno,xfs_extlen_t len,int * stat)57 xfs_alloc_lookup_eq(
58 	struct xfs_btree_cur	*cur,	/* btree cursor */
59 	xfs_agblock_t		bno,	/* starting block of extent */
60 	xfs_extlen_t		len,	/* length of extent */
61 	int			*stat)	/* success/failure */
62 {
63 	cur->bc_rec.a.ar_startblock = bno;
64 	cur->bc_rec.a.ar_blockcount = len;
65 	return xfs_btree_lookup(cur, XFS_LOOKUP_EQ, stat);
66 }
67 
68 /*
69  * Lookup the first record greater than or equal to [bno, len]
70  * in the btree given by cur.
71  */
72 int				/* error */
xfs_alloc_lookup_ge(struct xfs_btree_cur * cur,xfs_agblock_t bno,xfs_extlen_t len,int * stat)73 xfs_alloc_lookup_ge(
74 	struct xfs_btree_cur	*cur,	/* btree cursor */
75 	xfs_agblock_t		bno,	/* starting block of extent */
76 	xfs_extlen_t		len,	/* length of extent */
77 	int			*stat)	/* success/failure */
78 {
79 	cur->bc_rec.a.ar_startblock = bno;
80 	cur->bc_rec.a.ar_blockcount = len;
81 	return xfs_btree_lookup(cur, XFS_LOOKUP_GE, stat);
82 }
83 
84 /*
85  * Lookup the first record less than or equal to [bno, len]
86  * in the btree given by cur.
87  */
88 int					/* error */
xfs_alloc_lookup_le(struct xfs_btree_cur * cur,xfs_agblock_t bno,xfs_extlen_t len,int * stat)89 xfs_alloc_lookup_le(
90 	struct xfs_btree_cur	*cur,	/* btree cursor */
91 	xfs_agblock_t		bno,	/* starting block of extent */
92 	xfs_extlen_t		len,	/* length of extent */
93 	int			*stat)	/* success/failure */
94 {
95 	cur->bc_rec.a.ar_startblock = bno;
96 	cur->bc_rec.a.ar_blockcount = len;
97 	return xfs_btree_lookup(cur, XFS_LOOKUP_LE, stat);
98 }
99 
100 /*
101  * Update the record referred to by cur to the value given
102  * by [bno, len].
103  * This either works (return 0) or gets an EFSCORRUPTED error.
104  */
105 STATIC int				/* error */
xfs_alloc_update(struct xfs_btree_cur * cur,xfs_agblock_t bno,xfs_extlen_t len)106 xfs_alloc_update(
107 	struct xfs_btree_cur	*cur,	/* btree cursor */
108 	xfs_agblock_t		bno,	/* starting block of extent */
109 	xfs_extlen_t		len)	/* length of extent */
110 {
111 	union xfs_btree_rec	rec;
112 
113 	rec.alloc.ar_startblock = cpu_to_be32(bno);
114 	rec.alloc.ar_blockcount = cpu_to_be32(len);
115 	return xfs_btree_update(cur, &rec);
116 }
117 
118 /*
119  * Get the data from the pointed-to record.
120  */
121 int					/* error */
xfs_alloc_get_rec(struct xfs_btree_cur * cur,xfs_agblock_t * bno,xfs_extlen_t * len,int * stat)122 xfs_alloc_get_rec(
123 	struct xfs_btree_cur	*cur,	/* btree cursor */
124 	xfs_agblock_t		*bno,	/* output: starting block of extent */
125 	xfs_extlen_t		*len,	/* output: length of extent */
126 	int			*stat)	/* output: success/failure */
127 {
128 	union xfs_btree_rec	*rec;
129 	int			error;
130 
131 	error = xfs_btree_get_rec(cur, &rec, stat);
132 	if (!error && *stat == 1) {
133 		*bno = be32_to_cpu(rec->alloc.ar_startblock);
134 		*len = be32_to_cpu(rec->alloc.ar_blockcount);
135 	}
136 	return error;
137 }
138 
139 /*
140  * Compute aligned version of the found extent.
141  * Takes alignment and min length into account.
142  */
143 STATIC void
xfs_alloc_compute_aligned(xfs_alloc_arg_t * args,xfs_agblock_t foundbno,xfs_extlen_t foundlen,xfs_agblock_t * resbno,xfs_extlen_t * reslen)144 xfs_alloc_compute_aligned(
145 	xfs_alloc_arg_t	*args,		/* allocation argument structure */
146 	xfs_agblock_t	foundbno,	/* starting block in found extent */
147 	xfs_extlen_t	foundlen,	/* length in found extent */
148 	xfs_agblock_t	*resbno,	/* result block number */
149 	xfs_extlen_t	*reslen)	/* result length */
150 {
151 	xfs_agblock_t	bno;
152 	xfs_extlen_t	len;
153 
154 	/* Trim busy sections out of found extent */
155 	xfs_extent_busy_trim(args, foundbno, foundlen, &bno, &len);
156 
157 	if (args->alignment > 1 && len >= args->minlen) {
158 		xfs_agblock_t	aligned_bno = roundup(bno, args->alignment);
159 		xfs_extlen_t	diff = aligned_bno - bno;
160 
161 		*resbno = aligned_bno;
162 		*reslen = diff >= len ? 0 : len - diff;
163 	} else {
164 		*resbno = bno;
165 		*reslen = len;
166 	}
167 }
168 
169 /*
170  * Compute best start block and diff for "near" allocations.
171  * freelen >= wantlen already checked by caller.
172  */
173 STATIC xfs_extlen_t			/* difference value (absolute) */
xfs_alloc_compute_diff(xfs_agblock_t wantbno,xfs_extlen_t wantlen,xfs_extlen_t alignment,char userdata,xfs_agblock_t freebno,xfs_extlen_t freelen,xfs_agblock_t * newbnop)174 xfs_alloc_compute_diff(
175 	xfs_agblock_t	wantbno,	/* target starting block */
176 	xfs_extlen_t	wantlen,	/* target length */
177 	xfs_extlen_t	alignment,	/* target alignment */
178 	char		userdata,	/* are we allocating data? */
179 	xfs_agblock_t	freebno,	/* freespace's starting block */
180 	xfs_extlen_t	freelen,	/* freespace's length */
181 	xfs_agblock_t	*newbnop)	/* result: best start block from free */
182 {
183 	xfs_agblock_t	freeend;	/* end of freespace extent */
184 	xfs_agblock_t	newbno1;	/* return block number */
185 	xfs_agblock_t	newbno2;	/* other new block number */
186 	xfs_extlen_t	newlen1=0;	/* length with newbno1 */
187 	xfs_extlen_t	newlen2=0;	/* length with newbno2 */
188 	xfs_agblock_t	wantend;	/* end of target extent */
189 
190 	ASSERT(freelen >= wantlen);
191 	freeend = freebno + freelen;
192 	wantend = wantbno + wantlen;
193 	/*
194 	 * We want to allocate from the start of a free extent if it is past
195 	 * the desired block or if we are allocating user data and the free
196 	 * extent is before desired block. The second case is there to allow
197 	 * for contiguous allocation from the remaining free space if the file
198 	 * grows in the short term.
199 	 */
200 	if (freebno >= wantbno || (userdata && freeend < wantend)) {
201 		if ((newbno1 = roundup(freebno, alignment)) >= freeend)
202 			newbno1 = NULLAGBLOCK;
203 	} else if (freeend >= wantend && alignment > 1) {
204 		newbno1 = roundup(wantbno, alignment);
205 		newbno2 = newbno1 - alignment;
206 		if (newbno1 >= freeend)
207 			newbno1 = NULLAGBLOCK;
208 		else
209 			newlen1 = XFS_EXTLEN_MIN(wantlen, freeend - newbno1);
210 		if (newbno2 < freebno)
211 			newbno2 = NULLAGBLOCK;
212 		else
213 			newlen2 = XFS_EXTLEN_MIN(wantlen, freeend - newbno2);
214 		if (newbno1 != NULLAGBLOCK && newbno2 != NULLAGBLOCK) {
215 			if (newlen1 < newlen2 ||
216 			    (newlen1 == newlen2 &&
217 			     XFS_ABSDIFF(newbno1, wantbno) >
218 			     XFS_ABSDIFF(newbno2, wantbno)))
219 				newbno1 = newbno2;
220 		} else if (newbno2 != NULLAGBLOCK)
221 			newbno1 = newbno2;
222 	} else if (freeend >= wantend) {
223 		newbno1 = wantbno;
224 	} else if (alignment > 1) {
225 		newbno1 = roundup(freeend - wantlen, alignment);
226 		if (newbno1 > freeend - wantlen &&
227 		    newbno1 - alignment >= freebno)
228 			newbno1 -= alignment;
229 		else if (newbno1 >= freeend)
230 			newbno1 = NULLAGBLOCK;
231 	} else
232 		newbno1 = freeend - wantlen;
233 	*newbnop = newbno1;
234 	return newbno1 == NULLAGBLOCK ? 0 : XFS_ABSDIFF(newbno1, wantbno);
235 }
236 
237 /*
238  * Fix up the length, based on mod and prod.
239  * len should be k * prod + mod for some k.
240  * If len is too small it is returned unchanged.
241  * If len hits maxlen it is left alone.
242  */
243 STATIC void
xfs_alloc_fix_len(xfs_alloc_arg_t * args)244 xfs_alloc_fix_len(
245 	xfs_alloc_arg_t	*args)		/* allocation argument structure */
246 {
247 	xfs_extlen_t	k;
248 	xfs_extlen_t	rlen;
249 
250 	ASSERT(args->mod < args->prod);
251 	rlen = args->len;
252 	ASSERT(rlen >= args->minlen);
253 	ASSERT(rlen <= args->maxlen);
254 	if (args->prod <= 1 || rlen < args->mod || rlen == args->maxlen ||
255 	    (args->mod == 0 && rlen < args->prod))
256 		return;
257 	k = rlen % args->prod;
258 	if (k == args->mod)
259 		return;
260 	if (k > args->mod)
261 		rlen = rlen - (k - args->mod);
262 	else
263 		rlen = rlen - args->prod + (args->mod - k);
264 	if ((int)rlen < (int)args->minlen)
265 		return;
266 	ASSERT(rlen >= args->minlen && rlen <= args->maxlen);
267 	ASSERT(rlen % args->prod == args->mod);
268 	args->len = rlen;
269 }
270 
271 /*
272  * Fix up length if there is too little space left in the a.g.
273  * Return 1 if ok, 0 if too little, should give up.
274  */
275 STATIC int
xfs_alloc_fix_minleft(xfs_alloc_arg_t * args)276 xfs_alloc_fix_minleft(
277 	xfs_alloc_arg_t	*args)		/* allocation argument structure */
278 {
279 	xfs_agf_t	*agf;		/* a.g. freelist header */
280 	int		diff;		/* free space difference */
281 
282 	if (args->minleft == 0)
283 		return 1;
284 	agf = XFS_BUF_TO_AGF(args->agbp);
285 	diff = be32_to_cpu(agf->agf_freeblks)
286 		- args->len - args->minleft;
287 	if (diff >= 0)
288 		return 1;
289 	args->len += diff;		/* shrink the allocated space */
290 	if (args->len >= args->minlen)
291 		return 1;
292 	args->agbno = NULLAGBLOCK;
293 	return 0;
294 }
295 
296 /*
297  * Update the two btrees, logically removing from freespace the extent
298  * starting at rbno, rlen blocks.  The extent is contained within the
299  * actual (current) free extent fbno for flen blocks.
300  * Flags are passed in indicating whether the cursors are set to the
301  * relevant records.
302  */
303 STATIC int				/* error code */
xfs_alloc_fixup_trees(xfs_btree_cur_t * cnt_cur,xfs_btree_cur_t * bno_cur,xfs_agblock_t fbno,xfs_extlen_t flen,xfs_agblock_t rbno,xfs_extlen_t rlen,int flags)304 xfs_alloc_fixup_trees(
305 	xfs_btree_cur_t	*cnt_cur,	/* cursor for by-size btree */
306 	xfs_btree_cur_t	*bno_cur,	/* cursor for by-block btree */
307 	xfs_agblock_t	fbno,		/* starting block of free extent */
308 	xfs_extlen_t	flen,		/* length of free extent */
309 	xfs_agblock_t	rbno,		/* starting block of returned extent */
310 	xfs_extlen_t	rlen,		/* length of returned extent */
311 	int		flags)		/* flags, XFSA_FIXUP_... */
312 {
313 	int		error;		/* error code */
314 	int		i;		/* operation results */
315 	xfs_agblock_t	nfbno1;		/* first new free startblock */
316 	xfs_agblock_t	nfbno2;		/* second new free startblock */
317 	xfs_extlen_t	nflen1=0;	/* first new free length */
318 	xfs_extlen_t	nflen2=0;	/* second new free length */
319 
320 	/*
321 	 * Look up the record in the by-size tree if necessary.
322 	 */
323 	if (flags & XFSA_FIXUP_CNT_OK) {
324 #ifdef DEBUG
325 		if ((error = xfs_alloc_get_rec(cnt_cur, &nfbno1, &nflen1, &i)))
326 			return error;
327 		XFS_WANT_CORRUPTED_RETURN(
328 			i == 1 && nfbno1 == fbno && nflen1 == flen);
329 #endif
330 	} else {
331 		if ((error = xfs_alloc_lookup_eq(cnt_cur, fbno, flen, &i)))
332 			return error;
333 		XFS_WANT_CORRUPTED_RETURN(i == 1);
334 	}
335 	/*
336 	 * Look up the record in the by-block tree if necessary.
337 	 */
338 	if (flags & XFSA_FIXUP_BNO_OK) {
339 #ifdef DEBUG
340 		if ((error = xfs_alloc_get_rec(bno_cur, &nfbno1, &nflen1, &i)))
341 			return error;
342 		XFS_WANT_CORRUPTED_RETURN(
343 			i == 1 && nfbno1 == fbno && nflen1 == flen);
344 #endif
345 	} else {
346 		if ((error = xfs_alloc_lookup_eq(bno_cur, fbno, flen, &i)))
347 			return error;
348 		XFS_WANT_CORRUPTED_RETURN(i == 1);
349 	}
350 
351 #ifdef DEBUG
352 	if (bno_cur->bc_nlevels == 1 && cnt_cur->bc_nlevels == 1) {
353 		struct xfs_btree_block	*bnoblock;
354 		struct xfs_btree_block	*cntblock;
355 
356 		bnoblock = XFS_BUF_TO_BLOCK(bno_cur->bc_bufs[0]);
357 		cntblock = XFS_BUF_TO_BLOCK(cnt_cur->bc_bufs[0]);
358 
359 		XFS_WANT_CORRUPTED_RETURN(
360 			bnoblock->bb_numrecs == cntblock->bb_numrecs);
361 	}
362 #endif
363 
364 	/*
365 	 * Deal with all four cases: the allocated record is contained
366 	 * within the freespace record, so we can have new freespace
367 	 * at either (or both) end, or no freespace remaining.
368 	 */
369 	if (rbno == fbno && rlen == flen)
370 		nfbno1 = nfbno2 = NULLAGBLOCK;
371 	else if (rbno == fbno) {
372 		nfbno1 = rbno + rlen;
373 		nflen1 = flen - rlen;
374 		nfbno2 = NULLAGBLOCK;
375 	} else if (rbno + rlen == fbno + flen) {
376 		nfbno1 = fbno;
377 		nflen1 = flen - rlen;
378 		nfbno2 = NULLAGBLOCK;
379 	} else {
380 		nfbno1 = fbno;
381 		nflen1 = rbno - fbno;
382 		nfbno2 = rbno + rlen;
383 		nflen2 = (fbno + flen) - nfbno2;
384 	}
385 	/*
386 	 * Delete the entry from the by-size btree.
387 	 */
388 	if ((error = xfs_btree_delete(cnt_cur, &i)))
389 		return error;
390 	XFS_WANT_CORRUPTED_RETURN(i == 1);
391 	/*
392 	 * Add new by-size btree entry(s).
393 	 */
394 	if (nfbno1 != NULLAGBLOCK) {
395 		if ((error = xfs_alloc_lookup_eq(cnt_cur, nfbno1, nflen1, &i)))
396 			return error;
397 		XFS_WANT_CORRUPTED_RETURN(i == 0);
398 		if ((error = xfs_btree_insert(cnt_cur, &i)))
399 			return error;
400 		XFS_WANT_CORRUPTED_RETURN(i == 1);
401 	}
402 	if (nfbno2 != NULLAGBLOCK) {
403 		if ((error = xfs_alloc_lookup_eq(cnt_cur, nfbno2, nflen2, &i)))
404 			return error;
405 		XFS_WANT_CORRUPTED_RETURN(i == 0);
406 		if ((error = xfs_btree_insert(cnt_cur, &i)))
407 			return error;
408 		XFS_WANT_CORRUPTED_RETURN(i == 1);
409 	}
410 	/*
411 	 * Fix up the by-block btree entry(s).
412 	 */
413 	if (nfbno1 == NULLAGBLOCK) {
414 		/*
415 		 * No remaining freespace, just delete the by-block tree entry.
416 		 */
417 		if ((error = xfs_btree_delete(bno_cur, &i)))
418 			return error;
419 		XFS_WANT_CORRUPTED_RETURN(i == 1);
420 	} else {
421 		/*
422 		 * Update the by-block entry to start later|be shorter.
423 		 */
424 		if ((error = xfs_alloc_update(bno_cur, nfbno1, nflen1)))
425 			return error;
426 	}
427 	if (nfbno2 != NULLAGBLOCK) {
428 		/*
429 		 * 2 resulting free entries, need to add one.
430 		 */
431 		if ((error = xfs_alloc_lookup_eq(bno_cur, nfbno2, nflen2, &i)))
432 			return error;
433 		XFS_WANT_CORRUPTED_RETURN(i == 0);
434 		if ((error = xfs_btree_insert(bno_cur, &i)))
435 			return error;
436 		XFS_WANT_CORRUPTED_RETURN(i == 1);
437 	}
438 	return 0;
439 }
440 
441 static bool
xfs_agfl_verify(struct xfs_buf * bp)442 xfs_agfl_verify(
443 	struct xfs_buf	*bp)
444 {
445 	struct xfs_mount *mp = bp->b_target->bt_mount;
446 	struct xfs_agfl	*agfl = XFS_BUF_TO_AGFL(bp);
447 	int		i;
448 
449 	if (!uuid_equal(&agfl->agfl_uuid, &mp->m_sb.sb_uuid))
450 		return false;
451 	if (be32_to_cpu(agfl->agfl_magicnum) != XFS_AGFL_MAGIC)
452 		return false;
453 	/*
454 	 * during growfs operations, the perag is not fully initialised,
455 	 * so we can't use it for any useful checking. growfs ensures we can't
456 	 * use it by using uncached buffers that don't have the perag attached
457 	 * so we can detect and avoid this problem.
458 	 */
459 	if (bp->b_pag && be32_to_cpu(agfl->agfl_seqno) != bp->b_pag->pag_agno)
460 		return false;
461 
462 	for (i = 0; i < XFS_AGFL_SIZE(mp); i++) {
463 		if (be32_to_cpu(agfl->agfl_bno[i]) != NULLAGBLOCK &&
464 		    be32_to_cpu(agfl->agfl_bno[i]) >= mp->m_sb.sb_agblocks)
465 			return false;
466 	}
467 	return true;
468 }
469 
470 static void
xfs_agfl_read_verify(struct xfs_buf * bp)471 xfs_agfl_read_verify(
472 	struct xfs_buf	*bp)
473 {
474 	struct xfs_mount *mp = bp->b_target->bt_mount;
475 
476 	/*
477 	 * There is no verification of non-crc AGFLs because mkfs does not
478 	 * initialise the AGFL to zero or NULL. Hence the only valid part of the
479 	 * AGFL is what the AGF says is active. We can't get to the AGF, so we
480 	 * can't verify just those entries are valid.
481 	 */
482 	if (!xfs_sb_version_hascrc(&mp->m_sb))
483 		return;
484 
485 	if (!xfs_buf_verify_cksum(bp, XFS_AGFL_CRC_OFF))
486 		xfs_buf_ioerror(bp, -EFSBADCRC);
487 	else if (!xfs_agfl_verify(bp))
488 		xfs_buf_ioerror(bp, -EFSCORRUPTED);
489 
490 	if (bp->b_error)
491 		xfs_verifier_error(bp);
492 }
493 
494 static void
xfs_agfl_write_verify(struct xfs_buf * bp)495 xfs_agfl_write_verify(
496 	struct xfs_buf	*bp)
497 {
498 	struct xfs_mount *mp = bp->b_target->bt_mount;
499 	struct xfs_buf_log_item	*bip = bp->b_fspriv;
500 
501 	/* no verification of non-crc AGFLs */
502 	if (!xfs_sb_version_hascrc(&mp->m_sb))
503 		return;
504 
505 	if (!xfs_agfl_verify(bp)) {
506 		xfs_buf_ioerror(bp, -EFSCORRUPTED);
507 		xfs_verifier_error(bp);
508 		return;
509 	}
510 
511 	if (bip)
512 		XFS_BUF_TO_AGFL(bp)->agfl_lsn = cpu_to_be64(bip->bli_item.li_lsn);
513 
514 	xfs_buf_update_cksum(bp, XFS_AGFL_CRC_OFF);
515 }
516 
517 const struct xfs_buf_ops xfs_agfl_buf_ops = {
518 	.name = "xfs_agfl",
519 	.verify_read = xfs_agfl_read_verify,
520 	.verify_write = xfs_agfl_write_verify,
521 };
522 
523 /*
524  * Read in the allocation group free block array.
525  */
526 STATIC int				/* error */
xfs_alloc_read_agfl(xfs_mount_t * mp,xfs_trans_t * tp,xfs_agnumber_t agno,xfs_buf_t ** bpp)527 xfs_alloc_read_agfl(
528 	xfs_mount_t	*mp,		/* mount point structure */
529 	xfs_trans_t	*tp,		/* transaction pointer */
530 	xfs_agnumber_t	agno,		/* allocation group number */
531 	xfs_buf_t	**bpp)		/* buffer for the ag free block array */
532 {
533 	xfs_buf_t	*bp;		/* return value */
534 	int		error;
535 
536 	ASSERT(agno != NULLAGNUMBER);
537 	error = xfs_trans_read_buf(
538 			mp, tp, mp->m_ddev_targp,
539 			XFS_AG_DADDR(mp, agno, XFS_AGFL_DADDR(mp)),
540 			XFS_FSS_TO_BB(mp, 1), 0, &bp, &xfs_agfl_buf_ops);
541 	if (error)
542 		return error;
543 	xfs_buf_set_ref(bp, XFS_AGFL_REF);
544 	*bpp = bp;
545 	return 0;
546 }
547 
548 STATIC int
xfs_alloc_update_counters(struct xfs_trans * tp,struct xfs_perag * pag,struct xfs_buf * agbp,long len)549 xfs_alloc_update_counters(
550 	struct xfs_trans	*tp,
551 	struct xfs_perag	*pag,
552 	struct xfs_buf		*agbp,
553 	long			len)
554 {
555 	struct xfs_agf		*agf = XFS_BUF_TO_AGF(agbp);
556 
557 	pag->pagf_freeblks += len;
558 	be32_add_cpu(&agf->agf_freeblks, len);
559 
560 	xfs_trans_agblocks_delta(tp, len);
561 	if (unlikely(be32_to_cpu(agf->agf_freeblks) >
562 		     be32_to_cpu(agf->agf_length)))
563 		return -EFSCORRUPTED;
564 
565 	xfs_alloc_log_agf(tp, agbp, XFS_AGF_FREEBLKS);
566 	return 0;
567 }
568 
569 /*
570  * Allocation group level functions.
571  */
572 
573 /*
574  * Allocate a variable extent in the allocation group agno.
575  * Type and bno are used to determine where in the allocation group the
576  * extent will start.
577  * Extent's length (returned in *len) will be between minlen and maxlen,
578  * and of the form k * prod + mod unless there's nothing that large.
579  * Return the starting a.g. block, or NULLAGBLOCK if we can't do it.
580  */
581 STATIC int			/* error */
xfs_alloc_ag_vextent(xfs_alloc_arg_t * args)582 xfs_alloc_ag_vextent(
583 	xfs_alloc_arg_t	*args)	/* argument structure for allocation */
584 {
585 	int		error=0;
586 
587 	ASSERT(args->minlen > 0);
588 	ASSERT(args->maxlen > 0);
589 	ASSERT(args->minlen <= args->maxlen);
590 	ASSERT(args->mod < args->prod);
591 	ASSERT(args->alignment > 0);
592 	/*
593 	 * Branch to correct routine based on the type.
594 	 */
595 	args->wasfromfl = 0;
596 	switch (args->type) {
597 	case XFS_ALLOCTYPE_THIS_AG:
598 		error = xfs_alloc_ag_vextent_size(args);
599 		break;
600 	case XFS_ALLOCTYPE_NEAR_BNO:
601 		error = xfs_alloc_ag_vextent_near(args);
602 		break;
603 	case XFS_ALLOCTYPE_THIS_BNO:
604 		error = xfs_alloc_ag_vextent_exact(args);
605 		break;
606 	default:
607 		ASSERT(0);
608 		/* NOTREACHED */
609 	}
610 
611 	if (error || args->agbno == NULLAGBLOCK)
612 		return error;
613 
614 	ASSERT(args->len >= args->minlen);
615 	ASSERT(args->len <= args->maxlen);
616 	ASSERT(!args->wasfromfl || !args->isfl);
617 	ASSERT(args->agbno % args->alignment == 0);
618 
619 	if (!args->wasfromfl) {
620 		error = xfs_alloc_update_counters(args->tp, args->pag,
621 						  args->agbp,
622 						  -((long)(args->len)));
623 		if (error)
624 			return error;
625 
626 		ASSERT(!xfs_extent_busy_search(args->mp, args->agno,
627 					      args->agbno, args->len));
628 	}
629 
630 	if (!args->isfl) {
631 		xfs_trans_mod_sb(args->tp, args->wasdel ?
632 				 XFS_TRANS_SB_RES_FDBLOCKS :
633 				 XFS_TRANS_SB_FDBLOCKS,
634 				 -((long)(args->len)));
635 	}
636 
637 	XFS_STATS_INC(xs_allocx);
638 	XFS_STATS_ADD(xs_allocb, args->len);
639 	return error;
640 }
641 
642 /*
643  * Allocate a variable extent at exactly agno/bno.
644  * Extent's length (returned in *len) will be between minlen and maxlen,
645  * and of the form k * prod + mod unless there's nothing that large.
646  * Return the starting a.g. block (bno), or NULLAGBLOCK if we can't do it.
647  */
648 STATIC int			/* error */
xfs_alloc_ag_vextent_exact(xfs_alloc_arg_t * args)649 xfs_alloc_ag_vextent_exact(
650 	xfs_alloc_arg_t	*args)	/* allocation argument structure */
651 {
652 	xfs_btree_cur_t	*bno_cur;/* by block-number btree cursor */
653 	xfs_btree_cur_t	*cnt_cur;/* by count btree cursor */
654 	int		error;
655 	xfs_agblock_t	fbno;	/* start block of found extent */
656 	xfs_extlen_t	flen;	/* length of found extent */
657 	xfs_agblock_t	tbno;	/* start block of trimmed extent */
658 	xfs_extlen_t	tlen;	/* length of trimmed extent */
659 	xfs_agblock_t	tend;	/* end block of trimmed extent */
660 	int		i;	/* success/failure of operation */
661 
662 	ASSERT(args->alignment == 1);
663 
664 	/*
665 	 * Allocate/initialize a cursor for the by-number freespace btree.
666 	 */
667 	bno_cur = xfs_allocbt_init_cursor(args->mp, args->tp, args->agbp,
668 					  args->agno, XFS_BTNUM_BNO);
669 
670 	/*
671 	 * Lookup bno and minlen in the btree (minlen is irrelevant, really).
672 	 * Look for the closest free block <= bno, it must contain bno
673 	 * if any free block does.
674 	 */
675 	error = xfs_alloc_lookup_le(bno_cur, args->agbno, args->minlen, &i);
676 	if (error)
677 		goto error0;
678 	if (!i)
679 		goto not_found;
680 
681 	/*
682 	 * Grab the freespace record.
683 	 */
684 	error = xfs_alloc_get_rec(bno_cur, &fbno, &flen, &i);
685 	if (error)
686 		goto error0;
687 	XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
688 	ASSERT(fbno <= args->agbno);
689 
690 	/*
691 	 * Check for overlapping busy extents.
692 	 */
693 	xfs_extent_busy_trim(args, fbno, flen, &tbno, &tlen);
694 
695 	/*
696 	 * Give up if the start of the extent is busy, or the freespace isn't
697 	 * long enough for the minimum request.
698 	 */
699 	if (tbno > args->agbno)
700 		goto not_found;
701 	if (tlen < args->minlen)
702 		goto not_found;
703 	tend = tbno + tlen;
704 	if (tend < args->agbno + args->minlen)
705 		goto not_found;
706 
707 	/*
708 	 * End of extent will be smaller of the freespace end and the
709 	 * maximal requested end.
710 	 *
711 	 * Fix the length according to mod and prod if given.
712 	 */
713 	args->len = XFS_AGBLOCK_MIN(tend, args->agbno + args->maxlen)
714 						- args->agbno;
715 	xfs_alloc_fix_len(args);
716 	if (!xfs_alloc_fix_minleft(args))
717 		goto not_found;
718 
719 	ASSERT(args->agbno + args->len <= tend);
720 
721 	/*
722 	 * We are allocating agbno for args->len
723 	 * Allocate/initialize a cursor for the by-size btree.
724 	 */
725 	cnt_cur = xfs_allocbt_init_cursor(args->mp, args->tp, args->agbp,
726 		args->agno, XFS_BTNUM_CNT);
727 	ASSERT(args->agbno + args->len <=
728 		be32_to_cpu(XFS_BUF_TO_AGF(args->agbp)->agf_length));
729 	error = xfs_alloc_fixup_trees(cnt_cur, bno_cur, fbno, flen, args->agbno,
730 				      args->len, XFSA_FIXUP_BNO_OK);
731 	if (error) {
732 		xfs_btree_del_cursor(cnt_cur, XFS_BTREE_ERROR);
733 		goto error0;
734 	}
735 
736 	xfs_btree_del_cursor(bno_cur, XFS_BTREE_NOERROR);
737 	xfs_btree_del_cursor(cnt_cur, XFS_BTREE_NOERROR);
738 
739 	args->wasfromfl = 0;
740 	trace_xfs_alloc_exact_done(args);
741 	return 0;
742 
743 not_found:
744 	/* Didn't find it, return null. */
745 	xfs_btree_del_cursor(bno_cur, XFS_BTREE_NOERROR);
746 	args->agbno = NULLAGBLOCK;
747 	trace_xfs_alloc_exact_notfound(args);
748 	return 0;
749 
750 error0:
751 	xfs_btree_del_cursor(bno_cur, XFS_BTREE_ERROR);
752 	trace_xfs_alloc_exact_error(args);
753 	return error;
754 }
755 
756 /*
757  * Search the btree in a given direction via the search cursor and compare
758  * the records found against the good extent we've already found.
759  */
760 STATIC int
xfs_alloc_find_best_extent(struct xfs_alloc_arg * args,struct xfs_btree_cur ** gcur,struct xfs_btree_cur ** scur,xfs_agblock_t gdiff,xfs_agblock_t * sbno,xfs_extlen_t * slen,xfs_agblock_t * sbnoa,xfs_extlen_t * slena,int dir)761 xfs_alloc_find_best_extent(
762 	struct xfs_alloc_arg	*args,	/* allocation argument structure */
763 	struct xfs_btree_cur	**gcur,	/* good cursor */
764 	struct xfs_btree_cur	**scur,	/* searching cursor */
765 	xfs_agblock_t		gdiff,	/* difference for search comparison */
766 	xfs_agblock_t		*sbno,	/* extent found by search */
767 	xfs_extlen_t		*slen,	/* extent length */
768 	xfs_agblock_t		*sbnoa,	/* aligned extent found by search */
769 	xfs_extlen_t		*slena,	/* aligned extent length */
770 	int			dir)	/* 0 = search right, 1 = search left */
771 {
772 	xfs_agblock_t		new;
773 	xfs_agblock_t		sdiff;
774 	int			error;
775 	int			i;
776 
777 	/* The good extent is perfect, no need to  search. */
778 	if (!gdiff)
779 		goto out_use_good;
780 
781 	/*
782 	 * Look until we find a better one, run out of space or run off the end.
783 	 */
784 	do {
785 		error = xfs_alloc_get_rec(*scur, sbno, slen, &i);
786 		if (error)
787 			goto error0;
788 		XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
789 		xfs_alloc_compute_aligned(args, *sbno, *slen, sbnoa, slena);
790 
791 		/*
792 		 * The good extent is closer than this one.
793 		 */
794 		if (!dir) {
795 			if (*sbnoa >= args->agbno + gdiff)
796 				goto out_use_good;
797 		} else {
798 			if (*sbnoa <= args->agbno - gdiff)
799 				goto out_use_good;
800 		}
801 
802 		/*
803 		 * Same distance, compare length and pick the best.
804 		 */
805 		if (*slena >= args->minlen) {
806 			args->len = XFS_EXTLEN_MIN(*slena, args->maxlen);
807 			xfs_alloc_fix_len(args);
808 
809 			sdiff = xfs_alloc_compute_diff(args->agbno, args->len,
810 						       args->alignment,
811 						       args->userdata, *sbnoa,
812 						       *slena, &new);
813 
814 			/*
815 			 * Choose closer size and invalidate other cursor.
816 			 */
817 			if (sdiff < gdiff)
818 				goto out_use_search;
819 			goto out_use_good;
820 		}
821 
822 		if (!dir)
823 			error = xfs_btree_increment(*scur, 0, &i);
824 		else
825 			error = xfs_btree_decrement(*scur, 0, &i);
826 		if (error)
827 			goto error0;
828 	} while (i);
829 
830 out_use_good:
831 	xfs_btree_del_cursor(*scur, XFS_BTREE_NOERROR);
832 	*scur = NULL;
833 	return 0;
834 
835 out_use_search:
836 	xfs_btree_del_cursor(*gcur, XFS_BTREE_NOERROR);
837 	*gcur = NULL;
838 	return 0;
839 
840 error0:
841 	/* caller invalidates cursors */
842 	return error;
843 }
844 
845 /*
846  * Allocate a variable extent near bno in the allocation group agno.
847  * Extent's length (returned in len) will be between minlen and maxlen,
848  * and of the form k * prod + mod unless there's nothing that large.
849  * Return the starting a.g. block, or NULLAGBLOCK if we can't do it.
850  */
851 STATIC int				/* error */
xfs_alloc_ag_vextent_near(xfs_alloc_arg_t * args)852 xfs_alloc_ag_vextent_near(
853 	xfs_alloc_arg_t	*args)		/* allocation argument structure */
854 {
855 	xfs_btree_cur_t	*bno_cur_gt;	/* cursor for bno btree, right side */
856 	xfs_btree_cur_t	*bno_cur_lt;	/* cursor for bno btree, left side */
857 	xfs_btree_cur_t	*cnt_cur;	/* cursor for count btree */
858 	xfs_agblock_t	gtbno;		/* start bno of right side entry */
859 	xfs_agblock_t	gtbnoa;		/* aligned ... */
860 	xfs_extlen_t	gtdiff;		/* difference to right side entry */
861 	xfs_extlen_t	gtlen;		/* length of right side entry */
862 	xfs_extlen_t	gtlena;		/* aligned ... */
863 	xfs_agblock_t	gtnew;		/* useful start bno of right side */
864 	int		error;		/* error code */
865 	int		i;		/* result code, temporary */
866 	int		j;		/* result code, temporary */
867 	xfs_agblock_t	ltbno;		/* start bno of left side entry */
868 	xfs_agblock_t	ltbnoa;		/* aligned ... */
869 	xfs_extlen_t	ltdiff;		/* difference to left side entry */
870 	xfs_extlen_t	ltlen;		/* length of left side entry */
871 	xfs_extlen_t	ltlena;		/* aligned ... */
872 	xfs_agblock_t	ltnew;		/* useful start bno of left side */
873 	xfs_extlen_t	rlen;		/* length of returned extent */
874 	int		forced = 0;
875 #ifdef DEBUG
876 	/*
877 	 * Randomly don't execute the first algorithm.
878 	 */
879 	int		dofirst;	/* set to do first algorithm */
880 
881 	dofirst = prandom_u32() & 1;
882 #endif
883 
884 restart:
885 	bno_cur_lt = NULL;
886 	bno_cur_gt = NULL;
887 	ltlen = 0;
888 	gtlena = 0;
889 	ltlena = 0;
890 
891 	/*
892 	 * Get a cursor for the by-size btree.
893 	 */
894 	cnt_cur = xfs_allocbt_init_cursor(args->mp, args->tp, args->agbp,
895 		args->agno, XFS_BTNUM_CNT);
896 
897 	/*
898 	 * See if there are any free extents as big as maxlen.
899 	 */
900 	if ((error = xfs_alloc_lookup_ge(cnt_cur, 0, args->maxlen, &i)))
901 		goto error0;
902 	/*
903 	 * If none, then pick up the last entry in the tree unless the
904 	 * tree is empty.
905 	 */
906 	if (!i) {
907 		if ((error = xfs_alloc_ag_vextent_small(args, cnt_cur, &ltbno,
908 				&ltlen, &i)))
909 			goto error0;
910 		if (i == 0 || ltlen == 0) {
911 			xfs_btree_del_cursor(cnt_cur, XFS_BTREE_NOERROR);
912 			trace_xfs_alloc_near_noentry(args);
913 			return 0;
914 		}
915 		ASSERT(i == 1);
916 	}
917 	args->wasfromfl = 0;
918 
919 	/*
920 	 * First algorithm.
921 	 * If the requested extent is large wrt the freespaces available
922 	 * in this a.g., then the cursor will be pointing to a btree entry
923 	 * near the right edge of the tree.  If it's in the last btree leaf
924 	 * block, then we just examine all the entries in that block
925 	 * that are big enough, and pick the best one.
926 	 * This is written as a while loop so we can break out of it,
927 	 * but we never loop back to the top.
928 	 */
929 	while (xfs_btree_islastblock(cnt_cur, 0)) {
930 		xfs_extlen_t	bdiff;
931 		int		besti=0;
932 		xfs_extlen_t	blen=0;
933 		xfs_agblock_t	bnew=0;
934 
935 #ifdef DEBUG
936 		if (dofirst)
937 			break;
938 #endif
939 		/*
940 		 * Start from the entry that lookup found, sequence through
941 		 * all larger free blocks.  If we're actually pointing at a
942 		 * record smaller than maxlen, go to the start of this block,
943 		 * and skip all those smaller than minlen.
944 		 */
945 		if (ltlen || args->alignment > 1) {
946 			cnt_cur->bc_ptrs[0] = 1;
947 			do {
948 				if ((error = xfs_alloc_get_rec(cnt_cur, &ltbno,
949 						&ltlen, &i)))
950 					goto error0;
951 				XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
952 				if (ltlen >= args->minlen)
953 					break;
954 				if ((error = xfs_btree_increment(cnt_cur, 0, &i)))
955 					goto error0;
956 			} while (i);
957 			ASSERT(ltlen >= args->minlen);
958 			if (!i)
959 				break;
960 		}
961 		i = cnt_cur->bc_ptrs[0];
962 		for (j = 1, blen = 0, bdiff = 0;
963 		     !error && j && (blen < args->maxlen || bdiff > 0);
964 		     error = xfs_btree_increment(cnt_cur, 0, &j)) {
965 			/*
966 			 * For each entry, decide if it's better than
967 			 * the previous best entry.
968 			 */
969 			if ((error = xfs_alloc_get_rec(cnt_cur, &ltbno, &ltlen, &i)))
970 				goto error0;
971 			XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
972 			xfs_alloc_compute_aligned(args, ltbno, ltlen,
973 						  &ltbnoa, &ltlena);
974 			if (ltlena < args->minlen)
975 				continue;
976 			args->len = XFS_EXTLEN_MIN(ltlena, args->maxlen);
977 			xfs_alloc_fix_len(args);
978 			ASSERT(args->len >= args->minlen);
979 			if (args->len < blen)
980 				continue;
981 			ltdiff = xfs_alloc_compute_diff(args->agbno, args->len,
982 				args->alignment, args->userdata, ltbnoa,
983 				ltlena, &ltnew);
984 			if (ltnew != NULLAGBLOCK &&
985 			    (args->len > blen || ltdiff < bdiff)) {
986 				bdiff = ltdiff;
987 				bnew = ltnew;
988 				blen = args->len;
989 				besti = cnt_cur->bc_ptrs[0];
990 			}
991 		}
992 		/*
993 		 * It didn't work.  We COULD be in a case where
994 		 * there's a good record somewhere, so try again.
995 		 */
996 		if (blen == 0)
997 			break;
998 		/*
999 		 * Point at the best entry, and retrieve it again.
1000 		 */
1001 		cnt_cur->bc_ptrs[0] = besti;
1002 		if ((error = xfs_alloc_get_rec(cnt_cur, &ltbno, &ltlen, &i)))
1003 			goto error0;
1004 		XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
1005 		ASSERT(ltbno + ltlen <= be32_to_cpu(XFS_BUF_TO_AGF(args->agbp)->agf_length));
1006 		args->len = blen;
1007 		if (!xfs_alloc_fix_minleft(args)) {
1008 			xfs_btree_del_cursor(cnt_cur, XFS_BTREE_NOERROR);
1009 			trace_xfs_alloc_near_nominleft(args);
1010 			return 0;
1011 		}
1012 		blen = args->len;
1013 		/*
1014 		 * We are allocating starting at bnew for blen blocks.
1015 		 */
1016 		args->agbno = bnew;
1017 		ASSERT(bnew >= ltbno);
1018 		ASSERT(bnew + blen <= ltbno + ltlen);
1019 		/*
1020 		 * Set up a cursor for the by-bno tree.
1021 		 */
1022 		bno_cur_lt = xfs_allocbt_init_cursor(args->mp, args->tp,
1023 			args->agbp, args->agno, XFS_BTNUM_BNO);
1024 		/*
1025 		 * Fix up the btree entries.
1026 		 */
1027 		if ((error = xfs_alloc_fixup_trees(cnt_cur, bno_cur_lt, ltbno,
1028 				ltlen, bnew, blen, XFSA_FIXUP_CNT_OK)))
1029 			goto error0;
1030 		xfs_btree_del_cursor(cnt_cur, XFS_BTREE_NOERROR);
1031 		xfs_btree_del_cursor(bno_cur_lt, XFS_BTREE_NOERROR);
1032 
1033 		trace_xfs_alloc_near_first(args);
1034 		return 0;
1035 	}
1036 	/*
1037 	 * Second algorithm.
1038 	 * Search in the by-bno tree to the left and to the right
1039 	 * simultaneously, until in each case we find a space big enough,
1040 	 * or run into the edge of the tree.  When we run into the edge,
1041 	 * we deallocate that cursor.
1042 	 * If both searches succeed, we compare the two spaces and pick
1043 	 * the better one.
1044 	 * With alignment, it's possible for both to fail; the upper
1045 	 * level algorithm that picks allocation groups for allocations
1046 	 * is not supposed to do this.
1047 	 */
1048 	/*
1049 	 * Allocate and initialize the cursor for the leftward search.
1050 	 */
1051 	bno_cur_lt = xfs_allocbt_init_cursor(args->mp, args->tp, args->agbp,
1052 		args->agno, XFS_BTNUM_BNO);
1053 	/*
1054 	 * Lookup <= bno to find the leftward search's starting point.
1055 	 */
1056 	if ((error = xfs_alloc_lookup_le(bno_cur_lt, args->agbno, args->maxlen, &i)))
1057 		goto error0;
1058 	if (!i) {
1059 		/*
1060 		 * Didn't find anything; use this cursor for the rightward
1061 		 * search.
1062 		 */
1063 		bno_cur_gt = bno_cur_lt;
1064 		bno_cur_lt = NULL;
1065 	}
1066 	/*
1067 	 * Found something.  Duplicate the cursor for the rightward search.
1068 	 */
1069 	else if ((error = xfs_btree_dup_cursor(bno_cur_lt, &bno_cur_gt)))
1070 		goto error0;
1071 	/*
1072 	 * Increment the cursor, so we will point at the entry just right
1073 	 * of the leftward entry if any, or to the leftmost entry.
1074 	 */
1075 	if ((error = xfs_btree_increment(bno_cur_gt, 0, &i)))
1076 		goto error0;
1077 	if (!i) {
1078 		/*
1079 		 * It failed, there are no rightward entries.
1080 		 */
1081 		xfs_btree_del_cursor(bno_cur_gt, XFS_BTREE_NOERROR);
1082 		bno_cur_gt = NULL;
1083 	}
1084 	/*
1085 	 * Loop going left with the leftward cursor, right with the
1086 	 * rightward cursor, until either both directions give up or
1087 	 * we find an entry at least as big as minlen.
1088 	 */
1089 	do {
1090 		if (bno_cur_lt) {
1091 			if ((error = xfs_alloc_get_rec(bno_cur_lt, &ltbno, &ltlen, &i)))
1092 				goto error0;
1093 			XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
1094 			xfs_alloc_compute_aligned(args, ltbno, ltlen,
1095 						  &ltbnoa, &ltlena);
1096 			if (ltlena >= args->minlen)
1097 				break;
1098 			if ((error = xfs_btree_decrement(bno_cur_lt, 0, &i)))
1099 				goto error0;
1100 			if (!i) {
1101 				xfs_btree_del_cursor(bno_cur_lt,
1102 						     XFS_BTREE_NOERROR);
1103 				bno_cur_lt = NULL;
1104 			}
1105 		}
1106 		if (bno_cur_gt) {
1107 			if ((error = xfs_alloc_get_rec(bno_cur_gt, &gtbno, &gtlen, &i)))
1108 				goto error0;
1109 			XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
1110 			xfs_alloc_compute_aligned(args, gtbno, gtlen,
1111 						  &gtbnoa, &gtlena);
1112 			if (gtlena >= args->minlen)
1113 				break;
1114 			if ((error = xfs_btree_increment(bno_cur_gt, 0, &i)))
1115 				goto error0;
1116 			if (!i) {
1117 				xfs_btree_del_cursor(bno_cur_gt,
1118 						     XFS_BTREE_NOERROR);
1119 				bno_cur_gt = NULL;
1120 			}
1121 		}
1122 	} while (bno_cur_lt || bno_cur_gt);
1123 
1124 	/*
1125 	 * Got both cursors still active, need to find better entry.
1126 	 */
1127 	if (bno_cur_lt && bno_cur_gt) {
1128 		if (ltlena >= args->minlen) {
1129 			/*
1130 			 * Left side is good, look for a right side entry.
1131 			 */
1132 			args->len = XFS_EXTLEN_MIN(ltlena, args->maxlen);
1133 			xfs_alloc_fix_len(args);
1134 			ltdiff = xfs_alloc_compute_diff(args->agbno, args->len,
1135 				args->alignment, args->userdata, ltbnoa,
1136 				ltlena, &ltnew);
1137 
1138 			error = xfs_alloc_find_best_extent(args,
1139 						&bno_cur_lt, &bno_cur_gt,
1140 						ltdiff, &gtbno, &gtlen,
1141 						&gtbnoa, &gtlena,
1142 						0 /* search right */);
1143 		} else {
1144 			ASSERT(gtlena >= args->minlen);
1145 
1146 			/*
1147 			 * Right side is good, look for a left side entry.
1148 			 */
1149 			args->len = XFS_EXTLEN_MIN(gtlena, args->maxlen);
1150 			xfs_alloc_fix_len(args);
1151 			gtdiff = xfs_alloc_compute_diff(args->agbno, args->len,
1152 				args->alignment, args->userdata, gtbnoa,
1153 				gtlena, &gtnew);
1154 
1155 			error = xfs_alloc_find_best_extent(args,
1156 						&bno_cur_gt, &bno_cur_lt,
1157 						gtdiff, &ltbno, &ltlen,
1158 						&ltbnoa, &ltlena,
1159 						1 /* search left */);
1160 		}
1161 
1162 		if (error)
1163 			goto error0;
1164 	}
1165 
1166 	/*
1167 	 * If we couldn't get anything, give up.
1168 	 */
1169 	if (bno_cur_lt == NULL && bno_cur_gt == NULL) {
1170 		xfs_btree_del_cursor(cnt_cur, XFS_BTREE_NOERROR);
1171 
1172 		if (!forced++) {
1173 			trace_xfs_alloc_near_busy(args);
1174 			xfs_log_force(args->mp, XFS_LOG_SYNC);
1175 			goto restart;
1176 		}
1177 		trace_xfs_alloc_size_neither(args);
1178 		args->agbno = NULLAGBLOCK;
1179 		return 0;
1180 	}
1181 
1182 	/*
1183 	 * At this point we have selected a freespace entry, either to the
1184 	 * left or to the right.  If it's on the right, copy all the
1185 	 * useful variables to the "left" set so we only have one
1186 	 * copy of this code.
1187 	 */
1188 	if (bno_cur_gt) {
1189 		bno_cur_lt = bno_cur_gt;
1190 		bno_cur_gt = NULL;
1191 		ltbno = gtbno;
1192 		ltbnoa = gtbnoa;
1193 		ltlen = gtlen;
1194 		ltlena = gtlena;
1195 		j = 1;
1196 	} else
1197 		j = 0;
1198 
1199 	/*
1200 	 * Fix up the length and compute the useful address.
1201 	 */
1202 	args->len = XFS_EXTLEN_MIN(ltlena, args->maxlen);
1203 	xfs_alloc_fix_len(args);
1204 	if (!xfs_alloc_fix_minleft(args)) {
1205 		trace_xfs_alloc_near_nominleft(args);
1206 		xfs_btree_del_cursor(bno_cur_lt, XFS_BTREE_NOERROR);
1207 		xfs_btree_del_cursor(cnt_cur, XFS_BTREE_NOERROR);
1208 		return 0;
1209 	}
1210 	rlen = args->len;
1211 	(void)xfs_alloc_compute_diff(args->agbno, rlen, args->alignment,
1212 				     args->userdata, ltbnoa, ltlena, &ltnew);
1213 	ASSERT(ltnew >= ltbno);
1214 	ASSERT(ltnew + rlen <= ltbnoa + ltlena);
1215 	ASSERT(ltnew + rlen <= be32_to_cpu(XFS_BUF_TO_AGF(args->agbp)->agf_length));
1216 	args->agbno = ltnew;
1217 
1218 	if ((error = xfs_alloc_fixup_trees(cnt_cur, bno_cur_lt, ltbno, ltlen,
1219 			ltnew, rlen, XFSA_FIXUP_BNO_OK)))
1220 		goto error0;
1221 
1222 	if (j)
1223 		trace_xfs_alloc_near_greater(args);
1224 	else
1225 		trace_xfs_alloc_near_lesser(args);
1226 
1227 	xfs_btree_del_cursor(cnt_cur, XFS_BTREE_NOERROR);
1228 	xfs_btree_del_cursor(bno_cur_lt, XFS_BTREE_NOERROR);
1229 	return 0;
1230 
1231  error0:
1232 	trace_xfs_alloc_near_error(args);
1233 	if (cnt_cur != NULL)
1234 		xfs_btree_del_cursor(cnt_cur, XFS_BTREE_ERROR);
1235 	if (bno_cur_lt != NULL)
1236 		xfs_btree_del_cursor(bno_cur_lt, XFS_BTREE_ERROR);
1237 	if (bno_cur_gt != NULL)
1238 		xfs_btree_del_cursor(bno_cur_gt, XFS_BTREE_ERROR);
1239 	return error;
1240 }
1241 
1242 /*
1243  * Allocate a variable extent anywhere in the allocation group agno.
1244  * Extent's length (returned in len) will be between minlen and maxlen,
1245  * and of the form k * prod + mod unless there's nothing that large.
1246  * Return the starting a.g. block, or NULLAGBLOCK if we can't do it.
1247  */
1248 STATIC int				/* error */
xfs_alloc_ag_vextent_size(xfs_alloc_arg_t * args)1249 xfs_alloc_ag_vextent_size(
1250 	xfs_alloc_arg_t	*args)		/* allocation argument structure */
1251 {
1252 	xfs_btree_cur_t	*bno_cur;	/* cursor for bno btree */
1253 	xfs_btree_cur_t	*cnt_cur;	/* cursor for cnt btree */
1254 	int		error;		/* error result */
1255 	xfs_agblock_t	fbno;		/* start of found freespace */
1256 	xfs_extlen_t	flen;		/* length of found freespace */
1257 	int		i;		/* temp status variable */
1258 	xfs_agblock_t	rbno;		/* returned block number */
1259 	xfs_extlen_t	rlen;		/* length of returned extent */
1260 	int		forced = 0;
1261 
1262 restart:
1263 	/*
1264 	 * Allocate and initialize a cursor for the by-size btree.
1265 	 */
1266 	cnt_cur = xfs_allocbt_init_cursor(args->mp, args->tp, args->agbp,
1267 		args->agno, XFS_BTNUM_CNT);
1268 	bno_cur = NULL;
1269 
1270 	/*
1271 	 * Look for an entry >= maxlen+alignment-1 blocks.
1272 	 */
1273 	if ((error = xfs_alloc_lookup_ge(cnt_cur, 0,
1274 			args->maxlen + args->alignment - 1, &i)))
1275 		goto error0;
1276 
1277 	/*
1278 	 * If none or we have busy extents that we cannot allocate from, then
1279 	 * we have to settle for a smaller extent. In the case that there are
1280 	 * no large extents, this will return the last entry in the tree unless
1281 	 * the tree is empty. In the case that there are only busy large
1282 	 * extents, this will return the largest small extent unless there
1283 	 * are no smaller extents available.
1284 	 */
1285 	if (!i || forced > 1) {
1286 		error = xfs_alloc_ag_vextent_small(args, cnt_cur,
1287 						   &fbno, &flen, &i);
1288 		if (error)
1289 			goto error0;
1290 		if (i == 0 || flen == 0) {
1291 			xfs_btree_del_cursor(cnt_cur, XFS_BTREE_NOERROR);
1292 			trace_xfs_alloc_size_noentry(args);
1293 			return 0;
1294 		}
1295 		ASSERT(i == 1);
1296 		xfs_alloc_compute_aligned(args, fbno, flen, &rbno, &rlen);
1297 	} else {
1298 		/*
1299 		 * Search for a non-busy extent that is large enough.
1300 		 * If we are at low space, don't check, or if we fall of
1301 		 * the end of the btree, turn off the busy check and
1302 		 * restart.
1303 		 */
1304 		for (;;) {
1305 			error = xfs_alloc_get_rec(cnt_cur, &fbno, &flen, &i);
1306 			if (error)
1307 				goto error0;
1308 			XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
1309 
1310 			xfs_alloc_compute_aligned(args, fbno, flen,
1311 						  &rbno, &rlen);
1312 
1313 			if (rlen >= args->maxlen)
1314 				break;
1315 
1316 			error = xfs_btree_increment(cnt_cur, 0, &i);
1317 			if (error)
1318 				goto error0;
1319 			if (i == 0) {
1320 				/*
1321 				 * Our only valid extents must have been busy.
1322 				 * Make it unbusy by forcing the log out and
1323 				 * retrying. If we've been here before, forcing
1324 				 * the log isn't making the extents available,
1325 				 * which means they have probably been freed in
1326 				 * this transaction.  In that case, we have to
1327 				 * give up on them and we'll attempt a minlen
1328 				 * allocation the next time around.
1329 				 */
1330 				xfs_btree_del_cursor(cnt_cur,
1331 						     XFS_BTREE_NOERROR);
1332 				trace_xfs_alloc_size_busy(args);
1333 				if (!forced++)
1334 					xfs_log_force(args->mp, XFS_LOG_SYNC);
1335 				goto restart;
1336 			}
1337 		}
1338 	}
1339 
1340 	/*
1341 	 * In the first case above, we got the last entry in the
1342 	 * by-size btree.  Now we check to see if the space hits maxlen
1343 	 * once aligned; if not, we search left for something better.
1344 	 * This can't happen in the second case above.
1345 	 */
1346 	rlen = XFS_EXTLEN_MIN(args->maxlen, rlen);
1347 	XFS_WANT_CORRUPTED_GOTO(rlen == 0 ||
1348 			(rlen <= flen && rbno + rlen <= fbno + flen), error0);
1349 	if (rlen < args->maxlen) {
1350 		xfs_agblock_t	bestfbno;
1351 		xfs_extlen_t	bestflen;
1352 		xfs_agblock_t	bestrbno;
1353 		xfs_extlen_t	bestrlen;
1354 
1355 		bestrlen = rlen;
1356 		bestrbno = rbno;
1357 		bestflen = flen;
1358 		bestfbno = fbno;
1359 		for (;;) {
1360 			if ((error = xfs_btree_decrement(cnt_cur, 0, &i)))
1361 				goto error0;
1362 			if (i == 0)
1363 				break;
1364 			if ((error = xfs_alloc_get_rec(cnt_cur, &fbno, &flen,
1365 					&i)))
1366 				goto error0;
1367 			XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
1368 			if (flen < bestrlen)
1369 				break;
1370 			xfs_alloc_compute_aligned(args, fbno, flen,
1371 						  &rbno, &rlen);
1372 			rlen = XFS_EXTLEN_MIN(args->maxlen, rlen);
1373 			XFS_WANT_CORRUPTED_GOTO(rlen == 0 ||
1374 				(rlen <= flen && rbno + rlen <= fbno + flen),
1375 				error0);
1376 			if (rlen > bestrlen) {
1377 				bestrlen = rlen;
1378 				bestrbno = rbno;
1379 				bestflen = flen;
1380 				bestfbno = fbno;
1381 				if (rlen == args->maxlen)
1382 					break;
1383 			}
1384 		}
1385 		if ((error = xfs_alloc_lookup_eq(cnt_cur, bestfbno, bestflen,
1386 				&i)))
1387 			goto error0;
1388 		XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
1389 		rlen = bestrlen;
1390 		rbno = bestrbno;
1391 		flen = bestflen;
1392 		fbno = bestfbno;
1393 	}
1394 	args->wasfromfl = 0;
1395 	/*
1396 	 * Fix up the length.
1397 	 */
1398 	args->len = rlen;
1399 	if (rlen < args->minlen) {
1400 		if (!forced++) {
1401 			xfs_btree_del_cursor(cnt_cur, XFS_BTREE_NOERROR);
1402 			trace_xfs_alloc_size_busy(args);
1403 			xfs_log_force(args->mp, XFS_LOG_SYNC);
1404 			goto restart;
1405 		}
1406 		goto out_nominleft;
1407 	}
1408 	xfs_alloc_fix_len(args);
1409 
1410 	if (!xfs_alloc_fix_minleft(args))
1411 		goto out_nominleft;
1412 	rlen = args->len;
1413 	XFS_WANT_CORRUPTED_GOTO(rlen <= flen, error0);
1414 	/*
1415 	 * Allocate and initialize a cursor for the by-block tree.
1416 	 */
1417 	bno_cur = xfs_allocbt_init_cursor(args->mp, args->tp, args->agbp,
1418 		args->agno, XFS_BTNUM_BNO);
1419 	if ((error = xfs_alloc_fixup_trees(cnt_cur, bno_cur, fbno, flen,
1420 			rbno, rlen, XFSA_FIXUP_CNT_OK)))
1421 		goto error0;
1422 	xfs_btree_del_cursor(cnt_cur, XFS_BTREE_NOERROR);
1423 	xfs_btree_del_cursor(bno_cur, XFS_BTREE_NOERROR);
1424 	cnt_cur = bno_cur = NULL;
1425 	args->len = rlen;
1426 	args->agbno = rbno;
1427 	XFS_WANT_CORRUPTED_GOTO(
1428 		args->agbno + args->len <=
1429 			be32_to_cpu(XFS_BUF_TO_AGF(args->agbp)->agf_length),
1430 		error0);
1431 	trace_xfs_alloc_size_done(args);
1432 	return 0;
1433 
1434 error0:
1435 	trace_xfs_alloc_size_error(args);
1436 	if (cnt_cur)
1437 		xfs_btree_del_cursor(cnt_cur, XFS_BTREE_ERROR);
1438 	if (bno_cur)
1439 		xfs_btree_del_cursor(bno_cur, XFS_BTREE_ERROR);
1440 	return error;
1441 
1442 out_nominleft:
1443 	xfs_btree_del_cursor(cnt_cur, XFS_BTREE_NOERROR);
1444 	trace_xfs_alloc_size_nominleft(args);
1445 	args->agbno = NULLAGBLOCK;
1446 	return 0;
1447 }
1448 
1449 /*
1450  * Deal with the case where only small freespaces remain.
1451  * Either return the contents of the last freespace record,
1452  * or allocate space from the freelist if there is nothing in the tree.
1453  */
1454 STATIC int			/* error */
xfs_alloc_ag_vextent_small(xfs_alloc_arg_t * args,xfs_btree_cur_t * ccur,xfs_agblock_t * fbnop,xfs_extlen_t * flenp,int * stat)1455 xfs_alloc_ag_vextent_small(
1456 	xfs_alloc_arg_t	*args,	/* allocation argument structure */
1457 	xfs_btree_cur_t	*ccur,	/* by-size cursor */
1458 	xfs_agblock_t	*fbnop,	/* result block number */
1459 	xfs_extlen_t	*flenp,	/* result length */
1460 	int		*stat)	/* status: 0-freelist, 1-normal/none */
1461 {
1462 	int		error;
1463 	xfs_agblock_t	fbno;
1464 	xfs_extlen_t	flen;
1465 	int		i;
1466 
1467 	if ((error = xfs_btree_decrement(ccur, 0, &i)))
1468 		goto error0;
1469 	if (i) {
1470 		if ((error = xfs_alloc_get_rec(ccur, &fbno, &flen, &i)))
1471 			goto error0;
1472 		XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
1473 	}
1474 	/*
1475 	 * Nothing in the btree, try the freelist.  Make sure
1476 	 * to respect minleft even when pulling from the
1477 	 * freelist.
1478 	 */
1479 	else if (args->minlen == 1 && args->alignment == 1 && !args->isfl &&
1480 		 (be32_to_cpu(XFS_BUF_TO_AGF(args->agbp)->agf_flcount)
1481 		  > args->minleft)) {
1482 		error = xfs_alloc_get_freelist(args->tp, args->agbp, &fbno, 0);
1483 		if (error)
1484 			goto error0;
1485 		if (fbno != NULLAGBLOCK) {
1486 			xfs_extent_busy_reuse(args->mp, args->agno, fbno, 1,
1487 					     args->userdata);
1488 
1489 			if (args->userdata) {
1490 				xfs_buf_t	*bp;
1491 
1492 				bp = xfs_btree_get_bufs(args->mp, args->tp,
1493 					args->agno, fbno, 0);
1494 				xfs_trans_binval(args->tp, bp);
1495 			}
1496 			args->len = 1;
1497 			args->agbno = fbno;
1498 			XFS_WANT_CORRUPTED_GOTO(
1499 				args->agbno + args->len <=
1500 				be32_to_cpu(XFS_BUF_TO_AGF(args->agbp)->agf_length),
1501 				error0);
1502 			args->wasfromfl = 1;
1503 			trace_xfs_alloc_small_freelist(args);
1504 			*stat = 0;
1505 			return 0;
1506 		}
1507 		/*
1508 		 * Nothing in the freelist.
1509 		 */
1510 		else
1511 			flen = 0;
1512 	}
1513 	/*
1514 	 * Can't allocate from the freelist for some reason.
1515 	 */
1516 	else {
1517 		fbno = NULLAGBLOCK;
1518 		flen = 0;
1519 	}
1520 	/*
1521 	 * Can't do the allocation, give up.
1522 	 */
1523 	if (flen < args->minlen) {
1524 		args->agbno = NULLAGBLOCK;
1525 		trace_xfs_alloc_small_notenough(args);
1526 		flen = 0;
1527 	}
1528 	*fbnop = fbno;
1529 	*flenp = flen;
1530 	*stat = 1;
1531 	trace_xfs_alloc_small_done(args);
1532 	return 0;
1533 
1534 error0:
1535 	trace_xfs_alloc_small_error(args);
1536 	return error;
1537 }
1538 
1539 /*
1540  * Free the extent starting at agno/bno for length.
1541  */
1542 STATIC int			/* error */
xfs_free_ag_extent(xfs_trans_t * tp,xfs_buf_t * agbp,xfs_agnumber_t agno,xfs_agblock_t bno,xfs_extlen_t len,int isfl)1543 xfs_free_ag_extent(
1544 	xfs_trans_t	*tp,	/* transaction pointer */
1545 	xfs_buf_t	*agbp,	/* buffer for a.g. freelist header */
1546 	xfs_agnumber_t	agno,	/* allocation group number */
1547 	xfs_agblock_t	bno,	/* starting block number */
1548 	xfs_extlen_t	len,	/* length of extent */
1549 	int		isfl)	/* set if is freelist blocks - no sb acctg */
1550 {
1551 	xfs_btree_cur_t	*bno_cur;	/* cursor for by-block btree */
1552 	xfs_btree_cur_t	*cnt_cur;	/* cursor for by-size btree */
1553 	int		error;		/* error return value */
1554 	xfs_agblock_t	gtbno;		/* start of right neighbor block */
1555 	xfs_extlen_t	gtlen;		/* length of right neighbor block */
1556 	int		haveleft;	/* have a left neighbor block */
1557 	int		haveright;	/* have a right neighbor block */
1558 	int		i;		/* temp, result code */
1559 	xfs_agblock_t	ltbno;		/* start of left neighbor block */
1560 	xfs_extlen_t	ltlen;		/* length of left neighbor block */
1561 	xfs_mount_t	*mp;		/* mount point struct for filesystem */
1562 	xfs_agblock_t	nbno;		/* new starting block of freespace */
1563 	xfs_extlen_t	nlen;		/* new length of freespace */
1564 	xfs_perag_t	*pag;		/* per allocation group data */
1565 
1566 	mp = tp->t_mountp;
1567 	/*
1568 	 * Allocate and initialize a cursor for the by-block btree.
1569 	 */
1570 	bno_cur = xfs_allocbt_init_cursor(mp, tp, agbp, agno, XFS_BTNUM_BNO);
1571 	cnt_cur = NULL;
1572 	/*
1573 	 * Look for a neighboring block on the left (lower block numbers)
1574 	 * that is contiguous with this space.
1575 	 */
1576 	if ((error = xfs_alloc_lookup_le(bno_cur, bno, len, &haveleft)))
1577 		goto error0;
1578 	if (haveleft) {
1579 		/*
1580 		 * There is a block to our left.
1581 		 */
1582 		if ((error = xfs_alloc_get_rec(bno_cur, &ltbno, &ltlen, &i)))
1583 			goto error0;
1584 		XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
1585 		/*
1586 		 * It's not contiguous, though.
1587 		 */
1588 		if (ltbno + ltlen < bno)
1589 			haveleft = 0;
1590 		else {
1591 			/*
1592 			 * If this failure happens the request to free this
1593 			 * space was invalid, it's (partly) already free.
1594 			 * Very bad.
1595 			 */
1596 			XFS_WANT_CORRUPTED_GOTO(ltbno + ltlen <= bno, error0);
1597 		}
1598 	}
1599 	/*
1600 	 * Look for a neighboring block on the right (higher block numbers)
1601 	 * that is contiguous with this space.
1602 	 */
1603 	if ((error = xfs_btree_increment(bno_cur, 0, &haveright)))
1604 		goto error0;
1605 	if (haveright) {
1606 		/*
1607 		 * There is a block to our right.
1608 		 */
1609 		if ((error = xfs_alloc_get_rec(bno_cur, &gtbno, &gtlen, &i)))
1610 			goto error0;
1611 		XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
1612 		/*
1613 		 * It's not contiguous, though.
1614 		 */
1615 		if (bno + len < gtbno)
1616 			haveright = 0;
1617 		else {
1618 			/*
1619 			 * If this failure happens the request to free this
1620 			 * space was invalid, it's (partly) already free.
1621 			 * Very bad.
1622 			 */
1623 			XFS_WANT_CORRUPTED_GOTO(gtbno >= bno + len, error0);
1624 		}
1625 	}
1626 	/*
1627 	 * Now allocate and initialize a cursor for the by-size tree.
1628 	 */
1629 	cnt_cur = xfs_allocbt_init_cursor(mp, tp, agbp, agno, XFS_BTNUM_CNT);
1630 	/*
1631 	 * Have both left and right contiguous neighbors.
1632 	 * Merge all three into a single free block.
1633 	 */
1634 	if (haveleft && haveright) {
1635 		/*
1636 		 * Delete the old by-size entry on the left.
1637 		 */
1638 		if ((error = xfs_alloc_lookup_eq(cnt_cur, ltbno, ltlen, &i)))
1639 			goto error0;
1640 		XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
1641 		if ((error = xfs_btree_delete(cnt_cur, &i)))
1642 			goto error0;
1643 		XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
1644 		/*
1645 		 * Delete the old by-size entry on the right.
1646 		 */
1647 		if ((error = xfs_alloc_lookup_eq(cnt_cur, gtbno, gtlen, &i)))
1648 			goto error0;
1649 		XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
1650 		if ((error = xfs_btree_delete(cnt_cur, &i)))
1651 			goto error0;
1652 		XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
1653 		/*
1654 		 * Delete the old by-block entry for the right block.
1655 		 */
1656 		if ((error = xfs_btree_delete(bno_cur, &i)))
1657 			goto error0;
1658 		XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
1659 		/*
1660 		 * Move the by-block cursor back to the left neighbor.
1661 		 */
1662 		if ((error = xfs_btree_decrement(bno_cur, 0, &i)))
1663 			goto error0;
1664 		XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
1665 #ifdef DEBUG
1666 		/*
1667 		 * Check that this is the right record: delete didn't
1668 		 * mangle the cursor.
1669 		 */
1670 		{
1671 			xfs_agblock_t	xxbno;
1672 			xfs_extlen_t	xxlen;
1673 
1674 			if ((error = xfs_alloc_get_rec(bno_cur, &xxbno, &xxlen,
1675 					&i)))
1676 				goto error0;
1677 			XFS_WANT_CORRUPTED_GOTO(
1678 				i == 1 && xxbno == ltbno && xxlen == ltlen,
1679 				error0);
1680 		}
1681 #endif
1682 		/*
1683 		 * Update remaining by-block entry to the new, joined block.
1684 		 */
1685 		nbno = ltbno;
1686 		nlen = len + ltlen + gtlen;
1687 		if ((error = xfs_alloc_update(bno_cur, nbno, nlen)))
1688 			goto error0;
1689 	}
1690 	/*
1691 	 * Have only a left contiguous neighbor.
1692 	 * Merge it together with the new freespace.
1693 	 */
1694 	else if (haveleft) {
1695 		/*
1696 		 * Delete the old by-size entry on the left.
1697 		 */
1698 		if ((error = xfs_alloc_lookup_eq(cnt_cur, ltbno, ltlen, &i)))
1699 			goto error0;
1700 		XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
1701 		if ((error = xfs_btree_delete(cnt_cur, &i)))
1702 			goto error0;
1703 		XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
1704 		/*
1705 		 * Back up the by-block cursor to the left neighbor, and
1706 		 * update its length.
1707 		 */
1708 		if ((error = xfs_btree_decrement(bno_cur, 0, &i)))
1709 			goto error0;
1710 		XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
1711 		nbno = ltbno;
1712 		nlen = len + ltlen;
1713 		if ((error = xfs_alloc_update(bno_cur, nbno, nlen)))
1714 			goto error0;
1715 	}
1716 	/*
1717 	 * Have only a right contiguous neighbor.
1718 	 * Merge it together with the new freespace.
1719 	 */
1720 	else if (haveright) {
1721 		/*
1722 		 * Delete the old by-size entry on the right.
1723 		 */
1724 		if ((error = xfs_alloc_lookup_eq(cnt_cur, gtbno, gtlen, &i)))
1725 			goto error0;
1726 		XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
1727 		if ((error = xfs_btree_delete(cnt_cur, &i)))
1728 			goto error0;
1729 		XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
1730 		/*
1731 		 * Update the starting block and length of the right
1732 		 * neighbor in the by-block tree.
1733 		 */
1734 		nbno = bno;
1735 		nlen = len + gtlen;
1736 		if ((error = xfs_alloc_update(bno_cur, nbno, nlen)))
1737 			goto error0;
1738 	}
1739 	/*
1740 	 * No contiguous neighbors.
1741 	 * Insert the new freespace into the by-block tree.
1742 	 */
1743 	else {
1744 		nbno = bno;
1745 		nlen = len;
1746 		if ((error = xfs_btree_insert(bno_cur, &i)))
1747 			goto error0;
1748 		XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
1749 	}
1750 	xfs_btree_del_cursor(bno_cur, XFS_BTREE_NOERROR);
1751 	bno_cur = NULL;
1752 	/*
1753 	 * In all cases we need to insert the new freespace in the by-size tree.
1754 	 */
1755 	if ((error = xfs_alloc_lookup_eq(cnt_cur, nbno, nlen, &i)))
1756 		goto error0;
1757 	XFS_WANT_CORRUPTED_GOTO(i == 0, error0);
1758 	if ((error = xfs_btree_insert(cnt_cur, &i)))
1759 		goto error0;
1760 	XFS_WANT_CORRUPTED_GOTO(i == 1, error0);
1761 	xfs_btree_del_cursor(cnt_cur, XFS_BTREE_NOERROR);
1762 	cnt_cur = NULL;
1763 
1764 	/*
1765 	 * Update the freespace totals in the ag and superblock.
1766 	 */
1767 	pag = xfs_perag_get(mp, agno);
1768 	error = xfs_alloc_update_counters(tp, pag, agbp, len);
1769 	xfs_perag_put(pag);
1770 	if (error)
1771 		goto error0;
1772 
1773 	if (!isfl)
1774 		xfs_trans_mod_sb(tp, XFS_TRANS_SB_FDBLOCKS, (long)len);
1775 	XFS_STATS_INC(xs_freex);
1776 	XFS_STATS_ADD(xs_freeb, len);
1777 
1778 	trace_xfs_free_extent(mp, agno, bno, len, isfl, haveleft, haveright);
1779 
1780 	return 0;
1781 
1782  error0:
1783 	trace_xfs_free_extent(mp, agno, bno, len, isfl, -1, -1);
1784 	if (bno_cur)
1785 		xfs_btree_del_cursor(bno_cur, XFS_BTREE_ERROR);
1786 	if (cnt_cur)
1787 		xfs_btree_del_cursor(cnt_cur, XFS_BTREE_ERROR);
1788 	return error;
1789 }
1790 
1791 /*
1792  * Visible (exported) allocation/free functions.
1793  * Some of these are used just by xfs_alloc_btree.c and this file.
1794  */
1795 
1796 /*
1797  * Compute and fill in value of m_ag_maxlevels.
1798  */
1799 void
xfs_alloc_compute_maxlevels(xfs_mount_t * mp)1800 xfs_alloc_compute_maxlevels(
1801 	xfs_mount_t	*mp)	/* file system mount structure */
1802 {
1803 	int		level;
1804 	uint		maxblocks;
1805 	uint		maxleafents;
1806 	int		minleafrecs;
1807 	int		minnoderecs;
1808 
1809 	maxleafents = (mp->m_sb.sb_agblocks + 1) / 2;
1810 	minleafrecs = mp->m_alloc_mnr[0];
1811 	minnoderecs = mp->m_alloc_mnr[1];
1812 	maxblocks = (maxleafents + minleafrecs - 1) / minleafrecs;
1813 	for (level = 1; maxblocks > 1; level++)
1814 		maxblocks = (maxblocks + minnoderecs - 1) / minnoderecs;
1815 	mp->m_ag_maxlevels = level;
1816 }
1817 
1818 /*
1819  * Find the length of the longest extent in an AG.
1820  */
1821 xfs_extlen_t
xfs_alloc_longest_free_extent(struct xfs_mount * mp,struct xfs_perag * pag)1822 xfs_alloc_longest_free_extent(
1823 	struct xfs_mount	*mp,
1824 	struct xfs_perag	*pag)
1825 {
1826 	xfs_extlen_t		need, delta = 0;
1827 
1828 	need = XFS_MIN_FREELIST_PAG(pag, mp);
1829 	if (need > pag->pagf_flcount)
1830 		delta = need - pag->pagf_flcount;
1831 
1832 	if (pag->pagf_longest > delta)
1833 		return pag->pagf_longest - delta;
1834 	return pag->pagf_flcount > 0 || pag->pagf_longest > 0;
1835 }
1836 
1837 /*
1838  * Decide whether to use this allocation group for this allocation.
1839  * If so, fix up the btree freelist's size.
1840  */
1841 STATIC int			/* error */
xfs_alloc_fix_freelist(xfs_alloc_arg_t * args,int flags)1842 xfs_alloc_fix_freelist(
1843 	xfs_alloc_arg_t	*args,	/* allocation argument structure */
1844 	int		flags)	/* XFS_ALLOC_FLAG_... */
1845 {
1846 	xfs_buf_t	*agbp;	/* agf buffer pointer */
1847 	xfs_agf_t	*agf;	/* a.g. freespace structure pointer */
1848 	xfs_buf_t	*agflbp;/* agfl buffer pointer */
1849 	xfs_agblock_t	bno;	/* freelist block */
1850 	xfs_extlen_t	delta;	/* new blocks needed in freelist */
1851 	int		error;	/* error result code */
1852 	xfs_extlen_t	longest;/* longest extent in allocation group */
1853 	xfs_mount_t	*mp;	/* file system mount point structure */
1854 	xfs_extlen_t	need;	/* total blocks needed in freelist */
1855 	xfs_perag_t	*pag;	/* per-ag information structure */
1856 	xfs_alloc_arg_t	targs;	/* local allocation arguments */
1857 	xfs_trans_t	*tp;	/* transaction pointer */
1858 
1859 	mp = args->mp;
1860 
1861 	pag = args->pag;
1862 	tp = args->tp;
1863 	if (!pag->pagf_init) {
1864 		if ((error = xfs_alloc_read_agf(mp, tp, args->agno, flags,
1865 				&agbp)))
1866 			return error;
1867 		if (!pag->pagf_init) {
1868 			ASSERT(flags & XFS_ALLOC_FLAG_TRYLOCK);
1869 			ASSERT(!(flags & XFS_ALLOC_FLAG_FREEING));
1870 			args->agbp = NULL;
1871 			return 0;
1872 		}
1873 	} else
1874 		agbp = NULL;
1875 
1876 	/*
1877 	 * If this is a metadata preferred pag and we are user data
1878 	 * then try somewhere else if we are not being asked to
1879 	 * try harder at this point
1880 	 */
1881 	if (pag->pagf_metadata && args->userdata &&
1882 	    (flags & XFS_ALLOC_FLAG_TRYLOCK)) {
1883 		ASSERT(!(flags & XFS_ALLOC_FLAG_FREEING));
1884 		args->agbp = NULL;
1885 		return 0;
1886 	}
1887 
1888 	if (!(flags & XFS_ALLOC_FLAG_FREEING)) {
1889 		/*
1890 		 * If it looks like there isn't a long enough extent, or enough
1891 		 * total blocks, reject it.
1892 		 */
1893 		need = XFS_MIN_FREELIST_PAG(pag, mp);
1894 		longest = xfs_alloc_longest_free_extent(mp, pag);
1895 		if ((args->minlen + args->alignment + args->minalignslop - 1) >
1896 				longest ||
1897 		    ((int)(pag->pagf_freeblks + pag->pagf_flcount -
1898 			   need - args->total) < (int)args->minleft)) {
1899 			if (agbp)
1900 				xfs_trans_brelse(tp, agbp);
1901 			args->agbp = NULL;
1902 			return 0;
1903 		}
1904 	}
1905 
1906 	/*
1907 	 * Get the a.g. freespace buffer.
1908 	 * Can fail if we're not blocking on locks, and it's held.
1909 	 */
1910 	if (agbp == NULL) {
1911 		if ((error = xfs_alloc_read_agf(mp, tp, args->agno, flags,
1912 				&agbp)))
1913 			return error;
1914 		if (agbp == NULL) {
1915 			ASSERT(flags & XFS_ALLOC_FLAG_TRYLOCK);
1916 			ASSERT(!(flags & XFS_ALLOC_FLAG_FREEING));
1917 			args->agbp = NULL;
1918 			return 0;
1919 		}
1920 	}
1921 	/*
1922 	 * Figure out how many blocks we should have in the freelist.
1923 	 */
1924 	agf = XFS_BUF_TO_AGF(agbp);
1925 	need = XFS_MIN_FREELIST(agf, mp);
1926 	/*
1927 	 * If there isn't enough total or single-extent, reject it.
1928 	 */
1929 	if (!(flags & XFS_ALLOC_FLAG_FREEING)) {
1930 		delta = need > be32_to_cpu(agf->agf_flcount) ?
1931 			(need - be32_to_cpu(agf->agf_flcount)) : 0;
1932 		longest = be32_to_cpu(agf->agf_longest);
1933 		longest = (longest > delta) ? (longest - delta) :
1934 			(be32_to_cpu(agf->agf_flcount) > 0 || longest > 0);
1935 		if ((args->minlen + args->alignment + args->minalignslop - 1) >
1936 				longest ||
1937 		    ((int)(be32_to_cpu(agf->agf_freeblks) +
1938 		     be32_to_cpu(agf->agf_flcount) - need - args->total) <
1939 				(int)args->minleft)) {
1940 			xfs_trans_brelse(tp, agbp);
1941 			args->agbp = NULL;
1942 			return 0;
1943 		}
1944 	}
1945 	/*
1946 	 * Make the freelist shorter if it's too long.
1947 	 */
1948 	while (be32_to_cpu(agf->agf_flcount) > need) {
1949 		xfs_buf_t	*bp;
1950 
1951 		error = xfs_alloc_get_freelist(tp, agbp, &bno, 0);
1952 		if (error)
1953 			return error;
1954 		if ((error = xfs_free_ag_extent(tp, agbp, args->agno, bno, 1, 1)))
1955 			return error;
1956 		bp = xfs_btree_get_bufs(mp, tp, args->agno, bno, 0);
1957 		xfs_trans_binval(tp, bp);
1958 	}
1959 	/*
1960 	 * Initialize the args structure.
1961 	 */
1962 	memset(&targs, 0, sizeof(targs));
1963 	targs.tp = tp;
1964 	targs.mp = mp;
1965 	targs.agbp = agbp;
1966 	targs.agno = args->agno;
1967 	targs.alignment = targs.minlen = targs.prod = targs.isfl = 1;
1968 	targs.type = XFS_ALLOCTYPE_THIS_AG;
1969 	targs.pag = pag;
1970 	if ((error = xfs_alloc_read_agfl(mp, tp, targs.agno, &agflbp)))
1971 		return error;
1972 	/*
1973 	 * Make the freelist longer if it's too short.
1974 	 */
1975 	while (be32_to_cpu(agf->agf_flcount) < need) {
1976 		targs.agbno = 0;
1977 		targs.maxlen = need - be32_to_cpu(agf->agf_flcount);
1978 		/*
1979 		 * Allocate as many blocks as possible at once.
1980 		 */
1981 		if ((error = xfs_alloc_ag_vextent(&targs))) {
1982 			xfs_trans_brelse(tp, agflbp);
1983 			return error;
1984 		}
1985 		/*
1986 		 * Stop if we run out.  Won't happen if callers are obeying
1987 		 * the restrictions correctly.  Can happen for free calls
1988 		 * on a completely full ag.
1989 		 */
1990 		if (targs.agbno == NULLAGBLOCK) {
1991 			if (flags & XFS_ALLOC_FLAG_FREEING)
1992 				break;
1993 			xfs_trans_brelse(tp, agflbp);
1994 			args->agbp = NULL;
1995 			return 0;
1996 		}
1997 		/*
1998 		 * Put each allocated block on the list.
1999 		 */
2000 		for (bno = targs.agbno; bno < targs.agbno + targs.len; bno++) {
2001 			error = xfs_alloc_put_freelist(tp, agbp,
2002 							agflbp, bno, 0);
2003 			if (error)
2004 				return error;
2005 		}
2006 	}
2007 	xfs_trans_brelse(tp, agflbp);
2008 	args->agbp = agbp;
2009 	return 0;
2010 }
2011 
2012 /*
2013  * Get a block from the freelist.
2014  * Returns with the buffer for the block gotten.
2015  */
2016 int				/* error */
xfs_alloc_get_freelist(xfs_trans_t * tp,xfs_buf_t * agbp,xfs_agblock_t * bnop,int btreeblk)2017 xfs_alloc_get_freelist(
2018 	xfs_trans_t	*tp,	/* transaction pointer */
2019 	xfs_buf_t	*agbp,	/* buffer containing the agf structure */
2020 	xfs_agblock_t	*bnop,	/* block address retrieved from freelist */
2021 	int		btreeblk) /* destination is a AGF btree */
2022 {
2023 	xfs_agf_t	*agf;	/* a.g. freespace structure */
2024 	xfs_buf_t	*agflbp;/* buffer for a.g. freelist structure */
2025 	xfs_agblock_t	bno;	/* block number returned */
2026 	__be32		*agfl_bno;
2027 	int		error;
2028 	int		logflags;
2029 	xfs_mount_t	*mp = tp->t_mountp;
2030 	xfs_perag_t	*pag;	/* per allocation group data */
2031 
2032 	/*
2033 	 * Freelist is empty, give up.
2034 	 */
2035 	agf = XFS_BUF_TO_AGF(agbp);
2036 	if (!agf->agf_flcount) {
2037 		*bnop = NULLAGBLOCK;
2038 		return 0;
2039 	}
2040 	/*
2041 	 * Read the array of free blocks.
2042 	 */
2043 	error = xfs_alloc_read_agfl(mp, tp, be32_to_cpu(agf->agf_seqno),
2044 				    &agflbp);
2045 	if (error)
2046 		return error;
2047 
2048 
2049 	/*
2050 	 * Get the block number and update the data structures.
2051 	 */
2052 	agfl_bno = XFS_BUF_TO_AGFL_BNO(mp, agflbp);
2053 	bno = be32_to_cpu(agfl_bno[be32_to_cpu(agf->agf_flfirst)]);
2054 	be32_add_cpu(&agf->agf_flfirst, 1);
2055 	xfs_trans_brelse(tp, agflbp);
2056 	if (be32_to_cpu(agf->agf_flfirst) == XFS_AGFL_SIZE(mp))
2057 		agf->agf_flfirst = 0;
2058 
2059 	pag = xfs_perag_get(mp, be32_to_cpu(agf->agf_seqno));
2060 	be32_add_cpu(&agf->agf_flcount, -1);
2061 	xfs_trans_agflist_delta(tp, -1);
2062 	pag->pagf_flcount--;
2063 	xfs_perag_put(pag);
2064 
2065 	logflags = XFS_AGF_FLFIRST | XFS_AGF_FLCOUNT;
2066 	if (btreeblk) {
2067 		be32_add_cpu(&agf->agf_btreeblks, 1);
2068 		pag->pagf_btreeblks++;
2069 		logflags |= XFS_AGF_BTREEBLKS;
2070 	}
2071 
2072 	xfs_alloc_log_agf(tp, agbp, logflags);
2073 	*bnop = bno;
2074 
2075 	return 0;
2076 }
2077 
2078 /*
2079  * Log the given fields from the agf structure.
2080  */
2081 void
xfs_alloc_log_agf(xfs_trans_t * tp,xfs_buf_t * bp,int fields)2082 xfs_alloc_log_agf(
2083 	xfs_trans_t	*tp,	/* transaction pointer */
2084 	xfs_buf_t	*bp,	/* buffer for a.g. freelist header */
2085 	int		fields)	/* mask of fields to be logged (XFS_AGF_...) */
2086 {
2087 	int	first;		/* first byte offset */
2088 	int	last;		/* last byte offset */
2089 	static const short	offsets[] = {
2090 		offsetof(xfs_agf_t, agf_magicnum),
2091 		offsetof(xfs_agf_t, agf_versionnum),
2092 		offsetof(xfs_agf_t, agf_seqno),
2093 		offsetof(xfs_agf_t, agf_length),
2094 		offsetof(xfs_agf_t, agf_roots[0]),
2095 		offsetof(xfs_agf_t, agf_levels[0]),
2096 		offsetof(xfs_agf_t, agf_flfirst),
2097 		offsetof(xfs_agf_t, agf_fllast),
2098 		offsetof(xfs_agf_t, agf_flcount),
2099 		offsetof(xfs_agf_t, agf_freeblks),
2100 		offsetof(xfs_agf_t, agf_longest),
2101 		offsetof(xfs_agf_t, agf_btreeblks),
2102 		offsetof(xfs_agf_t, agf_uuid),
2103 		sizeof(xfs_agf_t)
2104 	};
2105 
2106 	trace_xfs_agf(tp->t_mountp, XFS_BUF_TO_AGF(bp), fields, _RET_IP_);
2107 
2108 	xfs_trans_buf_set_type(tp, bp, XFS_BLFT_AGF_BUF);
2109 
2110 	xfs_btree_offsets(fields, offsets, XFS_AGF_NUM_BITS, &first, &last);
2111 	xfs_trans_log_buf(tp, bp, (uint)first, (uint)last);
2112 }
2113 
2114 /*
2115  * Interface for inode allocation to force the pag data to be initialized.
2116  */
2117 int					/* error */
xfs_alloc_pagf_init(xfs_mount_t * mp,xfs_trans_t * tp,xfs_agnumber_t agno,int flags)2118 xfs_alloc_pagf_init(
2119 	xfs_mount_t		*mp,	/* file system mount structure */
2120 	xfs_trans_t		*tp,	/* transaction pointer */
2121 	xfs_agnumber_t		agno,	/* allocation group number */
2122 	int			flags)	/* XFS_ALLOC_FLAGS_... */
2123 {
2124 	xfs_buf_t		*bp;
2125 	int			error;
2126 
2127 	if ((error = xfs_alloc_read_agf(mp, tp, agno, flags, &bp)))
2128 		return error;
2129 	if (bp)
2130 		xfs_trans_brelse(tp, bp);
2131 	return 0;
2132 }
2133 
2134 /*
2135  * Put the block on the freelist for the allocation group.
2136  */
2137 int					/* error */
xfs_alloc_put_freelist(xfs_trans_t * tp,xfs_buf_t * agbp,xfs_buf_t * agflbp,xfs_agblock_t bno,int btreeblk)2138 xfs_alloc_put_freelist(
2139 	xfs_trans_t		*tp,	/* transaction pointer */
2140 	xfs_buf_t		*agbp,	/* buffer for a.g. freelist header */
2141 	xfs_buf_t		*agflbp,/* buffer for a.g. free block array */
2142 	xfs_agblock_t		bno,	/* block being freed */
2143 	int			btreeblk) /* block came from a AGF btree */
2144 {
2145 	xfs_agf_t		*agf;	/* a.g. freespace structure */
2146 	__be32			*blockp;/* pointer to array entry */
2147 	int			error;
2148 	int			logflags;
2149 	xfs_mount_t		*mp;	/* mount structure */
2150 	xfs_perag_t		*pag;	/* per allocation group data */
2151 	__be32			*agfl_bno;
2152 	int			startoff;
2153 
2154 	agf = XFS_BUF_TO_AGF(agbp);
2155 	mp = tp->t_mountp;
2156 
2157 	if (!agflbp && (error = xfs_alloc_read_agfl(mp, tp,
2158 			be32_to_cpu(agf->agf_seqno), &agflbp)))
2159 		return error;
2160 	be32_add_cpu(&agf->agf_fllast, 1);
2161 	if (be32_to_cpu(agf->agf_fllast) == XFS_AGFL_SIZE(mp))
2162 		agf->agf_fllast = 0;
2163 
2164 	pag = xfs_perag_get(mp, be32_to_cpu(agf->agf_seqno));
2165 	be32_add_cpu(&agf->agf_flcount, 1);
2166 	xfs_trans_agflist_delta(tp, 1);
2167 	pag->pagf_flcount++;
2168 
2169 	logflags = XFS_AGF_FLLAST | XFS_AGF_FLCOUNT;
2170 	if (btreeblk) {
2171 		be32_add_cpu(&agf->agf_btreeblks, -1);
2172 		pag->pagf_btreeblks--;
2173 		logflags |= XFS_AGF_BTREEBLKS;
2174 	}
2175 	xfs_perag_put(pag);
2176 
2177 	xfs_alloc_log_agf(tp, agbp, logflags);
2178 
2179 	ASSERT(be32_to_cpu(agf->agf_flcount) <= XFS_AGFL_SIZE(mp));
2180 
2181 	agfl_bno = XFS_BUF_TO_AGFL_BNO(mp, agflbp);
2182 	blockp = &agfl_bno[be32_to_cpu(agf->agf_fllast)];
2183 	*blockp = cpu_to_be32(bno);
2184 	startoff = (char *)blockp - (char *)agflbp->b_addr;
2185 
2186 	xfs_alloc_log_agf(tp, agbp, logflags);
2187 
2188 	xfs_trans_buf_set_type(tp, agflbp, XFS_BLFT_AGFL_BUF);
2189 	xfs_trans_log_buf(tp, agflbp, startoff,
2190 			  startoff + sizeof(xfs_agblock_t) - 1);
2191 	return 0;
2192 }
2193 
2194 static bool
xfs_agf_verify(struct xfs_mount * mp,struct xfs_buf * bp)2195 xfs_agf_verify(
2196 	struct xfs_mount *mp,
2197 	struct xfs_buf	*bp)
2198  {
2199 	struct xfs_agf	*agf = XFS_BUF_TO_AGF(bp);
2200 
2201 	if (xfs_sb_version_hascrc(&mp->m_sb) &&
2202 	    !uuid_equal(&agf->agf_uuid, &mp->m_sb.sb_uuid))
2203 			return false;
2204 
2205 	if (!(agf->agf_magicnum == cpu_to_be32(XFS_AGF_MAGIC) &&
2206 	      XFS_AGF_GOOD_VERSION(be32_to_cpu(agf->agf_versionnum)) &&
2207 	      be32_to_cpu(agf->agf_freeblks) <= be32_to_cpu(agf->agf_length) &&
2208 	      be32_to_cpu(agf->agf_flfirst) < XFS_AGFL_SIZE(mp) &&
2209 	      be32_to_cpu(agf->agf_fllast) < XFS_AGFL_SIZE(mp) &&
2210 	      be32_to_cpu(agf->agf_flcount) <= XFS_AGFL_SIZE(mp)))
2211 		return false;
2212 
2213 	if (be32_to_cpu(agf->agf_levels[XFS_BTNUM_BNO]) > XFS_BTREE_MAXLEVELS ||
2214 	    be32_to_cpu(agf->agf_levels[XFS_BTNUM_CNT]) > XFS_BTREE_MAXLEVELS)
2215 		return false;
2216 
2217 	/*
2218 	 * during growfs operations, the perag is not fully initialised,
2219 	 * so we can't use it for any useful checking. growfs ensures we can't
2220 	 * use it by using uncached buffers that don't have the perag attached
2221 	 * so we can detect and avoid this problem.
2222 	 */
2223 	if (bp->b_pag && be32_to_cpu(agf->agf_seqno) != bp->b_pag->pag_agno)
2224 		return false;
2225 
2226 	if (xfs_sb_version_haslazysbcount(&mp->m_sb) &&
2227 	    be32_to_cpu(agf->agf_btreeblks) > be32_to_cpu(agf->agf_length))
2228 		return false;
2229 
2230 	return true;;
2231 
2232 }
2233 
2234 static void
xfs_agf_read_verify(struct xfs_buf * bp)2235 xfs_agf_read_verify(
2236 	struct xfs_buf	*bp)
2237 {
2238 	struct xfs_mount *mp = bp->b_target->bt_mount;
2239 
2240 	if (xfs_sb_version_hascrc(&mp->m_sb) &&
2241 	    !xfs_buf_verify_cksum(bp, XFS_AGF_CRC_OFF))
2242 		xfs_buf_ioerror(bp, -EFSBADCRC);
2243 	else if (XFS_TEST_ERROR(!xfs_agf_verify(mp, bp), mp,
2244 				XFS_ERRTAG_ALLOC_READ_AGF,
2245 				XFS_RANDOM_ALLOC_READ_AGF))
2246 		xfs_buf_ioerror(bp, -EFSCORRUPTED);
2247 
2248 	if (bp->b_error)
2249 		xfs_verifier_error(bp);
2250 }
2251 
2252 static void
xfs_agf_write_verify(struct xfs_buf * bp)2253 xfs_agf_write_verify(
2254 	struct xfs_buf	*bp)
2255 {
2256 	struct xfs_mount *mp = bp->b_target->bt_mount;
2257 	struct xfs_buf_log_item	*bip = bp->b_fspriv;
2258 
2259 	if (!xfs_agf_verify(mp, bp)) {
2260 		xfs_buf_ioerror(bp, -EFSCORRUPTED);
2261 		xfs_verifier_error(bp);
2262 		return;
2263 	}
2264 
2265 	if (!xfs_sb_version_hascrc(&mp->m_sb))
2266 		return;
2267 
2268 	if (bip)
2269 		XFS_BUF_TO_AGF(bp)->agf_lsn = cpu_to_be64(bip->bli_item.li_lsn);
2270 
2271 	xfs_buf_update_cksum(bp, XFS_AGF_CRC_OFF);
2272 }
2273 
2274 const struct xfs_buf_ops xfs_agf_buf_ops = {
2275 	.name = "xfs_agf",
2276 	.verify_read = xfs_agf_read_verify,
2277 	.verify_write = xfs_agf_write_verify,
2278 };
2279 
2280 /*
2281  * Read in the allocation group header (free/alloc section).
2282  */
2283 int					/* error */
xfs_read_agf(struct xfs_mount * mp,struct xfs_trans * tp,xfs_agnumber_t agno,int flags,struct xfs_buf ** bpp)2284 xfs_read_agf(
2285 	struct xfs_mount	*mp,	/* mount point structure */
2286 	struct xfs_trans	*tp,	/* transaction pointer */
2287 	xfs_agnumber_t		agno,	/* allocation group number */
2288 	int			flags,	/* XFS_BUF_ */
2289 	struct xfs_buf		**bpp)	/* buffer for the ag freelist header */
2290 {
2291 	int		error;
2292 
2293 	trace_xfs_read_agf(mp, agno);
2294 
2295 	ASSERT(agno != NULLAGNUMBER);
2296 	error = xfs_trans_read_buf(
2297 			mp, tp, mp->m_ddev_targp,
2298 			XFS_AG_DADDR(mp, agno, XFS_AGF_DADDR(mp)),
2299 			XFS_FSS_TO_BB(mp, 1), flags, bpp, &xfs_agf_buf_ops);
2300 	if (error)
2301 		return error;
2302 	if (!*bpp)
2303 		return 0;
2304 
2305 	ASSERT(!(*bpp)->b_error);
2306 	xfs_buf_set_ref(*bpp, XFS_AGF_REF);
2307 	return 0;
2308 }
2309 
2310 /*
2311  * Read in the allocation group header (free/alloc section).
2312  */
2313 int					/* error */
xfs_alloc_read_agf(struct xfs_mount * mp,struct xfs_trans * tp,xfs_agnumber_t agno,int flags,struct xfs_buf ** bpp)2314 xfs_alloc_read_agf(
2315 	struct xfs_mount	*mp,	/* mount point structure */
2316 	struct xfs_trans	*tp,	/* transaction pointer */
2317 	xfs_agnumber_t		agno,	/* allocation group number */
2318 	int			flags,	/* XFS_ALLOC_FLAG_... */
2319 	struct xfs_buf		**bpp)	/* buffer for the ag freelist header */
2320 {
2321 	struct xfs_agf		*agf;		/* ag freelist header */
2322 	struct xfs_perag	*pag;		/* per allocation group data */
2323 	int			error;
2324 
2325 	trace_xfs_alloc_read_agf(mp, agno);
2326 
2327 	ASSERT(agno != NULLAGNUMBER);
2328 	error = xfs_read_agf(mp, tp, agno,
2329 			(flags & XFS_ALLOC_FLAG_TRYLOCK) ? XBF_TRYLOCK : 0,
2330 			bpp);
2331 	if (error)
2332 		return error;
2333 	if (!*bpp)
2334 		return 0;
2335 	ASSERT(!(*bpp)->b_error);
2336 
2337 	agf = XFS_BUF_TO_AGF(*bpp);
2338 	pag = xfs_perag_get(mp, agno);
2339 	if (!pag->pagf_init) {
2340 		pag->pagf_freeblks = be32_to_cpu(agf->agf_freeblks);
2341 		pag->pagf_btreeblks = be32_to_cpu(agf->agf_btreeblks);
2342 		pag->pagf_flcount = be32_to_cpu(agf->agf_flcount);
2343 		pag->pagf_longest = be32_to_cpu(agf->agf_longest);
2344 		pag->pagf_levels[XFS_BTNUM_BNOi] =
2345 			be32_to_cpu(agf->agf_levels[XFS_BTNUM_BNOi]);
2346 		pag->pagf_levels[XFS_BTNUM_CNTi] =
2347 			be32_to_cpu(agf->agf_levels[XFS_BTNUM_CNTi]);
2348 		spin_lock_init(&pag->pagb_lock);
2349 		pag->pagb_count = 0;
2350 		pag->pagb_tree = RB_ROOT;
2351 		pag->pagf_init = 1;
2352 	}
2353 #ifdef DEBUG
2354 	else if (!XFS_FORCED_SHUTDOWN(mp)) {
2355 		ASSERT(pag->pagf_freeblks == be32_to_cpu(agf->agf_freeblks));
2356 		ASSERT(pag->pagf_btreeblks == be32_to_cpu(agf->agf_btreeblks));
2357 		ASSERT(pag->pagf_flcount == be32_to_cpu(agf->agf_flcount));
2358 		ASSERT(pag->pagf_longest == be32_to_cpu(agf->agf_longest));
2359 		ASSERT(pag->pagf_levels[XFS_BTNUM_BNOi] ==
2360 		       be32_to_cpu(agf->agf_levels[XFS_BTNUM_BNOi]));
2361 		ASSERT(pag->pagf_levels[XFS_BTNUM_CNTi] ==
2362 		       be32_to_cpu(agf->agf_levels[XFS_BTNUM_CNTi]));
2363 	}
2364 #endif
2365 	xfs_perag_put(pag);
2366 	return 0;
2367 }
2368 
2369 /*
2370  * Allocate an extent (variable-size).
2371  * Depending on the allocation type, we either look in a single allocation
2372  * group or loop over the allocation groups to find the result.
2373  */
2374 int				/* error */
xfs_alloc_vextent(xfs_alloc_arg_t * args)2375 xfs_alloc_vextent(
2376 	xfs_alloc_arg_t	*args)	/* allocation argument structure */
2377 {
2378 	xfs_agblock_t	agsize;	/* allocation group size */
2379 	int		error;
2380 	int		flags;	/* XFS_ALLOC_FLAG_... locking flags */
2381 	xfs_extlen_t	minleft;/* minimum left value, temp copy */
2382 	xfs_mount_t	*mp;	/* mount structure pointer */
2383 	xfs_agnumber_t	sagno;	/* starting allocation group number */
2384 	xfs_alloctype_t	type;	/* input allocation type */
2385 	int		bump_rotor = 0;
2386 	int		no_min = 0;
2387 	xfs_agnumber_t	rotorstep = xfs_rotorstep; /* inode32 agf stepper */
2388 
2389 	mp = args->mp;
2390 	type = args->otype = args->type;
2391 	args->agbno = NULLAGBLOCK;
2392 	/*
2393 	 * Just fix this up, for the case where the last a.g. is shorter
2394 	 * (or there's only one a.g.) and the caller couldn't easily figure
2395 	 * that out (xfs_bmap_alloc).
2396 	 */
2397 	agsize = mp->m_sb.sb_agblocks;
2398 	if (args->maxlen > agsize)
2399 		args->maxlen = agsize;
2400 	if (args->alignment == 0)
2401 		args->alignment = 1;
2402 	ASSERT(XFS_FSB_TO_AGNO(mp, args->fsbno) < mp->m_sb.sb_agcount);
2403 	ASSERT(XFS_FSB_TO_AGBNO(mp, args->fsbno) < agsize);
2404 	ASSERT(args->minlen <= args->maxlen);
2405 	ASSERT(args->minlen <= agsize);
2406 	ASSERT(args->mod < args->prod);
2407 	if (XFS_FSB_TO_AGNO(mp, args->fsbno) >= mp->m_sb.sb_agcount ||
2408 	    XFS_FSB_TO_AGBNO(mp, args->fsbno) >= agsize ||
2409 	    args->minlen > args->maxlen || args->minlen > agsize ||
2410 	    args->mod >= args->prod) {
2411 		args->fsbno = NULLFSBLOCK;
2412 		trace_xfs_alloc_vextent_badargs(args);
2413 		return 0;
2414 	}
2415 	minleft = args->minleft;
2416 
2417 	switch (type) {
2418 	case XFS_ALLOCTYPE_THIS_AG:
2419 	case XFS_ALLOCTYPE_NEAR_BNO:
2420 	case XFS_ALLOCTYPE_THIS_BNO:
2421 		/*
2422 		 * These three force us into a single a.g.
2423 		 */
2424 		args->agno = XFS_FSB_TO_AGNO(mp, args->fsbno);
2425 		args->pag = xfs_perag_get(mp, args->agno);
2426 		args->minleft = 0;
2427 		error = xfs_alloc_fix_freelist(args, 0);
2428 		args->minleft = minleft;
2429 		if (error) {
2430 			trace_xfs_alloc_vextent_nofix(args);
2431 			goto error0;
2432 		}
2433 		if (!args->agbp) {
2434 			trace_xfs_alloc_vextent_noagbp(args);
2435 			break;
2436 		}
2437 		args->agbno = XFS_FSB_TO_AGBNO(mp, args->fsbno);
2438 		if ((error = xfs_alloc_ag_vextent(args)))
2439 			goto error0;
2440 		break;
2441 	case XFS_ALLOCTYPE_START_BNO:
2442 		/*
2443 		 * Try near allocation first, then anywhere-in-ag after
2444 		 * the first a.g. fails.
2445 		 */
2446 		if ((args->userdata  == XFS_ALLOC_INITIAL_USER_DATA) &&
2447 		    (mp->m_flags & XFS_MOUNT_32BITINODES)) {
2448 			args->fsbno = XFS_AGB_TO_FSB(mp,
2449 					((mp->m_agfrotor / rotorstep) %
2450 					mp->m_sb.sb_agcount), 0);
2451 			bump_rotor = 1;
2452 		}
2453 		args->agbno = XFS_FSB_TO_AGBNO(mp, args->fsbno);
2454 		args->type = XFS_ALLOCTYPE_NEAR_BNO;
2455 		/* FALLTHROUGH */
2456 	case XFS_ALLOCTYPE_ANY_AG:
2457 	case XFS_ALLOCTYPE_START_AG:
2458 	case XFS_ALLOCTYPE_FIRST_AG:
2459 		/*
2460 		 * Rotate through the allocation groups looking for a winner.
2461 		 */
2462 		if (type == XFS_ALLOCTYPE_ANY_AG) {
2463 			/*
2464 			 * Start with the last place we left off.
2465 			 */
2466 			args->agno = sagno = (mp->m_agfrotor / rotorstep) %
2467 					mp->m_sb.sb_agcount;
2468 			args->type = XFS_ALLOCTYPE_THIS_AG;
2469 			flags = XFS_ALLOC_FLAG_TRYLOCK;
2470 		} else if (type == XFS_ALLOCTYPE_FIRST_AG) {
2471 			/*
2472 			 * Start with allocation group given by bno.
2473 			 */
2474 			args->agno = XFS_FSB_TO_AGNO(mp, args->fsbno);
2475 			args->type = XFS_ALLOCTYPE_THIS_AG;
2476 			sagno = 0;
2477 			flags = 0;
2478 		} else {
2479 			if (type == XFS_ALLOCTYPE_START_AG)
2480 				args->type = XFS_ALLOCTYPE_THIS_AG;
2481 			/*
2482 			 * Start with the given allocation group.
2483 			 */
2484 			args->agno = sagno = XFS_FSB_TO_AGNO(mp, args->fsbno);
2485 			flags = XFS_ALLOC_FLAG_TRYLOCK;
2486 		}
2487 		/*
2488 		 * Loop over allocation groups twice; first time with
2489 		 * trylock set, second time without.
2490 		 */
2491 		for (;;) {
2492 			args->pag = xfs_perag_get(mp, args->agno);
2493 			if (no_min) args->minleft = 0;
2494 			error = xfs_alloc_fix_freelist(args, flags);
2495 			args->minleft = minleft;
2496 			if (error) {
2497 				trace_xfs_alloc_vextent_nofix(args);
2498 				goto error0;
2499 			}
2500 			/*
2501 			 * If we get a buffer back then the allocation will fly.
2502 			 */
2503 			if (args->agbp) {
2504 				if ((error = xfs_alloc_ag_vextent(args)))
2505 					goto error0;
2506 				break;
2507 			}
2508 
2509 			trace_xfs_alloc_vextent_loopfailed(args);
2510 
2511 			/*
2512 			 * Didn't work, figure out the next iteration.
2513 			 */
2514 			if (args->agno == sagno &&
2515 			    type == XFS_ALLOCTYPE_START_BNO)
2516 				args->type = XFS_ALLOCTYPE_THIS_AG;
2517 			/*
2518 			* For the first allocation, we can try any AG to get
2519 			* space.  However, if we already have allocated a
2520 			* block, we don't want to try AGs whose number is below
2521 			* sagno. Otherwise, we may end up with out-of-order
2522 			* locking of AGF, which might cause deadlock.
2523 			*/
2524 			if (++(args->agno) == mp->m_sb.sb_agcount) {
2525 				if (args->firstblock != NULLFSBLOCK)
2526 					args->agno = sagno;
2527 				else
2528 					args->agno = 0;
2529 			}
2530 			/*
2531 			 * Reached the starting a.g., must either be done
2532 			 * or switch to non-trylock mode.
2533 			 */
2534 			if (args->agno == sagno) {
2535 				if (no_min == 1) {
2536 					args->agbno = NULLAGBLOCK;
2537 					trace_xfs_alloc_vextent_allfailed(args);
2538 					break;
2539 				}
2540 				if (flags == 0) {
2541 					no_min = 1;
2542 				} else {
2543 					flags = 0;
2544 					if (type == XFS_ALLOCTYPE_START_BNO) {
2545 						args->agbno = XFS_FSB_TO_AGBNO(mp,
2546 							args->fsbno);
2547 						args->type = XFS_ALLOCTYPE_NEAR_BNO;
2548 					}
2549 				}
2550 			}
2551 			xfs_perag_put(args->pag);
2552 		}
2553 		if (bump_rotor || (type == XFS_ALLOCTYPE_ANY_AG)) {
2554 			if (args->agno == sagno)
2555 				mp->m_agfrotor = (mp->m_agfrotor + 1) %
2556 					(mp->m_sb.sb_agcount * rotorstep);
2557 			else
2558 				mp->m_agfrotor = (args->agno * rotorstep + 1) %
2559 					(mp->m_sb.sb_agcount * rotorstep);
2560 		}
2561 		break;
2562 	default:
2563 		ASSERT(0);
2564 		/* NOTREACHED */
2565 	}
2566 	if (args->agbno == NULLAGBLOCK)
2567 		args->fsbno = NULLFSBLOCK;
2568 	else {
2569 		args->fsbno = XFS_AGB_TO_FSB(mp, args->agno, args->agbno);
2570 #ifdef DEBUG
2571 		ASSERT(args->len >= args->minlen);
2572 		ASSERT(args->len <= args->maxlen);
2573 		ASSERT(args->agbno % args->alignment == 0);
2574 		XFS_AG_CHECK_DADDR(mp, XFS_FSB_TO_DADDR(mp, args->fsbno),
2575 			args->len);
2576 #endif
2577 	}
2578 	xfs_perag_put(args->pag);
2579 	return 0;
2580 error0:
2581 	xfs_perag_put(args->pag);
2582 	return error;
2583 }
2584 
2585 /*
2586  * Free an extent.
2587  * Just break up the extent address and hand off to xfs_free_ag_extent
2588  * after fixing up the freelist.
2589  */
2590 int				/* error */
xfs_free_extent(xfs_trans_t * tp,xfs_fsblock_t bno,xfs_extlen_t len)2591 xfs_free_extent(
2592 	xfs_trans_t	*tp,	/* transaction pointer */
2593 	xfs_fsblock_t	bno,	/* starting block number of extent */
2594 	xfs_extlen_t	len)	/* length of extent */
2595 {
2596 	xfs_alloc_arg_t	args;
2597 	int		error;
2598 
2599 	ASSERT(len != 0);
2600 	memset(&args, 0, sizeof(xfs_alloc_arg_t));
2601 	args.tp = tp;
2602 	args.mp = tp->t_mountp;
2603 
2604 	/*
2605 	 * validate that the block number is legal - the enables us to detect
2606 	 * and handle a silent filesystem corruption rather than crashing.
2607 	 */
2608 	args.agno = XFS_FSB_TO_AGNO(args.mp, bno);
2609 	if (args.agno >= args.mp->m_sb.sb_agcount)
2610 		return -EFSCORRUPTED;
2611 
2612 	args.agbno = XFS_FSB_TO_AGBNO(args.mp, bno);
2613 	if (args.agbno >= args.mp->m_sb.sb_agblocks)
2614 		return -EFSCORRUPTED;
2615 
2616 	args.pag = xfs_perag_get(args.mp, args.agno);
2617 	ASSERT(args.pag);
2618 
2619 	error = xfs_alloc_fix_freelist(&args, XFS_ALLOC_FLAG_FREEING);
2620 	if (error)
2621 		goto error0;
2622 
2623 	/* validate the extent size is legal now we have the agf locked */
2624 	if (args.agbno + len >
2625 			be32_to_cpu(XFS_BUF_TO_AGF(args.agbp)->agf_length)) {
2626 		error = -EFSCORRUPTED;
2627 		goto error0;
2628 	}
2629 
2630 	error = xfs_free_ag_extent(tp, args.agbp, args.agno, args.agbno, len, 0);
2631 	if (!error)
2632 		xfs_extent_busy_insert(tp, args.agno, args.agbno, len, 0);
2633 error0:
2634 	xfs_perag_put(args.pag);
2635 	return error;
2636 }
2637