X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/dac5d8074d0d4971410ad158c52f1bc6f1dda9a4..0ce363d7431c7d5bfdadf74b8599c4ec348c82cd:/src/s4u/s4u_mailbox.cpp diff --git a/src/s4u/s4u_mailbox.cpp b/src/s4u/s4u_mailbox.cpp index c87c3808ed..3f289d8425 100644 --- a/src/s4u/s4u_mailbox.cpp +++ b/src/s4u/s4u_mailbox.cpp @@ -21,7 +21,8 @@ const char *Mailbox::getName() { return pimpl_->name; } -MailboxPtr Mailbox::byName(const char*name) { +MailboxPtr Mailbox::byName(const char*name) +{ // FIXME: there is a race condition here where two actors run Mailbox::byName // on a non-existent mailbox during the same scheduling round. Both will be // interrupted in the simcall creating the underlying simix mbox. @@ -34,8 +35,14 @@ MailboxPtr Mailbox::byName(const char*name) { return MailboxPtr(&mbox->piface_, true); } -bool Mailbox::empty() { - return nullptr == simcall_mbox_front(pimpl_); +bool Mailbox::empty() +{ + return pimpl_->comm_queue.empty(); +} + +smx_synchro_t Mailbox::front() +{ + return pimpl_->comm_queue.empty() ? nullptr : pimpl_->comm_queue.front(); } void Mailbox::setReceiver(Actor* actor) {