MSG_comm_destroy(comm_received);
tracker_task_data_free(data);
MSG_task_destroy(task_received);
- comm_received = NULL;
}
}
peer->id = id;
snprintf(peer->mailbox,MAILBOX_SIZE-1, "%d", id);
snprintf(peer->mailbox_tracker,MAILBOX_SIZE-1, "tracker_%d", id);
- peer->peers = xbt_dict_new();
- peer->active_peers = xbt_dict_new();
+ peer->peers = xbt_dict_new_homogeneous(NULL);
+ peer->active_peers = xbt_dict_new_homogeneous(NULL);
peer->hostname = MSG_host_get_name(MSG_host_self());
peer->bitfield = xbt_new(char, FILE_PIECES + 1);
peer->current_pieces = xbt_dynar_new(sizeof(int), NULL);
- peer->stream = (RngStream)MSG_host_get_property_value(MSG_host_self(), "stream");
+ peer->stream = (RngStream)MSG_host_get_data(MSG_host_self());
peer->comm_received = NULL;
peer->round = 0;