blob: 508a31a18a49fe32b421f1c322e71dd7c5168f82 (
plain)
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
|
#include "simgrid/s4u.hpp"
#include <simgrid/s4u/Mailbox.hpp>
#include <string>
#include <sstream>
#include "inputs.hpp"
#include "xbt/log.h"
XBT_LOG_NEW_DEFAULT_CATEGORY(simulator, "[DAO]");
typedef unsigned int u32;
u32 max_attempts=0;
/// @brief Observation unit code
static void obs_unit(std::vector<std::string> args);
int main(int argc, char **argv) {
// Build engine
simgrid::s4u::Engine engine(&argc, argv);
engine.load_platform("platform.xml");
// Parse arguments
max_attempts=std::stoi(argv[1]);
XBT_INFO("-------------------------------------------------");
XBT_INFO("Sarting loosely coupled data dissemination experiments");
XBT_INFO("Number of wake attempts per OU is %d",max_attempts);
XBT_INFO("-------------------------------------------------");
u32 nObsUnit=simgrid::s4u::Engine::get_instance()->get_host_count();
for(u32 i=0;i<nObsUnit;i++){
std::vector<std::string> args;
std::ostringstream ss;
ss<< "ou" <<i;
simgrid::s4u::Actor::create("Sender", simgrid::s4u::Host::by_name(ss.str()), obs_unit, args);
}
// Setup/Run simulation
engine.run();
XBT_INFO("Simulation took %fs", simgrid::s4u::Engine::get_clock());
return (0);
}
static void obs_unit(std::vector<std::string> args) {
std::string selfName = simgrid::s4u::this_actor::get_host()->get_name();
Inputs i(selfName);
simgrid::s4u::Mailbox *m = simgrid::s4u::Mailbox::by_name("medium");
XBT_INFO("Deploying %s",selfName.c_str());
std::string msg("aloha");
double wake_interval=i.wake_interval;
for(u32 i=0;i<max_attempts;i++){
try
{
simgrid::s4u::this_actor::sleep_for(wake_interval);
}
catch (...)
{
XBT_INFO("Not send");
}
}
}
|
