| Index: net/http/http_server_properties_manager_unittest.cc
|
| diff --git a/net/http/http_server_properties_manager_unittest.cc b/net/http/http_server_properties_manager_unittest.cc
|
| deleted file mode 100644
|
| index f2e36499e736850c19b757f9e8146e5d6adbf96c..0000000000000000000000000000000000000000
|
| --- a/net/http/http_server_properties_manager_unittest.cc
|
| +++ /dev/null
|
| @@ -1,781 +0,0 @@
|
| -// Copyright 2014 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/http/http_server_properties_manager.h"
|
| -
|
| -#include "base/basictypes.h"
|
| -#include "base/json/json_writer.h"
|
| -#include "base/message_loop/message_loop.h"
|
| -#include "base/prefs/pref_registry_simple.h"
|
| -#include "base/prefs/testing_pref_service.h"
|
| -#include "base/run_loop.h"
|
| -#include "base/strings/string_number_conversions.h"
|
| -#include "base/strings/stringprintf.h"
|
| -#include "base/test/test_simple_task_runner.h"
|
| -#include "base/values.h"
|
| -#include "testing/gmock/include/gmock/gmock.h"
|
| -#include "testing/gtest/include/gtest/gtest.h"
|
| -#include "url/gurl.h"
|
| -
|
| -namespace net {
|
| -
|
| -namespace {
|
| -
|
| -using base::StringPrintf;
|
| -using ::testing::_;
|
| -using ::testing::Invoke;
|
| -using ::testing::Mock;
|
| -using ::testing::StrictMock;
|
| -
|
| -const char kTestHttpServerProperties[] = "TestHttpServerProperties";
|
| -
|
| -class TestingHttpServerPropertiesManager : public HttpServerPropertiesManager {
|
| - public:
|
| - TestingHttpServerPropertiesManager(
|
| - PrefService* pref_service,
|
| - const char* pref_path,
|
| - scoped_refptr<base::SingleThreadTaskRunner> io_task_runner)
|
| - : HttpServerPropertiesManager(pref_service, pref_path, io_task_runner) {
|
| - InitializeOnNetworkThread();
|
| - }
|
| -
|
| - virtual ~TestingHttpServerPropertiesManager() {}
|
| -
|
| - // Make these methods public for testing.
|
| - using HttpServerPropertiesManager::ScheduleUpdateCacheOnPrefThread;
|
| - using HttpServerPropertiesManager::ScheduleUpdatePrefsOnNetworkThread;
|
| -
|
| - // Post tasks without a delay during tests.
|
| - virtual void StartPrefsUpdateTimerOnNetworkThread(
|
| - base::TimeDelta delay) override {
|
| - HttpServerPropertiesManager::StartPrefsUpdateTimerOnNetworkThread(
|
| - base::TimeDelta());
|
| - }
|
| -
|
| - void UpdateCacheFromPrefsOnUIConcrete() {
|
| - HttpServerPropertiesManager::UpdateCacheFromPrefsOnPrefThread();
|
| - }
|
| -
|
| - // Post tasks without a delay during tests.
|
| - virtual void StartCacheUpdateTimerOnPrefThread(
|
| - base::TimeDelta delay) override {
|
| - HttpServerPropertiesManager::StartCacheUpdateTimerOnPrefThread(
|
| - base::TimeDelta());
|
| - }
|
| -
|
| - void UpdatePrefsFromCacheOnNetworkThreadConcrete(
|
| - const base::Closure& callback) {
|
| - HttpServerPropertiesManager::UpdatePrefsFromCacheOnNetworkThread(callback);
|
| - }
|
| -
|
| - MOCK_METHOD0(UpdateCacheFromPrefsOnPrefThread, void());
|
| - MOCK_METHOD1(UpdatePrefsFromCacheOnNetworkThread, void(const base::Closure&));
|
| - MOCK_METHOD6(UpdateCacheFromPrefsOnNetworkThread,
|
| - void(std::vector<std::string>* spdy_servers,
|
| - SpdySettingsMap* spdy_settings_map,
|
| - AlternateProtocolMap* alternate_protocol_map,
|
| - IPAddressNumber* last_quic_address,
|
| - ServerNetworkStatsMap* server_network_stats_map,
|
| - bool detected_corrupted_prefs));
|
| - MOCK_METHOD5(UpdatePrefsOnPref,
|
| - void(base::ListValue* spdy_server_list,
|
| - SpdySettingsMap* spdy_settings_map,
|
| - AlternateProtocolMap* alternate_protocol_map,
|
| - IPAddressNumber* last_quic_address,
|
| - ServerNetworkStatsMap* server_network_stats_map));
|
| -
|
| - private:
|
| - DISALLOW_COPY_AND_ASSIGN(TestingHttpServerPropertiesManager);
|
| -};
|
| -
|
| -class HttpServerPropertiesManagerTest : public testing::Test {
|
| - protected:
|
| - HttpServerPropertiesManagerTest() {}
|
| -
|
| - void SetUp() override {
|
| - pref_service_.registry()->RegisterDictionaryPref(kTestHttpServerProperties);
|
| - http_server_props_manager_.reset(
|
| - new StrictMock<TestingHttpServerPropertiesManager>(
|
| - &pref_service_,
|
| - kTestHttpServerProperties,
|
| - base::MessageLoop::current()->message_loop_proxy()));
|
| - ExpectCacheUpdate();
|
| - base::RunLoop().RunUntilIdle();
|
| - }
|
| -
|
| - void TearDown() override {
|
| - if (http_server_props_manager_.get())
|
| - http_server_props_manager_->ShutdownOnPrefThread();
|
| - base::RunLoop().RunUntilIdle();
|
| - http_server_props_manager_.reset();
|
| - }
|
| -
|
| - void ExpectCacheUpdate() {
|
| - EXPECT_CALL(*http_server_props_manager_, UpdateCacheFromPrefsOnPrefThread())
|
| - .WillOnce(Invoke(http_server_props_manager_.get(),
|
| - &TestingHttpServerPropertiesManager::
|
| - UpdateCacheFromPrefsOnUIConcrete));
|
| - }
|
| -
|
| - void ExpectPrefsUpdate() {
|
| - EXPECT_CALL(*http_server_props_manager_,
|
| - UpdatePrefsFromCacheOnNetworkThread(_))
|
| - .WillOnce(Invoke(http_server_props_manager_.get(),
|
| - &TestingHttpServerPropertiesManager::
|
| - UpdatePrefsFromCacheOnNetworkThreadConcrete));
|
| - }
|
| -
|
| - void ExpectPrefsUpdateRepeatedly() {
|
| - EXPECT_CALL(*http_server_props_manager_,
|
| - UpdatePrefsFromCacheOnNetworkThread(_))
|
| - .WillRepeatedly(
|
| - Invoke(http_server_props_manager_.get(),
|
| - &TestingHttpServerPropertiesManager::
|
| - UpdatePrefsFromCacheOnNetworkThreadConcrete));
|
| - }
|
| -
|
| - bool HasAlternateProtocol(const HostPortPair& server) {
|
| - const AlternateProtocolInfo alternate =
|
| - http_server_props_manager_->GetAlternateProtocol(server);
|
| - return alternate.protocol != UNINITIALIZED_ALTERNATE_PROTOCOL;
|
| - }
|
| -
|
| - //base::RunLoop loop_;
|
| - TestingPrefServiceSimple pref_service_;
|
| - scoped_ptr<TestingHttpServerPropertiesManager> http_server_props_manager_;
|
| -
|
| - private:
|
| - DISALLOW_COPY_AND_ASSIGN(HttpServerPropertiesManagerTest);
|
| -};
|
| -
|
| -TEST_F(HttpServerPropertiesManagerTest,
|
| - SingleUpdateForTwoSpdyServerPrefChanges) {
|
| - ExpectCacheUpdate();
|
| -
|
| - // Set up the prefs for www.google.com:80 and mail.google.com:80 and then set
|
| - // it twice. Only expect a single cache update.
|
| -
|
| - base::DictionaryValue* server_pref_dict = new base::DictionaryValue;
|
| - HostPortPair google_server("www.google.com", 80);
|
| - HostPortPair mail_server("mail.google.com", 80);
|
| -
|
| - // Set supports_spdy for www.google.com:80.
|
| - server_pref_dict->SetBoolean("supports_spdy", true);
|
| -
|
| - // Set up alternate_protocol for www.google.com:80.
|
| - base::DictionaryValue* alternate_protocol = new base::DictionaryValue;
|
| - alternate_protocol->SetInteger("port", 443);
|
| - alternate_protocol->SetString("protocol_str", "npn-spdy/3");
|
| - server_pref_dict->SetWithoutPathExpansion("alternate_protocol",
|
| - alternate_protocol);
|
| -
|
| - // Set up ServerNetworkStats for www.google.com:80.
|
| - base::DictionaryValue* stats = new base::DictionaryValue;
|
| - stats->SetInteger("srtt", 10);
|
| - server_pref_dict->SetWithoutPathExpansion("network_stats", stats);
|
| -
|
| - // Set the server preference for www.google.com:80.
|
| - base::DictionaryValue* servers_dict = new base::DictionaryValue;
|
| - servers_dict->SetWithoutPathExpansion("www.google.com:80", server_pref_dict);
|
| -
|
| - // Set the preference for mail.google.com server.
|
| - base::DictionaryValue* server_pref_dict1 = new base::DictionaryValue;
|
| -
|
| - // Set supports_spdy for mail.google.com:80
|
| - server_pref_dict1->SetBoolean("supports_spdy", true);
|
| -
|
| - // Set up alternate_protocol for mail.google.com:80
|
| - base::DictionaryValue* alternate_protocol1 = new base::DictionaryValue;
|
| - alternate_protocol1->SetInteger("port", 444);
|
| - alternate_protocol1->SetString("protocol_str", "npn-spdy/3.1");
|
| -
|
| - server_pref_dict1->SetWithoutPathExpansion("alternate_protocol",
|
| - alternate_protocol1);
|
| -
|
| - // Set up ServerNetworkStats for mail.google.com:80.
|
| - base::DictionaryValue* stats1 = new base::DictionaryValue;
|
| - stats1->SetInteger("srtt", 20);
|
| - server_pref_dict1->SetWithoutPathExpansion("network_stats", stats1);
|
| - // Set the server preference for mail.google.com:80.
|
| - servers_dict->SetWithoutPathExpansion("mail.google.com:80",
|
| - server_pref_dict1);
|
| -
|
| - base::DictionaryValue* http_server_properties_dict =
|
| - new base::DictionaryValue;
|
| - HttpServerPropertiesManager::SetVersion(http_server_properties_dict, -1);
|
| - http_server_properties_dict->SetWithoutPathExpansion("servers", servers_dict);
|
| - base::DictionaryValue* supports_quic = new base::DictionaryValue;
|
| - supports_quic->SetBoolean("used_quic", true);
|
| - supports_quic->SetString("address", "127.0.0.1");
|
| - http_server_properties_dict->SetWithoutPathExpansion("supports_quic",
|
| - supports_quic);
|
| -
|
| - // Set the same value for kHttpServerProperties multiple times.
|
| - pref_service_.SetManagedPref(kTestHttpServerProperties,
|
| - http_server_properties_dict);
|
| - base::DictionaryValue* http_server_properties_dict2 =
|
| - http_server_properties_dict->DeepCopy();
|
| - pref_service_.SetManagedPref(kTestHttpServerProperties,
|
| - http_server_properties_dict2);
|
| -
|
| - base::RunLoop().RunUntilIdle();
|
| - Mock::VerifyAndClearExpectations(http_server_props_manager_.get());
|
| -
|
| - // Verify SupportsSpdy.
|
| - EXPECT_TRUE(
|
| - http_server_props_manager_->SupportsRequestPriority(google_server));
|
| - EXPECT_TRUE(http_server_props_manager_->SupportsRequestPriority(mail_server));
|
| - EXPECT_FALSE(http_server_props_manager_->SupportsRequestPriority(
|
| - HostPortPair::FromString("foo.google.com:1337")));
|
| -
|
| - // Verify AlternateProtocol.
|
| - AlternateProtocolInfo port_alternate_protocol =
|
| - http_server_props_manager_->GetAlternateProtocol(google_server);
|
| - EXPECT_EQ(443, port_alternate_protocol.port);
|
| - EXPECT_EQ(NPN_SPDY_3, port_alternate_protocol.protocol);
|
| - port_alternate_protocol =
|
| - http_server_props_manager_->GetAlternateProtocol(mail_server);
|
| - EXPECT_EQ(444, port_alternate_protocol.port);
|
| - EXPECT_EQ(NPN_SPDY_3_1, port_alternate_protocol.protocol);
|
| -
|
| - // Verify SupportsQuic.
|
| - IPAddressNumber last_address;
|
| - EXPECT_TRUE(http_server_props_manager_->GetSupportsQuic(&last_address));
|
| - EXPECT_EQ("127.0.0.1", IPAddressToString(last_address));
|
| -
|
| - // Verify ServerNetworkStats.
|
| - const ServerNetworkStats* stats2 =
|
| - http_server_props_manager_->GetServerNetworkStats(google_server);
|
| - EXPECT_EQ(10, stats2->srtt.ToInternalValue());
|
| - const ServerNetworkStats* stats3 =
|
| - http_server_props_manager_->GetServerNetworkStats(mail_server);
|
| - EXPECT_EQ(20, stats3->srtt.ToInternalValue());
|
| -}
|
| -
|
| -TEST_F(HttpServerPropertiesManagerTest, BadCachedHostPortPair) {
|
| - ExpectCacheUpdate();
|
| - // The prefs are automaticalls updated in the case corruption is detected.
|
| - ExpectPrefsUpdate();
|
| -
|
| - base::DictionaryValue* server_pref_dict = new base::DictionaryValue;
|
| -
|
| - // Set supports_spdy for www.google.com:65536.
|
| - server_pref_dict->SetBoolean("supports_spdy", true);
|
| -
|
| - // Set up alternate_protocol for www.google.com:65536.
|
| - base::DictionaryValue* alternate_protocol = new base::DictionaryValue;
|
| - alternate_protocol->SetInteger("port", 80);
|
| - alternate_protocol->SetString("protocol_str", "npn-spdy/3");
|
| - server_pref_dict->SetWithoutPathExpansion("alternate_protocol",
|
| - alternate_protocol);
|
| -
|
| - // Set up ServerNetworkStats for www.google.com:65536.
|
| - base::DictionaryValue* stats = new base::DictionaryValue;
|
| - stats->SetInteger("srtt", 10);
|
| - server_pref_dict->SetWithoutPathExpansion("network_stats", stats);
|
| -
|
| - // Set the server preference for www.google.com:65536.
|
| - base::DictionaryValue* servers_dict = new base::DictionaryValue;
|
| - servers_dict->SetWithoutPathExpansion("www.google.com:65536",
|
| - server_pref_dict);
|
| -
|
| - base::DictionaryValue* http_server_properties_dict =
|
| - new base::DictionaryValue;
|
| - HttpServerPropertiesManager::SetVersion(http_server_properties_dict, -1);
|
| - http_server_properties_dict->SetWithoutPathExpansion("servers", servers_dict);
|
| -
|
| - // Set up the pref.
|
| - pref_service_.SetManagedPref(kTestHttpServerProperties,
|
| - http_server_properties_dict);
|
| -
|
| - base::RunLoop().RunUntilIdle();
|
| - Mock::VerifyAndClearExpectations(http_server_props_manager_.get());
|
| -
|
| - // Verify that nothing is set.
|
| - EXPECT_FALSE(http_server_props_manager_->SupportsRequestPriority(
|
| - HostPortPair::FromString("www.google.com:65536")));
|
| - EXPECT_FALSE(
|
| - HasAlternateProtocol(HostPortPair::FromString("www.google.com:65536")));
|
| - const ServerNetworkStats* stats1 =
|
| - http_server_props_manager_->GetServerNetworkStats(
|
| - HostPortPair::FromString("www.google.com:65536"));
|
| - EXPECT_EQ(NULL, stats1);
|
| -}
|
| -
|
| -TEST_F(HttpServerPropertiesManagerTest, BadCachedAltProtocolPort) {
|
| - ExpectCacheUpdate();
|
| - // The prefs are automaticalls updated in the case corruption is detected.
|
| - ExpectPrefsUpdate();
|
| -
|
| - base::DictionaryValue* server_pref_dict = new base::DictionaryValue;
|
| -
|
| - // Set supports_spdy for www.google.com:80.
|
| - server_pref_dict->SetBoolean("supports_spdy", true);
|
| -
|
| - // Set up alternate_protocol for www.google.com:80.
|
| - base::DictionaryValue* alternate_protocol = new base::DictionaryValue;
|
| - alternate_protocol->SetInteger("port", 65536);
|
| - alternate_protocol->SetString("protocol_str", "npn-spdy/3");
|
| - server_pref_dict->SetWithoutPathExpansion("alternate_protocol",
|
| - alternate_protocol);
|
| -
|
| - // Set the server preference for www.google.com:80.
|
| - base::DictionaryValue* servers_dict = new base::DictionaryValue;
|
| - servers_dict->SetWithoutPathExpansion("www.google.com:80", server_pref_dict);
|
| -
|
| - base::DictionaryValue* http_server_properties_dict =
|
| - new base::DictionaryValue;
|
| - HttpServerPropertiesManager::SetVersion(http_server_properties_dict, -1);
|
| - http_server_properties_dict->SetWithoutPathExpansion("servers", servers_dict);
|
| -
|
| - // Set up the pref.
|
| - pref_service_.SetManagedPref(kTestHttpServerProperties,
|
| - http_server_properties_dict);
|
| -
|
| - base::RunLoop().RunUntilIdle();
|
| - Mock::VerifyAndClearExpectations(http_server_props_manager_.get());
|
| -
|
| - // Verify AlternateProtocol is not set.
|
| - EXPECT_FALSE(
|
| - HasAlternateProtocol(HostPortPair::FromString("www.google.com:80")));
|
| -}
|
| -
|
| -TEST_F(HttpServerPropertiesManagerTest, SupportsSpdy) {
|
| - ExpectPrefsUpdate();
|
| -
|
| - // Post an update task to the network thread. SetSupportsSpdy calls
|
| - // ScheduleUpdatePrefsOnNetworkThread.
|
| -
|
| - // Add mail.google.com:443 as a supporting spdy server.
|
| - HostPortPair spdy_server_mail("mail.google.com", 443);
|
| - EXPECT_FALSE(
|
| - http_server_props_manager_->SupportsRequestPriority(spdy_server_mail));
|
| - http_server_props_manager_->SetSupportsSpdy(spdy_server_mail, true);
|
| -
|
| - // Run the task.
|
| - base::RunLoop().RunUntilIdle();
|
| -
|
| - EXPECT_TRUE(
|
| - http_server_props_manager_->SupportsRequestPriority(spdy_server_mail));
|
| - Mock::VerifyAndClearExpectations(http_server_props_manager_.get());
|
| -}
|
| -
|
| -TEST_F(HttpServerPropertiesManagerTest, SetSpdySetting) {
|
| - ExpectPrefsUpdate();
|
| -
|
| - // Add SpdySetting for mail.google.com:443.
|
| - HostPortPair spdy_server_mail("mail.google.com", 443);
|
| - const SpdySettingsIds id1 = SETTINGS_UPLOAD_BANDWIDTH;
|
| - const SpdySettingsFlags flags1 = SETTINGS_FLAG_PLEASE_PERSIST;
|
| - const uint32 value1 = 31337;
|
| - http_server_props_manager_->SetSpdySetting(
|
| - spdy_server_mail, id1, flags1, value1);
|
| -
|
| - // Run the task.
|
| - base::RunLoop().RunUntilIdle();
|
| -
|
| - const SettingsMap& settings_map1_ret =
|
| - http_server_props_manager_->GetSpdySettings(spdy_server_mail);
|
| - ASSERT_EQ(1U, settings_map1_ret.size());
|
| - SettingsMap::const_iterator it1_ret = settings_map1_ret.find(id1);
|
| - EXPECT_TRUE(it1_ret != settings_map1_ret.end());
|
| - SettingsFlagsAndValue flags_and_value1_ret = it1_ret->second;
|
| - EXPECT_EQ(SETTINGS_FLAG_PERSISTED, flags_and_value1_ret.first);
|
| - EXPECT_EQ(value1, flags_and_value1_ret.second);
|
| -
|
| - Mock::VerifyAndClearExpectations(http_server_props_manager_.get());
|
| -}
|
| -
|
| -TEST_F(HttpServerPropertiesManagerTest, ClearSpdySetting) {
|
| - ExpectPrefsUpdateRepeatedly();
|
| -
|
| - // Add SpdySetting for mail.google.com:443.
|
| - HostPortPair spdy_server_mail("mail.google.com", 443);
|
| - const SpdySettingsIds id1 = SETTINGS_UPLOAD_BANDWIDTH;
|
| - const SpdySettingsFlags flags1 = SETTINGS_FLAG_PLEASE_PERSIST;
|
| - const uint32 value1 = 31337;
|
| - http_server_props_manager_->SetSpdySetting(
|
| - spdy_server_mail, id1, flags1, value1);
|
| -
|
| - // Run the task.
|
| - base::RunLoop().RunUntilIdle();
|
| -
|
| - const SettingsMap& settings_map1_ret =
|
| - http_server_props_manager_->GetSpdySettings(spdy_server_mail);
|
| - ASSERT_EQ(1U, settings_map1_ret.size());
|
| - SettingsMap::const_iterator it1_ret = settings_map1_ret.find(id1);
|
| - EXPECT_TRUE(it1_ret != settings_map1_ret.end());
|
| - SettingsFlagsAndValue flags_and_value1_ret = it1_ret->second;
|
| - EXPECT_EQ(SETTINGS_FLAG_PERSISTED, flags_and_value1_ret.first);
|
| - EXPECT_EQ(value1, flags_and_value1_ret.second);
|
| -
|
| - // Clear SpdySetting for mail.google.com:443.
|
| - http_server_props_manager_->ClearSpdySettings(spdy_server_mail);
|
| -
|
| - // Run the task.
|
| - base::RunLoop().RunUntilIdle();
|
| -
|
| - // Verify that there are no entries in the settings map for
|
| - // mail.google.com:443.
|
| - const SettingsMap& settings_map2_ret =
|
| - http_server_props_manager_->GetSpdySettings(spdy_server_mail);
|
| - ASSERT_EQ(0U, settings_map2_ret.size());
|
| -
|
| - Mock::VerifyAndClearExpectations(http_server_props_manager_.get());
|
| -}
|
| -
|
| -TEST_F(HttpServerPropertiesManagerTest, ClearAllSpdySetting) {
|
| - ExpectPrefsUpdateRepeatedly();
|
| -
|
| - // Add SpdySetting for mail.google.com:443.
|
| - HostPortPair spdy_server_mail("mail.google.com", 443);
|
| - const SpdySettingsIds id1 = SETTINGS_UPLOAD_BANDWIDTH;
|
| - const SpdySettingsFlags flags1 = SETTINGS_FLAG_PLEASE_PERSIST;
|
| - const uint32 value1 = 31337;
|
| - http_server_props_manager_->SetSpdySetting(
|
| - spdy_server_mail, id1, flags1, value1);
|
| -
|
| - // Run the task.
|
| - base::RunLoop().RunUntilIdle();
|
| -
|
| - const SettingsMap& settings_map1_ret =
|
| - http_server_props_manager_->GetSpdySettings(spdy_server_mail);
|
| - ASSERT_EQ(1U, settings_map1_ret.size());
|
| - SettingsMap::const_iterator it1_ret = settings_map1_ret.find(id1);
|
| - EXPECT_TRUE(it1_ret != settings_map1_ret.end());
|
| - SettingsFlagsAndValue flags_and_value1_ret = it1_ret->second;
|
| - EXPECT_EQ(SETTINGS_FLAG_PERSISTED, flags_and_value1_ret.first);
|
| - EXPECT_EQ(value1, flags_and_value1_ret.second);
|
| -
|
| - // Clear All SpdySettings.
|
| - http_server_props_manager_->ClearAllSpdySettings();
|
| -
|
| - // Run the task.
|
| - base::RunLoop().RunUntilIdle();
|
| -
|
| - // Verify that there are no entries in the settings map.
|
| - const SpdySettingsMap& spdy_settings_map2_ret =
|
| - http_server_props_manager_->spdy_settings_map();
|
| - ASSERT_EQ(0U, spdy_settings_map2_ret.size());
|
| -
|
| - Mock::VerifyAndClearExpectations(http_server_props_manager_.get());
|
| -}
|
| -
|
| -TEST_F(HttpServerPropertiesManagerTest, GetAlternateProtocol) {
|
| - ExpectPrefsUpdate();
|
| -
|
| - HostPortPair spdy_server_mail("mail.google.com", 80);
|
| - EXPECT_FALSE(HasAlternateProtocol(spdy_server_mail));
|
| - http_server_props_manager_->SetAlternateProtocol(spdy_server_mail, 443,
|
| - NPN_SPDY_3, 1.0);
|
| -
|
| - // Run the task.
|
| - base::RunLoop().RunUntilIdle();
|
| - Mock::VerifyAndClearExpectations(http_server_props_manager_.get());
|
| -
|
| - const AlternateProtocolInfo alternate_protocol =
|
| - http_server_props_manager_->GetAlternateProtocol(spdy_server_mail);
|
| - EXPECT_EQ(443, alternate_protocol.port);
|
| - EXPECT_EQ(NPN_SPDY_3, alternate_protocol.protocol);
|
| - EXPECT_EQ(1.0, alternate_protocol.probability);
|
| -}
|
| -
|
| -TEST_F(HttpServerPropertiesManagerTest, SupportsQuic) {
|
| - ExpectPrefsUpdate();
|
| -
|
| - IPAddressNumber address;
|
| - EXPECT_FALSE(http_server_props_manager_->GetSupportsQuic(&address));
|
| -
|
| - IPAddressNumber actual_address;
|
| - CHECK(ParseIPLiteralToNumber("127.0.0.1", &actual_address));
|
| - http_server_props_manager_->SetSupportsQuic(true, actual_address);
|
| -
|
| - // Run the task.
|
| - base::RunLoop().RunUntilIdle();
|
| - Mock::VerifyAndClearExpectations(http_server_props_manager_.get());
|
| -
|
| - EXPECT_TRUE(http_server_props_manager_->GetSupportsQuic(&address));
|
| - EXPECT_EQ(actual_address, address);
|
| -}
|
| -
|
| -TEST_F(HttpServerPropertiesManagerTest, ServerNetworkStats) {
|
| - ExpectPrefsUpdate();
|
| -
|
| - HostPortPair mail_server("mail.google.com", 80);
|
| - const ServerNetworkStats* stats =
|
| - http_server_props_manager_->GetServerNetworkStats(mail_server);
|
| - EXPECT_EQ(NULL, stats);
|
| - ServerNetworkStats stats1;
|
| - stats1.srtt = base::TimeDelta::FromMicroseconds(10);
|
| - http_server_props_manager_->SetServerNetworkStats(mail_server, stats1);
|
| -
|
| - // Run the task.
|
| - base::RunLoop().RunUntilIdle();
|
| - Mock::VerifyAndClearExpectations(http_server_props_manager_.get());
|
| -
|
| - const ServerNetworkStats* stats2 =
|
| - http_server_props_manager_->GetServerNetworkStats(mail_server);
|
| - EXPECT_EQ(10, stats2->srtt.ToInternalValue());
|
| -}
|
| -
|
| -TEST_F(HttpServerPropertiesManagerTest, Clear) {
|
| - ExpectPrefsUpdate();
|
| -
|
| - HostPortPair spdy_server_mail("mail.google.com", 443);
|
| - http_server_props_manager_->SetSupportsSpdy(spdy_server_mail, true);
|
| - http_server_props_manager_->SetAlternateProtocol(spdy_server_mail, 443,
|
| - NPN_SPDY_3, 1.0);
|
| - IPAddressNumber actual_address;
|
| - CHECK(ParseIPLiteralToNumber("127.0.0.1", &actual_address));
|
| - http_server_props_manager_->SetSupportsQuic(true, actual_address);
|
| - ServerNetworkStats stats;
|
| - stats.srtt = base::TimeDelta::FromMicroseconds(10);
|
| - http_server_props_manager_->SetServerNetworkStats(spdy_server_mail, stats);
|
| -
|
| - const SpdySettingsIds id1 = SETTINGS_UPLOAD_BANDWIDTH;
|
| - const SpdySettingsFlags flags1 = SETTINGS_FLAG_PLEASE_PERSIST;
|
| - const uint32 value1 = 31337;
|
| - http_server_props_manager_->SetSpdySetting(
|
| - spdy_server_mail, id1, flags1, value1);
|
| -
|
| - // Run the task.
|
| - base::RunLoop().RunUntilIdle();
|
| -
|
| - EXPECT_TRUE(
|
| - http_server_props_manager_->SupportsRequestPriority(spdy_server_mail));
|
| - EXPECT_TRUE(HasAlternateProtocol(spdy_server_mail));
|
| - IPAddressNumber address;
|
| - EXPECT_TRUE(http_server_props_manager_->GetSupportsQuic(&address));
|
| - EXPECT_EQ(actual_address, address);
|
| - const ServerNetworkStats* stats1 =
|
| - http_server_props_manager_->GetServerNetworkStats(spdy_server_mail);
|
| - EXPECT_EQ(10, stats1->srtt.ToInternalValue());
|
| -
|
| - // Check SPDY settings values.
|
| - const SettingsMap& settings_map1_ret =
|
| - http_server_props_manager_->GetSpdySettings(spdy_server_mail);
|
| - ASSERT_EQ(1U, settings_map1_ret.size());
|
| - SettingsMap::const_iterator it1_ret = settings_map1_ret.find(id1);
|
| - EXPECT_TRUE(it1_ret != settings_map1_ret.end());
|
| - SettingsFlagsAndValue flags_and_value1_ret = it1_ret->second;
|
| - EXPECT_EQ(SETTINGS_FLAG_PERSISTED, flags_and_value1_ret.first);
|
| - EXPECT_EQ(value1, flags_and_value1_ret.second);
|
| -
|
| - Mock::VerifyAndClearExpectations(http_server_props_manager_.get());
|
| -
|
| - ExpectPrefsUpdate();
|
| -
|
| - // Clear http server data, time out if we do not get a completion callback.
|
| - http_server_props_manager_->Clear(base::MessageLoop::QuitClosure());
|
| - base::RunLoop().Run();
|
| -
|
| - EXPECT_FALSE(
|
| - http_server_props_manager_->SupportsRequestPriority(spdy_server_mail));
|
| - EXPECT_FALSE(HasAlternateProtocol(spdy_server_mail));
|
| - EXPECT_FALSE(http_server_props_manager_->GetSupportsQuic(&address));
|
| - const ServerNetworkStats* stats2 =
|
| - http_server_props_manager_->GetServerNetworkStats(spdy_server_mail);
|
| - EXPECT_EQ(NULL, stats2);
|
| -
|
| - const SettingsMap& settings_map2_ret =
|
| - http_server_props_manager_->GetSpdySettings(spdy_server_mail);
|
| - EXPECT_EQ(0U, settings_map2_ret.size());
|
| -
|
| - Mock::VerifyAndClearExpectations(http_server_props_manager_.get());
|
| -}
|
| -
|
| -// https://crbug.com/444956: Add 200 alternate_protocol servers followed by
|
| -// supports_quic and verify we have read supports_quic from prefs.
|
| -TEST_F(HttpServerPropertiesManagerTest, BadSupportsQuic) {
|
| - ExpectCacheUpdate();
|
| -
|
| - base::DictionaryValue* servers_dict = new base::DictionaryValue;
|
| -
|
| - for (int i = 0; i < 200; ++i) {
|
| - // Set up alternate_protocol for www.google.com:i.
|
| - base::DictionaryValue* alternate_protocol = new base::DictionaryValue;
|
| - alternate_protocol->SetInteger("port", i);
|
| - alternate_protocol->SetString("protocol_str", "npn-spdy/3");
|
| - base::DictionaryValue* server_pref_dict = new base::DictionaryValue;
|
| - server_pref_dict->SetWithoutPathExpansion("alternate_protocol",
|
| - alternate_protocol);
|
| - servers_dict->SetWithoutPathExpansion(StringPrintf("www.google.com:%d", i),
|
| - server_pref_dict);
|
| - }
|
| -
|
| - // Set the preference for mail.google.com server.
|
| - base::DictionaryValue* server_pref_dict1 = new base::DictionaryValue;
|
| -
|
| - // Set the server preference for mail.google.com:80.
|
| - servers_dict->SetWithoutPathExpansion("mail.google.com:80",
|
| - server_pref_dict1);
|
| -
|
| - base::DictionaryValue* http_server_properties_dict =
|
| - new base::DictionaryValue;
|
| - HttpServerPropertiesManager::SetVersion(http_server_properties_dict, -1);
|
| - http_server_properties_dict->SetWithoutPathExpansion("servers", servers_dict);
|
| -
|
| - // Set up SupportsQuic for 127.0.0.1
|
| - base::DictionaryValue* supports_quic = new base::DictionaryValue;
|
| - supports_quic->SetBoolean("used_quic", true);
|
| - supports_quic->SetString("address", "127.0.0.1");
|
| - http_server_properties_dict->SetWithoutPathExpansion("supports_quic",
|
| - supports_quic);
|
| -
|
| - // Set up the pref.
|
| - pref_service_.SetManagedPref(kTestHttpServerProperties,
|
| - http_server_properties_dict);
|
| -
|
| - base::RunLoop().RunUntilIdle();
|
| - Mock::VerifyAndClearExpectations(http_server_props_manager_.get());
|
| -
|
| - // Verify AlternateProtocol.
|
| - for (int i = 0; i < 200; ++i) {
|
| - std::string server = StringPrintf("www.google.com:%d", i);
|
| - AlternateProtocolInfo port_alternate_protocol =
|
| - http_server_props_manager_->GetAlternateProtocol(
|
| - HostPortPair::FromString(server));
|
| - EXPECT_EQ(i, port_alternate_protocol.port);
|
| - EXPECT_EQ(NPN_SPDY_3, port_alternate_protocol.protocol);
|
| - }
|
| -
|
| - // Verify SupportsQuic.
|
| - IPAddressNumber address;
|
| - ASSERT_TRUE(http_server_props_manager_->GetSupportsQuic(&address));
|
| - EXPECT_EQ("127.0.0.1", IPAddressToString(address));
|
| -}
|
| -
|
| -TEST_F(HttpServerPropertiesManagerTest, UpdateCacheWithPrefs) {
|
| - const HostPortPair server_www("www.google.com", 80);
|
| - const HostPortPair server_mail("mail.google.com", 80);
|
| -
|
| - // Set alternate protocol.
|
| - http_server_props_manager_->SetAlternateProtocol(server_www, 443, NPN_SPDY_3,
|
| - 1.0);
|
| - http_server_props_manager_->SetAlternateProtocol(server_mail, 444,
|
| - NPN_SPDY_3_1, 0.2);
|
| -
|
| - // Set ServerNetworkStats.
|
| - ServerNetworkStats stats;
|
| - stats.srtt = base::TimeDelta::FromInternalValue(42);
|
| - http_server_props_manager_->SetServerNetworkStats(server_mail, stats);
|
| -
|
| - // Set SupportsQuic.
|
| - IPAddressNumber actual_address;
|
| - CHECK(ParseIPLiteralToNumber("127.0.0.1", &actual_address));
|
| - http_server_props_manager_->SetSupportsQuic(true, actual_address);
|
| -
|
| - // Update cache.
|
| - ExpectPrefsUpdate();
|
| - ExpectCacheUpdate();
|
| - http_server_props_manager_->ScheduleUpdateCacheOnPrefThread();
|
| - base::RunLoop().RunUntilIdle();
|
| -
|
| - // Verify preferences.
|
| - const char expected_json[] = "{"
|
| - "\"servers\":{"
|
| - "\"mail.google.com:80\":{"
|
| - "\"alternate_protocol\":{"
|
| - "\"port\":444,\"probability\":0.2,\"protocol_str\":\"npn-spdy/3.1\""
|
| - "},"
|
| - "\"network_stats\":{"
|
| - "\"srtt\":42"
|
| - "}"
|
| - "},"
|
| - "\"www.google.com:80\":{"
|
| - "\"alternate_protocol\":{"
|
| - "\"port\":443,\"probability\":1.0,\"protocol_str\":\"npn-spdy/3\""
|
| - "}"
|
| - "}"
|
| - "},"
|
| - "\"supports_quic\":{"
|
| - "\"address\":\"127.0.0.1\",\"used_quic\":true"
|
| - "},"
|
| - "\"version\":3"
|
| - "}";
|
| -
|
| - const base::Value* http_server_properties =
|
| - pref_service_.GetUserPref(kTestHttpServerProperties);
|
| - ASSERT_NE(nullptr, http_server_properties);
|
| - std::string preferences_json;
|
| - EXPECT_TRUE(
|
| - base::JSONWriter::Write(http_server_properties, &preferences_json));
|
| - EXPECT_EQ(expected_json, preferences_json);
|
| -}
|
| -
|
| -TEST_F(HttpServerPropertiesManagerTest, ShutdownWithPendingUpdateCache0) {
|
| - // Post an update task to the UI thread.
|
| - http_server_props_manager_->ScheduleUpdateCacheOnPrefThread();
|
| - // Shutdown comes before the task is executed.
|
| - http_server_props_manager_->ShutdownOnPrefThread();
|
| - http_server_props_manager_.reset();
|
| - // Run the task after shutdown and deletion.
|
| - base::RunLoop().RunUntilIdle();
|
| -}
|
| -
|
| -TEST_F(HttpServerPropertiesManagerTest, ShutdownWithPendingUpdateCache1) {
|
| - // Post an update task.
|
| - http_server_props_manager_->ScheduleUpdateCacheOnPrefThread();
|
| - // Shutdown comes before the task is executed.
|
| - http_server_props_manager_->ShutdownOnPrefThread();
|
| - // Run the task after shutdown, but before deletion.
|
| - base::RunLoop().RunUntilIdle();
|
| - Mock::VerifyAndClearExpectations(http_server_props_manager_.get());
|
| - http_server_props_manager_.reset();
|
| - base::RunLoop().RunUntilIdle();
|
| -}
|
| -
|
| -TEST_F(HttpServerPropertiesManagerTest, ShutdownWithPendingUpdateCache2) {
|
| - http_server_props_manager_->UpdateCacheFromPrefsOnUIConcrete();
|
| - // Shutdown comes before the task is executed.
|
| - http_server_props_manager_->ShutdownOnPrefThread();
|
| - // Run the task after shutdown, but before deletion.
|
| - base::RunLoop().RunUntilIdle();
|
| - Mock::VerifyAndClearExpectations(http_server_props_manager_.get());
|
| - http_server_props_manager_.reset();
|
| - base::RunLoop().RunUntilIdle();
|
| -}
|
| -
|
| -//
|
| -// Tests for shutdown when updating prefs.
|
| -//
|
| -TEST_F(HttpServerPropertiesManagerTest, ShutdownWithPendingUpdatePrefs0) {
|
| - // Post an update task to the IO thread.
|
| - http_server_props_manager_->ScheduleUpdatePrefsOnNetworkThread();
|
| - // Shutdown comes before the task is executed.
|
| - http_server_props_manager_->ShutdownOnPrefThread();
|
| - http_server_props_manager_.reset();
|
| - // Run the task after shutdown and deletion.
|
| - base::RunLoop().RunUntilIdle();
|
| -}
|
| -
|
| -TEST_F(HttpServerPropertiesManagerTest, ShutdownWithPendingUpdatePrefs1) {
|
| - ExpectPrefsUpdate();
|
| - // Post an update task.
|
| - http_server_props_manager_->ScheduleUpdatePrefsOnNetworkThread();
|
| - // Shutdown comes before the task is executed.
|
| - http_server_props_manager_->ShutdownOnPrefThread();
|
| - // Run the task after shutdown, but before deletion.
|
| - base::RunLoop().RunUntilIdle();
|
| - Mock::VerifyAndClearExpectations(http_server_props_manager_.get());
|
| - http_server_props_manager_.reset();
|
| - base::RunLoop().RunUntilIdle();
|
| -}
|
| -
|
| -TEST_F(HttpServerPropertiesManagerTest, ShutdownWithPendingUpdatePrefs2) {
|
| - // This posts a task to the UI thread.
|
| - http_server_props_manager_->UpdatePrefsFromCacheOnNetworkThreadConcrete(
|
| - base::Closure());
|
| - // Shutdown comes before the task is executed.
|
| - http_server_props_manager_->ShutdownOnPrefThread();
|
| - // Run the task after shutdown, but before deletion.
|
| - base::RunLoop().RunUntilIdle();
|
| - Mock::VerifyAndClearExpectations(http_server_props_manager_.get());
|
| - http_server_props_manager_.reset();
|
| - base::RunLoop().RunUntilIdle();
|
| -}
|
| -
|
| -} // namespace
|
| -
|
| -} // namespace net
|
|
|