Changeset fe97de26 for benchmark/readyQ/locality.go

Timestamp:

Dec 22, 2020, 9:16:13 AM (3 years ago)

Author:

caparsons <caparson@…>

Branches:

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

Children:

797a193

Parents:

0285efe (diff), 3f8baf4 (diff)
Note: this is a merge changeset, the changes displayed below correspond to the merge itself.
Use the (diff) links above to see all the changes relative to each parent.

Message:

Merge branch 'master' of plg.uwaterloo.ca:software/cfa/cfa-cc

File:

• benchmark/readyQ/locality.go (modified) (9 diffs)

benchmark/readyQ/locality.go

@@ -18 +18 @@
 // ==================================================
 type MyData struct {
+        _p1 [16]uint64 // padding
         ttid int
         id int
         data [] uint64
+        _p2 [16]uint64 // padding
 }
 
@@ -29 +31 @@
                 data[i] = 0
         }
-        return &MyData{syscall.Gettid(), id, data}
+        return &MyData{[16]uint64{0}, syscall.Gettid(), id, data,[16]uint64{0}}
 }
 
@@ -46 +48 @@
 // ==================================================
 type MyCtx struct {
+        _p1 [16]uint64 // padding
         s * semaphore.Weighted
         d unsafe.Pointer
@@ -51 +54 @@
         ttid int
         id int
+        _p2 [16]uint64 // padding
 }
 
 func NewCtx( data * MyData, id int ) (MyCtx) {
-        r := MyCtx{semaphore.NewWeighted(1), unsafe.Pointer(data), context.Background(), syscall.Gettid(), id}
+        r := MyCtx{[16]uint64{0},semaphore.NewWeighted(1), unsafe.Pointer(data), context.Background(), syscall.Gettid(), id,[16]uint64{0}}
         r.s.Acquire(context.Background(), 1)
         return r
@@ -71 +75 @@
 // May exchanges data
 type Spot struct {
+        _p1 [16]uint64 // padding
         ptr uintptr // atomic variable use fo MES
         id int      // id for debugging
+        _p2 [16]uint64 // padding
 }
 
@@ -215 +221 @@
 func main() {
         // Benchmark specific command line arguments
-        work_sizeOpt := flag.Uint64("w", 2    , "Number of words (uint64) per threads")
-        countOpt     := flag.Uint64("c", 2    , "Number of words (uint64) to touch")
+        work_sizeOpt := flag.Uint64("w", 2    , "Size of the array for each threads, in words (64bit)")
+        countOpt     := flag.Uint64("c", 2    , "Number of words to touch when working (random pick, cells can be picked more than once)")
         shareOpt     := flag.Bool  ("s", false, "Pass the work data to the next thread when blocking")
 
@@ -239 +245 @@
         channels := make([]Spot, nthreads - nprocs) // Number of spots
         for i := range channels {
-                channels[i] = Spot{uintptr(0), i}     // init spots
+                channels[i] = Spot{[16]uint64{0},uintptr(0), i,[16]uint64{0}}     // init spots
         }
 
@@ -266 +272 @@
 
         // Join and accumulate results
-        global_result := NewResult()
+        results := NewResult()
         for i := 0; i < nthreads; i++ {
                 r := <- result
-                global_result.count += r.count
-                global_result.gmigs += r.gmigs
-                global_result.dmigs += r.dmigs
+                results.count += r.count
+                results.gmigs += r.gmigs
+                results.dmigs += r.dmigs
         }
 
@@ -280 +286 @@
         p.Printf("Number of threads      : %d\n", nthreads);
         p.Printf("Work size (64bit words): %d\n", size);
-        p.Printf("Total Operations(ops)  : %15d\n", global_result.count)
-        p.Printf("Total G Migrations     : %15d\n", global_result.gmigs)
-        p.Printf("Total D Migrations     : %15d\n", global_result.dmigs)
-        p.Printf("Ops per second         : %18.2f\n", float64(global_result.count) / delta.Seconds())
-        p.Printf("ns per ops             : %18.2f\n", float64(delta.Nanoseconds()) / float64(global_result.count))
-        p.Printf("Ops per threads        : %15d\n", global_result.count / uint64(nthreads))
-        p.Printf("Ops per procs          : %15d\n", global_result.count / uint64(nprocs))
-        p.Printf("Ops/sec/procs          : %18.2f\n", (float64(global_result.count) / float64(nprocs)) / delta.Seconds())
-        p.Printf("ns per ops/procs       : %18.2f\n", float64(delta.Nanoseconds()) / (float64(global_result.count) / float64(nprocs)))
-}
+        p.Printf("Total Operations(ops)  : %15d\n", results.count)
+        p.Printf("Total G Migrations     : %15d\n", results.gmigs)
+        p.Printf("Total D Migrations     : %15d\n", results.dmigs)
+        p.Printf("Ops per second         : %18.2f\n", float64(results.count) / delta.Seconds())
+        p.Printf("ns per ops             : %18.2f\n", float64(delta.Nanoseconds()) / float64(results.count))
+        p.Printf("Ops per threads        : %15d\n", results.count / uint64(nthreads))
+        p.Printf("Ops per procs          : %15d\n", results.count / uint64(nprocs))
+        p.Printf("Ops/sec/procs          : %18.2f\n", (float64(results.count) / float64(nprocs)) / delta.Seconds())
+        p.Printf("ns per ops/procs       : %18.2f\n", float64(delta.Nanoseconds()) / (float64(results.count) / float64(nprocs)))
+}