Struct FreezeState 

pub struct FreezeState { /* private fields */ }

State for managing process freezing.

Uses an epoch counter to prevent race conditions where a freeze is scheduled but work arrives before it executes. The epoch is incremented on unfreeze, and freeze operations check the epoch matches before proceeding.

Supports freezing multiple PIDs (runtime + extensions) to accurately simulate Lambda’s behaviour where the entire execution environment is frozen. PIDs can be registered dynamically after creation using register_pid().

Implementations

impl FreezeState

pub fn new(mode: FreezeMode, pid: Option<u32>) -> Self

Creates a new freeze state with a single PID (for backwards compatibility).

pub fn with_pids(mode: FreezeMode, pids: Vec<u32>) -> Self

Creates a new freeze state with multiple PIDs.

Use this to freeze the runtime and all extension processes together, which accurately simulates Lambda’s freeze behaviour.

pub fn mode(&self) -> FreezeMode

Returns the current freeze mode.

pub fn pid_count(&self) -> usize

Returns the number of registered PIDs.

pub fn pid(&self) -> Option<i32>

Returns the first configured PID, if any (for backwards compatibility).

pub fn register_pid(&self, pid: u32)

Registers a PID to be frozen/unfrozen with the execution environment.

Call this after spawning runtime or extension processes to include them in freeze/thaw operations.

pub fn is_frozen(&self) -> bool

Returns whether the processes are currently frozen.

pub fn current_epoch(&self) -> u64

Returns the current freeze epoch.

pub async fn wait_for_state_change(&self)

Waits for the freeze state to change.

pub fn freeze_at_epoch(&self, _epoch: u64) -> Result<bool, FreezeError>

pub fn unfreeze(&self) -> Result<(), FreezeError>

pub fn force_unfreeze(&self)

Trait Implementations

impl Debug for FreezeState

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for FreezeState

fn default() -> Self

Returns the “default value” for a type.