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

remoting/host/remoting_me2me_host.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.
 //
 // This file implements a standalone host process for Me2Me.
 
 #include <string>
 
 #include "base/at_exit.h"
 #include "base/bind.h"
@@ skipping 291 matching lines @@
   virtual bool OnMessageReceived(const IPC::Message& message) {
     DCHECK(context_->ui_task_runner()->BelongsToCurrentThread());
 
 #if defined(REMOTING_MULTI_PROCESS)
     bool handled = true;
     IPC_BEGIN_MESSAGE_MAP(HostProcess, message)
       IPC_MESSAGE_HANDLER(ChromotingDaemonNetworkMsg_Crash,
                           OnCrash)
       IPC_MESSAGE_HANDLER(ChromotingDaemonNetworkMsg_Configuration,
                           OnConfigUpdated)
+      IPC_MESSAGE_FORWARD(
+          ChromotingDaemonNetworkMsg_DesktopAttached,
+          desktop_session_connector_,
+          DesktopSessionConnector::OnDesktopSessionAgentAttached)
       IPC_MESSAGE_FORWARD(ChromotingDaemonNetworkMsg_TerminalDisconnected,
                           desktop_session_connector_,
                           DesktopSessionConnector::OnTerminalDisconnected)
       IPC_MESSAGE_UNHANDLED(handled = false)
     IPC_END_MESSAGE_MAP()
     return handled;
 #else  // !defined(REMOTING_MULTI_PROCESS)
     return false;
 #endif  // !defined(REMOTING_MULTI_PROCESS)
   }
 
+  // Shutdown the host if the daemon disconnected the channel.
+  virtual void OnChannelError() OVERRIDE {
+    DCHECK(context_->ui_task_runner()->BelongsToCurrentThread());
+
+    context_->network_task_runner()->PostTask(
+        FROM_HERE,
+        base::Bind(&HostProcess::Shutdown, base::Unretained(this),
+                   kSuccessExitCode));
+  }
+
   void StartHostProcess() {
     DCHECK(context_->ui_task_runner()->BelongsToCurrentThread());
 
     if (!InitWithCommandLine(CommandLine::ForCurrentProcess())) {
       OnConfigWatcherError();
       return;
     }
 
     // Create a desktop environment factory appropriate to the build type &
     // platform.
@@ skipping 538 matching lines @@
             user32.GetFunctionPointer("SetProcessDPIAware"));
     set_process_dpi_aware();
   }
 
   // CommandLine::Init() ignores the passed |argc| and |argv| on Windows getting
   // the command line from GetCommandLineW(), so we can safely pass NULL here.
   return main(0, NULL);
 }
 
 #endif  // defined(OS_WIN)