|  | // Copyright (c) 2019 The Chromium Authors. All rights reserved. | 
|  | // Use of this source code is governed by a BSD-style license that can be | 
|  | // found in the LICENSE file. | 
|  |  | 
|  | #include "net/third_party/quiche/src/quic/platform/api/quic_socket_address.h" | 
|  |  | 
|  | #include <memory> | 
|  | #include <sstream> | 
|  |  | 
|  | #include "net/third_party/quiche/src/quic/platform/api/quic_test.h" | 
|  |  | 
|  | namespace quic { | 
|  | namespace { | 
|  |  | 
|  | TEST(QuicSocketAddress, Uninitialized) { | 
|  | QuicSocketAddress uninitialized; | 
|  | EXPECT_FALSE(uninitialized.IsInitialized()); | 
|  | } | 
|  |  | 
|  | TEST(QuicSocketAddress, ExplicitConstruction) { | 
|  | QuicSocketAddress ipv4_address(QuicIpAddress::Loopback4(), 443); | 
|  | QuicSocketAddress ipv6_address(QuicIpAddress::Loopback6(), 443); | 
|  | EXPECT_TRUE(ipv4_address.IsInitialized()); | 
|  | EXPECT_EQ("127.0.0.1:443", ipv4_address.ToString()); | 
|  | EXPECT_EQ("[::1]:443", ipv6_address.ToString()); | 
|  | EXPECT_EQ(QuicIpAddress::Loopback4(), ipv4_address.host()); | 
|  | EXPECT_EQ(QuicIpAddress::Loopback6(), ipv6_address.host()); | 
|  | EXPECT_EQ(443, ipv4_address.port()); | 
|  | } | 
|  |  | 
|  | TEST(QuicSocketAddress, OutputToStream) { | 
|  | QuicSocketAddress ipv4_address(QuicIpAddress::Loopback4(), 443); | 
|  | std::stringstream stream; | 
|  | stream << ipv4_address; | 
|  | EXPECT_EQ("127.0.0.1:443", stream.str()); | 
|  | } | 
|  |  | 
|  | TEST(QuicSocketAddress, FromSockaddrIPv4) { | 
|  | union { | 
|  | sockaddr_storage storage; | 
|  | sockaddr addr; | 
|  | sockaddr_in v4; | 
|  | } address; | 
|  |  | 
|  | memset(&address, 0, sizeof(address)); | 
|  | address.v4.sin_family = AF_INET; | 
|  | address.v4.sin_addr = QuicIpAddress::Loopback4().GetIPv4(); | 
|  | address.v4.sin_port = htons(443); | 
|  | EXPECT_EQ("127.0.0.1:443", | 
|  | QuicSocketAddress(&address.addr, sizeof(address.v4)).ToString()); | 
|  | EXPECT_EQ("127.0.0.1:443", QuicSocketAddress(address.storage).ToString()); | 
|  | } | 
|  |  | 
|  | TEST(QuicSocketAddress, FromSockaddrIPv6) { | 
|  | union { | 
|  | sockaddr_storage storage; | 
|  | sockaddr addr; | 
|  | sockaddr_in6 v6; | 
|  | } address; | 
|  |  | 
|  | memset(&address, 0, sizeof(address)); | 
|  | address.v6.sin6_family = AF_INET6; | 
|  | address.v6.sin6_addr = QuicIpAddress::Loopback6().GetIPv6(); | 
|  | address.v6.sin6_port = htons(443); | 
|  | EXPECT_EQ("[::1]:443", | 
|  | QuicSocketAddress(&address.addr, sizeof(address.v6)).ToString()); | 
|  | EXPECT_EQ("[::1]:443", QuicSocketAddress(address.storage).ToString()); | 
|  | } | 
|  |  | 
|  | TEST(QuicSocketAddres, ToSockaddrIPv4) { | 
|  | union { | 
|  | sockaddr_storage storage; | 
|  | sockaddr_in v4; | 
|  | } address; | 
|  |  | 
|  | address.storage = | 
|  | QuicSocketAddress(QuicIpAddress::Loopback4(), 443).generic_address(); | 
|  | ASSERT_EQ(AF_INET, address.v4.sin_family); | 
|  | EXPECT_EQ(QuicIpAddress::Loopback4(), QuicIpAddress(address.v4.sin_addr)); | 
|  | EXPECT_EQ(htons(443), address.v4.sin_port); | 
|  | } | 
|  |  | 
|  | TEST(QuicSocketAddress, Normalize) { | 
|  | QuicIpAddress dual_stacked; | 
|  | ASSERT_TRUE(dual_stacked.FromString("::ffff:127.0.0.1")); | 
|  | ASSERT_TRUE(dual_stacked.IsIPv6()); | 
|  | QuicSocketAddress not_normalized(dual_stacked, 443); | 
|  | QuicSocketAddress normalized = not_normalized.Normalized(); | 
|  | EXPECT_EQ("[::ffff:127.0.0.1]:443", not_normalized.ToString()); | 
|  | EXPECT_EQ("127.0.0.1:443", normalized.ToString()); | 
|  | } | 
|  |  | 
|  | // TODO(vasilvv): either ensure this works on all platforms, or deprecate and | 
|  | // remove this API. | 
|  | #if defined(__linux__) && !defined(ANDROID) | 
|  | #include <errno.h> | 
|  | #include <sys/socket.h> | 
|  | #include <sys/types.h> | 
|  |  | 
|  | TEST(QuicSocketAddress, FromSocket) { | 
|  | int fd; | 
|  | QuicSocketAddress address; | 
|  | bool bound = false; | 
|  | for (int port = 50000; port < 50400; port++) { | 
|  | fd = socket(AF_INET6, SOCK_DGRAM, IPPROTO_UDP); | 
|  | ASSERT_GT(fd, 0); | 
|  |  | 
|  | address = QuicSocketAddress(QuicIpAddress::Loopback6(), port); | 
|  | sockaddr_storage raw_address = address.generic_address(); | 
|  | int bind_result = bind(fd, reinterpret_cast<const sockaddr*>(&raw_address), | 
|  | sizeof(sockaddr_in6)); | 
|  |  | 
|  | if (bind_result < 0 && errno == EADDRINUSE) { | 
|  | close(fd); | 
|  | continue; | 
|  | } | 
|  |  | 
|  | ASSERT_EQ(0, bind_result); | 
|  | bound = true; | 
|  | break; | 
|  | } | 
|  | ASSERT_TRUE(bound); | 
|  |  | 
|  | QuicSocketAddress real_address; | 
|  | ASSERT_EQ(0, real_address.FromSocket(fd)); | 
|  | ASSERT_TRUE(real_address.IsInitialized()); | 
|  | EXPECT_EQ(real_address, address); | 
|  | close(fd); | 
|  | } | 
|  | #endif | 
|  |  | 
|  | }  // namespace | 
|  | }  // namespace quic |