Move device/usb classes from the FILE thread to UI thread.

chrome/browser/devtools/device/usb/android_usb_device.h

 // 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.
 
 #ifndef CHROME_BROWSER_DEVTOOLS_DEVICE_USB_ANDROID_USB_DEVICE_H_
 #define CHROME_BROWSER_DEVTOOLS_DEVICE_USB_ANDROID_USB_DEVICE_H_
 
 #include <map>
 #include <queue>
 #include <vector>
 
 #include "base/memory/ref_counted.h"
 #include "base/memory/scoped_vector.h"
 #include "base/memory/weak_ptr.h"
 #include "device/usb/usb_device_handle.h"
 
 namespace base {
-class MessageLoop;
+class SingleThreadTaskRunner;
 }
 
 namespace crypto {
 class RSAPrivateKey;
 }
 
 namespace net {
 class StreamSocket;
 }
 
@@ skipping 32 matching lines @@
   DISALLOW_COPY_AND_ASSIGN(AdbMessage);
 };
 
 class AndroidUsbDevice;
 typedef std::vector<scoped_refptr<AndroidUsbDevice> > AndroidUsbDevices;
 typedef base::Callback<void(const AndroidUsbDevices&)>
     AndroidUsbDevicesCallback;
 
 class AndroidUsbDevice : public base::RefCountedThreadSafe<AndroidUsbDevice> {
  public:
+  static void CountDevices(const base::Callback<void(int)>& callback);
   static void Enumerate(crypto::RSAPrivateKey* rsa_key,
                         const AndroidUsbDevicesCallback& callback);
 
-  static void CountDevices(const base::Callback<void(int)>& callback);
-
   AndroidUsbDevice(crypto::RSAPrivateKey* rsa_key,
                    scoped_refptr<device::UsbDeviceHandle> device,
                    const std::string& serial,
                    int inbound_address,
                    int outbound_address,
                    int zero_mask,
                    int interface_id);
 
   void InitOnCallerThread();
 
   net::StreamSocket* CreateSocket(const std::string& command);
 
   void Send(uint32 command,
             uint32 arg0,
             uint32 arg1,
             const std::string& body);
 
   scoped_refptr<device::UsbDeviceHandle> usb_device() { return usb_handle_; }
 
   std::string serial() { return serial_; }
 
   bool is_connected() { return is_connected_; }
 
  private:
   friend class base::RefCountedThreadSafe<AndroidUsbDevice>;
   virtual ~AndroidUsbDevice();
 
   void Queue(scoped_ptr<AdbMessage> message);
   void ProcessOutgoing();
-  void OutgoingMessageSent(device::UsbTransferStatus status,
-                           scoped_refptr<net::IOBuffer> buffer,
-                           size_t result);
+  static void OutgoingMessageSent(
+      base::WeakPtr<AndroidUsbDevice> device,
+      scoped_refptr<base::SingleThreadTaskRunner> task_runner,
+      device::UsbTransferStatus status,
+      scoped_refptr<net::IOBuffer> buffer,
+      size_t result);
 
   void ReadHeader();
+  static void ReceivedHeader(
+      base::WeakPtr<AndroidUsbDevice> device,
+      scoped_refptr<base::SingleThreadTaskRunner> task_runner,
+      device::UsbTransferStatus status,
+      scoped_refptr<net::IOBuffer> buffer,
+      size_t result);
   void ParseHeader(device::UsbTransferStatus status,
                    scoped_refptr<net::IOBuffer> buffer,
                    size_t result);
 
   void ReadBody(scoped_ptr<AdbMessage> message,
                 uint32 data_length,
                 uint32 data_check);
+  static void ReceivedBody(
+      base::WeakPtr<AndroidUsbDevice> device,
+      scoped_refptr<base::SingleThreadTaskRunner> task_runner,
+      scoped_ptr<AdbMessage> message,
+      uint32 data_length,
+      uint32 data_check,
+      device::UsbTransferStatus status,
+      scoped_refptr<net::IOBuffer> buffer,
+      size_t result);
   void ParseBody(scoped_ptr<AdbMessage> message,
                  uint32 data_length,
                  uint32 data_check,
                  device::UsbTransferStatus status,
                  scoped_refptr<net::IOBuffer> buffer,
                  size_t result);
 
   void HandleIncoming(scoped_ptr<AdbMessage> message);
 
   void TransferError(device::UsbTransferStatus status);
 
   void TerminateIfReleased(scoped_refptr<device::UsbDeviceHandle> usb_handle);
   void Terminate();
 
   void SocketDeleted(uint32 socket_id);
 
-  base::MessageLoop* message_loop_;
+  scoped_refptr<base::SingleThreadTaskRunner> task_runner_;
 
   scoped_ptr<crypto::RSAPrivateKey> rsa_key_;
 
   // Device info
   scoped_refptr<device::UsbDeviceHandle> usb_handle_;
   std::string serial_;
   int inbound_address_;
   int outbound_address_;
   int zero_mask_;
   int interface_id_;
@@ skipping 13 matching lines @@
   // Outgoing messages pending connect
   typedef ScopedVector<AdbMessage> PendingMessages;
   PendingMessages pending_messages_;
 
   base::WeakPtrFactory<AndroidUsbDevice> weak_factory_;
 
   DISALLOW_COPY_AND_ASSIGN(AndroidUsbDevice);
 };
 
 #endif  // CHROME_BROWSER_DEVTOOLS_DEVICE_USB_ANDROID_USB_DEVICE_H_