Index: net/spdy/spdy_proxy_client_socket.h |
diff --git a/net/spdy/spdy_proxy_client_socket.h b/net/spdy/spdy_proxy_client_socket.h |
deleted file mode 100644 |
index fd7eb5e595d536da0c4c27e7321266a5ac8cd1c5..0000000000000000000000000000000000000000 |
--- a/net/spdy/spdy_proxy_client_socket.h |
+++ /dev/null |
@@ -1,189 +0,0 @@ |
-// 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. |
- |
-#ifndef NET_SPDY_SPDY_PROXY_CLIENT_SOCKET_H_ |
-#define NET_SPDY_SPDY_PROXY_CLIENT_SOCKET_H_ |
- |
-#include <stddef.h> |
-#include <stdint.h> |
- |
-#include <list> |
-#include <memory> |
- |
-#include "base/macros.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/load_timing_info.h" |
-#include "net/base/net_export.h" |
-#include "net/http/http_auth_controller.h" |
-#include "net/http/http_request_headers.h" |
-#include "net/http/http_request_info.h" |
-#include "net/http/http_response_info.h" |
-#include "net/http/proxy_client_socket.h" |
-#include "net/log/net_log_source.h" |
-#include "net/log/net_log_with_source.h" |
-#include "net/spdy/platform/api/spdy_string.h" |
-#include "net/spdy/spdy_http_stream.h" |
-#include "net/spdy/spdy_protocol.h" |
-#include "net/spdy/spdy_read_queue.h" |
-#include "net/spdy/spdy_session.h" |
-#include "net/spdy/spdy_stream.h" |
- |
-namespace net { |
- |
-class HttpStream; |
-class IOBuffer; |
-class SpdyStream; |
- |
-class NET_EXPORT_PRIVATE SpdyProxyClientSocket : public ProxyClientSocket, |
- public SpdyStream::Delegate { |
- public: |
- // Create a socket on top of the |spdy_stream| by sending a HEADERS CONNECT |
- // frame for |endpoint|. After the response HEADERS frame is received, any |
- // data read/written to the socket will be transferred in data frames. This |
- // object will set itself as |spdy_stream|'s delegate. |
- SpdyProxyClientSocket(const base::WeakPtr<SpdyStream>& spdy_stream, |
- const SpdyString& user_agent, |
- const HostPortPair& endpoint, |
- const HostPortPair& proxy_server, |
- const NetLogWithSource& source_net_log, |
- HttpAuthController* auth_controller); |
- |
- // On destruction Disconnect() is called. |
- ~SpdyProxyClientSocket() override; |
- |
- // ProxyClientSocket methods: |
- const HttpResponseInfo* GetConnectResponseInfo() const override; |
- HttpStream* CreateConnectResponseStream() override; |
- const scoped_refptr<HttpAuthController>& GetAuthController() const override; |
- int RestartWithAuth(const CompletionCallback& callback) override; |
- bool IsUsingSpdy() const override; |
- NextProto GetProxyNegotiatedProtocol() const override; |
- |
- // StreamSocket implementation. |
- int Connect(const CompletionCallback& callback) override; |
- void Disconnect() override; |
- bool IsConnected() const override; |
- bool IsConnectedAndIdle() const override; |
- const NetLogWithSource& NetLog() const override; |
- void SetSubresourceSpeculation() override; |
- void SetOmniboxSpeculation() override; |
- bool WasEverUsed() const override; |
- bool WasAlpnNegotiated() const override; |
- NextProto GetNegotiatedProtocol() const override; |
- bool GetSSLInfo(SSLInfo* ssl_info) override; |
- void GetConnectionAttempts(ConnectionAttempts* out) const override; |
- void ClearConnectionAttempts() override {} |
- void AddConnectionAttempts(const ConnectionAttempts& attempts) override {} |
- int64_t GetTotalReceivedBytes() const override; |
- |
- // Socket implementation. |
- int Read(IOBuffer* buf, |
- int buf_len, |
- const CompletionCallback& callback) override; |
- int Write(IOBuffer* buf, |
- int buf_len, |
- const CompletionCallback& callback) override; |
- int SetReceiveBufferSize(int32_t size) override; |
- int SetSendBufferSize(int32_t size) override; |
- int GetPeerAddress(IPEndPoint* address) const override; |
- int GetLocalAddress(IPEndPoint* address) const override; |
- |
- // SpdyStream::Delegate implementation. |
- void OnHeadersSent() override; |
- void OnHeadersReceived(const SpdyHeaderBlock& response_headers) override; |
- void OnDataReceived(std::unique_ptr<SpdyBuffer> buffer) override; |
- void OnDataSent() override; |
- void OnTrailers(const SpdyHeaderBlock& trailers) override; |
- void OnClose(int status) override; |
- NetLogSource source_dependency() const override; |
- |
- private: |
- enum State { |
- STATE_DISCONNECTED, |
- STATE_GENERATE_AUTH_TOKEN, |
- STATE_GENERATE_AUTH_TOKEN_COMPLETE, |
- STATE_SEND_REQUEST, |
- STATE_SEND_REQUEST_COMPLETE, |
- STATE_READ_REPLY_COMPLETE, |
- STATE_OPEN, |
- STATE_CLOSED |
- }; |
- |
- void LogBlockedTunnelResponse() const; |
- |
- // Calls |callback.Run(result)|. Used to run a callback posted to the |
- // message loop. |
- void RunCallback(const CompletionCallback& callback, int result) const; |
- |
- void OnIOComplete(int result); |
- |
- int DoLoop(int last_io_result); |
- int DoGenerateAuthToken(); |
- int DoGenerateAuthTokenComplete(int result); |
- int DoSendRequest(); |
- int DoSendRequestComplete(int result); |
- int DoReadReplyComplete(int result); |
- |
- // Populates |user_buffer_| with as much read data as possible |
- // and returns the number of bytes read. |
- size_t PopulateUserReadBuffer(char* out, size_t len); |
- |
- State next_state_; |
- |
- // Pointer to the SPDY Stream that this sits on top of. |
- base::WeakPtr<SpdyStream> spdy_stream_; |
- |
- // Stores the callback to the layer above, called on completing Read() or |
- // Connect(). |
- CompletionCallback read_callback_; |
- // Stores the callback to the layer above, called on completing Write(). |
- CompletionCallback write_callback_; |
- |
- // CONNECT request and response. |
- HttpRequestInfo request_; |
- HttpResponseInfo response_; |
- |
- // The hostname and port of the endpoint. This is not necessarily the one |
- // specified by the URL, due to Alternate-Protocol or fixed testing ports. |
- const HostPortPair endpoint_; |
- scoped_refptr<HttpAuthController> auth_; |
- |
- SpdyString user_agent_; |
- |
- // We buffer the response body as it arrives asynchronously from the stream. |
- SpdyReadQueue read_buffer_queue_; |
- |
- // User provided buffer for the Read() response. |
- scoped_refptr<IOBuffer> user_buffer_; |
- size_t user_buffer_len_; |
- |
- // User specified number of bytes to be written. |
- int write_buffer_len_; |
- |
- // True if the transport socket has ever sent data. |
- bool was_ever_used_; |
- |
- // Used only for redirects. |
- bool redirect_has_load_timing_info_; |
- LoadTimingInfo redirect_load_timing_info_; |
- |
- const NetLogWithSource net_log_; |
- const NetLogSource source_dependency_; |
- |
- // The default weak pointer factory. |
- base::WeakPtrFactory<SpdyProxyClientSocket> weak_factory_; |
- |
- // Only used for posting write callbacks. Weak pointers created by this |
- // factory are invalidated in Disconnect(). |
- base::WeakPtrFactory<SpdyProxyClientSocket> write_callback_weak_factory_; |
- |
- DISALLOW_COPY_AND_ASSIGN(SpdyProxyClientSocket); |
-}; |
- |
-} // namespace net |
- |
-#endif // NET_SPDY_SPDY_PROXY_CLIENT_SOCKET_H_ |