Use ChannelMojo between the remoting network and desktop processes.

remoting/host/daemon_process_win.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 <stdint.h>
 
 #include <memory>
 #include <utility>
 
 #include "base/base_switches.h"
 #include "base/bind.h"
 #include "base/bind_helpers.h"
 #include "base/location.h"
 #include "base/logging.h"
 #include "base/macros.h"
 #include "base/memory/ref_counted.h"
 #include "base/process/process.h"
 #include "base/single_thread_task_runner.h"
 #include "base/strings/utf_string_conversions.h"
 #include "base/time/time.h"
 #include "base/win/registry.h"
 #include "base/win/scoped_handle.h"
 #include "base/win/win_util.h"
+#include "ipc/ipc_channel_handle.h"
 #include "ipc/ipc_message.h"
 #include "ipc/ipc_message_macros.h"
 #include "mojo/edk/embedder/scoped_ipc_support.h"
 #include "remoting/base/auto_thread_task_runner.h"
 #include "remoting/base/scoped_sc_handle_win.h"
 #include "remoting/host/branding.h"
 #include "remoting/host/chromoting_messages.h"
 #include "remoting/host/desktop_session_win.h"
 #include "remoting/host/host_exit_codes.h"
 #include "remoting/host/host_main.h"
@@ skipping 39 matching lines @@
   ~DaemonProcessWin() override;
 
   // WorkerProcessIpcDelegate implementation.
   void OnChannelConnected(int32_t peer_pid) override;
   void OnPermanentError(int exit_code) override;
 
   // DaemonProcess overrides.
   void SendToNetwork(IPC::Message* message) override;
   bool OnDesktopSessionAgentAttached(
       int terminal_id,
-      base::ProcessHandle desktop_process,
-      IPC::PlatformFileForTransit desktop_pipe) override;
+      const IPC::ChannelHandle& desktop_pipe) override;
 
  protected:
   // DaemonProcess implementation.
   std::unique_ptr<DesktopSession> DoCreateDesktopSession(
       int terminal_id,
       const ScreenResolution& resolution,
       bool virtual_terminal) override;
   void DoCrashNetworkProcess(
       const tracked_objects::Location& location) override;
   void LaunchNetworkProcess() override;
@@ skipping 70 matching lines @@
 void DaemonProcessWin::SendToNetwork(IPC::Message* message) {
   if (network_launcher_) {
     network_launcher_->Send(message);
   } else {
     delete message;
   }
 }
 
 bool DaemonProcessWin::OnDesktopSessionAgentAttached(
     int terminal_id,
-    base::ProcessHandle desktop_process,
-    IPC::PlatformFileForTransit desktop_pipe) {
-  // Prepare |desktop_process| handle for sending over to the network process.
-  base::ProcessHandle desktop_process_for_transit;
-  if (!DuplicateHandle(GetCurrentProcess(),
-                       desktop_process,
-                       network_process_.Get(),
-                       &desktop_process_for_transit,
-                       0,
-                       FALSE,
-                       DUPLICATE_SAME_ACCESS)) {
-    PLOG(ERROR) << "Failed to duplicate the desktop process handle";
-    return false;
-  }
-
-  // |desktop_pipe| is a handle in the desktop process. It will be duplicated
-  // by the network process directly from the desktop process.
+    const IPC::ChannelHandle& desktop_pipe) {
   SendToNetwork(new ChromotingDaemonNetworkMsg_DesktopAttached(
-      terminal_id, desktop_process_for_transit, desktop_pipe));
+      terminal_id, desktop_pipe));
   return true;
 }
 
 std::unique_ptr<DesktopSession> DaemonProcessWin::DoCreateDesktopSession(
     int terminal_id,
     const ScreenResolution& resolution,
     bool virtual_terminal) {
   DCHECK(caller_task_runner()->BelongsToCurrentThread());
 
   if (virtual_terminal) {
@@ skipping 179 matching lines @@
                 << "\\" << kPairingRegistrySecretsKeyName;
     return false;
   }
 
   pairing_registry_privileged_key_.Set(privileged.Take());
   pairing_registry_unprivileged_key_.Set(unprivileged.Take());
   return true;
 }
 
 }  // namespace remoting