Changes in src/libcfa/concurrency/preemption.c [de6319f:8ad6533]

File:

• src/libcfa/concurrency/preemption.c (modified) (3 diffs)

src/libcfa/concurrency/preemption.c

@@ -149 +149 @@
         // Disable interrupts by incrementing the counter
         void disable_interrupts() {
-                with( TL_GET( preemption_state ) ) {
-                        enabled = false;
-                        __attribute__((unused)) unsigned short new_val = disable_count + 1;
-                        disable_count = new_val;
-                        verify( new_val < 65_000u );              // If this triggers someone is disabling interrupts without enabling them
-                }
+                TL_GET( preemption_state ).enabled = false;
+                __attribute__((unused)) unsigned short new_val = TL_GET( preemption_state ).disable_count + 1;
+                TL_GET( preemption_state ).disable_count = new_val;
+                verify( new_val < 65_000u );              // If this triggers someone is disabling interrupts without enabling them
         }
 
@@ -163 +161 @@
                 thread_desc * thrd = TL_GET( this_thread );       // Cache the thread now since interrupts can start happening after the atomic add
 
-                with( TL_GET( preemption_state ) ){
-                        unsigned short prev = disable_count;
-                        disable_count -= 1;
-                        verify( prev != 0u );                     // If this triggers someone is enabled already enabled interruptsverify( prev != 0u );
-
-                        // Check if we need to prempt the thread because an interrupt was missed
-                        if( prev == 1 ) {
-                                enabled = true;
-                                if( proc->pending_preemption ) {
-                                        proc->pending_preemption = false;
-                                        BlockInternal( thrd );
-                                }
+                unsigned short prev = TL_GET( preemption_state ).disable_count;
+                TL_GET( preemption_state ).disable_count -= 1;
+                verify( prev != 0u );                     // If this triggers someone is enabled already enabled interruptsverify( prev != 0u );
+
+                // Check if we need to prempt the thread because an interrupt was missed
+                if( prev == 1 ) {
+                        TL_GET( preemption_state ).enabled = true;
+                        if( proc->pending_preemption ) {
+                                proc->pending_preemption = false;
+                                BlockInternal( thrd );
                         }
                 }
@@ -332 +328 @@
         if( !preemption_ready() ) { return; }
 
-        __cfaabi_dbg_print_buffer_decl( " KERNEL: preempting core %p (%p).\n", TL_GET( this_processor ), TL_GET( this_thread ) );
+        __cfaabi_dbg_print_buffer_decl( " KERNEL: preempting core %p (%p).\n", this_processor, this_thread);
 
         TL_GET( preemption_state ).in_progress = true;  // Sync flag : prevent recursive calls to the signal handler