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 130 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
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_.path().AppendASCII("tmp"); |
150 ASSERT_TRUE(base::CreateDirectory(temp_file_dir)); | 150 ASSERT_TRUE(base::CreateDirectory(temp_file_dir)); |
151 file_task_runner_ = content::BrowserThread::GetMessageLoopProxyForThread( | 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. |
160 file_system_->sync_client_for_testing()->set_delay_for_testing( | 160 file_system_->sync_client_for_testing()->set_delay_for_testing( |
161 base::TimeDelta::FromSeconds(0)); | 161 base::TimeDelta::FromSeconds(0)); |
(...skipping 902 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 |