Index: net/http/http_pipelined_host_pool_unittest.cc |
diff --git a/net/http/http_pipelined_host_pool_unittest.cc b/net/http/http_pipelined_host_pool_unittest.cc |
index fa8d93facb17848cff0603d3c85d3efde28c127f..2c2b63b104c16940566d4fcaf12d8e07ba89d5f0 100644 |
--- a/net/http/http_pipelined_host_pool_unittest.cc |
+++ b/net/http/http_pipelined_host_pool_unittest.cc |
@@ -25,8 +25,7 @@ namespace { |
ClientSocketHandle* kDummyConnection = |
reinterpret_cast<ClientSocketHandle*>(188); |
-HttpPipelinedStream* kDummyStream = |
- reinterpret_cast<HttpPipelinedStream*>(99); |
+HttpPipelinedStream* kDummyStream = reinterpret_cast<HttpPipelinedStream*>(99); |
class MockPoolDelegate : public HttpPipelinedHostPool::Delegate { |
public: |
@@ -36,27 +35,25 @@ class MockPoolDelegate : public HttpPipelinedHostPool::Delegate { |
class MockHostFactory : public HttpPipelinedHost::Factory { |
public: |
- MOCK_METHOD5(CreateNewHost, HttpPipelinedHost*( |
- HttpPipelinedHost::Delegate* delegate, |
- const HttpPipelinedHost::Key& key, |
- HttpPipelinedConnection::Factory* factory, |
- HttpPipelinedHostCapability capability, |
- bool force_pipelining)); |
+ MOCK_METHOD5(CreateNewHost, |
+ HttpPipelinedHost*(HttpPipelinedHost::Delegate* delegate, |
+ const HttpPipelinedHost::Key& key, |
+ HttpPipelinedConnection::Factory* factory, |
+ HttpPipelinedHostCapability capability, |
+ bool force_pipelining)); |
}; |
class MockHost : public HttpPipelinedHost { |
public: |
- MockHost(const Key& key) |
- : key_(key) { |
- } |
- |
- MOCK_METHOD6(CreateStreamOnNewPipeline, HttpPipelinedStream*( |
- ClientSocketHandle* connection, |
- const SSLConfig& used_ssl_config, |
- const ProxyInfo& used_proxy_info, |
- const BoundNetLog& net_log, |
- bool was_npn_negotiated, |
- NextProto protocol_negotiated)); |
+ MockHost(const Key& key) : key_(key) {} |
+ |
+ MOCK_METHOD6(CreateStreamOnNewPipeline, |
+ HttpPipelinedStream*(ClientSocketHandle* connection, |
+ const SSLConfig& used_ssl_config, |
+ const ProxyInfo& used_proxy_info, |
+ const BoundNetLog& net_log, |
+ bool was_npn_negotiated, |
+ NextProto protocol_negotiated)); |
MOCK_METHOD0(CreateStreamOnExistingPipeline, HttpPipelinedStream*()); |
MOCK_CONST_METHOD0(IsExistingPipelineAvailable, bool()); |
MOCK_CONST_METHOD0(PipelineInfoToValue, base::Value*()); |
@@ -72,38 +69,43 @@ class HttpPipelinedHostPoolTest : public testing::Test { |
HttpPipelinedHostPoolTest() |
: key_(HostPortPair("host", 123)), |
factory_(new MockHostFactory), // Owned by pool_. |
- host_(new MockHost(key_)), // Owned by pool_. |
+ host_(new MockHost(key_)), // Owned by pool_. |
http_server_properties_(new HttpServerPropertiesImpl()), |
- pool_(new HttpPipelinedHostPool( |
- &delegate_, factory_, |
- http_server_properties_->GetWeakPtr(), false)), |
+ pool_(new HttpPipelinedHostPool(&delegate_, |
+ factory_, |
+ http_server_properties_->GetWeakPtr(), |
+ false)), |
was_npn_negotiated_(false), |
- protocol_negotiated_(kProtoUnknown) { |
- } |
+ protocol_negotiated_(kProtoUnknown) {} |
void CreateDummyStream(const HttpPipelinedHost::Key& key, |
ClientSocketHandle* connection, |
HttpPipelinedStream* stream, |
MockHost* host) { |
- EXPECT_CALL(*host, CreateStreamOnNewPipeline(connection, |
- Ref(ssl_config_), |
- Ref(proxy_info_), |
- Ref(net_log_), |
- was_npn_negotiated_, |
- protocol_negotiated_)) |
+ EXPECT_CALL(*host, |
+ CreateStreamOnNewPipeline(connection, |
+ Ref(ssl_config_), |
+ Ref(proxy_info_), |
+ Ref(net_log_), |
+ was_npn_negotiated_, |
+ protocol_negotiated_)) |
.Times(1) |
.WillOnce(Return(stream)); |
EXPECT_EQ(stream, |
- pool_->CreateStreamOnNewPipeline(key, connection, |
- ssl_config_, proxy_info_, |
- net_log_, was_npn_negotiated_, |
+ pool_->CreateStreamOnNewPipeline(key, |
+ connection, |
+ ssl_config_, |
+ proxy_info_, |
+ net_log_, |
+ was_npn_negotiated_, |
protocol_negotiated_)); |
} |
MockHost* CreateDummyHost(const HttpPipelinedHost::Key& key) { |
MockHost* mock_host = new MockHost(key); |
- EXPECT_CALL(*factory_, CreateNewHost(pool_.get(), Ref(key), _, |
- PIPELINE_UNKNOWN, false)) |
+ EXPECT_CALL( |
+ *factory_, |
+ CreateNewHost(pool_.get(), Ref(key), _, PIPELINE_UNKNOWN, false)) |
.Times(1) |
.WillOnce(Return(mock_host)); |
ClientSocketHandle* dummy_connection = |
@@ -130,8 +132,8 @@ class HttpPipelinedHostPoolTest : public testing::Test { |
TEST_F(HttpPipelinedHostPoolTest, DefaultUnknown) { |
EXPECT_TRUE(pool_->IsKeyEligibleForPipelining(key_)); |
- EXPECT_CALL(*factory_, CreateNewHost(pool_.get(), Ref(key_), _, |
- PIPELINE_UNKNOWN, false)) |
+ EXPECT_CALL(*factory_, |
+ CreateNewHost(pool_.get(), Ref(key_), _, PIPELINE_UNKNOWN, false)) |
.Times(1) |
.WillOnce(Return(host_)); |
@@ -140,8 +142,8 @@ TEST_F(HttpPipelinedHostPoolTest, DefaultUnknown) { |
} |
TEST_F(HttpPipelinedHostPoolTest, RemembersIncapable) { |
- EXPECT_CALL(*factory_, CreateNewHost(pool_.get(), Ref(key_), _, |
- PIPELINE_UNKNOWN, false)) |
+ EXPECT_CALL(*factory_, |
+ CreateNewHost(pool_.get(), Ref(key_), _, PIPELINE_UNKNOWN, false)) |
.Times(1) |
.WillOnce(Return(host_)); |
@@ -149,19 +151,23 @@ TEST_F(HttpPipelinedHostPoolTest, RemembersIncapable) { |
pool_->OnHostDeterminedCapability(host_, PIPELINE_INCAPABLE); |
pool_->OnHostIdle(host_); |
EXPECT_FALSE(pool_->IsKeyEligibleForPipelining(key_)); |
- EXPECT_CALL(*factory_, CreateNewHost(pool_.get(), Ref(key_), _, |
- PIPELINE_INCAPABLE, false)) |
+ EXPECT_CALL( |
+ *factory_, |
+ CreateNewHost(pool_.get(), Ref(key_), _, PIPELINE_INCAPABLE, false)) |
.Times(0); |
EXPECT_EQ(NULL, |
- pool_->CreateStreamOnNewPipeline(key_, kDummyConnection, |
- ssl_config_, proxy_info_, net_log_, |
+ pool_->CreateStreamOnNewPipeline(key_, |
+ kDummyConnection, |
+ ssl_config_, |
+ proxy_info_, |
+ net_log_, |
was_npn_negotiated_, |
protocol_negotiated_)); |
} |
TEST_F(HttpPipelinedHostPoolTest, RemembersCapable) { |
- EXPECT_CALL(*factory_, CreateNewHost(pool_.get(), Ref(key_), _, |
- PIPELINE_UNKNOWN, false)) |
+ EXPECT_CALL(*factory_, |
+ CreateNewHost(pool_.get(), Ref(key_), _, PIPELINE_UNKNOWN, false)) |
.Times(1) |
.WillOnce(Return(host_)); |
@@ -171,8 +177,8 @@ TEST_F(HttpPipelinedHostPoolTest, RemembersCapable) { |
EXPECT_TRUE(pool_->IsKeyEligibleForPipelining(key_)); |
host_ = new MockHost(key_); |
- EXPECT_CALL(*factory_, CreateNewHost(pool_.get(), Ref(key_), _, |
- PIPELINE_CAPABLE, false)) |
+ EXPECT_CALL(*factory_, |
+ CreateNewHost(pool_.get(), Ref(key_), _, PIPELINE_CAPABLE, false)) |
.Times(1) |
.WillOnce(Return(host_)); |
CreateDummyStream(key_, kDummyConnection, kDummyStream, host_); |
@@ -180,8 +186,8 @@ TEST_F(HttpPipelinedHostPoolTest, RemembersCapable) { |
} |
TEST_F(HttpPipelinedHostPoolTest, IncapableIsSticky) { |
- EXPECT_CALL(*factory_, CreateNewHost(pool_.get(), Ref(key_), _, |
- PIPELINE_UNKNOWN, false)) |
+ EXPECT_CALL(*factory_, |
+ CreateNewHost(pool_.get(), Ref(key_), _, PIPELINE_UNKNOWN, false)) |
.Times(1) |
.WillOnce(Return(host_)); |
@@ -194,8 +200,8 @@ TEST_F(HttpPipelinedHostPoolTest, IncapableIsSticky) { |
} |
TEST_F(HttpPipelinedHostPoolTest, RemainsUnknownWithoutFeedback) { |
- EXPECT_CALL(*factory_, CreateNewHost(pool_.get(), Ref(key_), _, |
- PIPELINE_UNKNOWN, false)) |
+ EXPECT_CALL(*factory_, |
+ CreateNewHost(pool_.get(), Ref(key_), _, PIPELINE_UNKNOWN, false)) |
.Times(1) |
.WillOnce(Return(host_)); |
@@ -204,8 +210,8 @@ TEST_F(HttpPipelinedHostPoolTest, RemainsUnknownWithoutFeedback) { |
EXPECT_TRUE(pool_->IsKeyEligibleForPipelining(key_)); |
host_ = new MockHost(key_); |
- EXPECT_CALL(*factory_, CreateNewHost(pool_.get(), Ref(key_), _, |
- PIPELINE_UNKNOWN, false)) |
+ EXPECT_CALL(*factory_, |
+ CreateNewHost(pool_.get(), Ref(key_), _, PIPELINE_UNKNOWN, false)) |
.Times(1) |
.WillOnce(Return(host_)); |
@@ -214,13 +220,13 @@ TEST_F(HttpPipelinedHostPoolTest, RemainsUnknownWithoutFeedback) { |
} |
TEST_F(HttpPipelinedHostPoolTest, PopulatesServerProperties) { |
- EXPECT_EQ(PIPELINE_UNKNOWN, |
- http_server_properties_->GetPipelineCapability( |
- host_->GetKey().origin())); |
+ EXPECT_EQ( |
+ PIPELINE_UNKNOWN, |
+ http_server_properties_->GetPipelineCapability(host_->GetKey().origin())); |
pool_->OnHostDeterminedCapability(host_, PIPELINE_CAPABLE); |
- EXPECT_EQ(PIPELINE_CAPABLE, |
- http_server_properties_->GetPipelineCapability( |
- host_->GetKey().origin())); |
+ EXPECT_EQ( |
+ PIPELINE_CAPABLE, |
+ http_server_properties_->GetPipelineCapability(host_->GetKey().origin())); |
delete host_; // Must manually delete, because it's never added to |pool_|. |
} |
@@ -233,19 +239,16 @@ TEST_F(HttpPipelinedHostPoolTest, MultipleKeys) { |
MockHost* host2 = CreateDummyHost(key2); |
MockHost* host3 = CreateDummyHost(key3); |
- EXPECT_CALL(*host1, IsExistingPipelineAvailable()) |
- .Times(1) |
- .WillOnce(Return(true)); |
+ EXPECT_CALL(*host1, IsExistingPipelineAvailable()).Times(1).WillOnce( |
+ Return(true)); |
EXPECT_TRUE(pool_->IsExistingPipelineAvailableForKey(key1)); |
- EXPECT_CALL(*host2, IsExistingPipelineAvailable()) |
- .Times(1) |
- .WillOnce(Return(false)); |
+ EXPECT_CALL(*host2, IsExistingPipelineAvailable()).Times(1).WillOnce( |
+ Return(false)); |
EXPECT_FALSE(pool_->IsExistingPipelineAvailableForKey(key2)); |
- EXPECT_CALL(*host3, IsExistingPipelineAvailable()) |
- .Times(1) |
- .WillOnce(Return(true)); |
+ EXPECT_CALL(*host3, IsExistingPipelineAvailable()).Times(1).WillOnce( |
+ Return(true)); |
EXPECT_TRUE(pool_->IsExistingPipelineAvailableForKey(key3)); |
EXPECT_FALSE(pool_->IsExistingPipelineAvailableForKey(key4)); |