Lines Matching refs:nb_rx

74 		uint16_t nb_rx = rte_event_dequeue_burst(dev, port, ev,  in pipeline_queue_worker_single_stage_burst_tx()  local
77 if (!nb_rx) { in pipeline_queue_worker_single_stage_burst_tx()
82 for (i = 0; i < nb_rx; i++) { in pipeline_queue_worker_single_stage_burst_tx()
95 pipeline_event_enqueue_burst(dev, port, ev, nb_rx); in pipeline_queue_worker_single_stage_burst_tx()
108 uint16_t nb_rx = rte_event_dequeue_burst(dev, port, ev, in pipeline_queue_worker_single_stage_burst_fwd() local
111 if (!nb_rx) { in pipeline_queue_worker_single_stage_burst_fwd()
116 for (i = 0; i < nb_rx; i++) { in pipeline_queue_worker_single_stage_burst_fwd()
123 pipeline_event_enqueue_burst(dev, port, ev, nb_rx); in pipeline_queue_worker_single_stage_burst_fwd()
124 w->processed_pkts += nb_rx; in pipeline_queue_worker_single_stage_burst_fwd()
202 uint16_t nb_rx = rte_event_dequeue_burst(dev, port, ev, in pipeline_queue_worker_multi_stage_burst_tx() local
205 if (!nb_rx) { in pipeline_queue_worker_multi_stage_burst_tx()
210 for (i = 0; i < nb_rx; i++) { in pipeline_queue_worker_multi_stage_burst_tx()
227 pipeline_event_enqueue_burst(dev, port, ev, nb_rx); in pipeline_queue_worker_multi_stage_burst_tx()
240 uint16_t nb_rx = rte_event_dequeue_burst(dev, port, ev, in pipeline_queue_worker_multi_stage_burst_fwd() local
243 if (!nb_rx) { in pipeline_queue_worker_multi_stage_burst_fwd()
248 for (i = 0; i < nb_rx; i++) { in pipeline_queue_worker_multi_stage_burst_fwd()
265 pipeline_event_enqueue_burst(dev, port, ev, nb_rx); in pipeline_queue_worker_multi_stage_burst_fwd()