diff options
| author |   Jake McGinty <me@jake.su> | 2018-02-12 15:21:12 +0000 |
|---|---|---|
| committer | Jake McGinty <me@jake.su> | 2018-02-12 15:21:12 +0000 |
| commit | 12b5509c0474772d9a1314270ca5de2f6caf6529 (patch) | |
| tree | ba19b52b87be5f039c318d9c23dbe80c1286efb8 /src | |
| parent | handle routing to peers with unknown endpoints (diff) | |
| download | wireguard-rs-12b5509c0474772d9a1314270ca5de2f6caf6529.tar.xz wireguard-rs-12b5509c0474772d9a1314270ca5de2f6caf6529.zip | |
splfy
Diffstat (limited to 'src')
| -rw-r--r-- | src/interface/peer_server.rs | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/interface/peer_server.rs b/src/interface/peer_server.rs index 337543a..1aa4daa 100644 --- a/src/interface/peer_server.rs +++ b/src/interface/peer_server.rs @@ -253,7 +253,7 @@ impl PeerServer { let init_packet = peer.get_handshake_packet().unwrap(); let endpoint = peer.info.endpoint.unwrap().clone(); - self.handle.spawn(self.udp_tx.clone().send((endpoint, init_packet)).then(|_| Ok(()))); + self.send_to_peer((endpoint, init_packet)); info!("sent rekey"); }, TimerMessage::KeepAlive(peer_ref, _our_index) => { @@ -267,7 +267,7 @@ impl PeerServer { LittleEndian::write_u32(&mut packet[4..], their_index); LittleEndian::write_u64(&mut packet[8..], noise.sending_nonce().unwrap()); let _ = noise.write_message(&[], &mut packet[16..]).map_err(SyncFailure::new)?; - self.handle.spawn(self.udp_tx.clone().send((endpoint, packet)).then(|_| Ok(()))); + self.send_to_peer((endpoint, packet)); debug!("sent keepalive"); } } |