X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/913c6a415bb94569081a13769ed15d521d3a0e4e..6d4f53d13aa99005985fbb4d7da6e674b5cc80ae:/src/smpi/internals/instr_smpi.cpp?ds=sidebyside diff --git a/src/smpi/internals/instr_smpi.cpp b/src/smpi/internals/instr_smpi.cpp index 5985693348..2d5e97584e 100644 --- a/src/smpi/internals/instr_smpi.cpp +++ b/src/smpi/internals/instr_smpi.cpp @@ -56,9 +56,9 @@ static const char* instr_find_color(const char* state) return ret; } -XBT_PRIVATE std::string smpi_container(int rank) +XBT_PRIVATE container_t smpi_container(int rank) { - return std::string("rank-") + std::to_string(rank); + return simgrid::instr::Container::byName(std::string("rank-") + std::to_string(rank)); } static std::string TRACE_smpi_put_key(int src, int dst, int tag, int send) @@ -108,9 +108,9 @@ static std::unordered_map process_category; static void cleanup_extra_data (instr_extra_data extra){ if(extra!=nullptr){ if(extra->sendcounts!=nullptr) - xbt_free(extra->sendcounts); + delete[] extra->sendcounts; if(extra->recvcounts!=nullptr) - xbt_free(extra->recvcounts); + delete[] extra->recvcounts; xbt_free(extra); } } @@ -152,13 +152,13 @@ void TRACE_smpi_init(int rank) if (not TRACE_smpi_is_enabled()) return; - std::string str = smpi_container(rank); + std::string str = std::string("rank-") + std::to_string(rank); container_t father; if (TRACE_smpi_is_grouped()){ father = simgrid::instr::Container::byNameOrNull(sg_host_self_get_name()); }else{ - father = simgrid::instr::Container::getRootContainer(); + father = simgrid::instr::Container::getRoot(); } xbt_assert(father != nullptr, "Could not find a parent for mpi rank %s at function %s", str.c_str(), __FUNCTION__); #if HAVE_PAPI @@ -185,47 +185,18 @@ void TRACE_smpi_finalize(int rank) if (not TRACE_smpi_is_enabled()) return; - container_t container = simgrid::instr::Container::byName(smpi_container(rank)); + container_t container = smpi_container(rank); container->removeFromParent(); delete container; } -void TRACE_smpi_collective_in(int rank, const char *operation, instr_extra_data extra) -{ - if (not TRACE_smpi_is_enabled()) { - cleanup_extra_data(extra); - return; - } - - container_t container = simgrid::instr::Container::byName(smpi_container(rank)); - simgrid::instr::StateType* state = static_cast(container->type_->byName("MPI_STATE")); - const char *color = instr_find_color (operation); - state->addEntityValue(operation, color); - new simgrid::instr::PushStateEvent(SIMIX_get_clock(), container, state, state->getEntityValue(operation), - static_cast(extra)); -} - -void TRACE_smpi_collective_out(int rank, const char *operation) -{ - if (not TRACE_smpi_is_enabled()) - return; - - container_t container = simgrid::instr::Container::byName(smpi_container(rank)); - simgrid::instr::Type* type = container->type_->byName("MPI_STATE"); - - new simgrid::instr::PopStateEvent(SIMIX_get_clock(), container, type); -} - void TRACE_smpi_computing_init(int rank) { //first use, initialize the color in the trace if (not TRACE_smpi_is_enabled() || not TRACE_smpi_is_computing()) return; - container_t container = simgrid::instr::Container::byName(smpi_container(rank)); - simgrid::instr::StateType* state = static_cast(container->type_->byName("MPI_STATE")); - state->addEntityValue("computing", instr_find_color("computing")); - new simgrid::instr::PushStateEvent(SIMIX_get_clock(), container, state, state->getEntityValue("computing")); + smpi_container(rank)->getState("MPI_STATE")->addEntityValue("computing", instr_find_color("computing")); } void TRACE_smpi_computing_in(int rank, instr_extra_data extra) @@ -236,11 +207,7 @@ void TRACE_smpi_computing_in(int rank, instr_extra_data extra) return; } - container_t container = simgrid::instr::Container::byName(smpi_container(rank)); - simgrid::instr::StateType* state = static_cast(container->type_->byName("MPI_STATE")); - state->addEntityValue("computing"); - new simgrid::instr::PushStateEvent(SIMIX_get_clock(), container, state, state->getEntityValue("computing"), - static_cast(extra)); + smpi_container(rank)->getState("MPI_STATE")->pushEvent("computing", static_cast(extra)); } void TRACE_smpi_computing_out(int rank) @@ -248,9 +215,7 @@ void TRACE_smpi_computing_out(int rank) if (not TRACE_smpi_is_enabled() || not TRACE_smpi_is_computing()) return; - container_t container = simgrid::instr::Container::byName(smpi_container(rank)); - simgrid::instr::Type* type = container->type_->byName("MPI_STATE"); - new simgrid::instr::PopStateEvent(SIMIX_get_clock(), container, type); + smpi_container(rank)->getState("MPI_STATE")->popEvent(); } void TRACE_smpi_sleeping_init(int rank) @@ -259,10 +224,7 @@ void TRACE_smpi_sleeping_init(int rank) if (not TRACE_smpi_is_enabled() || not TRACE_smpi_is_sleeping()) return; - container_t container = simgrid::instr::Container::byName(smpi_container(rank)); - simgrid::instr::StateType* state = static_cast(container->type_->byName("MPI_STATE")); - state->addEntityValue("sleeping", instr_find_color("sleeping")); - new simgrid::instr::PushStateEvent(SIMIX_get_clock(), container, state, state->getEntityValue("sleeping")); + smpi_container(rank)->getState("MPI_STATE")->addEntityValue("sleeping", instr_find_color("sleeping")); } void TRACE_smpi_sleeping_in(int rank, instr_extra_data extra) @@ -273,11 +235,7 @@ void TRACE_smpi_sleeping_in(int rank, instr_extra_data extra) return; } - container_t container = simgrid::instr::Container::byName(smpi_container(rank)); - simgrid::instr::StateType* state = static_cast(container->type_->byName("MPI_STATE")); - state->addEntityValue("sleeping"); - new simgrid::instr::PushStateEvent(SIMIX_get_clock(), container, state, state->getEntityValue("sleeping"), - static_cast(extra)); + smpi_container(rank)->getState("MPI_STATE")->pushEvent("sleeping", static_cast(extra)); } void TRACE_smpi_sleeping_out(int rank) @@ -285,9 +243,7 @@ void TRACE_smpi_sleeping_out(int rank) if (not TRACE_smpi_is_enabled() || not TRACE_smpi_is_sleeping()) return; - container_t container = simgrid::instr::Container::byName(smpi_container(rank)); - simgrid::instr::Type* type = container->type_->byName("MPI_STATE"); - new simgrid::instr::PopStateEvent(SIMIX_get_clock(), container, type); + smpi_container(rank)->getState("MPI_STATE")->popEvent(); } void TRACE_smpi_testing_in(int rank, instr_extra_data extra) @@ -298,46 +254,33 @@ void TRACE_smpi_testing_in(int rank, instr_extra_data extra) return; } - container_t container = simgrid::instr::Container::byName(smpi_container(rank)); - simgrid::instr::StateType* state = static_cast(container->type_->byName("MPI_STATE")); + simgrid::instr::StateType* state = smpi_container(rank)->getState("MPI_STATE"); state->addEntityValue("test"); - new simgrid::instr::PushStateEvent(SIMIX_get_clock(), container, state, state->getEntityValue("test"), - static_cast(extra)); + state->pushEvent("test", static_cast(extra)); } void TRACE_smpi_testing_out(int rank) { - if (not TRACE_smpi_is_enabled()) - return; - - container_t container = simgrid::instr::Container::byName(smpi_container(rank)); - simgrid::instr::Type* type = container->type_->byName("MPI_STATE"); - new simgrid::instr::PopStateEvent(SIMIX_get_clock(), container, type); + if (TRACE_smpi_is_enabled()) + smpi_container(rank)->getState("MPI_STATE")->popEvent(); } -void TRACE_smpi_ptp_in(int rank, const char *operation, instr_extra_data extra) +void TRACE_smpi_comm_in(int rank, const char* operation, instr_extra_data extra) { if (not TRACE_smpi_is_enabled()) { cleanup_extra_data(extra); return; } - container_t container = simgrid::instr::Container::byName(smpi_container(rank)); - simgrid::instr::StateType* state = static_cast(container->type_->byName("MPI_STATE")); + simgrid::instr::StateType* state = smpi_container(rank)->getState("MPI_STATE"); state->addEntityValue(operation, instr_find_color(operation)); - new simgrid::instr::PushStateEvent(SIMIX_get_clock(), container, state, state->getEntityValue(operation), - static_cast(extra)); + state->pushEvent(operation, static_cast(extra)); } -void TRACE_smpi_ptp_out(int rank, int dst, const char *operation) +void TRACE_smpi_comm_out(int rank) { - if (not TRACE_smpi_is_enabled()) - return; - - container_t container = simgrid::instr::Container::byName(smpi_container(rank)); - simgrid::instr::Type* type = container->type_->byName("MPI_STATE"); - - new simgrid::instr::PopStateEvent(SIMIX_get_clock(), container, type); + if (TRACE_smpi_is_enabled()) + smpi_container(rank)->getState("MPI_STATE")->popEvent(); } void TRACE_smpi_send(int rank, int src, int dst, int tag, int size) @@ -347,11 +290,8 @@ void TRACE_smpi_send(int rank, int src, int dst, int tag, int size) std::string key = TRACE_smpi_get_key(src, dst, tag, 1); - container_t container = simgrid::instr::Container::byName(smpi_container(rank)); - simgrid::instr::Type* type = simgrid::instr::Type::getRootType()->byName("MPI_LINK"); XBT_DEBUG("Send tracing from %d to %d, tag %d, with key %s", src, dst, tag, key.c_str()); - new simgrid::instr::StartLinkEvent(SIMIX_get_clock(), simgrid::instr::Container::getRootContainer(), type, container, - "PTP", key, size); + simgrid::instr::Container::getRoot()->getLink("MPI_LINK")->startEvent(smpi_container(rank), "PTP", key, size); } void TRACE_smpi_recv(int src, int dst, int tag) @@ -361,9 +301,6 @@ void TRACE_smpi_recv(int src, int dst, int tag) std::string key = TRACE_smpi_get_key(src, dst, tag, 0); - container_t container = simgrid::instr::Container::byName(smpi_container(dst)); - simgrid::instr::Type* type = simgrid::instr::Type::getRootType()->byName("MPI_LINK"); XBT_DEBUG("Recv tracing from %d to %d, tag %d, with key %s", src, dst, tag, key.c_str()); - new simgrid::instr::EndLinkEvent(SIMIX_get_clock(), simgrid::instr::Container::getRootContainer(), type, container, - "PTP", key); + simgrid::instr::Container::getRoot()->getLink("MPI_LINK")->endEvent(smpi_container(dst), "PTP", key); }