Changeset fbaea970 for libcfa/src/concurrency/channel.hfa

Timestamp:

Nov 23, 2025, 10:54:30 PM (3 days ago)

Author:

Peter A. Buhr <pabuhr@…>

Branches:

master

Children:

00aa122

Parents:

8ffee9a

Message:

rename private waituntil routines register_select, unregister_select, and on_selected with tailing $

File:

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

libcfa/src/concurrency/channel.hfa

@@ -411 +411 @@
         }
 
-        bool register_select( chan_read(T) & this, select_node & node ) with(*this.chan, this) {
+        bool register_select$( chan_read(T) & this, select_node & node ) with(*this.chan, this) {
             lock( mutex_lock );
             node.extra = ret; // set .extra so that if it == 0p later in on_selected it is due to channel close
@@ -476 +476 @@
             return true;
         }
-        bool unregister_select( chan_read(T) & this, select_node & node ) { return unregister_chan( *this.chan, node ); }
-        bool on_selected( chan_read(T) & this, select_node & node ) with(this) {
+        bool unregister_select$( chan_read(T) & this, select_node & node ) { return unregister_chan( *this.chan, node ); }
+        bool on_selected$( chan_read(T) & this, select_node & node ) with(this) {
             if ( unlikely(node.extra == 0p) ) {
                 if ( ! exception_in_flight() ) __closed_remove( *chan, *ret ); // check if woken up due to closed channel
@@ -491 +491 @@
 
         chan_read_no_ret(T) remove( channel(T) & chan ) { chan_read_no_ret(T) c_read{ chan }; return c_read; }
-        bool register_select( chan_read_no_ret(T) & this, select_node & node ) { 
+        bool register_select$( chan_read_no_ret(T) & this, select_node & node ) { 
             this.c_read.ret = &this.retval;
-            return register_select( this.c_read, node );
-        }
-        bool unregister_select( chan_read_no_ret(T) & this, select_node & node ) { return unregister_select( this.c_read, node ); }
-        bool on_selected( chan_read_no_ret(T) & this, select_node & node ) { return on_selected( this.c_read, node ); }
+            return register_select$( this.c_read, node );
+        }
+        bool unregister_select$( chan_read_no_ret(T) & this, select_node & node ) { return unregister_select$( this.c_read, node ); }
+        bool on_selected$( chan_read_no_ret(T) & this, select_node & node ) { return on_selected$( this.c_read, node ); }
 
         void ?{}( chan_write(T) & cw, channel(T) * chan, T elem ) {
@@ -511 +511 @@
         }
 
-        bool register_select( chan_write(T) & this, select_node & node ) with(*this.chan, this) {
+        bool register_select$( chan_write(T) & this, select_node & node ) with(*this.chan, this) {
             lock( mutex_lock );
             node.extra = &elem; // set .extra so that if it == 0p later in on_selected it is due to channel close
@@ -577 +577 @@
                 return true;
         }
-        bool unregister_select( chan_write(T) & this, select_node & node ) { return unregister_chan( *this.chan, node ); }
-
-        bool on_selected( chan_write(T) & this, select_node & node ) with(this) { 
+        bool unregister_select$( chan_write(T) & this, select_node & node ) { return unregister_chan( *this.chan, node ); }
+
+        bool on_selected$( chan_write(T) & this, select_node & node ) with(this) { 
                 if ( unlikely(node.extra == 0p) ) {
                         if ( ! exception_in_flight() ) __closed_insert( *chan, elem ); // check if woken up due to closed channel