X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/5faf49cdf3f8ad8751317b857a6d3134fe07eda3..efbbd7433e0f1dc72d63f821fbbcaf12962469c8:/src/surf/network_smpi.cpp diff --git a/src/surf/network_smpi.cpp b/src/surf/network_smpi.cpp index 10d2e6247b..8f707a5df9 100644 --- a/src/surf/network_smpi.cpp +++ b/src/surf/network_smpi.cpp @@ -16,7 +16,8 @@ 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); + 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; } @@ -71,13 +72,33 @@ void surf_network_model_init_SMPI(void) 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; xbt_cfg_setdefault_double(_sg_cfg_set, "network/sender_gap", 10e-6); xbt_cfg_setdefault_double(_sg_cfg_set, "network/weight_S", 8775); } +NetworkSmpiModel::NetworkSmpiModel() + : NetworkCm02Model() { + m_haveGap=true; +} + +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 NetworkCm02LinkLmmPtr link, NetworkCm02ActionLmmPtr action) { const char *src = link->m_name; @@ -87,7 +108,7 @@ void NetworkSmpiModel::gapAppend(double size, const NetworkCm02LinkLmmPtr link, if (sg_sender_gap > 0.0) { if (!gap_lookup) { - gap_lookup = xbt_dict_new(); + gap_lookup = xbt_dict_new_homogeneous(NULL); } fifo = (xbt_fifo_t) xbt_dict_get_or_null(gap_lookup, src); action->m_senderGap = 0.0; @@ -139,7 +160,7 @@ void NetworkSmpiModel::gapRemove(ActionLmmPtr lmm_action) } } -double NetworkSmpiModel::latencyFactor(double size) +double NetworkSmpiModel::bandwidthFactor(double size) { if (!smpi_bw_factor) smpi_bw_factor = @@ -150,16 +171,16 @@ double NetworkSmpiModel::latencyFactor(double size) double current=1.0; xbt_dynar_foreach(smpi_bw_factor, iter, fact) { if (size <= fact.factor) { - XBT_DEBUG("%lf <= %ld return %f", size, fact.factor, current); + XBT_DEBUG("%f <= %ld return %f", size, fact.factor, current); return current; }else current=fact.value; } - XBT_DEBUG("%lf > %ld return %f", size, fact.factor, current); + XBT_DEBUG("%f > %ld return %f", size, fact.factor, current); return current; } -double NetworkSmpiModel::bandwidthFactor(double size) +double NetworkSmpiModel::latencyFactor(double size) { if (!smpi_lat_factor) smpi_lat_factor = @@ -170,12 +191,12 @@ double NetworkSmpiModel::bandwidthFactor(double size) double current=1.0; xbt_dynar_foreach(smpi_lat_factor, iter, fact) { if (size <= fact.factor) { - XBT_DEBUG("%lf <= %ld return %f", size, fact.factor, current); + XBT_DEBUG("%f <= %ld return %f", size, fact.factor, current); return current; }else current=fact.value; } - XBT_DEBUG("%lf > %ld return %f", size, fact.factor, current); + XBT_DEBUG("%f > %ld return %f", size, fact.factor, current); return current; }