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
112
113
114
115
116
117
118
119
|
// 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 ipv4_endpoint
#include "caf/ipv4_endpoint.hpp"
#include "core-test.hpp"
#include <cassert>
#include <vector>
#include "caf/actor_system.hpp"
#include "caf/actor_system_config.hpp"
#include "caf/binary_deserializer.hpp"
#include "caf/binary_serializer.hpp"
#include "caf/byte.hpp"
#include "caf/byte_buffer.hpp"
#include "caf/detail/parse.hpp"
#include "caf/ipv4_address.hpp"
#include "caf/span.hpp"
using namespace caf;
namespace {
ipv4_endpoint operator"" _ep(const char* str, size_t size) {
ipv4_endpoint result;
if (auto err = detail::parse(string_view{str, size}, result))
CAF_FAIL("unable to parse input: " << err);
return result;
}
struct fixture {
actor_system_config cfg;
actor_system sys{cfg};
template <class T>
T roundtrip(T x) {
byte_buffer buf;
binary_serializer sink(sys, buf);
if (!sink.apply(x))
CAF_FAIL("serialization failed: " << sink.get_error());
binary_deserializer source(sys, make_span(buf));
T y;
if (!source.apply(y))
CAF_FAIL("deserialization failed: " << source.get_error());
return y;
}
};
#define CHECK_TO_STRING(addr) CHECK_EQ(addr, to_string(addr##_ep))
#define CHECK_COMPARISON(addr1, addr2) \
CHECK_GT(addr2##_ep, addr1##_ep); \
CHECK_GE(addr2##_ep, addr1##_ep); \
CHECK_GE(addr1##_ep, addr1##_ep); \
CHECK_GE(addr2##_ep, addr2##_ep); \
CHECK_EQ(addr1##_ep, addr1##_ep); \
CHECK_EQ(addr2##_ep, addr2##_ep); \
CHECK_LE(addr1##_ep, addr2##_ep); \
CHECK_LE(addr1##_ep, addr1##_ep); \
CHECK_LE(addr2##_ep, addr2##_ep); \
CHECK_NE(addr1##_ep, addr2##_ep); \
CHECK_NE(addr2##_ep, addr1##_ep);
#define CHECK_SERIALIZATION(addr) CHECK_EQ(addr##_ep, roundtrip(addr##_ep))
} // namespace
BEGIN_FIXTURE_SCOPE(fixture)
CAF_TEST(constructing assigning and hash_code) {
const uint16_t port = 8888;
auto addr = make_ipv4_address(127, 0, 0, 1);
ipv4_endpoint ep1(addr, port);
CHECK_EQ(ep1.address(), addr);
CHECK_EQ(ep1.port(), port);
ipv4_endpoint ep2;
ep2.address(addr);
ep2.port(port);
CHECK_EQ(ep2.address(), addr);
CHECK_EQ(ep2.port(), port);
CHECK_EQ(ep1, ep2);
CHECK_EQ(ep1.hash_code(), ep2.hash_code());
}
CAF_TEST(to string) {
CHECK_TO_STRING("127.0.0.1:8888");
CHECK_TO_STRING("192.168.178.1:8888");
CHECK_TO_STRING("255.255.255.1:17");
CHECK_TO_STRING("192.168.178.1:8888");
CHECK_TO_STRING("127.0.0.1:111");
CHECK_TO_STRING("123.123.123.123:8888");
CHECK_TO_STRING("127.0.0.1:8888");
}
CAF_TEST(comparison) {
CHECK_COMPARISON("127.0.0.1:8888", "127.0.0.2:8888");
CHECK_COMPARISON("192.168.178.1:8888", "245.114.2.89:8888");
CHECK_COMPARISON("188.56.23.97:1211", "189.22.36.0:1211");
CHECK_COMPARISON("0.0.0.0:8888", "255.255.255.1:8888");
CHECK_COMPARISON("127.0.0.1:111", "127.0.0.1:8888");
CHECK_COMPARISON("192.168.178.1:8888", "245.114.2.89:8888");
CHECK_COMPARISON("123.123.123.123:8888", "123.123.123.123:8889");
}
CAF_TEST(serialization) {
CHECK_SERIALIZATION("127.0.0.1:8888");
CHECK_SERIALIZATION("192.168.178.1:8888");
CHECK_SERIALIZATION("255.255.255.1:17");
CHECK_SERIALIZATION("192.168.178.1:8888");
CHECK_SERIALIZATION("127.0.0.1:111");
CHECK_SERIALIZATION("123.123.123.123:8888");
CHECK_SERIALIZATION("127.0.0.1:8888");
}
END_FIXTURE_SCOPE()
|
