Struct InlineBudget 

pub(super) struct InlineBudget {
    config: InlineBudgetConfig,
    activation: Option<ActivationBudget>,
}

The fuel of the activation under way, armed from the parameters by the first peek that asks for a slice of it.

Arming at the grant is what reads the parameters as late as anything can. Commands drain in full before the sweep that begins an activation, so a peek arriving on that path is granted a slice before any activation has begun, and a budget that only an activation’s start armed would hand that peek whatever the last one left. The constructor cannot arm it either: ConfigSet handles read the live value, but a value read there is read before handle_create_instance applies the controller’s snapshot, and an empty snapshot leaves the defaults in place until the first UpdateConfiguration. Since the offload’s own flag defaults off, an eagerly armed budget is an unbounded one, and it would go to every peek in a reconnecting controller’s backlog.

Fields

config: InlineBudgetConfig

activation: Option<ActivationBudget>

The fuel of the activation under way, or None while no peek has asked for a slice since the activation began.

Implementations

impl InlineBudget

pub(super) fn new(config: &ConfigSet) -> Self

A budget reading config, whose first grant arms the first activation.

pub(super) fn start_activation(&mut self)

Begins an activation, discarding what the previous one left. Nothing else refills the fuel.

pub(super) fn grant(&mut self) -> Option<usize>

The fuel one peek’s slice may spend, or None when this activation has none left to give.

A peek gets its whole per-peek budget or nothing, so the aggregate can overrun by one budget.

A caller granted None must pass the peek over. Stepping with no fuel suspends the scan without walking anything, offloading a peek that never had its inline turn.

pub(super) fn charge(&mut self, spent: usize)

Charges the activation for the positions a slice walked. An unarmed budget has nothing to charge, since a slice is only ever walked out of fuel this granted.