| Message ID | 1438179941-22229-1-git-send-email-balakrishna.garapati@linaro.org |
|---|---|
| State | Accepted |
| Commit | 342cc3edcaf86deba4774aacc5bdd8fe8afc5f97 |
| Headers | show |
On Wed, Jul 29, 2015 at 04:25:41PM +0200, Balakrishna.Garapati wrote: > Signed-off-by: Balakrishna.Garapati <balakrishna.garapati@linaro.org> Reviewed-by: Stuart Haslam <stuart.haslam@linaro.org> > --- > Added fflush > example/generator/odp_generator.c | 14 +++++++++++++- > 1 file changed, 13 insertions(+), 1 deletion(-) > > diff --git a/example/generator/odp_generator.c b/example/generator/odp_generator.c > index d6ec758..bdee222 100644 > --- a/example/generator/odp_generator.c > +++ b/example/generator/odp_generator.c > @@ -26,6 +26,7 @@ > #define MAX_WORKERS 32 /**< max number of works */ > #define SHM_PKT_POOL_SIZE (512*2048) /**< pkt pool size */ > #define SHM_PKT_POOL_BUF_SIZE 1856 /**< pkt pool buf size */ > +#define DEFAULT_PKT_INTERVAL 1000 /**< interval btw each pkt */ > > #define APPL_MODE_UDP 0 /**< UDP mode */ > #define APPL_MODE_PING 1 /**< ping mode */ > @@ -370,6 +371,7 @@ static odp_pktio_t create_pktio(const char *dev, odp_pool_t pool) > static void *gen_send_thread(void *arg) > { > int thr; > + uint64_t start, now, diff; > odp_pktio_t pktio; > thread_args_t *thr_args; > odp_queue_t outq_def; > @@ -391,6 +393,7 @@ static void *gen_send_thread(void *arg) > return NULL; > } > > + start = odp_time_cycles(); > printf(" [%02i] created mode: SEND\n", thr); > for (;;) { > int err; > @@ -431,6 +434,15 @@ static void *gen_send_thread(void *arg) > >= (unsigned int)args->appl.number) { > break; > } > + > + now = odp_time_cycles(); > + diff = odp_time_diff_cycles(start, now); > + if (odp_time_cycles_to_ns(diff) > 20 * ODP_TIME_SEC) { > + start = odp_time_cycles(); > + printf(" [%02i] total send: %ju\n", > + thr, odp_atomic_load_u64(&counters.seq)); > + fflush(stdout); > + } > } > > /* receive number of reply pks until timeout */ > @@ -439,7 +451,7 @@ static void *gen_send_thread(void *arg) > if (odp_atomic_load_u64(&counters.icmp) >= > (unsigned int)args->appl.number) > break; > - millisleep(1000, > + millisleep(DEFAULT_PKT_INTERVAL, > thr_args->tp, > thr_args->tim, > thr_args->tq, > -- > 1.9.1 >
Merged, Maxim. On 07/30/15 13:55, Stuart Haslam wrote: > On Wed, Jul 29, 2015 at 04:25:41PM +0200, Balakrishna.Garapati wrote: >> Signed-off-by: Balakrishna.Garapati <balakrishna.garapati@linaro.org> > Reviewed-by: Stuart Haslam <stuart.haslam@linaro.org> > >> --- >> Added fflush >> example/generator/odp_generator.c | 14 +++++++++++++- >> 1 file changed, 13 insertions(+), 1 deletion(-) >> >> diff --git a/example/generator/odp_generator.c b/example/generator/odp_generator.c >> index d6ec758..bdee222 100644 >> --- a/example/generator/odp_generator.c >> +++ b/example/generator/odp_generator.c >> @@ -26,6 +26,7 @@ >> #define MAX_WORKERS 32 /**< max number of works */ >> #define SHM_PKT_POOL_SIZE (512*2048) /**< pkt pool size */ >> #define SHM_PKT_POOL_BUF_SIZE 1856 /**< pkt pool buf size */ >> +#define DEFAULT_PKT_INTERVAL 1000 /**< interval btw each pkt */ >> >> #define APPL_MODE_UDP 0 /**< UDP mode */ >> #define APPL_MODE_PING 1 /**< ping mode */ >> @@ -370,6 +371,7 @@ static odp_pktio_t create_pktio(const char *dev, odp_pool_t pool) >> static void *gen_send_thread(void *arg) >> { >> int thr; >> + uint64_t start, now, diff; >> odp_pktio_t pktio; >> thread_args_t *thr_args; >> odp_queue_t outq_def; >> @@ -391,6 +393,7 @@ static void *gen_send_thread(void *arg) >> return NULL; >> } >> >> + start = odp_time_cycles(); >> printf(" [%02i] created mode: SEND\n", thr); >> for (;;) { >> int err; >> @@ -431,6 +434,15 @@ static void *gen_send_thread(void *arg) >> >= (unsigned int)args->appl.number) { >> break; >> } >> + >> + now = odp_time_cycles(); >> + diff = odp_time_diff_cycles(start, now); >> + if (odp_time_cycles_to_ns(diff) > 20 * ODP_TIME_SEC) { >> + start = odp_time_cycles(); >> + printf(" [%02i] total send: %ju\n", >> + thr, odp_atomic_load_u64(&counters.seq)); >> + fflush(stdout); >> + } >> } >> >> /* receive number of reply pks until timeout */ >> @@ -439,7 +451,7 @@ static void *gen_send_thread(void *arg) >> if (odp_atomic_load_u64(&counters.icmp) >= >> (unsigned int)args->appl.number) >> break; >> - millisleep(1000, >> + millisleep(DEFAULT_PKT_INTERVAL, >> thr_args->tp, >> thr_args->tim, >> thr_args->tq, >> -- >> 1.9.1 >>
diff --git a/example/generator/odp_generator.c b/example/generator/odp_generator.c index d6ec758..bdee222 100644 --- a/example/generator/odp_generator.c +++ b/example/generator/odp_generator.c @@ -26,6 +26,7 @@ #define MAX_WORKERS 32 /**< max number of works */ #define SHM_PKT_POOL_SIZE (512*2048) /**< pkt pool size */ #define SHM_PKT_POOL_BUF_SIZE 1856 /**< pkt pool buf size */ +#define DEFAULT_PKT_INTERVAL 1000 /**< interval btw each pkt */ #define APPL_MODE_UDP 0 /**< UDP mode */ #define APPL_MODE_PING 1 /**< ping mode */ @@ -370,6 +371,7 @@ static odp_pktio_t create_pktio(const char *dev, odp_pool_t pool) static void *gen_send_thread(void *arg) { int thr; + uint64_t start, now, diff; odp_pktio_t pktio; thread_args_t *thr_args; odp_queue_t outq_def; @@ -391,6 +393,7 @@ static void *gen_send_thread(void *arg) return NULL; } + start = odp_time_cycles(); printf(" [%02i] created mode: SEND\n", thr); for (;;) { int err; @@ -431,6 +434,15 @@ static void *gen_send_thread(void *arg) >= (unsigned int)args->appl.number) { break; } + + now = odp_time_cycles(); + diff = odp_time_diff_cycles(start, now); + if (odp_time_cycles_to_ns(diff) > 20 * ODP_TIME_SEC) { + start = odp_time_cycles(); + printf(" [%02i] total send: %ju\n", + thr, odp_atomic_load_u64(&counters.seq)); + fflush(stdout); + } } /* receive number of reply pks until timeout */ @@ -439,7 +451,7 @@ static void *gen_send_thread(void *arg) if (odp_atomic_load_u64(&counters.icmp) >= (unsigned int)args->appl.number) break; - millisleep(1000, + millisleep(DEFAULT_PKT_INTERVAL, thr_args->tp, thr_args->tim, thr_args->tq,
Signed-off-by: Balakrishna.Garapati <balakrishna.garapati@linaro.org> --- Added fflush example/generator/odp_generator.c | 14 +++++++++++++- 1 file changed, 13 insertions(+), 1 deletion(-)