mod process_mpi

module process_mpi

MPI-distributed process command.

Each MPI rank processes a subset of FASTQ files in parallel (rayon), then results are reduced to rank 0 which writes the output.

Usage: mpirun -np 4 rsx process -i reads/ -o markers.tsv -T 4 Build: cargo build --release --features mpi

Functions

fn run_mpi(params: &ProcessParams) -> Result<(), Box<dyn std::error::Error>>

Run process with MPI distribution. Falls back to single-node rayon if MPI is not initialized or size=1.

fn run_mpi(params: &ProcessParams) -> Result<(), Box<dyn std::error::Error>>

Stub for non-MPI builds.