1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
|
/* simple test trying to load a DOT file. */
/* Copyright (c) 2010-2025. 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. */
import org.simgrid.s4u.*;
public class dag_from_dot {
public static void main(String[] args)
{
Engine e = new Engine(args);
e.load_platform(args[0]);
Activity[] dag = e.create_DAG_from_dot(args[1]);
if (dag.length == 0) {
Engine.error("No dot loaded. Do you have a cycle in your graph?");
System.exit(2);
}
Engine.info("--------- Display all activities of the loaded DAG -----------");
for (var a : dag) {
String type = "an Exec";
String task = "flops to execute";
if (a instanceof Comm) {
type = "a Comm";
task = "bytes to transfer";
}
Engine.info("'%s' is %s: %.0f %s. Dependencies: %s; Ressources: %s", a.get_name(), type, a.get_remaining(), task,
(a.dependencies_solved() ? "solved" : "NOT solved"), (a.is_assigned() ? "assigned" : "NOT assigned"));
}
Engine.info("------------------- Schedule tasks ---------------------------");
var hosts = e.get_all_hosts();
int count = (int)e.get_host_count();
int cursor = 0;
// Schedule end first
((Exec)dag[dag.length - 1]).set_host(hosts[0]);
for (var a : dag) {
if (a instanceof Exec && a.get_name() != "end") {
var exec = (Exec)a;
exec.set_host(hosts[cursor % count]);
cursor++;
}
if (a instanceof Comm) {
Comm comm = (Comm)a;
var pred = ((Exec)(comm.get_dependencies()[0]));
var succ = ((Exec)comm.get_successors()[0]);
comm.set_source(pred.get_host()).set_destination(succ.get_host());
}
}
Engine.info("------------------- Run the schedule -------------------------");
e.run();
Engine.info("-------------- Summary of executed schedule ------------------");
for (var a : dag) {
if (a instanceof Exec) {
var exec = (Exec)a;
Engine.info("[%f->%f] '%s' executed on %s", exec.get_start_time(), exec.get_finish_time(), exec.get_name(),
exec.get_host().get_name());
}
if (a instanceof Comm) {
var comm = (Comm)a;
Engine.info("[%f->%f] '%s' transferred from %s to %s", comm.get_start_time(), comm.get_finish_time(),
comm.get_name(), comm.get_source().get_name(), comm.get_destination().get_name());
}
}
// The following call is useless in your code, but our continuous integration uses it to track memleaks
e.force_garbage_collection();
}
}
|
