26 	while (t->done == false) {  in pipeline_queue_worker_single_stage_tx()
35 			enq = pipeline_event_tx(dev, port, &ev, t);  in pipeline_queue_worker_single_stage_tx()
41 			enq = pipeline_event_enqueue(dev, port, &ev, t);  in pipeline_queue_worker_single_stage_tx()
53 	const uint8_t *tx_queue = t->tx_evqueue_id;  in pipeline_queue_worker_single_stage_fwd()
56 	while (t->done == false) {  in pipeline_queue_worker_single_stage_fwd()
67 		enq = pipeline_event_enqueue(dev, port, &ev, t);  in pipeline_queue_worker_single_stage_fwd()
81 	while (t->done == false) {  in pipeline_queue_worker_single_stage_burst_tx()
92 				pipeline_event_tx(dev, port, &ev[i], t);  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()
112 	const uint8_t *tx_queue = t->tx_evqueue_id;  in pipeline_queue_worker_single_stage_burst_fwd()
115 	while (t->done == false) {  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()
145 	while (!t->done) {  in pipeline_queue_worker_single_stage_tx_vector()
155 			enq = pipeline_event_tx_vector(dev, port, &ev, t);  in pipeline_queue_worker_single_stage_tx_vector()
161 			enq = pipeline_event_enqueue(dev, port, &ev, t);  in pipeline_queue_worker_single_stage_tx_vector()
173 	const uint8_t *tx_queue = t->tx_evqueue_id;  in pipeline_queue_worker_single_stage_fwd_vector()
177 	while (!t->done) {  in pipeline_queue_worker_single_stage_fwd_vector()
189 		enq = pipeline_event_enqueue(dev, port, &ev, t);  in pipeline_queue_worker_single_stage_fwd_vector()
204 	while (!t->done) {  in pipeline_queue_worker_single_stage_burst_tx_vector()
215 				pipeline_event_tx_vector(dev, port, &ev[i], t);  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()
236 	const uint8_t *tx_queue = t->tx_evqueue_id;  in pipeline_queue_worker_single_stage_burst_fwd_vector()
240 	while (!t->done) {  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()
269 	const uint8_t *tx_queue = t->tx_evqueue_id;  in pipeline_queue_worker_multi_stage_tx()
272 	while (t->done == false) {  in pipeline_queue_worker_multi_stage_tx()
283 			enq = pipeline_event_tx(dev, port, &ev, t);  in pipeline_queue_worker_multi_stage_tx()
293 		enq = pipeline_event_enqueue(dev, port, &ev, t);  in pipeline_queue_worker_multi_stage_tx()
304 	const uint8_t *tx_queue = t->tx_evqueue_id;  in pipeline_queue_worker_multi_stage_fwd()
307 	while (t->done == false) {  in pipeline_queue_worker_multi_stage_fwd()
321 			enq = pipeline_event_enqueue(dev, port, &ev, t);  in pipeline_queue_worker_multi_stage_fwd()
326 			enq = pipeline_event_enqueue(dev, port, &ev, t);  in pipeline_queue_worker_multi_stage_fwd()
338 	const uint8_t *tx_queue = t->tx_evqueue_id;  in pipeline_queue_worker_multi_stage_burst_tx()
341 	while (t->done == false) {  in pipeline_queue_worker_multi_stage_burst_tx()
354 				pipeline_event_tx(dev, port, &ev[i], t);  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()
376 	const uint8_t *tx_queue = t->tx_evqueue_id;  in pipeline_queue_worker_multi_stage_burst_fwd()
379 	while (t->done == false) {  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()
417 	const uint8_t *tx_queue = t->tx_evqueue_id;  in pipeline_queue_worker_multi_stage_tx_vector()
421 	while (!t->done) {  in pipeline_queue_worker_multi_stage_tx_vector()
433 			enq = pipeline_event_tx_vector(dev, port, &ev, t);  in pipeline_queue_worker_multi_stage_tx_vector()
443 		enq = pipeline_event_enqueue(dev, port, &ev, t);  in pipeline_queue_worker_multi_stage_tx_vector()
454 	const uint8_t *tx_queue = t->tx_evqueue_id;  in pipeline_queue_worker_multi_stage_fwd_vector()
458 	while (!t->done) {  in pipeline_queue_worker_multi_stage_fwd_vector()
478 		enq = pipeline_event_enqueue(dev, port, &ev, t);  in pipeline_queue_worker_multi_stage_fwd_vector()
489 	const uint8_t *tx_queue = t->tx_evqueue_id;  in pipeline_queue_worker_multi_stage_burst_tx_vector()
493 	while (!t->done) {  in pipeline_queue_worker_multi_stage_burst_tx_vector()
506 				pipeline_event_tx_vector(dev, port, &ev[i], t);  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()
530 	const uint8_t *tx_queue = t->tx_evqueue_id;  in pipeline_queue_worker_multi_stage_burst_fwd_vector()
534 	while (!t->done) {  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()
569 	struct evt_options *opt = w->t->opt;  in worker_wrapper()
571 	const bool internal_port = w->t->internal_port;  in worker_wrapper()
629 	struct test_pipeline *t = evt_test_priv(test);  in pipeline_queue_eventdev_setup()  local
660 			if (!t->internal_port) {  in pipeline_queue_eventdev_setup()
688 	if (!t->internal_port) {  in pipeline_queue_eventdev_setup()
733 	if (!t->internal_port) {  in pipeline_queue_eventdev_setup()
784 	memcpy(t->tx_evqueue_id, tx_evqueue_id, sizeof(uint8_t) *  in pipeline_queue_eventdev_setup()