| 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 <stdint.h> | 7 #include <stdint.h> |
| 8 | 8 |
| 9 #include <unordered_map> | 9 #include <unordered_map> |
| 10 #include <utility> | 10 #include <utility> |
| (...skipping 10 matching lines...) Expand all Loading... |
| 21 #include "chrome/browser/sync_file_system/drive_backend/drive_backend_test_util.
h" | 21 #include "chrome/browser/sync_file_system/drive_backend/drive_backend_test_util.
h" |
| 22 #include "chrome/browser/sync_file_system/drive_backend/drive_backend_util.h" | 22 #include "chrome/browser/sync_file_system/drive_backend/drive_backend_util.h" |
| 23 #include "chrome/browser/sync_file_system/drive_backend/leveldb_wrapper.h" | 23 #include "chrome/browser/sync_file_system/drive_backend/leveldb_wrapper.h" |
| 24 #include "chrome/browser/sync_file_system/drive_backend/metadata_database.pb.h" | 24 #include "chrome/browser/sync_file_system/drive_backend/metadata_database.pb.h" |
| 25 #include "chrome/browser/sync_file_system/drive_backend/metadata_database_index.
h" | 25 #include "chrome/browser/sync_file_system/drive_backend/metadata_database_index.
h" |
| 26 #include "chrome/browser/sync_file_system/drive_backend/metadata_database_index_
interface.h" | 26 #include "chrome/browser/sync_file_system/drive_backend/metadata_database_index_
interface.h" |
| 27 #include "chrome/browser/sync_file_system/drive_backend/metadata_database_index_
on_disk.h" | 27 #include "chrome/browser/sync_file_system/drive_backend/metadata_database_index_
on_disk.h" |
| 28 #include "chrome/browser/sync_file_system/sync_file_system_test_util.h" | 28 #include "chrome/browser/sync_file_system/sync_file_system_test_util.h" |
| 29 #include "google_apis/drive/drive_api_parser.h" | 29 #include "google_apis/drive/drive_api_parser.h" |
| 30 #include "testing/gtest/include/gtest/gtest.h" | 30 #include "testing/gtest/include/gtest/gtest.h" |
| 31 #include "third_party/leveldatabase/env_chromium.h" |
| 31 #include "third_party/leveldatabase/src/helpers/memenv/memenv.h" | 32 #include "third_party/leveldatabase/src/helpers/memenv/memenv.h" |
| 32 #include "third_party/leveldatabase/src/include/leveldb/db.h" | 33 #include "third_party/leveldatabase/src/include/leveldb/db.h" |
| 33 #include "third_party/leveldatabase/src/include/leveldb/env.h" | 34 #include "third_party/leveldatabase/src/include/leveldb/env.h" |
| 34 #include "third_party/leveldatabase/src/include/leveldb/write_batch.h" | 35 #include "third_party/leveldatabase/src/include/leveldb/write_batch.h" |
| 35 | 36 |
| 36 #define FPL(a) FILE_PATH_LITERAL(a) | 37 #define FPL(a) FILE_PATH_LITERAL(a) |
| 37 | 38 |
| 38 namespace sync_file_system { | 39 namespace sync_file_system { |
| 39 namespace drive_backend { | 40 namespace drive_backend { |
| 40 | 41 |
| (...skipping 223 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 264 } | 265 } |
| 265 | 266 |
| 266 void VerifyTrackedFiles(const TrackedFile** tracked_files, int size) { | 267 void VerifyTrackedFiles(const TrackedFile** tracked_files, int size) { |
| 267 for (int i = 0; i < size; ++i) | 268 for (int i = 0; i < size; ++i) |
| 268 VerifyTrackedFile(*tracked_files[i]); | 269 VerifyTrackedFile(*tracked_files[i]); |
| 269 } | 270 } |
| 270 | 271 |
| 271 MetadataDatabase* metadata_database() { return metadata_database_.get(); } | 272 MetadataDatabase* metadata_database() { return metadata_database_.get(); } |
| 272 | 273 |
| 273 std::unique_ptr<LevelDBWrapper> InitializeLevelDB() { | 274 std::unique_ptr<LevelDBWrapper> InitializeLevelDB() { |
| 274 leveldb::DB* db = nullptr; | 275 std::unique_ptr<leveldb::DB> db; |
| 275 leveldb::Options options; | 276 leveldb::Options options; |
| 276 options.create_if_missing = true; | 277 options.create_if_missing = true; |
| 277 options.max_open_files = 0; // Use minimum. | 278 options.max_open_files = 0; // Use minimum. |
| 278 options.env = in_memory_env_.get(); | 279 options.env = in_memory_env_.get(); |
| 279 leveldb::Status status = | 280 leveldb::Status status = leveldb_env::OpenDB( |
| 280 leveldb::DB::Open(options, database_dir_.GetPath().AsUTF8Unsafe(), &db); | 281 options, database_dir_.GetPath().AsUTF8Unsafe(), &db); |
| 281 EXPECT_TRUE(status.ok()); | 282 EXPECT_TRUE(status.ok()); |
| 282 | 283 |
| 283 std::unique_ptr<LevelDBWrapper> wrapper( | 284 std::unique_ptr<LevelDBWrapper> wrapper(new LevelDBWrapper(std::move(db))); |
| 284 new LevelDBWrapper(base::WrapUnique(db))); | |
| 285 | 285 |
| 286 wrapper->Put(kDatabaseVersionKey, base::Int64ToString(3)); | 286 wrapper->Put(kDatabaseVersionKey, base::Int64ToString(3)); |
| 287 SetUpServiceMetadata(wrapper.get()); | 287 SetUpServiceMetadata(wrapper.get()); |
| 288 | 288 |
| 289 return wrapper; | 289 return wrapper; |
| 290 } | 290 } |
| 291 | 291 |
| 292 void SetUpServiceMetadata(LevelDBWrapper* db) { | 292 void SetUpServiceMetadata(LevelDBWrapper* db) { |
| 293 ServiceMetadata service_metadata; | 293 ServiceMetadata service_metadata; |
| 294 service_metadata.set_largest_change_id(kInitialChangeID); | 294 service_metadata.set_largest_change_id(kInitialChangeID); |
| (...skipping 873 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1168 EXPECT_TRUE(file->HasKey("details")); | 1168 EXPECT_TRUE(file->HasKey("details")); |
| 1169 | 1169 |
| 1170 ASSERT_TRUE(files->GetDictionary(1, &file)); | 1170 ASSERT_TRUE(files->GetDictionary(1, &file)); |
| 1171 EXPECT_TRUE(file->GetString("title", &str) && str == "file_0"); | 1171 EXPECT_TRUE(file->GetString("title", &str) && str == "file_0"); |
| 1172 EXPECT_TRUE(file->GetString("type", &str) && str == "file"); | 1172 EXPECT_TRUE(file->GetString("type", &str) && str == "file"); |
| 1173 EXPECT_TRUE(file->HasKey("details")); | 1173 EXPECT_TRUE(file->HasKey("details")); |
| 1174 } | 1174 } |
| 1175 | 1175 |
| 1176 } // namespace drive_backend | 1176 } // namespace drive_backend |
| 1177 } // namespace sync_file_system | 1177 } // namespace sync_file_system |
| OLD | NEW |