Method update

nodedb-bridge/src/backpressure.rs:101–149

Update the backpressure state based on current queue utilization. Returns the new state if a transition occurred, or `None` if unchanged. The caller SHOULD emit a tracing event on transitions.

(&self, utilization_percent: u8)

    /// Returns the new state if a transition occurred, or `None` if unchanged.
    /// The caller SHOULD emit a tracing event on transitions.
    pub fn update(&self, utilization_percent: u8) -> Option<PressureState> {
        let current = PressureState::from_u8(self.state.load(Ordering::Relaxed));

        let new_state = match current {
            PressureState::Normal => {
                if utilization_percent >= self.config.suspend_enter {
                    PressureState::Suspended
                } else if utilization_percent >= self.config.throttle_enter {
                    PressureState::Throttled
                } else {
                    return None;
                }
            }
            PressureState::Throttled => {
                if utilization_percent >= self.config.suspend_enter {
                    PressureState::Suspended
                } else if utilization_percent < self.config.throttle_exit {
                    PressureState::Normal
                } else {
                    return None;
                }
            }
            PressureState::Suspended => {
                if utilization_percent < self.config.suspend_exit {
                    if utilization_percent < self.config.throttle_exit {
                        PressureState::Normal
                    } else {
                        PressureState::Throttled
                    }
                } else {
                    return None;
                }
            }
        };

        self.state.store(new_state as u8, Ordering::Release);

        match new_state {
            PressureState::Throttled => {
                self.throttle_count.fetch_add(1, Ordering::Relaxed);
            }
            PressureState::Suspended => {
                self.suspend_count.fetch_add(1, Ordering::Relaxed);
            }
            PressureState::Normal => {}
        }

        Some(new_state)
    }

    /// Current backpressure state.
    pub fn state(&self) -> PressureState {