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
|
// Copyright 2013 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "net/dns/mdns_client.h"
#include "net/base/net_errors.h"
#include "net/dns/dns_protocol.h"
#include "net/dns/mdns_client_impl.h"
namespace net {
namespace {
const char kMDnsMulticastGroupIPv4[] = "224.0.0.251";
const char kMDnsMulticastGroupIPv6[] = "FF02::FB";
IPEndPoint GetMDnsIPEndPoint(const char* address) {
IPAddressNumber multicast_group_number;
bool success = ParseIPLiteralToNumber(address,
&multicast_group_number);
DCHECK(success);
return IPEndPoint(multicast_group_number,
dns_protocol::kDefaultPortMulticast);
}
int Bind(const IPEndPoint& multicast_addr,
uint32 interface_index,
DatagramServerSocket* socket) {
IPAddressNumber address_any(multicast_addr.address().size());
IPEndPoint bind_endpoint(address_any, multicast_addr.port());
socket->AllowAddressReuse();
socket->SetMulticastInterface(interface_index);
int rv = socket->Listen(bind_endpoint);
if (rv < OK)
return rv;
return socket->JoinGroup(multicast_addr.address());
}
} // namespace
// static
scoped_ptr<MDnsSocketFactory> MDnsSocketFactory::CreateDefault() {
return scoped_ptr<MDnsSocketFactory>(new MDnsSocketFactoryImpl);
}
// static
scoped_ptr<MDnsClient> MDnsClient::CreateDefault() {
return scoped_ptr<MDnsClient>(new MDnsClientImpl());
}
IPEndPoint GetMDnsIPEndPoint(AddressFamily address_family) {
switch (address_family) {
case ADDRESS_FAMILY_IPV4:
return GetMDnsIPEndPoint(kMDnsMulticastGroupIPv4);
case ADDRESS_FAMILY_IPV6:
return GetMDnsIPEndPoint(kMDnsMulticastGroupIPv6);
default:
NOTREACHED();
return IPEndPoint();
}
}
InterfaceIndexFamilyList GetMDnsInterfacesToBind() {
NetworkInterfaceList network_list;
InterfaceIndexFamilyList interfaces;
if (!GetNetworkList(&network_list))
return interfaces;
for (size_t i = 0; i < network_list.size(); ++i) {
AddressFamily family = GetAddressFamily(network_list[i].address);
if (family == ADDRESS_FAMILY_IPV4 || family == ADDRESS_FAMILY_IPV6) {
interfaces.push_back(
std::make_pair(network_list[i].interface_index, family));
}
}
std::sort(interfaces.begin(), interfaces.end());
// Interfaces could have multiple addresses. Filter out duplicate entries.
interfaces.erase(std::unique(interfaces.begin(), interfaces.end()),
interfaces.end());
return interfaces;
}
scoped_ptr<DatagramServerSocket> CreateAndBindMDnsSocket(
AddressFamily address_family,
uint32 interface_index) {
scoped_ptr<DatagramServerSocket> socket(
new UDPServerSocket(NULL, NetLog::Source()));
IPEndPoint multicast_addr = GetMDnsIPEndPoint(address_family);
int rv = Bind(multicast_addr, interface_index, socket.get());
if (rv != OK) {
socket.reset();
VLOG(1) << "Bind failed, endpoint=" << multicast_addr.ToStringWithoutPort()
<< ", error=" << rv;
}
return socket.PassAs<DatagramServerSocket>();
}
} // namespace net
|
