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 |