X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/6760cb07d6b57be16928d95339d71e57c4e24f36..9d7e857328377861f81e95fbc3138032b51b7da9:/teshsuite/gras/msg_handle/msg_handle.c

diff --git a/teshsuite/gras/msg_handle/msg_handle.c b/teshsuite/gras/msg_handle/msg_handle.c
index 678115b1d7..675cb00c4d 100644
--- a/teshsuite/gras/msg_handle/msg_handle.c
+++ b/teshsuite/gras/msg_handle/msg_handle.c
@@ -1,5 +1,3 @@
-/* $Id: mmrpc.c 3399 2007-04-11 19:34:43Z cherierm $ */
-
 /* msg_handle - ensures the semantic of gras_msg_handle(i) for i<0,=0 or >0 */
 
 /* Copyright (c) 2007, 2008, 2009, 2010. The SimGrid Team.
@@ -16,65 +14,69 @@ XBT_LOG_NEW_DEFAULT_CATEGORY(test, "Messages specific to this test");
 int server(int argc, char *argv[]);
 int client(int argc, char *argv[]);
 
-static int server_cb_hello_handler(gras_msg_cb_ctx_t ctx, void *payload_data)
+static int server_cb_hello_handler(gras_msg_cb_ctx_t ctx,
+                                   void *payload_data)
 {
-  INFO0("Got the message");
+  XBT_INFO("Got the message");
   return 0;
 }
 
 int server(int argc, char *argv[])
 {
-  gras_socket_t me = NULL, pal = NULL;
+  volatile xbt_socket_t me = NULL, pal = NULL;
   int myport;
   char *palstr;
 
   xbt_ex_t e;
-  int got_expected;
-  double now;
+  _XBT_GNUC_UNUSED int got_expected;
+  _XBT_GNUC_UNUSED double now;
 
 
   gras_init(&argc, argv);
 
-  xbt_assert0(argc == 3, "Usage: server <myport> <client>");
+  xbt_assert(argc == 3, "Usage: server <myport> <client>");
   myport = atoi(argv[1]);
   palstr = argv[2];
 
   gras_msgtype_declare("hello", NULL);
   gras_cb_register("hello", &server_cb_hello_handler);
 
-  INFO1("Launch server (port=%d)", myport);
+  XBT_INFO("Launch server (port=%d)", myport);
   TRY {
     me = gras_socket_server(myport);
-  } CATCH(e) {
-    RETHROW0("Unable to establish a server socket: %s");
+  }
+  CATCH_ANONYMOUS {
+    RETHROWF("Unable to establish a server socket: %s");
   }
   gras_os_sleep(1);             /* Wait for pal to startup */
   TRY {
     pal = gras_socket_client_from_string(palstr);
-  } CATCH(e) {
-    RETHROW1("Unable to establish a socket to %s: %s", palstr);
   }
-  INFO0("Initialization done.");
+  CATCH_ANONYMOUS {
+    RETHROWF("Unable to establish a socket to %s: %s", palstr);
+  }
+  XBT_INFO("Initialization done.");
   now = gras_os_time();
 
   /* Launch handle(0) when there is no message. Timeout expected */
   got_expected = 0;
   TRY {
     gras_msg_handle(0);
-  } CATCH(e) {
+  }
+  CATCH(e) {
     if (e.category == timeout_error) {
       got_expected = 1;
       xbt_ex_free(e);
     } else {
-      RETHROW0("Didn't got the expected timeout: %s");
+      RETHROWF("Didn't got the expected timeout: %s");
     }
   }
-  xbt_assert0(got_expected,
+  xbt_assert(got_expected,
               "gras_msg_handle(0) do not lead to any timeout exception");
-  xbt_assert1(gras_os_time() - now < 0.01,
+  xbt_assert(gras_os_time() - now < 0.01,
               "gras_msg_handle(0) do not anwser immediately (%.4fsec)",
               gras_os_time() - now);
-  INFO0("gras_msg_handle(0) works as expected (immediate timeout)");
+  XBT_INFO("gras_msg_handle(0) works as expected (immediate timeout)");
   /* Launch handle(0) when there is no message. Timeout expected */
   got_expected = 0;
   TRY {
@@ -85,22 +87,22 @@ int server(int argc, char *argv[])
       got_expected = 1;
       xbt_ex_free(e);
     } else {
-      RETHROW0("Didn't got the expected timeout: %s");
+      RETHROWF("Didn't got the expected timeout: %s");
     }
   }
-  xbt_assert0(got_expected,
+  xbt_assert(got_expected,
               "gras_msg_handle(1) do not lead to any timeout exception");
-  xbt_assert1(gras_os_time() - now < 1.5,
+  xbt_assert(gras_os_time() - now < 1.5,
               "gras_msg_handle(1) needs more than 1.5 sec to answer (%.4fsec)",
               gras_os_time() - now);
-  xbt_assert1(gras_os_time() - now >= 1.0,
+  xbt_assert(gras_os_time() - now >= 1.0,
               "gras_msg_handle(1) answers in less than one second (%.4fsec)",
               gras_os_time() - now);
-  INFO0("gras_msg_handle(1) works as expected (delayed timeout)");
+  XBT_INFO("gras_msg_handle(1) works as expected (delayed timeout)");
   gras_os_sleep(3);
 
   /* Send an hello to the client to unlock it */
-  INFO0("Unlock pal");
+  XBT_INFO("Unlock pal");
   gras_msg_send(pal, "hello", NULL);
 
   /* Frees the allocated resources, and shut GRAS down */
@@ -112,44 +114,42 @@ int server(int argc, char *argv[])
 
 int client(int argc, char *argv[])
 {
-  gras_socket_t me = NULL, pal = NULL;
+  volatile xbt_socket_t me = NULL, pal = NULL;
   int myport;
   char *palstr;
 
-  xbt_ex_t e;
-  int got_expected;
-
-
   gras_init(&argc, argv);
-  xbt_assert0(argc == 3, "Usage: client <myport> <server>");
+  xbt_assert(argc == 3, "Usage: client <myport> <server>");
   myport = atoi(argv[1]);
   palstr = argv[2];
 
   gras_msgtype_declare("hello", NULL);
   gras_cb_register("hello", &server_cb_hello_handler);
 
-  INFO1("Launch client (port=%d)", myport);
+  XBT_INFO("Launch client (port=%d)", myport);
   TRY {
     me = gras_socket_server(myport);
-  } CATCH(e) {
-    RETHROW0("Unable to establish a server socket: %s");
+  }
+  CATCH_ANONYMOUS {
+    RETHROWF("Unable to establish a server socket: %s");
   }
   gras_os_sleep(1);             /* Wait for pal to startup */
   TRY {
     pal = gras_socket_client_from_string(palstr);
-  } CATCH(e) {
-    RETHROW1("Unable to establish a socket to %s: %s", palstr);
   }
-  INFO0("Initialization done.");
+  CATCH_ANONYMOUS {
+    RETHROWF("Unable to establish a socket to %s: %s", palstr);
+  }
+  XBT_INFO("Initialization done.");
 
   /* Launch handle(-1). Lock until message from server expected */
-  got_expected = 0;
   TRY {
     gras_msg_handle(-1);
-  } CATCH(e) {
-    RETHROW0("No exception expected during handle(-1), but got %s");
   }
-  INFO0("gras_msg_handle(-1) works as expected (locked)");
+  CATCH_ANONYMOUS {
+    RETHROWF("No exception expected during handle(-1), but got %s");
+  }
+  XBT_INFO("gras_msg_handle(-1) works as expected (locked)");
 
   /* Frees the allocated resources, and shut GRAS down */
   gras_socket_close(me);