[Chromoting] The daemon process now starts the networking process and passes the host configuration…

remoting/host/win/worker_process_launcher.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/win/worker_process_launcher.h"
 
 #include <windows.h>
 #include <sddl.h>
 #include <limits>
 
 #include "base/base_switches.h"
 #include "base/bind.h"
 #include "base/bind_helpers.h"
 #include "base/logging.h"
 #include "base/single_thread_task_runner.h"
 #include "base/process_util.h"
 #include "base/rand_util.h"
 #include "base/stringprintf.h"
 #include "base/time.h"
 #include "base/utf_string_conversions.h"
 #include "base/win/scoped_handle.h"
 #include "ipc/ipc_channel_proxy.h"
 #include "ipc/ipc_message.h"
+#include "remoting/host/worker_process_ipc_delegate.h"
 
 using base::win::ScopedHandle;
 
 namespace {
 
 // Match the pipe name prefix used by Chrome IPC channels so that the client
 // could use Chrome IPC APIs instead of connecting manually.
 const char kChromePipeNamePrefix[] = "\\\\.\\pipe\\chrome.";
 
 } // namespace
 
 namespace remoting {
 
 WorkerProcessLauncher::Delegate::~Delegate() {
 }
 
 WorkerProcessLauncher::WorkerProcessLauncher(
-    Delegate* delegate,
+    Delegate* launcher_delegate,
+    WorkerProcessIpcDelegate* worker_delegate,
     const base::Closure& stopped_callback,
     scoped_refptr<base::SingleThreadTaskRunner> main_task_runner,
     scoped_refptr<base::SingleThreadTaskRunner> ipc_task_runner)
     : Stoppable(main_task_runner, stopped_callback),
-      delegate_(delegate),
+      launcher_delegate_(launcher_delegate),
+      worker_delegate_(worker_delegate),
       main_task_runner_(main_task_runner),
       ipc_task_runner_(ipc_task_runner) {
 }
 
 WorkerProcessLauncher::~WorkerProcessLauncher() {
   DCHECK(main_task_runner_->BelongsToCurrentThread());
 }
 
 void WorkerProcessLauncher::Start(const std::string& pipe_sddl) {
   DCHECK(main_task_runner_->BelongsToCurrentThread());
   DCHECK(ipc_channel_.get() == NULL);
   DCHECK(!pipe_.IsValid());
   DCHECK(!process_exit_event_.IsValid());
   DCHECK(process_watcher_.GetWatchedObject() == NULL);
 
   std::string channel_name = GenerateRandomChannelId();
   if (CreatePipeForIpcChannel(channel_name, pipe_sddl, &pipe_)) {
     // Wrap the pipe into an IPC channel.
     ipc_channel_.reset(new IPC::ChannelProxy(
         IPC::ChannelHandle(pipe_),
         IPC::Channel::MODE_SERVER,
         this,
         ipc_task_runner_));
 
     // Launch the process and attach an object watcher to the returned process
     // handle so that we get notified if the process terminates.
-    if (delegate_->DoLaunchProcess(channel_name, &process_exit_event_)) {
+    if (launcher_delegate_->DoLaunchProcess(channel_name,
+                                            &process_exit_event_)) {
       if (process_watcher_.StartWatching(process_exit_event_, this)) {
         return;
       }
 
-      delegate_->DoKillProcess(CONTROL_C_EXIT);
+      launcher_delegate_->DoKillProcess(CONTROL_C_EXIT);
     }
   }
 
   Stop();
 }
 
 void WorkerProcessLauncher::Send(IPC::Message* message) {
   DCHECK(main_task_runner_->BelongsToCurrentThread());
 
-  ipc_channel_->Send(message);
+  if (ipc_channel_.get()) {
+    ipc_channel_->Send(message);
+  } else {
+    delete message;
+  }
 }
 
 void WorkerProcessLauncher::OnObjectSignaled(HANDLE object) {
   DCHECK(main_task_runner_->BelongsToCurrentThread());
   DCHECK(process_watcher_.GetWatchedObject() == NULL);
 
   Stop();
 }
 
 bool WorkerProcessLauncher::OnMessageReceived(const IPC::Message& message) {
   DCHECK(main_task_runner_->BelongsToCurrentThread());
   DCHECK(ipc_channel_.get() != NULL);
   DCHECK(pipe_.IsValid());
   DCHECK(process_exit_event_.IsValid());
 
-  return delegate_->OnMessageReceived(message);
+  return worker_delegate_->OnMessageReceived(message);
 }
 
 void WorkerProcessLauncher::OnChannelConnected(int32 peer_pid) {
   DCHECK(main_task_runner_->BelongsToCurrentThread());
   DCHECK(ipc_channel_.get() != NULL);
   DCHECK(pipe_.IsValid());
   DCHECK(process_exit_event_.IsValid());
 
   // |peer_pid| is send by the client and cannot be trusted.
   // GetNamedPipeClientProcessId() is not available on XP. The pipe's security
   // descriptor is the only protection we currently have against malicious
   // clients.
   //
   // If we'd like to be able to launch low-privileged workers and let them
   // connect back, the pipe handle should be passed to the worker instead of
   // the pipe name.
-  delegate_->OnChannelConnected();
+  worker_delegate_->OnChannelConnected();
 }
 
 void WorkerProcessLauncher::OnChannelError() {
   DCHECK(main_task_runner_->BelongsToCurrentThread());
   DCHECK(ipc_channel_.get() != NULL);
   DCHECK(pipe_.IsValid());
   DCHECK(process_exit_event_.IsValid());
 
   // Schedule a delayed termination of the worker process. Usually, the pipe is
   // disconnected when the worker process is about to exit. Waiting a little bit
   // here allows the worker to exit completely and so, notify
   // |process_watcher_|. As the result DoKillProcess() will not be called and
   // the original exit code reported by the worker process will be retrieved.
   ipc_error_timer_.Start(FROM_HERE, base::TimeDelta::FromSeconds(5),
                          this, &WorkerProcessLauncher::Stop);
 }
 
 void WorkerProcessLauncher::DoStop() {
   DCHECK(main_task_runner_->BelongsToCurrentThread());
 
   ipc_channel_.reset();
   pipe_.Close();
 
   // Kill the process if it has been started already.
   if (process_watcher_.GetWatchedObject() != NULL) {
-    delegate_->DoKillProcess(CONTROL_C_EXIT);
+    launcher_delegate_->DoKillProcess(CONTROL_C_EXIT);
     return;
   }
 
   ipc_error_timer_.Stop();
 
   DCHECK(ipc_channel_.get() == NULL);
   DCHECK(!pipe_.IsValid());
   DCHECK(process_watcher_.GetWatchedObject() == NULL);
 
   process_exit_event_.Close();
@@ skipping 52 matching lines @@
 }
 
 // N.B. Copied from src/content/common/child_process_host_impl.cc
 std::string WorkerProcessLauncher::GenerateRandomChannelId() {
   return base::StringPrintf("%d.%p.%d",
                             base::GetCurrentProcId(), this,
                             base::RandInt(0, std::numeric_limits<int>::max()));
 }
 
 } // namespace remoting