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
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
|
#include <arpa/inet.h>
#include <stdlib.h>
#include <string.h>
#include <netdb.h>
#include "common/Formatter.h"
#include "msg_types.h"
void entity_name_t::dump(Formatter *f) const
{
f->dump_string("type", type_str());
f->dump_unsigned("num", num());
}
void entity_addr_t::dump(Formatter *f) const
{
f->dump_unsigned("nonce", nonce);
f->dump_stream("addr") << addr;
}
void entity_name_t::generate_test_instances(list<entity_name_t*>& o)
{
o.push_back(new entity_name_t(entity_name_t::MON()));
o.push_back(new entity_name_t(entity_name_t::MON(1)));
o.push_back(new entity_name_t(entity_name_t::OSD(1)));
o.push_back(new entity_name_t(entity_name_t::CLIENT(1)));
}
void entity_addr_t::generate_test_instances(list<entity_addr_t*>& o)
{
o.push_back(new entity_addr_t());
entity_addr_t *a = new entity_addr_t();
a->set_nonce(1);
o.push_back(a);
entity_addr_t *b = new entity_addr_t();
b->set_nonce(5);
b->set_family(AF_INET);
b->set_in4_quad(0, 127);
b->set_in4_quad(0, 0);
b->set_in4_quad(0, 1);
b->set_in4_quad(0, 2);
b->set_port(2);
o.push_back(b);
}
bool entity_addr_t::parse(const char *s, const char **end)
{
memset(this, 0, sizeof(*this));
const char *start = s;
bool brackets = false;
if (*start == '[') {
start++;
brackets = true;
}
// inet_pton() requires a null terminated input, so let's fill two
// buffers, one with ipv4 allowed characters, and one with ipv6, and
// then see which parses.
char buf4[39];
char *o = buf4;
const char *p = start;
while (o < buf4 + sizeof(buf4) &&
*p && ((*p == '.') ||
(*p >= '0' && *p <= '9'))) {
*o++ = *p++;
}
*o = 0;
char buf6[64]; // actually 39 + null is sufficient.
o = buf6;
p = start;
while (o < buf6 + sizeof(buf6) &&
*p && ((*p == ':') ||
(*p >= '0' && *p <= '9') ||
(*p >= 'a' && *p <= 'f') ||
(*p >= 'A' && *p <= 'F'))) {
*o++ = *p++;
}
*o = 0;
//cout << "buf4 is '" << buf4 << "', buf6 is '" << buf6 << "'" << std::endl;
// ipv4?
struct in_addr a4;
struct in6_addr a6;
if (inet_pton(AF_INET, buf4, &a4)) {
addr4.sin_addr.s_addr = a4.s_addr;
addr.ss_family = AF_INET;
p = start + strlen(buf4);
} else if (inet_pton(AF_INET6, buf6, &a6)) {
addr.ss_family = AF_INET6;
memcpy(&addr6.sin6_addr, &a6, sizeof(a6));
p = start + strlen(buf6);
} else {
return false;
}
if (brackets) {
if (*p != ']')
return false;
p++;
}
//cout << "p is " << *p << std::endl;
if (*p == ':') {
// parse a port, too!
p++;
int port = atoi(p);
set_port(port);
while (*p && *p >= '0' && *p <= '9')
p++;
}
if (*p == '/') {
// parse nonce, too
p++;
int non = atoi(p);
set_nonce(non);
while (*p && *p >= '0' && *p <= '9')
p++;
}
if (end)
*end = p;
//cout << *this << std::endl;
return true;
}
ostream& operator<<(ostream& out, const sockaddr_storage &ss)
{
char buf[NI_MAXHOST] = { 0 };
char serv[20] = { 0 };
size_t hostlen;
if (ss.ss_family == AF_INET)
hostlen = sizeof(struct sockaddr_in);
else if (ss.ss_family == AF_INET6)
hostlen = sizeof(struct sockaddr_in6);
else
hostlen = sizeof(struct sockaddr_storage);
getnameinfo((struct sockaddr *)&ss, hostlen, buf, sizeof(buf),
serv, sizeof(serv),
NI_NUMERICHOST | NI_NUMERICSERV);
if (ss.ss_family == AF_INET6)
return out << '[' << buf << "]:" << serv;
return out //<< ss.ss_family << ":"
<< buf << ':' << serv;
}
|
