Skip to content

Commit 9d24844

Browse files
authored
Lookup log improvements (#5491)
* log improvements
1 parent 334aa2e commit 9d24844

File tree

2 files changed

+38
-49
lines changed

2 files changed

+38
-49
lines changed

beacon_node/network/src/sync/block_lookups/mod.rs

Lines changed: 20 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -152,7 +152,6 @@ impl<T: BeaconChainTypes> BlockLookups<T> {
152152
if let Some(components) = child_components {
153153
lookup.add_child_components(components);
154154
}
155-
debug!(self.log, "Already searching for block"; "block_root" => ?block_root);
156155
return;
157156
}
158157

@@ -163,7 +162,7 @@ impl<T: BeaconChainTypes> BlockLookups<T> {
163162

164163
// If the block was already downloaded, or is being downloaded in this moment, do not
165164
// request it.
166-
debug!(self.log, "Already searching for block in a parent lookup request"; "block_root" => ?block_root);
165+
trace!(self.log, "Already searching for block in a parent lookup request"; "block_root" => ?block_root);
167166
return;
168167
}
169168

@@ -173,7 +172,7 @@ impl<T: BeaconChainTypes> BlockLookups<T> {
173172
.any(|(hashes, _last_parent_request)| hashes.contains(&block_root))
174173
{
175174
// we are already processing this block, ignore it.
176-
debug!(self.log, "Already processing block in a parent request"; "block_root" => ?block_root);
175+
trace!(self.log, "Already processing block in a parent request"; "block_root" => ?block_root);
177176
return;
178177
}
179178

@@ -309,12 +308,15 @@ impl<T: BeaconChainTypes> BlockLookups<T> {
309308
};
310309

311310
let expected_block_root = lookup.block_root();
312-
debug!(self.log,
313-
"Peer returned block for single lookup";
314-
"peer_id" => %peer_id ,
315-
"id" => ?id,
316-
"block_root" => ?expected_block_root,
317-
);
311+
if response.is_some() {
312+
debug!(self.log,
313+
"Peer returned response for single lookup";
314+
"peer_id" => %peer_id ,
315+
"id" => ?id,
316+
"block_root" => ?expected_block_root,
317+
"response_type" => ?response_type,
318+
);
319+
}
318320

319321
match self.single_lookup_response_inner::<R>(peer_id, response, seen_timestamp, cx, lookup)
320322
{
@@ -495,12 +497,15 @@ impl<T: BeaconChainTypes> BlockLookups<T> {
495497
return;
496498
};
497499

498-
debug!(self.log,
499-
"Peer returned block for parent lookup";
500-
"peer_id" => %peer_id ,
501-
"id" => ?id,
502-
"block_root" => ?parent_lookup.current_parent_request.block_request_state.requested_block_root,
503-
);
500+
if response.is_some() {
501+
debug!(self.log,
502+
"Peer returned response for parent lookup";
503+
"peer_id" => %peer_id ,
504+
"id" => ?id,
505+
"block_root" => ?parent_lookup.current_parent_request.block_request_state.requested_block_root,
506+
"response_type" => ?R::response_type(),
507+
);
508+
}
504509

505510
match self.parent_lookup_response_inner::<R>(
506511
peer_id,

beacon_node/network/src/sync/manager.rs

Lines changed: 18 additions & 34 deletions
Original file line numberDiff line numberDiff line change
@@ -915,44 +915,28 @@ impl<T: BeaconChainTypes> SyncManager<T> {
915915
RequestId::SingleBlock { .. } => {
916916
crit!(self.log, "Single blob received during block request"; "peer_id" => %peer_id );
917917
}
918-
RequestId::SingleBlob { id } => {
919-
if let Some(blob) = blob.as_ref() {
920-
debug!(self.log,
921-
"Peer returned blob for single lookup";
922-
"peer_id" => %peer_id ,
923-
"blob_id" =>?blob.id()
924-
);
925-
}
926-
self.block_lookups
927-
.single_lookup_response::<BlobRequestState<Current, T::EthSpec>>(
928-
id,
929-
peer_id,
930-
blob,
931-
seen_timestamp,
932-
&self.network,
933-
)
934-
}
918+
RequestId::SingleBlob { id } => self
919+
.block_lookups
920+
.single_lookup_response::<BlobRequestState<Current, T::EthSpec>>(
921+
id,
922+
peer_id,
923+
blob,
924+
seen_timestamp,
925+
&self.network,
926+
),
935927

936928
RequestId::ParentLookup { id: _ } => {
937929
crit!(self.log, "Single blob received during parent block request"; "peer_id" => %peer_id );
938930
}
939-
RequestId::ParentLookupBlob { id } => {
940-
if let Some(blob) = blob.as_ref() {
941-
debug!(self.log,
942-
"Peer returned blob for parent lookup";
943-
"peer_id" => %peer_id ,
944-
"blob_id" =>?blob.id()
945-
);
946-
}
947-
self.block_lookups
948-
.parent_lookup_response::<BlobRequestState<Parent, T::EthSpec>>(
949-
id,
950-
peer_id,
951-
blob,
952-
seen_timestamp,
953-
&self.network,
954-
)
955-
}
931+
RequestId::ParentLookupBlob { id } => self
932+
.block_lookups
933+
.parent_lookup_response::<BlobRequestState<Parent, T::EthSpec>>(
934+
id,
935+
peer_id,
936+
blob,
937+
seen_timestamp,
938+
&self.network,
939+
),
956940
RequestId::BackFillBlocks { id: _ } => {
957941
crit!(self.log, "Blob received during backfill block request"; "peer_id" => %peer_id );
958942
}

0 commit comments

Comments
 (0)