Changeset ec43cf9 for libcfa/src/concurrency/kernel.cfa

Timestamp:

Apr 5, 2021, 7:06:37 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:

7039ab9, cd59d28

Parents:

a5a01faa

Message:

Kernel now keeps track of the how many threads each processor has contributed.
This isn't useful if it is not sampled regularly but it's a first step.

File:

• libcfa/src/concurrency/kernel.cfa (modified) (4 diffs)

libcfa/src/concurrency/kernel.cfa

@@ -357 +357 @@
                                 break RUNNING;
                         case TICKET_UNBLOCK:
+                                #if !defined(__CFA_NO_STATISTICS__)
+                                        __tls_stats()->ready.threads.threads++;
+                                #endif
                                 // This is case 2, the racy case, someone tried to run this thread before it finished blocking
                                 // In this case, just run it again.
@@ -370 +373 @@
 
         __cfadbg_print_safe(runtime_core, "Kernel : core %p finished running thread %p\n", this, thrd_dst);
+
+        #if !defined(__CFA_NO_STATISTICS__)
+                __tls_stats()->ready.threads.threads--;
+        #endif
 
         /* paranoid */ verify( ! __preemption_enabled() );
@@ -432 +439 @@
         if (thrd->preempted == __NO_PREEMPTION) thrd->state = Ready;
 
+        // Dereference the thread now because once we push it, there is not guaranteed it's still valid.
+        struct cluster * cl = thrd->curr_cluster;
+
         ready_schedule_lock();
-                // Dereference the thread now because once we push it, there is not guaranteed it's still valid.
-                struct cluster * cl = thrd->curr_cluster;
-
                 // push the thread to the cluster ready-queue
                 push( cl, thrd );
@@ -444 +451 @@
                 __wake_one( cl );
         ready_schedule_unlock();
+
+        #if !defined(__CFA_NO_STATISTICS__)
+                if( kernelTLS().this_stats ) {
+                        __tls_stats()->ready.threads.threads++;
+                }
+                else {
+                        __atomic_fetch_add(&cl->stats->ready.threads.threads, 1, __ATOMIC_RELAXED);
+                }
+        #endif
 
         /* paranoid */ verify( ! __preemption_enabled() );