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

MAXIMUM_QUEUED_DATA_COLUMNS

Browse Source
This commit is contained in:
Eitan Seri-Levi
2026-05-22 16:29:45 +03:00
parent e775a63116
commit 4a97fd47be
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
beacon_node/beacon_processor/src/scheduler/work_reprocessing_queue.rs
View File

@@ -76,6 +76,9 @@ const MAXIMUM_QUEUED_ENVELOPES: usize = 16;
/// How many attestations we keep before new ones get dropped. /// How many attestations we keep before new ones get dropped.
const MAXIMUM_QUEUED_ATTESTATIONS: usize = 16_384; const MAXIMUM_QUEUED_ATTESTATIONS: usize = 16_384;
/// How many columns we keep before new ones get dropped.
const MAXIMUM_QUEUED_DATA_COLUMNS: usize = 256;
/// How many light client updates we keep before new ones get dropped. /// How many light client updates we keep before new ones get dropped.
const MAXIMUM_QUEUED_LIGHT_CLIENT_UPDATES: usize = 128; const MAXIMUM_QUEUED_LIGHT_CLIENT_UPDATES: usize = 128;
@@ -717,7 +720,7 @@ impl<S: SlotClock> ReprocessQueue<S> {
self.next_attestation += 1; self.next_attestation += 1;
} }
InboundEvent::Msg(UnknownBlockDataColumn(queued_data_column)) => { InboundEvent::Msg(UnknownBlockDataColumn(queued_data_column)) => {
if self.queued_gossip_data_columns.len() >= MAXIMUM_QUEUED_ATTESTATIONS { if self.queued_gossip_data_columns.len() >= MAXIMUM_QUEUED_DATA_COLUMNS {
return; return;
} }