henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 1 | /* |
| 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 Bonadei | 92ea95e | 2017-09-15 04:47:31 | [diff] [blame] | 11 | #include "rtc_base/network.h" |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 12 | |
oprypin | 1ea631f | 2017-08-18 07:15:19 | [diff] [blame] | 13 | #include <stdlib.h> |
| 14 | |
jbauch | 555604a | 2016-04-26 10:13:22 | [diff] [blame] | 15 | #include <memory> |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 16 | #include <vector> |
oprypin | 1ea631f | 2017-08-18 07:15:19 | [diff] [blame] | 17 | |
Mirko Bonadei | 92ea95e | 2017-09-15 04:47:31 | [diff] [blame] | 18 | #include "rtc_base/checks.h" |
| 19 | #include "rtc_base/nethelpers.h" |
| 20 | #include "rtc_base/networkmonitor.h" |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 21 | #if defined(WEBRTC_POSIX) |
Henrik Kjellander | 0072511 | 2017-06-30 13:14:45 | [diff] [blame] | 22 | #include <net/if.h> |
Yves Gerey | 665174f | 2018-06-19 13:03:05 | [diff] [blame] | 23 | #include <sys/types.h> |
Mirko Bonadei | 92ea95e | 2017-09-15 04:47:31 | [diff] [blame] | 24 | #include "rtc_base/ifaddrs_converter.h" |
Guo-wei Shieh | 9faf154 | 2015-12-28 22:06:55 | [diff] [blame] | 25 | #endif // defined(WEBRTC_POSIX) |
Mirko Bonadei | 92ea95e | 2017-09-15 04:47:31 | [diff] [blame] | 26 | #include "rtc_base/gunit.h" |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 27 | #if defined(WEBRTC_WIN) |
Mirko Bonadei | 675513b | 2017-11-09 10:09:25 | [diff] [blame] | 28 | #include "rtc_base/logging.h" // For RTC_LOG_GLE |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 29 | #endif |
| 30 | |
| 31 | namespace rtc { |
| 32 | |
Guo-wei Shieh | 9faf154 | 2015-12-28 22:06:55 | [diff] [blame] | 33 | namespace { |
| 34 | |
honghaiz | 023f3ef | 2015-10-19 16:39:32 | [diff] [blame] | 35 | class FakeNetworkMonitor : public NetworkMonitorBase { |
| 36 | public: |
honghaiz | cec0a08 | 2016-01-15 22:49:09 | [diff] [blame] | 37 | void Start() override { started_ = true; } |
| 38 | void Stop() override { started_ = false; } |
| 39 | bool started() { return started_; } |
honghaiz | a7ad7c3 | 2016-02-02 20:54:14 | [diff] [blame] | 40 | AdapterType GetAdapterType(const std::string& if_name) override { |
Honghai Zhang | 351d77b | 2016-05-20 22:08:29 | [diff] [blame] | 41 | // Note that the name matching rules are different from the |
| 42 | // GetAdapterTypeFromName in NetworkManager. |
| 43 | if (if_name.find("wifi") == 0) { |
| 44 | return ADAPTER_TYPE_WIFI; |
| 45 | } |
| 46 | if (if_name.find("cellular") == 0) { |
| 47 | return ADAPTER_TYPE_CELLULAR; |
| 48 | } |
honghaiz | a7ad7c3 | 2016-02-02 20:54:14 | [diff] [blame] | 49 | return ADAPTER_TYPE_UNKNOWN; |
| 50 | } |
honghaiz | cec0a08 | 2016-01-15 22:49:09 | [diff] [blame] | 51 | |
| 52 | private: |
| 53 | bool started_ = false; |
honghaiz | 023f3ef | 2015-10-19 16:39:32 | [diff] [blame] | 54 | }; |
| 55 | |
| 56 | class FakeNetworkMonitorFactory : public NetworkMonitorFactory { |
| 57 | public: |
| 58 | FakeNetworkMonitorFactory() {} |
honghaiz | cec0a08 | 2016-01-15 22:49:09 | [diff] [blame] | 59 | NetworkMonitorInterface* CreateNetworkMonitor() override { |
honghaiz | 023f3ef | 2015-10-19 16:39:32 | [diff] [blame] | 60 | return new FakeNetworkMonitor(); |
| 61 | } |
| 62 | }; |
| 63 | |
Qingsi Wang | 10a0e51 | 2018-05-16 20:37:03 | [diff] [blame] | 64 | bool SameNameAndPrefix(const rtc::Network& a, const rtc::Network& b) { |
| 65 | if (a.name() != b.name()) { |
| 66 | RTC_LOG(INFO) << "Different interface names."; |
| 67 | return false; |
| 68 | } |
| 69 | if (a.prefix_length() != b.prefix_length() || a.prefix() != b.prefix()) { |
| 70 | RTC_LOG(INFO) << "Different IP prefixes."; |
| 71 | return false; |
| 72 | } |
| 73 | return true; |
| 74 | } |
| 75 | |
Guo-wei Shieh | 9faf154 | 2015-12-28 22:06:55 | [diff] [blame] | 76 | } // namespace |
| 77 | |
Yves Gerey | 665174f | 2018-06-19 13:03:05 | [diff] [blame] | 78 | class NetworkTest : public testing::Test, public sigslot::has_slots<> { |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 79 | public: |
| 80 | NetworkTest() : callback_called_(false) {} |
| 81 | |
Yves Gerey | 665174f | 2018-06-19 13:03:05 | [diff] [blame] | 82 | void OnNetworksChanged() { callback_called_ = true; } |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 83 | |
guoweis@webrtc.org | a094cac | 2015-01-28 19:34:05 | [diff] [blame] | 84 | NetworkManager::Stats MergeNetworkList( |
| 85 | BasicNetworkManager& network_manager, |
| 86 | const NetworkManager::NetworkList& list, |
| 87 | bool* changed) { |
| 88 | NetworkManager::Stats stats; |
| 89 | network_manager.MergeNetworkList(list, changed, &stats); |
| 90 | return stats; |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 91 | } |
| 92 | |
| 93 | bool IsIgnoredNetwork(BasicNetworkManager& network_manager, |
| 94 | const Network& network) { |
| 95 | return network_manager.IsIgnoredNetwork(network); |
| 96 | } |
| 97 | |
| 98 | NetworkManager::NetworkList GetNetworks( |
Yves Gerey | 665174f | 2018-06-19 13:03:05 | [diff] [blame] | 99 | const BasicNetworkManager& network_manager, |
| 100 | bool include_ignored) { |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 101 | NetworkManager::NetworkList list; |
| 102 | network_manager.CreateNetworks(include_ignored, &list); |
| 103 | return list; |
| 104 | } |
| 105 | |
honghaiz | cec0a08 | 2016-01-15 22:49:09 | [diff] [blame] | 106 | FakeNetworkMonitor* GetNetworkMonitor(BasicNetworkManager& network_manager) { |
| 107 | return static_cast<FakeNetworkMonitor*>( |
| 108 | network_manager.network_monitor_.get()); |
honghaiz | 023f3ef | 2015-10-19 16:39:32 | [diff] [blame] | 109 | } |
| 110 | void ClearNetworks(BasicNetworkManager& network_manager) { |
| 111 | for (const auto& kv : network_manager.networks_map_) { |
| 112 | delete kv.second; |
| 113 | } |
| 114 | network_manager.networks_.clear(); |
| 115 | network_manager.networks_map_.clear(); |
| 116 | } |
| 117 | |
Honghai Zhang | 351d77b | 2016-05-20 22:08:29 | [diff] [blame] | 118 | AdapterType GetAdapterType(BasicNetworkManager& network_manager) { |
| 119 | BasicNetworkManager::NetworkList list; |
| 120 | network_manager.GetNetworks(&list); |
nisse | c16fa5e | 2017-02-07 15:18:43 | [diff] [blame] | 121 | RTC_CHECK_EQ(1, list.size()); |
Honghai Zhang | 351d77b | 2016-05-20 22:08:29 | [diff] [blame] | 122 | return list[0]->type(); |
| 123 | } |
| 124 | |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 125 | #if defined(WEBRTC_POSIX) |
| 126 | // Separated from CreateNetworks for tests. |
| 127 | static void CallConvertIfAddrs(const BasicNetworkManager& network_manager, |
| 128 | struct ifaddrs* interfaces, |
| 129 | bool include_ignored, |
| 130 | NetworkManager::NetworkList* networks) { |
Guo-wei Shieh | 9faf154 | 2015-12-28 22:06:55 | [diff] [blame] | 131 | // Use the base IfAddrsConverter for test cases. |
jbauch | 555604a | 2016-04-26 10:13:22 | [diff] [blame] | 132 | std::unique_ptr<IfAddrsConverter> ifaddrs_converter(new IfAddrsConverter()); |
Guo-wei Shieh | 9faf154 | 2015-12-28 22:06:55 | [diff] [blame] | 133 | network_manager.ConvertIfAddrs(interfaces, ifaddrs_converter.get(), |
| 134 | include_ignored, networks); |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 135 | } |
honghaiz | db8cf50 | 2015-12-21 21:08:46 | [diff] [blame] | 136 | |
| 137 | struct sockaddr_in6* CreateIpv6Addr(const std::string& ip_string, |
| 138 | uint32_t scope_id) { |
Yves Gerey | 665174f | 2018-06-19 13:03:05 | [diff] [blame] | 139 | struct sockaddr_in6* ipv6_addr = |
| 140 | static_cast<struct sockaddr_in6*>(malloc(sizeof(struct sockaddr_in6))); |
honghaiz | db8cf50 | 2015-12-21 21:08:46 | [diff] [blame] | 141 | memset(ipv6_addr, 0, sizeof(struct sockaddr_in6)); |
| 142 | ipv6_addr->sin6_family = AF_INET6; |
| 143 | ipv6_addr->sin6_scope_id = scope_id; |
| 144 | IPAddress ip; |
| 145 | IPFromString(ip_string, &ip); |
| 146 | ipv6_addr->sin6_addr = ip.ipv6_address(); |
| 147 | return ipv6_addr; |
| 148 | } |
| 149 | |
| 150 | // Pointers created here need to be released via ReleaseIfAddrs. |
| 151 | struct ifaddrs* AddIpv6Address(struct ifaddrs* list, |
| 152 | char* if_name, |
| 153 | const std::string& ipv6_address, |
| 154 | const std::string& ipv6_netmask, |
| 155 | uint32_t scope_id) { |
| 156 | struct ifaddrs* if_addr = new struct ifaddrs; |
| 157 | memset(if_addr, 0, sizeof(struct ifaddrs)); |
| 158 | if_addr->ifa_name = if_name; |
| 159 | if_addr->ifa_addr = reinterpret_cast<struct sockaddr*>( |
| 160 | CreateIpv6Addr(ipv6_address, scope_id)); |
| 161 | if_addr->ifa_netmask = |
| 162 | reinterpret_cast<struct sockaddr*>(CreateIpv6Addr(ipv6_netmask, 0)); |
| 163 | if_addr->ifa_next = list; |
Guo-wei Shieh | 9faf154 | 2015-12-28 22:06:55 | [diff] [blame] | 164 | if_addr->ifa_flags = IFF_RUNNING; |
honghaiz | db8cf50 | 2015-12-21 21:08:46 | [diff] [blame] | 165 | return if_addr; |
| 166 | } |
| 167 | |
Honghai Zhang | 351d77b | 2016-05-20 22:08:29 | [diff] [blame] | 168 | struct ifaddrs* InstallIpv6Network(char* if_name, |
| 169 | const std::string& ipv6_address, |
| 170 | const std::string& ipv6_mask, |
| 171 | BasicNetworkManager& network_manager) { |
| 172 | ifaddrs* addr_list = nullptr; |
| 173 | addr_list = AddIpv6Address(addr_list, if_name, ipv6_address, ipv6_mask, 0); |
| 174 | NetworkManager::NetworkList result; |
| 175 | bool changed; |
| 176 | NetworkManager::Stats stats; |
| 177 | CallConvertIfAddrs(network_manager, addr_list, true, &result); |
| 178 | network_manager.MergeNetworkList(result, &changed, &stats); |
| 179 | return addr_list; |
| 180 | } |
| 181 | |
honghaiz | db8cf50 | 2015-12-21 21:08:46 | [diff] [blame] | 182 | void ReleaseIfAddrs(struct ifaddrs* list) { |
| 183 | struct ifaddrs* if_addr = list; |
| 184 | while (if_addr != nullptr) { |
| 185 | struct ifaddrs* next_addr = if_addr->ifa_next; |
oprypin | 1ea631f | 2017-08-18 07:15:19 | [diff] [blame] | 186 | free(if_addr->ifa_addr); |
| 187 | free(if_addr->ifa_netmask); |
honghaiz | db8cf50 | 2015-12-21 21:08:46 | [diff] [blame] | 188 | delete if_addr; |
| 189 | if_addr = next_addr; |
| 190 | } |
| 191 | } |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 192 | #endif // defined(WEBRTC_POSIX) |
| 193 | |
| 194 | protected: |
| 195 | bool callback_called_; |
| 196 | }; |
| 197 | |
Guo-wei Shieh | 9af97f8 | 2015-11-10 22:47:39 | [diff] [blame] | 198 | class TestBasicNetworkManager : public BasicNetworkManager { |
| 199 | public: |
| 200 | using BasicNetworkManager::QueryDefaultLocalAddress; |
Guo-wei Shieh | a34c39e | 2015-11-25 21:12:26 | [diff] [blame] | 201 | using BasicNetworkManager::set_default_local_addresses; |
Guo-wei Shieh | 9af97f8 | 2015-11-10 22:47:39 | [diff] [blame] | 202 | }; |
| 203 | |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 204 | // Test that the Network ctor works properly. |
| 205 | TEST_F(NetworkTest, TestNetworkConstruct) { |
| 206 | Network ipv4_network1("test_eth0", "Test Network Adapter 1", |
| 207 | IPAddress(0x12345600U), 24); |
| 208 | EXPECT_EQ("test_eth0", ipv4_network1.name()); |
| 209 | EXPECT_EQ("Test Network Adapter 1", ipv4_network1.description()); |
| 210 | EXPECT_EQ(IPAddress(0x12345600U), ipv4_network1.prefix()); |
| 211 | EXPECT_EQ(24, ipv4_network1.prefix_length()); |
| 212 | EXPECT_FALSE(ipv4_network1.ignored()); |
| 213 | } |
| 214 | |
phoglund@webrtc.org | 006521d | 2015-02-12 09:23:59 | [diff] [blame] | 215 | TEST_F(NetworkTest, TestIsIgnoredNetworkIgnoresIPsStartingWith0) { |
| 216 | Network ipv4_network1("test_eth0", "Test Network Adapter 1", |
| 217 | IPAddress(0x12345600U), 24, ADAPTER_TYPE_ETHERNET); |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 218 | Network ipv4_network2("test_eth1", "Test Network Adapter 2", |
phoglund@webrtc.org | 006521d | 2015-02-12 09:23:59 | [diff] [blame] | 219 | IPAddress(0x010000U), 24, ADAPTER_TYPE_ETHERNET); |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 220 | BasicNetworkManager network_manager; |
| 221 | EXPECT_FALSE(IsIgnoredNetwork(network_manager, ipv4_network1)); |
| 222 | EXPECT_TRUE(IsIgnoredNetwork(network_manager, ipv4_network2)); |
| 223 | } |
| 224 | |
phoglund@webrtc.org | 006521d | 2015-02-12 09:23:59 | [diff] [blame] | 225 | // TODO(phoglund): Remove when ignore list goes away. |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 226 | TEST_F(NetworkTest, TestIgnoreList) { |
Yves Gerey | 665174f | 2018-06-19 13:03:05 | [diff] [blame] | 227 | Network ignore_me("ignore_me", "Ignore me please!", IPAddress(0x12345600U), |
| 228 | 24); |
| 229 | Network include_me("include_me", "Include me please!", IPAddress(0x12345600U), |
| 230 | 24); |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 231 | BasicNetworkManager network_manager; |
| 232 | EXPECT_FALSE(IsIgnoredNetwork(network_manager, ignore_me)); |
| 233 | EXPECT_FALSE(IsIgnoredNetwork(network_manager, include_me)); |
| 234 | std::vector<std::string> ignore_list; |
| 235 | ignore_list.push_back("ignore_me"); |
| 236 | network_manager.set_network_ignore_list(ignore_list); |
| 237 | EXPECT_TRUE(IsIgnoredNetwork(network_manager, ignore_me)); |
| 238 | EXPECT_FALSE(IsIgnoredNetwork(network_manager, include_me)); |
| 239 | } |
| 240 | |
| 241 | // Test is failing on Windows opt: b/11288214 |
| 242 | TEST_F(NetworkTest, DISABLED_TestCreateNetworks) { |
| 243 | BasicNetworkManager manager; |
| 244 | NetworkManager::NetworkList result = GetNetworks(manager, true); |
| 245 | // We should be able to bind to any addresses we find. |
| 246 | NetworkManager::NetworkList::iterator it; |
Yves Gerey | 665174f | 2018-06-19 13:03:05 | [diff] [blame] | 247 | for (it = result.begin(); it != result.end(); ++it) { |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 248 | sockaddr_storage storage; |
| 249 | memset(&storage, 0, sizeof(storage)); |
guoweis@webrtc.org | 369a637 | 2014-09-17 22:37:29 | [diff] [blame] | 250 | IPAddress ip = (*it)->GetBestIP(); |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 251 | SocketAddress bindaddress(ip, 0); |
| 252 | bindaddress.SetScopeID((*it)->scope_id()); |
| 253 | // TODO(thaloun): Use rtc::AsyncSocket once it supports IPv6. |
| 254 | int fd = static_cast<int>(socket(ip.family(), SOCK_STREAM, IPPROTO_TCP)); |
| 255 | if (fd > 0) { |
| 256 | size_t ipsize = bindaddress.ToSockAddrStorage(&storage); |
| 257 | EXPECT_GE(ipsize, 0U); |
Yves Gerey | 665174f | 2018-06-19 13:03:05 | [diff] [blame] | 258 | int success = ::bind(fd, reinterpret_cast<sockaddr*>(&storage), |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 259 | static_cast<int>(ipsize)); |
| 260 | #if defined(WEBRTC_WIN) |
Mirko Bonadei | 675513b | 2017-11-09 10:09:25 | [diff] [blame] | 261 | if (success) |
| 262 | RTC_LOG_GLE(LS_ERROR) << "Socket bind failed."; |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 263 | #endif |
| 264 | EXPECT_EQ(0, success); |
| 265 | #if defined(WEBRTC_WIN) |
| 266 | closesocket(fd); |
| 267 | #else |
| 268 | close(fd); |
| 269 | #endif |
| 270 | } |
| 271 | delete (*it); |
| 272 | } |
| 273 | } |
| 274 | |
Guo-wei Shieh | 47872ec | 2015-08-19 17:32:46 | [diff] [blame] | 275 | // Test StartUpdating() and StopUpdating(). network_permission_state starts with |
| 276 | // ALLOWED. |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 277 | TEST_F(NetworkTest, TestUpdateNetworks) { |
| 278 | BasicNetworkManager manager; |
Yves Gerey | 665174f | 2018-06-19 13:03:05 | [diff] [blame] | 279 | manager.SignalNetworksChanged.connect(static_cast<NetworkTest*>(this), |
| 280 | &NetworkTest::OnNetworksChanged); |
guoweis | ea1012b | 2015-08-21 16:06:28 | [diff] [blame] | 281 | EXPECT_EQ(NetworkManager::ENUMERATION_ALLOWED, |
| 282 | manager.enumeration_permission()); |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 283 | manager.StartUpdating(); |
| 284 | Thread::Current()->ProcessMessages(0); |
| 285 | EXPECT_TRUE(callback_called_); |
| 286 | callback_called_ = false; |
| 287 | // Callback should be triggered immediately when StartUpdating |
| 288 | // is called, after network update signal is already sent. |
| 289 | manager.StartUpdating(); |
| 290 | EXPECT_TRUE(manager.started()); |
| 291 | Thread::Current()->ProcessMessages(0); |
| 292 | EXPECT_TRUE(callback_called_); |
| 293 | manager.StopUpdating(); |
| 294 | EXPECT_TRUE(manager.started()); |
| 295 | manager.StopUpdating(); |
guoweis | ea1012b | 2015-08-21 16:06:28 | [diff] [blame] | 296 | EXPECT_EQ(NetworkManager::ENUMERATION_ALLOWED, |
| 297 | manager.enumeration_permission()); |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 298 | EXPECT_FALSE(manager.started()); |
| 299 | manager.StopUpdating(); |
| 300 | EXPECT_FALSE(manager.started()); |
| 301 | callback_called_ = false; |
| 302 | // Callback should be triggered immediately after StartUpdating is called |
| 303 | // when start_count_ is reset to 0. |
| 304 | manager.StartUpdating(); |
| 305 | Thread::Current()->ProcessMessages(0); |
| 306 | EXPECT_TRUE(callback_called_); |
| 307 | } |
| 308 | |
| 309 | // Verify that MergeNetworkList() merges network lists properly. |
| 310 | TEST_F(NetworkTest, TestBasicMergeNetworkList) { |
| 311 | Network ipv4_network1("test_eth0", "Test Network Adapter 1", |
| 312 | IPAddress(0x12345600U), 24); |
| 313 | Network ipv4_network2("test_eth1", "Test Network Adapter 2", |
| 314 | IPAddress(0x00010000U), 16); |
| 315 | ipv4_network1.AddIP(IPAddress(0x12345678)); |
| 316 | ipv4_network2.AddIP(IPAddress(0x00010004)); |
| 317 | BasicNetworkManager manager; |
| 318 | |
| 319 | // Add ipv4_network1 to the list of networks. |
| 320 | NetworkManager::NetworkList list; |
| 321 | list.push_back(new Network(ipv4_network1)); |
| 322 | bool changed; |
guoweis@webrtc.org | a094cac | 2015-01-28 19:34:05 | [diff] [blame] | 323 | NetworkManager::Stats stats = MergeNetworkList(manager, list, &changed); |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 324 | EXPECT_TRUE(changed); |
guoweis@webrtc.org | a094cac | 2015-01-28 19:34:05 | [diff] [blame] | 325 | EXPECT_EQ(stats.ipv6_network_count, 0); |
| 326 | EXPECT_EQ(stats.ipv4_network_count, 1); |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 327 | list.clear(); |
| 328 | |
| 329 | manager.GetNetworks(&list); |
| 330 | EXPECT_EQ(1U, list.size()); |
Qingsi Wang | 10a0e51 | 2018-05-16 20:37:03 | [diff] [blame] | 331 | EXPECT_TRUE(SameNameAndPrefix(ipv4_network1, *list[0])); |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 332 | Network* net1 = list[0]; |
honghaiz | a0c44ea | 2016-03-23 23:07:48 | [diff] [blame] | 333 | uint16_t net_id1 = net1->id(); |
| 334 | EXPECT_EQ(1, net_id1); |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 335 | list.clear(); |
| 336 | |
| 337 | // Replace ipv4_network1 with ipv4_network2. |
| 338 | list.push_back(new Network(ipv4_network2)); |
guoweis@webrtc.org | a094cac | 2015-01-28 19:34:05 | [diff] [blame] | 339 | stats = MergeNetworkList(manager, list, &changed); |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 340 | EXPECT_TRUE(changed); |
guoweis@webrtc.org | a094cac | 2015-01-28 19:34:05 | [diff] [blame] | 341 | EXPECT_EQ(stats.ipv6_network_count, 0); |
| 342 | EXPECT_EQ(stats.ipv4_network_count, 1); |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 343 | list.clear(); |
| 344 | |
| 345 | manager.GetNetworks(&list); |
| 346 | EXPECT_EQ(1U, list.size()); |
Qingsi Wang | 10a0e51 | 2018-05-16 20:37:03 | [diff] [blame] | 347 | EXPECT_TRUE(SameNameAndPrefix(ipv4_network2, *list[0])); |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 348 | Network* net2 = list[0]; |
honghaiz | a0c44ea | 2016-03-23 23:07:48 | [diff] [blame] | 349 | uint16_t net_id2 = net2->id(); |
| 350 | // Network id will increase. |
| 351 | EXPECT_LT(net_id1, net_id2); |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 352 | list.clear(); |
| 353 | |
| 354 | // Add Network2 back. |
| 355 | list.push_back(new Network(ipv4_network1)); |
| 356 | list.push_back(new Network(ipv4_network2)); |
guoweis@webrtc.org | a094cac | 2015-01-28 19:34:05 | [diff] [blame] | 357 | stats = MergeNetworkList(manager, list, &changed); |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 358 | EXPECT_TRUE(changed); |
guoweis@webrtc.org | a094cac | 2015-01-28 19:34:05 | [diff] [blame] | 359 | EXPECT_EQ(stats.ipv6_network_count, 0); |
| 360 | EXPECT_EQ(stats.ipv4_network_count, 2); |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 361 | list.clear(); |
| 362 | |
| 363 | // Verify that we get previous instances of Network objects. |
| 364 | manager.GetNetworks(&list); |
| 365 | EXPECT_EQ(2U, list.size()); |
| 366 | EXPECT_TRUE((net1 == list[0] && net2 == list[1]) || |
| 367 | (net1 == list[1] && net2 == list[0])); |
honghaiz | a0c44ea | 2016-03-23 23:07:48 | [diff] [blame] | 368 | EXPECT_TRUE((net_id1 == list[0]->id() && net_id2 == list[1]->id()) || |
| 369 | (net_id1 == list[1]->id() && net_id2 == list[0]->id())); |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 370 | list.clear(); |
| 371 | |
| 372 | // Call MergeNetworkList() again and verify that we don't get update |
| 373 | // notification. |
| 374 | list.push_back(new Network(ipv4_network2)); |
| 375 | list.push_back(new Network(ipv4_network1)); |
guoweis@webrtc.org | a094cac | 2015-01-28 19:34:05 | [diff] [blame] | 376 | stats = MergeNetworkList(manager, list, &changed); |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 377 | EXPECT_FALSE(changed); |
guoweis@webrtc.org | a094cac | 2015-01-28 19:34:05 | [diff] [blame] | 378 | EXPECT_EQ(stats.ipv6_network_count, 0); |
| 379 | EXPECT_EQ(stats.ipv4_network_count, 2); |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 380 | list.clear(); |
| 381 | |
| 382 | // Verify that we get previous instances of Network objects. |
| 383 | manager.GetNetworks(&list); |
| 384 | EXPECT_EQ(2U, list.size()); |
| 385 | EXPECT_TRUE((net1 == list[0] && net2 == list[1]) || |
| 386 | (net1 == list[1] && net2 == list[0])); |
honghaiz | a0c44ea | 2016-03-23 23:07:48 | [diff] [blame] | 387 | EXPECT_TRUE((net_id1 == list[0]->id() && net_id2 == list[1]->id()) || |
| 388 | (net_id1 == list[1]->id() && net_id2 == list[0]->id())); |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 389 | list.clear(); |
| 390 | } |
| 391 | |
| 392 | // Sets up some test IPv6 networks and appends them to list. |
| 393 | // Four networks are added - public and link local, for two interfaces. |
| 394 | void SetupNetworks(NetworkManager::NetworkList* list) { |
| 395 | IPAddress ip; |
| 396 | IPAddress prefix; |
guoweis@webrtc.org | bbce5ef | 2015-03-05 04:38:29 | [diff] [blame] | 397 | EXPECT_TRUE(IPFromString("abcd::1234:5678:abcd:ef12", &ip)); |
| 398 | EXPECT_TRUE(IPFromString("abcd::", &prefix)); |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 399 | // First, fake link-locals. |
| 400 | Network ipv6_eth0_linklocalnetwork("test_eth0", "Test NetworkAdapter 1", |
| 401 | prefix, 64); |
| 402 | ipv6_eth0_linklocalnetwork.AddIP(ip); |
guoweis@webrtc.org | bbce5ef | 2015-03-05 04:38:29 | [diff] [blame] | 403 | EXPECT_TRUE(IPFromString("abcd::5678:abcd:ef12:3456", &ip)); |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 404 | Network ipv6_eth1_linklocalnetwork("test_eth1", "Test NetworkAdapter 2", |
| 405 | prefix, 64); |
| 406 | ipv6_eth1_linklocalnetwork.AddIP(ip); |
| 407 | // Public networks: |
| 408 | EXPECT_TRUE(IPFromString("2401:fa00:4:1000:be30:5bff:fee5:c3", &ip)); |
| 409 | prefix = TruncateIP(ip, 64); |
| 410 | Network ipv6_eth0_publicnetwork1_ip1("test_eth0", "Test NetworkAdapter 1", |
| 411 | prefix, 64); |
| 412 | ipv6_eth0_publicnetwork1_ip1.AddIP(ip); |
| 413 | EXPECT_TRUE(IPFromString("2400:4030:1:2c00:be30:abcd:efab:cdef", &ip)); |
| 414 | prefix = TruncateIP(ip, 64); |
| 415 | Network ipv6_eth1_publicnetwork1_ip1("test_eth1", "Test NetworkAdapter 1", |
| 416 | prefix, 64); |
| 417 | ipv6_eth1_publicnetwork1_ip1.AddIP(ip); |
| 418 | list->push_back(new Network(ipv6_eth0_linklocalnetwork)); |
| 419 | list->push_back(new Network(ipv6_eth1_linklocalnetwork)); |
| 420 | list->push_back(new Network(ipv6_eth0_publicnetwork1_ip1)); |
| 421 | list->push_back(new Network(ipv6_eth1_publicnetwork1_ip1)); |
| 422 | } |
| 423 | |
| 424 | // Test that the basic network merging case works. |
| 425 | TEST_F(NetworkTest, TestIPv6MergeNetworkList) { |
| 426 | BasicNetworkManager manager; |
Yves Gerey | 665174f | 2018-06-19 13:03:05 | [diff] [blame] | 427 | manager.SignalNetworksChanged.connect(static_cast<NetworkTest*>(this), |
| 428 | &NetworkTest::OnNetworksChanged); |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 429 | NetworkManager::NetworkList original_list; |
| 430 | SetupNetworks(&original_list); |
| 431 | bool changed = false; |
guoweis@webrtc.org | a094cac | 2015-01-28 19:34:05 | [diff] [blame] | 432 | NetworkManager::Stats stats = |
| 433 | MergeNetworkList(manager, original_list, &changed); |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 434 | EXPECT_TRUE(changed); |
guoweis@webrtc.org | a094cac | 2015-01-28 19:34:05 | [diff] [blame] | 435 | EXPECT_EQ(stats.ipv6_network_count, 4); |
| 436 | EXPECT_EQ(stats.ipv4_network_count, 0); |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 437 | NetworkManager::NetworkList list; |
| 438 | manager.GetNetworks(&list); |
| 439 | EXPECT_EQ(original_list.size(), list.size()); |
| 440 | // Verify that the original members are in the merged list. |
| 441 | for (NetworkManager::NetworkList::iterator it = original_list.begin(); |
| 442 | it != original_list.end(); ++it) { |
| 443 | EXPECT_NE(list.end(), std::find(list.begin(), list.end(), *it)); |
| 444 | } |
| 445 | } |
| 446 | |
| 447 | // Tests that when two network lists that describe the same set of networks are |
| 448 | // merged, that the changed callback is not called, and that the original |
| 449 | // objects remain in the result list. |
| 450 | TEST_F(NetworkTest, TestNoChangeMerge) { |
| 451 | BasicNetworkManager manager; |
Yves Gerey | 665174f | 2018-06-19 13:03:05 | [diff] [blame] | 452 | manager.SignalNetworksChanged.connect(static_cast<NetworkTest*>(this), |
| 453 | &NetworkTest::OnNetworksChanged); |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 454 | NetworkManager::NetworkList original_list; |
| 455 | SetupNetworks(&original_list); |
| 456 | bool changed = false; |
| 457 | MergeNetworkList(manager, original_list, &changed); |
| 458 | EXPECT_TRUE(changed); |
| 459 | // Second list that describes the same networks but with new objects. |
| 460 | NetworkManager::NetworkList second_list; |
| 461 | SetupNetworks(&second_list); |
| 462 | changed = false; |
| 463 | MergeNetworkList(manager, second_list, &changed); |
| 464 | EXPECT_FALSE(changed); |
| 465 | NetworkManager::NetworkList resulting_list; |
| 466 | manager.GetNetworks(&resulting_list); |
| 467 | EXPECT_EQ(original_list.size(), resulting_list.size()); |
| 468 | // Verify that the original members are in the merged list. |
| 469 | for (NetworkManager::NetworkList::iterator it = original_list.begin(); |
| 470 | it != original_list.end(); ++it) { |
| 471 | EXPECT_NE(resulting_list.end(), |
| 472 | std::find(resulting_list.begin(), resulting_list.end(), *it)); |
| 473 | } |
| 474 | // Doublecheck that the new networks aren't in the list. |
| 475 | for (NetworkManager::NetworkList::iterator it = second_list.begin(); |
| 476 | it != second_list.end(); ++it) { |
| 477 | EXPECT_EQ(resulting_list.end(), |
| 478 | std::find(resulting_list.begin(), resulting_list.end(), *it)); |
| 479 | } |
| 480 | } |
| 481 | |
| 482 | // Test that we can merge a network that is the same as another network but with |
| 483 | // a different IP. The original network should remain in the list, but have its |
| 484 | // IP changed. |
| 485 | TEST_F(NetworkTest, MergeWithChangedIP) { |
| 486 | BasicNetworkManager manager; |
Yves Gerey | 665174f | 2018-06-19 13:03:05 | [diff] [blame] | 487 | manager.SignalNetworksChanged.connect(static_cast<NetworkTest*>(this), |
| 488 | &NetworkTest::OnNetworksChanged); |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 489 | NetworkManager::NetworkList original_list; |
| 490 | SetupNetworks(&original_list); |
| 491 | // Make a network that we're going to change. |
| 492 | IPAddress ip; |
| 493 | EXPECT_TRUE(IPFromString("2401:fa01:4:1000:be30:faa:fee:faa", &ip)); |
| 494 | IPAddress prefix = TruncateIP(ip, 64); |
Yves Gerey | 665174f | 2018-06-19 13:03:05 | [diff] [blame] | 495 | Network* network_to_change = |
| 496 | new Network("test_eth0", "Test Network Adapter 1", prefix, 64); |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 497 | Network* changed_network = new Network(*network_to_change); |
| 498 | network_to_change->AddIP(ip); |
| 499 | IPAddress changed_ip; |
| 500 | EXPECT_TRUE(IPFromString("2401:fa01:4:1000:be30:f00:f00:f00", &changed_ip)); |
| 501 | changed_network->AddIP(changed_ip); |
| 502 | original_list.push_back(network_to_change); |
| 503 | bool changed = false; |
| 504 | MergeNetworkList(manager, original_list, &changed); |
| 505 | NetworkManager::NetworkList second_list; |
| 506 | SetupNetworks(&second_list); |
| 507 | second_list.push_back(changed_network); |
| 508 | changed = false; |
| 509 | MergeNetworkList(manager, second_list, &changed); |
| 510 | EXPECT_TRUE(changed); |
| 511 | NetworkManager::NetworkList list; |
| 512 | manager.GetNetworks(&list); |
| 513 | EXPECT_EQ(original_list.size(), list.size()); |
| 514 | // Make sure the original network is still in the merged list. |
Yves Gerey | 665174f | 2018-06-19 13:03:05 | [diff] [blame] | 515 | EXPECT_NE(list.end(), std::find(list.begin(), list.end(), network_to_change)); |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 516 | EXPECT_EQ(changed_ip, network_to_change->GetIPs().at(0)); |
| 517 | } |
| 518 | |
| 519 | // Testing a similar case to above, but checking that a network can be updated |
| 520 | // with additional IPs (not just a replacement). |
| 521 | TEST_F(NetworkTest, TestMultipleIPMergeNetworkList) { |
| 522 | BasicNetworkManager manager; |
Yves Gerey | 665174f | 2018-06-19 13:03:05 | [diff] [blame] | 523 | manager.SignalNetworksChanged.connect(static_cast<NetworkTest*>(this), |
| 524 | &NetworkTest::OnNetworksChanged); |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 525 | NetworkManager::NetworkList original_list; |
| 526 | SetupNetworks(&original_list); |
| 527 | bool changed = false; |
| 528 | MergeNetworkList(manager, original_list, &changed); |
| 529 | EXPECT_TRUE(changed); |
| 530 | IPAddress ip; |
| 531 | IPAddress check_ip; |
| 532 | IPAddress prefix; |
| 533 | // Add a second IP to the public network on eth0 (2401:fa00:4:1000/64). |
| 534 | EXPECT_TRUE(IPFromString("2401:fa00:4:1000:be30:5bff:fee5:c6", &ip)); |
| 535 | prefix = TruncateIP(ip, 64); |
| 536 | Network ipv6_eth0_publicnetwork1_ip2("test_eth0", "Test NetworkAdapter 1", |
| 537 | prefix, 64); |
| 538 | // This is the IP that already existed in the public network on eth0. |
| 539 | EXPECT_TRUE(IPFromString("2401:fa00:4:1000:be30:5bff:fee5:c3", &check_ip)); |
| 540 | ipv6_eth0_publicnetwork1_ip2.AddIP(ip); |
| 541 | original_list.push_back(new Network(ipv6_eth0_publicnetwork1_ip2)); |
| 542 | changed = false; |
| 543 | MergeNetworkList(manager, original_list, &changed); |
| 544 | EXPECT_TRUE(changed); |
| 545 | // There should still be four networks. |
| 546 | NetworkManager::NetworkList list; |
| 547 | manager.GetNetworks(&list); |
| 548 | EXPECT_EQ(4U, list.size()); |
| 549 | // Check the gathered IPs. |
| 550 | int matchcount = 0; |
| 551 | for (NetworkManager::NetworkList::iterator it = list.begin(); |
| 552 | it != list.end(); ++it) { |
Qingsi Wang | 10a0e51 | 2018-05-16 20:37:03 | [diff] [blame] | 553 | if (SameNameAndPrefix(**it, *original_list[2])) { |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 554 | ++matchcount; |
| 555 | EXPECT_EQ(1, matchcount); |
| 556 | // This should be the same network object as before. |
| 557 | EXPECT_EQ((*it), original_list[2]); |
| 558 | // But with two addresses now. |
| 559 | EXPECT_EQ(2U, (*it)->GetIPs().size()); |
| 560 | EXPECT_NE((*it)->GetIPs().end(), |
Taylor Brandstetter | 01cb5f2 | 2018-03-07 23:49:32 | [diff] [blame] | 561 | std::find((*it)->GetIPs().begin(), (*it)->GetIPs().end(), |
| 562 | InterfaceAddress(check_ip))); |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 563 | EXPECT_NE((*it)->GetIPs().end(), |
Taylor Brandstetter | 01cb5f2 | 2018-03-07 23:49:32 | [diff] [blame] | 564 | std::find((*it)->GetIPs().begin(), (*it)->GetIPs().end(), |
| 565 | InterfaceAddress(ip))); |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 566 | } else { |
| 567 | // Check the IP didn't get added anywhere it wasn't supposed to. |
| 568 | EXPECT_EQ((*it)->GetIPs().end(), |
Taylor Brandstetter | 01cb5f2 | 2018-03-07 23:49:32 | [diff] [blame] | 569 | std::find((*it)->GetIPs().begin(), (*it)->GetIPs().end(), |
| 570 | InterfaceAddress(ip))); |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 571 | } |
| 572 | } |
| 573 | } |
| 574 | |
| 575 | // Test that merge correctly distinguishes multiple networks on an interface. |
| 576 | TEST_F(NetworkTest, TestMultiplePublicNetworksOnOneInterfaceMerge) { |
| 577 | BasicNetworkManager manager; |
Yves Gerey | 665174f | 2018-06-19 13:03:05 | [diff] [blame] | 578 | manager.SignalNetworksChanged.connect(static_cast<NetworkTest*>(this), |
| 579 | &NetworkTest::OnNetworksChanged); |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 580 | NetworkManager::NetworkList original_list; |
| 581 | SetupNetworks(&original_list); |
| 582 | bool changed = false; |
| 583 | MergeNetworkList(manager, original_list, &changed); |
| 584 | EXPECT_TRUE(changed); |
| 585 | IPAddress ip; |
| 586 | IPAddress prefix; |
| 587 | // A second network for eth0. |
| 588 | EXPECT_TRUE(IPFromString("2400:4030:1:2c00:be30:5bff:fee5:c3", &ip)); |
| 589 | prefix = TruncateIP(ip, 64); |
| 590 | Network ipv6_eth0_publicnetwork2_ip1("test_eth0", "Test NetworkAdapter 1", |
| 591 | prefix, 64); |
| 592 | ipv6_eth0_publicnetwork2_ip1.AddIP(ip); |
| 593 | original_list.push_back(new Network(ipv6_eth0_publicnetwork2_ip1)); |
| 594 | changed = false; |
| 595 | MergeNetworkList(manager, original_list, &changed); |
| 596 | EXPECT_TRUE(changed); |
| 597 | // There should be five networks now. |
| 598 | NetworkManager::NetworkList list; |
| 599 | manager.GetNetworks(&list); |
| 600 | EXPECT_EQ(5U, list.size()); |
| 601 | // Check the resulting addresses. |
| 602 | for (NetworkManager::NetworkList::iterator it = list.begin(); |
| 603 | it != list.end(); ++it) { |
| 604 | if ((*it)->prefix() == ipv6_eth0_publicnetwork2_ip1.prefix() && |
| 605 | (*it)->name() == ipv6_eth0_publicnetwork2_ip1.name()) { |
| 606 | // Check the new network has 1 IP and that it's the correct one. |
| 607 | EXPECT_EQ(1U, (*it)->GetIPs().size()); |
| 608 | EXPECT_EQ(ip, (*it)->GetIPs().at(0)); |
| 609 | } else { |
| 610 | // Check the IP didn't get added anywhere it wasn't supposed to. |
| 611 | EXPECT_EQ((*it)->GetIPs().end(), |
Taylor Brandstetter | 01cb5f2 | 2018-03-07 23:49:32 | [diff] [blame] | 612 | std::find((*it)->GetIPs().begin(), (*it)->GetIPs().end(), |
| 613 | InterfaceAddress(ip))); |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 614 | } |
| 615 | } |
| 616 | } |
| 617 | |
honghaiz | db8cf50 | 2015-12-21 21:08:46 | [diff] [blame] | 618 | // Test that DumpNetworks does not crash. |
| 619 | TEST_F(NetworkTest, TestCreateAndDumpNetworks) { |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 620 | BasicNetworkManager manager; |
honghaiz | db8cf50 | 2015-12-21 21:08:46 | [diff] [blame] | 621 | NetworkManager::NetworkList list = GetNetworks(manager, true); |
| 622 | bool changed; |
| 623 | MergeNetworkList(manager, list, &changed); |
| 624 | manager.DumpNetworks(); |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 625 | } |
| 626 | |
| 627 | // Test that we can toggle IPv6 on and off. |
minyue | 5d69648 | 2015-08-19 11:42:03 | [diff] [blame] | 628 | // Crashes on Linux. See webrtc:4923. |
| 629 | #if defined(WEBRTC_LINUX) |
| 630 | #define MAYBE_TestIPv6Toggle DISABLED_TestIPv6Toggle |
| 631 | #else |
| 632 | #define MAYBE_TestIPv6Toggle TestIPv6Toggle |
| 633 | #endif |
| 634 | TEST_F(NetworkTest, MAYBE_TestIPv6Toggle) { |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 635 | BasicNetworkManager manager; |
| 636 | bool ipv6_found = false; |
| 637 | NetworkManager::NetworkList list; |
| 638 | #if !defined(WEBRTC_WIN) |
| 639 | // There should be at least one IPv6 network (fe80::/64 should be in there). |
| 640 | // TODO(thaloun): Disabling this test on windows for the moment as the test |
| 641 | // machines don't seem to have IPv6 installed on them at all. |
| 642 | manager.set_ipv6_enabled(true); |
| 643 | list = GetNetworks(manager, true); |
| 644 | for (NetworkManager::NetworkList::iterator it = list.begin(); |
| 645 | it != list.end(); ++it) { |
| 646 | if ((*it)->prefix().family() == AF_INET6) { |
| 647 | ipv6_found = true; |
| 648 | break; |
| 649 | } |
| 650 | } |
| 651 | EXPECT_TRUE(ipv6_found); |
| 652 | for (NetworkManager::NetworkList::iterator it = list.begin(); |
| 653 | it != list.end(); ++it) { |
| 654 | delete (*it); |
| 655 | } |
| 656 | #endif |
| 657 | ipv6_found = false; |
| 658 | manager.set_ipv6_enabled(false); |
| 659 | list = GetNetworks(manager, true); |
| 660 | for (NetworkManager::NetworkList::iterator it = list.begin(); |
| 661 | it != list.end(); ++it) { |
| 662 | if ((*it)->prefix().family() == AF_INET6) { |
| 663 | ipv6_found = true; |
| 664 | break; |
| 665 | } |
| 666 | } |
| 667 | EXPECT_FALSE(ipv6_found); |
| 668 | for (NetworkManager::NetworkList::iterator it = list.begin(); |
| 669 | it != list.end(); ++it) { |
| 670 | delete (*it); |
| 671 | } |
| 672 | } |
| 673 | |
deadbeef | 3427f53 | 2017-07-26 23:09:33 | [diff] [blame] | 674 | // Test that when network interfaces are sorted and given preference values, |
| 675 | // IPv6 comes first. |
| 676 | TEST_F(NetworkTest, IPv6NetworksPreferredOverIPv4) { |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 677 | BasicNetworkManager manager; |
| 678 | Network ipv4_network1("test_eth0", "Test Network Adapter 1", |
| 679 | IPAddress(0x12345600U), 24); |
| 680 | ipv4_network1.AddIP(IPAddress(0x12345600U)); |
| 681 | |
| 682 | IPAddress ip; |
| 683 | IPAddress prefix; |
| 684 | EXPECT_TRUE(IPFromString("2400:4030:1:2c00:be30:abcd:efab:cdef", &ip)); |
| 685 | prefix = TruncateIP(ip, 64); |
| 686 | Network ipv6_eth1_publicnetwork1_ip1("test_eth1", "Test NetworkAdapter 2", |
| 687 | prefix, 64); |
| 688 | ipv6_eth1_publicnetwork1_ip1.AddIP(ip); |
| 689 | |
| 690 | NetworkManager::NetworkList list; |
| 691 | list.push_back(new Network(ipv4_network1)); |
| 692 | list.push_back(new Network(ipv6_eth1_publicnetwork1_ip1)); |
| 693 | Network* net1 = list[0]; |
| 694 | Network* net2 = list[1]; |
| 695 | |
| 696 | bool changed = false; |
| 697 | MergeNetworkList(manager, list, &changed); |
| 698 | ASSERT_TRUE(changed); |
| 699 | // After sorting IPv6 network should be higher order than IPv4 networks. |
| 700 | EXPECT_TRUE(net1->preference() < net2->preference()); |
| 701 | } |
| 702 | |
deadbeef | 3427f53 | 2017-07-26 23:09:33 | [diff] [blame] | 703 | // When two interfaces are equivalent in everything but name, they're expected |
| 704 | // to be preference-ordered by name. For example, "eth0" before "eth1". |
| 705 | TEST_F(NetworkTest, NetworksSortedByInterfaceName) { |
| 706 | BasicNetworkManager manager; |
| 707 | Network* eth0 = new Network("test_eth0", "Test Network Adapter 1", |
| 708 | IPAddress(0x65432100U), 24); |
| 709 | eth0->AddIP(IPAddress(0x65432100U)); |
| 710 | Network* eth1 = new Network("test_eth1", "Test Network Adapter 2", |
| 711 | IPAddress(0x12345600U), 24); |
| 712 | eth1->AddIP(IPAddress(0x12345600U)); |
| 713 | NetworkManager::NetworkList list; |
| 714 | // Add them to the list in the opposite of the expected sorted order, to |
| 715 | // ensure sorting actually occurs. |
| 716 | list.push_back(eth1); |
| 717 | list.push_back(eth0); |
| 718 | |
| 719 | bool changed = false; |
| 720 | MergeNetworkList(manager, list, &changed); |
| 721 | ASSERT_TRUE(changed); |
| 722 | // "test_eth0" should be preferred over "test_eth1". |
| 723 | EXPECT_TRUE(eth0->preference() > eth1->preference()); |
| 724 | } |
| 725 | |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 726 | TEST_F(NetworkTest, TestNetworkAdapterTypes) { |
| 727 | Network wifi("wlan0", "Wireless Adapter", IPAddress(0x12345600U), 24, |
| 728 | ADAPTER_TYPE_WIFI); |
| 729 | EXPECT_EQ(ADAPTER_TYPE_WIFI, wifi.type()); |
| 730 | Network ethernet("eth0", "Ethernet", IPAddress(0x12345600U), 24, |
| 731 | ADAPTER_TYPE_ETHERNET); |
| 732 | EXPECT_EQ(ADAPTER_TYPE_ETHERNET, ethernet.type()); |
| 733 | Network cellular("test_cell", "Cellular Adapter", IPAddress(0x12345600U), 24, |
| 734 | ADAPTER_TYPE_CELLULAR); |
| 735 | EXPECT_EQ(ADAPTER_TYPE_CELLULAR, cellular.type()); |
| 736 | Network vpn("bridge_test", "VPN Adapter", IPAddress(0x12345600U), 24, |
| 737 | ADAPTER_TYPE_VPN); |
| 738 | EXPECT_EQ(ADAPTER_TYPE_VPN, vpn.type()); |
| 739 | Network unknown("test", "Test Adapter", IPAddress(0x12345600U), 24, |
| 740 | ADAPTER_TYPE_UNKNOWN); |
| 741 | EXPECT_EQ(ADAPTER_TYPE_UNKNOWN, unknown.type()); |
| 742 | } |
| 743 | |
| 744 | #if defined(WEBRTC_POSIX) |
| 745 | // Verify that we correctly handle interfaces with no address. |
| 746 | TEST_F(NetworkTest, TestConvertIfAddrsNoAddress) { |
| 747 | ifaddrs list; |
| 748 | memset(&list, 0, sizeof(list)); |
| 749 | list.ifa_name = const_cast<char*>("test_iface"); |
| 750 | |
| 751 | NetworkManager::NetworkList result; |
| 752 | BasicNetworkManager manager; |
| 753 | CallConvertIfAddrs(manager, &list, true, &result); |
| 754 | EXPECT_TRUE(result.empty()); |
| 755 | } |
honghaiz | db8cf50 | 2015-12-21 21:08:46 | [diff] [blame] | 756 | |
| 757 | // Verify that if there are two addresses on one interface, only one network |
| 758 | // is generated. |
| 759 | TEST_F(NetworkTest, TestConvertIfAddrsMultiAddressesOnOneInterface) { |
| 760 | char if_name[20] = "rmnet0"; |
| 761 | ifaddrs* list = nullptr; |
| 762 | list = AddIpv6Address(list, if_name, "1000:2000:3000:4000:0:0:0:1", |
| 763 | "FFFF:FFFF:FFFF:FFFF::", 0); |
| 764 | list = AddIpv6Address(list, if_name, "1000:2000:3000:4000:0:0:0:2", |
| 765 | "FFFF:FFFF:FFFF:FFFF::", 0); |
| 766 | NetworkManager::NetworkList result; |
| 767 | BasicNetworkManager manager; |
| 768 | CallConvertIfAddrs(manager, list, true, &result); |
| 769 | EXPECT_EQ(1U, result.size()); |
| 770 | bool changed; |
| 771 | // This ensures we release the objects created in CallConvertIfAddrs. |
| 772 | MergeNetworkList(manager, result, &changed); |
| 773 | ReleaseIfAddrs(list); |
| 774 | } |
Guo-wei Shieh | 9faf154 | 2015-12-28 22:06:55 | [diff] [blame] | 775 | |
| 776 | TEST_F(NetworkTest, TestConvertIfAddrsNotRunning) { |
| 777 | ifaddrs list; |
| 778 | memset(&list, 0, sizeof(list)); |
| 779 | list.ifa_name = const_cast<char*>("test_iface"); |
| 780 | sockaddr ifa_addr; |
| 781 | sockaddr ifa_netmask; |
| 782 | list.ifa_addr = &ifa_addr; |
| 783 | list.ifa_netmask = &ifa_netmask; |
| 784 | |
| 785 | NetworkManager::NetworkList result; |
| 786 | BasicNetworkManager manager; |
| 787 | CallConvertIfAddrs(manager, &list, true, &result); |
| 788 | EXPECT_TRUE(result.empty()); |
| 789 | } |
Honghai Zhang | 351d77b | 2016-05-20 22:08:29 | [diff] [blame] | 790 | |
| 791 | // Tests that the network type can be updated after the network monitor is |
| 792 | // started. |
| 793 | TEST_F(NetworkTest, TestGetAdapterTypeFromNetworkMonitor) { |
| 794 | char if_name1[20] = "wifi0"; |
| 795 | std::string ipv6_address1 = "1000:2000:3000:4000:0:0:0:1"; |
| 796 | std::string ipv6_address2 = "1000:2000:3000:8000:0:0:0:1"; |
| 797 | std::string ipv6_mask = "FFFF:FFFF:FFFF:FFFF::"; |
| 798 | BasicNetworkManager manager; |
| 799 | // A network created before the network monitor is started will get |
| 800 | // UNKNOWN type. |
| 801 | ifaddrs* addr_list = |
| 802 | InstallIpv6Network(if_name1, ipv6_address1, ipv6_mask, manager); |
| 803 | EXPECT_EQ(ADAPTER_TYPE_UNKNOWN, GetAdapterType(manager)); |
| 804 | ReleaseIfAddrs(addr_list); |
| 805 | // Note: Do not call ClearNetworks here in order to test that the type |
| 806 | // of an existing network can be changed after the network monitor starts |
| 807 | // and detects the network type correctly. |
| 808 | |
| 809 | // After the network monitor starts, the type will be updated. |
| 810 | FakeNetworkMonitorFactory* factory = new FakeNetworkMonitorFactory(); |
| 811 | NetworkMonitorFactory::SetFactory(factory); |
| 812 | // This brings up the hook with the network monitor. |
| 813 | manager.StartUpdating(); |
| 814 | // Add the same ipv6 address as before but it has the right network type |
| 815 | // detected by the network monitor now. |
| 816 | addr_list = InstallIpv6Network(if_name1, ipv6_address1, ipv6_mask, manager); |
| 817 | EXPECT_EQ(ADAPTER_TYPE_WIFI, GetAdapterType(manager)); |
| 818 | ReleaseIfAddrs(addr_list); |
| 819 | ClearNetworks(manager); |
| 820 | |
| 821 | // Add another network with the type inferred from the network monitor. |
| 822 | char if_name2[20] = "cellular0"; |
| 823 | addr_list = InstallIpv6Network(if_name2, ipv6_address2, ipv6_mask, manager); |
| 824 | EXPECT_EQ(ADAPTER_TYPE_CELLULAR, GetAdapterType(manager)); |
| 825 | ReleaseIfAddrs(addr_list); |
| 826 | ClearNetworks(manager); |
| 827 | } |
| 828 | |
| 829 | // Test that the network type can be determined based on name matching in |
| 830 | // a few cases. Note that UNKNOWN type for non-matching strings has been tested |
| 831 | // in the above test. |
| 832 | TEST_F(NetworkTest, TestGetAdapterTypeFromNameMatching) { |
| 833 | std::string ipv6_address1 = "1000:2000:3000:4000:0:0:0:1"; |
| 834 | std::string ipv6_address2 = "1000:2000:3000:8000:0:0:0:1"; |
| 835 | std::string ipv6_mask = "FFFF:FFFF:FFFF:FFFF::"; |
| 836 | BasicNetworkManager manager; |
| 837 | |
deadbeef | 4cd599f | 2017-07-27 22:05:29 | [diff] [blame] | 838 | // IPSec interface; name is in form "ipsec<index>". |
| 839 | char if_name[20] = "ipsec11"; |
Honghai Zhang | 351d77b | 2016-05-20 22:08:29 | [diff] [blame] | 840 | ifaddrs* addr_list = |
| 841 | InstallIpv6Network(if_name, ipv6_address1, ipv6_mask, manager); |
deadbeef | 4cd599f | 2017-07-27 22:05:29 | [diff] [blame] | 842 | EXPECT_EQ(ADAPTER_TYPE_VPN, GetAdapterType(manager)); |
| 843 | ClearNetworks(manager); |
| 844 | ReleaseIfAddrs(addr_list); |
Honghai Zhang | 351d77b | 2016-05-20 22:08:29 | [diff] [blame] | 845 | |
Qingsi Wang | e53ac04 | 2018-05-08 18:55:07 | [diff] [blame] | 846 | strcpy(if_name, "lo0"); |
| 847 | addr_list = InstallIpv6Network(if_name, ipv6_address1, ipv6_mask, manager); |
| 848 | EXPECT_EQ(ADAPTER_TYPE_LOOPBACK, GetAdapterType(manager)); |
| 849 | ClearNetworks(manager); |
| 850 | ReleaseIfAddrs(addr_list); |
| 851 | |
| 852 | strcpy(if_name, "eth0"); |
| 853 | addr_list = InstallIpv6Network(if_name, ipv6_address1, ipv6_mask, manager); |
| 854 | EXPECT_EQ(ADAPTER_TYPE_ETHERNET, GetAdapterType(manager)); |
| 855 | ClearNetworks(manager); |
| 856 | ReleaseIfAddrs(addr_list); |
| 857 | |
deadbeef | 4cd599f | 2017-07-27 22:05:29 | [diff] [blame] | 858 | #if defined(WEBRTC_IOS) |
| 859 | strcpy(if_name, "pdp_ip0"); |
| 860 | addr_list = InstallIpv6Network(if_name, ipv6_address1, ipv6_mask, manager); |
Honghai Zhang | 351d77b | 2016-05-20 22:08:29 | [diff] [blame] | 861 | EXPECT_EQ(ADAPTER_TYPE_CELLULAR, GetAdapterType(manager)); |
| 862 | ClearNetworks(manager); |
| 863 | ReleaseIfAddrs(addr_list); |
| 864 | |
Honghai Zhang | 63ab810 | 2016-05-27 03:30:15 | [diff] [blame] | 865 | strcpy(if_name, "en0"); |
| 866 | addr_list = InstallIpv6Network(if_name, ipv6_address1, ipv6_mask, manager); |
| 867 | EXPECT_EQ(ADAPTER_TYPE_WIFI, GetAdapterType(manager)); |
| 868 | ClearNetworks(manager); |
| 869 | ReleaseIfAddrs(addr_list); |
| 870 | |
Honghai Zhang | 351d77b | 2016-05-20 22:08:29 | [diff] [blame] | 871 | #elif defined(WEBRTC_ANDROID) |
deadbeef | 4cd599f | 2017-07-27 22:05:29 | [diff] [blame] | 872 | strcpy(if_name, "rmnet0"); |
| 873 | addr_list = InstallIpv6Network(if_name, ipv6_address1, ipv6_mask, manager); |
Honghai Zhang | 351d77b | 2016-05-20 22:08:29 | [diff] [blame] | 874 | EXPECT_EQ(ADAPTER_TYPE_CELLULAR, GetAdapterType(manager)); |
| 875 | ClearNetworks(manager); |
| 876 | ReleaseIfAddrs(addr_list); |
| 877 | |
| 878 | strcpy(if_name, "wlan1"); |
| 879 | addr_list = InstallIpv6Network(if_name, ipv6_address2, ipv6_mask, manager); |
| 880 | EXPECT_EQ(ADAPTER_TYPE_WIFI, GetAdapterType(manager)); |
| 881 | ClearNetworks(manager); |
| 882 | ReleaseIfAddrs(addr_list); |
| 883 | |
| 884 | strcpy(if_name, "v4-rmnet_data0"); |
| 885 | addr_list = InstallIpv6Network(if_name, ipv6_address2, ipv6_mask, manager); |
| 886 | EXPECT_EQ(ADAPTER_TYPE_CELLULAR, GetAdapterType(manager)); |
| 887 | ClearNetworks(manager); |
| 888 | ReleaseIfAddrs(addr_list); |
| 889 | #else |
deadbeef | 4cd599f | 2017-07-27 22:05:29 | [diff] [blame] | 890 | // TODO(deadbeef): If not iOS or Android, "wlan0" should be treated as |
| 891 | // "unknown"? Why? This should be fixed if there's no good reason. |
| 892 | strcpy(if_name, "wlan0"); |
| 893 | addr_list = InstallIpv6Network(if_name, ipv6_address1, ipv6_mask, manager); |
Honghai Zhang | 351d77b | 2016-05-20 22:08:29 | [diff] [blame] | 894 | |
| 895 | EXPECT_EQ(ADAPTER_TYPE_UNKNOWN, GetAdapterType(manager)); |
| 896 | ClearNetworks(manager); |
| 897 | ReleaseIfAddrs(addr_list); |
| 898 | #endif |
| 899 | } |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 900 | #endif // defined(WEBRTC_POSIX) |
| 901 | |
| 902 | #if defined(WEBRTC_LINUX) && !defined(WEBRTC_ANDROID) |
| 903 | // If you want to test non-default routes, you can do the following on a linux |
| 904 | // machine: |
| 905 | // 1) Load the dummy network driver: |
| 906 | // sudo modprobe dummy |
| 907 | // sudo ifconfig dummy0 127.0.0.1 |
| 908 | // 2) Run this test and confirm the output says it found a dummy route (and |
| 909 | // passes). |
| 910 | // 3) When done: |
| 911 | // sudo rmmmod dummy |
| 912 | TEST_F(NetworkTest, TestIgnoreNonDefaultRoutes) { |
| 913 | BasicNetworkManager manager; |
| 914 | NetworkManager::NetworkList list; |
| 915 | list = GetNetworks(manager, false); |
| 916 | bool found_dummy = false; |
Mirko Bonadei | 675513b | 2017-11-09 10:09:25 | [diff] [blame] | 917 | RTC_LOG(LS_INFO) << "Looking for dummy network: "; |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 918 | for (NetworkManager::NetworkList::iterator it = list.begin(); |
| 919 | it != list.end(); ++it) { |
Mirko Bonadei | 675513b | 2017-11-09 10:09:25 | [diff] [blame] | 920 | RTC_LOG(LS_INFO) << " Network name: " << (*it)->name(); |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 921 | found_dummy |= (*it)->name().find("dummy0") != std::string::npos; |
| 922 | } |
| 923 | for (NetworkManager::NetworkList::iterator it = list.begin(); |
| 924 | it != list.end(); ++it) { |
| 925 | delete (*it); |
| 926 | } |
| 927 | if (!found_dummy) { |
Mirko Bonadei | 675513b | 2017-11-09 10:09:25 | [diff] [blame] | 928 | RTC_LOG(LS_INFO) << "No dummy found, quitting."; |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 929 | return; |
| 930 | } |
Mirko Bonadei | 675513b | 2017-11-09 10:09:25 | [diff] [blame] | 931 | RTC_LOG(LS_INFO) << "Found dummy, running again while ignoring non-default " |
| 932 | << "routes."; |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 933 | manager.set_ignore_non_default_routes(true); |
| 934 | list = GetNetworks(manager, false); |
| 935 | for (NetworkManager::NetworkList::iterator it = list.begin(); |
| 936 | it != list.end(); ++it) { |
Mirko Bonadei | 675513b | 2017-11-09 10:09:25 | [diff] [blame] | 937 | RTC_LOG(LS_INFO) << " Network name: " << (*it)->name(); |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 938 | EXPECT_TRUE((*it)->name().find("dummy0") == std::string::npos); |
| 939 | } |
| 940 | for (NetworkManager::NetworkList::iterator it = list.begin(); |
| 941 | it != list.end(); ++it) { |
| 942 | delete (*it); |
| 943 | } |
| 944 | } |
| 945 | #endif |
| 946 | |
guoweis@webrtc.org | 4bbd3c8 | 2014-09-09 13:54:45 | [diff] [blame] | 947 | // Test MergeNetworkList successfully combines all IPs for the same |
| 948 | // prefix/length into a single Network. |
| 949 | TEST_F(NetworkTest, TestMergeNetworkList) { |
| 950 | BasicNetworkManager manager; |
| 951 | NetworkManager::NetworkList list; |
| 952 | |
| 953 | // Create 2 IPAddress classes with only last digit different. |
| 954 | IPAddress ip1, ip2; |
| 955 | EXPECT_TRUE(IPFromString("2400:4030:1:2c00:be30:0:0:1", &ip1)); |
| 956 | EXPECT_TRUE(IPFromString("2400:4030:1:2c00:be30:0:0:2", &ip2)); |
| 957 | |
| 958 | // Create 2 networks with the same prefix and length. |
| 959 | Network* net1 = new Network("em1", "em1", TruncateIP(ip1, 64), 64); |
| 960 | Network* net2 = new Network("em1", "em1", TruncateIP(ip1, 64), 64); |
| 961 | |
| 962 | // Add different IP into each. |
| 963 | net1->AddIP(ip1); |
| 964 | net2->AddIP(ip2); |
| 965 | |
| 966 | list.push_back(net1); |
| 967 | list.push_back(net2); |
| 968 | bool changed; |
| 969 | MergeNetworkList(manager, list, &changed); |
| 970 | EXPECT_TRUE(changed); |
| 971 | |
| 972 | NetworkManager::NetworkList list2; |
| 973 | manager.GetNetworks(&list2); |
| 974 | |
| 975 | // Make sure the resulted networklist has only 1 element and 2 |
| 976 | // IPAddresses. |
| 977 | EXPECT_EQ(list2.size(), 1uL); |
| 978 | EXPECT_EQ(list2[0]->GetIPs().size(), 2uL); |
Taylor Brandstetter | 01cb5f2 | 2018-03-07 23:49:32 | [diff] [blame] | 979 | EXPECT_EQ(list2[0]->GetIPs()[0], InterfaceAddress(ip1)); |
| 980 | EXPECT_EQ(list2[0]->GetIPs()[1], InterfaceAddress(ip2)); |
guoweis@webrtc.org | 4bbd3c8 | 2014-09-09 13:54:45 | [diff] [blame] | 981 | } |
| 982 | |
honghaiz | db8cf50 | 2015-12-21 21:08:46 | [diff] [blame] | 983 | // Test that MergeNetworkList successfully detects the change if |
| 984 | // a network becomes inactive and then active again. |
| 985 | TEST_F(NetworkTest, TestMergeNetworkListWithInactiveNetworks) { |
| 986 | BasicNetworkManager manager; |
| 987 | Network network1("test_wifi", "Test Network Adapter 1", |
| 988 | IPAddress(0x12345600U), 24); |
| 989 | Network network2("test_eth0", "Test Network Adapter 2", |
| 990 | IPAddress(0x00010000U), 16); |
| 991 | network1.AddIP(IPAddress(0x12345678)); |
| 992 | network2.AddIP(IPAddress(0x00010004)); |
| 993 | NetworkManager::NetworkList list; |
| 994 | Network* net1 = new Network(network1); |
| 995 | list.push_back(net1); |
| 996 | bool changed; |
| 997 | MergeNetworkList(manager, list, &changed); |
| 998 | EXPECT_TRUE(changed); |
| 999 | list.clear(); |
| 1000 | manager.GetNetworks(&list); |
| 1001 | ASSERT_EQ(1U, list.size()); |
| 1002 | EXPECT_EQ(net1, list[0]); |
| 1003 | |
| 1004 | list.clear(); |
| 1005 | Network* net2 = new Network(network2); |
| 1006 | list.push_back(net2); |
| 1007 | MergeNetworkList(manager, list, &changed); |
| 1008 | EXPECT_TRUE(changed); |
| 1009 | list.clear(); |
| 1010 | manager.GetNetworks(&list); |
| 1011 | ASSERT_EQ(1U, list.size()); |
| 1012 | EXPECT_EQ(net2, list[0]); |
| 1013 | |
| 1014 | // Now network1 is inactive. Try to merge it again. |
| 1015 | list.clear(); |
| 1016 | list.push_back(new Network(network1)); |
| 1017 | MergeNetworkList(manager, list, &changed); |
| 1018 | EXPECT_TRUE(changed); |
| 1019 | list.clear(); |
| 1020 | manager.GetNetworks(&list); |
| 1021 | ASSERT_EQ(1U, list.size()); |
| 1022 | EXPECT_TRUE(list[0]->active()); |
| 1023 | EXPECT_EQ(net1, list[0]); |
| 1024 | } |
| 1025 | |
guoweis@webrtc.org | 369a637 | 2014-09-17 22:37:29 | [diff] [blame] | 1026 | // Test that the filtering logic follows the defined ruleset in network.h. |
| 1027 | TEST_F(NetworkTest, TestIPv6Selection) { |
| 1028 | InterfaceAddress ip; |
| 1029 | std::string ipstr; |
| 1030 | |
| 1031 | ipstr = "2401:fa00:4:1000:be30:5bff:fee5:c3"; |
| 1032 | ASSERT_TRUE(IPFromString(ipstr, IPV6_ADDRESS_FLAG_DEPRECATED, &ip)); |
| 1033 | |
| 1034 | // Create a network with this prefix. |
Yves Gerey | 665174f | 2018-06-19 13:03:05 | [diff] [blame] | 1035 | Network ipv6_network("test_eth0", "Test NetworkAdapter", TruncateIP(ip, 64), |
| 1036 | 64); |
guoweis@webrtc.org | 369a637 | 2014-09-17 22:37:29 | [diff] [blame] | 1037 | |
| 1038 | // When there is no address added, it should return an unspecified |
| 1039 | // address. |
| 1040 | EXPECT_EQ(ipv6_network.GetBestIP(), IPAddress()); |
| 1041 | EXPECT_TRUE(IPIsUnspec(ipv6_network.GetBestIP())); |
| 1042 | |
| 1043 | // Deprecated one should not be returned. |
| 1044 | ipv6_network.AddIP(ip); |
| 1045 | EXPECT_EQ(ipv6_network.GetBestIP(), IPAddress()); |
| 1046 | |
aluebs@webrtc.org | 07dcf60 | 2015-02-27 18:42:22 | [diff] [blame] | 1047 | // Add ULA one. ULA is unique local address which is starting either |
| 1048 | // with 0xfc or 0xfd. |
guoweis@webrtc.org | 369a637 | 2014-09-17 22:37:29 | [diff] [blame] | 1049 | ipstr = "fd00:fa00:4:1000:be30:5bff:fee5:c4"; |
| 1050 | ASSERT_TRUE(IPFromString(ipstr, IPV6_ADDRESS_FLAG_NONE, &ip)); |
| 1051 | ipv6_network.AddIP(ip); |
aluebs@webrtc.org | 07dcf60 | 2015-02-27 18:42:22 | [diff] [blame] | 1052 | EXPECT_EQ(ipv6_network.GetBestIP(), static_cast<IPAddress>(ip)); |
guoweis@webrtc.org | 369a637 | 2014-09-17 22:37:29 | [diff] [blame] | 1053 | |
aluebs@webrtc.org | 07dcf60 | 2015-02-27 18:42:22 | [diff] [blame] | 1054 | // Add global one. |
guoweis@webrtc.org | 369a637 | 2014-09-17 22:37:29 | [diff] [blame] | 1055 | ipstr = "2401:fa00:4:1000:be30:5bff:fee5:c5"; |
| 1056 | ASSERT_TRUE(IPFromString(ipstr, IPV6_ADDRESS_FLAG_NONE, &ip)); |
| 1057 | ipv6_network.AddIP(ip); |
aluebs@webrtc.org | 07dcf60 | 2015-02-27 18:42:22 | [diff] [blame] | 1058 | EXPECT_EQ(ipv6_network.GetBestIP(), static_cast<IPAddress>(ip)); |
guoweis@webrtc.org | 369a637 | 2014-09-17 22:37:29 | [diff] [blame] | 1059 | |
| 1060 | // Add global dynamic temporary one. |
| 1061 | ipstr = "2401:fa00:4:1000:be30:5bff:fee5:c6"; |
| 1062 | ASSERT_TRUE(IPFromString(ipstr, IPV6_ADDRESS_FLAG_TEMPORARY, &ip)); |
| 1063 | ipv6_network.AddIP(ip); |
| 1064 | EXPECT_EQ(ipv6_network.GetBestIP(), static_cast<IPAddress>(ip)); |
| 1065 | } |
| 1066 | |
honghaiz | 023f3ef | 2015-10-19 16:39:32 | [diff] [blame] | 1067 | TEST_F(NetworkTest, TestNetworkMonitoring) { |
| 1068 | BasicNetworkManager manager; |
| 1069 | manager.SignalNetworksChanged.connect(static_cast<NetworkTest*>(this), |
| 1070 | &NetworkTest::OnNetworksChanged); |
| 1071 | FakeNetworkMonitorFactory* factory = new FakeNetworkMonitorFactory(); |
| 1072 | NetworkMonitorFactory::SetFactory(factory); |
| 1073 | manager.StartUpdating(); |
honghaiz | cec0a08 | 2016-01-15 22:49:09 | [diff] [blame] | 1074 | FakeNetworkMonitor* network_monitor = GetNetworkMonitor(manager); |
| 1075 | EXPECT_TRUE(network_monitor && network_monitor->started()); |
honghaiz | 023f3ef | 2015-10-19 16:39:32 | [diff] [blame] | 1076 | EXPECT_TRUE_WAIT(callback_called_, 1000); |
| 1077 | callback_called_ = false; |
| 1078 | |
| 1079 | // Clear the networks so that there will be network changes below. |
| 1080 | ClearNetworks(manager); |
| 1081 | // Network manager is started, so the callback is called when the network |
| 1082 | // monitor fires the network-change event. |
| 1083 | network_monitor->OnNetworksChanged(); |
| 1084 | EXPECT_TRUE_WAIT(callback_called_, 1000); |
| 1085 | |
honghaiz | cec0a08 | 2016-01-15 22:49:09 | [diff] [blame] | 1086 | // Network manager is stopped. |
honghaiz | 023f3ef | 2015-10-19 16:39:32 | [diff] [blame] | 1087 | manager.StopUpdating(); |
honghaiz | cec0a08 | 2016-01-15 22:49:09 | [diff] [blame] | 1088 | EXPECT_FALSE(GetNetworkMonitor(manager)->started()); |
honghaiz | 023f3ef | 2015-10-19 16:39:32 | [diff] [blame] | 1089 | |
| 1090 | NetworkMonitorFactory::ReleaseFactory(factory); |
| 1091 | } |
| 1092 | |
Edward Lemur | 8dc945c | 2016-07-21 08:16:40 | [diff] [blame] | 1093 | // Fails on Android: https://bugs.chromium.org/p/webrtc/issues/detail?id=4364. |
| 1094 | #if defined(WEBRTC_ANDROID) |
| 1095 | #define MAYBE_DefaultLocalAddress DISABLED_DefaultLocalAddress |
| 1096 | #else |
| 1097 | #define MAYBE_DefaultLocalAddress DefaultLocalAddress |
| 1098 | #endif |
| 1099 | TEST_F(NetworkTest, MAYBE_DefaultLocalAddress) { |
Guo-wei Shieh | a34c39e | 2015-11-25 21:12:26 | [diff] [blame] | 1100 | IPAddress ip; |
guoweis | 56271ed | 2016-01-15 22:45:06 | [diff] [blame] | 1101 | TestBasicNetworkManager manager; |
| 1102 | manager.SignalNetworksChanged.connect(static_cast<NetworkTest*>(this), |
| 1103 | &NetworkTest::OnNetworksChanged); |
| 1104 | FakeNetworkMonitorFactory* factory = new FakeNetworkMonitorFactory(); |
| 1105 | NetworkMonitorFactory::SetFactory(factory); |
| 1106 | manager.StartUpdating(); |
| 1107 | EXPECT_TRUE_WAIT(callback_called_, 1000); |
Guo-wei Shieh | a34c39e | 2015-11-25 21:12:26 | [diff] [blame] | 1108 | |
| 1109 | // Make sure we can query default local address when an address for such |
| 1110 | // address family exists. |
Guo-wei Shieh | 9af97f8 | 2015-11-10 22:47:39 | [diff] [blame] | 1111 | std::vector<Network*> networks; |
| 1112 | manager.GetNetworks(&networks); |
guoweis | 56271ed | 2016-01-15 22:45:06 | [diff] [blame] | 1113 | EXPECT_TRUE(!networks.empty()); |
Steve Anton | 9de3aac | 2017-10-24 17:08:26 | [diff] [blame] | 1114 | for (const auto* network : networks) { |
Guo-wei Shieh | 9af97f8 | 2015-11-10 22:47:39 | [diff] [blame] | 1115 | if (network->GetBestIP().family() == AF_INET) { |
| 1116 | EXPECT_TRUE(manager.QueryDefaultLocalAddress(AF_INET) != IPAddress()); |
guoweis | 56271ed | 2016-01-15 22:45:06 | [diff] [blame] | 1117 | } else if (network->GetBestIP().family() == AF_INET6 && |
| 1118 | !IPIsLoopback(network->GetBestIP())) { |
| 1119 | // Existence of an IPv6 loopback address doesn't mean it has IPv6 network |
| 1120 | // enabled. |
Guo-wei Shieh | 9af97f8 | 2015-11-10 22:47:39 | [diff] [blame] | 1121 | EXPECT_TRUE(manager.QueryDefaultLocalAddress(AF_INET6) != IPAddress()); |
| 1122 | } |
| 1123 | } |
Guo-wei Shieh | a34c39e | 2015-11-25 21:12:26 | [diff] [blame] | 1124 | |
| 1125 | // GetDefaultLocalAddress should return the valid default address after set. |
| 1126 | manager.set_default_local_addresses(GetLoopbackIP(AF_INET), |
| 1127 | GetLoopbackIP(AF_INET6)); |
| 1128 | EXPECT_TRUE(manager.GetDefaultLocalAddress(AF_INET, &ip)); |
| 1129 | EXPECT_EQ(ip, GetLoopbackIP(AF_INET)); |
| 1130 | EXPECT_TRUE(manager.GetDefaultLocalAddress(AF_INET6, &ip)); |
| 1131 | EXPECT_EQ(ip, GetLoopbackIP(AF_INET6)); |
honghaiz | af83fe6 | 2016-04-18 21:50:44 | [diff] [blame] | 1132 | |
| 1133 | // More tests on GetDefaultLocalAddress with ipv6 addresses where the set |
| 1134 | // default address may be different from the best IP address of any network. |
| 1135 | InterfaceAddress ip1; |
| 1136 | EXPECT_TRUE(IPFromString("abcd::1234:5678:abcd:1111", |
| 1137 | IPV6_ADDRESS_FLAG_TEMPORARY, &ip1)); |
| 1138 | // Create a network with a prefix of ip1. |
| 1139 | Network ipv6_network("test_eth0", "Test NetworkAdapter", TruncateIP(ip1, 64), |
| 1140 | 64); |
| 1141 | IPAddress ip2; |
| 1142 | EXPECT_TRUE(IPFromString("abcd::1234:5678:abcd:2222", &ip2)); |
| 1143 | ipv6_network.AddIP(ip1); |
| 1144 | ipv6_network.AddIP(ip2); |
| 1145 | BasicNetworkManager::NetworkList list(1, new Network(ipv6_network)); |
| 1146 | bool changed; |
| 1147 | MergeNetworkList(manager, list, &changed); |
| 1148 | // If the set default address is not in any network, GetDefaultLocalAddress |
| 1149 | // should return it. |
| 1150 | IPAddress ip3; |
| 1151 | EXPECT_TRUE(IPFromString("abcd::1234:5678:abcd:3333", &ip3)); |
| 1152 | manager.set_default_local_addresses(GetLoopbackIP(AF_INET), ip3); |
| 1153 | EXPECT_TRUE(manager.GetDefaultLocalAddress(AF_INET6, &ip)); |
| 1154 | EXPECT_EQ(ip3, ip); |
| 1155 | // If the set default address is in a network, GetDefaultLocalAddress will |
| 1156 | // return the best IP in that network. |
| 1157 | manager.set_default_local_addresses(GetLoopbackIP(AF_INET), ip2); |
| 1158 | EXPECT_TRUE(manager.GetDefaultLocalAddress(AF_INET6, &ip)); |
| 1159 | EXPECT_EQ(static_cast<IPAddress>(ip1), ip); |
| 1160 | |
Guo-wei Shieh | 9af97f8 | 2015-11-10 22:47:39 | [diff] [blame] | 1161 | manager.StopUpdating(); |
| 1162 | } |
| 1163 | |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 | [diff] [blame] | 1164 | } // namespace rtc |