X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/a56e6f7447dd5df3e411ed7583869aa209213390..d685808894710dda03e4734a9e39f617adda0508:/teshsuite/s4u/actor-suspend/actor-suspend.cpp diff --git a/teshsuite/s4u/actor-suspend/actor-suspend.cpp b/teshsuite/s4u/actor-suspend/actor-suspend.cpp index cab47290ba..ed4d1ed980 100644 --- a/teshsuite/s4u/actor-suspend/actor-suspend.cpp +++ b/teshsuite/s4u/actor-suspend/actor-suspend.cpp @@ -1,35 +1,37 @@ -/* Copyright (c) 2020. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2020-2023. 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. */ // This is the MWE of https://framagit.org/simgrid/simgrid/-/issues/50 -// The problem was occuring when suspending an actor that will be executed later in the same scheduling round +// The problem was occurring when suspending an actor that will be executed later in the same scheduling round +#include +#include #include #include -#include -#include #include XBT_LOG_NEW_DEFAULT_CATEGORY(mwe, "Minimum Working Example"); -simgrid::s4u::ActorPtr receiver; - class Receiver { public: - void operator()() + void operator()() const { XBT_INFO("Starting."); auto mailbox = simgrid::s4u::Mailbox::by_name("receiver"); - int data = *(int*)mailbox->get(); + int data = *mailbox->get(); XBT_INFO("Got %d at the end", data); } }; class Suspender { + const simgrid::s4u::ActorPtr& receiver; + public: - void operator()() + explicit Suspender(const simgrid::s4u::ActorPtr& receiver) : receiver(receiver) {} + + void operator()() const { XBT_INFO("Suspend the receiver..."); receiver->suspend(); @@ -41,7 +43,7 @@ public: XBT_INFO("Sending a message to the receiver..."); auto mailbox = simgrid::s4u::Mailbox::by_name("receiver"); - int data = 42; + static int data = 42; mailbox->put(&data, 4); XBT_INFO("Done!"); @@ -50,15 +52,16 @@ public: int main(int argc, char** argv) { - simgrid::s4u::Engine* engine = new simgrid::s4u::Engine(&argc, argv); + simgrid::s4u::Engine engine(&argc, argv); - engine->load_platform(argv[1]); - simgrid::s4u::Host* host = simgrid::s4u::Host::by_name("Tremblay"); + engine.load_platform(argv[1]); + simgrid::s4u::Host* host = engine.host_by_name("Tremblay"); - simgrid::s4u::Actor::create("Suspender", host, Suspender()); + simgrid::s4u::ActorPtr receiver; + simgrid::s4u::Actor::create("Suspender", host, Suspender(receiver)); receiver = simgrid::s4u::Actor::create("Receiver", host, Receiver()); - engine->run(); + engine.run(); return 0; }