Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
update all the platforms file with the new s/:/_/ in DTD
[simgrid.git] / examples / msg / gtnets / gtnets.c
index 196bd1b..22adcee 100644 (file)
@@ -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;
@@ -185,6 +194,7 @@ int main(int argc, char *argv[])
   }
 
   TRACE_start ();
+  TRACE_declare_mark ("endmark");
 
   res = test_all(argv[1], argv[2]);