From: ido goshen <ido@cgstowernetworks.com>
To: Ferruh Yigit <ferruh.yigit@intel.com>
Cc: dev@dpdk.org, ido goshen <ido@cgstowernetworks.com>
Subject: [dpdk-dev] [PATCH v2 3/3] net/pcap: support pcap files and ifaces mix
Date: Thu, 21 Jun 2018 15:24:33 +0300 [thread overview]
Message-ID: <1529583874-71745-1-git-send-email-ido@cgstowernetworks.com> (raw)
Suggested-by: Ferruh Yigit <ferruh.yigit@intel.com>
Signed-off-by: ido goshen <ido@cgstowernetworks.com>
---
drivers/net/pcap/rte_eth_pcap.c | 82 +++++++++++++++++++++++++----------------
1 file changed, 50 insertions(+), 32 deletions(-)
diff --git a/drivers/net/pcap/rte_eth_pcap.c b/drivers/net/pcap/rte_eth_pcap.c
index b21930b..33c5366 100644
--- a/drivers/net/pcap/rte_eth_pcap.c
+++ b/drivers/net/pcap/rte_eth_pcap.c
@@ -232,7 +232,7 @@ struct pmd_devargs {
/*
* Callback to handle writing packets to a pcap file.
*/
-static uint16_t
+static inline uint16_t
eth_pcap_tx_dumper(void *queue, struct rte_mbuf **bufs, uint16_t nb_pkts)
{
unsigned int i;
@@ -293,7 +293,7 @@ struct pmd_devargs {
/*
* Callback to handle sending packets through a real NIC.
*/
-static uint16_t
+static inline uint16_t
eth_pcap_tx(void *queue, struct rte_mbuf **bufs, uint16_t nb_pkts)
{
unsigned int i;
@@ -343,6 +343,16 @@ struct pmd_devargs {
return num_tx;
}
+static uint16_t
+eth_pcap_tx_mux(void *queue, struct rte_mbuf **bufs, uint16_t nb_pkts)
+{
+ struct pcap_tx_queue *tx_queue = queue;
+ if (tx_queue->dumper)
+ return eth_pcap_tx_dumper(queue, bufs, nb_pkts);
+ else
+ return eth_pcap_tx(queue, bufs, nb_pkts);
+}
+
/*
* pcap_open_live wrapper function
*/
@@ -773,6 +783,31 @@ struct pmd_devargs {
return open_iface(key, value, extra_args);
}
+static int
+open_pcap_rx_mux(const char *key, const char *value, void *extra_args)
+{
+ struct pmd_devargs *pcaps = extra_args;
+
+ if (strcmp(key, ETH_PCAP_RX_PCAP_ARG) == 0)
+ return open_rx_pcap(key, value, pcaps);
+ if (strcmp(key, ETH_PCAP_RX_IFACE_ARG) == 0)
+ return open_rx_iface(key, value, pcaps);
+ return 0;
+}
+
+static int
+open_pcap_tx_mux(const char *key, const char *value, void *extra_args)
+{
+ struct pmd_devargs *dumpers = extra_args;
+
+ if (strcmp(key, ETH_PCAP_TX_PCAP_ARG) == 0)
+ return open_tx_pcap(key, value, dumpers);
+ if (strcmp(key, ETH_PCAP_TX_IFACE_ARG) == 0)
+ return open_tx_iface(key, value, dumpers);
+ return 0;
+}
+
+
static struct rte_vdev_driver pmd_pcap_drv;
static int
@@ -873,8 +908,7 @@ struct pmd_devargs {
eth_from_pcaps(struct rte_vdev_device *vdev,
struct pmd_devargs *rx_queues, const unsigned int nb_rx_queues,
struct pmd_devargs *tx_queues, const unsigned int nb_tx_queues,
- struct rte_kvargs *kvlist, int single_iface,
- unsigned int using_dumpers)
+ struct rte_kvargs *kvlist, int single_iface)
{
struct pmd_internals *internals = NULL;
struct rte_eth_dev *eth_dev = NULL;
@@ -891,10 +925,7 @@ struct pmd_devargs {
eth_dev->rx_pkt_burst = eth_pcap_rx;
- if (using_dumpers)
- eth_dev->tx_pkt_burst = eth_pcap_tx_dumper;
- else
- eth_dev->tx_pkt_burst = eth_pcap_tx;
+ eth_dev->tx_pkt_burst = eth_pcap_tx_mux;
rte_eth_dev_probing_finish(eth_dev);
return 0;
@@ -904,7 +935,6 @@ struct pmd_devargs {
pmd_pcap_probe(struct rte_vdev_device *dev)
{
const char *name;
- unsigned int is_rx_pcap = 0, is_tx_pcap = 0;
struct rte_kvargs *kvlist;
struct pmd_devargs pcaps = {0};
struct pmd_devargs dumpers = {0};
@@ -958,42 +988,30 @@ struct pmd_devargs {
}
/*
- * We check whether we want to open a RX stream from a real NIC or a
- * pcap file
+ * Open RX streams for pcap files and real NICs
+ * Need to be parsed together for the queues to maintain
+ * the input args order
*/
- is_rx_pcap = rte_kvargs_count(kvlist, ETH_PCAP_RX_PCAP_ARG) ? 1 : 0;
pcaps.num_of_queue = 0;
-
- if (is_rx_pcap)
- ret = rte_kvargs_process(kvlist, ETH_PCAP_RX_PCAP_ARG,
- &open_rx_pcap, &pcaps);
- else
- ret = rte_kvargs_process(kvlist, ETH_PCAP_RX_IFACE_ARG,
- &open_rx_iface, &pcaps);
-
+ ret = rte_kvargs_process(kvlist, NULL,
+ &open_pcap_rx_mux, &pcaps);
if (ret < 0)
goto free_kvlist;
/*
- * We check whether we want to open a TX stream to a real NIC or a
- * pcap file
+ * Open TX streams for pcap files and real NICs
+ * Need to be parsed together for the queues to maintain
+ * the input args order
*/
- is_tx_pcap = rte_kvargs_count(kvlist, ETH_PCAP_TX_PCAP_ARG) ? 1 : 0;
dumpers.num_of_queue = 0;
-
- if (is_tx_pcap)
- ret = rte_kvargs_process(kvlist, ETH_PCAP_TX_PCAP_ARG,
- &open_tx_pcap, &dumpers);
- else
- ret = rte_kvargs_process(kvlist, ETH_PCAP_TX_IFACE_ARG,
- &open_tx_iface, &dumpers);
-
+ ret = rte_kvargs_process(kvlist, NULL,
+ &open_pcap_tx_mux, &dumpers);
if (ret < 0)
goto free_kvlist;
create_eth:
ret = eth_from_pcaps(dev, &pcaps, pcaps.num_of_queue, &dumpers,
- dumpers.num_of_queue, kvlist, single_iface, is_tx_pcap);
+ dumpers.num_of_queue, kvlist, single_iface);
free_kvlist:
rte_kvargs_free(kvlist);
--
1.9.1
next reply other threads:[~2018-06-21 12:25 UTC|newest]
Thread overview: 4+ messages / expand[flat|nested] mbox.gz Atom feed top
2018-06-21 12:24 ido goshen [this message]
2018-06-21 12:51 ` Ferruh Yigit
2018-06-22 7:15 ` Ido Goshen
2018-06-26 9:05 ` Ferruh Yigit
Reply instructions:
You may reply publicly to this message via plain-text email
using any one of the following methods:
* Save the following mbox file, import it into your mail client,
and reply-to-all from there: mbox
Avoid top-posting and favor interleaved quoting:
https://en.wikipedia.org/wiki/Posting_style#Interleaved_style
* Reply using the --to, --cc, and --in-reply-to
switches of git-send-email(1):
git send-email \
--in-reply-to=1529583874-71745-1-git-send-email-ido@cgstowernetworks.com \
--to=ido@cgstowernetworks.com \
--cc=dev@dpdk.org \
--cc=ferruh.yigit@intel.com \
/path/to/YOUR_REPLY
https://kernel.org/pub/software/scm/git/docs/git-send-email.html
* If your mail client supports setting the In-Reply-To header
via mailto: links, try the mailto: link
Be sure your reply has a Subject: header at the top and a blank line
before the message body.
This is a public inbox, see mirroring instructions
for how to clone and mirror all data and code used for this inbox;
as well as URLs for NNTP newsgroup(s).