Changes in libcfa/src/concurrency/ready_queue.cfa [1eb239e4:62502cc4]

File:

• libcfa/src/concurrency/ready_queue.cfa (modified) (6 diffs)

libcfa/src/concurrency/ready_queue.cfa

@@ -150 +150 @@
 //  queues or removing them.
 uint_fast32_t ready_mutate_lock( void ) with(*__scheduler_lock) {
+        /* paranoid */ verify( ! kernelTLS.preemption_state.enabled );
+
         // Step 1 : lock global lock
         // It is needed to avoid processors that register mid Critical-Section
@@ -164 +166 @@
         }
 
+        /* paranoid */ verify( ! kernelTLS.preemption_state.enabled );
         return s;
 }
 
 void ready_mutate_unlock( uint_fast32_t last_s ) with(*__scheduler_lock) {
+        /* paranoid */ verify( ! kernelTLS.preemption_state.enabled );
+
         // Step 1 : release local locks
         // This must be done while the global lock is held to avoid
@@ -182 +187 @@
         /*paranoid*/ assert(true == lock);
         __atomic_store_n(&lock, (bool)false, __ATOMIC_RELEASE);
+
+        /* paranoid */ verify( ! kernelTLS.preemption_state.enabled );
 }
 
@@ -419 +426 @@
         // Actually pop the list
         struct $thread * thrd;
-        bool emptied;
-        [thrd, emptied] = pop(lane);
+        thrd = pop(lane);
 
         /* paranoid */ verify(thrd);
@@ -457 +463 @@
                         if(head(lane)->link.next == thrd) {
                                 $thread * pthrd;
-                                bool emptied;
-                                [pthrd, emptied] = pop(lane);
+                                pthrd = pop(lane);
 
                                 /* paranoid */ verify( pthrd == thrd );
@@ -608 +613 @@
                         while(!is_empty(lanes.data[idx])) {
                                 struct $thread * thrd;
-                                __attribute__((unused)) bool _;
-                                [thrd, _] = pop(lanes.data[idx]);
+                                thrd = pop(lanes.data[idx]);
 
                                 push(cltr, thrd);