| 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_;
|
| -}
|
|
|