Patch Detail
get:
Show a patch.
patch:
Update a patch.
put:
Update a patch.
GET /api/patches/126508/?format=api
{ "id": 126508, "url": "http://patches.dpdk.org/api/patches/126508/?format=api", "web_url": "http://patches.dpdk.org/project/dpdk/patch/20230425131516.3308612-2-vattunuru@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": "<20230425131516.3308612-2-vattunuru@marvell.com>", "list_archive_url": "https://inbox.dpdk.org/dev/20230425131516.3308612-2-vattunuru@marvell.com", "date": "2023-04-25T13:15:13", "name": "[v2,1/4] node: add pkt punt to kernel node", "commit_ref": null, "pull_url": null, "state": "superseded", "archived": true, "hash": "537ce8aa742c88f0b97ca253efa8282b8df2a23b", "submitter": { "id": 1277, "url": "http://patches.dpdk.org/api/people/1277/?format=api", "name": "Vamsi Krishna Attunuru", "email": "vattunuru@marvell.com" }, "delegate": { "id": 1, "url": "http://patches.dpdk.org/api/users/1/?format=api", "username": "tmonjalo", "first_name": "Thomas", "last_name": "Monjalon", "email": "thomas@monjalon.net" }, "mbox": "http://patches.dpdk.org/project/dpdk/patch/20230425131516.3308612-2-vattunuru@marvell.com/mbox/", "series": [ { "id": 27859, "url": "http://patches.dpdk.org/api/series/27859/?format=api", "web_url": "http://patches.dpdk.org/project/dpdk/list/?series=27859", "date": "2023-04-25T13:15:12", "name": "app: introduce testgraph application", "version": 2, "mbox": "http://patches.dpdk.org/series/27859/mbox/" } ], "comments": "http://patches.dpdk.org/api/patches/126508/comments/", "check": "success", "checks": "http://patches.dpdk.org/api/patches/126508/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 EB600429EB;\n\tTue, 25 Apr 2023 15:15:50 +0200 (CEST)", "from mails.dpdk.org (localhost [127.0.0.1])\n\tby mails.dpdk.org (Postfix) with ESMTP id 80EEA42BD9;\n\tTue, 25 Apr 2023 15:15:47 +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 3A5EA40ED6\n for <dev@dpdk.org>; Tue, 25 Apr 2023 15:15:45 +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 33P9EsIB013403; Tue, 25 Apr 2023 06:15:44 -0700", "from dc5-exch02.marvell.com ([199.233.59.182])\n by mx0a-0016f401.pphosted.com (PPS) with ESMTPS id 3q6c2f8vq0-1\n (version=TLSv1.2 cipher=ECDHE-RSA-AES256-SHA384 bits=256 verify=NOT);\n Tue, 25 Apr 2023 06:15:43 -0700", "from DC5-EXCH02.marvell.com (10.69.176.39) by DC5-EXCH02.marvell.com\n (10.69.176.39) with Microsoft SMTP Server (TLS) id 15.0.1497.48;\n Tue, 25 Apr 2023 06:15:42 -0700", "from maili.marvell.com (10.69.176.80) by DC5-EXCH02.marvell.com\n (10.69.176.39) with Microsoft SMTP Server id 15.0.1497.48 via Frontend\n Transport; Tue, 25 Apr 2023 06:15:42 -0700", "from localhost.localdomain (unknown [10.28.36.156])\n by maili.marvell.com (Postfix) with ESMTP id ECDF53F7058;\n Tue, 25 Apr 2023 06:15:39 -0700 (PDT)" ], "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=kYaAUYukWWxpoCw8YaCNyyjV5/HmP1gHgvjR6Ww37UI=;\n b=QzcBrhkX/82xsWNLkyunAZ1TdntVxmgkiJevMLIFzxcBH8GiVcd9yCr8Rp2MTNxK6gBL\n N0f7rnZqHiZLKjr/HVWb24gkdjLOXtH4IRuN5ct8qF6x08CwFauc0y99/YgrQ8sjdR9p\n eCfH2AzZurQkrIJNqwF2Qeh6bSoPsWIeqPV2fJfDGZjT4ZB9MSrGl1L5DZdy9WedZk+r\n R03zS+ltdmGHYkPIyxjWCxTVPEDdAYvMP6ow/a9i244TvPjotzwua6DU1xg3NjYpMjKc\n eY1n4jcBwB0JsxauMHkFCw57i0ynA2hzEquW/Kh4fPBvld+IfTU7dQ/7Td5hP8GZLDRO ww==", "From": "Vamsi Attunuru <vattunuru@marvell.com>", "To": "<dev@dpdk.org>, <thomas@monjalon.net>, <jerinj@marvell.com>", "CC": "<vattunuru@marvell.com>, <ndabilpuram@marvell.com>", "Subject": "[PATCH v2 1/4] node: add pkt punt to kernel node", "Date": "Tue, 25 Apr 2023 06:15:13 -0700", "Message-ID": "<20230425131516.3308612-2-vattunuru@marvell.com>", "X-Mailer": "git-send-email 2.25.1", "In-Reply-To": "<20230425131516.3308612-1-vattunuru@marvell.com>", "References": "<20230421060245.3136217-1-vattunuru@marvell.com>\n <20230425131516.3308612-1-vattunuru@marvell.com>", "MIME-Version": "1.0", "Content-Transfer-Encoding": "8bit", "Content-Type": "text/plain", "X-Proofpoint-GUID": "hg9jQCOw3HfF_CfqJKQDXZOk0HJoE2-5", "X-Proofpoint-ORIG-GUID": "hg9jQCOw3HfF_CfqJKQDXZOk0HJoE2-5", "X-Proofpoint-Virus-Version": "vendor=baseguard\n engine=ICAP:2.0.254,Aquarius:18.0.942,Hydra:6.0.573,FMLib:17.11.170.22\n definitions=2023-04-25_05,2023-04-25_01,2023-02-09_01", "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": "Patch adds a node to punt the packets to kernel over\na raw socket.\n\nSigned-off-by: Vamsi Attunuru <vattunuru@marvell.com>\n---\n doc/guides/prog_guide/graph_lib.rst | 10 +++\n lib/node/meson.build | 1 +\n lib/node/punt_kernel.c | 125 ++++++++++++++++++++++++++++\n lib/node/punt_kernel_priv.h | 36 ++++++++\n 4 files changed, 172 insertions(+)", "diff": "diff --git a/doc/guides/prog_guide/graph_lib.rst b/doc/guides/prog_guide/graph_lib.rst\nindex 1cfdc86433..b3b5b14827 100644\n--- a/doc/guides/prog_guide/graph_lib.rst\n+++ b/doc/guides/prog_guide/graph_lib.rst\n@@ -392,3 +392,13 @@ null\n ~~~~\n This node ignores the set of objects passed to it and reports that all are\n processed.\n+\n+punt_kernel\n+~~~~~~~~~~~\n+This node punts the packets to kernel using a raw socket interface. For sending\n+the received packets, raw socket uses the packet's destination IP address in\n+sockaddr_in address structure and node uses ``sendto`` function to send data\n+on the raw socket.\n+\n+Aftering sending the burst of packets to kernel, this node redirects the same\n+objects to pkt_drop node to free up the packet buffers.\ndiff --git a/lib/node/meson.build b/lib/node/meson.build\nindex dbdf673c86..48c2da73f7 100644\n--- a/lib/node/meson.build\n+++ b/lib/node/meson.build\n@@ -17,6 +17,7 @@ sources = files(\n 'null.c',\n 'pkt_cls.c',\n 'pkt_drop.c',\n+ 'punt_kernel.c',\n )\n headers = files('rte_node_ip4_api.h', 'rte_node_eth_api.h')\n # Strict-aliasing rules are violated by uint8_t[] to context size casts.\ndiff --git a/lib/node/punt_kernel.c b/lib/node/punt_kernel.c\nnew file mode 100644\nindex 0000000000..e5dd15b759\n--- /dev/null\n+++ b/lib/node/punt_kernel.c\n@@ -0,0 +1,125 @@\n+/* SPDX-License-Identifier: BSD-3-Clause\n+ * Copyright(C) 2023 Marvell International Ltd.\n+ */\n+\n+#include <fcntl.h>\n+#include <sys/ioctl.h>\n+#include <sys/socket.h>\n+#include <unistd.h>\n+\n+#include <rte_debug.h>\n+#include <rte_ethdev.h>\n+#include <rte_graph.h>\n+#include <rte_graph_worker.h>\n+#include <rte_ip.h>\n+\n+#include \"node_private.h\"\n+#include \"punt_kernel_priv.h\"\n+\n+static __rte_always_inline void\n+punt_kernel_process_mbuf(struct rte_node *node, struct rte_mbuf **mbufs, uint16_t cnt)\n+{\n+\tpunt_kernel_node_ctx_t *ctx = (punt_kernel_node_ctx_t *)node->ctx;\n+\tstruct sockaddr_in sin = {0};\n+\tstruct rte_ipv4_hdr *ip4;\n+\tsize_t len;\n+\tchar *buf;\n+\tint i;\n+\n+\tfor (i = 0; i < cnt; i++) {\n+\t\tip4 = rte_pktmbuf_mtod(mbufs[i], struct rte_ipv4_hdr *);\n+\t\tlen = rte_pktmbuf_data_len(mbufs[i]);\n+\t\tbuf = (char *)ip4;\n+\n+\t\tsin.sin_family = AF_INET;\n+\t\tsin.sin_port = 0;\n+\t\tsin.sin_addr.s_addr = ip4->dst_addr;\n+\n+\t\tif (sendto(ctx->sock, buf, len, 0, (struct sockaddr *)&sin, sizeof(sin)) < 0)\n+\t\t\tnode_err(\"punt_kernel\", \"Unable to send packets: %s\\n\", strerror(errno));\n+\t}\n+}\n+\n+static uint16_t\n+punt_kernel_node_process(struct rte_graph *graph __rte_unused, struct rte_node *node, void **objs,\n+\t\t\t uint16_t nb_objs)\n+{\n+\tstruct rte_mbuf **pkts = (struct rte_mbuf **)objs;\n+\tuint16_t obj_left = nb_objs;\n+\n+#define PREFETCH_CNT 4\n+\n+\twhile (obj_left >= 12) {\n+\t\t/* Prefetch next-next mbufs */\n+\t\trte_prefetch0(pkts[8]);\n+\t\trte_prefetch0(pkts[9]);\n+\t\trte_prefetch0(pkts[10]);\n+\t\trte_prefetch0(pkts[11]);\n+\n+\t\t/* Prefetch next mbuf data */\n+\t\trte_prefetch0(rte_pktmbuf_mtod_offset(pkts[4], void *, pkts[4]->l2_len));\n+\t\trte_prefetch0(rte_pktmbuf_mtod_offset(pkts[5], void *, pkts[5]->l2_len));\n+\t\trte_prefetch0(rte_pktmbuf_mtod_offset(pkts[6], void *, pkts[6]->l2_len));\n+\t\trte_prefetch0(rte_pktmbuf_mtod_offset(pkts[7], void *, pkts[7]->l2_len));\n+\n+\t\tpunt_kernel_process_mbuf(node, pkts, PREFETCH_CNT);\n+\n+\t\tobj_left -= PREFETCH_CNT;\n+\t\tpkts += PREFETCH_CNT;\n+\t}\n+\n+\twhile (obj_left > 0) {\n+\t\tpunt_kernel_process_mbuf(node, pkts, 1);\n+\n+\t\tobj_left--;\n+\t\tpkts++;\n+\t}\n+\n+\trte_node_next_stream_move(graph, node, PUNT_KERNEL_NEXT_PKT_DROP);\n+\n+\treturn nb_objs;\n+}\n+\n+static int\n+punt_kernel_node_init(const struct rte_graph *graph __rte_unused, struct rte_node *node)\n+{\n+\tpunt_kernel_node_ctx_t *ctx = (punt_kernel_node_ctx_t *)node->ctx;\n+\n+\tctx->sock = socket(AF_INET, SOCK_RAW, IPPROTO_RAW);\n+\tif (ctx->sock < 0)\n+\t\tnode_err(\"punt_kernel\", \"Unable to open RAW socket\\n\");\n+\n+\treturn 0;\n+}\n+\n+static void\n+punt_kernel_node_fini(const struct rte_graph *graph __rte_unused, struct rte_node *node)\n+{\n+\tpunt_kernel_node_ctx_t *ctx = (punt_kernel_node_ctx_t *)node->ctx;\n+\n+\tif (ctx->sock >= 0) {\n+\t\tclose(ctx->sock);\n+\t\tctx->sock = -1;\n+\t}\n+}\n+\n+static struct rte_node_register punt_kernel_node_base = {\n+\t.process = punt_kernel_node_process,\n+\t.name = \"punt_kernel\",\n+\n+\t.init = punt_kernel_node_init,\n+\t.fini = punt_kernel_node_fini,\n+\n+\t.nb_edges = PUNT_KERNEL_NEXT_MAX,\n+\t.next_nodes = {\n+\t\t\t[PUNT_KERNEL_NEXT_PKT_DROP] = \"pkt_drop\",\n+\t},\n+};\n+\n+struct rte_node_register *\n+punt_kernel_node_get(void)\n+{\n+\treturn &punt_kernel_node_base;\n+}\n+\n+RTE_NODE_REGISTER(punt_kernel_node_base);\ndiff --git a/lib/node/punt_kernel_priv.h b/lib/node/punt_kernel_priv.h\nnew file mode 100644\nindex 0000000000..25ba2072e7\n--- /dev/null\n+++ b/lib/node/punt_kernel_priv.h\n@@ -0,0 +1,36 @@\n+/* SPDX-License-Identifier: BSD-3-Clause\n+ * Copyright(C) 2023 Marvell International Ltd.\n+ */\n+\n+#ifndef __INCLUDE_PUNT_KERNEL_PRIV_H__\n+#define __INCLUDE_PUNT_KERNEL_PRIV_H__\n+\n+struct punt_kernel_node_elem;\n+struct punt_kernel_node_ctx;\n+typedef struct punt_kernel_node_elem punt_kernel_node_elem_t;\n+\n+/**\n+ * @internal\n+ *\n+ * PUNT Kernel node context structure.\n+ */\n+typedef struct punt_kernel_node_ctx {\n+\tint sock;\n+} punt_kernel_node_ctx_t;\n+\n+enum punt_kernel_next_nodes {\n+\tPUNT_KERNEL_NEXT_PKT_DROP,\n+\tPUNT_KERNEL_NEXT_MAX,\n+};\n+\n+/**\n+ * @internal\n+ *\n+ * Get the PUNT Kernel node.\n+ *\n+ * @return\n+ * Pointer to the PUNT Kernel node.\n+ */\n+struct rte_node_register *punt_kernel_node_get(void);\n+\n+#endif /* __INCLUDE_PUNT_KERNEL_PRIV_H__ */\n", "prefixes": [ "v2", "1/4" ] }