Re: [lng-odp] [PATCHv3] example:generator:printing verbose output

[Maxim Uvarov]

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.garap...@linaro.org>

Reviewed-by: Stuart Haslam <stuart.has...@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

_______________________________________________
lng-odp mailing list
lng-odp@lists.linaro.org
https://lists.linaro.org/mailman/listinfo/lng-odp