[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..e7c291180a7cb14425154e0c3ea48b0906ecd509 100644
--- a/content/browser/indexed_db/indexed_db_transaction.h
+++ b/content/browser/indexed_db/indexed_db_transaction.h
@@ -21,6 +21,7 @@
 #include "content/browser/indexed_db/indexed_db_connection.h"
 #include "content/browser/indexed_db/indexed_db_database.h"
 #include "content/browser/indexed_db/indexed_db_database_error.h"
+#include "content/browser/indexed_db/indexed_db_observer_changes.h"
 #include "third_party/WebKit/public/platform/modules/indexeddb/WebIDBTypes.h"
 
 namespace content {
@@ -29,10 +30,13 @@ class BlobWriteCallbackImpl;
 class IndexedDBCursor;
 class IndexedDBDatabaseCallbacks;
 class IndexedDBObserver;
+class IndexedDBObservation;
 
 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);
+
   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();