[Chromoting] The desktop process now creates a pre-connected pipe and passes (with some help of the…

remoting/host/desktop_session_agent.cc

Index: remoting/host/desktop_session_agent.cc
diff --git a/remoting/host/desktop_session_agent.cc b/remoting/host/desktop_session_agent.cc
new file mode 100644
index 0000000000000000000000000000000000000000..bc5819731b28fc37420ddf6736f1ca4248072b41
--- /dev/null
+++ b/remoting/host/desktop_session_agent.cc
@@ -0,0 +1,61 @@
+// Copyright (c) 2012 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/host/desktop_session_agent.h"
+
+#include "base/logging.h"
+#include "base/single_thread_task_runner.h"
+#include "ipc/ipc_channel_proxy.h"
+#include "ipc/ipc_message.h"
+#include "ipc/ipc_message_macros.h"
+#include "remoting/host/chromoting_messages.h"
+
+namespace remoting {
+
+DesktopSessionAgent::~DesktopSessionAgent() {
+  DCHECK(caller_task_runner()->BelongsToCurrentThread());
+}
+
+bool DesktopSessionAgent::OnMessageReceived(const IPC::Message& message) {
+  DCHECK(caller_task_runner()->BelongsToCurrentThread());
+
+  NOTIMPLEMENTED();
+  return false;
+}
+
+void DesktopSessionAgent::OnChannelConnected(int32 peer_pid) {
+  DCHECK(caller_task_runner()->BelongsToCurrentThread());
+
+  VLOG(1) << "IPC: desktop <- network (" << peer_pid << ")";
+
+  NOTIMPLEMENTED();
+}
+
+void DesktopSessionAgent::OnChannelError() {
+  DCHECK(caller_task_runner()->BelongsToCurrentThread());
+
+  // Make sure the channel is closed.
+  network_channel_.reset();
+
+  // Notify the caller that |this| can be destroyed now.
+  done_task_.Run();
+}
+
+bool DesktopSessionAgent::Start(const base::Closure& done_task,
+                                IPC::PlatformFileForTransit* desktop_pipe_out) {
+  DCHECK(caller_task_runner()->BelongsToCurrentThread());
+
+  done_task_ = done_task;
+  return DoCreateNetworkChannel(desktop_pipe_out, &network_channel_);
+}
+
+DesktopSessionAgent::DesktopSessionAgent(
+    scoped_refptr<base::SingleThreadTaskRunner> caller_task_runner,
+    scoped_refptr<base::SingleThreadTaskRunner> io_task_runner)
+    : caller_task_runner_(caller_task_runner),
+      io_task_runner_(io_task_runner) {
+  DCHECK(caller_task_runner_->BelongsToCurrentThread());

[Sergey Ulanov, 2012/10/24 20:12:01]

It might be better to use base::ThreadTaskRunnerHandle::Get() here to get
current task runner - that way you won't need two arguments.

[alexeypa (please no reviews), 2012/10/24 21:41:51]

base::ThreadTaskRunnerHandle::Get() will give me a pointer to message_loop_proxy
exposed by the message loop. I, however, need AutoThreadTaskRunner that makes
sure that the message loop will continue run until all references to
AutoThreadTaskRunner are gone.

I updated a bunch of base::SingleThreadTaskRunner to be AutoThreadTaskRunners.
I'll gradually update others.

+}
+
+}  // namespace remoting