From 875a609190a37ed30823b846d17add15e85eb791 Mon Sep 17 00:00:00 2001 From: "willchan@chromium.org" Date: Mon, 3 Aug 2009 22:12:54 +0000 Subject: Add timeouts for ConnectJobs. Limit ConnectJobs per group to number of Requests per group + 1. In the histograms for Net.SocketRequestTime, late binding has a much longer tail. This is presumably because I didn't implement timeouts and CancelRequest() never cancelled jobs. I'm limiting TCPConnectJobs to 30 seconds and cancelling jobs if there are too many more than there are requests. Review URL: http://codereview.chromium.org/160499 git-svn-id: svn://svn.chromium.org/chrome/trunk/src@22330 0039d316-1c4b-4281-b951-d872f2087c98 --- net/socket/client_socket_pool_base.h | 19 +++---------------- 1 file changed, 3 insertions(+), 16 deletions(-) (limited to 'net/socket/client_socket_pool_base.h') diff --git a/net/socket/client_socket_pool_base.h b/net/socket/client_socket_pool_base.h index 51b2139..21cd642 100644 --- a/net/socket/client_socket_pool_base.h +++ b/net/socket/client_socket_pool_base.h @@ -43,10 +43,8 @@ class ConnectJob { DISALLOW_COPY_AND_ASSIGN(Delegate); }; - // A |timeout_duration| of 0 corresponds to no timeout. ConnectJob(const std::string& group_name, const ClientSocketHandle* key_handle, - base::TimeDelta timeout_duration, Delegate* delegate); virtual ~ConnectJob(); @@ -65,7 +63,7 @@ class ConnectJob { // |delegate_| via OnConnectJobComplete. In both asynchronous and synchronous // completion, ReleaseSocket() can be called to acquire the connected socket // if it succeeded. - int Connect(); + virtual int Connect() = 0; protected: void set_load_state(LoadState load_state) { load_state_ = load_state; } @@ -74,18 +72,10 @@ class ConnectJob { Delegate* delegate() { return delegate_; } private: - virtual int ConnectInternal() = 0; - - // Alerts the delegate that the ConnectJob has timed out. - void OnTimeout(); - const std::string group_name_; // Temporarily needed until we switch to late binding. const ClientSocketHandle* const key_handle_; - const base::TimeDelta timeout_duration_; - // Timer to abort jobs that take too long. - base::OneShotTimer timer_; - Delegate* delegate_; + Delegate* const delegate_; LoadState load_state_; scoped_ptr socket_; @@ -178,9 +168,6 @@ class ClientSocketPoolBase // For testing. bool may_have_stalled_group() const { return may_have_stalled_group_; } - int NumConnectJobsInGroup(const std::string& group_name) const { - return group_map_.find(group_name)->second.jobs.size(); - } private: // Entry for a persistent socket which became idle at time |start_time|. @@ -265,7 +252,7 @@ class ClientSocketPoolBase // binding is enabled. |job| must be non-NULL when late binding is // enabled. Also updates |group| if non-NULL. void RemoveConnectJob(const ClientSocketHandle* handle, - const ConnectJob* job, + ConnectJob* job, Group* group); // Same as OnAvailableSocketSlot except it looks up the Group first to see if -- cgit v1.1