blob: c011c1f1f914d61e76a096b9ab6bb8521060d957 [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"
51#include "webrtc/base/scoped_ptr.h"
52#include "webrtc/base/socket.h" // includes something that makes windows happy
53#include "webrtc/base/stream.h"
54#include "webrtc/base/stringencode.h"
55#include "webrtc/base/thread.h"
56
57namespace rtc {
58namespace {
59
guoweis@webrtc.org2444d962015-01-30 00:09:28 +000060// Turning on IPv6 could make many IPv6 interfaces available for connectivity
61// check and delay the call setup time. kMaxIPv6Networks is the default upper
62// limit of IPv6 networks but could be changed by set_max_ipv6_networks().
63const int kMaxIPv6Networks = 5;
64
henrike@webrtc.orgf0488722014-05-13 18:00:26 +000065const uint32 kUpdateNetworksMessage = 1;
66const uint32 kSignalNetworksMessage = 2;
67
68// Fetch list of networks every two seconds.
69const int kNetworksUpdateIntervalMs = 2000;
70
71const int kHighestNetworkPreference = 127;
72
guoweis@webrtc.org4bbd3c82014-09-09 13:54:45 +000073typedef struct {
74 Network* net;
guoweis@webrtc.orgfa603982014-09-09 23:42:40 +000075 std::vector<InterfaceAddress> ips;
guoweis@webrtc.org4bbd3c82014-09-09 13:54:45 +000076} AddressList;
77
henrike@webrtc.orgf0488722014-05-13 18:00:26 +000078bool CompareNetworks(const Network* a, const Network* b) {
79 if (a->prefix_length() == b->prefix_length()) {
80 if (a->name() == b->name()) {
81 return a->prefix() < b->prefix();
82 }
83 }
84 return a->name() < b->name();
85}
86
87bool SortNetworks(const Network* a, const Network* b) {
88 // Network types will be preferred above everything else while sorting
89 // Networks.
90
91 // Networks are sorted first by type.
92 if (a->type() != b->type()) {
93 return a->type() < b->type();
94 }
95
guoweis@webrtc.org369a6372014-09-17 22:37:29 +000096 IPAddress ip_a = a->GetBestIP();
97 IPAddress ip_b = b->GetBestIP();
98
henrike@webrtc.orgf0488722014-05-13 18:00:26 +000099 // After type, networks are sorted by IP address precedence values
100 // from RFC 3484-bis
guoweis@webrtc.org369a6372014-09-17 22:37:29 +0000101 if (IPAddressPrecedence(ip_a) != IPAddressPrecedence(ip_b)) {
102 return IPAddressPrecedence(ip_a) > IPAddressPrecedence(ip_b);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000103 }
104
105 // TODO(mallinath) - Add VPN and Link speed conditions while sorting.
106
107 // Networks are sorted last by key.
108 return a->key() > b->key();
109}
110
111std::string AdapterTypeToString(AdapterType type) {
112 switch (type) {
113 case ADAPTER_TYPE_UNKNOWN:
114 return "Unknown";
115 case ADAPTER_TYPE_ETHERNET:
116 return "Ethernet";
117 case ADAPTER_TYPE_WIFI:
118 return "Wifi";
119 case ADAPTER_TYPE_CELLULAR:
120 return "Cellular";
121 case ADAPTER_TYPE_VPN:
122 return "VPN";
phoglund@webrtc.org006521d2015-02-12 09:23:59 +0000123 case ADAPTER_TYPE_LOOPBACK:
124 return "Loopback";
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000125 default:
phoglund@webrtc.org006521d2015-02-12 09:23:59 +0000126 DCHECK(false) << "Invalid type " << type;
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000127 return std::string();
128 }
129}
130
guoweis@webrtc.orgb91d0f52015-03-17 14:43:20 +0000131bool IsIgnoredIPv6(const IPAddress& ip) {
132 if (ip.family() != AF_INET6) {
133 return false;
134 }
135
136 // Link-local addresses require scope id to be bound successfully.
137 // However, our IPAddress structure doesn't carry that so the
138 // information is lost and causes binding failure.
139 if (IPIsLinkLocal(ip)) {
140 return true;
141 }
142
143 // Any MAC based IPv6 should be avoided to prevent the MAC tracking.
144 if (IPIsMacBased(ip)) {
145 return true;
146 }
147
148 return false;
149}
150
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000151} // namespace
152
153std::string MakeNetworkKey(const std::string& name, const IPAddress& prefix,
154 int prefix_length) {
155 std::ostringstream ost;
156 ost << name << "%" << prefix.ToString() << "/" << prefix_length;
157 return ost.str();
158}
159
160NetworkManager::NetworkManager() {
161}
162
163NetworkManager::~NetworkManager() {
164}
165
Guo-wei Shieh86cb9232015-08-19 10:57:53 -0700166NetworkManager::EnumerationPermission NetworkManager::enumeration_permission()
167 const {
guoweisea1012b2015-08-21 09:06:28 -0700168 return ENUMERATION_ALLOWED;
Guo-wei Shieh86cb9232015-08-19 10:57:53 -0700169}
170
guoweis@webrtc.org2444d962015-01-30 00:09:28 +0000171NetworkManagerBase::NetworkManagerBase()
guoweisea1012b2015-08-21 09:06:28 -0700172 : enumeration_permission_(NetworkManager::ENUMERATION_ALLOWED),
Guo-wei Shieh47872ec2015-08-19 10:32:46 -0700173 max_ipv6_networks_(kMaxIPv6Networks),
174 ipv6_enabled_(true) {
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000175}
176
177NetworkManagerBase::~NetworkManagerBase() {
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000178 for (const auto& kv : networks_map_) {
179 delete kv.second;
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000180 }
181}
182
Guo-wei Shieh47872ec2015-08-19 10:32:46 -0700183NetworkManager::EnumerationPermission
184NetworkManagerBase::enumeration_permission() const {
185 return enumeration_permission_;
186}
187
guoweis@webrtc.orgf358aea2015-02-18 18:44:01 +0000188void NetworkManagerBase::GetAnyAddressNetworks(NetworkList* networks) {
189 if (!ipv4_any_address_network_) {
190 const rtc::IPAddress ipv4_any_address(INADDR_ANY);
191 ipv4_any_address_network_.reset(
192 new rtc::Network("any", "any", ipv4_any_address, 0));
193 ipv4_any_address_network_->AddIP(ipv4_any_address);
194 }
195 networks->push_back(ipv4_any_address_network_.get());
196
197 if (ipv6_enabled()) {
198 if (!ipv6_any_address_network_) {
199 const rtc::IPAddress ipv6_any_address(in6addr_any);
200 ipv6_any_address_network_.reset(
201 new rtc::Network("any", "any", ipv6_any_address, 0));
202 ipv6_any_address_network_->AddIP(ipv6_any_address);
203 }
204 networks->push_back(ipv6_any_address_network_.get());
205 }
206}
207
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000208void NetworkManagerBase::GetNetworks(NetworkList* result) const {
guoweis@webrtc.org2444d962015-01-30 00:09:28 +0000209 int ipv6_networks = 0;
210 result->clear();
211 for (Network* network : networks_) {
212 // Keep the number of IPv6 networks under |max_ipv6_networks_|.
213 if (network->prefix().family() == AF_INET6) {
214 if (ipv6_networks >= max_ipv6_networks_) {
215 continue;
216 }
217 ++ipv6_networks;
218 }
219 result->push_back(network);
220 }
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000221}
222
223void NetworkManagerBase::MergeNetworkList(const NetworkList& new_networks,
224 bool* changed) {
guoweis@webrtc.orga094cac2015-01-28 19:34:05 +0000225 NetworkManager::Stats stats;
226 MergeNetworkList(new_networks, changed, &stats);
227}
228
229void NetworkManagerBase::MergeNetworkList(const NetworkList& new_networks,
230 bool* changed,
231 NetworkManager::Stats* stats) {
guoweis@webrtc.org4bbd3c82014-09-09 13:54:45 +0000232 // AddressList in this map will track IP addresses for all Networks
233 // with the same key.
234 std::map<std::string, AddressList> consolidated_address_list;
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000235 NetworkList list(new_networks);
guoweis@webrtc.org4bbd3c82014-09-09 13:54:45 +0000236
237 // Result of Network merge. Element in this list should have unique key.
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000238 NetworkList merged_list;
239 std::sort(list.begin(), list.end(), CompareNetworks);
240
241 *changed = false;
242
243 if (networks_.size() != list.size())
244 *changed = true;
245
246 // First, build a set of network-keys to the ipaddresses.
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000247 for (Network* network : list) {
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000248 bool might_add_to_merged_list = false;
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000249 std::string key = MakeNetworkKey(network->name(),
250 network->prefix(),
251 network->prefix_length());
guoweis@webrtc.org4bbd3c82014-09-09 13:54:45 +0000252 if (consolidated_address_list.find(key) ==
253 consolidated_address_list.end()) {
254 AddressList addrlist;
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000255 addrlist.net = network;
guoweis@webrtc.org4bbd3c82014-09-09 13:54:45 +0000256 consolidated_address_list[key] = addrlist;
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000257 might_add_to_merged_list = true;
258 }
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000259 const std::vector<InterfaceAddress>& addresses = network->GetIPs();
guoweis@webrtc.org4bbd3c82014-09-09 13:54:45 +0000260 AddressList& current_list = consolidated_address_list[key];
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000261 for (const InterfaceAddress& address : addresses) {
262 current_list.ips.push_back(address);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000263 }
264 if (!might_add_to_merged_list) {
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000265 delete network;
guoweis@webrtc.orga094cac2015-01-28 19:34:05 +0000266 } else {
267 if (current_list.ips[0].family() == AF_INET) {
268 stats->ipv4_network_count++;
269 } else {
270 ASSERT(current_list.ips[0].family() == AF_INET6);
271 stats->ipv6_network_count++;
272 }
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000273 }
274 }
275
276 // Next, look for existing network objects to re-use.
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000277 for (const auto& kv : consolidated_address_list) {
278 const std::string& key = kv.first;
279 Network* net = kv.second.net;
280 auto existing = networks_map_.find(key);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000281 if (existing == networks_map_.end()) {
282 // This network is new. Place it in the network map.
283 merged_list.push_back(net);
284 networks_map_[key] = net;
guoweis@webrtc.org4bbd3c82014-09-09 13:54:45 +0000285 // Also, we might have accumulated IPAddresses from the first
286 // step, set it here.
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000287 net->SetIPs(kv.second.ips, true);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000288 *changed = true;
289 } else {
290 // This network exists in the map already. Reset its IP addresses.
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000291 *changed = existing->second->SetIPs(kv.second.ips, *changed);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000292 merged_list.push_back(existing->second);
293 if (existing->second != net) {
294 delete net;
295 }
296 }
297 }
298 networks_ = merged_list;
299
300 // If the network lists changes, we resort it.
guoweis@webrtc.orga094cac2015-01-28 19:34:05 +0000301 if (*changed) {
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000302 std::sort(networks_.begin(), networks_.end(), SortNetworks);
303 // Now network interfaces are sorted, we should set the preference value
304 // for each of the interfaces we are planning to use.
305 // Preference order of network interfaces might have changed from previous
306 // sorting due to addition of higher preference network interface.
307 // Since we have already sorted the network interfaces based on our
308 // requirements, we will just assign a preference value starting with 127,
309 // in decreasing order.
310 int pref = kHighestNetworkPreference;
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000311 for (Network* network : networks_) {
312 network->set_preference(pref);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000313 if (pref > 0) {
314 --pref;
315 } else {
316 LOG(LS_ERROR) << "Too many network interfaces to handle!";
317 break;
318 }
319 }
320 }
321}
322
323BasicNetworkManager::BasicNetworkManager()
324 : thread_(NULL), sent_first_update_(false), start_count_(0),
phoglund@webrtc.org006521d2015-02-12 09:23:59 +0000325 network_ignore_mask_(kDefaultNetworkIgnoreMask),
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000326 ignore_non_default_routes_(false) {
327}
328
329BasicNetworkManager::~BasicNetworkManager() {
330}
331
332#if defined(__native_client__)
333
334bool BasicNetworkManager::CreateNetworks(bool include_ignored,
335 NetworkList* networks) const {
336 ASSERT(false);
337 LOG(LS_WARNING) << "BasicNetworkManager doesn't work on NaCl yet";
338 return false;
339}
340
341#elif defined(WEBRTC_POSIX)
342void BasicNetworkManager::ConvertIfAddrs(struct ifaddrs* interfaces,
343 bool include_ignored,
344 NetworkList* networks) const {
345 NetworkMap current_networks;
346 for (struct ifaddrs* cursor = interfaces;
347 cursor != NULL; cursor = cursor->ifa_next) {
348 IPAddress prefix;
349 IPAddress mask;
350 IPAddress ip;
351 int scope_id = 0;
352
353 // Some interfaces may not have address assigned.
354 if (!cursor->ifa_addr || !cursor->ifa_netmask)
355 continue;
356
357 switch (cursor->ifa_addr->sa_family) {
358 case AF_INET: {
359 ip = IPAddress(
360 reinterpret_cast<sockaddr_in*>(cursor->ifa_addr)->sin_addr);
361 mask = IPAddress(
362 reinterpret_cast<sockaddr_in*>(cursor->ifa_netmask)->sin_addr);
363 break;
364 }
365 case AF_INET6: {
366 if (ipv6_enabled()) {
367 ip = IPAddress(
368 reinterpret_cast<sockaddr_in6*>(cursor->ifa_addr)->sin6_addr);
guoweis@webrtc.orgb91d0f52015-03-17 14:43:20 +0000369
370 if (IsIgnoredIPv6(ip)) {
371 continue;
372 }
373
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000374 mask = IPAddress(
375 reinterpret_cast<sockaddr_in6*>(cursor->ifa_netmask)->sin6_addr);
376 scope_id =
377 reinterpret_cast<sockaddr_in6*>(cursor->ifa_addr)->sin6_scope_id;
378 break;
379 } else {
380 continue;
381 }
382 }
383 default: {
384 continue;
385 }
386 }
387
388 int prefix_length = CountIPMaskBits(mask);
389 prefix = TruncateIP(ip, prefix_length);
390 std::string key = MakeNetworkKey(std::string(cursor->ifa_name),
391 prefix, prefix_length);
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000392 auto existing_network = current_networks.find(key);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000393 if (existing_network == current_networks.end()) {
phoglund@webrtc.org006521d2015-02-12 09:23:59 +0000394 AdapterType adapter_type = ADAPTER_TYPE_UNKNOWN;
395 if (cursor->ifa_flags & IFF_LOOPBACK) {
phoglund@webrtc.org006521d2015-02-12 09:23:59 +0000396 adapter_type = ADAPTER_TYPE_LOOPBACK;
397 }
Noah Richards2e266e92015-04-07 11:51:56 -0700398#if defined(WEBRTC_IOS)
399 // Cell networks are pdp_ipN on iOS.
400 if (strncmp(cursor->ifa_name, "pdp_ip", 6) == 0) {
401 adapter_type = ADAPTER_TYPE_CELLULAR;
402 }
403#endif
404 // TODO(phoglund): Need to recognize other types as well.
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000405 scoped_ptr<Network> network(new Network(cursor->ifa_name,
406 cursor->ifa_name,
407 prefix,
phoglund@webrtc.org006521d2015-02-12 09:23:59 +0000408 prefix_length,
409 adapter_type));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000410 network->set_scope_id(scope_id);
411 network->AddIP(ip);
phoglund@webrtc.org006521d2015-02-12 09:23:59 +0000412 network->set_ignored(IsIgnoredNetwork(*network));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000413 if (include_ignored || !network->ignored()) {
414 networks->push_back(network.release());
415 }
416 } else {
417 (*existing_network).second->AddIP(ip);
418 }
419 }
420}
421
422bool BasicNetworkManager::CreateNetworks(bool include_ignored,
423 NetworkList* networks) const {
424 struct ifaddrs* interfaces;
425 int error = getifaddrs(&interfaces);
426 if (error != 0) {
427 LOG_ERR(LERROR) << "getifaddrs failed to gather interface data: " << error;
428 return false;
429 }
430
431 ConvertIfAddrs(interfaces, include_ignored, networks);
432
433 freeifaddrs(interfaces);
434 return true;
435}
436
437#elif defined(WEBRTC_WIN)
438
439unsigned int GetPrefix(PIP_ADAPTER_PREFIX prefixlist,
440 const IPAddress& ip, IPAddress* prefix) {
441 IPAddress current_prefix;
442 IPAddress best_prefix;
443 unsigned int best_length = 0;
444 while (prefixlist) {
445 // Look for the longest matching prefix in the prefixlist.
446 if (prefixlist->Address.lpSockaddr == NULL ||
447 prefixlist->Address.lpSockaddr->sa_family != ip.family()) {
448 prefixlist = prefixlist->Next;
449 continue;
450 }
451 switch (prefixlist->Address.lpSockaddr->sa_family) {
452 case AF_INET: {
453 sockaddr_in* v4_addr =
454 reinterpret_cast<sockaddr_in*>(prefixlist->Address.lpSockaddr);
455 current_prefix = IPAddress(v4_addr->sin_addr);
456 break;
457 }
458 case AF_INET6: {
459 sockaddr_in6* v6_addr =
460 reinterpret_cast<sockaddr_in6*>(prefixlist->Address.lpSockaddr);
461 current_prefix = IPAddress(v6_addr->sin6_addr);
462 break;
463 }
464 default: {
465 prefixlist = prefixlist->Next;
466 continue;
467 }
468 }
469 if (TruncateIP(ip, prefixlist->PrefixLength) == current_prefix &&
470 prefixlist->PrefixLength > best_length) {
471 best_prefix = current_prefix;
472 best_length = prefixlist->PrefixLength;
473 }
474 prefixlist = prefixlist->Next;
475 }
476 *prefix = best_prefix;
477 return best_length;
478}
479
480bool BasicNetworkManager::CreateNetworks(bool include_ignored,
481 NetworkList* networks) const {
482 NetworkMap current_networks;
483 // MSDN recommends a 15KB buffer for the first try at GetAdaptersAddresses.
484 size_t buffer_size = 16384;
485 scoped_ptr<char[]> adapter_info(new char[buffer_size]);
486 PIP_ADAPTER_ADDRESSES adapter_addrs =
487 reinterpret_cast<PIP_ADAPTER_ADDRESSES>(adapter_info.get());
488 int adapter_flags = (GAA_FLAG_SKIP_DNS_SERVER | GAA_FLAG_SKIP_ANYCAST |
489 GAA_FLAG_SKIP_MULTICAST | GAA_FLAG_INCLUDE_PREFIX);
490 int ret = 0;
491 do {
492 adapter_info.reset(new char[buffer_size]);
493 adapter_addrs = reinterpret_cast<PIP_ADAPTER_ADDRESSES>(adapter_info.get());
494 ret = GetAdaptersAddresses(AF_UNSPEC, adapter_flags,
495 0, adapter_addrs,
496 reinterpret_cast<PULONG>(&buffer_size));
497 } while (ret == ERROR_BUFFER_OVERFLOW);
498 if (ret != ERROR_SUCCESS) {
499 return false;
500 }
501 int count = 0;
502 while (adapter_addrs) {
503 if (adapter_addrs->OperStatus == IfOperStatusUp) {
504 PIP_ADAPTER_UNICAST_ADDRESS address = adapter_addrs->FirstUnicastAddress;
505 PIP_ADAPTER_PREFIX prefixlist = adapter_addrs->FirstPrefix;
506 std::string name;
507 std::string description;
508#ifdef _DEBUG
509 name = ToUtf8(adapter_addrs->FriendlyName,
510 wcslen(adapter_addrs->FriendlyName));
511#endif
512 description = ToUtf8(adapter_addrs->Description,
513 wcslen(adapter_addrs->Description));
514 for (; address; address = address->Next) {
515#ifndef _DEBUG
516 name = rtc::ToString(count);
517#endif
518
519 IPAddress ip;
520 int scope_id = 0;
521 scoped_ptr<Network> network;
522 switch (address->Address.lpSockaddr->sa_family) {
523 case AF_INET: {
524 sockaddr_in* v4_addr =
525 reinterpret_cast<sockaddr_in*>(address->Address.lpSockaddr);
526 ip = IPAddress(v4_addr->sin_addr);
527 break;
528 }
529 case AF_INET6: {
530 if (ipv6_enabled()) {
531 sockaddr_in6* v6_addr =
532 reinterpret_cast<sockaddr_in6*>(address->Address.lpSockaddr);
533 scope_id = v6_addr->sin6_scope_id;
534 ip = IPAddress(v6_addr->sin6_addr);
guoweis@webrtc.orgb91d0f52015-03-17 14:43:20 +0000535
536 if (IsIgnoredIPv6(ip)) {
537 continue;
538 }
539
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000540 break;
541 } else {
542 continue;
543 }
544 }
545 default: {
546 continue;
547 }
548 }
549
550 IPAddress prefix;
551 int prefix_length = GetPrefix(prefixlist, ip, &prefix);
552 std::string key = MakeNetworkKey(name, prefix, prefix_length);
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000553 auto existing_network = current_networks.find(key);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000554 if (existing_network == current_networks.end()) {
phoglund@webrtc.org006521d2015-02-12 09:23:59 +0000555 AdapterType adapter_type = ADAPTER_TYPE_UNKNOWN;
556 if (adapter_addrs->IfType == IF_TYPE_SOFTWARE_LOOPBACK) {
557 // TODO(phoglund): Need to recognize other types as well.
558 adapter_type = ADAPTER_TYPE_LOOPBACK;
559 }
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000560 scoped_ptr<Network> network(new Network(name,
561 description,
562 prefix,
phoglund@webrtc.org006521d2015-02-12 09:23:59 +0000563 prefix_length,
564 adapter_type));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000565 network->set_scope_id(scope_id);
566 network->AddIP(ip);
phoglund@webrtc.org006521d2015-02-12 09:23:59 +0000567 bool ignored = IsIgnoredNetwork(*network);
568 network->set_ignored(ignored);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000569 if (include_ignored || !network->ignored()) {
570 networks->push_back(network.release());
571 }
572 } else {
573 (*existing_network).second->AddIP(ip);
574 }
575 }
576 // Count is per-adapter - all 'Networks' created from the same
577 // adapter need to have the same name.
578 ++count;
579 }
580 adapter_addrs = adapter_addrs->Next;
581 }
582 return true;
583}
guoweis@webrtc.org369a6372014-09-17 22:37:29 +0000584#endif // WEBRTC_WIN
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000585
586#if defined(WEBRTC_LINUX)
587bool IsDefaultRoute(const std::string& network_name) {
588 FileStream fs;
589 if (!fs.Open("/proc/net/route", "r", NULL)) {
590 LOG(LS_WARNING) << "Couldn't read /proc/net/route, skipping default "
591 << "route check (assuming everything is a default route).";
592 return true;
593 } else {
594 std::string line;
595 while (fs.ReadLine(&line) == SR_SUCCESS) {
596 char iface_name[256];
597 unsigned int iface_ip, iface_gw, iface_mask, iface_flags;
598 if (sscanf(line.c_str(),
599 "%255s %8X %8X %4X %*d %*u %*d %8X",
600 iface_name, &iface_ip, &iface_gw,
601 &iface_flags, &iface_mask) == 5 &&
602 network_name == iface_name &&
603 iface_mask == 0 &&
604 (iface_flags & (RTF_UP | RTF_HOST)) == RTF_UP) {
605 return true;
606 }
607 }
608 }
609 return false;
610}
611#endif
612
613bool BasicNetworkManager::IsIgnoredNetwork(const Network& network) const {
614 // Ignore networks on the explicit ignore list.
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000615 for (const std::string& ignored_name : network_ignore_list_) {
616 if (network.name() == ignored_name) {
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000617 return true;
618 }
619 }
phoglund@webrtc.org006521d2015-02-12 09:23:59 +0000620
621 if (network_ignore_mask_ & network.type()) {
622 return true;
623 }
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000624#if defined(WEBRTC_POSIX)
pthatcher@webrtc.orgdfef0282015-01-07 17:20:52 +0000625 // Filter out VMware/VirtualBox interfaces, typically named vmnet1,
626 // vmnet8, or vboxnet0.
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000627 if (strncmp(network.name().c_str(), "vmnet", 5) == 0 ||
pthatcher@webrtc.orgdfef0282015-01-07 17:20:52 +0000628 strncmp(network.name().c_str(), "vnic", 4) == 0 ||
629 strncmp(network.name().c_str(), "vboxnet", 7) == 0) {
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000630 return true;
631 }
632#if defined(WEBRTC_LINUX)
633 // Make sure this is a default route, if we're ignoring non-defaults.
634 if (ignore_non_default_routes_ && !IsDefaultRoute(network.name())) {
635 return true;
636 }
637#endif
638#elif defined(WEBRTC_WIN)
639 // Ignore any HOST side vmware adapters with a description like:
640 // VMware Virtual Ethernet Adapter for VMnet1
641 // but don't ignore any GUEST side adapters with a description like:
642 // VMware Accelerated AMD PCNet Adapter #2
643 if (strstr(network.description().c_str(), "VMnet") != NULL) {
644 return true;
645 }
646#endif
647
648 // Ignore any networks with a 0.x.y.z IP
649 if (network.prefix().family() == AF_INET) {
650 return (network.prefix().v4AddressAsHostOrderInteger() < 0x01000000);
651 }
guoweis@webrtc.orgbbce5ef2015-03-05 04:38:29 +0000652
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000653 return false;
654}
655
656void BasicNetworkManager::StartUpdating() {
657 thread_ = Thread::Current();
658 if (start_count_) {
659 // If network interfaces are already discovered and signal is sent,
660 // we should trigger network signal immediately for the new clients
661 // to start allocating ports.
662 if (sent_first_update_)
663 thread_->Post(this, kSignalNetworksMessage);
664 } else {
665 thread_->Post(this, kUpdateNetworksMessage);
666 }
667 ++start_count_;
668}
669
670void BasicNetworkManager::StopUpdating() {
671 ASSERT(Thread::Current() == thread_);
672 if (!start_count_)
673 return;
674
675 --start_count_;
676 if (!start_count_) {
677 thread_->Clear(this);
678 sent_first_update_ = false;
679 }
680}
681
682void BasicNetworkManager::OnMessage(Message* msg) {
683 switch (msg->message_id) {
684 case kUpdateNetworksMessage: {
685 DoUpdateNetworks();
686 break;
687 }
688 case kSignalNetworksMessage: {
689 SignalNetworksChanged();
690 break;
691 }
692 default:
693 ASSERT(false);
694 }
695}
696
697void BasicNetworkManager::DoUpdateNetworks() {
698 if (!start_count_)
699 return;
700
701 ASSERT(Thread::Current() == thread_);
702
703 NetworkList list;
704 if (!CreateNetworks(false, &list)) {
705 SignalError();
706 } else {
707 bool changed;
708 MergeNetworkList(list, &changed);
709 if (changed || !sent_first_update_) {
710 SignalNetworksChanged();
711 sent_first_update_ = true;
712 }
713 }
714
715 thread_->PostDelayed(kNetworksUpdateIntervalMs, this, kUpdateNetworksMessage);
716}
717
718void BasicNetworkManager::DumpNetworks(bool include_ignored) {
719 NetworkList list;
720 CreateNetworks(include_ignored, &list);
721 LOG(LS_INFO) << "NetworkManager detected " << list.size() << " networks:";
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000722 for (const Network* network : list) {
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000723 if (!network->ignored() || include_ignored) {
724 LOG(LS_INFO) << network->ToString() << ": "
725 << network->description()
726 << ((network->ignored()) ? ", Ignored" : "");
727 }
728 }
729 // Release the network list created previously.
730 // Do this in a seperated for loop for better readability.
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000731 for (Network* network : list) {
732 delete network;
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000733 }
734}
735
736Network::Network(const std::string& name, const std::string& desc,
737 const IPAddress& prefix, int prefix_length)
738 : name_(name), description_(desc), prefix_(prefix),
739 prefix_length_(prefix_length),
740 key_(MakeNetworkKey(name, prefix, prefix_length)), scope_id_(0),
741 ignored_(false), type_(ADAPTER_TYPE_UNKNOWN), preference_(0) {
742}
743
744Network::Network(const std::string& name, const std::string& desc,
745 const IPAddress& prefix, int prefix_length, AdapterType type)
746 : name_(name), description_(desc), prefix_(prefix),
747 prefix_length_(prefix_length),
748 key_(MakeNetworkKey(name, prefix, prefix_length)), scope_id_(0),
749 ignored_(false), type_(type), preference_(0) {
750}
751
kwiberg@webrtc.org67186fe2015-03-09 22:21:53 +0000752Network::~Network() = default;
753
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000754// Sets the addresses of this network. Returns true if the address set changed.
755// Change detection is short circuited if the changed argument is true.
guoweis@webrtc.orgfa603982014-09-09 23:42:40 +0000756bool Network::SetIPs(const std::vector<InterfaceAddress>& ips, bool changed) {
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000757 // Detect changes with a nested loop; n-squared but we expect on the order
758 // of 2-3 addresses per network.
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000759 changed = changed || ips.size() != ips_.size();
760 if (!changed) {
761 for (const InterfaceAddress& ip : ips) {
762 if (std::find(ips_.begin(), ips_.end(), ip) == ips_.end()) {
763 changed = true;
764 break;
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000765 }
766 }
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000767 }
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000768
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000769 ips_ = ips;
770 return changed;
771}
772
aluebs@webrtc.org07dcf602015-02-27 18:42:22 +0000773// Select the best IP address to use from this Network.
guoweis@webrtc.org369a6372014-09-17 22:37:29 +0000774IPAddress Network::GetBestIP() const {
guoweis@webrtc.orgfa603982014-09-09 23:42:40 +0000775 if (ips_.size() == 0) {
776 return IPAddress();
777 }
guoweis@webrtc.org369a6372014-09-17 22:37:29 +0000778
779 if (prefix_.family() == AF_INET) {
780 return static_cast<IPAddress>(ips_.at(0));
781 }
782
aluebs@webrtc.org07dcf602015-02-27 18:42:22 +0000783 InterfaceAddress selected_ip, ula_ip;
784
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000785 for (const InterfaceAddress& ip : ips_) {
aluebs@webrtc.org07dcf602015-02-27 18:42:22 +0000786 // Ignore any address which has been deprecated already.
787 if (ip.ipv6_flags() & IPV6_ADDRESS_FLAG_DEPRECATED)
788 continue;
789
790 // ULA address should only be returned when we have no other
791 // global IP.
792 if (IPIsULA(static_cast<const IPAddress&>(ip))) {
793 ula_ip = ip;
guoweis@webrtc.org369a6372014-09-17 22:37:29 +0000794 continue;
795 }
aluebs@webrtc.org07dcf602015-02-27 18:42:22 +0000796 selected_ip = ip;
guoweis@webrtc.org369a6372014-09-17 22:37:29 +0000797
aluebs@webrtc.org07dcf602015-02-27 18:42:22 +0000798 // Search could stop once a temporary non-deprecated one is found.
799 if (ip.ipv6_flags() & IPV6_ADDRESS_FLAG_TEMPORARY)
800 break;
guoweis@webrtc.org369a6372014-09-17 22:37:29 +0000801 }
802
aluebs@webrtc.org07dcf602015-02-27 18:42:22 +0000803 // No proper global IPv6 address found, use ULA instead.
804 if (IPIsUnspec(selected_ip) && !IPIsUnspec(ula_ip)) {
805 selected_ip = ula_ip;
806 }
807
808 return static_cast<IPAddress>(selected_ip);
guoweis@webrtc.org369a6372014-09-17 22:37:29 +0000809}
810
811std::string Network::ToString() const {
812 std::stringstream ss;
813 // Print out the first space-terminated token of the network desc, plus
814 // the IP address.
815 ss << "Net[" << description_.substr(0, description_.find(' '))
816 << ":" << prefix_.ToSensitiveString() << "/" << prefix_length_
817 << ":" << AdapterTypeToString(type_) << "]";
818 return ss.str();
guoweis@webrtc.orgfa603982014-09-09 23:42:40 +0000819}
820
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000821} // namespace rtc