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/mojo/device_manager_impl.h" | 5 #include "device/usb/mojo/device_manager_impl.h" |
6 | 6 |
7 #include <stddef.h> | 7 #include <stddef.h> |
8 #include <utility> | 8 #include <utility> |
9 | 9 |
10 #include "base/bind.h" | 10 #include "base/bind.h" |
(...skipping 57 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
68 MaybeRunDeviceChangesCallback(); | 68 MaybeRunDeviceChangesCallback(); |
69 } | 69 } |
70 | 70 |
71 void DeviceManagerImpl::GetDevice( | 71 void DeviceManagerImpl::GetDevice( |
72 const mojo::String& guid, | 72 const mojo::String& guid, |
73 mojo::InterfaceRequest<Device> device_request) { | 73 mojo::InterfaceRequest<Device> device_request) { |
74 scoped_refptr<UsbDevice> device = usb_service_->GetDevice(guid); | 74 scoped_refptr<UsbDevice> device = usb_service_->GetDevice(guid); |
75 if (!device) | 75 if (!device) |
76 return; | 76 return; |
77 | 77 |
78 DeviceInfoPtr device_info = DeviceInfo::From(*device); | |
79 if (permission_provider_ && | 78 if (permission_provider_ && |
80 permission_provider_->HasDevicePermission(*device_info)) { | 79 permission_provider_->HasDevicePermission(device)) { |
81 new DeviceImpl(device, std::move(device_info), permission_provider_, | 80 new DeviceImpl(device, DeviceInfo::From(*device), permission_provider_, |
82 std::move(device_request)); | 81 std::move(device_request)); |
83 } | 82 } |
84 } | 83 } |
85 | 84 |
86 void DeviceManagerImpl::OnGetDevices( | 85 void DeviceManagerImpl::OnGetDevices( |
87 EnumerationOptionsPtr options, | 86 EnumerationOptionsPtr options, |
88 const GetDevicesCallback& callback, | 87 const GetDevicesCallback& callback, |
89 const std::vector<scoped_refptr<UsbDevice>>& devices) { | 88 const std::vector<scoped_refptr<UsbDevice>>& devices) { |
90 std::vector<UsbDeviceFilter> filters; | 89 std::vector<UsbDeviceFilter> filters; |
91 if (options) | 90 if (options) |
92 filters = options->filters.To<std::vector<UsbDeviceFilter>>(); | 91 filters = options->filters.To<std::vector<UsbDeviceFilter>>(); |
93 | 92 |
94 mojo::Array<DeviceInfoPtr> device_infos; | 93 mojo::Array<DeviceInfoPtr> device_infos; |
95 for (const auto& device : devices) { | 94 for (const auto& device : devices) { |
96 if (filters.empty() || UsbDeviceFilter::MatchesAny(device, filters)) { | 95 if (filters.empty() || UsbDeviceFilter::MatchesAny(device, filters)) { |
97 DeviceInfoPtr device_info = DeviceInfo::From(*device); | |
98 if (permission_provider_ && | 96 if (permission_provider_ && |
99 permission_provider_->HasDevicePermission(*device_info)) { | 97 permission_provider_->HasDevicePermission(device)) { |
100 device_infos.push_back(std::move(device_info)); | 98 device_infos.push_back(DeviceInfo::From(*device)); |
101 } | 99 } |
102 } | 100 } |
103 } | 101 } |
104 | 102 |
105 callback.Run(std::move(device_infos)); | 103 callback.Run(std::move(device_infos)); |
106 } | 104 } |
107 | 105 |
108 void DeviceManagerImpl::OnDeviceAdded(scoped_refptr<UsbDevice> device) { | 106 void DeviceManagerImpl::OnDeviceAdded(scoped_refptr<UsbDevice> device) { |
109 DeviceInfoPtr device_info = DeviceInfo::From(*device); | |
110 if (permission_provider_ && | 107 if (permission_provider_ && |
111 permission_provider_->HasDevicePermission(*device_info)) { | 108 permission_provider_->HasDevicePermission(device)) { |
112 devices_added_[device->guid()] = std::move(device_info); | 109 devices_added_[device->guid()] = DeviceInfo::From(*device); |
113 MaybeRunDeviceChangesCallback(); | 110 MaybeRunDeviceChangesCallback(); |
114 } | 111 } |
115 } | 112 } |
116 | 113 |
117 void DeviceManagerImpl::OnDeviceRemoved(scoped_refptr<UsbDevice> device) { | 114 void DeviceManagerImpl::OnDeviceRemoved(scoped_refptr<UsbDevice> device) { |
118 if (devices_added_.erase(device->guid()) == 0) { | 115 if (devices_added_.erase(device->guid()) == 0) { |
119 DeviceInfoPtr device_info = DeviceInfo::From(*device); | |
120 if (permission_provider_ && | 116 if (permission_provider_ && |
121 permission_provider_->HasDevicePermission(*device_info)) { | 117 permission_provider_->HasDevicePermission(device)) { |
122 devices_removed_.push_back(std::move(device_info)); | 118 devices_removed_.push_back(DeviceInfo::From(*device)); |
123 MaybeRunDeviceChangesCallback(); | 119 MaybeRunDeviceChangesCallback(); |
124 } | 120 } |
125 } | 121 } |
126 } | 122 } |
127 | 123 |
128 void DeviceManagerImpl::WillDestroyUsbService() { | 124 void DeviceManagerImpl::WillDestroyUsbService() { |
129 delete this; | 125 delete this; |
130 } | 126 } |
131 | 127 |
132 void DeviceManagerImpl::MaybeRunDeviceChangesCallback() { | 128 void DeviceManagerImpl::MaybeRunDeviceChangesCallback() { |
133 if (!device_change_callbacks_.empty() && | 129 if (!device_change_callbacks_.empty() && |
134 !(devices_added_.empty() && devices_removed_.empty())) { | 130 !(devices_added_.empty() && devices_removed_.empty())) { |
135 DeviceChangeNotificationPtr notification = DeviceChangeNotification::New(); | 131 DeviceChangeNotificationPtr notification = DeviceChangeNotification::New(); |
136 notification->devices_added.SetToEmpty(); | 132 notification->devices_added.SetToEmpty(); |
137 notification->devices_removed.SetToEmpty(); | 133 notification->devices_removed.SetToEmpty(); |
138 for (auto& map_entry : devices_added_) | 134 for (auto& map_entry : devices_added_) |
139 notification->devices_added.push_back(std::move(map_entry.second)); | 135 notification->devices_added.push_back(std::move(map_entry.second)); |
140 devices_added_.clear(); | 136 devices_added_.clear(); |
141 notification->devices_removed.Swap(&devices_removed_); | 137 notification->devices_removed.Swap(&devices_removed_); |
142 | 138 |
143 device_change_callbacks_.front().Run(std::move(notification)); | 139 device_change_callbacks_.front().Run(std::move(notification)); |
144 device_change_callbacks_.pop(); | 140 device_change_callbacks_.pop(); |
145 } | 141 } |
146 } | 142 } |
147 | 143 |
148 } // namespace usb | 144 } // namespace usb |
149 } // namespace device | 145 } // namespace device |
OLD | NEW |