X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/a67401724cacc1bc8f57194f61ab19c0b2ed0df0..a6071d1660902b3e0634c8ee6b7508e7f965c787:/src/smpi/internals/smpi_actor.cpp diff --git a/src/smpi/internals/smpi_actor.cpp b/src/smpi/internals/smpi_actor.cpp index 4e2fa04ffd..7c56710c3b 100644 --- a/src/smpi/internals/smpi_actor.cpp +++ b/src/smpi/internals/smpi_actor.cpp @@ -10,6 +10,7 @@ #include "smpi_comm.hpp" #include "smpi_info.hpp" #include "src/mc/mc_replay.hpp" +#include "xbt/str.h" #if HAVE_PAPI #include "papi.h" @@ -17,8 +18,7 @@ XBT_LOG_NEW_DEFAULT_SUBCATEGORY(smpi_process, smpi, "Logging specific to SMPI (kernel)"); -namespace simgrid { -namespace smpi { +namespace simgrid::smpi { simgrid::xbt::Extension ActorExt::EXTENSION_ID; ActorExt::ActorExt(s4u::Actor* actor) : actor_(actor) @@ -32,8 +32,7 @@ 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()) { @@ -99,6 +98,19 @@ void ActorExt::mark_as_initialized() 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) @@ -259,5 +271,4 @@ int ActorExt::set_bsend_buffer(void* buf, int size) return MPI_SUCCESS; } -} // namespace smpi -} // namespace simgrid +} // namespace simgrid::smpi