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

remoting/host/daemon_process.h

 // 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.
 
 #ifndef REMOTING_HOST_DAEMON_PROCESS_H_
 #define REMOTING_HOST_DAEMON_PROCESS_H_
 
 #include <list>
 
 #include "base/basictypes.h"
 #include "base/compiler_specific.h"
 #include "base/location.h"
 #include "base/memory/ref_counted.h"
 #include "base/memory/scoped_ptr.h"
+#include "base/process.h"
 #include "ipc/ipc_channel.h"
 #include "ipc/ipc_channel_proxy.h"
+#include "ipc/ipc_platform_file.h"
 #include "remoting/base/stoppable.h"
 #include "remoting/host/config_file_watcher.h"
 #include "remoting/host/worker_process_ipc_delegate.h"
 
 class FilePath;
 
 namespace base {
 class SingleThreadTaskRunner;
 }  // namespace base
 
@@ skipping 28 matching lines @@
 
   // WorkerProcessIpcDelegate implementation.
   virtual void OnChannelConnected(int32 peer_pid) OVERRIDE;
   virtual bool OnMessageReceived(const IPC::Message& message) OVERRIDE;
   virtual void OnPermanentError() OVERRIDE;
 
   // Sends an IPC message to the network process. The message will be dropped
   // unless the network process is connected over the IPC channel.
   virtual void SendToNetwork(IPC::Message* message) = 0;
 
+  // Called when a desktop integration process attaches to |terminal_id|.
+  // |desktop_process| is a handle of the desktop integration process.
+  // |desktop_pipe| specifies the client end of the desktop pipe. Returns true
+  // on success, false otherwise.
+  virtual bool OnDesktopSessionAgentAttached(

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

Does this method need to be public? Maybe make it protected since we don't
expect it to be called from outside.

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

It is called by DesktopSessionWin::OnDesktopSessionAgentAttached().

+      int terminal_id,
+      base::ProcessHandle desktop_process,
+      IPC::PlatformFileForTransit desktop_pipe) = 0;
+
   // Closes the desktop session identified by |terminal_id|.
   void CloseDesktopSession(int terminal_id);
 
  protected:
   DaemonProcess(scoped_refptr<base::SingleThreadTaskRunner> caller_task_runner,
                 scoped_refptr<base::SingleThreadTaskRunner> io_task_runner,
                 const base::Closure& stopped_callback);
 
   // Reads the host configuration and launches the network process.
   void Initialize();
@@ skipping 52 matching lines @@
 
   // The highest desktop session ID that has been seen so far.
   int next_terminal_id_;
 
   DISALLOW_COPY_AND_ASSIGN(DaemonProcess);
 };
 
 }  // namespace remoting
 
 #endif  // REMOTING_HOST_DAEMON_PROCESS_H_