X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/2455643f96166346bf10d16ddc289cc44f1fe78a..a9786d0c1612118b9fc2304ea7aa36b67b232267:/src/s4u/s4u_engine.cpp diff --git a/src/s4u/s4u_engine.cpp b/src/s4u/s4u_engine.cpp index 1f6a490321..6e37df00eb 100644 --- a/src/s4u/s4u_engine.cpp +++ b/src/s4u/s4u_engine.cpp @@ -5,63 +5,78 @@ /* 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. */ -#include "simgrid/simix.h" +#include "instr/instr_interface.h" #include "mc/mc.h" -#include "simgrid/s4u/As.hpp" +#include "simgrid/s4u/Mailbox.hpp" +#include "simgrid/s4u/NetZone.hpp" #include "simgrid/s4u/engine.hpp" -#include "simgrid/s4u/mailbox.hpp" +#include "simgrid/s4u/host.hpp" #include "simgrid/s4u/storage.hpp" +#include "simgrid/simix.h" +#include "src/kernel/EngineImpl.hpp" +#include "src/kernel/routing/NetZoneImpl.hpp" + +#include "src/surf/network_interface.hpp" +#include "surf/surf.h" // routing_platf. FIXME:KILLME. SOON XBT_LOG_NEW_CATEGORY(s4u,"Log channels of the S4U (Simgrid for you) interface"); -using namespace simgrid; -s4u::Engine *s4u::Engine::instance_ = nullptr; /* That singleton is awful, but I don't see no other solution right now. */ +namespace simgrid { +namespace s4u { + +Engine *Engine::instance_ = nullptr; /* That singleton is awful, but I don't see no other solution right now. */ -s4u::Engine::Engine(int *argc, char **argv) { +Engine::Engine(int *argc, char **argv) { xbt_assert(s4u::Engine::instance_ == nullptr, "It is currently forbidden to create more than one instance of s4u::Engine"); s4u::Engine::instance_ = this; + pimpl = new kernel::EngineImpl(); + TRACE_global_init(argc, argv); SIMIX_global_init(argc, argv); } -s4u::Engine *s4u::Engine::instance() { +Engine::~Engine() +{ + delete pimpl; +} + +Engine *Engine::instance() { if (s4u::Engine::instance_ == nullptr) new Engine(0,nullptr); return s4u::Engine::instance_; } -void s4u::Engine::shutdown() { +void Engine::shutdown() { delete s4u::Engine::instance_; s4u::Engine::instance_ = nullptr; - delete s4u::Mailbox::mailboxes; delete s4u::Storage::storages_; } -double s4u::Engine::getClock() +double Engine::getClock() { return SIMIX_get_clock(); } -void s4u::Engine::loadPlatform(const char *platf) +void Engine::loadPlatform(const char *platf) { SIMIX_create_environment(platf); } -void s4u::Engine::registerFunction(const char*name, int (*code)(int,char**)) +void Engine::registerFunction(const char*name, int (*code)(int,char**)) { SIMIX_function_register(name,code); } -void s4u::Engine::registerDefault(int (*code)(int,char**)) +void Engine::registerDefault(int (*code)(int,char**)) { SIMIX_function_register_default(code); } -void s4u::Engine::loadDeployment(const char *deploy) +void Engine::loadDeployment(const char *deploy) { SIMIX_launch_application(deploy); } -void s4u::Engine::run() { +void Engine::run() { if (MC_is_active()) { MC_run(); } else { @@ -69,31 +84,46 @@ void s4u::Engine::run() { } } -#include "surf/surf.h" // routing_platf. FIXME:KILLME. SOON -#include "src/surf/surf_routing.hpp" // routing_platf. FIXME:KILLME. SOON - -s4u::As *s4u::Engine::rootAs() +s4u::NetZone* Engine::netRoot() { - return routing_platf->root_; // FIXME: get the root into the Engine directly (and kill the platf) + return pimpl->netRoot_; } -static s4u::As *asByNameRecursive(s4u::As *current, const char *name) +static s4u::NetZone* netzoneByNameRecursive(s4u::NetZone* current, const char* name) { if(!strcmp(current->name(), name)) return current; - xbt_dict_cursor_t cursor = NULL; + xbt_dict_cursor_t cursor = nullptr; char *key; - AS_t elem; + NetZone_t elem; xbt_dict_foreach(current->children(), cursor, key, elem) { - simgrid::s4u::As *tmp = asByNameRecursive(elem, name); - if (tmp != NULL ) + simgrid::s4u::NetZone* tmp = netzoneByNameRecursive(elem, name); + if (tmp != nullptr ) return tmp; } return nullptr; } -/** @brief Retrieve the AS of the given name (or nullptr if not found) */ -s4u::As *s4u::Engine::asByNameOrNull(const char *name) { - return asByNameRecursive(rootAs(),name); + +/** @brief Retrieve the NetZone of the given name (or nullptr if not found) */ +NetZone* Engine::netzoneByNameOrNull(const char* name) +{ + return netzoneByNameRecursive(netRoot(), name); } +/** @brief Retrieve the netcard of the given name (or nullptr if not found) */ +simgrid::kernel::routing::NetCard* Engine::netcardByNameOrNull(const char* name) +{ + return static_cast(xbt_dict_get_or_null(netcards_dict, name)); +} +void Engine::netcardList(std::vector* list) +{ + xbt_lib_cursor_t cursor = nullptr; + char* key; + void* data; + xbt_dict_foreach (netcards_dict, cursor, key, data) { + list->push_back(static_cast(data)); + } +} +} +}