Commit 78d7aabd authored by Brian Foster's avatar Brian Foster Committed by Darrick J. Wong

xfs: refactor and reuse best extent scanning logic

The bnobt "find best" helper implements a simple btree walker
function. This general pattern, or a subset thereof, is reused in
various parts of a near mode allocation operation. For example, the
bnobt left/right scans are each iterative btree walks along with the
cntbt lastblock scan.

Rework this function into a generic btree walker, add a couple
parameters to control termination behavior from various contexts and
reuse it where applicable.
Signed-off-by: default avatarBrian Foster <bfoster@redhat.com>
Reviewed-by: default avatarDarrick J. Wong <darrick.wong@oracle.com>
Signed-off-by: default avatarDarrick J. Wong <darrick.wong@oracle.com>
parent 4a65b7c2
...@@ -875,6 +875,13 @@ xfs_alloc_cur_check( ...@@ -875,6 +875,13 @@ xfs_alloc_cur_check(
acur->diff = diff; acur->diff = diff;
*new = 1; *new = 1;
/*
* We're done if we found a perfect allocation. This only deactivates
* the current cursor, but this is just an optimization to terminate a
* cntbt search that otherwise runs to the edge of the tree.
*/
if (acur->diff == 0 && acur->len == args->maxlen)
deactivate = true;
out: out:
if (deactivate) if (deactivate)
cur->bc_private.a.priv.abt.active = false; cur->bc_private.a.priv.abt.active = false;
...@@ -1172,30 +1179,38 @@ xfs_alloc_ag_vextent_exact( ...@@ -1172,30 +1179,38 @@ xfs_alloc_ag_vextent_exact(
} }
/* /*
* Search the btree in a given direction and check the records against the good * Search a given number of btree records in a given direction. Check each
* extent we've already found. * record against the good extent we've already found.
*/ */
STATIC int STATIC int
xfs_alloc_find_best_extent( xfs_alloc_walk_iter(
struct xfs_alloc_arg *args, struct xfs_alloc_arg *args,
struct xfs_alloc_cur *acur, struct xfs_alloc_cur *acur,
struct xfs_btree_cur *cur, struct xfs_btree_cur *cur,
bool increment) bool increment,
bool find_one, /* quit on first candidate */
int count, /* rec count (-1 for infinite) */
int *stat)
{ {
int error; int error;
int i; int i;
*stat = 0;
/* /*
* Search so long as the cursor is active or we find a better extent. * Search so long as the cursor is active or we find a better extent.
* The cursor is deactivated if it extends beyond the range of the * The cursor is deactivated if it extends beyond the range of the
* current allocation candidate. * current allocation candidate.
*/ */
while (xfs_alloc_cur_active(cur)) { while (xfs_alloc_cur_active(cur) && count) {
error = xfs_alloc_cur_check(args, acur, cur, &i); error = xfs_alloc_cur_check(args, acur, cur, &i);
if (error) if (error)
return error; return error;
if (i == 1) if (i == 1) {
break; *stat = 1;
if (find_one)
break;
}
if (!xfs_alloc_cur_active(cur)) if (!xfs_alloc_cur_active(cur))
break; break;
...@@ -1207,6 +1222,9 @@ xfs_alloc_find_best_extent( ...@@ -1207,6 +1222,9 @@ xfs_alloc_find_best_extent(
return error; return error;
if (i == 0) if (i == 0)
cur->bc_private.a.priv.abt.active = false; cur->bc_private.a.priv.abt.active = false;
if (count > 0)
count--;
} }
return 0; return 0;
...@@ -1226,7 +1244,6 @@ xfs_alloc_ag_vextent_near( ...@@ -1226,7 +1244,6 @@ xfs_alloc_ag_vextent_near(
struct xfs_btree_cur *fbcur = NULL; struct xfs_btree_cur *fbcur = NULL;
int error; /* error code */ int error; /* error code */
int i; /* result code, temporary */ int i; /* result code, temporary */
int j; /* result code, temporary */
xfs_agblock_t bno; xfs_agblock_t bno;
xfs_extlen_t len; xfs_extlen_t len;
bool fbinc = false; bool fbinc = false;
...@@ -1313,19 +1330,12 @@ xfs_alloc_ag_vextent_near( ...@@ -1313,19 +1330,12 @@ xfs_alloc_ag_vextent_near(
if (!i) if (!i)
break; break;
} }
i = acur.cnt->bc_ptrs[0];
for (j = 1; error = xfs_alloc_walk_iter(args, &acur, acur.cnt, true, false,
!error && j && xfs_alloc_cur_active(acur.cnt) && -1, &i);
(acur.len < args->maxlen || acur.diff > 0); if (error)
error = xfs_btree_increment(acur.cnt, 0, &j)) { goto out;
/*
* For each entry, decide if it's better than
* the previous best entry.
*/
error = xfs_alloc_cur_check(args, &acur, acur.cnt, &i);
if (error)
goto out;
}
/* /*
* It didn't work. We COULD be in a case where * It didn't work. We COULD be in a case where
* there's a good record somewhere, so try again. * there's a good record somewhere, so try again.
...@@ -1357,49 +1367,39 @@ xfs_alloc_ag_vextent_near( ...@@ -1357,49 +1367,39 @@ xfs_alloc_ag_vextent_near(
goto out; goto out;
/* /*
* Loop going left with the leftward cursor, right with the * Loop going left with the leftward cursor, right with the rightward
* rightward cursor, until either both directions give up or * cursor, until either both directions give up or we find an entry at
* we find an entry at least as big as minlen. * least as big as minlen.
*/ */
do { do {
if (xfs_alloc_cur_active(acur.bnolt)) { error = xfs_alloc_walk_iter(args, &acur, acur.bnolt, false,
error = xfs_alloc_cur_check(args, &acur, acur.bnolt, &i); true, 1, &i);
if (error) if (error)
goto out; goto out;
if (i == 1) { if (i == 1) {
trace_xfs_alloc_cur_left(args); trace_xfs_alloc_cur_left(args);
fbcur = acur.bnogt; fbcur = acur.bnogt;
fbinc = true; fbinc = true;
break; break;
}
error = xfs_btree_decrement(acur.bnolt, 0, &i);
if (error)
goto out;
if (!i)
acur.bnolt->bc_private.a.priv.abt.active = false;
} }
if (xfs_alloc_cur_active(acur.bnogt)) {
error = xfs_alloc_cur_check(args, &acur, acur.bnogt, &i); error = xfs_alloc_walk_iter(args, &acur, acur.bnogt, true, true,
if (error) 1, &i);
goto out; if (error)
if (i == 1) { goto out;
trace_xfs_alloc_cur_right(args); if (i == 1) {
fbcur = acur.bnolt; trace_xfs_alloc_cur_right(args);
fbinc = false; fbcur = acur.bnolt;
break; fbinc = false;
} break;
error = xfs_btree_increment(acur.bnogt, 0, &i);
if (error)
goto out;
if (!i)
acur.bnogt->bc_private.a.priv.abt.active = false;
} }
} while (xfs_alloc_cur_active(acur.bnolt) || } while (xfs_alloc_cur_active(acur.bnolt) ||
xfs_alloc_cur_active(acur.bnogt)); xfs_alloc_cur_active(acur.bnogt));
/* search the opposite direction for a better entry */ /* search the opposite direction for a better entry */
if (fbcur) { if (fbcur) {
error = xfs_alloc_find_best_extent(args, &acur, fbcur, fbinc); error = xfs_alloc_walk_iter(args, &acur, fbcur, fbinc, true, -1,
&i);
if (error) if (error)
goto out; goto out;
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment