Changeset 29cb302

Timestamp:

Jun 24, 2020, 3:37:32 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:

d72c074

Parents:

7bfc849

Message:

cfa stats now count number of migrations

Location:

libcfa/src/concurrency

Files:

• kernel.cfa (modified) (2 diffs)
• stats.cfa (modified) (4 diffs)
• stats.hfa (modified) (1 diff)

libcfa/src/concurrency/kernel.cfa

@@ -490 +490 @@
         $thread * thrd_src = kernelTLS.this_thread;
 
+        #if !defined(__CFA_NO_STATISTICS__)
+                struct processor * last_proc = kernelTLS.this_processor;
+        #endif
+
         // Run the thread on this processor
         {
@@ -504 +508 @@
         }
 
+        #if !defined(__CFA_NO_STATISTICS__)
+                if(last_proc != kernelTLS.this_processor) {
+                        __tls_stats()->ready.threads.migration++;
+                }
+        #endif
+
         /* paranoid */ verify( ! kernelTLS.preemption_state.enabled );
         /* paranoid */ verifyf( ((uintptr_t)thrd_src->context.SP) < ((uintptr_t)__get_stack(thrd_src->curr_cor)->base ), "ERROR : Returning $thread %p has been corrupted.\n StackPointer too small.\n", thrd_src );

libcfa/src/concurrency/stats.cfa

@@ -17 +17 @@
                 stats->ready.pick.pop .local    = 0;
                 stats->ready.pick.pop .lsuccess = 0;
+                stats->ready.threads.migration = 0;
                 stats->ready.sleep.halts   = 0;
                 stats->ready.sleep.cancels = 0;
@@ -49 +50 @@
                 __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.threads.migration, proc->ready.threads.migration, __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 );
@@ -113 +115 @@
                         "- local push avg prb len : %'18.2lf, %'18.2lf%% (%'15lu attempts)\n"
                         "- local pop  avg prb len : %'18.2lf, %'18.2lf%% (%'15lu attempts)\n"
+                        "- thread migrations      : %'15lu\n"
                         "- Idle Sleep -\n"
                         "-- halts                 : %'15lu\n"
@@ -140 +143 @@
                         , lpush_len, lpush_sur, ready.pick.push.local
                         , lpop_len , lpop_sur , ready.pick.pop .local
+                        , ready.threads.migration
                         , ready.sleep.halts, ready.sleep.cancels, ready.sleep.wakes, ready.sleep.exits
                         #if defined(HAVE_LINUX_IO_URING_H)

libcfa/src/concurrency/stats.hfa

@@ -46 +46 @@
                         } pop;
                 } pick;
+                struct {
+                        volatile uint64_t migration;
+                } threads;
                 struct {
                         volatile uint64_t halts;