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

Gossip reprocessed payload envelopes that are timely (#9210)

Browse Source 
Payloads from the reprocess queue should be gossiped after import if they are still timely. In devnets this happens frequently since there are many cases where the envelope arrives before the block


  


Co-Authored-By: Eitan Seri-Levi <eserilev@ucsc.edu>
This commit is contained in:
Eitan Seri-Levi
2026-04-28 23:50:07 +02:00
committed by GitHub
parent 6258eadc91
commit e8c865dcc6
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

@@ -3627,6 +3627,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(
@@ -3831,6 +3848,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,