X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/3f3fb941d6947eb019ac76114fcd0495097030ff..0433449947b08247ca57c84e32f547c35e351145:/src/mc/ModelChecker.hpp?ds=sidebyside diff --git a/src/mc/ModelChecker.hpp b/src/mc/ModelChecker.hpp index a90e1b4137..394a8c1822 100644 --- a/src/mc/ModelChecker.hpp +++ b/src/mc/ModelChecker.hpp @@ -21,6 +21,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 +29,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)? + xbt_dict_t /* */ 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() @@ -56,23 +56,24 @@ public: } const char* get_host_name(const char* name); - bool is_important_snapshot(Snapshot const& snapshot) const - { - return &snapshot == this->parent_snapshot_; - } - 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);