Changes in benchmark/readyQ/locality.cfa [3f8baf4:06573b2]

File:

• benchmark/readyQ/locality.cfa (modified) (5 diffs)

benchmark/readyQ/locality.cfa

@@ -63 +63 @@
 }
 
-void access(MyData & this, size_t idx) {
+__attribute__((noinline)) void access(MyData & this, size_t idx) {
         size_t l = this.len;
         this.data[idx % l] += 1;
@@ -126 +126 @@
 // ==================================================
 // Do some work by accessing 'cnt' cells in the array
-void work(MyData & data, size_t cnt, uint64_t & state) {
+__attribute__((noinline)) void work(MyData & data, size_t cnt, uint64_t & state) {
         for (cnt) {
                 access(data, __xorshift64(state));
@@ -166 +166 @@
 
 void ?{}( MyThread & this, MyData * data, MySpot ** spots, size_t spot_len, size_t cnt, bool share, size_t id) {
+        ((thread&)this){ bench_cluster };
         this.data = data;
         this.spots.ptr = spots;
@@ -196 +197 @@
         unsigned long long global_dmigs = 0;
 
-        MyData * data_arrays[nthreads];
-        for(i; nthreads) {
-                data_arrays[i] = malloc();
-                (*data_arrays[i]){ i, wsize };
-        }
-
-        MySpot * spots[nthreads - nprocs];
-        for(i; nthreads - nprocs) {
-                spots[i] = malloc();
-                (*spots[i]){ i };
-        }
-
         Time start, end;
         {
+                MyData * data_arrays[nthreads];
+                for(i; nthreads) {
+                        data_arrays[i] = malloc();
+                        (*data_arrays[i]){ i, wsize };
+                }
+
+                MySpot * spots[nthreads - nprocs];
+                for(i; nthreads - nprocs) {
+                        spots[i] = malloc();
+                        (*spots[i]){ i };
+                }
+
                 BenchCluster bc = { nprocs };
                 threads_left = nprocs;
@@ -250 +251 @@
                         }
                 }
-        }
-
-        printf("Duration (ms)          : %'ld\n", (end - start)`dms);
+
+                for(i; nthreads) {
+                        delete( data_arrays[i] );
+                }
+
+                for(i; nthreads - nprocs) {
+                        delete( spots[i] );
+                }
+        }
+
+        printf("Duration (ms)          : %'lf\n", (end - start)`dms);
         printf("Number of processors   : %'d\n", nprocs);
         printf("Number of threads      : %'d\n", nthreads);
         printf("Total Operations(ops)  : %'15llu\n", global_count);
-        printf("Work size (64bit words): %'15llu\n", wsize);
+        printf("Work size (64bit words): %'15u\n", wsize);
         printf("Total Operations(ops)  : %'15llu\n", global_count);
         printf("Total G Migrations     : %'15llu\n", global_gmigs);