Changes in benchmark/readyQ/transfer.cfa [65c9208:adfd125]

File:

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

benchmark/readyQ/transfer.cfa

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