| OLD | NEW |
| 1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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 "components/drive/directory_loader.h" | 5 #include "components/drive/directory_loader.h" |
| 6 | 6 |
| 7 #include <stddef.h> | 7 #include <stddef.h> |
| 8 #include <utility> | 8 #include <utility> |
| 9 | 9 |
| 10 #include "base/callback.h" | 10 #include "base/callback.h" |
| (...skipping 123 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 134 } | 134 } |
| 135 | 135 |
| 136 DCHECK(file_list); | 136 DCHECK(file_list); |
| 137 scoped_ptr<ChangeList> change_list(new ChangeList(*file_list)); | 137 scoped_ptr<ChangeList> change_list(new ChangeList(*file_list)); |
| 138 GURL next_url = file_list->next_link(); | 138 GURL next_url = file_list->next_link(); |
| 139 | 139 |
| 140 ResourceEntryVector* entries = new ResourceEntryVector; | 140 ResourceEntryVector* entries = new ResourceEntryVector; |
| 141 loader_->loader_controller_->ScheduleRun(base::Bind( | 141 loader_->loader_controller_->ScheduleRun(base::Bind( |
| 142 base::IgnoreResult( | 142 base::IgnoreResult( |
| 143 &base::PostTaskAndReplyWithResult<FileError, FileError>), | 143 &base::PostTaskAndReplyWithResult<FileError, FileError>), |
| 144 loader_->blocking_task_runner_, | 144 base::RetainedRef(loader_->blocking_task_runner_), FROM_HERE, |
| 145 FROM_HERE, | |
| 146 base::Bind(&ChangeListProcessor::RefreshDirectory, | 145 base::Bind(&ChangeListProcessor::RefreshDirectory, |
| 147 loader_->resource_metadata_, | 146 loader_->resource_metadata_, directory_fetch_info_, |
| 148 directory_fetch_info_, | 147 base::Passed(&change_list), entries), |
| 149 base::Passed(&change_list), | |
| 150 entries), | |
| 151 base::Bind(&FeedFetcher::OnDirectoryRefreshed, | 148 base::Bind(&FeedFetcher::OnDirectoryRefreshed, |
| 152 weak_ptr_factory_.GetWeakPtr(), | 149 weak_ptr_factory_.GetWeakPtr(), callback, next_url, |
| 153 callback, | |
| 154 next_url, | |
| 155 base::Owned(entries)))); | 150 base::Owned(entries)))); |
| 156 } | 151 } |
| 157 | 152 |
| 158 void OnDirectoryRefreshed( | 153 void OnDirectoryRefreshed( |
| 159 const FileOperationCallback& callback, | 154 const FileOperationCallback& callback, |
| 160 const GURL& next_url, | 155 const GURL& next_url, |
| 161 const std::vector<ResourceEntry>* refreshed_entries, | 156 const std::vector<ResourceEntry>* refreshed_entries, |
| 162 FileError error) { | 157 FileError error) { |
| 163 DCHECK(thread_checker_.CalledOnValidThread()); | 158 DCHECK(thread_checker_.CalledOnValidThread()); |
| 164 DCHECK(!callback.is_null()); | 159 DCHECK(!callback.is_null()); |
| (...skipping 401 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 566 // Also notify the observers. | 561 // Also notify the observers. |
| 567 if (error == FILE_ERROR_OK && !directory_path->empty()) { | 562 if (error == FILE_ERROR_OK && !directory_path->empty()) { |
| 568 FOR_EACH_OBSERVER(ChangeListLoaderObserver, | 563 FOR_EACH_OBSERVER(ChangeListLoaderObserver, |
| 569 observers_, | 564 observers_, |
| 570 OnDirectoryReloaded(*directory_path)); | 565 OnDirectoryReloaded(*directory_path)); |
| 571 } | 566 } |
| 572 } | 567 } |
| 573 | 568 |
| 574 } // namespace internal | 569 } // namespace internal |
| 575 } // namespace drive | 570 } // namespace drive |
| OLD | NEW |