aboutsummaryrefslogtreecommitdiff
path: root/src/rpc
diff options
context:
space:
mode:
authorAlex Auvolat <alex@adnab.me>2024-08-24 12:38:56 +0200
committerAlex Auvolat <alex@adnab.me>2024-08-24 12:38:56 +0200
commit7fb66b4944b637dfcd53bc301f7bbed501ca8573 (patch)
tree51a39beb9c5b0cf8f1683981d9b32ea25deac3ed /src/rpc
parent679ae8bcbb234623eed83dd10bb9d051eefead4a (diff)
downloadgarage-7fb66b4944b637dfcd53bc301f7bbed501ca8573.tar.gz
garage-7fb66b4944b637dfcd53bc301f7bbed501ca8573.zip
layout: discard old info when it is completely out-of-date (fix #841)fix-841
Diffstat (limited to 'src/rpc')
-rw-r--r--src/rpc/layout/history.rs23
1 files changed, 14 insertions, 9 deletions
diff --git a/src/rpc/layout/history.rs b/src/rpc/layout/history.rs
index af2cbc63..574c50c2 100644
--- a/src/rpc/layout/history.rs
+++ b/src/rpc/layout/history.rs
@@ -227,24 +227,29 @@ impl LayoutHistory {
// ================== updates to layout, public interface ===================
pub fn merge(&mut self, other: &LayoutHistory) -> bool {
+ // If our current layout version is completely out-of-date,
+ // forget everything we know and replace it by incoming layout data.
+ if self.current().version < other.min_stored() {
+ *self = other.clone();
+ return true;
+ }
+
let mut changed = false;
// Add any new versions to history
for v2 in other.versions.iter() {
- if let Some(v1) = self.versions.iter().find(|v| v.version == v2.version) {
+ if v2.version == self.current().version + 1 {
+ // This is the next version, add it to our version list
+ self.versions.push(v2.clone());
+ changed = true;
+ } else if let Some(v1) = self.versions.iter().find(|v| v.version == v2.version) {
// Version is already present, check consistency
if v1 != v2 {
error!("Inconsistent layout histories: different layout compositions for version {}. Your cluster will be broken as long as this layout version is not replaced.", v2.version);
}
- } else if self.versions.iter().all(|v| v.version != v2.version - 1) {
- error!(
- "Cannot receive new layout version {}, version {} is missing",
- v2.version,
- v2.version - 1
- );
} else {
- self.versions.push(v2.clone());
- changed = true;
+ // This is an older version
+ assert!(v2.version < self.min_stored());
}
}