Patch Detail
get:
Show a patch.
patch:
Update a patch.
put:
Update a patch.
GET /api/patches/41102/?format=api
{ "id": 41102, "url": "http://patches.dpdk.org/api/patches/41102/?format=api", "web_url": "http://patches.dpdk.org/project/dpdk/patch/1528971477-14156-8-git-send-email-anoob.joseph@caviumnetworks.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": "<1528971477-14156-8-git-send-email-anoob.joseph@caviumnetworks.com>", "list_archive_url": "https://inbox.dpdk.org/dev/1528971477-14156-8-git-send-email-anoob.joseph@caviumnetworks.com", "date": "2018-06-14T10:17:49", "name": "[v1,07/15] examples/l2fwd: move dataplane code to new file", "commit_ref": null, "pull_url": null, "state": "superseded", "archived": true, "hash": "386666e133a83d414c83e1bb32a2c5ce862912ef", "submitter": { "id": 893, "url": "http://patches.dpdk.org/api/people/893/?format=api", "name": "Anoob Joseph", "email": "anoob.joseph@caviumnetworks.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/1528971477-14156-8-git-send-email-anoob.joseph@caviumnetworks.com/mbox/", "series": [ { "id": 121, "url": "http://patches.dpdk.org/api/series/121/?format=api", "web_url": "http://patches.dpdk.org/project/dpdk/list/?series=121", "date": "2018-06-14T10:17:42", "name": "preparing l2fwd for eventmode additions", "version": 1, "mbox": "http://patches.dpdk.org/series/121/mbox/" } ], "comments": "http://patches.dpdk.org/api/patches/41102/comments/", "check": "success", "checks": "http://patches.dpdk.org/api/patches/41102/checks/", "tags": {}, "related": [], "headers": { "Return-Path": "<dev-bounces@dpdk.org>", "X-Original-To": "patchwork@dpdk.org", "Delivered-To": "patchwork@dpdk.org", "Received": [ "from [92.243.14.124] (localhost [127.0.0.1])\n\tby dpdk.org (Postfix) with ESMTP id 099B41E9BA;\n\tThu, 14 Jun 2018 12:19:14 +0200 (CEST)", "from NAM04-CO1-obe.outbound.protection.outlook.com\n\t(mail-eopbgr690056.outbound.protection.outlook.com [40.107.69.56])\n\tby dpdk.org (Postfix) with ESMTP id 4753F1E9B5\n\tfor <dev@dpdk.org>; Thu, 14 Jun 2018 12:19:12 +0200 (CEST)", "from ajoseph83.caveonetworks.com.caveonetworks.com (115.113.156.2)\n\tby BYAPR07MB4902.namprd07.prod.outlook.com (2603:10b6:a02:ef::25)\n\twith Microsoft SMTP Server (version=TLS1_2,\n\tcipher=TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384) id 15.20.841.19;\n\tThu, 14 Jun 2018 10:19:08 +0000" ], "DKIM-Signature": "v=1; a=rsa-sha256; c=relaxed/relaxed;\n\td=CAVIUMNETWORKS.onmicrosoft.com; s=selector1-cavium-com;\n\th=From:Date:Subject:Message-ID:Content-Type:MIME-Version:X-MS-Exchange-SenderADCheck;\n\tbh=SJnEqS1MT9WU1Jk8C5neU/7z7SEWftzUXtR3syKlW38=;\n\tb=j1AhQYVtUJ3ihVue5mdl2Dvq6NzgQ0JTunEqGGYGk0ZCbXxIfuxQfgm0tQHtWmagtbfSJjEln+z+mDUq9CloGvyRgtZt9dNnJYEqIzAfGYB0XDSTSTDJdaCtg5diVVti6vzt7ZjaoHIQkgNfsjjWtFa0mh7mtXVs9/LkFlpEPr4=", "Authentication-Results": "spf=none (sender IP is )\n\tsmtp.mailfrom=Anoob.Joseph@cavium.com; ", "From": "Anoob Joseph <anoob.joseph@caviumnetworks.com>", "To": "Bruce Richardson <bruce.richardson@intel.com>,\n\tPablo de Lara <pablo.de.lara.guarch@intel.com>", "Cc": "Anoob Joseph <anoob.joseph@caviumnetworks.com>,\n\tJerin Jacob <jerin.jacob@caviumnetworks.com>,\n\tNarayana Prasad <narayanaprasad.athreya@caviumnetworks.com>, dev@dpdk.org", "Date": "Thu, 14 Jun 2018 15:47:49 +0530", "Message-Id": "<1528971477-14156-8-git-send-email-anoob.joseph@caviumnetworks.com>", "X-Mailer": "git-send-email 2.7.4", "In-Reply-To": "<1528971477-14156-1-git-send-email-anoob.joseph@caviumnetworks.com>", "References": "<1528477766-15788-1-git-send-email-anoob.joseph@caviumnetworks.com>\n\t<1528971477-14156-1-git-send-email-anoob.joseph@caviumnetworks.com>", "MIME-Version": "1.0", "Content-Type": "text/plain", "X-Originating-IP": "[115.113.156.2]", "X-ClientProxiedBy": "BM1PR0101CA0031.INDPRD01.PROD.OUTLOOK.COM\n\t(2603:1096:b00:1a::17) To BYAPR07MB4902.namprd07.prod.outlook.com\n\t(2603:10b6:a02:ef::25)", "X-MS-PublicTrafficType": "Email", "X-MS-Office365-Filtering-Correlation-Id": "673f9480-9ebf-4ad8-ebfb-08d5d1e04518", "X-Microsoft-Antispam": "UriScan:; BCL:0; PCL:0;\n\tRULEID:(7020095)(4652020)(5600026)(711020)(4534165)(7168020)(4627221)(201703031133081)(201702281549075)(2017052603328)(7153060)(7193020);\n\tSRVR:BYAPR07MB4902; ", "X-Microsoft-Exchange-Diagnostics": [ "1; BYAPR07MB4902;\n\t3:qn7fpx15CikBPEv9of9nF0t7BYr//Vi5ENcUHKp08aD7ycx2x6fFDhec+Ol35ZdiwL1lC/irA28B/aHFflPal7jMHgXUhqXurUEuTRYi+G6Ejt2JYk07FK1nwxZ0zwgxQMPhA+rYc/SEB5I19xrUt0fgDsnDmPlYkS6Usdu52LrFh+bGoSr9XEPeuZxVSwyHzXEOStsreNM/f7cUSAHxPYj1U7inVkK6C+8o4F+fFESm2Po+FsZ2/e7AObVeKNOp;\n\t25:LvCtdvftzKmmf9bxxB0FI0+b6pXJXfK+qWK8Fec1J6sUzWMLblbc1NPmTp9yUNXI11y38wbY5I6NYpkytX1l5lxhzWRfFIXzM+ir9aghaQjr3OEexn38ebrLeH08Ej+i4KEFdjXQG4DYrcbnPdwQwBFSAq9Weugo238pFwwZM/XfE5AHKXDCt2xG67yQlH2lc/tX0CYFD/dhBwixyF/1+L7BFtnyWJ9W+Jybh6J1jQL9HrnhimL50EyYIUovNmxu4cIX5VjnYnYCqMaKh2aibJmskY4ReQYtxRAv9C7+aieaEAG4g4T+l63npU19SQt72BsF84Mjv+rhjKhe0l/xmg==;\n\t31:HG2I+8+i91cOwaZYf3C5fXe7EpVOIub1emON+YTAazcQ39IpcIuZmBSvY62kdWUK5pUD4hyWF0T7urpd4J3nP9ZdyCL5o5k96LEPr3KMoDsRhaw77P8r27d0o7zrs0vWnB4aEjU6t0MeJSbbvccc6CLF3NF71WFimkAT0Lm553kGGwopC0WFbnI/VZszkIJAuFKjt/g2sEPJwyv2oxUZvrF9ERVsIvlSA1MNDOYj86k=", "1; BYAPR07MB4902;\n\t20:t2Pjbzea2YjQp9q+EK4HiNi2GXhMHwxy4iAnk8zGR+1NviQfAfAY8O8Wd9aP2ydIeTFczxwVP7dlqH0E8qX00CoLOuPZTBIN9S2JR218D/hPnlHE9qRjHuPmQJfmbr351cwaJRZJa+GxKgmXSuQTdO8A9GsEbtxqaU7gZbZsqQw5hTflhZuystCfc7Xj8+atB998PbxVaivRfaqyxA4vGED7jVOd+AFaIkXA95pTNnoH1QY9O2SVaEvgvzidzGR3Fb6lfRD6Mo9H4HocoQh6kY/UqIWhSyjF8u/c5OJp6E/FWvIDwN0mkVvSTPF1s1QkMztdtHGp/3PNKFqdCs5H1T4ywJkorh1/VEmkaVRzswMnTCgDIKhV5DCqvbwofeNa0TYIXP8eNw8srI3vH5QUNuZxlHajmIT6zc6vO6ZA4OkRHkkS5TV97Q3dcNrNtb7SMC/AKnYsC7w9bH8UwHkYjqAO/GkdHTtBpBDCNfPHwX81oUemwVqjmXB3fCKmnSwEhAB9wH9ZilKXo0vCbAVT1bk7yO11d3EJez9s3WK5uRhRGco05Vg8iE8xhpCW+UE3Bi1ficWPZa1RXQviS/bhSFiRiQOdJcsQw7STWEQAnGo=;\n\t4:AOMRxfkRbXuHRnW8e5l/B3wMRcyFCmZRE1lmgqU2RsXBPLLgP2ePj7A0Irw/3QngOHxRbd/SYvdXncyNoU9aKneoX+X1OFK67WhUDi3Sir+vhj7DmRGeiZ1N2zY7z/9trnHyfjC5oaAXtjdwfBDkd8A99LjfS+74TzJUQXOBenjL6ydeIh16fQwS1p/YI53a9JWWodS/vhuI3Bgv2VHsVRJIRcJtyV+kShK1z/zT7bMFvSlvChyIvjpRnTKDGfFx2V1lZahafaw9u7cMk6vi4A==", "=?us-ascii?Q?1; BYAPR07MB4902;\n\t23:LTGagn4vrUxiqsJooWt6cJBan0SqQ6XAbH3l84fOl?=\n\tPFcecY09aasoO0eKmZeLMwxSLvG3lJJ9kJkayZfnDmJCz8Pv9COfV6/2tD0+oSgp8e9xrgCdXkZeaHGMZVYIw0oAD3hYs7F5SmO8VfNuonbUlQYd+v/X7WPmvUNz+OvT5at/Fjm6DnVNFfkr3eS/j7FqsWIKBjqZoIa+OiroiWVnaZcbyNdvxb9wEXUNV7c0pIA+Gx1VBTuN2bzi0PKGl4Hs7Nc4AjO9IAWYzeXmsn/2kOz/8pWSoz6G+klL10aH9X5b3UV108sgfAo/wToBzSSnkEL87LzUX0SGBXCK65d6KqxWYSN8XOk3m2QVs3P1UCqnJYz+3nhPO93oiQqaPf0Ve5hhWbyGS1q3WaYPUIYzP1khizOc/yJsHxBedmkSxRva+mlfcA264AvvwRETZahyqGyOmcmQVkUqwrN9/QlzVasPHPSC/VFRJ/Sw0RBmN2E/Nlfpthr/YrVMuvank7MD9PMAmYJJ8vG/2BS+aYc++f7GcJIPl2VnHszpQDcD0ecZIXw0G4Y9t4OKLvOugFlnsnOYVR2cHI7H32o2XXrXleTzDvNdr+4gfUTQAoQULZq7bkzJ+PfD/EdPNkua0Qdpip08qdABwRehUWRR0U2ZjjWGF48UELzGOU96F7+g9DBkU1qlK2+Epf6xWw7pTlBlN2ExED5gAodYWPH/pWnTY/4cLzp4DB+oO89g3mF/nAyRKon9LBWw439XLYNe5a702Oi0fCx8Oj5nW73ui2LTzlQ8HAzs3mGoqkQQpWyNIAg+KsJcpEqCntNsAVeUz8nEzwdwXmMnenCrT2BgkMAntjXoDTKhkZ2GxdQM/gWg3N11UUoTATPOizF0D0h9MFILzZTEtJIPasOyRIVG0gSeChjMKIwNIbywOF4CSThhcrJXhYIs25hRH589FBSNwSc1eVqziyXLSI7wfTJMHW2o5kVEvxKeXLDCH8irjXqf3dz9Iv+hUfYkElCgxKhfMXZ9eQRLoGjWejnv2Lt11/0CTECySP4om1mX+nlZPQrC1kYT81VAtgP/gKKa0NJkiMyK3v9m9bcjsC0/zJMmKO4wTaDiwUN+pXfmqKmM//VytfLFGoDOIi+0OlWneq6VtRALEoyaVNansqTm1wFl1UPa8K1+47cJfZqMooxk99GJA70tmJyBWU8Uht044IElhn3WfXDkmd20i4ifns5S1btrHn2rQlkKlJT5pi/kfB+nygnkCjMHq/JV2YjkeRsRj4r7m6ylvaopmcOX2zWRj3f/g==", "1; BYAPR07MB4902;\n\t6:dVLO8W4r2aGPaByymTgMgSy8gAVid5UoBNoq5M66X7rQ4e07Lvf7jfmTSNQQ8oYP59ViNcgfu/+nKGFXcsO37zOv1FryOM+ssxn+t8GnP7Gs576KLBGB6/G8YgyCL6YZQnJIDw82ipN5maEqCU89soY/BVlZGXFhtkiW5Dpta+PD3H18ithQySf2EZHtaNp9zCRrFuY69NF/bJFAr9hWhHBqKqb/Ut1h+8e2/cMBCCJtGBVU9gTb0U3ZF/iOSW3o7U02xyxzjRnWuQEoHlAqoqL+1VCpHj7QfPp/k8aWIoPXiQgrS3xDZnBM2zDJ+3E+aQOyZ4cM9nI1LO8ap6CQHgWRMnCIFH/wlZtioGHrxN6vGZej8Z8uPmfU+AvJoOqPaUUHEasIDpjHQ+IuuvZUfGh/FpGQtXHIKCsjViOkB410RXRxbzc40a0s5gA/an7L0cjsHTEgk7P6Synj4sxfOg==;\n\t5:5r+tqKTRFfSkwqRfLLn2zy8uQTX+BiJ1R/USod39+EbXoQAjensELfp8fYpqGexZHDPS7ifJVAe0zLjUJ0/xA9eBQt6qN5OqCF+SarYmhvY2Bdkoh1+4EbMpI3kZQwHDylmW41rqGc2K+IUAhJO1INLkXOsAEyfqwti+7iJCwcs=;\n\t24:pG15HcBMZBh1uViiLVEK0ZnppypHnEqrsannx3dHgBb6TabutumPIsSHS1NH/F36+YGHDwvUBpB/gvwjhsGAkmn8BXV8tVtvAjcSHwdnUM0=", "1; BYAPR07MB4902;\n\t7:yyrtvoJKUK0DP8W1oHmdttIUsO87MbkMKiJgxUQWiMpYXvW0ins8cJqFpwCKfxPteLgkZmCKNkP4UY9/D90Dpy+oZCtKopWmseAwQGtgWolz1H9W+guX/9tgOZ43OUx50Nt5fKRkS/WE538eNBlzLRqco6gocgiCp3SLHMcVwBwYENULO0etLki6YYagSYCd1AgdBoOvOBVYpEq/vvMeHm268lmRyKMWTjswrAWYIJ24UFsZHHEPLaoCJCv5np4u" ], "X-MS-TrafficTypeDiagnostic": "BYAPR07MB4902:", "X-Microsoft-Antispam-PRVS": "<BYAPR07MB4902EF9200D5D48C48EBF8E5F87D0@BYAPR07MB4902.namprd07.prod.outlook.com>", "X-Exchange-Antispam-Report-Test": "UriScan:;", "X-MS-Exchange-SenderADCheck": "1", "X-Exchange-Antispam-Report-CFA-Test": "BCL:0; PCL:0;\n\tRULEID:(8211001083)(6040522)(2401047)(5005006)(8121501046)(3231254)(944501410)(52105095)(10201501046)(93006095)(3002001)(149027)(150027)(6041310)(20161123562045)(20161123564045)(201703131423095)(201702281528075)(20161123555045)(201703061421075)(201703061406153)(20161123560045)(20161123558120)(6072148)(201708071742011)(7699016);\n\tSRVR:BYAPR07MB4902; BCL:0; PCL:0; RULEID:; SRVR:BYAPR07MB4902; ", "X-Forefront-PRVS": "0703B549E4", "X-Forefront-Antispam-Report": "SFV:NSPM;\n\tSFS:(10009020)(346002)(39860400002)(39380400002)(376002)(396003)(366004)(189003)(199004)(316002)(6666003)(110136005)(68736007)(2906002)(66066001)(54906003)(47776003)(6512007)(5660300001)(50466002)(72206003)(48376002)(97736004)(6116002)(3846002)(53936002)(16586007)(105586002)(478600001)(6486002)(106356001)(6506007)(36756003)(59450400001)(11346002)(956004)(25786009)(4326008)(50226002)(16526019)(186003)(81156014)(486006)(81166006)(8676002)(7736002)(26005)(8936002)(2616005)(476003)(386003)(44832011)(55236004)(52116002)(42882007)(51416003)(76176011)(446003)(305945005);\n\tDIR:OUT; SFP:1101; SCL:1; SRVR:BYAPR07MB4902;\n\tH:ajoseph83.caveonetworks.com.caveonetworks.com; FPR:; SPF:None;\n\tLANG:en; PTR:InfoNoRecords; MX:1; A:1; ", "Received-SPF": "None (protection.outlook.com: cavium.com does not designate\n\tpermitted sender hosts)", "X-Microsoft-Antispam-Message-Info": "tJcEikPkMLF094Sb7sJOZDyzJ0/GKPHDvwV+EMcjIN4iZt1deHIsXAfe+BM1XCfXUFit0oUGo+N06q5ZoppKQX5MsuzfN73hT4cWBatP8/t9F4kB+PsxwkP5VPIR/CWVoJt+nMqhPRso9D4JWcINAmW98SC9y/cKeXBPpolHNhK+4syfVpld5phDD6vZdQpg", "SpamDiagnosticOutput": "1:99", "SpamDiagnosticMetadata": "NSPM", "X-OriginatorOrg": "caviumnetworks.com", "X-MS-Exchange-CrossTenant-OriginalArrivalTime": "14 Jun 2018 10:19:08.1627\n\t(UTC)", "X-MS-Exchange-CrossTenant-Network-Message-Id": "673f9480-9ebf-4ad8-ebfb-08d5d1e04518", "X-MS-Exchange-CrossTenant-FromEntityHeader": "Hosted", "X-MS-Exchange-CrossTenant-Id": "711e4ccf-2e9b-4bcf-a551-4094005b6194", "X-MS-Exchange-Transport-CrossTenantHeadersStamped": "BYAPR07MB4902", "Subject": "[dpdk-dev] [PATCH v1 07/15] examples/l2fwd: move dataplane code to\n\tnew file", "X-BeenThere": "dev@dpdk.org", "X-Mailman-Version": "2.1.15", "Precedence": "list", "List-Id": "DPDK patches and discussions <dev.dpdk.org>", "List-Unsubscribe": "<https://dpdk.org/ml/options/dev>,\n\t<mailto:dev-request@dpdk.org?subject=unsubscribe>", "List-Archive": "<http://dpdk.org/ml/archives/dev/>", "List-Post": "<mailto:dev@dpdk.org>", "List-Help": "<mailto:dev-request@dpdk.org?subject=help>", "List-Subscribe": "<https://dpdk.org/ml/listinfo/dev>,\n\t<mailto:dev-request@dpdk.org?subject=subscribe>", "Errors-To": "dev-bounces@dpdk.org", "Sender": "\"dev\" <dev-bounces@dpdk.org>" }, "content": "v1:\n* Replaced 'unsigned' with 'unsigned int'\n\nSigned-off-by: Anoob Joseph <anoob.joseph@caviumnetworks.com>\n---\n examples/l2fwd/Makefile | 1 +\n examples/l2fwd/l2fwd_worker.c | 233 ++++++++++++++++++++++++++++++++++++++++++\n examples/l2fwd/l2fwd_worker.h | 10 ++\n examples/l2fwd/main.c | 191 +---------------------------------\n 4 files changed, 245 insertions(+), 190 deletions(-)\n create mode 100644 examples/l2fwd/l2fwd_worker.c\n create mode 100644 examples/l2fwd/l2fwd_worker.h", "diff": "diff --git a/examples/l2fwd/Makefile b/examples/l2fwd/Makefile\nindex a8a47ad..24d1e4e 100644\n--- a/examples/l2fwd/Makefile\n+++ b/examples/l2fwd/Makefile\n@@ -6,6 +6,7 @@ APP = l2fwd\n \n # all source are stored in SRCS-y\n SRCS-y := main.c\n+SRCS-y += l2fwd_worker.c\n \n # Build using pkg-config variables if possible\n $(shell pkg-config --exists libdpdk)\ndiff --git a/examples/l2fwd/l2fwd_worker.c b/examples/l2fwd/l2fwd_worker.c\nnew file mode 100644\nindex 0000000..663c505\n--- /dev/null\n+++ b/examples/l2fwd/l2fwd_worker.c\n@@ -0,0 +1,233 @@\n+/* SPDX-License-Identifier: BSD-3-Clause\n+ * Copyright(c) 2010-2016 Intel Corporation\n+ * Copyright(c) 2018 Cavium, Inc\n+ */\n+#include <stdio.h>\n+#include <stdlib.h>\n+#include <string.h>\n+#include <stdint.h>\n+#include <inttypes.h>\n+#include <sys/types.h>\n+#include <sys/queue.h>\n+#include <netinet/in.h>\n+#include <setjmp.h>\n+#include <stdarg.h>\n+#include <ctype.h>\n+#include <errno.h>\n+#include <getopt.h>\n+#include <signal.h>\n+#include <stdbool.h>\n+\n+#include <rte_common.h>\n+#include <rte_log.h>\n+#include <rte_malloc.h>\n+#include <rte_memory.h>\n+#include <rte_memcpy.h>\n+#include <rte_eal.h>\n+#include <rte_launch.h>\n+#include <rte_atomic.h>\n+#include <rte_cycles.h>\n+#include <rte_prefetch.h>\n+#include <rte_lcore.h>\n+#include <rte_per_lcore.h>\n+#include <rte_branch_prediction.h>\n+#include <rte_interrupts.h>\n+#include <rte_random.h>\n+#include <rte_debug.h>\n+#include <rte_ether.h>\n+#include <rte_ethdev.h>\n+#include <rte_mempool.h>\n+#include <rte_mbuf.h>\n+\n+#include \"l2fwd_common.h\"\n+#include \"l2fwd_worker.h\"\n+\n+/* Print out statistics on packets dropped */\n+static void\n+print_stats(void)\n+{\n+\tuint64_t total_packets_dropped, total_packets_tx, total_packets_rx;\n+\tunsigned int portid;\n+\n+\ttotal_packets_dropped = 0;\n+\ttotal_packets_tx = 0;\n+\ttotal_packets_rx = 0;\n+\n+\tconst char clr[] = { 27, '[', '2', 'J', '\\0' };\n+\tconst char topLeft[] = { 27, '[', '1', ';', '1', 'H', '\\0' };\n+\n+\t\t/* Clear screen and move to top left */\n+\tprintf(\"%s%s\", clr, topLeft);\n+\n+\tprintf(\"\\nPort statistics ====================================\");\n+\n+\tfor (portid = 0; portid < RTE_MAX_ETHPORTS; portid++) {\n+\t\t/* skip disabled ports */\n+\t\tif ((l2fwd_enabled_port_mask & (1 << portid)) == 0)\n+\t\t\tcontinue;\n+\t\tprintf(\"\\nStatistics for port %u ------------------------------\"\n+\t\t\t \"\\nPackets sent: %24\"PRIu64\n+\t\t\t \"\\nPackets received: %20\"PRIu64\n+\t\t\t \"\\nPackets dropped: %21\"PRIu64,\n+\t\t\t portid,\n+\t\t\t port_statistics[portid].tx,\n+\t\t\t port_statistics[portid].rx,\n+\t\t\t port_statistics[portid].dropped);\n+\n+\t\ttotal_packets_dropped += port_statistics[portid].dropped;\n+\t\ttotal_packets_tx += port_statistics[portid].tx;\n+\t\ttotal_packets_rx += port_statistics[portid].rx;\n+\t}\n+\tprintf(\"\\nAggregate statistics ===============================\"\n+\t\t \"\\nTotal packets sent: %18\"PRIu64\n+\t\t \"\\nTotal packets received: %14\"PRIu64\n+\t\t \"\\nTotal packets dropped: %15\"PRIu64,\n+\t\t total_packets_tx,\n+\t\t total_packets_rx,\n+\t\t total_packets_dropped);\n+\tprintf(\"\\n====================================================\\n\");\n+}\n+\n+static void\n+l2fwd_mac_updating(struct rte_mbuf *m, unsigned int dest_portid)\n+{\n+\tstruct ether_hdr *eth;\n+\tvoid *tmp;\n+\n+\teth = rte_pktmbuf_mtod(m, struct ether_hdr *);\n+\n+\t/* 02:00:00:00:00:xx */\n+\ttmp = ð->d_addr.addr_bytes[0];\n+\t*((uint64_t *)tmp) = 0x000000000002 + ((uint64_t)dest_portid << 40);\n+\n+\t/* src addr */\n+\tether_addr_copy(&l2fwd_ports_eth_addr[dest_portid], ð->s_addr);\n+}\n+\n+static void\n+l2fwd_simple_forward(struct rte_mbuf *m, unsigned int portid)\n+{\n+\tunsigned int dst_port;\n+\tint sent;\n+\tstruct rte_eth_dev_tx_buffer *buffer;\n+\n+\tdst_port = l2fwd_dst_ports[portid];\n+\n+\tif (mac_updating)\n+\t\tl2fwd_mac_updating(m, dst_port);\n+\n+\tbuffer = tx_buffer[dst_port];\n+\tsent = rte_eth_tx_buffer(dst_port, 0, buffer, m);\n+\tif (sent)\n+\t\tport_statistics[dst_port].tx += sent;\n+}\n+\n+/* main processing loop */\n+static void\n+l2fwd_main_loop(void)\n+{\n+\tstruct rte_mbuf *pkts_burst[MAX_PKT_BURST];\n+\tstruct rte_mbuf *m;\n+\tint sent;\n+\tunsigned int lcore_id;\n+\tunsigned int master_core_id;\n+\tuint64_t prev_tsc, diff_tsc, cur_tsc, timer_tsc;\n+\tunsigned int i, j, portid, nb_rx;\n+\tstruct lcore_queue_conf *qconf;\n+\tconst uint64_t drain_tsc = (rte_get_tsc_hz() + US_PER_S - 1)\n+\t\t\t/ US_PER_S * BURST_TX_DRAIN_US;\n+\tstruct rte_eth_dev_tx_buffer *buffer;\n+\n+\tprev_tsc = 0;\n+\ttimer_tsc = 0;\n+\n+\tlcore_id = rte_lcore_id();\n+\tqconf = &lcore_queue_conf[lcore_id];\n+\n+\tif (qconf->n_rx_port == 0) {\n+\t\tRTE_LOG(INFO, L2FWD, \"lcore %u has nothing to do\\n\", lcore_id);\n+\t\treturn;\n+\t}\n+\n+\tRTE_LOG(INFO, L2FWD, \"entering main loop on lcore %u\\n\", lcore_id);\n+\n+\tfor (i = 0; i < qconf->n_rx_port; i++) {\n+\n+\t\tportid = qconf->rx_port_list[i];\n+\t\tRTE_LOG(INFO, L2FWD, \" -- lcoreid=%u portid=%u\\n\", lcore_id,\n+\t\t\tportid);\n+\n+\t}\n+\n+\tmaster_core_id = rte_get_master_lcore();\n+\n+\twhile (!force_quit) {\n+\n+\t\tcur_tsc = rte_rdtsc();\n+\n+\t\t/*\n+\t\t * TX burst queue drain\n+\t\t */\n+\t\tdiff_tsc = cur_tsc - prev_tsc;\n+\t\tif (unlikely(diff_tsc > drain_tsc)) {\n+\n+\t\t\tfor (i = 0; i < qconf->n_rx_port; i++) {\n+\n+\t\t\t\tportid =\n+\t\t\t\t\tl2fwd_dst_ports[qconf->rx_port_list[i]];\n+\t\t\t\tbuffer = tx_buffer[portid];\n+\n+\t\t\t\tsent = rte_eth_tx_buffer_flush(portid, 0,\n+\t\t\t\t\t\tbuffer);\n+\t\t\t\tif (sent)\n+\t\t\t\t\tport_statistics[portid].tx += sent;\n+\n+\t\t\t}\n+\n+\t\t\t/* if timer is enabled */\n+\t\t\tif (timer_period > 0) {\n+\n+\t\t\t\t/* advance the timer */\n+\t\t\t\ttimer_tsc += diff_tsc;\n+\n+\t\t\t\t/* if timer has reached its timeout */\n+\t\t\t\tif (unlikely(timer_tsc >= timer_period)) {\n+\n+\t\t\t\t\t/* do this only on master core */\n+\t\t\t\t\tif (lcore_id == master_core_id) {\n+\t\t\t\t\t\tprint_stats();\n+\t\t\t\t\t\t/* reset the timer */\n+\t\t\t\t\t\ttimer_tsc = 0;\n+\t\t\t\t\t}\n+\t\t\t\t}\n+\t\t\t}\n+\n+\t\t\tprev_tsc = cur_tsc;\n+\t\t}\n+\n+\t\t/*\n+\t\t * Read packet from RX queues\n+\t\t */\n+\t\tfor (i = 0; i < qconf->n_rx_port; i++) {\n+\n+\t\t\tportid = qconf->rx_port_list[i];\n+\t\t\tnb_rx = rte_eth_rx_burst(portid, 0,\n+\t\t\t\t\t\t pkts_burst, MAX_PKT_BURST);\n+\n+\t\t\tport_statistics[portid].rx += nb_rx;\n+\n+\t\t\tfor (j = 0; j < nb_rx; j++) {\n+\t\t\t\tm = pkts_burst[j];\n+\t\t\t\trte_prefetch0(rte_pktmbuf_mtod(m, void *));\n+\t\t\t\tl2fwd_simple_forward(m, portid);\n+\t\t\t}\n+\t\t}\n+\t}\n+}\n+\n+int\n+l2fwd_launch_one_lcore(__attribute__((unused)) void *dummy)\n+{\n+\tl2fwd_main_loop();\n+\treturn 0;\n+}\ndiff --git a/examples/l2fwd/l2fwd_worker.h b/examples/l2fwd/l2fwd_worker.h\nnew file mode 100644\nindex 0000000..8971a6a\n--- /dev/null\n+++ b/examples/l2fwd/l2fwd_worker.h\n@@ -0,0 +1,10 @@\n+/* SPDX-License-Identifier: BSD-3-Clause\n+ * Copyright(c) 2018 Cavium, Inc\n+ */\n+#ifndef _L2FWD_WORKER_H_\n+#define _L2FWD_WORKER_H_\n+\n+int\n+l2fwd_launch_one_lcore(__attribute__((unused)) void *dummy);\n+\n+#endif /* _L2FWD_WORKER_H_ */\ndiff --git a/examples/l2fwd/main.c b/examples/l2fwd/main.c\nindex 3e0269e..05f9d28 100644\n--- a/examples/l2fwd/main.c\n+++ b/examples/l2fwd/main.c\n@@ -40,6 +40,7 @@\n #include <rte_mbuf.h>\n \n #include \"l2fwd_common.h\"\n+#include \"l2fwd_worker.h\"\n \n static uint16_t nb_rxd = RTE_TEST_RX_DESC_DEFAULT;\n static uint16_t nb_txd = RTE_TEST_TX_DESC_DEFAULT;\n@@ -59,196 +60,6 @@ static struct rte_eth_conf port_conf = {\n \n struct rte_mempool * l2fwd_pktmbuf_pool = NULL;\n \n-/* Print out statistics on packets dropped */\n-static void\n-print_stats(void)\n-{\n-\tuint64_t total_packets_dropped, total_packets_tx, total_packets_rx;\n-\tunsigned portid;\n-\n-\ttotal_packets_dropped = 0;\n-\ttotal_packets_tx = 0;\n-\ttotal_packets_rx = 0;\n-\n-\tconst char clr[] = { 27, '[', '2', 'J', '\\0' };\n-\tconst char topLeft[] = { 27, '[', '1', ';', '1', 'H', '\\0' };\n-\n-\t\t/* Clear screen and move to top left */\n-\tprintf(\"%s%s\", clr, topLeft);\n-\n-\tprintf(\"\\nPort statistics ====================================\");\n-\n-\tfor (portid = 0; portid < RTE_MAX_ETHPORTS; portid++) {\n-\t\t/* skip disabled ports */\n-\t\tif ((l2fwd_enabled_port_mask & (1 << portid)) == 0)\n-\t\t\tcontinue;\n-\t\tprintf(\"\\nStatistics for port %u ------------------------------\"\n-\t\t\t \"\\nPackets sent: %24\"PRIu64\n-\t\t\t \"\\nPackets received: %20\"PRIu64\n-\t\t\t \"\\nPackets dropped: %21\"PRIu64,\n-\t\t\t portid,\n-\t\t\t port_statistics[portid].tx,\n-\t\t\t port_statistics[portid].rx,\n-\t\t\t port_statistics[portid].dropped);\n-\n-\t\ttotal_packets_dropped += port_statistics[portid].dropped;\n-\t\ttotal_packets_tx += port_statistics[portid].tx;\n-\t\ttotal_packets_rx += port_statistics[portid].rx;\n-\t}\n-\tprintf(\"\\nAggregate statistics ===============================\"\n-\t\t \"\\nTotal packets sent: %18\"PRIu64\n-\t\t \"\\nTotal packets received: %14\"PRIu64\n-\t\t \"\\nTotal packets dropped: %15\"PRIu64,\n-\t\t total_packets_tx,\n-\t\t total_packets_rx,\n-\t\t total_packets_dropped);\n-\tprintf(\"\\n====================================================\\n\");\n-}\n-\n-static void\n-l2fwd_mac_updating(struct rte_mbuf *m, unsigned dest_portid)\n-{\n-\tstruct ether_hdr *eth;\n-\tvoid *tmp;\n-\n-\teth = rte_pktmbuf_mtod(m, struct ether_hdr *);\n-\n-\t/* 02:00:00:00:00:xx */\n-\ttmp = ð->d_addr.addr_bytes[0];\n-\t*((uint64_t *)tmp) = 0x000000000002 + ((uint64_t)dest_portid << 40);\n-\n-\t/* src addr */\n-\tether_addr_copy(&l2fwd_ports_eth_addr[dest_portid], ð->s_addr);\n-}\n-\n-static void\n-l2fwd_simple_forward(struct rte_mbuf *m, unsigned portid)\n-{\n-\tunsigned dst_port;\n-\tint sent;\n-\tstruct rte_eth_dev_tx_buffer *buffer;\n-\n-\tdst_port = l2fwd_dst_ports[portid];\n-\n-\tif (mac_updating)\n-\t\tl2fwd_mac_updating(m, dst_port);\n-\n-\tbuffer = tx_buffer[dst_port];\n-\tsent = rte_eth_tx_buffer(dst_port, 0, buffer, m);\n-\tif (sent)\n-\t\tport_statistics[dst_port].tx += sent;\n-}\n-\n-/* main processing loop */\n-static void\n-l2fwd_main_loop(void)\n-{\n-\tstruct rte_mbuf *pkts_burst[MAX_PKT_BURST];\n-\tstruct rte_mbuf *m;\n-\tint sent;\n-\tunsigned lcore_id;\n-\tunsigned int master_core_id;\n-\tuint64_t prev_tsc, diff_tsc, cur_tsc, timer_tsc;\n-\tunsigned i, j, portid, nb_rx;\n-\tstruct lcore_queue_conf *qconf;\n-\tconst uint64_t drain_tsc = (rte_get_tsc_hz() + US_PER_S - 1)\n-\t\t\t/ US_PER_S * BURST_TX_DRAIN_US;\n-\tstruct rte_eth_dev_tx_buffer *buffer;\n-\n-\tprev_tsc = 0;\n-\ttimer_tsc = 0;\n-\n-\tlcore_id = rte_lcore_id();\n-\tqconf = &lcore_queue_conf[lcore_id];\n-\n-\tif (qconf->n_rx_port == 0) {\n-\t\tRTE_LOG(INFO, L2FWD, \"lcore %u has nothing to do\\n\", lcore_id);\n-\t\treturn;\n-\t}\n-\n-\tRTE_LOG(INFO, L2FWD, \"entering main loop on lcore %u\\n\", lcore_id);\n-\n-\tfor (i = 0; i < qconf->n_rx_port; i++) {\n-\n-\t\tportid = qconf->rx_port_list[i];\n-\t\tRTE_LOG(INFO, L2FWD, \" -- lcoreid=%u portid=%u\\n\", lcore_id,\n-\t\t\tportid);\n-\n-\t}\n-\n-\tmaster_core_id = rte_get_master_lcore();\n-\n-\twhile (!force_quit) {\n-\n-\t\tcur_tsc = rte_rdtsc();\n-\n-\t\t/*\n-\t\t * TX burst queue drain\n-\t\t */\n-\t\tdiff_tsc = cur_tsc - prev_tsc;\n-\t\tif (unlikely(diff_tsc > drain_tsc)) {\n-\n-\t\t\tfor (i = 0; i < qconf->n_rx_port; i++) {\n-\n-\t\t\t\tportid =\n-\t\t\t\t\tl2fwd_dst_ports[qconf->rx_port_list[i]];\n-\t\t\t\tbuffer = tx_buffer[portid];\n-\n-\t\t\t\tsent = rte_eth_tx_buffer_flush(portid, 0,\n-\t\t\t\t\t\tbuffer);\n-\t\t\t\tif (sent)\n-\t\t\t\t\tport_statistics[portid].tx += sent;\n-\n-\t\t\t}\n-\n-\t\t\t/* if timer is enabled */\n-\t\t\tif (timer_period > 0) {\n-\n-\t\t\t\t/* advance the timer */\n-\t\t\t\ttimer_tsc += diff_tsc;\n-\n-\t\t\t\t/* if timer has reached its timeout */\n-\t\t\t\tif (unlikely(timer_tsc >= timer_period)) {\n-\n-\t\t\t\t\t/* do this only on master core */\n-\t\t\t\t\tif (lcore_id == master_core_id) {\n-\t\t\t\t\t\tprint_stats();\n-\t\t\t\t\t\t/* reset the timer */\n-\t\t\t\t\t\ttimer_tsc = 0;\n-\t\t\t\t\t}\n-\t\t\t\t}\n-\t\t\t}\n-\n-\t\t\tprev_tsc = cur_tsc;\n-\t\t}\n-\n-\t\t/*\n-\t\t * Read packet from RX queues\n-\t\t */\n-\t\tfor (i = 0; i < qconf->n_rx_port; i++) {\n-\n-\t\t\tportid = qconf->rx_port_list[i];\n-\t\t\tnb_rx = rte_eth_rx_burst(portid, 0,\n-\t\t\t\t\t\t pkts_burst, MAX_PKT_BURST);\n-\n-\t\t\tport_statistics[portid].rx += nb_rx;\n-\n-\t\t\tfor (j = 0; j < nb_rx; j++) {\n-\t\t\t\tm = pkts_burst[j];\n-\t\t\t\trte_prefetch0(rte_pktmbuf_mtod(m, void *));\n-\t\t\t\tl2fwd_simple_forward(m, portid);\n-\t\t\t}\n-\t\t}\n-\t}\n-}\n-\n-static int\n-l2fwd_launch_one_lcore(__attribute__((unused)) void *dummy)\n-{\n-\tl2fwd_main_loop();\n-\treturn 0;\n-}\n-\n /* display usage */\n static void\n l2fwd_usage(const char *prgname)\n", "prefixes": [ "v1", "07/15" ] }