X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/b8df87e176f27b25534f27d7e240defa32ca35bc..b41c921fc0a6a13f5db4d6cefb9b6955d5f21e3b:/src/mc/mc_record.cpp diff --git a/src/mc/mc_record.cpp b/src/mc/mc_record.cpp index 8183746d34..4c7f441c1c 100644 --- a/src/mc/mc_record.cpp +++ b/src/mc/mc_record.cpp @@ -9,7 +9,6 @@ #include "src/mc/Transition.hpp" #include "src/mc/mc_base.h" #include "src/mc/mc_replay.hpp" -#include "src/simix/ActorImpl.hpp" #if SIMGRID_HAVE_MC #include "src/mc/checker/Checker.hpp" @@ -19,8 +18,7 @@ #include "src/mc/mc_state.hpp" #endif -XBT_LOG_NEW_DEFAULT_SUBCATEGORY(mc_record, mc, - " Logging specific to MC record/replay facility"); +XBT_LOG_NEW_DEFAULT_SUBCATEGORY(mc_record, mc, "Logging specific to MC record/replay facility"); namespace simgrid { namespace mc { @@ -30,27 +28,27 @@ void replay(RecordTrace const& trace) simgrid::mc::wait_for_requests(); for (simgrid::mc::Transition const& transition : trace) { - XBT_DEBUG("Executing %i$%i", transition.pid, transition.argument); + XBT_DEBUG("Executing %i$%i", transition.pid_, transition.argument_); // Choose a request: - smx_actor_t process = SIMIX_process_from_PID(transition.pid); + smx_actor_t process = SIMIX_process_from_PID(transition.pid_); if (not process) - xbt_die("Unexpected process (pid:%d).", transition.pid); + xbt_die("Unexpected process (pid:%d).", transition.pid_); smx_simcall_t simcall = &(process->simcall); - if (not simcall || simcall->call == SIMCALL_NONE) - xbt_die("No simcall for process %d.", transition.pid); + if (simcall == nullptr || simcall->call_ == 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(process)) xbt_die("Unexpected simcall."); // Execute the request: - SIMIX_simcall_handle(simcall, transition.argument); + simcall->issuer_->simcall_handle(transition.argument_); simgrid::mc::wait_for_requests(); } } -void replay(std::string path_string) +void replay(const std::string& path_string) { - simgrid::mc::processes_time.resize(SIMIX_process_get_maxpid()); + simgrid::mc::processes_time.resize(simgrid::kernel::actor::get_maxpid()); simgrid::mc::RecordTrace trace = simgrid::mc::parseRecordTrace(path_string.c_str()); simgrid::mc::replay(trace); simgrid::mc::processes_time.clear(); @@ -67,7 +65,7 @@ RecordTrace parseRecordTrace(const char* data) while (*current) { simgrid::mc::Transition item; - int count = sscanf(current, "%d/%d", &item.pid, &item.argument); + int count = sscanf(current, "%d/%d", &item.pid_, &item.argument_); if(count != 2 && count != 1) throw std::invalid_argument("Could not parse record path"); res.push_back(item); @@ -91,19 +89,17 @@ 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; - if (i->argument) - stream << '/' << i->argument; + stream << i->pid_; + if (i->argument_) + stream << '/' << i->argument_; } return stream.str(); } void dumpRecordPath() { - if (MC_record_is_active()) { - RecordTrace trace = mc_model_checker->getChecker()->getRecordTrace(); - XBT_INFO("Path = %s", traceToString(trace).c_str()); - } + RecordTrace trace = mc_model_checker->getChecker()->get_record_trace(); + XBT_INFO("Path = %s", traceToString(trace).c_str()); } #endif