Changeset 5e0b6657 for libcfa/src/concurrency/channel.hfa

Timestamp:

Dec 8, 2025, 11:29:33 AM (2 months ago)

Author:

Michael Brooks <mlbrooks@…>

Branches:

master, stuck-waitfor-destruct

Children:

79ba50c

Parents:

8f448e0 (diff), 79ec8c3 (diff)
Note: this is a merge changeset, the changes displayed below correspond to the merge itself.
Use the (diff) links above to see all the changes relative to each parent.

Message:

Merge remote-tracking branch 'refs/remotes/origin/master'

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