[Chromoting] Add DataChannelManager to manage optional incoming data channels

remoting/protocol/fake_message_pipe.h

Index: remoting/protocol/fake_message_pipe.h
diff --git a/remoting/protocol/fake_message_pipe.h b/remoting/protocol/fake_message_pipe.h
new file mode 100644
index 0000000000000000000000000000000000000000..6be457b1c62272136989cdb7591a295eaf47efd8
--- /dev/null
+++ b/remoting/protocol/fake_message_pipe.h
@@ -0,0 +1,66 @@
+// Copyright 2017 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_MESSAGE_PIPE_H_
+#define REMOTING_PROTOCOL_FAKE_MESSAGE_PIPE_H_
+
+#include <memory>
+
+#include "remoting/protocol/message_pipe.h"
+
+namespace google {
+namespace protobuf {
+class MessageLite;
+}  // namespace protobuf
+}  // namespace google
+
+namespace remoting {
+namespace protocol {
+
+class FakeMessagePipeWrapper;
+
+class FakeMessagePipe final : public MessagePipe {
+ public:
+  explicit FakeMessagePipe(bool asynchronous);
+  ~FakeMessagePipe() override;
+
+  // Creates an std::unique_ptr<FakeMessagePipeWrapper> instance to wrap |this|.
+  // All operations will be forwarded to |this| except for the destructor.
+  //
+  // Most of the components take ownership of std::unique_ptr<MessagePipe>,
+  // which makes the test cases hard to maintain the lifetime of a
+  // FakeMessagePipe. So this function creates a "weak" unique_ptr of this
+  // instance to let the test case decide the lifetime of a FakeMessagePipe.
+  std::unique_ptr<FakeMessagePipeWrapper> Wrap();
+
+  // MessagePipe implementation.
+  void Start(EventHandler* event_handler) override;
+  void Send(google::protobuf::MessageLite* message,
+            const base::Closure& done) override;
+
+  // Forwards |message| to EventHandler.
+  void Receive(std::unique_ptr<CompoundBuffer> message);
+
+  // Simulates the operation to open the pipe.
+  void OpenPipe();
+
+  // Simulates the operation to close the pipe.
+  void ClosePipe();
+
+ private:
+  void SendImpl(google::protobuf::MessageLite* message,
+                const base::Closure& done);
+  void ReceiveImpl(std::unique_ptr<CompoundBuffer> message);
+  void OpenPipeImpl();
+  void ClosePipeImpl();
+
+  const bool asynchronous_;
+  bool pipe_opened_ = false;
+  EventHandler* event_handler_ = nullptr;
+};
+
+}  // namespace protocol
+}  // namespace remoting
+
+#endif  // REMOTING_PROTOCOL_FAKE_MESSAGE_PIPE_H_