Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
ChangeLog update
[simgrid.git] / src / msg / msg_gos.c
index f31cec1..bcc59e1 100644 (file)
@@ -75,7 +75,7 @@ msg_error_t MSG_parallel_task_execute(msg_task_t task)
       XBT_DEBUG("Parallel execution action created: %p", simdata->compute);
     } else {
       simdata->compute = simcall_host_execute(task->name,
-                                              p_simdata->m_host->smx_host,
+                                              p_simdata->m_host,
                                               simdata->computation_amount,
                                               simdata->priority);
 
@@ -571,15 +571,15 @@ msg_error_t MSG_comm_wait(msg_comm_t comm, double timeout)
 /** \ingroup msg_task_usage
 * \brief This function is called by a sender and permit to wait for each communication
 *
-* \param comm a vector of communications
+* \param comm a vector of communication
+* \param nb_elem is the size of the comm vector
 * \param timeout for each call of MSG_comm_wait
 */
-void MSG_comm_waitall(xbt_dynar_t comms, double timeout)
+void MSG_comm_waitall(msg_comm_t * comm, int nb_elem, double timeout)
 {
-  unsigned int cursor;
-  msg_comm_t comm;
-  xbt_dynar_foreach(comms, cursor, comm) {
-    MSG_comm_wait(comm, timeout);    
+  int i = 0;
+  for (i = 0; i < nb_elem; i++) {
+    MSG_comm_wait(comm[i], timeout);
   }
 }