X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/d693e2620b270cd5a6ca836f5ead1c079be4820e..6d7f851f116cff677f5d5cb009aa493a7510780c:/examples/msg/chainsend/peer.c

diff --git a/examples/msg/chainsend/peer.c b/examples/msg/chainsend/peer.c
index 7711068349..5605c88dd8 100644
--- a/examples/msg/chainsend/peer.c
+++ b/examples/msg/chainsend/peer.c
@@ -14,7 +14,7 @@ void peer_init_chain(peer_t peer, message_t msg)
   peer->init = 1;
 }
 
-void peer_forward_msg(peer_t peer, message_t msg)
+static void peer_forward_msg(peer_t peer, message_t msg)
 {
   msg_task_t task = task_message_data_new(peer->me, peer->next, NULL, 0);
   msg_comm_t comm = NULL;
@@ -73,7 +73,7 @@ msg_error_t peer_wait_for_message(peer_t peer)
       task = NULL;
     } else {
       process_pending_connections(peer->pending_sends);
-      MSG_process_sleep(0.1);
+      MSG_process_sleep(0.01);
     }
   }
 
@@ -105,7 +105,7 @@ void peer_shutdown(peer_t p)
   XBT_INFO("Waiting for sends to finish before shutdown...");
   while (xbt_dynar_length(p->pending_sends) && MSG_get_clock() < end_time) {
     process_pending_connections(p->pending_sends);
-    MSG_process_sleep(0.1);
+    MSG_process_sleep(1);
   }
 
   xbt_assert(xbt_dynar_length(p->pending_sends) == 0, "Shutdown failed, sends still pending after deadline");
@@ -127,7 +127,7 @@ int peer(int argc, char *argv[])
   status = peer_wait_for_message(p);
   peer_shutdown(p);
 
-  return MSG_OK;
+  return status;
 }                               /* end_of_receiver */