fix break logic processed listner
This commit is contained in:
parent
b82f2c9f37
commit
02cd1e5f46
|
@ -421,7 +421,7 @@ impl BlockListener {
|
||||||
|
|
||||||
let mut errors = 0;
|
let mut errors = 0;
|
||||||
|
|
||||||
while errors == 5 {
|
while errors <= 10 {
|
||||||
if let Err(err) = self
|
if let Err(err) = self
|
||||||
.block_processor
|
.block_processor
|
||||||
.poll_latest_block(CommitmentConfig::processed())
|
.poll_latest_block(CommitmentConfig::processed())
|
||||||
|
@ -437,7 +437,7 @@ impl BlockListener {
|
||||||
tokio::time::sleep(tokio::time::Duration::from_millis(100)).await;
|
tokio::time::sleep(tokio::time::Duration::from_millis(100)).await;
|
||||||
}
|
}
|
||||||
|
|
||||||
bail!("5 consecutive errors while polling processed blocks")
|
bail!("{errors} consecutive errors while polling processed blocks")
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue