Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
new tracing mask TRACE_VOLUME to trace the msg tasks communication size and group...
[simgrid.git] / src / smpi / smpi_util.c
index 91649a8..1e2fb2c 100644 (file)
@@ -3,6 +3,7 @@
 XBT_LOG_NEW_DEFAULT_SUBCATEGORY(smpi_util, smpi,
                                 "Logging specific to SMPI (utilities)");
 
+/*
 int smpi_gettimeofday(struct timeval *tv, struct timezone *tz)
 {
   double now;
@@ -23,34 +24,13 @@ int smpi_gettimeofday(struct timeval *tv, struct timezone *tz)
 unsigned int smpi_sleep(unsigned int seconds)
 {
   smx_host_t host;
-  smx_mutex_t mutex;
-  smx_cond_t cond;
   smx_action_t action;
-  e_surf_action_state_t state;
 
   smpi_bench_end();
-
   host = SIMIX_host_self();
-  mutex = smpi_process_mutex();
-  cond = smpi_process_cond();
-
-  SIMIX_mutex_lock(mutex);
-
-  // FIXME: explicit conversion to double?
-  action = SIMIX_action_sleep(host, seconds);
-
-  SIMIX_register_action_to_condition(action, cond);
-  for (state = SIMIX_action_get_state(action);
-       state == SURF_ACTION_READY ||
-       state == SURF_ACTION_RUNNING; state = SIMIX_action_get_state(action)
-    ) {
-    SIMIX_cond_wait(cond, mutex);
-  }
-  SIMIX_unregister_action_to_condition(action, cond);
+  action = SIMIX_action_sleep(host, (double)seconds);
+  smpi_process_wait_action(action);
   SIMIX_action_destroy(action);
-
-  SIMIX_mutex_unlock(mutex);
-
   smpi_bench_begin();
   return 0;
 }
@@ -62,3 +42,4 @@ void smpi_exit(int status)
   SIMIX_process_kill(SIMIX_process_self());
   return;
 }
+*/