Changeset e6e250d for libcfa/src/concurrency

Timestamp:

Mar 29, 2026, 11:03:25 PM (9 days ago)

Author:

Peter A. Buhr <pabuhr@…>

Branches:

master

Children:

c1f17aa

Parents:

81ab5eb

Message:

3rd attempt at harmonizing isOp functions, e.g., isListed, isFirst, isLast

Location:

libcfa/src/concurrency

Files:

• channel.hfa (modified) (1 diff)
• future.hfa (modified) (2 diffs)
• locks.cfa (modified) (3 diffs)
• locks.hfa (modified) (2 diffs)

libcfa/src/concurrency/channel.hfa

@@ -369 +369 @@
         ///////////////////////////////////////////////////////////////////////////////////////////
         bool unregister_chan( channel(T) & chan, select_node & node ) with(chan) {
-            if ( ! isListed( node ) && ! node.park_counter ) return false; // handle special OR case
+            if ( ! listed( node ) && ! node.park_counter ) return false; // handle special OR case
             lock( mutex_lock );
-            if ( isListed( node ) ) { // op wasn't performed
+            if ( listed( node ) ) { // op wasn't performed
                 remove( node );
                 unlock( mutex_lock );

libcfa/src/concurrency/future.hfa

@@ -10 +10 @@
 // Created On       : Wed Jan 06 17:33:18 2021
 // Last Modified By : Peter A. Buhr
-// Last Modified On : Sun Mar 29 21:13:04 2026
-// Update Count     : 223
+// Last Modified On : Sun Mar 29 22:47:01 2026
+// Update Count     : 224
 //
 
@@ -79 +79 @@
 
                 bool unregister_select$( future(T) & fut, select_node & s ) with( fut ) { // for waituntil statement
-                  if ( ! isListed( s ) ) return false;
-                        lock( lock );
-                        if ( isListed( s ) ) remove( s );
+                  if ( ! listed( s ) ) return false;
+                        lock( lock );
+                        if ( listed( s ) ) remove( s );
                         unlock( lock );
                         return false;

libcfa/src/concurrency/locks.cfa

@@ -220 +220 @@
 bool unregister_select$( blocking_lock & this, select_node & node ) with(this) {
         lock( lock __cfaabi_dbg_ctx2 );
-        if ( isListed( node ) ) {
+        if ( listed( node ) ) {
                 remove( node );
                 wait_count--;
@@ -265 +265 @@
                 //      may still be called after a thread has been removed from the queue but
                 //      before the alarm is unregistered
-                if ( isListed( *info_thd ) ) {                                  // is thread on queue
+                if ( listed( *info_thd ) ) {                                    // is thread on queue
                         info_thd->signalled = false;
                         // remove this thread O(1)
@@ -304 +304 @@
                 //      may still be called after a thread has been removed from the queue but
                 //      before the alarm is unregistered
-                if ( isListed( *info_thd ) ) {                                  // is thread on queue
+                if ( listed( *info_thd ) ) {                                    // is thread on queue
                         info_thd->signalled = false;
                         // remove this thread O(1)

libcfa/src/concurrency/locks.hfa

@@ -11 +11 @@
 // Created On       : Thu Jan 21 19:46:50 2021
 // Last Modified By : Peter A. Buhr
-// Last Modified On : Sun Nov 23 22:38:45 2025
-// Update Count     : 67
+// Last Modified On : Sun Mar 29 22:46:39 2026
+// Update Count     : 68
 //
 
@@ -645 +645 @@
 static inline bool unregister_select$( simple_owner_lock & this, select_node & node ) with( this ) {
         lock( lock __cfaabi_dbg_ctx2 );
-        if ( isListed( node ) ) {
+        if ( listed( node ) ) {
                 remove( node );
                 unlock( lock );