| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 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 | 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 "base/file_util.h" | 5 #include "base/file_util.h" |
| 6 #include "base/files/scoped_temp_dir.h" | 6 #include "base/files/scoped_temp_dir.h" |
| 7 #include "base/test/test_simple_task_runner.h" | 7 #include "base/test/test_simple_task_runner.h" |
| 8 #include "base/threading/thread.h" | 8 #include "base/threading/thread.h" |
| 9 #include "content/browser/browser_thread_impl.h" | 9 #include "content/browser/browser_thread_impl.h" |
| 10 #include "content/browser/indexed_db/indexed_db_connection.h" | 10 #include "content/browser/indexed_db/indexed_db_connection.h" |
| (...skipping 48 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 59 base::FilePath normal_path; | 59 base::FilePath normal_path; |
| 60 base::FilePath session_only_path; | 60 base::FilePath session_only_path; |
| 61 | 61 |
| 62 // Create the scope which will ensure we run the destructor of the context | 62 // Create the scope which will ensure we run the destructor of the context |
| 63 // which should trigger the clean up. | 63 // which should trigger the clean up. |
| 64 { | 64 { |
| 65 scoped_refptr<IndexedDBContextImpl> idb_context = new IndexedDBContextImpl( | 65 scoped_refptr<IndexedDBContextImpl> idb_context = new IndexedDBContextImpl( |
| 66 temp_dir.path(), special_storage_policy_, NULL, task_runner_); | 66 temp_dir.path(), special_storage_policy_, NULL, task_runner_); |
| 67 | 67 |
| 68 normal_path = idb_context->GetFilePathForTesting( | 68 normal_path = idb_context->GetFilePathForTesting( |
| 69 webkit_database::GetIdentifierFromOrigin(kNormalOrigin)); | 69 storage::GetIdentifierFromOrigin(kNormalOrigin)); |
| 70 session_only_path = idb_context->GetFilePathForTesting( | 70 session_only_path = idb_context->GetFilePathForTesting( |
| 71 webkit_database::GetIdentifierFromOrigin(kSessionOnlyOrigin)); | 71 storage::GetIdentifierFromOrigin(kSessionOnlyOrigin)); |
| 72 ASSERT_TRUE(base::CreateDirectory(normal_path)); | 72 ASSERT_TRUE(base::CreateDirectory(normal_path)); |
| 73 ASSERT_TRUE(base::CreateDirectory(session_only_path)); | 73 ASSERT_TRUE(base::CreateDirectory(session_only_path)); |
| 74 FlushIndexedDBTaskRunner(); | 74 FlushIndexedDBTaskRunner(); |
| 75 message_loop_.RunUntilIdle(); | 75 message_loop_.RunUntilIdle(); |
| 76 } | 76 } |
| 77 | 77 |
| 78 FlushIndexedDBTaskRunner(); | 78 FlushIndexedDBTaskRunner(); |
| 79 message_loop_.RunUntilIdle(); | 79 message_loop_.RunUntilIdle(); |
| 80 | 80 |
| 81 EXPECT_TRUE(base::DirectoryExists(normal_path)); | 81 EXPECT_TRUE(base::DirectoryExists(normal_path)); |
| (...skipping 11 matching lines...) Expand all Loading... |
| 93 { | 93 { |
| 94 // Create some indexedDB paths. | 94 // Create some indexedDB paths. |
| 95 // With the levelDB backend, these are directories. | 95 // With the levelDB backend, these are directories. |
| 96 scoped_refptr<IndexedDBContextImpl> idb_context = new IndexedDBContextImpl( | 96 scoped_refptr<IndexedDBContextImpl> idb_context = new IndexedDBContextImpl( |
| 97 temp_dir.path(), special_storage_policy_, NULL, task_runner_); | 97 temp_dir.path(), special_storage_policy_, NULL, task_runner_); |
| 98 | 98 |
| 99 // Save session state. This should bypass the destruction-time deletion. | 99 // Save session state. This should bypass the destruction-time deletion. |
| 100 idb_context->SetForceKeepSessionState(); | 100 idb_context->SetForceKeepSessionState(); |
| 101 | 101 |
| 102 normal_path = idb_context->GetFilePathForTesting( | 102 normal_path = idb_context->GetFilePathForTesting( |
| 103 webkit_database::GetIdentifierFromOrigin(kNormalOrigin)); | 103 storage::GetIdentifierFromOrigin(kNormalOrigin)); |
| 104 session_only_path = idb_context->GetFilePathForTesting( | 104 session_only_path = idb_context->GetFilePathForTesting( |
| 105 webkit_database::GetIdentifierFromOrigin(kSessionOnlyOrigin)); | 105 storage::GetIdentifierFromOrigin(kSessionOnlyOrigin)); |
| 106 ASSERT_TRUE(base::CreateDirectory(normal_path)); | 106 ASSERT_TRUE(base::CreateDirectory(normal_path)); |
| 107 ASSERT_TRUE(base::CreateDirectory(session_only_path)); | 107 ASSERT_TRUE(base::CreateDirectory(session_only_path)); |
| 108 message_loop_.RunUntilIdle(); | 108 message_loop_.RunUntilIdle(); |
| 109 } | 109 } |
| 110 | 110 |
| 111 // Make sure we wait until the destructor has run. | 111 // Make sure we wait until the destructor has run. |
| 112 message_loop_.RunUntilIdle(); | 112 message_loop_.RunUntilIdle(); |
| 113 | 113 |
| 114 // No data was cleared because of SetForceKeepSessionState. | 114 // No data was cleared because of SetForceKeepSessionState. |
| 115 EXPECT_TRUE(base::DirectoryExists(normal_path)); | 115 EXPECT_TRUE(base::DirectoryExists(normal_path)); |
| (...skipping 50 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 166 | 166 |
| 167 scoped_refptr<ForceCloseDBCallbacks> open_callbacks = | 167 scoped_refptr<ForceCloseDBCallbacks> open_callbacks = |
| 168 new ForceCloseDBCallbacks(idb_context, kTestOrigin); | 168 new ForceCloseDBCallbacks(idb_context, kTestOrigin); |
| 169 | 169 |
| 170 scoped_refptr<ForceCloseDBCallbacks> closed_callbacks = | 170 scoped_refptr<ForceCloseDBCallbacks> closed_callbacks = |
| 171 new ForceCloseDBCallbacks(idb_context, kTestOrigin); | 171 new ForceCloseDBCallbacks(idb_context, kTestOrigin); |
| 172 | 172 |
| 173 IndexedDBFactory* factory = idb_context->GetIDBFactory(); | 173 IndexedDBFactory* factory = idb_context->GetIDBFactory(); |
| 174 | 174 |
| 175 test_path = idb_context->GetFilePathForTesting( | 175 test_path = idb_context->GetFilePathForTesting( |
| 176 webkit_database::GetIdentifierFromOrigin(kTestOrigin)); | 176 storage::GetIdentifierFromOrigin(kTestOrigin)); |
| 177 | 177 |
| 178 IndexedDBPendingConnection open_connection(open_callbacks, | 178 IndexedDBPendingConnection open_connection(open_callbacks, |
| 179 open_db_callbacks, | 179 open_db_callbacks, |
| 180 0 /* child_process_id */, | 180 0 /* child_process_id */, |
| 181 0 /* host_transaction_id */, | 181 0 /* host_transaction_id */, |
| 182 0 /* version */); | 182 0 /* version */); |
| 183 factory->Open(base::ASCIIToUTF16("opendb"), | 183 factory->Open(base::ASCIIToUTF16("opendb"), |
| 184 open_connection, | 184 open_connection, |
| 185 NULL /* request_context */, | 185 NULL /* request_context */, |
| 186 kTestOrigin, | 186 kTestOrigin, |
| (...skipping 29 matching lines...) Expand all Loading... |
| 216 | 216 |
| 217 TEST_F(IndexedDBTest, DeleteFailsIfDirectoryLocked) { | 217 TEST_F(IndexedDBTest, DeleteFailsIfDirectoryLocked) { |
| 218 base::ScopedTempDir temp_dir; | 218 base::ScopedTempDir temp_dir; |
| 219 ASSERT_TRUE(temp_dir.CreateUniqueTempDir()); | 219 ASSERT_TRUE(temp_dir.CreateUniqueTempDir()); |
| 220 const GURL kTestOrigin("http://test/"); | 220 const GURL kTestOrigin("http://test/"); |
| 221 | 221 |
| 222 scoped_refptr<IndexedDBContextImpl> idb_context = new IndexedDBContextImpl( | 222 scoped_refptr<IndexedDBContextImpl> idb_context = new IndexedDBContextImpl( |
| 223 temp_dir.path(), special_storage_policy_, NULL, task_runner_); | 223 temp_dir.path(), special_storage_policy_, NULL, task_runner_); |
| 224 | 224 |
| 225 base::FilePath test_path = idb_context->GetFilePathForTesting( | 225 base::FilePath test_path = idb_context->GetFilePathForTesting( |
| 226 webkit_database::GetIdentifierFromOrigin(kTestOrigin)); | 226 storage::GetIdentifierFromOrigin(kTestOrigin)); |
| 227 ASSERT_TRUE(base::CreateDirectory(test_path)); | 227 ASSERT_TRUE(base::CreateDirectory(test_path)); |
| 228 | 228 |
| 229 scoped_ptr<LevelDBLock> lock = | 229 scoped_ptr<LevelDBLock> lock = |
| 230 LevelDBDatabase::LockForTesting(test_path); | 230 LevelDBDatabase::LockForTesting(test_path); |
| 231 ASSERT_TRUE(lock); | 231 ASSERT_TRUE(lock); |
| 232 | 232 |
| 233 idb_context->TaskRunner()->PostTask( | 233 idb_context->TaskRunner()->PostTask( |
| 234 FROM_HERE, | 234 FROM_HERE, |
| 235 base::Bind( | 235 base::Bind( |
| 236 &IndexedDBContextImpl::DeleteForOrigin, idb_context, kTestOrigin)); | 236 &IndexedDBContextImpl::DeleteForOrigin, idb_context, kTestOrigin)); |
| (...skipping 39 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 276 | 276 |
| 277 // Simulate the write failure. | 277 // Simulate the write failure. |
| 278 leveldb::Status status = leveldb::Status::IOError("Simulated failure"); | 278 leveldb::Status status = leveldb::Status::IOError("Simulated failure"); |
| 279 callbacks->connection()->database()->TransactionCommitFailed(status); | 279 callbacks->connection()->database()->TransactionCommitFailed(status); |
| 280 | 280 |
| 281 EXPECT_TRUE(db_callbacks->forced_close_called()); | 281 EXPECT_TRUE(db_callbacks->forced_close_called()); |
| 282 EXPECT_FALSE(factory->IsBackingStoreOpen(kTestOrigin)); | 282 EXPECT_FALSE(factory->IsBackingStoreOpen(kTestOrigin)); |
| 283 } | 283 } |
| 284 | 284 |
| 285 } // namespace content | 285 } // namespace content |
| OLD | NEW |