Patch Detail
get:
Show a patch.
patch:
Update a patch.
put:
Update a patch.
GET /api/patches/109147/?format=api
{ "id": 109147, "url": "https://patches.dpdk.org/api/patches/109147/?format=api", "web_url": "https://patches.dpdk.org/project/dpdk/patch/20220405123002.40671-1-cristian.dumitrescu@intel.com/", "project": { "id": 1, "url": "https://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": "<20220405123002.40671-1-cristian.dumitrescu@intel.com>", "list_archive_url": "https://inbox.dpdk.org/dev/20220405123002.40671-1-cristian.dumitrescu@intel.com", "date": "2022-04-05T12:30:00", "name": "[V2,1/3] port: support packet mirroring", "commit_ref": null, "pull_url": null, "state": "superseded", "archived": true, "hash": "2550aaba151e598d840a7271c9a275b45916c4ad", "submitter": { "id": 19, "url": "https://patches.dpdk.org/api/people/19/?format=api", "name": "Cristian Dumitrescu", "email": "cristian.dumitrescu@intel.com" }, "delegate": { "id": 1, "url": "https://patches.dpdk.org/api/users/1/?format=api", "username": "tmonjalo", "first_name": "Thomas", "last_name": "Monjalon", "email": "thomas@monjalon.net" }, "mbox": "https://patches.dpdk.org/project/dpdk/patch/20220405123002.40671-1-cristian.dumitrescu@intel.com/mbox/", "series": [ { "id": 22351, "url": "https://patches.dpdk.org/api/series/22351/?format=api", "web_url": "https://patches.dpdk.org/project/dpdk/list/?series=22351", "date": "2022-04-05T12:30:00", "name": "[V2,1/3] port: support packet mirroring", "version": 2, "mbox": "https://patches.dpdk.org/series/22351/mbox/" } ], "comments": "https://patches.dpdk.org/api/patches/109147/comments/", "check": "success", "checks": "https://patches.dpdk.org/api/patches/109147/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 E519DA0509;\n\tTue, 5 Apr 2022 14:30:08 +0200 (CEST)", "from [217.70.189.124] (localhost [127.0.0.1])\n\tby mails.dpdk.org (Postfix) with ESMTP id 78E9240F35;\n\tTue, 5 Apr 2022 14:30:08 +0200 (CEST)", "from mga04.intel.com (mga04.intel.com [192.55.52.120])\n by mails.dpdk.org (Postfix) with ESMTP id 31CEF40DF6\n for <dev@dpdk.org>; Tue, 5 Apr 2022 14:30:05 +0200 (CEST)", "from orsmga002.jf.intel.com ([10.7.209.21])\n by fmsmga104.fm.intel.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384;\n 05 Apr 2022 05:30:05 -0700", "from silpixa00400573.ir.intel.com (HELO\n silpixa00400573.ger.corp.intel.com) ([10.237.223.107])\n by orsmga002.jf.intel.com with ESMTP; 05 Apr 2022 05:30:03 -0700" ], "DKIM-Signature": "v=1; a=rsa-sha256; c=relaxed/simple;\n d=intel.com; i=@intel.com; q=dns/txt; s=Intel;\n t=1649161806; x=1680697806;\n h=from:to:cc:subject:date:message-id:in-reply-to: references;\n bh=Xp/wjiLaSYg9aMxxnlefhSoA+Q3Unk5nofpZyZ18sr8=;\n b=B7OfRoannpzvcEcUuBTaryVy1Jx9IeCp7AiZ66K5lObSrD9zuA73UJcM\n gBg9QTh/MblSxPmSrro7jMnL9FiZgkzPZlz3+RYIatLm+43DlC/PwTrbz\n cA35oKyoMk9fPZQnfUUGfeSvB7gVUg/emrFq7Blz5mt28HscFDIikacEI\n smnxDgQadB/LM/Z9+5u0KDEsvez4naZIPNanKU1ngHFtLWG0kqKj4aC26\n 8kP3/ft+T4if9hm2riBD9piAGvY+pyISygBcDf9B6Qn5ttswoYU96hn5s\n WeIdl90ZpTKPhm6nOkEpLfue7kHKOQEce7aoOFe5IBufxUhkF6qnJ6Lw0 Q==;", "X-IronPort-AV": [ "E=McAfee;i=\"6200,9189,10307\"; a=\"259567319\"", "E=Sophos;i=\"5.90,236,1643702400\"; d=\"scan'208\";a=\"259567319\"", "E=Sophos;i=\"5.90,236,1643702400\"; d=\"scan'208\";a=\"523441133\"" ], "X-ExtLoop1": "1", "From": "Cristian Dumitrescu <cristian.dumitrescu@intel.com>", "To": "dev@dpdk.org", "Cc": "Kamalakannan R <kamalakannan.r@intel.com>", "Subject": "[PATCH V2 1/3] port: support packet mirroring", "Date": "Tue, 5 Apr 2022 13:30:00 +0100", "Message-Id": "<20220405123002.40671-1-cristian.dumitrescu@intel.com>", "X-Mailer": "git-send-email 2.17.1", "In-Reply-To": "<20220304180623.74893-1-cristian.dumitrescu@intel.com>", "References": "<20220304180623.74893-1-cristian.dumitrescu@intel.com>", "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": "Add packet clone operation to the output ports in order to support\npacket mirroring.\n\nSigned-off-by: Cristian Dumitrescu <cristian.dumitrescu@intel.com>\nSigned-off-by: Kamalakannan R <kamalakannan.r@intel.com>\n---\n lib/port/rte_swx_port.h | 37 ++++++++++++++++\n lib/port/rte_swx_port_ethdev.c | 67 ++++++++++++++++++++++++++++-\n lib/port/rte_swx_port_fd.c | 65 +++++++++++++++++++++++++++-\n lib/port/rte_swx_port_ring.c | 65 +++++++++++++++++++++++++++-\n lib/port/rte_swx_port_source_sink.c | 51 +++++++++++++++++++++-\n 5 files changed, 281 insertions(+), 4 deletions(-)", "diff": "diff --git a/lib/port/rte_swx_port.h b/lib/port/rte_swx_port.h\nindex ecf109d2ca..2c94335ffd 100644\n--- a/lib/port/rte_swx_port.h\n+++ b/lib/port/rte_swx_port.h\n@@ -147,6 +147,31 @@ typedef void\n (*rte_swx_port_out_pkt_tx_t)(void *port,\n \t\t\t struct rte_swx_pkt *pkt);\n \n+/**\n+ * Output port packet fast clone and transmit\n+ *\n+ * @param[in] port\n+ * Output port handle.\n+ * @param[in] pkt\n+ * Packet to be transmitted.\n+ */\n+typedef void\n+(*rte_swx_port_out_pkt_fast_clone_tx_t)(void *port,\n+\t\t\t\t\tstruct rte_swx_pkt *pkt);\n+\n+/**\n+ * Output port packet clone and transmit\n+ *\n+ * @param[in] port\n+ * Output port handle.\n+ * @param[in] pkt\n+ * Packet to be transmitted.\n+ */\n+typedef void\n+(*rte_swx_port_out_pkt_clone_tx_t)(void *port,\n+\t\t\t\t struct rte_swx_pkt *pkt,\n+\t\t\t\t uint32_t truncation_length);\n+\n /**\n * Output port flush\n *\n@@ -163,6 +188,12 @@ struct rte_swx_port_out_stats {\n \n \t/** Number of bytes. */\n \tuint64_t n_bytes;\n+\n+\t/** Number of packets cloned successfully. */\n+\tuint64_t n_pkts_clone;\n+\n+\t/** Number of packets with clone errors. */\n+\tuint64_t n_pkts_clone_err;\n };\n \n /**\n@@ -188,6 +219,12 @@ struct rte_swx_port_out_ops {\n \t/** Packet transmission. Must be non-NULL. */\n \trte_swx_port_out_pkt_tx_t pkt_tx;\n \n+\t/** Packet fast clone and transmission. Must be non-NULL. */\n+\trte_swx_port_out_pkt_fast_clone_tx_t pkt_fast_clone_tx;\n+\n+\t/** Packet clone and transmission. Must be non-NULL. */\n+\trte_swx_port_out_pkt_clone_tx_t pkt_clone_tx;\n+\n \t/** Flush. May be NULL. */\n \trte_swx_port_out_flush_t flush;\n \ndiff --git a/lib/port/rte_swx_port_ethdev.c b/lib/port/rte_swx_port_ethdev.c\nindex 18d1c0b5db..ca4a43ac4f 100644\n--- a/lib/port/rte_swx_port_ethdev.c\n+++ b/lib/port/rte_swx_port_ethdev.c\n@@ -252,8 +252,8 @@ writer_pkt_tx(void *port, struct rte_swx_pkt *pkt)\n \tif (TRACE_LEVEL)\n \t\trte_hexdump(stdout, NULL, &pkt->pkt[pkt->offset], pkt->length);\n \n+\tm->data_len = (uint16_t)(pkt->length + m->data_len - m->pkt_len);\n \tm->pkt_len = pkt->length;\n-\tm->data_len = (uint16_t)pkt->length;\n \tm->data_off = (uint16_t)pkt->offset;\n \n \tp->stats.n_pkts++;\n@@ -264,6 +264,69 @@ writer_pkt_tx(void *port, struct rte_swx_pkt *pkt)\n \t\t__writer_flush(p);\n }\n \n+static void\n+writer_pkt_fast_clone_tx(void *port, struct rte_swx_pkt *pkt)\n+{\n+\tstruct writer *p = port;\n+\tstruct rte_mbuf *m = pkt->handle;\n+\n+\tTRACE(\"[Ethdev TX port %u queue %u] Pkt %d (%u bytes at offset %u) (fast clone)\\n\",\n+\t (uint32_t)p->params.port_id,\n+\t (uint32_t)p->params.queue_id,\n+\t p->n_pkts - 1,\n+\t pkt->length,\n+\t pkt->offset);\n+\tif (TRACE_LEVEL)\n+\t\trte_hexdump(stdout, NULL, &pkt->pkt[pkt->offset], pkt->length);\n+\n+\tm->data_len = (uint16_t)(pkt->length + m->data_len - m->pkt_len);\n+\tm->pkt_len = pkt->length;\n+\tm->data_off = (uint16_t)pkt->offset;\n+\trte_pktmbuf_refcnt_update(m, 1);\n+\n+\tp->stats.n_pkts++;\n+\tp->stats.n_bytes += pkt->length;\n+\tp->stats.n_pkts_clone++;\n+\n+\tp->pkts[p->n_pkts++] = m;\n+\tif (p->n_pkts == (int)p->params.burst_size)\n+\t\t__writer_flush(p);\n+}\n+\n+static void\n+writer_pkt_clone_tx(void *port, struct rte_swx_pkt *pkt, uint32_t truncation_length)\n+{\n+\tstruct writer *p = port;\n+\tstruct rte_mbuf *m = pkt->handle, *m_clone;\n+\n+\tTRACE(\"[Ethdev TX port %u queue %u] Pkt %d (%u bytes at offset %u) (clone)\\n\",\n+\t (uint32_t)p->params.port_id,\n+\t (uint32_t)p->params.queue_id,\n+\t p->n_pkts - 1,\n+\t pkt->length,\n+\t pkt->offset);\n+\tif (TRACE_LEVEL)\n+\t\trte_hexdump(stdout, NULL, &pkt->pkt[pkt->offset], pkt->length);\n+\n+\tm->data_len = (uint16_t)(pkt->length + m->data_len - m->pkt_len);\n+\tm->pkt_len = pkt->length;\n+\tm->data_off = (uint16_t)pkt->offset;\n+\n+\tm_clone = rte_pktmbuf_copy(m, m->pool, 0, truncation_length);\n+\tif (!m_clone) {\n+\t\tp->stats.n_pkts_clone_err++;\n+\t\treturn;\n+\t}\n+\n+\tp->stats.n_pkts++;\n+\tp->stats.n_bytes += pkt->length;\n+\tp->stats.n_pkts_clone++;\n+\n+\tp->pkts[p->n_pkts++] = m_clone;\n+\tif (p->n_pkts == (int)p->params.burst_size)\n+\t\t__writer_flush(p);\n+}\n+\n static void\n writer_flush(void *port)\n {\n@@ -308,6 +371,8 @@ struct rte_swx_port_out_ops rte_swx_port_ethdev_writer_ops = {\n \t.create = writer_create,\n \t.free = writer_free,\n \t.pkt_tx = writer_pkt_tx,\n+\t.pkt_fast_clone_tx = writer_pkt_fast_clone_tx,\n+\t.pkt_clone_tx = writer_pkt_clone_tx,\n \t.flush = writer_flush,\n \t.stats_read = writer_stats_read,\n };\ndiff --git a/lib/port/rte_swx_port_fd.c b/lib/port/rte_swx_port_fd.c\nindex 51bcd3bb7b..1ee5086684 100644\n--- a/lib/port/rte_swx_port_fd.c\n+++ b/lib/port/rte_swx_port_fd.c\n@@ -237,8 +237,8 @@ writer_pkt_tx(void *port, struct rte_swx_pkt *pkt)\n \tif (TRACE_LEVEL)\n \t\trte_hexdump(stdout, NULL, &pkt->pkt[pkt->offset], pkt->length);\n \n+\tm->data_len = (uint16_t)(pkt->length + m->data_len - m->pkt_len);\n \tm->pkt_len = pkt->length;\n-\tm->data_len = (uint16_t)pkt->length;\n \tm->data_off = (uint16_t)pkt->offset;\n \n \tp->stats.n_pkts++;\n@@ -249,6 +249,67 @@ writer_pkt_tx(void *port, struct rte_swx_pkt *pkt)\n \t\t__writer_flush(p);\n }\n \n+static void\n+writer_pkt_fast_clone_tx(void *port, struct rte_swx_pkt *pkt)\n+{\n+\tstruct writer *p = port;\n+\tstruct rte_mbuf *m = pkt->handle;\n+\n+\tTRACE(\"[FD %u] Pkt %u (%u bytes at offset %u) (fast clone)\\n\",\n+\t\t(uint32_t)p->params.fd,\n+\t\tp->n_pkts - 1,\n+\t\tpkt->length,\n+\t\tpkt->offset);\n+\tif (TRACE_LEVEL)\n+\t\trte_hexdump(stdout, NULL, &pkt->pkt[pkt->offset], pkt->length);\n+\n+\tm->data_len = (uint16_t)(pkt->length + m->data_len - m->pkt_len);\n+\tm->pkt_len = pkt->length;\n+\tm->data_off = (uint16_t)pkt->offset;\n+\trte_pktmbuf_refcnt_update(m, 1);\n+\n+\tp->stats.n_pkts++;\n+\tp->stats.n_bytes += pkt->length;\n+\tp->stats.n_pkts_clone++;\n+\n+\tp->pkts[p->n_pkts++] = m;\n+\tif (p->n_pkts == p->params.burst_size)\n+\t\t__writer_flush(p);\n+}\n+\n+static void\n+writer_pkt_clone_tx(void *port, struct rte_swx_pkt *pkt, uint32_t truncation_length)\n+{\n+\tstruct writer *p = port;\n+\tstruct rte_mbuf *m = pkt->handle, *m_clone;\n+\n+\tTRACE(\"[FD %u] Pkt %u (%u bytes at offset %u) (clone)\\n\",\n+\t\t(uint32_t)p->params.fd,\n+\t\tp->n_pkts - 1,\n+\t\tpkt->length,\n+\t\tpkt->offset);\n+\tif (TRACE_LEVEL)\n+\t\trte_hexdump(stdout, NULL, &pkt->pkt[pkt->offset], pkt->length);\n+\n+\tm->data_len = (uint16_t)(pkt->length + m->data_len - m->pkt_len);\n+\tm->pkt_len = pkt->length;\n+\tm->data_off = (uint16_t)pkt->offset;\n+\n+\tm_clone = rte_pktmbuf_copy(m, m->pool, 0, truncation_length);\n+\tif (!m_clone) {\n+\t\tp->stats.n_pkts_clone_err++;\n+\t\treturn;\n+\t}\n+\n+\tp->stats.n_pkts++;\n+\tp->stats.n_bytes += pkt->length;\n+\tp->stats.n_pkts_clone++;\n+\n+\tp->pkts[p->n_pkts++] = m_clone;\n+\tif (p->n_pkts == p->params.burst_size)\n+\t\t__writer_flush(p);\n+}\n+\n static void\n writer_flush(void *port)\n {\n@@ -293,6 +354,8 @@ struct rte_swx_port_out_ops rte_swx_port_fd_writer_ops = {\n \t.create = writer_create,\n \t.free = writer_free,\n \t.pkt_tx = writer_pkt_tx,\n+\t.pkt_fast_clone_tx = writer_pkt_fast_clone_tx,\n+\t.pkt_clone_tx = writer_pkt_clone_tx,\n \t.flush = writer_flush,\n \t.stats_read = writer_stats_read,\n };\ndiff --git a/lib/port/rte_swx_port_ring.c b/lib/port/rte_swx_port_ring.c\nindex 8a076a2135..c62fb3d8c8 100644\n--- a/lib/port/rte_swx_port_ring.c\n+++ b/lib/port/rte_swx_port_ring.c\n@@ -252,8 +252,8 @@ writer_pkt_tx(void *port, struct rte_swx_pkt *pkt)\n \tif (TRACE_LEVEL)\n \t\trte_hexdump(stdout, NULL, &pkt->pkt[pkt->offset], pkt->length);\n \n+\tm->data_len = (uint16_t)(pkt->length + m->data_len - m->pkt_len);\n \tm->pkt_len = pkt->length;\n-\tm->data_len = (uint16_t)pkt->length;\n \tm->data_off = (uint16_t)pkt->offset;\n \n \tp->stats.n_pkts++;\n@@ -264,6 +264,67 @@ writer_pkt_tx(void *port, struct rte_swx_pkt *pkt)\n \t\t__writer_flush(p);\n }\n \n+static void\n+writer_pkt_fast_clone_tx(void *port, struct rte_swx_pkt *pkt)\n+{\n+\tstruct writer *p = port;\n+\tstruct rte_mbuf *m = pkt->handle;\n+\n+\tTRACE(\"[Ring %s] Pkt %d (%u bytes at offset %u) (fast clone)\\n\",\n+\t p->params.name,\n+\t p->n_pkts - 1,\n+\t pkt->length,\n+\t pkt->offset);\n+\tif (TRACE_LEVEL)\n+\t\trte_hexdump(stdout, NULL, &pkt->pkt[pkt->offset], pkt->length);\n+\n+\tm->data_len = (uint16_t)(pkt->length + m->data_len - m->pkt_len);\n+\tm->pkt_len = pkt->length;\n+\tm->data_off = (uint16_t)pkt->offset;\n+\trte_pktmbuf_refcnt_update(m, 1);\n+\n+\tp->stats.n_pkts++;\n+\tp->stats.n_bytes += pkt->length;\n+\tp->stats.n_pkts_clone++;\n+\n+\tp->pkts[p->n_pkts++] = m;\n+\tif (p->n_pkts == (int)p->params.burst_size)\n+\t\t__writer_flush(p);\n+}\n+\n+static void\n+writer_pkt_clone_tx(void *port, struct rte_swx_pkt *pkt, uint32_t truncation_length)\n+{\n+\tstruct writer *p = port;\n+\tstruct rte_mbuf *m = pkt->handle, *m_clone;\n+\n+\tTRACE(\"[Ring %s] Pkt %d (%u bytes at offset %u) (clone)\\n\",\n+\t p->params.name,\n+\t p->n_pkts - 1,\n+\t pkt->length,\n+\t pkt->offset);\n+\tif (TRACE_LEVEL)\n+\t\trte_hexdump(stdout, NULL, &pkt->pkt[pkt->offset], pkt->length);\n+\n+\tm->data_len = (uint16_t)(pkt->length + m->data_len - m->pkt_len);\n+\tm->pkt_len = pkt->length;\n+\tm->data_off = (uint16_t)pkt->offset;\n+\n+\tm_clone = rte_pktmbuf_copy(m, m->pool, 0, truncation_length);\n+\tif (!m_clone) {\n+\t\tp->stats.n_pkts_clone_err++;\n+\t\treturn;\n+\t}\n+\n+\tp->stats.n_pkts++;\n+\tp->stats.n_bytes += pkt->length;\n+\tp->stats.n_pkts_clone++;\n+\n+\tp->pkts[p->n_pkts++] = m_clone;\n+\tif (p->n_pkts == (int)p->params.burst_size)\n+\t\t__writer_flush(p);\n+}\n+\n static void\n writer_flush(void *port)\n {\n@@ -312,6 +373,8 @@ struct rte_swx_port_out_ops rte_swx_port_ring_writer_ops = {\n \t.create = writer_create,\n \t.free = writer_free,\n \t.pkt_tx = writer_pkt_tx,\n+\t.pkt_fast_clone_tx = writer_pkt_fast_clone_tx,\n+\t.pkt_clone_tx = writer_pkt_clone_tx,\n \t.flush = writer_flush,\n \t.stats_read = writer_stats_read,\n };\ndiff --git a/lib/port/rte_swx_port_source_sink.c b/lib/port/rte_swx_port_source_sink.c\nindex 93c346cfb1..d3cf42c30b 100644\n--- a/lib/port/rte_swx_port_source_sink.c\n+++ b/lib/port/rte_swx_port_source_sink.c\n@@ -295,8 +295,8 @@ sink_pkt_tx(void *port, struct rte_swx_pkt *pkt)\n \tif (TRACE_LEVEL)\n \t\trte_hexdump(stdout, NULL, &pkt->pkt[pkt->offset], pkt->length);\n \n+\tm->data_len = (uint16_t)(pkt->length + m->data_len - m->pkt_len);\n \tm->pkt_len = pkt->length;\n-\tm->data_len = (uint16_t)pkt->length;\n \tm->data_off = (uint16_t)pkt->offset;\n \n \tp->stats.n_pkts++;\n@@ -319,6 +319,53 @@ sink_pkt_tx(void *port, struct rte_swx_pkt *pkt)\n \trte_pktmbuf_free(m);\n }\n \n+static void\n+__sink_pkt_clone_tx(void *port, struct rte_swx_pkt *pkt, uint32_t truncation_length __rte_unused)\n+{\n+\tstruct sink *p = port;\n+\tstruct rte_mbuf *m = pkt->handle;\n+\n+\tTRACE(\"[Sink port] Pkt TX (%u bytes at offset %u) (clone)\\n\",\n+\t pkt->length,\n+\t pkt->offset);\n+\tif (TRACE_LEVEL)\n+\t\trte_hexdump(stdout, NULL, &pkt->pkt[pkt->offset], pkt->length);\n+\n+\tm->data_len = (uint16_t)(pkt->length + m->data_len - m->pkt_len);\n+\tm->pkt_len = pkt->length;\n+\tm->data_off = (uint16_t)pkt->offset;\n+\n+\tp->stats.n_pkts++;\n+\tp->stats.n_bytes += pkt->length;\n+\tp->stats.n_pkts_clone++;\n+\n+#ifdef RTE_PORT_PCAP\n+\tif (p->f_dump) {\n+\t\tstruct pcap_pkthdr pcap_pkthdr;\n+\t\tuint8_t *m_data = rte_pktmbuf_mtod(m, uint8_t *);\n+\n+\t\tpcap_pkthdr.len = m->pkt_len;\n+\t\tpcap_pkthdr.caplen = RTE_MIN(m->data_len, truncation_length);\n+\t\tgettimeofday(&pcap_pkthdr.ts, NULL);\n+\n+\t\tpcap_dump((uint8_t *)p->f_dump, &pcap_pkthdr, m_data);\n+\t\tpcap_dump_flush(p->f_dump);\n+\t}\n+#endif\n+}\n+\n+static void\n+sink_pkt_fast_clone_tx(void *port, struct rte_swx_pkt *pkt)\n+{\n+\t__sink_pkt_clone_tx(port, pkt, UINT32_MAX);\n+}\n+\n+static void\n+sink_pkt_clone_tx(void *port, struct rte_swx_pkt *pkt, uint32_t truncation_length)\n+{\n+\t__sink_pkt_clone_tx(port, pkt, truncation_length);\n+}\n+\n static void\n sink_stats_read(void *port, struct rte_swx_port_out_stats *stats)\n {\n@@ -337,6 +384,8 @@ struct rte_swx_port_out_ops rte_swx_port_sink_ops = {\n \t.create = sink_create,\n \t.free = sink_free,\n \t.pkt_tx = sink_pkt_tx,\n+\t.pkt_fast_clone_tx = sink_pkt_fast_clone_tx,\n+\t.pkt_clone_tx = sink_pkt_clone_tx,\n \t.flush = NULL,\n \t.stats_read = sink_stats_read,\n };\n", "prefixes": [ "V2", "1/3" ] }