X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/047872771f0685df5ad0db3422b3333e26696330..5824e3e084f8021554e73ba26124bd5ed2933b59:/src/mc/checker/simgrid_mc.cpp diff --git a/src/mc/checker/simgrid_mc.cpp b/src/mc/checker/simgrid_mc.cpp index 7f3d39a4cf..0cc4ffe173 100644 --- a/src/mc/checker/simgrid_mc.cpp +++ b/src/mc/checker/simgrid_mc.cpp @@ -1,99 +1,74 @@ -/* Copyright (c) 2015-2018. The SimGrid Team. +/* Copyright (c) 2015-2022. 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 - -#include -#include -#include - -#include - -#include - -#include - #include "simgrid/sg_config.hpp" -#include "src/xbt_modinter.h" - -#include "src/mc/Session.hpp" #include "src/mc/checker/Checker.hpp" -#include "src/mc/mc_base.h" -#include "src/mc/mc_comm_pattern.hpp" +#include "src/mc/mc_config.hpp" #include "src/mc/mc_exit.hpp" -#include "src/mc/mc_private.hpp" -#include "src/mc/mc_safety.hpp" -#include "src/mc/remote/mc_protocol.h" +#include "src/internal_config.h" + +#if HAVE_SMPI +#include "smpi/smpi.h" +#endif + +#include +#include +#include -XBT_LOG_NEW_DEFAULT_SUBCATEGORY(mc_main, mc, "Entry point for simgrid-mc"); -extern std::string _sg_mc_property_file; +using api = simgrid::mc::Api; static inline char** argvdup(int argc, char** argv) { - char** argv_copy = new char*[argc + 1]; + auto* argv_copy = new char*[argc + 1]; std::memcpy(argv_copy, argv, sizeof(char*) * argc); argv_copy[argc] = nullptr; return argv_copy; } -static std::unique_ptr createChecker(simgrid::mc::Session& session) -{ - if (_sg_mc_comms_determinism || _sg_mc_send_determinism) - return std::unique_ptr(simgrid::mc::createCommunicationDeterminismChecker(session)); - else if (_sg_mc_property_file.empty()) - return std::unique_ptr(simgrid::mc::createSafetyChecker(session)); - else - return std::unique_ptr(simgrid::mc::createLivenessChecker(session)); -} - int main(int argc, char** argv) { - using simgrid::mc::Session; + xbt_assert(argc >= 2, "Missing arguments"); - try { - if (argc < 2) - xbt_die("Missing arguments.\n"); + // Currently, we need this before sg_config_init: + _sg_do_model_check = 1; - // Currently, we need this before sg_config_init: - _sg_do_model_check = 1; + // The initialization function can touch argv. + // We make a copy of argv before modifying it in order to pass the original value to the model-checked application: + char** argv_copy = argvdup(argc, argv); - // The initialization function can touch argv. - // We make a copy of argv before modifying it in order to pass the original - // value to the model-checked: - char** argv_copy = argvdup(argc, argv); - xbt_log_init(&argc, argv); - sg_config_init(&argc, argv); + xbt_log_init(&argc, argv); +#if HAVE_SMPI + smpi_init_options(); // only performed once +#endif + sg_config_init(&argc, argv); - std::unique_ptr session = - std::unique_ptr(Session::spawnvp(argv_copy[1], argv_copy+1)); - delete[] argv_copy; + simgrid::mc::CheckerAlgorithm algo; + if (_sg_mc_comms_determinism || _sg_mc_send_determinism) + algo = simgrid::mc::CheckerAlgorithm::CommDeterminism; + else if (_sg_mc_unfolding_checker) + algo = simgrid::mc::CheckerAlgorithm::UDPOR; + else if (_sg_mc_property_file.get().empty()) + algo = simgrid::mc::CheckerAlgorithm::Safety; + else + algo = simgrid::mc::CheckerAlgorithm::Liveness; - simgrid::mc::session = session.get(); - std::unique_ptr checker = createChecker(*session); - int res = SIMGRID_MC_EXIT_SUCCESS; - try { - checker->run(); - } catch (simgrid::mc::DeadlockError& de) { - res = SIMGRID_MC_EXIT_DEADLOCK; - } catch (simgrid::mc::TerminationError& te) { - res = SIMGRID_MC_EXIT_NON_TERMINATION; - } catch (simgrid::mc::LivenessError& le) { - res = SIMGRID_MC_EXIT_LIVENESS; - } - checker = nullptr; - session->close(); - return res; - } - catch(std::exception& e) { - XBT_ERROR("Exception: %s", e.what()); - return SIMGRID_MC_EXIT_ERROR; - } - catch(...) { - XBT_ERROR("Unknown exception"); - return SIMGRID_MC_EXIT_ERROR; + int res = SIMGRID_MC_EXIT_SUCCESS; + auto checker = api::get().initialize(argv_copy, algo); + try { + checker->run(); + } catch (const simgrid::mc::DeadlockError&) { + res = SIMGRID_MC_EXIT_DEADLOCK; + } catch (const simgrid::mc::TerminationError&) { + res = SIMGRID_MC_EXIT_NON_TERMINATION; + } catch (const simgrid::mc::LivenessError&) { + res = SIMGRID_MC_EXIT_LIVENESS; } + api::get().s_close(); + delete[] argv_copy; + delete checker; + return res; }