blob: a8152fd5258587e55f44d92e32f1469dfbc1d0d7 [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
Mirko Bonadei92ea95e2017-09-15 06:47:31 +020011#include "rtc_base/network.h"
henrike@webrtc.orgf0488722014-05-13 18:00:26 +000012
oprypin1ea631f2017-08-18 00:15:19 -070013#include <stdlib.h>
14
Taylor Brandstetterea7fbfb2020-08-19 16:41:54 -070015#include <algorithm>
jbauch555604a2016-04-26 03:13:22 -070016#include <memory>
henrike@webrtc.orgf0488722014-05-13 18:00:26 +000017#include <vector>
oprypin1ea631f2017-08-18 00:15:19 -070018
Taylor Brandstetterea7fbfb2020-08-19 16:41:54 -070019#include "absl/algorithm/container.h"
Mirko Bonadei06d35592020-04-01 13:43:08 +020020#include "absl/strings/match.h"
Ali Tofigh7fa90572022-03-17 15:47:49 +010021#include "absl/strings/string_view.h"
Mirko Bonadei92ea95e2017-09-15 06:47:31 +020022#include "rtc_base/checks.h"
Steve Anton10542f22019-01-11 09:11:00 -080023#include "rtc_base/net_helpers.h"
24#include "rtc_base/network_monitor.h"
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -070025#include "rtc_base/network_monitor_factory.h"
Niels Mölleraa373162021-09-28 16:09:07 +020026#include "rtc_base/physical_socket_server.h"
henrike@webrtc.orgf0488722014-05-13 18:00:26 +000027#if defined(WEBRTC_POSIX)
Henrik Kjellander00725112017-06-30 15:14:45 +020028#include <net/if.h>
Yves Gerey665174f2018-06-19 15:03:05 +020029#include <sys/types.h>
Jonas Olssona4d87372019-07-05 19:08:33 +020030
Mirko Bonadei92ea95e2017-09-15 06:47:31 +020031#include "rtc_base/ifaddrs_converter.h"
Guo-wei Shieh9faf1542015-12-28 14:06:55 -080032#endif // defined(WEBRTC_POSIX)
Mirko Bonadei92ea95e2017-09-15 06:47:31 +020033#include "rtc_base/gunit.h"
Steve Anton2acd1632019-03-25 13:48:30 -070034#include "test/gmock.h"
henrike@webrtc.orgf0488722014-05-13 18:00:26 +000035#if defined(WEBRTC_WIN)
Mirko Bonadei675513b2017-11-09 11:09:25 +010036#include "rtc_base/logging.h" // For RTC_LOG_GLE
henrike@webrtc.orgf0488722014-05-13 18:00:26 +000037#endif
Jonas Oreland47fa08f2020-12-05 18:09:13 +010038#include "test/field_trial.h"
Jonas Orelandc06fe8b2022-03-28 14:58:26 +020039#include "test/scoped_key_value_config.h"
henrike@webrtc.orgf0488722014-05-13 18:00:26 +000040
Steve Anton2acd1632019-03-25 13:48:30 -070041using ::testing::Contains;
42using ::testing::Not;
43using ::testing::UnorderedElementsAre;
44using ::testing::UnorderedElementsAreArray;
45
henrike@webrtc.orgf0488722014-05-13 18:00:26 +000046namespace rtc {
47
Guo-wei Shieh9faf1542015-12-28 14:06:55 -080048namespace {
49
Ali Tofigh7fa90572022-03-17 15:47:49 +010050IPAddress IPFromString(absl::string_view str) {
Jonas Oreland2ee0e642021-08-25 15:43:02 +020051 IPAddress ip;
52 RTC_CHECK(IPFromString(str, &ip));
53 return ip;
54}
55
Taylor Brandstetter32eb03a2020-09-11 17:15:30 +000056class FakeNetworkMonitor : public NetworkMonitorInterface {
honghaiz023f3ef2015-10-19 09:39:32 -070057 public:
honghaizcec0a082016-01-15 14:49:09 -080058 void Start() override { started_ = true; }
59 void Stop() override { started_ = false; }
60 bool started() { return started_; }
Jonas Oreland61dbcd12022-05-31 11:34:20 +020061 InterfaceInfo GetInterfaceInfo(absl::string_view if_name) override {
62 InterfaceInfo if_info = {
63 .adapter_type = ADAPTER_TYPE_UNKNOWN,
64 .available = absl::c_count(unavailable_adapters_, if_name) == 0,
65 };
Mirko Bonadei06d35592020-04-01 13:43:08 +020066 if (absl::StartsWith(if_name, "wifi")) {
Jonas Oreland61dbcd12022-05-31 11:34:20 +020067 if_info.adapter_type = ADAPTER_TYPE_WIFI;
68 } else if (absl::StartsWith(if_name, "cellular")) {
69 if_info.adapter_type = ADAPTER_TYPE_CELLULAR;
Honghai Zhang351d77b2016-05-20 15:08:29 -070070 }
Jonas Oreland61dbcd12022-05-31 11:34:20 +020071 return if_info;
Taylor Brandstetterea7fbfb2020-08-19 16:41:54 -070072 }
73
74 // Used to test IsAdapterAvailable.
75 void set_unavailable_adapters(std::vector<std::string> unavailable_adapters) {
76 unavailable_adapters_ = unavailable_adapters;
77 }
78
Jonas Oreland6ca955a2021-03-15 08:27:43 +000079 bool SupportsBindSocketToNetwork() const override { return true; }
80
Ali Tofigh7fa90572022-03-17 15:47:49 +010081 NetworkBindingResult BindSocketToNetwork(int socket_fd,
82 const IPAddress& address,
83 absl::string_view if_name) override {
Jonas Oreland6ca955a2021-03-15 08:27:43 +000084 if (absl::c_count(addresses_, address) > 0) {
85 return NetworkBindingResult::SUCCESS;
86 }
87
88 for (auto const& iter : adapters_) {
Ali Tofigh7fa90572022-03-17 15:47:49 +010089 if (if_name.find(iter) != absl::string_view::npos) {
Jonas Oreland6ca955a2021-03-15 08:27:43 +000090 return NetworkBindingResult::SUCCESS;
91 }
92 }
93 return NetworkBindingResult::ADDRESS_NOT_FOUND;
94 }
95
96 void set_ip_addresses(std::vector<IPAddress> addresses) {
97 addresses_ = addresses;
98 }
99
100 void set_adapters(std::vector<std::string> adapters) { adapters_ = adapters; }
101
Mirko Bonadei37077932021-07-27 17:00:58 +0200102 void InovkeNetworksChangedCallbackForTesting() {
103 InvokeNetworksChangedCallback();
104 }
105
honghaizcec0a082016-01-15 14:49:09 -0800106 private:
107 bool started_ = false;
Jonas Oreland6ca955a2021-03-15 08:27:43 +0000108 std::vector<std::string> adapters_;
Taylor Brandstetterea7fbfb2020-08-19 16:41:54 -0700109 std::vector<std::string> unavailable_adapters_;
Jonas Oreland6ca955a2021-03-15 08:27:43 +0000110 std::vector<IPAddress> addresses_;
honghaiz023f3ef2015-10-19 09:39:32 -0700111};
112
113class FakeNetworkMonitorFactory : public NetworkMonitorFactory {
114 public:
115 FakeNetworkMonitorFactory() {}
Jonas Orelandc06fe8b2022-03-28 14:58:26 +0200116 NetworkMonitorInterface* CreateNetworkMonitor(
Jonas Orelande62c2f22022-03-29 11:04:48 +0200117 const webrtc::FieldTrialsView& field_trials) override {
honghaiz023f3ef2015-10-19 09:39:32 -0700118 return new FakeNetworkMonitor();
119 }
120};
121
Qingsi Wang10a0e512018-05-16 13:37:03 -0700122bool SameNameAndPrefix(const rtc::Network& a, const rtc::Network& b) {
123 if (a.name() != b.name()) {
Harald Alvestrand97597c02021-11-04 12:01:23 +0000124 RTC_LOG(LS_INFO) << "Different interface names.";
Qingsi Wang10a0e512018-05-16 13:37:03 -0700125 return false;
126 }
127 if (a.prefix_length() != b.prefix_length() || a.prefix() != b.prefix()) {
Harald Alvestrand97597c02021-11-04 12:01:23 +0000128 RTC_LOG(LS_INFO) << "Different IP prefixes.";
Qingsi Wang10a0e512018-05-16 13:37:03 -0700129 return false;
130 }
131 return true;
132}
133
Niels Möllerd959f3a2022-04-19 11:29:19 +0200134std::vector<const Network*> CopyNetworkPointers(
135 const std::vector<std::unique_ptr<Network>>& owning_list) {
136 std::vector<const Network*> ptr_list;
137 ptr_list.reserve(owning_list.size());
138 for (const auto& network : owning_list) {
139 ptr_list.push_back(network.get());
140 }
141 return ptr_list;
142}
143
Guo-wei Shieh9faf1542015-12-28 14:06:55 -0800144} // namespace
145
Mirko Bonadei6a489f22019-04-09 15:11:12 +0200146class NetworkTest : public ::testing::Test, public sigslot::has_slots<> {
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000147 public:
148 NetworkTest() : callback_called_(false) {}
149
Yves Gerey665174f2018-06-19 15:03:05 +0200150 void OnNetworksChanged() { callback_called_ = true; }
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000151
guoweis@webrtc.orga094cac2015-01-28 19:34:05 +0000152 NetworkManager::Stats MergeNetworkList(
153 BasicNetworkManager& network_manager,
Niels Möllerd959f3a2022-04-19 11:29:19 +0200154 std::vector<std::unique_ptr<Network>> list,
guoweis@webrtc.orga094cac2015-01-28 19:34:05 +0000155 bool* changed) {
156 NetworkManager::Stats stats;
Niels Möllerd959f3a2022-04-19 11:29:19 +0200157 network_manager.MergeNetworkList(std::move(list), changed, &stats);
guoweis@webrtc.orga094cac2015-01-28 19:34:05 +0000158 return stats;
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000159 }
160
161 bool IsIgnoredNetwork(BasicNetworkManager& network_manager,
162 const Network& network) {
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -0700163 RTC_DCHECK_RUN_ON(network_manager.thread_);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000164 return network_manager.IsIgnoredNetwork(network);
165 }
166
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -0700167 IPAddress QueryDefaultLocalAddress(BasicNetworkManager& network_manager,
168 int family) {
169 RTC_DCHECK_RUN_ON(network_manager.thread_);
170 return network_manager.QueryDefaultLocalAddress(family);
171 }
172
Niels Möllerd959f3a2022-04-19 11:29:19 +0200173 std::vector<std::unique_ptr<Network>> GetNetworks(
Yves Gerey665174f2018-06-19 15:03:05 +0200174 const BasicNetworkManager& network_manager,
175 bool include_ignored) {
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -0700176 RTC_DCHECK_RUN_ON(network_manager.thread_);
Niels Möllerd959f3a2022-04-19 11:29:19 +0200177 std::vector<std::unique_ptr<Network>> list;
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000178 network_manager.CreateNetworks(include_ignored, &list);
179 return list;
180 }
181
honghaizcec0a082016-01-15 14:49:09 -0800182 FakeNetworkMonitor* GetNetworkMonitor(BasicNetworkManager& network_manager) {
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -0700183 RTC_DCHECK_RUN_ON(network_manager.thread_);
honghaizcec0a082016-01-15 14:49:09 -0800184 return static_cast<FakeNetworkMonitor*>(
185 network_manager.network_monitor_.get());
honghaiz023f3ef2015-10-19 09:39:32 -0700186 }
187 void ClearNetworks(BasicNetworkManager& network_manager) {
honghaiz023f3ef2015-10-19 09:39:32 -0700188 network_manager.networks_.clear();
189 network_manager.networks_map_.clear();
190 }
191
Honghai Zhang351d77b2016-05-20 15:08:29 -0700192 AdapterType GetAdapterType(BasicNetworkManager& network_manager) {
Niels Möller22211442022-04-07 11:43:28 +0200193 std::vector<const Network*> list = network_manager.GetNetworks();
nissec16fa5e2017-02-07 07:18:43 -0800194 RTC_CHECK_EQ(1, list.size());
Honghai Zhang351d77b2016-05-20 15:08:29 -0700195 return list[0]->type();
196 }
197
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000198#if defined(WEBRTC_POSIX)
199 // Separated from CreateNetworks for tests.
Niels Möllerd959f3a2022-04-19 11:29:19 +0200200 static void CallConvertIfAddrs(
201 const BasicNetworkManager& network_manager,
202 struct ifaddrs* interfaces,
203 bool include_ignored,
204 std::vector<std::unique_ptr<Network>>* networks) {
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -0700205 RTC_DCHECK_RUN_ON(network_manager.thread_);
Guo-wei Shieh9faf1542015-12-28 14:06:55 -0800206 // Use the base IfAddrsConverter for test cases.
jbauch555604a2016-04-26 03:13:22 -0700207 std::unique_ptr<IfAddrsConverter> ifaddrs_converter(new IfAddrsConverter());
Guo-wei Shieh9faf1542015-12-28 14:06:55 -0800208 network_manager.ConvertIfAddrs(interfaces, ifaddrs_converter.get(),
209 include_ignored, networks);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000210 }
honghaizdb8cf502015-12-21 13:08:46 -0800211
Ali Tofigh7fa90572022-03-17 15:47:49 +0100212 struct sockaddr_in6* CreateIpv6Addr(absl::string_view ip_string,
honghaizdb8cf502015-12-21 13:08:46 -0800213 uint32_t scope_id) {
Yves Gerey665174f2018-06-19 15:03:05 +0200214 struct sockaddr_in6* ipv6_addr =
215 static_cast<struct sockaddr_in6*>(malloc(sizeof(struct sockaddr_in6)));
honghaizdb8cf502015-12-21 13:08:46 -0800216 memset(ipv6_addr, 0, sizeof(struct sockaddr_in6));
217 ipv6_addr->sin6_family = AF_INET6;
218 ipv6_addr->sin6_scope_id = scope_id;
219 IPAddress ip;
220 IPFromString(ip_string, &ip);
221 ipv6_addr->sin6_addr = ip.ipv6_address();
222 return ipv6_addr;
223 }
224
225 // Pointers created here need to be released via ReleaseIfAddrs.
226 struct ifaddrs* AddIpv6Address(struct ifaddrs* list,
227 char* if_name,
Ali Tofigh7fa90572022-03-17 15:47:49 +0100228 absl::string_view ipv6_address,
229 absl::string_view ipv6_netmask,
honghaizdb8cf502015-12-21 13:08:46 -0800230 uint32_t scope_id) {
231 struct ifaddrs* if_addr = new struct ifaddrs;
232 memset(if_addr, 0, sizeof(struct ifaddrs));
233 if_addr->ifa_name = if_name;
234 if_addr->ifa_addr = reinterpret_cast<struct sockaddr*>(
235 CreateIpv6Addr(ipv6_address, scope_id));
236 if_addr->ifa_netmask =
237 reinterpret_cast<struct sockaddr*>(CreateIpv6Addr(ipv6_netmask, 0));
238 if_addr->ifa_next = list;
Guo-wei Shieh9faf1542015-12-28 14:06:55 -0800239 if_addr->ifa_flags = IFF_RUNNING;
honghaizdb8cf502015-12-21 13:08:46 -0800240 return if_addr;
241 }
242
Honghai Zhang351d77b2016-05-20 15:08:29 -0700243 struct ifaddrs* InstallIpv6Network(char* if_name,
Ali Tofigh7fa90572022-03-17 15:47:49 +0100244 absl::string_view ipv6_address,
245 absl::string_view ipv6_mask,
Honghai Zhang351d77b2016-05-20 15:08:29 -0700246 BasicNetworkManager& network_manager) {
247 ifaddrs* addr_list = nullptr;
248 addr_list = AddIpv6Address(addr_list, if_name, ipv6_address, ipv6_mask, 0);
Niels Möllerd959f3a2022-04-19 11:29:19 +0200249 std::vector<std::unique_ptr<Network>> result;
Honghai Zhang351d77b2016-05-20 15:08:29 -0700250 bool changed;
251 NetworkManager::Stats stats;
252 CallConvertIfAddrs(network_manager, addr_list, true, &result);
Niels Möllerd959f3a2022-04-19 11:29:19 +0200253 network_manager.MergeNetworkList(std::move(result), &changed, &stats);
Honghai Zhang351d77b2016-05-20 15:08:29 -0700254 return addr_list;
255 }
256
Ali Tofigh7fa90572022-03-17 15:47:49 +0100257 struct sockaddr_in* CreateIpv4Addr(absl::string_view ip_string) {
Jeroen de Borst8f096d02019-02-21 13:34:45 -0800258 struct sockaddr_in* ipv4_addr =
259 static_cast<struct sockaddr_in*>(malloc(sizeof(struct sockaddr_in)));
260 memset(ipv4_addr, 0, sizeof(struct sockaddr_in));
261 ipv4_addr->sin_family = AF_INET;
262 IPAddress ip;
263 IPFromString(ip_string, &ip);
264 ipv4_addr->sin_addr = ip.ipv4_address();
265 return ipv4_addr;
266 }
267
268 // Pointers created here need to be released via ReleaseIfAddrs.
269 struct ifaddrs* AddIpv4Address(struct ifaddrs* list,
270 char* if_name,
Ali Tofigh7fa90572022-03-17 15:47:49 +0100271 absl::string_view ipv4_address,
272 absl::string_view ipv4_netmask) {
Jeroen de Borst8f096d02019-02-21 13:34:45 -0800273 struct ifaddrs* if_addr = new struct ifaddrs;
274 memset(if_addr, 0, sizeof(struct ifaddrs));
275 if_addr->ifa_name = if_name;
276 if_addr->ifa_addr =
277 reinterpret_cast<struct sockaddr*>(CreateIpv4Addr(ipv4_address));
278 if_addr->ifa_netmask =
279 reinterpret_cast<struct sockaddr*>(CreateIpv4Addr(ipv4_netmask));
280 if_addr->ifa_next = list;
281 if_addr->ifa_flags = IFF_RUNNING;
282 return if_addr;
283 }
284
285 struct ifaddrs* InstallIpv4Network(char* if_name,
Ali Tofigh7fa90572022-03-17 15:47:49 +0100286 absl::string_view ipv4_address,
287 absl::string_view ipv4_mask,
Jeroen de Borst8f096d02019-02-21 13:34:45 -0800288 BasicNetworkManager& network_manager) {
289 ifaddrs* addr_list = nullptr;
290 addr_list = AddIpv4Address(addr_list, if_name, ipv4_address, ipv4_mask);
Niels Möllerd959f3a2022-04-19 11:29:19 +0200291 std::vector<std::unique_ptr<Network>> result;
Jeroen de Borst8f096d02019-02-21 13:34:45 -0800292 bool changed;
293 NetworkManager::Stats stats;
294 CallConvertIfAddrs(network_manager, addr_list, true, &result);
Niels Möllerd959f3a2022-04-19 11:29:19 +0200295 network_manager.MergeNetworkList(std::move(result), &changed, &stats);
Jeroen de Borst8f096d02019-02-21 13:34:45 -0800296 return addr_list;
297 }
298
honghaizdb8cf502015-12-21 13:08:46 -0800299 void ReleaseIfAddrs(struct ifaddrs* list) {
300 struct ifaddrs* if_addr = list;
301 while (if_addr != nullptr) {
302 struct ifaddrs* next_addr = if_addr->ifa_next;
oprypin1ea631f2017-08-18 00:15:19 -0700303 free(if_addr->ifa_addr);
304 free(if_addr->ifa_netmask);
honghaizdb8cf502015-12-21 13:08:46 -0800305 delete if_addr;
306 if_addr = next_addr;
307 }
308 }
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000309#endif // defined(WEBRTC_POSIX)
310
311 protected:
Jonas Orelandc06fe8b2022-03-28 14:58:26 +0200312 webrtc::test::ScopedKeyValueConfig field_trials_;
Niels Möller83830f32022-05-20 09:12:57 +0200313 rtc::AutoThread main_thread_;
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000314 bool callback_called_;
315};
316
Guo-wei Shieh9af97f82015-11-10 14:47:39 -0800317class TestBasicNetworkManager : public BasicNetworkManager {
318 public:
Niels Mölleraa373162021-09-28 16:09:07 +0200319 TestBasicNetworkManager(NetworkMonitorFactory* network_monitor_factory,
Jonas Orelandc06fe8b2022-03-28 14:58:26 +0200320 SocketFactory* socket_factory,
Jonas Orelande62c2f22022-03-29 11:04:48 +0200321 const webrtc::FieldTrialsView& field_trials)
Jonas Orelandc06fe8b2022-03-28 14:58:26 +0200322 : BasicNetworkManager(network_monitor_factory,
323 socket_factory,
324 &field_trials) {}
Guo-wei Shieh9af97f82015-11-10 14:47:39 -0800325 using BasicNetworkManager::QueryDefaultLocalAddress;
Guo-wei Shieha34c39e2015-11-25 13:12:26 -0800326 using BasicNetworkManager::set_default_local_addresses;
Guo-wei Shieh9af97f82015-11-10 14:47:39 -0800327};
328
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000329// Test that the Network ctor works properly.
330TEST_F(NetworkTest, TestNetworkConstruct) {
331 Network ipv4_network1("test_eth0", "Test Network Adapter 1",
332 IPAddress(0x12345600U), 24);
333 EXPECT_EQ("test_eth0", ipv4_network1.name());
334 EXPECT_EQ("Test Network Adapter 1", ipv4_network1.description());
335 EXPECT_EQ(IPAddress(0x12345600U), ipv4_network1.prefix());
336 EXPECT_EQ(24, ipv4_network1.prefix_length());
337 EXPECT_FALSE(ipv4_network1.ignored());
338}
339
phoglund@webrtc.org006521d2015-02-12 09:23:59 +0000340TEST_F(NetworkTest, TestIsIgnoredNetworkIgnoresIPsStartingWith0) {
341 Network ipv4_network1("test_eth0", "Test Network Adapter 1",
342 IPAddress(0x12345600U), 24, ADAPTER_TYPE_ETHERNET);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000343 Network ipv4_network2("test_eth1", "Test Network Adapter 2",
phoglund@webrtc.org006521d2015-02-12 09:23:59 +0000344 IPAddress(0x010000U), 24, ADAPTER_TYPE_ETHERNET);
Niels Möller539f3e12021-11-26 16:33:19 +0100345 PhysicalSocketServer socket_server;
346 BasicNetworkManager network_manager(&socket_server);
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -0700347 network_manager.StartUpdating();
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000348 EXPECT_FALSE(IsIgnoredNetwork(network_manager, ipv4_network1));
349 EXPECT_TRUE(IsIgnoredNetwork(network_manager, ipv4_network2));
350}
351
phoglund@webrtc.org006521d2015-02-12 09:23:59 +0000352// TODO(phoglund): Remove when ignore list goes away.
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000353TEST_F(NetworkTest, TestIgnoreList) {
Yves Gerey665174f2018-06-19 15:03:05 +0200354 Network ignore_me("ignore_me", "Ignore me please!", IPAddress(0x12345600U),
355 24);
356 Network include_me("include_me", "Include me please!", IPAddress(0x12345600U),
357 24);
Niels Möller539f3e12021-11-26 16:33:19 +0100358 PhysicalSocketServer socket_server;
359 BasicNetworkManager default_network_manager(&socket_server);
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -0700360 default_network_manager.StartUpdating();
361 EXPECT_FALSE(IsIgnoredNetwork(default_network_manager, ignore_me));
362 EXPECT_FALSE(IsIgnoredNetwork(default_network_manager, include_me));
363
Niels Möller539f3e12021-11-26 16:33:19 +0100364 BasicNetworkManager ignoring_network_manager(&socket_server);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000365 std::vector<std::string> ignore_list;
366 ignore_list.push_back("ignore_me");
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -0700367 ignoring_network_manager.set_network_ignore_list(ignore_list);
368 ignoring_network_manager.StartUpdating();
369 EXPECT_TRUE(IsIgnoredNetwork(ignoring_network_manager, ignore_me));
370 EXPECT_FALSE(IsIgnoredNetwork(ignoring_network_manager, include_me));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000371}
372
373// Test is failing on Windows opt: b/11288214
374TEST_F(NetworkTest, DISABLED_TestCreateNetworks) {
Niels Möller539f3e12021-11-26 16:33:19 +0100375 PhysicalSocketServer socket_server;
376 BasicNetworkManager manager(&socket_server);
Niels Möllerd959f3a2022-04-19 11:29:19 +0200377 std::vector<std::unique_ptr<Network>> result = GetNetworks(manager, true);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000378 // We should be able to bind to any addresses we find.
Niels Möllerd959f3a2022-04-19 11:29:19 +0200379 for (auto it = result.begin(); it != result.end(); ++it) {
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000380 sockaddr_storage storage;
381 memset(&storage, 0, sizeof(storage));
guoweis@webrtc.org369a6372014-09-17 22:37:29 +0000382 IPAddress ip = (*it)->GetBestIP();
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000383 SocketAddress bindaddress(ip, 0);
384 bindaddress.SetScopeID((*it)->scope_id());
Niels Möllerd0b88792021-08-12 10:32:30 +0200385 // TODO(thaloun): Use rtc::Socket once it supports IPv6.
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000386 int fd = static_cast<int>(socket(ip.family(), SOCK_STREAM, IPPROTO_TCP));
387 if (fd > 0) {
388 size_t ipsize = bindaddress.ToSockAddrStorage(&storage);
389 EXPECT_GE(ipsize, 0U);
Yves Gerey665174f2018-06-19 15:03:05 +0200390 int success = ::bind(fd, reinterpret_cast<sockaddr*>(&storage),
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000391 static_cast<int>(ipsize));
392#if defined(WEBRTC_WIN)
Mirko Bonadei675513b2017-11-09 11:09:25 +0100393 if (success)
394 RTC_LOG_GLE(LS_ERROR) << "Socket bind failed.";
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000395#endif
396 EXPECT_EQ(0, success);
397#if defined(WEBRTC_WIN)
398 closesocket(fd);
399#else
400 close(fd);
401#endif
402 }
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000403 }
404}
405
Guo-wei Shieh47872ec2015-08-19 10:32:46 -0700406// Test StartUpdating() and StopUpdating(). network_permission_state starts with
407// ALLOWED.
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000408TEST_F(NetworkTest, TestUpdateNetworks) {
Niels Mölleraa373162021-09-28 16:09:07 +0200409 PhysicalSocketServer socket_server;
Jonas Orelandc06fe8b2022-03-28 14:58:26 +0200410 BasicNetworkManager manager(nullptr, &socket_server, &field_trials_);
Yves Gerey665174f2018-06-19 15:03:05 +0200411 manager.SignalNetworksChanged.connect(static_cast<NetworkTest*>(this),
412 &NetworkTest::OnNetworksChanged);
guoweisea1012b2015-08-21 09:06:28 -0700413 EXPECT_EQ(NetworkManager::ENUMERATION_ALLOWED,
414 manager.enumeration_permission());
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000415 manager.StartUpdating();
416 Thread::Current()->ProcessMessages(0);
417 EXPECT_TRUE(callback_called_);
418 callback_called_ = false;
419 // Callback should be triggered immediately when StartUpdating
420 // is called, after network update signal is already sent.
421 manager.StartUpdating();
422 EXPECT_TRUE(manager.started());
423 Thread::Current()->ProcessMessages(0);
424 EXPECT_TRUE(callback_called_);
425 manager.StopUpdating();
426 EXPECT_TRUE(manager.started());
427 manager.StopUpdating();
guoweisea1012b2015-08-21 09:06:28 -0700428 EXPECT_EQ(NetworkManager::ENUMERATION_ALLOWED,
429 manager.enumeration_permission());
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000430 EXPECT_FALSE(manager.started());
431 manager.StopUpdating();
432 EXPECT_FALSE(manager.started());
433 callback_called_ = false;
434 // Callback should be triggered immediately after StartUpdating is called
435 // when start_count_ is reset to 0.
436 manager.StartUpdating();
437 Thread::Current()->ProcessMessages(0);
438 EXPECT_TRUE(callback_called_);
439}
440
441// Verify that MergeNetworkList() merges network lists properly.
442TEST_F(NetworkTest, TestBasicMergeNetworkList) {
443 Network ipv4_network1("test_eth0", "Test Network Adapter 1",
444 IPAddress(0x12345600U), 24);
445 Network ipv4_network2("test_eth1", "Test Network Adapter 2",
446 IPAddress(0x00010000U), 16);
447 ipv4_network1.AddIP(IPAddress(0x12345678));
448 ipv4_network2.AddIP(IPAddress(0x00010004));
Niels Möller539f3e12021-11-26 16:33:19 +0100449 PhysicalSocketServer socket_server;
450 BasicNetworkManager manager(&socket_server);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000451
452 // Add ipv4_network1 to the list of networks.
Niels Möllerd959f3a2022-04-19 11:29:19 +0200453 std::vector<std::unique_ptr<Network>> list;
454 list.push_back(std::make_unique<Network>(ipv4_network1));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000455 bool changed;
Niels Möllerd959f3a2022-04-19 11:29:19 +0200456 NetworkManager::Stats stats =
457 MergeNetworkList(manager, std::move(list), &changed);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000458 EXPECT_TRUE(changed);
guoweis@webrtc.orga094cac2015-01-28 19:34:05 +0000459 EXPECT_EQ(stats.ipv6_network_count, 0);
460 EXPECT_EQ(stats.ipv4_network_count, 1);
Niels Möllerd959f3a2022-04-19 11:29:19 +0200461 list.clear(); // It is fine to call .clear() on a moved-from vector.
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000462
Niels Möller22211442022-04-07 11:43:28 +0200463 std::vector<const rtc::Network*> current = manager.GetNetworks();
464 EXPECT_EQ(1U, current.size());
465 EXPECT_TRUE(SameNameAndPrefix(ipv4_network1, *current[0]));
466 const Network* net1 = current[0];
honghaiza0c44ea2016-03-23 16:07:48 -0700467 uint16_t net_id1 = net1->id();
468 EXPECT_EQ(1, net_id1);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000469
470 // Replace ipv4_network1 with ipv4_network2.
Niels Möllerd959f3a2022-04-19 11:29:19 +0200471 list.push_back(std::make_unique<Network>(ipv4_network2));
472 stats = MergeNetworkList(manager, std::move(list), &changed);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000473 EXPECT_TRUE(changed);
guoweis@webrtc.orga094cac2015-01-28 19:34:05 +0000474 EXPECT_EQ(stats.ipv6_network_count, 0);
475 EXPECT_EQ(stats.ipv4_network_count, 1);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000476 list.clear();
477
Niels Möller22211442022-04-07 11:43:28 +0200478 current = manager.GetNetworks();
479 EXPECT_EQ(1U, current.size());
480 EXPECT_TRUE(SameNameAndPrefix(ipv4_network2, *current[0]));
481 const Network* net2 = current[0];
honghaiza0c44ea2016-03-23 16:07:48 -0700482 uint16_t net_id2 = net2->id();
483 // Network id will increase.
484 EXPECT_LT(net_id1, net_id2);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000485
486 // Add Network2 back.
Niels Möllerd959f3a2022-04-19 11:29:19 +0200487 list.push_back(std::make_unique<Network>(ipv4_network1));
488 list.push_back(std::make_unique<Network>(ipv4_network2));
489 stats = MergeNetworkList(manager, std::move(list), &changed);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000490 EXPECT_TRUE(changed);
guoweis@webrtc.orga094cac2015-01-28 19:34:05 +0000491 EXPECT_EQ(stats.ipv6_network_count, 0);
492 EXPECT_EQ(stats.ipv4_network_count, 2);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000493 list.clear();
494
495 // Verify that we get previous instances of Network objects.
Niels Möller22211442022-04-07 11:43:28 +0200496 current = manager.GetNetworks();
497 EXPECT_EQ(2U, current.size());
498 EXPECT_TRUE((net1 == current[0] && net2 == current[1]) ||
499 (net1 == current[1] && net2 == current[0]));
500 EXPECT_TRUE((net_id1 == current[0]->id() && net_id2 == current[1]->id()) ||
501 (net_id1 == current[1]->id() && net_id2 == current[0]->id()));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000502
503 // Call MergeNetworkList() again and verify that we don't get update
504 // notification.
Niels Möllerd959f3a2022-04-19 11:29:19 +0200505 list.push_back(std::make_unique<Network>(ipv4_network2));
506 list.push_back(std::make_unique<Network>(ipv4_network1));
507 stats = MergeNetworkList(manager, std::move(list), &changed);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000508 EXPECT_FALSE(changed);
guoweis@webrtc.orga094cac2015-01-28 19:34:05 +0000509 EXPECT_EQ(stats.ipv6_network_count, 0);
510 EXPECT_EQ(stats.ipv4_network_count, 2);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000511 list.clear();
512
513 // Verify that we get previous instances of Network objects.
Niels Möller22211442022-04-07 11:43:28 +0200514 current = manager.GetNetworks();
515 EXPECT_EQ(2U, current.size());
516 EXPECT_TRUE((net1 == current[0] && net2 == current[1]) ||
517 (net1 == current[1] && net2 == current[0]));
518 EXPECT_TRUE((net_id1 == current[0]->id() && net_id2 == current[1]->id()) ||
519 (net_id1 == current[1]->id() && net_id2 == current[0]->id()));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000520}
521
522// Sets up some test IPv6 networks and appends them to list.
523// Four networks are added - public and link local, for two interfaces.
Niels Möllerd959f3a2022-04-19 11:29:19 +0200524void SetupNetworks(std::vector<std::unique_ptr<Network>>* list) {
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000525 IPAddress ip;
526 IPAddress prefix;
guoweis@webrtc.orgbbce5ef2015-03-05 04:38:29 +0000527 EXPECT_TRUE(IPFromString("abcd::1234:5678:abcd:ef12", &ip));
528 EXPECT_TRUE(IPFromString("abcd::", &prefix));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000529 // First, fake link-locals.
530 Network ipv6_eth0_linklocalnetwork("test_eth0", "Test NetworkAdapter 1",
531 prefix, 64);
532 ipv6_eth0_linklocalnetwork.AddIP(ip);
guoweis@webrtc.orgbbce5ef2015-03-05 04:38:29 +0000533 EXPECT_TRUE(IPFromString("abcd::5678:abcd:ef12:3456", &ip));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000534 Network ipv6_eth1_linklocalnetwork("test_eth1", "Test NetworkAdapter 2",
535 prefix, 64);
536 ipv6_eth1_linklocalnetwork.AddIP(ip);
537 // Public networks:
538 EXPECT_TRUE(IPFromString("2401:fa00:4:1000:be30:5bff:fee5:c3", &ip));
539 prefix = TruncateIP(ip, 64);
540 Network ipv6_eth0_publicnetwork1_ip1("test_eth0", "Test NetworkAdapter 1",
541 prefix, 64);
542 ipv6_eth0_publicnetwork1_ip1.AddIP(ip);
543 EXPECT_TRUE(IPFromString("2400:4030:1:2c00:be30:abcd:efab:cdef", &ip));
544 prefix = TruncateIP(ip, 64);
545 Network ipv6_eth1_publicnetwork1_ip1("test_eth1", "Test NetworkAdapter 1",
546 prefix, 64);
547 ipv6_eth1_publicnetwork1_ip1.AddIP(ip);
Niels Möllerd959f3a2022-04-19 11:29:19 +0200548 list->push_back(std::make_unique<Network>(ipv6_eth0_linklocalnetwork));
549 list->push_back(std::make_unique<Network>(ipv6_eth1_linklocalnetwork));
550 list->push_back(std::make_unique<Network>(ipv6_eth0_publicnetwork1_ip1));
551 list->push_back(std::make_unique<Network>(ipv6_eth1_publicnetwork1_ip1));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000552}
553
554// Test that the basic network merging case works.
555TEST_F(NetworkTest, TestIPv6MergeNetworkList) {
Niels Möller539f3e12021-11-26 16:33:19 +0100556 PhysicalSocketServer socket_server;
557 BasicNetworkManager manager(&socket_server);
Yves Gerey665174f2018-06-19 15:03:05 +0200558 manager.SignalNetworksChanged.connect(static_cast<NetworkTest*>(this),
559 &NetworkTest::OnNetworksChanged);
Niels Möllerd959f3a2022-04-19 11:29:19 +0200560 std::vector<std::unique_ptr<Network>> networks;
561 SetupNetworks(&networks);
562 std::vector<const Network*> original_list = CopyNetworkPointers(networks);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000563 bool changed = false;
guoweis@webrtc.orga094cac2015-01-28 19:34:05 +0000564 NetworkManager::Stats stats =
Niels Möllerd959f3a2022-04-19 11:29:19 +0200565 MergeNetworkList(manager, std::move(networks), &changed);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000566 EXPECT_TRUE(changed);
guoweis@webrtc.orga094cac2015-01-28 19:34:05 +0000567 EXPECT_EQ(stats.ipv6_network_count, 4);
568 EXPECT_EQ(stats.ipv4_network_count, 0);
Niels Möller22211442022-04-07 11:43:28 +0200569 std::vector<const Network*> list = manager.GetNetworks();
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000570 // Verify that the original members are in the merged list.
Steve Anton2acd1632019-03-25 13:48:30 -0700571 EXPECT_THAT(list, UnorderedElementsAreArray(original_list));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000572}
573
574// Tests that when two network lists that describe the same set of networks are
575// merged, that the changed callback is not called, and that the original
576// objects remain in the result list.
577TEST_F(NetworkTest, TestNoChangeMerge) {
Niels Möller539f3e12021-11-26 16:33:19 +0100578 PhysicalSocketServer socket_server;
579 BasicNetworkManager manager(&socket_server);
Yves Gerey665174f2018-06-19 15:03:05 +0200580 manager.SignalNetworksChanged.connect(static_cast<NetworkTest*>(this),
581 &NetworkTest::OnNetworksChanged);
Niels Möllerd959f3a2022-04-19 11:29:19 +0200582 std::vector<std::unique_ptr<Network>> networks;
583 SetupNetworks(&networks);
584 std::vector<const Network*> original_list = CopyNetworkPointers(networks);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000585 bool changed = false;
Niels Möllerd959f3a2022-04-19 11:29:19 +0200586 MergeNetworkList(manager, std::move(networks), &changed);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000587 EXPECT_TRUE(changed);
588 // Second list that describes the same networks but with new objects.
Niels Möllerd959f3a2022-04-19 11:29:19 +0200589 std::vector<std::unique_ptr<Network>> second_networks;
590 SetupNetworks(&second_networks);
591 std::vector<const Network*> second_list =
592 CopyNetworkPointers(second_networks);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000593 changed = false;
Niels Möllerd959f3a2022-04-19 11:29:19 +0200594 MergeNetworkList(manager, std::move(second_networks), &changed);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000595 EXPECT_FALSE(changed);
Niels Möller22211442022-04-07 11:43:28 +0200596 std::vector<const Network*> resulting_list = manager.GetNetworks();
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000597 // Verify that the original members are in the merged list.
Steve Anton2acd1632019-03-25 13:48:30 -0700598 EXPECT_THAT(resulting_list, UnorderedElementsAreArray(original_list));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000599 // Doublecheck that the new networks aren't in the list.
Steve Anton2acd1632019-03-25 13:48:30 -0700600 for (const Network* network : second_list) {
601 EXPECT_THAT(resulting_list, Not(Contains(network)));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000602 }
603}
604
605// Test that we can merge a network that is the same as another network but with
606// a different IP. The original network should remain in the list, but have its
607// IP changed.
608TEST_F(NetworkTest, MergeWithChangedIP) {
Niels Möller539f3e12021-11-26 16:33:19 +0100609 PhysicalSocketServer socket_server;
610 BasicNetworkManager manager(&socket_server);
Yves Gerey665174f2018-06-19 15:03:05 +0200611 manager.SignalNetworksChanged.connect(static_cast<NetworkTest*>(this),
612 &NetworkTest::OnNetworksChanged);
Niels Möllerd959f3a2022-04-19 11:29:19 +0200613 std::vector<std::unique_ptr<Network>> original_list;
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000614 SetupNetworks(&original_list);
615 // Make a network that we're going to change.
616 IPAddress ip;
617 EXPECT_TRUE(IPFromString("2401:fa01:4:1000:be30:faa:fee:faa", &ip));
618 IPAddress prefix = TruncateIP(ip, 64);
Niels Möllerd959f3a2022-04-19 11:29:19 +0200619 std::unique_ptr<Network> network_to_change = std::make_unique<Network>(
620 "test_eth0", "Test Network Adapter 1", prefix, 64);
621 std::unique_ptr<Network> changed_network =
622 std::make_unique<Network>(*network_to_change);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000623 network_to_change->AddIP(ip);
624 IPAddress changed_ip;
625 EXPECT_TRUE(IPFromString("2401:fa01:4:1000:be30:f00:f00:f00", &changed_ip));
626 changed_network->AddIP(changed_ip);
Niels Möllerd959f3a2022-04-19 11:29:19 +0200627 const Network* const network_to_change_ptr = network_to_change.get();
628 original_list.push_back(std::move(network_to_change));
629 const size_t original_size = original_list.size();
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000630 bool changed = false;
Niels Möllerd959f3a2022-04-19 11:29:19 +0200631 MergeNetworkList(manager, std::move(original_list), &changed);
632 std::vector<std::unique_ptr<Network>> second_list;
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000633 SetupNetworks(&second_list);
Niels Möllerd959f3a2022-04-19 11:29:19 +0200634 second_list.push_back(std::move(changed_network));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000635 changed = false;
Niels Möllerd959f3a2022-04-19 11:29:19 +0200636 MergeNetworkList(manager, std::move(second_list), &changed);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000637 EXPECT_TRUE(changed);
Niels Möller22211442022-04-07 11:43:28 +0200638 std::vector<const Network*> list = manager.GetNetworks();
Niels Möllerd959f3a2022-04-19 11:29:19 +0200639 EXPECT_EQ(original_size, list.size());
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000640 // Make sure the original network is still in the merged list.
Niels Möllerd959f3a2022-04-19 11:29:19 +0200641 EXPECT_THAT(list, Contains(network_to_change_ptr));
642 EXPECT_EQ(changed_ip, network_to_change_ptr->GetIPs().at(0));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000643}
644
Niels Möllerd959f3a2022-04-19 11:29:19 +0200645TEST_F(NetworkTest, TestMultipleIPMergeNetworkList) {
Niels Möller539f3e12021-11-26 16:33:19 +0100646 PhysicalSocketServer socket_server;
647 BasicNetworkManager manager(&socket_server);
Yves Gerey665174f2018-06-19 15:03:05 +0200648 manager.SignalNetworksChanged.connect(static_cast<NetworkTest*>(this),
649 &NetworkTest::OnNetworksChanged);
Niels Möllerd959f3a2022-04-19 11:29:19 +0200650 std::vector<std::unique_ptr<Network>> original_list;
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000651 SetupNetworks(&original_list);
Niels Möllerd959f3a2022-04-19 11:29:19 +0200652 const Network* const network_ptr = original_list[2].get();
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000653 bool changed = false;
Niels Möllerd959f3a2022-04-19 11:29:19 +0200654 MergeNetworkList(manager, std::move(original_list), &changed);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000655 EXPECT_TRUE(changed);
656 IPAddress ip;
657 IPAddress check_ip;
658 IPAddress prefix;
659 // Add a second IP to the public network on eth0 (2401:fa00:4:1000/64).
660 EXPECT_TRUE(IPFromString("2401:fa00:4:1000:be30:5bff:fee5:c6", &ip));
661 prefix = TruncateIP(ip, 64);
662 Network ipv6_eth0_publicnetwork1_ip2("test_eth0", "Test NetworkAdapter 1",
663 prefix, 64);
664 // This is the IP that already existed in the public network on eth0.
665 EXPECT_TRUE(IPFromString("2401:fa00:4:1000:be30:5bff:fee5:c3", &check_ip));
666 ipv6_eth0_publicnetwork1_ip2.AddIP(ip);
Niels Möllerd959f3a2022-04-19 11:29:19 +0200667
668 std::vector<std::unique_ptr<Network>> second_list;
669 SetupNetworks(&second_list);
670 second_list.push_back(
671 std::make_unique<Network>(ipv6_eth0_publicnetwork1_ip2));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000672 changed = false;
Niels Möllerd959f3a2022-04-19 11:29:19 +0200673 const auto network_copy = std::make_unique<Network>(*second_list[2]);
674 MergeNetworkList(manager, std::move(second_list), &changed);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000675 EXPECT_TRUE(changed);
676 // There should still be four networks.
Niels Möller22211442022-04-07 11:43:28 +0200677 std::vector<const Network*> list = manager.GetNetworks();
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000678 EXPECT_EQ(4U, list.size());
679 // Check the gathered IPs.
680 int matchcount = 0;
Niels Möller22211442022-04-07 11:43:28 +0200681 for (const Network* network : list) {
Niels Möllerd959f3a2022-04-19 11:29:19 +0200682 if (SameNameAndPrefix(*network, *network_copy)) {
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000683 ++matchcount;
684 EXPECT_EQ(1, matchcount);
685 // This should be the same network object as before.
Niels Möllerd959f3a2022-04-19 11:29:19 +0200686 EXPECT_EQ(network, network_ptr);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000687 // But with two addresses now.
Niels Möller22211442022-04-07 11:43:28 +0200688 EXPECT_THAT(network->GetIPs(),
Steve Anton2acd1632019-03-25 13:48:30 -0700689 UnorderedElementsAre(InterfaceAddress(check_ip),
690 InterfaceAddress(ip)));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000691 } else {
692 // Check the IP didn't get added anywhere it wasn't supposed to.
Niels Möller22211442022-04-07 11:43:28 +0200693 EXPECT_THAT(network->GetIPs(), Not(Contains(InterfaceAddress(ip))));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000694 }
695 }
696}
697
698// Test that merge correctly distinguishes multiple networks on an interface.
699TEST_F(NetworkTest, TestMultiplePublicNetworksOnOneInterfaceMerge) {
Niels Möller539f3e12021-11-26 16:33:19 +0100700 PhysicalSocketServer socket_server;
701 BasicNetworkManager manager(&socket_server);
Yves Gerey665174f2018-06-19 15:03:05 +0200702 manager.SignalNetworksChanged.connect(static_cast<NetworkTest*>(this),
703 &NetworkTest::OnNetworksChanged);
Niels Möllerd959f3a2022-04-19 11:29:19 +0200704 std::vector<std::unique_ptr<Network>> original_list;
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000705 SetupNetworks(&original_list);
706 bool changed = false;
Niels Möllerd959f3a2022-04-19 11:29:19 +0200707 MergeNetworkList(manager, std::move(original_list), &changed);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000708 EXPECT_TRUE(changed);
709 IPAddress ip;
710 IPAddress prefix;
711 // A second network for eth0.
712 EXPECT_TRUE(IPFromString("2400:4030:1:2c00:be30:5bff:fee5:c3", &ip));
713 prefix = TruncateIP(ip, 64);
714 Network ipv6_eth0_publicnetwork2_ip1("test_eth0", "Test NetworkAdapter 1",
715 prefix, 64);
716 ipv6_eth0_publicnetwork2_ip1.AddIP(ip);
Niels Möllerd959f3a2022-04-19 11:29:19 +0200717 std::vector<std::unique_ptr<Network>> second_list;
718 SetupNetworks(&second_list);
719 second_list.push_back(
720 std::make_unique<Network>(ipv6_eth0_publicnetwork2_ip1));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000721 changed = false;
Niels Möllerd959f3a2022-04-19 11:29:19 +0200722 MergeNetworkList(manager, std::move(second_list), &changed);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000723 EXPECT_TRUE(changed);
724 // There should be five networks now.
Niels Möller22211442022-04-07 11:43:28 +0200725 std::vector<const Network*> list = manager.GetNetworks();
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000726 EXPECT_EQ(5U, list.size());
727 // Check the resulting addresses.
Niels Möller22211442022-04-07 11:43:28 +0200728 for (const Network* network : list) {
729 if (network->prefix() == ipv6_eth0_publicnetwork2_ip1.prefix() &&
730 network->name() == ipv6_eth0_publicnetwork2_ip1.name()) {
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000731 // Check the new network has 1 IP and that it's the correct one.
Niels Möller22211442022-04-07 11:43:28 +0200732 EXPECT_EQ(1U, network->GetIPs().size());
733 EXPECT_EQ(ip, network->GetIPs().at(0));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000734 } else {
735 // Check the IP didn't get added anywhere it wasn't supposed to.
Niels Möller22211442022-04-07 11:43:28 +0200736 EXPECT_THAT(network->GetIPs(), Not(Contains(InterfaceAddress(ip))));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000737 }
738 }
739}
740
honghaizdb8cf502015-12-21 13:08:46 -0800741// Test that DumpNetworks does not crash.
742TEST_F(NetworkTest, TestCreateAndDumpNetworks) {
Niels Möller539f3e12021-11-26 16:33:19 +0100743 PhysicalSocketServer socket_server;
744 BasicNetworkManager manager(&socket_server);
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -0700745 manager.StartUpdating();
Niels Möllerd959f3a2022-04-19 11:29:19 +0200746 std::vector<std::unique_ptr<Network>> list = GetNetworks(manager, true);
honghaizdb8cf502015-12-21 13:08:46 -0800747 bool changed;
Niels Möllerd959f3a2022-04-19 11:29:19 +0200748 MergeNetworkList(manager, std::move(list), &changed);
honghaizdb8cf502015-12-21 13:08:46 -0800749 manager.DumpNetworks();
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000750}
751
Mirko Bonadei44f0f872019-01-20 18:16:42 +0100752TEST_F(NetworkTest, TestIPv6Toggle) {
Niels Möller539f3e12021-11-26 16:33:19 +0100753 PhysicalSocketServer socket_server;
754 BasicNetworkManager manager(&socket_server);
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -0700755 manager.StartUpdating();
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000756 bool ipv6_found = false;
Niels Möllerd959f3a2022-04-19 11:29:19 +0200757 for (const auto& network : GetNetworks(manager, true)) {
758 if (network->prefix().family() == AF_INET6) {
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000759 ipv6_found = true;
760 break;
761 }
762 }
763 EXPECT_TRUE(ipv6_found);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000764}
765
deadbeef3427f532017-07-26 16:09:33 -0700766// Test that when network interfaces are sorted and given preference values,
767// IPv6 comes first.
768TEST_F(NetworkTest, IPv6NetworksPreferredOverIPv4) {
Niels Möller539f3e12021-11-26 16:33:19 +0100769 PhysicalSocketServer socket_server;
770 BasicNetworkManager manager(&socket_server);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000771 Network ipv4_network1("test_eth0", "Test Network Adapter 1",
772 IPAddress(0x12345600U), 24);
773 ipv4_network1.AddIP(IPAddress(0x12345600U));
774
775 IPAddress ip;
776 IPAddress prefix;
777 EXPECT_TRUE(IPFromString("2400:4030:1:2c00:be30:abcd:efab:cdef", &ip));
778 prefix = TruncateIP(ip, 64);
779 Network ipv6_eth1_publicnetwork1_ip1("test_eth1", "Test NetworkAdapter 2",
780 prefix, 64);
781 ipv6_eth1_publicnetwork1_ip1.AddIP(ip);
782
Niels Möllerd959f3a2022-04-19 11:29:19 +0200783 std::vector<std::unique_ptr<Network>> list;
784 list.push_back(std::make_unique<Network>(ipv4_network1));
785 list.push_back(std::make_unique<Network>(ipv6_eth1_publicnetwork1_ip1));
786 const Network* net1 = list[0].get();
787 const Network* net2 = list[1].get();
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000788
789 bool changed = false;
Niels Möllerd959f3a2022-04-19 11:29:19 +0200790 MergeNetworkList(manager, std::move(list), &changed);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000791 ASSERT_TRUE(changed);
792 // After sorting IPv6 network should be higher order than IPv4 networks.
793 EXPECT_TRUE(net1->preference() < net2->preference());
794}
795
deadbeef3427f532017-07-26 16:09:33 -0700796// When two interfaces are equivalent in everything but name, they're expected
797// to be preference-ordered by name. For example, "eth0" before "eth1".
798TEST_F(NetworkTest, NetworksSortedByInterfaceName) {
Niels Möller539f3e12021-11-26 16:33:19 +0100799 PhysicalSocketServer socket_server;
Jonas Orelandc06fe8b2022-03-28 14:58:26 +0200800 BasicNetworkManager manager(&socket_server, &field_trials_);
Niels Möllerd959f3a2022-04-19 11:29:19 +0200801 auto eth0 = std::make_unique<Network>("test_eth0", "Test Network Adapter 1",
802 IPAddress(0x65432100U), 24);
deadbeef3427f532017-07-26 16:09:33 -0700803 eth0->AddIP(IPAddress(0x65432100U));
Niels Möllerd959f3a2022-04-19 11:29:19 +0200804 auto eth1 = std::make_unique<Network>("test_eth1", "Test Network Adapter 2",
805 IPAddress(0x12345600U), 24);
deadbeef3427f532017-07-26 16:09:33 -0700806 eth1->AddIP(IPAddress(0x12345600U));
Niels Möllerd959f3a2022-04-19 11:29:19 +0200807 std::vector<std::unique_ptr<Network>> list;
808 const Network* eth0_ptr = eth0.get();
809 const Network* eth1_ptr = eth1.get();
deadbeef3427f532017-07-26 16:09:33 -0700810 // Add them to the list in the opposite of the expected sorted order, to
811 // ensure sorting actually occurs.
Niels Möllerd959f3a2022-04-19 11:29:19 +0200812 list.push_back(std::move(eth1));
813 list.push_back(std::move(eth0));
deadbeef3427f532017-07-26 16:09:33 -0700814
815 bool changed = false;
Niels Möllerd959f3a2022-04-19 11:29:19 +0200816 MergeNetworkList(manager, std::move(list), &changed);
deadbeef3427f532017-07-26 16:09:33 -0700817 ASSERT_TRUE(changed);
818 // "test_eth0" should be preferred over "test_eth1".
Niels Möllerd959f3a2022-04-19 11:29:19 +0200819 EXPECT_TRUE(eth0_ptr->preference() > eth1_ptr->preference());
deadbeef3427f532017-07-26 16:09:33 -0700820}
821
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000822TEST_F(NetworkTest, TestNetworkAdapterTypes) {
823 Network wifi("wlan0", "Wireless Adapter", IPAddress(0x12345600U), 24,
824 ADAPTER_TYPE_WIFI);
825 EXPECT_EQ(ADAPTER_TYPE_WIFI, wifi.type());
826 Network ethernet("eth0", "Ethernet", IPAddress(0x12345600U), 24,
827 ADAPTER_TYPE_ETHERNET);
828 EXPECT_EQ(ADAPTER_TYPE_ETHERNET, ethernet.type());
829 Network cellular("test_cell", "Cellular Adapter", IPAddress(0x12345600U), 24,
830 ADAPTER_TYPE_CELLULAR);
831 EXPECT_EQ(ADAPTER_TYPE_CELLULAR, cellular.type());
832 Network vpn("bridge_test", "VPN Adapter", IPAddress(0x12345600U), 24,
833 ADAPTER_TYPE_VPN);
834 EXPECT_EQ(ADAPTER_TYPE_VPN, vpn.type());
835 Network unknown("test", "Test Adapter", IPAddress(0x12345600U), 24,
836 ADAPTER_TYPE_UNKNOWN);
837 EXPECT_EQ(ADAPTER_TYPE_UNKNOWN, unknown.type());
838}
839
840#if defined(WEBRTC_POSIX)
841// Verify that we correctly handle interfaces with no address.
842TEST_F(NetworkTest, TestConvertIfAddrsNoAddress) {
843 ifaddrs list;
844 memset(&list, 0, sizeof(list));
845 list.ifa_name = const_cast<char*>("test_iface");
846
Niels Möllerd959f3a2022-04-19 11:29:19 +0200847 std::vector<std::unique_ptr<Network>> result;
Niels Möller539f3e12021-11-26 16:33:19 +0100848 PhysicalSocketServer socket_server;
849 BasicNetworkManager manager(&socket_server);
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -0700850 manager.StartUpdating();
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000851 CallConvertIfAddrs(manager, &list, true, &result);
852 EXPECT_TRUE(result.empty());
853}
honghaizdb8cf502015-12-21 13:08:46 -0800854
855// Verify that if there are two addresses on one interface, only one network
856// is generated.
857TEST_F(NetworkTest, TestConvertIfAddrsMultiAddressesOnOneInterface) {
858 char if_name[20] = "rmnet0";
859 ifaddrs* list = nullptr;
860 list = AddIpv6Address(list, if_name, "1000:2000:3000:4000:0:0:0:1",
861 "FFFF:FFFF:FFFF:FFFF::", 0);
862 list = AddIpv6Address(list, if_name, "1000:2000:3000:4000:0:0:0:2",
863 "FFFF:FFFF:FFFF:FFFF::", 0);
Niels Möllerd959f3a2022-04-19 11:29:19 +0200864 std::vector<std::unique_ptr<Network>> result;
Niels Möller539f3e12021-11-26 16:33:19 +0100865 PhysicalSocketServer socket_server;
866 BasicNetworkManager manager(&socket_server);
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -0700867 manager.StartUpdating();
honghaizdb8cf502015-12-21 13:08:46 -0800868 CallConvertIfAddrs(manager, list, true, &result);
869 EXPECT_EQ(1U, result.size());
870 bool changed;
871 // This ensures we release the objects created in CallConvertIfAddrs.
Niels Möllerd959f3a2022-04-19 11:29:19 +0200872 MergeNetworkList(manager, std::move(result), &changed);
honghaizdb8cf502015-12-21 13:08:46 -0800873 ReleaseIfAddrs(list);
874}
Guo-wei Shieh9faf1542015-12-28 14:06:55 -0800875
876TEST_F(NetworkTest, TestConvertIfAddrsNotRunning) {
877 ifaddrs list;
878 memset(&list, 0, sizeof(list));
879 list.ifa_name = const_cast<char*>("test_iface");
880 sockaddr ifa_addr;
881 sockaddr ifa_netmask;
882 list.ifa_addr = &ifa_addr;
883 list.ifa_netmask = &ifa_netmask;
884
Niels Möllerd959f3a2022-04-19 11:29:19 +0200885 std::vector<std::unique_ptr<Network>> result;
Niels Möller539f3e12021-11-26 16:33:19 +0100886 PhysicalSocketServer socket_server;
887 BasicNetworkManager manager(&socket_server);
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -0700888 manager.StartUpdating();
Guo-wei Shieh9faf1542015-12-28 14:06:55 -0800889 CallConvertIfAddrs(manager, &list, true, &result);
890 EXPECT_TRUE(result.empty());
891}
Honghai Zhang351d77b2016-05-20 15:08:29 -0700892
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -0700893// Tests that the network type can be determined from the network monitor when
894// it would otherwise be unknown.
Honghai Zhang351d77b2016-05-20 15:08:29 -0700895TEST_F(NetworkTest, TestGetAdapterTypeFromNetworkMonitor) {
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -0700896 char if_name[20] = "wifi0";
897 std::string ipv6_address = "1000:2000:3000:4000:0:0:0:1";
Honghai Zhang351d77b2016-05-20 15:08:29 -0700898 std::string ipv6_mask = "FFFF:FFFF:FFFF:FFFF::";
Niels Mölleraa373162021-09-28 16:09:07 +0200899 PhysicalSocketServer socket_server;
Jonas Orelandc06fe8b2022-03-28 14:58:26 +0200900 BasicNetworkManager manager_without_monitor(nullptr, &socket_server,
901 &field_trials_);
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -0700902 manager_without_monitor.StartUpdating();
903 // A network created without a network monitor will get UNKNOWN type.
904 ifaddrs* addr_list = InstallIpv6Network(if_name, ipv6_address, ipv6_mask,
905 manager_without_monitor);
906 EXPECT_EQ(ADAPTER_TYPE_UNKNOWN, GetAdapterType(manager_without_monitor));
Honghai Zhang351d77b2016-05-20 15:08:29 -0700907 ReleaseIfAddrs(addr_list);
Honghai Zhang351d77b2016-05-20 15:08:29 -0700908
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -0700909 // With the fake network monitor the type should be correctly determined.
910 FakeNetworkMonitorFactory factory;
Jonas Orelandc06fe8b2022-03-28 14:58:26 +0200911 BasicNetworkManager manager_with_monitor(&factory, &socket_server,
912 &field_trials_);
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -0700913 manager_with_monitor.StartUpdating();
Honghai Zhang351d77b2016-05-20 15:08:29 -0700914 // Add the same ipv6 address as before but it has the right network type
915 // detected by the network monitor now.
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -0700916 addr_list = InstallIpv6Network(if_name, ipv6_address, ipv6_mask,
917 manager_with_monitor);
918 EXPECT_EQ(ADAPTER_TYPE_WIFI, GetAdapterType(manager_with_monitor));
Honghai Zhang351d77b2016-05-20 15:08:29 -0700919 ReleaseIfAddrs(addr_list);
Honghai Zhang351d77b2016-05-20 15:08:29 -0700920}
921
922// Test that the network type can be determined based on name matching in
923// a few cases. Note that UNKNOWN type for non-matching strings has been tested
924// in the above test.
925TEST_F(NetworkTest, TestGetAdapterTypeFromNameMatching) {
Jeroen de Borst8f096d02019-02-21 13:34:45 -0800926 std::string ipv4_address1 = "192.0.0.121";
927 std::string ipv4_mask = "255.255.255.0";
Honghai Zhang351d77b2016-05-20 15:08:29 -0700928 std::string ipv6_address1 = "1000:2000:3000:4000:0:0:0:1";
929 std::string ipv6_address2 = "1000:2000:3000:8000:0:0:0:1";
930 std::string ipv6_mask = "FFFF:FFFF:FFFF:FFFF::";
Niels Möller539f3e12021-11-26 16:33:19 +0100931 PhysicalSocketServer socket_server;
932 BasicNetworkManager manager(&socket_server);
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -0700933 manager.StartUpdating();
Honghai Zhang351d77b2016-05-20 15:08:29 -0700934
deadbeef4cd599f2017-07-27 15:05:29 -0700935 // IPSec interface; name is in form "ipsec<index>".
936 char if_name[20] = "ipsec11";
Honghai Zhang351d77b2016-05-20 15:08:29 -0700937 ifaddrs* addr_list =
938 InstallIpv6Network(if_name, ipv6_address1, ipv6_mask, manager);
deadbeef4cd599f2017-07-27 15:05:29 -0700939 EXPECT_EQ(ADAPTER_TYPE_VPN, GetAdapterType(manager));
940 ClearNetworks(manager);
941 ReleaseIfAddrs(addr_list);
Honghai Zhang351d77b2016-05-20 15:08:29 -0700942
Qingsi Wange53ac042018-05-08 11:55:07 -0700943 strcpy(if_name, "lo0");
944 addr_list = InstallIpv6Network(if_name, ipv6_address1, ipv6_mask, manager);
945 EXPECT_EQ(ADAPTER_TYPE_LOOPBACK, GetAdapterType(manager));
946 ClearNetworks(manager);
947 ReleaseIfAddrs(addr_list);
948
949 strcpy(if_name, "eth0");
Jeroen de Borst8f096d02019-02-21 13:34:45 -0800950 addr_list = InstallIpv4Network(if_name, ipv4_address1, ipv4_mask, manager);
Qingsi Wange53ac042018-05-08 11:55:07 -0700951 EXPECT_EQ(ADAPTER_TYPE_ETHERNET, GetAdapterType(manager));
952 ClearNetworks(manager);
953 ReleaseIfAddrs(addr_list);
954
Qingsi Wangc5bc9d62019-09-25 15:03:19 -0700955 strcpy(if_name, "wlan0");
956 addr_list = InstallIpv6Network(if_name, ipv6_address1, ipv6_mask, manager);
957 EXPECT_EQ(ADAPTER_TYPE_WIFI, GetAdapterType(manager));
958 ClearNetworks(manager);
959 ReleaseIfAddrs(addr_list);
960
deadbeef4cd599f2017-07-27 15:05:29 -0700961#if defined(WEBRTC_IOS)
962 strcpy(if_name, "pdp_ip0");
963 addr_list = InstallIpv6Network(if_name, ipv6_address1, ipv6_mask, manager);
Honghai Zhang351d77b2016-05-20 15:08:29 -0700964 EXPECT_EQ(ADAPTER_TYPE_CELLULAR, GetAdapterType(manager));
965 ClearNetworks(manager);
966 ReleaseIfAddrs(addr_list);
967
Honghai Zhang63ab8102016-05-26 20:30:15 -0700968 strcpy(if_name, "en0");
969 addr_list = InstallIpv6Network(if_name, ipv6_address1, ipv6_mask, manager);
970 EXPECT_EQ(ADAPTER_TYPE_WIFI, GetAdapterType(manager));
971 ClearNetworks(manager);
972 ReleaseIfAddrs(addr_list);
973
Honghai Zhang351d77b2016-05-20 15:08:29 -0700974#elif defined(WEBRTC_ANDROID)
deadbeef4cd599f2017-07-27 15:05:29 -0700975 strcpy(if_name, "rmnet0");
976 addr_list = InstallIpv6Network(if_name, ipv6_address1, ipv6_mask, manager);
Honghai Zhang351d77b2016-05-20 15:08:29 -0700977 EXPECT_EQ(ADAPTER_TYPE_CELLULAR, GetAdapterType(manager));
978 ClearNetworks(manager);
979 ReleaseIfAddrs(addr_list);
980
Honghai Zhang351d77b2016-05-20 15:08:29 -0700981 strcpy(if_name, "v4-rmnet_data0");
982 addr_list = InstallIpv6Network(if_name, ipv6_address2, ipv6_mask, manager);
983 EXPECT_EQ(ADAPTER_TYPE_CELLULAR, GetAdapterType(manager));
984 ClearNetworks(manager);
985 ReleaseIfAddrs(addr_list);
Jeroen de Borst8f096d02019-02-21 13:34:45 -0800986
987 strcpy(if_name, "clat4");
988 addr_list = InstallIpv4Network(if_name, ipv4_address1, ipv4_mask, manager);
989 EXPECT_EQ(ADAPTER_TYPE_CELLULAR, GetAdapterType(manager));
990 ClearNetworks(manager);
991 ReleaseIfAddrs(addr_list);
Honghai Zhang351d77b2016-05-20 15:08:29 -0700992#endif
993}
Taylor Brandstetterea7fbfb2020-08-19 16:41:54 -0700994
995// Test that an adapter won't be included in the network list if there's a
996// network monitor that says it's unavailable.
997TEST_F(NetworkTest, TestNetworkMonitorIsAdapterAvailable) {
998 char if_name1[20] = "pdp_ip0";
999 char if_name2[20] = "pdp_ip1";
1000 ifaddrs* list = nullptr;
1001 list = AddIpv6Address(list, if_name1, "1000:2000:3000:4000:0:0:0:1",
1002 "FFFF:FFFF:FFFF:FFFF::", 0);
1003 list = AddIpv6Address(list, if_name2, "1000:2000:3000:4000:0:0:0:2",
1004 "FFFF:FFFF:FFFF:FFFF::", 0);
Niels Möllerd959f3a2022-04-19 11:29:19 +02001005 std::vector<std::unique_ptr<Network>> result;
Taylor Brandstetterea7fbfb2020-08-19 16:41:54 -07001006
1007 // Sanity check that both interfaces are included by default.
1008 FakeNetworkMonitorFactory factory;
Niels Mölleraa373162021-09-28 16:09:07 +02001009 PhysicalSocketServer socket_server;
Jonas Orelandc06fe8b2022-03-28 14:58:26 +02001010 BasicNetworkManager manager(&factory, &socket_server, &field_trials_);
Taylor Brandstetterea7fbfb2020-08-19 16:41:54 -07001011 manager.StartUpdating();
1012 CallConvertIfAddrs(manager, list, /*include_ignored=*/false, &result);
1013 EXPECT_EQ(2u, result.size());
1014 bool changed;
1015 // This ensures we release the objects created in CallConvertIfAddrs.
Niels Möllerd959f3a2022-04-19 11:29:19 +02001016 MergeNetworkList(manager, std::move(result), &changed);
Taylor Brandstetterea7fbfb2020-08-19 16:41:54 -07001017 result.clear();
1018
1019 // Now simulate one interface being unavailable.
1020 FakeNetworkMonitor* network_monitor = GetNetworkMonitor(manager);
1021 network_monitor->set_unavailable_adapters({if_name1});
1022 CallConvertIfAddrs(manager, list, /*include_ignored=*/false, &result);
1023 EXPECT_EQ(1u, result.size());
1024 EXPECT_EQ(if_name2, result[0]->name());
1025
Niels Möllerd959f3a2022-04-19 11:29:19 +02001026 MergeNetworkList(manager, std::move(result), &changed);
Taylor Brandstetterea7fbfb2020-08-19 16:41:54 -07001027 ReleaseIfAddrs(list);
1028}
1029
henrike@webrtc.orgf0488722014-05-13 18:00:26 +00001030#endif // defined(WEBRTC_POSIX)
1031
guoweis@webrtc.org4bbd3c82014-09-09 13:54:45 +00001032// Test MergeNetworkList successfully combines all IPs for the same
1033// prefix/length into a single Network.
1034TEST_F(NetworkTest, TestMergeNetworkList) {
Niels Möller539f3e12021-11-26 16:33:19 +01001035 PhysicalSocketServer socket_server;
1036 BasicNetworkManager manager(&socket_server);
Niels Möllerd959f3a2022-04-19 11:29:19 +02001037 std::vector<std::unique_ptr<Network>> list;
guoweis@webrtc.org4bbd3c82014-09-09 13:54:45 +00001038
1039 // Create 2 IPAddress classes with only last digit different.
1040 IPAddress ip1, ip2;
1041 EXPECT_TRUE(IPFromString("2400:4030:1:2c00:be30:0:0:1", &ip1));
1042 EXPECT_TRUE(IPFromString("2400:4030:1:2c00:be30:0:0:2", &ip2));
1043
1044 // Create 2 networks with the same prefix and length.
Niels Möllerd959f3a2022-04-19 11:29:19 +02001045 auto net1 = std::make_unique<Network>("em1", "em1", TruncateIP(ip1, 64), 64);
1046 auto net2 = std::make_unique<Network>("em1", "em1", TruncateIP(ip1, 64), 64);
guoweis@webrtc.org4bbd3c82014-09-09 13:54:45 +00001047
1048 // Add different IP into each.
1049 net1->AddIP(ip1);
1050 net2->AddIP(ip2);
1051
Niels Möllerd959f3a2022-04-19 11:29:19 +02001052 list.push_back(std::move(net1));
1053 list.push_back(std::move(net2));
guoweis@webrtc.org4bbd3c82014-09-09 13:54:45 +00001054 bool changed;
Niels Möllerd959f3a2022-04-19 11:29:19 +02001055 MergeNetworkList(manager, std::move(list), &changed);
guoweis@webrtc.org4bbd3c82014-09-09 13:54:45 +00001056 EXPECT_TRUE(changed);
1057
Niels Möller22211442022-04-07 11:43:28 +02001058 std::vector<const Network*> list2 = manager.GetNetworks();
guoweis@webrtc.org4bbd3c82014-09-09 13:54:45 +00001059
1060 // Make sure the resulted networklist has only 1 element and 2
1061 // IPAddresses.
1062 EXPECT_EQ(list2.size(), 1uL);
1063 EXPECT_EQ(list2[0]->GetIPs().size(), 2uL);
Mirko Bonadeib2a57852022-03-18 12:19:56 +01001064 EXPECT_THAT(list2[0]->GetIPs(), UnorderedElementsAre(InterfaceAddress(ip1),
1065 InterfaceAddress(ip2)));
guoweis@webrtc.org4bbd3c82014-09-09 13:54:45 +00001066}
1067
honghaizdb8cf502015-12-21 13:08:46 -08001068// Test that MergeNetworkList successfully detects the change if
1069// a network becomes inactive and then active again.
1070TEST_F(NetworkTest, TestMergeNetworkListWithInactiveNetworks) {
Niels Möller539f3e12021-11-26 16:33:19 +01001071 PhysicalSocketServer socket_server;
1072 BasicNetworkManager manager(&socket_server);
honghaizdb8cf502015-12-21 13:08:46 -08001073 Network network1("test_wifi", "Test Network Adapter 1",
1074 IPAddress(0x12345600U), 24);
1075 Network network2("test_eth0", "Test Network Adapter 2",
1076 IPAddress(0x00010000U), 16);
1077 network1.AddIP(IPAddress(0x12345678));
1078 network2.AddIP(IPAddress(0x00010004));
Niels Möllerd959f3a2022-04-19 11:29:19 +02001079 std::vector<std::unique_ptr<Network>> list;
1080 auto net1 = std::make_unique<Network>(network1);
1081 const Network* const net1_ptr = net1.get();
1082 list.push_back(std::move(net1));
honghaizdb8cf502015-12-21 13:08:46 -08001083 bool changed;
Niels Möllerd959f3a2022-04-19 11:29:19 +02001084 MergeNetworkList(manager, std::move(list), &changed);
honghaizdb8cf502015-12-21 13:08:46 -08001085 EXPECT_TRUE(changed);
1086 list.clear();
Niels Möller22211442022-04-07 11:43:28 +02001087
1088 std::vector<const Network*> current = manager.GetNetworks();
1089 ASSERT_EQ(1U, current.size());
Niels Möllerd959f3a2022-04-19 11:29:19 +02001090 EXPECT_EQ(net1_ptr, current[0]);
honghaizdb8cf502015-12-21 13:08:46 -08001091
1092 list.clear();
Niels Möllerd959f3a2022-04-19 11:29:19 +02001093 auto net2 = std::make_unique<Network>(network2);
1094 const Network* const net2_ptr = net2.get();
1095 list.push_back(std::move(net2));
1096 MergeNetworkList(manager, std::move(list), &changed);
honghaizdb8cf502015-12-21 13:08:46 -08001097 EXPECT_TRUE(changed);
1098 list.clear();
Niels Möller22211442022-04-07 11:43:28 +02001099
1100 current = manager.GetNetworks();
1101 ASSERT_EQ(1U, current.size());
Niels Möllerd959f3a2022-04-19 11:29:19 +02001102 EXPECT_EQ(net2_ptr, current[0]);
honghaizdb8cf502015-12-21 13:08:46 -08001103 // Now network1 is inactive. Try to merge it again.
1104 list.clear();
Niels Möllerd959f3a2022-04-19 11:29:19 +02001105 list.push_back(std::make_unique<Network>(network1));
1106 MergeNetworkList(manager, std::move(list), &changed);
honghaizdb8cf502015-12-21 13:08:46 -08001107 EXPECT_TRUE(changed);
1108 list.clear();
Niels Möller22211442022-04-07 11:43:28 +02001109 current = manager.GetNetworks();
1110 ASSERT_EQ(1U, current.size());
1111 EXPECT_TRUE(current[0]->active());
Niels Möllerd959f3a2022-04-19 11:29:19 +02001112 EXPECT_EQ(net1_ptr, current[0]);
honghaizdb8cf502015-12-21 13:08:46 -08001113}
1114
guoweis@webrtc.org369a6372014-09-17 22:37:29 +00001115// Test that the filtering logic follows the defined ruleset in network.h.
1116TEST_F(NetworkTest, TestIPv6Selection) {
1117 InterfaceAddress ip;
1118 std::string ipstr;
1119
1120 ipstr = "2401:fa00:4:1000:be30:5bff:fee5:c3";
1121 ASSERT_TRUE(IPFromString(ipstr, IPV6_ADDRESS_FLAG_DEPRECATED, &ip));
1122
1123 // Create a network with this prefix.
Yves Gerey665174f2018-06-19 15:03:05 +02001124 Network ipv6_network("test_eth0", "Test NetworkAdapter", TruncateIP(ip, 64),
1125 64);
guoweis@webrtc.org369a6372014-09-17 22:37:29 +00001126
1127 // When there is no address added, it should return an unspecified
1128 // address.
1129 EXPECT_EQ(ipv6_network.GetBestIP(), IPAddress());
1130 EXPECT_TRUE(IPIsUnspec(ipv6_network.GetBestIP()));
1131
1132 // Deprecated one should not be returned.
1133 ipv6_network.AddIP(ip);
1134 EXPECT_EQ(ipv6_network.GetBestIP(), IPAddress());
1135
aluebs@webrtc.org07dcf602015-02-27 18:42:22 +00001136 // Add ULA one. ULA is unique local address which is starting either
1137 // with 0xfc or 0xfd.
guoweis@webrtc.org369a6372014-09-17 22:37:29 +00001138 ipstr = "fd00:fa00:4:1000:be30:5bff:fee5:c4";
1139 ASSERT_TRUE(IPFromString(ipstr, IPV6_ADDRESS_FLAG_NONE, &ip));
1140 ipv6_network.AddIP(ip);
aluebs@webrtc.org07dcf602015-02-27 18:42:22 +00001141 EXPECT_EQ(ipv6_network.GetBestIP(), static_cast<IPAddress>(ip));
guoweis@webrtc.org369a6372014-09-17 22:37:29 +00001142
aluebs@webrtc.org07dcf602015-02-27 18:42:22 +00001143 // Add global one.
guoweis@webrtc.org369a6372014-09-17 22:37:29 +00001144 ipstr = "2401:fa00:4:1000:be30:5bff:fee5:c5";
1145 ASSERT_TRUE(IPFromString(ipstr, IPV6_ADDRESS_FLAG_NONE, &ip));
1146 ipv6_network.AddIP(ip);
aluebs@webrtc.org07dcf602015-02-27 18:42:22 +00001147 EXPECT_EQ(ipv6_network.GetBestIP(), static_cast<IPAddress>(ip));
guoweis@webrtc.org369a6372014-09-17 22:37:29 +00001148
1149 // Add global dynamic temporary one.
1150 ipstr = "2401:fa00:4:1000:be30:5bff:fee5:c6";
1151 ASSERT_TRUE(IPFromString(ipstr, IPV6_ADDRESS_FLAG_TEMPORARY, &ip));
1152 ipv6_network.AddIP(ip);
1153 EXPECT_EQ(ipv6_network.GetBestIP(), static_cast<IPAddress>(ip));
1154}
1155
honghaiz023f3ef2015-10-19 09:39:32 -07001156TEST_F(NetworkTest, TestNetworkMonitoring) {
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -07001157 FakeNetworkMonitorFactory factory;
Niels Mölleraa373162021-09-28 16:09:07 +02001158 PhysicalSocketServer socket_server;
Jonas Orelandc06fe8b2022-03-28 14:58:26 +02001159 BasicNetworkManager manager(&factory, &socket_server, &field_trials_);
honghaiz023f3ef2015-10-19 09:39:32 -07001160 manager.SignalNetworksChanged.connect(static_cast<NetworkTest*>(this),
1161 &NetworkTest::OnNetworksChanged);
honghaiz023f3ef2015-10-19 09:39:32 -07001162 manager.StartUpdating();
honghaizcec0a082016-01-15 14:49:09 -08001163 FakeNetworkMonitor* network_monitor = GetNetworkMonitor(manager);
1164 EXPECT_TRUE(network_monitor && network_monitor->started());
honghaiz023f3ef2015-10-19 09:39:32 -07001165 EXPECT_TRUE_WAIT(callback_called_, 1000);
1166 callback_called_ = false;
1167
1168 // Clear the networks so that there will be network changes below.
1169 ClearNetworks(manager);
1170 // Network manager is started, so the callback is called when the network
1171 // monitor fires the network-change event.
Mirko Bonadei37077932021-07-27 17:00:58 +02001172 network_monitor->InovkeNetworksChangedCallbackForTesting();
honghaiz023f3ef2015-10-19 09:39:32 -07001173 EXPECT_TRUE_WAIT(callback_called_, 1000);
1174
honghaizcec0a082016-01-15 14:49:09 -08001175 // Network manager is stopped.
honghaiz023f3ef2015-10-19 09:39:32 -07001176 manager.StopUpdating();
honghaizcec0a082016-01-15 14:49:09 -08001177 EXPECT_FALSE(GetNetworkMonitor(manager)->started());
honghaiz023f3ef2015-10-19 09:39:32 -07001178}
1179
Edward Lemur8dc945c2016-07-21 10:16:40 +02001180// Fails on Android: https://bugs.chromium.org/p/webrtc/issues/detail?id=4364.
1181#if defined(WEBRTC_ANDROID)
1182#define MAYBE_DefaultLocalAddress DISABLED_DefaultLocalAddress
1183#else
1184#define MAYBE_DefaultLocalAddress DefaultLocalAddress
1185#endif
1186TEST_F(NetworkTest, MAYBE_DefaultLocalAddress) {
Guo-wei Shieha34c39e2015-11-25 13:12:26 -08001187 IPAddress ip;
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -07001188 FakeNetworkMonitorFactory factory;
Niels Mölleraa373162021-09-28 16:09:07 +02001189 PhysicalSocketServer socket_server;
Jonas Orelandc06fe8b2022-03-28 14:58:26 +02001190 TestBasicNetworkManager manager(&factory, &socket_server, field_trials_);
guoweis56271ed2016-01-15 14:45:06 -08001191 manager.SignalNetworksChanged.connect(static_cast<NetworkTest*>(this),
1192 &NetworkTest::OnNetworksChanged);
guoweis56271ed2016-01-15 14:45:06 -08001193 manager.StartUpdating();
1194 EXPECT_TRUE_WAIT(callback_called_, 1000);
Guo-wei Shieha34c39e2015-11-25 13:12:26 -08001195
1196 // Make sure we can query default local address when an address for such
1197 // address family exists.
Niels Möller22211442022-04-07 11:43:28 +02001198 std::vector<const Network*> networks = manager.GetNetworks();
guoweis56271ed2016-01-15 14:45:06 -08001199 EXPECT_TRUE(!networks.empty());
Niels Möller22211442022-04-07 11:43:28 +02001200 for (const Network* network : networks) {
Guo-wei Shieh9af97f82015-11-10 14:47:39 -08001201 if (network->GetBestIP().family() == AF_INET) {
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -07001202 EXPECT_TRUE(QueryDefaultLocalAddress(manager, AF_INET) != IPAddress());
guoweis56271ed2016-01-15 14:45:06 -08001203 } else if (network->GetBestIP().family() == AF_INET6 &&
1204 !IPIsLoopback(network->GetBestIP())) {
1205 // Existence of an IPv6 loopback address doesn't mean it has IPv6 network
1206 // enabled.
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -07001207 EXPECT_TRUE(QueryDefaultLocalAddress(manager, AF_INET6) != IPAddress());
Guo-wei Shieh9af97f82015-11-10 14:47:39 -08001208 }
1209 }
Guo-wei Shieha34c39e2015-11-25 13:12:26 -08001210
1211 // GetDefaultLocalAddress should return the valid default address after set.
1212 manager.set_default_local_addresses(GetLoopbackIP(AF_INET),
1213 GetLoopbackIP(AF_INET6));
1214 EXPECT_TRUE(manager.GetDefaultLocalAddress(AF_INET, &ip));
1215 EXPECT_EQ(ip, GetLoopbackIP(AF_INET));
1216 EXPECT_TRUE(manager.GetDefaultLocalAddress(AF_INET6, &ip));
1217 EXPECT_EQ(ip, GetLoopbackIP(AF_INET6));
honghaizaf83fe62016-04-18 14:50:44 -07001218
1219 // More tests on GetDefaultLocalAddress with ipv6 addresses where the set
1220 // default address may be different from the best IP address of any network.
1221 InterfaceAddress ip1;
1222 EXPECT_TRUE(IPFromString("abcd::1234:5678:abcd:1111",
1223 IPV6_ADDRESS_FLAG_TEMPORARY, &ip1));
1224 // Create a network with a prefix of ip1.
1225 Network ipv6_network("test_eth0", "Test NetworkAdapter", TruncateIP(ip1, 64),
1226 64);
1227 IPAddress ip2;
1228 EXPECT_TRUE(IPFromString("abcd::1234:5678:abcd:2222", &ip2));
1229 ipv6_network.AddIP(ip1);
1230 ipv6_network.AddIP(ip2);
Niels Möllerd959f3a2022-04-19 11:29:19 +02001231 std::vector<std::unique_ptr<Network>> list;
1232 list.push_back(std::make_unique<Network>(ipv6_network));
honghaizaf83fe62016-04-18 14:50:44 -07001233 bool changed;
Niels Möllerd959f3a2022-04-19 11:29:19 +02001234 MergeNetworkList(manager, std::move(list), &changed);
honghaizaf83fe62016-04-18 14:50:44 -07001235 // If the set default address is not in any network, GetDefaultLocalAddress
1236 // should return it.
1237 IPAddress ip3;
1238 EXPECT_TRUE(IPFromString("abcd::1234:5678:abcd:3333", &ip3));
1239 manager.set_default_local_addresses(GetLoopbackIP(AF_INET), ip3);
1240 EXPECT_TRUE(manager.GetDefaultLocalAddress(AF_INET6, &ip));
1241 EXPECT_EQ(ip3, ip);
1242 // If the set default address is in a network, GetDefaultLocalAddress will
1243 // return the best IP in that network.
1244 manager.set_default_local_addresses(GetLoopbackIP(AF_INET), ip2);
1245 EXPECT_TRUE(manager.GetDefaultLocalAddress(AF_INET6, &ip));
1246 EXPECT_EQ(static_cast<IPAddress>(ip1), ip);
1247
Guo-wei Shieh9af97f82015-11-10 14:47:39 -08001248 manager.StopUpdating();
1249}
1250
Jonas Orelandc7ea04a2020-04-03 10:12:28 +02001251// Test that MergeNetworkList does not set change = true
1252// when changing from cellular_X to cellular_Y.
1253TEST_F(NetworkTest, TestWhenNetworkListChangeReturnsChangedFlag) {
Niels Möller539f3e12021-11-26 16:33:19 +01001254 PhysicalSocketServer socket_server;
1255 BasicNetworkManager manager(&socket_server);
Jonas Orelandc7ea04a2020-04-03 10:12:28 +02001256
1257 IPAddress ip1;
1258 EXPECT_TRUE(IPFromString("2400:4030:1:2c00:be30:0:0:1", &ip1));
Niels Möllerd959f3a2022-04-19 11:29:19 +02001259 auto net1 = std::make_unique<Network>("em1", "em1", TruncateIP(ip1, 64), 64);
Jonas Orelandc7ea04a2020-04-03 10:12:28 +02001260 net1->set_type(ADAPTER_TYPE_CELLULAR_3G);
1261 net1->AddIP(ip1);
Niels Möllerd959f3a2022-04-19 11:29:19 +02001262 std::vector<std::unique_ptr<Network>> list;
1263 list.push_back(std::move(net1));
Jonas Orelandc7ea04a2020-04-03 10:12:28 +02001264
1265 {
1266 bool changed;
Niels Möllerd959f3a2022-04-19 11:29:19 +02001267 MergeNetworkList(manager, std::move(list), &changed);
Jonas Orelandc7ea04a2020-04-03 10:12:28 +02001268 EXPECT_TRUE(changed);
Niels Möller22211442022-04-07 11:43:28 +02001269 std::vector<const Network*> list2 = manager.GetNetworks();
Jonas Orelandc7ea04a2020-04-03 10:12:28 +02001270 EXPECT_EQ(list2.size(), 1uL);
1271 EXPECT_EQ(ADAPTER_TYPE_CELLULAR_3G, list2[0]->type());
1272 }
1273
1274 // Modify net1 from 3G to 4G
1275 {
Niels Möllerd959f3a2022-04-19 11:29:19 +02001276 auto net2 =
1277 std::make_unique<Network>("em1", "em1", TruncateIP(ip1, 64), 64);
Jonas Orelandc7ea04a2020-04-03 10:12:28 +02001278 net2->set_type(ADAPTER_TYPE_CELLULAR_4G);
1279 net2->AddIP(ip1);
1280 list.clear();
Niels Möllerd959f3a2022-04-19 11:29:19 +02001281 list.push_back(std::move(net2));
Jonas Orelandc7ea04a2020-04-03 10:12:28 +02001282 bool changed;
Niels Möllerd959f3a2022-04-19 11:29:19 +02001283 MergeNetworkList(manager, std::move(list), &changed);
Jonas Orelandc7ea04a2020-04-03 10:12:28 +02001284
1285 // Change from 3G to 4G shall not trigger OnNetworksChanged,
1286 // i.e changed = false.
1287 EXPECT_FALSE(changed);
Niels Möller22211442022-04-07 11:43:28 +02001288 std::vector<const Network*> list2 = manager.GetNetworks();
Jonas Orelandc7ea04a2020-04-03 10:12:28 +02001289 ASSERT_EQ(list2.size(), 1uL);
1290 EXPECT_EQ(ADAPTER_TYPE_CELLULAR_4G, list2[0]->type());
1291 }
1292
1293 // Don't modify.
1294 {
Niels Möllerd959f3a2022-04-19 11:29:19 +02001295 auto net2 =
1296 std::make_unique<Network>("em1", "em1", TruncateIP(ip1, 64), 64);
Jonas Orelandc7ea04a2020-04-03 10:12:28 +02001297 net2->set_type(ADAPTER_TYPE_CELLULAR_4G);
1298 net2->AddIP(ip1);
1299 list.clear();
Niels Möllerd959f3a2022-04-19 11:29:19 +02001300 list.push_back(std::move(net2));
Jonas Orelandc7ea04a2020-04-03 10:12:28 +02001301 bool changed;
Niels Möllerd959f3a2022-04-19 11:29:19 +02001302 MergeNetworkList(manager, std::move(list), &changed);
Jonas Orelandc7ea04a2020-04-03 10:12:28 +02001303
1304 // No change.
1305 EXPECT_FALSE(changed);
Niels Möller22211442022-04-07 11:43:28 +02001306 std::vector<const Network*> list2 = manager.GetNetworks();
Jonas Orelandc7ea04a2020-04-03 10:12:28 +02001307 ASSERT_EQ(list2.size(), 1uL);
1308 EXPECT_EQ(ADAPTER_TYPE_CELLULAR_4G, list2[0]->type());
1309 }
1310}
1311
Jonas Oreland47fa08f2020-12-05 18:09:13 +01001312#if defined(WEBRTC_POSIX)
1313TEST_F(NetworkTest, IgnoresMACBasedIPv6Address) {
1314 std::string ipv6_address = "2607:fc20:f340:1dc8:214:22ff:fe01:2345";
1315 std::string ipv6_mask = "FFFF:FFFF:FFFF:FFFF:FFFF:FFFF:FFFF:FFFF";
Niels Möller539f3e12021-11-26 16:33:19 +01001316 PhysicalSocketServer socket_server;
1317 BasicNetworkManager manager(&socket_server);
Jonas Oreland47fa08f2020-12-05 18:09:13 +01001318 manager.StartUpdating();
1319
1320 // IPSec interface; name is in form "ipsec<index>".
1321 char if_name[20] = "ipsec11";
1322 ifaddrs* addr_list =
1323 InstallIpv6Network(if_name, ipv6_address, ipv6_mask, manager);
1324
Niels Möller22211442022-04-07 11:43:28 +02001325 std::vector<const Network*> list = manager.GetNetworks();
Jonas Oreland47fa08f2020-12-05 18:09:13 +01001326 EXPECT_EQ(list.size(), 0u);
1327 ReleaseIfAddrs(addr_list);
1328}
1329
1330TEST_F(NetworkTest, WebRTC_AllowMACBasedIPv6Address) {
1331 webrtc::test::ScopedFieldTrials field_trials(
1332 "WebRTC-AllowMACBasedIPv6/Enabled/");
1333 std::string ipv6_address = "2607:fc20:f340:1dc8:214:22ff:fe01:2345";
1334 std::string ipv6_mask = "FFFF:FFFF:FFFF:FFFF:FFFF:FFFF:FFFF:FFFF";
Niels Möller539f3e12021-11-26 16:33:19 +01001335 PhysicalSocketServer socket_server;
1336 BasicNetworkManager manager(&socket_server);
Jonas Oreland47fa08f2020-12-05 18:09:13 +01001337 manager.StartUpdating();
1338
1339 // IPSec interface; name is in form "ipsec<index>".
1340 char if_name[20] = "ipsec11";
1341 ifaddrs* addr_list =
1342 InstallIpv6Network(if_name, ipv6_address, ipv6_mask, manager);
1343
Niels Möller22211442022-04-07 11:43:28 +02001344 std::vector<const Network*> list = manager.GetNetworks();
Jonas Oreland47fa08f2020-12-05 18:09:13 +01001345 EXPECT_EQ(list.size(), 1u);
1346 ReleaseIfAddrs(addr_list);
1347}
1348#endif
1349
Jonas Oreland6ca955a2021-03-15 08:27:43 +00001350#if defined(WEBRTC_POSIX)
1351TEST_F(NetworkTest, WebRTC_BindUsingInterfaceName) {
Jonas Oreland6ca955a2021-03-15 08:27:43 +00001352 char if_name1[20] = "wlan0";
1353 char if_name2[20] = "v4-wlan0";
1354 ifaddrs* list = nullptr;
1355 list = AddIpv6Address(list, if_name1, "1000:2000:3000:4000:0:0:0:1",
1356 "FFFF:FFFF:FFFF:FFFF::", 0);
1357 list = AddIpv4Address(list, if_name2, "192.168.0.2", "255.255.255.255");
Niels Möllerd959f3a2022-04-19 11:29:19 +02001358 std::vector<std::unique_ptr<Network>> result;
Jonas Oreland6ca955a2021-03-15 08:27:43 +00001359
1360 // Sanity check that both interfaces are included by default.
1361 FakeNetworkMonitorFactory factory;
Niels Mölleraa373162021-09-28 16:09:07 +02001362 PhysicalSocketServer socket_server;
Jonas Orelandc06fe8b2022-03-28 14:58:26 +02001363 BasicNetworkManager manager(&factory, &socket_server, &field_trials_);
Jonas Oreland6ca955a2021-03-15 08:27:43 +00001364 manager.StartUpdating();
1365 CallConvertIfAddrs(manager, list, /*include_ignored=*/false, &result);
1366 EXPECT_EQ(2u, result.size());
1367 ReleaseIfAddrs(list);
1368 bool changed;
1369 // This ensures we release the objects created in CallConvertIfAddrs.
Niels Möllerd959f3a2022-04-19 11:29:19 +02001370 MergeNetworkList(manager, std::move(result), &changed);
Jonas Oreland6ca955a2021-03-15 08:27:43 +00001371 result.clear();
1372
1373 FakeNetworkMonitor* network_monitor = GetNetworkMonitor(manager);
1374
1375 IPAddress ipv6;
1376 EXPECT_TRUE(IPFromString("1000:2000:3000:4000:0:0:0:1", &ipv6));
1377 IPAddress ipv4;
1378 EXPECT_TRUE(IPFromString("192.168.0.2", &ipv4));
1379
1380 // The network monitor only knwos about the ipv6 address, interface.
1381 network_monitor->set_adapters({"wlan0"});
1382 network_monitor->set_ip_addresses({ipv6});
1383 EXPECT_EQ(manager.BindSocketToNetwork(/* fd */ 77, ipv6),
1384 NetworkBindingResult::SUCCESS);
1385
1386 // But it will bind anyway using string matching...
1387 EXPECT_EQ(manager.BindSocketToNetwork(/* fd */ 77, ipv4),
1388 NetworkBindingResult::SUCCESS);
1389}
1390#endif
1391
Jonas Orelandb477fc72021-08-23 12:16:33 +02001392TEST_F(NetworkTest, NetworkCostVpn_Default) {
1393 IPAddress ip1;
1394 EXPECT_TRUE(IPFromString("2400:4030:1:2c00:be30:0:0:1", &ip1));
Jonas Orelandc06fe8b2022-03-28 14:58:26 +02001395 webrtc::test::ScopedKeyValueConfig field_trials;
Jonas Orelandb477fc72021-08-23 12:16:33 +02001396
1397 Network* net1 = new Network("em1", "em1", TruncateIP(ip1, 64), 64);
1398 net1->set_type(ADAPTER_TYPE_VPN);
1399 net1->set_underlying_type_for_vpn(ADAPTER_TYPE_ETHERNET);
1400
1401 Network* net2 = new Network("em1", "em1", TruncateIP(ip1, 64), 64);
1402 net2->set_type(ADAPTER_TYPE_ETHERNET);
1403
Jonas Orelandc06fe8b2022-03-28 14:58:26 +02001404 EXPECT_EQ(net1->GetCost(field_trials), net2->GetCost(field_trials));
Jonas Orelandb477fc72021-08-23 12:16:33 +02001405 delete net1;
1406 delete net2;
1407}
1408
1409TEST_F(NetworkTest, NetworkCostVpn_VpnMoreExpensive) {
Jonas Orelandc06fe8b2022-03-28 14:58:26 +02001410 webrtc::test::ScopedKeyValueConfig field_trials(
Jonas Orelandb477fc72021-08-23 12:16:33 +02001411 "WebRTC-AddNetworkCostToVpn/Enabled/");
1412
1413 IPAddress ip1;
1414 EXPECT_TRUE(IPFromString("2400:4030:1:2c00:be30:0:0:1", &ip1));
1415
1416 Network* net1 = new Network("em1", "em1", TruncateIP(ip1, 64), 64);
1417 net1->set_type(ADAPTER_TYPE_VPN);
1418 net1->set_underlying_type_for_vpn(ADAPTER_TYPE_ETHERNET);
1419
1420 Network* net2 = new Network("em1", "em1", TruncateIP(ip1, 64), 64);
1421 net2->set_type(ADAPTER_TYPE_ETHERNET);
1422
Jonas Orelandc06fe8b2022-03-28 14:58:26 +02001423 EXPECT_GT(net1->GetCost(field_trials), net2->GetCost(field_trials));
Jonas Orelandb477fc72021-08-23 12:16:33 +02001424 delete net1;
1425 delete net2;
1426}
1427
Jonas Oreland30019052022-01-28 14:11:44 +01001428TEST_F(NetworkTest, GuessAdapterFromNetworkCost) {
Jonas Orelandc06fe8b2022-03-28 14:58:26 +02001429 webrtc::test::ScopedKeyValueConfig field_trials(
Jonas Oreland30019052022-01-28 14:11:44 +01001430 "WebRTC-AddNetworkCostToVpn/Enabled/"
1431 "WebRTC-UseDifferentiatedCellularCosts/Enabled/");
1432
1433 IPAddress ip1;
1434 EXPECT_TRUE(IPFromString("2400:4030:1:2c00:be30:0:0:1", &ip1));
1435
1436 for (auto type : kAllAdapterTypes) {
1437 if (type == rtc::ADAPTER_TYPE_VPN)
1438 continue;
1439 Network net1("em1", "em1", TruncateIP(ip1, 64), 64);
1440 net1.set_type(type);
Jonas Orelandc06fe8b2022-03-28 14:58:26 +02001441 auto [guess, vpn] =
1442 Network::GuessAdapterFromNetworkCost(net1.GetCost(field_trials));
Jonas Oreland30019052022-01-28 14:11:44 +01001443 EXPECT_FALSE(vpn);
1444 if (type == rtc::ADAPTER_TYPE_LOOPBACK) {
1445 EXPECT_EQ(guess, rtc::ADAPTER_TYPE_ETHERNET);
1446 } else {
1447 EXPECT_EQ(type, guess);
1448 }
1449 }
1450
1451 // VPN
1452 for (auto type : kAllAdapterTypes) {
1453 if (type == rtc::ADAPTER_TYPE_VPN)
1454 continue;
1455 Network net1("em1", "em1", TruncateIP(ip1, 64), 64);
1456 net1.set_type(rtc::ADAPTER_TYPE_VPN);
1457 net1.set_underlying_type_for_vpn(type);
Jonas Orelandc06fe8b2022-03-28 14:58:26 +02001458 auto [guess, vpn] =
1459 Network::GuessAdapterFromNetworkCost(net1.GetCost(field_trials));
Jonas Oreland30019052022-01-28 14:11:44 +01001460 EXPECT_TRUE(vpn);
1461 if (type == rtc::ADAPTER_TYPE_LOOPBACK) {
1462 EXPECT_EQ(guess, rtc::ADAPTER_TYPE_ETHERNET);
1463 } else {
1464 EXPECT_EQ(type, guess);
1465 }
1466 }
1467}
1468
Jonas Oreland2ee0e642021-08-25 15:43:02 +02001469TEST_F(NetworkTest, VpnList) {
Niels Möller539f3e12021-11-26 16:33:19 +01001470 PhysicalSocketServer socket_server;
Jonas Oreland2ee0e642021-08-25 15:43:02 +02001471 {
Niels Möller539f3e12021-11-26 16:33:19 +01001472 BasicNetworkManager manager(&socket_server);
Jonas Oreland2ee0e642021-08-25 15:43:02 +02001473 manager.set_vpn_list({NetworkMask(IPFromString("192.168.0.0"), 16)});
1474 manager.StartUpdating();
1475 EXPECT_TRUE(manager.IsConfiguredVpn(IPFromString("192.168.1.1"), 32));
1476 EXPECT_TRUE(manager.IsConfiguredVpn(IPFromString("192.168.12.1"), 24));
1477 EXPECT_TRUE(manager.IsConfiguredVpn(IPFromString("192.168.0.0"), 16));
1478 EXPECT_TRUE(manager.IsConfiguredVpn(IPFromString("192.168.0.0"), 24));
1479 EXPECT_FALSE(manager.IsConfiguredVpn(IPFromString("192.133.1.1"), 32));
1480 EXPECT_FALSE(manager.IsConfiguredVpn(IPFromString("192.133.0.0"), 16));
1481 EXPECT_FALSE(manager.IsConfiguredVpn(IPFromString("192.168.0.0"), 15));
1482 }
1483 {
Niels Möller539f3e12021-11-26 16:33:19 +01001484 BasicNetworkManager manager(&socket_server);
Jonas Oreland2ee0e642021-08-25 15:43:02 +02001485 manager.set_vpn_list({NetworkMask(IPFromString("192.168.0.0"), 24)});
1486 manager.StartUpdating();
1487 EXPECT_FALSE(manager.IsConfiguredVpn(IPFromString("192.168.1.1"), 32));
1488 EXPECT_TRUE(manager.IsConfiguredVpn(IPFromString("192.168.0.1"), 32));
1489 }
1490}
1491
1492#if defined(WEBRTC_POSIX)
1493// TODO(webrtc:13114): Implement the InstallIpv4Network for windows.
1494TEST_F(NetworkTest, VpnListOverrideAdapterType) {
Niels Möller539f3e12021-11-26 16:33:19 +01001495 PhysicalSocketServer socket_server;
1496 BasicNetworkManager manager(&socket_server);
Jonas Oreland2ee0e642021-08-25 15:43:02 +02001497 manager.set_vpn_list({NetworkMask(IPFromString("192.168.0.0"), 16)});
1498 manager.StartUpdating();
1499
1500 char if_name[20] = "eth0";
1501 auto addr_list =
1502 InstallIpv4Network(if_name, "192.168.1.23", "255.255.255.255", manager);
1503
Niels Möller22211442022-04-07 11:43:28 +02001504 std::vector<const Network*> list = manager.GetNetworks();
Jonas Oreland2ee0e642021-08-25 15:43:02 +02001505 ASSERT_EQ(1u, list.size());
1506 EXPECT_EQ(ADAPTER_TYPE_VPN, list[0]->type());
1507 EXPECT_EQ(ADAPTER_TYPE_ETHERNET, list[0]->underlying_type_for_vpn());
1508 ClearNetworks(manager);
1509 ReleaseIfAddrs(addr_list);
1510}
1511#endif // defined(WEBRTC_POSIX)
1512
Jonas Orelandac554eb2021-08-27 09:43:38 +02001513TEST_F(NetworkTest, HardcodedVpn) {
1514 const uint8_t cisco[] = {0x0, 0x5, 0x9A, 0x3C, 0x7A, 0x0};
1515 const uint8_t global[] = {0x2, 0x50, 0x41, 0x0, 0x0, 0x1};
1516 const uint8_t unknown[] = {0x2, 0x50, 0x41, 0x0, 0x0, 0x0};
1517 const uint8_t five_bytes[] = {0x2, 0x50, 0x41, 0x0, 0x0};
1518 EXPECT_TRUE(NetworkManagerBase::IsVpnMacAddress(cisco));
1519 EXPECT_TRUE(NetworkManagerBase::IsVpnMacAddress(global));
1520
1521 EXPECT_FALSE(NetworkManagerBase::IsVpnMacAddress(
1522 rtc::ArrayView<const uint8_t>(cisco, 5)));
1523 EXPECT_FALSE(NetworkManagerBase::IsVpnMacAddress(five_bytes));
1524 EXPECT_FALSE(NetworkManagerBase::IsVpnMacAddress(unknown));
1525 EXPECT_FALSE(NetworkManagerBase::IsVpnMacAddress(nullptr));
1526}
1527
Mirko Bonadei13f9c622022-04-29 16:38:32 +02001528TEST(CompareNetworks, IrreflexivityTest) {
1529 // x < x is false
1530 auto network = std::make_unique<Network>(
1531 "test_eth0", "Test Network Adapter 1", IPAddress(0x12345600U), 24);
1532 EXPECT_FALSE(webrtc_network_internal::CompareNetworks(network, network));
1533}
1534
1535TEST(CompareNetworks, AsymmetryTest) {
1536 // x < y and y < x cannot be both true
1537 auto network_a = std::make_unique<Network>(
1538 "test_eth0", "Test Network Adapter 1", IPAddress(0x12345600U), 24);
1539 auto network_b = std::make_unique<Network>(
1540 "test_eth1", "Test Network Adapter 1", IPAddress(0x12345600U), 24);
1541 EXPECT_TRUE(webrtc_network_internal::CompareNetworks(network_a, network_b));
1542 EXPECT_FALSE(webrtc_network_internal::CompareNetworks(network_b, network_a));
1543
1544 auto network_c = std::make_unique<Network>(
1545 "test_eth0", "Test Network Adapter 1", IPAddress(0x12345500U), 24);
1546 auto network_d = std::make_unique<Network>(
1547 "test_eth0", "Test Network Adapter 1", IPAddress(0x12345600U), 24);
1548 EXPECT_TRUE(webrtc_network_internal::CompareNetworks(network_c, network_d));
1549 EXPECT_FALSE(webrtc_network_internal::CompareNetworks(network_d, network_c));
1550}
1551
1552TEST(CompareNetworks, TransitivityTest) {
1553 // x < y and y < z imply x < z
1554 auto network_a = std::make_unique<Network>(
1555 "test_eth0", "Test Network Adapter 1", IPAddress(0x12345600U), 24);
1556 auto network_b = std::make_unique<Network>(
1557 "test_eth1", "Test Network Adapter 1", IPAddress(0x12345600U), 24);
1558 auto network_c = std::make_unique<Network>(
1559 "test_eth2", "Test Network Adapter 1", IPAddress(0x12345600U), 24);
1560 EXPECT_TRUE(webrtc_network_internal::CompareNetworks(network_a, network_b));
1561 EXPECT_TRUE(webrtc_network_internal::CompareNetworks(network_b, network_c));
1562
1563 auto network_d = std::make_unique<Network>(
1564 "test_eth0", "Test Network Adapter 1", IPAddress(0x12345600U), 24);
1565 auto network_e = std::make_unique<Network>(
1566 "test_eth0", "Test Network Adapter 1", IPAddress(0x12345700U), 24);
1567 auto network_f = std::make_unique<Network>(
1568 "test_eth0", "Test Network Adapter 1", IPAddress(0x12345800U), 24);
1569 EXPECT_TRUE(webrtc_network_internal::CompareNetworks(network_d, network_e));
1570 EXPECT_TRUE(webrtc_network_internal::CompareNetworks(network_e, network_f));
1571 EXPECT_TRUE(webrtc_network_internal::CompareNetworks(network_d, network_f));
1572 EXPECT_TRUE(webrtc_network_internal::CompareNetworks(network_a, network_c));
1573}
1574
1575TEST(CompareNetworks, TransitivityOfIncomparabilityTest) {
1576 // x == y and y == z imply x == z,
1577 // where x == y means x < y and y < x are both false
1578 auto network_a = std::make_unique<Network>(
1579 "test_eth0", "Test Network Adapter 1", IPAddress(0x12345600U), 23);
1580 auto network_b = std::make_unique<Network>(
1581 "test_eth0", "Test Network Adapter 1", IPAddress(0x12345600U), 24);
1582 auto network_c = std::make_unique<Network>(
1583 "test_eth0", "Test Network Adapter 1", IPAddress(0x12345700U), 24);
1584
1585 // network_a < network_b
1586 EXPECT_TRUE(webrtc_network_internal::CompareNetworks(network_a, network_b));
1587 EXPECT_FALSE(webrtc_network_internal::CompareNetworks(network_b, network_a));
1588
1589 // network_b < network_c
1590 EXPECT_TRUE(webrtc_network_internal::CompareNetworks(network_b, network_c));
1591 EXPECT_FALSE(webrtc_network_internal::CompareNetworks(network_c, network_b));
1592
1593 // network_a < network_c
1594 EXPECT_TRUE(webrtc_network_internal::CompareNetworks(network_a, network_c));
1595 EXPECT_FALSE(webrtc_network_internal::CompareNetworks(network_c, network_a));
1596
1597 auto network_d = std::make_unique<Network>(
1598 "test_eth0", "Test Network Adapter 1", IPAddress(0x12345600U), 24);
1599 auto network_e = std::make_unique<Network>(
1600 "test_eth0", "Test Network Adapter 1", IPAddress(0x12345600U), 24);
1601 auto network_f = std::make_unique<Network>(
1602 "test_eth0", "Test Network Adapter 1", IPAddress(0x12345600U), 24);
1603
1604 // network_d == network_e
1605 EXPECT_FALSE(webrtc_network_internal::CompareNetworks(network_d, network_e));
1606 EXPECT_FALSE(webrtc_network_internal::CompareNetworks(network_e, network_d));
1607
1608 // network_e == network_f
1609 EXPECT_FALSE(webrtc_network_internal::CompareNetworks(network_e, network_f));
1610 EXPECT_FALSE(webrtc_network_internal::CompareNetworks(network_f, network_e));
1611
1612 // network_d == network_f
1613 EXPECT_FALSE(webrtc_network_internal::CompareNetworks(network_d, network_f));
1614 EXPECT_FALSE(webrtc_network_internal::CompareNetworks(network_f, network_d));
1615}
1616
henrike@webrtc.orgf0488722014-05-13 18:00:26 +00001617} // namespace rtc