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/data.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/data.c')
-rw-r--r-- | src/data.c | 4 |
1 files changed, 2 insertions, 2 deletions
@@ -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; } |