IDBObserver: Lifetime Management: Adding Observer

content/child/indexed_db/webidbdatabase_impl.h

Index: content/child/indexed_db/webidbdatabase_impl.h
diff --git a/content/child/indexed_db/webidbdatabase_impl.h b/content/child/indexed_db/webidbdatabase_impl.h
index 7d214bbd6c51f50ea8c7e7aeab5b3c6f8c7f530b..9aa23a9148f792fee81b1cd9d2b42965312d77e6 100644
--- a/content/child/indexed_db/webidbdatabase_impl.h
+++ b/content/child/indexed_db/webidbdatabase_impl.h
@@ -16,6 +16,7 @@ namespace blink {
 class WebBlobInfo;
 class WebIDBCallbacks;
 class WebIDBDatabaseCallbacks;
+class WebIDBObserver;
 class WebString;
 }
 
@@ -45,6 +46,11 @@ class WebIDBDatabaseImpl : public blink::WebIDBDatabase {
   void close() override;
   void versionChangeIgnored() override;
 
+  int32_t addObserver(blink::WebIDBObserver*, long long transactionId) override;
+  bool containsObserverId(int32_t id) override;

[cmumford, 2016/06/28 20:26:23]

make method const.

[palakj1, 2016/06/29 23:02:41]

Done.

+  void removeObservers(
+      const std::vector<int32_t>& observer_ids_to_remove) override;
+
   void get(long long transactionId,
            long long objectStoreId,
            long long indexId,
@@ -113,6 +119,7 @@ class WebIDBDatabaseImpl : public blink::WebIDBDatabase {
  private:
   int32_t ipc_database_id_;
   int32_t ipc_database_callbacks_id_;
+  std::set<int32_t> observer_ids_;
   scoped_refptr<ThreadSafeSender> thread_safe_sender_;
 };