| 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
|
| index 696746d33f6b637e31b5b4fb7be781d28ca833c3..e6b415a551c9919a38d57a5480f24f5e36877829 100644
|
| --- a/sync/internal_api/test/fake_sync_manager.cc
|
| +++ b/sync/internal_api/test/fake_sync_manager.cc
|
| @@ -9,6 +9,7 @@
|
| #include "base/bind.h"
|
| #include "base/location.h"
|
| #include "base/logging.h"
|
| +#include "base/run_loop.h"
|
| #include "base/sequenced_task_runner.h"
|
| #include "base/single_thread_task_runner.h"
|
| #include "base/thread_task_runner_handle.h"
|
| @@ -21,22 +22,15 @@
|
|
|
| namespace syncer {
|
|
|
| -FakeSyncManager::FakeSyncManager() {}
|
| +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) {}
|
|
|
| FakeSyncManager::~FakeSyncManager() {}
|
|
|
| -void FakeSyncManager::set_initial_sync_ended_types(ModelTypeSet types) {
|
| - initial_sync_ended_types_ = types;
|
| -}
|
| -
|
| -void FakeSyncManager::set_progress_marker_types(ModelTypeSet types) {
|
| - progress_marker_types_ = types;
|
| -}
|
| -
|
| -void FakeSyncManager::set_configure_fail_types(ModelTypeSet types) {
|
| - configure_fail_types_ = types;
|
| -}
|
| -
|
| ModelTypeSet FakeSyncManager::GetAndResetCleanedTypes() {
|
| ModelTypeSet cleaned_types = cleaned_types_;
|
| cleaned_types_.Clear();
|
| @@ -84,6 +78,24 @@ void FakeSyncManager::DisableNotifications(
|
| }
|
| }
|
|
|
| +namespace {
|
| +
|
| +void DoNothing() {}
|
| +
|
| +} // namespace
|
| +
|
| +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(&DoNothing),
|
| + run_loop.QuitClosure())) {
|
| + NOTREACHED();
|
| + }
|
| + run_loop.Run();
|
| +}
|
| +
|
| void FakeSyncManager::Init(
|
| const FilePath& database_location,
|
| const WeakHandle<JsEventHandler>& event_handler,
|
| @@ -148,10 +160,20 @@ void FakeSyncManager::UpdateEnabledTypes(const ModelTypeSet& types) {
|
| enabled_types_ = types;
|
| }
|
|
|
| +void FakeSyncManager::RegisterInvalidationHandler(
|
| + SyncNotifierObserver* handler) {
|
| + registrar_.RegisterHandler(handler);
|
| +}
|
| +
|
| void FakeSyncManager::UpdateRegisteredInvalidationIds(
|
| SyncNotifierObserver* handler,
|
| const ObjectIdSet& ids) {
|
| - notifier_helper_.UpdateRegisteredIds(handler, ids);
|
| + registrar_.UpdateRegisteredIds(handler, ids);
|
| +}
|
| +
|
| +void FakeSyncManager::UnregisterInvalidationHandler(
|
| + SyncNotifierObserver* handler) {
|
| + registrar_.UnregisterHandler(handler);
|
| }
|
|
|
| void FakeSyncManager::StartSyncingNormally(
|
| @@ -264,18 +286,18 @@ void FakeSyncManager::InvalidateOnSyncThread(
|
| const ObjectIdPayloadMap& id_payloads,
|
| IncomingNotificationSource source) {
|
| DCHECK(sync_task_runner_->RunsTasksOnCurrentThread());
|
| - notifier_helper_.DispatchInvalidationsToHandlers(id_payloads, source);
|
| + registrar_.DispatchInvalidationsToHandlers(id_payloads, source);
|
| }
|
|
|
| void FakeSyncManager::EnableNotificationsOnSyncThread() {
|
| DCHECK(sync_task_runner_->RunsTasksOnCurrentThread());
|
| - notifier_helper_.EmitOnNotificationsEnabled();
|
| + registrar_.EmitOnNotificationsEnabled();
|
| }
|
|
|
| void FakeSyncManager::DisableNotificationsOnSyncThread(
|
| NotificationsDisabledReason reason) {
|
| DCHECK(sync_task_runner_->RunsTasksOnCurrentThread());
|
| - notifier_helper_.EmitOnNotificationsDisabled(reason);
|
| + registrar_.EmitOnNotificationsDisabled(reason);
|
| }
|
|
|
| } // namespace syncer
|
|
|