Struct GatherProcessor 

pub struct GatherProcessor { /* private fields */ }

Pure gather processing logic: merges arrays from multiple upstream ports into a single output stream.

Multi-source subscription is achieved at the IOC wiring level: NDGatherConfigure registers the same NDArraySender with multiple upstream NDArrayOutputs, so arrays from any configured source arrive on the plugin’s single input channel.

The processor stores the configured source port names and addresses as params (GATHER_NDARRAY_PORT_1..8, GATHER_NDARRAY_ADDR_1..8) for introspection and runtime reconfiguration via PVs.

Implementations

impl GatherProcessor

pub fn new() -> Self

pub fn with_ports(ports: &[&str]) -> Self

Create a GatherProcessor pre-configured with the given source port names.

pub fn total_received(&self) -> u64

pub fn num_ports(&self) -> usize

Number of configured source ports.

pub fn source_port(&self, index: usize) -> &str

Get the configured source port name for the given index (0-based).

Trait Implementations

impl Default for GatherProcessor

fn default() -> Self

Returns the “default value” for a type.

impl NDPluginProcess for GatherProcessor

fn process_array( &mut self, array: &NDArray, _pool: &NDArrayPool, ) -> ProcessResult

Process one array. Return output arrays and param updates.

fn plugin_type(&self) -> &str

Plugin type name for PLUGIN_TYPE param.

fn register_params(&mut self, base: &mut PortDriverBase) -> AsynResult<()>

Register plugin-specific params on the base. Called once during construction.

fn on_param_change( &mut self, reason: usize, params: &PluginParamSnapshot, ) -> ParamChangeResult

Called when a param changes. Reason is the param index. Return param updates to be written back to the port driver.

fn array_data_handle( &self, ) -> Option<Arc<Mutex<RawMutex, Option<Arc<NDArray>>>>>

Return a handle to the latest NDArray data for array reads. Override this in plugins like NDPluginStdArrays that serve pixel data via readInt8Array/readInt16Array/etc.