| Index: sync/internal_api/test/fake_sync_manager.cc
|
| diff --git a/sync/internal_api/test/fake_sync_manager.cc b/sync/internal_api/test/fake_sync_manager.cc
|
| deleted file mode 100644
|
| index a0883f893935f3ea275ebaa26ba22de62ce46257..0000000000000000000000000000000000000000
|
| --- a/sync/internal_api/test/fake_sync_manager.cc
|
| +++ /dev/null
|
| @@ -1,275 +0,0 @@
|
| -// Copyright (c) 2012 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 "sync/internal_api/public/test/fake_sync_manager.h"
|
| -
|
| -#include <cstddef>
|
| -
|
| -#include "base/bind.h"
|
| -#include "base/bind_helpers.h"
|
| -#include "base/location.h"
|
| -#include "base/logging.h"
|
| -#include "base/memory/ptr_util.h"
|
| -#include "base/run_loop.h"
|
| -#include "base/sequenced_task_runner.h"
|
| -#include "base/single_thread_task_runner.h"
|
| -#include "base/threading/thread_task_runner_handle.h"
|
| -#include "sync/internal_api/public/http_post_provider_factory.h"
|
| -#include "sync/internal_api/public/internal_components_factory.h"
|
| -#include "sync/internal_api/public/test/fake_model_type_connector.h"
|
| -#include "sync/internal_api/public/util/weak_handle.h"
|
| -#include "sync/syncable/directory.h"
|
| -#include "sync/test/fake_sync_encryption_handler.h"
|
| -
|
| -class GURL;
|
| -
|
| -namespace syncer {
|
| -
|
| -FakeSyncManager::FakeSyncManager(ModelTypeSet initial_sync_ended_types,
|
| - ModelTypeSet progress_marker_types,
|
| - ModelTypeSet configure_fail_types) :
|
| - initial_sync_ended_types_(initial_sync_ended_types),
|
| - progress_marker_types_(progress_marker_types),
|
| - configure_fail_types_(configure_fail_types),
|
| - last_configure_reason_(CONFIGURE_REASON_UNKNOWN),
|
| - num_invalidations_received_(0) {
|
| - fake_encryption_handler_.reset(new FakeSyncEncryptionHandler());
|
| -}
|
| -
|
| -FakeSyncManager::~FakeSyncManager() {}
|
| -
|
| -ModelTypeSet FakeSyncManager::GetAndResetCleanedTypes() {
|
| - ModelTypeSet cleaned_types = cleaned_types_;
|
| - cleaned_types_.Clear();
|
| - return cleaned_types;
|
| -}
|
| -
|
| -ModelTypeSet FakeSyncManager::GetAndResetDownloadedTypes() {
|
| - ModelTypeSet downloaded_types = downloaded_types_;
|
| - downloaded_types_.Clear();
|
| - return downloaded_types;
|
| -}
|
| -
|
| -ModelTypeSet FakeSyncManager::GetAndResetEnabledTypes() {
|
| - ModelTypeSet enabled_types = enabled_types_;
|
| - enabled_types_.Clear();
|
| - return enabled_types;
|
| -}
|
| -
|
| -ConfigureReason FakeSyncManager::GetAndResetConfigureReason() {
|
| - ConfigureReason reason = last_configure_reason_;
|
| - last_configure_reason_ = CONFIGURE_REASON_UNKNOWN;
|
| - return reason;
|
| -}
|
| -
|
| -int FakeSyncManager::GetInvalidationCount() const {
|
| - return num_invalidations_received_;
|
| -}
|
| -
|
| -void FakeSyncManager::WaitForSyncThread() {
|
| - // Post a task to |sync_task_runner_| and block until it runs.
|
| - base::RunLoop run_loop;
|
| - if (!sync_task_runner_->PostTaskAndReply(
|
| - FROM_HERE,
|
| - base::Bind(&base::DoNothing),
|
| - run_loop.QuitClosure())) {
|
| - NOTREACHED();
|
| - }
|
| - run_loop.Run();
|
| -}
|
| -
|
| -void FakeSyncManager::Init(InitArgs* args) {
|
| - sync_task_runner_ = base::ThreadTaskRunnerHandle::Get();
|
| - PurgePartiallySyncedTypes();
|
| -
|
| - test_user_share_.SetUp();
|
| - UserShare* share = test_user_share_.user_share();
|
| - for (ModelTypeSet::Iterator it = initial_sync_ended_types_.First();
|
| - it.Good(); it.Inc()) {
|
| - TestUserShare::CreateRoot(it.Get(), share);
|
| - }
|
| -
|
| - FOR_EACH_OBSERVER(SyncManager::Observer, observers_,
|
| - OnInitializationComplete(
|
| - WeakHandle<JsBackend>(),
|
| - WeakHandle<DataTypeDebugInfoListener>(),
|
| - true, initial_sync_ended_types_));
|
| -}
|
| -
|
| -ModelTypeSet FakeSyncManager::InitialSyncEndedTypes() {
|
| - return initial_sync_ended_types_;
|
| -}
|
| -
|
| -ModelTypeSet FakeSyncManager::GetTypesWithEmptyProgressMarkerToken(
|
| - ModelTypeSet types) {
|
| - ModelTypeSet empty_types = types;
|
| - empty_types.RemoveAll(progress_marker_types_);
|
| - return empty_types;
|
| -}
|
| -
|
| -bool FakeSyncManager::PurgePartiallySyncedTypes() {
|
| - ModelTypeSet partial_types;
|
| - for (ModelTypeSet::Iterator i = progress_marker_types_.First();
|
| - i.Good(); i.Inc()) {
|
| - if (!initial_sync_ended_types_.Has(i.Get()))
|
| - partial_types.Put(i.Get());
|
| - }
|
| - progress_marker_types_.RemoveAll(partial_types);
|
| - cleaned_types_.PutAll(partial_types);
|
| - return true;
|
| -}
|
| -
|
| -void FakeSyncManager::UpdateCredentials(const SyncCredentials& credentials) {
|
| - NOTIMPLEMENTED();
|
| -}
|
| -
|
| -void FakeSyncManager::StartSyncingNormally(
|
| - const ModelSafeRoutingInfo& routing_info, base::Time last_poll_time) {
|
| - // Do nothing.
|
| -}
|
| -
|
| -void FakeSyncManager::ConfigureSyncer(
|
| - ConfigureReason reason,
|
| - ModelTypeSet to_download,
|
| - ModelTypeSet to_purge,
|
| - ModelTypeSet to_journal,
|
| - ModelTypeSet to_unapply,
|
| - const ModelSafeRoutingInfo& new_routing_info,
|
| - const base::Closure& ready_task,
|
| - const base::Closure& retry_task) {
|
| - last_configure_reason_ = reason;
|
| - enabled_types_ = GetRoutingInfoTypes(new_routing_info);
|
| - ModelTypeSet success_types = to_download;
|
| - success_types.RemoveAll(configure_fail_types_);
|
| -
|
| - DVLOG(1) << "Faking configuration. Downloading: "
|
| - << ModelTypeSetToString(success_types) << ". Cleaning: "
|
| - << ModelTypeSetToString(to_purge);
|
| -
|
| - // Update our fake directory by clearing and fake-downloading as necessary.
|
| - UserShare* share = GetUserShare();
|
| - share->directory->PurgeEntriesWithTypeIn(to_purge,
|
| - to_journal,
|
| - to_unapply);
|
| - for (ModelTypeSet::Iterator it = success_types.First(); it.Good(); it.Inc()) {
|
| - // We must be careful to not create the same root node twice.
|
| - if (!initial_sync_ended_types_.Has(it.Get())) {
|
| - TestUserShare::CreateRoot(it.Get(), share);
|
| - }
|
| - }
|
| -
|
| - // Simulate cleaning up disabled types.
|
| - // TODO(sync): consider only cleaning those types that were recently disabled,
|
| - // if this isn't the first cleanup, which more accurately reflects the
|
| - // behavior of the real cleanup logic.
|
| - initial_sync_ended_types_.RemoveAll(to_purge);
|
| - progress_marker_types_.RemoveAll(to_purge);
|
| - cleaned_types_.PutAll(to_purge);
|
| -
|
| - // Now simulate the actual configuration for those types that successfully
|
| - // download + apply.
|
| - progress_marker_types_.PutAll(success_types);
|
| - initial_sync_ended_types_.PutAll(success_types);
|
| - downloaded_types_.PutAll(success_types);
|
| -
|
| - ready_task.Run();
|
| -}
|
| -
|
| -void FakeSyncManager::AddObserver(Observer* observer) {
|
| - observers_.AddObserver(observer);
|
| -}
|
| -
|
| -void FakeSyncManager::RemoveObserver(Observer* observer) {
|
| - observers_.RemoveObserver(observer);
|
| -}
|
| -
|
| -SyncStatus FakeSyncManager::GetDetailedStatus() const {
|
| - NOTIMPLEMENTED();
|
| - return SyncStatus();
|
| -}
|
| -
|
| -void FakeSyncManager::SaveChanges() {
|
| - // Do nothing.
|
| -}
|
| -
|
| -void FakeSyncManager::ShutdownOnSyncThread(ShutdownReason reason) {
|
| - DCHECK(sync_task_runner_->RunsTasksOnCurrentThread());
|
| - test_user_share_.TearDown();
|
| -}
|
| -
|
| -UserShare* FakeSyncManager::GetUserShare() {
|
| - return test_user_share_.user_share();
|
| -}
|
| -
|
| -std::unique_ptr<syncer_v2::ModelTypeConnector>
|
| -FakeSyncManager::GetModelTypeConnectorProxy() {
|
| - return base::WrapUnique(new syncer_v2::FakeModelTypeConnector());
|
| -}
|
| -
|
| -const std::string FakeSyncManager::cache_guid() {
|
| - return test_user_share_.user_share()->directory->cache_guid();
|
| -}
|
| -
|
| -bool FakeSyncManager::ReceivedExperiment(Experiments* experiments) {
|
| - return false;
|
| -}
|
| -
|
| -bool FakeSyncManager::HasUnsyncedItems() {
|
| - NOTIMPLEMENTED();
|
| - return false;
|
| -}
|
| -
|
| -SyncEncryptionHandler* FakeSyncManager::GetEncryptionHandler() {
|
| - return fake_encryption_handler_.get();
|
| -}
|
| -
|
| -ScopedVector<syncer::ProtocolEvent>
|
| -FakeSyncManager::GetBufferedProtocolEvents() {
|
| - return ScopedVector<syncer::ProtocolEvent>();
|
| -}
|
| -
|
| -std::unique_ptr<base::ListValue> FakeSyncManager::GetAllNodesForType(
|
| - syncer::ModelType type) {
|
| - return std::unique_ptr<base::ListValue>(new base::ListValue());
|
| -}
|
| -
|
| -void FakeSyncManager::RefreshTypes(ModelTypeSet types) {
|
| - last_refresh_request_types_ = types;
|
| -}
|
| -
|
| -void FakeSyncManager::RegisterDirectoryTypeDebugInfoObserver(
|
| - syncer::TypeDebugInfoObserver* observer) {}
|
| -
|
| -void FakeSyncManager::UnregisterDirectoryTypeDebugInfoObserver(
|
| - syncer::TypeDebugInfoObserver* observer) {}
|
| -
|
| -bool FakeSyncManager::HasDirectoryTypeDebugInfoObserver(
|
| - syncer::TypeDebugInfoObserver* observer) {
|
| - return false;
|
| -}
|
| -
|
| -void FakeSyncManager::RequestEmitDebugInfo() {}
|
| -
|
| -void FakeSyncManager::OnIncomingInvalidation(
|
| - syncer::ModelType type,
|
| - std::unique_ptr<InvalidationInterface> invalidation) {
|
| - num_invalidations_received_++;
|
| -}
|
| -
|
| -ModelTypeSet FakeSyncManager::GetLastRefreshRequestTypes() {
|
| - return last_refresh_request_types_;
|
| -}
|
| -
|
| -void FakeSyncManager::SetInvalidatorEnabled(bool invalidator_enabled) {
|
| - // Do nothing.
|
| -}
|
| -
|
| -void FakeSyncManager::ClearServerData(const ClearServerDataCallback& callback) {
|
| - callback.Run();
|
| -}
|
| -
|
| -void FakeSyncManager::OnCookieJarChanged(bool account_mismatch,
|
| - bool empty_jar) {}
|
| -
|
| -} // namespace syncer
|
|
|