11 pipeline_queue_nb_event_queues(struct evt_options *opt)  in pipeline_queue_nb_event_queues()  argument
15 	return (eth_count * opt->nb_stages) + eth_count;  in pipeline_queue_nb_event_queues()
569 	struct evt_options *opt = w->t->opt;  in worker_wrapper()  local
572 	const uint8_t nb_stages = opt->nb_stages;  in worker_wrapper()
598 		return (pipeline_queue_worker_single_stage[opt->ena_vector]  in worker_wrapper()
602 		return (pipeline_queue_worker_multi_stage[opt->ena_vector]  in worker_wrapper()
610 pipeline_queue_launch_lcores(struct evt_test *test, struct evt_options *opt)  in pipeline_queue_launch_lcores()  argument
612 	return pipeline_launch_lcores(test, opt, worker_wrapper);  in pipeline_queue_launch_lcores()
616 pipeline_queue_eventdev_setup(struct evt_test *test, struct evt_options *opt)  in pipeline_queue_eventdev_setup()  argument
621 	int nb_stages = opt->nb_stages;  in pipeline_queue_eventdev_setup()
631 	nb_ports = evt_nr_active_lcores(opt->wlcores);  in pipeline_queue_eventdev_setup()
640 	rte_event_dev_info_get(opt->dev_id, &info);  in pipeline_queue_eventdev_setup()
641 	ret = evt_configure_eventdev(opt, nb_queues, nb_ports);  in pipeline_queue_eventdev_setup()
643 		evt_err("failed to configure eventdev %d", opt->dev_id);  in pipeline_queue_eventdev_setup()
649 			.nb_atomic_flows = opt->nb_flows,  in pipeline_queue_eventdev_setup()
650 			.nb_atomic_order_sequences = opt->nb_flows,  in pipeline_queue_eventdev_setup()
666 			q_conf.schedule_type = opt->sched_type_list[slot];  in pipeline_queue_eventdev_setup()
671 		ret = rte_event_queue_setup(opt->dev_id, queue, &q_conf);  in pipeline_queue_eventdev_setup()
678 	if (opt->wkr_deq_dep > info.max_event_port_dequeue_depth)  in pipeline_queue_eventdev_setup()
679 		opt->wkr_deq_dep = info.max_event_port_dequeue_depth;  in pipeline_queue_eventdev_setup()
683 			.dequeue_depth = opt->wkr_deq_dep,  in pipeline_queue_eventdev_setup()
689 		ret = pipeline_event_port_setup(test, opt, queue_arr,  in pipeline_queue_eventdev_setup()
694 		ret = pipeline_event_port_setup(test, opt, NULL, nb_queues,  in pipeline_queue_eventdev_setup()
714 	ret = pipeline_event_rx_adapter_setup(opt, nb_stages + 1, p_conf);  in pipeline_queue_eventdev_setup()
718 	ret = pipeline_event_tx_adapter_setup(opt, p_conf);  in pipeline_queue_eventdev_setup()
722 	if (!evt_has_distributed_sched(opt->dev_id)) {  in pipeline_queue_eventdev_setup()
724 		rte_event_dev_service_id_get(opt->dev_id, &service_id);  in pipeline_queue_eventdev_setup()
743 			if (rte_event_port_link(opt->dev_id, tx_evport_id,  in pipeline_queue_eventdev_setup()
753 	ret = rte_event_dev_start(opt->dev_id);  in pipeline_queue_eventdev_setup()
755 		evt_err("failed to start eventdev %d", opt->dev_id);  in pipeline_queue_eventdev_setup()
791 pipeline_queue_opt_dump(struct evt_options *opt)  in pipeline_queue_opt_dump()  argument
793 	pipeline_opt_dump(opt, pipeline_queue_nb_event_queues(opt));  in pipeline_queue_opt_dump()
797 pipeline_queue_opt_check(struct evt_options *opt)  in pipeline_queue_opt_check()  argument
799 	return pipeline_opt_check(opt, pipeline_queue_nb_event_queues(opt));  in pipeline_queue_opt_check()
803 pipeline_queue_capability_check(struct evt_options *opt)  in pipeline_queue_capability_check()  argument
807 	rte_event_dev_info_get(opt->dev_id, &dev_info);  in pipeline_queue_capability_check()
808 	if (dev_info.max_event_queues < pipeline_queue_nb_event_queues(opt) ||  in pipeline_queue_capability_check()
810 			evt_nr_active_lcores(opt->wlcores)) {  in pipeline_queue_capability_check()
812 			pipeline_queue_nb_event_queues(opt),  in pipeline_queue_capability_check()
814 			evt_nr_active_lcores(opt->wlcores),  in pipeline_queue_capability_check()