summaryrefslogtreecommitdiffstats
path: root/net
diff options
context:
space:
mode:
authordhollowa@chromium.org <dhollowa@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98>2010-08-05 17:21:34 +0000
committerdhollowa@chromium.org <dhollowa@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98>2010-08-05 17:21:34 +0000
commitd6149fded8c3cc8939e244ae6c5d9d076e69a4ab (patch)
tree093d9d27bf276f0126ccf41ce179729ad57956c4 /net
parent7ba53e1db77e3cd7c9e7b05c6e44698a142beea5 (diff)
downloadchromium_src-d6149fded8c3cc8939e244ae6c5d9d076e69a4ab.zip
chromium_src-d6149fded8c3cc8939e244ae6c5d9d076e69a4ab.tar.gz
chromium_src-d6149fded8c3cc8939e244ae6c5d9d076e69a4ab.tar.bz2
Revert 55071 - Reland 54771 (and 54795) To enable TCP Preconnection by default
Leaks reported with this CL. http://build.chromium.org/buildbot/memory/builders/Linux%20Heapcheck/builds/6130/steps/heapcheck%20test:%20net/logs/stdio Eg. Leak of 24 bytes in 1 objects allocated from: @ 84aece net::SSLClientSocketNSS::BufferRecv @ 84b161 net::SSLClientSocketNSS::DoTransportIO @ 84ca1f net::SSLClientSocketNSS::DoHandshakeLoop @ 84ca6b net::SSLClientSocketNSS::OnHandshakeIOComplete @ 84cadc net::SSLClientSocketNSS::OnRecvComplete @ 84cbb0 net::SSLClientSocketNSS::BufferRecvComplete @ 84ea4b void DispatchToMethod @ 84ea7b CallbackImpl::RunWithParams @ 4b3a10 CallbackRunner::Run @ 853e7e net::TCPClientSocketLibevent::DoReadCallback @ 85426f net::TCPClientSocketLibevent::DidCompleteRead @ 856a5c net::TCPClientSocketLibevent::ReadWatcher::OnFileCanReadWithoutBlocking @ 93d8fd base::MessagePumpLibevent::FileDescriptorWatcher::OnFileCanReadWithoutBlocking @ 93d966 base::MessagePumpLibevent::OnLibeventNotification @ 9da639 event_process_active @ 9da923 event_base_loop @ 93dfd0 base::MessagePumpLibevent::Run @ 8f2873 MessageLoop::RunInternal @ 8f2893 MessageLoop::RunHandler @ 8f2938 MessageLoop::Run @ 44b7f9 TestCompletionCallback::WaitForResult @ 6a1ee6 SSLClientSocketTest_ConnectMismatched_Test::TestBody @ 961831 testing::Test::Run @ 965026 testing::internal::TestInfoImpl::Run @ 96515c testing::TestCase::Run @ 965bbe testing::internal::UnitTestImpl::RunAllTests @ 965d35 testing::UnitTest::Run @ 4a4bf7 TestSuite::Run @ 4a3b6d main @ 2adff5bb11c4 __libc_start_main Suppression: { <insert_a_suppression_name_here> Heapcheck:Leak fun:net::SSLClientSocketNSS::BufferRecv fun:net::SSLClientSocketNSS::DoTransportIO fun:net::SSLClientSocketNSS::DoHandshakeLoop fun:net::SSLClientSocketNSS::OnHandshakeIOComplete fun:net::SSLClientSocketNSS::OnRecvComplete fun:net::SSLClientSocketNSS::BufferRecvComplete fun:void DispatchToMethod fun:CallbackImpl::RunWithParams fun:CallbackRunner::Run fun:net::TCPClientSocketLibevent::DoReadCallback fun:net::TCPClientSocketLibevent::DidCompleteRead fun:net::TCPClientSocketLibevent::ReadWatcher::OnFileCanReadWithoutBlocking fun:base::MessagePumpLibevent::FileDescriptorWatcher::OnFileCanReadWithoutBlocking fun:base::MessagePumpLibevent::OnLibeventNotification fun:event_process_active fun:event_base_loop fun:base::MessagePumpLibevent::Run fun:MessageLoop::RunInternal fun:MessageLoop::RunHandler fun:MessageLoop::Run fun:TestCompletionCallback::WaitForResult fun:SSLClientSocketTest_ConnectMismatched_Test::TestBody fun:testing::Test::Run fun:testing::internal::TestInfoImpl::Run fun:testing::TestCase::Run fun:testing::internal::UnitTestImpl::RunAllTests fun:testing::UnitTest::Run fun:TestSuite::Run fun:main fun:__libc_start_main } I added defensive code in ClientSocketHandle::ReleaseSocket(), which should preclude the crash that was reported on the stability bot. I added a second call to ReleaseSocket() from ~ClientSocketHandle to ensure that we updated the related ClientSocket when we are torn down. r=mbelshe Review URL: http://codereview.chromium.org/3071022 TBR=jar@chromium.org git-svn-id: svn://svn.chromium.org/chrome/trunk/src@55090 0039d316-1c4b-4281-b951-d872f2087c98
Diffstat (limited to 'net')
-rw-r--r--net/net.gyp1
-rw-r--r--net/socket/client_socket.cc69
-rw-r--r--net/socket/client_socket.h38
-rw-r--r--net/socket/client_socket_handle.cc3
-rw-r--r--net/socket/client_socket_handle.h11
-rw-r--r--net/socket/client_socket_pool_base.h11
6 files changed, 7 insertions, 126 deletions
diff --git a/net/net.gyp b/net/net.gyp
index b7f6245..64eb95a 100644
--- a/net/net.gyp
+++ b/net/net.gyp
@@ -459,7 +459,6 @@
'proxy/proxy_service.h',
'proxy/sync_host_resolver_bridge.cc',
'proxy/sync_host_resolver_bridge.h',
- 'socket/client_socket.cc',
'socket/client_socket.h',
'socket/client_socket_factory.cc',
'socket/client_socket_factory.h',
diff --git a/net/socket/client_socket.cc b/net/socket/client_socket.cc
deleted file mode 100644
index dc63f35..0000000
--- a/net/socket/client_socket.cc
+++ /dev/null
@@ -1,69 +0,0 @@
-// Copyright (c) 2010 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/socket/client_socket.h"
-
-#include "base/histogram.h"
-
-namespace net {
-
-ClientSocket::ClientSocket()
- : was_ever_connected_(false),
- omnibox_speculation_(false),
- subresource_speculation_(false),
- was_used_to_transmit_data_(false) {}
-
-ClientSocket::~ClientSocket() {
- EmitPreconnectionHistograms();
-}
-
-void ClientSocket::EmitPreconnectionHistograms() const {
- DCHECK(!subresource_speculation_ || !omnibox_speculation_);
- // 0 ==> non-speculative, never connected.
- // 1 ==> non-speculative never used (but connected).
- // 2 ==> non-spculative and used.
- // 3 ==> omnibox_speculative never connected.
- // 4 ==> omnibox_speculative never used (but connected).
- // 5 ==> omnibox_speculative and used.
- // 6 ==> subresource_speculative never connected.
- // 7 ==> subresource_speculative never used (but connected).
- // 8 ==> subresource_speculative and used.
- int result;
- if (was_used_to_transmit_data_)
- result = 2;
- else if (was_ever_connected_)
- result = 1;
- else
- result = 0; // Never used, and not really connected.
-
- if (omnibox_speculation_)
- result += 3;
- else if (subresource_speculation_)
- result += 6;
- UMA_HISTOGRAM_ENUMERATION("Net.PreconnectUtilization", result, 9);
-}
-
-void ClientSocket::SetSubresourceSpeculation() {
- if (was_used_to_transmit_data_)
- return;
- subresource_speculation_ = true;
-}
-
-void ClientSocket::SetOmniboxSpeculation() {
- if (was_used_to_transmit_data_)
- return;
- omnibox_speculation_ = true;
-}
-
-void ClientSocket::UpdateConnectivityState(bool is_reused) {
- // Record if this connection has every actually connected successfully.
- // Note that IsConnected() won't be defined at destruction time, so we need
- // to record this data now, while the derived class is present.
- was_ever_connected_ |= IsConnected();
- // A socket is_reused only after it has transmitted some data.
- was_used_to_transmit_data_ |= is_reused;
-}
-
-} // namespace net
-
diff --git a/net/socket/client_socket.h b/net/socket/client_socket.h
index 44ee085..29d297e 100644
--- a/net/socket/client_socket.h
+++ b/net/socket/client_socket.h
@@ -15,26 +15,6 @@ class BoundNetLog;
class ClientSocket : public Socket {
public:
- ClientSocket();
-
- // Destructor emits statistics for this socket's lifetime.
- virtual ~ClientSocket();
-
- // Set the annotation to indicate this socket was created for speculative
- // reasons. Note that if the socket was used before calling this method, then
- // the call will be ignored (no annotation will be added).
- void SetSubresourceSpeculation();
- void SetOmniboxSpeculation();
-
- // Establish values of was_ever_connected_ and was_used_to_transmit_data_.
- // The argument indicates if the socket's state, as reported by a
- // ClientSocketHandle::is_reused(), should show that the socket has already
- // been used to transmit data.
- // This is typically called when a transaction finishes, and
- // ClientSocketHandle is being destroyed. Calling at that point it allows us
- // to aggregates the impact of that connect job into this instance.
- void UpdateConnectivityState(bool is_reused);
-
// Called to establish a connection. Returns OK if the connection could be
// established synchronously. Otherwise, ERR_IO_PENDING is returned and the
// given callback will run asynchronously when the connection is established
@@ -74,24 +54,6 @@ class ClientSocket : public Socket {
// Gets the NetLog for this socket.
virtual const BoundNetLog& NetLog() const = 0;
-
- private:
- // Publish histogram to help evaluate preconnection utilization.
- void EmitPreconnectionHistograms() const;
-
- // Indicate if any ClientSocketHandle that used this socket was connected as
- // would be indicated by the IsConnected() method. This variable set by a
- // ClientSocketHandle before releasing this ClientSocket.
- bool was_ever_connected_;
-
- // Indicate if this socket was first created for speculative use, and identify
- // the motivation.
- bool omnibox_speculation_;
- bool subresource_speculation_;
-
- // Indicate if this socket was ever used. This state is set by a
- // ClientSocketHandle before releasing this ClientSocket.
- bool was_used_to_transmit_data_;
};
} // namespace net
diff --git a/net/socket/client_socket_handle.cc b/net/socket/client_socket_handle.cc
index ff0b2c5..d9ccbd5 100644
--- a/net/socket/client_socket_handle.cc
+++ b/net/socket/client_socket_handle.cc
@@ -22,9 +22,6 @@ ClientSocketHandle::ClientSocketHandle()
ClientSocketHandle::~ClientSocketHandle() {
Reset();
- // Manually release socket, so that we also cause state to be recorded into
- // associated socket_ as needed.
- release_socket();
}
void ClientSocketHandle::Reset() {
diff --git a/net/socket/client_socket_handle.h b/net/socket/client_socket_handle.h
index bcb94cb..adccc89 100644
--- a/net/socket/client_socket_handle.h
+++ b/net/socket/client_socket_handle.h
@@ -132,16 +132,7 @@ class ClientSocketHandle {
const std::string& group_name() const { return group_name_; }
int id() const { return pool_id_; }
ClientSocket* socket() { return socket_.get(); }
- ClientSocket* release_socket() {
- // Update the base class to record things like whether we've ever
- // transmitted data, and whether the connection was able to be established.
- // We use this data to construct histograms indicating whether a
- // speculative connection was ever used, etc., when the ClientSocket is
- // eventually discarded.
- if (socket_.get())
- socket_->UpdateConnectivityState(is_reused());
- return socket_.release();
- }
+ ClientSocket* release_socket() { return socket_.release(); }
bool is_reused() const { return is_reused_; }
base::TimeDelta idle_time() const { return idle_time_; }
SocketReuseType reuse_type() const {
diff --git a/net/socket/client_socket_pool_base.h b/net/socket/client_socket_pool_base.h
index 96c78d5..30cff70 100644
--- a/net/socket/client_socket_pool_base.h
+++ b/net/socket/client_socket_pool_base.h
@@ -491,7 +491,7 @@ class ClientSocketPoolBase {
const scoped_refptr<SocketParams>& params,
const BoundNetLog& net_log)
: internal::ClientSocketPoolBaseHelper::Request(
- handle, callback, priority, net_log),
+ handle, callback, priority, net_log),
params_(params) {}
const scoped_refptr<SocketParams>& params() const { return params_; }
@@ -531,9 +531,9 @@ class ClientSocketPoolBase {
ConnectJobFactory* connect_job_factory)
: histograms_(histograms),
helper_(new internal::ClientSocketPoolBaseHelper(
- max_sockets, max_sockets_per_group,
- unused_idle_socket_timeout, used_idle_socket_timeout,
- new ConnectJobFactoryAdaptor(connect_job_factory))) {}
+ max_sockets, max_sockets_per_group,
+ unused_idle_socket_timeout, used_idle_socket_timeout,
+ new ConnectJobFactoryAdaptor(connect_job_factory))) {}
virtual ~ClientSocketPoolBase() {}
@@ -611,7 +611,8 @@ class ClientSocketPoolBase {
typedef typename ClientSocketPoolBase<SocketParams>::ConnectJobFactory
ConnectJobFactory;
- explicit ConnectJobFactoryAdaptor(ConnectJobFactory* connect_job_factory)
+ explicit ConnectJobFactoryAdaptor(
+ ConnectJobFactory* connect_job_factory)
: connect_job_factory_(connect_job_factory) {}
virtual ~ConnectJobFactoryAdaptor() {}