Remove calls to MessageLoop::current() in base.

net/quic/quic_end_to_end_unittest.cc

 // Copyright 2013 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 <memory>
 #include <ostream>
 #include <utility>
 #include <vector>
 
 #include "base/compiler_specific.h"
 #include "base/memory/ptr_util.h"
+#include "base/run_loop.h"
 #include "base/stl_util.h"
 #include "base/strings/string_number_conversions.h"
 #include "net/base/elements_upload_data_stream.h"
 #include "net/base/ip_address.h"
 #include "net/base/test_completion_callback.h"
 #include "net/base/upload_bytes_element_reader.h"
 #include "net/base/upload_data_stream.h"
 #include "net/cert/ct_policy_enforcer.h"
 #include "net/cert/mock_cert_verifier.h"
 #include "net/cert/multi_log_ct_verifier.h"
@@ skipping 261 matching lines @@
 TEST_P(QuicEndToEndTest, LargeGetWithNoPacketLoss) {
   std::string response(10 * 1024, 'x');
 
   AddToCache(request_.url.PathForRequest(), 200, "OK", response);
 
   TestTransactionConsumer consumer(DEFAULT_PRIORITY,
                                    transaction_factory_.get());
   consumer.Start(&request_, BoundNetLog());
 
   // Will terminate when the last consumer completes.
-  base::MessageLoop::current()->Run();
+  base::RunLoop().Run();
 
   CheckResponse(consumer, "HTTP/1.1 200", response);
 }
 
 TEST_P(QuicEndToEndTest, TokenBinding) {
   // Enable token binding and re-initialize the TestTransactionFactory.
   params_.enable_token_binding = true;
   transaction_factory_.reset(new TestTransactionFactory(params_));
 
   AddToCache(request_.url.PathForRequest(), 200, "OK", kResponseBody);
 
   TestTransactionConsumer consumer(DEFAULT_PRIORITY,
                                    transaction_factory_.get());
   consumer.Start(&request_, BoundNetLog());
 
   // Will terminate when the last consumer completes.
-  base::MessageLoop::current()->Run();
+  base::RunLoop().Run();
 
   CheckResponse(consumer, "HTTP/1.1 200", kResponseBody);
   HttpRequestHeaders headers;
   ASSERT_TRUE(consumer.transaction()->GetFullRequestHeaders(&headers));
   EXPECT_TRUE(headers.HasHeader(HttpRequestHeaders::kTokenBinding));
 }
 
 // crbug.com/559173
 #if defined(THREAD_SANITIZER)
 TEST_P(QuicEndToEndTest, DISABLED_LargePostWithNoPacketLoss) {
 #else
 TEST_P(QuicEndToEndTest, LargePostWithNoPacketLoss) {
 #endif
   InitializePostRequest(1024 * 1024);
 
   AddToCache(request_.url.PathForRequest(), 200, "OK", kResponseBody);
 
   TestTransactionConsumer consumer(DEFAULT_PRIORITY,
                                    transaction_factory_.get());
   consumer.Start(&request_, BoundNetLog());
 
   // Will terminate when the last consumer completes.
-  base::MessageLoop::current()->Run();
+  base::RunLoop().Run();
 
   CheckResponse(consumer, "HTTP/1.1 200", kResponseBody);
 }
 
 // crbug.com/559173
 #if defined(THREAD_SANITIZER)
 TEST_P(QuicEndToEndTest, DISABLED_LargePostWithPacketLoss) {
 #else
 TEST_P(QuicEndToEndTest, LargePostWithPacketLoss) {
 #endif
   // FLAGS_fake_packet_loss_percentage = 30;
   InitializePostRequest(1024 * 1024);
 
   const char kResponseBody[] = "some really big response body";
   AddToCache(request_.url.PathForRequest(), 200, "OK", kResponseBody);
 
   TestTransactionConsumer consumer(DEFAULT_PRIORITY,
                                    transaction_factory_.get());
   consumer.Start(&request_, BoundNetLog());
 
   // Will terminate when the last consumer completes.
-  base::MessageLoop::current()->Run();
+  base::RunLoop().Run();
 
   CheckResponse(consumer, "HTTP/1.1 200", kResponseBody);
 }
 
 // crbug.com/536845
 #if defined(THREAD_SANITIZER)
 TEST_P(QuicEndToEndTest, DISABLED_UberTest) {
 #else
 TEST_P(QuicEndToEndTest, UberTest) {
 #endif
   // FLAGS_fake_packet_loss_percentage = 30;
 
   const char kResponseBody[] = "some really big response body";
   AddToCache(request_.url.PathForRequest(), 200, "OK", kResponseBody);
 
   std::vector<TestTransactionConsumer*> consumers;
   size_t num_requests = 100;
   for (size_t i = 0; i < num_requests; ++i) {
     TestTransactionConsumer* consumer = new TestTransactionConsumer(
         DEFAULT_PRIORITY, transaction_factory_.get());
     consumers.push_back(consumer);
     consumer->Start(&request_, BoundNetLog());
   }
 
   // Will terminate when the last consumer completes.
-  base::MessageLoop::current()->Run();
+  base::RunLoop().Run();
 
   for (size_t i = 0; i < num_requests; ++i) {
     CheckResponse(*consumers[i], "HTTP/1.1 200", kResponseBody);
   }
   STLDeleteElements(&consumers);
 }
 
 }  // namespace test
 }  // namespace net