| Index: webrtc/base/socketadapters.h
|
| diff --git a/webrtc/base/socketadapters.h b/webrtc/base/socketadapters.h
|
| index 3b5be10c61016928ae9bde186b56d651470255d6..57e1f9eeb1ae1f8ff22ab7b311b259dfd0e81861 100644
|
| --- a/webrtc/base/socketadapters.h
|
| +++ b/webrtc/base/socketadapters.h
|
| @@ -21,7 +21,6 @@
|
|
|
| namespace rtc {
|
|
|
| -struct HttpAuthContext;
|
| class ByteBufferReader;
|
| class ByteBufferWriter;
|
|
|
| @@ -94,114 +93,6 @@ class AsyncSSLServerSocket : public BufferedReadAdapter {
|
| RTC_DISALLOW_COPY_AND_ASSIGN(AsyncSSLServerSocket);
|
| };
|
|
|
| -///////////////////////////////////////////////////////////////////////////////
|
| -
|
| -// Implements a socket adapter that speaks the HTTP/S proxy protocol.
|
| -class AsyncHttpsProxySocket : public BufferedReadAdapter {
|
| - public:
|
| - AsyncHttpsProxySocket(AsyncSocket* socket, const std::string& user_agent,
|
| - const SocketAddress& proxy,
|
| - const std::string& username, const CryptString& password);
|
| - ~AsyncHttpsProxySocket() override;
|
| -
|
| - // If connect is forced, the adapter will always issue an HTTP CONNECT to the
|
| - // target address. Otherwise, it will connect only if the destination port
|
| - // is not port 80.
|
| - void SetForceConnect(bool force) { force_connect_ = force; }
|
| -
|
| - int Connect(const SocketAddress& addr) override;
|
| - SocketAddress GetRemoteAddress() const override;
|
| - int Close() override;
|
| - ConnState GetState() const override;
|
| -
|
| - protected:
|
| - void OnConnectEvent(AsyncSocket* socket) override;
|
| - void OnCloseEvent(AsyncSocket* socket, int err) override;
|
| - void ProcessInput(char* data, size_t* len) override;
|
| -
|
| - bool ShouldIssueConnect() const;
|
| - void SendRequest();
|
| - void ProcessLine(char* data, size_t len);
|
| - void EndResponse();
|
| - void Error(int error);
|
| -
|
| - private:
|
| - SocketAddress proxy_, dest_;
|
| - std::string agent_, user_, headers_;
|
| - CryptString pass_;
|
| - bool force_connect_;
|
| - size_t content_length_;
|
| - int defer_error_;
|
| - bool expect_close_;
|
| - enum ProxyState {
|
| - PS_INIT, PS_LEADER, PS_AUTHENTICATE, PS_SKIP_HEADERS, PS_ERROR_HEADERS,
|
| - PS_TUNNEL_HEADERS, PS_SKIP_BODY, PS_TUNNEL, PS_WAIT_CLOSE, PS_ERROR
|
| - } state_;
|
| - HttpAuthContext * context_;
|
| - std::string unknown_mechanisms_;
|
| - RTC_DISALLOW_COPY_AND_ASSIGN(AsyncHttpsProxySocket);
|
| -};
|
| -
|
| -///////////////////////////////////////////////////////////////////////////////
|
| -
|
| -// Implements a socket adapter that speaks the SOCKS proxy protocol.
|
| -class AsyncSocksProxySocket : public BufferedReadAdapter {
|
| - public:
|
| - AsyncSocksProxySocket(AsyncSocket* socket, const SocketAddress& proxy,
|
| - const std::string& username, const CryptString& password);
|
| - ~AsyncSocksProxySocket() override;
|
| -
|
| - int Connect(const SocketAddress& addr) override;
|
| - SocketAddress GetRemoteAddress() const override;
|
| - int Close() override;
|
| - ConnState GetState() const override;
|
| -
|
| - protected:
|
| - void OnConnectEvent(AsyncSocket* socket) override;
|
| - void ProcessInput(char* data, size_t* len) override;
|
| -
|
| - void SendHello();
|
| - void SendConnect();
|
| - void SendAuth();
|
| - void Error(int error);
|
| -
|
| - private:
|
| - enum State {
|
| - SS_INIT, SS_HELLO, SS_AUTH, SS_CONNECT, SS_TUNNEL, SS_ERROR
|
| - };
|
| - State state_;
|
| - SocketAddress proxy_, dest_;
|
| - std::string user_;
|
| - CryptString pass_;
|
| - RTC_DISALLOW_COPY_AND_ASSIGN(AsyncSocksProxySocket);
|
| -};
|
| -
|
| -// Implements a proxy server socket for the SOCKS protocol.
|
| -class AsyncSocksProxyServerSocket : public AsyncProxyServerSocket {
|
| - public:
|
| - explicit AsyncSocksProxyServerSocket(AsyncSocket* socket);
|
| -
|
| - private:
|
| - void ProcessInput(char* data, size_t* len) override;
|
| - void DirectSend(const ByteBufferWriter& buf);
|
| -
|
| - void HandleHello(ByteBufferReader* request);
|
| - void SendHelloReply(uint8_t method);
|
| - void HandleAuth(ByteBufferReader* request);
|
| - void SendAuthReply(uint8_t result);
|
| - void HandleConnect(ByteBufferReader* request);
|
| - void SendConnectResult(int result, const SocketAddress& addr) override;
|
| -
|
| - void Error(int error);
|
| -
|
| - static const int kBufferSize = 1024;
|
| - enum State {
|
| - SS_HELLO, SS_AUTH, SS_CONNECT, SS_CONNECT_PENDING, SS_TUNNEL, SS_ERROR
|
| - };
|
| - State state_;
|
| - RTC_DISALLOW_COPY_AND_ASSIGN(AsyncSocksProxyServerSocket);
|
| -};
|
| -
|
| } // namespace rtc
|
|
|
| #endif // WEBRTC_BASE_SOCKETADAPTERS_H_
|
|
|