diff options
| author |   Mathias Hall-Andersen <mathias@hall-andersen.dk> | 2019-12-14 13:37:51 +0100 |
|---|---|---|
| committer | Mathias Hall-Andersen <mathias@hall-andersen.dk> | 2019-12-14 13:37:51 +0100 |
| commit | e0db9861bcf7194c29888c28184785f969199c38 (patch) | |
| tree | 76c14e6ccf9bfac6880f1ce99ad1d96f06d62788 /src/wireguard/router/inbound.rs | |
| parent | Remove crossbeam dependency (diff) | |
| download | wireguard-rs-e0db9861bcf7194c29888c28184785f969199c38.tar.xz wireguard-rs-e0db9861bcf7194c29888c28184785f969199c38.zip | |
Added profiler feature
Diffstat (limited to 'src/wireguard/router/inbound.rs')
| -rw-r--r-- | src/wireguard/router/inbound.rs | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/wireguard/router/inbound.rs b/src/wireguard/router/inbound.rs index 5a27c95..db6d3f3 100644 --- a/src/wireguard/router/inbound.rs +++ b/src/wireguard/router/inbound.rs @@ -1,3 +1,4 @@ +use super::constants::MAX_INORDER_CONSUME; use super::device::DecryptionState; use super::device::Device; use super::messages::TransportHeader; @@ -185,6 +186,7 @@ pub fn sequential<E: Endpoint, C: Callbacks, T: tun::Writer, B: udp::Writer<E>>( // handle message from the peers inbound queue device.run_inbound.run(|peer| { - peer.inbound.handle(|body| work(&peer, body)); + peer.inbound + .handle(|body| work(&peer, body), MAX_INORDER_CONSUME) }); } |