static int periodic_check_predecessor_delay = 120;
static int periodic_lookup_delay = 10;
+extern long int smx_total_comms;
+
/**
* Finger element.
*/
// stop the simulation
xbt_free(node.fingers);
+ INFO1("Messages created: %lu", smx_total_comms);
return 0;
}
INFO2("Joining the ring with id %d, knowing node %d", node->id, known_id);
set_predecessor(node, -1); // no predecessor (yet)
+ int i;
+ for (i = 0; i < nb_bits; i++) {
+ set_finger(node, i, known_id);
+ }
+
int successor_id = remote_find_successor(node, known_id, node->id);
if (successor_id == -1) {
INFO0("Cannot join the ring.");
MSG_launch_application(application_file);
MSG_error_t res = MSG_main();
- INFO1("Simulation time: %g", MSG_get_clock());
+ INFO1("Simulated time: %g", MSG_get_clock());
MSG_clean();
"Logging specific to SIMIX (network)");
static xbt_dict_t rdv_points = NULL;
+unsigned long int smx_total_comms = 0;
static XBT_INLINE void SIMIX_comm_start(smx_action_t action);
static void SIMIX_comm_finish(smx_action_t action);
#endif
DEBUG1("Create communicate action %p", act);
+ ++smx_total_comms;
return act;
}