Patch Detail
get:
Show a patch.
patch:
Update a patch.
put:
Update a patch.
GET /api/patches/131823/?format=api
{ "id": 131823, "url": "http://patchwork.dpdk.org/api/patches/131823/?format=api", "web_url": "http://patchwork.dpdk.org/project/dpdk/patch/20230922081912.7090-3-bruce.richardson@intel.com/", "project": { "id": 1, "url": "http://patchwork.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": "<20230922081912.7090-3-bruce.richardson@intel.com>", "list_archive_url": "https://inbox.dpdk.org/dev/20230922081912.7090-3-bruce.richardson@intel.com", "date": "2023-09-22T08:19:09", "name": "[RFC,2/5] mempool: driver for mempools of mbufs on shared memory", "commit_ref": null, "pull_url": null, "state": "new", "archived": false, "hash": "eee52f2a74832cc179c7cb75ce74d2f18f6f8e45", "submitter": { "id": 20, "url": "http://patchwork.dpdk.org/api/people/20/?format=api", "name": "Bruce Richardson", "email": "bruce.richardson@intel.com" }, "delegate": { "id": 1, "url": "http://patchwork.dpdk.org/api/users/1/?format=api", "username": "tmonjalo", "first_name": "Thomas", "last_name": "Monjalon", "email": "thomas@monjalon.net" }, "mbox": "http://patchwork.dpdk.org/project/dpdk/patch/20230922081912.7090-3-bruce.richardson@intel.com/mbox/", "series": [ { "id": 29602, "url": "http://patchwork.dpdk.org/api/series/29602/?format=api", "web_url": "http://patchwork.dpdk.org/project/dpdk/list/?series=29602", "date": "2023-09-22T08:19:07", "name": "Using shared mempools for zero-copy IO proxying", "version": 1, "mbox": "http://patchwork.dpdk.org/series/29602/mbox/" } ], "comments": "http://patchwork.dpdk.org/api/patches/131823/comments/", "check": "success", "checks": "http://patchwork.dpdk.org/api/patches/131823/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 AAFD242612;\n\tFri, 22 Sep 2023 10:19:57 +0200 (CEST)", "from mails.dpdk.org (localhost [127.0.0.1])\n\tby mails.dpdk.org (Postfix) with ESMTP id BBEB8406B7;\n\tFri, 22 Sep 2023 10:19:45 +0200 (CEST)", "from mgamail.intel.com (mgamail.intel.com [192.55.52.93])\n by mails.dpdk.org (Postfix) with ESMTP id DBF0D402CF\n for <dev@dpdk.org>; Fri, 22 Sep 2023 10:19:42 +0200 (CEST)", "from fmsmga005.fm.intel.com ([10.253.24.32])\n by fmsmga102.fm.intel.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384;\n 22 Sep 2023 01:19:29 -0700", "from silpixa00401385.ir.intel.com ([10.237.214.14])\n by fmsmga005.fm.intel.com with ESMTP; 22 Sep 2023 01:19:28 -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=1695370783; x=1726906783;\n h=from:to:cc:subject:date:message-id:in-reply-to:\n references:mime-version:content-transfer-encoding;\n bh=U4rN/bJ0jMS4H1nA4okPsutu3C1ppa60frVKw3sTBsM=;\n b=bS1adXb9WKcVbwQDtCiWWRzScMNFw6Z8XeSy5S0vdBjkWeWZ+OR5QTYc\n xf7+b2yFDXVr6BAm3zmCuYbo+CDOcJP1srS5tO+GMD1yrYRedTcuPq2E6\n GKYjkP8bK+tyu9P9DT65Yh9R3naqMWY5Kcy8ViMV1TnMnmvyRkQczIemd\n OnSW3LFZunPJyMjUZY/VHKbZVVn7cpQxIXWwDP8canfKgiuVvR/Em09Yx\n bKRxOmv2IfuC1WNff+HP41XYC8A7LN3NHoaXqF+PHCgx/X7A7R6zD2jRh\n WLYkGJ7h7lxBxasrTYbP+N5FNjJH4/T2L58AgNj0VE7b30aQ8L5hKODMt A==;", "X-IronPort-AV": [ "E=McAfee;i=\"6600,9927,10840\"; a=\"378063968\"", "E=Sophos;i=\"6.03,167,1694761200\"; d=\"scan'208\";a=\"378063968\"", "E=McAfee;i=\"6600,9927,10840\"; a=\"1078281125\"", "E=Sophos;i=\"6.03,167,1694761200\"; d=\"scan'208\";a=\"1078281125\"" ], "X-ExtLoop1": "1", "From": "Bruce Richardson <bruce.richardson@intel.com>", "To": "dev@dpdk.org", "Cc": "Bruce Richardson <bruce.richardson@intel.com>", "Subject": "[RFC PATCH 2/5] mempool: driver for mempools of mbufs on shared\n memory", "Date": "Fri, 22 Sep 2023 09:19:09 +0100", "Message-Id": "<20230922081912.7090-3-bruce.richardson@intel.com>", "X-Mailer": "git-send-email 2.39.2", "In-Reply-To": "<20230922081912.7090-1-bruce.richardson@intel.com>", "References": "<20230922081912.7090-1-bruce.richardson@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": "This mempool driver can be used with the shared_mem bus driver to create\na pool of shared mbufs on a shared memory segment.\n\nSigned-off-by: Bruce Richardson <bruce.richardson@intel.com>\n---\n drivers/mempool/meson.build | 1 +\n drivers/mempool/shared_mem/meson.build | 10 +++\n drivers/mempool/shared_mem/shared_mem_mp.c | 94 ++++++++++++++++++++++\n 3 files changed, 105 insertions(+)\n create mode 100644 drivers/mempool/shared_mem/meson.build\n create mode 100644 drivers/mempool/shared_mem/shared_mem_mp.c", "diff": "diff --git a/drivers/mempool/meson.build b/drivers/mempool/meson.build\nindex dc88812585..4326bd0ea3 100644\n--- a/drivers/mempool/meson.build\n+++ b/drivers/mempool/meson.build\n@@ -8,6 +8,7 @@ drivers = [\n 'dpaa2',\n 'octeontx',\n 'ring',\n+ 'shared_mem',\n 'stack',\n ]\n \ndiff --git a/drivers/mempool/shared_mem/meson.build b/drivers/mempool/shared_mem/meson.build\nnew file mode 100644\nindex 0000000000..ee740ccdc9\n--- /dev/null\n+++ b/drivers/mempool/shared_mem/meson.build\n@@ -0,0 +1,10 @@\n+# SPDX-License-Identifier: BSD-3-Clause\n+# Copyright(c) 2023 Intel Corporation\n+\n+if is_windows\n+ build = false\n+ reason = 'not supported on Windows'\n+endif\n+sources = files('shared_mem_mp.c')\n+require_iova_in_mbuf = false\n+deps += ['stack', 'bus_shared_mem']\ndiff --git a/drivers/mempool/shared_mem/shared_mem_mp.c b/drivers/mempool/shared_mem/shared_mem_mp.c\nnew file mode 100644\nindex 0000000000..7dae8aba92\n--- /dev/null\n+++ b/drivers/mempool/shared_mem/shared_mem_mp.c\n@@ -0,0 +1,94 @@\n+/* SPDX-License-Identifier: BSD-3-Clause\n+ * Copyright(c) 2023 Intel Corporation\n+ */\n+#include <sys/types.h>\n+#include <rte_mbuf.h>\n+#include <rte_stack.h>\n+#include <rte_mempool.h>\n+#include <shared_mem_bus.h>\n+\n+RTE_LOG_REGISTER_DEFAULT(shared_mem_mp_log, DEBUG);\n+#define MP_LOG(level, fmt, args...) rte_log(RTE_LOG_ ## level, \\\n+\t\tshared_mem_mp_log, \"## SHARED MP: %s(): \" fmt \"\\n\", __func__, ##args)\n+#define MP_ERR(fmt, args...) MP_LOG(ERR, fmt, ## args)\n+#define MP_INFO(fmt, args...) MP_LOG(INFO, fmt, ## args)\n+#define MP_DEBUG(fmt, args...) MP_LOG(DEBUG, fmt, ## args)\n+\n+static int\n+shm_mp_alloc(struct rte_mempool *mp)\n+{\n+\tchar name[RTE_STACK_NAMESIZE];\n+\tstruct rte_stack *s;\n+\tint ret;\n+\n+\tret = snprintf(name, sizeof(name), RTE_MEMPOOL_MZ_FORMAT, mp->name);\n+\tif (ret < 0 || ret >= (int)sizeof(name)) {\n+\t\trte_errno = ENAMETOOLONG;\n+\t\treturn -rte_errno;\n+\t}\n+\n+\ts = rte_stack_create(name, mp->size, mp->socket_id, 0);\n+\tif (s == NULL)\n+\t\treturn -rte_errno;\n+\tMP_DEBUG(\"Stack created at address: %p\", s);\n+\n+\tmp->pool_data = s;\n+\n+\treturn 0;\n+}\n+\n+static int\n+shm_mp_enqueue(struct rte_mempool *mp, void * const *obj_table,\n+\t unsigned int n)\n+{\n+\tstruct rte_stack *s = mp->pool_data;\n+\n+\tvoid *offset_table[n];\n+\tuintptr_t mempool_base = (uintptr_t)rte_shm_bus_get_mem_ptr(0); /* offset 0 == base addr */\n+\tfor (uint i = 0; i < n; i++)\n+\t\toffset_table[i] = RTE_PTR_SUB(obj_table[i], mempool_base);\n+\n+\treturn rte_stack_push(s, offset_table, n) == 0 ? -ENOBUFS : 0;\n+}\n+\n+static int\n+shm_mp_dequeue(struct rte_mempool *mp, void **obj_table,\n+\t unsigned int n)\n+{\n+\tstruct rte_stack *s = mp->pool_data;\n+\tuintptr_t mempool_base = (uintptr_t)rte_shm_bus_get_mem_ptr(0); /* offset 0 == base addr */\n+\tuint16_t priv_size = rte_pktmbuf_priv_size(mp);\n+\n+\tif (rte_stack_pop(s, obj_table, n) == 0)\n+\t\treturn -ENOBUFS;\n+\tfor (uint i = 0; i < n; i++) {\n+\t\tobj_table[i] = RTE_PTR_ADD(obj_table[i], mempool_base);\n+\t\tstruct rte_mbuf *mb = obj_table[i];\n+\t\tmb->buf_addr = RTE_PTR_ADD(mb, sizeof(struct rte_mbuf) + priv_size);\n+\t\tmb->pool = mp;\n+\t}\n+\treturn 0;\n+}\n+\n+static unsigned\n+shm_mp_get_count(const struct rte_mempool *mp)\n+{\n+\treturn rte_stack_count(mp->pool_data);\n+}\n+\n+static void\n+shm_mp_free(struct rte_mempool *mp)\n+{\n+\trte_stack_free(mp->pool_data);\n+}\n+\n+static struct rte_mempool_ops ops_shared_mem_mp = {\n+\t.name = \"shared_mem\",\n+\t.alloc = shm_mp_alloc,\n+\t.free = shm_mp_free,\n+\t.enqueue = shm_mp_enqueue,\n+\t.dequeue = shm_mp_dequeue,\n+\t.get_count = shm_mp_get_count,\n+};\n+\n+RTE_MEMPOOL_REGISTER_OPS(ops_shared_mem_mp);\n", "prefixes": [ "RFC", "2/5" ] }