-
-/* Copyright (c) 2010-2013. The SimGrid Team.
+/* Copyright (c) 2010-2014. The SimGrid Team.
* All rights reserved. */
/* This program is free software; you can redistribute it and/or modify it
static int periodic_check_predecessor_delay = 120;
static int periodic_lookup_delay = 10;
+static const double sleep_delay = 4.9999;
+
extern long int smx_total_comms;
/*
} s_task_data_t, *task_data_t;
static int *powers2;
+static xbt_dynar_t host_list;
// utility functions
static void chord_initialize(void);
// compute the powers of 2 once for all
powers2 = xbt_new(int, nb_bits);
int pow = 1;
- int i;
+ unsigned i;
for (i = 0; i < nb_bits; i++) {
powers2[i] = pow;
pow = pow << 1;
}
nb_keys = pow;
XBT_DEBUG("Sets nb_keys to %d", nb_keys);
+
+ msg_host_t host;
+ 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);
+ }
}
static void chord_exit(void)
{
+ msg_host_t host;
+ unsigned i;
+ xbt_dynar_foreach(host_list, i, host) {
+ RngStream stream = (RngStream)MSG_host_get_property_value(host, "stream");
+ RngStream_DeleteStream(&stream);
+ }
+ xbt_dynar_free(&host_list);
+
xbt_free(powers2);
}
double next_check_predecessor_date = init_time + periodic_check_predecessor_delay;
double next_lookup_date = init_time + periodic_lookup_delay;
- #ifdef HAVE_MC
int listen = 0;
int no_op = 0;
int sub_protocol = 0;
- #endif
xbt_assert(argc == 3 || argc == 5, "Wrong number of arguments for this node");
// initialize my node
s_node_t node = {0};
node.id = atoi(argv[1]);
+ node.stream =
+ (RngStream)MSG_host_get_property_value(MSG_host_self(), "stream");
get_mailbox(node.id, node.mailbox);
node.next_finger_to_fix = 0;
node.fingers = xbt_new0(s_finger_t, nb_bits);
// no task was received: make some periodic calls
-#ifdef HAVE_MC
if(MC_is_active()){
if(!MC_visited_reduction() && no_op){
MC_cut();
random_lookup(&node);
listen = 1;
}else{
- MSG_process_sleep(5);
+ MSG_process_sleep(sleep_delay);
if(!MC_visited_reduction())
no_op = 1;
}
next_lookup_date = MSG_get_clock() + periodic_lookup_delay;
}else {
// nothing to do: sleep for a while
- MSG_process_sleep(5);
+ MSG_process_sleep(sleep_delay);
}
}
-#else
- if (MSG_get_clock() >= next_stabilize_date) {
- stabilize(&node);
- next_stabilize_date = MSG_get_clock() + periodic_stabilize_delay;
- }else if (MSG_get_clock() >= next_fix_fingers_date) {
- fix_fingers(&node);
- next_fix_fingers_date = MSG_get_clock() + periodic_fix_fingers_delay;
- }else if (MSG_get_clock() >= next_check_predecessor_date) {
- check_predecessor(&node);
- next_check_predecessor_date = MSG_get_clock() + periodic_check_predecessor_delay;
- }else if (MSG_get_clock() >= next_lookup_date) {
- random_lookup(&node);
- next_lookup_date = MSG_get_clock() + periodic_lookup_delay;
- }else {
- // nothing to do: sleep for a while
- MSG_process_sleep(5);
- }
-#endif
} else {
// a transfer has occurred
}
if (node.comm_receive) {
+ /* handle last task if any */
+ if (MSG_comm_wait(node.comm_receive, 0) == MSG_OK)
+ task_free(task_received);
MSG_comm_destroy(node.comm_receive);
node.comm_receive = NULL;
}
MSG_task_dsend(task, task_data->answer_to, task_free);
break;
+ default:
+ THROW_IMPOSSIBLE;
}
}
{
XBT_DEBUG("Well Guys! I Think it's time for me to quit ;)");
quit_notify(node);
- RngStream_DeleteStream(&node->stream);
}
/**
// MC to fail any further under that condition, but this comment is here to as a memorial for this first
// brillant victory of the model-checking in the SimGrid community :)
- if (task_received != task_sent) {
+ if (task_received != task_sent ||
+ ans_data->type != TASK_FIND_SUCCESSOR_ANSWER) {
// this is not the expected answer
MSG_comm_destroy(node->comm_receive);
node->comm_receive = NULL;
stop = 1;
MSG_comm_destroy(node->comm_receive);
node->comm_receive = NULL;
- task_free(task_sent);
}
else {
msg_task_t task_received = MSG_comm_get_task(node->comm_receive);
MC_assert(task_received == task_sent);
}*/
- if (task_received != task_sent) {
+ if (task_received != task_sent ||
+ ans_data->type != TASK_GET_PREDECESSOR_ANSWER) {
MSG_comm_destroy(node->comm_receive);
node->comm_receive = NULL;
handle_task(node, task_received);
*/
static void random_lookup(node_t node)
{
-
- int id = 1337;
- find_successor(node, id);
-
- /*** Random lookup disabled for tesh examples ***/
- /*if(node->stream == NULL)
- node->stream = RngStream_CreateStream("");
int random_index = RngStream_RandInt (node->stream, 0, nb_bits - 1);
int random_id = node->fingers[random_index].id;
XBT_DEBUG("Making a lookup request for id %d", random_id);
int res = find_successor(node, random_id);
- XBT_DEBUG("The successor of node %d is %d", random_id, res);*/
+ XBT_DEBUG("The successor of node %d is %d", random_id, res);
}
const char* platform_file = options[0];
const char* application_file = options[1];
- chord_initialize();
-
MSG_create_environment(platform_file);
+ chord_initialize();
+
MSG_function_register("node", node);
MSG_launch_application(application_file);
