Changeset 52769ba for libcfa/src/concurrency/stats.cfa

Timestamp:

Jun 24, 2020, 1:40:35 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:

c7816be

Parents:

de917da3

Message:

Added statistics for local success when biased

File:

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

libcfa/src/concurrency/stats.cfa

@@ -8 +8 @@
 #if !defined(__CFA_NO_STATISTICS__)
         void __init_stats( struct __stats_t * stats ) {
-                stats->ready.pick.push.attempt = 0;
-                stats->ready.pick.push.success = 0;
-                stats->ready.pick.pop .probe   = 0;
-                stats->ready.pick.pop .attempt = 0;
-                stats->ready.pick.pop .local   = 0;
-                stats->ready.pick.pop .success = 0;
+                stats->ready.pick.push.attempt  = 0;
+                stats->ready.pick.push.success  = 0;
+                stats->ready.pick.push.local    = 0;
+                stats->ready.pick.push.lsuccess = 0;
+                stats->ready.pick.pop .probe    = 0;
+                stats->ready.pick.pop .attempt  = 0;
+                stats->ready.pick.pop .success  = 0;
+                stats->ready.pick.pop .local    = 0;
+                stats->ready.pick.pop .lsuccess = 0;
                 stats->ready.sleep.halts   = 0;
                 stats->ready.sleep.cancels = 0;
@@ -37 +40 @@
 
         void __tally_stats( struct __stats_t * cltr, struct __stats_t * proc ) {
-                __atomic_fetch_add( &cltr->ready.pick.push.attempt, proc->ready.pick.push.attempt, __ATOMIC_SEQ_CST );
-                __atomic_fetch_add( &cltr->ready.pick.push.local  , proc->ready.pick.push.local  , __ATOMIC_SEQ_CST );
-                __atomic_fetch_add( &cltr->ready.pick.push.success, proc->ready.pick.push.success, __ATOMIC_SEQ_CST );
-                __atomic_fetch_add( &cltr->ready.pick.pop .probe  , proc->ready.pick.pop .probe  , __ATOMIC_SEQ_CST );
-                __atomic_fetch_add( &cltr->ready.pick.pop .attempt, proc->ready.pick.pop .attempt, __ATOMIC_SEQ_CST );
-                __atomic_fetch_add( &cltr->ready.pick.pop .local  , proc->ready.pick.pop .local  , __ATOMIC_SEQ_CST );
-                __atomic_fetch_add( &cltr->ready.pick.pop .success, proc->ready.pick.pop .success, __ATOMIC_SEQ_CST );
+                __atomic_fetch_add( &cltr->ready.pick.push.attempt , proc->ready.pick.push.attempt , __ATOMIC_SEQ_CST );
+                __atomic_fetch_add( &cltr->ready.pick.push.success , proc->ready.pick.push.success , __ATOMIC_SEQ_CST );
+                __atomic_fetch_add( &cltr->ready.pick.push.local   , proc->ready.pick.push.local   , __ATOMIC_SEQ_CST );
+                __atomic_fetch_add( &cltr->ready.pick.push.lsuccess, proc->ready.pick.push.lsuccess, __ATOMIC_SEQ_CST );
+                __atomic_fetch_add( &cltr->ready.pick.pop .probe   , proc->ready.pick.pop .probe   , __ATOMIC_SEQ_CST );
+                __atomic_fetch_add( &cltr->ready.pick.pop .attempt , proc->ready.pick.pop .attempt , __ATOMIC_SEQ_CST );
+                __atomic_fetch_add( &cltr->ready.pick.pop .success , proc->ready.pick.pop .success , __ATOMIC_SEQ_CST );
+                __atomic_fetch_add( &cltr->ready.pick.pop .local   , proc->ready.pick.pop .local   , __ATOMIC_SEQ_CST );
+                __atomic_fetch_add( &cltr->ready.pick.pop .lsuccess, proc->ready.pick.pop .lsuccess, __ATOMIC_SEQ_CST );
                 __atomic_fetch_add( &cltr->ready.sleep.halts  , proc->ready.sleep.halts  , __ATOMIC_SEQ_CST );
                 __atomic_fetch_add( &cltr->ready.sleep.cancels, proc->ready.sleep.cancels, __ATOMIC_SEQ_CST );
@@ -74 +79 @@
                 double pop_len  = ((double)ready.pick.pop .attempt) / ready.pick.pop .success;
 
+                double lpush_sur = (100.0 * ((double)ready.pick.push.lsuccess) / ready.pick.push.local);
+                double lpop_sur  = (100.0 * ((double)ready.pick.pop .lsuccess) / ready.pick.pop .local);
+
+                double lpush_len = ((double)ready.pick.push.local) / ready.pick.push.lsuccess;
+                double lpop_len  = ((double)ready.pick.pop .local) / ready.pick.pop .lsuccess;
+
                 #if defined(HAVE_LINUX_IO_URING_H)
                         double avgrdy = ((double)io.submit_q.submit_avg.rdy) / io.submit_q.submit_avg.cnt;
@@ -98 +109 @@
                         "- total threads run      : %'15lu\n"
                         "- total threads scheduled: %'15lu\n"
-                        "- push average probe len : %'18.2lf, %'18.2lf%% (%'15lu attempts, %'15lu local)\n"
-                        "- pop  average probe len : %'18.2lf, %'18.2lf%% (%'15lu attempts, %'15lu local)\n"
+                        "- push average probe len : %'18.2lf, %'18.2lf%% (%'15lu attempts)\n"
+                        "- pop  average probe len : %'18.2lf, %'18.2lf%% (%'15lu attempts)\n"
+                        "- local push avg prb len : %'18.2lf, %'18.2lf%% (%'15lu attempts)\n"
+                        "- local pop  avg prb len : %'18.2lf, %'18.2lf%% (%'15lu attempts)\n"
                         "- Idle Sleep -\n"
                         "-- halts                 : %'15lu\n"
@@ -123 +136 @@
                         , ready.pick.pop.success
                         , ready.pick.push.success
-                        , push_len, push_sur, ready.pick.push.attempt, ready.pick.push.local
-                        , pop_len , pop_sur , ready.pick.pop .attempt, ready.pick.pop .local
+                        , push_len, push_sur, ready.pick.push.attempt
+                        , pop_len , pop_sur , ready.pick.pop .attempt
+                        , lpush_len, lpush_sur, ready.pick.push.local
+                        , lpop_len , lpop_sur , ready.pick.pop .local
                         , ready.sleep.halts, ready.sleep.cancels, ready.sleep.wakes, ready.sleep.exits
                         #if defined(HAVE_LINUX_IO_URING_H)