[IndexedDB] Propogating changes to observers : Renderer

content/child/indexed_db/indexed_db_dispatcher.h

 // Copyright 2013 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #ifndef CONTENT_CHILD_INDEXED_DB_INDEXED_DB_DISPATCHER_H_
 #define CONTENT_CHILD_INDEXED_DB_INDEXED_DB_DISPATCHER_H_
 
 #include <stddef.h>
 #include <stdint.h>
 
@@ skipping 17 matching lines @@
 #include "third_party/WebKit/public/platform/modules/indexeddb/WebIDBTypes.h"
 #include "url/origin.h"
 
 struct IndexedDBDatabaseMetadata;
 struct IndexedDBMsg_CallbacksSuccessCursorContinue_Params;
 struct IndexedDBMsg_CallbacksSuccessCursorPrefetch_Params;
 struct IndexedDBMsg_CallbacksSuccessIDBCursor_Params;
 struct IndexedDBMsg_CallbacksSuccessArray_Params;
 struct IndexedDBMsg_CallbacksSuccessValue_Params;
 struct IndexedDBMsg_CallbacksUpgradeNeeded_Params;
+struct IndexedDBMsg_Observation;
+struct IndexedDBMsg_ObserverChanges;
 
 namespace blink {
 class WebData;
+struct WebIDBObservation;
 }
 
 namespace content {
 class IndexedDBKey;
 class IndexedDBKeyPath;
 class IndexedDBKeyRange;
 class WebIDBCursorImpl;
 class WebIDBDatabaseImpl;
 class ThreadSafeSender;
 
@@ skipping 11 matching lines @@
   // |thread_safe_sender| needs to be passed in because if the call leads to
   // construction it will be needed.
   static IndexedDBDispatcher* ThreadSpecificInstance(
       ThreadSafeSender* thread_safe_sender);
 
   // WorkerThread::Observer implementation.
   void WillStopCurrentWorkerThread() override;
 
   static blink::WebIDBMetadata ConvertMetadata(
       const IndexedDBDatabaseMetadata& idb_metadata);
+  static std::vector<blink::WebIDBObservation> ConvertObservations(
+      const std::vector<IndexedDBMsg_Observation>& idb_observation);
 
   void OnMessageReceived(const IPC::Message& msg);
 
   // This method is virtual so it can be overridden in unit tests.
   virtual bool Send(IPC::Message* msg);
 
   int32_t AddIDBObserver(int32_t ipc_database_id,
                          int64_t transaction_id,
                          std::unique_ptr<blink::WebIDBObserver> observer);
 
@@ skipping 168 matching lines @@
                     int64_t existing_version);
   void OnUpgradeNeeded(const IndexedDBMsg_CallbacksUpgradeNeeded_Params& p);
   void OnAbort(int32_t ipc_thread_id,
                int32_t ipc_database_id,
                int64_t transaction_id,
                int code,
                const base::string16& message);
   void OnComplete(int32_t ipc_thread_id,
                   int32_t ipc_database_id,
                   int64_t transaction_id);
+  void OnDatabaseChanges(int32_t ipc_thread_id,
+                         int32_t ipc_database_id,
+                         const IndexedDBMsg_ObserverChanges&);
+
   void OnForcedClose(int32_t ipc_thread_id, int32_t ipc_database_id);
   void OnVersionChange(int32_t ipc_thread_id,
                        int32_t ipc_database_id,
                        int64_t old_version,
                        int64_t new_version);
 
   // Reset cursor prefetch caches for all cursors except exception_cursor_id.
   void ResetCursorPrefetchCaches(int64_t transaction_id,
                                  int32_t ipc_exception_cursor_id);
 
@@ skipping 21 matching lines @@
   std::map<int32_t, WebIDBCursorImpl*> cursors_;
 
   std::map<int32_t, WebIDBDatabaseImpl*> databases_;
 
   DISALLOW_COPY_AND_ASSIGN(IndexedDBDispatcher);
 };
 
 }  // namespace content
 
 #endif  // CONTENT_CHILD_INDEXED_DB_INDEXED_DB_DISPATCHER_H_