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

Merge branch 'unstable' of https://github.com/sigp/lighthouse into gloas-range-sync

Browse Source
This commit is contained in:
Eitan Seri-Levi
2026-04-29 09:47:15 +02:00
parent 46c9f313e3 e8c865dcc6
commit 93293ee8e8
1 changed files with 23 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -3642,6 +3642,23 @@ impl<T: BeaconChainTypes> NetworkBeaconProcessor<T> {
self.propagate_if_timely(is_timely, message_id, peer_id)
}
/// If a payload envelope is still valid with respect to the current time (i.e., its slot
/// matches the current slot), propagate it on gossip. Otherwise, ignore it.
fn propagate_envelope_if_timely(
&self,
envelope_slot: Slot,
message_id: MessageId,
peer_id: PeerId,
) {
let is_timely = self
.chain
.slot_clock
.now()
.is_some_and(|current_slot| envelope_slot == current_slot);
self.propagate_if_timely(is_timely, message_id, peer_id)
}
/// If a sync committee signature or sync committee contribution is still valid with respect to
/// the current time (i.e., timely), propagate it on gossip. Otherwise, ignore it.
fn propagate_sync_message_if_timely(
@@ -3846,6 +3863,12 @@ impl<T: BeaconChainTypes> NetworkBeaconProcessor<T> {
let process_fn = Box::pin(async move {
match chain.verify_envelope_for_gossip(envelope).await {
Ok(verified_envelope) => {
let envelope_slot = verified_envelope.signed_envelope.slot();
inner_self.propagate_envelope_if_timely(
envelope_slot,
message_id,
peer_id,
);
inner_self
.process_gossip_verified_execution_payload_envelope(
peer_id,