d/numam-dpdk
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

app/test: fix ring unit test

Browse Source 
If eth_ring vdevs are created from the command line with the --vdev option,
they create their own rings which are not shared by other vdevs.
Some of tests in this suite require that the vdevs share rings, so some
of the tests fail.

For vdevs to share rings they must be created in the test code with the
rte_eth_from_rings() function using rings created with the rte_ring_create()
function.

Use the command line option --vdev=eth_ring0 to create port 0.
This option is not mandatory for the tests to pass. It allows some additional
functional tests on cmd-line created rings to be executed.

Create two rings and five ethdevs in test_pmd_ring.c for ports 1 to 5,
and then use these to run the unit tests on the pmd ring functionality.

Improve test output by adding the port number to printf statements,
and adding a printf describing each test.

Fixes: 572eb3cd83 ("ring: simplify unit tests")

Signed-off-by: Bernard Iremonger <bernard.iremonger@intel.com>
Acked-by: Bruce Richardson <bruce.richardson@intel.com>
This commit is contained in:
Bernard Iremonger 2015-11-28 11:01:53 +00:00 committed by Thomas Monjalon
parent 962973095c
commit 4ea3801b32
1 changed files with 224 additions and 146 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

370
app/test/test_pmd_ring.c
View File

@ -1,7 +1,7 @@
/*-
* BSD LICENSE
*
* Copyright(c) 2010-2014 Intel Corporation. All rights reserved.
* Copyright(c) 2010-2015 Intel Corporation. All rights reserved.
* All rights reserved.
*
* Redistribution and use in source and binary forms, with or without
@ -38,85 +38,50 @@
#include <rte_ethdev.h>
static struct rte_mempool *mp;
static int tx_porta, rx_portb, rxtx_portc, rxtx_portd, rxtx_porte;
#define TX_PORT 0
#define RX_PORT 1
#define RXTX_PORT 2
#define RXTX_PORT2 3
#define RXTX_PORT3 4
#define SOCKET0 0
#define RING_SIZE 256
#define NUM_RINGS 2
#define NB_MBUF 512
#define NB_MBUF 512
static int
test_ethdev_configure(void)
test_ethdev_configure_port(int port)
{
struct rte_eth_conf null_conf;
struct rte_eth_link link;
memset(&null_conf, 0, sizeof(struct rte_eth_conf));
if ((TX_PORT >= RTE_MAX_ETHPORTS) || (RX_PORT >= RTE_MAX_ETHPORTS)\
|| (RXTX_PORT >= RTE_MAX_ETHPORTS)) {
printf(" TX/RX port exceed max eth ports\n");
return -1;
}
if (rte_eth_dev_configure(TX_PORT, 1, 2, &null_conf) < 0) {
printf("Configure failed for TX port\n");
if (rte_eth_dev_configure(port, 1, 2, &null_conf) < 0) {
printf("Configure failed for port %d\n", port);
return -1;
}
/* Test queue release */
if (rte_eth_dev_configure(TX_PORT, 1, 1, &null_conf) < 0) {
printf("Configure failed for TX port\n");
return -1;
}
if (rte_eth_dev_configure(RX_PORT, 1, 1, &null_conf) < 0) {
printf("Configure failed for RX port\n");
return -1;
}
if (rte_eth_dev_configure(RXTX_PORT, 1, 1, &null_conf) < 0) {
printf("Configure failed for RXTX port\n");
if (rte_eth_dev_configure(port, 1, 1, &null_conf) < 0) {
printf("Configure failed for port %d\n", port);
return -1;
}
if (rte_eth_tx_queue_setup(TX_PORT, 0, RING_SIZE, SOCKET0, NULL) < 0) {
printf("TX queue setup failed\n");
if (rte_eth_tx_queue_setup(port, 0, RING_SIZE, SOCKET0, NULL) < 0) {
printf("TX queue setup failed port %d\n", port);
return -1;
}
if (rte_eth_rx_queue_setup(RX_PORT, 0, RING_SIZE, SOCKET0,
if (rte_eth_rx_queue_setup(port, 0, RING_SIZE, SOCKET0,
NULL, mp) < 0) {
printf("RX queue setup failed\n");
return -1;
}
if (rte_eth_tx_queue_setup(RXTX_PORT, 0, RING_SIZE, SOCKET0, NULL) < 0) {
printf("TX queue setup failed\n");
return -1;
}
if (rte_eth_rx_queue_setup(RXTX_PORT, 0, RING_SIZE, SOCKET0,
NULL, mp) < 0) {
printf("RX queue setup failed\n");
printf("RX queue setup failed port %d\n", port);
return -1;
}
if (rte_eth_dev_start(TX_PORT) < 0) {
printf("Error starting TX port\n");
return -1;
}
if (rte_eth_dev_start(RX_PORT) < 0) {
printf("Error starting RX port\n");
return -1;
}
if (rte_eth_dev_start(RXTX_PORT) < 0) {
printf("Error starting RX port\n");
if (rte_eth_dev_start(port) < 0) {
printf("Error starting port %d\n", port);
return -1;
}
rte_eth_link_get(TX_PORT, &link);
rte_eth_link_get(RX_PORT, &link);
rte_eth_link_get(RXTX_PORT, &link);
rte_eth_link_get(port, &link);
return 0;
}
@ -128,18 +93,18 @@ test_send_basic_packets(void)
struct rte_mbuf *pbufs[RING_SIZE];
int i;
printf("Testing ring pmd RX/TX\n");
printf("Testing send and receive RING_SIZE/2 packets (tx_porta -> rx_portb)\n");
for (i = 0; i < RING_SIZE/2; i++)
pbufs[i] = &bufs[i];
if (rte_eth_tx_burst(TX_PORT, 0, pbufs, RING_SIZE/2) < RING_SIZE/2) {
printf("Failed to transmit packet burst\n");
if (rte_eth_tx_burst(tx_porta, 0, pbufs, RING_SIZE/2) < RING_SIZE/2) {
printf("Failed to transmit packet burst port %d\n", tx_porta);
return -1;
}
if (rte_eth_rx_burst(RX_PORT, 0, pbufs, RING_SIZE) != RING_SIZE/2) {
printf("Failed to receive packet burst\n");
if (rte_eth_rx_burst(rx_portb, 0, pbufs, RING_SIZE) != RING_SIZE/2) {
printf("Failed to receive packet burst on port %d\n", rx_portb);
return -1;
}
@ -153,88 +118,122 @@ test_send_basic_packets(void)
}
static int
test_get_stats(void)
test_send_basic_packets_port(int port)
{
struct rte_mbuf bufs[RING_SIZE];
struct rte_mbuf *pbufs[RING_SIZE];
int i;
printf("Testing send and receive RING_SIZE/2 packets (cmdl_port0 -> cmdl_port0)\n");
for (i = 0; i < RING_SIZE/2; i++)
pbufs[i] = &bufs[i];
if (rte_eth_tx_burst(port, 0, pbufs, RING_SIZE/2) < RING_SIZE/2) {
printf("Failed to transmit packet burst port %d\n", port);
return -1;
}
if (rte_eth_rx_burst(port, 0, pbufs, RING_SIZE) != RING_SIZE/2) {
printf("Failed to receive packet burst on port %d\n", port);
return -1;
}
for (i = 0; i < RING_SIZE/2; i++)
if (pbufs[i] != &bufs[i]) {
printf("Error: received data does not match that transmitted\n");
return -1;
}
return 0;
}
static int
test_get_stats(int port)
{
struct rte_eth_stats stats;
struct rte_mbuf buf, *pbuf = &buf;
printf("Testing ring PMD stats\n");
printf("Testing ring PMD stats_get port %d\n", port);
/* check stats of RXTX port, should all be zero */
rte_eth_stats_get(RXTX_PORT, &stats);
rte_eth_stats_get(port, &stats);
if (stats.ipackets != 0 || stats.opackets != 0 ||
stats.ibytes != 0 || stats.obytes != 0 ||
stats.ierrors != 0 || stats.oerrors != 0) {
printf("Error: RXTX port stats are not zero\n");
printf("Error: port %d stats are not zero\n", port);
return -1;
}
/* send and receive 1 packet and check for stats update */
if (rte_eth_tx_burst(RXTX_PORT, 0, &pbuf, 1) != 1) {
printf("Error sending packet to RXTX port\n");
return -1;
}
if (rte_eth_rx_burst(RXTX_PORT, 0, &pbuf, 1) != 1) {
printf("Error receiving packet from RXTX port\n");
if (rte_eth_tx_burst(port, 0, &pbuf, 1) != 1) {
printf("Error sending packet to port %d\n", port);
return -1;
}
rte_eth_stats_get(RXTX_PORT, &stats);
if (rte_eth_rx_burst(port, 0, &pbuf, 1) != 1) {
printf("Error receiving packet from port %d\n", port);
return -1;
}
rte_eth_stats_get(port, &stats);
if (stats.ipackets != 1 || stats.opackets != 1 ||
stats.ibytes != 0 || stats.obytes != 0 ||
stats.ierrors != 0 || stats.oerrors != 0) {
printf("Error: RXTX port stats are not as expected\n");
printf("Error: port %d stats are not as expected\n", port);
return -1;
}
return 0;
}
static int
test_stats_reset(void)
test_stats_reset(int port)
{
struct rte_eth_stats stats;
struct rte_mbuf buf, *pbuf = &buf;
printf("Testing ring PMD stats reset\n");
printf("Testing ring PMD stats_reset port %d\n", port);
rte_eth_stats_reset(RXTX_PORT);
rte_eth_stats_reset(port);
/* check stats of RXTX port, should all be zero */
rte_eth_stats_get(RXTX_PORT, &stats);
rte_eth_stats_get(port, &stats);
if (stats.ipackets != 0 || stats.opackets != 0 ||
stats.ibytes != 0 || stats.obytes != 0 ||
stats.ierrors != 0 || stats.oerrors != 0) {
printf("Error: RXTX port stats are not zero\n");
printf("Error: port %d stats are not zero\n", port);
return -1;
}
/* send and receive 1 packet and check for stats update */
if (rte_eth_tx_burst(RXTX_PORT, 0, &pbuf, 1) != 1) {
printf("Error sending packet to RXTX port\n");
if (rte_eth_tx_burst(port, 0, &pbuf, 1) != 1) {
printf("Error sending packet to port %d\n", port);
return -1;
}
if (rte_eth_rx_burst(RXTX_PORT, 0, &pbuf, 1) != 1) {
printf("Error receiving packet from RXTX port\n");
if (rte_eth_rx_burst(port, 0, &pbuf, 1) != 1) {
printf("Error receiving packet from port %d\n", port);
return -1;
}
rte_eth_stats_get(RXTX_PORT, &stats);
rte_eth_stats_get(port, &stats);
if (stats.ipackets != 1 || stats.opackets != 1 ||
stats.ibytes != 0 || stats.obytes != 0 ||
stats.ierrors != 0 || stats.oerrors != 0) {
printf("Error: RXTX port stats are not as expected\n");
printf("Error: port %d stats are not as expected\n", port);
return -1;
}
rte_eth_stats_reset(RXTX_PORT);
rte_eth_stats_reset(port);
/* check stats of RXTX port, should all be zero */
rte_eth_stats_get(RXTX_PORT, &stats);
rte_eth_stats_get(port, &stats);
if (stats.ipackets != 0 || stats.opackets != 0 ||
stats.ibytes != 0 || stats.obytes != 0 ||
stats.ierrors != 0 || stats.oerrors != 0) {
printf("Error: RXTX port stats are not zero\n");
printf("Error: port %d stats are not zero\n", port);
return -1;
}
@ -242,162 +241,182 @@ test_stats_reset(void)
}
static int
test_pmd_ring_pair_create_attach(void)
test_pmd_ring_pair_create_attach(int portd, int porte)
{
struct rte_eth_stats stats, stats2;
struct rte_mbuf buf, *pbuf = &buf;
struct rte_eth_conf null_conf;
if ((RXTX_PORT2 >= RTE_MAX_ETHPORTS) || (RXTX_PORT3 >= RTE_MAX_ETHPORTS)) {
printf(" TX/RX port exceed max eth ports\n");
return -1;
}
if ((rte_eth_dev_configure(RXTX_PORT2, 1, 1, &null_conf) < 0)
|| (rte_eth_dev_configure(RXTX_PORT3, 1, 1, &null_conf) < 0)) {
printf("Configure failed for RXTX port\n");
if ((rte_eth_dev_configure(portd, 1, 1, &null_conf) < 0)
|| (rte_eth_dev_configure(porte, 1, 1, &null_conf) < 0)) {
printf("Configure failed for port\n");
return -1;
}
if ((rte_eth_tx_queue_setup(RXTX_PORT2, 0, RING_SIZE, SOCKET0, NULL) < 0)
|| (rte_eth_tx_queue_setup(RXTX_PORT3, 0, RING_SIZE, SOCKET0, NULL) < 0)) {
if ((rte_eth_tx_queue_setup(portd, 0, RING_SIZE, SOCKET0, NULL) < 0)
|| (rte_eth_tx_queue_setup(porte, 0, RING_SIZE, SOCKET0, NULL) < 0)) {
printf("TX queue setup failed\n");
return -1;
}
if ((rte_eth_rx_queue_setup(RXTX_PORT2, 0, RING_SIZE, SOCKET0, NULL, mp) < 0)
|| (rte_eth_rx_queue_setup(RXTX_PORT3, 0, RING_SIZE, SOCKET0, NULL, mp) < 0)) {
if ((rte_eth_rx_queue_setup(portd, 0, RING_SIZE, SOCKET0, NULL, mp) < 0)
|| (rte_eth_rx_queue_setup(porte, 0, RING_SIZE, SOCKET0, NULL, mp) < 0)) {
printf("RX queue setup failed\n");
return -1;
}
if ((rte_eth_dev_start(RXTX_PORT2) < 0)
|| (rte_eth_dev_start(RXTX_PORT3) < 0)) {
printf("Error starting RXTX port\n");
if ((rte_eth_dev_start(portd) < 0)
|| (rte_eth_dev_start(porte) < 0)) {
printf("Error starting port\n");
return -1;
}
rte_eth_stats_reset(portd);
/* check stats of port, should all be zero */
rte_eth_stats_get(portd, &stats);
if (stats.ipackets != 0 || stats.opackets != 0 ||
stats.ibytes != 0 || stats.obytes != 0 ||
stats.ierrors != 0 || stats.oerrors != 0) {
printf("Error: port %d stats are not zero\n", portd);
return -1;
}
rte_eth_stats_reset(porte);
/* check stats of port, should all be zero */
rte_eth_stats_get(porte, &stats2);
if (stats2.ipackets != 0 || stats2.opackets != 0 ||
stats2.ibytes != 0 || stats2.obytes != 0 ||
stats2.ierrors != 0 || stats2.oerrors != 0) {
printf("Error: port %d stats are not zero\n", porte);
return -1;
}
/*
* send and receive 1 packet (RXTX_PORT2 -> RXTX_PORT3)
* send and receive 1 packet (portd -> porte)
* and check for stats update
*/
if (rte_eth_tx_burst(RXTX_PORT2, 0, &pbuf, 1) != 1) {
printf("Error sending packet to RXTX port\n");
printf("Testing send and receive 1 packet (portd -> porte)\n");
if (rte_eth_tx_burst(portd, 0, &pbuf, 1) != 1) {
printf("Error sending packet to port %d\n", portd);
return -1;
}
if (rte_eth_rx_burst(RXTX_PORT3, 0, &pbuf, 1) != 1) {
printf("Error receiving packet from RXTX port\n");
if (rte_eth_rx_burst(porte, 0, &pbuf, 1) != 1) {
printf("Error receiving packet from port %d\n", porte);
return -1;
}
rte_eth_stats_get(RXTX_PORT2, &stats);
rte_eth_stats_get(RXTX_PORT3, &stats2);
rte_eth_stats_get(portd, &stats);
rte_eth_stats_get(porte, &stats2);
if (stats.ipackets != 0 || stats.opackets != 1 ||
stats.ibytes != 0 || stats.obytes != 0 ||
stats.ierrors != 0 || stats.oerrors != 0) {
printf("Error: RXTX port stats are not as expected\n");
printf("Error: port %d stats are not as expected\n", portd);
return -1;
}
if (stats2.ipackets != 1 || stats2.opackets != 0 ||
stats2.ibytes != 0 || stats2.obytes != 0 ||
stats2.ierrors != 0 || stats2.oerrors != 0) {
printf("Error: RXTX port stats are not as expected\n");
printf("Error: port %d stats are not as expected\n", porte);
return -1;
}
/*
* send and receive 1 packet (RXTX_PORT3 -> RXTX_PORT2)
* send and receive 1 packet (porte -> portd)
* and check for stats update
*/
if (rte_eth_tx_burst(RXTX_PORT3, 0, &pbuf, 1) != 1) {
printf("Error sending packet to RXTX port\n");
printf("Testing send and receive 1 packet (porte -> portd)\n");
if (rte_eth_tx_burst(porte, 0, &pbuf, 1) != 1) {
printf("Error sending packet to port %d\n", porte);
return -1;
}
if (rte_eth_rx_burst(RXTX_PORT2, 0, &pbuf, 1) != 1) {
printf("Error receiving packet from RXTX port\n");
if (rte_eth_rx_burst(portd, 0, &pbuf, 1) != 1) {
printf("Error receiving packet from port %d\n", portd);
return -1;
}
rte_eth_stats_get(RXTX_PORT2, &stats);
rte_eth_stats_get(RXTX_PORT3, &stats2);
rte_eth_stats_get(portd, &stats);
rte_eth_stats_get(porte, &stats2);
if (stats.ipackets != 1 || stats.opackets != 1 ||
stats.ibytes != 0 || stats.obytes != 0 ||
stats.ierrors != 0 || stats.oerrors != 0) {
printf("Error: RXTX port stats are not as expected\n");
printf("Error: port %d stats are not as expected\n", portd);
return -1;
}
if (stats2.ipackets != 1 || stats2.opackets != 1 ||
stats2.ibytes != 0 || stats2.obytes != 0 ||
stats2.ierrors != 0 || stats2.oerrors != 0) {
printf("Error: RXTX port stats are not as expected\n");
printf("Error: port %d stats are not as expected\n", porte);
return -1;
}
/*
* send and receive 1 packet (RXTX_PORT2 -> RXTX_PORT2)
* send and receive 1 packet (portd -> portd)
* and check for stats update
*/
if (rte_eth_tx_burst(RXTX_PORT2, 0, &pbuf, 1) != 1) {
printf("Error sending packet to RXTX port\n");
printf("Testing send and receive 1 packet (portd -> portd)\n");
if (rte_eth_tx_burst(portd, 0, &pbuf, 1) != 1) {
printf("Error sending packet to port %d\n", portd);
return -1;
}
if (rte_eth_rx_burst(RXTX_PORT2, 0, &pbuf, 1) != 1) {
printf("Error receiving packet from RXTX port\n");
if (rte_eth_rx_burst(portd, 0, &pbuf, 1) != 1) {
printf("Error receiving packet from port %d\n", porte);
return -1;
}
rte_eth_stats_get(RXTX_PORT2, &stats);
rte_eth_stats_get(RXTX_PORT3, &stats2);
rte_eth_stats_get(portd, &stats);
rte_eth_stats_get(porte, &stats2);
if (stats.ipackets != 2 || stats.opackets != 2 ||
stats.ibytes != 0 || stats.obytes != 0 ||
stats.ierrors != 0 || stats.oerrors != 0) {
printf("Error: RXTX port stats are not as expected\n");
printf("Error: port %d stats are not as expected\n", portd);
return -1;
}
if (stats2.ipackets != 1 || stats2.opackets != 1 ||
stats2.ibytes != 0 || stats2.obytes != 0 ||
stats2.ierrors != 0 || stats2.oerrors != 0) {
printf("Error: RXTX port stats are not as expected\n");
printf("Error: port %d stats are not as expected\n", porte);
return -1;
}
/*
* send and receive 1 packet (RXTX_PORT3 -> RXTX_PORT3)
* send and receive 1 packet (porte -> porte)
* and check for stats update
*/
if (rte_eth_tx_burst(RXTX_PORT3, 0, &pbuf, 1) != 1) {
printf("Error sending packet to RXTX port\n");
printf("Testing send and receive 1 packet (porte -> porte)\n");
if (rte_eth_tx_burst(porte, 0, &pbuf, 1) != 1) {
printf("Error sending packet to port %d\n", porte);
return -1;
}
if (rte_eth_rx_burst(RXTX_PORT3, 0, &pbuf, 1) != 1) {
printf("Error receiving packet from RXTX port\n");
if (rte_eth_rx_burst(porte, 0, &pbuf, 1) != 1) {
printf("Error receiving packet from port %d\n", porte);
return -1;
}
rte_eth_stats_get(RXTX_PORT2, &stats);
rte_eth_stats_get(RXTX_PORT3, &stats2);
rte_eth_stats_get(portd, &stats);
rte_eth_stats_get(porte, &stats2);
if (stats.ipackets != 2 || stats.opackets != 2 ||
stats.ibytes != 0 || stats.obytes != 0 ||
stats.ierrors != 0 || stats.oerrors != 0) {
printf("Error: RXTX port stats are not as expected\n");
printf("Error: port %d stats are not as expected\n", portd);
return -1;
}
if (stats2.ipackets != 2 || stats2.opackets != 2 ||
stats2.ibytes != 0 || stats2.obytes != 0 ||
stats2.ierrors != 0 || stats2.oerrors != 0) {
printf("Error: RXTX port stats are not as expected\n");
printf("Error: port %d stats are not as expected\n", porte);
return -1;
}
rte_eth_dev_stop(RXTX_PORT2);
rte_eth_dev_stop(RXTX_PORT3);
rte_eth_dev_stop(portd);
rte_eth_dev_stop(porte);
return 0;
}
@ -405,36 +424,95 @@ test_pmd_ring_pair_create_attach(void)
static int
test_pmd_ring(void)
{
struct rte_ring *rxtx[NUM_RINGS];
int cmdl_port0 = 0;
uint8_t nb_ports;
nb_ports = rte_eth_dev_count();
printf("nb_ports=%d\n", (int)nb_ports);
/* create the rings and eth_rings in the test code.
* This does not test the rte_pmd_ring_devinit function.
*
* Test with the command line option --vdev=eth_ring0 to test rte_pmd_ring_devinit.
*/
rxtx[0] = rte_ring_create("R0", RING_SIZE, SOCKET0, RING_F_SP_ENQ|RING_F_SC_DEQ);
if (rxtx[0] == NULL) {
printf("rte_ring_create R0 failed");
return -1;
}
rxtx[1] = rte_ring_create("R1", RING_SIZE, SOCKET0, RING_F_SP_ENQ|RING_F_SC_DEQ);
if (rxtx[1] == NULL) {
printf("rte_ring_create R1 failed");
return -1;
}
tx_porta = rte_eth_from_rings("eth_ringa", rxtx, NUM_RINGS, rxtx, NUM_RINGS, SOCKET0);
rx_portb = rte_eth_from_rings("eth_ringb", rxtx, NUM_RINGS, rxtx, NUM_RINGS, SOCKET0);
rxtx_portc = rte_eth_from_rings("eth_ringc", rxtx, NUM_RINGS, rxtx, NUM_RINGS, SOCKET0);
rxtx_portd = rte_eth_from_rings("eth_ringd", rxtx, NUM_RINGS, rxtx, NUM_RINGS, SOCKET0);
rxtx_porte = rte_eth_from_rings("eth_ringe", rxtx, NUM_RINGS, rxtx, NUM_RINGS, SOCKET0);
printf("tx_porta=%d rx_portb=%d rxtx_portc=%d rxtx_portd=%d rxtx_porte=%d\n",
tx_porta, rx_portb, rxtx_portc, rxtx_portd, rxtx_porte);
if ((tx_porta == -1) || (rx_portb == -1) || (rxtx_portc == -1)
|| (rxtx_portd == -1) || (rxtx_porte == -1)) {
printf("rte_eth_from rings failed\n");
return -1;
}
mp = rte_pktmbuf_pool_create("mbuf_pool", NB_MBUF, 32,
0, RTE_MBUF_DEFAULT_BUF_SIZE, rte_socket_id());
if (mp == NULL)
return -1;
if ((TX_PORT >= RTE_MAX_ETHPORTS) || (RX_PORT >= RTE_MAX_ETHPORTS)\
|| (RXTX_PORT >= RTE_MAX_ETHPORTS)) {
printf(" TX/RX port exceed max eth ports\n");
if ((tx_porta >= RTE_MAX_ETHPORTS) || (rx_portb >= RTE_MAX_ETHPORTS)
|| (rxtx_portc >= RTE_MAX_ETHPORTS)
|| (rxtx_portd >= RTE_MAX_ETHPORTS)
|| (rxtx_porte >= RTE_MAX_ETHPORTS)) {
printf(" port exceed max eth ports\n");
return -1;
}
if (test_ethdev_configure() < 0)
if (test_ethdev_configure_port(tx_porta) < 0)
return -1;
if (test_ethdev_configure_port(rx_portb) < 0)
return -1;
if (test_ethdev_configure_port(rxtx_portc) < 0)
return -1;
if (test_send_basic_packets() < 0)
return -1;
if (test_get_stats() < 0)
if (test_get_stats(rxtx_portc) < 0)
return -1;
if (test_stats_reset() < 0)
if (test_stats_reset(rxtx_portc) < 0)
return -1;
rte_eth_dev_stop(RX_PORT);
rte_eth_dev_stop(TX_PORT);
rte_eth_dev_stop(RXTX_PORT);
rte_eth_dev_stop(tx_porta);
rte_eth_dev_stop(rx_portb);
rte_eth_dev_stop(rxtx_portc);
if (test_pmd_ring_pair_create_attach() < 0)
if (test_pmd_ring_pair_create_attach(rxtx_portd, rxtx_porte) < 0)
return -1;
if (nb_ports > 0) {
/* test port 0 created with the --vdev=eth_ring0 command line option */
if (test_ethdev_configure_port(cmdl_port0) < 0)
return -1;
if (test_send_basic_packets_port(cmdl_port0) < 0)
return -1;
if (test_stats_reset(cmdl_port0) < 0)
return -1;
if (test_get_stats(cmdl_port0) < 0)
return -1;
rte_eth_dev_stop(cmdl_port0);
}
return 0;
}