|
|
@@ -257,10 +257,15 @@ pub async fn occupied_nodes(config: &Config) -> Result<HashSet<String>> {
|
|
|
}
|
|
|
let mut occupied = HashSet::new();
|
|
|
for h in futures::future::join_all(handles).await {
|
|
|
- if let Ok((name, Ok(output))) = h
|
|
|
- && !output.trim().is_empty()
|
|
|
- {
|
|
|
- occupied.insert(name);
|
|
|
+ match h {
|
|
|
+ Ok((name, Ok(output))) if !output.trim().is_empty() => {
|
|
|
+ occupied.insert(name);
|
|
|
+ }
|
|
|
+ Ok((name, Err(_))) => {
|
|
|
+ // Node is unreachable — mark as unavailable
|
|
|
+ occupied.insert(name);
|
|
|
+ }
|
|
|
+ _ => {}
|
|
|
}
|
|
|
}
|
|
|
Ok(occupied)
|