- File:
-
- 1 edited
-
libcfa/src/concurrency/channel.hfa (modified) (3 diffs)
Legend:
- Unmodified
- Added
- Removed
-
libcfa/src/concurrency/channel.hfa
r3f0b062 rca995e3 28 28 unlock( lock ); 29 29 park(); 30 #if defined(__ARM_ARCH)31 30 __atomic_thread_fence( __ATOMIC_SEQ_CST ); 32 #endif33 31 return sn.extra == 0p; 34 32 } … … 133 131 static inline void __cons_handoff( channel(T) & chan, T & elem ) with(chan) { 134 132 memcpy( cons`first.extra, (void *)&elem, sizeof(T) ); // do waiting consumer work 135 #if defined(__ARM_ARCH)136 133 __atomic_thread_fence( __ATOMIC_SEQ_CST ); 137 #endif138 134 wake_one( cons ); 139 135 } … … 142 138 static inline void __prods_handoff( channel(T) & chan, T & retval ) with(chan) { 143 139 memcpy( (void *)&retval, prods`first.extra, sizeof(T) ); 144 #if defined(__ARM_ARCH)145 140 __atomic_thread_fence( __ATOMIC_SEQ_CST ); 146 #endif147 141 wake_one( prods ); 148 142 }
Note:
See TracChangeset
for help on using the changeset viewer.