X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/2a999ac2440bf73a4b7882a728e01d3485e0982a..319324b9226c85a78ccc2faea87be6de86cf6056:/include/simgrid/s4u/Engine.hpp diff --git a/include/simgrid/s4u/Engine.hpp b/include/simgrid/s4u/Engine.hpp index fcbf72a846..742bb360c7 100644 --- a/include/simgrid/s4u/Engine.hpp +++ b/include/simgrid/s4u/Engine.hpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2006-2022. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2006-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. */ @@ -56,9 +56,33 @@ public: static s4u::Engine* get_instance(); static s4u::Engine* get_instance(int* argc, char** argv); static bool has_instance() { return instance_ != nullptr; } + const std::vector& get_cmdline() const; + /** + * Creates a new platform, including hosts, links, and the routing table. + * + * @beginrst + * See also: :ref:`platform`. + * @endrst + */ void load_platform(const std::string& platf) const; + /** + * @brief Seals the platform, finishing the creation of its resources. + * + * This method is optional. The seal() is done automatically when you call Engine::run. + */ void seal_platform() const; + /** @brief Get a debug output of the platform. + * + * It looks like a XML platform file, but it may be very different from the input platform file: All netzones are + * flatified into a unique zone. This representation is mostly useful to debug your platform configuration and ensure + * that your assumptions over your configuration hold. This enables you to verify the exact list of links traversed + * between any two hosts, and the characteristics of every host and link. But you should not use the resulting file as + * an input platform file: it is very verbose, and thus much less efficient (in parsing time and runtime performance) + * than a regular platform file with the sufficient amount of intermediary netzones. Even if you use one zone only, + * specialized zones (such as clusters) are more efficient than the one with fully explicit routing used here. + */ + std::string flatify_platform() const; /** @verbatim embed:rst:inline Bind an actor name that could be found in :ref:`pf_tag_actor` tag to a function taking classical argc/argv parameters. See the :ref:`example `. @endverbatim */ void register_function(const std::string& name, const std::function& code); @@ -105,10 +129,6 @@ protected: friend kernel::routing::NetZoneImpl; friend kernel::resource::HostImpl; friend kernel::resource::StandardLinkImpl; - void host_register(const std::string& name, Host* host); - void host_unregister(const std::string& name); - void link_register(const std::string& name, const Link* link); - void link_unregister(const std::string& name); void netpoint_register(simgrid::kernel::routing::NetPoint* card); void netpoint_unregister(simgrid::kernel::routing::NetPoint* card); void set_netzone_root(const NetZone* netzone); @@ -180,7 +200,10 @@ public: return res; } - kernel::EngineImpl* get_impl() const { return pimpl; } + kernel::EngineImpl* get_impl() const + { + return pimpl_; + } /** Returns whether SimGrid was initialized yet -- mostly for internal use */ static bool is_initialized(); @@ -200,7 +223,8 @@ public: static void set_config(const std::string& name, double value); static void set_config(const std::string& name, const std::string& value); - Engine* set_default_comm_data_copy_callback(void (*callback)(kernel::activity::CommImpl*, void*, size_t)); + Engine* + set_default_comm_data_copy_callback(const std::function& callback); /** Add a callback fired when the platform is created (ie, the xml file parsed), * right before the actual simulation starts. */ @@ -208,10 +232,15 @@ public: /** Add a callback fired when the platform is about to be created * (ie, after any configuration change and just before the resource creation) */ static void on_platform_creation_cb(const std::function& cb) { on_platform_creation.connect(cb); } + /** Add a callback fired when the main simulation loop starts, at the beginning of the first call to Engine::run() */ + static void on_simulation_start_cb(const std::function& cb) { on_simulation_start.connect(cb); } /** Add a callback fired when the main simulation loop ends, just before the end of Engine::run() */ static void on_simulation_end_cb(const std::function& cb) { on_simulation_end.connect(cb); } - /** Add a callback fired when the time jumps into the future */ + /** Add a callback fired when the time jumps into the future. + * + * It is fired right after the time change (use get_clock() to get the new timestamp). + * The callback parameter is the time delta since previous timestamp. */ static void on_time_advance_cb(const std::function& cb) { on_time_advance.connect(cb); } /** Add a callback fired when the time cannot advance because of inter-actors deadlock. Note that the on_exit of each @@ -225,16 +254,19 @@ public: #endif private: - static xbt::signal on_simulation_end; + static xbt::signal on_simulation_start; static xbt::signal on_time_advance; static xbt::signal on_deadlock; - kernel::EngineImpl* const pimpl; + static xbt::signal on_simulation_end; + + kernel::EngineImpl* const pimpl_; static Engine* instance_; void initialize(int* argc, char** argv); }; std::vector create_DAG_from_dot(const std::string& filename); std::vector create_DAG_from_DAX(const std::string& filename); +std::vector create_DAG_from_json(const std::string& filename); #ifndef DOXYGEN /* Internal use only, no need to expose it */ template