X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/33266b5538bcd1a3a07c20dea720ae2a21c3c90f..96d605fde63f72480bf570f7bc7609e2954cb2d7:/src/mc/mc_base.cpp diff --git a/src/mc/mc_base.cpp b/src/mc/mc_base.cpp index c6072eac26..91012ba602 100644 --- a/src/mc/mc_base.cpp +++ b/src/mc/mc_base.cpp @@ -16,10 +16,8 @@ #if SIMGRID_HAVE_MC #include "src/mc/ModelChecker.hpp" -#include "src/mc/Session.hpp" +#include "src/mc/api/RemoteApp.hpp" #include "src/mc/remote/RemoteProcess.hpp" - -using simgrid::mc::remote; #endif XBT_LOG_NEW_DEFAULT_CATEGORY(mc, "All MC categories"); @@ -37,33 +35,20 @@ int MC_random(int min, int max) return simgrid::kernel::actor::simcall_answered([&observer] { return observer.get_value(); }, &observer); } -namespace simgrid { -namespace mc { +namespace simgrid::mc { void execute_actors() { auto* engine = kernel::EngineImpl::get_instance(); -#if SIMGRID_HAVE_MC - xbt_assert(mc_model_checker == nullptr, "This must be called from the client"); -#endif + while (engine->has_actors_to_run()) { engine->run_all_actors(); for (auto const& actor : engine->get_actors_that_ran()) { - const s_smx_simcall* req = &actor->simcall_; - if (req->call_ != simix::Simcall::NONE && not simgrid::mc::request_is_visible(req)) + const kernel::actor::Simcall* req = &actor->simcall_; + if (req->call_ != kernel::actor::Simcall::Type::NONE && not simgrid::mc::request_is_visible(req)) actor->simcall_handle(0); } } -#if SIMGRID_HAVE_MC - engine->reset_actor_dynar(); - for (auto const& kv : engine->get_actor_list()) { - auto actor = kv.second; - // Only visible requests remain at this point, and they all have an observer - actor->simcall_.mc_max_consider_ = actor->simcall_.observer_->get_max_consider(); - - engine->add_actor_to_dynar(actor); - } -#endif } /** @brief returns if there this transition can proceed in a finite amount of time @@ -78,19 +63,19 @@ void execute_actors() * This is controlled in the is_enabled() method of the corresponding observers. */ // Called from both MCer and MCed: -bool actor_is_enabled(smx_actor_t actor) +bool actor_is_enabled(kernel::actor::ActorImpl* actor) { #if SIMGRID_HAVE_MC xbt_assert(mc_model_checker == nullptr, "This should be called from the client side"); #endif // Now, we are in the client app, no need for remote memory reading. - smx_simcall_t req = &actor->simcall_; + kernel::actor::Simcall* req = &actor->simcall_; if (req->observer_ != nullptr) return req->observer_->is_enabled(); - if (req->call_ == simix::Simcall::NONE) + if (req->call_ == kernel::actor::Simcall::Type::NONE) return false; else /* The rest of the requests are always enabled */ @@ -100,7 +85,7 @@ bool actor_is_enabled(smx_actor_t actor) /* This is the list of requests that are visible from the checker algorithm. * Any other requests are handled right away on the application side. */ -bool request_is_visible(const s_smx_simcall* req) +bool request_is_visible(const kernel::actor::Simcall* req) { #if SIMGRID_HAVE_MC xbt_assert(mc_model_checker == nullptr, "This should be called from the client side"); @@ -111,5 +96,4 @@ bool request_is_visible(const s_smx_simcall* req) return false; } -} // namespace mc -} // namespace simgrid +} // namespace simgrid::mc