X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/b77216e633e2d4e03cfb7778436b2464e7e24b70..6d7f851f116cff677f5d5cb009aa493a7510780c:/examples/msg/chainsend/peer.c diff --git a/examples/msg/chainsend/peer.c b/examples/msg/chainsend/peer.c index 107d25fdb2..5605c88dd8 100644 --- a/examples/msg/chainsend/peer.c +++ b/examples/msg/chainsend/peer.c @@ -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 */