diff mbox

[dpdk-dev,v2,1/3] pcap: remove duplicate fields in internal data struct

Message ID 1455794803-20383-2-git-send-email-ferruh.yigit@intel.com (mailing list archive)
State Superseded, archived
Delegated to: Bruce Richardson
Headers show

Commit Message

Ferruh Yigit Feb. 18, 2016, 11:26 a.m. UTC
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

Nicolás Pernas Maradei Feb. 22, 2016, 9:54 a.m. UTC | #1
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, &eth_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, &eth_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, &eth_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, &eth_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;
diff mbox

Patch

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, &eth_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, &eth_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, &eth_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, &eth_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;