Changes in benchmark/readyQ/locality.cpp [56ac392:f03209d3]

File:

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

benchmark/readyQ/locality.cpp

@@ -9 +9 @@
         uint64_t dmigs = 0;
         uint64_t gmigs = 0;
+};
+
+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;
+                                }
+                        }
+                }
+        }
 };
 
@@ -244 +287 @@
 
                         bool is_tty = isatty(STDOUT_FILENO);
-                        start = timeHiRes();
+                        start = getTimeNsec();
 
                         for(size_t i = 0; i < nthreads; i++) {
@@ -252 +295 @@
 
                         stop = true;
-                        end = timeHiRes();
+                        end = getTimeNsec();
                         printf("\nDone\n");