* under the terms of the license (GNU LGPL) which comes with this package. */
#include "simgrid/s4u/Comm.hpp"
+#include "simgrid/s4u/Engine.hpp"
#include "simgrid/s4u/Mailbox.hpp"
#include "src/kernel/activity/MailboxImpl.hpp"
Mailbox* Mailbox::by_name(const std::string& name)
{
- kernel::activity::MailboxImpl* mbox = kernel::activity::MailboxImpl::by_name_or_null(name);
- if (mbox == nullptr) {
- mbox = kernel::actor::simcall([&name] { return kernel::activity::MailboxImpl::by_name_or_create(name); });
- }
- return &mbox->piface_;
+ return Engine::get_instance()->mailbox_by_name_or_create(name);
}
bool Mailbox::empty() const
return pimpl_->comm_queue_.empty();
}
+unsigned int Mailbox::size() const
+{
+ return pimpl_->comm_queue_.size();
+}
+
bool Mailbox::listen() const
{
return not this->empty() || (pimpl_->permanent_receiver_ && not pimpl_->done_comm_queue_.empty());
return res;
}
-CommPtr Mailbox::put_init(void* data, uint64_t simulated_size_in_bytes)
+CommPtr Mailbox::put_init(void* payload, uint64_t simulated_size_in_bytes)
{
- CommPtr res = put_init();
- res->set_remaining(simulated_size_in_bytes);
- res->src_buff_ = data;
- res->src_buff_size_ = sizeof(void*);
- return res;
+ return put_init()->set_payload_size(simulated_size_in_bytes)->set_src_data(payload)->set_src_data_size(sizeof(void*));
}
CommPtr Mailbox::put_async(void* payload, uint64_t simulated_size_in_bytes)
res->vetoable_start();
return res;
}
+
void Mailbox::put(void* payload, uint64_t simulated_size_in_bytes)
{
xbt_assert(payload != nullptr, "You cannot send nullptr");
- CommPtr c = put_init();
- c->set_remaining(simulated_size_in_bytes);
- c->set_src_data(payload);
- c->vetoable_start();
- c->wait();
+ put_init()->set_payload_size(simulated_size_in_bytes)->set_src_data(payload)->vetoable_start()->wait();
}
+
/** Blocking send with timeout */
void Mailbox::put(void* payload, uint64_t simulated_size_in_bytes, double timeout)
{
xbt_assert(payload != nullptr, "You cannot send nullptr");
- CommPtr c = put_init();
- c->set_remaining(simulated_size_in_bytes);
- c->set_src_data(payload);
- c->vetoable_start();
- c->wait_for(timeout);
+ put_init()->set_payload_size(simulated_size_in_bytes)->set_src_data(payload)->vetoable_start()->wait_for(timeout);
}
CommPtr Mailbox::get_init()