Changeset 65c9208 for benchmark/readyQ/transfer.cfa

Timestamp:

May 10, 2022, 12:28:54 PM (2 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

ADT, ast-experimental, master, pthread-emulation, qualifiedEnum

Children:

e07187d

Parents:

3613e25

Message:

Changed transfer benchmark to be more consistent with other rmit benchmarks

File:

• benchmark/readyQ/transfer.cfa (modified) (6 diffs)

benchmark/readyQ/transfer.cfa

@@ -14 +14 @@
 
 bool exhaust = false;
+volatile bool estop = false;
+
 
 thread$ * the_main;
@@ -35 +37 @@
 static void waitgroup() {
         Time start = timeHiRes();
-        for(i; nthreads) {
+        OUTER: for(i; nthreads) {
                 PRINT( sout | "Waiting for :" | i | "(" | threads[i]->idx | ")"; )
                 while( threads[i]->idx != lead_idx ) {
@@ -42 +44 @@
                                 print_stats_now( bench_cluster, CFA_STATS_READY_Q | CFA_STATS_IO );
                                 serr | "Programs has been blocked for more than 5 secs";
-                                exit(1);
+                                estop = true;
+                                unpark( the_main );
+                                break OUTER;
                         }
                 }
@@ -59 +63 @@
 static void lead(MyThread & this) {
         this.idx = ++lead_idx;
-        if(lead_idx > stop_count) {
+        if(lead_idx > stop_count || estop) {
                 PRINT( sout | "Leader" | this.id | "done"; )
                 unpark( the_main );
@@ -100 +104 @@
                         wait( this );
                 }
-                if(lead_idx > stop_count) break;
+                if(lead_idx > stop_count || estop) break;
         }
 }
@@ -172 +176 @@
         sout | "Number of processors    : " | nprocs;
         sout | "Number of threads       : " | nthreads;
-        sout | "Total Operations(ops)   : " | stop_count;
+        sout | "Total Operations(ops)   : " | lead_idx - 1;
         sout | "Threads parking on wait : " | (exhaust ? "yes" : "no");
         sout | "Rechecking              : " | rechecks;
+        sout | "ns per transfer         : " | (end - start)`dms / lead_idx;