aboutsummaryrefslogtreecommitdiff
path: root/src/garage
diff options
context:
space:
mode:
authorAlex Auvolat <lx@deuxfleurs.fr>2025-02-14 14:11:23 +0100
committerAlex Auvolat <lx@deuxfleurs.fr>2025-02-14 14:11:41 +0100
commitd84308c413ce3e7d84678170f51384e25341031e (patch)
treeb3f8d18dd58703dcb5180b8b01c119026877dd12 /src/garage
parent63f20bdeabfef21cf4f8c91a542bf3d0f5e77ad6 (diff)
downloadgarage-d84308c413ce3e7d84678170f51384e25341031e.tar.gz
garage-d84308c413ce3e7d84678170f51384e25341031e.zip
cli: return info of all nodes when doing garage stats -a (fix #814)
Diffstat (limited to 'src/garage')
-rw-r--r--src/garage/admin/mod.rs7
1 files changed, 6 insertions, 1 deletions
diff --git a/src/garage/admin/mod.rs b/src/garage/admin/mod.rs
index 1a4ff853..3bbc2b86 100644
--- a/src/garage/admin/mod.rs
+++ b/src/garage/admin/mod.rs
@@ -146,7 +146,12 @@ impl AdminRpcHandler {
async fn handle_stats(&self, opt: StatsOpt) -> Result<AdminRpc, Error> {
if opt.all_nodes {
let mut ret = String::new();
- let all_nodes = self.garage.system.cluster_layout().all_nodes().to_vec();
+ let mut all_nodes = self.garage.system.cluster_layout().all_nodes().to_vec();
+ for node in self.garage.system.get_known_nodes().iter() {
+ if node.is_up && !all_nodes.contains(&node.id) {
+ all_nodes.push(node.id);
+ }
+ }
for node in all_nodes.iter() {
let mut opt = opt.clone();