Changeset de6319f for src/libcfa/concurrency/preemption.c

Timestamp:

Apr 26, 2018, 5:23:15 PM (6 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

ADT, aaron-thesis, arm-eh, ast-experimental, cleanup-dtors, deferred_resn, demangler, enum, forall-pointer-decay, jacob/cs343-translation, jenkins-sandbox, master, new-ast, new-ast-unique-expr, new-env, no_list, persistent-indexer, pthread-emulation, qualifiedEnum, with_gc

Children:

b9f383f

Parents:

22bdc34

Message:

Implemented clusters and added many constructors for threads/coroutines/processors

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() {
-                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
+                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
+                }
         }
 
@@ -161 +163 @@
                 thread_desc * thrd = TL_GET( this_thread );       // Cache the thread now since interrupts can start happening after the atomic add
 
-                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 );
+                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 );
+                                }
                         }
                 }
@@ -328 +332 @@
         if( !preemption_ready() ) { return; }
 
-        __cfaabi_dbg_print_buffer_decl( " KERNEL: preempting core %p (%p).\n", this_processor, this_thread);
+        __cfaabi_dbg_print_buffer_decl( " KERNEL: preempting core %p (%p).\n", TL_GET( this_processor ), TL_GET( this_thread ) );
 
         TL_GET( preemption_state ).in_progress = true;  // Sync flag : prevent recursive calls to the signal handler