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_database.h" | 5 #include "content/browser/indexed_db/indexed_db_database.h" |
6 | 6 |
7 #include <math.h> | 7 #include <math.h> |
8 #include <set> | 8 #include <set> |
9 | 9 |
10 #include "base/auto_reset.h" | 10 #include "base/auto_reset.h" |
(...skipping 1571 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1582 } | 1582 } |
1583 metadata_.version = kNoStringVersion; | 1583 metadata_.version = kNoStringVersion; |
1584 metadata_.id = kInvalidId; | 1584 metadata_.id = kInvalidId; |
1585 metadata_.int_version = IndexedDBDatabaseMetadata::NO_INT_VERSION; | 1585 metadata_.int_version = IndexedDBDatabaseMetadata::NO_INT_VERSION; |
1586 metadata_.object_stores.clear(); | 1586 metadata_.object_stores.clear(); |
1587 callbacks->OnSuccess(); | 1587 callbacks->OnSuccess(); |
1588 if (factory_) | 1588 if (factory_) |
1589 factory_->DatabaseDeleted(identifier_); | 1589 factory_->DatabaseDeleted(identifier_); |
1590 } | 1590 } |
1591 | 1591 |
1592 void IndexedDBDatabase::ForceClose() { | |
1593 // IndexedDBConnection::ForceClose() may delete this database, so hold ref. | |
1594 scoped_refptr<IndexedDBDatabase> protect(this); | |
1595 ConnectionSet::const_iterator it = connections_.begin(); | |
1596 while (it != connections_.end()) { | |
1597 IndexedDBConnection* connection = *it++; | |
1598 connection->ForceClose(); | |
1599 } | |
1600 DCHECK(connections_.empty()); | |
1601 } | |
1602 | |
1603 void IndexedDBDatabase::Close(IndexedDBConnection* connection, bool forced) { | 1592 void IndexedDBDatabase::Close(IndexedDBConnection* connection, bool forced) { |
1604 DCHECK(connections_.count(connection)); | 1593 DCHECK(connections_.count(connection)); |
1605 DCHECK(connection->IsConnected()); | 1594 DCHECK(connection->IsConnected()); |
1606 DCHECK(connection->database() == this); | 1595 DCHECK(connection->database() == this); |
1607 | 1596 |
1608 // Abort outstanding transactions from the closing connection. This | 1597 // Abort outstanding transactions from the closing connection. This |
1609 // can not happen if the close is requested by the connection itself | 1598 // can not happen if the close is requested by the connection itself |
1610 // as the front-end defers the close until all transactions are | 1599 // as the front-end defers the close until all transactions are |
1611 // complete, but can occur on process termination or forced close. | 1600 // complete, but can occur on process termination or forced close. |
1612 { | 1601 { |
(...skipping 58 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1671 const base::string16& previous_version, | 1660 const base::string16& previous_version, |
1672 int64 previous_int_version, | 1661 int64 previous_int_version, |
1673 IndexedDBTransaction* transaction) { | 1662 IndexedDBTransaction* transaction) { |
1674 IDB_TRACE("IndexedDBDatabase::VersionChangeAbortOperation"); | 1663 IDB_TRACE("IndexedDBDatabase::VersionChangeAbortOperation"); |
1675 DCHECK(!transaction); | 1664 DCHECK(!transaction); |
1676 metadata_.version = previous_version; | 1665 metadata_.version = previous_version; |
1677 metadata_.int_version = previous_int_version; | 1666 metadata_.int_version = previous_int_version; |
1678 } | 1667 } |
1679 | 1668 |
1680 } // namespace content | 1669 } // namespace content |
OLD | NEW |