X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/f6acb706fa20197049c849cf3021077c5fa97f93..e7d1d5c0992980f857cb281b7f168b1ca9b54297:/include/simgrid/s4u/Engine.hpp diff --git a/include/simgrid/s4u/Engine.hpp b/include/simgrid/s4u/Engine.hpp index c9d2318b07..636f678ed2 100644 --- a/include/simgrid/s4u/Engine.hpp +++ b/include/simgrid/s4u/Engine.hpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2006-2017. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2006-2018. 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. */ @@ -13,21 +13,18 @@ #include #include +#include #include -#include +#include namespace simgrid { -namespace kernel { -class EngineImpl; -} namespace s4u { /** @brief Simulation engine * * This class is an interface to the simulation engine. */ -XBT_PUBLIC_CLASS Engine -{ +class XBT_PUBLIC Engine { public: /** Constructor, taking the command line parameters of your main function */ Engine(int* argc, char** argv); @@ -49,7 +46,7 @@ public: /** Registers a function as the default main function of actors * * It will be used as fallback when the function requested from the deployment file was not registered. - * It is used for trace-based simulations (see examples/msg/actions). + * It is used for trace-based simulations (see examples/s4u/replay-comms and similar). */ void registerDefault(int (*code)(int, char**)); @@ -58,16 +55,27 @@ public: protected: friend s4u::Host; + friend s4u::Storage; void addHost(std::string name, simgrid::s4u::Host * host); void delHost(std::string name); + void addStorage(std::string name, simgrid::s4u::Storage * storage); + void delStorage(std::string name); public: simgrid::s4u::Host* hostByName(std::string name); simgrid::s4u::Host* hostByNameOrNull(std::string name); + simgrid::s4u::Storage* storageByName(std::string name); + simgrid::s4u::Storage* storageByNameOrNull(std::string name); + size_t getHostCount(); void getHostList(std::vector * whereTo); + std::vector getAllHosts(); + size_t getLinkCount(); void getLinkList(std::vector * list); + std::vector getAllLinks(); + + std::vector getAllStorages(); /** @brief Run the simulation */ void run(); @@ -85,8 +93,7 @@ public: simgrid::s4u::NetZone* getNetzoneByNameOrNull(const char* name); /** @brief Retrieves all netzones of the same type than the subtype of the whereto vector */ - template void getNetzoneByType(std::vector * whereto); - + template void getNetzoneByType(std::vector * whereto) { netzoneByTypeRecursive(getNetRoot(), whereto); } /** @brief Retrieve the netcard of the given name (or nullptr if not found) */ simgrid::kernel::routing::NetPoint* getNetpointByNameOrNull(std::string name); void getNetpointList(std::vector * list); @@ -130,16 +137,25 @@ private: /** Callback fired when the platform is created (ie, the xml file parsed), * right before the actual simulation starts. */ -extern XBT_PUBLIC(xbt::signal) onPlatformCreated; +extern XBT_PUBLIC xbt::signal onPlatformCreated; -/** Callback fired when the main simulation loop ends, just before MSG_run (or similar) ends */ -extern XBT_PUBLIC(xbt::signal) onSimulationEnd; +/** Callback fired when the main simulation loop ends, just before the end of Engine::run() */ +extern XBT_PUBLIC xbt::signal onSimulationEnd; /** Callback fired when the time jumps into the future */ -extern XBT_PUBLIC(xbt::signal) onTimeAdvance; +extern XBT_PUBLIC xbt::signal onTimeAdvance; /** Callback fired when the time cannot jump because of inter-actors deadlock */ -extern XBT_PUBLIC(xbt::signal) onDeadlock; +extern XBT_PUBLIC xbt::signal onDeadlock; + +template XBT_PRIVATE void netzoneByTypeRecursive(s4u::NetZone* current, std::vector* whereto) +{ + for (auto const& elem : *(current->getChildren())) { + netzoneByTypeRecursive(elem, whereto); + if (elem == dynamic_cast(elem)) + whereto->push_back(dynamic_cast(elem)); + } +} } } // namespace simgrid::s4u