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: add more granular tx propagation logs (#10026)

Browse Source
This commit is contained in:
Dan Cline
2024-08-02 12:14:35 -04:00
committed by GitHub
parent 34f4b6efae
commit a6733cafa3
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
crates/net/network/src/transactions/mod.rs
View File

@ -362,6 +362,8 @@ where
),
);
trace!(target: "net::tx::propagation", sent_txs=?transactions.iter().map(|tx| *tx.hash()), "Sending requested transactions to peer");
// we sent a response at which point we assume that the peer is aware of the
// transactions
peer.seen_transactions.extend(transactions.iter().map(|tx| *tx.hash()));
@ -580,6 +582,8 @@ where
propagated.0.entry(hash).or_default().push(PropagateKind::Hash(peer_id));
}
trace!(target: "net::tx::propagation", ?peer_id, ?new_pooled_hashes, "Propagating transactions to peer");
// send hashes of transactions
self.network.send_transactions_hashes(peer_id, new_pooled_hashes);
@ -728,7 +732,7 @@ where
return
}
trace!(target: "net::tx",
trace!(target: "net::tx::propagation",
peer_id=format!("{peer_id:#}"),
hashes_len=valid_announcement_data.iter().count(),
hashes=?valid_announcement_data.keys().collect::<Vec<_>>(),
@ -1037,6 +1041,7 @@ where
let tx_manager_info_pending_pool_imports =
self.pending_pool_imports_info.pending_pool_imports.clone();
trace!(target: "net::tx::propagation", new_txs_len=?new_txs.len(), "Importing new transactions");
let import = Box::pin(async move {
let added = new_txs.len();
let res = pool.add_external_transactions(new_txs).await;