Changes in libcfa/src/concurrency/channel.hfa [b93bf85:00b046f]

File:

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

libcfa/src/concurrency/channel.hfa

@@ -444 +444 @@
 }
 static inline bool unregister_select( chan_read(T) & this, select_node & node ) { return unregister_chan( this.chan, node ); }
-static inline 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
-        else return false;
-    }
+static inline void on_selected( chan_read(T) & this, select_node & node ) with(this) {
+    if ( node.extra == 0p ) // check if woken up due to closed channel
+        __closed_remove( chan, ret );
     // This is only reachable if not closed or closed exception was handled
-    return true;
 }
 
@@ -539 +536 @@
 static inline bool unregister_select( chan_write(T) & this, select_node & node ) { return unregister_chan( this.chan, node ); }
 
-static inline 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
-        else return false;
-    }
+static inline void on_selected( chan_write(T) & this, select_node & node ) with(this) { 
+    if ( node.extra == 0p ) // check if woken up due to closed channel
+        __closed_insert( chan, elem );
+
     // This is only reachable if not closed or closed exception was handled
-    return true;
 }