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

Merge branch 'unstable' of https://github.com/sigp/lighthouse into gloas-data-availability-checker

Browse Source
This commit is contained in:
Eitan Seri- Levi
2026-01-29 11:35:53 -08:00
parent 6ea966846c cd8049a696
commit 1098f5d071
7 changed files with 258 additions and 112 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -81,6 +81,7 @@ use bls::{PublicKey, PublicKeyBytes, Signature};
use eth2::beacon_response::ForkVersionedResponse;
use eth2::types::{
EventKind, SseBlobSidecar, SseBlock, SseDataColumnSidecar, SseExtendedPayloadAttributes,
SseHead,
};
use execution_layer::{
BlockProposalContents, BlockProposalContentsType, BuilderParams, ChainHealth, ExecutionLayer,
@@ -3914,6 +3915,9 @@ impl<T: BeaconChainTypes> BeaconChain<T> {
}
};
// Read the cached head prior to taking the fork choice lock to avoid potential deadlocks.
let old_head_slot = self.canonical_head.cached_head().head_slot();
// Take an upgradable read lock on fork choice so we can check if this block has already
// been imported. We don't want to repeat work importing a block that is already imported.
let fork_choice_reader = self.canonical_head.fork_choice_upgradable_read_lock();
@@ -3969,6 +3973,9 @@ impl<T: BeaconChainTypes> BeaconChain<T> {
// This block became the head, add it to the early attester cache.
Ok(new_head_root) if new_head_root == block_root => {
if let Some(proto_block) = fork_choice.get_block(&block_root) {
let new_head_is_optimistic =
proto_block.execution_status.is_optimistic_or_invalid();
if let Err(e) = self.early_attester_cache.add_head_block(
block_root,
&signed_block,
@@ -3988,6 +3995,50 @@ impl<T: BeaconChainTypes> BeaconChain<T> {
attestable_timestamp,
)
}
// Register a server-sent-event for a new head.
if let Some(event_handler) = self
.event_handler
.as_ref()
.filter(|handler| handler.has_head_subscribers())
{
let head_slot = state.slot();
let state_root = block.state_root();
let is_epoch_transition = state.current_epoch()
> old_head_slot.epoch(T::EthSpec::slots_per_epoch());
let dependent_root = state.attester_shuffling_decision_root(
self.genesis_block_root,
RelativeEpoch::Next,
);
let prev_dependent_root = state.attester_shuffling_decision_root(
self.genesis_block_root,
RelativeEpoch::Current,
);
match (dependent_root, prev_dependent_root) {
(
Ok(current_duty_dependent_root),
Ok(previous_duty_dependent_root),
) => {
event_handler.register(EventKind::Head(SseHead {
slot: head_slot,
block: block_root,
state: state_root,
current_duty_dependent_root,
previous_duty_dependent_root,
epoch_transition: is_epoch_transition,
execution_optimistic: new_head_is_optimistic,
}));
}
(Err(e), _) | (_, Err(e)) => {
warn!(
error = ?e,
"Unable to find dependent roots, cannot register head event"
);
}
}
}
} else {
warn!(?block_root, "Early attester block missing");
}