Fix process_killall. Closes #186.

[simgrid.git] / src / s4u / s4u_mailbox.cpp

diff --git a/src/s4u/s4u_mailbox.cpp b/src/s4u/s4u_mailbox.cpp
index 9642de0..245bd53 100644 (file)
--- 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,83 +53,88 @@ 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();
 }
 
-CommPtr Mailbox::send_init()
+CommPtr Mailbox::put_init()
 {
   CommPtr res   = CommPtr(new s4u::Comm());
   res->sender_  = SIMIX_process_self();
   res->mailbox_ = this;
   return res;
 }
-s4u::CommPtr Mailbox::send_init(void* data, int simulatedSize)
+s4u::CommPtr Mailbox::put_init(void* data, uint64_t simulatedSize)
 {
-  s4u::CommPtr res = send_init();
+  s4u::CommPtr res = put_init();
   res->setRemains(simulatedSize);
   res->srcBuff_     = data;
   res->srcBuffSize_ = sizeof(void*);
   return res;
 }
-s4u::CommPtr Mailbox::send_async(void* data, int simulatedSize)
+s4u::CommPtr Mailbox::put_async(void* payload, uint64_t simulatedSize)
 {
-  s4u::CommPtr res = send_init(data, simulatedSize);
+  xbt_assert(payload != nullptr, "You cannot send nullptr");
+
+  s4u::CommPtr res = put_init(payload, simulatedSize);
   res->start();
   return res;
 }
-void Mailbox::send(void* payload, double simulatedSize)
+void Mailbox::put(void* payload, uint64_t simulatedSize)
 {
-  CommPtr c = send_init();
+  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::send(void* payload, double simulatedSize, double timeout)
+void Mailbox::put(void* payload, uint64_t simulatedSize, double timeout)
 {
-  CommPtr c = send_init();
+  xbt_assert(payload != nullptr, "You cannot send nullptr");
+
+  CommPtr c = put_init();
   c->setRemains(simulatedSize);
   c->setSrcData(payload);
   // c->start() is optional.
   c->wait(timeout);
 }
 
-s4u::CommPtr Mailbox::recv_init()
+s4u::CommPtr Mailbox::get_init()
 {
   CommPtr res    = CommPtr(new s4u::Comm());
   res->receiver_ = SIMIX_process_self();
   res->mailbox_  = this;
   return res;
 }
-s4u::CommPtr Mailbox::recv_async(void** data)
+s4u::CommPtr Mailbox::get_async(void** data)
 {
-  s4u::CommPtr res = recv_init();
+  s4u::CommPtr res = get_init();
   res->setDstData(data, sizeof(*data));
   res->start();
   return res;
 }
 
-void* Mailbox::recv()
+void* Mailbox::get()
 {
   void* res = nullptr;
-  CommPtr c = recv_init();
+  CommPtr c = get_init();
   c->setDstData(&res, sizeof(res));
   c->wait();
   return res;
 }
-void* Mailbox::recv(double timeout)
+void* Mailbox::get(double timeout)
 {
   void* res = nullptr;
-  CommPtr c = recv_init();
+  CommPtr c = get_init();
   c->setDstData(&res, sizeof(res));
   c->wait(timeout);
   return res;