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

fix(op): fix logs (#8329)

Browse Source
This commit is contained in:
Emilia Hane
2024-05-21 11:49:43 +02:00
committed by GitHub
parent 23738e6db5
commit 043b4a9cda
4 changed files with 8 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
bin/reth/src/commands/import_op.rs
View File

@ -121,7 +121,7 @@ impl ImportOpCommand {
info!(target: "reth::cli", "Chain file chunk read");
total_decoded_blocks += file_client.headers_len();
total_decoded_txns += file_client.bodies_len();
total_decoded_txns += file_client.total_transactions();
for (block_number, body) in file_client.bodies_iter_mut() {
body.transactions.retain(|tx| {
@ -172,16 +172,17 @@ impl ImportOpCommand {
let provider = provider_factory.provider()?;
let total_imported_blocks = provider.tx_ref().entries::<tables::Headers>()?;
let total_imported_blocks = provider.tx_ref().entries::<tables::HeaderNumbers>()?;
let total_imported_txns = provider.tx_ref().entries::<tables::TransactionHashNumbers>()?;
if total_decoded_blocks != total_imported_blocks ||
total_decoded_txns != total_imported_txns
total_decoded_txns != total_imported_txns + total_filtered_out_dup_txns
{
error!(target: "reth::cli",
total_decoded_blocks,
total_imported_blocks,
total_decoded_txns,
total_filtered_out_dup_txns,
total_imported_txns,
"Chain was partially imported"
);

4
bin/reth/src/commands/import_receipts.rs
View File

@ -19,7 +19,7 @@ use reth_provider::{
BundleStateWithReceipts, OriginalValuesKnown, ProviderFactory, StageCheckpointReader,
StateWriter, StaticFileProviderFactory, StaticFileWriter,
};
use tracing::{debug, error, info};
use tracing::{debug, error, info, trace};
use std::{path::PathBuf, sync::Arc};
@ -89,7 +89,7 @@ impl ImportReceiptsCommand {
for stage in StageId::ALL {
let checkpoint = provider.get_stage_checkpoint(stage)?;
debug!(target: "reth::cli",
trace!(target: "reth::cli",
?stage,
?checkpoint,
"Read stage checkpoints from db"

2
crates/net/downloaders/src/file_client.rs
View File

@ -172,7 +172,7 @@ impl FileClient {
/// Returns the current number of transactions in the client.
pub fn total_transactions(&self) -> usize {
self.bodies.iter().flat_map(|(_, body)| &body.transactions).count()
self.bodies.iter().fold(0, |acc, (_, body)| acc + body.transactions.len())
}
}

2
crates/net/downloaders/src/receipt_file_client.rs
View File

@ -43,7 +43,7 @@ impl FromReader for ReceiptFileClient {
trace!(target: "downloaders::file",
target_num_bytes=num_bytes,
capacity=stream.read_buffer().capacity(),
coded=?HackReceiptFileCodec,
codec=?HackReceiptFileCodec,
"init decode stream"
);