diff options
| author |   Mathias Hall-Andersen <mathias@hall-andersen.dk> | 2020-02-12 21:38:25 +0100 |
|---|---|---|
| committer | Mathias Hall-Andersen <mathias@hall-andersen.dk> | 2020-02-12 21:38:25 +0100 |
| commit | 5e6edb280e588397c3420d08cf46a52b34b58740 (patch) | |
| tree | dee5854adb5adce3549e53d96b48f0ef16886f04 /src/wireguard/workers.rs | |
| parent | Squashed commit of the following: (diff) | |
| download | wireguard-rs-5e6edb280e588397c3420d08cf46a52b34b58740.tar.xz wireguard-rs-5e6edb280e588397c3420d08cf46a52b34b58740.zip | |
Bumped crate versions.
Diffstat (limited to '')
| -rw-r--r-- | src/wireguard/workers.rs | 17 |
1 files changed, 4 insertions, 13 deletions
diff --git a/src/wireguard/workers.rs b/src/wireguard/workers.rs index c1a2af7..02db160 100644 --- a/src/wireguard/workers.rs +++ b/src/wireguard/workers.rs @@ -14,7 +14,6 @@ use super::tun::Reader as TunReader; use super::tun::Tun; use super::udp::Reader as UDPReader; -use super::udp::Writer as UDPWriter; use super::udp::UDP; // constants @@ -195,20 +194,12 @@ pub fn handshake_worker<T: Tun, B: UDP>( let mut resp_len: u64 = 0; if let Some(msg) = resp { resp_len = msg.len() as u64; - let send: &Option<B::Writer> = &*wg.send.read(); - if let Some(writer) = send.as_ref() { + let _ = wg.router.write(&msg[..], &mut src).map_err(|e| { debug!( - "{} : handshake worker, send response ({} bytes)", - wg, resp_len + "{} : handshake worker, failed to send response, error = {}", + wg, e ); - let _ = writer.write(&msg[..], &mut src).map_err(|e| { - debug!( - "{} : handshake worker, failed to send response, error = {}", - wg, - e - ) - }); - } + }); } // update peer state |