crush: new SET_CHOOSE_LEAF_TRIES command
Explicitly control the number of sample attempts, and allow the number of
tries in the recursive call to be explicitly controlled via the rule. This
is important because the amount of time we want to spend looking for a
solution may be rule dependent (e.g., higher for the wide indep pool than
the rep pools).
(We should do the same for the other tunables, by the way!)
Reflects ceph.git commit c43c893be872f709c787bc57f46c0e97876ff681.
Signed-off-by: Ilya Dryomov <ilya.dryomov@inktank.com>
Reviewed-by: Sage Weil <sage@inktank.com>
diff --git a/net/ceph/crush/mapper.c b/net/ceph/crush/mapper.c
index c727836..e3ade07 100644
--- a/net/ceph/crush/mapper.c
+++ b/net/ceph/crush/mapper.c
@@ -455,11 +455,13 @@
*
*/
static void crush_choose_indep(const struct crush_map *map,
- struct crush_bucket *bucket,
- const __u32 *weight, int weight_max,
+ struct crush_bucket *bucket,
+ const __u32 *weight, int weight_max,
int x, int left, int numrep, int type,
- int *out, int outpos,
- int recurse_to_leaf,
+ int *out, int outpos,
+ unsigned int attempts,
+ unsigned int recurse_attempts,
+ int recurse_to_leaf,
int *out2,
int parent_r)
{
@@ -483,7 +485,7 @@
out2[rep] = CRUSH_ITEM_UNDEF;
}
- for (ftotal = 0; left > 0 && ftotal < map->choose_total_tries; ftotal++) {
+ for (ftotal = 0; left > 0 && ftotal < attempts; ftotal++) {
for (rep = outpos; rep < endpos; rep++) {
if (out[rep] != CRUSH_ITEM_UNDEF)
continue;
@@ -564,11 +566,12 @@
if (recurse_to_leaf) {
if (item < 0) {
crush_choose_indep(map,
- map->buckets[-1-item],
- weight, weight_max,
- x, 1, numrep, 0,
- out2, rep,
- 0, NULL, r);
+ map->buckets[-1-item],
+ weight, weight_max,
+ x, 1, numrep, 0,
+ out2, rep,
+ recurse_attempts, 0,
+ 0, NULL, r);
if (out2[rep] == CRUSH_ITEM_NONE) {
/* placed nothing; no leaf */
break;
@@ -631,6 +634,7 @@
__u32 step;
int i, j;
int numrep;
+ int choose_leaf_tries = 1;
const int descend_once = 0;
if ((__u32)ruleno >= map->max_rules) {
@@ -653,6 +657,11 @@
wsize = 1;
break;
+ case CRUSH_RULE_SET_CHOOSE_LEAF_TRIES:
+ if (curstep->arg1 > 0)
+ choose_leaf_tries = curstep->arg1;
+ break;
+
case CRUSH_RULE_CHOOSE_LEAF_FIRSTN:
case CRUSH_RULE_CHOOSE_FIRSTN:
firstn = 1;
@@ -702,6 +711,8 @@
x, numrep, numrep,
curstep->arg2,
o+osize, j,
+ map->choose_total_tries,
+ choose_leaf_tries,
recurse_to_leaf,
c+osize,
0);