Skip to main content

InputFairnessGuard

Struct InputFairnessGuard 

Source
pub struct InputFairnessGuard { /* private fields */ }
Expand description

Guard for input fairness scheduling.

Monitors event processing fairness and triggers interventions when input events are at risk of starvation due to resize processing.

Implementations§

Source§

impl InputFairnessGuard

Source

pub fn new() -> Self

Create a new fairness guard with default configuration.

Source

pub fn with_config(config: FairnessConfig) -> Self

Create a new fairness guard with the given configuration.

Source

pub fn input_arrived(&mut self, now: Instant)

Signal that an input event has arrived.

Call this when an input event is received but before processing.

Source

pub fn check_fairness(&mut self, now: Instant) -> FairnessDecision

Check fairness and return a decision.

Call this before processing a resize event to check if input is starving.

Source

pub fn event_processed( &mut self, event_type: EventType, duration: Duration, _now: Instant, )

Record that an event was processed.

Source

pub fn stats(&self) -> &FairnessStats

Get current statistics.

Source

pub fn intervention_counts(&self) -> &InterventionCounts

Get intervention counts.

Source

pub fn config(&self) -> &FairnessConfig

Get current configuration.

Source

pub fn resize_dominance_count(&self) -> u32

Current resize dominance count.

Source

pub fn is_enabled(&self) -> bool

Check if fairness is enabled.

Source

pub fn jain_index(&self) -> f64

Get current Jain’s fairness index.

Source

pub fn has_pending_input(&self) -> bool

Check if there is pending input.

Source

pub fn reset(&mut self)

Reset the guard state (useful for testing).

Trait Implementations§

Source§

impl Debug for InputFairnessGuard

Source§

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

Formats the value using the given formatter. Read more
Source§

impl Default for InputFairnessGuard

Source§

fn default() -> Self

Returns the “default value” for a type. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more