| OLD | NEW |
| (Empty) |
| 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 | |
| 3 // found in the LICENSE file. | |
| 4 | |
| 5 | |
| 6 #include "webkit/browser/dom_storage/session_storage_database.h" | |
| 7 | |
| 8 #include <algorithm> | |
| 9 #include <map> | |
| 10 #include <string> | |
| 11 | |
| 12 #include "base/file_util.h" | |
| 13 #include "base/files/scoped_temp_dir.h" | |
| 14 #include "base/logging.h" | |
| 15 #include "base/strings/string_number_conversions.h" | |
| 16 #include "base/strings/utf_string_conversions.h" | |
| 17 #include "testing/gtest/include/gtest/gtest.h" | |
| 18 #include "third_party/leveldatabase/src/include/leveldb/db.h" | |
| 19 #include "third_party/leveldatabase/src/include/leveldb/iterator.h" | |
| 20 #include "third_party/leveldatabase/src/include/leveldb/options.h" | |
| 21 #include "url/gurl.h" | |
| 22 #include "webkit/common/dom_storage/dom_storage_types.h" | |
| 23 | |
| 24 namespace dom_storage { | |
| 25 | |
| 26 class SessionStorageDatabaseTest : public testing::Test { | |
| 27 public: | |
| 28 SessionStorageDatabaseTest(); | |
| 29 virtual ~SessionStorageDatabaseTest(); | |
| 30 virtual void SetUp() OVERRIDE; | |
| 31 | |
| 32 protected: | |
| 33 typedef std::map<std::string, std::string> DataMap; | |
| 34 | |
| 35 // Helpers. | |
| 36 static bool IsNamespaceKey(const std::string& key, | |
| 37 std::string* namespace_id); | |
| 38 static bool IsNamespaceOriginKey(const std::string& key, | |
| 39 std::string* namespace_id); | |
| 40 static bool IsMapRefCountKey(const std::string& key, | |
| 41 int64* map_id); | |
| 42 static bool IsMapValueKey(const std::string& key, | |
| 43 int64* map_id); | |
| 44 void ResetDatabase(); | |
| 45 void ReadData(DataMap* data) const; | |
| 46 void CheckDatabaseConsistency() const; | |
| 47 void CheckEmptyDatabase() const; | |
| 48 void DumpData() const; | |
| 49 void CheckAreaData(const std::string& namespace_id, | |
| 50 const GURL& origin, | |
| 51 const ValuesMap& reference) const; | |
| 52 void CompareValuesMaps(const ValuesMap& map1, const ValuesMap& map2) const; | |
| 53 void CheckNamespaceIds( | |
| 54 const std::set<std::string>& expected_namespace_ids) const; | |
| 55 void CheckOrigins( | |
| 56 const std::string& namespace_id, | |
| 57 const std::set<GURL>& expected_origins) const; | |
| 58 std::string GetMapForArea(const std::string& namespace_id, | |
| 59 const GURL& origin) const; | |
| 60 int64 GetMapRefCount(const std::string& map_id) const; | |
| 61 | |
| 62 base::ScopedTempDir temp_dir_; | |
| 63 scoped_refptr<SessionStorageDatabase> db_; | |
| 64 | |
| 65 // Test data. | |
| 66 const GURL kOrigin1; | |
| 67 const GURL kOrigin2; | |
| 68 const std::string kNamespace1; | |
| 69 const std::string kNamespace2; | |
| 70 const std::string kNamespaceClone; | |
| 71 const base::string16 kKey1; | |
| 72 const base::string16 kKey2; | |
| 73 const base::string16 kKey3; | |
| 74 const base::NullableString16 kValue1; | |
| 75 const base::NullableString16 kValue2; | |
| 76 const base::NullableString16 kValue3; | |
| 77 const base::NullableString16 kValue4; | |
| 78 const base::NullableString16 kValueNull; | |
| 79 | |
| 80 DISALLOW_COPY_AND_ASSIGN(SessionStorageDatabaseTest); | |
| 81 }; | |
| 82 | |
| 83 SessionStorageDatabaseTest::SessionStorageDatabaseTest() | |
| 84 : kOrigin1("http://www.origin1.com"), | |
| 85 kOrigin2("http://www.origin2.com"), | |
| 86 kNamespace1("namespace1"), | |
| 87 kNamespace2("namespace2"), | |
| 88 kNamespaceClone("wascloned"), | |
| 89 kKey1(ASCIIToUTF16("key1")), | |
| 90 kKey2(ASCIIToUTF16("key2")), | |
| 91 kKey3(ASCIIToUTF16("key3")), | |
| 92 kValue1(ASCIIToUTF16("value1"), false), | |
| 93 kValue2(ASCIIToUTF16("value2"), false), | |
| 94 kValue3(ASCIIToUTF16("value3"), false), | |
| 95 kValue4(ASCIIToUTF16("value4"), false) { } | |
| 96 | |
| 97 SessionStorageDatabaseTest::~SessionStorageDatabaseTest() { } | |
| 98 | |
| 99 void SessionStorageDatabaseTest::SetUp() { | |
| 100 ASSERT_TRUE(temp_dir_.CreateUniqueTempDir()); | |
| 101 ResetDatabase(); | |
| 102 } | |
| 103 | |
| 104 void SessionStorageDatabaseTest::ResetDatabase() { | |
| 105 db_ = new SessionStorageDatabase(temp_dir_.path()); | |
| 106 ASSERT_TRUE(db_->LazyOpen(true)); | |
| 107 } | |
| 108 | |
| 109 // static | |
| 110 bool SessionStorageDatabaseTest::IsNamespaceKey(const std::string& key, | |
| 111 std::string* namespace_id) { | |
| 112 std::string namespace_prefix = SessionStorageDatabase::NamespacePrefix(); | |
| 113 if (key.find(namespace_prefix) != 0) | |
| 114 return false; | |
| 115 if (key == namespace_prefix) | |
| 116 return false; | |
| 117 | |
| 118 size_t second_dash = key.find('-', namespace_prefix.length()); | |
| 119 if (second_dash != key.length() - 1) | |
| 120 return false; | |
| 121 | |
| 122 // Key is of the form "namespace-<namespaceid>-". | |
| 123 *namespace_id = key.substr( | |
| 124 namespace_prefix.length(), | |
| 125 second_dash - namespace_prefix.length()); | |
| 126 return true; | |
| 127 } | |
| 128 | |
| 129 // static | |
| 130 bool SessionStorageDatabaseTest::IsNamespaceOriginKey( | |
| 131 const std::string& key, | |
| 132 std::string* namespace_id) { | |
| 133 std::string namespace_prefix = SessionStorageDatabase::NamespacePrefix(); | |
| 134 if (key.find(namespace_prefix) != 0) | |
| 135 return false; | |
| 136 size_t second_dash = key.find('-', namespace_prefix.length()); | |
| 137 if (second_dash == std::string::npos || second_dash == key.length() - 1) | |
| 138 return false; | |
| 139 | |
| 140 // Key is of the form "namespace-<namespaceid>-<origin>", and the value | |
| 141 // is the map id. | |
| 142 *namespace_id = key.substr( | |
| 143 namespace_prefix.length(), | |
| 144 second_dash - namespace_prefix.length()); | |
| 145 return true; | |
| 146 } | |
| 147 | |
| 148 // static | |
| 149 bool SessionStorageDatabaseTest::IsMapRefCountKey(const std::string& key, | |
| 150 int64* map_id) { | |
| 151 std::string map_prefix = "map-"; | |
| 152 if (key.find(map_prefix) != 0) | |
| 153 return false; | |
| 154 size_t second_dash = key.find('-', map_prefix.length()); | |
| 155 if (second_dash != key.length() - 1) | |
| 156 return false; | |
| 157 // Key is of the form "map-<mapid>-" and the value is the ref count. | |
| 158 std::string map_id_str = key.substr(map_prefix.length(), | |
| 159 second_dash - map_prefix.length()); | |
| 160 bool conversion_ok = base::StringToInt64(map_id_str, map_id); | |
| 161 EXPECT_TRUE(conversion_ok); | |
| 162 return true; | |
| 163 } | |
| 164 | |
| 165 // static | |
| 166 bool SessionStorageDatabaseTest::IsMapValueKey(const std::string& key, | |
| 167 int64* map_id) { | |
| 168 std::string map_prefix = "map-"; | |
| 169 if (key.find(map_prefix) != 0) | |
| 170 return false; | |
| 171 size_t second_dash = key.find('-', map_prefix.length()); | |
| 172 if (second_dash == std::string::npos || second_dash == key.length() - 1) | |
| 173 return false; | |
| 174 // Key is of the form "map-<mapid>-key". | |
| 175 std::string map_id_str = key.substr(map_prefix.length(), | |
| 176 second_dash - map_prefix.length()); | |
| 177 bool conversion_ok = base::StringToInt64(map_id_str, map_id); | |
| 178 EXPECT_TRUE(conversion_ok); | |
| 179 return true; | |
| 180 } | |
| 181 | |
| 182 void SessionStorageDatabaseTest::ReadData(DataMap* data) const { | |
| 183 leveldb::DB* leveldb = db_->db_.get(); | |
| 184 scoped_ptr<leveldb::Iterator> it( | |
| 185 leveldb->NewIterator(leveldb::ReadOptions())); | |
| 186 for (it->SeekToFirst(); it->Valid(); it->Next()) { | |
| 187 (*data)[it->key().ToString()] = it->value().ToString(); | |
| 188 } | |
| 189 } | |
| 190 | |
| 191 void SessionStorageDatabaseTest::CheckDatabaseConsistency() const { | |
| 192 DataMap data; | |
| 193 ReadData(&data); | |
| 194 // Empty db is ok. | |
| 195 if (data.empty()) | |
| 196 return; | |
| 197 | |
| 198 // For detecting rubbish keys. | |
| 199 size_t valid_keys = 0; | |
| 200 | |
| 201 std::string next_map_id_key = SessionStorageDatabase::NextMapIdKey(); | |
| 202 // Check the namespace start key. | |
| 203 if (data.find(SessionStorageDatabase::NamespacePrefix()) == data.end()) { | |
| 204 // If there is no namespace start key, the database may contain only counter | |
| 205 // keys. | |
| 206 for (DataMap::const_iterator it = data.begin(); it != data.end(); ++it) { | |
| 207 ASSERT_TRUE(it->first == next_map_id_key); | |
| 208 } | |
| 209 return; | |
| 210 } | |
| 211 ++valid_keys; | |
| 212 | |
| 213 // Iterate the "namespace-" keys. | |
| 214 std::set<std::string> found_namespace_ids; | |
| 215 std::set<std::string> namespaces_with_areas; | |
| 216 std::map<int64, int64> expected_map_refcounts; | |
| 217 int64 max_map_id = -1; | |
| 218 | |
| 219 for (DataMap::const_iterator it = data.begin(); it != data.end(); ++it) { | |
| 220 std::string namespace_id; | |
| 221 std::string origin; | |
| 222 if (IsNamespaceKey(it->first, &namespace_id)) { | |
| 223 found_namespace_ids.insert(namespace_id); | |
| 224 ++valid_keys; | |
| 225 } else if (IsNamespaceOriginKey( | |
| 226 it->first, &namespace_id)) { | |
| 227 // Check that the corresponding "namespace-<namespaceid>-" key exists. It | |
| 228 // has been read by now, since the keys are stored in order. | |
| 229 ASSERT_TRUE(found_namespace_ids.find(namespace_id) != | |
| 230 found_namespace_ids.end()); | |
| 231 namespaces_with_areas.insert(namespace_id); | |
| 232 int64 map_id; | |
| 233 bool conversion_ok = base::StringToInt64(it->second, &map_id); | |
| 234 ASSERT_TRUE(conversion_ok); | |
| 235 ASSERT_GE(map_id, 0); | |
| 236 ++expected_map_refcounts[map_id]; | |
| 237 max_map_id = std::max(map_id, max_map_id); | |
| 238 ++valid_keys; | |
| 239 } | |
| 240 } | |
| 241 // Check that there are no leftover "namespace-namespaceid-" keys without | |
| 242 // associated areas. | |
| 243 ASSERT_EQ(found_namespace_ids.size(), namespaces_with_areas.size()); | |
| 244 | |
| 245 if (max_map_id != -1) { | |
| 246 // The database contains maps. | |
| 247 ASSERT_TRUE(data.find(next_map_id_key) != data.end()); | |
| 248 int64 next_map_id; | |
| 249 bool conversion_ok = | |
| 250 base::StringToInt64(data[next_map_id_key], &next_map_id); | |
| 251 ASSERT_TRUE(conversion_ok); | |
| 252 ASSERT_GT(next_map_id, max_map_id); | |
| 253 } | |
| 254 | |
| 255 // Iterate the "map-" keys. | |
| 256 std::set<int64> found_map_ids; | |
| 257 for (DataMap::const_iterator it = data.begin(); it != data.end(); ++it) { | |
| 258 int64 map_id; | |
| 259 if (IsMapRefCountKey(it->first, &map_id)) { | |
| 260 int64 ref_count; | |
| 261 bool conversion_ok = base::StringToInt64(it->second, &ref_count); | |
| 262 ASSERT_TRUE(conversion_ok); | |
| 263 // Check that the map is not stale. | |
| 264 ASSERT_GT(ref_count, 0); | |
| 265 ASSERT_TRUE(expected_map_refcounts.find(map_id) != | |
| 266 expected_map_refcounts.end()); | |
| 267 ASSERT_EQ(expected_map_refcounts[map_id], ref_count); | |
| 268 // Mark the map as existing. | |
| 269 expected_map_refcounts.erase(map_id); | |
| 270 found_map_ids.insert(map_id); | |
| 271 ++valid_keys; | |
| 272 } else if (IsMapValueKey(it->first, &map_id)) { | |
| 273 ASSERT_TRUE(found_map_ids.find(map_id) != found_map_ids.end()); | |
| 274 ++valid_keys; | |
| 275 } | |
| 276 } | |
| 277 // Check that all maps referred to exist. | |
| 278 ASSERT_TRUE(expected_map_refcounts.empty()); | |
| 279 | |
| 280 if (data.find(next_map_id_key) != data.end()) | |
| 281 ++valid_keys; | |
| 282 | |
| 283 ASSERT_EQ(data.size(), valid_keys); | |
| 284 } | |
| 285 | |
| 286 void SessionStorageDatabaseTest::CheckEmptyDatabase() const { | |
| 287 DataMap data; | |
| 288 ReadData(&data); | |
| 289 size_t valid_keys = 0; | |
| 290 if (data.find(SessionStorageDatabase::NamespacePrefix()) != data.end()) | |
| 291 ++valid_keys; | |
| 292 if (data.find(SessionStorageDatabase::NextMapIdKey()) != data.end()) | |
| 293 ++valid_keys; | |
| 294 EXPECT_EQ(valid_keys, data.size()); | |
| 295 } | |
| 296 | |
| 297 void SessionStorageDatabaseTest::DumpData() const { | |
| 298 LOG(WARNING) << "---- Session storage contents"; | |
| 299 scoped_ptr<leveldb::Iterator> it( | |
| 300 db_->db_->NewIterator(leveldb::ReadOptions())); | |
| 301 for (it->SeekToFirst(); it->Valid(); it->Next()) { | |
| 302 int64 dummy_map_id; | |
| 303 if (IsMapValueKey(it->key().ToString(), &dummy_map_id)) { | |
| 304 // Convert the value back to base::string16. | |
| 305 base::string16 value; | |
| 306 size_t len = it->value().size() / sizeof(char16); | |
| 307 value.resize(len); | |
| 308 value.assign(reinterpret_cast<const char16*>(it->value().data()), len); | |
| 309 LOG(WARNING) << it->key().ToString() << ": " << value; | |
| 310 } else { | |
| 311 LOG(WARNING) << it->key().ToString() << ": " << it->value().ToString(); | |
| 312 } | |
| 313 } | |
| 314 LOG(WARNING) << "----"; | |
| 315 } | |
| 316 | |
| 317 void SessionStorageDatabaseTest::CheckAreaData( | |
| 318 const std::string& namespace_id, const GURL& origin, | |
| 319 const ValuesMap& reference) const { | |
| 320 ValuesMap values; | |
| 321 db_->ReadAreaValues(namespace_id, origin, &values); | |
| 322 CompareValuesMaps(values, reference); | |
| 323 } | |
| 324 | |
| 325 void SessionStorageDatabaseTest::CompareValuesMaps( | |
| 326 const ValuesMap& map1, | |
| 327 const ValuesMap& map2) const { | |
| 328 ASSERT_EQ(map2.size(), map1.size()); | |
| 329 for (ValuesMap::const_iterator it = map1.begin(); it != map1.end(); ++it) { | |
| 330 base::string16 key = it->first; | |
| 331 ASSERT_TRUE(map2.find(key) != map2.end()); | |
| 332 base::NullableString16 val1 = it->second; | |
| 333 base::NullableString16 val2 = map2.find(key)->second; | |
| 334 EXPECT_EQ(val2.is_null(), val1.is_null()); | |
| 335 EXPECT_EQ(val2.string(), val1.string()); | |
| 336 } | |
| 337 } | |
| 338 | |
| 339 void SessionStorageDatabaseTest::CheckNamespaceIds( | |
| 340 const std::set<std::string>& expected_namespace_ids) const { | |
| 341 std::map<std::string, std::vector<GURL> > namespaces_and_origins; | |
| 342 EXPECT_TRUE(db_->ReadNamespacesAndOrigins(&namespaces_and_origins)); | |
| 343 EXPECT_EQ(expected_namespace_ids.size(), namespaces_and_origins.size()); | |
| 344 for (std::map<std::string, std::vector<GURL> >::const_iterator it = | |
| 345 namespaces_and_origins.begin(); | |
| 346 it != namespaces_and_origins.end(); ++it) { | |
| 347 EXPECT_TRUE(expected_namespace_ids.find(it->first) != | |
| 348 expected_namespace_ids.end()); | |
| 349 } | |
| 350 } | |
| 351 | |
| 352 void SessionStorageDatabaseTest::CheckOrigins( | |
| 353 const std::string& namespace_id, | |
| 354 const std::set<GURL>& expected_origins) const { | |
| 355 std::map<std::string, std::vector<GURL> > namespaces_and_origins; | |
| 356 EXPECT_TRUE(db_->ReadNamespacesAndOrigins(&namespaces_and_origins)); | |
| 357 const std::vector<GURL>& origins = namespaces_and_origins[namespace_id]; | |
| 358 EXPECT_EQ(expected_origins.size(), origins.size()); | |
| 359 for (std::vector<GURL>::const_iterator it = origins.begin(); | |
| 360 it != origins.end(); ++it) { | |
| 361 EXPECT_TRUE(expected_origins.find(*it) != expected_origins.end()); | |
| 362 } | |
| 363 } | |
| 364 | |
| 365 std::string SessionStorageDatabaseTest::GetMapForArea( | |
| 366 const std::string& namespace_id, const GURL& origin) const { | |
| 367 bool exists; | |
| 368 std::string map_id; | |
| 369 EXPECT_TRUE(db_->GetMapForArea(namespace_id, origin.spec(), | |
| 370 leveldb::ReadOptions(), &exists, &map_id)); | |
| 371 EXPECT_TRUE(exists); | |
| 372 return map_id; | |
| 373 } | |
| 374 | |
| 375 int64 SessionStorageDatabaseTest::GetMapRefCount( | |
| 376 const std::string& map_id) const { | |
| 377 int64 ref_count; | |
| 378 EXPECT_TRUE(db_->GetMapRefCount(map_id, &ref_count)); | |
| 379 return ref_count; | |
| 380 } | |
| 381 | |
| 382 TEST_F(SessionStorageDatabaseTest, EmptyDatabaseSanityCheck) { | |
| 383 // An empty database should be valid. | |
| 384 CheckDatabaseConsistency(); | |
| 385 } | |
| 386 | |
| 387 TEST_F(SessionStorageDatabaseTest, WriteDataForOneOrigin) { | |
| 388 // Keep track on what the values should look like. | |
| 389 ValuesMap reference; | |
| 390 // Write data. | |
| 391 { | |
| 392 ValuesMap changes; | |
| 393 changes[kKey1] = kValue1; | |
| 394 changes[kKey2] = kValue2; | |
| 395 changes[kKey3] = kValue3; | |
| 396 reference[kKey1] = kValue1; | |
| 397 reference[kKey2] = kValue2; | |
| 398 reference[kKey3] = kValue3; | |
| 399 EXPECT_TRUE(db_->CommitAreaChanges(kNamespace1, kOrigin1, false, changes)); | |
| 400 } | |
| 401 CheckDatabaseConsistency(); | |
| 402 CheckAreaData(kNamespace1, kOrigin1, reference); | |
| 403 | |
| 404 // Overwrite and delete values. | |
| 405 { | |
| 406 ValuesMap changes; | |
| 407 changes[kKey1] = kValue4; | |
| 408 changes[kKey3] = kValueNull; | |
| 409 reference[kKey1] = kValue4; | |
| 410 reference.erase(kKey3); | |
| 411 EXPECT_TRUE(db_->CommitAreaChanges(kNamespace1, kOrigin1, false, changes)); | |
| 412 } | |
| 413 CheckDatabaseConsistency(); | |
| 414 CheckAreaData(kNamespace1, kOrigin1, reference); | |
| 415 | |
| 416 // Clear data before writing. | |
| 417 { | |
| 418 ValuesMap changes; | |
| 419 changes[kKey2] = kValue2; | |
| 420 reference.erase(kKey1); | |
| 421 reference[kKey2] = kValue2; | |
| 422 EXPECT_TRUE(db_->CommitAreaChanges(kNamespace1, kOrigin1, true, changes)); | |
| 423 } | |
| 424 CheckDatabaseConsistency(); | |
| 425 CheckAreaData(kNamespace1, kOrigin1, reference); | |
| 426 } | |
| 427 | |
| 428 TEST_F(SessionStorageDatabaseTest, WriteDataForTwoOrigins) { | |
| 429 // Write data. | |
| 430 ValuesMap data1; | |
| 431 data1[kKey1] = kValue1; | |
| 432 data1[kKey2] = kValue2; | |
| 433 data1[kKey3] = kValue3; | |
| 434 EXPECT_TRUE(db_->CommitAreaChanges(kNamespace1, kOrigin1, false, data1)); | |
| 435 | |
| 436 ValuesMap data2; | |
| 437 data2[kKey1] = kValue4; | |
| 438 data2[kKey2] = kValue1; | |
| 439 data2[kKey3] = kValue2; | |
| 440 EXPECT_TRUE(db_->CommitAreaChanges(kNamespace1, kOrigin2, false, data2)); | |
| 441 | |
| 442 CheckDatabaseConsistency(); | |
| 443 CheckAreaData(kNamespace1, kOrigin1, data1); | |
| 444 CheckAreaData(kNamespace1, kOrigin2, data2); | |
| 445 } | |
| 446 | |
| 447 TEST_F(SessionStorageDatabaseTest, WriteDataForTwoNamespaces) { | |
| 448 // Write data. | |
| 449 ValuesMap data11; | |
| 450 data11[kKey1] = kValue1; | |
| 451 data11[kKey2] = kValue2; | |
| 452 data11[kKey3] = kValue3; | |
| 453 EXPECT_TRUE(db_->CommitAreaChanges(kNamespace1, kOrigin1, false, data11)); | |
| 454 ValuesMap data12; | |
| 455 data12[kKey2] = kValue4; | |
| 456 data12[kKey3] = kValue3; | |
| 457 EXPECT_TRUE(db_->CommitAreaChanges(kNamespace1, kOrigin2, false, data12)); | |
| 458 ValuesMap data21; | |
| 459 data21[kKey1] = kValue2; | |
| 460 data21[kKey2] = kValue4; | |
| 461 EXPECT_TRUE(db_->CommitAreaChanges(kNamespace2, kOrigin1, false, data21)); | |
| 462 ValuesMap data22; | |
| 463 data22[kKey2] = kValue1; | |
| 464 data22[kKey3] = kValue2; | |
| 465 EXPECT_TRUE(db_->CommitAreaChanges(kNamespace2, kOrigin2, false, data22)); | |
| 466 CheckDatabaseConsistency(); | |
| 467 CheckAreaData(kNamespace1, kOrigin1, data11); | |
| 468 CheckAreaData(kNamespace1, kOrigin2, data12); | |
| 469 CheckAreaData(kNamespace2, kOrigin1, data21); | |
| 470 CheckAreaData(kNamespace2, kOrigin2, data22); | |
| 471 } | |
| 472 | |
| 473 TEST_F(SessionStorageDatabaseTest, ShallowCopy) { | |
| 474 // Write data for a namespace, for 2 origins. | |
| 475 ValuesMap data1; | |
| 476 data1[kKey1] = kValue1; | |
| 477 data1[kKey2] = kValue2; | |
| 478 data1[kKey3] = kValue3; | |
| 479 ASSERT_TRUE(db_->CommitAreaChanges(kNamespace1, kOrigin1, false, data1)); | |
| 480 ValuesMap data2; | |
| 481 data2[kKey1] = kValue2; | |
| 482 data2[kKey3] = kValue1; | |
| 483 ASSERT_TRUE(db_->CommitAreaChanges(kNamespace1, kOrigin2, false, data2)); | |
| 484 // Make a shallow copy. | |
| 485 EXPECT_TRUE(db_->CloneNamespace(kNamespace1, kNamespaceClone)); | |
| 486 // Now both namespaces should have the same data. | |
| 487 CheckDatabaseConsistency(); | |
| 488 CheckAreaData(kNamespace1, kOrigin1, data1); | |
| 489 CheckAreaData(kNamespace1, kOrigin2, data2); | |
| 490 CheckAreaData(kNamespaceClone, kOrigin1, data1); | |
| 491 CheckAreaData(kNamespaceClone, kOrigin2, data2); | |
| 492 // Both the namespaces refer to the same maps. | |
| 493 EXPECT_EQ(GetMapForArea(kNamespace1, kOrigin1), | |
| 494 GetMapForArea(kNamespaceClone, kOrigin1)); | |
| 495 EXPECT_EQ(GetMapForArea(kNamespace1, kOrigin2), | |
| 496 GetMapForArea(kNamespaceClone, kOrigin2)); | |
| 497 EXPECT_EQ(2, GetMapRefCount(GetMapForArea(kNamespace1, kOrigin1))); | |
| 498 EXPECT_EQ(2, GetMapRefCount(GetMapForArea(kNamespace1, kOrigin2))); | |
| 499 } | |
| 500 | |
| 501 TEST_F(SessionStorageDatabaseTest, WriteIntoShallowCopy) { | |
| 502 ValuesMap data1; | |
| 503 data1[kKey1] = kValue1; | |
| 504 data1[kKey2] = kValue2; | |
| 505 ASSERT_TRUE(db_->CommitAreaChanges(kNamespace1, kOrigin1, false, data1)); | |
| 506 EXPECT_TRUE(db_->CloneNamespace(kNamespace1, kNamespaceClone)); | |
| 507 | |
| 508 // Write data into a shallow copy. | |
| 509 ValuesMap changes; | |
| 510 ValuesMap reference; | |
| 511 changes[kKey1] = kValueNull; | |
| 512 changes[kKey2] = kValue4; | |
| 513 changes[kKey3] = kValue4; | |
| 514 reference[kKey2] = kValue4; | |
| 515 reference[kKey3] = kValue4; | |
| 516 EXPECT_TRUE(db_->CommitAreaChanges(kNamespaceClone, kOrigin1, false, | |
| 517 changes)); | |
| 518 | |
| 519 // Values in the original namespace were not changed. | |
| 520 CheckAreaData(kNamespace1, kOrigin1, data1); | |
| 521 // But values in the copy were. | |
| 522 CheckAreaData(kNamespaceClone, kOrigin1, reference); | |
| 523 | |
| 524 // The namespaces no longer refer to the same map. | |
| 525 EXPECT_NE(GetMapForArea(kNamespace1, kOrigin1), | |
| 526 GetMapForArea(kNamespaceClone, kOrigin1)); | |
| 527 EXPECT_EQ(1, GetMapRefCount(GetMapForArea(kNamespace1, kOrigin1))); | |
| 528 EXPECT_EQ(1, GetMapRefCount(GetMapForArea(kNamespaceClone, kOrigin1))); | |
| 529 } | |
| 530 | |
| 531 TEST_F(SessionStorageDatabaseTest, ManyShallowCopies) { | |
| 532 // Write data for a namespace, for 2 origins. | |
| 533 ValuesMap data1; | |
| 534 data1[kKey1] = kValue1; | |
| 535 data1[kKey2] = kValue2; | |
| 536 data1[kKey3] = kValue3; | |
| 537 ASSERT_TRUE(db_->CommitAreaChanges(kNamespace1, kOrigin1, false, data1)); | |
| 538 ValuesMap data2; | |
| 539 data2[kKey1] = kValue2; | |
| 540 data2[kKey3] = kValue1; | |
| 541 ASSERT_TRUE(db_->CommitAreaChanges(kNamespace1, kOrigin2, false, data2)); | |
| 542 | |
| 543 // Make a two shallow copies. | |
| 544 EXPECT_TRUE(db_->CloneNamespace(kNamespace1, kNamespaceClone)); | |
| 545 std::string another_clone("another_cloned"); | |
| 546 EXPECT_TRUE(db_->CloneNamespace(kNamespace1, another_clone)); | |
| 547 | |
| 548 // Make a shallow copy of a shallow copy. | |
| 549 std::string clone_of_clone("clone_of_clone"); | |
| 550 EXPECT_TRUE(db_->CloneNamespace(another_clone, clone_of_clone)); | |
| 551 | |
| 552 // Now all namespaces should have the same data. | |
| 553 CheckDatabaseConsistency(); | |
| 554 CheckAreaData(kNamespace1, kOrigin1, data1); | |
| 555 CheckAreaData(kNamespaceClone, kOrigin1, data1); | |
| 556 CheckAreaData(another_clone, kOrigin1, data1); | |
| 557 CheckAreaData(clone_of_clone, kOrigin1, data1); | |
| 558 CheckAreaData(kNamespace1, kOrigin2, data2); | |
| 559 CheckAreaData(kNamespaceClone, kOrigin2, data2); | |
| 560 CheckAreaData(another_clone, kOrigin2, data2); | |
| 561 CheckAreaData(clone_of_clone, kOrigin2, data2); | |
| 562 | |
| 563 // All namespaces refer to the same maps. | |
| 564 EXPECT_EQ(GetMapForArea(kNamespace1, kOrigin1), | |
| 565 GetMapForArea(kNamespaceClone, kOrigin1)); | |
| 566 EXPECT_EQ(GetMapForArea(kNamespace1, kOrigin2), | |
| 567 GetMapForArea(kNamespaceClone, kOrigin2)); | |
| 568 EXPECT_EQ(GetMapForArea(kNamespace1, kOrigin1), | |
| 569 GetMapForArea(another_clone, kOrigin1)); | |
| 570 EXPECT_EQ(GetMapForArea(kNamespace1, kOrigin2), | |
| 571 GetMapForArea(another_clone, kOrigin2)); | |
| 572 EXPECT_EQ(GetMapForArea(kNamespace1, kOrigin1), | |
| 573 GetMapForArea(clone_of_clone, kOrigin1)); | |
| 574 EXPECT_EQ(GetMapForArea(kNamespace1, kOrigin2), | |
| 575 GetMapForArea(clone_of_clone, kOrigin2)); | |
| 576 | |
| 577 // Check the ref counts. | |
| 578 EXPECT_EQ(4, GetMapRefCount(GetMapForArea(kNamespace1, kOrigin1))); | |
| 579 EXPECT_EQ(4, GetMapRefCount(GetMapForArea(kNamespace1, kOrigin2))); | |
| 580 } | |
| 581 | |
| 582 TEST_F(SessionStorageDatabaseTest, DisassociateShallowCopy) { | |
| 583 ValuesMap data1; | |
| 584 data1[kKey1] = kValue1; | |
| 585 data1[kKey2] = kValue2; | |
| 586 ASSERT_TRUE(db_->CommitAreaChanges(kNamespace1, kOrigin1, false, data1)); | |
| 587 EXPECT_TRUE(db_->CloneNamespace(kNamespace1, kNamespaceClone)); | |
| 588 | |
| 589 // Disassoaciate the shallow copy. | |
| 590 EXPECT_TRUE(db_->DeleteArea(kNamespaceClone, kOrigin1)); | |
| 591 CheckDatabaseConsistency(); | |
| 592 | |
| 593 // Now new data can be written to that map. | |
| 594 ValuesMap reference; | |
| 595 ValuesMap changes; | |
| 596 changes[kKey1] = kValueNull; | |
| 597 changes[kKey2] = kValue4; | |
| 598 changes[kKey3] = kValue4; | |
| 599 reference[kKey2] = kValue4; | |
| 600 reference[kKey3] = kValue4; | |
| 601 EXPECT_TRUE(db_->CommitAreaChanges(kNamespaceClone, kOrigin1, false, | |
| 602 changes)); | |
| 603 | |
| 604 // Values in the original map were not changed. | |
| 605 CheckAreaData(kNamespace1, kOrigin1, data1); | |
| 606 | |
| 607 // But values in the disassociated map were. | |
| 608 CheckAreaData(kNamespaceClone, kOrigin1, reference); | |
| 609 } | |
| 610 | |
| 611 TEST_F(SessionStorageDatabaseTest, DeleteNamespace) { | |
| 612 ValuesMap data1; | |
| 613 data1[kKey1] = kValue1; | |
| 614 data1[kKey2] = kValue2; | |
| 615 data1[kKey3] = kValue3; | |
| 616 ASSERT_TRUE(db_->CommitAreaChanges(kNamespace1, kOrigin1, false, data1)); | |
| 617 ValuesMap data2; | |
| 618 data2[kKey2] = kValue4; | |
| 619 data2[kKey3] = kValue3; | |
| 620 ASSERT_TRUE(db_->CommitAreaChanges(kNamespace1, kOrigin2, false, data2)); | |
| 621 EXPECT_TRUE(db_->DeleteNamespace(kNamespace1)); | |
| 622 CheckDatabaseConsistency(); | |
| 623 CheckEmptyDatabase(); | |
| 624 } | |
| 625 | |
| 626 TEST_F(SessionStorageDatabaseTest, DeleteNamespaceWithShallowCopy) { | |
| 627 // Write data for a namespace, for 2 origins. | |
| 628 ValuesMap data1; | |
| 629 data1[kKey1] = kValue1; | |
| 630 data1[kKey2] = kValue2; | |
| 631 data1[kKey3] = kValue3; | |
| 632 ASSERT_TRUE(db_->CommitAreaChanges(kNamespace1, kOrigin1, false, data1)); | |
| 633 ValuesMap data2; | |
| 634 data2[kKey1] = kValue2; | |
| 635 data2[kKey3] = kValue1; | |
| 636 ASSERT_TRUE(db_->CommitAreaChanges(kNamespace1, kOrigin2, false, data2)); | |
| 637 | |
| 638 // Make a shallow copy and delete the original namespace. | |
| 639 EXPECT_TRUE(db_->CloneNamespace(kNamespace1, kNamespaceClone)); | |
| 640 EXPECT_TRUE(db_->DeleteNamespace(kNamespace1)); | |
| 641 | |
| 642 // The original namespace has no data. | |
| 643 CheckDatabaseConsistency(); | |
| 644 CheckAreaData(kNamespace1, kOrigin1, ValuesMap()); | |
| 645 CheckAreaData(kNamespace1, kOrigin2, ValuesMap()); | |
| 646 // But the copy persists. | |
| 647 CheckAreaData(kNamespaceClone, kOrigin1, data1); | |
| 648 CheckAreaData(kNamespaceClone, kOrigin2, data2); | |
| 649 } | |
| 650 | |
| 651 TEST_F(SessionStorageDatabaseTest, DeleteArea) { | |
| 652 // Write data for a namespace, for 2 origins. | |
| 653 ValuesMap data1; | |
| 654 data1[kKey1] = kValue1; | |
| 655 data1[kKey2] = kValue2; | |
| 656 data1[kKey3] = kValue3; | |
| 657 ASSERT_TRUE(db_->CommitAreaChanges(kNamespace1, kOrigin1, false, data1)); | |
| 658 ValuesMap data2; | |
| 659 data2[kKey1] = kValue2; | |
| 660 data2[kKey3] = kValue1; | |
| 661 ASSERT_TRUE(db_->CommitAreaChanges(kNamespace1, kOrigin2, false, data2)); | |
| 662 | |
| 663 EXPECT_TRUE(db_->DeleteArea(kNamespace1, kOrigin2)); | |
| 664 CheckDatabaseConsistency(); | |
| 665 // The data for the non-deleted origin persists. | |
| 666 CheckAreaData(kNamespace1, kOrigin1, data1); | |
| 667 // The data for the deleted origin is gone. | |
| 668 CheckAreaData(kNamespace1, kOrigin2, ValuesMap()); | |
| 669 } | |
| 670 | |
| 671 TEST_F(SessionStorageDatabaseTest, DeleteAreaWithShallowCopy) { | |
| 672 // Write data for a namespace, for 2 origins. | |
| 673 ValuesMap data1; | |
| 674 data1[kKey1] = kValue1; | |
| 675 data1[kKey2] = kValue2; | |
| 676 data1[kKey3] = kValue3; | |
| 677 ASSERT_TRUE(db_->CommitAreaChanges(kNamespace1, kOrigin1, false, data1)); | |
| 678 ValuesMap data2; | |
| 679 data2[kKey1] = kValue2; | |
| 680 data2[kKey3] = kValue1; | |
| 681 ASSERT_TRUE(db_->CommitAreaChanges(kNamespace1, kOrigin2, false, data2)); | |
| 682 | |
| 683 // Make a shallow copy and delete an origin from the original namespace. | |
| 684 EXPECT_TRUE(db_->CloneNamespace(kNamespace1, kNamespaceClone)); | |
| 685 EXPECT_TRUE(db_->DeleteArea(kNamespace1, kOrigin1)); | |
| 686 CheckDatabaseConsistency(); | |
| 687 | |
| 688 // The original namespace has data for only the non-deleted origin. | |
| 689 CheckAreaData(kNamespace1, kOrigin1, ValuesMap()); | |
| 690 CheckAreaData(kNamespace1, kOrigin2, data2); | |
| 691 // But the copy persists. | |
| 692 CheckAreaData(kNamespaceClone, kOrigin1, data1); | |
| 693 CheckAreaData(kNamespaceClone, kOrigin2, data2); | |
| 694 } | |
| 695 | |
| 696 TEST_F(SessionStorageDatabaseTest, WriteRawBytes) { | |
| 697 // Write data which is not valid utf8 and contains null bytes. | |
| 698 unsigned char raw_data[10] = {255, 0, 0, 0, 1, 2, 3, 4, 5, 0}; | |
| 699 ValuesMap changes; | |
| 700 base::string16 string_with_raw_data; | |
| 701 string_with_raw_data.assign(reinterpret_cast<char16*>(raw_data), 5); | |
| 702 changes[kKey1] = base::NullableString16(string_with_raw_data, false); | |
| 703 EXPECT_TRUE(db_->CommitAreaChanges(kNamespace1, kOrigin1, false, changes)); | |
| 704 CheckDatabaseConsistency(); | |
| 705 ValuesMap values; | |
| 706 db_->ReadAreaValues(kNamespace1, kOrigin1, &values); | |
| 707 const unsigned char* data = | |
| 708 reinterpret_cast<const unsigned char*>(values[kKey1].string().data()); | |
| 709 for (int i = 0; i < 10; ++i) | |
| 710 EXPECT_EQ(raw_data[i], data[i]); | |
| 711 } | |
| 712 | |
| 713 TEST_F(SessionStorageDatabaseTest, DeleteNamespaceConfusion) { | |
| 714 // Regression test for a bug where a namespace with id 10 prevented deleting | |
| 715 // the namespace with id 1. | |
| 716 | |
| 717 ValuesMap data1; | |
| 718 data1[kKey1] = kValue1; | |
| 719 ASSERT_TRUE(db_->CommitAreaChanges("foobar", kOrigin1, false, data1)); | |
| 720 ASSERT_TRUE(db_->CommitAreaChanges("foobarbaz", kOrigin1, false, data1)); | |
| 721 | |
| 722 // Delete the namespace with ID 1. | |
| 723 EXPECT_TRUE(db_->DeleteNamespace("foobar")); | |
| 724 } | |
| 725 | |
| 726 TEST_F(SessionStorageDatabaseTest, ReadNamespaceIds) { | |
| 727 ValuesMap data1; | |
| 728 data1[kKey1] = kValue1; | |
| 729 data1[kKey2] = kValue2; | |
| 730 data1[kKey3] = kValue3; | |
| 731 std::set<std::string> expected_namespace_ids; | |
| 732 | |
| 733 ASSERT_TRUE(db_->CommitAreaChanges(kNamespace1, kOrigin1, false, data1)); | |
| 734 expected_namespace_ids.insert(kNamespace1); | |
| 735 CheckNamespaceIds(expected_namespace_ids); | |
| 736 | |
| 737 ASSERT_TRUE(db_->CloneNamespace(kNamespace1, kNamespaceClone)); | |
| 738 expected_namespace_ids.insert(kNamespaceClone); | |
| 739 CheckNamespaceIds(expected_namespace_ids); | |
| 740 | |
| 741 ASSERT_TRUE(db_->DeleteNamespace(kNamespace1)); | |
| 742 expected_namespace_ids.erase(kNamespace1); | |
| 743 CheckNamespaceIds(expected_namespace_ids); | |
| 744 | |
| 745 CheckDatabaseConsistency(); | |
| 746 } | |
| 747 | |
| 748 TEST_F(SessionStorageDatabaseTest, ReadNamespaceIdsInEmptyDatabase) { | |
| 749 std::set<std::string> expected_namespace_ids; | |
| 750 CheckNamespaceIds(expected_namespace_ids); | |
| 751 } | |
| 752 | |
| 753 TEST_F(SessionStorageDatabaseTest, ReadOriginsInNamespace) { | |
| 754 ValuesMap data1; | |
| 755 data1[kKey1] = kValue1; | |
| 756 data1[kKey2] = kValue2; | |
| 757 data1[kKey3] = kValue3; | |
| 758 | |
| 759 std::set<GURL> expected_origins1; | |
| 760 ASSERT_TRUE(db_->CommitAreaChanges(kNamespace1, kOrigin1, false, data1)); | |
| 761 ASSERT_TRUE(db_->CommitAreaChanges(kNamespace1, kOrigin2, false, data1)); | |
| 762 expected_origins1.insert(kOrigin1); | |
| 763 expected_origins1.insert(kOrigin2); | |
| 764 CheckOrigins(kNamespace1, expected_origins1); | |
| 765 | |
| 766 std::set<GURL> expected_origins2; | |
| 767 ASSERT_TRUE(db_->CommitAreaChanges(kNamespace2, kOrigin2, false, data1)); | |
| 768 expected_origins2.insert(kOrigin2); | |
| 769 CheckOrigins(kNamespace2, expected_origins2); | |
| 770 | |
| 771 ASSERT_TRUE(db_->CloneNamespace(kNamespace1, kNamespaceClone)); | |
| 772 CheckOrigins(kNamespaceClone, expected_origins1); | |
| 773 | |
| 774 ASSERT_TRUE(db_->DeleteArea(kNamespace1, kOrigin2)); | |
| 775 expected_origins1.erase(kOrigin2); | |
| 776 CheckOrigins(kNamespace1, expected_origins1); | |
| 777 | |
| 778 CheckDatabaseConsistency(); | |
| 779 } | |
| 780 | |
| 781 TEST_F(SessionStorageDatabaseTest, DeleteAllOrigins) { | |
| 782 // Write data for a namespace, for 2 origins. | |
| 783 ValuesMap data1; | |
| 784 data1[kKey1] = kValue1; | |
| 785 ASSERT_TRUE(db_->CommitAreaChanges(kNamespace1, kOrigin1, false, data1)); | |
| 786 ValuesMap data2; | |
| 787 data2[kKey1] = kValue2; | |
| 788 ASSERT_TRUE(db_->CommitAreaChanges(kNamespace1, kOrigin2, false, data2)); | |
| 789 | |
| 790 EXPECT_TRUE(db_->DeleteArea(kNamespace1, kOrigin1)); | |
| 791 EXPECT_TRUE(db_->DeleteArea(kNamespace1, kOrigin2)); | |
| 792 // Check that also the namespace start key was deleted. | |
| 793 CheckDatabaseConsistency(); | |
| 794 } | |
| 795 | |
| 796 | |
| 797 } // namespace dom_storage | |
| OLD | NEW |