blob: 9ed1c87e3f6111f75b2e5be5e9ace2c7cb5cd545 [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
131} // namespace
132
133std::string MakeNetworkKey(const std::string& name, const IPAddress& prefix,
134 int prefix_length) {
135 std::ostringstream ost;
136 ost << name << "%" << prefix.ToString() << "/" << prefix_length;
137 return ost.str();
138}
139
140NetworkManager::NetworkManager() {
141}
142
143NetworkManager::~NetworkManager() {
144}
145
guoweis@webrtc.org2444d962015-01-30 00:09:28 +0000146NetworkManagerBase::NetworkManagerBase()
147 : max_ipv6_networks_(kMaxIPv6Networks), ipv6_enabled_(true) {
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000148}
149
150NetworkManagerBase::~NetworkManagerBase() {
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000151 for (const auto& kv : networks_map_) {
152 delete kv.second;
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000153 }
154}
155
guoweis@webrtc.orgf358aea2015-02-18 18:44:01 +0000156void NetworkManagerBase::GetAnyAddressNetworks(NetworkList* networks) {
157 if (!ipv4_any_address_network_) {
158 const rtc::IPAddress ipv4_any_address(INADDR_ANY);
159 ipv4_any_address_network_.reset(
160 new rtc::Network("any", "any", ipv4_any_address, 0));
161 ipv4_any_address_network_->AddIP(ipv4_any_address);
162 }
163 networks->push_back(ipv4_any_address_network_.get());
164
165 if (ipv6_enabled()) {
166 if (!ipv6_any_address_network_) {
167 const rtc::IPAddress ipv6_any_address(in6addr_any);
168 ipv6_any_address_network_.reset(
169 new rtc::Network("any", "any", ipv6_any_address, 0));
170 ipv6_any_address_network_->AddIP(ipv6_any_address);
171 }
172 networks->push_back(ipv6_any_address_network_.get());
173 }
174}
175
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000176void NetworkManagerBase::GetNetworks(NetworkList* result) const {
guoweis@webrtc.org2444d962015-01-30 00:09:28 +0000177 int ipv6_networks = 0;
178 result->clear();
179 for (Network* network : networks_) {
180 // Keep the number of IPv6 networks under |max_ipv6_networks_|.
181 if (network->prefix().family() == AF_INET6) {
182 if (ipv6_networks >= max_ipv6_networks_) {
183 continue;
184 }
185 ++ipv6_networks;
186 }
187 result->push_back(network);
188 }
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000189}
190
191void NetworkManagerBase::MergeNetworkList(const NetworkList& new_networks,
192 bool* changed) {
guoweis@webrtc.orga094cac2015-01-28 19:34:05 +0000193 NetworkManager::Stats stats;
194 MergeNetworkList(new_networks, changed, &stats);
195}
196
197void NetworkManagerBase::MergeNetworkList(const NetworkList& new_networks,
198 bool* changed,
199 NetworkManager::Stats* stats) {
guoweis@webrtc.org4bbd3c82014-09-09 13:54:45 +0000200 // AddressList in this map will track IP addresses for all Networks
201 // with the same key.
202 std::map<std::string, AddressList> consolidated_address_list;
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000203 NetworkList list(new_networks);
guoweis@webrtc.org4bbd3c82014-09-09 13:54:45 +0000204
205 // Result of Network merge. Element in this list should have unique key.
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000206 NetworkList merged_list;
207 std::sort(list.begin(), list.end(), CompareNetworks);
208
209 *changed = false;
210
211 if (networks_.size() != list.size())
212 *changed = true;
213
214 // First, build a set of network-keys to the ipaddresses.
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000215 for (Network* network : list) {
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000216 bool might_add_to_merged_list = false;
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000217 std::string key = MakeNetworkKey(network->name(),
218 network->prefix(),
219 network->prefix_length());
guoweis@webrtc.org4bbd3c82014-09-09 13:54:45 +0000220 if (consolidated_address_list.find(key) ==
221 consolidated_address_list.end()) {
222 AddressList addrlist;
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000223 addrlist.net = network;
guoweis@webrtc.org4bbd3c82014-09-09 13:54:45 +0000224 consolidated_address_list[key] = addrlist;
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000225 might_add_to_merged_list = true;
226 }
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000227 const std::vector<InterfaceAddress>& addresses = network->GetIPs();
guoweis@webrtc.org4bbd3c82014-09-09 13:54:45 +0000228 AddressList& current_list = consolidated_address_list[key];
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000229 for (const InterfaceAddress& address : addresses) {
230 current_list.ips.push_back(address);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000231 }
232 if (!might_add_to_merged_list) {
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000233 delete network;
guoweis@webrtc.orga094cac2015-01-28 19:34:05 +0000234 } else {
235 if (current_list.ips[0].family() == AF_INET) {
236 stats->ipv4_network_count++;
237 } else {
238 ASSERT(current_list.ips[0].family() == AF_INET6);
239 stats->ipv6_network_count++;
240 }
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000241 }
242 }
243
244 // Next, look for existing network objects to re-use.
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000245 for (const auto& kv : consolidated_address_list) {
246 const std::string& key = kv.first;
247 Network* net = kv.second.net;
248 auto existing = networks_map_.find(key);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000249 if (existing == networks_map_.end()) {
250 // This network is new. Place it in the network map.
251 merged_list.push_back(net);
252 networks_map_[key] = net;
guoweis@webrtc.org4bbd3c82014-09-09 13:54:45 +0000253 // Also, we might have accumulated IPAddresses from the first
254 // step, set it here.
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000255 net->SetIPs(kv.second.ips, true);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000256 *changed = true;
257 } else {
258 // This network exists in the map already. Reset its IP addresses.
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000259 *changed = existing->second->SetIPs(kv.second.ips, *changed);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000260 merged_list.push_back(existing->second);
261 if (existing->second != net) {
262 delete net;
263 }
264 }
265 }
266 networks_ = merged_list;
267
268 // If the network lists changes, we resort it.
guoweis@webrtc.orga094cac2015-01-28 19:34:05 +0000269 if (*changed) {
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000270 std::sort(networks_.begin(), networks_.end(), SortNetworks);
271 // Now network interfaces are sorted, we should set the preference value
272 // for each of the interfaces we are planning to use.
273 // Preference order of network interfaces might have changed from previous
274 // sorting due to addition of higher preference network interface.
275 // Since we have already sorted the network interfaces based on our
276 // requirements, we will just assign a preference value starting with 127,
277 // in decreasing order.
278 int pref = kHighestNetworkPreference;
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000279 for (Network* network : networks_) {
280 network->set_preference(pref);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000281 if (pref > 0) {
282 --pref;
283 } else {
284 LOG(LS_ERROR) << "Too many network interfaces to handle!";
285 break;
286 }
287 }
288 }
289}
290
291BasicNetworkManager::BasicNetworkManager()
292 : thread_(NULL), sent_first_update_(false), start_count_(0),
phoglund@webrtc.org006521d2015-02-12 09:23:59 +0000293 network_ignore_mask_(kDefaultNetworkIgnoreMask),
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000294 ignore_non_default_routes_(false) {
295}
296
297BasicNetworkManager::~BasicNetworkManager() {
298}
299
300#if defined(__native_client__)
301
302bool BasicNetworkManager::CreateNetworks(bool include_ignored,
303 NetworkList* networks) const {
304 ASSERT(false);
305 LOG(LS_WARNING) << "BasicNetworkManager doesn't work on NaCl yet";
306 return false;
307}
308
309#elif defined(WEBRTC_POSIX)
310void BasicNetworkManager::ConvertIfAddrs(struct ifaddrs* interfaces,
311 bool include_ignored,
312 NetworkList* networks) const {
313 NetworkMap current_networks;
314 for (struct ifaddrs* cursor = interfaces;
315 cursor != NULL; cursor = cursor->ifa_next) {
316 IPAddress prefix;
317 IPAddress mask;
318 IPAddress ip;
319 int scope_id = 0;
320
321 // Some interfaces may not have address assigned.
322 if (!cursor->ifa_addr || !cursor->ifa_netmask)
323 continue;
324
325 switch (cursor->ifa_addr->sa_family) {
326 case AF_INET: {
327 ip = IPAddress(
328 reinterpret_cast<sockaddr_in*>(cursor->ifa_addr)->sin_addr);
329 mask = IPAddress(
330 reinterpret_cast<sockaddr_in*>(cursor->ifa_netmask)->sin_addr);
331 break;
332 }
333 case AF_INET6: {
334 if (ipv6_enabled()) {
335 ip = IPAddress(
336 reinterpret_cast<sockaddr_in6*>(cursor->ifa_addr)->sin6_addr);
337 mask = IPAddress(
338 reinterpret_cast<sockaddr_in6*>(cursor->ifa_netmask)->sin6_addr);
339 scope_id =
340 reinterpret_cast<sockaddr_in6*>(cursor->ifa_addr)->sin6_scope_id;
341 break;
342 } else {
343 continue;
344 }
345 }
346 default: {
347 continue;
348 }
349 }
350
351 int prefix_length = CountIPMaskBits(mask);
352 prefix = TruncateIP(ip, prefix_length);
353 std::string key = MakeNetworkKey(std::string(cursor->ifa_name),
354 prefix, prefix_length);
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000355 auto existing_network = current_networks.find(key);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000356 if (existing_network == current_networks.end()) {
phoglund@webrtc.org006521d2015-02-12 09:23:59 +0000357 AdapterType adapter_type = ADAPTER_TYPE_UNKNOWN;
358 if (cursor->ifa_flags & IFF_LOOPBACK) {
359 // TODO(phoglund): Need to recognize other types as well.
360 adapter_type = ADAPTER_TYPE_LOOPBACK;
361 }
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000362 scoped_ptr<Network> network(new Network(cursor->ifa_name,
363 cursor->ifa_name,
364 prefix,
phoglund@webrtc.org006521d2015-02-12 09:23:59 +0000365 prefix_length,
366 adapter_type));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000367 network->set_scope_id(scope_id);
368 network->AddIP(ip);
phoglund@webrtc.org006521d2015-02-12 09:23:59 +0000369 network->set_ignored(IsIgnoredNetwork(*network));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000370 if (include_ignored || !network->ignored()) {
371 networks->push_back(network.release());
372 }
373 } else {
374 (*existing_network).second->AddIP(ip);
375 }
376 }
377}
378
379bool BasicNetworkManager::CreateNetworks(bool include_ignored,
380 NetworkList* networks) const {
381 struct ifaddrs* interfaces;
382 int error = getifaddrs(&interfaces);
383 if (error != 0) {
384 LOG_ERR(LERROR) << "getifaddrs failed to gather interface data: " << error;
385 return false;
386 }
387
388 ConvertIfAddrs(interfaces, include_ignored, networks);
389
390 freeifaddrs(interfaces);
391 return true;
392}
393
394#elif defined(WEBRTC_WIN)
395
396unsigned int GetPrefix(PIP_ADAPTER_PREFIX prefixlist,
397 const IPAddress& ip, IPAddress* prefix) {
398 IPAddress current_prefix;
399 IPAddress best_prefix;
400 unsigned int best_length = 0;
401 while (prefixlist) {
402 // Look for the longest matching prefix in the prefixlist.
403 if (prefixlist->Address.lpSockaddr == NULL ||
404 prefixlist->Address.lpSockaddr->sa_family != ip.family()) {
405 prefixlist = prefixlist->Next;
406 continue;
407 }
408 switch (prefixlist->Address.lpSockaddr->sa_family) {
409 case AF_INET: {
410 sockaddr_in* v4_addr =
411 reinterpret_cast<sockaddr_in*>(prefixlist->Address.lpSockaddr);
412 current_prefix = IPAddress(v4_addr->sin_addr);
413 break;
414 }
415 case AF_INET6: {
416 sockaddr_in6* v6_addr =
417 reinterpret_cast<sockaddr_in6*>(prefixlist->Address.lpSockaddr);
418 current_prefix = IPAddress(v6_addr->sin6_addr);
419 break;
420 }
421 default: {
422 prefixlist = prefixlist->Next;
423 continue;
424 }
425 }
426 if (TruncateIP(ip, prefixlist->PrefixLength) == current_prefix &&
427 prefixlist->PrefixLength > best_length) {
428 best_prefix = current_prefix;
429 best_length = prefixlist->PrefixLength;
430 }
431 prefixlist = prefixlist->Next;
432 }
433 *prefix = best_prefix;
434 return best_length;
435}
436
437bool BasicNetworkManager::CreateNetworks(bool include_ignored,
438 NetworkList* networks) const {
439 NetworkMap current_networks;
440 // MSDN recommends a 15KB buffer for the first try at GetAdaptersAddresses.
441 size_t buffer_size = 16384;
442 scoped_ptr<char[]> adapter_info(new char[buffer_size]);
443 PIP_ADAPTER_ADDRESSES adapter_addrs =
444 reinterpret_cast<PIP_ADAPTER_ADDRESSES>(adapter_info.get());
445 int adapter_flags = (GAA_FLAG_SKIP_DNS_SERVER | GAA_FLAG_SKIP_ANYCAST |
446 GAA_FLAG_SKIP_MULTICAST | GAA_FLAG_INCLUDE_PREFIX);
447 int ret = 0;
448 do {
449 adapter_info.reset(new char[buffer_size]);
450 adapter_addrs = reinterpret_cast<PIP_ADAPTER_ADDRESSES>(adapter_info.get());
451 ret = GetAdaptersAddresses(AF_UNSPEC, adapter_flags,
452 0, adapter_addrs,
453 reinterpret_cast<PULONG>(&buffer_size));
454 } while (ret == ERROR_BUFFER_OVERFLOW);
455 if (ret != ERROR_SUCCESS) {
456 return false;
457 }
458 int count = 0;
459 while (adapter_addrs) {
460 if (adapter_addrs->OperStatus == IfOperStatusUp) {
461 PIP_ADAPTER_UNICAST_ADDRESS address = adapter_addrs->FirstUnicastAddress;
462 PIP_ADAPTER_PREFIX prefixlist = adapter_addrs->FirstPrefix;
463 std::string name;
464 std::string description;
465#ifdef _DEBUG
466 name = ToUtf8(adapter_addrs->FriendlyName,
467 wcslen(adapter_addrs->FriendlyName));
468#endif
469 description = ToUtf8(adapter_addrs->Description,
470 wcslen(adapter_addrs->Description));
471 for (; address; address = address->Next) {
472#ifndef _DEBUG
473 name = rtc::ToString(count);
474#endif
475
476 IPAddress ip;
477 int scope_id = 0;
478 scoped_ptr<Network> network;
479 switch (address->Address.lpSockaddr->sa_family) {
480 case AF_INET: {
481 sockaddr_in* v4_addr =
482 reinterpret_cast<sockaddr_in*>(address->Address.lpSockaddr);
483 ip = IPAddress(v4_addr->sin_addr);
484 break;
485 }
486 case AF_INET6: {
487 if (ipv6_enabled()) {
488 sockaddr_in6* v6_addr =
489 reinterpret_cast<sockaddr_in6*>(address->Address.lpSockaddr);
490 scope_id = v6_addr->sin6_scope_id;
491 ip = IPAddress(v6_addr->sin6_addr);
492 break;
493 } else {
494 continue;
495 }
496 }
497 default: {
498 continue;
499 }
500 }
501
502 IPAddress prefix;
503 int prefix_length = GetPrefix(prefixlist, ip, &prefix);
504 std::string key = MakeNetworkKey(name, prefix, prefix_length);
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000505 auto existing_network = current_networks.find(key);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000506 if (existing_network == current_networks.end()) {
phoglund@webrtc.org006521d2015-02-12 09:23:59 +0000507 AdapterType adapter_type = ADAPTER_TYPE_UNKNOWN;
508 if (adapter_addrs->IfType == IF_TYPE_SOFTWARE_LOOPBACK) {
509 // TODO(phoglund): Need to recognize other types as well.
510 adapter_type = ADAPTER_TYPE_LOOPBACK;
511 }
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000512 scoped_ptr<Network> network(new Network(name,
513 description,
514 prefix,
phoglund@webrtc.org006521d2015-02-12 09:23:59 +0000515 prefix_length,
516 adapter_type));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000517 network->set_scope_id(scope_id);
518 network->AddIP(ip);
phoglund@webrtc.org006521d2015-02-12 09:23:59 +0000519 bool ignored = IsIgnoredNetwork(*network);
520 network->set_ignored(ignored);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000521 if (include_ignored || !network->ignored()) {
522 networks->push_back(network.release());
523 }
524 } else {
525 (*existing_network).second->AddIP(ip);
526 }
527 }
528 // Count is per-adapter - all 'Networks' created from the same
529 // adapter need to have the same name.
530 ++count;
531 }
532 adapter_addrs = adapter_addrs->Next;
533 }
534 return true;
535}
guoweis@webrtc.org369a6372014-09-17 22:37:29 +0000536#endif // WEBRTC_WIN
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000537
538#if defined(WEBRTC_LINUX)
539bool IsDefaultRoute(const std::string& network_name) {
540 FileStream fs;
541 if (!fs.Open("/proc/net/route", "r", NULL)) {
542 LOG(LS_WARNING) << "Couldn't read /proc/net/route, skipping default "
543 << "route check (assuming everything is a default route).";
544 return true;
545 } else {
546 std::string line;
547 while (fs.ReadLine(&line) == SR_SUCCESS) {
548 char iface_name[256];
549 unsigned int iface_ip, iface_gw, iface_mask, iface_flags;
550 if (sscanf(line.c_str(),
551 "%255s %8X %8X %4X %*d %*u %*d %8X",
552 iface_name, &iface_ip, &iface_gw,
553 &iface_flags, &iface_mask) == 5 &&
554 network_name == iface_name &&
555 iface_mask == 0 &&
556 (iface_flags & (RTF_UP | RTF_HOST)) == RTF_UP) {
557 return true;
558 }
559 }
560 }
561 return false;
562}
563#endif
564
565bool BasicNetworkManager::IsIgnoredNetwork(const Network& network) const {
566 // Ignore networks on the explicit ignore list.
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000567 for (const std::string& ignored_name : network_ignore_list_) {
568 if (network.name() == ignored_name) {
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000569 return true;
570 }
571 }
phoglund@webrtc.org006521d2015-02-12 09:23:59 +0000572
573 if (network_ignore_mask_ & network.type()) {
574 return true;
575 }
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000576#if defined(WEBRTC_POSIX)
pthatcher@webrtc.orgdfef0282015-01-07 17:20:52 +0000577 // Filter out VMware/VirtualBox interfaces, typically named vmnet1,
578 // vmnet8, or vboxnet0.
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000579 if (strncmp(network.name().c_str(), "vmnet", 5) == 0 ||
pthatcher@webrtc.orgdfef0282015-01-07 17:20:52 +0000580 strncmp(network.name().c_str(), "vnic", 4) == 0 ||
581 strncmp(network.name().c_str(), "vboxnet", 7) == 0) {
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000582 return true;
583 }
584#if defined(WEBRTC_LINUX)
585 // Make sure this is a default route, if we're ignoring non-defaults.
586 if (ignore_non_default_routes_ && !IsDefaultRoute(network.name())) {
587 return true;
588 }
589#endif
590#elif defined(WEBRTC_WIN)
591 // Ignore any HOST side vmware adapters with a description like:
592 // VMware Virtual Ethernet Adapter for VMnet1
593 // but don't ignore any GUEST side adapters with a description like:
594 // VMware Accelerated AMD PCNet Adapter #2
595 if (strstr(network.description().c_str(), "VMnet") != NULL) {
596 return true;
597 }
598#endif
599
600 // Ignore any networks with a 0.x.y.z IP
601 if (network.prefix().family() == AF_INET) {
602 return (network.prefix().v4AddressAsHostOrderInteger() < 0x01000000);
603 }
guoweis@webrtc.orgbbce5ef2015-03-05 04:38:29 +0000604
605 // Linklocal addresses require scope id to be bound successfully. However, our
606 // IPAddress structure doesn't carry that so the information is lost and
607 // causes binding failure.
608 if (network.prefix().family() == AF_INET6 &&
609 IPIsLinkLocal(network.GetBestIP())) {
610 return true;
611 }
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000612 return false;
613}
614
615void BasicNetworkManager::StartUpdating() {
616 thread_ = Thread::Current();
617 if (start_count_) {
618 // If network interfaces are already discovered and signal is sent,
619 // we should trigger network signal immediately for the new clients
620 // to start allocating ports.
621 if (sent_first_update_)
622 thread_->Post(this, kSignalNetworksMessage);
623 } else {
624 thread_->Post(this, kUpdateNetworksMessage);
625 }
626 ++start_count_;
627}
628
629void BasicNetworkManager::StopUpdating() {
630 ASSERT(Thread::Current() == thread_);
631 if (!start_count_)
632 return;
633
634 --start_count_;
635 if (!start_count_) {
636 thread_->Clear(this);
637 sent_first_update_ = false;
638 }
639}
640
641void BasicNetworkManager::OnMessage(Message* msg) {
642 switch (msg->message_id) {
643 case kUpdateNetworksMessage: {
644 DoUpdateNetworks();
645 break;
646 }
647 case kSignalNetworksMessage: {
648 SignalNetworksChanged();
649 break;
650 }
651 default:
652 ASSERT(false);
653 }
654}
655
656void BasicNetworkManager::DoUpdateNetworks() {
657 if (!start_count_)
658 return;
659
660 ASSERT(Thread::Current() == thread_);
661
662 NetworkList list;
663 if (!CreateNetworks(false, &list)) {
664 SignalError();
665 } else {
666 bool changed;
667 MergeNetworkList(list, &changed);
668 if (changed || !sent_first_update_) {
669 SignalNetworksChanged();
670 sent_first_update_ = true;
671 }
672 }
673
674 thread_->PostDelayed(kNetworksUpdateIntervalMs, this, kUpdateNetworksMessage);
675}
676
677void BasicNetworkManager::DumpNetworks(bool include_ignored) {
678 NetworkList list;
679 CreateNetworks(include_ignored, &list);
680 LOG(LS_INFO) << "NetworkManager detected " << list.size() << " networks:";
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000681 for (const Network* network : list) {
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000682 if (!network->ignored() || include_ignored) {
683 LOG(LS_INFO) << network->ToString() << ": "
684 << network->description()
685 << ((network->ignored()) ? ", Ignored" : "");
686 }
687 }
688 // Release the network list created previously.
689 // Do this in a seperated for loop for better readability.
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000690 for (Network* network : list) {
691 delete network;
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000692 }
693}
694
695Network::Network(const std::string& name, const std::string& desc,
696 const IPAddress& prefix, int prefix_length)
697 : name_(name), description_(desc), prefix_(prefix),
698 prefix_length_(prefix_length),
699 key_(MakeNetworkKey(name, prefix, prefix_length)), scope_id_(0),
700 ignored_(false), type_(ADAPTER_TYPE_UNKNOWN), preference_(0) {
701}
702
703Network::Network(const std::string& name, const std::string& desc,
704 const IPAddress& prefix, int prefix_length, AdapterType type)
705 : name_(name), description_(desc), prefix_(prefix),
706 prefix_length_(prefix_length),
707 key_(MakeNetworkKey(name, prefix, prefix_length)), scope_id_(0),
708 ignored_(false), type_(type), preference_(0) {
709}
710
kwiberg@webrtc.org67186fe2015-03-09 22:21:53 +0000711Network::~Network() = default;
712
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000713// Sets the addresses of this network. Returns true if the address set changed.
714// Change detection is short circuited if the changed argument is true.
guoweis@webrtc.orgfa603982014-09-09 23:42:40 +0000715bool Network::SetIPs(const std::vector<InterfaceAddress>& ips, bool changed) {
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000716 // Detect changes with a nested loop; n-squared but we expect on the order
717 // of 2-3 addresses per network.
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000718 changed = changed || ips.size() != ips_.size();
719 if (!changed) {
720 for (const InterfaceAddress& ip : ips) {
721 if (std::find(ips_.begin(), ips_.end(), ip) == ips_.end()) {
722 changed = true;
723 break;
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000724 }
725 }
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000726 }
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000727
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000728 ips_ = ips;
729 return changed;
730}
731
aluebs@webrtc.org07dcf602015-02-27 18:42:22 +0000732// Select the best IP address to use from this Network.
guoweis@webrtc.org369a6372014-09-17 22:37:29 +0000733IPAddress Network::GetBestIP() const {
guoweis@webrtc.orgfa603982014-09-09 23:42:40 +0000734 if (ips_.size() == 0) {
735 return IPAddress();
736 }
guoweis@webrtc.org369a6372014-09-17 22:37:29 +0000737
738 if (prefix_.family() == AF_INET) {
739 return static_cast<IPAddress>(ips_.at(0));
740 }
741
aluebs@webrtc.org07dcf602015-02-27 18:42:22 +0000742 InterfaceAddress selected_ip, ula_ip;
743
pthatcher@webrtc.org5950b642014-12-01 23:18:27 +0000744 for (const InterfaceAddress& ip : ips_) {
aluebs@webrtc.org07dcf602015-02-27 18:42:22 +0000745 // Ignore any address which has been deprecated already.
746 if (ip.ipv6_flags() & IPV6_ADDRESS_FLAG_DEPRECATED)
747 continue;
748
749 // ULA address should only be returned when we have no other
750 // global IP.
751 if (IPIsULA(static_cast<const IPAddress&>(ip))) {
752 ula_ip = ip;
guoweis@webrtc.org369a6372014-09-17 22:37:29 +0000753 continue;
754 }
aluebs@webrtc.org07dcf602015-02-27 18:42:22 +0000755 selected_ip = ip;
guoweis@webrtc.org369a6372014-09-17 22:37:29 +0000756
aluebs@webrtc.org07dcf602015-02-27 18:42:22 +0000757 // Search could stop once a temporary non-deprecated one is found.
758 if (ip.ipv6_flags() & IPV6_ADDRESS_FLAG_TEMPORARY)
759 break;
guoweis@webrtc.org369a6372014-09-17 22:37:29 +0000760 }
761
aluebs@webrtc.org07dcf602015-02-27 18:42:22 +0000762 // No proper global IPv6 address found, use ULA instead.
763 if (IPIsUnspec(selected_ip) && !IPIsUnspec(ula_ip)) {
764 selected_ip = ula_ip;
765 }
766
767 return static_cast<IPAddress>(selected_ip);
guoweis@webrtc.org369a6372014-09-17 22:37:29 +0000768}
769
770std::string Network::ToString() const {
771 std::stringstream ss;
772 // Print out the first space-terminated token of the network desc, plus
773 // the IP address.
774 ss << "Net[" << description_.substr(0, description_.find(' '))
775 << ":" << prefix_.ToSensitiveString() << "/" << prefix_length_
776 << ":" << AdapterTypeToString(type_) << "]";
777 return ss.str();
guoweis@webrtc.orgfa603982014-09-09 23:42:40 +0000778}
779
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000780} // namespace rtc