X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/a91fb1920bacd2a982a7e7cc341d2fea6617ade0..fd28ea3d66eee426ac29108bc8a5d4f017dc326d:/examples/ping/ping.c diff --git a/examples/ping/ping.c b/examples/ping/ping.c index aa7ad2fd6e..800df8b20d 100644 --- a/examples/ping/ping.c +++ b/examples/ping/ping.c @@ -12,9 +12,9 @@ #include #include -#include +#include "gras.h" -GRAS_LOG_NEW_DEFAULT_CATEGORY(Ping); +GRAS_LOG_NEW_DEFAULT_CATEGORY(Ping,"Messages specific to this example"); /* ********************************************************************** * Comon code @@ -25,16 +25,13 @@ typedef struct { } msg_ping_t; /* Function prototypes */ -gras_error_t register_messages(void); +void register_messages(void); /* Code */ -gras_error_t register_messages(void) { - gras_error_t errcode; - - TRY(gras_msgtype_declare("ping", gras_datadesc_by_name("int"))); - TRY(gras_msgtype_declare("pong", gras_datadesc_by_name("int"))); +void register_messages(void) { - return no_error; + gras_msgtype_declare("ping", gras_datadesc_by_name("int")); + gras_msgtype_declare("pong", gras_datadesc_by_name("int")); } /* ********************************************************************** @@ -69,8 +66,7 @@ int server_cb_ping_handler(gras_socket_t *expeditor, gras_socket_peer_port(expeditor)); msg = 4321; - TRY(gras_msgtype_by_name("pong",&pong_t)); - errcode = gras_msg_send(expeditor, pong_t, &msg); + errcode = gras_msg_send(expeditor, gras_msgtype_by_name("pong"), &msg); if (errcode != no_error) { ERROR1("SERVER: Unable answer with PONG: %s\n", gras_error_name(errcode)); @@ -106,10 +102,9 @@ int server (int argc,char *argv[]) { return 1; } - TRYFAIL(register_messages()); - TRYFAIL(register_messages()); - TRYFAIL(gras_msgtype_by_name("ping",&ping_msg)); - TRYFAIL(gras_cb_register(ping_msg,&server_cb_ping_handler)); + register_messages(); + register_messages(); + gras_cb_register(gras_msgtype_by_name("ping"),&server_cb_ping_handler); INFO1("SERVER: >>>>>>>> Listening on port %d <<<<<<<<", gras_socket_my_port(g->sock)); @@ -147,7 +142,6 @@ int client(int argc,char *argv[]) { gras_socket_t *from; int ping, pong; - gras_msgtype_t *msg_ping_type=NULL, *msg_pong_type=NULL; const char *host = "127.0.0.1"; int port = 4000; @@ -170,15 +164,13 @@ int client(int argc,char *argv[]) { INFO2("Client: Connected to %s:%d.",host,port); - TRY(register_messages()); - TRY(gras_msgtype_by_name("ping",&msg_ping_type)); - TRY(gras_msgtype_by_name("pong",&msg_pong_type)); + register_messages(); INFO2("Client: >>>>>>>> Connected to server which is on %s:%d <<<<<<<<", gras_socket_peer_name(g->sock),gras_socket_peer_port(g->sock)); ping = 1234; - errcode = gras_msg_send(g->sock, msg_ping_type, &ping); + errcode = gras_msg_send(g->sock, gras_msgtype_by_name("ping"), &ping); if (errcode != no_error) { fprintf(stderr, "Client: Unable send PING to server (%s)\n", gras_error_name(errcode)); @@ -189,8 +181,8 @@ int client(int argc,char *argv[]) { ping, gras_socket_peer_name(g->sock),gras_socket_peer_port(g->sock)); - if ((errcode=gras_msg_wait(6000, - msg_pong_type,&from,&pong))) { + if ((errcode=gras_msg_wait(6000,gras_msgtype_by_name("pong"), + &from,&pong))) { ERROR1("Client: Why can't I get my PONG message like everyone else (%s)?", gras_error_name(errcode)); gras_socket_close(g->sock);