Changeset e60e0dc for src/libcfa/concurrency/kernel.c

Timestamp:

Jul 17, 2017, 3:54:02 PM (7 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

ADT, aaron-thesis, arm-eh, ast-experimental, cleanup-dtors, deferred_resn, demangler, enum, forall-pointer-decay, jacob/cs343-translation, jenkins-sandbox, master, new-ast, new-ast-unique-expr, new-env, no_list, persistent-indexer, pthread-emulation, qualifiedEnum, resolv-new, with_gc

Children:

5bd0aad

Parents:

b706db1

Message:

Some cleanu[ in the kernel, notably phasing out the system processor

File:

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

src/libcfa/concurrency/kernel.c

@@ -47 +47 @@
 KERNEL_STORAGE(cluster, systemCluster);
 KERNEL_STORAGE(system_proc_t, systemProcessor);
+KERNEL_STORAGE(event_kernel_t, event_kernel);
 KERNEL_STORAGE(thread_desc, mainThread);
 KERNEL_STORAGE(machine_context_t, mainThreadCtx);
@@ -52 +53 @@
 cluster * systemCluster;
 system_proc_t * systemProcessor;
+event_kernel_t * event_kernel;
 thread_desc * mainThread;
 
@@ -131 +133 @@
         this->cltr = cltr;
         (&this->terminated){ 0 };
-        this->is_terminated = false;
+        this->do_terminate = false;
         this->preemption_alarm = NULL;
-        this->preemption = default_preemption();
         this->pending_preemption = false;
 
@@ -142 +143 @@
         this->cltr = cltr;
         (&this->terminated){ 0 };
-        this->is_terminated = false;
+        this->do_terminate = false;
         this->preemption_alarm = NULL;
-        this->preemption = default_preemption();
         this->pending_preemption = false;
         this->kernel_thread = pthread_self();
@@ -156 +156 @@
 
 void ?{}(system_proc_t * this, cluster * cltr, processorCtx_t * runner) {
+        (&this->proc){ cltr, runner };
+}
+
+void ?{}(event_kernel_t * this) {
         (&this->alarms){};
-        (&this->alarm_lock){};
-        this->pending_alarm = false;
-
-        (&this->proc){ cltr, runner };
+        (&this->lock){};
 
         verify( validate( &this->alarms ) );
@@ -166 +167 @@
 
 void ^?{}(processor * this) {
-        if( ! this->is_terminated ) {
+        if( ! this->do_terminate ) {
                 LIB_DEBUG_PRINT_SAFE("Kernel : core %p signaling termination\n", this);
-                this->is_terminated = true;
+                this->do_terminate = true;
                 P( &this->terminated );
                 pthread_join( this->kernel_thread, NULL );
@@ -176 +177 @@
 void ?{}(cluster * this) {
         ( &this->ready_queue ){};
-        ( &this->lock ){};
+        ( &this->ready_queue_lock ){};
+
+        this->preemption = default_preemption();
 }
 
@@ -199 +202 @@
 
                 thread_desc * readyThread = NULL;
-                for( unsigned int spin_count = 0; ! this->is_terminated; spin_count++ )
+                for( unsigned int spin_count = 0; ! this->do_terminate; spin_count++ )
                 {
                         readyThread = nextThread( this->cltr );
@@ -343 +346 @@
         verifyf( thrd->next == NULL, "Expected null got %p", thrd->next );
 
-        lock( &systemProcessor->proc.cltr->lock DEBUG_CTX2 );
+        lock( &systemProcessor->proc.cltr->ready_queue_lock DEBUG_CTX2 );
         append( &systemProcessor->proc.cltr->ready_queue, thrd );
-        unlock( &systemProcessor->proc.cltr->lock );
+        unlock( &systemProcessor->proc.cltr->ready_queue_lock );
 
         verify( disable_preempt_count > 0 );
@@ -352 +355 @@
 thread_desc * nextThread(cluster * this) {
         verify( disable_preempt_count > 0 );
-        lock( &this->lock DEBUG_CTX2 );
+        lock( &this->ready_queue_lock DEBUG_CTX2 );
         thread_desc * head = pop_head( &this->ready_queue );
-        unlock( &this->lock );
+        unlock( &this->ready_queue_lock );
         verify( disable_preempt_count > 0 );
         return head;
@@ -470 +473 @@
         systemProcessor{ systemCluster, (processorCtx_t *)&systemProcessorCtxStorage };
 
+        // Initialize the event kernel
+        event_kernel = (event_kernel_t *)&event_kernelStorage;
+        event_kernel{};
+
         // Add the main thread to the ready queue
         // once resume is called on systemProcessor->runner the mainThread needs to be scheduled like any normal thread
@@ -504 +511 @@
         // When its coroutine terminates, it return control to the mainThread
         // which is currently here
-        systemProcessor->proc.is_terminated = true;
+        systemProcessor->proc.do_terminate = true;
         suspend();