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;
task = NULL;
} else {
process_pending_connections(peer->pending_sends);
- MSG_process_sleep(0.1);
+ MSG_process_sleep(0.01);
}
}
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");
status = peer_wait_for_message(p);
peer_shutdown(p);
- return MSG_OK;
+ return status;
} /* end_of_receiver */