diff --git a/node/sync/src/controllers/serial.rs b/node/sync/src/controllers/serial.rs index 1fe2d8d..c13ec75 100644 --- a/node/sync/src/controllers/serial.rs +++ b/node/sync/src/controllers/serial.rs @@ -561,7 +561,10 @@ impl SerialSyncController { while !completed { match self.state { SyncState::Idle => { - if self.peers.count(&[Found, Connecting, Connected]) > 0 { + if self + .peers + .all_shards_available(vec![Found, Connecting, Connected]) + { self.state = SyncState::FoundPeers; } else { self.try_find_peers(); @@ -569,7 +572,10 @@ impl SerialSyncController { } SyncState::FindingPeers { since, .. } => { - if self.peers.count(&[Found, Connecting, Connected]) > 0 { + if self + .peers + .all_shards_available(vec![Found, Connecting, Connected]) + { self.state = SyncState::FoundPeers; } else { // storage node may not have the specific file when `FindFile`