Ignore:
File:
1 edited

Legend:

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

    rccf1d99 r1950837  
    1515};
    1616void ?{}( d_actor & this ) with(this) {
    17     ((actor &)this){};
    1817    id = ids++;
    1918    gstart = (&this + (id / Set * Set - id)); // remember group-start array-element
     
    2423
    2524struct d_msg { inline message; } shared_msg;
    26 void ?{}( d_msg & this ) { ((message &) this){ Nodelete }; }
    2725
    2826Allocation receive( d_actor & this, d_msg & msg ) with( this ) {
     
    3028    if ( recs % Batch == 0 ) {
    3129        for ( i; Batch ) {
    32             gstart[sends % Set] | shared_msg;
     30            gstart[sends % Set] << shared_msg;
    3331            sends += 1;
    3432        }
     
    8583        } // switch
    8684
    87    
    8885    executor e{ Processors, Processors, Processors == 1 ? 1 : Processors * 512, true };
    8986
     
    9794
    9895        for ( i; Actors ) {
    99                 actors[i] | shared_msg;
     96                actors[i] << shared_msg;
    10097        } // for
    10198
Note: See TracChangeset for help on using the changeset viewer.