X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/2807fde4fd1f59c230d69a934634c5dfb77905f2..28b9e83a90c238b71d27f5cb3c6596906a3d4641:/src/mc/ModelChecker.hpp diff --git a/src/mc/ModelChecker.hpp b/src/mc/ModelChecker.hpp index e7b7e9022c..0d51e9e236 100644 --- a/src/mc/ModelChecker.hpp +++ b/src/mc/ModelChecker.hpp @@ -1,5 +1,4 @@ -/* Copyright (c) 2007-2017. The SimGrid Team. - * All rights reserved. */ +/* Copyright (c) 2007-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. */ @@ -7,88 +6,44 @@ #ifndef SIMGRID_MC_MODEL_CHECKER_HPP #define SIMGRID_MC_MODEL_CHECKER_HPP -#include - -#include -#include -#include - -#include - +#include "src/mc/remote/CheckerSide.hpp" +#include "src/mc/remote/RemotePtr.hpp" +#include "src/mc/sosp/PageStore.hpp" #include "xbt/base.h" -#include -#include "src/mc/PageStore.hpp" -#include "src/mc/Transition.hpp" -#include "src/mc/mc_forward.hpp" -#include "src/mc/remote/RemoteClient.hpp" -#include "src/mc/remote/mc_protocol.h" +#include -namespace simgrid { -namespace mc { +namespace simgrid::mc { /** State of the model-checker (global variables for the model checker) */ class ModelChecker { - struct event_base *base_; - struct event* socket_event_; - struct event* signal_event_; - /** String pool for host names */ - // TODO, use std::set with heterogeneous comparison lookup (C++14)? - std::set hostnames_; - // This is the parent snapshot of the current state: - PageStore page_store_; - std::unique_ptr process_; - Checker* checker_ = nullptr; -public: - std::shared_ptr parent_snapshot_; + CheckerSide checker_side_; + std::unique_ptr remote_process_memory_; + Exploration* exploration_ = nullptr; +public: ModelChecker(ModelChecker const&) = delete; ModelChecker& operator=(ModelChecker const&) = delete; - explicit ModelChecker(std::unique_ptr process); - ~ModelChecker(); - - RemoteClient& process() { return *process_; } - PageStore& page_store() - { - return page_store_; - } + explicit ModelChecker(std::unique_ptr remote_simulation, int sockfd); - std::string const& get_host_name(const char* hostname) - { - return *this->hostnames_.insert(hostname).first; - } - std::string const& get_host_name(std::string const& hostname) - { - return *this->hostnames_.insert(hostname).first; - } + RemoteProcessMemory& get_remote_process_memory() { return *remote_process_memory_; } + Channel& get_channel() { return checker_side_.get_channel(); } + void channel_handle_events() { checker_side_.dispatch(); } void start(); - void shutdown(); - void resume(simgrid::mc::RemoteClient& process); - void loop(); - void handle_events(int fd, short events); - void wait_for_requests(); - void handle_simcall(Transition const& transition); - void exit(int status); - bool checkDeadlock(); + /** Let the application take a transition. A new Transition is created iff the last parameter is true */ + Transition* handle_simcall(aid_t aid, int times_considered, bool new_transition); - Checker* getChecker() const { return checker_; } - void setChecker(Checker* checker) { checker_ = checker; } + Exploration* get_exploration() const { return exploration_; } + void set_exploration(Exploration* exploration) { exploration_ = exploration; } private: - void setup_ignore(); - bool handle_message(char* buffer, ssize_t size); + bool handle_message(const char* buffer, ssize_t size); void handle_waitpid(); - void on_signal(int signo); - -public: - unsigned long visited_states = 0; - unsigned long executed_transitions = 0; }; -} -} +} // namespace simgrid::mc #endif