X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/fa9f8bd4dce9b5c37e9c66ac09c9acc2e47e5bc3..e9994d33a883aa73468e38d54cf377f52b3fd950:/src/instr/jedule/jedule_platform.cpp diff --git a/src/instr/jedule/jedule_platform.cpp b/src/instr/jedule/jedule_platform.cpp index 6aedb79adc..53e657a3bc 100644 --- a/src/instr/jedule/jedule_platform.cpp +++ b/src/instr/jedule/jedule_platform.cpp @@ -1,117 +1,96 @@ -/* Copyright (c) 2010-2016. The SimGrid Team. - * All rights reserved. */ +/* Copyright (c) 2010-2020. 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 "simgrid/jedule/jedule.hpp" -#include "simgrid/jedule/jedule_platform.hpp" +#include "simgrid/host.h" #include "simgrid/s4u/NetZone.hpp" #include "xbt/asserts.h" -#include "xbt/dynar.h" #include -#if HAVE_JEDULE +#if SIMGRID_HAVE_JEDULE + +namespace { +std::unordered_map host2_simgrid_parent_container; +std::unordered_map container_name2container; +} namespace simgrid { namespace jedule { Subset::Subset(int start_idx, int end_idx, Container* parent) -: start_idx(start_idx), parent(parent) + : start_idx(start_idx), nres(end_idx - start_idx + 1), parent(parent) { - nres=end_idx-start_idx+1; } - -Container::Container(std::string name): name(name) +Container::Container(const std::string& name) : name(name) { container_name2container.insert({this->name, this}); } -Container::~Container() -{ - if(!this->children.empty()) - for (auto child: this->children) - delete child; -} - -void Container::addChild(jed_container_t child) +void Container::add_child(jed_container_t child) { - xbt_assert(this != nullptr); xbt_assert(child != nullptr); - this->children.push_back(child); - child->parent = this; + children_.emplace_back(child); + child->set_parent(this); } -void Container::addResources(std::vector hosts) +void Container::add_resources(std::vector hosts) { - this->is_lowest = 1; - this->children.clear(); - this->last_id = 0; + children_.clear(); + last_id_ = 0; - //FIXME do we need to sort?: xbt_dynar_sort_strings(host_names); - - for (auto host : hosts) { + for (auto const& host : hosts) { const char *host_name = sg_host_get_name(host); - this->name2id.insert({host_name, this->last_id}); - (this->last_id)++; + this->name2id.insert({host_name, this->last_id_}); + (this->last_id_)++; host2_simgrid_parent_container.insert({host_name, this}); this->resource_list.push_back(host); } } -void Container::createHierarchy(NetZone_t from_as) +void Container::create_hierarchy(const_sg_netzone_t from_as) { - xbt_dict_cursor_t cursor = nullptr; - char *key; - NetZone_t elem; - xbt_dict_t routing_sons = from_as->children(); - - if (xbt_dict_is_empty(routing_sons)) { + if (from_as->get_children().empty()) { // I am no AS // add hosts to jedule platform - xbt_dynar_t table = from_as->hosts(); - unsigned int dynar_cursor; - sg_host_t host; - - std::vector hosts; - - xbt_dynar_foreach(table, dynar_cursor, host) { - hosts.push_back(host); - } - this->addResources(hosts); - xbt_dynar_free(&table); + std::vector table = from_as->get_all_hosts(); + this->add_resources(table); } else { - xbt_dict_foreach(routing_sons, cursor, key, elem) { - jed_container_t child_container = new simgrid::jedule::Container(std::string(elem->name())); - this->addChild(child_container); - child_container->createHierarchy(elem); + for (auto const& nz : from_as->get_children()) { + jed_container_t child_container = new simgrid::jedule::Container(nz->get_name()); + this->add_child(child_container); + child_container->create_hierarchy(nz); } } } -std::vector Container::getHierarchy() +int Container::get_child_position(Container* child) { - xbt_assert( this!= nullptr ); + unsigned int i = 0; + int child_nb = -1; - if(this->parent != nullptr ) { + for (auto const& c : children_) { + if (c.get() == child) { + child_nb = i; + break; + } + i++; + } + return child_nb; +} - if(!this->parent->children.empty()) { +std::vector Container::get_hierarchy() +{ + if (parent_ != nullptr) { + if (not parent_->has_children()) { // we are in the last level - return this->parent->getHierarchy(); + return parent_->get_hierarchy(); } else { - unsigned int i =0; - int child_nb = -1; - - for (auto child : this->parent->children) { - if( child == this) { - child_nb = i; - break; - } - i++; - } + int child_nb = parent_->get_child_position(this); xbt_assert( child_nb > - 1); - std::vector heir_list = this->parent->getHierarchy(); + std::vector heir_list = parent_->get_hierarchy(); heir_list.insert(heir_list.begin(), child_nb); return heir_list; } @@ -122,15 +101,15 @@ std::vector Container::getHierarchy() } } -std::string Container::getHierarchyAsString() +std::string Container::get_hierarchy_as_string() { std::string output(""); - std::vector heir_list = this->getHierarchy(); + std::vector heir_list = this->get_hierarchy(); unsigned int length = heir_list.size(); unsigned int i = 0; - for (auto id : heir_list) { + for (auto const& id : heir_list) { output += std::to_string(id); if( i != length-1 ) { output += "."; @@ -140,16 +119,16 @@ std::string Container::getHierarchyAsString() return output; } -void Container::printResources(FILE * jed_file) +void Container::print_resources(FILE* jed_file) { unsigned int i=0; - xbt_assert(!this->resource_list.empty()); + xbt_assert(not this->resource_list.empty()); unsigned int res_nb = this->resource_list.size(); - std::string resid = this->getHierarchyAsString(); + std::string resid = this->get_hierarchy_as_string(); fprintf(jed_file, " resource_list) { + for (auto const& res : this->resource_list) { const char * res_name = sg_host_get_name(res); fprintf(jed_file, "%s", res_name); if( i != res_nb-1 ) { @@ -162,22 +141,22 @@ void Container::printResources(FILE * jed_file) void Container::print(FILE* jed_file) { - xbt_assert( this != nullptr ); fprintf(jed_file, " \n", this->name.c_str()); - if( !this->children.empty()){ - for (auto child: this->children) { + if (not children_.empty()) { + for (auto const& child : children_) { child->print(jed_file); } } else { - this->printResources(jed_file); + this->print_resources(jed_file); } fprintf(jed_file, " \n"); } -} -} +} // namespace jedule +} // namespace simgrid -static void add_subsets_to(std::vector *subset_list, std::vector hostgroup, jed_container_t parent) +static void add_subsets_to(std::vector& subset_list, std::vector hostgroup, + jed_container_t parent) { // get ids for each host // sort ids @@ -188,10 +167,10 @@ static void add_subsets_to(std::vector *subset_list, std::vector id_list; - for (auto host_name : hostgroup) { + for (auto const& host_name : hostgroup) { xbt_assert( host_name != nullptr ); - jed_container_t parent = host2_simgrid_parent_container.at(host_name); - unsigned int id = parent->name2id.at(host_name); + jed_container_t parent_cont = host2_simgrid_parent_container.at(host_name); + unsigned int id = parent_cont->get_id_by_name(host_name); id_list.push_back(id); } unsigned int nb_ids = id_list.size(); @@ -202,43 +181,42 @@ static void add_subsets_to(std::vector *subset_list, std::vector 1 ) { - subset_list->push_back(new simgrid::jedule::Subset(id_list[start], id_list[pos], parent)); + subset_list.emplace_back(id_list[start], id_list[pos], parent); start = i; if( i == nb_ids-1 ) { - subset_list->push_back(new simgrid::jedule::Subset(id_list[i], id_list[i], parent)); + subset_list.emplace_back(id_list[i], id_list[i], parent); } } else { if( i == nb_ids-1 ) { - subset_list->push_back(new simgrid::jedule::Subset(id_list[start], id_list[i], parent)); + subset_list.emplace_back(id_list[start], id_list[i], parent); } } pos = i; } } - } -void get_resource_selection_by_hosts(std::vector *subset_list, std::vector *host_list) +void get_resource_selection_by_hosts(std::vector& subset_list, + const std::vector& host_list) { - xbt_assert( host_list != nullptr ); // for each host name // find parent container // group by parent container std::unordered_map> parent2hostgroup; - for (auto host: *host_list) { + for (auto const& host : host_list) { const char *host_name = sg_host_get_name(host); - jed_container_t parent = host2_simgrid_parent_container.at(host_name); + const simgrid::jedule::Container* parent = host2_simgrid_parent_container.at(host_name); xbt_assert( parent != nullptr ); - auto host_group = parent2hostgroup.find(parent->name.c_str()); + auto host_group = parent2hostgroup.find(parent->get_cname()); if (host_group == parent2hostgroup.end()) - parent2hostgroup.insert({parent->name.c_str(), std::vector(1,host_name)}); + parent2hostgroup.insert({parent->get_cname(), std::vector(1, host_name)}); else host_group->second.push_back(host_name); } - for (auto elm: parent2hostgroup) { + for (auto const& elm : parent2hostgroup) { jed_container_t parent = container_name2container.at(elm.first); add_subsets_to(subset_list, elm.second, parent); }