#include <stdint.h>
#include <inttypes.h>
#define RX_RING_SIZE 128
#define TX_RING_SIZE 512
#define NUM_MBUFS 8191
#define MBUF_CACHE_SIZE 250
#define BURST_SIZE 32
};
static unsigned nb_ports;
static struct {
uint64_t total_cycles;
uint64_t total_pkts;
} latency_numbers;
static uint16_t
struct rte_mbuf **pkts, uint16_t nb_pkts,
uint16_t max_pkts __rte_unused, void *_ __rte_unused)
{
unsigned i;
uint64_t now = rte_rdtsc();
for (i = 0; i < nb_pkts; i++)
pkts[i]->udata64 = now;
return nb_pkts;
}
static uint16_t
calc_latency(uint8_t
port __rte_unused, uint16_t qidx __rte_unused,
struct rte_mbuf **pkts, uint16_t nb_pkts,
void *_ __rte_unused)
{
uint64_t cycles = 0;
uint64_t now = rte_rdtsc();
unsigned i;
for (i = 0; i < nb_pkts; i++)
cycles += now - pkts[i]->udata64;
latency_numbers.total_cycles += cycles;
latency_numbers.total_pkts += nb_pkts;
if (latency_numbers.total_pkts > (100 * 1000 * 1000ULL)) {
printf("Latency = %"PRIu64" cycles\n",
latency_numbers.total_cycles / latency_numbers.total_pkts);
latency_numbers.total_cycles = latency_numbers.total_pkts = 0;
}
return nb_pkts;
}
static inline int
{
const uint16_t rx_rings = 1, tx_rings = 1;
int retval;
uint16_t q;
return -1;
if (retval != 0)
return retval;
for (q = 0; q < rx_rings; q++) {
if (retval < 0)
return retval;
}
for (q = 0; q < tx_rings; q++) {
if (retval < 0)
return retval;
}
if (retval < 0)
return retval;
printf("Port %u MAC: %02"PRIx8" %02"PRIx8" %02"PRIx8
" %02"PRIx8" %02"PRIx8" %02"PRIx8"\n",
(unsigned)port,
addr.addr_bytes[0], addr.addr_bytes[1],
addr.addr_bytes[2], addr.addr_bytes[3],
addr.addr_bytes[4], addr.addr_bytes[5]);
return 0;
}
static __attribute__((noreturn)) void
lcore_main(void)
{
uint8_t port;
for (port = 0; port < nb_ports; port++)
printf("WARNING, port %u is on remote NUMA node to "
"polling thread.\n\tPerformance will "
"not be optimal.\n", port);
printf("\nCore %u forwarding packets. [Ctrl+C to quit]\n",
for (;;) {
for (port = 0; port < nb_ports; port++) {
bufs, BURST_SIZE);
continue;
bufs, nb_rx);
uint16_t buf;
for (buf = nb_tx; buf < nb_rx; buf++)
}
}
}
}
int
main(int argc, char *argv[])
{
uint8_t portid;
if (ret < 0)
rte_exit(EXIT_FAILURE,
"Error with EAL initialization\n");
argc -= ret;
argv += ret;
if (nb_ports < 2 || (nb_ports & 1))
rte_exit(EXIT_FAILURE,
"Error: number of ports must be even\n");
NUM_MBUFS * nb_ports, MBUF_CACHE_SIZE, 0,
if (mbuf_pool == NULL)
rte_exit(EXIT_FAILURE,
"Cannot create mbuf pool\n");
for (portid = 0; portid < nb_ports; portid++)
if (port_init(portid, mbuf_pool) != 0)
rte_exit(EXIT_FAILURE,
"Cannot init port %"PRIu8
"\n",
portid);
printf("\nWARNING: Too much enabled lcores - "
"App uses only 1 lcore\n");
lcore_main();
return 0;
}