Changeset 7edf912 for tests/concurrency/actors/executor.cfa

Timestamp:

Sep 17, 2023, 10:17:50 PM (10 months ago)

Author:

Peter A. Buhr <pabuhr@…>

Branches:

master

Children:

a2c2363

Parents:

50be8af

Message:

formatting, replace constructor calls with set_allocation calls

File:

• tests/concurrency/actors/executor.cfa (modified) (5 diffs)

tests/concurrency/actors/executor.cfa

@@ -10 +10 @@
 static int ids = 0;
 struct d_actor { 
-    inline actor;
-    d_actor * gstart;
-    int id, rounds, recs, sends;
+        inline actor;
+        d_actor * gstart;
+        int id, rounds, recs, sends;
 };
 void ?{}( d_actor & this ) with(this) {
-    id = ids++;
-    gstart = (&this + (id / Set * Set - id)); // remember group-start array-element
-    rounds = Set * Rounds;      // send at least one message to each group member
-    recs = 0;
-    sends = 0;
+        id = ids++;
+        gstart = (&this + (id / Set * Set - id)); // remember group-start array-element
+        rounds = Set * Rounds;  // send at least one message to each group member
+        recs = 0;
+        sends = 0;
 }
 
@@ -25 +25 @@
 
 allocation receive( d_actor & this, d_msg & msg ) with( this ) {
-    if ( recs == rounds ) return Finished;
-    if ( recs % Batch == 0 ) {
-        for ( i; Batch ) {
-            gstart[sends % Set] | shared_msg;
-            sends += 1;
-        }
-    }
-    recs += 1;
-    return Nodelete;
+        if ( recs == rounds ) return Finished;
+        if ( recs % Batch == 0 ) {
+                for ( i; Batch ) {
+                        gstart[sends % Set] | shared_msg;
+                        sends += 1;
+                }
+        }
+        recs += 1;
+        return Nodelete;
 }
 
 int main( int argc, char * argv[] ) {
-    switch ( argc ) {
+        switch ( argc ) {
           case 7:
                 if ( strcmp( argv[6], "d" ) != 0 ) {                    // default ?
@@ -72 +72 @@
           default:
                 exit | "Usage: " | argv[0]
-             | " [ actors (> 0 && > set && actors % set == 0 ) | 'd' (default " | Actors
+                         | " [ actors (> 0 && > set && actors % set == 0 ) | 'd' (default " | Actors
                          | ") ] [ set (> 0) | 'd' (default " | Set
                          | ") ] [ rounds (> 0) | 'd' (default " | Rounds
@@ -81 +81 @@
         } // switch
 
-    executor e{ Processors, Processors, Processors == 1 ? 1 : Processors * 512, true };
+        executor e{ Processors, Processors, Processors == 1 ? 1 : Processors * 512, true };
 
-    sout | "starting";
+        sout | "starting";
 
-    start_actor_system( e );
+        start_actor_system( e );
 
-    sout | "started";
+        sout | "started";
 
-    d_actor actors[ Actors ];
+        d_actor actors[ Actors ];
 
         for ( i; Actors ) {
@@ -95 +95 @@
         } // for
 
-    sout | "stopping";
+        sout | "stopping";
 
-    stop_actor_system();
+        stop_actor_system();
 
-    sout | "stopped";
-
-    return 0;
+        sout | "stopped";
 }