Patch Detail
get:
Show a patch.
patch:
Update a patch.
put:
Update a patch.
GET /api/patches/113235/?format=api
{ "id": 113235, "url": "https://patches.dpdk.org/api/patches/113235/?format=api", "web_url": "https://patches.dpdk.org/project/dpdk/patch/20220622103756.421869-4-ganapati.kundapura@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": "<20220622103756.421869-4-ganapati.kundapura@intel.com>", "list_archive_url": "https://inbox.dpdk.org/dev/20220622103756.421869-4-ganapati.kundapura@intel.com", "date": "2022-06-22T10:37:53", "name": "[v7,4/7] eventdev/eth_tx: add instance get API", "commit_ref": null, "pull_url": null, "state": "superseded", "archived": true, "hash": "1a6d2842ea299e71d88034d391b82aa46a90ac60", "submitter": { "id": 2287, "url": "https://patches.dpdk.org/api/people/2287/?format=api", "name": "Ganapati Kundapura", "email": "ganapati.kundapura@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/20220622103756.421869-4-ganapati.kundapura@intel.com/mbox/", "series": [ { "id": 23690, "url": "https://patches.dpdk.org/api/series/23690/?format=api", "web_url": "https://patches.dpdk.org/project/dpdk/list/?series=23690", "date": "2022-06-22T10:37:50", "name": "[v7,1/7] eventdev/eth_rx: add adapter instance get API", "version": 7, "mbox": "https://patches.dpdk.org/series/23690/mbox/" } ], "comments": "https://patches.dpdk.org/api/patches/113235/comments/", "check": "success", "checks": "https://patches.dpdk.org/api/patches/113235/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 5DD2FA04FD;\n\tWed, 22 Jun 2022 12:38:12 +0200 (CEST)", "from [217.70.189.124] (localhost [127.0.0.1])\n\tby mails.dpdk.org (Postfix) with ESMTP id 11A164280B;\n\tWed, 22 Jun 2022 12:38:07 +0200 (CEST)", "from mga09.intel.com (mga09.intel.com [134.134.136.24])\n by mails.dpdk.org (Postfix) with ESMTP id 25787427EE\n for <dev@dpdk.org>; Wed, 22 Jun 2022 12:38:01 +0200 (CEST)", "from fmsmga003.fm.intel.com ([10.253.24.29])\n by orsmga102.jf.intel.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384;\n 22 Jun 2022 03:38:00 -0700", "from txandevlnx322.an.intel.com ([10.123.117.44])\n by FMSMGA003.fm.intel.com with ESMTP; 22 Jun 2022 03:38:00 -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=1655894282; x=1687430282;\n h=from:to:subject:date:message-id:in-reply-to:references:\n mime-version:content-transfer-encoding;\n bh=HF8rspENHf8njPePyfB9atWn+EfhubG6RzA8Zxbmxus=;\n b=kSabAtN/W1QZLzBG+bEYNYGbEPs/DAYDUAzodDf//9j0IZVKEQ3MvP2o\n FdoU+rdC4yKt8SPEdJsQDRL2pZzYNkGU0WChMWPcI+6qiLnxEji7zzdCG\n wdppNzs8amsCKwoMto/If+JcLed+mjyyKrJHnxCRVklEGyiZqS63gNPvO\n ZozRCAkPUvrWZf2cHK71UdeTbjqXBlA89NCuKH7fGE+Hjj6mn/eWGfawg\n rX0oamCzoQCTFeo/VWCKg0c8s1zdtIVyvJuemIzHR+lxyCW7CIwrIX/Ga\n rQYAJobJHEGBSG9wON2lIH8uszK5I5pJFZzRTYrx0bZIJyPm5TUkay1QX A==;", "X-IronPort-AV": [ "E=McAfee;i=\"6400,9594,10385\"; a=\"281112378\"", "E=Sophos;i=\"5.92,212,1650956400\"; d=\"scan'208\";a=\"281112378\"", "E=Sophos;i=\"5.92,212,1650956400\"; d=\"scan'208\";a=\"677472097\"" ], "X-ExtLoop1": "1", "From": "Ganapati Kundapura <ganapati.kundapura@intel.com>", "To": "dev@dpdk.org, jerinj@marvell.com, jay.jayatheerthan@intel.com,\n s.v.naga.harish.k@intel.com", "Subject": "[PATCH v7 4/7] eventdev/eth_tx: add instance get API", "Date": "Wed, 22 Jun 2022 05:37:53 -0500", "Message-Id": "<20220622103756.421869-4-ganapati.kundapura@intel.com>", "X-Mailer": "git-send-email 2.23.0", "In-Reply-To": "<20220622103756.421869-1-ganapati.kundapura@intel.com>", "References": "<20220608121400.3954603-1-ganapati.kundapura@intel.com>\n <20220622103756.421869-1-ganapati.kundapura@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": "Added rte_event_eth_tx_adapter_instance_get() to get the\nadapter instance id for specified ethernet device id and\ntx queue index.\n\nSigned-off-by: Ganapati Kundapura <ganapati.kundapura@intel.com>\n---\n lib/eventdev/eventdev_pmd.h | 23 +++++++\n lib/eventdev/rte_event_eth_tx_adapter.c | 102 +++++++++++++++++++++++++++++++-\n lib/eventdev/rte_event_eth_tx_adapter.h | 24 ++++++++\n lib/eventdev/version.map | 1 +\n 4 files changed, 148 insertions(+), 2 deletions(-)", "diff": "diff --git a/lib/eventdev/eventdev_pmd.h b/lib/eventdev/eventdev_pmd.h\nindex c58ba05..f514a37 100644\n--- a/lib/eventdev/eventdev_pmd.h\n+++ b/lib/eventdev/eventdev_pmd.h\n@@ -1274,6 +1274,27 @@ typedef int (*eventdev_eth_tx_adapter_stats_get_t)(\n typedef int (*eventdev_eth_tx_adapter_stats_reset_t)(uint8_t id,\n \t\t\t\t\tconst struct rte_eventdev *dev);\n \n+/**\n+ * Get TX adapter instance id for TX queue\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+ * @param[out] txa_inst_id\n+ * Pointer to TX adapter instance identifier\n+ * Contains valid Tx adapter instance id when return value is 0\n+ *\n+ * @return\n+ * - 0: Success\n+ * - <0: Error code on failure\n+ */\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 /** Event device operations function pointer table */\n struct eventdev_ops {\n \teventdev_info_get_t dev_infos_get;\t/**< Get device info. */\n@@ -1386,6 +1407,8 @@ struct eventdev_ops {\n \t/**< Get eth Tx adapter statistics */\n \teventdev_eth_tx_adapter_stats_reset_t eth_tx_adapter_stats_reset;\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 \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 c700fb7..44a60cc 100644\n--- a/lib/eventdev/rte_event_eth_tx_adapter.c\n+++ b/lib/eventdev/rte_event_eth_tx_adapter.c\n@@ -18,6 +18,9 @@\n #define TXA_INVALID_DEV_ID\tINT32_C(-1)\n #define TXA_INVALID_SERVICE_ID\tINT64_C(-1)\n \n+#define TXA_ADAPTER_ARRAY \"txa_adapter_array\"\n+#define TXA_SERVICE_DATA_ARRAY \"txa_service_data_array\"\n+\n #define txa_evdev(id) (&rte_eventdevs[txa_dev_id_array[(id)]])\n \n #define txa_dev_caps_get(id) txa_evdev((id))->dev_ops->eth_tx_adapter_caps_get\n@@ -41,6 +44,9 @@\n \n #define txa_dev_stats_get(t) txa_evdev(t)->dev_ops->eth_tx_adapter_stats_get\n \n+#define txa_dev_instance_get(id) \\\n+\t\t\ttxa_evdev(id)->dev_ops->eth_tx_adapter_instance_get\n+\n #define RTE_EVENT_ETH_TX_ADAPTER_ID_VALID_OR_ERR_RET(id, retval) \\\n do { \\\n \tif (!txa_valid_id(id)) { \\\n@@ -194,12 +200,34 @@ txa_memzone_array_get(const char *name, unsigned int elt_size, int nb_elems)\n }\n \n static int\n+txa_lookup(void)\n+{\n+\tconst struct rte_memzone *mz;\n+\n+\tif (txa_dev_id_array == NULL) {\n+\t\tmz = rte_memzone_lookup(TXA_ADAPTER_ARRAY);\n+\t\tif (mz == NULL)\n+\t\t\treturn -ENOMEM;\n+\t\ttxa_dev_id_array = mz->addr;\n+\t}\n+\n+\tif (txa_service_data_array == NULL) {\n+\t\tmz = rte_memzone_lookup(TXA_SERVICE_DATA_ARRAY);\n+\t\tif (mz == NULL)\n+\t\t\treturn -ENOMEM;\n+\t\ttxa_service_data_array = mz->addr;\n+\t}\n+\n+\treturn 0;\n+}\n+\n+static int\n txa_dev_id_array_init(void)\n {\n \tif (txa_dev_id_array == NULL) {\n \t\tint i;\n \n-\t\ttxa_dev_id_array = txa_memzone_array_get(\"txa_adapter_array\",\n+\t\ttxa_dev_id_array = txa_memzone_array_get(TXA_ADAPTER_ARRAY,\n \t\t\t\t\tsizeof(int),\n \t\t\t\t\tRTE_EVENT_ETH_TX_ADAPTER_MAX_INSTANCE);\n \t\tif (txa_dev_id_array == NULL)\n@@ -222,12 +250,18 @@ static int\n txa_service_data_init(void)\n {\n \tif (txa_service_data_array == NULL) {\n+\t\tint i;\n+\n \t\ttxa_service_data_array =\n-\t\t\t\ttxa_memzone_array_get(\"txa_service_data_array\",\n+\t\t\t\ttxa_memzone_array_get(TXA_SERVICE_DATA_ARRAY,\n \t\t\t\t\tsizeof(*txa_service_data_array),\n \t\t\t\t\tRTE_EVENT_ETH_TX_ADAPTER_MAX_INSTANCE);\n \t\tif (txa_service_data_array == NULL)\n \t\t\treturn -ENOMEM;\n+\n+\t\t/* Reset the txa service pointers */\n+\t\tfor (i = 0; i < RTE_EVENT_ETH_TX_ADAPTER_MAX_INSTANCE; i++)\n+\t\t\ttxa_service_data_array[i] = NULL;\n \t}\n \n \treturn 0;\n@@ -1218,3 +1252,67 @@ rte_event_eth_tx_adapter_stop(uint8_t id)\n \trte_eventdev_trace_eth_tx_adapter_stop(id, ret);\n \treturn ret;\n }\n+\n+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+\tuint8_t id;\n+\tint ret = -EINVAL;\n+\tuint32_t caps;\n+\tstruct txa_service_data *txa;\n+\n+\tif (txa_lookup())\n+\t\treturn -ENOMEM;\n+\n+\tif (eth_dev_id >= rte_eth_dev_count_avail()) {\n+\t\tRTE_EDEV_LOG_ERR(\"Invalid ethernet port id %u\", eth_dev_id);\n+\t\treturn -EINVAL;\n+\t}\n+\n+\tif (tx_queue_id >= rte_eth_devices[eth_dev_id].data->nb_tx_queues) {\n+\t\tRTE_EDEV_LOG_ERR(\"Invalid tx queue id %u\", tx_queue_id);\n+\t\treturn -EINVAL;\n+\t}\n+\n+\tif (txa_inst_id == NULL) {\n+\t\tRTE_EDEV_LOG_ERR(\"txa_instance_id cannot be NULL\");\n+\t\treturn -EINVAL;\n+\t}\n+\n+\t/* Iterate through all Tx adapter instances */\n+\tfor (id = 0; id < RTE_EVENT_ETH_TX_ADAPTER_MAX_INSTANCE; id++) {\n+\t\ttxa = txa_service_id_to_data(id);\n+\t\tif (!txa)\n+\t\t\tcontinue;\n+\n+\t\tcaps = 0;\n+\t\tif (rte_event_eth_tx_adapter_caps_get(txa->eventdev_id,\n+\t\t\t\t\t\t eth_dev_id,\n+\t\t\t\t\t\t &caps))\n+\t\t\tcontinue;\n+\n+\t\tif (caps & RTE_EVENT_ETH_TX_ADAPTER_CAP_INTERNAL_PORT) {\n+\t\t\tret = txa_dev_instance_get(id) ?\n+\t\t\t\t\ttxa_dev_instance_get(id)(eth_dev_id,\n+\t\t\t\t\t\t\t\t tx_queue_id,\n+\t\t\t\t\t\t\t\t txa_inst_id)\n+\t\t\t\t\t\t\t: -EINVAL;\n+\t\t\tif (ret == 0)\n+\t\t\t\treturn ret;\n+\t\t} else {\n+\t\t\tstruct rte_eth_dev *eth_dev;\n+\n+\t\t\teth_dev = &rte_eth_devices[eth_dev_id];\n+\n+\t\t\tif (txa_service_is_queue_added(txa, eth_dev,\n+\t\t\t\t\t\t tx_queue_id)) {\n+\t\t\t\t*txa_inst_id = txa->id;\n+\t\t\t\treturn 0;\n+\t\t\t}\n+\t\t}\n+\t}\n+\n+\treturn -EINVAL;\n+}\ndiff --git a/lib/eventdev/rte_event_eth_tx_adapter.h b/lib/eventdev/rte_event_eth_tx_adapter.h\nindex 3908c2d..9432b74 100644\n--- a/lib/eventdev/rte_event_eth_tx_adapter.h\n+++ b/lib/eventdev/rte_event_eth_tx_adapter.h\n@@ -34,6 +34,7 @@\n * - rte_event_eth_tx_adapter_enqueue()\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 *\n * The application creates the adapter using\n * rte_event_eth_tx_adapter_create() or rte_event_eth_tx_adapter_create_ext().\n@@ -423,6 +424,29 @@ rte_event_eth_tx_adapter_stats_reset(uint8_t id);\n int\n rte_event_eth_tx_adapter_service_id_get(uint8_t id, uint32_t *service_id);\n \n+/**\n+ * Get TX adapter instance id for TX queue\n+ *\n+ * @param eth_dev_id\n+ * Port identifier of Ethernet device\n+ *\n+ * @param tx_queue_id\n+ * Etherdev device TX queue index\n+ *\n+ * @param[out] txa_inst_id\n+ * Pointer to TX adapter instance identifier\n+ * Contains valid Tx adapter instance id when return value is 0\n+ *\n+ * @return\n+ * - 0: Success\n+ * - <0: Error code on failure\n+ */\n+__rte_experimental\n+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 #ifdef __cplusplus\n }\n #endif\ndiff --git a/lib/eventdev/version.map b/lib/eventdev/version.map\nindex d1ecda4..dd9255c 100644\n--- a/lib/eventdev/version.map\n+++ b/lib/eventdev/version.map\n@@ -111,6 +111,7 @@ EXPERIMENTAL {\n \n \t# added in 22.07\n \trte_event_eth_rx_adapter_instance_get;\n+\trte_event_eth_tx_adapter_instance_get;\n \trte_event_port_quiesce;\n \trte_event_queue_attr_set;\n };\n", "prefixes": [ "v7", "4/7" ] }