OLD | NEW |
---|---|
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 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 | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "sync/syncable/on_disk_directory_backing_store.h" | 5 #include "sync/syncable/on_disk_directory_backing_store.h" |
6 | 6 |
7 #include "base/logging.h" | 7 #include "base/logging.h" |
8 #include "base/metrics/histogram.h" | |
9 #include "sync/syncable/syncable-inl.h" | |
8 | 10 |
9 namespace syncer { | 11 namespace syncer { |
10 namespace syncable { | 12 namespace syncable { |
11 | 13 |
14 namespace { | |
15 | |
16 enum HistogramResultEnum { | |
17 FIRST_TRY_SUCCESS, | |
18 SECOND_TRY_SUCCESS, | |
19 SECOND_TRY_FAILURE, | |
20 RESULT_COUNT | |
21 }; | |
22 | |
23 } // namespace | |
24 | |
12 OnDiskDirectoryBackingStore::OnDiskDirectoryBackingStore( | 25 OnDiskDirectoryBackingStore::OnDiskDirectoryBackingStore( |
13 const std::string& dir_name, const FilePath& backing_filepath) | 26 const std::string& dir_name, const FilePath& backing_filepath) |
14 : DirectoryBackingStore(dir_name), | 27 : DirectoryBackingStore(dir_name), |
28 allow_failure_for_test_(false), | |
15 backing_filepath_(backing_filepath) { | 29 backing_filepath_(backing_filepath) { |
16 db_->set_exclusive_locking(); | 30 db_->set_exclusive_locking(); |
17 db_->set_page_size(4096); | 31 db_->set_page_size(4096); |
18 } | 32 } |
19 | 33 |
20 DirOpenResult OnDiskDirectoryBackingStore::Load( | 34 DirOpenResult OnDiskDirectoryBackingStore::TryLoad( |
21 MetahandlesIndex* entry_bucket, | 35 MetahandlesIndex* entry_bucket, |
22 Directory::KernelLoadInfo* kernel_load_info) { | 36 Directory::KernelLoadInfo* kernel_load_info) { |
23 DCHECK(CalledOnValidThread()); | 37 DCHECK(CalledOnValidThread()); |
24 if (!db_->is_open()) { | 38 if (!db_->is_open()) { |
25 if (!db_->Open(backing_filepath_)) | 39 if (!db_->Open(backing_filepath_)) |
26 return FAILED_OPEN_DATABASE; | 40 return FAILED_OPEN_DATABASE; |
27 } | 41 } |
28 | 42 |
29 if (!InitializeTables()) | 43 if (!InitializeTables()) |
30 return FAILED_OPEN_DATABASE; | 44 return FAILED_OPEN_DATABASE; |
31 | 45 |
32 if (!DropDeletedEntries()) | 46 if (!DropDeletedEntries()) |
33 return FAILED_DATABASE_CORRUPT; | 47 return FAILED_DATABASE_CORRUPT; |
34 if (!LoadEntries(entry_bucket)) | 48 if (!LoadEntries(entry_bucket)) |
35 return FAILED_DATABASE_CORRUPT; | 49 return FAILED_DATABASE_CORRUPT; |
36 if (!LoadInfo(kernel_load_info)) | 50 if (!LoadInfo(kernel_load_info)) |
37 return FAILED_DATABASE_CORRUPT; | 51 return FAILED_DATABASE_CORRUPT; |
52 if (!VerifyReferenceIntegrity(*entry_bucket)) | |
53 return FAILED_DATABASE_CORRUPT; | |
38 | 54 |
39 return OPENED; | 55 return OPENED; |
56 | |
57 } | |
58 | |
59 DirOpenResult OnDiskDirectoryBackingStore::Load( | |
60 MetahandlesIndex* entry_bucket, | |
61 Directory::KernelLoadInfo* kernel_load_info) { | |
62 DirOpenResult result = TryLoad(entry_bucket, kernel_load_info); | |
63 if (result == OPENED) { | |
64 HISTOGRAM_ENUMERATION( | |
65 "Sync.DirectoryOpenResult", FIRST_TRY_SUCCESS, RESULT_COUNT); | |
66 return OPENED; | |
67 } | |
68 | |
69 // In debug builds, the last thing we want is to silently clear the database. | |
70 // It's full of evidence that might help us determine what went wrong. It | |
71 // might be sqlite's fault, but it could also be a bug in sync. We crash | |
72 // immediately so a developer can investigate. | |
tim (not reviewing)
2012/08/01 21:31:59
Let's keep an eye on this. I've seen similar dche
rlarocque
2012/08/01 22:37:51
I've updated the comment with instructions on how
| |
73 if (!allow_failure_for_test_) | |
74 NOTREACHED() << "Crashing to preserve corrupt sync database"; | |
75 | |
76 // The fallback: delete the current database and return a fresh one. We can | |
77 // fetch the user's data from the could. | |
78 entry_bucket->clear(); | |
79 db_.reset(new sql::Connection); | |
tim (not reviewing)
2012/08/01 21:31:59
A bit nervous to swap this out since we set it in
| |
80 file_util::Delete(backing_filepath_, false); | |
81 | |
82 result = TryLoad(entry_bucket, kernel_load_info); | |
83 if (result == OPENED) { | |
84 HISTOGRAM_ENUMERATION( | |
85 "Sync.DirectoryOpenResult", SECOND_TRY_SUCCESS, RESULT_COUNT); | |
86 } else { | |
87 HISTOGRAM_ENUMERATION( | |
88 "Sync.DirectoryOpenResult", SECOND_TRY_FAILURE, RESULT_COUNT); | |
89 } | |
90 | |
91 return result; | |
92 } | |
93 | |
94 void OnDiskDirectoryBackingStore::AllowFailureForTest() { | |
tim (not reviewing)
2012/08/01 21:31:59
I think it would be clearer / preferable to have a
rlarocque
2012/08/01 21:53:50
Yet another implementation of DirectoryBackingStor
| |
95 allow_failure_for_test_ = true; | |
40 } | 96 } |
41 | 97 |
42 } // namespace syncable | 98 } // namespace syncable |
43 } // namespace syncer | 99 } // namespace syncer |
OLD | NEW |