app/testpmd: fix bonding mode set

[dpdk.git] / app / test-eventdev / test_order_atq.c

diff --git a/app/test-eventdev/test_order_atq.c b/app/test-eventdev/test_order_atq.c
index cfcb1dc..2fee4b4 100644 (file)
--- a/app/test-eventdev/test_order_atq.c
+++ b/app/test-eventdev/test_order_atq.c
@@ -28,14 +28,14 @@ order_atq_worker(void *arg, const bool flow_id_cap)
                uint16_t event = rte_event_dequeue_burst(dev_id, port,
                                        &ev, 1, 0);
                if (!event) {
-                       if (rte_atomic64_read(outstand_pkts) <= 0)
+                       if (__atomic_load_n(outstand_pkts, __ATOMIC_RELAXED) <= 0)
                                break;
                        rte_pause();
                        continue;
                }
 
                if (!flow_id_cap)
-                       ev.flow_id = ev.mbuf->udata64;
+                       order_flow_id_copy_from_mbuf(t, &ev);
 
                if (ev.sub_event_type == 0) { /* stage 0 from producer */
                        order_atq_process_stage_0(&ev);
@@ -64,7 +64,7 @@ order_atq_worker_burst(void *arg, const bool flow_id_cap)
                                BURST_SIZE, 0);
 
                if (nb_rx == 0) {
-                       if (rte_atomic64_read(outstand_pkts) <= 0)
+                       if (__atomic_load_n(outstand_pkts, __ATOMIC_RELAXED) <= 0)
                                break;
                        rte_pause();
                        continue;
@@ -72,7 +72,7 @@ order_atq_worker_burst(void *arg, const bool flow_id_cap)
 
                for (i = 0; i < nb_rx; i++) {
                        if (!flow_id_cap)
-                               ev[i].flow_id = ev[i].mbuf->udata64;
+                               order_flow_id_copy_from_mbuf(t, &ev[i]);
 
                        if (ev[i].sub_event_type == 0) { /*stage 0 */
                                order_atq_process_stage_0(&ev[i]);