[Chromoting] Add DataChannelManager to manage optional incoming data channels

remoting/protocol/named_message_pipe_handler.cc

Index: remoting/protocol/named_message_pipe_handler.cc
diff --git a/remoting/protocol/named_message_pipe_handler.cc b/remoting/protocol/named_message_pipe_handler.cc
new file mode 100644
index 0000000000000000000000000000000000000000..4741d57a02244ae5ff56db52e532010102b32cb1
--- /dev/null
+++ b/remoting/protocol/named_message_pipe_handler.cc
@@ -0,0 +1,69 @@
+// 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.
+
+#include "remoting/protocol/named_message_pipe_handler.h"
+
+#include <utility>
+
+#include "base/location.h"
+#include "base/logging.h"
+#include "base/threading/thread_task_runner_handle.h"
+#include "remoting/base/compound_buffer.h"
+
+namespace remoting {
+namespace protocol {
+
+NamedMessagePipeHandler::NamedMessagePipeHandler(
+    const std::string& name,
+    std::unique_ptr<MessagePipe> pipe)
+    : name_(name),
+      pipe_(std::move(pipe)) {
+  DCHECK(pipe_);
+  pipe_->Start(this);
+}
+
+NamedMessagePipeHandler::~NamedMessagePipeHandler() = default;
+
+void NamedMessagePipeHandler::Close() {
+  DCHECK(thread_checker_.CalledOnValidThread());
+  if (connected()) {
+    OnDisconnecting();
+    is_connected_ = false;
+  }
+  delete this;
+}
+
+void NamedMessagePipeHandler::Send(google::protobuf::MessageLite* message,
+                              const base::Closure& done) {
+  DCHECK(thread_checker_.CalledOnValidThread());
+  DCHECK(connected());
+  pipe_->Send(message, done);
+}
+
+void NamedMessagePipeHandler::OnIncomingMessage(
+    std::unique_ptr<CompoundBuffer> message) {}
+
+void NamedMessagePipeHandler::OnConnected() {}
+
+void NamedMessagePipeHandler::OnDisconnecting() {}
+
+void NamedMessagePipeHandler::OnMessagePipeOpen() {
+  DCHECK(thread_checker_.CalledOnValidThread());
+  DCHECK(!is_connected_);
+  is_connected_ = true;
+  OnConnected();
+}
+
+void NamedMessagePipeHandler::OnMessageReceived(
+    std::unique_ptr<CompoundBuffer> message) {
+  DCHECK(thread_checker_.CalledOnValidThread());
+  OnIncomingMessage(std::move(message));
+}
+
+void NamedMessagePipeHandler::OnMessagePipeClosed() {
+  Close();
+}
+
+}  // namespace protocol
+}  // namespace remoting