| OLD | NEW |
| 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 #include "device/usb/usb_device_impl.h" | 5 #include "device/usb/usb_device_impl.h" |
| 6 | 6 |
| 7 #include <algorithm> | 7 #include <algorithm> |
| 8 | 8 |
| 9 #include "base/bind.h" | 9 #include "base/bind.h" |
| 10 #include "base/location.h" | 10 #include "base/location.h" |
| 11 #include "base/single_thread_task_runner.h" | 11 #include "base/single_thread_task_runner.h" |
| 12 #include "base/stl_util.h" | 12 #include "base/stl_util.h" |
| 13 #include "base/thread_task_runner_handle.h" | 13 #include "base/thread_task_runner_handle.h" |
| 14 #include "device/usb/usb_context.h" | 14 #include "device/usb/usb_context.h" |
| 15 #include "device/usb/usb_descriptors.h" |
| 15 #include "device/usb/usb_device_handle_impl.h" | 16 #include "device/usb/usb_device_handle_impl.h" |
| 16 #include "device/usb/usb_error.h" | 17 #include "device/usb/usb_error.h" |
| 17 #include "device/usb/usb_interface_impl.h" | |
| 18 #include "third_party/libusb/src/libusb/libusb.h" | 18 #include "third_party/libusb/src/libusb/libusb.h" |
| 19 | 19 |
| 20 #if defined(OS_CHROMEOS) | 20 #if defined(OS_CHROMEOS) |
| 21 #include "base/sys_info.h" | 21 #include "base/sys_info.h" |
| 22 #include "chromeos/dbus/dbus_thread_manager.h" | 22 #include "chromeos/dbus/dbus_thread_manager.h" |
| 23 #include "chromeos/dbus/permission_broker_client.h" | 23 #include "chromeos/dbus/permission_broker_client.h" |
| 24 #endif // defined(OS_CHROMEOS) | 24 #endif // defined(OS_CHROMEOS) |
| 25 | 25 |
| 26 namespace device { |
| 27 |
| 26 namespace { | 28 namespace { |
| 27 | 29 |
| 28 #if defined(OS_CHROMEOS) | 30 #if defined(OS_CHROMEOS) |
| 29 void OnRequestUsbAccessReplied( | 31 void OnRequestUsbAccessReplied( |
| 30 scoped_refptr<base::SingleThreadTaskRunner> task_runner, | 32 scoped_refptr<base::SingleThreadTaskRunner> task_runner, |
| 31 const base::Callback<void(bool success)>& callback, | 33 const base::Callback<void(bool success)>& callback, |
| 32 bool success) { | 34 bool success) { |
| 33 task_runner->PostTask(FROM_HERE, base::Bind(callback, success)); | 35 task_runner->PostTask(FROM_HERE, base::Bind(callback, success)); |
| 34 } | 36 } |
| 35 #endif // defined(OS_CHROMEOS) | 37 #endif // defined(OS_CHROMEOS) |
| 36 | 38 |
| 39 UsbEndpointDirection GetDirection( |
| 40 const libusb_endpoint_descriptor* descriptor) { |
| 41 switch (descriptor->bEndpointAddress & LIBUSB_ENDPOINT_DIR_MASK) { |
| 42 case LIBUSB_ENDPOINT_IN: |
| 43 return USB_DIRECTION_INBOUND; |
| 44 case LIBUSB_ENDPOINT_OUT: |
| 45 return USB_DIRECTION_OUTBOUND; |
| 46 default: |
| 47 NOTREACHED(); |
| 48 return USB_DIRECTION_INBOUND; |
| 49 } |
| 50 } |
| 51 |
| 52 UsbSynchronizationType GetSynchronizationType( |
| 53 const libusb_endpoint_descriptor* descriptor) { |
| 54 switch (descriptor->bmAttributes & LIBUSB_ISO_SYNC_TYPE_MASK) { |
| 55 case LIBUSB_ISO_SYNC_TYPE_NONE: |
| 56 return USB_SYNCHRONIZATION_NONE; |
| 57 case LIBUSB_ISO_SYNC_TYPE_ASYNC: |
| 58 return USB_SYNCHRONIZATION_ASYNCHRONOUS; |
| 59 case LIBUSB_ISO_SYNC_TYPE_ADAPTIVE: |
| 60 return USB_SYNCHRONIZATION_ADAPTIVE; |
| 61 case LIBUSB_ISO_SYNC_TYPE_SYNC: |
| 62 return USB_SYNCHRONIZATION_SYNCHRONOUS; |
| 63 default: |
| 64 NOTREACHED(); |
| 65 return USB_SYNCHRONIZATION_NONE; |
| 66 } |
| 67 } |
| 68 |
| 69 UsbTransferType GetTransferType(const libusb_endpoint_descriptor* descriptor) { |
| 70 switch (descriptor->bmAttributes & LIBUSB_TRANSFER_TYPE_MASK) { |
| 71 case LIBUSB_TRANSFER_TYPE_CONTROL: |
| 72 return USB_TRANSFER_CONTROL; |
| 73 case LIBUSB_TRANSFER_TYPE_ISOCHRONOUS: |
| 74 return USB_TRANSFER_ISOCHRONOUS; |
| 75 case LIBUSB_TRANSFER_TYPE_BULK: |
| 76 return USB_TRANSFER_BULK; |
| 77 case LIBUSB_TRANSFER_TYPE_INTERRUPT: |
| 78 return USB_TRANSFER_INTERRUPT; |
| 79 default: |
| 80 NOTREACHED(); |
| 81 return USB_TRANSFER_CONTROL; |
| 82 } |
| 83 } |
| 84 |
| 85 UsbUsageType GetUsageType(const libusb_endpoint_descriptor* descriptor) { |
| 86 switch (descriptor->bmAttributes & LIBUSB_ISO_USAGE_TYPE_MASK) { |
| 87 case LIBUSB_ISO_USAGE_TYPE_DATA: |
| 88 return USB_USAGE_DATA; |
| 89 case LIBUSB_ISO_USAGE_TYPE_FEEDBACK: |
| 90 return USB_USAGE_FEEDBACK; |
| 91 case LIBUSB_ISO_USAGE_TYPE_IMPLICIT: |
| 92 return USB_USAGE_EXPLICIT_FEEDBACK; |
| 93 default: |
| 94 NOTREACHED(); |
| 95 return USB_USAGE_DATA; |
| 96 } |
| 97 } |
| 98 |
| 37 } // namespace | 99 } // namespace |
| 38 | 100 |
| 39 namespace device { | |
| 40 | |
| 41 UsbDeviceImpl::UsbDeviceImpl( | 101 UsbDeviceImpl::UsbDeviceImpl( |
| 42 scoped_refptr<UsbContext> context, | 102 scoped_refptr<UsbContext> context, |
| 43 scoped_refptr<base::SingleThreadTaskRunner> ui_task_runner, | 103 scoped_refptr<base::SingleThreadTaskRunner> ui_task_runner, |
| 44 PlatformUsbDevice platform_device, | 104 PlatformUsbDevice platform_device, |
| 45 uint16 vendor_id, | 105 uint16 vendor_id, |
| 46 uint16 product_id, | 106 uint16 product_id, |
| 47 uint32 unique_id) | 107 uint32 unique_id) |
| 48 : UsbDevice(vendor_id, product_id, unique_id), | 108 : UsbDevice(vendor_id, product_id, unique_id), |
| 49 platform_device_(platform_device), | 109 platform_device_(platform_device), |
| 110 current_configuration_cached_(false), |
| 50 context_(context), | 111 context_(context), |
| 51 ui_task_runner_(ui_task_runner) { | 112 ui_task_runner_(ui_task_runner) { |
| 52 CHECK(platform_device) << "platform_device cannot be NULL"; | 113 CHECK(platform_device) << "platform_device cannot be NULL"; |
| 53 libusb_ref_device(platform_device); | 114 libusb_ref_device(platform_device); |
| 54 } | 115 } |
| 55 | 116 |
| 56 UsbDeviceImpl::~UsbDeviceImpl() { | 117 UsbDeviceImpl::~UsbDeviceImpl() { |
| 57 DCHECK(thread_checker_.CalledOnValidThread()); | 118 DCHECK(thread_checker_.CalledOnValidThread()); |
| 58 for (HandlesVector::iterator it = handles_.begin(); it != handles_.end(); | 119 for (HandlesVector::iterator it = handles_.begin(); it != handles_.end(); |
| 59 ++it) { | 120 ++it) { |
| (...skipping 34 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 94 } | 155 } |
| 95 } | 156 } |
| 96 | 157 |
| 97 #endif | 158 #endif |
| 98 | 159 |
| 99 scoped_refptr<UsbDeviceHandle> UsbDeviceImpl::Open() { | 160 scoped_refptr<UsbDeviceHandle> UsbDeviceImpl::Open() { |
| 100 DCHECK(thread_checker_.CalledOnValidThread()); | 161 DCHECK(thread_checker_.CalledOnValidThread()); |
| 101 PlatformUsbDeviceHandle handle; | 162 PlatformUsbDeviceHandle handle; |
| 102 const int rv = libusb_open(platform_device_, &handle); | 163 const int rv = libusb_open(platform_device_, &handle); |
| 103 if (LIBUSB_SUCCESS == rv) { | 164 if (LIBUSB_SUCCESS == rv) { |
| 104 scoped_refptr<UsbConfigDescriptor> interfaces = ListInterfaces(); | 165 GetConfiguration(); |
| 105 if (!interfaces.get()) | 166 if (!current_configuration_cached_) { |
| 106 return NULL; | 167 return NULL; |
| 168 } |
| 107 scoped_refptr<UsbDeviceHandleImpl> device_handle = | 169 scoped_refptr<UsbDeviceHandleImpl> device_handle = |
| 108 new UsbDeviceHandleImpl(context_, this, handle, interfaces); | 170 new UsbDeviceHandleImpl(context_, this, handle, current_configuration_); |
| 109 handles_.push_back(device_handle); | 171 handles_.push_back(device_handle); |
| 110 return device_handle; | 172 return device_handle; |
| 111 } else { | 173 } else { |
| 112 VLOG(1) << "Failed to open device: " << ConvertPlatformUsbErrorToString(rv); | 174 VLOG(1) << "Failed to open device: " << ConvertPlatformUsbErrorToString(rv); |
| 113 return NULL; | 175 return NULL; |
| 114 } | 176 } |
| 115 } | 177 } |
| 116 | 178 |
| 117 bool UsbDeviceImpl::Close(scoped_refptr<UsbDeviceHandle> handle) { | 179 bool UsbDeviceImpl::Close(scoped_refptr<UsbDeviceHandle> handle) { |
| 118 DCHECK(thread_checker_.CalledOnValidThread()); | 180 DCHECK(thread_checker_.CalledOnValidThread()); |
| 119 | 181 |
| 120 for (HandlesVector::iterator it = handles_.begin(); it != handles_.end(); | 182 for (HandlesVector::iterator it = handles_.begin(); it != handles_.end(); |
| 121 ++it) { | 183 ++it) { |
| 122 if (it->get() == handle.get()) { | 184 if (it->get() == handle.get()) { |
| 123 (*it)->InternalClose(); | 185 (*it)->InternalClose(); |
| 124 handles_.erase(it); | 186 handles_.erase(it); |
| 125 return true; | 187 return true; |
| 126 } | 188 } |
| 127 } | 189 } |
| 128 return false; | 190 return false; |
| 129 } | 191 } |
| 130 | 192 |
| 131 scoped_refptr<UsbConfigDescriptor> UsbDeviceImpl::ListInterfaces() { | 193 const UsbConfigDescriptor& UsbDeviceImpl::GetConfiguration() { |
| 132 DCHECK(thread_checker_.CalledOnValidThread()); | 194 DCHECK(thread_checker_.CalledOnValidThread()); |
| 133 | 195 |
| 134 PlatformUsbConfigDescriptor platform_config; | 196 if (!current_configuration_cached_) { |
| 135 const int rv = | 197 libusb_config_descriptor* platform_config; |
| 136 libusb_get_active_config_descriptor(platform_device_, &platform_config); | 198 const int rv = |
| 137 if (rv == LIBUSB_SUCCESS) { | 199 libusb_get_active_config_descriptor(platform_device_, &platform_config); |
| 138 return new UsbConfigDescriptorImpl(platform_config); | 200 if (rv != LIBUSB_SUCCESS) { |
| 139 } else { | 201 VLOG(1) << "Failed to get config descriptor: " |
| 140 VLOG(1) << "Failed to get config descriptor: " | 202 << ConvertPlatformUsbErrorToString(rv); |
| 141 << ConvertPlatformUsbErrorToString(rv); | 203 return current_configuration_; |
| 142 return NULL; | 204 } |
| 205 |
| 206 current_configuration_.configuration_value = |
| 207 platform_config->bConfigurationValue; |
| 208 current_configuration_.self_powered = |
| 209 (platform_config->bmAttributes & 0x40) != 0; |
| 210 current_configuration_.remote_wakeup = |
| 211 (platform_config->bmAttributes & 0x20) != 0; |
| 212 current_configuration_.maximum_power = platform_config->MaxPower * 2; |
| 213 |
| 214 for (size_t i = 0; i < platform_config->bNumInterfaces; ++i) { |
| 215 const struct libusb_interface* platform_interface = |
| 216 &platform_config->interface[i]; |
| 217 for (int j = 0; j < platform_interface->num_altsetting; ++j) { |
| 218 const struct libusb_interface_descriptor* platform_alt_setting = |
| 219 &platform_interface->altsetting[j]; |
| 220 UsbInterfaceDescriptor interface; |
| 221 |
| 222 interface.interface_number = platform_alt_setting->bInterfaceNumber; |
| 223 interface.alternate_setting = platform_alt_setting->bAlternateSetting; |
| 224 interface.interface_class = platform_alt_setting->bInterfaceClass; |
| 225 interface.interface_subclass = platform_alt_setting->bInterfaceSubClass; |
| 226 interface.interface_protocol = platform_alt_setting->bInterfaceProtocol; |
| 227 |
| 228 for (size_t k = 0; k < platform_alt_setting->bNumEndpoints; ++k) { |
| 229 const struct libusb_endpoint_descriptor* platform_endpoint = |
| 230 &platform_alt_setting->endpoint[k]; |
| 231 UsbEndpointDescriptor endpoint; |
| 232 |
| 233 endpoint.address = platform_endpoint->bEndpointAddress; |
| 234 endpoint.direction = GetDirection(platform_endpoint); |
| 235 endpoint.maximum_packet_size = platform_endpoint->wMaxPacketSize; |
| 236 endpoint.synchronization_type = |
| 237 GetSynchronizationType(platform_endpoint); |
| 238 endpoint.transfer_type = GetTransferType(platform_endpoint); |
| 239 endpoint.usage_type = GetUsageType(platform_endpoint); |
| 240 endpoint.polling_interval = platform_endpoint->bInterval; |
| 241 endpoint.extra_data = std::vector<uint8_t>( |
| 242 platform_endpoint->extra, |
| 243 platform_endpoint->extra + platform_endpoint->extra_length); |
| 244 |
| 245 interface.endpoints.push_back(endpoint); |
| 246 } |
| 247 |
| 248 interface.extra_data = std::vector<uint8_t>( |
| 249 platform_alt_setting->extra, |
| 250 platform_alt_setting->extra + platform_alt_setting->extra_length); |
| 251 |
| 252 current_configuration_.interfaces.push_back(interface); |
| 253 } |
| 254 } |
| 255 |
| 256 current_configuration_.extra_data = std::vector<uint8_t>( |
| 257 platform_config->extra, |
| 258 platform_config->extra + platform_config->extra_length); |
| 259 current_configuration_cached_ = true; |
| 143 } | 260 } |
| 261 |
| 262 return current_configuration_; |
| 144 } | 263 } |
| 145 | 264 |
| 146 void UsbDeviceImpl::OnDisconnect() { | 265 void UsbDeviceImpl::OnDisconnect() { |
| 147 DCHECK(thread_checker_.CalledOnValidThread()); | 266 DCHECK(thread_checker_.CalledOnValidThread()); |
| 148 HandlesVector handles; | 267 HandlesVector handles; |
| 149 swap(handles, handles_); | 268 swap(handles, handles_); |
| 150 for (HandlesVector::iterator it = handles.begin(); it != handles.end(); ++it) | 269 for (HandlesVector::iterator it = handles.begin(); it != handles.end(); ++it) |
| 151 (*it)->InternalClose(); | 270 (*it)->InternalClose(); |
| 152 } | 271 } |
| 153 | 272 |
| 154 } // namespace device | 273 } // namespace device |
| OLD | NEW |