| 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/sync_client.h" | 5 #include "components/drive/chromeos/sync_client.h" |
| 6 | 6 |
| 7 #include <memory> | 7 #include <memory> |
| 8 | 8 |
| 9 #include "base/files/file_path.h" | 9 #include "base/files/file_path.h" |
| 10 #include "base/files/file_util.h" | 10 #include "base/files/file_util.h" |
| (...skipping 105 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 116 | 116 |
| 117 drive_service_.reset(new SyncClientTestDriveService); | 117 drive_service_.reset(new SyncClientTestDriveService); |
| 118 | 118 |
| 119 scheduler_.reset(new JobScheduler( | 119 scheduler_.reset(new JobScheduler( |
| 120 pref_service_.get(), | 120 pref_service_.get(), |
| 121 logger_.get(), | 121 logger_.get(), |
| 122 drive_service_.get(), | 122 drive_service_.get(), |
| 123 base::ThreadTaskRunnerHandle::Get().get())); | 123 base::ThreadTaskRunnerHandle::Get().get())); |
| 124 | 124 |
| 125 metadata_storage_.reset(new ResourceMetadataStorage( | 125 metadata_storage_.reset(new ResourceMetadataStorage( |
| 126 temp_dir_.path(), base::ThreadTaskRunnerHandle::Get().get())); | 126 temp_dir_.GetPath(), base::ThreadTaskRunnerHandle::Get().get())); |
| 127 ASSERT_TRUE(metadata_storage_->Initialize()); | 127 ASSERT_TRUE(metadata_storage_->Initialize()); |
| 128 | 128 |
| 129 cache_.reset(new FileCache(metadata_storage_.get(), | 129 cache_.reset(new FileCache(metadata_storage_.get(), temp_dir_.GetPath(), |
| 130 temp_dir_.path(), | |
| 131 base::ThreadTaskRunnerHandle::Get().get(), | 130 base::ThreadTaskRunnerHandle::Get().get(), |
| 132 NULL /* free_disk_space_getter */)); | 131 NULL /* free_disk_space_getter */)); |
| 133 ASSERT_TRUE(cache_->Initialize()); | 132 ASSERT_TRUE(cache_->Initialize()); |
| 134 | 133 |
| 135 metadata_.reset(new internal::ResourceMetadata( | 134 metadata_.reset(new internal::ResourceMetadata( |
| 136 metadata_storage_.get(), cache_.get(), | 135 metadata_storage_.get(), cache_.get(), |
| 137 base::ThreadTaskRunnerHandle::Get())); | 136 base::ThreadTaskRunnerHandle::Get())); |
| 138 ASSERT_EQ(FILE_ERROR_OK, metadata_->Initialize()); | 137 ASSERT_EQ(FILE_ERROR_OK, metadata_->Initialize()); |
| 139 | 138 |
| 140 about_resource_loader_.reset(new AboutResourceLoader(scheduler_.get())); | 139 about_resource_loader_.reset(new AboutResourceLoader(scheduler_.get())); |
| 141 loader_controller_.reset(new LoaderController); | 140 loader_controller_.reset(new LoaderController); |
| 142 change_list_loader_.reset(new ChangeListLoader( | 141 change_list_loader_.reset(new ChangeListLoader( |
| 143 logger_.get(), | 142 logger_.get(), |
| 144 base::ThreadTaskRunnerHandle::Get().get(), | 143 base::ThreadTaskRunnerHandle::Get().get(), |
| 145 metadata_.get(), | 144 metadata_.get(), |
| 146 scheduler_.get(), | 145 scheduler_.get(), |
| 147 about_resource_loader_.get(), | 146 about_resource_loader_.get(), |
| 148 loader_controller_.get())); | 147 loader_controller_.get())); |
| 149 ASSERT_NO_FATAL_FAILURE(SetUpTestData()); | 148 ASSERT_NO_FATAL_FAILURE(SetUpTestData()); |
| 150 | 149 |
| 151 sync_client_.reset(new SyncClient(base::ThreadTaskRunnerHandle::Get().get(), | 150 sync_client_.reset( |
| 152 &delegate_, | 151 new SyncClient(base::ThreadTaskRunnerHandle::Get().get(), &delegate_, |
| 153 scheduler_.get(), | 152 scheduler_.get(), metadata_.get(), cache_.get(), |
| 154 metadata_.get(), | 153 loader_controller_.get(), temp_dir_.GetPath())); |
| 155 cache_.get(), | |
| 156 loader_controller_.get(), | |
| 157 temp_dir_.path())); | |
| 158 | 154 |
| 159 // Disable delaying so that DoSyncLoop() starts immediately. | 155 // Disable delaying so that DoSyncLoop() starts immediately. |
| 160 sync_client_->set_delay_for_testing(base::TimeDelta::FromSeconds(0)); | 156 sync_client_->set_delay_for_testing(base::TimeDelta::FromSeconds(0)); |
| 161 } | 157 } |
| 162 | 158 |
| 163 // Adds a file to the service root and |resource_ids_|. | 159 // Adds a file to the service root and |resource_ids_|. |
| 164 void AddFileEntry(const std::string& title) { | 160 void AddFileEntry(const std::string& title) { |
| 165 google_apis::DriveApiErrorCode error = google_apis::DRIVE_FILE_ERROR; | 161 google_apis::DriveApiErrorCode error = google_apis::DRIVE_FILE_ERROR; |
| 166 std::unique_ptr<google_apis::FileResource> entry; | 162 std::unique_ptr<google_apis::FileResource> entry; |
| 167 drive_service_->AddNewFile( | 163 drive_service_->AddNewFile( |
| 168 "text/plain", | 164 "text/plain", |
| 169 kRemoteContent, | 165 kRemoteContent, |
| 170 drive_service_->GetRootResourceId(), | 166 drive_service_->GetRootResourceId(), |
| 171 title, | 167 title, |
| 172 false, // shared_with_me | 168 false, // shared_with_me |
| 173 google_apis::test_util::CreateCopyResultCallback(&error, &entry)); | 169 google_apis::test_util::CreateCopyResultCallback(&error, &entry)); |
| 174 base::RunLoop().RunUntilIdle(); | 170 base::RunLoop().RunUntilIdle(); |
| 175 ASSERT_EQ(google_apis::HTTP_CREATED, error); | 171 ASSERT_EQ(google_apis::HTTP_CREATED, error); |
| 176 ASSERT_TRUE(entry); | 172 ASSERT_TRUE(entry); |
| 177 resource_ids_[title] = entry->file_id(); | 173 resource_ids_[title] = entry->file_id(); |
| 178 } | 174 } |
| 179 | 175 |
| 180 // Sets up data for tests. | 176 // Sets up data for tests. |
| 181 void SetUpTestData() { | 177 void SetUpTestData() { |
| 182 // Prepare a temp file. | 178 // Prepare a temp file. |
| 183 base::FilePath temp_file; | 179 base::FilePath temp_file; |
| 184 EXPECT_TRUE(base::CreateTemporaryFileInDir(temp_dir_.path(), &temp_file)); | 180 EXPECT_TRUE( |
| 181 base::CreateTemporaryFileInDir(temp_dir_.GetPath(), &temp_file)); |
| 185 ASSERT_TRUE(google_apis::test_util::WriteStringToFile(temp_file, | 182 ASSERT_TRUE(google_apis::test_util::WriteStringToFile(temp_file, |
| 186 kLocalContent)); | 183 kLocalContent)); |
| 187 | 184 |
| 188 // Add file entries to the service. | 185 // Add file entries to the service. |
| 189 ASSERT_NO_FATAL_FAILURE(AddFileEntry("foo")); | 186 ASSERT_NO_FATAL_FAILURE(AddFileEntry("foo")); |
| 190 ASSERT_NO_FATAL_FAILURE(AddFileEntry("bar")); | 187 ASSERT_NO_FATAL_FAILURE(AddFileEntry("bar")); |
| 191 ASSERT_NO_FATAL_FAILURE(AddFileEntry("baz")); | 188 ASSERT_NO_FATAL_FAILURE(AddFileEntry("baz")); |
| 192 ASSERT_NO_FATAL_FAILURE(AddFileEntry("fetched")); | 189 ASSERT_NO_FATAL_FAILURE(AddFileEntry("fetched")); |
| 193 ASSERT_NO_FATAL_FAILURE(AddFileEntry("dirty")); | 190 ASSERT_NO_FATAL_FAILURE(AddFileEntry("dirty")); |
| 194 ASSERT_NO_FATAL_FAILURE(AddFileEntry("removed")); | 191 ASSERT_NO_FATAL_FAILURE(AddFileEntry("removed")); |
| (...skipping 320 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 515 local_id, google_apis::test_util::CreateCopyResultCallback(&error))); | 512 local_id, google_apis::test_util::CreateCopyResultCallback(&error))); |
| 516 | 513 |
| 517 base::RunLoop().RunUntilIdle(); | 514 base::RunLoop().RunUntilIdle(); |
| 518 | 515 |
| 519 // The callback is called. | 516 // The callback is called. |
| 520 EXPECT_EQ(FILE_ERROR_OK, error); | 517 EXPECT_EQ(FILE_ERROR_OK, error); |
| 521 } | 518 } |
| 522 | 519 |
| 523 } // namespace internal | 520 } // namespace internal |
| 524 } // namespace drive | 521 } // namespace drive |
| OLD | NEW |