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
|
// 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 actor_registry
#include "caf/actor_registry.hpp"
#include "core-test.hpp"
#include "caf/binary_deserializer.hpp"
#include "caf/binary_serializer.hpp"
using namespace caf;
namespace {
behavior dummy() {
return {[](int i) { return i; }};
}
} // namespace
BEGIN_FIXTURE_SCOPE(test_coordinator_fixture<>)
CAF_TEST(erase) {
// CAF registers a few actors by itself.
auto baseline = sys.registry().named_actors().size();
sys.registry().put("foo", sys.spawn(dummy));
CHECK_EQ(sys.registry().named_actors().size(), baseline + 1u);
self->send(sys.registry().get<actor>("foo"), 42);
run();
expect((int), from(_).to(self).with(42));
sys.registry().erase("foo");
CHECK_EQ(sys.registry().named_actors().size(), baseline);
}
CAF_TEST(serialization roundtrips go through the registry) {
auto hdl = sys.spawn(dummy);
MESSAGE("hdl.id: " << hdl->id());
byte_buffer buf;
binary_serializer sink{sys, buf};
if (!sink.apply(hdl))
CAF_FAIL("serialization failed: " << sink.get_error());
MESSAGE("buf: " << buf);
actor hdl2;
binary_deserializer source{sys, buf};
if (!source.apply(hdl2))
CAF_FAIL("deserialization failed: " << source.get_error());
CHECK_EQ(hdl, hdl2);
anon_send_exit(hdl, exit_reason::user_shutdown);
}
END_FIXTURE_SCOPE()
|
