// Copyright (c) 2011 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. #ifndef NET_SOCKET_STREAM_SOCKET_STREAM_H_ #define NET_SOCKET_STREAM_SOCKET_STREAM_H_ #pragma once #include <deque> #include <map> #include <string> #include "base/memory/linked_ptr.h" #include "base/memory/ref_counted.h" #include "base/memory/scoped_ptr.h" #include "base/string16.h" #include "base/task.h" #include "net/base/address_list.h" #include "net/base/completion_callback.h" #include "net/base/io_buffer.h" #include "net/base/net_log.h" #include "net/base/net_errors.h" #include "net/base/ssl_config_service.h" #include "net/http/http_auth.h" #include "net/http/http_auth_cache.h" #include "net/http/http_auth_handler.h" #include "net/proxy/proxy_service.h" #include "net/socket/tcp_client_socket.h" #include "net/url_request/url_request_context.h" namespace net { class AuthChallengeInfo; class ClientSocketFactory; class HostResolver; class HttpAuthHandlerFactory; class SSLConfigService; class SingleRequestHostResolver; class SocketStreamMetrics; // SocketStream is used to implement Web Sockets. // It provides plain full-duplex stream with proxy and SSL support. // For proxy authentication, only basic mechanisum is supported. It will try // authentication identity for proxy URL first. If server requires proxy // authentication, it will try authentication identity for realm that server // requests. class SocketStream : public base::RefCountedThreadSafe<SocketStream> { public: // Derive from this class and add your own data members to associate extra // information with a SocketStream. Use GetUserData(key) and // SetUserData(key, data). class UserData { public: UserData() {} virtual ~UserData() {} }; class Delegate { public: virtual ~Delegate() {} virtual int OnStartOpenConnection(SocketStream* socket, CompletionCallback* callback) { return OK; } // Called when socket stream has been connected. The socket stream accepts // at most |max_pending_send_allowed| so that a client of the socket stream // should keep track of how much it has pending and shouldn't go over // |max_pending_send_allowed| bytes. virtual void OnConnected(SocketStream* socket, int max_pending_send_allowed) = 0; // Called when |amount_sent| bytes of data are sent. virtual void OnSentData(SocketStream* socket, int amount_sent) = 0; // Called when |len| bytes of |data| are received. virtual void OnReceivedData(SocketStream* socket, const char* data, int len) = 0; // Called when the socket stream has been closed. virtual void OnClose(SocketStream* socket) = 0; // Called when proxy authentication required. // The delegate should call RestartWithAuth() if credential for |auth_info| // is found in password database, or call Close() to close the connection. virtual void OnAuthRequired(SocketStream* socket, AuthChallengeInfo* auth_info) { // By default, no credential is available and close the connection. socket->Close(); } // Called when an error occured. // This is only for error reporting to the delegate. // |error| is net::Error. virtual void OnError(const SocketStream* socket, int error) {} }; SocketStream(const GURL& url, Delegate* delegate); // The user data allows the clients to associate data with this job. // Multiple user data values can be stored under different keys. // This job will TAKE OWNERSHIP of the given data pointer, and will // delete the object if it is changed or the job is destroyed. UserData* GetUserData(const void* key) const; void SetUserData(const void* key, UserData* data); const GURL& url() const { return url_; } bool is_secure() const; const AddressList& address_list() const { return addresses_; } Delegate* delegate() const { return delegate_; } int max_pending_send_allowed() const { return max_pending_send_allowed_; } URLRequestContext* context() const { return context_.get(); } void set_context(URLRequestContext* context); BoundNetLog* net_log() { return &net_log_; } // Opens the connection on the IO thread. // Once the connection is established, calls delegate's OnConnected. virtual void Connect(); // Requests to send |len| bytes of |data| on the connection. // Returns true if |data| is buffered in the job. // Returns false if size of buffered data would exceeds // |max_pending_send_allowed_| and |data| is not sent at all. virtual bool SendData(const char* data, int len); // Requests to close the connection. // Once the connection is closed, calls delegate's OnClose. virtual void Close(); // Restarts with authentication info. // Should be used for response of OnAuthRequired. virtual void RestartWithAuth( const string16& username, const string16& password); // Detach delegate. Call before delegate is deleted. // Once delegate is detached, close the socket stream and never call delegate // back. virtual void DetachDelegate(); // Sets an alternative HostResolver. For testing purposes only. void SetHostResolver(HostResolver* host_resolver); // Sets an alternative ClientSocketFactory. Doesn't take ownership of // |factory|. For testing purposes only. void SetClientSocketFactory(ClientSocketFactory* factory); protected: friend class base::RefCountedThreadSafe<SocketStream>; virtual ~SocketStream(); Delegate* delegate_; private: friend class WebSocketThrottleTest; typedef std::map<const void*, linked_ptr<UserData> > UserDataMap; typedef std::deque< scoped_refptr<IOBufferWithSize> > PendingDataQueue; class RequestHeaders : public IOBuffer { public: RequestHeaders() : IOBuffer() {} void SetDataOffset(size_t offset) { data_ = const_cast<char*>(headers_.data()) + offset; } std::string headers_; private: ~RequestHeaders() { data_ = NULL; } }; class ResponseHeaders : public IOBuffer { public: ResponseHeaders(); void SetDataOffset(size_t offset) { data_ = headers_.get() + offset; } char* headers() const { return headers_.get(); } void Reset() { headers_.reset(); } void Realloc(size_t new_size); private: ~ResponseHeaders(); scoped_ptr_malloc<char> headers_; }; enum State { STATE_NONE, STATE_RESOLVE_PROXY, STATE_RESOLVE_PROXY_COMPLETE, STATE_RESOLVE_HOST, STATE_RESOLVE_HOST_COMPLETE, STATE_TCP_CONNECT, STATE_TCP_CONNECT_COMPLETE, STATE_WRITE_TUNNEL_HEADERS, STATE_WRITE_TUNNEL_HEADERS_COMPLETE, STATE_READ_TUNNEL_HEADERS, STATE_READ_TUNNEL_HEADERS_COMPLETE, STATE_SOCKS_CONNECT, STATE_SOCKS_CONNECT_COMPLETE, STATE_SSL_CONNECT, STATE_SSL_CONNECT_COMPLETE, STATE_READ_WRITE, STATE_AUTH_REQUIRED, STATE_CLOSE, }; enum ProxyMode { kDirectConnection, // If using a direct connection kTunnelProxy, // If using a tunnel (CONNECT method as HTTPS) kSOCKSProxy, // If using a SOCKS proxy }; // Use the same number as HttpNetworkTransaction::kMaxHeaderBufSize. enum { kMaxTunnelResponseHeadersSize = 32768 }; // 32 kilobytes. // Copies the given addrinfo list in |addresses_|. // Used for WebSocketThrottleTest. void CopyAddrInfo(struct addrinfo* head); void DoClose(); // Finishes the job. // Calls OnError and OnClose of delegate, and no more // notifications will be sent to delegate. void Finish(int result); int DidEstablishConnection(); int DidReceiveData(int result); int DidSendData(int result); void OnIOCompleted(int result); void OnReadCompleted(int result); void OnWriteCompleted(int result); void DoLoop(int result); int DoResolveProxy(); int DoResolveProxyComplete(int result); int DoResolveHost(); int DoResolveHostComplete(int result); int DoTcpConnect(int result); int DoTcpConnectComplete(int result); int DoWriteTunnelHeaders(); int DoWriteTunnelHeadersComplete(int result); int DoReadTunnelHeaders(); int DoReadTunnelHeadersComplete(int result); int DoSOCKSConnect(); int DoSOCKSConnectComplete(int result); int DoSSLConnect(); int DoSSLConnectComplete(int result); int DoReadWrite(int result); GURL ProxyAuthOrigin() const; int HandleAuthChallenge(const HttpResponseHeaders* headers); void DoAuthRequired(); void DoRestartWithAuth(); int HandleCertificateError(int result); SSLConfigService* ssl_config_service() const; ProxyService* proxy_service() const; BoundNetLog net_log_; GURL url_; int max_pending_send_allowed_; scoped_refptr<URLRequestContext> context_; UserDataMap user_data_; State next_state_; HostResolver* host_resolver_; CertVerifier* cert_verifier_; HttpAuthHandlerFactory* http_auth_handler_factory_; ClientSocketFactory* factory_; ProxyMode proxy_mode_; GURL proxy_url_; ProxyService::PacRequest* pac_request_; ProxyInfo proxy_info_; HttpAuthCache auth_cache_; scoped_ptr<HttpAuthHandler> auth_handler_; HttpAuth::Identity auth_identity_; scoped_refptr<AuthChallengeInfo> auth_info_; scoped_refptr<RequestHeaders> tunnel_request_headers_; size_t tunnel_request_headers_bytes_sent_; scoped_refptr<ResponseHeaders> tunnel_response_headers_; int tunnel_response_headers_capacity_; int tunnel_response_headers_len_; scoped_ptr<SingleRequestHostResolver> resolver_; AddressList addresses_; scoped_ptr<ClientSocket> socket_; SSLConfig ssl_config_; CompletionCallbackImpl<SocketStream> io_callback_; CompletionCallbackImpl<SocketStream> read_callback_; CompletionCallbackImpl<SocketStream> write_callback_; scoped_refptr<IOBuffer> read_buf_; int read_buf_size_; // Total amount of buffer (|write_buf_size_| - |write_buf_offset_| + // sum of size of |pending_write_bufs_|) should not exceed // |max_pending_send_allowed_|. // |write_buf_| holds requested data and |current_write_buf_| is used // for Write operation, that is, |current_write_buf_| is // |write_buf_| + |write_buf_offset_|. scoped_refptr<IOBuffer> write_buf_; scoped_refptr<DrainableIOBuffer> current_write_buf_; int write_buf_offset_; int write_buf_size_; PendingDataQueue pending_write_bufs_; bool closing_; bool server_closed_; scoped_ptr<SocketStreamMetrics> metrics_; DISALLOW_COPY_AND_ASSIGN(SocketStream); }; } // namespace net #endif // NET_SOCKET_STREAM_SOCKET_STREAM_H_