IDBObserver: Lifetime Management: Adding Observer

content/child/indexed_db/indexed_db_dispatcher.cc

Index: content/child/indexed_db/indexed_db_dispatcher.cc
diff --git a/content/child/indexed_db/indexed_db_dispatcher.cc b/content/child/indexed_db/indexed_db_dispatcher.cc
index aa40cca350f2e8548188b939f202ec53a261f290..0e6ee3353172ec66cbcfcc78bf87a6e9e6f6ad45 100644
--- a/content/child/indexed_db/indexed_db_dispatcher.cc
+++ b/content/child/indexed_db/indexed_db_dispatcher.cc
@@ -21,6 +21,7 @@
 #include "third_party/WebKit/public/platform/modules/indexeddb/WebIDBDatabaseException.h"
 #include "third_party/WebKit/public/platform/modules/indexeddb/WebIDBValue.h"
 
+using blink::IDBObserver;
 using blink::WebBlobInfo;
 using blink::WebData;
 using blink::WebIDBCallbacks;
@@ -167,6 +168,19 @@ bool IndexedDBDispatcher::Send(IPC::Message* msg) {
   return thread_safe_sender_->Send(msg);
 }
 
+void IndexedDBDispatcher::AddIDBObserver(int32_t ipc_database_id,
+                                         int64_t transaction_id,
+                                         blink::IDBObserver* observer) {
+  int64_t observer_id = maxObserverId++;

[dmurph, 2016/06/15 12:49:43]

If you change to IDMap, we get this id from the 'insert' call into the map.

+  observers_[observer_id] = observer;
+  IndexedDBHostMsg_DatabaseObserve_Params params;
+  params.ipc_thread_id = CurrentWorkerId();
+  params.ipc_database_id = ipc_database_id;
+  params.transaction_id = transaction_id;
+  params.observer_id = observer_id;
+  Send(new IndexedDBHostMsg_DatabaseObserve(params));
+}
+
 void IndexedDBDispatcher::RequestIDBCursorAdvance(
     unsigned long count,
     WebIDBCallbacks* callbacks_ptr,