doc/gtut-files/06-logs.c

   1 #include <gras.h>
   2
   3 XBT_LOG_NEW_DEFAULT_CATEGORY(test,"My little example");
   4
   5 typedef struct {
   6    int killed;
   7 } server_data_t;
   8
   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(-1); /* blocking */
  49   }
  50
  51   gras_exit();
  52   return 0;
  53 }
  54
  55 int client(int argc, char *argv[]) {
  56   gras_socket_t mysock;   /* socket on which I listen */
  57   gras_socket_t toserver; /* socket used to write to the server */
  58
  59   gras_init(&argc,argv);
  60
  61   gras_msgtype_declare("hello", NULL);
  62   gras_msgtype_declare("kill", NULL);
  63   mysock = gras_socket_server_range(1024, 10000, 0, 0);
  64
  65   VERB1("Client ready; listening on %d", gras_socket_my_port(mysock));
  66
  67   gras_os_sleep(1.5); /* sleep 1 second and half */
  68   toserver = gras_socket_client(argv[1], atoi(argv[2]));
  69
  70   gras_msg_send(toserver,"hello", NULL);
  71   INFO1("we sent the data to the server on %s. Let's do it again for fun", gras_socket_peer_name(toserver));
  72   gras_msg_send(toserver,"hello", NULL);
  73
  74   INFO0("Ok. Enough. Have a rest, and then kill the server");
  75   gras_os_sleep(5); /* sleep 1 second and half */
  76   gras_msg_send(toserver,"kill", NULL);
  77
  78   gras_exit();
  79   return 0;
  80 }