Index: net/spdy/spdy_session_unittest.cc |
diff --git a/net/spdy/spdy_session_unittest.cc b/net/spdy/spdy_session_unittest.cc |
index c48a6a3c69f59a5e9b4afd695c9370ada9a66bb4..e3a10bd5d772368aa5a4c702818f9af400fcb531 100644 |
--- a/net/spdy/spdy_session_unittest.cc |
+++ b/net/spdy/spdy_session_unittest.cc |
@@ -142,7 +142,7 @@ class SpdySessionTest : public PlatformTest, |
spdy_util_(GetProtocol(), GetDependenciesFromPriority()), |
session_deps_(GetProtocol()), |
spdy_session_pool_(nullptr), |
- test_url_(kDefaultURL), |
+ test_url_(kDefaultUrl), |
test_server_(test_url_), |
key_(HostPortPair::FromURL(test_url_), |
ProxyServer::Direct(), |
@@ -179,6 +179,12 @@ class SpdySessionTest : public PlatformTest, |
log_.bound()); |
} |
+ void CreateSecureSpdySession() { |
+ DCHECK(!session_); |
+ session_ = |
+ ::net::CreateSecureSpdySession(http_session_.get(), key_, log_.bound()); |
+ } |
+ |
void StallSessionSend() { |
// Reduce the send window size to 0 to stall. |
while (session_->session_send_window_size_ > 0) { |
@@ -217,8 +223,8 @@ class SpdySessionTest : public PlatformTest, |
std::unique_ptr<HttpNetworkSession> http_session_; |
base::WeakPtr<SpdySession> session_; |
SpdySessionPool* spdy_session_pool_; |
- GURL test_url_; |
- url::SchemeHostPort test_server_; |
+ const GURL test_url_; |
+ const url::SchemeHostPort test_server_; |
SpdySessionKey key_; |
BoundTestNetLog log_; |
}; |
@@ -405,7 +411,7 @@ TEST_P(SpdySessionTest, GoAwayWithActiveStreams) { |
spdy_stream2->SetDelegate(&delegate2); |
std::unique_ptr<SpdyHeaderBlock> headers( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
std::unique_ptr<SpdyHeaderBlock> headers2(new SpdyHeaderBlock(*headers)); |
spdy_stream1->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND); |
@@ -471,7 +477,7 @@ TEST_P(SpdySessionTest, GoAwayWithActiveAndCreatedStream) { |
test::StreamDelegateDoNothing delegate1(spdy_stream1); |
spdy_stream1->SetDelegate(&delegate1); |
std::unique_ptr<SpdyHeaderBlock> headers1( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
spdy_stream1->SendRequestHeaders(std::move(headers1), NO_MORE_DATA_TO_SEND); |
EXPECT_TRUE(spdy_stream1->HasUrlFromHeaders()); |
@@ -544,7 +550,7 @@ TEST_P(SpdySessionTest, GoAwayTwice) { |
spdy_stream2->SetDelegate(&delegate2); |
std::unique_ptr<SpdyHeaderBlock> headers( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
std::unique_ptr<SpdyHeaderBlock> headers2(new SpdyHeaderBlock(*headers)); |
spdy_stream1->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND); |
@@ -618,7 +624,7 @@ TEST_P(SpdySessionTest, GoAwayWithActiveStreamsThenClose) { |
spdy_stream2->SetDelegate(&delegate2); |
std::unique_ptr<SpdyHeaderBlock> headers( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
std::unique_ptr<SpdyHeaderBlock> headers2(new SpdyHeaderBlock(*headers)); |
spdy_stream1->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND); |
@@ -703,7 +709,7 @@ TEST_P(SpdySessionTest, GoAwayWhileDraining) { |
spdy_stream->SetDelegate(&delegate); |
std::unique_ptr<SpdyHeaderBlock> headers( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
spdy_stream->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND); |
EXPECT_TRUE(spdy_stream->HasUrlFromHeaders()); |
@@ -748,7 +754,7 @@ TEST_P(SpdySessionTest, CreateStreamAfterGoAway) { |
spdy_stream->SetDelegate(&delegate); |
std::unique_ptr<SpdyHeaderBlock> headers( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
spdy_stream->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND); |
EXPECT_TRUE(spdy_stream->HasUrlFromHeaders()); |
@@ -785,7 +791,7 @@ TEST_P(SpdySessionTest, SynStreamAfterGoAway) { |
std::unique_ptr<SpdySerializedFrame> goaway( |
spdy_util_.ConstructSpdyGoAway(1)); |
std::unique_ptr<SpdySerializedFrame> push( |
- spdy_util_.ConstructSpdyPush(nullptr, 0, 2, 1, kDefaultURL)); |
+ spdy_util_.ConstructSpdyPush(nullptr, 0, 2, 1, kDefaultUrl)); |
MockRead reads[] = { |
MockRead(ASYNC, ERR_IO_PENDING, 1), |
CreateMockRead(*goaway, 2), |
@@ -812,7 +818,7 @@ TEST_P(SpdySessionTest, SynStreamAfterGoAway) { |
spdy_stream->SetDelegate(&delegate); |
std::unique_ptr<SpdyHeaderBlock> headers( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
spdy_stream->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND); |
EXPECT_TRUE(spdy_stream->HasUrlFromHeaders()); |
@@ -863,7 +869,7 @@ TEST_P(SpdySessionTest, NetworkChangeWithActiveStreams) { |
spdy_stream->SetDelegate(&delegate); |
std::unique_ptr<SpdyHeaderBlock> headers( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
spdy_stream->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND); |
EXPECT_TRUE(spdy_stream->HasUrlFromHeaders()); |
@@ -1024,7 +1030,7 @@ TEST_P(SpdySessionTest, PingAndWriteLoop) { |
spdy_stream->SetDelegate(&delegate); |
std::unique_ptr<SpdyHeaderBlock> headers( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
spdy_stream->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND); |
// Shift time so that a ping will be sent out. |
@@ -1119,7 +1125,7 @@ TEST_P(SpdySessionTest, StreamIdSpaceExhausted) { |
// Activate stream 1. One ID remains available. |
stream1->SendRequestHeaders( |
std::unique_ptr<SpdyHeaderBlock>( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))), |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))), |
NO_MORE_DATA_TO_SEND); |
base::RunLoop().RunUntilIdle(); |
@@ -1131,7 +1137,7 @@ TEST_P(SpdySessionTest, StreamIdSpaceExhausted) { |
// Activate stream 2. ID space is exhausted. |
stream2->SendRequestHeaders( |
std::unique_ptr<SpdyHeaderBlock>( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))), |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))), |
NO_MORE_DATA_TO_SEND); |
base::RunLoop().RunUntilIdle(); |
@@ -1254,7 +1260,7 @@ TEST_P(SpdySessionTest, MaxConcurrentStreamsZero) { |
test::StreamDelegateDoNothing delegate(stream); |
stream->SetDelegate(&delegate); |
std::unique_ptr<SpdyHeaderBlock> headers( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
stream->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND); |
EXPECT_TRUE(stream->HasUrlFromHeaders()); |
@@ -1338,13 +1344,13 @@ TEST_P(SpdySessionTest, DeleteExpiredPushStreams) { |
MockWrite writes[] = {CreateMockWrite(*req, 0), CreateMockWrite(*rst, 5)}; |
std::unique_ptr<SpdySerializedFrame> push_a(spdy_util_.ConstructSpdyPush( |
- nullptr, 0, 2, 1, "http://www.example.org/a.dat")); |
+ nullptr, 0, 2, 1, "https://www.example.org/a.dat")); |
std::unique_ptr<SpdySerializedFrame> push_a_body( |
spdy_util_.ConstructSpdyBodyFrame(2, false)); |
// In ascii "0" < "a". We use it to verify that we properly handle std::map |
// iterators inside. See http://crbug.com/443490 |
std::unique_ptr<SpdySerializedFrame> push_b(spdy_util_.ConstructSpdyPush( |
- nullptr, 0, 4, 1, "http://www.example.org/0.dat")); |
+ nullptr, 0, 4, 1, "https://www.example.org/0.dat")); |
MockRead reads[] = { |
CreateMockRead(*push_a, 1), |
CreateMockRead(*push_a_body, 2), |
@@ -1367,7 +1373,7 @@ TEST_P(SpdySessionTest, DeleteExpiredPushStreams) { |
spdy_stream->SetDelegate(&delegate); |
std::unique_ptr<SpdyHeaderBlock> headers( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
spdy_stream->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND); |
base::RunLoop().RunUntilIdle(); |
@@ -1375,7 +1381,7 @@ TEST_P(SpdySessionTest, DeleteExpiredPushStreams) { |
// Verify that there is one unclaimed push stream. |
EXPECT_EQ(1u, session_->num_unclaimed_pushed_streams()); |
EXPECT_EQ(1u, session_->count_unclaimed_pushed_streams_for_url( |
- GURL("http://www.example.org/a.dat"))); |
+ GURL("https://www.example.org/a.dat"))); |
// Unclaimed push body consumed bytes from the session window. |
EXPECT_EQ( |
@@ -1392,7 +1398,7 @@ TEST_P(SpdySessionTest, DeleteExpiredPushStreams) { |
// Verify that the second pushed stream evicted the first pushed stream. |
EXPECT_EQ(1u, session_->num_unclaimed_pushed_streams()); |
EXPECT_EQ(1u, session_->count_unclaimed_pushed_streams_for_url( |
- GURL("http://www.example.org/0.dat"))); |
+ GURL("https://www.example.org/0.dat"))); |
// Verify that the session window reclaimed the evicted stream body. |
EXPECT_EQ(SpdySession::GetDefaultInitialWindowSize(GetProtocol()), |
@@ -1550,6 +1556,19 @@ TEST_P(SpdySessionTest, ClearSettings) { |
SequencedSocketData data(reads, arraysize(reads), nullptr, 0); |
session_deps_.socket_factory->AddSocketDataProvider(&data); |
+ // Load a cert that is valid for: |
+ // www.example.org |
+ // mail.example.org |
+ // mail.example.com |
+ base::FilePath certs_dir = GetTestCertsDirectory(); |
+ scoped_refptr<X509Certificate> test_cert( |
+ ImportCertFromFile(certs_dir, "spdy_pooling.pem")); |
+ ASSERT_NE(static_cast<X509Certificate*>(nullptr), test_cert.get()); |
+ |
+ SSLSocketDataProvider ssl(SYNCHRONOUS, OK); |
+ ssl.cert = test_cert; |
+ session_deps_.socket_factory->AddSSLSocketDataProvider(&ssl); |
+ |
CreateNetworkSession(); |
// Initialize the SpdySetting with the default. |
@@ -1561,7 +1580,7 @@ TEST_P(SpdySessionTest, ClearSettings) { |
->GetSpdySettings(test_server_) |
.empty()); |
- CreateInsecureSpdySession(); |
+ CreateSecureSpdySession(); |
// Create the maximum number of concurrent streams. |
for (size_t i = 0; i < kInitialMaxConcurrentStreams; ++i) { |
@@ -1688,6 +1707,19 @@ TEST_P(SpdySessionTest, SendInitialDataOnNewSession) { |
writes.size()); |
session_deps_.socket_factory->AddSocketDataProvider(&data); |
+ // Load a cert that is valid for: |
+ // www.example.org |
+ // mail.example.org |
+ // mail.example.com |
+ base::FilePath certs_dir = GetTestCertsDirectory(); |
+ scoped_refptr<X509Certificate> test_cert( |
+ ImportCertFromFile(certs_dir, "spdy_pooling.pem")); |
+ ASSERT_NE(static_cast<X509Certificate*>(nullptr), test_cert.get()); |
+ |
+ SSLSocketDataProvider ssl(SYNCHRONOUS, OK); |
+ ssl.cert = test_cert; |
+ session_deps_.socket_factory->AddSSLSocketDataProvider(&ssl); |
+ |
CreateNetworkSession(); |
spdy_session_pool_->http_server_properties()->SetSpdySetting( |
@@ -1697,7 +1729,7 @@ TEST_P(SpdySessionTest, SendInitialDataOnNewSession) { |
SpdySessionPoolPeer pool_peer(spdy_session_pool_); |
pool_peer.SetEnableSendingInitialData(true); |
- CreateInsecureSpdySession(); |
+ CreateSecureSpdySession(); |
base::RunLoop().RunUntilIdle(); |
EXPECT_TRUE(data.AllWriteDataConsumed()); |
@@ -1872,7 +1904,7 @@ TEST_P(SpdySessionTest, SynCompressionHistograms) { |
spdy_stream->SetDelegate(&delegate); |
std::unique_ptr<SpdyHeaderBlock> headers( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
spdy_stream->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND); |
EXPECT_TRUE(spdy_stream->HasUrlFromHeaders()); |
@@ -1962,13 +1994,13 @@ TEST_P(SpdySessionTest, OutOfOrderSynStreams) { |
// Queue the lower priority one first. |
std::unique_ptr<SpdyHeaderBlock> headers_lowest( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
spdy_stream_lowest->SendRequestHeaders(std::move(headers_lowest), |
NO_MORE_DATA_TO_SEND); |
EXPECT_TRUE(spdy_stream_lowest->HasUrlFromHeaders()); |
std::unique_ptr<SpdyHeaderBlock> headers_highest( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
spdy_stream_highest->SendRequestHeaders(std::move(headers_highest), |
NO_MORE_DATA_TO_SEND); |
EXPECT_TRUE(spdy_stream_highest->HasUrlFromHeaders()); |
@@ -2025,12 +2057,12 @@ TEST_P(SpdySessionTest, CancelStream) { |
spdy_stream2->SetDelegate(&delegate2); |
std::unique_ptr<SpdyHeaderBlock> headers( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
spdy_stream1->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND); |
EXPECT_TRUE(spdy_stream1->HasUrlFromHeaders()); |
std::unique_ptr<SpdyHeaderBlock> headers2( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
spdy_stream2->SendRequestHeaders(std::move(headers2), NO_MORE_DATA_TO_SEND); |
EXPECT_TRUE(spdy_stream2->HasUrlFromHeaders()); |
@@ -2088,12 +2120,12 @@ TEST_P(SpdySessionTest, CloseSessionWithTwoCreatedSelfClosingStreams) { |
spdy_stream2->SetDelegate(&delegate2); |
std::unique_ptr<SpdyHeaderBlock> headers( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
spdy_stream1->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND); |
EXPECT_TRUE(spdy_stream1->HasUrlFromHeaders()); |
std::unique_ptr<SpdyHeaderBlock> headers2( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
spdy_stream2->SendRequestHeaders(std::move(headers2), NO_MORE_DATA_TO_SEND); |
EXPECT_TRUE(spdy_stream2->HasUrlFromHeaders()); |
@@ -2144,12 +2176,12 @@ TEST_P(SpdySessionTest, CloseSessionWithTwoCreatedMutuallyClosingStreams) { |
spdy_stream2->SetDelegate(&delegate2); |
std::unique_ptr<SpdyHeaderBlock> headers( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
spdy_stream1->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND); |
EXPECT_TRUE(spdy_stream1->HasUrlFromHeaders()); |
std::unique_ptr<SpdyHeaderBlock> headers2( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
spdy_stream2->SendRequestHeaders(std::move(headers2), NO_MORE_DATA_TO_SEND); |
EXPECT_TRUE(spdy_stream2->HasUrlFromHeaders()); |
@@ -2211,12 +2243,12 @@ TEST_P(SpdySessionTest, CloseSessionWithTwoActivatedSelfClosingStreams) { |
spdy_stream2->SetDelegate(&delegate2); |
std::unique_ptr<SpdyHeaderBlock> headers( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
spdy_stream1->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND); |
EXPECT_TRUE(spdy_stream1->HasUrlFromHeaders()); |
std::unique_ptr<SpdyHeaderBlock> headers2( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
spdy_stream2->SendRequestHeaders(std::move(headers2), NO_MORE_DATA_TO_SEND); |
EXPECT_TRUE(spdy_stream2->HasUrlFromHeaders()); |
@@ -2287,12 +2319,12 @@ TEST_P(SpdySessionTest, CloseSessionWithTwoActivatedMutuallyClosingStreams) { |
spdy_stream2->SetDelegate(&delegate2); |
std::unique_ptr<SpdyHeaderBlock> headers( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
spdy_stream1->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND); |
EXPECT_TRUE(spdy_stream1->HasUrlFromHeaders()); |
std::unique_ptr<SpdyHeaderBlock> headers2( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
spdy_stream2->SendRequestHeaders(std::move(headers2), NO_MORE_DATA_TO_SEND); |
EXPECT_TRUE(spdy_stream2->HasUrlFromHeaders()); |
@@ -2375,7 +2407,7 @@ TEST_P(SpdySessionTest, CloseActivatedStreamThatClosesSession) { |
spdy_stream->SetDelegate(&delegate); |
std::unique_ptr<SpdyHeaderBlock> headers( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
spdy_stream->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND); |
EXPECT_TRUE(spdy_stream->HasUrlFromHeaders()); |
@@ -2418,8 +2450,7 @@ TEST_P(SpdySessionTest, VerifyDomainAuthentication) { |
session_deps_.socket_factory->AddSSLSocketDataProvider(&ssl); |
CreateNetworkSession(); |
- |
- session_ = CreateSecureSpdySession(http_session_.get(), key_, BoundNetLog()); |
+ CreateSecureSpdySession(); |
EXPECT_TRUE(session_->VerifyDomainAuthentication("www.example.org")); |
EXPECT_TRUE(session_->VerifyDomainAuthentication("mail.example.org")); |
@@ -2448,8 +2479,7 @@ TEST_P(SpdySessionTest, ConnectionPooledWithTlsChannelId) { |
session_deps_.socket_factory->AddSSLSocketDataProvider(&ssl); |
CreateNetworkSession(); |
- |
- session_ = CreateSecureSpdySession(http_session_.get(), key_, BoundNetLog()); |
+ CreateSecureSpdySession(); |
EXPECT_TRUE(session_->VerifyDomainAuthentication("www.example.org")); |
EXPECT_TRUE(session_->VerifyDomainAuthentication("mail.example.org")); |
@@ -2550,7 +2580,7 @@ TEST_P(SpdySessionTest, CloseTwoStalledCreateStream) { |
EXPECT_EQ(2u, session_->pending_create_stream_queue_size(LOWEST)); |
std::unique_ptr<SpdyHeaderBlock> headers( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
spdy_stream1->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND); |
EXPECT_TRUE(spdy_stream1->HasUrlFromHeaders()); |
@@ -2575,7 +2605,7 @@ TEST_P(SpdySessionTest, CloseTwoStalledCreateStream) { |
test::StreamDelegateDoNothing delegate2(stream2); |
stream2->SetDelegate(&delegate2); |
std::unique_ptr<SpdyHeaderBlock> headers2( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
stream2->SendRequestHeaders(std::move(headers2), NO_MORE_DATA_TO_SEND); |
EXPECT_TRUE(stream2->HasUrlFromHeaders()); |
@@ -2600,7 +2630,7 @@ TEST_P(SpdySessionTest, CloseTwoStalledCreateStream) { |
test::StreamDelegateDoNothing delegate3(stream3); |
stream3->SetDelegate(&delegate3); |
std::unique_ptr<SpdyHeaderBlock> headers3( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
stream3->SendRequestHeaders(std::move(headers3), NO_MORE_DATA_TO_SEND); |
EXPECT_TRUE(stream3->HasUrlFromHeaders()); |
@@ -2749,7 +2779,7 @@ TEST_P(SpdySessionTest, ReadDataWithoutYielding) { |
spdy_stream1->SetDelegate(&delegate1); |
std::unique_ptr<SpdyHeaderBlock> headers1( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
spdy_stream1->SendRequestHeaders(std::move(headers1), NO_MORE_DATA_TO_SEND); |
EXPECT_TRUE(spdy_stream1->HasUrlFromHeaders()); |
@@ -2813,7 +2843,7 @@ TEST_P(SpdySessionTest, TestYieldingSlowReads) { |
spdy_stream1->SetDelegate(&delegate1); |
std::unique_ptr<SpdyHeaderBlock> headers1( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
spdy_stream1->SendRequestHeaders(std::move(headers1), NO_MORE_DATA_TO_SEND); |
EXPECT_TRUE(spdy_stream1->HasUrlFromHeaders()); |
@@ -2884,7 +2914,7 @@ TEST_P(SpdySessionTest, TestYieldingSlowSynchronousReads) { |
spdy_stream1->SetDelegate(&delegate1); |
std::unique_ptr<SpdyHeaderBlock> headers1( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
spdy_stream1->SendRequestHeaders(std::move(headers1), NO_MORE_DATA_TO_SEND); |
EXPECT_TRUE(spdy_stream1->HasUrlFromHeaders()); |
@@ -2965,7 +2995,7 @@ TEST_P(SpdySessionTest, TestYieldingDuringReadData) { |
spdy_stream1->SetDelegate(&delegate1); |
std::unique_ptr<SpdyHeaderBlock> headers1( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
spdy_stream1->SendRequestHeaders(std::move(headers1), NO_MORE_DATA_TO_SEND); |
EXPECT_TRUE(spdy_stream1->HasUrlFromHeaders()); |
@@ -3072,7 +3102,7 @@ TEST_P(SpdySessionTest, TestYieldingDuringAsyncReadData) { |
spdy_stream1->SetDelegate(&delegate1); |
std::unique_ptr<SpdyHeaderBlock> headers1( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
spdy_stream1->SendRequestHeaders(std::move(headers1), NO_MORE_DATA_TO_SEND); |
EXPECT_TRUE(spdy_stream1->HasUrlFromHeaders()); |
@@ -3141,7 +3171,7 @@ TEST_P(SpdySessionTest, GoAwayWhileInDoReadLoop) { |
EXPECT_EQ(0u, spdy_stream1->stream_id()); |
std::unique_ptr<SpdyHeaderBlock> headers1( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
spdy_stream1->SendRequestHeaders(std::move(headers1), NO_MORE_DATA_TO_SEND); |
EXPECT_TRUE(spdy_stream1->HasUrlFromHeaders()); |
@@ -3358,7 +3388,7 @@ TEST_P(SpdySessionTest, CloseSessionOnIdleWhenPoolStalled) { |
spdy_stream1->SetDelegate(&delegate1); |
std::unique_ptr<SpdyHeaderBlock> headers1( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
EXPECT_EQ(ERR_IO_PENDING, spdy_stream1->SendRequestHeaders( |
std::move(headers1), NO_MORE_DATA_TO_SEND)); |
EXPECT_TRUE(spdy_stream1->HasUrlFromHeaders()); |
@@ -3443,7 +3473,7 @@ class StreamCreatingDelegate : public test::StreamDelegateDoNothing { |
~StreamCreatingDelegate() override {} |
void OnClose(int status) override { |
- GURL url(kDefaultURL); |
+ GURL url(kDefaultUrl); |
ignore_result( |
CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, |
session_, url, MEDIUM, BoundNetLog())); |
@@ -3488,7 +3518,7 @@ TEST_P(SpdySessionTest, CreateStreamOnStreamReset) { |
spdy_stream->SetDelegate(&delegate); |
std::unique_ptr<SpdyHeaderBlock> headers( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
spdy_stream->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND); |
EXPECT_TRUE(spdy_stream->HasUrlFromHeaders()); |
@@ -3775,7 +3805,7 @@ TEST_P(SpdySessionTest, StreamFlowControlTooMuchData) { |
spdy_stream->SetDelegate(&delegate); |
std::unique_ptr<SpdyHeaderBlock> headers( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
EXPECT_EQ(ERR_IO_PENDING, spdy_stream->SendRequestHeaders( |
std::move(headers), NO_MORE_DATA_TO_SEND)); |
@@ -3913,7 +3943,7 @@ TEST_P(SpdySessionTest, StreamFlowControlTooMuchDataTwoDataFrames) { |
spdy_stream->SetDelegate(&delegate); |
std::unique_ptr<SpdyHeaderBlock> headers( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
EXPECT_EQ(ERR_IO_PENDING, spdy_stream->SendRequestHeaders( |
std::move(headers), NO_MORE_DATA_TO_SEND)); |
@@ -3967,7 +3997,7 @@ TEST_P(SpdySessionTest, SessionFlowControlNoReceiveLeaks) { |
const std::string msg_data(kMsgDataSize, 'a'); |
std::unique_ptr<SpdySerializedFrame> req(spdy_util_.ConstructSpdyPost( |
- kDefaultURL, 1, kMsgDataSize, MEDIUM, nullptr, 0)); |
+ kDefaultUrl, 1, kMsgDataSize, MEDIUM, nullptr, 0)); |
std::unique_ptr<SpdySerializedFrame> msg(spdy_util_.ConstructSpdyBodyFrame( |
1, msg_data.data(), kMsgDataSize, false)); |
MockWrite writes[] = { |
@@ -4006,7 +4036,7 @@ TEST_P(SpdySessionTest, SessionFlowControlNoReceiveLeaks) { |
stream->SetDelegate(&delegate); |
std::unique_ptr<SpdyHeaderBlock> headers(new SpdyHeaderBlock( |
- spdy_util_.ConstructPostHeaderBlock(kDefaultURL, kMsgDataSize))); |
+ spdy_util_.ConstructPostHeaderBlock(kDefaultUrl, kMsgDataSize))); |
EXPECT_EQ(ERR_IO_PENDING, |
stream->SendRequestHeaders(std::move(headers), MORE_DATA_TO_SEND)); |
EXPECT_TRUE(stream->HasUrlFromHeaders()); |
@@ -4042,7 +4072,7 @@ TEST_P(SpdySessionTest, SessionFlowControlNoSendLeaks) { |
const std::string msg_data(kMsgDataSize, 'a'); |
std::unique_ptr<SpdySerializedFrame> req(spdy_util_.ConstructSpdyPost( |
- kDefaultURL, 1, kMsgDataSize, MEDIUM, nullptr, 0)); |
+ kDefaultUrl, 1, kMsgDataSize, MEDIUM, nullptr, 0)); |
MockWrite writes[] = { |
CreateMockWrite(*req, 0), |
}; |
@@ -4072,7 +4102,7 @@ TEST_P(SpdySessionTest, SessionFlowControlNoSendLeaks) { |
stream->SetDelegate(&delegate); |
std::unique_ptr<SpdyHeaderBlock> headers(new SpdyHeaderBlock( |
- spdy_util_.ConstructPostHeaderBlock(kDefaultURL, kMsgDataSize))); |
+ spdy_util_.ConstructPostHeaderBlock(kDefaultUrl, kMsgDataSize))); |
EXPECT_EQ(ERR_IO_PENDING, |
stream->SendRequestHeaders(std::move(headers), MORE_DATA_TO_SEND)); |
EXPECT_TRUE(stream->HasUrlFromHeaders()); |
@@ -4115,7 +4145,7 @@ TEST_P(SpdySessionTest, SessionFlowControlEndToEnd) { |
const std::string msg_data(kMsgDataSize, 'a'); |
std::unique_ptr<SpdySerializedFrame> req(spdy_util_.ConstructSpdyPost( |
- kDefaultURL, 1, kMsgDataSize, MEDIUM, nullptr, 0)); |
+ kDefaultUrl, 1, kMsgDataSize, MEDIUM, nullptr, 0)); |
std::unique_ptr<SpdySerializedFrame> msg(spdy_util_.ConstructSpdyBodyFrame( |
1, msg_data.data(), kMsgDataSize, false)); |
MockWrite writes[] = { |
@@ -4157,7 +4187,7 @@ TEST_P(SpdySessionTest, SessionFlowControlEndToEnd) { |
stream->SetDelegate(&delegate); |
std::unique_ptr<SpdyHeaderBlock> headers(new SpdyHeaderBlock( |
- spdy_util_.ConstructPostHeaderBlock(kDefaultURL, kMsgDataSize))); |
+ spdy_util_.ConstructPostHeaderBlock(kDefaultUrl, kMsgDataSize))); |
EXPECT_EQ(ERR_IO_PENDING, |
stream->SendRequestHeaders(std::move(headers), MORE_DATA_TO_SEND)); |
EXPECT_TRUE(stream->HasUrlFromHeaders()); |
@@ -4225,7 +4255,7 @@ void SpdySessionTest::RunResumeAfterUnstallTest( |
session_deps_.host_resolver->set_synchronous_mode(true); |
std::unique_ptr<SpdySerializedFrame> req(spdy_util_.ConstructSpdyPost( |
- kDefaultURL, 1, kBodyDataSize, LOWEST, nullptr, 0)); |
+ kDefaultUrl, 1, kBodyDataSize, LOWEST, nullptr, 0)); |
std::unique_ptr<SpdySerializedFrame> body( |
spdy_util_.ConstructSpdyBodyFrame(1, kBodyData, kBodyDataSize, true)); |
MockWrite writes[] = { |
@@ -4258,11 +4288,11 @@ void SpdySessionTest::RunResumeAfterUnstallTest( |
EXPECT_FALSE(stream->send_stalled_by_flow_control()); |
std::unique_ptr<SpdyHeaderBlock> headers(new SpdyHeaderBlock( |
- spdy_util_.ConstructPostHeaderBlock(kDefaultURL, kBodyDataSize))); |
+ spdy_util_.ConstructPostHeaderBlock(kDefaultUrl, kBodyDataSize))); |
EXPECT_EQ(ERR_IO_PENDING, |
stream->SendRequestHeaders(std::move(headers), MORE_DATA_TO_SEND)); |
EXPECT_TRUE(stream->HasUrlFromHeaders()); |
- EXPECT_EQ(kDefaultURL, stream->GetUrlFromHeaders().spec()); |
+ EXPECT_EQ(kDefaultUrl, stream->GetUrlFromHeaders().spec()); |
stall_function.Run(stream.get()); |
@@ -4343,9 +4373,9 @@ TEST_P(SpdySessionTest, ResumeByPriorityAfterSendWindowSizeIncrease) { |
session_deps_.host_resolver->set_synchronous_mode(true); |
std::unique_ptr<SpdySerializedFrame> req1(spdy_util_.ConstructSpdyPost( |
- kDefaultURL, 1, kBodyDataSize, LOWEST, nullptr, 0)); |
+ kDefaultUrl, 1, kBodyDataSize, LOWEST, nullptr, 0)); |
std::unique_ptr<SpdySerializedFrame> req2(spdy_util_.ConstructSpdyPost( |
- kDefaultURL, 3, kBodyDataSize, MEDIUM, nullptr, 0)); |
+ kDefaultUrl, 3, kBodyDataSize, MEDIUM, nullptr, 0)); |
std::unique_ptr<SpdySerializedFrame> body1( |
spdy_util_.ConstructSpdyBodyFrame(1, kBodyData, kBodyDataSize, true)); |
std::unique_ptr<SpdySerializedFrame> body2( |
@@ -4397,22 +4427,22 @@ TEST_P(SpdySessionTest, ResumeByPriorityAfterSendWindowSizeIncrease) { |
StallSessionSend(); |
std::unique_ptr<SpdyHeaderBlock> headers1(new SpdyHeaderBlock( |
- spdy_util_.ConstructPostHeaderBlock(kDefaultURL, kBodyDataSize))); |
+ spdy_util_.ConstructPostHeaderBlock(kDefaultUrl, kBodyDataSize))); |
EXPECT_EQ(ERR_IO_PENDING, stream1->SendRequestHeaders(std::move(headers1), |
MORE_DATA_TO_SEND)); |
EXPECT_TRUE(stream1->HasUrlFromHeaders()); |
- EXPECT_EQ(kDefaultURL, stream1->GetUrlFromHeaders().spec()); |
+ EXPECT_EQ(kDefaultUrl, stream1->GetUrlFromHeaders().spec()); |
base::RunLoop().RunUntilIdle(); |
EXPECT_EQ(1u, stream1->stream_id()); |
EXPECT_TRUE(stream1->send_stalled_by_flow_control()); |
std::unique_ptr<SpdyHeaderBlock> headers2(new SpdyHeaderBlock( |
- spdy_util_.ConstructPostHeaderBlock(kDefaultURL, kBodyDataSize))); |
+ spdy_util_.ConstructPostHeaderBlock(kDefaultUrl, kBodyDataSize))); |
EXPECT_EQ(ERR_IO_PENDING, stream2->SendRequestHeaders(std::move(headers2), |
MORE_DATA_TO_SEND)); |
EXPECT_TRUE(stream2->HasUrlFromHeaders()); |
- EXPECT_EQ(kDefaultURL, stream2->GetUrlFromHeaders().spec()); |
+ EXPECT_EQ(kDefaultUrl, stream2->GetUrlFromHeaders().spec()); |
base::RunLoop().RunUntilIdle(); |
EXPECT_EQ(3u, stream2->stream_id()); |
@@ -4484,11 +4514,11 @@ TEST_P(SpdySessionTest, SendWindowSizeIncreaseWithDeletedStreams) { |
session_deps_.host_resolver->set_synchronous_mode(true); |
std::unique_ptr<SpdySerializedFrame> req1(spdy_util_.ConstructSpdyPost( |
- kDefaultURL, 1, kBodyDataSize, LOWEST, nullptr, 0)); |
+ kDefaultUrl, 1, kBodyDataSize, LOWEST, nullptr, 0)); |
std::unique_ptr<SpdySerializedFrame> req2(spdy_util_.ConstructSpdyPost( |
- kDefaultURL, 3, kBodyDataSize, LOWEST, nullptr, 0)); |
+ kDefaultUrl, 3, kBodyDataSize, LOWEST, nullptr, 0)); |
std::unique_ptr<SpdySerializedFrame> req3(spdy_util_.ConstructSpdyPost( |
- kDefaultURL, 5, kBodyDataSize, LOWEST, nullptr, 0)); |
+ kDefaultUrl, 5, kBodyDataSize, LOWEST, nullptr, 0)); |
std::unique_ptr<SpdySerializedFrame> body2( |
spdy_util_.ConstructSpdyBodyFrame(3, kBodyData, kBodyDataSize, true)); |
MockWrite writes[] = { |
@@ -4546,33 +4576,33 @@ TEST_P(SpdySessionTest, SendWindowSizeIncreaseWithDeletedStreams) { |
StallSessionSend(); |
std::unique_ptr<SpdyHeaderBlock> headers1(new SpdyHeaderBlock( |
- spdy_util_.ConstructPostHeaderBlock(kDefaultURL, kBodyDataSize))); |
+ spdy_util_.ConstructPostHeaderBlock(kDefaultUrl, kBodyDataSize))); |
EXPECT_EQ(ERR_IO_PENDING, stream1->SendRequestHeaders(std::move(headers1), |
MORE_DATA_TO_SEND)); |
EXPECT_TRUE(stream1->HasUrlFromHeaders()); |
- EXPECT_EQ(kDefaultURL, stream1->GetUrlFromHeaders().spec()); |
+ EXPECT_EQ(kDefaultUrl, stream1->GetUrlFromHeaders().spec()); |
base::RunLoop().RunUntilIdle(); |
EXPECT_EQ(1u, stream1->stream_id()); |
EXPECT_TRUE(stream1->send_stalled_by_flow_control()); |
std::unique_ptr<SpdyHeaderBlock> headers2(new SpdyHeaderBlock( |
- spdy_util_.ConstructPostHeaderBlock(kDefaultURL, kBodyDataSize))); |
+ spdy_util_.ConstructPostHeaderBlock(kDefaultUrl, kBodyDataSize))); |
EXPECT_EQ(ERR_IO_PENDING, stream2->SendRequestHeaders(std::move(headers2), |
MORE_DATA_TO_SEND)); |
EXPECT_TRUE(stream2->HasUrlFromHeaders()); |
- EXPECT_EQ(kDefaultURL, stream2->GetUrlFromHeaders().spec()); |
+ EXPECT_EQ(kDefaultUrl, stream2->GetUrlFromHeaders().spec()); |
base::RunLoop().RunUntilIdle(); |
EXPECT_EQ(3u, stream2->stream_id()); |
EXPECT_TRUE(stream2->send_stalled_by_flow_control()); |
std::unique_ptr<SpdyHeaderBlock> headers3(new SpdyHeaderBlock( |
- spdy_util_.ConstructPostHeaderBlock(kDefaultURL, kBodyDataSize))); |
+ spdy_util_.ConstructPostHeaderBlock(kDefaultUrl, kBodyDataSize))); |
EXPECT_EQ(ERR_IO_PENDING, stream3->SendRequestHeaders(std::move(headers3), |
MORE_DATA_TO_SEND)); |
EXPECT_TRUE(stream3->HasUrlFromHeaders()); |
- EXPECT_EQ(kDefaultURL, stream3->GetUrlFromHeaders().spec()); |
+ EXPECT_EQ(kDefaultUrl, stream3->GetUrlFromHeaders().spec()); |
base::RunLoop().RunUntilIdle(); |
EXPECT_EQ(5u, stream3->stream_id()); |
@@ -4631,9 +4661,9 @@ TEST_P(SpdySessionTest, SendWindowSizeIncreaseWithDeletedSession) { |
session_deps_.host_resolver->set_synchronous_mode(true); |
std::unique_ptr<SpdySerializedFrame> req1(spdy_util_.ConstructSpdyPost( |
- kDefaultURL, 1, kBodyDataSize, LOWEST, nullptr, 0)); |
+ kDefaultUrl, 1, kBodyDataSize, LOWEST, nullptr, 0)); |
std::unique_ptr<SpdySerializedFrame> req2(spdy_util_.ConstructSpdyPost( |
- kDefaultURL, 3, kBodyDataSize, LOWEST, nullptr, 0)); |
+ kDefaultUrl, 3, kBodyDataSize, LOWEST, nullptr, 0)); |
std::unique_ptr<SpdySerializedFrame> body1( |
spdy_util_.ConstructSpdyBodyFrame(1, kBodyData, kBodyDataSize, false)); |
MockWrite writes[] = { |
@@ -4675,22 +4705,22 @@ TEST_P(SpdySessionTest, SendWindowSizeIncreaseWithDeletedSession) { |
StallSessionSend(); |
std::unique_ptr<SpdyHeaderBlock> headers1(new SpdyHeaderBlock( |
- spdy_util_.ConstructPostHeaderBlock(kDefaultURL, kBodyDataSize))); |
+ spdy_util_.ConstructPostHeaderBlock(kDefaultUrl, kBodyDataSize))); |
EXPECT_EQ(ERR_IO_PENDING, stream1->SendRequestHeaders(std::move(headers1), |
MORE_DATA_TO_SEND)); |
EXPECT_TRUE(stream1->HasUrlFromHeaders()); |
- EXPECT_EQ(kDefaultURL, stream1->GetUrlFromHeaders().spec()); |
+ EXPECT_EQ(kDefaultUrl, stream1->GetUrlFromHeaders().spec()); |
base::RunLoop().RunUntilIdle(); |
EXPECT_EQ(1u, stream1->stream_id()); |
EXPECT_TRUE(stream1->send_stalled_by_flow_control()); |
std::unique_ptr<SpdyHeaderBlock> headers2(new SpdyHeaderBlock( |
- spdy_util_.ConstructPostHeaderBlock(kDefaultURL, kBodyDataSize))); |
+ spdy_util_.ConstructPostHeaderBlock(kDefaultUrl, kBodyDataSize))); |
EXPECT_EQ(ERR_IO_PENDING, stream2->SendRequestHeaders(std::move(headers2), |
MORE_DATA_TO_SEND)); |
EXPECT_TRUE(stream2->HasUrlFromHeaders()); |
- EXPECT_EQ(kDefaultURL, stream2->GetUrlFromHeaders().spec()); |
+ EXPECT_EQ(kDefaultUrl, stream2->GetUrlFromHeaders().spec()); |
base::RunLoop().RunUntilIdle(); |
EXPECT_EQ(3u, stream2->stream_id()); |
@@ -4756,7 +4786,7 @@ TEST_P(SpdySessionTest, GoAwayOnSessionFlowControlError) { |
spdy_stream->SetDelegate(&delegate); |
std::unique_ptr<SpdyHeaderBlock> headers( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
spdy_stream->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND); |
// Write request. |
@@ -4775,7 +4805,7 @@ TEST_P(SpdySessionTest, GoAwayOnSessionFlowControlError) { |
} |
TEST_P(SpdySessionTest, SplitHeaders) { |
- GURL kStreamUrl("http://www.example.org/foo.dat"); |
+ GURL kStreamUrl("https://www.example.org/foo.dat"); |
SpdyHeaderBlock headers; |
spdy_util_.AddUrlToHeaderBlock(kStreamUrl.spec(), &headers); |
headers["alpha"] = "beta"; |
@@ -4805,7 +4835,7 @@ TEST_P(SpdySessionTest, PushedStreamShouldNotCountToClientConcurrencyLimit) { |
std::unique_ptr<SpdySerializedFrame> settings_frame( |
spdy_util_.ConstructSpdySettings(new_settings)); |
std::unique_ptr<SpdySerializedFrame> pushed(spdy_util_.ConstructSpdyPush( |
- nullptr, 0, 2, 1, "http://www.example.org/a.dat")); |
+ nullptr, 0, 2, 1, "https://www.example.org/a.dat")); |
MockRead reads[] = { |
CreateMockRead(*settings_frame, 0), |
MockRead(ASYNC, ERR_IO_PENDING, 3), |
@@ -4844,7 +4874,7 @@ TEST_P(SpdySessionTest, PushedStreamShouldNotCountToClientConcurrencyLimit) { |
EXPECT_EQ(0u, session_->num_active_pushed_streams()); |
std::unique_ptr<SpdyHeaderBlock> headers( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
spdy_stream1->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND); |
EXPECT_TRUE(spdy_stream1->HasUrlFromHeaders()); |
@@ -4884,9 +4914,9 @@ TEST_P(SpdySessionTest, PushedStreamShouldNotCountToClientConcurrencyLimit) { |
TEST_P(SpdySessionTest, RejectPushedStreamExceedingConcurrencyLimit) { |
std::unique_ptr<SpdySerializedFrame> push_a(spdy_util_.ConstructSpdyPush( |
- nullptr, 0, 2, 1, "http://www.example.org/a.dat")); |
+ nullptr, 0, 2, 1, "https://www.example.org/a.dat")); |
std::unique_ptr<SpdySerializedFrame> push_b(spdy_util_.ConstructSpdyPush( |
- nullptr, 0, 4, 1, "http://www.example.org/b.dat")); |
+ nullptr, 0, 4, 1, "https://www.example.org/b.dat")); |
MockRead reads[] = { |
MockRead(ASYNC, ERR_IO_PENDING, 1), |
CreateMockRead(*push_a, 2), |
@@ -4924,7 +4954,7 @@ TEST_P(SpdySessionTest, RejectPushedStreamExceedingConcurrencyLimit) { |
EXPECT_EQ(0u, session_->num_active_pushed_streams()); |
std::unique_ptr<SpdyHeaderBlock> headers( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
spdy_stream1->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND); |
EXPECT_TRUE(spdy_stream1->HasUrlFromHeaders()); |
@@ -4962,13 +4992,13 @@ TEST_P(SpdySessionTest, RejectPushedStreamExceedingConcurrencyLimit) { |
// Tests that HTTP SPDY push streams that advertise an origin different from the |
// associated stream are accepted from a trusted SPDY proxy. |
TEST_P(SpdySessionTest, TrustedSpdyProxy) { |
- // Origin of kDefaultURL should be different from the origin of |
+ // Origin of kDefaultUrl should be different from the origin of |
// kHttpURLFromAnotherOrigin and kHttpsURLFromAnotherOrigin. |
- ASSERT_NE(GURL(kDefaultURL).host(), GURL(kHttpURLFromAnotherOrigin).host()); |
- ASSERT_NE(GURL(kDefaultURL).host(), GURL(kHttpsURLFromAnotherOrigin).host()); |
+ ASSERT_NE(GURL(kDefaultUrl).host(), GURL(kHttpURLFromAnotherOrigin).host()); |
+ ASSERT_NE(GURL(kDefaultUrl).host(), GURL(kHttpsURLFromAnotherOrigin).host()); |
// cross_origin_push contains HTTP resource for an origin different from the |
- // origin of kDefaultURL, and should be accepted. |
+ // origin of kDefaultUrl, and should be accepted. |
std::unique_ptr<SpdySerializedFrame> cross_origin_push( |
spdy_util_.ConstructSpdyPush(nullptr, 0, 2, 1, |
kHttpURLFromAnotherOrigin)); |
@@ -4999,11 +5029,24 @@ TEST_P(SpdySessionTest, TrustedSpdyProxy) { |
std::unique_ptr<TestProxyDelegate> proxy_delegate(new TestProxyDelegate()); |
proxy_delegate->set_trusted_spdy_proxy( |
net::ProxyServer(net::ProxyServer::SCHEME_HTTPS, |
- HostPortPair(GURL(kDefaultURL).host(), 80))); |
+ HostPortPair(GURL(kDefaultUrl).host(), 443))); |
session_deps_.proxy_delegate.reset(proxy_delegate.release()); |
+ // Load a cert that is valid for: |
+ // www.example.org |
+ // mail.example.org |
+ // mail.example.com |
+ base::FilePath certs_dir = GetTestCertsDirectory(); |
+ scoped_refptr<X509Certificate> test_cert( |
+ ImportCertFromFile(certs_dir, "spdy_pooling.pem")); |
+ ASSERT_NE(static_cast<X509Certificate*>(nullptr), test_cert.get()); |
+ |
+ SSLSocketDataProvider ssl(SYNCHRONOUS, OK); |
+ ssl.cert = test_cert; |
+ session_deps_.socket_factory->AddSSLSocketDataProvider(&ssl); |
+ |
CreateNetworkSession(); |
- CreateInsecureSpdySession(); |
+ CreateSecureSpdySession(); |
base::WeakPtr<SpdyStream> spdy_stream = CreateStreamSynchronously( |
SPDY_REQUEST_RESPONSE_STREAM, session_, test_url_, LOWEST, BoundNetLog()); |
@@ -5018,7 +5061,7 @@ TEST_P(SpdySessionTest, TrustedSpdyProxy) { |
EXPECT_EQ(0u, session_->num_active_pushed_streams()); |
std::unique_ptr<SpdyHeaderBlock> headers( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
spdy_stream->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND); |
EXPECT_TRUE(spdy_stream->HasUrlFromHeaders()); |
@@ -5056,12 +5099,12 @@ TEST_P(SpdySessionTest, TrustedSpdyProxy) { |
// Tests that if the SPDY trusted proxy is not set, then push streams that |
// advertise an origin different from the associated stream are refused. |
TEST_P(SpdySessionTest, TrustedSpdyProxyNotSet) { |
- // Origin of kDefaultURL should be different from the origin of |
+ // Origin of kDefaultUrl should be different from the origin of |
// kHttpURLFromAnotherOrigin. |
- ASSERT_NE(GURL(kDefaultURL).host(), GURL(kHttpURLFromAnotherOrigin).host()); |
+ ASSERT_NE(GURL(kDefaultUrl).host(), GURL(kHttpURLFromAnotherOrigin).host()); |
// cross_origin_push contains resource for an origin different from the |
- // origin of kDefaultURL, and should be refused. |
+ // origin of kDefaultUrl, and should be refused. |
std::unique_ptr<SpdySerializedFrame> cross_origin_push( |
spdy_util_.ConstructSpdyPush(nullptr, 0, 2, 1, |
kHttpURLFromAnotherOrigin)); |
@@ -5081,8 +5124,21 @@ TEST_P(SpdySessionTest, TrustedSpdyProxyNotSet) { |
SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes)); |
session_deps_.socket_factory->AddSocketDataProvider(&data); |
+ // Load a cert that is valid for: |
+ // www.example.org |
+ // mail.example.org |
+ // mail.example.com |
+ base::FilePath certs_dir = GetTestCertsDirectory(); |
+ scoped_refptr<X509Certificate> test_cert( |
+ ImportCertFromFile(certs_dir, "spdy_pooling.pem")); |
+ ASSERT_NE(static_cast<X509Certificate*>(nullptr), test_cert.get()); |
+ |
+ SSLSocketDataProvider ssl(SYNCHRONOUS, OK); |
+ ssl.cert = test_cert; |
+ session_deps_.socket_factory->AddSSLSocketDataProvider(&ssl); |
+ |
CreateNetworkSession(); |
- CreateInsecureSpdySession(); |
+ CreateSecureSpdySession(); |
base::WeakPtr<SpdyStream> spdy_stream = CreateStreamSynchronously( |
SPDY_REQUEST_RESPONSE_STREAM, session_, test_url_, LOWEST, BoundNetLog()); |
@@ -5097,7 +5153,7 @@ TEST_P(SpdySessionTest, TrustedSpdyProxyNotSet) { |
EXPECT_EQ(0u, session_->num_active_pushed_streams()); |
std::unique_ptr<SpdyHeaderBlock> headers( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
spdy_stream->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND); |
EXPECT_TRUE(spdy_stream->HasUrlFromHeaders()); |
@@ -5122,9 +5178,10 @@ TEST_P(SpdySessionTest, IgnoreReservedRemoteStreamsCount) { |
return; |
std::unique_ptr<SpdySerializedFrame> push_a(spdy_util_.ConstructSpdyPush( |
- nullptr, 0, 2, 1, "http://www.example.org/a.dat")); |
+ nullptr, 0, 2, 1, "https://www.example.org/a.dat")); |
SpdyHeaderBlock push_headers; |
- spdy_util_.AddUrlToHeaderBlock("http://www.example.org/b.dat", &push_headers); |
+ spdy_util_.AddUrlToHeaderBlock("https://www.example.org/b.dat", |
+ &push_headers); |
std::unique_ptr<SpdySerializedFrame> push_b( |
spdy_util_.ConstructInitialSpdyPushFrame(std::move(push_headers), 4, 1)); |
std::unique_ptr<SpdySerializedFrame> headers_b( |
@@ -5168,7 +5225,7 @@ TEST_P(SpdySessionTest, IgnoreReservedRemoteStreamsCount) { |
EXPECT_EQ(0u, session_->num_active_pushed_streams()); |
std::unique_ptr<SpdyHeaderBlock> headers( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
spdy_stream1->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND); |
EXPECT_TRUE(spdy_stream1->HasUrlFromHeaders()); |
@@ -5217,7 +5274,7 @@ TEST_P(SpdySessionTest, CancelReservedStreamOnHeadersReceived) { |
if (spdy_util_.spdy_version() < HTTP2) |
return; |
- const char kPushedUrl[] = "http://www.example.org/a.dat"; |
+ const char kPushedUrl[] = "https://www.example.org/a.dat"; |
SpdyHeaderBlock push_headers; |
spdy_util_.AddUrlToHeaderBlock(kPushedUrl, &push_headers); |
std::unique_ptr<SpdySerializedFrame> push_promise( |
@@ -5260,7 +5317,7 @@ TEST_P(SpdySessionTest, CancelReservedStreamOnHeadersReceived) { |
EXPECT_EQ(0u, session_->num_active_pushed_streams()); |
std::unique_ptr<SpdyHeaderBlock> headers( |
- new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultURL))); |
+ new SpdyHeaderBlock(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl))); |
spdy_stream1->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND); |
EXPECT_TRUE(spdy_stream1->HasUrlFromHeaders()); |