X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/1692f2d57cbdd2bfffcba9481b96fb58fec34016..87b1fdc15d908c4e94bc6a81cbcf97f18a451205:/examples/s4u/dht-chord/s4u-dht-chord-node.cpp diff --git a/examples/s4u/dht-chord/s4u-dht-chord-node.cpp b/examples/s4u/dht-chord/s4u-dht-chord-node.cpp index 992d3a2047..8eda1ef168 100644 --- a/examples/s4u/dht-chord/s4u-dht-chord-node.cpp +++ b/examples/s4u/dht-chord/s4u-dht-chord-node.cpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2010-2019. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2010-2020. The SimGrid Team. All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it * under the terms of the license (GNU LGPL) which comes with this package. */ @@ -20,9 +20,9 @@ XBT_LOG_EXTERNAL_DEFAULT_CATEGORY(s4u_chord); * @param id id to check * @param start lower bound * @param end upper bound - * @return a non-zero value if id in in [start, end] + * @return true if id in in [start, end] */ -static int is_in_interval(int id, int start, int end) +static bool is_in_interval(int id, int start, int end) { int i = id % nb_keys; int s = start % nb_keys; @@ -134,8 +134,7 @@ void Node::notifyAndQuit() void Node::randomLookup() { int res = id_; - std::uniform_int_distribution dist(0, nb_bits - 1); - int random_index = dist(generator); + int random_index = simgrid::xbt::random::uniform_int(0, nb_bits - 1); int random_id = fingers_[random_index]; XBT_DEBUG("Making a lookup request for id %d", random_id); if (random_id != id_) @@ -268,7 +267,7 @@ int Node::remoteGetPredecessor(int ask_to) try { comm->wait_for(timeout); - ChordMessage* answer = static_cast(data); + const ChordMessage* answer = static_cast(data); XBT_DEBUG("Received the answer to my 'Get Predecessor' request: the predecessor of node %d is %d", ask_to, answer->answer_id); predecessor_id = answer->answer_id; @@ -315,7 +314,7 @@ int Node::findSuccessor(int id) int Node::remoteFindSuccessor(int ask_to, int id) { int successor = -1; - void* data = nullptr; + ChordMessage* data = nullptr; simgrid::s4u::Mailbox* mailbox = simgrid::s4u::Mailbox::by_name(std::to_string(ask_to)); simgrid::s4u::Mailbox* return_mailbox = simgrid::s4u::Mailbox::by_name(std::to_string(id_) + "_succ"); @@ -334,18 +333,18 @@ int Node::remoteFindSuccessor(int ask_to, int id) } // receive the answer XBT_DEBUG("Sent a 'Find Successor' request to %d for key %d, waiting for the answer", ask_to, id); - simgrid::s4u::CommPtr comm = return_mailbox->get_async(&data); + simgrid::s4u::CommPtr comm = return_mailbox->get_async(reinterpret_cast(&data)); try { comm->wait_for(timeout); - ChordMessage* answer = static_cast(data); + const ChordMessage* answer = data; XBT_DEBUG("Received the answer to my 'Find Successor' request for id %d: the successor of key %d is %d", answer->request_id, id_, answer->answer_id); successor = answer->answer_id; delete answer; } catch (const simgrid::TimeoutException&) { XBT_DEBUG("Failed to receive the answer to my 'Find Successor' request"); - delete static_cast(data); + delete data; } return successor;