diff options
| author |   Jason A. Donenfeld <Jason@zx2c4.com> | 2017-04-05 14:45:20 +0200 |
|---|---|---|
| committer | Jason A. Donenfeld <Jason@zx2c4.com> | 2017-04-08 01:49:32 +0200 |
| commit | 0a41cbc6d58faabf2d7f28c9323821255267827a (patch) | |
| tree | f6ae23a4c82a4ab2ebd627cf4cc452a49ae4d5d5 /src/receive.c | |
| parent | data: simplify flow (diff) | |
| download | wireguard-monolithic-historical-0a41cbc6d58faabf2d7f28c9323821255267827a.tar.xz wireguard-monolithic-historical-0a41cbc6d58faabf2d7f28c9323821255267827a.zip | |
data: cleanup parallel workqueue and use two max_active
Diffstat (limited to 'src/receive.c')
| -rw-r--r-- | src/receive.c | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/receive.c b/src/receive.c index 929d723..06be5f7 100644 --- a/src/receive.c +++ b/src/receive.c @@ -179,7 +179,7 @@ void packet_process_queued_handshake_packets(struct work_struct *work) receive_handshake_packet(wg, skb); dev_kfree_skb(skb); if (++num_processed == MAX_BURST_INCOMING_HANDSHAKES) { - queue_work(wg->workqueue, &wg->incoming_handshakes_work); + queue_work(wg->handshake_wq, &wg->incoming_handshakes_work); return; } } @@ -296,7 +296,7 @@ void packet_receive(struct wireguard_device *wg, struct sk_buff *skb) } skb_queue_tail(&wg->incoming_handshakes, skb); /* Queues up a call to packet_process_queued_handshake_packets(skb): */ - queue_work(wg->workqueue, &wg->incoming_handshakes_work); + queue_work(wg->handshake_wq, &wg->incoming_handshakes_work); break; case MESSAGE_DATA: PACKET_CB(skb)->ds = ip_tunnel_get_dsfield(ip_hdr(skb), skb); |