- for (auto it = this->comm_queue_.begin(); it != this->comm_queue_.end(); it++)
- if (*it == comm) {
- this->comm_queue_.erase(it);
- return;
- }
- xbt_die("Comm %p not found in mailbox %s", comm.get(), this->get_cname());
+ auto it = std::find(this->comm_queue_.begin(), this->comm_queue_.end(), comm);
+ if (it != this->comm_queue_.end())
+ this->comm_queue_.erase(it);
+ else
+ xbt_die("Comm %p not found in mailbox %s", comm.get(), this->get_cname());
+}
+
+/** @brief Removes all communication activities from a mailbox
+ */
+void MailboxImpl::clear(bool do_finish)
+{
+ // CommImpl::cancel() will remove the comm from the mailbox..
+ for (const auto& comm : done_comm_queue_) {
+ comm->cancel();
+ comm->set_state(State::FAILED);
+ if (do_finish)
+ comm->finish();
+ }
+ done_comm_queue_.clear();
+
+ while (not comm_queue_.empty()) {
+ auto comm = comm_queue_.back();
+ if (comm->get_state() == State::WAITING && not comm->is_detached()) {
+ comm->cancel();
+ comm->set_state(State::FAILED);
+ if (do_finish)
+ comm->finish();
+ } else
+ comm_queue_.pop_back();
+ }
+ xbt_assert(comm_queue_.empty() && done_comm_queue_.empty());