[IndexedDB] Propogating changes to observers : Renderer

content/browser/indexed_db/indexed_db_transaction.h

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..e7d9033e9ad1fd28b4d0aab3782b92f9d4a12aa6 100644
--- a/content/browser/indexed_db/indexed_db_transaction.h
+++ b/content/browser/indexed_db/indexed_db_transaction.h
@@ -28,7 +28,9 @@ 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>) {
@@ -65,10 +67,21 @@ class CONTENT_EXPORT IndexedDBTransaction
     pending_preemptive_events_--;
     DCHECK_GE(pending_preemptive_events_, 0);
   }
-  void AddPendingObserver(int32_t observer_id);
+  void AddPendingObserver(int32_t observer_id,
+                          bool includeTransaction,
+                          bool noRecords,
+                          bool values);
   // 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 the last observation index to observer_id's list of recorded
+  // observation indices.
+  void RecordObserverForLastObservation(int32_t connection_id,
+                                        int32_t observer_id);
+
   IndexedDBBackingStore::Transaction* BackingStoreTransaction() {
     return transaction_.get();
   }
@@ -143,6 +156,8 @@ class CONTENT_EXPORT IndexedDBTransaction
 
   // Observers in pending queue do not listen to changes until activated.
   std::vector<std::unique_ptr<IndexedDBObserver>> pending_observers_;
+  std::map<int32_t, std::unique_ptr<IndexedDBObserverChanges>>
+      connection_changes_map_;
 
   class TaskQueue {
    public: