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

ios/web/web_thread_impl.cc

 // Copyright 2014 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 "ios/web/web_thread_impl.h"
 
 #include <string>
 
 #include "base/atomicops.h"
 #include "base/bind.h"
 #include "base/compiler_specific.h"
 #include "base/lazy_instance.h"
 #include "base/macros.h"
 #include "base/message_loop/message_loop.h"
+#include "base/run_loop.h"
 #include "base/single_thread_task_runner.h"
 #include "base/threading/sequenced_worker_pool.h"
 #include "base/threading/thread_restrictions.h"
 #include "ios/web/public/web_thread_delegate.h"
 #include "net/disk_cache/simple/simple_backend_impl.h"
 #include "net/url_request/url_fetcher.h"
 
 namespace web {
 
 namespace {
@@ skipping 136 matching lines @@
 
   if (WebThread::CurrentlyOn(WebThread::IO)) {
     // Though this thread is called the "IO" thread, it actually just routes
     // messages around; it shouldn't be allowed to perform any blocking disk
     // I/O.
     base::ThreadRestrictions::SetIOAllowed(false);
     base::ThreadRestrictions::DisallowWaiting();
   }
 }
 
-NOINLINE void WebThreadImpl::UIThreadRun(base::MessageLoop* message_loop) {
+NOINLINE void WebThreadImpl::UIThreadRun(base::RunLoop* run_loop) {
   volatile int line_number = __LINE__;
-  Thread::Run(message_loop);
+  Thread::Run(run_loop);
   CHECK_GT(line_number, 0);
 }
 
-NOINLINE void WebThreadImpl::DBThreadRun(base::MessageLoop* message_loop) {
+NOINLINE void WebThreadImpl::DBThreadRun(base::RunLoop* run_loop) {
   volatile int line_number = __LINE__;
-  Thread::Run(message_loop);
+  Thread::Run(run_loop);
   CHECK_GT(line_number, 0);
 }
 
-NOINLINE void WebThreadImpl::FileThreadRun(base::MessageLoop* message_loop) {
+NOINLINE void WebThreadImpl::FileThreadRun(base::RunLoop* run_loop) {
   volatile int line_number = __LINE__;
-  Thread::Run(message_loop);
+  Thread::Run(run_loop);
   CHECK_GT(line_number, 0);
 }
 
 NOINLINE void WebThreadImpl::FileUserBlockingThreadRun(
-    base::MessageLoop* message_loop) {
+    base::RunLoop* run_loop) {
   volatile int line_number = __LINE__;
-  Thread::Run(message_loop);
+  Thread::Run(run_loop);
   CHECK_GT(line_number, 0);
 }
 
-NOINLINE void WebThreadImpl::CacheThreadRun(base::MessageLoop* message_loop) {
+NOINLINE void WebThreadImpl::CacheThreadRun(base::RunLoop* run_loop) {
   volatile int line_number = __LINE__;
-  Thread::Run(message_loop);
+  Thread::Run(run_loop);
   CHECK_GT(line_number, 0);
 }
 
-NOINLINE void WebThreadImpl::IOThreadRun(base::MessageLoop* message_loop) {
+NOINLINE void WebThreadImpl::IOThreadRun(base::RunLoop* run_loop) {
   volatile int line_number = __LINE__;
-  Thread::Run(message_loop);
+  Thread::Run(run_loop);
   CHECK_GT(line_number, 0);
 }
 
-void WebThreadImpl::Run(base::MessageLoop* message_loop) {
+void WebThreadImpl::Run(base::RunLoop* run_loop) {
   WebThread::ID thread_id = ID_COUNT;
   if (!GetCurrentThreadIdentifier(&thread_id))
-    return Thread::Run(message_loop);
+    return Thread::Run(run_loop);
 
   switch (thread_id) {
     case WebThread::UI:
-      return UIThreadRun(message_loop);
+      return UIThreadRun(run_loop);
     case WebThread::DB:
-      return DBThreadRun(message_loop);
+      return DBThreadRun(run_loop);
     case WebThread::FILE:
-      return FileThreadRun(message_loop);
+      return FileThreadRun(run_loop);
     case WebThread::FILE_USER_BLOCKING:
-      return FileUserBlockingThreadRun(message_loop);
+      return FileUserBlockingThreadRun(run_loop);
     case WebThread::CACHE:
-      return CacheThreadRun(message_loop);
+      return CacheThreadRun(run_loop);
     case WebThread::IO:
-      return IOThreadRun(message_loop);
+      return IOThreadRun(run_loop);
     case WebThread::ID_COUNT:
       CHECK(false);  // This shouldn't actually be reached!
       break;
   }
-  Thread::Run(message_loop);
+  Thread::Run(run_loop);
 }
 
 void WebThreadImpl::CleanUp() {
   if (WebThread::CurrentlyOn(WebThread::IO))
     IOThreadPreCleanUp();
 
   WebThreadGlobals& globals = g_globals.Get();
 
   using base::subtle::AtomicWord;
   AtomicWord* storage =
@@ skipping 254 matching lines @@
   AtomicWord* storage =
       reinterpret_cast<AtomicWord*>(&globals.thread_delegates[identifier]);
   AtomicWord old_pointer = base::subtle::NoBarrier_AtomicExchange(
       storage, reinterpret_cast<AtomicWord>(delegate));
 
   // This catches registration when previously registered.
   DCHECK(!delegate || !old_pointer);
 }
 
 }  // namespace web