X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/9b62031fae59dfc84cdcda62f6d4e35e1a55a7c5..bda6e0c064e2ebbac5dc3b5f780bb5e6cb61e9b0:/src/surf/network.c diff --git a/src/surf/network.c b/src/surf/network.c index 8555a3a6a3..7f207d0d23 100644 --- a/src/surf/network.c +++ b/src/surf/network.c @@ -18,6 +18,10 @@ static void (*network_solve) (lmm_system_t) = NULL; xbt_dict_t link_set = NULL; xbt_dict_t network_card_set = NULL; +double latency_factor = 1.0; /* default value */ +double bandwidth_factor = 1.0; /* default value */ + + int card_number = 0; int host_number = 0; link_CM02_t **routing_table = NULL; @@ -70,7 +74,7 @@ static link_CM02_t link_new(char *name, nw_link->constraint = lmm_constraint_new(network_maxmin_system, nw_link, - nw_link->bw_current); + bandwidth_factor*nw_link->bw_current); if (policy == SURF_LINK_FATPIPE) lmm_constraint_shared(nw_link->constraint); @@ -433,7 +437,7 @@ static void update_resource_state(void *id, if (event_type == nw_link->bw_event) { nw_link->bw_current = value; lmm_update_constraint_bound(network_maxmin_system, nw_link->constraint, - nw_link->bw_current); + bandwidth_factor*nw_link->bw_current); } else if (event_type == nw_link->lat_event) { double delta = value - nw_link->lat_current; lmm_variable_t var = NULL; @@ -459,8 +463,7 @@ static void update_resource_state(void *id, if (!(action->suspended)) lmm_update_variable_weight(network_maxmin_system, action->variable, action->lat_current); - lmm_update_variable_latency(network_maxmin_system, action->variable, - delta); + } } else if (event_type == nw_link->state_event) { if (value > 0) @@ -542,6 +545,8 @@ static surf_action_t communicate(void *src, void *dst, double size, /* LARGE PLATFORMS HACK: Add src->link and dst->link latencies */ action->lat_current = action->latency; + action->latency *= latency_factor; + /* LARGE PLATFORMS HACK: lmm_variable_new(..., total_route_size)*/ @@ -573,8 +578,6 @@ static surf_action_t communicate(void *src, void *dst, double size, lmm_update_variable_bound(network_maxmin_system, action->variable, action->rate); } - lmm_update_variable_latency(network_maxmin_system, action->variable, - action->latency); for (i = 0; i < route_size; i++) lmm_expand(network_maxmin_system, route[i]->constraint, @@ -766,11 +769,12 @@ static void surf_network_model_init_internal(void) network_maxmin_system = lmm_system_new(); } -/***************************************************************************/ -/* New TCP sharing model based on thesis experimantation and discussions. */ -/***************************************************************************/ +/************************************************************************/ +/* New model based on optimizations discussed during this thesis */ +/************************************************************************/ void surf_network_model_init_LegrandVelho(const char *filename) { + if (surf_network_model) return; surf_network_model_init_internal(); @@ -778,10 +782,12 @@ void surf_network_model_init_LegrandVelho(const char *filename) xbt_dynar_push(model_list, &surf_network_model); network_solve = lmm_solve; + latency_factor = 10.4; + bandwidth_factor = 0.92; + update_model_description(surf_network_model_description, "LegrandVelho", (surf_model_t) surf_network_model); - INFO0("LegrandVelho Model was chosen!!"); } /***************************************************************************/