| Index: chrome/test/automation/proxy_launcher.cc | 
| =================================================================== | 
| --- chrome/test/automation/proxy_launcher.cc	(revision 261647) | 
| +++ chrome/test/automation/proxy_launcher.cc	(working copy) | 
| @@ -1,631 +0,0 @@ | 
| -// 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/automation/proxy_launcher.h" | 
| - | 
| -#include <vector> | 
| - | 
| -#include "base/environment.h" | 
| -#include "base/file_util.h" | 
| -#include "base/files/file_enumerator.h" | 
| -#include "base/files/scoped_file.h" | 
| -#include "base/process/kill.h" | 
| -#include "base/process/launch.h" | 
| -#include "base/strings/string_number_conversions.h" | 
| -#include "base/strings/string_split.h" | 
| -#include "base/strings/stringprintf.h" | 
| -#include "base/strings/utf_string_conversions.h" | 
| -#include "base/test/test_file_util.h" | 
| -#include "base/test/test_timeouts.h" | 
| -#include "chrome/app/chrome_command_ids.h" | 
| -#include "chrome/common/automation_constants.h" | 
| -#include "chrome/common/chrome_constants.h" | 
| -#include "chrome/common/chrome_switches.h" | 
| -#include "chrome/common/logging_chrome.h" | 
| -#include "chrome/common/url_constants.h" | 
| -#include "chrome/test/automation/automation_proxy.h" | 
| -#include "chrome/test/base/chrome_process_util.h" | 
| -#include "chrome/test/base/test_launcher_utils.h" | 
| -#include "chrome/test/base/test_switches.h" | 
| -#include "chrome/test/ui/ui_test.h" | 
| -#include "content/public/common/process_type.h" | 
| -#include "ipc/ipc_channel.h" | 
| -#include "ipc/ipc_descriptors.h" | 
| -#include "sql/connection.h" | 
| - | 
| -#if defined(OS_POSIX) | 
| -#include <signal.h> | 
| -#include "base/posix/global_descriptors.h" | 
| -#endif | 
| - | 
| -namespace { | 
| - | 
| -// Passed as value of kTestType. | 
| -const char kUITestType[] = "ui"; | 
| - | 
| -// Copies the contents of the given source directory to the given dest | 
| -// directory. This is somewhat different than CopyDirectory in base which will | 
| -// copies "source/" to "dest/source/". This version will copy "source/*" to | 
| -// "dest/*", overwriting existing files as necessary. | 
| -// | 
| -// This also kicks the files out of the memory cache for the startup tests. | 
| -// TODO(brettw) bug 237904: This is the wrong place for this code. It means all | 
| -// startup tests other than the "cold" ones run more slowly than necessary. | 
| -bool CopyDirectoryContentsNoCache(const base::FilePath& source, | 
| -                                  const base::FilePath& dest) { | 
| -  base::FileEnumerator en(source, false, | 
| -      base::FileEnumerator::FILES | base::FileEnumerator::DIRECTORIES); | 
| -  for (base::FilePath cur = en.Next(); !cur.empty(); cur = en.Next()) { | 
| -    base::FileEnumerator::FileInfo info = en.GetInfo(); | 
| -    if (info.IsDirectory()) { | 
| -      if (!base::CopyDirectory(cur, dest, true)) | 
| -        return false; | 
| -    } else { | 
| -      if (!base::CopyFile(cur, dest.Append(cur.BaseName()))) | 
| -        return false; | 
| -    } | 
| -  } | 
| - | 
| -  // Kick out the profile files, this must happen after SetUp which creates the | 
| -  // profile. It might be nicer to use EvictFileFromSystemCacheWrapper from | 
| -  // UITest which will retry on failure. | 
| -  base::FileEnumerator kickout(dest, true, base::FileEnumerator::FILES); | 
| -  for (base::FilePath cur = kickout.Next(); !cur.empty(); cur = kickout.Next()) | 
| -    base::EvictFileFromSystemCacheWithRetry(cur); | 
| -  return true; | 
| -} | 
| - | 
| -// We want to have a current history database when we start the browser so | 
| -// things like the NTP will have thumbnails.  This method updates the dates | 
| -// in the history to be more recent. | 
| -void UpdateHistoryDates(const base::FilePath& user_data_dir) { | 
| -  // Migrate the times in the segment_usage table to yesterday so we get | 
| -  // actual thumbnails on the NTP. | 
| -  sql::Connection db; | 
| -  base::FilePath history = | 
| -      user_data_dir.AppendASCII("Default").AppendASCII("History"); | 
| -  // Not all test profiles have a history file. | 
| -  if (!base::PathExists(history)) | 
| -    return; | 
| - | 
| -  ASSERT_TRUE(db.Open(history)); | 
| -  base::Time yesterday = base::Time::Now() - base::TimeDelta::FromDays(1); | 
| -  std::string yesterday_str = base::Int64ToString(yesterday.ToInternalValue()); | 
| -  std::string query = base::StringPrintf( | 
| -      "UPDATE segment_usage " | 
| -      "SET time_slot = %s " | 
| -      "WHERE id IN (SELECT id FROM segment_usage WHERE time_slot > 0);", | 
| -      yesterday_str.c_str()); | 
| -  ASSERT_TRUE(db.Execute(query.c_str())); | 
| -  db.Close(); | 
| -  base::EvictFileFromSystemCache(history); | 
| -} | 
| - | 
| -}  // namespace | 
| - | 
| -// ProxyLauncher functions | 
| - | 
| -#if defined(OS_WIN) | 
| -const char ProxyLauncher::kDefaultInterfaceId[] = "ChromeTestingInterface"; | 
| -#elif defined(OS_POSIX) | 
| -const char ProxyLauncher::kDefaultInterfaceId[] = | 
| -    "/var/tmp/ChromeTestingInterface"; | 
| -#endif | 
| - | 
| -ProxyLauncher::ProxyLauncher() | 
| -    : process_(base::kNullProcessHandle), | 
| -      process_id_(-1), | 
| -      shutdown_type_(WINDOW_CLOSE), | 
| -      no_sandbox_(CommandLine::ForCurrentProcess()->HasSwitch( | 
| -                      switches::kNoSandbox)), | 
| -      full_memory_dump_(CommandLine::ForCurrentProcess()->HasSwitch( | 
| -                            switches::kFullMemoryCrashReport)), | 
| -      show_error_dialogs_(CommandLine::ForCurrentProcess()->HasSwitch( | 
| -                              switches::kEnableErrorDialogs)), | 
| -      silent_dump_on_dcheck_(CommandLine::ForCurrentProcess()->HasSwitch( | 
| -                                 switches::kSilentDumpOnDCHECK)), | 
| -      disable_breakpad_(CommandLine::ForCurrentProcess()->HasSwitch( | 
| -                            switches::kDisableBreakpad)), | 
| -      js_flags_(CommandLine::ForCurrentProcess()->GetSwitchValueASCII( | 
| -                    switches::kJavaScriptFlags)), | 
| -      log_level_(CommandLine::ForCurrentProcess()->GetSwitchValueASCII( | 
| -                     switches::kLoggingLevel)) { | 
| -} | 
| - | 
| -ProxyLauncher::~ProxyLauncher() {} | 
| - | 
| -bool ProxyLauncher::WaitForBrowserLaunch(bool wait_for_initial_loads) { | 
| -  AutomationLaunchResult app_launched = automation_proxy_->WaitForAppLaunch(); | 
| -  EXPECT_EQ(AUTOMATION_SUCCESS, app_launched) | 
| -      << "Error while awaiting automation ping from browser process"; | 
| -  if (app_launched != AUTOMATION_SUCCESS) | 
| -    return false; | 
| - | 
| -  if (wait_for_initial_loads) { | 
| -    if (!automation_proxy_->WaitForInitialLoads()) { | 
| -      LOG(ERROR) << "WaitForInitialLoads failed."; | 
| -      return false; | 
| -    } | 
| -  } else { | 
| -#if defined(OS_WIN) | 
| -    // TODO(phajdan.jr): Get rid of this Sleep when logging_chrome_uitest | 
| -    // stops "relying" on it. | 
| -    base::PlatformThread::Sleep(TestTimeouts::action_timeout()); | 
| -#endif | 
| -  } | 
| - | 
| -  return true; | 
| -} | 
| - | 
| -bool ProxyLauncher::LaunchBrowserAndServer(const LaunchState& state, | 
| -                                           bool wait_for_initial_loads) { | 
| -  // Set up IPC testing interface as a server. | 
| -  automation_proxy_.reset(CreateAutomationProxy( | 
| -      TestTimeouts::action_max_timeout())); | 
| - | 
| -  if (!LaunchBrowser(state)) | 
| -    return false; | 
| - | 
| -  if (!WaitForBrowserLaunch(wait_for_initial_loads)) | 
| -    return false; | 
| - | 
| -  return true; | 
| -} | 
| - | 
| -bool ProxyLauncher::ConnectToRunningBrowser(bool wait_for_initial_loads) { | 
| -  // Set up IPC testing interface as a client. | 
| -  automation_proxy_.reset(CreateAutomationProxy( | 
| -                              TestTimeouts::action_max_timeout())); | 
| - | 
| -  return WaitForBrowserLaunch(wait_for_initial_loads); | 
| -} | 
| - | 
| -void ProxyLauncher::CloseBrowserAndServer() { | 
| -  QuitBrowser(); | 
| - | 
| -  // Suppress spammy failures that seem to be occurring when running | 
| -  // the UI tests in single-process mode. | 
| -  // TODO(jhughes): figure out why this is necessary at all, and fix it | 
| -  AssertAppNotRunning( | 
| -      base::StringPrintf( | 
| -          "Unable to quit all browser processes. Original PID %d", | 
| -          process_id_)); | 
| - | 
| -  DisconnectFromRunningBrowser(); | 
| -} | 
| - | 
| -void ProxyLauncher::DisconnectFromRunningBrowser() { | 
| -  automation_proxy_.reset();  // Shut down IPC testing interface. | 
| -} | 
| - | 
| -bool ProxyLauncher::LaunchBrowser(const LaunchState& state) { | 
| -  if (state.clear_profile || !temp_profile_dir_.IsValid()) { | 
| -    if (temp_profile_dir_.IsValid() && !temp_profile_dir_.Delete()) { | 
| -      LOG(ERROR) << "Failed to delete temporary directory."; | 
| -      return false; | 
| -    } | 
| - | 
| -    if (!temp_profile_dir_.CreateUniqueTempDir()) { | 
| -      LOG(ERROR) << "Failed to create temporary directory."; | 
| -      return false; | 
| -    } | 
| - | 
| -    if (!test_launcher_utils::OverrideUserDataDir(user_data_dir())) { | 
| -      LOG(ERROR) << "Failed to override user data directory."; | 
| -      return false; | 
| -    } | 
| -  } | 
| - | 
| -  if (!state.template_user_data.empty()) { | 
| -    // Recursively copy the template directory to the user_data_dir. | 
| -    if (!CopyDirectoryContentsNoCache(state.template_user_data, | 
| -                                      user_data_dir())) { | 
| -      LOG(ERROR) << "Failed to copy user data directory template."; | 
| -      return false; | 
| -    } | 
| - | 
| -    // Update the history file to include recent dates. | 
| -    UpdateHistoryDates(user_data_dir()); | 
| -  } | 
| - | 
| -  // Optionally do any final setup of the test environment. | 
| -  if (!state.setup_profile_callback.is_null()) | 
| -    state.setup_profile_callback.Run(); | 
| - | 
| -  if (!LaunchBrowserHelper(state, true, false, &process_)) { | 
| -    LOG(ERROR) << "LaunchBrowserHelper failed."; | 
| -    return false; | 
| -  } | 
| -  process_id_ = base::GetProcId(process_); | 
| - | 
| -  return true; | 
| -} | 
| - | 
| -void ProxyLauncher::QuitBrowser() { | 
| -  // If we have already finished waiting for the browser to exit | 
| -  // (or it hasn't launched at all), there's nothing to do here. | 
| -  if (process_ == base::kNullProcessHandle || !automation_proxy_.get()) | 
| -    return; | 
| - | 
| -  if (SESSION_ENDING == shutdown_type_) { | 
| -    TerminateBrowser(); | 
| -    return; | 
| -  } | 
| - | 
| -  base::TimeTicks quit_start = base::TimeTicks::Now(); | 
| - | 
| -  if (WINDOW_CLOSE == shutdown_type_) { | 
| -    int window_count = 0; | 
| -    EXPECT_TRUE(automation()->GetBrowserWindowCount(&window_count)); | 
| - | 
| -    // Synchronously close all but the last browser window. Closing them | 
| -    // one-by-one may help with stability. | 
| -    while (window_count > 1) { | 
| -      scoped_refptr<BrowserProxy> browser_proxy = | 
| -          automation()->GetBrowserWindow(0); | 
| -      EXPECT_TRUE(browser_proxy.get()); | 
| -      if (browser_proxy.get()) { | 
| -        EXPECT_TRUE(browser_proxy->RunCommand(IDC_CLOSE_WINDOW)); | 
| -        EXPECT_TRUE(automation()->GetBrowserWindowCount(&window_count)); | 
| -      } else { | 
| -        break; | 
| -      } | 
| -    } | 
| - | 
| -    // Close the last window asynchronously, because the browser may | 
| -    // shutdown faster than it will be able to send a synchronous response | 
| -    // to our message. | 
| -    scoped_refptr<BrowserProxy> browser_proxy = | 
| -        automation()->GetBrowserWindow(0); | 
| -    EXPECT_TRUE(browser_proxy.get()); | 
| -    if (browser_proxy.get()) { | 
| -      EXPECT_TRUE(browser_proxy->is_valid()); | 
| -      EXPECT_TRUE(browser_proxy->ApplyAccelerator(IDC_CLOSE_WINDOW)); | 
| -      browser_proxy = NULL; | 
| -    } | 
| -  } else if (USER_QUIT == shutdown_type_) { | 
| -    scoped_refptr<BrowserProxy> browser_proxy = | 
| -        automation()->GetBrowserWindow(0); | 
| -    EXPECT_TRUE(browser_proxy.get()); | 
| -    if (browser_proxy.get()) { | 
| -      EXPECT_TRUE(browser_proxy->RunCommandAsync(IDC_EXIT)); | 
| -    } | 
| -  } else { | 
| -    NOTREACHED() << "Invalid shutdown type " << shutdown_type_; | 
| -  } | 
| - | 
| -  ChromeProcessList processes = GetRunningChromeProcesses(process_id_); | 
| - | 
| -  // Now, drop the automation IPC channel so that the automation provider in | 
| -  // the browser notices and drops its reference to the browser process. | 
| -  if (automation_proxy_.get()) | 
| -    automation_proxy_->Disconnect(); | 
| - | 
| -  // Wait for the browser process to quit. It should quit once all tabs have | 
| -  // been closed. | 
| -  int exit_code = -1; | 
| -  EXPECT_TRUE(WaitForBrowserProcessToQuit( | 
| -                  TestTimeouts::action_max_timeout(), &exit_code)); | 
| -  EXPECT_EQ(0, exit_code);  // Expect a clean shutdown. | 
| - | 
| -  browser_quit_time_ = base::TimeTicks::Now() - quit_start; | 
| - | 
| -  // Ensure no child processes are left dangling. | 
| -  TerminateAllChromeProcesses(processes); | 
| -} | 
| - | 
| -void ProxyLauncher::TerminateBrowser() { | 
| -  // If we have already finished waiting for the browser to exit | 
| -  // (or it hasn't launched at all), there's nothing to do here. | 
| -  if (process_ == base::kNullProcessHandle || !automation_proxy_.get()) | 
| -    return; | 
| - | 
| -  base::TimeTicks quit_start = base::TimeTicks::Now(); | 
| - | 
| -  ChromeProcessList processes = GetRunningChromeProcesses(process_id_); | 
| - | 
| -  // Now, drop the automation IPC channel so that the automation provider in | 
| -  // the browser notices and drops its reference to the browser process. | 
| -  if (automation_proxy_.get()) | 
| -    automation_proxy_->Disconnect(); | 
| - | 
| -#if defined(OS_POSIX) | 
| -  EXPECT_EQ(kill(process_, SIGTERM), 0); | 
| -#endif  // OS_POSIX | 
| - | 
| -  int exit_code = -1; | 
| -  EXPECT_TRUE(WaitForBrowserProcessToQuit( | 
| -                  TestTimeouts::action_max_timeout(), &exit_code)); | 
| -  EXPECT_EQ(0, exit_code);  // Expect a clean shutdown. | 
| - | 
| -  browser_quit_time_ = base::TimeTicks::Now() - quit_start; | 
| - | 
| -  // Ensure no child processes are left dangling. | 
| -  TerminateAllChromeProcesses(processes); | 
| -} | 
| - | 
| -void ProxyLauncher::AssertAppNotRunning(const std::string& error_message) { | 
| -  std::string final_error_message(error_message); | 
| - | 
| -  ChromeProcessList processes = GetRunningChromeProcesses(process_id_); | 
| -  if (!processes.empty()) { | 
| -    final_error_message += " Leftover PIDs: ["; | 
| -    for (ChromeProcessList::const_iterator it = processes.begin(); | 
| -         it != processes.end(); ++it) { | 
| -      final_error_message += base::StringPrintf(" %d", *it); | 
| -    } | 
| -    final_error_message += " ]"; | 
| -  } | 
| -  ASSERT_TRUE(processes.empty()) << final_error_message; | 
| -} | 
| - | 
| -bool ProxyLauncher::WaitForBrowserProcessToQuit( | 
| -    base::TimeDelta timeout, | 
| -    int* exit_code) { | 
| -#ifdef WAIT_FOR_DEBUGGER_ON_OPEN | 
| -  timeout = base::TimeDelta::FromSeconds(500); | 
| -#endif | 
| -  bool success = false; | 
| - | 
| -  // Only wait for exit if the "browser, please terminate" message had a | 
| -  // chance of making it through. | 
| -  if (!automation_proxy_->channel_disconnected_on_failure()) | 
| -    success = base::WaitForExitCodeWithTimeout(process_, exit_code, timeout); | 
| - | 
| -  base::CloseProcessHandle(process_); | 
| -  process_ = base::kNullProcessHandle; | 
| -  process_id_ = -1; | 
| - | 
| -  return success; | 
| -} | 
| - | 
| -void ProxyLauncher::PrepareTestCommandline(CommandLine* command_line, | 
| -                                           bool include_testing_id) { | 
| -  // Add any explicit command line flags passed to the process. | 
| -  CommandLine::StringType extra_chrome_flags = | 
| -      CommandLine::ForCurrentProcess()->GetSwitchValueNative( | 
| -          switches::kExtraChromeFlags); | 
| -  if (!extra_chrome_flags.empty()) { | 
| -    // Split by spaces and append to command line. | 
| -    std::vector<CommandLine::StringType> flags; | 
| -    base::SplitStringAlongWhitespace(extra_chrome_flags, &flags); | 
| -    for (size_t i = 0; i < flags.size(); ++i) | 
| -      command_line->AppendArgNative(flags[i]); | 
| -  } | 
| - | 
| -  // Also look for extra flags in environment. | 
| -  scoped_ptr<base::Environment> env(base::Environment::Create()); | 
| -  std::string extra_from_env; | 
| -  if (env->GetVar("EXTRA_CHROME_FLAGS", &extra_from_env)) { | 
| -    std::vector<std::string> flags; | 
| -    base::SplitStringAlongWhitespace(extra_from_env, &flags); | 
| -    for (size_t i = 0; i < flags.size(); ++i) | 
| -      command_line->AppendArg(flags[i]); | 
| -  } | 
| - | 
| -  // No default browser check, it would create an info-bar (if we are not the | 
| -  // default browser) that could conflicts with some tests expectations. | 
| -  command_line->AppendSwitch(switches::kNoDefaultBrowserCheck); | 
| - | 
| -  // This is a UI test. | 
| -  command_line->AppendSwitchASCII(switches::kTestType, kUITestType); | 
| - | 
| -  // Tell the browser to use a temporary directory just for this test | 
| -  // if it is not already set. | 
| -  if (command_line->GetSwitchValuePath(switches::kUserDataDir).empty()) { | 
| -    command_line->AppendSwitchPath(switches::kUserDataDir, user_data_dir()); | 
| -  } | 
| - | 
| -  if (include_testing_id) | 
| -    command_line->AppendSwitchASCII(switches::kTestingChannelID, | 
| -                                    PrefixedChannelID()); | 
| - | 
| -  if (!show_error_dialogs_) | 
| -    command_line->AppendSwitch(switches::kNoErrorDialogs); | 
| -  if (no_sandbox_) | 
| -    command_line->AppendSwitch(switches::kNoSandbox); | 
| -  if (full_memory_dump_) | 
| -    command_line->AppendSwitch(switches::kFullMemoryCrashReport); | 
| -  if (silent_dump_on_dcheck_) | 
| -    command_line->AppendSwitch(switches::kSilentDumpOnDCHECK); | 
| -  if (disable_breakpad_) | 
| -    command_line->AppendSwitch(switches::kDisableBreakpad); | 
| - | 
| -  if (!js_flags_.empty()) | 
| -    command_line->AppendSwitchASCII(switches::kJavaScriptFlags, js_flags_); | 
| -  if (!log_level_.empty()) | 
| -    command_line->AppendSwitchASCII(switches::kLoggingLevel, log_level_); | 
| - | 
| -  command_line->AppendSwitch(switches::kMetricsRecordingOnly); | 
| - | 
| -  if (!CommandLine::ForCurrentProcess()->HasSwitch( | 
| -          switches::kEnableErrorDialogs)) | 
| -    command_line->AppendSwitch(switches::kEnableLogging); | 
| - | 
| -#ifdef WAIT_FOR_DEBUGGER_ON_OPEN | 
| -  command_line->AppendSwitch(switches::kDebugOnStart); | 
| -#endif | 
| - | 
| -  // Force the app to always exit when the last browser window is closed. | 
| -  command_line->AppendSwitch(switches::kDisableZeroBrowsersOpenForTests); | 
| - | 
| -  // Allow file:// access on ChromeOS. | 
| -  command_line->AppendSwitch(switches::kAllowFileAccess); | 
| - | 
| -  // The tests assume that file:// URIs can freely access other file:// URIs. | 
| -  command_line->AppendSwitch(switches::kAllowFileAccessFromFiles); | 
| -} | 
| - | 
| -bool ProxyLauncher::LaunchBrowserHelper(const LaunchState& state, | 
| -                                        bool main_launch, | 
| -                                        bool wait, | 
| -                                        base::ProcessHandle* process) { | 
| -  CommandLine command_line(state.command); | 
| - | 
| -  // Add command line arguments that should be applied to all UI tests. | 
| -  PrepareTestCommandline(&command_line, state.include_testing_id); | 
| - | 
| -  // Sometimes one needs to run the browser under a special environment | 
| -  // (e.g. valgrind) without also running the test harness (e.g. python) | 
| -  // under the special environment.  Provide a way to wrap the browser | 
| -  // commandline with a special prefix to invoke the special environment. | 
| -  const char* browser_wrapper = getenv("BROWSER_WRAPPER"); | 
| -  if (browser_wrapper) { | 
| -#if defined(OS_WIN) | 
| -    command_line.PrependWrapper(base::ASCIIToWide(browser_wrapper)); | 
| -#elif defined(OS_POSIX) | 
| -    command_line.PrependWrapper(browser_wrapper); | 
| -#endif | 
| -    VLOG(1) << "BROWSER_WRAPPER was set, prefixing command_line with " | 
| -            << browser_wrapper; | 
| -  } | 
| - | 
| -  if (main_launch) | 
| -    browser_launch_time_ = base::TimeTicks::Now(); | 
| - | 
| -  base::LaunchOptions options; | 
| -  options.wait = wait; | 
| - | 
| -#if defined(OS_WIN) | 
| -  options.start_hidden = !state.show_window; | 
| -#elif defined(OS_POSIX) | 
| -  base::ScopedFD ipcfd; | 
| -  base::FileHandleMappingVector fds; | 
| -  if (main_launch && automation_proxy_.get()) { | 
| -    ipcfd.reset(automation_proxy_->channel()->TakeClientFileDescriptor()); | 
| -    fds.push_back(std::make_pair(ipcfd.get(), | 
| -        kPrimaryIPCChannel + base::GlobalDescriptors::kBaseDescriptor)); | 
| -    options.fds_to_remap = &fds; | 
| -  } | 
| -#endif | 
| - | 
| -  return base::LaunchProcess(command_line, options, process); | 
| -} | 
| - | 
| -AutomationProxy* ProxyLauncher::automation() const { | 
| -  EXPECT_TRUE(automation_proxy_.get()); | 
| -  return automation_proxy_.get(); | 
| -} | 
| - | 
| -base::FilePath ProxyLauncher::user_data_dir() const { | 
| -  EXPECT_TRUE(temp_profile_dir_.IsValid()); | 
| -  return temp_profile_dir_.path(); | 
| -} | 
| - | 
| -base::ProcessHandle ProxyLauncher::process() const { | 
| -  return process_; | 
| -} | 
| - | 
| -base::ProcessId ProxyLauncher::process_id() const { | 
| -  return process_id_; | 
| -} | 
| - | 
| -base::TimeTicks ProxyLauncher::browser_launch_time() const { | 
| -  return browser_launch_time_; | 
| -} | 
| - | 
| -base::TimeDelta ProxyLauncher::browser_quit_time() const { | 
| -  return browser_quit_time_; | 
| -} | 
| - | 
| -// NamedProxyLauncher functions | 
| - | 
| -NamedProxyLauncher::NamedProxyLauncher(const std::string& channel_id, | 
| -                                       bool launch_browser, | 
| -                                       bool disconnect_on_failure) | 
| -    : channel_id_(channel_id), | 
| -      launch_browser_(launch_browser), | 
| -      disconnect_on_failure_(disconnect_on_failure) { | 
| -} | 
| - | 
| -AutomationProxy* NamedProxyLauncher::CreateAutomationProxy( | 
| -    base::TimeDelta execution_timeout) { | 
| -  AutomationProxy* proxy = new AutomationProxy(execution_timeout, | 
| -                                               disconnect_on_failure_); | 
| -  proxy->InitializeChannel(channel_id_, true); | 
| -  return proxy; | 
| -} | 
| - | 
| -bool NamedProxyLauncher::InitializeConnection(const LaunchState& state, | 
| -                                              bool wait_for_initial_loads) { | 
| -  if (launch_browser_) { | 
| -#if defined(OS_POSIX) | 
| -    // Because we are waiting on the existence of the testing file below, | 
| -    // make sure there isn't one already there before browser launch. | 
| -    if (!base::DeleteFile(base::FilePath(channel_id_), false)) { | 
| -      LOG(ERROR) << "Failed to delete " << channel_id_; | 
| -      return false; | 
| -    } | 
| -#endif | 
| - | 
| -    if (!LaunchBrowser(state)) { | 
| -      LOG(ERROR) << "Failed to LaunchBrowser"; | 
| -      return false; | 
| -    } | 
| -  } | 
| - | 
| -  // Wait for browser to be ready for connections. | 
| -  bool channel_initialized = false; | 
| -  base::TimeDelta sleep_time = base::TimeDelta::FromMilliseconds( | 
| -      automation::kSleepTime); | 
| -  for (base::TimeDelta wait_time = base::TimeDelta(); | 
| -       wait_time < TestTimeouts::action_max_timeout(); | 
| -       wait_time += sleep_time) { | 
| -    channel_initialized = IPC::Channel::IsNamedServerInitialized(channel_id_); | 
| -    if (channel_initialized) | 
| -      break; | 
| -    base::PlatformThread::Sleep(sleep_time); | 
| -  } | 
| -  if (!channel_initialized) { | 
| -    LOG(ERROR) << "Failed to wait for testing channel presence."; | 
| -    return false; | 
| -  } | 
| - | 
| -  if (!ConnectToRunningBrowser(wait_for_initial_loads)) { | 
| -    LOG(ERROR) << "Failed to ConnectToRunningBrowser"; | 
| -    return false; | 
| -  } | 
| -  return true; | 
| -} | 
| - | 
| -void NamedProxyLauncher::TerminateConnection() { | 
| -  if (launch_browser_) | 
| -    CloseBrowserAndServer(); | 
| -  else | 
| -    DisconnectFromRunningBrowser(); | 
| -} | 
| - | 
| -std::string NamedProxyLauncher::PrefixedChannelID() const { | 
| -  std::string channel_id; | 
| -  channel_id.append(automation::kNamedInterfacePrefix).append(channel_id_); | 
| -  return channel_id; | 
| -} | 
| - | 
| -// AnonymousProxyLauncher functions | 
| - | 
| -AnonymousProxyLauncher::AnonymousProxyLauncher(bool disconnect_on_failure) | 
| -    : disconnect_on_failure_(disconnect_on_failure) { | 
| -  channel_id_ = AutomationProxy::GenerateChannelID(); | 
| -} | 
| - | 
| -AutomationProxy* AnonymousProxyLauncher::CreateAutomationProxy( | 
| -    base::TimeDelta execution_timeout) { | 
| -  AutomationProxy* proxy = new AutomationProxy(execution_timeout, | 
| -                                               disconnect_on_failure_); | 
| -  proxy->InitializeChannel(channel_id_, false); | 
| -  return proxy; | 
| -} | 
| - | 
| -bool AnonymousProxyLauncher::InitializeConnection(const LaunchState& state, | 
| -                                                  bool wait_for_initial_loads) { | 
| -  return LaunchBrowserAndServer(state, wait_for_initial_loads); | 
| -} | 
| - | 
| -void AnonymousProxyLauncher::TerminateConnection() { | 
| -  CloseBrowserAndServer(); | 
| -} | 
| - | 
| -std::string AnonymousProxyLauncher::PrefixedChannelID() const { | 
| -  return channel_id_; | 
| -} | 
|  |