Changeset 5407cdc for benchmark/readyQ/rq_bench.hpp

Timestamp:

Apr 28, 2021, 4:56:50 PM (5 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

ADT, arm-eh, ast-experimental, enum, forall-pointer-decay, jacob/cs343-translation, master, new-ast-unique-expr, pthread-emulation, qualifiedEnum, stuck-waitfor-destruct

Children:

8d66610

Parents:

feacef9 (diff), b7fd2db6 (diff)
Note: this is a merge changeset, the changes displayed below correspond to the merge itself.
Use the (diff) links above to see all the changes relative to each parent.

Message:

Merge branch 'master' of plg.uwaterloo.ca:software/cfa/cfa-cc

File:

• benchmark/readyQ/rq_bench.hpp (modified) (6 diffs)

benchmark/readyQ/rq_bench.hpp

@@ -6 +6 @@
 #include <time.h>                                                                               // timespec
 #include <sys/time.h>                                                                   // timeval
+
+typedef __uint128_t __lehmer64_state_t;
+static inline uint64_t __lehmer64( __lehmer64_state_t & state ) {
+        state *= 0xda942042e4dd58b5;
+        return state >> 64;
+}
 
 enum { TIMEGRAN = 1000000000LL };                                       // nanosecond granularity, except for timeval
@@ -46 +52 @@
         }
 
-uint64_t getTimeNsec() {
+uint64_t timeHiRes() {
         timespec curr;
         clock_gettime( CLOCK_REALTIME, &curr );
@@ -60 +66 @@
         for(;;) {
                 Sleeper::usleep(100000);
-                uint64_t end = getTimeNsec();
+                uint64_t end = timeHiRes();
                 uint64_t delta = end - start;
                 if(is_tty) {
@@ -74 +80 @@
         }
 }
+
+class Fibre;
+int fibre_park();
+int fibre_unpark( Fibre * );
+Fibre * fibre_self();
+
+class __attribute__((aligned(128))) bench_sem {
+        Fibre * volatile ptr = nullptr;
+public:
+        inline bool wait() {
+                static Fibre * const ready  = reinterpret_cast<Fibre *>(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 *>(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;
+                                }
+                        }
+                }
+        }
+};
 
 // ==========================================================================================
@@ -188 +242 @@
                 this->help       = help;
                 this->variable   = reinterpret_cast<void*>(&variable);
-                this->parse_fun  = reinterpret_cast<bool (*)(const char *, void * )>(static_cast<bool (*)(const char *, T & )>(parse));
+                #pragma GCC diagnostic push
+                #pragma GCC diagnostic ignored "-Wcast-function-type"
+                                this->parse_fun  = reinterpret_cast<bool (*)(const char *, void * )>(static_cast<bool (*)(const char *, T & )>(parse));
+                #pragma GCC diagnostic pop
         }
 
@@ -197 +254 @@
                 this->help       = help;
                 this->variable   = reinterpret_cast<void*>(&variable);
-                this->parse_fun  = reinterpret_cast<bool (*)(const char *, void * )>(parse);
+                #pragma GCC diagnostic push
+                #pragma GCC diagnostic ignored "-Wcast-function-type"
+                        this->parse_fun  = reinterpret_cast<bool (*)(const char *, void * )>(parse);
+                #pragma GCC diagnostic pop
         }
 };