| Index: chrome/browser/chromeos/drive/file_system/operation_test_base.cc
|
| diff --git a/chrome/browser/chromeos/drive/file_system/operation_test_base.cc b/chrome/browser/chromeos/drive/file_system/operation_test_base.cc
|
| deleted file mode 100644
|
| index 2597de098e031558fc56fb94389a7898aab71468..0000000000000000000000000000000000000000
|
| --- a/chrome/browser/chromeos/drive/file_system/operation_test_base.cc
|
| +++ /dev/null
|
| @@ -1,195 +0,0 @@
|
| -// Copyright 2013 The Chromium Authors. All rights reserved.
|
| -// Use of this source code is governed by a BSD-style license that can be
|
| -// found in the LICENSE file.
|
| -
|
| -#include "chrome/browser/chromeos/drive/file_system/operation_test_base.h"
|
| -
|
| -#include "base/prefs/testing_pref_service.h"
|
| -#include "base/threading/sequenced_worker_pool.h"
|
| -#include "chrome/browser/chromeos/drive/change_list_loader.h"
|
| -#include "chrome/browser/chromeos/drive/fake_free_disk_space_getter.h"
|
| -#include "chrome/browser/chromeos/drive/file_cache.h"
|
| -#include "chrome/browser/chromeos/drive/file_change.h"
|
| -#include "chrome/browser/chromeos/drive/file_system/operation_delegate.h"
|
| -#include "chrome/browser/chromeos/drive/job_scheduler.h"
|
| -#include "chrome/browser/chromeos/drive/resource_metadata.h"
|
| -#include "components/drive/event_logger.h"
|
| -#include "components/drive/service/fake_drive_service.h"
|
| -#include "components/drive/service/test_util.h"
|
| -#include "content/public/browser/browser_thread.h"
|
| -#include "content/public/test/test_utils.h"
|
| -#include "google_apis/drive/test_util.h"
|
| -
|
| -namespace drive {
|
| -namespace file_system {
|
| -
|
| -OperationTestBase::LoggingDelegate::LoggingDelegate() {
|
| -}
|
| -
|
| -OperationTestBase::LoggingDelegate::~LoggingDelegate() {
|
| -}
|
| -
|
| -void OperationTestBase::LoggingDelegate::OnFileChangedByOperation(
|
| - const FileChange& changed_files) {
|
| - changed_files_.Apply(changed_files);
|
| -}
|
| -
|
| -void OperationTestBase::LoggingDelegate::OnEntryUpdatedByOperation(
|
| - const ClientContext& /* client_context */,
|
| - const std::string& local_id) {
|
| - updated_local_ids_.insert(local_id);
|
| -}
|
| -
|
| -void OperationTestBase::LoggingDelegate::OnDriveSyncError(
|
| - DriveSyncErrorType type, const std::string& local_id) {
|
| - drive_sync_errors_.push_back(type);
|
| -}
|
| -
|
| -bool OperationTestBase::LoggingDelegate::WaitForSyncComplete(
|
| - const std::string& local_id,
|
| - const FileOperationCallback& callback) {
|
| - return wait_for_sync_complete_handler_.is_null() ?
|
| - false : wait_for_sync_complete_handler_.Run(local_id, callback);
|
| -}
|
| -
|
| -OperationTestBase::OperationTestBase() {
|
| -}
|
| -
|
| -OperationTestBase::OperationTestBase(int test_thread_bundle_options)
|
| - : thread_bundle_(test_thread_bundle_options) {
|
| -}
|
| -
|
| -OperationTestBase::~OperationTestBase() {
|
| -}
|
| -
|
| -void OperationTestBase::SetUp() {
|
| - scoped_refptr<base::SequencedWorkerPool> pool =
|
| - content::BrowserThread::GetBlockingPool();
|
| - blocking_task_runner_ =
|
| - pool->GetSequencedTaskRunner(pool->GetSequenceToken());
|
| -
|
| - pref_service_.reset(new TestingPrefServiceSimple);
|
| - test_util::RegisterDrivePrefs(pref_service_->registry());
|
| -
|
| - ASSERT_TRUE(temp_dir_.CreateUniqueTempDir());
|
| -
|
| - logger_.reset(new EventLogger);
|
| -
|
| - fake_drive_service_.reset(new FakeDriveService);
|
| - ASSERT_TRUE(test_util::SetUpTestEntries(fake_drive_service_.get()));
|
| -
|
| - scheduler_.reset(new JobScheduler(
|
| - pref_service_.get(),
|
| - logger_.get(),
|
| - fake_drive_service_.get(),
|
| - blocking_task_runner_.get()));
|
| -
|
| - metadata_storage_.reset(new internal::ResourceMetadataStorage(
|
| - temp_dir_.path(), blocking_task_runner_.get()));
|
| - bool success = false;
|
| - base::PostTaskAndReplyWithResult(
|
| - blocking_task_runner_.get(),
|
| - FROM_HERE,
|
| - base::Bind(&internal::ResourceMetadataStorage::Initialize,
|
| - base::Unretained(metadata_storage_.get())),
|
| - google_apis::test_util::CreateCopyResultCallback(&success));
|
| - content::RunAllBlockingPoolTasksUntilIdle();
|
| - ASSERT_TRUE(success);
|
| -
|
| - fake_free_disk_space_getter_.reset(new FakeFreeDiskSpaceGetter);
|
| - cache_.reset(new internal::FileCache(metadata_storage_.get(),
|
| - temp_dir_.path(),
|
| - blocking_task_runner_.get(),
|
| - fake_free_disk_space_getter_.get()));
|
| - success = false;
|
| - base::PostTaskAndReplyWithResult(
|
| - blocking_task_runner_.get(),
|
| - FROM_HERE,
|
| - base::Bind(&internal::FileCache::Initialize,
|
| - base::Unretained(cache_.get())),
|
| - google_apis::test_util::CreateCopyResultCallback(&success));
|
| - content::RunAllBlockingPoolTasksUntilIdle();
|
| - ASSERT_TRUE(success);
|
| -
|
| - metadata_.reset(new internal::ResourceMetadata(metadata_storage_.get(),
|
| - cache_.get(),
|
| - blocking_task_runner_));
|
| -
|
| - FileError error = FILE_ERROR_FAILED;
|
| - base::PostTaskAndReplyWithResult(
|
| - blocking_task_runner_.get(),
|
| - FROM_HERE,
|
| - base::Bind(&internal::ResourceMetadata::Initialize,
|
| - base::Unretained(metadata_.get())),
|
| - google_apis::test_util::CreateCopyResultCallback(&error));
|
| - content::RunAllBlockingPoolTasksUntilIdle();
|
| - ASSERT_EQ(FILE_ERROR_OK, error);
|
| -
|
| - // Makes sure the FakeDriveService's content is loaded to the metadata_.
|
| - about_resource_loader_.reset(new internal::AboutResourceLoader(
|
| - scheduler_.get()));
|
| - loader_controller_.reset(new internal::LoaderController);
|
| - change_list_loader_.reset(new internal::ChangeListLoader(
|
| - logger_.get(),
|
| - blocking_task_runner_.get(),
|
| - metadata_.get(),
|
| - scheduler_.get(),
|
| - about_resource_loader_.get(),
|
| - loader_controller_.get()));
|
| - change_list_loader_->LoadIfNeeded(
|
| - google_apis::test_util::CreateCopyResultCallback(&error));
|
| - content::RunAllBlockingPoolTasksUntilIdle();
|
| - ASSERT_EQ(FILE_ERROR_OK, error);
|
| -}
|
| -
|
| -FileError OperationTestBase::GetLocalResourceEntry(const base::FilePath& path,
|
| - ResourceEntry* entry) {
|
| - FileError error = FILE_ERROR_FAILED;
|
| - base::PostTaskAndReplyWithResult(
|
| - blocking_task_runner(),
|
| - FROM_HERE,
|
| - base::Bind(&internal::ResourceMetadata::GetResourceEntryByPath,
|
| - base::Unretained(metadata()), path, entry),
|
| - base::Bind(google_apis::test_util::CreateCopyResultCallback(&error)));
|
| - content::RunAllBlockingPoolTasksUntilIdle();
|
| - return error;
|
| -}
|
| -
|
| -FileError OperationTestBase::GetLocalResourceEntryById(
|
| - const std::string& local_id,
|
| - ResourceEntry* entry) {
|
| - FileError error = FILE_ERROR_FAILED;
|
| - base::PostTaskAndReplyWithResult(
|
| - blocking_task_runner(),
|
| - FROM_HERE,
|
| - base::Bind(&internal::ResourceMetadata::GetResourceEntryById,
|
| - base::Unretained(metadata()), local_id, entry),
|
| - base::Bind(google_apis::test_util::CreateCopyResultCallback(&error)));
|
| - content::RunAllBlockingPoolTasksUntilIdle();
|
| - return error;
|
| -}
|
| -
|
| -std::string OperationTestBase::GetLocalId(const base::FilePath& path) {
|
| - std::string local_id;
|
| - FileError error = FILE_ERROR_FAILED;
|
| - base::PostTaskAndReplyWithResult(
|
| - blocking_task_runner(),
|
| - FROM_HERE,
|
| - base::Bind(&internal::ResourceMetadata::GetIdByPath,
|
| - base::Unretained(metadata()), path, &local_id),
|
| - base::Bind(google_apis::test_util::CreateCopyResultCallback(&error)));
|
| - content::RunAllBlockingPoolTasksUntilIdle();
|
| - EXPECT_EQ(FILE_ERROR_OK, error) << path.value();
|
| - return local_id;
|
| -}
|
| -
|
| -FileError OperationTestBase::CheckForUpdates() {
|
| - FileError error = FILE_ERROR_FAILED;
|
| - change_list_loader_->CheckForUpdates(
|
| - google_apis::test_util::CreateCopyResultCallback(&error));
|
| - content::RunAllBlockingPoolTasksUntilIdle();
|
| - return error;
|
| -}
|
| -
|
| -} // namespace file_system
|
| -} // namespace drive
|
|
|