X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/ba24a6c5ee07011c4418b2e327843f0d62658157..19e1048a7009c4144b0f361ad85fb9dff44761ea:/src/s4u/s4u_Engine.cpp diff --git a/src/s4u/s4u_Engine.cpp b/src/s4u/s4u_Engine.cpp index 6cdb27598a..47b512e668 100644 --- a/src/s4u/s4u_Engine.cpp +++ b/src/s4u/s4u_Engine.cpp @@ -16,6 +16,7 @@ #include "simgrid/simix.h" #include "src/instr/instr_private.hpp" #include "src/kernel/EngineImpl.hpp" +#include "src/mc/mc_replay.hpp" #include "src/surf/network_interface.hpp" #include "surf/surf.hpp" // routing_platf. FIXME:KILLME. SOON #include @@ -80,7 +81,11 @@ void Engine::shutdown() double Engine::get_clock() { - return SIMIX_get_clock(); + if (MC_is_active() || MC_record_replay_is_active()) { + return MC_process_clock_get(SIMIX_process_self()); + } else { + return surf_get_clock(); + } } void Engine::add_model(std::shared_ptr model, @@ -103,11 +108,7 @@ const std::vector& Engine::get_all_models() c */ void Engine::load_platform(const std::string& platf) const { - double start = xbt_os_time(); - parse_platform_file(platf); - - double end = xbt_os_time(); - XBT_DEBUG("PARSE TIME: %g", (end - start)); + pimpl->load_platform(platf); } void Engine::register_function(const std::string& name, int (*code)(int, char**)) // XBT_ATTRIB_DEPRECATED_v329 @@ -235,6 +236,14 @@ Link* Engine::link_by_name(const std::string& name) const return link->second->get_iface(); } +SplitDuplexLink* Engine::split_duplex_link_by_name(const std::string& name) const +{ + auto link = pimpl->split_duplex_links_.find(name); + if (link == pimpl->split_duplex_links_.end()) + throw std::invalid_argument(std::string("Link not found: ") + name); + return link->second->get_iface(); +} + /** @brief Find a link from its name (or nullptr if that link does not exist) */ Link* Engine::link_by_name_or_null(const std::string& name) const { @@ -249,9 +258,8 @@ Mailbox* Engine::mailbox_by_name_or_create(const std::string& name) const kernel::activity::MailboxImpl* mbox = kernel::actor::simcall([&name, this] { auto m = pimpl->mailboxes_.emplace(name, nullptr); if (m.second) { - auto* mbox = new kernel::activity::MailboxImpl(name); - XBT_DEBUG("Creating a mailbox at %p with name %s", mbox, name.c_str()); - m.first->second = mbox; + m.first->second = new kernel::activity::MailboxImpl(name); + XBT_DEBUG("Creating a mailbox at %p with name %s", m.first->second, name.c_str()); } return m.first->second; });