Chromium Code Reviews| Index: chrome/browser/media_gallery/linux/mtp_recursive_device_object_enumerator.cc |
| diff --git a/chrome/browser/media_gallery/linux/mtp_recursive_device_object_enumerator.cc b/chrome/browser/media_gallery/linux/mtp_recursive_device_object_enumerator.cc |
| index 2b5ceebea0759b0b0c5e0735df5953bbf83c3388..250eafaeaa4e81d2a046c1b4c4b8aae80088f3f0 100644 |
| --- a/chrome/browser/media_gallery/linux/mtp_recursive_device_object_enumerator.cc |
| +++ b/chrome/browser/media_gallery/linux/mtp_recursive_device_object_enumerator.cc |
| @@ -19,8 +19,6 @@ MTPRecursiveDeviceObjectEnumerator::MTPRecursiveDeviceObjectEnumerator( |
| base::WaitableEvent* shutdown_event) |
| : device_handle_(handle), |
| media_task_runner_(task_runner), |
| - file_entries_(entries), |
| - file_entry_iter_(file_entries_.begin()), |
| on_task_completed_event_(task_completed_event), |
| on_shutdown_event_(shutdown_event) { |
| DCHECK(on_task_completed_event_); |
| @@ -37,29 +35,17 @@ FilePath MTPRecursiveDeviceObjectEnumerator::Next() { |
| return FilePath(); |
| } |
| - FilePath path = current_enumerator_->Next(); |
| - if (!path.empty()) |
| - return path; |
| + if (!static_cast<MTPDeviceObjectEnumerator*>( |
| + current_enumerator_.get())->HasMoreEntries()) |
|
Lei Zhang
2013/01/11 23:25:24
If you call Next() after you reach the end, you ar
kmadhusu
2013/01/11 23:52:45
If current_enumerator is set to EmptyFileEnumerato
Lei Zhang
2013/01/12 00:08:35
It should never happen, but it can happen. If it d
|
| + UpdateEnumeratorToTraverseSubdirectory(); |
| - // We reached the end. |
| - if (file_entry_iter_ == file_entries_.end()) |
| - return FilePath(); |
| - |
| - // Enumerate subdirectories of the next media file entry. |
| - MtpFileEntry next_file_entry = *file_entry_iter_; |
| - ++file_entry_iter_; |
| - |
| - // Create a MTPReadDirectoryWorker object to enumerate sub directories. |
| - scoped_refptr<MTPReadDirectoryWorker> worker(new MTPReadDirectoryWorker( |
| - device_handle_, next_file_entry.item_id(), media_task_runner_, |
| - on_task_completed_event_, on_shutdown_event_)); |
| - worker->Run(); |
| - if (!worker->get_file_entries().empty()) { |
| - current_enumerator_.reset( |
| - new MTPDeviceObjectEnumerator(worker->get_file_entries())); |
| - } else { |
| - current_enumerator_.reset( |
| - new fileapi::FileSystemFileUtil::EmptyFileEnumerator()); |
| + if (IsDirectory()) { |
| + // If the current entry is a directory, add it to |
| + // |untraversed_directory_entry_ids_| to scan after scanning this directory. |
| + DirectoryEntryId dir_entry_id; |
| + if (static_cast<MTPDeviceObjectEnumerator*>( |
| + current_enumerator_.get())->GetEntryId(&dir_entry_id)) |
| + untraversed_directory_entry_ids_.push(dir_entry_id); |
| } |
| return current_enumerator_->Next(); |
| } |
| @@ -76,4 +62,30 @@ base::Time MTPRecursiveDeviceObjectEnumerator::LastModifiedTime() { |
| return current_enumerator_->LastModifiedTime(); |
| } |
| +void MTPRecursiveDeviceObjectEnumerator:: |
| +UpdateEnumeratorToTraverseSubdirectory() { |
| + bool has_more_entries = false; |
| + while (!untraversed_directory_entry_ids_.empty()) { |
| + // Create a MTPReadDirectoryWorker object to enumerate sub directories. |
| + DirectoryEntryId dir_entry_id = untraversed_directory_entry_ids_.front(); |
| + untraversed_directory_entry_ids_.pop(); |
| + scoped_refptr<MTPReadDirectoryWorker> worker(new MTPReadDirectoryWorker( |
| + device_handle_, dir_entry_id, media_task_runner_, |
| + on_task_completed_event_, on_shutdown_event_)); |
| + worker->Run(); |
| + if (!worker->get_file_entries().empty()) { |
| + current_enumerator_.reset( |
| + new MTPDeviceObjectEnumerator(worker->get_file_entries())); |
| + has_more_entries = true; |
| + break; |
|
Lei Zhang
2013/01/11 23:25:24
you can just return here and get rid of |has_more
kmadhusu
2013/01/11 23:52:45
Done.
|
| + } |
| + } |
| + |
| + if (!has_more_entries) { |
| + // Reached the end. Traversed all the sub directories. |
| + current_enumerator_.reset( |
| + new fileapi::FileSystemFileUtil::EmptyFileEnumerator()); |
| + } |
| +} |
| + |
| } // namespace chrome |