[device] Replace MessageLoopProxy usage with ThreadTaskRunnerHandle

device/serial/serial_io_handler_posix.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 "device/serial/serial_io_handler_posix.h"
 
 #include <sys/ioctl.h>
 #include <termios.h>
 
 #include "base/posix/eintr_wrapper.h"
@@ skipping 111 matching lines @@
   return false;
 #endif
 }
 
 }  // namespace
 
 namespace device {
 
 // static
 scoped_refptr<SerialIoHandler> SerialIoHandler::Create(
-    scoped_refptr<base::MessageLoopProxy> file_thread_message_loop,
-    scoped_refptr<base::MessageLoopProxy> ui_thread_message_loop) {
-  return new SerialIoHandlerPosix(file_thread_message_loop,
-                                  ui_thread_message_loop);
+    scoped_refptr<base::SingleThreadTaskRunner> file_thread_task_runner,
+    scoped_refptr<base::SingleThreadTaskRunner> ui_thread_task_runner) {
+  return new SerialIoHandlerPosix(file_thread_task_runner,
+                                  ui_thread_task_runner);
 }
 
 void SerialIoHandlerPosix::RequestAccess(
     const std::string& port,
-    scoped_refptr<base::MessageLoopProxy> file_message_loop,
-    scoped_refptr<base::MessageLoopProxy> ui_message_loop) {
+    scoped_refptr<base::SingleThreadTaskRunner> file_task_runner,
+    scoped_refptr<base::SingleThreadTaskRunner> ui_task_runner) {
 #if defined(OS_LINUX) && defined(OS_CHROMEOS)
   if (base::SysInfo::IsRunningOnChromeOS()) {
     chromeos::PermissionBrokerClient* client =
         chromeos::DBusThreadManager::Get()->GetPermissionBrokerClient();
     if (!client) {
       DVLOG(1) << "Could not get permission_broker client.";
       OnRequestAccessComplete(port, false /* failure */);
       return;
     }
     // PermissionBrokerClient should be called on the UI thread.
-    ui_message_loop->PostTask(
+    ui_task_runner->PostTask(
         FROM_HERE,
         base::Bind(
             &chromeos::PermissionBrokerClient::RequestPathAccess,
-            base::Unretained(client),
-            port,
-            -1,
+            base::Unretained(client), port, -1,
             base::Bind(&SerialIoHandler::OnRequestAccessComplete, this, port)));
   } else {
     OnRequestAccessComplete(port, true /* success */);
     return;
   }
 #else
   OnRequestAccessComplete(port, true /* success */);
 #endif  // defined(OS_LINUX) && defined(OS_CHROMEOS)
 }
 
@@ skipping 103 matching lines @@
   }
 
   if (tcsetattr(file().GetPlatformFile(), TCSANOW, &config) != 0) {
     VPLOG(1) << "Failed to set port attributes";
     return false;
   }
   return true;
 }
 
 SerialIoHandlerPosix::SerialIoHandlerPosix(
-    scoped_refptr<base::MessageLoopProxy> file_thread_message_loop,
-    scoped_refptr<base::MessageLoopProxy> ui_thread_message_loop)
-    : SerialIoHandler(file_thread_message_loop, ui_thread_message_loop),
+    scoped_refptr<base::SingleThreadTaskRunner> file_thread_task_runner,
+    scoped_refptr<base::SingleThreadTaskRunner> ui_thread_task_runner)
+    : SerialIoHandler(file_thread_task_runner, ui_thread_task_runner),
       is_watching_reads_(false),
       is_watching_writes_(false) {
 }
 
 SerialIoHandlerPosix::~SerialIoHandlerPosix() {
 }
 
 void SerialIoHandlerPosix::OnFileCanReadWithoutBlocking(int fd) {
   DCHECK(CalledOnValidThread());
   DCHECK_EQ(fd, file().GetPlatformFile());
@@ skipping 159 matching lines @@
       (config.c_cflag & CSTOPB) ? serial::STOP_BITS_TWO : serial::STOP_BITS_ONE;
   info->cts_flow_control = (config.c_cflag & CRTSCTS) != 0;
   return info.Pass();
 }
 
 std::string SerialIoHandler::MaybeFixUpPortName(const std::string& port_name) {
   return port_name;
 }
 
 }  // namespace device