X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/d2eaf1bc9afee2877dd1b0351a91521165cf1590..934f086b51d328c46cb8fb20db2ad3efd4668ac9:/src/mc/ModelChecker.cpp diff --git a/src/mc/ModelChecker.cpp b/src/mc/ModelChecker.cpp index 3a9fb8513f..9dbc7412bf 100644 --- a/src/mc/ModelChecker.cpp +++ b/src/mc/ModelChecker.cpp @@ -1,11 +1,12 @@ -/* Copyright (c) 2008-2021. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2008-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 "src/mc/ModelChecker.hpp" #include "src/mc/Session.hpp" -#include "src/mc/Transition.hpp" +#include "src/mc/api/Transition.hpp" +#include "src/mc/api/TransitionComm.hpp" #include "src/mc/checker/Checker.hpp" #include "src/mc/mc_config.hpp" #include "src/mc/mc_exit.hpp" @@ -15,6 +16,7 @@ #include "xbt/system_error.hpp" #include +#include #include #include @@ -40,23 +42,25 @@ ModelChecker::ModelChecker(std::unique_ptr remote_simulation, int void ModelChecker::start() { - checker_side_.start([](evutil_socket_t sig, short events, void* arg) { - auto mc = static_cast(arg); - if (events == EV_READ) { - std::array buffer; - ssize_t size = mc->checker_side_.get_channel().receive(buffer.data(), buffer.size(), false); - if (size == -1 && errno != EAGAIN) - throw simgrid::xbt::errno_error(); - - if (not mc->handle_message(buffer.data(), size)) - mc->checker_side_.break_loop(); - } else if (events == EV_SIGNAL) { - if (sig == SIGCHLD) - mc->handle_waitpid(); - } else { - xbt_die("Unexpected event"); - } - }); + checker_side_.start( + [](evutil_socket_t sig, short events, void* arg) { + auto mc = static_cast(arg); + if (events == EV_READ) { + std::array buffer; + ssize_t size = mc->checker_side_.get_channel().receive(buffer.data(), buffer.size(), false); + if (size == -1 && errno != EAGAIN) + throw simgrid::xbt::errno_error(); + + if (not mc->handle_message(buffer.data(), size)) + mc->checker_side_.break_loop(); + } else if (events == EV_SIGNAL) { + if (sig == SIGCHLD) + mc->handle_waitpid(); + } else { + xbt_die("Unexpected event"); + } + }, + this); XBT_DEBUG("Waiting for the model-checked process"); int status; @@ -64,9 +68,8 @@ void ModelChecker::start() // The model-checked process SIGSTOP itself to signal it's ready: const pid_t pid = remote_process_->pid(); - pid_t res = waitpid(pid, &status, WAITPID_CHECKED_FLAGS); - if (res < 0 || not WIFSTOPPED(status) || WSTOPSIG(status) != SIGSTOP) - xbt_die("Could not wait model-checked process"); + xbt_assert(waitpid(pid, &status, WAITPID_CHECKED_FLAGS) == pid && WIFSTOPPED(status) && WSTOPSIG(status) == SIGSTOP, + "Could not wait model-checked process"); if (not _sg_mc_dot_output_file.get().empty()) MC_init_dot_output(); @@ -136,7 +139,7 @@ static void MC_report_crash(int status) XBT_INFO("Counter-example execution trace:"); for (auto const& s : mc_model_checker->getChecker()->get_textual_trace()) XBT_INFO(" %s", s.c_str()); - dumpRecordPath(); + XBT_INFO("Path = %s", mc_model_checker->getChecker()->get_record_trace().to_string().c_str()); session_singleton->log_state(); if (xbt_log_no_loc) { XBT_INFO("Stack trace not displayed because you passed --log=no_loc"); @@ -227,7 +230,7 @@ bool ModelChecker::handle_message(const char* buffer, ssize_t size) XBT_INFO("Counter-example execution trace:"); for (auto const& s : getChecker()->get_textual_trace()) XBT_INFO(" %s", s.c_str()); - dumpRecordPath(); + XBT_INFO("Path = %s", getChecker()->get_record_trace().to_string().c_str()); session_singleton->log_state(); this->exit(SIMGRID_MC_EXIT_SAFETY); @@ -266,8 +269,7 @@ void ModelChecker::handle_waitpid() // From PTRACE_O_TRACEEXIT: #ifdef __linux__ if (status>>8 == (SIGTRAP | (PTRACE_EVENT_EXIT<<8))) { - long ptrace_res = ptrace(PTRACE_GETEVENTMSG, remote_process_->pid(), 0, &status); - xbt_assert(ptrace_res != -1, "Could not get exit status"); + xbt_assert(ptrace(PTRACE_GETEVENTMSG, remote_process_->pid(), 0, &status) != -1, "Could not get exit status"); if (WIFSIGNALED(status)) { MC_report_crash(status); this->get_remote_process().terminate(); @@ -307,19 +309,35 @@ void ModelChecker::wait_for_requests() checker_side_.dispatch(); } -void ModelChecker::handle_simcall(Transition const& transition) +Transition* ModelChecker::handle_simcall(aid_t aid, int times_considered, bool new_transition) { - s_mc_message_simcall_handle_t m; + s_mc_message_simcall_execute_t m; memset(&m, 0, sizeof(m)); - m.type = MessageType::SIMCALL_HANDLE; - m.aid_ = transition.aid_; - m.times_considered_ = transition.times_considered_; + m.type = MessageType::SIMCALL_EXECUTE; + m.aid_ = aid; + m.times_considered_ = times_considered; checker_side_.get_channel().send(m); + this->remote_process_->clear_cache(); if (this->remote_process_->running()) - checker_side_.dispatch(); + checker_side_.dispatch(); // The app may send messages while processing the transition + + s_mc_message_simcall_execute_answer_t answer; + ssize_t s = checker_side_.get_channel().receive(answer); + xbt_assert(s != -1, "Could not receive message"); + xbt_assert(s == sizeof(answer) && answer.type == MessageType::SIMCALL_EXECUTE_ANSWER, + "Received unexpected message %s (%i, size=%i) " + "expected MessageType::SIMCALL_EXECUTE_ANSWER (%i, size=%i)", + to_c_str(answer.type), (int)answer.type, (int)s, (int)MessageType::SIMCALL_EXECUTE_ANSWER, + (int)sizeof(answer)); + + if (new_transition) { + std::stringstream stream(answer.buffer.data()); + return deserialize_transition(aid, times_considered, stream); + } else + return nullptr; } -bool ModelChecker::simcall_is_visible(int aid) +bool ModelChecker::simcall_is_visible(aid_t aid) { xbt_assert(mc_model_checker != nullptr, "This should be called from the checker side"); @@ -338,67 +356,27 @@ bool ModelChecker::simcall_is_visible(int aid) to_c_str(answer.type), (int)answer.type, (int)s, (int)MessageType::SIMCALL_IS_VISIBLE_ANSWER, (int)sizeof(answer)); - XBT_DEBUG("is_visible(%d) is returning %s", aid, answer.value ? "true" : "false"); + XBT_DEBUG("is_visible(%ld) is returning %s", aid, answer.value ? "true" : "false"); this->remote_process_->clear_cache(); return answer.value; } -std::string ModelChecker::simcall_to_string(MessageType type, int aid, int times_considered) -{ - xbt_assert(mc_model_checker != nullptr, "This should be called from the checker side"); - - s_mc_message_simcall_to_string_t m; - memset(&m, 0, sizeof(m)); - m.type = type; - m.aid = aid; - m.time_considered = times_considered; - checker_side_.get_channel().send(m); - - s_mc_message_simcall_to_string_answer_t answer; - ssize_t s = checker_side_.get_channel().receive(answer); - xbt_assert(s != -1, "Could not receive message"); - xbt_assert(s == sizeof(answer) && answer.type == MessageType::SIMCALL_TO_STRING_ANSWER, - "Received unexpected message %s (%i, size=%i) " - "expected MessageType::SIMCALL_TO_STRING_ANSWER (%i, size=%i)", - to_c_str(answer.type), (int)answer.type, (int)s, (int)MessageType::SIMCALL_TO_STRING_ANSWER, - (int)sizeof(answer)); - - return std::string(answer.value); -} - -std::string ModelChecker::simcall_to_string(int aid, int times_considered) -{ - std::string answer = simcall_to_string(MessageType::SIMCALL_TO_STRING, aid, times_considered); - XBT_DEBUG("to_string(%d) is returning %s", aid, answer.c_str()); - return answer; -} - -std::string ModelChecker::simcall_dot_label(int aid, int times_considered) -{ - std::string answer = simcall_to_string(MessageType::SIMCALL_DOT_LABEL, aid, times_considered); - XBT_DEBUG("dot_label(%d) is returning %s", aid, answer.c_str()); - return answer; -} - void ModelChecker::finalize_app(bool terminate_asap) { s_mc_message_int_t m; memset(&m, 0, sizeof m); m.type = MessageType::FINALIZE; m.value = terminate_asap; - int res = checker_side_.get_channel().send(m); - xbt_assert(res == 0, "Could not ask the app to finalize on need"); + xbt_assert(checker_side_.get_channel().send(m) == 0, "Could not ask the app to finalize on need"); s_mc_message_t answer; - ssize_t s = checker_side_.get_channel().receive(answer); - xbt_assert(s != -1, "Could not receive answer to FINALIZE"); + xbt_assert(checker_side_.get_channel().receive(answer) != -1, "Could not receive answer to FINALIZE"); } bool ModelChecker::checkDeadlock() { - int res = checker_side_.get_channel().send(MessageType::DEADLOCK_CHECK); - xbt_assert(res == 0, "Could not check deadlock state"); + xbt_assert(checker_side_.get_channel().send(MessageType::DEADLOCK_CHECK) == 0, "Could not check deadlock state"); s_mc_message_int_t message; ssize_t s = checker_side_.get_channel().receive(message); xbt_assert(s != -1, "Could not receive message");