Changeset fd1f65e for libcfa/src/concurrency/stats.cfa

Timestamp:

Apr 1, 2021, 8:02:19 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:

a344425

Parents:

b580bcc

Message:

Stats now keep track of external pushes separately

File:

• libcfa/src/concurrency/stats.cfa (modified) (5 diffs)

libcfa/src/concurrency/stats.cfa

@@ -13 +13 @@
                 stats->ready.pick.push.local    = 0;
                 stats->ready.pick.push.lsuccess = 0;
+                stats->ready.pick.ext.attempt  = 0;
+                stats->ready.pick.ext.success  = 0;
+                stats->ready.pick.ext.local    = 0;
+                stats->ready.pick.ext.lsuccess = 0;
                 stats->ready.pick.pop .probe    = 0;
                 stats->ready.pick.pop .attempt  = 0;
@@ -47 +51 @@
                 __atomic_fetch_add( &cltr->ready.pick.push.local   , proc->ready.pick.push.local   , __ATOMIC_SEQ_CST ); proc->ready.pick.push.local    = 0;
                 __atomic_fetch_add( &cltr->ready.pick.push.lsuccess, proc->ready.pick.push.lsuccess, __ATOMIC_SEQ_CST ); proc->ready.pick.push.lsuccess = 0;
+                __atomic_fetch_add( &cltr->ready.pick.ext.attempt  , proc->ready.pick.ext.attempt  , __ATOMIC_SEQ_CST ); proc->ready.pick.ext.attempt   = 0;
+                __atomic_fetch_add( &cltr->ready.pick.ext.success  , proc->ready.pick.ext.success  , __ATOMIC_SEQ_CST ); proc->ready.pick.ext.success   = 0;
+                __atomic_fetch_add( &cltr->ready.pick.ext.local    , proc->ready.pick.ext.local    , __ATOMIC_SEQ_CST ); proc->ready.pick.ext.local     = 0;
+                __atomic_fetch_add( &cltr->ready.pick.ext.lsuccess , proc->ready.pick.ext.lsuccess , __ATOMIC_SEQ_CST ); proc->ready.pick.ext.lsuccess  = 0;
                 __atomic_fetch_add( &cltr->ready.pick.pop .probe   , proc->ready.pick.pop .probe   , __ATOMIC_SEQ_CST ); proc->ready.pick.pop .probe    = 0;
                 __atomic_fetch_add( &cltr->ready.pick.pop .attempt , proc->ready.pick.pop .attempt , __ATOMIC_SEQ_CST ); proc->ready.pick.pop .attempt  = 0;
@@ -80 +88 @@
                 if( flags & CFA_STATS_READY_Q ) {
                         double push_len = ((double)ready.pick.push.attempt) / ready.pick.push.success;
+                        double ext_len  = ((double)ready.pick.ext .attempt) / ready.pick.ext .success;
                         double pop_len  = ((double)ready.pick.pop .attempt) / ready.pick.pop .success;
 
                         double lpush_len = ((double)ready.pick.push.local) / ready.pick.push.lsuccess;
+                        double lext_len  = ((double)ready.pick.ext .local) / ready.pick.ext .lsuccess;
                         double lpop_len  = ((double)ready.pick.pop .local) / ready.pick.pop .lsuccess;
 
@@ -89 +99 @@
                                 "- total threads  : %'15" PRIu64 "run, %'15" PRIu64 "schd (%'" PRIu64 "mig )\n"
                                 "- push avg probe : %'3.2lf, %'3.2lfl (%'15" PRIu64 " attempts, %'15" PRIu64 " locals)\n"
+                                "- ext  avg probe : %'3.2lf, %'3.2lfl (%'15" PRIu64 " attempts, %'15" PRIu64 " locals)\n"
                                 "- pop  avg probe : %'3.2lf, %'3.2lfl (%'15" PRIu64 " attempts, %'15" PRIu64 " locals)\n"
                                 "- Idle Sleep     : %'15" PRIu64 "h, %'15" PRIu64 "c, %'15" PRIu64 "w, %'15" PRIu64 "e\n"
@@ -97 +108 @@
                                 , ready.threads.migration
                                 , push_len, lpush_len, ready.pick.push.attempt, ready.pick.push.local
+                                , ext_len , lext_len , ready.pick.ext .attempt, ready.pick.ext .local
                                 , pop_len , lpop_len , ready.pick.pop .attempt, ready.pick.pop .local
                                 , ready.sleep.halts, ready.sleep.cancels, ready.sleep.wakes, ready.sleep.exits