| // Copyright (c) 2012 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. |
| // |
| // This StreamSocket implementation wraps a ClientSocketHandle that is created |
| // from the client socket pool after resolving proxies. |
| |
| #ifndef JINGLE_GLUE_PROXY_RESOLVING_CLIENT_SOCKET_H_ |
| #define JINGLE_GLUE_PROXY_RESOLVING_CLIENT_SOCKET_H_ |
| |
| #include "base/basictypes.h" |
| #include "base/compiler_specific.h" |
| #include "base/memory/ref_counted.h" |
| #include "base/memory/weak_ptr.h" |
| #include "net/base/completion_callback.h" |
| #include "net/base/host_port_pair.h" |
| #include "net/base/net_errors.h" |
| #include "net/base/net_log.h" |
| #include "net/proxy/proxy_info.h" |
| #include "net/proxy/proxy_service.h" |
| #include "net/socket/stream_socket.h" |
| #include "net/ssl/ssl_config_service.h" |
| #include "url/gurl.h" |
| |
| namespace net { |
| class ClientSocketFactory; |
| class ClientSocketHandle; |
| class HttpNetworkSession; |
| class URLRequestContextGetter; |
| } // namespace net |
| |
| // TODO(sanjeevr): Move this to net/ |
| namespace jingle_glue { |
| |
| class ProxyResolvingClientSocket : public net::StreamSocket { |
| public: |
| // Constructs a new ProxyResolvingClientSocket. |socket_factory| is |
| // the ClientSocketFactory that will be used by the underlying |
| // HttpNetworkSession. If |socket_factory| is NULL, the default |
| // socket factory (net::ClientSocketFactory::GetDefaultFactory()) |
| // will be used. |dest_host_port_pair| is the destination for this |
| // socket. The hostname must be non-empty and the port must be > 0. |
| ProxyResolvingClientSocket( |
| net::ClientSocketFactory* socket_factory, |
| const scoped_refptr<net::URLRequestContextGetter>& request_context_getter, |
| const net::SSLConfig& ssl_config, |
| const net::HostPortPair& dest_host_port_pair); |
| virtual ~ProxyResolvingClientSocket(); |
| |
| // net::StreamSocket implementation. |
| virtual int Read(net::IOBuffer* buf, int buf_len, |
| const net::CompletionCallback& callback) OVERRIDE; |
| virtual int Write(net::IOBuffer* buf, int buf_len, |
| const net::CompletionCallback& callback) OVERRIDE; |
| virtual bool SetReceiveBufferSize(int32 size) OVERRIDE; |
| virtual bool SetSendBufferSize(int32 size) OVERRIDE; |
| virtual int Connect(const net::CompletionCallback& callback) OVERRIDE; |
| virtual void Disconnect() OVERRIDE; |
| virtual bool IsConnected() const OVERRIDE; |
| virtual bool IsConnectedAndIdle() const OVERRIDE; |
| virtual int GetPeerAddress(net::IPEndPoint* address) const OVERRIDE; |
| virtual int GetLocalAddress(net::IPEndPoint* address) const OVERRIDE; |
| virtual const net::BoundNetLog& NetLog() const OVERRIDE; |
| virtual void SetSubresourceSpeculation() OVERRIDE; |
| virtual void SetOmniboxSpeculation() OVERRIDE; |
| virtual bool WasEverUsed() const OVERRIDE; |
| virtual bool UsingTCPFastOpen() const OVERRIDE; |
| virtual bool WasNpnNegotiated() const OVERRIDE; |
| virtual net::NextProto GetNegotiatedProtocol() const OVERRIDE; |
| virtual bool GetSSLInfo(net::SSLInfo* ssl_info) OVERRIDE; |
| |
| private: |
| // Proxy resolution and connection functions. |
| void ProcessProxyResolveDone(int status); |
| void ProcessConnectDone(int status); |
| |
| void CloseTransportSocket(); |
| void RunUserConnectCallback(int status); |
| int ReconsiderProxyAfterError(int error); |
| void ReportSuccessfulProxyConnection(); |
| |
| // Callbacks passed to net APIs. |
| net::CompletionCallback proxy_resolve_callback_; |
| net::CompletionCallback connect_callback_; |
| |
| scoped_refptr<net::HttpNetworkSession> network_session_; |
| |
| // The transport socket. |
| scoped_ptr<net::ClientSocketHandle> transport_; |
| |
| const net::SSLConfig ssl_config_; |
| net::ProxyService::PacRequest* pac_request_; |
| net::ProxyInfo proxy_info_; |
| const net::HostPortPair dest_host_port_pair_; |
| const GURL proxy_url_; |
| bool tried_direct_connect_fallback_; |
| net::BoundNetLog bound_net_log_; |
| |
| // The callback passed to Connect(). |
| net::CompletionCallback user_connect_callback_; |
| |
| base::WeakPtrFactory<ProxyResolvingClientSocket> weak_factory_; |
| |
| DISALLOW_COPY_AND_ASSIGN(ProxyResolvingClientSocket); |
| }; |
| |
| } // namespace jingle_glue |
| |
| #endif // JINGLE_GLUE_PROXY_RESOLVING_CLIENT_SOCKET_H_ |