From 8f384089af3d664bf1f59324d41f1511d5dfa0ab Mon Sep 17 00:00:00 2001 From: mquinson Date: Tue, 20 Oct 2009 13:08:20 +0000 Subject: [PATCH] useless cosmetics git-svn-id: svn+ssh://scm.gforge.inria.fr/svn/simgrid/simgrid/trunk@6801 48e7efb5-ca39-0410-a469-dd3cf9ba447f --- src/gras/Msg/gras_msg_listener.c | 18 ++++++------------ src/gras/Msg/msg_private.h | 2 +- src/gras/gras.c | 2 +- 3 files changed, 8 insertions(+), 14 deletions(-) diff --git a/src/gras/Msg/gras_msg_listener.c b/src/gras/Msg/gras_msg_listener.c index e4930fc617..b583d58e1e 100644 --- a/src/gras/Msg/gras_msg_listener.c +++ b/src/gras/Msg/gras_msg_listener.c @@ -103,28 +103,22 @@ gras_msg_listener_t gras_msg_listener_launch(xbt_queue_t msg_exchange) } #include "gras/Virtu/virtu_private.h" /* procdata_t content */ -void gras_msg_listener_shutdown(gras_msg_listener_t l) +void gras_msg_listener_shutdown() { gras_procdata_t *pd = gras_procdata_get(); char kill = '0'; DEBUG0("Listener quit"); - if (pd->listener) gras_msg_send(pd->listener->wakeup_sock_master_side, "_wakeup_listener", - &kill); + &kill); - /* FIXME: thread_join is not implemented in SG (remove next conditional when fixed) - * But I guess it's not a big deal since we're terminating the thread mainly to - * make it free its OS locks on darwin. - * darwin is definitly different from the neat & nice SG world */ - if (gras_if_RL()) - xbt_thread_join(pd->listener->listener); + xbt_thread_join(pd->listener->listener); // gras_socket_close(pd->listener->wakeup_sock_master_side); FIXME: uncommenting this leads to deadlock at terminaison - xbt_queue_free(&l->incomming_messages); - xbt_queue_free(&l->socks_to_close); - xbt_free(l); + xbt_queue_free(&pd->listener->incomming_messages); + xbt_queue_free(&pd->listener->socks_to_close); + xbt_free(pd->listener); } void gras_msg_listener_awake() diff --git a/src/gras/Msg/msg_private.h b/src/gras/Msg/msg_private.h index 484bdd3a68..353d5d52af 100644 --- a/src/gras/Msg/msg_private.h +++ b/src/gras/Msg/msg_private.h @@ -76,7 +76,7 @@ void gras_msg_send_ext(gras_socket_t sock, typedef struct s_gras_msg_listener_ *gras_msg_listener_t; gras_msg_listener_t gras_msg_listener_launch(xbt_queue_t msg_exchange); /* The caller has the responsability to cleanup the queues himself */ -void gras_msg_listener_shutdown(gras_msg_listener_t); +void gras_msg_listener_shutdown(void); /** * gras_cblist_t: diff --git a/src/gras/gras.c b/src/gras/gras.c index f718ca1cad..4ec704d2a8 100644 --- a/src/gras/gras.c +++ b/src/gras/gras.c @@ -150,7 +150,7 @@ void gras_exit(void) amok_exit(); gras_moddata_leave(); pd = gras_procdata_get(); - gras_msg_listener_shutdown(pd->listener); + gras_msg_listener_shutdown(); gras_process_exit(); if (--gras_running_process == 0) { gras_msg_exit(); -- 2.20.1