o3 0.1.0

shared-nothing primitives
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
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123

pub struct Rolling<const CAP: usize> {
    buf: [u8; CAP],
    head: u32,
    tail: u32,
}

impl<const CAP: usize> Default for Rolling<CAP> {
    #[inline(always)]
    fn default() -> Self {
        const {
            assert!(CAP <= u32::MAX as usize, "buffer::Rolling CAP must fit u32");
        }
        Self {
            buf: [0u8; CAP],
            head: 0,
            tail: 0,
        }
    }
}

impl<const CAP: usize> Rolling<CAP> {
    #[inline(always)]
    pub fn new() -> Self {
        Self::default()
    }

    #[inline(always)]
    pub const fn capacity(&self) -> usize {
        CAP
    }

    #[inline(always)]
    pub fn len(&self) -> usize {
        (self.tail - self.head) as usize
    }

    #[inline(always)]
    pub fn is_empty(&self) -> bool {
        self.head == self.tail
    }

    #[inline(always)]
    pub fn spare_capacity(&self) -> usize {
        CAP - self.len()
    }

    #[inline(always)]
    pub fn as_slice(&self) -> &[u8] {
        let h = self.head as usize;
        let t = self.tail as usize;
        unsafe { self.buf.get_unchecked(h..t) }
    }

    #[inline(always)]
    pub fn as_mut_slice(&mut self) -> &mut [u8] {
        let h = self.head as usize;
        let t = self.tail as usize;
        unsafe { self.buf.get_unchecked_mut(h..t) }
    }

    pub fn spare_capacity_mut(&mut self) -> &mut [u8] {
        if (CAP - self.tail as usize) < self.spare_capacity() {
            self.compact();
        }
        let t = self.tail as usize;
        unsafe { self.buf.get_unchecked_mut(t..CAP) }
    }

    #[inline]
    pub unsafe fn advance(&mut self, n: usize) {
        let new_tail = self.tail as usize + n;
        debug_assert!(new_tail <= CAP, "buffer::Rolling::advance past CAP");
        self.tail = new_tail as u32;
    }

    pub fn push(&mut self, src: &[u8]) {
        let need = src.len();
        if need == 0 {
            return;
        }
        let tail_room = CAP - self.tail as usize;
        if need > tail_room {
            self.compact();
        }
        let tail = self.tail as usize;
        let avail = CAP - tail;
        assert!(
            need <= avail,
            "buffer::Rolling push overflow: need={need} cap={CAP}"
        );
        unsafe {
            std::ptr::copy_nonoverlapping(src.as_ptr(), self.buf.as_mut_ptr().add(tail), need);
        }
        self.tail = (tail + need) as u32;
    }

    pub fn consume(&mut self, n: usize) {
        let len = self.len();
        let n = n.min(len);
        self.head += n as u32;
        if self.head == self.tail {
            self.head = 0;
            self.tail = 0;
        }
    }

    #[cold]
    fn compact(&mut self) {
        if self.head == 0 {
            return;
        }
        let h = self.head as usize;
        let t = self.tail as usize;
        let n = t - h;
        if n > 0 {
            unsafe {
                std::ptr::copy(self.buf.as_ptr().add(h), self.buf.as_mut_ptr(), n);
            }
        }
        self.head = 0;
        self.tail = n as u32;
    }
}