Changeset 9b1dcc2 for libcfa/src/concurrency/preemption.cfa

Timestamp:

Jun 12, 2020, 1:49:17 PM (4 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

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

Children:

cb196f2

Parents:

b388ee81

Message:

Changed scheduling API to adapt to non-Processors scheduling threads.

File:

• libcfa/src/concurrency/preemption.cfa (modified) (7 diffs)

libcfa/src/concurrency/preemption.cfa

@@ -39 +39 @@
 // FwdDeclarations : timeout handlers
 static void preempt( processor   * this );
-static void timeout( $thread * this );
+static void timeout( struct __processor_id_t * id, $thread * this );
 
 // FwdDeclarations : Signal handlers
@@ -90 +90 @@
 
 // Tick one frame of the Discrete Event Simulation for alarms
-static void tick_preemption() {
+static void tick_preemption( struct __processor_id_t * id ) {
         alarm_node_t * node = 0p;                                                       // Used in the while loop but cannot be declared in the while condition
         alarm_list_t * alarms = &event_kernel->alarms;          // Local copy for ease of reading
@@ -108 +108 @@
                 }
                 else {
-                        timeout( node->thrd );
+                        timeout( id, node->thrd );
                 }
 
@@ -268 +268 @@
 
 // reserved for future use
-static void timeout( $thread * this ) {
-        __unpark( this __cfaabi_dbg_ctx2 );
+static void timeout( struct __processor_id_t * id, $thread * this ) {
+        __unpark( id, this __cfaabi_dbg_ctx2 );
 }
 
@@ -405 +405 @@
 // Waits on SIGALRM and send SIGUSR1 to whom ever needs it
 static void * alarm_loop( __attribute__((unused)) void * args ) {
+        __processor_id_t id;
+        id.id = doregister(&id);
+
         // Block sigalrms to control when they arrive
         sigset_t mask;
@@ -449 +452 @@
                         // __cfaabi_dbg_print_safe( "Kernel : Preemption thread tick\n" );
                         lock( event_kernel->lock __cfaabi_dbg_ctx2 );
-                        tick_preemption();
+                        tick_preemption( &id );
                         unlock( event_kernel->lock );
                         break;
@@ -462 +465 @@
 EXIT:
         __cfaabi_dbg_print_safe( "Kernel : Preemption thread stopping\n" );
+        unregister(&id);
         return 0p;
 }