app/testpmd: remove hardcoded descriptors limit

[dpdk.git] / app / test-pmd / testpmd.c

diff --git a/app/test-pmd/testpmd.c b/app/test-pmd/testpmd.c
index 035836a..99bacdd 100644 (file)
--- a/app/test-pmd/testpmd.c
+++ b/app/test-pmd/testpmd.c
@@ -1155,6 +1155,177 @@ check_nb_txq(queueid_t txq)
        return 0;
 }
 
+/*
+ * Get the allowed maximum number of RXDs of every rx queue.
+ * *pid return the port id which has minimal value of
+ * max_rxd in all queues of all ports.
+ */
+static uint16_t
+get_allowed_max_nb_rxd(portid_t *pid)
+{
+       uint16_t allowed_max_rxd = UINT16_MAX;
+       portid_t pi;
+       struct rte_eth_dev_info dev_info;
+
+       RTE_ETH_FOREACH_DEV(pi) {
+               if (eth_dev_info_get_print_err(pi, &dev_info) != 0)
+                       continue;
+
+               if (dev_info.rx_desc_lim.nb_max < allowed_max_rxd) {
+                       allowed_max_rxd = dev_info.rx_desc_lim.nb_max;
+                       *pid = pi;
+               }
+       }
+       return allowed_max_rxd;
+}
+
+/*
+ * Get the allowed minimal number of RXDs of every rx queue.
+ * *pid return the port id which has minimal value of
+ * min_rxd in all queues of all ports.
+ */
+static uint16_t
+get_allowed_min_nb_rxd(portid_t *pid)
+{
+       uint16_t allowed_min_rxd = 0;
+       portid_t pi;
+       struct rte_eth_dev_info dev_info;
+
+       RTE_ETH_FOREACH_DEV(pi) {
+               if (eth_dev_info_get_print_err(pi, &dev_info) != 0)
+                       continue;
+
+               if (dev_info.rx_desc_lim.nb_min > allowed_min_rxd) {
+                       allowed_min_rxd = dev_info.rx_desc_lim.nb_min;
+                       *pid = pi;
+               }
+       }
+
+       return allowed_min_rxd;
+}
+
+/*
+ * Check input rxd is valid or not.
+ * If input rxd is not greater than any of maximum number
+ * of RXDs of every Rx queues and is not less than any of
+ * minimal number of RXDs of every Rx queues, it is valid.
+ * if valid, return 0, else return -1
+ */
+int
+check_nb_rxd(queueid_t rxd)
+{
+       uint16_t allowed_max_rxd;
+       uint16_t allowed_min_rxd;
+       portid_t pid = 0;
+
+       allowed_max_rxd = get_allowed_max_nb_rxd(&pid);
+       if (rxd > allowed_max_rxd) {
+               printf("Fail: input rxd (%u) can't be greater "
+                      "than max_rxds (%u) of port %u\n",
+                      rxd,
+                      allowed_max_rxd,
+                      pid);
+               return -1;
+       }
+
+       allowed_min_rxd = get_allowed_min_nb_rxd(&pid);
+       if (rxd < allowed_min_rxd) {
+               printf("Fail: input rxd (%u) can't be less "
+                      "than min_rxds (%u) of port %u\n",
+                      rxd,
+                      allowed_min_rxd,
+                      pid);
+               return -1;
+       }
+
+       return 0;
+}
+
+/*
+ * Get the allowed maximum number of TXDs of every rx queues.
+ * *pid return the port id which has minimal value of
+ * max_txd in every tx queue.
+ */
+static uint16_t
+get_allowed_max_nb_txd(portid_t *pid)
+{
+       uint16_t allowed_max_txd = UINT16_MAX;
+       portid_t pi;
+       struct rte_eth_dev_info dev_info;
+
+       RTE_ETH_FOREACH_DEV(pi) {
+               if (eth_dev_info_get_print_err(pi, &dev_info) != 0)
+                       continue;
+
+               if (dev_info.tx_desc_lim.nb_max < allowed_max_txd) {
+                       allowed_max_txd = dev_info.tx_desc_lim.nb_max;
+                       *pid = pi;
+               }
+       }
+       return allowed_max_txd;
+}
+
+/*
+ * Get the allowed maximum number of TXDs of every tx queues.
+ * *pid return the port id which has minimal value of
+ * min_txd in every tx queue.
+ */
+static uint16_t
+get_allowed_min_nb_txd(portid_t *pid)
+{
+       uint16_t allowed_min_txd = 0;
+       portid_t pi;
+       struct rte_eth_dev_info dev_info;
+
+       RTE_ETH_FOREACH_DEV(pi) {
+               if (eth_dev_info_get_print_err(pi, &dev_info) != 0)
+                       continue;
+
+               if (dev_info.tx_desc_lim.nb_min > allowed_min_txd) {
+                       allowed_min_txd = dev_info.tx_desc_lim.nb_min;
+                       *pid = pi;
+               }
+       }
+
+       return allowed_min_txd;
+}
+
+/*
+ * Check input txd is valid or not.
+ * If input txd is not greater than any of maximum number
+ * of TXDs of every Rx queues, it is valid.
+ * if valid, return 0, else return -1
+ */
+int
+check_nb_txd(queueid_t txd)
+{
+       uint16_t allowed_max_txd;
+       uint16_t allowed_min_txd;
+       portid_t pid = 0;
+
+       allowed_max_txd = get_allowed_max_nb_txd(&pid);
+       if (txd > allowed_max_txd) {
+               printf("Fail: input txd (%u) can't be greater "
+                      "than max_txds (%u) of port %u\n",
+                      txd,
+                      allowed_max_txd,
+                      pid);
+               return -1;
+       }
+
+       allowed_min_txd = get_allowed_min_nb_txd(&pid);
+       if (txd < allowed_min_txd) {
+               printf("Fail: input txd (%u) can't be less "
+                      "than min_txds (%u) of port %u\n",
+                      txd,
+                      allowed_min_txd,
+                      pid);
+               return -1;
+       }
+       return 0;
+}
+
+
 /*
  * Get the allowed maximum number of hairpin queues.
  * *pid return the port id which has minimal value of