Changes in src/libcfa/concurrency/thread.c [44264c5:1c273d0]

File:

• src/libcfa/concurrency/thread.c (modified) (4 diffs)

src/libcfa/concurrency/thread.c

@@ -28 +28 @@
 }
 
-extern thread_local processor * this_processor;
+extern volatile thread_local processor * this_processor;
 
 //-----------------------------------------------------------------------------
@@ -71 +71 @@
         coroutine_desc* thrd_c = get_coroutine(this);
         thread_desc*  thrd_h = get_thread   (this);
-        thrd_c->last = this_coroutine();
-        this_processor->current_coroutine = thrd_c;
+        thrd_c->last = this_coroutine;
 
-        LIB_DEBUG_PRINT_SAFE("Thread start : %p (t %p, c %p)\n", this, thrd_c, thrd_h);
+        // LIB_DEBUG_PRINT_SAFE("Thread start : %p (t %p, c %p)\n", this, thrd_c, thrd_h);
 
+        disable_interrupts();
         create_stack(&thrd_c->stack, thrd_c->stack.size);
+        this_coroutine = thrd_c;
         CtxStart(this, CtxInvokeThread);
+        assert( thrd_c->last->stack.context );
         CtxSwitch( thrd_c->last->stack.context, thrd_c->stack.context );
 
         ScheduleThread(thrd_h);
+        enable_interrupts( __PRETTY_FUNCTION__ );
 }
 
 void yield( void ) {
-        ScheduleInternal( this_processor->current_thread );
+        BlockInternal( (thread_desc *)this_thread );
 }
 
@@ -95 +98 @@
 void ThreadCtxSwitch(coroutine_desc* src, coroutine_desc* dst) {
         // set state of current coroutine to inactive
-        src->state = Inactive;
+        src->state = src->state == Halted ? Halted : Inactive;
         dst->state = Active;
 
@@ -103 +106 @@
         // set new coroutine that the processor is executing
         // and context switch to it
-        this_processor->current_coroutine = dst;
+        this_coroutine = dst;
+        assert( src->stack.context );
         CtxSwitch( src->stack.context, dst->stack.context );
-        this_processor->current_coroutine = src;
+        this_coroutine = src;
 
         // set state of new coroutine to active
-        dst->state = Inactive;
+        dst->state = dst->state == Halted ? Halted : Inactive;
         src->state = Active;
 }