Patch Detail

HTTP 200 OK
Allow: GET, PUT, PATCH, HEAD, OPTIONS
Content-Type: application/json
Vary: Accept

{
    "id": 12650,
    "url": "http://patches.dpdk.org/api/patches/12650/?format=api",
    "web_url": "http://patches.dpdk.org/project/dpdk/patch/1462873202-3314-4-git-send-email-reshma.pattan@intel.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": "<1462873202-3314-4-git-send-email-reshma.pattan@intel.com>",
    "list_archive_url": "https://inbox.dpdk.org/dev/1462873202-3314-4-git-send-email-reshma.pattan@intel.com",
    "date": "2016-05-10T09:40:00",
    "name": "[dpdk-dev,PATCHv2,3/5] app/pdump: add pdump tool for packet capturing",
    "commit_ref": null,
    "pull_url": null,
    "state": "superseded",
    "archived": true,
    "hash": "6d9aac1c49500cac472259a0ecf63353f1ecafa7",
    "submitter": {
        "id": 70,
        "url": "http://patches.dpdk.org/api/people/70/?format=api",
        "name": "Pattan, Reshma",
        "email": "reshma.pattan@intel.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/1462873202-3314-4-git-send-email-reshma.pattan@intel.com/mbox/",
    "series": [],
    "comments": "http://patches.dpdk.org/api/patches/12650/comments/",
    "check": "pending",
    "checks": "http://patches.dpdk.org/api/patches/12650/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 [IPv6:::1])\n\tby dpdk.org (Postfix) with ESMTP id B372C9AB7;\n\tTue, 10 May 2016 11:40:13 +0200 (CEST)",
            "from mga03.intel.com (mga03.intel.com [134.134.136.65])\n\tby dpdk.org (Postfix) with ESMTP id DB48D9A8D\n\tfor <dev@dpdk.org>; Tue, 10 May 2016 11:40:08 +0200 (CEST)",
            "from fmsmga004.fm.intel.com ([10.253.24.48])\n\tby orsmga103.jf.intel.com with ESMTP; 10 May 2016 02:40:07 -0700",
            "from irvmail001.ir.intel.com ([163.33.26.43])\n\tby fmsmga004.fm.intel.com with ESMTP; 10 May 2016 02:40:06 -0700",
            "from sivswdev02.ir.intel.com (sivswdev02.ir.intel.com\n\t[10.237.217.46])\n\tby irvmail001.ir.intel.com (8.14.3/8.13.6/MailSET/Hub) with ESMTP id\n\tu4A9e52H003325; Tue, 10 May 2016 10:40:05 +0100",
            "from sivswdev02.ir.intel.com (localhost [127.0.0.1])\n\tby sivswdev02.ir.intel.com with ESMTP id u4A9e5mb003382;\n\tTue, 10 May 2016 10:40:05 +0100",
            "(from reshmapa@localhost)\n\tby sivswdev02.ir.intel.com with  id u4A9e5k5003378;\n\tTue, 10 May 2016 10:40:05 +0100"
        ],
        "X-ExtLoop1": "1",
        "X-IronPort-AV": "E=Sophos;i=\"5.24,604,1455004800\"; d=\"scan'208\";a=\"100401567\"",
        "From": "Reshma Pattan <reshma.pattan@intel.com>",
        "To": "dev@dpdk.org",
        "Cc": "Reshma Pattan <reshma.pattan@intel.com>",
        "Date": "Tue, 10 May 2016 10:40:00 +0100",
        "Message-Id": "<1462873202-3314-4-git-send-email-reshma.pattan@intel.com>",
        "X-Mailer": "git-send-email 1.7.4.1",
        "In-Reply-To": "<1462873202-3314-1-git-send-email-reshma.pattan@intel.com>",
        "References": "<1462532139-17848-1-git-send-email-reshma.pattan@intel.com>\n\t<1462873202-3314-1-git-send-email-reshma.pattan@intel.com>",
        "Subject": "[dpdk-dev] [PATCHv2 3/5] app/pdump: add pdump tool for packet\n\tcapturing",
        "X-BeenThere": "dev@dpdk.org",
        "X-Mailman-Version": "2.1.15",
        "Precedence": "list",
        "List-Id": "patches and discussions about DPDK <dev.dpdk.org>",
        "List-Unsubscribe": "<http://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": "<http://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": "New tool added for packet capturing on dpdk.\nThis tool supports command line options.\nThis tool runs as secondary process by default.\n\nCommand line supports various parameters to capture\nthe packets.\n\nUser should pass on a)port and queue (or) b)pci address\nand queue (or) c)device name and queue to capture\nthe packets.\n\nUsers also need to pass on either pcap file name or\nany linux iface, on to which packets captured from dpdk\nports will be sent on for the users to view using tcpdump.\n\nUsers have option to capture packets either a) in RX\ndirection, b)(or) in TX direction c)(or) from both the\ndirections.\n\nUser can pass on ring_size and mempool parameters using\ncommand line, but these are optional parameters.\nThese are used to create ring and mempool objects for packet\nmirroring from primary application to tool. If user doesn't\nprovide any values, default values will be used internally\nfor the creation of the ring and mempool.\n\nSigned-off-by: Reshma Pattan <reshma.pattan@intel.com>\n---\n MAINTAINERS        |   1 +\n app/Makefile       |   1 +\n app/pdump/Makefile |  45 +++\n app/pdump/main.c   | 936 +++++++++++++++++++++++++++++++++++++++++++++++++++++\n 4 files changed, 983 insertions(+)\n create mode 100644 app/pdump/Makefile\n create mode 100644 app/pdump/main.c",
    "diff": "diff --git a/MAINTAINERS b/MAINTAINERS\nindex 74140c7..b6a39c7 100644\n--- a/MAINTAINERS\n+++ b/MAINTAINERS\n@@ -431,6 +431,7 @@ F: doc/guides/sample_app_ug/packet_ordering.rst\n Pdump\n M: Reshma Pattan <reshma.pattan@intel.com>\n F: lib/librte_pdump/\n+F: app/pdump/\n \n Hierarchical scheduler\n M: Cristian Dumitrescu <cristian.dumitrescu@intel.com>\ndiff --git a/app/Makefile b/app/Makefile\nindex 1151e09..c593efa 100644\n--- a/app/Makefile\n+++ b/app/Makefile\n@@ -37,5 +37,6 @@ DIRS-$(CONFIG_RTE_LIBRTE_PIPELINE) += test-pipeline\n DIRS-$(CONFIG_RTE_TEST_PMD) += test-pmd\n DIRS-$(CONFIG_RTE_LIBRTE_CMDLINE) += cmdline_test\n DIRS-$(CONFIG_RTE_EXEC_ENV_LINUXAPP) += proc_info\n+DIRS-$(CONFIG_RTE_EXEC_ENV_LINUXAPP) += pdump\n \n include $(RTE_SDK)/mk/rte.subdir.mk\ndiff --git a/app/pdump/Makefile b/app/pdump/Makefile\nnew file mode 100644\nindex 0000000..96bb4af\n--- /dev/null\n+++ b/app/pdump/Makefile\n@@ -0,0 +1,45 @@\n+#   BSD LICENSE\n+#\n+#   Copyright(c) 2016 Intel Corporation. All rights reserved.\n+#   All rights reserved.\n+#\n+#   Redistribution and use in source and binary forms, with or without\n+#   modification, are permitted provided that the following conditions\n+#   are met:\n+#\n+#     * Redistributions of source code must retain the above copyright\n+#       notice, this list of conditions and the following disclaimer.\n+#     * Redistributions in binary form must reproduce the above copyright\n+#       notice, this list of conditions and the following disclaimer in\n+#       the documentation and/or other materials provided with the\n+#       distribution.\n+#     * Neither the name of Intel Corporation nor the names of its\n+#       contributors may be used to endorse or promote products derived\n+#       from this software without specific prior written permission.\n+#\n+#   THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS\n+#   \"AS IS\" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT\n+#   LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR\n+#   A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT\n+#   OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,\n+#   SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT\n+#   LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,\n+#   DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY\n+#   THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT\n+#   (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE\n+#   OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.\n+\n+include $(RTE_SDK)/mk/rte.vars.mk\n+\n+APP = dpdk_pdump\n+\n+CFLAGS += $(WERROR_FLAGS)\n+\n+# all source are stored in SRCS-y\n+\n+SRCS-y := main.c\n+\n+# this application needs libraries first\n+DEPDIRS-y += lib\n+\n+include $(RTE_SDK)/mk/rte.app.mk\ndiff --git a/app/pdump/main.c b/app/pdump/main.c\nnew file mode 100644\nindex 0000000..5d57382\n--- /dev/null\n+++ b/app/pdump/main.c\n@@ -0,0 +1,936 @@\n+/*\n+ *   BSD LICENSE\n+ *\n+ *   Copyright(c) 2016 Intel Corporation. All rights reserved.\n+ *   All rights reserved.\n+ *\n+ *   Redistribution and use in source and binary forms, with or without\n+ *   modification, are permitted provided that the following conditions\n+ *   are met:\n+ *\n+ *     * Redistributions of source code must retain the above copyright\n+ *       notice, this list of conditions and the following disclaimer.\n+ *     * Redistributions in binary form must reproduce the above copyright\n+ *       notice, this list of conditions and the following disclaimer in\n+ *       the documentation and/or other materials provided with the\n+ *       distribution.\n+ *     * Neither the name of Intel Corporation nor the names of its\n+ *       contributors may be used to endorse or promote products derived\n+ *       from this software without specific prior written permission.\n+ *\n+ *   THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS\n+ *   \"AS IS\" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT\n+ *   LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR\n+ *   A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT\n+ *   OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,\n+ *   SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT\n+ *   LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,\n+ *   DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY\n+ *   THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT\n+ *   (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE\n+ *   OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.\n+ */\n+\n+#include <stdio.h>\n+#include <string.h>\n+#include <stdint.h>\n+#include <inttypes.h>\n+#include <stdlib.h>\n+#include <getopt.h>\n+#include <signal.h>\n+#include <stdbool.h>\n+#include <net/if.h>\n+\n+#include <rte_eal.h>\n+#include <rte_common.h>\n+#include <rte_debug.h>\n+#include <rte_ethdev.h>\n+#include <rte_memory.h>\n+#include <rte_lcore.h>\n+#include <rte_branch_prediction.h>\n+#include <rte_errno.h>\n+#include <rte_dev.h>\n+#include <rte_kvargs.h>\n+#include <rte_mempool.h>\n+#include <rte_ring.h>\n+#include <rte_pdump.h>\n+\n+#define PDUMP_PORT_ARG \"port\"\n+#define PDUMP_PCI_ARG \"device_id\"\n+#define PDUMP_QUEUE_ARG \"queue\"\n+#define PDUMP_DIR_ARG \"dir\"\n+#define PDUMP_RX_DEV_ARG \"rx-dev\"\n+#define PDUMP_TX_DEV_ARG \"tx-dev\"\n+#define PDUMP_RXTX_DEV_ARG \"rxtx-dev\"\n+#define PDUMP_RING_SIZE_ARG \"ring-size\"\n+#define PDUMP_MBUF_SIZE_ARG \"mbuf-size\"\n+#define PDUMP_NUM_MBUFS_ARG \"total-num-mbufs\"\n+\n+#define VDEV_NAME \"eth_pcap_%s_%d\"\n+#define VDEV_TX_PCAP \"tx_pcap=%s\"\n+#define VDEV_TX_IFACE \"tx_iface=%s\"\n+#define TX_STREAM_SIZE 64\n+\n+#define MP_NAME \"pdump_pool_%d\"\n+\n+#define RXTX_RING \"rxtx_ring_%d\"\n+#define RX_RING \"rx_ring_%d\"\n+#define TX_RING \"tx_ring_%d\"\n+\n+#define RXTX_STR \"rxtx\"\n+#define RX_STR \"rx\"\n+#define TX_STR \"tx\"\n+\n+/* Maximum long option length for option parsing. */\n+#define APP_ARG_TCPDUMP_MAX_TUPLES 54\n+#define MBUF_POOL_CACHE_SIZE 250\n+#define TX_DESC_PER_QUEUE 512\n+#define RX_DESC_PER_QUEUE 128\n+#define MBUFS_PER_POOL 65535\n+#define MAX_LONG_OPT_SZ 64\n+#define RING_SIZE 16384\n+#define ARRAY_SIZE 256\n+#define BURST_SIZE 32\n+#define NUM_VDEVS 2\n+\n+enum pdump_en_dis {\n+\tDISABLE = 1,\n+\tENABLE = 2\n+};\n+\n+enum pcap_stream {\n+\tIFACE = 1,\n+\tPCAP = 2\n+};\n+\n+enum pdump_by {\n+\tPORT_ID = 1,\n+\tDEVICE_ID = 2\n+};\n+\n+const char *valid_pdump_arguments[] = {\n+\tPDUMP_PORT_ARG,\n+\tPDUMP_PCI_ARG,\n+\tPDUMP_QUEUE_ARG,\n+\tPDUMP_DIR_ARG,\n+\tPDUMP_RX_DEV_ARG,\n+\tPDUMP_TX_DEV_ARG,\n+\tPDUMP_RXTX_DEV_ARG,\n+\tPDUMP_RING_SIZE_ARG,\n+\tPDUMP_MBUF_SIZE_ARG,\n+\tPDUMP_NUM_MBUFS_ARG,\n+\tNULL\n+};\n+\n+struct pdump_stats {\n+\tuint64_t dequeue_pkts;\n+\tuint64_t tx_pkts;\n+\tuint64_t freed_pkts;\n+};\n+\n+struct pdump_tuples {\n+\t/* cli params */\n+\tuint8_t port;\n+\tchar *device_id;\n+\tuint16_t queue;\n+\tchar rx_dev[TX_STREAM_SIZE];\n+\tchar tx_dev[TX_STREAM_SIZE];\n+\tchar rxtx_dev[TX_STREAM_SIZE];\n+\tuint32_t ring_size;\n+\tuint16_t mbuf_data_size;\n+\tuint32_t total_num_mbufs;\n+\n+\t/* params for library API call */\n+\tuint32_t dir;\n+\tstruct rte_mempool *mp;\n+\tstruct rte_ring *rx_ring;\n+\tstruct rte_ring *tx_ring;\n+\tstruct rte_ring *rxtx_ring;\n+\n+\t/* params for packet dumping */\n+\tenum pdump_by dump_by_type;\n+\tint rx_vdev_id;\n+\tint tx_vdev_id;\n+\tint rxtx_vdev_id;\n+\tenum pcap_stream rx_vdev_stream_type;\n+\tenum pcap_stream tx_vdev_stream_type;\n+\tenum pcap_stream rxtx_vdev_stream_type;\n+\tbool single_pdump_dev;\n+\n+\t/* stats */\n+\tstruct pdump_stats stats;\n+} __rte_cache_aligned;\n+static struct pdump_tuples pdump_t[APP_ARG_TCPDUMP_MAX_TUPLES];\n+\n+int num_tuples;\n+static struct rte_eth_conf port_conf_default;\n+volatile uint8_t quit_signal;\n+\n+/**< display usage */\n+static void\n+pdump_usage(const char *prgname)\n+{\n+\tprintf(\"%s [EAL options] -- --pdump='(\"\n+\t\"port=<port_id>|device_id=<pci address or device name>),\"\n+\t\"(queue=2),\"\n+\t\"(rx-dev=<iface/path to pcap file>|\"\n+\t\"tx-dev=<iface/path to pcap file>\"\n+\t\"|rxtx-dev=<iface/path to pcap file>),\"\n+\t\"[ring-size=<size of ring>default:16384],\"\n+\t\"[mbuf-size=<mbuf data room size>default:2176],\"\n+\t\"[total-num-mbufs=<number mbufs>default:65535]\"\n+\t\")'\\n\",\n+\tprgname);\n+}\n+\n+static int\n+parse_port(const char *key __rte_unused, const char *value, void *extra_args)\n+{\n+\tint n;\n+\tstruct pdump_tuples *pt = extra_args;\n+\n+\tn = atoi(value);\n+\tif (n >= RTE_MAX_ETHPORTS) {\n+\t\tprintf(\"port %d >= RTE_MAX_ETHPORTS(%d)\\n\", n, RTE_MAX_ETHPORTS);\n+\t\treturn -1;\n+\t}\n+\tpt->port = (uint8_t) n;\n+\tpt->dump_by_type = PORT_ID;\n+\n+\treturn 0;\n+}\n+\n+static int\n+parse_device_id(const char *key __rte_unused, const char *value, void *extra_args)\n+{\n+\tstruct pdump_tuples *pt = extra_args;\n+\n+\tpt->device_id = strdup(value);\n+\tpt->dump_by_type = DEVICE_ID;\n+\n+\treturn 0;\n+}\n+\n+static int\n+parse_queue(const char *key __rte_unused, const char *value, void *extra_args)\n+{\n+\tint n;\n+\tstruct pdump_tuples *pt = extra_args;\n+\n+\tif (!strcmp(value, \"*\"))\n+\t\tpt->queue = RTE_PDUMP_ALL_QUEUES;\n+\telse {\n+\t\tn = atoi(value);\n+\t\tif (n >= 0)\n+\t\t\tpt->queue = (uint16_t) n;\n+\t\telse {\n+\t\t\tprintf(\"queue id %d invalid - must be >= 0\\n\", n);\n+\t\t\treturn -1;\n+\t\t}\n+\t}\n+\treturn 0;\n+}\n+\n+static int\n+parse_rxtxdev(const char *key, const char *value, void *extra_args)\n+{\n+\n+\tstruct pdump_tuples *pt = extra_args;\n+\n+\tif (!strcmp(key, PDUMP_RX_DEV_ARG)) {\n+\t\tstrncpy(pt->rx_dev, value, strlen(value));\n+\t\t/* identify the tx stream type for pcap vdev */\n+\t\tif (if_nametoindex(pt->rx_dev))\n+\t\t\tpt->rx_vdev_stream_type = IFACE;\n+\t} else if (!strcmp(key, PDUMP_TX_DEV_ARG)) {\n+\t\tstrncpy(pt->tx_dev, value, strlen(value));\n+\t\t/* identify the tx stream type for pcap vdev */\n+\t\tif (if_nametoindex(pt->tx_dev))\n+\t\t\tpt->tx_vdev_stream_type = IFACE;\n+\t} else if (!strcmp(key, PDUMP_RXTX_DEV_ARG)) {\n+\t\tstrncpy(pt->rxtx_dev, value, strlen(value));\n+\t\t/* identify the tx stream type for pcap vdev */\n+\t\tif (if_nametoindex(pt->rxtx_dev))\n+\t\t\tpt->rxtx_vdev_stream_type = IFACE;\n+\t} else {\n+\t\tprintf(\"dev type %s invalid must be rx|tx|rxtx\\n\", value);\n+\t\treturn -1;\n+\t}\n+\n+\treturn 0;\n+}\n+\n+static int\n+parse_ring_size(const char *key __rte_unused, const char *value, void *extra_args)\n+{\n+\tint n;\n+\tstruct pdump_tuples *pt = extra_args;\n+\n+\tn = atoi(value);\n+\tif (n >= 0)\n+\t\tpt->ring_size = (uint32_t) n;\n+\telse {\n+\t\tprintf(\"ring_size %d invalid - must be >= 0\\n\", n);\n+\t\treturn -1;\n+\t}\n+\n+\treturn 0;\n+}\n+\n+static int\n+parse_mbuf_data_size(const char *key __rte_unused, const char *value, void *extra_args)\n+{\n+\tint n;\n+\tstruct pdump_tuples *pt = extra_args;\n+\n+\tn = atoi(value);\n+\tif (n > 0 && n <= 0xFFFF)\n+\t\tpt->mbuf_data_size = (uint16_t) n;\n+\telse {\n+\t\tprintf(\"mbuf_data_size %d invalid - must be > 0 and < 65536\\n\", n);\n+\t\treturn -1;\n+\t}\n+\n+\treturn 0;\n+}\n+\n+static int\n+parse_num_mbufs(const char *key __rte_unused, const char *value, void *extra_args)\n+{\n+\tint n;\n+\tstruct pdump_tuples *pt = extra_args;\n+\n+\tn = atoi(value);\n+\tif (n > 1024)\n+\t\tpt->total_num_mbufs = (uint16_t) n;\n+\telse {\n+\t\tprintf(\"total-num-mbufs %d invalid - must be > 1024\\n\", n);\n+\t\treturn -1;\n+\t}\n+\n+\treturn 0;\n+}\n+\n+static int\n+parse_pdump(const char *optarg)\n+{\n+\tstruct rte_kvargs *kvlist;\n+\tint ret = 0, cnt1, cnt2, cnt3;\n+\tstruct pdump_tuples *pt;\n+\n+\tpt = &pdump_t[num_tuples];\n+\n+\t/* initial check for invalid arguments */\n+\tkvlist = rte_kvargs_parse(optarg, valid_pdump_arguments);\n+\tif (kvlist == NULL) {\n+\t\tprintf(\"invalid arguments passed in --pdump parameter\\n\");\n+\t\treturn -1;\n+\t}\n+\n+\t/* port/device_id parsing and validation */\n+\tcnt1 = rte_kvargs_count(kvlist, PDUMP_PORT_ARG);\n+\tcnt2 = rte_kvargs_count(kvlist, PDUMP_PCI_ARG);\n+\tif (!((cnt1 == 1 && cnt2 == 0) || (cnt1 == 0 && cnt2 == 1))) {\n+\t\tprintf(\"--pdump parameter must have either port id or device_id \"\n+\t\t\t\"( i.e.pci or dev name) address argument\\n\");\n+\t\tret = -1;\n+\t\tgoto free_kvlist;\n+\t} else if (cnt1 == 1)\n+\t\tret = rte_kvargs_process(kvlist, PDUMP_PORT_ARG,\n+\t\t\t\t&parse_port, pt);\n+\telse if (cnt2 == 1)\n+\t\tret = rte_kvargs_process(kvlist, PDUMP_PCI_ARG,\n+\t\t\t\t&parse_device_id, pt);\n+\tif (ret < 0)\n+\t\tgoto free_kvlist;\n+\n+\t/* queue parsing and validation */\n+\tcnt1 = rte_kvargs_count(kvlist, PDUMP_QUEUE_ARG);\n+\tif (cnt1 != 1) {\n+\t\tprintf(\"--pdump parameter must have queue argument\\n\");\n+\t\tret = -1;\n+\t\tgoto free_kvlist;\n+\t}\n+\tret = rte_kvargs_process(kvlist, PDUMP_QUEUE_ARG, &parse_queue, pt);\n+\tif (ret < 0)\n+\t\tgoto free_kvlist;\n+\n+\tcnt1 = rte_kvargs_count(kvlist, PDUMP_RXTX_DEV_ARG);\n+\tcnt2 = rte_kvargs_count(kvlist, PDUMP_RX_DEV_ARG);\n+\tcnt3 = rte_kvargs_count(kvlist, PDUMP_TX_DEV_ARG);\n+\tif (cnt1 == 0 && cnt2 == 0 && cnt3 == 0) {\n+\t\tprintf(\"--pdump must have either rx/tx/rxtx device for packet capturing\\n\");\n+\t\tret = -1;\n+\t\tgoto free_kvlist;\n+\t} else if (cnt1 == 1 && (cnt2 >= 1 || cnt3 >= 1)) {\n+\t\tprintf(\"--pdump must have either rx and/or tx devices or\"\n+\t\t\t\" rxtx device only for packet capturing\\n\");\n+\t\tret = -1;\n+\t\tgoto free_kvlist;\n+\t} else if (cnt2 == 1 && cnt3 == 1) {\n+\t\tret = rte_kvargs_process(kvlist, PDUMP_RX_DEV_ARG, &parse_rxtxdev, pt);\n+\t\tif (ret < 0)\n+\t\t\tgoto free_kvlist;\n+\t\tret = rte_kvargs_process(kvlist, PDUMP_TX_DEV_ARG, &parse_rxtxdev, pt);\n+\t\tif (ret < 0)\n+\t\t\tgoto free_kvlist;\n+\t\tpt->dir = RTE_PDUMP_FLAG_RXTX;\n+\t} else if (cnt1 ==  1) {\n+\t\tret = rte_kvargs_process(kvlist, PDUMP_RXTX_DEV_ARG, &parse_rxtxdev, pt);\n+\t\tif (ret < 0)\n+\t\t\tgoto free_kvlist;\n+\t\tpt->single_pdump_dev = true;\n+\t\tpt->dir = RTE_PDUMP_FLAG_RXTX;\n+\t} else if (cnt2 == 1) {\n+\t\tret = rte_kvargs_process(kvlist, PDUMP_RX_DEV_ARG, &parse_rxtxdev, pt);\n+\t\tif (ret < 0)\n+\t\t\tgoto free_kvlist;\n+\t\tpt->dir = RTE_PDUMP_FLAG_RX;\n+\t} else if (cnt3 == 1) {\n+\t\tret = rte_kvargs_process(kvlist, PDUMP_TX_DEV_ARG, &parse_rxtxdev, pt);\n+\t\tif (ret < 0)\n+\t\t\tgoto free_kvlist;\n+\t\tpt->dir = RTE_PDUMP_FLAG_TX;\n+\t}\n+\n+\t/* optional */\n+\t/* ring_size parsing and validation */\n+\tcnt1 = rte_kvargs_count(kvlist, PDUMP_RING_SIZE_ARG);\n+\tif (cnt1 == 1) {\n+\t\tret = rte_kvargs_process(kvlist, PDUMP_RING_SIZE_ARG,\n+\t\t\t\t\t\t&parse_ring_size, pt);\n+\t\tif (ret < 0)\n+\t\t\tgoto free_kvlist;\n+\t} else\n+\t\tpt->ring_size = RING_SIZE;\n+\n+\t/* mbuf_data_size parsing and validation */\n+\tcnt1 = rte_kvargs_count(kvlist, PDUMP_MBUF_SIZE_ARG);\n+\tif (cnt1 == 1) {\n+\t\tret = rte_kvargs_process(kvlist, PDUMP_MBUF_SIZE_ARG,\n+\t\t\t\t\t\t&parse_mbuf_data_size, pt);\n+\t\tif (ret < 0)\n+\t\t\tgoto free_kvlist;\n+\t} else\n+\t\tpt->mbuf_data_size = RTE_MBUF_DEFAULT_BUF_SIZE;\n+\n+\t/* total_num_mbufs parsing and validation */\n+\tcnt1 = rte_kvargs_count(kvlist, PDUMP_NUM_MBUFS_ARG);\n+\tif (cnt1 == 1) {\n+\t\tret = rte_kvargs_process(kvlist, PDUMP_NUM_MBUFS_ARG,\n+\t\t\t\t\t\t&parse_num_mbufs, pt);\n+\t\tif (ret < 0)\n+\t\t\tgoto free_kvlist;\n+\t} else\n+\t\tpt->total_num_mbufs = MBUFS_PER_POOL;\n+\n+\tnum_tuples++;\n+\treturn 0;\n+\n+free_kvlist:\n+\t\trte_kvargs_free(kvlist);\n+\t\treturn ret;\n+}\n+\n+/* Parse the argument given in the command line of the application */\n+static int\n+launch_args_parse(int argc, char **argv)\n+{\n+\tint opt, ret;\n+\tint option_index;\n+\tchar *prgname = argv[0];\n+\tstatic struct option long_option[] = {\n+\t\t{\"pdump\", 1, 0, 0},\n+\t\t{NULL, 0, 0, 0}\n+\t};\n+\n+\tif (argc == 1)\n+\t\tpdump_usage(prgname);\n+\n+\t/* Parse command line */\n+\twhile ((opt = getopt_long(argc, argv, \" \",\n+\t\t\tlong_option, &option_index)) != EOF) {\n+\t\tswitch (opt) {\n+\t\tcase 0:\n+\t\t\tif (!strncmp(long_option[option_index].name, \"pdump\",\n+\t\t\t\t\tMAX_LONG_OPT_SZ)) {\n+\t\t\t\tret = parse_pdump(optarg);\n+\t\t\t\tif (ret) {\n+\t\t\t\t\tprintf(\"invalid pdump\\n\");\n+\t\t\t\t\tpdump_usage(prgname);\n+\t\t\t\t\treturn -1;\n+\t\t\t\t}\n+\t\t\t}\n+\t\t\tbreak;\n+\t\tdefault:\n+\t\t\tpdump_usage(prgname);\n+\t\t\treturn -1;\n+\t\t}\n+\t}\n+\n+\treturn 0;\n+}\n+\n+static void\n+print_pdump_stats(void)\n+{\n+\tint i;\n+\tstruct pdump_tuples *pt;\n+\n+\tfor (i = 0; i < num_tuples; i++) {\n+\t\tprintf(\"##### PDUMP DEBUG STATS #####\\n\");\n+\t\tpt = &pdump_t[i];\n+\t\tprintf(\" -packets dequeued:\t\t\t%\"PRIu64\"\\n\",\n+\t\t\t\t\t\t\tpt->stats.dequeue_pkts);\n+\t\tprintf(\" -packets transmitted to vdev:\t\t%\"PRIu64\"\\n\",\n+\t\t\t\t\t\t\tpt->stats.tx_pkts);\n+\t\tprintf(\" -packets freed:\t\t\t%\"PRIu64\"\\n\",\n+\t\t\t\t\t\t\tpt->stats.freed_pkts);\n+\t}\n+}\n+\n+static inline void\n+disable_pdump(struct pdump_tuples *pt)\n+{\n+\tif (pt->dump_by_type == DEVICE_ID)\n+\t\trte_pdump_disable_by_deviceid(pt->device_id, pt->queue, pt->dir);\n+\telse if (pt->dump_by_type == PORT_ID)\n+\t\trte_pdump_disable(pt->port, pt->queue, pt->dir);\n+}\n+\n+static void\n+free_ring_data(struct rte_ring *ring, uint8_t vdev_id, struct pdump_stats *stats)\n+{\n+\twhile (rte_ring_count(ring)) {\n+\t\t/* write input packets of port to vdev for pdump */\n+\t\tstruct rte_mbuf *rxtx_bufs[BURST_SIZE];\n+\n+\t\t/* first dequeue packets from ring of primary process */\n+\t\tconst uint16_t nb_in_deq = rte_ring_dequeue_burst(ring,\n+\t\t\t\t(void *)rxtx_bufs, BURST_SIZE);\n+\t\tstats->dequeue_pkts += nb_in_deq;\n+\n+\t\tif (nb_in_deq) {\n+\t\t\t/* then sent on vdev */\n+\t\t\tuint16_t nb_in_txd = rte_eth_tx_burst(\n+\t\t\t\t\tvdev_id,\n+\t\t\t\t\t0, rxtx_bufs, nb_in_deq);\n+\t\t\tstats->tx_pkts += nb_in_txd;\n+\n+\t\t\tif (unlikely(nb_in_txd < nb_in_deq)) {\n+\t\t\t\tdo {\n+\t\t\t\t\trte_pktmbuf_free(rxtx_bufs[nb_in_txd]);\n+\t\t\t\t\tstats->freed_pkts++;\n+\t\t\t\t} while (++nb_in_txd < nb_in_deq);\n+\t\t\t}\n+\t\t}\n+\t}\n+}\n+\n+static void\n+cleanup_pdump_resources(void)\n+{\n+\tint i;\n+\tstruct pdump_tuples *pt;\n+\n+\t/* disable pdump and free the pdump_tuple resources */\n+\tfor (i = 0; i < num_tuples; i++) {\n+\t\tpt = &pdump_t[i];\n+\n+\t\t/* remove callbacks */\n+\t\tdisable_pdump(pt);\n+\n+\t\t/*\n+\t\t* transmit rest enqueued packets of the rings to vdev,\n+\t\t* in order to release mbufs to the mepool\n+\t\t**/\n+\t\tif (pt->single_pdump_dev && pt->dir == RTE_PDUMP_FLAG_RXTX)\n+\t\t\tfree_ring_data(pt->rxtx_ring, pt->rxtx_vdev_id, &pt->stats);\n+\t\telse if (pt->dir == RTE_PDUMP_FLAG_RXTX) {\n+\t\t\tfree_ring_data(pt->rx_ring, pt->rx_vdev_id, &pt->stats);\n+\t\t\tfree_ring_data(pt->tx_ring, pt->tx_vdev_id, &pt->stats);\n+\t\t} else if (pt->dir == RTE_PDUMP_FLAG_RX)\n+\t\t\tfree_ring_data(pt->rx_ring, pt->rx_vdev_id, &pt->stats);\n+\t\telse if (pt->dir == RTE_PDUMP_FLAG_TX)\n+\t\t\tfree_ring_data(pt->tx_ring, pt->tx_vdev_id, &pt->stats);\n+\n+\t\tif (pt->device_id)\n+\t\t\tfree(pt->device_id);\n+\n+\t\t/* free the rings */\n+\t\tif (pt->rx_ring)\n+\t\t\trte_ring_free(pt->rx_ring);\n+\t\tif (pt->tx_ring)\n+\t\t\trte_ring_free(pt->tx_ring);\n+\t\tif (pt->rxtx_ring)\n+\t\t\trte_ring_free(pt->rxtx_ring);\n+\t}\n+}\n+\n+static void\n+signal_handler(int sig_num)\n+{\n+\n+\tif (sig_num == SIGINT) {\n+\t\tprintf(\"\\n\\nSignal %d received, preparing to exit...\\n\",\n+\t\t\t\tsig_num);\n+\t\tquit_signal = 1;\n+\t}\n+\n+\tcleanup_pdump_resources();\n+\t/* dump debug stats */\n+\tprint_pdump_stats();\n+}\n+\n+static inline int\n+configure_vdev(uint8_t port_id)\n+{\n+\tstruct ether_addr addr;\n+\tconst uint16_t rxRings = 0, txRings = 1;\n+\tconst uint8_t nb_ports = rte_eth_dev_count();\n+\tint ret;\n+\tuint16_t q;\n+\n+\tif (port_id > nb_ports)\n+\t\treturn -1;\n+\n+\tret = rte_eth_dev_configure(port_id, rxRings, txRings, &port_conf_default);\n+\tif (ret != 0)\n+\t\trte_exit(EXIT_FAILURE, \"dev config failed\\n\");\n+\n+\t for (q = 0; q < txRings; q++) {\n+\t\tret = rte_eth_tx_queue_setup(port_id, q, TX_DESC_PER_QUEUE,\n+\t\t\t\trte_eth_dev_socket_id(port_id), NULL);\n+\t\tif (ret < 0)\n+\t\t\trte_exit(EXIT_FAILURE, \"queue setup failed\\n\");\n+\t}\n+\n+\tret = rte_eth_dev_start(port_id);\n+\tif (ret < 0)\n+\t\trte_exit(EXIT_FAILURE, \"dev start failed\\n\");\n+\n+\trte_eth_macaddr_get(port_id, &addr);\n+\tprintf(\"Port %u MAC: %02\"PRIx8\" %02\"PRIx8\" %02\"PRIx8\n+\t\t\t\" %02\"PRIx8\" %02\"PRIx8\" %02\"PRIx8\"\\n\",\n+\t\t\t(unsigned)port_id,\n+\t\t\taddr.addr_bytes[0], addr.addr_bytes[1],\n+\t\t\taddr.addr_bytes[2], addr.addr_bytes[3],\n+\t\t\taddr.addr_bytes[4], addr.addr_bytes[5]);\n+\n+\trte_eth_promiscuous_enable(port_id);\n+\n+\treturn 0;\n+}\n+\n+static void\n+create_mp_ring_vdev(void)\n+{\n+\tint i;\n+\tstruct pdump_tuples *pt = NULL;\n+\tstruct rte_mempool *mbuf_pool = NULL;\n+\tchar vdev_name[ARRAY_SIZE];\n+\tchar vdev_params[ARRAY_SIZE];\n+\tchar ring_name[ARRAY_SIZE];\n+\tchar mempool_name[ARRAY_SIZE];\n+\tuint8_t nb_ports = rte_eth_dev_count();\n+\n+\tfor (i = 0; i < num_tuples; i++) {\n+\t\tpt = &pdump_t[i];\n+\t\t/* create rxtx_ring */\n+\t\tsnprintf(mempool_name, ARRAY_SIZE, MP_NAME, i);\n+\t\tmbuf_pool = rte_mempool_lookup(mempool_name);\n+\t\tif (mbuf_pool == NULL) {\n+\t\t\t/* create mempool */\n+\t\t\tmbuf_pool = rte_pktmbuf_pool_create(mempool_name,\n+\t\t\t\t\tpt->total_num_mbufs,\n+\t\t\t\t\tMBUF_POOL_CACHE_SIZE, 0, pt->mbuf_data_size,\n+\t\t\t\t\trte_socket_id());\n+\t\t\tif (mbuf_pool == NULL)\n+\t\t\t\trte_exit(EXIT_FAILURE, \"%s\\n\", rte_strerror(rte_errno));\n+\t\t}\n+\t\tpt->mp = mbuf_pool;\n+\n+\t\tif (pt->dir == RTE_PDUMP_FLAG_RXTX && pt->single_pdump_dev) {\n+\t\t\t/* create rxtx_ring */\n+\t\t\tsnprintf(ring_name, ARRAY_SIZE, RXTX_RING, i);\n+\t\t\tpt->rxtx_ring = rte_ring_create(ring_name, pt->ring_size,\n+\t\t\t\t\t\t\trte_socket_id(), 0);\n+\t\t\tif (pt->rxtx_ring == NULL)\n+\t\t\t\trte_exit(EXIT_FAILURE, \"%s:%s:%d\\n\",\n+\t\t\t\t\trte_strerror(rte_errno), __func__, __LINE__);\n+\n+\t\t\t/* create vdevs */\n+\t\t\tsnprintf(vdev_name, ARRAY_SIZE, VDEV_NAME, RXTX_STR, i);\n+\t\t\tif (pt->rxtx_vdev_stream_type == IFACE)\n+\t\t\t\tsnprintf(vdev_params, ARRAY_SIZE, VDEV_TX_IFACE,\n+\t\t\t\t\t\tpt->rxtx_dev);\n+\t\t\telse\n+\t\t\t\tsnprintf(vdev_params, ARRAY_SIZE, VDEV_TX_PCAP,\n+\t\t\t\t\t\tpt->rxtx_dev);\n+\t\t\tif (rte_eal_vdev_init(vdev_name, vdev_params) < 0)\n+\t\t\t\trte_exit(EXIT_FAILURE, \"vdev creation failed:%s:%d\\n\",\n+\t\t\t\t\t\t__func__, __LINE__);\n+\t\t\tpt->rxtx_vdev_id = nb_ports++;\n+\n+\t\t\t/* configure vdev */\n+\t\t\tconfigure_vdev(pt->rxtx_vdev_id);\n+\n+\t\t} else if (pt->dir == RTE_PDUMP_FLAG_RXTX) {\n+\n+\t\t\t/* create rx_ring */\n+\t\t\tsnprintf(ring_name, ARRAY_SIZE, RX_RING, i);\n+\t\t\tpt->rx_ring = rte_ring_create(ring_name, pt->ring_size,\n+\t\t\t\t\t\t\trte_socket_id(), 0);\n+\t\t\tif (pt->rx_ring == NULL)\n+\t\t\t\trte_exit(EXIT_FAILURE, \"%s:%s:%d\\n\",\n+\t\t\t\t\t\trte_strerror(rte_errno),\n+\t\t\t\t\t\t__func__, __LINE__);\n+\n+\t\t\t/* create tx_ring */\n+\t\t\tsnprintf(ring_name, ARRAY_SIZE, TX_RING, i);\n+\t\t\tpt->tx_ring = rte_ring_create(ring_name, pt->ring_size,\n+\t\t\t\t\t\t\trte_socket_id(), 0);\n+\t\t\tif (pt->tx_ring == NULL)\n+\t\t\t\trte_exit(EXIT_FAILURE, \"%s:%s:%d\\n\",\n+\t\t\t\t\trte_strerror(rte_errno),\n+\t\t\t\t\t__func__, __LINE__);\n+\n+\t\t\t/* create vdevs */\n+\t\t\tsnprintf(vdev_name, ARRAY_SIZE, VDEV_NAME, RX_STR, i);\n+\t\t\tif (pt->rx_vdev_stream_type == IFACE)\n+\t\t\t\tsnprintf(vdev_params, ARRAY_SIZE, VDEV_TX_IFACE,\n+\t\t\t\t\t\tpt->rx_dev);\n+\t\t\telse\n+\t\t\t\tsnprintf(vdev_params, ARRAY_SIZE, VDEV_TX_PCAP,\n+\t\t\t\t\t\tpt->rx_dev);\n+\t\t\tif (rte_eal_vdev_init(vdev_name, vdev_params) < 0)\n+\t\t\t\trte_exit(EXIT_FAILURE, \"vdev creation failed:%s:%d\\n\",\n+\t\t\t\t\t__func__, __LINE__);\n+\t\t\tpt->rx_vdev_id = nb_ports++;\n+\t\t\t/* configure vdev */\n+\t\t\tconfigure_vdev(pt->rx_vdev_id);\n+\n+\t\t\tsnprintf(vdev_name, ARRAY_SIZE, VDEV_NAME, TX_STR, i);\n+\t\t\tif (pt->tx_vdev_stream_type == IFACE)\n+\t\t\t\tsnprintf(vdev_params, ARRAY_SIZE, VDEV_TX_IFACE,\n+\t\t\t\t\t\tpt->tx_dev);\n+\t\t\telse\n+\t\t\t\tsnprintf(vdev_params, ARRAY_SIZE, VDEV_TX_PCAP,\n+\t\t\t\t\t\tpt->tx_dev);\n+\t\t\tif (rte_eal_vdev_init(vdev_name, vdev_params) < 0)\n+\t\t\t\trte_exit(EXIT_FAILURE, \"vdev creation failed:%s:%d\\n\",\n+\t\t\t\t\t\t__func__, __LINE__);\n+\t\t\tpt->tx_vdev_id = nb_ports++;\n+\t\t\t/* configure vdev */\n+\t\t\tconfigure_vdev(pt->tx_vdev_id);\n+\n+\t\t} else if (pt->dir == RTE_PDUMP_FLAG_RX) {\n+\n+\t\t\t/* create rx_ring */\n+\t\t\tsnprintf(ring_name, ARRAY_SIZE, RX_RING, i);\n+\t\t\tpt->rx_ring = rte_ring_create(ring_name, pt->ring_size,\n+\t\t\t\t\t\t\trte_socket_id(), 0);\n+\t\t\tif (pt->rx_ring == NULL)\n+\t\t\t\trte_exit(EXIT_FAILURE, \"%s\\n\", rte_strerror(rte_errno));\n+\n+\t\t\t/* create vdevs */\n+\t\t\tsnprintf(vdev_name, ARRAY_SIZE, VDEV_NAME, RX_STR, i);\n+\t\t\tif (pt->rx_vdev_stream_type == IFACE)\n+\t\t\t\tsnprintf(vdev_params, ARRAY_SIZE, VDEV_TX_IFACE,\n+\t\t\t\t\t\tpt->rx_dev);\n+\t\t\telse\n+\t\t\t\tsnprintf(vdev_params, ARRAY_SIZE, VDEV_TX_PCAP,\n+\t\t\t\t\t\tpt->rx_dev);\n+\t\t\tif (rte_eal_vdev_init(vdev_name, vdev_params) < 0)\n+\t\t\t\trte_exit(EXIT_FAILURE, \"vdev creation failed:%s:%d\\n\",\n+\t\t\t\t\t\t__func__, __LINE__);\n+\t\t\tpt->rx_vdev_id = nb_ports++;\n+\t\t\t/* configure vdev */\n+\t\t\tconfigure_vdev(pt->rx_vdev_id);\n+\n+\t\t} else if (pt->dir == RTE_PDUMP_FLAG_TX) {\n+\n+\t\t\t/* create tx_ring */\n+\t\t\tsnprintf(ring_name, ARRAY_SIZE, TX_RING, i);\n+\t\t\tpt->tx_ring = rte_ring_create(ring_name, pt->ring_size,\n+\t\t\t\t\t\t\trte_socket_id(), 0);\n+\t\t\tif (pt->tx_ring == NULL)\n+\t\t\t\trte_exit(EXIT_FAILURE, \"%s\\n\", rte_strerror(rte_errno));\n+\n+\t\t\t/* create vdevs */\n+\t\t\tsnprintf(vdev_name, ARRAY_SIZE, VDEV_NAME, TX_STR, i);\n+\t\t\tif (pt->tx_vdev_stream_type == IFACE)\n+\t\t\t\tsnprintf(vdev_params, ARRAY_SIZE, VDEV_TX_IFACE,\n+\t\t\t\t\t\tpt->tx_dev);\n+\t\t\telse\n+\t\t\t\tsnprintf(vdev_params, ARRAY_SIZE, VDEV_TX_PCAP,\n+\t\t\t\t\t\tpt->tx_dev);\n+\t\t\tif (rte_eal_vdev_init(vdev_name, vdev_params) < 0)\n+\t\t\t\trte_exit(EXIT_FAILURE, \"vdev creation failed\\n\");\n+\t\t\tpt->tx_vdev_id = nb_ports++;\n+\t\t\t/* configure vdev */\n+\t\t\tconfigure_vdev(pt->tx_vdev_id);\n+\n+\t\t}\n+\t}\n+}\n+\n+static void\n+enable_pdump(void)\n+{\n+\tint i;\n+\tstruct pdump_tuples *pt;\n+\tint ret = 0, ret1 = 0;\n+\n+\tfor (i = 0; i < num_tuples; i++) {\n+\t\tpt = &pdump_t[i];\n+\t\tif (pt->single_pdump_dev && pt->dir == RTE_PDUMP_FLAG_RXTX) {\n+\t\t\tif (pt->dump_by_type == DEVICE_ID)\n+\t\t\t\tret = rte_pdump_enable_by_deviceid(pt->device_id,\n+\t\t\t\t\t\tpt->queue, pt->dir,\n+\t\t\t\t\t\tpt->rxtx_ring,\n+\t\t\t\t\t\tpt->mp, NULL);\n+\t\t\telse if (pt->dump_by_type == PORT_ID)\n+\t\t\t\tret = rte_pdump_enable(pt->port, pt->queue, pt->dir,\n+\t\t\t\t\t\tpt->rxtx_ring, pt->mp, NULL);\n+\t\t} else if (pt->dir == RTE_PDUMP_FLAG_RXTX) {\n+\t\t\tif (pt->dump_by_type == DEVICE_ID) {\n+\t\t\t\tret = rte_pdump_enable_by_deviceid(pt->device_id,\n+\t\t\t\t\t\t\t\tpt->queue,\n+\t\t\t\t\t\t\t\tRTE_PDUMP_FLAG_RX,\n+\t\t\t\t\t\t\t\tpt->rx_ring,\n+\t\t\t\t\t\t\t\tpt->mp, NULL);\n+\t\t\t\tret = rte_pdump_enable_by_deviceid(pt->device_id,\n+\t\t\t\t\t\t\t\tpt->queue,\n+\t\t\t\t\t\t\t\tRTE_PDUMP_FLAG_TX,\n+\t\t\t\t\t\t\t\tpt->tx_ring,\n+\t\t\t\t\t\t\t\tpt->mp, NULL);\n+\t\t\t} else if (pt->dump_by_type == PORT_ID) {\n+\t\t\t\tret = rte_pdump_enable(pt->port, pt->queue,\n+\t\t\t\t\t\t\tRTE_PDUMP_FLAG_RX,\n+\t\t\t\t\t\t\tpt->rx_ring, pt->mp, NULL);\n+\t\t\t\tret1 = rte_pdump_enable(pt->port, pt->queue,\n+\t\t\t\t\t\t\tRTE_PDUMP_FLAG_TX,\n+\t\t\t\t\t\t\tpt->tx_ring, pt->mp, NULL);\n+\t\t\t}\n+\t\t} else if (pt->dir == RTE_PDUMP_FLAG_RX) {\n+\t\t\tif (pt->dump_by_type == DEVICE_ID)\n+\t\t\t\tret = rte_pdump_enable_by_deviceid(pt->device_id,\n+\t\t\t\t\t\t\t\tpt->queue,\n+\t\t\t\t\t\t\t\tpt->dir, pt->rx_ring,\n+\t\t\t\t\t\t\t\tpt->mp, NULL);\n+\t\t\telse if (pt->dump_by_type == PORT_ID)\n+\t\t\t\tret = rte_pdump_enable(pt->port, pt->queue, pt->dir,\n+\t\t\t\t\t\tpt->rx_ring, pt->mp, NULL);\n+\t\t} else if (pt->dir == RTE_PDUMP_FLAG_TX) {\n+\t\t\tif (pt->dump_by_type == DEVICE_ID)\n+\t\t\t\tret = rte_pdump_enable_by_deviceid(pt->device_id,\n+\t\t\t\t\t\t\t\tpt->queue,\n+\t\t\t\t\t\t\t\tpt->dir,\n+\t\t\t\t\t\tpt->tx_ring, pt->mp, NULL);\n+\t\t\telse if (pt->dump_by_type == PORT_ID)\n+\t\t\t\tret = rte_pdump_enable(pt->port, pt->queue, pt->dir,\n+\t\t\t\t\t\tpt->tx_ring, pt->mp, NULL);\n+\t\t}\n+\t\tif (ret < 0 || ret1 < 0) {\n+\t\t\tcleanup_pdump_resources();\n+\t\t\trte_exit(EXIT_FAILURE, \"%s\\n\", rte_strerror(rte_errno));\n+\t\t}\n+\t}\n+}\n+\n+static inline void\n+pdump_rxtx(struct rte_ring *ring, uint8_t vdev_id, struct pdump_stats *stats)\n+{\n+\t/* write input packets of port to vdev for pdump */\n+\tstruct rte_mbuf *rxtx_bufs[BURST_SIZE];\n+\n+\t/* first dequeue packets from ring of primary process */\n+\tconst uint16_t nb_in_deq = rte_ring_dequeue_burst(ring,\n+\t\t\t(void *)rxtx_bufs, BURST_SIZE);\n+\tstats->dequeue_pkts += nb_in_deq;\n+\n+\tif (nb_in_deq) {\n+\t\t/* then sent on vdev */\n+\t\tuint16_t nb_in_txd = rte_eth_tx_burst(\n+\t\t\t\tvdev_id,\n+\t\t\t\t0, rxtx_bufs, nb_in_deq);\n+\t\tstats->tx_pkts += nb_in_txd;\n+\n+\t\tif (unlikely(nb_in_txd < nb_in_deq)) {\n+\t\t\tdo {\n+\t\t\t\trte_pktmbuf_free(rxtx_bufs[nb_in_txd]);\n+\t\t\t\tstats->freed_pkts++;\n+\t\t\t} while (++nb_in_txd < nb_in_deq);\n+\t\t}\n+\t}\n+}\n+\n+static inline void\n+dump_packets(void)\n+{\n+\tint i;\n+\tstruct pdump_tuples *pt;\n+\n+\twhile (!quit_signal) {\n+\t\tfor (i = 0; i < num_tuples; i++) {\n+\t\t\tpt = &pdump_t[i];\n+\t\t\tif (pt->single_pdump_dev && pt->dir == RTE_PDUMP_FLAG_RXTX)\n+\t\t\t\tpdump_rxtx(pt->rxtx_ring, pt->rxtx_vdev_id, &pt->stats);\n+\t\t\telse if (pt->dir == RTE_PDUMP_FLAG_RXTX) {\n+\t\t\t\tpdump_rxtx(pt->rx_ring, pt->rx_vdev_id, &pt->stats);\n+\t\t\t\tpdump_rxtx(pt->tx_ring, pt->tx_vdev_id, &pt->stats);\n+\t\t\t} else if (pt->dir == RTE_PDUMP_FLAG_RX)\n+\t\t\t\tpdump_rxtx(pt->rx_ring, pt->rx_vdev_id, &pt->stats);\n+\t\t\telse if (pt->dir == RTE_PDUMP_FLAG_TX)\n+\t\t\t\tpdump_rxtx(pt->tx_ring, pt->tx_vdev_id, &pt->stats);\n+\t\t}\n+\t}\n+}\n+\n+int\n+main(int argc, char **argv)\n+{\n+\tint diag;\n+\tint ret;\n+\tint i;\n+\n+\tchar c_flag[] = \"-c1\";\n+\tchar n_flag[] = \"-n4\";\n+\tchar mp_flag[] = \"--proc-type=secondary\";\n+\tchar *argp[argc + 3];\n+\n+\t/* catch ctrl-c so we can print on exit */\n+\tsignal(SIGINT, signal_handler);\n+\n+\targp[0] = argv[0];\n+\targp[1] = c_flag;\n+\targp[2] = n_flag;\n+\targp[3] = mp_flag;\n+\n+\tfor (i = 1; i < argc; i++)\n+\t\targp[i + 3] = argv[i];\n+\n+\targc += 3;\n+\n+\tdiag = rte_eal_init(argc, argp);\n+\tif (diag < 0)\n+\t\trte_panic(\"Cannot init EAL\\n\");\n+\n+\targc -= diag;\n+\targv += (diag - 3);\n+\n+\t/* parse app arguments */\n+\tif (argc > 1) {\n+\t\tret = launch_args_parse(argc, argv);\n+\t\tif (ret < 0)\n+\t\t\trte_exit(EXIT_FAILURE, \"Invalid argument\\n\");\n+\t}\n+\n+\t/* create mempool, ring and vdevs info */\n+\tcreate_mp_ring_vdev();\n+\tenable_pdump();\n+\tdump_packets();\n+\n+\treturn 0;\n+}\n",
    "prefixes": [
        "dpdk-dev",
        "PATCHv2",
        "3/5"
    ]
}