diff options
| author | Alex Auvolat <alex@adnab.me> | 2023-11-15 13:28:30 +0100 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2023-11-15 13:28:30 +0100 |
| commit | 65066c70640371cc318faddfb4c05c96de18e86d (patch) | |
| tree | 11c8d69b325896e8b0cf3d2af83e18c1c90fbc78 /src/rpc/layout/manager.rs | |
| parent | acd49de9f97bd27409232691262bd5827983388d (diff) | |
| download | garage-65066c70640371cc318faddfb4c05c96de18e86d.tar.gz garage-65066c70640371cc318faddfb4c05c96de18e86d.zip | |
layout: wip cache global mins
Diffstat (limited to 'src/rpc/layout/manager.rs')
| -rw-r--r-- | src/rpc/layout/manager.rs | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/rpc/layout/manager.rs b/src/rpc/layout/manager.rs index ce8b6f61..21ec2d8d 100644 --- a/src/rpc/layout/manager.rs +++ b/src/rpc/layout/manager.rs @@ -74,7 +74,7 @@ impl LayoutManager { } }; - cluster_layout.update_trackers(node_id.into()); + cluster_layout.update_trackers_of(node_id.into()); let layout = Arc::new(RwLock::new(cluster_layout)); let change_notify = Arc::new(Notify::new()); @@ -158,7 +158,7 @@ impl LayoutManager { if !prev_layout_check || adv.check().is_ok() { if layout.merge(adv) { - layout.update_trackers(self.node_id); + layout.update_trackers_of(self.node_id); if prev_layout_check && layout.check().is_err() { panic!("Merged two correct layouts and got an incorrect layout."); } @@ -172,7 +172,7 @@ impl LayoutManager { let mut layout = self.layout.write().unwrap(); if layout.update_trackers != *adv { if layout.update_trackers.merge(adv) { - layout.update_trackers(self.node_id); + layout.update_trackers_of(self.node_id); return Some(layout.update_trackers.clone()); } } |