Index: content/browser/indexed_db/indexed_db_transaction.h |
diff --git a/content/browser/indexed_db/indexed_db_transaction.h b/content/browser/indexed_db/indexed_db_transaction.h |
index e889d4389ebb2780278c1a0d38b313dccf8b4ecf..473cb801aff1d819922fec91054c5a55125a07cb 100644 |
--- a/content/browser/indexed_db/indexed_db_transaction.h |
+++ b/content/browser/indexed_db/indexed_db_transaction.h |
@@ -28,11 +28,15 @@ namespace content { |
class BlobWriteCallbackImpl; |
class IndexedDBCursor; |
class IndexedDBDatabaseCallbacks; |
+class IndexedDBObservation; |
class IndexedDBObserver; |
+class IndexedDBObserverChanges; |
class CONTENT_EXPORT IndexedDBTransaction |
: public NON_EXPORTED_BASE(base::RefCounted<IndexedDBTransaction>) { |
public: |
+ // using Changes = IndexedDBDatabase::Changes; |
+ |
typedef base::Callback<void(IndexedDBTransaction*)> Operation; |
enum State { |
@@ -69,6 +73,12 @@ class CONTENT_EXPORT IndexedDBTransaction |
// Delete pending observers with ID's listed in |pending_observer_ids|. |
void RemovePendingObservers(const std::vector<int32_t>& pending_observer_ids); |
+ // Adds observation for the connection. |
+ void AddObservation(int32_t connection_id, |
+ std::unique_ptr<IndexedDBObservation>); |
+ // Adds observation index to observer_id of connection_id. |
+ void AddObservationIndex(int32_t observer_id, int32_t connection_id); |
dmurph
2016/07/08 18:40:44
This is confusing to me. Maybe change the name lik
palakj1
2016/07/08 22:17:54
Done.
|
+ |
IndexedDBBackingStore::Transaction* BackingStoreTransaction() { |
return transaction_.get(); |
} |
@@ -144,6 +154,10 @@ class CONTENT_EXPORT IndexedDBTransaction |
// Observers in pending queue do not listen to changes until activated. |
std::vector<std::unique_ptr<IndexedDBObserver>> pending_observers_; |
+ typedef std::map<int32_t, std::unique_ptr<IndexedDBObserverChanges>> |
+ ConnectionChangeMap; |
+ ConnectionChangeMap connection_changes_map_; |
+ |
class TaskQueue { |
public: |
TaskQueue(); |