X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/6760cb07d6b57be16928d95339d71e57c4e24f36..43a86622d96c8ea32510b5406644b17a060eb6ac:/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..dcc37ce412 100644 --- a/teshsuite/gras/msg_handle/msg_handle.c +++ b/teshsuite/gras/msg_handle/msg_handle.c @@ -16,9 +16,10 @@ 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; } @@ -35,26 +36,26 @@ int server(int argc, char *argv[]) gras_init(&argc, argv); - xbt_assert0(argc == 3, "Usage: server "); + xbt_assert(argc == 3, "Usage: server "); 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"); + 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); + RETHROWF("Unable to establish a socket to %s: %s", palstr); } - INFO0("Initialization done."); + XBT_INFO("Initialization done."); now = gras_os_time(); /* Launch handle(0) when there is no message. Timeout expected */ @@ -66,15 +67,15 @@ 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(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 +86,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 */ @@ -121,35 +122,35 @@ int client(int argc, char *argv[]) gras_init(&argc, argv); - xbt_assert0(argc == 3, "Usage: client "); + xbt_assert(argc == 3, "Usage: client "); 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"); + 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); + RETHROWF("Unable to establish a socket to %s: %s", palstr); } - INFO0("Initialization done."); + 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"); + RETHROWF("No exception expected during handle(-1), but got %s"); } - INFO0("gras_msg_handle(-1) works as expected (locked)"); + XBT_INFO("gras_msg_handle(-1) works as expected (locked)"); /* Frees the allocated resources, and shut GRAS down */ gras_socket_close(me);