From bc93975e89c1b7d29f7247e4700fca9277895e2f Mon Sep 17 00:00:00 2001 From: Christian Heinrich Date: Thu, 21 Jun 2018 15:52:02 +0200 Subject: [PATCH] [SMPI] Code changes for allReduce -> allreduce --- include/simgrid/smpi/replay.hpp | 2 +- src/instr/instr_private.hpp | 2 +- src/smpi/bindings/smpi_pmpi_coll.cpp | 2 +- src/smpi/internals/smpi_replay.cpp | 4 ++-- 4 files changed, 5 insertions(+), 5 deletions(-) diff --git a/include/simgrid/smpi/replay.hpp b/include/simgrid/smpi/replay.hpp index 99a9f1d64e..8b675e8b70 100644 --- a/include/simgrid/smpi/replay.hpp +++ b/include/simgrid/smpi/replay.hpp @@ -277,7 +277,7 @@ public: class AllReduceAction : public ReplayAction { public: - explicit AllReduceAction() : ReplayAction("allReduce") {} + explicit AllReduceAction() : ReplayAction("allreduce") {} void kernel(simgrid::xbt::ReplayAction& action) override; }; diff --git a/src/instr/instr_private.hpp b/src/instr/instr_private.hpp index 46ac112896..502ffb311e 100644 --- a/src/instr/instr_private.hpp +++ b/src/instr/instr_private.hpp @@ -66,7 +66,7 @@ public: // Pt2PtTI: send, isend, sssend, issend, recv, irecv explicit TIData(std::string name, int endpoint, int size, std::string datatype) : name_(name), endpoint(endpoint), send_size(size), send_type(datatype){}; - // CollTI: bcast, reduce, allReduce, gather, scatter, allGather, allToAll + // CollTI: bcast, reduce, allreduce, gather, scatter, allGather, allToAll explicit TIData(std::string name, int root, double amount, int send_size, int recv_size, std::string send_type, std::string recv_type) : name_(name) diff --git a/src/smpi/bindings/smpi_pmpi_coll.cpp b/src/smpi/bindings/smpi_pmpi_coll.cpp index 2593fa3bcc..ce321238a3 100644 --- a/src/smpi/bindings/smpi_pmpi_coll.cpp +++ b/src/smpi/bindings/smpi_pmpi_coll.cpp @@ -384,7 +384,7 @@ int PMPI_Allreduce(void *sendbuf, void *recvbuf, int count, MPI_Datatype datatyp int rank = simgrid::s4u::this_actor::get_pid(); TRACE_smpi_comm_in(rank, __func__, - new simgrid::instr::CollTIData("allReduce", -1, 0, + new simgrid::instr::CollTIData("allreduce", -1, 0, datatype->is_replayable() ? count : count * datatype->size(), -1, simgrid::smpi::Datatype::encode(datatype), "")); diff --git a/src/smpi/internals/smpi_replay.cpp b/src/smpi/internals/smpi_replay.cpp index 8a7032f910..ca1cbe2582 100644 --- a/src/smpi/internals/smpi_replay.cpp +++ b/src/smpi/internals/smpi_replay.cpp @@ -576,7 +576,7 @@ void ReduceAction::kernel(simgrid::xbt::ReplayAction& action) void AllReduceAction::kernel(simgrid::xbt::ReplayAction& action) { - TRACE_smpi_comm_in(my_proc_id, "action_allReduce", new simgrid::instr::CollTIData("allReduce", -1, args.comp_size, args.comm_size, -1, + TRACE_smpi_comm_in(my_proc_id, "action_allreduce", new simgrid::instr::CollTIData("allreduce", -1, args.comp_size, args.comm_size, -1, Datatype::encode(args.datatype1), "")); Colls::allreduce(send_buffer(args.comm_size * args.datatype1->size()), @@ -727,7 +727,7 @@ void smpi_replay_init(int* argc, char*** argv) xbt_replay_action_register("barrier", [](simgrid::xbt::ReplayAction& action) { simgrid::smpi::replay::BarrierAction().execute(action); }); xbt_replay_action_register("bcast", [](simgrid::xbt::ReplayAction& action) { simgrid::smpi::replay::BcastAction().execute(action); }); xbt_replay_action_register("reduce", [](simgrid::xbt::ReplayAction& action) { simgrid::smpi::replay::ReduceAction().execute(action); }); - xbt_replay_action_register("allReduce", [](simgrid::xbt::ReplayAction& action) { simgrid::smpi::replay::AllReduceAction().execute(action); }); + xbt_replay_action_register("allreduce", [](simgrid::xbt::ReplayAction& action) { simgrid::smpi::replay::AllReduceAction().execute(action); }); xbt_replay_action_register("allToAll", [](simgrid::xbt::ReplayAction& action) { simgrid::smpi::replay::AllToAllAction().execute(action); }); xbt_replay_action_register("allToAllV", [](simgrid::xbt::ReplayAction& action) { simgrid::smpi::replay::AllToAllVAction().execute(action); }); xbt_replay_action_register("gather", [](simgrid::xbt::ReplayAction& action) { simgrid::smpi::replay::GatherAction("gather").execute(action); }); -- 2.20.1