X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/836b672987ff5f6786e727bdc46eca4b84d7484d..dc76306284748ef47d089d7816204fefde54a337:/examples/msg/gtnets/gtnets.c diff --git a/examples/msg/gtnets/gtnets.c b/examples/msg/gtnets/gtnets.c index 63be2558b4..22adcee44a 100644 --- a/examples/msg/gtnets/gtnets.c +++ b/examples/msg/gtnets/gtnets.c @@ -98,7 +98,9 @@ int slave(int argc, char *argv[]) m_task_t task = NULL; int a; int id = 0; +#ifdef HAVE_LATENCY_BOUND_TRACKING int limited_latency=0; +#endif double remaining = 0; char id_alias[10]; @@ -108,6 +110,7 @@ int slave(int argc, char *argv[]) id = atoi(argv[1]); sprintf(id_alias, "%d", id); + int trace_id = id; a = MSG_task_receive(&(task), id_alias); @@ -123,21 +126,25 @@ int slave(int argc, char *argv[]) for (id = 0; id < NTASKS; id++) { if (gl_task_array[id] == NULL) { } else if (gl_task_array[id] == task) { +#ifdef HAVE_LATENCY_BOUND_TRACKING limited_latency = MSG_task_is_latency_bounded(gl_task_array[id]); if(limited_latency){ INFO1("WARNING FLOW[%d] is limited by latency!!", id); } +#endif INFO5 ("===> Estimated Bw of FLOW[%d] : %f ; message from %s to %s with remaining : %f", id, gl_data_size[id] / elapsed_time, masternames[id], slavenames[id], 0.0); } else { remaining = MSG_task_get_remaining_communication(gl_task_array[id]); +#ifdef HAVE_LATENCY_BOUND_TRACKING limited_latency = MSG_task_is_latency_bounded(gl_task_array[id]); if(limited_latency){ INFO1("WARNING FLOW[%d] is limited by latency!!", id); } +#endif INFO5 ("===> Estimated Bw of FLOW[%d] : %f ; message from %s to %s with remaining : %f", id, (gl_data_size[id] - remaining) / elapsed_time, masternames[id], @@ -145,8 +152,10 @@ int slave(int argc, char *argv[]) } } - TRACE_mark ("endmark", "finished"); } + char mark[100]; + snprintf (mark, 100, "flow_%d_finished", trace_id); + TRACE_mark ("endmark", mark); MSG_task_destroy(task); return 0;