From f720bcdf7d23a7fb812018afc512536e324991f7 Mon Sep 17 00:00:00 2001 From: Martin Quinson Date: Sat, 12 Nov 2016 19:15:31 +0100 Subject: [PATCH] the AS can now create hosts. --- src/kernel/routing/AsImpl.cpp | 11 +++++++++-- src/kernel/routing/AsImpl.hpp | 4 ++-- src/surf/sg_platf.cpp | 36 +++++++++++++++-------------------- 3 files changed, 26 insertions(+), 25 deletions(-) diff --git a/src/kernel/routing/AsImpl.cpp b/src/kernel/routing/AsImpl.cpp index 67e292fb08..3bd9c9e080 100644 --- a/src/kernel/routing/AsImpl.cpp +++ b/src/kernel/routing/AsImpl.cpp @@ -7,6 +7,7 @@ #include "simgrid/s4u/host.hpp" #include "src/kernel/routing/AsImpl.hpp" +#include "src/surf/cpu_interface.hpp" #include "src/surf/network_interface.hpp" // Link FIXME: move to proper header XBT_LOG_NEW_DEFAULT_SUBCATEGORY(AsImpl,surf, "Implementation of S4U autonomous systems"); @@ -26,12 +27,18 @@ namespace simgrid { } AsImpl::~AsImpl() = default; - void AsImpl::attachHost(s4u::Host* host) + simgrid::s4u::Host* AsImpl::createHost(const char* name, std::vector* speedPerPstate, int coreAmount) { + simgrid::s4u::Host* res = new simgrid::s4u::Host(name); + if (hierarchy_ == RoutingMode::unset) hierarchy_ = RoutingMode::base; - host->pimpl_netcard = new NetCardImpl(host->name().c_str(), NetCard::Type::Host, this); + res->pimpl_netcard = new NetCardImpl(name, NetCard::Type::Host, this); + + surf_cpu_model_pm->createCpu(res, speedPerPstate, coreAmount); + + return res; } xbt_dynar_t AsImpl::getOneLinkRoutes() diff --git a/src/kernel/routing/AsImpl.hpp b/src/kernel/routing/AsImpl.hpp index 700f067e09..8530695984 100644 --- a/src/kernel/routing/AsImpl.hpp +++ b/src/kernel/routing/AsImpl.hpp @@ -30,8 +30,8 @@ protected: ~AsImpl() override; public: - /** @brief attach the given host to that AS */ - void attachHost(s4u::Host * host); + /** @brief Make an host within that AS */ + simgrid::s4u::Host* createHost(const char* name, std::vector* speedPerPstate, int coreAmount); /** * @brief Probe the routing path between two points diff --git a/src/surf/sg_platf.cpp b/src/surf/sg_platf.cpp index f5df97064c..1a9eee7c01 100644 --- a/src/surf/sg_platf.cpp +++ b/src/surf/sg_platf.cpp @@ -74,37 +74,31 @@ void sg_platf_exit() { } /** @brief Add an host to the current AS */ -void sg_platf_new_host(sg_platf_host_cbarg_t hostArgs) +void sg_platf_new_host(sg_platf_host_cbarg_t args) { - simgrid::kernel::routing::AsImpl* current_routing = routing_get_current(); - - simgrid::s4u::Host* host = new simgrid::s4u::Host(hostArgs->id); - current_routing->attachHost(host); - - if (hostArgs->coord && strcmp(hostArgs->coord, "")) - new simgrid::kernel::routing::vivaldi::Coords(host, hostArgs->coord); - - surf_cpu_model_pm->createCpu(host, &hostArgs->speed_per_pstate, hostArgs->core_amount); + simgrid::s4u::Host* host = routing_get_current()->createHost(args->id, &args->speed_per_pstate, args->core_amount); new simgrid::surf::HostImpl(host, mount_list); - xbt_lib_set(storage_lib, hostArgs->id, ROUTING_STORAGE_HOST_LEVEL, static_cast(mount_list)); + xbt_lib_set(storage_lib, args->id, ROUTING_STORAGE_HOST_LEVEL, static_cast(mount_list)); mount_list = nullptr; - if (hostArgs->properties) { + if (args->properties) { xbt_dict_cursor_t cursor=nullptr; char *key,*data; - xbt_dict_foreach (hostArgs->properties, cursor, key, data) + xbt_dict_foreach (args->properties, cursor, key, data) host->setProperty(key, data); - xbt_dict_free(&hostArgs->properties); + xbt_dict_free(&args->properties); } - /* Change from the default */ - if (hostArgs->state_trace) - host->pimpl_cpu->setStateTrace(hostArgs->state_trace); - if (hostArgs->speed_trace) - host->pimpl_cpu->setSpeedTrace(hostArgs->speed_trace); - if (hostArgs->pstate != 0) - host->pimpl_cpu->setPState(hostArgs->pstate); + /* Change from the defaults */ + if (args->state_trace) + host->pimpl_cpu->setStateTrace(args->state_trace); + if (args->speed_trace) + host->pimpl_cpu->setSpeedTrace(args->speed_trace); + if (args->pstate != 0) + host->pimpl_cpu->setPState(args->pstate); + if (args->coord && strcmp(args->coord, "")) + new simgrid::kernel::routing::vivaldi::Coords(host, args->coord); simgrid::s4u::Host::onCreation(*host); -- 2.20.1