1 /* SPDX-License-Identifier: BSD-3-Clause
2 * Copyright(c) 2017 Intel Corporation
5 #include <rte_common.h>
6 #include <rte_mempool.h>
8 #include <rte_ethdev.h>
9 #include <rte_eventdev.h>
10 #include <rte_bus_vdev.h>
12 #include <rte_event_eth_rx_adapter.h>
16 #define MAX_NUM_RX_QUEUE 64
17 #define NB_MBUFS (8192 * num_ports * MAX_NUM_RX_QUEUE)
18 #define MBUF_CACHE_SIZE 512
19 #define MBUF_PRIV_SIZE 0
20 #define TEST_INST_ID 0
22 #define TEST_ETHDEV_ID 0
24 struct event_eth_rx_adapter_test_params {
25 struct rte_mempool *mp;
26 uint16_t rx_rings, tx_rings;
30 static struct event_eth_rx_adapter_test_params default_params;
33 port_init(uint8_t port, struct rte_mempool *mp)
35 static const struct rte_eth_conf port_conf_default = {
37 .mq_mode = ETH_MQ_RX_RSS,
38 .max_rx_pkt_len = ETHER_MAX_LEN
42 .rss_hf = ETH_RSS_IP |
48 const uint16_t rx_ring_size = 512, tx_ring_size = 512;
49 struct rte_eth_conf port_conf = port_conf_default;
52 struct rte_eth_dev_info dev_info;
54 if (!rte_eth_dev_is_valid_port(port))
57 retval = rte_eth_dev_configure(port, 0, 0, &port_conf);
59 rte_eth_dev_info_get(port, &dev_info);
61 default_params.rx_rings = RTE_MIN(dev_info.max_rx_queues,
63 default_params.tx_rings = 1;
65 /* Configure the Ethernet device. */
66 retval = rte_eth_dev_configure(port, default_params.rx_rings,
67 default_params.tx_rings, &port_conf);
71 for (q = 0; q < default_params.rx_rings; q++) {
72 retval = rte_eth_rx_queue_setup(port, q, rx_ring_size,
73 rte_eth_dev_socket_id(port), NULL, mp);
78 /* Allocate and set up 1 TX queue per Ethernet port. */
79 for (q = 0; q < default_params.tx_rings; q++) {
80 retval = rte_eth_tx_queue_setup(port, q, tx_ring_size,
81 rte_eth_dev_socket_id(port), NULL);
86 /* Start the Ethernet port. */
87 retval = rte_eth_dev_start(port);
91 /* Display the port MAC address. */
92 struct ether_addr addr;
93 rte_eth_macaddr_get(port, &addr);
94 printf("Port %u MAC: %02" PRIx8 " %02" PRIx8 " %02" PRIx8
95 " %02" PRIx8 " %02" PRIx8 " %02" PRIx8 "\n",
97 addr.addr_bytes[0], addr.addr_bytes[1],
98 addr.addr_bytes[2], addr.addr_bytes[3],
99 addr.addr_bytes[4], addr.addr_bytes[5]);
101 /* Enable RX in promiscuous mode for the Ethernet device. */
102 rte_eth_promiscuous_enable(port);
108 init_ports(int num_ports)
113 default_params.mp = rte_pktmbuf_pool_create("packet_pool",
117 RTE_MBUF_DEFAULT_BUF_SIZE,
119 if (!default_params.mp)
122 RTE_ETH_FOREACH_DEV(portid) {
123 retval = port_init(portid, default_params.mp);
132 testsuite_setup(void)
136 struct rte_event_dev_info dev_info;
138 count = rte_event_dev_count();
140 printf("Failed to find a valid event device,"
141 " testing with event_skeleton device\n");
142 rte_vdev_init("event_skeleton", NULL);
145 struct rte_event_dev_config config = {
146 .nb_event_queues = 1,
150 err = rte_event_dev_info_get(TEST_DEV_ID, &dev_info);
151 config.nb_event_queue_flows = dev_info.max_event_queue_flows;
152 config.nb_event_port_dequeue_depth =
153 dev_info.max_event_port_dequeue_depth;
154 config.nb_event_port_enqueue_depth =
155 dev_info.max_event_port_enqueue_depth;
156 config.nb_events_limit =
157 dev_info.max_num_events;
158 err = rte_event_dev_configure(TEST_DEV_ID, &config);
159 TEST_ASSERT(err == 0, "Event device initialization failed err %d\n",
163 * eth devices like octeontx use event device to receive packets
164 * so rte_eth_dev_start invokes rte_event_dev_start internally, so
165 * call init_ports after rte_event_dev_configure
167 err = init_ports(rte_eth_dev_count_total());
168 TEST_ASSERT(err == 0, "Port initialization failed err %d\n", err);
170 err = rte_event_eth_rx_adapter_caps_get(TEST_DEV_ID, TEST_ETHDEV_ID,
171 &default_params.caps);
172 TEST_ASSERT(err == 0, "Failed to get adapter cap err %d\n",
179 testsuite_teardown(void)
182 RTE_ETH_FOREACH_DEV(i)
185 rte_mempool_free(default_params.mp);
192 struct rte_event_dev_info dev_info;
193 struct rte_event_port_conf rx_p_conf;
195 err = rte_event_dev_info_get(TEST_DEV_ID, &dev_info);
196 TEST_ASSERT(err == 0, "Expected 0 got %d", err);
198 rx_p_conf.new_event_threshold = dev_info.max_num_events;
199 rx_p_conf.dequeue_depth = dev_info.max_event_port_dequeue_depth;
200 rx_p_conf.enqueue_depth = dev_info.max_event_port_enqueue_depth;
201 err = rte_event_eth_rx_adapter_create(TEST_INST_ID, TEST_DEV_ID,
203 TEST_ASSERT(err == 0, "Expected 0 got %d", err);
211 rte_event_eth_rx_adapter_free(TEST_INST_ID);
215 adapter_create_free(void)
219 struct rte_event_port_conf rx_p_conf = {
222 .new_event_threshold = 1200,
225 err = rte_event_eth_rx_adapter_create(TEST_INST_ID, TEST_DEV_ID,
227 TEST_ASSERT(err == -EINVAL, "Expected -EINVAL got %d", err);
229 err = rte_event_eth_rx_adapter_create(TEST_INST_ID, TEST_DEV_ID,
231 TEST_ASSERT(err == 0, "Expected 0 got %d", err);
233 err = rte_event_eth_rx_adapter_create(TEST_INST_ID,
234 TEST_DEV_ID, &rx_p_conf);
235 TEST_ASSERT(err == -EEXIST, "Expected -EEXIST %d got %d", -EEXIST, err);
237 err = rte_event_eth_rx_adapter_free(TEST_INST_ID);
238 TEST_ASSERT(err == 0, "Expected 0 got %d", err);
240 err = rte_event_eth_rx_adapter_free(TEST_INST_ID);
241 TEST_ASSERT(err == -EINVAL, "Expected -EINVAL %d got %d", -EINVAL, err);
243 err = rte_event_eth_rx_adapter_free(1);
244 TEST_ASSERT(err == -EINVAL, "Expected -EINVAL %d got %d", -EINVAL, err);
250 adapter_queue_add_del(void)
256 struct rte_event_eth_rx_adapter_queue_conf queue_config;
258 err = rte_event_eth_rx_adapter_caps_get(TEST_DEV_ID, TEST_ETHDEV_ID,
260 TEST_ASSERT(err == 0, "Expected 0 got %d", err);
263 ev.sched_type = RTE_SCHED_TYPE_ATOMIC;
266 queue_config.rx_queue_flags = 0;
267 if (cap & RTE_EVENT_ETH_RX_ADAPTER_CAP_OVERRIDE_FLOW_ID) {
269 queue_config.rx_queue_flags =
270 RTE_EVENT_ETH_RX_ADAPTER_QUEUE_FLOW_ID_VALID;
272 queue_config.ev = ev;
273 queue_config.servicing_weight = 1;
275 err = rte_event_eth_rx_adapter_queue_add(TEST_INST_ID,
276 rte_eth_dev_count_total(),
278 TEST_ASSERT(err == -EINVAL, "Expected -EINVAL got %d", err);
280 if (cap & RTE_EVENT_ETH_RX_ADAPTER_CAP_MULTI_EVENTQ) {
281 err = rte_event_eth_rx_adapter_queue_add(TEST_INST_ID,
284 TEST_ASSERT(err == 0, "Expected 0 got %d", err);
286 err = rte_event_eth_rx_adapter_queue_del(TEST_INST_ID,
288 TEST_ASSERT(err == 0, "Expected 0 got %d", err);
290 err = rte_event_eth_rx_adapter_queue_add(TEST_INST_ID,
294 TEST_ASSERT(err == 0, "Expected 0 got %d", err);
296 err = rte_event_eth_rx_adapter_queue_del(TEST_INST_ID,
299 TEST_ASSERT(err == 0, "Expected 0 got %d", err);
301 err = rte_event_eth_rx_adapter_queue_add(TEST_INST_ID,
305 TEST_ASSERT(err == -EINVAL, "Expected EINVAL got %d", err);
307 err = rte_event_eth_rx_adapter_queue_add(TEST_INST_ID,
310 TEST_ASSERT(err == 0, "Expected 0 got %d", err);
312 err = rte_event_eth_rx_adapter_queue_del(TEST_INST_ID,
314 TEST_ASSERT(err == 0, "Expected 0 got %d", err);
316 err = rte_event_eth_rx_adapter_queue_del(TEST_INST_ID,
318 TEST_ASSERT(err == 0, "Expected 0 got %d", err);
320 err = rte_event_eth_rx_adapter_queue_del(TEST_INST_ID,
322 TEST_ASSERT(err == 0, "Expected 0 got %d", err);
325 err = rte_event_eth_rx_adapter_queue_add(1, TEST_ETHDEV_ID, -1,
327 TEST_ASSERT(err == -EINVAL, "Expected -EINVAL got %d", err);
329 err = rte_event_eth_rx_adapter_queue_del(1, TEST_ETHDEV_ID, -1);
330 TEST_ASSERT(err == -EINVAL, "Expected -EINVAL got %d", err);
336 adapter_start_stop(void)
342 ev.sched_type = RTE_SCHED_TYPE_ATOMIC;
345 struct rte_event_eth_rx_adapter_queue_conf queue_config;
347 queue_config.rx_queue_flags = 0;
348 if (default_params.caps &
349 RTE_EVENT_ETH_RX_ADAPTER_CAP_OVERRIDE_FLOW_ID) {
351 queue_config.rx_queue_flags =
352 RTE_EVENT_ETH_RX_ADAPTER_QUEUE_FLOW_ID_VALID;
355 queue_config.ev = ev;
356 queue_config.servicing_weight = 1;
358 err = rte_event_eth_rx_adapter_queue_add(TEST_INST_ID, TEST_ETHDEV_ID,
360 TEST_ASSERT(err == 0, "Expected 0 got %d", err);
362 err = rte_event_eth_rx_adapter_start(TEST_INST_ID);
363 TEST_ASSERT(err == 0, "Expected 0 got %d", err);
365 err = rte_event_eth_rx_adapter_stop(TEST_INST_ID);
366 TEST_ASSERT(err == 0, "Expected 0 got %d", err);
368 err = rte_event_eth_rx_adapter_queue_del(TEST_INST_ID, TEST_ETHDEV_ID,
370 TEST_ASSERT(err == 0, "Expected 0 got %d", err);
372 err = rte_event_eth_rx_adapter_start(TEST_INST_ID);
373 TEST_ASSERT(err == 0, "Expected 0 got %d", err);
375 err = rte_event_eth_rx_adapter_stop(TEST_INST_ID);
376 TEST_ASSERT(err == 0, "Expected 0 got %d", err);
378 err = rte_event_eth_rx_adapter_start(1);
379 TEST_ASSERT(err == -EINVAL, "Expected -EINVAL got %d", err);
381 err = rte_event_eth_rx_adapter_stop(1);
382 TEST_ASSERT(err == -EINVAL, "Expected -EINVAL got %d", err);
391 struct rte_event_eth_rx_adapter_stats stats;
393 err = rte_event_eth_rx_adapter_stats_get(TEST_INST_ID, NULL);
394 TEST_ASSERT(err == -EINVAL, "Expected -EINVAL got %d", err);
396 err = rte_event_eth_rx_adapter_stats_get(TEST_INST_ID, &stats);
397 TEST_ASSERT(err == 0, "Expected 0 got %d", err);
399 err = rte_event_eth_rx_adapter_stats_get(1, &stats);
400 TEST_ASSERT(err == -EINVAL, "Expected -EINVAL got %d", err);
405 static struct unit_test_suite service_tests = {
406 .suite_name = "rx event eth adapter test suite",
407 .setup = testsuite_setup,
408 .teardown = testsuite_teardown,
410 TEST_CASE_ST(NULL, NULL, adapter_create_free),
411 TEST_CASE_ST(adapter_create, adapter_free,
412 adapter_queue_add_del),
413 TEST_CASE_ST(adapter_create, adapter_free, adapter_start_stop),
414 TEST_CASE_ST(adapter_create, adapter_free, adapter_stats),
415 TEST_CASES_END() /**< NULL terminate unit test array */
420 test_event_eth_rx_adapter_common(void)
422 return unit_test_suite_runner(&service_tests);
425 REGISTER_TEST_COMMAND(event_eth_rx_adapter_autotest,
426 test_event_eth_rx_adapter_common);