Changeset 02c5880 for libcfa/src/concurrency/channel.hfa

Timestamp:

Oct 12, 2023, 4:03:38 PM (13 months ago)

Author:

caparsons <caparson@…>

Branches:

master

Children:

80f8703

Parents:

4604bf5

Message:

Added fence after channel handoff to prevent reordering on the arm that resulted in stale values

File:

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

libcfa/src/concurrency/channel.hfa

@@ -130 +130 @@
 static inline void __cons_handoff( channel(T) & chan, T & elem ) with(chan) {
     memcpy( cons`first.extra, (void *)&elem, sizeof(T) ); // do waiting consumer work
+    __atomic_thread_fence( __ATOMIC_SEQ_CST );
     wake_one( cons );
 }
@@ -136 +137 @@
 static inline void __prods_handoff( channel(T) & chan, T & retval ) with(chan) {
     memcpy( (void *)&retval, prods`first.extra, sizeof(T) );
+    __atomic_thread_fence( __ATOMIC_SEQ_CST );
     wake_one( prods );
 }