Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(24)

Unified Diff: sync/internal_api/test/fake_sync_manager.cc

Issue 2130453004: [Sync] Move //sync to //components/sync. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Rebase. Created 4 years, 5 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
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
« no previous file with comments | « sync/internal_api/test/fake_model_type_processor.cc ('k') | sync/internal_api/test/model_type_store_test_util.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698