X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/ae811896a4746542e8de1616e8bc95a3ee6320f2..e6e653ac5c6803a507ccb966a6e561500f0208a2:/src/msg/msg_gos.c diff --git a/src/msg/msg_gos.c b/src/msg/msg_gos.c index f31cec178c..bcc59e135c 100644 --- a/src/msg/msg_gos.c +++ b/src/msg/msg_gos.c @@ -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); } }