Changes in benchmark/readyQ/transfer.cpp [6dc2db9:65c9208]

File:

• benchmark/readyQ/transfer.cpp (modified) (8 diffs)

benchmark/readyQ/transfer.cpp

@@ -12 +12 @@
 
 bool exhaust = false;
+volatile bool estop = false;
 
 bench_sem the_main;
@@ -42 +43 @@
                                 if( to_miliseconds(timeHiRes() - start) > 5'000 ) {
                                         std::cerr << "Programs has been blocked for more than 5 secs" << std::endl;
-                                        std::exit(1);
+                                        estop = true;
+                                        the_main.post();
+                                        goto END;
                                 }
                         }
                 }
+                END:;
                 PRINT( std::cout | "Waiting done"; )
         }
@@ -59 +63 @@
         void lead() {
                 this->idx = ++lead_idx;
-                if(lead_idx > stop_count) {
+                if(lead_idx > stop_count || estop) {
                         PRINT( std::cout << "Leader " << this->id << " done" << std::endl; )
                         the_main.post();
@@ -88 +92 @@
         }
 
-        static void main(void * arg) {
-                MyThread & self = *reinterpret_cast<MyThread*>(arg);
+        static void main(MyThread * arg) {
+                MyThread & self = *arg;
                 self.park();
 
@@ -101 +105 @@
                                 self.wait();
                         }
-                        if(lead_idx > stop_count) break;
+                        if(lead_idx > stop_count || estop) break;
                 }
         }
@@ -144 +148 @@
                         for(size_t i = 0; i < nthreads; i++) {
                                 threads[i] = new MyThread( i );
-                                handles[i] = new Fibre( MyThread::main, threads[i] );
+                                handles[i] = new Fibre();
+                                handles[i]->run( MyThread::main, threads[i] );
                         }
 
@@ -164 +169 @@
                                 PRINT( std::cout << i << " joined" << std::endl; )
                                 rechecks += thrd.rechecks;
-                                // delete( handles[i] );
                                 delete( threads[i] );
                         }
@@ -176 +180 @@
         std::cout << "Number of processors    : " << nprocs << std::endl;
         std::cout << "Number of threads       : " << nthreads << std::endl;
-        std::cout << "Total Operations(ops)   : " << stop_count << std::endl;
+        std::cout << "Total Operations(ops)   : " << (lead_idx - 1) << std::endl;
         std::cout << "Threads parking on wait : " << (exhaust ? "yes" : "no") << std::endl;
         std::cout << "Rechecking              : " << rechecks << std::endl;
+        std::cout << "ns per transfer         : " << std::fixed << (((double)(end - start)) / (lead_idx)) << std::endl;