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

remoting/host/remoting_me2me_host.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 a standalone host process for Me2Me, which is currently
 // used for the Linux-only Virtual Me2Me build.
 
 #if defined(OS_WIN)
 #include <windows.h>
 #endif
 
 #include <string>
 
 #include "base/at_exit.h"
 #include "base/bind.h"
 #include "base/callback.h"
 #include "base/command_line.h"
 #include "base/file_path.h"
 #include "base/file_util.h"
 #include "base/logging.h"
+#include "base/memory/scoped_ptr.h"
 #include "base/message_loop.h"
 #include "base/path_service.h"
 #include "base/threading/thread.h"
 #include "build/build_config.h"
 #include "crypto/nss_util.h"
 #include "net/base/network_change_notifier.h"
 #include "remoting/base/constants.h"
 #include "remoting/host/capturer.h"
 #include "remoting/host/chromoting_host.h"
 #include "remoting/host/chromoting_host_context.h"
@@ skipping 47 matching lines @@
 
 }  // namespace
 
 namespace remoting {
 
 class HostProcess {
  public:
   HostProcess()
       : message_loop_(MessageLoop::TYPE_UI),
         file_io_thread_("FileIO"),
-        context_(message_loop_.message_loop_proxy()),
         allow_nat_traversal_(true),
         restarting_(false) {
-    context_.Start();
     file_io_thread_.StartWithOptions(
         base::Thread::Options(MessageLoop::TYPE_IO, 0));
+
+    context_.reset(new ChromotingHostContext(
+                           file_io_thread_.message_loop_proxy(),
+                           message_loop_.message_loop_proxy()));
+    context_->Start();
     network_change_notifier_.reset(net::NetworkChangeNotifier::Create());
   }
 
   void InitWithCommandLine(const CommandLine* cmd_line) {
     FilePath default_config_dir = GetDefaultConfigDir();
     if (cmd_line->HasSwitch(kAuthConfigSwitchName)) {
       auth_config_path_ = cmd_line->GetSwitchValuePath(kAuthConfigSwitchName);
     } else {
       auth_config_path_ = default_config_dir.Append(kDefaultAuthConfigFile);
     }
@@ skipping 76 matching lines @@
       // chromiumsync because we do not have an HTTP stack with which we can
       // easily request an OAuth2 access token even if we had a RefreshToken for
       // the account.
       xmpp_auth_service_ = kChromotingTokenDefaultServiceName;
     }
 
     return true;
   }
 
   void OnNatPolicyUpdate(bool nat_traversal_enabled) {
-    if (!context_.network_message_loop()->BelongsToCurrentThread()) {
-      context_.network_message_loop()->PostTask(FROM_HERE, base::Bind(
+    if (!context_->network_message_loop()->BelongsToCurrentThread()) {
+      context_->network_message_loop()->PostTask(FROM_HERE, base::Bind(
           &HostProcess::OnNatPolicyUpdate, base::Unretained(this),
           nat_traversal_enabled));
       return;
     }
 
     bool policy_changed = allow_nat_traversal_ != nat_traversal_enabled;
     allow_nat_traversal_ = nat_traversal_enabled;
 
     if (host_) {
       // Restart the host if the policy has changed while the host was
       // online.
       if (policy_changed)
         RestartHost();
     } else {
       // Just start the host otherwise.
       StartHost();
     }
   }
 
   void StartHost() {
-    DCHECK(context_.network_message_loop()->BelongsToCurrentThread());
+    DCHECK(context_->network_message_loop()->BelongsToCurrentThread());
     DCHECK(!host_);
 
     if (!signal_strategy_.get()) {
       signal_strategy_.reset(
-          new XmppSignalStrategy(context_.jingle_thread(), xmpp_login_,
+          new XmppSignalStrategy(context_->jingle_thread(), xmpp_login_,
                                  xmpp_auth_token_, xmpp_auth_service_));
       signaling_connector_.reset(
           new SignalingConnector(signal_strategy_.get()));
     }
 
     if (!desktop_environment_.get())
-      desktop_environment_.reset(DesktopEnvironment::Create(&context_));
+      desktop_environment_ = DesktopEnvironment::Create(context_.get());
 
     protocol::NetworkSettings network_settings(allow_nat_traversal_);
     if (!allow_nat_traversal_) {
       network_settings.min_port = kMinPortNumber;
       network_settings.max_port = kMaxPortNumber;
     }
 
     host_ = new ChromotingHost(
-        &context_, signal_strategy_.get(), desktop_environment_.get(),
+        context_.get(), signal_strategy_.get(), desktop_environment_.get(),
         network_settings);
 
     heartbeat_sender_.reset(
         new HeartbeatSender(host_id_, signal_strategy_.get(), &key_pair_));
 
     log_to_server_.reset(
         new LogToServer(host_, ServerLogEntry::ME2ME, signal_strategy_.get()));
     host_event_logger_ = HostEventLogger::Create(host_, kApplicationName);
 
     host_->Start();
 
     // Create authenticator factory.
     scoped_ptr<protocol::AuthenticatorFactory> factory(
         new protocol::Me2MeHostAuthenticatorFactory(
             xmpp_login_, key_pair_.GenerateCertificate(),
             *key_pair_.private_key(), host_secret_hash_));
     host_->SetAuthenticatorFactory(factory.Pass());
   }
 
   void RestartHost() {
-    DCHECK(context_.network_message_loop()->BelongsToCurrentThread());
+    DCHECK(context_->network_message_loop()->BelongsToCurrentThread());
 
     if (restarting_)
       return;
 
     restarting_ = true;
     host_->Shutdown(base::Bind(
         &HostProcess::RestartOnHostShutdown, base::Unretained(this)));
   }
 
   void RestartOnHostShutdown() {
-    DCHECK(context_.network_message_loop()->BelongsToCurrentThread());
+    DCHECK(context_->network_message_loop()->BelongsToCurrentThread());
 
     restarting_ = false;
 
     host_ = NULL;
     log_to_server_.reset();
     host_event_logger_.reset();
     heartbeat_sender_.reset();
 
     StartHost();
   }
 
   MessageLoop message_loop_;
   base::Thread file_io_thread_;
-  ChromotingHostContext context_;
+  scoped_ptr<ChromotingHostContext> context_;
   scoped_ptr<net::NetworkChangeNotifier> network_change_notifier_;
 
   FilePath auth_config_path_;
   FilePath host_config_path_;
 
   std::string host_id_;
   HostKeyPair key_pair_;
   protocol::SharedSecretHash host_secret_hash_;
   std::string xmpp_login_;
   std::string xmpp_auth_token_;
@@ skipping 42 matching lines @@
 int CALLBACK WinMain(HINSTANCE instance,
                      HINSTANCE previous_instance,
                      LPSTR command_line,
                      int show_command) {
   // CommandLine::Init() ignores the passed |argc| and |argv| on Windows getting
   // the command line from GetCommandLineW(), so we can safely pass NULL here.
   return main(0, NULL);
 }
 
 #endif