| Index: net/spdy/spdy_session_pool_unittest.cc
|
| diff --git a/net/spdy/spdy_session_pool_unittest.cc b/net/spdy/spdy_session_pool_unittest.cc
|
| index 682d31a418d09006e6dcbb195404e1ec24920fa1..aa640af8921a4e5c516fb3425f78226b0e538e54 100644
|
| --- a/net/spdy/spdy_session_pool_unittest.cc
|
| +++ b/net/spdy/spdy_session_pool_unittest.cc
|
| @@ -10,6 +10,7 @@
|
| #include <utility>
|
|
|
| #include "base/memory/ref_counted.h"
|
| +#include "base/run_loop.h"
|
| #include "net/dns/host_cache.h"
|
| #include "net/http/http_network_session.h"
|
| #include "net/socket/client_socket_handle.h"
|
| @@ -117,7 +118,7 @@ TEST_P(SpdySessionPoolTest, CloseCurrentSessions) {
|
| CreateInsecureSpdySession(http_session_.get(), test_key, BoundNetLog());
|
|
|
| // Flush the SpdySession::OnReadComplete() task.
|
| - base::MessageLoop::current()->RunUntilIdle();
|
| + base::RunLoop().RunUntilIdle();
|
|
|
| // Verify that we have sessions for everything.
|
| EXPECT_TRUE(HasSpdySession(spdy_session_pool_, test_key));
|
| @@ -230,7 +231,7 @@ TEST_P(SpdySessionPoolTest, CloseCurrentIdleSessions) {
|
|
|
| // Should close session 1 and 3, 2 should be left open
|
| spdy_session_pool_->CloseCurrentIdleSessions();
|
| - base::MessageLoop::current()->RunUntilIdle();
|
| + base::RunLoop().RunUntilIdle();
|
|
|
| EXPECT_FALSE(session1);
|
| EXPECT_TRUE(session2->is_active());
|
| @@ -239,14 +240,14 @@ TEST_P(SpdySessionPoolTest, CloseCurrentIdleSessions) {
|
|
|
| // Should not do anything
|
| spdy_session_pool_->CloseCurrentIdleSessions();
|
| - base::MessageLoop::current()->RunUntilIdle();
|
| + base::RunLoop().RunUntilIdle();
|
|
|
| EXPECT_TRUE(session2->is_active());
|
| EXPECT_TRUE(session2->IsAvailable());
|
|
|
| // Make 2 not active
|
| session2->CloseCreatedStream(spdy_stream2, OK);
|
| - base::MessageLoop::current()->RunUntilIdle();
|
| + base::RunLoop().RunUntilIdle();
|
|
|
| EXPECT_FALSE(spdy_stream2);
|
| EXPECT_FALSE(session2->is_active());
|
| @@ -254,7 +255,7 @@ TEST_P(SpdySessionPoolTest, CloseCurrentIdleSessions) {
|
|
|
| // This should close session 2
|
| spdy_session_pool_->CloseCurrentIdleSessions();
|
| - base::MessageLoop::current()->RunUntilIdle();
|
| + base::RunLoop().RunUntilIdle();
|
|
|
| EXPECT_FALSE(session2);
|
| }
|
| @@ -292,7 +293,7 @@ TEST_P(SpdySessionPoolTest, CloseAllSessions) {
|
| CreateInsecureSpdySession(http_session_.get(), test_key, BoundNetLog());
|
|
|
| // Flush the SpdySession::OnReadComplete() task.
|
| - base::MessageLoop::current()->RunUntilIdle();
|
| + base::RunLoop().RunUntilIdle();
|
|
|
| // Verify that we have sessions for everything.
|
| EXPECT_TRUE(HasSpdySession(spdy_session_pool_, test_key));
|
| @@ -382,7 +383,7 @@ void SpdySessionPoolTest::RunIPPoolingTest(
|
| http_session_.get(), test_hosts[0].key, BoundNetLog());
|
|
|
| // Flush the SpdySession::OnReadComplete() task.
|
| - base::MessageLoop::current()->RunUntilIdle();
|
| + base::RunLoop().RunUntilIdle();
|
|
|
| // The third host has no overlap with the first, so it can't pool IPs.
|
| EXPECT_FALSE(HasSpdySession(spdy_session_pool_, test_hosts[2].key));
|
| @@ -434,7 +435,7 @@ void SpdySessionPoolTest::RunIPPoolingTest(
|
| case SPDY_POOL_CLOSE_SESSIONS_MANUALLY:
|
| session->CloseSessionOnError(ERR_ABORTED, std::string());
|
| session2->CloseSessionOnError(ERR_ABORTED, std::string());
|
| - base::MessageLoop::current()->RunUntilIdle();
|
| + base::RunLoop().RunUntilIdle();
|
| EXPECT_FALSE(session);
|
| EXPECT_FALSE(session2);
|
| break;
|
| @@ -472,7 +473,7 @@ void SpdySessionPoolTest::RunIPPoolingTest(
|
| // Test that calling CloseIdleSessions, does not cause a crash.
|
| // http://crbug.com/181400
|
| spdy_session_pool_->CloseCurrentIdleSessions();
|
| - base::MessageLoop::current()->RunUntilIdle();
|
| + base::RunLoop().RunUntilIdle();
|
|
|
| // Verify spdy_session and spdy_session1 are closed.
|
| EXPECT_FALSE(session);
|
| @@ -486,7 +487,7 @@ void SpdySessionPoolTest::RunIPPoolingTest(
|
| EXPECT_FALSE(spdy_stream2);
|
|
|
| session2->CloseSessionOnError(ERR_ABORTED, std::string());
|
| - base::MessageLoop::current()->RunUntilIdle();
|
| + base::RunLoop().RunUntilIdle();
|
| EXPECT_FALSE(session2);
|
| break;
|
| }
|
| @@ -559,7 +560,7 @@ TEST_P(SpdySessionPoolTest, IPAddressChanged) {
|
| spdy_streamA->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND);
|
| EXPECT_TRUE(spdy_streamA->HasUrlFromHeaders());
|
|
|
| - base::MessageLoop::current()->RunUntilIdle(); // Allow headers to write.
|
| + base::RunLoop().RunUntilIdle(); // Allow headers to write.
|
| EXPECT_TRUE(delegateA.send_headers_completed());
|
|
|
| sessionA->MakeUnavailable();
|
| @@ -650,7 +651,7 @@ TEST_P(SpdySessionPoolTest, FindAvailableSession) {
|
| CreateInsecureSpdySession(http_session_.get(), key, BoundNetLog());
|
|
|
| // Flush the SpdySession::OnReadComplete() task.
|
| - base::MessageLoop::current()->RunUntilIdle();
|
| + base::RunLoop().RunUntilIdle();
|
|
|
| EXPECT_TRUE(HasSpdySession(spdy_session_pool_, key));
|
|
|
|
|