From 9c8fd08e3ee11b9b95940d99ea4b2d7ee02d9a65 Mon Sep 17 00:00:00 2001 From: Xiangyi Zheng Date: Mon, 4 Aug 2025 18:16:22 -0700 Subject: [PATCH] continue if no new block head received --- chain-signatures/node/src/indexer_eth.rs | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/chain-signatures/node/src/indexer_eth.rs b/chain-signatures/node/src/indexer_eth.rs index 211a8956b..4504caac5 100644 --- a/chain-signatures/node/src/indexer_eth.rs +++ b/chain-signatures/node/src/indexer_eth.rs @@ -688,11 +688,12 @@ async fn add_new_block_to_process( let mut receiver_state_update_timestamp = Instant::now(); loop { interval.tick().await; - if block_heads_rx.is_empty() - && receiver_state_update_timestamp.elapsed() > Duration::from_secs(60) - { - tracing::warn!("No new block heads received for 60 seconds, waiting..."); - receiver_state_update_timestamp = Instant::now(); + if block_heads_rx.is_empty() { + if receiver_state_update_timestamp.elapsed() > Duration::from_secs(60) { + tracing::warn!("No new block heads received for 60 seconds, waiting..."); + receiver_state_update_timestamp = Instant::now(); + } + continue; } let new_block_head = match block_heads_rx.recv().await { Ok(new_block_head) => new_block_head,