Lines Matching defs:bq
436 struct xdp_bulk_queue *bq;
452 bq = per_cpu_ptr(rcpu->bulkq, i);
453 bq->obj = rcpu;
712 static void bq_flush_to_queue(struct xdp_bulk_queue *bq)
714 struct bpf_cpu_map_entry *rcpu = bq->obj;
720 if (unlikely(!bq->count))
726 for (i = 0; i < bq->count; i++) {
727 struct xdp_frame *xdpf = bq->q[i];
737 bq->count = 0;
740 __list_del_clearprev(&bq->flush_node);
751 struct xdp_bulk_queue *bq = this_cpu_ptr(rcpu->bulkq);
753 if (unlikely(bq->count == CPU_MAP_BULK_SIZE))
754 bq_flush_to_queue(bq);
765 bq->q[bq->count++] = xdpf;
767 if (!bq->flush_node.prev) {
770 list_add(&bq->flush_node, flush_list);
805 struct xdp_bulk_queue *bq, *tmp;
807 list_for_each_entry_safe(bq, tmp, flush_list, flush_node) {
808 bq_flush_to_queue(bq);
811 wake_up_process(bq->obj->kthread);