Patch Detail
get:
Show a patch.
patch:
Update a patch.
put:
Update a patch.
GET /api/patches/116398/?format=api
{ "id": 116398, "url": "http://patches.dpdk.org/api/patches/116398/?format=api", "web_url": "http://patches.dpdk.org/project/dpdk/patch/20220916151543.2691949-1-s.v.naga.harish.k@intel.com/", "project": { "id": 1, "url": "http://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": "<20220916151543.2691949-1-s.v.naga.harish.k@intel.com>", "list_archive_url": "https://inbox.dpdk.org/dev/20220916151543.2691949-1-s.v.naga.harish.k@intel.com", "date": "2022-09-16T15:15:42", "name": "[v4,1/2] eventdev/eth_tx: add queue start stop API", "commit_ref": null, "pull_url": null, "state": "superseded", "archived": true, "hash": "6521c6592236ec3fd71e0ec1d75d39d81ffafb7d", "submitter": { "id": 2280, "url": "http://patches.dpdk.org/api/people/2280/?format=api", "name": "Naga Harish K, S V", "email": "s.v.naga.harish.k@intel.com" }, "delegate": { "id": 310, "url": "http://patches.dpdk.org/api/users/310/?format=api", "username": "jerin", "first_name": "Jerin", "last_name": "Jacob", "email": "jerinj@marvell.com" }, "mbox": "http://patches.dpdk.org/project/dpdk/patch/20220916151543.2691949-1-s.v.naga.harish.k@intel.com/mbox/", "series": [ { "id": 24695, "url": "http://patches.dpdk.org/api/series/24695/?format=api", "web_url": "http://patches.dpdk.org/project/dpdk/list/?series=24695", "date": "2022-09-16T15:15:42", "name": "[v4,1/2] eventdev/eth_tx: add queue start stop API", "version": 4, "mbox": "http://patches.dpdk.org/series/24695/mbox/" } ], "comments": "http://patches.dpdk.org/api/patches/116398/comments/", "check": "warning", "checks": "http://patches.dpdk.org/api/patches/116398/checks/", "tags": {}, "related": [], "headers": { "Return-Path": "<dev-bounces@dpdk.org>", "X-Original-To": "patchwork@inbox.dpdk.org", "Delivered-To": "patchwork@inbox.dpdk.org", "Received": [ "from mails.dpdk.org (mails.dpdk.org [217.70.189.124])\n\tby inbox.dpdk.org (Postfix) with ESMTP id F3F9DA0032;\n\tFri, 16 Sep 2022 17:15:50 +0200 (CEST)", "from [217.70.189.124] (localhost [127.0.0.1])\n\tby mails.dpdk.org (Postfix) with ESMTP id 7F8E94021D;\n\tFri, 16 Sep 2022 17:15:50 +0200 (CEST)", "from mga01.intel.com (mga01.intel.com [192.55.52.88])\n by mails.dpdk.org (Postfix) with ESMTP id 5B91940156\n for <dev@dpdk.org>; Fri, 16 Sep 2022 17:15:48 +0200 (CEST)", "from orsmga008.jf.intel.com ([10.7.209.65])\n by fmsmga101.fm.intel.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384;\n 16 Sep 2022 08:15:47 -0700", "from txandevlnx322.an.intel.com ([10.123.117.44])\n by orsmga008.jf.intel.com with ESMTP; 16 Sep 2022 08:15:46 -0700" ], "DKIM-Signature": "v=1; a=rsa-sha256; c=relaxed/simple;\n d=intel.com; i=@intel.com; q=dns/txt; s=Intel;\n t=1663341348; x=1694877348;\n h=from:to:cc:subject:date:message-id:in-reply-to:\n references:mime-version:content-transfer-encoding;\n bh=s/hMDPwH4sc1AlU170jZ4pzL0V3N/19P/aYeRB4A8Tw=;\n b=LQCwDut4+0i7IUtV/YyGBmULbY41D/ebVGED7EAYDkQTcIH4jLAPmdjL\n veKvG4x3+W599dOGZjdGlIIAkZ3CgPwguSTgSkKPU9SJWowIx1tliaG6n\n qxVHitVGKRSKIyHZCWhkA0GsbHcfeiwdys8jwatwNZYUJeFapGR2ovVGr\n vpPMMMrKtOPnIDBfb1BO7ZuCMJl2SP00ctwry0Jvms9PyQVTi1GwDJw5V\n FeEa3iP6Q6c4FNvzygzqH9UBQFJYBVhmctC+tPgn+vabNIRFhUSYKAuPJ\n S4g3cKNjeqZbOPZlMO61ywbwsJ/acGhDKLWmmyg6pnM2vy6MwmQZO5NSo Q==;", "X-IronPort-AV": [ "E=McAfee;i=\"6500,9779,10472\"; a=\"325286591\"", "E=Sophos;i=\"5.93,320,1654585200\"; d=\"scan'208\";a=\"325286591\"", "E=Sophos;i=\"5.93,320,1654585200\"; d=\"scan'208\";a=\"648292608\"" ], "X-ExtLoop1": "1", "From": "Naga Harish K S V <s.v.naga.harish.k@intel.com>", "To": "jerinj@marvell.com,\n\tjay.jayatheerthan@intel.com", "Cc": "dev@dpdk.org", "Subject": "[PATCH v4 1/2] eventdev/eth_tx: add queue start stop API", "Date": "Fri, 16 Sep 2022 10:15:42 -0500", "Message-Id": "<20220916151543.2691949-1-s.v.naga.harish.k@intel.com>", "X-Mailer": "git-send-email 2.23.0", "In-Reply-To": "<20220915151915.2285722-1-s.v.naga.harish.k@intel.com>", "References": "<20220915151915.2285722-1-s.v.naga.harish.k@intel.com>", "MIME-Version": "1.0", "Content-Transfer-Encoding": "8bit", "X-BeenThere": "dev@dpdk.org", "X-Mailman-Version": "2.1.29", "Precedence": "list", "List-Id": "DPDK patches and discussions <dev.dpdk.org>", "List-Unsubscribe": "<https://mails.dpdk.org/options/dev>,\n <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 <mailto:dev-request@dpdk.org?subject=subscribe>", "Errors-To": "dev-bounces@dpdk.org" }, "content": "Add support to start or stop a particular queue\nthat is associated with the adapter.\n\nStart function enables the Tx adapter to start enqueueing\npackets to the Tx queue.\n\nStop function stops the Tx adapter from transmitting any\npackets to the Tx queue. The Tx adapter also frees any packets\nthat may have been buffered for this queue. All inflight packets\ndestined to the queue are freed by the adapter runtime until the\nqueue is started again.\n\nSigned-off-by: Naga Harish K S V <s.v.naga.harish.k@intel.com>\n---\nv4:\n* update programmer guide and doxygen comments\nv3:\n* fix documentation and address review comments\n---\n .../prog_guide/event_ethernet_tx_adapter.rst | 25 ++++\n doc/guides/rel_notes/release_22_11.rst | 8 ++\n lib/eventdev/eventdev_pmd.h | 41 +++++++\n lib/eventdev/rte_event_eth_tx_adapter.c | 113 +++++++++++++++++-\n lib/eventdev/rte_event_eth_tx_adapter.h | 54 +++++++++\n lib/eventdev/version.map | 2 +\n 6 files changed, 239 insertions(+), 4 deletions(-)", "diff": "diff --git a/doc/guides/prog_guide/event_ethernet_tx_adapter.rst b/doc/guides/prog_guide/event_ethernet_tx_adapter.rst\nindex 4da9bcda3a..d1fdf9a6d1 100644\n--- a/doc/guides/prog_guide/event_ethernet_tx_adapter.rst\n+++ b/doc/guides/prog_guide/event_ethernet_tx_adapter.rst\n@@ -182,3 +182,28 @@ mbufs are destined to the same ethernet port and queue by setting the bit\n ``rte_event_vector::queue``.\n If ``rte_event_vector::attr_valid`` is not set then the Tx adapter should peek\n into each mbuf and transmit them to the requested ethernet port and queue pair.\n+\n+Queue start/stop\n+~~~~~~~~~~~~~~~~\n+\n+The adapter can be configured to start/stop enqueueing of packets to a NIC\n+queue using ``rte_event_eth_tx_adapter_queue_start()`` or\n+``rte_event_eth_tx_adapter_queue_stop()`` respectively. By default the queue\n+is in start state.\n+\n+These APIs help avoid some unexpected behavior with application stopping ethdev\n+Tx queues and adapter being unaware of it. With these APIs, the application can\n+call stop API to notify adapter that corresponding ethdev Tx queue is stopped\n+and any in-flight packets are freed by adapter dataplane code. Adapter queue\n+stop API is called before stopping the ethdev Tx queue. When ethdev Tx queue\n+is enabled, application can notify adapter to resume processing of the packets\n+for that queue by calling the start API. The ethdev Tx queue is started before\n+calling adapter start API.\n+\n+Start function enables the adapter runtime to start enqueueing packets\n+to the Tx queue.\n+\n+Stop function stops the adapter runtime function from enqueueing any\n+packets to the associated Tx queue. This API also frees any packets that\n+may have been buffered for this queue. All inflight packets destined to the\n+queue are freed by the adapter runtime until the queue is started again.\ndiff --git a/doc/guides/rel_notes/release_22_11.rst b/doc/guides/rel_notes/release_22_11.rst\nindex c32c18ff49..ec05ddcbf5 100644\n--- a/doc/guides/rel_notes/release_22_11.rst\n+++ b/doc/guides/rel_notes/release_22_11.rst\n@@ -30,6 +30,14 @@ New Features\n Added ``rte_event_eth_tx_adapter_instance_get`` to get the Tx adapter instance id for specified\n ethernet device id and Tx queue index.\n \n+\n+* **Added Tx adapter queue start/stop API**\n+\n+ Added ``rte_event_eth_tx_adapter_queue_start`` to start enqueueing packets to the Tx queue by\n+ Tx adapter.\n+ Added ``rte_event_eth_tx_adapter_queue_stop`` to stop the Tx Adapter from transmitting any\n+ packets to the Tx queue.\n+\n .. This section should contain new features added in this release.\n Sample format:\n \ndiff --git a/lib/eventdev/eventdev_pmd.h b/lib/eventdev/eventdev_pmd.h\nindex f514a37575..31eaf927df 100644\n--- a/lib/eventdev/eventdev_pmd.h\n+++ b/lib/eventdev/eventdev_pmd.h\n@@ -1294,6 +1294,43 @@ typedef int (*eventdev_eth_tx_adapter_stats_reset_t)(uint8_t id,\n typedef int (*eventdev_eth_tx_adapter_instance_get_t)\n \t(uint16_t eth_dev_id, uint16_t tx_queue_id, uint8_t *txa_inst_id);\n \n+/**\n+ * Start a Tx queue that is assigned to Tx adapter instance\n+ *\n+ * @param id\n+ * Adapter identifier\n+ *\n+ * @param eth_dev_id\n+ * Port identifier of Ethernet device\n+ *\n+ * @param tx_queue_id\n+ * Ethernet device Tx queue index\n+ *\n+ * @return\n+ * - 0: Success\n+ * - <0: Error code on failure\n+ */\n+typedef int (*eventdev_eth_tx_adapter_queue_start)\n+\t(uint8_t id, uint16_t eth_dev_id, uint16_t tx_queue_id);\n+\n+/**\n+ * Stop a Tx queue that is assigned to Tx adapter instance\n+ *\n+ * @param id\n+ * Adapter identifier\n+ *\n+ * @param eth_dev_id\n+ * Port identifier of Ethernet device\n+ *\n+ * @param tx_queue_id\n+ * Ethernet device Tx queue index\n+ *\n+ * @return\n+ * - 0: Success\n+ * - <0: Error code on failure\n+ */\n+typedef int (*eventdev_eth_tx_adapter_queue_stop)\n+\t(uint8_t id, uint16_t eth_dev_id, uint16_t tx_queue_id);\n \n /** Event device operations function pointer table */\n struct eventdev_ops {\n@@ -1409,6 +1446,10 @@ struct eventdev_ops {\n \t/**< Reset eth Tx adapter statistics */\n \teventdev_eth_tx_adapter_instance_get_t eth_tx_adapter_instance_get;\n \t/**< Get Tx adapter instance id for Tx queue */\n+\teventdev_eth_tx_adapter_queue_start eth_tx_adapter_queue_start;\n+\t/**< Start Tx queue assigned to Tx adapter instance */\n+\teventdev_eth_tx_adapter_queue_stop eth_tx_adapter_queue_stop;\n+\t/**< Stop Tx queue assigned to Tx adapter instance */\n \n \teventdev_selftest dev_selftest;\n \t/**< Start eventdev Selftest */\ndiff --git a/lib/eventdev/rte_event_eth_tx_adapter.c b/lib/eventdev/rte_event_eth_tx_adapter.c\nindex 7e82fe030c..5fb6a09f2d 100644\n--- a/lib/eventdev/rte_event_eth_tx_adapter.c\n+++ b/lib/eventdev/rte_event_eth_tx_adapter.c\n@@ -47,6 +47,12 @@\n #define txa_dev_instance_get(id) \\\n \t\t\ttxa_evdev(id)->dev_ops->eth_tx_adapter_instance_get\n \n+#define txa_dev_queue_start(id) \\\n+\t\t\ttxa_evdev(id)->dev_ops->eth_tx_adapter_queue_start\n+\n+#define txa_dev_queue_stop(id) \\\n+\t\t\ttxa_evdev(id)->dev_ops->eth_tx_adapter_queue_stop\n+\n #define RTE_EVENT_ETH_TX_ADAPTER_ID_VALID_OR_ERR_RET(id, retval) \\\n do { \\\n \tif (!txa_valid_id(id)) { \\\n@@ -94,6 +100,8 @@ struct txa_retry {\n struct txa_service_queue_info {\n \t/* Queue has been added */\n \tuint8_t added;\n+\t/* Queue is stopped */\n+\tbool stopped;\n \t/* Retry callback argument */\n \tstruct txa_retry txa_retry;\n \t/* Tx buffer */\n@@ -556,7 +564,7 @@ txa_process_event_vector(struct txa_service_data *txa,\n \t\tport = vec->port;\n \t\tqueue = vec->queue;\n \t\ttqi = txa_service_queue(txa, port, queue);\n-\t\tif (unlikely(tqi == NULL || !tqi->added)) {\n+\t\tif (unlikely(tqi == NULL || !tqi->added || tqi->stopped)) {\n \t\t\trte_pktmbuf_free_bulk(mbufs, vec->nb_elem);\n \t\t\trte_mempool_put(rte_mempool_from_obj(vec), vec);\n \t\t\treturn 0;\n@@ -570,7 +578,8 @@ txa_process_event_vector(struct txa_service_data *txa,\n \t\t\tport = mbufs[i]->port;\n \t\t\tqueue = rte_event_eth_tx_adapter_txq_get(mbufs[i]);\n \t\t\ttqi = txa_service_queue(txa, port, queue);\n-\t\t\tif (unlikely(tqi == NULL || !tqi->added)) {\n+\t\t\tif (unlikely(tqi == NULL || !tqi->added ||\n+\t\t\t\t tqi->stopped)) {\n \t\t\t\trte_pktmbuf_free(mbufs[i]);\n \t\t\t\tcontinue;\n \t\t\t}\n@@ -607,7 +616,8 @@ txa_service_tx(struct txa_service_data *txa, struct rte_event *ev,\n \t\t\tqueue = rte_event_eth_tx_adapter_txq_get(m);\n \n \t\t\ttqi = txa_service_queue(txa, port, queue);\n-\t\t\tif (unlikely(tqi == NULL || !tqi->added)) {\n+\t\t\tif (unlikely(tqi == NULL || !tqi->added ||\n+\t\t\t\t tqi->stopped)) {\n \t\t\t\trte_pktmbuf_free(m);\n \t\t\t\tcontinue;\n \t\t\t}\n@@ -671,7 +681,8 @@ txa_service_func(void *args)\n \t\t\tfor (q = 0; q < dev->data->nb_tx_queues; q++) {\n \n \t\t\t\ttqi = txa_service_queue(txa, i, q);\n-\t\t\t\tif (unlikely(tqi == NULL || !tqi->added))\n+\t\t\t\tif (unlikely(tqi == NULL || !tqi->added ||\n+\t\t\t\t\t tqi->stopped))\n \t\t\t\t\tcontinue;\n \n \t\t\t\tnb_tx += rte_eth_tx_buffer_flush(i, q,\n@@ -866,6 +877,7 @@ txa_service_queue_add(uint8_t id,\n \n \ttqi->tx_buf = tb;\n \ttqi->added = 1;\n+\ttqi->stopped = false;\n \ttdi->nb_queues++;\n \ttxa->nb_queues++;\n \n@@ -884,6 +896,20 @@ txa_service_queue_add(uint8_t id,\n \treturn -1;\n }\n \n+static inline void\n+txa_txq_buffer_drain(struct txa_service_queue_info *tqi)\n+{\n+\tstruct rte_eth_dev_tx_buffer *b;\n+\tuint16_t i;\n+\n+\tb = tqi->tx_buf;\n+\n+\tfor (i = 0; i < b->length; i++)\n+\t\trte_pktmbuf_free(b->pkts[i]);\n+\n+\tb->length = 0;\n+}\n+\n static int\n txa_service_queue_del(uint8_t id,\n \t\tconst struct rte_eth_dev *dev,\n@@ -929,6 +955,8 @@ txa_service_queue_del(uint8_t id,\n \tif (tqi == NULL || !tqi->added)\n \t\tgoto ret_unlock;\n \n+\t/* Drain the buffered mbufs */\n+\ttxa_txq_buffer_drain(tqi);\n \ttb = tqi->tx_buf;\n \ttqi->added = 0;\n \ttqi->tx_buf = NULL;\n@@ -1319,3 +1347,80 @@ rte_event_eth_tx_adapter_instance_get(uint16_t eth_dev_id,\n \n \treturn -EINVAL;\n }\n+\n+static inline int\n+txa_sw_queue_start_state_set(uint16_t eth_dev_id, uint16_t tx_queue_id,\n+\t\t\t bool start_state, struct txa_service_data *txa)\n+{\n+\tstruct txa_service_queue_info *tqi = NULL;\n+\n+\trte_spinlock_lock(&txa->tx_lock);\n+\ttqi = txa_service_queue(txa, eth_dev_id, tx_queue_id);\n+\tif (unlikely(tqi == NULL || !tqi->added)) {\n+\t\trte_spinlock_unlock(&txa->tx_lock);\n+\t\treturn -EINVAL;\n+\t}\n+\tif (start_state == false)\n+\t\ttxa_txq_buffer_drain(tqi);\n+\n+\ttqi->stopped = !start_state;\n+\trte_spinlock_unlock(&txa->tx_lock);\n+\treturn 0;\n+}\n+\n+static int\n+txa_queue_start_state_set(uint16_t eth_dev_id, uint16_t tx_queue_id,\n+\t\t\t bool start_state)\n+{\n+\tstruct txa_service_data *txa;\n+\tuint8_t txa_inst_id;\n+\tint ret;\n+\tuint32_t caps = 0;\n+\n+\t/* Below API already does validation of input parameters.\n+\t * Hence skipping the validation here.\n+\t */\n+\tret = rte_event_eth_tx_adapter_instance_get(eth_dev_id,\n+\t\t\t\t\t\t tx_queue_id,\n+\t\t\t\t\t\t &txa_inst_id);\n+\tif (ret < 0)\n+\t\treturn -EINVAL;\n+\n+\tTXA_CHECK_OR_ERR_RET(txa_inst_id);\n+\n+\ttxa = txa_service_id_to_data(txa_inst_id);\n+\tret = rte_event_eth_tx_adapter_caps_get(txa->eventdev_id,\n+\t\t\t\t\t\teth_dev_id,\n+\t\t\t\t\t\t&caps);\n+\tif (ret < 0)\n+\t\treturn -EINVAL;\n+\n+\tif (caps & RTE_EVENT_ETH_TX_ADAPTER_CAP_INTERNAL_PORT) {\n+\t\tif (start_state == true) {\n+\t\t\tret = txa_dev_queue_start(txa_inst_id) ?\n+\t\t\t txa_dev_queue_start(txa_inst_id)(txa_inst_id,\n+\t\t\t\t\t\t\t eth_dev_id,\n+\t\t\t\t\t\t\t tx_queue_id) : 0;\n+\t\t} else {\n+\t\t\tret = txa_dev_queue_stop(txa_inst_id) ?\n+\t\t\t txa_dev_queue_stop(txa_inst_id)(txa_inst_id,\n+\t\t\t\t\t\t\t eth_dev_id,\n+\t\t\t\t\t\t\t tx_queue_id) : 0;\n+\t\t}\n+\t\treturn ret;\n+\t}\n+\treturn txa_sw_queue_start_state_set(eth_dev_id, tx_queue_id,\n+\t\t\t\t\t start_state, txa);\n+}\n+\n+int\n+rte_event_eth_tx_adapter_queue_start(uint16_t eth_dev_id, uint16_t tx_queue_id)\n+{\n+\treturn txa_queue_start_state_set(eth_dev_id, tx_queue_id, true);\n+}\n+\n+int\n+rte_event_eth_tx_adapter_queue_stop(uint16_t eth_dev_id, uint16_t tx_queue_id)\n+{\n+\treturn txa_queue_start_state_set(eth_dev_id, tx_queue_id, false);\n+}\ndiff --git a/lib/eventdev/rte_event_eth_tx_adapter.h b/lib/eventdev/rte_event_eth_tx_adapter.h\nindex 9432b740e8..54d7a32b94 100644\n--- a/lib/eventdev/rte_event_eth_tx_adapter.h\n+++ b/lib/eventdev/rte_event_eth_tx_adapter.h\n@@ -35,6 +35,8 @@\n * - rte_event_eth_tx_adapter_event_port_get()\n * - rte_event_eth_tx_adapter_service_id_get()\n * - rte_event_eth_tx_adapter_instance_get()\n+ * - rte_event_eth_tx_adapter_queue_start()\n+ * - rte_event_eth_tx_adapter_queue_stop()\n *\n * The application creates the adapter using\n * rte_event_eth_tx_adapter_create() or rte_event_eth_tx_adapter_create_ext().\n@@ -446,6 +448,58 @@ int\n rte_event_eth_tx_adapter_instance_get(uint16_t eth_dev_id,\n \t\t\t\t uint16_t tx_queue_id,\n \t\t\t\t uint8_t *txa_inst_id);\n+/**\n+ * Enables the Tx adapter to start enqueueing packets to the\n+ * Tx queue.\n+ *\n+ * This function is provided so that the application can\n+ * resume enqueueing packets that reference packets for\n+ * <eth_dev_id, tx_queue_id> after calling\n+ * rte_event_eth_tx_adapter_queue_stop()\n+ * @see rte_event_eth_tx_adapter_queue_stop\n+ *\n+ * Use case:\n+ * ~~~~~~~~\n+ * The queue start/stop APIs help avoid some unexpected behavior with\n+ * application stopping ethdev Tx queues and adapter being unaware of it.\n+ * With these APIs, the application can call stop API to notify adapter\n+ * that corresponding ethdev Tx queue is stopped and any in-flight\n+ * packets are freed by adapter dataplane code. Adapter queue stop API\n+ * is called before stopping the ethdev Tx queue. When ethdev Tx queue\n+ * is enabled, application can notify adapter to resume processing of\n+ * the packets for that queue by calling the start API. The ethdev Tx\n+ * queue is started before calling adapter start API.\n+ *\n+ * @param eth_dev_id\n+ * Port identifier of Ethernet device.\n+ * @param tx_queue_id\n+ * Ethernet device transmit queue index.\n+ * @return\n+ * - 0: Success\n+ * - <0: Error code on failure\n+ */\n+__rte_experimental\n+int\n+rte_event_eth_tx_adapter_queue_start(uint16_t eth_dev_id, uint16_t tx_queue_id);\n+\n+/**\n+ * Stops the Tx adapter runtime function from enqueueing any packets\n+ * to the associated Tx queue. This API also frees any packets that may\n+ * have been buffered for this queue. All inflight packets destined to the\n+ * queue are freed by the adapter runtime until the queue is started again.\n+ * @see rte_event_eth_tx_adapter_queue_start\n+ *\n+ * @param eth_dev_id\n+ * Port identifier of Ethernet device.\n+ * @param tx_queue_id\n+ * Ethernet device transmit queue index.\n+ * @return\n+ * - 0: Success\n+ * - <0: Error code on failure\n+ */\n+__rte_experimental\n+int\n+rte_event_eth_tx_adapter_queue_stop(uint16_t eth_dev_id, uint16_t tx_queue_id);\n \n #ifdef __cplusplus\n }\ndiff --git a/lib/eventdev/version.map b/lib/eventdev/version.map\nindex 9a71cf3f8f..dd63ec6f68 100644\n--- a/lib/eventdev/version.map\n+++ b/lib/eventdev/version.map\n@@ -116,6 +116,8 @@ EXPERIMENTAL {\n \t# added in 22.11\n \trte_event_eth_rx_adapter_instance_get;\n \trte_event_eth_tx_adapter_instance_get;\n+\trte_event_eth_tx_adapter_queue_start;\n+\trte_event_eth_tx_adapter_queue_stop;\n };\n \n INTERNAL {\n", "prefixes": [ "v4", "1/2" ] }