3 /* timer: repetitive and delayed actions */
5 /* Copyright (c) 2004 Martin Quinson. All rights reserved. */
7 /* This program is free software; you can redistribute it and/or modify it
8 * under the terms of the license (GNU LGPL) which comes with this package. */
10 int client(int argc,char *argv[]); /* Placed here to not bother doxygen inclusion */
14 XBT_LOG_NEW_DEFAULT_CATEGORY(test,"Logging specific to this test");
16 #define REPEAT_INTERVAL 1.0
17 #define DELAY_INTERVAL 2.0
24 static void repetitive_action(void) {
25 my_globals *globals=(my_globals*)gras_userdata_get();
27 /* Stop if nothing to do yet */
28 if (globals->still_to_do <= 0) {
29 INFO1("[%.0f] Repetitive_action has nothing to do yet",gras_os_time());
33 if (globals->still_to_do == 1) {
34 /* Unregister myself if I'm done */
35 gras_timer_cancel_repeat(REPEAT_INTERVAL,repetitive_action);
38 INFO2("[%.0f] repetitive_action decrementing globals->still_to_do. New value: %d",gras_os_time(),
39 globals->still_to_do-1);
41 globals->still_to_do--; /* should be the last line of the action since value=0 stops the program */
42 } /* end_of_repetitive_action */
44 static void delayed_action(void) {
45 my_globals *globals=(my_globals*)gras_userdata_get();
47 INFO2("[%.0f] delayed_action setting globals->still_to_do to %d",
48 gras_os_time(),LOOP_COUNT);
50 globals->still_to_do = LOOP_COUNT;
51 } /* end_of_delayed_action */
53 int client(int argc,char *argv[]) {
56 gras_init(&argc,argv);
57 globals=gras_userdata_new(my_globals);
58 globals->still_to_do = -1;
60 INFO2("[%.0f] Programming the repetitive_action with a frequency of %f sec", gras_os_time(), REPEAT_INTERVAL);
61 gras_timer_repeat(REPEAT_INTERVAL,repetitive_action);
63 INFO2("[%.0f] Programming the delayed_action for after %f sec", gras_os_time(), DELAY_INTERVAL);
64 gras_timer_delay(REPEAT_INTERVAL,delayed_action);
66 INFO1("[%.0f] Have a rest", gras_os_time());
67 gras_os_sleep(DELAY_INTERVAL / 2.0);
69 INFO1("[%.0f] Canceling the delayed_action.",gras_os_time());
70 gras_timer_cancel_delay(REPEAT_INTERVAL,delayed_action);
72 INFO2("[%.0f] Re-programming the delayed_action for after %f sec", gras_os_time(),DELAY_INTERVAL);
73 gras_timer_delay(REPEAT_INTERVAL,delayed_action);
75 while (globals->still_to_do == -1 || /* Before delayed action runs */
76 globals->still_to_do > 0 /* after delayed_action, and not enough repetitive_action */) {
78 DEBUG2("[%.0f] Prepare to handle messages for 5 sec (still_to_do=%d)",
79 gras_os_time(), globals->still_to_do);