Chromoting: Implemented security attention sequence (SAS) emulation on Windows.

remoting/host/host_service_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.
 //
 // This file implements the Windows service controlling Me2Me host processes
 // running within user sessions.
 
 #include "remoting/host/host_service_win.h"
 
 #include <windows.h>
 #include <wtsapi32.h>
 #include <stdio.h>
 
 #include "base/at_exit.h"
 #include "base/base_paths.h"
 #include "base/bind.h"
 #include "base/command_line.h"
 #include "base/file_util.h"
 #include "base/logging.h"
 #include "base/message_loop.h"
 #include "base/path_service.h"
 #include "base/stringprintf.h"
+#include "base/threading/thread.h"
 #include "base/utf_string_conversions.h"
 #include "base/win/wrapped_window_proc.h"
 
 #include "remoting/host/host_service_resource.h"
 #include "remoting/base/scoped_sc_handle_win.h"
 #include "remoting/host/wts_console_observer_win.h"
 #include "remoting/host/wts_session_process_launcher_win.h"
 
 using base::StringPrintf;
 
 namespace {
 
 // Service name.
 const char kServiceName[] = "chromoting";
 // TODO(alexeypa): investigate and migrate this over to Chrome's i18n framework.
 const char kMuiStringFormat[] = "@%ls,-%d";
 const char kServiceDependencies[] = "";
 
 const char kServiceCommandLineFormat[] = "\"%ls\" --host-binary=\"%ls\"";
 
 const DWORD kServiceStopTimeoutMs = 30 * 1000;
 
 // Session id that does not represent any session.
 const uint32 kInvalidSession = 0xffffffff;
 
+const char kIoThreadName[] = "I/O thread";
+
 // A window class for the session change notifications window.
 static const char kSessionNotificationWindowClass[] =
   "Chromoting_SessionNotificationWindow";
 
 // Command line actions and switches:
 // "run" sumply runs the service as usual.
 const char kRunActionName[] = "run";
 
 // "install" requests the service to be installed.
 const char kInstallActionName[] = "install";
@@ skipping 286 matching lines @@
 
   printf("The service has been removed successfully.\n");
   return kSuccessExitCode;
 }
 
 int HostService::Run() {
   return (this->*run_routine_)();
 }
 
 void HostService::RunMessageLoop() {
-  WtsSessionProcessLauncher launcher(this, host_binary_);
+  // Launch the I/O thread.
+  base::Thread io_thread(kIoThreadName);
+  base::Thread::Options io_thread_options(MessageLoop::TYPE_IO, 0);
+  if (!io_thread.StartWithOptions(io_thread_options)) {
+    shutting_down_ = true;
+    stopped_event_.Signal();
+    return;
+  }
+
+  WtsSessionProcessLauncher launcher(this, host_binary_, &io_thread);
 
   // Run the service.
   message_loop_->Run();
 
   // Clean up the observers by emulating detaching from the console.
   shutting_down_ = true;
   OnSessionChange();
 
   // Release the control handler.
   stopped_event_.Signal();
@@ skipping 202 matching lines @@
   }
 
   remoting::HostService* service = remoting::HostService::GetInstance();
   if (!service->InitWithCommandLine(command_line)) {
     usage(argv[0]);
     return kUsageExitCode;
   }
 
   return service->Run();
 }