diff options
| author | Ola Liljedahl <ola.liljedahl@linaro.org> | 2014-11-24 23:38:46 +0100 |
|---|---|---|
| committer | Maxim Uvarov <maxim.uvarov@linaro.org> | 2014-11-25 18:24:24 +0300 |
| commit | 6d2d4d957ea9ee5a71e93a141811fb2eafb9bca6 (patch) | |
| tree | 4ecdf3e900e04bd369fc620769a1622f33476238 /example | |
| parent | 9fe348ddad05e929e9a51dc4e5fe3a54b3d46e9c (diff) | |
linux-generic: odp_generator.c use odp_atomic.h
Signed-off-by: Ola Liljedahl <ola.liljedahl@linaro.org>
Reviewed-by: Petri Savolainen <petri.savolainen@linaro.org>
Signed-off-by: Maxim Uvarov <maxim.uvarov@linaro.org>
Diffstat (limited to 'example')
| -rw-r--r-- | example/generator/odp_generator.c | 16 |
1 files changed, 11 insertions, 5 deletions
diff --git a/example/generator/odp_generator.c b/example/generator/odp_generator.c index e2e0ba415..7d1c2371e 100644 --- a/example/generator/odp_generator.c +++ b/example/generator/odp_generator.c @@ -338,11 +338,14 @@ static void *gen_send_thread(void *arg) if (args->appl.interval != 0) { printf(" [%02i] send pkt no:%ju seq %ju\n", - thr, counters.seq, counters.seq%0xffff); + thr, + odp_atomic_load_u64(&counters.seq), + odp_atomic_load_u64(&counters.seq)%0xffff); /* TODO use odp timer */ usleep(args->appl.interval * 1000); } - if (args->appl.number != -1 && counters.seq + if (args->appl.number != -1 && + odp_atomic_load_u64(&counters.seq) >= (unsigned int)args->appl.number) { break; } @@ -351,7 +354,8 @@ static void *gen_send_thread(void *arg) /* receive number of reply pks until timeout */ if (args->appl.mode == APPL_MODE_PING && args->appl.number > 0) { while (args->appl.timeout >= 0) { - if (counters.icmp >= (unsigned int)args->appl.number) + if (odp_atomic_load_u64(&counters.icmp) >= + (unsigned int)args->appl.number) break; /* TODO use odp timer */ sleep(1); @@ -361,10 +365,12 @@ static void *gen_send_thread(void *arg) /* print info */ if (args->appl.mode == APPL_MODE_UDP) { - printf(" [%02i] total send: %ju\n", thr, counters.seq); + printf(" [%02i] total send: %ju\n", + thr, odp_atomic_load_u64(&counters.seq)); } else if (args->appl.mode == APPL_MODE_PING) { printf(" [%02i] total send: %ju total receive: %ju\n", - thr, counters.seq, counters.icmp); + thr, odp_atomic_load_u64(&counters.seq), + odp_atomic_load_u64(&counters.icmp)); } return arg; } |