Crash the network process when a fatal daemon-to-network protocol error encountered.

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"
@@ skipping 60 matching lines @@
 }
 
 void DaemonProcess::CloseDesktopSession(int terminal_id) {
   DCHECK(caller_task_runner()->BelongsToCurrentThread());
 
   // Validate the supplied terminal ID. An attempt to close a desktop session
   // with an ID that couldn't possibly have been allocated is considered
   // a protocol error and the network process will be restarted.
   if (!IsTerminalIdKnown(terminal_id)) {
     LOG(ERROR) << "An invalid terminal ID. terminal_id=" << terminal_id;
-    RestartNetworkProcess();
+    CrashNetworkProcess(FROM_HERE);
     DeleteAllDesktopSessions();
     return;
   }
 
   DesktopSessionList::iterator i;
   for (i = desktop_sessions_.begin(); i != desktop_sessions_.end(); ++i) {
     if ((*i)->id() == terminal_id) {
       break;
     }
   }
@@ skipping 16 matching lines @@
     scoped_refptr<base::SingleThreadTaskRunner> caller_task_runner,
     scoped_refptr<base::SingleThreadTaskRunner> io_task_runner,
     const base::Closure& stopped_callback)
     : Stoppable(caller_task_runner, stopped_callback),
       caller_task_runner_(caller_task_runner),
       io_task_runner_(io_task_runner),
       next_terminal_id_(0) {
   DCHECK(caller_task_runner->BelongsToCurrentThread());
 }
 
-void DaemonProcess::Initialize() {
-  DCHECK(caller_task_runner()->BelongsToCurrentThread());
-
-  // 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 ConfigFileWatcher(caller_task_runner(),
-                                              io_task_runner(),
-                                              this));
-  config_watcher_->Watch(config_path);
-
-  // Launch the process.
-  LaunchNetworkProcess();
-}
-
 bool DaemonProcess::IsTerminalIdKnown(int terminal_id) {
   return terminal_id < next_terminal_id_;
 }
 
 void DaemonProcess::CreateDesktopSession(int terminal_id) {
   DCHECK(caller_task_runner()->BelongsToCurrentThread());
 
   // Validate the supplied terminal ID. An attempt to create a desktop session
   // with an ID that could possibly have been allocated already is considered
   // a protocol error and the network process will be restarted.
   if (IsTerminalIdKnown(terminal_id)) {
     LOG(ERROR) << "An invalid terminal ID. terminal_id=" << terminal_id;
-    RestartNetworkProcess();
+    CrashNetworkProcess(FROM_HERE);
     DeleteAllDesktopSessions();
     return;
   }
 
   VLOG(1) << "Daemon: opened desktop session " << terminal_id;
   desktop_sessions_.push_back(
       DoCreateDesktopSession(terminal_id).release());
   next_terminal_id_ = std::max(next_terminal_id_, terminal_id + 1);
 }
 
+void DaemonProcess::CrashNetworkProcess(
+    const tracked_objects::Location& location) {
+  SendToNetwork(new ChromotingDaemonNetworkMsg_Crash(
+      location.function_name(), location.file_name(), location.line_number()));
+}
+
+void DaemonProcess::Initialize() {
+  DCHECK(caller_task_runner()->BelongsToCurrentThread());
+
+  // 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 ConfigFileWatcher(caller_task_runner(),
+                                              io_task_runner(),
+                                              this));
+  config_watcher_->Watch(config_path);
+
+  // Launch the process.
+  LaunchNetworkProcess();
+}
+
 void DaemonProcess::DoStop() {
   DCHECK(caller_task_runner()->BelongsToCurrentThread());
 
   config_watcher_.reset();
   DeleteAllDesktopSessions();
 
   CompleteStopping();
 }
 
 void DaemonProcess::DeleteAllDesktopSessions() {
   while (!desktop_sessions_.empty()) {
     delete desktop_sessions_.front();
     desktop_sessions_.pop_front();
   }
 }
 
 }  // namespace remoting