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 |