From 4a97fd47be16fb4b1e27814c0d5eb1fba76d2baf Mon Sep 17 00:00:00 2001 From: Eitan Seri-Levi Date: Fri, 22 May 2026 16:29:45 +0300 Subject: [PATCH] MAXIMUM_QUEUED_DATA_COLUMNS --- .../src/scheduler/work_reprocessing_queue.rs | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/beacon_node/beacon_processor/src/scheduler/work_reprocessing_queue.rs b/beacon_node/beacon_processor/src/scheduler/work_reprocessing_queue.rs index 6a61f61362..ab2acd16a1 100644 --- a/beacon_node/beacon_processor/src/scheduler/work_reprocessing_queue.rs +++ b/beacon_node/beacon_processor/src/scheduler/work_reprocessing_queue.rs @@ -76,6 +76,9 @@ const MAXIMUM_QUEUED_ENVELOPES: usize = 16; /// How many attestations we keep before new ones get dropped. 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. const MAXIMUM_QUEUED_LIGHT_CLIENT_UPDATES: usize = 128; @@ -717,7 +720,7 @@ impl ReprocessQueue { self.next_attestation += 1; } 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; }