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

remoting/host/daemon_process.cc

 // 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/daemon_process.h"
 
 #include "base/bind.h"
 #include "base/bind_helpers.h"
 #include "base/command_line.h"
 #include "base/file_path.h"
 #include "base/file_util.h"
 #include "base/single_thread_task_runner.h"
+#include "remoting/base/auto_thread_task_runner.h"
 #include "remoting/host/branding.h"
 #include "remoting/host/chromoting_messages.h"
 #include "remoting/host/desktop_session.h"
 
 namespace remoting {
 
 DaemonProcess::~DaemonProcess() {
   DCHECK(!config_watcher_.get());
   DCHECK(desktop_sessions_.empty());
 }
@@ skipping 10 matching lines @@
 
 void DaemonProcess::OnConfigWatcherError() {
   DCHECK(caller_task_runner()->BelongsToCurrentThread());
 
   Stop();
 }
 
 void DaemonProcess::OnChannelConnected(int32 peer_pid) {
   DCHECK(caller_task_runner()->BelongsToCurrentThread());
 
+  VLOG(1) << "IPC: daemon <- network (" << peer_pid << ")";
+
   DeleteAllDesktopSessions();
 
   // Reset the last known terminal ID because no IDs have been allocated
   // by the the newly started process yet.
   next_terminal_id_ = 0;
 
   // Send the configuration to the network process.
   SendToNetwork(
       new ChromotingDaemonNetworkMsg_Configuration(serialized_config_));
 }
@@ skipping 45 matching lines @@
 
   delete *i;
   desktop_sessions_.erase(i);
 
   VLOG(1) << "Daemon: closed desktop session " << terminal_id;
   SendToNetwork(
       new ChromotingDaemonNetworkMsg_TerminalDisconnected(terminal_id));
 }
 
 DaemonProcess::DaemonProcess(
-    scoped_refptr<base::SingleThreadTaskRunner> caller_task_runner,
-    scoped_refptr<base::SingleThreadTaskRunner> io_task_runner,
+    scoped_refptr<AutoThreadTaskRunner> caller_task_runner,
+    scoped_refptr<AutoThreadTaskRunner> io_task_runner,
     const base::Closure& stopped_callback)
     : Stoppable(caller_task_runner, stopped_callback),
       caller_task_runner_(caller_task_runner),
       io_task_runner_(io_task_runner),
       next_terminal_id_(0) {
   DCHECK(caller_task_runner->BelongsToCurrentThread());
 }
 
 bool DaemonProcess::IsTerminalIdKnown(int terminal_id) {
   return terminal_id < next_terminal_id_;
@@ skipping 55 matching lines @@
 }
 
 void DaemonProcess::DeleteAllDesktopSessions() {
   while (!desktop_sessions_.empty()) {
     delete desktop_sessions_.front();
     desktop_sessions_.pop_front();
   }
 }
 
 }  // namespace remoting