forked from Deuxfleurs/garage
Reviewed-on: Deuxfleurs/garage#429
This commit is contained in:
commit
293139a94a
1 changed files with 5 additions and 3 deletions
|
@ -254,9 +254,11 @@ To know the correct value of the new layout version, invoke `garage layout show`
|
||||||
match self.initial_partition_assignation() {
|
match self.initial_partition_assignation() {
|
||||||
Some(initial_partitions) => {
|
Some(initial_partitions) => {
|
||||||
for (part, ipart) in partitions.iter_mut().zip(initial_partitions.iter()) {
|
for (part, ipart) in partitions.iter_mut().zip(initial_partitions.iter()) {
|
||||||
for (id, info) in ipart.nodes.iter() {
|
for _ in 0..2 {
|
||||||
if part.nodes.len() < self.replication_factor {
|
for (id, info) in ipart.nodes.iter() {
|
||||||
part.add(None, n_zones, id, info.unwrap());
|
if part.nodes.len() < self.replication_factor {
|
||||||
|
part.add(None, n_zones, id, info.unwrap());
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
assert!(part.nodes.len() == self.replication_factor);
|
assert!(part.nodes.len() == self.replication_factor);
|
||||||
|
|
Loading…
Reference in a new issue