source: tests/concurrency/actors/dynamic.cfa @ de3a579

Last change on this file since de3a579 was 9cbdc13, checked in by caparson <caparson@…>, 12 months ago

removed print from static and dynamic tests that could be reordered due to a race

  • Property mode set to 100644
File size: 1.2 KB
RevLine 
[dab2b6a]1#include <actor.hfa>
2#include <fstream.hfa>
3#include <stdlib.hfa>
4#include <string.h>
5#include <stdio.h>
6
[1f35220]7int Times = 1000000;                                                            // default values
[dab2b6a]8
[4933f18]9struct derived_actor { inline actor; };
[dab2b6a]10struct derived_msg {
[7edf912]11        inline message;
12        int cnt;
[dab2b6a]13};
14
15void ?{}( derived_msg & this, int cnt ) {
[7edf912]16        set_allocation( this, Delete );
17        this.cnt = cnt;
[dab2b6a]18}
19void ?{}( derived_msg & this ) { ((derived_msg &)this){ 0 }; }
20
[c880a7b]21allocation receive( derived_actor & receiver, derived_msg & msg ) {
[7edf912]22        if ( msg.cnt >= Times ) {
23                sout | "Done";
24                return Delete;
25        }
26        derived_msg * d_msg = alloc();
27        (*d_msg){ msg.cnt + 1 };
28        derived_actor * d_actor = alloc();
29        (*d_actor){};
30        *d_actor | *d_msg;
31        return Delete;
[dab2b6a]32}
33
34int main( int argc, char * argv[] ) {
[7edf912]35        switch ( argc ) {
[dab2b6a]36          case 2:
37                if ( strcmp( argv[1], "d" ) != 0 ) {                    // default ?
[50be8af]38                        Times = ato( argv[1] );
39                        if ( Times < 1 ) fallthru default;
[dab2b6a]40                } // if
41          case 1:                                                                                       // use defaults
42                break;
43          default:
[50be8af]44                exit | "Usage: " | argv[0] | " [ times (> 0) ]";
[dab2b6a]45        } // switch
46
[7edf912]47        sout | "starting";
[dab2b6a]48
[7edf912]49        executor e{ 0, 1, 1, false };
50        start_actor_system( e );
[dab2b6a]51
[7edf912]52        sout | "started";
[dab2b6a]53
[7edf912]54        derived_msg * d_msg = alloc();
55        (*d_msg){};
56        derived_actor * d_actor = alloc();
57        (*d_actor){};
58        *d_actor | *d_msg;
[dab2b6a]59
[7edf912]60        stop_actor_system();
[dab2b6a]61
[7edf912]62        sout | "stopped";
[50be8af]63}
Note: See TracBrowser for help on using the repository browser.