[IndexedDB] Propogating Changes to Observer : Browser

content/child/indexed_db/indexed_db_dispatcher.cc

 // 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.
 
 #include "content/child/indexed_db/indexed_db_dispatcher.h"
 
 #include <utility>
 
 #include "base/format_macros.h"
 #include "base/lazy_instance.h"
@@ skipping 155 matching lines @@
 
 bool IndexedDBDispatcher::Send(IPC::Message* msg) {
   return thread_safe_sender_->Send(msg);
 }
 
 int32_t IndexedDBDispatcher::AddIDBObserver(
     int32_t ipc_database_id,
     int64_t transaction_id,
     std::unique_ptr<WebIDBObserver> observer) {
   int32_t observer_id = observers_.Add(observer.release());
-  Send(new IndexedDBHostMsg_DatabaseObserve(ipc_database_id, transaction_id,
-                                            observer_id));
+  IndexedDBHostMsg_DatabaseObserve_Params params;
+  // TODO(palakj): Other params are assigned values as a part of next cl.
+  params.ipc_database_id = ipc_database_id;
+  params.transaction_id = transaction_id;
+  params.observer_id = observer_id;
+  Send(new IndexedDBHostMsg_DatabaseObserve(params));
   return observer_id;
 }
 
 void IndexedDBDispatcher::RemoveIDBObserversFromDatabase(
     int32_t ipc_database_id,
     const std::vector<int32_t>& observer_ids_to_remove) {
   for (int32_t id_to_remove : observer_ids_to_remove) {
     observers_.Remove(id_to_remove);
   }
   Send(new IndexedDBHostMsg_DatabaseUnobserve(ipc_database_id,
@@ skipping 639 matching lines @@
   typedef std::map<int32_t, WebIDBCursorImpl*>::iterator Iterator;
   for (Iterator i = cursors_.begin(); i != cursors_.end(); ++i) {
     if (i->first == ipc_exception_cursor_id ||
         i->second->transaction_id() != transaction_id)
       continue;
     i->second->ResetPrefetchCache();
   }
 }
 
 }  // namespace content