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
54
55
56
57
58
59
60
61
62
63
64
65
66

#![deny(warnings)]
use mpi::traits::*;

#[derive(Debug, PartialEq)]
struct MyData1(i32);

impl CommAttribute for MyData1 {
    const CLONE_ON_DUP: bool = true;
}

// These implementations are only for logging
impl Drop for MyData1 {
    fn drop(&mut self) {
        println!("Dropping: {self:?}");
    }
}

impl Clone for MyData1 {
    fn clone(&self) -> Self {
        println!("Cloning: {self:?}");
        Self(self.0 + 1)
    }
}

#[derive(Debug, PartialEq)]
struct MyData2(i32);

impl CommAttribute for MyData2 {}

impl Drop for MyData2 {
    fn drop(&mut self) {
        println!("Dropping: {self:?}");
    }
}

impl Clone for MyData2 {
    fn clone(&self) -> Self {
        println!("Cloning: {self:?}");
        Self(self.0 + 1)
    }
}

fn with_trait_object(comm: &mut dyn Communicator) {
    comm.set_attr(MyData2(22));
    println!("Got from comm2: {:?}", comm.get_attr::<MyData2>());
}

fn main() {
    let universe = mpi::initialize().unwrap();
    println!("Universe: {:?}", universe.size());
    let mut world = universe.world();
    println!("World   : {}", world.size());
    world.set_attr(MyData1(10));
    world.set_attr(MyData2(20));
    assert_eq!(world.get_attr::<MyData1>(), Some(MyData1(10)).as_ref());
    println!("Got from world: {:?}", world.get_attr::<MyData1>());
    assert_eq!(world.get_attr::<MyData2>(), Some(MyData2(20)).as_ref());
    println!("Got from world: {:?}", world.get_attr::<MyData2>());
    let comm = world.duplicate();
    assert_eq!(comm.get_attr::<MyData1>(), Some(MyData1(11)).as_ref());
    println!("Got from comm: {:?}", comm.get_attr::<MyData1>());
    assert_eq!(comm.get_attr::<MyData2>(), None);
    println!("Got from comm: {:?}", comm.get_attr::<MyData2>());
    let mut comm2 = comm.duplicate();
    with_trait_object(&mut comm2);
}