[dpdk-dev,v2,1/3] pcap: remove duplicate fields in internal data struct
Commit Message
1- Remove duplicate nb_rx/tx_queues fields from internals
2- Move duplicate code into a common function
Signed-off-by: Ferruh Yigit <ferruh.yigit@intel.com>
---
drivers/net/pcap/rte_eth_pcap.c | 130 +++++++++++++++++++---------------------
1 file changed, 61 insertions(+), 69 deletions(-)
Comments
Hi,
Patch looks good to me although I haven't tested it. Adding Acked-by line.
Nico.
On 18/02/16 11:26, Ferruh Yigit wrote:
> 1- Remove duplicate nb_rx/tx_queues fields from internals
> 2- Move duplicate code into a common function
>
> Signed-off-by: Ferruh Yigit <ferruh.yigit@intel.com>
> Acked-by: Nicolas Pernas Maradei <nicolas.pernas.maradei@emutex.com>
> ---
> drivers/net/pcap/rte_eth_pcap.c | 130 +++++++++++++++++++---------------------
> 1 file changed, 61 insertions(+), 69 deletions(-)
>
> diff --git a/drivers/net/pcap/rte_eth_pcap.c b/drivers/net/pcap/rte_eth_pcap.c
> index f9230eb..c8b7dbd 100644
> --- a/drivers/net/pcap/rte_eth_pcap.c
> +++ b/drivers/net/pcap/rte_eth_pcap.c
> @@ -103,8 +103,6 @@ struct tx_pcaps {
> struct pmd_internals {
> struct pcap_rx_queue rx_queue[RTE_PMD_RING_MAX_RX_RINGS];
> struct pcap_tx_queue tx_queue[RTE_PMD_RING_MAX_TX_RINGS];
> - unsigned nb_rx_queues;
> - unsigned nb_tx_queues;
> int if_index;
> int single_iface;
> };
> @@ -396,7 +394,7 @@ eth_dev_start(struct rte_eth_dev *dev)
> }
>
> /* If not open already, open tx pcaps/dumpers */
> - for (i = 0; i < internals->nb_tx_queues; i++) {
> + for (i = 0; i < dev->data->nb_tx_queues; i++) {
> tx = &internals->tx_queue[i];
>
> if (!tx->dumper && strcmp(tx->type, ETH_PCAP_TX_PCAP_ARG) == 0) {
> @@ -411,7 +409,7 @@ eth_dev_start(struct rte_eth_dev *dev)
> }
>
> /* If not open already, open rx pcaps */
> - for (i = 0; i < internals->nb_rx_queues; i++) {
> + for (i = 0; i < dev->data->nb_rx_queues; i++) {
> rx = &internals->rx_queue[i];
>
> if (rx->pcap != NULL)
> @@ -457,7 +455,7 @@ eth_dev_stop(struct rte_eth_dev *dev)
> goto status_down;
> }
>
> - for (i = 0; i < internals->nb_tx_queues; i++) {
> + for (i = 0; i < dev->data->nb_tx_queues; i++) {
> tx = &internals->tx_queue[i];
>
> if (tx->dumper != NULL) {
> @@ -471,7 +469,7 @@ eth_dev_stop(struct rte_eth_dev *dev)
> }
> }
>
> - for (i = 0; i < internals->nb_rx_queues; i++) {
> + for (i = 0; i < dev->data->nb_rx_queues; i++) {
> rx = &internals->rx_queue[i];
>
> if (rx->pcap != NULL) {
> @@ -499,8 +497,8 @@ eth_dev_info(struct rte_eth_dev *dev,
> dev_info->if_index = internals->if_index;
> dev_info->max_mac_addrs = 1;
> dev_info->max_rx_pktlen = (uint32_t) -1;
> - dev_info->max_rx_queues = (uint16_t)internals->nb_rx_queues;
> - dev_info->max_tx_queues = (uint16_t)internals->nb_tx_queues;
> + dev_info->max_rx_queues = dev->data->nb_rx_queues;
> + dev_info->max_tx_queues = dev->data->nb_tx_queues;
> dev_info->min_rx_bufsize = 0;
> dev_info->pci_dev = NULL;
> }
> @@ -515,16 +513,16 @@ eth_stats_get(struct rte_eth_dev *dev,
> unsigned long tx_packets_err_total = 0;
> const struct pmd_internals *internal = dev->data->dev_private;
>
> - for (i = 0; i < RTE_ETHDEV_QUEUE_STAT_CNTRS && i < internal->nb_rx_queues;
> - i++) {
> + for (i = 0; i < RTE_ETHDEV_QUEUE_STAT_CNTRS &&
> + i < dev->data->nb_rx_queues; i++) {
> igb_stats->q_ipackets[i] = internal->rx_queue[i].rx_pkts;
> igb_stats->q_ibytes[i] = internal->rx_queue[i].rx_bytes;
> rx_packets_total += igb_stats->q_ipackets[i];
> rx_bytes_total += igb_stats->q_ibytes[i];
> }
>
> - for (i = 0; i < RTE_ETHDEV_QUEUE_STAT_CNTRS && i < internal->nb_tx_queues;
> - i++) {
> + for (i = 0; i < RTE_ETHDEV_QUEUE_STAT_CNTRS &&
> + i < dev->data->nb_tx_queues; i++) {
> igb_stats->q_opackets[i] = internal->tx_queue[i].tx_pkts;
> igb_stats->q_obytes[i] = internal->tx_queue[i].tx_bytes;
> igb_stats->q_errors[i] = internal->tx_queue[i].err_pkts;
> @@ -545,11 +543,11 @@ eth_stats_reset(struct rte_eth_dev *dev)
> {
> unsigned i;
> struct pmd_internals *internal = dev->data->dev_private;
> - for (i = 0; i < internal->nb_rx_queues; i++) {
> + for (i = 0; i < dev->data->nb_rx_queues; i++) {
> internal->rx_queue[i].rx_pkts = 0;
> internal->rx_queue[i].rx_bytes = 0;
> }
> - for (i = 0; i < internal->nb_tx_queues; i++) {
> + for (i = 0; i < dev->data->nb_tx_queues; i++) {
> internal->tx_queue[i].tx_pkts = 0;
> internal->tx_queue[i].tx_bytes = 0;
> internal->tx_queue[i].err_pkts = 0;
> @@ -840,9 +838,6 @@ rte_pmd_init_internals(const char *name, const unsigned nb_rx_queues,
> /* NOTE: we'll replace the data element, of originally allocated eth_dev
> * so the rings are local per-process */
>
> - (*internals)->nb_rx_queues = nb_rx_queues;
> - (*internals)->nb_tx_queues = nb_tx_queues;
> -
> if (pair == NULL)
> (*internals)->if_index = 0;
> else
> @@ -860,11 +855,11 @@ rte_pmd_init_internals(const char *name, const unsigned nb_rx_queues,
>
> (*eth_dev)->data = data;
> (*eth_dev)->dev_ops = &ops;
> - (*eth_dev)->data->dev_flags = RTE_ETH_DEV_DETACHABLE;
> (*eth_dev)->driver = NULL;
> - (*eth_dev)->data->kdrv = RTE_KDRV_NONE;
> - (*eth_dev)->data->drv_name = drivername;
> - (*eth_dev)->data->numa_node = numa_node;
> + data->dev_flags = RTE_ETH_DEV_DETACHABLE;
> + data->kdrv = RTE_KDRV_NONE;
> + data->drv_name = drivername;
> + data->numa_node = numa_node;
>
> return 0;
>
> @@ -876,16 +871,12 @@ error:
> }
>
> static int
> -rte_eth_from_pcaps_n_dumpers(const char *name,
> - struct rx_pcaps *rx_queues,
> - const unsigned nb_rx_queues,
> - struct tx_pcaps *tx_queues,
> - const unsigned nb_tx_queues,
> - const unsigned numa_node,
> - struct rte_kvargs *kvlist)
> +rte_eth_from_pcaps_common(const char *name, struct rx_pcaps *rx_queues,
> + const unsigned nb_rx_queues, struct tx_pcaps *tx_queues,
> + const unsigned nb_tx_queues, const unsigned numa_node,
> + struct rte_kvargs *kvlist, struct pmd_internals **internals,
> + struct rte_eth_dev **eth_dev)
> {
> - struct pmd_internals *internals = NULL;
> - struct rte_eth_dev *eth_dev = NULL;
> unsigned i;
>
> /* do some parameter checking */
> @@ -895,28 +886,51 @@ rte_eth_from_pcaps_n_dumpers(const char *name,
> return -1;
>
> if (rte_pmd_init_internals(name, nb_rx_queues, nb_tx_queues, numa_node,
> - &internals, ð_dev, kvlist) < 0)
> + internals, eth_dev, kvlist) < 0)
> return -1;
>
> for (i = 0; i < nb_rx_queues; i++) {
> - internals->rx_queue[i].pcap = rx_queues->pcaps[i];
> - snprintf(internals->rx_queue[i].name,
> - sizeof(internals->rx_queue[i].name), "%s",
> + (*internals)->rx_queue[i].pcap = rx_queues->pcaps[i];
> + snprintf((*internals)->rx_queue[i].name,
> + sizeof((*internals)->rx_queue[i].name), "%s",
> rx_queues->names[i]);
> - snprintf(internals->rx_queue[i].type,
> - sizeof(internals->rx_queue[i].type), "%s",
> + snprintf((*internals)->rx_queue[i].type,
> + sizeof((*internals)->rx_queue[i].type), "%s",
> rx_queues->types[i]);
> }
> for (i = 0; i < nb_tx_queues; i++) {
> - internals->tx_queue[i].dumper = tx_queues->dumpers[i];
> - snprintf(internals->tx_queue[i].name,
> - sizeof(internals->tx_queue[i].name), "%s",
> + (*internals)->tx_queue[i].dumper = tx_queues->dumpers[i];
> + snprintf((*internals)->tx_queue[i].name,
> + sizeof((*internals)->tx_queue[i].name), "%s",
> tx_queues->names[i]);
> - snprintf(internals->tx_queue[i].type,
> - sizeof(internals->tx_queue[i].type), "%s",
> + snprintf((*internals)->tx_queue[i].type,
> + sizeof((*internals)->tx_queue[i].type), "%s",
> tx_queues->types[i]);
> }
>
> + return 0;
> +}
> +
> +static int
> +rte_eth_from_pcaps_n_dumpers(const char *name,
> + struct rx_pcaps *rx_queues,
> + const unsigned nb_rx_queues,
> + struct tx_pcaps *tx_queues,
> + const unsigned nb_tx_queues,
> + const unsigned numa_node,
> + struct rte_kvargs *kvlist)
> +{
> + struct pmd_internals *internals = NULL;
> + struct rte_eth_dev *eth_dev = NULL;
> + int ret;
> +
> + ret = rte_eth_from_pcaps_common(name, rx_queues, nb_rx_queues,
> + tx_queues, nb_tx_queues, numa_node, kvlist,
> + &internals, ð_dev);
> +
> + if (ret < 0)
> + return ret;
> +
> /* using multiple pcaps/interfaces */
> internals->single_iface = 0;
>
> @@ -938,36 +952,14 @@ rte_eth_from_pcaps(const char *name,
> {
> struct pmd_internals *internals = NULL;
> struct rte_eth_dev *eth_dev = NULL;
> - unsigned i;
> -
> - /* do some parameter checking */
> - if (rx_queues == NULL && nb_rx_queues > 0)
> - return -1;
> - if (tx_queues == NULL && nb_tx_queues > 0)
> - return -1;
> + int ret;
>
> - if (rte_pmd_init_internals(name, nb_rx_queues, nb_tx_queues, numa_node,
> - &internals, ð_dev, kvlist) < 0)
> - return -1;
> + ret = rte_eth_from_pcaps_common(name, rx_queues, nb_rx_queues,
> + tx_queues, nb_tx_queues, numa_node, kvlist,
> + &internals, ð_dev);
>
> - for (i = 0; i < nb_rx_queues; i++) {
> - internals->rx_queue[i].pcap = rx_queues->pcaps[i];
> - snprintf(internals->rx_queue[i].name,
> - sizeof(internals->rx_queue[i].name), "%s",
> - rx_queues->names[i]);
> - snprintf(internals->rx_queue[i].type,
> - sizeof(internals->rx_queue[i].type), "%s",
> - rx_queues->types[i]);
> - }
> - for (i = 0; i < nb_tx_queues; i++) {
> - internals->tx_queue[i].dumper = tx_queues->dumpers[i];
> - snprintf(internals->tx_queue[i].name,
> - sizeof(internals->tx_queue[i].name), "%s",
> - tx_queues->names[i]);
> - snprintf(internals->tx_queue[i].type,
> - sizeof(internals->tx_queue[i].type), "%s",
> - tx_queues->types[i]);
> - }
> + if (ret < 0)
> + return ret;
>
> /* store wether we are using a single interface for rx/tx or not */
> internals->single_iface = single_iface;
@@ -103,8 +103,6 @@ struct tx_pcaps {
struct pmd_internals {
struct pcap_rx_queue rx_queue[RTE_PMD_RING_MAX_RX_RINGS];
struct pcap_tx_queue tx_queue[RTE_PMD_RING_MAX_TX_RINGS];
- unsigned nb_rx_queues;
- unsigned nb_tx_queues;
int if_index;
int single_iface;
};
@@ -396,7 +394,7 @@ eth_dev_start(struct rte_eth_dev *dev)
}
/* If not open already, open tx pcaps/dumpers */
- for (i = 0; i < internals->nb_tx_queues; i++) {
+ for (i = 0; i < dev->data->nb_tx_queues; i++) {
tx = &internals->tx_queue[i];
if (!tx->dumper && strcmp(tx->type, ETH_PCAP_TX_PCAP_ARG) == 0) {
@@ -411,7 +409,7 @@ eth_dev_start(struct rte_eth_dev *dev)
}
/* If not open already, open rx pcaps */
- for (i = 0; i < internals->nb_rx_queues; i++) {
+ for (i = 0; i < dev->data->nb_rx_queues; i++) {
rx = &internals->rx_queue[i];
if (rx->pcap != NULL)
@@ -457,7 +455,7 @@ eth_dev_stop(struct rte_eth_dev *dev)
goto status_down;
}
- for (i = 0; i < internals->nb_tx_queues; i++) {
+ for (i = 0; i < dev->data->nb_tx_queues; i++) {
tx = &internals->tx_queue[i];
if (tx->dumper != NULL) {
@@ -471,7 +469,7 @@ eth_dev_stop(struct rte_eth_dev *dev)
}
}
- for (i = 0; i < internals->nb_rx_queues; i++) {
+ for (i = 0; i < dev->data->nb_rx_queues; i++) {
rx = &internals->rx_queue[i];
if (rx->pcap != NULL) {
@@ -499,8 +497,8 @@ eth_dev_info(struct rte_eth_dev *dev,
dev_info->if_index = internals->if_index;
dev_info->max_mac_addrs = 1;
dev_info->max_rx_pktlen = (uint32_t) -1;
- dev_info->max_rx_queues = (uint16_t)internals->nb_rx_queues;
- dev_info->max_tx_queues = (uint16_t)internals->nb_tx_queues;
+ dev_info->max_rx_queues = dev->data->nb_rx_queues;
+ dev_info->max_tx_queues = dev->data->nb_tx_queues;
dev_info->min_rx_bufsize = 0;
dev_info->pci_dev = NULL;
}
@@ -515,16 +513,16 @@ eth_stats_get(struct rte_eth_dev *dev,
unsigned long tx_packets_err_total = 0;
const struct pmd_internals *internal = dev->data->dev_private;
- for (i = 0; i < RTE_ETHDEV_QUEUE_STAT_CNTRS && i < internal->nb_rx_queues;
- i++) {
+ for (i = 0; i < RTE_ETHDEV_QUEUE_STAT_CNTRS &&
+ i < dev->data->nb_rx_queues; i++) {
igb_stats->q_ipackets[i] = internal->rx_queue[i].rx_pkts;
igb_stats->q_ibytes[i] = internal->rx_queue[i].rx_bytes;
rx_packets_total += igb_stats->q_ipackets[i];
rx_bytes_total += igb_stats->q_ibytes[i];
}
- for (i = 0; i < RTE_ETHDEV_QUEUE_STAT_CNTRS && i < internal->nb_tx_queues;
- i++) {
+ for (i = 0; i < RTE_ETHDEV_QUEUE_STAT_CNTRS &&
+ i < dev->data->nb_tx_queues; i++) {
igb_stats->q_opackets[i] = internal->tx_queue[i].tx_pkts;
igb_stats->q_obytes[i] = internal->tx_queue[i].tx_bytes;
igb_stats->q_errors[i] = internal->tx_queue[i].err_pkts;
@@ -545,11 +543,11 @@ eth_stats_reset(struct rte_eth_dev *dev)
{
unsigned i;
struct pmd_internals *internal = dev->data->dev_private;
- for (i = 0; i < internal->nb_rx_queues; i++) {
+ for (i = 0; i < dev->data->nb_rx_queues; i++) {
internal->rx_queue[i].rx_pkts = 0;
internal->rx_queue[i].rx_bytes = 0;
}
- for (i = 0; i < internal->nb_tx_queues; i++) {
+ for (i = 0; i < dev->data->nb_tx_queues; i++) {
internal->tx_queue[i].tx_pkts = 0;
internal->tx_queue[i].tx_bytes = 0;
internal->tx_queue[i].err_pkts = 0;
@@ -840,9 +838,6 @@ rte_pmd_init_internals(const char *name, const unsigned nb_rx_queues,
/* NOTE: we'll replace the data element, of originally allocated eth_dev
* so the rings are local per-process */
- (*internals)->nb_rx_queues = nb_rx_queues;
- (*internals)->nb_tx_queues = nb_tx_queues;
-
if (pair == NULL)
(*internals)->if_index = 0;
else
@@ -860,11 +855,11 @@ rte_pmd_init_internals(const char *name, const unsigned nb_rx_queues,
(*eth_dev)->data = data;
(*eth_dev)->dev_ops = &ops;
- (*eth_dev)->data->dev_flags = RTE_ETH_DEV_DETACHABLE;
(*eth_dev)->driver = NULL;
- (*eth_dev)->data->kdrv = RTE_KDRV_NONE;
- (*eth_dev)->data->drv_name = drivername;
- (*eth_dev)->data->numa_node = numa_node;
+ data->dev_flags = RTE_ETH_DEV_DETACHABLE;
+ data->kdrv = RTE_KDRV_NONE;
+ data->drv_name = drivername;
+ data->numa_node = numa_node;
return 0;
@@ -876,16 +871,12 @@ error:
}
static int
-rte_eth_from_pcaps_n_dumpers(const char *name,
- struct rx_pcaps *rx_queues,
- const unsigned nb_rx_queues,
- struct tx_pcaps *tx_queues,
- const unsigned nb_tx_queues,
- const unsigned numa_node,
- struct rte_kvargs *kvlist)
+rte_eth_from_pcaps_common(const char *name, struct rx_pcaps *rx_queues,
+ const unsigned nb_rx_queues, struct tx_pcaps *tx_queues,
+ const unsigned nb_tx_queues, const unsigned numa_node,
+ struct rte_kvargs *kvlist, struct pmd_internals **internals,
+ struct rte_eth_dev **eth_dev)
{
- struct pmd_internals *internals = NULL;
- struct rte_eth_dev *eth_dev = NULL;
unsigned i;
/* do some parameter checking */
@@ -895,28 +886,51 @@ rte_eth_from_pcaps_n_dumpers(const char *name,
return -1;
if (rte_pmd_init_internals(name, nb_rx_queues, nb_tx_queues, numa_node,
- &internals, ð_dev, kvlist) < 0)
+ internals, eth_dev, kvlist) < 0)
return -1;
for (i = 0; i < nb_rx_queues; i++) {
- internals->rx_queue[i].pcap = rx_queues->pcaps[i];
- snprintf(internals->rx_queue[i].name,
- sizeof(internals->rx_queue[i].name), "%s",
+ (*internals)->rx_queue[i].pcap = rx_queues->pcaps[i];
+ snprintf((*internals)->rx_queue[i].name,
+ sizeof((*internals)->rx_queue[i].name), "%s",
rx_queues->names[i]);
- snprintf(internals->rx_queue[i].type,
- sizeof(internals->rx_queue[i].type), "%s",
+ snprintf((*internals)->rx_queue[i].type,
+ sizeof((*internals)->rx_queue[i].type), "%s",
rx_queues->types[i]);
}
for (i = 0; i < nb_tx_queues; i++) {
- internals->tx_queue[i].dumper = tx_queues->dumpers[i];
- snprintf(internals->tx_queue[i].name,
- sizeof(internals->tx_queue[i].name), "%s",
+ (*internals)->tx_queue[i].dumper = tx_queues->dumpers[i];
+ snprintf((*internals)->tx_queue[i].name,
+ sizeof((*internals)->tx_queue[i].name), "%s",
tx_queues->names[i]);
- snprintf(internals->tx_queue[i].type,
- sizeof(internals->tx_queue[i].type), "%s",
+ snprintf((*internals)->tx_queue[i].type,
+ sizeof((*internals)->tx_queue[i].type), "%s",
tx_queues->types[i]);
}
+ return 0;
+}
+
+static int
+rte_eth_from_pcaps_n_dumpers(const char *name,
+ struct rx_pcaps *rx_queues,
+ const unsigned nb_rx_queues,
+ struct tx_pcaps *tx_queues,
+ const unsigned nb_tx_queues,
+ const unsigned numa_node,
+ struct rte_kvargs *kvlist)
+{
+ struct pmd_internals *internals = NULL;
+ struct rte_eth_dev *eth_dev = NULL;
+ int ret;
+
+ ret = rte_eth_from_pcaps_common(name, rx_queues, nb_rx_queues,
+ tx_queues, nb_tx_queues, numa_node, kvlist,
+ &internals, ð_dev);
+
+ if (ret < 0)
+ return ret;
+
/* using multiple pcaps/interfaces */
internals->single_iface = 0;
@@ -938,36 +952,14 @@ rte_eth_from_pcaps(const char *name,
{
struct pmd_internals *internals = NULL;
struct rte_eth_dev *eth_dev = NULL;
- unsigned i;
-
- /* do some parameter checking */
- if (rx_queues == NULL && nb_rx_queues > 0)
- return -1;
- if (tx_queues == NULL && nb_tx_queues > 0)
- return -1;
+ int ret;
- if (rte_pmd_init_internals(name, nb_rx_queues, nb_tx_queues, numa_node,
- &internals, ð_dev, kvlist) < 0)
- return -1;
+ ret = rte_eth_from_pcaps_common(name, rx_queues, nb_rx_queues,
+ tx_queues, nb_tx_queues, numa_node, kvlist,
+ &internals, ð_dev);
- for (i = 0; i < nb_rx_queues; i++) {
- internals->rx_queue[i].pcap = rx_queues->pcaps[i];
- snprintf(internals->rx_queue[i].name,
- sizeof(internals->rx_queue[i].name), "%s",
- rx_queues->names[i]);
- snprintf(internals->rx_queue[i].type,
- sizeof(internals->rx_queue[i].type), "%s",
- rx_queues->types[i]);
- }
- for (i = 0; i < nb_tx_queues; i++) {
- internals->tx_queue[i].dumper = tx_queues->dumpers[i];
- snprintf(internals->tx_queue[i].name,
- sizeof(internals->tx_queue[i].name), "%s",
- tx_queues->names[i]);
- snprintf(internals->tx_queue[i].type,
- sizeof(internals->tx_queue[i].type), "%s",
- tx_queues->types[i]);
- }
+ if (ret < 0)
+ return ret;
/* store wether we are using a single interface for rx/tx or not */
internals->single_iface = single_iface;