X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/3969bc792f09c7ac4ebd5c1e556704b69269d2f7..b6fe7e75cd720400327e0585247824b7b82805aa:/src/simix/libsmx.cpp diff --git a/src/simix/libsmx.cpp b/src/simix/libsmx.cpp index 253116df3e..626f177e1f 100644 --- a/src/simix/libsmx.cpp +++ b/src/simix/libsmx.cpp @@ -25,7 +25,7 @@ #include "xbt/ex.h" #include "mc/mc.h" #include "src/simix/smx_host_private.h" -#include "src/simix/SynchroComm.hpp" +#include "src/kernel/activity/SynchroComm.hpp" #include @@ -642,8 +642,7 @@ smx_mailbox_t simcall_mbox_get_by_name(const char *name) */ smx_synchro_t simcall_mbox_front(smx_mailbox_t mbox) { - - return mbox->comm_queue->empty()? nullptr:mbox->comm_queue->front(); + return mbox->comm_queue.empty() ? nullptr : mbox->comm_queue.front(); } void simcall_mbox_set_receiver(smx_mailbox_t mbox, smx_process_t process) @@ -758,7 +757,7 @@ smx_synchro_t simcall_comm_iprobe(smx_mailbox_t mbox, int type, int src, int tag void simcall_comm_cancel(smx_synchro_t synchro) { simgrid::simix::kernelImmediate([synchro]{ - simgrid::simix::Comm *comm = static_cast(synchro); + simgrid::kernel::activity::Comm *comm = static_cast(synchro); comm->cancel(); }); } @@ -766,19 +765,19 @@ void simcall_comm_cancel(smx_synchro_t synchro) /** * \ingroup simix_comm_management */ -unsigned int simcall_comm_waitany(xbt_dynar_t comms) +unsigned int simcall_comm_waitany(xbt_dynar_t comms, double timeout) { - return simcall_BODY_comm_waitany(comms); + return simcall_BODY_comm_waitany(comms, timeout); } /** * \ingroup simix_comm_management */ -int simcall_comm_testany(xbt_dynar_t comms) +int simcall_comm_testany(smx_synchro_t* comms, size_t count) { - if (xbt_dynar_is_empty(comms)) + if (count == 0) return -1; - return simcall_BODY_comm_testany(comms); + return simcall_BODY_comm_testany(comms, count); } /** @@ -1120,4 +1119,4 @@ void unblock(smx_process_t process) } } -} \ No newline at end of file +}