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
103
104
105
106
107
108
109
110
111
|
// 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.remote_group
#include "caf/config.hpp"
#include "io-test.hpp"
#include <algorithm>
#include <vector>
#include "caf/all.hpp"
#include "caf/io/all.hpp"
using namespace caf;
namespace {
class config : public caf::actor_system_config {
public:
config() {
load<caf::io::middleman>();
}
};
const uint16_t port = 8080;
const char* server = "mars";
const char* group_name = "foobar";
size_t received_messages = 0u;
behavior group_receiver(event_based_actor* self) {
self->set_default_handler(reflect_and_quit);
return {
[](ok_atom) { ++received_messages; },
};
}
// Our server is `mars` and our client is `earth`.
struct fixture : point_to_point_fixture<test_coordinator_fixture<config>> {
fixture() {
prepare_connection(mars, earth, server, port);
}
~fixture() {
for (auto& receiver : receivers)
anon_send_exit(receiver, exit_reason::user_shutdown);
}
void spawn_receivers(planet_type& planet, group grp, size_t count) {
for (size_t i = 0; i < count; ++i)
receivers.emplace_back(planet.sys.spawn_in_group(grp, group_receiver));
}
std::vector<actor> receivers;
};
} // namespace
BEGIN_FIXTURE_SCOPE(fixture)
CAF_TEST(publish_local_groups) {
loop_after_next_enqueue(mars);
CHECK_EQ(mars.sys.middleman().publish_local_groups(port), port);
}
CAF_TEST(connecting to remote group) {
MESSAGE("publish local groups on mars");
loop_after_next_enqueue(mars);
CHECK_EQ(mars.sys.middleman().publish_local_groups(port), port);
MESSAGE("call remote_group on earth");
loop_after_next_enqueue(earth);
auto grp = unbox(earth.mm.remote_group(group_name, server, port));
CAF_REQUIRE(grp != nullptr);
CHECK_EQ(grp->get()->identifier(), group_name);
}
CAF_TEST(message transmission) {
MESSAGE("spawn 5 receivers on mars");
auto mars_grp = mars.sys.groups().get_local(group_name);
spawn_receivers(mars, mars_grp, 5u);
MESSAGE("publish local groups on mars");
loop_after_next_enqueue(mars);
CHECK_EQ(mars.sys.middleman().publish_local_groups(port), port);
MESSAGE("call remote_group on earth");
loop_after_next_enqueue(earth);
auto earth_grp = unbox(earth.mm.remote_group(group_name, server, port));
MESSAGE("spawn 5 more receivers on earth");
spawn_receivers(earth, earth_grp, 5u);
exec_all();
MESSAGE("send message on mars and expect 10 handled messages total");
{
received_messages = 0u;
mars.self->send(mars_grp, ok_atom_v);
exec_all();
CHECK_EQ(received_messages, 10u);
}
MESSAGE("send message on earth and again expect 10 handled messages");
{
received_messages = 0u;
earth.self->send(earth_grp, ok_atom_v);
exec_all();
CHECK_EQ(received_messages, 10u);
}
}
END_FIXTURE_SCOPE()
|
