Struct PoolArbitrationConfig 

pub struct PoolArbitrationConfig {
    pub enabled: bool,
    pub occupancy_pct: u32,
    pub encode_reserve_pct: u32,
}

Arbitration of the shared Rayon pool, protecting the encode path (SPHINX wrap + SURB generation) from decode floods (SPHINX peel — relay forwarding + exit termination).

Asymmetric and occupancy-gated: only decode is ever throttled, and only when the pool is saturated and encode work is present, so pure forwarding and unsaturated nodes are untouched. Enforced inside spawn_decode_blocking (see hopr_utils::parallelize::cpu::configure_arbitration).

Fields

enabled: bool

When false, decode is never throttled (the pool is shared first-come-first-served).

occupancy_pct: u32

Pool occupancy (percent of threads actually running) at or above which decode admission may engage. Below it, decode is never throttled.

encode_reserve_pct: u32

Share of the pool (percent) that decode yields to encode when both contend under saturation.

Implementations

impl PoolArbitrationConfig

pub fn to_arbitration(&self) -> ArbitrationConfig

Maps this flat (serde-friendly) config onto the pool arbiter’s ArbitrationConfig enum, where the disabled state carries no tuning percentages.

Trait Implementations

impl Clone for PoolArbitrationConfig

fn clone(&self) -> PoolArbitrationConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Copy for PoolArbitrationConfig

impl Debug for PoolArbitrationConfig

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

Formats the value using the given formatter.

impl Default for PoolArbitrationConfig

fn default() -> Self

Return PoolArbitrationConfig { enabled: default_arbitration_enabled(), occupancy_pct: default_arbitration_occupancy_pct(), encode_reserve_pct: default_arbitration_encode_reserve_pct() }

impl Eq for PoolArbitrationConfig

impl PartialEq for PoolArbitrationConfig

fn eq(&self, other: &PoolArbitrationConfig) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for PoolArbitrationConfig

impl Validate for PoolArbitrationConfig

fn validate(&self) -> Result<(), ValidationErrors>

impl<'v_a> ValidateArgs<'v_a> for PoolArbitrationConfig

type Args = ()

fn validate_with_args(&self, args: Self::Args) -> Result<(), ValidationErrors>