| OLD | NEW |
| 1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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/sync_file_system/local/syncable_file_system_operation.h
" | 5 #include "chrome/browser/sync_file_system/local/syncable_file_system_operation.h
" |
| 6 | 6 |
| 7 #include "base/logging.h" | 7 #include "base/logging.h" |
| 8 #include "chrome/browser/sync_file_system/local/local_file_sync_context.h" | 8 #include "chrome/browser/sync_file_system/local/local_file_sync_context.h" |
| 9 #include "chrome/browser/sync_file_system/local/sync_file_system_backend.h" | 9 #include "chrome/browser/sync_file_system/local/sync_file_system_backend.h" |
| 10 #include "chrome/browser/sync_file_system/local/syncable_file_operation_runner.h
" | 10 #include "chrome/browser/sync_file_system/local/syncable_file_operation_runner.h
" |
| (...skipping 105 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 116 base::Bind(&FileSystemOperation::CreateDirectory, | 116 base::Bind(&FileSystemOperation::CreateDirectory, |
| 117 base::Unretained(impl_.get()), | 117 base::Unretained(impl_.get()), |
| 118 url, exclusive, recursive, | 118 url, exclusive, recursive, |
| 119 base::Bind(&self::DidFinish, weak_factory_.GetWeakPtr())))); | 119 base::Bind(&self::DidFinish, weak_factory_.GetWeakPtr())))); |
| 120 operation_runner_->PostOperationTask(task.Pass()); | 120 operation_runner_->PostOperationTask(task.Pass()); |
| 121 } | 121 } |
| 122 | 122 |
| 123 void SyncableFileSystemOperation::Copy( | 123 void SyncableFileSystemOperation::Copy( |
| 124 const FileSystemURL& src_url, | 124 const FileSystemURL& src_url, |
| 125 const FileSystemURL& dest_url, | 125 const FileSystemURL& dest_url, |
| 126 const CopyProgressCallback& progress_callback, |
| 126 const StatusCallback& callback) { | 127 const StatusCallback& callback) { |
| 127 DCHECK(CalledOnValidThread()); | 128 DCHECK(CalledOnValidThread()); |
| 128 if (!operation_runner_.get()) { | 129 if (!operation_runner_.get()) { |
| 129 callback.Run(base::PLATFORM_FILE_ERROR_NOT_FOUND); | 130 callback.Run(base::PLATFORM_FILE_ERROR_NOT_FOUND); |
| 130 return; | 131 return; |
| 131 } | 132 } |
| 132 DCHECK(operation_runner_.get()); | 133 DCHECK(operation_runner_.get()); |
| 133 target_paths_.push_back(dest_url); | 134 target_paths_.push_back(dest_url); |
| 134 completion_callback_ = callback; | 135 completion_callback_ = callback; |
| 135 scoped_ptr<SyncableFileOperationRunner::Task> task(new QueueableTask( | 136 scoped_ptr<SyncableFileOperationRunner::Task> task(new QueueableTask( |
| 136 weak_factory_.GetWeakPtr(), | 137 weak_factory_.GetWeakPtr(), |
| 137 base::Bind(&FileSystemOperation::Copy, | 138 base::Bind(&FileSystemOperation::Copy, |
| 138 base::Unretained(impl_.get()), | 139 base::Unretained(impl_.get()), |
| 139 src_url, dest_url, | 140 src_url, dest_url, progress_callback, |
| 140 base::Bind(&self::DidFinish, weak_factory_.GetWeakPtr())))); | 141 base::Bind(&self::DidFinish, weak_factory_.GetWeakPtr())))); |
| 141 operation_runner_->PostOperationTask(task.Pass()); | 142 operation_runner_->PostOperationTask(task.Pass()); |
| 142 } | 143 } |
| 143 | 144 |
| 144 void SyncableFileSystemOperation::Move( | 145 void SyncableFileSystemOperation::Move( |
| 145 const FileSystemURL& src_url, | 146 const FileSystemURL& src_url, |
| 146 const FileSystemURL& dest_url, | 147 const FileSystemURL& dest_url, |
| 147 const StatusCallback& callback) { | 148 const StatusCallback& callback) { |
| 148 DCHECK(CalledOnValidThread()); | 149 DCHECK(CalledOnValidThread()); |
| 149 if (!operation_runner_.get()) { | 150 if (!operation_runner_.get()) { |
| (...skipping 170 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 320 void SyncableFileSystemOperation::RemoveDirectory( | 321 void SyncableFileSystemOperation::RemoveDirectory( |
| 321 const FileSystemURL& url, | 322 const FileSystemURL& url, |
| 322 const StatusCallback& callback) { | 323 const StatusCallback& callback) { |
| 323 DCHECK(CalledOnValidThread()); | 324 DCHECK(CalledOnValidThread()); |
| 324 impl_->RemoveDirectory(url, callback); | 325 impl_->RemoveDirectory(url, callback); |
| 325 } | 326 } |
| 326 | 327 |
| 327 void SyncableFileSystemOperation::CopyFileLocal( | 328 void SyncableFileSystemOperation::CopyFileLocal( |
| 328 const FileSystemURL& src_url, | 329 const FileSystemURL& src_url, |
| 329 const FileSystemURL& dest_url, | 330 const FileSystemURL& dest_url, |
| 331 const CopyFileProgressCallback& progress_callback, |
| 330 const StatusCallback& callback) { | 332 const StatusCallback& callback) { |
| 331 DCHECK(CalledOnValidThread()); | 333 DCHECK(CalledOnValidThread()); |
| 332 impl_->CopyFileLocal(src_url, dest_url, callback); | 334 impl_->CopyFileLocal(src_url, dest_url, progress_callback, callback); |
| 333 } | 335 } |
| 334 | 336 |
| 335 void SyncableFileSystemOperation::MoveFileLocal( | 337 void SyncableFileSystemOperation::MoveFileLocal( |
| 336 const FileSystemURL& src_url, | 338 const FileSystemURL& src_url, |
| 337 const FileSystemURL& dest_url, | 339 const FileSystemURL& dest_url, |
| 338 const StatusCallback& callback) { | 340 const StatusCallback& callback) { |
| 339 DCHECK(CalledOnValidThread()); | 341 DCHECK(CalledOnValidThread()); |
| 340 impl_->MoveFileLocal(src_url, dest_url, callback); | 342 impl_->MoveFileLocal(src_url, dest_url, callback); |
| 341 } | 343 } |
| 342 | 344 |
| (...skipping 47 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 390 operation_runner_->OnOperationCompleted(target_paths_); | 392 operation_runner_->OnOperationCompleted(target_paths_); |
| 391 callback.Run(result, bytes, complete); | 393 callback.Run(result, bytes, complete); |
| 392 } | 394 } |
| 393 | 395 |
| 394 void SyncableFileSystemOperation::OnCancelled() { | 396 void SyncableFileSystemOperation::OnCancelled() { |
| 395 DCHECK(!completion_callback_.is_null()); | 397 DCHECK(!completion_callback_.is_null()); |
| 396 completion_callback_.Run(base::PLATFORM_FILE_ERROR_ABORT); | 398 completion_callback_.Run(base::PLATFORM_FILE_ERROR_ABORT); |
| 397 } | 399 } |
| 398 | 400 |
| 399 } // namespace sync_file_system | 401 } // namespace sync_file_system |
| OLD | NEW |