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

Import validated IL's into IL cache

Browse Source
This commit is contained in:
Eitan Seri-Levi
2025-01-17 16:09:21 +07:00
parent f87f83873a
commit 77551ea1b7
4 changed files with 11 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
beacon_node/beacon_chain/src/beacon_chain.rs
View File

@@ -471,7 +471,7 @@ pub struct BeaconChain<T: BeaconChainTypes> {
/// A cache used when producing attestations whilst the head block is still being imported.
pub early_attester_cache: EarlyAttesterCache<T::EthSpec>,
/// A cache used to store verified/equivocating inclusion lists.
pub inclusion_list_cache: InclusionListCache<T::EthSpec>,
pub inclusion_list_cache: RwLock<InclusionListCache<T::EthSpec>>,
/// Cache gossip verified blocks to serve over ReqResp before they are imported
pub reqresp_pre_import_cache: Arc<RwLock<ReqRespPreImportCache<T::EthSpec>>>,
/// A cache used to keep track of various block timings.
@@ -7293,6 +7293,10 @@ impl<T: BeaconChainTypes> BeaconChain<T> {
Ok(())
}
pub fn on_verified_inclusion_list(&self, signed_il: SignedInclusionList<T::EthSpec>) {
self.inclusion_list_cache.write().on_inclusion_list(signed_il);
}
pub fn metrics(&self) -> BeaconChainMetrics {
BeaconChainMetrics {
reqresp_pre_import_cache_len: self.reqresp_pre_import_cache.read().len(),

1
beacon_node/beacon_chain/src/execution_payload.rs
View File

@@ -105,6 +105,7 @@ impl<T: BeaconChainTypes> PayloadNotifier<T> {
let inclusion_list_transactions = chain
.inclusion_list_cache
.read()
.get_inclusion_list_transactions(block.slot())
.unwrap_or(vec![].into());

4
beacon_node/beacon_chain/src/inclusion_list_verification.rs
View File

@@ -29,9 +29,7 @@ impl From<BeaconChainError> for GossipInclusionListError {
}
pub struct GossipVerifiedInclusionList<T: BeaconChainTypes> {
// TODO(focil) remove once this field is read
#[allow(dead_code)]
signed_il: SignedInclusionList<T::EthSpec>,
pub signed_il: SignedInclusionList<T::EthSpec>,
}
impl<T: BeaconChainTypes> GossipVerifiedInclusionList<T> {

5
beacon_node/network/src/network_beacon_processor/gossip_methods.rs
View File

@@ -2174,8 +2174,11 @@ impl<T: BeaconChainTypes> NetworkBeaconProcessor<T> {
_seen_timestamp: Duration,
) {
match GossipVerifiedInclusionList::verify(&il, &self.chain) {
Ok(_gossip_verified_il) => {
Ok(gossip_verified_il) => {
debug!(self.log, "Successfully verified gossip inclusion list");
// Store validated inclusion list in the IL cache. This also catches
// equivocating IL's and handles them accordingly.
self.chain.on_verified_inclusion_list(gossip_verified_il.signed_il);
}
Err(err) => match err {
GossipInclusionListError::FutureSlot { .. }