OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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/chromeos/file_system.h" | 5 #include "components/drive/chromeos/file_system.h" |
6 | 6 |
7 #include <stddef.h> | 7 #include <stddef.h> |
8 #include <stdint.h> | 8 #include <stdint.h> |
9 | 9 |
10 #include <memory> | 10 #include <memory> |
(...skipping 108 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
119 logger_.get(), | 119 logger_.get(), |
120 fake_drive_service_.get(), | 120 fake_drive_service_.get(), |
121 base::ThreadTaskRunnerHandle::Get().get())); | 121 base::ThreadTaskRunnerHandle::Get().get())); |
122 | 122 |
123 mock_directory_observer_.reset(new MockDirectoryChangeObserver); | 123 mock_directory_observer_.reset(new MockDirectoryChangeObserver); |
124 | 124 |
125 SetUpResourceMetadataAndFileSystem(); | 125 SetUpResourceMetadataAndFileSystem(); |
126 } | 126 } |
127 | 127 |
128 void SetUpResourceMetadataAndFileSystem() { | 128 void SetUpResourceMetadataAndFileSystem() { |
129 const base::FilePath metadata_dir = temp_dir_.path().AppendASCII("meta"); | 129 const base::FilePath metadata_dir = temp_dir_.GetPath().AppendASCII("meta"); |
130 ASSERT_TRUE(base::CreateDirectory(metadata_dir)); | 130 ASSERT_TRUE(base::CreateDirectory(metadata_dir)); |
131 metadata_storage_.reset(new internal::ResourceMetadataStorage( | 131 metadata_storage_.reset(new internal::ResourceMetadataStorage( |
132 metadata_dir, base::ThreadTaskRunnerHandle::Get().get())); | 132 metadata_dir, base::ThreadTaskRunnerHandle::Get().get())); |
133 ASSERT_TRUE(metadata_storage_->Initialize()); | 133 ASSERT_TRUE(metadata_storage_->Initialize()); |
134 | 134 |
135 const base::FilePath cache_dir = temp_dir_.path().AppendASCII("files"); | 135 const base::FilePath cache_dir = temp_dir_.GetPath().AppendASCII("files"); |
136 ASSERT_TRUE(base::CreateDirectory(cache_dir)); | 136 ASSERT_TRUE(base::CreateDirectory(cache_dir)); |
137 cache_.reset(new internal::FileCache( | 137 cache_.reset(new internal::FileCache( |
138 metadata_storage_.get(), | 138 metadata_storage_.get(), |
139 cache_dir, | 139 cache_dir, |
140 base::ThreadTaskRunnerHandle::Get().get(), | 140 base::ThreadTaskRunnerHandle::Get().get(), |
141 fake_free_disk_space_getter_.get())); | 141 fake_free_disk_space_getter_.get())); |
142 ASSERT_TRUE(cache_->Initialize()); | 142 ASSERT_TRUE(cache_->Initialize()); |
143 | 143 |
144 resource_metadata_.reset(new internal::ResourceMetadata( | 144 resource_metadata_.reset(new internal::ResourceMetadata( |
145 metadata_storage_.get(), cache_.get(), | 145 metadata_storage_.get(), cache_.get(), |
146 base::ThreadTaskRunnerHandle::Get())); | 146 base::ThreadTaskRunnerHandle::Get())); |
147 ASSERT_EQ(FILE_ERROR_OK, resource_metadata_->Initialize()); | 147 ASSERT_EQ(FILE_ERROR_OK, resource_metadata_->Initialize()); |
148 | 148 |
149 const base::FilePath temp_file_dir = temp_dir_.path().AppendASCII("tmp"); | 149 const base::FilePath temp_file_dir = temp_dir_.GetPath().AppendASCII("tmp"); |
150 ASSERT_TRUE(base::CreateDirectory(temp_file_dir)); | 150 ASSERT_TRUE(base::CreateDirectory(temp_file_dir)); |
151 file_task_runner_ = content::BrowserThread::GetTaskRunnerForThread( | 151 file_task_runner_ = content::BrowserThread::GetTaskRunnerForThread( |
152 content::BrowserThread::FILE); | 152 content::BrowserThread::FILE); |
153 file_system_.reset(new FileSystem( | 153 file_system_.reset(new FileSystem( |
154 pref_service_.get(), logger_.get(), cache_.get(), scheduler_.get(), | 154 pref_service_.get(), logger_.get(), cache_.get(), scheduler_.get(), |
155 resource_metadata_.get(), base::ThreadTaskRunnerHandle::Get().get(), | 155 resource_metadata_.get(), base::ThreadTaskRunnerHandle::Get().get(), |
156 file_task_runner_.get(), temp_file_dir)); | 156 file_task_runner_.get(), temp_file_dir)); |
157 file_system_->AddObserver(mock_directory_observer_.get()); | 157 file_system_->AddObserver(mock_directory_observer_.get()); |
158 | 158 |
159 // Disable delaying so that the sync starts immediately. | 159 // Disable delaying so that the sync starts immediately. |
(...skipping 59 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
219 | 219 |
220 // Sets up a filesystem with directories: drive/root, drive/root/Dir1, | 220 // Sets up a filesystem with directories: drive/root, drive/root/Dir1, |
221 // drive/root/Dir1/SubDir2 and files drive/root/File1, drive/root/Dir1/File2, | 221 // drive/root/Dir1/SubDir2 and files drive/root/File1, drive/root/Dir1/File2, |
222 // drive/root/Dir1/SubDir2/File3. If |use_up_to_date_timestamp| is true, sets | 222 // drive/root/Dir1/SubDir2/File3. If |use_up_to_date_timestamp| is true, sets |
223 // the changestamp to that of FakeDriveService, indicating the cache is | 223 // the changestamp to that of FakeDriveService, indicating the cache is |
224 // holding the latest file system info. | 224 // holding the latest file system info. |
225 void SetUpTestFileSystem(SetUpTestFileSystemParam param) { | 225 void SetUpTestFileSystem(SetUpTestFileSystemParam param) { |
226 // Destroy the existing resource metadata to close DB. | 226 // Destroy the existing resource metadata to close DB. |
227 resource_metadata_.reset(); | 227 resource_metadata_.reset(); |
228 | 228 |
229 const base::FilePath metadata_dir = temp_dir_.path().AppendASCII("meta"); | 229 const base::FilePath metadata_dir = temp_dir_.GetPath().AppendASCII("meta"); |
230 ASSERT_TRUE(base::CreateDirectory(metadata_dir)); | 230 ASSERT_TRUE(base::CreateDirectory(metadata_dir)); |
231 std::unique_ptr<internal::ResourceMetadataStorage, | 231 std::unique_ptr<internal::ResourceMetadataStorage, |
232 test_util::DestroyHelperForTests> | 232 test_util::DestroyHelperForTests> |
233 metadata_storage(new internal::ResourceMetadataStorage( | 233 metadata_storage(new internal::ResourceMetadataStorage( |
234 metadata_dir, base::ThreadTaskRunnerHandle::Get().get())); | 234 metadata_dir, base::ThreadTaskRunnerHandle::Get().get())); |
235 | 235 |
236 const base::FilePath cache_dir = temp_dir_.path().AppendASCII("files"); | 236 const base::FilePath cache_dir = temp_dir_.GetPath().AppendASCII("files"); |
237 std::unique_ptr<internal::FileCache, test_util::DestroyHelperForTests> | 237 std::unique_ptr<internal::FileCache, test_util::DestroyHelperForTests> |
238 cache(new internal::FileCache(metadata_storage.get(), cache_dir, | 238 cache(new internal::FileCache(metadata_storage.get(), cache_dir, |
239 base::ThreadTaskRunnerHandle::Get().get(), | 239 base::ThreadTaskRunnerHandle::Get().get(), |
240 fake_free_disk_space_getter_.get())); | 240 fake_free_disk_space_getter_.get())); |
241 | 241 |
242 std::unique_ptr<internal::ResourceMetadata, | 242 std::unique_ptr<internal::ResourceMetadata, |
243 test_util::DestroyHelperForTests> | 243 test_util::DestroyHelperForTests> |
244 resource_metadata(new internal::ResourceMetadata( | 244 resource_metadata(new internal::ResourceMetadata( |
245 metadata_storage_.get(), cache.get(), | 245 metadata_storage_.get(), cache.get(), |
246 base::ThreadTaskRunnerHandle::Get())); | 246 base::ThreadTaskRunnerHandle::Get())); |
(...skipping 817 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1064 google_apis::test_util::CreateCopyResultCallback(&available)); | 1064 google_apis::test_util::CreateCopyResultCallback(&available)); |
1065 content::RunAllBlockingPoolTasksUntilIdle(); | 1065 content::RunAllBlockingPoolTasksUntilIdle(); |
1066 ASSERT_FALSE(available); | 1066 ASSERT_FALSE(available); |
1067 | 1067 |
1068 entry = GetResourceEntrySync(file_in_root); | 1068 entry = GetResourceEntrySync(file_in_root); |
1069 ASSERT_TRUE(entry); | 1069 ASSERT_TRUE(entry); |
1070 EXPECT_FALSE(entry->file_specific_info().cache_state().is_present()); | 1070 EXPECT_FALSE(entry->file_specific_info().cache_state().is_present()); |
1071 } | 1071 } |
1072 | 1072 |
1073 } // namespace drive | 1073 } // namespace drive |
OLD | NEW |