Changes in src/libcfa/concurrency/thread.c [2ac095d:44264c5]

File:

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

src/libcfa/concurrency/thread.c

@@ -28 +28 @@
 }
 
-extern volatile thread_local processor * this_processor;
+extern 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;
+        thrd_c->last = this_coroutine();
+        this_processor->current_coroutine = thrd_c;
 
-        // 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( DEBUG_CTX );
 }
 
 void yield( void ) {
-        BlockInternal( (thread_desc *)this_thread );
+        ScheduleInternal( this_processor->current_thread );
 }
 
@@ -98 +95 @@
 void ThreadCtxSwitch(coroutine_desc* src, coroutine_desc* dst) {
         // set state of current coroutine to inactive
-        src->state = src->state == Halted ? Halted : Inactive;
+        src->state = Inactive;
         dst->state = Active;
 
@@ -106 +103 @@
         // set new coroutine that the processor is executing
         // and context switch to it
-        this_coroutine = dst;
-        assert( src->stack.context );
+        this_processor->current_coroutine = dst;
         CtxSwitch( src->stack.context, dst->stack.context );
-        this_coroutine = src;
+        this_processor->current_coroutine = src;
 
         // set state of new coroutine to active
-        dst->state = dst->state == Halted ? Halted : Inactive;
+        dst->state = Inactive;
         src->state = Active;
 }