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
94
95
96
97
98
99
100
101
102
|
// This file is part of CAF, the C++ Actor Framework. See the file LICENSE in
// the main distribution directory for license terms and copyright or visit
// https://github.com/actor-framework/actor-framework/blob/master/LICENSE.
#define CAF_SUITE io.monitor
#include "caf/io/middleman.hpp"
#include "io-test.hpp"
using namespace caf;
namespace {
struct fixture : point_to_point_fixture<> {
actor observer;
fixture() {
mars_id = mars.sys.node();
}
// Connects earth and mars, storing the connection handles in earth_conn and
// mars_conn.
void connect() {
auto acc = next_accept_handle();
std::tie(earth_conn, mars_conn)
= prepare_connection(earth, mars, "localhost", 8080, acc);
CHECK_EQ(earth.publish(actor{earth.self}, 8080), 8080);
CHECK(mars.remote_actor("localhost", 8080));
}
void disconnect() {
anon_send(earth.bb, io::connection_closed_msg{earth_conn});
earth.handle_io_event();
anon_send(mars.bb, io::connection_closed_msg{mars_conn});
mars.handle_io_event();
}
node_id mars_id;
io::connection_handle earth_conn;
io::connection_handle mars_conn;
};
} // namespace
BEGIN_FIXTURE_SCOPE(fixture)
CAF_TEST(disconnects cause node_down_msg) {
connect();
earth.self->monitor(mars_id);
run();
disconnect();
expect_on(earth, (node_down_msg),
to(earth.self).with(node_down_msg{mars_id, error{}}));
CHECK(earth.self->mailbox().empty());
}
CAF_TEST(node_down_msg calls the special node_down_handler) {
connect();
bool node_down_handler_called = false;
auto observer = earth.sys.spawn([&](event_based_actor* self) -> behavior {
self->monitor(mars_id);
self->set_node_down_handler([&](node_down_msg& dm) {
CHECK_EQ(dm.node, mars_id);
node_down_handler_called = true;
});
return [] {};
});
run();
disconnect();
expect_on(earth, (node_down_msg),
to(observer).with(node_down_msg{mars_id, error{}}));
CHECK(node_down_handler_called);
}
CAF_TEST(calling monitor n times produces n node_down_msg) {
connect();
for (int i = 0; i < 5; ++i)
earth.self->monitor(mars_id);
run();
disconnect();
for (int i = 0; i < 5; ++i)
expect_on(earth, (node_down_msg),
to(earth.self).with(node_down_msg{mars_id, error{}}));
CHECK_EQ(earth.self->mailbox().size(), 0u);
}
CAF_TEST(each demonitor only cancels one node_down_msg) {
connect();
for (int i = 0; i < 5; ++i)
earth.self->monitor(mars_id);
run();
earth.self->demonitor(mars_id);
run();
disconnect();
for (int i = 0; i < 4; ++i)
expect_on(earth, (node_down_msg),
to(earth.self).with(node_down_msg{mars_id, error{}}));
CHECK_EQ(earth.self->mailbox().size(), 0u);
}
END_FIXTURE_SCOPE()
|
