| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "net/socket/transport_client_socket_pool.h" | 5 #include "net/socket/transport_client_socket_pool.h" |
| 6 | 6 |
| 7 #include <algorithm> | 7 #include <algorithm> |
| 8 | 8 |
| 9 #include "base/compiler_specific.h" | 9 #include "base/compiler_specific.h" |
| 10 #include "base/lazy_instance.h" | 10 #include "base/lazy_instance.h" |
| (...skipping 458 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 469 | 469 |
| 470 base::TimeDelta | 470 base::TimeDelta |
| 471 TransportClientSocketPool::TransportConnectJobFactory::ConnectionTimeout() | 471 TransportClientSocketPool::TransportConnectJobFactory::ConnectionTimeout() |
| 472 const { | 472 const { |
| 473 return base::TimeDelta::FromSeconds(kTransportConnectJobTimeoutInSeconds); | 473 return base::TimeDelta::FromSeconds(kTransportConnectJobTimeoutInSeconds); |
| 474 } | 474 } |
| 475 | 475 |
| 476 TransportClientSocketPool::TransportClientSocketPool( | 476 TransportClientSocketPool::TransportClientSocketPool( |
| 477 int max_sockets, | 477 int max_sockets, |
| 478 int max_sockets_per_group, | 478 int max_sockets_per_group, |
| 479 ClientSocketPoolHistograms* histograms, | |
| 480 HostResolver* host_resolver, | 479 HostResolver* host_resolver, |
| 481 ClientSocketFactory* client_socket_factory, | 480 ClientSocketFactory* client_socket_factory, |
| 482 NetLog* net_log) | 481 NetLog* net_log) |
| 483 : base_(NULL, max_sockets, max_sockets_per_group, histograms, | 482 : base_(NULL, |
| 483 max_sockets, |
| 484 max_sockets_per_group, |
| 484 ClientSocketPool::unused_idle_socket_timeout(), | 485 ClientSocketPool::unused_idle_socket_timeout(), |
| 485 ClientSocketPool::used_idle_socket_timeout(), | 486 ClientSocketPool::used_idle_socket_timeout(), |
| 486 new TransportConnectJobFactory(client_socket_factory, | 487 new TransportConnectJobFactory(client_socket_factory, |
| 487 host_resolver, net_log)) { | 488 host_resolver, |
| 489 net_log)) { |
| 488 base_.EnableConnectBackupJobs(); | 490 base_.EnableConnectBackupJobs(); |
| 489 } | 491 } |
| 490 | 492 |
| 491 TransportClientSocketPool::~TransportClientSocketPool() {} | 493 TransportClientSocketPool::~TransportClientSocketPool() {} |
| 492 | 494 |
| 493 int TransportClientSocketPool::RequestSocket( | 495 int TransportClientSocketPool::RequestSocket( |
| 494 const std::string& group_name, | 496 const std::string& group_name, |
| 495 const void* params, | 497 const void* params, |
| 496 RequestPriority priority, | 498 RequestPriority priority, |
| 497 ClientSocketHandle* handle, | 499 ClientSocketHandle* handle, |
| (...skipping 78 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 576 const std::string& name, | 578 const std::string& name, |
| 577 const std::string& type, | 579 const std::string& type, |
| 578 bool include_nested_pools) const { | 580 bool include_nested_pools) const { |
| 579 return base_.GetInfoAsValue(name, type); | 581 return base_.GetInfoAsValue(name, type); |
| 580 } | 582 } |
| 581 | 583 |
| 582 base::TimeDelta TransportClientSocketPool::ConnectionTimeout() const { | 584 base::TimeDelta TransportClientSocketPool::ConnectionTimeout() const { |
| 583 return base_.ConnectionTimeout(); | 585 return base_.ConnectionTimeout(); |
| 584 } | 586 } |
| 585 | 587 |
| 586 ClientSocketPoolHistograms* TransportClientSocketPool::histograms() const { | |
| 587 return base_.histograms(); | |
| 588 } | |
| 589 | |
| 590 bool TransportClientSocketPool::IsStalled() const { | 588 bool TransportClientSocketPool::IsStalled() const { |
| 591 return base_.IsStalled(); | 589 return base_.IsStalled(); |
| 592 } | 590 } |
| 593 | 591 |
| 594 void TransportClientSocketPool::AddHigherLayeredPool( | 592 void TransportClientSocketPool::AddHigherLayeredPool( |
| 595 HigherLayeredPool* higher_pool) { | 593 HigherLayeredPool* higher_pool) { |
| 596 base_.AddHigherLayeredPool(higher_pool); | 594 base_.AddHigherLayeredPool(higher_pool); |
| 597 } | 595 } |
| 598 | 596 |
| 599 void TransportClientSocketPool::RemoveHigherLayeredPool( | 597 void TransportClientSocketPool::RemoveHigherLayeredPool( |
| 600 HigherLayeredPool* higher_pool) { | 598 HigherLayeredPool* higher_pool) { |
| 601 base_.RemoveHigherLayeredPool(higher_pool); | 599 base_.RemoveHigherLayeredPool(higher_pool); |
| 602 } | 600 } |
| 603 | 601 |
| 604 } // namespace net | 602 } // namespace net |
| OLD | NEW |