X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/08e7455d67920bbd7a87f440d00f2c1e071314a0..d6eb772e45cc853fc204bb5aebeb411cdfa7c929:/src/mc/mc_record.cpp diff --git a/src/mc/mc_record.cpp b/src/mc/mc_record.cpp index b326b20cc9..6f1d32f486 100644 --- a/src/mc/mc_record.cpp +++ b/src/mc/mc_record.cpp @@ -1,74 +1,95 @@ -/* Copyright (c) 2014-2021. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2014-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. */ #include "src/mc/mc_record.hpp" +#include "src/kernel/EngineImpl.hpp" #include "src/kernel/activity/CommImpl.hpp" -#include "src/kernel/context/Context.hpp" -#include "src/mc/Transition.hpp" -#include "src/mc/mc_base.h" +#include "src/mc/mc_base.hpp" #include "src/mc/mc_replay.hpp" +#include "src/mc/transition/Transition.hpp" #if SIMGRID_HAVE_MC -#include "src/mc/checker/Checker.hpp" +#include "src/mc/api/State.hpp" +#include "src/mc/explo/Exploration.hpp" #include "src/mc/mc_private.hpp" -#include "src/mc/mc_request.hpp" -#include "src/mc/mc_smx.hpp" -#include "src/mc/mc_state.hpp" #endif XBT_LOG_NEW_DEFAULT_SUBCATEGORY(mc_record, mc, "Logging specific to MC record/replay facility"); -namespace simgrid { -namespace mc { +namespace simgrid::mc { -void replay(RecordTrace const& trace) +void RecordTrace::replay() const { - simgrid::mc::wait_for_requests(); - - for (simgrid::mc::Transition const& transition : trace) { - XBT_DEBUG("Executing %i$%i", transition.pid_, transition.argument_); - - // 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_); - 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."); + simgrid::mc::execute_actors(); + auto* engine = kernel::EngineImpl::get_instance(); + + int frame_count = 1; + if (xbt_log_no_loc) + XBT_INFO("The backtrace of each transition will not be shown because of --log=no_loc"); + else + simgrid_mc_replay_show_backtraces = true; + + for (const simgrid::mc::Transition* transition : transitions_) { + kernel::actor::ActorImpl* actor = engine->get_actor_by_pid(transition->aid_); + xbt_assert(actor != nullptr, "Unexpected actor (id:%ld).", transition->aid_); + const kernel::actor::Simcall* simcall = &(actor->simcall_); + xbt_assert(simgrid::mc::request_is_visible(simcall), "Simcall %s of actor %s is not visible.", simcall->get_cname(), + actor->get_cname()); + + XBT_INFO("***********************************************************************************"); + XBT_INFO("* Path chunk #%d '%ld/%i' Actor %s(pid:%ld): %s", frame_count++, transition->aid_, + transition->times_considered_, simcall->issuer_->get_cname(), simcall->issuer_->get_pid(), + simcall->observer_->to_string().c_str()); + XBT_INFO("***********************************************************************************"); + if (not mc::actor_is_enabled(actor)) + simgrid::kernel::EngineImpl::get_instance()->display_all_actor_status(); + + xbt_assert(simgrid::mc::actor_is_enabled(actor), "Actor %s (simcall %s) is not enabled.", actor->get_cname(), + simcall->get_cname()); // Execute the request: - simcall->issuer_->simcall_handle(transition.argument_); - simgrid::mc::wait_for_requests(); + simcall->issuer_->simcall_handle(transition->times_considered_); + simgrid::mc::execute_actors(); + } + + const auto& actor_list = engine->get_actor_list(); + if (actor_list.empty()) { + XBT_INFO("The replay of the trace is complete. The application is terminating."); + } else if (std::none_of(begin(actor_list), end(actor_list), + [](const auto& kv) { return mc::actor_is_enabled(kv.second); })) { + XBT_INFO("The replay of the trace is complete. DEADLOCK detected."); + engine->display_all_actor_status(); + } else { + XBT_INFO("The replay of the trace is complete. The application could run further."); } } -void replay(const std::string& path_string) +void simgrid::mc::RecordTrace::replay(const std::string& path_string) { - 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.resize(kernel::actor::ActorImpl::get_maxpid()); + simgrid::mc::RecordTrace trace(path_string.c_str()); + trace.replay(); + for (auto* item : trace.transitions_) + delete item; simgrid::mc::processes_time.clear(); } -RecordTrace parseRecordTrace(const char* data) +simgrid::mc::RecordTrace::RecordTrace(const char* data) { - RecordTrace res; XBT_INFO("path=%s", data); if (data == nullptr || data[0] == '\0') throw std::invalid_argument("Could not parse record path"); const char* current = data; while (*current) { - simgrid::mc::Transition item; - int count = sscanf(current, "%d/%d", &item.pid_, &item.argument_); + long aid; + int times_considered = 0; - if(count != 2 && count != 1) + if (int count = sscanf(current, "%ld/%d", &aid, ×_considered); count != 2 && count != 1) throw std::invalid_argument("Could not parse record path"); - res.push_back(item); + push_back(new simgrid::mc::Transition(simgrid::mc::Transition::Type::UNKNOWN, aid, times_considered)); // Find next chunk: const char* end = std::strchr(current, ';'); @@ -77,32 +98,23 @@ RecordTrace parseRecordTrace(const char* data) else current = end + 1; } - - return res; } #if SIMGRID_HAVE_MC -std::string traceToString(simgrid::mc::RecordTrace const& trace) +std::string simgrid::mc::RecordTrace::to_string() const { std::ostringstream stream; - for (auto i = trace.begin(); i != trace.end(); ++i) { - if (i != trace.begin()) + for (auto i = transitions_.begin(); i != transitions_.end(); ++i) { + if (i != transitions_.begin()) stream << ';'; - stream << i->pid_; - if (i->argument_) - stream << '/' << i->argument_; + stream << (*i)->aid_; + if ((*i)->times_considered_ > 0) + stream << '/' << (*i)->times_considered_; } return stream.str(); } -void dumpRecordPath() -{ - RecordTrace trace = mc_model_checker->getChecker()->get_record_trace(); - XBT_INFO("Path = %s", traceToString(trace).c_str()); -} - #endif -} -} +} // namespace simgrid::mc