Add P2PDatagramSocket and P2PStreamSocket interfaces.

remoting/protocol/pseudotcp_adapter.h

 // Copyright 2015 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 REMOTING_PROTOCOL_PSEUDOTCP_ADAPTER_H_
 #define REMOTING_PROTOCOL_PSEUDOTCP_ADAPTER_H_
 
 #include "base/basictypes.h"
 #include "base/compiler_specific.h"
 #include "base/memory/ref_counted.h"
 #include "base/memory/scoped_ptr.h"
 #include "base/threading/non_thread_safe.h"
 #include "net/log/net_log.h"
-#include "net/socket/stream_socket.h"
+#include "remoting/protocol/p2p_socket.h"
 #include "third_party/webrtc/p2p/base/pseudotcp.h"
 
 namespace remoting {
 namespace protocol {
 
-// PseudoTcpAdapter adapts a connectionless net::Socket to a connection-
-// oriented net::StreamSocket using PseudoTcp.  Because net::StreamSockets
-// can be deleted during callbacks, while PseudoTcp cannot, the core of the
-// PseudoTcpAdapter is reference counted, with a reference held by the
-// adapter, and an additional reference held on the stack during callbacks.
-class PseudoTcpAdapter : public net::StreamSocket, base::NonThreadSafe {
+// PseudoTcpAdapter adapts a P2PDatagramSocket to P2PStreamSocket using
+// PseudoTcp. Because net::StreamSockets can be deleted during callbacks,

[Wez, 2015/06/22 15:49:07]

nit: Because P2PStreamSockets...

[Sergey Ulanov, 2015/07/10 00:49:54]

Done.

+// while PseudoTcp cannot, the core of the PseudoTcpAdapter is reference
+// counted, with a reference held by the adapter, and an additional reference
+// held on the stack during callbacks.
+class PseudoTcpAdapter : public P2PStreamSocket, base::NonThreadSafe {
  public:
-  explicit PseudoTcpAdapter(scoped_ptr<net::Socket> socket);
+  explicit PseudoTcpAdapter(scoped_ptr<P2PDatagramSocket> socket);
   ~PseudoTcpAdapter() override;
 
-  // net::Socket implementation.
+  // P2PStreamSocket implementation.
   int Read(net::IOBuffer* buffer,
            int buffer_size,
            const net::CompletionCallback& callback) override;
   int Write(net::IOBuffer* buffer,
             int buffer_size,
             const net::CompletionCallback& callback) override;
   int SetReceiveBufferSize(int32 size) override;
   int SetSendBufferSize(int32 size) override;
 
-  // net::StreamSocket implementation.
-  int Connect(const net::CompletionCallback& callback) override;
-  void Disconnect() override;
-  bool IsConnected() const override;
-  bool IsConnectedAndIdle() const override;
-  int GetPeerAddress(net::IPEndPoint* address) const override;
-  int GetLocalAddress(net::IPEndPoint* address) const override;
-  const net::BoundNetLog& NetLog() const override;
-  void SetSubresourceSpeculation() override;
-  void SetOmniboxSpeculation() override;
-  bool WasEverUsed() const override;
-  bool UsingTCPFastOpen() const override;
-  bool WasNpnNegotiated() const override;
-  net::NextProto GetNegotiatedProtocol() const override;
-  bool GetSSLInfo(net::SSLInfo* ssl_info) override;
-  void GetConnectionAttempts(net::ConnectionAttempts* out) const override;
-  void ClearConnectionAttempts() override {}
-  void AddConnectionAttempts(const net::ConnectionAttempts& attempts) override {
-  }
+  int Connect(const net::CompletionCallback& callback);
 
   // Set the delay for sending ACK.
   void SetAckDelay(int delay_ms);
 
   // Set whether Nagle's algorithm is enabled.
   void SetNoDelay(bool no_delay);
 
   // When write_waits_for_send flag is set to true the Write() method
   // will wait until the data is sent to the remote end before the
   // write completes (it still doesn't wait until the data is received
@@ skipping 19 matching lines @@
 
   net::BoundNetLog net_log_;
 
   DISALLOW_COPY_AND_ASSIGN(PseudoTcpAdapter);
 };
 
 }  // namespace protocol
 }  // namespace remoting
 
 #endif  // REMOTING_PROTOCOL_PSEUDOTCP_ADAPTER_H_