diff options
| author |   Mathias Hall-Andersen <mathias@hall-andersen.dk> | 2019-11-21 11:43:16 +0100 |
|---|---|---|
| committer | Mathias Hall-Andersen <mathias@hall-andersen.dk> | 2019-11-21 11:43:16 +0100 |
| commit | 92dbb4c46a5651afb8f92375e0ed154673929eeb (patch) | |
| tree | f274dbaa58256e1fb412ae3934e02e2b19cb47f5 /src/wireguard/wireguard.rs | |
| parent | Better compartmentalization of cryptokey router (diff) | |
| download | wireguard-rs-92dbb4c46a5651afb8f92375e0ed154673929eeb.tar.xz wireguard-rs-92dbb4c46a5651afb8f92375e0ed154673929eeb.zip | |
Clean dependencies and imports
Diffstat (limited to '')
| -rw-r--r-- | src/wireguard/wireguard.rs | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/src/wireguard/wireguard.rs b/src/wireguard/wireguard.rs index 00ee053..e548c8a 100644 --- a/src/wireguard/wireguard.rs +++ b/src/wireguard/wireguard.rs @@ -368,7 +368,6 @@ impl<T: Tun, B: Bind> Wireguard<T, B> { wg.pending.fetch_sub(1, Ordering::SeqCst); let device = wg.handshake.read(); - match job { HandshakeJob::Message(msg, src) => { // feed message to handshake device @@ -418,10 +417,14 @@ impl<T: Tun, B: Bind> Wireguard<T, B> { // update endpoint peer.router.set_endpoint(src); - // update timers after sending handshake response if resp_len > 0 { + // update timers after sending handshake response debug!("{} : handshake worker, handshake response sent", wg); peer.state.sent_handshake_response(); + } else { + // update timers after receiving handshake response + debug!("{} : handshake worker, handshake response was received", wg); + peer.state.timers_handshake_complete(); } // add any new keypair to peer |