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