X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/14618dc3963308a371947b248cef842153acffc1..7a1d9713c8dd8a96686f75acb428b2e4dcb08c1f:/examples/cpp/dag-scheduling/s4u-dag-scheduling.cpp

diff --git a/examples/cpp/dag-scheduling/s4u-dag-scheduling.cpp b/examples/cpp/dag-scheduling/s4u-dag-scheduling.cpp
index 40a9ad3057..d20de088e1 100644
--- a/examples/cpp/dag-scheduling/s4u-dag-scheduling.cpp
+++ b/examples/cpp/dag-scheduling/s4u-dag-scheduling.cpp
@@ -1,10 +1,10 @@
-/* Copyright (c) 2009-2022. The SimGrid Team. All rights reserved.          */
+/* Copyright (c) 2009-2023. 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. */
 
 /* simple test to schedule a DAX file with the Min-Min algorithm.           */
-#include <math.h>
+#include <algorithm>
 #include <simgrid/host.h>
 #include <simgrid/s4u.hpp>
 #include <string.h>
@@ -55,13 +55,11 @@ static std::vector<sg4::Exec*> get_ready_tasks(const std::vector<sg4::ActivityPt
     // Only look at activity that have their dependencies solved but are not assigned
     if (a->dependencies_solved() && not a->is_assigned()) {
       // if it is an exec, it's ready
-      auto* exec = dynamic_cast<sg4::Exec*>(a.get());
-      if (exec != nullptr)
+      if (auto* exec = dynamic_cast<sg4::Exec*>(a.get()))
         ready_tasks.push_back(exec);
       // if it a comm, we consider its successor as a candidate. If a candidate solves all its dependencies,
       // i.e., get all its input data, it's ready
-      const auto* comm = dynamic_cast<sg4::Comm*>(a.get());
-      if (comm != nullptr) {
+      if (const auto* comm = dynamic_cast<sg4::Comm*>(a.get())) {
         auto* next_exec = static_cast<sg4::Exec*>(comm->get_successors().front().get());
         candidate_execs[next_exec]++;
         if (next_exec->get_dependencies().size() == candidate_execs[next_exec])
@@ -75,49 +73,36 @@ static std::vector<sg4::Exec*> get_ready_tasks(const std::vector<sg4::ActivityPt
 
 static double finish_on_at(const sg4::ExecPtr task, const sg4::Host* host)
 {
-  double result;
-
-  const auto& parents = task->get_dependencies();
-
-  if (not parents.empty()) {
-    double data_available = 0.;
-    double last_data_available;
-    /* compute last_data_available */
-    last_data_available = -1.0;
-    for (const auto& parent : parents) {
-      /* normal case */
-      const auto* comm = dynamic_cast<sg4::Comm*>(parent.get());
-      if (comm != nullptr) {
-        auto source = comm->get_source();
-        XBT_DEBUG("transfer from %s to %s", source->get_cname(), host->get_cname());
-        /* Estimate the redistribution time from this parent */
-        double redist_time;
-        if (comm->get_remaining() <= 1e-6) {
-          redist_time = 0;
-        } else {
-          redist_time = sg_host_get_route_latency(source, host) +
-                        comm->get_remaining() / sg_host_get_route_bandwidth(source, host);
-        }
-        // We use the user data field to store the finish time of the predecessor of the comm, i.e., its potential start
-        // time
-        data_available = *comm->get_data<double>() + redist_time;
+  double data_available      = 0.;
+  double last_data_available = -1.0;
+  /* compute last_data_available */
+  for (const auto& parent : task->get_dependencies()) {
+    /* normal case */
+    if (const auto* comm = dynamic_cast<sg4::Comm*>(parent.get())) {
+      auto source = comm->get_source();
+      XBT_DEBUG("transfer from %s to %s", source->get_cname(), host->get_cname());
+      /* Estimate the redistribution time from this parent */
+      double redist_time;
+      if (comm->get_remaining() <= 1e-6) {
+        redist_time = 0;
+      } else {
+        redist_time =
+            sg_host_get_route_latency(source, host) + comm->get_remaining() / sg_host_get_route_bandwidth(source, host);
       }
-
-      const auto* exec = dynamic_cast<sg4::Exec*>(parent.get());
-      /* no transfer, control dependency */
-      if (exec != nullptr) {
-        data_available = exec->get_finish_time();
-      }
-
-      if (last_data_available < data_available)
-        last_data_available = data_available;
+      // We use the user data field to store the finish time of the predecessor of the comm, i.e., its potential start
+      // time
+      data_available = *comm->get_data<double>() + redist_time;
     }
 
-    result = fmax(sg_host_get_available_at(host), last_data_available) + task->get_remaining() / host->get_speed();
-  } else
-    result = sg_host_get_available_at(host) + task->get_remaining() / host->get_speed();
+    /* no transfer, control dependency */
+    if (const auto* exec = dynamic_cast<sg4::Exec*>(parent.get()))
+      data_available = exec->get_finish_time();
+
+    if (last_data_available < data_available)
+      last_data_available = data_available;
+  }
 
-  return result;
+  return std::max(sg_host_get_available_at(host), last_data_available) + task->get_remaining() / host->get_speed();
 }
 
 static sg4::Host* get_best_host(const sg4::ExecPtr exec)
@@ -240,8 +225,8 @@ int main(int argc, char** argv)
      * new dependency
      */
 
-    auto last_scheduled_task = sg_host_get_last_scheduled_task(selected_host);
-    if (last_scheduled_task && (last_scheduled_task->get_state() != sg4::Activity::State::FINISHED) &&
+    if (auto last_scheduled_task = sg_host_get_last_scheduled_task(selected_host);
+        last_scheduled_task && (last_scheduled_task->get_state() != sg4::Activity::State::FINISHED) &&
         (last_scheduled_task->get_state() != sg4::Activity::State::FAILED) &&
         not dependency_exists(sg_host_get_last_scheduled_task(selected_host), selected_task))
       last_scheduled_task->add_successor(selected_task);