New upstream version 17.08

[deb_dpdk.git] / examples / ip_pipeline / init.c

diff --git a/examples/ip_pipeline/init.c b/examples/ip_pipeline/init.c
index be148fc..7cde49a 100644 (file)
--- a/examples/ip_pipeline/init.c
+++ b/examples/ip_pipeline/init.c
@@ -1003,16 +1003,30 @@ app_init_link(struct app_params *app)
                        struct app_pktq_hwq_in_params *p_rxq =
                                &app->hwq_in_params[j];
                        uint32_t rxq_link_id, rxq_queue_id;
+                       uint16_t nb_rxd = p_rxq->size;
 
                        sscanf(p_rxq->name, "RXQ%" PRIu32 ".%" PRIu32,
                                &rxq_link_id, &rxq_queue_id);
                        if (rxq_link_id != link_id)
                                continue;
 
+                       status = rte_eth_dev_adjust_nb_rx_tx_desc(
+                               p_link->pmd_id,
+                               &nb_rxd,
+                               NULL);
+                       if (status < 0)
+                               rte_panic("%s (%" PRIu32 "): "
+                                       "%s adjust number of Rx descriptors "
+                                       "error (%" PRId32 ")\n",
+                                       p_link->name,
+                                       p_link->pmd_id,
+                                       p_rxq->name,
+                                       status);
+
                        status = rte_eth_rx_queue_setup(
                                p_link->pmd_id,
                                rxq_queue_id,
-                               p_rxq->size,
+                               nb_rxd,
                                app_get_cpu_socket_id(p_link->pmd_id),
                                &p_rxq->conf,
                                app->mempool[p_rxq->mempool_id]);
@@ -1030,16 +1044,30 @@ app_init_link(struct app_params *app)
                        struct app_pktq_hwq_out_params *p_txq =
                                &app->hwq_out_params[j];
                        uint32_t txq_link_id, txq_queue_id;
+                       uint16_t nb_txd = p_txq->size;
 
                        sscanf(p_txq->name, "TXQ%" PRIu32 ".%" PRIu32,
                                &txq_link_id, &txq_queue_id);
                        if (txq_link_id != link_id)
                                continue;
 
+                       status = rte_eth_dev_adjust_nb_rx_tx_desc(
+                               p_link->pmd_id,
+                               NULL,
+                               &nb_txd);
+                       if (status < 0)
+                               rte_panic("%s (%" PRIu32 "): "
+                                       "%s adjust number of Tx descriptors "
+                                       "error (%" PRId32 ")\n",
+                                       p_link->name,
+                                       p_link->pmd_id,
+                                       p_txq->name,
+                                       status);
+
                        status = rte_eth_tx_queue_setup(
                                p_link->pmd_id,
                                txq_queue_id,
-                               p_txq->size,
+                               nb_txd,
                                app_get_cpu_socket_id(p_link->pmd_id),
                                &p_txq->conf);
                        if (status < 0)