Changeset cb69fba

Timestamp:

May 4, 2023, 2:39:28 PM (19 months ago)

Author:

caparsons <caparson@…>

Branches:

ADT, ast-experimental, master

Children:

a882b68

Parents:

ca8c91ce

Message:

did some cleanup of channels

File:

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

libcfa/src/concurrency/channel.hfa

@@ -343 +343 @@
 
 static inline bool register_select( chan_read(T) & this, select_node & node ) with(this.chan, this) {
-    // mutex(sout) sout | "register_read";
     lock( mutex_lock );
     node.extra = &ret; // set .extra so that if it == 0p later in on_selected it is due to channel close
@@ -416 +415 @@
 
 static inline bool register_select( chan_write(T) & this, select_node & node ) with(this.chan, this) {
-    // mutex(sout) sout | "register_write";
     lock( mutex_lock );
     node.extra = &elem; // set .extra so that if it == 0p later in on_selected it is due to channel close
@@ -441 +439 @@
     // handle blocked consumer case via handoff (buffer is implicitly empty)
     ConsEmpty: if ( !cons`isEmpty ) {
-        if ( !__handle_waituntil_OR( cons ) ) {
-            // mutex(sout) sout | "empty";
-            break ConsEmpty;
-        }
-        // mutex(sout) sout | "signal";
+        if ( !__handle_waituntil_OR( cons ) ) break ConsEmpty;
         __cons_handoff( chan, elem );
         __set_avail_then_unlock( node, mutex_lock );