X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/41f97f763bc1771fe15e96ffcd4ff3e7c76a9a63..d30da2368132926308b70ab2553bc0d288f507e1:/src/kernel/EngineImpl.cpp diff --git a/src/kernel/EngineImpl.cpp b/src/kernel/EngineImpl.cpp index 9fa10c8a12..b6b12995d3 100644 --- a/src/kernel/EngineImpl.cpp +++ b/src/kernel/EngineImpl.cpp @@ -1,50 +1,79 @@ -/* Copyright (c) 2016-2018. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2016-2021. 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. */ #include "src/kernel/EngineImpl.hpp" +#include "simgrid/Exception.hpp" #include "simgrid/kernel/routing/NetPoint.hpp" #include "simgrid/kernel/routing/NetZoneImpl.hpp" #include "simgrid/s4u/Host.hpp" -#include "simgrid/s4u/Link.hpp" -#include "src/surf/StorageImpl.hpp" - -#include +#include "src/kernel/resource/DiskImpl.hpp" +#include "src/simix/smx_private.hpp" +#include "src/surf/network_interface.hpp" +#include "src/surf/xml/platf.hpp" // FIXME: KILLME. There must be a better way than mimicking XML here namespace simgrid { namespace kernel { -EngineImpl::EngineImpl() = default; EngineImpl::~EngineImpl() { - /* copy all names to not modify the map while iterating over it. - * - * Plus, the hosts are destroyed in the lexicographic order to ensure - * that the output is reproducible: we don't want to kill them in the - * pointer order as it could be platform-dependent, which would break - * the tests. + /* Since hosts_ is a std::map, the hosts are destroyed in the lexicographic order, which ensures that the output is + * reproducible. */ - std::vector names; - for (auto const& kv : hosts_) - names.push_back(kv.second->get_name()); - - std::sort(names.begin(), names.end()); - - for (auto const& name : names) - hosts_.at(name)->destroy(); + while (not hosts_.empty()) + hosts_.begin()->second->destroy(); /* Also delete the other data */ delete netzone_root_; for (auto const& kv : netpoints_) delete kv.second; - for (auto const& kv : storages_) - if (kv.second) - kv.second->getImpl()->destroy(); for (auto const& kv : links_) if (kv.second) - (kv.second)->destroy(); + kv.second->destroy(); } + +void EngineImpl::load_deployment(const std::string& file) const +{ + sg_platf_exit(); + sg_platf_init(); + + surf_parse_open(file); + surf_parse(); + surf_parse_close(); } + +void EngineImpl::register_function(const std::string& name, const actor::ActorCodeFactory& code) +{ + registered_functions[name] = code; +} +void EngineImpl::register_default(const actor::ActorCodeFactory& code) +{ + default_function = code; } + +void EngineImpl::add_model_ptask(resource::Model::Type type, resource::Model* model, bool is_default) +{ + if (is_default) + models_by_type_[type].insert(models_by_type_[type].begin(), model); + else + models_by_type_[type].push_back(model); +} + +void EngineImpl::add_model(resource::Model::Type type, std::unique_ptr model, bool is_default) +{ + add_model_ptask(type, model.get(), is_default); + models_.push_back(std::move(model)); +} + +resource::Model* EngineImpl::get_default_model(resource::Model::Type type) +{ + if (models_by_type_[type].size() > 0) + return models_by_type_[type][0]; + else + return nullptr; +} + +} // namespace kernel +} // namespace simgrid