sync/internal_api/internal_components_factory_impl.cc

   1 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 #include "sync/internal_api/public/internal_components_factory_impl.h"
   6
   7 #include "sync/engine/backoff_delay_provider.h"
   8 #include "sync/engine/syncer.h"
   9 #include "sync/engine/sync_scheduler_impl.h"
  10 #include "sync/sessions/sync_session_context.h"
  11 #include "sync/syncable/deferred_on_disk_directory_backing_store.h"
  12 #include "sync/syncable/on_disk_directory_backing_store.h"
  13
  14 using base::TimeDelta;
  15
  16 namespace syncer {
  17
  18 InternalComponentsFactoryImpl::InternalComponentsFactoryImpl(
  19     const Switches& switches) : switches_(switches) {
  20 }
  21
  22 InternalComponentsFactoryImpl::~InternalComponentsFactoryImpl() { }
  23
  24 scoped_ptr<SyncScheduler> InternalComponentsFactoryImpl::BuildScheduler(
  25     const std::string& name,
  26     sessions::SyncSessionContext* context,
  27     CancelationSignal* cancelation_signal) {
  28
  29   scoped_ptr<BackoffDelayProvider> delay(BackoffDelayProvider::FromDefaults());
  30
  31   if (switches_.backoff_override == BACKOFF_SHORT_INITIAL_RETRY_OVERRIDE)
  32     delay.reset(BackoffDelayProvider::WithShortInitialRetryOverride());
  33
  34   return scoped_ptr<SyncScheduler>(new SyncSchedulerImpl(
  35           name,
  36           delay.release(),
  37           context,
  38           new Syncer(cancelation_signal)));
  39 }
  40
  41 scoped_ptr<sessions::SyncSessionContext>
  42 InternalComponentsFactoryImpl::BuildContext(
  43     ServerConnectionManager* connection_manager,
  44     syncable::Directory* directory,
  45     ExtensionsActivity* extensions_activity,
  46     const std::vector<SyncEngineEventListener*>& listeners,
  47     sessions::DebugInfoGetter* debug_info_getter,
  48     ModelTypeRegistry* model_type_registry,
  49     const std::string& invalidation_client_id) {
  50   return scoped_ptr<sessions::SyncSessionContext>(
  51       new sessions::SyncSessionContext(
  52           connection_manager, directory, extensions_activity,
  53           listeners, debug_info_getter,
  54           model_type_registry,
  55           switches_.encryption_method == ENCRYPTION_KEYSTORE,
  56           switches_.pre_commit_updates_policy ==
  57               FORCE_ENABLE_PRE_COMMIT_UPDATE_AVOIDANCE,
  58           invalidation_client_id));
  59 }
  60
  61 scoped_ptr<syncable::DirectoryBackingStore>
  62 InternalComponentsFactoryImpl::BuildDirectoryBackingStore(
  63     StorageOption storage, const std::string& dir_name,
  64     const base::FilePath& backing_filepath) {
  65   if (storage == STORAGE_ON_DISK) {
  66     return scoped_ptr<syncable::DirectoryBackingStore>(
  67         new syncable::OnDiskDirectoryBackingStore(dir_name, backing_filepath));
  68   } else if (storage == STORAGE_ON_DISK_DEFERRED) {
  69     return scoped_ptr<syncable::DirectoryBackingStore>(
  70         new syncable::DeferredOnDiskDirectoryBackingStore(dir_name,
  71                                                           backing_filepath));
  72   } else {
  73     NOTREACHED();
  74     return scoped_ptr<syncable::DirectoryBackingStore>();
  75   }
  76 }
  77
  78 InternalComponentsFactory::Switches
  79 InternalComponentsFactoryImpl::GetSwitches() const {
  80   return switches_;
  81 }
  82
  83 }  // namespace syncer