Struct Universe

Source

pub struct Universe { /* private fields */ }

Expand description

Global context

Implementations§

Source §

impl Universe

Source

pub fn world(&self) -> SystemCommunicator

The ‘world communicator’

Contains all processes initially partaking in the computation.

§Examples

See examples/simple.rs

Examples found in repository ?

examples/simple.rs (line 8)

6fn main() {
7    let universe = mpi::initialize().unwrap();
8    let world = universe.world();
9    println!(
10        "Hello parallel world from process {} of {}!",
11        world.rank(),
12        world.size()
13    );
14}

More examples

Hide additional examples

examples/comm_name.rs (line 10)

8fn main() {
9    let universe = mpi::initialize().unwrap();
10    let world = universe.world();
11    assert_eq!("MPI_COMM_WORLD", world.get_name());
12    world.set_name(CNAME);
13    assert_eq!(CNAME, world.get_name());
14}

examples/cartesian_map.rs (line 9)

6fn main() {
7    let universe = mpi::initialize().unwrap();
8
9    let comm = universe.world();
10
11    let new_rank = comm.cartesian_map(&[2, comm.size() / 4], &[false, false]);
12
13    println!("{} -> {:?}", comm.rank(), new_rank);
14}

examples/duplicate.rs (line 9)

7fn main() {
8    let universe = mpi::initialize().unwrap();
9    let world = universe.world();
10    let moon = world.duplicate();
11
12    world.barrier();
13    moon.barrier();
14
15    assert_eq!(CommunicatorRelation::Congruent, world.compare(&moon));
16}

examples/pack.rs (line 8)

6fn main() {
7    let universe = mpi::initialize().unwrap();
8    let world = universe.world();
9
10    let ints = [3i32, 2, 1];
11    let packed = world.pack(&ints[..]);
12
13    let mut new_ints = [0, 0, 0];
14    unsafe {
15        world.unpack_into(&packed, &mut new_ints[..], 0);
16    }
17
18    assert_eq!([3, 2, 1], new_ints);
19}

examples/time.rs (line 8)

6fn main() {
7    let universe = mpi::initialize().unwrap();
8    let world = universe.world();
9
10    let t_start = mpi::time();
11    world.barrier();
12    let t_end = mpi::time();
13
14    println!("barrier took: {} s", t_end - t_start);
15    println!(
16        "the clock has a resoltion of {} seconds",
17        mpi::time_resolution()
18    );
19}

Additional examples can be found in:

Source

pub fn buffer_size(&self) -> usize

The size in bytes of the buffer used for buffered communication.

Examples found in repository ?

examples/buffered.rs (line 14)

9fn main() {
10    let mut universe = mpi::initialize().unwrap();
11    // Try to attach a buffer.
12    universe.set_buffer_size(BUFFER_SIZE);
13    // Check buffer size matches.
14    assert_eq!(universe.buffer_size(), BUFFER_SIZE);
15    // Try to detach the buffer.
16    universe.detach_buffer();
17    // Attach another buffer.
18    universe.set_buffer_size(BUFFER_SIZE);
19
20    let world = universe.world();
21
22    let x = vec![std::f32::consts::PI; 1024];
23    let mut y = vec![0.0; 1024];
24    mpi::request::scope(|scope| {
25        let _rreq = WaitGuard::from(
26            world
27                .any_process()
28                .immediate_receive_into(scope, &mut y[..]),
29        );
30        world.this_process().buffered_send(&x[..]);
31    });
32    assert_eq!(x, y);
33}

Source

pub fn set_buffer_size(&mut self, size: usize)

Set the size in bytes of the buffer used for buffered communication.

Examples found in repository ?

examples/buffered.rs (line 12)

9fn main() {
10    let mut universe = mpi::initialize().unwrap();
11    // Try to attach a buffer.
12    universe.set_buffer_size(BUFFER_SIZE);
13    // Check buffer size matches.
14    assert_eq!(universe.buffer_size(), BUFFER_SIZE);
15    // Try to detach the buffer.
16    universe.detach_buffer();
17    // Attach another buffer.
18    universe.set_buffer_size(BUFFER_SIZE);
19
20    let world = universe.world();
21
22    let x = vec![std::f32::consts::PI; 1024];
23    let mut y = vec![0.0; 1024];
24    mpi::request::scope(|scope| {
25        let _rreq = WaitGuard::from(
26            world
27                .any_process()
28                .immediate_receive_into(scope, &mut y[..]),
29        );
30        world.this_process().buffered_send(&x[..]);
31    });
32    assert_eq!(x, y);
33}

Source

pub fn detach_buffer(&mut self)

Detach the buffer used for buffered communication.

Examples found in repository ?

examples/buffered.rs (line 16)

9fn main() {
10    let mut universe = mpi::initialize().unwrap();
11    // Try to attach a buffer.
12    universe.set_buffer_size(BUFFER_SIZE);
13    // Check buffer size matches.
14    assert_eq!(universe.buffer_size(), BUFFER_SIZE);
15    // Try to detach the buffer.
16    universe.detach_buffer();
17    // Attach another buffer.
18    universe.set_buffer_size(BUFFER_SIZE);
19
20    let world = universe.world();
21
22    let x = vec![std::f32::consts::PI; 1024];
23    let mut y = vec![0.0; 1024];
24    mpi::request::scope(|scope| {
25        let _rreq = WaitGuard::from(
26            world
27                .any_process()
28                .immediate_receive_into(scope, &mut y[..]),
29        );
30        world.this_process().buffered_send(&x[..]);
31    });
32    assert_eq!(x, y);
33}