github/reth
1
1
Fork 0
mirror of https://github.com/paradigmxyz/reth.git synced 2026-01-29 00:58:11 -05:00
Code Issues Packages Projects Releases Wiki Activity

fix(txpool): maintenance tracing target (#4160)

Browse Source
This commit is contained in:
Roman Krasiuk
2023-08-11 15:39:38 +03:00
committed by GitHub
parent 500b0fac13
commit 03fc87701a
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
crates/transaction-pool/src/maintain.rs
View File

@@ -105,7 +105,7 @@ pub async fn maintain_transaction_pool<Client, P, St, Tasks>(
// The update loop that waits for new blocks and reorgs and performs pool updated
// Listen for new chain events and derive the update action for the pool
loop {
trace!(target = "txpool", state=?maintained_state, "awaiting new block or reorg");
trace!(target: "txpool", state=?maintained_state, "awaiting new block or reorg");
metrics.set_dirty_accounts_len(dirty_addresses.len());
let pool_info = pool.block_info();
@@ -181,7 +181,7 @@ pub async fn maintain_transaction_pool<Client, P, St, Tasks>(
Some(Ok(Err(res))) => {
// Failed to load accounts from state
let (accs, err) = *res;
debug!(target = "txpool", ?err, "failed to load accounts");
debug!(target: "txpool", ?err, "failed to load accounts");
dirty_addresses.extend(accs);
}
Some(Err(_)) => {
@@ -238,7 +238,7 @@ pub async fn maintain_transaction_pool<Client, P, St, Tasks>(
Err(err) => {
let (addresses, err) = *err;
debug!(
target = "txpool",
target: "txpool",
?err,
"failed to load missing changed accounts at new tip: {:?}",
new_tip.hash
@@ -295,7 +295,7 @@ pub async fn maintain_transaction_pool<Client, P, St, Tasks>(
let first_block = blocks.first();
trace!(
target = "txpool",
target: "txpool",
first = first_block.number,
tip = tip.number,
pool_block = pool_info.last_seen_block_number,
@@ -307,7 +307,7 @@ pub async fn maintain_transaction_pool<Client, P, St, Tasks>(
let depth = tip.number.abs_diff(pool_info.last_seen_block_number);
if depth > max_update_depth {
maintained_state = MaintainedPoolState::Drifted;
debug!(target = "txpool", ?depth, "skipping deep canonical update");
debug!(target: "txpool", ?depth, "skipping deep canonical update");
let info = BlockInfo {
last_seen_block_hash: tip.hash,
last_seen_block_number: tip.number,