--- /dev/null
+/* SPDX-License-Identifier: BSD-3-Clause
+ * Copyright 2020 Mellanox Technologies, Ltd
+ *
+ * This file contain the application main file
+ * This application provides the user the ability to test the
+ * insertion rate for specific rte_flow rule under stress state ~4M rule/
+ *
+ * Then it will also provide packet per second measurement after installing
+ * all rules, the user may send traffic to test the PPS that match the rules
+ * after all rules are installed, to check performance or functionality after
+ * the stress.
+ *
+ * The flows insertion will go for all ports first, then it will print the
+ * results, after that the application will go into forwarding packets mode
+ * it will start receiving traffic if any and then forwarding it back and
+ * gives packet per second measurement.
+ */
+
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <stdint.h>
+#include <inttypes.h>
+#include <stdarg.h>
+#include <errno.h>
+#include <getopt.h>
+#include <stdbool.h>
+#include <sys/time.h>
+
+#include <rte_malloc.h>
+#include <rte_mempool.h>
+#include <rte_mbuf.h>
+#include <rte_ethdev.h>
+#include <rte_flow.h>
+
+#include "config.h"
+
+static struct rte_mempool *mbuf_mp;
+static uint32_t nb_lcores;
+
+static void
+usage(char *progname)
+{
+ printf("\nusage: %s\n", progname);
+}
+
+static void
+args_parse(int argc, char **argv)
+{
+ char **argvopt;
+ int opt;
+ int opt_idx;
+ static struct option lgopts[] = {
+ /* Control */
+ { "help", 0, 0, 0 },
+ };
+
+ argvopt = argv;
+
+ while ((opt = getopt_long(argc, argvopt, "",
+ lgopts, &opt_idx)) != EOF) {
+ switch (opt) {
+ case 0:
+ if (strcmp(lgopts[opt_idx].name, "help") == 0) {
+ usage(argv[0]);
+ rte_exit(EXIT_SUCCESS, "Displayed help\n");
+ }
+ break;
+ default:
+ fprintf(stderr, "Invalid option: %s\n", argv[optind]);
+ usage(argv[0]);
+ rte_exit(EXIT_SUCCESS, "Invalid option\n");
+ break;
+ }
+ }
+}
+
+static void
+init_port(void)
+{
+ int ret;
+ uint16_t std_queue;
+ uint16_t port_id;
+ uint16_t nr_ports;
+ struct rte_eth_conf port_conf = {
+ .rx_adv_conf = {
+ .rss_conf.rss_hf =
+ GET_RSS_HF(),
+ }
+ };
+ struct rte_eth_txconf txq_conf;
+ struct rte_eth_rxconf rxq_conf;
+ struct rte_eth_dev_info dev_info;
+
+ nr_ports = rte_eth_dev_count_avail();
+ if (nr_ports == 0)
+ rte_exit(EXIT_FAILURE, "Error: no port detected\n");
+
+ mbuf_mp = rte_pktmbuf_pool_create("mbuf_pool",
+ TOTAL_MBUF_NUM, MBUF_CACHE_SIZE,
+ 0, MBUF_SIZE,
+ rte_socket_id());
+ if (mbuf_mp == NULL)
+ rte_exit(EXIT_FAILURE, "Error: can't init mbuf pool\n");
+
+ for (port_id = 0; port_id < nr_ports; port_id++) {
+ ret = rte_eth_dev_info_get(port_id, &dev_info);
+ if (ret != 0)
+ rte_exit(EXIT_FAILURE,
+ "Error during getting device"
+ " (port %u) info: %s\n",
+ port_id, strerror(-ret));
+
+ port_conf.txmode.offloads &= dev_info.tx_offload_capa;
+ port_conf.rxmode.offloads &= dev_info.rx_offload_capa;
+
+ printf(":: initializing port: %d\n", port_id);
+
+ ret = rte_eth_dev_configure(port_id, RXQ_NUM,
+ TXQ_NUM, &port_conf);
+ if (ret < 0)
+ rte_exit(EXIT_FAILURE,
+ ":: cannot configure device: err=%d, port=%u\n",
+ ret, port_id);
+
+ rxq_conf = dev_info.default_rxconf;
+ for (std_queue = 0; std_queue < RXQ_NUM; std_queue++) {
+ ret = rte_eth_rx_queue_setup(port_id, std_queue, NR_RXD,
+ rte_eth_dev_socket_id(port_id),
+ &rxq_conf,
+ mbuf_mp);
+ if (ret < 0)
+ rte_exit(EXIT_FAILURE,
+ ":: Rx queue setup failed: err=%d, port=%u\n",
+ ret, port_id);
+ }
+
+ txq_conf = dev_info.default_txconf;
+ for (std_queue = 0; std_queue < TXQ_NUM; std_queue++) {
+ ret = rte_eth_tx_queue_setup(port_id, std_queue, NR_TXD,
+ rte_eth_dev_socket_id(port_id),
+ &txq_conf);
+ if (ret < 0)
+ rte_exit(EXIT_FAILURE,
+ ":: Tx queue setup failed: err=%d, port=%u\n",
+ ret, port_id);
+ }
+
+ /* Catch all packets from traffic generator. */
+ ret = rte_eth_promiscuous_enable(port_id);
+ if (ret != 0)
+ rte_exit(EXIT_FAILURE,
+ ":: promiscuous mode enable failed: err=%s, port=%u\n",
+ rte_strerror(-ret), port_id);
+
+ ret = rte_eth_dev_start(port_id);
+ if (ret < 0)
+ rte_exit(EXIT_FAILURE,
+ "rte_eth_dev_start:err=%d, port=%u\n",
+ ret, port_id);
+
+ printf(":: initializing port: %d done\n", port_id);
+ }
+}
+
+int
+main(int argc, char **argv)
+{
+ int ret;
+ uint16_t port;
+ struct rte_flow_error error;
+
+ ret = rte_eal_init(argc, argv);
+ if (ret < 0)
+ rte_exit(EXIT_FAILURE, "EAL init failed\n");
+
+ argc -= ret;
+ argv += ret;
+ if (argc > 1)
+ args_parse(argc, argv);
+
+ init_port();
+
+ nb_lcores = rte_lcore_count();
+ if (nb_lcores <= 1)
+ rte_exit(EXIT_FAILURE, "This app needs at least two cores\n");
+
+ RTE_ETH_FOREACH_DEV(port) {
+ rte_flow_flush(port, &error);
+ rte_eth_dev_stop(port);
+ rte_eth_dev_close(port);
+ }
+ return 0;
+}
--- /dev/null
+.. SPDX-License-Identifier: BSD-3-Clause
+ Copyright 2020 Mellanox Technologies, Ltd
+
+Flow Performance Tool
+=====================
+
+Application for rte_flow performance testing.
+
+
+Compiling the Application
+=========================
+
+The ``test-flow-perf`` application is compiled as part of the main compilation
+of the DPDK libraries and tools.
+
+Refer to the DPDK Getting Started Guides for details.
+
+
+Running the Application
+=======================
+
+EAL Command-line Options
+------------------------
+
+Please refer to :doc:`EAL parameters (Linux) <../linux_gsg/linux_eal_parameters>`
+or :doc:`EAL parameters (FreeBSD) <../freebsd_gsg/freebsd_eal_parameters>` for
+a list of available EAL command-line options.
+
+
+Flow Performance Options
+------------------------
+
+The following are the command-line options for the flow performance application.
+They must be separated from the EAL options, shown in the previous section,
+with a ``--`` separator:
+
+.. code-block:: console
+
+ sudo ./dpdk-test-flow-perf -n 4 -w 08:00.0 --
+
+The command line options are:
+
+* ``--help``
+ Display a help message and quit.
git.droids-corp.org / dpdk.git / commitdiff