jleony/nanoreth
1
0
Fork 0
mirror of https://github.com/hl-archive-node/nanoreth.git synced 2025-12-06 10:59:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: Improve log

Browse Source
This commit is contained in:
sprites0
2025-08-01 17:28:31 +00:00
parent ff2e55b5a2
commit 2d6b5e5cd2
1 changed files with 15 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
src/pseudo_peer/sources/hl_node.rs
View File

@ -7,8 +7,8 @@ use std::{
}; };
use futures::future::BoxFuture; use futures::future::BoxFuture;
use reth_network::cache::LruMap;
use rangemap::RangeInclusiveMap; use rangemap::RangeInclusiveMap;
use reth_network::cache::LruMap;
use serde::Deserialize; use serde::Deserialize;
use time::{macros::format_description, Date, Duration, OffsetDateTime, Time}; use time::{macros::format_description, Date, Duration, OffsetDateTime, Time};
use tokio::sync::Mutex; use tokio::sync::Mutex;
@ -33,10 +33,7 @@ impl LocalBlocksCache {
const CACHE_SIZE: u32 = 8000; const CACHE_SIZE: u32 = 8000;
fn new() -> Self { fn new() -> Self {
Self { Self { cache: LruMap::new(Self::CACHE_SIZE), ranges: RangeInclusiveMap::new() }
cache: LruMap::new(Self::CACHE_SIZE),
ranges: RangeInclusiveMap::new(),
}
} }
fn load_scan_result(&mut self, scan_result: ScanResult) { fn load_scan_result(&mut self, scan_result: ScanResult) {
@ -280,7 +277,19 @@ impl HlNodeBlockSource {
scan_result.new_blocks.clear(); scan_result.new_blocks.clear();
u_cache.load_scan_result(scan_result); u_cache.load_scan_result(scan_result);
} }
info!("Backfilled {} blocks", u_cache.cache.len());
if u_cache.ranges.is_empty() {
warn!("No ranges found in {:?}", root);
} else {
let (min, _) = u_cache.ranges.first_range_value().unwrap();
let (max, _) = u_cache.ranges.last_range_value().unwrap();
info!(
"Populated {} ranges (min: {}, max: {})",
u_cache.ranges.len(),
min.start(),
max.end()
);
}
Ok(()) Ok(())
} }