X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/dc6b95dec8c8c9c6f6aba852061d2e469c21aca1..HEAD:/src/mc/mc_record.cpp diff --git a/src/mc/mc_record.cpp b/src/mc/mc_record.cpp index 2afb21bdcb..63d9fc0680 100644 --- a/src/mc/mc_record.cpp +++ b/src/mc/mc_record.cpp @@ -1,73 +1,89 @@ -/* 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.hpp" #include "src/mc/mc_replay.hpp" - -#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 +#include "src/mc/transition/Transition.hpp" 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.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_); - 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.times_considered_); - 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(std::begin(actor_list), std::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.times_considered_); + 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, ';'); @@ -76,32 +92,20 @@ 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 == nullptr) + continue; + if (i != transitions_.begin()) stream << ';'; - stream << i->pid_; - if (i->times_considered_) - stream << '/' << i->times_considered_; + 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