Patch Detail
get:
Show a patch.
patch:
Update a patch.
put:
Update a patch.
GET /api/patches/133510/?format=api
{ "id": 133510, "url": "http://patches.dpdk.org/api/patches/133510/?format=api", "web_url": "http://patches.dpdk.org/project/dpdk/patch/20231027145534.16803-6-rnagadheeraj@marvell.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": "<20231027145534.16803-6-rnagadheeraj@marvell.com>", "list_archive_url": "https://inbox.dpdk.org/dev/20231027145534.16803-6-rnagadheeraj@marvell.com", "date": "2023-10-27T14:55:31", "name": "[5/7] compress/nitrox: add software queue management", "commit_ref": null, "pull_url": null, "state": "superseded", "archived": true, "hash": "86168968204f7e7cc79cc735e47de52719266eaf", "submitter": { "id": 1365, "url": "http://patches.dpdk.org/api/people/1365/?format=api", "name": "Nagadheeraj Rottela", "email": "rnagadheeraj@marvell.com" }, "delegate": { "id": 6690, "url": "http://patches.dpdk.org/api/users/6690/?format=api", "username": "akhil", "first_name": "akhil", "last_name": "goyal", "email": "gakhil@marvell.com" }, "mbox": "http://patches.dpdk.org/project/dpdk/patch/20231027145534.16803-6-rnagadheeraj@marvell.com/mbox/", "series": [ { "id": 30030, "url": "http://patches.dpdk.org/api/series/30030/?format=api", "web_url": "http://patches.dpdk.org/project/dpdk/list/?series=30030", "date": "2023-10-27T14:55:26", "name": "add Nitrox compress device support", "version": 1, "mbox": "http://patches.dpdk.org/series/30030/mbox/" } ], "comments": "http://patches.dpdk.org/api/patches/133510/comments/", "check": "success", "checks": "http://patches.dpdk.org/api/patches/133510/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 854F443217;\n\tFri, 27 Oct 2023 16:56:29 +0200 (CEST)", "from mails.dpdk.org (localhost [127.0.0.1])\n\tby mails.dpdk.org (Postfix) with ESMTP id 9668642E26;\n\tFri, 27 Oct 2023 16:55:59 +0200 (CEST)", "from mx0b-0016f401.pphosted.com (mx0a-0016f401.pphosted.com\n [67.231.148.174])\n by mails.dpdk.org (Postfix) with ESMTP id 8663842E22\n for <dev@dpdk.org>; Fri, 27 Oct 2023 16:55:58 +0200 (CEST)", "from pps.filterd (m0045849.ppops.net [127.0.0.1])\n by mx0a-0016f401.pphosted.com (8.17.1.19/8.17.1.19) with ESMTP id\n 39R5TuUW012486; Fri, 27 Oct 2023 07:55:57 -0700", "from dc5-exch01.marvell.com ([199.233.59.181])\n by mx0a-0016f401.pphosted.com (PPS) with ESMTPS id 3tywr83u9k-1\n (version=TLSv1.2 cipher=ECDHE-RSA-AES256-SHA384 bits=256 verify=NOT);\n Fri, 27 Oct 2023 07:55:57 -0700", "from DC5-EXCH02.marvell.com (10.69.176.39) by DC5-EXCH01.marvell.com\n (10.69.176.38) with Microsoft SMTP Server (TLS) id 15.0.1497.48;\n Fri, 27 Oct 2023 07:55:56 -0700", "from hyd1399.caveonetworks.com.com (10.69.176.80) by\n DC5-EXCH02.marvell.com (10.69.176.39) with Microsoft SMTP Server id\n 15.0.1497.48 via Frontend Transport; Fri, 27 Oct 2023 07:55:54 -0700" ], "DKIM-Signature": "v=1; a=rsa-sha256; c=relaxed/relaxed; d=marvell.com;\n h=from : to : cc :\n subject : date : message-id : in-reply-to : references : mime-version :\n content-transfer-encoding : content-type; s=pfpt0220;\n bh=BkhfNMHgKNhNiJRUbydmyLBYvy4ZeadvxuLDdwBKMp4=;\n b=WGY9H0uypM4V3MI1ZtFDUzAMrqfFWdvlnNLh1+T/IhulOWNSErLyuulBL5enFJH63w4k\n zMC9z/EY2epgtg2axr3Xx/xXtDllF77s3V0X6XNaEK6Y4faacTlNGE5aA+Zp223GFgbt\n cUK850QZr5ur8UnUxCo22MHQcmhxobm0W5Lp/523zT2dfqs/5cq/41aFNGthlLWwHrAS\n WZSrvJD9j2G/0hf+4rrYiXJ3mnj1pWF5Df4AE/DFpWOLatpbYWAy/MFX34s3XUZcxvBV\n pyknzwWitT9OJFKltDbCvNgoazpdrKpJZUFH8ZtjyvCAdlLMyelAiaycO5btXqFVxPSW gA==", "From": "Nagadheeraj Rottela <rnagadheeraj@marvell.com>", "To": "Nagadheeraj Rottela <rnagadheeraj@marvell.com>, Fan Zhang\n <fanzhang.oss@gmail.com>, Ashish Gupta <ashish.gupta@marvell.com>", "CC": "<dev@dpdk.org>", "Subject": "[PATCH 5/7] compress/nitrox: add software queue management", "Date": "Fri, 27 Oct 2023 20:25:31 +0530", "Message-ID": "<20231027145534.16803-6-rnagadheeraj@marvell.com>", "X-Mailer": "git-send-email 2.42.0", "In-Reply-To": "<20231027145534.16803-1-rnagadheeraj@marvell.com>", "References": "<20231027145534.16803-1-rnagadheeraj@marvell.com>", "MIME-Version": "1.0", "Content-Transfer-Encoding": "8bit", "Content-Type": "text/plain", "X-Proofpoint-GUID": "9JTSSmYfMvTn_FRQ-X2AfbhT3Q5QN7rn", "X-Proofpoint-ORIG-GUID": "9JTSSmYfMvTn_FRQ-X2AfbhT3Q5QN7rn", "X-Proofpoint-Virus-Version": "vendor=baseguard\n engine=ICAP:2.0.272,Aquarius:18.0.987,Hydra:6.0.619,FMLib:17.11.176.26\n definitions=2023-10-27_13,2023-10-27_01,2023-05-22_02", "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 software queue management code corresponding to\nqueue pair setup and release functions.\n\nSigned-off-by: Nagadheeraj Rottela <rnagadheeraj@marvell.com>\n---\n drivers/compress/nitrox/nitrox_comp.c | 116 +++++++++++++++++++++++---\n 1 file changed, 105 insertions(+), 11 deletions(-)", "diff": "diff --git a/drivers/compress/nitrox/nitrox_comp.c b/drivers/compress/nitrox/nitrox_comp.c\nindex d9bd04db06..2d6e6dcc17 100644\n--- a/drivers/compress/nitrox/nitrox_comp.c\n+++ b/drivers/compress/nitrox/nitrox_comp.c\n@@ -5,10 +5,12 @@\n #include <rte_compressdev_pmd.h>\n #include <rte_comp.h>\n #include <rte_errno.h>\n+#include <rte_malloc.h>\n \n #include \"nitrox_comp.h\"\n #include \"nitrox_device.h\"\n #include \"nitrox_logs.h\"\n+#include \"nitrox_qp.h\"\n \n #define COMPRESSDEV_NAME_NITROX_PMD\tcompress_nitrox\n #define NITROX_DECOMP_CTX_SIZE 2048\n@@ -21,6 +23,7 @@\n #define NITROX_COMP_LEVEL_MEDIUM_END 6\n #define NITROX_COMP_LEVEL_BEST_START 7\n #define NITROX_COMP_LEVEL_BEST_END 9\n+#define ZIP_INSTR_SIZE 64\n \n struct nitrox_comp_device {\n \tstruct rte_compressdev *cdev;\n@@ -73,6 +76,9 @@ static const struct rte_driver nitrox_rte_comp_drv = {\n \t.alias = nitrox_comp_drv_name\n };\n \n+static int nitrox_comp_queue_pair_release(struct rte_compressdev *dev,\n+\t\t\t\t\t uint16_t qp_id);\n+\n static const struct rte_compressdev_capabilities\n \t\t\t\tnitrox_comp_pmd_capabilities[] = {\n \t{\t.algo = RTE_COMP_ALGO_DEFLATE,\n@@ -138,8 +144,15 @@ static void nitrox_comp_dev_stop(struct rte_compressdev *dev)\n \n static int nitrox_comp_dev_close(struct rte_compressdev *dev)\n {\n+\tint i, ret;\n \tstruct nitrox_comp_device *comp_dev = dev->data->dev_private;\n \n+\tfor (i = 0; i < dev->data->nb_queue_pairs; i++) {\n+\t\tret = nitrox_comp_queue_pair_release(dev, i);\n+\t\tif (ret)\n+\t\t\treturn ret;\n+\t}\n+\n \trte_mempool_free(comp_dev->xform_pool);\n \tcomp_dev->xform_pool = NULL;\n \treturn 0;\n@@ -148,13 +161,33 @@ static int nitrox_comp_dev_close(struct rte_compressdev *dev)\n static void nitrox_comp_stats_get(struct rte_compressdev *dev,\n \t\t\t\t struct rte_compressdev_stats *stats)\n {\n-\tRTE_SET_USED(dev);\n-\tRTE_SET_USED(stats);\n+\tint qp_id;\n+\n+\tfor (qp_id = 0; qp_id < dev->data->nb_queue_pairs; qp_id++) {\n+\t\tstruct nitrox_qp *qp = dev->data->queue_pairs[qp_id];\n+\n+\t\tif (!qp)\n+\t\t\tcontinue;\n+\n+\t\tstats->enqueued_count += qp->stats.enqueued_count;\n+\t\tstats->dequeued_count += qp->stats.dequeued_count;\n+\t\tstats->enqueue_err_count += qp->stats.enqueue_err_count;\n+\t\tstats->dequeue_err_count += qp->stats.dequeue_err_count;\n+\t}\n }\n \n static void nitrox_comp_stats_reset(struct rte_compressdev *dev)\n {\n-\tRTE_SET_USED(dev);\n+\tint qp_id;\n+\n+\tfor (qp_id = 0; qp_id < dev->data->nb_queue_pairs; qp_id++) {\n+\t\tstruct nitrox_qp *qp = dev->data->queue_pairs[qp_id];\n+\n+\t\tif (!qp)\n+\t\t\tcontinue;\n+\n+\t\tmemset(&qp->stats, 0, sizeof(qp->stats));\n+\t}\n }\n \n static void nitrox_comp_dev_info_get(struct rte_compressdev *dev,\n@@ -175,19 +208,80 @@ static int nitrox_comp_queue_pair_setup(struct rte_compressdev *dev,\n \t\t\t\t\tuint16_t qp_id,\n \t\t\t\t\tuint32_t max_inflight_ops, int socket_id)\n {\n-\tRTE_SET_USED(dev);\n-\tRTE_SET_USED(qp_id);\n-\tRTE_SET_USED(max_inflight_ops);\n-\tRTE_SET_USED(socket_id);\n-\treturn -1;\n+\tstruct nitrox_comp_device *comp_dev = dev->data->dev_private;\n+\tstruct nitrox_device *ndev = comp_dev->ndev;\n+\tstruct nitrox_qp *qp = NULL;\n+\tint err;\n+\n+\tNITROX_LOG(DEBUG, \"queue %d\\n\", qp_id);\n+\tif (qp_id >= ndev->nr_queues) {\n+\t\tNITROX_LOG(ERR, \"queue %u invalid, max queues supported %d\\n\",\n+\t\t\t qp_id, ndev->nr_queues);\n+\t\treturn -EINVAL;\n+\t}\n+\n+\tif (dev->data->queue_pairs[qp_id]) {\n+\t\terr = nitrox_comp_queue_pair_release(dev, qp_id);\n+\t\tif (err)\n+\t\t\treturn err;\n+\t}\n+\n+\tqp = rte_zmalloc_socket(\"nitrox PMD qp\", sizeof(*qp),\n+\t\t\t\tRTE_CACHE_LINE_SIZE,\n+\t\t\t\tsocket_id);\n+\tif (!qp) {\n+\t\tNITROX_LOG(ERR, \"Failed to allocate nitrox qp\\n\");\n+\t\treturn -ENOMEM;\n+\t}\n+\n+\tqp->type = NITROX_QUEUE_ZIP;\n+\tqp->qno = qp_id;\n+\terr = nitrox_qp_setup(qp, ndev->bar_addr, dev->data->name,\n+\t\t\t max_inflight_ops, ZIP_INSTR_SIZE,\n+\t\t\t socket_id);\n+\tif (unlikely(err))\n+\t\tgoto qp_setup_err;\n+\n+\tdev->data->queue_pairs[qp_id] = qp;\n+\tNITROX_LOG(DEBUG, \"queue %d setup done\\n\", qp_id);\n+\treturn 0;\n+\n+qp_setup_err:\n+\trte_free(qp);\n+\treturn err;\n }\n \n static int nitrox_comp_queue_pair_release(struct rte_compressdev *dev,\n \t\t\t\t\t uint16_t qp_id)\n {\n-\tRTE_SET_USED(dev);\n-\tRTE_SET_USED(qp_id);\n-\treturn 0;\n+\tstruct nitrox_comp_device *comp_dev = dev->data->dev_private;\n+\tstruct nitrox_device *ndev = comp_dev->ndev;\n+\tstruct nitrox_qp *qp;\n+\tint err;\n+\n+\tNITROX_LOG(DEBUG, \"queue %d\\n\", qp_id);\n+\tif (qp_id >= ndev->nr_queues) {\n+\t\tNITROX_LOG(ERR, \"queue %u invalid, max queues supported %d\\n\",\n+\t\t\t qp_id, ndev->nr_queues);\n+\t\treturn -EINVAL;\n+\t}\n+\n+\tqp = dev->data->queue_pairs[qp_id];\n+\tif (!qp) {\n+\t\tNITROX_LOG(DEBUG, \"queue %u already freed\\n\", qp_id);\n+\t\treturn 0;\n+\t}\n+\n+\tif (!nitrox_qp_is_empty(qp)) {\n+\t\tNITROX_LOG(ERR, \"queue %d not empty\\n\", qp_id);\n+\t\treturn -EAGAIN;\n+\t}\n+\n+\tdev->data->queue_pairs[qp_id] = NULL;\n+\terr = nitrox_qp_release(qp, ndev->bar_addr);\n+\trte_free(qp);\n+\tNITROX_LOG(DEBUG, \"queue %d release done\\n\", qp_id);\n+\treturn err;\n }\n \n static int nitrox_comp_private_xform_create(struct rte_compressdev *dev,\n", "prefixes": [ "5/7" ] }