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

feat(prune): add pruner log with INFO level (#4573)

Browse Source 
Co-authored-by: Alexey Shekhirin <a.shekhirin@gmail.com>
This commit is contained in:
Thomas Coratger
2023-09-18 19:45:31 +02:00
committed by GitHub
parent b5905c482b
commit 78edae4d4f
1 changed files with 18 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
crates/prune/src/pruner.rs
View File

@ -19,8 +19,8 @@ use reth_provider::{
BlockReader, DatabaseProviderRW, ProviderFactory, PruneCheckpointReader, PruneCheckpointWriter,
TransactionsProvider,
};
use std::{ops::RangeInclusive, sync::Arc, time::Instant};
use tracing::{debug, error, instrument, trace};
use std::{collections::HashMap, ops::RangeInclusive, sync::Arc, time::Instant};
use tracing::{debug, error, info, instrument, trace};
/// Result of [Pruner::run] execution.
///
@ -81,6 +81,8 @@ impl<DB: Database> Pruner<DB> {
let mut done = true;
let mut parts_done = HashMap::new();
if let Some((to_block, prune_mode)) =
self.modes.prune_target_block_receipts(tip_block_number)?
{
@ -95,6 +97,7 @@ impl<DB: Database> Pruner<DB> {
let part_start = Instant::now();
let part_done = self.prune_receipts(&provider, to_block, prune_mode)?;
done = done && part_done;
parts_done.insert(PrunePart::Receipts, part_done);
self.metrics
.get_prune_part_metrics(PrunePart::Receipts)
.duration_seconds
@ -107,6 +110,7 @@ impl<DB: Database> Pruner<DB> {
let part_start = Instant::now();
let part_done = self.prune_receipts_by_logs(&provider, tip_block_number)?;
done = done && part_done;
parts_done.insert(PrunePart::ContractLogs, part_done);
self.metrics
.get_prune_part_metrics(PrunePart::ContractLogs)
.duration_seconds
@ -129,6 +133,7 @@ impl<DB: Database> Pruner<DB> {
let part_start = Instant::now();
let part_done = self.prune_transaction_lookup(&provider, to_block, prune_mode)?;
done = done && part_done;
parts_done.insert(PrunePart::TransactionLookup, part_done);
self.metrics
.get_prune_part_metrics(PrunePart::TransactionLookup)
.duration_seconds
@ -155,6 +160,7 @@ impl<DB: Database> Pruner<DB> {
let part_start = Instant::now();
let part_done = self.prune_transaction_senders(&provider, to_block, prune_mode)?;
done = done && part_done;
parts_done.insert(PrunePart::SenderRecovery, part_done);
self.metrics
.get_prune_part_metrics(PrunePart::SenderRecovery)
.duration_seconds
@ -181,6 +187,7 @@ impl<DB: Database> Pruner<DB> {
let part_start = Instant::now();
let part_done = self.prune_account_history(&provider, to_block, prune_mode)?;
done = done && part_done;
parts_done.insert(PrunePart::AccountHistory, part_done);
self.metrics
.get_prune_part_metrics(PrunePart::AccountHistory)
.duration_seconds
@ -207,6 +214,7 @@ impl<DB: Database> Pruner<DB> {
let part_start = Instant::now();
let part_done = self.prune_storage_history(&provider, to_block, prune_mode)?;
done = done && part_done;
parts_done.insert(PrunePart::StorageHistory, part_done);
self.metrics
.get_prune_part_metrics(PrunePart::StorageHistory)
.duration_seconds
@ -225,7 +233,14 @@ impl<DB: Database> Pruner<DB> {
let elapsed = start.elapsed();
self.metrics.duration_seconds.record(elapsed);
trace!(target: "pruner", %tip_block_number, ?elapsed, "Pruner finished");
info!(
target: "pruner",
%tip_block_number,
?elapsed,
%done,
?parts_done,
"Pruner finished"
);
Ok(done)
}