Changeset 16fd826

Timestamp:

May 13, 2021, 3:44: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:

fb4ccdf

Parents:

8cd40bf

Message:

Added count to the ready sub_queues

File:

• libcfa/src/concurrency/ready_subqueue.hfa (modified) (6 diffs)

libcfa/src/concurrency/ready_subqueue.hfa

@@ -11 +11 @@
         // spin lock protecting the queue
         volatile bool lock;
+
+        #if !defined(__CFA_NO_STATISTICS__)
+                unsigned cnt;
+        #endif
 
         __thread_desc_link anchor;
@@ -29 +33 @@
         this.anchor.next = 0p;
         this.anchor.ts   = 0;
+        #if !defined(__CFA_NO_STATISTICS__)
+                this.cnt  = 0;
+        #endif
 
         // We add a boat-load of assertions here because the anchor code is very fragile
+        /* paranoid */ _Static_assert( offsetof( $thread, link ) == offsetof(__intrusive_lane_t, anchor) );
         /* paranoid */ verify( offsetof( $thread, link ) == offsetof(__intrusive_lane_t, anchor) );
         /* paranoid */ verify( ((uintptr_t)( mock_head(this) ) + offsetof( $thread, link )) == (uintptr_t)(&this.anchor) );
@@ -54 +62 @@
 // returns true of lane was empty before push, false otherwise
 static inline void push( __intrusive_lane_t & this, $thread * node ) {
+        /* paranoid */ verify( this.lock );
         /* paranoid */ verify( node->link.next == 0p );
         /* paranoid */ verify( node->link.ts   == 0  );
@@ -72 +81 @@
         this.prev->link.ts   = rdtscl();
         this.prev = node;
+        #if !defined(__CFA_NO_STATISTICS__)
+                this.cnt++;
+        #endif
 }
 
@@ -78 +90 @@
 // returns true of lane was empty before push, false otherwise
 static inline [* $thread, unsigned long long] pop( __intrusive_lane_t & this ) {
+        /* paranoid */ verify( this.lock );
         /* paranoid */ verify( this.anchor.next != 0p );
         /* paranoid */ verify( this.anchor.ts   != 0  );
@@ -89 +102 @@
         node->link.next = 0p;
         node->link.ts   = 0;
+        #if !defined(__CFA_NO_STATISTICS__)
+                this.cnt--;
+        #endif
 
         // Update head time stamp