Ignore:
File:
1 edited

Legend:

Unmodified
Added
Removed
  • libcfa/src/concurrency/channel.hfa

    r3f0b062 rca995e3  
    2828    unlock( lock );
    2929    park();
    30     #if defined(__ARM_ARCH)
    3130    __atomic_thread_fence( __ATOMIC_SEQ_CST );
    32     #endif
    3331    return sn.extra == 0p;
    3432}
     
    133131static inline void __cons_handoff( channel(T) & chan, T & elem ) with(chan) {
    134132    memcpy( cons`first.extra, (void *)&elem, sizeof(T) ); // do waiting consumer work
    135     #if defined(__ARM_ARCH)
    136133    __atomic_thread_fence( __ATOMIC_SEQ_CST );
    137     #endif
    138134    wake_one( cons );
    139135}
     
    142138static inline void __prods_handoff( channel(T) & chan, T & retval ) with(chan) {
    143139    memcpy( (void *)&retval, prods`first.extra, sizeof(T) );
    144     #if defined(__ARM_ARCH)
    145140    __atomic_thread_fence( __ATOMIC_SEQ_CST );
    146     #endif
    147141    wake_one( prods );
    148142}
Note: See TracChangeset for help on using the changeset viewer.