Changeset 13c5e19 for libcfa/src/concurrency/kernel.cfa

Timestamp:

Jun 23, 2020, 4:42:58 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:

de917da3

Parents:

b232745

Message:

• Moved snzi and subqueues outside of ready_queue.cfa.
• Added random.hfa with multiple prng.
• Minor optimizations to ready-queue
• Stats now track number of local pops( bias pops )
• Fixed stats for io
• Fixed calculaton of nprocessors
• Fixed IO to work with new ready-queue

File:

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

libcfa/src/concurrency/kernel.cfa

@@ -229 +229 @@
 static void * __invoke_processor(void * arg);
 
-void ?{}(processor & this, const char name[], cluster & cltr) with( this ) {
+void ?{}(processor & this, const char name[], cluster & _cltr) with( this ) {
         this.name = name;
-        this.cltr = &cltr;
+        this.cltr = &_cltr;
         id = -1u;
         terminated{ 0 };
@@ -245 +245 @@
 
         this.stack = __create_pthread( &this.kernel_thread, __invoke_processor, (void *)&this );
+        __atomic_fetch_add( &cltr->nprocessors, 1u, __ATOMIC_SEQ_CST );
 
         __cfadbg_print_safe(runtime_core, "Kernel : core %p created\n", &this);
@@ -264 +265 @@
 
         free( this.stack );
+
+        __atomic_fetch_sub( &cltr->nprocessors, 1u, __ATOMIC_SEQ_CST );
 }
 
@@ -269 +272 @@
         this.name = name;
         this.preemption_rate = preemption_rate;
+        this.nprocessors = 0;
         ready_queue{};
 
@@ -324 +328 @@
         }
 
-        doregister(this->cltr, this);
-
         {
                 // Setup preemption data
@@ -357 +359 @@
                 __cfadbg_print_safe(runtime_core, "Kernel : core %p stopping\n", this);
         }
-
-        unregister(this->cltr, this);
 
         V( this->terminated );
@@ -845 +845 @@
                 runner{ &this };
                 __cfadbg_print_safe(runtime_core, "Kernel : constructed main processor context %p\n", &runner);
+
+                __atomic_fetch_add( &cltr->nprocessors, 1u, __ATOMIC_SEQ_CST );
         }
 
@@ -918 +920 @@
         void ^?{}(processor & this) with( this ){
                 /* paranoid */ verify( this.do_terminate == true );
+                __atomic_fetch_sub( &cltr->nprocessors, 1u, __ATOMIC_SEQ_CST );
                 __cfaabi_dbg_print_safe("Kernel : destroyed main processor context %p\n", &runner);
         }
@@ -1150 +1153 @@
 }
 
-void doregister( cluster * cltr, processor * proc ) {
-        // lock      (cltr->idle_lock __cfaabi_dbg_ctx2);
-        // cltr->nprocessors += 1;
-        // push_front(cltr->procs, *proc);
-        // unlock    (cltr->idle_lock);
-}
-
-void unregister( cluster * cltr, processor * proc ) {
-        // lock  (cltr->idle_lock __cfaabi_dbg_ctx2);
-        // remove(cltr->procs, *proc );
-        // cltr->nprocessors -= 1;
-        // unlock(cltr->idle_lock);
-}
-
 //-----------------------------------------------------------------------------
 // Debug