// Copyright (c) 2009 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. // // A ClientSocketPoolBase is used to restrict the number of sockets open at // a time. It also maintains a list of idle persistent sockets for reuse. // Subclasses of ClientSocketPool should compose ClientSocketPoolBase to handle // the core logic of (1) restricting the number of active (connected or // connecting) sockets per "group" (generally speaking, the hostname), (2) // maintaining a per-group list of idle, persistent sockets for reuse, and (3) // limiting the total number of active sockets in the system. // // ClientSocketPoolBase abstracts socket connection details behind ConnectJob, // ConnectJobFactory, and SocketParams. When a socket "slot" becomes available, // the ClientSocketPoolBase will ask the ConnectJobFactory to create a // ConnectJob with a SocketParams. Subclasses of ClientSocketPool should // implement their socket specific connection by subclassing ConnectJob and // implementing ConnectJob::ConnectInternal(). They can control the parameters // passed to each new ConnectJob instance via their ConnectJobFactory subclass // and templated SocketParams parameter. // #ifndef NET_SOCKET_CLIENT_SOCKET_POOL_BASE_H_ #define NET_SOCKET_CLIENT_SOCKET_POOL_BASE_H_ #include <deque> #include <map> #include <set> #include <string> #include "base/basictypes.h" #include "base/ref_counted.h" #include "base/scoped_ptr.h" #include "base/time.h" #include "base/timer.h" #include "net/base/address_list.h" #include "net/base/completion_callback.h" #include "net/base/load_log.h" #include "net/base/load_states.h" #include "net/base/net_errors.h" #include "net/base/network_change_notifier.h" #include "net/base/request_priority.h" #include "net/socket/client_socket.h" #include "net/socket/client_socket_pool.h" namespace net { class ClientSocketHandle; // ConnectJob provides an abstract interface for "connecting" a socket. // The connection may involve host resolution, tcp connection, ssl connection, // etc. class ConnectJob { public: class Delegate { public: Delegate() {} virtual ~Delegate() {} // Alerts the delegate that the connection completed. virtual void OnConnectJobComplete(int result, ConnectJob* job) = 0; private: DISALLOW_COPY_AND_ASSIGN(Delegate); }; // A |timeout_duration| of 0 corresponds to no timeout. ConnectJob(const std::string& group_name, base::TimeDelta timeout_duration, Delegate* delegate, LoadLog* load_log); virtual ~ConnectJob(); // Accessors const std::string& group_name() const { return group_name_; } LoadLog* load_log() { return load_log_; } // Releases |socket_| to the client. On connection error, this should return // NULL. ClientSocket* ReleaseSocket() { return socket_.release(); } // Begins connecting the socket. Returns OK on success, ERR_IO_PENDING if it // cannot complete synchronously without blocking, or another net error code // on error. In asynchronous completion, the ConnectJob will notify // |delegate_| via OnConnectJobComplete. In both asynchronous and synchronous // completion, ReleaseSocket() can be called to acquire the connected socket // if it succeeded. int Connect(); virtual LoadState GetLoadState() const = 0; protected: void set_socket(ClientSocket* socket) { socket_.reset(socket); } ClientSocket* socket() { return socket_.get(); } void NotifyDelegateOfCompletion(int rv); private: virtual int ConnectInternal() = 0; // Alerts the delegate that the ConnectJob has timed out. void OnTimeout(); const std::string group_name_; const base::TimeDelta timeout_duration_; // Timer to abort jobs that take too long. base::OneShotTimer<ConnectJob> timer_; Delegate* delegate_; scoped_ptr<ClientSocket> socket_; scoped_refptr<LoadLog> load_log_; DISALLOW_COPY_AND_ASSIGN(ConnectJob); }; namespace internal { // ClientSocketPoolBaseHelper is an internal class that implements almost all // the functionality from ClientSocketPoolBase without using templates. // ClientSocketPoolBase adds templated definitions built on top of // ClientSocketPoolBaseHelper. This class is not for external use, please use // ClientSocketPoolBase instead. class ClientSocketPoolBaseHelper : public base::RefCounted<ClientSocketPoolBaseHelper>, public ConnectJob::Delegate, public NetworkChangeNotifier::Observer { public: class Request { public: Request(ClientSocketHandle* handle, CompletionCallback* callback, RequestPriority priority, LoadLog* load_log) : handle_(handle), callback_(callback), priority_(priority), load_log_(load_log) {} virtual ~Request() {} ClientSocketHandle* handle() const { return handle_; } CompletionCallback* callback() const { return callback_; } RequestPriority priority() const { return priority_; } LoadLog* load_log() const { return load_log_.get(); } private: ClientSocketHandle* const handle_; CompletionCallback* const callback_; const RequestPriority priority_; const scoped_refptr<LoadLog> load_log_; DISALLOW_COPY_AND_ASSIGN(Request); }; class ConnectJobFactory { public: ConnectJobFactory() {} virtual ~ConnectJobFactory() {} virtual ConnectJob* NewConnectJob( const std::string& group_name, const Request& request, ConnectJob::Delegate* delegate, LoadLog* load_log) const = 0; private: DISALLOW_COPY_AND_ASSIGN(ConnectJobFactory); }; ClientSocketPoolBaseHelper( int max_sockets, int max_sockets_per_group, base::TimeDelta unused_idle_socket_timeout, base::TimeDelta used_idle_socket_timeout, ConnectJobFactory* connect_job_factory, NetworkChangeNotifier* network_change_notifier); // See ClientSocketPool::RequestSocket for documentation on this function. // Note that |request| must be heap allocated. If ERR_IO_PENDING is returned, // then ClientSocketPoolBaseHelper takes ownership of |request|. int RequestSocket(const std::string& group_name, const Request* request); // See ClientSocketPool::CancelRequest for documentation on this function. void CancelRequest(const std::string& group_name, const ClientSocketHandle* handle); // See ClientSocketPool::ReleaseSocket for documentation on this function. void ReleaseSocket(const std::string& group_name, ClientSocket* socket); // See ClientSocketPool::CloseIdleSockets for documentation on this function. void CloseIdleSockets(); // See ClientSocketPool::IdleSocketCount() for documentation on this function. int idle_socket_count() const { return idle_socket_count_; } // See ClientSocketPool::IdleSocketCountInGroup() for documentation on this // function. int IdleSocketCountInGroup(const std::string& group_name) const; // See ClientSocketPool::GetLoadState() for documentation on this function. LoadState GetLoadState(const std::string& group_name, const ClientSocketHandle* handle) const; // ConnectJob::Delegate methods: virtual void OnConnectJobComplete(int result, ConnectJob* job); // NetworkChangeNotifier::Observer methods: virtual void OnIPAddressChanged(); // 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(); } // Closes all idle sockets if |force| is true. Else, only closes idle // sockets that timed out or can't be reused. Made public for testing. void CleanupIdleSockets(bool force); private: friend class base::RefCounted<ClientSocketPoolBaseHelper>; ~ClientSocketPoolBaseHelper(); // Entry for a persistent socket which became idle at time |start_time|. struct IdleSocket { IdleSocket() : socket(NULL), used(false) {} ClientSocket* socket; base::TimeTicks start_time; bool used; // Indicates whether or not the socket has been used yet. // An idle socket should be removed if it can't be reused, or has been idle // for too long. |now| is the current time value (TimeTicks::Now()). // |timeout| is the length of time to wait before timing out an idle socket. // // An idle socket can't be reused if it is disconnected or has received // data unexpectedly (hence no longer idle). The unread data would be // mistaken for the beginning of the next response if we were to reuse the // socket for a new request. bool ShouldCleanup(base::TimeTicks now, base::TimeDelta timeout) const; }; typedef std::deque<const Request*> RequestQueue; typedef std::map<const ClientSocketHandle*, const Request*> RequestMap; // A Group is allocated per group_name when there are idle sockets or pending // requests. Otherwise, the Group object is removed from the map. // |active_socket_count| tracks the number of sockets held by clients. Of // this number of sockets held by clients, some of them may be released soon, // since ReleaseSocket() was called of them, but the DoReleaseSocket() task // has not run yet for them. |num_releasing_sockets| tracks these values, // which is useful for not starting up new ConnectJobs when sockets may become // available really soon. struct Group { Group() : active_socket_count(0), num_releasing_sockets(0) {} bool IsEmpty() const { return active_socket_count == 0 && idle_sockets.empty() && jobs.empty() && pending_requests.empty(); } bool HasAvailableSocketSlot(int max_sockets_per_group) const { return active_socket_count + static_cast<int>(jobs.size()) < max_sockets_per_group; } bool HasReleasingSockets() const { return num_releasing_sockets > 0; } RequestPriority TopPendingPriority() const { return pending_requests.front()->priority(); } std::deque<IdleSocket> idle_sockets; std::set<const ConnectJob*> jobs; RequestQueue pending_requests; int active_socket_count; // number of active sockets used by clients // Number of sockets being released within one loop through the MessageLoop. int num_releasing_sockets; }; typedef std::map<std::string, Group> GroupMap; typedef std::set<const ConnectJob*> ConnectJobSet; static void InsertRequestIntoQueue(const Request* r, RequestQueue* pending_requests); static const Request* RemoveRequestFromQueue(RequestQueue::iterator it, RequestQueue* pending_requests); // Called when the number of idle sockets changes. void IncrementIdleCount(); void DecrementIdleCount(); // Called via PostTask by ReleaseSocket. void DoReleaseSocket(const std::string& group_name, ClientSocket* socket); // Scans the group map for groups which have an available socket slot and // at least one pending request. Returns number of groups found, and if found // at least one, fills |group| and |group_name| with data of the stalled group // having highest priority. int FindTopStalledGroup(Group** group, std::string* group_name); // Called when timer_ fires. This method scans the idle sockets removing // sockets that timed out or can't be reused. void OnCleanupTimerFired() { CleanupIdleSockets(false); } // Removes |job| from |connect_job_set_|. Also updates |group| if non-NULL. void RemoveConnectJob(const ConnectJob* job, Group* group); // Same as OnAvailableSocketSlot except it looks up the Group first to see if // it's there. void MaybeOnAvailableSocketSlot(const std::string& group_name); // Might delete the Group from |group_map_|. void OnAvailableSocketSlot(const std::string& group_name, Group* group); // Process a request from a group's pending_requests queue. void ProcessPendingRequest(const std::string& group_name, Group* group); // Assigns |socket| to |handle| and updates |group|'s counters appropriately. void HandOutSocket(ClientSocket* socket, bool reused, ClientSocketHandle* handle, base::TimeDelta time_idle, Group* group); // Adds |socket| to the list of idle sockets for |group|. |used| indicates // whether or not the socket has previously been used. void AddIdleSocket(ClientSocket* socket, bool used, Group* group); // Iterates through |connect_job_map_|, canceling all ConnectJobs. // Afterwards, it iterates through all groups and deletes them if they are no // longer needed. void CancelAllConnectJobs(); // Returns true if we can't create any more sockets due to the total limit. // TODO(phajdan.jr): Also take idle sockets into account. bool ReachedMaxSocketsLimit() const; GroupMap group_map_; // Timer used to periodically prune idle sockets that timed out or can't be // reused. base::RepeatingTimer<ClientSocketPoolBaseHelper> timer_; // The total number of idle sockets in the system. int idle_socket_count_; // Number of connecting sockets across all groups. int connecting_socket_count_; // Number of connected sockets we handed out across all groups. int handed_out_socket_count_; // The maximum total number of sockets. See ReachedMaxSocketsLimit. const int max_sockets_; // The maximum number of sockets kept per group. const int max_sockets_per_group_; // The time to wait until closing idle sockets. const base::TimeDelta unused_idle_socket_timeout_; const base::TimeDelta used_idle_socket_timeout_; // Until the maximum number of sockets limit is reached, a group can only // have pending requests if it exceeds the "max sockets per group" limit. // // This means when a socket is released, the only pending requests that can // be started next belong to the same group. // // However once the |max_sockets_| limit is reached, this stops being true: // groups can now have pending requests without having first reached the // |max_sockets_per_group_| limit. So choosing the next request involves // selecting the highest priority request across *all* groups. // // Since reaching the maximum number of sockets is an edge case, we make note // of when it happens, and thus avoid doing the slower "scan all groups" // in the common case. bool may_have_stalled_group_; const scoped_ptr<ConnectJobFactory> connect_job_factory_; NetworkChangeNotifier* const network_change_notifier_; }; } // namespace internal // The maximum duration, in seconds, to keep unused idle persistent sockets // alive. // TODO(willchan): Change this timeout after getting histogram data on how // long it should be. static const int kUnusedIdleSocketTimeout = 10; // The maximum duration, in seconds, to keep used idle persistent sockets alive. static const int kUsedIdleSocketTimeout = 300; // 5 minutes template <typename SocketParams> class ClientSocketPoolBase { public: class Request : public internal::ClientSocketPoolBaseHelper::Request { public: Request(ClientSocketHandle* handle, CompletionCallback* callback, RequestPriority priority, const SocketParams& params, LoadLog* load_log) : internal::ClientSocketPoolBaseHelper::Request( handle, callback, priority, load_log), params_(params) {} const SocketParams& params() const { return params_; } private: SocketParams params_; }; class ConnectJobFactory { public: ConnectJobFactory() {} virtual ~ConnectJobFactory() {} virtual ConnectJob* NewConnectJob( const std::string& group_name, const Request& request, ConnectJob::Delegate* delegate, LoadLog* load_log) const = 0; private: DISALLOW_COPY_AND_ASSIGN(ConnectJobFactory); }; // |max_sockets| is the maximum number of sockets to be maintained by this // ClientSocketPool. |max_sockets_per_group| specifies the maximum number of // sockets a "group" can have. |unused_idle_socket_timeout| specifies how // long to leave an unused idle socket open before closing it. // |used_idle_socket_timeout| specifies how long to leave a previously used // idle socket open before closing it. ClientSocketPoolBase( int max_sockets, int max_sockets_per_group, base::TimeDelta unused_idle_socket_timeout, base::TimeDelta used_idle_socket_timeout, ConnectJobFactory* connect_job_factory, NetworkChangeNotifier* network_change_notifier) : helper_(new internal::ClientSocketPoolBaseHelper( max_sockets, max_sockets_per_group, unused_idle_socket_timeout, used_idle_socket_timeout, new ConnectJobFactoryAdaptor(connect_job_factory), network_change_notifier)) {} virtual ~ClientSocketPoolBase() {} // These member functions simply forward to ClientSocketPoolBaseHelper. // RequestSocket bundles up the parameters into a Request and then forwards to // ClientSocketPoolBaseHelper::RequestSocket(). Note that the memory // ownership is transferred in the asynchronous (ERR_IO_PENDING) case. int RequestSocket(const std::string& group_name, const SocketParams& params, RequestPriority priority, ClientSocketHandle* handle, CompletionCallback* callback, LoadLog* load_log) { scoped_ptr<Request> request( new Request(handle, callback, priority, params, load_log)); LoadLog::BeginEvent(load_log, LoadLog::TYPE_SOCKET_POOL); int rv = helper_->RequestSocket(group_name, request.get()); if (rv == ERR_IO_PENDING) request.release(); else LoadLog::EndEvent(load_log, LoadLog::TYPE_SOCKET_POOL); return rv; } void CancelRequest(const std::string& group_name, const ClientSocketHandle* handle) { return helper_->CancelRequest(group_name, handle); } void ReleaseSocket(const std::string& group_name, ClientSocket* socket) { return helper_->ReleaseSocket(group_name, socket); } void CloseIdleSockets() { return helper_->CloseIdleSockets(); } int idle_socket_count() const { return helper_->idle_socket_count(); } int IdleSocketCountInGroup(const std::string& group_name) const { return helper_->IdleSocketCountInGroup(group_name); } LoadState GetLoadState(const std::string& group_name, const ClientSocketHandle* handle) const { return helper_->GetLoadState(group_name, handle); } virtual void OnConnectJobComplete(int result, ConnectJob* job) { return helper_->OnConnectJobComplete(result, job); } // For testing. bool may_have_stalled_group() const { return helper_->may_have_stalled_group(); } int NumConnectJobsInGroup(const std::string& group_name) const { return helper_->NumConnectJobsInGroup(group_name); } void CleanupIdleSockets(bool force) { return helper_->CleanupIdleSockets(force); } private: // This adaptor class exists to bridge the // internal::ClientSocketPoolBaseHelper::ConnectJobFactory and // ClientSocketPoolBase::ConnectJobFactory types, allowing clients to use the // typesafe ClientSocketPoolBase::ConnectJobFactory, rather than having to // static_cast themselves. class ConnectJobFactoryAdaptor : public internal::ClientSocketPoolBaseHelper::ConnectJobFactory { public: typedef typename ClientSocketPoolBase<SocketParams>::ConnectJobFactory ConnectJobFactory; explicit ConnectJobFactoryAdaptor( ConnectJobFactory* connect_job_factory) : connect_job_factory_(connect_job_factory) {} virtual ~ConnectJobFactoryAdaptor() {} virtual ConnectJob* NewConnectJob( const std::string& group_name, const internal::ClientSocketPoolBaseHelper::Request& request, ConnectJob::Delegate* delegate, LoadLog* load_log) const { const Request* casted_request = static_cast<const Request*>(&request); return connect_job_factory_->NewConnectJob( group_name, *casted_request, delegate, load_log); } const scoped_ptr<ConnectJobFactory> connect_job_factory_; }; // One might ask why ClientSocketPoolBaseHelper is also refcounted if its // containing ClientSocketPool is already refcounted. The reason is because // DoReleaseSocket() posts a task. If ClientSocketPool gets deleted between // the posting of the task and the execution, then we'll hit the DCHECK that // |ClientSocketPoolBaseHelper::group_map_| is empty. scoped_refptr<internal::ClientSocketPoolBaseHelper> helper_; DISALLOW_COPY_AND_ASSIGN(ClientSocketPoolBase); }; } // namespace net #endif // NET_SOCKET_CLIENT_SOCKET_POOL_BASE_H_