| OLD | NEW |
| 1 // Copyright (c) 2013 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 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 "content/browser/indexed_db/indexed_db_backing_store.h" | 5 #include "content/browser/indexed_db/indexed_db_backing_store.h" |
| 6 | 6 |
| 7 #include "base/logging.h" | 7 #include "base/logging.h" |
| 8 #include "base/strings/string16.h" | 8 #include "base/strings/string16.h" |
| 9 #include "base/strings/utf_string_conversions.h" | 9 #include "base/strings/utf_string_conversions.h" |
| 10 #include "content/browser/indexed_db/indexed_db_leveldb_coding.h" | 10 #include "content/browser/indexed_db/indexed_db_leveldb_coding.h" |
| (...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 44 IndexedDBValue m_value2; | 44 IndexedDBValue m_value2; |
| 45 | 45 |
| 46 private: | 46 private: |
| 47 DISALLOW_COPY_AND_ASSIGN(IndexedDBBackingStoreTest); | 47 DISALLOW_COPY_AND_ASSIGN(IndexedDBBackingStoreTest); |
| 48 }; | 48 }; |
| 49 | 49 |
| 50 TEST_F(IndexedDBBackingStoreTest, PutGetConsistency) { | 50 TEST_F(IndexedDBBackingStoreTest, PutGetConsistency) { |
| 51 { | 51 { |
| 52 IndexedDBBackingStore::Transaction transaction1(backing_store_); | 52 IndexedDBBackingStore::Transaction transaction1(backing_store_); |
| 53 transaction1.Begin(); | 53 transaction1.Begin(); |
| 54 ScopedVector<webkit_blob::BlobDataHandle> handles; |
| 54 IndexedDBBackingStore::RecordIdentifier record; | 55 IndexedDBBackingStore::RecordIdentifier record; |
| 55 leveldb::Status s = backing_store_->PutRecord( | 56 leveldb::Status s = backing_store_->PutRecord( |
| 56 &transaction1, 1, 1, m_key1, m_value1, &record); | 57 &transaction1, 1, 1, m_key1, m_value1, &handles, &record); |
| 57 EXPECT_TRUE(s.ok()); | 58 EXPECT_TRUE(s.ok()); |
| 58 transaction1.Commit(); | 59 transaction1.Commit(); |
| 59 } | 60 } |
| 60 | 61 |
| 61 { | 62 { |
| 62 IndexedDBBackingStore::Transaction transaction2(backing_store_); | 63 IndexedDBBackingStore::Transaction transaction2(backing_store_); |
| 63 transaction2.Begin(); | 64 transaction2.Begin(); |
| 64 IndexedDBValue result_value; | 65 IndexedDBValue result_value; |
| 65 leveldb::Status s = | 66 leveldb::Status s = |
| 66 backing_store_->GetRecord(&transaction2, 1, 1, m_key1, &result_value); | 67 backing_store_->GetRecord(&transaction2, 1, 1, m_key1, &result_value); |
| (...skipping 12 matching lines...) Expand all Loading... |
| 79 const int64 high_index_id = 1ULL << 29; | 80 const int64 high_index_id = 1ULL << 29; |
| 80 | 81 |
| 81 const int64 invalid_high_index_id = 1ULL << 37; | 82 const int64 invalid_high_index_id = 1ULL << 37; |
| 82 | 83 |
| 83 const IndexedDBKey& index_key = m_key2; | 84 const IndexedDBKey& index_key = m_key2; |
| 84 std::string index_key_raw; | 85 std::string index_key_raw; |
| 85 EncodeIDBKey(index_key, &index_key_raw); | 86 EncodeIDBKey(index_key, &index_key_raw); |
| 86 { | 87 { |
| 87 IndexedDBBackingStore::Transaction transaction1(backing_store_); | 88 IndexedDBBackingStore::Transaction transaction1(backing_store_); |
| 88 transaction1.Begin(); | 89 transaction1.Begin(); |
| 90 ScopedVector<webkit_blob::BlobDataHandle> handles; |
| 89 IndexedDBBackingStore::RecordIdentifier record; | 91 IndexedDBBackingStore::RecordIdentifier record; |
| 90 leveldb::Status s = backing_store_->PutRecord(&transaction1, | 92 leveldb::Status s = backing_store_->PutRecord(&transaction1, |
| 91 high_database_id, | 93 high_database_id, |
| 92 high_object_store_id, | 94 high_object_store_id, |
| 93 m_key1, | 95 m_key1, |
| 94 m_value1, | 96 m_value1, |
| 97 &handles, |
| 95 &record); | 98 &record); |
| 96 EXPECT_TRUE(s.ok()); | 99 EXPECT_TRUE(s.ok()); |
| 97 | 100 |
| 98 s = backing_store_->PutIndexDataForRecord(&transaction1, | 101 s = backing_store_->PutIndexDataForRecord(&transaction1, |
| 99 high_database_id, | 102 high_database_id, |
| 100 high_object_store_id, | 103 high_object_store_id, |
| 101 invalid_high_index_id, | 104 invalid_high_index_id, |
| 102 index_key, | 105 index_key, |
| 103 record); | 106 record); |
| 104 EXPECT_FALSE(s.ok()); | 107 EXPECT_FALSE(s.ok()); |
| (...skipping 51 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 156 const int64 database_id = 1; | 159 const int64 database_id = 1; |
| 157 const int64 object_store_id = 1; | 160 const int64 object_store_id = 1; |
| 158 const int64 index_id = kMinimumIndexId; | 161 const int64 index_id = kMinimumIndexId; |
| 159 const int64 invalid_low_index_id = 19; // index_ids must be > kMinimumIndexId | 162 const int64 invalid_low_index_id = 19; // index_ids must be > kMinimumIndexId |
| 160 | 163 |
| 161 IndexedDBValue result_value; | 164 IndexedDBValue result_value; |
| 162 | 165 |
| 163 IndexedDBBackingStore::Transaction transaction1(backing_store_); | 166 IndexedDBBackingStore::Transaction transaction1(backing_store_); |
| 164 transaction1.Begin(); | 167 transaction1.Begin(); |
| 165 | 168 |
| 169 ScopedVector<webkit_blob::BlobDataHandle> handles; |
| 166 IndexedDBBackingStore::RecordIdentifier record; | 170 IndexedDBBackingStore::RecordIdentifier record; |
| 167 leveldb::Status s = backing_store_->PutRecord(&transaction1, | 171 leveldb::Status s = backing_store_->PutRecord(&transaction1, |
| 168 database_id, | 172 database_id, |
| 169 KeyPrefix::kInvalidId, | 173 KeyPrefix::kInvalidId, |
| 170 m_key1, | 174 m_key1, |
| 171 m_value1, | 175 m_value1, |
| 176 &handles, |
| 172 &record); | 177 &record); |
| 173 EXPECT_FALSE(s.ok()); | 178 EXPECT_FALSE(s.ok()); |
| 174 s = backing_store_->PutRecord( | 179 s = backing_store_->PutRecord( |
| 175 &transaction1, database_id, 0, m_key1, m_value1, &record); | 180 &transaction1, database_id, 0, m_key1, m_value1, &handles, &record); |
| 176 EXPECT_FALSE(s.ok()); | 181 EXPECT_FALSE(s.ok()); |
| 177 s = backing_store_->PutRecord(&transaction1, | 182 s = backing_store_->PutRecord(&transaction1, |
| 178 KeyPrefix::kInvalidId, | 183 KeyPrefix::kInvalidId, |
| 179 object_store_id, | 184 object_store_id, |
| 180 m_key1, | 185 m_key1, |
| 181 m_value1, | 186 m_value1, |
| 187 &handles, |
| 182 &record); | 188 &record); |
| 183 EXPECT_FALSE(s.ok()); | 189 EXPECT_FALSE(s.ok()); |
| 184 s = backing_store_->PutRecord( | 190 s = backing_store_->PutRecord( |
| 185 &transaction1, 0, object_store_id, m_key1, m_value1, &record); | 191 &transaction1, 0, object_store_id, m_key1, m_value1, &handles, &record); |
| 186 EXPECT_FALSE(s.ok()); | 192 EXPECT_FALSE(s.ok()); |
| 187 | 193 |
| 188 s = backing_store_->GetRecord( | 194 s = backing_store_->GetRecord( |
| 189 &transaction1, database_id, KeyPrefix::kInvalidId, m_key1, &result_value); | 195 &transaction1, database_id, KeyPrefix::kInvalidId, m_key1, &result_value); |
| 190 EXPECT_FALSE(s.ok()); | 196 EXPECT_FALSE(s.ok()); |
| 191 s = backing_store_->GetRecord( | 197 s = backing_store_->GetRecord( |
| 192 &transaction1, database_id, 0, m_key1, &result_value); | 198 &transaction1, database_id, 0, m_key1, &result_value); |
| 193 EXPECT_FALSE(s.ok()); | 199 EXPECT_FALSE(s.ok()); |
| 194 s = backing_store_->GetRecord(&transaction1, | 200 s = backing_store_->GetRecord(&transaction1, |
| 195 KeyPrefix::kInvalidId, | 201 KeyPrefix::kInvalidId, |
| (...skipping 117 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 313 EXPECT_EQ(index_name, index.name); | 319 EXPECT_EQ(index_name, index.name); |
| 314 EXPECT_EQ(index_key_path, index.key_path); | 320 EXPECT_EQ(index_key_path, index.key_path); |
| 315 EXPECT_EQ(unique, index.unique); | 321 EXPECT_EQ(unique, index.unique); |
| 316 EXPECT_EQ(multi_entry, index.multi_entry); | 322 EXPECT_EQ(multi_entry, index.multi_entry); |
| 317 } | 323 } |
| 318 } | 324 } |
| 319 | 325 |
| 320 } // namespace | 326 } // namespace |
| 321 | 327 |
| 322 } // namespace content | 328 } // namespace content |
| OLD | NEW |