*/
int tracker(int argc, char *argv[])
{
- int i, key_elm;
- char *key;
- void *data_p;
+ int i;
- RngStream stream = RngStream_CreateStream("tracker");
+ RngStream stream = MSG_host_get_data(MSG_host_self());
//Checking arguments
xbt_assert(argc == 2, "Wrong number of arguments for the tracker.");
xbt_dynar_push_as(peers_list, int, data->peer_id);
}
//Sending peers to the peer
- int nb_peers = 0, next_peer;
+ int next_peer;
int peers_length = xbt_dynar_length(peers_list);
for (i = 0; i < MAXIMUM_PAIRS && i < peers_length; i++) {
do {
}
//Free the peers list
xbt_dynar_free(&peers_list);
- //Free the RngStream object.
- RngStream_DeleteStream(&stream);
XBT_INFO("Tracker is leaving");
*/
int is_in_list(xbt_dynar_t peers, int id)
{
- int i, elm;
+ unsigned i;
+ int elm;
xbt_dynar_foreach(peers, i, elm) {
if (elm == id) {
return 1;