Changes in benchmark/readyQ/rq_bench.hfa [0b84b15:2c7eee0]

File:

• benchmark/readyQ/rq_bench.hfa (modified) (2 diffs)

benchmark/readyQ/rq_bench.hfa

@@ -66 +66 @@
 
 void ^?{}( BenchCluster & this ) {
-        adelete( this.nprocs, this.procs );
+        adelete( this.procs );
         ^(this.cl){};
 }
@@ -87 +87 @@
         }
 }
+
+struct bench_sem {
+        struct $thread * volatile ptr;
+};
+
+static inline {
+        void  ?{}(bench_sem & this) {
+                this.ptr = 0p;
+        }
+
+        void ^?{}(bench_sem & this) {}
+
+        bool wait(bench_sem & this) {
+                for() {
+                        struct $thread * expected = this.ptr;
+                        if(expected == 1p) {
+                                if(__atomic_compare_exchange_n(&this.ptr, &expected, 0p, false, __ATOMIC_SEQ_CST, __ATOMIC_SEQ_CST)) {
+                                        return false;
+                                }
+                        }
+                        else {
+                                /* paranoid */ verify( expected == 0p );
+                                if(__atomic_compare_exchange_n(&this.ptr, &expected, active_thread(), false, __ATOMIC_SEQ_CST, __ATOMIC_SEQ_CST)) {
+                                        park();
+                                        return true;
+                                }
+                        }
+
+                }
+        }
+
+        bool post(bench_sem & this) {
+                for() {
+                        struct $thread * expected = this.ptr;
+                        if(expected == 1p) return false;
+                        if(expected == 0p) {
+                                if(__atomic_compare_exchange_n(&this.ptr, &expected, 1p, false, __ATOMIC_SEQ_CST, __ATOMIC_SEQ_CST)) {
+                                        return false;
+                                }
+                        }
+                        else {
+                                if(__atomic_compare_exchange_n(&this.ptr, &expected, 0p, false, __ATOMIC_SEQ_CST, __ATOMIC_SEQ_CST)) {
+                                        unpark( expected );
+                                        return true;
+                                }
+                        }
+                }
+        }
+}