sync/syncable/deferred_on_disk_directory_backing_store.cc

   1 // Copyright 2014 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/syncable/deferred_on_disk_directory_backing_store.h"
   6
   7 #include "base/logging.h"
   8 #include "base/metrics/histogram.h"
   9 #include "base/stl_util.h"
  10 #include "sync/syncable/syncable-inl.h"
  11
  12 namespace syncer {
  13 namespace syncable {
  14
  15 DeferredOnDiskDirectoryBackingStore::DeferredOnDiskDirectoryBackingStore(
  16     const std::string& dir_name, const base::FilePath& backing_filepath)
  17     : DirectoryBackingStore(dir_name),
  18       backing_filepath_(backing_filepath),
  19       db_is_on_disk_(false) {
  20 }
  21
  22 DeferredOnDiskDirectoryBackingStore::~DeferredOnDiskDirectoryBackingStore() {}
  23
  24 bool DeferredOnDiskDirectoryBackingStore::SaveChanges(
  25     const Directory::SaveChangesSnapshot& snapshot) {
  26   DCHECK(CalledOnValidThread());
  27
  28   // Back out early if there is nothing to save.
  29   if (snapshot.dirty_metas.empty() && snapshot.metahandles_to_purge.empty() &&
  30       snapshot.delete_journals.empty() &&
  31       snapshot.delete_journals_to_purge.empty()) {
  32     return true;
  33   }
  34
  35   if (!db_is_on_disk_) {
  36     if (!base::DeleteFile(backing_filepath_, false))
  37       return false;
  38
  39     // Reopen DB on disk.
  40     ResetAndCreateConnection();
  41     if (!db_->Open(backing_filepath_) || !InitializeTables())
  42       return false;
  43
  44     db_is_on_disk_ = true;
  45   }
  46
  47   return DirectoryBackingStore::SaveChanges(snapshot);
  48 }
  49
  50 DirOpenResult DeferredOnDiskDirectoryBackingStore::Load(
  51     Directory::MetahandlesMap* handles_map,
  52     JournalIndex* delete_journals,
  53     MetahandleSet* metahandles_to_purge,
  54     Directory::KernelLoadInfo* kernel_load_info) {
  55   // Open an in-memory database at first to create initial sync data needed by
  56   // Directory.
  57   CHECK(!db_->is_open());
  58   if (!db_->OpenInMemory())
  59     return FAILED_OPEN_DATABASE;
  60
  61   if (!InitializeTables())
  62     return FAILED_OPEN_DATABASE;
  63   if (!LoadEntries(handles_map, metahandles_to_purge))
  64     return FAILED_DATABASE_CORRUPT;
  65   if (!LoadInfo(kernel_load_info))
  66     return FAILED_DATABASE_CORRUPT;
  67
  68   return OPENED;
  69 }
  70
  71 }  // namespace syncable
  72 }  // namespace syncer