From: mquinson Date: Sun, 27 Feb 2005 23:25:06 +0000 (+0000) Subject: more debuging X-Git-Tag: v3.3~4266 X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/commitdiff_plain/823d34beebb36450fa3074133e498b21b3d53f02 more debuging git-svn-id: svn+ssh://scm.gforge.inria.fr/svn/simgrid/simgrid/trunk@1087 48e7efb5-ca39-0410-a469-dd3cf9ba447f --- diff --git a/src/gras/Transport/transport.c b/src/gras/Transport/transport.c index b757c4579e..6cb3f1e5bd 100644 --- a/src/gras/Transport/transport.c +++ b/src/gras/Transport/transport.c @@ -292,6 +292,7 @@ void gras_socket_close(gras_socket_t sock) { gras_socket_t sock_iter; int cursor; + XBT_IN; /* FIXME: Issue an event when the socket is closed */ if (sock) { xbt_dynar_foreach(sockets,cursor,sock_iter) { @@ -304,11 +305,13 @@ void gras_socket_close(gras_socket_t sock) { if (sock->peer_name) free(sock->peer_name); free(sock); + XBT_OUT; return; } } WARN0("Ignoring request to free an unknown socket"); } + XBT_OUT; } /** diff --git a/src/gras/Transport/transport_plugin_sg.c b/src/gras/Transport/transport_plugin_sg.c index 6e7725c4ca..90897171f2 100644 --- a/src/gras/Transport/transport_plugin_sg.c +++ b/src/gras/Transport/transport_plugin_sg.c @@ -204,6 +204,8 @@ void gras_trp_sg_socket_close(gras_socket_t sock){ gras_sg_portrec_t pr; + XBT_IN1(" (sock=%p)",sock); + if (!sock) return; xbt_assert0(hd,"Please run gras_process_init on each process"); @@ -216,11 +218,13 @@ void gras_trp_sg_socket_close(gras_socket_t sock){ DEBUG2("Check pr %d of %lu", cpt, xbt_dynar_length(hd->ports)); if (pr.port == sock->port) { xbt_dynar_cursor_rm(hd->ports, &cpt); - return; + XBT_OUT; + return; } } WARN0("socket_close called on an unknown socket"); } + XBT_OUT; } typedef struct { @@ -271,6 +275,7 @@ xbt_error_t gras_trp_sg_chunk_recv(gras_socket_t sock, MSG_host_get_name(MSG_host_self()), sock_data->to_chan, size); if (MSG_task_get(&task, (sock->raw ? pd->rawChan : pd->chan)) != MSG_OK) RAISE0(unknown_error,"Error in MSG_task_get()"); + DEBUG1("Got chuck %s",MSG_task_get_name(task)); task_data = MSG_task_get_data(task); if (task_data->size != size)