Patch Detail
get:
Show a patch.
patch:
Update a patch.
put:
Update a patch.
GET /api/patches/45057/?format=api
{ "id": 45057, "url": "https://patches.dpdk.org/api/patches/45057/?format=api", "web_url": "https://patches.dpdk.org/project/dpdk/patch/1537465276-77264-4-git-send-email-nikhil.rao@intel.com/", "project": { "id": 1, "url": "https://patches.dpdk.org/api/projects/1/?format=api", "name": "DPDK", "link_name": "dpdk", "list_id": "dev.dpdk.org", "list_email": "dev@dpdk.org", "web_url": "http://core.dpdk.org", "scm_url": "git://dpdk.org/dpdk", "webscm_url": "http://git.dpdk.org/dpdk", "list_archive_url": "https://inbox.dpdk.org/dev", "list_archive_url_format": "https://inbox.dpdk.org/dev/{}", "commit_url_format": "" }, "msgid": "<1537465276-77264-4-git-send-email-nikhil.rao@intel.com>", "list_archive_url": "https://inbox.dpdk.org/dev/1537465276-77264-4-git-send-email-nikhil.rao@intel.com", "date": "2018-09-20T17:41:15", "name": "[v4,4/5] eventdev: add auto test for eth Tx adapter", "commit_ref": null, "pull_url": null, "state": "accepted", "archived": true, "hash": "71bf79f7ce50f9d6d64b14d1bfa1efba377f289b", "submitter": { "id": 528, "url": "https://patches.dpdk.org/api/people/528/?format=api", "name": "Rao, Nikhil", "email": "nikhil.rao@intel.com" }, "delegate": { "id": 310, "url": "https://patches.dpdk.org/api/users/310/?format=api", "username": "jerin", "first_name": "Jerin", "last_name": "Jacob", "email": "jerinj@marvell.com" }, "mbox": "https://patches.dpdk.org/project/dpdk/patch/1537465276-77264-4-git-send-email-nikhil.rao@intel.com/mbox/", "series": [ { "id": 1426, "url": "https://patches.dpdk.org/api/series/1426/?format=api", "web_url": "https://patches.dpdk.org/project/dpdk/list/?series=1426", "date": "2018-09-20T17:41:12", "name": "[v4,1/5] eventdev: add eth Tx adapter APIs", "version": 4, "mbox": "https://patches.dpdk.org/series/1426/mbox/" } ], "comments": "https://patches.dpdk.org/api/patches/45057/comments/", "check": "success", "checks": "https://patches.dpdk.org/api/patches/45057/checks/", "tags": {}, "related": [], "headers": { "Return-Path": "<dev-bounces@dpdk.org>", "X-Original-To": "patchwork@dpdk.org", "Delivered-To": "patchwork@dpdk.org", "Received": [ "from [92.243.14.124] (localhost [127.0.0.1])\n\tby dpdk.org (Postfix) with ESMTP id EED831B159;\n\tThu, 20 Sep 2018 19:42:34 +0200 (CEST)", "from mga18.intel.com (mga18.intel.com [134.134.136.126])\n\tby dpdk.org (Postfix) with ESMTP id AF2821B145\n\tfor <dev@dpdk.org>; Thu, 20 Sep 2018 19:42:33 +0200 (CEST)", "from orsmga006.jf.intel.com ([10.7.209.51])\n\tby orsmga106.jf.intel.com with ESMTP/TLS/DHE-RSA-AES256-GCM-SHA384;\n\t20 Sep 2018 10:42:32 -0700", "from unknown (HELO localhost.localdomain.localdomain)\n\t([10.224.122.193])\n\tby orsmga006.jf.intel.com with ESMTP; 20 Sep 2018 10:42:29 -0700" ], "X-Amp-Result": "SKIPPED(no attachment in message)", "X-Amp-File-Uploaded": "False", "X-ExtLoop1": "1", "X-IronPort-AV": "E=Sophos;i=\"5.54,281,1534834800\"; d=\"scan'208\";a=\"75970131\"", "From": "Nikhil Rao <nikhil.rao@intel.com>", "To": "jerin.jacob@caviumnetworks.com, olivier.matz@6wind.com,\n\tmarko.kovacevic@intel.com, john.mcnamara@intel.com", "Cc": "dev@dpdk.org,\n\tNikhil Rao <nikhil.rao@intel.com>", "Date": "Thu, 20 Sep 2018 23:11:15 +0530", "Message-Id": "<1537465276-77264-4-git-send-email-nikhil.rao@intel.com>", "X-Mailer": "git-send-email 1.8.3.1", "In-Reply-To": "<1537465276-77264-1-git-send-email-nikhil.rao@intel.com>", "References": "<1535694069-88757-1-git-send-email-nikhil.rao@intel.com>\n\t<1537465276-77264-1-git-send-email-nikhil.rao@intel.com>", "Subject": "[dpdk-dev] [PATCH v4 4/5] eventdev: add auto test for eth Tx adapter", "X-BeenThere": "dev@dpdk.org", "X-Mailman-Version": "2.1.15", "Precedence": "list", "List-Id": "DPDK patches and discussions <dev.dpdk.org>", "List-Unsubscribe": "<https://mails.dpdk.org/options/dev>,\n\t<mailto:dev-request@dpdk.org?subject=unsubscribe>", "List-Archive": "<http://mails.dpdk.org/archives/dev/>", "List-Post": "<mailto:dev@dpdk.org>", "List-Help": "<mailto:dev-request@dpdk.org?subject=help>", "List-Subscribe": "<https://mails.dpdk.org/listinfo/dev>,\n\t<mailto:dev-request@dpdk.org?subject=subscribe>", "Errors-To": "dev-bounces@dpdk.org", "Sender": "\"dev\" <dev-bounces@dpdk.org>" }, "content": "This patch adds tests for the eth Tx adapter APIs. It also\ntests the data path for the rte_service function based\nimplementation of the APIs.\n\nSigned-off-by: Nikhil Rao <nikhil.rao@intel.com>\nAcked-by: Jerin Jacob <jerin.jacob@caviumnetworks.com>\n---\n test/test/test_event_eth_tx_adapter.c | 699 ++++++++++++++++++++++++++++++++++\n MAINTAINERS | 1 +\n test/test/Makefile | 1 +\n test/test/meson.build | 2 +\n 4 files changed, 703 insertions(+)\n create mode 100644 test/test/test_event_eth_tx_adapter.c", "diff": "diff --git a/test/test/test_event_eth_tx_adapter.c b/test/test/test_event_eth_tx_adapter.c\nnew file mode 100644\nindex 0000000..c26c515\n--- /dev/null\n+++ b/test/test/test_event_eth_tx_adapter.c\n@@ -0,0 +1,699 @@\n+/* SPDX-License-Identifier: BSD-3-Clause\n+ * Copyright(c) 2018 Intel Corporation\n+ */\n+\n+#include <string.h>\n+\n+#include <rte_bus_vdev.h>\n+#include <rte_common.h>\n+#include <rte_ethdev.h>\n+#include <rte_eth_ring.h>\n+#include <rte_eventdev.h>\n+#include <rte_event_eth_tx_adapter.h>\n+#include <rte_mbuf.h>\n+#include <rte_mempool.h>\n+#include <rte_service.h>\n+\n+#include \"test.h\"\n+\n+#define MAX_NUM_QUEUE\t\tRTE_PMD_RING_MAX_RX_RINGS\n+#define TEST_INST_ID\t\t0\n+#define TEST_DEV_ID\t\t0\n+#define SOCKET0\t\t\t0\n+#define RING_SIZE\t\t256\n+#define ETH_NAME_LEN\t\t32\n+#define NUM_ETH_PAIR\t\t1\n+#define NUM_ETH_DEV\t\t(2 * NUM_ETH_PAIR)\n+#define NB_MBUF\t\t\t512\n+#define PAIR_PORT_INDEX(p)\t((p) + NUM_ETH_PAIR)\n+#define PORT(p)\t\t\tdefault_params.port[(p)]\n+#define TEST_ETHDEV_ID\t\tPORT(0)\n+#define TEST_ETHDEV_PAIR_ID\tPORT(PAIR_PORT_INDEX(0))\n+\n+#define EDEV_RETRY\t\t0xffff\n+\n+struct event_eth_tx_adapter_test_params {\n+\tstruct rte_mempool *mp;\n+\tuint16_t rx_rings, tx_rings;\n+\tstruct rte_ring *r[NUM_ETH_DEV][MAX_NUM_QUEUE];\n+\tint port[NUM_ETH_DEV];\n+};\n+\n+static int event_dev_delete;\n+static struct event_eth_tx_adapter_test_params default_params;\n+static uint64_t eid = ~0ULL;\n+static uint32_t tid;\n+\n+static inline int\n+port_init_common(uint8_t port, const struct rte_eth_conf *port_conf,\n+\t\tstruct rte_mempool *mp)\n+{\n+\tconst uint16_t rx_ring_size = RING_SIZE, tx_ring_size = RING_SIZE;\n+\tint retval;\n+\tuint16_t q;\n+\n+\tif (!rte_eth_dev_is_valid_port(port))\n+\t\treturn -1;\n+\n+\tdefault_params.rx_rings = MAX_NUM_QUEUE;\n+\tdefault_params.tx_rings = MAX_NUM_QUEUE;\n+\n+\t/* Configure the Ethernet device. */\n+\tretval = rte_eth_dev_configure(port, default_params.rx_rings,\n+\t\t\t\tdefault_params.tx_rings, port_conf);\n+\tif (retval != 0)\n+\t\treturn retval;\n+\n+\tfor (q = 0; q < default_params.rx_rings; q++) {\n+\t\tretval = rte_eth_rx_queue_setup(port, q, rx_ring_size,\n+\t\t\t\trte_eth_dev_socket_id(port), NULL, mp);\n+\t\tif (retval < 0)\n+\t\t\treturn retval;\n+\t}\n+\n+\tfor (q = 0; q < default_params.tx_rings; q++) {\n+\t\tretval = rte_eth_tx_queue_setup(port, q, tx_ring_size,\n+\t\t\t\trte_eth_dev_socket_id(port), NULL);\n+\t\tif (retval < 0)\n+\t\t\treturn retval;\n+\t}\n+\n+\t/* Start the Ethernet port. */\n+\tretval = rte_eth_dev_start(port);\n+\tif (retval < 0)\n+\t\treturn retval;\n+\n+\t/* Display the port MAC address. */\n+\tstruct ether_addr addr;\n+\trte_eth_macaddr_get(port, &addr);\n+\tprintf(\"Port %u MAC: %02\" PRIx8 \" %02\" PRIx8 \" %02\" PRIx8\n+\t\t\t \" %02\" PRIx8 \" %02\" PRIx8 \" %02\" PRIx8 \"\\n\",\n+\t\t\t(unsigned int)port,\n+\t\t\taddr.addr_bytes[0], addr.addr_bytes[1],\n+\t\t\taddr.addr_bytes[2], addr.addr_bytes[3],\n+\t\t\taddr.addr_bytes[4], addr.addr_bytes[5]);\n+\n+\t/* Enable RX in promiscuous mode for the Ethernet device. */\n+\trte_eth_promiscuous_enable(port);\n+\n+\treturn 0;\n+}\n+\n+static inline int\n+port_init(uint8_t port, struct rte_mempool *mp)\n+{\n+\tstruct rte_eth_conf conf = { 0 };\n+\treturn port_init_common(port, &conf, mp);\n+}\n+\n+#define RING_NAME_LEN\t20\n+#define DEV_NAME_LEN\t20\n+\n+static int\n+init_ports(void)\n+{\n+\tchar ring_name[ETH_NAME_LEN];\n+\tunsigned int i, j;\n+\tstruct rte_ring * const *c1;\n+\tstruct rte_ring * const *c2;\n+\tint err;\n+\n+\tif (!default_params.mp)\n+\t\tdefault_params.mp = rte_pktmbuf_pool_create(\"mbuf_pool\",\n+\t\t\tNB_MBUF, 32,\n+\t\t\t0, RTE_MBUF_DEFAULT_BUF_SIZE, rte_socket_id());\n+\n+\tif (!default_params.mp)\n+\t\treturn -ENOMEM;\n+\n+\tfor (i = 0; i < NUM_ETH_DEV; i++) {\n+\t\tfor (j = 0; j < MAX_NUM_QUEUE; j++) {\n+\t\t\tsnprintf(ring_name, sizeof(ring_name), \"R%u%u\", i, j);\n+\t\t\tdefault_params.r[i][j] = rte_ring_create(ring_name,\n+\t\t\t\t\t\tRING_SIZE,\n+\t\t\t\t\t\tSOCKET0,\n+\t\t\t\t\t\tRING_F_SP_ENQ | RING_F_SC_DEQ);\n+\t\t\tTEST_ASSERT((default_params.r[i][j] != NULL),\n+\t\t\t\t\"Failed to allocate ring\");\n+\t\t}\n+\t}\n+\n+\t/*\n+\t * To create two pseudo-Ethernet ports where the traffic is\n+\t * switched between them, that is, traffic sent to port 1 is\n+\t * read back from port 2 and vice-versa\n+\t */\n+\tfor (i = 0; i < NUM_ETH_PAIR; i++) {\n+\t\tchar dev_name[DEV_NAME_LEN];\n+\t\tint p;\n+\n+\t\tc1 = default_params.r[i];\n+\t\tc2 = default_params.r[PAIR_PORT_INDEX(i)];\n+\n+\t\tsnprintf(dev_name, DEV_NAME_LEN, \"%u-%u\", i, i + NUM_ETH_PAIR);\n+\t\tp = rte_eth_from_rings(dev_name, c1, MAX_NUM_QUEUE,\n+\t\t\t\t c2, MAX_NUM_QUEUE, SOCKET0);\n+\t\tTEST_ASSERT(p >= 0, \"Port creation failed %s\", dev_name);\n+\t\terr = port_init(p, default_params.mp);\n+\t\tTEST_ASSERT(err == 0, \"Port init failed %s\", dev_name);\n+\t\tdefault_params.port[i] = p;\n+\n+\t\tsnprintf(dev_name, DEV_NAME_LEN, \"%u-%u\", i + NUM_ETH_PAIR, i);\n+\t\tp = rte_eth_from_rings(dev_name, c2, MAX_NUM_QUEUE,\n+\t\t\t\tc1, MAX_NUM_QUEUE, SOCKET0);\n+\t\tTEST_ASSERT(p > 0, \"Port creation failed %s\", dev_name);\n+\t\terr = port_init(p, default_params.mp);\n+\t\tTEST_ASSERT(err == 0, \"Port init failed %s\", dev_name);\n+\t\tdefault_params.port[PAIR_PORT_INDEX(i)] = p;\n+\t}\n+\n+\treturn 0;\n+}\n+\n+static void\n+deinit_ports(void)\n+{\n+\tuint16_t i, j;\n+\tchar name[ETH_NAME_LEN];\n+\n+\tfor (i = 0; i < RTE_DIM(default_params.port); i++) {\n+\t\trte_eth_dev_stop(default_params.port[i]);\n+\t\trte_eth_dev_get_name_by_port(default_params.port[i], name);\n+\t\trte_vdev_uninit(name);\n+\t\tfor (j = 0; j < RTE_DIM(default_params.r[i]); j++)\n+\t\t\trte_ring_free(default_params.r[i][j]);\n+\t}\n+}\n+\n+static int\n+testsuite_setup(void)\n+{\n+\tconst char *vdev_name = \"event_sw0\";\n+\n+\tint err = init_ports();\n+\tTEST_ASSERT(err == 0, \"Port initialization failed err %d\\n\", err);\n+\n+\tif (rte_event_dev_count() == 0) {\n+\t\tprintf(\"Failed to find a valid event device,\"\n+\t\t\t\" testing with event_sw0 device\\n\");\n+\t\terr = rte_vdev_init(vdev_name, NULL);\n+\t\tTEST_ASSERT(err == 0, \"vdev %s creation failed %d\\n\",\n+\t\t\tvdev_name, err);\n+\t\tevent_dev_delete = 1;\n+\t}\n+\treturn err;\n+}\n+\n+#define DEVICE_ID_SIZE 64\n+\n+static void\n+testsuite_teardown(void)\n+{\n+\tdeinit_ports();\n+\trte_mempool_free(default_params.mp);\n+\tdefault_params.mp = NULL;\n+\tif (event_dev_delete)\n+\t\trte_vdev_uninit(\"event_sw0\");\n+}\n+\n+static int\n+tx_adapter_create(void)\n+{\n+\tint err;\n+\tstruct rte_event_dev_info dev_info;\n+\tstruct rte_event_port_conf tx_p_conf;\n+\tuint8_t priority;\n+\tuint8_t queue_id;\n+\n+\tstruct rte_event_dev_config config = {\n+\t\t\t.nb_event_queues = 1,\n+\t\t\t.nb_event_ports = 1,\n+\t};\n+\n+\tstruct rte_event_queue_conf wkr_q_conf = {\n+\t\t\t.schedule_type = RTE_SCHED_TYPE_ORDERED,\n+\t\t\t.priority = RTE_EVENT_DEV_PRIORITY_NORMAL,\n+\t\t\t.nb_atomic_flows = 1024,\n+\t\t\t.nb_atomic_order_sequences = 1024,\n+\t};\n+\n+\tmemset(&tx_p_conf, 0, sizeof(tx_p_conf));\n+\terr = rte_event_dev_info_get(TEST_DEV_ID, &dev_info);\n+\tconfig.nb_event_queue_flows = dev_info.max_event_queue_flows;\n+\tconfig.nb_event_port_dequeue_depth =\n+\t\t\tdev_info.max_event_port_dequeue_depth;\n+\tconfig.nb_event_port_enqueue_depth =\n+\t\t\tdev_info.max_event_port_enqueue_depth;\n+\tconfig.nb_events_limit =\n+\t\t\tdev_info.max_num_events;\n+\n+\terr = rte_event_dev_configure(TEST_DEV_ID, &config);\n+\tTEST_ASSERT(err == 0, \"Event device initialization failed err %d\\n\",\n+\t\t\terr);\n+\n+\tqueue_id = 0;\n+\terr = rte_event_queue_setup(TEST_DEV_ID, 0, &wkr_q_conf);\n+\tTEST_ASSERT(err == 0, \"Event queue setup failed %d\\n\", err);\n+\n+\terr = rte_event_port_setup(TEST_DEV_ID, 0, NULL);\n+\tTEST_ASSERT(err == 0, \"Event port setup failed %d\\n\", err);\n+\n+\tpriority = RTE_EVENT_DEV_PRIORITY_LOWEST;\n+\terr = rte_event_port_link(TEST_DEV_ID, 0, &queue_id, &priority, 1);\n+\tTEST_ASSERT(err == 1, \"Error linking port %s\\n\",\n+\t\trte_strerror(rte_errno));\n+\terr = rte_event_dev_info_get(TEST_DEV_ID, &dev_info);\n+\tTEST_ASSERT(err == 0, \"Expected 0 got %d\", err);\n+\n+\ttx_p_conf.new_event_threshold = dev_info.max_num_events;\n+\ttx_p_conf.dequeue_depth = dev_info.max_event_port_dequeue_depth;\n+\ttx_p_conf.enqueue_depth = dev_info.max_event_port_enqueue_depth;\n+\terr = rte_event_eth_tx_adapter_create(TEST_INST_ID, TEST_DEV_ID,\n+\t\t\t\t\t&tx_p_conf);\n+\tTEST_ASSERT(err == 0, \"Expected 0 got %d\", err);\n+\n+\treturn err;\n+}\n+\n+static void\n+tx_adapter_free(void)\n+{\n+\trte_event_eth_tx_adapter_free(TEST_INST_ID);\n+}\n+\n+static int\n+tx_adapter_create_free(void)\n+{\n+\tint err;\n+\tstruct rte_event_dev_info dev_info;\n+\tstruct rte_event_port_conf tx_p_conf;\n+\n+\terr = rte_event_dev_info_get(TEST_DEV_ID, &dev_info);\n+\tTEST_ASSERT(err == 0, \"Expected 0 got %d\", err);\n+\n+\ttx_p_conf.new_event_threshold = dev_info.max_num_events;\n+\ttx_p_conf.dequeue_depth = dev_info.max_event_port_dequeue_depth;\n+\ttx_p_conf.enqueue_depth = dev_info.max_event_port_enqueue_depth;\n+\n+\terr = rte_event_eth_tx_adapter_create(TEST_INST_ID, TEST_DEV_ID,\n+\t\t\t\t\tNULL);\n+\tTEST_ASSERT(err == -EINVAL, \"Expected -EINVAL got %d\", err);\n+\n+\terr = rte_event_eth_tx_adapter_create(TEST_INST_ID, TEST_DEV_ID,\n+\t\t\t\t\t&tx_p_conf);\n+\tTEST_ASSERT(err == 0, \"Expected 0 got %d\", err);\n+\n+\terr = rte_event_eth_tx_adapter_create(TEST_INST_ID,\n+\t\t\t\t\tTEST_DEV_ID, &tx_p_conf);\n+\tTEST_ASSERT(err == -EEXIST, \"Expected -EEXIST %d got %d\", -EEXIST, err);\n+\n+\terr = rte_event_eth_tx_adapter_free(TEST_INST_ID);\n+\tTEST_ASSERT(err == 0, \"Expected 0 got %d\", err);\n+\n+\terr = rte_event_eth_tx_adapter_free(TEST_INST_ID);\n+\tTEST_ASSERT(err == -EINVAL, \"Expected -EINVAL %d got %d\", -EINVAL, err);\n+\n+\terr = rte_event_eth_tx_adapter_free(1);\n+\tTEST_ASSERT(err == -EINVAL, \"Expected -EINVAL %d got %d\", -EINVAL, err);\n+\n+\treturn TEST_SUCCESS;\n+}\n+\n+static int\n+tx_adapter_queue_add_del(void)\n+{\n+\tint err;\n+\tuint32_t cap;\n+\n+\terr = rte_event_eth_tx_adapter_caps_get(TEST_DEV_ID, TEST_ETHDEV_ID,\n+\t\t\t\t\t &cap);\n+\tTEST_ASSERT(err == 0, \"Expected 0 got %d\", err);\n+\n+\n+\terr = rte_event_eth_tx_adapter_queue_add(TEST_INST_ID,\n+\t\t\t\t\t\trte_eth_dev_count_total(),\n+\t\t\t\t\t\t-1);\n+\tTEST_ASSERT(err == -EINVAL, \"Expected -EINVAL got %d\", err);\n+\n+\terr = rte_event_eth_tx_adapter_queue_add(TEST_INST_ID,\n+\t\t\t\t\t\tTEST_ETHDEV_ID,\n+\t\t\t\t\t\t0);\n+\tTEST_ASSERT(err == 0, \"Expected 0 got %d\", err);\n+\n+\terr = rte_event_eth_tx_adapter_queue_add(TEST_INST_ID,\n+\t\t\t\t\t\tTEST_ETHDEV_ID,\n+\t\t\t\t\t\t-1);\n+\tTEST_ASSERT(err == 0, \"Expected 0 got %d\", err);\n+\n+\terr = rte_event_eth_tx_adapter_queue_del(TEST_INST_ID,\n+\t\t\t\t\t\tTEST_ETHDEV_ID,\n+\t\t\t\t\t\t0);\n+\tTEST_ASSERT(err == 0, \"Expected 0 got %d\", err);\n+\n+\terr = rte_event_eth_tx_adapter_queue_del(TEST_INST_ID,\n+\t\t\t\t\t\tTEST_ETHDEV_ID,\n+\t\t\t\t\t\t-1);\n+\tTEST_ASSERT(err == 0, \"Expected 0 got %d\", err);\n+\n+\terr = rte_event_eth_tx_adapter_queue_del(TEST_INST_ID,\n+\t\t\t\t\t\tTEST_ETHDEV_ID,\n+\t\t\t\t\t\t-1);\n+\tTEST_ASSERT(err == 0, \"Expected 0 got %d\", err);\n+\n+\terr = rte_event_eth_tx_adapter_queue_add(1, TEST_ETHDEV_ID, -1);\n+\tTEST_ASSERT(err == -EINVAL, \"Expected -EINVAL got %d\", err);\n+\n+\terr = rte_event_eth_tx_adapter_queue_del(1, TEST_ETHDEV_ID, -1);\n+\tTEST_ASSERT(err == -EINVAL, \"Expected -EINVAL got %d\", err);\n+\n+\treturn TEST_SUCCESS;\n+}\n+\n+static int\n+tx_adapter_start_stop(void)\n+{\n+\tint err;\n+\n+\terr = rte_event_eth_tx_adapter_queue_add(TEST_INST_ID, TEST_ETHDEV_ID,\n+\t\t\t\t\t\t-1);\n+\tTEST_ASSERT(err == 0, \"Expected 0 got %d\", err);\n+\n+\terr = rte_event_eth_tx_adapter_start(TEST_INST_ID);\n+\tTEST_ASSERT(err == 0, \"Expected 0 got %d\", err);\n+\n+\terr = rte_event_eth_tx_adapter_stop(TEST_INST_ID);\n+\tTEST_ASSERT(err == 0, \"Expected 0 got %d\", err);\n+\n+\terr = rte_event_eth_tx_adapter_queue_del(TEST_INST_ID, TEST_ETHDEV_ID,\n+\t\t\t\t\t\t-1);\n+\tTEST_ASSERT(err == 0, \"Expected 0 got %d\", err);\n+\n+\terr = rte_event_eth_tx_adapter_start(TEST_INST_ID);\n+\tTEST_ASSERT(err == 0, \"Expected 0 got %d\", err);\n+\n+\terr = rte_event_eth_tx_adapter_stop(TEST_INST_ID);\n+\tTEST_ASSERT(err == 0, \"Expected 0 got %d\", err);\n+\n+\terr = rte_event_eth_tx_adapter_start(1);\n+\n+\terr = rte_event_eth_tx_adapter_stop(1);\n+\tTEST_ASSERT(err == -EINVAL, \"Expected -EINVAL got %d\", err);\n+\n+\treturn TEST_SUCCESS;\n+}\n+\n+\n+static int\n+tx_adapter_single(uint16_t port, uint16_t tx_queue_id,\n+\t\tstruct rte_mbuf *m, uint8_t qid,\n+\t\tuint8_t sched_type)\n+{\n+\tstruct rte_event event;\n+\tstruct rte_mbuf *r;\n+\tint ret;\n+\tunsigned int l;\n+\n+\tevent.queue_id = qid;\n+\tevent.op = RTE_EVENT_OP_NEW;\n+\tevent.event_type = RTE_EVENT_TYPE_CPU;\n+\tevent.sched_type = sched_type;\n+\tevent.mbuf = m;\n+\n+\tm->port = port;\n+\trte_event_eth_tx_adapter_txq_set(m, tx_queue_id);\n+\n+\tl = 0;\n+\twhile (rte_event_enqueue_burst(TEST_DEV_ID, 0, &event, 1) != 1) {\n+\t\tl++;\n+\t\tif (l > EDEV_RETRY)\n+\t\t\tbreak;\n+\t}\n+\n+\tTEST_ASSERT(l < EDEV_RETRY, \"Unable to enqueue to eventdev\");\n+\tl = 0;\n+\twhile (l++ < EDEV_RETRY) {\n+\n+\t\tif (eid != ~0ULL) {\n+\t\t\tret = rte_service_run_iter_on_app_lcore(eid, 0);\n+\t\t\tTEST_ASSERT(ret == 0, \"failed to run service %d\", ret);\n+\t\t}\n+\n+\t\tret = rte_service_run_iter_on_app_lcore(tid, 0);\n+\t\tTEST_ASSERT(ret == 0, \"failed to run service %d\", ret);\n+\n+\t\tif (rte_eth_rx_burst(TEST_ETHDEV_PAIR_ID, tx_queue_id,\n+\t\t\t\t&r, 1)) {\n+\t\t\tTEST_ASSERT_EQUAL(r, m, \"mbuf comparison failed\"\n+\t\t\t\t\t\" expected %p received %p\", m, r);\n+\t\t\treturn 0;\n+\t\t}\n+\t}\n+\n+\tTEST_ASSERT(0, \"Failed to receive packet\");\n+\treturn -1;\n+}\n+\n+static int\n+tx_adapter_service(void)\n+{\n+\tstruct rte_event_eth_tx_adapter_stats stats;\n+\tuint32_t i;\n+\tint err;\n+\tuint8_t ev_port, ev_qid;\n+\tstruct rte_mbuf bufs[RING_SIZE];\n+\tstruct rte_mbuf *pbufs[RING_SIZE];\n+\tstruct rte_event_dev_info dev_info;\n+\tstruct rte_event_dev_config dev_conf;\n+\tstruct rte_event_queue_conf qconf;\n+\tuint32_t qcnt, pcnt;\n+\tuint16_t q;\n+\tint internal_port;\n+\tuint32_t cap;\n+\n+\tmemset(&dev_conf, 0, sizeof(dev_conf));\n+\terr = rte_event_eth_tx_adapter_caps_get(TEST_DEV_ID, TEST_ETHDEV_ID,\n+\t\t\t\t\t\t&cap);\n+\tTEST_ASSERT(err == 0, \"Failed to get adapter cap err %d\\n\", err);\n+\n+\tinternal_port = !!(cap & RTE_EVENT_ETH_TX_ADAPTER_CAP_INTERNAL_PORT);\n+\tif (internal_port)\n+\t\treturn TEST_SUCCESS;\n+\n+\terr = rte_event_eth_tx_adapter_queue_add(TEST_INST_ID, TEST_ETHDEV_ID,\n+\t\t\t\t\t\t-1);\n+\tTEST_ASSERT(err == 0, \"Expected 0 got %d\", err);\n+\n+\terr = rte_event_eth_tx_adapter_event_port_get(TEST_INST_ID,\n+\t\t\t\t\t\t&ev_port);\n+\tTEST_ASSERT_SUCCESS(err, \"Failed to get event port %d\", err);\n+\n+\terr = rte_event_dev_attr_get(TEST_DEV_ID, RTE_EVENT_DEV_ATTR_PORT_COUNT,\n+\t\t\t\t\t&pcnt);\n+\tTEST_ASSERT_SUCCESS(err, \"Port count get failed\");\n+\n+\terr = rte_event_dev_attr_get(TEST_DEV_ID,\n+\t\t\t\tRTE_EVENT_DEV_ATTR_QUEUE_COUNT, &qcnt);\n+\tTEST_ASSERT_SUCCESS(err, \"Queue count get failed\");\n+\n+\terr = rte_event_dev_info_get(TEST_DEV_ID, &dev_info);\n+\tTEST_ASSERT_SUCCESS(err, \"Dev info failed\");\n+\n+\tdev_conf.nb_event_queue_flows = dev_info.max_event_queue_flows;\n+\tdev_conf.nb_event_port_dequeue_depth =\n+\t\t\tdev_info.max_event_port_dequeue_depth;\n+\tdev_conf.nb_event_port_enqueue_depth =\n+\t\t\tdev_info.max_event_port_enqueue_depth;\n+\tdev_conf.nb_events_limit =\n+\t\t\tdev_info.max_num_events;\n+\tdev_conf.nb_event_queues = qcnt + 1;\n+\tdev_conf.nb_event_ports = pcnt;\n+\terr = rte_event_dev_configure(TEST_DEV_ID, &dev_conf);\n+\tTEST_ASSERT(err == 0, \"Event device initialization failed err %d\\n\",\n+\t\t\terr);\n+\n+\tev_qid = qcnt;\n+\tqconf.nb_atomic_flows = dev_info.max_event_queue_flows;\n+\tqconf.nb_atomic_order_sequences = 32;\n+\tqconf.schedule_type = RTE_SCHED_TYPE_ATOMIC;\n+\tqconf.priority = RTE_EVENT_DEV_PRIORITY_HIGHEST;\n+\tqconf.event_queue_cfg = RTE_EVENT_QUEUE_CFG_SINGLE_LINK;\n+\terr = rte_event_queue_setup(TEST_DEV_ID, ev_qid, &qconf);\n+\tTEST_ASSERT_SUCCESS(err, \"Failed to setup queue %u\", ev_qid);\n+\n+\t/*\n+\t * Setup ports again so that the newly added queue is visible\n+\t * to them\n+\t */\n+\tfor (i = 0; i < pcnt; i++) {\n+\n+\t\tint n_links;\n+\t\tuint8_t queues[RTE_EVENT_MAX_QUEUES_PER_DEV];\n+\t\tuint8_t priorities[RTE_EVENT_MAX_QUEUES_PER_DEV];\n+\n+\t\tif (i == ev_port)\n+\t\t\tcontinue;\n+\n+\t\tn_links = rte_event_port_links_get(TEST_DEV_ID, i, queues,\n+\t\t\t\t\t\tpriorities);\n+\t\tTEST_ASSERT(n_links > 0, \"Failed to get port links %d\\n\",\n+\t\t\tn_links);\n+\t\terr = rte_event_port_setup(TEST_DEV_ID, i, NULL);\n+\t\tTEST_ASSERT(err == 0, \"Failed to setup port err %d\\n\", err);\n+\t\terr = rte_event_port_link(TEST_DEV_ID, i, queues, priorities,\n+\t\t\t\t\tn_links);\n+\t\tTEST_ASSERT(n_links == err, \"Failed to link all queues\"\n+\t\t\t\" err %s\\n\", rte_strerror(rte_errno));\n+\t}\n+\n+\terr = rte_event_port_link(TEST_DEV_ID, ev_port, &ev_qid, NULL, 1);\n+\tTEST_ASSERT(err == 1, \"Failed to link queue port %u\",\n+\t\t ev_port);\n+\n+\terr = rte_event_eth_tx_adapter_start(TEST_INST_ID);\n+\tTEST_ASSERT(err == 0, \"Expected 0 got %d\", err);\n+\n+\tif (!(dev_info.event_dev_cap & RTE_EVENT_DEV_CAP_DISTRIBUTED_SCHED)) {\n+\t\terr = rte_event_dev_service_id_get(0, (uint32_t *)&eid);\n+\t\tTEST_ASSERT(err == 0, \"Expected 0 got %d\", err);\n+\n+\t\terr = rte_service_runstate_set(eid, 1);\n+\t\tTEST_ASSERT(err == 0, \"Expected 0 got %d\", err);\n+\n+\t\terr = rte_service_set_runstate_mapped_check(eid, 0);\n+\t\tTEST_ASSERT(err == 0, \"Expected 0 got %d\", err);\n+\t}\n+\n+\terr = rte_event_eth_tx_adapter_service_id_get(TEST_INST_ID, &tid);\n+\tTEST_ASSERT(err == 0, \"Expected 0 got %d\", err);\n+\n+\terr = rte_service_runstate_set(tid, 1);\n+\tTEST_ASSERT(err == 0, \"Expected 0 got %d\", err);\n+\n+\terr = rte_service_set_runstate_mapped_check(tid, 0);\n+\tTEST_ASSERT(err == 0, \"Expected 0 got %d\", err);\n+\n+\terr = rte_event_dev_start(TEST_DEV_ID);\n+\tTEST_ASSERT(err == 0, \"Expected 0 got %d\", err);\n+\n+\tfor (q = 0; q < MAX_NUM_QUEUE; q++) {\n+\t\tfor (i = 0; i < RING_SIZE; i++)\n+\t\t\tpbufs[i] = &bufs[i];\n+\t\tfor (i = 0; i < RING_SIZE; i++) {\n+\t\t\tpbufs[i] = &bufs[i];\n+\t\t\terr = tx_adapter_single(TEST_ETHDEV_ID, q, pbufs[i],\n+\t\t\t\t\t\tev_qid,\n+\t\t\t\t\t\tRTE_SCHED_TYPE_ORDERED);\n+\t\t\tTEST_ASSERT(err == 0, \"Expected 0 got %d\", err);\n+\t\t}\n+\t\tfor (i = 0; i < RING_SIZE; i++) {\n+\t\t\tTEST_ASSERT_EQUAL(pbufs[i], &bufs[i],\n+\t\t\t\t\"Error: received data does not match\"\n+\t\t\t\t\" that transmitted\");\n+\t\t}\n+\t}\n+\n+\terr = rte_event_eth_tx_adapter_stats_get(TEST_INST_ID, NULL);\n+\tTEST_ASSERT(err == -EINVAL, \"Expected -EINVAL got %d\", err);\n+\n+\terr = rte_event_eth_tx_adapter_stats_get(TEST_INST_ID, &stats);\n+\tTEST_ASSERT(err == 0, \"Expected 0 got %d\", err);\n+\tTEST_ASSERT_EQUAL(stats.tx_packets, MAX_NUM_QUEUE * RING_SIZE,\n+\t\t\t\"stats.tx_packets expected %u got %\"PRIu64,\n+\t\t\tMAX_NUM_QUEUE * RING_SIZE,\n+\t\t\tstats.tx_packets);\n+\n+\terr = rte_event_eth_tx_adapter_stats_reset(TEST_INST_ID);\n+\tTEST_ASSERT(err == 0, \"Expected 0 got %d\", err);\n+\n+\terr = rte_event_eth_tx_adapter_stats_get(TEST_INST_ID, &stats);\n+\tTEST_ASSERT(err == 0, \"Expected 0 got %d\", err);\n+\tTEST_ASSERT_EQUAL(stats.tx_packets, 0,\n+\t\t\t\"stats.tx_packets expected %u got %\"PRIu64,\n+\t\t\t0,\n+\t\t\tstats.tx_packets);\n+\n+\terr = rte_event_eth_tx_adapter_stats_get(1, &stats);\n+\tTEST_ASSERT(err == -EINVAL, \"Expected -EINVAL got %d\", err);\n+\n+\terr = rte_event_eth_tx_adapter_queue_del(TEST_INST_ID, TEST_ETHDEV_ID,\n+\t\t\t\t\t\t-1);\n+\tTEST_ASSERT(err == 0, \"Expected 0 got %d\", err);\n+\n+\terr = rte_event_eth_tx_adapter_free(TEST_INST_ID);\n+\tTEST_ASSERT(err == 0, \"Expected 0 got %d\", err);\n+\n+\trte_event_dev_stop(TEST_DEV_ID);\n+\n+\treturn TEST_SUCCESS;\n+}\n+\n+static int\n+tx_adapter_dynamic_device(void)\n+{\n+\tuint16_t port_id = rte_eth_dev_count_avail();\n+\tconst char *null_dev[2] = { \"eth_null0\", \"eth_null1\" };\n+\tstruct rte_eth_conf dev_conf;\n+\tint ret;\n+\tsize_t i;\n+\n+\tmemset(&dev_conf, 0, sizeof(dev_conf));\n+\tfor (i = 0; i < RTE_DIM(null_dev); i++) {\n+\t\tret = rte_vdev_init(null_dev[i], NULL);\n+\t\tTEST_ASSERT_SUCCESS(ret, \"%s Port creation failed %d\",\n+\t\t\t\tnull_dev[i], ret);\n+\n+\t\tif (i == 0) {\n+\t\t\tret = tx_adapter_create();\n+\t\t\tTEST_ASSERT_SUCCESS(ret, \"Adapter create failed %d\",\n+\t\t\t\t\tret);\n+\t\t}\n+\n+\t\tret = rte_eth_dev_configure(port_id + i, MAX_NUM_QUEUE,\n+\t\t\t\t\tMAX_NUM_QUEUE, &dev_conf);\n+\t\tTEST_ASSERT_SUCCESS(ret, \"Failed to configure device %d\", ret);\n+\n+\t\tret = rte_event_eth_tx_adapter_queue_add(TEST_INST_ID,\n+\t\t\t\t\t\t\tport_id + i, 0);\n+\t\tTEST_ASSERT_SUCCESS(ret, \"Failed to add queues %d\", ret);\n+\n+\t}\n+\n+\tfor (i = 0; i < RTE_DIM(null_dev); i++) {\n+\t\tret = rte_event_eth_tx_adapter_queue_del(TEST_INST_ID,\n+\t\t\t\t\t\t\tport_id + i, -1);\n+\t\tTEST_ASSERT_SUCCESS(ret, \"Failed to delete queues %d\", ret);\n+\t}\n+\n+\ttx_adapter_free();\n+\n+\tfor (i = 0; i < RTE_DIM(null_dev); i++)\n+\t\trte_vdev_uninit(null_dev[i]);\n+\n+\treturn TEST_SUCCESS;\n+}\n+\n+static struct unit_test_suite event_eth_tx_tests = {\n+\t.setup = testsuite_setup,\n+\t.teardown = testsuite_teardown,\n+\t.suite_name = \"tx event eth adapter test suite\",\n+\t.unit_test_cases = {\n+\t\tTEST_CASE_ST(NULL, NULL, tx_adapter_create_free),\n+\t\tTEST_CASE_ST(tx_adapter_create, tx_adapter_free,\n+\t\t\t\t\ttx_adapter_queue_add_del),\n+\t\tTEST_CASE_ST(tx_adapter_create, tx_adapter_free,\n+\t\t\t\t\ttx_adapter_start_stop),\n+\t\tTEST_CASE_ST(tx_adapter_create, tx_adapter_free,\n+\t\t\t\t\ttx_adapter_service),\n+\t\tTEST_CASE_ST(NULL, NULL, tx_adapter_dynamic_device),\n+\t\tTEST_CASES_END() /**< NULL terminate unit test array */\n+\t}\n+};\n+\n+static int\n+test_event_eth_tx_adapter_common(void)\n+{\n+\treturn unit_test_suite_runner(&event_eth_tx_tests);\n+}\n+\n+REGISTER_TEST_COMMAND(event_eth_tx_adapter_autotest,\n+\t\ttest_event_eth_tx_adapter_common);\ndiff --git a/MAINTAINERS b/MAINTAINERS\nindex 3f06b56..93699ba 100644\n--- a/MAINTAINERS\n+++ b/MAINTAINERS\n@@ -395,6 +395,7 @@ Eventdev Ethdev Tx Adapter API - EXPERIMENTAL\n M: Nikhil Rao <nikhil.rao@intel.com>\n T: git://dpdk.org/next/dpdk-next-eventdev\n F: lib/librte_eventdev/*eth_tx_adapter*\n+F: test/test/test_event_eth_tx_adapter.c\n \n Raw device API - EXPERIMENTAL\n M: Shreyansh Jain <shreyansh.jain@nxp.com>\ndiff --git a/test/test/Makefile b/test/test/Makefile\nindex e6967ba..dcea441 100644\n--- a/test/test/Makefile\n+++ b/test/test/Makefile\n@@ -191,6 +191,7 @@ ifeq ($(CONFIG_RTE_LIBRTE_EVENTDEV),y)\n SRCS-y += test_eventdev.c\n SRCS-y += test_event_ring.c\n SRCS-y += test_event_eth_rx_adapter.c\n+SRCS-y += test_event_eth_tx_adapter.c\n SRCS-y += test_event_timer_adapter.c\n SRCS-y += test_event_crypto_adapter.c\n endif\ndiff --git a/test/test/meson.build b/test/test/meson.build\nindex b1dd6ec..3d2887b 100644\n--- a/test/test/meson.build\n+++ b/test/test/meson.build\n@@ -34,6 +34,7 @@ test_sources = files('commands.c',\n \t'test_efd_perf.c',\n \t'test_errno.c',\n \t'test_event_ring.c',\n+\t'test_event_eth_tx_adapter.c',\n \t'test_eventdev.c',\n \t'test_func_reentrancy.c',\n \t'test_flow_classify.c',\n@@ -152,6 +153,7 @@ test_names = [\n \t'efd_perf_autotest',\n \t'errno_autotest',\n \t'event_ring_autotest',\n+\t'event_eth_tx_adapter_autotest',\n \t'eventdev_common_autotest',\n \t'eventdev_octeontx_autotest',\n \t'eventdev_sw_autotest',\n", "prefixes": [ "v4", "4/5" ] }