blob: 32b2a91844ab1b2f97ae6b771e4783340f66c9db [file] [log] [blame]
henrike@webrtc.orgf0488722014-05-13 18:00:26 +00001/*
2 * Copyright 2004 The WebRTC Project Authors. All rights reserved.
3 *
4 * Use of this source code is governed by a BSD-style license
5 * that can be found in the LICENSE file in the root of the source
6 * tree. An additional intellectual property rights grant can be found
7 * in the file PATENTS. All contributing project authors may
8 * be found in the AUTHORS file in the root of the source tree.
9 */
10
11#ifdef HAVE_CONFIG_H
12#include "config.h"
13#endif
14
15#include "webrtc/base/network.h"
16
17#if defined(WEBRTC_POSIX)
18// linux/if.h can't be included at the same time as the posix sys/if.h, and
19// it's transitively required by linux/route.h, so include that version on
20// linux instead of the standard posix one.
21#if defined(WEBRTC_LINUX)
22#include <linux/if.h>
23#include <linux/route.h>
24#elif !defined(__native_client__)
25#include <net/if.h>
26#endif
27#include <sys/socket.h>
28#include <sys/utsname.h>
29#include <sys/ioctl.h>
30#include <unistd.h>
31#include <errno.h>
32
33#if defined(WEBRTC_ANDROID)
34#include "webrtc/base/ifaddrs-android.h"
35#elif !defined(__native_client__)
36#include <ifaddrs.h>
37#endif
38
39#endif // WEBRTC_POSIX
40
41#if defined(WEBRTC_WIN)
42#include "webrtc/base/win32.h"
43#include <Iphlpapi.h>
44#endif
45
46#include <stdio.h>
47
48#include <algorithm>
49
50#include "webrtc/base/logging.h"
honghaiz023f3ef2015-10-19 09:39:32 -070051#include "webrtc/base/networkmonitor.h"
henrike@webrtc.orgf0488722014-05-13 18:00:26 +000052#include "webrtc/base/scoped_ptr.h"
53#include "webrtc/base/socket.h" // includes something that makes windows happy
54#include "webrtc/base/stream.h"
55#include "webrtc/base/stringencode.h"
56#include "webrtc/base/thread.h"
57
58namespace rtc {
59namespace {
60
guoweis@webrtc.org2444d962015-01-30 00:09:28 +000061// Turning on IPv6 could make many IPv6 interfaces available for connectivity
62// check and delay the call setup time. kMaxIPv6Networks is the default upper
63// limit of IPv6 networks but could be changed by set_max_ipv6_networks().
64const int kMaxIPv6Networks = 5;
65
Peter Boström0c4e06b2015-10-07 12:23:21 +020066const uint32_t kUpdateNetworksMessage = 1;
67const uint32_t kSignalNetworksMessage = 2;
henrike@webrtc.orgf0488722014-05-13 18:00:26 +000068
69// Fetch list of networks every two seconds.
70const int kNetworksUpdateIntervalMs = 2000;
71
72const int kHighestNetworkPreference = 127;
73
guoweis@webrtc.org4bbd3c82014-09-09 13:54:45 +000074typedef struct {
75 Network* net;
guoweis@webrtc.orgfa603982014-09-09 23:42:40 +000076 std::vector<InterfaceAddress> ips;
guoweis@webrtc.org4bbd3c82014-09-09 13:54:45 +000077} AddressList;
78
henrike@webrtc.orgf0488722014-05-13 18:00:26 +000079bool CompareNetworks(const Network* a, const Network* b) {
80 if (a->prefix_length() == b->prefix_length()) {
81 if (a->name() == b->name()) {
82 return a->prefix() < b->prefix();
83 }
84 }
85 return a->name() < b->name();
86}
87
88bool SortNetworks(const Network* a, const Network* b) {
89 // Network types will be preferred above everything else while sorting
90 // Networks.
91
92 // Networks are sorted first by type.
93 if (a->type() != b->type()) {
94 return a->type() < b->type();
95 }
96
guoweis@webrtc.org369a6372014-09-17 22:37:29 +000097 IPAddress ip_a = a->GetBestIP();
98 IPAddress ip_b = b->GetBestIP();
99
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000100 // After type, networks are sorted by IP address precedence values
101 // from RFC 3484-bis
guoweis@webrtc.org369a6372014-09-17 22:37:29 +0000102 if (IPAddressPrecedence(ip_a) != IPAddressPrecedence(ip_b)) {
103 return IPAddressPrecedence(ip_a) > IPAddressPrecedence(ip_b);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000104 }
105
106 // TODO(mallinath) - Add VPN and Link speed conditions while sorting.
107
108 // Networks are sorted last by key.
109 return a->key() > b->key();
110}
111
112std::string AdapterTypeToString(AdapterType type) {
113 switch (type) {
114 case ADAPTER_TYPE_UNKNOWN:
115 return "Unknown";
116 case ADAPTER_TYPE_ETHERNET:
117 return "Ethernet";
118 case ADAPTER_TYPE_WIFI:
119 return "Wifi";
120 case ADAPTER_TYPE_CELLULAR:
121 return "Cellular";
122 case ADAPTER_TYPE_VPN:
123 return "VPN";
phoglund@webrtc.org006521d2015-02-12 09:23:59 +0000124 case ADAPTER_TYPE_LOOPBACK:
125 return "Loopback";
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000126 default:
henrikg91d6ede2015-09-17 00:24:34 -0700127 RTC_DCHECK(false) << "Invalid type " << type;
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000128 return std::string();
129 }
130}
131
guoweis@webrtc.orgb91d0f52015-03-17 14:43:20 +0000132bool IsIgnoredIPv6(const IPAddress& ip) {
133 if (ip.family() != AF_INET6) {
134 return false;
135 }
136
137 // Link-local addresses require scope id to be bound successfully.
138 // However, our IPAddress structure doesn't carry that so the
139 // information is lost and causes binding failure.
140 if (IPIsLinkLocal(ip)) {
141 return true;
142 }
143
144 // Any MAC based IPv6 should be avoided to prevent the MAC tracking.
145 if (IPIsMacBased(ip)) {
146 return true;
147 }
148
149 return false;
150}
151
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000152} // namespace
153
154std::string MakeNetworkKey(const std::string& name, const IPAddress& prefix,
155 int prefix_length) {
156 std::ostringstream ost;
157 ost << name << "%" << prefix.ToString() << "/" << prefix_length;
158 return ost.str();
159}
160
161NetworkManager::NetworkManager() {
162}
163
164NetworkManager::~NetworkManager() {
165}
166
Guo-wei Shieh86cb9232015-08-19 10:57:53 -0700167NetworkManager::EnumerationPermission NetworkManager::enumeration_permission()
168 const {
guoweisea1012b2015-08-21 09:06:28 -0700169 return ENUMERATION_ALLOWED;
Guo-wei Shieh86cb9232015-08-19 10:57:53 -0700170}
171
guoweis@webrtc.org2444d962015-01-30 00:09:28 +0000172NetworkManagerBase::NetworkManagerBase()
guoweisea1012b2015-08-21 09:06:28 -0700173 : enumeration_permission_(NetworkManager::ENUMERATION_ALLOWED),
Guo-wei Shieh47872ec2015-08-19 10:32:46 -0700174 max_ipv6_networks_(kMaxIPv6Networks),
175 ipv6_enabled_(true) {
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000176}
177
178NetworkManagerBase::~NetworkManagerBase() {
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000179 for (const auto& kv : networks_map_) {
180 delete kv.second;
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000181 }
182}
183
Guo-wei Shieh47872ec2015-08-19 10:32:46 -0700184NetworkManager::EnumerationPermission
185NetworkManagerBase::enumeration_permission() const {
186 return enumeration_permission_;
187}
188
guoweis@webrtc.orgf358aea2015-02-18 18:44:01 +0000189void NetworkManagerBase::GetAnyAddressNetworks(NetworkList* networks) {
190 if (!ipv4_any_address_network_) {
191 const rtc::IPAddress ipv4_any_address(INADDR_ANY);
192 ipv4_any_address_network_.reset(
193 new rtc::Network("any", "any", ipv4_any_address, 0));
194 ipv4_any_address_network_->AddIP(ipv4_any_address);
195 }
196 networks->push_back(ipv4_any_address_network_.get());
197
198 if (ipv6_enabled()) {
199 if (!ipv6_any_address_network_) {
200 const rtc::IPAddress ipv6_any_address(in6addr_any);
201 ipv6_any_address_network_.reset(
202 new rtc::Network("any", "any", ipv6_any_address, 0));
203 ipv6_any_address_network_->AddIP(ipv6_any_address);
204 }
205 networks->push_back(ipv6_any_address_network_.get());
206 }
207}
208
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000209void NetworkManagerBase::GetNetworks(NetworkList* result) const {
guoweis@webrtc.org2444d962015-01-30 00:09:28 +0000210 int ipv6_networks = 0;
211 result->clear();
212 for (Network* network : networks_) {
213 // Keep the number of IPv6 networks under |max_ipv6_networks_|.
214 if (network->prefix().family() == AF_INET6) {
215 if (ipv6_networks >= max_ipv6_networks_) {
216 continue;
217 }
218 ++ipv6_networks;
219 }
220 result->push_back(network);
221 }
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000222}
223
224void NetworkManagerBase::MergeNetworkList(const NetworkList& new_networks,
225 bool* changed) {
guoweis@webrtc.orga094cac2015-01-28 19:34:05 +0000226 NetworkManager::Stats stats;
227 MergeNetworkList(new_networks, changed, &stats);
228}
229
230void NetworkManagerBase::MergeNetworkList(const NetworkList& new_networks,
231 bool* changed,
232 NetworkManager::Stats* stats) {
guoweis@webrtc.org4bbd3c82014-09-09 13:54:45 +0000233 // AddressList in this map will track IP addresses for all Networks
234 // with the same key.
235 std::map<std::string, AddressList> consolidated_address_list;
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000236 NetworkList list(new_networks);
guoweis@webrtc.org4bbd3c82014-09-09 13:54:45 +0000237
238 // Result of Network merge. Element in this list should have unique key.
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000239 NetworkList merged_list;
240 std::sort(list.begin(), list.end(), CompareNetworks);
241
242 *changed = false;
243
244 if (networks_.size() != list.size())
245 *changed = true;
246
247 // First, build a set of network-keys to the ipaddresses.
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000248 for (Network* network : list) {
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000249 bool might_add_to_merged_list = false;
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000250 std::string key = MakeNetworkKey(network->name(),
251 network->prefix(),
252 network->prefix_length());
guoweis@webrtc.org4bbd3c82014-09-09 13:54:45 +0000253 if (consolidated_address_list.find(key) ==
254 consolidated_address_list.end()) {
255 AddressList addrlist;
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000256 addrlist.net = network;
guoweis@webrtc.org4bbd3c82014-09-09 13:54:45 +0000257 consolidated_address_list[key] = addrlist;
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000258 might_add_to_merged_list = true;
259 }
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000260 const std::vector<InterfaceAddress>& addresses = network->GetIPs();
guoweis@webrtc.org4bbd3c82014-09-09 13:54:45 +0000261 AddressList& current_list = consolidated_address_list[key];
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000262 for (const InterfaceAddress& address : addresses) {
263 current_list.ips.push_back(address);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000264 }
265 if (!might_add_to_merged_list) {
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000266 delete network;
guoweis@webrtc.orga094cac2015-01-28 19:34:05 +0000267 } else {
268 if (current_list.ips[0].family() == AF_INET) {
269 stats->ipv4_network_count++;
270 } else {
271 ASSERT(current_list.ips[0].family() == AF_INET6);
272 stats->ipv6_network_count++;
273 }
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000274 }
275 }
276
277 // Next, look for existing network objects to re-use.
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000278 for (const auto& kv : consolidated_address_list) {
279 const std::string& key = kv.first;
280 Network* net = kv.second.net;
281 auto existing = networks_map_.find(key);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000282 if (existing == networks_map_.end()) {
283 // This network is new. Place it in the network map.
284 merged_list.push_back(net);
285 networks_map_[key] = net;
guoweis@webrtc.org4bbd3c82014-09-09 13:54:45 +0000286 // Also, we might have accumulated IPAddresses from the first
287 // step, set it here.
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000288 net->SetIPs(kv.second.ips, true);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000289 *changed = true;
290 } else {
291 // This network exists in the map already. Reset its IP addresses.
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000292 *changed = existing->second->SetIPs(kv.second.ips, *changed);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000293 merged_list.push_back(existing->second);
294 if (existing->second != net) {
295 delete net;
296 }
297 }
298 }
299 networks_ = merged_list;
300
301 // If the network lists changes, we resort it.
guoweis@webrtc.orga094cac2015-01-28 19:34:05 +0000302 if (*changed) {
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000303 std::sort(networks_.begin(), networks_.end(), SortNetworks);
304 // Now network interfaces are sorted, we should set the preference value
305 // for each of the interfaces we are planning to use.
306 // Preference order of network interfaces might have changed from previous
307 // sorting due to addition of higher preference network interface.
308 // Since we have already sorted the network interfaces based on our
309 // requirements, we will just assign a preference value starting with 127,
310 // in decreasing order.
311 int pref = kHighestNetworkPreference;
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000312 for (Network* network : networks_) {
313 network->set_preference(pref);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000314 if (pref > 0) {
315 --pref;
316 } else {
317 LOG(LS_ERROR) << "Too many network interfaces to handle!";
318 break;
319 }
320 }
321 }
322}
323
324BasicNetworkManager::BasicNetworkManager()
325 : thread_(NULL), sent_first_update_(false), start_count_(0),
phoglund@webrtc.org006521d2015-02-12 09:23:59 +0000326 network_ignore_mask_(kDefaultNetworkIgnoreMask),
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000327 ignore_non_default_routes_(false) {
328}
329
330BasicNetworkManager::~BasicNetworkManager() {
331}
332
honghaiz023f3ef2015-10-19 09:39:32 -0700333void BasicNetworkManager::OnNetworksChanged() {
334 LOG(LS_VERBOSE) << "Network change was observed at the network manager";
335 UpdateNetworksOnce();
336}
337
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000338#if defined(__native_client__)
339
340bool BasicNetworkManager::CreateNetworks(bool include_ignored,
341 NetworkList* networks) const {
342 ASSERT(false);
343 LOG(LS_WARNING) << "BasicNetworkManager doesn't work on NaCl yet";
344 return false;
345}
346
347#elif defined(WEBRTC_POSIX)
348void BasicNetworkManager::ConvertIfAddrs(struct ifaddrs* interfaces,
349 bool include_ignored,
350 NetworkList* networks) const {
351 NetworkMap current_networks;
352 for (struct ifaddrs* cursor = interfaces;
353 cursor != NULL; cursor = cursor->ifa_next) {
354 IPAddress prefix;
355 IPAddress mask;
356 IPAddress ip;
357 int scope_id = 0;
358
359 // Some interfaces may not have address assigned.
360 if (!cursor->ifa_addr || !cursor->ifa_netmask)
361 continue;
362
363 switch (cursor->ifa_addr->sa_family) {
364 case AF_INET: {
365 ip = IPAddress(
366 reinterpret_cast<sockaddr_in*>(cursor->ifa_addr)->sin_addr);
367 mask = IPAddress(
368 reinterpret_cast<sockaddr_in*>(cursor->ifa_netmask)->sin_addr);
369 break;
370 }
371 case AF_INET6: {
372 if (ipv6_enabled()) {
373 ip = IPAddress(
374 reinterpret_cast<sockaddr_in6*>(cursor->ifa_addr)->sin6_addr);
guoweis@webrtc.orgb91d0f52015-03-17 14:43:20 +0000375
376 if (IsIgnoredIPv6(ip)) {
377 continue;
378 }
379
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000380 mask = IPAddress(
381 reinterpret_cast<sockaddr_in6*>(cursor->ifa_netmask)->sin6_addr);
382 scope_id =
383 reinterpret_cast<sockaddr_in6*>(cursor->ifa_addr)->sin6_scope_id;
384 break;
385 } else {
386 continue;
387 }
388 }
389 default: {
390 continue;
391 }
392 }
393
394 int prefix_length = CountIPMaskBits(mask);
395 prefix = TruncateIP(ip, prefix_length);
396 std::string key = MakeNetworkKey(std::string(cursor->ifa_name),
397 prefix, prefix_length);
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000398 auto existing_network = current_networks.find(key);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000399 if (existing_network == current_networks.end()) {
phoglund@webrtc.org006521d2015-02-12 09:23:59 +0000400 AdapterType adapter_type = ADAPTER_TYPE_UNKNOWN;
401 if (cursor->ifa_flags & IFF_LOOPBACK) {
phoglund@webrtc.org006521d2015-02-12 09:23:59 +0000402 adapter_type = ADAPTER_TYPE_LOOPBACK;
403 }
Noah Richards2e266e92015-04-07 11:51:56 -0700404#if defined(WEBRTC_IOS)
405 // Cell networks are pdp_ipN on iOS.
406 if (strncmp(cursor->ifa_name, "pdp_ip", 6) == 0) {
407 adapter_type = ADAPTER_TYPE_CELLULAR;
408 }
409#endif
410 // TODO(phoglund): Need to recognize other types as well.
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000411 scoped_ptr<Network> network(new Network(cursor->ifa_name,
412 cursor->ifa_name,
413 prefix,
phoglund@webrtc.org006521d2015-02-12 09:23:59 +0000414 prefix_length,
415 adapter_type));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000416 network->set_scope_id(scope_id);
417 network->AddIP(ip);
phoglund@webrtc.org006521d2015-02-12 09:23:59 +0000418 network->set_ignored(IsIgnoredNetwork(*network));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000419 if (include_ignored || !network->ignored()) {
420 networks->push_back(network.release());
421 }
422 } else {
423 (*existing_network).second->AddIP(ip);
424 }
425 }
426}
427
428bool BasicNetworkManager::CreateNetworks(bool include_ignored,
429 NetworkList* networks) const {
430 struct ifaddrs* interfaces;
431 int error = getifaddrs(&interfaces);
432 if (error != 0) {
433 LOG_ERR(LERROR) << "getifaddrs failed to gather interface data: " << error;
434 return false;
435 }
436
437 ConvertIfAddrs(interfaces, include_ignored, networks);
438
439 freeifaddrs(interfaces);
440 return true;
441}
442
443#elif defined(WEBRTC_WIN)
444
445unsigned int GetPrefix(PIP_ADAPTER_PREFIX prefixlist,
446 const IPAddress& ip, IPAddress* prefix) {
447 IPAddress current_prefix;
448 IPAddress best_prefix;
449 unsigned int best_length = 0;
450 while (prefixlist) {
451 // Look for the longest matching prefix in the prefixlist.
452 if (prefixlist->Address.lpSockaddr == NULL ||
453 prefixlist->Address.lpSockaddr->sa_family != ip.family()) {
454 prefixlist = prefixlist->Next;
455 continue;
456 }
457 switch (prefixlist->Address.lpSockaddr->sa_family) {
458 case AF_INET: {
459 sockaddr_in* v4_addr =
460 reinterpret_cast<sockaddr_in*>(prefixlist->Address.lpSockaddr);
461 current_prefix = IPAddress(v4_addr->sin_addr);
462 break;
463 }
464 case AF_INET6: {
465 sockaddr_in6* v6_addr =
466 reinterpret_cast<sockaddr_in6*>(prefixlist->Address.lpSockaddr);
467 current_prefix = IPAddress(v6_addr->sin6_addr);
468 break;
469 }
470 default: {
471 prefixlist = prefixlist->Next;
472 continue;
473 }
474 }
475 if (TruncateIP(ip, prefixlist->PrefixLength) == current_prefix &&
476 prefixlist->PrefixLength > best_length) {
477 best_prefix = current_prefix;
478 best_length = prefixlist->PrefixLength;
479 }
480 prefixlist = prefixlist->Next;
481 }
482 *prefix = best_prefix;
483 return best_length;
484}
485
486bool BasicNetworkManager::CreateNetworks(bool include_ignored,
487 NetworkList* networks) const {
488 NetworkMap current_networks;
489 // MSDN recommends a 15KB buffer for the first try at GetAdaptersAddresses.
490 size_t buffer_size = 16384;
491 scoped_ptr<char[]> adapter_info(new char[buffer_size]);
492 PIP_ADAPTER_ADDRESSES adapter_addrs =
493 reinterpret_cast<PIP_ADAPTER_ADDRESSES>(adapter_info.get());
494 int adapter_flags = (GAA_FLAG_SKIP_DNS_SERVER | GAA_FLAG_SKIP_ANYCAST |
495 GAA_FLAG_SKIP_MULTICAST | GAA_FLAG_INCLUDE_PREFIX);
496 int ret = 0;
497 do {
498 adapter_info.reset(new char[buffer_size]);
499 adapter_addrs = reinterpret_cast<PIP_ADAPTER_ADDRESSES>(adapter_info.get());
500 ret = GetAdaptersAddresses(AF_UNSPEC, adapter_flags,
501 0, adapter_addrs,
502 reinterpret_cast<PULONG>(&buffer_size));
503 } while (ret == ERROR_BUFFER_OVERFLOW);
504 if (ret != ERROR_SUCCESS) {
505 return false;
506 }
507 int count = 0;
508 while (adapter_addrs) {
509 if (adapter_addrs->OperStatus == IfOperStatusUp) {
510 PIP_ADAPTER_UNICAST_ADDRESS address = adapter_addrs->FirstUnicastAddress;
511 PIP_ADAPTER_PREFIX prefixlist = adapter_addrs->FirstPrefix;
512 std::string name;
513 std::string description;
tfarinaa41ab932015-10-30 16:08:48 -0700514#if !defined(NDEBUG)
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000515 name = ToUtf8(adapter_addrs->FriendlyName,
516 wcslen(adapter_addrs->FriendlyName));
517#endif
518 description = ToUtf8(adapter_addrs->Description,
519 wcslen(adapter_addrs->Description));
520 for (; address; address = address->Next) {
tfarinaa41ab932015-10-30 16:08:48 -0700521#if defined(NDEBUG)
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000522 name = rtc::ToString(count);
523#endif
524
525 IPAddress ip;
526 int scope_id = 0;
527 scoped_ptr<Network> network;
528 switch (address->Address.lpSockaddr->sa_family) {
529 case AF_INET: {
530 sockaddr_in* v4_addr =
531 reinterpret_cast<sockaddr_in*>(address->Address.lpSockaddr);
532 ip = IPAddress(v4_addr->sin_addr);
533 break;
534 }
535 case AF_INET6: {
536 if (ipv6_enabled()) {
537 sockaddr_in6* v6_addr =
538 reinterpret_cast<sockaddr_in6*>(address->Address.lpSockaddr);
539 scope_id = v6_addr->sin6_scope_id;
540 ip = IPAddress(v6_addr->sin6_addr);
guoweis@webrtc.orgb91d0f52015-03-17 14:43:20 +0000541
542 if (IsIgnoredIPv6(ip)) {
543 continue;
544 }
545
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000546 break;
547 } else {
548 continue;
549 }
550 }
551 default: {
552 continue;
553 }
554 }
555
556 IPAddress prefix;
557 int prefix_length = GetPrefix(prefixlist, ip, &prefix);
558 std::string key = MakeNetworkKey(name, prefix, prefix_length);
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000559 auto existing_network = current_networks.find(key);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000560 if (existing_network == current_networks.end()) {
phoglund@webrtc.org006521d2015-02-12 09:23:59 +0000561 AdapterType adapter_type = ADAPTER_TYPE_UNKNOWN;
562 if (adapter_addrs->IfType == IF_TYPE_SOFTWARE_LOOPBACK) {
563 // TODO(phoglund): Need to recognize other types as well.
564 adapter_type = ADAPTER_TYPE_LOOPBACK;
565 }
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000566 scoped_ptr<Network> network(new Network(name,
567 description,
568 prefix,
phoglund@webrtc.org006521d2015-02-12 09:23:59 +0000569 prefix_length,
570 adapter_type));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000571 network->set_scope_id(scope_id);
572 network->AddIP(ip);
phoglund@webrtc.org006521d2015-02-12 09:23:59 +0000573 bool ignored = IsIgnoredNetwork(*network);
574 network->set_ignored(ignored);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000575 if (include_ignored || !network->ignored()) {
576 networks->push_back(network.release());
577 }
578 } else {
579 (*existing_network).second->AddIP(ip);
580 }
581 }
582 // Count is per-adapter - all 'Networks' created from the same
583 // adapter need to have the same name.
584 ++count;
585 }
586 adapter_addrs = adapter_addrs->Next;
587 }
588 return true;
589}
guoweis@webrtc.org369a6372014-09-17 22:37:29 +0000590#endif // WEBRTC_WIN
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000591
592#if defined(WEBRTC_LINUX)
593bool IsDefaultRoute(const std::string& network_name) {
594 FileStream fs;
595 if (!fs.Open("/proc/net/route", "r", NULL)) {
596 LOG(LS_WARNING) << "Couldn't read /proc/net/route, skipping default "
597 << "route check (assuming everything is a default route).";
598 return true;
599 } else {
600 std::string line;
601 while (fs.ReadLine(&line) == SR_SUCCESS) {
602 char iface_name[256];
603 unsigned int iface_ip, iface_gw, iface_mask, iface_flags;
604 if (sscanf(line.c_str(),
605 "%255s %8X %8X %4X %*d %*u %*d %8X",
606 iface_name, &iface_ip, &iface_gw,
607 &iface_flags, &iface_mask) == 5 &&
608 network_name == iface_name &&
609 iface_mask == 0 &&
610 (iface_flags & (RTF_UP | RTF_HOST)) == RTF_UP) {
611 return true;
612 }
613 }
614 }
615 return false;
616}
617#endif
618
619bool BasicNetworkManager::IsIgnoredNetwork(const Network& network) const {
620 // Ignore networks on the explicit ignore list.
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000621 for (const std::string& ignored_name : network_ignore_list_) {
622 if (network.name() == ignored_name) {
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000623 return true;
624 }
625 }
phoglund@webrtc.org006521d2015-02-12 09:23:59 +0000626
627 if (network_ignore_mask_ & network.type()) {
628 return true;
629 }
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000630#if defined(WEBRTC_POSIX)
pthatcher@webrtc.orgdfef0282015-01-07 17:20:52 +0000631 // Filter out VMware/VirtualBox interfaces, typically named vmnet1,
632 // vmnet8, or vboxnet0.
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000633 if (strncmp(network.name().c_str(), "vmnet", 5) == 0 ||
pthatcher@webrtc.orgdfef0282015-01-07 17:20:52 +0000634 strncmp(network.name().c_str(), "vnic", 4) == 0 ||
635 strncmp(network.name().c_str(), "vboxnet", 7) == 0) {
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000636 return true;
637 }
638#if defined(WEBRTC_LINUX)
639 // Make sure this is a default route, if we're ignoring non-defaults.
640 if (ignore_non_default_routes_ && !IsDefaultRoute(network.name())) {
641 return true;
642 }
643#endif
644#elif defined(WEBRTC_WIN)
645 // Ignore any HOST side vmware adapters with a description like:
646 // VMware Virtual Ethernet Adapter for VMnet1
647 // but don't ignore any GUEST side adapters with a description like:
648 // VMware Accelerated AMD PCNet Adapter #2
649 if (strstr(network.description().c_str(), "VMnet") != NULL) {
650 return true;
651 }
652#endif
653
654 // Ignore any networks with a 0.x.y.z IP
655 if (network.prefix().family() == AF_INET) {
656 return (network.prefix().v4AddressAsHostOrderInteger() < 0x01000000);
657 }
guoweis@webrtc.orgbbce5ef2015-03-05 04:38:29 +0000658
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000659 return false;
660}
661
662void BasicNetworkManager::StartUpdating() {
663 thread_ = Thread::Current();
664 if (start_count_) {
665 // If network interfaces are already discovered and signal is sent,
666 // we should trigger network signal immediately for the new clients
667 // to start allocating ports.
668 if (sent_first_update_)
669 thread_->Post(this, kSignalNetworksMessage);
670 } else {
671 thread_->Post(this, kUpdateNetworksMessage);
honghaiz023f3ef2015-10-19 09:39:32 -0700672 StartNetworkMonitor();
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000673 }
674 ++start_count_;
675}
676
677void BasicNetworkManager::StopUpdating() {
678 ASSERT(Thread::Current() == thread_);
679 if (!start_count_)
680 return;
681
682 --start_count_;
683 if (!start_count_) {
684 thread_->Clear(this);
685 sent_first_update_ = false;
honghaiz023f3ef2015-10-19 09:39:32 -0700686 StopNetworkMonitor();
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000687 }
688}
689
honghaiz023f3ef2015-10-19 09:39:32 -0700690void BasicNetworkManager::StartNetworkMonitor() {
691 NetworkMonitorFactory* factory = NetworkMonitorFactory::GetFactory();
692 if (factory == nullptr) {
693 return;
694 }
695 network_monitor_.reset(factory->CreateNetworkMonitor());
696 if (!network_monitor_) {
697 return;
698 }
699 network_monitor_->SignalNetworksChanged.connect(
700 this, &BasicNetworkManager::OnNetworksChanged);
701 network_monitor_->Start();
702}
703
704void BasicNetworkManager::StopNetworkMonitor() {
705 if (!network_monitor_) {
706 return;
707 }
708 network_monitor_->Stop();
709 network_monitor_.reset();
710}
711
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000712void BasicNetworkManager::OnMessage(Message* msg) {
713 switch (msg->message_id) {
honghaiz023f3ef2015-10-19 09:39:32 -0700714 case kUpdateNetworksMessage: {
715 UpdateNetworksContinually();
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000716 break;
717 }
718 case kSignalNetworksMessage: {
719 SignalNetworksChanged();
720 break;
721 }
722 default:
723 ASSERT(false);
724 }
725}
726
honghaiz023f3ef2015-10-19 09:39:32 -0700727void BasicNetworkManager::UpdateNetworksOnce() {
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000728 if (!start_count_)
729 return;
730
731 ASSERT(Thread::Current() == thread_);
732
733 NetworkList list;
734 if (!CreateNetworks(false, &list)) {
735 SignalError();
736 } else {
737 bool changed;
738 MergeNetworkList(list, &changed);
739 if (changed || !sent_first_update_) {
740 SignalNetworksChanged();
741 sent_first_update_ = true;
742 }
743 }
honghaiz023f3ef2015-10-19 09:39:32 -0700744}
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000745
honghaiz023f3ef2015-10-19 09:39:32 -0700746void BasicNetworkManager::UpdateNetworksContinually() {
747 UpdateNetworksOnce();
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000748 thread_->PostDelayed(kNetworksUpdateIntervalMs, this, kUpdateNetworksMessage);
749}
750
751void BasicNetworkManager::DumpNetworks(bool include_ignored) {
752 NetworkList list;
753 CreateNetworks(include_ignored, &list);
754 LOG(LS_INFO) << "NetworkManager detected " << list.size() << " networks:";
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000755 for (const Network* network : list) {
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000756 if (!network->ignored() || include_ignored) {
757 LOG(LS_INFO) << network->ToString() << ": "
758 << network->description()
759 << ((network->ignored()) ? ", Ignored" : "");
760 }
761 }
762 // Release the network list created previously.
763 // Do this in a seperated for loop for better readability.
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000764 for (Network* network : list) {
765 delete network;
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000766 }
767}
768
769Network::Network(const std::string& name, const std::string& desc,
770 const IPAddress& prefix, int prefix_length)
771 : name_(name), description_(desc), prefix_(prefix),
772 prefix_length_(prefix_length),
773 key_(MakeNetworkKey(name, prefix, prefix_length)), scope_id_(0),
774 ignored_(false), type_(ADAPTER_TYPE_UNKNOWN), preference_(0) {
775}
776
777Network::Network(const std::string& name, const std::string& desc,
778 const IPAddress& prefix, int prefix_length, AdapterType type)
779 : name_(name), description_(desc), prefix_(prefix),
780 prefix_length_(prefix_length),
781 key_(MakeNetworkKey(name, prefix, prefix_length)), scope_id_(0),
782 ignored_(false), type_(type), preference_(0) {
783}
784
kwiberg@webrtc.org67186fe2015-03-09 22:21:53 +0000785Network::~Network() = default;
786
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000787// Sets the addresses of this network. Returns true if the address set changed.
788// Change detection is short circuited if the changed argument is true.
guoweis@webrtc.orgfa603982014-09-09 23:42:40 +0000789bool Network::SetIPs(const std::vector<InterfaceAddress>& ips, bool changed) {
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000790 // Detect changes with a nested loop; n-squared but we expect on the order
791 // of 2-3 addresses per network.
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000792 changed = changed || ips.size() != ips_.size();
793 if (!changed) {
794 for (const InterfaceAddress& ip : ips) {
795 if (std::find(ips_.begin(), ips_.end(), ip) == ips_.end()) {
796 changed = true;
797 break;
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000798 }
799 }
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000800 }
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000801
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000802 ips_ = ips;
803 return changed;
804}
805
aluebs@webrtc.org07dcf602015-02-27 18:42:22 +0000806// Select the best IP address to use from this Network.
guoweis@webrtc.org369a6372014-09-17 22:37:29 +0000807IPAddress Network::GetBestIP() const {
guoweis@webrtc.orgfa603982014-09-09 23:42:40 +0000808 if (ips_.size() == 0) {
809 return IPAddress();
810 }
guoweis@webrtc.org369a6372014-09-17 22:37:29 +0000811
812 if (prefix_.family() == AF_INET) {
813 return static_cast<IPAddress>(ips_.at(0));
814 }
815
aluebs@webrtc.org07dcf602015-02-27 18:42:22 +0000816 InterfaceAddress selected_ip, ula_ip;
817
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000818 for (const InterfaceAddress& ip : ips_) {
aluebs@webrtc.org07dcf602015-02-27 18:42:22 +0000819 // Ignore any address which has been deprecated already.
820 if (ip.ipv6_flags() & IPV6_ADDRESS_FLAG_DEPRECATED)
821 continue;
822
823 // ULA address should only be returned when we have no other
824 // global IP.
825 if (IPIsULA(static_cast<const IPAddress&>(ip))) {
826 ula_ip = ip;
guoweis@webrtc.org369a6372014-09-17 22:37:29 +0000827 continue;
828 }
aluebs@webrtc.org07dcf602015-02-27 18:42:22 +0000829 selected_ip = ip;
guoweis@webrtc.org369a6372014-09-17 22:37:29 +0000830
aluebs@webrtc.org07dcf602015-02-27 18:42:22 +0000831 // Search could stop once a temporary non-deprecated one is found.
832 if (ip.ipv6_flags() & IPV6_ADDRESS_FLAG_TEMPORARY)
833 break;
guoweis@webrtc.org369a6372014-09-17 22:37:29 +0000834 }
835
aluebs@webrtc.org07dcf602015-02-27 18:42:22 +0000836 // No proper global IPv6 address found, use ULA instead.
837 if (IPIsUnspec(selected_ip) && !IPIsUnspec(ula_ip)) {
838 selected_ip = ula_ip;
839 }
840
841 return static_cast<IPAddress>(selected_ip);
guoweis@webrtc.org369a6372014-09-17 22:37:29 +0000842}
843
844std::string Network::ToString() const {
845 std::stringstream ss;
846 // Print out the first space-terminated token of the network desc, plus
847 // the IP address.
848 ss << "Net[" << description_.substr(0, description_.find(' '))
849 << ":" << prefix_.ToSensitiveString() << "/" << prefix_length_
850 << ":" << AdapterTypeToString(type_) << "]";
851 return ss.str();
guoweis@webrtc.orgfa603982014-09-09 23:42:40 +0000852}
853
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000854} // namespace rtc