shared-data 0.0.2

A library for data structures living in shared memory.
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

use crate::tests::ChildId;
#[cfg(not(test))]
use num_traits::FromPrimitive;
#[cfg(test)]
use num_traits::ToPrimitive;
use shared_data::SharedAddressRange;
#[cfg(test)]
use std::env;
#[cfg(test)]
use std::process::Child;
#[cfg(test)]
use std::process::Command;

// This code is run in the main test process
#[cfg(test)]
pub fn spawn_child(child_id: ChildId, address: SharedAddressRange) -> Child {
    // Get the name of the shared memory
    let shmem_name = shared_data::get_bootstrap_name();

    // The executable for the child process, which does nothing
    // but call back here. Assumes the layout of the target directory a bit.
    let mut exe_path = env::current_exe().unwrap();
    exe_path.pop();
    exe_path.pop();
    exe_path.push("child");

    // Convert the child_id and address to strings
    let child_name = child_id.to_usize().unwrap().to_string();
    let address_name = u64::from(address).to_string();

    // Spawn a child process
    Command::new(exe_path)
        .arg(shmem_name)
        .arg(child_name)
        .arg(address_name)
        .spawn()
        .unwrap()
}

// This code is run in the child processes
#[cfg(not(test))]
pub fn child(shmem_path: String, child_name: String, address_name: String) {
    // Bootstrap the shared memory
    shared_data::set_bootstrap_name(shmem_path.clone());

    // Double-check that the allocator has been configured
    // with the right path
    assert_eq!(shared_data::get_bootstrap_name(), shmem_path);

    // Parse the child id and address
    let child_id = ChildId::from_usize(child_name.parse().unwrap()).unwrap();
    let address_number: u64 = address_name.parse().unwrap();
    let address = SharedAddressRange::from(address_number);

    // Run the child
    child_id.run(address);
}