Ignore:
File:
1 edited

Legend:

Unmodified
Added
Removed
  • tests/concurrent/actors/executor.cfa

    r1950837 rccf1d99  
    1515};
    1616void ?{}( d_actor & this ) with(this) {
     17    ((actor &)this){};
    1718    id = ids++;
    1819    gstart = (&this + (id / Set * Set - id)); // remember group-start array-element
     
    2324
    2425struct d_msg { inline message; } shared_msg;
     26void ?{}( d_msg & this ) { ((message &) this){ Nodelete }; }
    2527
    2628Allocation receive( d_actor & this, d_msg & msg ) with( this ) {
     
    2830    if ( recs % Batch == 0 ) {
    2931        for ( i; Batch ) {
    30             gstart[sends % Set] << shared_msg;
     32            gstart[sends % Set] | shared_msg;
    3133            sends += 1;
    3234        }
     
    8385        } // switch
    8486
     87   
    8588    executor e{ Processors, Processors, Processors == 1 ? 1 : Processors * 512, true };
    8689
     
    9497
    9598        for ( i; Actors ) {
    96                 actors[i] << shared_msg;
     99                actors[i] | shared_msg;
    97100        } // for
    98101
Note: See TracChangeset for help on using the changeset viewer.