Struct msgpass::Communicator

pub struct Communicator { /* private fields */ }

Implements the Rust communicator (wrapping the C data)

This struct holds a pointer to the C communicator, which stores the communicator (MPI_Comm), the group (MPI_Group), and the status from recv calls (MPI_Status).

Implementations

impl Communicator

pub fn new() -> Result<Self, StrError>

Allocates a new instance

pub fn new_subset(ranks: &[usize]) -> Result<Self, StrError>

Allocates a new instance using a subset of processors

pub fn abort(&mut self, error_code: i32) -> Result<(), StrError>

Terminates the MPI execution environment

pub fn barrier(&mut self) -> Result<(), StrError>

Synchronizes the MPI processes

pub fn broadcast_i32( &mut self, sender: usize, x: &mut [i32] ) -> Result<(), StrError>

Broadcasts a message from sender to all other processes in the group

pub fn broadcast_i64( &mut self, sender: usize, x: &mut [i64] ) -> Result<(), StrError>

Broadcasts a message from sender to all other processes in the group

pub fn broadcast_u32( &mut self, sender: usize, x: &mut [u32] ) -> Result<(), StrError>

Broadcasts a message from sender to all other processes in the group

pub fn broadcast_u64( &mut self, sender: usize, x: &mut [u64] ) -> Result<(), StrError>

Broadcasts a message from sender to all other processes in the group

pub fn broadcast_usize( &mut self, sender: usize, x: &mut [usize] ) -> Result<(), StrError>

Broadcasts a message from sender to all other processes in the group

pub fn broadcast_f32( &mut self, sender: usize, x: &mut [f32] ) -> Result<(), StrError>

Broadcasts a message from sender to all other processes in the group

pub fn broadcast_f64( &mut self, sender: usize, x: &mut [f64] ) -> Result<(), StrError>

Broadcasts a message from sender to all other processes in the group

pub fn reduce_i32( &mut self, root: usize, dest: &mut [i32], orig: &[i32], op: MpiOp ) -> Result<(), StrError>

Reduces values on all processes within a group

pub fn reduce_i64( &mut self, root: usize, dest: &mut [i64], orig: &[i64], op: MpiOp ) -> Result<(), StrError>

Reduces values on all processes within a group

pub fn reduce_u32( &mut self, root: usize, dest: &mut [u32], orig: &[u32], op: MpiOp ) -> Result<(), StrError>

Reduces values on all processes within a group

pub fn reduce_u64( &mut self, root: usize, dest: &mut [u64], orig: &[u64], op: MpiOp ) -> Result<(), StrError>

Reduces values on all processes within a group

pub fn reduce_usize( &mut self, root: usize, dest: &mut [usize], orig: &[usize], op: MpiOp ) -> Result<(), StrError>

Reduces values on all processes within a group

pub fn reduce_f32( &mut self, root: usize, dest: &mut [f32], orig: &[f32], op: MpiOpx ) -> Result<(), StrError>

Reduces values on all processes within a group

pub fn reduce_f64( &mut self, root: usize, dest: &mut [f64], orig: &[f64], op: MpiOpx ) -> Result<(), StrError>

Reduces values on all processes within a group

pub fn allreduce_i32( &mut self, dest: &mut [i32], orig: &[i32], op: MpiOp ) -> Result<(), StrError>

Combines values from all processes and distributes the result back to all processes

pub fn allreduce_i64( &mut self, dest: &mut [i64], orig: &[i64], op: MpiOp ) -> Result<(), StrError>

Combines values from all processes and distributes the result back to all processes

pub fn allreduce_u32( &mut self, dest: &mut [u32], orig: &[u32], op: MpiOp ) -> Result<(), StrError>

Combines values from all processes and distributes the result back to all processes

pub fn allreduce_u64( &mut self, dest: &mut [u64], orig: &[u64], op: MpiOp ) -> Result<(), StrError>

Combines values from all processes and distributes the result back to all processes

pub fn allreduce_usize( &mut self, dest: &mut [usize], orig: &[usize], op: MpiOp ) -> Result<(), StrError>

Combines values from all processes and distributes the result back to all processes

pub fn allreduce_f32( &mut self, dest: &mut [f32], orig: &[f32], op: MpiOpx ) -> Result<(), StrError>

Combines values from all processes and distributes the result back to all processes

pub fn allreduce_f64( &mut self, dest: &mut [f64], orig: &[f64], op: MpiOpx ) -> Result<(), StrError>

Combines values from all processes and distributes the result back to all processes

pub fn get_receive_status(&mut self) -> (i32, i32, i32)

Returns the status of the last receive call

pub fn send_i32( &mut self, data: &[i32], to_rank: usize, tag: i32 ) -> Result<(), StrError>

Performs a standard-mode blocking send

pub fn send_i64( &mut self, data: &[i64], to_rank: usize, tag: i32 ) -> Result<(), StrError>

Performs a standard-mode blocking send

pub fn send_u32( &mut self, data: &[u32], to_rank: usize, tag: i32 ) -> Result<(), StrError>

Performs a standard-mode blocking send

pub fn send_u64( &mut self, data: &[u64], to_rank: usize, tag: i32 ) -> Result<(), StrError>

Performs a standard-mode blocking send

pub fn send_usize( &mut self, data: &[usize], to_rank: usize, tag: i32 ) -> Result<(), StrError>

Performs a standard-mode blocking send

pub fn send_f32( &mut self, data: &[f32], to_rank: usize, tag: i32 ) -> Result<(), StrError>

Performs a standard-mode blocking send

pub fn send_f64( &mut self, data: &[f64], to_rank: usize, tag: i32 ) -> Result<(), StrError>

Performs a standard-mode blocking send

pub fn receive_i32( &mut self, data: &mut [i32], from_rank: i32, tag: i32 ) -> Result<(), StrError>

Performs a standard-mode blocking receive

data – Buffer to store the received data from_rank – Rank from where the data was sent (a negative value corresponds to MPI_ANY_SOURCE) tag – Tag of the message (a negative value corresponds to MPI_ANY_TAG)

pub fn receive_i64( &mut self, data: &mut [i64], from_rank: i32, tag: i32 ) -> Result<(), StrError>

Performs a standard-mode blocking receive

data – Buffer to store the received data from_rank – Rank from where the data was sent (a negative value corresponds to MPI_ANY_SOURCE) tag – Tag of the message (a negative value corresponds to MPI_ANY_TAG)

pub fn receive_u32( &mut self, data: &mut [u32], from_rank: i32, tag: i32 ) -> Result<(), StrError>

Performs a standard-mode blocking receive

data – Buffer to store the received data from_rank – Rank from where the data was sent (a negative value corresponds to MPI_ANY_SOURCE) tag – Tag of the message (a negative value corresponds to MPI_ANY_TAG)

pub fn receive_u64( &mut self, data: &mut [u64], from_rank: i32, tag: i32 ) -> Result<(), StrError>

Performs a standard-mode blocking receive

data – Buffer to store the received data from_rank – Rank from where the data was sent (a negative value corresponds to MPI_ANY_SOURCE) tag – Tag of the message (a negative value corresponds to MPI_ANY_TAG)

pub fn receive_usize( &mut self, data: &mut [usize], from_rank: i32, tag: i32 ) -> Result<(), StrError>

Performs a standard-mode blocking receive

data – Buffer to store the received data from_rank – Rank from where the data was sent (a negative value corresponds to MPI_ANY_SOURCE) tag – Tag of the message (a negative value corresponds to MPI_ANY_TAG)

pub fn receive_f32( &mut self, data: &mut [f32], from_rank: i32, tag: i32 ) -> Result<(), StrError>

Performs a standard-mode blocking receive

data – Buffer to store the received data from_rank – Rank from where the data was sent (a negative value corresponds to MPI_ANY_SOURCE) tag – Tag of the message (a negative value corresponds to MPI_ANY_TAG)

pub fn receive_f64( &mut self, data: &mut [f64], from_rank: i32, tag: i32 ) -> Result<(), StrError>

Performs a standard-mode blocking receive

data – Buffer to store the received data from_rank – Rank from where the data was sent (a negative value corresponds to MPI_ANY_SOURCE) tag – Tag of the message (a negative value corresponds to MPI_ANY_TAG)

Trait Implementations

impl Drop for Communicator

fn drop(&mut self)

Deallocates the C memory