Lines Matching refs:queue
65 struct ptr_ring *queue; member
158 __cpu_map_ring_cleanup(rcpu->queue); in put_cpu_map_entry()
159 ptr_ring_cleanup(rcpu->queue, NULL); in put_cpu_map_entry()
160 kfree(rcpu->queue); in put_cpu_map_entry()
318 while (!kthread_should_stop() || !__ptr_ring_empty(rcpu->queue)) { in cpu_map_kthread_run()
328 if (__ptr_ring_empty(rcpu->queue)) { in cpu_map_kthread_run()
331 if (__ptr_ring_empty(rcpu->queue)) { in cpu_map_kthread_run()
346 n = __ptr_ring_consume_batched(rcpu->queue, frames, in cpu_map_kthread_run()
458 rcpu->queue = bpf_map_kmalloc_node(map, sizeof(*rcpu->queue), gfp, in __cpu_map_entry_alloc()
460 if (!rcpu->queue) in __cpu_map_entry_alloc()
463 err = ptr_ring_init(rcpu->queue, value->qsize, gfp); in __cpu_map_entry_alloc()
501 ptr_ring_cleanup(rcpu->queue, NULL); in __cpu_map_entry_alloc()
503 kfree(rcpu->queue); in __cpu_map_entry_alloc()
717 q = rcpu->queue; in bq_flush_to_queue()
785 ret = ptr_ring_produce(rcpu->queue, skb); in cpu_map_generic_redirect()