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();