X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/b8df87e176f27b25534f27d7e240defa32ca35bc..fbf5fafb60eb44c0c00a7283fd05a6dec5f2b58f:/src/s4u/s4u_Mailbox.cpp diff --git a/src/s4u/s4u_Mailbox.cpp b/src/s4u/s4u_Mailbox.cpp index 5262cdec6a..baa91b81ce 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); @@ -14,7 +15,7 @@ XBT_LOG_NEW_DEFAULT_SUBCATEGORY(s4u_channel, s4u, "S4U Communication Mailboxes") namespace simgrid { namespace s4u { -const simgrid::xbt::string& Mailbox::get_name() const +const xbt::string& Mailbox::get_name() const { return pimpl_->get_name(); } @@ -24,13 +25,13 @@ const char* Mailbox::get_cname() const return pimpl_->get_cname(); } -MailboxPtr Mailbox::by_name(std::string name) +Mailbox* Mailbox::by_name(const std::string& name) { kernel::activity::MailboxImpl* mbox = kernel::activity::MailboxImpl::by_name_or_null(name); if (mbox == nullptr) { - mbox = simix::simcall([name] { return kernel::activity::MailboxImpl::by_name_or_create(name); }); + mbox = simix::simcall([&name] { return kernel::activity::MailboxImpl::by_name_or_create(name); }); } - return MailboxPtr(&mbox->piface_, true); + return &mbox->piface_; } bool Mailbox::empty() @@ -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