[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"
 #include "base/callback.h"
 #include "base/command_line.h"
 #include "base/file_path.h"
 #include "base/file_util.h"
 #include "base/memory/scoped_ptr.h"
 #include "base/message_loop.h"
 #include "base/scoped_native_library.h"
 #include "base/string_number_conversions.h"
 #include "base/string_util.h"
 #include "base/stringize_macros.h"
 #include "base/synchronization/waitable_event.h"
 #include "base/threading/thread.h"
 #include "base/utf_string_conversions.h"
 #include "base/win/windows_version.h"
 #include "build/build_config.h"
 #include "crypto/nss_util.h"
 #include "google_apis/google_api_keys.h"
 #include "ipc/ipc_channel.h"
 #include "ipc/ipc_channel_proxy.h"
+#include "ipc/ipc_listener.h"
 #include "net/base/network_change_notifier.h"
 #include "net/socket/ssl_server_socket.h"
 #include "remoting/base/auto_thread_task_runner.h"
 #include "remoting/base/breakpad.h"
 #include "remoting/base/constants.h"
 #include "remoting/host/branding.h"
 #include "remoting/host/chromoting_host.h"
 #include "remoting/host/chromoting_host_context.h"
 #include "remoting/host/chromoting_messages.h"
 #include "remoting/host/config_file_watcher.h"
@@ skipping 85 matching lines @@
   bool InitWithCommandLine(const CommandLine* cmd_line);
 
   // ConfigFileWatcher::Delegate interface.
   virtual void OnConfigUpdated(const std::string& serialized_config) OVERRIDE;
   virtual void OnConfigWatcherError() OVERRIDE;
 
   void StartWatchingConfigChanges();
   void CreateAuthenticatorFactory();
 
   // IPC::Listener implementation.
-  virtual bool OnMessageReceived(const IPC::Message& message);
+  virtual bool OnMessageReceived(const IPC::Message& message) OVERRIDE;
+  virtual void OnChannelError() OVERRIDE;
 
   // HeartbeatSender::Listener overrides.
   virtual void OnUnknownHostIdError() OVERRIDE;
 
   void StartHostProcess();
 
   int get_exit_code() const;
 
  private:
 #if defined(OS_POSIX)
@@ skipping 28 matching lines @@
   void RestartHost();
 
   void RestartOnHostShutdown();
 
   void Shutdown(int exit_code);
 
   void OnShutdownFinished();
 
   void ResetHost();
 
+  // Crashes the process in response to a daemon's request. The daemon passes
+  // the location of the code that detected the fatal error resulted in this
+  // request.
+  void OnCrash(const std::string& function_name,
+               const std::string& file_name,
+               const int& line_number);
+
   scoped_ptr<ChromotingHostContext> context_;
   scoped_ptr<IPC::ChannelProxy> daemon_channel_;
   scoped_ptr<net::NetworkChangeNotifier> network_change_notifier_;
 
   FilePath host_config_path_;
   scoped_ptr<ConfigFileWatcher> config_watcher_;
 
   // Accessed on the network thread.
   std::string host_id_;
   protocol::SharedSecretHash host_secret_hash_;
@@ skipping 45 matching lines @@
 #endif  // defined(REMOTING_MULTI_PROCESS)
       exit_code_(kSuccessExitCode) {
   network_change_notifier_.reset(net::NetworkChangeNotifier::Create());
   curtain_ = CurtainMode::Create(
       base::Bind(&HostProcess::OnDisconnectRequested,
                  base::Unretained(this)),
       base::Bind(&HostProcess::RejectAuthenticatingClient,
                  base::Unretained(this)));
 }
 
-// Crashes the process in response to a daemon's request. The daemon passes
-// the location of the code that detected the fatal error resulted in this
-// request.
-void OnCrash(const std::string& function_name,
-             const std::string& file_name,
-             const int& line_number) {
-  CHECK(false);
-}
-
 bool HostProcess::InitWithCommandLine(const CommandLine* cmd_line) {
 #if defined(REMOTING_MULTI_PROCESS)
   // Parse the handle value and convert it to a handle/file descriptor.
   std::string channel_name =
       cmd_line->GetSwitchValueASCII(kDaemonPipeSwitchName);
 
   int pipe_handle = 0;
   if (channel_name.empty() ||
       !base::StringToInt(channel_name, &pipe_handle)) {
     LOG(ERROR) << "Invalid '" << kDaemonPipeSwitchName
@@ skipping 130 matching lines @@
 bool HostProcess::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)
 }
 
+void HostProcess::OnChannelError() {
+  DCHECK(context_->ui_task_runner()->BelongsToCurrentThread());
+
+  // Shutdown the host if the daemon disconnected the channel.
+  context_->network_task_runner()->PostTask(
+      FROM_HERE,
+      base::Bind(&HostProcess::Shutdown, base::Unretained(this),
+                 kSuccessExitCode));
+}
+
 void HostProcess::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 394 matching lines @@
 
   curtaining_host_observer_.reset();
   host_event_logger_.reset();
   log_to_server_.reset();
   heartbeat_sender_.reset();
   signaling_connector_.reset();
   signal_strategy_.reset();
   resizing_host_observer_.reset();
 }
 
+void HostProcess::OnCrash(const std::string& function_name,
+                          const std::string& file_name,
+                          const int& line_number) {
+  CHECK(false);
+}
+
 }  // namespace remoting
 
 int main(int argc, char** argv) {
 #if defined(OS_MACOSX)
   // Needed so we don't leak objects when threads are created.
   base::mac::ScopedNSAutoreleasePool pool;
 #endif
 
   CommandLine::Init(argc, argv);
 
@@ skipping 80 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)