OLD | NEW |
1 // Copyright (c) 2014 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 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/hid/hid_connection.h" | 5 #include "device/hid/hid_connection.h" |
6 | 6 |
7 #include <algorithm> | 7 #include <algorithm> |
8 | 8 |
9 namespace device { | 9 namespace device { |
10 | 10 |
(...skipping 20 matching lines...) Expand all Loading... |
31 const uint8_t report_id_; | 31 const uint8_t report_id_; |
32 }; | 32 }; |
33 | 33 |
34 // Functor returning true if collection has a protected usage. | 34 // Functor returning true if collection has a protected usage. |
35 struct CollectionIsProtected { | 35 struct CollectionIsProtected { |
36 bool operator()(const HidCollectionInfo& info) const { | 36 bool operator()(const HidCollectionInfo& info) const { |
37 return info.usage.IsProtected(); | 37 return info.usage.IsProtected(); |
38 } | 38 } |
39 }; | 39 }; |
40 | 40 |
41 bool FindCollectionByReportId(const HidDeviceInfo& device_info, | 41 bool FindCollectionByReportId(const std::vector<HidCollectionInfo>& collections, |
42 uint8_t report_id, | 42 uint8_t report_id, |
43 HidCollectionInfo* collection_info) { | 43 HidCollectionInfo* collection_info) { |
44 std::vector<HidCollectionInfo>::const_iterator collection_iter = | 44 std::vector<HidCollectionInfo>::const_iterator collection_iter = std::find_if( |
45 std::find_if(device_info.collections.begin(), | 45 collections.begin(), collections.end(), CollectionHasReportId(report_id)); |
46 device_info.collections.end(), | 46 if (collection_iter != collections.end()) { |
47 CollectionHasReportId(report_id)); | |
48 if (collection_iter != device_info.collections.end()) { | |
49 if (collection_info) { | 47 if (collection_info) { |
50 *collection_info = *collection_iter; | 48 *collection_info = *collection_iter; |
51 } | 49 } |
52 return true; | 50 return true; |
53 } | 51 } |
54 | 52 |
55 return false; | 53 return false; |
56 } | 54 } |
57 | 55 |
58 bool HasProtectedCollection(const HidDeviceInfo& device_info) { | 56 bool HasProtectedCollection(const std::vector<HidCollectionInfo>& collections) { |
59 return std::find_if(device_info.collections.begin(), | 57 return std::find_if(collections.begin(), collections.end(), |
60 device_info.collections.end(), | 58 CollectionIsProtected()) != collections.end(); |
61 CollectionIsProtected()) != device_info.collections.end(); | |
62 } | 59 } |
63 | 60 |
64 } // namespace | 61 } // namespace |
65 | 62 |
66 HidConnection::HidConnection(const HidDeviceInfo& device_info) | 63 HidConnection::HidConnection(scoped_refptr<HidDeviceInfo> device_info) |
67 : device_info_(device_info), closed_(false) { | 64 : device_info_(device_info), closed_(false) { |
68 has_protected_collection_ = HasProtectedCollection(device_info); | 65 has_protected_collection_ = |
| 66 HasProtectedCollection(device_info->collections()); |
69 } | 67 } |
70 | 68 |
71 HidConnection::~HidConnection() { | 69 HidConnection::~HidConnection() { |
72 DCHECK(thread_checker_.CalledOnValidThread()); | 70 DCHECK(thread_checker_.CalledOnValidThread()); |
73 DCHECK(closed_); | 71 DCHECK(closed_); |
74 } | 72 } |
75 | 73 |
76 void HidConnection::Close() { | 74 void HidConnection::Close() { |
77 DCHECK(thread_checker_.CalledOnValidThread()); | 75 DCHECK(thread_checker_.CalledOnValidThread()); |
78 DCHECK(!closed_); | 76 DCHECK(!closed_); |
79 | 77 |
80 PlatformClose(); | 78 PlatformClose(); |
81 closed_ = true; | 79 closed_ = true; |
82 } | 80 } |
83 | 81 |
84 void HidConnection::Read(const ReadCallback& callback) { | 82 void HidConnection::Read(const ReadCallback& callback) { |
85 DCHECK(thread_checker_.CalledOnValidThread()); | 83 DCHECK(thread_checker_.CalledOnValidThread()); |
86 if (device_info_.max_input_report_size == 0) { | 84 if (device_info_->max_input_report_size() == 0) { |
87 VLOG(1) << "This device does not support input reports."; | 85 VLOG(1) << "This device does not support input reports."; |
88 callback.Run(false, NULL, 0); | 86 callback.Run(false, NULL, 0); |
89 return; | 87 return; |
90 } | 88 } |
91 | 89 |
92 PlatformRead(callback); | 90 PlatformRead(callback); |
93 } | 91 } |
94 | 92 |
95 void HidConnection::Write(scoped_refptr<net::IOBuffer> buffer, | 93 void HidConnection::Write(scoped_refptr<net::IOBuffer> buffer, |
96 size_t size, | 94 size_t size, |
97 const WriteCallback& callback) { | 95 const WriteCallback& callback) { |
98 DCHECK(thread_checker_.CalledOnValidThread()); | 96 DCHECK(thread_checker_.CalledOnValidThread()); |
99 if (device_info_.max_output_report_size == 0) { | 97 if (device_info_->max_output_report_size() == 0) { |
100 VLOG(1) << "This device does not support output reports."; | 98 VLOG(1) << "This device does not support output reports."; |
101 callback.Run(false); | 99 callback.Run(false); |
102 return; | 100 return; |
103 } | 101 } |
104 DCHECK_GE(size, 1u); | 102 DCHECK_GE(size, 1u); |
105 uint8_t report_id = buffer->data()[0]; | 103 uint8_t report_id = buffer->data()[0]; |
106 if (device_info().has_report_id != (report_id != 0)) { | 104 if (device_info_->has_report_id() != (report_id != 0)) { |
107 VLOG(1) << "Invalid output report ID."; | 105 VLOG(1) << "Invalid output report ID."; |
108 callback.Run(false); | 106 callback.Run(false); |
109 return; | 107 return; |
110 } | 108 } |
111 if (IsReportIdProtected(report_id)) { | 109 if (IsReportIdProtected(report_id)) { |
112 VLOG(1) << "Attempt to set a protected output report."; | 110 VLOG(1) << "Attempt to set a protected output report."; |
113 callback.Run(false); | 111 callback.Run(false); |
114 return; | 112 return; |
115 } | 113 } |
116 | 114 |
117 PlatformWrite(buffer, size, callback); | 115 PlatformWrite(buffer, size, callback); |
118 } | 116 } |
119 | 117 |
120 void HidConnection::GetFeatureReport(uint8_t report_id, | 118 void HidConnection::GetFeatureReport(uint8_t report_id, |
121 const ReadCallback& callback) { | 119 const ReadCallback& callback) { |
122 DCHECK(thread_checker_.CalledOnValidThread()); | 120 DCHECK(thread_checker_.CalledOnValidThread()); |
123 if (device_info_.max_feature_report_size == 0) { | 121 if (device_info_->max_feature_report_size() == 0) { |
124 VLOG(1) << "This device does not support feature reports."; | 122 VLOG(1) << "This device does not support feature reports."; |
125 callback.Run(false, NULL, 0); | 123 callback.Run(false, NULL, 0); |
126 return; | 124 return; |
127 } | 125 } |
128 if (device_info().has_report_id != (report_id != 0)) { | 126 if (device_info_->has_report_id() != (report_id != 0)) { |
129 VLOG(1) << "Invalid feature report ID."; | 127 VLOG(1) << "Invalid feature report ID."; |
130 callback.Run(false, NULL, 0); | 128 callback.Run(false, NULL, 0); |
131 return; | 129 return; |
132 } | 130 } |
133 if (IsReportIdProtected(report_id)) { | 131 if (IsReportIdProtected(report_id)) { |
134 VLOG(1) << "Attempt to get a protected feature report."; | 132 VLOG(1) << "Attempt to get a protected feature report."; |
135 callback.Run(false, NULL, 0); | 133 callback.Run(false, NULL, 0); |
136 return; | 134 return; |
137 } | 135 } |
138 | 136 |
139 PlatformGetFeatureReport(report_id, callback); | 137 PlatformGetFeatureReport(report_id, callback); |
140 } | 138 } |
141 | 139 |
142 void HidConnection::SendFeatureReport(scoped_refptr<net::IOBuffer> buffer, | 140 void HidConnection::SendFeatureReport(scoped_refptr<net::IOBuffer> buffer, |
143 size_t size, | 141 size_t size, |
144 const WriteCallback& callback) { | 142 const WriteCallback& callback) { |
145 DCHECK(thread_checker_.CalledOnValidThread()); | 143 DCHECK(thread_checker_.CalledOnValidThread()); |
146 if (device_info_.max_feature_report_size == 0) { | 144 if (device_info_->max_feature_report_size() == 0) { |
147 VLOG(1) << "This device does not support feature reports."; | 145 VLOG(1) << "This device does not support feature reports."; |
148 callback.Run(false); | 146 callback.Run(false); |
149 return; | 147 return; |
150 } | 148 } |
151 DCHECK_GE(size, 1u); | 149 DCHECK_GE(size, 1u); |
152 uint8_t report_id = buffer->data()[0]; | 150 uint8_t report_id = buffer->data()[0]; |
153 if (device_info().has_report_id != (report_id != 0)) { | 151 if (device_info_->has_report_id() != (report_id != 0)) { |
154 VLOG(1) << "Invalid feature report ID."; | 152 VLOG(1) << "Invalid feature report ID."; |
155 callback.Run(false); | 153 callback.Run(false); |
156 return; | 154 return; |
157 } | 155 } |
158 if (IsReportIdProtected(report_id)) { | 156 if (IsReportIdProtected(report_id)) { |
159 VLOG(1) << "Attempt to set a protected feature report."; | 157 VLOG(1) << "Attempt to set a protected feature report."; |
160 callback.Run(false); | 158 callback.Run(false); |
161 return; | 159 return; |
162 } | 160 } |
163 | 161 |
164 PlatformSendFeatureReport(buffer, size, callback); | 162 PlatformSendFeatureReport(buffer, size, callback); |
165 } | 163 } |
166 | 164 |
167 bool HidConnection::CompleteRead(scoped_refptr<net::IOBuffer> buffer, | 165 bool HidConnection::CompleteRead(scoped_refptr<net::IOBuffer> buffer, |
168 size_t size, | 166 size_t size, |
169 const ReadCallback& callback) { | 167 const ReadCallback& callback) { |
170 DCHECK_GE(size, 1u); | 168 DCHECK_GE(size, 1u); |
171 uint8_t report_id = buffer->data()[0]; | 169 uint8_t report_id = buffer->data()[0]; |
172 if (IsReportIdProtected(report_id)) { | 170 if (IsReportIdProtected(report_id)) { |
173 VLOG(1) << "Filtered a protected input report."; | 171 VLOG(1) << "Filtered a protected input report."; |
174 return false; | 172 return false; |
175 } | 173 } |
176 | 174 |
177 callback.Run(true, buffer, size); | 175 callback.Run(true, buffer, size); |
178 return true; | 176 return true; |
179 } | 177 } |
180 | 178 |
181 bool HidConnection::IsReportIdProtected(uint8_t report_id) { | 179 bool HidConnection::IsReportIdProtected(uint8_t report_id) { |
182 HidCollectionInfo collection_info; | 180 HidCollectionInfo collection_info; |
183 if (FindCollectionByReportId(device_info_, report_id, &collection_info)) { | 181 if (FindCollectionByReportId(device_info_->collections(), report_id, |
| 182 &collection_info)) { |
184 return collection_info.usage.IsProtected(); | 183 return collection_info.usage.IsProtected(); |
185 } | 184 } |
186 | 185 |
187 return has_protected_collection(); | 186 return has_protected_collection(); |
188 } | 187 } |
189 | 188 |
190 PendingHidReport::PendingHidReport() {} | 189 PendingHidReport::PendingHidReport() {} |
191 | 190 |
192 PendingHidReport::~PendingHidReport() {} | 191 PendingHidReport::~PendingHidReport() {} |
193 | 192 |
194 PendingHidRead::PendingHidRead() {} | 193 PendingHidRead::PendingHidRead() {} |
195 | 194 |
196 PendingHidRead::~PendingHidRead() {} | 195 PendingHidRead::~PendingHidRead() {} |
197 | 196 |
198 } // namespace device | 197 } // namespace device |
OLD | NEW |