X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/fe9f13ea487593ec11c6af50d8150a6743c84114..4b0fa756ae6e58a74c374a519389ecb9e8b6a4d9:/include/simgrid/smpi/replay.hpp

diff --git a/include/simgrid/smpi/replay.hpp b/include/simgrid/smpi/replay.hpp
index 169d71c95d..4da7a7ee7a 100644
--- a/include/simgrid/smpi/replay.hpp
+++ b/include/simgrid/smpi/replay.hpp
@@ -1,4 +1,4 @@
-/* Copyright (c) 2009-2019. The SimGrid Team. All rights reserved.          */
+/* Copyright (c) 2009-2020. The SimGrid Team. All rights reserved.          */
 
 /* This program is free software; you can redistribute it and/or modify it
  * under the terms of the license (GNU LGPL) which comes with this package. */
@@ -34,7 +34,7 @@
 XBT_PRIVATE unsigned char* smpi_get_tmp_sendbuffer(size_t size);
 XBT_PRIVATE unsigned char* smpi_get_tmp_recvbuffer(size_t size);
 
-XBT_PRIVATE void log_timed_action(simgrid::xbt::ReplayAction& action, double clock);
+XBT_PRIVATE void log_timed_action(const simgrid::xbt::ReplayAction& action, double clock);
 
 namespace simgrid {
 namespace smpi {
@@ -49,7 +49,7 @@ class RequestStorage; // Forward decl
 class ActionArgParser {
 public:
   virtual ~ActionArgParser() = default;
-  virtual void parse(simgrid::xbt::ReplayAction& action, const std::string& name) { CHECK_ACTION_PARAMS(action, 0, 0) }
+  virtual void parse(xbt::ReplayAction& action, const std::string& name) { CHECK_ACTION_PARAMS(action, 0, 0) }
 };
 
 class WaitTestParser : public ActionArgParser {
@@ -58,7 +58,7 @@ public:
   int dst;
   int tag;
 
-  void parse(simgrid::xbt::ReplayAction& action, const std::string& name) override;
+  void parse(xbt::ReplayAction& action, const std::string& name) override;
 };
 
 class SendRecvParser : public ActionArgParser {
@@ -69,15 +69,29 @@ public:
   int tag;
   MPI_Datatype datatype1 = MPI_DEFAULT_TYPE;
 
-  void parse(simgrid::xbt::ReplayAction& action, const std::string& name) override;
+  void parse(xbt::ReplayAction& action, const std::string& name) override;
 };
 
 class ComputeParser : public ActionArgParser {
 public:
-  /* communication partner; if we send, this is the receiver and vice versa */
   double flops;
 
-  void parse(simgrid::xbt::ReplayAction& action, const std::string& name) override;
+  void parse(xbt::ReplayAction& action, const std::string& name) override;
+};
+
+class SleepParser : public ActionArgParser {
+public:
+  double time;
+
+  void parse(xbt::ReplayAction& action, const std::string& name) override;
+};
+
+class LocationParser : public ActionArgParser {
+public:
+  std::string filename;
+  int line;
+
+  void parse(xbt::ReplayAction& action, const std::string& name) override;
 };
 
 class CollCommParser : public ActionArgParser {
@@ -94,27 +108,27 @@ public:
 
 class BcastArgParser : public CollCommParser {
 public:
-  void parse(simgrid::xbt::ReplayAction& action, const std::string& name) override;
+  void parse(xbt::ReplayAction& action, const std::string& name) override;
 };
 
 class ReduceArgParser : public CollCommParser {
 public:
-  void parse(simgrid::xbt::ReplayAction& action, const std::string& name) override;
+  void parse(xbt::ReplayAction& action, const std::string& name) override;
 };
 
 class AllReduceArgParser : public CollCommParser {
 public:
-  void parse(simgrid::xbt::ReplayAction& action, const std::string& name) override;
+  void parse(xbt::ReplayAction& action, const std::string& name) override;
 };
 
 class AllToAllArgParser : public CollCommParser {
 public:
-  void parse(simgrid::xbt::ReplayAction& action, const std::string& name) override;
+  void parse(xbt::ReplayAction& action, const std::string& name) override;
 };
 
 class GatherArgParser : public CollCommParser {
 public:
-  void parse(simgrid::xbt::ReplayAction& action, const std::string& name) override;
+  void parse(xbt::ReplayAction& action, const std::string& name) override;
 };
 
 class GatherVArgParser : public CollCommParser {
@@ -122,12 +136,12 @@ public:
   int recv_size_sum;
   std::shared_ptr<std::vector<int>> recvcounts;
   std::vector<int> disps;
-  void parse(simgrid::xbt::ReplayAction& action, const std::string& name) override;
+  void parse(xbt::ReplayAction& action, const std::string& name) override;
 };
 
 class ScatterArgParser : public CollCommParser {
 public:
-  void parse(simgrid::xbt::ReplayAction& action, const std::string& name) override;
+  void parse(xbt::ReplayAction& action, const std::string& name) override;
 };
 
 class ScatterVArgParser : public CollCommParser {
@@ -136,7 +150,7 @@ public:
   int send_size_sum;
   std::shared_ptr<std::vector<int>> sendcounts;
   std::vector<int> disps;
-  void parse(simgrid::xbt::ReplayAction& action, const std::string& name) override;
+  void parse(xbt::ReplayAction& action, const std::string& name) override;
 };
 
 class ReduceScatterArgParser : public CollCommParser {
@@ -144,7 +158,7 @@ public:
   int recv_size_sum;
   std::shared_ptr<std::vector<int>> recvcounts;
   std::vector<int> disps;
-  void parse(simgrid::xbt::ReplayAction& action, const std::string& name) override;
+  void parse(xbt::ReplayAction& action, const std::string& name) override;
 };
 
 class AllToAllVArgParser : public CollCommParser {
@@ -157,7 +171,7 @@ public:
   std::vector<int> recvdisps;
   int send_buf_size;
   int recv_buf_size;
-  void parse(simgrid::xbt::ReplayAction& action, const std::string& name) override;
+  void parse(xbt::ReplayAction& action, const std::string& name) override;
 };
 
 /**
@@ -167,22 +181,26 @@ public:
  * In other words: The logic goes here, the setup is done by the ActionArgParser.
  */
 template <class T> class ReplayAction {
+  const std::string name_;
+  const aid_t my_proc_id_ = s4u::this_actor::get_pid();
+  T args_;
+
 protected:
-  const std::string name;
-  const aid_t my_proc_id;
-  T args;
+  const std::string& get_name() const { return name_; }
+  aid_t get_pid() const { return my_proc_id_; }
+  const T& get_args() const { return args_; }
 
 public:
-  explicit ReplayAction(const std::string& name) : name(name), my_proc_id(simgrid::s4u::this_actor::get_pid()) {}
+  explicit ReplayAction(const std::string& name) : name_(name) {}
   virtual ~ReplayAction() = default;
 
-  void execute(simgrid::xbt::ReplayAction& action)
+  void execute(xbt::ReplayAction& action)
   {
     // Needs to be re-initialized for every action, hence here
     double start_time = smpi_process()->simulated_elapsed();
-    args.parse(action, name);
+    args_.parse(action, name_);
     kernel(action);
-    if (name != "Init")
+    if (name_ != "Init")
       log_timed_action(action, start_time);
   }
 
@@ -192,36 +210,45 @@ public:
 };
 
 class WaitAction : public ReplayAction<WaitTestParser> {
-private:
   RequestStorage& req_storage;
 
 public:
   explicit WaitAction(RequestStorage& storage) : ReplayAction("Wait"), req_storage(storage) {}
-  void kernel(simgrid::xbt::ReplayAction& action) override;
+  void kernel(xbt::ReplayAction& action) override;
 };
 
 class SendAction : public ReplayAction<SendRecvParser> {
-private:
   RequestStorage& req_storage;
 
 public:
   explicit SendAction(const std::string& name, RequestStorage& storage) : ReplayAction(name), req_storage(storage) {}
-  void kernel(simgrid::xbt::ReplayAction& action) override;
+  void kernel(xbt::ReplayAction& action) override;
 };
 
 class RecvAction : public ReplayAction<SendRecvParser> {
-private:
   RequestStorage& req_storage;
 
 public:
   explicit RecvAction(const std::string& name, RequestStorage& storage) : ReplayAction(name), req_storage(storage) {}
-  void kernel(simgrid::xbt::ReplayAction& action) override;
+  void kernel(xbt::ReplayAction& action) override;
 };
 
 class ComputeAction : public ReplayAction<ComputeParser> {
 public:
   explicit ComputeAction() : ReplayAction("compute") {}
-  void kernel(simgrid::xbt::ReplayAction& action) override;
+  void kernel(xbt::ReplayAction& action) override;
+};
+
+class SleepAction : public ReplayAction<SleepParser> {
+public:
+  explicit SleepAction() : ReplayAction("sleep") {}
+  void kernel(xbt::ReplayAction& action) override;
+};
+
+class LocationAction : public ReplayAction<LocationParser> {
+public:
+  explicit LocationAction() : ReplayAction("location") {}
+  void kernel(xbt::ReplayAction& action) override;
 };
 
 class TestAction : public ReplayAction<WaitTestParser> {
@@ -230,97 +257,97 @@ private:
 
 public:
   explicit TestAction(RequestStorage& storage) : ReplayAction("Test"), req_storage(storage) {}
-  void kernel(simgrid::xbt::ReplayAction& action) override;
+  void kernel(xbt::ReplayAction& action) override;
 };
 
 class InitAction : public ReplayAction<ActionArgParser> {
 public:
   explicit InitAction() : ReplayAction("Init") {}
-  void kernel(simgrid::xbt::ReplayAction& action) override;
+  void kernel(xbt::ReplayAction& action) override;
 };
 
 class CommunicatorAction : public ReplayAction<ActionArgParser> {
 public:
   explicit CommunicatorAction() : ReplayAction("Comm") {}
-  void kernel(simgrid::xbt::ReplayAction& action) override;
+  void kernel(xbt::ReplayAction& action) override;
 };
 
 class WaitAllAction : public ReplayAction<ActionArgParser> {
-private:
   RequestStorage& req_storage;
 
 public:
   explicit WaitAllAction(RequestStorage& storage) : ReplayAction("waitall"), req_storage(storage) {}
-  void kernel(simgrid::xbt::ReplayAction& action) override;
+  void kernel(xbt::ReplayAction& action) override;
 };
 
 class BarrierAction : public ReplayAction<ActionArgParser> {
 public:
   explicit BarrierAction() : ReplayAction("barrier") {}
-  void kernel(simgrid::xbt::ReplayAction& action) override;
+  void kernel(xbt::ReplayAction& action) override;
 };
 
 class BcastAction : public ReplayAction<BcastArgParser> {
 public:
   explicit BcastAction() : ReplayAction("bcast") {}
-  void kernel(simgrid::xbt::ReplayAction& action) override;
+  void kernel(xbt::ReplayAction& action) override;
 };
 
 class ReduceAction : public ReplayAction<ReduceArgParser> {
 public:
   explicit ReduceAction() : ReplayAction("reduce") {}
-  void kernel(simgrid::xbt::ReplayAction& action) override;
+  void kernel(xbt::ReplayAction& action) override;
 };
 
 class AllReduceAction : public ReplayAction<AllReduceArgParser> {
 public:
   explicit AllReduceAction() : ReplayAction("allreduce") {}
-  void kernel(simgrid::xbt::ReplayAction& action) override;
+  void kernel(xbt::ReplayAction& action) override;
 };
 
 class AllToAllAction : public ReplayAction<AllToAllArgParser> {
 public:
   explicit AllToAllAction() : ReplayAction("alltoall") {}
-  void kernel(simgrid::xbt::ReplayAction& action) override;
+  void kernel(xbt::ReplayAction& action) override;
 };
 
 class GatherAction : public ReplayAction<GatherArgParser> {
 public:
   explicit GatherAction(const std::string& name) : ReplayAction(name) {}
-  void kernel(simgrid::xbt::ReplayAction& action) override;
+  void kernel(xbt::ReplayAction& action) override;
 };
 
 class GatherVAction : public ReplayAction<GatherVArgParser> {
 public:
   explicit GatherVAction(const std::string& name) : ReplayAction(name) {}
-  void kernel(simgrid::xbt::ReplayAction& action) override;
+  void kernel(xbt::ReplayAction& action) override;
 };
 
 class ScatterAction : public ReplayAction<ScatterArgParser> {
 public:
   explicit ScatterAction() : ReplayAction("scatter") {}
-  void kernel(simgrid::xbt::ReplayAction& action) override;
+  void kernel(xbt::ReplayAction& action) override;
 };
 
 class ScatterVAction : public ReplayAction<ScatterVArgParser> {
 public:
   explicit ScatterVAction() : ReplayAction("scatterv") {}
-  void kernel(simgrid::xbt::ReplayAction& action) override;
+  void kernel(xbt::ReplayAction& action) override;
 };
 
 class ReduceScatterAction : public ReplayAction<ReduceScatterArgParser> {
 public:
   explicit ReduceScatterAction() : ReplayAction("reducescatter") {}
-  void kernel(simgrid::xbt::ReplayAction& action) override;
+  void kernel(xbt::ReplayAction& action) override;
 };
 
 class AllToAllVAction : public ReplayAction<AllToAllVArgParser> {
 public:
   explicit AllToAllVAction() : ReplayAction("alltoallv") {}
-  void kernel(simgrid::xbt::ReplayAction& action) override;
+  void kernel(xbt::ReplayAction& action) override;
 };
-}
-}
-}
+
+} // namespace replay
+} // namespace smpi
+} // namespace simgrid
 
 #endif