| Index: net/socket/transport_client_socket_pool.cc
|
| diff --git a/net/socket/transport_client_socket_pool.cc b/net/socket/transport_client_socket_pool.cc
|
| index a00e8101d2dd4c63bda02277f53d7350b8dac2be..b2ca683c048ae10e818b82346e307d98e50891a8 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()));
|
|
|