xbt_dynar_t host_list = MSG_hosts_as_dynar();
xbt_dynar_foreach(host_list, i, host) {
char descr[512];
- RngStream stream;
snprintf(descr, sizeof descr, "RngSream<%s>", MSG_host_get_name(host));
- stream = RngStream_CreateStream(descr);
- MSG_host_set_property_value(host, "stream", (char*)stream, NULL);
+ RngStream stream = RngStream_CreateStream(descr);
+ MSG_host_set_data(host, stream);
}
MSG_function_register("tracker", tracker);
MSG_main();
xbt_dynar_foreach(host_list, i, host) {
- RngStream stream = (RngStream) MSG_host_get_property_value(host, "stream");
+ RngStream stream = (RngStream)MSG_host_get_data(host);
RngStream_DeleteStream(&stream);
+ MSG_host_set_data(host, NULL);
}
xbt_dynar_free(&host_list);
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;
{
int i;
- RngStream stream = (RngStream) MSG_host_get_property_value(MSG_host_self(), "stream");
+ RngStream stream = (RngStream)MSG_host_get_data(MSG_host_self());
//Checking arguments
xbt_assert(argc == 2, "Wrong number of arguments for the tracker.");
//Retrieving end time
RngStream stream;
snprintf(descr, sizeof descr, "RngSream<%s>", MSG_host_get_name(host));
stream = RngStream_CreateStream(descr);
- MSG_host_set_property_value(host, "stream", (char*)stream, NULL);
+ MSG_host_set_data(host, stream);
}
}
msg_host_t host;
unsigned i;
xbt_dynar_foreach(host_list, i, host) {
- RngStream stream = (RngStream)MSG_host_get_property_value(host, "stream");
+ RngStream stream = (RngStream)MSG_host_get_data(host);
RngStream_DeleteStream(&stream);
+ MSG_host_set_data(host, NULL);
}
xbt_dynar_free(&host_list);
// initialize my node
s_node_t node = {0};
node.id = xbt_str_parse_int(argv[1],"Invalid ID: %s");
- node.stream = (RngStream)MSG_host_get_property_value(MSG_host_self(), "stream");
+ node.stream = (RngStream)MSG_host_get_data(MSG_host_self());
get_mailbox(node.id, node.mailbox);
node.next_finger_to_fix = 0;
node.fingers = xbt_new0(s_finger_t, nb_bits);