11 pipeline_atq_nb_event_queues(struct evt_options *opt)  in pipeline_atq_nb_event_queues()  argument
13 	RTE_SET_USED(opt);  in pipeline_atq_nb_event_queues()
252 	struct evt_options *opt = w->t->opt;  in worker_wrapper()  local
255 	const uint8_t nb_stages = opt->nb_stages;  in worker_wrapper()
256 	RTE_SET_USED(opt);  in worker_wrapper()
282 pipeline_atq_launch_lcores(struct evt_test *test, struct evt_options *opt)  in pipeline_atq_launch_lcores()  argument
284 	return pipeline_launch_lcores(test, opt, worker_wrapper);  in pipeline_atq_launch_lcores()
288 pipeline_atq_eventdev_setup(struct evt_test *test, struct evt_options *opt)  in pipeline_atq_eventdev_setup()  argument
302 	nb_ports = evt_nr_active_lcores(opt->wlcores);  in pipeline_atq_eventdev_setup()
315 	rte_event_dev_info_get(opt->dev_id, &info);  in pipeline_atq_eventdev_setup()
317 	ret = evt_configure_eventdev(opt, nb_queues, nb_ports);  in pipeline_atq_eventdev_setup()
319 		evt_err("failed to configure eventdev %d", opt->dev_id);  in pipeline_atq_eventdev_setup()
325 		.nb_atomic_flows = opt->nb_flows,  in pipeline_atq_eventdev_setup()
326 		.nb_atomic_order_sequences = opt->nb_flows,  in pipeline_atq_eventdev_setup()
344 		ret = rte_event_queue_setup(opt->dev_id, queue, &q_conf);  in pipeline_atq_eventdev_setup()
351 	if (opt->wkr_deq_dep > info.max_event_port_dequeue_depth)  in pipeline_atq_eventdev_setup()
352 		opt->wkr_deq_dep = info.max_event_port_dequeue_depth;  in pipeline_atq_eventdev_setup()
356 		.dequeue_depth = opt->wkr_deq_dep,  in pipeline_atq_eventdev_setup()
362 		ret = pipeline_event_port_setup(test, opt, queue_arr,  in pipeline_atq_eventdev_setup()
365 		ret = pipeline_event_port_setup(test, opt, NULL, nb_queues,  in pipeline_atq_eventdev_setup()
398 	ret = pipeline_event_rx_adapter_setup(opt, 1, p_conf);  in pipeline_atq_eventdev_setup()
401 	ret = pipeline_event_tx_adapter_setup(opt, p_conf);  in pipeline_atq_eventdev_setup()
405 	if (!evt_has_distributed_sched(opt->dev_id)) {  in pipeline_atq_eventdev_setup()
407 		rte_event_dev_service_id_get(opt->dev_id, &service_id);  in pipeline_atq_eventdev_setup()
425 			if (rte_event_port_link(opt->dev_id, tx_evport_id,  in pipeline_atq_eventdev_setup()
435 	ret = rte_event_dev_start(opt->dev_id);  in pipeline_atq_eventdev_setup()
437 		evt_err("failed to start eventdev %d", opt->dev_id);  in pipeline_atq_eventdev_setup()
472 pipeline_atq_opt_dump(struct evt_options *opt)  in pipeline_atq_opt_dump()  argument
474 	pipeline_opt_dump(opt, pipeline_atq_nb_event_queues(opt));  in pipeline_atq_opt_dump()
478 pipeline_atq_opt_check(struct evt_options *opt)  in pipeline_atq_opt_check()  argument
480 	return pipeline_opt_check(opt, pipeline_atq_nb_event_queues(opt));  in pipeline_atq_opt_check()
484 pipeline_atq_capability_check(struct evt_options *opt)  in pipeline_atq_capability_check()  argument
488 	rte_event_dev_info_get(opt->dev_id, &dev_info);  in pipeline_atq_capability_check()
489 	if (dev_info.max_event_queues < pipeline_atq_nb_event_queues(opt) ||  in pipeline_atq_capability_check()
491 			evt_nr_active_lcores(opt->wlcores)) {  in pipeline_atq_capability_check()
493 			pipeline_atq_nb_event_queues(opt),  in pipeline_atq_capability_check()
495 			evt_nr_active_lcores(opt->wlcores),  in pipeline_atq_capability_check()
498 	if (!evt_has_all_types_queue(opt->dev_id))  in pipeline_atq_capability_check()