Changeset 3bd4293

Timestamp:

Apr 24, 2021, 7:26:23 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:

5c04e82

Parents:

c1c95b1

Message:

Added stat for unparks that can migrate

Location:

libcfa/src/concurrency

Files:

• stats.cfa (modified) (3 diffs)
• stats.hfa (modified) (1 diff)

libcfa/src/concurrency/stats.cfa

@@ -38 +38 @@
                 stats->ready.pop.search.espec   = 0;
                 stats->ready.threads.migration = 0;
+                stats->ready.threads.extunpark = 0;
                 stats->ready.threads.threads   = 0;
                 stats->ready.sleep.halts   = 0;
@@ -95 +96 @@
                 __atomic_fetch_add( &cltr->ready.pop.search.espec  , proc->ready.pop.search.espec  , __ATOMIC_SEQ_CST ); proc->ready.pop.search.espec   = 0;
                 __atomic_fetch_add( &cltr->ready.threads.migration , proc->ready.threads.migration , __ATOMIC_SEQ_CST ); proc->ready.threads.migration  = 0;
+                __atomic_fetch_add( &cltr->ready.threads.extunpark , proc->ready.threads.extunpark , __ATOMIC_SEQ_CST ); proc->ready.threads.extunpark  = 0;
                 __atomic_fetch_add( &cltr->ready.threads.threads   , proc->ready.threads.threads   , __ATOMIC_SEQ_CST ); proc->ready.threads.threads    = 0;
                 __atomic_fetch_add( &cltr->ready.sleep.halts       , proc->ready.sleep.halts       , __ATOMIC_SEQ_CST ); proc->ready.sleep.halts        = 0;
@@ -132 +134 @@
                         uint64_t totalR = ready.pop.local.success + ready.pop.help.success + ready.pop.steal.success + ready.pop.search.success;
                         uint64_t totalS = ready.push.local.success + ready.push.share.success + ready.push.extrn.success;
-                        sstr | "- totals   : " | eng3(totalR) | "run," | eng3(totalS) | "schd (" | eng3(ready.push.extrn.success) | "ext," | eng3(ready.threads.migration) | "mig)";
+                        sstr | "- totals   : " | eng3(totalR) | "run," | eng3(totalS) | "schd (" | eng3(ready.push.extrn.success) | "ext," | eng3(ready.threads.migration) | "mig," | eng3(ready.threads.extunpark) | " eupk)";
 
                         double push_len = ((double)ready.push.local.attempt + ready.push.share.attempt + ready.push.extrn.attempt) / totalS;

libcfa/src/concurrency/stats.hfa

@@ -70 +70 @@
                 struct {
                         volatile uint64_t migration;
+                        volatile uint64_t extunpark;
                         volatile  int64_t threads; // number of threads in the system, includes only local change
                 } threads;