/* * Copyright 2004 The WebRTC Project Authors. All rights reserved. * * Use of this source code is governed by a BSD-style license * that can be found in the LICENSE file in the root of the source * tree. An additional intellectual property rights grant can be found * in the file PATENTS. All contributing project authors may * be found in the AUTHORS file in the root of the source tree. */ #include "rtc_base/network.h" #include #include #include #include "absl/strings/match.h" #include "rtc_base/checks.h" #include "rtc_base/net_helpers.h" #include "rtc_base/network_monitor.h" #include "rtc_base/network_monitor_factory.h" #if defined(WEBRTC_POSIX) #include #include #include "rtc_base/ifaddrs_converter.h" #endif // defined(WEBRTC_POSIX) #include "rtc_base/gunit.h" #include "test/gmock.h" #if defined(WEBRTC_WIN) #include "rtc_base/logging.h" // For RTC_LOG_GLE #endif using ::testing::Contains; using ::testing::Not; using ::testing::UnorderedElementsAre; using ::testing::UnorderedElementsAreArray; namespace rtc { namespace { class FakeNetworkMonitor : public NetworkMonitorBase { public: void Start() override { started_ = true; } void Stop() override { started_ = false; } bool started() { return started_; } AdapterType GetAdapterType(const std::string& if_name) override { // Note that the name matching rules are different from the // GetAdapterTypeFromName in NetworkManager. if (absl::StartsWith(if_name, "wifi")) { return ADAPTER_TYPE_WIFI; } if (absl::StartsWith(if_name, "cellular")) { return ADAPTER_TYPE_CELLULAR; } return ADAPTER_TYPE_UNKNOWN; } NetworkPreference GetNetworkPreference(const std::string& if_name) override { return NetworkPreference::NEUTRAL; } private: bool started_ = false; }; class FakeNetworkMonitorFactory : public NetworkMonitorFactory { public: FakeNetworkMonitorFactory() {} NetworkMonitorInterface* CreateNetworkMonitor() override { return new FakeNetworkMonitor(); } }; bool SameNameAndPrefix(const rtc::Network& a, const rtc::Network& b) { if (a.name() != b.name()) { RTC_LOG(INFO) << "Different interface names."; return false; } if (a.prefix_length() != b.prefix_length() || a.prefix() != b.prefix()) { RTC_LOG(INFO) << "Different IP prefixes."; return false; } return true; } } // namespace class NetworkTest : public ::testing::Test, public sigslot::has_slots<> { public: NetworkTest() : callback_called_(false) {} void OnNetworksChanged() { callback_called_ = true; } NetworkManager::Stats MergeNetworkList( BasicNetworkManager& network_manager, const NetworkManager::NetworkList& list, bool* changed) { NetworkManager::Stats stats; network_manager.MergeNetworkList(list, changed, &stats); return stats; } bool IsIgnoredNetwork(BasicNetworkManager& network_manager, const Network& network) { RTC_DCHECK_RUN_ON(network_manager.thread_); return network_manager.IsIgnoredNetwork(network); } IPAddress QueryDefaultLocalAddress(BasicNetworkManager& network_manager, int family) { RTC_DCHECK_RUN_ON(network_manager.thread_); return network_manager.QueryDefaultLocalAddress(family); } NetworkManager::NetworkList GetNetworks( const BasicNetworkManager& network_manager, bool include_ignored) { RTC_DCHECK_RUN_ON(network_manager.thread_); NetworkManager::NetworkList list; network_manager.CreateNetworks(include_ignored, &list); return list; } FakeNetworkMonitor* GetNetworkMonitor(BasicNetworkManager& network_manager) { RTC_DCHECK_RUN_ON(network_manager.thread_); return static_cast( network_manager.network_monitor_.get()); } void ClearNetworks(BasicNetworkManager& network_manager) { for (const auto& kv : network_manager.networks_map_) { delete kv.second; } network_manager.networks_.clear(); network_manager.networks_map_.clear(); } AdapterType GetAdapterType(BasicNetworkManager& network_manager) { BasicNetworkManager::NetworkList list; network_manager.GetNetworks(&list); RTC_CHECK_EQ(1, list.size()); return list[0]->type(); } #if defined(WEBRTC_POSIX) // Separated from CreateNetworks for tests. static void CallConvertIfAddrs(const BasicNetworkManager& network_manager, struct ifaddrs* interfaces, bool include_ignored, NetworkManager::NetworkList* networks) { RTC_DCHECK_RUN_ON(network_manager.thread_); // Use the base IfAddrsConverter for test cases. std::unique_ptr ifaddrs_converter(new IfAddrsConverter()); network_manager.ConvertIfAddrs(interfaces, ifaddrs_converter.get(), include_ignored, networks); } struct sockaddr_in6* CreateIpv6Addr(const std::string& ip_string, uint32_t scope_id) { struct sockaddr_in6* ipv6_addr = static_cast(malloc(sizeof(struct sockaddr_in6))); memset(ipv6_addr, 0, sizeof(struct sockaddr_in6)); ipv6_addr->sin6_family = AF_INET6; ipv6_addr->sin6_scope_id = scope_id; IPAddress ip; IPFromString(ip_string, &ip); ipv6_addr->sin6_addr = ip.ipv6_address(); return ipv6_addr; } // Pointers created here need to be released via ReleaseIfAddrs. struct ifaddrs* AddIpv6Address(struct ifaddrs* list, char* if_name, const std::string& ipv6_address, const std::string& ipv6_netmask, uint32_t scope_id) { struct ifaddrs* if_addr = new struct ifaddrs; memset(if_addr, 0, sizeof(struct ifaddrs)); if_addr->ifa_name = if_name; if_addr->ifa_addr = reinterpret_cast( CreateIpv6Addr(ipv6_address, scope_id)); if_addr->ifa_netmask = reinterpret_cast(CreateIpv6Addr(ipv6_netmask, 0)); if_addr->ifa_next = list; if_addr->ifa_flags = IFF_RUNNING; return if_addr; } struct ifaddrs* InstallIpv6Network(char* if_name, const std::string& ipv6_address, const std::string& ipv6_mask, BasicNetworkManager& network_manager) { ifaddrs* addr_list = nullptr; addr_list = AddIpv6Address(addr_list, if_name, ipv6_address, ipv6_mask, 0); NetworkManager::NetworkList result; bool changed; NetworkManager::Stats stats; CallConvertIfAddrs(network_manager, addr_list, true, &result); network_manager.MergeNetworkList(result, &changed, &stats); return addr_list; } struct sockaddr_in* CreateIpv4Addr(const std::string& ip_string) { struct sockaddr_in* ipv4_addr = static_cast(malloc(sizeof(struct sockaddr_in))); memset(ipv4_addr, 0, sizeof(struct sockaddr_in)); ipv4_addr->sin_family = AF_INET; IPAddress ip; IPFromString(ip_string, &ip); ipv4_addr->sin_addr = ip.ipv4_address(); return ipv4_addr; } // Pointers created here need to be released via ReleaseIfAddrs. struct ifaddrs* AddIpv4Address(struct ifaddrs* list, char* if_name, const std::string& ipv4_address, const std::string& ipv4_netmask) { struct ifaddrs* if_addr = new struct ifaddrs; memset(if_addr, 0, sizeof(struct ifaddrs)); if_addr->ifa_name = if_name; if_addr->ifa_addr = reinterpret_cast(CreateIpv4Addr(ipv4_address)); if_addr->ifa_netmask = reinterpret_cast(CreateIpv4Addr(ipv4_netmask)); if_addr->ifa_next = list; if_addr->ifa_flags = IFF_RUNNING; return if_addr; } struct ifaddrs* InstallIpv4Network(char* if_name, const std::string& ipv4_address, const std::string& ipv4_mask, BasicNetworkManager& network_manager) { ifaddrs* addr_list = nullptr; addr_list = AddIpv4Address(addr_list, if_name, ipv4_address, ipv4_mask); NetworkManager::NetworkList result; bool changed; NetworkManager::Stats stats; CallConvertIfAddrs(network_manager, addr_list, true, &result); network_manager.MergeNetworkList(result, &changed, &stats); return addr_list; } void ReleaseIfAddrs(struct ifaddrs* list) { struct ifaddrs* if_addr = list; while (if_addr != nullptr) { struct ifaddrs* next_addr = if_addr->ifa_next; free(if_addr->ifa_addr); free(if_addr->ifa_netmask); delete if_addr; if_addr = next_addr; } } #endif // defined(WEBRTC_POSIX) protected: bool callback_called_; }; class TestBasicNetworkManager : public BasicNetworkManager { public: TestBasicNetworkManager(NetworkMonitorFactory* network_monitor_factory) : BasicNetworkManager(network_monitor_factory) {} using BasicNetworkManager::QueryDefaultLocalAddress; using BasicNetworkManager::set_default_local_addresses; }; // Test that the Network ctor works properly. TEST_F(NetworkTest, TestNetworkConstruct) { Network ipv4_network1("test_eth0", "Test Network Adapter 1", IPAddress(0x12345600U), 24); EXPECT_EQ("test_eth0", ipv4_network1.name()); EXPECT_EQ("Test Network Adapter 1", ipv4_network1.description()); EXPECT_EQ(IPAddress(0x12345600U), ipv4_network1.prefix()); EXPECT_EQ(24, ipv4_network1.prefix_length()); EXPECT_FALSE(ipv4_network1.ignored()); } TEST_F(NetworkTest, TestIsIgnoredNetworkIgnoresIPsStartingWith0) { Network ipv4_network1("test_eth0", "Test Network Adapter 1", IPAddress(0x12345600U), 24, ADAPTER_TYPE_ETHERNET); Network ipv4_network2("test_eth1", "Test Network Adapter 2", IPAddress(0x010000U), 24, ADAPTER_TYPE_ETHERNET); BasicNetworkManager network_manager; network_manager.StartUpdating(); EXPECT_FALSE(IsIgnoredNetwork(network_manager, ipv4_network1)); EXPECT_TRUE(IsIgnoredNetwork(network_manager, ipv4_network2)); } // TODO(phoglund): Remove when ignore list goes away. TEST_F(NetworkTest, TestIgnoreList) { Network ignore_me("ignore_me", "Ignore me please!", IPAddress(0x12345600U), 24); Network include_me("include_me", "Include me please!", IPAddress(0x12345600U), 24); BasicNetworkManager default_network_manager; default_network_manager.StartUpdating(); EXPECT_FALSE(IsIgnoredNetwork(default_network_manager, ignore_me)); EXPECT_FALSE(IsIgnoredNetwork(default_network_manager, include_me)); BasicNetworkManager ignoring_network_manager; std::vector ignore_list; ignore_list.push_back("ignore_me"); ignoring_network_manager.set_network_ignore_list(ignore_list); ignoring_network_manager.StartUpdating(); EXPECT_TRUE(IsIgnoredNetwork(ignoring_network_manager, ignore_me)); EXPECT_FALSE(IsIgnoredNetwork(ignoring_network_manager, include_me)); } // Test is failing on Windows opt: b/11288214 TEST_F(NetworkTest, DISABLED_TestCreateNetworks) { BasicNetworkManager manager; NetworkManager::NetworkList result = GetNetworks(manager, true); // We should be able to bind to any addresses we find. NetworkManager::NetworkList::iterator it; for (it = result.begin(); it != result.end(); ++it) { sockaddr_storage storage; memset(&storage, 0, sizeof(storage)); IPAddress ip = (*it)->GetBestIP(); SocketAddress bindaddress(ip, 0); bindaddress.SetScopeID((*it)->scope_id()); // TODO(thaloun): Use rtc::AsyncSocket once it supports IPv6. int fd = static_cast(socket(ip.family(), SOCK_STREAM, IPPROTO_TCP)); if (fd > 0) { size_t ipsize = bindaddress.ToSockAddrStorage(&storage); EXPECT_GE(ipsize, 0U); int success = ::bind(fd, reinterpret_cast(&storage), static_cast(ipsize)); #if defined(WEBRTC_WIN) if (success) RTC_LOG_GLE(LS_ERROR) << "Socket bind failed."; #endif EXPECT_EQ(0, success); #if defined(WEBRTC_WIN) closesocket(fd); #else close(fd); #endif } delete (*it); } } // Test StartUpdating() and StopUpdating(). network_permission_state starts with // ALLOWED. TEST_F(NetworkTest, TestUpdateNetworks) { BasicNetworkManager manager; manager.SignalNetworksChanged.connect(static_cast(this), &NetworkTest::OnNetworksChanged); EXPECT_EQ(NetworkManager::ENUMERATION_ALLOWED, manager.enumeration_permission()); manager.StartUpdating(); Thread::Current()->ProcessMessages(0); EXPECT_TRUE(callback_called_); callback_called_ = false; // Callback should be triggered immediately when StartUpdating // is called, after network update signal is already sent. manager.StartUpdating(); EXPECT_TRUE(manager.started()); Thread::Current()->ProcessMessages(0); EXPECT_TRUE(callback_called_); manager.StopUpdating(); EXPECT_TRUE(manager.started()); manager.StopUpdating(); EXPECT_EQ(NetworkManager::ENUMERATION_ALLOWED, manager.enumeration_permission()); EXPECT_FALSE(manager.started()); manager.StopUpdating(); EXPECT_FALSE(manager.started()); callback_called_ = false; // Callback should be triggered immediately after StartUpdating is called // when start_count_ is reset to 0. manager.StartUpdating(); Thread::Current()->ProcessMessages(0); EXPECT_TRUE(callback_called_); } // Verify that MergeNetworkList() merges network lists properly. TEST_F(NetworkTest, TestBasicMergeNetworkList) { Network ipv4_network1("test_eth0", "Test Network Adapter 1", IPAddress(0x12345600U), 24); Network ipv4_network2("test_eth1", "Test Network Adapter 2", IPAddress(0x00010000U), 16); ipv4_network1.AddIP(IPAddress(0x12345678)); ipv4_network2.AddIP(IPAddress(0x00010004)); BasicNetworkManager manager; // Add ipv4_network1 to the list of networks. NetworkManager::NetworkList list; list.push_back(new Network(ipv4_network1)); bool changed; NetworkManager::Stats stats = MergeNetworkList(manager, list, &changed); EXPECT_TRUE(changed); EXPECT_EQ(stats.ipv6_network_count, 0); EXPECT_EQ(stats.ipv4_network_count, 1); list.clear(); manager.GetNetworks(&list); EXPECT_EQ(1U, list.size()); EXPECT_TRUE(SameNameAndPrefix(ipv4_network1, *list[0])); Network* net1 = list[0]; uint16_t net_id1 = net1->id(); EXPECT_EQ(1, net_id1); list.clear(); // Replace ipv4_network1 with ipv4_network2. list.push_back(new Network(ipv4_network2)); stats = MergeNetworkList(manager, list, &changed); EXPECT_TRUE(changed); EXPECT_EQ(stats.ipv6_network_count, 0); EXPECT_EQ(stats.ipv4_network_count, 1); list.clear(); manager.GetNetworks(&list); EXPECT_EQ(1U, list.size()); EXPECT_TRUE(SameNameAndPrefix(ipv4_network2, *list[0])); Network* net2 = list[0]; uint16_t net_id2 = net2->id(); // Network id will increase. EXPECT_LT(net_id1, net_id2); list.clear(); // Add Network2 back. list.push_back(new Network(ipv4_network1)); list.push_back(new Network(ipv4_network2)); stats = MergeNetworkList(manager, list, &changed); EXPECT_TRUE(changed); EXPECT_EQ(stats.ipv6_network_count, 0); EXPECT_EQ(stats.ipv4_network_count, 2); list.clear(); // Verify that we get previous instances of Network objects. manager.GetNetworks(&list); EXPECT_EQ(2U, list.size()); EXPECT_TRUE((net1 == list[0] && net2 == list[1]) || (net1 == list[1] && net2 == list[0])); EXPECT_TRUE((net_id1 == list[0]->id() && net_id2 == list[1]->id()) || (net_id1 == list[1]->id() && net_id2 == list[0]->id())); list.clear(); // Call MergeNetworkList() again and verify that we don't get update // notification. list.push_back(new Network(ipv4_network2)); list.push_back(new Network(ipv4_network1)); stats = MergeNetworkList(manager, list, &changed); EXPECT_FALSE(changed); EXPECT_EQ(stats.ipv6_network_count, 0); EXPECT_EQ(stats.ipv4_network_count, 2); list.clear(); // Verify that we get previous instances of Network objects. manager.GetNetworks(&list); EXPECT_EQ(2U, list.size()); EXPECT_TRUE((net1 == list[0] && net2 == list[1]) || (net1 == list[1] && net2 == list[0])); EXPECT_TRUE((net_id1 == list[0]->id() && net_id2 == list[1]->id()) || (net_id1 == list[1]->id() && net_id2 == list[0]->id())); list.clear(); } // Sets up some test IPv6 networks and appends them to list. // Four networks are added - public and link local, for two interfaces. void SetupNetworks(NetworkManager::NetworkList* list) { IPAddress ip; IPAddress prefix; EXPECT_TRUE(IPFromString("abcd::1234:5678:abcd:ef12", &ip)); EXPECT_TRUE(IPFromString("abcd::", &prefix)); // First, fake link-locals. Network ipv6_eth0_linklocalnetwork("test_eth0", "Test NetworkAdapter 1", prefix, 64); ipv6_eth0_linklocalnetwork.AddIP(ip); EXPECT_TRUE(IPFromString("abcd::5678:abcd:ef12:3456", &ip)); Network ipv6_eth1_linklocalnetwork("test_eth1", "Test NetworkAdapter 2", prefix, 64); ipv6_eth1_linklocalnetwork.AddIP(ip); // Public networks: EXPECT_TRUE(IPFromString("2401:fa00:4:1000:be30:5bff:fee5:c3", &ip)); prefix = TruncateIP(ip, 64); Network ipv6_eth0_publicnetwork1_ip1("test_eth0", "Test NetworkAdapter 1", prefix, 64); ipv6_eth0_publicnetwork1_ip1.AddIP(ip); EXPECT_TRUE(IPFromString("2400:4030:1:2c00:be30:abcd:efab:cdef", &ip)); prefix = TruncateIP(ip, 64); Network ipv6_eth1_publicnetwork1_ip1("test_eth1", "Test NetworkAdapter 1", prefix, 64); ipv6_eth1_publicnetwork1_ip1.AddIP(ip); list->push_back(new Network(ipv6_eth0_linklocalnetwork)); list->push_back(new Network(ipv6_eth1_linklocalnetwork)); list->push_back(new Network(ipv6_eth0_publicnetwork1_ip1)); list->push_back(new Network(ipv6_eth1_publicnetwork1_ip1)); } // Test that the basic network merging case works. TEST_F(NetworkTest, TestIPv6MergeNetworkList) { BasicNetworkManager manager; manager.SignalNetworksChanged.connect(static_cast(this), &NetworkTest::OnNetworksChanged); NetworkManager::NetworkList original_list; SetupNetworks(&original_list); bool changed = false; NetworkManager::Stats stats = MergeNetworkList(manager, original_list, &changed); EXPECT_TRUE(changed); EXPECT_EQ(stats.ipv6_network_count, 4); EXPECT_EQ(stats.ipv4_network_count, 0); NetworkManager::NetworkList list; manager.GetNetworks(&list); // Verify that the original members are in the merged list. EXPECT_THAT(list, UnorderedElementsAreArray(original_list)); } // Tests that when two network lists that describe the same set of networks are // merged, that the changed callback is not called, and that the original // objects remain in the result list. TEST_F(NetworkTest, TestNoChangeMerge) { BasicNetworkManager manager; manager.SignalNetworksChanged.connect(static_cast(this), &NetworkTest::OnNetworksChanged); NetworkManager::NetworkList original_list; SetupNetworks(&original_list); bool changed = false; MergeNetworkList(manager, original_list, &changed); EXPECT_TRUE(changed); // Second list that describes the same networks but with new objects. NetworkManager::NetworkList second_list; SetupNetworks(&second_list); changed = false; MergeNetworkList(manager, second_list, &changed); EXPECT_FALSE(changed); NetworkManager::NetworkList resulting_list; manager.GetNetworks(&resulting_list); // Verify that the original members are in the merged list. EXPECT_THAT(resulting_list, UnorderedElementsAreArray(original_list)); // Doublecheck that the new networks aren't in the list. for (const Network* network : second_list) { EXPECT_THAT(resulting_list, Not(Contains(network))); } } // Test that we can merge a network that is the same as another network but with // a different IP. The original network should remain in the list, but have its // IP changed. TEST_F(NetworkTest, MergeWithChangedIP) { BasicNetworkManager manager; manager.SignalNetworksChanged.connect(static_cast(this), &NetworkTest::OnNetworksChanged); NetworkManager::NetworkList original_list; SetupNetworks(&original_list); // Make a network that we're going to change. IPAddress ip; EXPECT_TRUE(IPFromString("2401:fa01:4:1000:be30:faa:fee:faa", &ip)); IPAddress prefix = TruncateIP(ip, 64); Network* network_to_change = new Network("test_eth0", "Test Network Adapter 1", prefix, 64); Network* changed_network = new Network(*network_to_change); network_to_change->AddIP(ip); IPAddress changed_ip; EXPECT_TRUE(IPFromString("2401:fa01:4:1000:be30:f00:f00:f00", &changed_ip)); changed_network->AddIP(changed_ip); original_list.push_back(network_to_change); bool changed = false; MergeNetworkList(manager, original_list, &changed); NetworkManager::NetworkList second_list; SetupNetworks(&second_list); second_list.push_back(changed_network); changed = false; MergeNetworkList(manager, second_list, &changed); EXPECT_TRUE(changed); NetworkManager::NetworkList list; manager.GetNetworks(&list); EXPECT_EQ(original_list.size(), list.size()); // Make sure the original network is still in the merged list. EXPECT_THAT(list, Contains(network_to_change)); EXPECT_EQ(changed_ip, network_to_change->GetIPs().at(0)); } // Testing a similar case to above, but checking that a network can be updated // with additional IPs (not just a replacement). TEST_F(NetworkTest, TestMultipleIPMergeNetworkList) { BasicNetworkManager manager; manager.SignalNetworksChanged.connect(static_cast(this), &NetworkTest::OnNetworksChanged); NetworkManager::NetworkList original_list; SetupNetworks(&original_list); bool changed = false; MergeNetworkList(manager, original_list, &changed); EXPECT_TRUE(changed); IPAddress ip; IPAddress check_ip; IPAddress prefix; // Add a second IP to the public network on eth0 (2401:fa00:4:1000/64). EXPECT_TRUE(IPFromString("2401:fa00:4:1000:be30:5bff:fee5:c6", &ip)); prefix = TruncateIP(ip, 64); Network ipv6_eth0_publicnetwork1_ip2("test_eth0", "Test NetworkAdapter 1", prefix, 64); // This is the IP that already existed in the public network on eth0. EXPECT_TRUE(IPFromString("2401:fa00:4:1000:be30:5bff:fee5:c3", &check_ip)); ipv6_eth0_publicnetwork1_ip2.AddIP(ip); original_list.push_back(new Network(ipv6_eth0_publicnetwork1_ip2)); changed = false; MergeNetworkList(manager, original_list, &changed); EXPECT_TRUE(changed); // There should still be four networks. NetworkManager::NetworkList list; manager.GetNetworks(&list); EXPECT_EQ(4U, list.size()); // Check the gathered IPs. int matchcount = 0; for (NetworkManager::NetworkList::iterator it = list.begin(); it != list.end(); ++it) { if (SameNameAndPrefix(**it, *original_list[2])) { ++matchcount; EXPECT_EQ(1, matchcount); // This should be the same network object as before. EXPECT_EQ((*it), original_list[2]); // But with two addresses now. EXPECT_THAT((*it)->GetIPs(), UnorderedElementsAre(InterfaceAddress(check_ip), InterfaceAddress(ip))); } else { // Check the IP didn't get added anywhere it wasn't supposed to. EXPECT_THAT((*it)->GetIPs(), Not(Contains(InterfaceAddress(ip)))); } } } // Test that merge correctly distinguishes multiple networks on an interface. TEST_F(NetworkTest, TestMultiplePublicNetworksOnOneInterfaceMerge) { BasicNetworkManager manager; manager.SignalNetworksChanged.connect(static_cast(this), &NetworkTest::OnNetworksChanged); NetworkManager::NetworkList original_list; SetupNetworks(&original_list); bool changed = false; MergeNetworkList(manager, original_list, &changed); EXPECT_TRUE(changed); IPAddress ip; IPAddress prefix; // A second network for eth0. EXPECT_TRUE(IPFromString("2400:4030:1:2c00:be30:5bff:fee5:c3", &ip)); prefix = TruncateIP(ip, 64); Network ipv6_eth0_publicnetwork2_ip1("test_eth0", "Test NetworkAdapter 1", prefix, 64); ipv6_eth0_publicnetwork2_ip1.AddIP(ip); original_list.push_back(new Network(ipv6_eth0_publicnetwork2_ip1)); changed = false; MergeNetworkList(manager, original_list, &changed); EXPECT_TRUE(changed); // There should be five networks now. NetworkManager::NetworkList list; manager.GetNetworks(&list); EXPECT_EQ(5U, list.size()); // Check the resulting addresses. for (NetworkManager::NetworkList::iterator it = list.begin(); it != list.end(); ++it) { if ((*it)->prefix() == ipv6_eth0_publicnetwork2_ip1.prefix() && (*it)->name() == ipv6_eth0_publicnetwork2_ip1.name()) { // Check the new network has 1 IP and that it's the correct one. EXPECT_EQ(1U, (*it)->GetIPs().size()); EXPECT_EQ(ip, (*it)->GetIPs().at(0)); } else { // Check the IP didn't get added anywhere it wasn't supposed to. EXPECT_THAT((*it)->GetIPs(), Not(Contains(InterfaceAddress(ip)))); } } } // Test that DumpNetworks does not crash. TEST_F(NetworkTest, TestCreateAndDumpNetworks) { BasicNetworkManager manager; manager.StartUpdating(); NetworkManager::NetworkList list = GetNetworks(manager, true); bool changed; MergeNetworkList(manager, list, &changed); manager.DumpNetworks(); } TEST_F(NetworkTest, TestIPv6Toggle) { BasicNetworkManager manager; manager.StartUpdating(); bool ipv6_found = false; NetworkManager::NetworkList list; list = GetNetworks(manager, true); for (NetworkManager::NetworkList::iterator it = list.begin(); it != list.end(); ++it) { if ((*it)->prefix().family() == AF_INET6) { ipv6_found = true; break; } } EXPECT_TRUE(ipv6_found); for (NetworkManager::NetworkList::iterator it = list.begin(); it != list.end(); ++it) { delete (*it); } } // Test that when network interfaces are sorted and given preference values, // IPv6 comes first. TEST_F(NetworkTest, IPv6NetworksPreferredOverIPv4) { BasicNetworkManager manager; Network ipv4_network1("test_eth0", "Test Network Adapter 1", IPAddress(0x12345600U), 24); ipv4_network1.AddIP(IPAddress(0x12345600U)); IPAddress ip; IPAddress prefix; EXPECT_TRUE(IPFromString("2400:4030:1:2c00:be30:abcd:efab:cdef", &ip)); prefix = TruncateIP(ip, 64); Network ipv6_eth1_publicnetwork1_ip1("test_eth1", "Test NetworkAdapter 2", prefix, 64); ipv6_eth1_publicnetwork1_ip1.AddIP(ip); NetworkManager::NetworkList list; list.push_back(new Network(ipv4_network1)); list.push_back(new Network(ipv6_eth1_publicnetwork1_ip1)); Network* net1 = list[0]; Network* net2 = list[1]; bool changed = false; MergeNetworkList(manager, list, &changed); ASSERT_TRUE(changed); // After sorting IPv6 network should be higher order than IPv4 networks. EXPECT_TRUE(net1->preference() < net2->preference()); } // When two interfaces are equivalent in everything but name, they're expected // to be preference-ordered by name. For example, "eth0" before "eth1". TEST_F(NetworkTest, NetworksSortedByInterfaceName) { BasicNetworkManager manager; Network* eth0 = new Network("test_eth0", "Test Network Adapter 1", IPAddress(0x65432100U), 24); eth0->AddIP(IPAddress(0x65432100U)); Network* eth1 = new Network("test_eth1", "Test Network Adapter 2", IPAddress(0x12345600U), 24); eth1->AddIP(IPAddress(0x12345600U)); NetworkManager::NetworkList list; // Add them to the list in the opposite of the expected sorted order, to // ensure sorting actually occurs. list.push_back(eth1); list.push_back(eth0); bool changed = false; MergeNetworkList(manager, list, &changed); ASSERT_TRUE(changed); // "test_eth0" should be preferred over "test_eth1". EXPECT_TRUE(eth0->preference() > eth1->preference()); } TEST_F(NetworkTest, TestNetworkAdapterTypes) { Network wifi("wlan0", "Wireless Adapter", IPAddress(0x12345600U), 24, ADAPTER_TYPE_WIFI); EXPECT_EQ(ADAPTER_TYPE_WIFI, wifi.type()); Network ethernet("eth0", "Ethernet", IPAddress(0x12345600U), 24, ADAPTER_TYPE_ETHERNET); EXPECT_EQ(ADAPTER_TYPE_ETHERNET, ethernet.type()); Network cellular("test_cell", "Cellular Adapter", IPAddress(0x12345600U), 24, ADAPTER_TYPE_CELLULAR); EXPECT_EQ(ADAPTER_TYPE_CELLULAR, cellular.type()); Network vpn("bridge_test", "VPN Adapter", IPAddress(0x12345600U), 24, ADAPTER_TYPE_VPN); EXPECT_EQ(ADAPTER_TYPE_VPN, vpn.type()); Network unknown("test", "Test Adapter", IPAddress(0x12345600U), 24, ADAPTER_TYPE_UNKNOWN); EXPECT_EQ(ADAPTER_TYPE_UNKNOWN, unknown.type()); } #if defined(WEBRTC_POSIX) // Verify that we correctly handle interfaces with no address. TEST_F(NetworkTest, TestConvertIfAddrsNoAddress) { ifaddrs list; memset(&list, 0, sizeof(list)); list.ifa_name = const_cast("test_iface"); NetworkManager::NetworkList result; BasicNetworkManager manager; manager.StartUpdating(); CallConvertIfAddrs(manager, &list, true, &result); EXPECT_TRUE(result.empty()); } // Verify that if there are two addresses on one interface, only one network // is generated. TEST_F(NetworkTest, TestConvertIfAddrsMultiAddressesOnOneInterface) { char if_name[20] = "rmnet0"; ifaddrs* list = nullptr; list = AddIpv6Address(list, if_name, "1000:2000:3000:4000:0:0:0:1", "FFFF:FFFF:FFFF:FFFF::", 0); list = AddIpv6Address(list, if_name, "1000:2000:3000:4000:0:0:0:2", "FFFF:FFFF:FFFF:FFFF::", 0); NetworkManager::NetworkList result; BasicNetworkManager manager; manager.StartUpdating(); CallConvertIfAddrs(manager, list, true, &result); EXPECT_EQ(1U, result.size()); bool changed; // This ensures we release the objects created in CallConvertIfAddrs. MergeNetworkList(manager, result, &changed); ReleaseIfAddrs(list); } TEST_F(NetworkTest, TestConvertIfAddrsNotRunning) { ifaddrs list; memset(&list, 0, sizeof(list)); list.ifa_name = const_cast("test_iface"); sockaddr ifa_addr; sockaddr ifa_netmask; list.ifa_addr = &ifa_addr; list.ifa_netmask = &ifa_netmask; NetworkManager::NetworkList result; BasicNetworkManager manager; manager.StartUpdating(); CallConvertIfAddrs(manager, &list, true, &result); EXPECT_TRUE(result.empty()); } // Tests that the network type can be determined from the network monitor when // it would otherwise be unknown. TEST_F(NetworkTest, TestGetAdapterTypeFromNetworkMonitor) { char if_name[20] = "wifi0"; std::string ipv6_address = "1000:2000:3000:4000:0:0:0:1"; std::string ipv6_mask = "FFFF:FFFF:FFFF:FFFF::"; BasicNetworkManager manager_without_monitor; manager_without_monitor.StartUpdating(); // A network created without a network monitor will get UNKNOWN type. ifaddrs* addr_list = InstallIpv6Network(if_name, ipv6_address, ipv6_mask, manager_without_monitor); EXPECT_EQ(ADAPTER_TYPE_UNKNOWN, GetAdapterType(manager_without_monitor)); ReleaseIfAddrs(addr_list); // With the fake network monitor the type should be correctly determined. FakeNetworkMonitorFactory factory; BasicNetworkManager manager_with_monitor(&factory); manager_with_monitor.StartUpdating(); // Add the same ipv6 address as before but it has the right network type // detected by the network monitor now. addr_list = InstallIpv6Network(if_name, ipv6_address, ipv6_mask, manager_with_monitor); EXPECT_EQ(ADAPTER_TYPE_WIFI, GetAdapterType(manager_with_monitor)); ReleaseIfAddrs(addr_list); } // Test that the network type can be determined based on name matching in // a few cases. Note that UNKNOWN type for non-matching strings has been tested // in the above test. TEST_F(NetworkTest, TestGetAdapterTypeFromNameMatching) { std::string ipv4_address1 = "192.0.0.121"; std::string ipv4_mask = "255.255.255.0"; std::string ipv6_address1 = "1000:2000:3000:4000:0:0:0:1"; std::string ipv6_address2 = "1000:2000:3000:8000:0:0:0:1"; std::string ipv6_mask = "FFFF:FFFF:FFFF:FFFF::"; BasicNetworkManager manager; manager.StartUpdating(); // IPSec interface; name is in form "ipsec". char if_name[20] = "ipsec11"; ifaddrs* addr_list = InstallIpv6Network(if_name, ipv6_address1, ipv6_mask, manager); EXPECT_EQ(ADAPTER_TYPE_VPN, GetAdapterType(manager)); ClearNetworks(manager); ReleaseIfAddrs(addr_list); strcpy(if_name, "lo0"); addr_list = InstallIpv6Network(if_name, ipv6_address1, ipv6_mask, manager); EXPECT_EQ(ADAPTER_TYPE_LOOPBACK, GetAdapterType(manager)); ClearNetworks(manager); ReleaseIfAddrs(addr_list); strcpy(if_name, "eth0"); addr_list = InstallIpv4Network(if_name, ipv4_address1, ipv4_mask, manager); EXPECT_EQ(ADAPTER_TYPE_ETHERNET, GetAdapterType(manager)); ClearNetworks(manager); ReleaseIfAddrs(addr_list); strcpy(if_name, "wlan0"); addr_list = InstallIpv6Network(if_name, ipv6_address1, ipv6_mask, manager); EXPECT_EQ(ADAPTER_TYPE_WIFI, GetAdapterType(manager)); ClearNetworks(manager); ReleaseIfAddrs(addr_list); #if defined(WEBRTC_IOS) strcpy(if_name, "pdp_ip0"); addr_list = InstallIpv6Network(if_name, ipv6_address1, ipv6_mask, manager); EXPECT_EQ(ADAPTER_TYPE_CELLULAR, GetAdapterType(manager)); ClearNetworks(manager); ReleaseIfAddrs(addr_list); strcpy(if_name, "en0"); addr_list = InstallIpv6Network(if_name, ipv6_address1, ipv6_mask, manager); EXPECT_EQ(ADAPTER_TYPE_WIFI, GetAdapterType(manager)); ClearNetworks(manager); ReleaseIfAddrs(addr_list); #elif defined(WEBRTC_ANDROID) strcpy(if_name, "rmnet0"); addr_list = InstallIpv6Network(if_name, ipv6_address1, ipv6_mask, manager); EXPECT_EQ(ADAPTER_TYPE_CELLULAR, GetAdapterType(manager)); ClearNetworks(manager); ReleaseIfAddrs(addr_list); strcpy(if_name, "v4-rmnet_data0"); addr_list = InstallIpv6Network(if_name, ipv6_address2, ipv6_mask, manager); EXPECT_EQ(ADAPTER_TYPE_CELLULAR, GetAdapterType(manager)); ClearNetworks(manager); ReleaseIfAddrs(addr_list); strcpy(if_name, "clat4"); addr_list = InstallIpv4Network(if_name, ipv4_address1, ipv4_mask, manager); EXPECT_EQ(ADAPTER_TYPE_CELLULAR, GetAdapterType(manager)); ClearNetworks(manager); ReleaseIfAddrs(addr_list); #endif } #endif // defined(WEBRTC_POSIX) // Test MergeNetworkList successfully combines all IPs for the same // prefix/length into a single Network. TEST_F(NetworkTest, TestMergeNetworkList) { BasicNetworkManager manager; NetworkManager::NetworkList list; // Create 2 IPAddress classes with only last digit different. IPAddress ip1, ip2; EXPECT_TRUE(IPFromString("2400:4030:1:2c00:be30:0:0:1", &ip1)); EXPECT_TRUE(IPFromString("2400:4030:1:2c00:be30:0:0:2", &ip2)); // Create 2 networks with the same prefix and length. Network* net1 = new Network("em1", "em1", TruncateIP(ip1, 64), 64); Network* net2 = new Network("em1", "em1", TruncateIP(ip1, 64), 64); // Add different IP into each. net1->AddIP(ip1); net2->AddIP(ip2); list.push_back(net1); list.push_back(net2); bool changed; MergeNetworkList(manager, list, &changed); EXPECT_TRUE(changed); NetworkManager::NetworkList list2; manager.GetNetworks(&list2); // Make sure the resulted networklist has only 1 element and 2 // IPAddresses. EXPECT_EQ(list2.size(), 1uL); EXPECT_EQ(list2[0]->GetIPs().size(), 2uL); EXPECT_EQ(list2[0]->GetIPs()[0], InterfaceAddress(ip1)); EXPECT_EQ(list2[0]->GetIPs()[1], InterfaceAddress(ip2)); } // Test that MergeNetworkList successfully detects the change if // a network becomes inactive and then active again. TEST_F(NetworkTest, TestMergeNetworkListWithInactiveNetworks) { BasicNetworkManager manager; Network network1("test_wifi", "Test Network Adapter 1", IPAddress(0x12345600U), 24); Network network2("test_eth0", "Test Network Adapter 2", IPAddress(0x00010000U), 16); network1.AddIP(IPAddress(0x12345678)); network2.AddIP(IPAddress(0x00010004)); NetworkManager::NetworkList list; Network* net1 = new Network(network1); list.push_back(net1); bool changed; MergeNetworkList(manager, list, &changed); EXPECT_TRUE(changed); list.clear(); manager.GetNetworks(&list); ASSERT_EQ(1U, list.size()); EXPECT_EQ(net1, list[0]); list.clear(); Network* net2 = new Network(network2); list.push_back(net2); MergeNetworkList(manager, list, &changed); EXPECT_TRUE(changed); list.clear(); manager.GetNetworks(&list); ASSERT_EQ(1U, list.size()); EXPECT_EQ(net2, list[0]); // Now network1 is inactive. Try to merge it again. list.clear(); list.push_back(new Network(network1)); MergeNetworkList(manager, list, &changed); EXPECT_TRUE(changed); list.clear(); manager.GetNetworks(&list); ASSERT_EQ(1U, list.size()); EXPECT_TRUE(list[0]->active()); EXPECT_EQ(net1, list[0]); } // Test that the filtering logic follows the defined ruleset in network.h. TEST_F(NetworkTest, TestIPv6Selection) { InterfaceAddress ip; std::string ipstr; ipstr = "2401:fa00:4:1000:be30:5bff:fee5:c3"; ASSERT_TRUE(IPFromString(ipstr, IPV6_ADDRESS_FLAG_DEPRECATED, &ip)); // Create a network with this prefix. Network ipv6_network("test_eth0", "Test NetworkAdapter", TruncateIP(ip, 64), 64); // When there is no address added, it should return an unspecified // address. EXPECT_EQ(ipv6_network.GetBestIP(), IPAddress()); EXPECT_TRUE(IPIsUnspec(ipv6_network.GetBestIP())); // Deprecated one should not be returned. ipv6_network.AddIP(ip); EXPECT_EQ(ipv6_network.GetBestIP(), IPAddress()); // Add ULA one. ULA is unique local address which is starting either // with 0xfc or 0xfd. ipstr = "fd00:fa00:4:1000:be30:5bff:fee5:c4"; ASSERT_TRUE(IPFromString(ipstr, IPV6_ADDRESS_FLAG_NONE, &ip)); ipv6_network.AddIP(ip); EXPECT_EQ(ipv6_network.GetBestIP(), static_cast(ip)); // Add global one. ipstr = "2401:fa00:4:1000:be30:5bff:fee5:c5"; ASSERT_TRUE(IPFromString(ipstr, IPV6_ADDRESS_FLAG_NONE, &ip)); ipv6_network.AddIP(ip); EXPECT_EQ(ipv6_network.GetBestIP(), static_cast(ip)); // Add global dynamic temporary one. ipstr = "2401:fa00:4:1000:be30:5bff:fee5:c6"; ASSERT_TRUE(IPFromString(ipstr, IPV6_ADDRESS_FLAG_TEMPORARY, &ip)); ipv6_network.AddIP(ip); EXPECT_EQ(ipv6_network.GetBestIP(), static_cast(ip)); } TEST_F(NetworkTest, TestNetworkMonitoring) { FakeNetworkMonitorFactory factory; BasicNetworkManager manager(&factory); manager.SignalNetworksChanged.connect(static_cast(this), &NetworkTest::OnNetworksChanged); manager.StartUpdating(); FakeNetworkMonitor* network_monitor = GetNetworkMonitor(manager); EXPECT_TRUE(network_monitor && network_monitor->started()); EXPECT_TRUE_WAIT(callback_called_, 1000); callback_called_ = false; // Clear the networks so that there will be network changes below. ClearNetworks(manager); // Network manager is started, so the callback is called when the network // monitor fires the network-change event. network_monitor->OnNetworksChanged(); EXPECT_TRUE_WAIT(callback_called_, 1000); // Network manager is stopped. manager.StopUpdating(); EXPECT_FALSE(GetNetworkMonitor(manager)->started()); } // Fails on Android: https://bugs.chromium.org/p/webrtc/issues/detail?id=4364. #if defined(WEBRTC_ANDROID) #define MAYBE_DefaultLocalAddress DISABLED_DefaultLocalAddress #else #define MAYBE_DefaultLocalAddress DefaultLocalAddress #endif TEST_F(NetworkTest, MAYBE_DefaultLocalAddress) { IPAddress ip; FakeNetworkMonitorFactory factory; TestBasicNetworkManager manager(&factory); manager.SignalNetworksChanged.connect(static_cast(this), &NetworkTest::OnNetworksChanged); manager.StartUpdating(); EXPECT_TRUE_WAIT(callback_called_, 1000); // Make sure we can query default local address when an address for such // address family exists. std::vector networks; manager.GetNetworks(&networks); EXPECT_TRUE(!networks.empty()); for (const auto* network : networks) { if (network->GetBestIP().family() == AF_INET) { EXPECT_TRUE(QueryDefaultLocalAddress(manager, AF_INET) != IPAddress()); } else if (network->GetBestIP().family() == AF_INET6 && !IPIsLoopback(network->GetBestIP())) { // Existence of an IPv6 loopback address doesn't mean it has IPv6 network // enabled. EXPECT_TRUE(QueryDefaultLocalAddress(manager, AF_INET6) != IPAddress()); } } // GetDefaultLocalAddress should return the valid default address after set. manager.set_default_local_addresses(GetLoopbackIP(AF_INET), GetLoopbackIP(AF_INET6)); EXPECT_TRUE(manager.GetDefaultLocalAddress(AF_INET, &ip)); EXPECT_EQ(ip, GetLoopbackIP(AF_INET)); EXPECT_TRUE(manager.GetDefaultLocalAddress(AF_INET6, &ip)); EXPECT_EQ(ip, GetLoopbackIP(AF_INET6)); // More tests on GetDefaultLocalAddress with ipv6 addresses where the set // default address may be different from the best IP address of any network. InterfaceAddress ip1; EXPECT_TRUE(IPFromString("abcd::1234:5678:abcd:1111", IPV6_ADDRESS_FLAG_TEMPORARY, &ip1)); // Create a network with a prefix of ip1. Network ipv6_network("test_eth0", "Test NetworkAdapter", TruncateIP(ip1, 64), 64); IPAddress ip2; EXPECT_TRUE(IPFromString("abcd::1234:5678:abcd:2222", &ip2)); ipv6_network.AddIP(ip1); ipv6_network.AddIP(ip2); BasicNetworkManager::NetworkList list(1, new Network(ipv6_network)); bool changed; MergeNetworkList(manager, list, &changed); // If the set default address is not in any network, GetDefaultLocalAddress // should return it. IPAddress ip3; EXPECT_TRUE(IPFromString("abcd::1234:5678:abcd:3333", &ip3)); manager.set_default_local_addresses(GetLoopbackIP(AF_INET), ip3); EXPECT_TRUE(manager.GetDefaultLocalAddress(AF_INET6, &ip)); EXPECT_EQ(ip3, ip); // If the set default address is in a network, GetDefaultLocalAddress will // return the best IP in that network. manager.set_default_local_addresses(GetLoopbackIP(AF_INET), ip2); EXPECT_TRUE(manager.GetDefaultLocalAddress(AF_INET6, &ip)); EXPECT_EQ(static_cast(ip1), ip); manager.StopUpdating(); } // Test that MergeNetworkList does not set change = true // when changing from cellular_X to cellular_Y. TEST_F(NetworkTest, TestWhenNetworkListChangeReturnsChangedFlag) { BasicNetworkManager manager; IPAddress ip1; EXPECT_TRUE(IPFromString("2400:4030:1:2c00:be30:0:0:1", &ip1)); Network* net1 = new Network("em1", "em1", TruncateIP(ip1, 64), 64); net1->set_type(ADAPTER_TYPE_CELLULAR_3G); net1->AddIP(ip1); NetworkManager::NetworkList list; list.push_back(net1); { bool changed; MergeNetworkList(manager, list, &changed); EXPECT_TRUE(changed); NetworkManager::NetworkList list2; manager.GetNetworks(&list2); EXPECT_EQ(list2.size(), 1uL); EXPECT_EQ(ADAPTER_TYPE_CELLULAR_3G, list2[0]->type()); } // Modify net1 from 3G to 4G { Network* net2 = new Network("em1", "em1", TruncateIP(ip1, 64), 64); net2->set_type(ADAPTER_TYPE_CELLULAR_4G); net2->AddIP(ip1); list.clear(); list.push_back(net2); bool changed; MergeNetworkList(manager, list, &changed); // Change from 3G to 4G shall not trigger OnNetworksChanged, // i.e changed = false. EXPECT_FALSE(changed); NetworkManager::NetworkList list2; manager.GetNetworks(&list2); ASSERT_EQ(list2.size(), 1uL); EXPECT_EQ(ADAPTER_TYPE_CELLULAR_4G, list2[0]->type()); } // Don't modify. { Network* net2 = new Network("em1", "em1", TruncateIP(ip1, 64), 64); net2->set_type(ADAPTER_TYPE_CELLULAR_4G); net2->AddIP(ip1); list.clear(); list.push_back(net2); bool changed; MergeNetworkList(manager, list, &changed); // No change. EXPECT_FALSE(changed); NetworkManager::NetworkList list2; manager.GetNetworks(&list2); ASSERT_EQ(list2.size(), 1uL); EXPECT_EQ(ADAPTER_TYPE_CELLULAR_4G, list2[0]->type()); } } } // namespace rtc