Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(263)

Side by Side Diff: chrome/browser/devtools/device/usb/android_usb_device.h

Issue 497363004: Merge components/usb_service into device/usb. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Rebased. Created 6 years, 3 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
1 // Copyright 2014 The Chromium Authors. All rights reserved. 1 // Copyright 2014 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #ifndef CHROME_BROWSER_DEVTOOLS_DEVICE_USB_ANDROID_USB_DEVICE_H_ 5 #ifndef CHROME_BROWSER_DEVTOOLS_DEVICE_USB_ANDROID_USB_DEVICE_H_
6 #define CHROME_BROWSER_DEVTOOLS_DEVICE_USB_ANDROID_USB_DEVICE_H_ 6 #define CHROME_BROWSER_DEVTOOLS_DEVICE_USB_ANDROID_USB_DEVICE_H_
7 7
8 #include <map> 8 #include <map>
9 #include <queue> 9 #include <queue>
10 #include <vector> 10 #include <vector>
11
11 #include "base/memory/ref_counted.h" 12 #include "base/memory/ref_counted.h"
12 #include "base/memory/weak_ptr.h" 13 #include "base/memory/weak_ptr.h"
13 #include "components/usb_service/usb_device_handle.h" 14 #include "device/usb/usb_device_handle.h"
14 15
15 namespace base { 16 namespace base {
16 class MessageLoop; 17 class MessageLoop;
17 } 18 }
18 19
19 namespace crypto { 20 namespace crypto {
20 class RSAPrivateKey; 21 class RSAPrivateKey;
21 } 22 }
22 23
23 namespace net { 24 namespace net {
(...skipping 42 matching lines...) Expand 10 before | Expand all | Expand 10 after
66 AndroidUsbDevicesCallback; 67 AndroidUsbDevicesCallback;
67 68
68 class AndroidUsbDevice : public base::RefCountedThreadSafe<AndroidUsbDevice> { 69 class AndroidUsbDevice : public base::RefCountedThreadSafe<AndroidUsbDevice> {
69 public: 70 public:
70 static void Enumerate(crypto::RSAPrivateKey* rsa_key, 71 static void Enumerate(crypto::RSAPrivateKey* rsa_key,
71 const AndroidUsbDevicesCallback& callback); 72 const AndroidUsbDevicesCallback& callback);
72 73
73 static void CountDevices(const base::Callback<void(int)>& callback); 74 static void CountDevices(const base::Callback<void(int)>& callback);
74 75
75 AndroidUsbDevice(crypto::RSAPrivateKey* rsa_key, 76 AndroidUsbDevice(crypto::RSAPrivateKey* rsa_key,
76 scoped_refptr<usb_service::UsbDeviceHandle> device, 77 scoped_refptr<device::UsbDeviceHandle> device,
77 const std::string& serial, 78 const std::string& serial,
78 int inbound_address, 79 int inbound_address,
79 int outbound_address, 80 int outbound_address,
80 int zero_mask, 81 int zero_mask,
81 int interface_id); 82 int interface_id);
82 83
83 void InitOnCallerThread(); 84 void InitOnCallerThread();
84 85
85 net::StreamSocket* CreateSocket(const std::string& command); 86 net::StreamSocket* CreateSocket(const std::string& command);
86 87
87 void Send(uint32 command, 88 void Send(uint32 command,
88 uint32 arg0, 89 uint32 arg0,
89 uint32 arg1, 90 uint32 arg1,
90 const std::string& body); 91 const std::string& body);
91 92
92 scoped_refptr<usb_service::UsbDeviceHandle> usb_device() { 93 scoped_refptr<device::UsbDeviceHandle> usb_device() { return usb_handle_; }
93 return usb_handle_;
94 }
95 94
96 std::string serial() { return serial_; } 95 std::string serial() { return serial_; }
97 96
98 bool is_connected() { return is_connected_; } 97 bool is_connected() { return is_connected_; }
99 98
100 private: 99 private:
101 friend class base::RefCountedThreadSafe<AndroidUsbDevice>; 100 friend class base::RefCountedThreadSafe<AndroidUsbDevice>;
102 virtual ~AndroidUsbDevice(); 101 virtual ~AndroidUsbDevice();
103 102
104 void Queue(scoped_refptr<AdbMessage> message); 103 void Queue(scoped_refptr<AdbMessage> message);
105 void ProcessOutgoing(); 104 void ProcessOutgoing();
106 void OutgoingMessageSent(usb_service::UsbTransferStatus status, 105 void OutgoingMessageSent(device::UsbTransferStatus status,
107 scoped_refptr<net::IOBuffer> buffer, 106 scoped_refptr<net::IOBuffer> buffer,
108 size_t result); 107 size_t result);
109 108
110 void ReadHeader(); 109 void ReadHeader();
111 void ParseHeader(usb_service::UsbTransferStatus status, 110 void ParseHeader(device::UsbTransferStatus status,
112 scoped_refptr<net::IOBuffer> buffer, 111 scoped_refptr<net::IOBuffer> buffer,
113 size_t result); 112 size_t result);
114 113
115 void ReadBody(scoped_refptr<AdbMessage> message, 114 void ReadBody(scoped_refptr<AdbMessage> message,
116 uint32 data_length, 115 uint32 data_length,
117 uint32 data_check); 116 uint32 data_check);
118 void ParseBody(scoped_refptr<AdbMessage> message, 117 void ParseBody(scoped_refptr<AdbMessage> message,
119 uint32 data_length, 118 uint32 data_length,
120 uint32 data_check, 119 uint32 data_check,
121 usb_service::UsbTransferStatus status, 120 device::UsbTransferStatus status,
122 scoped_refptr<net::IOBuffer> buffer, 121 scoped_refptr<net::IOBuffer> buffer,
123 size_t result); 122 size_t result);
124 123
125 void HandleIncoming(scoped_refptr<AdbMessage> message); 124 void HandleIncoming(scoped_refptr<AdbMessage> message);
126 125
127 void TransferError(usb_service::UsbTransferStatus status); 126 void TransferError(device::UsbTransferStatus status);
128 127
129 void TerminateIfReleased( 128 void TerminateIfReleased(scoped_refptr<device::UsbDeviceHandle> usb_handle);
130 scoped_refptr<usb_service::UsbDeviceHandle> usb_handle);
131 void Terminate(); 129 void Terminate();
132 130
133 void SocketDeleted(uint32 socket_id); 131 void SocketDeleted(uint32 socket_id);
134 132
135 base::MessageLoop* message_loop_; 133 base::MessageLoop* message_loop_;
136 134
137 scoped_ptr<crypto::RSAPrivateKey> rsa_key_; 135 scoped_ptr<crypto::RSAPrivateKey> rsa_key_;
138 136
139 // Device info 137 // Device info
140 scoped_refptr<usb_service::UsbDeviceHandle> usb_handle_; 138 scoped_refptr<device::UsbDeviceHandle> usb_handle_;
141 std::string serial_; 139 std::string serial_;
142 int inbound_address_; 140 int inbound_address_;
143 int outbound_address_; 141 int outbound_address_;
144 int zero_mask_; 142 int zero_mask_;
145 int interface_id_; 143 int interface_id_;
146 144
147 bool is_connected_; 145 bool is_connected_;
148 bool signature_sent_; 146 bool signature_sent_;
149 147
150 // Created sockets info 148 // Created sockets info
151 uint32 last_socket_id_; 149 uint32 last_socket_id_;
152 typedef std::map<uint32, AndroidUsbSocket*> AndroidUsbSockets; 150 typedef std::map<uint32, AndroidUsbSocket*> AndroidUsbSockets;
153 AndroidUsbSockets sockets_; 151 AndroidUsbSockets sockets_;
154 152
155 // Outgoing bulk queue 153 // Outgoing bulk queue
156 typedef scoped_refptr<net::IOBufferWithSize> BulkMessage; 154 typedef scoped_refptr<net::IOBufferWithSize> BulkMessage;
157 std::queue<BulkMessage> outgoing_queue_; 155 std::queue<BulkMessage> outgoing_queue_;
158 156
159 // Outgoing messages pending connect 157 // Outgoing messages pending connect
160 typedef std::vector<scoped_refptr<AdbMessage> > PendingMessages; 158 typedef std::vector<scoped_refptr<AdbMessage> > PendingMessages;
161 PendingMessages pending_messages_; 159 PendingMessages pending_messages_;
162 160
163 base::WeakPtrFactory<AndroidUsbDevice> weak_factory_; 161 base::WeakPtrFactory<AndroidUsbDevice> weak_factory_;
164 162
165 DISALLOW_COPY_AND_ASSIGN(AndroidUsbDevice); 163 DISALLOW_COPY_AND_ASSIGN(AndroidUsbDevice);
166 }; 164 };
167 165
168 #endif // CHROME_BROWSER_DEVTOOLS_DEVICE_USB_ANDROID_USB_DEVICE_H_ 166 #endif // CHROME_BROWSER_DEVTOOLS_DEVICE_USB_ANDROID_USB_DEVICE_H_
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698