add global mean in ring buffer tests

2 files changed, 16 insertions, 4 deletions

diff --git a/lf_ring_buffer_test.c b/lf_ring_buffer_test.c
index dd56ca2..2f95af1 100644
--- a/lf_ring_buffer_test.c
+++ b/lf_ring_buffer_test.c
@@ -30,6 +30,7 @@ struct thread_params {
     lf_ring_buffer_t *ring;
     int n;
     int flags;
+    uint64_t dt;
 };
 
 /*
@@ -78,19 +79,20 @@ static uint64_t sequential_reads( lf_ring_buffer_t *ring, int n, int flags ) {
 void* writer_thread( void* param ) {
     struct thread_params *params = (struct thread_params*)param;
     //report( "write", params->n, sequential_writes( params->ring, params->n, params->flags ) );
-    sequential_writes( params->ring, params->n, params->flags );
+    params->dt = sequential_writes( params->ring, params->n, params->flags );
     return NULL;
 }
 
 void* reader_thread( void* param ) {
     struct thread_params *params = (struct thread_params*)param;
     //report( "read ", params->n, sequential_reads( params->ring, params->n, params->flags ) );
-    sequential_reads( params->ring, params->n, params->flags );
+    params->dt = sequential_reads( params->ring, params->n, params->flags );
     return NULL;
 }
 
 static void parallel_op( int op, int nt, lf_ring_buffer_t *ring, int n, int flags ) {
     int i;
+    uint64_t dt;
     
     pthread_t *threads = malloc( sizeof(pthread_t)*nt);
     struct thread_params *params = malloc( sizeof(struct thread_params)*nt);
@@ -121,9 +123,13 @@ static void parallel_op( int op, int nt, lf_ring_buffer_t *ring, int n, int flag
             }
         }
     }
+    dt = 0;
     for(i=0; i<nt; i++) {
         pthread_join( threads[i], NULL );
+        dt += params[i].dt;
     }
+    dt/=nt;
+    fprintf(stdout,"\t\t\t       Mean : %4d [ms] => %7d [us] => %10d [ns]\t >>> %6d [ns/op]\n",(int)(dt/1000000), (int)(dt/1000), (int)dt, (int)(dt/(n/nt)) );
     /* empty the ring */
     free(threads);
     free(params);
diff --git a/lf_ring_buffer_test2.c b/lf_ring_buffer_test2.c
index 8b5ac8b..c1288cc 100644
--- a/lf_ring_buffer_test2.c
+++ b/lf_ring_buffer_test2.c
@@ -30,6 +30,7 @@ struct thread_params {
     lf_ring_buffer_t *ring;
     int n;
     int flags;
+    uint64_t dt;
 };
 
 /*
@@ -78,19 +79,20 @@ static uint64_t sequential_reads( lf_ring_buffer_t *ring, int n, int flags ) {
 void* writer_thread( void* param ) {
     struct thread_params *params = (struct thread_params*)param;
     //report( "write", params->n, sequential_writes( params->ring, params->n, params->flags ) );
-    sequential_writes( params->ring, params->n, params->flags );
+    params->dt = sequential_writes( params->ring, params->n, params->flags );
     return NULL;
 }
 
 void* reader_thread( void* param ) {
     struct thread_params *params = (struct thread_params*)param;
     //report( "read ", params->n, sequential_reads( params->ring, params->n, params->flags ) );
-    sequential_reads( params->ring, params->n, params->flags );
+    params->dt = sequential_reads( params->ring, params->n, params->flags );
     return NULL;
 }
 
 static void parallel_op( int op, int nt, lf_ring_buffer_t *ring, int n, int flags ) {
     int i;
+    uint64_t dt;
     
     pthread_t *threads = malloc( sizeof(pthread_t)*nt);
     struct thread_params *params = malloc( sizeof(struct thread_params)*nt);
@@ -121,9 +123,13 @@ static void parallel_op( int op, int nt, lf_ring_buffer_t *ring, int n, int flag
             }
         }
     }
+    dt = 0;
     for(i=0; i<nt; i++) {
         pthread_join( threads[i], NULL );
+        dt += params[i].dt;
     }
+    dt/=nt;
+    fprintf(stdout,"\t\t\t       Mean : %4d [ms] => %7d [us] => %10d [ns]\t >>> %6d [ns/op]\n",(int)(dt/1000000), (int)(dt/1000), (int)dt, (int)(dt/(n/nt)) );
     /* empty the ring */
     free(threads);
     free(params);