X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/0b86d2dae6ca1d3b4beed12f4dfc08611f7f1c4b..de190af4974a9ed57a52e649e5cbe0ac83512acb:/src/smpi/internals/smpi_process.cpp diff --git a/src/smpi/internals/smpi_process.cpp b/src/smpi/internals/smpi_process.cpp index 31fd2b93ba..91fe28a5a8 100644 --- a/src/smpi/internals/smpi_process.cpp +++ b/src/smpi/internals/smpi_process.cpp @@ -5,10 +5,7 @@ #include "smpi_process.hpp" #include "mc/mc.h" -#include "private.hpp" -#include "simgrid/s4u/forward.hpp" #include "smpi_comm.hpp" -#include "smpi_group.hpp" #include "src/mc/mc_replay.hpp" #include "src/msg/msg_private.hpp" #include "src/simix/smx_private.hpp" @@ -24,8 +21,8 @@ using simgrid::s4u::ActorPtr; Process::Process(ActorPtr actor, msg_bar_t finalization_barrier) : finalization_barrier_(finalization_barrier), process_(actor) { - mailbox_ = simgrid::s4u::Mailbox::byName("SMPI-" + std::to_string(process_->getPid())); - mailbox_small_ = simgrid::s4u::Mailbox::byName("small-" + std::to_string(process_->getPid())); + mailbox_ = simgrid::s4u::Mailbox::byName("SMPI-" + std::to_string(process_->get_pid())); + mailbox_small_ = simgrid::s4u::Mailbox::byName("small-" + std::to_string(process_->get_pid())); mailboxes_mutex_ = xbt_mutex_init(); timer_ = xbt_os_timer_new(); state_ = SMPI_UNINITIALIZED; @@ -69,7 +66,7 @@ void Process::set_data(int* argc, char*** argv) finalization_barrier_ = barrier; process_ = simgrid::s4u::Actor::self(); - static_cast(process_->getImpl()->userdata)->data = this; + static_cast(process_->get_impl()->userdata)->data = this; if (*argc > 3) { memmove(&(*argv)[0], &(*argv)[2], sizeof(char*) * (*argc - 2)); @@ -81,14 +78,14 @@ void Process::set_data(int* argc, char*** argv) argv_ = argv; // set the process attached to the mailbox mailbox_small_->setReceiver(process_); - XBT_DEBUG("<%ld> SMPI process has been initialized: %p", process_->getPid(), process_.get()); + XBT_DEBUG("<%ld> SMPI process has been initialized: %p", process_->get_pid(), process_.get()); } /** @brief Prepares the current process for termination. */ void Process::finalize() { state_ = SMPI_FINALIZED; - XBT_DEBUG("<%ld> Process left the game", process_->getPid()); + XBT_DEBUG("<%ld> Process left the game", process_->get_pid()); // This leads to an explosion of the search graph which cannot be reduced: if(MC_is_active() || MC_record_replay_is_active()) @@ -168,12 +165,12 @@ MPI_Comm Process::comm_world() smx_mailbox_t Process::mailbox() { - return mailbox_->getImpl(); + return mailbox_->get_impl(); } smx_mailbox_t Process::mailbox_small() { - return mailbox_small_->getImpl(); + return mailbox_small_->get_impl(); } xbt_mutex_t Process::mailboxes_mutex() @@ -249,7 +246,7 @@ void Process::init(int *argc, char ***argv){ } if (argc != nullptr && argv != nullptr) { simgrid::s4u::ActorPtr proc = simgrid::s4u::Actor::self(); - proc->getImpl()->context->set_cleanup(&MSG_process_cleanup_from_SIMIX); + proc->get_impl()->context->set_cleanup(&MSG_process_cleanup_from_SIMIX); char* instance_id = (*argv)[1]; try {