Changeset a5e7233 for libcfa/src/concurrency/kernel

Timestamp:

Mar 17, 2021, 1:56:12 PM (3 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

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

Children:

c407434e

Parents:

e0c072c

Message:

C interface now runs worker init routine in dedicated thread.
Also added test for this case.

File:

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

libcfa/src/concurrency/kernel/startup.cfa

@@ -73 +73 @@
 static void __kernel_first_resume( processor * this );
 static void __kernel_last_resume ( processor * this );
-static void init(processor & this, const char name[], cluster & _cltr, void (*fnc) (void *), void * arg);
+static void init(processor & this, const char name[], cluster & _cltr, $thread * initT);
 static void deinit(processor & this);
 static void doregister( struct cluster & cltr );
@@ -198 +198 @@
                 ( this.terminated ){};
                 ( this.runner ){};
-                init( this, "Main Processor", *mainCluster, 0p, 0p );
+                init( this, "Main Processor", *mainCluster, 0p );
                 kernel_thread = pthread_self();
 
@@ -452 +452 @@
 }
 
-static void init(processor & this, const char name[], cluster & _cltr, void (*fnc) (void *), void * arg) with( this ) {
+static void init(processor & this, const char name[], cluster & _cltr, $thread * initT) with( this ) {
         this.name = name;
         this.cltr = &_cltr;
@@ -464 +464 @@
         this.io.dirty   = false;
 
-        this.init.fnc = fnc;
-        this.init.arg = arg;
+        this.init.thrd = initT;
 
         this.idle = eventfd(0, 0);
@@ -516 +515 @@
 }
 
-void ?{}(processor & this, const char name[], cluster & _cltr, void (*fnc) (void *), void * arg) {
+void ?{}(processor & this, const char name[], cluster & _cltr, $thread * initT) {
         ( this.terminated ){};
         ( this.runner ){};
 
         disable_interrupts();
-                init( this, name, _cltr, fnc, arg );
+                init( this, name, _cltr, initT );
         enable_interrupts( __cfaabi_dbg_ctx );
 
@@ -527 +526 @@
 
         this.stack = __create_pthread( &this.kernel_thread, __invoke_processor, (void *)&this );
-
+}
+
+void ?{}(processor & this, const char name[], cluster & _cltr) {
+        (this){name, _cltr, 0p};
 }