Changes in benchmark/readyQ/cycle.cpp [56ac392:c4241b6]

File:

• benchmark/readyQ/cycle.cpp (modified) (3 diffs)

benchmark/readyQ/cycle.cpp

@@ -3 +3 @@
 #include <libfibre/fibre.h>
 
+class __attribute__((aligned(128))) bench_sem {
+        Fibre * volatile ptr = nullptr;
+public:
+        inline bool wait() {
+                static Fibre * const ready  = reinterpret_cast<Fibre * const>(1ull);
+                for(;;) {
+                        Fibre * expected = this->ptr;
+                        if(expected == ready) {
+                                if(__atomic_compare_exchange_n(&this->ptr, &expected, nullptr, false, __ATOMIC_SEQ_CST, __ATOMIC_SEQ_CST)) {
+                                        return false;
+                                }
+                        }
+                        else {
+                                /* paranoid */ assert( expected == nullptr );
+                                if(__atomic_compare_exchange_n(&this->ptr, &expected, fibre_self(), false, __ATOMIC_SEQ_CST, __ATOMIC_SEQ_CST)) {
+                                        fibre_park();
+                                        return true;
+                                }
+                        }
+
+                }
+        }
+
+        inline bool post() {
+                static Fibre * const ready  = reinterpret_cast<Fibre * const>(1ull);
+                for(;;) {
+                        Fibre * expected = this->ptr;
+                        if(expected == ready) return false;
+                        if(expected == nullptr) {
+                                if(__atomic_compare_exchange_n(&this->ptr, &expected, ready, false, __ATOMIC_SEQ_CST, __ATOMIC_SEQ_CST)) {
+                                        return false;
+                                }
+                        }
+                        else {
+                                if(__atomic_compare_exchange_n(&this->ptr, &expected, nullptr, false, __ATOMIC_SEQ_CST, __ATOMIC_SEQ_CST)) {
+                                        fibre_unpark( expected );
+                                        return true;
+                                }
+                        }
+                }
+        }
+};
 struct Partner {
         unsigned long long count  = 0;
@@ -51 +93 @@
 
                         bool is_tty = isatty(STDOUT_FILENO);
-                        start = timeHiRes();
+                        start = getTimeNsec();
 
                         for(int i = 0; i < nthreads; i++) {
@@ -59 +101 @@
 
                         stop = true;
-                        end = timeHiRes();
+                        end = getTimeNsec();
                         printf("\nDone\n");