summaryrefslogtreecommitdiffhomepage
path: root/socket-relay/src
diff options
context:
space:
mode:
authorLinus Färnstrand <linus@mullvad.net>2017-11-08 13:55:20 +0100
committerLinus Färnstrand <linus@mullvad.net>2017-11-08 14:16:45 +0100
commit2924ae213c68ab10ed8902bb9699960374dce5fc (patch)
tree929cea24524f4b28d0c52ff24ee1deaa510e8a3f /socket-relay/src
parent7d700e2a987c4a2366707de3b0cae0c4bc0b422e (diff)
downloadmullvadvpn-2924ae213c68ab10ed8902bb9699960374dce5fc.tar.xz
mullvadvpn-2924ae213c68ab10ed8902bb9699960374dce5fc.zip
rustfmt after 0.2.15 upgrade
Diffstat (limited to 'socket-relay/src')
-rw-r--r--socket-relay/src/udp.rs32
1 files changed, 17 insertions, 15 deletions
diff --git a/socket-relay/src/udp.rs b/socket-relay/src/udp.rs
index 032b238442..c5b48ffb7c 100644
--- a/socket-relay/src/udp.rs
+++ b/socket-relay/src/udp.rs
@@ -97,21 +97,23 @@ impl Relay {
});
let recv_stream = forward_stream
- .filter_map(move |(addr, data)| if addr == destination {
- trace!(
- "Returning {} byte response from {} to {}",
- data.len(),
- addr,
- client_addr
- );
- Some((client_addr, data))
- } else {
- trace!(
- "Discarding data from {}, expecting data from {}",
- addr,
- destination
- );
- None
+ .filter_map(move |(addr, data)| {
+ if addr == destination {
+ trace!(
+ "Returning {} byte response from {} to {}",
+ data.len(),
+ addr,
+ client_addr
+ );
+ Some((client_addr, data))
+ } else {
+ trace!(
+ "Discarding data from {}, expecting data from {}",
+ addr,
+ destination
+ );
+ None
+ }
})
.map_err(|e| {
error!("Error reading datagrams from forward socket: {}", e)