OLD | NEW |
1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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 "chrome/browser/sync_file_system/drive_backend/metadata_database.h" | 5 #include "chrome/browser/sync_file_system/drive_backend/metadata_database.h" |
6 | 6 |
7 #include <algorithm> | 7 #include <algorithm> |
8 #include <stack> | 8 #include <stack> |
9 | 9 |
10 #include "base/bind.h" | 10 #include "base/bind.h" |
(...skipping 16 matching lines...) Expand all Loading... |
27 #include "chrome/browser/sync_file_system/drive_backend/leveldb_wrapper.h" | 27 #include "chrome/browser/sync_file_system/drive_backend/leveldb_wrapper.h" |
28 #include "chrome/browser/sync_file_system/drive_backend/metadata_database.pb.h" | 28 #include "chrome/browser/sync_file_system/drive_backend/metadata_database.pb.h" |
29 #include "chrome/browser/sync_file_system/drive_backend/metadata_database_index.
h" | 29 #include "chrome/browser/sync_file_system/drive_backend/metadata_database_index.
h" |
30 #include "chrome/browser/sync_file_system/drive_backend/metadata_database_index_
interface.h" | 30 #include "chrome/browser/sync_file_system/drive_backend/metadata_database_index_
interface.h" |
31 #include "chrome/browser/sync_file_system/drive_backend/metadata_database_index_
on_disk.h" | 31 #include "chrome/browser/sync_file_system/drive_backend/metadata_database_index_
on_disk.h" |
32 #include "chrome/browser/sync_file_system/drive_backend/metadata_db_migration_ut
il.h" | 32 #include "chrome/browser/sync_file_system/drive_backend/metadata_db_migration_ut
il.h" |
33 #include "chrome/browser/sync_file_system/logger.h" | 33 #include "chrome/browser/sync_file_system/logger.h" |
34 #include "chrome/browser/sync_file_system/syncable_file_system_util.h" | 34 #include "chrome/browser/sync_file_system/syncable_file_system_util.h" |
35 #include "google_apis/drive/drive_api_parser.h" | 35 #include "google_apis/drive/drive_api_parser.h" |
36 #include "storage/common/fileapi/file_system_util.h" | 36 #include "storage/common/fileapi/file_system_util.h" |
| 37 #include "third_party/leveldatabase/env_chromium.h" |
37 #include "third_party/leveldatabase/src/include/leveldb/db.h" | 38 #include "third_party/leveldatabase/src/include/leveldb/db.h" |
38 #include "third_party/leveldatabase/src/include/leveldb/env.h" | 39 #include "third_party/leveldatabase/src/include/leveldb/env.h" |
39 #include "third_party/leveldatabase/src/include/leveldb/status.h" | 40 #include "third_party/leveldatabase/src/include/leveldb/status.h" |
40 #include "third_party/leveldatabase/src/include/leveldb/write_batch.h" | 41 #include "third_party/leveldatabase/src/include/leveldb/write_batch.h" |
41 | 42 |
42 namespace sync_file_system { | 43 namespace sync_file_system { |
43 namespace drive_backend { | 44 namespace drive_backend { |
44 | 45 |
45 namespace { | 46 namespace { |
46 | 47 |
(...skipping 160 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
207 scoped_ptr<LevelDBWrapper>* db_out, | 208 scoped_ptr<LevelDBWrapper>* db_out, |
208 bool* created) { | 209 bool* created) { |
209 base::ThreadRestrictions::AssertIOAllowed(); | 210 base::ThreadRestrictions::AssertIOAllowed(); |
210 DCHECK(db_out); | 211 DCHECK(db_out); |
211 DCHECK(created); | 212 DCHECK(created); |
212 DCHECK(path.IsAbsolute()); | 213 DCHECK(path.IsAbsolute()); |
213 | 214 |
214 leveldb::Options options; | 215 leveldb::Options options; |
215 options.max_open_files = 0; // Use minimum. | 216 options.max_open_files = 0; // Use minimum. |
216 options.create_if_missing = true; | 217 options.create_if_missing = true; |
| 218 options.reuse_logs = leveldb_env::kDefaultLogReuseOptionValue; |
217 if (env_override) | 219 if (env_override) |
218 options.env = env_override; | 220 options.env = env_override; |
219 leveldb::DB* db = nullptr; | 221 leveldb::DB* db = nullptr; |
220 leveldb::Status db_status = | 222 leveldb::Status db_status = |
221 leveldb::DB::Open(options, path.AsUTF8Unsafe(), &db); | 223 leveldb::DB::Open(options, path.AsUTF8Unsafe(), &db); |
222 SyncStatusCode status = LevelDBStatusToSyncStatusCode(db_status); | 224 SyncStatusCode status = LevelDBStatusToSyncStatusCode(db_status); |
223 if (status != SYNC_STATUS_OK) { | 225 if (status != SYNC_STATUS_OK) { |
224 delete db; | 226 delete db; |
225 return status; | 227 return status; |
226 } | 228 } |
(...skipping 1568 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1795 return false; | 1797 return false; |
1796 | 1798 |
1797 if (!parents.empty()) | 1799 if (!parents.empty()) |
1798 return false; | 1800 return false; |
1799 | 1801 |
1800 return true; | 1802 return true; |
1801 } | 1803 } |
1802 | 1804 |
1803 } // namespace drive_backend | 1805 } // namespace drive_backend |
1804 } // namespace sync_file_system | 1806 } // namespace sync_file_system |
OLD | NEW |