Patch Detail

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

{
    "id": 131346,
    "url": "http://patchwork.dpdk.org/api/patches/131346/?format=api",
    "web_url": "http://patchwork.dpdk.org/project/dpdk/patch/20230912063903.1266245-3-feifei.wang2@arm.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": "<20230912063903.1266245-3-feifei.wang2@arm.com>",
    "list_archive_url": "https://inbox.dpdk.org/dev/20230912063903.1266245-3-feifei.wang2@arm.com",
    "date": "2023-09-12T06:39:02",
    "name": "[v3,2/3] app/test-pipeline: fix SIGINT handling issue",
    "commit_ref": null,
    "pull_url": null,
    "state": "accepted",
    "archived": true,
    "hash": "1527d13aca2854ccdc33d8f269d4d664fff6483c",
    "submitter": {
        "id": 1771,
        "url": "http://patchwork.dpdk.org/api/people/1771/?format=api",
        "name": "Feifei Wang",
        "email": "feifei.wang2@arm.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/20230912063903.1266245-3-feifei.wang2@arm.com/mbox/",
    "series": [
        {
            "id": 29482,
            "url": "http://patchwork.dpdk.org/api/series/29482/?format=api",
            "web_url": "http://patchwork.dpdk.org/project/dpdk/list/?series=29482",
            "date": "2023-09-12T06:39:00",
            "name": "fix test-pipeline issues",
            "version": 3,
            "mbox": "http://patchwork.dpdk.org/series/29482/mbox/"
        }
    ],
    "comments": "http://patchwork.dpdk.org/api/patches/131346/comments/",
    "check": "success",
    "checks": "http://patchwork.dpdk.org/api/patches/131346/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 EBE1A42579;\n\tTue, 12 Sep 2023 08:39:26 +0200 (CEST)",
            "from mails.dpdk.org (localhost [127.0.0.1])\n\tby mails.dpdk.org (Postfix) with ESMTP id 6BF96402E7;\n\tTue, 12 Sep 2023 08:39:20 +0200 (CEST)",
            "from foss.arm.com (foss.arm.com [217.140.110.172])\n by mails.dpdk.org (Postfix) with ESMTP id BFE0C402E6;\n Tue, 12 Sep 2023 08:39:18 +0200 (CEST)",
            "from usa-sjc-imap-foss1.foss.arm.com (unknown [10.121.207.14])\n by usa-sjc-mx-foss1.foss.arm.com (Postfix) with ESMTP id 44CABD75;\n Mon, 11 Sep 2023 23:39:55 -0700 (PDT)",
            "from net-x86-dell-8268.shanghai.arm.com\n (net-x86-dell-8268.shanghai.arm.com [10.169.210.116])\n by usa-sjc-imap-foss1.foss.arm.com (Postfix) with ESMTPA id 784DA3F67D;\n Mon, 11 Sep 2023 23:39:15 -0700 (PDT)"
        ],
        "From": "Feifei Wang <feifei.wang2@arm.com>",
        "To": "Cristian Dumitrescu <cristian.dumitrescu@intel.com>,\n Pablo de Lara <pablo.de.lara.guarch@intel.com>",
        "Cc": "dev@dpdk.org, nd@arm.com, Feifei Wang <feifei.wang2@arm.com>,\n stable@dpdk.org, Ruifeng Wang <ruifeng.wang@arm.com>,\n Matthew Dirba <Matthew.Dirba@arm.com>",
        "Subject": "[PATCH v3 2/3] app/test-pipeline: fix SIGINT handling issue",
        "Date": "Tue, 12 Sep 2023 14:39:02 +0800",
        "Message-Id": "<20230912063903.1266245-3-feifei.wang2@arm.com>",
        "X-Mailer": "git-send-email 2.25.1",
        "In-Reply-To": "<20230912063903.1266245-1-feifei.wang2@arm.com>",
        "References": "<20230626074538.3354554-1-feifei.wang2@arm.com>\n <20230912063903.1266245-1-feifei.wang2@arm.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": "For test-pipeline, if the main core receive SIGINT signal, it will kill\nall the threads immediately and not wait other threads to finish their\njobs.\n\nTo fix this, add 'signal_handler' function.\n\nFixes: 48f31ca50cc4 (\"app/pipeline: packet framework benchmark\")\nCc: cristian.dumitrescu@intel.com\nCc: stable@dpdk.org\n\nSigned-off-by: Feifei Wang <feifei.wang2@arm.com>\nReviewed-by: Ruifeng Wang <ruifeng.wang@arm.com>\nReviewed-by: Matthew Dirba <Matthew.Dirba@arm.com>\n---\n app/test-pipeline/main.c              |  14 +++\n app/test-pipeline/main.h              |   2 +\n app/test-pipeline/pipeline_acl.c      |   6 +-\n app/test-pipeline/pipeline_hash.c     | 110 ++++++++++-----------\n app/test-pipeline/pipeline_lpm.c      |   6 +-\n app/test-pipeline/pipeline_lpm_ipv6.c |   6 +-\n app/test-pipeline/pipeline_stub.c     |   6 +-\n app/test-pipeline/runtime.c           | 132 ++++++++++++++------------\n 8 files changed, 158 insertions(+), 124 deletions(-)",
    "diff": "diff --git a/app/test-pipeline/main.c b/app/test-pipeline/main.c\nindex 1e16794183..8633933fd9 100644\n--- a/app/test-pipeline/main.c\n+++ b/app/test-pipeline/main.c\n@@ -10,6 +10,7 @@\n #include <string.h>\n #include <sys/queue.h>\n #include <stdarg.h>\n+#include <signal.h>\n #include <errno.h>\n #include <getopt.h>\n #include <unistd.h>\n@@ -41,6 +42,15 @@\n \n #include \"main.h\"\n \n+bool force_quit;\n+\n+static void\n+signal_handler(int signum)\n+{\n+\tif (signum == SIGINT || signum == SIGTERM)\n+\t\tforce_quit = true;\n+}\n+\n int\n main(int argc, char **argv)\n {\n@@ -54,6 +64,10 @@ main(int argc, char **argv)\n \targc -= ret;\n \targv += ret;\n \n+\tforce_quit = false;\n+\tsignal(SIGINT, signal_handler);\n+\tsignal(SIGTERM, signal_handler);\n+\n \t/* Parse application arguments (after the EAL ones) */\n \tret = app_parse_args(argc, argv);\n \tif (ret < 0) {\ndiff --git a/app/test-pipeline/main.h b/app/test-pipeline/main.h\nindex 59dcfddbf4..9df157de22 100644\n--- a/app/test-pipeline/main.h\n+++ b/app/test-pipeline/main.h\n@@ -60,6 +60,8 @@ struct app_params {\n \n extern struct app_params app;\n \n+extern bool force_quit;\n+\n int app_parse_args(int argc, char **argv);\n void app_print_usage(void);\n void app_init(void);\ndiff --git a/app/test-pipeline/pipeline_acl.c b/app/test-pipeline/pipeline_acl.c\nindex 2f04868e3e..9eb4053e23 100644\n--- a/app/test-pipeline/pipeline_acl.c\n+++ b/app/test-pipeline/pipeline_acl.c\n@@ -236,14 +236,16 @@ app_main_loop_worker_pipeline_acl(void) {\n \n \t/* Run-time */\n #if APP_FLUSH == 0\n-\tfor ( ; ; )\n+\twhile (!force_quit)\n \t\trte_pipeline_run(p);\n #else\n-\tfor (i = 0; ; i++) {\n+\ti = 0;\n+\twhile (!force_quit) {\n \t\trte_pipeline_run(p);\n \n \t\tif ((i & APP_FLUSH) == 0)\n \t\t\trte_pipeline_flush(p);\n+\t\ti++;\n \t}\n #endif\n }\ndiff --git a/app/test-pipeline/pipeline_hash.c b/app/test-pipeline/pipeline_hash.c\nindex 2dd8928d43..cab9c20980 100644\n--- a/app/test-pipeline/pipeline_hash.c\n+++ b/app/test-pipeline/pipeline_hash.c\n@@ -366,14 +366,16 @@ app_main_loop_worker_pipeline_hash(void) {\n \n \t/* Run-time */\n #if APP_FLUSH == 0\n-\tfor ( ; ; )\n+\twhile (!force_quit)\n \t\trte_pipeline_run(p);\n #else\n-\tfor (i = 0; ; i++) {\n+\ti = 0;\n+\twhile (!force_quit) {\n \t\trte_pipeline_run(p);\n \n \t\tif ((i & APP_FLUSH) == 0)\n \t\t\trte_pipeline_flush(p);\n+\t\ti++;\n \t}\n #endif\n }\n@@ -411,59 +413,61 @@ app_main_loop_rx_metadata(void) {\n \tRTE_LOG(INFO, USER1, \"Core %u is doing RX (with meta-data)\\n\",\n \t\trte_lcore_id());\n \n-\tfor (i = 0; ; i = ((i + 1) & (app.n_ports - 1))) {\n-\t\tuint16_t n_mbufs;\n-\n-\t\tn_mbufs = rte_eth_rx_burst(\n-\t\t\tapp.ports[i],\n-\t\t\t0,\n-\t\t\tapp.mbuf_rx.array,\n-\t\t\tapp.burst_size_rx_read);\n-\n-\t\tif (n_mbufs == 0)\n-\t\t\tcontinue;\n-\n-\t\tfor (j = 0; j < n_mbufs; j++) {\n-\t\t\tstruct rte_mbuf *m;\n-\t\t\tuint8_t *m_data, *key;\n-\t\t\tstruct rte_ipv4_hdr *ip_hdr;\n-\t\t\tstruct rte_ipv6_hdr *ipv6_hdr;\n-\t\t\tuint32_t ip_dst;\n-\t\t\tuint8_t *ipv6_dst;\n-\t\t\tuint32_t *signature, *k32;\n-\n-\t\t\tm = app.mbuf_rx.array[j];\n-\t\t\tm_data = rte_pktmbuf_mtod(m, uint8_t *);\n-\t\t\tsignature = RTE_MBUF_METADATA_UINT32_PTR(m,\n-\t\t\t\t\tAPP_METADATA_OFFSET(0));\n-\t\t\tkey = RTE_MBUF_METADATA_UINT8_PTR(m,\n-\t\t\t\t\tAPP_METADATA_OFFSET(32));\n-\n-\t\t\tif (RTE_ETH_IS_IPV4_HDR(m->packet_type)) {\n-\t\t\t\tip_hdr = (struct rte_ipv4_hdr *)\n-\t\t\t\t\t&m_data[sizeof(struct rte_ether_hdr)];\n-\t\t\t\tip_dst = ip_hdr->dst_addr;\n-\n-\t\t\t\tk32 = (uint32_t *) key;\n-\t\t\t\tk32[0] = ip_dst & 0xFFFFFF00;\n-\t\t\t} else if (RTE_ETH_IS_IPV6_HDR(m->packet_type)) {\n-\t\t\t\tipv6_hdr = (struct rte_ipv6_hdr *)\n-\t\t\t\t\t&m_data[sizeof(struct rte_ether_hdr)];\n-\t\t\t\tipv6_dst = ipv6_hdr->dst_addr;\n-\n-\t\t\t\tmemcpy(key, ipv6_dst, 16);\n-\t\t\t} else\n+\twhile (!force_quit) {\n+\t\tfor (i = 0; i < app.n_ports; i++) {\n+\t\t\tuint16_t n_mbufs;\n+\n+\t\t\tn_mbufs = rte_eth_rx_burst(\n+\t\t\t\tapp.ports[i],\n+\t\t\t\t0,\n+\t\t\t\tapp.mbuf_rx.array,\n+\t\t\t\tapp.burst_size_rx_read);\n+\n+\t\t\tif (n_mbufs == 0)\n \t\t\t\tcontinue;\n \n-\t\t\t*signature = test_hash(key, NULL, 0, 0);\n+\t\t\tfor (j = 0; j < n_mbufs; j++) {\n+\t\t\t\tstruct rte_mbuf *m;\n+\t\t\t\tuint8_t *m_data, *key;\n+\t\t\t\tstruct rte_ipv4_hdr *ip_hdr;\n+\t\t\t\tstruct rte_ipv6_hdr *ipv6_hdr;\n+\t\t\t\tuint32_t ip_dst;\n+\t\t\t\tuint8_t *ipv6_dst;\n+\t\t\t\tuint32_t *signature, *k32;\n+\n+\t\t\t\tm = app.mbuf_rx.array[j];\n+\t\t\t\tm_data = rte_pktmbuf_mtod(m, uint8_t *);\n+\t\t\t\tsignature = RTE_MBUF_METADATA_UINT32_PTR(m,\n+\t\t\t\t\t\tAPP_METADATA_OFFSET(0));\n+\t\t\t\tkey = RTE_MBUF_METADATA_UINT8_PTR(m,\n+\t\t\t\t\t\tAPP_METADATA_OFFSET(32));\n+\n+\t\t\t\tif (RTE_ETH_IS_IPV4_HDR(m->packet_type)) {\n+\t\t\t\t\tip_hdr = (struct rte_ipv4_hdr *)\n+\t\t\t\t\t\t&m_data[sizeof(struct rte_ether_hdr)];\n+\t\t\t\t\tip_dst = ip_hdr->dst_addr;\n+\n+\t\t\t\t\tk32 = (uint32_t *) key;\n+\t\t\t\t\tk32[0] = ip_dst & 0xFFFFFF00;\n+\t\t\t\t} else if (RTE_ETH_IS_IPV6_HDR(m->packet_type)) {\n+\t\t\t\t\tipv6_hdr = (struct rte_ipv6_hdr *)\n+\t\t\t\t\t\t&m_data[sizeof(struct rte_ether_hdr)];\n+\t\t\t\t\tipv6_dst = ipv6_hdr->dst_addr;\n+\n+\t\t\t\t\tmemcpy(key, ipv6_dst, 16);\n+\t\t\t\t} else\n+\t\t\t\t\tcontinue;\n+\n+\t\t\t\t*signature = test_hash(key, NULL, 0, 0);\n+\t\t\t}\n+\n+\t\t\tdo {\n+\t\t\t\tret = rte_ring_sp_enqueue_bulk(\n+\t\t\t\t\tapp.rings_rx[i],\n+\t\t\t\t\t(void **) app.mbuf_rx.array,\n+\t\t\t\t\tn_mbufs,\n+\t\t\t\t\tNULL);\n+\t\t\t} while (ret == 0 && !force_quit);\n \t\t}\n-\n-\t\tdo {\n-\t\t\tret = rte_ring_sp_enqueue_bulk(\n-\t\t\t\tapp.rings_rx[i],\n-\t\t\t\t(void **) app.mbuf_rx.array,\n-\t\t\t\tn_mbufs,\n-\t\t\t\tNULL);\n-\t\t} while (ret == 0);\n \t}\n }\ndiff --git a/app/test-pipeline/pipeline_lpm.c b/app/test-pipeline/pipeline_lpm.c\nindex 854319174b..8a59bd0042 100644\n--- a/app/test-pipeline/pipeline_lpm.c\n+++ b/app/test-pipeline/pipeline_lpm.c\n@@ -160,14 +160,16 @@ app_main_loop_worker_pipeline_lpm(void) {\n \n \t/* Run-time */\n #if APP_FLUSH == 0\n-\tfor ( ; ; )\n+\twhile (!force_quit)\n \t\trte_pipeline_run(p);\n #else\n-\tfor (i = 0; ; i++) {\n+\ti = 0;\n+\twhile (!force_quit) {\n \t\trte_pipeline_run(p);\n \n \t\tif ((i & APP_FLUSH) == 0)\n \t\t\trte_pipeline_flush(p);\n+\t\ti++;\n \t}\n #endif\n }\ndiff --git a/app/test-pipeline/pipeline_lpm_ipv6.c b/app/test-pipeline/pipeline_lpm_ipv6.c\nindex 18d4f018f1..207ffbeff0 100644\n--- a/app/test-pipeline/pipeline_lpm_ipv6.c\n+++ b/app/test-pipeline/pipeline_lpm_ipv6.c\n@@ -158,14 +158,16 @@ app_main_loop_worker_pipeline_lpm_ipv6(void) {\n \n \t/* Run-time */\n #if APP_FLUSH == 0\n-\tfor ( ; ; )\n+\twhile (!force_quit)\n \t\trte_pipeline_run(p);\n #else\n-\tfor (i = 0; ; i++) {\n+\ti = 0;\n+\twhile (!force_quit) {\n \t\trte_pipeline_run(p);\n \n \t\tif ((i & APP_FLUSH) == 0)\n \t\t\trte_pipeline_flush(p);\n+\t\ti++;\n \t}\n #endif\n }\ndiff --git a/app/test-pipeline/pipeline_stub.c b/app/test-pipeline/pipeline_stub.c\nindex b6750d51bf..48a638aad7 100644\n--- a/app/test-pipeline/pipeline_stub.c\n+++ b/app/test-pipeline/pipeline_stub.c\n@@ -122,14 +122,16 @@ app_main_loop_worker_pipeline_stub(void) {\n \n \t/* Run-time */\n #if APP_FLUSH == 0\n-\tfor ( ; ; )\n+\twhile (!force_quit)\n \t\trte_pipeline_run(p);\n #else\n-\tfor (i = 0; ; i++) {\n+\ti = 0;\n+\twhile (!force_quit) {\n \t\trte_pipeline_run(p);\n \n \t\tif ((i & APP_FLUSH) == 0)\n \t\t\trte_pipeline_flush(p);\n+\t\ti++;\n \t}\n #endif\n }\ndiff --git a/app/test-pipeline/runtime.c b/app/test-pipeline/runtime.c\nindex d939a85d7e..752f783370 100644\n--- a/app/test-pipeline/runtime.c\n+++ b/app/test-pipeline/runtime.c\n@@ -48,24 +48,26 @@ app_main_loop_rx(void) {\n \n \tRTE_LOG(INFO, USER1, \"Core %u is doing RX\\n\", rte_lcore_id());\n \n-\tfor (i = 0; ; i = ((i + 1) & (app.n_ports - 1))) {\n-\t\tuint16_t n_mbufs;\n-\n-\t\tn_mbufs = rte_eth_rx_burst(\n-\t\t\tapp.ports[i],\n-\t\t\t0,\n-\t\t\tapp.mbuf_rx.array,\n-\t\t\tapp.burst_size_rx_read);\n-\n-\t\tif (n_mbufs == 0)\n-\t\t\tcontinue;\n-\n-\t\tdo {\n-\t\t\tret = rte_ring_sp_enqueue_bulk(\n-\t\t\t\tapp.rings_rx[i],\n-\t\t\t\t(void **) app.mbuf_rx.array,\n-\t\t\t\tn_mbufs, NULL);\n-\t\t} while (ret == 0);\n+\twhile (!force_quit) {\n+\t\tfor (i = 0; i < app.n_ports; i++) {\n+\t\t\tuint16_t n_mbufs;\n+\n+\t\t\tn_mbufs = rte_eth_rx_burst(\n+\t\t\t\tapp.ports[i],\n+\t\t\t\t0,\n+\t\t\t\tapp.mbuf_rx.array,\n+\t\t\t\tapp.burst_size_rx_read);\n+\n+\t\t\tif (n_mbufs == 0)\n+\t\t\t\tcontinue;\n+\n+\t\t\tdo {\n+\t\t\t\tret = rte_ring_sp_enqueue_bulk(\n+\t\t\t\t\tapp.rings_rx[i],\n+\t\t\t\t\t(void **) app.mbuf_rx.array,\n+\t\t\t\t\tn_mbufs, NULL);\n+\t\t\t} while (ret == 0 && !force_quit);\n+\t\t}\n \t}\n }\n \n@@ -82,25 +84,27 @@ app_main_loop_worker(void) {\n \tif (worker_mbuf == NULL)\n \t\trte_panic(\"Worker thread: cannot allocate buffer space\\n\");\n \n-\tfor (i = 0; ; i = ((i + 1) & (app.n_ports - 1))) {\n-\t\tint ret;\n-\n-\t\tret = rte_ring_sc_dequeue_bulk(\n-\t\t\tapp.rings_rx[i],\n-\t\t\t(void **) worker_mbuf->array,\n-\t\t\tapp.burst_size_worker_read,\n-\t\t\tNULL);\n+\twhile (!force_quit) {\n+\t\tfor (i = 0; i < app.n_ports; i++) {\n+\t\t\tint ret;\n \n-\t\tif (ret == 0)\n-\t\t\tcontinue;\n-\n-\t\tdo {\n-\t\t\tret = rte_ring_sp_enqueue_bulk(\n-\t\t\t\tapp.rings_tx[i ^ 1],\n+\t\t\tret = rte_ring_sc_dequeue_bulk(\n+\t\t\t\tapp.rings_rx[i],\n \t\t\t\t(void **) worker_mbuf->array,\n-\t\t\t\tapp.burst_size_worker_write,\n+\t\t\t\tapp.burst_size_worker_read,\n \t\t\t\tNULL);\n-\t\t} while (ret == 0);\n+\n+\t\t\tif (ret == 0)\n+\t\t\t\tcontinue;\n+\n+\t\t\tdo {\n+\t\t\t\tret = rte_ring_sp_enqueue_bulk(\n+\t\t\t\t\tapp.rings_tx[i ^ 1],\n+\t\t\t\t\t(void **) worker_mbuf->array,\n+\t\t\t\t\tapp.burst_size_worker_write,\n+\t\t\t\t\tNULL);\n+\t\t\t} while (ret == 0 && !force_quit);\n+\t\t}\n \t}\n }\n \n@@ -110,45 +114,47 @@ app_main_loop_tx(void) {\n \n \tRTE_LOG(INFO, USER1, \"Core %u is doing TX\\n\", rte_lcore_id());\n \n-\tfor (i = 0; ; i = ((i + 1) & (app.n_ports - 1))) {\n-\t\tuint16_t n_mbufs, n_pkts;\n-\t\tint ret;\n+\twhile (!force_quit) {\n+\t\tfor (i = 0; i < app.n_ports; i++) {\n+\t\t\tuint16_t n_mbufs, n_pkts;\n+\t\t\tint ret;\n \n-\t\tn_mbufs = app.mbuf_tx[i].n_mbufs;\n+\t\t\tn_mbufs = app.mbuf_tx[i].n_mbufs;\n \n-\t\tret = rte_ring_sc_dequeue_bulk(\n-\t\t\tapp.rings_tx[i],\n-\t\t\t(void **) &app.mbuf_tx[i].array[n_mbufs],\n-\t\t\tapp.burst_size_tx_read,\n-\t\t\tNULL);\n+\t\t\tret = rte_ring_sc_dequeue_bulk(\n+\t\t\t\tapp.rings_tx[i],\n+\t\t\t\t(void **) &app.mbuf_tx[i].array[n_mbufs],\n+\t\t\t\tapp.burst_size_tx_read,\n+\t\t\t\tNULL);\n \n-\t\tif (ret == 0)\n-\t\t\tcontinue;\n+\t\t\tif (ret == 0)\n+\t\t\t\tcontinue;\n \n-\t\tn_mbufs += app.burst_size_tx_read;\n+\t\t\tn_mbufs += app.burst_size_tx_read;\n \n-\t\tif (n_mbufs < app.burst_size_tx_write) {\n-\t\t\tapp.mbuf_tx[i].n_mbufs = n_mbufs;\n-\t\t\tcontinue;\n-\t\t}\n+\t\t\tif (n_mbufs < app.burst_size_tx_write) {\n+\t\t\t\tapp.mbuf_tx[i].n_mbufs = n_mbufs;\n+\t\t\t\tcontinue;\n+\t\t\t}\n \n-\t\tn_pkts = rte_eth_tx_burst(\n-\t\t\tapp.ports[i],\n-\t\t\t0,\n-\t\t\tapp.mbuf_tx[i].array,\n-\t\t\tn_mbufs);\n+\t\t\tn_pkts = rte_eth_tx_burst(\n+\t\t\t\tapp.ports[i],\n+\t\t\t\t0,\n+\t\t\t\tapp.mbuf_tx[i].array,\n+\t\t\t\tn_mbufs);\n \n-\t\tif (n_pkts < n_mbufs) {\n-\t\t\tuint16_t k;\n+\t\t\tif (n_pkts < n_mbufs) {\n+\t\t\t\tuint16_t k;\n \n-\t\t\tfor (k = n_pkts; k < n_mbufs; k++) {\n-\t\t\t\tstruct rte_mbuf *pkt_to_free;\n+\t\t\t\tfor (k = n_pkts; k < n_mbufs; k++) {\n+\t\t\t\t\tstruct rte_mbuf *pkt_to_free;\n \n-\t\t\t\tpkt_to_free = app.mbuf_tx[i].array[k];\n-\t\t\t\trte_pktmbuf_free(pkt_to_free);\n+\t\t\t\t\tpkt_to_free = app.mbuf_tx[i].array[k];\n+\t\t\t\t\trte_pktmbuf_free(pkt_to_free);\n+\t\t\t\t}\n \t\t\t}\n-\t\t}\n \n-\t\tapp.mbuf_tx[i].n_mbufs = 0;\n+\t\t\tapp.mbuf_tx[i].n_mbufs = 0;\n+\t\t}\n \t}\n }\n",
    "prefixes": [
        "v3",
        "2/3"
    ]
}