Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
[sonar] bunch of const
authorSUTER Frederic <frederic.suter@cc.in2p3.fr>
Fri, 24 Dec 2021 11:16:48 +0000 (12:16 +0100)
committerSUTER Frederic <frederic.suter@cc.in2p3.fr>
Fri, 24 Dec 2021 11:27:42 +0000 (12:27 +0100)
19 files changed:
examples/cpp/dag-comm/s4u-dag-comm.cpp
examples/cpp/dag-failure/s4u-dag-failure.cpp
examples/cpp/dag-from-dot/s4u-dag-from-dot.cpp
examples/cpp/dag-io/s4u-dag-io.cpp
examples/cpp/dag-simple/s4u-dag-simple.cpp
include/simgrid/s4u/Comm.hpp
include/simgrid/s4u/Engine.hpp
include/simgrid/s4u/Exec.hpp
src/instr/instr_platform.cpp
src/kernel/EngineImpl.cpp
src/kernel/actor/ActorImpl.cpp
src/kernel/resource/VirtualMachineImpl.cpp
src/plugins/host_dvfs.cpp
src/plugins/host_load.cpp
src/plugins/vm/dirty_page_tracking.cpp
src/s4u/s4u_Engine.cpp
src/s4u/s4u_Exec.cpp
src/surf/HostImpl.cpp
teshsuite/s4u/dependencies/dependencies.cpp

index b7a90ea..9401b8a 100644 (file)
@@ -19,17 +19,17 @@ int main(int argc, char* argv[])
   auto jupiter  = e.host_by_name("Jupiter");
 
   // Display the details on vetoed activities
-  simgrid::s4u::Activity::on_veto.connect([](simgrid::s4u::Activity& a) {
+  simgrid::s4u::Activity::on_veto.connect([](const simgrid::s4u::Activity& a) {
     XBT_INFO("Activity '%s' vetoed. Dependencies: %s; Ressources: %s", a.get_cname(),
              (a.dependencies_solved() ? "solved" : "NOT solved"), (a.is_assigned() ? "assigned" : "NOT assigned"));
   });
 
   simgrid::s4u::Activity::on_completion.connect([](simgrid::s4u::Activity& activity) {
-    auto* exec = dynamic_cast<simgrid::s4u::Exec*>(&activity);
+    const auto* exec = dynamic_cast<simgrid::s4u::Exec*>(&activity);
     if (exec != nullptr)
       XBT_INFO("Activity '%s' is complete (start time: %f, finish time: %f)", exec->get_cname(), exec->get_start_time(),
                exec->get_finish_time());
-    auto* comm = dynamic_cast<simgrid::s4u::Comm*>(&activity);
+    const auto* comm = dynamic_cast<simgrid::s4u::Comm*>(&activity);
     if (comm != nullptr)
       XBT_INFO("Activity '%s' is complete", comm->get_cname());
   });
index a3da8aa..2c6bd2e 100644 (file)
@@ -19,7 +19,7 @@ int main(int argc, char** argv)
   auto* faulty = e.host_by_name("Faulty Host");
   auto* safe   = e.host_by_name("Safe Host");
   sg4::Activity::on_completion.connect([](sg4::Activity& activity) {
-    auto* exec = dynamic_cast<simgrid::s4u::Exec*>(&activity);
+    const auto* exec = dynamic_cast<simgrid::s4u::Exec*>(&activity);
     if (exec == nullptr) // Only Execs are concerned here
       return;
     if (exec->get_state() == sg4::Activity::State::FINISHED)
index ce05e47..11b6eee 100644 (file)
@@ -62,12 +62,12 @@ int main(int argc, char** argv)
 
   XBT_INFO("-------------- Summary of executed schedule ------------------");
   for (const auto& a : dag) {
-    auto* exec = dynamic_cast<simgrid::s4u::Exec*>(a.get());
+    const auto* exec = dynamic_cast<simgrid::s4u::Exec*>(a.get());
     if (exec != nullptr) {
       XBT_INFO("[%f->%f] '%s' executed on %s", exec->get_start_time(), exec->get_finish_time(), exec->get_cname(),
                exec->get_host()->get_cname());
     }
-    auto* comm = dynamic_cast<simgrid::s4u::Comm*>(a.get());
+    const auto* comm = dynamic_cast<simgrid::s4u::Comm*>(a.get());
     if (comm != nullptr) {
       XBT_INFO("[%f->%f] '%s' transferred from %s to %s", comm->get_start_time(), comm->get_finish_time(),
                comm->get_cname(), comm->get_source()->get_cname(), comm->get_destination()->get_cname());
index 12077c7..9f1bee8 100644 (file)
@@ -19,13 +19,13 @@ int main(int argc, char* argv[])
   auto carl = e.host_by_name("carl");
 
   // Display the details on vetoed activities
-  simgrid::s4u::Activity::on_veto.connect([](simgrid::s4u::Activity& a) {
+  simgrid::s4u::Activity::on_veto.connect([](const simgrid::s4u::Activity& a) {
     XBT_INFO("Activity '%s' vetoed. Dependencies: %s; Ressources: %s", a.get_cname(),
              (a.dependencies_solved() ? "solved" : "NOT solved"), (a.is_assigned() ? "assigned" : "NOT assigned"));
   });
 
   simgrid::s4u::Activity::on_completion.connect([](simgrid::s4u::Activity& activity) {
-    auto* exec = dynamic_cast<simgrid::s4u::Exec*>(&activity);
+    const auto* exec = dynamic_cast<simgrid::s4u::Exec*>(&activity);
     if (exec == nullptr) // Only Execs are concerned here
       return;
     XBT_INFO("Activity '%s' is complete (start time: %f, finish time: %f)", exec->get_cname(), exec->get_start_time(),
index f3fa340..f377550 100644 (file)
@@ -18,8 +18,8 @@ int main(int argc, char* argv[])
   auto fafard = e.host_by_name("Fafard");
 
   // Display the details on vetoed activities
-  simgrid::s4u::Activity::on_veto.connect([](simgrid::s4u::Activity& a) {
-    auto& exec = static_cast<simgrid::s4u::Exec&>(a); // all activities are execs in this example
+  simgrid::s4u::Activity::on_veto.connect([](const simgrid::s4u::Activity& a) {
+    const auto& exec = static_cast<const simgrid::s4u::Exec&>(a); // all activities are execs in this example
 
     XBT_INFO("Activity '%s' vetoed. Dependencies: %s; Ressources: %s", exec.get_cname(),
              (exec.dependencies_solved() ? "solved" : "NOT solved"),
@@ -27,7 +27,7 @@ int main(int argc, char* argv[])
   });
 
   simgrid::s4u::Activity::on_completion.connect([](simgrid::s4u::Activity& activity) {
-    auto* exec = dynamic_cast<simgrid::s4u::Exec*>(&activity);
+    const auto* exec = dynamic_cast<simgrid::s4u::Exec*>(&activity);
     if (exec == nullptr) // Only Execs are concerned here
       return;
     XBT_INFO("Activity '%s' is complete (start time: %f, finish time: %f)", exec->get_cname(), exec->get_start_time(),
index 6806ed9..bee49b3 100644 (file)
@@ -108,9 +108,9 @@ public:
 
   /** Set the source and destination of communications that bypass the mailbox mechanism */
   CommPtr set_source(Host* from);
-  Host* get_source() { return from_; }
+  Host* get_source() const { return from_; }
   CommPtr set_destination(Host* to);
-  Host* get_destination() { return to_; }
+  Host* get_destination() const { return to_; }
 
   /** Sets the maximal communication rate (in byte/sec). Must be done before start */
   CommPtr set_rate(double rate);
index 20f6ee8..e57c3b6 100644 (file)
@@ -85,7 +85,7 @@ public:
   }
 
   /** If non-null, the provided set will be filled with all activities that fail to start because of a veto */
-  void track_vetoed_activities(std::set<Activity*>* vetoed_activities);
+  void track_vetoed_activities(std::set<Activity*>* vetoed_activities) const;
 
   void load_deployment(const std::string& deploy) const;
 
index e030b5a..14c173b 100644 (file)
@@ -40,7 +40,7 @@ class XBT_PUBLIC Exec : public Activity_T<Exec> {
 protected:
   explicit Exec(kernel::activity::ExecImplPtr pimpl);
 
-  void reset();
+  void reset() const;
 
 public:
 #ifndef DOXYGEN
index 801cd44..67cf075 100644 (file)
@@ -467,7 +467,7 @@ void define_callbacks()
     s4u::Exec::on_start.connect([](s4u::Exec const&) {
       Container::by_name(instr_pid(*s4u::Actor::self()))->get_state("ACTOR_STATE")->push_event("execute");
     });
-    s4u::Activity::on_completion.connect([](s4u::Activity&) {
+    s4u::Activity::on_completion.connect([](const s4u::Activity&) {
       Container::by_name(instr_pid(*s4u::Actor::self()))->get_state("ACTOR_STATE")->pop_event();
     });
     s4u::Comm::on_send.connect([](s4u::Comm const&) {
@@ -485,7 +485,7 @@ void define_callbacks()
           ->get_state("MPI_STATE")
           ->push_event("computing", new CpuTIData("compute", exec.get_cost()));
     });
-    s4u::Activity::on_completion.connect([](s4u::Activity&) {
+    s4u::Activity::on_completion.connect([](const s4u::Activity&) {
       Container::by_name(std::string("rank-") + std::to_string(s4u::Actor::self()->get_pid()))
           ->get_state("MPI_STATE")
           ->pop_event();
index 9017884..665e7cb 100644 (file)
@@ -696,7 +696,7 @@ void EngineImpl::run(double max_date)
   }
 
   double elapsed_time = -1;
-  std::set<s4u::Activity*>* vetoed_activities = s4u::Activity::get_vetoed_activities();
+  const std::set<s4u::Activity*>* vetoed_activities = s4u::Activity::get_vetoed_activities();
 
   do {
     XBT_DEBUG("New Schedule Round; size(queue)=%zu", actors_to_run_.size());
index e670469..6e206eb 100644 (file)
@@ -536,6 +536,6 @@ smx_actor_t SIMIX_process_from_PID(aid_t pid) // XBT_ATTRIB_DEPRECATED_v331
 
 int SIMIX_is_maestro() // XBT_ATTRIB_DEPRECATED_v333
 {
-  auto* self = simgrid::kernel::actor::ActorImpl::self();
+  const auto* self = simgrid::kernel::actor::ActorImpl::self();
   return self != nullptr && self->is_maestro();
 }
index de7fddb..e429c16 100644 (file)
@@ -77,7 +77,7 @@ static void add_active_exec(s4u::Exec const& task)
 
 static void remove_active_exec(s4u::Activity& task)
 {
-  auto* exec = dynamic_cast<s4u::Exec*>(&task);
+  const auto* exec = dynamic_cast<s4u::Exec*>(&task);
   if (exec == nullptr)
     return;
   const s4u::VirtualMachine* vm = dynamic_cast<s4u::VirtualMachine*>(exec->get_host());
index bc6203b..ef6f7d4 100644 (file)
@@ -300,7 +300,7 @@ public:
         pre_task();
     });
     simgrid::s4u::Activity::on_completion.connect([this](simgrid::s4u::Activity& activity) {
-      auto* exec = dynamic_cast<simgrid::s4u::Exec*>(&activity);
+      const auto* exec = dynamic_cast<simgrid::s4u::Exec*>(&activity);
       if (exec == nullptr) // Only Execs are concerned here
         return;
       // For more than one host (not yet supported), we can access the host via
index 545befb..3f95fb4 100644 (file)
@@ -250,7 +250,7 @@ void sg_host_load_plugin_init()
     }
   });
   simgrid::s4u::Activity::on_completion.connect([](simgrid::s4u::Activity& activity) {
-    auto* exec = dynamic_cast<simgrid::s4u::Exec*>(&activity);
+    const auto* exec = dynamic_cast<simgrid::s4u::Exec*>(&activity);
     if (exec == nullptr) // Only Execs are concerned here
       return;
     if (exec->get_host_number() == 1) { // We only run on one host
index c128303..466c071 100644 (file)
@@ -94,7 +94,7 @@ static void on_exec_creation(simgrid::s4u::Exec const& e)
 
 static void on_exec_completion(simgrid::s4u::Activity& e)
 {
-  auto exec = dynamic_cast<simgrid::kernel::activity::ExecImpl*>(e.get_impl());
+  const auto exec = dynamic_cast<simgrid::kernel::activity::ExecImpl*>(e.get_impl());
   if (exec == nullptr)
     return;
   const simgrid::s4u::VirtualMachine* vm = dynamic_cast<simgrid::s4u::VirtualMachine*>(exec->get_host());
index 6d73ea2..0d1c8f8 100644 (file)
@@ -338,7 +338,7 @@ void Engine::run_until(double max_date) const
   }
 }
 
-void Engine::track_vetoed_activities(std::set<Activity*>* vetoed_activities)
+void Engine::track_vetoed_activities(std::set<Activity*>* vetoed_activities) const
 {
   Activity::set_vetoed_activities(vetoed_activities);
 }
index c742291..e6723c4 100644 (file)
@@ -23,7 +23,7 @@ Exec::Exec(kernel::activity::ExecImplPtr pimpl)
   pimpl_ = pimpl;
 }
 
-void Exec::reset()
+void Exec::reset() const
 {
   boost::static_pointer_cast<kernel::activity::ExecImpl>(pimpl_)->reset();
 }
index 4fe0ac9..1ffe713 100644 (file)
@@ -99,7 +99,7 @@ void HostImpl::turn_off(const actor::ActorImpl* issuer)
               actor.get_host()->get_cname(), issuer->get_cname());
     issuer->kill(&actor);
   }
-  for (auto& activity : EngineImpl::get_instance()->get_maestro()->activities_) {
+  for (const auto& activity : EngineImpl::get_instance()->get_maestro()->activities_) {
     auto* exec = dynamic_cast<activity::ExecImpl*>(activity.get());
     if (exec != nullptr) {
       auto hosts = exec->get_hosts();
index 6a9cf63..e846943 100644 (file)
@@ -14,7 +14,7 @@ int main(int argc, char** argv)
   e.load_platform(argv[1]);
 
   simgrid::s4u::Activity::on_completion.connect([](simgrid::s4u::Activity& activity) {
-    auto* exec = dynamic_cast<simgrid::s4u::Exec*>(&activity);
+    const auto* exec = dynamic_cast<simgrid::s4u::Exec*>(&activity);
     if (exec == nullptr) // Only Execs are concerned here
       return;
     XBT_INFO("Exec '%s' start time: %f, finish time: %f", exec->get_cname(), exec->get_start_time(),
@@ -35,7 +35,7 @@ int main(int argc, char** argv)
 
   try {
     A->add_successor(A);
-    /* shouldn't work and must raise an exception */
+    /* shouldn't work and must raise an exception */
     xbt_die("Hey, I can add a dependency between A and A!");
   } catch (const std::invalid_argument& e) {
     XBT_INFO("Caught attempt to self-dependency creation: %s", e.what());