blob: 1b8463e9f666fc4cf683997d97cad2da221ad14c [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",
Diep Bui1e589eb2022-08-02 07:37:30 +0000342 IPAddress(0x12345600U), 24, ADAPTER_TYPE_ETHERNET,
343 &field_trials_);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000344 Network ipv4_network2("test_eth1", "Test Network Adapter 2",
Diep Bui1e589eb2022-08-02 07:37:30 +0000345 IPAddress(0x010000U), 24, ADAPTER_TYPE_ETHERNET,
346 &field_trials_);
Niels Möller539f3e12021-11-26 16:33:19 +0100347 PhysicalSocketServer socket_server;
348 BasicNetworkManager network_manager(&socket_server);
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -0700349 network_manager.StartUpdating();
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000350 EXPECT_FALSE(IsIgnoredNetwork(network_manager, ipv4_network1));
351 EXPECT_TRUE(IsIgnoredNetwork(network_manager, ipv4_network2));
352}
353
phoglund@webrtc.org006521d2015-02-12 09:23:59 +0000354// TODO(phoglund): Remove when ignore list goes away.
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000355TEST_F(NetworkTest, TestIgnoreList) {
Yves Gerey665174f2018-06-19 15:03:05 +0200356 Network ignore_me("ignore_me", "Ignore me please!", IPAddress(0x12345600U),
357 24);
358 Network include_me("include_me", "Include me please!", IPAddress(0x12345600U),
359 24);
Niels Möller539f3e12021-11-26 16:33:19 +0100360 PhysicalSocketServer socket_server;
361 BasicNetworkManager default_network_manager(&socket_server);
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -0700362 default_network_manager.StartUpdating();
363 EXPECT_FALSE(IsIgnoredNetwork(default_network_manager, ignore_me));
364 EXPECT_FALSE(IsIgnoredNetwork(default_network_manager, include_me));
365
Niels Möller539f3e12021-11-26 16:33:19 +0100366 BasicNetworkManager ignoring_network_manager(&socket_server);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000367 std::vector<std::string> ignore_list;
368 ignore_list.push_back("ignore_me");
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -0700369 ignoring_network_manager.set_network_ignore_list(ignore_list);
370 ignoring_network_manager.StartUpdating();
371 EXPECT_TRUE(IsIgnoredNetwork(ignoring_network_manager, ignore_me));
372 EXPECT_FALSE(IsIgnoredNetwork(ignoring_network_manager, include_me));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000373}
374
375// Test is failing on Windows opt: b/11288214
376TEST_F(NetworkTest, DISABLED_TestCreateNetworks) {
Niels Möller539f3e12021-11-26 16:33:19 +0100377 PhysicalSocketServer socket_server;
378 BasicNetworkManager manager(&socket_server);
Niels Möllerd959f3a2022-04-19 11:29:19 +0200379 std::vector<std::unique_ptr<Network>> result = GetNetworks(manager, true);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000380 // We should be able to bind to any addresses we find.
Niels Möllerd959f3a2022-04-19 11:29:19 +0200381 for (auto it = result.begin(); it != result.end(); ++it) {
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000382 sockaddr_storage storage;
383 memset(&storage, 0, sizeof(storage));
guoweis@webrtc.org369a6372014-09-17 22:37:29 +0000384 IPAddress ip = (*it)->GetBestIP();
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000385 SocketAddress bindaddress(ip, 0);
386 bindaddress.SetScopeID((*it)->scope_id());
Niels Möllerd0b88792021-08-12 10:32:30 +0200387 // TODO(thaloun): Use rtc::Socket once it supports IPv6.
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000388 int fd = static_cast<int>(socket(ip.family(), SOCK_STREAM, IPPROTO_TCP));
389 if (fd > 0) {
390 size_t ipsize = bindaddress.ToSockAddrStorage(&storage);
391 EXPECT_GE(ipsize, 0U);
Yves Gerey665174f2018-06-19 15:03:05 +0200392 int success = ::bind(fd, reinterpret_cast<sockaddr*>(&storage),
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000393 static_cast<int>(ipsize));
394#if defined(WEBRTC_WIN)
Mirko Bonadei675513b2017-11-09 11:09:25 +0100395 if (success)
396 RTC_LOG_GLE(LS_ERROR) << "Socket bind failed.";
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000397#endif
398 EXPECT_EQ(0, success);
399#if defined(WEBRTC_WIN)
400 closesocket(fd);
401#else
402 close(fd);
403#endif
404 }
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000405 }
406}
407
Guo-wei Shieh47872ec2015-08-19 10:32:46 -0700408// Test StartUpdating() and StopUpdating(). network_permission_state starts with
409// ALLOWED.
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000410TEST_F(NetworkTest, TestUpdateNetworks) {
Niels Mölleraa373162021-09-28 16:09:07 +0200411 PhysicalSocketServer socket_server;
Jonas Orelandc06fe8b2022-03-28 14:58:26 +0200412 BasicNetworkManager manager(nullptr, &socket_server, &field_trials_);
Yves Gerey665174f2018-06-19 15:03:05 +0200413 manager.SignalNetworksChanged.connect(static_cast<NetworkTest*>(this),
414 &NetworkTest::OnNetworksChanged);
guoweisea1012b2015-08-21 09:06:28 -0700415 EXPECT_EQ(NetworkManager::ENUMERATION_ALLOWED,
416 manager.enumeration_permission());
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000417 manager.StartUpdating();
418 Thread::Current()->ProcessMessages(0);
419 EXPECT_TRUE(callback_called_);
420 callback_called_ = false;
421 // Callback should be triggered immediately when StartUpdating
422 // is called, after network update signal is already sent.
423 manager.StartUpdating();
424 EXPECT_TRUE(manager.started());
425 Thread::Current()->ProcessMessages(0);
426 EXPECT_TRUE(callback_called_);
427 manager.StopUpdating();
428 EXPECT_TRUE(manager.started());
429 manager.StopUpdating();
guoweisea1012b2015-08-21 09:06:28 -0700430 EXPECT_EQ(NetworkManager::ENUMERATION_ALLOWED,
431 manager.enumeration_permission());
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000432 EXPECT_FALSE(manager.started());
433 manager.StopUpdating();
434 EXPECT_FALSE(manager.started());
435 callback_called_ = false;
436 // Callback should be triggered immediately after StartUpdating is called
437 // when start_count_ is reset to 0.
438 manager.StartUpdating();
439 Thread::Current()->ProcessMessages(0);
440 EXPECT_TRUE(callback_called_);
441}
442
443// Verify that MergeNetworkList() merges network lists properly.
444TEST_F(NetworkTest, TestBasicMergeNetworkList) {
445 Network ipv4_network1("test_eth0", "Test Network Adapter 1",
446 IPAddress(0x12345600U), 24);
447 Network ipv4_network2("test_eth1", "Test Network Adapter 2",
448 IPAddress(0x00010000U), 16);
449 ipv4_network1.AddIP(IPAddress(0x12345678));
450 ipv4_network2.AddIP(IPAddress(0x00010004));
Niels Möller539f3e12021-11-26 16:33:19 +0100451 PhysicalSocketServer socket_server;
452 BasicNetworkManager manager(&socket_server);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000453
454 // Add ipv4_network1 to the list of networks.
Niels Möllerd959f3a2022-04-19 11:29:19 +0200455 std::vector<std::unique_ptr<Network>> list;
456 list.push_back(std::make_unique<Network>(ipv4_network1));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000457 bool changed;
Niels Möllerd959f3a2022-04-19 11:29:19 +0200458 NetworkManager::Stats stats =
459 MergeNetworkList(manager, std::move(list), &changed);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000460 EXPECT_TRUE(changed);
guoweis@webrtc.orga094cac2015-01-28 19:34:05 +0000461 EXPECT_EQ(stats.ipv6_network_count, 0);
462 EXPECT_EQ(stats.ipv4_network_count, 1);
Niels Möllerd959f3a2022-04-19 11:29:19 +0200463 list.clear(); // It is fine to call .clear() on a moved-from vector.
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000464
Niels Möller22211442022-04-07 11:43:28 +0200465 std::vector<const rtc::Network*> current = manager.GetNetworks();
466 EXPECT_EQ(1U, current.size());
467 EXPECT_TRUE(SameNameAndPrefix(ipv4_network1, *current[0]));
468 const Network* net1 = current[0];
honghaiza0c44ea2016-03-23 16:07:48 -0700469 uint16_t net_id1 = net1->id();
470 EXPECT_EQ(1, net_id1);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000471
472 // Replace ipv4_network1 with ipv4_network2.
Niels Möllerd959f3a2022-04-19 11:29:19 +0200473 list.push_back(std::make_unique<Network>(ipv4_network2));
474 stats = MergeNetworkList(manager, std::move(list), &changed);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000475 EXPECT_TRUE(changed);
guoweis@webrtc.orga094cac2015-01-28 19:34:05 +0000476 EXPECT_EQ(stats.ipv6_network_count, 0);
477 EXPECT_EQ(stats.ipv4_network_count, 1);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000478 list.clear();
479
Niels Möller22211442022-04-07 11:43:28 +0200480 current = manager.GetNetworks();
481 EXPECT_EQ(1U, current.size());
482 EXPECT_TRUE(SameNameAndPrefix(ipv4_network2, *current[0]));
483 const Network* net2 = current[0];
honghaiza0c44ea2016-03-23 16:07:48 -0700484 uint16_t net_id2 = net2->id();
485 // Network id will increase.
486 EXPECT_LT(net_id1, net_id2);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000487
488 // Add Network2 back.
Niels Möllerd959f3a2022-04-19 11:29:19 +0200489 list.push_back(std::make_unique<Network>(ipv4_network1));
490 list.push_back(std::make_unique<Network>(ipv4_network2));
491 stats = MergeNetworkList(manager, std::move(list), &changed);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000492 EXPECT_TRUE(changed);
guoweis@webrtc.orga094cac2015-01-28 19:34:05 +0000493 EXPECT_EQ(stats.ipv6_network_count, 0);
494 EXPECT_EQ(stats.ipv4_network_count, 2);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000495 list.clear();
496
497 // Verify that we get previous instances of Network objects.
Niels Möller22211442022-04-07 11:43:28 +0200498 current = manager.GetNetworks();
499 EXPECT_EQ(2U, current.size());
500 EXPECT_TRUE((net1 == current[0] && net2 == current[1]) ||
501 (net1 == current[1] && net2 == current[0]));
502 EXPECT_TRUE((net_id1 == current[0]->id() && net_id2 == current[1]->id()) ||
503 (net_id1 == current[1]->id() && net_id2 == current[0]->id()));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000504
505 // Call MergeNetworkList() again and verify that we don't get update
506 // notification.
Niels Möllerd959f3a2022-04-19 11:29:19 +0200507 list.push_back(std::make_unique<Network>(ipv4_network2));
508 list.push_back(std::make_unique<Network>(ipv4_network1));
509 stats = MergeNetworkList(manager, std::move(list), &changed);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000510 EXPECT_FALSE(changed);
guoweis@webrtc.orga094cac2015-01-28 19:34:05 +0000511 EXPECT_EQ(stats.ipv6_network_count, 0);
512 EXPECT_EQ(stats.ipv4_network_count, 2);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000513 list.clear();
514
515 // Verify that we get previous instances of Network objects.
Niels Möller22211442022-04-07 11:43:28 +0200516 current = manager.GetNetworks();
517 EXPECT_EQ(2U, current.size());
518 EXPECT_TRUE((net1 == current[0] && net2 == current[1]) ||
519 (net1 == current[1] && net2 == current[0]));
520 EXPECT_TRUE((net_id1 == current[0]->id() && net_id2 == current[1]->id()) ||
521 (net_id1 == current[1]->id() && net_id2 == current[0]->id()));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000522}
523
524// Sets up some test IPv6 networks and appends them to list.
525// Four networks are added - public and link local, for two interfaces.
Niels Möllerd959f3a2022-04-19 11:29:19 +0200526void SetupNetworks(std::vector<std::unique_ptr<Network>>* list) {
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000527 IPAddress ip;
528 IPAddress prefix;
guoweis@webrtc.orgbbce5ef2015-03-05 04:38:29 +0000529 EXPECT_TRUE(IPFromString("abcd::1234:5678:abcd:ef12", &ip));
530 EXPECT_TRUE(IPFromString("abcd::", &prefix));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000531 // First, fake link-locals.
532 Network ipv6_eth0_linklocalnetwork("test_eth0", "Test NetworkAdapter 1",
533 prefix, 64);
534 ipv6_eth0_linklocalnetwork.AddIP(ip);
guoweis@webrtc.orgbbce5ef2015-03-05 04:38:29 +0000535 EXPECT_TRUE(IPFromString("abcd::5678:abcd:ef12:3456", &ip));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000536 Network ipv6_eth1_linklocalnetwork("test_eth1", "Test NetworkAdapter 2",
537 prefix, 64);
538 ipv6_eth1_linklocalnetwork.AddIP(ip);
539 // Public networks:
540 EXPECT_TRUE(IPFromString("2401:fa00:4:1000:be30:5bff:fee5:c3", &ip));
541 prefix = TruncateIP(ip, 64);
542 Network ipv6_eth0_publicnetwork1_ip1("test_eth0", "Test NetworkAdapter 1",
543 prefix, 64);
544 ipv6_eth0_publicnetwork1_ip1.AddIP(ip);
545 EXPECT_TRUE(IPFromString("2400:4030:1:2c00:be30:abcd:efab:cdef", &ip));
546 prefix = TruncateIP(ip, 64);
547 Network ipv6_eth1_publicnetwork1_ip1("test_eth1", "Test NetworkAdapter 1",
548 prefix, 64);
549 ipv6_eth1_publicnetwork1_ip1.AddIP(ip);
Niels Möllerd959f3a2022-04-19 11:29:19 +0200550 list->push_back(std::make_unique<Network>(ipv6_eth0_linklocalnetwork));
551 list->push_back(std::make_unique<Network>(ipv6_eth1_linklocalnetwork));
552 list->push_back(std::make_unique<Network>(ipv6_eth0_publicnetwork1_ip1));
553 list->push_back(std::make_unique<Network>(ipv6_eth1_publicnetwork1_ip1));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000554}
555
556// Test that the basic network merging case works.
557TEST_F(NetworkTest, TestIPv6MergeNetworkList) {
Niels Möller539f3e12021-11-26 16:33:19 +0100558 PhysicalSocketServer socket_server;
559 BasicNetworkManager manager(&socket_server);
Yves Gerey665174f2018-06-19 15:03:05 +0200560 manager.SignalNetworksChanged.connect(static_cast<NetworkTest*>(this),
561 &NetworkTest::OnNetworksChanged);
Niels Möllerd959f3a2022-04-19 11:29:19 +0200562 std::vector<std::unique_ptr<Network>> networks;
563 SetupNetworks(&networks);
564 std::vector<const Network*> original_list = CopyNetworkPointers(networks);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000565 bool changed = false;
guoweis@webrtc.orga094cac2015-01-28 19:34:05 +0000566 NetworkManager::Stats stats =
Niels Möllerd959f3a2022-04-19 11:29:19 +0200567 MergeNetworkList(manager, std::move(networks), &changed);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000568 EXPECT_TRUE(changed);
guoweis@webrtc.orga094cac2015-01-28 19:34:05 +0000569 EXPECT_EQ(stats.ipv6_network_count, 4);
570 EXPECT_EQ(stats.ipv4_network_count, 0);
Niels Möller22211442022-04-07 11:43:28 +0200571 std::vector<const Network*> list = manager.GetNetworks();
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000572 // Verify that the original members are in the merged list.
Steve Anton2acd1632019-03-25 13:48:30 -0700573 EXPECT_THAT(list, UnorderedElementsAreArray(original_list));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000574}
575
576// Tests that when two network lists that describe the same set of networks are
577// merged, that the changed callback is not called, and that the original
578// objects remain in the result list.
579TEST_F(NetworkTest, TestNoChangeMerge) {
Niels Möller539f3e12021-11-26 16:33:19 +0100580 PhysicalSocketServer socket_server;
581 BasicNetworkManager manager(&socket_server);
Yves Gerey665174f2018-06-19 15:03:05 +0200582 manager.SignalNetworksChanged.connect(static_cast<NetworkTest*>(this),
583 &NetworkTest::OnNetworksChanged);
Niels Möllerd959f3a2022-04-19 11:29:19 +0200584 std::vector<std::unique_ptr<Network>> networks;
585 SetupNetworks(&networks);
586 std::vector<const Network*> original_list = CopyNetworkPointers(networks);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000587 bool changed = false;
Niels Möllerd959f3a2022-04-19 11:29:19 +0200588 MergeNetworkList(manager, std::move(networks), &changed);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000589 EXPECT_TRUE(changed);
590 // Second list that describes the same networks but with new objects.
Niels Möllerd959f3a2022-04-19 11:29:19 +0200591 std::vector<std::unique_ptr<Network>> second_networks;
592 SetupNetworks(&second_networks);
593 std::vector<const Network*> second_list =
594 CopyNetworkPointers(second_networks);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000595 changed = false;
Niels Möllerd959f3a2022-04-19 11:29:19 +0200596 MergeNetworkList(manager, std::move(second_networks), &changed);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000597 EXPECT_FALSE(changed);
Niels Möller22211442022-04-07 11:43:28 +0200598 std::vector<const Network*> resulting_list = manager.GetNetworks();
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000599 // Verify that the original members are in the merged list.
Steve Anton2acd1632019-03-25 13:48:30 -0700600 EXPECT_THAT(resulting_list, UnorderedElementsAreArray(original_list));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000601 // Doublecheck that the new networks aren't in the list.
Steve Anton2acd1632019-03-25 13:48:30 -0700602 for (const Network* network : second_list) {
603 EXPECT_THAT(resulting_list, Not(Contains(network)));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000604 }
605}
606
607// Test that we can merge a network that is the same as another network but with
608// a different IP. The original network should remain in the list, but have its
609// IP changed.
610TEST_F(NetworkTest, MergeWithChangedIP) {
Niels Möller539f3e12021-11-26 16:33:19 +0100611 PhysicalSocketServer socket_server;
612 BasicNetworkManager manager(&socket_server);
Yves Gerey665174f2018-06-19 15:03:05 +0200613 manager.SignalNetworksChanged.connect(static_cast<NetworkTest*>(this),
614 &NetworkTest::OnNetworksChanged);
Niels Möllerd959f3a2022-04-19 11:29:19 +0200615 std::vector<std::unique_ptr<Network>> original_list;
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000616 SetupNetworks(&original_list);
617 // Make a network that we're going to change.
618 IPAddress ip;
619 EXPECT_TRUE(IPFromString("2401:fa01:4:1000:be30:faa:fee:faa", &ip));
620 IPAddress prefix = TruncateIP(ip, 64);
Niels Möllerd959f3a2022-04-19 11:29:19 +0200621 std::unique_ptr<Network> network_to_change = std::make_unique<Network>(
622 "test_eth0", "Test Network Adapter 1", prefix, 64);
623 std::unique_ptr<Network> changed_network =
624 std::make_unique<Network>(*network_to_change);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000625 network_to_change->AddIP(ip);
626 IPAddress changed_ip;
627 EXPECT_TRUE(IPFromString("2401:fa01:4:1000:be30:f00:f00:f00", &changed_ip));
628 changed_network->AddIP(changed_ip);
Niels Möllerd959f3a2022-04-19 11:29:19 +0200629 const Network* const network_to_change_ptr = network_to_change.get();
630 original_list.push_back(std::move(network_to_change));
631 const size_t original_size = original_list.size();
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000632 bool changed = false;
Niels Möllerd959f3a2022-04-19 11:29:19 +0200633 MergeNetworkList(manager, std::move(original_list), &changed);
634 std::vector<std::unique_ptr<Network>> second_list;
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000635 SetupNetworks(&second_list);
Niels Möllerd959f3a2022-04-19 11:29:19 +0200636 second_list.push_back(std::move(changed_network));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000637 changed = false;
Niels Möllerd959f3a2022-04-19 11:29:19 +0200638 MergeNetworkList(manager, std::move(second_list), &changed);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000639 EXPECT_TRUE(changed);
Niels Möller22211442022-04-07 11:43:28 +0200640 std::vector<const Network*> list = manager.GetNetworks();
Niels Möllerd959f3a2022-04-19 11:29:19 +0200641 EXPECT_EQ(original_size, list.size());
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000642 // Make sure the original network is still in the merged list.
Niels Möllerd959f3a2022-04-19 11:29:19 +0200643 EXPECT_THAT(list, Contains(network_to_change_ptr));
644 EXPECT_EQ(changed_ip, network_to_change_ptr->GetIPs().at(0));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000645}
646
Niels Möllerd959f3a2022-04-19 11:29:19 +0200647TEST_F(NetworkTest, TestMultipleIPMergeNetworkList) {
Niels Möller539f3e12021-11-26 16:33:19 +0100648 PhysicalSocketServer socket_server;
649 BasicNetworkManager manager(&socket_server);
Yves Gerey665174f2018-06-19 15:03:05 +0200650 manager.SignalNetworksChanged.connect(static_cast<NetworkTest*>(this),
651 &NetworkTest::OnNetworksChanged);
Niels Möllerd959f3a2022-04-19 11:29:19 +0200652 std::vector<std::unique_ptr<Network>> original_list;
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000653 SetupNetworks(&original_list);
Niels Möllerd959f3a2022-04-19 11:29:19 +0200654 const Network* const network_ptr = original_list[2].get();
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000655 bool changed = false;
Niels Möllerd959f3a2022-04-19 11:29:19 +0200656 MergeNetworkList(manager, std::move(original_list), &changed);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000657 EXPECT_TRUE(changed);
658 IPAddress ip;
659 IPAddress check_ip;
660 IPAddress prefix;
661 // Add a second IP to the public network on eth0 (2401:fa00:4:1000/64).
662 EXPECT_TRUE(IPFromString("2401:fa00:4:1000:be30:5bff:fee5:c6", &ip));
663 prefix = TruncateIP(ip, 64);
664 Network ipv6_eth0_publicnetwork1_ip2("test_eth0", "Test NetworkAdapter 1",
665 prefix, 64);
666 // This is the IP that already existed in the public network on eth0.
667 EXPECT_TRUE(IPFromString("2401:fa00:4:1000:be30:5bff:fee5:c3", &check_ip));
668 ipv6_eth0_publicnetwork1_ip2.AddIP(ip);
Niels Möllerd959f3a2022-04-19 11:29:19 +0200669
670 std::vector<std::unique_ptr<Network>> second_list;
671 SetupNetworks(&second_list);
672 second_list.push_back(
673 std::make_unique<Network>(ipv6_eth0_publicnetwork1_ip2));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000674 changed = false;
Niels Möllerd959f3a2022-04-19 11:29:19 +0200675 const auto network_copy = std::make_unique<Network>(*second_list[2]);
676 MergeNetworkList(manager, std::move(second_list), &changed);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000677 EXPECT_TRUE(changed);
678 // There should still be four networks.
Niels Möller22211442022-04-07 11:43:28 +0200679 std::vector<const Network*> list = manager.GetNetworks();
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000680 EXPECT_EQ(4U, list.size());
681 // Check the gathered IPs.
682 int matchcount = 0;
Niels Möller22211442022-04-07 11:43:28 +0200683 for (const Network* network : list) {
Niels Möllerd959f3a2022-04-19 11:29:19 +0200684 if (SameNameAndPrefix(*network, *network_copy)) {
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000685 ++matchcount;
686 EXPECT_EQ(1, matchcount);
687 // This should be the same network object as before.
Niels Möllerd959f3a2022-04-19 11:29:19 +0200688 EXPECT_EQ(network, network_ptr);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000689 // But with two addresses now.
Niels Möller22211442022-04-07 11:43:28 +0200690 EXPECT_THAT(network->GetIPs(),
Steve Anton2acd1632019-03-25 13:48:30 -0700691 UnorderedElementsAre(InterfaceAddress(check_ip),
692 InterfaceAddress(ip)));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000693 } else {
694 // Check the IP didn't get added anywhere it wasn't supposed to.
Niels Möller22211442022-04-07 11:43:28 +0200695 EXPECT_THAT(network->GetIPs(), Not(Contains(InterfaceAddress(ip))));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000696 }
697 }
698}
699
700// Test that merge correctly distinguishes multiple networks on an interface.
701TEST_F(NetworkTest, TestMultiplePublicNetworksOnOneInterfaceMerge) {
Niels Möller539f3e12021-11-26 16:33:19 +0100702 PhysicalSocketServer socket_server;
703 BasicNetworkManager manager(&socket_server);
Yves Gerey665174f2018-06-19 15:03:05 +0200704 manager.SignalNetworksChanged.connect(static_cast<NetworkTest*>(this),
705 &NetworkTest::OnNetworksChanged);
Niels Möllerd959f3a2022-04-19 11:29:19 +0200706 std::vector<std::unique_ptr<Network>> original_list;
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000707 SetupNetworks(&original_list);
708 bool changed = false;
Niels Möllerd959f3a2022-04-19 11:29:19 +0200709 MergeNetworkList(manager, std::move(original_list), &changed);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000710 EXPECT_TRUE(changed);
711 IPAddress ip;
712 IPAddress prefix;
713 // A second network for eth0.
714 EXPECT_TRUE(IPFromString("2400:4030:1:2c00:be30:5bff:fee5:c3", &ip));
715 prefix = TruncateIP(ip, 64);
716 Network ipv6_eth0_publicnetwork2_ip1("test_eth0", "Test NetworkAdapter 1",
717 prefix, 64);
718 ipv6_eth0_publicnetwork2_ip1.AddIP(ip);
Niels Möllerd959f3a2022-04-19 11:29:19 +0200719 std::vector<std::unique_ptr<Network>> second_list;
720 SetupNetworks(&second_list);
721 second_list.push_back(
722 std::make_unique<Network>(ipv6_eth0_publicnetwork2_ip1));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000723 changed = false;
Niels Möllerd959f3a2022-04-19 11:29:19 +0200724 MergeNetworkList(manager, std::move(second_list), &changed);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000725 EXPECT_TRUE(changed);
726 // There should be five networks now.
Niels Möller22211442022-04-07 11:43:28 +0200727 std::vector<const Network*> list = manager.GetNetworks();
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000728 EXPECT_EQ(5U, list.size());
729 // Check the resulting addresses.
Niels Möller22211442022-04-07 11:43:28 +0200730 for (const Network* network : list) {
731 if (network->prefix() == ipv6_eth0_publicnetwork2_ip1.prefix() &&
732 network->name() == ipv6_eth0_publicnetwork2_ip1.name()) {
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000733 // Check the new network has 1 IP and that it's the correct one.
Niels Möller22211442022-04-07 11:43:28 +0200734 EXPECT_EQ(1U, network->GetIPs().size());
735 EXPECT_EQ(ip, network->GetIPs().at(0));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000736 } else {
737 // Check the IP didn't get added anywhere it wasn't supposed to.
Niels Möller22211442022-04-07 11:43:28 +0200738 EXPECT_THAT(network->GetIPs(), Not(Contains(InterfaceAddress(ip))));
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000739 }
740 }
741}
742
honghaizdb8cf502015-12-21 13:08:46 -0800743// Test that DumpNetworks does not crash.
744TEST_F(NetworkTest, TestCreateAndDumpNetworks) {
Niels Möller539f3e12021-11-26 16:33:19 +0100745 PhysicalSocketServer socket_server;
746 BasicNetworkManager manager(&socket_server);
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -0700747 manager.StartUpdating();
Niels Möllerd959f3a2022-04-19 11:29:19 +0200748 std::vector<std::unique_ptr<Network>> list = GetNetworks(manager, true);
honghaizdb8cf502015-12-21 13:08:46 -0800749 bool changed;
Niels Möllerd959f3a2022-04-19 11:29:19 +0200750 MergeNetworkList(manager, std::move(list), &changed);
honghaizdb8cf502015-12-21 13:08:46 -0800751 manager.DumpNetworks();
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000752}
753
Mirko Bonadei44f0f872019-01-20 18:16:42 +0100754TEST_F(NetworkTest, TestIPv6Toggle) {
Niels Möller539f3e12021-11-26 16:33:19 +0100755 PhysicalSocketServer socket_server;
756 BasicNetworkManager manager(&socket_server);
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -0700757 manager.StartUpdating();
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000758 bool ipv6_found = false;
Niels Möllerd959f3a2022-04-19 11:29:19 +0200759 for (const auto& network : GetNetworks(manager, true)) {
760 if (network->prefix().family() == AF_INET6) {
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000761 ipv6_found = true;
762 break;
763 }
764 }
765 EXPECT_TRUE(ipv6_found);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000766}
767
deadbeef3427f532017-07-26 16:09:33 -0700768// Test that when network interfaces are sorted and given preference values,
769// IPv6 comes first.
770TEST_F(NetworkTest, IPv6NetworksPreferredOverIPv4) {
Niels Möller539f3e12021-11-26 16:33:19 +0100771 PhysicalSocketServer socket_server;
772 BasicNetworkManager manager(&socket_server);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000773 Network ipv4_network1("test_eth0", "Test Network Adapter 1",
774 IPAddress(0x12345600U), 24);
775 ipv4_network1.AddIP(IPAddress(0x12345600U));
776
777 IPAddress ip;
778 IPAddress prefix;
779 EXPECT_TRUE(IPFromString("2400:4030:1:2c00:be30:abcd:efab:cdef", &ip));
780 prefix = TruncateIP(ip, 64);
781 Network ipv6_eth1_publicnetwork1_ip1("test_eth1", "Test NetworkAdapter 2",
782 prefix, 64);
783 ipv6_eth1_publicnetwork1_ip1.AddIP(ip);
784
Niels Möllerd959f3a2022-04-19 11:29:19 +0200785 std::vector<std::unique_ptr<Network>> list;
786 list.push_back(std::make_unique<Network>(ipv4_network1));
787 list.push_back(std::make_unique<Network>(ipv6_eth1_publicnetwork1_ip1));
788 const Network* net1 = list[0].get();
789 const Network* net2 = list[1].get();
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000790
791 bool changed = false;
Niels Möllerd959f3a2022-04-19 11:29:19 +0200792 MergeNetworkList(manager, std::move(list), &changed);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000793 ASSERT_TRUE(changed);
794 // After sorting IPv6 network should be higher order than IPv4 networks.
795 EXPECT_TRUE(net1->preference() < net2->preference());
796}
797
deadbeef3427f532017-07-26 16:09:33 -0700798// When two interfaces are equivalent in everything but name, they're expected
799// to be preference-ordered by name. For example, "eth0" before "eth1".
800TEST_F(NetworkTest, NetworksSortedByInterfaceName) {
Niels Möller539f3e12021-11-26 16:33:19 +0100801 PhysicalSocketServer socket_server;
Jonas Orelandc06fe8b2022-03-28 14:58:26 +0200802 BasicNetworkManager manager(&socket_server, &field_trials_);
Niels Möllerd959f3a2022-04-19 11:29:19 +0200803 auto eth0 = std::make_unique<Network>("test_eth0", "Test Network Adapter 1",
804 IPAddress(0x65432100U), 24);
deadbeef3427f532017-07-26 16:09:33 -0700805 eth0->AddIP(IPAddress(0x65432100U));
Niels Möllerd959f3a2022-04-19 11:29:19 +0200806 auto eth1 = std::make_unique<Network>("test_eth1", "Test Network Adapter 2",
807 IPAddress(0x12345600U), 24);
deadbeef3427f532017-07-26 16:09:33 -0700808 eth1->AddIP(IPAddress(0x12345600U));
Niels Möllerd959f3a2022-04-19 11:29:19 +0200809 std::vector<std::unique_ptr<Network>> list;
810 const Network* eth0_ptr = eth0.get();
811 const Network* eth1_ptr = eth1.get();
deadbeef3427f532017-07-26 16:09:33 -0700812 // Add them to the list in the opposite of the expected sorted order, to
813 // ensure sorting actually occurs.
Niels Möllerd959f3a2022-04-19 11:29:19 +0200814 list.push_back(std::move(eth1));
815 list.push_back(std::move(eth0));
deadbeef3427f532017-07-26 16:09:33 -0700816
817 bool changed = false;
Niels Möllerd959f3a2022-04-19 11:29:19 +0200818 MergeNetworkList(manager, std::move(list), &changed);
deadbeef3427f532017-07-26 16:09:33 -0700819 ASSERT_TRUE(changed);
820 // "test_eth0" should be preferred over "test_eth1".
Niels Möllerd959f3a2022-04-19 11:29:19 +0200821 EXPECT_TRUE(eth0_ptr->preference() > eth1_ptr->preference());
deadbeef3427f532017-07-26 16:09:33 -0700822}
823
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000824TEST_F(NetworkTest, TestNetworkAdapterTypes) {
825 Network wifi("wlan0", "Wireless Adapter", IPAddress(0x12345600U), 24,
Diep Bui1e589eb2022-08-02 07:37:30 +0000826 ADAPTER_TYPE_WIFI, &field_trials_);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000827 EXPECT_EQ(ADAPTER_TYPE_WIFI, wifi.type());
828 Network ethernet("eth0", "Ethernet", IPAddress(0x12345600U), 24,
Diep Bui1e589eb2022-08-02 07:37:30 +0000829 ADAPTER_TYPE_ETHERNET, &field_trials_);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000830 EXPECT_EQ(ADAPTER_TYPE_ETHERNET, ethernet.type());
831 Network cellular("test_cell", "Cellular Adapter", IPAddress(0x12345600U), 24,
Diep Bui1e589eb2022-08-02 07:37:30 +0000832 ADAPTER_TYPE_CELLULAR, &field_trials_);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000833 EXPECT_EQ(ADAPTER_TYPE_CELLULAR, cellular.type());
834 Network vpn("bridge_test", "VPN Adapter", IPAddress(0x12345600U), 24,
Diep Bui1e589eb2022-08-02 07:37:30 +0000835 ADAPTER_TYPE_VPN, &field_trials_);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000836 EXPECT_EQ(ADAPTER_TYPE_VPN, vpn.type());
837 Network unknown("test", "Test Adapter", IPAddress(0x12345600U), 24,
Diep Bui1e589eb2022-08-02 07:37:30 +0000838 ADAPTER_TYPE_UNKNOWN, &field_trials_);
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000839 EXPECT_EQ(ADAPTER_TYPE_UNKNOWN, unknown.type());
840}
841
842#if defined(WEBRTC_POSIX)
843// Verify that we correctly handle interfaces with no address.
844TEST_F(NetworkTest, TestConvertIfAddrsNoAddress) {
845 ifaddrs list;
846 memset(&list, 0, sizeof(list));
847 list.ifa_name = const_cast<char*>("test_iface");
848
Niels Möllerd959f3a2022-04-19 11:29:19 +0200849 std::vector<std::unique_ptr<Network>> result;
Niels Möller539f3e12021-11-26 16:33:19 +0100850 PhysicalSocketServer socket_server;
851 BasicNetworkManager manager(&socket_server);
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -0700852 manager.StartUpdating();
henrike@webrtc.orgf0488722014-05-13 18:00:26 +0000853 CallConvertIfAddrs(manager, &list, true, &result);
854 EXPECT_TRUE(result.empty());
855}
honghaizdb8cf502015-12-21 13:08:46 -0800856
857// Verify that if there are two addresses on one interface, only one network
858// is generated.
859TEST_F(NetworkTest, TestConvertIfAddrsMultiAddressesOnOneInterface) {
860 char if_name[20] = "rmnet0";
861 ifaddrs* list = nullptr;
862 list = AddIpv6Address(list, if_name, "1000:2000:3000:4000:0:0:0:1",
863 "FFFF:FFFF:FFFF:FFFF::", 0);
864 list = AddIpv6Address(list, if_name, "1000:2000:3000:4000:0:0:0:2",
865 "FFFF:FFFF:FFFF:FFFF::", 0);
Niels Möllerd959f3a2022-04-19 11:29:19 +0200866 std::vector<std::unique_ptr<Network>> result;
Niels Möller539f3e12021-11-26 16:33:19 +0100867 PhysicalSocketServer socket_server;
868 BasicNetworkManager manager(&socket_server);
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -0700869 manager.StartUpdating();
honghaizdb8cf502015-12-21 13:08:46 -0800870 CallConvertIfAddrs(manager, list, true, &result);
871 EXPECT_EQ(1U, result.size());
872 bool changed;
873 // This ensures we release the objects created in CallConvertIfAddrs.
Niels Möllerd959f3a2022-04-19 11:29:19 +0200874 MergeNetworkList(manager, std::move(result), &changed);
honghaizdb8cf502015-12-21 13:08:46 -0800875 ReleaseIfAddrs(list);
876}
Guo-wei Shieh9faf1542015-12-28 14:06:55 -0800877
878TEST_F(NetworkTest, TestConvertIfAddrsNotRunning) {
879 ifaddrs list;
880 memset(&list, 0, sizeof(list));
881 list.ifa_name = const_cast<char*>("test_iface");
882 sockaddr ifa_addr;
883 sockaddr ifa_netmask;
884 list.ifa_addr = &ifa_addr;
885 list.ifa_netmask = &ifa_netmask;
886
Niels Möllerd959f3a2022-04-19 11:29:19 +0200887 std::vector<std::unique_ptr<Network>> result;
Niels Möller539f3e12021-11-26 16:33:19 +0100888 PhysicalSocketServer socket_server;
889 BasicNetworkManager manager(&socket_server);
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -0700890 manager.StartUpdating();
Guo-wei Shieh9faf1542015-12-28 14:06:55 -0800891 CallConvertIfAddrs(manager, &list, true, &result);
892 EXPECT_TRUE(result.empty());
893}
Honghai Zhang351d77b2016-05-20 15:08:29 -0700894
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -0700895// Tests that the network type can be determined from the network monitor when
896// it would otherwise be unknown.
Honghai Zhang351d77b2016-05-20 15:08:29 -0700897TEST_F(NetworkTest, TestGetAdapterTypeFromNetworkMonitor) {
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -0700898 char if_name[20] = "wifi0";
899 std::string ipv6_address = "1000:2000:3000:4000:0:0:0:1";
Honghai Zhang351d77b2016-05-20 15:08:29 -0700900 std::string ipv6_mask = "FFFF:FFFF:FFFF:FFFF::";
Niels Mölleraa373162021-09-28 16:09:07 +0200901 PhysicalSocketServer socket_server;
Jonas Orelandc06fe8b2022-03-28 14:58:26 +0200902 BasicNetworkManager manager_without_monitor(nullptr, &socket_server,
903 &field_trials_);
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -0700904 manager_without_monitor.StartUpdating();
905 // A network created without a network monitor will get UNKNOWN type.
906 ifaddrs* addr_list = InstallIpv6Network(if_name, ipv6_address, ipv6_mask,
907 manager_without_monitor);
908 EXPECT_EQ(ADAPTER_TYPE_UNKNOWN, GetAdapterType(manager_without_monitor));
Honghai Zhang351d77b2016-05-20 15:08:29 -0700909 ReleaseIfAddrs(addr_list);
Honghai Zhang351d77b2016-05-20 15:08:29 -0700910
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -0700911 // With the fake network monitor the type should be correctly determined.
912 FakeNetworkMonitorFactory factory;
Jonas Orelandc06fe8b2022-03-28 14:58:26 +0200913 BasicNetworkManager manager_with_monitor(&factory, &socket_server,
914 &field_trials_);
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -0700915 manager_with_monitor.StartUpdating();
Honghai Zhang351d77b2016-05-20 15:08:29 -0700916 // Add the same ipv6 address as before but it has the right network type
917 // detected by the network monitor now.
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -0700918 addr_list = InstallIpv6Network(if_name, ipv6_address, ipv6_mask,
919 manager_with_monitor);
920 EXPECT_EQ(ADAPTER_TYPE_WIFI, GetAdapterType(manager_with_monitor));
Honghai Zhang351d77b2016-05-20 15:08:29 -0700921 ReleaseIfAddrs(addr_list);
Honghai Zhang351d77b2016-05-20 15:08:29 -0700922}
923
924// Test that the network type can be determined based on name matching in
925// a few cases. Note that UNKNOWN type for non-matching strings has been tested
926// in the above test.
927TEST_F(NetworkTest, TestGetAdapterTypeFromNameMatching) {
Jeroen de Borst8f096d02019-02-21 13:34:45 -0800928 std::string ipv4_address1 = "192.0.0.121";
929 std::string ipv4_mask = "255.255.255.0";
Honghai Zhang351d77b2016-05-20 15:08:29 -0700930 std::string ipv6_address1 = "1000:2000:3000:4000:0:0:0:1";
931 std::string ipv6_address2 = "1000:2000:3000:8000:0:0:0:1";
932 std::string ipv6_mask = "FFFF:FFFF:FFFF:FFFF::";
Niels Möller539f3e12021-11-26 16:33:19 +0100933 PhysicalSocketServer socket_server;
934 BasicNetworkManager manager(&socket_server);
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -0700935 manager.StartUpdating();
Honghai Zhang351d77b2016-05-20 15:08:29 -0700936
deadbeef4cd599f2017-07-27 15:05:29 -0700937 // IPSec interface; name is in form "ipsec<index>".
938 char if_name[20] = "ipsec11";
Honghai Zhang351d77b2016-05-20 15:08:29 -0700939 ifaddrs* addr_list =
940 InstallIpv6Network(if_name, ipv6_address1, ipv6_mask, manager);
deadbeef4cd599f2017-07-27 15:05:29 -0700941 EXPECT_EQ(ADAPTER_TYPE_VPN, GetAdapterType(manager));
942 ClearNetworks(manager);
943 ReleaseIfAddrs(addr_list);
Honghai Zhang351d77b2016-05-20 15:08:29 -0700944
Qingsi Wange53ac042018-05-08 11:55:07 -0700945 strcpy(if_name, "lo0");
946 addr_list = InstallIpv6Network(if_name, ipv6_address1, ipv6_mask, manager);
947 EXPECT_EQ(ADAPTER_TYPE_LOOPBACK, GetAdapterType(manager));
948 ClearNetworks(manager);
949 ReleaseIfAddrs(addr_list);
950
951 strcpy(if_name, "eth0");
Jeroen de Borst8f096d02019-02-21 13:34:45 -0800952 addr_list = InstallIpv4Network(if_name, ipv4_address1, ipv4_mask, manager);
Qingsi Wange53ac042018-05-08 11:55:07 -0700953 EXPECT_EQ(ADAPTER_TYPE_ETHERNET, GetAdapterType(manager));
954 ClearNetworks(manager);
955 ReleaseIfAddrs(addr_list);
956
Qingsi Wangc5bc9d62019-09-25 15:03:19 -0700957 strcpy(if_name, "wlan0");
958 addr_list = InstallIpv6Network(if_name, ipv6_address1, ipv6_mask, manager);
959 EXPECT_EQ(ADAPTER_TYPE_WIFI, GetAdapterType(manager));
960 ClearNetworks(manager);
961 ReleaseIfAddrs(addr_list);
962
deadbeef4cd599f2017-07-27 15:05:29 -0700963#if defined(WEBRTC_IOS)
964 strcpy(if_name, "pdp_ip0");
965 addr_list = InstallIpv6Network(if_name, ipv6_address1, ipv6_mask, manager);
Honghai Zhang351d77b2016-05-20 15:08:29 -0700966 EXPECT_EQ(ADAPTER_TYPE_CELLULAR, GetAdapterType(manager));
967 ClearNetworks(manager);
968 ReleaseIfAddrs(addr_list);
969
Honghai Zhang63ab8102016-05-26 20:30:15 -0700970 strcpy(if_name, "en0");
971 addr_list = InstallIpv6Network(if_name, ipv6_address1, ipv6_mask, manager);
972 EXPECT_EQ(ADAPTER_TYPE_WIFI, GetAdapterType(manager));
973 ClearNetworks(manager);
974 ReleaseIfAddrs(addr_list);
975
Honghai Zhang351d77b2016-05-20 15:08:29 -0700976#elif defined(WEBRTC_ANDROID)
deadbeef4cd599f2017-07-27 15:05:29 -0700977 strcpy(if_name, "rmnet0");
978 addr_list = InstallIpv6Network(if_name, ipv6_address1, ipv6_mask, manager);
Honghai Zhang351d77b2016-05-20 15:08:29 -0700979 EXPECT_EQ(ADAPTER_TYPE_CELLULAR, GetAdapterType(manager));
980 ClearNetworks(manager);
981 ReleaseIfAddrs(addr_list);
982
Honghai Zhang351d77b2016-05-20 15:08:29 -0700983 strcpy(if_name, "v4-rmnet_data0");
984 addr_list = InstallIpv6Network(if_name, ipv6_address2, ipv6_mask, manager);
985 EXPECT_EQ(ADAPTER_TYPE_CELLULAR, GetAdapterType(manager));
986 ClearNetworks(manager);
987 ReleaseIfAddrs(addr_list);
Jeroen de Borst8f096d02019-02-21 13:34:45 -0800988
989 strcpy(if_name, "clat4");
990 addr_list = InstallIpv4Network(if_name, ipv4_address1, ipv4_mask, manager);
991 EXPECT_EQ(ADAPTER_TYPE_CELLULAR, GetAdapterType(manager));
992 ClearNetworks(manager);
993 ReleaseIfAddrs(addr_list);
Honghai Zhang351d77b2016-05-20 15:08:29 -0700994#endif
995}
Taylor Brandstetterea7fbfb2020-08-19 16:41:54 -0700996
997// Test that an adapter won't be included in the network list if there's a
998// network monitor that says it's unavailable.
999TEST_F(NetworkTest, TestNetworkMonitorIsAdapterAvailable) {
1000 char if_name1[20] = "pdp_ip0";
1001 char if_name2[20] = "pdp_ip1";
1002 ifaddrs* list = nullptr;
1003 list = AddIpv6Address(list, if_name1, "1000:2000:3000:4000:0:0:0:1",
1004 "FFFF:FFFF:FFFF:FFFF::", 0);
1005 list = AddIpv6Address(list, if_name2, "1000:2000:3000:4000:0:0:0:2",
1006 "FFFF:FFFF:FFFF:FFFF::", 0);
Niels Möllerd959f3a2022-04-19 11:29:19 +02001007 std::vector<std::unique_ptr<Network>> result;
Taylor Brandstetterea7fbfb2020-08-19 16:41:54 -07001008
1009 // Sanity check that both interfaces are included by default.
1010 FakeNetworkMonitorFactory factory;
Niels Mölleraa373162021-09-28 16:09:07 +02001011 PhysicalSocketServer socket_server;
Jonas Orelandc06fe8b2022-03-28 14:58:26 +02001012 BasicNetworkManager manager(&factory, &socket_server, &field_trials_);
Taylor Brandstetterea7fbfb2020-08-19 16:41:54 -07001013 manager.StartUpdating();
1014 CallConvertIfAddrs(manager, list, /*include_ignored=*/false, &result);
1015 EXPECT_EQ(2u, result.size());
1016 bool changed;
1017 // This ensures we release the objects created in CallConvertIfAddrs.
Niels Möllerd959f3a2022-04-19 11:29:19 +02001018 MergeNetworkList(manager, std::move(result), &changed);
Taylor Brandstetterea7fbfb2020-08-19 16:41:54 -07001019 result.clear();
1020
1021 // Now simulate one interface being unavailable.
1022 FakeNetworkMonitor* network_monitor = GetNetworkMonitor(manager);
1023 network_monitor->set_unavailable_adapters({if_name1});
1024 CallConvertIfAddrs(manager, list, /*include_ignored=*/false, &result);
1025 EXPECT_EQ(1u, result.size());
1026 EXPECT_EQ(if_name2, result[0]->name());
1027
Niels Möllerd959f3a2022-04-19 11:29:19 +02001028 MergeNetworkList(manager, std::move(result), &changed);
Taylor Brandstetterea7fbfb2020-08-19 16:41:54 -07001029 ReleaseIfAddrs(list);
1030}
1031
henrike@webrtc.orgf0488722014-05-13 18:00:26 +00001032#endif // defined(WEBRTC_POSIX)
1033
guoweis@webrtc.org4bbd3c82014-09-09 13:54:45 +00001034// Test MergeNetworkList successfully combines all IPs for the same
1035// prefix/length into a single Network.
1036TEST_F(NetworkTest, TestMergeNetworkList) {
Niels Möller539f3e12021-11-26 16:33:19 +01001037 PhysicalSocketServer socket_server;
1038 BasicNetworkManager manager(&socket_server);
Niels Möllerd959f3a2022-04-19 11:29:19 +02001039 std::vector<std::unique_ptr<Network>> list;
guoweis@webrtc.org4bbd3c82014-09-09 13:54:45 +00001040
1041 // Create 2 IPAddress classes with only last digit different.
1042 IPAddress ip1, ip2;
1043 EXPECT_TRUE(IPFromString("2400:4030:1:2c00:be30:0:0:1", &ip1));
1044 EXPECT_TRUE(IPFromString("2400:4030:1:2c00:be30:0:0:2", &ip2));
1045
1046 // Create 2 networks with the same prefix and length.
Niels Möllerd959f3a2022-04-19 11:29:19 +02001047 auto net1 = std::make_unique<Network>("em1", "em1", TruncateIP(ip1, 64), 64);
1048 auto net2 = std::make_unique<Network>("em1", "em1", TruncateIP(ip1, 64), 64);
guoweis@webrtc.org4bbd3c82014-09-09 13:54:45 +00001049
1050 // Add different IP into each.
1051 net1->AddIP(ip1);
1052 net2->AddIP(ip2);
1053
Niels Möllerd959f3a2022-04-19 11:29:19 +02001054 list.push_back(std::move(net1));
1055 list.push_back(std::move(net2));
guoweis@webrtc.org4bbd3c82014-09-09 13:54:45 +00001056 bool changed;
Niels Möllerd959f3a2022-04-19 11:29:19 +02001057 MergeNetworkList(manager, std::move(list), &changed);
guoweis@webrtc.org4bbd3c82014-09-09 13:54:45 +00001058 EXPECT_TRUE(changed);
1059
Niels Möller22211442022-04-07 11:43:28 +02001060 std::vector<const Network*> list2 = manager.GetNetworks();
guoweis@webrtc.org4bbd3c82014-09-09 13:54:45 +00001061
1062 // Make sure the resulted networklist has only 1 element and 2
1063 // IPAddresses.
1064 EXPECT_EQ(list2.size(), 1uL);
1065 EXPECT_EQ(list2[0]->GetIPs().size(), 2uL);
Mirko Bonadeib2a57852022-03-18 12:19:56 +01001066 EXPECT_THAT(list2[0]->GetIPs(), UnorderedElementsAre(InterfaceAddress(ip1),
1067 InterfaceAddress(ip2)));
guoweis@webrtc.org4bbd3c82014-09-09 13:54:45 +00001068}
1069
honghaizdb8cf502015-12-21 13:08:46 -08001070// Test that MergeNetworkList successfully detects the change if
1071// a network becomes inactive and then active again.
1072TEST_F(NetworkTest, TestMergeNetworkListWithInactiveNetworks) {
Niels Möller539f3e12021-11-26 16:33:19 +01001073 PhysicalSocketServer socket_server;
1074 BasicNetworkManager manager(&socket_server);
honghaizdb8cf502015-12-21 13:08:46 -08001075 Network network1("test_wifi", "Test Network Adapter 1",
1076 IPAddress(0x12345600U), 24);
1077 Network network2("test_eth0", "Test Network Adapter 2",
1078 IPAddress(0x00010000U), 16);
1079 network1.AddIP(IPAddress(0x12345678));
1080 network2.AddIP(IPAddress(0x00010004));
Niels Möllerd959f3a2022-04-19 11:29:19 +02001081 std::vector<std::unique_ptr<Network>> list;
1082 auto net1 = std::make_unique<Network>(network1);
1083 const Network* const net1_ptr = net1.get();
1084 list.push_back(std::move(net1));
honghaizdb8cf502015-12-21 13:08:46 -08001085 bool changed;
Niels Möllerd959f3a2022-04-19 11:29:19 +02001086 MergeNetworkList(manager, std::move(list), &changed);
honghaizdb8cf502015-12-21 13:08:46 -08001087 EXPECT_TRUE(changed);
1088 list.clear();
Niels Möller22211442022-04-07 11:43:28 +02001089
1090 std::vector<const Network*> current = manager.GetNetworks();
1091 ASSERT_EQ(1U, current.size());
Niels Möllerd959f3a2022-04-19 11:29:19 +02001092 EXPECT_EQ(net1_ptr, current[0]);
honghaizdb8cf502015-12-21 13:08:46 -08001093
1094 list.clear();
Niels Möllerd959f3a2022-04-19 11:29:19 +02001095 auto net2 = std::make_unique<Network>(network2);
1096 const Network* const net2_ptr = net2.get();
1097 list.push_back(std::move(net2));
1098 MergeNetworkList(manager, std::move(list), &changed);
honghaizdb8cf502015-12-21 13:08:46 -08001099 EXPECT_TRUE(changed);
1100 list.clear();
Niels Möller22211442022-04-07 11:43:28 +02001101
1102 current = manager.GetNetworks();
1103 ASSERT_EQ(1U, current.size());
Niels Möllerd959f3a2022-04-19 11:29:19 +02001104 EXPECT_EQ(net2_ptr, current[0]);
honghaizdb8cf502015-12-21 13:08:46 -08001105 // Now network1 is inactive. Try to merge it again.
1106 list.clear();
Niels Möllerd959f3a2022-04-19 11:29:19 +02001107 list.push_back(std::make_unique<Network>(network1));
1108 MergeNetworkList(manager, std::move(list), &changed);
honghaizdb8cf502015-12-21 13:08:46 -08001109 EXPECT_TRUE(changed);
1110 list.clear();
Niels Möller22211442022-04-07 11:43:28 +02001111 current = manager.GetNetworks();
1112 ASSERT_EQ(1U, current.size());
1113 EXPECT_TRUE(current[0]->active());
Niels Möllerd959f3a2022-04-19 11:29:19 +02001114 EXPECT_EQ(net1_ptr, current[0]);
honghaizdb8cf502015-12-21 13:08:46 -08001115}
1116
guoweis@webrtc.org369a6372014-09-17 22:37:29 +00001117// Test that the filtering logic follows the defined ruleset in network.h.
1118TEST_F(NetworkTest, TestIPv6Selection) {
1119 InterfaceAddress ip;
1120 std::string ipstr;
1121
1122 ipstr = "2401:fa00:4:1000:be30:5bff:fee5:c3";
1123 ASSERT_TRUE(IPFromString(ipstr, IPV6_ADDRESS_FLAG_DEPRECATED, &ip));
1124
1125 // Create a network with this prefix.
Yves Gerey665174f2018-06-19 15:03:05 +02001126 Network ipv6_network("test_eth0", "Test NetworkAdapter", TruncateIP(ip, 64),
1127 64);
guoweis@webrtc.org369a6372014-09-17 22:37:29 +00001128
1129 // When there is no address added, it should return an unspecified
1130 // address.
1131 EXPECT_EQ(ipv6_network.GetBestIP(), IPAddress());
1132 EXPECT_TRUE(IPIsUnspec(ipv6_network.GetBestIP()));
1133
1134 // Deprecated one should not be returned.
1135 ipv6_network.AddIP(ip);
1136 EXPECT_EQ(ipv6_network.GetBestIP(), IPAddress());
1137
aluebs@webrtc.org07dcf602015-02-27 18:42:22 +00001138 // Add ULA one. ULA is unique local address which is starting either
1139 // with 0xfc or 0xfd.
guoweis@webrtc.org369a6372014-09-17 22:37:29 +00001140 ipstr = "fd00:fa00:4:1000:be30:5bff:fee5:c4";
1141 ASSERT_TRUE(IPFromString(ipstr, IPV6_ADDRESS_FLAG_NONE, &ip));
1142 ipv6_network.AddIP(ip);
aluebs@webrtc.org07dcf602015-02-27 18:42:22 +00001143 EXPECT_EQ(ipv6_network.GetBestIP(), static_cast<IPAddress>(ip));
guoweis@webrtc.org369a6372014-09-17 22:37:29 +00001144
aluebs@webrtc.org07dcf602015-02-27 18:42:22 +00001145 // Add global one.
guoweis@webrtc.org369a6372014-09-17 22:37:29 +00001146 ipstr = "2401:fa00:4:1000:be30:5bff:fee5:c5";
1147 ASSERT_TRUE(IPFromString(ipstr, IPV6_ADDRESS_FLAG_NONE, &ip));
1148 ipv6_network.AddIP(ip);
aluebs@webrtc.org07dcf602015-02-27 18:42:22 +00001149 EXPECT_EQ(ipv6_network.GetBestIP(), static_cast<IPAddress>(ip));
guoweis@webrtc.org369a6372014-09-17 22:37:29 +00001150
1151 // Add global dynamic temporary one.
1152 ipstr = "2401:fa00:4:1000:be30:5bff:fee5:c6";
1153 ASSERT_TRUE(IPFromString(ipstr, IPV6_ADDRESS_FLAG_TEMPORARY, &ip));
1154 ipv6_network.AddIP(ip);
1155 EXPECT_EQ(ipv6_network.GetBestIP(), static_cast<IPAddress>(ip));
1156}
1157
Diep Bui1e589eb2022-08-02 07:37:30 +00001158// Test that the filtering logic follows the defined ruleset in network.h.
1159TEST_F(NetworkTest, TestGetBestIPWithPreferGlobalIPv6ToLinkLocalEnabled) {
1160 webrtc::test::ScopedKeyValueConfig field_trials(
1161 "WebRTC-PreferGlobalIPv6ToLinkLocal/Enabled/");
1162 InterfaceAddress ip, link_local;
1163 std::string ipstr;
1164
1165 ipstr = "2401:fa00:4:1000:be30:5bff:fee5:c3";
1166 ASSERT_TRUE(IPFromString(ipstr, IPV6_ADDRESS_FLAG_DEPRECATED, &ip));
1167
1168 // Create a network with this prefix.
1169 Network ipv6_network("test_eth0", "Test NetworkAdapter", TruncateIP(ip, 64),
1170 64, ADAPTER_TYPE_UNKNOWN, &field_trials);
1171
1172 // When there is no address added, it should return an unspecified
1173 // address.
1174 EXPECT_EQ(ipv6_network.GetBestIP(), IPAddress());
1175 EXPECT_TRUE(IPIsUnspec(ipv6_network.GetBestIP()));
1176
1177 // Deprecated one should not be returned.
1178 ipv6_network.AddIP(ip);
1179 EXPECT_EQ(ipv6_network.GetBestIP(), IPAddress());
1180
1181 // Add ULA one. ULA is unique local address which is starting either
1182 // with 0xfc or 0xfd.
1183 ipstr = "fd00:fa00:4:1000:be30:5bff:fee5:c4";
1184 ASSERT_TRUE(IPFromString(ipstr, IPV6_ADDRESS_FLAG_NONE, &ip));
1185 ipv6_network.AddIP(ip);
1186 EXPECT_EQ(ipv6_network.GetBestIP(), static_cast<IPAddress>(ip));
1187
1188 // Add link local one.
1189 ipstr = "fe80::aabb:ccff:fedd:eeff";
1190 ASSERT_TRUE(IPFromString(ipstr, IPV6_ADDRESS_FLAG_NONE, &link_local));
1191 ipv6_network.AddIP(link_local);
1192 EXPECT_EQ(ipv6_network.GetBestIP(), static_cast<IPAddress>(link_local));
1193
1194 // Add global one.
1195 ipstr = "2401:fa00:4:1000:be30:5bff:fee5:c5";
1196 ASSERT_TRUE(IPFromString(ipstr, IPV6_ADDRESS_FLAG_NONE, &ip));
1197 ipv6_network.AddIP(ip);
1198 EXPECT_EQ(ipv6_network.GetBestIP(), static_cast<IPAddress>(ip));
1199
1200 // Add another link local address, then the compatible address is still global
1201 // one.
1202 ipstr = "fe80::aabb:ccff:fedd:eedd";
1203 ASSERT_TRUE(IPFromString(ipstr, IPV6_ADDRESS_FLAG_NONE, &link_local));
1204 ipv6_network.AddIP(link_local);
1205 EXPECT_EQ(ipv6_network.GetBestIP(), static_cast<IPAddress>(ip));
1206
1207 // Add global dynamic temporary one.
1208 ipstr = "2401:fa00:4:1000:be30:5bff:fee5:c6";
1209 ASSERT_TRUE(IPFromString(ipstr, IPV6_ADDRESS_FLAG_TEMPORARY, &ip));
1210 ipv6_network.AddIP(ip);
1211 EXPECT_EQ(ipv6_network.GetBestIP(), static_cast<IPAddress>(ip));
1212
1213 // Add another link local address, then the compatible address is still global
1214 // dynamic one.
1215 ipstr = "fe80::aabb:ccff:fedd:eedd";
1216 ASSERT_TRUE(IPFromString(ipstr, IPV6_ADDRESS_FLAG_NONE, &link_local));
1217 ipv6_network.AddIP(link_local);
1218 EXPECT_EQ(ipv6_network.GetBestIP(), static_cast<IPAddress>(ip));
1219}
1220
honghaiz023f3ef2015-10-19 09:39:32 -07001221TEST_F(NetworkTest, TestNetworkMonitoring) {
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -07001222 FakeNetworkMonitorFactory factory;
Niels Mölleraa373162021-09-28 16:09:07 +02001223 PhysicalSocketServer socket_server;
Jonas Orelandc06fe8b2022-03-28 14:58:26 +02001224 BasicNetworkManager manager(&factory, &socket_server, &field_trials_);
honghaiz023f3ef2015-10-19 09:39:32 -07001225 manager.SignalNetworksChanged.connect(static_cast<NetworkTest*>(this),
1226 &NetworkTest::OnNetworksChanged);
honghaiz023f3ef2015-10-19 09:39:32 -07001227 manager.StartUpdating();
honghaizcec0a082016-01-15 14:49:09 -08001228 FakeNetworkMonitor* network_monitor = GetNetworkMonitor(manager);
1229 EXPECT_TRUE(network_monitor && network_monitor->started());
honghaiz023f3ef2015-10-19 09:39:32 -07001230 EXPECT_TRUE_WAIT(callback_called_, 1000);
1231 callback_called_ = false;
1232
1233 // Clear the networks so that there will be network changes below.
1234 ClearNetworks(manager);
1235 // Network manager is started, so the callback is called when the network
1236 // monitor fires the network-change event.
Mirko Bonadei37077932021-07-27 17:00:58 +02001237 network_monitor->InovkeNetworksChangedCallbackForTesting();
honghaiz023f3ef2015-10-19 09:39:32 -07001238 EXPECT_TRUE_WAIT(callback_called_, 1000);
1239
honghaizcec0a082016-01-15 14:49:09 -08001240 // Network manager is stopped.
honghaiz023f3ef2015-10-19 09:39:32 -07001241 manager.StopUpdating();
honghaizcec0a082016-01-15 14:49:09 -08001242 EXPECT_FALSE(GetNetworkMonitor(manager)->started());
honghaiz023f3ef2015-10-19 09:39:32 -07001243}
1244
Edward Lemur8dc945c2016-07-21 10:16:40 +02001245// Fails on Android: https://bugs.chromium.org/p/webrtc/issues/detail?id=4364.
1246#if defined(WEBRTC_ANDROID)
1247#define MAYBE_DefaultLocalAddress DISABLED_DefaultLocalAddress
1248#else
1249#define MAYBE_DefaultLocalAddress DefaultLocalAddress
1250#endif
1251TEST_F(NetworkTest, MAYBE_DefaultLocalAddress) {
Guo-wei Shieha34c39e2015-11-25 13:12:26 -08001252 IPAddress ip;
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -07001253 FakeNetworkMonitorFactory factory;
Niels Mölleraa373162021-09-28 16:09:07 +02001254 PhysicalSocketServer socket_server;
Jonas Orelandc06fe8b2022-03-28 14:58:26 +02001255 TestBasicNetworkManager manager(&factory, &socket_server, field_trials_);
guoweis56271ed2016-01-15 14:45:06 -08001256 manager.SignalNetworksChanged.connect(static_cast<NetworkTest*>(this),
1257 &NetworkTest::OnNetworksChanged);
guoweis56271ed2016-01-15 14:45:06 -08001258 manager.StartUpdating();
1259 EXPECT_TRUE_WAIT(callback_called_, 1000);
Guo-wei Shieha34c39e2015-11-25 13:12:26 -08001260
1261 // Make sure we can query default local address when an address for such
1262 // address family exists.
Niels Möller22211442022-04-07 11:43:28 +02001263 std::vector<const Network*> networks = manager.GetNetworks();
guoweis56271ed2016-01-15 14:45:06 -08001264 EXPECT_TRUE(!networks.empty());
Niels Möller22211442022-04-07 11:43:28 +02001265 for (const Network* network : networks) {
Guo-wei Shieh9af97f82015-11-10 14:47:39 -08001266 if (network->GetBestIP().family() == AF_INET) {
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -07001267 EXPECT_TRUE(QueryDefaultLocalAddress(manager, AF_INET) != IPAddress());
guoweis56271ed2016-01-15 14:45:06 -08001268 } else if (network->GetBestIP().family() == AF_INET6 &&
1269 !IPIsLoopback(network->GetBestIP())) {
1270 // Existence of an IPv6 loopback address doesn't mean it has IPv6 network
1271 // enabled.
Taylor Brandstetter239ac8a2020-07-31 16:07:52 -07001272 EXPECT_TRUE(QueryDefaultLocalAddress(manager, AF_INET6) != IPAddress());
Guo-wei Shieh9af97f82015-11-10 14:47:39 -08001273 }
1274 }
Guo-wei Shieha34c39e2015-11-25 13:12:26 -08001275
1276 // GetDefaultLocalAddress should return the valid default address after set.
1277 manager.set_default_local_addresses(GetLoopbackIP(AF_INET),
1278 GetLoopbackIP(AF_INET6));
1279 EXPECT_TRUE(manager.GetDefaultLocalAddress(AF_INET, &ip));
1280 EXPECT_EQ(ip, GetLoopbackIP(AF_INET));
1281 EXPECT_TRUE(manager.GetDefaultLocalAddress(AF_INET6, &ip));
1282 EXPECT_EQ(ip, GetLoopbackIP(AF_INET6));
honghaizaf83fe62016-04-18 14:50:44 -07001283
1284 // More tests on GetDefaultLocalAddress with ipv6 addresses where the set
1285 // default address may be different from the best IP address of any network.
1286 InterfaceAddress ip1;
1287 EXPECT_TRUE(IPFromString("abcd::1234:5678:abcd:1111",
1288 IPV6_ADDRESS_FLAG_TEMPORARY, &ip1));
1289 // Create a network with a prefix of ip1.
1290 Network ipv6_network("test_eth0", "Test NetworkAdapter", TruncateIP(ip1, 64),
1291 64);
1292 IPAddress ip2;
1293 EXPECT_TRUE(IPFromString("abcd::1234:5678:abcd:2222", &ip2));
1294 ipv6_network.AddIP(ip1);
1295 ipv6_network.AddIP(ip2);
Niels Möllerd959f3a2022-04-19 11:29:19 +02001296 std::vector<std::unique_ptr<Network>> list;
1297 list.push_back(std::make_unique<Network>(ipv6_network));
honghaizaf83fe62016-04-18 14:50:44 -07001298 bool changed;
Niels Möllerd959f3a2022-04-19 11:29:19 +02001299 MergeNetworkList(manager, std::move(list), &changed);
honghaizaf83fe62016-04-18 14:50:44 -07001300 // If the set default address is not in any network, GetDefaultLocalAddress
1301 // should return it.
1302 IPAddress ip3;
1303 EXPECT_TRUE(IPFromString("abcd::1234:5678:abcd:3333", &ip3));
1304 manager.set_default_local_addresses(GetLoopbackIP(AF_INET), ip3);
1305 EXPECT_TRUE(manager.GetDefaultLocalAddress(AF_INET6, &ip));
1306 EXPECT_EQ(ip3, ip);
1307 // If the set default address is in a network, GetDefaultLocalAddress will
1308 // return the best IP in that network.
1309 manager.set_default_local_addresses(GetLoopbackIP(AF_INET), ip2);
1310 EXPECT_TRUE(manager.GetDefaultLocalAddress(AF_INET6, &ip));
1311 EXPECT_EQ(static_cast<IPAddress>(ip1), ip);
1312
Guo-wei Shieh9af97f82015-11-10 14:47:39 -08001313 manager.StopUpdating();
1314}
1315
Jonas Orelandc7ea04a2020-04-03 10:12:28 +02001316// Test that MergeNetworkList does not set change = true
1317// when changing from cellular_X to cellular_Y.
1318TEST_F(NetworkTest, TestWhenNetworkListChangeReturnsChangedFlag) {
Niels Möller539f3e12021-11-26 16:33:19 +01001319 PhysicalSocketServer socket_server;
1320 BasicNetworkManager manager(&socket_server);
Jonas Orelandc7ea04a2020-04-03 10:12:28 +02001321
1322 IPAddress ip1;
1323 EXPECT_TRUE(IPFromString("2400:4030:1:2c00:be30:0:0:1", &ip1));
Niels Möllerd959f3a2022-04-19 11:29:19 +02001324 auto net1 = std::make_unique<Network>("em1", "em1", TruncateIP(ip1, 64), 64);
Jonas Orelandc7ea04a2020-04-03 10:12:28 +02001325 net1->set_type(ADAPTER_TYPE_CELLULAR_3G);
1326 net1->AddIP(ip1);
Niels Möllerd959f3a2022-04-19 11:29:19 +02001327 std::vector<std::unique_ptr<Network>> list;
1328 list.push_back(std::move(net1));
Jonas Orelandc7ea04a2020-04-03 10:12:28 +02001329
1330 {
1331 bool changed;
Niels Möllerd959f3a2022-04-19 11:29:19 +02001332 MergeNetworkList(manager, std::move(list), &changed);
Jonas Orelandc7ea04a2020-04-03 10:12:28 +02001333 EXPECT_TRUE(changed);
Niels Möller22211442022-04-07 11:43:28 +02001334 std::vector<const Network*> list2 = manager.GetNetworks();
Jonas Orelandc7ea04a2020-04-03 10:12:28 +02001335 EXPECT_EQ(list2.size(), 1uL);
1336 EXPECT_EQ(ADAPTER_TYPE_CELLULAR_3G, list2[0]->type());
1337 }
1338
1339 // Modify net1 from 3G to 4G
1340 {
Niels Möllerd959f3a2022-04-19 11:29:19 +02001341 auto net2 =
1342 std::make_unique<Network>("em1", "em1", TruncateIP(ip1, 64), 64);
Jonas Orelandc7ea04a2020-04-03 10:12:28 +02001343 net2->set_type(ADAPTER_TYPE_CELLULAR_4G);
1344 net2->AddIP(ip1);
1345 list.clear();
Niels Möllerd959f3a2022-04-19 11:29:19 +02001346 list.push_back(std::move(net2));
Jonas Orelandc7ea04a2020-04-03 10:12:28 +02001347 bool changed;
Niels Möllerd959f3a2022-04-19 11:29:19 +02001348 MergeNetworkList(manager, std::move(list), &changed);
Jonas Orelandc7ea04a2020-04-03 10:12:28 +02001349
1350 // Change from 3G to 4G shall not trigger OnNetworksChanged,
1351 // i.e changed = false.
1352 EXPECT_FALSE(changed);
Niels Möller22211442022-04-07 11:43:28 +02001353 std::vector<const Network*> list2 = manager.GetNetworks();
Jonas Orelandc7ea04a2020-04-03 10:12:28 +02001354 ASSERT_EQ(list2.size(), 1uL);
1355 EXPECT_EQ(ADAPTER_TYPE_CELLULAR_4G, list2[0]->type());
1356 }
1357
1358 // Don't modify.
1359 {
Niels Möllerd959f3a2022-04-19 11:29:19 +02001360 auto net2 =
1361 std::make_unique<Network>("em1", "em1", TruncateIP(ip1, 64), 64);
Jonas Orelandc7ea04a2020-04-03 10:12:28 +02001362 net2->set_type(ADAPTER_TYPE_CELLULAR_4G);
1363 net2->AddIP(ip1);
1364 list.clear();
Niels Möllerd959f3a2022-04-19 11:29:19 +02001365 list.push_back(std::move(net2));
Jonas Orelandc7ea04a2020-04-03 10:12:28 +02001366 bool changed;
Niels Möllerd959f3a2022-04-19 11:29:19 +02001367 MergeNetworkList(manager, std::move(list), &changed);
Jonas Orelandc7ea04a2020-04-03 10:12:28 +02001368
1369 // No change.
1370 EXPECT_FALSE(changed);
Niels Möller22211442022-04-07 11:43:28 +02001371 std::vector<const Network*> list2 = manager.GetNetworks();
Jonas Orelandc7ea04a2020-04-03 10:12:28 +02001372 ASSERT_EQ(list2.size(), 1uL);
1373 EXPECT_EQ(ADAPTER_TYPE_CELLULAR_4G, list2[0]->type());
1374 }
1375}
1376
Jonas Oreland47fa08f2020-12-05 18:09:13 +01001377#if defined(WEBRTC_POSIX)
1378TEST_F(NetworkTest, IgnoresMACBasedIPv6Address) {
1379 std::string ipv6_address = "2607:fc20:f340:1dc8:214:22ff:fe01:2345";
1380 std::string ipv6_mask = "FFFF:FFFF:FFFF:FFFF:FFFF:FFFF:FFFF:FFFF";
Niels Möller539f3e12021-11-26 16:33:19 +01001381 PhysicalSocketServer socket_server;
1382 BasicNetworkManager manager(&socket_server);
Jonas Oreland47fa08f2020-12-05 18:09:13 +01001383 manager.StartUpdating();
1384
1385 // IPSec interface; name is in form "ipsec<index>".
1386 char if_name[20] = "ipsec11";
1387 ifaddrs* addr_list =
1388 InstallIpv6Network(if_name, ipv6_address, ipv6_mask, manager);
1389
Niels Möller22211442022-04-07 11:43:28 +02001390 std::vector<const Network*> list = manager.GetNetworks();
Jonas Oreland47fa08f2020-12-05 18:09:13 +01001391 EXPECT_EQ(list.size(), 0u);
1392 ReleaseIfAddrs(addr_list);
1393}
1394
1395TEST_F(NetworkTest, WebRTC_AllowMACBasedIPv6Address) {
1396 webrtc::test::ScopedFieldTrials field_trials(
1397 "WebRTC-AllowMACBasedIPv6/Enabled/");
1398 std::string ipv6_address = "2607:fc20:f340:1dc8:214:22ff:fe01:2345";
1399 std::string ipv6_mask = "FFFF:FFFF:FFFF:FFFF:FFFF:FFFF:FFFF:FFFF";
Niels Möller539f3e12021-11-26 16:33:19 +01001400 PhysicalSocketServer socket_server;
1401 BasicNetworkManager manager(&socket_server);
Jonas Oreland47fa08f2020-12-05 18:09:13 +01001402 manager.StartUpdating();
1403
1404 // IPSec interface; name is in form "ipsec<index>".
1405 char if_name[20] = "ipsec11";
1406 ifaddrs* addr_list =
1407 InstallIpv6Network(if_name, ipv6_address, ipv6_mask, manager);
1408
Niels Möller22211442022-04-07 11:43:28 +02001409 std::vector<const Network*> list = manager.GetNetworks();
Jonas Oreland47fa08f2020-12-05 18:09:13 +01001410 EXPECT_EQ(list.size(), 1u);
1411 ReleaseIfAddrs(addr_list);
1412}
1413#endif
1414
Jonas Oreland6ca955a2021-03-15 08:27:43 +00001415#if defined(WEBRTC_POSIX)
1416TEST_F(NetworkTest, WebRTC_BindUsingInterfaceName) {
Jonas Oreland6ca955a2021-03-15 08:27:43 +00001417 char if_name1[20] = "wlan0";
1418 char if_name2[20] = "v4-wlan0";
1419 ifaddrs* list = nullptr;
1420 list = AddIpv6Address(list, if_name1, "1000:2000:3000:4000:0:0:0:1",
1421 "FFFF:FFFF:FFFF:FFFF::", 0);
1422 list = AddIpv4Address(list, if_name2, "192.168.0.2", "255.255.255.255");
Niels Möllerd959f3a2022-04-19 11:29:19 +02001423 std::vector<std::unique_ptr<Network>> result;
Jonas Oreland6ca955a2021-03-15 08:27:43 +00001424
1425 // Sanity check that both interfaces are included by default.
1426 FakeNetworkMonitorFactory factory;
Niels Mölleraa373162021-09-28 16:09:07 +02001427 PhysicalSocketServer socket_server;
Jonas Orelandc06fe8b2022-03-28 14:58:26 +02001428 BasicNetworkManager manager(&factory, &socket_server, &field_trials_);
Jonas Oreland6ca955a2021-03-15 08:27:43 +00001429 manager.StartUpdating();
1430 CallConvertIfAddrs(manager, list, /*include_ignored=*/false, &result);
1431 EXPECT_EQ(2u, result.size());
1432 ReleaseIfAddrs(list);
1433 bool changed;
1434 // This ensures we release the objects created in CallConvertIfAddrs.
Niels Möllerd959f3a2022-04-19 11:29:19 +02001435 MergeNetworkList(manager, std::move(result), &changed);
Jonas Oreland6ca955a2021-03-15 08:27:43 +00001436 result.clear();
1437
1438 FakeNetworkMonitor* network_monitor = GetNetworkMonitor(manager);
1439
1440 IPAddress ipv6;
1441 EXPECT_TRUE(IPFromString("1000:2000:3000:4000:0:0:0:1", &ipv6));
1442 IPAddress ipv4;
1443 EXPECT_TRUE(IPFromString("192.168.0.2", &ipv4));
1444
1445 // The network monitor only knwos about the ipv6 address, interface.
1446 network_monitor->set_adapters({"wlan0"});
1447 network_monitor->set_ip_addresses({ipv6});
1448 EXPECT_EQ(manager.BindSocketToNetwork(/* fd */ 77, ipv6),
1449 NetworkBindingResult::SUCCESS);
1450
1451 // But it will bind anyway using string matching...
1452 EXPECT_EQ(manager.BindSocketToNetwork(/* fd */ 77, ipv4),
1453 NetworkBindingResult::SUCCESS);
1454}
1455#endif
1456
Jonas Orelandb477fc72021-08-23 12:16:33 +02001457TEST_F(NetworkTest, NetworkCostVpn_Default) {
1458 IPAddress ip1;
1459 EXPECT_TRUE(IPFromString("2400:4030:1:2c00:be30:0:0:1", &ip1));
Jonas Orelandc06fe8b2022-03-28 14:58:26 +02001460 webrtc::test::ScopedKeyValueConfig field_trials;
Jonas Orelandb477fc72021-08-23 12:16:33 +02001461
1462 Network* net1 = new Network("em1", "em1", TruncateIP(ip1, 64), 64);
1463 net1->set_type(ADAPTER_TYPE_VPN);
1464 net1->set_underlying_type_for_vpn(ADAPTER_TYPE_ETHERNET);
1465
1466 Network* net2 = new Network("em1", "em1", TruncateIP(ip1, 64), 64);
1467 net2->set_type(ADAPTER_TYPE_ETHERNET);
1468
Jonas Orelandc06fe8b2022-03-28 14:58:26 +02001469 EXPECT_EQ(net1->GetCost(field_trials), net2->GetCost(field_trials));
Jonas Orelandb477fc72021-08-23 12:16:33 +02001470 delete net1;
1471 delete net2;
1472}
1473
1474TEST_F(NetworkTest, NetworkCostVpn_VpnMoreExpensive) {
Jonas Orelandc06fe8b2022-03-28 14:58:26 +02001475 webrtc::test::ScopedKeyValueConfig field_trials(
Jonas Orelandb477fc72021-08-23 12:16:33 +02001476 "WebRTC-AddNetworkCostToVpn/Enabled/");
1477
1478 IPAddress ip1;
1479 EXPECT_TRUE(IPFromString("2400:4030:1:2c00:be30:0:0:1", &ip1));
1480
1481 Network* net1 = new Network("em1", "em1", TruncateIP(ip1, 64), 64);
1482 net1->set_type(ADAPTER_TYPE_VPN);
1483 net1->set_underlying_type_for_vpn(ADAPTER_TYPE_ETHERNET);
1484
1485 Network* net2 = new Network("em1", "em1", TruncateIP(ip1, 64), 64);
1486 net2->set_type(ADAPTER_TYPE_ETHERNET);
1487
Jonas Orelandc06fe8b2022-03-28 14:58:26 +02001488 EXPECT_GT(net1->GetCost(field_trials), net2->GetCost(field_trials));
Jonas Orelandb477fc72021-08-23 12:16:33 +02001489 delete net1;
1490 delete net2;
1491}
1492
Jonas Oreland30019052022-01-28 14:11:44 +01001493TEST_F(NetworkTest, GuessAdapterFromNetworkCost) {
Jonas Orelandc06fe8b2022-03-28 14:58:26 +02001494 webrtc::test::ScopedKeyValueConfig field_trials(
Jonas Oreland30019052022-01-28 14:11:44 +01001495 "WebRTC-AddNetworkCostToVpn/Enabled/"
1496 "WebRTC-UseDifferentiatedCellularCosts/Enabled/");
1497
1498 IPAddress ip1;
1499 EXPECT_TRUE(IPFromString("2400:4030:1:2c00:be30:0:0:1", &ip1));
1500
1501 for (auto type : kAllAdapterTypes) {
1502 if (type == rtc::ADAPTER_TYPE_VPN)
1503 continue;
1504 Network net1("em1", "em1", TruncateIP(ip1, 64), 64);
1505 net1.set_type(type);
Jonas Orelandc06fe8b2022-03-28 14:58:26 +02001506 auto [guess, vpn] =
1507 Network::GuessAdapterFromNetworkCost(net1.GetCost(field_trials));
Jonas Oreland30019052022-01-28 14:11:44 +01001508 EXPECT_FALSE(vpn);
1509 if (type == rtc::ADAPTER_TYPE_LOOPBACK) {
1510 EXPECT_EQ(guess, rtc::ADAPTER_TYPE_ETHERNET);
1511 } else {
1512 EXPECT_EQ(type, guess);
1513 }
1514 }
1515
1516 // VPN
1517 for (auto type : kAllAdapterTypes) {
1518 if (type == rtc::ADAPTER_TYPE_VPN)
1519 continue;
1520 Network net1("em1", "em1", TruncateIP(ip1, 64), 64);
1521 net1.set_type(rtc::ADAPTER_TYPE_VPN);
1522 net1.set_underlying_type_for_vpn(type);
Jonas Orelandc06fe8b2022-03-28 14:58:26 +02001523 auto [guess, vpn] =
1524 Network::GuessAdapterFromNetworkCost(net1.GetCost(field_trials));
Jonas Oreland30019052022-01-28 14:11:44 +01001525 EXPECT_TRUE(vpn);
1526 if (type == rtc::ADAPTER_TYPE_LOOPBACK) {
1527 EXPECT_EQ(guess, rtc::ADAPTER_TYPE_ETHERNET);
1528 } else {
1529 EXPECT_EQ(type, guess);
1530 }
1531 }
1532}
1533
Jonas Oreland2ee0e642021-08-25 15:43:02 +02001534TEST_F(NetworkTest, VpnList) {
Niels Möller539f3e12021-11-26 16:33:19 +01001535 PhysicalSocketServer socket_server;
Jonas Oreland2ee0e642021-08-25 15:43:02 +02001536 {
Niels Möller539f3e12021-11-26 16:33:19 +01001537 BasicNetworkManager manager(&socket_server);
Jonas Oreland2ee0e642021-08-25 15:43:02 +02001538 manager.set_vpn_list({NetworkMask(IPFromString("192.168.0.0"), 16)});
1539 manager.StartUpdating();
1540 EXPECT_TRUE(manager.IsConfiguredVpn(IPFromString("192.168.1.1"), 32));
1541 EXPECT_TRUE(manager.IsConfiguredVpn(IPFromString("192.168.12.1"), 24));
1542 EXPECT_TRUE(manager.IsConfiguredVpn(IPFromString("192.168.0.0"), 16));
1543 EXPECT_TRUE(manager.IsConfiguredVpn(IPFromString("192.168.0.0"), 24));
1544 EXPECT_FALSE(manager.IsConfiguredVpn(IPFromString("192.133.1.1"), 32));
1545 EXPECT_FALSE(manager.IsConfiguredVpn(IPFromString("192.133.0.0"), 16));
1546 EXPECT_FALSE(manager.IsConfiguredVpn(IPFromString("192.168.0.0"), 15));
1547 }
1548 {
Niels Möller539f3e12021-11-26 16:33:19 +01001549 BasicNetworkManager manager(&socket_server);
Jonas Oreland2ee0e642021-08-25 15:43:02 +02001550 manager.set_vpn_list({NetworkMask(IPFromString("192.168.0.0"), 24)});
1551 manager.StartUpdating();
1552 EXPECT_FALSE(manager.IsConfiguredVpn(IPFromString("192.168.1.1"), 32));
1553 EXPECT_TRUE(manager.IsConfiguredVpn(IPFromString("192.168.0.1"), 32));
1554 }
1555}
1556
1557#if defined(WEBRTC_POSIX)
1558// TODO(webrtc:13114): Implement the InstallIpv4Network for windows.
1559TEST_F(NetworkTest, VpnListOverrideAdapterType) {
Niels Möller539f3e12021-11-26 16:33:19 +01001560 PhysicalSocketServer socket_server;
1561 BasicNetworkManager manager(&socket_server);
Jonas Oreland2ee0e642021-08-25 15:43:02 +02001562 manager.set_vpn_list({NetworkMask(IPFromString("192.168.0.0"), 16)});
1563 manager.StartUpdating();
1564
1565 char if_name[20] = "eth0";
1566 auto addr_list =
1567 InstallIpv4Network(if_name, "192.168.1.23", "255.255.255.255", manager);
1568
Niels Möller22211442022-04-07 11:43:28 +02001569 std::vector<const Network*> list = manager.GetNetworks();
Jonas Oreland2ee0e642021-08-25 15:43:02 +02001570 ASSERT_EQ(1u, list.size());
1571 EXPECT_EQ(ADAPTER_TYPE_VPN, list[0]->type());
1572 EXPECT_EQ(ADAPTER_TYPE_ETHERNET, list[0]->underlying_type_for_vpn());
1573 ClearNetworks(manager);
1574 ReleaseIfAddrs(addr_list);
1575}
1576#endif // defined(WEBRTC_POSIX)
1577
Jonas Orelandac554eb2021-08-27 09:43:38 +02001578TEST_F(NetworkTest, HardcodedVpn) {
1579 const uint8_t cisco[] = {0x0, 0x5, 0x9A, 0x3C, 0x7A, 0x0};
1580 const uint8_t global[] = {0x2, 0x50, 0x41, 0x0, 0x0, 0x1};
1581 const uint8_t unknown[] = {0x2, 0x50, 0x41, 0x0, 0x0, 0x0};
1582 const uint8_t five_bytes[] = {0x2, 0x50, 0x41, 0x0, 0x0};
1583 EXPECT_TRUE(NetworkManagerBase::IsVpnMacAddress(cisco));
1584 EXPECT_TRUE(NetworkManagerBase::IsVpnMacAddress(global));
1585
1586 EXPECT_FALSE(NetworkManagerBase::IsVpnMacAddress(
1587 rtc::ArrayView<const uint8_t>(cisco, 5)));
1588 EXPECT_FALSE(NetworkManagerBase::IsVpnMacAddress(five_bytes));
1589 EXPECT_FALSE(NetworkManagerBase::IsVpnMacAddress(unknown));
1590 EXPECT_FALSE(NetworkManagerBase::IsVpnMacAddress(nullptr));
1591}
1592
Mirko Bonadei13f9c622022-04-29 16:38:32 +02001593TEST(CompareNetworks, IrreflexivityTest) {
1594 // x < x is false
1595 auto network = std::make_unique<Network>(
1596 "test_eth0", "Test Network Adapter 1", IPAddress(0x12345600U), 24);
1597 EXPECT_FALSE(webrtc_network_internal::CompareNetworks(network, network));
1598}
1599
1600TEST(CompareNetworks, AsymmetryTest) {
1601 // x < y and y < x cannot be both true
1602 auto network_a = std::make_unique<Network>(
1603 "test_eth0", "Test Network Adapter 1", IPAddress(0x12345600U), 24);
1604 auto network_b = std::make_unique<Network>(
1605 "test_eth1", "Test Network Adapter 1", IPAddress(0x12345600U), 24);
1606 EXPECT_TRUE(webrtc_network_internal::CompareNetworks(network_a, network_b));
1607 EXPECT_FALSE(webrtc_network_internal::CompareNetworks(network_b, network_a));
1608
1609 auto network_c = std::make_unique<Network>(
1610 "test_eth0", "Test Network Adapter 1", IPAddress(0x12345500U), 24);
1611 auto network_d = std::make_unique<Network>(
1612 "test_eth0", "Test Network Adapter 1", IPAddress(0x12345600U), 24);
1613 EXPECT_TRUE(webrtc_network_internal::CompareNetworks(network_c, network_d));
1614 EXPECT_FALSE(webrtc_network_internal::CompareNetworks(network_d, network_c));
1615}
1616
1617TEST(CompareNetworks, TransitivityTest) {
1618 // x < y and y < z imply x < z
1619 auto network_a = std::make_unique<Network>(
1620 "test_eth0", "Test Network Adapter 1", IPAddress(0x12345600U), 24);
1621 auto network_b = std::make_unique<Network>(
1622 "test_eth1", "Test Network Adapter 1", IPAddress(0x12345600U), 24);
1623 auto network_c = std::make_unique<Network>(
1624 "test_eth2", "Test Network Adapter 1", IPAddress(0x12345600U), 24);
1625 EXPECT_TRUE(webrtc_network_internal::CompareNetworks(network_a, network_b));
1626 EXPECT_TRUE(webrtc_network_internal::CompareNetworks(network_b, network_c));
1627
1628 auto network_d = std::make_unique<Network>(
1629 "test_eth0", "Test Network Adapter 1", IPAddress(0x12345600U), 24);
1630 auto network_e = std::make_unique<Network>(
1631 "test_eth0", "Test Network Adapter 1", IPAddress(0x12345700U), 24);
1632 auto network_f = std::make_unique<Network>(
1633 "test_eth0", "Test Network Adapter 1", IPAddress(0x12345800U), 24);
1634 EXPECT_TRUE(webrtc_network_internal::CompareNetworks(network_d, network_e));
1635 EXPECT_TRUE(webrtc_network_internal::CompareNetworks(network_e, network_f));
1636 EXPECT_TRUE(webrtc_network_internal::CompareNetworks(network_d, network_f));
1637 EXPECT_TRUE(webrtc_network_internal::CompareNetworks(network_a, network_c));
1638}
1639
1640TEST(CompareNetworks, TransitivityOfIncomparabilityTest) {
1641 // x == y and y == z imply x == z,
1642 // where x == y means x < y and y < x are both false
1643 auto network_a = std::make_unique<Network>(
1644 "test_eth0", "Test Network Adapter 1", IPAddress(0x12345600U), 23);
1645 auto network_b = std::make_unique<Network>(
1646 "test_eth0", "Test Network Adapter 1", IPAddress(0x12345600U), 24);
1647 auto network_c = std::make_unique<Network>(
1648 "test_eth0", "Test Network Adapter 1", IPAddress(0x12345700U), 24);
1649
1650 // network_a < network_b
1651 EXPECT_TRUE(webrtc_network_internal::CompareNetworks(network_a, network_b));
1652 EXPECT_FALSE(webrtc_network_internal::CompareNetworks(network_b, network_a));
1653
1654 // network_b < network_c
1655 EXPECT_TRUE(webrtc_network_internal::CompareNetworks(network_b, network_c));
1656 EXPECT_FALSE(webrtc_network_internal::CompareNetworks(network_c, network_b));
1657
1658 // network_a < network_c
1659 EXPECT_TRUE(webrtc_network_internal::CompareNetworks(network_a, network_c));
1660 EXPECT_FALSE(webrtc_network_internal::CompareNetworks(network_c, network_a));
1661
1662 auto network_d = std::make_unique<Network>(
1663 "test_eth0", "Test Network Adapter 1", IPAddress(0x12345600U), 24);
1664 auto network_e = std::make_unique<Network>(
1665 "test_eth0", "Test Network Adapter 1", IPAddress(0x12345600U), 24);
1666 auto network_f = std::make_unique<Network>(
1667 "test_eth0", "Test Network Adapter 1", IPAddress(0x12345600U), 24);
1668
1669 // network_d == network_e
1670 EXPECT_FALSE(webrtc_network_internal::CompareNetworks(network_d, network_e));
1671 EXPECT_FALSE(webrtc_network_internal::CompareNetworks(network_e, network_d));
1672
1673 // network_e == network_f
1674 EXPECT_FALSE(webrtc_network_internal::CompareNetworks(network_e, network_f));
1675 EXPECT_FALSE(webrtc_network_internal::CompareNetworks(network_f, network_e));
1676
1677 // network_d == network_f
1678 EXPECT_FALSE(webrtc_network_internal::CompareNetworks(network_d, network_f));
1679 EXPECT_FALSE(webrtc_network_internal::CompareNetworks(network_f, network_d));
1680}
1681
henrike@webrtc.orgf0488722014-05-13 18:00:26 +00001682} // namespace rtc