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

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