Add P2PDatagramSocket and P2PStreamSocket interfaces.

remoting/protocol/channel_socket_adapter_unittest.cc

 // 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.
 
 #include "remoting/protocol/channel_socket_adapter.h"
 
 #include "base/memory/ref_counted.h"
 #include "base/memory/scoped_ptr.h"
 #include "base/message_loop/message_loop.h"
 #include "net/base/io_buffer.h"
@@ skipping 70 matching lines @@
   scoped_ptr<TransportChannelSocketAdapter> target_;
   net::CompletionCallback callback_;
   int callback_result_;
   base::MessageLoopForIO message_loop_;
 };
 
 // Verify that Read() returns net::ERR_IO_PENDING.
 TEST_F(TransportChannelSocketAdapterTest, Read) {
   scoped_refptr<IOBuffer> buffer(new IOBuffer(kBufferSize));
 
-  int result = target_->Read(buffer.get(), kBufferSize, callback_);
+  int result = target_->Recv(buffer.get(), kBufferSize, callback_);
   ASSERT_EQ(net::ERR_IO_PENDING, result);
 
   channel_.SignalReadPacket(&channel_, kTestData, kTestDataSize,
                             rtc::CreatePacketTime(0), 0);
   EXPECT_EQ(kTestDataSize, callback_result_);
 }
 
 // Verify that Read() after Close() returns error.
 TEST_F(TransportChannelSocketAdapterTest, ReadClose) {
   scoped_refptr<IOBuffer> buffer(new IOBuffer(kBufferSize));
 
-  int result = target_->Read(buffer.get(), kBufferSize, callback_);
+  int result = target_->Recv(buffer.get(), kBufferSize, callback_);
   ASSERT_EQ(net::ERR_IO_PENDING, result);
 
   target_->Close(kTestError);
   EXPECT_EQ(kTestError, callback_result_);
 
-  // All Read() calls after Close() should return the error.
-  EXPECT_EQ(kTestError, target_->Read(buffer.get(), kBufferSize, callback_));
+  // All Recv() calls after Close() should return the error.
+  EXPECT_EQ(kTestError, target_->Recv(buffer.get(), kBufferSize, callback_));
 }
 
-// Verify that Write sends the packet and returns correct result.
-TEST_F(TransportChannelSocketAdapterTest, Write) {
+// Verify that Send sends the packet and returns correct result.
+TEST_F(TransportChannelSocketAdapterTest, Send) {
   scoped_refptr<IOBuffer> buffer(new IOBuffer(kTestDataSize));
 
   EXPECT_CALL(channel_, SendPacket(buffer->data(), kTestDataSize, _, 0))
       .WillOnce(Return(kTestDataSize));
 
-  int result = target_->Write(buffer.get(), kTestDataSize, callback_);
+  int result = target_->Send(buffer.get(), kTestDataSize, callback_);
   EXPECT_EQ(kTestDataSize, result);
 }
 
-// Verify that the message is still sent if Write() is called while
+// Verify that the message is still sent if Send() is called while
 // socket is not open yet. The result is the packet is lost.
-TEST_F(TransportChannelSocketAdapterTest, WritePending) {
+TEST_F(TransportChannelSocketAdapterTest, SendPending) {
   scoped_refptr<IOBuffer> buffer(new IOBuffer(kTestDataSize));
 
   EXPECT_CALL(channel_, SendPacket(buffer->data(), kTestDataSize, _, 0))
       .Times(1)
       .WillOnce(Return(SOCKET_ERROR));
 
   EXPECT_CALL(channel_, GetError())
       .WillOnce(Return(EWOULDBLOCK));
 
-  int result = target_->Write(buffer.get(), kTestDataSize, callback_);
+  int result = target_->Send(buffer.get(), kTestDataSize, callback_);
   ASSERT_EQ(net::OK, result);
 }
 
 }  // namespace protocol
 }  // namespace remoting