Changes in src/libcfa/concurrency/kernel.c [82c948c:d0a045c7]

File:

• src/libcfa/concurrency/kernel.c (modified) (11 diffs)

src/libcfa/concurrency/kernel.c

@@ -108 +108 @@
 void ?{}( thread_desc & this, current_stack_info_t * info) with( this ) {
         self_cor{ info };
-        curr_cor = &self_cor;
-        self_mon.owner = &this;
-        self_mon.recursion = 1;
-        self_mon_p = &self_mon;
-        next = NULL;
-        __cfaabi_dbg_debug_do(
-                dbg_next = NULL;
-                dbg_prev = NULL;
-                __cfaabi_dbg_thread_register(&this);
-        )
-
-        monitors{ &self_mon_p, 1, (fptr_t)0 };
 }
 
@@ -237 +225 @@
 // from the processor coroutine to the target thread
 void runThread(processor * this, thread_desc * dst) {
-        assert(dst->curr_cor);
         coroutine_desc * proc_cor = get_coroutine(*this->runner);
-        coroutine_desc * thrd_cor = dst->curr_cor;
+        coroutine_desc * thrd_cor = get_coroutine(dst);
 
         //Reset the terminating actions here
@@ -250 +237 @@
         ThreadCtxSwitch(proc_cor, thrd_cor);
         // when ThreadCtxSwitch returns we are back in the processor coroutine
-}
-
-void returnToKernel() {
-        coroutine_desc * proc_cor = get_coroutine(*this_processor->runner);
-        coroutine_desc * thrd_cor = this_thread->curr_cor = this_coroutine;
-        ThreadCtxSwitch(thrd_cor, proc_cor);
 }
 
@@ -379 +360 @@
         disable_interrupts();
         verify( !preemption_enabled );
-        returnToKernel();
+        suspend();
         verify( !preemption_enabled );
         enable_interrupts( __cfaabi_dbg_ctx );
@@ -390 +371 @@
 
         verify( !preemption_enabled );
-        returnToKernel();
+        suspend();
         verify( !preemption_enabled );
 
@@ -402 +383 @@
 
         verify( !preemption_enabled );
-        returnToKernel();
+        suspend();
         verify( !preemption_enabled );
 
@@ -416 +397 @@
 
         verify( !preemption_enabled );
-        returnToKernel();
+        suspend();
         verify( !preemption_enabled );
 
@@ -429 +410 @@
 
         verify( !preemption_enabled );
-        returnToKernel();
+        suspend();
         verify( !preemption_enabled );
 
@@ -444 +425 @@
 
         verify( !preemption_enabled );
-        returnToKernel();
+        suspend();
         verify( !preemption_enabled );
 
@@ -456 +437 @@
         this_processor->finish.thrd        = thrd;
 
-        returnToKernel();
+        suspend();
 }
 
@@ -521 +502 @@
         // which is currently here
         mainProcessor->do_terminate = true;
-        returnToKernel();
+        suspend();
 
         // THE SYSTEM IS NOW COMPLETELY STOPPED