diff options
author | Mathias Hall-Andersen <mathias@hall-andersen.dk> | 2020-02-20 13:21:37 +0100 |
---|---|---|
committer | Mathias Hall-Andersen <mathias@hall-andersen.dk> | 2020-02-20 13:21:37 +0100 |
commit | db02609334482cf391dbf665559ca60654ed4398 (patch) | |
tree | 331adb172b17ccbf5916078ca02968ba5eab0262 /src/wireguard/router/worker.rs | |
parent | Simplified router code (diff) | |
download | wireguard-rs-db02609334482cf391dbf665559ca60654ed4398.tar.xz wireguard-rs-db02609334482cf391dbf665559ca60654ed4398.zip |
More comprehensive unit tests for router
Diffstat (limited to '')
-rw-r--r-- | src/wireguard/router/worker.rs | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/src/wireguard/router/worker.rs b/src/wireguard/router/worker.rs index bbb644c..459a198 100644 --- a/src/wireguard/router/worker.rs +++ b/src/wireguard/router/worker.rs @@ -6,6 +6,7 @@ use super::receive::ReceiveJob; use super::send::SendJob; use crossbeam_channel::Receiver; +use log; pub enum JobUnion<E: Endpoint, C: Callbacks, T: tun::Writer, B: udp::Writer<E>> { Outbound(SendJob<E, C, T, B>), @@ -16,8 +17,12 @@ pub fn worker<E: Endpoint, C: Callbacks, T: tun::Writer, B: udp::Writer<E>>( receiver: Receiver<JobUnion<E, C, T, B>>, ) { loop { + log::trace!("pool worker awaiting job"); match receiver.recv() { - Err(_) => break, + Err(e) => { + log::debug!("worker stopped with {}", e); + break; + } Ok(JobUnion::Inbound(job)) => { job.parallel_work(); job.queue().consume(); |