X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/0facf52013684615c801816de974754778c9474a..609b277351c837356a7b284127eed888eca3620d:/src/mc/ModelChecker.cpp diff --git a/src/mc/ModelChecker.cpp b/src/mc/ModelChecker.cpp index f83ee8d1c0..f44ed02065 100644 --- a/src/mc/ModelChecker.cpp +++ b/src/mc/ModelChecker.cpp @@ -40,23 +40,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; @@ -317,7 +319,7 @@ void ModelChecker::handle_simcall(Transition const& transition) if (this->remote_process_->running()) checker_side_.dispatch(); } -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"); @@ -336,13 +338,13 @@ 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) +std::string ModelChecker::simcall_to_string(MessageType type, aid_t aid, int times_considered) { xbt_assert(mc_model_checker != nullptr, "This should be called from the checker side"); @@ -365,17 +367,17 @@ std::string ModelChecker::simcall_to_string(MessageType type, int aid, int times return std::string(answer.value); } -std::string ModelChecker::simcall_to_string(int aid, int times_considered) +std::string ModelChecker::simcall_to_string(aid_t 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()); + XBT_DEBUG("to_string(%ld) is returning %s", aid, answer.c_str()); return answer; } -std::string ModelChecker::simcall_dot_label(int aid, int times_considered) +std::string ModelChecker::simcall_dot_label(aid_t 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()); + XBT_DEBUG("dot_label(%ld) is returning %s", aid, answer.c_str()); return answer; }