X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/d76599052f7eb659641d0b981c04f99d5f735a14..eb413d34ba90fa4818841ede7fb5ffc89c95939f:/src/kernel/activity/MailboxImpl.hpp diff --git a/src/kernel/activity/MailboxImpl.hpp b/src/kernel/activity/MailboxImpl.hpp index 33fd74bd1d..353b963e73 100644 --- a/src/kernel/activity/MailboxImpl.hpp +++ b/src/kernel/activity/MailboxImpl.hpp @@ -14,9 +14,7 @@ #include "src/kernel/activity/CommImpl.hpp" #include "src/kernel/actor/ActorImpl.hpp" -namespace simgrid { -namespace kernel { -namespace activity { +namespace simgrid::kernel::activity { /** @brief Implementation of the s4u::Mailbox */ @@ -34,16 +32,19 @@ class MailboxImpl { friend s4u::Mailbox; friend s4u::Mailbox* s4u::Engine::mailbox_by_name_or_create(const std::string& name) const; friend s4u::Mailbox* s4u::Mailbox::by_name(const std::string& name); - friend mc::CommunicationDeterminismChecker; static unsigned next_id_; // Next ID to be given const unsigned id_ = next_id_++; explicit MailboxImpl(const std::string& name) : piface_(this), name_(name) {} + MailboxImpl(const MailboxImpl&) = delete; + MailboxImpl& operator=(const MailboxImpl&) = delete; public: /** @brief Public interface */ unsigned get_id() const { return id_; } + ~MailboxImpl(); + const s4u::Mailbox* get_iface() const { return &piface_; } s4u::Mailbox* get_iface() { return &piface_; } @@ -53,9 +54,10 @@ public: void push(CommImplPtr comm); void push_done(CommImplPtr done_comm) { done_comm_queue_.push_back(done_comm); } void remove(const CommImplPtr& comm); - CommImplPtr iprobe(int type, bool (*match_fun)(void*, void*, CommImpl*), void* data); - CommImplPtr find_matching_comm(CommImpl::Type type, bool (*match_fun)(void*, void*, CommImpl*), void* this_user_data, - const CommImplPtr& my_synchro, bool done, bool remove_matching); + void clear(bool do_post ); + CommImplPtr iprobe(int type, const std::function& match_fun, void* data); + CommImplPtr find_matching_comm(CommImplType type, const std::function& match_fun, + void* this_user_data, const CommImplPtr& my_synchro, bool done, bool remove_matching); bool is_permanent() const { return permanent_receiver_ != nullptr; } actor::ActorImplPtr get_permanent_receiver() const { return permanent_receiver_; } bool empty() const { return comm_queue_.empty(); } @@ -64,8 +66,6 @@ public: bool has_some_done_comm() const { return not done_comm_queue_.empty(); } CommImplPtr done_front() const { return done_comm_queue_.front(); } }; -} // namespace activity -} // namespace kernel -} // namespace simgrid +} // namespace simgrid::kernel::activity #endif