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()
275 	struct evt_options *opt = w->t->opt;  in worker_wrapper()  local
278 	const uint8_t nb_stages = opt->nb_stages;  in worker_wrapper()
279 	RTE_SET_USED(opt);  in worker_wrapper()
306 pipeline_queue_launch_lcores(struct evt_test *test, struct evt_options *opt)  in pipeline_queue_launch_lcores()  argument
308 	return pipeline_launch_lcores(test, opt, worker_wrapper);  in pipeline_queue_launch_lcores()
312 pipeline_queue_eventdev_setup(struct evt_test *test, struct evt_options *opt)  in pipeline_queue_eventdev_setup()  argument
317 	int nb_stages = opt->nb_stages;  in pipeline_queue_eventdev_setup()
327 	nb_ports = evt_nr_active_lcores(opt->wlcores);  in pipeline_queue_eventdev_setup()
336 	rte_event_dev_info_get(opt->dev_id, &info);  in pipeline_queue_eventdev_setup()
337 	ret = evt_configure_eventdev(opt, nb_queues, nb_ports);  in pipeline_queue_eventdev_setup()
339 		evt_err("failed to configure eventdev %d", opt->dev_id);  in pipeline_queue_eventdev_setup()
345 			.nb_atomic_flows = opt->nb_flows,  in pipeline_queue_eventdev_setup()
346 			.nb_atomic_order_sequences = opt->nb_flows,  in pipeline_queue_eventdev_setup()
362 			q_conf.schedule_type = opt->sched_type_list[slot];  in pipeline_queue_eventdev_setup()
367 		ret = rte_event_queue_setup(opt->dev_id, queue, &q_conf);  in pipeline_queue_eventdev_setup()
374 	if (opt->wkr_deq_dep > info.max_event_port_dequeue_depth)  in pipeline_queue_eventdev_setup()
375 		opt->wkr_deq_dep = info.max_event_port_dequeue_depth;  in pipeline_queue_eventdev_setup()
379 			.dequeue_depth = opt->wkr_deq_dep,  in pipeline_queue_eventdev_setup()
385 		ret = pipeline_event_port_setup(test, opt, queue_arr,  in pipeline_queue_eventdev_setup()
390 		ret = pipeline_event_port_setup(test, opt, NULL, nb_queues,  in pipeline_queue_eventdev_setup()
410 	ret = pipeline_event_rx_adapter_setup(opt, nb_stages + 1, p_conf);  in pipeline_queue_eventdev_setup()
414 	ret = pipeline_event_tx_adapter_setup(opt, p_conf);  in pipeline_queue_eventdev_setup()
418 	if (!evt_has_distributed_sched(opt->dev_id)) {  in pipeline_queue_eventdev_setup()
420 		rte_event_dev_service_id_get(opt->dev_id, &service_id);  in pipeline_queue_eventdev_setup()
439 			if (rte_event_port_link(opt->dev_id, tx_evport_id,  in pipeline_queue_eventdev_setup()
449 	ret = rte_event_dev_start(opt->dev_id);  in pipeline_queue_eventdev_setup()
451 		evt_err("failed to start eventdev %d", opt->dev_id);  in pipeline_queue_eventdev_setup()
487 pipeline_queue_opt_dump(struct evt_options *opt)  in pipeline_queue_opt_dump()  argument
489 	pipeline_opt_dump(opt, pipeline_queue_nb_event_queues(opt));  in pipeline_queue_opt_dump()
493 pipeline_queue_opt_check(struct evt_options *opt)  in pipeline_queue_opt_check()  argument
495 	return pipeline_opt_check(opt, pipeline_queue_nb_event_queues(opt));  in pipeline_queue_opt_check()
499 pipeline_queue_capability_check(struct evt_options *opt)  in pipeline_queue_capability_check()  argument
503 	rte_event_dev_info_get(opt->dev_id, &dev_info);  in pipeline_queue_capability_check()
504 	if (dev_info.max_event_queues < pipeline_queue_nb_event_queues(opt) ||  in pipeline_queue_capability_check()
506 			evt_nr_active_lcores(opt->wlcores)) {  in pipeline_queue_capability_check()
508 			pipeline_queue_nb_event_queues(opt),  in pipeline_queue_capability_check()
510 			evt_nr_active_lcores(opt->wlcores),  in pipeline_queue_capability_check()