| 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_factory.h" | 5 #include "content/browser/indexed_db/indexed_db_factory.h" |
| 6 | 6 |
| 7 #include "base/logging.h" | 7 #include "base/logging.h" |
| 8 #include "base/strings/utf_string_conversions.h" | 8 #include "base/strings/utf_string_conversions.h" |
| 9 #include "content/browser/indexed_db/indexed_db_backing_store.h" | 9 #include "content/browser/indexed_db/indexed_db_backing_store.h" |
| 10 #include "content/browser/indexed_db/indexed_db_database.h" | 10 #include "content/browser/indexed_db/indexed_db_database.h" |
| (...skipping 39 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 50 database_backend_map_.erase(unique_identifier); | 50 database_backend_map_.erase(unique_identifier); |
| 51 } | 51 } |
| 52 | 52 |
| 53 void IndexedDBFactory::GetDatabaseNames( | 53 void IndexedDBFactory::GetDatabaseNames( |
| 54 scoped_refptr<IndexedDBCallbacksWrapper> callbacks, | 54 scoped_refptr<IndexedDBCallbacksWrapper> callbacks, |
| 55 const string16& database_identifier, | 55 const string16& database_identifier, |
| 56 const base::FilePath& data_directory) { | 56 const base::FilePath& data_directory) { |
| 57 IDB_TRACE("IndexedDBFactory::get_database_names"); | 57 IDB_TRACE("IndexedDBFactory::get_database_names"); |
| 58 scoped_refptr<IndexedDBBackingStore> backing_store = | 58 scoped_refptr<IndexedDBBackingStore> backing_store = |
| 59 OpenBackingStore(database_identifier, data_directory); | 59 OpenBackingStore(database_identifier, data_directory); |
| 60 if (!backing_store) { | 60 if (!backing_store.get()) { |
| 61 callbacks->OnError( | 61 callbacks->OnError( |
| 62 IndexedDBDatabaseError(WebKit::WebIDBDatabaseExceptionUnknownError, | 62 IndexedDBDatabaseError(WebKit::WebIDBDatabaseExceptionUnknownError, |
| 63 "Internal error opening backing store for " | 63 "Internal error opening backing store for " |
| 64 "indexedDB.webkitGetDatabaseNames.")); | 64 "indexedDB.webkitGetDatabaseNames.")); |
| 65 return; | 65 return; |
| 66 } | 66 } |
| 67 | 67 |
| 68 callbacks->OnSuccess(backing_store->GetDatabaseNames()); | 68 callbacks->OnSuccess(backing_store->GetDatabaseNames()); |
| 69 } | 69 } |
| 70 | 70 |
| (...skipping 11 matching lines...) Expand all Loading... |
| 82 if (it != database_backend_map_.end()) { | 82 if (it != database_backend_map_.end()) { |
| 83 // If there are any connections to the database, directly delete the | 83 // If there are any connections to the database, directly delete the |
| 84 // database. | 84 // database. |
| 85 it->second->DeleteDatabase(callbacks); | 85 it->second->DeleteDatabase(callbacks); |
| 86 return; | 86 return; |
| 87 } | 87 } |
| 88 | 88 |
| 89 // TODO(jsbell): Everything from now on should be done on another thread. | 89 // TODO(jsbell): Everything from now on should be done on another thread. |
| 90 scoped_refptr<IndexedDBBackingStore> backing_store = | 90 scoped_refptr<IndexedDBBackingStore> backing_store = |
| 91 OpenBackingStore(database_identifier, data_directory); | 91 OpenBackingStore(database_identifier, data_directory); |
| 92 if (!backing_store) { | 92 if (!backing_store.get()) { |
| 93 callbacks->OnError(IndexedDBDatabaseError( | 93 callbacks->OnError(IndexedDBDatabaseError( |
| 94 WebKit::WebIDBDatabaseExceptionUnknownError, | 94 WebKit::WebIDBDatabaseExceptionUnknownError, |
| 95 ASCIIToUTF16("Internal error opening backing store " | 95 ASCIIToUTF16("Internal error opening backing store " |
| 96 "for indexed_db.delete_database."))); | 96 "for indexed_db.delete_database."))); |
| 97 return; | 97 return; |
| 98 } | 98 } |
| 99 | 99 |
| 100 scoped_refptr<IndexedDBDatabase> database_backend = IndexedDBDatabase::Create( | 100 scoped_refptr<IndexedDBDatabase> database_backend = IndexedDBDatabase::Create( |
| 101 name, backing_store.get(), this, unique_identifier); | 101 name, backing_store.get(), this, unique_identifier); |
| 102 if (!database_backend) { | 102 if (!database_backend.get()) { |
| 103 callbacks->OnError(IndexedDBDatabaseError( | 103 callbacks->OnError(IndexedDBDatabaseError( |
| 104 WebKit::WebIDBDatabaseExceptionUnknownError, | 104 WebKit::WebIDBDatabaseExceptionUnknownError, |
| 105 ASCIIToUTF16("Internal error creating database backend for " | 105 ASCIIToUTF16("Internal error creating database backend for " |
| 106 "indexed_db.delete_database."))); | 106 "indexed_db.delete_database."))); |
| 107 return; | 107 return; |
| 108 } | 108 } |
| 109 | 109 |
| 110 database_backend_map_[unique_identifier] = database_backend.get(); | 110 database_backend_map_[unique_identifier] = database_backend.get(); |
| 111 database_backend->DeleteDatabase(callbacks); | 111 database_backend->DeleteDatabase(callbacks); |
| 112 database_backend_map_.erase(unique_identifier); | 112 database_backend_map_.erase(unique_identifier); |
| (...skipping 11 matching lines...) Expand all Loading... |
| 124 return it2->second.get(); | 124 return it2->second.get(); |
| 125 | 125 |
| 126 scoped_refptr<IndexedDBBackingStore> backing_store; | 126 scoped_refptr<IndexedDBBackingStore> backing_store; |
| 127 if (open_in_memory) { | 127 if (open_in_memory) { |
| 128 backing_store = IndexedDBBackingStore::OpenInMemory(file_identifier); | 128 backing_store = IndexedDBBackingStore::OpenInMemory(file_identifier); |
| 129 } else { | 129 } else { |
| 130 backing_store = IndexedDBBackingStore::Open( | 130 backing_store = IndexedDBBackingStore::Open( |
| 131 database_identifier, data_directory, file_identifier); | 131 database_identifier, data_directory, file_identifier); |
| 132 } | 132 } |
| 133 | 133 |
| 134 if (backing_store) { | 134 if (backing_store.get()) { |
| 135 CleanWeakMap(&backing_store_map_); | 135 CleanWeakMap(&backing_store_map_); |
| 136 backing_store_map_[file_identifier] = backing_store->GetWeakPtr(); | 136 backing_store_map_[file_identifier] = backing_store->GetWeakPtr(); |
| 137 // If an in-memory database, bind lifetime to this factory instance. | 137 // If an in-memory database, bind lifetime to this factory instance. |
| 138 if (open_in_memory) | 138 if (open_in_memory) |
| 139 session_only_backing_stores_.insert(backing_store); | 139 session_only_backing_stores_.insert(backing_store); |
| 140 | 140 |
| 141 // All backing stores associated with this factory should be of the same | 141 // All backing stores associated with this factory should be of the same |
| 142 // type. | 142 // type. |
| 143 DCHECK(session_only_backing_stores_.empty() || open_in_memory); | 143 DCHECK(session_only_backing_stores_.empty() || open_in_memory); |
| 144 | 144 |
| (...skipping 14 matching lines...) Expand all Loading... |
| 159 IDB_TRACE("IndexedDBFactory::open"); | 159 IDB_TRACE("IndexedDBFactory::open"); |
| 160 const string16 unique_identifier = | 160 const string16 unique_identifier = |
| 161 ComputeUniqueIdentifier(name, database_identifier); | 161 ComputeUniqueIdentifier(name, database_identifier); |
| 162 | 162 |
| 163 scoped_refptr<IndexedDBDatabase> database_backend; | 163 scoped_refptr<IndexedDBDatabase> database_backend; |
| 164 IndexedDBDatabaseMap::iterator it = | 164 IndexedDBDatabaseMap::iterator it = |
| 165 database_backend_map_.find(unique_identifier); | 165 database_backend_map_.find(unique_identifier); |
| 166 if (it == database_backend_map_.end()) { | 166 if (it == database_backend_map_.end()) { |
| 167 scoped_refptr<IndexedDBBackingStore> backing_store = | 167 scoped_refptr<IndexedDBBackingStore> backing_store = |
| 168 OpenBackingStore(database_identifier, data_directory); | 168 OpenBackingStore(database_identifier, data_directory); |
| 169 if (!backing_store) { | 169 if (!backing_store.get()) { |
| 170 callbacks->OnError(IndexedDBDatabaseError( | 170 callbacks->OnError(IndexedDBDatabaseError( |
| 171 WebKit::WebIDBDatabaseExceptionUnknownError, | 171 WebKit::WebIDBDatabaseExceptionUnknownError, |
| 172 ASCIIToUTF16( | 172 ASCIIToUTF16( |
| 173 "Internal error opening backing store for indexedDB.open."))); | 173 "Internal error opening backing store for indexedDB.open."))); |
| 174 return; | 174 return; |
| 175 } | 175 } |
| 176 | 176 |
| 177 database_backend = IndexedDBDatabase::Create( | 177 database_backend = IndexedDBDatabase::Create( |
| 178 name, backing_store.get(), this, unique_identifier); | 178 name, backing_store.get(), this, unique_identifier); |
| 179 if (!database_backend) { | 179 if (!database_backend.get()) { |
| 180 callbacks->OnError(IndexedDBDatabaseError( | 180 callbacks->OnError(IndexedDBDatabaseError( |
| 181 WebKit::WebIDBDatabaseExceptionUnknownError, | 181 WebKit::WebIDBDatabaseExceptionUnknownError, |
| 182 ASCIIToUTF16( | 182 ASCIIToUTF16( |
| 183 "Internal error creating database backend for indexedDB.open."))); | 183 "Internal error creating database backend for indexedDB.open."))); |
| 184 return; | 184 return; |
| 185 } | 185 } |
| 186 | 186 |
| 187 database_backend_map_[unique_identifier] = database_backend.get(); | 187 database_backend_map_[unique_identifier] = database_backend.get(); |
| 188 } else { | 188 } else { |
| 189 database_backend = it->second; | 189 database_backend = it->second; |
| 190 } | 190 } |
| 191 | 191 |
| 192 database_backend->OpenConnection( | 192 database_backend->OpenConnection( |
| 193 callbacks, database_callbacks, transaction_id, version); | 193 callbacks, database_callbacks, transaction_id, version); |
| 194 } | 194 } |
| 195 | 195 |
| 196 } // namespace content | 196 } // namespace content |
| OLD | NEW |