oneringbuf 0.7.0

A lock-free single-producer, single-consumer (SPSC) ring buffer with in-place mutability, asynchronous support, and virtual memory optimisation.
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

use crate::common_def;
use oneringbuf::ORBIterator;

common_def!();

macro_rules! test_buf {
    ($v: tt, $prod: tt) => {
        #[cfg(not(all(feature = "vmem", unix)))]
        let b = {
            let (h, t) = $prod.get_mut_slice_avail().unwrap();
            h.iter().chain(t.iter()).map(|e| *e).collect::<Vec<usize>>()
        };

        #[cfg(all(feature = "vmem", unix))]
        let b = $prod.get_mut_slice_avail().unwrap();

        for (be, ve) in b.iter().zip($v.iter()) {
            assert_eq!(*ve, *be);
        }
    };
}

#[test]
fn test_new_buf() {
    let v: [usize; BUFFER_SIZE] = (0..BUFFER_SIZE).collect::<Vec<usize>>().try_into().unwrap();

    #[cfg(all(feature = "alloc", feature = "vmem", unix))]
    {
        use oneringbuf::{LocalVmemRB, SharedVmemRB};
        let (mut prod, _) = SharedVmemRB::from(v.clone().to_vec()).split();
        test_buf!(v, prod);

        let (mut prod, _) = LocalVmemRB::from(v.clone().to_vec()).split();
        test_buf!(v, prod);
    }

    #[cfg(all(feature = "alloc", not(all(feature = "vmem", unix))))]
    {
        use oneringbuf::{LocalHeapRB, SharedHeapRB};
        let (mut prod, _) = SharedHeapRB::from(v.clone().to_vec()).split();
        test_buf!(v, prod);

        let (mut prod, _) = LocalHeapRB::from(v.clone().to_vec()).split();
        test_buf!(v, prod);
    }

    #[cfg(all(not(feature = "alloc"), not(all(feature = "vmem", unix))))]
    {
        use oneringbuf::{LocalStackRB, SharedStackRB};

        let mut buf = SharedStackRB::from(v.clone());
        let (mut prod, _) = buf.split();
        test_buf!(v, prod);

        let mut buf = LocalStackRB::from(v.clone());
        let (mut prod, _) = buf.split();
        test_buf!(v, prod);
    }
}