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];
id = atoi(argv[1]);
sprintf(id_alias, "%d", id);
+ int trace_id = id;
a = MSG_task_receive(&(task), id_alias);
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],
}
}
- 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;
}
TRACE_start ();
+ TRACE_declare_mark ("endmark");
res = test_all(argv[1], argv[2]);