Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(75)

Unified Diff: content/browser/indexed_db/indexed_db_connection.h

Issue 2472213003: [IndexedDB] Refactoring to remove ref ptrs and host transaction ids. (Closed)
Patch Set: comments & rebase Created 4 years, 1 month ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: content/browser/indexed_db/indexed_db_connection.h
diff --git a/content/browser/indexed_db/indexed_db_connection.h b/content/browser/indexed_db/indexed_db_connection.h
index ce60ebd8cc5f6cf33d5f811011e0a24d4cc40abc..77988f52581affd97c75aedb354c1de39c7cfa51 100644
--- a/content/browser/indexed_db/indexed_db_connection.h
+++ b/content/browser/indexed_db/indexed_db_connection.h
@@ -6,20 +6,26 @@
#define CONTENT_BROWSER_INDEXED_DB_INDEXED_DB_CONNECTION_H_
#include <memory>
+#include <unordered_map>
#include <vector>
#include "base/macros.h"
#include "base/memory/ref_counted.h"
#include "base/memory/weak_ptr.h"
#include "content/browser/indexed_db/indexed_db_database.h"
-#include "content/browser/indexed_db/indexed_db_database_callbacks.h"
-#include "content/browser/indexed_db/indexed_db_observer.h"
+#include "url/origin.h"
namespace content {
+class IndexedDBDatabaseCallbacks;
+class IndexedDBDatabaseError;
+class IndexedDBObserver;
+class IndexedDBTransaction;
class CONTENT_EXPORT IndexedDBConnection {
public:
- IndexedDBConnection(scoped_refptr<IndexedDBDatabase> db,
+ IndexedDBConnection(int child_process_id,
+ const url::Origin& origin,
+ scoped_refptr<IndexedDBDatabase> db,
scoped_refptr<IndexedDBDatabaseCallbacks> callbacks);
virtual ~IndexedDBConnection();
@@ -38,6 +44,8 @@ class CONTENT_EXPORT IndexedDBConnection {
virtual void RemoveObservers(const std::vector<int32_t>& remove_observer_ids);
int32_t id() const { return id_; }
+ int child_process_id() const { return child_process_id_; }
+ const url::Origin& origin() const { return origin_; }
IndexedDBDatabase* database() const { return database_.get(); }
IndexedDBDatabaseCallbacks* callbacks() const { return callbacks_.get(); }
@@ -49,11 +57,48 @@ class CONTENT_EXPORT IndexedDBConnection {
return weak_factory_.GetWeakPtr();
}
+ // Creates a transaction for this connection.
+ IndexedDBTransaction* CreateTransaction(
+ int64_t id,
+ const std::set<int64_t>& scope,
+ blink::WebIDBTransactionMode mode,
+ IndexedDBBackingStore::Transaction* backing_store_transaction);
+
+ void AbortTransaction(IndexedDBTransaction* transaction);
+ void AbortTransaction(IndexedDBTransaction* transaction,
+ const IndexedDBDatabaseError& error);
+
+ void AbortAllTransactions(const IndexedDBDatabaseError& error);
+
+ IndexedDBTransaction* GetTransaction(int64_t id);
+
+ IndexedDBTransaction* StoreTransactionForTesting(
+ std::unique_ptr<IndexedDBTransaction> transaction);
+
+ // We ignore calls where the id doesn't exist to facilitate our AbortAll call
+ // below.
jsbell 2016/11/08 00:42:52 above?
dmurph 2016/11/09 00:27:32 Clarified.
+ // TODO(dmurph): Change this to make aborting more robust.
+ void EraseTransaction(int64_t id);
+
+ const std::unordered_map<int64_t, std::unique_ptr<IndexedDBTransaction>>&
+ transactions() const {
+ return transactions_;
+ }
+
private:
const int32_t id_;
+ // The process id of the child process this connection is associated with.
+ // Tracked for IndexedDBContextImpl::GetAllOriginsDetails and debugging.
+ const int child_process_id_;
+ // The origin that this connection was created from.
jsbell 2016/11/08 00:42:52 Now that I think about it, this can be derived fro
dmurph 2016/11/09 00:27:32 Done.
+ const url::Origin origin_;
+
// NULL in some unit tests, and after the connection is closed.
scoped_refptr<IndexedDBDatabase> database_;
+ // The connection owns transactions created on this connection.
+ std::unordered_map<int64_t, std::unique_ptr<IndexedDBTransaction>>
+ transactions_;
// The callbacks_ member is cleared when the connection is closed.
// May be NULL in unit tests.

Powered by Google App Engine
This is Rietveld 408576698