From c6f8ca620b4fdf2a32d5ea398569cb3680d108dd Mon Sep 17 00:00:00 2001 From: Arnaud Giersch Date: Fri, 6 May 2022 10:17:57 +0200 Subject: [PATCH] No need to have two code paths. --- .../cpp/dag-scheduling/s4u-dag-scheduling.cpp | 65 ++++++++----------- 1 file changed, 27 insertions(+), 38 deletions(-) diff --git a/examples/cpp/dag-scheduling/s4u-dag-scheduling.cpp b/examples/cpp/dag-scheduling/s4u-dag-scheduling.cpp index 155a84b479..da4e24b180 100644 --- a/examples/cpp/dag-scheduling/s4u-dag-scheduling.cpp +++ b/examples/cpp/dag-scheduling/s4u-dag-scheduling.cpp @@ -4,7 +4,7 @@ * 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 +#include #include #include #include @@ -73,47 +73,36 @@ static std::vector get_ready_tasks(const std::vectorget_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 */ - if (const auto* comm = dynamic_cast(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); - } - // 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() + redist_time; - } - - /* no transfer, control dependency */ - if (const auto* exec = dynamic_cast(parent.get())) { - data_available = exec->get_finish_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(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); } - - 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() + 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(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) -- 2.20.1