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(stages): debug logs with progress in sender recovery (#7113)

Browse Source
This commit is contained in:
Alexey Shekhirin
2024-03-13 09:59:59 +00:00
committed by GitHub
parent bf18bf50d5
commit 884fd71a01
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
crates/stages/src/stages/sender_recovery.rs
View File

@ -101,7 +101,7 @@ impl<DB: Database> Stage<DB> for SenderRecoveryStage {
for chunk_range in chunks { for chunk_range in chunks {
// An _unordered_ channel to receive results from a rayon job // An _unordered_ channel to receive results from a rayon job
let (recovered_senders_tx, recovered_senders_rx) = mpsc::channel(); let (recovered_senders_tx, recovered_senders_rx) = mpsc::channel();
channels.push(recovered_senders_rx); channels.push((chunk_range.clone(), recovered_senders_rx));
let static_file_provider = provider.static_file_provider().clone(); let static_file_provider = provider.static_file_provider().clone();
@ -109,10 +109,11 @@ impl<DB: Database> Stage<DB> for SenderRecoveryStage {
// This task will send the results through the channel after it has read the transaction // This task will send the results through the channel after it has read the transaction
// and calculated the sender. // and calculated the sender.
rayon::spawn(move || { rayon::spawn(move || {
debug!(target: "sync::stages::sender_recovery", ?chunk_range, "Recovering senders batch");
let mut rlp_buf = Vec::with_capacity(128); let mut rlp_buf = Vec::with_capacity(128);
let _ = static_file_provider.fetch_range_with_predicate( let _ = static_file_provider.fetch_range_with_predicate(
StaticFileSegment::Transactions, StaticFileSegment::Transactions,
chunk_range, chunk_range.clone(),
|cursor, number| { |cursor, number| {
Ok(cursor Ok(cursor
.get_one::<TransactionMask<TransactionSignedNoHash>>(number.into())? .get_one::<TransactionMask<TransactionSignedNoHash>>(number.into())?
@ -124,11 +125,13 @@ impl<DB: Database> Stage<DB> for SenderRecoveryStage {
}, },
|_| true, |_| true,
); );
debug!(target: "sync::stages::sender_recovery", ?chunk_range, "Finished recovering senders batch");
}); });
} }
// Iterate over channels and append the sender in the order that they are received. // Iterate over channels and append the sender in the order that they are received.
for channel in channels { for (chunk_range, channel) in channels {
debug!(target: "sync::stages::sender_recovery", ?chunk_range, "Appending recovered senders to the database");
while let Ok(recovered) = channel.recv() { while let Ok(recovered) = channel.recv() {
let (tx_id, sender) = match recovered { let (tx_id, sender) = match recovered {
Ok(result) => result, Ok(result) => result,