- Timestamp:
- Mar 4, 2023, 1:46:44 PM (19 months ago)
- Branches:
- ADT, ast-experimental, master
- Children:
- 046ba23
- Parents:
- 231e1ae
- Location:
- tests/concurrent/actors
- Files:
-
- 6 edited
Legend:
- Unmodified
- Added
- Removed
-
tests/concurrent/actors/dynamic.cfa
r231e1ae r809e058 33 33 derived_actor * d_actor = alloc(); 34 34 (*d_actor){}; 35 *d_actor |*d_msg;35 *d_actor << *d_msg; 36 36 return Delete; 37 37 } … … 63 63 derived_actor * d_actor = alloc(); 64 64 (*d_actor){}; 65 *d_actor |*d_msg;65 *d_actor << *d_msg; 66 66 67 67 printf("stopping\n"); -
tests/concurrent/actors/executor.cfa
r231e1ae r809e058 30 30 if ( recs % Batch == 0 ) { 31 31 for ( i; Batch ) { 32 gstart[sends % Set] |shared_msg;32 gstart[sends % Set] << shared_msg; 33 33 sends += 1; 34 34 } … … 97 97 98 98 for ( i; Actors ) { 99 actors[i] |shared_msg;99 actors[i] << shared_msg; 100 100 } // for 101 101 -
tests/concurrent/actors/matrix.cfa
r231e1ae r809e058 21 21 void ?{}( derived_msg & this ) {} 22 22 void ?{}( derived_msg & this, int * Z, int * X, int ** Y ) { 23 ((message &) this){ Finished};23 ((message &) this){ Nodelete }; 24 24 this.Z = Z; 25 25 this.X = X; … … 108 108 109 109 for ( unsigned int r = 0; r < xr; r += 1 ) { 110 actors[r] |messages[r];110 actors[r] << messages[r]; 111 111 } // for 112 112 -
tests/concurrent/actors/pingpong.cfa
r231e1ae r809e058 32 32 Allocation retval = Nodelete; 33 33 if ( msg.count == times ) retval = Finished; 34 *po |msg;34 *po << msg; 35 35 return retval; 36 36 } … … 42 42 Allocation retval = Nodelete; 43 43 if ( msg.count == times ) retval = Finished; 44 *pi |msg;44 *pi << msg; 45 45 return retval; 46 46 } … … 60 60 pi = &pi_actor; 61 61 p_msg m; 62 pi_actor |m;62 pi_actor << m; 63 63 stop_actor_system(); 64 64 -
tests/concurrent/actors/static.cfa
r231e1ae r809e058 30 30 } 31 31 msg.cnt++; 32 receiver |msg;32 receiver << msg; 33 33 return Nodelete; 34 34 } … … 60 60 derived_actor actor; 61 61 62 actor |msg;62 actor << msg; 63 63 64 64 printf("stopping\n"); -
tests/concurrent/actors/types.cfa
r231e1ae r809e058 78 78 b.num = 1; 79 79 c.num = 2; 80 a | b |c;80 a << b << c; 81 81 stop_actor_system(); 82 82 … … 86 86 d_msg d_ac2_msg; 87 87 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; 90 90 stop_actor_system(); 91 91 … … 99 99 d_msg d_ac23_msg; 100 100 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; 103 103 stop_actor_system(); 104 104 } // RAII to clean up executor … … 113 113 b1.num = -1; 114 114 c2.num = 5; 115 a3 | b1 |c2;115 a3 << b1 << c2; 116 116 stop_actor_system(); 117 117 } // RAII to clean up executor
Note: See TracChangeset
for help on using the changeset viewer.