Struct InterPhaseReduction 

pub struct InterPhaseReduction<T> { /* private fields */ }

Inter-phase reduction state

Implementations

impl<T: Default + Clone + Copy> InterPhaseReduction<T>

pub fn new(input_size: usize, sync_mode: SyncMode) -> Self

Create a new inter-phase reduction

pub fn with_config(input_size: usize, config: ReductionConfig) -> Self

Create with full configuration

pub fn config(&self) -> &ReductionConfig

Get configuration

pub fn input_size(&self) -> usize

Get input size

pub fn current_phase(&self) -> u32

Get current phase

pub fn phase_start(&self, phase: u32) -> Result<(), ReductionError>

Start a phase

pub fn phase_complete(&self, phase: u32) -> Result<(), ReductionError>

Complete a phase

pub fn phase_failed(&self, phase: u32)

Mark a phase as failed

pub fn phase_state(&self, phase: u32) -> PhaseState

Get phase state

pub fn is_complete(&self) -> bool

Check if reduction is complete

pub fn get_buffer(&self, phase: u32) -> Option<&[T]>

Get buffer for a phase (for reading previous phase results)

pub fn get_buffer_mut(&mut self, phase: u32) -> Option<&mut [T]>

Get mutable buffer for a phase (for writing current phase results)

pub fn buffer_size(&self, phase: u32) -> usize

Get buffer size for a phase

pub fn set_convergence(&self, value: f64)

Set convergence value (as bits)

pub fn convergence(&self) -> f64

Get convergence value

pub fn is_converged(&self) -> bool

Check if converged (if convergence checking enabled)

pub fn reset(&mut self)

Reset for reuse