X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/aa64bb0b015da853b7f904a9384cfa14cf42326f..9a6b1a23ce86f475df4c3dd63310c3484cebd956:/src/kernel/EngineImpl.hpp?ds=sidebyside diff --git a/src/kernel/EngineImpl.hpp b/src/kernel/EngineImpl.hpp index e2a082cb1e..6ea9106128 100644 --- a/src/kernel/EngineImpl.hpp +++ b/src/kernel/EngineImpl.hpp @@ -29,17 +29,9 @@ #include #include -namespace simgrid { -namespace kernel { -// In MC mode, the application sends these pointers to the MC -xbt_dynar_t get_actors_addr(); +namespace simgrid::kernel { class EngineImpl { - std::map> hosts_; - std::map> links_; - /* save split-duplex links separately, keep links_ with only LinkImpl* seen by the user - * members of a split-duplex are saved in the links_ */ - std::map, std::less<>> split_duplex_links_; std::unordered_map netpoints_; std::unordered_map mailboxes_; @@ -67,9 +59,7 @@ class EngineImpl { xbt_dynar_t actors_vector_ = xbt_dynar_new(sizeof(actor::ActorImpl*), nullptr); #endif - std::vector> tasks; - - std::mutex mutex_; + static double now_; static EngineImpl* instance_; actor::ActorImpl* maestro_ = nullptr; context::ContextFactory* context_factory_ = nullptr; @@ -102,11 +92,6 @@ public: context::ContextFactory* get_context_factory() const { return context_factory_; } void set_context_factory(context::ContextFactory* factory) { context_factory_ = factory; } bool has_context_factory() const { return context_factory_ != nullptr; } - void destroy_context_factory() - { - delete context_factory_; - context_factory_ = nullptr; - } void context_mod_init() const; /** @@ -150,10 +135,8 @@ public: actor::ActorImpl* get_actor_by_pid(aid_t pid); void add_actor(aid_t pid, actor::ActorImpl* actor) { actor_list_[pid] = actor; } void remove_actor(aid_t pid) { actor_list_.erase(pid); } - void add_split_duplex_link(const std::string& name, std::unique_ptr link); #if SIMGRID_HAVE_MC - xbt_dynar_t get_actors_vector() const { return actors_vector_; } void reset_actor_dynar() { xbt_dynar_reset(actors_vector_); } void add_actor_to_dynar(actor::ActorImpl* actor) { xbt_dynar_push_as(actors_vector_, actor::ActorImpl*, actor); } #endif @@ -162,10 +145,7 @@ public: const std::vector& get_actors_to_run() const { return actors_to_run_; } const std::vector& get_actors_that_ran() const { return actors_that_ran_; } - std::mutex& get_mutex() { return mutex_; } - bool execute_tasks(); - void add_task(xbt::Task&& t) { tasks.push_back(std::move(t)); } - void wake_all_waiting_actors() const; + void handle_ended_actions() const; /** * Garbage collection * @@ -197,7 +177,6 @@ public: static double get_clock(); }; -} // namespace kernel -} // namespace simgrid +} // namespace simgrid::kernel #endif