X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/ea10e88fd41a11386d9e3868d72ab8cb933a4292..96d605fde63f72480bf570f7bc7609e2954cb2d7:/src/mc/api/State.hpp diff --git a/src/mc/api/State.hpp b/src/mc/api/State.hpp index dd243f862a..01d013550e 100644 --- a/src/mc/api/State.hpp +++ b/src/mc/api/State.hpp @@ -6,12 +6,12 @@ #ifndef SIMGRID_MC_STATE_HPP #define SIMGRID_MC_STATE_HPP -#include "src/mc/mc_pattern.hpp" +#include "src/mc/api/ActorState.hpp" +#include "src/mc/api/RemoteApp.hpp" #include "src/mc/sosp/Snapshot.hpp" #include "src/mc/transition/Transition.hpp" -namespace simgrid { -namespace mc { +namespace simgrid::mc { /* A node in the exploration graph (kind-of) */ class XBT_PRIVATE State : public xbt::Extendable { @@ -20,30 +20,34 @@ class XBT_PRIVATE State : public xbt::Extendable { /* Outgoing transition: what was the last transition that we took to leave this state? */ std::unique_ptr transition_; - /** Sequential state number (used for debugging) */ + /** Sequential state ID (used for debugging) */ long num_ = 0; - /** State's exploration status by process */ - std::vector actor_states_; + /** State's exploration status by actor. Not all the actors are there, only the ones that are ready-to-run in this state */ + std::map actors_to_run_; /** Snapshot of system state (if needed) */ std::shared_ptr system_state_; public: - explicit State(); + explicit State(RemoteApp& remote_app); /* Returns a positive number if there is another transition to pick, or -1 if not */ - int next_transition() const; + aid_t next_transition() const; /* Explore a new path; the parameter must be the result of a previous call to next_transition() */ - void execute_next(int next); + void execute_next(aid_t next); long get_num() const { return num_; } std::size_t count_todo() const; - void mark_todo(aid_t actor) { this->actor_states_[actor].mark_todo(); } - bool is_done(aid_t actor) const { return this->actor_states_[actor].is_done(); } + void mark_todo(aid_t actor) { actors_to_run_.at(actor).mark_todo(); } + bool is_done(aid_t actor) const { return actors_to_run_.at(actor).is_done(); } Transition* get_transition() const; void set_transition(Transition* t) { transition_.reset(t); } + std::map const& get_actors_list() { return actors_to_run_; } + + int get_actor_count() { return actors_to_run_.size(); } + bool is_actor_enabled(int actor) { return actors_to_run_.at(actor).is_enabled(); } Snapshot* get_system_state() const { return system_state_.get(); } void set_system_state(std::shared_ptr state) { system_state_ = std::move(state); } @@ -51,7 +55,6 @@ public: /* Returns the total amount of states created so far (for statistics) */ static long get_expanded_states() { return expended_states_; } }; -} // namespace mc -} // namespace simgrid +} // namespace simgrid::mc #endif