mpi 0.8.0

Message Passing Interface bindings for Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53

#![deny(warnings)]
use std::env;
use std::process::Command;

use mpi::topology::MergeOrder;
use mpi::traits::*;

fn main() -> Result<(), mpi::MpiError> {
    let universe = mpi::initialize().unwrap();
    let world = universe.world();

    let merged = if let Some(parent) = world.parent() {
        assert_eq!("from_parent", env::args().skip(1).next().unwrap());

        parent.process_at_rank(0).send(&7i32);

        println!(
            "[{}/{}] Child universe {:?}",
            world.rank(),
            world.size(),
            universe.size()
        );
        parent.merge(MergeOrder::High)
    } else {
        let child_size = 1;
        let mut exe = Command::new(env::current_exe().unwrap());
        exe.arg("from_parent");

        let child = world.process_at_rank(0).spawn(&exe, child_size)?;

        assert_eq!(child_size, child.remote_size());

        if world.rank() == 0 {
            assert_eq!(7i32, child.process_at_rank(0).receive().0);
        }
        println!(
            "[{}/{}] Parent universe {:?} appnum {}",
            world.rank(),
            world.size(),
            universe.size(),
            universe.appnum().unwrap_or(-1),
        );
        child.merge(MergeOrder::Low)
    };
    println!(
        "[{}/{}] Merged is World {}/{}",
        merged.rank(),
        merged.size(),
        world.rank(),
        world.size()
    );
    Ok(())
}