bcast 0.0.29

Low latency broadcast (SPMC) buffer designed to work with shared memory.
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

use crate::common::reader;
use memmap2::MmapOptions;
use std::fs::OpenOptions;

mod common;

/// This example assumes a memory mapped file has already been created and will
/// attach a reader to it. The memory mapped file must be initialised (it's length set) by the
/// writer before it can be used.
fn main() -> anyhow::Result<()> {
    let file = OpenOptions::new().read(true).open("test.dat")?;

    // wait until file has been initialised
    loop {
        let len = file.metadata()?.len() as usize;
        if len > 0 {
            break;
        }
    }

    let mmap = unsafe { MmapOptions::new().map(&file)? };
    let bytes = mmap.as_ref();

    reader(bytes)?;

    Ok(())
}