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

remoting/host/daemon_process.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 "base/bind.h"
 #include "base/bind_helpers.h"
+#include "base/command_line.h"
+#include "base/file_path.h"
+#include "base/file_util.h"
 #include "base/single_thread_task_runner.h"
-#include "base/threading/thread.h"
-
-namespace {
-
-const char kIpcThreadName[] = "Daemon process IPC";
-
-}  // namespace
+#include "remoting/host/branding.h"
+#include "remoting/host/chromoting_messages.h"
 
 namespace remoting {
 
 DaemonProcess::~DaemonProcess() {
+  CHECK(!config_watcher_.get());
+}
+
+void DaemonProcess::OnConfigUpdated(const std::string& config) {
+  if (config_ != config) {
+    config_ = config;
+    Send(new ChromotingDaemonNetworkMsg_Configuration(config_));
+  }
+}
+
+void DaemonProcess::OnConfigWatcherError() {
+  Stop();
+}
+
+void DaemonProcess::OnChannelConnected() {
+  DCHECK(main_task_runner()->BelongsToCurrentThread());
+
+  // Send the configuration to the network process.
+  Send(new ChromotingDaemonNetworkMsg_Configuration(config_));
 }
 
 bool DaemonProcess::OnMessageReceived(const IPC::Message& message) {
-  return true;
+  DCHECK(main_task_runner()->BelongsToCurrentThread());
+
+  return false;
 }
 
 DaemonProcess::DaemonProcess(
     scoped_refptr<base::SingleThreadTaskRunner> main_task_runner,
     scoped_refptr<base::SingleThreadTaskRunner> io_task_runner,
     const base::Closure& stopped_callback)
     : Stoppable(main_task_runner, stopped_callback),
       main_task_runner_(main_task_runner),
-      io_task_runner_(io_task_runner) {
+      io_task_runner_(io_task_runner),
+      ALLOW_THIS_IN_INITIALIZER_LIST(weak_factory_(this)) {
   // Initialize on the same thread that will be used for shutting down.
   main_task_runner_->PostTask(
     FROM_HERE,
-    base::Bind(&DaemonProcess::Init, base::Unretained(this)));
+    base::Bind(&DaemonProcess::Initialize, base::Unretained(this)));
 }
 
-void DaemonProcess::Init() {
-  DCHECK(main_task_runner_->BelongsToCurrentThread());
+void DaemonProcess::Initialize() {
+  DCHECK(main_task_runner()->BelongsToCurrentThread());
 
-  if (!LaunchNetworkProcess()) {
-    LOG(ERROR) << "Failed to launch the networking process.";
-    Stop();
-    return;
+  // Get the name of the host configuration file.
+  FilePath default_config_dir = remoting::GetConfigDir();
+  FilePath config_path = default_config_dir.Append(kDefaultHostConfigFile);
+  const CommandLine* command_line = CommandLine::ForCurrentProcess();
+  if (command_line->HasSwitch(kHostConfigSwitchName)) {
+    config_path = command_line->GetSwitchValuePath(kHostConfigSwitchName);
   }
+
+  // Start watching the host configuration file.
+  config_watcher_.reset(new DaemonConfigWatcher(main_task_runner(),
+                                                io_task_runner(),
+                                                weak_factory_.GetWeakPtr()));
+  config_watcher_->Watch(config_path);
+
+  // Launch the process.
+  LaunchNetworkProcess();
 }
 
 void DaemonProcess::DoStop() {
-  DCHECK(main_task_runner_->BelongsToCurrentThread());
+  DCHECK(main_task_runner()->BelongsToCurrentThread());
+
+  weak_factory_.InvalidateWeakPtrs();
+  if (config_watcher_.get()) {
+    DaemonConfigWatcher* config_watcher = config_watcher_.get();

[Wez, 2012/08/24 22:20:38]

Why do you need this?

[alexeypa (please no reviews), 2012/08/27 23:16:41]

I wasn't sure that -> will be evaluated before config_watcher_.Pass(). This is
not needed any more.

+    config_watcher->Stop(config_watcher_.Pass());
+  }
 
   CompleteStopping();
 }
 
+void DaemonProcess::SendConfig(const std::string& config) {
+  DCHECK(main_task_runner()->BelongsToCurrentThread());
+
+  if (config_ != config) {
+    config_ = config;
+    Send(new ChromotingDaemonNetworkMsg_Configuration(config_));
+  }
+}
+
 }  // namespace remoting