9 pipeline_test_result(struct evt_test *test, struct evt_options *opt)  in pipeline_test_result()  argument
11 	RTE_SET_USED(opt);  in pipeline_test_result()
29 pipeline_opt_dump(struct evt_options *opt, uint8_t nb_queues)  in pipeline_opt_dump()  argument
31 	evt_dump("nb_worker_lcores", "%d", evt_nr_active_lcores(opt->wlcores));  in pipeline_opt_dump()
32 	evt_dump_worker_lcores(opt);  in pipeline_opt_dump()
33 	evt_dump_nb_stages(opt);  in pipeline_opt_dump()
34 	evt_dump("nb_evdev_ports", "%d", pipeline_nb_event_ports(opt));  in pipeline_opt_dump()
36 	evt_dump_queue_priority(opt);  in pipeline_opt_dump()
37 	evt_dump_sched_type_list(opt);  in pipeline_opt_dump()
38 	evt_dump_producer_type(opt);  in pipeline_opt_dump()
55 pipeline_launch_lcores(struct evt_test *test, struct evt_options *opt,  in pipeline_launch_lcores()  argument
64 		if (!(opt->wlcores[lcore_id]))  in pipeline_launch_lcores()
106 pipeline_opt_check(struct evt_options *opt, uint64_t nb_queues)  in pipeline_opt_check()  argument
113 	if (opt->prod_type != EVT_PROD_TYPE_ETH_RX_ADPTR) {  in pipeline_opt_check()
115 			evt_prod_id_to_name(opt->prod_type),  in pipeline_opt_check()
131 	if (evt_lcores_has_overlap(opt->wlcores, rte_get_main_lcore())) {  in pipeline_opt_check()
135 	if (evt_has_disabled_lcore(opt->wlcores)) {  in pipeline_opt_check()
139 	if (!evt_has_active_lcore(opt->wlcores)) {  in pipeline_opt_check()
148 	if (pipeline_nb_event_ports(opt) > EVT_MAX_PORTS) {  in pipeline_opt_check()
153 	if (evt_has_invalid_stage(opt))  in pipeline_opt_check()
156 	if (evt_has_invalid_sched_type(opt))  in pipeline_opt_check()
165 pipeline_ethdev_setup(struct evt_test *test, struct evt_options *opt)  in pipeline_ethdev_setup()  argument
189 	if (opt->max_pkt_sz < RTE_ETHER_MIN_LEN) {  in pipeline_ethdev_setup()
195 	port_conf.rxmode.max_rx_pkt_len = opt->max_pkt_sz;  in pipeline_ethdev_setup()
196 	if (opt->max_pkt_sz > RTE_ETHER_MAX_LEN)  in pipeline_ethdev_setup()
205 		ret = rte_event_eth_tx_adapter_caps_get(opt->dev_id, i, &caps);  in pipeline_ethdev_setup()
272 pipeline_event_port_setup(struct evt_test *test, struct evt_options *opt,  in pipeline_event_port_setup()  argument
282 	for (port = 0; port < evt_nr_active_lcores(opt->wlcores); port++) {  in pipeline_event_port_setup()
285 		w->dev_id = opt->dev_id;  in pipeline_event_port_setup()
290 		ret = rte_event_port_setup(opt->dev_id, port, &p_conf);  in pipeline_event_port_setup()
296 		if (rte_event_port_link(opt->dev_id, port, queue_arr, NULL,  in pipeline_event_port_setup()
309 pipeline_event_rx_adapter_setup(struct evt_options *opt, uint8_t stride,  in pipeline_event_rx_adapter_setup()  argument
318 	queue_conf.ev.sched_type = opt->sched_type_list[0];  in pipeline_event_rx_adapter_setup()
322 		ret = rte_event_eth_rx_adapter_caps_get(opt->dev_id,  in pipeline_event_rx_adapter_setup()
327 					opt->dev_id);  in pipeline_event_rx_adapter_setup()
331 		ret = rte_event_eth_rx_adapter_create(prod, opt->dev_id,  in pipeline_event_rx_adapter_setup()
365 pipeline_event_tx_adapter_setup(struct evt_options *opt,  in pipeline_event_tx_adapter_setup()  argument
374 		ret = rte_event_eth_tx_adapter_caps_get(opt->dev_id,  in pipeline_event_tx_adapter_setup()
382 		ret = rte_event_eth_tx_adapter_create(consm, opt->dev_id,  in pipeline_event_tx_adapter_setup()
421 pipeline_ethdev_destroy(struct evt_test *test, struct evt_options *opt)  in pipeline_ethdev_destroy()  argument
425 	RTE_SET_USED(opt);  in pipeline_ethdev_destroy()
435 pipeline_eventdev_destroy(struct evt_test *test, struct evt_options *opt)  in pipeline_eventdev_destroy()  argument
439 	rte_event_dev_stop(opt->dev_id);  in pipeline_eventdev_destroy()
440 	rte_event_dev_close(opt->dev_id);  in pipeline_eventdev_destroy()
444 pipeline_mempool_setup(struct evt_test *test, struct evt_options *opt)  in pipeline_mempool_setup()  argument
449 	if (!opt->mbuf_sz)  in pipeline_mempool_setup()
450 		opt->mbuf_sz = RTE_MBUF_DEFAULT_BUF_SIZE;  in pipeline_mempool_setup()
452 	if (!opt->max_pkt_sz)  in pipeline_mempool_setup()
453 		opt->max_pkt_sz = RTE_ETHER_MAX_LEN;  in pipeline_mempool_setup()
469 			data_size = opt->max_pkt_sz /  in pipeline_mempool_setup()
473 			if (data_size  > opt->mbuf_sz)  in pipeline_mempool_setup()
474 				opt->mbuf_sz = data_size;  in pipeline_mempool_setup()
479 			opt->pool_sz, /* number of elements*/  in pipeline_mempool_setup()
482 			opt->mbuf_sz,  in pipeline_mempool_setup()
483 			opt->socket_id); /* flags */  in pipeline_mempool_setup()
494 pipeline_mempool_destroy(struct evt_test *test, struct evt_options *opt)  in pipeline_mempool_destroy()  argument
496 	RTE_SET_USED(opt);  in pipeline_mempool_destroy()
503 pipeline_test_setup(struct evt_test *test, struct evt_options *opt)  in pipeline_test_setup()  argument
509 			opt->socket_id);  in pipeline_test_setup()
518 	t->nb_workers = evt_nr_active_lcores(opt->wlcores);  in pipeline_test_setup()
519 	t->outstand_pkts = opt->nb_pkts * evt_nr_active_lcores(opt->wlcores);  in pipeline_test_setup()
521 	t->nb_flows = opt->nb_flows;  in pipeline_test_setup()
523 	t->opt = opt;  in pipeline_test_setup()
524 	opt->prod_type = EVT_PROD_TYPE_ETH_RX_ADPTR;  in pipeline_test_setup()
525 	memcpy(t->sched_type_list, opt->sched_type_list,  in pipeline_test_setup()
526 			sizeof(opt->sched_type_list));  in pipeline_test_setup()
533 pipeline_test_destroy(struct evt_test *test, struct evt_options *opt)  in pipeline_test_destroy()  argument
535 	RTE_SET_USED(opt);  in pipeline_test_destroy()