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
|
// 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 node_id
#include "caf/node_id.hpp"
#include "core-test.hpp"
#include "caf/binary_deserializer.hpp"
#include "caf/binary_serializer.hpp"
using namespace caf;
namespace {
node_id roundtrip(node_id nid) {
byte_buffer buf;
{
binary_serializer sink{nullptr, buf};
if (!sink.apply(nid))
CAF_FAIL("serialization failed: " << sink.get_error());
}
if (buf.empty())
CAF_FAIL("serializer produced no output");
node_id result;
{
binary_deserializer source{nullptr, buf};
if (!source.apply(result))
CAF_FAIL("deserialization failed: " << source.get_error());
if (source.remaining() > 0)
CAF_FAIL("binary_serializer ignored part of its input");
}
return result;
}
} // namespace
#define CHECK_PARSE_OK(str, ...) \
do { \
CHECK(node_id::can_parse(str)); \
node_id nid; \
CHECK_EQ(parse(str, nid), none); \
CHECK_EQ(nid, make_node_id(__VA_ARGS__)); \
} while (false)
CAF_TEST(node IDs are convertible from string) {
node_id::default_data::host_id_type hash{{
1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20,
}};
auto uri_id = unbox(make_uri("ip://foo:8080"));
CHECK_PARSE_OK("0102030405060708090A0B0C0D0E0F1011121314#1", 1, hash);
CHECK_PARSE_OK("0102030405060708090A0B0C0D0E0F1011121314#123", 123, hash);
CHECK_PARSE_OK("ip://foo:8080", uri_id);
}
#define CHECK_PARSE_FAIL(str) CHECK(!node_id::can_parse(str))
CAF_TEST(node IDs reject malformed strings) {
// not URIs
CHECK_PARSE_FAIL("foobar");
CHECK_PARSE_FAIL("CAF#1");
// uint32_t overflow on the process ID
CHECK_PARSE_FAIL("0102030405060708090A0B0C0D0E0F1011121314#42949672950");
}
CAF_TEST(node IDs are serializable) {
MESSAGE("empty node IDs remain empty");
{
node_id nil_id;
CHECK_EQ(nil_id, roundtrip(nil_id));
}
MESSAGE("hash-based node IDs remain intact");
{
auto tmp = make_node_id(42, "0102030405060708090A0B0C0D0E0F1011121314");
auto hash_based_id = unbox(tmp);
CHECK_EQ(hash_based_id, roundtrip(hash_based_id));
}
MESSAGE("URI-based node IDs remain intact");
{
auto uri_based_id = make_node_id(unbox(make_uri("foo:bar")));
CHECK_EQ(uri_based_id, roundtrip(uri_based_id));
}
}
|
