Changes in libcfa/src/concurrency/thread.cfa [5b2b42e:b798713]

File:

• libcfa/src/concurrency/thread.cfa (modified) (6 diffs)

libcfa/src/concurrency/thread.cfa

@@ -10 +10 @@
 // Created On       : Tue Jan 17 12:27:26 2017
 // Last Modified By : Peter A. Buhr
-// Last Modified On : Wed Dec  4 09:17:49 2019
-// Update Count     : 9
+// Last Modified On : Fri Mar 30 17:19:52 2018
+// Update Count     : 8
 //
 
@@ -33 +33 @@
 // Thread ctors and dtors
 void ?{}(thread_desc & this, const char * const name, cluster & cl, void * storage, size_t storageSize ) with( this ) {
-        context{ 0p, 0p };
+        context{ NULL, NULL };
         self_cor{ name, storage, storageSize };
         state = Start;
@@ -41 +41 @@
         self_mon_p = &self_mon;
         curr_cluster = &cl;
-        next = 0p;
+        link.next = 0p;
+        link.prev = 0p;
 
-        node.next = 0p;
-        node.prev = 0p;
+        node.next = NULL;
+        node.prev = NULL;
         doregister(curr_cluster, this);
 
@@ -58 +59 @@
 void ?{}( scoped(T)& this ) with( this ) {
         handle{};
-        __thrd_start(handle, main);
+        __thrd_start(handle);
 }
 
@@ -64 +65 @@
 void ?{}( scoped(T)& this, P params ) with( this ) {
         handle{ params };
-        __thrd_start(handle, main);
+        __thrd_start(handle);
 }
 
@@ -75 +76 @@
 // Starting and stopping threads
 forall( dtype T | is_thread(T) )
-void __thrd_start( T & this, void (*main_p)(T &) ) {
+void __thrd_start( T& this ) {
         thread_desc * this_thrd = get_thread(this);
+        thread_desc * curr_thrd = TL_GET( this_thread );
 
         disable_interrupts();
-        CtxStart(main_p, get_coroutine(this), this, CtxInvokeThread);
-
+        CtxStart(&this, CtxInvokeThread);
         this_thrd->context.[SP, FP] = this_thrd->self_cor.context.[SP, FP];
         verify( this_thrd->context.SP );
+        CtxSwitch( &curr_thrd->context, &this_thrd->context );
 
         ScheduleThread(this_thrd);
         enable_interrupts( __cfaabi_dbg_ctx );
+}
+
+extern "C" {
+        // KERNEL ONLY
+        void __finish_creation(thread_desc * this) {
+                // set new coroutine that the processor is executing
+                // and context switch to it
+                verify( kernelTLS.this_thread != this );
+                verify( kernelTLS.this_thread->context.SP );
+                CtxSwitch( &this->context, &kernelTLS.this_thread->context );
+        }
 }