X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/dc6b95dec8c8c9c6f6aba852061d2e469c21aca1..392c33f9c790418e1f5196d7dbbda5776b50d983:/src/mc/mc_record.cpp diff --git a/src/mc/mc_record.cpp b/src/mc/mc_record.cpp index 2afb21bdcb..bc2b30c4a8 100644 --- a/src/mc/mc_record.cpp +++ b/src/mc/mc_record.cpp @@ -13,7 +13,6 @@ #if SIMGRID_HAVE_MC #include "src/mc/checker/Checker.hpp" #include "src/mc/mc_private.hpp" -#include "src/mc/mc_request.hpp" #include "src/mc/mc_state.hpp" #endif @@ -24,24 +23,21 @@ namespace mc { void replay(RecordTrace const& trace) { - simgrid::mc::wait_for_requests(); + simgrid::mc::execute_actors(); for (simgrid::mc::Transition const& transition : trace) { - XBT_DEBUG("Executing %i$%i", transition.pid_, transition.times_considered_); + XBT_DEBUG("Executing %ld$%i", transition.aid_, transition.times_considered_); // Choose a request: - kernel::actor::ActorImpl* actor = kernel::actor::ActorImpl::by_PID(transition.pid_); - if (actor == nullptr) - xbt_die("Unexpected actor (id:%d).", transition.pid_); + kernel::actor::ActorImpl* actor = kernel::actor::ActorImpl::by_pid(transition.aid_); + xbt_assert(actor != nullptr, "Unexpected actor (id:%ld).", transition.aid_); const s_smx_simcall* simcall = &(actor->simcall_); - if (simcall->call_ == simix::Simcall::NONE) - xbt_die("No simcall for process %d.", transition.pid_); - if (not simgrid::mc::request_is_visible(simcall) || not simgrid::mc::actor_is_enabled(actor)) - xbt_die("Unexpected simcall."); + xbt_assert(simcall->call_ != simix::Simcall::NONE, "No simcall for process %ld.", transition.aid_); + xbt_assert(simgrid::mc::request_is_visible(simcall) && simgrid::mc::actor_is_enabled(actor), "Unexpected simcall."); // Execute the request: simcall->issuer_->simcall_handle(transition.times_considered_); - simgrid::mc::wait_for_requests(); + simgrid::mc::execute_actors(); } } @@ -63,7 +59,7 @@ RecordTrace parseRecordTrace(const char* data) const char* current = data; while (*current) { simgrid::mc::Transition item; - int count = sscanf(current, "%d/%d", &item.pid_, &item.times_considered_); + int count = sscanf(current, "%ld/%d", &item.aid_, &item.times_considered_); if(count != 2 && count != 1) throw std::invalid_argument("Could not parse record path"); @@ -88,7 +84,7 @@ std::string traceToString(simgrid::mc::RecordTrace const& trace) for (auto i = trace.begin(); i != trace.end(); ++i) { if (i != trace.begin()) stream << ';'; - stream << i->pid_; + stream << i->aid_; if (i->times_considered_) stream << '/' << i->times_considered_; }