X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/cc4eceb15c80a597e44222b8c0ff60caf85db959..9853c047276b618315bd3f064c1f13c3d3ccd771:/examples/s4u/dht-chord/s4u-dht-chord.hpp diff --git a/examples/s4u/dht-chord/s4u-dht-chord.hpp b/examples/s4u/dht-chord/s4u-dht-chord.hpp index 7db25b19da..12b6921640 100644 --- a/examples/s4u/dht-chord/s4u-dht-chord.hpp +++ b/examples/s4u/dht-chord/s4u-dht-chord.hpp @@ -22,7 +22,8 @@ extern int nb_keys; extern int timeout; class HostChord { - RngStream stream_; + std::unique_ptr::type, std::function> stream_ = { + nullptr, [](RngStream stream) { RngStream_DeleteStream(&stream); }}; simgrid::s4u::Host* host = nullptr; public: @@ -31,14 +32,12 @@ public: explicit HostChord(simgrid::s4u::Host* ptr) : host(ptr) { std::string descr = std::string("RngSream<") + host->get_cname() + ">"; - stream_ = RngStream_CreateStream(descr.c_str()); + stream_.reset(RngStream_CreateStream(descr.c_str())); } HostChord(const HostChord&) = delete; HostChord& operator=(const HostChord&) = delete; - ~HostChord() { RngStream_DeleteStream(&stream_); }; - - RngStream getStream() { return stream_; }; + RngStream getStream() { return stream_.get(); }; }; /* Types of tasks exchanged between nodes. */ @@ -61,15 +60,13 @@ public: int request_id = -1; // id (used by some types of messages) int request_finger = 1; // finger parameter (used by some types of messages) int answer_id = -1; // answer (used by some types of messages) - simgrid::s4u::MailboxPtr answer_to; // mailbox to send an answer to (if any) + simgrid::s4u::Mailbox* answer_to = nullptr; // mailbox to send an answer to (if any) explicit ChordMessage(e_message_type_t type) : type(type), issuer_host_name(simgrid::s4u::this_actor::get_host()->get_name()) { } - ~ChordMessage() = default; - static void destroy(void* message); }; @@ -80,8 +77,8 @@ class Node { bool joined = false; int id_; // my id int pred_id_ = -1; // predecessor id - simgrid::s4u::MailboxPtr mailbox_; // my mailbox - int* fingers_; // finger table,(fingers[0] is my successor) + simgrid::s4u::Mailbox* mailbox_; // my mailbox + std::vector fingers_; // finger table,(fingers[0] is my successor) int next_finger_to_fix; // index of the next finger to fix in fix_fingers() RngStream stream; @@ -89,7 +86,6 @@ public: explicit Node(std::vector args); Node(const Node&) = delete; Node& operator=(const Node&) = delete; - ~Node(); void join(int known_id); void leave(); void notifyAndQuit();