From 18000f1f5a3802b35cb9ac79cc88fec7f885d13c Mon Sep 17 00:00:00 2001 From: Christian Heinrich Date: Tue, 27 Mar 2018 15:06:55 +0200 Subject: [PATCH] [SMPI] Replay: C++-ify barrier action --- src/smpi/internals/smpi_replay.cpp | 23 +++++++++++------------ 1 file changed, 11 insertions(+), 12 deletions(-) diff --git a/src/smpi/internals/smpi_replay.cpp b/src/smpi/internals/smpi_replay.cpp index f5cd6897a9..d89a3fab25 100644 --- a/src/smpi/internals/smpi_replay.cpp +++ b/src/smpi/internals/smpi_replay.cpp @@ -307,19 +307,18 @@ public: } }; -} // Replay Namespace - -static void action_barrier(simgrid::xbt::ReplayAction& action) -{ - double clock = smpi_process()->simulated_elapsed(); - int my_proc_id = Actor::self()->getPid(); - TRACE_smpi_comm_in(my_proc_id, __FUNCTION__, new simgrid::instr::NoOpTIData("barrier")); - - Colls::barrier(MPI_COMM_WORLD); +class BarrierAction : public ReplayAction { +public: + BarrierAction() : ReplayAction("barrier") {} + void kernel(simgrid::xbt::ReplayAction& action) override + { + TRACE_smpi_comm_in(my_proc_id, __FUNCTION__, new simgrid::instr::NoOpTIData("barrier")); + Colls::barrier(MPI_COMM_WORLD); + TRACE_smpi_comm_out(my_proc_id); + } +}; - TRACE_smpi_comm_out(my_proc_id); - log_timed_action (action, clock); -} +} // Replay Namespace static void action_bcast(simgrid::xbt::ReplayAction& action) { -- 2.20.1