OLD | NEW |
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 "device/media_transfer_protocol/media_transfer_protocol_manager.h" | 5 #include "device/media_transfer_protocol/media_transfer_protocol_manager.h" |
6 | 6 |
7 #include <map> | 7 #include <map> |
8 #include <queue> | 8 #include <queue> |
9 #include <set> | 9 #include <set> |
10 #include <utility> | 10 #include <utility> |
(...skipping 131 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
142 close_storage_callbacks_.push(std::make_pair(callback, storage_handle)); | 142 close_storage_callbacks_.push(std::make_pair(callback, storage_handle)); |
143 mtp_client_->CloseStorage( | 143 mtp_client_->CloseStorage( |
144 storage_handle, | 144 storage_handle, |
145 base::Bind(&MediaTransferProtocolManagerImpl::OnCloseStorage, | 145 base::Bind(&MediaTransferProtocolManagerImpl::OnCloseStorage, |
146 weak_ptr_factory_.GetWeakPtr()), | 146 weak_ptr_factory_.GetWeakPtr()), |
147 base::Bind(&MediaTransferProtocolManagerImpl::OnCloseStorageError, | 147 base::Bind(&MediaTransferProtocolManagerImpl::OnCloseStorageError, |
148 weak_ptr_factory_.GetWeakPtr())); | 148 weak_ptr_factory_.GetWeakPtr())); |
149 } | 149 } |
150 | 150 |
151 // MediaTransferProtocolManager override. | 151 // MediaTransferProtocolManager override. |
152 virtual void ReadDirectoryByPath( | |
153 const std::string& storage_handle, | |
154 const std::string& path, | |
155 const ReadDirectoryCallback& callback) OVERRIDE { | |
156 DCHECK(thread_checker_.CalledOnValidThread()); | |
157 if (!ContainsKey(handles_, storage_handle) || !mtp_client_) { | |
158 callback.Run(std::vector<MtpFileEntry>(), true); | |
159 return; | |
160 } | |
161 read_directory_callbacks_.push(callback); | |
162 mtp_client_->ReadDirectoryByPath( | |
163 storage_handle, | |
164 path, | |
165 base::Bind(&MediaTransferProtocolManagerImpl::OnReadDirectory, | |
166 weak_ptr_factory_.GetWeakPtr()), | |
167 base::Bind(&MediaTransferProtocolManagerImpl::OnReadDirectoryError, | |
168 weak_ptr_factory_.GetWeakPtr())); | |
169 } | |
170 | |
171 // MediaTransferProtocolManager override. | |
172 virtual void ReadDirectoryById( | 152 virtual void ReadDirectoryById( |
173 const std::string& storage_handle, | 153 const std::string& storage_handle, |
174 uint32 file_id, | 154 uint32 file_id, |
175 const ReadDirectoryCallback& callback) OVERRIDE { | 155 const ReadDirectoryCallback& callback) OVERRIDE { |
176 DCHECK(thread_checker_.CalledOnValidThread()); | 156 DCHECK(thread_checker_.CalledOnValidThread()); |
177 if (!ContainsKey(handles_, storage_handle) || !mtp_client_) { | 157 if (!ContainsKey(handles_, storage_handle) || !mtp_client_) { |
178 callback.Run(std::vector<MtpFileEntry>(), true); | 158 callback.Run(std::vector<MtpFileEntry>(), true); |
179 return; | 159 return; |
180 } | 160 } |
181 read_directory_callbacks_.push(callback); | 161 read_directory_callbacks_.push(callback); |
182 mtp_client_->ReadDirectoryById( | 162 mtp_client_->ReadDirectoryById( |
183 storage_handle, | 163 storage_handle, |
184 file_id, | 164 file_id, |
185 base::Bind(&MediaTransferProtocolManagerImpl::OnReadDirectory, | 165 base::Bind(&MediaTransferProtocolManagerImpl::OnReadDirectory, |
186 weak_ptr_factory_.GetWeakPtr()), | 166 weak_ptr_factory_.GetWeakPtr()), |
187 base::Bind(&MediaTransferProtocolManagerImpl::OnReadDirectoryError, | 167 base::Bind(&MediaTransferProtocolManagerImpl::OnReadDirectoryError, |
188 weak_ptr_factory_.GetWeakPtr())); | 168 weak_ptr_factory_.GetWeakPtr())); |
189 } | 169 } |
190 | 170 |
191 // MediaTransferProtocolManager override. | 171 // MediaTransferProtocolManager override. |
192 virtual void ReadFileChunkByPath(const std::string& storage_handle, | |
193 const std::string& path, | |
194 uint32 offset, | |
195 uint32 count, | |
196 const ReadFileCallback& callback) OVERRIDE { | |
197 DCHECK(thread_checker_.CalledOnValidThread()); | |
198 if (!ContainsKey(handles_, storage_handle) || !mtp_client_) { | |
199 callback.Run(std::string(), true); | |
200 return; | |
201 } | |
202 read_file_callbacks_.push(callback); | |
203 mtp_client_->ReadFileChunkByPath( | |
204 storage_handle, path, offset, count, | |
205 base::Bind(&MediaTransferProtocolManagerImpl::OnReadFile, | |
206 weak_ptr_factory_.GetWeakPtr()), | |
207 base::Bind(&MediaTransferProtocolManagerImpl::OnReadFileError, | |
208 weak_ptr_factory_.GetWeakPtr())); | |
209 } | |
210 | |
211 // MediaTransferProtocolManager override. | |
212 virtual void ReadFileChunkById(const std::string& storage_handle, | 172 virtual void ReadFileChunkById(const std::string& storage_handle, |
213 uint32 file_id, | 173 uint32 file_id, |
214 uint32 offset, | 174 uint32 offset, |
215 uint32 count, | 175 uint32 count, |
216 const ReadFileCallback& callback) OVERRIDE { | 176 const ReadFileCallback& callback) OVERRIDE { |
217 DCHECK(thread_checker_.CalledOnValidThread()); | 177 DCHECK(thread_checker_.CalledOnValidThread()); |
218 if (!ContainsKey(handles_, storage_handle) || !mtp_client_) { | 178 if (!ContainsKey(handles_, storage_handle) || !mtp_client_) { |
219 callback.Run(std::string(), true); | 179 callback.Run(std::string(), true); |
220 return; | 180 return; |
221 } | 181 } |
222 read_file_callbacks_.push(callback); | 182 read_file_callbacks_.push(callback); |
223 mtp_client_->ReadFileChunkById( | 183 mtp_client_->ReadFileChunkById( |
224 storage_handle, file_id, offset, count, | 184 storage_handle, file_id, offset, count, |
225 base::Bind(&MediaTransferProtocolManagerImpl::OnReadFile, | 185 base::Bind(&MediaTransferProtocolManagerImpl::OnReadFile, |
226 weak_ptr_factory_.GetWeakPtr()), | 186 weak_ptr_factory_.GetWeakPtr()), |
227 base::Bind(&MediaTransferProtocolManagerImpl::OnReadFileError, | 187 base::Bind(&MediaTransferProtocolManagerImpl::OnReadFileError, |
228 weak_ptr_factory_.GetWeakPtr())); | 188 weak_ptr_factory_.GetWeakPtr())); |
229 } | 189 } |
230 | 190 |
231 virtual void GetFileInfoByPath(const std::string& storage_handle, | |
232 const std::string& path, | |
233 const GetFileInfoCallback& callback) OVERRIDE { | |
234 DCHECK(thread_checker_.CalledOnValidThread()); | |
235 if (!ContainsKey(handles_, storage_handle) || !mtp_client_) { | |
236 callback.Run(MtpFileEntry(), true); | |
237 return; | |
238 } | |
239 get_file_info_callbacks_.push(callback); | |
240 mtp_client_->GetFileInfoByPath( | |
241 storage_handle, | |
242 path, | |
243 base::Bind(&MediaTransferProtocolManagerImpl::OnGetFileInfo, | |
244 weak_ptr_factory_.GetWeakPtr()), | |
245 base::Bind(&MediaTransferProtocolManagerImpl::OnGetFileInfoError, | |
246 weak_ptr_factory_.GetWeakPtr())); | |
247 } | |
248 | |
249 virtual void GetFileInfoById(const std::string& storage_handle, | 191 virtual void GetFileInfoById(const std::string& storage_handle, |
250 uint32 file_id, | 192 uint32 file_id, |
251 const GetFileInfoCallback& callback) OVERRIDE { | 193 const GetFileInfoCallback& callback) OVERRIDE { |
252 DCHECK(thread_checker_.CalledOnValidThread()); | 194 DCHECK(thread_checker_.CalledOnValidThread()); |
253 if (!ContainsKey(handles_, storage_handle) || !mtp_client_) { | 195 if (!ContainsKey(handles_, storage_handle) || !mtp_client_) { |
254 callback.Run(MtpFileEntry(), true); | 196 callback.Run(MtpFileEntry(), true); |
255 return; | 197 return; |
256 } | 198 } |
257 get_file_info_callbacks_.push(callback); | 199 get_file_info_callbacks_.push(callback); |
258 mtp_client_->GetFileInfoById( | 200 mtp_client_->GetFileInfoById( |
(...skipping 252 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
511 DCHECK(!g_media_transfer_protocol_manager); | 453 DCHECK(!g_media_transfer_protocol_manager); |
512 | 454 |
513 g_media_transfer_protocol_manager = | 455 g_media_transfer_protocol_manager = |
514 new MediaTransferProtocolManagerImpl(task_runner); | 456 new MediaTransferProtocolManagerImpl(task_runner); |
515 VLOG(1) << "MediaTransferProtocolManager initialized"; | 457 VLOG(1) << "MediaTransferProtocolManager initialized"; |
516 | 458 |
517 return g_media_transfer_protocol_manager; | 459 return g_media_transfer_protocol_manager; |
518 } | 460 } |
519 | 461 |
520 } // namespace device | 462 } // namespace device |
OLD | NEW |