From fae4b4c8f903c87fa48ffc20aa25c511f59ebdbe Mon Sep 17 00:00:00 2001 From: Nicholas Wehr Date: Thu, 21 Aug 2025 23:50:10 -0700 Subject: [PATCH] debug --- bin/reth/src/share_blocks.rs | 3 +-- crates/net/hlfs/src/lib.rs | 3 ++- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/bin/reth/src/share_blocks.rs b/bin/reth/src/share_blocks.rs index ede25305c..6383bb4c1 100644 --- a/bin/reth/src/share_blocks.rs +++ b/bin/reth/src/share_blocks.rs @@ -81,16 +81,15 @@ where Arc::new(tokio::sync::Mutex::new(HashSet::new())); tokio::spawn({ + warn!("hlfs: backfiller started"); let backfiller = backfiller.clone(); async move { loop { let mut bf = backfiller.lock().await; - warn!("hlfs: backfiller started"); if bf.client.max_block < bf.max_block_seen { let block = bf.client.max_block + 1; let _ = bf.fetch_if_missing(block).await; } - sleep(Duration::from_secs(1)).await; } } diff --git a/crates/net/hlfs/src/lib.rs b/crates/net/hlfs/src/lib.rs index bbbf4403e..a5c739a02 100644 --- a/crates/net/hlfs/src/lib.rs +++ b/crates/net/hlfs/src/lib.rs @@ -338,7 +338,7 @@ impl Backfiller { let path = format!("{}/{f}/{s}/{number}.rmp.lz4", self.root.to_string_lossy()); if Path::new(&path).exists() { - trace!(block = number, "hlfs: already have"); + debug!(block = number, "hlfs: already have"); return Ok(None); } match self.client.wants_block(number, rr_index).await { @@ -356,6 +356,7 @@ impl Backfiller { warn!(%path, "hlfs: write failed: {e}"); return Ok(None); } + debug!(block = number, "hlfs: got block"); Ok(Some(data.len())) } }