Changeset fb0be05


Ignore:
Timestamp:
Apr 24, 2021, 8:13:19 PM (5 months ago)
Author:
Thierry Delisle <tdelisle@…>
Branches:
arm-eh, jacob/cs343-translation, master, new-ast-unique-expr
Children:
28d426a
Parents:
cfff639 (diff), a76efc8 (diff)
Note: this is a merge changeset, the changes displayed below correspond to the merge itself.
Use the (diff) links above to see all the changes relative to each parent.
Message:

Merge branch 'master' of plg.uwaterloo.ca:software/cfa/cfa-cc

Location:
libcfa/src/concurrency
Files:
2 edited

Legend:

Unmodified
Added
Removed
  • libcfa/src/concurrency/io/types.hfa

    rcfff639 rfb0be05  
    179179
    180180static inline {
    181         bool fulfil( io_future_t & this, __s32 result ) {
     181        $thread * fulfil( io_future_t & this, __s32 result, bool do_unpark = true ) {
    182182                this.result = result;
    183                 return fulfil(this.self);
     183                return fulfil(this.self, do_unpark);
    184184        }
    185185
  • libcfa/src/concurrency/kernel/fwd.hfa

    rcfff639 rfb0be05  
    219219                        // Mark as fulfilled, wake thread if needed
    220220                        // return true if a thread was unparked
    221                         bool post(oneshot & this) {
     221                        $thread * post(oneshot & this, bool do_unpark = true) {
    222222                                struct $thread * got = __atomic_exchange_n( &this.ptr, 1p, __ATOMIC_SEQ_CST);
    223                                 if( got == 0p ) return false;
    224                                 unpark( got );
    225                                 return true;
     223                                if( got == 0p ) return 0p;
     224                                if(do_unpark) unpark( got );
     225                                return got;
    226226                        }
    227227                }
     
    335335                        // from the server side, mark the future as fulfilled
    336336                        // delete it if needed
    337                         bool fulfil( future_t & this ) {
     337                        $thread * fulfil( future_t & this, bool do_unpark = true ) {
    338338                                for() {
    339339                                        struct oneshot * expected = this.ptr;
     
    343343                                                #pragma GCC diagnostic ignored "-Wfree-nonheap-object"
    344344                                        #endif
    345                                                 if( expected == 3p ) { free( &this ); return false; }
     345                                                if( expected == 3p ) { free( &this ); return 0p; }
    346346                                        #if defined(__GNUC__) && __GNUC__ >= 7
    347347                                                #pragma GCC diagnostic pop
     
    355355                                        struct oneshot * want = expected == 0p ? 1p : 2p;
    356356                                        if(__atomic_compare_exchange_n(&this.ptr, &expected, want, false, __ATOMIC_SEQ_CST, __ATOMIC_SEQ_CST)) {
    357                                                 if( expected == 0p ) { /* paranoid */ verify( this.ptr == 1p); return false; }
    358                                                 bool ret = post( *expected );
     357                                                if( expected == 0p ) { /* paranoid */ verify( this.ptr == 1p); return 0p; }
     358                                                $thread * ret = post( *expected, do_unpark );
    359359                                                __atomic_store_n( &this.ptr, 1p, __ATOMIC_SEQ_CST);
    360360                                                return ret;
Note: See TracChangeset for help on using the changeset viewer.