X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/dceed88b84f4c8dccf94f8031cc9ba635eaf75da..4c372fe556f773fbce3514655087de660dbe6b1a:/src/s4u/s4u_mailbox.cpp diff --git a/src/s4u/s4u_mailbox.cpp b/src/s4u/s4u_mailbox.cpp index f514ce5356..245bd5334b 100644 --- a/src/s4u/s4u_mailbox.cpp +++ b/src/s4u/s4u_mailbox.cpp @@ -16,7 +16,8 @@ XBT_LOG_NEW_DEFAULT_SUBCATEGORY(s4u_channel,s4u,"S4U Communication Mailboxes"); namespace simgrid { namespace s4u { -const char *Mailbox::name() { +const char* Mailbox::getName() +{ return pimpl_->name_; } @@ -52,13 +53,12 @@ smx_activity_t Mailbox::front() } void Mailbox::setReceiver(ActorPtr actor) { - simix::kernelImmediate([this, actor]() { - this->pimpl_->setReceiver(actor); - }); + simix::kernelImmediate([this, actor]() { this->pimpl_->setReceiver(actor); }); } /** @brief get the receiver (process associated to the mailbox) */ -ActorPtr Mailbox::receiver() { +ActorPtr Mailbox::getReceiver() +{ if (pimpl_->permanent_receiver == nullptr) return ActorPtr(); return pimpl_->permanent_receiver->iface(); @@ -71,7 +71,7 @@ CommPtr Mailbox::put_init() res->mailbox_ = this; return res; } -s4u::CommPtr Mailbox::put_init(void* data, int simulatedSize) +s4u::CommPtr Mailbox::put_init(void* data, uint64_t simulatedSize) { s4u::CommPtr res = put_init(); res->setRemains(simulatedSize); @@ -79,22 +79,28 @@ s4u::CommPtr Mailbox::put_init(void* data, int simulatedSize) res->srcBuffSize_ = sizeof(void*); return res; } -s4u::CommPtr Mailbox::put_async(void* data, int simulatedSize) +s4u::CommPtr Mailbox::put_async(void* payload, uint64_t simulatedSize) { - s4u::CommPtr res = put_init(data, simulatedSize); + xbt_assert(payload != nullptr, "You cannot send nullptr"); + + s4u::CommPtr res = put_init(payload, simulatedSize); res->start(); return res; } -void Mailbox::put(void* payload, double simulatedSize) +void Mailbox::put(void* payload, uint64_t simulatedSize) { + xbt_assert(payload != nullptr, "You cannot send nullptr"); + CommPtr c = put_init(); c->setRemains(simulatedSize); c->setSrcData(payload); c->wait(); } /** Blocking send with timeout */ -void Mailbox::put(void* payload, double simulatedSize, double timeout) +void Mailbox::put(void* payload, uint64_t simulatedSize, double timeout) { + xbt_assert(payload != nullptr, "You cannot send nullptr"); + CommPtr c = put_init(); c->setRemains(simulatedSize); c->setSrcData(payload);