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