OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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 #include "chrome/browser/usb/usb_device.h" | 5 #include "chrome/browser/usb/usb_device.h" |
6 | 6 |
| 7 #include <vector> |
| 8 |
7 #include "base/stl_util.h" | 9 #include "base/stl_util.h" |
8 #include "base/synchronization/lock.h" | 10 #include "base/synchronization/lock.h" |
| 11 #include "chrome/browser/usb/usb_interface.h" |
9 #include "chrome/browser/usb/usb_service.h" | 12 #include "chrome/browser/usb/usb_service.h" |
10 #include "third_party/libusb/src/libusb/libusb.h" | 13 #include "third_party/libusb/src/libusb/libusb.h" |
11 | 14 |
12 namespace { | 15 namespace { |
13 | 16 |
14 static uint8 ConvertTransferDirection( | 17 static uint8 ConvertTransferDirection( |
15 const UsbDevice::TransferDirection direction) { | 18 const UsbInterfaceDirection direction) { |
16 switch (direction) { | 19 switch (direction) { |
17 case UsbDevice::INBOUND: | 20 case USB_DIRECTION_INBOUND: |
18 return LIBUSB_ENDPOINT_IN; | 21 return LIBUSB_ENDPOINT_IN; |
19 case UsbDevice::OUTBOUND: | 22 case USB_DIRECTION_OUTBOUND: |
20 return LIBUSB_ENDPOINT_OUT; | 23 return LIBUSB_ENDPOINT_OUT; |
21 } | 24 } |
22 NOTREACHED(); | 25 NOTREACHED(); |
23 return LIBUSB_ENDPOINT_OUT; | 26 return LIBUSB_ENDPOINT_OUT; |
24 } | 27 } |
25 | 28 |
26 static uint8 CreateRequestType(const UsbDevice::TransferDirection direction, | 29 static uint8 CreateRequestType(const UsbInterfaceDirection direction, |
27 const UsbDevice::TransferRequestType request_type, | 30 const UsbDevice::TransferRequestType request_type, |
28 const UsbDevice::TransferRecipient recipient) { | 31 const UsbDevice::TransferRecipient recipient) { |
29 uint8 result = ConvertTransferDirection(direction); | 32 uint8 result = ConvertTransferDirection(direction); |
30 | 33 |
31 switch (request_type) { | 34 switch (request_type) { |
32 case UsbDevice::STANDARD: | 35 case UsbDevice::STANDARD: |
33 result |= LIBUSB_REQUEST_TYPE_STANDARD; | 36 result |= LIBUSB_REQUEST_TYPE_STANDARD; |
34 break; | 37 break; |
35 case UsbDevice::CLASS: | 38 case UsbDevice::CLASS: |
36 result |= LIBUSB_REQUEST_TYPE_CLASS; | 39 result |= LIBUSB_REQUEST_TYPE_CLASS; |
(...skipping 83 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
120 | 123 |
121 DCHECK(handle->actual_length >= 0) << "Negative actual length received"; | 124 DCHECK(handle->actual_length >= 0) << "Negative actual length received"; |
122 size_t actual_length = | 125 size_t actual_length = |
123 static_cast<size_t>(std::max(handle->actual_length, 0)); | 126 static_cast<size_t>(std::max(handle->actual_length, 0)); |
124 | 127 |
125 DCHECK(transfer->length >= actual_length) << | 128 DCHECK(transfer->length >= actual_length) << |
126 "data too big for our buffer (libusb failure?)"; | 129 "data too big for our buffer (libusb failure?)"; |
127 | 130 |
128 scoped_refptr<net::IOBuffer> buffer = transfer->buffer; | 131 scoped_refptr<net::IOBuffer> buffer = transfer->buffer; |
129 switch (transfer->transfer_type) { | 132 switch (transfer->transfer_type) { |
130 case USB_TRANSFER_CONTROL: | 133 case USB_ENDPOINT_CONTROL: |
131 // If the transfer is a control transfer we do not expose the control | 134 // If the transfer is a control transfer we do not expose the control |
132 // setup header to the caller. This logic strips off the header if | 135 // setup header to the caller. This logic strips off the header if |
133 // present before invoking the callback provided with the transfer. | 136 // present before invoking the callback provided with the transfer. |
134 if (actual_length > 0) { | 137 if (actual_length > 0) { |
135 CHECK(transfer->length >= LIBUSB_CONTROL_SETUP_SIZE) << | 138 CHECK(transfer->length >= LIBUSB_CONTROL_SETUP_SIZE) << |
136 "buffer was not correctly set: too small for the control header"; | 139 "buffer was not correctly set: too small for the control header"; |
137 | 140 |
138 if (transfer->length >= actual_length && | 141 if (transfer->length >= actual_length && |
139 actual_length >= LIBUSB_CONTROL_SETUP_SIZE) { | 142 actual_length >= LIBUSB_CONTROL_SETUP_SIZE) { |
140 // If the payload is zero bytes long, pad out the allocated buffer | 143 // If the payload is zero bytes long, pad out the allocated buffer |
141 // size to one byte so that an IOBuffer of that size can be allocated. | 144 // size to one byte so that an IOBuffer of that size can be allocated. |
142 scoped_refptr<net::IOBuffer> resized_buffer = new net::IOBuffer( | 145 scoped_refptr<net::IOBuffer> resized_buffer = new net::IOBuffer( |
143 std::max(actual_length, static_cast<size_t>(1))); | 146 std::max(actual_length, static_cast<size_t>(1))); |
144 memcpy(resized_buffer->data(), | 147 memcpy(resized_buffer->data(), |
145 buffer->data() + LIBUSB_CONTROL_SETUP_SIZE, | 148 buffer->data() + LIBUSB_CONTROL_SETUP_SIZE, |
146 actual_length); | 149 actual_length); |
147 buffer = resized_buffer; | 150 buffer = resized_buffer; |
148 } | 151 } |
149 } | 152 } |
150 break; | 153 break; |
151 | 154 |
152 case USB_TRANSFER_ISOCHRONOUS: | 155 case USB_ENDPOINT_ISOCHRONOUS: |
153 // Isochronous replies might carry data in the different isoc packets even | 156 // Isochronous replies might carry data in the different isoc packets even |
154 // if the transfer actual_data value is zero. Furthermore, not all of the | 157 // if the transfer actual_data value is zero. Furthermore, not all of the |
155 // received packets might contain data, so we need to calculate how many | 158 // received packets might contain data, so we need to calculate how many |
156 // data bytes we are effectively providing and pack the results. | 159 // data bytes we are effectively providing and pack the results. |
157 if (actual_length == 0) { | 160 if (actual_length == 0) { |
158 size_t packet_buffer_start = 0; | 161 size_t packet_buffer_start = 0; |
159 for (int i = 0; i < handle->num_iso_packets; ++i) { | 162 for (int i = 0; i < handle->num_iso_packets; ++i) { |
160 PlatformUsbIsoPacketDescriptor packet = &handle->iso_packet_desc[i]; | 163 PlatformUsbIsoPacketDescriptor packet = &handle->iso_packet_desc[i]; |
161 if (packet->actual_length > 0) { | 164 if (packet->actual_length > 0) { |
162 // We don't need to copy as long as all packets until now provide | 165 // We don't need to copy as long as all packets until now provide |
163 // all the data the packet can hold. | 166 // all the data the packet can hold. |
164 if (actual_length < packet_buffer_start) { | 167 if (actual_length < packet_buffer_start) { |
165 CHECK(packet_buffer_start + packet->actual_length <= | 168 CHECK(packet_buffer_start + packet->actual_length <= |
166 transfer->length); | 169 transfer->length); |
167 memmove(buffer->data() + actual_length, | 170 memmove(buffer->data() + actual_length, |
168 buffer->data() + packet_buffer_start, | 171 buffer->data() + packet_buffer_start, |
169 packet->actual_length); | 172 packet->actual_length); |
170 } | 173 } |
171 actual_length += packet->actual_length; | 174 actual_length += packet->actual_length; |
172 } | 175 } |
173 | 176 |
174 packet_buffer_start += packet->length; | 177 packet_buffer_start += packet->length; |
175 } | 178 } |
176 } | 179 } |
177 break; | 180 break; |
178 | 181 |
179 case USB_TRANSFER_BULK: | 182 case USB_ENDPOINT_BULK: |
180 case USB_TRANSFER_INTERRUPT: | 183 case USB_ENDPOINT_INTERRUPT: |
181 break; | 184 break; |
182 | 185 |
183 default: | 186 default: |
184 NOTREACHED() << "Invalid usb transfer type"; | 187 NOTREACHED() << "Invalid usb transfer type"; |
185 } | 188 } |
186 | 189 |
187 transfer->callback.Run(ConvertTransferStatus(handle->status), buffer, | 190 transfer->callback.Run(ConvertTransferStatus(handle->status), buffer, |
188 actual_length); | 191 actual_length); |
189 | 192 |
190 transfers_.erase(handle); | 193 transfers_.erase(handle); |
191 libusb_free_transfer(handle); | 194 libusb_free_transfer(handle); |
192 } | 195 } |
193 | 196 |
| 197 void UsbDevice::ListInterfaces(PlatformUsbConfigDescriptor* config, |
| 198 const UsbInterfaceCallback& callback) { |
| 199 PlatformUsbDevice device = libusb_get_device(handle_); |
| 200 |
| 201 const int list_result = libusb_get_active_config_descriptor(device, config); |
| 202 callback.Run(list_result == 0); |
| 203 } |
| 204 |
194 void UsbDevice::ClaimInterface(const int interface_number, | 205 void UsbDevice::ClaimInterface(const int interface_number, |
195 const UsbInterfaceCallback& callback) { | 206 const UsbInterfaceCallback& callback) { |
196 CheckDevice(); | 207 CheckDevice(); |
197 | 208 |
198 const int claim_result = libusb_claim_interface(handle_, interface_number); | 209 const int claim_result = libusb_claim_interface(handle_, interface_number); |
199 callback.Run(claim_result == 0); | 210 callback.Run(claim_result == 0); |
200 } | 211 } |
201 | 212 |
202 void UsbDevice::ReleaseInterface(const int interface_number, | 213 void UsbDevice::ReleaseInterface(const int interface_number, |
203 const UsbInterfaceCallback& callback) { | 214 const UsbInterfaceCallback& callback) { |
204 CheckDevice(); | 215 CheckDevice(); |
205 | 216 |
206 const int release_result = libusb_release_interface(handle_, | 217 const int release_result = libusb_release_interface(handle_, |
207 interface_number); | 218 interface_number); |
208 callback.Run(release_result == 0); | 219 callback.Run(release_result == 0); |
209 } | 220 } |
210 | 221 |
211 void UsbDevice::SetInterfaceAlternateSetting( | 222 void UsbDevice::SetInterfaceAlternateSetting( |
212 const int interface_number, | 223 const int interface_number, |
213 const int alternate_setting, | 224 const int alternate_setting, |
214 const UsbInterfaceCallback& callback) { | 225 const UsbInterfaceCallback& callback) { |
215 CheckDevice(); | 226 CheckDevice(); |
216 | 227 |
217 const int setting_result = libusb_set_interface_alt_setting(handle_, | 228 const int setting_result = libusb_set_interface_alt_setting(handle_, |
218 interface_number, alternate_setting); | 229 interface_number, alternate_setting); |
219 | 230 |
220 callback.Run(setting_result == 0); | 231 callback.Run(setting_result == 0); |
221 } | 232 } |
222 | 233 |
223 void UsbDevice::ControlTransfer(const TransferDirection direction, | 234 void UsbDevice::ControlTransfer(const UsbInterfaceDirection direction, |
224 const TransferRequestType request_type, const TransferRecipient recipient, | 235 const TransferRequestType request_type, const TransferRecipient recipient, |
225 const uint8 request, const uint16 value, const uint16 index, | 236 const uint8 request, const uint16 value, const uint16 index, |
226 net::IOBuffer* buffer, const size_t length, const unsigned int timeout, | 237 net::IOBuffer* buffer, const size_t length, const unsigned int timeout, |
227 const UsbTransferCallback& callback) { | 238 const UsbTransferCallback& callback) { |
228 CheckDevice(); | 239 CheckDevice(); |
229 | 240 |
230 const size_t resized_length = LIBUSB_CONTROL_SETUP_SIZE + length; | 241 const size_t resized_length = LIBUSB_CONTROL_SETUP_SIZE + length; |
231 scoped_refptr<net::IOBuffer> resized_buffer(new net::IOBufferWithSize( | 242 scoped_refptr<net::IOBuffer> resized_buffer(new net::IOBufferWithSize( |
232 resized_length)); | 243 resized_length)); |
233 memcpy(resized_buffer->data() + LIBUSB_CONTROL_SETUP_SIZE, buffer->data(), | 244 memcpy(resized_buffer->data() + LIBUSB_CONTROL_SETUP_SIZE, buffer->data(), |
234 length); | 245 length); |
235 | 246 |
236 struct libusb_transfer* const transfer = libusb_alloc_transfer(0); | 247 struct libusb_transfer* const transfer = libusb_alloc_transfer(0); |
237 const uint8 converted_type = CreateRequestType(direction, request_type, | 248 const uint8 converted_type = CreateRequestType(direction, request_type, |
238 recipient); | 249 recipient); |
239 libusb_fill_control_setup(reinterpret_cast<uint8*>(resized_buffer->data()), | 250 libusb_fill_control_setup(reinterpret_cast<uint8*>(resized_buffer->data()), |
240 converted_type, request, value, index, length); | 251 converted_type, request, value, index, length); |
241 libusb_fill_control_transfer(transfer, handle_, reinterpret_cast<uint8*>( | 252 libusb_fill_control_transfer(transfer, handle_, reinterpret_cast<uint8*>( |
242 resized_buffer->data()), HandleTransferCompletion, this, timeout); | 253 resized_buffer->data()), HandleTransferCompletion, this, timeout); |
243 SubmitTransfer(transfer, USB_TRANSFER_CONTROL, resized_buffer, resized_length, | 254 SubmitTransfer(transfer, USB_ENDPOINT_CONTROL, resized_buffer, resized_length, |
244 callback); | 255 callback); |
245 } | 256 } |
246 | 257 |
247 void UsbDevice::BulkTransfer(const TransferDirection direction, | 258 void UsbDevice::BulkTransfer(const UsbInterfaceDirection direction, |
248 const uint8 endpoint, net::IOBuffer* buffer, const size_t length, | 259 const uint8 endpoint, net::IOBuffer* buffer, const size_t length, |
249 const unsigned int timeout, const UsbTransferCallback& callback) { | 260 const unsigned int timeout, const UsbTransferCallback& callback) { |
250 CheckDevice(); | 261 CheckDevice(); |
251 | 262 |
252 struct libusb_transfer* const transfer = libusb_alloc_transfer(0); | 263 struct libusb_transfer* const transfer = libusb_alloc_transfer(0); |
253 const uint8 new_endpoint = ConvertTransferDirection(direction) | endpoint; | 264 const uint8 new_endpoint = ConvertTransferDirection(direction) | endpoint; |
254 libusb_fill_bulk_transfer(transfer, handle_, new_endpoint, | 265 libusb_fill_bulk_transfer(transfer, handle_, new_endpoint, |
255 reinterpret_cast<uint8*>(buffer->data()), length, | 266 reinterpret_cast<uint8*>(buffer->data()), length, |
256 HandleTransferCompletion, this, timeout); | 267 HandleTransferCompletion, this, timeout); |
257 SubmitTransfer(transfer, USB_TRANSFER_BULK, buffer, length, callback); | 268 SubmitTransfer(transfer, USB_ENDPOINT_BULK, buffer, length, callback); |
258 } | 269 } |
259 | 270 |
260 void UsbDevice::InterruptTransfer(const TransferDirection direction, | 271 void UsbDevice::InterruptTransfer(const UsbInterfaceDirection direction, |
261 const uint8 endpoint, net::IOBuffer* buffer, const size_t length, | 272 const uint8 endpoint, net::IOBuffer* buffer, const size_t length, |
262 const unsigned int timeout, const UsbTransferCallback& callback) { | 273 const unsigned int timeout, const UsbTransferCallback& callback) { |
263 CheckDevice(); | 274 CheckDevice(); |
264 | 275 |
265 struct libusb_transfer* const transfer = libusb_alloc_transfer(0); | 276 struct libusb_transfer* const transfer = libusb_alloc_transfer(0); |
266 const uint8 new_endpoint = ConvertTransferDirection(direction) | endpoint; | 277 const uint8 new_endpoint = ConvertTransferDirection(direction) | endpoint; |
267 libusb_fill_interrupt_transfer(transfer, handle_, new_endpoint, | 278 libusb_fill_interrupt_transfer(transfer, handle_, new_endpoint, |
268 reinterpret_cast<uint8*>(buffer->data()), length, | 279 reinterpret_cast<uint8*>(buffer->data()), length, |
269 HandleTransferCompletion, this, timeout); | 280 HandleTransferCompletion, this, timeout); |
270 SubmitTransfer(transfer, USB_TRANSFER_INTERRUPT, buffer, length, callback); | 281 SubmitTransfer(transfer, USB_ENDPOINT_INTERRUPT, buffer, length, callback); |
271 } | 282 } |
272 | 283 |
273 void UsbDevice::IsochronousTransfer(const TransferDirection direction, | 284 void UsbDevice::IsochronousTransfer(const UsbInterfaceDirection direction, |
274 const uint8 endpoint, net::IOBuffer* buffer, const size_t length, | 285 const uint8 endpoint, net::IOBuffer* buffer, const size_t length, |
275 const unsigned int packets, const unsigned int packet_length, | 286 const unsigned int packets, const unsigned int packet_length, |
276 const unsigned int timeout, const UsbTransferCallback& callback) { | 287 const unsigned int timeout, const UsbTransferCallback& callback) { |
277 CheckDevice(); | 288 CheckDevice(); |
278 | 289 |
279 const uint64 total_length = packets * packet_length; | 290 const uint64 total_length = packets * packet_length; |
280 CHECK(packets <= length && total_length <= length) << | 291 CHECK(packets <= length && total_length <= length) << |
281 "transfer length is too small"; | 292 "transfer length is too small"; |
282 | 293 |
283 struct libusb_transfer* const transfer = libusb_alloc_transfer(packets); | 294 struct libusb_transfer* const transfer = libusb_alloc_transfer(packets); |
284 const uint8 new_endpoint = ConvertTransferDirection(direction) | endpoint; | 295 const uint8 new_endpoint = ConvertTransferDirection(direction) | endpoint; |
285 libusb_fill_iso_transfer(transfer, handle_, new_endpoint, | 296 libusb_fill_iso_transfer(transfer, handle_, new_endpoint, |
286 reinterpret_cast<uint8*>(buffer->data()), length, packets, | 297 reinterpret_cast<uint8*>(buffer->data()), length, packets, |
287 HandleTransferCompletion, this, timeout); | 298 HandleTransferCompletion, this, timeout); |
288 libusb_set_iso_packet_lengths(transfer, packet_length); | 299 libusb_set_iso_packet_lengths(transfer, packet_length); |
289 | 300 |
290 SubmitTransfer(transfer, USB_TRANSFER_ISOCHRONOUS, buffer, length, callback); | 301 SubmitTransfer(transfer, USB_ENDPOINT_ISOCHRONOUS, buffer, length, callback); |
291 } | 302 } |
292 | 303 |
293 void UsbDevice::CheckDevice() { | 304 void UsbDevice::CheckDevice() { |
294 DCHECK(handle_) << "Device is already closed."; | 305 DCHECK(handle_) << "Device is already closed."; |
295 } | 306 } |
296 | 307 |
297 void UsbDevice::SubmitTransfer(PlatformUsbTransferHandle handle, | 308 void UsbDevice::SubmitTransfer(PlatformUsbTransferHandle handle, |
298 UsbTransferType transfer_type, | 309 UsbEndpointType transfer_type, |
299 net::IOBuffer* buffer, | 310 net::IOBuffer* buffer, |
300 const size_t length, | 311 const size_t length, |
301 const UsbTransferCallback& callback) { | 312 const UsbTransferCallback& callback) { |
302 Transfer transfer; | 313 Transfer transfer; |
303 transfer.transfer_type = transfer_type; | 314 transfer.transfer_type = transfer_type; |
304 transfer.buffer = buffer; | 315 transfer.buffer = buffer; |
305 transfer.length = length; | 316 transfer.length = length; |
306 transfer.callback = callback; | 317 transfer.callback = callback; |
307 | 318 |
308 { | 319 { |
309 base::AutoLock lock(lock_); | 320 base::AutoLock lock(lock_); |
310 transfers_[handle] = transfer; | 321 transfers_[handle] = transfer; |
311 libusb_submit_transfer(handle); | 322 libusb_submit_transfer(handle); |
312 } | 323 } |
313 } | 324 } |
OLD | NEW |