Changes in src/tests/concurrent/preempt.c [b2fe1c9:b68fc85]

File:

• src/tests/concurrent/preempt.c (modified) (3 diffs)

src/tests/concurrent/preempt.c

@@ -1 +1 @@
 #include <kernel>
 #include <thread>
+#include <time>
 
 #ifndef PREEMPTION_RATE
-#define PREEMPTION_RATE 10_000ul
+#define PREEMPTION_RATE 10`ms
 #endif
 
-unsigned int default_preemption() {
+Duration default_preemption() {
         return PREEMPTION_RATE;
 }
@@ -15 +16 @@
 static const unsigned long N = 500ul;
 #endif
+
+extern void __cfaabi_check_preemption();
 
 static volatile int counter = 0;
@@ -28 +31 @@
 void main(worker_t & this) {
         while(counter < N) {
+                __cfaabi_check_preemption();
                 if( (counter % 7) == this.value ) {
+                        __cfaabi_check_preemption();
                         int next = __atomic_add_fetch_4(&counter, 1, __ATOMIC_SEQ_CST);
+                        __cfaabi_check_preemption();
                         if( (next % 100) == 0 ) printf("%d\n", (int)next);
+                        __cfaabi_check_preemption();
                 }
+                __cfaabi_check_preemption();
         }
 }