[chromedriver] Implement connecting to devtools and loading a page.

chrome/test/chromedriver/chromedriver.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 "chrome/test/chromedriver/chromedriver.h"
 
 #include "base/json/json_reader.h"
 #include "base/json/json_writer.h"
+#include "base/lazy_instance.h"
 #include "base/logging.h"
 #include "base/memory/scoped_ptr.h"
+#include "base/synchronization/lock.h"
 #include "base/values.h"
 #include "chrome/test/chromedriver/command_executor.h"
 #include "chrome/test/chromedriver/status.h"
 
 namespace {
 
+// Guards |g_executor_initialized|.
+base::LazyInstance<base::Lock> g_lazy_lock = LAZY_INSTANCE_INITIALIZER;
+bool g_executor_initialized = false;
 CommandExecutor* g_command_executor = NULL;
 
 void SetResponse(StatusCode status,
                  const base::Value* value,
                  const std::string& session_id,
                  std::string* response) {
   base::DictionaryValue response_dict;
   response_dict.SetInteger("status", status);
   response_dict.Set("value", value->DeepCopy());
   response_dict.SetString("sessionId", session_id);
   std::string json;
   base::JSONWriter::Write(&response_dict, response);
 }
 
 void SetError(const std::string& error_msg,
               std::string* response) {
   base::DictionaryValue value;
   value.SetString("message", error_msg);
   SetResponse(kUnknownError, &value, "", response);
 }
 
 }  // namespace
 
 void Init(scoped_ptr<CommandExecutor> executor) {
   g_command_executor = executor.release();
+  // We do not call CommandExecutor::Init here because you can't do some things
+  // (e.g., creating threads) during DLL loading on Windows.
 }
 
 void ExecuteCommand(const std::string& command, std::string* response) {
   CHECK(g_command_executor);
+  {
+    base::AutoLock(g_lazy_lock.Get());
+    if (!g_executor_initialized) {
+      g_command_executor->Init();
+      g_executor_initialized = true;
+    }
+  }
   std::string error_msg;
   scoped_ptr<base::Value> value(base::JSONReader::ReadAndReturnError(
       command, 0, NULL, &error_msg));
   if (!value.get()) {
     SetError("failed to parse command: " + error_msg, response);
     return;
   }
   base::DictionaryValue* command_dict;
   if (!value->GetAsDictionary(&command_dict)) {
     SetError("invalid command (must be dictionary)", response);
@@ skipping 47 matching lines @@
   //    temp directories, unless we make Chrome clean its own directory too.
   //    If Chrome crashes the directory would be leaked.
   base::DictionaryValue params;
   StatusCode status_code;
   scoped_ptr<base::Value> value;
   std::string session_id;
   g_command_executor->ExecuteCommand(
       "quitAll", params, "", &status_code, &value, &session_id);
   delete g_command_executor;
 }