1 /* simple test trying to load a DAX file. */
3 /* Copyright (c) 2009-2022. The SimGrid Team. All rights reserved. */
5 /* This program is free software; you can redistribute it and/or modify it
6 * under the terms of the license (GNU LGPL) which comes with this package. */
8 #include "simgrid/s4u.hpp"
13 XBT_LOG_NEW_DEFAULT_CATEGORY(dag_from_dax, "Logging specific to this example");
14 namespace sg4 = simgrid::s4u;
16 int main(int argc, char** argv)
18 sg4::Engine e(&argc, argv);
19 e.load_platform(argv[1]);
21 std::vector<sg4::ActivityPtr> dag = sg4::create_DAG_from_DAX(argv[2]);
24 XBT_ERROR("A problem occurred during DAX parsing (cycle or syntax). Do not continue this test");
28 XBT_INFO("--------- Display all activities of the loaded DAG -----------");
29 for (const auto& a : dag) {
30 std::string type = "an Exec";
31 std::string task = "flops to execute";
32 if (dynamic_cast<sg4::Comm*>(a.get()) != nullptr) {
34 task = "bytes to transfer";
36 XBT_INFO("'%s' is %s: %.0f %s. Dependencies: %s; Ressources: %s", a->get_cname(), type.c_str(), a->get_remaining(),
37 task.c_str(), (a->dependencies_solved() ? "solved" : "NOT solved"),
38 (a->is_assigned() ? "assigned" : "NOT assigned"));
41 XBT_INFO("------------------- Schedule tasks ---------------------------");
42 auto hosts = e.get_all_hosts();
43 auto count = e.get_host_count();
46 static_cast<sg4::Exec*>(dag.back().get())->set_host(hosts[0]);
48 for (const auto& a : dag) {
49 if (auto* exec = dynamic_cast<sg4::Exec*>(a.get()); exec != nullptr && exec->get_name() != "end") {
50 exec->set_host(hosts[cursor % count]);
53 if (auto* comm = dynamic_cast<sg4::Comm*>(a.get())) {
54 auto pred = dynamic_cast<sg4::Exec*>((*comm->get_dependencies().begin()).get());
55 auto succ = dynamic_cast<sg4::Exec*>(comm->get_successors().front().get());
56 comm->set_source(pred->get_host())->set_destination(succ->get_host());
60 XBT_INFO("------------------- Run the schedule -------------------------");
63 XBT_INFO("-------------- Summary of executed schedule ------------------");
64 for (const auto& a : dag) {
65 if (const auto* exec = dynamic_cast<sg4::Exec*>(a.get())) {
66 XBT_INFO("[%f->%f] '%s' executed on %s", exec->get_start_time(), exec->get_finish_time(), exec->get_cname(),
67 exec->get_host()->get_cname());
69 if (const auto* comm = dynamic_cast<sg4::Comm*>(a.get())) {
70 XBT_INFO("[%f->%f] '%s' transferred from %s to %s", comm->get_start_time(), comm->get_finish_time(),
71 comm->get_cname(), comm->get_source()->get_cname(), comm->get_destination()->get_cname());