net/ngbe: add simple Rx flow

[dpdk.git] / drivers / event / dpaa2 / dpaa2_eventdev_selftest.c

diff --git a/drivers/event/dpaa2/dpaa2_eventdev_selftest.c b/drivers/event/dpaa2/dpaa2_eventdev_selftest.c
index ba4f4bd..cd7311a 100644 (file)
--- a/drivers/event/dpaa2/dpaa2_eventdev_selftest.c
+++ b/drivers/event/dpaa2/dpaa2_eventdev_selftest.c
@@ -19,6 +19,7 @@
 #include <rte_random.h>
 #include <rte_bus_vdev.h>
 #include <rte_test.h>
+#include <rte_fslmc.h>
 
 #include "dpaa2_eventdev.h"
 #include "dpaa2_eventdev_logs.h"
@@ -47,17 +48,6 @@ struct event_attr {
        uint8_t seq;
 };
 
-static uint32_t seqn_list_index;
-static int seqn_list[NUM_PACKETS];
-
-static void
-seqn_list_init(void)
-{
-       RTE_BUILD_BUG_ON(NUM_PACKETS < MAX_EVENTS);
-       memset(seqn_list, 0, sizeof(seqn_list));
-       seqn_list_index = 0;
-}
-
 struct test_core_param {
        rte_atomic32_t *total_events;
        uint64_t dequeue_tmo_ticks;
@@ -285,7 +275,8 @@ check_excess_events(uint8_t port)
                valid_event = rte_event_dequeue_burst(evdev, port, &ev, 1, 0);
 
                RTE_TEST_ASSERT_SUCCESS(valid_event,
-                               "Unexpected valid event=%d", ev.mbuf->seqn);
+                               "Unexpected valid event=%d",
+                               *dpaa2_seqn(ev.mbuf));
        }
        return 0;
 }
@@ -501,8 +492,8 @@ wait_workers_to_join(int lcore, const rte_atomic32_t *count)
 
 
 static int
-launch_workers_and_wait(int (*master_worker)(void *),
-                       int (*slave_workers)(void *), uint32_t total_events,
+launch_workers_and_wait(int (*main_worker)(void *),
+                       int (*workers)(void *), uint32_t total_events,
                        uint8_t nb_workers, uint8_t sched_type)
 {
        uint8_t port = 0;
@@ -516,7 +507,7 @@ launch_workers_and_wait(int (*master_worker)(void *),
                return 0;
 
        rte_atomic32_set(&atomic_total_events, total_events);
-       seqn_list_init();
+       RTE_BUILD_BUG_ON(NUM_PACKETS < MAX_EVENTS);
 
        param = malloc(sizeof(struct test_core_param) * nb_workers);
        if (!param)
@@ -537,9 +528,9 @@ launch_workers_and_wait(int (*master_worker)(void *),
 
        w_lcore = rte_get_next_lcore(
                        /* start core */ -1,
-                       /* skip master */ 1,
+                       /* skip main */ 1,
                        /* wrap */ 0);
-       rte_eal_remote_launch(master_worker, &param[0], w_lcore);
+       rte_eal_remote_launch(main_worker, &param[0], w_lcore);
 
        for (port = 1; port < nb_workers; port++) {
                param[port].total_events = &atomic_total_events;
@@ -548,7 +539,7 @@ launch_workers_and_wait(int (*master_worker)(void *),
                param[port].dequeue_tmo_ticks = dequeue_tmo_ticks;
                rte_smp_wmb();
                w_lcore = rte_get_next_lcore(w_lcore, 1, 0);
-               rte_eal_remote_launch(slave_workers, &param[port], w_lcore);
+               rte_eal_remote_launch(workers, &param[port], w_lcore);
        }
 
        ret = wait_workers_to_join(w_lcore, &atomic_total_events);