source: tests/concurrency/actors/static.cfa@ c7f9f53

Last change on this file since c7f9f53 was 9cbdc13, checked in by caparson <caparson@…>, 2 years ago

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

  • Property mode set to 100644
File size: 1.1 KB
RevLine 
[757099e]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
[757099e]8
[4933f18]9struct derived_actor { inline actor; };
[757099e]10struct derived_msg {
[7edf912]11 inline message;
12 int cnt;
[757099e]13};
14
15void ?{}( derived_msg & this, int cnt ) {
[7edf912]16 set_allocation( this, Nodelete );
17 this.cnt = cnt;
[757099e]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 Finished;
25 }
26 msg.cnt++;
27 receiver | msg;
28 return Nodelete;
[757099e]29}
30
31int main( int argc, char * argv[] ) {
[7edf912]32 switch ( argc ) {
[757099e]33 case 2:
34 if ( strcmp( argv[1], "d" ) != 0 ) { // default ?
[50be8af5]35 Times = ato( argv[1] );
36 if ( Times < 1 ) fallthru default;
[757099e]37 } // if
38 case 1: // use defaults
39 break;
40 default:
[50be8af5]41 exit | "Usage: " | argv[0] | " [ times (> 0) ]";
[757099e]42 } // switch
43
[7edf912]44 sout | "starting";
[757099e]45
[7edf912]46 executor e{ 0, 1, 1, false };
47 start_actor_system( e );
[757099e]48
[7edf912]49 sout | "started";
[757099e]50
[7edf912]51 derived_msg msg;
[757099e]52
[7edf912]53 derived_actor actor;
[757099e]54
[7edf912]55 actor | msg;
[757099e]56
[7edf912]57 stop_actor_system();
[757099e]58
[7edf912]59 sout | "stopped";
[50be8af5]60}
Note: See TracBrowser for help on using the repository browser.