OLD | NEW |
1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "chrome/test/automation/proxy_launcher.h" | 5 #include "chrome/test/automation/proxy_launcher.h" |
6 | 6 |
7 #include "base/environment.h" | 7 #include "base/environment.h" |
8 #include "base/file_util.h" | 8 #include "base/file_util.h" |
9 #include "base/string_number_conversions.h" | 9 #include "base/string_number_conversions.h" |
10 #include "base/string_split.h" | 10 #include "base/string_split.h" |
(...skipping 501 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
512 } | 512 } |
513 | 513 |
514 AutomationProxy* NamedProxyLauncher::CreateAutomationProxy( | 514 AutomationProxy* NamedProxyLauncher::CreateAutomationProxy( |
515 int execution_timeout) { | 515 int execution_timeout) { |
516 AutomationProxy* proxy = new AutomationProxy(execution_timeout, | 516 AutomationProxy* proxy = new AutomationProxy(execution_timeout, |
517 disconnect_on_failure_); | 517 disconnect_on_failure_); |
518 proxy->InitializeChannel(channel_id_, true); | 518 proxy->InitializeChannel(channel_id_, true); |
519 return proxy; | 519 return proxy; |
520 } | 520 } |
521 | 521 |
522 bool NamedProxyLauncher::InitializeConnection(const LaunchState& state, | 522 void NamedProxyLauncher::InitializeConnection(const LaunchState& state, |
523 bool wait_for_initial_loads) { | 523 bool wait_for_initial_loads) { |
524 if (launch_browser_) { | 524 if (launch_browser_) { |
525 #if defined(OS_POSIX) | 525 #if defined(OS_POSIX) |
526 // Because we are waiting on the existence of the testing file below, | 526 // Because we are waiting on the existence of the testing file below, |
527 // make sure there isn't one already there before browser launch. | 527 // make sure there isn't one already there before browser launch. |
528 if (!file_util::Delete(FilePath(channel_id_), false)) { | 528 EXPECT_TRUE(file_util::Delete(FilePath(channel_id_), false)); |
529 LOG(ERROR) << "Failed to delete " << channel_id_; | |
530 return false; | |
531 } | |
532 #endif | 529 #endif |
533 | 530 |
534 if (!LaunchBrowser(state)) { | 531 // Set up IPC testing interface as a client. |
535 LOG(ERROR) << "Failed to LaunchBrowser"; | 532 ASSERT_TRUE(LaunchBrowser(state)); |
536 return false; | |
537 } | |
538 } | 533 } |
539 | 534 |
540 // Wait for browser to be ready for connections. | 535 // Wait for browser to be ready for connections. |
541 bool channel_initialized = false; | 536 bool channel_initialized = false; |
542 for (int wait_time = 0; | 537 for (int wait_time = 0; |
543 wait_time < TestTimeouts::action_max_timeout_ms(); | 538 wait_time < TestTimeouts::action_max_timeout_ms(); |
544 wait_time += automation::kSleepTime) { | 539 wait_time += automation::kSleepTime) { |
545 channel_initialized = IPC::Channel::IsNamedServerInitialized(channel_id_); | 540 channel_initialized = IPC::Channel::IsNamedServerInitialized(channel_id_); |
546 if (channel_initialized) | 541 if (channel_initialized) |
547 break; | 542 break; |
548 base::PlatformThread::Sleep(automation::kSleepTime); | 543 base::PlatformThread::Sleep(automation::kSleepTime); |
549 } | 544 } |
550 if (!channel_initialized) { | 545 EXPECT_TRUE(channel_initialized); |
551 LOG(ERROR) << "Failed to wait for testing channel presence."; | |
552 return false; | |
553 } | |
554 | 546 |
555 if (!ConnectToRunningBrowser(wait_for_initial_loads)) { | 547 ASSERT_TRUE(ConnectToRunningBrowser(wait_for_initial_loads)); |
556 LOG(ERROR) << "Failed to ConnectToRunningBrowser"; | |
557 return false; | |
558 } | |
559 return true; | |
560 } | 548 } |
561 | 549 |
562 void NamedProxyLauncher::TerminateConnection() { | 550 void NamedProxyLauncher::TerminateConnection() { |
563 if (launch_browser_) | 551 if (launch_browser_) |
564 CloseBrowserAndServer(); | 552 CloseBrowserAndServer(); |
565 else | 553 else |
566 DisconnectFromRunningBrowser(); | 554 DisconnectFromRunningBrowser(); |
567 } | 555 } |
568 | 556 |
569 std::string NamedProxyLauncher::PrefixedChannelID() const { | 557 std::string NamedProxyLauncher::PrefixedChannelID() const { |
(...skipping 10 matching lines...) Expand all Loading... |
580 } | 568 } |
581 | 569 |
582 AutomationProxy* AnonymousProxyLauncher::CreateAutomationProxy( | 570 AutomationProxy* AnonymousProxyLauncher::CreateAutomationProxy( |
583 int execution_timeout) { | 571 int execution_timeout) { |
584 AutomationProxy* proxy = new AutomationProxy(execution_timeout, | 572 AutomationProxy* proxy = new AutomationProxy(execution_timeout, |
585 disconnect_on_failure_); | 573 disconnect_on_failure_); |
586 proxy->InitializeChannel(channel_id_, false); | 574 proxy->InitializeChannel(channel_id_, false); |
587 return proxy; | 575 return proxy; |
588 } | 576 } |
589 | 577 |
590 bool AnonymousProxyLauncher::InitializeConnection(const LaunchState& state, | 578 void AnonymousProxyLauncher::InitializeConnection(const LaunchState& state, |
591 bool wait_for_initial_loads) { | 579 bool wait_for_initial_loads) { |
592 return LaunchBrowserAndServer(state, wait_for_initial_loads); | 580 ASSERT_TRUE(LaunchBrowserAndServer(state, wait_for_initial_loads)); |
593 } | 581 } |
594 | 582 |
595 void AnonymousProxyLauncher::TerminateConnection() { | 583 void AnonymousProxyLauncher::TerminateConnection() { |
596 CloseBrowserAndServer(); | 584 CloseBrowserAndServer(); |
597 } | 585 } |
598 | 586 |
599 std::string AnonymousProxyLauncher::PrefixedChannelID() const { | 587 std::string AnonymousProxyLauncher::PrefixedChannelID() const { |
600 return channel_id_; | 588 return channel_id_; |
601 } | 589 } |
OLD | NEW |