git.droids-corp.org
/
dpdk.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
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_random.h>
#include <rte_bus_vdev.h>
#include <rte_test.h>
+#include <rte_fslmc.h>
#include "dpaa2_eventdev.h"
#include "dpaa2_eventdev_logs.h"
#include "dpaa2_eventdev.h"
#include "dpaa2_eventdev_logs.h"
@@
-47,17
+48,6
@@
struct event_attr {
uint8_t seq;
};
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;
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,
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;
}
}
return 0;
}
@@
-501,8
+492,8
@@
wait_workers_to_join(int lcore, const rte_atomic32_t *count)
static int
static int
-launch_workers_and_wait(int (*ma
ster
_worker)(void *),
- int (*
slave_
workers)(void *), uint32_t total_events,
+launch_workers_and_wait(int (*ma
in
_worker)(void *),
+ int (*workers)(void *), uint32_t total_events,
uint8_t nb_workers, uint8_t sched_type)
{
uint8_t port = 0;
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);
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)
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,
w_lcore = rte_get_next_lcore(
/* start core */ -1,
- /* skip ma
ster
*/ 1,
+ /* skip ma
in
*/ 1,
/* wrap */ 0);
/* wrap */ 0);
- rte_eal_remote_launch(ma
ster
_worker, ¶m[0], w_lcore);
+ rte_eal_remote_launch(ma
in
_worker, ¶m[0], w_lcore);
for (port = 1; port < nb_workers; port++) {
param[port].total_events = &atomic_total_events;
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);
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, ¶m[port], w_lcore);
+ rte_eal_remote_launch(workers, ¶m[port], w_lcore);
}
ret = wait_workers_to_join(w_lcore, &atomic_total_events);
}
ret = wait_workers_to_join(w_lcore, &atomic_total_events);