#include "xbt/str.h"
#if HAVE_PAPI
-#include "papi.h"
+#include <papi.h>
#endif
XBT_LOG_NEW_DEFAULT_SUBCATEGORY(smpi_process, smpi, "Logging specific to SMPI (kernel)");
if (not simgrid::smpi::ActorExt::EXTENSION_ID.valid())
simgrid::smpi::ActorExt::EXTENSION_ID = simgrid::s4u::Actor::extension_create<simgrid::smpi::ActorExt>();
- mailbox_ = s4u::Mailbox::by_name("SMPI-" + std::to_string(actor_->get_pid()));
- mailbox_small_ = s4u::Mailbox::by_name("small-" + std::to_string(actor_->get_pid()));
+ mailbox_ = nullptr;
+ mailbox_small_ = nullptr;
mailboxes_mutex_ = s4u::Mutex::create();
timer_ = xbt_os_timer_new();
state_ = SmpiProcessState::UNINITIALIZED;
info_env_ = MPI_INFO_NULL;
- MC_ignore_heap(timer_, xbt_os_timer_size());
#if HAVE_PAPI
if (not smpi_cfg_papi_events_file().empty()) {
return (state_ == SmpiProcessState::INITIALIZED);
}
+/** @brief Return main mailbox of the process */
+s4u::Mailbox* ActorExt::mailbox()
+{
+ if(mailbox_==nullptr)
+ mailbox_=s4u::Mailbox::by_name("SMPI-" + std::to_string(actor_->get_pid()));
+ return mailbox_;
+}
+
+/** @brief Return mailbox for small messages */
+s4u::Mailbox* ActorExt::mailbox_small()
+{
+ if(mailbox_small_==nullptr)
+ mailbox_small_=s4u::Mailbox::by_name("small-" + std::to_string(actor_->get_pid()));
+ return mailbox_small_;
+}
+
/** @brief Mark a process as initialized (=MPI_Init called) */
void ActorExt::mark_as_initialized()
{
void ActorExt::init()
{
- xbt_assert(smpi_get_universe_size() != 0, "SimGrid was not initialized properly before entering MPI_Init. "
- "Aborting, please check compilation process and use smpirun.");
-
ActorExt* ext = smpi_process();
// if we are in MPI_Init and argc handling has already been done.
if (ext->initialized())
return;
const simgrid::s4u::Actor* self = simgrid::s4u::Actor::self();
- ext->instance_id_ = self->get_property("instance_id");
+ const char* id = self->get_property("instance_id");
+ xbt_assert(id != nullptr, "Actor '%s' seem to be calling MPI_Init(), but it was created outside of MPI, wasn't it?",
+ self->get_cname());
+ ext->instance_id_ = id;
const int rank = static_cast<int>(xbt_str_parse_int(self->get_property("rank"), "Cannot parse rank"));
ext->state_ = SmpiProcessState::INITIALIZING;
ext->comm_world_ = smpi_deployment_comm_world(ext->instance_id_);
// set the process attached to the mailbox
- ext->mailbox_small_->set_receiver(ext->actor_);
+ ext->mailbox_small()->set_receiver(ext->actor_);
XBT_DEBUG("<%ld> SMPI process has been initialized: %p", ext->actor_->get_pid(), ext->actor_);
}