| 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/sync_file_system/drive_backend/list_changes_task.h" | 5 #include "chrome/browser/sync_file_system/drive_backend/list_changes_task.h" |
| 6 | 6 |
| 7 #include <string> | 7 #include <string> |
| 8 | 8 |
| 9 #include "base/files/scoped_temp_dir.h" | 9 #include "base/files/scoped_temp_dir.h" |
| 10 #include "base/format_macros.h" | 10 #include "base/format_macros.h" |
| (...skipping 24 matching lines...) Expand all Loading... |
| 35 | 35 |
| 36 class ListChangesTaskTest : public testing::Test { | 36 class ListChangesTaskTest : public testing::Test { |
| 37 public: | 37 public: |
| 38 ListChangesTaskTest() {} | 38 ListChangesTaskTest() {} |
| 39 virtual ~ListChangesTaskTest() {} | 39 virtual ~ListChangesTaskTest() {} |
| 40 | 40 |
| 41 virtual void SetUp() OVERRIDE { | 41 virtual void SetUp() OVERRIDE { |
| 42 ASSERT_TRUE(database_dir_.CreateUniqueTempDir()); | 42 ASSERT_TRUE(database_dir_.CreateUniqueTempDir()); |
| 43 in_memory_env_.reset(leveldb::NewMemEnv(leveldb::Env::Default())); | 43 in_memory_env_.reset(leveldb::NewMemEnv(leveldb::Env::Default())); |
| 44 | 44 |
| 45 fake_drive_service_.reset(new drive::FakeDriveService); | 45 scoped_ptr<drive::FakeDriveService> |
| 46 fake_drive_service(new drive::FakeDriveService); |
| 46 | 47 |
| 47 drive_uploader_.reset( | 48 drive_uploader_.reset( |
| 48 new drive::DriveUploader(fake_drive_service_.get(), | 49 new drive::DriveUploader(fake_drive_service.get(), |
| 49 base::MessageLoopProxy::current())); | 50 base::MessageLoopProxy::current())); |
| 50 | 51 |
| 51 fake_drive_service_helper_.reset( | 52 fake_drive_service_helper_.reset( |
| 52 new FakeDriveServiceHelper(fake_drive_service_.get(), | 53 new FakeDriveServiceHelper(fake_drive_service.get(), |
| 53 drive_uploader_.get(), | 54 drive_uploader_.get(), |
| 54 kSyncRootFolderTitle)); | 55 kSyncRootFolderTitle)); |
| 55 | 56 |
| 56 sync_task_manager_.reset(new SyncTaskManager( | 57 sync_task_manager_.reset(new SyncTaskManager( |
| 57 base::WeakPtr<SyncTaskManager::Client>(), | 58 base::WeakPtr<SyncTaskManager::Client>(), |
| 58 10 /* maximum_background_task */)); | 59 10 /* maximum_background_task */)); |
| 59 sync_task_manager_->Initialize(SYNC_STATUS_OK); | 60 sync_task_manager_->Initialize(SYNC_STATUS_OK); |
| 60 | 61 |
| 61 context_.reset( | 62 context_.reset(new SyncEngineContext( |
| 62 new SyncEngineContext(fake_drive_service_.get(), | 63 fake_drive_service.PassAs<drive::DriveServiceInterface>(), |
| 63 drive_uploader_.get(), | 64 drive_uploader_.get(), |
| 64 base::MessageLoopProxy::current(), | 65 base::MessageLoopProxy::current(), |
| 65 base::MessageLoopProxy::current())); | 66 base::MessageLoopProxy::current())); |
| 66 | 67 |
| 67 SetUpRemoteFolders(); | 68 SetUpRemoteFolders(); |
| 68 | 69 |
| 69 InitializeMetadataDatabase(); | 70 InitializeMetadataDatabase(); |
| 70 RegisterApp(kAppID); | 71 RegisterApp(kAppID); |
| 71 } | 72 } |
| 72 | 73 |
| 73 virtual void TearDown() OVERRIDE { | 74 virtual void TearDown() OVERRIDE { |
| 74 sync_task_manager_.reset(); | 75 sync_task_manager_.reset(); |
| 75 context_.reset(); | 76 context_.reset(); |
| 76 fake_drive_service_.reset(); | |
| 77 drive_uploader_.reset(); | 77 drive_uploader_.reset(); |
| 78 base::RunLoop().RunUntilIdle(); | 78 base::RunLoop().RunUntilIdle(); |
| 79 } | 79 } |
| 80 | 80 |
| 81 protected: | 81 protected: |
| 82 SyncStatusCode RunTask(scoped_ptr<SyncTask> sync_task) { | 82 SyncStatusCode RunTask(scoped_ptr<SyncTask> sync_task) { |
| 83 SyncStatusCode status = SYNC_STATUS_UNKNOWN; | 83 SyncStatusCode status = SYNC_STATUS_UNKNOWN; |
| 84 sync_task_manager_->ScheduleSyncTask( | 84 sync_task_manager_->ScheduleSyncTask( |
| 85 FROM_HERE, sync_task.Pass(), | 85 FROM_HERE, sync_task.Pass(), |
| 86 SyncTaskManager::PRIORITY_MED, | 86 SyncTaskManager::PRIORITY_MED, |
| (...skipping 110 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 197 scoped_ptr<leveldb::Env> in_memory_env_; | 197 scoped_ptr<leveldb::Env> in_memory_env_; |
| 198 | 198 |
| 199 std::string sync_root_folder_id_; | 199 std::string sync_root_folder_id_; |
| 200 std::string app_root_folder_id_; | 200 std::string app_root_folder_id_; |
| 201 std::string unregistered_app_root_folder_id_; | 201 std::string unregistered_app_root_folder_id_; |
| 202 | 202 |
| 203 content::TestBrowserThreadBundle browser_threads_; | 203 content::TestBrowserThreadBundle browser_threads_; |
| 204 base::ScopedTempDir database_dir_; | 204 base::ScopedTempDir database_dir_; |
| 205 | 205 |
| 206 scoped_ptr<SyncEngineContext> context_; | 206 scoped_ptr<SyncEngineContext> context_; |
| 207 scoped_ptr<drive::FakeDriveService> fake_drive_service_; | |
| 208 scoped_ptr<drive::DriveUploaderInterface> drive_uploader_; | 207 scoped_ptr<drive::DriveUploaderInterface> drive_uploader_; |
| 209 scoped_ptr<FakeDriveServiceHelper> fake_drive_service_helper_; | 208 scoped_ptr<FakeDriveServiceHelper> fake_drive_service_helper_; |
| 210 | 209 |
| 211 scoped_ptr<SyncTaskManager> sync_task_manager_; | 210 scoped_ptr<SyncTaskManager> sync_task_manager_; |
| 212 | 211 |
| 213 DISALLOW_COPY_AND_ASSIGN(ListChangesTaskTest); | 212 DISALLOW_COPY_AND_ASSIGN(ListChangesTaskTest); |
| 214 }; | 213 }; |
| 215 | 214 |
| 216 TEST_F(ListChangesTaskTest, NoChange) { | 215 TEST_F(ListChangesTaskTest, NoChange) { |
| 217 size_t num_dirty_trackers = CountDirtyTracker(); | 216 size_t num_dirty_trackers = CountDirtyTracker(); |
| (...skipping 22 matching lines...) Expand all Loading... |
| 240 SetUpChangesInFolder(app_root_folder_id()); | 239 SetUpChangesInFolder(app_root_folder_id()); |
| 241 | 240 |
| 242 EXPECT_EQ(SYNC_STATUS_OK, RunTask( | 241 EXPECT_EQ(SYNC_STATUS_OK, RunTask( |
| 243 scoped_ptr<SyncTask>(new ListChangesTask(GetSyncEngineContext())))); | 242 scoped_ptr<SyncTask>(new ListChangesTask(GetSyncEngineContext())))); |
| 244 | 243 |
| 245 EXPECT_EQ(num_dirty_trackers + 4, CountDirtyTracker()); | 244 EXPECT_EQ(num_dirty_trackers + 4, CountDirtyTracker()); |
| 246 } | 245 } |
| 247 | 246 |
| 248 } // namespace drive_backend | 247 } // namespace drive_backend |
| 249 } // namespace sync_file_system | 248 } // namespace sync_file_system |
| OLD | NEW |