Changes in libcfa/src/concurrency/ready_subqueue.hfa [f302d80:16fd826]

File:

• libcfa/src/concurrency/ready_subqueue.hfa (modified) (7 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
@@ -108 +124 @@
         return this.anchor.ts;
 }
-
-// Aligned timestamps which are used by the relaxed ready queue
-struct __attribute__((aligned(128))) __timestamp_t {
-        volatile unsigned long long tv;
-};
-
-void  ?{}(__timestamp_t & this) { this.tv = 0; }
-void ^?{}(__timestamp_t & this) {}