161e9524aSPavan Nikhilesh /* 261e9524aSPavan Nikhilesh * SPDX-License-Identifier: BSD-3-Clause 361e9524aSPavan Nikhilesh * Copyright 2017 Cavium, Inc. 461e9524aSPavan Nikhilesh */ 561e9524aSPavan Nikhilesh 661e9524aSPavan Nikhilesh #ifndef _TEST_PIPELINE_COMMON_ 761e9524aSPavan Nikhilesh #define _TEST_PIPELINE_COMMON_ 861e9524aSPavan Nikhilesh 961e9524aSPavan Nikhilesh #include <stdio.h> 1061e9524aSPavan Nikhilesh #include <stdbool.h> 1161e9524aSPavan Nikhilesh #include <unistd.h> 1261e9524aSPavan Nikhilesh 1361e9524aSPavan Nikhilesh #include <rte_cycles.h> 1461e9524aSPavan Nikhilesh #include <rte_ethdev.h> 1561e9524aSPavan Nikhilesh #include <rte_eventdev.h> 1661e9524aSPavan Nikhilesh #include <rte_event_eth_rx_adapter.h> 1761e9524aSPavan Nikhilesh #include <rte_lcore.h> 1861e9524aSPavan Nikhilesh #include <rte_malloc.h> 1961e9524aSPavan Nikhilesh #include <rte_mempool.h> 2061e9524aSPavan Nikhilesh #include <rte_prefetch.h> 2161e9524aSPavan Nikhilesh #include <rte_spinlock.h> 2261e9524aSPavan Nikhilesh 2361e9524aSPavan Nikhilesh #include "evt_common.h" 2461e9524aSPavan Nikhilesh #include "evt_options.h" 2561e9524aSPavan Nikhilesh #include "evt_test.h" 2661e9524aSPavan Nikhilesh 2761e9524aSPavan Nikhilesh struct test_pipeline; 2861e9524aSPavan Nikhilesh 2961e9524aSPavan Nikhilesh struct worker_data { 3061e9524aSPavan Nikhilesh uint64_t processed_pkts; 3161e9524aSPavan Nikhilesh uint8_t dev_id; 3261e9524aSPavan Nikhilesh uint8_t port_id; 3361e9524aSPavan Nikhilesh struct test_pipeline *t; 3461e9524aSPavan Nikhilesh } __rte_cache_aligned; 3561e9524aSPavan Nikhilesh 3661e9524aSPavan Nikhilesh struct test_pipeline { 3761e9524aSPavan Nikhilesh /* Don't change the offset of "done". Signal handler use this memory 3861e9524aSPavan Nikhilesh * to terminate all lcores work. 3961e9524aSPavan Nikhilesh */ 4061e9524aSPavan Nikhilesh int done; 4161e9524aSPavan Nikhilesh uint8_t nb_workers; 4261e9524aSPavan Nikhilesh uint8_t mt_unsafe; 4361e9524aSPavan Nikhilesh enum evt_test_result result; 4461e9524aSPavan Nikhilesh uint32_t nb_flows; 4561e9524aSPavan Nikhilesh uint64_t outstand_pkts; 4661e9524aSPavan Nikhilesh struct rte_mempool *pool; 4761e9524aSPavan Nikhilesh struct worker_data worker[EVT_MAX_PORTS]; 4861e9524aSPavan Nikhilesh struct rte_eth_dev_tx_buffer *tx_buf[RTE_MAX_ETHPORTS]; 4961e9524aSPavan Nikhilesh rte_spinlock_t tx_lk[RTE_MAX_ETHPORTS]; 5061e9524aSPavan Nikhilesh struct evt_options *opt; 5161e9524aSPavan Nikhilesh uint8_t sched_type_list[EVT_MAX_STAGES] __rte_cache_aligned; 5261e9524aSPavan Nikhilesh } __rte_cache_aligned; 5361e9524aSPavan Nikhilesh 5438f842bcSPavan Nikhilesh static inline int 5538f842bcSPavan Nikhilesh pipeline_nb_event_ports(struct evt_options *opt) 5638f842bcSPavan Nikhilesh { 5738f842bcSPavan Nikhilesh return evt_nr_active_lcores(opt->wlcores); 5838f842bcSPavan Nikhilesh } 5938f842bcSPavan Nikhilesh 6038f842bcSPavan Nikhilesh int pipeline_test_result(struct evt_test *test, struct evt_options *opt); 6138f842bcSPavan Nikhilesh int pipeline_opt_check(struct evt_options *opt, uint64_t nb_queues); 6261e9524aSPavan Nikhilesh int pipeline_test_setup(struct evt_test *test, struct evt_options *opt); 63*76f98e02SPavan Nikhilesh int pipeline_ethdev_setup(struct evt_test *test, struct evt_options *opt); 64e4131b79SPavan Nikhilesh int pipeline_mempool_setup(struct evt_test *test, struct evt_options *opt); 6538f842bcSPavan Nikhilesh void pipeline_opt_dump(struct evt_options *opt, uint8_t nb_queues); 6661e9524aSPavan Nikhilesh void pipeline_test_destroy(struct evt_test *test, struct evt_options *opt); 67*76f98e02SPavan Nikhilesh void pipeline_eventdev_destroy(struct evt_test *test, struct evt_options *opt); 68*76f98e02SPavan Nikhilesh void pipeline_ethdev_destroy(struct evt_test *test, struct evt_options *opt); 69e4131b79SPavan Nikhilesh void pipeline_mempool_destroy(struct evt_test *test, struct evt_options *opt); 7061e9524aSPavan Nikhilesh 7161e9524aSPavan Nikhilesh #endif /* _TEST_PIPELINE_COMMON_ */ 72