79 	uint16_t nb_rx = 0, nb_tx = 0;  in pipeline_queue_worker_single_stage_burst_tx()  local
82 		nb_rx = rte_event_dequeue_burst(dev, port, ev, BURST_SIZE, 0);  in pipeline_queue_worker_single_stage_burst_tx()
84 		if (!nb_rx) {  in pipeline_queue_worker_single_stage_burst_tx()
89 		for (i = 0; i < nb_rx; i++) {  in pipeline_queue_worker_single_stage_burst_tx()
101 		nb_tx = pipeline_event_enqueue_burst(dev, port, ev, nb_rx, t);  in pipeline_queue_worker_single_stage_burst_tx()
103 	pipeline_worker_cleanup(dev, port, ev, nb_tx, nb_rx);  in pipeline_queue_worker_single_stage_burst_tx()
113 	uint16_t nb_rx = 0, nb_tx = 0;  in pipeline_queue_worker_single_stage_burst_fwd()  local
116 		nb_rx = rte_event_dequeue_burst(dev, port, ev, BURST_SIZE, 0);  in pipeline_queue_worker_single_stage_burst_fwd()
118 		if (!nb_rx) {  in pipeline_queue_worker_single_stage_burst_fwd()
123 		for (i = 0; i < nb_rx; i++) {  in pipeline_queue_worker_single_stage_burst_fwd()
130 		nb_tx = pipeline_event_enqueue_burst(dev, port, ev, nb_rx, t);  in pipeline_queue_worker_single_stage_burst_fwd()
131 		w->processed_pkts += nb_rx;  in pipeline_queue_worker_single_stage_burst_fwd()
133 	pipeline_worker_cleanup(dev, port, ev, nb_tx, nb_rx);  in pipeline_queue_worker_single_stage_burst_fwd()
201 	uint16_t nb_rx = 0, nb_tx = 0;  in pipeline_queue_worker_single_stage_burst_tx_vector()  local
205 		nb_rx = rte_event_dequeue_burst(dev, port, ev, BURST_SIZE, 0);  in pipeline_queue_worker_single_stage_burst_tx_vector()
207 		if (!nb_rx) {  in pipeline_queue_worker_single_stage_burst_tx_vector()
212 		for (i = 0; i < nb_rx; i++) {  in pipeline_queue_worker_single_stage_burst_tx_vector()
225 		nb_tx = pipeline_event_enqueue_burst(dev, port, ev, nb_rx, t);  in pipeline_queue_worker_single_stage_burst_tx_vector()
227 	pipeline_worker_cleanup(dev, port, ev, nb_tx, nb_rx);  in pipeline_queue_worker_single_stage_burst_tx_vector()
237 	uint16_t nb_rx = 0, nb_tx = 0;  in pipeline_queue_worker_single_stage_burst_fwd_vector()  local
241 		nb_rx = rte_event_dequeue_burst(dev, port, ev, BURST_SIZE, 0);  in pipeline_queue_worker_single_stage_burst_fwd_vector()
243 		if (!nb_rx) {  in pipeline_queue_worker_single_stage_burst_fwd_vector()
249 		for (i = 0; i < nb_rx; i++) {  in pipeline_queue_worker_single_stage_burst_fwd_vector()
257 		nb_tx = pipeline_event_enqueue_burst(dev, port, ev, nb_rx, t);  in pipeline_queue_worker_single_stage_burst_fwd_vector()
260 	pipeline_worker_cleanup(dev, port, ev, nb_tx, nb_rx);  in pipeline_queue_worker_single_stage_burst_fwd_vector()
339 	uint16_t nb_rx = 0, nb_tx = 0;  in pipeline_queue_worker_multi_stage_burst_tx()  local
342 		nb_rx = rte_event_dequeue_burst(dev, port, ev, BURST_SIZE, 0);  in pipeline_queue_worker_multi_stage_burst_tx()
344 		if (!nb_rx) {  in pipeline_queue_worker_multi_stage_burst_tx()
349 		for (i = 0; i < nb_rx; i++) {  in pipeline_queue_worker_multi_stage_burst_tx()
365 		nb_tx = pipeline_event_enqueue_burst(dev, port, ev, nb_rx, t);  in pipeline_queue_worker_multi_stage_burst_tx()
367 	pipeline_worker_cleanup(dev, port, ev, nb_tx, nb_rx);  in pipeline_queue_worker_multi_stage_burst_tx()
377 	uint16_t nb_rx = 0, nb_tx = 0;  in pipeline_queue_worker_multi_stage_burst_fwd()  local
381 		nb_rx = rte_event_dequeue_burst(dev, port, ev, BURST_SIZE, 0);  in pipeline_queue_worker_multi_stage_burst_fwd()
383 		if (!nb_rx) {  in pipeline_queue_worker_multi_stage_burst_fwd()
388 		for (i = 0; i < nb_rx; i++) {  in pipeline_queue_worker_multi_stage_burst_fwd()
405 		nb_tx = pipeline_event_enqueue_burst(dev, port, ev, nb_rx, t);  in pipeline_queue_worker_multi_stage_burst_fwd()
408 	pipeline_worker_cleanup(dev, port, ev, nb_tx, nb_rx);  in pipeline_queue_worker_multi_stage_burst_fwd()
490 	uint16_t nb_rx = 0, nb_tx = 0;  in pipeline_queue_worker_multi_stage_burst_tx_vector()  local
494 		nb_rx = rte_event_dequeue_burst(dev, port, ev, BURST_SIZE, 0);  in pipeline_queue_worker_multi_stage_burst_tx_vector()
496 		if (!nb_rx) {  in pipeline_queue_worker_multi_stage_burst_tx_vector()
501 		for (i = 0; i < nb_rx; i++) {  in pipeline_queue_worker_multi_stage_burst_tx_vector()
519 		nb_tx = pipeline_event_enqueue_burst(dev, port, ev, nb_rx, t);  in pipeline_queue_worker_multi_stage_burst_tx_vector()
521 	pipeline_worker_cleanup(dev, port, ev, nb_tx, nb_rx);  in pipeline_queue_worker_multi_stage_burst_tx_vector()
531 	uint16_t nb_rx = 0, nb_tx = 0;  in pipeline_queue_worker_multi_stage_burst_fwd_vector()  local
535 		nb_rx = rte_event_dequeue_burst(dev, port, ev, BURST_SIZE, 0);  in pipeline_queue_worker_multi_stage_burst_fwd_vector()
537 		if (!nb_rx) {  in pipeline_queue_worker_multi_stage_burst_fwd_vector()
542 		for (i = 0; i < nb_rx; i++) {  in pipeline_queue_worker_multi_stage_burst_fwd_vector()
558 		nb_tx = pipeline_event_enqueue_burst(dev, port, ev, nb_rx, t);  in pipeline_queue_worker_multi_stage_burst_fwd_vector()
560 	pipeline_worker_cleanup(dev, port, ev, nb_tx, nb_rx);  in pipeline_queue_worker_multi_stage_burst_fwd_vector()