summaryrefslogtreecommitdiffstats
path: root/xlators
diff options
context:
space:
mode:
Diffstat (limited to 'xlators')
-rw-r--r--xlators/cluster/dht/src/dht-selfheal.c44
1 files changed, 38 insertions, 6 deletions
diff --git a/xlators/cluster/dht/src/dht-selfheal.c b/xlators/cluster/dht/src/dht-selfheal.c
index f4b0ceeade8..1583ee5c602 100644
--- a/xlators/cluster/dht/src/dht-selfheal.c
+++ b/xlators/cluster/dht/src/dht-selfheal.c
@@ -380,15 +380,41 @@ dht_layout_span (dht_layout_t *layout)
return count;
}
+int
+dht_decommissioned_bricks_in_layout (xlator_t *this, dht_layout_t *layout)
+{
+ dht_conf_t *conf = NULL;
+ int count = 0, i = 0, j = 0;
+
+ if ((this == NULL) || (layout == NULL))
+ goto out;
+
+ conf = this->private;
+
+ for (i = 0; i < layout->cnt; i++) {
+ for (j = 0; j < conf->subvolume_cnt; j++) {
+ if (conf->decommissioned_bricks[j] &&
+ conf->decommissioned_bricks[j]
+ == layout->list[i].xlator) {
+ count++;
+ }
+ }
+ }
+
+out:
+ return count;
+}
+
gf_boolean_t
dht_should_fix_layout (call_frame_t *frame, dht_layout_t **inmem,
dht_layout_t **ondisk)
{
- gf_boolean_t fixit = _gf_true;
- dht_local_t *local = NULL;
- int layout_span = 0;
- int ret = 0;
- dht_conf_t *conf = NULL;
+ gf_boolean_t fixit = _gf_true;
+ dht_local_t *local = NULL;
+ int layout_span = 0, decommissioned_bricks = 0;
+ int spread_count = 0;
+ int ret = 0;
+ dht_conf_t *conf = NULL;
conf = frame->this->private;
@@ -418,7 +444,13 @@ dht_should_fix_layout (call_frame_t *frame, dht_layout_t **inmem,
layout_span = dht_layout_span (*ondisk);
- if (layout_span == conf->subvolume_cnt)
+ decommissioned_bricks = dht_decommissioned_bricks_in_layout (frame->this,
+ *ondisk);
+ spread_count = conf->dir_spread_cnt ? conf->dir_spread_cnt
+ : conf->subvolume_cnt;
+
+ if ((decommissioned_bricks == 0) && (layout_span
+ == spread_count))
fixit = _gf_false;
out: