gnosis/lighthouse
1
0
Fork 0
mirror of https://github.com/sigp/lighthouse.git synced 2026-05-07 00:42:42 +00:00
Code Issues Packages Projects Releases Wiki Activity

Optimise status processing for holesky-rescue (#7054)

Browse Source 
* Optimise status processing

* Fix lint

---------

Co-authored-by: Michael Sproul <michael@sigmaprime.io>
This commit is contained in:
Jimmy Chen
2025-02-27 21:23:40 +11:00
committed by GitHub
parent dc320e3faa
commit 9f15f31942
1 changed files with 35 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

48
beacon_node/network/src/network_beacon_processor/rpc_methods.rs
View File

@@ -17,7 +17,7 @@ use std::collections::{hash_map::Entry, HashMap};
use std::sync::Arc; use std::sync::Arc;
use tokio_stream::StreamExt; use tokio_stream::StreamExt;
use types::blob_sidecar::BlobIdentifier; use types::blob_sidecar::BlobIdentifier;
use types::{Epoch, EthSpec, FixedBytesExtended, Hash256, Slot}; use types::{Epoch, EthSpec, Hash256, Slot};
impl<T: BeaconChainTypes> NetworkBeaconProcessor<T> { impl<T: BeaconChainTypes> NetworkBeaconProcessor<T> {
/* Auxiliary functions */ /* Auxiliary functions */
@@ -93,20 +93,42 @@ impl<T: BeaconChainTypes> NetworkBeaconProcessor<T> {
// current slot. This could be because they are using a different genesis time, or that // current slot. This could be because they are using a different genesis time, or that
// their or our system's clock is incorrect. // their or our system's clock is incorrect.
Some("Different system clocks or genesis time".to_string()) Some("Different system clocks or genesis time".to_string())
} else if remote.finalized_epoch <= local.finalized_epoch } else if (remote.finalized_epoch == local.finalized_epoch
&& remote.finalized_root != Hash256::zero() && remote.finalized_root == local.finalized_root)
&& local.finalized_root != Hash256::zero() || remote.finalized_root.is_zero()
&& self || local.finalized_root.is_zero()
.chain || remote.finalized_epoch > local.finalized_epoch
.block_root_at_slot(start_slot(remote.finalized_epoch), WhenSlotSkipped::Prev)
.map(|root_opt| root_opt != Some(remote.finalized_root))?
{ {
// The remote's finalized epoch is less than or equal to ours, but the block root is // Fast path. Remote finalized checkpoint is either identical, or genesis, or we are at
// different to the one in our chain. Therefore, the node is on a different chain and we // genesis, or they are ahead. In all cases, we should allow this peer to connect to us
// should not communicate with them. // so we can sync from them.
Some("Different finalized chain".to_string())
} else {
None None
} else {
// Remote finalized epoch is less than ours.
let remote_finalized_slot = start_slot(remote.finalized_epoch);
if remote_finalized_slot < self.chain.store.get_oldest_block_slot() {
// Peer's finalized checkpoint is older than anything in our DB. We are unlikely
// to be able to help them sync.
Some("Old finality out of range".to_string())
} else if remote_finalized_slot < self.chain.store.get_split_slot() {
// Peer's finalized slot is in range for a quick block root check in our freezer DB.
// If that block root check fails, reject them as they're on a different finalized
// chain.
if self
.chain
.block_root_at_slot(remote_finalized_slot, WhenSlotSkipped::Prev)
.map(|root_opt| root_opt != Some(remote.finalized_root))?
{
Some("Different finalized chain".to_string())
} else {
None
}
} else {
// Peer's finality is older than ours, but newer than our split point, making a
// block root check infeasible. This case shouldn't happen particularly often so
// we give the peer the benefit of the doubt and let them connect to us.
None
}
}; };
Ok(irrelevant_reason) Ok(irrelevant_reason)