| 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 |