blob: 0c183132e37ebaf3c82b59bef2d68cf311483901 [file] [log] [blame]
// Copyright 2013 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/browser/media/webrtc_browsertest_common.h"
#include "base/command_line.h"
#include "base/file_util.h"
#include "base/path_service.h"
#include "base/process/launch.h"
#include "base/strings/stringprintf.h"
#include "base/test/test_timeouts.h"
#include "base/time/time.h"
#include "chrome/browser/profiles/profile.h"
#include "chrome/browser/ui/browser_tabstrip.h"
#include "content/public/test/browser_test_utils.h"
const int kDefaultPollIntervalMsec = 250;
bool SleepInJavascript(content::WebContents* tab_contents, int timeout_msec) {
const std::string javascript = base::StringPrintf(
"setTimeout(function() {"
" window.domAutomationController.send('sleep-ok');"
"}, %d)", timeout_msec);
std::string result;
bool ok = content::ExecuteScriptAndExtractString(
tab_contents, javascript, &result);
return ok && result == "sleep-ok";
}
bool PollingWaitUntil(const std::string& javascript,
const std::string& evaluates_to,
content::WebContents* tab_contents) {
return PollingWaitUntil(javascript, evaluates_to, tab_contents,
kDefaultPollIntervalMsec);
}
bool PollingWaitUntil(const std::string& javascript,
const std::string& evaluates_to,
content::WebContents* tab_contents,
int poll_interval_msec) {
base::Time start_time = base::Time::Now();
base::TimeDelta timeout = TestTimeouts::action_max_timeout();
std::string result;
while (base::Time::Now() - start_time < timeout) {
std::string result;
if (!content::ExecuteScriptAndExtractString(tab_contents, javascript,
&result)) {
LOG(ERROR) << "Failed to execute javascript " << javascript;
return false;
}
if (evaluates_to == result)
return true;
// Sleep a bit here to keep this loop from spinlocking too badly.
if (!SleepInJavascript(tab_contents, poll_interval_msec)) {
// TODO(phoglund): Figure out why this fails every now and then.
// It's not a huge deal if it does though.
LOG(ERROR) << "Failed to sleep.";
}
}
LOG(ERROR) << "Timed out while waiting for " << javascript <<
" to evaluate to " << evaluates_to << "; last result was '" << result <<
"'";
return false;
}
static base::FilePath::CharType kServerExecutable[] =
#if defined(OS_WIN)
FILE_PATH_LITERAL("peerconnection_server.exe");
#else
FILE_PATH_LITERAL("peerconnection_server");
#endif
const char PeerConnectionServerRunner::kDefaultPort[] = "7778";
bool PeerConnectionServerRunner::Start() {
base::FilePath peerconnection_server;
if (!PathService::Get(base::DIR_MODULE, &peerconnection_server)) {
LOG(ERROR) << "Failed retrieving base::DIR_MODULE!";
return false;
}
peerconnection_server = peerconnection_server.Append(kServerExecutable);
if (!base::PathExists(peerconnection_server)) {
LOG(ERROR) << "Missing " << kServerExecutable << ". You must build "
"it so it ends up next to the browser test binary.";
return false;
}
CommandLine command_line(peerconnection_server);
command_line.AppendSwitchASCII("port", kDefaultPort);
VLOG(0) << "Running " << command_line.GetCommandLineString();
return base::LaunchProcess(command_line,
base::LaunchOptions(),
&server_pid_);
}
bool PeerConnectionServerRunner::Stop() {
return base::KillProcess(server_pid_, 0, false);
}
void PeerConnectionServerRunner::KillAllPeerConnectionServersOnCurrentSystem() {
if (!base::KillProcesses(kServerExecutable, -1, NULL)) {
LOG(ERROR) << "Failed to kill instances of " << kServerExecutable << ".";
return;
}
base::WaitForProcessesToExit(kServerExecutable,
base::TimeDelta::FromSeconds(5), NULL);
}