source:
tests/concurrency/actors/dynamic.cfa
@
d7b399f
Last change on this file since d7b399f was 9cbdc13, checked in by , 10 months ago | |
---|---|
|
|
File size: 1.2 KB |
Rev | Line | |
---|---|---|
[dab2b6a] | 1 | #include <actor.hfa> |
2 | #include <fstream.hfa> | |
3 | #include <stdlib.hfa> | |
4 | #include <string.h> | |
5 | #include <stdio.h> | |
6 | ||
[1f35220] | 7 | int Times = 1000000; // default values |
[dab2b6a] | 8 | |
[4933f18] | 9 | struct derived_actor { inline actor; }; |
[dab2b6a] | 10 | struct derived_msg { |
[7edf912] | 11 | inline message; |
12 | int cnt; | |
[dab2b6a] | 13 | }; |
14 | ||
15 | void ?{}( derived_msg & this, int cnt ) { | |
[7edf912] | 16 | set_allocation( this, Delete ); |
17 | this.cnt = cnt; | |
[dab2b6a] | 18 | } |
19 | void ?{}( derived_msg & this ) { ((derived_msg &)this){ 0 }; } | |
20 | ||
[c880a7b] | 21 | allocation 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 | ||
34 | int 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.