X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/3f3fb941d6947eb019ac76114fcd0495097030ff..831de10adaaf8910940aa280e2ac2dd075b5ffe5:/src/mc/ModelChecker.hpp diff --git a/src/mc/ModelChecker.hpp b/src/mc/ModelChecker.hpp index a90e1b4137..0e7ed9d9f3 100644 --- a/src/mc/ModelChecker.hpp +++ b/src/mc/ModelChecker.hpp @@ -10,10 +10,12 @@ #include #include + #include +#include +#include #include -#include #include #include @@ -21,6 +23,7 @@ #include "src/mc/Process.hpp" #include "src/mc/PageStore.hpp" #include "src/mc/mc_protocol.h" +#include "src/mc/Transition.hpp" namespace simgrid { namespace mc { @@ -28,22 +31,21 @@ namespace mc { /** State of the model-checker (global variables for the model checker) */ class ModelChecker { - pid_t pid_; - int socket_; struct pollfd fds_[2]; /** String pool for host names */ - // TODO, use std::unordered_set with heterogeneous comparison lookup (C++14) - xbt_dict_t /* */ hostnames_; + // 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: - mc_snapshot_t parent_snapshot_; + std::shared_ptr parent_snapshot_; public: ModelChecker(ModelChecker const&) = delete; ModelChecker& operator=(ModelChecker const&) = delete; - ModelChecker(pid_t pid, int socket); + ModelChecker(std::unique_ptr process); ~ModelChecker(); Process& process() @@ -54,25 +56,34 @@ public: { return page_store_; } - const char* get_host_name(const char* name); - bool is_important_snapshot(Snapshot const& snapshot) const + 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 &snapshot == this->parent_snapshot_; + return *this->hostnames_.insert(hostname).first; } void start(); - void init_process(); void shutdown(); void resume(simgrid::mc::Process& process); void loop(); bool handle_events(); void wait_client(simgrid::mc::Process& process); - void simcall_handle(simgrid::mc::Process& process, unsigned long pid, int value); + void handle_simcall(Transition const& transition); void wait_for_requests() { mc_model_checker->wait_client(mc_model_checker->process()); } + void exit(int status); + + bool checkDeadlock(); + + Checker* getChecker() const { return checker_; } + void setChecker(Checker* checker) { checker_ = checker; } + private: void setup_ignore(); bool handle_message(char* buffer, ssize_t size); @@ -80,6 +91,9 @@ private: void handle_waitpid(); void on_signal(const struct signalfd_siginfo* info); +public: + unsigned long visited_states = 0; + unsigned long executed_transitions = 0; }; }