| Index: net/proxy/dhcp_proxy_script_fetcher_win_unittest.cc
|
| diff --git a/net/proxy/dhcp_proxy_script_fetcher_win_unittest.cc b/net/proxy/dhcp_proxy_script_fetcher_win_unittest.cc
|
| deleted file mode 100644
|
| index d9c4356600f3f57652b33a48a6e6d8a83e8642c5..0000000000000000000000000000000000000000
|
| --- a/net/proxy/dhcp_proxy_script_fetcher_win_unittest.cc
|
| +++ /dev/null
|
| @@ -1,649 +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 "net/proxy/dhcp_proxy_script_fetcher_win.h"
|
| -
|
| -#include <vector>
|
| -
|
| -#include "base/bind.h"
|
| -#include "base/bind_helpers.h"
|
| -#include "base/message_loop/message_loop.h"
|
| -#include "base/rand_util.h"
|
| -#include "base/test/test_timeouts.h"
|
| -#include "base/threading/platform_thread.h"
|
| -#include "base/timer/elapsed_timer.h"
|
| -#include "net/base/completion_callback.h"
|
| -#include "net/proxy/dhcp_proxy_script_adapter_fetcher_win.h"
|
| -#include "net/url_request/url_request_test_util.h"
|
| -#include "testing/gtest/include/gtest/gtest.h"
|
| -
|
| -namespace net {
|
| -
|
| -namespace {
|
| -
|
| -TEST(DhcpProxyScriptFetcherWin, AdapterNamesAndPacURLFromDhcp) {
|
| - // This tests our core Win32 implementation without any of the wrappers
|
| - // we layer on top to achieve asynchronous and parallel operations.
|
| - //
|
| - // We don't make assumptions about the environment this unit test is
|
| - // running in, so it just exercises the code to make sure there
|
| - // is no crash and no error returned, but does not assert on the number
|
| - // of interfaces or the information returned via DHCP.
|
| - std::set<std::string> adapter_names;
|
| - DhcpProxyScriptFetcherWin::GetCandidateAdapterNames(&adapter_names);
|
| - for (std::set<std::string>::const_iterator it = adapter_names.begin();
|
| - it != adapter_names.end();
|
| - ++it) {
|
| - const std::string& adapter_name = *it;
|
| - DhcpProxyScriptAdapterFetcher::GetPacURLFromDhcp(adapter_name);
|
| - }
|
| -}
|
| -
|
| -// Helper for RealFetch* tests below.
|
| -class RealFetchTester {
|
| - public:
|
| - RealFetchTester()
|
| - : context_(new TestURLRequestContext),
|
| - fetcher_(new DhcpProxyScriptFetcherWin(context_.get())),
|
| - finished_(false),
|
| - on_completion_is_error_(false) {
|
| - // Make sure the test ends.
|
| - timeout_.Start(FROM_HERE,
|
| - base::TimeDelta::FromSeconds(5), this, &RealFetchTester::OnTimeout);
|
| - }
|
| -
|
| - void RunTest() {
|
| - int result = fetcher_->Fetch(
|
| - &pac_text_,
|
| - base::Bind(&RealFetchTester::OnCompletion, base::Unretained(this)));
|
| - if (result != ERR_IO_PENDING)
|
| - finished_ = true;
|
| - }
|
| -
|
| - void RunTestWithCancel() {
|
| - RunTest();
|
| - fetcher_->Cancel();
|
| - }
|
| -
|
| - void RunTestWithDeferredCancel() {
|
| - // Put the cancellation into the queue before even running the
|
| - // test to avoid the chance of one of the adapter fetcher worker
|
| - // threads completing before cancellation. See http://crbug.com/86756.
|
| - cancel_timer_.Start(FROM_HERE, base::TimeDelta::FromMilliseconds(0),
|
| - this, &RealFetchTester::OnCancelTimer);
|
| - RunTest();
|
| - }
|
| -
|
| - void OnCompletion(int result) {
|
| - if (on_completion_is_error_) {
|
| - FAIL() << "Received completion for test in which this is error.";
|
| - }
|
| - finished_ = true;
|
| - }
|
| -
|
| - void OnTimeout() {
|
| - OnCompletion(0);
|
| - }
|
| -
|
| - void OnCancelTimer() {
|
| - fetcher_->Cancel();
|
| - finished_ = true;
|
| - }
|
| -
|
| - void WaitUntilDone() {
|
| - while (!finished_) {
|
| - base::MessageLoop::current()->RunUntilIdle();
|
| - }
|
| - base::MessageLoop::current()->RunUntilIdle();
|
| - }
|
| -
|
| - // Attempts to give worker threads time to finish. This is currently
|
| - // very simplistic as completion (via completion callback or cancellation)
|
| - // immediately "detaches" any worker threads, so the best we can do is give
|
| - // them a little time. If we start running into Valgrind leaks, we can
|
| - // do something a bit more clever to track worker threads even when the
|
| - // DhcpProxyScriptFetcherWin state machine has finished.
|
| - void FinishTestAllowCleanup() {
|
| - base::PlatformThread::Sleep(base::TimeDelta::FromMilliseconds(30));
|
| - }
|
| -
|
| - scoped_ptr<URLRequestContext> context_;
|
| - scoped_ptr<DhcpProxyScriptFetcherWin> fetcher_;
|
| - bool finished_;
|
| - base::string16 pac_text_;
|
| - base::OneShotTimer<RealFetchTester> timeout_;
|
| - base::OneShotTimer<RealFetchTester> cancel_timer_;
|
| - bool on_completion_is_error_;
|
| -};
|
| -
|
| -TEST(DhcpProxyScriptFetcherWin, RealFetch) {
|
| - // This tests a call to Fetch() with no stubbing out of dependencies.
|
| - //
|
| - // We don't make assumptions about the environment this unit test is
|
| - // running in, so it just exercises the code to make sure there
|
| - // is no crash and no unexpected error returned, but does not assert on
|
| - // results beyond that.
|
| - RealFetchTester fetcher;
|
| - fetcher.RunTest();
|
| -
|
| - fetcher.WaitUntilDone();
|
| - fetcher.fetcher_->GetPacURL().possibly_invalid_spec();
|
| -
|
| - fetcher.FinishTestAllowCleanup();
|
| -}
|
| -
|
| -TEST(DhcpProxyScriptFetcherWin, RealFetchWithCancel) {
|
| - // Does a Fetch() with an immediate cancel. As before, just
|
| - // exercises the code without stubbing out dependencies.
|
| - RealFetchTester fetcher;
|
| - fetcher.RunTestWithCancel();
|
| - base::MessageLoop::current()->RunUntilIdle();
|
| -
|
| - // Attempt to avoid Valgrind leak reports in case worker thread is
|
| - // still running.
|
| - fetcher.FinishTestAllowCleanup();
|
| -}
|
| -
|
| -// For RealFetchWithDeferredCancel, below.
|
| -class DelayingDhcpProxyScriptAdapterFetcher
|
| - : public DhcpProxyScriptAdapterFetcher {
|
| - public:
|
| - DelayingDhcpProxyScriptAdapterFetcher(
|
| - URLRequestContext* url_request_context,
|
| - scoped_refptr<base::TaskRunner> task_runner)
|
| - : DhcpProxyScriptAdapterFetcher(url_request_context, task_runner) {
|
| - }
|
| -
|
| - class DelayingDhcpQuery : public DhcpQuery {
|
| - public:
|
| - explicit DelayingDhcpQuery()
|
| - : DhcpQuery() {
|
| - }
|
| -
|
| - std::string ImplGetPacURLFromDhcp(
|
| - const std::string& adapter_name) override {
|
| - base::PlatformThread::Sleep(base::TimeDelta::FromMilliseconds(20));
|
| - return DhcpQuery::ImplGetPacURLFromDhcp(adapter_name);
|
| - }
|
| - };
|
| -
|
| - DhcpQuery* ImplCreateDhcpQuery() override {
|
| - return new DelayingDhcpQuery();
|
| - }
|
| -};
|
| -
|
| -// For RealFetchWithDeferredCancel, below.
|
| -class DelayingDhcpProxyScriptFetcherWin
|
| - : public DhcpProxyScriptFetcherWin {
|
| - public:
|
| - explicit DelayingDhcpProxyScriptFetcherWin(
|
| - URLRequestContext* context)
|
| - : DhcpProxyScriptFetcherWin(context) {
|
| - }
|
| -
|
| - DhcpProxyScriptAdapterFetcher* ImplCreateAdapterFetcher() override {
|
| - return new DelayingDhcpProxyScriptAdapterFetcher(url_request_context(),
|
| - GetTaskRunner());
|
| - }
|
| -};
|
| -
|
| -TEST(DhcpProxyScriptFetcherWin, RealFetchWithDeferredCancel) {
|
| - // Does a Fetch() with a slightly delayed cancel. As before, just
|
| - // exercises the code without stubbing out dependencies, but
|
| - // introduces a guaranteed 20 ms delay on the worker threads so that
|
| - // the cancel is called before they complete.
|
| - RealFetchTester fetcher;
|
| - fetcher.fetcher_.reset(
|
| - new DelayingDhcpProxyScriptFetcherWin(fetcher.context_.get()));
|
| - fetcher.on_completion_is_error_ = true;
|
| - fetcher.RunTestWithDeferredCancel();
|
| - fetcher.WaitUntilDone();
|
| -}
|
| -
|
| -// The remaining tests are to exercise our state machine in various
|
| -// situations, with actual network access fully stubbed out.
|
| -
|
| -class DummyDhcpProxyScriptAdapterFetcher
|
| - : public DhcpProxyScriptAdapterFetcher {
|
| - public:
|
| - DummyDhcpProxyScriptAdapterFetcher(URLRequestContext* context,
|
| - scoped_refptr<base::TaskRunner> runner)
|
| - : DhcpProxyScriptAdapterFetcher(context, runner),
|
| - did_finish_(false),
|
| - result_(OK),
|
| - pac_script_(L"bingo"),
|
| - fetch_delay_ms_(1) {
|
| - }
|
| -
|
| - void Fetch(const std::string& adapter_name,
|
| - const CompletionCallback& callback) override {
|
| - callback_ = callback;
|
| - timer_.Start(FROM_HERE, base::TimeDelta::FromMilliseconds(fetch_delay_ms_),
|
| - this, &DummyDhcpProxyScriptAdapterFetcher::OnTimer);
|
| - }
|
| -
|
| - void Cancel() override {
|
| - timer_.Stop();
|
| - }
|
| -
|
| - bool DidFinish() const override {
|
| - return did_finish_;
|
| - }
|
| -
|
| - int GetResult() const override {
|
| - return result_;
|
| - }
|
| -
|
| - base::string16 GetPacScript() const override {
|
| - return pac_script_;
|
| - }
|
| -
|
| - void OnTimer() {
|
| - callback_.Run(result_);
|
| - }
|
| -
|
| - void Configure(bool did_finish,
|
| - int result,
|
| - base::string16 pac_script,
|
| - int fetch_delay_ms) {
|
| - did_finish_ = did_finish;
|
| - result_ = result;
|
| - pac_script_ = pac_script;
|
| - fetch_delay_ms_ = fetch_delay_ms;
|
| - }
|
| -
|
| - private:
|
| - bool did_finish_;
|
| - int result_;
|
| - base::string16 pac_script_;
|
| - int fetch_delay_ms_;
|
| - CompletionCallback callback_;
|
| - base::OneShotTimer<DummyDhcpProxyScriptAdapterFetcher> timer_;
|
| -};
|
| -
|
| -class MockDhcpProxyScriptFetcherWin : public DhcpProxyScriptFetcherWin {
|
| - public:
|
| - class MockAdapterQuery : public AdapterQuery {
|
| - public:
|
| - MockAdapterQuery() {
|
| - }
|
| -
|
| - virtual ~MockAdapterQuery() {
|
| - }
|
| -
|
| - virtual bool ImplGetCandidateAdapterNames(
|
| - std::set<std::string>* adapter_names) override {
|
| - adapter_names->insert(
|
| - mock_adapter_names_.begin(), mock_adapter_names_.end());
|
| - return true;
|
| - }
|
| -
|
| - std::vector<std::string> mock_adapter_names_;
|
| - };
|
| -
|
| - MockDhcpProxyScriptFetcherWin(URLRequestContext* context)
|
| - : DhcpProxyScriptFetcherWin(context),
|
| - num_fetchers_created_(0),
|
| - worker_finished_event_(true, false) {
|
| - ResetTestState();
|
| - }
|
| -
|
| - virtual ~MockDhcpProxyScriptFetcherWin() {
|
| - ResetTestState();
|
| - }
|
| -
|
| - using DhcpProxyScriptFetcherWin::GetTaskRunner;
|
| -
|
| - // Adds a fetcher object to the queue of fetchers used by
|
| - // |ImplCreateAdapterFetcher()|, and its name to the list of adapters
|
| - // returned by ImplGetCandidateAdapterNames.
|
| - void PushBackAdapter(const std::string& adapter_name,
|
| - DhcpProxyScriptAdapterFetcher* fetcher) {
|
| - adapter_query_->mock_adapter_names_.push_back(adapter_name);
|
| - adapter_fetchers_.push_back(fetcher);
|
| - }
|
| -
|
| - void ConfigureAndPushBackAdapter(const std::string& adapter_name,
|
| - bool did_finish,
|
| - int result,
|
| - base::string16 pac_script,
|
| - base::TimeDelta fetch_delay) {
|
| - scoped_ptr<DummyDhcpProxyScriptAdapterFetcher> adapter_fetcher(
|
| - new DummyDhcpProxyScriptAdapterFetcher(url_request_context(),
|
| - GetTaskRunner()));
|
| - adapter_fetcher->Configure(
|
| - did_finish, result, pac_script, fetch_delay.InMilliseconds());
|
| - PushBackAdapter(adapter_name, adapter_fetcher.release());
|
| - }
|
| -
|
| - DhcpProxyScriptAdapterFetcher* ImplCreateAdapterFetcher() override {
|
| - ++num_fetchers_created_;
|
| - return adapter_fetchers_[next_adapter_fetcher_index_++];
|
| - }
|
| -
|
| - virtual AdapterQuery* ImplCreateAdapterQuery() override {
|
| - DCHECK(adapter_query_.get());
|
| - return adapter_query_.get();
|
| - }
|
| -
|
| - base::TimeDelta ImplGetMaxWait() override {
|
| - return max_wait_;
|
| - }
|
| -
|
| - void ImplOnGetCandidateAdapterNamesDone() override {
|
| - worker_finished_event_.Signal();
|
| - }
|
| -
|
| - void ResetTestState() {
|
| - // Delete any adapter fetcher objects we didn't hand out.
|
| - std::vector<DhcpProxyScriptAdapterFetcher*>::const_iterator it
|
| - = adapter_fetchers_.begin();
|
| - for (; it != adapter_fetchers_.end(); ++it) {
|
| - if (num_fetchers_created_-- <= 0) {
|
| - delete (*it);
|
| - }
|
| - }
|
| -
|
| - next_adapter_fetcher_index_ = 0;
|
| - num_fetchers_created_ = 0;
|
| - adapter_fetchers_.clear();
|
| - adapter_query_ = new MockAdapterQuery();
|
| - max_wait_ = TestTimeouts::tiny_timeout();
|
| - }
|
| -
|
| - bool HasPendingFetchers() {
|
| - return num_pending_fetchers() > 0;
|
| - }
|
| -
|
| - int next_adapter_fetcher_index_;
|
| -
|
| - // Ownership gets transferred to the implementation class via
|
| - // ImplCreateAdapterFetcher, but any objects not handed out are
|
| - // deleted on destruction.
|
| - std::vector<DhcpProxyScriptAdapterFetcher*> adapter_fetchers_;
|
| -
|
| - scoped_refptr<MockAdapterQuery> adapter_query_;
|
| -
|
| - base::TimeDelta max_wait_;
|
| - int num_fetchers_created_;
|
| - base::WaitableEvent worker_finished_event_;
|
| -};
|
| -
|
| -class FetcherClient {
|
| - public:
|
| - FetcherClient()
|
| - : context_(new TestURLRequestContext),
|
| - fetcher_(context_.get()),
|
| - finished_(false),
|
| - result_(ERR_UNEXPECTED) {
|
| - }
|
| -
|
| - void RunTest() {
|
| - int result = fetcher_.Fetch(
|
| - &pac_text_,
|
| - base::Bind(&FetcherClient::OnCompletion, base::Unretained(this)));
|
| - ASSERT_EQ(ERR_IO_PENDING, result);
|
| - }
|
| -
|
| - void RunMessageLoopUntilComplete() {
|
| - while (!finished_) {
|
| - base::MessageLoop::current()->RunUntilIdle();
|
| - }
|
| - base::MessageLoop::current()->RunUntilIdle();
|
| - }
|
| -
|
| - void RunMessageLoopUntilWorkerDone() {
|
| - DCHECK(fetcher_.adapter_query_.get());
|
| - while (!fetcher_.worker_finished_event_.TimedWait(
|
| - base::TimeDelta::FromMilliseconds(10))) {
|
| - base::MessageLoop::current()->RunUntilIdle();
|
| - }
|
| - }
|
| -
|
| - void OnCompletion(int result) {
|
| - finished_ = true;
|
| - result_ = result;
|
| - }
|
| -
|
| - void ResetTestState() {
|
| - finished_ = false;
|
| - result_ = ERR_UNEXPECTED;
|
| - pac_text_ = L"";
|
| - fetcher_.ResetTestState();
|
| - }
|
| -
|
| - scoped_refptr<base::TaskRunner> GetTaskRunner() {
|
| - return fetcher_.GetTaskRunner();
|
| - }
|
| -
|
| - scoped_ptr<URLRequestContext> context_;
|
| - MockDhcpProxyScriptFetcherWin fetcher_;
|
| - bool finished_;
|
| - int result_;
|
| - base::string16 pac_text_;
|
| -};
|
| -
|
| -// We separate out each test's logic so that we can easily implement
|
| -// the ReuseFetcher test at the bottom.
|
| -void TestNormalCaseURLConfiguredOneAdapter(FetcherClient* client) {
|
| - TestURLRequestContext context;
|
| - scoped_ptr<DummyDhcpProxyScriptAdapterFetcher> adapter_fetcher(
|
| - new DummyDhcpProxyScriptAdapterFetcher(&context,
|
| - client->GetTaskRunner()));
|
| - adapter_fetcher->Configure(true, OK, L"bingo", 1);
|
| - client->fetcher_.PushBackAdapter("a", adapter_fetcher.release());
|
| - client->RunTest();
|
| - client->RunMessageLoopUntilComplete();
|
| - ASSERT_EQ(OK, client->result_);
|
| - ASSERT_EQ(L"bingo", client->pac_text_);
|
| -}
|
| -
|
| -TEST(DhcpProxyScriptFetcherWin, NormalCaseURLConfiguredOneAdapter) {
|
| - FetcherClient client;
|
| - TestNormalCaseURLConfiguredOneAdapter(&client);
|
| -}
|
| -
|
| -void TestNormalCaseURLConfiguredMultipleAdapters(FetcherClient* client) {
|
| - client->fetcher_.ConfigureAndPushBackAdapter(
|
| - "most_preferred", true, ERR_PAC_NOT_IN_DHCP, L"",
|
| - base::TimeDelta::FromMilliseconds(1));
|
| - client->fetcher_.ConfigureAndPushBackAdapter(
|
| - "second", true, OK, L"bingo", base::TimeDelta::FromMilliseconds(50));
|
| - client->fetcher_.ConfigureAndPushBackAdapter(
|
| - "third", true, OK, L"rocko", base::TimeDelta::FromMilliseconds(1));
|
| - client->RunTest();
|
| - client->RunMessageLoopUntilComplete();
|
| - ASSERT_EQ(OK, client->result_);
|
| - ASSERT_EQ(L"bingo", client->pac_text_);
|
| -}
|
| -
|
| -TEST(DhcpProxyScriptFetcherWin, NormalCaseURLConfiguredMultipleAdapters) {
|
| - FetcherClient client;
|
| - TestNormalCaseURLConfiguredMultipleAdapters(&client);
|
| -}
|
| -
|
| -void TestNormalCaseURLConfiguredMultipleAdaptersWithTimeout(
|
| - FetcherClient* client) {
|
| - client->fetcher_.ConfigureAndPushBackAdapter(
|
| - "most_preferred", true, ERR_PAC_NOT_IN_DHCP, L"",
|
| - base::TimeDelta::FromMilliseconds(1));
|
| - // This will time out.
|
| - client->fetcher_.ConfigureAndPushBackAdapter(
|
| - "second", false, ERR_IO_PENDING, L"bingo",
|
| - TestTimeouts::action_timeout());
|
| - client->fetcher_.ConfigureAndPushBackAdapter(
|
| - "third", true, OK, L"rocko", base::TimeDelta::FromMilliseconds(1));
|
| - client->RunTest();
|
| - client->RunMessageLoopUntilComplete();
|
| - ASSERT_EQ(OK, client->result_);
|
| - ASSERT_EQ(L"rocko", client->pac_text_);
|
| -}
|
| -
|
| -TEST(DhcpProxyScriptFetcherWin,
|
| - NormalCaseURLConfiguredMultipleAdaptersWithTimeout) {
|
| - FetcherClient client;
|
| - TestNormalCaseURLConfiguredMultipleAdaptersWithTimeout(&client);
|
| -}
|
| -
|
| -void TestFailureCaseURLConfiguredMultipleAdaptersWithTimeout(
|
| - FetcherClient* client) {
|
| - client->fetcher_.ConfigureAndPushBackAdapter(
|
| - "most_preferred", true, ERR_PAC_NOT_IN_DHCP, L"",
|
| - base::TimeDelta::FromMilliseconds(1));
|
| - // This will time out.
|
| - client->fetcher_.ConfigureAndPushBackAdapter(
|
| - "second", false, ERR_IO_PENDING, L"bingo",
|
| - TestTimeouts::action_timeout());
|
| - // This is the first non-ERR_PAC_NOT_IN_DHCP error and as such
|
| - // should be chosen.
|
| - client->fetcher_.ConfigureAndPushBackAdapter(
|
| - "third", true, ERR_PAC_STATUS_NOT_OK, L"",
|
| - base::TimeDelta::FromMilliseconds(1));
|
| - client->fetcher_.ConfigureAndPushBackAdapter(
|
| - "fourth", true, ERR_NOT_IMPLEMENTED, L"",
|
| - base::TimeDelta::FromMilliseconds(1));
|
| - client->RunTest();
|
| - client->RunMessageLoopUntilComplete();
|
| - ASSERT_EQ(ERR_PAC_STATUS_NOT_OK, client->result_);
|
| - ASSERT_EQ(L"", client->pac_text_);
|
| -}
|
| -
|
| -TEST(DhcpProxyScriptFetcherWin,
|
| - FailureCaseURLConfiguredMultipleAdaptersWithTimeout) {
|
| - FetcherClient client;
|
| - TestFailureCaseURLConfiguredMultipleAdaptersWithTimeout(&client);
|
| -}
|
| -
|
| -void TestFailureCaseNoURLConfigured(FetcherClient* client) {
|
| - client->fetcher_.ConfigureAndPushBackAdapter(
|
| - "most_preferred", true, ERR_PAC_NOT_IN_DHCP, L"",
|
| - base::TimeDelta::FromMilliseconds(1));
|
| - // This will time out.
|
| - client->fetcher_.ConfigureAndPushBackAdapter(
|
| - "second", false, ERR_IO_PENDING, L"bingo",
|
| - TestTimeouts::action_timeout());
|
| - // This is the first non-ERR_PAC_NOT_IN_DHCP error and as such
|
| - // should be chosen.
|
| - client->fetcher_.ConfigureAndPushBackAdapter(
|
| - "third", true, ERR_PAC_NOT_IN_DHCP, L"",
|
| - base::TimeDelta::FromMilliseconds(1));
|
| - client->RunTest();
|
| - client->RunMessageLoopUntilComplete();
|
| - ASSERT_EQ(ERR_PAC_NOT_IN_DHCP, client->result_);
|
| - ASSERT_EQ(L"", client->pac_text_);
|
| -}
|
| -
|
| -TEST(DhcpProxyScriptFetcherWin, FailureCaseNoURLConfigured) {
|
| - FetcherClient client;
|
| - TestFailureCaseNoURLConfigured(&client);
|
| -}
|
| -
|
| -void TestFailureCaseNoDhcpAdapters(FetcherClient* client) {
|
| - client->RunTest();
|
| - client->RunMessageLoopUntilComplete();
|
| - ASSERT_EQ(ERR_PAC_NOT_IN_DHCP, client->result_);
|
| - ASSERT_EQ(L"", client->pac_text_);
|
| - ASSERT_EQ(0, client->fetcher_.num_fetchers_created_);
|
| -}
|
| -
|
| -TEST(DhcpProxyScriptFetcherWin, FailureCaseNoDhcpAdapters) {
|
| - FetcherClient client;
|
| - TestFailureCaseNoDhcpAdapters(&client);
|
| -}
|
| -
|
| -void TestShortCircuitLessPreferredAdapters(FetcherClient* client) {
|
| - // Here we have a bunch of adapters; the first reports no PAC in DHCP,
|
| - // the second responds quickly with a PAC file, the rest take a long
|
| - // time. Verify that we complete quickly and do not wait for the slow
|
| - // adapters, i.e. we finish before timeout.
|
| - client->fetcher_.ConfigureAndPushBackAdapter(
|
| - "1", true, ERR_PAC_NOT_IN_DHCP, L"",
|
| - base::TimeDelta::FromMilliseconds(1));
|
| - client->fetcher_.ConfigureAndPushBackAdapter(
|
| - "2", true, OK, L"bingo",
|
| - base::TimeDelta::FromMilliseconds(1));
|
| - client->fetcher_.ConfigureAndPushBackAdapter(
|
| - "3", true, OK, L"wrongo", TestTimeouts::action_max_timeout());
|
| -
|
| - // Increase the timeout to ensure the short circuit mechanism has
|
| - // time to kick in before the timeout waiting for more adapters kicks in.
|
| - client->fetcher_.max_wait_ = TestTimeouts::action_timeout();
|
| -
|
| - base::ElapsedTimer timer;
|
| - client->RunTest();
|
| - client->RunMessageLoopUntilComplete();
|
| - ASSERT_TRUE(client->fetcher_.HasPendingFetchers());
|
| - // Assert that the time passed is definitely less than the wait timer
|
| - // timeout, to get a second signal that it was the shortcut mechanism
|
| - // (in OnFetcherDone) that kicked in, and not the timeout waiting for
|
| - // more adapters.
|
| - ASSERT_GT(client->fetcher_.max_wait_ - (client->fetcher_.max_wait_ / 10),
|
| - timer.Elapsed());
|
| -}
|
| -
|
| -TEST(DhcpProxyScriptFetcherWin, ShortCircuitLessPreferredAdapters) {
|
| - FetcherClient client;
|
| - TestShortCircuitLessPreferredAdapters(&client);
|
| -}
|
| -
|
| -void TestImmediateCancel(FetcherClient* client) {
|
| - TestURLRequestContext context;
|
| - scoped_ptr<DummyDhcpProxyScriptAdapterFetcher> adapter_fetcher(
|
| - new DummyDhcpProxyScriptAdapterFetcher(&context,
|
| - client->GetTaskRunner()));
|
| - adapter_fetcher->Configure(true, OK, L"bingo", 1);
|
| - client->fetcher_.PushBackAdapter("a", adapter_fetcher.release());
|
| - client->RunTest();
|
| - client->fetcher_.Cancel();
|
| - client->RunMessageLoopUntilWorkerDone();
|
| - ASSERT_EQ(0, client->fetcher_.num_fetchers_created_);
|
| -}
|
| -
|
| -// Regression test to check that when we cancel immediately, no
|
| -// adapter fetchers get created.
|
| -TEST(DhcpProxyScriptFetcherWin, ImmediateCancel) {
|
| - FetcherClient client;
|
| - TestImmediateCancel(&client);
|
| -}
|
| -
|
| -TEST(DhcpProxyScriptFetcherWin, ReuseFetcher) {
|
| - FetcherClient client;
|
| -
|
| - // The ProxyScriptFetcher interface stipulates that only a single
|
| - // |Fetch()| may be in flight at once, but allows reuse, so test
|
| - // that the state transitions correctly from done to start in all
|
| - // cases we're testing.
|
| -
|
| - typedef void (*FetcherClientTestFunction)(FetcherClient*);
|
| - typedef std::vector<FetcherClientTestFunction> TestVector;
|
| - TestVector test_functions;
|
| - test_functions.push_back(TestNormalCaseURLConfiguredOneAdapter);
|
| - test_functions.push_back(TestNormalCaseURLConfiguredMultipleAdapters);
|
| - test_functions.push_back(
|
| - TestNormalCaseURLConfiguredMultipleAdaptersWithTimeout);
|
| - test_functions.push_back(
|
| - TestFailureCaseURLConfiguredMultipleAdaptersWithTimeout);
|
| - test_functions.push_back(TestFailureCaseNoURLConfigured);
|
| - test_functions.push_back(TestFailureCaseNoDhcpAdapters);
|
| - test_functions.push_back(TestShortCircuitLessPreferredAdapters);
|
| - test_functions.push_back(TestImmediateCancel);
|
| -
|
| - std::random_shuffle(test_functions.begin(),
|
| - test_functions.end(),
|
| - base::RandGenerator);
|
| - for (TestVector::const_iterator it = test_functions.begin();
|
| - it != test_functions.end();
|
| - ++it) {
|
| - (*it)(&client);
|
| - client.ResetTestState();
|
| - }
|
| -
|
| - // Re-do the first test to make sure the last test that was run did
|
| - // not leave things in a bad state.
|
| - (*test_functions.begin())(&client);
|
| -}
|
| -
|
| -} // namespace
|
| -
|
| -} // namespace net
|
|
|