Changeset 809e058 for tests/concurrent


Ignore:
Timestamp:
Mar 4, 2023, 1:46:44 PM (14 months ago)
Author:
caparsons <caparson@…>
Branches:
ADT, ast-experimental, master
Children:
046ba23
Parents:
231e1ae
Message:

changed actor tests to reflect syntax change and some small changes due to other features

Location:
tests/concurrent/actors
Files:
6 edited

Legend:

Unmodified
Added
Removed

  • tests/concurrent/actors/dynamic.cfa

    r231e1ae r809e058  
    3333    derived_actor * d_actor = alloc();
    3434    (*d_actor){};
    35     *d_actor | *d_msg;
     35    *d_actor << *d_msg;
    3636    return Delete;
    3737}
    … …  
    6363    derived_actor * d_actor = alloc();
    6464    (*d_actor){};
    65     *d_actor | *d_msg;
     65    *d_actor << *d_msg;
    6666
    6767    printf("stopping\n");

  • tests/concurrent/actors/executor.cfa

    r231e1ae r809e058  
    3030    if ( recs % Batch == 0 ) {
    3131        for ( i; Batch ) {
    32             gstart[sends % Set] | shared_msg;
     32            gstart[sends % Set] << shared_msg;
    3333            sends += 1;
    3434        }
    … …  
    9797
    9898        for ( i; Actors ) {
    99                 actors[i] | shared_msg;
     99                actors[i] << shared_msg;
    100100        } // for
    101101

  • tests/concurrent/actors/matrix.cfa

    r231e1ae r809e058  
    2121void ?{}( derived_msg & this ) {}
    2222void ?{}( derived_msg & this, int * Z, int * X, int ** Y ) {
    23     ((message &) this){ Finished };
     23    ((message &) this){ Nodelete };
    2424    this.Z = Z;
    2525    this.X = X;
    … …  
    108108
    109109        for ( unsigned int r = 0; r < xr; r += 1 ) {
    110                 actors[r] | messages[r];
     110                actors[r] << messages[r];
    111111        } // for
    112112

  • tests/concurrent/actors/pingpong.cfa

    r231e1ae r809e058  
    3232    Allocation retval = Nodelete;
    3333    if ( msg.count == times ) retval = Finished;
    34     *po | msg;
     34    *po << msg;
    3535    return retval;
    3636}
    … …  
    4242    Allocation retval = Nodelete;
    4343    if ( msg.count == times ) retval = Finished;
    44     *pi | msg;
     44    *pi << msg;
    4545    return retval;
    4646}
    … …  
    6060    pi = &pi_actor;
    6161    p_msg m;
    62     pi_actor | m;
     62    pi_actor << m;
    6363    stop_actor_system();
    6464

  • tests/concurrent/actors/static.cfa

    r231e1ae r809e058  
    3030    }
    3131    msg.cnt++;
    32     receiver | msg;
     32    receiver << msg;
    3333    return Nodelete;
    3434}
    … …  
    6060    derived_actor actor;
    6161
    62     actor | msg;
     62    actor << msg;
    6363
    6464    printf("stopping\n");

  • tests/concurrent/actors/types.cfa

    r231e1ae r809e058  
    7878    b.num = 1;
    7979    c.num = 2;
    80     a | b | c;
     80    a << b << c;
    8181    stop_actor_system();
    8282
    … …  
    8686    d_msg d_ac2_msg;
    8787    d_ac2_msg.num = 3;
    88     d_ac2_0 | d_ac2_msg;
    89     d_ac2_1 | d_ac2_msg;
     88    d_ac2_0 << d_ac2_msg;
     89    d_ac2_1 << d_ac2_msg;
    9090    stop_actor_system();
    9191
    … …  
    9999        d_msg d_ac23_msg;
    100100        d_ac23_msg.num = 4;
    101         d_ac3_0 | d_ac23_msg;
    102         d_ac2_2 | d_ac23_msg;
     101        d_ac3_0 << d_ac23_msg;
     102        d_ac2_2 << d_ac23_msg;
    103103        stop_actor_system();
    104104    } // RAII to clean up executor
    … …  
    113113        b1.num = -1;
    114114        c2.num = 5;
    115         a3 | b1 | c2;
     115        a3 << b1 << c2;
    116116        stop_actor_system();
    117117    } // RAII to clean up executor
Note: See TracChangeset for help on using the changeset viewer.