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

Unified Diff: components/sync/core_impl/test/fake_sync_manager.cc

Issue 2413313004: [Sync] Move the last things out of core/. (Closed)
Patch Set: Address comments. Created 4 years, 2 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: components/sync/core_impl/test/fake_sync_manager.cc
diff --git a/components/sync/core_impl/test/fake_sync_manager.cc b/components/sync/core_impl/test/fake_sync_manager.cc
deleted file mode 100644
index 50762b4adc2c70e95d435f668c804fd3caacb361..0000000000000000000000000000000000000000
--- a/components/sync/core_impl/test/fake_sync_manager.cc
+++ /dev/null
@@ -1,267 +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 "components/sync/core/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 "components/sync/base/weak_handle.h"
-#include "components/sync/core/internal_components_factory.h"
-#include "components/sync/core/test/fake_model_type_connector.h"
-#include "components/sync/engine/net/http_post_provider_factory.h"
-#include "components/sync/syncable/directory.h"
-#include "components/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<ModelTypeConnector>
-FakeSyncManager::GetModelTypeConnectorProxy() {
- return base::MakeUnique<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();
-}
-
-std::vector<std::unique_ptr<ProtocolEvent>>
-FakeSyncManager::GetBufferedProtocolEvents() {
- return std::vector<std::unique_ptr<ProtocolEvent>>();
-}
-
-void FakeSyncManager::RefreshTypes(ModelTypeSet types) {
- last_refresh_request_types_ = types;
-}
-
-void FakeSyncManager::RegisterDirectoryTypeDebugInfoObserver(
- TypeDebugInfoObserver* observer) {}
-
-void FakeSyncManager::UnregisterDirectoryTypeDebugInfoObserver(
- TypeDebugInfoObserver* observer) {}
-
-bool FakeSyncManager::HasDirectoryTypeDebugInfoObserver(
- TypeDebugInfoObserver* observer) {
- return false;
-}
-
-void FakeSyncManager::RequestEmitDebugInfo() {}
-
-void FakeSyncManager::OnIncomingInvalidation(
- 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

Powered by Google App Engine
This is Rietveld 408576698