OLD | NEW |
---|---|
1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 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/device_manager_impl.h" | 5 #include "device/usb/device_manager_impl.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
8 #include "base/location.h" | |
8 #include "base/memory/scoped_ptr.h" | 9 #include "base/memory/scoped_ptr.h" |
10 #include "base/sequenced_task_runner.h" | |
11 #include "base/thread_task_runner_handle.h" | |
9 #include "device/core/device_client.h" | 12 #include "device/core/device_client.h" |
10 #include "device/usb/device_impl.h" | 13 #include "device/usb/device_impl.h" |
11 #include "device/usb/public/cpp/device_manager_delegate.h" | 14 #include "device/usb/public/cpp/device_manager_delegate.h" |
12 #include "device/usb/public/cpp/device_manager_factory.h" | |
13 #include "device/usb/public/interfaces/device.mojom.h" | 15 #include "device/usb/public/interfaces/device.mojom.h" |
14 #include "device/usb/type_converters.h" | 16 #include "device/usb/type_converters.h" |
15 #include "device/usb/usb_device.h" | 17 #include "device/usb/usb_device.h" |
16 #include "device/usb/usb_device_filter.h" | 18 #include "device/usb/usb_device_filter.h" |
17 #include "device/usb/usb_service.h" | 19 #include "device/usb/usb_service.h" |
18 #include "third_party/mojo/src/mojo/public/cpp/bindings/array.h" | 20 #include "third_party/mojo/src/mojo/public/cpp/bindings/array.h" |
19 #include "third_party/mojo/src/mojo/public/cpp/bindings/interface_request.h" | 21 #include "third_party/mojo/src/mojo/public/cpp/bindings/interface_request.h" |
20 | 22 |
21 namespace device { | 23 namespace device { |
22 namespace usb { | 24 namespace usb { |
23 | 25 |
24 // static | 26 namespace { |
25 void DeviceManagerFactory::Build(mojo::InterfaceRequest<DeviceManager> request, | 27 |
26 scoped_ptr<DeviceManagerDelegate> delegate) { | 28 void OnGetDevicesOnServiceThread( |
29 const UsbService::GetDevicesCallback& callback, | |
30 scoped_refptr<base::TaskRunner> callback_task_runner, | |
31 const std::vector<scoped_refptr<UsbDevice>>& devices) { | |
32 callback_task_runner->PostTask(FROM_HERE, base::Bind(callback, devices)); | |
33 } | |
34 | |
35 void GetDevicesOnServiceThread( | |
36 const UsbService::GetDevicesCallback& callback, | |
37 scoped_refptr<base::TaskRunner> callback_task_runner) { | |
38 DCHECK(DeviceClient::Get()); | |
39 UsbService* usb_service = DeviceClient::Get()->GetUsbService(); | |
40 if (!usb_service) { | |
41 std::vector<scoped_refptr<UsbDevice>> no_devices; | |
42 callback_task_runner->PostTask(FROM_HERE, base::Bind(callback, no_devices)); | |
43 return; | |
44 } | |
45 usb_service->GetDevices( | |
46 base::Bind(&OnGetDevicesOnServiceThread, callback, callback_task_runner)); | |
47 } | |
48 | |
49 void RunOpenDeviceCallback(const DeviceManager::OpenDeviceCallback& callback, | |
50 OpenDeviceError error) { | |
51 callback.Run(error); | |
52 } | |
53 | |
54 void OnOpenDeviceOnServiceThread( | |
55 mojo::InterfaceRequest<Device> device_request, | |
56 const DeviceManager::OpenDeviceCallback& callback, | |
57 scoped_refptr<base::TaskRunner> callback_task_runner, | |
58 scoped_refptr<UsbDeviceHandle> device_handle) { | |
59 if (!device_handle) { | |
60 callback_task_runner->PostTask(FROM_HERE, | |
61 base::Bind(&RunOpenDeviceCallback, callback, | |
62 OPEN_DEVICE_ERROR_ACCESS_DENIED)); | |
Reilly Grant (use Gerrit)
2015/06/10 20:02:47
Why not base::Bind(callback, OPEN_DEVICE_ERROR_ACC
Ken Rockot(use gerrit already)
2015/06/10 20:15:51
base::Bind unfortunately does not know how to rebi
Reilly Grant (use Gerrit)
2015/06/10 21:33:16
I'm going to put in a strong vote in favor of impo
| |
63 return; | |
64 } | |
65 | |
27 // Owned by its MessagePipe. | 66 // Owned by its MessagePipe. |
28 new DeviceManagerImpl(request.Pass(), delegate.Pass()); | 67 new DeviceImpl(device_handle, device_request.Pass()); |
68 | |
69 callback_task_runner->PostTask( | |
70 FROM_HERE, | |
71 base::Bind(&RunOpenDeviceCallback, callback, OPEN_DEVICE_ERROR_OK)); | |
29 } | 72 } |
30 | 73 |
74 void OpenDeviceOnServiceThread( | |
75 const std::string& guid, | |
76 mojo::InterfaceRequest<Device> device_request, | |
77 const DeviceManager::OpenDeviceCallback& callback, | |
78 scoped_refptr<base::TaskRunner> callback_task_runner) { | |
79 DCHECK(DeviceClient::Get()); | |
80 UsbService* usb_service = DeviceClient::Get()->GetUsbService(); | |
81 if (!usb_service) { | |
82 callback_task_runner->PostTask(FROM_HERE, | |
83 base::Bind(&RunOpenDeviceCallback, callback, | |
84 OPEN_DEVICE_ERROR_NOT_FOUND)); | |
85 return; | |
86 } | |
87 scoped_refptr<UsbDevice> device = usb_service->GetDevice(guid); | |
88 if (!device) { | |
89 callback_task_runner->PostTask(FROM_HERE, | |
90 base::Bind(&RunOpenDeviceCallback, callback, | |
91 OPEN_DEVICE_ERROR_NOT_FOUND)); | |
92 return; | |
93 } | |
94 device->Open(base::Bind(&OnOpenDeviceOnServiceThread, | |
95 base::Passed(&device_request), callback, | |
96 callback_task_runner)); | |
97 } | |
98 | |
99 } // namespace | |
100 | |
31 DeviceManagerImpl::DeviceManagerImpl( | 101 DeviceManagerImpl::DeviceManagerImpl( |
32 mojo::InterfaceRequest<DeviceManager> request, | 102 mojo::InterfaceRequest<DeviceManager> request, |
33 scoped_ptr<DeviceManagerDelegate> delegate) | 103 scoped_ptr<DeviceManagerDelegate> delegate, |
104 scoped_refptr<base::SequencedTaskRunner> service_task_runner) | |
34 : binding_(this, request.Pass()), | 105 : binding_(this, request.Pass()), |
35 delegate_(delegate.Pass()), | 106 delegate_(delegate.Pass()), |
107 service_task_runner_(service_task_runner), | |
36 weak_factory_(this) { | 108 weak_factory_(this) { |
37 } | 109 } |
38 | 110 |
39 DeviceManagerImpl::~DeviceManagerImpl() { | 111 DeviceManagerImpl::~DeviceManagerImpl() { |
40 } | 112 } |
41 | 113 |
114 void DeviceManagerImpl::set_error_handler(mojo::ErrorHandler* error_handler) { | |
115 binding_.set_error_handler(error_handler); | |
116 } | |
117 | |
42 void DeviceManagerImpl::GetDevices(EnumerationOptionsPtr options, | 118 void DeviceManagerImpl::GetDevices(EnumerationOptionsPtr options, |
43 const GetDevicesCallback& callback) { | 119 const GetDevicesCallback& callback) { |
44 DCHECK(DeviceClient::Get()); | 120 auto get_devices_callback = |
45 UsbService* usb_service = DeviceClient::Get()->GetUsbService(); | 121 base::Bind(&DeviceManagerImpl::OnGetDevices, weak_factory_.GetWeakPtr(), |
46 if (!usb_service) { | 122 base::Passed(&options), callback); |
47 mojo::Array<DeviceInfoPtr> results(0); | 123 service_task_runner_->PostTask( |
48 callback.Run(results.Pass()); | 124 FROM_HERE, base::Bind(&GetDevicesOnServiceThread, get_devices_callback, |
49 return; | 125 base::ThreadTaskRunnerHandle::Get())); |
50 } | |
51 std::vector<UsbDeviceFilter> filters = | |
52 options->filters.To<std::vector<UsbDeviceFilter>>(); | |
53 usb_service->GetDevices(base::Bind(&DeviceManagerImpl::OnGetDevices, | |
54 weak_factory_.GetWeakPtr(), callback, | |
55 filters)); | |
56 } | 126 } |
57 | 127 |
58 void DeviceManagerImpl::OpenDevice( | 128 void DeviceManagerImpl::OpenDevice( |
59 const mojo::String& guid, | 129 const mojo::String& guid, |
60 mojo::InterfaceRequest<Device> device_request, | 130 mojo::InterfaceRequest<Device> device_request, |
61 const OpenDeviceCallback& callback) { | 131 const OpenDeviceCallback& callback) { |
62 DCHECK(DeviceClient::Get()); | 132 service_task_runner_->PostTask( |
63 UsbService* usb_service = DeviceClient::Get()->GetUsbService(); | 133 FROM_HERE, base::Bind(&OpenDeviceOnServiceThread, guid, |
64 if (!usb_service) { | 134 base::Passed(&device_request), callback, |
65 callback.Run(OPEN_DEVICE_ERROR_NOT_FOUND); | 135 base::ThreadTaskRunnerHandle::Get())); |
66 return; | |
67 } | |
68 scoped_refptr<UsbDevice> device = usb_service->GetDevice(guid); | |
69 if (!device) { | |
70 callback.Run(OPEN_DEVICE_ERROR_NOT_FOUND); | |
71 return; | |
72 } | |
73 device->Open(base::Bind(&DeviceManagerImpl::OnOpenDevice, | |
74 weak_factory_.GetWeakPtr(), callback, | |
75 base::Passed(&device_request))); | |
76 } | 136 } |
77 | 137 |
78 void DeviceManagerImpl::OnGetDevices( | 138 void DeviceManagerImpl::OnGetDevices( |
139 EnumerationOptionsPtr options, | |
79 const GetDevicesCallback& callback, | 140 const GetDevicesCallback& callback, |
80 const std::vector<UsbDeviceFilter>& filters, | |
81 const std::vector<scoped_refptr<UsbDevice>>& devices) { | 141 const std::vector<scoped_refptr<UsbDevice>>& devices) { |
142 auto filters = options->filters.To<std::vector<UsbDeviceFilter>>(); | |
82 mojo::Array<DeviceInfoPtr> device_infos(0); | 143 mojo::Array<DeviceInfoPtr> device_infos(0); |
83 for (size_t i = 0; i < devices.size(); ++i) { | 144 for (size_t i = 0; i < devices.size(); ++i) { |
84 DeviceInfoPtr device_info = DeviceInfo::From(*devices[i]); | 145 DeviceInfoPtr device_info = DeviceInfo::From(*devices[i]); |
85 if (UsbDeviceFilter::MatchesAny(devices[i], filters) && | 146 if (UsbDeviceFilter::MatchesAny(devices[i], filters) && |
86 delegate_->IsDeviceAllowed(*device_info)) { | 147 delegate_->IsDeviceAllowed(*device_info)) { |
87 const UsbConfigDescriptor* config = devices[i]->GetConfiguration(); | 148 const UsbConfigDescriptor* config = devices[i]->GetConfiguration(); |
88 device_info->configurations = mojo::Array<ConfigurationInfoPtr>::New(0); | 149 device_info->configurations = mojo::Array<ConfigurationInfoPtr>::New(0); |
89 if (config) | 150 if (config) |
90 device_info->configurations.push_back(ConfigurationInfo::From(*config)); | 151 device_info->configurations.push_back(ConfigurationInfo::From(*config)); |
91 device_infos.push_back(device_info.Pass()); | 152 device_infos.push_back(device_info.Pass()); |
92 } | 153 } |
93 } | 154 } |
94 callback.Run(device_infos.Pass()); | 155 callback.Run(device_infos.Pass()); |
95 } | 156 } |
96 | 157 |
97 void DeviceManagerImpl::OnOpenDevice( | |
98 const OpenDeviceCallback& callback, | |
99 mojo::InterfaceRequest<Device> device_request, | |
100 scoped_refptr<UsbDeviceHandle> device_handle) { | |
101 if (!device_handle) { | |
102 callback.Run(OPEN_DEVICE_ERROR_ACCESS_DENIED); | |
103 return; | |
104 } | |
105 | |
106 // Owned by its MessagePipe. | |
107 new DeviceImpl(device_handle, device_request.Pass()); | |
108 | |
109 callback.Run(OPEN_DEVICE_ERROR_OK); | |
110 } | |
111 | |
112 } // namespace usb | 158 } // namespace usb |
113 } // namespace device | 159 } // namespace device |
OLD | NEW |