| 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 <stddef.h> | 5 #include <stddef.h> |
| 6 #include <stdint.h> | 6 #include <stdint.h> |
| 7 #include <algorithm> | 7 #include <algorithm> |
| 8 #include <stack> | 8 #include <stack> |
| 9 #include <utility> | 9 #include <utility> |
| 10 | 10 |
| (...skipping 67 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 78 DriveBackendSyncTest() | 78 DriveBackendSyncTest() |
| 79 : thread_bundle_(content::TestBrowserThreadBundle::IO_MAINLOOP), | 79 : thread_bundle_(content::TestBrowserThreadBundle::IO_MAINLOOP), |
| 80 pending_remote_changes_(0), | 80 pending_remote_changes_(0), |
| 81 pending_local_changes_(0) {} | 81 pending_local_changes_(0) {} |
| 82 ~DriveBackendSyncTest() override {} | 82 ~DriveBackendSyncTest() override {} |
| 83 | 83 |
| 84 void SetUp() override { | 84 void SetUp() override { |
| 85 ASSERT_TRUE(base_dir_.CreateUniqueTempDir()); | 85 ASSERT_TRUE(base_dir_.CreateUniqueTempDir()); |
| 86 in_memory_env_.reset(leveldb::NewMemEnv(leveldb::Env::Default())); | 86 in_memory_env_.reset(leveldb::NewMemEnv(leveldb::Env::Default())); |
| 87 | 87 |
| 88 io_task_runner_ = content::BrowserThread::GetMessageLoopProxyForThread( | 88 io_task_runner_ = content::BrowserThread::GetTaskRunnerForThread( |
| 89 content::BrowserThread::IO); | 89 content::BrowserThread::IO); |
| 90 scoped_refptr<base::SequencedWorkerPool> worker_pool( | 90 scoped_refptr<base::SequencedWorkerPool> worker_pool( |
| 91 content::BrowserThread::GetBlockingPool()); | 91 content::BrowserThread::GetBlockingPool()); |
| 92 worker_task_runner_ = | 92 worker_task_runner_ = |
| 93 worker_pool->GetSequencedTaskRunnerWithShutdownBehavior( | 93 worker_pool->GetSequencedTaskRunnerWithShutdownBehavior( |
| 94 worker_pool->GetSequenceToken(), | 94 worker_pool->GetSequenceToken(), |
| 95 base::SequencedWorkerPool::SKIP_ON_SHUTDOWN); | 95 base::SequencedWorkerPool::SKIP_ON_SHUTDOWN); |
| 96 file_task_runner_ = content::BrowserThread::GetMessageLoopProxyForThread( | 96 file_task_runner_ = content::BrowserThread::GetTaskRunnerForThread( |
| 97 content::BrowserThread::FILE); | 97 content::BrowserThread::FILE); |
| 98 scoped_refptr<base::SequencedTaskRunner> drive_task_runner = | 98 scoped_refptr<base::SequencedTaskRunner> drive_task_runner = |
| 99 worker_pool->GetSequencedTaskRunnerWithShutdownBehavior( | 99 worker_pool->GetSequencedTaskRunnerWithShutdownBehavior( |
| 100 worker_pool->GetSequenceToken(), | 100 worker_pool->GetSequenceToken(), |
| 101 base::SequencedWorkerPool::SKIP_ON_SHUTDOWN); | 101 base::SequencedWorkerPool::SKIP_ON_SHUTDOWN); |
| 102 | 102 |
| 103 RegisterSyncableFileSystem(); | 103 RegisterSyncableFileSystem(); |
| 104 local_sync_service_ = LocalFileSyncService::CreateForTesting( | 104 local_sync_service_ = LocalFileSyncService::CreateForTesting( |
| 105 &profile_, in_memory_env_.get()); | 105 &profile_, in_memory_env_.get()); |
| 106 local_sync_service_->AddChangeObserver(this); | 106 local_sync_service_->AddChangeObserver(this); |
| (...skipping 1616 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1723 | 1723 |
| 1724 EXPECT_EQ(1u, CountApp()); | 1724 EXPECT_EQ(1u, CountApp()); |
| 1725 EXPECT_EQ(1u, CountLocalFile(app_id)); | 1725 EXPECT_EQ(1u, CountLocalFile(app_id)); |
| 1726 | 1726 |
| 1727 EXPECT_EQ(2u, CountMetadata()); | 1727 EXPECT_EQ(2u, CountMetadata()); |
| 1728 EXPECT_EQ(2u, CountTracker()); | 1728 EXPECT_EQ(2u, CountTracker()); |
| 1729 } | 1729 } |
| 1730 | 1730 |
| 1731 } // namespace drive_backend | 1731 } // namespace drive_backend |
| 1732 } // namespace sync_file_system | 1732 } // namespace sync_file_system |
| OLD | NEW |