diff --git a/bin/reth/src/block_ingest.rs b/bin/reth/src/block_ingest.rs index 74b82bbf0..2b023b6c7 100644 --- a/bin/reth/src/block_ingest.rs +++ b/bin/reth/src/block_ingest.rs @@ -29,7 +29,6 @@ use tokio::sync::Mutex; use tracing::{debug, info}; use crate::serialized::{BlockAndReceipts, EvmBlock}; -use crate::share_blocks::ShareBlocks; use crate::spot_meta::erc20_contract_to_spot_token; /// Poll interval when tailing an *open* hourly file. @@ -42,7 +41,6 @@ pub(crate) struct BlockIngest { pub local_ingest_dir: Option, pub local_blocks_cache: Arc>>, // height → block pub precompiles_cache: PrecompilesCache, - pub hlfs: Option, } #[derive(Deserialize)] @@ -159,16 +157,6 @@ impl BlockIngest { return Some(block); } - // if let Some(hlfs) = &self.hlfs { - // //info!("!! HEIGHT [{height}] :: HEAD [{head}]"); - // if hlfs.try_fetch_one(height).await.ok().flatten().is_some() { - // if let Some(block) = self.try_collect_local_block(height).await { - // info!("Returning HLFS-fetched block @[{height}]"); - // return Some(block); - // } - // } - // } - self.try_collect_s3_block(height) } diff --git a/bin/reth/src/share_blocks.rs b/bin/reth/src/share_blocks.rs index 8edee53a6..ee7afa1bc 100644 --- a/bin/reth/src/share_blocks.rs +++ b/bin/reth/src/share_blocks.rs @@ -60,10 +60,6 @@ impl ShareBlocks { Ok(Self { _server, _autodetect }) } - // #[allow(dead_code)] - // pub(crate) async fn try_fetch_one(&self, block: u64) -> eyre::Result> { - // self._backfiller.fetch_if_missing(block).await.map_err(|e| eyre::eyre!(e)) - // } } fn spawn_autodetect(