X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/9bc2502cd48aa890ae9143aaac342eca2f99a9b7..aad6b6c4c7b1454dd284f822ba6f52e790f42c6e:/src/kernel/activity/MailboxImpl.cpp diff --git a/src/kernel/activity/MailboxImpl.cpp b/src/kernel/activity/MailboxImpl.cpp index 92effb9a87..7bbb8152ce 100644 --- a/src/kernel/activity/MailboxImpl.cpp +++ b/src/kernel/activity/MailboxImpl.cpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2007-2022. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2007-2023. The SimGrid Team. All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it * under the terms of the license (GNU LGPL) which comes with this package. */ @@ -14,15 +14,17 @@ XBT_LOG_NEW_DEFAULT_SUBCATEGORY(ker_mailbox, kernel, "Mailbox implementation"); /* Rendez-Vous Points */ /******************************************************************************/ -namespace simgrid { -namespace kernel { -namespace activity { +namespace simgrid::kernel::activity { unsigned MailboxImpl::next_id_ = 0; MailboxImpl::~MailboxImpl() { - clear(); + try { + clear(false); + } catch (const std::bad_alloc& ba) { + XBT_ERROR("MailboxImpl::clear() failure: %s", ba.what()); + } set_receiver(nullptr); } @@ -32,7 +34,7 @@ MailboxImpl::~MailboxImpl() void MailboxImpl::set_receiver(s4u::ActorPtr actor) { if (this->permanent_receiver_) { - std::vector& mboxes = this->permanent_receiver_->mailboxes; + std::vector& mboxes = this->permanent_receiver_->mailboxes_; mboxes.erase(std::remove(mboxes.begin(), mboxes.end(), this), mboxes.end()); } @@ -69,46 +71,51 @@ void MailboxImpl::remove(const CommImplPtr& comm) /** @brief Removes all communication activities from a mailbox */ -void MailboxImpl::clear() +void MailboxImpl::clear( bool do_post ) { + // CommImpl::cancel() will remove the comm from the mailbox.. for (auto comm : done_comm_queue_) { comm->cancel(); - comm->set_state(State::DST_HOST_FAILURE); + comm->set_state(State::FAILED); + if(do_post) + comm->post(); } done_comm_queue_.clear(); - // CommImpl::cancel() will remove the comm from the mailbox.. while (not comm_queue_.empty()) { auto comm = comm_queue_.back(); - if (comm->get_state() == State::WAITING && not comm->detached()) { + if (comm->get_state() == State::WAITING && not comm->is_detached()) { comm->cancel(); - comm->set_state(State::DST_HOST_FAILURE); + comm->set_state(State::FAILED); + if(do_post) + comm->post(); } else comm_queue_.pop_back(); } + xbt_assert(comm_queue_.empty() && done_comm_queue_.empty()); } -CommImplPtr MailboxImpl::iprobe(int type, bool (*match_fun)(void*, void*, CommImpl*), void* data) +CommImplPtr MailboxImpl::iprobe(int type, const std::function& match_fun, void* data) { XBT_DEBUG("iprobe from %p %p", this, &comm_queue_); - CommImplPtr this_comm; - CommImpl::Type smx_type; + CommImplPtr this_comm(new CommImpl); + CommImplType other_type; if (type == 1) { - this_comm = CommImplPtr(new CommImpl(CommImpl::Type::SEND)); - smx_type = CommImpl::Type::RECEIVE; + this_comm->set_type(CommImplType::SEND); + other_type = CommImplType::RECEIVE; } else { - this_comm = CommImplPtr(new CommImpl(CommImpl::Type::RECEIVE)); - smx_type = CommImpl::Type::SEND; + this_comm->set_type(CommImplType::RECEIVE); + other_type = CommImplType::SEND; } CommImplPtr other_comm = nullptr; if (permanent_receiver_ != nullptr && not done_comm_queue_.empty()) { XBT_DEBUG("first check in the permanent recv mailbox, to see if we already got something"); - other_comm = find_matching_comm(smx_type, match_fun, data, this_comm, /*done*/ true, /*remove_matching*/ false); + other_comm = find_matching_comm(other_type, match_fun, data, this_comm, /*done*/ true, /*remove_matching*/ false); } if (not other_comm) { XBT_DEBUG("check if we have more luck in the normal mailbox"); - other_comm = find_matching_comm(smx_type, match_fun, data, this_comm, /*done*/ false, /*remove_matching*/ false); + other_comm = find_matching_comm(other_type, match_fun, data, this_comm, /*done*/ false, /*remove_matching*/ false); } return other_comm; @@ -123,7 +130,8 @@ CommImplPtr MailboxImpl::iprobe(int type, bool (*match_fun)(void*, void*, CommIm * @param remove_matching whether or not to clean the found object from the queue * @return The communication activity if found, nullptr otherwise */ -CommImplPtr MailboxImpl::find_matching_comm(CommImpl::Type type, bool (*match_fun)(void*, void*, CommImpl*), +CommImplPtr MailboxImpl::find_matching_comm(CommImplType type, + const std::function& match_fun, void* this_user_data, const CommImplPtr& my_synchro, bool done, bool remove_matching) { @@ -131,8 +139,8 @@ CommImplPtr MailboxImpl::find_matching_comm(CommImpl::Type type, bool (*match_fu auto iter = std::find_if( comm_queue.begin(), comm_queue.end(), [&type, &match_fun, &this_user_data, &my_synchro](const CommImplPtr& comm) { - void* other_user_data = (comm->type_ == CommImpl::Type::SEND ? comm->src_data_ : comm->dst_data_); - return (comm->type_ == type && (not match_fun || match_fun(this_user_data, other_user_data, comm.get())) && + void* other_user_data = (comm->get_type() == CommImplType::SEND ? comm->src_data_ : comm->dst_data_); + return (comm->get_type() == type && (not match_fun || match_fun(this_user_data, other_user_data, comm.get())) && (not comm->match_fun || comm->match_fun(other_user_data, this_user_data, my_synchro.get()))); }); if (iter == comm_queue.end()) { @@ -142,15 +150,10 @@ CommImplPtr MailboxImpl::find_matching_comm(CommImpl::Type type, bool (*match_fu const CommImplPtr& comm = *iter; XBT_DEBUG("Found a matching communication synchro %p", comm.get()); -#if SIMGRID_HAVE_MC - comm->mbox_cpy = comm->get_mailbox(); -#endif comm->set_mailbox(nullptr); CommImplPtr comm_cpy = comm; if (remove_matching) comm_queue.erase(iter); return comm_cpy; } -} // namespace activity -} // namespace kernel -} // namespace simgrid +} // namespace simgrid::kernel::activity