From f8f404c8717fb23fec922f35163937ab01962396 Mon Sep 17 00:00:00 2001
From: Mathias Hall-Andersen <mathias@hall-andersen.dk>
Date: Mon, 16 Dec 2019 16:53:23 +0100
Subject: Constant renamed to be consistent with kernel WG

---
 src/wireguard/router/device.rs | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

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

diff --git a/src/wireguard/router/device.rs b/src/wireguard/router/device.rs
index a12a657..f903a8e 100644
--- a/src/wireguard/router/device.rs
+++ b/src/wireguard/router/device.rs
@@ -12,6 +12,7 @@ use zerocopy::LayoutVerified;
 use super::anti_replay::AntiReplay;
 use super::pool::Job;
 
+use super::constants::PARALLEL_QUEUE_SIZE;
 use super::inbound;
 use super::outbound;
 
@@ -125,8 +126,8 @@ impl<E: Endpoint, C: Callbacks, T: tun::Writer, B: udp::Writer<E>> Drop
 impl<E: Endpoint, C: Callbacks, T: tun::Writer, B: udp::Writer<E>> DeviceHandle<E, C, T, B> {
     pub fn new(num_workers: usize, tun: T) -> DeviceHandle<E, C, T, B> {
         // allocate shared device state
-        let (queue_outbound, mut outrx) = ParallelQueue::new(num_workers, 128);
-        let (queue_inbound, mut inrx) = ParallelQueue::new(num_workers, 128);
+        let (queue_outbound, mut outrx) = ParallelQueue::new(num_workers, PARALLEL_QUEUE_SIZE);
+        let (queue_inbound, mut inrx) = ParallelQueue::new(num_workers, PARALLEL_QUEUE_SIZE);
         let device = Device {
             inner: Arc::new(DeviceInner {
                 inbound: tun,
-- 
cgit v1.2.3-59-g8ed1b