X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/6511b78ff810ead55a110d42b01a08255a55b56d..c6c517af9e561a831a14051c92abcb217b1fe2bb:/src/gras/Transport/transport.c diff --git a/src/gras/Transport/transport.c b/src/gras/Transport/transport.c index 4b5d45a78e..07b7b75dd5 100644 --- a/src/gras/Transport/transport.c +++ b/src/gras/Transport/transport.c @@ -9,7 +9,6 @@ under the terms of the license (GNU LGPL) which comes with this package. */ #include /* time() */ -//#include #include "Transport/transport_private.h" @@ -41,13 +40,13 @@ gras_trp_init(void){ /* TCP */ TRY(gras_trp_tcp_init(&plug)); - TRY(gras_dict_insert(_gras_trp_plugins, - plug->name, plug, gras_trp_plugin_free)); + TRY(gras_dict_set(_gras_trp_plugins, + plug->name, plug, gras_trp_plugin_free)); /* FILE */ TRY(gras_trp_file_init(&plug)); - TRY(gras_dict_insert(_gras_trp_plugins, - plug->name, plug, gras_trp_plugin_free)); + TRY(gras_dict_set(_gras_trp_plugins, + plug->name, plug, gras_trp_plugin_free)); return no_error; } @@ -130,7 +129,7 @@ gras_socket_server(unsigned short port, sock->port=port; /* Call plugin socket creation function */ - errcode = trp->socket_server(trp, port, sock); + errcode = trp->socket_server(trp, port, 0/* not raw */, sock); if (errcode != no_error) { free(sock); return errcode; @@ -177,6 +176,7 @@ gras_socket_client(const char *host, /* plugin-specific */ errcode= (* trp->socket_client)(trp, host ? host : "localhost", port, + 0 /* not raw */, sock); if (errcode != no_error) { free(sock); @@ -213,7 +213,7 @@ void gras_socket_close(gras_socket_t **sock) { return; } } - WARNING0("Ignoring request to free an unknown socket"); + WARN0("Ignoring request to free an unknown socket"); } } @@ -256,6 +256,15 @@ gras_error_t gras_trp_plugin_get_by_name(const char *name, gras_trp_plugin_t **dst){ - return gras_dict_retrieve(_gras_trp_plugins,name,(void**)dst); + return gras_dict_get(_gras_trp_plugins,name,(void**)dst); } +int gras_socket_my_port (gras_socket_t *sock) { + return sock->port; +} +int gras_socket_peer_port(gras_socket_t *sock) { + return sock->peer_port; +} +char *gras_socket_peer_name(gras_socket_t *sock) { + return sock->peer_name; +}