Changeset 15c93d8 for libcfa/src/concurrency/ready_subqueue.hfa

Timestamp:

Oct 28, 2022, 5:30:57 PM (18 months ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

ADT, ast-experimental, master

Children:

f1f481a

Parents:

be5f0a5

Message:

Renamed ready-queue link fields to rdy_link

File:

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

libcfa/src/concurrency/ready_subqueue.hfa

@@ -25 +25 @@
 static inline thread$ * mock_head(const __intrusive_lane_t & this) {
         thread$ * rhead = (thread$ *)(
-                (uintptr_t)( &this.l.anchor ) - __builtin_offsetof( thread$, link )
+                (uintptr_t)( &this.l.anchor ) - __builtin_offsetof( thread$, rdy_link )
         );
         return rhead;
@@ -34 +34 @@
 static inline void push( __intrusive_lane_t & this, thread$ * node ) {
         /* paranoid */ verify( this.l.lock );
-        /* paranoid */ verify( node->link.next == 0p );
-        /* paranoid */ verify( __atomic_load_n(&node->link.ts, __ATOMIC_RELAXED) == MAX  );
-        /* paranoid */ verify( this.l.prev->link.next == 0p );
-        /* paranoid */ verify( __atomic_load_n(&this.l.prev->link.ts, __ATOMIC_RELAXED)   == MAX  );
+        /* paranoid */ verify( node->rdy_link.next == 0p );
+        /* paranoid */ verify( __atomic_load_n(&node->rdy_link.ts, __ATOMIC_RELAXED) == MAX  );
+        /* paranoid */ verify( this.l.prev->rdy_link.next == 0p );
+        /* paranoid */ verify( __atomic_load_n(&this.l.prev->rdy_link.ts, __ATOMIC_RELAXED)   == MAX  );
         if( this.l.anchor.next == 0p ) {
                 /* paranoid */ verify( this.l.anchor.next == 0p );
@@ -51 +51 @@
 
         // Get the relevant nodes locally
-        this.l.prev->link.next = node;
-        __atomic_store_n(&this.l.prev->link.ts, rdtscl(), __ATOMIC_RELAXED);
+        this.l.prev->rdy_link.next = node;
+        __atomic_store_n(&this.l.prev->rdy_link.ts, rdtscl(), __ATOMIC_RELAXED);
         this.l.prev = node;
         #if !defined(__CFA_NO_STATISTICS__)
@@ -70 +70 @@
         // Get the relevant nodes locally
         thread$ * node = this.l.anchor.next;
-        this.l.anchor.next = node->link.next;
-        __atomic_store_n(&this.l.anchor.ts, __atomic_load_n(&node->link.ts, __ATOMIC_RELAXED), __ATOMIC_RELAXED);
+        this.l.anchor.next = node->rdy_link.next;
+        __atomic_store_n(&this.l.anchor.ts, __atomic_load_n(&node->rdy_link.ts, __ATOMIC_RELAXED), __ATOMIC_RELAXED);
         bool is_empty = this.l.anchor.next == 0p;
-        node->link.next = 0p;
-        __atomic_store_n(&node->link.ts, ULLONG_MAX, __ATOMIC_RELAXED);
+        node->rdy_link.next = 0p;
+        __atomic_store_n(&node->rdy_link.ts, ULLONG_MAX, __ATOMIC_RELAXED);
         #if !defined(__CFA_NO_STATISTICS__)
                 this.l.cnt--;
@@ -83 +83 @@
 
         unsigned long long ats = __atomic_load_n(&this.l.anchor.ts, __ATOMIC_RELAXED);
-        /* paranoid */ verify( node->link.next == 0p );
-        /* paranoid */ verify( __atomic_load_n(&node->link.ts , __ATOMIC_RELAXED) == MAX );
-        /* paranoid */ verify( __atomic_load_n(&node->link.ts , __ATOMIC_RELAXED) != 0   );
+        /* paranoid */ verify( node->rdy_link.next == 0p );
+        /* paranoid */ verify( __atomic_load_n(&node->rdy_link.ts , __ATOMIC_RELAXED) == MAX );
+        /* paranoid */ verify( __atomic_load_n(&node->rdy_link.ts , __ATOMIC_RELAXED) != 0   );
         /* paranoid */ verify( ats != 0 );
         /* paranoid */ verify( (ats == MAX) == is_empty );