gnosis/lighthouse
1
0
Fork 0
mirror of https://github.com/sigp/lighthouse.git synced 2026-06-10 09:37:38 +00:00
Code Issues Packages Projects Releases Wiki Activity

Clean up

Browse Source
This commit is contained in:
dapplion
2026-06-06 11:54:55 +02:00
parent 7d71c47a66
commit 7eda80b492
5 changed files with 19 additions and 94 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
beacon_node/network/src/network_beacon_processor/sync_methods.rs
View File

@@ -962,7 +962,7 @@ impl<T: BeaconChainTypes> NetworkBeaconProcessor<T> {
/// The classified outcome of submitting a block / blob / column for processing, ready for the
/// lookup state machine to act on without re-inspecting `BlockError`.
#[derive(Debug, Clone)]
#[derive(Debug)]
pub enum BlockProcessingResult {
/// `fully_imported` is true if the lookup is complete; false if `MissingComponents` (the
/// lookup must keep fetching). `info` is a stable label for logs / metrics.

82
beacon_node/network/src/sync/block_lookups/mod.rs
View File

@@ -195,9 +195,7 @@ impl<T: BeaconChainTypes> BlockLookups<T> {
Some(AwaitingParent::new(parent_root, parent_block_hash)),
// On a `UnknownParentBlock` or `UnknownParentSidecarHeader` event the peer is not
// required to have the rest of the block components. Create the lookup with zero
// peers to house the block components. We don't know the child's fork yet, so use
// `Block` conservatively; the correct peer set is established when the child's
// block downloads and its FULL children begin attesting.
// peers to house the block components.
&[],
&PeerType::Block,
cx,
@@ -230,9 +228,6 @@ impl<T: BeaconChainTypes> BlockLookups<T> {
pub fn search_parent_of_child(
&mut self,
block_root_to_search: Hash256,
// Classifies `peers` relative to the parent being searched: `GloasChild` when they imported
// the FULL child (and so can serve the parent's payload envelope and data columns), else
// `Block`.
peer_type: &PeerType,
child_block_root_trigger: Hash256,
peers: &[PeerId],
@@ -419,12 +414,9 @@ impl<T: BeaconChainTypes> BlockLookups<T> {
self.metrics.created_lookups += 1;
let result = lookup.continue_requests(cx);
if self.on_lookup_result(id, result, "new_current_lookup", cx) {
self.update_metrics();
true
} else {
false
}
self.on_lookup_result(id, result, "new_current_lookup");
self.update_metrics();
self.single_block_lookups.contains_key(&id)
}
/* Lookup responses */
@@ -441,7 +433,7 @@ impl<T: BeaconChainTypes> BlockLookups<T> {
return;
};
let result = lookup.on_block_download_response(id.req_id, response, cx);
self.on_lookup_result(id.lookup_id, result, "block_download_response", cx);
self.on_lookup_result(id.lookup_id, result, "block_download_response");
}
pub fn on_custody_download_response(
@@ -455,7 +447,7 @@ impl<T: BeaconChainTypes> BlockLookups<T> {
return;
};
let result = lookup.on_custody_download_response(id.req_id, response, cx);
self.on_lookup_result(id.lookup_id, result, "custody_download_response", cx);
self.on_lookup_result(id.lookup_id, result, "custody_download_response");
}
pub fn on_payload_download_response(
@@ -472,7 +464,7 @@ impl<T: BeaconChainTypes> BlockLookups<T> {
return;
};
let result = lookup.on_payload_download_response(id.req_id, response, cx);
self.on_lookup_result(id.lookup_id, result, "payload_download_response", cx);
self.on_lookup_result(id.lookup_id, result, "payload_download_response");
}
/* Error responses */
@@ -584,7 +576,7 @@ impl<T: BeaconChainTypes> BlockLookups<T> {
BlockProcessingResult::Error { .. } => {}
}
self.on_lookup_result(id, lookup_result, "processing_result", cx);
self.on_lookup_result(id, lookup_result, "processing_result");
}
pub fn has_any_awaiting_children(&self, block_root: Hash256) -> bool {
@@ -602,10 +594,6 @@ impl<T: BeaconChainTypes> BlockLookups<T> {
let mut lookup_results = vec![]; // < need to buffer lookup results to not re-borrow &mut self
for (id, lookup) in self.single_block_lookups.iter_mut() {
// If lookup is awaiting parent?
// - If Some
// - If parent_root lookup got block
// - Check if the child is FULL, if so keep waiting, otherwise continue and resolve
if lookup.maybe_resolve_awaiting_parent(import_action) {
debug!(
?import_action,
@@ -619,7 +607,7 @@ impl<T: BeaconChainTypes> BlockLookups<T> {
}
for (id, result) in lookup_results {
self.on_lookup_result(id, result, "continue_child_lookups", cx);
self.on_lookup_result(id, result, "continue_child_lookups");
}
}
@@ -658,52 +646,13 @@ impl<T: BeaconChainTypes> BlockLookups<T> {
id: SingleLookupId,
result: Result<(), LookupRequestError>,
source: &str,
cx: &mut SyncNetworkContext<T>,
) -> bool {
) {
match result {
Ok(_) => {
// The lookup may have become complete from already-cached components during
// `continue_requests` (e.g. the block became available via the da_checker), in
// which case no `Imported` processing result is emitted. Detect that here.
if self
.single_block_lookups
.get(&id)
.is_some_and(|lookup| lookup.is_complete())
&& let Some(lookup) = self.single_block_lookups.remove(&id)
{
let block_root = lookup.block_root();
debug!(?block_root, id, "Dropping completed lookup (cached)");
metrics::inc_counter(&metrics::SYNC_LOOKUP_COMPLETED);
self.metrics.completed_lookups += 1;
self.continue_child_lookups(ImportedAction::LookupComplete { block_root }, cx);
self.update_metrics();
}
true
}
// If UnknownLookup do not log the request error. No need to drop child lookups nor
// update metrics because the lookup does not exist.
Ok(_) => {}
Err(error) => {
// A FULL Gloas child re-awaits its parent's payload once the parent's block
// imports. A failed payload download must not cascade-drop the parent (and the
// child) — the payload may still arrive (e.g. via gossip). Retain the parent;
// genuinely stuck lookups are pruned by `drop_stuck_lookups`.
if source == "payload_download_response"
&& let Some(block_root) =
self.single_block_lookups.get(&id).map(|l| l.block_root())
&& self.has_any_awaiting_children(block_root)
{
debug!(
id,
source,
?error,
"Retaining parent with a child awaiting its payload"
);
return false;
}
debug!(id, source, ?error, "Dropping lookup on request error");
self.drop_lookup_and_children(id, error.into());
self.update_metrics();
false
}
}
}
@@ -827,12 +776,12 @@ impl<T: BeaconChainTypes> BlockLookups<T> {
lookup: &'a SingleBlockLookup<T>,
) -> Result<&'a SingleBlockLookup<T>, String> {
if let Some(awaiting_parent) = lookup.awaiting_parent() {
if let Some(parent_lookup) = self
if let Some(lookup) = self
.single_block_lookups
.values()
.find(|l| l.is_parent_of(awaiting_parent))
{
self.find_oldest_ancestor_lookup(parent_lookup)
self.find_oldest_ancestor_lookup(lookup)
} else {
Err(format!(
"Lookup references unknown parent {awaiting_parent:?}"
@@ -873,11 +822,10 @@ impl<T: BeaconChainTypes> BlockLookups<T> {
if let Some(&awaiting_parent) = lookup.awaiting_parent() {
// Regardless of gloas full/empty the lookup to add peers to is keyed by block_root
if let Some(parent_id) = self
if let Some((&parent_id, _)) = self
.single_block_lookups
.iter()
.find(|(_, l)| l.is_parent_of(&awaiting_parent))
.map(|(parent_id, _)| *parent_id)
{
self.add_peers_to_lookup_and_ancestors(
parent_id,
@@ -895,7 +843,7 @@ impl<T: BeaconChainTypes> BlockLookups<T> {
// pruned with `drop_lookups_without_peers` because it has peers. This is rare corner
// case, but it can result in stuck lookups.
let result = lookup.continue_requests(cx);
self.on_lookup_result(lookup_id, result, "add_peers", cx);
self.on_lookup_result(lookup_id, result, "add_peers");
Ok(())
} else {
Ok(())

6
beacon_node/network/src/sync/manager.rs
View File

@@ -852,8 +852,6 @@ impl<T: BeaconChainTypes> SyncManager<T> {
SyncMessage::UnknownParentBlock(peer_id, block, block_root) => {
let block_slot = block.slot();
let parent_root = block.parent_root();
// Post-Gloas: the child's bid `parent_block_hash` lets the parent lookup partition
// peers and know it's FULL.
let parent_block_hash = block.payload_bid_parent_block_hash().ok();
debug!(%block_root, %parent_root, "Received unknown parent block message");
self.handle_unknown_parent(
@@ -880,8 +878,8 @@ impl<T: BeaconChainTypes> SyncManager<T> {
peer_id,
block_root,
parent_root,
// No block downloaded yet, so the bid hash is unknown. The correct peer set is
// established once the child's block downloads.
// The event `UnknownParentSidecarHeader` only fires for pre-Gloas data
// structues, so the bid parent hash is None.
None,
slot,
BlockComponent::Sidecar,