From db02609334482cf391dbf665559ca60654ed4398 Mon Sep 17 00:00:00 2001
From: Mathias Hall-Andersen <mathias@hall-andersen.dk>
Date: Thu, 20 Feb 2020 13:21:37 +0100
Subject: More comprehensive unit tests for router

---
 src/wireguard/router/worker.rs | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

(limited to 'src/wireguard/router/worker.rs')

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();
-- 
cgit v1.2.3-59-g8ed1b