summaryrefslogtreecommitdiffstats
path: root/src/wireguard/router/inbound.rs
diff options
context:
space:
mode:
authorMathias Hall-Andersen <mathias@hall-andersen.dk>2019-12-09 13:38:08 +0100
committerMathias Hall-Andersen <mathias@hall-andersen.dk>2019-12-09 13:38:08 +0100
commit3b376cd6fba75787b08bb9bed8413a0d40998c26 (patch)
treea951aeb5ab0d7b48396593832c48388d6df27ece /src/wireguard/router/inbound.rs
parentMerge branch 'runq' of ssh://git.zx2c4.com/wireguard-rs into runq (diff)
downloadwireguard-rs-3b376cd6fba75787b08bb9bed8413a0d40998c26.tar.xz
wireguard-rs-3b376cd6fba75787b08bb9bed8413a0d40998c26.zip
Formatting
Diffstat (limited to 'src/wireguard/router/inbound.rs')
-rw-r--r--src/wireguard/router/inbound.rs10
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");