X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/1f9d3ddf07955738684abcb0bc108ecd1901374d..fadac1a01fdb1a6e786d0d170f16ffab1419f2fd:/src/surf/network_smpi.cpp diff --git a/src/surf/network_smpi.cpp b/src/surf/network_smpi.cpp index 8f707a5df9..c0d682f238 100644 --- a/src/surf/network_smpi.cpp +++ b/src/surf/network_smpi.cpp @@ -1,3 +1,15 @@ +/* Copyright (c) 2013-2015. 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 + +#include + +#include + #include "network_smpi.hpp" #include "simgrid/sg_config.h" @@ -34,7 +46,7 @@ static xbt_dynar_t parse_factor(const char *smpi_coef_string) radical_elements2 = xbt_str_split(value, ":"); if (xbt_dynar_length(radical_elements2) != 2) - xbt_die("Malformed radical for smpi factor!"); + 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); @@ -71,15 +83,17 @@ void surf_network_model_init_SMPI(void) if (surf_network_model) return; - surf_network_model = new NetworkSmpiModel(); + surf_network_model = new simgrid::surf::NetworkSmpiModel(); net_define_callbacks(); - xbt_dynar_push(model_list, &surf_network_model); - //network_solve = lmm_solve; + xbt_dynar_push(all_existing_models, &surf_network_model); xbt_cfg_setdefault_double(_sg_cfg_set, "network/sender_gap", 10e-6); xbt_cfg_setdefault_double(_sg_cfg_set, "network/weight_S", 8775); } +namespace simgrid { +namespace surf { + NetworkSmpiModel::NetworkSmpiModel() : NetworkCm02Model() { m_haveGap=true; @@ -99,12 +113,11 @@ NetworkSmpiModel::~NetworkSmpiModel(){ } } -void NetworkSmpiModel::gapAppend(double size, const NetworkCm02LinkLmmPtr link, NetworkCm02ActionLmmPtr action) +void NetworkSmpiModel::gapAppend(double size, Link* link, NetworkAction *act) { - const char *src = link->m_name; + const char *src = link->getName(); xbt_fifo_t fifo; - //surf_action_network_CM02_t last_action; - //double bw; + NetworkCm02Action *action= static_cast(act); if (sg_sender_gap > 0.0) { if (!gap_lookup) { @@ -136,11 +149,11 @@ void NetworkSmpiModel::gapAppend(double size, const NetworkCm02LinkLmmPtr link, } } -void NetworkSmpiModel::gapRemove(ActionLmmPtr lmm_action) +void NetworkSmpiModel::gapRemove(Action *lmm_action) { xbt_fifo_t fifo; size_t size; - NetworkCm02ActionLmmPtr action = (NetworkCm02ActionLmmPtr)(lmm_action); + NetworkCm02Action *action = static_cast(lmm_action); if (sg_sender_gap > 0.0 && action->p_senderLinkName && action->p_senderFifoItem) { @@ -180,6 +193,7 @@ double NetworkSmpiModel::bandwidthFactor(double size) return current; } + double NetworkSmpiModel::latencyFactor(double size) { if (!smpi_lat_factor) @@ -203,7 +217,7 @@ double NetworkSmpiModel::latencyFactor(double size) double NetworkSmpiModel::bandwidthConstraint(double rate, double bound, double size) { - return rate < 0 ? bound : min(bound, rate * bandwidthFactor(size)); + return rate < 0 ? bound : std::min(bound, rate * bandwidthFactor(size)); } /************ @@ -215,3 +229,6 @@ double NetworkSmpiModel::bandwidthConstraint(double rate, double bound, double s /********** * Action * **********/ + +} +}