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
ethdev: add represented port action to flow API
[dpdk.git]
/
app
/
test
/
test_ring_perf.c
diff --git
a/app/test/test_ring_perf.c
b/app/test/test_ring_perf.c
index
ee21faf
..
fd82e20
100644
(file)
--- a/
app/test/test_ring_perf.c
+++ b/
app/test/test_ring_perf.c
@@
-178,7
+178,7
@@
enqueue_dequeue_bulk_helper(const unsigned int flag, const int esize,
struct thread_params *p)
{
int ret;
struct thread_params *p)
{
int ret;
- const unsigned int iter_shift =
23
;
+ const unsigned int iter_shift =
15
;
const unsigned int iterations = 1 << iter_shift;
struct rte_ring *r = p->r;
unsigned int bsize = p->size;
const unsigned int iterations = 1 << iter_shift;
struct rte_ring *r = p->r;
unsigned int bsize = p->size;
@@
-297,7
+297,7
@@
run_on_core_pair(struct lcore_pair *cores, struct rte_ring *r, const int esize)
lcore_count = 0;
param1.size = param2.size = bulk_sizes[i];
param1.r = param2.r = r;
lcore_count = 0;
param1.size = param2.size = bulk_sizes[i];
param1.r = param2.r = r;
- if (cores->c1 == rte_get_ma
ster
_lcore()) {
+ if (cores->c1 == rte_get_ma
in
_lcore()) {
rte_eal_remote_launch(f2, ¶m2, cores->c2);
f1(¶m1);
rte_eal_wait_lcore(cores->c2);
rte_eal_remote_launch(f2, ¶m2, cores->c2);
f1(¶m1);
rte_eal_wait_lcore(cores->c2);
@@
-340,8
+340,8
@@
load_loop_fn_helper(struct thread_params *p, const int esize)
if (burst == NULL)
return -1;
if (burst == NULL)
return -1;
- /* wait synchro for
slave
s */
- if (lcore != rte_get_ma
ster
_lcore())
+ /* wait synchro for
worker
s */
+ if (lcore != rte_get_ma
in
_lcore())
while (rte_atomic32_read(&synchro) == 0)
rte_pause();
while (rte_atomic32_read(&synchro) == 0)
rte_pause();
@@
-380,7
+380,7
@@
load_loop_fn_16B(void *p)
static int
run_on_all_cores(struct rte_ring *r, const int esize)
{
static int
run_on_all_cores(struct rte_ring *r, const int esize)
{
- uint64_t total
= 0
;
+ uint64_t total;
struct thread_params param;
lcore_function_t *lcore_f;
unsigned int i, c;
struct thread_params param;
lcore_function_t *lcore_f;
unsigned int i, c;
@@
-392,16
+392,17
@@
run_on_all_cores(struct rte_ring *r, const int esize)
memset(¶m, 0, sizeof(struct thread_params));
for (i = 0; i < RTE_DIM(bulk_sizes); i++) {
memset(¶m, 0, sizeof(struct thread_params));
for (i = 0; i < RTE_DIM(bulk_sizes); i++) {
+ total = 0;
printf("\nBulk enq/dequeue count on size %u\n", bulk_sizes[i]);
param.size = bulk_sizes[i];
param.r = r;
printf("\nBulk enq/dequeue count on size %u\n", bulk_sizes[i]);
param.size = bulk_sizes[i];
param.r = r;
- /* clear synchro and start
slave
s */
+ /* clear synchro and start
worker
s */
rte_atomic32_set(&synchro, 0);
rte_atomic32_set(&synchro, 0);
- if (rte_eal_mp_remote_launch(lcore_f, ¶m, SKIP_MA
STER
) < 0)
+ if (rte_eal_mp_remote_launch(lcore_f, ¶m, SKIP_MA
IN
) < 0)
return -1;
return -1;
- /* start synchro and launch test on ma
ster
*/
+ /* start synchro and launch test on ma
in
*/
rte_atomic32_set(&synchro, 1);
lcore_f(¶m);
rte_atomic32_set(&synchro, 1);
lcore_f(¶m);
@@
-552,7
+553,7
@@
test_ring_perf_esize(const int esize)
goto test_fail;
}
goto test_fail;
}
- printf("\n### Testing using all
slave
nodes ###\n");
+ printf("\n### Testing using all
worker
nodes ###\n");
if (run_on_all_cores(r, esize) < 0)
goto test_fail;
if (run_on_all_cores(r, esize) < 0)
goto test_fail;