X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/b3f79cb50f4397aea7de50ef1676bed24b813125..c30236b12db6409bae3a4e86b01eca20f36a6f21:/examples/gras/rpc/rpc.c diff --git a/examples/gras/rpc/rpc.c b/examples/gras/rpc/rpc.c index 96e9355bb5..f40a4cf5d7 100644 --- a/examples/gras/rpc/rpc.c +++ b/examples/gras/rpc/rpc.c @@ -11,9 +11,6 @@ XBT_LOG_NEW_DEFAULT_CATEGORY(Rpc,"Messages specific to this example"); -int err=0; /* to make the message of the raised exception more informative and - even be able to follow their propagation from server to client*/ - /* register messages which may be sent (common to client and server) */ static void register_messages(void) { gras_msgtype_declare_rpc("plain ping", @@ -30,9 +27,9 @@ int server (int argc,char *argv[]); int forwarder (int argc,char *argv[]); int client (int argc,char *argv[]); -static void exception_raising(void) { - /*THROW1(unknown_error,42,"Some error we will catch on client side %d",err++);*/ -} +#define exception_raising() \ + THROW0(unknown_error,42,"Some error we will catch on client side") + static void exception_catching(void) { int gotit = 0,i; xbt_ex_t e; @@ -109,7 +106,7 @@ int client(int argc,char *argv[]) { register_messages(); /* 6. Keep the user informed of what's going on */ - INFO2("Connected to server which is on %s:%d ", + INFO2("Connected to server which is on %s:%d", gras_socket_peer_name(toserver),gras_socket_peer_port(toserver)); /* 7. Prepare and send the ping message to the server */ @@ -124,7 +121,7 @@ int client(int argc,char *argv[]) { exception_catching(); /* 8. Keep the user informed of what's going on, again */ - INFO4("The answer to PING(%d) on %s:%d is PONG(%d) ", + INFO4("The answer to PING(%d) on %s:%d is PONG(%d)", ping, gras_socket_peer_name(toserver),gras_socket_peer_port(toserver), pong); @@ -199,8 +196,8 @@ int client(int argc,char *argv[]) { /* 11. Cleanup the place before leaving */ gras_socket_close(toserver); gras_socket_close(toforwarder); - gras_exit(); INFO0("Done."); + gras_exit(); return 0; } /* end_of_client */ @@ -262,8 +259,8 @@ int forwarder (int argc,char *argv[]) { gras_socket_close(mysock); gras_socket_close(fdata->server); free(fdata); - gras_exit(); INFO0("Done."); + gras_exit(); return 0; } @@ -301,7 +298,7 @@ static int server_cb_ping(gras_msg_cb_ctx_t ctx, gras_socket_t expeditor = gras_msg_cb_ctx_from(ctx); /* 2. Log which client connected */ - INFO3("Got message PING(%d) from %s:%d ", + INFO3("Got message PING(%d) from %s:%d", msg, gras_socket_peer_name(expeditor), gras_socket_peer_port(expeditor)); @@ -346,7 +343,7 @@ int server (int argc,char *argv[]) { gras_cb_register("raise exception",&server_cb_raise_ex); gras_cb_register("kill",&server_cb_kill); - INFO1("Listening on port %d ", gras_socket_my_port(mysock)); + INFO1("Listening on port %d", gras_socket_my_port(mysock)); /* 5. Wait for the ping incomming messages */ @@ -382,9 +379,9 @@ int server (int argc,char *argv[]) { /* 8. Free the allocated resources, and shut GRAS down */ free(sdata); gras_socket_close(mysock); + INFO0("Done."); gras_exit(); - INFO0("Done."); return 0; } /* end_of_server */