|
@@ -113,7 +113,7 @@ pub async fn consensus_sync_task(p2p: P2pPtr, state: ValidatorStatePtr) -> Resul
|
|
|
let mut response = response_sub.receive().await?;
|
|
let mut response = response_sub.receive().await?;
|
|
|
// Verify that peer has finished finalizing forks
|
|
// Verify that peer has finished finalizing forks
|
|
|
loop {
|
|
loop {
|
|
|
- if response.forks.len() != 1 || response.forks[0].sequence.len() != 1 {
|
|
|
|
|
|
|
+ if response.forks.len() != 1 {
|
|
|
warn!(target: "consensus::consensus_sync", "Peer has not finished finalization, retrying...");
|
|
warn!(target: "consensus::consensus_sync", "Peer has not finished finalization, retrying...");
|
|
|
sleep(1).await;
|
|
sleep(1).await;
|
|
|
peer.send(ConsensusRequest {}).await?;
|
|
peer.send(ConsensusRequest {}).await?;
|