#include <stdint.h>
#include <stdio.h>
#include <stdlib.h>
#include <inttypes.h>
#include <unistd.h>
#include <signal.h>
#include <string.h>
#include <getopt.h>
#include <cmdline_parse_string.h>
#include <cmdline_socket.h>
#include <rte_pmd_ntb.h>
#include "commands.h"
uint64_t tx;
uint64_t rx;
};
struct ntb_port_statistics ntb_port_stats[2];
struct ntb_fwd_stream {
uint16_t tx_port;
uint16_t rx_port;
uint16_t qp_id;
uint8_t tx_ntb;
};
struct ntb_fwd_lcore_conf {
uint16_t stream_id;
uint16_t nb_stream;
uint8_t stopped;
};
enum ntb_fwd_mode {
FILE_TRANS = 0,
RXONLY,
TXONLY,
IOFWD,
MAX_FWD_MODE,
};
static const char *const fwd_mode_s[] = {
"file-trans",
"rxonly",
"txonly",
"iofwd",
NULL,
};
static enum ntb_fwd_mode fwd_mode = MAX_FWD_MODE;
static struct ntb_fwd_lcore_conf fwd_lcore_conf[RTE_MAX_LCORE];
static struct ntb_fwd_stream *fwd_streams;
#define NTB_DRV_NAME_LEN 7
#define MEMPOOL_CACHE_SIZE 256
static uint8_t in_test;
static uint8_t interactive = 1;
static uint16_t eth_port_id = RTE_MAX_ETHPORTS;
static uint16_t dev_id;
static uint16_t num_queues = 1;
static uint16_t ntb_buf_size = RTE_MBUF_DEFAULT_BUF_SIZE;
#define NTB_DEFAULT_NUM_DESCS 1024
static uint16_t nb_desc = NTB_DEFAULT_NUM_DESCS;
static uint16_t tx_free_thresh;
#define NTB_MAX_PKT_BURST 32
#define NTB_DFLT_PKT_BURST 32
static uint16_t pkt_burst = NTB_DFLT_PKT_BURST;
#define BURST_TX_RETRIES 64
},
.rx_adv_conf = {
.rss_conf = {
.rss_key = NULL,
.rss_hf = RTE_ETH_RSS_IP,
},
},
.txmode = {
},
};
void
struct cmdline *cl,
{
cmdline_printf(
cl,
"\n"
"The following commands are currently available:\n\n"
"Control:\n"
" quit :"
" Quit the application.\n"
"\nTransmission:\n"
" send [path] :"
" Send [path] file. Only take effect in file-trans mode\n"
" start :"
" Start transmissions.\n"
" stop :"
" Stop transmissions.\n"
" clear/show port stats :"
" Clear/show port stats.\n"
" set fwd file-trans/rxonly/txonly/iofwd :"
" Set packet forwarding mode.\n"
);
}
void
struct cmdline *cl,
{
struct ntb_fwd_lcore_conf *conf;
uint32_t lcore_id;
conf = &fwd_lcore_conf[lcore_id];
if (!conf->nb_stream)
continue;
if (conf->stopped)
continue;
conf->stopped = 1;
}
printf("\nWaiting for lcores to finish...\n");
in_test = 0;
if (eth_port_id < RTE_MAX_ETHPORTS && fwd_mode == IOFWD) {
}
cmdline_quit(cl);
}
void
cmd_send_parsed(void *parsed_result,
{
struct cmd_send_result *res = parsed_result;
struct rte_rawdev_buf *pkts_send[NTB_MAX_PKT_BURST];
struct rte_mbuf *mbuf_send[NTB_MAX_PKT_BURST];
uint64_t size, count, i, j, nb_burst;
uint16_t nb_tx, buf_size;
unsigned int nb_pkt;
size_t queue_id = 0;
uint16_t retry = 0;
uint32_t val;
FILE *file;
int ret;
if (num_queues != 1) {
printf("File transmission only supports 1 queue.\n");
num_queues = 1;
}
file = fopen(res->filepath, "r");
if (file == NULL) {
printf("Fail to open the file.\n");
return;
}
if (fseek(file, 0, SEEK_END) < 0) {
printf("Fail to get file size.\n");
fclose(file);
return;
}
size = ftell(file);
if (fseek(file, 0, SEEK_SET) < 0) {
printf("Fail to get file size.\n");
fclose(file);
return;
}
val = size >> 32;
val = size;
printf("Sending file, size is %"PRIu64"\n", size);
for (i = 0; i < NTB_MAX_PKT_BURST; i++)
pkts_send[i] = (struct rte_rawdev_buf *)
malloc(sizeof(struct rte_rawdev_buf));
buf_size = ntb_buf_size - RTE_PKTMBUF_HEADROOM;
count = (size + buf_size - 1) / buf_size;
nb_burst = (count + pkt_burst - 1) / pkt_burst;
for (i = 0; i < nb_burst; i++) {
val) == 0) {
for (nb_pkt = 0; nb_pkt < val; nb_pkt++) {
mbuf_send[nb_pkt]->port = dev_id;
mbuf_send[nb_pkt]->data_len =
void *), 1, buf_size, file);
mbuf_send[nb_pkt]->pkt_len =
mbuf_send[nb_pkt]->data_len;
pkts_send[nb_pkt]->buf_addr = mbuf_send[nb_pkt];
}
} else {
for (nb_pkt = 0; nb_pkt < val; nb_pkt++) {
mbuf_send[nb_pkt] =
if (mbuf_send[nb_pkt] == NULL)
break;
mbuf_send[nb_pkt]->port = dev_id;
mbuf_send[nb_pkt]->data_len =
void *), 1, buf_size, file);
mbuf_send[nb_pkt]->pkt_len =
mbuf_send[nb_pkt]->data_len;
pkts_send[nb_pkt]->buf_addr = mbuf_send[nb_pkt];
}
}
(void *)queue_id);
if (ret < 0) {
printf("Enqueue failed with err %d\n", ret);
for (j = 0; j < nb_pkt; j++)
goto clean;
}
nb_tx = ret;
while (nb_tx != nb_pkt && retry < BURST_TX_RETRIES) {
&pkts_send[nb_tx], nb_pkt - nb_tx,
(void *)queue_id);
if (ret < 0) {
printf("Enqueue failed with err %d\n", ret);
for (j = nb_tx; j < nb_pkt; j++)
goto clean;
}
nb_tx += ret;
}
count -= nb_pkt;
}
printf("Done sending file.\n");
clean:
for (i = 0; i < NTB_MAX_PKT_BURST; i++)
free(pkts_send[i]);
fclose(file);
}
#define RECV_FILE_LEN 30
static int
start_polling_recv_file(void *param)
{
struct rte_rawdev_buf *pkts_recv[NTB_MAX_PKT_BURST];
struct ntb_fwd_lcore_conf *conf = param;
char filepath[RECV_FILE_LEN];
uint64_t val, size, file_len;
uint16_t nb_rx, i, file_no;
size_t queue_id = 0;
FILE *file;
int ret;
for (i = 0; i < NTB_MAX_PKT_BURST; i++)
pkts_recv[i] = (struct rte_rawdev_buf *)
malloc(sizeof(struct rte_rawdev_buf));
file_no = 0;
while (!conf->stopped) {
snprintf(filepath, RECV_FILE_LEN, "ntb_recv_file%d", file_no);
file = fopen(filepath, "w");
if (file == NULL) {
printf("Fail to open the file.\n");
return -EINVAL;
}
size = val << 32;
size |= val;
if (!size) {
fclose(file);
continue;
}
file_len = 0;
nb_rx = NTB_MAX_PKT_BURST;
while (file_len < size && !conf->stopped) {
pkt_burst, (void *)queue_id);
if (ret < 0) {
printf("Dequeue failed with err %d\n", ret);
fclose(file);
goto clean;
}
nb_rx = ret;
ntb_port_stats[0].rx += nb_rx;
for (i = 0; i < nb_rx; i++) {
pkts_recv[i]->buf_addr = NULL;
}
}
printf("Received file (size: %" PRIu64 ") from peer to %s.\n",
size, filepath);
fclose(file);
file_no++;
}
clean:
for (i = 0; i < NTB_MAX_PKT_BURST; i++)
free(pkts_recv[i]);
return 0;
}
static int
start_iofwd_per_lcore(void *param)
{
struct rte_rawdev_buf *ntb_buf[NTB_MAX_PKT_BURST];
struct rte_mbuf *pkts_burst[NTB_MAX_PKT_BURST];
struct ntb_fwd_lcore_conf *conf = param;
struct ntb_fwd_stream fs;
uint16_t nb_rx, nb_tx;
int i, j, ret;
for (i = 0; i < NTB_MAX_PKT_BURST; i++)
ntb_buf[i] = (struct rte_rawdev_buf *)
malloc(sizeof(struct rte_rawdev_buf));
while (!conf->stopped) {
for (i = 0; i < conf->nb_stream; i++) {
fs = fwd_streams[conf->stream_id + i];
if (fs.tx_ntb) {
fs.qp_id, pkts_burst,
pkt_burst);
continue;
for (j = 0; j < nb_rx; j++)
ntb_buf[j]->buf_addr = pkts_burst[j];
ntb_buf, nb_rx,
(void *)(size_t)fs.qp_id);
if (ret < 0) {
printf("Enqueue failed with err %d\n",
ret);
for (j = 0; j < nb_rx; j++)
goto clean;
}
nb_tx = ret;
ntb_port_stats[0].tx += nb_tx;
ntb_port_stats[1].rx += nb_rx;
} else {
ntb_buf, pkt_burst,
(void *)(size_t)fs.qp_id);
if (ret < 0) {
printf("Dequeue failed with err %d\n",
ret);
goto clean;
}
nb_rx = ret;
continue;
for (j = 0; j < nb_rx; j++)
pkts_burst[j] = ntb_buf[j]->buf_addr;
fs.qp_id, pkts_burst, nb_rx);
ntb_port_stats[1].tx += nb_tx;
ntb_port_stats[0].rx += nb_rx;
}
do {
} while (++nb_tx < nb_rx);
}
}
}
clean:
for (i = 0; i < NTB_MAX_PKT_BURST; i++)
free(ntb_buf[i]);
return 0;
}
static int
start_rxonly_per_lcore(void *param)
{
struct rte_rawdev_buf *ntb_buf[NTB_MAX_PKT_BURST];
struct ntb_fwd_lcore_conf *conf = param;
struct ntb_fwd_stream fs;
uint16_t nb_rx;
int i, j, ret;
for (i = 0; i < NTB_MAX_PKT_BURST; i++)
ntb_buf[i] = (struct rte_rawdev_buf *)
malloc(sizeof(struct rte_rawdev_buf));
while (!conf->stopped) {
for (i = 0; i < conf->nb_stream; i++) {
fs = fwd_streams[conf->stream_id + i];
ntb_buf, pkt_burst, (void *)(size_t)fs.qp_id);
if (ret < 0) {
printf("Dequeue failed with err %d\n", ret);
goto clean;
}
nb_rx = ret;
continue;
ntb_port_stats[0].rx += nb_rx;
for (j = 0; j < nb_rx; j++)
}
}
clean:
for (i = 0; i < NTB_MAX_PKT_BURST; i++)
free(ntb_buf[i]);
return 0;
}
static int
start_txonly_per_lcore(void *param)
{
struct rte_rawdev_buf *ntb_buf[NTB_MAX_PKT_BURST];
struct rte_mbuf *pkts_burst[NTB_MAX_PKT_BURST];
struct ntb_fwd_lcore_conf *conf = param;
struct ntb_fwd_stream fs;
uint16_t nb_pkt, nb_tx;
int i, j, ret;
for (i = 0; i < NTB_MAX_PKT_BURST; i++)
ntb_buf[i] = (struct rte_rawdev_buf *)
malloc(sizeof(struct rte_rawdev_buf));
while (!conf->stopped) {
for (i = 0; i < conf->nb_stream; i++) {
fs = fwd_streams[conf->stream_id + i];
pkt_burst) == 0) {
for (nb_pkt = 0; nb_pkt < pkt_burst; nb_pkt++) {
pkts_burst[nb_pkt]->port = dev_id;
pkts_burst[nb_pkt]->data_len =
pkts_burst[nb_pkt]->buf_len -
RTE_PKTMBUF_HEADROOM;
pkts_burst[nb_pkt]->pkt_len =
pkts_burst[nb_pkt]->data_len;
ntb_buf[nb_pkt]->buf_addr =
pkts_burst[nb_pkt];
}
} else {
for (nb_pkt = 0; nb_pkt < pkt_burst; nb_pkt++) {
pkts_burst[nb_pkt] =
if (pkts_burst[nb_pkt] == NULL)
break;
pkts_burst[nb_pkt]->port = dev_id;
pkts_burst[nb_pkt]->data_len =
pkts_burst[nb_pkt]->buf_len -
RTE_PKTMBUF_HEADROOM;
pkts_burst[nb_pkt]->pkt_len =
pkts_burst[nb_pkt]->data_len;
ntb_buf[nb_pkt]->buf_addr =
pkts_burst[nb_pkt];
}
}
nb_pkt, (void *)(size_t)fs.qp_id);
if (ret < 0) {
printf("Enqueue failed with err %d\n", ret);
for (j = 0; j < nb_pkt; j++)
goto clean;
}
nb_tx = ret;
ntb_port_stats[0].tx += nb_tx;
do {
} while (++nb_tx < nb_pkt);
}
}
}
clean:
for (i = 0; i < NTB_MAX_PKT_BURST; i++)
free(ntb_buf[i]);
return 0;
}
static int
ntb_fwd_config_setup(void)
{
uint16_t i;
if (fwd_mode == IOFWD && eth_port_id >= RTE_MAX_ETHPORTS) {
printf("No ethdev, cannot be in iofwd mode.");
return -EINVAL;
}
if (fwd_mode == IOFWD) {
sizeof(struct ntb_fwd_stream) * num_queues * 2,
RTE_CACHE_LINE_SIZE);
for (i = 0; i < num_queues; i++) {
fwd_streams[i * 2].qp_id = i;
fwd_streams[i * 2].tx_port = dev_id;
fwd_streams[i * 2].rx_port = eth_port_id;
fwd_streams[i * 2].tx_ntb = 1;
fwd_streams[i * 2 + 1].qp_id = i;
fwd_streams[i * 2 + 1].tx_port = eth_port_id;
fwd_streams[i * 2 + 1].rx_port = dev_id;
fwd_streams[i * 2 + 1].tx_ntb = 0;
}
return 0;
}
if (fwd_mode == RXONLY || fwd_mode == FILE_TRANS) {
if (fwd_mode == FILE_TRANS)
num_queues = 1;
sizeof(struct ntb_fwd_stream) * num_queues,
RTE_CACHE_LINE_SIZE);
for (i = 0; i < num_queues; i++) {
fwd_streams[i].qp_id = i;
fwd_streams[i].tx_port = RTE_MAX_ETHPORTS;
fwd_streams[i].rx_port = dev_id;
fwd_streams[i].tx_ntb = 0;
}
return 0;
}
if (fwd_mode == TXONLY) {
sizeof(struct ntb_fwd_stream) * num_queues,
RTE_CACHE_LINE_SIZE);
for (i = 0; i < num_queues; i++) {
fwd_streams[i].qp_id = i;
fwd_streams[i].tx_port = dev_id;
fwd_streams[i].rx_port = RTE_MAX_ETHPORTS;
fwd_streams[i].tx_ntb = 1;
}
}
return 0;
}
static void
assign_stream_to_lcores(void)
{
struct ntb_fwd_lcore_conf *conf;
struct ntb_fwd_stream *fs;
uint16_t nb_streams, sm_per_lcore, sm_id, i;
uint32_t lcore_id;
uint8_t lcore_num, nb_extra;
lcore_num--;
nb_streams = (fwd_mode == IOFWD) ? num_queues * 2 : num_queues;
sm_per_lcore = nb_streams / lcore_num;
nb_extra = nb_streams % lcore_num;
sm_id = 0;
i = 0;
conf = &fwd_lcore_conf[lcore_id];
if (i < nb_extra) {
conf->nb_stream = sm_per_lcore + 1;
conf->stream_id = sm_id;
sm_id = sm_id + sm_per_lcore + 1;
} else {
conf->nb_stream = sm_per_lcore;
conf->stream_id = sm_id;
sm_id = sm_id + sm_per_lcore;
}
i++;
if (sm_id >= nb_streams)
break;
}
conf = &fwd_lcore_conf[lcore_id];
if (!conf->nb_stream)
continue;
printf("Streams on Lcore %u :\n", lcore_id);
for (i = 0; i < conf->nb_stream; i++) {
fs = &fwd_streams[conf->stream_id + i];
if (fwd_mode == IOFWD)
printf(" + Stream %u : %s%u RX -> %s%u TX,"
" Q=%u\n", conf->stream_id + i,
fs->tx_ntb ? "Eth" : "NTB", fs->rx_port,
fs->tx_ntb ? "NTB" : "Eth", fs->tx_port,
fs->qp_id);
if (fwd_mode == FILE_TRANS || fwd_mode == RXONLY)
printf(" + Stream %u : %s%u RX only\n",
conf->stream_id, "NTB", fs->rx_port);
if (fwd_mode == TXONLY)
printf(" + Stream %u : %s%u TX only\n",
conf->stream_id, "NTB", fs->tx_port);
}
}
}
static void
start_pkt_fwd(void)
{
struct ntb_fwd_lcore_conf *conf;
uint32_t lcore_id;
int ret, i;
ret = ntb_fwd_config_setup();
if (ret < 0) {
printf("Cannot start traffic. Please reset fwd mode.\n");
return;
}
if (fwd_mode == IOFWD) {
printf("Checking eth link status...\n");
for (i = 0; i < 100; i++) {
if (ret < 0) {
printf("Link get failed with err %d\n", ret);
return;
}
sizeof(link_status_text),
ð_link);
printf("Eth%u %s\n", eth_port_id,
link_status_text);
break;
}
}
printf("Eth%u link down. Cannot start traffic.\n",
eth_port_id);
return;
}
}
assign_stream_to_lcores();
in_test = 1;
conf = &fwd_lcore_conf[lcore_id];
if (!conf->nb_stream)
continue;
conf->stopped = 0;
if (fwd_mode == FILE_TRANS)
conf, lcore_id);
else if (fwd_mode == IOFWD)
conf, lcore_id);
else if (fwd_mode == RXONLY)
conf, lcore_id);
else if (fwd_mode == TXONLY)
conf, lcore_id);
}
}
void
{
start_pkt_fwd();
}
void
{
struct ntb_fwd_lcore_conf *conf;
uint32_t lcore_id;
conf = &fwd_lcore_conf[lcore_id];
if (!conf->nb_stream)
continue;
if (conf->stopped)
continue;
conf->stopped = 1;
}
printf("\nWaiting for lcores to finish...\n");
in_test = 0;
printf("\nDone.\n");
}
static void
ntb_stats_clear(void)
{
int nb_ids, i;
uint32_t *ids;
if (nb_ids <= 0) {
printf("Error: Cannot get count of xstats\n");
return;
}
ids = malloc(sizeof(uint32_t) * nb_ids);
for (i = 0; i < nb_ids; i++)
ids[i] = i;
printf("\n statistics for NTB port %d cleared\n", dev_id);
if (fwd_mode == IOFWD && eth_port_id != RTE_MAX_ETHPORTS) {
printf("\n statistics for ETH port %d cleared\n", eth_port_id);
}
}
static inline void
ntb_calculate_throughput(uint16_t port) {
uint64_t diff_pkts_rx, diff_pkts_tx, diff_cycles;
uint64_t mpps_rx, mpps_tx;
static uint64_t prev_pkts_rx[2];
static uint64_t prev_pkts_tx[2];
static uint64_t prev_cycles[2];
diff_cycles = prev_cycles[port];
prev_cycles[port] = rte_rdtsc();
if (diff_cycles > 0)
diff_cycles = prev_cycles[port] - diff_cycles;
diff_pkts_rx = (ntb_port_stats[port].rx > prev_pkts_rx[port]) ?
(ntb_port_stats[port].rx - prev_pkts_rx[port]) : 0;
diff_pkts_tx = (ntb_port_stats[port].tx > prev_pkts_tx[port]) ?
(ntb_port_stats[port].tx - prev_pkts_tx[port]) : 0;
prev_pkts_rx[port] = ntb_port_stats[port].rx;
prev_pkts_tx[port] = ntb_port_stats[port].tx;
mpps_rx = diff_cycles > 0 ?
mpps_tx = diff_cycles > 0 ?
printf(" Throughput (since last show)\n");
printf(" Rx-pps: %12"PRIu64"\n Tx-pps: %12"PRIu64"\n",
mpps_rx, mpps_tx);
}
static void
ntb_stats_display(void)
{
uint64_t *values;
uint32_t *ids;
int nb_ids, i;
printf("###### statistics for NTB port %d #######\n", dev_id);
if (nb_ids <= 0) {
printf("Error: Cannot get count of xstats\n");
return;
}
if (xstats_names == NULL) {
printf("Cannot allocate memory for xstats lookup\n");
return;
}
dev_id, xstats_names, nb_ids)) {
printf("Error: Cannot get xstats lookup\n");
free(xstats_names);
return;
}
ids = malloc(sizeof(uint32_t) * nb_ids);
for (i = 0; i < nb_ids; i++)
ids[i] = i;
values = malloc(sizeof(uint64_t) * nb_ids);
printf("Error: Unable to get xstats\n");
free(xstats_names);
free(values);
free(ids);
return;
}
for (i = 0; i < nb_ids; i++)
printf(" %s: %"PRIu64"\n", xstats_names[i].name, values[i]);
ntb_calculate_throughput(0);
if (fwd_mode == IOFWD && eth_port_id != RTE_MAX_ETHPORTS) {
printf("###### statistics for ETH port %d ######\n",
eth_port_id);
printf(
" RX-packets: %"PRIu64
"\n", stats.
ipackets);
printf(
" RX-bytes: %"PRIu64
"\n", stats.
ibytes);
printf(
" RX-errors: %"PRIu64
"\n", stats.
ierrors);
printf(
" RX-missed: %"PRIu64
"\n", stats.
imissed);
printf(
" TX-packets: %"PRIu64
"\n", stats.
opackets);
printf(
" TX-bytes: %"PRIu64
"\n", stats.
obytes);
printf(
" TX-errors: %"PRIu64
"\n", stats.
oerrors);
ntb_calculate_throughput(1);
}
free(xstats_names);
free(values);
free(ids);
}
void
cmd_show_port_stats_parsed(
__rte_unused void *parsed_result,
{
ntb_stats_display();
}
void
cmd_clear_port_stats_parsed(
__rte_unused void *parsed_result,
{
ntb_stats_clear();
}
void
cmd_set_fwd_parsed(void *parsed_result,
{
struct cmd_set_fwd_result *res = parsed_result;
int i;
if (in_test) {
printf("Please stop traffic first.\n");
return;
}
for (i = 0; i < MAX_FWD_MODE; i++) {
if (!strcmp(res->mode, fwd_mode_s[i])) {
fwd_mode = i;
return;
}
}
printf("Invalid %s packet forwarding mode.\n", res->mode);
}
static void
prompt(void)
{
struct cmdline *cl;
cl = cmdline_stdin_new(main_ctx, "ntb> ");
if (cl == NULL)
return;
cmdline_interact(cl);
cmdline_stdin_exit(cl);
}
static void
signal_handler(int signum)
{
if (signum == SIGINT || signum == SIGTERM) {
printf("\nSignal %d received, preparing to exit...\n", signum);
signal(signum, SIG_DFL);
kill(getpid(), signum);
}
}
#define OPT_BUF_SIZE "buf-size"
#define OPT_FWD_MODE "fwd-mode"
#define OPT_NB_DESC "nb-desc"
#define OPT_TXFREET "txfreet"
#define OPT_BURST "burst"
#define OPT_QP "qp"
enum {
OPT_NO_ZERO_COPY_NUM = 1,
OPT_BUF_SIZE_NUM,
OPT_FWD_MODE_NUM,
OPT_NB_DESC_NUM,
OPT_TXFREET_NUM,
OPT_BURST_NUM,
OPT_QP_NUM,
};
static const char short_options[] =
"i"
;
static const struct option lgopts[] = {
{OPT_BUF_SIZE, 1, NULL, OPT_BUF_SIZE_NUM },
{OPT_FWD_MODE, 1, NULL, OPT_FWD_MODE_NUM },
{OPT_NB_DESC, 1, NULL, OPT_NB_DESC_NUM },
{OPT_TXFREET, 1, NULL, OPT_TXFREET_NUM },
{OPT_BURST, 1, NULL, OPT_BURST_NUM },
{OPT_QP, 1, NULL, OPT_QP_NUM },
{0, 0, NULL, 0 }
};
static void
ntb_usage(const char *prgname)
{
printf("%s [EAL options] -- [options]\n"
"-i: run in interactive mode.\n"
"-qp=N: set number of queues as N (N > 0, default: 1).\n"
"--fwd-mode=N: set fwd mode (N: file-trans | rxonly | "
"txonly | iofwd, default: file-trans)\n"
"--buf-size=N: set mbuf dataroom size as N (0 < N < 65535,"
" default: 2048).\n"
"--nb-desc=N: set number of descriptors as N (%u <= N <= %u,"
" default: 1024).\n"
"--txfreet=N: set tx free thresh for NTB driver as N. (N >= 0)\n"
"--burst=N: set pkt burst as N (0 < N <= %u default: 32).\n",
prgname, NTB_MIN_DESC_SIZE, NTB_MAX_DESC_SIZE,
NTB_MAX_PKT_BURST);
}
static void
ntb_parse_args(int argc, char **argv)
{
char *prgname = argv[0], **argvopt = argv;
int opt, opt_idx, n, i;
while ((opt = getopt_long(argc, argvopt, short_options,
lgopts, &opt_idx)) != EOF) {
switch (opt) {
case 'i':
printf("Interactive-mode selected.\n");
interactive = 1;
break;
case OPT_QP_NUM:
n = atoi(optarg);
if (n > 0)
num_queues = n;
else
rte_exit(EXIT_FAILURE,
"q must be > 0.\n");
break;
case OPT_BUF_SIZE_NUM:
n = atoi(optarg);
if (n > RTE_PKTMBUF_HEADROOM && n <= 0xFFFF)
ntb_buf_size = n;
else
rte_exit(EXIT_FAILURE,
"buf-size must be > " "%u and < 65536.\n",
RTE_PKTMBUF_HEADROOM);
break;
case OPT_FWD_MODE_NUM:
for (i = 0; i < MAX_FWD_MODE; i++) {
if (!strcmp(optarg, fwd_mode_s[i])) {
fwd_mode = i;
break;
}
}
if (i == MAX_FWD_MODE)
rte_exit(EXIT_FAILURE,
"Unsupported mode. " "(Should be: file-trans | rxonly | txonly "
"| iofwd)\n");
break;
case OPT_NB_DESC_NUM:
n = atoi(optarg);
if (n >= NTB_MIN_DESC_SIZE && n <= NTB_MAX_DESC_SIZE)
nb_desc = n;
else
rte_exit(EXIT_FAILURE,
"nb-desc must be within" " [%u, %u].\n", NTB_MIN_DESC_SIZE,
NTB_MAX_DESC_SIZE);
break;
case OPT_TXFREET_NUM:
n = atoi(optarg);
if (n >= 0)
tx_free_thresh = n;
else
rte_exit(EXIT_FAILURE,
"txfreet must be" " >= 0\n");
break;
case OPT_BURST_NUM:
n = atoi(optarg);
if (n > 0 && n <= NTB_MAX_PKT_BURST)
pkt_burst = n;
else
rte_exit(EXIT_FAILURE,
"burst must be within " "(0, %u].\n", NTB_MAX_PKT_BURST);
break;
default:
ntb_usage(prgname);
"Command line is incomplete or incorrect.\n");
break;
}
}
}
static void
void *opaque)
{
}
ntb_mbuf_pool_create(uint16_t mbuf_seg_size, uint32_t nb_mbuf,
struct ntb_dev_info ntb_info,
struct ntb_dev_config *ntb_conf,
{
size_t mz_len, total_elt_sz, max_mz_len, left_sz;
char pool_name[RTE_MEMPOOL_NAMESIZE];
uint64_t align;
uint32_t mz_id;
int ret;
snprintf(pool_name, sizeof(pool_name), "ntb_mbuf_pool_%u", socket_id);
(mbuf_seg_size +
sizeof(
struct rte_mbuf)),
MEMPOOL_CACHE_SIZE,
socket_id, 0);
if (mp == NULL)
return NULL;
printf("error setting mempool handler\n");
goto fail;
}
memset(&mbp_priv, 0, sizeof(mbp_priv));
ntb_info.mw_cnt, 0);
if (ntb_conf->mz_list == NULL)
goto fail;
if (ntb_info.mw_size[0] < ntb_info.ntb_hdr_size) {
printf("mw0 (size: %" PRIu64 ") is not enough for ntb hdr"
" (size: %u)\n", ntb_info.mw_size[0],
ntb_info.ntb_hdr_size);
goto fail;
}
left_sz = total_elt_sz * nb_mbuf;
for (mz_id = 0; mz_id < ntb_info.mw_cnt; mz_id++) {
if (!left_sz)
break;
snprintf(mz_name, sizeof(mz_name), "ntb_mw_%d", mz_id);
align = ntb_info.mw_size_align ? ntb_info.mw_size[mz_id] :
RTE_CACHE_LINE_SIZE;
max_mz_len = mz_id ? ntb_info.mw_size[mz_id] :
ntb_info.mw_size[mz_id] - ntb_info.ntb_hdr_size;
mz_len = left_sz <= max_mz_len ? left_sz :
(max_mz_len / total_elt_sz * total_elt_sz);
if (!mz_len)
continue;
if (mz == NULL) {
printf("Cannot allocate %" PRIu64 " aligned memzone"
" %u\n", align, mz_id);
goto fail;
}
left_sz -= mz_len;
if (mz_id)
mz->
len, ntb_mempool_mz_free,
(void *)(uintptr_t)mz);
else
(void *)((size_t)mz->addr +
ntb_info.ntb_hdr_size),
mz->iova + ntb_info.ntb_hdr_size,
mz->len - ntb_info.ntb_hdr_size,
ntb_mempool_mz_free,
(void *)(uintptr_t)mz);
if (ret <= 0) {
return NULL;
}
ntb_conf->mz_list[mz_id] =
mz;
}
if (left_sz) {
printf("mw space is not enough for mempool.\n");
goto fail;
}
ntb_conf->mz_num = mz_id;
return mp;
fail:
return NULL;
}
int
main(int argc, char **argv)
{
struct rte_rawdev_info ntb_rawdev_conf;
struct rte_rawdev_info ntb_rawdev_info;
struct ntb_queue_conf ntb_q_conf;
struct ntb_dev_config ntb_conf;
struct ntb_dev_info ntb_info;
uint64_t ntb_link_status;
uint32_t nb_mbuf;
int ret, i;
signal(SIGINT, signal_handler);
signal(SIGTERM, signal_handler);
if (ret < 0)
rte_exit(EXIT_FAILURE,
"Error with EAL initialization.\n");
rte_exit(EXIT_FAILURE,
"Need at least 2 cores\n");
for (i = 0; i < RTE_RAWDEV_MAX_DEVS; i++)
if (rte_rawdevs[i].driver_name &&
(strncmp(rte_rawdevs[i].driver_name, "raw_ntb",
NTB_DRV_NAME_LEN) == 0) && (rte_rawdevs[i].attached == 1))
break;
if (i == RTE_RAWDEV_MAX_DEVS)
rte_exit(EXIT_FAILURE,
"Cannot find any ntb device.\n");
dev_id = i;
argc -= ret;
argv += ret;
ntb_parse_args(argc, argv);
printf("Set queue size as %u.\n", nb_desc);
printf("Set queue number as %u.\n", num_queues);
ntb_rawdev_info.dev_private = (rte_rawdev_obj_t)(&ntb_info);
MEMPOOL_CACHE_SIZE;
mbuf_pool = ntb_mbuf_pool_create(ntb_buf_size, nb_mbuf, ntb_info,
if (mbuf_pool == NULL)
rte_exit(EXIT_FAILURE,
"Cannot create mbuf pool.\n");
ntb_conf.num_queues = num_queues;
ntb_conf.queue_size = nb_desc;
ntb_rawdev_conf.dev_private = (rte_rawdev_obj_t)(&ntb_conf);
if (ret)
rte_exit(EXIT_FAILURE,
"Can't config ntb dev: err=%d, " "port=%u\n", ret, dev_id);
ntb_q_conf.tx_free_thresh = tx_free_thresh;
ntb_q_conf.nb_desc = nb_desc;
ntb_q_conf.rx_mp = mbuf_pool;
for (i = 0; i < num_queues; i++) {
sizeof(ntb_q_conf));
if (ret < 0)
"Failed to setup ntb queue %u.\n", i);
}
printf("Checking ntb link status...\n");
for (i = 0; i < 1000; i++) {
&ntb_link_status);
if (ntb_link_status) {
printf("Peer dev ready, ntb link up.\n");
break;
}
}
if (ntb_link_status == 0)
printf("Expire 100s. Link is not up. Please restart app.\n");
if (ret < 0)
rte_exit(EXIT_FAILURE,
"rte_rawdev_start: err=%d, port=%u\n",
ret, dev_id);
if (eth_port_id < RTE_MAX_ETHPORTS) {
num_queues, ð_pconf);
if (ret)
rte_exit(EXIT_FAILURE,
"Can't config ethdev: err=%d, " "port=%u\n", ret, eth_port_id);
for (i = 0; i < num_queues; i++) {
ð_rx_conf, mbuf_pool);
if (ret < 0)
"Failed to setup eth rxq %u.\n", i);
ð_tx_conf);
if (ret < 0)
"Failed to setup eth txq %u.\n", i);
}
if (ret < 0)
rte_exit(EXIT_FAILURE,
"rte_eth_dev_start: err=%d, " "port=%u\n", ret, eth_port_id);
}
memset(&ntb_port_stats, 0, sizeof(ntb_port_stats));
if (fwd_mode == MAX_FWD_MODE && eth_port_id < RTE_MAX_ETHPORTS) {
printf("Set default fwd mode as iofwd.\n");
fwd_mode = IOFWD;
}
if (fwd_mode == MAX_FWD_MODE) {
printf("Set default fwd mode as file-trans.\n");
fwd_mode = FILE_TRANS;
}
if (interactive) {
sleep(1);
prompt();
} else {
start_pkt_fwd();
}
return 0;
}