diff options
| author |   Mathias Hall-Andersen <mathias@hall-andersen.dk> | 2019-09-28 18:01:55 +0200 |
|---|---|---|
| committer | Mathias Hall-Andersen <mathias@hall-andersen.dk> | 2019-09-28 18:01:55 +0200 |
| commit | edfd2f235a7954c2a2b846d112a468156ceddfa6 (patch) | |
| tree | c5490b795c4776110ddf5d2374ee437152afb30d /src/router/device.rs | |
| parent | Work on peer timers (diff) | |
| download | wireguard-rs-edfd2f235a7954c2a2b846d112a468156ceddfa6.tar.xz wireguard-rs-edfd2f235a7954c2a2b846d112a468156ceddfa6.zip | |
Added key_confirmed callback
Diffstat (limited to 'src/router/device.rs')
| -rw-r--r-- | src/router/device.rs | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/src/router/device.rs b/src/router/device.rs index e8250cb..d126959 100644 --- a/src/router/device.rs +++ b/src/router/device.rs @@ -60,6 +60,8 @@ pub struct Device<C: Callbacks, T: Tun, B: Bind> { impl<C: Callbacks, T: Tun, B: Bind> Drop for Device<C, T, B> { fn drop(&mut self) { + debug!("router: dropping device"); + // drop all queues { let mut queues = self.state.queues.lock(); @@ -76,7 +78,7 @@ impl<C: Callbacks, T: Tun, B: Bind> Drop for Device<C, T, B> { _ => false, } {} - debug!("device dropped"); + debug!("router: device dropped"); } } @@ -175,7 +177,7 @@ impl<C: Callbacks, T: Tun, B: Bind> Device<C, T, B> { let peer = get_route(&self.state, packet).ok_or(RouterError::NoCryptKeyRoute)?; // schedule for encryption and transmission to peer - if let Some(job) = peer.send_job(msg) { + if let Some(job) = peer.send_job(msg, true) { debug_assert_eq!(job.1.op, Operation::Encryption); // add job to worker queue |