diff options
author | darin@google.com <darin@google.com@0039d316-1c4b-4281-b951-d872f2087c98> | 2008-08-06 23:57:07 +0000 |
---|---|---|
committer | darin@google.com <darin@google.com@0039d316-1c4b-4281-b951-d872f2087c98> | 2008-08-06 23:57:07 +0000 |
commit | e1e0626250c6accd6e72168636630ce2aedf4953 (patch) | |
tree | 0b6206aac9e8140eba48f6bb1e261926d448f1eb /net/base/client_socket_handle.h | |
parent | 78b02d540d5d4ee753b319b4811842273be9d509 (diff) | |
download | chromium_src-e1e0626250c6accd6e72168636630ce2aedf4953.zip chromium_src-e1e0626250c6accd6e72168636630ce2aedf4953.tar.gz chromium_src-e1e0626250c6accd6e72168636630ce2aedf4953.tar.bz2 |
Rename HttpConnection to ClientSocketHandle, and rename HttpConnectionManager to ClientSocketPool.
The max number of sockets per group is now a constructor argument to ClientSocketPool.
I also changed the API on the pool to take ClientSocketHandle pointers. The former SocketHandle typedef is now a private ClientSocketPtr typedef for use within the implementation of ClientSocketPool.
git-svn-id: svn://svn.chromium.org/chrome/trunk/src@471 0039d316-1c4b-4281-b951-d872f2087c98
Diffstat (limited to 'net/base/client_socket_handle.h')
-rw-r--r-- | net/base/client_socket_handle.h | 102 |
1 files changed, 102 insertions, 0 deletions
diff --git a/net/base/client_socket_handle.h b/net/base/client_socket_handle.h new file mode 100644 index 0000000..f5cab7f --- /dev/null +++ b/net/base/client_socket_handle.h @@ -0,0 +1,102 @@ +// Copyright 2008, Google Inc. +// All rights reserved. +// +// Redistribution and use in source and binary forms, with or without +// modification, are permitted provided that the following conditions are +// met: +// +// * Redistributions of source code must retain the above copyright +// notice, this list of conditions and the following disclaimer. +// * Redistributions in binary form must reproduce the above +// copyright notice, this list of conditions and the following disclaimer +// in the documentation and/or other materials provided with the +// distribution. +// * Neither the name of Google Inc. nor the names of its +// contributors may be used to endorse or promote products derived from +// this software without specific prior written permission. +// +// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS +// "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT +// LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR +// A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT +// OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, +// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT +// LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, +// DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY +// THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT +// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE +// OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. + +#ifndef NET_BASE_CLIENT_SOCKET_HANDLE_H_ +#define NET_BASE_CLIENT_SOCKET_HANDLE_H_ + +#include <string> + +#include "base/ref_counted.h" +#include "base/scoped_ptr.h" +#include "net/base/client_socket.h" +#include "net/base/completion_callback.h" + +namespace net { + +class ClientSocketPool; + +// A container for a connected ClientSocket. +// +// The handle's |group_name| uniquely identifies the origin and type of the +// connection. It is used by the ClientSocketPool to group similar connected +// client socket objects. +// +// A handle is initialized with a null socket. It is the consumer's job to +// initialize a ClientSocket object and set it on the handle. +// +class ClientSocketHandle { + public: + explicit ClientSocketHandle(ClientSocketPool* pool); + ~ClientSocketHandle(); + + // Initializes a ClientSocketHandle object, which involves talking to the + // ClientSocketPool to locate a socket to possibly reuse. This method + // returns either OK or ERR_IO_PENDING. + // + // If this method succeeds, then the socket member will be set to an existing + // socket if an existing socket was available to reuse. Otherwise, the + // consumer should set the socket member of this handle. + // + // This method returns ERR_IO_PENDING if it cannot complete synchronously, in + // which case the consumer should wait for the completion callback to run. + // + // Init may be called multiple times. + // + int Init(const std::string& group_name, CompletionCallback* callback); + + // An initialized handle can be reset, which causes it to return to the + // un-initialized state. This releases the underlying socket, which in the + // case of a socket that still has an established connection, indicates that + // the socket may be kept alive for use by a subsequent ClientSocketHandle. + // + // NOTE: To prevent the socket from being kept alive, be sure to call its + // Disconnect method. + // + void Reset(); + + // Returns true when Init has completed successfully. + bool is_initialized() const { return socket_ != NULL; } + + // These may only be used if is_initialized() is true. + ClientSocket* socket() { return socket_->get(); } + void set_socket(ClientSocket* s) { socket_->reset(s); } + + private: + friend class ClientSocketPool; + + scoped_refptr<ClientSocketPool> pool_; + scoped_ptr<ClientSocket>* socket_; + std::string group_name_; + + DISALLOW_COPY_AND_ASSIGN(ClientSocketHandle); +}; + +} // namespace net + +#endif // NET_BASE_CLIENT_SOCKET_HANDLE_H_ |