mmap-sync

1
mod common;
2

3
use common::HelloWorld;
4
use mmap_sync::synchronizer::Synchronizer;
5
use std::time::Duration;
6

7
fn main() {
8
    // Initialize the Synchronizer
9
    let mut synchronizer = Synchronizer::new("/tmp/hello_world".as_ref());
10

11
    // Define the data
12
    let data = HelloWorld {
13
        version: 7,
14
        messages: vec!["Hello".to_string(), "World".to_string(), "!".to_string()],
15
    };
16

17
    // Write data to shared memory
18
    let (written, reset) = synchronizer
19
        .write(&data, Duration::from_secs(1))
20
        .expect("failed to write data");
21

22
    // Show how many bytes written and whether state was reset
23
    println!("written: {} bytes | reset: {}", written, reset);
24
}
25