| Index: net/spdy/spdy_session_unittest.cc
|
| diff --git a/net/spdy/spdy_session_unittest.cc b/net/spdy/spdy_session_unittest.cc
|
| index cb8cd71633c60a5a601196aec314772957d5c4a5..476cb765fe6c876b8ef99d882d0e0a01892fa338 100644
|
| --- a/net/spdy/spdy_session_unittest.cc
|
| +++ b/net/spdy/spdy_session_unittest.cc
|
| @@ -124,6 +124,7 @@ class SpdySessionTest : public PlatformTest {
|
| 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_),
|
| @@ -152,6 +153,10 @@ class SpdySessionTest : public PlatformTest {
|
| 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();
|
| }
|
|
|
| @@ -210,7 +215,7 @@ class SpdySessionTest : public PlatformTest {
|
| SpdySessionDependencies session_deps_;
|
| std::unique_ptr<HttpNetworkSession> http_session_;
|
| base::WeakPtr<SpdySession> session_;
|
| - TestServerPushDelegate test_push_delegate_;
|
| + TestServerPushDelegate* test_push_delegate_;
|
| SpdySessionPool* spdy_session_pool_;
|
| const GURL test_url_;
|
| const url::SchemeHostPort test_server_;
|
| @@ -1311,7 +1316,6 @@ TEST_F(SpdySessionTest, CancelPushAfterSessionGoesAway) {
|
|
|
| CreateNetworkSession();
|
| CreateSecureSpdySession();
|
| - session_->set_push_delegate(&test_push_delegate_);
|
|
|
| // Process the principal request, and the first push stream request & body.
|
| base::WeakPtr<SpdyStream> spdy_stream =
|
| @@ -1359,7 +1363,7 @@ TEST_F(SpdySessionTest, CancelPushAfterSessionGoesAway) {
|
| // crash.
|
| EXPECT_FALSE(session_);
|
| EXPECT_TRUE(
|
| - test_push_delegate_.CancelPush(GURL("https://www.example.org/a.dat")));
|
| + 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",
|
| @@ -1397,7 +1401,6 @@ TEST_F(SpdySessionTest, CancelPushAfterExpired) {
|
|
|
| CreateNetworkSession();
|
| CreateSecureSpdySession();
|
| - session_->set_push_delegate(&test_push_delegate_);
|
|
|
| // Process the principal request, and the first push stream request & body.
|
| base::WeakPtr<SpdyStream> spdy_stream =
|
| @@ -1434,7 +1437,7 @@ TEST_F(SpdySessionTest, CancelPushAfterExpired) {
|
|
|
| // Cancel the first push after its expiration.
|
| EXPECT_TRUE(
|
| - test_push_delegate_.CancelPush(GURL("https://www.example.org/a.dat")));
|
| + test_push_delegate_->CancelPush(GURL("https://www.example.org/a.dat")));
|
| EXPECT_EQ(1u, session_->num_unclaimed_pushed_streams());
|
| EXPECT_TRUE(session_);
|
|
|
| @@ -1484,7 +1487,6 @@ TEST_F(SpdySessionTest, CancelPushBeforeClaimed) {
|
|
|
| CreateNetworkSession();
|
| CreateSecureSpdySession();
|
| - session_->set_push_delegate(&test_push_delegate_);
|
|
|
| // Process the principal request, and the first push stream request & body.
|
| base::WeakPtr<SpdyStream> spdy_stream =
|
| @@ -1525,7 +1527,7 @@ TEST_F(SpdySessionTest, CancelPushBeforeClaimed) {
|
|
|
| EXPECT_TRUE(session_);
|
| // Cancel the push before it's claimed.
|
| - EXPECT_TRUE(test_push_delegate_.CancelPush(pushed_url));
|
| + 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));
|
|
|
|
|