Changeset 3381ed7 for libcfa/src/concurrency/kernel_private.hfa

Timestamp:

Feb 13, 2020, 4:18:07 PM (5 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

ADT, arm-eh, ast-experimental, enum, forall-pointer-decay, jacob/cs343-translation, jenkins-sandbox, master, new-ast, new-ast-unique-expr, pthread-emulation, qualifiedEnum

Children:

50b8885

Parents:

9f575ea

Message:

Added park/unpark primitives thread and removed BlockInternal?.
Converted monitors to use park unpark.
Intrusive Queue now mark next field when thread is inside queue.
Added several asserts to kernel and monitor.
Added a few tests for park and unpark.

File:

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

libcfa/src/concurrency/kernel_private.hfa

@@ -32 +32 @@
 
 void ScheduleThread( thread_desc * ) __attribute__((nonnull (1)));
-static inline void WakeThread( thread_desc * thrd, bool must_yield ) {
-        if( !thrd ) return;
-
-        enum coroutine_state new_state = must_yield ? Reschedule : Rerun;
-
-        disable_interrupts();
-        static_assert(sizeof(thrd->state) == sizeof(int));
-        enum coroutine_state old_state = (enum coroutine_state)__atomic_exchange_n((volatile int *)&thrd->state, (int)new_state, __ATOMIC_SEQ_CST);
-        switch(old_state) {
-                case Active:
-                        // Wake won the race, the thread will reschedule/rerun itself
-                        break;
-                case Inactive:
-                        // Wake lost the race,
-                        thrd->state = Inactive;
-                        ScheduleThread( thrd );
-                        break;
-                case Rerun:
-                case Reschedule:
-                        abort("More than one thread attempted to schedule thread %p\n", thrd);
-                        break;
-                case Halted:
-                case Start:
-                case Primed:
-                default:
-                        // This makes no sense, something is wrong abort
-                        abort();
-        }
-        enable_interrupts( __cfaabi_dbg_ctx );
-}
-thread_desc * nextThread(cluster * this);
 
 //Block current thread and release/wake-up the following resources
-void BlockInternal(void);
-void BlockInternal(__spinlock_t * lock);
-void BlockInternal(thread_desc * thrd);
-void BlockInternal(__spinlock_t * lock, thread_desc * thrd);
-void BlockInternal(__spinlock_t * locks [], unsigned short count);
-void BlockInternal(__spinlock_t * locks [], unsigned short count, thread_desc * thrds [], unsigned short thrd_count);
-void BlockInternal(__finish_callback_fptr_t callback);
-void LeaveThread(__spinlock_t * lock, thread_desc * thrd);
+void LeaveThread();
+
+bool force_yield( enum __Preemption_Reason );
 
 //-----------------------------------------------------------------------------