| 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/chromeos/drive/sync/remove_performer.h" | 5 #include "chrome/browser/chromeos/drive/sync/remove_performer.h" |
| 6 | 6 |
| 7 #include "base/sequenced_task_runner.h" | 7 #include "base/sequenced_task_runner.h" |
| 8 #include "chrome/browser/chromeos/drive/drive.pb.h" | 8 #include "chrome/browser/chromeos/drive/drive.pb.h" |
| 9 #include "chrome/browser/chromeos/drive/file_system/operation_observer.h" | 9 #include "chrome/browser/chromeos/drive/file_system/operation_delegate.h" |
| 10 #include "chrome/browser/chromeos/drive/file_system_util.h" | 10 #include "chrome/browser/chromeos/drive/file_system_util.h" |
| 11 #include "chrome/browser/chromeos/drive/job_scheduler.h" | 11 #include "chrome/browser/chromeos/drive/job_scheduler.h" |
| 12 #include "chrome/browser/chromeos/drive/resource_entry_conversion.h" | 12 #include "chrome/browser/chromeos/drive/resource_entry_conversion.h" |
| 13 #include "chrome/browser/chromeos/drive/resource_metadata.h" | 13 #include "chrome/browser/chromeos/drive/resource_metadata.h" |
| 14 #include "chrome/browser/chromeos/drive/sync/entry_revert_performer.h" | 14 #include "chrome/browser/chromeos/drive/sync/entry_revert_performer.h" |
| 15 #include "chrome/browser/drive/drive_api_util.h" | 15 #include "chrome/browser/drive/drive_api_util.h" |
| 16 #include "content/public/browser/browser_thread.h" | 16 #include "content/public/browser/browser_thread.h" |
| 17 #include "google_apis/drive/drive_api_parser.h" | 17 #include "google_apis/drive/drive_api_parser.h" |
| 18 | 18 |
| 19 using content::BrowserThread; | 19 using content::BrowserThread; |
| (...skipping 24 matching lines...) Expand all Loading... |
| 44 FROM_HERE, | 44 FROM_HERE, |
| 45 base::Bind(&ResourceMetadata::RemoveEntry, | 45 base::Bind(&ResourceMetadata::RemoveEntry, |
| 46 base::Unretained(metadata), local_id), | 46 base::Unretained(metadata), local_id), |
| 47 callback); | 47 callback); |
| 48 } | 48 } |
| 49 | 49 |
| 50 } // namespace | 50 } // namespace |
| 51 | 51 |
| 52 RemovePerformer::RemovePerformer( | 52 RemovePerformer::RemovePerformer( |
| 53 base::SequencedTaskRunner* blocking_task_runner, | 53 base::SequencedTaskRunner* blocking_task_runner, |
| 54 file_system::OperationObserver* observer, | 54 file_system::OperationDelegate* delegate, |
| 55 JobScheduler* scheduler, | 55 JobScheduler* scheduler, |
| 56 ResourceMetadata* metadata) | 56 ResourceMetadata* metadata) |
| 57 : blocking_task_runner_(blocking_task_runner), | 57 : blocking_task_runner_(blocking_task_runner), |
| 58 observer_(observer), | 58 delegate_(delegate), |
| 59 scheduler_(scheduler), | 59 scheduler_(scheduler), |
| 60 metadata_(metadata), | 60 metadata_(metadata), |
| 61 entry_revert_performer_(new EntryRevertPerformer(blocking_task_runner, | 61 entry_revert_performer_(new EntryRevertPerformer(blocking_task_runner, |
| 62 observer, | 62 delegate, |
| 63 scheduler, | 63 scheduler, |
| 64 metadata)), | 64 metadata)), |
| 65 weak_ptr_factory_(this) { | 65 weak_ptr_factory_(this) { |
| 66 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 66 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
| 67 } | 67 } |
| 68 | 68 |
| 69 RemovePerformer::~RemovePerformer() { | 69 RemovePerformer::~RemovePerformer() { |
| 70 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 70 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
| 71 } | 71 } |
| 72 | 72 |
| (...skipping 73 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 146 const ClientContext& context, | 146 const ClientContext& context, |
| 147 const FileOperationCallback& callback, | 147 const FileOperationCallback& callback, |
| 148 const std::string& local_id, | 148 const std::string& local_id, |
| 149 google_apis::GDataErrorCode status) { | 149 google_apis::GDataErrorCode status) { |
| 150 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 150 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
| 151 DCHECK(!callback.is_null()); | 151 DCHECK(!callback.is_null()); |
| 152 | 152 |
| 153 if (status == google_apis::HTTP_FORBIDDEN) { | 153 if (status == google_apis::HTTP_FORBIDDEN) { |
| 154 // Editing this entry is not allowed, revert local changes. | 154 // Editing this entry is not allowed, revert local changes. |
| 155 entry_revert_performer_->RevertEntry(local_id, context, callback); | 155 entry_revert_performer_->RevertEntry(local_id, context, callback); |
| 156 observer_->OnDriveSyncError( | 156 delegate_->OnDriveSyncError( |
| 157 file_system::DRIVE_SYNC_ERROR_DELETE_WITHOUT_PERMISSION, local_id); | 157 file_system::DRIVE_SYNC_ERROR_DELETE_WITHOUT_PERMISSION, local_id); |
| 158 return; | 158 return; |
| 159 } | 159 } |
| 160 | 160 |
| 161 FileError error = GDataToFileError(status); | 161 FileError error = GDataToFileError(status); |
| 162 if (error == FILE_ERROR_NOT_FOUND) { // Remove local entry when not found. | 162 if (error == FILE_ERROR_NOT_FOUND) { // Remove local entry when not found. |
| 163 RemoveEntryOnUIThread(blocking_task_runner_.get(), metadata_, local_id, | 163 RemoveEntryOnUIThread(blocking_task_runner_.get(), metadata_, local_id, |
| 164 callback); | 164 callback); |
| 165 return; | 165 return; |
| 166 } | 166 } |
| (...skipping 83 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 250 | 250 |
| 251 base::PostTaskAndReplyWithResult( | 251 base::PostTaskAndReplyWithResult( |
| 252 blocking_task_runner_.get(), | 252 blocking_task_runner_.get(), |
| 253 FROM_HERE, | 253 FROM_HERE, |
| 254 base::Bind(&UpdateLocalStateAfterUnparent, metadata_, local_id), | 254 base::Bind(&UpdateLocalStateAfterUnparent, metadata_, local_id), |
| 255 callback); | 255 callback); |
| 256 } | 256 } |
| 257 | 257 |
| 258 } // namespace internal | 258 } // namespace internal |
| 259 } // namespace drive | 259 } // namespace drive |
| OLD | NEW |