-/* Copyright (c) 2009-2021. The SimGrid Team. All rights reserved. */
+/* Copyright (c) 2009-2023. 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/smpi/include/smpi_actor.hpp"
-#include "mc/mc.h"
#include "simgrid/s4u/Engine.hpp"
#include "simgrid/s4u/Mutex.hpp"
#include "smpi_comm.hpp"
#include "smpi_info.hpp"
+#include "src/mc/mc.h"
#include "src/mc/mc_replay.hpp"
-#include "src/simix/smx_private.hpp"
+#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)");
-namespace simgrid {
-namespace smpi {
+namespace simgrid::smpi {
simgrid::xbt::Extension<simgrid::s4u::Actor, ActorExt> ActorExt::EXTENSION_ID;
ActorExt::ActorExt(s4u::Actor* actor) : actor_(actor)
timer_ = xbt_os_timer_new();
state_ = SmpiProcessState::UNINITIALIZED;
info_env_ = MPI_INFO_NULL;
- if (MC_is_active())
- MC_ignore_heap(timer_, xbt_os_timer_size());
+ MC_ignore_heap(timer_, xbt_os_timer_size());
#if HAVE_PAPI
if (not smpi_cfg_papi_events_file().empty()) {
state_ = SmpiProcessState::INITIALIZED;
}
+/** @brief Mark a process as finalizing (=MPI_Finalize called) */
+void ActorExt::mark_as_finalizing()
+{
+ if (state_ != SmpiProcessState::FINALIZED)
+ state_ = SmpiProcessState::FINALIZING;
+}
+
+/** @brief Check if a process is finalizing */
+int ActorExt::finalizing() const
+{
+ return (state_ == SmpiProcessState::FINALIZING);
+}
+
void ActorExt::set_replaying(bool value)
{
if (state_ != SmpiProcessState::FINALIZED)
return;
const simgrid::s4u::Actor* self = simgrid::s4u::Actor::self();
- ext->instance_id_ = self->get_property("instance_id");
- const int rank = xbt_str_parse_int(self->get_property("rank"), "Cannot parse rank");
+ 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;
smpi_deployment_register_process(ext->instance_id_, rank, self);
return MPI_SUCCESS;
}
-} // namespace smpi
-} // namespace simgrid
+} // namespace simgrid::smpi