diff options
| author |   Mathias Hall-Andersen <mathias@hall-andersen.dk> | 2019-08-22 14:59:15 +0200 |
|---|---|---|
| committer | Mathias Hall-Andersen <mathias@hall-andersen.dk> | 2019-08-22 14:59:15 +0200 |
| commit | c5aba7183dc7c893ad42d41d9cac19e782715533 (patch) | |
| tree | 4448808063f73dec33b989546dae450fe9a2588b /src/router | |
| parent | Ensure peer threads are stopped on drop (diff) | |
| download | wireguard-rs-c5aba7183dc7c893ad42d41d9cac19e782715533.tar.xz wireguard-rs-c5aba7183dc7c893ad42d41d9cac19e782715533.zip | |
Initial version of timer framework
Diffstat (limited to 'src/router')
| -rw-r--r-- | src/router/device.rs | 2 | ||||
| -rw-r--r-- | src/router/workers.rs | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/src/router/device.rs b/src/router/device.rs index d92250e..974d019 100644 --- a/src/router/device.rs +++ b/src/router/device.rs @@ -18,7 +18,7 @@ use super::super::types::KeyPair; use super::anti_replay::AntiReplay; use super::peer; use super::peer::{Peer, PeerInner}; -use super::workers; +use super::workers::worker_parallel; pub struct DeviceInner { pub stopped: AtomicBool, diff --git a/src/router/workers.rs b/src/router/workers.rs index da5b600..2f7977c 100644 --- a/src/router/workers.rs +++ b/src/router/workers.rs @@ -136,7 +136,7 @@ pub fn worker_outbound( } } -fn worker_parallel( +pub fn worker_parallel( stopped: Arc<AtomicBool>, // stop workers (device has been dropped) parked: Arc<AtomicBool>, // thread has been parked? local: Worker<JobParallel>, // local job queue (local to thread) |