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: change net::discv5 log target to discv5 (#12045)

Browse Source
This commit is contained in:
Panagiotis Ganelis
2024-10-25 05:56:21 +02:00
committed by GitHub
parent 965dabacad
commit 674616cab9
1 changed files with 12 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
crates/net/discv5/src/lib.rs
View File

@ -167,7 +167,7 @@ impl Discv5 {
//
let (enr, bc_enr, fork_key, rlpx_ip_mode) = build_local_enr(sk, &discv5_config);
trace!(target: "net::discv5",
trace!(target: "discv5",
?enr,
"local ENR"
);
@ -271,7 +271,7 @@ impl Discv5 {
// to them over RLPx, to be compatible with EL discv5 implementations that don't
// enforce this security measure.
trace!(target: "net::discv5",
trace!(target: "discv5",
?enr,
%socket,
"discovered unverifiable enr, source socket doesn't match socket advertised in ENR"
@ -296,7 +296,7 @@ impl Discv5 {
let node_record = match self.try_into_reachable(enr, socket) {
Ok(enr_bc) => enr_bc,
Err(err) => {
trace!(target: "net::discv5",
trace!(target: "discv5",
%err,
?enr,
"discovered peer is unreachable"
@ -308,7 +308,7 @@ impl Discv5 {
}
};
if let FilterOutcome::Ignore { reason } = self.filter_discovered_peer(enr) {
trace!(target: "net::discv5",
trace!(target: "discv5",
?enr,
reason,
"filtered out discovered peer"
@ -324,7 +324,7 @@ impl Discv5 {
.then(|| self.get_fork_id(enr).ok())
.flatten();
trace!(target: "net::discv5",
trace!(target: "discv5",
?fork_id,
?enr,
"discovered peer"
@ -491,7 +491,7 @@ pub async fn bootstrap(
bootstrap_nodes: HashSet<BootNode>,
discv5: &Arc<discv5::Discv5>,
) -> Result<(), Error> {
trace!(target: "net::discv5",
trace!(target: "discv5",
?bootstrap_nodes,
"adding bootstrap nodes .."
);
@ -508,7 +508,7 @@ pub async fn bootstrap(
let discv5 = discv5.clone();
enr_requests.push(async move {
if let Err(err) = discv5.request_enr(enode.to_string()).await {
debug!(target: "net::discv5",
debug!(target: "discv5",
?enode,
%err,
"failed adding boot node"
@ -545,7 +545,7 @@ pub fn spawn_populate_kbuckets_bg(
for i in (0..bootstrap_lookup_countdown).rev() {
let target = discv5::enr::NodeId::random();
trace!(target: "net::discv5",
trace!(target: "discv5",
%target,
bootstrap_boost_runs_countdown=i,
lookup_interval=format!("{:#?}", pulse_lookup_interval),
@ -563,7 +563,7 @@ pub fn spawn_populate_kbuckets_bg(
// selection (ref kademlia)
let target = get_lookup_target(kbucket_index, local_node_id);
trace!(target: "net::discv5",
trace!(target: "discv5",
%target,
lookup_interval=format!("{:#?}", lookup_interval),
"starting periodic lookup query"
@ -628,11 +628,11 @@ pub async fn lookup(
);
match discv5.find_node(target).await {
Err(err) => trace!(target: "net::discv5",
Err(err) => trace!(target: "discv5",
%err,
"lookup query failed"
),
Ok(peers) => trace!(target: "net::discv5",
Ok(peers) => trace!(target: "discv5",
target=format!("{:#?}", target),
peers_count=peers.len(),
peers=format!("[{:#}]", peers.iter()
@ -645,7 +645,7 @@ pub async fn lookup(
// `Discv5::connected_peers` can be subset of sessions, not all peers make it
// into kbuckets, e.g. incoming sessions from peers with
// unreachable enrs
debug!(target: "net::discv5",
debug!(target: "discv5",
connected_peers=discv5.connected_peers(),
"connected peers in routing table"
);