diff options
| author | Linus Färnstrand <linus@mullvad.net> | 2017-11-08 14:30:16 +0100 |
|---|---|---|
| committer | Linus Färnstrand <linus@mullvad.net> | 2017-11-08 14:30:16 +0100 |
| commit | 2833754f1c863bf30dea4b1769078ffd9dce254a (patch) | |
| tree | 3b1e63c82e81f7cbb61b2fe055124f4cd60823ca /socket-relay/src | |
| parent | 3899bc25ace5ae802e0890d5b045b21675f93066 (diff) | |
| parent | aaeee003fcb5c27c24ecc87b2a5273e9f5d600b4 (diff) | |
| download | mullvadvpn-2833754f1c863bf30dea4b1769078ffd9dce254a.tar.xz mullvadvpn-2833754f1c863bf30dea4b1769078ffd9dce254a.zip | |
Merge branch 'censor-problem-report-logs'
Diffstat (limited to 'socket-relay/src')
| -rw-r--r-- | socket-relay/src/udp.rs | 32 |
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) |
