diff options
author | Mathias Hall-Andersen <mathias@hall-andersen.dk> | 2019-08-27 11:36:33 +0200 |
---|---|---|
committer | Mathias Hall-Andersen <mathias@hall-andersen.dk> | 2019-08-27 11:36:33 +0200 |
commit | 3eb7f5e423de482da36ad77d01f4b8454990552e (patch) | |
tree | 0c6eeb5181bf70fdfcd7fbed068abbdfe115acaa | |
parent | Unbox callback closures (diff) | |
download | wireguard-rs-3eb7f5e423de482da36ad77d01f4b8454990552e.tar.xz wireguard-rs-3eb7f5e423de482da36ad77d01f4b8454990552e.zip |
Removed unused sub-module
-rw-r--r-- | src/router/buffer.rs | 84 | ||||
-rw-r--r-- | src/router/mod.rs | 6 |
2 files changed, 2 insertions, 88 deletions
diff --git a/src/router/buffer.rs b/src/router/buffer.rs deleted file mode 100644 index 96b16ab..0000000 --- a/src/router/buffer.rs +++ /dev/null @@ -1,84 +0,0 @@ -/* Ring buffer implementing the WireGuard queuing semantics: - * - * 1. A fixed sized buffer - * 2. Inserting into the buffer always succeeds, but might overwrite the oldest item - */ - -const BUFFER_SIZE: usize = 1024; - -pub struct DiscardingRingBuffer<T> { - buf: [Option<T>; BUFFER_SIZE], - idx: usize, - next: usize, -} - -impl<T> DiscardingRingBuffer<T> -where - T: Copy, -{ - pub fn new() -> Self { - DiscardingRingBuffer { - buf: [None; BUFFER_SIZE], - idx: 0, - next: 0, - } - } - - pub fn empty(&mut self) { - self.next = 0; - self.idx = 0; - for i in 1..BUFFER_SIZE { - self.buf[i] = None; - } - } - - pub fn push(&mut self, val: T) { - // assign next slot (free / oldest) - self.buf[self.idx] = Some(val); - self.idx += 1; - self.idx %= BUFFER_SIZE; - - // check for wrap-around - if self.idx == self.next { - self.next += 1; - self.next %= BUFFER_SIZE; - } - } - - pub fn consume(&mut self) -> Option<T> { - match self.buf[self.next] { - None => None, - some => { - self.buf[self.next] = None; - self.next += 1; - self.next %= BUFFER_SIZE; - some - } - } - } - - pub fn has_element(&self) -> bool { - match self.buf[self.next] { - None => true, - _ => false, - } - } -} - -#[cfg(test)] -mod tests { - use super::*; - use proptest::prelude::*; - - proptest! { - #[test] - fn test_order(elems: Vec<usize>) { - let mut buf = DiscardingRingBuffer::new(); - - for e in &elems { - buf.push(e); - } - - } - } -} diff --git a/src/router/mod.rs b/src/router/mod.rs index 644dd61..613d88c 100644 --- a/src/router/mod.rs +++ b/src/router/mod.rs @@ -1,10 +1,8 @@ mod anti_replay; -mod buffer; mod device; mod types; // mod inbound; -mod workers; mod peer; +mod workers; -pub use peer::Peer; -pub use device::Device;
\ No newline at end of file +pub use device::Device;pub use peer::Peer; |