HELLO·Android
系统源代码
IT资讯
技术文章
我的收藏
注册
登录
-
我收藏的文章
创建代码块
我的代码块
我的账号
Lollipop
|
5.0.1_r1
下载
查看原文件
收藏
根目录
external
chromium_org
net
spdy
spdy_session_unittest.cc
// 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/spdy/spdy_session.h" #include "base/bind.h" #include "base/callback.h" #include "base/memory/scoped_ptr.h" #include "base/run_loop.h" #include "net/base/io_buffer.h" #include "net/base/ip_endpoint.h" #include "net/base/net_log_unittest.h" #include "net/base/request_priority.h" #include "net/base/test_data_directory.h" #include "net/base/test_data_stream.h" #include "net/socket/client_socket_pool_manager.h" #include "net/socket/next_proto.h" #include "net/socket/socket_test_util.h" #include "net/spdy/spdy_http_utils.h" #include "net/spdy/spdy_session_pool.h" #include "net/spdy/spdy_session_test_util.h" #include "net/spdy/spdy_stream.h" #include "net/spdy/spdy_stream_test_util.h" #include "net/spdy/spdy_test_util_common.h" #include "net/spdy/spdy_test_utils.h" #include "net/test/cert_test_util.h" #include "testing/platform_test.h" namespace net { namespace { static const char kTestUrl[] = "http://www.example.org/"; static const char kTestHost[] = "www.example.org"; static const int kTestPort = 80; const char kBodyData[] = "Body data"; const size_t kBodyDataSize = arraysize(kBodyData); const base::StringPiece kBodyDataStringPiece(kBodyData, kBodyDataSize); static base::TimeDelta g_time_delta; base::TimeTicks TheNearFuture() { return base::TimeTicks::Now() + g_time_delta; } } // namespace class SpdySessionTest : public PlatformTest, public ::testing::WithParamInterface
{ public: // Functions used with RunResumeAfterUnstallTest(). void StallSessionOnly(SpdySession* session, SpdyStream* stream) { StallSessionSend(session); } void StallStreamOnly(SpdySession* session, SpdyStream* stream) { StallStreamSend(stream); } void StallSessionStream(SpdySession* session, SpdyStream* stream) { StallSessionSend(session); StallStreamSend(stream); } void StallStreamSession(SpdySession* session, SpdyStream* stream) { StallStreamSend(stream); StallSessionSend(session); } void UnstallSessionOnly(SpdySession* session, SpdyStream* stream, int32 delta_window_size) { UnstallSessionSend(session, delta_window_size); } void UnstallStreamOnly(SpdySession* session, SpdyStream* stream, int32 delta_window_size) { UnstallStreamSend(stream, delta_window_size); } void UnstallSessionStream(SpdySession* session, SpdyStream* stream, int32 delta_window_size) { UnstallSessionSend(session, delta_window_size); UnstallStreamSend(stream, delta_window_size); } void UnstallStreamSession(SpdySession* session, SpdyStream* stream, int32 delta_window_size) { UnstallStreamSend(stream, delta_window_size); UnstallSessionSend(session, delta_window_size); } protected: SpdySessionTest() : old_max_group_sockets_(ClientSocketPoolManager::max_sockets_per_group( HttpNetworkSession::NORMAL_SOCKET_POOL)), old_max_pool_sockets_(ClientSocketPoolManager::max_sockets_per_pool( HttpNetworkSession::NORMAL_SOCKET_POOL)), spdy_util_(GetParam()), session_deps_(GetParam()), spdy_session_pool_(NULL), test_url_(kTestUrl), test_host_port_pair_(kTestHost, kTestPort), key_(test_host_port_pair_, ProxyServer::Direct(), PRIVACY_MODE_DISABLED) { } virtual ~SpdySessionTest() { // Important to restore the per-pool limit first, since the pool limit must // always be greater than group limit, and the tests reduce both limits. ClientSocketPoolManager::set_max_sockets_per_pool( HttpNetworkSession::NORMAL_SOCKET_POOL, old_max_pool_sockets_); ClientSocketPoolManager::set_max_sockets_per_group( HttpNetworkSession::NORMAL_SOCKET_POOL, old_max_group_sockets_); } virtual void SetUp() OVERRIDE { g_time_delta = base::TimeDelta(); } void CreateDeterministicNetworkSession() { http_session_ = SpdySessionDependencies::SpdyCreateSessionDeterministic(&session_deps_); spdy_session_pool_ = http_session_->spdy_session_pool(); } void CreateNetworkSession() { http_session_ = SpdySessionDependencies::SpdyCreateSession(&session_deps_); spdy_session_pool_ = http_session_->spdy_session_pool(); } void StallSessionSend(SpdySession* session) { // Reduce the send window size to 0 to stall. while (session->session_send_window_size_ > 0) { session->DecreaseSendWindowSize( std::min(kMaxSpdyFrameChunkSize, session->session_send_window_size_)); } } void UnstallSessionSend(SpdySession* session, int32 delta_window_size) { session->IncreaseSendWindowSize(delta_window_size); } void StallStreamSend(SpdyStream* stream) { // Reduce the send window size to 0 to stall. while (stream->send_window_size() > 0) { stream->DecreaseSendWindowSize( std::min(kMaxSpdyFrameChunkSize, stream->send_window_size())); } } void UnstallStreamSend(SpdyStream* stream, int32 delta_window_size) { stream->IncreaseSendWindowSize(delta_window_size); } void RunResumeAfterUnstallTest( const base::Callback
& stall_function, const base::Callback
& unstall_function); // Original socket limits. Some tests set these. Safest to always restore // them once each test has been run. int old_max_group_sockets_; int old_max_pool_sockets_; SpdyTestUtil spdy_util_; SpdySessionDependencies session_deps_; scoped_refptr
http_session_; SpdySessionPool* spdy_session_pool_; GURL test_url_; HostPortPair test_host_port_pair_; SpdySessionKey key_; }; INSTANTIATE_TEST_CASE_P( NextProto, SpdySessionTest, testing::Values(kProtoDeprecatedSPDY2, kProtoSPDY3, kProtoSPDY31, kProtoSPDY4)); // Try to create a SPDY session that will fail during // initialization. Nothing should blow up. TEST_P(SpdySessionTest, InitialReadError) { CreateDeterministicNetworkSession(); base::WeakPtr
session = TryCreateFakeSpdySessionExpectingFailure( spdy_session_pool_, key_, ERR_CONNECTION_CLOSED); EXPECT_TRUE(session); // Flush the read. base::RunLoop().RunUntilIdle(); EXPECT_FALSE(session); } namespace { // A helper class that vends a callback that, when fired, destroys a // given SpdyStreamRequest. class StreamRequestDestroyingCallback : public TestCompletionCallbackBase { public: StreamRequestDestroyingCallback() {} virtual ~StreamRequestDestroyingCallback() {} void SetRequestToDestroy(scoped_ptr
request) { request_ = request.Pass(); } CompletionCallback MakeCallback() { return base::Bind(&StreamRequestDestroyingCallback::OnComplete, base::Unretained(this)); } private: void OnComplete(int result) { request_.reset(); SetResult(result); } scoped_ptr
request_; }; } // namespace // Request kInitialMaxConcurrentStreams streams. Request two more // streams, but have the callback for one destroy the second stream // request. Close the session. Nothing should blow up. This is a // regression test for http://crbug.com/250841 . TEST_P(SpdySessionTest, PendingStreamCancellingAnother) { session_deps_.host_resolver->set_synchronous_mode(true); MockRead reads[] = {MockRead(ASYNC, 0, 0), }; DeterministicSocketData data(reads, arraysize(reads), NULL, 0); MockConnect connect_data(SYNCHRONOUS, OK); data.set_connect_data(connect_data); session_deps_.deterministic_socket_factory->AddSocketDataProvider(&data); CreateDeterministicNetworkSession(); base::WeakPtr
session = CreateInsecureSpdySession(http_session_, key_, BoundNetLog()); // Create the maximum number of concurrent streams. for (size_t i = 0; i < kInitialMaxConcurrentStreams; ++i) { base::WeakPtr
spdy_stream = CreateStreamSynchronously( SPDY_BIDIRECTIONAL_STREAM, session, test_url_, MEDIUM, BoundNetLog()); ASSERT_TRUE(spdy_stream != NULL); } SpdyStreamRequest request1; scoped_ptr
request2(new SpdyStreamRequest); StreamRequestDestroyingCallback callback1; ASSERT_EQ(ERR_IO_PENDING, request1.StartRequest(SPDY_BIDIRECTIONAL_STREAM, session, test_url_, MEDIUM, BoundNetLog(), callback1.MakeCallback())); // |callback2| is never called. TestCompletionCallback callback2; ASSERT_EQ(ERR_IO_PENDING, request2->StartRequest(SPDY_BIDIRECTIONAL_STREAM, session, test_url_, MEDIUM, BoundNetLog(), callback2.callback())); callback1.SetRequestToDestroy(request2.Pass()); session->CloseSessionOnError(ERR_ABORTED, "Aborting session"); EXPECT_EQ(ERR_ABORTED, callback1.WaitForResult()); } // A session receiving a GOAWAY frame with no active streams should close. TEST_P(SpdySessionTest, GoAwayWithNoActiveStreams) { session_deps_.host_resolver->set_synchronous_mode(true); MockConnect connect_data(SYNCHRONOUS, OK); scoped_ptr
goaway(spdy_util_.ConstructSpdyGoAway(1)); MockRead reads[] = { CreateMockRead(*goaway, 0), }; DeterministicSocketData data(reads, arraysize(reads), NULL, 0); data.set_connect_data(connect_data); session_deps_.deterministic_socket_factory->AddSocketDataProvider(&data); CreateDeterministicNetworkSession(); base::WeakPtr
session = CreateInsecureSpdySession(http_session_, key_, BoundNetLog()); EXPECT_EQ(spdy_util_.spdy_version(), session->GetProtocolVersion()); EXPECT_TRUE(HasSpdySession(spdy_session_pool_, key_)); // Read and process the GOAWAY frame. data.RunFor(1); EXPECT_FALSE(HasSpdySession(spdy_session_pool_, key_)); base::RunLoop().RunUntilIdle(); EXPECT_TRUE(session == NULL); } // A session receiving a GOAWAY frame immediately with no active // streams should then close. TEST_P(SpdySessionTest, GoAwayImmediatelyWithNoActiveStreams) { session_deps_.host_resolver->set_synchronous_mode(true); MockConnect connect_data(SYNCHRONOUS, OK); scoped_ptr
goaway(spdy_util_.ConstructSpdyGoAway(1)); MockRead reads[] = { CreateMockRead(*goaway, 0, SYNCHRONOUS), }; DeterministicSocketData data(reads, arraysize(reads), NULL, 0); data.set_connect_data(connect_data); session_deps_.deterministic_socket_factory->AddSocketDataProvider(&data); CreateDeterministicNetworkSession(); data.StopAfter(1); base::WeakPtr
session = TryCreateInsecureSpdySessionExpectingFailure( http_session_, key_, ERR_CONNECTION_CLOSED, BoundNetLog()); base::RunLoop().RunUntilIdle(); EXPECT_FALSE(session); EXPECT_FALSE(HasSpdySession(spdy_session_pool_, key_)); } // A session receiving a GOAWAY frame with active streams should close // when the last active stream is closed. TEST_P(SpdySessionTest, GoAwayWithActiveStreams) { session_deps_.host_resolver->set_synchronous_mode(true); MockConnect connect_data(SYNCHRONOUS, OK); scoped_ptr
goaway(spdy_util_.ConstructSpdyGoAway(1)); MockRead reads[] = { CreateMockRead(*goaway, 2), MockRead(ASYNC, 0, 3) // EOF }; scoped_ptr
req1( spdy_util_.ConstructSpdyGet(NULL, 0, false, 1, MEDIUM, true)); scoped_ptr
req2( spdy_util_.ConstructSpdyGet(NULL, 0, false, 3, MEDIUM, true)); MockWrite writes[] = { CreateMockWrite(*req1, 0), CreateMockWrite(*req2, 1), }; DeterministicSocketData data(reads, arraysize(reads), writes, arraysize(writes)); data.set_connect_data(connect_data); session_deps_.deterministic_socket_factory->AddSocketDataProvider(&data); CreateDeterministicNetworkSession(); base::WeakPtr
session = CreateInsecureSpdySession(http_session_, key_, BoundNetLog()); EXPECT_EQ(spdy_util_.spdy_version(), session->GetProtocolVersion()); GURL url(kDefaultURL); base::WeakPtr
spdy_stream1 = CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session, url, MEDIUM, BoundNetLog()); test::StreamDelegateDoNothing delegate1(spdy_stream1); spdy_stream1->SetDelegate(&delegate1); base::WeakPtr
spdy_stream2 = CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session, url, MEDIUM, BoundNetLog()); test::StreamDelegateDoNothing delegate2(spdy_stream2); spdy_stream2->SetDelegate(&delegate2); scoped_ptr
headers( spdy_util_.ConstructGetHeaderBlock(url.spec())); scoped_ptr
headers2(new SpdyHeaderBlock(*headers)); spdy_stream1->SendRequestHeaders(headers.Pass(), NO_MORE_DATA_TO_SEND); EXPECT_TRUE(spdy_stream1->HasUrlFromHeaders()); spdy_stream2->SendRequestHeaders(headers2.Pass(), NO_MORE_DATA_TO_SEND); EXPECT_TRUE(spdy_stream2->HasUrlFromHeaders()); data.RunFor(2); EXPECT_EQ(1u, spdy_stream1->stream_id()); EXPECT_EQ(3u, spdy_stream2->stream_id()); EXPECT_TRUE(HasSpdySession(spdy_session_pool_, key_)); // Read and process the GOAWAY frame. data.RunFor(1); EXPECT_FALSE(HasSpdySession(spdy_session_pool_, key_)); EXPECT_FALSE(session->IsStreamActive(3)); EXPECT_EQ(NULL, spdy_stream2.get()); EXPECT_TRUE(session->IsStreamActive(1)); EXPECT_TRUE(session->IsGoingAway()); // Should close the session. spdy_stream1->Close(); EXPECT_EQ(NULL, spdy_stream1.get()); base::MessageLoop::current()->RunUntilIdle(); EXPECT_TRUE(session == NULL); } // Have a session receive two GOAWAY frames, with the last one causing // the last active stream to be closed. The session should then be // closed after the second GOAWAY frame. TEST_P(SpdySessionTest, GoAwayTwice) { session_deps_.host_resolver->set_synchronous_mode(true); MockConnect connect_data(SYNCHRONOUS, OK); scoped_ptr
goaway1(spdy_util_.ConstructSpdyGoAway(1)); scoped_ptr
goaway2(spdy_util_.ConstructSpdyGoAway(0)); MockRead reads[] = { CreateMockRead(*goaway1, 2), CreateMockRead(*goaway2, 3), MockRead(ASYNC, 0, 4) // EOF }; scoped_ptr
req1( spdy_util_.ConstructSpdyGet(NULL, 0, false, 1, MEDIUM, true)); scoped_ptr
req2( spdy_util_.ConstructSpdyGet(NULL, 0, false, 3, MEDIUM, true)); MockWrite writes[] = { CreateMockWrite(*req1, 0), CreateMockWrite(*req2, 1), }; DeterministicSocketData data(reads, arraysize(reads), writes, arraysize(writes)); data.set_connect_data(connect_data); session_deps_.deterministic_socket_factory->AddSocketDataProvider(&data); CreateDeterministicNetworkSession(); base::WeakPtr
session = CreateInsecureSpdySession(http_session_, key_, BoundNetLog()); EXPECT_EQ(spdy_util_.spdy_version(), session->GetProtocolVersion()); GURL url(kDefaultURL); base::WeakPtr
spdy_stream1 = CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session, url, MEDIUM, BoundNetLog()); test::StreamDelegateDoNothing delegate1(spdy_stream1); spdy_stream1->SetDelegate(&delegate1); base::WeakPtr
spdy_stream2 = CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session, url, MEDIUM, BoundNetLog()); test::StreamDelegateDoNothing delegate2(spdy_stream2); spdy_stream2->SetDelegate(&delegate2); scoped_ptr
headers( spdy_util_.ConstructGetHeaderBlock(url.spec())); scoped_ptr
headers2(new SpdyHeaderBlock(*headers)); spdy_stream1->SendRequestHeaders(headers.Pass(), NO_MORE_DATA_TO_SEND); EXPECT_TRUE(spdy_stream1->HasUrlFromHeaders()); spdy_stream2->SendRequestHeaders(headers2.Pass(), NO_MORE_DATA_TO_SEND); EXPECT_TRUE(spdy_stream2->HasUrlFromHeaders()); data.RunFor(2); EXPECT_EQ(1u, spdy_stream1->stream_id()); EXPECT_EQ(3u, spdy_stream2->stream_id()); EXPECT_TRUE(HasSpdySession(spdy_session_pool_, key_)); // Read and process the first GOAWAY frame. data.RunFor(1); EXPECT_FALSE(HasSpdySession(spdy_session_pool_, key_)); EXPECT_FALSE(session->IsStreamActive(3)); EXPECT_EQ(NULL, spdy_stream2.get()); EXPECT_TRUE(session->IsStreamActive(1)); EXPECT_TRUE(session->IsGoingAway()); // Read and process the second GOAWAY frame, which should close the // session. data.RunFor(1); base::MessageLoop::current()->RunUntilIdle(); EXPECT_TRUE(session == NULL); } // Have a session with active streams receive a GOAWAY frame and then // close it. It should handle the close properly (i.e., not try to // make itself unavailable in its pool twice). TEST_P(SpdySessionTest, GoAwayWithActiveStreamsThenClose) { session_deps_.host_resolver->set_synchronous_mode(true); MockConnect connect_data(SYNCHRONOUS, OK); scoped_ptr
goaway(spdy_util_.ConstructSpdyGoAway(1)); MockRead reads[] = { CreateMockRead(*goaway, 2), MockRead(ASYNC, 0, 3) // EOF }; scoped_ptr
req1( spdy_util_.ConstructSpdyGet(NULL, 0, false, 1, MEDIUM, true)); scoped_ptr
req2( spdy_util_.ConstructSpdyGet(NULL, 0, false, 3, MEDIUM, true)); MockWrite writes[] = { CreateMockWrite(*req1, 0), CreateMockWrite(*req2, 1), }; DeterministicSocketData data(reads, arraysize(reads), writes, arraysize(writes)); data.set_connect_data(connect_data); session_deps_.deterministic_socket_factory->AddSocketDataProvider(&data); CreateDeterministicNetworkSession(); base::WeakPtr
session = CreateInsecureSpdySession(http_session_, key_, BoundNetLog()); EXPECT_EQ(spdy_util_.spdy_version(), session->GetProtocolVersion()); GURL url(kDefaultURL); base::WeakPtr
spdy_stream1 = CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session, url, MEDIUM, BoundNetLog()); test::StreamDelegateDoNothing delegate1(spdy_stream1); spdy_stream1->SetDelegate(&delegate1); base::WeakPtr
spdy_stream2 = CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session, url, MEDIUM, BoundNetLog()); test::StreamDelegateDoNothing delegate2(spdy_stream2); spdy_stream2->SetDelegate(&delegate2); scoped_ptr
headers( spdy_util_.ConstructGetHeaderBlock(url.spec())); scoped_ptr
headers2(new SpdyHeaderBlock(*headers)); spdy_stream1->SendRequestHeaders(headers.Pass(), NO_MORE_DATA_TO_SEND); EXPECT_TRUE(spdy_stream1->HasUrlFromHeaders()); spdy_stream2->SendRequestHeaders(headers2.Pass(), NO_MORE_DATA_TO_SEND); EXPECT_TRUE(spdy_stream2->HasUrlFromHeaders()); data.RunFor(2); EXPECT_EQ(1u, spdy_stream1->stream_id()); EXPECT_EQ(3u, spdy_stream2->stream_id()); EXPECT_TRUE(HasSpdySession(spdy_session_pool_, key_)); // Read and process the GOAWAY frame. data.RunFor(1); EXPECT_FALSE(HasSpdySession(spdy_session_pool_, key_)); EXPECT_FALSE(session->IsStreamActive(3)); EXPECT_EQ(NULL, spdy_stream2.get()); EXPECT_TRUE(session->IsStreamActive(1)); EXPECT_TRUE(session->IsGoingAway()); session->CloseSessionOnError(ERR_ABORTED, "Aborting session"); EXPECT_EQ(NULL, spdy_stream1.get()); base::MessageLoop::current()->RunUntilIdle(); EXPECT_TRUE(session == NULL); } // Process a joint read buffer which causes the session to begin draining, and // then processes a GOAWAY. The session should gracefully drain. Regression test // for crbug.com/379469 TEST_P(SpdySessionTest, GoAwayWhileDraining) { session_deps_.host_resolver->set_synchronous_mode(true); scoped_ptr
req( spdy_util_.ConstructSpdyGet(NULL, 0, false, 1, MEDIUM, true)); MockWrite writes[] = { CreateMockWrite(*req, 0), }; scoped_ptr
resp(spdy_util_.ConstructSpdyGetSynReply(NULL, 0, 1)); scoped_ptr
goaway(spdy_util_.ConstructSpdyGoAway(1)); scoped_ptr
body(spdy_util_.ConstructSpdyBodyFrame(1, true)); size_t joint_size = goaway->size() * 2 + body->size(); // Compose interleaved |goaway| and |body| frames into a single read. scoped_ptr
buffer(new char[joint_size]); { size_t out = 0; memcpy(&buffer[out], goaway->data(), goaway->size()); out += goaway->size(); memcpy(&buffer[out], body->data(), body->size()); out += body->size(); memcpy(&buffer[out], goaway->data(), goaway->size()); out += goaway->size(); ASSERT_EQ(out, joint_size); } SpdyFrame joint_frames(buffer.get(), joint_size, false); MockRead reads[] = { CreateMockRead(*resp, 1), CreateMockRead(joint_frames, 2), MockRead(ASYNC, 0, 3) // EOF }; MockConnect connect_data(SYNCHRONOUS, OK); DeterministicSocketData data( reads, arraysize(reads), writes, arraysize(writes)); data.set_connect_data(connect_data); session_deps_.deterministic_socket_factory->AddSocketDataProvider(&data); CreateDeterministicNetworkSession(); base::WeakPtr
session = CreateInsecureSpdySession(http_session_, key_, BoundNetLog()); GURL url(kDefaultURL); base::WeakPtr
spdy_stream = CreateStreamSynchronously( SPDY_REQUEST_RESPONSE_STREAM, session, url, MEDIUM, BoundNetLog()); test::StreamDelegateDoNothing delegate(spdy_stream); spdy_stream->SetDelegate(&delegate); scoped_ptr
headers( spdy_util_.ConstructGetHeaderBlock(url.spec())); spdy_stream->SendRequestHeaders(headers.Pass(), NO_MORE_DATA_TO_SEND); EXPECT_TRUE(spdy_stream->HasUrlFromHeaders()); data.RunFor(3); base::MessageLoop::current()->RunUntilIdle(); // Stream and session closed gracefully. EXPECT_TRUE(delegate.StreamIsClosed()); EXPECT_EQ(OK, delegate.WaitForClose()); EXPECT_EQ(kUploadData, delegate.TakeReceivedData()); EXPECT_TRUE(session == NULL); } // Try to create a stream after receiving a GOAWAY frame. It should // fail. TEST_P(SpdySessionTest, CreateStreamAfterGoAway) { session_deps_.host_resolver->set_synchronous_mode(true); MockConnect connect_data(SYNCHRONOUS, OK); scoped_ptr
goaway(spdy_util_.ConstructSpdyGoAway(1)); MockRead reads[] = { CreateMockRead(*goaway, 1), MockRead(ASYNC, 0, 2) // EOF }; scoped_ptr
req( spdy_util_.ConstructSpdyGet(NULL, 0, false, 1, MEDIUM, true)); MockWrite writes[] = { CreateMockWrite(*req, 0), }; DeterministicSocketData data(reads, arraysize(reads), writes, arraysize(writes)); data.set_connect_data(connect_data); session_deps_.deterministic_socket_factory->AddSocketDataProvider(&data); CreateDeterministicNetworkSession(); base::WeakPtr
session = CreateInsecureSpdySession(http_session_, key_, BoundNetLog()); EXPECT_EQ(spdy_util_.spdy_version(), session->GetProtocolVersion()); GURL url(kDefaultURL); base::WeakPtr
spdy_stream = CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session, url, MEDIUM, BoundNetLog()); test::StreamDelegateDoNothing delegate(spdy_stream); spdy_stream->SetDelegate(&delegate); scoped_ptr
headers( spdy_util_.ConstructGetHeaderBlock(url.spec())); spdy_stream->SendRequestHeaders(headers.Pass(), NO_MORE_DATA_TO_SEND); EXPECT_TRUE(spdy_stream->HasUrlFromHeaders()); data.RunFor(1); EXPECT_EQ(1u, spdy_stream->stream_id()); EXPECT_TRUE(HasSpdySession(spdy_session_pool_, key_)); // Read and process the GOAWAY frame. data.RunFor(1); EXPECT_FALSE(HasSpdySession(spdy_session_pool_, key_)); EXPECT_TRUE(session->IsStreamActive(1)); SpdyStreamRequest stream_request; int rv = stream_request.StartRequest( SPDY_REQUEST_RESPONSE_STREAM, session, url, MEDIUM, BoundNetLog(), CompletionCallback()); EXPECT_EQ(ERR_FAILED, rv); // Read and process EOF. data.RunFor(1); EXPECT_TRUE(session == NULL); } // Receiving a SYN_STREAM frame after a GOAWAY frame should result in // the stream being refused. TEST_P(SpdySessionTest, SynStreamAfterGoAway) { session_deps_.host_resolver->set_synchronous_mode(true); MockConnect connect_data(SYNCHRONOUS, OK); scoped_ptr
goaway(spdy_util_.ConstructSpdyGoAway(1)); scoped_ptr
push(spdy_util_.ConstructSpdyPush(NULL, 0, 2, 1, kDefaultURL)); MockRead reads[] = { CreateMockRead(*goaway, 1), CreateMockRead(*push, 2), MockRead(ASYNC, 0, 4) // EOF }; scoped_ptr
req( spdy_util_.ConstructSpdyGet(NULL, 0, false, 1, MEDIUM, true)); scoped_ptr
rst( spdy_util_.ConstructSpdyRstStream(2, RST_STREAM_REFUSED_STREAM)); MockWrite writes[] = { CreateMockWrite(*req, 0), CreateMockWrite(*rst, 3) }; DeterministicSocketData data(reads, arraysize(reads), writes, arraysize(writes)); data.set_connect_data(connect_data); session_deps_.deterministic_socket_factory->AddSocketDataProvider(&data); CreateDeterministicNetworkSession(); base::WeakPtr
session = CreateInsecureSpdySession(http_session_, key_, BoundNetLog()); EXPECT_EQ(spdy_util_.spdy_version(), session->GetProtocolVersion()); GURL url(kDefaultURL); base::WeakPtr
spdy_stream = CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session, url, MEDIUM, BoundNetLog()); test::StreamDelegateDoNothing delegate(spdy_stream); spdy_stream->SetDelegate(&delegate); scoped_ptr
headers( spdy_util_.ConstructGetHeaderBlock(url.spec())); spdy_stream->SendRequestHeaders(headers.Pass(), NO_MORE_DATA_TO_SEND); EXPECT_TRUE(spdy_stream->HasUrlFromHeaders()); data.RunFor(1); EXPECT_EQ(1u, spdy_stream->stream_id()); EXPECT_TRUE(HasSpdySession(spdy_session_pool_, key_)); // Read and process the GOAWAY frame. data.RunFor(1); EXPECT_FALSE(HasSpdySession(spdy_session_pool_, key_)); EXPECT_TRUE(session->IsStreamActive(1)); // Read and process the SYN_STREAM frame, the subsequent RST_STREAM, // and EOF. data.RunFor(3); base::MessageLoop::current()->RunUntilIdle(); EXPECT_TRUE(session == NULL); } // A session observing a network change with active streams should close // when the last active stream is closed. TEST_P(SpdySessionTest, NetworkChangeWithActiveStreams) { session_deps_.host_resolver->set_synchronous_mode(true); MockConnect connect_data(SYNCHRONOUS, OK); MockRead reads[] = { MockRead(ASYNC, 0, 1) // EOF }; scoped_ptr
req1( spdy_util_.ConstructSpdyGet(NULL, 0, false, 1, MEDIUM, true)); MockWrite writes[] = { CreateMockWrite(*req1, 0), }; DeterministicSocketData data(reads, arraysize(reads), writes, arraysize(writes)); data.set_connect_data(connect_data); session_deps_.deterministic_socket_factory->AddSocketDataProvider(&data); CreateDeterministicNetworkSession(); base::WeakPtr
session = CreateInsecureSpdySession(http_session_, key_, BoundNetLog()); EXPECT_EQ(spdy_util_.spdy_version(), session->GetProtocolVersion()); base::WeakPtr
spdy_stream = CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session, GURL(kDefaultURL), MEDIUM, BoundNetLog()); test::StreamDelegateDoNothing delegate(spdy_stream); spdy_stream->SetDelegate(&delegate); scoped_ptr
headers( spdy_util_.ConstructGetHeaderBlock(kDefaultURL)); spdy_stream->SendRequestHeaders(headers.Pass(), NO_MORE_DATA_TO_SEND); EXPECT_TRUE(spdy_stream->HasUrlFromHeaders()); data.RunFor(1); EXPECT_EQ(1u, spdy_stream->stream_id()); EXPECT_TRUE(HasSpdySession(spdy_session_pool_, key_)); spdy_session_pool_->OnIPAddressChanged(); // The SpdySessionPool behavior differs based on how the OSs reacts to // network changes; see comment in SpdySessionPool::OnIPAddressChanged(). #if defined(OS_ANDROID) || defined(OS_WIN) || defined(OS_IOS) // For OSs where the TCP connections will close upon relevant network // changes, SpdySessionPool doesn't need to force them to close, so in these // cases verify the session has become unavailable but remains open and the // pre-existing stream is still active. EXPECT_FALSE(HasSpdySession(spdy_session_pool_, key_)); EXPECT_TRUE(session->IsGoingAway()); EXPECT_TRUE(session->IsStreamActive(1)); // Should close the session. spdy_stream->Close(); #endif EXPECT_EQ(NULL, spdy_stream.get()); base::MessageLoop::current()->RunUntilIdle(); EXPECT_TRUE(session == NULL); } TEST_P(SpdySessionTest, ClientPing) { session_deps_.enable_ping = true; session_deps_.host_resolver->set_synchronous_mode(true); MockConnect connect_data(SYNCHRONOUS, OK); scoped_ptr
read_ping(spdy_util_.ConstructSpdyPing(1, true)); MockRead reads[] = { CreateMockRead(*read_ping, 1), MockRead(ASYNC, 0, 0, 2) // EOF }; scoped_ptr
write_ping(spdy_util_.ConstructSpdyPing(1, false)); MockWrite writes[] = { CreateMockWrite(*write_ping, 0), }; DeterministicSocketData data( reads, arraysize(reads), writes, arraysize(writes)); data.set_connect_data(connect_data); session_deps_.deterministic_socket_factory->AddSocketDataProvider(&data); CreateDeterministicNetworkSession(); base::WeakPtr
session = CreateInsecureSpdySession(http_session_, key_, BoundNetLog()); base::WeakPtr
spdy_stream1 = CreateStreamSynchronously(SPDY_BIDIRECTIONAL_STREAM, session, test_url_, MEDIUM, BoundNetLog()); ASSERT_TRUE(spdy_stream1.get() != NULL); test::StreamDelegateSendImmediate delegate(spdy_stream1, NULL); spdy_stream1->SetDelegate(&delegate); base::TimeTicks before_ping_time = base::TimeTicks::Now(); session->set_connection_at_risk_of_loss_time( base::TimeDelta::FromSeconds(-1)); session->set_hung_interval(base::TimeDelta::FromMilliseconds(50)); session->SendPrefacePingIfNoneInFlight(); data.RunFor(2); session->CheckPingStatus(before_ping_time); EXPECT_EQ(0, session->pings_in_flight()); EXPECT_GE(session->next_ping_id(), static_cast
(1)); EXPECT_FALSE(session->check_ping_status_pending()); EXPECT_GE(session->last_activity_time(), before_ping_time); data.RunFor(1); EXPECT_EQ(ERR_CONNECTION_CLOSED, delegate.WaitForClose()); EXPECT_FALSE(HasSpdySession(spdy_session_pool_, key_)); EXPECT_TRUE(session == NULL); } TEST_P(SpdySessionTest, ServerPing) { session_deps_.host_resolver->set_synchronous_mode(true); MockConnect connect_data(SYNCHRONOUS, OK); scoped_ptr
read_ping(spdy_util_.ConstructSpdyPing(2, false)); MockRead reads[] = { CreateMockRead(*read_ping), MockRead(SYNCHRONOUS, 0, 0) // EOF }; scoped_ptr
write_ping(spdy_util_.ConstructSpdyPing(2, true)); MockWrite writes[] = { CreateMockWrite(*write_ping), }; StaticSocketDataProvider data( reads, arraysize(reads), writes, arraysize(writes)); data.set_connect_data(connect_data); session_deps_.socket_factory->AddSocketDataProvider(&data); CreateNetworkSession(); base::WeakPtr
session = CreateInsecureSpdySession(http_session_, key_, BoundNetLog()); base::WeakPtr
spdy_stream1 = CreateStreamSynchronously(SPDY_BIDIRECTIONAL_STREAM, session, test_url_, MEDIUM, BoundNetLog()); ASSERT_TRUE(spdy_stream1.get() != NULL); test::StreamDelegateSendImmediate delegate(spdy_stream1, NULL); spdy_stream1->SetDelegate(&delegate); // Flush the read completion task. base::MessageLoop::current()->RunUntilIdle(); EXPECT_FALSE(HasSpdySession(spdy_session_pool_, key_)); EXPECT_TRUE(session == NULL); EXPECT_EQ(NULL, spdy_stream1.get()); } // Cause a ping to be sent out while producing a write. The write loop // should handle this properly, i.e. another DoWriteLoop task should // not be posted. This is a regression test for // http://crbug.com/261043 . TEST_P(SpdySessionTest, PingAndWriteLoop) { session_deps_.enable_ping = true; session_deps_.time_func = TheNearFuture; MockConnect connect_data(SYNCHRONOUS, OK); scoped_ptr
write_ping(spdy_util_.ConstructSpdyPing(1, false)); scoped_ptr
req( spdy_util_.ConstructSpdyGet(NULL, 0, false, 1, LOWEST, true)); MockWrite writes[] = { CreateMockWrite(*req, 0), CreateMockWrite(*write_ping, 1), }; MockRead reads[] = { MockRead(ASYNC, 0, 2) // EOF }; session_deps_.host_resolver->set_synchronous_mode(true); DeterministicSocketData data(reads, arraysize(reads), writes, arraysize(writes)); data.set_connect_data(connect_data); session_deps_.deterministic_socket_factory->AddSocketDataProvider(&data); CreateDeterministicNetworkSession(); base::WeakPtr
session = CreateInsecureSpdySession(http_session_, key_, BoundNetLog()); GURL url(kDefaultURL); base::WeakPtr
spdy_stream = CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session, url, LOWEST, BoundNetLog()); test::StreamDelegateDoNothing delegate(spdy_stream); spdy_stream->SetDelegate(&delegate); scoped_ptr
headers( spdy_util_.ConstructGetHeaderBlock(url.spec())); spdy_stream->SendRequestHeaders(headers.Pass(), NO_MORE_DATA_TO_SEND); // Shift time so that a ping will be sent out. g_time_delta = base::TimeDelta::FromSeconds(11); data.RunFor(2); session->CloseSessionOnError(ERR_ABORTED, "Aborting"); } TEST_P(SpdySessionTest, StreamIdSpaceExhausted) { const SpdyStreamId kLastStreamId = 0x7fffffff; session_deps_.host_resolver->set_synchronous_mode(true); // Test setup: |stream_hi_water_mark_| and |max_concurrent_streams_| are // fixed to allow for two stream ID assignments, and three concurrent // streams. Four streams are started, and two are activated. Verify the // session goes away, and that the created (but not activated) and // stalled streams are aborted. Also verify the activated streams complete, // at which point the session closes. scoped_ptr
req1(spdy_util_.ConstructSpdyGet( NULL, 0, false, kLastStreamId - 2, MEDIUM, true)); scoped_ptr
req2( spdy_util_.ConstructSpdyGet(NULL, 0, false, kLastStreamId, MEDIUM, true)); MockWrite writes[] = { CreateMockWrite(*req1, 0), CreateMockWrite(*req2, 1), }; scoped_ptr
resp1( spdy_util_.ConstructSpdyGetSynReply(NULL, 0, kLastStreamId - 2)); scoped_ptr
resp2( spdy_util_.ConstructSpdyGetSynReply(NULL, 0, kLastStreamId)); scoped_ptr
body1( spdy_util_.ConstructSpdyBodyFrame(kLastStreamId - 2, true)); scoped_ptr
body2( spdy_util_.ConstructSpdyBodyFrame(kLastStreamId, true)); MockRead reads[] = { CreateMockRead(*resp1, 2), CreateMockRead(*resp2, 3), CreateMockRead(*body1, 4), CreateMockRead(*body2, 5), MockRead(ASYNC, 0, 6) // EOF }; DeterministicSocketData data( reads, arraysize(reads), writes, arraysize(writes)); MockConnect connect_data(SYNCHRONOUS, OK); data.set_connect_data(connect_data); session_deps_.deterministic_socket_factory->AddSocketDataProvider(&data); CreateDeterministicNetworkSession(); base::WeakPtr
session = CreateInsecureSpdySession(http_session_, key_, BoundNetLog()); // Fix stream_hi_water_mark_ to allow for two stream activations. session->stream_hi_water_mark_ = kLastStreamId - 2; // Fix max_concurrent_streams to allow for three stream creations. session->max_concurrent_streams_ = 3; // Create three streams synchronously, and begin a fourth (which is stalled). GURL url(kDefaultURL); base::WeakPtr
stream1 = CreateStreamSynchronously( SPDY_REQUEST_RESPONSE_STREAM, session, url, MEDIUM, BoundNetLog()); test::StreamDelegateDoNothing delegate1(stream1); stream1->SetDelegate(&delegate1); base::WeakPtr
stream2 = CreateStreamSynchronously( SPDY_REQUEST_RESPONSE_STREAM, session, url, MEDIUM, BoundNetLog()); test::StreamDelegateDoNothing delegate2(stream2); stream2->SetDelegate(&delegate2); base::WeakPtr
stream3 = CreateStreamSynchronously( SPDY_REQUEST_RESPONSE_STREAM, session, url, MEDIUM, BoundNetLog()); test::StreamDelegateDoNothing delegate3(stream3); stream3->SetDelegate(&delegate3); SpdyStreamRequest request4; TestCompletionCallback callback4; EXPECT_EQ(ERR_IO_PENDING, request4.StartRequest(SPDY_REQUEST_RESPONSE_STREAM, session, url, MEDIUM, BoundNetLog(), callback4.callback())); // Streams 1-3 were created. 4th is stalled. No streams are active yet. EXPECT_EQ(0u, session->num_active_streams()); EXPECT_EQ(3u, session->num_created_streams()); EXPECT_EQ(1u, session->pending_create_stream_queue_size(MEDIUM)); // Activate stream 1. One ID remains available. stream1->SendRequestHeaders( scoped_ptr
( spdy_util_.ConstructGetHeaderBlock(url.spec())), NO_MORE_DATA_TO_SEND); data.RunFor(1); EXPECT_EQ(kLastStreamId - 2u, stream1->stream_id()); EXPECT_EQ(1u, session->num_active_streams()); EXPECT_EQ(2u, session->num_created_streams()); EXPECT_EQ(1u, session->pending_create_stream_queue_size(MEDIUM)); // Activate stream 2. ID space is exhausted. stream2->SendRequestHeaders( scoped_ptr
( spdy_util_.ConstructGetHeaderBlock(url.spec())), NO_MORE_DATA_TO_SEND); data.RunFor(1); // Active streams remain active. EXPECT_EQ(kLastStreamId, stream2->stream_id()); EXPECT_EQ(2u, session->num_active_streams()); // Session is going away. Created and stalled streams were aborted. EXPECT_EQ(SpdySession::STATE_GOING_AWAY, session->availability_state_); EXPECT_EQ(ERR_ABORTED, delegate3.WaitForClose()); EXPECT_EQ(ERR_ABORTED, callback4.WaitForResult()); EXPECT_EQ(0u, session->num_created_streams()); EXPECT_EQ(0u, session->pending_create_stream_queue_size(MEDIUM)); // Read responses on remaining active streams. data.RunFor(4); EXPECT_EQ(OK, delegate1.WaitForClose()); EXPECT_EQ(kUploadData, delegate1.TakeReceivedData()); EXPECT_EQ(OK, delegate2.WaitForClose()); EXPECT_EQ(kUploadData, delegate2.TakeReceivedData()); // Session was destroyed. base::MessageLoop::current()->RunUntilIdle(); EXPECT_FALSE(session.get()); } // Verifies that an unstalled pending stream creation racing with a new stream // creation doesn't violate the maximum stream concurrency. Regression test for // crbug.com/373858. TEST_P(SpdySessionTest, UnstallRacesWithStreamCreation) { session_deps_.host_resolver->set_synchronous_mode(true); MockRead reads[] = { MockRead(SYNCHRONOUS, ERR_IO_PENDING) // Stall forever. }; StaticSocketDataProvider data(reads, arraysize(reads), NULL, 0); MockConnect connect_data(SYNCHRONOUS, OK); data.set_connect_data(connect_data); session_deps_.socket_factory->AddSocketDataProvider(&data); CreateNetworkSession(); base::WeakPtr
session = CreateInsecureSpdySession(http_session_, key_, BoundNetLog()); // Fix max_concurrent_streams to allow for one open stream. session->max_concurrent_streams_ = 1; // Create two streams: one synchronously, and one which stalls. GURL url(kDefaultURL); base::WeakPtr
stream1 = CreateStreamSynchronously( SPDY_REQUEST_RESPONSE_STREAM, session, url, MEDIUM, BoundNetLog()); SpdyStreamRequest request2; TestCompletionCallback callback2; EXPECT_EQ(ERR_IO_PENDING, request2.StartRequest(SPDY_REQUEST_RESPONSE_STREAM, session, url, MEDIUM, BoundNetLog(), callback2.callback())); EXPECT_EQ(1u, session->num_created_streams()); EXPECT_EQ(1u, session->pending_create_stream_queue_size(MEDIUM)); // Cancel the first stream. A callback to unstall the second stream was // posted. Don't run it yet. stream1->Cancel(); EXPECT_EQ(0u, session->num_created_streams()); EXPECT_EQ(0u, session->pending_create_stream_queue_size(MEDIUM)); // Create a third stream prior to the second stream's callback. base::WeakPtr
stream3 = CreateStreamSynchronously( SPDY_REQUEST_RESPONSE_STREAM, session, url, MEDIUM, BoundNetLog()); EXPECT_EQ(1u, session->num_created_streams()); EXPECT_EQ(0u, session->pending_create_stream_queue_size(MEDIUM)); // NOW run the message loop. The unstalled stream will re-stall itself. base::MessageLoop::current()->RunUntilIdle(); EXPECT_EQ(1u, session->num_created_streams()); EXPECT_EQ(1u, session->pending_create_stream_queue_size(MEDIUM)); // Cancel the third stream and run the message loop. Verify that the second // stream creation now completes. stream3->Cancel(); base::MessageLoop::current()->RunUntilIdle(); EXPECT_EQ(1u, session->num_created_streams()); EXPECT_EQ(0u, session->pending_create_stream_queue_size(MEDIUM)); EXPECT_EQ(OK, callback2.WaitForResult()); } TEST_P(SpdySessionTest, DeleteExpiredPushStreams) { session_deps_.host_resolver->set_synchronous_mode(true); session_deps_.time_func = TheNearFuture; scoped_ptr
req( spdy_util_.ConstructSpdyGet(NULL, 0, false, 1, MEDIUM, true)); scoped_ptr
rst( spdy_util_.ConstructSpdyRstStream(2, RST_STREAM_REFUSED_STREAM)); scoped_ptr
push_a(spdy_util_.ConstructSpdyPush( NULL, 0, 2, 1, "http://www.google.com/a.dat")); scoped_ptr
push_a_body( spdy_util_.ConstructSpdyBodyFrame(2, false)); scoped_ptr
push_b(spdy_util_.ConstructSpdyPush( NULL, 0, 4, 1, "http://www.google.com/b.dat")); MockWrite writes[] = {CreateMockWrite(*req, 0), CreateMockWrite(*rst, 4)}; MockRead reads[] = { CreateMockRead(*push_a, 1), CreateMockRead(*push_a_body, 2), CreateMockRead(*push_b, 3), MockRead(ASYNC, 0, 5), // EOF }; DeterministicSocketData data( reads, arraysize(reads), writes, arraysize(writes)); MockConnect connect_data(SYNCHRONOUS, OK); data.set_connect_data(connect_data); session_deps_.deterministic_socket_factory->AddSocketDataProvider(&data); CreateDeterministicNetworkSession(); base::WeakPtr
session = CreateInsecureSpdySession(http_session_, key_, BoundNetLog()); // Process the principal request, and the first push stream request & body. GURL url(kDefaultURL); base::WeakPtr
spdy_stream = CreateStreamSynchronously( SPDY_REQUEST_RESPONSE_STREAM, session, url, MEDIUM, BoundNetLog()); test::StreamDelegateDoNothing delegate(spdy_stream); spdy_stream->SetDelegate(&delegate); scoped_ptr
headers( spdy_util_.ConstructGetHeaderBlock(url.spec())); spdy_stream->SendRequestHeaders(headers.Pass(), NO_MORE_DATA_TO_SEND); data.RunFor(3); // Verify that there is one unclaimed push stream. EXPECT_EQ(1u, session->num_unclaimed_pushed_streams()); SpdySession::PushedStreamMap::iterator iter = session->unclaimed_pushed_streams_.find( GURL("http://www.google.com/a.dat")); EXPECT_TRUE(session->unclaimed_pushed_streams_.end() != iter); if (session->flow_control_state_ == SpdySession::FLOW_CONTROL_STREAM_AND_SESSION) { // Unclaimed push body consumed bytes from the session window. EXPECT_EQ(kSpdySessionInitialWindowSize - kUploadDataSize, session->session_recv_window_size_); EXPECT_EQ(0, session->session_unacked_recv_window_bytes_); } // Shift time to expire the push stream. Read the second SYN_STREAM, // and verify a RST_STREAM was written. g_time_delta = base::TimeDelta::FromSeconds(301); data.RunFor(2); // Verify that the second pushed stream evicted the first pushed stream. EXPECT_EQ(1u, session->num_unclaimed_pushed_streams()); iter = session->unclaimed_pushed_streams_.find( GURL("http://www.google.com/b.dat")); EXPECT_TRUE(session->unclaimed_pushed_streams_.end() != iter); if (session->flow_control_state_ == SpdySession::FLOW_CONTROL_STREAM_AND_SESSION) { // Verify that the session window reclaimed the evicted stream body. EXPECT_EQ(kSpdySessionInitialWindowSize, session->session_recv_window_size_); EXPECT_EQ(kUploadDataSize, session->session_unacked_recv_window_bytes_); } // Read and process EOF. data.RunFor(1); base::MessageLoop::current()->RunUntilIdle(); EXPECT_TRUE(session == NULL); } TEST_P(SpdySessionTest, FailedPing) { session_deps_.host_resolver->set_synchronous_mode(true); MockConnect connect_data(SYNCHRONOUS, OK); MockRead reads[] = { MockRead(SYNCHRONOUS, ERR_IO_PENDING) // Stall forever. }; scoped_ptr
write_ping(spdy_util_.ConstructSpdyPing(1, false)); scoped_ptr
goaway( spdy_util_.ConstructSpdyGoAway(0, GOAWAY_PROTOCOL_ERROR, "Failed ping.")); MockWrite writes[] = {CreateMockWrite(*write_ping), CreateMockWrite(*goaway)}; StaticSocketDataProvider data( reads, arraysize(reads), writes, arraysize(writes)); data.set_connect_data(connect_data); session_deps_.socket_factory->AddSocketDataProvider(&data); CreateNetworkSession(); base::WeakPtr
session = CreateInsecureSpdySession(http_session_, key_, BoundNetLog()); base::WeakPtr
spdy_stream1 = CreateStreamSynchronously(SPDY_BIDIRECTIONAL_STREAM, session, test_url_, MEDIUM, BoundNetLog()); ASSERT_TRUE(spdy_stream1.get() != NULL); test::StreamDelegateSendImmediate delegate(spdy_stream1, NULL); spdy_stream1->SetDelegate(&delegate); session->set_connection_at_risk_of_loss_time(base::TimeDelta::FromSeconds(0)); session->set_hung_interval(base::TimeDelta::FromSeconds(0)); // Send a PING frame. session->WritePingFrame(1, false); EXPECT_LT(0, session->pings_in_flight()); EXPECT_GE(session->next_ping_id(), static_cast
(1)); EXPECT_TRUE(session->check_ping_status_pending()); // Assert session is not closed. EXPECT_TRUE(session->IsAvailable()); EXPECT_LT(0u, session->num_active_streams() + session->num_created_streams()); EXPECT_TRUE(HasSpdySession(spdy_session_pool_, key_)); // We set last time we have received any data in 1 sec less than now. // CheckPingStatus will trigger timeout because hung interval is zero. base::TimeTicks now = base::TimeTicks::Now(); session->last_activity_time_ = now - base::TimeDelta::FromSeconds(1); session->CheckPingStatus(now); base::MessageLoop::current()->RunUntilIdle(); EXPECT_TRUE(session == NULL); EXPECT_FALSE(HasSpdySession(spdy_session_pool_, key_)); EXPECT_EQ(NULL, spdy_stream1.get()); } // Request kInitialMaxConcurrentStreams + 1 streams. Receive a // settings frame increasing the max concurrent streams by 1. Make // sure nothing blows up. This is a regression test for // http://crbug.com/57331 . TEST_P(SpdySessionTest, OnSettings) { session_deps_.host_resolver->set_synchronous_mode(true); const SpdySettingsIds kSpdySettingsIds = SETTINGS_MAX_CONCURRENT_STREAMS; SettingsMap new_settings; const uint32 max_concurrent_streams = kInitialMaxConcurrentStreams + 1; new_settings[kSpdySettingsIds] = SettingsFlagsAndValue(SETTINGS_FLAG_NONE, max_concurrent_streams); scoped_ptr
settings_frame( spdy_util_.ConstructSpdySettings(new_settings)); MockRead reads[] = { CreateMockRead(*settings_frame, 0), MockRead(ASYNC, 0, 1), }; scoped_ptr
settings_ack(spdy_util_.ConstructSpdySettingsAck()); MockWrite writes[] = { CreateMockWrite(*settings_ack, 2), }; DeterministicSocketData data(reads, arraysize(reads), writes, arraysize(writes)); MockConnect connect_data(SYNCHRONOUS, OK); data.set_connect_data(connect_data); session_deps_.deterministic_socket_factory->AddSocketDataProvider(&data); CreateDeterministicNetworkSession(); base::WeakPtr
session = CreateInsecureSpdySession(http_session_, key_, BoundNetLog()); // Create the maximum number of concurrent streams. for (size_t i = 0; i < kInitialMaxConcurrentStreams; ++i) { base::WeakPtr
spdy_stream = CreateStreamSynchronously(SPDY_BIDIRECTIONAL_STREAM, session, test_url_, MEDIUM, BoundNetLog()); ASSERT_TRUE(spdy_stream != NULL); } StreamReleaserCallback stream_releaser; SpdyStreamRequest request; ASSERT_EQ(ERR_IO_PENDING, request.StartRequest( SPDY_BIDIRECTIONAL_STREAM, session, test_url_, MEDIUM, BoundNetLog(), stream_releaser.MakeCallback(&request))); data.RunFor(1); EXPECT_EQ(OK, stream_releaser.WaitForResult()); data.RunFor(1); if (spdy_util_.spdy_version() >= SPDY4) { // Allow the SETTINGS+ACK to write, so the session finishes draining. data.RunFor(1); } base::MessageLoop::current()->RunUntilIdle(); EXPECT_TRUE(session == NULL); } // Start with a persisted value for max concurrent streams. Receive a // settings frame increasing the max concurrent streams by 1 and which // also clears the persisted data. Verify that persisted data is // correct. TEST_P(SpdySessionTest, ClearSettings) { if (spdy_util_.spdy_version() >= SPDY4) { // SPDY4 doesn't include settings persistence, or a CLEAR_SETTINGS flag. // Flag 0x1, CLEAR_SETTINGS in SPDY3, is instead settings ACK in SPDY4. return; } session_deps_.host_resolver->set_synchronous_mode(true); SettingsMap new_settings; const uint32 max_concurrent_streams = kInitialMaxConcurrentStreams + 1; new_settings[SETTINGS_MAX_CONCURRENT_STREAMS] = SettingsFlagsAndValue(SETTINGS_FLAG_NONE, max_concurrent_streams); scoped_ptr
settings_frame( spdy_util_.ConstructSpdySettings(new_settings)); uint8 flags = SETTINGS_FLAG_CLEAR_PREVIOUSLY_PERSISTED_SETTINGS; test::SetFrameFlags(settings_frame.get(), flags, spdy_util_.spdy_version()); MockRead reads[] = { CreateMockRead(*settings_frame, 0), MockRead(ASYNC, 0, 1), }; DeterministicSocketData data(reads, arraysize(reads), NULL, 0); MockConnect connect_data(SYNCHRONOUS, OK); data.set_connect_data(connect_data); session_deps_.deterministic_socket_factory->AddSocketDataProvider(&data); CreateDeterministicNetworkSession(); // Initialize the SpdySetting with the default. spdy_session_pool_->http_server_properties()->SetSpdySetting( test_host_port_pair_, SETTINGS_MAX_CONCURRENT_STREAMS, SETTINGS_FLAG_PLEASE_PERSIST, kInitialMaxConcurrentStreams); EXPECT_FALSE( spdy_session_pool_->http_server_properties()->GetSpdySettings( test_host_port_pair_).empty()); base::WeakPtr
session = CreateInsecureSpdySession(http_session_, key_, BoundNetLog()); // Create the maximum number of concurrent streams. for (size_t i = 0; i < kInitialMaxConcurrentStreams; ++i) { base::WeakPtr
spdy_stream = CreateStreamSynchronously(SPDY_BIDIRECTIONAL_STREAM, session, test_url_, MEDIUM, BoundNetLog()); ASSERT_TRUE(spdy_stream != NULL); } StreamReleaserCallback stream_releaser; SpdyStreamRequest request; ASSERT_EQ(ERR_IO_PENDING, request.StartRequest( SPDY_BIDIRECTIONAL_STREAM, session, test_url_, MEDIUM, BoundNetLog(), stream_releaser.MakeCallback(&request))); data.RunFor(1); EXPECT_EQ(OK, stream_releaser.WaitForResult()); // Make sure that persisted data is cleared. EXPECT_TRUE( spdy_session_pool_->http_server_properties()->GetSpdySettings( test_host_port_pair_).empty()); // Make sure session's max_concurrent_streams is correct. EXPECT_EQ(kInitialMaxConcurrentStreams + 1, session->max_concurrent_streams()); data.RunFor(1); EXPECT_TRUE(session == NULL); } // Start with max concurrent streams set to 1. Request two streams. // When the first completes, have the callback close its stream, which // should trigger the second stream creation. Then cancel that one // immediately. Don't crash. This is a regression test for // http://crbug.com/63532 . TEST_P(SpdySessionTest, CancelPendingCreateStream) { session_deps_.host_resolver->set_synchronous_mode(true); MockRead reads[] = { MockRead(SYNCHRONOUS, ERR_IO_PENDING) // Stall forever. }; StaticSocketDataProvider data(reads, arraysize(reads), NULL, 0); MockConnect connect_data(SYNCHRONOUS, OK); data.set_connect_data(connect_data); session_deps_.socket_factory->AddSocketDataProvider(&data); CreateNetworkSession(); // Initialize the SpdySetting with 1 max concurrent streams. spdy_session_pool_->http_server_properties()->SetSpdySetting( test_host_port_pair_, SETTINGS_MAX_CONCURRENT_STREAMS, SETTINGS_FLAG_PLEASE_PERSIST, 1); base::WeakPtr
session = CreateInsecureSpdySession(http_session_, key_, BoundNetLog()); // Leave room for only one more stream to be created. for (size_t i = 0; i < kInitialMaxConcurrentStreams - 1; ++i) { base::WeakPtr
spdy_stream = CreateStreamSynchronously(SPDY_BIDIRECTIONAL_STREAM, session, test_url_, MEDIUM, BoundNetLog()); ASSERT_TRUE(spdy_stream != NULL); } // Create 2 more streams. First will succeed. Second will be pending. base::WeakPtr
spdy_stream1 = CreateStreamSynchronously(SPDY_BIDIRECTIONAL_STREAM, session, test_url_, MEDIUM, BoundNetLog()); ASSERT_TRUE(spdy_stream1.get() != NULL); // Use scoped_ptr to let us invalidate the memory when we want to, to trigger // a valgrind error if the callback is invoked when it's not supposed to be. scoped_ptr
callback(new TestCompletionCallback); SpdyStreamRequest request; ASSERT_EQ(ERR_IO_PENDING, request.StartRequest( SPDY_BIDIRECTIONAL_STREAM, session, test_url_, MEDIUM, BoundNetLog(), callback->callback())); // Release the first one, this will allow the second to be created. spdy_stream1->Cancel(); EXPECT_EQ(NULL, spdy_stream1.get()); request.CancelRequest(); callback.reset(); // Should not crash when running the pending callback. base::MessageLoop::current()->RunUntilIdle(); } TEST_P(SpdySessionTest, SendInitialDataOnNewSession) { session_deps_.host_resolver->set_synchronous_mode(true); MockRead reads[] = { MockRead(SYNCHRONOUS, ERR_IO_PENDING) // Stall forever. }; SettingsMap settings; const SpdySettingsIds kSpdySettingsIds1 = SETTINGS_MAX_CONCURRENT_STREAMS; const SpdySettingsIds kSpdySettingsIds2 = SETTINGS_INITIAL_WINDOW_SIZE; const uint32 kInitialRecvWindowSize = 10 * 1024 * 1024; settings[kSpdySettingsIds1] = SettingsFlagsAndValue(SETTINGS_FLAG_NONE, kMaxConcurrentPushedStreams); if (spdy_util_.spdy_version() >= SPDY3) { settings[kSpdySettingsIds2] = SettingsFlagsAndValue(SETTINGS_FLAG_NONE, kInitialRecvWindowSize); } MockConnect connect_data(SYNCHRONOUS, OK); scoped_ptr
settings_frame( spdy_util_.ConstructSpdySettings(settings)); scoped_ptr
initial_window_update( spdy_util_.ConstructSpdyWindowUpdate( kSessionFlowControlStreamId, kDefaultInitialRecvWindowSize - kSpdySessionInitialWindowSize)); std::vector
writes; if (GetParam() == kProtoSPDY4) { writes.push_back( MockWrite(ASYNC, kHttp2ConnectionHeaderPrefix, kHttp2ConnectionHeaderPrefixSize)); } writes.push_back(CreateMockWrite(*settings_frame)); if (GetParam() >= kProtoSPDY31) { writes.push_back(CreateMockWrite(*initial_window_update)); }; SettingsMap server_settings; const uint32 initial_max_concurrent_streams = 1; server_settings[SETTINGS_MAX_CONCURRENT_STREAMS] = SettingsFlagsAndValue(SETTINGS_FLAG_PERSISTED, initial_max_concurrent_streams); scoped_ptr
server_settings_frame( spdy_util_.ConstructSpdySettings(server_settings)); writes.push_back(CreateMockWrite(*server_settings_frame)); session_deps_.stream_initial_recv_window_size = kInitialRecvWindowSize; StaticSocketDataProvider data(reads, arraysize(reads), vector_as_array(&writes), writes.size()); data.set_connect_data(connect_data); session_deps_.socket_factory->AddSocketDataProvider(&data); CreateNetworkSession(); spdy_session_pool_->http_server_properties()->SetSpdySetting( test_host_port_pair_, SETTINGS_MAX_CONCURRENT_STREAMS, SETTINGS_FLAG_PLEASE_PERSIST, initial_max_concurrent_streams); SpdySessionPoolPeer pool_peer(spdy_session_pool_); pool_peer.SetEnableSendingInitialData(true); base::WeakPtr
session = CreateInsecureSpdySession(http_session_, key_, BoundNetLog()); base::MessageLoop::current()->RunUntilIdle(); EXPECT_TRUE(data.at_write_eof()); } TEST_P(SpdySessionTest, ClearSettingsStorageOnIPAddressChanged) { CreateNetworkSession(); base::WeakPtr
test_http_server_properties = spdy_session_pool_->http_server_properties(); SettingsFlagsAndValue flags_and_value1(SETTINGS_FLAG_PLEASE_PERSIST, 2); test_http_server_properties->SetSpdySetting( test_host_port_pair_, SETTINGS_MAX_CONCURRENT_STREAMS, SETTINGS_FLAG_PLEASE_PERSIST, 2); EXPECT_NE(0u, test_http_server_properties->GetSpdySettings( test_host_port_pair_).size()); spdy_session_pool_->OnIPAddressChanged(); EXPECT_EQ(0u, test_http_server_properties->GetSpdySettings( test_host_port_pair_).size()); } TEST_P(SpdySessionTest, Initialize) { CapturingBoundNetLog log; session_deps_.net_log = log.bound().net_log(); session_deps_.host_resolver->set_synchronous_mode(true); MockConnect connect_data(SYNCHRONOUS, OK); MockRead reads[] = { MockRead(ASYNC, 0, 0) // EOF }; StaticSocketDataProvider data(reads, arraysize(reads), NULL, 0); data.set_connect_data(connect_data); session_deps_.socket_factory->AddSocketDataProvider(&data); CreateNetworkSession(); base::WeakPtr
session = CreateInsecureSpdySession(http_session_, key_, log.bound()); EXPECT_TRUE(HasSpdySession(spdy_session_pool_, key_)); // Flush the read completion task. base::MessageLoop::current()->RunUntilIdle(); net::CapturingNetLog::CapturedEntryList entries; log.GetEntries(&entries); EXPECT_LT(0u, entries.size()); // Check that we logged TYPE_SPDY_SESSION_INITIALIZED correctly. int pos = net::ExpectLogContainsSomewhere( entries, 0, net::NetLog::TYPE_SPDY_SESSION_INITIALIZED, net::NetLog::PHASE_NONE); EXPECT_LT(0, pos); CapturingNetLog::CapturedEntry entry = entries[pos]; NetLog::Source socket_source; EXPECT_TRUE(NetLog::Source::FromEventParameters(entry.params.get(), &socket_source)); EXPECT_TRUE(socket_source.IsValid()); EXPECT_NE(log.bound().source().id, socket_source.id); } TEST_P(SpdySessionTest, NetLogOnSessionGoaway) { session_deps_.host_resolver->set_synchronous_mode(true); MockConnect connect_data(SYNCHRONOUS, OK); scoped_ptr
goaway(spdy_util_.ConstructSpdyGoAway()); MockRead reads[] = { CreateMockRead(*goaway), MockRead(SYNCHRONOUS, 0, 0) // EOF }; StaticSocketDataProvider data(reads, arraysize(reads), NULL, 0); data.set_connect_data(connect_data); session_deps_.socket_factory->AddSocketDataProvider(&data); CreateNetworkSession(); CapturingBoundNetLog log; base::WeakPtr
session = CreateInsecureSpdySession(http_session_, key_, log.bound()); EXPECT_TRUE(HasSpdySession(spdy_session_pool_, key_)); // Flush the read completion task. base::MessageLoop::current()->RunUntilIdle(); EXPECT_FALSE(HasSpdySession(spdy_session_pool_, key_)); EXPECT_TRUE(session == NULL); // Check that the NetLog was filled reasonably. net::CapturingNetLog::CapturedEntryList entries; log.GetEntries(&entries); EXPECT_LT(0u, entries.size()); // Check that we logged SPDY_SESSION_CLOSE correctly. int pos = net::ExpectLogContainsSomewhere( entries, 0, net::NetLog::TYPE_SPDY_SESSION_CLOSE, net::NetLog::PHASE_NONE); if (pos < static_cast
(entries.size())) { CapturingNetLog::CapturedEntry entry = entries[pos]; int error_code = 0; ASSERT_TRUE(entry.GetNetErrorCode(&error_code)); EXPECT_EQ(OK, error_code); } else { ADD_FAILURE(); } } TEST_P(SpdySessionTest, NetLogOnSessionEOF) { session_deps_.host_resolver->set_synchronous_mode(true); MockConnect connect_data(SYNCHRONOUS, OK); MockRead reads[] = { MockRead(SYNCHRONOUS, 0, 0) // EOF }; StaticSocketDataProvider data(reads, arraysize(reads), NULL, 0); data.set_connect_data(connect_data); session_deps_.socket_factory->AddSocketDataProvider(&data); CreateNetworkSession(); CapturingBoundNetLog log; base::WeakPtr
session = CreateInsecureSpdySession(http_session_, key_, log.bound()); EXPECT_TRUE(HasSpdySession(spdy_session_pool_, key_)); // Flush the read completion task. base::MessageLoop::current()->RunUntilIdle(); EXPECT_FALSE(HasSpdySession(spdy_session_pool_, key_)); EXPECT_TRUE(session == NULL); // Check that the NetLog was filled reasonably. net::CapturingNetLog::CapturedEntryList entries; log.GetEntries(&entries); EXPECT_LT(0u, entries.size()); // Check that we logged SPDY_SESSION_CLOSE correctly. int pos = net::ExpectLogContainsSomewhere(entries, 0, net::NetLog::TYPE_SPDY_SESSION_CLOSE, net::NetLog::PHASE_NONE); if (pos < static_cast
(entries.size())) { CapturingNetLog::CapturedEntry entry = entries[pos]; int error_code = 0; ASSERT_TRUE(entry.GetNetErrorCode(&error_code)); EXPECT_EQ(ERR_CONNECTION_CLOSED, error_code); } else { ADD_FAILURE(); } } // Queue up a low-priority SYN_STREAM followed by a high-priority // one. The high priority one should still send first and receive // first. TEST_P(SpdySessionTest, OutOfOrderSynStreams) { // Construct the request. MockConnect connect_data(SYNCHRONOUS, OK); scoped_ptr
req_highest( spdy_util_.ConstructSpdyGet(NULL, 0, false, 1, HIGHEST, true)); scoped_ptr
req_lowest( spdy_util_.ConstructSpdyGet(NULL, 0, false, 3, LOWEST, true)); MockWrite writes[] = { CreateMockWrite(*req_highest, 0), CreateMockWrite(*req_lowest, 1), }; scoped_ptr
resp_highest( spdy_util_.ConstructSpdyGetSynReply(NULL, 0, 1)); scoped_ptr
body_highest( spdy_util_.ConstructSpdyBodyFrame(1, true)); scoped_ptr
resp_lowest( spdy_util_.ConstructSpdyGetSynReply(NULL, 0, 3)); scoped_ptr
body_lowest( spdy_util_.ConstructSpdyBodyFrame(3, true)); MockRead reads[] = { CreateMockRead(*resp_highest, 2), CreateMockRead(*body_highest, 3), CreateMockRead(*resp_lowest, 4), CreateMockRead(*body_lowest, 5), MockRead(ASYNC, 0, 6) // EOF }; session_deps_.host_resolver->set_synchronous_mode(true); DeterministicSocketData data(reads, arraysize(reads), writes, arraysize(writes)); data.set_connect_data(connect_data); session_deps_.deterministic_socket_factory->AddSocketDataProvider(&data); CreateDeterministicNetworkSession(); base::WeakPtr
session = CreateInsecureSpdySession(http_session_, key_, BoundNetLog()); GURL url(kDefaultURL); base::WeakPtr
spdy_stream_lowest = CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session, url, LOWEST, BoundNetLog()); ASSERT_TRUE(spdy_stream_lowest); EXPECT_EQ(0u, spdy_stream_lowest->stream_id()); test::StreamDelegateDoNothing delegate_lowest(spdy_stream_lowest); spdy_stream_lowest->SetDelegate(&delegate_lowest); base::WeakPtr
spdy_stream_highest = CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session, url, HIGHEST, BoundNetLog()); ASSERT_TRUE(spdy_stream_highest); EXPECT_EQ(0u, spdy_stream_highest->stream_id()); test::StreamDelegateDoNothing delegate_highest(spdy_stream_highest); spdy_stream_highest->SetDelegate(&delegate_highest); // Queue the lower priority one first. scoped_ptr
headers_lowest( spdy_util_.ConstructGetHeaderBlock(url.spec())); spdy_stream_lowest->SendRequestHeaders( headers_lowest.Pass(), NO_MORE_DATA_TO_SEND); EXPECT_TRUE(spdy_stream_lowest->HasUrlFromHeaders()); scoped_ptr
headers_highest( spdy_util_.ConstructGetHeaderBlock(url.spec())); spdy_stream_highest->SendRequestHeaders( headers_highest.Pass(), NO_MORE_DATA_TO_SEND); EXPECT_TRUE(spdy_stream_highest->HasUrlFromHeaders()); data.RunFor(7); EXPECT_FALSE(spdy_stream_lowest); EXPECT_FALSE(spdy_stream_highest); EXPECT_EQ(3u, delegate_lowest.stream_id()); EXPECT_EQ(1u, delegate_highest.stream_id()); } TEST_P(SpdySessionTest, CancelStream) { MockConnect connect_data(SYNCHRONOUS, OK); // Request 1, at HIGHEST priority, will be cancelled before it writes data. // Request 2, at LOWEST priority, will be a full request and will be id 1. scoped_ptr
req2( spdy_util_.ConstructSpdyGet(NULL, 0, false, 1, LOWEST, true)); MockWrite writes[] = { CreateMockWrite(*req2, 0), }; scoped_ptr
resp2(spdy_util_.ConstructSpdyGetSynReply(NULL, 0, 1)); scoped_ptr
body2(spdy_util_.ConstructSpdyBodyFrame(1, true)); MockRead reads[] = { CreateMockRead(*resp2, 1), CreateMockRead(*body2, 2), MockRead(ASYNC, 0, 3) // EOF }; session_deps_.host_resolver->set_synchronous_mode(true); DeterministicSocketData data(reads, arraysize(reads), writes, arraysize(writes)); data.set_connect_data(connect_data); session_deps_.deterministic_socket_factory->AddSocketDataProvider(&data); CreateDeterministicNetworkSession(); base::WeakPtr
session = CreateInsecureSpdySession(http_session_, key_, BoundNetLog()); GURL url1(kDefaultURL); base::WeakPtr
spdy_stream1 = CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session, url1, HIGHEST, BoundNetLog()); ASSERT_TRUE(spdy_stream1.get() != NULL); EXPECT_EQ(0u, spdy_stream1->stream_id()); test::StreamDelegateDoNothing delegate1(spdy_stream1); spdy_stream1->SetDelegate(&delegate1); GURL url2(kDefaultURL); base::WeakPtr
spdy_stream2 = CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session, url2, LOWEST, BoundNetLog()); ASSERT_TRUE(spdy_stream2.get() != NULL); EXPECT_EQ(0u, spdy_stream2->stream_id()); test::StreamDelegateDoNothing delegate2(spdy_stream2); spdy_stream2->SetDelegate(&delegate2); scoped_ptr
headers( spdy_util_.ConstructGetHeaderBlock(url1.spec())); spdy_stream1->SendRequestHeaders(headers.Pass(), NO_MORE_DATA_TO_SEND); EXPECT_TRUE(spdy_stream1->HasUrlFromHeaders()); scoped_ptr
headers2( spdy_util_.ConstructGetHeaderBlock(url2.spec())); spdy_stream2->SendRequestHeaders(headers2.Pass(), NO_MORE_DATA_TO_SEND); EXPECT_TRUE(spdy_stream2->HasUrlFromHeaders()); EXPECT_EQ(0u, spdy_stream1->stream_id()); spdy_stream1->Cancel(); EXPECT_EQ(NULL, spdy_stream1.get()); EXPECT_EQ(0u, delegate1.stream_id()); data.RunFor(1); EXPECT_EQ(0u, delegate1.stream_id()); EXPECT_EQ(1u, delegate2.stream_id()); spdy_stream2->Cancel(); EXPECT_EQ(NULL, spdy_stream2.get()); } // Create two streams that are set to re-close themselves on close, // and then close the session. Nothing should blow up. Also a // regression test for http://crbug.com/139518 . TEST_P(SpdySessionTest, CloseSessionWithTwoCreatedSelfClosingStreams) { session_deps_.host_resolver->set_synchronous_mode(true); MockConnect connect_data(SYNCHRONOUS, OK); // No actual data will be sent. MockWrite writes[] = { MockWrite(ASYNC, 0, 1) // EOF }; MockRead reads[] = { MockRead(ASYNC, 0, 0) // EOF }; DeterministicSocketData data(reads, arraysize(reads), writes, arraysize(writes)); data.set_connect_data(connect_data); session_deps_.deterministic_socket_factory->AddSocketDataProvider(&data); CreateDeterministicNetworkSession(); base::WeakPtr
session = CreateInsecureSpdySession(http_session_, key_, BoundNetLog()); GURL url1(kDefaultURL); base::WeakPtr
spdy_stream1 = CreateStreamSynchronously(SPDY_BIDIRECTIONAL_STREAM, session, url1, HIGHEST, BoundNetLog()); ASSERT_TRUE(spdy_stream1.get() != NULL); EXPECT_EQ(0u, spdy_stream1->stream_id()); GURL url2(kDefaultURL); base::WeakPtr
spdy_stream2 = CreateStreamSynchronously(SPDY_BIDIRECTIONAL_STREAM, session, url2, LOWEST, BoundNetLog()); ASSERT_TRUE(spdy_stream2.get() != NULL); EXPECT_EQ(0u, spdy_stream2->stream_id()); test::ClosingDelegate delegate1(spdy_stream1); spdy_stream1->SetDelegate(&delegate1); test::ClosingDelegate delegate2(spdy_stream2); spdy_stream2->SetDelegate(&delegate2); scoped_ptr
headers( spdy_util_.ConstructGetHeaderBlock(url1.spec())); spdy_stream1->SendRequestHeaders(headers.Pass(), NO_MORE_DATA_TO_SEND); EXPECT_TRUE(spdy_stream1->HasUrlFromHeaders()); scoped_ptr
headers2( spdy_util_.ConstructGetHeaderBlock(url2.spec())); spdy_stream2->SendRequestHeaders(headers2.Pass(), NO_MORE_DATA_TO_SEND); EXPECT_TRUE(spdy_stream2->HasUrlFromHeaders()); // Ensure that the streams have not yet been activated and assigned an id. EXPECT_EQ(0u, spdy_stream1->stream_id()); EXPECT_EQ(0u, spdy_stream2->stream_id()); // Ensure we don't crash while closing the session. session->CloseSessionOnError(ERR_ABORTED, std::string()); EXPECT_EQ(NULL, spdy_stream1.get()); EXPECT_EQ(NULL, spdy_stream2.get()); EXPECT_TRUE(delegate1.StreamIsClosed()); EXPECT_TRUE(delegate2.StreamIsClosed()); base::MessageLoop::current()->RunUntilIdle(); EXPECT_TRUE(session == NULL); } // Create two streams that are set to close each other on close, and // then close the session. Nothing should blow up. TEST_P(SpdySessionTest, CloseSessionWithTwoCreatedMutuallyClosingStreams) { session_deps_.host_resolver->set_synchronous_mode(true); MockConnect connect_data(SYNCHRONOUS, OK); // No actual data will be sent. MockWrite writes[] = { MockWrite(ASYNC, 0, 1) // EOF }; MockRead reads[] = { MockRead(ASYNC, 0, 0) // EOF }; DeterministicSocketData data(reads, arraysize(reads), writes, arraysize(writes)); data.set_connect_data(connect_data); session_deps_.deterministic_socket_factory->AddSocketDataProvider(&data); CreateDeterministicNetworkSession(); base::WeakPtr
session = CreateInsecureSpdySession(http_session_, key_, BoundNetLog()); GURL url1(kDefaultURL); base::WeakPtr
spdy_stream1 = CreateStreamSynchronously(SPDY_BIDIRECTIONAL_STREAM, session, url1, HIGHEST, BoundNetLog()); ASSERT_TRUE(spdy_stream1.get() != NULL); EXPECT_EQ(0u, spdy_stream1->stream_id()); GURL url2(kDefaultURL); base::WeakPtr
spdy_stream2 = CreateStreamSynchronously(SPDY_BIDIRECTIONAL_STREAM, session, url2, LOWEST, BoundNetLog()); ASSERT_TRUE(spdy_stream2.get() != NULL); EXPECT_EQ(0u, spdy_stream2->stream_id()); // Make |spdy_stream1| close |spdy_stream2|. test::ClosingDelegate delegate1(spdy_stream2); spdy_stream1->SetDelegate(&delegate1); // Make |spdy_stream2| close |spdy_stream1|. test::ClosingDelegate delegate2(spdy_stream1); spdy_stream2->SetDelegate(&delegate2); scoped_ptr
headers( spdy_util_.ConstructGetHeaderBlock(url1.spec())); spdy_stream1->SendRequestHeaders(headers.Pass(), NO_MORE_DATA_TO_SEND); EXPECT_TRUE(spdy_stream1->HasUrlFromHeaders()); scoped_ptr
headers2( spdy_util_.ConstructGetHeaderBlock(url2.spec())); spdy_stream2->SendRequestHeaders(headers2.Pass(), NO_MORE_DATA_TO_SEND); EXPECT_TRUE(spdy_stream2->HasUrlFromHeaders()); // Ensure that the streams have not yet been activated and assigned an id. EXPECT_EQ(0u, spdy_stream1->stream_id()); EXPECT_EQ(0u, spdy_stream2->stream_id()); // Ensure we don't crash while closing the session. session->CloseSessionOnError(ERR_ABORTED, std::string()); EXPECT_EQ(NULL, spdy_stream1.get()); EXPECT_EQ(NULL, spdy_stream2.get()); EXPECT_TRUE(delegate1.StreamIsClosed()); EXPECT_TRUE(delegate2.StreamIsClosed()); base::MessageLoop::current()->RunUntilIdle(); EXPECT_TRUE(session == NULL); } // Create two streams that are set to re-close themselves on close, // activate them, and then close the session. Nothing should blow up. TEST_P(SpdySessionTest, CloseSessionWithTwoActivatedSelfClosingStreams) { session_deps_.host_resolver->set_synchronous_mode(true); MockConnect connect_data(SYNCHRONOUS, OK); scoped_ptr
req1( spdy_util_.ConstructSpdyGet(NULL, 0, false, 1, MEDIUM, true)); scoped_ptr
req2( spdy_util_.ConstructSpdyGet(NULL, 0, false, 3, MEDIUM, true)); MockWrite writes[] = { CreateMockWrite(*req1, 0), CreateMockWrite(*req2, 1), }; MockRead reads[] = { MockRead(ASYNC, 0, 2) // EOF }; DeterministicSocketData data(reads, arraysize(reads), writes, arraysize(writes)); data.set_connect_data(connect_data); session_deps_.deterministic_socket_factory->AddSocketDataProvider(&data); CreateDeterministicNetworkSession(); base::WeakPtr
session = CreateInsecureSpdySession(http_session_, key_, BoundNetLog()); GURL url1(kDefaultURL); base::WeakPtr
spdy_stream1 = CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session, url1, MEDIUM, BoundNetLog()); ASSERT_TRUE(spdy_stream1.get() != NULL); EXPECT_EQ(0u, spdy_stream1->stream_id()); GURL url2(kDefaultURL); base::WeakPtr
spdy_stream2 = CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session, url2, MEDIUM, BoundNetLog()); ASSERT_TRUE(spdy_stream2.get() != NULL); EXPECT_EQ(0u, spdy_stream2->stream_id()); test::ClosingDelegate delegate1(spdy_stream1); spdy_stream1->SetDelegate(&delegate1); test::ClosingDelegate delegate2(spdy_stream2); spdy_stream2->SetDelegate(&delegate2); scoped_ptr
headers( spdy_util_.ConstructGetHeaderBlock(url1.spec())); spdy_stream1->SendRequestHeaders(headers.Pass(), NO_MORE_DATA_TO_SEND); EXPECT_TRUE(spdy_stream1->HasUrlFromHeaders()); scoped_ptr
headers2( spdy_util_.ConstructGetHeaderBlock(url2.spec())); spdy_stream2->SendRequestHeaders(headers2.Pass(), NO_MORE_DATA_TO_SEND); EXPECT_TRUE(spdy_stream2->HasUrlFromHeaders()); // Ensure that the streams have not yet been activated and assigned an id. EXPECT_EQ(0u, spdy_stream1->stream_id()); EXPECT_EQ(0u, spdy_stream2->stream_id()); data.RunFor(2); EXPECT_EQ(1u, spdy_stream1->stream_id()); EXPECT_EQ(3u, spdy_stream2->stream_id()); // Ensure we don't crash while closing the session. session->CloseSessionOnError(ERR_ABORTED, std::string()); EXPECT_EQ(NULL, spdy_stream1.get()); EXPECT_EQ(NULL, spdy_stream2.get()); EXPECT_TRUE(delegate1.StreamIsClosed()); EXPECT_TRUE(delegate2.StreamIsClosed()); base::MessageLoop::current()->RunUntilIdle(); EXPECT_TRUE(session == NULL); } // Create two streams that are set to close each other on close, // activate them, and then close the session. Nothing should blow up. TEST_P(SpdySessionTest, CloseSessionWithTwoActivatedMutuallyClosingStreams) { session_deps_.host_resolver->set_synchronous_mode(true); MockConnect connect_data(SYNCHRONOUS, OK); scoped_ptr
req1( spdy_util_.ConstructSpdyGet(NULL, 0, false, 1, MEDIUM, true)); scoped_ptr
req2( spdy_util_.ConstructSpdyGet(NULL, 0, false, 3, MEDIUM, true)); MockWrite writes[] = { CreateMockWrite(*req1, 0), CreateMockWrite(*req2, 1), }; MockRead reads[] = { MockRead(ASYNC, 0, 2) // EOF }; DeterministicSocketData data(reads, arraysize(reads), writes, arraysize(writes)); data.set_connect_data(connect_data); session_deps_.deterministic_socket_factory->AddSocketDataProvider(&data); CreateDeterministicNetworkSession(); base::WeakPtr
session = CreateInsecureSpdySession(http_session_, key_, BoundNetLog()); GURL url1(kDefaultURL); base::WeakPtr
spdy_stream1 = CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session, url1, MEDIUM, BoundNetLog()); ASSERT_TRUE(spdy_stream1.get() != NULL); EXPECT_EQ(0u, spdy_stream1->stream_id()); GURL url2(kDefaultURL); base::WeakPtr
spdy_stream2 = CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session, url2, MEDIUM, BoundNetLog()); ASSERT_TRUE(spdy_stream2.get() != NULL); EXPECT_EQ(0u, spdy_stream2->stream_id()); // Make |spdy_stream1| close |spdy_stream2|. test::ClosingDelegate delegate1(spdy_stream2); spdy_stream1->SetDelegate(&delegate1); // Make |spdy_stream2| close |spdy_stream1|. test::ClosingDelegate delegate2(spdy_stream1); spdy_stream2->SetDelegate(&delegate2); scoped_ptr
headers( spdy_util_.ConstructGetHeaderBlock(url1.spec())); spdy_stream1->SendRequestHeaders(headers.Pass(), NO_MORE_DATA_TO_SEND); EXPECT_TRUE(spdy_stream1->HasUrlFromHeaders()); scoped_ptr
headers2( spdy_util_.ConstructGetHeaderBlock(url2.spec())); spdy_stream2->SendRequestHeaders(headers2.Pass(), NO_MORE_DATA_TO_SEND); EXPECT_TRUE(spdy_stream2->HasUrlFromHeaders()); // Ensure that the streams have not yet been activated and assigned an id. EXPECT_EQ(0u, spdy_stream1->stream_id()); EXPECT_EQ(0u, spdy_stream2->stream_id()); data.RunFor(2); EXPECT_EQ(1u, spdy_stream1->stream_id()); EXPECT_EQ(3u, spdy_stream2->stream_id()); // Ensure we don't crash while closing the session. session->CloseSessionOnError(ERR_ABORTED, std::string()); EXPECT_EQ(NULL, spdy_stream1.get()); EXPECT_EQ(NULL, spdy_stream2.get()); EXPECT_TRUE(delegate1.StreamIsClosed()); EXPECT_TRUE(delegate2.StreamIsClosed()); base::MessageLoop::current()->RunUntilIdle(); EXPECT_TRUE(session == NULL); } // Delegate that closes a given session when the stream is closed. class SessionClosingDelegate : public test::StreamDelegateDoNothing { public: SessionClosingDelegate(const base::WeakPtr
& stream, const base::WeakPtr
& session_to_close) : StreamDelegateDoNothing(stream), session_to_close_(session_to_close) {} virtual ~SessionClosingDelegate() {} virtual void OnClose(int status) OVERRIDE { session_to_close_->CloseSessionOnError(ERR_SPDY_PROTOCOL_ERROR, "Error"); } private: base::WeakPtr
session_to_close_; }; // Close an activated stream that closes its session. Nothing should // blow up. This is a regression test for http://crbug.com/263691 . TEST_P(SpdySessionTest, CloseActivatedStreamThatClosesSession) { session_deps_.host_resolver->set_synchronous_mode(true); MockConnect connect_data(SYNCHRONOUS, OK); scoped_ptr
req( spdy_util_.ConstructSpdyGet(NULL, 0, false, 1, MEDIUM, true)); scoped_ptr
rst( spdy_util_.ConstructSpdyRstStream(1, RST_STREAM_CANCEL)); scoped_ptr
goaway( spdy_util_.ConstructSpdyGoAway(0, GOAWAY_PROTOCOL_ERROR, "Error")); // The GOAWAY has higher-priority than the RST_STREAM, and is written first // despite being queued second. MockWrite writes[] = { CreateMockWrite(*req, 0), CreateMockWrite(*goaway, 1), CreateMockWrite(*rst, 2), }; MockRead reads[] = { MockRead(ASYNC, 0, 3) // EOF }; DeterministicSocketData data(reads, arraysize(reads), writes, arraysize(writes)); data.set_connect_data(connect_data); session_deps_.deterministic_socket_factory->AddSocketDataProvider(&data); CreateDeterministicNetworkSession(); base::WeakPtr
session = CreateInsecureSpdySession(http_session_, key_, BoundNetLog()); GURL url(kDefaultURL); base::WeakPtr
spdy_stream = CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session, url, MEDIUM, BoundNetLog()); ASSERT_TRUE(spdy_stream.get() != NULL); EXPECT_EQ(0u, spdy_stream->stream_id()); SessionClosingDelegate delegate(spdy_stream, session); spdy_stream->SetDelegate(&delegate); scoped_ptr
headers( spdy_util_.ConstructGetHeaderBlock(url.spec())); spdy_stream->SendRequestHeaders(headers.Pass(), NO_MORE_DATA_TO_SEND); EXPECT_TRUE(spdy_stream->HasUrlFromHeaders()); EXPECT_EQ(0u, spdy_stream->stream_id()); data.RunFor(1); EXPECT_EQ(1u, spdy_stream->stream_id()); // Ensure we don't crash while closing the stream (which closes the // session). spdy_stream->Cancel(); EXPECT_EQ(NULL, spdy_stream.get()); EXPECT_TRUE(delegate.StreamIsClosed()); data.RunFor(2); // Write the RST_STREAM & GOAWAY. base::MessageLoop::current()->RunUntilIdle(); EXPECT_TRUE(session == NULL); } TEST_P(SpdySessionTest, DISABLED_VerifyDomainAuthentication) { session_deps_.host_resolver->set_synchronous_mode(true); MockConnect connect_data(SYNCHRONOUS, OK); // No actual data will be sent. MockWrite writes[] = { MockWrite(ASYNC, 0, 1) // EOF }; MockRead reads[] = { MockRead(ASYNC, 0, 0) // EOF }; DeterministicSocketData data(reads, arraysize(reads), writes, arraysize(writes)); data.set_connect_data(connect_data); session_deps_.deterministic_socket_factory->AddSocketDataProvider(&data); // Load a cert that is valid for: // www.example.org // mail.example.org // www.example.com base::FilePath certs_dir = GetTestCertsDirectory(); scoped_refptr
test_cert( ImportCertFromFile(certs_dir, "spdy_pooling.pem")); ASSERT_NE(static_cast
(NULL), test_cert); SSLSocketDataProvider ssl(SYNCHRONOUS, OK); ssl.cert = test_cert; session_deps_.deterministic_socket_factory->AddSSLSocketDataProvider(&ssl); CreateDeterministicNetworkSession(); base::WeakPtr
session = CreateSecureSpdySession(http_session_, key_, BoundNetLog()); EXPECT_TRUE(session->VerifyDomainAuthentication("www.example.org")); EXPECT_TRUE(session->VerifyDomainAuthentication("mail.example.org")); EXPECT_TRUE(session->VerifyDomainAuthentication("mail.example.com")); EXPECT_FALSE(session->VerifyDomainAuthentication("mail.google.com")); } // TODO(rch): re-enable this. TEST_P(SpdySessionTest, DISABLED_ConnectionPooledWithTlsChannelId) { session_deps_.host_resolver->set_synchronous_mode(true); MockConnect connect_data(SYNCHRONOUS, OK); // No actual data will be sent. MockWrite writes[] = { MockWrite(ASYNC, 0, 1) // EOF }; MockRead reads[] = { MockRead(ASYNC, 0, 0) // EOF }; DeterministicSocketData data(reads, arraysize(reads), writes, arraysize(writes)); data.set_connect_data(connect_data); session_deps_.deterministic_socket_factory->AddSocketDataProvider(&data); // Load a cert that is valid for: // www.example.org // mail.example.org // www.example.com base::FilePath certs_dir = GetTestCertsDirectory(); scoped_refptr
test_cert( ImportCertFromFile(certs_dir, "spdy_pooling.pem")); ASSERT_NE(static_cast
(NULL), test_cert); SSLSocketDataProvider ssl(SYNCHRONOUS, OK); ssl.channel_id_sent = true; ssl.cert = test_cert; session_deps_.deterministic_socket_factory->AddSSLSocketDataProvider(&ssl); CreateDeterministicNetworkSession(); base::WeakPtr
session = CreateSecureSpdySession(http_session_, key_, BoundNetLog()); EXPECT_TRUE(session->VerifyDomainAuthentication("www.example.org")); EXPECT_TRUE(session->VerifyDomainAuthentication("mail.example.org")); EXPECT_FALSE(session->VerifyDomainAuthentication("mail.example.com")); EXPECT_FALSE(session->VerifyDomainAuthentication("mail.google.com")); } TEST_P(SpdySessionTest, CloseTwoStalledCreateStream) { // TODO(rtenneti): Define a helper class/methods and move the common code in // this file. MockConnect connect_data(SYNCHRONOUS, OK); SettingsMap new_settings; const SpdySettingsIds kSpdySettingsIds1 = SETTINGS_MAX_CONCURRENT_STREAMS; const uint32 max_concurrent_streams = 1; new_settings[kSpdySettingsIds1] = SettingsFlagsAndValue(SETTINGS_FLAG_NONE, max_concurrent_streams); scoped_ptr
settings_ack(spdy_util_.ConstructSpdySettingsAck()); scoped_ptr
req1( spdy_util_.ConstructSpdyGet(NULL, 0, false, 1, LOWEST, true)); scoped_ptr
req2( spdy_util_.ConstructSpdyGet(NULL, 0, false, 3, LOWEST, true)); scoped_ptr
req3( spdy_util_.ConstructSpdyGet(NULL, 0, false, 5, LOWEST, true)); MockWrite writes[] = { CreateMockWrite(*settings_ack, 1), CreateMockWrite(*req1, 2), CreateMockWrite(*req2, 5), CreateMockWrite(*req3, 8), }; // Set up the socket so we read a SETTINGS frame that sets max concurrent // streams to 1. scoped_ptr
settings_frame( spdy_util_.ConstructSpdySettings(new_settings)); scoped_ptr
resp1(spdy_util_.ConstructSpdyGetSynReply(NULL, 0, 1)); scoped_ptr
body1(spdy_util_.ConstructSpdyBodyFrame(1, true)); scoped_ptr
resp2(spdy_util_.ConstructSpdyGetSynReply(NULL, 0, 3)); scoped_ptr
body2(spdy_util_.ConstructSpdyBodyFrame(3, true)); scoped_ptr
resp3(spdy_util_.ConstructSpdyGetSynReply(NULL, 0, 5)); scoped_ptr
body3(spdy_util_.ConstructSpdyBodyFrame(5, true)); MockRead reads[] = { CreateMockRead(*settings_frame), CreateMockRead(*resp1, 3), CreateMockRead(*body1, 4), CreateMockRead(*resp2, 6), CreateMockRead(*body2, 7), CreateMockRead(*resp3, 9), CreateMockRead(*body3, 10), MockRead(ASYNC, 0, 11) // EOF }; DeterministicSocketData data(reads, arraysize(reads), writes, arraysize(writes)); data.set_connect_data(connect_data); session_deps_.deterministic_socket_factory->AddSocketDataProvider(&data); CreateDeterministicNetworkSession(); base::WeakPtr
session = CreateInsecureSpdySession(http_session_, key_, BoundNetLog()); // Read the settings frame. data.RunFor(1); GURL url1(kDefaultURL); base::WeakPtr
spdy_stream1 = CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session, url1, LOWEST, BoundNetLog()); ASSERT_TRUE(spdy_stream1.get() != NULL); EXPECT_EQ(0u, spdy_stream1->stream_id()); test::StreamDelegateDoNothing delegate1(spdy_stream1); spdy_stream1->SetDelegate(&delegate1); TestCompletionCallback callback2; GURL url2(kDefaultURL); SpdyStreamRequest request2; ASSERT_EQ(ERR_IO_PENDING, request2.StartRequest( SPDY_REQUEST_RESPONSE_STREAM, session, url2, LOWEST, BoundNetLog(), callback2.callback())); TestCompletionCallback callback3; GURL url3(kDefaultURL); SpdyStreamRequest request3; ASSERT_EQ(ERR_IO_PENDING, request3.StartRequest( SPDY_REQUEST_RESPONSE_STREAM, session, url3, LOWEST, BoundNetLog(), callback3.callback())); EXPECT_EQ(0u, session->num_active_streams()); EXPECT_EQ(1u, session->num_created_streams()); EXPECT_EQ(2u, session->pending_create_stream_queue_size(LOWEST)); scoped_ptr
headers( spdy_util_.ConstructGetHeaderBlock(url1.spec())); spdy_stream1->SendRequestHeaders(headers.Pass(), NO_MORE_DATA_TO_SEND); EXPECT_TRUE(spdy_stream1->HasUrlFromHeaders()); // Run until 1st stream is activated and then closed. EXPECT_EQ(0u, delegate1.stream_id()); data.RunFor(4); EXPECT_EQ(NULL, spdy_stream1.get()); EXPECT_EQ(1u, delegate1.stream_id()); EXPECT_EQ(0u, session->num_active_streams()); EXPECT_EQ(0u, session->num_created_streams()); EXPECT_EQ(1u, session->pending_create_stream_queue_size(LOWEST)); // Pump loop for SpdySession::ProcessPendingStreamRequests() to // create the 2nd stream. base::MessageLoop::current()->RunUntilIdle(); EXPECT_EQ(0u, session->num_active_streams()); EXPECT_EQ(1u, session->num_created_streams()); EXPECT_EQ(1u, session->pending_create_stream_queue_size(LOWEST)); base::WeakPtr
stream2 = request2.ReleaseStream(); test::StreamDelegateDoNothing delegate2(stream2); stream2->SetDelegate(&delegate2); scoped_ptr
headers2( spdy_util_.ConstructGetHeaderBlock(url2.spec())); stream2->SendRequestHeaders(headers2.Pass(), NO_MORE_DATA_TO_SEND); EXPECT_TRUE(stream2->HasUrlFromHeaders()); // Run until 2nd stream is activated and then closed. EXPECT_EQ(0u, delegate2.stream_id()); data.RunFor(3); EXPECT_EQ(NULL, stream2.get()); EXPECT_EQ(3u, delegate2.stream_id()); EXPECT_EQ(0u, session->num_active_streams()); EXPECT_EQ(0u, session->num_created_streams()); EXPECT_EQ(0u, session->pending_create_stream_queue_size(LOWEST)); // Pump loop for SpdySession::ProcessPendingStreamRequests() to // create the 3rd stream. base::MessageLoop::current()->RunUntilIdle(); EXPECT_EQ(0u, session->num_active_streams()); EXPECT_EQ(1u, session->num_created_streams()); EXPECT_EQ(0u, session->pending_create_stream_queue_size(LOWEST)); base::WeakPtr
stream3 = request3.ReleaseStream(); test::StreamDelegateDoNothing delegate3(stream3); stream3->SetDelegate(&delegate3); scoped_ptr
headers3( spdy_util_.ConstructGetHeaderBlock(url3.spec())); stream3->SendRequestHeaders(headers3.Pass(), NO_MORE_DATA_TO_SEND); EXPECT_TRUE(stream3->HasUrlFromHeaders()); // Run until 2nd stream is activated and then closed. EXPECT_EQ(0u, delegate3.stream_id()); data.RunFor(3); EXPECT_EQ(NULL, stream3.get()); EXPECT_EQ(5u, delegate3.stream_id()); EXPECT_EQ(0u, session->num_active_streams()); EXPECT_EQ(0u, session->num_created_streams()); EXPECT_EQ(0u, session->pending_create_stream_queue_size(LOWEST)); data.RunFor(1); } TEST_P(SpdySessionTest, CancelTwoStalledCreateStream) { session_deps_.host_resolver->set_synchronous_mode(true); MockRead reads[] = { MockRead(SYNCHRONOUS, ERR_IO_PENDING) // Stall forever. }; StaticSocketDataProvider data(reads, arraysize(reads), NULL, 0); MockConnect connect_data(SYNCHRONOUS, OK); data.set_connect_data(connect_data); session_deps_.socket_factory->AddSocketDataProvider(&data); CreateNetworkSession(); base::WeakPtr
session = CreateInsecureSpdySession(http_session_, key_, BoundNetLog()); // Leave room for only one more stream to be created. for (size_t i = 0; i < kInitialMaxConcurrentStreams - 1; ++i) { base::WeakPtr
spdy_stream = CreateStreamSynchronously(SPDY_BIDIRECTIONAL_STREAM, session, test_url_, MEDIUM, BoundNetLog()); ASSERT_TRUE(spdy_stream != NULL); } GURL url1(kDefaultURL); base::WeakPtr
spdy_stream1 = CreateStreamSynchronously(SPDY_BIDIRECTIONAL_STREAM, session, url1, LOWEST, BoundNetLog()); ASSERT_TRUE(spdy_stream1.get() != NULL); EXPECT_EQ(0u, spdy_stream1->stream_id()); TestCompletionCallback callback2; GURL url2(kDefaultURL); SpdyStreamRequest request2; ASSERT_EQ(ERR_IO_PENDING, request2.StartRequest( SPDY_BIDIRECTIONAL_STREAM, session, url2, LOWEST, BoundNetLog(), callback2.callback())); TestCompletionCallback callback3; GURL url3(kDefaultURL); SpdyStreamRequest request3; ASSERT_EQ(ERR_IO_PENDING, request3.StartRequest( SPDY_BIDIRECTIONAL_STREAM, session, url3, LOWEST, BoundNetLog(), callback3.callback())); EXPECT_EQ(0u, session->num_active_streams()); EXPECT_EQ(kInitialMaxConcurrentStreams, session->num_created_streams()); EXPECT_EQ(2u, session->pending_create_stream_queue_size(LOWEST)); // Cancel the first stream; this will allow the second stream to be created. EXPECT_TRUE(spdy_stream1.get() != NULL); spdy_stream1->Cancel(); EXPECT_EQ(NULL, spdy_stream1.get()); EXPECT_EQ(OK, callback2.WaitForResult()); EXPECT_EQ(0u, session->num_active_streams()); EXPECT_EQ(kInitialMaxConcurrentStreams, session->num_created_streams()); EXPECT_EQ(1u, session->pending_create_stream_queue_size(LOWEST)); // Cancel the second stream; this will allow the third stream to be created. base::WeakPtr
spdy_stream2 = request2.ReleaseStream(); spdy_stream2->Cancel(); EXPECT_EQ(NULL, spdy_stream2.get()); EXPECT_EQ(OK, callback3.WaitForResult()); EXPECT_EQ(0u, session->num_active_streams()); EXPECT_EQ(kInitialMaxConcurrentStreams, session->num_created_streams()); EXPECT_EQ(0u, session->pending_create_stream_queue_size(LOWEST)); // Cancel the third stream. base::WeakPtr
spdy_stream3 = request3.ReleaseStream(); spdy_stream3->Cancel(); EXPECT_EQ(NULL, spdy_stream3.get()); EXPECT_EQ(0u, session->num_active_streams()); EXPECT_EQ(kInitialMaxConcurrentStreams - 1, session->num_created_streams()); EXPECT_EQ(0u, session->pending_create_stream_queue_size(LOWEST)); } // Test that SpdySession::DoReadLoop reads data from the socket // without yielding. This test makes 32k - 1 bytes of data available // on the socket for reading. It then verifies that it has read all // the available data without yielding. TEST_P(SpdySessionTest, ReadDataWithoutYielding) { MockConnect connect_data(SYNCHRONOUS, OK); BufferedSpdyFramer framer(spdy_util_.spdy_version(), false); scoped_ptr
req1( spdy_util_.ConstructSpdyGet(NULL, 0, false, 1, MEDIUM, true)); MockWrite writes[] = { CreateMockWrite(*req1, 0), }; // Build buffer of size kMaxReadBytesWithoutYielding / 4 // (-spdy_data_frame_size). ASSERT_EQ(32 * 1024, kMaxReadBytesWithoutYielding); const int kPayloadSize = kMaxReadBytesWithoutYielding / 4 - framer.GetControlFrameHeaderSize(); TestDataStream test_stream; scoped_refptr
payload(new net::IOBuffer(kPayloadSize)); char* payload_data = payload->data(); test_stream.GetBytes(payload_data, kPayloadSize); scoped_ptr
partial_data_frame( framer.CreateDataFrame(1, payload_data, kPayloadSize, DATA_FLAG_NONE)); scoped_ptr
finish_data_frame( framer.CreateDataFrame(1, payload_data, kPayloadSize - 1, DATA_FLAG_FIN)); scoped_ptr
resp1(spdy_util_.ConstructSpdyGetSynReply(NULL, 0, 1)); // Write 1 byte less than kMaxReadBytes to check that DoRead reads up to 32k // bytes. MockRead reads[] = { CreateMockRead(*resp1, 1), CreateMockRead(*partial_data_frame, 2), CreateMockRead(*partial_data_frame, 3, SYNCHRONOUS), CreateMockRead(*partial_data_frame, 4, SYNCHRONOUS), CreateMockRead(*finish_data_frame, 5, SYNCHRONOUS), MockRead(ASYNC, 0, 6) // EOF }; // Create SpdySession and SpdyStream and send the request. DeterministicSocketData data(reads, arraysize(reads), writes, arraysize(writes)); data.set_connect_data(connect_data); session_deps_.host_resolver->set_synchronous_mode(true); session_deps_.deterministic_socket_factory->AddSocketDataProvider(&data); CreateDeterministicNetworkSession(); base::WeakPtr
session = CreateInsecureSpdySession(http_session_, key_, BoundNetLog()); GURL url1(kDefaultURL); base::WeakPtr
spdy_stream1 = CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session, url1, MEDIUM, BoundNetLog()); ASSERT_TRUE(spdy_stream1.get() != NULL); EXPECT_EQ(0u, spdy_stream1->stream_id()); test::StreamDelegateDoNothing delegate1(spdy_stream1); spdy_stream1->SetDelegate(&delegate1); scoped_ptr
headers1( spdy_util_.ConstructGetHeaderBlock(url1.spec())); spdy_stream1->SendRequestHeaders(headers1.Pass(), NO_MORE_DATA_TO_SEND); EXPECT_TRUE(spdy_stream1->HasUrlFromHeaders()); // Set up the TaskObserver to verify SpdySession::DoReadLoop doesn't // post a task. SpdySessionTestTaskObserver observer("spdy_session.cc", "DoReadLoop"); // Run until 1st read. EXPECT_EQ(0u, delegate1.stream_id()); data.RunFor(2); EXPECT_EQ(1u, delegate1.stream_id()); EXPECT_EQ(0u, observer.executed_count()); // Read all the data and verify SpdySession::DoReadLoop has not // posted a task. data.RunFor(4); EXPECT_EQ(NULL, spdy_stream1.get()); // Verify task observer's executed_count is zero, which indicates DoRead read // all the available data. EXPECT_EQ(0u, observer.executed_count()); EXPECT_TRUE(data.at_write_eof()); EXPECT_TRUE(data.at_read_eof()); } // Test that SpdySession::DoReadLoop yields while reading the // data. This test makes 32k + 1 bytes of data available on the socket // for reading. It then verifies that DoRead has yielded even though // there is data available for it to read (i.e, socket()->Read didn't // return ERR_IO_PENDING during socket reads). TEST_P(SpdySessionTest, TestYieldingDuringReadData) { MockConnect connect_data(SYNCHRONOUS, OK); BufferedSpdyFramer framer(spdy_util_.spdy_version(), false); scoped_ptr
req1( spdy_util_.ConstructSpdyGet(NULL, 0, false, 1, MEDIUM, true)); MockWrite writes[] = { CreateMockWrite(*req1, 0), }; // Build buffer of size kMaxReadBytesWithoutYielding / 4 // (-spdy_data_frame_size). ASSERT_EQ(32 * 1024, kMaxReadBytesWithoutYielding); const int kPayloadSize = kMaxReadBytesWithoutYielding / 4 - framer.GetControlFrameHeaderSize(); TestDataStream test_stream; scoped_refptr
payload(new net::IOBuffer(kPayloadSize)); char* payload_data = payload->data(); test_stream.GetBytes(payload_data, kPayloadSize); scoped_ptr
partial_data_frame( framer.CreateDataFrame(1, payload_data, kPayloadSize, DATA_FLAG_NONE)); scoped_ptr
finish_data_frame( framer.CreateDataFrame(1, "h", 1, DATA_FLAG_FIN)); scoped_ptr
resp1(spdy_util_.ConstructSpdyGetSynReply(NULL, 0, 1)); // Write 1 byte more than kMaxReadBytes to check that DoRead yields. MockRead reads[] = { CreateMockRead(*resp1, 1), CreateMockRead(*partial_data_frame, 2), CreateMockRead(*partial_data_frame, 3, SYNCHRONOUS), CreateMockRead(*partial_data_frame, 4, SYNCHRONOUS), CreateMockRead(*partial_data_frame, 5, SYNCHRONOUS), CreateMockRead(*finish_data_frame, 6, SYNCHRONOUS), MockRead(ASYNC, 0, 7) // EOF }; // Create SpdySession and SpdyStream and send the request. DeterministicSocketData data(reads, arraysize(reads), writes, arraysize(writes)); data.set_connect_data(connect_data); session_deps_.host_resolver->set_synchronous_mode(true); session_deps_.deterministic_socket_factory->AddSocketDataProvider(&data); CreateDeterministicNetworkSession(); base::WeakPtr
session = CreateInsecureSpdySession(http_session_, key_, BoundNetLog()); GURL url1(kDefaultURL); base::WeakPtr
spdy_stream1 = CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session, url1, MEDIUM, BoundNetLog()); ASSERT_TRUE(spdy_stream1.get() != NULL); EXPECT_EQ(0u, spdy_stream1->stream_id()); test::StreamDelegateDoNothing delegate1(spdy_stream1); spdy_stream1->SetDelegate(&delegate1); scoped_ptr
headers1( spdy_util_.ConstructGetHeaderBlock(url1.spec())); spdy_stream1->SendRequestHeaders(headers1.Pass(), NO_MORE_DATA_TO_SEND); EXPECT_TRUE(spdy_stream1->HasUrlFromHeaders()); // Set up the TaskObserver to verify SpdySession::DoReadLoop posts a // task. SpdySessionTestTaskObserver observer("spdy_session.cc", "DoReadLoop"); // Run until 1st read. EXPECT_EQ(0u, delegate1.stream_id()); data.RunFor(2); EXPECT_EQ(1u, delegate1.stream_id()); EXPECT_EQ(0u, observer.executed_count()); // Read all the data and verify SpdySession::DoReadLoop has posted a // task. data.RunFor(6); EXPECT_EQ(NULL, spdy_stream1.get()); // Verify task observer's executed_count is 1, which indicates DoRead has // posted only one task and thus yielded though there is data available for it // to read. EXPECT_EQ(1u, observer.executed_count()); EXPECT_TRUE(data.at_write_eof()); EXPECT_TRUE(data.at_read_eof()); } // Test that SpdySession::DoReadLoop() tests interactions of yielding // + async, by doing the following MockReads. // // MockRead of SYNCHRONOUS 8K, SYNCHRONOUS 8K, SYNCHRONOUS 8K, SYNCHRONOUS 2K // ASYNC 8K, SYNCHRONOUS 8K, SYNCHRONOUS 8K, SYNCHRONOUS 8K, SYNCHRONOUS 2K. // // The above reads 26K synchronously. Since that is less that 32K, we // will attempt to read again. However, that DoRead() will return // ERR_IO_PENDING (because of async read), so DoReadLoop() will // yield. When we come back, DoRead() will read the results from the // async read, and rest of the data synchronously. TEST_P(SpdySessionTest, TestYieldingDuringAsyncReadData) { MockConnect connect_data(SYNCHRONOUS, OK); BufferedSpdyFramer framer(spdy_util_.spdy_version(), false); scoped_ptr
req1( spdy_util_.ConstructSpdyGet(NULL, 0, false, 1, MEDIUM, true)); MockWrite writes[] = { CreateMockWrite(*req1, 0), }; // Build buffer of size kMaxReadBytesWithoutYielding / 4 // (-spdy_data_frame_size). ASSERT_EQ(32 * 1024, kMaxReadBytesWithoutYielding); TestDataStream test_stream; const int kEightKPayloadSize = kMaxReadBytesWithoutYielding / 4 - framer.GetControlFrameHeaderSize(); scoped_refptr
eightk_payload( new net::IOBuffer(kEightKPayloadSize)); char* eightk_payload_data = eightk_payload->data(); test_stream.GetBytes(eightk_payload_data, kEightKPayloadSize); // Build buffer of 2k size. TestDataStream test_stream2; const int kTwoKPayloadSize = kEightKPayloadSize - 6 * 1024; scoped_refptr
twok_payload( new net::IOBuffer(kTwoKPayloadSize)); char* twok_payload_data = twok_payload->data(); test_stream2.GetBytes(twok_payload_data, kTwoKPayloadSize); scoped_ptr
eightk_data_frame(framer.CreateDataFrame( 1, eightk_payload_data, kEightKPayloadSize, DATA_FLAG_NONE)); scoped_ptr
twok_data_frame(framer.CreateDataFrame( 1, twok_payload_data, kTwoKPayloadSize, DATA_FLAG_NONE)); scoped_ptr
finish_data_frame(framer.CreateDataFrame( 1, "h", 1, DATA_FLAG_FIN)); scoped_ptr
resp1(spdy_util_.ConstructSpdyGetSynReply(NULL, 0, 1)); MockRead reads[] = { CreateMockRead(*resp1, 1), CreateMockRead(*eightk_data_frame, 2), CreateMockRead(*eightk_data_frame, 3, SYNCHRONOUS), CreateMockRead(*eightk_data_frame, 4, SYNCHRONOUS), CreateMockRead(*twok_data_frame, 5, SYNCHRONOUS), CreateMockRead(*eightk_data_frame, 6, ASYNC), CreateMockRead(*eightk_data_frame, 7, SYNCHRONOUS), CreateMockRead(*eightk_data_frame, 8, SYNCHRONOUS), CreateMockRead(*eightk_data_frame, 9, SYNCHRONOUS), CreateMockRead(*twok_data_frame, 10, SYNCHRONOUS), CreateMockRead(*finish_data_frame, 11, SYNCHRONOUS), MockRead(ASYNC, 0, 12) // EOF }; // Create SpdySession and SpdyStream and send the request. DeterministicSocketData data(reads, arraysize(reads), writes, arraysize(writes)); data.set_connect_data(connect_data); session_deps_.host_resolver->set_synchronous_mode(true); session_deps_.deterministic_socket_factory->AddSocketDataProvider(&data); CreateDeterministicNetworkSession(); base::WeakPtr
session = CreateInsecureSpdySession(http_session_, key_, BoundNetLog()); GURL url1(kDefaultURL); base::WeakPtr
spdy_stream1 = CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session, url1, MEDIUM, BoundNetLog()); ASSERT_TRUE(spdy_stream1.get() != NULL); EXPECT_EQ(0u, spdy_stream1->stream_id()); test::StreamDelegateDoNothing delegate1(spdy_stream1); spdy_stream1->SetDelegate(&delegate1); scoped_ptr
headers1( spdy_util_.ConstructGetHeaderBlock(url1.spec())); spdy_stream1->SendRequestHeaders(headers1.Pass(), NO_MORE_DATA_TO_SEND); EXPECT_TRUE(spdy_stream1->HasUrlFromHeaders()); // Set up the TaskObserver to monitor SpdySession::DoReadLoop // posting of tasks. SpdySessionTestTaskObserver observer("spdy_session.cc", "DoReadLoop"); // Run until 1st read. EXPECT_EQ(0u, delegate1.stream_id()); data.RunFor(2); EXPECT_EQ(1u, delegate1.stream_id()); EXPECT_EQ(0u, observer.executed_count()); // Read all the data and verify SpdySession::DoReadLoop has posted a // task. data.RunFor(12); EXPECT_EQ(NULL, spdy_stream1.get()); // Verify task observer's executed_count is 1, which indicates DoRead has // posted only one task and thus yielded though there is data available for // it to read. EXPECT_EQ(1u, observer.executed_count()); EXPECT_TRUE(data.at_write_eof()); EXPECT_TRUE(data.at_read_eof()); } // Send a GoAway frame when SpdySession is in DoReadLoop. Make sure // nothing blows up. TEST_P(SpdySessionTest, GoAwayWhileInDoReadLoop) { MockConnect connect_data(SYNCHRONOUS, OK); BufferedSpdyFramer framer(spdy_util_.spdy_version(), false); scoped_ptr
req1( spdy_util_.ConstructSpdyGet(NULL, 0, false, 1, MEDIUM, true)); MockWrite writes[] = { CreateMockWrite(*req1, 0), }; scoped_ptr
resp1(spdy_util_.ConstructSpdyGetSynReply(NULL, 0, 1)); scoped_ptr
body1(spdy_util_.ConstructSpdyBodyFrame(1, true)); scoped_ptr
goaway(spdy_util_.ConstructSpdyGoAway()); MockRead reads[] = { CreateMockRead(*resp1, 1), CreateMockRead(*body1, 2), CreateMockRead(*goaway, 3), }; // Create SpdySession and SpdyStream and send the request. DeterministicSocketData data(reads, arraysize(reads), writes, arraysize(writes)); data.set_connect_data(connect_data); session_deps_.host_resolver->set_synchronous_mode(true); session_deps_.deterministic_socket_factory->AddSocketDataProvider(&data); CreateDeterministicNetworkSession(); base::WeakPtr
session = CreateInsecureSpdySession(http_session_, key_, BoundNetLog()); GURL url1(kDefaultURL); base::WeakPtr
spdy_stream1 = CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session, url1, MEDIUM, BoundNetLog()); test::StreamDelegateDoNothing delegate1(spdy_stream1); spdy_stream1->SetDelegate(&delegate1); ASSERT_TRUE(spdy_stream1.get() != NULL); EXPECT_EQ(0u, spdy_stream1->stream_id()); scoped_ptr
headers1( spdy_util_.ConstructGetHeaderBlock(url1.spec())); spdy_stream1->SendRequestHeaders(headers1.Pass(), NO_MORE_DATA_TO_SEND); EXPECT_TRUE(spdy_stream1->HasUrlFromHeaders()); // Run until 1st read. EXPECT_EQ(0u, spdy_stream1->stream_id()); data.RunFor(1); EXPECT_EQ(1u, spdy_stream1->stream_id()); // Run until GoAway. data.RunFor(3); EXPECT_EQ(NULL, spdy_stream1.get()); EXPECT_TRUE(data.at_write_eof()); EXPECT_TRUE(data.at_read_eof()); EXPECT_TRUE(session == NULL); } // Within this framework, a SpdySession should be initialized with // flow control disabled for protocol version 2, with flow control // enabled only for streams for protocol version 3, and with flow // control enabled for streams and sessions for higher versions. TEST_P(SpdySessionTest, ProtocolNegotiation) { session_deps_.host_resolver->set_synchronous_mode(true); MockConnect connect_data(SYNCHRONOUS, OK); MockRead reads[] = { MockRead(SYNCHRONOUS, 0, 0) // EOF }; StaticSocketDataProvider data(reads, arraysize(reads), NULL, 0); data.set_connect_data(connect_data); session_deps_.socket_factory->AddSocketDataProvider(&data); CreateNetworkSession(); base::WeakPtr
session = CreateFakeSpdySession(spdy_session_pool_, key_); EXPECT_EQ(spdy_util_.spdy_version(), session->buffered_spdy_framer_->protocol_version()); if (GetParam() == kProtoDeprecatedSPDY2) { EXPECT_EQ(SpdySession::FLOW_CONTROL_NONE, session->flow_control_state()); EXPECT_EQ(0, session->session_send_window_size_); EXPECT_EQ(0, session->session_recv_window_size_); } else if (GetParam() == kProtoSPDY3) { EXPECT_EQ(SpdySession::FLOW_CONTROL_STREAM, session->flow_control_state()); EXPECT_EQ(0, session->session_send_window_size_); EXPECT_EQ(0, session->session_recv_window_size_); } else { EXPECT_EQ(SpdySession::FLOW_CONTROL_STREAM_AND_SESSION, session->flow_control_state()); EXPECT_EQ(kSpdySessionInitialWindowSize, session->session_send_window_size_); EXPECT_EQ(kSpdySessionInitialWindowSize, session->session_recv_window_size_); } EXPECT_EQ(0, session->session_unacked_recv_window_bytes_); } // Tests the case of a non-SPDY request closing an idle SPDY session when no // pointers to the idle session are currently held. TEST_P(SpdySessionTest, CloseOneIdleConnection) { ClientSocketPoolManager::set_max_sockets_per_group( HttpNetworkSession::NORMAL_SOCKET_POOL, 1); ClientSocketPoolManager::set_max_sockets_per_pool( HttpNetworkSession::NORMAL_SOCKET_POOL, 1); MockConnect connect_data(SYNCHRONOUS, OK); MockRead reads[] = { MockRead(SYNCHRONOUS, ERR_IO_PENDING) // Stall forever. }; StaticSocketDataProvider data(reads, arraysize(reads), NULL, 0); data.set_connect_data(connect_data); session_deps_.socket_factory->AddSocketDataProvider(&data); session_deps_.socket_factory->AddSocketDataProvider(&data); CreateNetworkSession(); TransportClientSocketPool* pool = http_session_->GetTransportSocketPool( HttpNetworkSession::NORMAL_SOCKET_POOL); // Create an idle SPDY session. SpdySessionKey key1(HostPortPair("1.com", 80), ProxyServer::Direct(), PRIVACY_MODE_DISABLED); base::WeakPtr
session1 = CreateInsecureSpdySession(http_session_, key1, BoundNetLog()); EXPECT_FALSE(pool->IsStalled()); // Trying to create a new connection should cause the pool to be stalled, and // post a task asynchronously to try and close the session. TestCompletionCallback callback2; HostPortPair host_port2("2.com", 80); scoped_refptr
params2( new TransportSocketParams(host_port2, false, false, OnHostResolutionCallback())); scoped_ptr
connection2(new ClientSocketHandle); EXPECT_EQ(ERR_IO_PENDING, connection2->Init(host_port2.ToString(), params2, DEFAULT_PRIORITY, callback2.callback(), pool, BoundNetLog())); EXPECT_TRUE(pool->IsStalled()); // The socket pool should close the connection asynchronously and establish a // new connection. EXPECT_EQ(OK, callback2.WaitForResult()); EXPECT_FALSE(pool->IsStalled()); EXPECT_TRUE(session1 == NULL); } // Tests the case of a non-SPDY request closing an idle SPDY session when no // pointers to the idle session are currently held, in the case the SPDY session // has an alias. TEST_P(SpdySessionTest, CloseOneIdleConnectionWithAlias) { ClientSocketPoolManager::set_max_sockets_per_group( HttpNetworkSession::NORMAL_SOCKET_POOL, 1); ClientSocketPoolManager::set_max_sockets_per_pool( HttpNetworkSession::NORMAL_SOCKET_POOL, 1); MockConnect connect_data(SYNCHRONOUS, OK); MockRead reads[] = { MockRead(SYNCHRONOUS, ERR_IO_PENDING) // Stall forever. }; StaticSocketDataProvider data(reads, arraysize(reads), NULL, 0); data.set_connect_data(connect_data); session_deps_.socket_factory->AddSocketDataProvider(&data); session_deps_.socket_factory->AddSocketDataProvider(&data); session_deps_.host_resolver->set_synchronous_mode(true); session_deps_.host_resolver->rules()->AddIPLiteralRule( "1.com", "192.168.0.2", std::string()); session_deps_.host_resolver->rules()->AddIPLiteralRule( "2.com", "192.168.0.2", std::string()); // Not strictly needed. session_deps_.host_resolver->rules()->AddIPLiteralRule( "3.com", "192.168.0.3", std::string()); CreateNetworkSession(); TransportClientSocketPool* pool = http_session_->GetTransportSocketPool( HttpNetworkSession::NORMAL_SOCKET_POOL); // Create an idle SPDY session. SpdySessionKey key1(HostPortPair("1.com", 80), ProxyServer::Direct(), PRIVACY_MODE_DISABLED); base::WeakPtr
session1 = CreateInsecureSpdySession(http_session_, key1, BoundNetLog()); EXPECT_FALSE(pool->IsStalled()); // Set up an alias for the idle SPDY session, increasing its ref count to 2. SpdySessionKey key2(HostPortPair("2.com", 80), ProxyServer::Direct(), PRIVACY_MODE_DISABLED); HostResolver::RequestInfo info(key2.host_port_pair()); AddressList addresses; // Pre-populate the DNS cache, since a synchronous resolution is required in // order to create the alias. session_deps_.host_resolver->Resolve(info, DEFAULT_PRIORITY, &addresses, CompletionCallback(), NULL, BoundNetLog()); // Get a session for |key2|, which should return the session created earlier. base::WeakPtr
session2 = spdy_session_pool_->FindAvailableSession(key2, BoundNetLog()); ASSERT_EQ(session1.get(), session2.get()); EXPECT_FALSE(pool->IsStalled()); // Trying to create a new connection should cause the pool to be stalled, and // post a task asynchronously to try and close the session. TestCompletionCallback callback3; HostPortPair host_port3("3.com", 80); scoped_refptr
params3( new TransportSocketParams(host_port3, false, false, OnHostResolutionCallback())); scoped_ptr
connection3(new ClientSocketHandle); EXPECT_EQ(ERR_IO_PENDING, connection3->Init(host_port3.ToString(), params3, DEFAULT_PRIORITY, callback3.callback(), pool, BoundNetLog())); EXPECT_TRUE(pool->IsStalled()); // The socket pool should close the connection asynchronously and establish a // new connection. EXPECT_EQ(OK, callback3.WaitForResult()); EXPECT_FALSE(pool->IsStalled()); EXPECT_TRUE(session1 == NULL); EXPECT_TRUE(session2 == NULL); } // Tests that when a SPDY session becomes idle, it closes itself if there is // a lower layer pool stalled on the per-pool socket limit. TEST_P(SpdySessionTest, CloseSessionOnIdleWhenPoolStalled) { ClientSocketPoolManager::set_max_sockets_per_group( HttpNetworkSession::NORMAL_SOCKET_POOL, 1); ClientSocketPoolManager::set_max_sockets_per_pool( HttpNetworkSession::NORMAL_SOCKET_POOL, 1); MockConnect connect_data(SYNCHRONOUS, OK); MockRead reads[] = { MockRead(SYNCHRONOUS, ERR_IO_PENDING) // Stall forever. }; scoped_ptr
req1( spdy_util_.ConstructSpdyGet(NULL, 0, false, 1, LOWEST, true)); scoped_ptr
cancel1( spdy_util_.ConstructSpdyRstStream(1, RST_STREAM_CANCEL)); MockWrite writes[] = { CreateMockWrite(*req1, 1), CreateMockWrite(*cancel1, 1), }; StaticSocketDataProvider data(reads, arraysize(reads), writes, arraysize(writes)); data.set_connect_data(connect_data); session_deps_.socket_factory->AddSocketDataProvider(&data); MockRead http_reads[] = { MockRead(SYNCHRONOUS, ERR_IO_PENDING) // Stall forever. }; StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), NULL, 0); http_data.set_connect_data(connect_data); session_deps_.socket_factory->AddSocketDataProvider(&http_data); CreateNetworkSession(); TransportClientSocketPool* pool = http_session_->GetTransportSocketPool( HttpNetworkSession::NORMAL_SOCKET_POOL); // Create a SPDY session. GURL url1(kDefaultURL); SpdySessionKey key1(HostPortPair(url1.host(), 80), ProxyServer::Direct(), PRIVACY_MODE_DISABLED); base::WeakPtr
session1 = CreateInsecureSpdySession(http_session_, key1, BoundNetLog()); EXPECT_FALSE(pool->IsStalled()); // Create a stream using the session, and send a request. TestCompletionCallback callback1; base::WeakPtr