X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/73662a7c0b0d1e462f2b99322183295be3a24a5a..c1194401ce4a41ff54a7591f4cf33c9ce2756978:/src/surf/network_smpi.cpp diff --git a/src/surf/network_smpi.cpp b/src/surf/network_smpi.cpp index 68174dae76..9a14001b65 100644 --- a/src/surf/network_smpi.cpp +++ b/src/surf/network_smpi.cpp @@ -1,61 +1,18 @@ -/* Copyright (c) 2013-2014. The SimGrid Team. - * All rights reserved. */ +/* Copyright (c) 2013-2019. 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 "network_smpi.hpp" -#include "simgrid/sg_config.h" +#include "simgrid/sg_config.hpp" +#include "smpi_utils.hpp" +#include "src/surf/surf_interface.hpp" +#include "surf/surf.hpp" XBT_LOG_EXTERNAL_DEFAULT_CATEGORY(surf_network); -xbt_dynar_t smpi_bw_factor = NULL; -xbt_dynar_t smpi_lat_factor = NULL; - -typedef struct s_smpi_factor *smpi_factor_t; -typedef struct s_smpi_factor { - long factor; - double value; -} s_smpi_factor_t; - -xbt_dict_t gap_lookup = NULL; - -static int factor_cmp(const void *pa, const void *pb) -{ - return (((s_smpi_factor_t*)pa)->factor > ((s_smpi_factor_t*)pb)->factor) ? 1 : - (((s_smpi_factor_t*)pa)->factor < ((s_smpi_factor_t*)pb)->factor) ? -1 : 0; -} - - -static xbt_dynar_t parse_factor(const char *smpi_coef_string) -{ - char *value = NULL; - unsigned int iter = 0; - s_smpi_factor_t fact; - xbt_dynar_t smpi_factor, radical_elements, radical_elements2 = NULL; - - smpi_factor = xbt_dynar_new(sizeof(s_smpi_factor_t), NULL); - radical_elements = xbt_str_split(smpi_coef_string, ";"); - xbt_dynar_foreach(radical_elements, iter, value) { - - radical_elements2 = xbt_str_split(value, ":"); - if (xbt_dynar_length(radical_elements2) != 2) - surf_parse_error("Malformed radical for smpi factor!"); - fact.factor = atol(xbt_dynar_get_as(radical_elements2, 0, char *)); - fact.value = atof(xbt_dynar_get_as(radical_elements2, 1, char *)); - xbt_dynar_push_as(smpi_factor, s_smpi_factor_t, fact); - XBT_DEBUG("smpi_factor:\t%ld : %f", fact.factor, fact.value); - xbt_dynar_free(&radical_elements2); - } - xbt_dynar_free(&radical_elements); - iter=0; - xbt_dynar_sort(smpi_factor, &factor_cmp); - xbt_dynar_foreach(smpi_factor, iter, fact) { - XBT_DEBUG("ordered smpi_factor:\t%ld : %f", fact.factor, fact.value); - - } - return smpi_factor; -} +std::vector smpi_bw_factor; +std::vector smpi_lat_factor; /********* * Model * @@ -72,153 +29,74 @@ static xbt_dynar_t parse_factor(const char *smpi_coef_string) /* month=may, */ /* year={2011} */ /* } */ -void surf_network_model_init_SMPI(void) +void surf_network_model_init_SMPI() { - if (surf_network_model) return; - surf_network_model = new NetworkSmpiModel(); - net_define_callbacks(); - xbt_dynar_push(model_list, &surf_network_model); - //network_solve = lmm_solve; + surf_network_model = new simgrid::kernel::resource::NetworkSmpiModel(); - xbt_cfg_setdefault_double(_sg_cfg_set, "network/sender_gap", 10e-6); - xbt_cfg_setdefault_double(_sg_cfg_set, "network/weight_S", 8775); + simgrid::config::set_default("network/weight-S", 8775); } -NetworkSmpiModel::NetworkSmpiModel() - : NetworkCm02Model() { - m_haveGap=true; -} +namespace simgrid { +namespace kernel { +namespace resource { -NetworkSmpiModel::~NetworkSmpiModel(){ - if (gap_lookup) { - xbt_dict_free(&gap_lookup); - } - if (smpi_bw_factor) { - xbt_dynar_free(&smpi_bw_factor); - smpi_bw_factor = NULL; - } - if (smpi_lat_factor) { - xbt_dynar_free(&smpi_lat_factor); - smpi_lat_factor = NULL; - } -} - -void NetworkSmpiModel::gapAppend(double size, const NetworkLinkPtr link, NetworkActionPtr action) +NetworkSmpiModel::NetworkSmpiModel() : NetworkCm02Model() { - const char *src = link->getName(); - xbt_fifo_t fifo; - //surf_action_network_CM02_t last_action; - //double bw; - - if (sg_sender_gap > 0.0) { - if (!gap_lookup) { - gap_lookup = xbt_dict_new_homogeneous(NULL); - } - fifo = (xbt_fifo_t) xbt_dict_get_or_null(gap_lookup, src); - action->m_senderGap = 0.0; - if (fifo && xbt_fifo_size(fifo) > 0) { - /* Compute gap from last send */ - /*last_action = - (surf_action_network_CM02_t) - xbt_fifo_get_item_content(xbt_fifo_get_last_item(fifo));*/ - // bw = net_get_link_bandwidth(link); - action->m_senderGap = sg_sender_gap; - /* max(sg_sender_gap,last_action->sender.size / bw);*/ - action->m_latency += action->m_senderGap; - } - /* Append action as last send */ - /*action->sender.link_name = link->lmm_resource.generic_resource.name; - fifo = - (xbt_fifo_t) xbt_dict_get_or_null(gap_lookup, - action->sender.link_name); - if (!fifo) { - fifo = xbt_fifo_new(); - xbt_dict_set(gap_lookup, action->sender.link_name, fifo, NULL); - } - action->sender.fifo_item = xbt_fifo_push(fifo, action);*/ - action->m_senderSize = size; - } + /* Do not add this into all_existing_models: our ancestor already does so */ } -void NetworkSmpiModel::gapRemove(ActionPtr lmm_action) -{ - xbt_fifo_t fifo; - size_t size; - NetworkCm02ActionPtr action = static_cast(lmm_action); - - if (sg_sender_gap > 0.0 && action->p_senderLinkName - && action->p_senderFifoItem) { - fifo = - (xbt_fifo_t) xbt_dict_get_or_null(gap_lookup, - action->p_senderLinkName); - xbt_fifo_remove_item(fifo, action->p_senderFifoItem); - size = xbt_fifo_size(fifo); - if (size == 0) { - xbt_fifo_free(fifo); - xbt_dict_remove(gap_lookup, action->p_senderLinkName); - size = xbt_dict_length(gap_lookup); - if (size == 0) { - xbt_dict_free(&gap_lookup); - } - } - } -} +NetworkSmpiModel::~NetworkSmpiModel() = default; -double NetworkSmpiModel::bandwidthFactor(double size) +double NetworkSmpiModel::get_bandwidth_factor(double size) { - if (!smpi_bw_factor) - smpi_bw_factor = - parse_factor(sg_cfg_get_string("smpi/bw_factor")); - - unsigned int iter = 0; - s_smpi_factor_t fact; - double current=1.0; - xbt_dynar_foreach(smpi_bw_factor, iter, fact) { + if (smpi_bw_factor.empty()) + smpi_bw_factor = parse_factor(simgrid::config::get_value("smpi/bw-factor")); + + double current = 1.0; + for (auto const& fact : smpi_bw_factor) { if (size <= fact.factor) { - XBT_DEBUG("%f <= %ld return %f", size, fact.factor, current); + XBT_DEBUG("%f <= %zu return %f", size, fact.factor, current); return current; - }else - current=fact.value; + } else + current = fact.values.front(); } - XBT_DEBUG("%f > %ld return %f", size, fact.factor, current); + XBT_DEBUG("%f > %zu return %f", size, smpi_bw_factor.back().factor, current); return current; } -double NetworkSmpiModel::latencyFactor(double size) +double NetworkSmpiModel::get_latency_factor(double size) { - if (!smpi_lat_factor) - smpi_lat_factor = - parse_factor(sg_cfg_get_string("smpi/lat_factor")); - - unsigned int iter = 0; - s_smpi_factor_t fact; - double current=1.0; - xbt_dynar_foreach(smpi_lat_factor, iter, fact) { + if (smpi_lat_factor.empty()) + smpi_lat_factor = parse_factor(simgrid::config::get_value("smpi/lat-factor")); + + double current = 1.0; + for (auto const& fact : smpi_lat_factor) { if (size <= fact.factor) { - XBT_DEBUG("%f <= %ld return %f", size, fact.factor, current); + XBT_DEBUG("%f <= %zu return %f", size, fact.factor, current); return current; - }else - current=fact.value; + } else + current = fact.values.front(); } - XBT_DEBUG("%f > %ld return %f", size, fact.factor, current); + XBT_DEBUG("%f > %zu return %f", size, smpi_lat_factor.back().factor, current); return current; } -double NetworkSmpiModel::bandwidthConstraint(double rate, double bound, double size) +double NetworkSmpiModel::get_bandwidth_constraint(double rate, double bound, double size) { - return rate < 0 ? bound : min(bound, rate * bandwidthFactor(size)); + return rate < 0 ? bound : std::min(bound, rate * get_bandwidth_factor(size)); } /************ * Resource * ************/ - - /********** * Action * **********/ +} +} +} // namespace simgrid