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 |