Lines Matching defs:fs
365 struct ntb_fwd_stream fs;
375 fs = fwd_streams[conf->stream_id + i];
376 if (fs.tx_ntb) {
377 nb_rx = rte_eth_rx_burst(fs.rx_port,
378 fs.qp_id, pkts_burst,
384 ret = rte_rawdev_enqueue_buffers(fs.tx_port,
386 (void *)(size_t)fs.qp_id);
398 ret = rte_rawdev_dequeue_buffers(fs.rx_port,
400 (void *)(size_t)fs.qp_id);
411 nb_tx = rte_eth_tx_burst(fs.tx_port,
412 fs.qp_id, pkts_burst, nb_rx);
436 struct ntb_fwd_stream fs;
446 fs = fwd_streams[conf->stream_id + i];
447 ret = rte_rawdev_dequeue_buffers(fs.rx_port,
448 ntb_buf, pkt_burst, (void *)(size_t)fs.qp_id);
477 struct ntb_fwd_stream fs;
487 fs = fwd_streams[conf->stream_id + i];
516 ret = rte_rawdev_enqueue_buffers(fs.tx_port, ntb_buf,
517 nb_pkt, (void *)(size_t)fs.qp_id);
605 struct ntb_fwd_stream *fs;
648 fs = &fwd_streams[conf->stream_id + i];
652 fs->tx_ntb ? "Eth" : "NTB", fs->rx_port,
653 fs->tx_ntb ? "NTB" : "Eth", fs->tx_port,
654 fs->qp_id);
657 conf->stream_id, "NTB", fs->rx_port);
660 conf->stream_id, "NTB", fs->tx_port);