X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/ecd5f7562caf1d443bf22788fa5f4fac408776ec..5ac17b95ed6baf225a7d90d65536e0ce1843ec93:/src/kernel/activity/MailboxImpl.cpp diff --git a/src/kernel/activity/MailboxImpl.cpp b/src/kernel/activity/MailboxImpl.cpp index bed10c21be..ebf615ef52 100644 --- a/src/kernel/activity/MailboxImpl.cpp +++ b/src/kernel/activity/MailboxImpl.cpp @@ -1,10 +1,9 @@ -/* Copyright (c) 2007-2017. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2007-2018. 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. */ #include "src/kernel/activity/MailboxImpl.hpp" - #include "src/kernel/activity/CommImpl.hpp" XBT_LOG_NEW_DEFAULT_SUBCATEGORY(simix_mailbox, simix, "Mailbox implementation"); @@ -26,7 +25,7 @@ namespace simgrid { namespace kernel { namespace activity { /** @brief Returns the mailbox of that name, or nullptr */ -MailboxImpl* MailboxImpl::byNameOrNull(const char* name) +MailboxImpl* MailboxImpl::byNameOrNull(std::string name) { auto mbox = mailboxes->find(name); if (mbox != mailboxes->end()) @@ -35,14 +34,13 @@ MailboxImpl* MailboxImpl::byNameOrNull(const char* name) return nullptr; } /** @brief Returns the mailbox of that name, newly created on need */ -MailboxImpl* MailboxImpl::byNameOrCreate(const char* name) +MailboxImpl* MailboxImpl::byNameOrCreate(std::string name) { - xbt_assert(name, "Mailboxes must have a name"); /* two processes may have pushed the same mbox_create simcall at the same time */ auto m = mailboxes->find(name); if (m == mailboxes->end()) { smx_mailbox_t mbox = new MailboxImpl(name); - XBT_DEBUG("Creating a mailbox at %p with name %s", mbox, name); + XBT_DEBUG("Creating a mailbox at %p with name %s", mbox, name.c_str()); (*mailboxes)[mbox->name_] = mbox; return mbox; } else @@ -53,7 +51,10 @@ MailboxImpl* MailboxImpl::byNameOrCreate(const char* name) */ void MailboxImpl::setReceiver(s4u::ActorPtr actor) { - this->permanent_receiver = actor.get()->getImpl(); + if (actor != nullptr) + this->permanent_receiver = actor.get()->get_impl(); + else + this->permanent_receiver = nullptr; } /** @brief Pushes a communication activity into a mailbox * @param comm What to add @@ -73,14 +74,14 @@ void MailboxImpl::remove(smx_activity_t activity) boost::static_pointer_cast(activity); xbt_assert(comm->mbox == this, "Comm %p is in mailbox %s, not mailbox %s", comm.get(), - (comm->mbox ? comm->mbox->getCname() : "(null)"), this->getCname()); + (comm->mbox ? comm->mbox->get_cname() : "(null)"), this->get_cname()); comm->mbox = nullptr; 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->getCname()); + xbt_die("Comm %p not found in mailbox %s", comm.get(), this->get_cname()); } } }