diff options
Diffstat (limited to 'src/wireguard/router/runq.rs')
-rw-r--r-- | src/wireguard/router/runq.rs | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/src/wireguard/router/runq.rs b/src/wireguard/router/runq.rs index 6d96490..936a53c 100644 --- a/src/wireguard/router/runq.rs +++ b/src/wireguard/router/runq.rs @@ -1,6 +1,6 @@ +use std::hash::Hash; use std::mem; use std::sync::{Condvar, Mutex}; -use std::hash::Hash; use std::collections::hash_map::Entry; use std::collections::HashMap; @@ -11,18 +11,18 @@ pub trait ToKey { fn to_key(&self) -> Self::Key; } -pub struct RunQueue<T : ToKey> { +pub struct RunQueue<T: ToKey> { cvar: Condvar, inner: Mutex<Inner<T>>, } -struct Inner<T : ToKey> { +struct Inner<T: ToKey> { stop: bool, queue: VecDeque<T>, members: HashMap<T::Key, usize>, } -impl<T : ToKey> RunQueue<T> { +impl<T: ToKey> RunQueue<T> { pub fn close(&self) { let mut inner = self.inner.lock().unwrap(); inner.stop = true; @@ -33,7 +33,7 @@ impl<T : ToKey> RunQueue<T> { RunQueue { cvar: Condvar::new(), inner: Mutex::new(Inner { - stop:false, + stop: false, queue: VecDeque::new(), members: HashMap::new(), }), @@ -111,8 +111,8 @@ impl<T : ToKey> RunQueue<T> { #[cfg(test)] mod tests { use super::*; - use std::thread; use std::sync::Arc; + use std::thread; use std::time::Duration; /* @@ -142,4 +142,4 @@ mod tests { } */ -}
\ No newline at end of file +} |