X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/96cedde3cdbc0b8ffc3f096a1b65d021b0226f99..4b04faa98dd6b4d52c3383a177e810f8e450fd48:/src/s4u/s4u_Mailbox.cpp diff --git a/src/s4u/s4u_Mailbox.cpp b/src/s4u/s4u_Mailbox.cpp index 5262cdec6a..52a0874540 100644 --- a/src/s4u/s4u_Mailbox.cpp +++ b/src/s4u/s4u_Mailbox.cpp @@ -6,6 +6,7 @@ #include "simgrid/s4u/Comm.hpp" #include "simgrid/s4u/Mailbox.hpp" #include "src/kernel/activity/MailboxImpl.hpp" + #include XBT_LOG_EXTERNAL_CATEGORY(s4u); @@ -24,7 +25,7 @@ const char* Mailbox::get_cname() const return pimpl_->get_cname(); } -MailboxPtr Mailbox::by_name(std::string name) +MailboxPtr Mailbox::by_name(const std::string& name) { kernel::activity::MailboxImpl* mbox = kernel::activity::MailboxImpl::by_name_or_null(name); if (mbox == nullptr) { @@ -55,7 +56,7 @@ bool Mailbox::ready() return comm_ready; } -smx_activity_t Mailbox::front() +kernel::activity::CommImplPtr Mailbox::front() { return pimpl_->comm_queue_.empty() ? nullptr : pimpl_->comm_queue_.front(); } @@ -148,6 +149,11 @@ void* Mailbox::get(double timeout) c->wait_for(timeout); return res; } + +smx_activity_t Mailbox::iprobe(int type, int (*match_fun)(void*, void*, kernel::activity::CommImpl*), void* data) +{ + return simix::simcall([this, type, match_fun, data] { return pimpl_->iprobe(type, match_fun, data); }); +} } // namespace s4u } // namespace simgrid