doc/gtut-files/07-timers.c

   1 #include <gras.h>
   2
   3 XBT_LOG_NEW_DEFAULT_CATEGORY(test,"My little example");
   4
   5 /* *********************** Server *********************** */
   6 typedef struct {
   7    int killed;
   8 } server_data_t;
   9
  10 int server_kill_cb(gras_msg_cb_ctx_t ctx, void *payload) {
  11   gras_socket_t client = gras_msg_cb_ctx_from(ctx);
  12   server_data_t *globals=(server_data_t*)gras_userdata_get();
  13
  14   CRITICAL2("Argh, killed by %s:%d! Bye folks...",
  15         gras_socket_peer_name(client), gras_socket_peer_port(client));
  16
  17   globals->killed = 1;
  18
  19   return 0;
  20 } /* end_of_kill_callback */
  21
  22 int server_hello_cb(gras_msg_cb_ctx_t ctx, void *payload) {
  23   gras_socket_t client = gras_msg_cb_ctx_from(ctx);
  24
  25   INFO2("Cool, we received the message from %s:%d.",
  26         gras_socket_peer_name(client), gras_socket_peer_port(client));
  27
  28   return 0;
  29 } /* end_of_hello_callback */
  30
  31 int server(int argc, char *argv[]) {
  32   gras_socket_t mysock;   /* socket on which I listen */
  33   server_data_t *globals;
  34
  35   gras_init(&argc,argv);
  36
  37   globals=gras_userdata_new(server_data_t*);
  38   globals->killed=0;
  39
  40   gras_msgtype_declare("hello", NULL);
  41   gras_msgtype_declare("kill", NULL);
  42   mysock = gras_socket_server(atoi(argv[1]));
  43
  44   gras_cb_register("hello",&server_hello_cb);
  45   gras_cb_register("kill",&server_kill_cb);
  46
  47   while (!globals->killed) {
  48      gras_msg_handle(60);
  49   }
  50
  51   gras_exit();
  52   return 0;
  53 }
  54
  55 /* *********************** Client *********************** */
  56 /* client_data */
  57 typedef struct {
  58    gras_socket_t toserver;
  59    int done;
  60 } client_data_t;
  61
  62
  63 void client_do_hello(void) {
  64   client_data_t *globals=(client_data_t*)gras_userdata_get();
  65
  66   gras_msg_send(globals->toserver,"hello", NULL);
  67   INFO0("Hello sent to server");
  68 } /* end_of_client_do_hello */
  69
  70 void client_do_stop(void) {
  71   client_data_t *globals=(client_data_t*)gras_userdata_get();
  72
  73   gras_msg_send(globals->toserver,"kill", NULL);
  74   INFO0("Kill sent to server");
  75
  76   gras_timer_cancel_repeat(0.5,client_do_hello);
  77
  78   globals->done = 1;
  79   INFO0("Break the client's while loop");
  80 } /* end_of_client_do_stop */
  81
  82 int client(int argc, char *argv[]) {
  83   gras_socket_t mysock;   /* socket on which I listen */
  84   client_data_t *globals;
  85
  86   gras_init(&argc,argv);
  87
  88   gras_msgtype_declare("hello", NULL);
  89   gras_msgtype_declare("kill", NULL);
  90   mysock = gras_socket_server_range(1024, 10000, 0, 0);
  91
  92   VERB1("Client ready; listening on %d", gras_socket_my_port(mysock));
  93
  94   globals=gras_userdata_new(server_data_t*);
  95   globals->done = 0;
  96
  97   gras_os_sleep(1.5); /* sleep 1 second and half */
  98   globals->toserver = gras_socket_client(argv[1], atoi(argv[2]));
  99
 100   INFO0("Programming the repetitive action with a frequency of 0.5 sec");
 101   gras_timer_repeat(0.5,client_do_hello);
 102
 103   INFO0("Programming the delayed action in 5 secs");
 104   gras_timer_delay(5,client_do_stop);
 105
 106   while (!globals->done) {
 107      gras_msg_handle(60);
 108   }
 109
 110   gras_exit();
 111   return 0;
 112 }
 113