The TX port config will fail if the port is not up, so wait 10 seconds
on startup for it to start.

Fixes: de3cfa2c9823 ("sched: initial import")
Cc: sta...@dpdk.org

Signed-off-by: Bruce Richardson <bruce.richard...@intel.com>
---
 examples/qos_sched/init.c | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/examples/qos_sched/init.c b/examples/qos_sched/init.c
index 0709aec10c..6020367705 100644
--- a/examples/qos_sched/init.c
+++ b/examples/qos_sched/init.c
@@ -326,6 +326,8 @@ int app_init(void)
        for(i = 0; i < nb_pfc; i++) {
                uint32_t socket = rte_lcore_to_socket_id(qos_conf[i].rx_core);
                struct rte_ring *ring;
+               struct rte_eth_link link = {0};
+               int retry_count = 100, retry_delay = 100; /* try every 100ms 
for 10 sec */
 
                snprintf(ring_name, MAX_NAME_LEN, "ring-%u-%u", i, 
qos_conf[i].rx_core);
                ring = rte_ring_lookup(ring_name);
@@ -356,6 +358,14 @@ int app_init(void)
                app_init_port(qos_conf[i].rx_port, qos_conf[i].mbuf_pool);
                app_init_port(qos_conf[i].tx_port, qos_conf[i].mbuf_pool);
 
+               rte_eth_link_get(qos_conf[i].tx_port, &link);
+               if (link.link_status == 0)
+                       printf("Waiting for link on port %u\n", 
qos_conf[i].tx_port);
+               while (link.link_status == 0 && retry_count--) {
+                       rte_delay_ms(retry_delay);
+                       rte_eth_link_get(qos_conf[i].tx_port, &link);
+               }
+
                qos_conf[i].sched_port = 
app_init_sched_port(qos_conf[i].tx_port, socket);
        }
 
-- 
2.37.2

Reply via email to