Changeset f03209d3 for benchmark/readyQ/locality.cpp

Timestamp:

Jan 5, 2021, 5:51:30 PM (4 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

ADT, arm-eh, ast-experimental, enum, forall-pointer-decay, jacob/cs343-translation, master, new-ast-unique-expr, pthread-emulation, qualifiedEnum

Children:

4468a70, 587a608

Parents:

ed1a6374

Message:

Locality benchmark now supports explicit number of spots instead of using nthreads - nprocs

File:

• benchmark/readyQ/locality.cpp (modified) (7 diffs)

benchmark/readyQ/locality.cpp

@@ -201 +201 @@
 
 void thread_main( MyCtx & ctx ) {
-        uint64_t state;
+        uint64_t state = ctx.id;
 
         // Wait for start
@@ -237 +237 @@
         unsigned wsize = 2;
         unsigned wcnt  = 2;
+        unsigned nspots = 0;
         bool share = false;
         option_t opt[] = {
                 BENCH_OPT,
+                { 'n', "nspots", "Number of spots where threads sleep (nthreads - nspots are active at the same time)", nspots},
                 { 'w', "worksize", "Size of the array for each threads, in words (64bit)", wsize},
                 { 'c', "workcnt" , "Number of words to touch when working (random pick, cells can be picked more than once)", wcnt },
@@ -252 +254 @@
         unsigned long long global_gmigs = 0;
         unsigned long long global_dmigs = 0;
+
+        if( nspots == 0 ) { nspots = nthreads - nprocs; }
 
         uint64_t start, end;
@@ -261 +265 @@
                 }
 
-                MySpot * spots[nthreads - nprocs];
-                for(size_t i = 0; i < (nthreads - nprocs); i++) {
+                MySpot * spots[nspots];
+                for(unsigned i = 0; i < nspots; i++) {
                         spots[i] = new MySpot{ i };
                 }
 
-                threads_left = nthreads;
+                threads_left = nthreads - nspots;
                 Fibre * threads[nthreads];
                 MyCtx * thddata[nthreads];
@@ -274 +278 @@
                                         data_arrays[i],
                                         spots,
-                                        nthreads - nprocs,
+                                        nspots,
                                         wcnt,
                                         share,
@@ -307 +311 @@
                 }
 
-                for(size_t i = 0; i < (nthreads - nprocs); i++) {
+                for(size_t i = 0; i < nspots; i++) {
                         delete( spots[i] );
                 }
@@ -315 +319 @@
         printf("Number of processors   : %'d\n", nprocs);
         printf("Number of threads      : %'d\n", nthreads);
-        printf("Total Operations(ops)  : %'15llu\n", global_count);
+        printf("Number of spots        : %'d\n", nspots);
         printf("Work size (64bit words): %'15u\n", wsize);
         printf("Total Operations(ops)  : %'15llu\n", global_count);
         printf("Total G Migrations     : %'15llu\n", global_gmigs);
         printf("Total D Migrations     : %'15llu\n", global_dmigs);
-        printf("Ops per second       : %'18.2lf\n", ((double)global_count) / to_fseconds(end - start));
-        printf("ns per ops           : %'18.2lf\n", ((double)(end - start)) / global_count);
-        printf("Ops per threads      : %'15llu\n", global_count / nthreads);
-        printf("Ops per procs        : %'15llu\n", global_count / nprocs);
-        printf("Ops/sec/procs        : %'18.2lf\n", (((double)global_count) / nprocs) / to_fseconds(end - start));
-        printf("ns per ops/procs     : %'18.2lf\n", ((double)(end - start)) / (global_count / nprocs));
+        printf("Ops per second         : %'18.2lf\n", ((double)global_count) / to_fseconds(end - start));
+        printf("ns per ops             : %'18.2lf\n", ((double)(end - start)) / global_count);
+        printf("Ops per threads        : %'15llu\n", global_count / nthreads);
+        printf("Ops per procs          : %'15llu\n", global_count / nprocs);
+        printf("Ops/sec/procs          : %'18.2lf\n", (((double)global_count) / nprocs) / to_fseconds(end - start));
+        printf("ns per ops/procs       : %'18.2lf\n", ((double)(end - start)) / (global_count / nprocs));
         fflush(stdout);
 }