diff options
| author |   Jason A. Donenfeld <Jason@zx2c4.com> | 2017-10-04 05:05:51 +0200 |
|---|---|---|
| committer | Jason A. Donenfeld <Jason@zx2c4.com> | 2017-10-05 15:27:29 +0200 |
| commit | aa4d07187b66bf83bfddfa6d964f7c141518ba7b (patch) | |
| tree | dd5d948dce7251d25079bea81ae103d7a0ae9bc8 /src/device.c | |
| parent | receive: we're not planning on turning that into a while loop now (diff) | |
| download | wireguard-monolithic-historical-aa4d07187b66bf83bfddfa6d964f7c141518ba7b.tar.xz wireguard-monolithic-historical-aa4d07187b66bf83bfddfa6d964f7c141518ba7b.zip | |
queueing: use ptr_ring instead of linked lists
Diffstat (limited to 'src/device.c')
| -rw-r--r-- | src/device.c | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/device.c b/src/device.c index fdade83..5102acc 100644 --- a/src/device.c +++ b/src/device.c @@ -209,8 +209,8 @@ static void destruct(struct net_device *dev) wg->incoming_port = 0; destroy_workqueue(wg->handshake_receive_wq); destroy_workqueue(wg->handshake_send_wq); - free_percpu(wg->decrypt_queue.worker); - free_percpu(wg->encrypt_queue.worker); + packet_queue_free(&wg->decrypt_queue, true); + packet_queue_free(&wg->encrypt_queue, true); destroy_workqueue(wg->packet_crypt_wq); routing_table_free(&wg->peer_routing_table); ratelimiter_uninit(); @@ -293,10 +293,10 @@ static int newlink(struct net *src_net, struct net_device *dev, struct nlattr *t if (!wg->packet_crypt_wq) goto error_5; - if (packet_queue_init(&wg->encrypt_queue, packet_encrypt_worker, true) < 0) + if (packet_queue_init(&wg->encrypt_queue, packet_encrypt_worker, true, MAX_QUEUED_PACKETS) < 0) goto error_6; - if (packet_queue_init(&wg->decrypt_queue, packet_decrypt_worker, true) < 0) + if (packet_queue_init(&wg->decrypt_queue, packet_decrypt_worker, true, MAX_QUEUED_PACKETS) < 0) goto error_7; ret = ratelimiter_init(); @@ -319,9 +319,9 @@ static int newlink(struct net *src_net, struct net_device *dev, struct nlattr *t error_9: ratelimiter_uninit(); error_8: - free_percpu(wg->decrypt_queue.worker); + packet_queue_free(&wg->decrypt_queue, true); error_7: - free_percpu(wg->encrypt_queue.worker); + packet_queue_free(&wg->encrypt_queue, true); error_6: destroy_workqueue(wg->packet_crypt_wq); error_5: |