X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/48eccb2c1532e35819830ca56fad7cf89887359f..a1c2fd1f61bd5733f3ddb126713ec5da13f1e440:/examples/msg/dht-kademlia/dht-kademlia.c diff --git a/examples/msg/dht-kademlia/dht-kademlia.c b/examples/msg/dht-kademlia/dht-kademlia.c index 186c620109..c718db420f 100644 --- a/examples/msg/dht-kademlia/dht-kademlia.c +++ b/examples/msg/dht-kademlia/dht-kademlia.c @@ -112,7 +112,8 @@ unsigned int join(node_t node, unsigned int id_known) answer_t node_list; msg_error_t status; unsigned int trial = 0; - unsigned int i, answer_got = 0; + unsigned int i; + unsigned int answer_got = 0; /* Add the guy we know to our routing table and ourselves. */ node_routing_table_update(node, node->id); @@ -158,8 +159,8 @@ unsigned int join(node_t node, unsigned int id_known) } while (answer_got == 0 && trial < max_join_trials); /* Second step: Send a FIND_NODE to a a random node in buckets */ unsigned int bucket_id = routing_table_find_bucket(node->table, id_known)->id; - for (i = 0; ((bucket_id - i) > 0 || (bucket_id + i) <= identifier_size) && i < JOIN_BUCKETS_QUERIES; i++) { - if (bucket_id - i > 0) { + for (i = 0; ((bucket_id > i) || (bucket_id + i) <= identifier_size) && i < JOIN_BUCKETS_QUERIES; i++) { + if (bucket_id > i) { unsigned int id_in_bucket = get_id_in_prefix(node->id, bucket_id - i); find_node(node, id_in_bucket, 0); } @@ -178,11 +179,13 @@ unsigned int join(node_t node, unsigned int id_known) unsigned int find_node(node_t node, unsigned int id_to_find, unsigned int count_in_stats) { unsigned int i = 0; - unsigned int queries, answers; + unsigned int queries; + unsigned int answers; unsigned int destination_found = 0; unsigned int nodes_added = 0; double time_beginreceive; - double timeout, global_timeout = MSG_get_clock() + find_node_global_timeout; + double timeout; + double global_timeout = MSG_get_clock() + find_node_global_timeout; unsigned int steps = 0; xbt_assert((id_to_find >= 0), "Id supplied incorrect"); @@ -274,8 +277,8 @@ unsigned int find_node(node_t node, unsigned int id_to_find, unsigned int count_ */ unsigned int ping(node_t node, unsigned int id_to_ping) { - char mailbox[MAILBOX_NAME_SIZE + 1]; - sprintf(mailbox, "%0*x", MAILBOX_NAME_SIZE, id_to_ping); + char mailbox[MAILBOX_NAME_SIZE]; + snprintf(mailbox,MAILBOX_NAME_SIZE, "%d", id_to_ping); unsigned int destination_found = 0; double timeout = MSG_get_clock() + ping_timeout; @@ -342,7 +345,7 @@ void random_lookup(node_t node) */ void send_find_node(node_t node, unsigned int id, unsigned int destination) { - char mailbox[MAILBOX_NAME_SIZE + 1]; + char mailbox[MAILBOX_NAME_SIZE]; /* Gets the mailbox to send to */ get_node_mailbox(id, mailbox); /* Build the task */ @@ -358,7 +361,8 @@ void send_find_node(node_t node, unsigned int id, unsigned int destination) */ unsigned int send_find_node_to_best(node_t node, answer_t node_list) { - unsigned int i = 0, j = 0; + unsigned int i = 0; + unsigned int j = 0; unsigned int destination = node_list->destination_id; node_contact_t node_to_query; while (j < kademlia_alpha && i < node_list->size) {