Changeset c81ebf9 for src/libcfa/concurrency/kernel_private.h

Timestamp:

Jun 6, 2017, 11:45:13 AM (7 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, resolv-new, with_gc

Children:

c5ac6d5

Parents:

7b13aeb

Message:

More work done on preemption in cforall, next step disabling interrupts at the correct places

File:

• src/libcfa/concurrency/kernel_private.h (modified) (1 diff)

src/libcfa/concurrency/kernel_private.h

@@ -52 +52 @@
         alarm_list_t alarms;
         spinlock alarm_lock;
+
+        bool pending_alarm;
 };
 
 extern cluster * systemCluster;
 extern system_proc_t * systemProcessor;
+extern thread_local processor * this_processor;
+
+static inline void disable_interrupts() {
+        __attribute__((unused)) unsigned short prev = __atomic_fetch_add_2( &this_processor->disable_preempt_count, 1, __ATOMIC_SEQ_CST );
+        assert( prev != (unsigned short) -1 );
+}
+
+static inline void enable_interrupts_noRF() {
+        unsigned short prev = __atomic_fetch_add_2( &this_processor->disable_preempt_count, -1, __ATOMIC_SEQ_CST );
+        assert( prev != (unsigned short) 0 );
+}
+
+static inline void enable_interrupts() {
+        unsigned short prev = __atomic_fetch_add_2( &this_processor->disable_preempt_count, -1, __ATOMIC_SEQ_CST );
+        assert( prev != (unsigned short) 0 );
+        if( prev == 1 && this_processor->pending_preemption ) {
+                ScheduleInternal( this_processor->current_thread );
+                this_processor->pending_preemption = false;
+        }
+}
 
 //-----------------------------------------------------------------------------