Split ByteBuffer into writer/reader objects.

webrtc/base/socketadapters.h

 /*
  *  Copyright 2004 The WebRTC Project Authors. All rights reserved.
  *
  *  Use of this source code is governed by a BSD-style license
  *  that can be found in the LICENSE file in the root of the source
  *  tree. An additional intellectual property rights grant can be found
  *  in the file PATENTS.  All contributing project authors may
  *  be found in the AUTHORS file in the root of the source tree.
  */
 
 #ifndef WEBRTC_BASE_SOCKETADAPTERS_H_
 #define WEBRTC_BASE_SOCKETADAPTERS_H_
 
 #include <map>
 #include <string>
 
 #include "webrtc/base/asyncsocket.h"
 #include "webrtc/base/cryptstring.h"
 #include "webrtc/base/logging.h"
 
 namespace rtc {
 
 struct HttpAuthContext;
-class ByteBuffer;
+class ByteBufferReader;
+class ByteBufferWriter;
 
 ///////////////////////////////////////////////////////////////////////////////
 
 // Implements a socket adapter that can buffer and process data internally,
 // as in the case of connecting to a proxy, where you must speak the proxy
 // protocol before commencing normal socket behavior.
 class BufferedReadAdapter : public AsyncSocketAdapter {
  public:
   BufferedReadAdapter(AsyncSocket* socket, size_t buffer_size);
   ~BufferedReadAdapter() override;
@@ skipping 151 matching lines @@
   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 ByteBuffer& buf);
+  void DirectSend(const ByteBufferWriter& buf);
 
-  void HandleHello(ByteBuffer* request);
+  void HandleHello(ByteBufferReader* request);
   void SendHelloReply(uint8_t method);
-  void HandleAuth(ByteBuffer* request);
+  void HandleAuth(ByteBufferReader* request);
   void SendAuthReply(uint8_t result);
-  void HandleConnect(ByteBuffer* request);
+  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);
@@ skipping 23 matching lines @@
   bool hex_mode_;
   LogMultilineState lms_;
   RTC_DISALLOW_COPY_AND_ASSIGN(LoggingSocketAdapter);
 };
 
 ///////////////////////////////////////////////////////////////////////////////
 
 }  // namespace rtc
 
 #endif  // WEBRTC_BASE_SOCKETADAPTERS_H_