| 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 |