chrome/browser: Remove use of MessageLoopProxy and deprecated MessageLoop APIs

chrome/browser/devtools/device/adb/mock_adb_server.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 "chrome/browser/devtools/device/adb/mock_adb_server.h"
 
+#include "base/location.h"
 #include "base/memory/weak_ptr.h"
+#include "base/single_thread_task_runner.h"
 #include "base/strings/string_number_conversions.h"
 #include "base/strings/string_util.h"
 #include "base/strings/stringprintf.h"
+#include "base/thread_task_runner_handle.h"
 #include "base/threading/non_thread_safe.h"
 #include "content/public/browser/browser_thread.h"
 #include "content/public/test/browser_test.h"
 #include "content/public/test/test_utils.h"
 #include "net/base/io_buffer.h"
 #include "net/base/ip_endpoint.h"
 #include "net/base/net_errors.h"
 #include "net/socket/stream_socket.h"
 #include "net/socket/tcp_server_socket.h"
 
@@ skipping 286 matching lines @@
     char* data = input_buffer_->StartOfBuffer();
     int data_size = input_buffer_->offset();
     bytes_processed = parser_->Consume(data, data_size);
 
     if (bytes_processed) {
       memmove(data, data + bytes_processed, data_size - bytes_processed);
       input_buffer_->set_offset(data_size - bytes_processed);
     }
   } while (bytes_processed);
   // Posting to avoid deep recursion in case of synchronous IO
-  base::MessageLoop::current()->PostTask(
-      FROM_HERE,
-      base::Bind(&Connection::ReadData, weak_factory_.GetWeakPtr()));
+  base::ThreadTaskRunnerHandle::Get()->PostTask(
+      FROM_HERE, base::Bind(&Connection::ReadData, weak_factory_.GetWeakPtr()));
 }
 
 void SimpleHttpServer::Connection::WriteData() {
   CHECK(CalledOnValidThread());
   CHECK_GE(output_buffer_->capacity(),
            output_buffer_->offset() + bytes_to_write_) << "Overflow";
 
   int write_result = socket_->Write(
       output_buffer_.get(),
       bytes_to_write_,
@@ skipping 11 matching lines @@
   }
   CHECK_GT(count, 0);
   CHECK_GE(output_buffer_->capacity(),
            output_buffer_->offset() + bytes_to_write_) << "Overflow";
 
   bytes_to_write_ -= count;
   output_buffer_->set_offset(output_buffer_->offset() + count);
 
   if (bytes_to_write_ != 0)
     // Posting to avoid deep recursion in case of synchronous IO
-    base::MessageLoop::current()->PostTask(
+    base::ThreadTaskRunnerHandle::Get()->PostTask(
         FROM_HERE,
         base::Bind(&Connection::WriteData, weak_factory_.GetWeakPtr()));
   else if (read_closed_)
     delete this;
 }
 
 void SimpleHttpServer::AcceptConnection() {
   CHECK(CalledOnValidThread());
 
   int accept_result = socket_->Accept(&client_socket_,
       base::Bind(&SimpleHttpServer::OnAccepted, base::Unretained(this)));
 
   if (accept_result != net::ERR_IO_PENDING)
-    base::MessageLoop::current()->PostTask(
-        FROM_HERE,
-        base::Bind(&SimpleHttpServer::OnAccepted,
-                   weak_factory_.GetWeakPtr(),
-                   accept_result));
+    base::ThreadTaskRunnerHandle::Get()->PostTask(
+        FROM_HERE, base::Bind(&SimpleHttpServer::OnAccepted,
+                              weak_factory_.GetWeakPtr(), accept_result));
 }
 
 void SimpleHttpServer::OnAccepted(int result) {
   CHECK(CalledOnValidThread());
   ASSERT_EQ(result, 0);  // Fails if the socket is already in use.
   new Connection(client_socket_.release(), factory_);
   AcceptConnection();
 }
 
 class AdbParser : public SimpleHttpServer::Parser,
@@ skipping 215 matching lines @@
 
 void StopMockAdbServer() {
   BrowserThread::PostTaskAndReply(
       BrowserThread::IO,
       FROM_HERE,
       base::Bind(&StopMockAdbServerOnIOThread),
       base::MessageLoop::QuitClosure());
   content::RunMessageLoop();
 }