trinity-1686a/garage
2
0
Fork 0
forked from Deuxfleurs/garage
Code Issues Pull requests 1 Projects Releases Wiki Activity

update condition

Browse source
This commit is contained in:
Alex 2021-03-05 17:08:03 +01:00
parent 5e33c3cfc9
commit 7cda917b6b
1 changed files with 2 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
src/rpc/ring.rs
View file

@ -122,9 +122,8 @@ impl Ring {
.iter() .iter()
.map(|(_id, info)| info.datacenter.as_str()) .map(|(_id, info)| info.datacenter.as_str())
.collect::<HashSet<&str>>(); .collect::<HashSet<&str>>();
if !partitions[qv] if (p_dcs.len() < n_datacenters
.iter() && !p_dcs.contains(&node_info.datacenter.as_str()))
.any(|(_id, i)| *i.datacenter == node_info.datacenter)
|| (p_dcs.len() == n_datacenters || (p_dcs.len() == n_datacenters
&& !partitions[qv].iter().any(|(id, _i)| id == node_id)) && !partitions[qv].iter().any(|(id, _i)| id == node_id))
{ {