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;
status = peer_wait_for_message(p);
peer_shutdown(p);
- return MSG_OK;
+ return status;
} /* end_of_receiver */