aboutsummaryrefslogtreecommitdiffstatshomepage
path: root/src/data.c
diff options
context:
space:
mode:
authorJason A. Donenfeld <Jason@zx2c4.com>2017-04-05 14:45:20 +0200
committerJason A. Donenfeld <Jason@zx2c4.com>2017-04-08 01:49:32 +0200
commit0a41cbc6d58faabf2d7f28c9323821255267827a (patch)
treef6ae23a4c82a4ab2ebd627cf4cc452a49ae4d5d5 /src/data.c
parentdata: simplify flow (diff)
downloadwireguard-monolithic-historical-0a41cbc6d58faabf2d7f28c9323821255267827a.tar.xz
wireguard-monolithic-historical-0a41cbc6d58faabf2d7f28c9323821255267827a.zip
data: cleanup parallel workqueue and use two max_active
Diffstat (limited to 'src/data.c')
-rw-r--r--src/data.c4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/data.c b/src/data.c
index d993007..f188be5 100644
--- a/src/data.c
+++ b/src/data.c
@@ -304,7 +304,7 @@ int packet_create_data(struct sk_buff_head *queue, struct wireguard_peer *peer)
if (unlikely(!ctx->peer))
goto err_parallel;
atomic_inc(&peer->parallel_encryption_inflight);
- if (unlikely(padata_do_parallel(peer->device->parallel_send, &ctx->padata, choose_cpu(keypair->remote_index)))) {
+ if (unlikely(padata_do_parallel(peer->device->encrypt_pd, &ctx->padata, choose_cpu(keypair->remote_index)))) {
atomic_dec(&peer->parallel_encryption_inflight);
peer_put(ctx->peer);
err_parallel:
@@ -397,7 +397,7 @@ void packet_consume_data(struct sk_buff *skb, struct wireguard_device *wg)
memset(&ctx->padata, 0, sizeof(ctx->padata));
ctx->padata.parallel = begin_parallel_decryption;
ctx->padata.serial = finish_parallel_decryption;
- if (unlikely(padata_do_parallel(wg->parallel_receive, &ctx->padata, choose_cpu(idx)))) {
+ if (unlikely(padata_do_parallel(wg->decrypt_pd, &ctx->padata, choose_cpu(idx)))) {
kmem_cache_free(decryption_ctx_cache, ctx);
goto err_peer;
}