Struct InterruptManager 

pub struct InterruptManager { /* private fields */ }

Central interrupt manager coordinating interrupt observations and waiters.

Implementations

impl InterruptManager

pub fn new() -> Self

pub fn register(&mut self, resource: ResourceId)

Registers an offered interrupt resource.

pub fn is_registered(&self, resource: ResourceId) -> bool

Checks if a resource is registered.

pub fn on_interrupt( &mut self, resource: ResourceId, timestamp_ns: i64, backend: Option<&mut dyn InterruptBackend>, ) -> Result<InterruptEvent, Denial>

Triggers an interrupt event on resource.

Increments sequence and count, updates timestamp, calculates coalesced count, satisfies all eligible waiters, and invokes their callbacks (Spec 17).

pub fn wait_for_interrupt( &mut self, resource: ResourceId, after_sequence: u64, sender: Box<dyn FnOnce(InterruptEvent) + Send>, ) -> Result<Option<InterruptEvent>, Denial>

Requests an interrupt observation.

If state.sequence > after_sequence, returns Ok(Some(event)) immediately. Otherwise, registers the callback to be notified when the next event arrives.

pub fn cancel_waiters(&mut self)

Clears all pending waiters (for example during session close or PrepareStop).

pub fn waiter_count(&self, resource: ResourceId) -> usize

Number of active waiters for a given resource.

Trait Implementations

impl Debug for InterruptManager

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

Formats the value using the given formatter.

impl Default for InterruptManager

fn default() -> Self

Returns the “default value” for a type.