X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/ddf7edd058e0c646da8ec010cfbe068dd8e966a3..eb205f1bc5310adb939db1e08fe8bc1d02a37f8f:/src/surf/network.c diff --git a/src/surf/network.c b/src/surf/network.c index df157aa651..6dee71934e 100644 --- a/src/surf/network.c +++ b/src/surf/network.c @@ -58,11 +58,18 @@ static void gap_append(double size, const link_CM02_t link, surf_action_network_ } } +static void gap_unknown(surf_action_network_CM02_t action) { + action->sender.gap = 0.0; + action->sender.link_name = NULL; + action->sender.fifo_item = NULL; + action->sender.size = 0.0; +} + static void gap_remove(surf_action_network_CM02_t action) { xbt_fifo_t fifo; size_t size; - if(sg_sender_gap > 0.0) { + if(sg_sender_gap > 0.0 && action->sender.link_name && action->sender.fifo_item) { fifo = (xbt_fifo_t)xbt_dict_get_or_null(gap_lookup, action->sender.link_name); xbt_fifo_remove_item(fifo, action->sender.fifo_item); size = xbt_fifo_size(fifo); @@ -181,9 +188,6 @@ static link_CM02_t net_link_new(char *name, xbt_dict_set(surf_network_model->resource_set, name, nw_link, surf_resource_free); -#ifdef HAVE_TRACING - TRACE_surf_link_declaration(nw_link, name, bw_initial, lat_initial); -#endif return nw_link; } @@ -343,7 +347,7 @@ static int net_action_unref(surf_action_t action) if (action->category) xbt_free(action->category); #endif - free(action); + surf_action_free(&action); return 1; } return 0; @@ -403,6 +407,8 @@ static double net_share_resources(double now) } } + DEBUG1("Min of share resources %f", min); + return min; } @@ -438,7 +444,7 @@ static void net_update_actions_state(double now, double delta) link_CM02_t link; unsigned int i; xbt_dynar_foreach(route, i, link) { - TRACE_surf_link_set_utilization(link, + TRACE_surf_link_set_utilization(link->lmm_resource.generic_resource.name, action->generic_action.data, (surf_action_t) action, lmm_variable_getvalue @@ -502,7 +508,7 @@ static void net_update_resource_state(void *id, (nw_link->lmm_resource.power.peak * nw_link->lmm_resource.power.scale)); #ifdef HAVE_TRACING - TRACE_surf_link_set_bandwidth(date, nw_link, + TRACE_surf_link_set_bandwidth(date, nw_link->lmm_resource.generic_resource.name, sg_bandwidth_factor * (nw_link->lmm_resource.power.peak * nw_link->lmm_resource.power.scale)); @@ -665,10 +671,14 @@ static surf_action_t net_communicate(const char *src_name, (*bandwidth_constraint_callback) (action->rate, bandwidth_bound, size); - link = *(link_CM02_t*)xbt_dynar_get_ptr(route, 0); - gap_append(size, link, action); - DEBUG5("Comm %p: %s -> %s gap=%f (lat=%f)", - action, src_name, dst_name, action->sender.gap, action->latency); + if(xbt_dynar_length(route) > 0) { + link = *(link_CM02_t*)xbt_dynar_get_ptr(route, 0); + gap_append(size, link, action); + DEBUG5("Comm %p: %s -> %s gap=%f (lat=%f)", + action, src_name, dst_name, action->sender.gap, action->latency); + } else { + gap_unknown(action); + } /* LARGE PLATFORMS HACK: