Changeset 68f36f4 for libcfa/src/concurrency/kernel.cfa

Timestamp:

Jun 19, 2020, 4:59:19 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:

0f89d4f

Parents:

64a7146

Message:

Added Idle Sleep stats and removed extra call to unsafe_remove

File:

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

libcfa/src/concurrency/kernel.cfa

@@ -371 +371 @@
 
                         // Make sure we aren't on the idle queue
+                        #if !defined(__CFA_NO_STATISTICS__)
+                                bool removed =
+                        #endif
                         unsafe_remove( this->cltr->idles, this );
-                        Link(processor) * link = &this->cltr->idles.stack;
-                        for() {
-                                processor * next = link->top;
-                                if( next == this ) {
-                                        link->top = getNext(this)->top;
-                                        break;
-                                }
-                                if( next == 0p ) break;
-                                link = getNext(next);
-                        }
+
+                        #if !defined(__CFA_NO_STATISTICS__)
+                                if(removed) __tls_stats()->ready.sleep.exits++;
+                        #endif
 
                 // Unlock the RWlock
@@ -672 +669 @@
                 push( thrd->curr_cluster, thrd );
 
-                __wake_one(id, thrd->curr_cluster);
+                #if !defined(__CFA_NO_STATISTICS__)
+                        bool woke =
+                #endif
+                        __wake_one(id, thrd->curr_cluster);
+
+                #if !defined(__CFA_NO_STATISTICS__)
+                        if(woke) __tls_stats()->ready.sleep.wakes++;
+                #endif
         ready_schedule_unlock( id );
 
@@ -969 +973 @@
         if( do_terminate ) return;
 
+        #if !defined(__CFA_NO_STATISTICS__)
+                __tls_stats()->ready.sleep.halts++;
+        #endif
         // Push self to queue
         push(cltr->idles, *this);
@@ -979 +986 @@
                         __wake_one( id, cltr );
                 ready_schedule_unlock( id );
+                #if !defined(__CFA_NO_STATISTICS__)
+                        __tls_stats()->ready.sleep.cancels++;
+                #endif
         }