diff options
Diffstat (limited to 'src/queueing.h')
| -rw-r--r-- | src/queueing.h | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/src/queueing.h b/src/queueing.h index e90744e..51d0b8e 100644 --- a/src/queueing.h +++ b/src/queueing.h @@ -120,12 +120,10 @@ static inline int queue_enqueue_per_device_and_peer(struct crypt_queue *device_q int cpu; atomic_set(&PACKET_CB(skb)->state, PACKET_STATE_UNCRYPTED); - //if (unlikely(ptr_ring_produce_bh(&peer_queue->ring, skb))) - if (unlikely(ck_ring_enqueue_mpmc(&peer_queue->ring, &peer_queue->ring_buffer, skb))) + if (unlikely(!ck_ring_enqueue_mpmc(&peer_queue->ring, skb))) return -ENOSPC; cpu = cpumask_next_online(next_cpu); - //if (unlikely(ptr_ring_produce_bh(&device_queue->ring, skb))) - if (unlikely(ck_ring_enqueue_mpmc(&device_queue->ring, &device_queue->ring_buffer, skb))) + if (unlikely(!ck_ring_enqueue_mpmc(&device_queue->ring, skb))) return -EPIPE; queue_work_on(cpu, wq, &per_cpu_ptr(device_queue->worker, cpu)->work); return 0; |