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
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
|
/* Copyright (c) 2017-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 "simgrid/plugins/jbod.hpp"
XBT_LOG_NEW_DEFAULT_CATEGORY(jbod_test, "Messages specific for this simulation");
namespace sg4 = simgrid::s4u;
static void write_then_read(simgrid::plugin::JbodPtr jbod)
{
simgrid::plugin::JbodIoPtr io = jbod->write_async(1e7);
XBT_INFO("asynchronous write posted, wait for it");
io->wait();
XBT_INFO("asynchronous write done");
jbod->read_init(1e7)->wait();
XBT_INFO("synchonous read done");
jbod->write(1e7);
XBT_INFO("synchonous write done");
io = jbod->read_async(1e7);
XBT_INFO("asynchronous read posted, wait for it");
io->wait();
XBT_INFO("asynchonous read done");
jbod->write_init(1e7)->wait();
XBT_INFO("synchonous write done");
jbod->read(1e7);
XBT_INFO("synchonous read done");
jbod->read(1e7);
XBT_INFO("synchonous read done");
}
int main(int argc, char** argv)
{
sg4::Engine e(&argc, argv);
auto* zone = e.get_netzone_root();
auto* host = zone->add_host("host", "1Gf");
// set up link so that data transfer from host to JBOD takes exactly 1 second (without crosstraffic)
const auto* link = zone->add_link("link", 1e7 / 0.97)->set_latency(0);
auto jbod_raid0 =
simgrid::plugin::Jbod::create_jbod(zone, "jbod_raid0", 1e9, 4, simgrid::plugin::Jbod::RAID::RAID0, 1e7, 5e6);
zone->add_route(host, jbod_raid0->get_controller(), {link});
auto jbod_raid1 =
simgrid::plugin::Jbod::create_jbod(zone, "jbod_raid1", 1e9, 4, simgrid::plugin::Jbod::RAID::RAID1, 1e7, 5e6);
zone->add_route(host, jbod_raid1->get_controller(), {link});
auto jbod_raid4 =
simgrid::plugin::Jbod::create_jbod(zone, "jbod_raid4", 1e9, 4, simgrid::plugin::Jbod::RAID::RAID4, 1e7, 5e6);
zone->add_route(host, jbod_raid4->get_controller(), {link});
auto jbod_raid5 =
simgrid::plugin::Jbod::create_jbod(zone, "jbod_raid5", 1e9, 4, simgrid::plugin::Jbod::RAID::RAID5, 1e7, 5e6);
zone->add_route(host, jbod_raid5->get_controller(), {link});
auto jbod_raid6 =
simgrid::plugin::Jbod::create_jbod(zone, "jbod_raid6", 1e9, 4, simgrid::plugin::Jbod::RAID::RAID6, 1e7, 5e6);
zone->add_route(host, jbod_raid6->get_controller(), {link});
zone->seal();
auto jbod_test = simgrid::plugin::Jbod::by_name("jbod_raid1");
XBT_INFO("'%s' is a valid JBOD", jbod_test->get_cname());
jbod_test = simgrid::plugin::Jbod::by_name_or_null("jbod_raid3");
if (not jbod_test)
XBT_INFO("'jbod_raid3' is not a valid JBOD");
XBT_INFO("XXXXXXXXXXXXXXX RAID 0 XXXXXXXXXXXXXXXX");
e.add_actor("", host, write_then_read, jbod_raid0);
e.run();
XBT_INFO("XXXXXXXXXXXXXXX RAID 1 XXXXXXXXXXXXXXXX");
e.add_actor("", host, write_then_read, jbod_raid1);
e.run();
XBT_INFO("XXXXXXXXXXXXXXX RAID 4 XXXXXXXXXXXXXXXX");
e.add_actor("", host, write_then_read, jbod_raid4);
e.run();
XBT_INFO("XXXXXXXXXXXXXXX RAID 5 XXXXXXXXXXXXXXXX");
e.add_actor("", host, write_then_read, jbod_raid5);
e.run();
XBT_INFO("XXXXXXXXXXXXXXX RAID 6 XXXXXXXXXXXXXXXX");
e.add_actor("", host, write_then_read, jbod_raid6);
e.run();
XBT_INFO("Simulated time: %g", sg4::Engine::get_clock());
return 0;
}
|
