diff options
Diffstat (limited to 'net/socket/transport_client_socket_pool.cc')
-rw-r--r-- | net/socket/transport_client_socket_pool.cc | 68 |
1 files changed, 17 insertions, 51 deletions
diff --git a/net/socket/transport_client_socket_pool.cc b/net/socket/transport_client_socket_pool.cc index a00e810..b2ca683 100644 --- a/net/socket/transport_client_socket_pool.cc +++ b/net/socket/transport_client_socket_pool.cc @@ -4,6 +4,8 @@ #include "net/socket/transport_client_socket_pool.h" +#include <algorithm> + #include "base/compiler_specific.h" #include "base/logging.h" #include "base/message_loop.h" @@ -14,7 +16,6 @@ #include "net/base/ip_endpoint.h" #include "net/base/net_log.h" #include "net/base/net_errors.h" -#include "net/base/sys_addrinfo.h" #include "net/socket/client_socket_factory.h" #include "net/socket/client_socket_handle.h" #include "net/socket/client_socket_pool_base.h" @@ -31,28 +32,14 @@ const int TransportConnectJob::kIPv6FallbackTimerInMs = 300; namespace { -bool AddressListStartsWithIPv6AndHasAnIPv4Addr(const AddressList& addrlist) { - const struct addrinfo* ai = addrlist.head(); - if (ai->ai_family != AF_INET6) - return false; - - ai = ai->ai_next; - while (ai) { - if (ai->ai_family != AF_INET6) - return true; - ai = ai->ai_next; - } - - return false; -} - -bool AddressListOnlyContainsIPv6Addresses(const AddressList& addrlist) { - DCHECK(addrlist.head()); - for (const struct addrinfo* ai = addrlist.head(); ai; ai = ai->ai_next) { - if (ai->ai_family != AF_INET6) +// Returns true iff all addresses in |list| are in the IPv6 family. +bool AddressListOnlyContainsIPv6(const AddressList& list) { + DCHECK(!list.empty()); + for (AddressList::const_iterator iter = list.begin(); iter != list.end(); + ++iter) { + if (iter->GetFamily() != AF_INET6) return false; } - return true; } @@ -123,35 +110,13 @@ LoadState TransportConnectJob::GetLoadState() const { } // static -void TransportConnectJob::MakeAddrListStartWithIPv4(AddressList* addrlist) { - if (addrlist->head()->ai_family != AF_INET6) - return; - bool has_ipv4 = false; - for (const struct addrinfo* ai = addrlist->head(); ai; ai = ai->ai_next) { - if (ai->ai_family != AF_INET6) { - has_ipv4 = true; +void TransportConnectJob::MakeAddressListStartWithIPv4(AddressList* list) { + for (AddressList::iterator i = list->begin(); i != list->end(); ++i) { + if (i->GetFamily() == AF_INET) { + std::rotate(list->begin(), i, list->end()); break; } } - if (!has_ipv4) - return; - - struct addrinfo* head = CreateCopyOfAddrinfo(addrlist->head(), true); - struct addrinfo* tail = head; - while (tail->ai_next) - tail = tail->ai_next; - char* canonname = head->ai_canonname; - head->ai_canonname = NULL; - while (head->ai_family == AF_INET6) { - tail->ai_next = head; - tail = head; - head = head->ai_next; - tail->ai_next = NULL; - } - head->ai_canonname = canonname; - - *addrlist = AddressList::CreateByCopying(head); - FreeCopyOfAddrinfo(head); } void TransportConnectJob::OnIOComplete(int result) { @@ -214,7 +179,8 @@ int TransportConnectJob::DoTransportConnect() { int rv = transport_socket_->Connect( base::Bind(&TransportConnectJob::OnIOComplete, base::Unretained(this))); if (rv == ERR_IO_PENDING && - AddressListStartsWithIPv6AndHasAnIPv4Addr(addresses_)) { + addresses_.front().GetFamily() == AF_INET6 && + !AddressListOnlyContainsIPv6(addresses_)) { fallback_timer_.Start(FROM_HERE, base::TimeDelta::FromMilliseconds(kIPv6FallbackTimerInMs), this, &TransportConnectJob::DoIPv6FallbackTransportConnect); @@ -224,7 +190,7 @@ int TransportConnectJob::DoTransportConnect() { int TransportConnectJob::DoTransportConnectComplete(int result) { if (result == OK) { - bool is_ipv4 = addresses_.head()->ai_family != AF_INET6; + bool is_ipv4 = addresses_.front().GetFamily() != AF_INET6; DCHECK(connect_start_time_ != base::TimeTicks()); DCHECK(start_time_ != base::TimeTicks()); base::TimeTicks now = base::TimeTicks::Now(); @@ -250,7 +216,7 @@ int TransportConnectJob::DoTransportConnectComplete(int result) { base::TimeDelta::FromMinutes(10), 100); } else { - if (AddressListOnlyContainsIPv6Addresses(addresses_)) { + if (AddressListOnlyContainsIPv6(addresses_)) { UMA_HISTOGRAM_CUSTOM_TIMES("Net.TCP_Connection_Latency_IPv6_Solo", connect_duration, base::TimeDelta::FromMilliseconds(1), @@ -287,7 +253,7 @@ void TransportConnectJob::DoIPv6FallbackTransportConnect() { DCHECK(!fallback_addresses_.get()); fallback_addresses_.reset(new AddressList(addresses_)); - MakeAddrListStartWithIPv4(fallback_addresses_.get()); + MakeAddressListStartWithIPv4(fallback_addresses_.get()); fallback_transport_socket_.reset( client_socket_factory_->CreateTransportClientSocket( *fallback_addresses_, net_log().net_log(), net_log().source())); |