From mboxrd@z Thu Jan 1 00:00:00 1970
Return-Path: <dev-bounces@dpdk.org>
Received: from mails.dpdk.org (mails.dpdk.org [217.70.189.124])
by inbox.dpdk.org (Postfix) with ESMTP id 4288646566;
Sat, 12 Apr 2025 01:50:53 +0200 (CEST)
Received: from mails.dpdk.org (localhost [127.0.0.1])
by mails.dpdk.org (Postfix) with ESMTP id 89BE640E3E;
Sat, 12 Apr 2025 01:49:55 +0200 (CEST)
Received: from mail-pj1-f45.google.com (mail-pj1-f45.google.com
[209.85.216.45]) by mails.dpdk.org (Postfix) with ESMTP id 3F21D40E19
for <dev@dpdk.org>; Sat, 12 Apr 2025 01:49:49 +0200 (CEST)
Received: by mail-pj1-f45.google.com with SMTP id
98e67ed59e1d1-306b602d2ffso2751448a91.0
for <dev@dpdk.org>; Fri, 11 Apr 2025 16:49:49 -0700 (PDT)
DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed;
d=networkplumber-org.20230601.gappssmtp.com; s=20230601; t=1744415388;
x=1745020188; darn=dpdk.org;
h=content-transfer-encoding:mime-version:references:in-reply-to
:message-id:date:subject:cc:to:from:from:to:cc:subject:date
:message-id:reply-to;
bh=MR4V0n2VwSX53dtLlCJVdM7SsoSQDIE4/l6kpHXuixQ=;
b=gJY14HqBYU96wniI9j3V6lgdp3X9s7mnmOvblspBnixcFlXb2AlXlv+iwxIYKevN49
41lFWbJ3VXqlh56C/KVOaV5dDjysKGDPpcrrx1pm2tBYgeD4GRdewL48bR1Qrf42nly/
m+Byb/H1hk/gRldg3vQ+OGeDDW2rSd7QlnNKrXn94WlJ3NjLCc6JJb6EZBRCviRpSOBi
t8cAFmLT+cYK2qtApz3/79bSaEowsmcLcEPnMnWSzyn1eyntlKU2tmKkN4j5leaMtMhI
XtCi22yTUgLjJWahPOXdVNsyl9yKZQ8Ruha2KZ/1mWi70+1yIT9d8N+yoPiUOdVvKeww
01VQ==
X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed;
d=1e100.net; s=20230601; t=1744415388; x=1745020188;
h=content-transfer-encoding:mime-version:references:in-reply-to
:message-id:date:subject:cc:to:from:x-gm-message-state:from:to:cc
:subject:date:message-id:reply-to;
bh=MR4V0n2VwSX53dtLlCJVdM7SsoSQDIE4/l6kpHXuixQ=;
b=Mb6Adb2NykthwHqCTWd3OZkH0t7txrm7qgrmJWZYRbVQCoN63INU/ntAuUeh2p9QtL
0jHWzOjZxOJXo12A6810sgzXVMTOIaW8TGi890gjZjVqnKm4mwzOBf/PegjVx6etFvoG
VATNorGpd2U0tOgIZnYDqLzYu3M1oX+gDrT209i1PsDapqjwFs0HmcM+O2ZcpTJlYUnv
nScsDcaZLlS7VrYPund6p9FqnyPzeVu28WlKis/uKIHtph06mjQ8g6qo0BV94TxKbLET
B1tYNbug+lNPyINIoWPDdaEC2qw7KAVdly6xhFko1lIHlhtEKl+qVE4emFzrBYLZP/QT
KoZg==
X-Gm-Message-State: AOJu0YzMNeJpMFSnK3zLL0i2WRRoS7Rkab1+Ib+hJH2vtLAuwCOb8iyb
xiylN5GVW7RUu9+DES4F4GfWulJvkLGZ/0bA/pre+X/RhyrydEs9JKPE62x0BODylroKb1R2fRN
f
X-Gm-Gg: ASbGncuqkpR+8JnPXcXWePUwE5OHwB0j1GODkE6Jrf0xdRA2+Jsw+xZOYOIcbM1Gl6D
gpT3Y2oUz2vXY5Go5qL+ozFux2vgGGimuImvAGzyRR6lkPUo49uSARWHkl5pwFQYtfu1i91WL3C
lYRbKGvOpnOmtncySv6YnS+P82apyLcOMKZm3HWRYMeJ4ycVhNhSU1d+QxO3r1tS6ckcjyVAdfJ
TNfzOoBNcEl8rX5CsSLRpKC2IeRLP22hwrvt6Y6C6adswpJvfzNg0FYqbA5/HcqRArV9doFxsMt
ufRFkD+JQiMDWuJD4btgIaOby3hQxiIpjIT9cTOc8e7UBBcQM391Q1+MdDhykm4X3VHDkZD7qW8
+hxkJBh8pRWgXhA20
X-Google-Smtp-Source: AGHT+IGfrwEfgcEsRCFQ0NYQY1Mj2cIxzYvoVhdGhlM3q8HpK/dWCC/ZPYd6VbHH0rA8/KseHQMv1A==
X-Received: by 2002:a17:90b:4c02:b0:2fe:8c22:48b0 with SMTP id
98e67ed59e1d1-30823642c66mr7086502a91.15.1744415388433;
Fri, 11 Apr 2025 16:49:48 -0700 (PDT)
Received: from hermes.local (204-195-96-226.wavecable.com. [204.195.96.226])
by smtp.gmail.com with ESMTPSA id
98e67ed59e1d1-306dd11e643sm6538661a91.12.2025.04.11.16.49.47
(version=TLS1_3 cipher=TLS_AES_256_GCM_SHA384 bits=256/256);
Fri, 11 Apr 2025 16:49:48 -0700 (PDT)
From: Stephen Hemminger <stephen@networkplumber.org>
To: dev@dpdk.org
Cc: Stephen Hemminger <stephen@networkplumber.org>,
Thomas Monjalon <thomas@monjalon.net>, Ferruh Yigit <ferruh.yigit@amd.com>,
Andrew Rybchenko <andrew.rybchenko@oktetlabs.ru>
Subject: [RFC 11/13] test: add tests for ethdev mirror
Date: Fri, 11 Apr 2025 16:44:48 -0700
Message-ID: <20250411234927.114568-12-stephen@networkplumber.org>
X-Mailer: git-send-email 2.47.2
In-Reply-To: <20250411234927.114568-1-stephen@networkplumber.org>
References: <20250411234927.114568-1-stephen@networkplumber.org>
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>,
<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>,
<mailto:dev-request@dpdk.org?subject=subscribe>
Errors-To: dev-bounces@dpdk.org
Simple API and packet mirroring standalone tests.
Signed-off-by: Stephen Hemminger <stephen@networkplumber.org>
---
app/test/meson.build | 1 +
app/test/test_ethdev_mirror.c | 286 ++++++++++++++++++++++++++++++++++
2 files changed, 287 insertions(+)
create mode 100644 app/test/test_ethdev_mirror.c
diff --git a/app/test/meson.build b/app/test/meson.build
index b6285a6b45..ee90ca6648 100644
--- a/app/test/meson.build
+++ b/app/test/meson.build
@@ -73,6 +73,7 @@ source_file_deps = {
'test_errno.c': [],
'test_ethdev_api.c': ['ethdev'],
'test_ethdev_link.c': ['ethdev'],
+ 'test_ethdev_mirror.c': ['net_ring', 'ethdev', 'bus_vdev'],
'test_event_crypto_adapter.c': ['cryptodev', 'eventdev', 'bus_vdev'],
'test_event_dma_adapter.c': ['dmadev', 'eventdev', 'bus_vdev'],
'test_event_eth_rx_adapter.c': ['ethdev', 'eventdev', 'bus_vdev'],
diff --git a/app/test/test_ethdev_mirror.c b/app/test/test_ethdev_mirror.c
new file mode 100644
index 0000000000..924b8d0617
--- /dev/null
+++ b/app/test/test_ethdev_mirror.c
@@ -0,0 +1,286 @@
+/* SPDX-License-Identifier: BSD-3-Clause
+ * Copyright(c) 2025 Stephen Hemminger <stephen@networkplumber.org>
+ */
+#include "test.h"
+
+#include <stdio.h>
+
+#include <rte_eth_ring.h>
+#include <rte_ethdev.h>
+#include <rte_bus_vdev.h>
+
+#define SOCKET0 0
+#define RING_SIZE 256
+#define MIRROR_BURST 64
+#define NB_MBUF 512
+
+static struct rte_mempool *mirror_pool;
+static const uint32_t pkt_len = 200;
+
+static struct rte_ring *rxtx_ring;
+static const char ring_dev[] = "net_ring0";
+static uint16_t ring_port;
+static const char null_dev[] = "net_null0";
+static uint16_t null_port;
+
+static int
+configure_port(uint16_t port, const char *name)
+{
+ struct rte_eth_conf eth_conf = { 0 };
+
+ if (rte_eth_dev_configure(port, 1, 1, ð_conf) < 0) {
+ fprintf(stderr, "Configure failed for port %u: %s\n", port, name);
+ return -1;
+ }
+
+ /* only single queue */
+ if (rte_eth_tx_queue_setup(port, 0, RING_SIZE, SOCKET0, NULL) < 0) {
+ fprintf(stderr, "TX queue setup failed port %u: %s\n", port, name);
+ return -1;
+ }
+
+ if (rte_eth_rx_queue_setup(port, 0, RING_SIZE, SOCKET0, NULL, mirror_pool) < 0) {
+ fprintf(stderr, "RX queue setup failed port %u: %s\n", port, name);
+ return -1;
+ }
+
+ if (rte_eth_dev_start(port) < 0) {
+ fprintf(stderr, "Error starting port %u:%s\n", port, name);
+ return -1;
+ }
+
+ return 0;
+}
+
+static void
+test_cleanup(void)
+{
+ rte_ring_free(rxtx_ring);
+
+ rte_vdev_uninit("net_ring");
+ rte_vdev_uninit("net_null");
+
+ rte_mempool_free(mirror_pool);
+}
+
+/* Make two virtual devices ring and null */
+static int
+test_setup(void)
+{
+ char null_name[] = "net_null0";
+ int ret;
+
+ /* ring must support multiple enqueue for mirror to work */
+ rxtx_ring = rte_ring_create("R0", RING_SIZE, SOCKET0, RING_F_MP_RTS_ENQ | RING_F_SC_DEQ);
+ if (rxtx_ring == NULL) {
+ fprintf(stderr, "rte_ring_create R0 failed\n");
+ goto fail;
+ }
+ ret = rte_eth_from_rings(ring_dev, &rxtx_ring, 1, &rxtx_ring, 1, SOCKET0);
+ if (ret < 0) {
+ fprintf(stderr, "rte_eth_from_rings failed\n");
+ goto fail;
+ }
+ ring_port = ret;
+
+ /* Make a dummy null device to snoop on */
+ if (rte_vdev_init(null_dev, NULL) != 0) {
+ fprintf(stderr, "Failed to create vdev '%s'\n", null_dev);
+ goto fail;
+ }
+ if (rte_eth_dev_get_port_by_name(null_dev, &null_port) != 0) {
+ fprintf(stderr, "cannot find added vdev %s\n", null_name);
+ goto fail;
+ }
+
+ mirror_pool = rte_pktmbuf_pool_create("mirror_pool", NB_MBUF, 32,
+ 0, RTE_MBUF_DEFAULT_BUF_SIZE, rte_socket_id());
+ if (mirror_pool == NULL) {
+ fprintf(stderr, "rte_pktmbuf_pool_create failed\n");
+ goto fail;
+ }
+
+ ret = configure_port(ring_port, ring_dev);
+ if (ret < 0)
+ goto fail;
+
+ ret = configure_port(null_port, null_dev);
+ if (ret < 0)
+ goto fail;
+
+ return 0;
+fail:
+ test_cleanup();
+ return -1;
+}
+
+/* Make sure mirror API checks args */
+static int32_t
+ethdev_mirror_api(void)
+{
+ struct rte_eth_mirror_conf conf = {
+ .mp = mirror_pool,
+ .snaplen = UINT32_MAX,
+ .direction = RTE_MIRROR_DIRECTION_EGRESS,
+ };
+ uint16_t invalid_port = RTE_MAX_ETHPORTS;
+ int ret;
+
+ ret = rte_eth_add_mirror(invalid_port, null_port, &conf);
+ TEST_ASSERT(ret != 0, "Created mirror from invalid port");
+
+ ret = rte_eth_add_mirror(null_port, invalid_port, &conf);
+ TEST_ASSERT(ret != 0, "Created mirror to invalid port");
+
+ conf.snaplen = 1;
+ ret = rte_eth_add_mirror(null_port, ring_port, &conf);
+ TEST_ASSERT(ret != 0, "Created mirror with invalid snap len");
+
+ conf.snaplen = UINT16_MAX;
+ conf.direction = 0;
+ ret = rte_eth_add_mirror(null_port, ring_port, &conf);
+ TEST_ASSERT(ret != 0, "Created mirror with invalid direction");
+
+ conf.direction = RTE_MIRROR_DIRECTION_INGRESS;
+ ret = rte_eth_add_mirror(ring_port, ring_port, &conf);
+ TEST_ASSERT(ret != 0, "Created mirror to self");
+
+ ret = rte_eth_add_mirror(ring_port, null_port, &conf);
+ TEST_ASSERT(ret == 0, "Could not create mirror from ring to null");
+
+ ret = rte_eth_add_mirror(ring_port, null_port, &conf);
+ TEST_ASSERT(ret != 0, "Able to create duplicate mirror");
+
+ ret = rte_eth_remove_mirror(ring_port);
+ TEST_ASSERT(ret == 0, "Unable to delete mirror");
+
+ ret = rte_eth_remove_mirror(ring_port);
+ TEST_ASSERT(ret != 0, "Able to delete port without mirror");
+
+ return 0;
+}
+
+static int
+init_mbuf(struct rte_mbuf *m, uint16_t id)
+{
+ struct {
+ struct rte_ether_hdr eth;
+ struct rte_ipv4_hdr ip;
+ struct rte_udp_hdr udp;
+ } hdrs = {
+ .eth = {
+ .dst_addr.addr_bytes = { 0xff, 0xff, 0xff, 0xff, 0xff, 0xff },
+ .ether_type = rte_cpu_to_be_16(RTE_ETHER_TYPE_IPV4),
+ },
+ .ip = {
+ .version_ihl = RTE_IPV4_VHL_DEF,
+ .time_to_live = 1,
+ .next_proto_id = IPPROTO_UDP,
+ .src_addr = rte_cpu_to_be_32(RTE_IPV4_LOOPBACK),
+ .dst_addr = rte_cpu_to_be_32(RTE_IPV4_BROADCAST),
+ },
+ .udp = {
+ .dst_port = rte_cpu_to_be_16(9), /* Discard port */
+ },
+ };
+
+ rte_eth_random_addr(hdrs.eth.src_addr.addr_bytes);
+ uint16_t plen = pkt_len - sizeof(struct rte_ether_hdr);
+
+ hdrs.ip.packet_id = rte_cpu_to_be_16(id);
+ hdrs.ip.total_length = rte_cpu_to_be_16(plen);
+ hdrs.ip.hdr_checksum = rte_ipv4_cksum(&hdrs.ip);
+
+ plen -= sizeof(struct rte_ipv4_hdr);
+ hdrs.udp.src_port = rte_rand();
+ hdrs.udp.dgram_len = rte_cpu_to_be_16(plen);
+
+ void *data = rte_pktmbuf_append(m, pkt_len);
+ TEST_ASSERT(data != NULL, "could not add header");
+
+ memcpy(data, &hdrs, sizeof(hdrs));
+ return 0;
+}
+
+static int
+init_burst(struct rte_mbuf *pkts[], unsigned int n)
+{
+ for (unsigned int i = 0; i < n; i++) {
+ if (init_mbuf(pkts[i], i) < 0)
+ return -1;
+ }
+ return 0;
+}
+
+static int
+validate_burst(struct rte_mbuf *pkts[], unsigned int n)
+{
+ for (unsigned int i = 0; i < n; i++) {
+ struct rte_mbuf *m = pkts[i];
+
+ rte_mbuf_sanity_check(m, 1);
+ TEST_ASSERT(m->pkt_len != pkt_len,
+ "mirror packet not right len");
+
+ const struct rte_ether_hdr *eh
+ = rte_pktmbuf_mtod(m, struct rte_ether_hdr *);
+ TEST_ASSERT(rte_is_broadcast_ether_addr(&eh->dst_addr),
+ "mirrored packet is not broadcast");
+
+ }
+ return 0;
+}
+
+static int32_t
+ethdev_mirror_packets(void)
+{
+ struct rte_eth_mirror_conf conf = {
+ .mp = mirror_pool,
+ .snaplen = UINT32_MAX,
+ .direction = RTE_MIRROR_DIRECTION_EGRESS,
+ };
+ struct rte_mbuf *tx_pkts[MIRROR_BURST], *rx_pkts[MIRROR_BURST];
+ uint16_t nb_tx, nb_rx;
+ int ret;
+
+ ret = rte_pktmbuf_alloc_bulk(mirror_pool, tx_pkts, MIRROR_BURST);
+ TEST_ASSERT(ret == 0, "Could not allocate mbufs");
+
+ ret = init_burst(tx_pkts, MIRROR_BURST);
+ TEST_ASSERT(ret == 0, "Init mbufs failed");
+
+ ret = rte_eth_add_mirror(null_port, ring_port, &conf);
+ TEST_ASSERT(ret == 0, "Could not create mirror from ring to null");
+
+ nb_tx = rte_eth_tx_burst(null_port, 0, tx_pkts, MIRROR_BURST);
+ TEST_ASSERT(nb_tx == MIRROR_BURST, "Only sent %u burst to null (vs %u)",
+ nb_tx, MIRROR_BURST);
+
+ nb_rx = rte_eth_rx_burst(ring_port, 0, rx_pkts, MIRROR_BURST);
+ TEST_ASSERT(nb_rx == MIRROR_BURST, "Only received %u of %u packets",
+ nb_rx, MIRROR_BURST);
+
+ validate_burst(rx_pkts, nb_rx);
+ rte_pktmbuf_free_bulk(rx_pkts, nb_rx);
+
+ return 0;
+}
+
+static struct unit_test_suite ethdev_mirror_suite = {
+ .suite_name = "port mirroring",
+ .setup = test_setup,
+ .teardown = test_cleanup,
+ .unit_test_cases = {
+ TEST_CASE(ethdev_mirror_api),
+ TEST_CASE(ethdev_mirror_packets),
+ TEST_CASES_END()
+ }
+};
+
+static int
+test_ethdev_mirror(void)
+{
+ return unit_test_suite_runner(ðdev_mirror_suite);
+}
+
+REGISTER_FAST_TEST(ethdev_mirror, true, true, test_ethdev_mirror);
--
2.47.2