statime-algo 0.1.1

Full-featured implementation of NTP with NTS support
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

const RINGBUFFER_SIZE: usize = 8;

#[derive(Debug, Clone, PartialEq, Default)]
pub(crate) struct UnorderedRingBuffer {
    values: [f64; RINGBUFFER_SIZE],
    n_values: usize,
    write_idx: usize,
}

impl UnorderedRingBuffer {
    pub(crate) fn insert(&mut self, value: f64) {
        self.values[self.write_idx] = value;
        self.write_idx = (self.write_idx + 1) % RINGBUFFER_SIZE;
        self.n_values = (self.n_values + 1).min(RINGBUFFER_SIZE);
    }
}

impl AsRef<[f64]> for UnorderedRingBuffer {
    fn as_ref(&self) -> &[f64] {
        &self.values[..self.n_values]
    }
}

impl AsMut<[f64]> for UnorderedRingBuffer {
    fn as_mut(&mut self) -> &mut [f64] {
        &mut self.values[..self.n_values]
    }
}