Split net/spdy into core and chromium subdirectories.

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 <algorithm>
-#include <memory>
-#include <utility>
-
-#include "base/base64.h"
-#include "base/bind.h"
-#include "base/callback.h"
-#include "base/run_loop.h"
-#include "base/test/histogram_tester.h"
-#include "base/test/scoped_feature_list.h"
-#include "net/base/host_port_pair.h"
-#include "net/base/io_buffer.h"
-#include "net/base/ip_endpoint.h"
-#include "net/base/proxy_delegate.h"
-#include "net/base/request_priority.h"
-#include "net/base/test_data_stream.h"
-#include "net/base/test_proxy_delegate.h"
-#include "net/cert/ct_policy_status.h"
-#include "net/log/net_log_event_type.h"
-#include "net/log/net_log_source.h"
-#include "net/log/test_net_log.h"
-#include "net/log/test_net_log_entry.h"
-#include "net/log/test_net_log_util.h"
-#include "net/proxy/proxy_server.h"
-#include "net/socket/client_socket_pool_manager.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 "net/test/gtest_util.h"
-#include "net/test/test_data_directory.h"
-#include "testing/gmock/include/gmock/gmock.h"
-#include "testing/platform_test.h"
-
-using net::test::IsError;
-using net::test::IsOk;
-using net::test::TestServerPushDelegate;
-
-namespace net {
-
-namespace {
-
-const char kHttpURLFromAnotherOrigin[] = "http://www.example2.org/a.dat";
-const char kHttpsURLFromAnotherOrigin[] = "https://www.example2.org/b.dat";
-
-const char kBodyData[] = "Body data";
-const size_t kBodyDataSize = arraysize(kBodyData);
-const SpdyStringPiece kBodyDataStringPiece(kBodyData, kBodyDataSize);
-
-static base::TimeDelta g_time_delta;
-static base::TimeTicks g_time_now;
-
-base::TimeTicks TheNearFuture() {
-  return base::TimeTicks::Now() + g_time_delta;
-}
-
-base::TimeTicks SlowReads() {
-  g_time_delta +=
-      base::TimeDelta::FromMilliseconds(2 * kYieldAfterDurationMilliseconds);
-  return base::TimeTicks::Now() + g_time_delta;
-}
-
-base::TimeTicks InstantaneousReads() {
-  return g_time_now;
-}
-
-class MockRequireCTDelegate : public TransportSecurityState::RequireCTDelegate {
- public:
-  MOCK_METHOD1(IsCTRequiredForHost, CTRequirementLevel(const SpdyString& host));
-};
-
-}  // namespace
-
-class SpdySessionTest : public PlatformTest {
- public:
-  // Functions used with RunResumeAfterUnstallTest().
-
-  void StallSessionOnly(SpdyStream* stream) { StallSessionSend(); }
-
-  void StallStreamOnly(SpdyStream* stream) { StallStreamSend(stream); }
-
-  void StallSessionStream(SpdyStream* stream) {
-    StallSessionSend();
-    StallStreamSend(stream);
-  }
-
-  void StallStreamSession(SpdyStream* stream) {
-    StallStreamSend(stream);
-    StallSessionSend();
-  }
-
-  void UnstallSessionOnly(SpdyStream* stream, int32_t delta_window_size) {
-    UnstallSessionSend(delta_window_size);
-  }
-
-  void UnstallStreamOnly(SpdyStream* stream, int32_t delta_window_size) {
-    UnstallStreamSend(stream, delta_window_size);
-  }
-
-  void UnstallSessionStream(SpdyStream* stream, int32_t delta_window_size) {
-    UnstallSessionSend(delta_window_size);
-    UnstallStreamSend(stream, delta_window_size);
-  }
-
-  void UnstallStreamSession(SpdyStream* stream, int32_t delta_window_size) {
-    UnstallStreamSend(stream, delta_window_size);
-    UnstallSessionSend(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)),
-        test_push_delegate_(nullptr),
-        spdy_session_pool_(nullptr),
-        test_url_(kDefaultUrl),
-        test_server_(test_url_),
-        key_(HostPortPair::FromURL(test_url_),
-             ProxyServer::Direct(),
-             PRIVACY_MODE_DISABLED),
-        ssl_(SYNCHRONOUS, OK) {}
-
-  ~SpdySessionTest() override {
-    // 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_);
-  }
-
-  void SetUp() override {
-    g_time_delta = base::TimeDelta();
-    g_time_now = base::TimeTicks::Now();
-    session_deps_.net_log = log_.bound().net_log();
-    session_deps_.enable_server_push_cancellation = true;
-  }
-
-  void CreateNetworkSession() {
-    DCHECK(!http_session_);
-    DCHECK(!spdy_session_pool_);
-    http_session_ =
-        SpdySessionDependencies::SpdyCreateSession(&session_deps_);
-    std::unique_ptr<TestServerPushDelegate> test_push_delegate(
-        new TestServerPushDelegate());
-    test_push_delegate_ = test_push_delegate.get();
-    http_session_->SetServerPushDelegate(std::move(test_push_delegate));
-    spdy_session_pool_ = http_session_->spdy_session_pool();
-  }
-
-  void CreateInsecureSpdySession() {
-    DCHECK(!session_);
-    session_ = ::net::CreateInsecureSpdySession(http_session_.get(), key_,
-                                                log_.bound());
-  }
-
-  void AddSSLSocketData() {
-    ssl_.cert = ImportCertFromFile(GetTestCertsDirectory(), "spdy_pooling.pem");
-    ASSERT_TRUE(ssl_.cert);
-    session_deps_.socket_factory->AddSSLSocketDataProvider(&ssl_);
-  }
-
-  void CreateSecureSpdySession() {
-    DCHECK(!session_);
-    session_ =
-        ::net::CreateSecureSpdySession(http_session_.get(), key_, log_.bound());
-  }
-
-  void StallSessionSend() {
-    // Reduce the send window size to 0 to stall.
-    while (session_->session_send_window_size_ > 0) {
-      session_->DecreaseSendWindowSize(std::min(
-          kMaxSpdyFrameChunkSize, session_->session_send_window_size_));
-    }
-  }
-
-  void UnstallSessionSend(int32_t 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_t delta_window_size) {
-    stream->IncreaseSendWindowSize(delta_window_size);
-  }
-
-  void RunResumeAfterUnstallTest(
-      const base::Callback<void(SpdyStream*)>& stall_function,
-      const base::Callback<void(SpdyStream*, int32_t)>& 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_;
-  std::unique_ptr<HttpNetworkSession> http_session_;
-  base::WeakPtr<SpdySession> session_;
-  TestServerPushDelegate* test_push_delegate_;
-  SpdySessionPool* spdy_session_pool_;
-  const GURL test_url_;
-  const url::SchemeHostPort test_server_;
-  SpdySessionKey key_;
-  SSLSocketDataProvider ssl_;
-  BoundTestNetLog log_;
-};
-
-// Try to create a SPDY session that will fail during
-// initialization. Nothing should blow up.
-TEST_F(SpdySessionTest, InitialReadError) {
-  CreateNetworkSession();
-
-  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() {}
-
-  ~StreamRequestDestroyingCallback() override {}
-
-  void SetRequestToDestroy(std::unique_ptr<SpdyStreamRequest> request) {
-    request_ = std::move(request);
-  }
-
-  CompletionCallback MakeCallback() {
-    return base::Bind(&StreamRequestDestroyingCallback::OnComplete,
-                      base::Unretained(this));
-  }
-
- private:
-  void OnComplete(int result) {
-    request_.reset();
-    SetResult(result);
-  }
-
-  std::unique_ptr<SpdyStreamRequest> 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_F(SpdySessionTest, PendingStreamCancellingAnother) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  MockRead reads[] = {MockRead(ASYNC, 0, 0), };
-
-  SequencedSocketData data(reads, arraysize(reads), nullptr, 0);
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  // Create the maximum number of concurrent streams.
-  for (size_t i = 0; i < kInitialMaxConcurrentStreams; ++i) {
-    base::WeakPtr<SpdyStream> spdy_stream =
-        CreateStreamSynchronously(SPDY_BIDIRECTIONAL_STREAM, session_,
-                                  test_url_, MEDIUM, NetLogWithSource());
-    ASSERT_TRUE(spdy_stream);
-  }
-
-  SpdyStreamRequest request1;
-  std::unique_ptr<SpdyStreamRequest> request2(new SpdyStreamRequest);
-
-  StreamRequestDestroyingCallback callback1;
-  ASSERT_EQ(ERR_IO_PENDING,
-            request1.StartRequest(SPDY_BIDIRECTIONAL_STREAM, session_,
-                                  test_url_, MEDIUM, NetLogWithSource(),
-                                  callback1.MakeCallback()));
-
-  // |callback2| is never called.
-  TestCompletionCallback callback2;
-  ASSERT_EQ(
-      ERR_IO_PENDING,
-      request2->StartRequest(SPDY_BIDIRECTIONAL_STREAM, session_, test_url_,
-                             MEDIUM, NetLogWithSource(), callback2.callback()));
-
-  callback1.SetRequestToDestroy(std::move(request2));
-
-  session_->CloseSessionOnError(ERR_ABORTED, "Aborting session");
-
-  EXPECT_THAT(callback1.WaitForResult(), IsError(ERR_ABORTED));
-}
-
-// A session receiving a GOAWAY frame with no active streams should close.
-TEST_F(SpdySessionTest, GoAwayWithNoActiveStreams) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  SpdySerializedFrame goaway(spdy_util_.ConstructSpdyGoAway(1));
-  MockRead reads[] = {
-      CreateMockRead(goaway, 0),
-  };
-  SequencedSocketData data(reads, arraysize(reads), nullptr, 0);
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  EXPECT_TRUE(HasSpdySession(spdy_session_pool_, key_));
-
-  // Read and process the GOAWAY frame.
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(HasSpdySession(spdy_session_pool_, key_));
-  EXPECT_FALSE(session_);
-}
-
-// A session receiving a GOAWAY frame immediately with no active
-// streams should then close.
-TEST_F(SpdySessionTest, GoAwayImmediatelyWithNoActiveStreams) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  SpdySerializedFrame goaway(spdy_util_.ConstructSpdyGoAway(1));
-  MockRead reads[] = {
-      CreateMockRead(goaway, 0, SYNCHRONOUS), MockRead(ASYNC, 0, 1)  // EOF
-  };
-  SequencedSocketData data(reads, arraysize(reads), nullptr, 0);
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-
-  session_ = TryCreateSpdySessionExpectingFailure(
-      http_session_.get(), key_, ERR_CONNECTION_CLOSED, NetLogWithSource());
-  base::RunLoop().RunUntilIdle();
-
-  EXPECT_FALSE(session_);
-  EXPECT_FALSE(HasSpdySession(spdy_session_pool_, key_));
-  EXPECT_FALSE(data.AllReadDataConsumed());
-}
-
-// A session receiving a GOAWAY frame with active streams should close
-// when the last active stream is closed.
-TEST_F(SpdySessionTest, GoAwayWithActiveStreams) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  SpdySerializedFrame goaway(spdy_util_.ConstructSpdyGoAway(1));
-  MockRead reads[] = {
-      MockRead(ASYNC, ERR_IO_PENDING, 2), CreateMockRead(goaway, 3),
-      MockRead(ASYNC, ERR_IO_PENDING, 4), MockRead(ASYNC, 0, 5)  // EOF
-  };
-  SpdySerializedFrame req1(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 1, MEDIUM, true));
-  SpdySerializedFrame req2(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 3, MEDIUM, true));
-  MockWrite writes[] = {
-      CreateMockWrite(req1, 0), CreateMockWrite(req2, 1),
-  };
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::WeakPtr<SpdyStream> spdy_stream1 =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, MEDIUM, NetLogWithSource());
-  test::StreamDelegateDoNothing delegate1(spdy_stream1);
-  spdy_stream1->SetDelegate(&delegate1);
-
-  base::WeakPtr<SpdyStream> spdy_stream2 =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, MEDIUM, NetLogWithSource());
-  test::StreamDelegateDoNothing delegate2(spdy_stream2);
-  spdy_stream2->SetDelegate(&delegate2);
-
-  SpdyHeaderBlock headers(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  SpdyHeaderBlock headers2(headers.Clone());
-
-  spdy_stream1->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND);
-  spdy_stream2->SendRequestHeaders(std::move(headers2), NO_MORE_DATA_TO_SEND);
-
-  base::RunLoop().RunUntilIdle();
-
-  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.Resume();
-  base::RunLoop().RunUntilIdle();
-
-  EXPECT_FALSE(HasSpdySession(spdy_session_pool_, key_));
-
-  EXPECT_FALSE(session_->IsStreamActive(3));
-  EXPECT_FALSE(spdy_stream2);
-  EXPECT_TRUE(session_->IsStreamActive(1));
-
-  EXPECT_TRUE(session_->IsGoingAway());
-
-  // Should close the session.
-  spdy_stream1->Close();
-  EXPECT_FALSE(spdy_stream1);
-
-  EXPECT_TRUE(session_);
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(session_);
-}
-
-// Regression test for https://crbug.com/547130.
-TEST_F(SpdySessionTest, GoAwayWithActiveAndCreatedStream) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  SpdySerializedFrame goaway(spdy_util_.ConstructSpdyGoAway(0));
-  MockRead reads[] = {
-      MockRead(ASYNC, ERR_IO_PENDING, 1), CreateMockRead(goaway, 2),
-  };
-
-  // No |req2|, because the second stream will never get activated.
-  SpdySerializedFrame req1(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 1, MEDIUM, true));
-  MockWrite writes[] = {
-      CreateMockWrite(req1, 0),
-  };
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::WeakPtr<SpdyStream> spdy_stream1 =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, MEDIUM, NetLogWithSource());
-  test::StreamDelegateDoNothing delegate1(spdy_stream1);
-  spdy_stream1->SetDelegate(&delegate1);
-  SpdyHeaderBlock headers1(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  spdy_stream1->SendRequestHeaders(std::move(headers1), NO_MORE_DATA_TO_SEND);
-
-  EXPECT_EQ(0u, spdy_stream1->stream_id());
-
-  // Active stream 1.
-  base::RunLoop().RunUntilIdle();
-  EXPECT_EQ(1u, spdy_stream1->stream_id());
-  EXPECT_TRUE(session_->IsStreamActive(1));
-
-  // Create stream corresponding to the next request.
-  base::WeakPtr<SpdyStream> spdy_stream2 =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, MEDIUM, NetLogWithSource());
-
-  EXPECT_EQ(0u, spdy_stream2->stream_id());
-
-  // Read and process the GOAWAY frame before the second stream could be
-  // activated.
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-
-  EXPECT_FALSE(session_);
-
-  EXPECT_TRUE(data.AllWriteDataConsumed());
-  EXPECT_TRUE(data.AllReadDataConsumed());
-}
-
-// 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_F(SpdySessionTest, GoAwayTwice) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  SpdySerializedFrame goaway1(spdy_util_.ConstructSpdyGoAway(1));
-  SpdySerializedFrame goaway2(spdy_util_.ConstructSpdyGoAway(0));
-  MockRead reads[] = {
-      MockRead(ASYNC, ERR_IO_PENDING, 2), CreateMockRead(goaway1, 3),
-      MockRead(ASYNC, ERR_IO_PENDING, 4), CreateMockRead(goaway2, 5),
-      MockRead(ASYNC, ERR_IO_PENDING, 6), MockRead(ASYNC, 0, 7)  // EOF
-  };
-  SpdySerializedFrame req1(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 1, MEDIUM, true));
-  SpdySerializedFrame req2(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 3, MEDIUM, true));
-  MockWrite writes[] = {
-      CreateMockWrite(req1, 0), CreateMockWrite(req2, 1),
-  };
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::WeakPtr<SpdyStream> spdy_stream1 =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, MEDIUM, NetLogWithSource());
-  test::StreamDelegateDoNothing delegate1(spdy_stream1);
-  spdy_stream1->SetDelegate(&delegate1);
-
-  base::WeakPtr<SpdyStream> spdy_stream2 =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, MEDIUM, NetLogWithSource());
-  test::StreamDelegateDoNothing delegate2(spdy_stream2);
-  spdy_stream2->SetDelegate(&delegate2);
-
-  SpdyHeaderBlock headers(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  SpdyHeaderBlock headers2(headers.Clone());
-
-  spdy_stream1->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND);
-  spdy_stream2->SendRequestHeaders(std::move(headers2), NO_MORE_DATA_TO_SEND);
-
-  base::RunLoop().RunUntilIdle();
-
-  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.Resume();
-  base::RunLoop().RunUntilIdle();
-
-  EXPECT_FALSE(HasSpdySession(spdy_session_pool_, key_));
-
-  EXPECT_FALSE(session_->IsStreamActive(3));
-  EXPECT_FALSE(spdy_stream2);
-  EXPECT_TRUE(session_->IsStreamActive(1));
-  EXPECT_TRUE(session_->IsGoingAway());
-
-  // Read and process the second GOAWAY frame, which should close the
-  // session.
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(session_);
-}
-
-// 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_F(SpdySessionTest, GoAwayWithActiveStreamsThenClose) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  SpdySerializedFrame goaway(spdy_util_.ConstructSpdyGoAway(1));
-  MockRead reads[] = {
-      MockRead(ASYNC, ERR_IO_PENDING, 2), CreateMockRead(goaway, 3),
-      MockRead(ASYNC, ERR_IO_PENDING, 4), MockRead(ASYNC, 0, 5)  // EOF
-  };
-  SpdySerializedFrame req1(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 1, MEDIUM, true));
-  SpdySerializedFrame req2(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 3, MEDIUM, true));
-  MockWrite writes[] = {
-      CreateMockWrite(req1, 0), CreateMockWrite(req2, 1),
-  };
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::WeakPtr<SpdyStream> spdy_stream1 =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, MEDIUM, NetLogWithSource());
-  test::StreamDelegateDoNothing delegate1(spdy_stream1);
-  spdy_stream1->SetDelegate(&delegate1);
-
-  base::WeakPtr<SpdyStream> spdy_stream2 =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, MEDIUM, NetLogWithSource());
-  test::StreamDelegateDoNothing delegate2(spdy_stream2);
-  spdy_stream2->SetDelegate(&delegate2);
-
-  SpdyHeaderBlock headers(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  SpdyHeaderBlock headers2(headers.Clone());
-
-  spdy_stream1->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND);
-  spdy_stream2->SendRequestHeaders(std::move(headers2), NO_MORE_DATA_TO_SEND);
-
-  base::RunLoop().RunUntilIdle();
-
-  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.Resume();
-  base::RunLoop().RunUntilIdle();
-
-  EXPECT_FALSE(HasSpdySession(spdy_session_pool_, key_));
-
-  EXPECT_FALSE(session_->IsStreamActive(3));
-  EXPECT_FALSE(spdy_stream2);
-  EXPECT_TRUE(session_->IsStreamActive(1));
-  EXPECT_TRUE(session_->IsGoingAway());
-
-  session_->CloseSessionOnError(ERR_ABORTED, "Aborting session");
-  EXPECT_FALSE(spdy_stream1);
-
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(session_);
-}
-
-// 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_F(SpdySessionTest, GoAwayWhileDraining) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  SpdySerializedFrame req(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 1, MEDIUM, true));
-  MockWrite writes[] = {
-      CreateMockWrite(req, 0),
-  };
-
-  SpdySerializedFrame resp(spdy_util_.ConstructSpdyGetReply(nullptr, 0, 1));
-  SpdySerializedFrame goaway(spdy_util_.ConstructSpdyGoAway(1));
-  SpdySerializedFrame body(spdy_util_.ConstructSpdyDataFrame(1, true));
-  size_t joint_size = goaway.size() * 2 + body.size();
-
-  // Compose interleaved |goaway| and |body| frames into a single read.
-  std::unique_ptr<char[]> 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);
-  }
-  SpdySerializedFrame joint_frames(buffer.get(), joint_size, false);
-
-  MockRead reads[] = {
-      CreateMockRead(resp, 1), CreateMockRead(joint_frames, 2),
-      MockRead(ASYNC, 0, 3)  // EOF
-  };
-
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::WeakPtr<SpdyStream> spdy_stream =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, MEDIUM, NetLogWithSource());
-  test::StreamDelegateDoNothing delegate(spdy_stream);
-  spdy_stream->SetDelegate(&delegate);
-
-  SpdyHeaderBlock headers(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  spdy_stream->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND);
-
-  base::RunLoop().RunUntilIdle();
-
-  // Stream and session closed gracefully.
-  EXPECT_TRUE(delegate.StreamIsClosed());
-  EXPECT_THAT(delegate.WaitForClose(), IsOk());
-  EXPECT_EQ(kUploadData, delegate.TakeReceivedData());
-  EXPECT_FALSE(session_);
-}
-
-// Try to create a stream after receiving a GOAWAY frame. It should
-// fail.
-TEST_F(SpdySessionTest, CreateStreamAfterGoAway) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  SpdySerializedFrame goaway(spdy_util_.ConstructSpdyGoAway(1));
-  MockRead reads[] = {
-      MockRead(ASYNC, ERR_IO_PENDING, 1), CreateMockRead(goaway, 2),
-      MockRead(ASYNC, ERR_IO_PENDING, 3), MockRead(ASYNC, 0, 4)  // EOF
-  };
-  SpdySerializedFrame req(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 1, MEDIUM, true));
-  MockWrite writes[] = {
-      CreateMockWrite(req, 0),
-  };
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::WeakPtr<SpdyStream> spdy_stream =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, MEDIUM, NetLogWithSource());
-  test::StreamDelegateDoNothing delegate(spdy_stream);
-  spdy_stream->SetDelegate(&delegate);
-
-  SpdyHeaderBlock headers(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  spdy_stream->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND);
-
-  base::RunLoop().RunUntilIdle();
-
-  EXPECT_EQ(1u, spdy_stream->stream_id());
-
-  EXPECT_TRUE(HasSpdySession(spdy_session_pool_, key_));
-
-  // Read and process the GOAWAY frame.
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-
-  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_,
-                                       test_url_, MEDIUM, NetLogWithSource(),
-                                       CompletionCallback());
-  EXPECT_THAT(rv, IsError(ERR_FAILED));
-
-  EXPECT_TRUE(session_);
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(session_);
-}
-
-// Receiving a HEADERS frame after a GOAWAY frame should result in
-// the stream being refused.
-TEST_F(SpdySessionTest, HeadersAfterGoAway) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  SpdySerializedFrame goaway(spdy_util_.ConstructSpdyGoAway(1));
-  SpdySerializedFrame push(
-      spdy_util_.ConstructSpdyPush(nullptr, 0, 2, 1, kDefaultUrl));
-  MockRead reads[] = {
-      MockRead(ASYNC, ERR_IO_PENDING, 1), CreateMockRead(goaway, 2),
-      MockRead(ASYNC, ERR_IO_PENDING, 3), CreateMockRead(push, 4),
-      MockRead(ASYNC, 0, 6)  // EOF
-  };
-  SpdySerializedFrame req(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 1, MEDIUM, true));
-  SpdySerializedFrame rst(
-      spdy_util_.ConstructSpdyRstStream(2, ERROR_CODE_REFUSED_STREAM));
-  MockWrite writes[] = {CreateMockWrite(req, 0), CreateMockWrite(rst, 5)};
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::WeakPtr<SpdyStream> spdy_stream =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, MEDIUM, NetLogWithSource());
-  test::StreamDelegateDoNothing delegate(spdy_stream);
-  spdy_stream->SetDelegate(&delegate);
-
-  SpdyHeaderBlock headers(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  spdy_stream->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND);
-
-  base::RunLoop().RunUntilIdle();
-
-  EXPECT_EQ(1u, spdy_stream->stream_id());
-
-  EXPECT_TRUE(HasSpdySession(spdy_session_pool_, key_));
-
-  // Read and process the GOAWAY frame.
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-
-  EXPECT_FALSE(HasSpdySession(spdy_session_pool_, key_));
-  EXPECT_TRUE(session_->IsStreamActive(1));
-
-  // Read and process the HEADERS frame, the subsequent RST_STREAM,
-  // and EOF.
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(session_);
-}
-
-// A session observing a network change with active streams should close
-// when the last active stream is closed.
-TEST_F(SpdySessionTest, NetworkChangeWithActiveStreams) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  MockRead reads[] = {
-      MockRead(ASYNC, ERR_IO_PENDING, 1), MockRead(ASYNC, 0, 2)  // EOF
-  };
-  SpdySerializedFrame req1(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 1, MEDIUM, true));
-  MockWrite writes[] = {
-      CreateMockWrite(req1, 0),
-  };
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::WeakPtr<SpdyStream> spdy_stream =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, MEDIUM, NetLogWithSource());
-  test::StreamDelegateDoNothing delegate(spdy_stream);
-  spdy_stream->SetDelegate(&delegate);
-
-  SpdyHeaderBlock headers(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-
-  spdy_stream->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND);
-
-  base::RunLoop().RunUntilIdle();
-
-  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_FALSE(spdy_stream);
-
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(session_);
-}
-
-TEST_F(SpdySessionTest, ClientPing) {
-  session_deps_.enable_ping = true;
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  SpdySerializedFrame read_ping(spdy_util_.ConstructSpdyPing(1, true));
-  MockRead reads[] = {
-      CreateMockRead(read_ping, 1), MockRead(ASYNC, ERR_IO_PENDING, 2),
-      MockRead(ASYNC, 0, 3)  // EOF
-  };
-  SpdySerializedFrame write_ping(spdy_util_.ConstructSpdyPing(1, false));
-  MockWrite writes[] = {
-      CreateMockWrite(write_ping, 0),
-  };
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::WeakPtr<SpdyStream> spdy_stream1 =
-      CreateStreamSynchronously(SPDY_BIDIRECTIONAL_STREAM, session_, test_url_,
-                                MEDIUM, NetLogWithSource());
-  ASSERT_TRUE(spdy_stream1);
-  test::StreamDelegateSendImmediate delegate(spdy_stream1, nullptr);
-  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();
-
-  base::RunLoop().RunUntilIdle();
-
-  session_->CheckPingStatus(before_ping_time);
-
-  EXPECT_EQ(0, session_->pings_in_flight());
-  EXPECT_GE(session_->next_ping_id(), 1U);
-  EXPECT_FALSE(session_->check_ping_status_pending());
-  EXPECT_GE(session_->last_activity_time(), before_ping_time);
-
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-
-  EXPECT_THAT(delegate.WaitForClose(), IsError(ERR_CONNECTION_CLOSED));
-
-  EXPECT_FALSE(HasSpdySession(spdy_session_pool_, key_));
-  EXPECT_FALSE(session_);
-}
-
-TEST_F(SpdySessionTest, ServerPing) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  SpdySerializedFrame read_ping(spdy_util_.ConstructSpdyPing(2, false));
-  MockRead reads[] = {
-      CreateMockRead(read_ping), MockRead(SYNCHRONOUS, 0, 0)  // EOF
-  };
-  SpdySerializedFrame write_ping(spdy_util_.ConstructSpdyPing(2, true));
-  MockWrite writes[] = {
-      CreateMockWrite(write_ping),
-  };
-  StaticSocketDataProvider data(
-      reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::WeakPtr<SpdyStream> spdy_stream1 =
-      CreateStreamSynchronously(SPDY_BIDIRECTIONAL_STREAM, session_, test_url_,
-                                MEDIUM, NetLogWithSource());
-  ASSERT_TRUE(spdy_stream1);
-  test::StreamDelegateSendImmediate delegate(spdy_stream1, nullptr);
-  spdy_stream1->SetDelegate(&delegate);
-
-  // Flush the read completion task.
-  base::RunLoop().RunUntilIdle();
-
-  EXPECT_FALSE(HasSpdySession(spdy_session_pool_, key_));
-
-  EXPECT_FALSE(session_);
-  EXPECT_FALSE(spdy_stream1);
-}
-
-// 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_F(SpdySessionTest, PingAndWriteLoop) {
-  session_deps_.enable_ping = true;
-  session_deps_.time_func = TheNearFuture;
-
-  SpdySerializedFrame write_ping(spdy_util_.ConstructSpdyPing(1, false));
-  SpdySerializedFrame req(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 1, LOWEST, true));
-  MockWrite writes[] = {
-      CreateMockWrite(req, 0), CreateMockWrite(write_ping, 1),
-  };
-
-  MockRead reads[] = {
-      MockRead(ASYNC, ERR_IO_PENDING, 2), MockRead(ASYNC, 0, 3)  // EOF
-  };
-
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::WeakPtr<SpdyStream> spdy_stream =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, LOWEST, NetLogWithSource());
-  test::StreamDelegateDoNothing delegate(spdy_stream);
-  spdy_stream->SetDelegate(&delegate);
-
-  SpdyHeaderBlock headers(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  spdy_stream->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND);
-
-  // Shift time so that a ping will be sent out.
-  g_time_delta = base::TimeDelta::FromSeconds(11);
-
-  base::RunLoop().RunUntilIdle();
-  session_->CloseSessionOnError(ERR_ABORTED, "Aborting");
-
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(session_);
-}
-
-TEST_F(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.
-
-  SpdySerializedFrame req1(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, kLastStreamId - 2, MEDIUM, true));
-  SpdySerializedFrame req2(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, kLastStreamId, MEDIUM, true));
-
-  MockWrite writes[] = {
-      CreateMockWrite(req1, 0), CreateMockWrite(req2, 1),
-  };
-
-  SpdySerializedFrame resp1(
-      spdy_util_.ConstructSpdyGetReply(nullptr, 0, kLastStreamId - 2));
-  SpdySerializedFrame resp2(
-      spdy_util_.ConstructSpdyGetReply(nullptr, 0, kLastStreamId));
-
-  SpdySerializedFrame body1(
-      spdy_util_.ConstructSpdyDataFrame(kLastStreamId - 2, true));
-  SpdySerializedFrame body2(
-      spdy_util_.ConstructSpdyDataFrame(kLastStreamId, true));
-
-  MockRead reads[] = {
-      CreateMockRead(resp1, 2),           CreateMockRead(resp2, 3),
-      MockRead(ASYNC, ERR_IO_PENDING, 4), CreateMockRead(body1, 5),
-      CreateMockRead(body2, 6),           MockRead(ASYNC, 0, 7)  // EOF
-  };
-
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  // 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).
-  base::WeakPtr<SpdyStream> stream1 =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, MEDIUM, NetLogWithSource());
-  test::StreamDelegateDoNothing delegate1(stream1);
-  stream1->SetDelegate(&delegate1);
-
-  base::WeakPtr<SpdyStream> stream2 =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, MEDIUM, NetLogWithSource());
-  test::StreamDelegateDoNothing delegate2(stream2);
-  stream2->SetDelegate(&delegate2);
-
-  base::WeakPtr<SpdyStream> stream3 =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, MEDIUM, NetLogWithSource());
-  test::StreamDelegateDoNothing delegate3(stream3);
-  stream3->SetDelegate(&delegate3);
-
-  SpdyStreamRequest request4;
-  TestCompletionCallback callback4;
-  EXPECT_EQ(
-      ERR_IO_PENDING,
-      request4.StartRequest(SPDY_REQUEST_RESPONSE_STREAM, session_, test_url_,
-                            MEDIUM, NetLogWithSource(), 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(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl),
-                              NO_MORE_DATA_TO_SEND);
-  base::RunLoop().RunUntilIdle();
-
-  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(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl),
-                              NO_MORE_DATA_TO_SEND);
-  base::RunLoop().RunUntilIdle();
-
-  // 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_THAT(delegate3.WaitForClose(), IsError(ERR_ABORTED));
-  EXPECT_THAT(callback4.WaitForResult(), IsError(ERR_ABORTED));
-  EXPECT_EQ(0u, session_->num_created_streams());
-  EXPECT_EQ(0u, session_->pending_create_stream_queue_size(MEDIUM));
-
-  // Read responses on remaining active streams.
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_THAT(delegate1.WaitForClose(), IsOk());
-  EXPECT_EQ(kUploadData, delegate1.TakeReceivedData());
-  EXPECT_THAT(delegate2.WaitForClose(), IsOk());
-  EXPECT_EQ(kUploadData, delegate2.TakeReceivedData());
-
-  // Session was destroyed.
-  EXPECT_FALSE(session_);
-}
-
-// Regression test for https://crbug.com/481009.
-TEST_F(SpdySessionTest, MaxConcurrentStreamsZero) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  // Receive SETTINGS frame that sets max_concurrent_streams to zero.
-  SettingsMap settings_zero;
-  settings_zero[SETTINGS_MAX_CONCURRENT_STREAMS] = 0;
-  SpdySerializedFrame settings_frame_zero(
-      spdy_util_.ConstructSpdySettings(settings_zero));
-
-  // Acknowledge it.
-  SpdySerializedFrame settings_ack0(spdy_util_.ConstructSpdySettingsAck());
-
-  // Receive SETTINGS frame that sets max_concurrent_streams to one.
-  SettingsMap settings_one;
-  settings_one[SETTINGS_MAX_CONCURRENT_STREAMS] = 1;
-  SpdySerializedFrame settings_frame_one(
-      spdy_util_.ConstructSpdySettings(settings_one));
-
-  // Acknowledge it.
-  SpdySerializedFrame settings_ack1(spdy_util_.ConstructSpdySettingsAck());
-
-  // Request and response.
-  SpdySerializedFrame req(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 1, MEDIUM, true));
-
-  SpdySerializedFrame resp(spdy_util_.ConstructSpdyGetReply(nullptr, 0, 1));
-
-  SpdySerializedFrame body(spdy_util_.ConstructSpdyDataFrame(1, true));
-
-  MockRead reads[] = {CreateMockRead(settings_frame_zero, 0),
-                      MockRead(ASYNC, ERR_IO_PENDING, 2),
-                      CreateMockRead(settings_frame_one, 3),
-                      CreateMockRead(resp, 6),
-                      CreateMockRead(body, 7),
-                      MockRead(ASYNC, 0, 8)};
-
-  MockWrite writes[] = {CreateMockWrite(settings_ack0, 1),
-                        CreateMockWrite(settings_ack1, 4),
-                        CreateMockWrite(req, 5)};
-
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  // Create session.
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  // Receive SETTINGS frame that sets max_concurrent_streams to zero.
-  base::RunLoop().RunUntilIdle();
-  EXPECT_EQ(0u, session_->max_concurrent_streams_);
-
-  // Start request.
-  SpdyStreamRequest request;
-  TestCompletionCallback callback;
-  int rv =
-      request.StartRequest(SPDY_REQUEST_RESPONSE_STREAM, session_, test_url_,
-                           MEDIUM, NetLogWithSource(), callback.callback());
-  EXPECT_THAT(rv, IsError(ERR_IO_PENDING));
-
-  // Stream is stalled.
-  EXPECT_EQ(1u, session_->pending_create_stream_queue_size(MEDIUM));
-  EXPECT_EQ(0u, session_->num_created_streams());
-
-  // Receive SETTINGS frame that sets max_concurrent_streams to one.
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_EQ(1u, session_->max_concurrent_streams_);
-
-  // Stream is created.
-  EXPECT_EQ(0u, session_->pending_create_stream_queue_size(MEDIUM));
-  EXPECT_EQ(1u, session_->num_created_streams());
-
-  EXPECT_THAT(callback.WaitForResult(), IsOk());
-
-  // Send request.
-  base::WeakPtr<SpdyStream> stream = request.ReleaseStream();
-  test::StreamDelegateDoNothing delegate(stream);
-  stream->SetDelegate(&delegate);
-  SpdyHeaderBlock headers(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  stream->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND);
-
-  EXPECT_THAT(delegate.WaitForClose(), IsOk());
-  EXPECT_EQ("hello!", delegate.TakeReceivedData());
-
-  // Finish async network reads/writes.
-  base::RunLoop().RunUntilIdle();
-  EXPECT_TRUE(data.AllWriteDataConsumed());
-  EXPECT_TRUE(data.AllReadDataConsumed());
-
-  // Session is destroyed.
-  EXPECT_FALSE(session_);
-}
-
-// 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_F(SpdySessionTest, UnstallRacesWithStreamCreation) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  MockRead reads[] = {
-      MockRead(SYNCHRONOUS, ERR_IO_PENDING)  // Stall forever.
-  };
-
-  StaticSocketDataProvider data(reads, arraysize(reads), nullptr, 0);
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  // Fix max_concurrent_streams to allow for one open stream.
-  session_->max_concurrent_streams_ = 1;
-
-  // Create two streams: one synchronously, and one which stalls.
-  base::WeakPtr<SpdyStream> stream1 =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, MEDIUM, NetLogWithSource());
-
-  SpdyStreamRequest request2;
-  TestCompletionCallback callback2;
-  EXPECT_EQ(
-      ERR_IO_PENDING,
-      request2.StartRequest(SPDY_REQUEST_RESPONSE_STREAM, session_, test_url_,
-                            MEDIUM, NetLogWithSource(), 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<SpdyStream> stream3 =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, MEDIUM, NetLogWithSource());
-
-  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::RunLoop().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::RunLoop().RunUntilIdle();
-
-  EXPECT_EQ(1u, session_->num_created_streams());
-  EXPECT_EQ(0u, session_->pending_create_stream_queue_size(MEDIUM));
-  EXPECT_THAT(callback2.WaitForResult(), IsOk());
-}
-
-TEST_F(SpdySessionTest, CancelPushAfterSessionGoesAway) {
-  base::HistogramTester histogram_tester;
-  session_deps_.host_resolver->set_synchronous_mode(true);
-  session_deps_.time_func = TheNearFuture;
-
-  SpdySerializedFrame req(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 1, MEDIUM, true));
-  SpdySerializedFrame priority_a(
-      spdy_util_.ConstructSpdyPriority(2, 1, IDLE, true));
-  SpdySerializedFrame priority_b(
-      spdy_util_.ConstructSpdyPriority(4, 2, IDLE, true));
-  SpdySerializedFrame rst_a(
-      spdy_util_.ConstructSpdyRstStream(2, ERROR_CODE_REFUSED_STREAM));
-  MockWrite writes[] = {
-      CreateMockWrite(req, 0), CreateMockWrite(priority_a, 2),
-      CreateMockWrite(priority_b, 6), CreateMockWrite(rst_a, 7),
-  };
-
-  SpdySerializedFrame push_a(spdy_util_.ConstructSpdyPush(
-      nullptr, 0, 2, 1, "https://www.example.org/a.dat"));
-  SpdySerializedFrame push_a_body(spdy_util_.ConstructSpdyDataFrame(2, false));
-  // In ascii "0" < "a". We use it to verify that we properly handle std::map
-  // iterators inside. See http://crbug.com/443490
-  SpdySerializedFrame push_b(spdy_util_.ConstructSpdyPush(
-      nullptr, 0, 4, 1, "https://www.example.org/0.dat"));
-  MockRead reads[] = {
-      CreateMockRead(push_a, 1),          CreateMockRead(push_a_body, 3),
-      MockRead(ASYNC, ERR_IO_PENDING, 4), CreateMockRead(push_b, 5),
-      MockRead(ASYNC, ERR_IO_PENDING, 8), MockRead(ASYNC, 0, 9)  // EOF
-  };
-
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  // Process the principal request, and the first push stream request & body.
-  base::WeakPtr<SpdyStream> spdy_stream =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, MEDIUM, NetLogWithSource());
-  test::StreamDelegateDoNothing delegate(spdy_stream);
-  spdy_stream->SetDelegate(&delegate);
-
-  SpdyHeaderBlock headers(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  spdy_stream->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND);
-
-  base::RunLoop().RunUntilIdle();
-
-  // Verify that there is one unclaimed push stream.
-  EXPECT_EQ(1u, session_->num_unclaimed_pushed_streams());
-  EXPECT_EQ(1u, session_->count_unclaimed_pushed_streams_for_url(
-                    GURL("https://www.example.org/a.dat")));
-
-  // Unclaimed push body consumed bytes from the session window.
-  EXPECT_EQ(kDefaultInitialWindowSize - 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 HEADERS,
-  // and verify a RST_STREAM was written.
-  g_time_delta = base::TimeDelta::FromSeconds(301);
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-
-  // Verify that the second pushed stream evicted the first pushed stream.
-  EXPECT_EQ(1u, session_->num_unclaimed_pushed_streams());
-  EXPECT_EQ(1u, session_->count_unclaimed_pushed_streams_for_url(
-                    GURL("https://www.example.org/0.dat")));
-
-  // Verify that the session window reclaimed the evicted stream body.
-  EXPECT_EQ(kDefaultInitialWindowSize, session_->session_recv_window_size_);
-  EXPECT_EQ(kUploadDataSize, session_->session_unacked_recv_window_bytes_);
-  EXPECT_TRUE(session_);
-
-  // Read and process EOF.
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-
-  // Cancel the first push after session goes away. Verify the test doesn't
-  // crash.
-  EXPECT_FALSE(session_);
-  EXPECT_TRUE(
-      test_push_delegate_->CancelPush(GURL("https://www.example.org/a.dat")));
-
-  histogram_tester.ExpectBucketCount("Net.SpdySession.PushedBytes", 6, 1);
-  histogram_tester.ExpectBucketCount("Net.SpdySession.PushedAndUnclaimedBytes",
-                                     6, 1);
-}
-
-TEST_F(SpdySessionTest, CancelPushAfterExpired) {
-  base::HistogramTester histogram_tester;
-  session_deps_.host_resolver->set_synchronous_mode(true);
-  session_deps_.time_func = TheNearFuture;
-
-  SpdySerializedFrame req(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 1, MEDIUM, true));
-  SpdySerializedFrame priority_a(
-      spdy_util_.ConstructSpdyPriority(2, 1, IDLE, true));
-  SpdySerializedFrame priority_b(
-      spdy_util_.ConstructSpdyPriority(4, 2, IDLE, true));
-  SpdySerializedFrame rst_a(
-      spdy_util_.ConstructSpdyRstStream(2, ERROR_CODE_REFUSED_STREAM));
-  MockWrite writes[] = {
-      CreateMockWrite(req, 0), CreateMockWrite(priority_a, 2),
-      CreateMockWrite(priority_b, 6), CreateMockWrite(rst_a, 7),
-  };
-
-  SpdySerializedFrame push_a(spdy_util_.ConstructSpdyPush(
-      nullptr, 0, 2, 1, "https://www.example.org/a.dat"));
-  SpdySerializedFrame push_a_body(spdy_util_.ConstructSpdyDataFrame(2, false));
-  // In ascii "0" < "a". We use it to verify that we properly handle std::map
-  // iterators inside. See http://crbug.com/443490
-  SpdySerializedFrame push_b(spdy_util_.ConstructSpdyPush(
-      nullptr, 0, 4, 1, "https://www.example.org/0.dat"));
-  MockRead reads[] = {
-      CreateMockRead(push_a, 1),          CreateMockRead(push_a_body, 3),
-      MockRead(ASYNC, ERR_IO_PENDING, 4), CreateMockRead(push_b, 5),
-      MockRead(ASYNC, ERR_IO_PENDING, 8), MockRead(ASYNC, 0, 9)  // EOF
-  };
-
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  // Process the principal request, and the first push stream request & body.
-  base::WeakPtr<SpdyStream> spdy_stream =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, MEDIUM, NetLogWithSource());
-  test::StreamDelegateDoNothing delegate(spdy_stream);
-  spdy_stream->SetDelegate(&delegate);
-
-  SpdyHeaderBlock headers(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  spdy_stream->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND);
-
-  base::RunLoop().RunUntilIdle();
-
-  // Verify that there is one unclaimed push stream.
-  EXPECT_EQ(1u, session_->num_unclaimed_pushed_streams());
-  EXPECT_EQ(1u, session_->count_unclaimed_pushed_streams_for_url(
-                    GURL("https://www.example.org/a.dat")));
-
-  // Unclaimed push body consumed bytes from the session window.
-  EXPECT_EQ(kDefaultInitialWindowSize - 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 HEADERS,
-  // and verify a RST_STREAM was written.
-  g_time_delta = base::TimeDelta::FromSeconds(301);
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-
-  // Verify that the second pushed stream evicted the first pushed stream.
-  EXPECT_EQ(1u, session_->num_unclaimed_pushed_streams());
-  EXPECT_EQ(1u, session_->count_unclaimed_pushed_streams_for_url(
-                    GURL("https://www.example.org/0.dat")));
-
-  // Cancel the first push after its expiration.
-  EXPECT_TRUE(
-      test_push_delegate_->CancelPush(GURL("https://www.example.org/a.dat")));
-  EXPECT_EQ(1u, session_->num_unclaimed_pushed_streams());
-  EXPECT_TRUE(session_);
-
-  // Verify that the session window reclaimed the evicted stream body.
-  EXPECT_EQ(kDefaultInitialWindowSize, session_->session_recv_window_size_);
-  EXPECT_EQ(kUploadDataSize, session_->session_unacked_recv_window_bytes_);
-  EXPECT_TRUE(session_);
-
-  // Read and process EOF.
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(session_);
-
-  histogram_tester.ExpectBucketCount("Net.SpdySession.PushedBytes", 6, 1);
-  histogram_tester.ExpectBucketCount("Net.SpdySession.PushedAndUnclaimedBytes",
-                                     6, 1);
-}
-
-TEST_F(SpdySessionTest, CancelPushBeforeClaimed) {
-  base::HistogramTester histogram_tester;
-  session_deps_.host_resolver->set_synchronous_mode(true);
-  session_deps_.time_func = TheNearFuture;
-
-  SpdySerializedFrame req(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 1, MEDIUM, true));
-  SpdySerializedFrame priority_a(
-      spdy_util_.ConstructSpdyPriority(2, 1, IDLE, true));
-  SpdySerializedFrame priority_b(
-      spdy_util_.ConstructSpdyPriority(4, 2, IDLE, true));
-  SpdySerializedFrame rst_a(
-      spdy_util_.ConstructSpdyRstStream(2, ERROR_CODE_REFUSED_STREAM));
-  MockWrite writes[] = {
-      CreateMockWrite(req, 0), CreateMockWrite(priority_a, 2),
-      CreateMockWrite(priority_b, 6), CreateMockWrite(rst_a, 7),
-  };
-
-  SpdySerializedFrame push_a(spdy_util_.ConstructSpdyPush(
-      nullptr, 0, 2, 1, "https://www.example.org/a.dat"));
-  SpdySerializedFrame push_a_body(spdy_util_.ConstructSpdyDataFrame(2, false));
-  // In ascii "0" < "a". We use it to verify that we properly handle std::map
-  // iterators inside. See http://crbug.com/443490
-  SpdySerializedFrame push_b(spdy_util_.ConstructSpdyPush(
-      nullptr, 0, 4, 1, "https://www.example.org/0.dat"));
-  MockRead reads[] = {
-      CreateMockRead(push_a, 1),          CreateMockRead(push_a_body, 3),
-      MockRead(ASYNC, ERR_IO_PENDING, 4), CreateMockRead(push_b, 5),
-      MockRead(ASYNC, ERR_IO_PENDING, 8), MockRead(ASYNC, 0, 9)  // EOF
-  };
-
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  // Process the principal request, and the first push stream request & body.
-  base::WeakPtr<SpdyStream> spdy_stream =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, MEDIUM, NetLogWithSource());
-  test::StreamDelegateDoNothing delegate(spdy_stream);
-  spdy_stream->SetDelegate(&delegate);
-
-  SpdyHeaderBlock headers(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  spdy_stream->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND);
-
-  base::RunLoop().RunUntilIdle();
-
-  // Verify that there is one unclaimed push stream.
-  EXPECT_EQ(1u, session_->num_unclaimed_pushed_streams());
-  EXPECT_EQ(1u, session_->count_unclaimed_pushed_streams_for_url(
-                    GURL("https://www.example.org/a.dat")));
-
-  // Unclaimed push body consumed bytes from the session window.
-  EXPECT_EQ(kDefaultInitialWindowSize - 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 HEADERS,
-  // and verify a RST_STREAM was written.
-  g_time_delta = base::TimeDelta::FromSeconds(301);
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-
-  // Verify that the second pushed stream evicted the first pushed stream.
-  GURL pushed_url("https://www.example.org/0.dat");
-  EXPECT_EQ(1u, session_->num_unclaimed_pushed_streams());
-  EXPECT_EQ(1u, session_->count_unclaimed_pushed_streams_for_url(pushed_url));
-
-  // Verify that the session window reclaimed the evicted stream body.
-  EXPECT_EQ(kDefaultInitialWindowSize, session_->session_recv_window_size_);
-  EXPECT_EQ(kUploadDataSize, session_->session_unacked_recv_window_bytes_);
-
-  EXPECT_TRUE(session_);
-  // Cancel the push before it's claimed.
-  EXPECT_TRUE(test_push_delegate_->CancelPush(pushed_url));
-  EXPECT_EQ(0u, session_->num_unclaimed_pushed_streams());
-  EXPECT_EQ(0u, session_->count_unclaimed_pushed_streams_for_url(pushed_url));
-
-  // Read and process EOF.
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(session_);
-  histogram_tester.ExpectBucketCount("Net.SpdySession.PushedBytes", 6, 1);
-  histogram_tester.ExpectBucketCount("Net.SpdySession.PushedAndUnclaimedBytes",
-                                     6, 1);
-}
-
-TEST_F(SpdySessionTest, DeleteExpiredPushStreams) {
-  base::HistogramTester histogram_tester;
-  session_deps_.host_resolver->set_synchronous_mode(true);
-  session_deps_.time_func = TheNearFuture;
-
-  SpdySerializedFrame req(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 1, MEDIUM, true));
-  SpdySerializedFrame priority_a(
-      spdy_util_.ConstructSpdyPriority(2, 1, IDLE, true));
-  SpdySerializedFrame priority_b(
-      spdy_util_.ConstructSpdyPriority(4, 2, IDLE, true));
-  SpdySerializedFrame rst_a(
-      spdy_util_.ConstructSpdyRstStream(2, ERROR_CODE_REFUSED_STREAM));
-  MockWrite writes[] = {
-      CreateMockWrite(req, 0), CreateMockWrite(priority_a, 2),
-      CreateMockWrite(priority_b, 6), CreateMockWrite(rst_a, 7),
-  };
-
-  SpdySerializedFrame push_a(spdy_util_.ConstructSpdyPush(
-      nullptr, 0, 2, 1, "https://www.example.org/a.dat"));
-  SpdySerializedFrame push_a_body(spdy_util_.ConstructSpdyDataFrame(2, false));
-  // In ascii "0" < "a". We use it to verify that we properly handle std::map
-  // iterators inside. See http://crbug.com/443490
-  SpdySerializedFrame push_b(spdy_util_.ConstructSpdyPush(
-      nullptr, 0, 4, 1, "https://www.example.org/0.dat"));
-  MockRead reads[] = {
-      CreateMockRead(push_a, 1),          CreateMockRead(push_a_body, 3),
-      MockRead(ASYNC, ERR_IO_PENDING, 4), CreateMockRead(push_b, 5),
-      MockRead(ASYNC, ERR_IO_PENDING, 8), MockRead(ASYNC, 0, 9)  // EOF
-  };
-
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  // Process the principal request, and the first push stream request & body.
-  base::WeakPtr<SpdyStream> spdy_stream =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, MEDIUM, NetLogWithSource());
-  test::StreamDelegateDoNothing delegate(spdy_stream);
-  spdy_stream->SetDelegate(&delegate);
-
-  SpdyHeaderBlock headers(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  spdy_stream->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND);
-
-  base::RunLoop().RunUntilIdle();
-
-  // Verify that there is one unclaimed push stream.
-  EXPECT_EQ(1u, session_->num_unclaimed_pushed_streams());
-  EXPECT_EQ(1u, session_->count_unclaimed_pushed_streams_for_url(
-                    GURL("https://www.example.org/a.dat")));
-
-  // Unclaimed push body consumed bytes from the session window.
-  EXPECT_EQ(kDefaultInitialWindowSize - 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 HEADERS,
-  // and verify a RST_STREAM was written.
-  g_time_delta = base::TimeDelta::FromSeconds(301);
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-
-  // Verify that the second pushed stream evicted the first pushed stream.
-  EXPECT_EQ(1u, session_->num_unclaimed_pushed_streams());
-  EXPECT_EQ(1u, session_->count_unclaimed_pushed_streams_for_url(
-                    GURL("https://www.example.org/0.dat")));
-
-  // Verify that the session window reclaimed the evicted stream body.
-  EXPECT_EQ(kDefaultInitialWindowSize, session_->session_recv_window_size_);
-  EXPECT_EQ(kUploadDataSize, session_->session_unacked_recv_window_bytes_);
-
-  // Read and process EOF.
-  EXPECT_TRUE(session_);
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(session_);
-  histogram_tester.ExpectBucketCount("Net.SpdySession.PushedBytes", 6, 1);
-  histogram_tester.ExpectBucketCount("Net.SpdySession.PushedAndUnclaimedBytes",
-                                     6, 1);
-}
-
-TEST_F(SpdySessionTest, MetricsCollectionOnPushStreams) {
-  base::HistogramTester histogram_tester;
-  session_deps_.host_resolver->set_synchronous_mode(true);
-  session_deps_.time_func = TheNearFuture;
-
-  SpdySerializedFrame req(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 1, MEDIUM, true));
-  SpdySerializedFrame priority_a(
-      spdy_util_.ConstructSpdyPriority(2, 1, IDLE, true));
-  SpdySerializedFrame priority_b(
-      spdy_util_.ConstructSpdyPriority(4, 2, IDLE, true));
-  SpdySerializedFrame priority_c(
-      spdy_util_.ConstructSpdyPriority(6, 4, IDLE, true));
-  SpdySerializedFrame rst_a(
-      spdy_util_.ConstructSpdyRstStream(2, ERROR_CODE_REFUSED_STREAM));
-  MockWrite writes[] = {
-      CreateMockWrite(req, 0),         CreateMockWrite(priority_a, 2),
-      CreateMockWrite(priority_b, 6),  CreateMockWrite(rst_a, 7),
-      CreateMockWrite(priority_c, 10),
-  };
-
-  SpdySerializedFrame push_a(spdy_util_.ConstructSpdyPush(
-      nullptr, 0, 2, 1, "https://www.example.org/a.dat"));
-  SpdySerializedFrame push_a_body(spdy_util_.ConstructSpdyDataFrame(2, false));
-  // In ascii "0" < "a". We use it to verify that we properly handle std::map
-  // iterators inside. See http://crbug.com/443490
-  SpdySerializedFrame push_b(spdy_util_.ConstructSpdyPush(
-      nullptr, 0, 4, 1, "https://www.example.org/0.dat"));
-  SpdySerializedFrame push_c(spdy_util_.ConstructSpdyPush(
-      nullptr, 0, 6, 1, "https://www.example.org/1.dat"));
-  SpdySerializedFrame push_c_body(spdy_util_.ConstructSpdyDataFrame(6, false));
-
-  MockRead reads[] = {
-      CreateMockRead(push_a, 1),
-      CreateMockRead(push_a_body, 3),
-      MockRead(ASYNC, ERR_IO_PENDING, 4),
-      CreateMockRead(push_b, 5),
-      MockRead(ASYNC, ERR_IO_PENDING, 8),
-      CreateMockRead(push_c, 9),
-      CreateMockRead(push_c_body, 11),
-      MockRead(ASYNC, ERR_IO_PENDING, 12),
-      MockRead(ASYNC, 0, 13)  // EOF
-  };
-
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  // Process the principal request, and the first push stream request & body.
-  base::WeakPtr<SpdyStream> spdy_stream =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, MEDIUM, NetLogWithSource());
-  test::StreamDelegateDoNothing delegate(spdy_stream);
-  spdy_stream->SetDelegate(&delegate);
-
-  SpdyHeaderBlock headers(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  spdy_stream->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND);
-
-  base::RunLoop().RunUntilIdle();
-
-  // Verify that there is one unclaimed push stream.
-  EXPECT_EQ(1u, session_->num_unclaimed_pushed_streams());
-  EXPECT_EQ(1u, session_->count_unclaimed_pushed_streams_for_url(
-                    GURL("https://www.example.org/a.dat")));
-
-  // Unclaimed push body consumed bytes from the session window.
-  EXPECT_EQ(kDefaultInitialWindowSize - 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 HEADERS,
-  // and verify a RST_STREAM was written.
-  g_time_delta = base::TimeDelta::FromSeconds(300);
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-
-  // Verify that the second pushed stream evicted the first pushed stream.
-  EXPECT_EQ(1u, session_->num_unclaimed_pushed_streams());
-  EXPECT_EQ(1u, session_->count_unclaimed_pushed_streams_for_url(
-                    GURL("https://www.example.org/0.dat")));
-
-  // Verify that the session window reclaimed the evicted stream body.
-  EXPECT_EQ(kDefaultInitialWindowSize, session_->session_recv_window_size_);
-  EXPECT_EQ(kUploadDataSize, session_->session_unacked_recv_window_bytes_);
-
-  // Read the third PUSH, this will not be expired when the test tear down.
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-
-  EXPECT_EQ(2u, session_->num_unclaimed_pushed_streams());
-  EXPECT_EQ(1u, session_->count_unclaimed_pushed_streams_for_url(
-                    GURL("https://www.example.org/1.dat")));
-
-  // Read and process EOF.
-  EXPECT_TRUE(session_);
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(session_);
-  histogram_tester.ExpectBucketCount("Net.SpdySession.PushedBytes", 12, 1);
-  histogram_tester.ExpectBucketCount("Net.SpdySession.PushedAndUnclaimedBytes",
-                                     6, 1);
-}
-
-TEST_F(SpdySessionTest, FailedPing) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  MockRead reads[] = {
-      MockRead(SYNCHRONOUS, ERR_IO_PENDING)  // Stall forever.
-  };
-  SpdySerializedFrame write_ping(spdy_util_.ConstructSpdyPing(1, false));
-  SpdySerializedFrame goaway(spdy_util_.ConstructSpdyGoAway(
-      0, ERROR_CODE_PROTOCOL_ERROR, "Failed ping."));
-  MockWrite writes[] = {CreateMockWrite(write_ping), CreateMockWrite(goaway)};
-
-  StaticSocketDataProvider data(
-      reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::WeakPtr<SpdyStream> spdy_stream1 =
-      CreateStreamSynchronously(SPDY_BIDIRECTIONAL_STREAM, session_, test_url_,
-                                MEDIUM, NetLogWithSource());
-  ASSERT_TRUE(spdy_stream1);
-  test::StreamDelegateSendImmediate delegate(spdy_stream1, nullptr);
-  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(), 1U);
-  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::RunLoop().RunUntilIdle();
-
-  EXPECT_FALSE(session_);
-  EXPECT_FALSE(HasSpdySession(spdy_session_pool_, key_));
-  EXPECT_FALSE(spdy_stream1);
-}
-
-// 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_F(SpdySessionTest, OnSettings) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  const SpdySettingsIds kSpdySettingsIds = SETTINGS_MAX_CONCURRENT_STREAMS;
-
-  SettingsMap new_settings;
-  const uint32_t max_concurrent_streams = kInitialMaxConcurrentStreams + 1;
-  new_settings[kSpdySettingsIds] = max_concurrent_streams;
-  SpdySerializedFrame settings_frame(
-      spdy_util_.ConstructSpdySettings(new_settings));
-  MockRead reads[] = {
-      CreateMockRead(settings_frame, 0), MockRead(ASYNC, ERR_IO_PENDING, 2),
-      MockRead(ASYNC, 0, 3),
-  };
-
-  SpdySerializedFrame settings_ack(spdy_util_.ConstructSpdySettingsAck());
-  MockWrite writes[] = {CreateMockWrite(settings_ack, 1)};
-
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  // Create the maximum number of concurrent streams.
-  for (size_t i = 0; i < kInitialMaxConcurrentStreams; ++i) {
-    base::WeakPtr<SpdyStream> spdy_stream =
-        CreateStreamSynchronously(SPDY_BIDIRECTIONAL_STREAM, session_,
-                                  test_url_, MEDIUM, NetLogWithSource());
-    ASSERT_TRUE(spdy_stream);
-  }
-
-  StreamReleaserCallback stream_releaser;
-  SpdyStreamRequest request;
-  ASSERT_EQ(ERR_IO_PENDING,
-            request.StartRequest(SPDY_BIDIRECTIONAL_STREAM, session_, test_url_,
-                                 MEDIUM, NetLogWithSource(),
-                                 stream_releaser.MakeCallback(&request)));
-
-  base::RunLoop().RunUntilIdle();
-
-  EXPECT_THAT(stream_releaser.WaitForResult(), IsOk());
-
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(session_);
-
-  EXPECT_TRUE(data.AllWriteDataConsumed());
-  EXPECT_TRUE(data.AllReadDataConsumed());
-}
-
-// Create one more stream than maximum number of concurrent streams,
-// so that one of them is pending.  Cancel one stream, which should trigger the
-// creation of the pending stream.  Then cancel that one immediately as well,
-// and make sure this does not lead to a crash.
-// This is a regression test for https://crbug.com/63532.
-TEST_F(SpdySessionTest, CancelPendingCreateStream) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  MockRead reads[] = {
-    MockRead(SYNCHRONOUS, ERR_IO_PENDING)  // Stall forever.
-  };
-
-  StaticSocketDataProvider data(reads, arraysize(reads), nullptr, 0);
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  // Leave room for only one more stream to be created.
-  for (size_t i = 0; i < kInitialMaxConcurrentStreams - 1; ++i) {
-    base::WeakPtr<SpdyStream> spdy_stream =
-        CreateStreamSynchronously(SPDY_BIDIRECTIONAL_STREAM, session_,
-                                  test_url_, MEDIUM, NetLogWithSource());
-    ASSERT_TRUE(spdy_stream);
-  }
-
-  // Create 2 more streams.  First will succeed.  Second will be pending.
-  base::WeakPtr<SpdyStream> spdy_stream1 =
-      CreateStreamSynchronously(SPDY_BIDIRECTIONAL_STREAM, session_, test_url_,
-                                MEDIUM, NetLogWithSource());
-  ASSERT_TRUE(spdy_stream1);
-
-  // Use unique_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.
-  std::unique_ptr<TestCompletionCallback> callback(new TestCompletionCallback);
-
-  SpdyStreamRequest request;
-  ASSERT_THAT(
-      request.StartRequest(SPDY_BIDIRECTIONAL_STREAM, session_, test_url_,
-                           MEDIUM, NetLogWithSource(), callback->callback()),
-      IsError(ERR_IO_PENDING));
-
-  // Release the first one, this will allow the second to be created.
-  spdy_stream1->Cancel();
-  EXPECT_FALSE(spdy_stream1);
-
-  request.CancelRequest();
-  callback.reset();
-
-  // Should not crash when running the pending callback.
-  base::RunLoop().RunUntilIdle();
-}
-
-TEST_F(SpdySessionTest, Initialize) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  MockRead reads[] = {
-    MockRead(ASYNC, 0, 0)  // EOF
-  };
-
-  StaticSocketDataProvider data(reads, arraysize(reads), nullptr, 0);
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-  EXPECT_TRUE(HasSpdySession(spdy_session_pool_, key_));
-
-  // Flush the read completion task.
-  base::RunLoop().RunUntilIdle();
-
-  TestNetLogEntry::List entries;
-  log_.GetEntries(&entries);
-  EXPECT_LT(0u, entries.size());
-
-  // Check that we logged HTTP2_SESSION_INITIALIZED correctly.
-  int pos = ExpectLogContainsSomewhere(
-      entries, 0, NetLogEventType::HTTP2_SESSION_INITIALIZED,
-      NetLogEventPhase::NONE);
-  EXPECT_LT(0, pos);
-
-  TestNetLogEntry entry = entries[pos];
-  NetLogSource socket_source;
-  EXPECT_TRUE(
-      NetLogSource::FromEventParameters(entry.params.get(), &socket_source));
-  EXPECT_TRUE(socket_source.IsValid());
-  EXPECT_NE(log_.bound().source().id, socket_source.id);
-}
-
-TEST_F(SpdySessionTest, NetLogOnSessionGoaway) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  SpdySerializedFrame goaway(
-      spdy_util_.ConstructSpdyGoAway(42, ERROR_CODE_ENHANCE_YOUR_CALM, "foo"));
-  MockRead reads[] = {
-      CreateMockRead(goaway), MockRead(SYNCHRONOUS, 0, 0)  // EOF
-  };
-
-  StaticSocketDataProvider data(reads, arraysize(reads), nullptr, 0);
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-  EXPECT_TRUE(HasSpdySession(spdy_session_pool_, key_));
-
-  // Flush the read completion task.
-  base::RunLoop().RunUntilIdle();
-
-  EXPECT_FALSE(HasSpdySession(spdy_session_pool_, key_));
-  EXPECT_FALSE(session_);
-
-  // Check that the NetLog was filled reasonably.
-  TestNetLogEntry::List entries;
-  log_.GetEntries(&entries);
-  EXPECT_LT(0u, entries.size());
-
-  int pos = ExpectLogContainsSomewhere(
-      entries, 0, NetLogEventType::HTTP2_SESSION_RECV_GOAWAY,
-      NetLogEventPhase::NONE);
-  TestNetLogEntry entry = entries[pos];
-  int last_accepted_stream_id;
-  ASSERT_TRUE(entry.GetIntegerValue("last_accepted_stream_id",
-                                    &last_accepted_stream_id));
-  EXPECT_EQ(42, last_accepted_stream_id);
-  int active_streams;
-  ASSERT_TRUE(entry.GetIntegerValue("active_streams", &active_streams));
-  EXPECT_EQ(0, active_streams);
-  int unclaimed_streams;
-  ASSERT_TRUE(entry.GetIntegerValue("unclaimed_streams", &unclaimed_streams));
-  EXPECT_EQ(0, unclaimed_streams);
-  SpdyString error_code;
-  ASSERT_TRUE(entry.GetStringValue("error_code", &error_code));
-  EXPECT_EQ("11 (ENHANCE_YOUR_CALM)", error_code);
-  SpdyString debug_data;
-  ASSERT_TRUE(entry.GetStringValue("debug_data", &debug_data));
-  EXPECT_EQ("foo", debug_data);
-
-  // Check that we logged SPDY_SESSION_CLOSE correctly.
-  pos = ExpectLogContainsSomewhere(
-      entries, 0, NetLogEventType::HTTP2_SESSION_CLOSE, NetLogEventPhase::NONE);
-  entry = entries[pos];
-  int net_error_code = 0;
-  ASSERT_TRUE(entry.GetNetErrorCode(&net_error_code));
-  EXPECT_THAT(net_error_code, IsOk());
-}
-
-TEST_F(SpdySessionTest, NetLogOnSessionEOF) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  MockRead reads[] = {
-      MockRead(SYNCHRONOUS, 0, 0)  // EOF
-  };
-
-  StaticSocketDataProvider data(reads, arraysize(reads), nullptr, 0);
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-  EXPECT_TRUE(HasSpdySession(spdy_session_pool_, key_));
-
-  // Flush the read completion task.
-  base::RunLoop().RunUntilIdle();
-
-  EXPECT_FALSE(HasSpdySession(spdy_session_pool_, key_));
-  EXPECT_FALSE(session_);
-
-  // Check that the NetLog was filled reasonably.
-  TestNetLogEntry::List entries;
-  log_.GetEntries(&entries);
-  EXPECT_LT(0u, entries.size());
-
-  // Check that we logged SPDY_SESSION_CLOSE correctly.
-  int pos = ExpectLogContainsSomewhere(
-      entries, 0, NetLogEventType::HTTP2_SESSION_CLOSE, NetLogEventPhase::NONE);
-
-  if (pos < static_cast<int>(entries.size())) {
-    TestNetLogEntry entry = entries[pos];
-    int error_code = 0;
-    ASSERT_TRUE(entry.GetNetErrorCode(&error_code));
-    EXPECT_THAT(error_code, IsError(ERR_CONNECTION_CLOSED));
-  } else {
-    ADD_FAILURE();
-  }
-}
-
-TEST_F(SpdySessionTest, HeadersCompressionHistograms) {
-  SpdySerializedFrame req(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 1, MEDIUM, true));
-  MockWrite writes[] = {
-      CreateMockWrite(req, 0),
-  };
-  MockRead reads[] = {
-      MockRead(ASYNC, ERR_IO_PENDING, 1), MockRead(ASYNC, 0, 2)  // EOF
-  };
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::WeakPtr<SpdyStream> spdy_stream =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, MEDIUM, NetLogWithSource());
-  test::StreamDelegateDoNothing delegate(spdy_stream);
-  spdy_stream->SetDelegate(&delegate);
-
-  SpdyHeaderBlock headers(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  spdy_stream->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND);
-
-  // Write request headers & capture resulting histogram update.
-  base::HistogramTester histogram_tester;
-
-  base::RunLoop().RunUntilIdle();
-  // Regression test of compression performance under the request fixture.
-  histogram_tester.ExpectBucketCount("Net.SpdyHeadersCompressionPercentage", 76,
-                                     1);
-
-  // Read and process EOF.
-  EXPECT_TRUE(session_);
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(session_);
-}
-
-// Queue up a low-priority HEADERS followed by a high-priority
-// one. The high priority one should still send first and receive
-// first.
-TEST_F(SpdySessionTest, OutOfOrderHeaders) {
-  // Construct the request.
-  SpdySerializedFrame req_highest(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 1, HIGHEST, true));
-  SpdySerializedFrame req_lowest(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 3, LOWEST, true));
-  MockWrite writes[] = {
-      CreateMockWrite(req_highest, 0), CreateMockWrite(req_lowest, 1),
-  };
-
-  SpdySerializedFrame resp_highest(
-      spdy_util_.ConstructSpdyGetReply(nullptr, 0, 1));
-  SpdySerializedFrame body_highest(spdy_util_.ConstructSpdyDataFrame(1, true));
-  SpdySerializedFrame resp_lowest(
-      spdy_util_.ConstructSpdyGetReply(nullptr, 0, 3));
-  SpdySerializedFrame body_lowest(spdy_util_.ConstructSpdyDataFrame(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);
-
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::WeakPtr<SpdyStream> spdy_stream_lowest =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, LOWEST, NetLogWithSource());
-  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<SpdyStream> spdy_stream_highest =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, HIGHEST, NetLogWithSource());
-  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.
-
-  SpdyHeaderBlock headers_lowest(
-      spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  spdy_stream_lowest->SendRequestHeaders(std::move(headers_lowest),
-                                         NO_MORE_DATA_TO_SEND);
-
-  SpdyHeaderBlock headers_highest(
-      spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  spdy_stream_highest->SendRequestHeaders(std::move(headers_highest),
-                                          NO_MORE_DATA_TO_SEND);
-
-  base::RunLoop().RunUntilIdle();
-
-  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_F(SpdySessionTest, CancelStream) {
-  // 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.
-  SpdySerializedFrame req2(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 1, LOWEST, true));
-  MockWrite writes[] = {
-      CreateMockWrite(req2, 0),
-  };
-
-  SpdySerializedFrame resp2(spdy_util_.ConstructSpdyGetReply(nullptr, 0, 1));
-  SpdySerializedFrame body2(spdy_util_.ConstructSpdyDataFrame(1, true));
-  MockRead reads[] = {
-      CreateMockRead(resp2, 1), MockRead(ASYNC, ERR_IO_PENDING, 2),
-      CreateMockRead(body2, 3), MockRead(ASYNC, 0, 4)  // EOF
-  };
-
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::WeakPtr<SpdyStream> spdy_stream1 =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, HIGHEST, NetLogWithSource());
-  ASSERT_TRUE(spdy_stream1);
-  EXPECT_EQ(0u, spdy_stream1->stream_id());
-  test::StreamDelegateDoNothing delegate1(spdy_stream1);
-  spdy_stream1->SetDelegate(&delegate1);
-
-  base::WeakPtr<SpdyStream> spdy_stream2 =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, LOWEST, NetLogWithSource());
-  ASSERT_TRUE(spdy_stream2);
-  EXPECT_EQ(0u, spdy_stream2->stream_id());
-  test::StreamDelegateDoNothing delegate2(spdy_stream2);
-  spdy_stream2->SetDelegate(&delegate2);
-
-  SpdyHeaderBlock headers(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  spdy_stream1->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND);
-
-  SpdyHeaderBlock headers2(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  spdy_stream2->SendRequestHeaders(std::move(headers2), NO_MORE_DATA_TO_SEND);
-
-  EXPECT_EQ(0u, spdy_stream1->stream_id());
-
-  spdy_stream1->Cancel();
-  EXPECT_FALSE(spdy_stream1);
-
-  EXPECT_EQ(0u, delegate1.stream_id());
-
-  base::RunLoop().RunUntilIdle();
-
-  EXPECT_EQ(0u, delegate1.stream_id());
-  EXPECT_EQ(1u, delegate2.stream_id());
-
-  spdy_stream2->Cancel();
-  EXPECT_FALSE(spdy_stream2);
-}
-
-// 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_F(SpdySessionTest, CloseSessionWithTwoCreatedSelfClosingStreams) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-
-  // No actual data will be sent.
-  MockWrite writes[] = {
-    MockWrite(ASYNC, 0, 1)  // EOF
-  };
-
-  MockRead reads[] = {
-    MockRead(ASYNC, 0, 0)  // EOF
-  };
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::WeakPtr<SpdyStream> spdy_stream1 =
-      CreateStreamSynchronously(SPDY_BIDIRECTIONAL_STREAM, session_, test_url_,
-                                HIGHEST, NetLogWithSource());
-  ASSERT_TRUE(spdy_stream1);
-  EXPECT_EQ(0u, spdy_stream1->stream_id());
-
-  base::WeakPtr<SpdyStream> spdy_stream2 =
-      CreateStreamSynchronously(SPDY_BIDIRECTIONAL_STREAM, session_, test_url_,
-                                LOWEST, NetLogWithSource());
-  ASSERT_TRUE(spdy_stream2);
-  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);
-
-  SpdyHeaderBlock headers(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  spdy_stream1->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND);
-
-  SpdyHeaderBlock headers2(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  spdy_stream2->SendRequestHeaders(std::move(headers2), NO_MORE_DATA_TO_SEND);
-
-  // 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, SpdyString());
-
-  EXPECT_FALSE(spdy_stream1);
-  EXPECT_FALSE(spdy_stream2);
-
-  EXPECT_TRUE(delegate1.StreamIsClosed());
-  EXPECT_TRUE(delegate2.StreamIsClosed());
-
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(session_);
-}
-
-// Create two streams that are set to close each other on close, and
-// then close the session. Nothing should blow up.
-TEST_F(SpdySessionTest, CloseSessionWithTwoCreatedMutuallyClosingStreams) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  SequencedSocketData data(nullptr, 0, nullptr, 0);
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::WeakPtr<SpdyStream> spdy_stream1 =
-      CreateStreamSynchronously(SPDY_BIDIRECTIONAL_STREAM, session_, test_url_,
-                                HIGHEST, NetLogWithSource());
-  ASSERT_TRUE(spdy_stream1);
-  EXPECT_EQ(0u, spdy_stream1->stream_id());
-
-  base::WeakPtr<SpdyStream> spdy_stream2 =
-      CreateStreamSynchronously(SPDY_BIDIRECTIONAL_STREAM, session_, test_url_,
-                                LOWEST, NetLogWithSource());
-  ASSERT_TRUE(spdy_stream2);
-  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);
-
-  SpdyHeaderBlock headers(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  spdy_stream1->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND);
-
-  SpdyHeaderBlock headers2(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  spdy_stream2->SendRequestHeaders(std::move(headers2), NO_MORE_DATA_TO_SEND);
-
-  // 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, SpdyString());
-
-  EXPECT_FALSE(spdy_stream1);
-  EXPECT_FALSE(spdy_stream2);
-
-  EXPECT_TRUE(delegate1.StreamIsClosed());
-  EXPECT_TRUE(delegate2.StreamIsClosed());
-
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(session_);
-}
-
-// Create two streams that are set to re-close themselves on close,
-// activate them, and then close the session. Nothing should blow up.
-TEST_F(SpdySessionTest, CloseSessionWithTwoActivatedSelfClosingStreams) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  SpdySerializedFrame req1(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 1, MEDIUM, true));
-  SpdySerializedFrame req2(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 3, MEDIUM, true));
-  MockWrite writes[] = {
-      CreateMockWrite(req1, 0), CreateMockWrite(req2, 1),
-  };
-
-  MockRead reads[] = {
-      MockRead(ASYNC, ERR_IO_PENDING, 2), MockRead(ASYNC, 0, 3)  // EOF
-  };
-
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::WeakPtr<SpdyStream> spdy_stream1 =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, MEDIUM, NetLogWithSource());
-  ASSERT_TRUE(spdy_stream1);
-  EXPECT_EQ(0u, spdy_stream1->stream_id());
-
-  base::WeakPtr<SpdyStream> spdy_stream2 =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, MEDIUM, NetLogWithSource());
-  ASSERT_TRUE(spdy_stream2);
-  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);
-
-  SpdyHeaderBlock headers(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  spdy_stream1->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND);
-
-  SpdyHeaderBlock headers2(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  spdy_stream2->SendRequestHeaders(std::move(headers2), NO_MORE_DATA_TO_SEND);
-
-  // 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());
-
-  base::RunLoop().RunUntilIdle();
-
-  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, SpdyString());
-
-  EXPECT_FALSE(spdy_stream1);
-  EXPECT_FALSE(spdy_stream2);
-
-  EXPECT_TRUE(delegate1.StreamIsClosed());
-  EXPECT_TRUE(delegate2.StreamIsClosed());
-
-  EXPECT_TRUE(session_);
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(session_);
-}
-
-// Create two streams that are set to close each other on close,
-// activate them, and then close the session. Nothing should blow up.
-TEST_F(SpdySessionTest, CloseSessionWithTwoActivatedMutuallyClosingStreams) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  SpdySerializedFrame req1(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 1, MEDIUM, true));
-  SpdySerializedFrame req2(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 3, MEDIUM, true));
-  MockWrite writes[] = {
-      CreateMockWrite(req1, 0), CreateMockWrite(req2, 1),
-  };
-
-  MockRead reads[] = {
-      MockRead(ASYNC, ERR_IO_PENDING, 2), MockRead(ASYNC, 0, 3)  // EOF
-  };
-
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::WeakPtr<SpdyStream> spdy_stream1 =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, MEDIUM, NetLogWithSource());
-  ASSERT_TRUE(spdy_stream1);
-  EXPECT_EQ(0u, spdy_stream1->stream_id());
-
-  base::WeakPtr<SpdyStream> spdy_stream2 =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, MEDIUM, NetLogWithSource());
-  ASSERT_TRUE(spdy_stream2);
-  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);
-
-  SpdyHeaderBlock headers(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  spdy_stream1->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND);
-
-  SpdyHeaderBlock headers2(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  spdy_stream2->SendRequestHeaders(std::move(headers2), NO_MORE_DATA_TO_SEND);
-
-  // 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());
-
-  base::RunLoop().RunUntilIdle();
-
-  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, SpdyString());
-
-  EXPECT_FALSE(spdy_stream1);
-  EXPECT_FALSE(spdy_stream2);
-
-  EXPECT_TRUE(delegate1.StreamIsClosed());
-  EXPECT_TRUE(delegate2.StreamIsClosed());
-
-  EXPECT_TRUE(session_);
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(session_);
-}
-
-// Delegate that closes a given session when the stream is closed.
-class SessionClosingDelegate : public test::StreamDelegateDoNothing {
- public:
-  SessionClosingDelegate(const base::WeakPtr<SpdyStream>& stream,
-                         const base::WeakPtr<SpdySession>& session_to_close)
-      : StreamDelegateDoNothing(stream),
-        session_to_close_(session_to_close) {}
-
-  ~SessionClosingDelegate() override {}
-
-  void OnClose(int status) override {
-    session_to_close_->CloseSessionOnError(ERR_SPDY_PROTOCOL_ERROR, "Error");
-  }
-
- private:
-  base::WeakPtr<SpdySession> session_to_close_;
-};
-
-// Close an activated stream that closes its session. Nothing should
-// blow up. This is a regression test for https://crbug.com/263691.
-TEST_F(SpdySessionTest, CloseActivatedStreamThatClosesSession) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  SpdySerializedFrame req(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 1, MEDIUM, true));
-  SpdySerializedFrame rst(
-      spdy_util_.ConstructSpdyRstStream(1, ERROR_CODE_CANCEL));
-  SpdySerializedFrame goaway(
-      spdy_util_.ConstructSpdyGoAway(0, ERROR_CODE_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, 3),
-  };
-
-  MockRead reads[] = {
-      MockRead(ASYNC, 0, 2)  // EOF
-  };
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::WeakPtr<SpdyStream> spdy_stream =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, MEDIUM, NetLogWithSource());
-  ASSERT_TRUE(spdy_stream);
-  EXPECT_EQ(0u, spdy_stream->stream_id());
-
-  SessionClosingDelegate delegate(spdy_stream, session_);
-  spdy_stream->SetDelegate(&delegate);
-
-  SpdyHeaderBlock headers(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  spdy_stream->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND);
-
-  EXPECT_EQ(0u, spdy_stream->stream_id());
-
-  base::RunLoop().RunUntilIdle();
-
-  EXPECT_EQ(1u, spdy_stream->stream_id());
-
-  // Ensure we don't crash while closing the stream (which closes the
-  // session).
-  spdy_stream->Cancel();
-
-  EXPECT_FALSE(spdy_stream);
-  EXPECT_TRUE(delegate.StreamIsClosed());
-
-  // Write the RST_STREAM & GOAWAY.
-  base::RunLoop().RunUntilIdle();
-  EXPECT_TRUE(data.AllWriteDataConsumed());
-  EXPECT_TRUE(data.AllReadDataConsumed());
-}
-
-TEST_F(SpdySessionTest, VerifyDomainAuthentication) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  SequencedSocketData data(nullptr, 0, nullptr, 0);
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  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"));
-}
-
-TEST_F(SpdySessionTest, ConnectionPooledWithTlsChannelId) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  SequencedSocketData data(nullptr, 0, nullptr, 0);
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  ssl_.channel_id_sent = true;
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  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_F(SpdySessionTest, CloseTwoStalledCreateStream) {
-  // TODO(rtenneti): Define a helper class/methods and move the common code in
-  // this file.
-  SettingsMap new_settings;
-  const SpdySettingsIds kSpdySettingsIds1 = SETTINGS_MAX_CONCURRENT_STREAMS;
-  const uint32_t max_concurrent_streams = 1;
-  new_settings[kSpdySettingsIds1] = max_concurrent_streams;
-
-  SpdySerializedFrame settings_ack(spdy_util_.ConstructSpdySettingsAck());
-  SpdySerializedFrame req1(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 1, LOWEST, true));
-  spdy_util_.UpdateWithStreamDestruction(1);
-  SpdySerializedFrame req2(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 3, LOWEST, true));
-  spdy_util_.UpdateWithStreamDestruction(3);
-  SpdySerializedFrame req3(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 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.
-  SpdySerializedFrame settings_frame(
-      spdy_util_.ConstructSpdySettings(new_settings));
-
-  SpdySerializedFrame resp1(spdy_util_.ConstructSpdyGetReply(nullptr, 0, 1));
-  SpdySerializedFrame body1(spdy_util_.ConstructSpdyDataFrame(1, true));
-
-  SpdySerializedFrame resp2(spdy_util_.ConstructSpdyGetReply(nullptr, 0, 3));
-  SpdySerializedFrame body2(spdy_util_.ConstructSpdyDataFrame(3, true));
-
-  SpdySerializedFrame resp3(spdy_util_.ConstructSpdyGetReply(nullptr, 0, 5));
-  SpdySerializedFrame body3(spdy_util_.ConstructSpdyDataFrame(5, true));
-
-  MockRead reads[] = {
-      CreateMockRead(settings_frame, 0),
-      CreateMockRead(resp1, 3),
-      CreateMockRead(body1, 4),
-      CreateMockRead(resp2, 6),
-      CreateMockRead(body2, 7),
-      CreateMockRead(resp3, 9),
-      CreateMockRead(body3, 10),
-      MockRead(ASYNC, ERR_IO_PENDING, 11),
-      MockRead(ASYNC, 0, 12)  // EOF
-  };
-
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  // Read the settings frame.
-  base::RunLoop().RunUntilIdle();
-
-  base::WeakPtr<SpdyStream> spdy_stream1 =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, LOWEST, NetLogWithSource());
-  ASSERT_TRUE(spdy_stream1);
-  EXPECT_EQ(0u, spdy_stream1->stream_id());
-  test::StreamDelegateDoNothing delegate1(spdy_stream1);
-  spdy_stream1->SetDelegate(&delegate1);
-
-  TestCompletionCallback callback2;
-  SpdyStreamRequest request2;
-  ASSERT_EQ(
-      ERR_IO_PENDING,
-      request2.StartRequest(SPDY_REQUEST_RESPONSE_STREAM, session_, test_url_,
-                            LOWEST, NetLogWithSource(), callback2.callback()));
-
-  TestCompletionCallback callback3;
-  SpdyStreamRequest request3;
-  ASSERT_EQ(
-      ERR_IO_PENDING,
-      request3.StartRequest(SPDY_REQUEST_RESPONSE_STREAM, session_, test_url_,
-                            LOWEST, NetLogWithSource(), 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));
-
-  SpdyHeaderBlock headers(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  spdy_stream1->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND);
-
-  // Run until 1st stream is activated and then closed.
-  EXPECT_EQ(0u, delegate1.stream_id());
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(spdy_stream1);
-  EXPECT_EQ(1u, delegate1.stream_id());
-
-  EXPECT_EQ(0u, session_->num_active_streams());
-  EXPECT_EQ(1u, session_->pending_create_stream_queue_size(LOWEST));
-
-  // Pump loop for SpdySession::ProcessPendingStreamRequests() to
-  // create the 2nd stream.
-  base::RunLoop().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<SpdyStream> stream2 = request2.ReleaseStream();
-  test::StreamDelegateDoNothing delegate2(stream2);
-  stream2->SetDelegate(&delegate2);
-  SpdyHeaderBlock headers2(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  stream2->SendRequestHeaders(std::move(headers2), NO_MORE_DATA_TO_SEND);
-
-  // Run until 2nd stream is activated and then closed.
-  EXPECT_EQ(0u, delegate2.stream_id());
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(stream2);
-  EXPECT_EQ(3u, delegate2.stream_id());
-
-  EXPECT_EQ(0u, session_->num_active_streams());
-  EXPECT_EQ(0u, session_->pending_create_stream_queue_size(LOWEST));
-
-  // Pump loop for SpdySession::ProcessPendingStreamRequests() to
-  // create the 3rd stream.
-  base::RunLoop().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<SpdyStream> stream3 = request3.ReleaseStream();
-  test::StreamDelegateDoNothing delegate3(stream3);
-  stream3->SetDelegate(&delegate3);
-  SpdyHeaderBlock headers3(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  stream3->SendRequestHeaders(std::move(headers3), NO_MORE_DATA_TO_SEND);
-
-  // Run until 2nd stream is activated and then closed.
-  EXPECT_EQ(0u, delegate3.stream_id());
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(stream3);
-  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.Resume();
-  base::RunLoop().RunUntilIdle();
-}
-
-TEST_F(SpdySessionTest, CancelTwoStalledCreateStream) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  MockRead reads[] = {
-    MockRead(SYNCHRONOUS, ERR_IO_PENDING)  // Stall forever.
-  };
-
-  StaticSocketDataProvider data(reads, arraysize(reads), nullptr, 0);
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  // Leave room for only one more stream to be created.
-  for (size_t i = 0; i < kInitialMaxConcurrentStreams - 1; ++i) {
-    base::WeakPtr<SpdyStream> spdy_stream =
-        CreateStreamSynchronously(SPDY_BIDIRECTIONAL_STREAM, session_,
-                                  test_url_, MEDIUM, NetLogWithSource());
-    ASSERT_TRUE(spdy_stream);
-  }
-
-  base::WeakPtr<SpdyStream> spdy_stream1 =
-      CreateStreamSynchronously(SPDY_BIDIRECTIONAL_STREAM, session_, test_url_,
-                                LOWEST, NetLogWithSource());
-  ASSERT_TRUE(spdy_stream1);
-  EXPECT_EQ(0u, spdy_stream1->stream_id());
-
-  TestCompletionCallback callback2;
-  SpdyStreamRequest request2;
-  ASSERT_EQ(
-      ERR_IO_PENDING,
-      request2.StartRequest(SPDY_BIDIRECTIONAL_STREAM, session_, test_url_,
-                            LOWEST, NetLogWithSource(), callback2.callback()));
-
-  TestCompletionCallback callback3;
-  SpdyStreamRequest request3;
-  ASSERT_EQ(
-      ERR_IO_PENDING,
-      request3.StartRequest(SPDY_BIDIRECTIONAL_STREAM, session_, test_url_,
-                            LOWEST, NetLogWithSource(), 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);
-  spdy_stream1->Cancel();
-  EXPECT_FALSE(spdy_stream1);
-
-  EXPECT_THAT(callback2.WaitForResult(), IsOk());
-  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<SpdyStream> spdy_stream2 = request2.ReleaseStream();
-  spdy_stream2->Cancel();
-  EXPECT_FALSE(spdy_stream2);
-
-  EXPECT_THAT(callback3.WaitForResult(), IsOk());
-  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<SpdyStream> spdy_stream3 = request3.ReleaseStream();
-  spdy_stream3->Cancel();
-  EXPECT_FALSE(spdy_stream3);
-  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_F(SpdySessionTest, ReadDataWithoutYielding) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-  session_deps_.time_func = InstantaneousReads;
-
-  BufferedSpdyFramer framer;
-
-  SpdySerializedFrame req1(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 1, MEDIUM, true));
-  MockWrite writes[] = {
-      CreateMockWrite(req1, 0),
-  };
-
-  // Build buffer of size kYieldAfterBytesRead / 4
-  // (-spdy_data_frame_size).
-  ASSERT_EQ(32 * 1024, kYieldAfterBytesRead);
-  const int kPayloadSize =
-      kYieldAfterBytesRead / 4 - framer.GetFrameHeaderSize();
-  TestDataStream test_stream;
-  scoped_refptr<IOBuffer> payload(new IOBuffer(kPayloadSize));
-  char* payload_data = payload->data();
-  test_stream.GetBytes(payload_data, kPayloadSize);
-
-  SpdySerializedFrame partial_data_frame(spdy_util_.ConstructSpdyDataFrame(
-      1, payload_data, kPayloadSize, /*fin=*/false));
-  SpdySerializedFrame finish_data_frame(spdy_util_.ConstructSpdyDataFrame(
-      1, payload_data, kPayloadSize - 1, /*fin=*/true));
-
-  SpdySerializedFrame resp1(spdy_util_.ConstructSpdyGetReply(nullptr, 0, 1));
-
-  // Write 1 byte less than kMaxReadBytes to check that DoRead reads up to 32k
-  // bytes.
-  MockRead reads[] = {
-      CreateMockRead(resp1, 1),
-      MockRead(ASYNC, ERR_IO_PENDING, 2),
-      CreateMockRead(partial_data_frame, 3),
-      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.
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::WeakPtr<SpdyStream> spdy_stream1 =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, MEDIUM, NetLogWithSource());
-  ASSERT_TRUE(spdy_stream1);
-  EXPECT_EQ(0u, spdy_stream1->stream_id());
-  test::StreamDelegateDoNothing delegate1(spdy_stream1);
-  spdy_stream1->SetDelegate(&delegate1);
-
-  SpdyHeaderBlock headers1(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  spdy_stream1->SendRequestHeaders(std::move(headers1), NO_MORE_DATA_TO_SEND);
-
-  // 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());
-  base::RunLoop().RunUntilIdle();
-  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.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(spdy_stream1);
-
-  // 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.AllWriteDataConsumed());
-  EXPECT_TRUE(data.AllReadDataConsumed());
-}
-
-// Test that SpdySession::DoReadLoop yields if more than
-// |kYieldAfterDurationMilliseconds| has passed.  This test uses a mock time
-// function that makes the response frame look very slow to read.
-TEST_F(SpdySessionTest, TestYieldingSlowReads) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-  session_deps_.time_func = SlowReads;
-
-  SpdySerializedFrame req1(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 1, MEDIUM, true));
-  MockWrite writes[] = {
-      CreateMockWrite(req1, 0),
-  };
-
-  SpdySerializedFrame resp1(spdy_util_.ConstructSpdyGetReply(nullptr, 0, 1));
-
-  MockRead reads[] = {
-      CreateMockRead(resp1, 1), MockRead(ASYNC, 0, 2)  // EOF
-  };
-
-  // Create SpdySession and SpdyStream and send the request.
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::WeakPtr<SpdyStream> spdy_stream1 =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, MEDIUM, NetLogWithSource());
-  ASSERT_TRUE(spdy_stream1);
-  EXPECT_EQ(0u, spdy_stream1->stream_id());
-  test::StreamDelegateDoNothing delegate1(spdy_stream1);
-  spdy_stream1->SetDelegate(&delegate1);
-
-  SpdyHeaderBlock headers1(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  spdy_stream1->SendRequestHeaders(std::move(headers1), NO_MORE_DATA_TO_SEND);
-
-  // Set up the TaskObserver to verify that SpdySession::DoReadLoop posts a
-  // task.
-  SpdySessionTestTaskObserver observer("spdy_session.cc", "DoReadLoop");
-
-  EXPECT_EQ(0u, delegate1.stream_id());
-  EXPECT_EQ(0u, observer.executed_count());
-
-  // Read all the data and verify that SpdySession::DoReadLoop has posted a
-  // task.
-  base::RunLoop().RunUntilIdle();
-  EXPECT_EQ(1u, delegate1.stream_id());
-  EXPECT_FALSE(spdy_stream1);
-
-  // Verify task that the 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.AllWriteDataConsumed());
-  EXPECT_TRUE(data.AllReadDataConsumed());
-}
-
-// Regression test for https://crbug.com/531570.
-// Test the case where DoRead() takes long but returns synchronously.
-TEST_F(SpdySessionTest, TestYieldingSlowSynchronousReads) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-  session_deps_.time_func = SlowReads;
-
-  SpdySerializedFrame req1(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 1, MEDIUM, true));
-  MockWrite writes[] = {
-      CreateMockWrite(req1, 0),
-  };
-
-  SpdySerializedFrame partial_data_frame(
-      spdy_util_.ConstructSpdyDataFrame(1, "foo ", 4, /*fin=*/false));
-  SpdySerializedFrame finish_data_frame(
-      spdy_util_.ConstructSpdyDataFrame(1, "bar", 3, /*fin=*/true));
-
-  SpdySerializedFrame resp1(spdy_util_.ConstructSpdyGetReply(nullptr, 0, 1));
-
-  MockRead reads[] = {
-      CreateMockRead(resp1, 1),
-      MockRead(ASYNC, ERR_IO_PENDING, 2),
-      CreateMockRead(partial_data_frame, 3, ASYNC),
-      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.
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::WeakPtr<SpdyStream> spdy_stream1 =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, MEDIUM, NetLogWithSource());
-  ASSERT_TRUE(spdy_stream1);
-  EXPECT_EQ(0u, spdy_stream1->stream_id());
-  test::StreamDelegateDoNothing delegate1(spdy_stream1);
-  spdy_stream1->SetDelegate(&delegate1);
-
-  SpdyHeaderBlock headers1(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  spdy_stream1->SendRequestHeaders(std::move(headers1), NO_MORE_DATA_TO_SEND);
-
-  // Run until 1st read.
-  EXPECT_EQ(0u, delegate1.stream_id());
-  base::RunLoop().RunUntilIdle();
-  EXPECT_EQ(1u, delegate1.stream_id());
-
-  // Read all the data and verify SpdySession::DoReadLoop has posted a task.
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_EQ("foo foo foo bar", delegate1.TakeReceivedData());
-  EXPECT_FALSE(spdy_stream1);
-
-  EXPECT_TRUE(data.AllWriteDataConsumed());
-  EXPECT_TRUE(data.AllReadDataConsumed());
-}
-
-// 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_F(SpdySessionTest, TestYieldingDuringReadData) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-  session_deps_.time_func = InstantaneousReads;
-
-  BufferedSpdyFramer framer;
-
-  SpdySerializedFrame req1(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 1, MEDIUM, true));
-  MockWrite writes[] = {
-      CreateMockWrite(req1, 0),
-  };
-
-  // Build buffer of size kYieldAfterBytesRead / 4
-  // (-spdy_data_frame_size).
-  ASSERT_EQ(32 * 1024, kYieldAfterBytesRead);
-  const int kPayloadSize =
-      kYieldAfterBytesRead / 4 - framer.GetFrameHeaderSize();
-  TestDataStream test_stream;
-  scoped_refptr<IOBuffer> payload(new IOBuffer(kPayloadSize));
-  char* payload_data = payload->data();
-  test_stream.GetBytes(payload_data, kPayloadSize);
-
-  SpdySerializedFrame partial_data_frame(spdy_util_.ConstructSpdyDataFrame(
-      1, payload_data, kPayloadSize, /*fin=*/false));
-  SpdySerializedFrame finish_data_frame(
-      spdy_util_.ConstructSpdyDataFrame(1, "h", 1, /*fin=*/true));
-
-  SpdySerializedFrame resp1(spdy_util_.ConstructSpdyGetReply(nullptr, 0, 1));
-
-  // Write 1 byte more than kMaxReadBytes to check that DoRead yields.
-  MockRead reads[] = {
-      CreateMockRead(resp1, 1),
-      MockRead(ASYNC, ERR_IO_PENDING, 2),
-      CreateMockRead(partial_data_frame, 3),
-      CreateMockRead(partial_data_frame, 4, SYNCHRONOUS),
-      CreateMockRead(partial_data_frame, 5, SYNCHRONOUS),
-      CreateMockRead(partial_data_frame, 6, SYNCHRONOUS),
-      CreateMockRead(finish_data_frame, 7, SYNCHRONOUS),
-      MockRead(ASYNC, 0, 8)  // EOF
-  };
-
-  // Create SpdySession and SpdyStream and send the request.
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::WeakPtr<SpdyStream> spdy_stream1 =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, MEDIUM, NetLogWithSource());
-  ASSERT_TRUE(spdy_stream1);
-  EXPECT_EQ(0u, spdy_stream1->stream_id());
-  test::StreamDelegateDoNothing delegate1(spdy_stream1);
-  spdy_stream1->SetDelegate(&delegate1);
-
-  SpdyHeaderBlock headers1(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  spdy_stream1->SendRequestHeaders(std::move(headers1), NO_MORE_DATA_TO_SEND);
-
-  // 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());
-  base::RunLoop().RunUntilIdle();
-  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.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(spdy_stream1);
-
-  // 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.AllWriteDataConsumed());
-  EXPECT_TRUE(data.AllReadDataConsumed());
-}
-
-// 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_F(SpdySessionTest, TestYieldingDuringAsyncReadData) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-  session_deps_.time_func = InstantaneousReads;
-
-  BufferedSpdyFramer framer;
-
-  SpdySerializedFrame req1(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 1, MEDIUM, true));
-  MockWrite writes[] = {
-      CreateMockWrite(req1, 0),
-  };
-
-  // Build buffer of size kYieldAfterBytesRead / 4
-  // (-spdy_data_frame_size).
-  ASSERT_EQ(32 * 1024, kYieldAfterBytesRead);
-  TestDataStream test_stream;
-  const int kEightKPayloadSize =
-      kYieldAfterBytesRead / 4 - framer.GetFrameHeaderSize();
-  scoped_refptr<IOBuffer> eightk_payload(new 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<IOBuffer> twok_payload(new IOBuffer(kTwoKPayloadSize));
-  char* twok_payload_data = twok_payload->data();
-  test_stream2.GetBytes(twok_payload_data, kTwoKPayloadSize);
-
-  SpdySerializedFrame eightk_data_frame(spdy_util_.ConstructSpdyDataFrame(
-      1, eightk_payload_data, kEightKPayloadSize, /*fin=*/false));
-  SpdySerializedFrame twok_data_frame(spdy_util_.ConstructSpdyDataFrame(
-      1, twok_payload_data, kTwoKPayloadSize, /*fin=*/false));
-  SpdySerializedFrame finish_data_frame(
-      spdy_util_.ConstructSpdyDataFrame(1, "h", 1, /*fin=*/true));
-
-  SpdySerializedFrame resp1(spdy_util_.ConstructSpdyGetReply(nullptr, 0, 1));
-
-  MockRead reads[] = {
-      CreateMockRead(resp1, 1),
-      MockRead(ASYNC, ERR_IO_PENDING, 2),
-      CreateMockRead(eightk_data_frame, 3),
-      CreateMockRead(eightk_data_frame, 4, SYNCHRONOUS),
-      CreateMockRead(eightk_data_frame, 5, SYNCHRONOUS),
-      CreateMockRead(twok_data_frame, 6, SYNCHRONOUS),
-      CreateMockRead(eightk_data_frame, 7, ASYNC),
-      CreateMockRead(eightk_data_frame, 8, SYNCHRONOUS),
-      CreateMockRead(eightk_data_frame, 9, SYNCHRONOUS),
-      CreateMockRead(eightk_data_frame, 10, SYNCHRONOUS),
-      CreateMockRead(twok_data_frame, 11, SYNCHRONOUS),
-      CreateMockRead(finish_data_frame, 12, SYNCHRONOUS),
-      MockRead(ASYNC, 0, 13)  // EOF
-  };
-
-  // Create SpdySession and SpdyStream and send the request.
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::WeakPtr<SpdyStream> spdy_stream1 =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, MEDIUM, NetLogWithSource());
-  ASSERT_TRUE(spdy_stream1);
-  EXPECT_EQ(0u, spdy_stream1->stream_id());
-  test::StreamDelegateDoNothing delegate1(spdy_stream1);
-  spdy_stream1->SetDelegate(&delegate1);
-
-  SpdyHeaderBlock headers1(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  spdy_stream1->SendRequestHeaders(std::move(headers1), NO_MORE_DATA_TO_SEND);
-
-  // 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());
-  base::RunLoop().RunUntilIdle();
-  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.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(spdy_stream1);
-
-  // 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.AllWriteDataConsumed());
-  EXPECT_TRUE(data.AllReadDataConsumed());
-}
-
-// Send a GoAway frame when SpdySession is in DoReadLoop. Make sure
-// nothing blows up.
-TEST_F(SpdySessionTest, GoAwayWhileInDoReadLoop) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  SpdySerializedFrame req1(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 1, MEDIUM, true));
-  MockWrite writes[] = {
-      CreateMockWrite(req1, 0),
-  };
-
-  SpdySerializedFrame resp1(spdy_util_.ConstructSpdyGetReply(nullptr, 0, 1));
-  SpdySerializedFrame body1(spdy_util_.ConstructSpdyDataFrame(1, true));
-  SpdySerializedFrame goaway(spdy_util_.ConstructSpdyGoAway());
-
-  MockRead reads[] = {
-      CreateMockRead(resp1, 1), MockRead(ASYNC, ERR_IO_PENDING, 2),
-      CreateMockRead(body1, 3), CreateMockRead(goaway, 4),
-  };
-
-  // Create SpdySession and SpdyStream and send the request.
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::WeakPtr<SpdyStream> spdy_stream1 =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, MEDIUM, NetLogWithSource());
-  test::StreamDelegateDoNothing delegate1(spdy_stream1);
-  spdy_stream1->SetDelegate(&delegate1);
-  ASSERT_TRUE(spdy_stream1);
-  EXPECT_EQ(0u, spdy_stream1->stream_id());
-
-  SpdyHeaderBlock headers1(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  spdy_stream1->SendRequestHeaders(std::move(headers1), NO_MORE_DATA_TO_SEND);
-
-  // Run until 1st read.
-  EXPECT_EQ(0u, spdy_stream1->stream_id());
-  base::RunLoop().RunUntilIdle();
-  EXPECT_EQ(1u, spdy_stream1->stream_id());
-
-  // Run until GoAway.
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(spdy_stream1);
-  EXPECT_TRUE(data.AllWriteDataConsumed());
-  EXPECT_TRUE(data.AllReadDataConsumed());
-  EXPECT_FALSE(session_);
-}
-
-// 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_F(SpdySessionTest, ProtocolNegotiation) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  MockRead reads[] = {
-    MockRead(SYNCHRONOUS, 0, 0)  // EOF
-  };
-  StaticSocketDataProvider data(reads, arraysize(reads), nullptr, 0);
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  CreateNetworkSession();
-  session_ = CreateFakeSpdySession(spdy_session_pool_, key_);
-
-  EXPECT_EQ(kDefaultInitialWindowSize, session_->session_send_window_size_);
-  EXPECT_EQ(kDefaultInitialWindowSize, 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_F(SpdySessionTest, CloseOneIdleConnection) {
-  ClientSocketPoolManager::set_max_sockets_per_group(
-      HttpNetworkSession::NORMAL_SOCKET_POOL, 1);
-  ClientSocketPoolManager::set_max_sockets_per_pool(
-      HttpNetworkSession::NORMAL_SOCKET_POOL, 1);
-
-  MockRead reads[] = {
-    MockRead(SYNCHRONOUS, ERR_IO_PENDING)  // Stall forever.
-  };
-  StaticSocketDataProvider data(reads, arraysize(reads), nullptr, 0);
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-
-  TransportClientSocketPool* pool =
-      http_session_->GetTransportSocketPool(
-          HttpNetworkSession::NORMAL_SOCKET_POOL);
-
-  // Create an idle SPDY session.
-  CreateSecureSpdySession();
-  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<TransportSocketParams> params2(new TransportSocketParams(
-      host_port2, false, OnHostResolutionCallback(),
-      TransportSocketParams::COMBINE_CONNECT_AND_WRITE_DEFAULT));
-  std::unique_ptr<ClientSocketHandle> connection2(new ClientSocketHandle);
-  EXPECT_EQ(ERR_IO_PENDING,
-            connection2->Init(host_port2.ToString(), params2, DEFAULT_PRIORITY,
-                              ClientSocketPool::RespectLimits::ENABLED,
-                              callback2.callback(), pool, NetLogWithSource()));
-  EXPECT_TRUE(pool->IsStalled());
-
-  // The socket pool should close the connection asynchronously and establish a
-  // new connection.
-  EXPECT_THAT(callback2.WaitForResult(), IsOk());
-  EXPECT_FALSE(pool->IsStalled());
-  EXPECT_FALSE(session_);
-}
-
-// 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_F(SpdySessionTest, CloseOneIdleConnectionWithAlias) {
-  ClientSocketPoolManager::set_max_sockets_per_group(
-      HttpNetworkSession::NORMAL_SOCKET_POOL, 1);
-  ClientSocketPoolManager::set_max_sockets_per_pool(
-      HttpNetworkSession::NORMAL_SOCKET_POOL, 1);
-
-  MockRead reads[] = {
-    MockRead(SYNCHRONOUS, ERR_IO_PENDING)  // Stall forever.
-  };
-  StaticSocketDataProvider data(reads, arraysize(reads), nullptr, 0);
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  session_deps_.host_resolver->set_synchronous_mode(true);
-  session_deps_.host_resolver->rules()->AddIPLiteralRule(
-      "www.example.org", "192.168.0.2", SpdyString());
-  session_deps_.host_resolver->rules()->AddIPLiteralRule(
-      "mail.example.org", "192.168.0.2", SpdyString());
-  // Not strictly needed.
-  session_deps_.host_resolver->rules()->AddIPLiteralRule("3.com", "192.168.0.3",
-                                                         SpdyString());
-
-  CreateNetworkSession();
-
-  TransportClientSocketPool* pool =
-      http_session_->GetTransportSocketPool(
-          HttpNetworkSession::NORMAL_SOCKET_POOL);
-
-  // Create an idle SPDY session.
-  SpdySessionKey key1(HostPortPair("www.example.org", 80),
-                      ProxyServer::Direct(), PRIVACY_MODE_DISABLED);
-  base::WeakPtr<SpdySession> session1 = ::net::CreateSecureSpdySession(
-      http_session_.get(), key1, NetLogWithSource());
-  EXPECT_FALSE(pool->IsStalled());
-
-  // Set up an alias for the idle SPDY session, increasing its ref count to 2.
-  SpdySessionKey key2(HostPortPair("mail.example.org", 80),
-                      ProxyServer::Direct(), PRIVACY_MODE_DISABLED);
-  HostResolver::RequestInfo info(key2.host_port_pair());
-  AddressList addresses;
-  std::unique_ptr<HostResolver::Request> request;
-  // 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(), &request,
-                                       NetLogWithSource());
-  // Get a session for |key2|, which should return the session created earlier.
-  base::WeakPtr<SpdySession> session2 =
-      spdy_session_pool_->FindAvailableSession(
-          key2, GURL(),
-          /* enable_ip_based_pooling = */ true, NetLogWithSource());
-  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<TransportSocketParams> params3(new TransportSocketParams(
-      host_port3, false, OnHostResolutionCallback(),
-      TransportSocketParams::COMBINE_CONNECT_AND_WRITE_DEFAULT));
-  std::unique_ptr<ClientSocketHandle> connection3(new ClientSocketHandle);
-  EXPECT_EQ(ERR_IO_PENDING,
-            connection3->Init(host_port3.ToString(), params3, DEFAULT_PRIORITY,
-                              ClientSocketPool::RespectLimits::ENABLED,
-                              callback3.callback(), pool, NetLogWithSource()));
-  EXPECT_TRUE(pool->IsStalled());
-
-  // The socket pool should close the connection asynchronously and establish a
-  // new connection.
-  EXPECT_THAT(callback3.WaitForResult(), IsOk());
-  EXPECT_FALSE(pool->IsStalled());
-  EXPECT_FALSE(session1);
-  EXPECT_FALSE(session2);
-}
-
-// 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_F(SpdySessionTest, CloseSessionOnIdleWhenPoolStalled) {
-  ClientSocketPoolManager::set_max_sockets_per_group(
-      HttpNetworkSession::NORMAL_SOCKET_POOL, 1);
-  ClientSocketPoolManager::set_max_sockets_per_pool(
-      HttpNetworkSession::NORMAL_SOCKET_POOL, 1);
-
-  MockRead reads[] = {
-    MockRead(SYNCHRONOUS, ERR_IO_PENDING)  // Stall forever.
-  };
-  SpdySerializedFrame req1(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 1, LOWEST, true));
-  SpdySerializedFrame cancel1(
-      spdy_util_.ConstructSpdyRstStream(1, ERROR_CODE_CANCEL));
-  MockWrite writes[] = {
-      CreateMockWrite(req1, 1), CreateMockWrite(cancel1, 1),
-  };
-  StaticSocketDataProvider data(reads, arraysize(reads),
-                                writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  MockRead http_reads[] = {
-    MockRead(SYNCHRONOUS, ERR_IO_PENDING)  // Stall forever.
-  };
-  StaticSocketDataProvider http_data(http_reads, arraysize(http_reads), nullptr,
-                                     0);
-  session_deps_.socket_factory->AddSocketDataProvider(&http_data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-
-  TransportClientSocketPool* pool =
-      http_session_->GetTransportSocketPool(
-          HttpNetworkSession::NORMAL_SOCKET_POOL);
-
-  // Create a SPDY session.
-  CreateSecureSpdySession();
-  EXPECT_FALSE(pool->IsStalled());
-
-  // Create a stream using the session, and send a request.
-
-  TestCompletionCallback callback1;
-  base::WeakPtr<SpdyStream> spdy_stream1 = CreateStreamSynchronously(
-      SPDY_REQUEST_RESPONSE_STREAM, session_, test_url_, DEFAULT_PRIORITY,
-      NetLogWithSource());
-  ASSERT_TRUE(spdy_stream1.get());
-  test::StreamDelegateDoNothing delegate1(spdy_stream1);
-  spdy_stream1->SetDelegate(&delegate1);
-
-  SpdyHeaderBlock headers1(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  EXPECT_EQ(ERR_IO_PENDING, spdy_stream1->SendRequestHeaders(
-                                std::move(headers1), NO_MORE_DATA_TO_SEND));
-
-  base::RunLoop().RunUntilIdle();
-
-  // 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<TransportSocketParams> params2(new TransportSocketParams(
-      host_port2, false, OnHostResolutionCallback(),
-      TransportSocketParams::COMBINE_CONNECT_AND_WRITE_DEFAULT));
-  std::unique_ptr<ClientSocketHandle> connection2(new ClientSocketHandle);
-  EXPECT_EQ(ERR_IO_PENDING,
-            connection2->Init(host_port2.ToString(), params2, DEFAULT_PRIORITY,
-                              ClientSocketPool::RespectLimits::ENABLED,
-                              callback2.callback(), pool, NetLogWithSource()));
-  EXPECT_TRUE(pool->IsStalled());
-
-  // Running the message loop should cause the socket pool to ask the SPDY
-  // session to close an idle socket, but since the socket is in use, nothing
-  // happens.
-  base::RunLoop().RunUntilIdle();
-  EXPECT_TRUE(pool->IsStalled());
-  EXPECT_FALSE(callback2.have_result());
-
-  // Cancelling the request should result in the session's socket being
-  // closed, since the pool is stalled.
-  ASSERT_TRUE(spdy_stream1.get());
-  spdy_stream1->Cancel();
-  base::RunLoop().RunUntilIdle();
-  ASSERT_FALSE(pool->IsStalled());
-  EXPECT_THAT(callback2.WaitForResult(), IsOk());
-}
-
-// Verify that SpdySessionKey and therefore SpdySession is different when
-// privacy mode is enabled or disabled.
-TEST_F(SpdySessionTest, SpdySessionKeyPrivacyMode) {
-  CreateNetworkSession();
-
-  HostPortPair host_port_pair("www.example.org", 443);
-  SpdySessionKey key_privacy_enabled(host_port_pair, ProxyServer::Direct(),
-                                     PRIVACY_MODE_ENABLED);
-  SpdySessionKey key_privacy_disabled(host_port_pair, ProxyServer::Direct(),
-                                     PRIVACY_MODE_DISABLED);
-
-  EXPECT_FALSE(HasSpdySession(spdy_session_pool_, key_privacy_enabled));
-  EXPECT_FALSE(HasSpdySession(spdy_session_pool_, key_privacy_disabled));
-
-  // Add SpdySession with PrivacyMode Enabled to the pool.
-  base::WeakPtr<SpdySession> session_privacy_enabled =
-      CreateFakeSpdySession(spdy_session_pool_, key_privacy_enabled);
-
-  EXPECT_TRUE(HasSpdySession(spdy_session_pool_, key_privacy_enabled));
-  EXPECT_FALSE(HasSpdySession(spdy_session_pool_, key_privacy_disabled));
-
-  // Add SpdySession with PrivacyMode Disabled to the pool.
-  base::WeakPtr<SpdySession> session_privacy_disabled =
-      CreateFakeSpdySession(spdy_session_pool_, key_privacy_disabled);
-
-  EXPECT_TRUE(HasSpdySession(spdy_session_pool_, key_privacy_enabled));
-  EXPECT_TRUE(HasSpdySession(spdy_session_pool_, key_privacy_disabled));
-
-  session_privacy_enabled->CloseSessionOnError(ERR_ABORTED, SpdyString());
-  EXPECT_FALSE(HasSpdySession(spdy_session_pool_, key_privacy_enabled));
-  EXPECT_TRUE(HasSpdySession(spdy_session_pool_, key_privacy_disabled));
-
-  session_privacy_disabled->CloseSessionOnError(ERR_ABORTED, SpdyString());
-  EXPECT_FALSE(HasSpdySession(spdy_session_pool_, key_privacy_enabled));
-  EXPECT_FALSE(HasSpdySession(spdy_session_pool_, key_privacy_disabled));
-}
-
-// Delegate that creates another stream when its stream is closed.
-class StreamCreatingDelegate : public test::StreamDelegateDoNothing {
- public:
-  StreamCreatingDelegate(const base::WeakPtr<SpdyStream>& stream,
-                         const base::WeakPtr<SpdySession>& session)
-      : StreamDelegateDoNothing(stream),
-        session_(session) {}
-
-  ~StreamCreatingDelegate() override {}
-
-  void OnClose(int status) override {
-    GURL url(kDefaultUrl);
-    ignore_result(CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM,
-                                            session_, url, MEDIUM,
-                                            NetLogWithSource()));
-  }
-
- private:
-  const base::WeakPtr<SpdySession> session_;
-};
-
-// Create another stream in response to a stream being reset. Nothing
-// should blow up. This is a regression test for
-// http://crbug.com/263690 .
-TEST_F(SpdySessionTest, CreateStreamOnStreamReset) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  SpdySerializedFrame req(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 1, MEDIUM, true));
-  MockWrite writes[] = {
-      CreateMockWrite(req, 0),
-  };
-
-  SpdySerializedFrame rst(
-      spdy_util_.ConstructSpdyRstStream(1, ERROR_CODE_REFUSED_STREAM));
-  MockRead reads[] = {
-      MockRead(ASYNC, ERR_IO_PENDING, 1), CreateMockRead(rst, 2),
-      MockRead(ASYNC, ERR_IO_PENDING, 3), MockRead(ASYNC, 0, 4)  // EOF
-  };
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::WeakPtr<SpdyStream> spdy_stream =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, MEDIUM, NetLogWithSource());
-  ASSERT_TRUE(spdy_stream);
-  EXPECT_EQ(0u, spdy_stream->stream_id());
-
-  StreamCreatingDelegate delegate(spdy_stream, session_);
-  spdy_stream->SetDelegate(&delegate);
-
-  SpdyHeaderBlock headers(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  spdy_stream->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND);
-
-  EXPECT_EQ(0u, spdy_stream->stream_id());
-
-  base::RunLoop().RunUntilIdle();
-
-  EXPECT_EQ(1u, spdy_stream->stream_id());
-
-  // Cause the stream to be reset, which should cause another stream
-  // to be created.
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-
-  EXPECT_FALSE(spdy_stream);
-  EXPECT_TRUE(delegate.StreamIsClosed());
-  EXPECT_EQ(0u, session_->num_active_streams());
-  EXPECT_EQ(1u, session_->num_created_streams());
-
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(session_);
-}
-
-TEST_F(SpdySessionTest, UpdateStreamsSendWindowSize) {
-  // Set SETTINGS_INITIAL_WINDOW_SIZE to a small number so that WINDOW_UPDATE
-  // gets sent.
-  SettingsMap new_settings;
-  int32_t window_size = 1;
-  new_settings[SETTINGS_INITIAL_WINDOW_SIZE] = window_size;
-
-  // Set up the socket so we read a SETTINGS frame that sets
-  // INITIAL_WINDOW_SIZE.
-  SpdySerializedFrame settings_frame(
-      spdy_util_.ConstructSpdySettings(new_settings));
-  MockRead reads[] = {
-      CreateMockRead(settings_frame, 0), MockRead(ASYNC, ERR_IO_PENDING, 1),
-      MockRead(ASYNC, 0, 2)  // EOF
-  };
-
-  SpdySerializedFrame settings_ack(spdy_util_.ConstructSpdySettingsAck());
-  MockWrite writes[] = {
-      CreateMockWrite(settings_ack, 3),
-  };
-
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-  base::WeakPtr<SpdyStream> spdy_stream1 =
-      CreateStreamSynchronously(SPDY_BIDIRECTIONAL_STREAM, session_, test_url_,
-                                MEDIUM, NetLogWithSource());
-  ASSERT_TRUE(spdy_stream1);
-  TestCompletionCallback callback1;
-  EXPECT_NE(spdy_stream1->send_window_size(), window_size);
-
-  // Process the SETTINGS frame.
-  base::RunLoop().RunUntilIdle();
-  EXPECT_EQ(session_->stream_initial_send_window_size(), window_size);
-  EXPECT_EQ(spdy_stream1->send_window_size(), window_size);
-
-  // Release the first one, this will allow the second to be created.
-  spdy_stream1->Cancel();
-  EXPECT_FALSE(spdy_stream1);
-
-  base::WeakPtr<SpdyStream> spdy_stream2 =
-      CreateStreamSynchronously(SPDY_BIDIRECTIONAL_STREAM, session_, test_url_,
-                                MEDIUM, NetLogWithSource());
-  ASSERT_TRUE(spdy_stream2);
-  EXPECT_EQ(spdy_stream2->send_window_size(), window_size);
-  spdy_stream2->Cancel();
-  EXPECT_FALSE(spdy_stream2);
-
-  EXPECT_TRUE(session_);
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(session_);
-}
-
-// SpdySession::{Increase,Decrease}RecvWindowSize should properly
-// adjust the session receive window size. In addition,
-// SpdySession::IncreaseRecvWindowSize should trigger
-// sending a WINDOW_UPDATE frame for a large enough delta.
-TEST_F(SpdySessionTest, AdjustRecvWindowSize) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  const int32_t initial_window_size = kDefaultInitialWindowSize;
-  const int32_t delta_window_size = 100;
-
-  MockRead reads[] = {
-      MockRead(ASYNC, ERR_IO_PENDING, 1), MockRead(ASYNC, 0, 2)  // EOF
-  };
-  SpdySerializedFrame window_update(spdy_util_.ConstructSpdyWindowUpdate(
-      kSessionFlowControlStreamId, initial_window_size + delta_window_size));
-  MockWrite writes[] = {
-      CreateMockWrite(window_update, 0),
-  };
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  EXPECT_EQ(initial_window_size, session_->session_recv_window_size_);
-  EXPECT_EQ(0, session_->session_unacked_recv_window_bytes_);
-
-  session_->IncreaseRecvWindowSize(delta_window_size);
-  EXPECT_EQ(initial_window_size + delta_window_size,
-            session_->session_recv_window_size_);
-  EXPECT_EQ(delta_window_size, session_->session_unacked_recv_window_bytes_);
-
-  // Should trigger sending a WINDOW_UPDATE frame.
-  session_->IncreaseRecvWindowSize(initial_window_size);
-  EXPECT_EQ(initial_window_size + delta_window_size + initial_window_size,
-            session_->session_recv_window_size_);
-  EXPECT_EQ(0, session_->session_unacked_recv_window_bytes_);
-
-  base::RunLoop().RunUntilIdle();
-
-  // DecreaseRecvWindowSize() expects |in_io_loop_| to be true.
-  session_->in_io_loop_ = true;
-  session_->DecreaseRecvWindowSize(initial_window_size + delta_window_size +
-                                   initial_window_size);
-  session_->in_io_loop_ = false;
-  EXPECT_EQ(0, session_->session_recv_window_size_);
-  EXPECT_EQ(0, session_->session_unacked_recv_window_bytes_);
-
-  EXPECT_TRUE(session_);
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(session_);
-}
-
-// SpdySession::{Increase,Decrease}SendWindowSize should properly
-// adjust the session send window size when the "enable_spdy_31" flag
-// is set.
-TEST_F(SpdySessionTest, AdjustSendWindowSize) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  MockRead reads[] = {
-    MockRead(SYNCHRONOUS, 0, 0)  // EOF
-  };
-  StaticSocketDataProvider data(reads, arraysize(reads), nullptr, 0);
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  CreateNetworkSession();
-  session_ = CreateFakeSpdySession(spdy_session_pool_, key_);
-
-  const int32_t initial_window_size = kDefaultInitialWindowSize;
-  const int32_t delta_window_size = 100;
-
-  EXPECT_EQ(initial_window_size, session_->session_send_window_size_);
-
-  session_->IncreaseSendWindowSize(delta_window_size);
-  EXPECT_EQ(initial_window_size + delta_window_size,
-            session_->session_send_window_size_);
-
-  session_->DecreaseSendWindowSize(delta_window_size);
-  EXPECT_EQ(initial_window_size, session_->session_send_window_size_);
-}
-
-// Incoming data for an inactive stream should not cause the session
-// receive window size to decrease, but it should cause the unacked
-// bytes to increase.
-TEST_F(SpdySessionTest, SessionFlowControlInactiveStream) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  SpdySerializedFrame resp(spdy_util_.ConstructSpdyDataFrame(1, false));
-  MockRead reads[] = {
-      CreateMockRead(resp, 0), MockRead(ASYNC, ERR_IO_PENDING, 1),
-      MockRead(ASYNC, 0, 2)  // EOF
-  };
-  SequencedSocketData data(reads, arraysize(reads), nullptr, 0);
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  EXPECT_EQ(kDefaultInitialWindowSize, session_->session_recv_window_size_);
-  EXPECT_EQ(0, session_->session_unacked_recv_window_bytes_);
-
-  base::RunLoop().RunUntilIdle();
-
-  EXPECT_EQ(kDefaultInitialWindowSize, session_->session_recv_window_size_);
-  EXPECT_EQ(kUploadDataSize, session_->session_unacked_recv_window_bytes_);
-
-  EXPECT_TRUE(session_);
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(session_);
-}
-
-// The frame header is not included in flow control, but frame payload
-// (including optional pad length and padding) is.
-TEST_F(SpdySessionTest, SessionFlowControlPadding) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  const int padding_length = 42;
-  SpdySerializedFrame resp(spdy_util_.ConstructSpdyDataFrame(
-      1, kUploadData, kUploadDataSize, false, padding_length));
-  MockRead reads[] = {
-      CreateMockRead(resp, 0), MockRead(ASYNC, ERR_IO_PENDING, 1),
-      MockRead(ASYNC, 0, 2)  // EOF
-  };
-  SequencedSocketData data(reads, arraysize(reads), nullptr, 0);
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  EXPECT_EQ(kDefaultInitialWindowSize, session_->session_recv_window_size_);
-  EXPECT_EQ(0, session_->session_unacked_recv_window_bytes_);
-
-  base::RunLoop().RunUntilIdle();
-
-  EXPECT_EQ(kDefaultInitialWindowSize, session_->session_recv_window_size_);
-  EXPECT_EQ(kUploadDataSize + padding_length,
-            session_->session_unacked_recv_window_bytes_);
-
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(session_);
-}
-
-// Peer sends more data than stream level receiving flow control window.
-TEST_F(SpdySessionTest, StreamFlowControlTooMuchData) {
-  const int32_t stream_max_recv_window_size = 1024;
-  const int32_t data_frame_size = 2 * stream_max_recv_window_size;
-
-  SpdySerializedFrame req(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 1, LOWEST, true));
-  SpdySerializedFrame rst(
-      spdy_util_.ConstructSpdyRstStream(1, ERROR_CODE_FLOW_CONTROL_ERROR));
-  MockWrite writes[] = {
-      CreateMockWrite(req, 0), CreateMockWrite(rst, 4),
-  };
-
-  SpdySerializedFrame resp(spdy_util_.ConstructSpdyGetReply(nullptr, 0, 1));
-  const SpdyString payload(data_frame_size, 'a');
-  SpdySerializedFrame data_frame(spdy_util_.ConstructSpdyDataFrame(
-      1, payload.data(), data_frame_size, false));
-  MockRead reads[] = {
-      CreateMockRead(resp, 1),       MockRead(ASYNC, ERR_IO_PENDING, 2),
-      CreateMockRead(data_frame, 3), MockRead(ASYNC, ERR_IO_PENDING, 5),
-      MockRead(ASYNC, 0, 6),
-  };
-
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  session_deps_.http2_settings[SETTINGS_INITIAL_WINDOW_SIZE] =
-      stream_max_recv_window_size;
-  CreateNetworkSession();
-
-  CreateSecureSpdySession();
-
-  base::WeakPtr<SpdyStream> spdy_stream =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, LOWEST, NetLogWithSource());
-  EXPECT_EQ(stream_max_recv_window_size, spdy_stream->recv_window_size());
-
-  test::StreamDelegateDoNothing delegate(spdy_stream);
-  spdy_stream->SetDelegate(&delegate);
-
-  SpdyHeaderBlock headers(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  EXPECT_EQ(ERR_IO_PENDING, spdy_stream->SendRequestHeaders(
-                                std::move(headers), NO_MORE_DATA_TO_SEND));
-
-  // Request and response.
-  base::RunLoop().RunUntilIdle();
-  EXPECT_EQ(1u, spdy_stream->stream_id());
-
-  // Too large data frame causes flow control error, should close stream.
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(spdy_stream);
-
-  EXPECT_TRUE(session_);
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(session_);
-}
-
-// Regression test for a bug that was caused by including unsent WINDOW_UPDATE
-// deltas in the receiving window size when checking incoming frames for flow
-// control errors at session level.
-TEST_F(SpdySessionTest, SessionFlowControlTooMuchDataTwoDataFrames) {
-  const int32_t session_max_recv_window_size = 500;
-  const int32_t first_data_frame_size = 200;
-  const int32_t second_data_frame_size = 400;
-
-  // First data frame should not trigger a WINDOW_UPDATE.
-  ASSERT_GT(session_max_recv_window_size / 2, first_data_frame_size);
-  // Second data frame would be fine had there been a WINDOW_UPDATE.
-  ASSERT_GT(session_max_recv_window_size, second_data_frame_size);
-  // But in fact, the two data frames together overflow the receiving window at
-  // session level.
-  ASSERT_LT(session_max_recv_window_size,
-            first_data_frame_size + second_data_frame_size);
-
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  SpdySerializedFrame goaway(spdy_util_.ConstructSpdyGoAway(
-      0, ERROR_CODE_FLOW_CONTROL_ERROR,
-      "delta_window_size is 400 in DecreaseRecvWindowSize, which is larger "
-      "than the receive window size of 500"));
-  MockWrite writes[] = {
-      CreateMockWrite(goaway, 4),
-  };
-
-  const SpdyString first_data_frame(first_data_frame_size, 'a');
-  SpdySerializedFrame first(spdy_util_.ConstructSpdyDataFrame(
-      1, first_data_frame.data(), first_data_frame_size, false));
-  const SpdyString second_data_frame(second_data_frame_size, 'b');
-  SpdySerializedFrame second(spdy_util_.ConstructSpdyDataFrame(
-      1, second_data_frame.data(), second_data_frame_size, false));
-  MockRead reads[] = {
-      CreateMockRead(first, 0), MockRead(ASYNC, ERR_IO_PENDING, 1),
-      CreateMockRead(second, 2), MockRead(ASYNC, 0, 3),
-  };
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-  // Setting session level receiving window size to smaller than initial is not
-  // possible via SpdySessionPoolPeer.
-  session_->session_recv_window_size_ = session_max_recv_window_size;
-
-  // First data frame is immediately consumed and does not trigger
-  // WINDOW_UPDATE.
-  base::RunLoop().RunUntilIdle();
-  EXPECT_EQ(first_data_frame_size,
-            session_->session_unacked_recv_window_bytes_);
-  EXPECT_EQ(session_max_recv_window_size, session_->session_recv_window_size_);
-  EXPECT_EQ(SpdySession::STATE_AVAILABLE, session_->availability_state_);
-
-  // Second data frame overflows receiving window, causes session to close.
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_EQ(SpdySession::STATE_DRAINING, session_->availability_state_);
-}
-
-// Regression test for a bug that was caused by including unsent WINDOW_UPDATE
-// deltas in the receiving window size when checking incoming data frames for
-// flow control errors at stream level.
-TEST_F(SpdySessionTest, StreamFlowControlTooMuchDataTwoDataFrames) {
-  const int32_t stream_max_recv_window_size = 500;
-  const int32_t first_data_frame_size = 200;
-  const int32_t second_data_frame_size = 400;
-
-  // First data frame should not trigger a WINDOW_UPDATE.
-  ASSERT_GT(stream_max_recv_window_size / 2, first_data_frame_size);
-  // Second data frame would be fine had there been a WINDOW_UPDATE.
-  ASSERT_GT(stream_max_recv_window_size, second_data_frame_size);
-  // But in fact, they should overflow the receiving window at stream level.
-  ASSERT_LT(stream_max_recv_window_size,
-            first_data_frame_size + second_data_frame_size);
-
-  SpdySerializedFrame req(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 1, LOWEST, true));
-  SpdySerializedFrame rst(
-      spdy_util_.ConstructSpdyRstStream(1, ERROR_CODE_FLOW_CONTROL_ERROR));
-  MockWrite writes[] = {
-      CreateMockWrite(req, 0), CreateMockWrite(rst, 6),
-  };
-
-  SpdySerializedFrame resp(spdy_util_.ConstructSpdyGetReply(nullptr, 0, 1));
-  const SpdyString first_data_frame(first_data_frame_size, 'a');
-  SpdySerializedFrame first(spdy_util_.ConstructSpdyDataFrame(
-      1, first_data_frame.data(), first_data_frame_size, false));
-  const SpdyString second_data_frame(second_data_frame_size, 'b');
-  SpdySerializedFrame second(spdy_util_.ConstructSpdyDataFrame(
-      1, second_data_frame.data(), second_data_frame_size, false));
-  MockRead reads[] = {
-      CreateMockRead(resp, 1),   MockRead(ASYNC, ERR_IO_PENDING, 2),
-      CreateMockRead(first, 3),  MockRead(ASYNC, ERR_IO_PENDING, 4),
-      CreateMockRead(second, 5), MockRead(ASYNC, ERR_IO_PENDING, 7),
-      MockRead(ASYNC, 0, 8),
-  };
-
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  session_deps_.http2_settings[SETTINGS_INITIAL_WINDOW_SIZE] =
-      stream_max_recv_window_size;
-  CreateNetworkSession();
-
-  CreateSecureSpdySession();
-
-  base::WeakPtr<SpdyStream> spdy_stream =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, LOWEST, NetLogWithSource());
-  test::StreamDelegateDoNothing delegate(spdy_stream);
-  spdy_stream->SetDelegate(&delegate);
-
-  SpdyHeaderBlock headers(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  EXPECT_EQ(ERR_IO_PENDING, spdy_stream->SendRequestHeaders(
-                                std::move(headers), NO_MORE_DATA_TO_SEND));
-
-  // Request and response.
-  base::RunLoop().RunUntilIdle();
-  EXPECT_TRUE(spdy_stream->IsLocallyClosed());
-  EXPECT_EQ(stream_max_recv_window_size, spdy_stream->recv_window_size());
-
-  // First data frame.
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_TRUE(spdy_stream->IsLocallyClosed());
-  EXPECT_EQ(stream_max_recv_window_size - first_data_frame_size,
-            spdy_stream->recv_window_size());
-
-  // Consume first data frame.  This does not trigger a WINDOW_UPDATE.
-  SpdyString received_data = delegate.TakeReceivedData();
-  EXPECT_EQ(static_cast<size_t>(first_data_frame_size), received_data.size());
-  EXPECT_EQ(stream_max_recv_window_size, spdy_stream->recv_window_size());
-
-  // Second data frame overflows receiving window, causes the stream to close.
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(spdy_stream.get());
-
-  // RST_STREAM
-  EXPECT_TRUE(session_);
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(session_);
-}
-
-// A delegate that drops any received data.
-class DropReceivedDataDelegate : public test::StreamDelegateSendImmediate {
- public:
-  DropReceivedDataDelegate(const base::WeakPtr<SpdyStream>& stream,
-                           SpdyStringPiece data)
-      : StreamDelegateSendImmediate(stream, data) {}
-
-  ~DropReceivedDataDelegate() override {}
-
-  // Drop any received data.
-  void OnDataReceived(std::unique_ptr<SpdyBuffer> buffer) override {}
-};
-
-// Send data back and forth but use a delegate that drops its received
-// data. The receive window should still increase to its original
-// value, i.e. we shouldn't "leak" receive window bytes.
-TEST_F(SpdySessionTest, SessionFlowControlNoReceiveLeaks) {
-  const int32_t kMsgDataSize = 100;
-  const SpdyString msg_data(kMsgDataSize, 'a');
-
-  SpdySerializedFrame req(spdy_util_.ConstructSpdyPost(
-      kDefaultUrl, 1, kMsgDataSize, MEDIUM, nullptr, 0));
-  SpdySerializedFrame msg(spdy_util_.ConstructSpdyDataFrame(
-      1, msg_data.data(), kMsgDataSize, false));
-  MockWrite writes[] = {
-      CreateMockWrite(req, 0), CreateMockWrite(msg, 2),
-  };
-
-  SpdySerializedFrame resp(spdy_util_.ConstructSpdyGetReply(nullptr, 0, 1));
-  SpdySerializedFrame echo(spdy_util_.ConstructSpdyDataFrame(
-      1, msg_data.data(), kMsgDataSize, false));
-  SpdySerializedFrame window_update(spdy_util_.ConstructSpdyWindowUpdate(
-      kSessionFlowControlStreamId, kMsgDataSize));
-  MockRead reads[] = {
-      CreateMockRead(resp, 1), CreateMockRead(echo, 3),
-      MockRead(ASYNC, ERR_IO_PENDING, 4), MockRead(ASYNC, 0, 5)  // EOF
-  };
-
-  // Create SpdySession and SpdyStream and send the request.
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.host_resolver->set_synchronous_mode(true);
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::WeakPtr<SpdyStream> stream =
-      CreateStreamSynchronously(SPDY_BIDIRECTIONAL_STREAM, session_, test_url_,
-                                MEDIUM, NetLogWithSource());
-  ASSERT_TRUE(stream);
-  EXPECT_EQ(0u, stream->stream_id());
-
-  DropReceivedDataDelegate delegate(stream, msg_data);
-  stream->SetDelegate(&delegate);
-
-  SpdyHeaderBlock headers(
-      spdy_util_.ConstructPostHeaderBlock(kDefaultUrl, kMsgDataSize));
-  EXPECT_EQ(ERR_IO_PENDING,
-            stream->SendRequestHeaders(std::move(headers), MORE_DATA_TO_SEND));
-
-  const int32_t initial_window_size = kDefaultInitialWindowSize;
-  EXPECT_EQ(initial_window_size, session_->session_recv_window_size_);
-  EXPECT_EQ(0, session_->session_unacked_recv_window_bytes_);
-
-  base::RunLoop().RunUntilIdle();
-
-  EXPECT_EQ(initial_window_size, session_->session_recv_window_size_);
-  EXPECT_EQ(kMsgDataSize, session_->session_unacked_recv_window_bytes_);
-
-  stream->Close();
-  EXPECT_FALSE(stream);
-
-  EXPECT_THAT(delegate.WaitForClose(), IsOk());
-
-  EXPECT_EQ(initial_window_size, session_->session_recv_window_size_);
-  EXPECT_EQ(kMsgDataSize, session_->session_unacked_recv_window_bytes_);
-
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(session_);
-}
-
-// Send data back and forth but close the stream before its data frame
-// can be written to the socket. The send window should then increase
-// to its original value, i.e. we shouldn't "leak" send window bytes.
-TEST_F(SpdySessionTest, SessionFlowControlNoSendLeaks) {
-  const int32_t kMsgDataSize = 100;
-  const SpdyString msg_data(kMsgDataSize, 'a');
-
-  SpdySerializedFrame req(spdy_util_.ConstructSpdyPost(
-      kDefaultUrl, 1, kMsgDataSize, MEDIUM, nullptr, 0));
-  MockWrite writes[] = {
-      CreateMockWrite(req, 0),
-  };
-
-  SpdySerializedFrame resp(spdy_util_.ConstructSpdyGetReply(nullptr, 0, 1));
-  MockRead reads[] = {
-      MockRead(ASYNC, ERR_IO_PENDING, 1), CreateMockRead(resp, 2),
-      MockRead(ASYNC, 0, 3)  // EOF
-  };
-
-  // Create SpdySession and SpdyStream and send the request.
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.host_resolver->set_synchronous_mode(true);
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::WeakPtr<SpdyStream> stream =
-      CreateStreamSynchronously(SPDY_BIDIRECTIONAL_STREAM, session_, test_url_,
-                                MEDIUM, NetLogWithSource());
-  ASSERT_TRUE(stream);
-  EXPECT_EQ(0u, stream->stream_id());
-
-  test::StreamDelegateSendImmediate delegate(stream, msg_data);
-  stream->SetDelegate(&delegate);
-
-  SpdyHeaderBlock headers(
-      spdy_util_.ConstructPostHeaderBlock(kDefaultUrl, kMsgDataSize));
-  EXPECT_EQ(ERR_IO_PENDING,
-            stream->SendRequestHeaders(std::move(headers), MORE_DATA_TO_SEND));
-
-  const int32_t initial_window_size = kDefaultInitialWindowSize;
-  EXPECT_EQ(initial_window_size, session_->session_send_window_size_);
-
-  // Write request.
-  base::RunLoop().RunUntilIdle();
-
-  EXPECT_EQ(initial_window_size, session_->session_send_window_size_);
-
-  // Read response, but do not run the message loop, so that the body is not
-  // written to the socket.
-  data.Resume();
-
-  EXPECT_EQ(initial_window_size - kMsgDataSize,
-            session_->session_send_window_size_);
-
-  // Closing the stream should increase the session's send window.
-  stream->Close();
-  EXPECT_FALSE(stream);
-
-  EXPECT_EQ(initial_window_size, session_->session_send_window_size_);
-
-  EXPECT_THAT(delegate.WaitForClose(), IsOk());
-
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(session_);
-
-  EXPECT_TRUE(data.AllWriteDataConsumed());
-  EXPECT_TRUE(data.AllReadDataConsumed());
-}
-
-// Send data back and forth; the send and receive windows should
-// change appropriately.
-TEST_F(SpdySessionTest, SessionFlowControlEndToEnd) {
-  const int32_t kMsgDataSize = 100;
-  const SpdyString msg_data(kMsgDataSize, 'a');
-
-  SpdySerializedFrame req(spdy_util_.ConstructSpdyPost(
-      kDefaultUrl, 1, kMsgDataSize, MEDIUM, nullptr, 0));
-  SpdySerializedFrame msg(spdy_util_.ConstructSpdyDataFrame(
-      1, msg_data.data(), kMsgDataSize, false));
-  MockWrite writes[] = {
-      CreateMockWrite(req, 0), CreateMockWrite(msg, 2),
-  };
-
-  SpdySerializedFrame resp(spdy_util_.ConstructSpdyGetReply(nullptr, 0, 1));
-  SpdySerializedFrame echo(spdy_util_.ConstructSpdyDataFrame(
-      1, msg_data.data(), kMsgDataSize, false));
-  SpdySerializedFrame window_update(spdy_util_.ConstructSpdyWindowUpdate(
-      kSessionFlowControlStreamId, kMsgDataSize));
-  MockRead reads[] = {
-      CreateMockRead(resp, 1),
-      MockRead(ASYNC, ERR_IO_PENDING, 3),
-      CreateMockRead(echo, 4),
-      MockRead(ASYNC, ERR_IO_PENDING, 5),
-      CreateMockRead(window_update, 6),
-      MockRead(ASYNC, ERR_IO_PENDING, 7),
-      MockRead(ASYNC, 0, 8)  // EOF
-  };
-
-  // Create SpdySession and SpdyStream and send the request.
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.host_resolver->set_synchronous_mode(true);
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::WeakPtr<SpdyStream> stream =
-      CreateStreamSynchronously(SPDY_BIDIRECTIONAL_STREAM, session_, test_url_,
-                                MEDIUM, NetLogWithSource());
-  ASSERT_TRUE(stream);
-  EXPECT_EQ(0u, stream->stream_id());
-
-  test::StreamDelegateSendImmediate delegate(stream, msg_data);
-  stream->SetDelegate(&delegate);
-
-  SpdyHeaderBlock headers(
-      spdy_util_.ConstructPostHeaderBlock(kDefaultUrl, kMsgDataSize));
-  EXPECT_EQ(ERR_IO_PENDING,
-            stream->SendRequestHeaders(std::move(headers), MORE_DATA_TO_SEND));
-
-  const int32_t initial_window_size = kDefaultInitialWindowSize;
-  EXPECT_EQ(initial_window_size, session_->session_send_window_size_);
-  EXPECT_EQ(initial_window_size, session_->session_recv_window_size_);
-  EXPECT_EQ(0, session_->session_unacked_recv_window_bytes_);
-
-  // Send request and message.
-  base::RunLoop().RunUntilIdle();
-
-  EXPECT_EQ(initial_window_size - kMsgDataSize,
-            session_->session_send_window_size_);
-  EXPECT_EQ(initial_window_size, session_->session_recv_window_size_);
-  EXPECT_EQ(0, session_->session_unacked_recv_window_bytes_);
-
-  // Read echo.
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-
-  EXPECT_EQ(initial_window_size - kMsgDataSize,
-            session_->session_send_window_size_);
-  EXPECT_EQ(initial_window_size - kMsgDataSize,
-            session_->session_recv_window_size_);
-  EXPECT_EQ(0, session_->session_unacked_recv_window_bytes_);
-
-  // Read window update.
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-
-  EXPECT_EQ(initial_window_size, session_->session_send_window_size_);
-  EXPECT_EQ(initial_window_size - kMsgDataSize,
-            session_->session_recv_window_size_);
-  EXPECT_EQ(0, session_->session_unacked_recv_window_bytes_);
-
-  EXPECT_EQ(msg_data, delegate.TakeReceivedData());
-
-  // Draining the delegate's read queue should increase the session's
-  // receive window.
-  EXPECT_EQ(initial_window_size, session_->session_send_window_size_);
-  EXPECT_EQ(initial_window_size, session_->session_recv_window_size_);
-  EXPECT_EQ(kMsgDataSize, session_->session_unacked_recv_window_bytes_);
-
-  stream->Close();
-  EXPECT_FALSE(stream);
-
-  EXPECT_THAT(delegate.WaitForClose(), IsOk());
-
-  EXPECT_EQ(initial_window_size, session_->session_send_window_size_);
-  EXPECT_EQ(initial_window_size, session_->session_recv_window_size_);
-  EXPECT_EQ(kMsgDataSize, session_->session_unacked_recv_window_bytes_);
-
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(session_);
-}
-
-// Given a stall function and an unstall function, runs a test to make
-// sure that a stream resumes after unstall.
-void SpdySessionTest::RunResumeAfterUnstallTest(
-    const base::Callback<void(SpdyStream*)>& stall_function,
-    const base::Callback<void(SpdyStream*, int32_t)>& unstall_function) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  SpdySerializedFrame req(spdy_util_.ConstructSpdyPost(
-      kDefaultUrl, 1, kBodyDataSize, LOWEST, nullptr, 0));
-  SpdySerializedFrame body(
-      spdy_util_.ConstructSpdyDataFrame(1, kBodyData, kBodyDataSize, true));
-  MockWrite writes[] = {
-      CreateMockWrite(req, 0), CreateMockWrite(body, 1),
-  };
-
-  SpdySerializedFrame resp(spdy_util_.ConstructSpdyGetReply(nullptr, 0, 1));
-  SpdySerializedFrame echo(
-      spdy_util_.ConstructSpdyDataFrame(1, kBodyData, kBodyDataSize, false));
-  MockRead reads[] = {
-      CreateMockRead(resp, 2), MockRead(ASYNC, 0, 3)  // EOF
-  };
-
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::WeakPtr<SpdyStream> stream =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, LOWEST, NetLogWithSource());
-  ASSERT_TRUE(stream);
-
-  test::StreamDelegateWithBody delegate(stream, kBodyDataStringPiece);
-  stream->SetDelegate(&delegate);
-
-  EXPECT_FALSE(stream->send_stalled_by_flow_control());
-
-  SpdyHeaderBlock headers(
-      spdy_util_.ConstructPostHeaderBlock(kDefaultUrl, kBodyDataSize));
-  EXPECT_EQ(ERR_IO_PENDING,
-            stream->SendRequestHeaders(std::move(headers), MORE_DATA_TO_SEND));
-  EXPECT_EQ(kDefaultUrl, stream->GetUrlFromHeaders().spec());
-
-  stall_function.Run(stream.get());
-
-  base::RunLoop().RunUntilIdle();
-
-  EXPECT_TRUE(stream->send_stalled_by_flow_control());
-
-  unstall_function.Run(stream.get(), kBodyDataSize);
-
-  EXPECT_FALSE(stream->send_stalled_by_flow_control());
-
-  EXPECT_THAT(delegate.WaitForClose(), IsError(ERR_CONNECTION_CLOSED));
-
-  EXPECT_TRUE(delegate.send_headers_completed());
-  EXPECT_EQ("200", delegate.GetResponseHeaderValue(":status"));
-  EXPECT_EQ(SpdyString(), delegate.TakeReceivedData());
-
-  // Run SpdySession::PumpWriteLoop which destroys |session_|.
-  base::RunLoop().RunUntilIdle();
-
-  EXPECT_FALSE(session_);
-  EXPECT_TRUE(data.AllWriteDataConsumed());
-}
-
-// Run the resume-after-unstall test with all possible stall and
-// unstall sequences.
-
-TEST_F(SpdySessionTest, ResumeAfterUnstallSession) {
-  RunResumeAfterUnstallTest(
-      base::Bind(&SpdySessionTest::StallSessionOnly,
-                 base::Unretained(this)),
-      base::Bind(&SpdySessionTest::UnstallSessionOnly,
-                 base::Unretained(this)));
-}
-
-// Equivalent to
-// SpdyStreamTest.ResumeAfterSendWindowSizeIncrease.
-TEST_F(SpdySessionTest, ResumeAfterUnstallStream) {
-  RunResumeAfterUnstallTest(
-      base::Bind(&SpdySessionTest::StallStreamOnly,
-                 base::Unretained(this)),
-      base::Bind(&SpdySessionTest::UnstallStreamOnly,
-                 base::Unretained(this)));
-}
-
-TEST_F(SpdySessionTest, StallSessionStreamResumeAfterUnstallSessionStream) {
-  RunResumeAfterUnstallTest(
-      base::Bind(&SpdySessionTest::StallSessionStream,
-                 base::Unretained(this)),
-      base::Bind(&SpdySessionTest::UnstallSessionStream,
-                 base::Unretained(this)));
-}
-
-TEST_F(SpdySessionTest, StallStreamSessionResumeAfterUnstallSessionStream) {
-  RunResumeAfterUnstallTest(
-      base::Bind(&SpdySessionTest::StallStreamSession,
-                 base::Unretained(this)),
-      base::Bind(&SpdySessionTest::UnstallSessionStream,
-                 base::Unretained(this)));
-}
-
-TEST_F(SpdySessionTest, StallStreamSessionResumeAfterUnstallStreamSession) {
-  RunResumeAfterUnstallTest(
-      base::Bind(&SpdySessionTest::StallStreamSession,
-                 base::Unretained(this)),
-      base::Bind(&SpdySessionTest::UnstallStreamSession,
-                 base::Unretained(this)));
-}
-
-TEST_F(SpdySessionTest, StallSessionStreamResumeAfterUnstallStreamSession) {
-  RunResumeAfterUnstallTest(
-      base::Bind(&SpdySessionTest::StallSessionStream,
-                 base::Unretained(this)),
-      base::Bind(&SpdySessionTest::UnstallStreamSession,
-                 base::Unretained(this)));
-}
-
-// Cause a stall by reducing the flow control send window to 0. The
-// streams should resume in priority order when that window is then
-// increased.
-TEST_F(SpdySessionTest, ResumeByPriorityAfterSendWindowSizeIncrease) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  SpdySerializedFrame req1(spdy_util_.ConstructSpdyPost(
-      kDefaultUrl, 1, kBodyDataSize, LOWEST, nullptr, 0));
-  SpdySerializedFrame req2(spdy_util_.ConstructSpdyPost(
-      kDefaultUrl, 3, kBodyDataSize, MEDIUM, nullptr, 0));
-  SpdySerializedFrame body1(
-      spdy_util_.ConstructSpdyDataFrame(1, kBodyData, kBodyDataSize, true));
-  SpdySerializedFrame body2(
-      spdy_util_.ConstructSpdyDataFrame(3, kBodyData, kBodyDataSize, true));
-  MockWrite writes[] = {
-      CreateMockWrite(req1, 0), CreateMockWrite(req2, 1),
-      CreateMockWrite(body2, 2), CreateMockWrite(body1, 3),
-  };
-
-  SpdySerializedFrame resp1(spdy_util_.ConstructSpdyGetReply(nullptr, 0, 1));
-  SpdySerializedFrame resp2(spdy_util_.ConstructSpdyGetReply(nullptr, 0, 3));
-  MockRead reads[] = {
-      CreateMockRead(resp1, 4), CreateMockRead(resp2, 5),
-      MockRead(ASYNC, 0, 6)  // EOF
-  };
-
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::WeakPtr<SpdyStream> stream1 =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, LOWEST, NetLogWithSource());
-  ASSERT_TRUE(stream1);
-
-  test::StreamDelegateWithBody delegate1(stream1, kBodyDataStringPiece);
-  stream1->SetDelegate(&delegate1);
-
-  base::WeakPtr<SpdyStream> stream2 =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, MEDIUM, NetLogWithSource());
-  ASSERT_TRUE(stream2);
-
-  test::StreamDelegateWithBody delegate2(stream2, kBodyDataStringPiece);
-  stream2->SetDelegate(&delegate2);
-
-  EXPECT_FALSE(stream1->send_stalled_by_flow_control());
-  EXPECT_FALSE(stream2->send_stalled_by_flow_control());
-
-  StallSessionSend();
-
-  SpdyHeaderBlock headers1(
-      spdy_util_.ConstructPostHeaderBlock(kDefaultUrl, kBodyDataSize));
-  EXPECT_EQ(ERR_IO_PENDING, stream1->SendRequestHeaders(std::move(headers1),
-                                                        MORE_DATA_TO_SEND));
-  EXPECT_EQ(kDefaultUrl, stream1->GetUrlFromHeaders().spec());
-
-  base::RunLoop().RunUntilIdle();
-  EXPECT_EQ(1u, stream1->stream_id());
-  EXPECT_TRUE(stream1->send_stalled_by_flow_control());
-
-  SpdyHeaderBlock headers2(
-      spdy_util_.ConstructPostHeaderBlock(kDefaultUrl, kBodyDataSize));
-  EXPECT_EQ(ERR_IO_PENDING, stream2->SendRequestHeaders(std::move(headers2),
-                                                        MORE_DATA_TO_SEND));
-  EXPECT_EQ(kDefaultUrl, stream2->GetUrlFromHeaders().spec());
-
-  base::RunLoop().RunUntilIdle();
-  EXPECT_EQ(3u, stream2->stream_id());
-  EXPECT_TRUE(stream2->send_stalled_by_flow_control());
-
-  // This should unstall only stream2.
-  UnstallSessionSend(kBodyDataSize);
-
-  EXPECT_TRUE(stream1->send_stalled_by_flow_control());
-  EXPECT_FALSE(stream2->send_stalled_by_flow_control());
-
-  base::RunLoop().RunUntilIdle();
-
-  EXPECT_TRUE(stream1->send_stalled_by_flow_control());
-  EXPECT_FALSE(stream2->send_stalled_by_flow_control());
-
-  // This should then unstall stream1.
-  UnstallSessionSend(kBodyDataSize);
-
-  EXPECT_FALSE(stream1->send_stalled_by_flow_control());
-  EXPECT_FALSE(stream2->send_stalled_by_flow_control());
-
-  base::RunLoop().RunUntilIdle();
-
-  EXPECT_THAT(delegate1.WaitForClose(), IsError(ERR_CONNECTION_CLOSED));
-  EXPECT_THAT(delegate2.WaitForClose(), IsError(ERR_CONNECTION_CLOSED));
-
-  EXPECT_TRUE(delegate1.send_headers_completed());
-  EXPECT_EQ("200", delegate1.GetResponseHeaderValue(":status"));
-  EXPECT_EQ(SpdyString(), delegate1.TakeReceivedData());
-
-  EXPECT_TRUE(delegate2.send_headers_completed());
-  EXPECT_EQ("200", delegate2.GetResponseHeaderValue(":status"));
-  EXPECT_EQ(SpdyString(), delegate2.TakeReceivedData());
-
-  EXPECT_FALSE(session_);
-  EXPECT_TRUE(data.AllWriteDataConsumed());
-  EXPECT_TRUE(data.AllReadDataConsumed());
-}
-
-// Delegate that closes a given stream after sending its body.
-class StreamClosingDelegate : public test::StreamDelegateWithBody {
- public:
-  StreamClosingDelegate(const base::WeakPtr<SpdyStream>& stream,
-                        SpdyStringPiece data)
-      : StreamDelegateWithBody(stream, data) {}
-
-  ~StreamClosingDelegate() override {}
-
-  void set_stream_to_close(const base::WeakPtr<SpdyStream>& stream_to_close) {
-    stream_to_close_ = stream_to_close;
-  }
-
-  void OnDataSent() override {
-    test::StreamDelegateWithBody::OnDataSent();
-    if (stream_to_close_.get()) {
-      stream_to_close_->Close();
-      EXPECT_FALSE(stream_to_close_);
-    }
-  }
-
- private:
-  base::WeakPtr<SpdyStream> stream_to_close_;
-};
-
-// Cause a stall by reducing the flow control send window to
-// 0. Unstalling the session should properly handle deleted streams.
-TEST_F(SpdySessionTest, SendWindowSizeIncreaseWithDeletedStreams) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  SpdySerializedFrame req1(spdy_util_.ConstructSpdyPost(
-      kDefaultUrl, 1, kBodyDataSize, LOWEST, nullptr, 0));
-  SpdySerializedFrame req2(spdy_util_.ConstructSpdyPost(
-      kDefaultUrl, 3, kBodyDataSize, LOWEST, nullptr, 0));
-  SpdySerializedFrame req3(spdy_util_.ConstructSpdyPost(
-      kDefaultUrl, 5, kBodyDataSize, LOWEST, nullptr, 0));
-  SpdySerializedFrame body2(
-      spdy_util_.ConstructSpdyDataFrame(3, kBodyData, kBodyDataSize, true));
-  MockWrite writes[] = {
-      CreateMockWrite(req1, 0), CreateMockWrite(req2, 1),
-      CreateMockWrite(req3, 2), CreateMockWrite(body2, 3),
-  };
-
-  SpdySerializedFrame resp2(spdy_util_.ConstructSpdyGetReply(nullptr, 0, 3));
-  MockRead reads[] = {
-      CreateMockRead(resp2, 4), MockRead(ASYNC, ERR_IO_PENDING, 5),
-      MockRead(ASYNC, 0, 6)  // EOF
-  };
-
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::WeakPtr<SpdyStream> stream1 =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, LOWEST, NetLogWithSource());
-  ASSERT_TRUE(stream1);
-
-  test::StreamDelegateWithBody delegate1(stream1, kBodyDataStringPiece);
-  stream1->SetDelegate(&delegate1);
-
-  base::WeakPtr<SpdyStream> stream2 =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, LOWEST, NetLogWithSource());
-  ASSERT_TRUE(stream2);
-
-  StreamClosingDelegate delegate2(stream2, kBodyDataStringPiece);
-  stream2->SetDelegate(&delegate2);
-
-  base::WeakPtr<SpdyStream> stream3 =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, LOWEST, NetLogWithSource());
-  ASSERT_TRUE(stream3);
-
-  test::StreamDelegateWithBody delegate3(stream3, kBodyDataStringPiece);
-  stream3->SetDelegate(&delegate3);
-
-  EXPECT_FALSE(stream1->send_stalled_by_flow_control());
-  EXPECT_FALSE(stream2->send_stalled_by_flow_control());
-  EXPECT_FALSE(stream3->send_stalled_by_flow_control());
-
-  StallSessionSend();
-
-  SpdyHeaderBlock headers1(
-      spdy_util_.ConstructPostHeaderBlock(kDefaultUrl, kBodyDataSize));
-  EXPECT_EQ(ERR_IO_PENDING, stream1->SendRequestHeaders(std::move(headers1),
-                                                        MORE_DATA_TO_SEND));
-  EXPECT_EQ(kDefaultUrl, stream1->GetUrlFromHeaders().spec());
-
-  base::RunLoop().RunUntilIdle();
-  EXPECT_EQ(1u, stream1->stream_id());
-  EXPECT_TRUE(stream1->send_stalled_by_flow_control());
-
-  SpdyHeaderBlock headers2(
-      spdy_util_.ConstructPostHeaderBlock(kDefaultUrl, kBodyDataSize));
-  EXPECT_EQ(ERR_IO_PENDING, stream2->SendRequestHeaders(std::move(headers2),
-                                                        MORE_DATA_TO_SEND));
-  EXPECT_EQ(kDefaultUrl, stream2->GetUrlFromHeaders().spec());
-
-  base::RunLoop().RunUntilIdle();
-  EXPECT_EQ(3u, stream2->stream_id());
-  EXPECT_TRUE(stream2->send_stalled_by_flow_control());
-
-  SpdyHeaderBlock headers3(
-      spdy_util_.ConstructPostHeaderBlock(kDefaultUrl, kBodyDataSize));
-  EXPECT_EQ(ERR_IO_PENDING, stream3->SendRequestHeaders(std::move(headers3),
-                                                        MORE_DATA_TO_SEND));
-  EXPECT_EQ(kDefaultUrl, stream3->GetUrlFromHeaders().spec());
-
-  base::RunLoop().RunUntilIdle();
-  EXPECT_EQ(5u, stream3->stream_id());
-  EXPECT_TRUE(stream3->send_stalled_by_flow_control());
-
-  SpdyStreamId stream_id1 = stream1->stream_id();
-  SpdyStreamId stream_id2 = stream2->stream_id();
-  SpdyStreamId stream_id3 = stream3->stream_id();
-
-  // Close stream1 preemptively.
-  session_->CloseActiveStream(stream_id1, ERR_CONNECTION_CLOSED);
-  EXPECT_FALSE(stream1);
-
-  EXPECT_FALSE(session_->IsStreamActive(stream_id1));
-  EXPECT_TRUE(session_->IsStreamActive(stream_id2));
-  EXPECT_TRUE(session_->IsStreamActive(stream_id3));
-
-  // Unstall stream2, which should then close stream3.
-  delegate2.set_stream_to_close(stream3);
-  UnstallSessionSend(kBodyDataSize);
-
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(stream3);
-
-  EXPECT_FALSE(stream2->send_stalled_by_flow_control());
-  EXPECT_FALSE(session_->IsStreamActive(stream_id1));
-  EXPECT_TRUE(session_->IsStreamActive(stream_id2));
-  EXPECT_FALSE(session_->IsStreamActive(stream_id3));
-
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(stream2);
-  EXPECT_FALSE(session_);
-
-  EXPECT_THAT(delegate1.WaitForClose(), IsError(ERR_CONNECTION_CLOSED));
-  EXPECT_THAT(delegate2.WaitForClose(), IsError(ERR_CONNECTION_CLOSED));
-  EXPECT_THAT(delegate3.WaitForClose(), IsOk());
-
-  EXPECT_TRUE(delegate1.send_headers_completed());
-  EXPECT_EQ(SpdyString(), delegate1.TakeReceivedData());
-
-  EXPECT_TRUE(delegate2.send_headers_completed());
-  EXPECT_EQ("200", delegate2.GetResponseHeaderValue(":status"));
-  EXPECT_EQ(SpdyString(), delegate2.TakeReceivedData());
-
-  EXPECT_TRUE(delegate3.send_headers_completed());
-  EXPECT_EQ(SpdyString(), delegate3.TakeReceivedData());
-
-  EXPECT_TRUE(data.AllWriteDataConsumed());
-}
-
-// Cause a stall by reducing the flow control send window to
-// 0. Unstalling the session should properly handle the session itself
-// being closed.
-TEST_F(SpdySessionTest, SendWindowSizeIncreaseWithDeletedSession) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  SpdySerializedFrame req1(spdy_util_.ConstructSpdyPost(
-      kDefaultUrl, 1, kBodyDataSize, LOWEST, nullptr, 0));
-  SpdySerializedFrame req2(spdy_util_.ConstructSpdyPost(
-      kDefaultUrl, 3, kBodyDataSize, LOWEST, nullptr, 0));
-  SpdySerializedFrame body1(
-      spdy_util_.ConstructSpdyDataFrame(1, kBodyData, kBodyDataSize, false));
-  MockWrite writes[] = {
-      CreateMockWrite(req1, 0), CreateMockWrite(req2, 1),
-  };
-
-  MockRead reads[] = {
-      MockRead(ASYNC, ERR_IO_PENDING, 2), MockRead(ASYNC, 0, 3)  // EOF
-  };
-
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::WeakPtr<SpdyStream> stream1 =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, LOWEST, NetLogWithSource());
-  ASSERT_TRUE(stream1);
-
-  test::StreamDelegateWithBody delegate1(stream1, kBodyDataStringPiece);
-  stream1->SetDelegate(&delegate1);
-
-  base::WeakPtr<SpdyStream> stream2 =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, LOWEST, NetLogWithSource());
-  ASSERT_TRUE(stream2);
-
-  test::StreamDelegateWithBody delegate2(stream2, kBodyDataStringPiece);
-  stream2->SetDelegate(&delegate2);
-
-  EXPECT_FALSE(stream1->send_stalled_by_flow_control());
-  EXPECT_FALSE(stream2->send_stalled_by_flow_control());
-
-  StallSessionSend();
-
-  SpdyHeaderBlock headers1(
-      spdy_util_.ConstructPostHeaderBlock(kDefaultUrl, kBodyDataSize));
-  EXPECT_EQ(ERR_IO_PENDING, stream1->SendRequestHeaders(std::move(headers1),
-                                                        MORE_DATA_TO_SEND));
-  EXPECT_EQ(kDefaultUrl, stream1->GetUrlFromHeaders().spec());
-
-  base::RunLoop().RunUntilIdle();
-  EXPECT_EQ(1u, stream1->stream_id());
-  EXPECT_TRUE(stream1->send_stalled_by_flow_control());
-
-  SpdyHeaderBlock headers2(
-      spdy_util_.ConstructPostHeaderBlock(kDefaultUrl, kBodyDataSize));
-  EXPECT_EQ(ERR_IO_PENDING, stream2->SendRequestHeaders(std::move(headers2),
-                                                        MORE_DATA_TO_SEND));
-  EXPECT_EQ(kDefaultUrl, stream2->GetUrlFromHeaders().spec());
-
-  base::RunLoop().RunUntilIdle();
-  EXPECT_EQ(3u, stream2->stream_id());
-  EXPECT_TRUE(stream2->send_stalled_by_flow_control());
-
-  EXPECT_TRUE(HasSpdySession(spdy_session_pool_, key_));
-
-  // Unstall stream1.
-  UnstallSessionSend(kBodyDataSize);
-
-  // Close the session (since we can't do it from within the delegate
-  // method, since it's in the stream's loop).
-  session_->CloseSessionOnError(ERR_CONNECTION_CLOSED, "Closing session");
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(session_);
-
-  EXPECT_FALSE(HasSpdySession(spdy_session_pool_, key_));
-
-  EXPECT_THAT(delegate1.WaitForClose(), IsError(ERR_CONNECTION_CLOSED));
-  EXPECT_THAT(delegate2.WaitForClose(), IsError(ERR_CONNECTION_CLOSED));
-
-  EXPECT_TRUE(delegate1.send_headers_completed());
-  EXPECT_EQ(SpdyString(), delegate1.TakeReceivedData());
-
-  EXPECT_TRUE(delegate2.send_headers_completed());
-  EXPECT_EQ(SpdyString(), delegate2.TakeReceivedData());
-
-  EXPECT_TRUE(data.AllWriteDataConsumed());
-}
-
-TEST_F(SpdySessionTest, GoAwayOnSessionFlowControlError) {
-  SpdySerializedFrame req(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 1, LOWEST, true));
-  SpdySerializedFrame goaway(spdy_util_.ConstructSpdyGoAway(
-      0, ERROR_CODE_FLOW_CONTROL_ERROR,
-      "delta_window_size is 6 in DecreaseRecvWindowSize, which is larger than "
-      "the receive window size of 1"));
-  MockWrite writes[] = {
-      CreateMockWrite(req, 0), CreateMockWrite(goaway, 4),
-  };
-
-  SpdySerializedFrame resp(spdy_util_.ConstructSpdyGetReply(nullptr, 0, 1));
-  SpdySerializedFrame body(spdy_util_.ConstructSpdyDataFrame(1, true));
-  MockRead reads[] = {
-      MockRead(ASYNC, ERR_IO_PENDING, 1), CreateMockRead(resp, 2),
-      CreateMockRead(body, 3),
-  };
-
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::WeakPtr<SpdyStream> spdy_stream =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, LOWEST, NetLogWithSource());
-  ASSERT_TRUE(spdy_stream);
-  test::StreamDelegateDoNothing delegate(spdy_stream);
-  spdy_stream->SetDelegate(&delegate);
-
-  SpdyHeaderBlock headers(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  spdy_stream->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND);
-
-  // Write request.
-  base::RunLoop().RunUntilIdle();
-
-  // Put session on the edge of overflowing it's recv window.
-  session_->session_recv_window_size_ = 1;
-
-  // Read response headers & body. Body overflows the session window, and a
-  // goaway is written.
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-
-  EXPECT_THAT(delegate.WaitForClose(), IsError(ERR_SPDY_FLOW_CONTROL_ERROR));
-  EXPECT_FALSE(session_);
-}
-
-// Regression. Sorta. Push streams and client streams were sharing a single
-// limit for a long time.
-TEST_F(SpdySessionTest, PushedStreamShouldNotCountToClientConcurrencyLimit) {
-  SettingsMap new_settings;
-  new_settings[SETTINGS_MAX_CONCURRENT_STREAMS] = 2;
-  SpdySerializedFrame settings_frame(
-      spdy_util_.ConstructSpdySettings(new_settings));
-  SpdySerializedFrame pushed(spdy_util_.ConstructSpdyPush(
-      nullptr, 0, 2, 1, "https://www.example.org/a.dat"));
-  MockRead reads[] = {
-      CreateMockRead(settings_frame, 0),
-      MockRead(ASYNC, ERR_IO_PENDING, 3),
-      CreateMockRead(pushed, 4),
-      MockRead(ASYNC, ERR_IO_PENDING, 6),
-      MockRead(ASYNC, 0, 7),
-  };
-
-  SpdySerializedFrame settings_ack(spdy_util_.ConstructSpdySettingsAck());
-  SpdySerializedFrame req(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 1, LOWEST, true));
-  SpdySerializedFrame priority(
-      spdy_util_.ConstructSpdyPriority(2, 1, IDLE, true));
-  MockWrite writes[] = {
-      CreateMockWrite(settings_ack, 1), CreateMockWrite(req, 2),
-      CreateMockWrite(priority, 5),
-  };
-
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  // Read the settings frame.
-  base::RunLoop().RunUntilIdle();
-
-  base::WeakPtr<SpdyStream> spdy_stream1 =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, LOWEST, NetLogWithSource());
-  ASSERT_TRUE(spdy_stream1);
-  EXPECT_EQ(0u, spdy_stream1->stream_id());
-  test::StreamDelegateDoNothing delegate1(spdy_stream1);
-  spdy_stream1->SetDelegate(&delegate1);
-
-  EXPECT_EQ(0u, session_->num_active_streams());
-  EXPECT_EQ(1u, session_->num_created_streams());
-  EXPECT_EQ(0u, session_->num_pushed_streams());
-  EXPECT_EQ(0u, session_->num_active_pushed_streams());
-
-  SpdyHeaderBlock headers(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  spdy_stream1->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND);
-
-  // Run until 1st stream is activated.
-  EXPECT_EQ(0u, delegate1.stream_id());
-  base::RunLoop().RunUntilIdle();
-  EXPECT_EQ(1u, delegate1.stream_id());
-  EXPECT_EQ(1u, session_->num_active_streams());
-  EXPECT_EQ(0u, session_->num_created_streams());
-  EXPECT_EQ(0u, session_->num_pushed_streams());
-  EXPECT_EQ(0u, session_->num_active_pushed_streams());
-
-  // Run until pushed stream is created.
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_EQ(2u, session_->num_active_streams());
-  EXPECT_EQ(0u, session_->num_created_streams());
-  EXPECT_EQ(1u, session_->num_pushed_streams());
-  EXPECT_EQ(1u, session_->num_active_pushed_streams());
-
-  // Second stream should not be stalled, although we have 2 active streams, but
-  // one of them is push stream and should not be taken into account when we
-  // create streams on the client.
-  base::WeakPtr<SpdyStream> spdy_stream2 =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, LOWEST, NetLogWithSource());
-  EXPECT_TRUE(spdy_stream2);
-  EXPECT_EQ(2u, session_->num_active_streams());
-  EXPECT_EQ(1u, session_->num_created_streams());
-  EXPECT_EQ(1u, session_->num_pushed_streams());
-  EXPECT_EQ(1u, session_->num_active_pushed_streams());
-
-  // Read EOF.
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(session_);
-}
-
-TEST_F(SpdySessionTest, RejectPushedStreamExceedingConcurrencyLimit) {
-  SpdySerializedFrame push_a(spdy_util_.ConstructSpdyPush(
-      nullptr, 0, 2, 1, "https://www.example.org/a.dat"));
-  SpdySerializedFrame push_b(spdy_util_.ConstructSpdyPush(
-      nullptr, 0, 4, 1, "https://www.example.org/b.dat"));
-  MockRead reads[] = {
-      MockRead(ASYNC, ERR_IO_PENDING, 1), CreateMockRead(push_a, 2),
-      MockRead(ASYNC, ERR_IO_PENDING, 4), CreateMockRead(push_b, 5),
-      MockRead(ASYNC, ERR_IO_PENDING, 8), MockRead(ASYNC, 0, 9),
-  };
-
-  SpdySerializedFrame req(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 1, LOWEST, true));
-  SpdySerializedFrame priority_a(
-      spdy_util_.ConstructSpdyPriority(2, 1, IDLE, true));
-  SpdySerializedFrame priority_b(
-      spdy_util_.ConstructSpdyPriority(4, 2, IDLE, true));
-  SpdySerializedFrame rst_b(
-      spdy_util_.ConstructSpdyRstStream(4, ERROR_CODE_REFUSED_STREAM));
-  MockWrite writes[] = {
-      CreateMockWrite(req, 0), CreateMockWrite(priority_a, 3),
-      CreateMockWrite(priority_b, 6), CreateMockWrite(rst_b, 7),
-  };
-
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-  session_->set_max_concurrent_pushed_streams(1);
-
-  base::WeakPtr<SpdyStream> spdy_stream1 =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, LOWEST, NetLogWithSource());
-  ASSERT_TRUE(spdy_stream1);
-  EXPECT_EQ(0u, spdy_stream1->stream_id());
-  test::StreamDelegateDoNothing delegate1(spdy_stream1);
-  spdy_stream1->SetDelegate(&delegate1);
-
-  EXPECT_EQ(0u, session_->num_active_streams());
-  EXPECT_EQ(1u, session_->num_created_streams());
-  EXPECT_EQ(0u, session_->num_pushed_streams());
-  EXPECT_EQ(0u, session_->num_active_pushed_streams());
-
-  SpdyHeaderBlock headers(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  spdy_stream1->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND);
-
-  // Run until 1st stream is activated.
-  EXPECT_EQ(0u, delegate1.stream_id());
-  base::RunLoop().RunUntilIdle();
-  EXPECT_EQ(1u, delegate1.stream_id());
-  EXPECT_EQ(1u, session_->num_active_streams());
-  EXPECT_EQ(0u, session_->num_created_streams());
-  EXPECT_EQ(0u, session_->num_pushed_streams());
-  EXPECT_EQ(0u, session_->num_active_pushed_streams());
-
-  // Run until pushed stream is created.
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_EQ(2u, session_->num_active_streams());
-  EXPECT_EQ(0u, session_->num_created_streams());
-  EXPECT_EQ(1u, session_->num_pushed_streams());
-  EXPECT_EQ(1u, session_->num_active_pushed_streams());
-
-  // Reset incoming pushed stream.
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_EQ(2u, session_->num_active_streams());
-  EXPECT_EQ(0u, session_->num_created_streams());
-  EXPECT_EQ(1u, session_->num_pushed_streams());
-  EXPECT_EQ(1u, session_->num_active_pushed_streams());
-
-  // Read EOF.
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(session_);
-}
-
-// Tests that HTTP SPDY push streams that advertise an origin different from the
-// associated stream are accepted from a trusted SPDY proxy.
-TEST_F(SpdySessionTest, TrustedSpdyProxy) {
-  // Origin of kDefaultUrl should be different from the origin of
-  // kHttpURLFromAnotherOrigin and kHttpsURLFromAnotherOrigin.
-  ASSERT_NE(GURL(kDefaultUrl).host(), GURL(kHttpURLFromAnotherOrigin).host());
-  ASSERT_NE(GURL(kDefaultUrl).host(), GURL(kHttpsURLFromAnotherOrigin).host());
-
-  // cross_origin_push contains HTTP resource for an origin different from the
-  // origin of kDefaultUrl, and should be accepted.
-  SpdySerializedFrame cross_origin_push(spdy_util_.ConstructSpdyPush(
-      nullptr, 0, 2, 1, kHttpURLFromAnotherOrigin));
-  // cross_origin_https_push contains HTTPS resource, and should be refused.
-  SpdySerializedFrame cross_origin_https_push(spdy_util_.ConstructSpdyPush(
-      nullptr, 0, 4, 1, kHttpsURLFromAnotherOrigin));
-  MockRead reads[] = {
-      MockRead(ASYNC, ERR_IO_PENDING, 1),
-      CreateMockRead(cross_origin_push, 2),
-      MockRead(ASYNC, ERR_IO_PENDING, 4),
-      CreateMockRead(cross_origin_https_push, 5),
-      MockRead(ASYNC, ERR_IO_PENDING, 7),
-      MockRead(ASYNC, 0, 8),
-  };
-
-  SpdySerializedFrame req(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 1, LOWEST, true));
-  SpdySerializedFrame priority_http(
-      spdy_util_.ConstructSpdyPriority(2, 1, IDLE, true));
-  SpdySerializedFrame rst_https(
-      spdy_util_.ConstructSpdyRstStream(4, ERROR_CODE_REFUSED_STREAM));
-  MockWrite writes[] = {
-      CreateMockWrite(req, 0), CreateMockWrite(priority_http, 3),
-      CreateMockWrite(rst_https, 6),
-  };
-
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  std::unique_ptr<TestProxyDelegate> proxy_delegate(new TestProxyDelegate());
-  proxy_delegate->set_trusted_spdy_proxy(
-      net::ProxyServer(net::ProxyServer::SCHEME_HTTPS,
-                       HostPortPair(GURL(kDefaultUrl).host(), 443)));
-  session_deps_.proxy_delegate = std::move(proxy_delegate);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::WeakPtr<SpdyStream> spdy_stream =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, LOWEST, NetLogWithSource());
-  ASSERT_TRUE(spdy_stream);
-  EXPECT_EQ(0u, spdy_stream->stream_id());
-  test::StreamDelegateDoNothing delegate(spdy_stream);
-  spdy_stream->SetDelegate(&delegate);
-
-  EXPECT_EQ(0u, session_->num_active_streams());
-  EXPECT_EQ(1u, session_->num_created_streams());
-  EXPECT_EQ(0u, session_->num_pushed_streams());
-  EXPECT_EQ(0u, session_->num_active_pushed_streams());
-
-  SpdyHeaderBlock headers(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  spdy_stream->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND);
-
-  // Run until 1st stream is activated.
-  EXPECT_EQ(0u, delegate.stream_id());
-  base::RunLoop().RunUntilIdle();
-  EXPECT_EQ(1u, delegate.stream_id());
-  EXPECT_EQ(1u, session_->num_active_streams());
-  EXPECT_EQ(0u, session_->num_created_streams());
-  EXPECT_EQ(0u, session_->num_pushed_streams());
-  EXPECT_EQ(0u, session_->num_active_pushed_streams());
-
-  // Run until pushed stream is created.
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_EQ(2u, session_->num_active_streams());
-  EXPECT_EQ(0u, session_->num_created_streams());
-  EXPECT_EQ(1u, session_->num_pushed_streams());
-  EXPECT_EQ(1u, session_->num_active_pushed_streams());
-
-  // Reset incoming pushed stream.
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_EQ(2u, session_->num_active_streams());
-  EXPECT_EQ(0u, session_->num_created_streams());
-  EXPECT_EQ(1u, session_->num_pushed_streams());
-  EXPECT_EQ(1u, session_->num_active_pushed_streams());
-
-  // Read EOF.
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(session_);
-}
-
-// Tests that if the SPDY trusted proxy is not set, then push streams that
-// advertise an origin different from the associated stream are refused.
-TEST_F(SpdySessionTest, TrustedSpdyProxyNotSet) {
-  // Origin of kDefaultUrl should be different from the origin of
-  // kHttpURLFromAnotherOrigin.
-  ASSERT_NE(GURL(kDefaultUrl).host(), GURL(kHttpURLFromAnotherOrigin).host());
-
-  // cross_origin_push contains resource for an origin different from the
-  // origin of kDefaultUrl, and should be refused.
-  SpdySerializedFrame cross_origin_push(spdy_util_.ConstructSpdyPush(
-      nullptr, 0, 2, 1, kHttpURLFromAnotherOrigin));
-  MockRead reads[] = {
-      MockRead(ASYNC, ERR_IO_PENDING, 1), CreateMockRead(cross_origin_push, 2),
-      MockRead(ASYNC, 0, 4),
-  };
-
-  SpdySerializedFrame req(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 1, LOWEST, true));
-  SpdySerializedFrame rst(
-      spdy_util_.ConstructSpdyRstStream(2, ERROR_CODE_REFUSED_STREAM));
-  MockWrite writes[] = {
-      CreateMockWrite(req, 0), CreateMockWrite(rst, 3),
-  };
-
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::WeakPtr<SpdyStream> spdy_stream =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, LOWEST, NetLogWithSource());
-  ASSERT_TRUE(spdy_stream);
-  EXPECT_EQ(0u, spdy_stream->stream_id());
-  test::StreamDelegateDoNothing delegate(spdy_stream);
-  spdy_stream->SetDelegate(&delegate);
-
-  EXPECT_EQ(0u, session_->num_active_streams());
-  EXPECT_EQ(1u, session_->num_created_streams());
-  EXPECT_EQ(0u, session_->num_pushed_streams());
-  EXPECT_EQ(0u, session_->num_active_pushed_streams());
-
-  SpdyHeaderBlock headers(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  spdy_stream->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND);
-
-  // Run until 1st stream is activated.
-  EXPECT_EQ(0u, delegate.stream_id());
-  base::RunLoop().RunUntilIdle();
-  EXPECT_EQ(1u, delegate.stream_id());
-  EXPECT_EQ(1u, session_->num_active_streams());
-  EXPECT_EQ(0u, session_->num_created_streams());
-  EXPECT_EQ(0u, session_->num_pushed_streams());
-  EXPECT_EQ(0u, session_->num_active_pushed_streams());
-
-  // Read EOF.
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(session_);
-}
-
-TEST_F(SpdySessionTest, IgnoreReservedRemoteStreamsCount) {
-  SpdySerializedFrame push_a(spdy_util_.ConstructSpdyPush(
-      nullptr, 0, 2, 1, "https://www.example.org/a.dat"));
-  SpdyHeaderBlock push_headers;
-  spdy_util_.AddUrlToHeaderBlock("https://www.example.org/b.dat",
-                                 &push_headers);
-  SpdySerializedFrame push_b(
-      spdy_util_.ConstructInitialSpdyPushFrame(std::move(push_headers), 4, 1));
-  SpdySerializedFrame headers_b(
-      spdy_util_.ConstructSpdyPushHeaders(4, nullptr, 0));
-  MockRead reads[] = {
-      MockRead(ASYNC, ERR_IO_PENDING, 1),  CreateMockRead(push_a, 2),
-      MockRead(ASYNC, ERR_IO_PENDING, 4),  CreateMockRead(push_b, 5),
-      MockRead(ASYNC, ERR_IO_PENDING, 7),  CreateMockRead(headers_b, 8),
-      MockRead(ASYNC, ERR_IO_PENDING, 10), MockRead(ASYNC, 0, 11),
-  };
-
-  SpdySerializedFrame req(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 1, LOWEST, true));
-  SpdySerializedFrame priority_a(
-      spdy_util_.ConstructSpdyPriority(2, 1, IDLE, true));
-  SpdySerializedFrame priority_b(
-      spdy_util_.ConstructSpdyPriority(4, 2, IDLE, true));
-  SpdySerializedFrame rst_b(
-      spdy_util_.ConstructSpdyRstStream(4, ERROR_CODE_REFUSED_STREAM));
-  MockWrite writes[] = {
-      CreateMockWrite(req, 0), CreateMockWrite(priority_a, 3),
-      CreateMockWrite(priority_b, 6), CreateMockWrite(rst_b, 9),
-  };
-
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-  session_->set_max_concurrent_pushed_streams(1);
-
-  base::WeakPtr<SpdyStream> spdy_stream1 =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, LOWEST, NetLogWithSource());
-  ASSERT_TRUE(spdy_stream1);
-  EXPECT_EQ(0u, spdy_stream1->stream_id());
-  test::StreamDelegateDoNothing delegate1(spdy_stream1);
-  spdy_stream1->SetDelegate(&delegate1);
-
-  EXPECT_EQ(0u, session_->num_active_streams());
-  EXPECT_EQ(1u, session_->num_created_streams());
-  EXPECT_EQ(0u, session_->num_pushed_streams());
-  EXPECT_EQ(0u, session_->num_active_pushed_streams());
-
-  SpdyHeaderBlock headers(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  spdy_stream1->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND);
-
-  // Run until 1st stream is activated.
-  EXPECT_EQ(0u, delegate1.stream_id());
-  base::RunLoop().RunUntilIdle();
-  EXPECT_EQ(1u, delegate1.stream_id());
-  EXPECT_EQ(1u, session_->num_active_streams());
-  EXPECT_EQ(0u, session_->num_created_streams());
-  EXPECT_EQ(0u, session_->num_pushed_streams());
-  EXPECT_EQ(0u, session_->num_active_pushed_streams());
-
-  // Run until pushed stream is created.
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_EQ(2u, session_->num_active_streams());
-  EXPECT_EQ(0u, session_->num_created_streams());
-  EXPECT_EQ(1u, session_->num_pushed_streams());
-  EXPECT_EQ(1u, session_->num_active_pushed_streams());
-
-  // Accept promised stream. It should not count towards pushed stream limit.
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_EQ(3u, session_->num_active_streams());
-  EXPECT_EQ(0u, session_->num_created_streams());
-  EXPECT_EQ(2u, session_->num_pushed_streams());
-  EXPECT_EQ(1u, session_->num_active_pushed_streams());
-
-  // Reset last pushed stream upon headers reception as it is going to be 2nd,
-  // while we accept only one.
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_EQ(2u, session_->num_active_streams());
-  EXPECT_EQ(0u, session_->num_created_streams());
-  EXPECT_EQ(1u, session_->num_pushed_streams());
-  EXPECT_EQ(1u, session_->num_active_pushed_streams());
-
-  // Read EOF.
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_FALSE(session_);
-}
-
-TEST_F(SpdySessionTest, CancelReservedStreamOnHeadersReceived) {
-  const char kPushedUrl[] = "https://www.example.org/a.dat";
-  SpdyHeaderBlock push_headers;
-  spdy_util_.AddUrlToHeaderBlock(kPushedUrl, &push_headers);
-  SpdySerializedFrame push_promise(
-      spdy_util_.ConstructInitialSpdyPushFrame(std::move(push_headers), 2, 1));
-  SpdySerializedFrame headers_frame(
-      spdy_util_.ConstructSpdyPushHeaders(2, nullptr, 0));
-  MockRead reads[] = {
-      MockRead(ASYNC, ERR_IO_PENDING, 1), CreateMockRead(push_promise, 2),
-      MockRead(ASYNC, ERR_IO_PENDING, 4), CreateMockRead(headers_frame, 5),
-      MockRead(ASYNC, ERR_IO_PENDING, 7), MockRead(ASYNC, 0, 8),
-  };
-
-  SpdySerializedFrame req(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 1, LOWEST, true));
-  SpdySerializedFrame priority(
-      spdy_util_.ConstructSpdyPriority(2, 1, IDLE, true));
-  SpdySerializedFrame rst(
-      spdy_util_.ConstructSpdyRstStream(2, ERROR_CODE_CANCEL));
-  MockWrite writes[] = {
-      CreateMockWrite(req, 0), CreateMockWrite(priority, 3),
-      CreateMockWrite(rst, 6),
-  };
-
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::WeakPtr<SpdyStream> spdy_stream1 =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, LOWEST, NetLogWithSource());
-  ASSERT_TRUE(spdy_stream1);
-  EXPECT_EQ(0u, spdy_stream1->stream_id());
-  test::StreamDelegateDoNothing delegate1(spdy_stream1);
-  spdy_stream1->SetDelegate(&delegate1);
-
-  EXPECT_EQ(0u, session_->num_active_streams());
-  EXPECT_EQ(1u, session_->num_created_streams());
-  EXPECT_EQ(0u, session_->num_pushed_streams());
-  EXPECT_EQ(0u, session_->num_active_pushed_streams());
-
-  SpdyHeaderBlock headers(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  spdy_stream1->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND);
-
-  // Run until 1st stream is activated.
-  EXPECT_EQ(0u, delegate1.stream_id());
-  base::RunLoop().RunUntilIdle();
-  EXPECT_EQ(1u, delegate1.stream_id());
-  EXPECT_EQ(1u, session_->num_active_streams());
-  EXPECT_EQ(0u, session_->num_created_streams());
-  EXPECT_EQ(0u, session_->num_pushed_streams());
-  EXPECT_EQ(0u, session_->num_active_pushed_streams());
-
-  // Run until pushed stream is created.
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_EQ(2u, session_->num_active_streams());
-  EXPECT_EQ(0u, session_->num_created_streams());
-  EXPECT_EQ(1u, session_->num_pushed_streams());
-  EXPECT_EQ(0u, session_->num_active_pushed_streams());
-
-  SpdyStream* pushed_stream;
-  int rv = session_->GetPushStream(GURL(kPushedUrl), IDLE, &pushed_stream,
-                                   NetLogWithSource());
-  ASSERT_THAT(rv, IsOk());
-  ASSERT_TRUE(pushed_stream);
-  test::StreamDelegateCloseOnHeaders delegate2(pushed_stream->GetWeakPtr());
-  pushed_stream->SetDelegate(&delegate2);
-
-  // Receive headers for pushed stream. Delegate will cancel the stream, ensure
-  // that all our counters are in consistent state.
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_EQ(1u, session_->num_active_streams());
-  EXPECT_EQ(0u, session_->num_created_streams());
-  EXPECT_EQ(0u, session_->num_pushed_streams());
-  EXPECT_EQ(0u, session_->num_active_pushed_streams());
-
-  // Read EOF.
-  data.Resume();
-  base::RunLoop().RunUntilIdle();
-  EXPECT_TRUE(data.AllWriteDataConsumed());
-  EXPECT_TRUE(data.AllReadDataConsumed());
-}
-
-TEST_F(SpdySessionTest, RejectInvalidUnknownFrames) {
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  MockRead reads[] = {
-      MockRead(SYNCHRONOUS, ERR_IO_PENDING)  // Stall forever.
-  };
-
-  StaticSocketDataProvider data(reads, arraysize(reads), nullptr, 0);
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  session_->stream_hi_water_mark_ = 5;
-  // Low client (odd) ids are fine.
-  EXPECT_TRUE(session_->OnUnknownFrame(3, 0));
-  // Client id exceeding watermark.
-  EXPECT_FALSE(session_->OnUnknownFrame(9, 0));
-
-  session_->last_accepted_push_stream_id_ = 6;
-  // Low server (even) ids are fine.
-  EXPECT_TRUE(session_->OnUnknownFrame(2, 0));
-  // Server id exceeding last accepted id.
-  EXPECT_FALSE(session_->OnUnknownFrame(8, 0));
-}
-
-enum ReadIfReadySupport {
-  // ReadIfReady() field trial is enabled, and ReadIfReady() is implemented.
-  READ_IF_READY_ENABLED_SUPPORTED,
-  // ReadIfReady() field trial is enabled, but ReadIfReady() is unimplemented.
-  READ_IF_READY_ENABLED_NOT_SUPPORTED,
-  // ReadIfReady() field trial is disabled.
-  READ_IF_READY_DISABLED,
-};
-
-class SpdySessionReadIfReadyTest
-    : public SpdySessionTest,
-      public testing::WithParamInterface<ReadIfReadySupport> {
- public:
-  void SetUp() override {
-    if (GetParam() != READ_IF_READY_DISABLED)
-      scoped_feature_list_.InitAndEnableFeature(Socket::kReadIfReadyExperiment);
-    if (GetParam() == READ_IF_READY_ENABLED_SUPPORTED)
-      session_deps_.socket_factory->set_enable_read_if_ready(true);
-    SpdySessionTest::SetUp();
-  }
-
- private:
-  base::test::ScopedFeatureList scoped_feature_list_;
-};
-
-INSTANTIATE_TEST_CASE_P(/* no prefix */,
-                        SpdySessionReadIfReadyTest,
-                        testing::Values(READ_IF_READY_ENABLED_SUPPORTED,
-                                        READ_IF_READY_ENABLED_NOT_SUPPORTED,
-                                        READ_IF_READY_DISABLED));
-
-// Tests basic functionality of ReadIfReady() when it is enabled or disabled.
-TEST_P(SpdySessionReadIfReadyTest, ReadIfReady) {
-  SpdySerializedFrame req(
-      spdy_util_.ConstructSpdyGet(nullptr, 0, 1, HIGHEST, true));
-  MockWrite writes[] = {
-      CreateMockWrite(req, 0),
-  };
-
-  SpdySerializedFrame resp(spdy_util_.ConstructSpdyGetReply(nullptr, 0, 1));
-  SpdySerializedFrame body(spdy_util_.ConstructSpdyDataFrame(1, true));
-  MockRead reads[] = {
-      CreateMockRead(resp, 1), CreateMockRead(body, 2),
-      MockRead(ASYNC, 0, 3)  // EOF
-  };
-
-  session_deps_.host_resolver->set_synchronous_mode(true);
-
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::WeakPtr<SpdyStream> spdy_stream =
-      CreateStreamSynchronously(SPDY_REQUEST_RESPONSE_STREAM, session_,
-                                test_url_, HIGHEST, NetLogWithSource());
-  ASSERT_TRUE(spdy_stream);
-  EXPECT_EQ(0u, spdy_stream->stream_id());
-  test::StreamDelegateDoNothing delegate(spdy_stream);
-  spdy_stream->SetDelegate(&delegate);
-
-  SpdyHeaderBlock headers(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl));
-  spdy_stream->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND);
-
-  base::RunLoop().RunUntilIdle();
-
-  EXPECT_FALSE(spdy_stream);
-  EXPECT_EQ(1u, delegate.stream_id());
-}
-
-class SendInitialSettingsOnNewSpdySessionTest : public SpdySessionTest {
- protected:
-  void RunInitialSettingsTest(const SettingsMap expected_settings) {
-    session_deps_.host_resolver->set_synchronous_mode(true);
-
-    MockRead reads[] = {MockRead(SYNCHRONOUS, ERR_IO_PENDING)};
-
-    SpdySerializedFrame settings_frame(
-        spdy_util_.ConstructSpdySettings(expected_settings));
-    MockWrite writes[] = {MockWrite(ASYNC, kHttp2ConnectionHeaderPrefix,
-                                    kHttp2ConnectionHeaderPrefixSize),
-                          CreateMockWrite(settings_frame)};
-
-    StaticSocketDataProvider data(reads, arraysize(reads), writes,
-                                  arraysize(writes));
-    session_deps_.socket_factory->AddSocketDataProvider(&data);
-    AddSSLSocketData();
-
-    CreateNetworkSession();
-
-    SpdySessionPoolPeer pool_peer(spdy_session_pool_);
-    pool_peer.SetEnableSendingInitialData(true);
-
-    CreateSecureSpdySession();
-
-    base::RunLoop().RunUntilIdle();
-    EXPECT_TRUE(data.AllWriteDataConsumed());
-  }
-};
-
-// Setting values when Params::http2_settings is empty.  Note that
-// SETTINGS_INITIAL_WINDOW_SIZE is sent in production, because it is set to a
-// non-default value, but it is not sent in tests, because the protocol default
-// value is used in tests.
-TEST_F(SendInitialSettingsOnNewSpdySessionTest, Empty) {
-  SettingsMap expected_settings;
-  expected_settings[SETTINGS_HEADER_TABLE_SIZE] = kSpdyMaxHeaderTableSize;
-  expected_settings[SETTINGS_MAX_CONCURRENT_STREAMS] =
-      kSpdyMaxConcurrentPushedStreams;
-  RunInitialSettingsTest(expected_settings);
-}
-
-// When a setting is set to the protocol default value,
-// no corresponding value is sent on the wire.
-TEST_F(SendInitialSettingsOnNewSpdySessionTest, ProtocolDefault) {
-  // Explicitly set protocol default values for the following settings.
-  session_deps_.http2_settings[SETTINGS_HEADER_TABLE_SIZE] = 4096;
-  session_deps_.http2_settings[SETTINGS_ENABLE_PUSH] = 1;
-  session_deps_.http2_settings[SETTINGS_INITIAL_WINDOW_SIZE] = 64 * 1024 - 1;
-
-  SettingsMap expected_settings;
-  expected_settings[SETTINGS_MAX_CONCURRENT_STREAMS] =
-      kSpdyMaxConcurrentPushedStreams;
-  RunInitialSettingsTest(expected_settings);
-}
-
-// Values set in Params::http2_settings overwrite Chromium's default values.
-TEST_F(SendInitialSettingsOnNewSpdySessionTest, OverwriteValues) {
-  session_deps_.http2_settings[SETTINGS_HEADER_TABLE_SIZE] = 16 * 1024;
-  session_deps_.http2_settings[SETTINGS_ENABLE_PUSH] = 0;
-  session_deps_.http2_settings[SETTINGS_MAX_CONCURRENT_STREAMS] = 42;
-  session_deps_.http2_settings[SETTINGS_INITIAL_WINDOW_SIZE] = 32 * 1024;
-
-  SettingsMap expected_settings;
-  expected_settings[SETTINGS_HEADER_TABLE_SIZE] = 16 * 1024;
-  expected_settings[SETTINGS_ENABLE_PUSH] = 0;
-  expected_settings[SETTINGS_MAX_CONCURRENT_STREAMS] = 42;
-  expected_settings[SETTINGS_INITIAL_WINDOW_SIZE] = 32 * 1024;
-  RunInitialSettingsTest(expected_settings);
-}
-
-// Unknown parameters should still be sent to the server.
-TEST_F(SendInitialSettingsOnNewSpdySessionTest, UnknownSettings) {
-  // The following parameters are not defined in the HTTP/2 specification.
-  session_deps_.http2_settings[static_cast<SpdySettingsIds>(7)] = 1234;
-  session_deps_.http2_settings[static_cast<SpdySettingsIds>(25)] = 5678;
-
-  SettingsMap expected_settings;
-  expected_settings[SETTINGS_HEADER_TABLE_SIZE] = kSpdyMaxHeaderTableSize;
-  expected_settings[SETTINGS_MAX_CONCURRENT_STREAMS] =
-      kSpdyMaxConcurrentPushedStreams;
-  expected_settings[static_cast<SpdySettingsIds>(7)] = 1234;
-  expected_settings[static_cast<SpdySettingsIds>(25)] = 5678;
-  RunInitialSettingsTest(expected_settings);
-}
-
-class AltSvcFrameTest : public SpdySessionTest {
- public:
-  AltSvcFrameTest()
-      : alternative_service_("quic",
-                             "alternative.example.org",
-                             443,
-                             86400,
-                             SpdyAltSvcWireFormat::VersionVector()) {}
-
-  void AddSocketData(const SpdyAltSvcIR& altsvc_ir) {
-    altsvc_frame_ = spdy_util_.SerializeFrame(altsvc_ir);
-    reads_.push_back(CreateMockRead(altsvc_frame_, 0));
-    reads_.push_back(MockRead(ASYNC, 0, 1));
-
-    data_.reset(
-        new SequencedSocketData(reads_.data(), reads_.size(), nullptr, 0));
-    session_deps_.socket_factory->AddSocketDataProvider(data_.get());
-  }
-
-  void CreateSecureSpdySession() {
-    session_ = ::net::CreateSecureSpdySession(http_session_.get(), key_,
-                                              NetLogWithSource());
-  }
-
-  SpdyAltSvcWireFormat::AlternativeService alternative_service_;
-
- private:
-  SpdySerializedFrame altsvc_frame_;
-  std::vector<MockRead> reads_;
-  std::unique_ptr<SequencedSocketData> data_;
-};
-
-TEST_F(AltSvcFrameTest, ProcessAltSvcFrame) {
-  const char origin[] = "https://mail.example.org";
-  SpdyAltSvcIR altsvc_ir(/* stream_id = */ 0);
-  altsvc_ir.add_altsvc(alternative_service_);
-  altsvc_ir.set_origin(origin);
-  AddSocketData(altsvc_ir);
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::RunLoop().RunUntilIdle();
-
-  const url::SchemeHostPort session_origin("https", test_url_.host(),
-                                           test_url_.EffectiveIntPort());
-  AlternativeServiceVector altsvc_vector =
-      spdy_session_pool_->http_server_properties()->GetAlternativeServices(
-          session_origin);
-  ASSERT_TRUE(altsvc_vector.empty());
-
-  altsvc_vector =
-      spdy_session_pool_->http_server_properties()->GetAlternativeServices(
-          url::SchemeHostPort(GURL(origin)));
-  ASSERT_EQ(1u, altsvc_vector.size());
-  EXPECT_EQ(kProtoQUIC, altsvc_vector[0].protocol);
-  EXPECT_EQ("alternative.example.org", altsvc_vector[0].host);
-  EXPECT_EQ(443u, altsvc_vector[0].port);
-}
-
-TEST_F(AltSvcFrameTest, DoNotProcessAltSvcFrameOnInsecureSession) {
-  const char origin[] = "https://mail.example.org";
-  SpdyAltSvcIR altsvc_ir(/* stream_id = */ 0);
-  altsvc_ir.add_altsvc(alternative_service_);
-  altsvc_ir.set_origin(origin);
-  AddSocketData(altsvc_ir);
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateInsecureSpdySession();
-
-  base::RunLoop().RunUntilIdle();
-
-  const url::SchemeHostPort session_origin("https", test_url_.host(),
-                                           test_url_.EffectiveIntPort());
-  AlternativeServiceVector altsvc_vector =
-      spdy_session_pool_->http_server_properties()->GetAlternativeServices(
-          session_origin);
-  ASSERT_TRUE(altsvc_vector.empty());
-
-  altsvc_vector =
-      spdy_session_pool_->http_server_properties()->GetAlternativeServices(
-          url::SchemeHostPort(GURL(origin)));
-  ASSERT_TRUE(altsvc_vector.empty());
-}
-
-TEST_F(AltSvcFrameTest, DoNotProcessAltSvcFrameForOriginNotCoveredByCert) {
-  const char origin[] = "https://invalid.example.org";
-  SpdyAltSvcIR altsvc_ir(/* stream_id = */ 0);
-  altsvc_ir.add_altsvc(alternative_service_);
-  altsvc_ir.set_origin(origin);
-  AddSocketData(altsvc_ir);
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::RunLoop().RunUntilIdle();
-
-  const url::SchemeHostPort session_origin("https", test_url_.host(),
-                                           test_url_.EffectiveIntPort());
-  AlternativeServiceVector altsvc_vector =
-      spdy_session_pool_->http_server_properties()->GetAlternativeServices(
-          session_origin);
-  ASSERT_TRUE(altsvc_vector.empty());
-
-  altsvc_vector =
-      spdy_session_pool_->http_server_properties()->GetAlternativeServices(
-          url::SchemeHostPort(GURL(origin)));
-  ASSERT_TRUE(altsvc_vector.empty());
-}
-
-// An ALTSVC frame on stream 0 with empty origin MUST be ignored.
-// (RFC 7838 Section 4)
-TEST_F(AltSvcFrameTest, DoNotProcessAltSvcFrameWithEmptyOriginOnStreamZero) {
-  SpdyAltSvcIR altsvc_ir(/* stream_id = */ 0);
-  altsvc_ir.add_altsvc(alternative_service_);
-  AddSocketData(altsvc_ir);
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::RunLoop().RunUntilIdle();
-
-  const url::SchemeHostPort session_origin("https", test_url_.host(),
-                                           test_url_.EffectiveIntPort());
-  AlternativeServiceVector altsvc_vector =
-      spdy_session_pool_->http_server_properties()->GetAlternativeServices(
-          session_origin);
-  ASSERT_TRUE(altsvc_vector.empty());
-}
-
-// An ALTSVC frame on a stream other than stream 0 with non-empty origin MUST be
-// ignored.  (RFC 7838 Section 4)
-TEST_F(AltSvcFrameTest,
-       DoNotProcessAltSvcFrameWithNonEmptyOriginOnNonZeroStream) {
-  SpdyAltSvcIR altsvc_ir(/* stream_id = */ 1);
-  altsvc_ir.add_altsvc(alternative_service_);
-  altsvc_ir.set_origin("https://mail.example.org");
-  AddSocketData(altsvc_ir);
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::RunLoop().RunUntilIdle();
-
-  const url::SchemeHostPort session_origin("https", test_url_.host(),
-                                           test_url_.EffectiveIntPort());
-  AlternativeServiceVector altsvc_vector =
-      spdy_session_pool_->http_server_properties()->GetAlternativeServices(
-          session_origin);
-  ASSERT_TRUE(altsvc_vector.empty());
-}
-
-TEST_F(AltSvcFrameTest, ProcessAltSvcFrameOnActiveStream) {
-  SpdyAltSvcIR altsvc_ir(/* stream_id = */ 1);
-  altsvc_ir.add_altsvc(alternative_service_);
-
-  SpdySerializedFrame altsvc_frame(spdy_util_.SerializeFrame(altsvc_ir));
-  SpdySerializedFrame rst(
-      spdy_util_.ConstructSpdyRstStream(1, ERROR_CODE_REFUSED_STREAM));
-  MockRead reads[] = {
-      CreateMockRead(altsvc_frame, 1), CreateMockRead(rst, 2),
-      MockRead(ASYNC, 0, 3)  // EOF
-  };
-
-  const char request_origin[] = "https://mail.example.org";
-  SpdySerializedFrame req(
-      spdy_util_.ConstructSpdyGet(request_origin, 1, MEDIUM));
-  MockWrite writes[] = {
-      CreateMockWrite(req, 0),
-  };
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::WeakPtr<SpdyStream> spdy_stream1 = CreateStreamSynchronously(
-      SPDY_REQUEST_RESPONSE_STREAM, session_, GURL(request_origin), MEDIUM,
-      NetLogWithSource());
-  test::StreamDelegateDoNothing delegate1(spdy_stream1);
-  spdy_stream1->SetDelegate(&delegate1);
-
-  SpdyHeaderBlock headers(spdy_util_.ConstructGetHeaderBlock(request_origin));
-
-  spdy_stream1->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND);
-
-  base::RunLoop().RunUntilIdle();
-
-  const url::SchemeHostPort session_origin("https", test_url_.host(),
-                                           test_url_.EffectiveIntPort());
-  AlternativeServiceVector altsvc_vector =
-      spdy_session_pool_->http_server_properties()->GetAlternativeServices(
-          session_origin);
-  ASSERT_TRUE(altsvc_vector.empty());
-
-  altsvc_vector =
-      spdy_session_pool_->http_server_properties()->GetAlternativeServices(
-          url::SchemeHostPort(GURL(request_origin)));
-  ASSERT_EQ(1u, altsvc_vector.size());
-  EXPECT_EQ(kProtoQUIC, altsvc_vector[0].protocol);
-  EXPECT_EQ("alternative.example.org", altsvc_vector[0].host);
-  EXPECT_EQ(443u, altsvc_vector[0].port);
-}
-
-TEST_F(AltSvcFrameTest, DoNotProcessAltSvcFrameOnStreamWithInsecureOrigin) {
-  SpdyAltSvcIR altsvc_ir(/* stream_id = */ 1);
-  altsvc_ir.add_altsvc(alternative_service_);
-
-  SpdySerializedFrame altsvc_frame(spdy_util_.SerializeFrame(altsvc_ir));
-  SpdySerializedFrame rst(
-      spdy_util_.ConstructSpdyRstStream(1, ERROR_CODE_REFUSED_STREAM));
-  MockRead reads[] = {
-      CreateMockRead(altsvc_frame, 1), CreateMockRead(rst, 2),
-      MockRead(ASYNC, 0, 3)  // EOF
-  };
-
-  const char request_origin[] = "http://mail.example.org";
-  SpdySerializedFrame req(
-      spdy_util_.ConstructSpdyGet(request_origin, 1, MEDIUM));
-  MockWrite writes[] = {
-      CreateMockWrite(req, 0),
-  };
-  SequencedSocketData data(reads, arraysize(reads), writes, arraysize(writes));
-  session_deps_.socket_factory->AddSocketDataProvider(&data);
-
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::WeakPtr<SpdyStream> spdy_stream1 = CreateStreamSynchronously(
-      SPDY_REQUEST_RESPONSE_STREAM, session_, GURL(request_origin), MEDIUM,
-      NetLogWithSource());
-  test::StreamDelegateDoNothing delegate1(spdy_stream1);
-  spdy_stream1->SetDelegate(&delegate1);
-
-  SpdyHeaderBlock headers(spdy_util_.ConstructGetHeaderBlock(request_origin));
-
-  spdy_stream1->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND);
-
-  base::RunLoop().RunUntilIdle();
-
-  const url::SchemeHostPort session_origin("https", test_url_.host(),
-                                           test_url_.EffectiveIntPort());
-  AlternativeServiceVector altsvc_vector =
-      spdy_session_pool_->http_server_properties()->GetAlternativeServices(
-          session_origin);
-  ASSERT_TRUE(altsvc_vector.empty());
-
-  altsvc_vector =
-      spdy_session_pool_->http_server_properties()->GetAlternativeServices(
-          url::SchemeHostPort(GURL(request_origin)));
-  ASSERT_TRUE(altsvc_vector.empty());
-}
-
-TEST_F(AltSvcFrameTest, DoNotProcessAltSvcFrameOnNonExistentStream) {
-  SpdyAltSvcIR altsvc_ir(/* stream_id = */ 1);
-  altsvc_ir.add_altsvc(alternative_service_);
-  AddSocketData(altsvc_ir);
-  AddSSLSocketData();
-
-  CreateNetworkSession();
-  CreateSecureSpdySession();
-
-  base::RunLoop().RunUntilIdle();
-
-  const url::SchemeHostPort session_origin("https", test_url_.host(),
-                                           test_url_.EffectiveIntPort());
-  AlternativeServiceVector altsvc_vector =
-      spdy_session_pool_->http_server_properties()->GetAlternativeServices(
-          session_origin);
-  ASSERT_TRUE(altsvc_vector.empty());
-}
-
-TEST(MapFramerErrorToProtocolError, MapsValues) {
-  CHECK_EQ(
-      SPDY_ERROR_INVALID_CONTROL_FRAME,
-      MapFramerErrorToProtocolError(SpdyFramer::SPDY_INVALID_CONTROL_FRAME));
-  CHECK_EQ(
-      SPDY_ERROR_INVALID_DATA_FRAME_FLAGS,
-      MapFramerErrorToProtocolError(SpdyFramer::SPDY_INVALID_DATA_FRAME_FLAGS));
-  CHECK_EQ(
-      SPDY_ERROR_GOAWAY_FRAME_CORRUPT,
-      MapFramerErrorToProtocolError(SpdyFramer::SPDY_GOAWAY_FRAME_CORRUPT));
-  CHECK_EQ(SPDY_ERROR_UNEXPECTED_FRAME,
-           MapFramerErrorToProtocolError(SpdyFramer::SPDY_UNEXPECTED_FRAME));
-}
-
-TEST(MapFramerErrorToNetError, MapsValue) {
-  CHECK_EQ(ERR_SPDY_PROTOCOL_ERROR,
-           MapFramerErrorToNetError(SpdyFramer::SPDY_INVALID_CONTROL_FRAME));
-  CHECK_EQ(ERR_SPDY_COMPRESSION_ERROR,
-           MapFramerErrorToNetError(SpdyFramer::SPDY_COMPRESS_FAILURE));
-  CHECK_EQ(ERR_SPDY_COMPRESSION_ERROR,
-           MapFramerErrorToNetError(SpdyFramer::SPDY_DECOMPRESS_FAILURE));
-  CHECK_EQ(
-      ERR_SPDY_FRAME_SIZE_ERROR,
-      MapFramerErrorToNetError(SpdyFramer::SPDY_CONTROL_PAYLOAD_TOO_LARGE));
-  CHECK_EQ(ERR_SPDY_FRAME_SIZE_ERROR,
-           MapFramerErrorToNetError(SpdyFramer::SPDY_OVERSIZED_PAYLOAD));
-}
-
-TEST(MapRstStreamStatusToProtocolError, MapsValues) {
-  CHECK_EQ(STATUS_CODE_PROTOCOL_ERROR,
-           MapRstStreamStatusToProtocolError(ERROR_CODE_PROTOCOL_ERROR));
-  CHECK_EQ(STATUS_CODE_FRAME_SIZE_ERROR,
-           MapRstStreamStatusToProtocolError(ERROR_CODE_FRAME_SIZE_ERROR));
-  CHECK_EQ(STATUS_CODE_ENHANCE_YOUR_CALM,
-           MapRstStreamStatusToProtocolError(ERROR_CODE_ENHANCE_YOUR_CALM));
-  CHECK_EQ(STATUS_CODE_INADEQUATE_SECURITY,
-           MapRstStreamStatusToProtocolError(ERROR_CODE_INADEQUATE_SECURITY));
-  CHECK_EQ(STATUS_CODE_HTTP_1_1_REQUIRED,
-           MapRstStreamStatusToProtocolError(ERROR_CODE_HTTP_1_1_REQUIRED));
-}
-
-TEST(MapNetErrorToGoAwayStatus, MapsValue) {
-  CHECK_EQ(ERROR_CODE_INADEQUATE_SECURITY,
-           MapNetErrorToGoAwayStatus(ERR_SPDY_INADEQUATE_TRANSPORT_SECURITY));
-  CHECK_EQ(ERROR_CODE_FLOW_CONTROL_ERROR,
-           MapNetErrorToGoAwayStatus(ERR_SPDY_FLOW_CONTROL_ERROR));
-  CHECK_EQ(ERROR_CODE_PROTOCOL_ERROR,
-           MapNetErrorToGoAwayStatus(ERR_SPDY_PROTOCOL_ERROR));
-  CHECK_EQ(ERROR_CODE_COMPRESSION_ERROR,
-           MapNetErrorToGoAwayStatus(ERR_SPDY_COMPRESSION_ERROR));
-  CHECK_EQ(ERROR_CODE_FRAME_SIZE_ERROR,
-           MapNetErrorToGoAwayStatus(ERR_SPDY_FRAME_SIZE_ERROR));
-  CHECK_EQ(ERROR_CODE_PROTOCOL_ERROR,
-           MapNetErrorToGoAwayStatus(ERR_UNEXPECTED));
-}
-
-TEST(CanPoolTest, CanPool) {
-  // Load a cert that is valid for:
-  //   www.example.org
-  //   mail.example.org
-  //   mail.example.com
-
-  TransportSecurityState tss;
-  SSLInfo ssl_info;
-  ssl_info.cert = ImportCertFromFile(GetTestCertsDirectory(),
-                                     "spdy_pooling.pem");
-
-  EXPECT_TRUE(SpdySession::CanPool(
-      &tss, ssl_info, "www.example.org", "www.example.org"));
-  EXPECT_TRUE(SpdySession::CanPool(
-      &tss, ssl_info, "www.example.org", "mail.example.org"));
-  EXPECT_TRUE(SpdySession::CanPool(
-      &tss, ssl_info, "www.example.org", "mail.example.com"));
-  EXPECT_FALSE(SpdySession::CanPool(
-      &tss, ssl_info, "www.example.org", "mail.google.com"));
-}
-
-TEST(CanPoolTest, CanNotPoolWithCertErrors) {
-  // Load a cert that is valid for:
-  //   www.example.org
-  //   mail.example.org
-  //   mail.example.com
-
-  TransportSecurityState tss;
-  SSLInfo ssl_info;
-  ssl_info.cert = ImportCertFromFile(GetTestCertsDirectory(),
-                                     "spdy_pooling.pem");
-  ssl_info.cert_status = CERT_STATUS_REVOKED;
-
-  EXPECT_FALSE(SpdySession::CanPool(
-      &tss, ssl_info, "www.example.org", "mail.example.org"));
-}
-
-TEST(CanPoolTest, CanNotPoolWithClientCerts) {
-  // Load a cert that is valid for:
-  //   www.example.org
-  //   mail.example.org
-  //   mail.example.com
-
-  TransportSecurityState tss;
-  SSLInfo ssl_info;
-  ssl_info.cert = ImportCertFromFile(GetTestCertsDirectory(),
-                                     "spdy_pooling.pem");
-  ssl_info.client_cert_sent = true;
-
-  EXPECT_FALSE(SpdySession::CanPool(
-      &tss, ssl_info, "www.example.org", "mail.example.org"));
-}
-
-TEST(CanPoolTest, CanNotPoolAcrossETLDsWithChannelID) {
-  // Load a cert that is valid for:
-  //   www.example.org
-  //   mail.example.org
-  //   mail.example.com
-
-  TransportSecurityState tss;
-  SSLInfo ssl_info;
-  ssl_info.cert = ImportCertFromFile(GetTestCertsDirectory(),
-                                     "spdy_pooling.pem");
-  ssl_info.channel_id_sent = true;
-
-  EXPECT_TRUE(SpdySession::CanPool(
-      &tss, ssl_info, "www.example.org", "mail.example.org"));
-  EXPECT_FALSE(SpdySession::CanPool(
-      &tss, ssl_info, "www.example.org", "www.example.com"));
-}
-
-TEST(CanPoolTest, CanNotPoolWithBadPins) {
-  uint8_t primary_pin = 1;
-  uint8_t backup_pin = 2;
-  uint8_t bad_pin = 3;
-  TransportSecurityState tss;
-  test::AddPin(&tss, "mail.example.org", primary_pin, backup_pin);
-
-  SSLInfo ssl_info;
-  ssl_info.cert = ImportCertFromFile(GetTestCertsDirectory(),
-                                     "spdy_pooling.pem");
-  ssl_info.is_issued_by_known_root = true;
-  ssl_info.public_key_hashes.push_back(test::GetTestHashValue(bad_pin));
-
-  EXPECT_FALSE(SpdySession::CanPool(
-      &tss, ssl_info, "www.example.org", "mail.example.org"));
-}
-
-TEST(CanPoolTest, CanNotPoolWithBadCTWhenCTRequired) {
-  using testing::Return;
-  using CTRequirementLevel =
-      TransportSecurityState::RequireCTDelegate::CTRequirementLevel;
-
-  SSLInfo ssl_info;
-  ssl_info.cert =
-      ImportCertFromFile(GetTestCertsDirectory(), "spdy_pooling.pem");
-  ssl_info.is_issued_by_known_root = true;
-  ssl_info.public_key_hashes.push_back(test::GetTestHashValue(1));
-  ssl_info.ct_cert_policy_compliance =
-      ct::CertPolicyCompliance::CERT_POLICY_NOT_ENOUGH_SCTS;
-
-  MockRequireCTDelegate require_ct_delegate;
-  EXPECT_CALL(require_ct_delegate, IsCTRequiredForHost("www.example.org"))
-      .WillRepeatedly(Return(CTRequirementLevel::NOT_REQUIRED));
-  EXPECT_CALL(require_ct_delegate, IsCTRequiredForHost("mail.example.org"))
-      .WillRepeatedly(Return(CTRequirementLevel::REQUIRED));
-
-  TransportSecurityState tss;
-  tss.SetRequireCTDelegate(&require_ct_delegate);
-
-  EXPECT_FALSE(SpdySession::CanPool(&tss, ssl_info, "www.example.org",
-                                    "mail.example.org"));
-}
-
-TEST(CanPoolTest, CanPoolWithBadCTWhenCTNotRequired) {
-  using testing::Return;
-  using CTRequirementLevel =
-      TransportSecurityState::RequireCTDelegate::CTRequirementLevel;
-
-  SSLInfo ssl_info;
-  ssl_info.cert =
-      ImportCertFromFile(GetTestCertsDirectory(), "spdy_pooling.pem");
-  ssl_info.is_issued_by_known_root = true;
-  ssl_info.public_key_hashes.push_back(test::GetTestHashValue(1));
-  ssl_info.ct_cert_policy_compliance =
-      ct::CertPolicyCompliance::CERT_POLICY_NOT_ENOUGH_SCTS;
-
-  MockRequireCTDelegate require_ct_delegate;
-  EXPECT_CALL(require_ct_delegate, IsCTRequiredForHost("www.example.org"))
-      .WillRepeatedly(Return(CTRequirementLevel::NOT_REQUIRED));
-  EXPECT_CALL(require_ct_delegate, IsCTRequiredForHost("mail.example.org"))
-      .WillRepeatedly(Return(CTRequirementLevel::NOT_REQUIRED));
-
-  TransportSecurityState tss;
-  tss.SetRequireCTDelegate(&require_ct_delegate);
-
-  EXPECT_TRUE(SpdySession::CanPool(&tss, ssl_info, "www.example.org",
-                                   "mail.example.org"));
-}
-
-TEST(CanPoolTest, CanPoolWithGoodCTWhenCTRequired) {
-  using testing::Return;
-  using CTRequirementLevel =
-      TransportSecurityState::RequireCTDelegate::CTRequirementLevel;
-
-  SSLInfo ssl_info;
-  ssl_info.cert =
-      ImportCertFromFile(GetTestCertsDirectory(), "spdy_pooling.pem");
-  ssl_info.is_issued_by_known_root = true;
-  ssl_info.public_key_hashes.push_back(test::GetTestHashValue(1));
-  ssl_info.ct_cert_policy_compliance =
-      ct::CertPolicyCompliance::CERT_POLICY_COMPLIES_VIA_SCTS;
-
-  MockRequireCTDelegate require_ct_delegate;
-  EXPECT_CALL(require_ct_delegate, IsCTRequiredForHost("www.example.org"))
-      .WillRepeatedly(Return(CTRequirementLevel::NOT_REQUIRED));
-  EXPECT_CALL(require_ct_delegate, IsCTRequiredForHost("mail.example.org"))
-      .WillRepeatedly(Return(CTRequirementLevel::REQUIRED));
-
-  TransportSecurityState tss;
-  tss.SetRequireCTDelegate(&require_ct_delegate);
-
-  EXPECT_TRUE(SpdySession::CanPool(&tss, ssl_info, "www.example.org",
-                                   "mail.example.org"));
-}
-
-TEST(CanPoolTest, CanPoolWithAcceptablePins) {
-  uint8_t primary_pin = 1;
-  uint8_t backup_pin = 2;
-  TransportSecurityState tss;
-  test::AddPin(&tss, "mail.example.org", primary_pin, backup_pin);
-
-  SSLInfo ssl_info;
-  ssl_info.cert = ImportCertFromFile(GetTestCertsDirectory(),
-                                     "spdy_pooling.pem");
-  ssl_info.is_issued_by_known_root = true;
-  ssl_info.public_key_hashes.push_back(test::GetTestHashValue(primary_pin));
-
-  EXPECT_TRUE(SpdySession::CanPool(
-      &tss, ssl_info, "www.example.org", "mail.example.org"));
-}
-
-}  // namespace net