source: tests/concurrent/actors/dynamic.cfa @ 046ba23

ADTast-experimental
Last change on this file since 046ba23 was 809e058, checked in by caparsons <caparson@…>, 20 months ago

changed actor tests to reflect syntax change and some small changes due to other features

  • Property mode set to 100644
File size: 1.5 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
9struct derived_actor {
10    inline actor;
11};
12void ?{}( derived_actor & this ) { ((actor &)this){}; }
13
14struct derived_msg {
15    inline message;
16    int cnt;
17};
18
19void ?{}( derived_msg & this, int cnt ) {
20    ((message &) this){ Delete };
21    this.cnt = cnt;
22}
23void ?{}( derived_msg & this ) { ((derived_msg &)this){ 0 }; }
24
25
26Allocation receive( derived_actor & receiver, derived_msg & msg ) {
27    if ( msg.cnt >= Times ) {
28        sout | "Done";
29        return Delete;
30    }
31    derived_msg * d_msg = alloc();
32    (*d_msg){ msg.cnt + 1 };
33    derived_actor * d_actor = alloc();
34    (*d_actor){};
[809e058]35    *d_actor << *d_msg;
[dab2b6a]36    return Delete;
37}
38
39int main( int argc, char * argv[] ) {
40    switch ( argc ) {
41          case 2:
42                if ( strcmp( argv[1], "d" ) != 0 ) {                    // default ?
43                        Times = atoi( argv[1] );
44                        if ( Times < 1 ) goto Usage;
45                } // if
46          case 1:                                                                                       // use defaults
47                break;
48          default:
49          Usage:
50                sout | "Usage: " | argv[0] | " [ times (> 0) ]";
51                exit( EXIT_FAILURE );
52        } // switch
53
54    printf("starting\n");
55
56    executor e{ 0, 1, 1, false };
57    start_actor_system( e );
58
59    printf("started\n");
60
61    derived_msg * d_msg = alloc();
62    (*d_msg){};
63    derived_actor * d_actor = alloc();
64    (*d_actor){};
[809e058]65    *d_actor << *d_msg;
[dab2b6a]66
67    printf("stopping\n");
68
69    stop_actor_system();
70
71    printf("stopped\n");
72
73    return 0;
74}
Note: See TracBrowser for help on using the repository browser.