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
|
/* Copyright (c) 2007-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. */
#include "simgrid/s4u.hpp"
#include <vector>
XBT_LOG_NEW_DEFAULT_CATEGORY(s4u_test, "Messages specific for this s4u example");
namespace sg4 = simgrid::s4u;
static void worker()
{
// Define an amount of work that should take 1 second to execute.
double computation_amount = sg4::this_actor::get_host()->get_speed();
// Create a small DAG
// + Two parents and a child
// + First parent ends after 1 second and the Second parent after 2 seconds.
sg4::ExecPtr first_parent = sg4::this_actor::exec_init(computation_amount);
sg4::ExecPtr second_parent = sg4::this_actor::exec_init(2 * computation_amount);
sg4::ExecPtr child = sg4::Exec::init()->set_flops_amount(computation_amount);
sg4::ActivitySet pending_execs ({first_parent, second_parent, child});
// Name the activities (for logging purposes only)
first_parent->set_name("parent 1");
second_parent->set_name("parent 2");
child->set_name("child");
// Create the dependencies by declaring 'child' as a successor of first_parent and second_parent
first_parent->add_successor(child);
second_parent->add_successor(child);
// Start the activities.
first_parent->start();
second_parent->start();
child->start();
// wait for the completion of all activities
while (not pending_execs.empty()) {
auto completed_one = pending_execs.wait_any();
if (completed_one != nullptr)
XBT_INFO("Exec '%s' is complete", completed_one->get_cname());
}
}
int main(int argc, char* argv[])
{
sg4::Engine e(&argc, argv);
e.load_platform(argv[1]);
e.add_actor("worker", e.host_by_name("Fafard"), worker);
sg4::Exec::on_veto_cb([&e](sg4::Exec& exec) {
// First display the situation
XBT_INFO("Activity '%s' vetoed. Dependencies: %s; Ressources: %s", exec.get_cname(),
(exec.dependencies_solved() ? "solved" : "NOT solved"),
(exec.is_assigned() ? "assigned" : "NOT assigned"));
// In this simple case, we just assign the child task to a resource when its dependencies are solved
if (exec.dependencies_solved() && not exec.is_assigned()) {
XBT_INFO("Activity %s's dependencies are resolved. Let's assign it to Fafard.", exec.get_cname());
exec.set_host(e.host_by_name("Fafard"));
}
});
e.run();
XBT_INFO("Simulation time %g", sg4::Engine::get_clock());
return 0;
}
|
