Method prune_safe

crates/batcher/encoder/src/encoder.rs:943–971

(&mut self, safe_l2_number: u64)

    }

    fn prune_safe(&mut self, safe_l2_number: u64) {
        // Count how many leading blocks are both safe (number <= safe_l2_number) and
        // already past the encoding cursor (index < block_cursor). We must not prune
        // blocks that haven't been fed into a channel yet or we'd silently skip them.
        let prune_count = self
            .blocks
            .iter()
            .take(self.block_cursor)
            .take_while(|b| b.header.number <= safe_l2_number)
            .count();

        if prune_count == 0 {
            return;
        }

        debug!(prune_count, safe_l2_number, "pruning safe blocks from input queue");

        self.blocks.drain(..prune_count);
        self.block_cursor -= prune_count;
        BatcherMetrics::pending_blocks().decrement(prune_count as f64);

        // Adjust block_range high-water marks in ready channels so that confirm()
        // does not over-prune later. This mirrors the adjustment in confirm().
        for ch in &mut self.ready_channels {
            ch.block_range.end = ch.block_range.end.saturating_sub(prune_count);
            ch.encoded_block_range.start = ch.encoded_block_range.start.saturating_sub(prune_count);
            ch.encoded_block_range.end = ch.encoded_block_range.end.saturating_sub(prune_count);
        }
    }

    fn da_backlog_bytes(&self) -> u64 {
        let pending_blocks = self