Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(68)

Side by Side Diff: chrome/browser/extensions/api/usb/usb_device_resource.cc

Issue 16316004: Separate usb device handle from usb device. (deprecate) (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Fix the threading mess Created 7 years, 5 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
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/extensions/api/usb/usb_device_resource.h" 5 #include "chrome/browser/extensions/api/usb/usb_device_resource.h"
6 6
7 #include <string> 7 #include <string>
8 #include <vector> 8 #include <vector>
9 9
10 #include "base/bind.h" 10 #include "base/bind.h"
11 #include "base/bind_helpers.h" 11 #include "base/bind_helpers.h"
12 #include "base/synchronization/lock.h" 12 #include "base/synchronization/lock.h"
13 #include "chrome/browser/extensions/api/api_resource.h" 13 #include "chrome/browser/extensions/api/api_resource.h"
14 #include "chrome/browser/usb/usb_device.h" 14 #include "chrome/browser/usb/usb_device_handle.h"
15 #include "chrome/common/extensions/api/usb.h" 15 #include "chrome/common/extensions/api/usb.h"
16 #include "content/public/browser/browser_thread.h"
16 17
17 namespace extensions { 18 namespace extensions {
18 19
19 static base::LazyInstance<ProfileKeyedAPIFactory< 20 static base::LazyInstance<ProfileKeyedAPIFactory<
20 ApiResourceManager<UsbDeviceResource> > > 21 ApiResourceManager<UsbDeviceResource> > >
21 g_factory = LAZY_INSTANCE_INITIALIZER; 22 g_factory = LAZY_INSTANCE_INITIALIZER;
22 23
23 // static 24 // static
24 template <> 25 template <>
25 ProfileKeyedAPIFactory<ApiResourceManager<UsbDeviceResource> >* 26 ProfileKeyedAPIFactory<ApiResourceManager<UsbDeviceResource> >*
26 ApiResourceManager<UsbDeviceResource>::GetFactoryInstance() { 27 ApiResourceManager<UsbDeviceResource>::GetFactoryInstance() {
27 return &g_factory.Get(); 28 return &g_factory.Get();
28 } 29 }
29 30
31 namespace {
32
33 void EmptyCallback(void) {}
34
35 } // namepsace
36
30 UsbDeviceResource::UsbDeviceResource(const std::string& owner_extension_id, 37 UsbDeviceResource::UsbDeviceResource(const std::string& owner_extension_id,
31 scoped_refptr<UsbDevice> device) 38 scoped_refptr<UsbDeviceHandle> device)
32 : ApiResource(owner_extension_id), device_(device) {} 39 : ApiResource(owner_extension_id), device_(device) {}
33 40
34 UsbDeviceResource::~UsbDeviceResource() {} 41 UsbDeviceResource::~UsbDeviceResource() { Close(base::Bind(EmptyCallback)); }
42
43 void UsbDeviceResource::Close(const base::Callback<void()>& callback) {
44 scoped_refptr<UsbDeviceHandle> handle;
45 handle.swap(device_);
46 if (!handle.get()) {
47 callback.Run();
48 return;
49 }
50 content::BrowserThread::PostTask(
51 content::BrowserThread::FILE, FROM_HERE,
52 base::Bind(&UsbDeviceHandle::Close, handle, callback));
53 }
54
55 void UsbDeviceResource::ListInterfaces(UsbConfigDescriptor* config,
56 const UsbInterfaceCallback& callback) {
57 if (!device_.get()) {
58 callback.Run(false);
59 }
60 content::BrowserThread::PostTask(
61 content::BrowserThread::FILE, FROM_HERE,
62 base::Bind(&UsbDeviceHandle::ListInterfaces, device_,
63 make_scoped_refptr(config), callback));
64 }
65
66 void UsbDeviceResource::ClaimInterface(const int interface_number,
67 const UsbInterfaceCallback& callback) {
68 if (!device_.get()) {
69 callback.Run(false);
70 }
71 content::BrowserThread::PostTask(
72 content::BrowserThread::FILE, FROM_HERE,
73 base::Bind(&UsbDeviceHandle::ClaimInterface, device_, interface_number,
74 callback));
75 }
76
77 void UsbDeviceResource::ReleaseInterface(const int interface_number,
78 const UsbInterfaceCallback& callback) {
79 if (!device_.get()) {
80 callback.Run(false);
81 }
82 content::BrowserThread::PostTask(
83 content::BrowserThread::FILE, FROM_HERE,
84 base::Bind(&UsbDeviceHandle::ReleaseInterface, device_, interface_number,
85 callback));
86 }
87
88 void UsbDeviceResource::SetInterfaceAlternateSetting(
89 const int interface_number, const int alternate_setting,
90 const UsbInterfaceCallback& callback) {
91 if (!device_.get()) {
92 callback.Run(false);
93 }
94 content::BrowserThread::PostTask(
95 content::BrowserThread::FILE, FROM_HERE,
96 base::Bind(&UsbDeviceHandle::SetInterfaceAlternateSetting, device_,
97 interface_number, alternate_setting, callback));
98 }
99
100 void UsbDeviceResource::ControlTransfer(
101 const UsbEndpointDirection direction,
102 const UsbDeviceHandle::TransferRequestType request_type,
103 const UsbDeviceHandle::TransferRecipient recipient, const uint8 request,
104 const uint16 value, const uint16 index, net::IOBuffer* buffer,
105 const size_t length, const unsigned int timeout,
106 const UsbTransferCallback& callback) {
107 if (!device_.get()) {
108 callback.Run(USB_TRANSFER_DISCONNECT,
109 scoped_refptr<net::IOBuffer>(), 0);
110 }
111 device_->ControlTransfer(direction, request_type, recipient, request, value,
112 index, buffer, length, timeout, callback);
113 }
114
115 void UsbDeviceResource::BulkTransfer(const UsbEndpointDirection direction,
116 const uint8 endpoint,
117 net::IOBuffer* buffer, const size_t length,
118 const unsigned int timeout,
119 const UsbTransferCallback& callback) {
120 if (!device_.get()) {
121 callback.Run(USB_TRANSFER_DISCONNECT,
122 scoped_refptr<net::IOBuffer>(), 0);
123 }
124 device_->BulkTransfer(direction, endpoint, buffer, length, timeout, callback);
125 }
126
127 void UsbDeviceResource::InterruptTransfer(const UsbEndpointDirection direction,
128 const uint8 endpoint,
129 net::IOBuffer* buffer,
130 const size_t length,
131 const unsigned int timeout,
132 const UsbTransferCallback& callback) {
133 if (!device_.get()) {
134 callback.Run(USB_TRANSFER_DISCONNECT,
135 scoped_refptr<net::IOBuffer>(), 0);
136 }
137 device_->InterruptTransfer(direction, endpoint, buffer, length, timeout,
138 callback);
139 }
140
141 void UsbDeviceResource::IsochronousTransfer(
142 const UsbEndpointDirection direction, const uint8 endpoint,
143 net::IOBuffer* buffer, const size_t length, const unsigned int packets,
144 const unsigned int packet_length, const unsigned int timeout,
145 const UsbTransferCallback& callback) {
146 if (!device_.get()) {
147 callback.Run(USB_TRANSFER_DISCONNECT,
148 scoped_refptr<net::IOBuffer>(), 0);
149 }
150 device_->IsochronousTransfer(direction, endpoint, buffer, length, packets,
151 packet_length, timeout, callback);
152 }
153
154 void UsbDeviceResource::ResetDevice(
155 const base::Callback<void(bool)>& callback) {
156 if (!device_.get()) {
157 callback.Run(false);
158 }
159 content::BrowserThread::PostTask(
160 content::BrowserThread::FILE, FROM_HERE,
161 base::Bind(&UsbDeviceHandle::ResetDevice, device_, callback));
162 }
35 163
36 } // namespace extensions 164 } // namespace extensions
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698