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 |