| 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 "chrome/browser/media_galleries/fileapi/native_media_file_util.h" | 5 #include "chrome/browser/media_galleries/fileapi/native_media_file_util.h" |
| 6 | 6 |
| 7 #include <string> | 7 #include <string> |
| 8 #include <utility> | 8 #include <utility> |
| 9 | 9 |
| 10 #include "base/bind.h" | 10 #include "base/bind.h" |
| (...skipping 138 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 149 void NativeMediaFileUtil::CreateDirectory( | 149 void NativeMediaFileUtil::CreateDirectory( |
| 150 std::unique_ptr<storage::FileSystemOperationContext> context, | 150 std::unique_ptr<storage::FileSystemOperationContext> context, |
| 151 const storage::FileSystemURL& url, | 151 const storage::FileSystemURL& url, |
| 152 bool exclusive, | 152 bool exclusive, |
| 153 bool recursive, | 153 bool recursive, |
| 154 const StatusCallback& callback) { | 154 const StatusCallback& callback) { |
| 155 DCHECK_CURRENTLY_ON(content::BrowserThread::IO); | 155 DCHECK_CURRENTLY_ON(content::BrowserThread::IO); |
| 156 storage::FileSystemOperationContext* context_ptr = context.get(); | 156 storage::FileSystemOperationContext* context_ptr = context.get(); |
| 157 const bool success = context_ptr->task_runner()->PostTask( | 157 const bool success = context_ptr->task_runner()->PostTask( |
| 158 FROM_HERE, | 158 FROM_HERE, |
| 159 base::Bind(&NativeMediaFileUtil::CreateDirectoryOnTaskRunnerThread, | 159 base::BindOnce(&NativeMediaFileUtil::CreateDirectoryOnTaskRunnerThread, |
| 160 weak_factory_.GetWeakPtr(), base::Passed(&context), | 160 weak_factory_.GetWeakPtr(), base::Passed(&context), url, |
| 161 url, exclusive, recursive, callback)); | 161 exclusive, recursive, callback)); |
| 162 DCHECK(success); | 162 DCHECK(success); |
| 163 } | 163 } |
| 164 | 164 |
| 165 void NativeMediaFileUtil::GetFileInfo( | 165 void NativeMediaFileUtil::GetFileInfo( |
| 166 std::unique_ptr<storage::FileSystemOperationContext> context, | 166 std::unique_ptr<storage::FileSystemOperationContext> context, |
| 167 const storage::FileSystemURL& url, | 167 const storage::FileSystemURL& url, |
| 168 int /* fields */, | 168 int /* fields */, |
| 169 const GetFileInfoCallback& callback) { | 169 const GetFileInfoCallback& callback) { |
| 170 DCHECK_CURRENTLY_ON(content::BrowserThread::IO); | 170 DCHECK_CURRENTLY_ON(content::BrowserThread::IO); |
| 171 storage::FileSystemOperationContext* context_ptr = context.get(); | 171 storage::FileSystemOperationContext* context_ptr = context.get(); |
| 172 const bool success = context_ptr->task_runner()->PostTask( | 172 const bool success = context_ptr->task_runner()->PostTask( |
| 173 FROM_HERE, | 173 FROM_HERE, |
| 174 base::Bind(&NativeMediaFileUtil::GetFileInfoOnTaskRunnerThread, | 174 base::BindOnce(&NativeMediaFileUtil::GetFileInfoOnTaskRunnerThread, |
| 175 weak_factory_.GetWeakPtr(), base::Passed(&context), | 175 weak_factory_.GetWeakPtr(), base::Passed(&context), url, |
| 176 url, callback)); | 176 callback)); |
| 177 DCHECK(success); | 177 DCHECK(success); |
| 178 } | 178 } |
| 179 | 179 |
| 180 void NativeMediaFileUtil::ReadDirectory( | 180 void NativeMediaFileUtil::ReadDirectory( |
| 181 std::unique_ptr<storage::FileSystemOperationContext> context, | 181 std::unique_ptr<storage::FileSystemOperationContext> context, |
| 182 const storage::FileSystemURL& url, | 182 const storage::FileSystemURL& url, |
| 183 const ReadDirectoryCallback& callback) { | 183 const ReadDirectoryCallback& callback) { |
| 184 DCHECK_CURRENTLY_ON(content::BrowserThread::IO); | 184 DCHECK_CURRENTLY_ON(content::BrowserThread::IO); |
| 185 storage::FileSystemOperationContext* context_ptr = context.get(); | 185 storage::FileSystemOperationContext* context_ptr = context.get(); |
| 186 const bool success = context_ptr->task_runner()->PostTask( | 186 const bool success = context_ptr->task_runner()->PostTask( |
| 187 FROM_HERE, | 187 FROM_HERE, |
| 188 base::Bind(&NativeMediaFileUtil::ReadDirectoryOnTaskRunnerThread, | 188 base::BindOnce(&NativeMediaFileUtil::ReadDirectoryOnTaskRunnerThread, |
| 189 weak_factory_.GetWeakPtr(), base::Passed(&context), | 189 weak_factory_.GetWeakPtr(), base::Passed(&context), url, |
| 190 url, callback)); | 190 callback)); |
| 191 DCHECK(success); | 191 DCHECK(success); |
| 192 } | 192 } |
| 193 | 193 |
| 194 void NativeMediaFileUtil::Touch( | 194 void NativeMediaFileUtil::Touch( |
| 195 std::unique_ptr<storage::FileSystemOperationContext> context, | 195 std::unique_ptr<storage::FileSystemOperationContext> context, |
| 196 const storage::FileSystemURL& url, | 196 const storage::FileSystemURL& url, |
| 197 const base::Time& last_access_time, | 197 const base::Time& last_access_time, |
| 198 const base::Time& last_modified_time, | 198 const base::Time& last_modified_time, |
| 199 const StatusCallback& callback) { | 199 const StatusCallback& callback) { |
| 200 DCHECK_CURRENTLY_ON(content::BrowserThread::IO); | 200 DCHECK_CURRENTLY_ON(content::BrowserThread::IO); |
| (...skipping 13 matching lines...) Expand all Loading... |
| 214 std::unique_ptr<storage::FileSystemOperationContext> context, | 214 std::unique_ptr<storage::FileSystemOperationContext> context, |
| 215 const storage::FileSystemURL& src_url, | 215 const storage::FileSystemURL& src_url, |
| 216 const storage::FileSystemURL& dest_url, | 216 const storage::FileSystemURL& dest_url, |
| 217 CopyOrMoveOption option, | 217 CopyOrMoveOption option, |
| 218 const CopyFileProgressCallback& progress_callback, | 218 const CopyFileProgressCallback& progress_callback, |
| 219 const StatusCallback& callback) { | 219 const StatusCallback& callback) { |
| 220 DCHECK_CURRENTLY_ON(content::BrowserThread::IO); | 220 DCHECK_CURRENTLY_ON(content::BrowserThread::IO); |
| 221 storage::FileSystemOperationContext* context_ptr = context.get(); | 221 storage::FileSystemOperationContext* context_ptr = context.get(); |
| 222 const bool success = context_ptr->task_runner()->PostTask( | 222 const bool success = context_ptr->task_runner()->PostTask( |
| 223 FROM_HERE, | 223 FROM_HERE, |
| 224 base::Bind(&NativeMediaFileUtil::CopyOrMoveFileLocalOnTaskRunnerThread, | 224 base::BindOnce( |
| 225 weak_factory_.GetWeakPtr(), base::Passed(&context), | 225 &NativeMediaFileUtil::CopyOrMoveFileLocalOnTaskRunnerThread, |
| 226 src_url, dest_url, option, true /* copy */, callback)); | 226 weak_factory_.GetWeakPtr(), base::Passed(&context), src_url, dest_url, |
| 227 option, true /* copy */, callback)); |
| 227 DCHECK(success); | 228 DCHECK(success); |
| 228 } | 229 } |
| 229 | 230 |
| 230 void NativeMediaFileUtil::MoveFileLocal( | 231 void NativeMediaFileUtil::MoveFileLocal( |
| 231 std::unique_ptr<storage::FileSystemOperationContext> context, | 232 std::unique_ptr<storage::FileSystemOperationContext> context, |
| 232 const storage::FileSystemURL& src_url, | 233 const storage::FileSystemURL& src_url, |
| 233 const storage::FileSystemURL& dest_url, | 234 const storage::FileSystemURL& dest_url, |
| 234 CopyOrMoveOption option, | 235 CopyOrMoveOption option, |
| 235 const StatusCallback& callback) { | 236 const StatusCallback& callback) { |
| 236 DCHECK_CURRENTLY_ON(content::BrowserThread::IO); | 237 DCHECK_CURRENTLY_ON(content::BrowserThread::IO); |
| 237 storage::FileSystemOperationContext* context_ptr = context.get(); | 238 storage::FileSystemOperationContext* context_ptr = context.get(); |
| 238 const bool success = context_ptr->task_runner()->PostTask( | 239 const bool success = context_ptr->task_runner()->PostTask( |
| 239 FROM_HERE, | 240 FROM_HERE, |
| 240 base::Bind(&NativeMediaFileUtil::CopyOrMoveFileLocalOnTaskRunnerThread, | 241 base::BindOnce( |
| 241 weak_factory_.GetWeakPtr(), base::Passed(&context), | 242 &NativeMediaFileUtil::CopyOrMoveFileLocalOnTaskRunnerThread, |
| 242 src_url, dest_url, option, false /* copy */, callback)); | 243 weak_factory_.GetWeakPtr(), base::Passed(&context), src_url, dest_url, |
| 244 option, false /* copy */, callback)); |
| 243 DCHECK(success); | 245 DCHECK(success); |
| 244 } | 246 } |
| 245 | 247 |
| 246 void NativeMediaFileUtil::CopyInForeignFile( | 248 void NativeMediaFileUtil::CopyInForeignFile( |
| 247 std::unique_ptr<storage::FileSystemOperationContext> context, | 249 std::unique_ptr<storage::FileSystemOperationContext> context, |
| 248 const base::FilePath& src_file_path, | 250 const base::FilePath& src_file_path, |
| 249 const storage::FileSystemURL& dest_url, | 251 const storage::FileSystemURL& dest_url, |
| 250 const StatusCallback& callback) { | 252 const StatusCallback& callback) { |
| 251 DCHECK_CURRENTLY_ON(content::BrowserThread::IO); | 253 DCHECK_CURRENTLY_ON(content::BrowserThread::IO); |
| 252 storage::FileSystemOperationContext* context_ptr = context.get(); | 254 storage::FileSystemOperationContext* context_ptr = context.get(); |
| 253 const bool success = context_ptr->task_runner()->PostTask( | 255 const bool success = context_ptr->task_runner()->PostTask( |
| 254 FROM_HERE, | 256 FROM_HERE, |
| 255 base::Bind(&NativeMediaFileUtil::CopyInForeignFileOnTaskRunnerThread, | 257 base::BindOnce(&NativeMediaFileUtil::CopyInForeignFileOnTaskRunnerThread, |
| 256 weak_factory_.GetWeakPtr(), base::Passed(&context), | 258 weak_factory_.GetWeakPtr(), base::Passed(&context), |
| 257 src_file_path, dest_url, callback)); | 259 src_file_path, dest_url, callback)); |
| 258 DCHECK(success); | 260 DCHECK(success); |
| 259 } | 261 } |
| 260 | 262 |
| 261 void NativeMediaFileUtil::DeleteFile( | 263 void NativeMediaFileUtil::DeleteFile( |
| 262 std::unique_ptr<storage::FileSystemOperationContext> context, | 264 std::unique_ptr<storage::FileSystemOperationContext> context, |
| 263 const storage::FileSystemURL& url, | 265 const storage::FileSystemURL& url, |
| 264 const StatusCallback& callback) { | 266 const StatusCallback& callback) { |
| 265 DCHECK_CURRENTLY_ON(content::BrowserThread::IO); | 267 DCHECK_CURRENTLY_ON(content::BrowserThread::IO); |
| 266 storage::FileSystemOperationContext* context_ptr = context.get(); | 268 storage::FileSystemOperationContext* context_ptr = context.get(); |
| 267 const bool success = context_ptr->task_runner()->PostTask( | 269 const bool success = context_ptr->task_runner()->PostTask( |
| 268 FROM_HERE, | 270 FROM_HERE, |
| 269 base::Bind(&NativeMediaFileUtil::DeleteFileOnTaskRunnerThread, | 271 base::BindOnce(&NativeMediaFileUtil::DeleteFileOnTaskRunnerThread, |
| 270 weak_factory_.GetWeakPtr(), base::Passed(&context), | 272 weak_factory_.GetWeakPtr(), base::Passed(&context), url, |
| 271 url, callback)); | 273 callback)); |
| 272 DCHECK(success); | 274 DCHECK(success); |
| 273 } | 275 } |
| 274 | 276 |
| 275 // This is needed to support Copy and Move. | 277 // This is needed to support Copy and Move. |
| 276 void NativeMediaFileUtil::DeleteDirectory( | 278 void NativeMediaFileUtil::DeleteDirectory( |
| 277 std::unique_ptr<storage::FileSystemOperationContext> context, | 279 std::unique_ptr<storage::FileSystemOperationContext> context, |
| 278 const storage::FileSystemURL& url, | 280 const storage::FileSystemURL& url, |
| 279 const StatusCallback& callback) { | 281 const StatusCallback& callback) { |
| 280 DCHECK_CURRENTLY_ON(content::BrowserThread::IO); | 282 DCHECK_CURRENTLY_ON(content::BrowserThread::IO); |
| 281 storage::FileSystemOperationContext* context_ptr = context.get(); | 283 storage::FileSystemOperationContext* context_ptr = context.get(); |
| 282 const bool success = context_ptr->task_runner()->PostTask( | 284 const bool success = context_ptr->task_runner()->PostTask( |
| 283 FROM_HERE, | 285 FROM_HERE, |
| 284 base::Bind(&NativeMediaFileUtil::DeleteDirectoryOnTaskRunnerThread, | 286 base::BindOnce(&NativeMediaFileUtil::DeleteDirectoryOnTaskRunnerThread, |
| 285 weak_factory_.GetWeakPtr(), base::Passed(&context), | 287 weak_factory_.GetWeakPtr(), base::Passed(&context), url, |
| 286 url, callback)); | 288 callback)); |
| 287 DCHECK(success); | 289 DCHECK(success); |
| 288 } | 290 } |
| 289 | 291 |
| 290 void NativeMediaFileUtil::DeleteRecursively( | 292 void NativeMediaFileUtil::DeleteRecursively( |
| 291 std::unique_ptr<storage::FileSystemOperationContext> context, | 293 std::unique_ptr<storage::FileSystemOperationContext> context, |
| 292 const storage::FileSystemURL& url, | 294 const storage::FileSystemURL& url, |
| 293 const StatusCallback& callback) { | 295 const StatusCallback& callback) { |
| 294 DCHECK_CURRENTLY_ON(content::BrowserThread::IO); | 296 DCHECK_CURRENTLY_ON(content::BrowserThread::IO); |
| 295 callback.Run(base::File::FILE_ERROR_INVALID_OPERATION); | 297 callback.Run(base::File::FILE_ERROR_INVALID_OPERATION); |
| 296 } | 298 } |
| 297 | 299 |
| 298 void NativeMediaFileUtil::CreateSnapshotFile( | 300 void NativeMediaFileUtil::CreateSnapshotFile( |
| 299 std::unique_ptr<storage::FileSystemOperationContext> context, | 301 std::unique_ptr<storage::FileSystemOperationContext> context, |
| 300 const storage::FileSystemURL& url, | 302 const storage::FileSystemURL& url, |
| 301 const CreateSnapshotFileCallback& callback) { | 303 const CreateSnapshotFileCallback& callback) { |
| 302 DCHECK_CURRENTLY_ON(content::BrowserThread::IO); | 304 DCHECK_CURRENTLY_ON(content::BrowserThread::IO); |
| 303 storage::FileSystemOperationContext* context_ptr = context.get(); | 305 storage::FileSystemOperationContext* context_ptr = context.get(); |
| 304 const bool success = context_ptr->task_runner()->PostTask( | 306 const bool success = context_ptr->task_runner()->PostTask( |
| 305 FROM_HERE, | 307 FROM_HERE, |
| 306 base::Bind(&NativeMediaFileUtil::CreateSnapshotFileOnTaskRunnerThread, | 308 base::BindOnce(&NativeMediaFileUtil::CreateSnapshotFileOnTaskRunnerThread, |
| 307 weak_factory_.GetWeakPtr(), base::Passed(&context), | 309 weak_factory_.GetWeakPtr(), base::Passed(&context), url, |
| 308 url, callback)); | 310 callback)); |
| 309 DCHECK(success); | 311 DCHECK(success); |
| 310 } | 312 } |
| 311 | 313 |
| 312 void NativeMediaFileUtil::CreateDirectoryOnTaskRunnerThread( | 314 void NativeMediaFileUtil::CreateDirectoryOnTaskRunnerThread( |
| 313 std::unique_ptr<storage::FileSystemOperationContext> context, | 315 std::unique_ptr<storage::FileSystemOperationContext> context, |
| 314 const storage::FileSystemURL& url, | 316 const storage::FileSystemURL& url, |
| 315 bool exclusive, | 317 bool exclusive, |
| 316 bool recursive, | 318 bool recursive, |
| 317 const StatusCallback& callback) { | 319 const StatusCallback& callback) { |
| 318 DCHECK(IsOnTaskRunnerThread(context.get())); | 320 DCHECK(IsOnTaskRunnerThread(context.get())); |
| 319 base::File::Error error = | 321 base::File::Error error = |
| 320 CreateDirectorySync(context.get(), url, exclusive, recursive); | 322 CreateDirectorySync(context.get(), url, exclusive, recursive); |
| 321 content::BrowserThread::PostTask( | 323 content::BrowserThread::PostTask(content::BrowserThread::IO, FROM_HERE, |
| 322 content::BrowserThread::IO, | 324 base::BindOnce(callback, error)); |
| 323 FROM_HERE, | |
| 324 base::Bind(callback, error)); | |
| 325 } | 325 } |
| 326 | 326 |
| 327 void NativeMediaFileUtil::GetFileInfoOnTaskRunnerThread( | 327 void NativeMediaFileUtil::GetFileInfoOnTaskRunnerThread( |
| 328 std::unique_ptr<storage::FileSystemOperationContext> context, | 328 std::unique_ptr<storage::FileSystemOperationContext> context, |
| 329 const storage::FileSystemURL& url, | 329 const storage::FileSystemURL& url, |
| 330 const GetFileInfoCallback& callback) { | 330 const GetFileInfoCallback& callback) { |
| 331 DCHECK(IsOnTaskRunnerThread(context.get())); | 331 DCHECK(IsOnTaskRunnerThread(context.get())); |
| 332 base::File::Info file_info; | 332 base::File::Info file_info; |
| 333 base::File::Error error = | 333 base::File::Error error = |
| 334 GetFileInfoSync(context.get(), url, &file_info, NULL); | 334 GetFileInfoSync(context.get(), url, &file_info, NULL); |
| 335 content::BrowserThread::PostTask( | 335 content::BrowserThread::PostTask(content::BrowserThread::IO, FROM_HERE, |
| 336 content::BrowserThread::IO, | 336 base::BindOnce(callback, error, file_info)); |
| 337 FROM_HERE, | |
| 338 base::Bind(callback, error, file_info)); | |
| 339 } | 337 } |
| 340 | 338 |
| 341 void NativeMediaFileUtil::ReadDirectoryOnTaskRunnerThread( | 339 void NativeMediaFileUtil::ReadDirectoryOnTaskRunnerThread( |
| 342 std::unique_ptr<storage::FileSystemOperationContext> context, | 340 std::unique_ptr<storage::FileSystemOperationContext> context, |
| 343 const storage::FileSystemURL& url, | 341 const storage::FileSystemURL& url, |
| 344 const ReadDirectoryCallback& callback) { | 342 const ReadDirectoryCallback& callback) { |
| 345 DCHECK(IsOnTaskRunnerThread(context.get())); | 343 DCHECK(IsOnTaskRunnerThread(context.get())); |
| 346 EntryList entry_list; | 344 EntryList entry_list; |
| 347 base::File::Error error = | 345 base::File::Error error = |
| 348 ReadDirectorySync(context.get(), url, &entry_list); | 346 ReadDirectorySync(context.get(), url, &entry_list); |
| 349 content::BrowserThread::PostTask( | 347 content::BrowserThread::PostTask( |
| 350 content::BrowserThread::IO, | 348 content::BrowserThread::IO, FROM_HERE, |
| 351 FROM_HERE, | 349 base::BindOnce(callback, error, entry_list, false /* has_more */)); |
| 352 base::Bind(callback, error, entry_list, false /* has_more */)); | |
| 353 } | 350 } |
| 354 | 351 |
| 355 void NativeMediaFileUtil::CopyOrMoveFileLocalOnTaskRunnerThread( | 352 void NativeMediaFileUtil::CopyOrMoveFileLocalOnTaskRunnerThread( |
| 356 std::unique_ptr<storage::FileSystemOperationContext> context, | 353 std::unique_ptr<storage::FileSystemOperationContext> context, |
| 357 const storage::FileSystemURL& src_url, | 354 const storage::FileSystemURL& src_url, |
| 358 const storage::FileSystemURL& dest_url, | 355 const storage::FileSystemURL& dest_url, |
| 359 CopyOrMoveOption option, | 356 CopyOrMoveOption option, |
| 360 bool copy, | 357 bool copy, |
| 361 const StatusCallback& callback) { | 358 const StatusCallback& callback) { |
| 362 DCHECK(IsOnTaskRunnerThread(context.get())); | 359 DCHECK(IsOnTaskRunnerThread(context.get())); |
| 363 base::File::Error error = | 360 base::File::Error error = |
| 364 CopyOrMoveFileSync(context.get(), src_url, dest_url, option, copy); | 361 CopyOrMoveFileSync(context.get(), src_url, dest_url, option, copy); |
| 365 content::BrowserThread::PostTask( | 362 content::BrowserThread::PostTask(content::BrowserThread::IO, FROM_HERE, |
| 366 content::BrowserThread::IO, | 363 base::BindOnce(callback, error)); |
| 367 FROM_HERE, | |
| 368 base::Bind(callback, error)); | |
| 369 } | 364 } |
| 370 | 365 |
| 371 void NativeMediaFileUtil::CopyInForeignFileOnTaskRunnerThread( | 366 void NativeMediaFileUtil::CopyInForeignFileOnTaskRunnerThread( |
| 372 std::unique_ptr<storage::FileSystemOperationContext> context, | 367 std::unique_ptr<storage::FileSystemOperationContext> context, |
| 373 const base::FilePath& src_file_path, | 368 const base::FilePath& src_file_path, |
| 374 const storage::FileSystemURL& dest_url, | 369 const storage::FileSystemURL& dest_url, |
| 375 const StatusCallback& callback) { | 370 const StatusCallback& callback) { |
| 376 DCHECK(IsOnTaskRunnerThread(context.get())); | 371 DCHECK(IsOnTaskRunnerThread(context.get())); |
| 377 base::File::Error error = | 372 base::File::Error error = |
| 378 CopyInForeignFileSync(context.get(), src_file_path, dest_url); | 373 CopyInForeignFileSync(context.get(), src_file_path, dest_url); |
| 379 content::BrowserThread::PostTask( | 374 content::BrowserThread::PostTask(content::BrowserThread::IO, FROM_HERE, |
| 380 content::BrowserThread::IO, | 375 base::BindOnce(callback, error)); |
| 381 FROM_HERE, | |
| 382 base::Bind(callback, error)); | |
| 383 } | 376 } |
| 384 | 377 |
| 385 void NativeMediaFileUtil::DeleteFileOnTaskRunnerThread( | 378 void NativeMediaFileUtil::DeleteFileOnTaskRunnerThread( |
| 386 std::unique_ptr<storage::FileSystemOperationContext> context, | 379 std::unique_ptr<storage::FileSystemOperationContext> context, |
| 387 const storage::FileSystemURL& url, | 380 const storage::FileSystemURL& url, |
| 388 const StatusCallback& callback) { | 381 const StatusCallback& callback) { |
| 389 DCHECK(IsOnTaskRunnerThread(context.get())); | 382 DCHECK(IsOnTaskRunnerThread(context.get())); |
| 390 base::File::Error error = DeleteFileSync(context.get(), url); | 383 base::File::Error error = DeleteFileSync(context.get(), url); |
| 391 content::BrowserThread::PostTask( | 384 content::BrowserThread::PostTask(content::BrowserThread::IO, FROM_HERE, |
| 392 content::BrowserThread::IO, | 385 base::BindOnce(callback, error)); |
| 393 FROM_HERE, | |
| 394 base::Bind(callback, error)); | |
| 395 } | 386 } |
| 396 | 387 |
| 397 void NativeMediaFileUtil::DeleteDirectoryOnTaskRunnerThread( | 388 void NativeMediaFileUtil::DeleteDirectoryOnTaskRunnerThread( |
| 398 std::unique_ptr<storage::FileSystemOperationContext> context, | 389 std::unique_ptr<storage::FileSystemOperationContext> context, |
| 399 const storage::FileSystemURL& url, | 390 const storage::FileSystemURL& url, |
| 400 const StatusCallback& callback) { | 391 const StatusCallback& callback) { |
| 401 DCHECK(IsOnTaskRunnerThread(context.get())); | 392 DCHECK(IsOnTaskRunnerThread(context.get())); |
| 402 base::File::Error error = DeleteDirectorySync(context.get(), url); | 393 base::File::Error error = DeleteDirectorySync(context.get(), url); |
| 403 content::BrowserThread::PostTask( | 394 content::BrowserThread::PostTask(content::BrowserThread::IO, FROM_HERE, |
| 404 content::BrowserThread::IO, | 395 base::BindOnce(callback, error)); |
| 405 FROM_HERE, | |
| 406 base::Bind(callback, error)); | |
| 407 } | 396 } |
| 408 | 397 |
| 409 void NativeMediaFileUtil::CreateSnapshotFileOnTaskRunnerThread( | 398 void NativeMediaFileUtil::CreateSnapshotFileOnTaskRunnerThread( |
| 410 std::unique_ptr<storage::FileSystemOperationContext> context, | 399 std::unique_ptr<storage::FileSystemOperationContext> context, |
| 411 const storage::FileSystemURL& url, | 400 const storage::FileSystemURL& url, |
| 412 const CreateSnapshotFileCallback& callback) { | 401 const CreateSnapshotFileCallback& callback) { |
| 413 DCHECK(IsOnTaskRunnerThread(context.get())); | 402 DCHECK(IsOnTaskRunnerThread(context.get())); |
| 414 base::File::Info file_info; | 403 base::File::Info file_info; |
| 415 base::FilePath platform_path; | 404 base::FilePath platform_path; |
| 416 scoped_refptr<storage::ShareableFileReference> file_ref; | 405 scoped_refptr<storage::ShareableFileReference> file_ref; |
| 417 base::File::Error error = CreateSnapshotFileSync( | 406 base::File::Error error = CreateSnapshotFileSync( |
| 418 context.get(), url, &file_info, &platform_path, &file_ref); | 407 context.get(), url, &file_info, &platform_path, &file_ref); |
| 419 content::BrowserThread::PostTask( | 408 content::BrowserThread::PostTask( |
| 420 content::BrowserThread::IO, | 409 content::BrowserThread::IO, FROM_HERE, |
| 421 FROM_HERE, | 410 base::BindOnce(callback, error, file_info, platform_path, file_ref)); |
| 422 base::Bind(callback, error, file_info, platform_path, file_ref)); | |
| 423 } | 411 } |
| 424 | 412 |
| 425 base::File::Error NativeMediaFileUtil::CreateDirectorySync( | 413 base::File::Error NativeMediaFileUtil::CreateDirectorySync( |
| 426 storage::FileSystemOperationContext* context, | 414 storage::FileSystemOperationContext* context, |
| 427 const storage::FileSystemURL& url, | 415 const storage::FileSystemURL& url, |
| 428 bool exclusive, | 416 bool exclusive, |
| 429 bool recursive) { | 417 bool recursive) { |
| 430 base::FilePath file_path; | 418 base::FilePath file_path; |
| 431 base::File::Error error = GetLocalFilePath(context, url, &file_path); | 419 base::File::Error error = GetLocalFilePath(context, url, &file_path); |
| 432 if (error != base::File::FILE_OK) | 420 if (error != base::File::FILE_OK) |
| (...skipping 235 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 668 return base::File::FILE_ERROR_FAILED; | 656 return base::File::FILE_ERROR_FAILED; |
| 669 | 657 |
| 670 if (!file_info.is_directory && | 658 if (!file_info.is_directory && |
| 671 !media_path_filter_->Match(file_path)) { | 659 !media_path_filter_->Match(file_path)) { |
| 672 return failure_error; | 660 return failure_error; |
| 673 } | 661 } |
| 674 | 662 |
| 675 *local_file_path = file_path; | 663 *local_file_path = file_path; |
| 676 return base::File::FILE_OK; | 664 return base::File::FILE_OK; |
| 677 } | 665 } |
| OLD | NEW |