continueing sync
This commit is contained in:
parent
20ca72ee0c
commit
86cfe95113
@ -985,11 +985,12 @@ impl ChainSync {
|
|||||||
}
|
}
|
||||||
|
|
||||||
/// Handle peer timeouts
|
/// Handle peer timeouts
|
||||||
pub fn maintain_peers(&self, io: &mut SyncIo) {
|
pub fn maintain_peers(&mut self, io: &mut SyncIo) {
|
||||||
let tick = time::precise_time_s();
|
let tick = time::precise_time_s();
|
||||||
|
|
||||||
if !io.chain().queue_info().full {
|
if !io.chain().queue_info().full && self.state == SyncState::Waiting {
|
||||||
self.state == SyncState::Idle;
|
self.state = SyncState::Idle;
|
||||||
|
self.continue_sync(io);
|
||||||
}
|
}
|
||||||
|
|
||||||
for (peer_id, peer) in &self.peers {
|
for (peer_id, peer) in &self.peers {
|
||||||
|
Loading…
Reference in New Issue
Block a user