Changeset ca0c311 for libcfa/src/concurrency

Timestamp:

Jun 19, 2023, 1:54:34 PM (19 months ago)

Author:

caparsons <caparson@…>

Branches:

master

Children:

e39cfb9

Parents:

dc136d7

Message:

added ability to get number of processors constructed on a cluster (not necessarily registered yet)

Location:

libcfa/src/concurrency

Files:

• kernel.hfa (modified) (2 diffs)
• kernel/startup.cfa (modified) (3 diffs)

libcfa/src/concurrency/kernel.hfa

@@ -195 +195 @@
         // Total number of processors
         unsigned total;
+
+    // Number of processors constructed
+    //  incremented at construction time, total is incremented once the processor asyncronously registers
+        unsigned constructed;
 
         // Total number of idle processors
@@ -297 +301 @@
 static inline struct cluster   * active_cluster  () { return publicTLS_get( this_processor )->cltr; }
 
+// gets the number of constructed processors on the cluster
+static inline unsigned get_proc_count( cluster & this ) { return this.procs.constructed; }
+
 // set the number of internal processors
 // these processors are in addition to any explicitly declared processors

libcfa/src/concurrency/kernel/startup.cfa

@@ -528 +528 @@
         this.name = name;
         this.cltr = &_cltr;
+    __atomic_add_fetch( &_cltr.procs.constructed, 1u, __ATOMIC_RELAXED );
         this.rdq.its = 0;
         this.rdq.itr = 0;
@@ -595 +596 @@
         __cfadbg_print_safe(runtime_core, "Kernel : core %p signaling termination\n", &this);
 
+    __atomic_sub_fetch( &this.cltr->procs.constructed, 1u, __ATOMIC_RELAXED );
+
         __atomic_store_n(&do_terminate, true, __ATOMIC_RELAXED);
         __disable_interrupts_checked();
@@ -615 +618 @@
         this.fdw   = 0p;
         this.idle  = 0;
+    this.constructed = 0;
         this.total = 0;
 }