Skip to content

Commit 495ba45

Browse files
committed
block_stream: reset error count correctly
1 parent f3bc5bc commit 495ba45

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

chain/ethereum/src/block_stream.rs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -799,6 +799,8 @@ impl<S: Store, C: ChainStore> Stream for BlockStream<S, C> {
799799
match next_blocks_future.poll() {
800800
// Reconciliation found blocks to process
801801
Ok(Async::Ready(NextBlocks::Blocks(next_blocks, block_range_size))) => {
802+
self.consecutive_err_count = 0;
803+
802804
let total_triggers =
803805
next_blocks.iter().map(|b| b.triggers.len()).sum::<usize>();
804806
self.ctx.previous_triggers_per_block =

0 commit comments

Comments
 (0)