diff options
author | Mathias Hall-Andersen <mathias@hall-andersen.dk> | 2019-12-09 13:38:08 +0100 |
---|---|---|
committer | Mathias Hall-Andersen <mathias@hall-andersen.dk> | 2019-12-09 13:38:08 +0100 |
commit | 3b376cd6fba75787b08bb9bed8413a0d40998c26 (patch) | |
tree | a951aeb5ab0d7b48396593832c48388d6df27ece /src/wireguard/router/inbound.rs | |
parent | Merge branch 'runq' of ssh://git.zx2c4.com/wireguard-rs into runq (diff) | |
download | wireguard-rs-3b376cd6fba75787b08bb9bed8413a0d40998c26.tar.xz wireguard-rs-3b376cd6fba75787b08bb9bed8413a0d40998c26.zip |
Formatting
Diffstat (limited to 'src/wireguard/router/inbound.rs')
-rw-r--r-- | src/wireguard/router/inbound.rs | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/wireguard/router/inbound.rs b/src/wireguard/router/inbound.rs index 9b15750..5a27c95 100644 --- a/src/wireguard/router/inbound.rs +++ b/src/wireguard/router/inbound.rs @@ -1,11 +1,11 @@ use super::device::DecryptionState; +use super::device::Device; use super::messages::TransportHeader; use super::peer::Peer; use super::pool::*; +use super::runq::RunQueue; use super::types::Callbacks; use super::{tun, udp, Endpoint}; -use super::device::Device; -use super::runq::RunQueue; use ring::aead::{Aad, LessSafeKey, Nonce, UnboundKey, CHACHA20_POLY1305}; use zerocopy::{AsBytes, LayoutVerified}; @@ -47,10 +47,10 @@ pub fn parallel<E: Endpoint, C: Callbacks, T: tun::Writer, B: udp::Writer<E>>( // run queue to schedule fn queue<E: Endpoint, C: Callbacks, T: tun::Writer, B: udp::Writer<E>>( device: &Device<E, C, T, B>, - ) -> &RunQueue<Peer<E, C, T, B>> { + ) -> &RunQueue<Peer<E, C, T, B>> { &device.run_inbound } - + // parallel work to apply fn work<E: Endpoint, C: Callbacks, T: tun::Writer, B: udp::Writer<E>>( peer: &Peer<E, C, T, B>, @@ -130,7 +130,7 @@ pub fn sequential<E: Endpoint, C: Callbacks, T: tun::Writer, B: udp::Writer<E>>( // sequential work to apply fn work<E: Endpoint, C: Callbacks, T: tun::Writer, B: udp::Writer<E>>( peer: &Peer<E, C, T, B>, - body: &mut Inbound<E, C, T, B> + body: &mut Inbound<E, C, T, B>, ) { log::trace!("worker, sequential section, obtained job"); |