Implement QuicChannel and QuicChannelFactory

remoting/protocol/fake_datagram_socket.h

 // Copyright 2014 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_FAKE_DATAGRAM_SOCKET_H_
 #define REMOTING_PROTOCOL_FAKE_DATAGRAM_SOCKET_H_
 
 #include <map>
 #include <string>
 #include <vector>
@@ skipping 23 matching lines @@
 // sockets |a| and |b| must be created and used on the same thread.
 class FakeDatagramSocket : public P2PDatagramSocket {
  public:
   FakeDatagramSocket();
   ~FakeDatagramSocket() override;
 
   const std::vector<std::string>& written_packets() const {
     return written_packets_;
   }
 
+  // Enables asynchronous Write().
+  void set_async_send(bool async_send) { async_send_ = async_send; }
+
+  // Set error codes for the next Write() call. Once returned the
+  // value is automatically reset to net::OK .
+  void set_next_send_error(int error) { next_send_error_ = error; }
+
   void AppendInputPacket(const std::string& data);
 
   // Current position in the input in number of packets, i.e. number of finished
   // Recv() calls.
   int input_pos() const { return input_pos_; }
 
   // Pairs the socket with |peer_socket|. Deleting either of the paired sockets
   // unpairs them.
   void PairWith(FakeDatagramSocket* peer_socket);
 
   base::WeakPtr<FakeDatagramSocket> GetWeakPtr();
 
   // P2PDatagramSocket implementation.
   int Recv(const scoped_refptr<net::IOBuffer>& buf, int buf_len,
            const net::CompletionCallback& callback) override;
   int Send(const scoped_refptr<net::IOBuffer>& buf, int buf_len,
            const net::CompletionCallback& callback) override;
 
  private:
   int CopyReadData(const scoped_refptr<net::IOBuffer>& buf, int buf_len);
 
+  void DoAsyncSend(const scoped_refptr<net::IOBuffer>& buf, int buf_len,
+                   const net::CompletionCallback& callback);
+  int DoSend(const scoped_refptr<net::IOBuffer>& buf, int buf_len);
+
+  bool async_send_ = false;
+  bool send_pending_ = false;
+  int next_send_error_ = 0;
+
   base::WeakPtr<FakeDatagramSocket> peer_socket_;
 
   scoped_refptr<net::IOBuffer> read_buffer_;
   int read_buffer_size_;
   net::CompletionCallback read_callback_;
 
   std::vector<std::string> written_packets_;
   std::vector<std::string> input_packets_;
   int input_pos_;
 
@@ skipping 46 matching lines @@
 
   base::WeakPtrFactory<FakeDatagramChannelFactory> weak_factory_;
 
   DISALLOW_COPY_AND_ASSIGN(FakeDatagramChannelFactory);
 };
 
 }  // namespace protocol
 }  // namespace remoting
 
 #endif  // REMOTING_PROTOCOL_FAKE_DATAGRAM_SOCKET_H_