Changeset 05956d21

Timestamp:

Jun 17, 2023, 9:30:32 AM (17 months ago)

Author:

caparsons <caparson@…>

Branches:

master

Children:

77fd9fe2

Parents:

086d6b8

Message:

refactored benchmarks to use actor bar operator

Location:

doc/theses/colby_parsons_MMAth/benchmarks/actors/cfa

Files:

• balance.cfa (modified) (3 diffs)
• dynamic.cfa (modified) (2 diffs)
• executor.cfa (modified) (2 diffs)
• matrix.cfa (modified) (1 diff)
• repeat.cfa (modified) (4 diffs)
• static.cfa (modified) (2 diffs)

doc/theses/colby_parsons_MMAth/benchmarks/actors/cfa/balance.cfa

@@ -33 +33 @@
 allocation receive( d_actor & this, start_msg & msg ) with( this ) {
     for ( i; Set ) {
-        *actor_arr[i + gstart] << shared_msg;
+        *actor_arr[i + gstart] | shared_msg;
     }
     return Nodelete;
@@ -42 +42 @@
     if ( recs % Batch == 0 ) {
         for ( i; Batch ) {
-            *actor_arr[gstart + sends % Set] << shared_msg;
+            *actor_arr[gstart + sends % Set] | shared_msg;
             sends += 1;
         }
@@ -163 +163 @@
     #ifndef MULTI
         for ( i; qpw )
-                *actors[i * ActorsPerQueue] << start_send;
+                *actors[i * ActorsPerQueue] | start_send;
     #else
     for ( i; qpw * ActorProcs ) {
-                *actors[i * ActorsPerQueue] << start_send;
+                *actors[i * ActorsPerQueue] | start_send;
     }
     #endif
     
     for ( i; FillActors ) 
-        *filler_actors[i] << shared_msg;
+        *filler_actors[i] | shared_msg;
 
     stop_actor_system();

doc/theses/colby_parsons_MMAth/benchmarks/actors/cfa/dynamic.cfa

@@ -33 +33 @@
     derived_actor * d_actor = malloc();
     (*d_actor){};
-    *d_actor << *d_msg;
+    *d_actor | *d_msg;
     return Delete;
 }
@@ -62 +62 @@
     derived_actor * d_actor = malloc();
     (*d_actor){};
-    *d_actor << *d_msg;
+    *d_actor | *d_msg;
 
 

doc/theses/colby_parsons_MMAth/benchmarks/actors/cfa/executor.cfa

@@ -29 +29 @@
     if ( recs % Batch == 0 ) {
         for ( i; Batch ) {
-            gstart[sends % Set] << shared_msg;
+            gstart[sends % Set] | shared_msg;
             sends += 1;
         }
@@ -94 +94 @@
 
         for ( i; Actors ) {
-                actors[i] << shared_msg;
+                actors[i] | shared_msg;
         } // for
 

doc/theses/colby_parsons_MMAth/benchmarks/actors/cfa/matrix.cfa

@@ -103 +103 @@
 
         for ( unsigned int r = 0; r < xr; r += 1 ) {
-                actors[r] << messages[r];
+                actors[r] | messages[r];
         } // for
 

doc/theses/colby_parsons_MMAth/benchmarks/actors/cfa/repeat.cfa

@@ -46 +46 @@
 
 Client * cl;
-allocation receive( Server & this, IntMsg & msg ) { msg.val = 7; *cl << msg; return Nodelete; }
-allocation receive( Server & this, CharMsg & msg ) { msg.val = 'x'; *cl << msg; return Nodelete; }
+allocation receive( Server & this, IntMsg & msg ) { msg.val = 7; *cl | msg; return Nodelete; }
+allocation receive( Server & this, CharMsg & msg ) { msg.val = 'x'; *cl | msg; return Nodelete; }
 allocation receive( Server & this, StateMsg & msg ) { return Finished; }
 
 void terminateServers( Client & this ) with(this) {
     for ( i; Messages ) {
-        servers[i] << stateMsg;
+        servers[i] | stateMsg;
     } // for
 }
@@ -60 +60 @@
     if ( times == Times ) { terminateServers( this ); return Finished; }
     results = 0;
-    this << stateMsg;
+    this | stateMsg;
     return Nodelete;
 }
@@ -74 +74 @@
 allocation receive( Client & this, StateMsg & msg ) with(this) {
     for ( i; Messages ) {
-        servers[i] << intmsg[i];
-        servers[i] << charmsg[i];
+        servers[i] | intmsg[i];
+        servers[i] | charmsg[i];
     }
     return Nodelete;
@@ -124 +124 @@
     Client client;
     cl = &client;
-    client << stateMsg;
+    client | stateMsg;
 
     stop_actor_system();

doc/theses/colby_parsons_MMAth/benchmarks/actors/cfa/static.cfa

@@ -29 +29 @@
     }
     msg.cnt++;
-    receiver << msg;
+    receiver | msg;
     return Nodelete;
 }
@@ -58 +58 @@
     derived_actor actor;
 
-    actor << msg;
+    actor | msg;
 
     stop_actor_system();